func()

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