kafka

Documentation

Overview

Package kafka is a generated GoMock package.

Index

• Variables
• func DefaultClientConfig() *sarama.Config
• func DefaultListenerConfig() *sarama.Config
• func DefaultTopicBuilder(streamType string) string
• type Client
  • func NewClient(addr []string, conf *sarama.Config) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) Send(ctx context.Context, topic string, routeKey string, event []byte) (err error)
• type ErrorFunc
• type EventFunc
• type Hook
• type Listener
  • func NewListener(addr []string, conf *sarama.Config, options ...ListenerOption) Listener
• type ListenerOption
  • func ListenerErrorHandler(handler func(context.Context, error)) ListenerOption
  • func ListenerHooks(setup Hook, cleanup Hook) ListenerOption
• type MockListener
  • func NewMockListener(ctrl *gomock.Controller) *MockListener
  • func (m *MockListener) Close() error
  • func (m *MockListener) Connect(topic, group string) error
  • func (m *MockListener) EXPECT() *MockListenerMockRecorder
  • func (m *MockListener) Listen(ctx context.Context, fn EventFunc)
• type MockListenerMockRecorder
  • func (mr *MockListenerMockRecorder) Close() *gomock.Call
  • func (mr *MockListenerMockRecorder) Connect(topic, group interface{}) *gomock.Call
  • func (mr *MockListenerMockRecorder) Listen(ctx, fn interface{}) *gomock.Call
• type MockSender
  • func NewMockSender(ctrl *gomock.Controller) *MockSender
  • func (m *MockSender) Close() error
  • func (m *MockSender) EXPECT() *MockSenderMockRecorder
  • func (m *MockSender) Send(ctx context.Context, topic, routeKey string, event []byte) error
• type MockSenderMockRecorder
  • func (mr *MockSenderMockRecorder) Close() *gomock.Call
  • func (mr *MockSenderMockRecorder) Send(ctx, topic, routeKey, event interface{}) *gomock.Call
• type Publisher
  • func NewPublisher(client Sender, eventCodec es.EventCoder, options ...PublisherOption) *Publisher
  • func (p *Publisher) Close() error
  • func (p *Publisher) Publish(ctx context.Context, event es.Event) error
• type PublisherOption
  • func PublisherMarshalEvent(m envelope.MarshalEvent) PublisherOption
  • func PublisherTopicBuilder(tb TopicBuilder) PublisherOption
• type Sender
• type StreamReceiver
  • func (a *StreamReceiver) EventReceiver(eventType string, handler es.EventHandler) *StreamReceiver
  • func (a *StreamReceiver) Receiver(handler es.EventHandler) *StreamReceiver
• type Subscriber
  • func NewSubscriber(serviceName string, eventCodec es.EventCoder, newListener func() Listener, ...) *Subscriber
  • func (s *Subscriber) Close() (err error)
  • func (s *Subscriber) Filter(f ...es.Filter)
  • func (s *Subscriber) Listen(ctx context.Context) error
  • func (s *Subscriber) Stream(streamType string) *StreamReceiver
  • func (s *Subscriber) Subscribe(_ context.Context, streamType string, handler es.EventHandler) error
  • func (s *Subscriber) SubscribeToEvent(ctx context.Context, streamType string, eventType string, ...) error
• type SubscriberOption
  • func SubscriberTopicBuilder(tb TopicBuilder) SubscriberOption
  • func SubscriberUnmarshalEvent(u envelope.UnmarshalEvent) SubscriberOption
• type TopicBuilder

Variables

var (
	ErrNoReceivers       = errors.New("eventbus: no receivers")
	ErrUnknownEvent      = errors.New("eventbus: unknown event type")
	ErrUnknownStreamType = errors.New("eventbus: unknown stream type")
)

Functions

func DefaultClientConfig

func DefaultClientConfig() *sarama.Config

func DefaultListenerConfig

func DefaultListenerConfig() *sarama.Config

func DefaultTopicBuilder

func DefaultTopicBuilder(streamType string) string

Types

type Client

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

func NewClient

func NewClient(addr []string, conf *sarama.Config) (*Client, error)

func (*Client) Close

func (c *Client) Close() error

func (*Client) Send

func (c *Client) Send(ctx context.Context, topic string, routeKey string, event []byte) (err error)

type ErrorFunc

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

type EventFunc

type EventFunc func(ctx context.Context, event []byte) error

type Hook

type Hook func()

type Listener

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

func NewListener

func NewListener(addr []string, conf *sarama.Config, options ...ListenerOption) Listener

