goengine

package module

Go to main page

Versions in this module

v0

v0.11.0

Aug 25, 2021

v0.10.0

Sep 4, 2019

v0.9.0

Mar 1, 2019

Changes in this version

type Logger

+ WithError func(err error) Logger

+ WithField func(key string, val interface{}) Logger

v0.3.6

Oct 7, 2021

Changes in this version

+ func Log(msg string, fields map[string]interface{}, err error)

+ func SetLogHandler(handler LogHandler)

+ type AggregateRepository interface

+ Load func(string, StreamName) (*EventStream, error)

+ Reconstitute func(string, AggregateRoot, StreamName) error

+ Save func(AggregateRoot, StreamName) error

+ type AggregateRoot interface

+ Apply func(DomainEvent)

+ GetID func() string

+ GetUncommittedEvents func() []*DomainMessage

+ GetVersion func() int

+ SetVersion func(int)

+ type AggregateRootBased struct

+ ID string

+ func NewAggregateRootBased(source interface{}) *AggregateRootBased

+ func NewEventSourceBasedWithID(source interface{}, id string) *AggregateRootBased

+ func (r *AggregateRootBased) Apply(event DomainEvent)

+ func (r *AggregateRootBased) GetID() string

+ func (r *AggregateRootBased) GetUncommittedEvents() []*DomainMessage

+ func (r *AggregateRootBased) GetVersion() int

+ func (r *AggregateRootBased) Record(event DomainEvent)

+ func (r *AggregateRootBased) RecordThat(event DomainEvent)

+ func (r *AggregateRootBased) SetVersion(version int)

+ type DomainEvent interface

+ OccurredOn func() time.Time

+ type DomainMessage struct

+ ID string

+ Payload DomainEvent

+ RecordedOn time.Time

+ Version int

+ func NewDomainMessage(id string, version int, payload DomainEvent, recordedOn time.Time) *DomainMessage

+ func RecordNow(id string, version int, payload DomainEvent) *DomainMessage

+ func (dm *DomainMessage) String() string

type EventStore

+ Append func(events *EventStream) error

+ CountEventsFor func(streamName StreamName, id string) (int64, error)

+ FromVersion func(streamName StreamName, id string, version int) (*EventStream, error)

+ GetEventsFor func(streamName StreamName, id string) (*EventStream, error)

type EventStream

+ Events []*DomainMessage

+ Name StreamName

+ func NewEventStream(name StreamName, events []*DomainMessage) *EventStream

+ type InMemoryTypeRegistry struct

+ func NewInMemoryTypeRegistry() *InMemoryTypeRegistry

+ func (r *InMemoryTypeRegistry) Get(name string) (interface{}, error)

+ func (r *InMemoryTypeRegistry) GetTypeByName(typeName string) (reflect.Type, bool)

+ func (r *InMemoryTypeRegistry) RegisterAggregate(aggregate AggregateRoot, events ...interface{})

+ func (r *InMemoryTypeRegistry) RegisterEvents(events ...interface{})

+ func (r *InMemoryTypeRegistry) RegisterType(i interface{})

+ type LogHandler func(msg string, fields map[string]interface{}, err error)

+ type MapBasedVersionedEventDispatcher struct

+ func NewVersionedEventDispatcher() *MapBasedVersionedEventDispatcher

+ func (m *MapBasedVersionedEventDispatcher) DispatchEvent(event *DomainMessage) error

+ func (m *MapBasedVersionedEventDispatcher) RegisterEventHandler(event interface{}, handler VersionedEventHandler)

+ func (m *MapBasedVersionedEventDispatcher) RegisterGlobalHandler(handler VersionedEventHandler)

+ type PublisherRepository struct

+ EventBus VersionedEventPublisher

+ EventStore EventStore

+ func NewPublisherRepository(eventStore EventStore, eventBus VersionedEventPublisher) *PublisherRepository

+ func (r *PublisherRepository) Load(id string, streamName StreamName) (*EventStream, error)

+ func (r *PublisherRepository) Reconstitute(id string, source AggregateRoot, streamName StreamName) error

+ func (r *PublisherRepository) Save(aggregateRoot AggregateRoot, streamName StreamName) error

+ type TypeRegistry interface

