func()

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