store

Documentation

Index

• type AggregateEvent
  • func NewAggregateEventBuilder() *AggregateEvent
  • func (e AggregateEvent) AggregateID() string
  • func (e AggregateEvent) AggregateName() string
  • func (e AggregateEvent) AggregateVersion() int
  • func (e *AggregateEvent) Build() AggregateEvent
  • func (e AggregateEvent) EventName() string
  • func (e AggregateEvent) ID() string
  • func (e AggregateEvent) Metadata() ddd.Metadata
  • func (e AggregateEvent) OccurredAt() time.Time
  • func (e AggregateEvent) Payload() ddd.EventPayload
  • func (e *AggregateEvent) WithAggregate(aggregate esourcing.EventSourcedAggregate) *AggregateEvent
  • func (e *AggregateEvent) WithAggregateVersion(version int) *AggregateEvent
  • func (e *AggregateEvent) WithID(id string) *AggregateEvent
  • func (e *AggregateEvent) WithName(name string) *AggregateEvent
  • func (e *AggregateEvent) WithOccurredAt(occurredAt time.Time) *AggregateEvent
  • func (e *AggregateEvent) WithPayload(payload ddd.EventPayload) *AggregateEvent
• type OutboxMessage
  • func NewOutboxMessageBuilder() *OutboxMessage
  • func (m *OutboxMessage) Build() OutboxMessage
  • func (m OutboxMessage) Data() []byte
  • func (m OutboxMessage) ID() string
  • func (m OutboxMessage) MessageName() string
  • func (m OutboxMessage) Metadata() ddd.Metadata
  • func (m OutboxMessage) SentAt() time.Time
  • func (m OutboxMessage) Subject() string
  • func (m *OutboxMessage) UnmarshalBSON(data []byte) error
  • func (m *OutboxMessage) WithData(data []byte) *OutboxMessage
  • func (m *OutboxMessage) WithID(id string) *OutboxMessage
  • func (m *OutboxMessage) WithMetadata(metada ddd.Metadata) *OutboxMessage
  • func (m *OutboxMessage) WithName(name string) *OutboxMessage
  • func (m *OutboxMessage) WithSendAt(sendAt time.Time) *OutboxMessage
  • func (m *OutboxMessage) WithSubject(subject string) *OutboxMessage

Types

type AggregateEvent

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

func NewAggregateEventBuilder

func NewAggregateEventBuilder() *AggregateEvent

func (AggregateEvent) AggregateID

func (e AggregateEvent) AggregateID() string

func (AggregateEvent) AggregateName

func (e AggregateEvent) AggregateName() string

func (AggregateEvent) AggregateVersion

func (e AggregateEvent) AggregateVersion() int

func (*AggregateEvent) Build

func (e *AggregateEvent) Build() AggregateEvent

func (AggregateEvent) EventName

func (e AggregateEvent) EventName() string

func (AggregateEvent) ID

func (e AggregateEvent) ID() string

func (AggregateEvent) Metadata

func (e AggregateEvent) Metadata() ddd.Metadata

func (AggregateEvent) OccurredAt

func (e AggregateEvent) OccurredAt() time.Time

func (AggregateEvent) Payload

func (e AggregateEvent) Payload() ddd.EventPayload

func (*AggregateEvent) WithAggregate

func (e *AggregateEvent) WithAggregate(aggregate esourcing.EventSourcedAggregate) *AggregateEvent

func (*AggregateEvent) WithAggregateVersion

func (e *AggregateEvent) WithAggregateVersion(version int) *AggregateEvent

func (*AggregateEvent) WithID

func (e *AggregateEvent) WithID(id string) *AggregateEvent

func (*AggregateEvent) WithName

func (e *AggregateEvent) WithName(name string) *AggregateEvent

func (*AggregateEvent) WithOccurredAt

func (e *AggregateEvent) WithOccurredAt(occurredAt time.Time) *AggregateEvent

func (*AggregateEvent) WithPayload

func (e *AggregateEvent) WithPayload(payload ddd.EventPayload) *AggregateEvent

type OutboxMessage

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

func NewOutboxMessageBuilder

func NewOutboxMessageBuilder() *OutboxMessage

func (*OutboxMessage) Build

func (m *OutboxMessage) Build() OutboxMessage

func (OutboxMessage) Data

func (m OutboxMessage) Data() []byte

func (OutboxMessage) ID

func (m OutboxMessage) ID() string

func (OutboxMessage) MessageName

func (m OutboxMessage) MessageName() string

func (OutboxMessage) Metadata

func (m OutboxMessage) Metadata() ddd.Metadata

func (OutboxMessage) SentAt

func (m OutboxMessage) SentAt() time.Time

func (OutboxMessage) Subject

func (m OutboxMessage) Subject() string

func (*OutboxMessage) UnmarshalBSON

func (m *OutboxMessage) UnmarshalBSON(data []byte) error

func (*OutboxMessage) WithData

func (m *OutboxMessage) WithData(data []byte) *OutboxMessage

func (*OutboxMessage) WithID

func (m *OutboxMessage) WithID(id string) *OutboxMessage

func (*OutboxMessage) WithMetadata

func (m *OutboxMessage) WithMetadata(metada ddd.Metadata) *OutboxMessage

func (*OutboxMessage) WithName

func (m *OutboxMessage) WithName(name string) *OutboxMessage

func (*OutboxMessage) WithSendAt

func (m *OutboxMessage) WithSendAt(sendAt time.Time) *OutboxMessage

func (*OutboxMessage) WithSubject

func (m *OutboxMessage) WithSubject(subject string) *OutboxMessage