in datahub/implement.go [824:850]
func (datahub *DataHub) UpdateConnectorWithPara(projectName, topicName, connectorId string, para *UpdateConnectorParameter) (*UpdateConnectorResult, error) {
if !util.CheckProjectName(projectName) {
return nil, NewInvalidParameterErrorWithMessage(projectNameInvalid)
}
if !util.CheckTopicName(topicName) {
return nil, NewInvalidParameterErrorWithMessage(topicNameInvalid)
}
if para == nil {
return nil, NewInvalidParameterErrorWithMessage(parameterNull)
}
path := fmt.Sprintf(connectorPath, projectName, topicName, connectorId)
reqPara := &RequestParameter{
Header: map[string]string{httpHeaderContentType: httpJsonContent},
}
ucr := &UpdateConnectorRequest{
Action: "updateconfig",
ColumnFields: para.ColumnFields,
ColumnNameMap: para.ColumnNameMap,
Config: para.Config,
}
_, commonResp, err := datahub.Client.Post(path, ucr, reqPara)
if err != nil {
return nil, err
}
return NewUpdateConnectorResult(commonResp)
}