pkg

Documentation

Index

• func Init(logger *zap.Logger) base.IOperator
• type Operator
  • func (o *Operator) CreateExecution(defUID uuid.UUID, task string, config *structpb.Struct, logger *zap.Logger) (base.IExecution, error)
  • func (o *Operator) ImportDefinitions(op base.IOperator)

Functions

func Init

func Init(logger *zap.Logger) base.IOperator

Init initializes the operator

Types

type Operator

type Operator struct {
	base.Operator
	// contains filtered or unexported fields
}

Operator is the derived operator

func (*Operator) CreateExecution

func (o *Operator) CreateExecution(defUID uuid.UUID, task string, config *structpb.Struct, logger *zap.Logger) (base.IExecution, error)

CreateExecution creates the derived execution

func (*Operator) ImportDefinitions

func (o *Operator) ImportDefinitions(op base.IOperator)

ImportDefinitions imports the operator definitions