pulsarfakes

package
v1.16.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 10, 2023 License: MIT Imports: 4 Imported by: 0

Documentation

Overview

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FakeClient 

type FakeClient struct {
	CloseStub func()

	CreateProducerStub func(pulsar.ProducerOptions) (pulsar.Producer, error)

	CreateReaderStub func(pulsar.ReaderOptions) (pulsar.Reader, error)

	SubscribeStub func(pulsar.ConsumerOptions) (pulsar.Consumer, error)

	TopicPartitionsStub func(string) ([]string, error)
	// contains filtered or unexported fields
}

func (*FakeClient) Close 

func (fake *FakeClient) Close()

func (*FakeClient) CloseCallCount 

func (fake *FakeClient) CloseCallCount() int

func (*FakeClient) CloseCalls 

func (fake *FakeClient) CloseCalls(stub func())

func (*FakeClient) CreateProducer 

func (fake *FakeClient) CreateProducer(arg1 pulsar.ProducerOptions) (pulsar.Producer, error)

func (*FakeClient) CreateProducerArgsForCall 

func (fake *FakeClient) CreateProducerArgsForCall(i int) pulsar.ProducerOptions

func (*FakeClient) CreateProducerCallCount 

func (fake *FakeClient) CreateProducerCallCount() int

func (*FakeClient) CreateProducerCalls 

func (fake *FakeClient) CreateProducerCalls(stub func(pulsar.ProducerOptions) (pulsar.Producer, error))

func (*FakeClient) CreateProducerReturns 

func (fake *FakeClient) CreateProducerReturns(result1 pulsar.Producer, result2 error)

func (*FakeClient) CreateProducerReturnsOnCall 

func (fake *FakeClient) CreateProducerReturnsOnCall(i int, result1 pulsar.Producer, result2 error)

func (*FakeClient) CreateReader 

func (fake *FakeClient) CreateReader(arg1 pulsar.ReaderOptions) (pulsar.Reader, error)

func (*FakeClient) CreateReaderArgsForCall 

func (fake *FakeClient) CreateReaderArgsForCall(i int) pulsar.ReaderOptions

func (*FakeClient) CreateReaderCallCount 

func (fake *FakeClient) CreateReaderCallCount() int

func (*FakeClient) CreateReaderCalls 

func (fake *FakeClient) CreateReaderCalls(stub func(pulsar.ReaderOptions) (pulsar.Reader, error))

func (*FakeClient) CreateReaderReturns 

func (fake *FakeClient) CreateReaderReturns(result1 pulsar.Reader, result2 error)

func (*FakeClient) CreateReaderReturnsOnCall 

func (fake *FakeClient) CreateReaderReturnsOnCall(i int, result1 pulsar.Reader, result2 error)

func (*FakeClient) Invocations 

func (fake *FakeClient) Invocations() map[string][][]interface{}

func (*FakeClient) Subscribe 

func (fake *FakeClient) Subscribe(arg1 pulsar.ConsumerOptions) (pulsar.Consumer, error)

func (*FakeClient) SubscribeArgsForCall 

func (fake *FakeClient) SubscribeArgsForCall(i int) pulsar.ConsumerOptions

func (*FakeClient) SubscribeCallCount 

func (fake *FakeClient) SubscribeCallCount() int

func (*FakeClient) SubscribeCalls 

func (fake *FakeClient) SubscribeCalls(stub func(pulsar.ConsumerOptions) (pulsar.Consumer, error))

func (*FakeClient) SubscribeReturns 

func (fake *FakeClient) SubscribeReturns(result1 pulsar.Consumer, result2 error)

func (*FakeClient) SubscribeReturnsOnCall 

func (fake *FakeClient) SubscribeReturnsOnCall(i int, result1 pulsar.Consumer, result2 error)

func (*FakeClient) TopicPartitions 

func (fake *FakeClient) TopicPartitions(arg1 string) ([]string, error)

func (*FakeClient) TopicPartitionsArgsForCall 

func (fake *FakeClient) TopicPartitionsArgsForCall(i int) string

