datamodel

Documentation

Index

• type Commands
  • func NewCommands(dataModelRepo datamodel.Repository, ...) *Commands
• type DeleteDataModelCommand
• type DeleteDataModelHandler
  • func NewDeleteDataModelHandler(svc datamodel.Service, workspaceReadModel workspacequery.WorkspaceReadModel, ...) DeleteDataModelHandler
• type PatchDataModelCommand
• type PatchDataModelHandler
  • func NewPatchDataModelHandler(svc datamodel.Service, workspaceReadModel workspacequery.WorkspaceReadModel, ...) PatchDataModelHandler

Types

type Commands

type Commands struct {
	PatchDataModel  PatchDataModelHandler
	DeleteDataModel DeleteDataModelHandler
}

func NewCommands

func NewCommands(dataModelRepo datamodel.Repository, workspaceReadModel workspacequery.WorkspaceReadModel, dataModelFactory *datamodel.Factory, dataModelReadModel datamodelquery.DataModelReadModel, eventBus eventbus.EventBus) *Commands

type DeleteDataModelCommand

type DeleteDataModelCommand struct {
	ID          string   `validate:"required"`
	WorkspaceID string   `validate:"required"`
	Headers     []string `validate:"deleteDataModelHeaders"`
	RowIDs      []string
}

type DeleteDataModelHandler

type DeleteDataModelHandler interface {
	Handle(ctx context.Context, cmd *DeleteDataModelCommand) error
}

func NewDeleteDataModelHandler

func NewDeleteDataModelHandler(svc datamodel.Service, workspaceReadModel workspacequery.WorkspaceReadModel, dataModelReadModel datamodelquery.DataModelReadModel) DeleteDataModelHandler

type PatchDataModelCommand

type PatchDataModelCommand struct {
	WorkspaceID string `validate:"required"`
	Name        string `validate:"required,dataModelName"`
	Async       bool
	Headers     []string   `validate:"required,dataModelHeaders"`
	Rows        [][]string `validate:"required,dataModelRows"`
}

type PatchDataModelHandler

type PatchDataModelHandler interface {
	Handle(ctx context.Context, cmd *PatchDataModelCommand) (string, error)
}

func NewPatchDataModelHandler

func NewPatchDataModelHandler(svc datamodel.Service, workspaceReadModel workspacequery.WorkspaceReadModel, dataModelReadModel datamodelquery.DataModelReadModel) PatchDataModelHandler