func()

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