event

Documentation

Index

• type CommonEventRouter
  • func NewRouter(manager *connection.Manager, config *queue.RouterConfig, logger zerolog.Logger) *CommonEventRouter
  • func (cer *CommonEventRouter) Close() error
  • func (cer *CommonEventRouter) SendAll(EventBatch *p_buff.EventBatch, attributes ...string) error
  • func (cer *CommonEventRouter) SubscribeAll(listener event.Listener, attributes ...string) (queue.Monitor, error)
  • func (cer *CommonEventRouter) SubscribeAllWithManualAck(listener event.ConformationListener, attributes ...string) (queue.Monitor, error)
• type CommonEventSender
  • func (sender *CommonEventSender) Send(batch *p_buff.EventBatch) error

Types

type CommonEventRouter

type CommonEventRouter struct {
	Logger zerolog.Logger
	// contains filtered or unexported fields
}

func NewRouter

func NewRouter(
	manager *connection.Manager,
	config *queue.RouterConfig,
	logger zerolog.Logger,
) *CommonEventRouter

func (*CommonEventRouter) Close

func (cer *CommonEventRouter) Close() error

func (*CommonEventRouter) SendAll

func (cer *CommonEventRouter) SendAll(EventBatch *p_buff.EventBatch, attributes ...string) error

func (*CommonEventRouter) SubscribeAll

func (cer *CommonEventRouter) SubscribeAll(listener event.Listener, attributes ...string) (queue.Monitor, error)

func (*CommonEventRouter) SubscribeAllWithManualAck

func (cer *CommonEventRouter) SubscribeAllWithManualAck(listener event.ConformationListener, attributes ...string) (queue.Monitor, error)

type CommonEventSender

type CommonEventSender struct {
	ConnManager *connection.Manager

	Logger zerolog.Logger
	// contains filtered or unexported fields
}

func (*CommonEventSender) Send

func (sender *CommonEventSender) Send(batch *p_buff.EventBatch) error