dispatcher

Documentation

Index

• type Dispatcher
• type DispatcherOption
  • func WithLogger(l *zerolog.Logger) DispatcherOption
• type LocalDispatcher
  • func NewLocalDispatcher(receiver receiver.Receiver, opts ...DispatcherOption) *LocalDispatcher
  • func (l *LocalDispatcher) Dispatch(event string, data json.RawMessage) error
  • func (l *LocalDispatcher) SetLogger(logger *zerolog.Logger)
• type NATSDispatcher
  • func NewNATSDispatcher(url string, natsOpts []nats.Option, opts ...DispatcherOption) (*NATSDispatcher, error)
  • func (d *NATSDispatcher) Dispatch(event string, data json.RawMessage) error
  • func (d *NATSDispatcher) SetLogger(logger *zerolog.Logger)
• type NOOPDispatcher
  • func NewNOOPDispatcher(opts ...DispatcherOption) *NOOPDispatcher
  • func (d *NOOPDispatcher) Dispatch(event string, data json.RawMessage) error
  • func (d *NOOPDispatcher) SetLogger(logger *zerolog.Logger)
• type RedisDispatcher
  • func NewRedisDispatcher(connectOpts *redis.Options, opts ...DispatcherOption) (*RedisDispatcher, error)
  • func (d *RedisDispatcher) Dispatch(event string, data json.RawMessage) error
  • func (d *RedisDispatcher) SetLogger(logger *zerolog.Logger)

Types

type Dispatcher

type Dispatcher interface {
	Dispatch(event string, data json.RawMessage) error
	SetLogger(l *zerolog.Logger)
}

type DispatcherOption

type DispatcherOption func(d Dispatcher)

func WithLogger

func WithLogger(l *zerolog.Logger) DispatcherOption

type LocalDispatcher

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

func NewLocalDispatcher

func NewLocalDispatcher(receiver receiver.Receiver, opts ...DispatcherOption) *LocalDispatcher

func (*LocalDispatcher) Dispatch

func (l *LocalDispatcher) Dispatch(event string, data json.RawMessage) error

func (*LocalDispatcher) SetLogger

func (l *LocalDispatcher) SetLogger(logger *zerolog.Logger)

type NATSDispatcher

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

func NewNATSDispatcher

func NewNATSDispatcher(url string, natsOpts []nats.Option, opts ...DispatcherOption) (*NATSDispatcher, error)

func (*NATSDispatcher) Dispatch

func (d *NATSDispatcher) Dispatch(event string, data json.RawMessage) error

func (*NATSDispatcher) SetLogger

func (d *NATSDispatcher) SetLogger(logger *zerolog.Logger)

type NOOPDispatcher

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

func NewNOOPDispatcher

func NewNOOPDispatcher(opts ...DispatcherOption) *NOOPDispatcher

func (*NOOPDispatcher) Dispatch

func (d *NOOPDispatcher) Dispatch(event string, data json.RawMessage) error

func (*NOOPDispatcher) SetLogger

func (d *NOOPDispatcher) SetLogger(logger *zerolog.Logger)

type RedisDispatcher

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

func NewRedisDispatcher

func NewRedisDispatcher(connectOpts *redis.Options, opts ...DispatcherOption) (*RedisDispatcher, error)

func (*RedisDispatcher) Dispatch

func (d *RedisDispatcher) Dispatch(event string, data json.RawMessage) error

func (*RedisDispatcher) SetLogger

func (d *RedisDispatcher) SetLogger(logger *zerolog.Logger)