store

package
v0.1.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 16, 2023 License: BSD-3-Clause Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.