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

Types

type Operator

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

func (*Operator) CreateExecution

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

func (*Operator) ImportDefinitions

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