Documentation ¶
Index ¶
- Variables
- type Base
- type Consumer
- type Producer
- func (c *Producer) Reply(ctx context.Context, event *eventv2.Event, callback *connector.SendCallback) error
- func (c *Producer) Request(ctx context.Context, event *eventv2.Event, ...) error
- func (c *Producer) Send(ctx context.Context, event *eventv2.Event, callback *connector.SendCallback) error
- func (c *Producer) Shutdown() error
- func (c *Producer) Start() error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrNoConnectorPlugin = fmt.Errorf("no connector plugin provided") ErrNoConnectorName = fmt.Errorf("no connector plugin name provided") )
Functions ¶
This section is empty.
Types ¶
type Base ¶
func DefaultBaseWrapper ¶
func DefaultBaseWrapper() *Base
type Consumer ¶
type Consumer interface { Subscribe(topicName string) error UnSubscribe(topicName string) error Init(props map[string]string) error Start() error Shutdown() error RegisterListener(lis *connector.EventListener) UpdateOffset(ctx context.Context, events []*eventv2.Event) }
func NewConsumer ¶
NewConsumer create new consumer to handle the grpc request
Click to show internal directories.
Click to hide internal directories.