Documentation
¶
Index ¶
- type OperatorStore
- func (os *OperatorStore) CreateExecution(defUID uuid.UUID, sysVars map[string]any, task string) (*base.ExecutionWrapper, error)
- func (os *OperatorStore) GetOperatorDefinitionByID(defID string, sysVars map[string]any, component *pipelinePB.OperatorComponent) (*pipelinePB.OperatorDefinition, error)
- func (os *OperatorStore) GetOperatorDefinitionByUID(defUID uuid.UUID, sysVars map[string]any, ...) (*pipelinePB.OperatorDefinition, error)
- func (os *OperatorStore) Import(op base.IOperator)
- func (os *OperatorStore) ListOperatorDefinitions(sysVars map[string]any, returnTombstone bool) []*pipelinePB.OperatorDefinition
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type OperatorStore ¶
type OperatorStore struct {
// contains filtered or unexported fields
}
Operator is the derived operator
func Init ¶
func Init(logger *zap.Logger, usageHandler base.UsageHandler) *OperatorStore
Init initializes the operator
func (*OperatorStore) CreateExecution ¶
func (os *OperatorStore) CreateExecution(defUID uuid.UUID, sysVars map[string]any, task string) (*base.ExecutionWrapper, error)
func (*OperatorStore) GetOperatorDefinitionByID ¶
func (os *OperatorStore) GetOperatorDefinitionByID(defID string, sysVars map[string]any, component *pipelinePB.OperatorComponent) (*pipelinePB.OperatorDefinition, error)
Get the operator definition by definition id
func (*OperatorStore) GetOperatorDefinitionByUID ¶
func (os *OperatorStore) GetOperatorDefinitionByUID(defUID uuid.UUID, sysVars map[string]any, component *pipelinePB.OperatorComponent) (*pipelinePB.OperatorDefinition, error)
func (*OperatorStore) Import ¶
func (os *OperatorStore) Import(op base.IOperator)
Imports imports the operator definitions
func (*OperatorStore) ListOperatorDefinitions ¶
func (os *OperatorStore) ListOperatorDefinitions(sysVars map[string]any, returnTombstone bool) []*pipelinePB.OperatorDefinition
Get the list of operator definitions under this operator
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.