mocks

Documentation

Index

• type MarkerProducer
  • func (_m *MarkerProducer) Close() error
  • func (_m *MarkerProducer) SendEndMarker(queueID string, msg *kafka.Message) error
  • func (_m *MarkerProducer) SendKeepAliveMarker(queueID string, msg *kafka.Message, redeliveryTimeout time.Duration) error
  • func (_m *MarkerProducer) SendStartMarker(queueID string, msg *kafka.Message, redeliveryTimeout time.Duration) error
• type MessageSender
  • func (_m *MessageSender) Close() error
  • func (_m *MessageSender) Flush(ctx context.Context)
  • func (_m *MessageSender) SendMessage(queueID string, payload []byte) error
  • func (_m *MessageSender) SendMessageAsync(queueID string, payload []byte, deliveryCh chan kafka.Event)
• type MqClient
  • func (_m *MqClient) Close() error
  • func (_m *MqClient) NeedsReconnect() bool
  • func (_m *MqClient) NeedsReset() bool
  • func (_m *MqClient) NextMessage(timeout time.Duration) (*kafka.Message, error)
  • func (_m *MqClient) Processed(msg *kafka.Message) error
  • func (_m *MqClient) ProcessingInProgress(msg *kafka.Message) error
  • func (_m *MqClient) Reconnect() error
  • func (_m *MqClient) Reset() error

Types

type MarkerProducer

type MarkerProducer struct {
	mock.Mock
}

MarkerProducer is an autogenerated mock type for the MarkerProducer type

func (*MarkerProducer) Close

func (_m *MarkerProducer) Close() error

Close provides a mock function with given fields:

func (*MarkerProducer) SendEndMarker

func (_m *MarkerProducer) SendEndMarker(queueID string, msg *kafka.Message) error

SendEndMarker provides a mock function with given fields: queueID, msg

func (*MarkerProducer) SendKeepAliveMarker

func (_m *MarkerProducer) SendKeepAliveMarker(queueID string, msg *kafka.Message, redeliveryTimeout time.Duration) error

SendKeepAliveMarker provides a mock function with given fields: queueID, msg, redeliveryTimeout

func (*MarkerProducer) SendStartMarker

func (_m *MarkerProducer) SendStartMarker(queueID string, msg *kafka.Message, redeliveryTimeout time.Duration) error

SendStartMarker provides a mock function with given fields: queueID, msg, redeliveryTimeout

type MessageSender

type MessageSender struct {
	mock.Mock
}

MessageSender is an autogenerated mock type for the MessageSender type

func (*MessageSender) Close

func (_m *MessageSender) Close() error

Close provides a mock function with given fields:

func (*MessageSender) Flush

func (_m *MessageSender) Flush(ctx context.Context)

Flush provides a mock function with given fields: ctx

func (*MessageSender) SendMessage

func (_m *MessageSender) SendMessage(queueID string, payload []byte) error

SendMessage provides a mock function with given fields: queueID, payload

func (*MessageSender) SendMessageAsync

func (_m *MessageSender) SendMessageAsync(queueID string, payload []byte, deliveryCh chan kafka.Event)

SendMessageAsync provides a mock function with given fields: queueID, payload, deliveryCh

type MqClient

type MqClient struct {
	mock.Mock
}

MqClient is an autogenerated mock type for the MqClient type

func (*MqClient) Close

func (_m *MqClient) Close() error

Close provides a mock function with given fields:

func (*MqClient) NeedsReconnect

func (_m *MqClient) NeedsReconnect() bool

NeedsReconnect provides a mock function with given fields:

func (*MqClient) NeedsReset

func (_m *MqClient) NeedsReset() bool

NeedsReset provides a mock function with given fields:

func (*MqClient) NextMessage

func (_m *MqClient) NextMessage(timeout time.Duration) (*kafka.Message, error)

NextMessage provides a mock function with given fields: timeout

func (*MqClient) Processed

func (_m *MqClient) Processed(msg *kafka.Message) error

Processed provides a mock function with given fields: msg

func (*MqClient) ProcessingInProgress

func (_m *MqClient) ProcessingInProgress(msg *kafka.Message) error

ProcessingInProgress provides a mock function with given fields: msg

func (*MqClient) Reconnect

func (_m *MqClient) Reconnect() error

Reconnect provides a mock function with given fields:

func (*MqClient) Reset

func (_m *MqClient) Reset() error

Reset provides a mock function with given fields: