aggregate

Documentation

Index

• Constants
• func GetPhoneNumberObjectID(aggregateID string, tenant string) string
• type PhoneNumberAggregate
  • func LoadPhoneNumberAggregate(ctx context.Context, eventStore eventstore.AggregateStore, ...) (*PhoneNumberAggregate, error)
  • func NewPhoneNumberAggregateWithTenantAndID(tenant, id string) *PhoneNumberAggregate
  • func (a *PhoneNumberAggregate) HandleCommand(ctx context.Context, cmd eventstore.Command) error
  • func (a *PhoneNumberAggregate) HandleGRPCRequest(ctx context.Context, request any, params map[string]any) (any, error)
  • func (a *PhoneNumberAggregate) OnPhoneNumberFailedValidation(event eventstore.Event) error
  • func (a *PhoneNumberAggregate) OnPhoneNumberSkippedValidation(event eventstore.Event) error
  • func (a *PhoneNumberAggregate) OnPhoneNumberValidated(event eventstore.Event) error
  • func (a *PhoneNumberAggregate) When(event eventstore.Event) error
• type PhoneNumberTempAggregate
  • func NewPhoneNumberTempAggregateWithTenantAndID(tenant, id string) *PhoneNumberTempAggregate
  • func (a *PhoneNumberTempAggregate) HandleGRPCRequest(ctx context.Context, request any, params map[string]any) (any, error)

Constants

const (
	PhoneNumberAggregateType eventstore.AggregateType = "phone_number"
)

Functions

func GetPhoneNumberObjectID

func GetPhoneNumberObjectID(aggregateID string, tenant string) string

Types

type PhoneNumberAggregate

type PhoneNumberAggregate struct {
	*eventstore.CommonTenantIdAggregate
	PhoneNumber *models.PhoneNumber
}

func LoadPhoneNumberAggregate

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

func NewPhoneNumberAggregateWithTenantAndID

func NewPhoneNumberAggregateWithTenantAndID(tenant, id string) *PhoneNumberAggregate

func (*PhoneNumberAggregate) HandleCommand

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

func (*PhoneNumberAggregate) HandleGRPCRequest

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

func (*PhoneNumberAggregate) OnPhoneNumberFailedValidation

func (a *PhoneNumberAggregate) OnPhoneNumberFailedValidation(event eventstore.Event) error

func (*PhoneNumberAggregate) OnPhoneNumberSkippedValidation

func (a *PhoneNumberAggregate) OnPhoneNumberSkippedValidation(event eventstore.Event) error

func (*PhoneNumberAggregate) OnPhoneNumberValidated

func (a *PhoneNumberAggregate) OnPhoneNumberValidated(event eventstore.Event) error

func (*PhoneNumberAggregate) When

func (a *PhoneNumberAggregate) When(event eventstore.Event) error

type PhoneNumberTempAggregate

type PhoneNumberTempAggregate struct {
	*eventstore.CommonTenantIdTempAggregate
}

func NewPhoneNumberTempAggregateWithTenantAndID

func NewPhoneNumberTempAggregateWithTenantAndID(tenant, id string) *PhoneNumberTempAggregate

func (*PhoneNumberTempAggregate) HandleGRPCRequest

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