eventbus

Documentation

Index

• Constants
• func HandlerFunc(eventName string, ...) stream.EventHandler
• func MutatorHandler(mutator stream.EventSinker) stream.EventHandler
• type Channel
  • func NewChannel(o ...Option) *Channel
  • func (b *Channel) Close() error
  • func (b *Channel) Listen(ctx context.Context) error
  • func (b *Channel) Publish(events []*event.Event) error
  • func (b *Channel) Subscribe(streamName string, handlers ...stream.EventHandler)
• type Deduplicator
• type Option
  • func WithChannelErrorHandler(h stream.EventErrorHandler) Option
  • func WithChannelPartitions(n int) Option

Constants

const (
	DefaultPartitions = 32
	MinPartitions     = 1
	MaxPartitions     = 1024
)

Functions

func HandlerFunc

func HandlerFunc(eventName string, handler, rollbackHandler func(context.Context, *event.Event) error) stream.EventHandler

func MutatorHandler

func MutatorHandler(mutator stream.EventSinker) stream.EventHandler

Types

type Channel

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

func NewChannel

func NewChannel(o ...Option) *Channel

func (*Channel) Close

func (b *Channel) Close() error

func (*Channel) Listen

func (b *Channel) Listen(ctx context.Context) error

func (*Channel) Publish

func (b *Channel) Publish(events []*event.Event) error

func (*Channel) Subscribe

func (b *Channel) Subscribe(streamName string, handlers ...stream.EventHandler)

type Deduplicator

type Deduplicator interface {
	SetVisit(context.Context, *event.Event) error
	HasVisit(context.Context, *event.Event) (bool, error)
}

type Option

type Option func(*Channel)

func WithChannelErrorHandler

func WithChannelErrorHandler(h stream.EventErrorHandler) Option

func WithChannelPartitions

func WithChannelPartitions(n int) Option