dispatcher

Documentation

Index

• type GoChannel
  • func NewGoChannel(pool evbundler.WorkerPool) *GoChannel
  • func (d *GoChannel) Dispatch(ctx context.Context, evCh chan evbundler.Event) error
• type RoundRobin
  • func (d *RoundRobin) Dispatch(ctx context.Context, evCh chan evbundler.Event) error

Types

type GoChannel

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

GoChannel dispatcher by go channel.

func NewGoChannel

func NewGoChannel(pool evbundler.WorkerPool) *GoChannel

NewGoChannel initialize GoChannel.

func (*GoChannel) Dispatch

func (d *GoChannel) Dispatch(ctx context.Context, evCh chan evbundler.Event) error

Dispatch dispatches events from a event channel.

type RoundRobin

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

func (*RoundRobin) Dispatch

func (d *RoundRobin) Dispatch(ctx context.Context, evCh chan evbundler.Event) error