shell

package

v1.1.1-beta Latest Latest Go to latest Published: Jul 29, 2025 License: GPL-3.0 Imports: 7 Imported by: 0

Documentation ¶

This section is empty.

View Source

var ErrEventEnvelopeFromStorableEventFailed = errors.New("event envelope from storable event failed")

View Source

var ErrMappingToDomainEventFailed = errors.New("mapping to domain event failed")

View Source

var ErrMappingToDomainEventUnknownEventType = errors.New("unknown event type")

View Source

var ErrMappingToEventMetadataFailed = errors.New("mapping to event metadata failed")

View Source

var ErrMappingToStorableEventFailedForDomainEvent = errors.New("mapping to storable event failed for domain event")

View Source

var ErrMappingToStorableEventFailedForMetadata = errors.New("mapping to storable event failed for metadata")

func DomainEventFrom(storableEvent eventstore.StorableEvent) (core.DomainEvent, error)

func DomainEventsFrom(storableEvents eventstore.StorableEvents) (core.DomainEvents, error)

func StorableEventFrom(event core.DomainEvent, metadata EventMetadata) (eventstore.StorableEvent, error)

func StorableEventWithEmptyMetadataFrom(event core.DomainEvent) (eventstore.StorableEvent, error)

type CausationID = string

type CorrelationID = string

type EventEnvelope struct {
	DomainEvent   core.DomainEvent
	EventMetadata EventMetadata
}

func BuildEventEnvelope(domainEvent core.DomainEvent, eventMetadata EventMetadata) EventEnvelope

func EventEnvelopeFrom(storableEvent eventstore.StorableEvent) (EventEnvelope, error)

type EventEnvelopes = []EventEnvelope

func EventEnvelopesFrom(storableEvents eventstore.StorableEvents) (EventEnvelopes, error)

type EventMetadata struct {
	MessageID     MessageID
	CausationID   CausationID
	CorrelationID CorrelationID
}

func BuildEventMetadata(messageID uuid.UUID, causationID uuid.UUID, correlationID uuid.UUID) EventMetadata

func EventMetadataFrom(storableEvent eventstore.StorableEvent) (EventMetadata, error)

type MessageID = string