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) GetConnectorDefinitionByID(defID string, resourceConfig *structpb.Struct, ...) (*pipelinePB.ConnectorDefinition, error)
- func (c *Connector) GetConnectorDefinitionByUID(defUID uuid.UUID, resourceConfig *structpb.Struct, ...) (*pipelinePB.ConnectorDefinition, error)
- func (c *Connector) ImportDefinitions(con base.IConnector)
- func (c *Connector) Test(defUID uuid.UUID, config *structpb.Struct, logger *zap.Logger) (pipelinePB.Connector_State, error)
- type ConnectorOptions
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Init ¶
func Init(logger *zap.Logger, options ConnectorOptions) base.IConnector
Types ¶
type Connector ¶
func (*Connector) CreateExecution ¶
func (*Connector) GetConnectorDefinitionByID ¶
func (c *Connector) GetConnectorDefinitionByID(defID string, resourceConfig *structpb.Struct, component *pipelinePB.ConnectorComponent) (*pipelinePB.ConnectorDefinition, error)
func (*Connector) GetConnectorDefinitionByUID ¶
func (c *Connector) GetConnectorDefinitionByUID(defUID uuid.UUID, resourceConfig *structpb.Struct, component *pipelinePB.ConnectorComponent) (*pipelinePB.ConnectorDefinition, error)
func (*Connector) ImportDefinitions ¶
func (c *Connector) ImportDefinitions(con base.IConnector)
type ConnectorOptions ¶
type ConnectorOptions struct {
Airbyte airbyte.ConnectorOptions
}
Click to show internal directories.
Click to hide internal directories.