aggregate

Documentation

Index

• Constants
• func GetContractObjectID(aggregateID, tenant string) string
• type ContractAggregate
  • func NewContractAggregateWithTenantAndID(tenant, id string) *ContractAggregate
  • func (a *ContractAggregate) HandleGRPCRequest(ctx context.Context, request any, params map[string]any) (any, error)
  • func (a *ContractAggregate) When(evt eventstore.Event) error
• type ContractTempAggregate
  • func NewContractTempAggregateWithTenantAndID(tenant, id string) *ContractTempAggregate
  • func (a *ContractTempAggregate) HandleGRPCRequest(ctx context.Context, request any, params map[string]any) (any, error)

Constants

const (
	ContractAggregateType eventstore.AggregateType = "contract"
)

Functions

func GetContractObjectID

func GetContractObjectID(aggregateID, tenant string) string

Types

type ContractAggregate

type ContractAggregate struct {
	*eventstore.CommonTenantIdAggregate
	Contract *model.Contract
}

func NewContractAggregateWithTenantAndID

func NewContractAggregateWithTenantAndID(tenant, id string) *ContractAggregate

func (*ContractAggregate) HandleGRPCRequest

func (a *ContractAggregate) HandleGRPCRequest(ctx context.Context, request any, params map[string]any) (any, error)

func (*ContractAggregate) When

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

type ContractTempAggregate

type ContractTempAggregate struct {
	*eventstore.CommonTenantIdTempAggregate
}

func NewContractTempAggregateWithTenantAndID

func NewContractTempAggregateWithTenantAndID(tenant, id string) *ContractTempAggregate

func (*ContractTempAggregate) HandleGRPCRequest

func (a *ContractTempAggregate) HandleGRPCRequest(ctx context.Context, request any, params map[string]any) (any, error)