Documentation
¶
Index ¶
- type Client
- func (_m *Client) Close()
- func (_m *Client) CreateProducer(_a0 pulsar.ProducerOptions) (pulsar.Producer, error)
- func (_m *Client) CreateReader(_a0 pulsar.ReaderOptions) (pulsar.Reader, error)
- func (_m *Client) CreateTableView(_a0 pulsar.TableViewOptions) (pulsar.TableView, error)
- func (_m *Client) Subscribe(_a0 pulsar.ConsumerOptions) (pulsar.Consumer, error)
- func (_m *Client) TopicPartitions(topic string) ([]string, error)
- type Consumer
- func (_m *Consumer) Ack(_a0 pulsar.Message) error
- func (_m *Consumer) AckID(_a0 pulsar.MessageID) error
- func (_m *Consumer) Chan() <-chan pulsar.ConsumerMessage
- func (_m *Consumer) Close()
- func (_m *Consumer) Nack(_a0 pulsar.Message)
- func (_m *Consumer) NackID(_a0 pulsar.MessageID)
- func (_m *Consumer) Name() string
- func (_m *Consumer) Receive(_a0 context.Context) (pulsar.Message, error)
- func (_m *Consumer) ReconsumeLater(msg pulsar.Message, delay time.Duration)
- func (_m *Consumer) Seek(_a0 pulsar.MessageID) error
- func (_m *Consumer) SeekByTime(_a0 time.Time) error
- func (_m *Consumer) Subscription() string
- func (_m *Consumer) Unsubscribe() error
- type Message
- func (_m *Message) BrokerPublishTime() *time.Time
- func (_m *Message) EventTime() time.Time
- func (_m *Message) GetEncryptionContext() *pulsar.EncryptionContext
- func (_m *Message) GetReplicatedFrom() string
- func (_m *Message) GetSchemaValue(v interface{}) error
- func (_m *Message) ID() pulsar.MessageID
- func (_m *Message) Index() *uint64
- func (_m *Message) IsReplicated() bool
- func (_m *Message) Key() string
- func (_m *Message) OrderingKey() string
- func (_m *Message) Payload() []byte
- func (_m *Message) ProducerName() string
- func (_m *Message) Properties() map[string]string
- func (_m *Message) PublishTime() time.Time
- func (_m *Message) RedeliveryCount() uint32
- func (_m *Message) SchemaVersion() []byte
- func (_m *Message) Topic() string
- type Producer
- func (_m *Producer) Close()
- func (_m *Producer) Flush() error
- func (_m *Producer) LastSequenceID() int64
- func (_m *Producer) Name() string
- func (_m *Producer) Send(_a0 context.Context, _a1 *pulsar.ProducerMessage) (pulsar.MessageID, error)
- func (_m *Producer) SendAsync(_a0 context.Context, _a1 *pulsar.ProducerMessage, ...)
- func (_m *Producer) Topic() string
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
Client is an autogenerated mock type for the Client type
func NewClient ¶
func NewClient(t mockConstructorTestingTNewClient) *Client
NewClient creates a new instance of Client. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Client) CreateProducer ¶
CreateProducer provides a mock function with given fields: _a0
func (*Client) CreateReader ¶
CreateReader provides a mock function with given fields: _a0
func (*Client) CreateTableView ¶ added in v10.0.8
CreateTableView provides a mock function with given fields: _a0
type Consumer ¶
Consumer is an autogenerated mock type for the Consumer type
func NewConsumer ¶
func NewConsumer(t mockConstructorTestingTNewConsumer) *Consumer
NewConsumer creates a new instance of Consumer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Consumer) Chan ¶
func (_m *Consumer) Chan() <-chan pulsar.ConsumerMessage
Chan provides a mock function with given fields:
func (*Consumer) Close ¶
func (_m *Consumer) Close()
Close provides a mock function with given fields:
func (*Consumer) ReconsumeLater ¶
ReconsumeLater provides a mock function with given fields: msg, delay
func (*Consumer) SeekByTime ¶
SeekByTime provides a mock function with given fields: _a0
func (*Consumer) Subscription ¶
Subscription provides a mock function with given fields:
func (*Consumer) Unsubscribe ¶
Unsubscribe provides a mock function with given fields:
type Message ¶
Message is an autogenerated mock type for the Message type
func NewMessage ¶
func NewMessage(t mockConstructorTestingTNewMessage) *Message
NewMessage creates a new instance of Message. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Message) BrokerPublishTime ¶ added in v10.0.8
BrokerPublishTime provides a mock function with given fields:
func (*Message) GetEncryptionContext ¶
func (_m *Message) GetEncryptionContext() *pulsar.EncryptionContext
GetEncryptionContext provides a mock function with given fields:
func (*Message) GetReplicatedFrom ¶
GetReplicatedFrom provides a mock function with given fields:
func (*Message) GetSchemaValue ¶
GetSchemaValue provides a mock function with given fields: v
func (*Message) IsReplicated ¶
IsReplicated provides a mock function with given fields:
func (*Message) OrderingKey ¶
OrderingKey provides a mock function with given fields:
func (*Message) ProducerName ¶
ProducerName provides a mock function with given fields:
func (*Message) Properties ¶
Properties provides a mock function with given fields:
func (*Message) PublishTime ¶
PublishTime provides a mock function with given fields:
func (*Message) RedeliveryCount ¶
RedeliveryCount provides a mock function with given fields:
func (*Message) SchemaVersion ¶ added in v10.0.8
SchemaVersion provides a mock function with given fields:
type Producer ¶
Producer is an autogenerated mock type for the Producer type
func NewProducer ¶
func NewProducer(t mockConstructorTestingTNewProducer) *Producer
NewProducer creates a new instance of Producer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Producer) Close ¶
func (_m *Producer) Close()
Close provides a mock function with given fields:
func (*Producer) LastSequenceID ¶
LastSequenceID provides a mock function with given fields:
func (*Producer) Send ¶
func (_m *Producer) Send(_a0 context.Context, _a1 *pulsar.ProducerMessage) (pulsar.MessageID, error)
Send provides a mock function with given fields: _a0, _a1
Source Files