Home
last modified time | relevance | path

Searched defs:FetchResponse (Results 1 – 25 of 30) sorted by relevance

12

/dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/
H A Dfetch_response.go224 type FetchResponse struct { struct
225 Blocks map[string]map[int32]*FetchResponseBlock
226 ThrottleTime time.Duration
227 ErrorCode int16
228 SessionID int32
229 Version int16
230 LogAppendTime bool
231 Timestamp time.Time
330 func (r *FetchResponse) key() int16 {
334 func (r *FetchResponse) version() int16 {
[all …]
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/Shopify/sarama/
H A Dfetch_response.go226 type FetchResponse struct { struct
227 Blocks map[string]map[int32]*FetchResponseBlock
228 ThrottleTime time.Duration
229 ErrorCode int16
230 SessionID int32
231 Version int16
232 LogAppendTime bool
233 Timestamp time.Time
332 func (r *FetchResponse) key() int16 {
336 func (r *FetchResponse) version() int16 {
[all …]
/dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/sarama-1.26.4/
H A Dfetch_response.go224 type FetchResponse struct { struct
225 Blocks map[string]map[int32]*FetchResponseBlock
226 ThrottleTime time.Duration
227 ErrorCode int16
228 SessionID int32
229 Version int16
230 LogAppendTime bool
231 Timestamp time.Time
330 func (r *FetchResponse) key() int16 {
334 func (r *FetchResponse) version() int16 {
[all …]
/dports/databases/tile38/tile38-1.12.0/vendor/github.com/Shopify/sarama/
H A Dfetch_response.go50 type FetchResponse struct { struct
51 Blocks map[string]map[int32]*FetchResponseBlock
52 ThrottleTime time.Duration
53 Version int16 // v1 requires 0.9+, v2 requires 0.10+
56 func (r *FetchResponse) decode(pd packetDecoder, version int16) (err error) {
104 func (r *FetchResponse) encode(pe packetEncoder) (err error) {
137 func (r *FetchResponse) key() int16 {
141 func (r *FetchResponse) version() int16 {
145 func (r *FetchResponse) requiredVersion() KafkaVersion {
156 func (r *FetchResponse) GetBlock(topic string, partition int32) *FetchResponseBlock {
[all …]
/dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/
H A Dfetch_response.go188 type FetchResponse struct { struct
189 Blocks map[string]map[int32]*FetchResponseBlock
190 ThrottleTime time.Duration
191 Version int16 // v1 requires 0.9+, v2 requires 0.10+
194 func (r *FetchResponse) decode(pd packetDecoder, version int16) (err error) {
242 func (r *FetchResponse) encode(pe packetEncoder) (err error) {
275 func (r *FetchResponse) key() int16 {
279 func (r *FetchResponse) version() int16 {
283 func (r *FetchResponse) requiredVersion() KafkaVersion {
298 func (r *FetchResponse) GetBlock(topic string, partition int32) *FetchResponseBlock {
[all …]
/dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/sarama-1.19.0/
H A Dfetch_response.go188 type FetchResponse struct { struct
189 Blocks map[string]map[int32]*FetchResponseBlock
190 ThrottleTime time.Duration
191 Version int16 // v1 requires 0.9+, v2 requires 0.10+
194 func (r *FetchResponse) decode(pd packetDecoder, version int16) (err error) {
242 func (r *FetchResponse) encode(pe packetEncoder) (err error) {
275 func (r *FetchResponse) key() int16 {
279 func (r *FetchResponse) version() int16 {
283 func (r *FetchResponse) requiredVersion() KafkaVersion {
298 func (r *FetchResponse) GetBlock(topic string, partition int32) *FetchResponseBlock {
[all …]
/dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/google/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/
H A Dfetch_response.go35 type FetchResponse struct { struct
36 Blocks map[string]map[int32]*FetchResponseBlock
52 func (fr *FetchResponse) decode(pd packetDecoder) (err error) {
90 func (fr *FetchResponse) encode(pe packetEncoder) (err error) {
119 func (fr *FetchResponse) GetBlock(topic string, partition int32) *FetchResponseBlock {
131 func (fr *FetchResponse) AddError(topic string, partition int32, err KError) {
148 …c (fr *FetchResponse) AddMessage(topic string, partition int32, key, value Encoder, offset int64) {
/dports/net-mgmt/carbonzipper/carbonzipper-0.74/carbonzipperpb/
H A Dcarbonzipper.pb.go43 type FetchResponse struct { struct
50 XXX_unrecognized []byte `json:"-"`
55 func (*FetchResponse) ProtoMessage() {}
58 func (m *FetchResponse) GetName() string {
65 func (m *FetchResponse) GetStartTime() int32 {
72 func (m *FetchResponse) GetStopTime() int32 {
79 func (m *FetchResponse) GetStepTime() int32 {
86 func (m *FetchResponse) GetValues() []float64 {
93 func (m *FetchResponse) GetIsAbsent() []bool {
692 func (m *FetchResponse) Size() (n int) {
[all …]
H A Dcarbonzipper.proto7 message FetchResponse { message
/dports/net-mgmt/carbonzipper/carbonzipper-0.74/carbonzipperpb3/
H A Dcarbonzipper3.pb.go44 type FetchResponse struct { struct
55 func (*FetchResponse) ProtoMessage() {}
58 func (m *FetchResponse) GetName() string {
65 func (m *FetchResponse) GetStartTime() int32 {
72 func (m *FetchResponse) GetStopTime() int32 {
79 func (m *FetchResponse) GetStepTime() int32 {
86 func (m *FetchResponse) GetValues() []float64 {
93 func (m *FetchResponse) GetIsAbsent() []bool {
381 func (m *FetchResponse) Marshal() (dAtA []byte, err error) {
855 func (m *FetchResponse) Size() (n int) {
[all …]
H A Dcarbonzipper3.proto7 message FetchResponse { message
/dports/java/javamail/javamail-JAVAMAIL-1_6_2/mail/src/main/java/com/sun/mail/imap/protocol/
H A DFetchResponse.java56 public class FetchResponse extends IMAPResponse { class
71 public FetchResponse(Protocol p) in FetchResponse() method in FetchResponse
78 public FetchResponse(IMAPResponse r) in FetchResponse() method in FetchResponse
92 public FetchResponse(IMAPResponse r, FetchItem[] fitems) in FetchResponse() method in FetchResponse
/dports/www/carbonapi/carbonapi-0.14.1/vendor/github.com/go-graphite/protocol/carbonapi_v2_pb/
H A Dcarbonapi_v2_pb.pb.go30 type FetchResponse struct { struct
40 func (*FetchResponse) ProtoMessage() {}
62 func (m *FetchResponse) XXX_Size() int {
65 func (m *FetchResponse) XXX_DiscardUnknown() {
71 func (m *FetchResponse) GetName() string {
78 func (m *FetchResponse) GetStartTime() int32 {
85 func (m *FetchResponse) GetStopTime() int32 {
92 func (m *FetchResponse) GetStepTime() int32 {
99 func (m *FetchResponse) GetValues() []float64 {
106 func (m *FetchResponse) GetIsAbsent() []bool {
[all …]
H A Dcarbonapi_v2_pb.proto7 message FetchResponse { message
/dports/www/carbonapi/carbonapi-0.14.1/vendor/github.com/go-graphite/protocol/carbonapi_v3_pb/
H A Dcarbonapi_v3_pb.pb.go341 type FetchResponse struct { struct
358 func (*FetchResponse) ProtoMessage() {}
380 func (m *FetchResponse) XXX_Size() int {
383 func (m *FetchResponse) XXX_DiscardUnknown() {
389 func (m *FetchResponse) GetName() string {
410 func (m *FetchResponse) GetStartTime() int64 {
417 func (m *FetchResponse) GetStopTime() int64 {
424 func (m *FetchResponse) GetStepTime() int64 {
445 func (m *FetchResponse) GetValues() []float64 {
3317 func (m *FetchResponse) Size() (n int) {
[all …]
/dports/www/carbonapi/carbonapi-0.14.1/zipper/types/
H A Dresponse.go398 func swapFetchResponses(m1, m2 *protov3.FetchResponse) {
409 func mergeFetchResponsesWithEqualStepTimes(m1, m2 *protov3.FetchResponse) merry.Error {
427 func mergeFetchResponsesWithUnequalStepTimes(m1, m2 *protov3.FetchResponse) merry.Error {
446 func MergeFetchResponses(m1, m2 *protov3.FetchResponse) merry.Error {
479 func coordinates(r *protov3.FetchResponse) fetchResponseCoordinates {
/dports/net/cloudquery/cloudquery-0.16.0/pkg/ui/console/
H A Dsummary.go11 func printFetchResponse(summary *client.FetchResponse) {
/dports/www/carbonapi/carbonapi-0.14.1/zipper/dummy/
H A Ddummy.go15 type FetchResponse struct { struct
16 Response *protov3.MultiFetchResponse
17 Stats *types.Stats
18 Errors merry.Error
/dports/www/carbonapi/carbonapi-0.14.1/zipper/
H A Dzipper_test.go28 func fetchResponseEquals(r1, r2 *protov3.FetchResponse) error {
/dports/mail/rainloop-community/rainloop-community-php74-1.16.0_1/rainloop/v/1.16.0/app/libraries/MailSo/Imap/
H A DFetchResponse.php18 class FetchResponse class
/dports/mail/rainloop/rainloop-php74-1.16.0_1/rainloop/v/1.16.0/app/libraries/MailSo/Imap/
H A DFetchResponse.php18 class FetchResponse class
/dports/www/grafana8/grafana-8.3.6/packages/grafana-runtime/src/services/
H A DbackendSrv.ts89 export interface FetchResponse<T = any> { interface
/dports/www/chromium-legacy/chromium-88.0.4324.182/chrome/browser/endpoint_fetcher/
H A Dendpoint_fetcher_unittest.cc115 TEST_F(EndpointFetcherTest, FetchResponse) { in TEST_F() argument
/dports/www/carbonapi/carbonapi-0.14.1/expr/types/
H A Dtypes.go28 pb.FetchResponse anonMember
/dports/net/py-kafka-python/kafka-python-1.4.5/kafka/protocol/
H A Dfetch.py204 FetchResponse = [ variable

12