connect

Dec 13, 2024

Changes in this version

+ func CreateConnectorOpenApi(cfg *openapi.Configuration, configJson io.Reader) (*openapi.ConnectorInfo, error)

+ func DeleteConnectorOpenApi(cfg *openapi.Configuration, name string) error

+ func GetConnectorOpenApi(cfg *openapi.Configuration, name string) (*openapi.ConnectorInfo, error)

+ func GetConnectorStatusOpenApi(cfg *openapi.Configuration, name string) (*openapi.ConnectorStateInfo, error)

+ func GetServerInfo(cfg *openapi.Configuration) (*openapi.ServerInfo, error)

+ func GetTaskConfigs(cfg *openapi.Configuration, name string) ([]openapi.TaskInfo, error)

+ func GetTaskStatusOpenApi(cfg *openapi.Configuration, connector string, taskID int32) (*openapi.TaskState, error)

+ func ListConnectorPluginOpenApi(cfg *openapi.Configuration) ([]openapi.PluginInfo, error)

+ func ListTopicsOpenApi(cfg *openapi.Configuration, name string) (*map[string]openapi.ConnectorActiveTopicsValue, error)

+ func PauseConnectorOpenApi(cfg *openapi.Configuration, name string) error

+ func RestartConnectorOpenApi(cfg *openapi.Configuration, name string, includeTasks, onlyFailed bool) error

+ func RestartTaskOpenApi(cfg *openapi.Configuration, connector string, taskId int32) error

+ func ResumeConnectorOpenApi(cfg *openapi.Configuration, name string) error

+ func UpdateConnectorOpenApi(cfg *openapi.Configuration, name string, configJson io.Reader) (*openapi.ConnectorInfo, error)

type ConnectorConfig

+ func GetConnectorConfigOpenApi(cfg *openapi.Configuration, name string) (*ConnectorConfig, error)

type ConnectorName

+ func ListConnectorsOpenApi(cfg *openapi.Configuration) ([]ConnectorName, error)

Mar 26, 2022

Changes in this version

type ConnectorName

+ func ListConnectorNames(endpoint string) ([]ConnectorName, error)

Oct 24, 2021

Changes in this version

type Connector

+ func UpdateConnector(endpoint, name string, configJSON io.Reader) (*Connector, error)

Oct 13, 2021

Changes in this version

+ func PauseConnector(endpoint, name string) error

+ func RestartConnector(endpoint, name string) error

+ func RestartTask(endpoint, name, id string) error

+ func ResumeConnector(endpoint, name string) error

type ConnectorName

+ func ListConnectors(endpoint string) ([]ConnectorName, error)

Oct 12, 2021

Changes in this version

+ func DeleteConnector(endpoint, name string) error

+ func ListTopics(endpoint, name string) ([]string, error)

+ type Connector struct

+ Config ConnectorConfig

+ Name ConnectorName

+ Tasks []Task

+ Type string

+ func CreateConnector(endpoint string, configJSON io.Reader) (*Connector, error)

+ func GetConnector(endpoint, name string) (*Connector, error)

+ type ConnectorConfig map[string]string

+ func GetConnectorConfig(endpoint, name string) (*ConnectorConfig, error)

+ type ConnectorName = string

+ func GetConnectorNames(endpoint string) ([]ConnectorName, error)

+ type ConnectorPlugin struct

+ Class string

+ Type string

+ Version string

+ func ListConnectorPlugin(endpoint string) ([]ConnectorPlugin, error)

+ type ConnectorState struct

+ State string

+ WorkerID string

+ type ConnectorStatus struct

+ Name string

+ State ConnectorState

+ Tasks []TaskState

+ Type string

+ func GetConnectorStatus(endpoint, name string) (*ConnectorStatus, error)

+ type Error struct

+ Code int

+ Message string

+ type Task struct

+ Connector string

+ ID int

+ type TaskConfig map[string]string

+ type TaskInfo struct

+ Config TaskConfig

+ ID Task

+ func ListTasks(endpoint, name string) ([]TaskInfo, error)

+ type TaskState struct

+ ID int

+ State string

+ WorkerID string

+ func GetTaskStatus(endpoint, name string, id int) (*TaskState, error)

+ type TaskTopics map[string]Topics

+ type Topics struct

+ Topics []string

+ type Worker struct

+ Commit string

+ ID string

+ Version string

+ func GetWorker(endpoint string) (*Worker, error)