Versions in this module Expand all Collapse all v2 v2.1.0 Sep 15, 2022 v2.0.0 Sep 14, 2021 Changes in this version + var ErrDuplicatePayloadType = errors.New("goengine: payload type is already registered") + var ErrEventStreamClosed = errors.New("goengine: no more messages") + var ErrEventStreamNotStarted = errors.New("goengine: eventStream Message called without calling Next") + var ErrMessageNumberCountMismatch = errors.New("goengine: provided messages and messageNumbers do not match") + var ErrNilMessage = errors.New("goengine: nil is not a valid message") + var ErrStreamExistsAlready = errors.New("goengine: stream already exists") + var ErrStreamNotFound = errors.New("goengine: unknown stream") + var ErrTypeMismatch = errors.New("goengine: the values to compare are of a different type") + var ErrUnknownPayloadType = errors.New("goengine: unknown payload type was provided") + var ErrUnsupportedOperator = errors.New("goengine: the operator is not supported for this type") + var ErrUnsupportedType = errors.New("the value is not a scalar type") + type EventStore struct + func NewEventStore(logger goengine.Logger) *EventStore + func (i *EventStore) AppendTo(ctx context.Context, streamName goengine.StreamName, ...) error + func (i *EventStore) Create(ctx context.Context, streamName goengine.StreamName) error + func (i *EventStore) HasStream(ctx context.Context, streamName goengine.StreamName) bool + func (i *EventStore) Load(ctx context.Context, streamName goengine.StreamName, fromNumber int64, ...) (goengine.EventStream, error) + type EventStream struct + func NewEventStream(messages []goengine.Message, messageNumbers []int64) (*EventStream, error) + func (e *EventStream) Close() error + func (e *EventStream) Err() error + func (e *EventStream) Message() (goengine.Message, int64, error) + func (e *EventStream) Next() bool + type IncompatibleConstraintError struct + Constraint metadata.Constraint + Parent error + func (e *IncompatibleConstraintError) Error() string + type IncompatibleMatcherError []IncompatibleConstraintError + func (e IncompatibleMatcherError) Error() string + type MetadataMatcher struct + func NewMetadataMatcher(matcher metadata.Matcher, logger goengine.Logger) (*MetadataMatcher, error) + func (m *MetadataMatcher) Matches(metadata metadata.Metadata) bool + type PayloadRegistry struct + func (p *PayloadRegistry) RegisterPayload(eventName string, payload interface{}) error + func (p *PayloadRegistry) ResolveName(payload interface{}) (string, error) Other modules containing this package github.com/hellofresh/goengine
Go to main page