func (*FakeClient) TopicPartitionsCallCount 

func (fake *FakeClient) TopicPartitionsCallCount() int

func (*FakeClient) TopicPartitionsCalls 

func (fake *FakeClient) TopicPartitionsCalls(stub func(string) ([]string, error))

func (*FakeClient) TopicPartitionsReturns 

func (fake *FakeClient) TopicPartitionsReturns(result1 []string, result2 error)

func (*FakeClient) TopicPartitionsReturnsOnCall 

func (fake *FakeClient) TopicPartitionsReturnsOnCall(i int, result1 []string, result2 error)

type FakeConsumer 

type FakeConsumer struct {
	AckStub func(pulsar.Message)

	AckIDStub func(pulsar.MessageID)

	ChanStub func() <-chan pulsar.ConsumerMessage

	CloseStub func()

	NackStub func(pulsar.Message)

	NackIDStub func(pulsar.MessageID)

	NameStub func() string

	ReceiveStub func(context.Context) (pulsar.Message, error)

	ReconsumeLaterStub func(pulsar.Message, time.Duration)

	SeekStub func(pulsar.MessageID) error

	SeekByTimeStub func(time.Time) error

	SubscriptionStub func() string

	UnsubscribeStub func() error
	// contains filtered or unexported fields
}

func (*FakeConsumer) Ack 

func (fake *FakeConsumer) Ack(arg1 pulsar.Message)

func (*FakeConsumer) AckArgsForCall 

func (fake *FakeConsumer) AckArgsForCall(i int) pulsar.Message

func (*FakeConsumer) AckCallCount 

func (fake *FakeConsumer) AckCallCount() int

func (*FakeConsumer) AckCalls 

func (fake *FakeConsumer) AckCalls(stub func(pulsar.Message))

func (*FakeConsumer) AckID 

func (fake *FakeConsumer) AckID(arg1 pulsar.MessageID)

func (*FakeConsumer) AckIDArgsForCall 

func (fake *FakeConsumer) AckIDArgsForCall(i int) pulsar.MessageID

func (*FakeConsumer) AckIDCallCount 

func (fake *FakeConsumer) AckIDCallCount() int

func (*FakeConsumer) AckIDCalls 

func (fake *FakeConsumer) AckIDCalls(stub func(pulsar.MessageID))

func (*FakeConsumer) Chan 

func (fake *FakeConsumer) Chan() <-chan pulsar.ConsumerMessage

func (*FakeConsumer) ChanCallCount 

func (fake *FakeConsumer) ChanCallCount() int

func (*FakeConsumer) ChanCalls 

func (fake *FakeConsumer) ChanCalls(stub func() <-chan pulsar.ConsumerMessage)

func (*FakeConsumer) ChanReturns 

func (fake *FakeConsumer) ChanReturns(result1 <-chan pulsar.ConsumerMessage)

func (*FakeConsumer) ChanReturnsOnCall 

func (fake *FakeConsumer) ChanReturnsOnCall(i int, result1 <-chan pulsar.ConsumerMessage)

func (*FakeConsumer) Close 

func (fake *FakeConsumer) Close()

func (*FakeConsumer) CloseCallCount 

func (fake *FakeConsumer) CloseCallCount() int

func (*FakeConsumer) CloseCalls 

func (fake *FakeConsumer) CloseCalls(stub func())

func (*FakeConsumer) Invocations 

func (fake *FakeConsumer) Invocations() map[string][][]interface{}

func (*FakeConsumer) Nack 

func (fake *FakeConsumer) Nack(arg1 pulsar.Message)

func (*FakeConsumer) NackArgsForCall 

func (fake *FakeConsumer) NackArgsForCall(i int) pulsar.Message

func (*FakeConsumer) NackCallCount 

func (fake *FakeConsumer) NackCallCount() int

func (*FakeConsumer) NackCalls 

func (fake *FakeConsumer) NackCalls(stub func(pulsar.Message))

func (*FakeConsumer) NackID 

