event

Mar 28, 2023

Changes in this version

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

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

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

+ type Registry struct

+ func NewRegistry() *Registry

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

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