rabbit

Documentation

Overview

Package rabbit provides an event and command bus for the CQRS and Event Sourcing framework

Current version: experimental

Index

• type EventBus
  • func NewEventBus(connectionString string, name string, exchange string) *EventBus
  • func (bus *EventBus) PublishEvents(events []cqrs.VersionedEvent) error
  • func (bus *EventBus) ReceiveEvents(options cqrs.VersionedEventReceiverOptions) error
• type RawVersionedEvent

Types

type EventBus

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

func NewEventBus

func NewEventBus(connectionString string, name string, exchange string) *EventBus

func (*EventBus) PublishEvents

func (bus *EventBus) PublishEvents(events []cqrs.VersionedEvent) error

func (*EventBus) ReceiveEvents

func (bus *EventBus) ReceiveEvents(options cqrs.VersionedEventReceiverOptions) error

type RawVersionedEvent

type RawVersionedEvent struct {
	ID        string    `json:"id"`
	SourceID  string    `json:"sourceID"`
	Version   int       `json:"version"`
	EventType string    `json:"eventType"`
	Created   time.Time `json:"time"`
	Event     json.RawMessage
}