func (fake *FakeConsumer) NackID(arg1 pulsar.MessageID)

func (*FakeConsumer) NackIDArgsForCall 

func (fake *FakeConsumer) NackIDArgsForCall(i int) pulsar.MessageID

func (*FakeConsumer) NackIDCallCount 

func (fake *FakeConsumer) NackIDCallCount() int

func (*FakeConsumer) NackIDCalls 

func (fake *FakeConsumer) NackIDCalls(stub func(pulsar.MessageID))

func (*FakeConsumer) Name 

func (fake *FakeConsumer) Name() string

func (*FakeConsumer) NameCallCount 

func (fake *FakeConsumer) NameCallCount() int

func (*FakeConsumer) NameCalls 

func (fake *FakeConsumer) NameCalls(stub func() string)

func (*FakeConsumer) NameReturns 

func (fake *FakeConsumer) NameReturns(result1 string)

func (*FakeConsumer) NameReturnsOnCall 

func (fake *FakeConsumer) NameReturnsOnCall(i int, result1 string)

func (*FakeConsumer) Receive 

func (fake *FakeConsumer) Receive(arg1 context.Context) (pulsar.Message, error)

func (*FakeConsumer) ReceiveArgsForCall 

func (fake *FakeConsumer) ReceiveArgsForCall(i int) context.Context

func (*FakeConsumer) ReceiveCallCount 

func (fake *FakeConsumer) ReceiveCallCount() int

func (*FakeConsumer) ReceiveCalls 

func (fake *FakeConsumer) ReceiveCalls(stub func(context.Context) (pulsar.Message, error))

func (*FakeConsumer) ReceiveReturns 

func (fake *FakeConsumer) ReceiveReturns(result1 pulsar.Message, result2 error)

func (*FakeConsumer) ReceiveReturnsOnCall 

func (fake *FakeConsumer) ReceiveReturnsOnCall(i int, result1 pulsar.Message, result2 error)

func (*FakeConsumer) ReconsumeLater 

func (fake *FakeConsumer) ReconsumeLater(arg1 pulsar.Message, arg2 time.Duration)

func (*FakeConsumer) ReconsumeLaterArgsForCall 

func (fake *FakeConsumer) ReconsumeLaterArgsForCall(i int) (pulsar.Message, time.Duration)

func (*FakeConsumer) ReconsumeLaterCallCount 

func (fake *FakeConsumer) ReconsumeLaterCallCount() int

func (*FakeConsumer) ReconsumeLaterCalls 

func (fake *FakeConsumer) ReconsumeLaterCalls(stub func(pulsar.Message, time.Duration))

func (*FakeConsumer) Seek 

func (fake *FakeConsumer) Seek(arg1 pulsar.MessageID) error

func (*FakeConsumer) SeekArgsForCall 

func (fake *FakeConsumer) SeekArgsForCall(i int) pulsar.MessageID

func (*FakeConsumer) SeekByTime 

func (fake *FakeConsumer) SeekByTime(arg1 time.Time) error

func (*FakeConsumer) SeekByTimeArgsForCall 

func (fake *FakeConsumer) SeekByTimeArgsForCall(i int) time.Time

func (*FakeConsumer) SeekByTimeCallCount 

func (fake *FakeConsumer) SeekByTimeCallCount() int

func (*FakeConsumer) SeekByTimeCalls 

func (fake *FakeConsumer) SeekByTimeCalls(stub func(time.Time) error)

func (*FakeConsumer) SeekByTimeReturns 

func (fake *FakeConsumer) SeekByTimeReturns(result1 error)

func (*FakeConsumer) SeekByTimeReturnsOnCall 

func (fake *FakeConsumer) SeekByTimeReturnsOnCall(i int, result1 error)

func (*FakeConsumer) SeekCallCount 

func (fake *FakeConsumer) SeekCallCount() int

func (*FakeConsumer) SeekCalls 

func (fake *FakeConsumer) SeekCalls(stub func(pulsar.MessageID) error)

func (*FakeConsumer) SeekReturns 

