receiver

Documentation

Overview

Code generated by events generator, DO NOT EDIT.

Index

• type EventHandler
  • func (eh EventHandler[T]) Handle(ctx context.Context, c rest.RESTClient, i interface{})
  • func (eh EventHandler[T]) New() interface{}
• type EventHandlerIface
• type HandlerFunc
• type LocalReceiver
  • func NewLocalReceiver(opts ...ReceiverOption) *LocalReceiver
  • func (e LocalReceiver) On(handler HandlerFunc) error
  • func (e LocalReceiver) Route(event string, data json.RawMessage) error
  • func (r *LocalReceiver) Run(ctx context.Context) error
• type NATSReceiver
  • func NewNATSReceiver(url string, natsOptions []nats.Option, opts ...ReceiverOption) (*NATSReceiver, error)
  • func (e NATSReceiver) On(handler HandlerFunc) error
  • func (e NATSReceiver) Route(event string, data json.RawMessage) error
  • func (r *NATSReceiver) Run(ctx context.Context) error
• type Receiver
• type ReceiverOption
  • func WithClient(c rest.RESTClient) ReceiverOption
  • func WithErrorHandler(h func(error)) ReceiverOption
  • func WithGroupName(name string) ReceiverOption
  • func WithLogger(l zerolog.Logger) ReceiverOption
• type RedisReceiver
  • func NewRedisReceiver(connectOpts *redis.Options, opts ...ReceiverOption) (*RedisReceiver, error)
  • func (e RedisReceiver) On(handler HandlerFunc) error
  • func (e RedisReceiver) Route(event string, data json.RawMessage) error
  • func (r *RedisReceiver) Run(ctx context.Context) error

Types

type EventHandler

type EventHandler[T any] func(context.Context, rest.RESTClient, *T)

func (EventHandler[T]) Handle

func (eh EventHandler[T]) Handle(ctx context.Context, c rest.RESTClient, i interface{})

func (EventHandler[T]) New

func (eh EventHandler[T]) New() interface{}

type EventHandlerIface

type EventHandlerIface interface {
	New() interface{}
	Handle(context.Context, rest.RESTClient, interface{})
}

type HandlerFunc

type HandlerFunc interface{}

type LocalReceiver

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

func NewLocalReceiver

func NewLocalReceiver(opts ...ReceiverOption) *LocalReceiver

func (LocalReceiver) On

func (e LocalReceiver) On(handler HandlerFunc) error

func (LocalReceiver) Route

func (e LocalReceiver) Route(event string, data json.RawMessage) error

func (*LocalReceiver) Run

func (r *LocalReceiver) Run(ctx context.Context) error

type NATSReceiver

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

func NewNATSReceiver

func NewNATSReceiver(url string, natsOptions []nats.Option, opts ...ReceiverOption) (*NATSReceiver, error)

func (NATSReceiver) On

func (e NATSReceiver) On(handler HandlerFunc) error

func (NATSReceiver) Route

func (e NATSReceiver) Route(event string, data json.RawMessage) error

func (*NATSReceiver) Run

func (r *NATSReceiver) Run(ctx context.Context) error

type Receiver

type Receiver interface {
	On(handler HandlerFunc) error
	Route(event string, data json.RawMessage) error
	Run(ctx context.Context) error
}

Receiver is a generic interface for receiving events from a Dispatcher

type ReceiverOption

type ReceiverOption func(*eventRouter)

func WithClient

func WithClient(c rest.RESTClient) ReceiverOption

func WithErrorHandler

func WithErrorHandler(h func(error)) ReceiverOption

func WithGroupName

func WithGroupName(name string) ReceiverOption

func WithLogger

func WithLogger(l zerolog.Logger) ReceiverOption

type RedisReceiver

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

func NewRedisReceiver

func NewRedisReceiver(connectOpts *redis.Options, opts ...ReceiverOption) (*RedisReceiver, error)

func (RedisReceiver) On

func (e RedisReceiver) On(handler HandlerFunc) error

func (RedisReceiver) Route

func (e RedisReceiver) Route(event string, data json.RawMessage) error

func (*RedisReceiver) Run

func (r *RedisReceiver) Run(ctx context.Context) error