aggregate

Documentation

Index

• Constants
• func GetServiceLineItemObjectID(aggregateID string, tenant string) string
• type ServiceLineItemAggregate
  • func NewServiceLineItemAggregateWithTenantAndID(tenant, id string) *ServiceLineItemAggregate
  • func (a *ServiceLineItemAggregate) CloseServiceLineItem(ctx context.Context, r *servicelineitempb.CloseServiceLineItemGrpcRequest, ...) error
  • func (a *ServiceLineItemAggregate) CreateServiceLineItem(ctx context.Context, r *servicelineitempb.CreateServiceLineItemGrpcRequest) error
  • func (a *ServiceLineItemAggregate) DeleteServiceLineItem(ctx context.Context, r *servicelineitempb.DeleteServiceLineItemGrpcRequest) error
  • func (a *ServiceLineItemAggregate) HandleGRPCRequest(ctx context.Context, request any, params map[string]any) (any, error)
  • func (a *ServiceLineItemAggregate) PauseServiceLineItem(ctx context.Context, r *servicelineitempb.PauseServiceLineItemGrpcRequest) error
  • func (a *ServiceLineItemAggregate) ResumeServiceLineItem(ctx context.Context, r *servicelineitempb.ResumeServiceLineItemGrpcRequest) error
  • func (a *ServiceLineItemAggregate) UpdateServiceLineItem(ctx context.Context, r *servicelineitempb.UpdateServiceLineItemGrpcRequest) error
  • func (a *ServiceLineItemAggregate) When(evt eventstore.Event) error

Constants

const (
	ServiceLineItemAggregateType eventstore.AggregateType = "service_line_item"
)

Functions

func GetServiceLineItemObjectID

func GetServiceLineItemObjectID(aggregateID string, tenant string) string

GetServiceLineItemObjectID generates the object ID for a service line item.

Types

type ServiceLineItemAggregate

type ServiceLineItemAggregate struct {
	*eventstore.CommonTenantIdAggregate
	ServiceLineItem *model.ServiceLineItem
}

func NewServiceLineItemAggregateWithTenantAndID

func NewServiceLineItemAggregateWithTenantAndID(tenant, id string) *ServiceLineItemAggregate

func (*ServiceLineItemAggregate) CloseServiceLineItem

func (a *ServiceLineItemAggregate) CloseServiceLineItem(ctx context.Context, r *servicelineitempb.CloseServiceLineItemGrpcRequest, params map[string]any) error

func (*ServiceLineItemAggregate) CreateServiceLineItem

func (a *ServiceLineItemAggregate) CreateServiceLineItem(ctx context.Context, r *servicelineitempb.CreateServiceLineItemGrpcRequest) error

func (*ServiceLineItemAggregate) DeleteServiceLineItem

func (a *ServiceLineItemAggregate) DeleteServiceLineItem(ctx context.Context, r *servicelineitempb.DeleteServiceLineItemGrpcRequest) error

func (*ServiceLineItemAggregate) HandleGRPCRequest

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

func (*ServiceLineItemAggregate) PauseServiceLineItem

func (a *ServiceLineItemAggregate) PauseServiceLineItem(ctx context.Context, r *servicelineitempb.PauseServiceLineItemGrpcRequest) error

func (*ServiceLineItemAggregate) ResumeServiceLineItem

func (a *ServiceLineItemAggregate) ResumeServiceLineItem(ctx context.Context, r *servicelineitempb.ResumeServiceLineItemGrpcRequest) error

func (*ServiceLineItemAggregate) UpdateServiceLineItem

func (a *ServiceLineItemAggregate) UpdateServiceLineItem(ctx context.Context, r *servicelineitempb.UpdateServiceLineItemGrpcRequest) error

func (*ServiceLineItemAggregate) When

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