func (fake *FakeConsumer) SeekReturns(result1 error)

func (*FakeConsumer) SeekReturnsOnCall 

func (fake *FakeConsumer) SeekReturnsOnCall(i int, result1 error)

func (*FakeConsumer) Subscription 

func (fake *FakeConsumer) Subscription() string

func (*FakeConsumer) SubscriptionCallCount 

func (fake *FakeConsumer) SubscriptionCallCount() int

func (*FakeConsumer) SubscriptionCalls 

func (fake *FakeConsumer) SubscriptionCalls(stub func() string)

func (*FakeConsumer) SubscriptionReturns 

func (fake *FakeConsumer) SubscriptionReturns(result1 string)

func (*FakeConsumer) SubscriptionReturnsOnCall 

func (fake *FakeConsumer) SubscriptionReturnsOnCall(i int, result1 string)

func (*FakeConsumer) Unsubscribe 

func (fake *FakeConsumer) Unsubscribe() error

func (*FakeConsumer) UnsubscribeCallCount 

func (fake *FakeConsumer) UnsubscribeCallCount() int

func (*FakeConsumer) UnsubscribeCalls 

func (fake *FakeConsumer) UnsubscribeCalls(stub func() error)

func (*FakeConsumer) UnsubscribeReturns 

func (fake *FakeConsumer) UnsubscribeReturns(result1 error)

func (*FakeConsumer) UnsubscribeReturnsOnCall 

func (fake *FakeConsumer) UnsubscribeReturnsOnCall(i int, result1 error)

type FakeMessage 

type FakeMessage struct {
	EventTimeStub func() time.Time

	GetEncryptionContextStub func() *pulsar.EncryptionContext

	GetReplicatedFromStub func() string

	GetSchemaValueStub func(interface{}) error

	IDStub func() pulsar.MessageID

	IsReplicatedStub func() bool

	KeyStub func() string

	OrderingKeyStub func() string

	PayloadStub func() []byte

	ProducerNameStub func() string

	PropertiesStub func() map[string]string

	PublishTimeStub func() time.Time

	RedeliveryCountStub func() uint32

	TopicStub func() string
	// contains filtered or unexported fields
}

func (*FakeMessage) EventTime 

func (fake *FakeMessage) EventTime() time.Time

func (*FakeMessage) EventTimeCallCount 

func (fake *FakeMessage) EventTimeCallCount() int

func (*FakeMessage) EventTimeCalls 

func (fake *FakeMessage) EventTimeCalls(stub func() time.Time)

func (*FakeMessage) EventTimeReturns 

func (fake *FakeMessage) EventTimeReturns(result1 time.Time)

func (*FakeMessage) EventTimeReturnsOnCall 

func (fake *FakeMessage) EventTimeReturnsOnCall(i int, result1 time.Time)

func (*FakeMessage) GetEncryptionContext 

func (fake *FakeMessage) GetEncryptionContext() *pulsar.EncryptionContext

func (*FakeMessage) GetEncryptionContextCallCount 

func (fake *FakeMessage) GetEncryptionContextCallCount() int

func (*FakeMessage) GetEncryptionContextCalls 

func (fake *FakeMessage) GetEncryptionContextCalls(stub func() *pulsar.EncryptionContext)

func (*FakeMessage) GetEncryptionContextReturns 

func (fake *FakeMessage) GetEncryptionContextReturns(result1 *pulsar.EncryptionContext)

func (*FakeMessage) GetEncryptionContextReturnsOnCall 

func (fake *FakeMessage) GetEncryptionContextReturnsOnCall(i int, result1 *pulsar.EncryptionContext)

func (*FakeMessage) GetReplicatedFrom 

func (fake *FakeMessage) GetReplicatedFrom() string

func (*FakeMessage) GetReplicatedFromCallCount 

func (fake *FakeMessage) GetReplicatedFromCallCount() int

func (*FakeMessage) GetReplicatedFromCalls 

func (fake *FakeMessage) GetReplicatedFromCalls(stub func() string)

