metadata

Documentation

Index

• type MetadataService
  • func NewMetadataService(storage MetadataStorage) MetadataService
• type MetadataServiceImpl
  • func (s *MetadataServiceImpl) GetFlow(name string, id string) (*flow.Flow, error)
  • func (s *MetadataServiceImpl) GetMetadataStorage() MetadataStorage
  • func (s *MetadataServiceImpl) ValidateFlow(wf model.Workflow) error
• type MetadataStorage

Types

type MetadataService

type MetadataService interface {
	GetFlow(name string, id string) (*flow.Flow, error)
	ValidateFlow(wf model.Workflow) error
	GetMetadataStorage() MetadataStorage
}

func NewMetadataService

func NewMetadataService(storage MetadataStorage) MetadataService

type MetadataServiceImpl

type MetadataServiceImpl struct {
	// contains filtered or unexported fields
}

func (*MetadataServiceImpl) GetFlow

func (s *MetadataServiceImpl) GetFlow(name string, id string) (*flow.Flow, error)

func (*MetadataServiceImpl) GetMetadataStorage

func (s *MetadataServiceImpl) GetMetadataStorage() MetadataStorage

func (*MetadataServiceImpl) ValidateFlow

func (s *MetadataServiceImpl) ValidateFlow(wf model.Workflow) error

type MetadataStorage

type MetadataStorage interface {
	SaveWorkflowDefinition(wf model.Workflow) error
	DeleteWorkflowDefinition(name string) error
	GetWorkflowDefinition(name string) (*model.Workflow, error)
	SaveActionDefinition(action model.ActionDefinition) error
	DeleteActionDefinition(action string) error
	GetActionDefinition(action string) (*model.ActionDefinition, error)
}