events

Documentation

Index

• type MemoryBus
  • func NewMemoryBus() *MemoryBus
  • func (b *MemoryBus) Publish(ctx context.Context, event contracts.Event) error
  • func (b *MemoryBus) Request(ctx context.Context, event contracts.Event, timeout time.Duration) (contracts.Event, error)
  • func (b *MemoryBus) SetValidation(enabled bool)
  • func (b *MemoryBus) Subscribe(ctx context.Context, eventType string, handler contracts.EventHandler) error
  • func (b *MemoryBus) Unsubscribe(ctx context.Context, eventType string, handler contracts.EventHandler) error

Types

type MemoryBus

type MemoryBus struct {
	EnableValidation bool // when true, validates payloads against known schemas
	// contains filtered or unexported fields
}

func NewMemoryBus

func NewMemoryBus() *MemoryBus

func (*MemoryBus) Publish

func (b *MemoryBus) Publish(ctx context.Context, event contracts.Event) error

func (*MemoryBus) Request

func (b *MemoryBus) Request(ctx context.Context, event contracts.Event, timeout time.Duration) (contracts.Event, error)

func (*MemoryBus) SetValidation

func (b *MemoryBus) SetValidation(enabled bool)

SetValidation enables or disables payload schema validation on publish.

func (*MemoryBus) Subscribe

func (b *MemoryBus) Subscribe(ctx context.Context, eventType string, handler contracts.EventHandler) error

func (*MemoryBus) Unsubscribe

func (b *MemoryBus) Unsubscribe(ctx context.Context, eventType string, handler contracts.EventHandler) error