kafkamock

Documentation

Index

• type MockKafka
  • func NewMockKafka(size int) *MockKafka
  • func (m *MockKafka) Close() error
  • func (m *MockKafka) GetMessages() chan *kafka.Message
• type MockKafkaInterface
• type MockReader
  • func NewMockReader(messages chan *kafka.Message) *MockReader
  • func (m *MockReader) Close() error
  • func (m *MockReader) ReadMessage(ctx context.Context) (kafka.Message, error)
• type MockWriter
  • func NewMockWriter(messages chan *kafka.Message) *MockWriter
  • func (m *MockWriter) Close() error
  • func (m *MockWriter) WriteMessages(ctx context.Context, msgs ...kafka.Message) error

Types

type MockKafka

type MockKafka struct {
	*MockReader
	*MockWriter
	// contains filtered or unexported fields
}

MockKafka contains MockReader and MockWriter

func NewMockKafka

func NewMockKafka(size int) *MockKafka

NewMockKafka creates a new MockKafka

func (*MockKafka) Close

func (m *MockKafka) Close() error

Close closes the MockKafka

func (*MockKafka) GetMessages

func (m *MockKafka) GetMessages() chan *kafka.Message

GetMessages gets the message channel of MockKafka

type MockKafkaInterface

type MockKafkaInterface interface {
	ReadMessage(ctx context.Context) (kafka.Message, error)
	WriteMessages(ctx context.Context, msgs ...kafka.Message) error
	Close() error
}

MockKafkaInterface defines an interface to easily replace the real Kafka client

type MockReader

type MockReader struct {
	// contains filtered or unexported fields
}

MockReader simulates the kafka.Reader interface

func NewMockReader

func NewMockReader(messages chan *kafka.Message) *MockReader

NewMockReader creates a new MockReader

func (*MockReader) Close

func (m *MockReader) Close() error

Close closes the MockReader

func (*MockReader) ReadMessage

func (m *MockReader) ReadMessage(ctx context.Context) (kafka.Message, error)

ReadMessage simulates reading a message

type MockWriter

type MockWriter struct {
	// contains filtered or unexported fields
}

MockWriter simulates the kafka.Writer interface

func NewMockWriter

func NewMockWriter(messages chan *kafka.Message) *MockWriter

NewMockWriter creates a new MockWriter

func (*MockWriter) Close

func (m *MockWriter) Close() error

Close closes the MockWriter

func (*MockWriter) WriteMessages

func (m *MockWriter) WriteMessages(ctx context.Context, msgs ...kafka.Message) error

WriteMessages simulates writing messages