func (*FakeMessage) GetReplicatedFromReturns 

func (fake *FakeMessage) GetReplicatedFromReturns(result1 string)

func (*FakeMessage) GetReplicatedFromReturnsOnCall 

func (fake *FakeMessage) GetReplicatedFromReturnsOnCall(i int, result1 string)

func (*FakeMessage) GetSchemaValue 

func (fake *FakeMessage) GetSchemaValue(arg1 interface{}) error

func (*FakeMessage) GetSchemaValueArgsForCall 

func (fake *FakeMessage) GetSchemaValueArgsForCall(i int) interface{}

func (*FakeMessage) GetSchemaValueCallCount 

func (fake *FakeMessage) GetSchemaValueCallCount() int

func (*FakeMessage) GetSchemaValueCalls 

func (fake *FakeMessage) GetSchemaValueCalls(stub func(interface{}) error)

func (*FakeMessage) GetSchemaValueReturns 

func (fake *FakeMessage) GetSchemaValueReturns(result1 error)

func (*FakeMessage) GetSchemaValueReturnsOnCall 

func (fake *FakeMessage) GetSchemaValueReturnsOnCall(i int, result1 error)

func (*FakeMessage) ID 

func (fake *FakeMessage) ID() pulsar.MessageID

func (*FakeMessage) IDCallCount 

func (fake *FakeMessage) IDCallCount() int

func (*FakeMessage) IDCalls 

func (fake *FakeMessage) IDCalls(stub func() pulsar.MessageID)

func (*FakeMessage) IDReturns 

func (fake *FakeMessage) IDReturns(result1 pulsar.MessageID)

func (*FakeMessage) IDReturnsOnCall 

func (fake *FakeMessage) IDReturnsOnCall(i int, result1 pulsar.MessageID)

func (*FakeMessage) Invocations 

func (fake *FakeMessage) Invocations() map[string][][]interface{}

func (*FakeMessage) IsReplicated 

func (fake *FakeMessage) IsReplicated() bool

func (*FakeMessage) IsReplicatedCallCount 

func (fake *FakeMessage) IsReplicatedCallCount() int

func (*FakeMessage) IsReplicatedCalls 

func (fake *FakeMessage) IsReplicatedCalls(stub func() bool)

func (*FakeMessage) IsReplicatedReturns 

func (fake *FakeMessage) IsReplicatedReturns(result1 bool)

func (*FakeMessage) IsReplicatedReturnsOnCall 

func (fake *FakeMessage) IsReplicatedReturnsOnCall(i int, result1 bool)

func (*FakeMessage) Key 

func (fake *FakeMessage) Key() string

func (*FakeMessage) KeyCallCount 

func (fake *FakeMessage) KeyCallCount() int

func (*FakeMessage) KeyCalls 

func (fake *FakeMessage) KeyCalls(stub func() string)

func (*FakeMessage) KeyReturns 

func (fake *FakeMessage) KeyReturns(result1 string)

func (*FakeMessage) KeyReturnsOnCall 

func (fake *FakeMessage) KeyReturnsOnCall(i int, result1 string)

func (*FakeMessage) OrderingKey 

func (fake *FakeMessage) OrderingKey() string

func (*FakeMessage) OrderingKeyCallCount 

func (fake *FakeMessage) OrderingKeyCallCount() int

func (*FakeMessage) OrderingKeyCalls 

func (fake *FakeMessage) OrderingKeyCalls(stub func() string)

func (*FakeMessage) OrderingKeyReturns 

func (fake *FakeMessage) OrderingKeyReturns(result1 string)

func (*FakeMessage) OrderingKeyReturnsOnCall 

func (fake *FakeMessage) OrderingKeyReturnsOnCall(i int, result1 string)

func (*FakeMessage) Payload 

func (fake *FakeMessage) Payload() []byte

func (*FakeMessage) PayloadCallCount 

func (fake *FakeMessage) PayloadCallCount() int

func (*FakeMessage) PayloadCalls 

func (fake *FakeMessage) PayloadCalls(stub func() []byte)

func (*FakeMessage) PayloadReturns 

func (fake *FakeMessage) PayloadReturns(result1 []byte)

func (*FakeMessage) PayloadReturnsOnCall 

func (fake *FakeMessage) PayloadReturnsOnCall(i int, result1 []byte)

func (*FakeMessage) ProducerName 

func (fake *FakeMessage) ProducerName() string

func (*FakeMessage) ProducerNameCallCount 

func (fake *FakeMessage) ProducerNameCallCount() int

func (*FakeMessage) ProducerNameCalls 

func (fake *FakeMessage) ProducerNameCalls(stub func() string)

func (*FakeMessage) ProducerNameReturns 

func (fake *FakeMessage) ProducerNameReturns(result1 string)

func (*FakeMessage) ProducerNameReturnsOnCall 

func (fake *FakeMessage) ProducerNameReturnsOnCall(i int, result1 string)

func (*FakeMessage) Properties 

func (fake *FakeMessage) Properties() map[string]string

func (*FakeMessage) PropertiesCallCount 

func (fake *FakeMessage) PropertiesCallCount() int

func (*FakeMessage) PropertiesCalls 

func (fake *FakeMessage) PropertiesCalls(stub func() map[string]string)

func (*FakeMessage) PropertiesReturns 

func (fake *FakeMessage) PropertiesReturns(result1 map[string]string)

func (*FakeMessage) PropertiesReturnsOnCall 

func (fake *FakeMessage) PropertiesReturnsOnCall(i int, result1 map[string]string)

func (*FakeMessage) PublishTime 

func (fake *FakeMessage) PublishTime() time.Time

func (*FakeMessage) PublishTimeCallCount 

func (fake *FakeMessage) PublishTimeCallCount() int

func (*FakeMessage) PublishTimeCalls 

func (fake *FakeMessage) PublishTimeCalls(stub func() time.Time)

func (*FakeMessage) PublishTimeReturns 

func (fake *FakeMessage) PublishTimeReturns(result1 time.Time)

func (*FakeMessage) PublishTimeReturnsOnCall 

func (fake *FakeMessage) PublishTimeReturnsOnCall(i int, result1 time.Time)

func (*FakeMessage) RedeliveryCount 

func (fake *FakeMessage) RedeliveryCount() uint32

func (*FakeMessage) RedeliveryCountCallCount 

func (fake *FakeMessage) RedeliveryCountCallCount() int

func (*FakeMessage) RedeliveryCountCalls 

func (fake *FakeMessage) RedeliveryCountCalls(stub func() uint32)

func (*FakeMessage) RedeliveryCountReturns 

func (fake *FakeMessage) RedeliveryCountReturns(result1 uint32)

func (*FakeMessage) RedeliveryCountReturnsOnCall 

func (fake *FakeMessage) RedeliveryCountReturnsOnCall(i int, result1 uint32)

func (*FakeMessage) Topic 

func (fake *FakeMessage) Topic() string

func (*FakeMessage) TopicCallCount 

func (fake *FakeMessage) TopicCallCount() int

func (*FakeMessage) TopicCalls 

func (fake *FakeMessage) TopicCalls(stub func() string)

func (*FakeMessage) TopicReturns 

func (fake *FakeMessage) TopicReturns(result1 string)

func (*FakeMessage) TopicReturnsOnCall 

func (fake *FakeMessage) TopicReturnsOnCall(i int, result1 string)

type FakeMessageID 

type FakeMessageID struct {
	BatchIdxStub func() int32

	EntryIDStub func() int64

	LedgerIDStub func() int64

	PartitionIdxStub func() int32

	SerializeStub func() []byte
	// contains filtered or unexported fields
}

func (*FakeMessageID) BatchIdx 

func (fake *FakeMessageID) BatchIdx() int32

func (*FakeMessageID) BatchIdxCallCount 

func (fake *FakeMessageID) BatchIdxCallCount() int

func (*FakeMessageID) BatchIdxCalls 

