kafka

type Client interface {
	Send(ctx context.Context, topic string, routeKey string, message []byte) (err error)
	Close() error
}

type ConsumerOption func(*DefaultConsumer)

type ConsumerRequestFunc func(context.Context) context.Context

type DecodeMessageFunc func(ctx context.Context, msg []byte) (request interface{}, err error)

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

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

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

type EncodeMessageFunc func(ctx context.Context, request interface{}) (msg []byte, err error)

type ErrorFunc func(ctx context.Context, err error)

type Hook func()

type Listener interface {
	Listen(ctx context.Context, topic string, group string, fn MessageFunc) error
	Close() error
}

type ListenerOption func(l *listener)

type M struct {
	Topic    string
	RouteKey string
	Payload  []byte
}

type MessageFunc func(ctx context.Context, bytes []byte) error

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

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

type TopicBuilder func(string) string