aggregate

Documentation

Index

• type Agg
  • func (agg *Agg) CurrentState() ([]byte, string)
  • func (agg *Agg) History() []Event
  • func (agg *Agg) WithChange(state []byte)
• type AggBatch
  • func (agg *AggBatch) History(id string) []Event
  • func (agg *AggBatch) State(id string) ([]byte, string)
  • func (agg *AggBatch) WithChange(id string, state any) error
• type Event
• type Service
  • func NewService(tSvc transaction.Service, events keyvalue.Versioned[State]) Service
• type State

Types

type Agg

type Agg struct {
	Events []Event

	Version string
	// contains filtered or unexported fields
}

func (*Agg) CurrentState

func (agg *Agg) CurrentState() ([]byte, string)

func (*Agg) History

func (agg *Agg) History() []Event

func (*Agg) WithChange

func (agg *Agg) WithChange(state []byte)

type AggBatch

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

func (*AggBatch) History

func (agg *AggBatch) History(id string) []Event

func (*AggBatch) State

func (agg *AggBatch) State(id string) ([]byte, string)

func (*AggBatch) WithChange

func (agg *AggBatch) WithChange(id string, state any) error

type Event

type Event struct {
	State         []byte    `json:"state"`
	Uncommitted   bool      `json:"uncommitted"`
	TransactionID *string   `json:"transactionId"`
	Deleted       bool      `json:"deleted"`
	CreatedAt     time.Time `json:"createdAt"`
}

type Service

type Service interface {
	// GetBatch returns aggregates and a function that persist aggregate changes
	GetBatch(ctx context.Context, ids []string) (aggs *AggBatch, persist func() error, err error)
}

func NewService

func NewService(tSvc transaction.Service, events keyvalue.Versioned[State]) Service

type State

type State struct {
	Events []Event `json:"events"`
	Dirty  bool    `json:"dirty"`
}