+ Get func(string) (interface{}, error)

+ GetTypeByName func(string) (reflect.Type, bool)

+ RegisterAggregate func(AggregateRoot, ...interface{})

+ RegisterEvents func(...interface{})

+ RegisterType func(interface{})

+ type VersionedEventDispatchManager struct

+ func NewVersionedEventDispatchManager(receiver VersionedEventReceiver, registry TypeRegistry) *VersionedEventDispatchManager

+ func (m *VersionedEventDispatchManager) Listen(stop <-chan bool, exclusive bool) error

+ func (m *VersionedEventDispatchManager) RegisterEventHandler(event interface{}, handler VersionedEventHandler)

+ func (m *VersionedEventDispatchManager) RegisterGlobalHandler(handler VersionedEventHandler)

+ type VersionedEventDispatcher interface

+ DispatchEvent func(*DomainMessage) error

+ RegisterEventHandler func(event interface{}, handler VersionedEventHandler)

+ RegisterGlobalHandler func(handler VersionedEventHandler)

+ type VersionedEventHandler func(*DomainMessage) error

+ type VersionedEventPublisher interface

+ PublishEvents func([]*DomainMessage) error

+ type VersionedEventReceiver interface

+ ReceiveEvents func(VersionedEventReceiverOptions) error

+ type VersionedEventReceiverOptions struct

+ Close chan chan error

+ Error chan error

+ Exclusive bool

+ ReceiveEvent chan VersionedEventTransactedAccept

+ TypeRegistry TypeRegistry

+ type VersionedEventTransactedAccept struct

+ Event *DomainMessage

+ ProcessedSuccessfully chan bool

v0.3.5

Aug 26, 2020

Changes in this version

+ func IsUUIDEmpty(id UUID) bool

+ type EventStore interface

+ AppendTo func(ctx context.Context, streamName StreamName, streamEvents []Message) error

+ Create func(ctx context.Context, streamName StreamName) error

+ type EventStream interface

+ Close func() error

+ Err func() error

+ Message func() (Message, int64, error)

+ Next func() bool

+ type Fields map[string]interface

+ type InvalidArgumentError string

+ func (i InvalidArgumentError) Error() string

+ type Logger interface

+ Debug func(msg string, fields func(LoggerEntry))

+ Error func(msg string, fields func(LoggerEntry))

+ Info func(msg string, fields func(LoggerEntry))

+ Warn func(msg string, fields func(LoggerEntry))

+ WithFields func(fields func(LoggerEntry)) Logger

+ var NopLogger Logger = &nopLogger{}

+ type LoggerEntry interface

+ Any func(k string, v interface{})

+ Error func(err error)

+ Int func(k string, v int)

+ Int64 func(s string, v int64)

+ String func(k, v string)

+ type Message interface

+ CreatedAt func() time.Time

+ Metadata func() metadata.Metadata

+ Payload func() interface{}

+ UUID func() UUID

+ WithMetadata func(key string, value interface{}) Message

+ func ReadEventStream(stream EventStream) ([]Message, []int64, error)

+ type MessageHandler func(ctx context.Context, state interface{}, message Message) (interface{}, error)

+ type MessagePayloadConverter interface

+ ConvertPayload func(payload interface{}) (name string, data []byte, err error)

+ type MessagePayloadFactory interface

+ CreatePayload func(payloadType string, data interface{}) (interface{}, error)

+ type MessagePayloadResolver interface

+ ResolveName func(payload interface{}) (string, error)

+ type Projection interface

+ FromStream func() StreamName

+ Name func() string

+ type ProjectionSaga interface

+ DecodeState func(data []byte) (interface{}, error)

+ EncodeState func(obj interface{}) ([]byte, error)

+ type Query interface

+ Handlers func() map[string]MessageHandler

+ Init func(ctx context.Context) (interface{}, error)

+ type ReadOnlyEventStore interface

+ HasStream func(ctx context.Context, streamName StreamName) bool

+ Load func(ctx context.Context, streamName StreamName, fromNumber int64, count *uint, ...) (EventStream, error)

+ type StreamName string

+ type UUID = uuid.UUID

+ func GenerateUUID() UUID

Other modules containing this package

github.com/hellofresh/goengine/v2

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL