connect

Documentation

Index

• 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)
• type Error

Functions

func CreateConnectorOpenApi

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

func DeleteConnectorOpenApi

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

func GetConnectorOpenApi

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

func GetConnectorStatusOpenApi

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

func GetServerInfo

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

func GetTaskConfigs

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

func GetTaskStatusOpenApi

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

func ListConnectorPluginOpenApi

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

func ListTopicsOpenApi

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

func PauseConnectorOpenApi

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

func RestartConnectorOpenApi

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

func RestartTaskOpenApi

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

func ResumeConnectorOpenApi

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

func UpdateConnectorOpenApi

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

Types

type ConnectorConfig

type ConnectorConfig = map[string]string

func GetConnectorConfigOpenApi

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

type ConnectorName

type ConnectorName = string

func ListConnectorsOpenApi

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

type Error

type Error struct {
	Code    int    `json:"error_code"`
	Message string `json:"message"`
}