operator

Documentation

Index

• type Store
  • func Init(logger *zap.Logger) *Store
  • func (os *Store) CreateExecution(defUID uuid.UUID, sysVars map[string]any, task string) (*base.ExecutionWrapper, error)
  • func (os *Store) GetOperatorDefinitionByID(defID string, sysVars map[string]any, component *pipelinePB.OperatorComponent) (*pipelinePB.OperatorDefinition, error)
  • func (os *Store) GetOperatorDefinitionByUID(defUID uuid.UUID, sysVars map[string]any, ...) (*pipelinePB.OperatorDefinition, error)
  • func (os *Store) Import(op base.IOperator)
  • func (os *Store) ListOperatorDefinitions(sysVars map[string]any, returnTombstone bool) []*pipelinePB.OperatorDefinition

Types

type Store

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

Store holds in-memory information about the initialized operators.

func Init

func Init(logger *zap.Logger) *Store

Init initializes the different operator components and loads their information to memory.

func (*Store) CreateExecution

func (os *Store) CreateExecution(defUID uuid.UUID, sysVars map[string]any, task string) (*base.ExecutionWrapper, error)

CreateExecution initializes the execution of a operator given its UID.

func (*Store) GetOperatorDefinitionByID

func (os *Store) GetOperatorDefinitionByID(defID string, sysVars map[string]any, component *pipelinePB.OperatorComponent) (*pipelinePB.OperatorDefinition, error)

GetOperatorDefinitionByID returns a operator definition by its ID.

func (*Store) GetOperatorDefinitionByUID

func (os *Store) GetOperatorDefinitionByUID(defUID uuid.UUID, sysVars map[string]any, component *pipelinePB.OperatorComponent) (*pipelinePB.OperatorDefinition, error)

GetOperatorDefinitionByUID returns a operator definition by its UID.

func (*Store) Import

func (os *Store) Import(op base.IOperator)

Import loads the operator definitions into memory.

func (*Store) ListOperatorDefinitions

func (os *Store) ListOperatorDefinitions(sysVars map[string]any, returnTombstone bool) []*pipelinePB.OperatorDefinition

ListOperatorDefinitions returns all the loaded operator definitions.