eventpubsub

Documentation

Index

• Variables
• type DecodeInputFunc
• type Event
• type Handler
• type HandlerSet
  • func NewHandlerSet() *HandlerSet
  • func (hs *HandlerSet) Add(typ string, handler Handler)
  • func (hs *HandlerSet) Handle(ctx context.Context, event Event) error
• type Publisher
• type Subscriber
  • func NewSubscriber(e endpoint.Endpoint, dec DecodeInputFunc) *Subscriber
  • func (s *Subscriber) Handle(ctx context.Context, event Event) error

Variables

var (
	ErrInvalidType = errors.New("invalid event type")
	ErrInvalidData = errors.New("invalid event data")
)

Types

type DecodeInputFunc

type DecodeInputFunc func(context.Context, Event) (input interface{}, err error)

DecodeInputFunc extracts a user-domain input object from an event. It's designed to be used in event handlers, for subscriber-side endpoints.

type Event

type Event interface {
	Type() string
	Data() interface{}
}

type Handler

type Handler interface {
	Handle(ctx context.Context, event Event) error
}

type HandlerSet

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

func NewHandlerSet

func NewHandlerSet() *HandlerSet

func (*HandlerSet) Add

func (hs *HandlerSet) Add(typ string, handler Handler)

func (*HandlerSet) Handle

func (hs *HandlerSet) Handle(ctx context.Context, event Event) error

type Publisher

type Publisher interface {
	Publish(ctx context.Context, typ string, data interface{}) error
}

type Subscriber

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

Subscriber wraps an endpoint and implements Handler.

func NewSubscriber

func NewSubscriber(e endpoint.Endpoint, dec DecodeInputFunc) *Subscriber

NewSubscriber constructs a new subscriber, which implements Handler and wraps the provided endpoint.

func (*Subscriber) Handle

func (s *Subscriber) Handle(ctx context.Context, event Event) error

Handle implements Handler.