Documentation ¶
Index ¶
- Constants
- func GetInvoicingCycleObjectID(aggregateID string, tenant string) string
- func NewInvoicingCycleCreateEvent(aggregate eventstore.Aggregate, invoicingCycleType string, ...) (eventstore.Event, error)
- func NewInvoicingCycleUpdateEvent(aggregate eventstore.Aggregate, invoicingCycleType string, ...) (eventstore.Event, error)
- type CreateInvoicingCycleHandler
- type EventHandlers
- type InvoicingCycle
- type InvoicingCycleAggregate
- type InvoicingCycleCreateEvent
- type InvoicingCycleType
- type InvoicingCycleTypeString
- type InvoicingCycleUpdateEvent
- type UpdateInvoicingCycleHandler
Constants ¶
View Source
const ( InvoicingCycleCreateV1 = "V1_INVOICING_CYCLE_CREATE" InvoicingCycleUpdateV1 = "V1_INVOICING_CYCLE_UPDATE" )
View Source
const (
InvoicingCycleAggregateType eventstore.AggregateType = "invoicing_cycle"
)
Variables ¶
This section is empty.
Functions ¶
func NewInvoicingCycleCreateEvent ¶
func NewInvoicingCycleCreateEvent(aggregate eventstore.Aggregate, invoicingCycleType string, createdAt *time.Time, sourceFields commonmodel.Source) (eventstore.Event, error)
func NewInvoicingCycleUpdateEvent ¶
func NewInvoicingCycleUpdateEvent(aggregate eventstore.Aggregate, invoicingCycleType string, updatedAt *time.Time, sourceFields commonmodel.Source) (eventstore.Event, error)
Types ¶
type CreateInvoicingCycleHandler ¶
type CreateInvoicingCycleHandler interface {
Handle(ctx context.Context, baseRequest eventstore.BaseRequest, request *invoicingcyclepb.CreateInvoicingCycleTypeRequest) error
}
func NewCreateInvoicingCycleHandler ¶
func NewCreateInvoicingCycleHandler(log logger.Logger, es eventstore.AggregateStore) CreateInvoicingCycleHandler
type EventHandlers ¶
type EventHandlers struct { CreateInvoicingCycle CreateInvoicingCycleHandler UpdateInvoicingCycle UpdateInvoicingCycleHandler }
func NewEventHandlers ¶
func NewEventHandlers(log logger.Logger, es eventstore.AggregateStore) *EventHandlers
type InvoicingCycle ¶
type InvoicingCycleAggregate ¶
type InvoicingCycleAggregate struct { *aggregate.CommonTenantIdAggregate InvoicingCycle *InvoicingCycle }
func LoadInvoicingCycleAggregate ¶
func LoadInvoicingCycleAggregate(ctx context.Context, eventStore eventstore.AggregateStore, tenant, objectID string) (*InvoicingCycleAggregate, error)
func NewInvoicingCycleAggregateWithTenantAndID ¶
func NewInvoicingCycleAggregateWithTenantAndID(tenant, id string) *InvoicingCycleAggregate
func (*InvoicingCycleAggregate) When ¶
func (a *InvoicingCycleAggregate) When(evt eventstore.Event) error
type InvoicingCycleType ¶
type InvoicingCycleType int32
const ( DATE InvoicingCycleType = iota ANNIVERSARY )
func (InvoicingCycleType) StringValue ¶
func (t InvoicingCycleType) StringValue() InvoicingCycleTypeString
type InvoicingCycleTypeString ¶
type InvoicingCycleTypeString string
const ( InvoicingCycleTypeDate InvoicingCycleTypeString = "DATE" InvoicingCycleTypeAnniversary InvoicingCycleTypeString = "ANNIVERSARY" )
type UpdateInvoicingCycleHandler ¶
type UpdateInvoicingCycleHandler interface {
Handle(ctx context.Context, baseRequest eventstore.BaseRequest, request *invoicingcyclepb.UpdateInvoicingCycleTypeRequest) error
}
func NewUpdateInvoicingCycleHandler ¶
func NewUpdateInvoicingCycleHandler(log logger.Logger, es eventstore.AggregateStore) UpdateInvoicingCycleHandler
Click to show internal directories.
Click to hide internal directories.