type ListenerOption

type ListenerOption func(l *listener)

func ListenerErrorHandler

func ListenerErrorHandler(handler func(context.Context, error)) ListenerOption

func ListenerHooks

func ListenerHooks(setup Hook, cleanup Hook) ListenerOption

type MockListener

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

MockListener is a mock of Listener interface

func NewMockListener

func NewMockListener(ctrl *gomock.Controller) *MockListener

NewMockListener creates a new mock instance

func (*MockListener) Close

func (m *MockListener) Close() error

Close mocks base method

func (*MockListener) Connect

func (m *MockListener) Connect(topic, group string) error

Connect mocks base method

func (*MockListener) EXPECT

func (m *MockListener) EXPECT() *MockListenerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockListener) Listen

func (m *MockListener) Listen(ctx context.Context, fn EventFunc)

Listen mocks base method

type MockListenerMockRecorder

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

MockListenerMockRecorder is the mock recorder for MockListener

func (*MockListenerMockRecorder) Close

func (mr *MockListenerMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close

func (*MockListenerMockRecorder) Connect

func (mr *MockListenerMockRecorder) Connect(topic, group interface{}) *gomock.Call

Connect indicates an expected call of Connect

func (*MockListenerMockRecorder) Listen

func (mr *MockListenerMockRecorder) Listen(ctx, fn interface{}) *gomock.Call

Listen indicates an expected call of Listen

type MockSender

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

MockSender is a mock of Sender interface

func NewMockSender

func NewMockSender(ctrl *gomock.Controller) *MockSender

NewMockSender creates a new mock instance

func (*MockSender) Close

func (m *MockSender) Close() error

Close mocks base method

func (*MockSender) EXPECT

func (m *MockSender) EXPECT() *MockSenderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockSender) Send

func (m *MockSender) Send(ctx context.Context, topic, routeKey string, event []byte) error

Send mocks base method

type MockSenderMockRecorder

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

MockSenderMockRecorder is the mock recorder for MockSender

func (*MockSenderMockRecorder) Close

func (mr *MockSenderMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close

func (*MockSenderMockRecorder) Send

func (mr *MockSenderMockRecorder) Send(ctx, topic, routeKey, event interface{}) *gomock.Call

Send indicates an expected call of Send

type Publisher

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

func NewPublisher

func NewPublisher(
	client Sender,
	eventCodec es.EventCoder,
	options ...PublisherOption,
) *Publisher

func (*Publisher) Close

func (p *Publisher) Close() error

func (*Publisher) Publish

func (p *Publisher) Publish(ctx context.Context, event es.Event) error

type PublisherOption

type PublisherOption func(p *Publisher)

func PublisherMarshalEvent

func PublisherMarshalEvent(m envelope.MarshalEvent) PublisherOption

func PublisherTopicBuilder

func PublisherTopicBuilder(tb TopicBuilder) PublisherOption

type Sender

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

type StreamReceiver

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

func (*StreamReceiver) EventReceiver

func (a *StreamReceiver) EventReceiver(eventType string, handler es.EventHandler) *StreamReceiver

func (*StreamReceiver) Receiver

func (a *StreamReceiver) Receiver(handler es.EventHandler) *StreamReceiver

type Subscriber

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

func NewSubscriber

func NewSubscriber(
	serviceName string,
	eventCodec es.EventCoder,
	newListener func() Listener,
	options ...SubscriberOption,
) *Subscriber

func (*Subscriber) Close

func (s *Subscriber) Close() (err error)

func (*Subscriber) Filter

func (s *Subscriber) Filter(f ...es.Filter)

func (*Subscriber) Listen

func (s *Subscriber) Listen(ctx context.Context) error

func (*Subscriber) Stream

func (s *Subscriber) Stream(streamType string) *StreamReceiver

func (*Subscriber) Subscribe

func (s *Subscriber) Subscribe(_ context.Context, streamType string, handler es.EventHandler) error

func (*Subscriber) SubscribeToEvent

func (s *Subscriber) SubscribeToEvent(ctx context.Context, streamType string, eventType string, handler es.EventHandler) error

type SubscriberOption

type SubscriberOption func(s *Subscriber)

func SubscriberTopicBuilder

func SubscriberTopicBuilder(tb TopicBuilder) SubscriberOption

func SubscriberUnmarshalEvent

func SubscriberUnmarshalEvent(u envelope.UnmarshalEvent) SubscriberOption

type TopicBuilder

type TopicBuilder func(string) string