rest

Documentation

Index

• func Init(logger *zap.Logger, options OperatorOptions) base.IOperator
• type Operation
  • func (c *Operation) Execute(inputs []*structpb.Struct) ([]*structpb.Struct, error)
  • func (c *Operation) Test() (connectorPB.ConnectorResource_State, error)
• type Operator
  • func (o *Operator) CreateExecution(defUid uuid.UUID, config *structpb.Struct, logger *zap.Logger) (base.IExecution, error)
• type OperatorOptions
• type Request
• type Response

Functions

func Init

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

Types

type Operation

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

func (*Operation) Execute

func (c *Operation) Execute(inputs []*structpb.Struct) ([]*structpb.Struct, error)

func (*Operation) Test

func (c *Operation) Test() (connectorPB.ConnectorResource_State, error)

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{}

type Request

type Request struct {
	URL         string            `json:"url"`
	Method      string            `json:"method"`
	RequestBody string            `json:"request_body"`
	Headers     map[string]string `json:"headers"`
}

type Response

type Response struct {
	StatusCode   int               `json:"status_code"`
	ResponseBody string            `json:"response_body"`
	Headers      map[string]string `json:"headers"`
}