func (fake *FakeMessageID) BatchIdxCalls(stub func() int32)

func (*FakeMessageID) BatchIdxReturns 

func (fake *FakeMessageID) BatchIdxReturns(result1 int32)

func (*FakeMessageID) BatchIdxReturnsOnCall 

func (fake *FakeMessageID) BatchIdxReturnsOnCall(i int, result1 int32)

func (*FakeMessageID) EntryID 

func (fake *FakeMessageID) EntryID() int64

func (*FakeMessageID) EntryIDCallCount 

func (fake *FakeMessageID) EntryIDCallCount() int

func (*FakeMessageID) EntryIDCalls 

func (fake *FakeMessageID) EntryIDCalls(stub func() int64)

func (*FakeMessageID) EntryIDReturns 

func (fake *FakeMessageID) EntryIDReturns(result1 int64)

func (*FakeMessageID) EntryIDReturnsOnCall 

func (fake *FakeMessageID) EntryIDReturnsOnCall(i int, result1 int64)

func (*FakeMessageID) Invocations 

func (fake *FakeMessageID) Invocations() map[string][][]interface{}

func (*FakeMessageID) LedgerID 

func (fake *FakeMessageID) LedgerID() int64

func (*FakeMessageID) LedgerIDCallCount 

func (fake *FakeMessageID) LedgerIDCallCount() int

func (*FakeMessageID) LedgerIDCalls 

func (fake *FakeMessageID) LedgerIDCalls(stub func() int64)

func (*FakeMessageID) LedgerIDReturns 

func (fake *FakeMessageID) LedgerIDReturns(result1 int64)

func (*FakeMessageID) LedgerIDReturnsOnCall 

func (fake *FakeMessageID) LedgerIDReturnsOnCall(i int, result1 int64)

func (*FakeMessageID) PartitionIdx 

func (fake *FakeMessageID) PartitionIdx() int32

func (*FakeMessageID) PartitionIdxCallCount 

func (fake *FakeMessageID) PartitionIdxCallCount() int

func (*FakeMessageID) PartitionIdxCalls 

func (fake *FakeMessageID) PartitionIdxCalls(stub func() int32)

func (*FakeMessageID) PartitionIdxReturns 

func (fake *FakeMessageID) PartitionIdxReturns(result1 int32)

func (*FakeMessageID) PartitionIdxReturnsOnCall 

func (fake *FakeMessageID) PartitionIdxReturnsOnCall(i int, result1 int32)

func (*FakeMessageID) Serialize 

func (fake *FakeMessageID) Serialize() []byte

func (*FakeMessageID) SerializeCallCount 

func (fake *FakeMessageID) SerializeCallCount() int

func (*FakeMessageID) SerializeCalls 

func (fake *FakeMessageID) SerializeCalls(stub func() []byte)

func (*FakeMessageID) SerializeReturns 

func (fake *FakeMessageID) SerializeReturns(result1 []byte)

func (*FakeMessageID) SerializeReturnsOnCall 

func (fake *FakeMessageID) SerializeReturnsOnCall(i int, result1 []byte)

type FakeProducer 

type FakeProducer struct {
	CloseStub func()

	FlushStub func() error

	LastSequenceIDStub func() int64

	NameStub func() string

	SendStub func(context.Context, *pulsar.ProducerMessage) (pulsar.MessageID, error)

	SendAsyncStub func(context.Context, *pulsar.ProducerMessage, func(pulsar.MessageID, *pulsar.ProducerMessage, error))

	TopicStub func() string
	// contains filtered or unexported fields
}

func (*FakeProducer) Close 

func (fake *FakeProducer) Close()

func (*FakeProducer) CloseCallCount 

func (fake *FakeProducer) CloseCallCount() int

func (*FakeProducer) CloseCalls 

func (fake *FakeProducer) CloseCalls(stub func())

func (*FakeProducer) Flush 

func (fake *FakeProducer) Flush() error

func (*FakeProducer) FlushCallCount 

func (fake *FakeProducer) FlushCallCount() int

