aggregate

Documentation

Index

• Constants
• func GetIssueObjectID(aggregateID string, tenant string) string
• type IssueAggregate
  • func LoadIssueAggregate(ctx context.Context, eventStore eventstore.AggregateStore, ...) (*IssueAggregate, error)
  • func NewIssueAggregateWithTenantAndID(tenant, id string) *IssueAggregate
  • func (a *IssueAggregate) HandleCommand(ctx context.Context, cmd eventstore.Command) error
  • func (a *IssueAggregate) When(evt eventstore.Event) error

Constants

const (
	IssueAggregateType eventstore.AggregateType = "issue"
)

Functions

func GetIssueObjectID

func GetIssueObjectID(aggregateID string, tenant string) string

Types

type IssueAggregate

type IssueAggregate struct {
	*eventstore.CommonTenantIdAggregate
	Issue *model.Issue
}

func LoadIssueAggregate

func LoadIssueAggregate(ctx context.Context, eventStore eventstore.AggregateStore, tenant, objectID string) (*IssueAggregate, error)

func NewIssueAggregateWithTenantAndID

func NewIssueAggregateWithTenantAndID(tenant, id string) *IssueAggregate

func (*IssueAggregate) HandleCommand

func (a *IssueAggregate) HandleCommand(ctx context.Context, cmd eventstore.Command) error

func (*IssueAggregate) When

func (a *IssueAggregate) When(evt eventstore.Event) error