destination

Documentation

Index

• func Init(logger *zap.Logger, options ConnectorOptions) base.IConnector
• type Connector
  • func (c *Connector) CreateExecution(defUID uuid.UUID, task string, config *structpb.Struct, logger *zap.Logger) (base.IExecution, error)
  • func (c *Connector) ImportDefinitions(con base.IConnector)
  • func (c *Connector) Test(defUid uuid.UUID, config *structpb.Struct, logger *zap.Logger) (connectorPB.ConnectorResource_State, error)
• type ConnectorOptions

Functions

func Init

func Init(logger *zap.Logger, options ConnectorOptions) base.IConnector

Types

type Connector

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

func (*Connector) CreateExecution

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

func (*Connector) ImportDefinitions

func (c *Connector) ImportDefinitions(con base.IConnector)

func (*Connector) Test

func (c *Connector) Test(defUid uuid.UUID, config *structpb.Struct, logger *zap.Logger) (connectorPB.ConnectorResource_State, error)

type ConnectorOptions

type ConnectorOptions struct {
	Airbyte airbyte.ConnectorOptions
}