pkg

package
v0.14.0-beta Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 12, 2024 License: MIT Imports: 20 Imported by: 4

Documentation

Index

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

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) 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)

func (*Connector) Test

func (c *Connector) Test(defUID uuid.UUID, config *structpb.Struct, logger *zap.Logger) (pipelinePB.Connector_State, error)

type ConnectorOptions

type ConnectorOptions struct {
	Airbyte airbyte.ConnectorOptions
}

Directories

Path Synopsis
airbyte
v0
archetypeai
v0
bigquery
v0
googlecloudstorage
v0
googlesearch
v0
huggingface
v0
instill
v0
numbers
v0
openai
v0
pinecone
v0
redis
v0
restapi
v0
stabilityai
v0
website
v0

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL