aggregate

Documentation

Index

• Constants
• func GetOrganizationObjectID(aggregateID string, tenant string) string
• type OrganizationAggregate
  • func LoadOrganizationAggregate(ctx context.Context, eventStore eventstore.AggregateStore, ...) (*OrganizationAggregate, error)
  • func NewOrganizationAggregateWithTenantAndID(tenant, id string) *OrganizationAggregate
  • func (a *OrganizationAggregate) CreateBillingProfile(ctx context.Context, request *organizationpb.CreateBillingProfileGrpcRequest) (billingProfileId string, err error)
  • func (a *OrganizationAggregate) HandleCommand(ctx context.Context, cmd eventstore.Command) error
  • func (a *OrganizationAggregate) HandleGRPCRequest(ctx context.Context, request any, params map[string]any) (any, error)
  • func (a *OrganizationAggregate) HandleRequest(ctx context.Context, request any) (any, error)
  • func (a *OrganizationAggregate) LinkEmailToBillingProfile(ctx context.Context, ...) error
  • func (a *OrganizationAggregate) LinkLocationToBillingProfile(ctx context.Context, ...) error
  • func (a *OrganizationAggregate) SetPhoneNumberNonPrimary(ctx context.Context, tenant, phoneNumberId, userId string) error
  • func (a *OrganizationAggregate) UnlinkEmailFromBillingProfile(ctx context.Context, ...) error
  • func (a *OrganizationAggregate) UnlinkLocationFromBillingProfile(ctx context.Context, ...) error
  • func (a *OrganizationAggregate) UpdateBillingProfile(ctx context.Context, request *organizationpb.UpdateBillingProfileGrpcRequest) error
  • func (a *OrganizationAggregate) UpdateOrganizationOwner(ctx context.Context, cmd *command.UpdateOrganizationOwnerCommand) error
  • func (a *OrganizationAggregate) When(event eventstore.Event) error
• type OrganizationTempAggregate
  • func LoadOrganizationTempAggregate(ctx context.Context, eventStore eventstore.AggregateStore, ...) (*OrganizationTempAggregate, error)
  • func NewOrganizationTempAggregateWithTenantAndID(tenant, id string) *OrganizationTempAggregate
  • func (a *OrganizationTempAggregate) HandleCommand(ctx context.Context, cmd eventstore.Command) error
  • func (a *OrganizationTempAggregate) HandleGRPCRequest(ctx context.Context, request any, params map[string]any) (any, error)
  • func (a *OrganizationTempAggregate) HandleRequest(ctx context.Context, request any) (any, error)

Constants

const (
	OrganizationAggregateType eventstore.AggregateType = "organization"
)

Functions

func GetOrganizationObjectID

func GetOrganizationObjectID(aggregateID string, tenant string) string

Types

type OrganizationAggregate

type OrganizationAggregate struct {
	*eventstore.CommonTenantIdAggregate
	Organization *model.Organization
}

func LoadOrganizationAggregate

func LoadOrganizationAggregate(ctx context.Context, eventStore eventstore.AggregateStore, tenant, objectID string, opts eventstore.LoadAggregateOptions) (*OrganizationAggregate, error)

func NewOrganizationAggregateWithTenantAndID

func NewOrganizationAggregateWithTenantAndID(tenant, id string) *OrganizationAggregate

func (*OrganizationAggregate) CreateBillingProfile

func (a *OrganizationAggregate) CreateBillingProfile(ctx context.Context, request *organizationpb.CreateBillingProfileGrpcRequest) (billingProfileId string, err error)

func (*OrganizationAggregate) HandleCommand

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

func (*OrganizationAggregate) HandleGRPCRequest

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

func (*OrganizationAggregate) HandleRequest

func (a *OrganizationAggregate) HandleRequest(ctx context.Context, request any) (any, error)

func (*OrganizationAggregate) LinkEmailToBillingProfile

func (a *OrganizationAggregate) LinkEmailToBillingProfile(ctx context.Context, request *organizationpb.LinkEmailToBillingProfileGrpcRequest) error

func (*OrganizationAggregate) LinkLocationToBillingProfile

func (a *OrganizationAggregate) LinkLocationToBillingProfile(ctx context.Context, request *organizationpb.LinkLocationToBillingProfileGrpcRequest) error

func (*OrganizationAggregate) SetPhoneNumberNonPrimary

func (a *OrganizationAggregate) SetPhoneNumberNonPrimary(ctx context.Context, tenant, phoneNumberId, userId string) error

func (*OrganizationAggregate) UnlinkEmailFromBillingProfile

func (a *OrganizationAggregate) UnlinkEmailFromBillingProfile(ctx context.Context, request *organizationpb.UnlinkEmailFromBillingProfileGrpcRequest) error

func (*OrganizationAggregate) UnlinkLocationFromBillingProfile

func (a *OrganizationAggregate) UnlinkLocationFromBillingProfile(ctx context.Context, request *organizationpb.UnlinkLocationFromBillingProfileGrpcRequest) error

func (*OrganizationAggregate) UpdateBillingProfile

func (a *OrganizationAggregate) UpdateBillingProfile(ctx context.Context, request *organizationpb.UpdateBillingProfileGrpcRequest) error

func (*OrganizationAggregate) UpdateOrganizationOwner

func (a *OrganizationAggregate) UpdateOrganizationOwner(ctx context.Context, cmd *command.UpdateOrganizationOwnerCommand) error

func (*OrganizationAggregate) When

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

type OrganizationTempAggregate

type OrganizationTempAggregate struct {
	*eventstore.CommonTenantIdTempAggregate
}

func LoadOrganizationTempAggregate

func LoadOrganizationTempAggregate(ctx context.Context, eventStore eventstore.AggregateStore, tenant, objectID string, opts eventstore.LoadAggregateOptions) (*OrganizationTempAggregate, error)

func NewOrganizationTempAggregateWithTenantAndID

func NewOrganizationTempAggregateWithTenantAndID(tenant, id string) *OrganizationTempAggregate

func (*OrganizationTempAggregate) HandleCommand

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

func (*OrganizationTempAggregate) HandleGRPCRequest

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

func (*OrganizationTempAggregate) HandleRequest

func (a *OrganizationTempAggregate) HandleRequest(ctx context.Context, request any) (any, error)