func (*FakeProducer) FlushCalls 

func (fake *FakeProducer) FlushCalls(stub func() error)

func (*FakeProducer) FlushReturns 

func (fake *FakeProducer) FlushReturns(result1 error)

func (*FakeProducer) FlushReturnsOnCall 

func (fake *FakeProducer) FlushReturnsOnCall(i int, result1 error)

func (*FakeProducer) Invocations 

func (fake *FakeProducer) Invocations() map[string][][]interface{}

func (*FakeProducer) LastSequenceID 

func (fake *FakeProducer) LastSequenceID() int64

func (*FakeProducer) LastSequenceIDCallCount 

func (fake *FakeProducer) LastSequenceIDCallCount() int

func (*FakeProducer) LastSequenceIDCalls 

func (fake *FakeProducer) LastSequenceIDCalls(stub func() int64)

func (*FakeProducer) LastSequenceIDReturns 

func (fake *FakeProducer) LastSequenceIDReturns(result1 int64)

func (*FakeProducer) LastSequenceIDReturnsOnCall 

func (fake *FakeProducer) LastSequenceIDReturnsOnCall(i int, result1 int64)

func (*FakeProducer) Name 

func (fake *FakeProducer) Name() string

func (*FakeProducer) NameCallCount 

func (fake *FakeProducer) NameCallCount() int

func (*FakeProducer) NameCalls 

func (fake *FakeProducer) NameCalls(stub func() string)

func (*FakeProducer) NameReturns 

func (fake *FakeProducer) NameReturns(result1 string)

func (*FakeProducer) NameReturnsOnCall 

func (fake *FakeProducer) NameReturnsOnCall(i int, result1 string)

func (*FakeProducer) Send 

func (fake *FakeProducer) Send(arg1 context.Context, arg2 *pulsar.ProducerMessage) (pulsar.MessageID, error)

func (*FakeProducer) SendArgsForCall 

func (fake *FakeProducer) SendArgsForCall(i int) (context.Context, *pulsar.ProducerMessage)

func (*FakeProducer) SendAsync 

func (fake *FakeProducer) SendAsync(arg1 context.Context, arg2 *pulsar.ProducerMessage, arg3 func(pulsar.MessageID, *pulsar.ProducerMessage, error))

func (*FakeProducer) SendAsyncArgsForCall 

func (fake *FakeProducer) SendAsyncArgsForCall(i int) (context.Context, *pulsar.ProducerMessage, func(pulsar.MessageID, *pulsar.ProducerMessage, error))

func (*FakeProducer) SendAsyncCallCount 

func (fake *FakeProducer) SendAsyncCallCount() int

func (*FakeProducer) SendAsyncCalls 

func (fake *FakeProducer) SendAsyncCalls(stub func(context.Context, *pulsar.ProducerMessage, func(pulsar.MessageID, *pulsar.ProducerMessage, error)))

func (*FakeProducer) SendCallCount 

func (fake *FakeProducer) SendCallCount() int

func (*FakeProducer) SendCalls 

func (fake *FakeProducer) SendCalls(stub func(context.Context, *pulsar.ProducerMessage) (pulsar.MessageID, error))

func (*FakeProducer) SendReturns 

func (fake *FakeProducer) SendReturns(result1 pulsar.MessageID, result2 error)

func (*FakeProducer) SendReturnsOnCall 

func (fake *FakeProducer) SendReturnsOnCall(i int, result1 pulsar.MessageID, result2 error)

func (*FakeProducer) Topic 

func (fake *FakeProducer) Topic() string

func (*FakeProducer) TopicCallCount 

func (fake *FakeProducer) TopicCallCount() int

func (*FakeProducer) TopicCalls 

func (fake *FakeProducer) TopicCalls(stub func() string)

func (*FakeProducer) TopicReturns 

func (fake *FakeProducer) TopicReturns(result1 string)

func (*FakeProducer) TopicReturnsOnCall 

func (fake *FakeProducer) TopicReturnsOnCall(i int, result1 string)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.