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
- type ErrorFunc
- type EventFunc
- type Hook
- type Listener
- type ListenerOption
- type MockListener
- type MockListenerMockRecorder
- type MockSender
- type MockSenderMockRecorder
- type Publisher
- type PublisherOption
- type Sender
- type StreamReceiver
- type 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
- type TopicBuilder
Constants ¶
This section is empty.
Variables ¶
Functions ¶
func DefaultClientConfig ¶
func DefaultListenerConfig ¶
func DefaultTopicBuilder ¶
Types ¶
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) 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
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) EXPECT ¶
func (m *MockSender) EXPECT() *MockSenderMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
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
type PublisherOption ¶
type PublisherOption func(p *Publisher)
func PublisherMarshalEvent ¶
func PublisherMarshalEvent(m envelope.MarshalEvent) PublisherOption
func PublisherTopicBuilder ¶
func PublisherTopicBuilder(tb TopicBuilder) PublisherOption
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) 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 ¶
Source Files
Click to show internal directories.
Click to hide internal directories.