diff --git a/services/datafactory/mgmt/2018-06-01/datafactory/datafactoryapi/interfaces.go b/services/datafactory/mgmt/2018-06-01/datafactory/datafactoryapi/interfaces.go index 6cc548312413..3853330a34ad 100644 --- a/services/datafactory/mgmt/2018-06-01/datafactory/datafactoryapi/interfaces.go +++ b/services/datafactory/mgmt/2018-06-01/datafactory/datafactoryapi/interfaces.go @@ -52,6 +52,7 @@ var _ FactoriesClientAPI = (*datafactory.FactoriesClient)(nil) type ExposureControlClientAPI interface { GetFeatureValue(ctx context.Context, locationID string, exposureControlRequest datafactory.ExposureControlRequest) (result datafactory.ExposureControlResponse, err error) GetFeatureValueByFactory(ctx context.Context, resourceGroupName string, factoryName string, exposureControlRequest datafactory.ExposureControlRequest) (result datafactory.ExposureControlResponse, err error) + QueryFeatureValuesByFactory(ctx context.Context, resourceGroupName string, factoryName string, exposureControlBatchRequest datafactory.ExposureControlBatchRequest) (result datafactory.ExposureControlBatchResponse, err error) } var _ ExposureControlClientAPI = (*datafactory.ExposureControlClient)(nil) diff --git a/services/datafactory/mgmt/2018-06-01/datafactory/enums.go b/services/datafactory/mgmt/2018-06-01/datafactory/enums.go index e4c33668cab4..03f2e3cf452f 100644 --- a/services/datafactory/mgmt/2018-06-01/datafactory/enums.go +++ b/services/datafactory/mgmt/2018-06-01/datafactory/enums.go @@ -2550,6 +2550,8 @@ const ( TypeAzureBlobStorageWriteSettings TypeBasicStoreWriteSettings = "AzureBlobStorageWriteSettings" // TypeAzureDataLakeStoreWriteSettings ... TypeAzureDataLakeStoreWriteSettings TypeBasicStoreWriteSettings = "AzureDataLakeStoreWriteSettings" + // TypeAzureFileStorageWriteSettings ... + TypeAzureFileStorageWriteSettings TypeBasicStoreWriteSettings = "AzureFileStorageWriteSettings" // TypeFileServerWriteSettings ... TypeFileServerWriteSettings TypeBasicStoreWriteSettings = "FileServerWriteSettings" // TypeSftpWriteSettings ... @@ -2560,7 +2562,7 @@ const ( // PossibleTypeBasicStoreWriteSettingsValues returns an array of possible values for the TypeBasicStoreWriteSettings const type. func PossibleTypeBasicStoreWriteSettingsValues() []TypeBasicStoreWriteSettings { - return []TypeBasicStoreWriteSettings{TypeAzureBlobFSWriteSettings, TypeAzureBlobStorageWriteSettings, TypeAzureDataLakeStoreWriteSettings, TypeFileServerWriteSettings, TypeSftpWriteSettings, TypeStoreWriteSettings} + return []TypeBasicStoreWriteSettings{TypeAzureBlobFSWriteSettings, TypeAzureBlobStorageWriteSettings, TypeAzureDataLakeStoreWriteSettings, TypeAzureFileStorageWriteSettings, TypeFileServerWriteSettings, TypeSftpWriteSettings, TypeStoreWriteSettings} } // TypeBasicTrigger enumerates the values for type basic trigger. diff --git a/services/datafactory/mgmt/2018-06-01/datafactory/exposurecontrol.go b/services/datafactory/mgmt/2018-06-01/datafactory/exposurecontrol.go index 43a61f74edad..c5b52c8e8682 100644 --- a/services/datafactory/mgmt/2018-06-01/datafactory/exposurecontrol.go +++ b/services/datafactory/mgmt/2018-06-01/datafactory/exposurecontrol.go @@ -208,3 +208,95 @@ func (client ExposureControlClient) GetFeatureValueByFactoryResponder(resp *http result.Response = autorest.Response{Response: resp} return } + +// QueryFeatureValuesByFactory get list of exposure control features for specific factory. +// Parameters: +// resourceGroupName - the resource group name. +// factoryName - the factory name. +// exposureControlBatchRequest - the exposure control request for list of features. +func (client ExposureControlClient) QueryFeatureValuesByFactory(ctx context.Context, resourceGroupName string, factoryName string, exposureControlBatchRequest ExposureControlBatchRequest) (result ExposureControlBatchResponse, err error) { + if tracing.IsEnabled() { + ctx = tracing.StartSpan(ctx, fqdn+"/ExposureControlClient.QueryFeatureValuesByFactory") + defer func() { + sc := -1 + if result.Response.Response != nil { + sc = result.Response.Response.StatusCode + } + tracing.EndSpan(ctx, sc, err) + }() + } + if err := validation.Validate([]validation.Validation{ + {TargetValue: resourceGroupName, + Constraints: []validation.Constraint{{Target: "resourceGroupName", Name: validation.MaxLength, Rule: 90, Chain: nil}, + {Target: "resourceGroupName", Name: validation.MinLength, Rule: 1, Chain: nil}, + {Target: "resourceGroupName", Name: validation.Pattern, Rule: `^[-\w\._\(\)]+$`, Chain: nil}}}, + {TargetValue: factoryName, + Constraints: []validation.Constraint{{Target: "factoryName", Name: validation.MaxLength, Rule: 63, Chain: nil}, + {Target: "factoryName", Name: validation.MinLength, Rule: 3, Chain: nil}, + {Target: "factoryName", Name: validation.Pattern, Rule: `^[A-Za-z0-9]+(?:-[A-Za-z0-9]+)*$`, Chain: nil}}}, + {TargetValue: exposureControlBatchRequest, + Constraints: []validation.Constraint{{Target: "exposureControlBatchRequest.ExposureControlRequests", Name: validation.Null, Rule: true, Chain: nil}}}}); err != nil { + return result, validation.NewError("datafactory.ExposureControlClient", "QueryFeatureValuesByFactory", err.Error()) + } + + req, err := client.QueryFeatureValuesByFactoryPreparer(ctx, resourceGroupName, factoryName, exposureControlBatchRequest) + if err != nil { + err = autorest.NewErrorWithError(err, "datafactory.ExposureControlClient", "QueryFeatureValuesByFactory", nil, "Failure preparing request") + return + } + + resp, err := client.QueryFeatureValuesByFactorySender(req) + if err != nil { + result.Response = autorest.Response{Response: resp} + err = autorest.NewErrorWithError(err, "datafactory.ExposureControlClient", "QueryFeatureValuesByFactory", resp, "Failure sending request") + return + } + + result, err = client.QueryFeatureValuesByFactoryResponder(resp) + if err != nil { + err = autorest.NewErrorWithError(err, "datafactory.ExposureControlClient", "QueryFeatureValuesByFactory", resp, "Failure responding to request") + } + + return +} + +// QueryFeatureValuesByFactoryPreparer prepares the QueryFeatureValuesByFactory request. +func (client ExposureControlClient) QueryFeatureValuesByFactoryPreparer(ctx context.Context, resourceGroupName string, factoryName string, exposureControlBatchRequest ExposureControlBatchRequest) (*http.Request, error) { + pathParameters := map[string]interface{}{ + "factoryName": autorest.Encode("path", factoryName), + "resourceGroupName": autorest.Encode("path", resourceGroupName), + "subscriptionId": autorest.Encode("path", client.SubscriptionID), + } + + const APIVersion = "2018-06-01" + queryParameters := map[string]interface{}{ + "api-version": APIVersion, + } + + preparer := autorest.CreatePreparer( + autorest.AsContentType("application/json; charset=utf-8"), + autorest.AsPost(), + autorest.WithBaseURL(client.BaseURI), + autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataFactory/factories/{factoryName}/queryFeaturesValue", pathParameters), + autorest.WithJSON(exposureControlBatchRequest), + autorest.WithQueryParameters(queryParameters)) + return preparer.Prepare((&http.Request{}).WithContext(ctx)) +} + +// QueryFeatureValuesByFactorySender sends the QueryFeatureValuesByFactory request. The method will close the +// http.Response Body if it receives an error. +func (client ExposureControlClient) QueryFeatureValuesByFactorySender(req *http.Request) (*http.Response, error) { + return client.Send(req, azure.DoRetryWithRegistration(client.Client)) +} + +// QueryFeatureValuesByFactoryResponder handles the response to the QueryFeatureValuesByFactory request. The method always +// closes the http.Response Body. +func (client ExposureControlClient) QueryFeatureValuesByFactoryResponder(resp *http.Response) (result ExposureControlBatchResponse, err error) { + err = autorest.Respond( + resp, + azure.WithErrorUnlessStatusCode(http.StatusOK), + autorest.ByUnmarshallingJSON(&result), + autorest.ByClosing()) + result.Response = autorest.Response{Response: resp} + return +} diff --git a/services/datafactory/mgmt/2018-06-01/datafactory/models.go b/services/datafactory/mgmt/2018-06-01/datafactory/models.go index cda575bb9735..327084ea9377 100644 --- a/services/datafactory/mgmt/2018-06-01/datafactory/models.go +++ b/services/datafactory/mgmt/2018-06-01/datafactory/models.go @@ -13287,7 +13287,7 @@ type AzureBlobFSWriteSettings struct { MaxConcurrentConnections interface{} `json:"maxConcurrentConnections,omitempty"` // CopyBehavior - The type of copy behavior for copy sink. CopyBehavior interface{} `json:"copyBehavior,omitempty"` - // Type - Possible values include: 'TypeStoreWriteSettings', 'TypeFileServerWriteSettings', 'TypeAzureDataLakeStoreWriteSettings', 'TypeAzureBlobFSWriteSettings', 'TypeAzureBlobStorageWriteSettings', 'TypeSftpWriteSettings' + // Type - Possible values include: 'TypeStoreWriteSettings', 'TypeAzureFileStorageWriteSettings', 'TypeFileServerWriteSettings', 'TypeAzureDataLakeStoreWriteSettings', 'TypeAzureBlobFSWriteSettings', 'TypeAzureBlobStorageWriteSettings', 'TypeSftpWriteSettings' Type TypeBasicStoreWriteSettings `json:"type,omitempty"` } @@ -13313,6 +13313,11 @@ func (abfws AzureBlobFSWriteSettings) MarshalJSON() ([]byte, error) { return json.Marshal(objectMap) } +// AsAzureFileStorageWriteSettings is the BasicStoreWriteSettings implementation for AzureBlobFSWriteSettings. +func (abfws AzureBlobFSWriteSettings) AsAzureFileStorageWriteSettings() (*AzureFileStorageWriteSettings, bool) { + return nil, false +} + // AsFileServerWriteSettings is the BasicStoreWriteSettings implementation for AzureBlobFSWriteSettings. func (abfws AzureBlobFSWriteSettings) AsFileServerWriteSettings() (*FileServerWriteSettings, bool) { return nil, false @@ -14606,7 +14611,7 @@ type AzureBlobStorageWriteSettings struct { MaxConcurrentConnections interface{} `json:"maxConcurrentConnections,omitempty"` // CopyBehavior - The type of copy behavior for copy sink. CopyBehavior interface{} `json:"copyBehavior,omitempty"` - // Type - Possible values include: 'TypeStoreWriteSettings', 'TypeFileServerWriteSettings', 'TypeAzureDataLakeStoreWriteSettings', 'TypeAzureBlobFSWriteSettings', 'TypeAzureBlobStorageWriteSettings', 'TypeSftpWriteSettings' + // Type - Possible values include: 'TypeStoreWriteSettings', 'TypeAzureFileStorageWriteSettings', 'TypeFileServerWriteSettings', 'TypeAzureDataLakeStoreWriteSettings', 'TypeAzureBlobFSWriteSettings', 'TypeAzureBlobStorageWriteSettings', 'TypeSftpWriteSettings' Type TypeBasicStoreWriteSettings `json:"type,omitempty"` } @@ -14632,6 +14637,11 @@ func (absws AzureBlobStorageWriteSettings) MarshalJSON() ([]byte, error) { return json.Marshal(objectMap) } +// AsAzureFileStorageWriteSettings is the BasicStoreWriteSettings implementation for AzureBlobStorageWriteSettings. +func (absws AzureBlobStorageWriteSettings) AsAzureFileStorageWriteSettings() (*AzureFileStorageWriteSettings, bool) { + return nil, false +} + // AsFileServerWriteSettings is the BasicStoreWriteSettings implementation for AzureBlobStorageWriteSettings. func (absws AzureBlobStorageWriteSettings) AsFileServerWriteSettings() (*FileServerWriteSettings, bool) { return nil, false @@ -21786,7 +21796,7 @@ type AzureDataLakeStoreWriteSettings struct { MaxConcurrentConnections interface{} `json:"maxConcurrentConnections,omitempty"` // CopyBehavior - The type of copy behavior for copy sink. CopyBehavior interface{} `json:"copyBehavior,omitempty"` - // Type - Possible values include: 'TypeStoreWriteSettings', 'TypeFileServerWriteSettings', 'TypeAzureDataLakeStoreWriteSettings', 'TypeAzureBlobFSWriteSettings', 'TypeAzureBlobStorageWriteSettings', 'TypeSftpWriteSettings' + // Type - Possible values include: 'TypeStoreWriteSettings', 'TypeAzureFileStorageWriteSettings', 'TypeFileServerWriteSettings', 'TypeAzureDataLakeStoreWriteSettings', 'TypeAzureBlobFSWriteSettings', 'TypeAzureBlobStorageWriteSettings', 'TypeSftpWriteSettings' Type TypeBasicStoreWriteSettings `json:"type,omitempty"` } @@ -21812,6 +21822,11 @@ func (adlsws AzureDataLakeStoreWriteSettings) MarshalJSON() ([]byte, error) { return json.Marshal(objectMap) } +// AsAzureFileStorageWriteSettings is the BasicStoreWriteSettings implementation for AzureDataLakeStoreWriteSettings. +func (adlsws AzureDataLakeStoreWriteSettings) AsAzureFileStorageWriteSettings() (*AzureFileStorageWriteSettings, bool) { + return nil, false +} + // AsFileServerWriteSettings is the BasicStoreWriteSettings implementation for AzureDataLakeStoreWriteSettings. func (adlsws AzureDataLakeStoreWriteSettings) AsFileServerWriteSettings() (*FileServerWriteSettings, bool) { return nil, false @@ -23081,6 +23096,131 @@ func (afsrs *AzureFileStorageReadSettings) UnmarshalJSON(body []byte) error { return nil } +// AzureFileStorageWriteSettings azure File Storage write settings. +type AzureFileStorageWriteSettings struct { + // AdditionalProperties - Unmatched properties from the message are deserialized this collection + AdditionalProperties map[string]interface{} `json:""` + // MaxConcurrentConnections - The maximum concurrent connection count for the source data store. Type: integer (or Expression with resultType integer). + MaxConcurrentConnections interface{} `json:"maxConcurrentConnections,omitempty"` + // CopyBehavior - The type of copy behavior for copy sink. + CopyBehavior interface{} `json:"copyBehavior,omitempty"` + // Type - Possible values include: 'TypeStoreWriteSettings', 'TypeAzureFileStorageWriteSettings', 'TypeFileServerWriteSettings', 'TypeAzureDataLakeStoreWriteSettings', 'TypeAzureBlobFSWriteSettings', 'TypeAzureBlobStorageWriteSettings', 'TypeSftpWriteSettings' + Type TypeBasicStoreWriteSettings `json:"type,omitempty"` +} + +// MarshalJSON is the custom marshaler for AzureFileStorageWriteSettings. +func (afsws AzureFileStorageWriteSettings) MarshalJSON() ([]byte, error) { + afsws.Type = TypeAzureFileStorageWriteSettings + objectMap := make(map[string]interface{}) + if afsws.MaxConcurrentConnections != nil { + objectMap["maxConcurrentConnections"] = afsws.MaxConcurrentConnections + } + if afsws.CopyBehavior != nil { + objectMap["copyBehavior"] = afsws.CopyBehavior + } + if afsws.Type != "" { + objectMap["type"] = afsws.Type + } + for k, v := range afsws.AdditionalProperties { + objectMap[k] = v + } + return json.Marshal(objectMap) +} + +// AsAzureFileStorageWriteSettings is the BasicStoreWriteSettings implementation for AzureFileStorageWriteSettings. +func (afsws AzureFileStorageWriteSettings) AsAzureFileStorageWriteSettings() (*AzureFileStorageWriteSettings, bool) { + return &afsws, true +} + +// AsFileServerWriteSettings is the BasicStoreWriteSettings implementation for AzureFileStorageWriteSettings. +func (afsws AzureFileStorageWriteSettings) AsFileServerWriteSettings() (*FileServerWriteSettings, bool) { + return nil, false +} + +// AsAzureDataLakeStoreWriteSettings is the BasicStoreWriteSettings implementation for AzureFileStorageWriteSettings. +func (afsws AzureFileStorageWriteSettings) AsAzureDataLakeStoreWriteSettings() (*AzureDataLakeStoreWriteSettings, bool) { + return nil, false +} + +// AsAzureBlobFSWriteSettings is the BasicStoreWriteSettings implementation for AzureFileStorageWriteSettings. +func (afsws AzureFileStorageWriteSettings) AsAzureBlobFSWriteSettings() (*AzureBlobFSWriteSettings, bool) { + return nil, false +} + +// AsAzureBlobStorageWriteSettings is the BasicStoreWriteSettings implementation for AzureFileStorageWriteSettings. +func (afsws AzureFileStorageWriteSettings) AsAzureBlobStorageWriteSettings() (*AzureBlobStorageWriteSettings, bool) { + return nil, false +} + +// AsSftpWriteSettings is the BasicStoreWriteSettings implementation for AzureFileStorageWriteSettings. +func (afsws AzureFileStorageWriteSettings) AsSftpWriteSettings() (*SftpWriteSettings, bool) { + return nil, false +} + +// AsStoreWriteSettings is the BasicStoreWriteSettings implementation for AzureFileStorageWriteSettings. +func (afsws AzureFileStorageWriteSettings) AsStoreWriteSettings() (*StoreWriteSettings, bool) { + return nil, false +} + +// AsBasicStoreWriteSettings is the BasicStoreWriteSettings implementation for AzureFileStorageWriteSettings. +func (afsws AzureFileStorageWriteSettings) AsBasicStoreWriteSettings() (BasicStoreWriteSettings, bool) { + return &afsws, true +} + +// UnmarshalJSON is the custom unmarshaler for AzureFileStorageWriteSettings struct. +func (afsws *AzureFileStorageWriteSettings) UnmarshalJSON(body []byte) error { + var m map[string]*json.RawMessage + err := json.Unmarshal(body, &m) + if err != nil { + return err + } + for k, v := range m { + switch k { + default: + if v != nil { + var additionalProperties interface{} + err = json.Unmarshal(*v, &additionalProperties) + if err != nil { + return err + } + if afsws.AdditionalProperties == nil { + afsws.AdditionalProperties = make(map[string]interface{}) + } + afsws.AdditionalProperties[k] = additionalProperties + } + case "maxConcurrentConnections": + if v != nil { + var maxConcurrentConnections interface{} + err = json.Unmarshal(*v, &maxConcurrentConnections) + if err != nil { + return err + } + afsws.MaxConcurrentConnections = maxConcurrentConnections + } + case "copyBehavior": + if v != nil { + var copyBehavior interface{} + err = json.Unmarshal(*v, ©Behavior) + if err != nil { + return err + } + afsws.CopyBehavior = copyBehavior + } + case "type": + if v != nil { + var typeVar TypeBasicStoreWriteSettings + err = json.Unmarshal(*v, &typeVar) + if err != nil { + return err + } + afsws.Type = typeVar + } + } + } + + return nil +} + // AzureFunctionActivity azure Function activity. type AzureFunctionActivity struct { // AzureFunctionActivityTypeProperties - Azure Function activity properties. @@ -59991,6 +60131,8 @@ type CosmosDbSQLAPISource struct { PageSize interface{} `json:"pageSize,omitempty"` // PreferredRegions - Preferred regions. Type: array of strings (or Expression with resultType array of strings). PreferredRegions interface{} `json:"preferredRegions,omitempty"` + // DetectDatetime - Whether detect primitive values as datetime values. Type: boolean (or Expression with resultType boolean). + DetectDatetime interface{} `json:"detectDatetime,omitempty"` // AdditionalColumns - Specifies the additional columns to be added to source data. Type: array of objects (or Expression with resultType array of objects). AdditionalColumns *[]AdditionalColumns `json:"additionalColumns,omitempty"` // AdditionalProperties - Unmatched properties from the message are deserialized this collection @@ -60018,6 +60160,9 @@ func (cdsas CosmosDbSQLAPISource) MarshalJSON() ([]byte, error) { if cdsas.PreferredRegions != nil { objectMap["preferredRegions"] = cdsas.PreferredRegions } + if cdsas.DetectDatetime != nil { + objectMap["detectDatetime"] = cdsas.DetectDatetime + } if cdsas.AdditionalColumns != nil { objectMap["additionalColumns"] = cdsas.AdditionalColumns } @@ -60545,6 +60690,15 @@ func (cdsas *CosmosDbSQLAPISource) UnmarshalJSON(body []byte) error { } cdsas.PreferredRegions = preferredRegions } + case "detectDatetime": + if v != nil { + var detectDatetime interface{} + err = json.Unmarshal(*v, &detectDatetime) + if err != nil { + return err + } + cdsas.DetectDatetime = detectDatetime + } case "additionalColumns": if v != nil { var additionalColumns []AdditionalColumns @@ -66188,6 +66342,8 @@ type DataFlowSink struct { LinkedService *LinkedServiceReference `json:"linkedService,omitempty"` // SchemaLinkedService - Schema linked service reference. SchemaLinkedService *LinkedServiceReference `json:"schemaLinkedService,omitempty"` + // Staging - Staging info for execute data flow activity. + Staging *DataFlowStagingInfo `json:"staging,omitempty"` // Name - Transformation name. Name *string `json:"name,omitempty"` // Description - Transformation description. @@ -66202,6 +66358,8 @@ type DataFlowSource struct { LinkedService *LinkedServiceReference `json:"linkedService,omitempty"` // SchemaLinkedService - Schema linked service reference. SchemaLinkedService *LinkedServiceReference `json:"schemaLinkedService,omitempty"` + // Staging - Staging info for execute data flow activity. + Staging *DataFlowStagingInfo `json:"staging,omitempty"` // Name - Transformation name. Name *string `json:"name,omitempty"` // Description - Transformation description. @@ -88886,6 +89044,19 @@ func (es *ExportSettings) UnmarshalJSON(body []byte) error { return nil } +// ExposureControlBatchRequest a list of exposure control features. +type ExposureControlBatchRequest struct { + // ExposureControlRequests - List of exposure control features. + ExposureControlRequests *[]ExposureControlRequest `json:"exposureControlRequests,omitempty"` +} + +// ExposureControlBatchResponse a list of exposure control feature values. +type ExposureControlBatchResponse struct { + autorest.Response `json:"-"` + // ExposureControlResponses - List of exposure control feature values. + ExposureControlResponses *[]ExposureControlResponse `json:"exposureControlResponses,omitempty"` +} + // ExposureControlRequest the exposure control request. type ExposureControlRequest struct { // FeatureName - The feature name. @@ -90731,7 +90902,7 @@ type FileServerWriteSettings struct { MaxConcurrentConnections interface{} `json:"maxConcurrentConnections,omitempty"` // CopyBehavior - The type of copy behavior for copy sink. CopyBehavior interface{} `json:"copyBehavior,omitempty"` - // Type - Possible values include: 'TypeStoreWriteSettings', 'TypeFileServerWriteSettings', 'TypeAzureDataLakeStoreWriteSettings', 'TypeAzureBlobFSWriteSettings', 'TypeAzureBlobStorageWriteSettings', 'TypeSftpWriteSettings' + // Type - Possible values include: 'TypeStoreWriteSettings', 'TypeAzureFileStorageWriteSettings', 'TypeFileServerWriteSettings', 'TypeAzureDataLakeStoreWriteSettings', 'TypeAzureBlobFSWriteSettings', 'TypeAzureBlobStorageWriteSettings', 'TypeSftpWriteSettings' Type TypeBasicStoreWriteSettings `json:"type,omitempty"` } @@ -90754,6 +90925,11 @@ func (fsws FileServerWriteSettings) MarshalJSON() ([]byte, error) { return json.Marshal(objectMap) } +// AsAzureFileStorageWriteSettings is the BasicStoreWriteSettings implementation for FileServerWriteSettings. +func (fsws FileServerWriteSettings) AsAzureFileStorageWriteSettings() (*AzureFileStorageWriteSettings, bool) { + return nil, false +} + // AsFileServerWriteSettings is the BasicStoreWriteSettings implementation for FileServerWriteSettings. func (fsws FileServerWriteSettings) AsFileServerWriteSettings() (*FileServerWriteSettings, bool) { return &fsws, true @@ -199516,7 +199692,7 @@ type SftpWriteSettings struct { MaxConcurrentConnections interface{} `json:"maxConcurrentConnections,omitempty"` // CopyBehavior - The type of copy behavior for copy sink. CopyBehavior interface{} `json:"copyBehavior,omitempty"` - // Type - Possible values include: 'TypeStoreWriteSettings', 'TypeFileServerWriteSettings', 'TypeAzureDataLakeStoreWriteSettings', 'TypeAzureBlobFSWriteSettings', 'TypeAzureBlobStorageWriteSettings', 'TypeSftpWriteSettings' + // Type - Possible values include: 'TypeStoreWriteSettings', 'TypeAzureFileStorageWriteSettings', 'TypeFileServerWriteSettings', 'TypeAzureDataLakeStoreWriteSettings', 'TypeAzureBlobFSWriteSettings', 'TypeAzureBlobStorageWriteSettings', 'TypeSftpWriteSettings' Type TypeBasicStoreWriteSettings `json:"type,omitempty"` } @@ -199545,6 +199721,11 @@ func (sws SftpWriteSettings) MarshalJSON() ([]byte, error) { return json.Marshal(objectMap) } +// AsAzureFileStorageWriteSettings is the BasicStoreWriteSettings implementation for SftpWriteSettings. +func (sws SftpWriteSettings) AsAzureFileStorageWriteSettings() (*AzureFileStorageWriteSettings, bool) { + return nil, false +} + // AsFileServerWriteSettings is the BasicStoreWriteSettings implementation for SftpWriteSettings. func (sws SftpWriteSettings) AsFileServerWriteSettings() (*FileServerWriteSettings, bool) { return nil, false @@ -217172,6 +217353,7 @@ func (srs *StoreReadSettings) UnmarshalJSON(body []byte) error { // BasicStoreWriteSettings connector write settings. type BasicStoreWriteSettings interface { + AsAzureFileStorageWriteSettings() (*AzureFileStorageWriteSettings, bool) AsFileServerWriteSettings() (*FileServerWriteSettings, bool) AsAzureDataLakeStoreWriteSettings() (*AzureDataLakeStoreWriteSettings, bool) AsAzureBlobFSWriteSettings() (*AzureBlobFSWriteSettings, bool) @@ -217188,7 +217370,7 @@ type StoreWriteSettings struct { MaxConcurrentConnections interface{} `json:"maxConcurrentConnections,omitempty"` // CopyBehavior - The type of copy behavior for copy sink. CopyBehavior interface{} `json:"copyBehavior,omitempty"` - // Type - Possible values include: 'TypeStoreWriteSettings', 'TypeFileServerWriteSettings', 'TypeAzureDataLakeStoreWriteSettings', 'TypeAzureBlobFSWriteSettings', 'TypeAzureBlobStorageWriteSettings', 'TypeSftpWriteSettings' + // Type - Possible values include: 'TypeStoreWriteSettings', 'TypeAzureFileStorageWriteSettings', 'TypeFileServerWriteSettings', 'TypeAzureDataLakeStoreWriteSettings', 'TypeAzureBlobFSWriteSettings', 'TypeAzureBlobStorageWriteSettings', 'TypeSftpWriteSettings' Type TypeBasicStoreWriteSettings `json:"type,omitempty"` } @@ -217200,6 +217382,10 @@ func unmarshalBasicStoreWriteSettings(body []byte) (BasicStoreWriteSettings, err } switch m["type"] { + case string(TypeAzureFileStorageWriteSettings): + var afsws AzureFileStorageWriteSettings + err := json.Unmarshal(body, &afsws) + return afsws, err case string(TypeFileServerWriteSettings): var fsws FileServerWriteSettings err := json.Unmarshal(body, &fsws) @@ -217264,6 +217450,11 @@ func (sws StoreWriteSettings) MarshalJSON() ([]byte, error) { return json.Marshal(objectMap) } +// AsAzureFileStorageWriteSettings is the BasicStoreWriteSettings implementation for StoreWriteSettings. +func (sws StoreWriteSettings) AsAzureFileStorageWriteSettings() (*AzureFileStorageWriteSettings, bool) { + return nil, false +} + // AsFileServerWriteSettings is the BasicStoreWriteSettings implementation for StoreWriteSettings. func (sws StoreWriteSettings) AsFileServerWriteSettings() (*FileServerWriteSettings, bool) { return nil, false @@ -232764,6 +232955,10 @@ type XMLReadSettings struct { CompressionProperties BasicCompressionReadSettings `json:"compressionProperties,omitempty"` // ValidationMode - Indicates what validation method is used when reading the xml files. Allowed values: 'none', 'xsd', or 'dtd'. Type: string (or Expression with resultType string). ValidationMode interface{} `json:"validationMode,omitempty"` + // DetectDataType - Indicates whether type detection is enabled when reading the xml files. Type: boolean (or Expression with resultType boolean). + DetectDataType interface{} `json:"detectDataType,omitempty"` + // Namespaces - Indicates whether namespace is enabled when reading the xml files. Type: boolean (or Expression with resultType boolean). + Namespaces interface{} `json:"namespaces,omitempty"` // NamespacePrefixes - Namespace uri to prefix mappings to override the prefixes in column names when namespace is enabled, if no prefix is defined for a namespace uri, the prefix of xml element/attribute name in the xml data file will be used. Example: "{"http://www.example.com/xml":"prefix"}" Type: object (or Expression with resultType object). NamespacePrefixes interface{} `json:"namespacePrefixes,omitempty"` // AdditionalProperties - Unmatched properties from the message are deserialized this collection @@ -232780,6 +232975,12 @@ func (xrs XMLReadSettings) MarshalJSON() ([]byte, error) { if xrs.ValidationMode != nil { objectMap["validationMode"] = xrs.ValidationMode } + if xrs.DetectDataType != nil { + objectMap["detectDataType"] = xrs.DetectDataType + } + if xrs.Namespaces != nil { + objectMap["namespaces"] = xrs.Namespaces + } if xrs.NamespacePrefixes != nil { objectMap["namespacePrefixes"] = xrs.NamespacePrefixes } @@ -232848,6 +233049,24 @@ func (xrs *XMLReadSettings) UnmarshalJSON(body []byte) error { } xrs.ValidationMode = validationMode } + case "detectDataType": + if v != nil { + var detectDataType interface{} + err = json.Unmarshal(*v, &detectDataType) + if err != nil { + return err + } + xrs.DetectDataType = detectDataType + } + case "namespaces": + if v != nil { + var namespaces interface{} + err = json.Unmarshal(*v, &namespaces) + if err != nil { + return err + } + xrs.Namespaces = namespaces + } case "namespacePrefixes": if v != nil { var namespacePrefixes interface{}