nats

Documentation

Index

• type EventHandler
  • func NewEventHandler(logger *cl.CustomLogger, nc *nats.EncodedConn, svc service.IInventoryService) *EventHandler
  • func (eh *EventHandler) Execute() error
  • func (eh *EventHandler) Interrupt(err error)
• type EventHandlerFuncs
  • func (ehf *EventHandlerFuncs) GetSubscription(nc *nats.EncodedConn) (subscriptions []*nats.Subscription, err error)

Types

type EventHandler

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

func NewEventHandler

func NewEventHandler(logger *cl.CustomLogger, nc *nats.EncodedConn, svc service.IInventoryService) *EventHandler

func (*EventHandler) Execute

func (eh *EventHandler) Execute() error

func (*EventHandler) Interrupt

func (eh *EventHandler) Interrupt(err error)

type EventHandlerFuncs

type EventHandlerFuncs struct {
	EventAccountCreatedHandler nats.Handler
	EventPolicyUpdatedHandler  nats.Handler
	EventOrderCreatedHandler   nats.Handler
	EventOrderApprovedHandler  nats.Handler
	EventOrderCanceledHandler  nats.Handler
}

func (*EventHandlerFuncs) GetSubscription

func (ehf *EventHandlerFuncs) GetSubscription(nc *nats.EncodedConn) (subscriptions []*nats.Subscription, err error)