func NewGetConnectorResult()

in datahub/resultmodel.go [745:775]

• 30 lines of code
• 11 McCabe index (conditional complexity)

func NewGetConnectorResult(data []byte, commonResp *CommonResponseResult) (*GetConnectorResult, error) {
	cType := &struct {
		Type ConnectorType `json:"Type"`
	}{}
	if err := json.Unmarshal(data, cType); err != nil {
		return nil, err
	}

	switch cType.Type {
	case SinkOdps:
		return unmarshalGetOdpsConnector(commonResp, data)
	case SinkOss:
		return unmarshalGetOssConnector(commonResp, data)
	case SinkEs:
		return unmarshalGetEsConnector(commonResp, data)
	case SinkAds:
		return unmarshalGetAdsConnector(commonResp, data)
	case SinkMysql:
		return unmarshalGetMysqlConnector(commonResp, data)
	case SinkFc:
		return unmarshalGetFcConnector(commonResp, data)
	case SinkOts:
		return unmarshalGetOtsConnector(commonResp, data)
	case SinkDatahub:
		return unmarshalGetDatahubConnector(commonResp, data)
	case SinkHologres:
		return unmarshalGetHologresConnector(commonResp, data)
	default:
		return nil, fmt.Errorf("not support connector type %s", cType.Type.String())
	}
}