in datahub/requestmodel.go [265:293]
func (ucr *UpdateConnectorRequest) requestBodyEncode() ([]byte, error) {
if ucr.Config == nil {
return marshalUpdateConnector(ucr)
}
switch ucr.Config.(type) {
case SinkOdpsConfig:
return marshalUpdateOdpsConnector(ucr)
case SinkOssConfig:
return marshalUpdateOssConnector(ucr)
case SinkEsConfig:
return marshalUpdateEsConnector(ucr)
case SinkAdsConfig:
return marshalUpdateAdsConnector(ucr)
case SinkMysqlConfig:
return marshalUpdateMysqlConnector(ucr)
case SinkFcConfig:
return marshalUpdateFcConnector(ucr)
case SinkOtsConfig:
return marshalUpdateOtsConnector(ucr)
case SinkDatahubConfig:
return marshalUpdateDatahubConnector(ucr)
case SinkHologresConfig:
return marshalUpdateHologresConnector(ucr)
default:
return nil, fmt.Errorf("this connector type not support, %t", reflect.TypeOf(ucr.Config))
}
}