event

Documentation

Index

• func GetEventFromMsg(data []byte) (*model.Envelope, error)
• func StartEventHandlers(ctx context.Context, conf config.Config, wg *sync.WaitGroup) error
• type HandlerFunc
• type Registry
  • func NewRegistry() *Registry
  • func (r *Registry) GetHandler(eventName string) HandlerFunc
  • func (r *Registry) Register(eventName string, f HandlerFunc)

Functions

func GetEventFromMsg

func GetEventFromMsg(data []byte) (*model.Envelope, error)

func StartEventHandlers

func StartEventHandlers(ctx context.Context, conf config.Config, wg *sync.WaitGroup) error

Types

type HandlerFunc

type HandlerFunc func(ctx context.Context, event model.HandlerContext) error

type Registry

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

func NewRegistry

func NewRegistry() *Registry

func (*Registry) GetHandler

func (r *Registry) GetHandler(eventName string) HandlerFunc

func (*Registry) Register

func (r *Registry) Register(eventName string, f HandlerFunc)