aggregate

Documentation

Index

• func HandleRetry(ctx context.Context, retryFunc RetryFunc) error
• type Aggregate
  • func NewAggregate(groupID, aggregateID string, retryFunc RetryFunc, numEventsInSnapshot int, ...) (*Aggregate, error)
  • func (a *Aggregate) AggregateID() string
  • func (a *Aggregate) FactoryModel(ctx context.Context) (AggregateModel, error)
  • func (a *Aggregate) GroupID() string
  • func (a *Aggregate) HandleCommand(ctx context.Context, cmd Command) ([]eventstore.Event, error)
  • func (a *Aggregate) HandleCommandWithAggregateModelWrapper(ctx context.Context, cmd Command, amodel *AggregateModelWrapper) (events []eventstore.Event, concurrencyExcpetion bool, err error)
• type AggregateModel
• type AggregateModelWrapper
  • func NewAggregateModel(ctx context.Context, groupID, aggregateID string, store eventstore.EventStore, ...) (*AggregateModelWrapper, error)
  • func (ah *AggregateModelWrapper) GroupID() string
  • func (ah *AggregateModelWrapper) Handle(ctx context.Context, iter eventstore.Iter) error
  • func (ah *AggregateModelWrapper) HandleCommand(ctx context.Context, cmd Command, newVersion uint64) ([]eventstore.Event, error)
  • func (ah *AggregateModelWrapper) TakeSnapshot(newVersion uint64) (eventstore.Event, bool)
• type Command
• type FactoryModelFunc
• type RetryFunc
  • func NewDefaultRetryFunc(limit int) RetryFunc

Functions

func HandleRetry

func HandleRetry(ctx context.Context, retryFunc RetryFunc) error

Types

type Aggregate

type Aggregate struct {
	LogDebugfFunc eventstore.LogDebugfFunc
	// contains filtered or unexported fields
}

Aggregate holds data for Handle command

func NewAggregate

func NewAggregate(groupID, aggregateID string, retryFunc RetryFunc, numEventsInSnapshot int, store eventstore.EventStore, factoryModel FactoryModelFunc, logDebugfFunc eventstore.LogDebugfFunc) (*Aggregate, error)

NewAggregate creates aggregate. it load and store events created from commands

func (*Aggregate) AggregateID

func (a *Aggregate) AggregateID() string

func (*Aggregate) FactoryModel

func (a *Aggregate) FactoryModel(ctx context.Context) (AggregateModel, error)

func (*Aggregate) GroupID

func (a *Aggregate) GroupID() string

func (*Aggregate) HandleCommand

func (a *Aggregate) HandleCommand(ctx context.Context, cmd Command) ([]eventstore.Event, error)

HandleCommand transforms command to a event, store and publish eventstore.

func (*Aggregate) HandleCommandWithAggregateModelWrapper

func (a *Aggregate) HandleCommandWithAggregateModelWrapper(ctx context.Context, cmd Command, amodel *AggregateModelWrapper) (events []eventstore.Event, concurrencyExcpetion bool, err error)

type AggregateModel

type AggregateModel = interface {
	eventstore.Model

	HandleCommand(ctx context.Context, cmd Command, newVersion uint64) ([]eventstore.Event, error)
	TakeSnapshot(version uint64) (snapshotEvent eventstore.Event, ok bool)
	GroupID() string // defines group where model belows
}

AggregateModel user model for aggregate need to satisfy this interface.

type AggregateModelWrapper

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

func NewAggregateModel

func NewAggregateModel(ctx context.Context, groupID, aggregateID string, store eventstore.EventStore, logDebugfFunc eventstore.LogDebugfFunc, model AggregateModel) (*AggregateModelWrapper, error)

func (*AggregateModelWrapper) GroupID

func (ah *AggregateModelWrapper) GroupID() string

func (*AggregateModelWrapper) Handle

func (ah *AggregateModelWrapper) Handle(ctx context.Context, iter eventstore.Iter) error

func (*AggregateModelWrapper) HandleCommand

func (ah *AggregateModelWrapper) HandleCommand(ctx context.Context, cmd Command, newVersion uint64) ([]eventstore.Event, error)

func (*AggregateModelWrapper) TakeSnapshot

func (ah *AggregateModelWrapper) TakeSnapshot(newVersion uint64) (eventstore.Event, bool)

type Command

type Command = interface{}

Command user defined command that will handled in AggregateModel.HandleCommand

type FactoryModelFunc

type FactoryModelFunc = func(ctx context.Context) (AggregateModel, error)

FactoryModelFunc creates model for aggregate

type RetryFunc

type RetryFunc func() (when time.Time, err error)

RetryFunc defines policy to repeat HandleCommand on concurrency exception.

func NewDefaultRetryFunc

func NewDefaultRetryFunc(limit int) RetryFunc

NewDefaultRetryFunc default retry function