link

Documentation

Index

• Constants
• Variables
• type Configs
• type Input
• type Link
• type LinkConfigs
• type LinkCreateOpts
• type LinkCreateResponse
  • func Create(c *golangsdk.ServiceClient, clusterId string, opts LinkCreateOpts) (*LinkCreateResponse, error)
• type LinkDeleteResponse
  • func Delete(c *golangsdk.ServiceClient, clusterId string, linkName string) (*LinkDeleteResponse, error)
• type LinkDetail
  • func Get(c *golangsdk.ServiceClient, clusterId string, linkName string) (*LinkDetail, error)
• type LinkUpdateResponse
  • func Update(c *golangsdk.ServiceClient, clusterId string, linkName string, ...) (*LinkUpdateResponse, error)
• type LinkValidationDetail

Constants

const (
	GenericJdbcConnector   = "generic-jdbc-connector"
	ObsConnector           = "obs-connector"
	ThirdpartyObsConnector = "thirdparty-obs-connector"
	HdfsConnector          = "hdfs-connector"
	HbaseConnector         = "hbase-connector"
	HiveConnector          = "hive-connector"
	SftpConnector          = "sftp-connector"
	FtpConnector           = "ftp-connector"
	MongodbConnector       = "mongodb-connector"
	KafkaConnector         = "kafka-connector"
	DisConnector           = "dis-connector"
	ElasticsearchConnector = "elasticsearch-connector"
	DliConnector           = "dli-connector"
	OpentsdbConnector      = "opentsdb-connector"
	DmsKafkaConnector      = "dms-kafka-connector"
)

Variables

var RequestOpts = golangsdk.RequestOpts{
	MoreHeaders: map[string]string{"Content-Type": "application/json", "X-Language": "en-us"},
}

Types

type Configs

type Configs struct {
	Inputs []Input `json:"inputs" required:"true"`
	Name   string  `json:"name" required:"true"`
}

type Input

type Input struct {
	Name  string `json:"name,omitempty"`
	Value string `json:"value,omitempty"`
	Type  string `json:"type,omitempty"`
}

type Link

type Link struct {
	Name string `json:"name" required:"true"`
	// Connector name. The mappings between the connectors and links are as follows:
	// generic-jdbc-connector: link to a relational database;
	// obs-connector: link to OBS and link to OSS on Alibaba Cloud
	// hdfs-connector: link to HDFS;
	// hbase-connector: link to HBase and link to CloudTable; hive-connector: link to Hive;
	// ftp-connector/sftp-connector: link to an FTP or SFTP server;
	// mongodb-connector: link to MongoDB;
	// redis-connector: link to Redis/DCS;
	// nas-connector: link to NAS/SFS;
	// kafka-connector: link to Kafka;
	// dis-connector: link to DIS;
	// elasticsearch-connector: link to Elasticsearch/Cloud Search Service;
	// dli-connector: link to DLI;
	// opentsdb-connector: link to CloudTable OpenTSDB;
	// http-connector: link to HTTP/HTTPS (No link parameters are required.);
	// thirdparty-obs-connector: link to KODO/COS/Amazon S3;
	// dms-kafka-connector: link to DMS Kafka
	ConnectorName    string      `json:"connector-name" required:"true"`
	LinkConfigValues LinkConfigs `json:"link-config-values" required:"true"`
	Enabled          *bool       `json:"enabled,omitempty"`
	CreationUser     string      `json:"creation-user,omitempty"`
	CreationDate     *int        `json:"creation-date,omitempty"`
	UpdateUser       string      `json:"update-user,omitempty"`
	UpdateDate       *int        `json:"update-date,omitempty"`
}

type LinkConfigs

type LinkConfigs struct {
	Configs []Configs `json:"configs,omitempty"`
}

type LinkCreateOpts

type LinkCreateOpts struct {
	Links []Link `json:"links" required:"true"`
}

type LinkCreateResponse

type LinkCreateResponse struct {
	Name             string             `json:"name"`
	ValidationResult []validationResult `json:"validation-result"`
}

func Create

func Create(c *golangsdk.ServiceClient, clusterId string, opts LinkCreateOpts) (*LinkCreateResponse, error)

type LinkDeleteResponse

type LinkDeleteResponse struct {
	// Error code
	ErrCode string `json:"errCode"`
	// Error message
	ErrMessage string `json:"externalMessage"`
}

func Delete

func Delete(c *golangsdk.ServiceClient, clusterId string, linkName string) (*LinkDeleteResponse, error)

type LinkDetail

type LinkDetail struct {
	// Link list. For details, see the description of the links parameter.
	Links []Link `json:"links"`
	// Source and destination data sources not supported by table/file migration
	FromToUnMapping string `json:"fromTo-unMapping"`
	// Source and destination data sources supported by entire DB migration
	BatchFromToMapping string `json:"batchFromTo-mapping"`
}

func Get

func Get(c *golangsdk.ServiceClient, clusterId string, linkName string) (*LinkDetail, error)

type LinkUpdateResponse

type LinkUpdateResponse struct {
	ValidationResult []validationResult `json:"validation-result"`
}

func Update

func Update(c *golangsdk.ServiceClient, clusterId string, linkName string, opts LinkCreateOpts) (*LinkUpdateResponse, error)

type LinkValidationDetail

type LinkValidationDetail struct {
	Message string `json:"message"`
	// ERROR,WARNING
	Status string `json:"status"`
}