dispatcher

Documentation

Index

• type Dispatcher
  • func New(c types.Consumer) *Dispatcher
  • func (d *Dispatcher) Start(ctx context.Context) error
  • func (d *Dispatcher) Stop(ctx context.Context) error

Types

type Dispatcher

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

func New

func New(c types.Consumer) *Dispatcher

func (*Dispatcher) Start

func (d *Dispatcher) Start(ctx context.Context) error

func (*Dispatcher) Stop

func (d *Dispatcher) Stop(ctx context.Context) error