instill

Documentation

Index

• func Init(logger *zap.Logger) base.IConnector
• type Connection
  • func (con *Connection) Execute(inputs []*connectorPB.DataPayload) ([]*connectorPB.DataPayload, error)
  • func (con *Connection) GetTask() (connectorPB.Task, error)
  • func (con *Connection) Test() (connectorPB.Connector_State, error)
• type Connector
  • func (c *Connector) CreateConnection(defUid uuid.UUID, config *structpb.Struct, logger *zap.Logger) (base.IConnection, error)

Functions

func Init

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

Types

type Connection

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

func (*Connection) Execute

func (con *Connection) Execute(inputs []*connectorPB.DataPayload) ([]*connectorPB.DataPayload, error)

func (*Connection) GetTask

func (con *Connection) GetTask() (connectorPB.Task, error)

func (*Connection) Test

func (con *Connection) Test() (connectorPB.Connector_State, error)

type Connector

type Connector struct {
	base.BaseConnector
}

func (*Connector) CreateConnection

func (c *Connector) CreateConnection(defUid uuid.UUID, config *structpb.Struct, logger *zap.Logger) (base.IConnection, error)