hook

Documentation

Index

• func NewInMemHook(channelSize int, handlers ...EventHandler) hook.Hook
• type EventHandler
• type InMemHook
  • func (h *InMemHook) Process()
  • func (h *InMemHook) Push(ctx context.Context, event hook.Event)
  • func (h *InMemHook) Stop()
  • func (h *InMemHook) WaitStop()

Functions

func NewInMemHook

func NewInMemHook(channelSize int, handlers ...EventHandler) hook.Hook

Types

type EventHandler

type EventHandler interface {
	Process(event *hook.EventCtx) error
}

type InMemHook

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

func (*InMemHook) Process

func (h *InMemHook) Process()

func (*InMemHook) Push

func (h *InMemHook) Push(ctx context.Context, event hook.Event)

func (*InMemHook) Stop

func (h *InMemHook) Stop()

func (*InMemHook) WaitStop

func (h *InMemHook) WaitStop()