kafkatest

package
v0.49.0-ntoml-functions.0 Latest Latest
Warning

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

Go to latest
Published: Feb 9, 2021 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

Types

type FakeKafkaConsumer

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

func NewFakeKafkaConsumer

func NewFakeKafkaConsumer(log logrus.FieldLogger, distri <-chan *kafka.Message) *FakeKafkaConsumer

func (*FakeKafkaConsumer) Close

func (f *FakeKafkaConsumer) Close() error

func (*FakeKafkaConsumer) CommitMessage

func (f *FakeKafkaConsumer) CommitMessage(msg *kafka.Message) error

func (*FakeKafkaConsumer) FetchMessage

func (f *FakeKafkaConsumer) FetchMessage(ctx context.Context) (*kafka.Message, error)

func (*FakeKafkaConsumer) Seek

func (f *FakeKafkaConsumer) Seek(offset int64, _ time.Duration) error

func (*FakeKafkaConsumer) SetInitialOffset

func (f *FakeKafkaConsumer) SetInitialOffset(offset int64) error

type FakeKafkaProducer

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

func NewFakeKafkaProducer

func NewFakeKafkaProducer(distris ...chan<- *kafka.Message) *FakeKafkaProducer

func (*FakeKafkaProducer) AddDistri

func (f *FakeKafkaProducer) AddDistri(d chan<- *kafka.Message)

func (*FakeKafkaProducer) Close

func (f *FakeKafkaProducer) Close() error

func (*FakeKafkaProducer) Produce

func (f *FakeKafkaProducer) Produce(ctx context.Context, msgs ...*kafka.Message) error

func (*FakeKafkaProducer) WaitForKey

func (f *FakeKafkaProducer) WaitForKey(key []byte) (gotKey bool)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL