command_handler

Documentation

Index

• type AddParentCommandHandler
  • func NewAddParentCommandHandler(log logger.Logger, es eventstore.AggregateStore) AddParentCommandHandler
• type CommandHandlers
  • func NewCommandHandlers(log logger.Logger, cfg *config.Config, es eventstore.AggregateStore, ...) *CommandHandlers
• type LinkLocationCommandHandler
  • func NewLinkLocationCommandHandler(log logger.Logger, es eventstore.AggregateStore) LinkLocationCommandHandler
• type LinkPhoneNumberCommandHandler
  • func NewLinkPhoneNumberCommandHandler(log logger.Logger, es eventstore.AggregateStore) LinkPhoneNumberCommandHandler
• type RefreshArrCommandHandler
  • func NewRefreshArrCommandHandler(log logger.Logger, es eventstore.AggregateStore, cfg config.Utils) RefreshArrCommandHandler
• type RemoveParentCommandHandler
  • func NewRemoveParentCommandHandler(log logger.Logger, es eventstore.AggregateStore) RemoveParentCommandHandler
• type UpdateOnboardingStatusCommandHandler
  • func NewUpdateOnboardingStatusCommandHandler(log logger.Logger, es eventstore.AggregateStore, cfg config.Utils) UpdateOnboardingStatusCommandHandler
• type UpdateOrganizationOwnerCommandHandler
  • func NewUpdateOrganizationOwnerCommandHandler(log logger.Logger, es eventstore.AggregateStore, cfg config.Utils, ...) UpdateOrganizationOwnerCommandHandler
• type UpsertCustomFieldCommandHandler
  • func NewUpsertCustomFieldCommandHandler(log logger.Logger, es eventstore.AggregateStore) UpsertCustomFieldCommandHandler

Types

type AddParentCommandHandler

type AddParentCommandHandler interface {
	Handle(ctx context.Context, command *command.AddParentCommand) error
}

func NewAddParentCommandHandler

func NewAddParentCommandHandler(log logger.Logger, es eventstore.AggregateStore) AddParentCommandHandler

type CommandHandlers

type CommandHandlers struct {
	LinkPhoneNumberCommand   LinkPhoneNumberCommandHandler
	LinkLocationCommand      LinkLocationCommandHandler
	UpsertCustomFieldCommand UpsertCustomFieldCommandHandler
	AddParentCommand         AddParentCommandHandler
	RemoveParentCommand      RemoveParentCommandHandler
	RefreshArr               RefreshArrCommandHandler
	UpdateOnboardingStatus   UpdateOnboardingStatusCommandHandler
	UpdateOrganizationOwner  UpdateOrganizationOwnerCommandHandler
}

CommandHandlers acts as a container for all command handlers.

func NewCommandHandlers

func NewCommandHandlers(log logger.Logger, cfg *config.Config, es eventstore.AggregateStore, ebs *eventbuffer.EventBufferStoreService) *CommandHandlers

type LinkLocationCommandHandler

type LinkLocationCommandHandler interface {
	Handle(ctx context.Context, command *command.LinkLocationCommand) error
}

func NewLinkLocationCommandHandler

func NewLinkLocationCommandHandler(log logger.Logger, es eventstore.AggregateStore) LinkLocationCommandHandler

type LinkPhoneNumberCommandHandler

type LinkPhoneNumberCommandHandler interface {
	Handle(ctx context.Context, command *command.LinkPhoneNumberCommand) error
}

func NewLinkPhoneNumberCommandHandler

func NewLinkPhoneNumberCommandHandler(log logger.Logger, es eventstore.AggregateStore) LinkPhoneNumberCommandHandler

type RefreshArrCommandHandler

type RefreshArrCommandHandler interface {
	Handle(ctx context.Context, command *command.RefreshArrCommand) error
}

func NewRefreshArrCommandHandler

func NewRefreshArrCommandHandler(log logger.Logger, es eventstore.AggregateStore, cfg config.Utils) RefreshArrCommandHandler

type RemoveParentCommandHandler

type RemoveParentCommandHandler interface {
	Handle(ctx context.Context, command *command.RemoveParentCommand) error
}

func NewRemoveParentCommandHandler

func NewRemoveParentCommandHandler(log logger.Logger, es eventstore.AggregateStore) RemoveParentCommandHandler

type UpdateOnboardingStatusCommandHandler

type UpdateOnboardingStatusCommandHandler interface {
	Handle(ctx context.Context, cmd *command.UpdateOnboardingStatusCommand) error
}

func NewUpdateOnboardingStatusCommandHandler

func NewUpdateOnboardingStatusCommandHandler(log logger.Logger, es eventstore.AggregateStore, cfg config.Utils) UpdateOnboardingStatusCommandHandler

type UpdateOrganizationOwnerCommandHandler

type UpdateOrganizationOwnerCommandHandler interface {
	Handle(ctx context.Context, command *command.UpdateOrganizationOwnerCommand) error
}

func NewUpdateOrganizationOwnerCommandHandler

func NewUpdateOrganizationOwnerCommandHandler(log logger.Logger, es eventstore.AggregateStore, cfg config.Utils, ebs *eventbuffer.EventBufferStoreService) UpdateOrganizationOwnerCommandHandler

type UpsertCustomFieldCommandHandler

type UpsertCustomFieldCommandHandler interface {
	Handle(ctx context.Context, command *command.UpsertCustomFieldCommand) error
}

func NewUpsertCustomFieldCommandHandler

func NewUpsertCustomFieldCommandHandler(log logger.Logger, es eventstore.AggregateStore) UpsertCustomFieldCommandHandler