wrapper

Documentation

Index

• Variables
• type Base
  • func DefaultBaseWrapper() *Base
• type Consumer
  • func NewConsumer() (Consumer, error)
• type Producer
  • func NewProducer() (*Producer, error)
  • 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

Variables

var (
	ErrNoConnectorPlugin = fmt.Errorf("no connector plugin provided")
	ErrNoConnectorName   = fmt.Errorf("no connector plugin name provided")
)

Types

type Base

type Base struct {
	CurrentEventStore string
	Started           *atomic.Bool
	Inited            *atomic.Bool
}

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

func NewConsumer() (Consumer, error)

NewConsumer create new consumer to handle the grpc request

type Producer

type Producer struct {
	*Base
	ProducerConnector connector.Producer
}

func NewProducer

func NewProducer() (*Producer, error)

NewProducer create new producer to handle the grpc request

func (*Producer) Reply

func (c *Producer) Reply(ctx context.Context, event *eventv2.Event, callback *connector.SendCallback) error

func (*Producer) Request

func (c *Producer) Request(ctx context.Context, event *eventv2.Event, callback *connector.RequestReplyCallback, timeout time.Duration) error

func (*Producer) Send

func (c *Producer) Send(ctx context.Context, event *eventv2.Event, callback *connector.SendCallback) error

func (*Producer) Shutdown

func (c *Producer) Shutdown() error

func (*Producer) Start

func (c *Producer) Start() error