in datahub/requestmodel.go [233:256]
func (ccr *CreateConnectorRequest) requestBodyEncode() ([]byte, error) {
switch ccr.Type {
case SinkOdps:
return marshalCreateOdpsConnector(ccr)
case SinkOss:
return marshalCreateOssConnector(ccr)
case SinkEs:
return marshalCreateEsConnector(ccr)
case SinkAds:
return marshalCreateAdsConnector(ccr)
case SinkMysql:
return marshalCreateMysqlConnector(ccr)
case SinkFc:
return marshalCreateFcConnector(ccr)
case SinkOts:
return marshalCreateOtsConnector(ccr)
case SinkDatahub:
return marshalCreateDatahubConnector(ccr)
case SinkHologres:
return marshalCreateHologresConnector(ccr)
default:
return nil, fmt.Errorf("not support connector type config: %s", ccr.Type.String())
}
}