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 + 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
Go to main page