domain

Documentation

Index

• type Domain
  • func (d *Domain) Init(config *types.Config) error
  • func (d *Domain) Start(ctx context.Context)
• type EventHandlers
  • func (h *EventHandlers) Create(ctx context.Context, request cacao_common_service.WorkspaceModel, ...)
  • func (h *EventHandlers) Delete(ctx context.Context, request cacao_common_service.WorkspaceModel, ...)
  • func (h *EventHandlers) Update(ctx context.Context, request cacao_common_service.WorkspaceModel, ...)
• type QueryHandlers
  • func (h *QueryHandlers) Get(ctx context.Context, request cacao_common_service.WorkspaceModel) cacao_common_service.WorkspaceModel
  • func (h *QueryHandlers) List(ctx context.Context, request cacao_common_service.Session) cacao_common_service.WorkspaceListModel

Types

type Domain

type Domain struct {
	Storage ports.PersistentStoragePort
	QueryIn ports.IncomingQueryPort
	EventIn ports.IncomingEventPort
	// contains filtered or unexported fields
}

Domain is the base struct for the domain service

func (*Domain) Init

func (d *Domain) Init(config *types.Config) error

Init initializes all the specified adapters

func (*Domain) Start

func (d *Domain) Start(ctx context.Context)

Start will start the domain object, and in turn start all the async adapters

type EventHandlers

type EventHandlers struct {
	Storage  ports.PersistentStoragePort
	EventOut ports.OutgoingEventPort
	TimeSrc  func() time.Time
}

EventHandlers implements IncomingEventPort

func (*EventHandlers) Create

func (h *EventHandlers) Create(ctx context.Context, request cacao_common_service.WorkspaceModel, sink ports.OutgoingEventPort)

Create creates a workspace

func (*EventHandlers) Delete

func (h *EventHandlers) Delete(ctx context.Context, request cacao_common_service.WorkspaceModel, sink ports.OutgoingEventPort)

Delete deletes the workspace

func (*EventHandlers) Update

func (h *EventHandlers) Update(ctx context.Context, request cacao_common_service.WorkspaceModel, sink ports.OutgoingEventPort)

Update updates the workspace

type QueryHandlers

type QueryHandlers struct {
	Storage ports.PersistentStoragePort
}

QueryHandlers implements ports.IncomingQueryHandlers

func (*QueryHandlers) Get

func (h *QueryHandlers) Get(ctx context.Context, request cacao_common_service.WorkspaceModel) cacao_common_service.WorkspaceModel

Get retrieves the workspace

func (*QueryHandlers) List

func (h *QueryHandlers) List(ctx context.Context, request cacao_common_service.Session) cacao_common_service.WorkspaceListModel

List retrieves all workspaces of the user