pkg

Documentation

Index

• func Init(logger *zap.Logger, options OperatorOptions) base.IOperator
• type Operator
  • func (o *Operator) CreateExecution(defUid uuid.UUID, config *structpb.Struct, logger *zap.Logger) (base.IExecution, error)
• type OperatorOptions

Functions

func Init

func Init(logger *zap.Logger, options OperatorOptions) base.IOperator

Types

type Operator

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

func (*Operator) CreateExecution

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

type OperatorOptions

type OperatorOptions struct {
	Base64         base64.OperatorOptions
	TextExtraction textextraction.OperatorOptions
	Pipeline       pipeline.OperatorOptions
	JSON           json.OperatorOptions
	REST           rest.OperatorOptions
}