MCPcopy Create free account

hub / github.com/IBM/sarama / functions

Functions3,668 in github.com/IBM/sarama

⨍ Functions 3,668◇ Types & classes 511
↓ 3 callersMethodLeaderAndEpoch
LeaderAndEpoch returns the leader and its epoch for the current topic/partition, as determined by querying the cluster metadata.
client.go:61
↓ 3 callersMethodLeastLoadedBroker
LeastLoadedBroker returns the broker with the least pending requests. Firstly, choose the broker from cached broker list. If the broker list is empty,
client.go:792
↓ 3 callersMethodLeaveGroup
LeaveGroup return a leave group response or error
broker.go:659
↓ 3 callersMethodListTopics
List the topics available in the cluster with the default options.
admin.go:27
↓ 3 callersMethodMemberID
MemberID returns the cluster member ID.
consumer_group_session.go:16
↓ 3 callersMethodMessageRequiresConsistency
MessageRequiresConsistency is similar to Partitioner.RequiresConsistency, but takes in the message being partitioned so that the partitioner can make
partitioner.go:38
↓ 3 callersFunctionNewConfig
(clientCert, clientKey string)
tools/tls/config.go:5
↓ 3 callersFunctionNewExponentialBackoff
NewExponentialBackoff returns a function that implements an exponential backoff strategy with jitter. It follows KIP-580, implementing the formula: MI
utils.go:370
↓ 3 callersFunctionNewListTransactionsRequest
NewListTransactionsRequest returns a ListTransactionsRequest for the given Kafka version with DurationFilter defaulted to -1 (no filter). Prefer this
list_transactions_request.go:40
↓ 3 callersFunctionNewMockCreateAclsResponse
(t TestReporter)
mockresponses.go:1060
↓ 3 callersFunctionNewMockCreatePartitionsResponse
(t TestReporter)
mockresponses.go:735
↓ 3 callersFunctionNewMockCreateTopicsResponse
(t TestReporter)
mockresponses.go:680
↓ 3 callersFunctionNewMockDeleteRecordsResponse
(t TestReporter)
mockresponses.go:821
↓ 3 callersFunctionNewMockDeleteTopicsResponse
(t TestReporter)
mockresponses.go:710
↓ 3 callersMethodPeek
Peek returns the head element. It panics if the queue is empty.
internal/queue/queue.go:46
↓ 3 callersMethodPrint
(v ...any)
sarama.go:128
↓ 3 callersMethodRemove
Remove pops and returns the head element. It panics if the queue is empty.
internal/queue/queue.go:54
↓ 3 callersMethodReplicas
Replicas returns the set of all replica IDs for the given partition.
client.go:64
↓ 3 callersMethodSendMessage
Implement SyncProducer interface SendMessage corresponds with the SendMessage method of sarama's SyncProducer implementation. You have to set expect
mocks/sync_producer.go:61
↓ 3 callersMethodSetLastOffsetDelta
(topic string, partition int32, offset int32)
fetch_response.go:737
↓ 3 callersMethodSetLastStableOffset
(topic string, partition int32, offset int64)
fetch_response.go:747
↓ 3 callersMethodStep
Step steps client through the SCRAM exchange. It is called repeatedly until it errors or `Done` returns true.
broker.go:125
↓ 3 callersMethodTopics
Topics returns the set of available topics as retrieved from cluster metadata.
client.go:45
↓ 3 callersMethodUpdateFeatures
Update the maximum version level of finalized features. This operation is supported by brokers with version 2.7.0.0 or higher.
admin.go:181
↓ 3 callersMethodWritablePartitions
WritablePartitions returns the sorted list of all writable partition IDs for the given topic, where "writable" means "having a valid leader accepting
client.go:53
↓ 3 callersMethodabortableErrorIfPossible
if kafka cluster is at least 2.5.0 mark txnmngr to bump epoch else mark it as fatal.
transaction_manager.go:606
↓ 3 callersMethodadd
(msg *ProducerMessage)
produce_set.go:39
↓ 3 callersFunctionallocateBody
(key, version int16)
request.go:125
↓ 3 callersFunctionassertDoneWithin
(t *testing.T, ch <-chan T, timeout time.Duration)
async_producer_test.go:1796
↓ 3 callersFunctionassertNotDone
(t *testing.T, ch <-chan T, wait time.Duration)
async_producer_test.go:1786
↓ 3 callersFunctionbenchmarkProduceRequestEncodeMetrics
(b *testing.B, partitions int)
produce_request_test.go:156
↓ 3 callersMethodcloseLocked
closeLocked closes the broker connection and resets state. NOTE: caller must hold b.lock.
broker.go:396
↓ 3 callersFunctioncloseProducerWithTimeout
(t *testing.T, p AsyncProducer, timeout time.Duration)
helpers_test.go:19
↓ 3 callersFunctioncompress
(cc CompressionCodec, level int, data []byte)
compress.go:112
↓ 3 callersMethodcomputeBackoff
Compute retry backoff considered current attempts.
transaction_manager.go:260
↓ 3 callersFunctioncomputeMetadataBackoff
(conf *Config, attemptsRemaining int)
client.go:1187
↓ 3 callersMethodcontrollerError
(code KError, msg *string)
admin.go:310
↓ 3 callersMethodcovers
(topic string, partition int32)
offset_manager.go:271
↓ 3 callersMethoddecode
(pd packetDecoder, version int16)
describe_client_quotas_response.go:223
↓ 3 callersFunctiondecodeRequest
(r io.Reader)
request.go:93
↓ 3 callersFunctiondecompress
(cc CompressionCodec, data []byte)
decompress.go:132
↓ 3 callersFunctiondependsOnSpecificNode
Returns a bool indicating whether the resource request needs to go to a specific broker
admin.go:825
↓ 3 callersMethodderegisterBroker
deregisterBroker removes a broker from the broker list, and if it's not in the broker list, removes it from seedBrokers.
client.go:765
↓ 3 callersMethoddispatcher
()
consumer.go:560
↓ 3 callersFunctionencodeKV
(key, value Encoder)
fetch_response.go:620
↓ 3 callersFunctionendOffsetForPartition
(t *testing.T, topic string, partition int32)
functional_java_interop_test.go:202
↓ 3 callersMethodensureRecords
(topic string, partition int32)
produce_request.go:288
↓ 3 callersMethoderrors
errors returns the per-topic errors in deterministic (sorted by topic) order.
metadata.go:47
↓ 3 callersMethodflushRetryBuffers
()
async_producer.go:930
↓ 3 callersMethodgetReplicas
(topic string, partitionID int32, extractor func(metadata *PartitionMetadata) []int32)
client.go:436
↓ 3 callersMethodgroupStrategies
groupStrategies gives the deprecated Strategy field precedence when set
config.go:612
↓ 3 callersMethodhandleResponse
(response *brokerProducerResponse)
async_producer.go:1354
↓ 3 callersFunctionhandleResponsePromise
(req protocolBody, res protocolBody, promise *responsePromise, metricRegistry metrics.Registry)
broker.go:1253
↓ 3 callersFunctioninitHandledOffsetManager
(t *testing.T, config *Config, commit MockResponse)
offset_manager_test.go:956
↓ 3 callersFunctionintersection
Produces the intersection of two slices From https://github.com/juliangruber/go-intersect
balance_strategy_test.go:2264
↓ 3 callersMethodisAnyMuted
isAnyMuted reports whether any partition in the set has an in-flight batch. Requires: m.mu held.
async_producer.go:152
↓ 3 callersFunctionisConnectionClosedError
(err error)
mockbroker.go:381
↓ 3 callersMethodisControl
()
records.go:146
↓ 3 callersFunctionisTimeoutError
(err error)
admin.go:287
↓ 3 callersMethodjoinSync
joinSync separates group negotiation from session lifetime so a session can survive a rejoin
consumer_group.go:319
↓ 3 callersFunctionmemberAssignmentsIncludeTopicPartition
(assignments []topicPartitionAssignment, topic topicPartitionAssignment)
balance_strategy.go:710
↓ 3 callersFunctionnewCRC32Field
(polynomial crcPolynomial)
crc32_field.go:49
↓ 3 callersFunctionnewConsumer
(client Client)
consumer.go:133
↓ 3 callersFunctionnewDecompressedBatchTooLargeError
(cc CompressionCodec, limit int)
decompress.go:40
↓ 3 callersFunctionnewKafkaVersion
(major, minor, veryMinor, patch uint)
utils.go:123
↓ 3 callersFunctionnewMetricValidators
()
metrics_helpers_test.go:17
↓ 3 callersFunctionnewOffsetManagerFromClient
(group, memberID string, generation int32, client Client, sessionCanceler context.CancelCauseFunc)
offset_manager.go:60
↓ 3 callersFunctionnewProduceSetWithMeta
(parent *asyncProducer, producerID int64, producerEpoch int16)
produce_set.go:30
↓ 3 callersFunctionnewTestAdminAt
newTestAdminAt is like newTestAdmin but with a caller-chosen KafkaVersion.
admin_test.go:2144
↓ 3 callersMethodnextOffset
()
records.go:208
↓ 3 callersMethodparseResponse
(response *FetchResponse)
consumer.go:872
↓ 3 callersFunctionprintMetrics
(w io.Writer, r metrics.Registry)
tools/kafka-producer-performance/main.go:420
↓ 3 callersMethodputInt16
(in int16)
real_encoder.go:30
↓ 3 callersMethodputRawBytes
collection
real_encoder.go:81
↓ 3 callersMethodreadyToFlush
()
produce_set.go:338
↓ 3 callersMethodrefBrokerConsumer
(broker *Broker)
consumer.go:257
↓ 3 callersMethodrefreshMetadata
()
client.go:954
↓ 3 callersMethodregisterForBroker
(broker *Broker, validator *metricValidator)
metrics_helpers_test.go:25
↓ 3 callersMethodreleaseCoordinator
(b *Broker)
offset_manager.go:234
↓ 3 callersFunctionremoveTopicPartitionFromMemberAssignments
(assignments []topicPartitionAssignment, topic topicPartitionAssignment)
balance_strategy.go:701
↓ 3 callersMethodreserveLength
Returns the length of data to reserve for the output of this encoder (eg 4 bytes for a CRC32).
packet_encoder.go:59
↓ 3 callersFunctionresetProxies
(t testing.TB)
functional_test.go:464
↓ 3 callersFunctionsafeClose
(t *testing.T, o io.Closer)
examples/http_server/http_server_test.go:107
↓ 3 callersMethodsaltedPassword
(password []byte, salt []byte, iterations int)
scram_formatter.go:50
↓ 3 callersMethodsaveOffset
Saves the offset into the input buffer as the location to actually write the calculated value when able.
packet_encoder.go:56
↓ 3 callersMethodsendError
(err error)
consumer.go:486
↓ 3 callersFunctionstartDockerTestBroker
(ctx context.Context, brokerID int32)
functional_test.go:313
↓ 3 callersFunctionstopDockerTestBroker
(ctx context.Context, brokerID int32)
functional_test.go:324
↓ 3 callersMethodwaitFor
(kind string, expected interface{}, factory func() (interface{}, error))
functional_consumer_group_test.go:572
↓ 2 callersMethodAbortTxn
AbortTxn abort current transaction.
async_producer.go:81
↓ 2 callersMethodAddBatch
(topic string, partition int32, batch *RecordBatch)
produce_request.go:315
↓ 2 callersMethodAddBlock
(topic string, partitionID int32, replicas []int32)
alter_partition_reassignments_request.go:142
↓ 2 callersMethodAddBlock
(topic string, partitionIDs []int32)
list_partition_reassignments_request.go:96
↓ 2 callersMethodAddBlock
(topic string, partition int32, replicas, addingReplicas, removingReplicas []int32)
list_partition_reassignments_response.go:56
↓ 2 callersMethodAddGroup
(groupID, protocolType string)
mockresponses.go:93
↓ 2 callersMethodAddGroup
(group string)
delete_groups_request.go:69
↓ 2 callersMethodAddGroupAssignment
(memberId string, memberAssignment []byte)
sync_group_request.go:192
↓ 2 callersMethodAddMessage
(topic string, partition int32, msg *Message)
produce_request.go:298
↓ 2 callersMethodAddMessageWithTimestamp
(topic string, partition int32, key, value Encoder, offset int64, timestamp time.Time, version int8)
fetch_response.go:633
↓ 2 callersMethodAddOffsetsToTxnWithGroupMetadata
(offsets map[string][]*PartitionOffsetMetadata, groupMetadata *ConsumerGroupMetadata)
async_producer.go:471
← previousnext →401–500 of 3,668, ranked by callers