From bbd8ab64159c946342abbbc50f838baf163b0be0 Mon Sep 17 00:00:00 2001 From: SDKAuto Date: Fri, 27 May 2022 07:56:06 +0000 Subject: [PATCH] CodeGen from PR 19247 in Azure/azure-rest-api-specs Merge 59fdc57bc4684aed97ea547d42ba7ee9915dc7a6 into 40fdd84627937fdd8b3b06486497c8f2cfced350 --- .../mgmt/2018-06-01/datafactory/CHANGELOG.md | 58 ++- .../mgmt/2018-06-01/datafactory/_meta.json | 2 +- .../datafactory/datafactoryapi/interfaces.go | 11 + .../mgmt/2018-06-01/datafactory/enums.go | 4 +- .../datafactory/globalparameters.go | 450 ++++++++++++++++++ .../mgmt/2018-06-01/datafactory/models.go | 240 +++++++++- .../datafactory/CHANGELOG.md | 112 ++++- .../2017-09-01-preview/datafactory/_meta.json | 2 +- .../2017-09-01-preview/datafactory/enums.go | 246 ++++++++-- .../2017-09-01-preview/datafactory/models.go | 118 ++--- 10 files changed, 1138 insertions(+), 105 deletions(-) create mode 100644 services/datafactory/mgmt/2018-06-01/datafactory/globalparameters.go diff --git a/services/datafactory/mgmt/2018-06-01/datafactory/CHANGELOG.md b/services/datafactory/mgmt/2018-06-01/datafactory/CHANGELOG.md index 2047f98206dc..e9e8d82aaa69 100644 --- a/services/datafactory/mgmt/2018-06-01/datafactory/CHANGELOG.md +++ b/services/datafactory/mgmt/2018-06-01/datafactory/CHANGELOG.md @@ -1,17 +1,61 @@ -# Change History +# Unreleased ## Additive Changes +### New Constants + +1. RestServiceAuthenticationType.RestServiceAuthenticationTypeOAuth2ClientCredential + +### New Funcs + +1. *GlobalParameterListResponseIterator.Next() error +1. *GlobalParameterListResponseIterator.NextWithContext(context.Context) error +1. *GlobalParameterListResponsePage.Next() error +1. *GlobalParameterListResponsePage.NextWithContext(context.Context) error +1. GlobalParameterListResponse.IsEmpty() bool +1. GlobalParameterListResponseIterator.NotDone() bool +1. GlobalParameterListResponseIterator.Response() GlobalParameterListResponse +1. GlobalParameterListResponseIterator.Value() GlobalParameterResource +1. GlobalParameterListResponsePage.NotDone() bool +1. GlobalParameterListResponsePage.Response() GlobalParameterListResponse +1. GlobalParameterListResponsePage.Values() []GlobalParameterResource +1. GlobalParameterResource.MarshalJSON() ([]byte, error) +1. GlobalParametersClient.CreateOrUpdate(context.Context, string, string, string, GlobalParameterResource) (GlobalParameterResource, error) +1. GlobalParametersClient.CreateOrUpdatePreparer(context.Context, string, string, string, GlobalParameterResource) (*http.Request, error) +1. GlobalParametersClient.CreateOrUpdateResponder(*http.Response) (GlobalParameterResource, error) +1. GlobalParametersClient.CreateOrUpdateSender(*http.Request) (*http.Response, error) +1. GlobalParametersClient.Delete(context.Context, string, string, string) (autorest.Response, error) +1. GlobalParametersClient.DeletePreparer(context.Context, string, string, string) (*http.Request, error) +1. GlobalParametersClient.DeleteResponder(*http.Response) (autorest.Response, error) +1. GlobalParametersClient.DeleteSender(*http.Request) (*http.Response, error) +1. GlobalParametersClient.Get(context.Context, string, string, string) (GlobalParameterResource, error) +1. GlobalParametersClient.GetPreparer(context.Context, string, string, string) (*http.Request, error) +1. GlobalParametersClient.GetResponder(*http.Response) (GlobalParameterResource, error) +1. GlobalParametersClient.GetSender(*http.Request) (*http.Response, error) +1. GlobalParametersClient.ListByFactory(context.Context, string, string) (GlobalParameterListResponsePage, error) +1. GlobalParametersClient.ListByFactoryComplete(context.Context, string, string) (GlobalParameterListResponseIterator, error) +1. GlobalParametersClient.ListByFactoryPreparer(context.Context, string, string) (*http.Request, error) +1. GlobalParametersClient.ListByFactoryResponder(*http.Response) (GlobalParameterListResponse, error) +1. GlobalParametersClient.ListByFactorySender(*http.Request) (*http.Response, error) +1. NewGlobalParameterListResponseIterator(GlobalParameterListResponsePage) GlobalParameterListResponseIterator +1. NewGlobalParameterListResponsePage(GlobalParameterListResponse, func(context.Context, GlobalParameterListResponse) (GlobalParameterListResponse, error)) GlobalParameterListResponsePage +1. NewGlobalParametersClient(string) GlobalParametersClient +1. NewGlobalParametersClientWithBaseURI(string, string) GlobalParametersClient + ### Struct Changes #### New Structs -1. PurviewConfiguration +1. GlobalParameterListResponse +1. GlobalParameterListResponseIterator +1. GlobalParameterListResponsePage +1. GlobalParameterResource +1. GlobalParametersClient #### New Struct Fields -1. DataFlowSink.RejectedDataLinkedService -1. ExecuteDataFlowActivityTypeProperties.SourceStagingConcurrency -1. ExecutePowerQueryActivityTypeProperties.SourceStagingConcurrency -1. FactoryProperties.PurviewConfiguration -1. PowerQuerySink.RejectedDataLinkedService +1. RestServiceLinkedServiceTypeProperties.ClientID +1. RestServiceLinkedServiceTypeProperties.ClientSecret +1. RestServiceLinkedServiceTypeProperties.Resource +1. RestServiceLinkedServiceTypeProperties.Scope +1. RestServiceLinkedServiceTypeProperties.TokenEndpoint diff --git a/services/datafactory/mgmt/2018-06-01/datafactory/_meta.json b/services/datafactory/mgmt/2018-06-01/datafactory/_meta.json index 4ea371390f8c..8b3e86ce903d 100644 --- a/services/datafactory/mgmt/2018-06-01/datafactory/_meta.json +++ b/services/datafactory/mgmt/2018-06-01/datafactory/_meta.json @@ -1,5 +1,5 @@ { - "commit": "cd8f049ce47372fd5955c2dfd11daf4a02050fe3", + "commit": "0103b10be26486c6cbae83ae44641069f92da0fe", "readme": "/_/azure-rest-api-specs/specification/datafactory/resource-manager/readme.md", "tag": "package-2018-06", "use": "@microsoft.azure/autorest.go@2.1.187", 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 97b9110d17c5..9d46dfd81b80 100644 --- a/services/datafactory/mgmt/2018-06-01/datafactory/datafactoryapi/interfaces.go +++ b/services/datafactory/mgmt/2018-06-01/datafactory/datafactoryapi/interfaces.go @@ -231,3 +231,14 @@ type PrivateLinkResourcesClientAPI interface { } var _ PrivateLinkResourcesClientAPI = (*datafactory.PrivateLinkResourcesClient)(nil) + +// GlobalParametersClientAPI contains the set of methods on the GlobalParametersClient type. +type GlobalParametersClientAPI interface { + CreateOrUpdate(ctx context.Context, resourceGroupName string, factoryName string, globalParameterName string, defaultParameter datafactory.GlobalParameterResource) (result datafactory.GlobalParameterResource, err error) + Delete(ctx context.Context, resourceGroupName string, factoryName string, globalParameterName string) (result autorest.Response, err error) + Get(ctx context.Context, resourceGroupName string, factoryName string, globalParameterName string) (result datafactory.GlobalParameterResource, err error) + ListByFactory(ctx context.Context, resourceGroupName string, factoryName string) (result datafactory.GlobalParameterListResponsePage, err error) + ListByFactoryComplete(ctx context.Context, resourceGroupName string, factoryName string) (result datafactory.GlobalParameterListResponseIterator, err error) +} + +var _ GlobalParametersClientAPI = (*datafactory.GlobalParametersClient)(nil) diff --git a/services/datafactory/mgmt/2018-06-01/datafactory/enums.go b/services/datafactory/mgmt/2018-06-01/datafactory/enums.go index 51d22e67b4a5..e9a4cdbc1e23 100644 --- a/services/datafactory/mgmt/2018-06-01/datafactory/enums.go +++ b/services/datafactory/mgmt/2018-06-01/datafactory/enums.go @@ -1121,11 +1121,13 @@ const ( RestServiceAuthenticationTypeBasic RestServiceAuthenticationType = "Basic" // RestServiceAuthenticationTypeManagedServiceIdentity ... RestServiceAuthenticationTypeManagedServiceIdentity RestServiceAuthenticationType = "ManagedServiceIdentity" + // RestServiceAuthenticationTypeOAuth2ClientCredential ... + RestServiceAuthenticationTypeOAuth2ClientCredential RestServiceAuthenticationType = "OAuth2ClientCredential" ) // PossibleRestServiceAuthenticationTypeValues returns an array of possible values for the RestServiceAuthenticationType const type. func PossibleRestServiceAuthenticationTypeValues() []RestServiceAuthenticationType { - return []RestServiceAuthenticationType{RestServiceAuthenticationTypeAadServicePrincipal, RestServiceAuthenticationTypeAnonymous, RestServiceAuthenticationTypeBasic, RestServiceAuthenticationTypeManagedServiceIdentity} + return []RestServiceAuthenticationType{RestServiceAuthenticationTypeAadServicePrincipal, RestServiceAuthenticationTypeAnonymous, RestServiceAuthenticationTypeBasic, RestServiceAuthenticationTypeManagedServiceIdentity, RestServiceAuthenticationTypeOAuth2ClientCredential} } // RunQueryFilterOperand enumerates the values for run query filter operand. diff --git a/services/datafactory/mgmt/2018-06-01/datafactory/globalparameters.go b/services/datafactory/mgmt/2018-06-01/datafactory/globalparameters.go new file mode 100644 index 000000000000..a4773cacd0dc --- /dev/null +++ b/services/datafactory/mgmt/2018-06-01/datafactory/globalparameters.go @@ -0,0 +1,450 @@ +package datafactory + +// Copyright (c) Microsoft Corporation. All rights reserved. +// Licensed under the MIT License. See License.txt in the project root for license information. +// +// Code generated by Microsoft (R) AutoRest Code Generator. +// Changes may cause incorrect behavior and will be lost if the code is regenerated. + +import ( + "context" + "github.com/Azure/go-autorest/autorest" + "github.com/Azure/go-autorest/autorest/azure" + "github.com/Azure/go-autorest/autorest/validation" + "github.com/Azure/go-autorest/tracing" + "net/http" +) + +// GlobalParametersClient is the the Azure Data Factory V2 management API provides a RESTful set of web services that +// interact with Azure Data Factory V2 services. +type GlobalParametersClient struct { + BaseClient +} + +// NewGlobalParametersClient creates an instance of the GlobalParametersClient client. +func NewGlobalParametersClient(subscriptionID string) GlobalParametersClient { + return NewGlobalParametersClientWithBaseURI(DefaultBaseURI, subscriptionID) +} + +// NewGlobalParametersClientWithBaseURI creates an instance of the GlobalParametersClient client using a custom +// endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure +// stack). +func NewGlobalParametersClientWithBaseURI(baseURI string, subscriptionID string) GlobalParametersClient { + return GlobalParametersClient{NewWithBaseURI(baseURI, subscriptionID)} +} + +// CreateOrUpdate creates or updates a Global parameter +// Parameters: +// resourceGroupName - the resource group name. +// factoryName - the factory name. +// globalParameterName - the global parameter name. +// defaultParameter - global parameter resource definition. +func (client GlobalParametersClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, factoryName string, globalParameterName string, defaultParameter GlobalParameterResource) (result GlobalParameterResource, err error) { + if tracing.IsEnabled() { + ctx = tracing.StartSpan(ctx, fqdn+"/GlobalParametersClient.CreateOrUpdate") + 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: globalParameterName, + Constraints: []validation.Constraint{{Target: "globalParameterName", Name: validation.MaxLength, Rule: 260, Chain: nil}, + {Target: "globalParameterName", Name: validation.MinLength, Rule: 1, Chain: nil}, + {Target: "globalParameterName", Name: validation.Pattern, Rule: `^[A-Za-z0-9_][^<>*#.%&:\\+?/]*$`, Chain: nil}}}, + {TargetValue: defaultParameter, + Constraints: []validation.Constraint{{Target: "defaultParameter.Properties", Name: validation.Null, Rule: true, Chain: nil}}}}); err != nil { + return result, validation.NewError("datafactory.GlobalParametersClient", "CreateOrUpdate", err.Error()) + } + + req, err := client.CreateOrUpdatePreparer(ctx, resourceGroupName, factoryName, globalParameterName, defaultParameter) + if err != nil { + err = autorest.NewErrorWithError(err, "datafactory.GlobalParametersClient", "CreateOrUpdate", nil, "Failure preparing request") + return + } + + resp, err := client.CreateOrUpdateSender(req) + if err != nil { + result.Response = autorest.Response{Response: resp} + err = autorest.NewErrorWithError(err, "datafactory.GlobalParametersClient", "CreateOrUpdate", resp, "Failure sending request") + return + } + + result, err = client.CreateOrUpdateResponder(resp) + if err != nil { + err = autorest.NewErrorWithError(err, "datafactory.GlobalParametersClient", "CreateOrUpdate", resp, "Failure responding to request") + return + } + + return +} + +// CreateOrUpdatePreparer prepares the CreateOrUpdate request. +func (client GlobalParametersClient) CreateOrUpdatePreparer(ctx context.Context, resourceGroupName string, factoryName string, globalParameterName string, defaultParameter GlobalParameterResource) (*http.Request, error) { + pathParameters := map[string]interface{}{ + "factoryName": autorest.Encode("path", factoryName), + "globalParameterName": autorest.Encode("path", globalParameterName), + "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.AsPut(), + autorest.WithBaseURL(client.BaseURI), + autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataFactory/factories/{factoryName}/globalParameters/{globalParameterName}", pathParameters), + autorest.WithJSON(defaultParameter), + autorest.WithQueryParameters(queryParameters)) + return preparer.Prepare((&http.Request{}).WithContext(ctx)) +} + +// CreateOrUpdateSender sends the CreateOrUpdate request. The method will close the +// http.Response Body if it receives an error. +func (client GlobalParametersClient) CreateOrUpdateSender(req *http.Request) (*http.Response, error) { + return client.Send(req, azure.DoRetryWithRegistration(client.Client)) +} + +// CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always +// closes the http.Response Body. +func (client GlobalParametersClient) CreateOrUpdateResponder(resp *http.Response) (result GlobalParameterResource, err error) { + err = autorest.Respond( + resp, + azure.WithErrorUnlessStatusCode(http.StatusOK), + autorest.ByUnmarshallingJSON(&result), + autorest.ByClosing()) + result.Response = autorest.Response{Response: resp} + return +} + +// Delete deletes a Global parameter +// Parameters: +// resourceGroupName - the resource group name. +// factoryName - the factory name. +// globalParameterName - the global parameter name. +func (client GlobalParametersClient) Delete(ctx context.Context, resourceGroupName string, factoryName string, globalParameterName string) (result autorest.Response, err error) { + if tracing.IsEnabled() { + ctx = tracing.StartSpan(ctx, fqdn+"/GlobalParametersClient.Delete") + defer func() { + sc := -1 + if result.Response != nil { + sc = result.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: globalParameterName, + Constraints: []validation.Constraint{{Target: "globalParameterName", Name: validation.MaxLength, Rule: 260, Chain: nil}, + {Target: "globalParameterName", Name: validation.MinLength, Rule: 1, Chain: nil}, + {Target: "globalParameterName", Name: validation.Pattern, Rule: `^[A-Za-z0-9_][^<>*#.%&:\\+?/]*$`, Chain: nil}}}}); err != nil { + return result, validation.NewError("datafactory.GlobalParametersClient", "Delete", err.Error()) + } + + req, err := client.DeletePreparer(ctx, resourceGroupName, factoryName, globalParameterName) + if err != nil { + err = autorest.NewErrorWithError(err, "datafactory.GlobalParametersClient", "Delete", nil, "Failure preparing request") + return + } + + resp, err := client.DeleteSender(req) + if err != nil { + result.Response = resp + err = autorest.NewErrorWithError(err, "datafactory.GlobalParametersClient", "Delete", resp, "Failure sending request") + return + } + + result, err = client.DeleteResponder(resp) + if err != nil { + err = autorest.NewErrorWithError(err, "datafactory.GlobalParametersClient", "Delete", resp, "Failure responding to request") + return + } + + return +} + +// DeletePreparer prepares the Delete request. +func (client GlobalParametersClient) DeletePreparer(ctx context.Context, resourceGroupName string, factoryName string, globalParameterName string) (*http.Request, error) { + pathParameters := map[string]interface{}{ + "factoryName": autorest.Encode("path", factoryName), + "globalParameterName": autorest.Encode("path", globalParameterName), + "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.AsDelete(), + autorest.WithBaseURL(client.BaseURI), + autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataFactory/factories/{factoryName}/globalParameters/{globalParameterName}", pathParameters), + autorest.WithQueryParameters(queryParameters)) + return preparer.Prepare((&http.Request{}).WithContext(ctx)) +} + +// DeleteSender sends the Delete request. The method will close the +// http.Response Body if it receives an error. +func (client GlobalParametersClient) DeleteSender(req *http.Request) (*http.Response, error) { + return client.Send(req, azure.DoRetryWithRegistration(client.Client)) +} + +// DeleteResponder handles the response to the Delete request. The method always +// closes the http.Response Body. +func (client GlobalParametersClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error) { + err = autorest.Respond( + resp, + azure.WithErrorUnlessStatusCode(http.StatusOK, http.StatusNoContent), + autorest.ByClosing()) + result.Response = resp + return +} + +// Get gets a Global parameter +// Parameters: +// resourceGroupName - the resource group name. +// factoryName - the factory name. +// globalParameterName - the global parameter name. +func (client GlobalParametersClient) Get(ctx context.Context, resourceGroupName string, factoryName string, globalParameterName string) (result GlobalParameterResource, err error) { + if tracing.IsEnabled() { + ctx = tracing.StartSpan(ctx, fqdn+"/GlobalParametersClient.Get") + 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: globalParameterName, + Constraints: []validation.Constraint{{Target: "globalParameterName", Name: validation.MaxLength, Rule: 260, Chain: nil}, + {Target: "globalParameterName", Name: validation.MinLength, Rule: 1, Chain: nil}, + {Target: "globalParameterName", Name: validation.Pattern, Rule: `^[A-Za-z0-9_][^<>*#.%&:\\+?/]*$`, Chain: nil}}}}); err != nil { + return result, validation.NewError("datafactory.GlobalParametersClient", "Get", err.Error()) + } + + req, err := client.GetPreparer(ctx, resourceGroupName, factoryName, globalParameterName) + if err != nil { + err = autorest.NewErrorWithError(err, "datafactory.GlobalParametersClient", "Get", nil, "Failure preparing request") + return + } + + resp, err := client.GetSender(req) + if err != nil { + result.Response = autorest.Response{Response: resp} + err = autorest.NewErrorWithError(err, "datafactory.GlobalParametersClient", "Get", resp, "Failure sending request") + return + } + + result, err = client.GetResponder(resp) + if err != nil { + err = autorest.NewErrorWithError(err, "datafactory.GlobalParametersClient", "Get", resp, "Failure responding to request") + return + } + + return +} + +// GetPreparer prepares the Get request. +func (client GlobalParametersClient) GetPreparer(ctx context.Context, resourceGroupName string, factoryName string, globalParameterName string) (*http.Request, error) { + pathParameters := map[string]interface{}{ + "factoryName": autorest.Encode("path", factoryName), + "globalParameterName": autorest.Encode("path", globalParameterName), + "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.AsGet(), + autorest.WithBaseURL(client.BaseURI), + autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataFactory/factories/{factoryName}/globalParameters/{globalParameterName}", pathParameters), + autorest.WithQueryParameters(queryParameters)) + return preparer.Prepare((&http.Request{}).WithContext(ctx)) +} + +// GetSender sends the Get request. The method will close the +// http.Response Body if it receives an error. +func (client GlobalParametersClient) GetSender(req *http.Request) (*http.Response, error) { + return client.Send(req, azure.DoRetryWithRegistration(client.Client)) +} + +// GetResponder handles the response to the Get request. The method always +// closes the http.Response Body. +func (client GlobalParametersClient) GetResponder(resp *http.Response) (result GlobalParameterResource, err error) { + err = autorest.Respond( + resp, + azure.WithErrorUnlessStatusCode(http.StatusOK), + autorest.ByUnmarshallingJSON(&result), + autorest.ByClosing()) + result.Response = autorest.Response{Response: resp} + return +} + +// ListByFactory lists Global parameters +// Parameters: +// resourceGroupName - the resource group name. +// factoryName - the factory name. +func (client GlobalParametersClient) ListByFactory(ctx context.Context, resourceGroupName string, factoryName string) (result GlobalParameterListResponsePage, err error) { + if tracing.IsEnabled() { + ctx = tracing.StartSpan(ctx, fqdn+"/GlobalParametersClient.ListByFactory") + defer func() { + sc := -1 + if result.gplr.Response.Response != nil { + sc = result.gplr.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}}}}); err != nil { + return result, validation.NewError("datafactory.GlobalParametersClient", "ListByFactory", err.Error()) + } + + result.fn = client.listByFactoryNextResults + req, err := client.ListByFactoryPreparer(ctx, resourceGroupName, factoryName) + if err != nil { + err = autorest.NewErrorWithError(err, "datafactory.GlobalParametersClient", "ListByFactory", nil, "Failure preparing request") + return + } + + resp, err := client.ListByFactorySender(req) + if err != nil { + result.gplr.Response = autorest.Response{Response: resp} + err = autorest.NewErrorWithError(err, "datafactory.GlobalParametersClient", "ListByFactory", resp, "Failure sending request") + return + } + + result.gplr, err = client.ListByFactoryResponder(resp) + if err != nil { + err = autorest.NewErrorWithError(err, "datafactory.GlobalParametersClient", "ListByFactory", resp, "Failure responding to request") + return + } + if result.gplr.hasNextLink() && result.gplr.IsEmpty() { + err = result.NextWithContext(ctx) + return + } + + return +} + +// ListByFactoryPreparer prepares the ListByFactory request. +func (client GlobalParametersClient) ListByFactoryPreparer(ctx context.Context, resourceGroupName string, factoryName string) (*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.AsGet(), + autorest.WithBaseURL(client.BaseURI), + autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataFactory/factories/{factoryName}/globalParameters", pathParameters), + autorest.WithQueryParameters(queryParameters)) + return preparer.Prepare((&http.Request{}).WithContext(ctx)) +} + +// ListByFactorySender sends the ListByFactory request. The method will close the +// http.Response Body if it receives an error. +func (client GlobalParametersClient) ListByFactorySender(req *http.Request) (*http.Response, error) { + return client.Send(req, azure.DoRetryWithRegistration(client.Client)) +} + +// ListByFactoryResponder handles the response to the ListByFactory request. The method always +// closes the http.Response Body. +func (client GlobalParametersClient) ListByFactoryResponder(resp *http.Response) (result GlobalParameterListResponse, err error) { + err = autorest.Respond( + resp, + azure.WithErrorUnlessStatusCode(http.StatusOK), + autorest.ByUnmarshallingJSON(&result), + autorest.ByClosing()) + result.Response = autorest.Response{Response: resp} + return +} + +// listByFactoryNextResults retrieves the next set of results, if any. +func (client GlobalParametersClient) listByFactoryNextResults(ctx context.Context, lastResults GlobalParameterListResponse) (result GlobalParameterListResponse, err error) { + req, err := lastResults.globalParameterListResponsePreparer(ctx) + if err != nil { + return result, autorest.NewErrorWithError(err, "datafactory.GlobalParametersClient", "listByFactoryNextResults", nil, "Failure preparing next results request") + } + if req == nil { + return + } + resp, err := client.ListByFactorySender(req) + if err != nil { + result.Response = autorest.Response{Response: resp} + return result, autorest.NewErrorWithError(err, "datafactory.GlobalParametersClient", "listByFactoryNextResults", resp, "Failure sending next results request") + } + result, err = client.ListByFactoryResponder(resp) + if err != nil { + err = autorest.NewErrorWithError(err, "datafactory.GlobalParametersClient", "listByFactoryNextResults", resp, "Failure responding to next results request") + } + return +} + +// ListByFactoryComplete enumerates all values, automatically crossing page boundaries as required. +func (client GlobalParametersClient) ListByFactoryComplete(ctx context.Context, resourceGroupName string, factoryName string) (result GlobalParameterListResponseIterator, err error) { + if tracing.IsEnabled() { + ctx = tracing.StartSpan(ctx, fqdn+"/GlobalParametersClient.ListByFactory") + defer func() { + sc := -1 + if result.Response().Response.Response != nil { + sc = result.page.Response().Response.Response.StatusCode + } + tracing.EndSpan(ctx, sc, err) + }() + } + result.page, err = client.ListByFactory(ctx, resourceGroupName, factoryName) + return +} diff --git a/services/datafactory/mgmt/2018-06-01/datafactory/models.go b/services/datafactory/mgmt/2018-06-01/datafactory/models.go index 3e84431becb7..a6161e563719 100644 --- a/services/datafactory/mgmt/2018-06-01/datafactory/models.go +++ b/services/datafactory/mgmt/2018-06-01/datafactory/models.go @@ -113511,6 +113511,190 @@ type GitHubClientSecret struct { ByoaSecretName *string `json:"byoaSecretName,omitempty"` } +// GlobalParameterListResponse a list of Global parameters. +type GlobalParameterListResponse struct { + autorest.Response `json:"-"` + // Value - List of global parameters. + Value *[]GlobalParameterResource `json:"value,omitempty"` + // NextLink - The link to the next page of results, if any remaining results exist. + NextLink *string `json:"nextLink,omitempty"` +} + +// GlobalParameterListResponseIterator provides access to a complete listing of GlobalParameterResource +// values. +type GlobalParameterListResponseIterator struct { + i int + page GlobalParameterListResponsePage +} + +// NextWithContext advances to the next value. If there was an error making +// the request the iterator does not advance and the error is returned. +func (iter *GlobalParameterListResponseIterator) NextWithContext(ctx context.Context) (err error) { + if tracing.IsEnabled() { + ctx = tracing.StartSpan(ctx, fqdn+"/GlobalParameterListResponseIterator.NextWithContext") + defer func() { + sc := -1 + if iter.Response().Response.Response != nil { + sc = iter.Response().Response.Response.StatusCode + } + tracing.EndSpan(ctx, sc, err) + }() + } + iter.i++ + if iter.i < len(iter.page.Values()) { + return nil + } + err = iter.page.NextWithContext(ctx) + if err != nil { + iter.i-- + return err + } + iter.i = 0 + return nil +} + +// Next advances to the next value. If there was an error making +// the request the iterator does not advance and the error is returned. +// Deprecated: Use NextWithContext() instead. +func (iter *GlobalParameterListResponseIterator) Next() error { + return iter.NextWithContext(context.Background()) +} + +// NotDone returns true if the enumeration should be started or is not yet complete. +func (iter GlobalParameterListResponseIterator) NotDone() bool { + return iter.page.NotDone() && iter.i < len(iter.page.Values()) +} + +// Response returns the raw server response from the last page request. +func (iter GlobalParameterListResponseIterator) Response() GlobalParameterListResponse { + return iter.page.Response() +} + +// Value returns the current value or a zero-initialized value if the +// iterator has advanced beyond the end of the collection. +func (iter GlobalParameterListResponseIterator) Value() GlobalParameterResource { + if !iter.page.NotDone() { + return GlobalParameterResource{} + } + return iter.page.Values()[iter.i] +} + +// Creates a new instance of the GlobalParameterListResponseIterator type. +func NewGlobalParameterListResponseIterator(page GlobalParameterListResponsePage) GlobalParameterListResponseIterator { + return GlobalParameterListResponseIterator{page: page} +} + +// IsEmpty returns true if the ListResult contains no values. +func (gplr GlobalParameterListResponse) IsEmpty() bool { + return gplr.Value == nil || len(*gplr.Value) == 0 +} + +// hasNextLink returns true if the NextLink is not empty. +func (gplr GlobalParameterListResponse) hasNextLink() bool { + return gplr.NextLink != nil && len(*gplr.NextLink) != 0 +} + +// globalParameterListResponsePreparer prepares a request to retrieve the next set of results. +// It returns nil if no more results exist. +func (gplr GlobalParameterListResponse) globalParameterListResponsePreparer(ctx context.Context) (*http.Request, error) { + if !gplr.hasNextLink() { + return nil, nil + } + return autorest.Prepare((&http.Request{}).WithContext(ctx), + autorest.AsJSON(), + autorest.AsGet(), + autorest.WithBaseURL(to.String(gplr.NextLink))) +} + +// GlobalParameterListResponsePage contains a page of GlobalParameterResource values. +type GlobalParameterListResponsePage struct { + fn func(context.Context, GlobalParameterListResponse) (GlobalParameterListResponse, error) + gplr GlobalParameterListResponse +} + +// NextWithContext advances to the next page of values. If there was an error making +// the request the page does not advance and the error is returned. +func (page *GlobalParameterListResponsePage) NextWithContext(ctx context.Context) (err error) { + if tracing.IsEnabled() { + ctx = tracing.StartSpan(ctx, fqdn+"/GlobalParameterListResponsePage.NextWithContext") + defer func() { + sc := -1 + if page.Response().Response.Response != nil { + sc = page.Response().Response.Response.StatusCode + } + tracing.EndSpan(ctx, sc, err) + }() + } + for { + next, err := page.fn(ctx, page.gplr) + if err != nil { + return err + } + page.gplr = next + if !next.hasNextLink() || !next.IsEmpty() { + break + } + } + return nil +} + +// Next advances to the next page of values. If there was an error making +// the request the page does not advance and the error is returned. +// Deprecated: Use NextWithContext() instead. +func (page *GlobalParameterListResponsePage) Next() error { + return page.NextWithContext(context.Background()) +} + +// NotDone returns true if the page enumeration should be started or is not yet complete. +func (page GlobalParameterListResponsePage) NotDone() bool { + return !page.gplr.IsEmpty() +} + +// Response returns the raw server response from the last page request. +func (page GlobalParameterListResponsePage) Response() GlobalParameterListResponse { + return page.gplr +} + +// Values returns the slice of values for the current page or nil if there are no values. +func (page GlobalParameterListResponsePage) Values() []GlobalParameterResource { + if page.gplr.IsEmpty() { + return nil + } + return *page.gplr.Value +} + +// Creates a new instance of the GlobalParameterListResponsePage type. +func NewGlobalParameterListResponsePage(cur GlobalParameterListResponse, getNextPage func(context.Context, GlobalParameterListResponse) (GlobalParameterListResponse, error)) GlobalParameterListResponsePage { + return GlobalParameterListResponsePage{ + fn: getNextPage, + gplr: cur, + } +} + +// GlobalParameterResource global parameters resource type. +type GlobalParameterResource struct { + autorest.Response `json:"-"` + // Properties - Properties of the global parameter. + Properties map[string]*GlobalParameterSpecification `json:"properties"` + // ID - READ-ONLY; The resource identifier. + ID *string `json:"id,omitempty"` + // Name - READ-ONLY; The resource name. + Name *string `json:"name,omitempty"` + // Type - READ-ONLY; The resource type. + Type *string `json:"type,omitempty"` + // Etag - READ-ONLY; Etag identifies change in the resource. + Etag *string `json:"etag,omitempty"` +} + +// MarshalJSON is the custom marshaler for GlobalParameterResource. +func (gpr GlobalParameterResource) MarshalJSON() ([]byte, error) { + objectMap := make(map[string]interface{}) + if gpr.Properties != nil { + objectMap["properties"] = gpr.Properties + } + return json.Marshal(objectMap) +} + // GlobalParameterSpecification definition of a single parameter for an entity. type GlobalParameterSpecification struct { // Type - Global Parameter type. Possible values include: 'GlobalParameterTypeObject', 'GlobalParameterTypeString', 'GlobalParameterTypeInt', 'GlobalParameterTypeFloat', 'GlobalParameterTypeBool', 'GlobalParameterTypeArray' @@ -204511,7 +204695,7 @@ type RestServiceLinkedServiceTypeProperties struct { URL interface{} `json:"url,omitempty"` // EnableServerCertificateValidation - Whether to validate server side SSL certificate when connecting to the endpoint.The default value is true. Type: boolean (or Expression with resultType boolean). EnableServerCertificateValidation interface{} `json:"enableServerCertificateValidation,omitempty"` - // AuthenticationType - Type of authentication used to connect to the REST service. Possible values include: 'RestServiceAuthenticationTypeAnonymous', 'RestServiceAuthenticationTypeBasic', 'RestServiceAuthenticationTypeAadServicePrincipal', 'RestServiceAuthenticationTypeManagedServiceIdentity' + // AuthenticationType - Type of authentication used to connect to the REST service. Possible values include: 'RestServiceAuthenticationTypeAnonymous', 'RestServiceAuthenticationTypeBasic', 'RestServiceAuthenticationTypeAadServicePrincipal', 'RestServiceAuthenticationTypeManagedServiceIdentity', 'RestServiceAuthenticationTypeOAuth2ClientCredential' AuthenticationType RestServiceAuthenticationType `json:"authenticationType,omitempty"` // UserName - The user name used in Basic authentication type. UserName interface{} `json:"userName,omitempty"` @@ -204533,6 +204717,16 @@ type RestServiceLinkedServiceTypeProperties struct { EncryptedCredential interface{} `json:"encryptedCredential,omitempty"` // Credential - The credential reference containing authentication information. Credential *CredentialReference `json:"credential,omitempty"` + // ClientID - The client ID associated with your application. Type: string (or Expression with resultType string). + ClientID interface{} `json:"clientId,omitempty"` + // ClientSecret - The client secret associated with your application. + ClientSecret BasicSecretBase `json:"clientSecret,omitempty"` + // TokenEndpoint - The token endpoint of the authorization server to acquire access token. Type: string (or Expression with resultType string). + TokenEndpoint interface{} `json:"tokenEndpoint,omitempty"` + // Resource - The target service or resource to which the access will be requested. Type: string (or Expression with resultType string). + Resource interface{} `json:"resource,omitempty"` + // Scope - The scope of the access required. It describes what kind of access will be requested. Type: string (or Expression with resultType string). + Scope interface{} `json:"scope,omitempty"` } // UnmarshalJSON is the custom unmarshaler for RestServiceLinkedServiceTypeProperties struct. @@ -204659,6 +204853,50 @@ func (rslstp *RestServiceLinkedServiceTypeProperties) UnmarshalJSON(body []byte) } rslstp.Credential = &credential } + case "clientId": + if v != nil { + var clientID interface{} + err = json.Unmarshal(*v, &clientID) + if err != nil { + return err + } + rslstp.ClientID = clientID + } + case "clientSecret": + if v != nil { + clientSecret, err := unmarshalBasicSecretBase(*v) + if err != nil { + return err + } + rslstp.ClientSecret = clientSecret + } + case "tokenEndpoint": + if v != nil { + var tokenEndpoint interface{} + err = json.Unmarshal(*v, &tokenEndpoint) + if err != nil { + return err + } + rslstp.TokenEndpoint = tokenEndpoint + } + case "resource": + if v != nil { + var resource interface{} + err = json.Unmarshal(*v, &resource) + if err != nil { + return err + } + rslstp.Resource = resource + } + case "scope": + if v != nil { + var scope interface{} + err = json.Unmarshal(*v, &scope) + if err != nil { + return err + } + rslstp.Scope = scope + } } } diff --git a/services/preview/datafactory/mgmt/2017-09-01-preview/datafactory/CHANGELOG.md b/services/preview/datafactory/mgmt/2017-09-01-preview/datafactory/CHANGELOG.md index 52911e4cc5e4..e15ee2c5efae 100644 --- a/services/preview/datafactory/mgmt/2017-09-01-preview/datafactory/CHANGELOG.md +++ b/services/preview/datafactory/mgmt/2017-09-01-preview/datafactory/CHANGELOG.md @@ -1,2 +1,112 @@ -# Change History +# Unreleased +## Breaking Changes + +### Removed Constants + +1. IntegrationRuntimeState.Initial +1. IntegrationRuntimeState.Limited +1. IntegrationRuntimeState.NeedRegistration +1. IntegrationRuntimeState.Offline +1. IntegrationRuntimeState.Stopping +1. ManagedIntegrationRuntimeNodeStatus.ManagedIntegrationRuntimeNodeStatusAvailable +1. ManagedIntegrationRuntimeNodeStatus.ManagedIntegrationRuntimeNodeStatusRecycling +1. ManagedIntegrationRuntimeNodeStatus.ManagedIntegrationRuntimeNodeStatusStarting +1. ManagedIntegrationRuntimeNodeStatus.ManagedIntegrationRuntimeNodeStatusUnavailable +1. TriggerRuntimeState.TriggerRuntimeStateDisabled +1. TriggerRuntimeState.TriggerRuntimeStateStarted +1. TriggerRuntimeState.TriggerRuntimeStateStopped + +### Signature Changes + +#### Const Types + +1. Online changed type from IntegrationRuntimeState to DynamicsDeploymentType +1. Started changed type from IntegrationRuntimeState to TriggerRuntimeState +1. Starting changed type from IntegrationRuntimeState to ManagedIntegrationRuntimeNodeStatus +1. Stopped changed type from IntegrationRuntimeState to TriggerRuntimeState + +#### Struct Fields + +1. AzureSearchIndexSink.WriteBehavior changed type from interface{} to AzureSearchIndexWriteBehaviorType +1. CassandraSource.ConsistencyLevel changed type from interface{} to CassandraSourceReadConsistencyLevels +1. DatasetDeflateCompression.Level changed type from interface{} to DatasetCompressionLevel +1. DatasetGZipCompression.Level changed type from interface{} to DatasetCompressionLevel +1. DatasetZipDeflateCompression.Level changed type from interface{} to DatasetCompressionLevel +1. DynamicsLinkedServiceTypeProperties.AuthenticationType changed type from interface{} to DynamicsAuthenticationType +1. DynamicsLinkedServiceTypeProperties.DeploymentType changed type from interface{} to DynamicsDeploymentType +1. DynamicsSink.WriteBehavior changed type from interface{} to *string +1. PolybaseSettings.RejectType changed type from interface{} to PolybaseSettingsRejectType +1. SalesforceSink.WriteBehavior changed type from interface{} to SalesforceSinkWriteBehavior +1. SalesforceSource.ReadBehavior changed type from interface{} to SalesforceSourceReadBehavior +1. SapCloudForCustomerSink.WriteBehavior changed type from interface{} to SapCloudForCustomerSinkWriteBehavior +1. StoredProcedureParameter.Type changed type from interface{} to StoredProcedureParameterType + +## Additive Changes + +### New Constants + +1. AzureSearchIndexWriteBehaviorType.Merge +1. AzureSearchIndexWriteBehaviorType.Upload +1. CassandraSourceReadConsistencyLevels.ALL +1. CassandraSourceReadConsistencyLevels.EACHQUORUM +1. CassandraSourceReadConsistencyLevels.LOCALONE +1. CassandraSourceReadConsistencyLevels.LOCALQUORUM +1. CassandraSourceReadConsistencyLevels.LOCALSERIAL +1. CassandraSourceReadConsistencyLevels.ONE +1. CassandraSourceReadConsistencyLevels.QUORUM +1. CassandraSourceReadConsistencyLevels.SERIAL +1. CassandraSourceReadConsistencyLevels.THREE +1. CassandraSourceReadConsistencyLevels.TWO +1. DatasetCompressionLevel.Fastest +1. DatasetCompressionLevel.Optimal +1. DynamicsAuthenticationType.Ifd +1. DynamicsAuthenticationType.Office365 +1. DynamicsDeploymentType.OnPremisesWithIfd +1. IntegrationRuntimeState.IntegrationRuntimeStateInitial +1. IntegrationRuntimeState.IntegrationRuntimeStateLimited +1. IntegrationRuntimeState.IntegrationRuntimeStateNeedRegistration +1. IntegrationRuntimeState.IntegrationRuntimeStateOffline +1. IntegrationRuntimeState.IntegrationRuntimeStateOnline +1. IntegrationRuntimeState.IntegrationRuntimeStateStarted +1. IntegrationRuntimeState.IntegrationRuntimeStateStarting +1. IntegrationRuntimeState.IntegrationRuntimeStateStopped +1. IntegrationRuntimeState.IntegrationRuntimeStateStopping +1. ManagedIntegrationRuntimeNodeStatus.Available +1. ManagedIntegrationRuntimeNodeStatus.Recycling +1. ManagedIntegrationRuntimeNodeStatus.Unavailable +1. PolybaseSettingsRejectType.Percentage +1. PolybaseSettingsRejectType.Value +1. SalesforceSinkWriteBehavior.Insert +1. SalesforceSinkWriteBehavior.Upsert +1. SalesforceSourceReadBehavior.Query +1. SalesforceSourceReadBehavior.QueryAll +1. SapCloudForCustomerSinkWriteBehavior.SapCloudForCustomerSinkWriteBehaviorInsert +1. SapCloudForCustomerSinkWriteBehavior.SapCloudForCustomerSinkWriteBehaviorUpdate +1. StoredProcedureParameterType.Boolean +1. StoredProcedureParameterType.Date +1. StoredProcedureParameterType.Decimal +1. StoredProcedureParameterType.GUID +1. StoredProcedureParameterType.Int +1. StoredProcedureParameterType.Int64 +1. StoredProcedureParameterType.String +1. TriggerRuntimeState.Disabled + +### New Funcs + +1. PossibleAzureSearchIndexWriteBehaviorTypeValues() []AzureSearchIndexWriteBehaviorType +1. PossibleCassandraSourceReadConsistencyLevelsValues() []CassandraSourceReadConsistencyLevels +1. PossibleDatasetCompressionLevelValues() []DatasetCompressionLevel +1. PossibleDynamicsAuthenticationTypeValues() []DynamicsAuthenticationType +1. PossibleDynamicsDeploymentTypeValues() []DynamicsDeploymentType +1. PossiblePolybaseSettingsRejectTypeValues() []PolybaseSettingsRejectType +1. PossibleSalesforceSinkWriteBehaviorValues() []SalesforceSinkWriteBehavior +1. PossibleSalesforceSourceReadBehaviorValues() []SalesforceSourceReadBehavior +1. PossibleSapCloudForCustomerSinkWriteBehaviorValues() []SapCloudForCustomerSinkWriteBehavior +1. PossibleStoredProcedureParameterTypeValues() []StoredProcedureParameterType + +### Struct Changes + +#### New Struct Fields + +1. WebActivityTypeProperties.DisableCertValidation diff --git a/services/preview/datafactory/mgmt/2017-09-01-preview/datafactory/_meta.json b/services/preview/datafactory/mgmt/2017-09-01-preview/datafactory/_meta.json index 0d1a082632c3..fc1db101d8f0 100644 --- a/services/preview/datafactory/mgmt/2017-09-01-preview/datafactory/_meta.json +++ b/services/preview/datafactory/mgmt/2017-09-01-preview/datafactory/_meta.json @@ -1,5 +1,5 @@ { - "commit": "3c764635e7d442b3e74caf593029fcd440b3ef82", + "commit": "0103b10be26486c6cbae83ae44641069f92da0fe", "readme": "/_/azure-rest-api-specs/specification/datafactory/resource-manager/readme.md", "tag": "package-2017-09-preview", "use": "@microsoft.azure/autorest.go@2.1.187", diff --git a/services/preview/datafactory/mgmt/2017-09-01-preview/datafactory/enums.go b/services/preview/datafactory/mgmt/2017-09-01-preview/datafactory/enums.go index 77b823ac5a7a..351ec53eed8c 100644 --- a/services/preview/datafactory/mgmt/2017-09-01-preview/datafactory/enums.go +++ b/services/preview/datafactory/mgmt/2017-09-01-preview/datafactory/enums.go @@ -42,6 +42,21 @@ func PossibleAuthorizationTypeValues() []AuthorizationType { return []AuthorizationType{AuthorizationTypeKey, AuthorizationTypeLinkedIntegrationRuntimeProperties, AuthorizationTypeRBAC} } +// AzureSearchIndexWriteBehaviorType enumerates the values for azure search index write behavior type. +type AzureSearchIndexWriteBehaviorType string + +const ( + // Merge ... + Merge AzureSearchIndexWriteBehaviorType = "Merge" + // Upload ... + Upload AzureSearchIndexWriteBehaviorType = "Upload" +) + +// PossibleAzureSearchIndexWriteBehaviorTypeValues returns an array of possible values for the AzureSearchIndexWriteBehaviorType const type. +func PossibleAzureSearchIndexWriteBehaviorTypeValues() []AzureSearchIndexWriteBehaviorType { + return []AzureSearchIndexWriteBehaviorType{Merge, Upload} +} + // BlobEventTypes enumerates the values for blob event types. type BlobEventTypes string @@ -57,6 +72,52 @@ func PossibleBlobEventTypesValues() []BlobEventTypes { return []BlobEventTypes{MicrosoftStorageBlobCreated, MicrosoftStorageBlobDeleted} } +// CassandraSourceReadConsistencyLevels enumerates the values for cassandra source read consistency levels. +type CassandraSourceReadConsistencyLevels string + +const ( + // ALL ... + ALL CassandraSourceReadConsistencyLevels = "ALL" + // EACHQUORUM ... + EACHQUORUM CassandraSourceReadConsistencyLevels = "EACH_QUORUM" + // LOCALONE ... + LOCALONE CassandraSourceReadConsistencyLevels = "LOCAL_ONE" + // LOCALQUORUM ... + LOCALQUORUM CassandraSourceReadConsistencyLevels = "LOCAL_QUORUM" + // LOCALSERIAL ... + LOCALSERIAL CassandraSourceReadConsistencyLevels = "LOCAL_SERIAL" + // ONE ... + ONE CassandraSourceReadConsistencyLevels = "ONE" + // QUORUM ... + QUORUM CassandraSourceReadConsistencyLevels = "QUORUM" + // SERIAL ... + SERIAL CassandraSourceReadConsistencyLevels = "SERIAL" + // THREE ... + THREE CassandraSourceReadConsistencyLevels = "THREE" + // TWO ... + TWO CassandraSourceReadConsistencyLevels = "TWO" +) + +// PossibleCassandraSourceReadConsistencyLevelsValues returns an array of possible values for the CassandraSourceReadConsistencyLevels const type. +func PossibleCassandraSourceReadConsistencyLevelsValues() []CassandraSourceReadConsistencyLevels { + return []CassandraSourceReadConsistencyLevels{ALL, EACHQUORUM, LOCALONE, LOCALQUORUM, LOCALSERIAL, ONE, QUORUM, SERIAL, THREE, TWO} +} + +// DatasetCompressionLevel enumerates the values for dataset compression level. +type DatasetCompressionLevel string + +const ( + // Fastest ... + Fastest DatasetCompressionLevel = "Fastest" + // Optimal ... + Optimal DatasetCompressionLevel = "Optimal" +) + +// PossibleDatasetCompressionLevelValues returns an array of possible values for the DatasetCompressionLevel const type. +func PossibleDatasetCompressionLevelValues() []DatasetCompressionLevel { + return []DatasetCompressionLevel{Fastest, Optimal} +} + // DayOfWeek enumerates the values for day of week. type DayOfWeek string @@ -139,6 +200,36 @@ func PossibleDependencyConditionValues() []DependencyCondition { return []DependencyCondition{Completed, Failed, Skipped, Succeeded} } +// DynamicsAuthenticationType enumerates the values for dynamics authentication type. +type DynamicsAuthenticationType string + +const ( + // Ifd ... + Ifd DynamicsAuthenticationType = "Ifd" + // Office365 ... + Office365 DynamicsAuthenticationType = "Office365" +) + +// PossibleDynamicsAuthenticationTypeValues returns an array of possible values for the DynamicsAuthenticationType const type. +func PossibleDynamicsAuthenticationTypeValues() []DynamicsAuthenticationType { + return []DynamicsAuthenticationType{Ifd, Office365} +} + +// DynamicsDeploymentType enumerates the values for dynamics deployment type. +type DynamicsDeploymentType string + +const ( + // Online ... + Online DynamicsDeploymentType = "Online" + // OnPremisesWithIfd ... + OnPremisesWithIfd DynamicsDeploymentType = "OnPremisesWithIfd" +) + +// PossibleDynamicsDeploymentTypeValues returns an array of possible values for the DynamicsDeploymentType const type. +func PossibleDynamicsDeploymentTypeValues() []DynamicsDeploymentType { + return []DynamicsDeploymentType{Online, OnPremisesWithIfd} +} + // FtpAuthenticationType enumerates the values for ftp authentication type. type FtpAuthenticationType string @@ -389,29 +480,29 @@ func PossibleIntegrationRuntimeLicenseTypeValues() []IntegrationRuntimeLicenseTy type IntegrationRuntimeState string const ( - // Initial ... - Initial IntegrationRuntimeState = "Initial" - // Limited ... - Limited IntegrationRuntimeState = "Limited" - // NeedRegistration ... - NeedRegistration IntegrationRuntimeState = "NeedRegistration" - // Offline ... - Offline IntegrationRuntimeState = "Offline" - // Online ... - Online IntegrationRuntimeState = "Online" - // Started ... - Started IntegrationRuntimeState = "Started" - // Starting ... - Starting IntegrationRuntimeState = "Starting" - // Stopped ... - Stopped IntegrationRuntimeState = "Stopped" - // Stopping ... - Stopping IntegrationRuntimeState = "Stopping" + // IntegrationRuntimeStateInitial ... + IntegrationRuntimeStateInitial IntegrationRuntimeState = "Initial" + // IntegrationRuntimeStateLimited ... + IntegrationRuntimeStateLimited IntegrationRuntimeState = "Limited" + // IntegrationRuntimeStateNeedRegistration ... + IntegrationRuntimeStateNeedRegistration IntegrationRuntimeState = "NeedRegistration" + // IntegrationRuntimeStateOffline ... + IntegrationRuntimeStateOffline IntegrationRuntimeState = "Offline" + // IntegrationRuntimeStateOnline ... + IntegrationRuntimeStateOnline IntegrationRuntimeState = "Online" + // IntegrationRuntimeStateStarted ... + IntegrationRuntimeStateStarted IntegrationRuntimeState = "Started" + // IntegrationRuntimeStateStarting ... + IntegrationRuntimeStateStarting IntegrationRuntimeState = "Starting" + // IntegrationRuntimeStateStopped ... + IntegrationRuntimeStateStopped IntegrationRuntimeState = "Stopped" + // IntegrationRuntimeStateStopping ... + IntegrationRuntimeStateStopping IntegrationRuntimeState = "Stopping" ) // PossibleIntegrationRuntimeStateValues returns an array of possible values for the IntegrationRuntimeState const type. func PossibleIntegrationRuntimeStateValues() []IntegrationRuntimeState { - return []IntegrationRuntimeState{Initial, Limited, NeedRegistration, Offline, Online, Started, Starting, Stopped, Stopping} + return []IntegrationRuntimeState{IntegrationRuntimeStateInitial, IntegrationRuntimeStateLimited, IntegrationRuntimeStateNeedRegistration, IntegrationRuntimeStateOffline, IntegrationRuntimeStateOnline, IntegrationRuntimeStateStarted, IntegrationRuntimeStateStarting, IntegrationRuntimeStateStopped, IntegrationRuntimeStateStopping} } // IntegrationRuntimeType enumerates the values for integration runtime type. @@ -463,19 +554,19 @@ func PossibleJSONFormatFilePatternValues() []JSONFormatFilePattern { type ManagedIntegrationRuntimeNodeStatus string const ( - // ManagedIntegrationRuntimeNodeStatusAvailable ... - ManagedIntegrationRuntimeNodeStatusAvailable ManagedIntegrationRuntimeNodeStatus = "Available" - // ManagedIntegrationRuntimeNodeStatusRecycling ... - ManagedIntegrationRuntimeNodeStatusRecycling ManagedIntegrationRuntimeNodeStatus = "Recycling" - // ManagedIntegrationRuntimeNodeStatusStarting ... - ManagedIntegrationRuntimeNodeStatusStarting ManagedIntegrationRuntimeNodeStatus = "Starting" - // ManagedIntegrationRuntimeNodeStatusUnavailable ... - ManagedIntegrationRuntimeNodeStatusUnavailable ManagedIntegrationRuntimeNodeStatus = "Unavailable" + // Available ... + Available ManagedIntegrationRuntimeNodeStatus = "Available" + // Recycling ... + Recycling ManagedIntegrationRuntimeNodeStatus = "Recycling" + // Starting ... + Starting ManagedIntegrationRuntimeNodeStatus = "Starting" + // Unavailable ... + Unavailable ManagedIntegrationRuntimeNodeStatus = "Unavailable" ) // PossibleManagedIntegrationRuntimeNodeStatusValues returns an array of possible values for the ManagedIntegrationRuntimeNodeStatus const type. func PossibleManagedIntegrationRuntimeNodeStatusValues() []ManagedIntegrationRuntimeNodeStatus { - return []ManagedIntegrationRuntimeNodeStatus{ManagedIntegrationRuntimeNodeStatusAvailable, ManagedIntegrationRuntimeNodeStatusRecycling, ManagedIntegrationRuntimeNodeStatusStarting, ManagedIntegrationRuntimeNodeStatusUnavailable} + return []ManagedIntegrationRuntimeNodeStatus{Available, Recycling, Starting, Unavailable} } // MongoDbAuthenticationType enumerates the values for mongo db authentication type. @@ -618,6 +709,21 @@ func PossiblePipelineRunQueryOrderByFieldValues() []PipelineRunQueryOrderByField return []PipelineRunQueryOrderByField{PipelineRunQueryOrderByFieldRunEnd, PipelineRunQueryOrderByFieldRunStart} } +// PolybaseSettingsRejectType enumerates the values for polybase settings reject type. +type PolybaseSettingsRejectType string + +const ( + // Percentage ... + Percentage PolybaseSettingsRejectType = "percentage" + // Value ... + Value PolybaseSettingsRejectType = "value" +) + +// PossiblePolybaseSettingsRejectTypeValues returns an array of possible values for the PolybaseSettingsRejectType const type. +func PossiblePolybaseSettingsRejectTypeValues() []PolybaseSettingsRejectType { + return []PolybaseSettingsRejectType{Percentage, Value} +} + // PrestoAuthenticationType enumerates the values for presto authentication type. type PrestoAuthenticationType string @@ -658,6 +764,51 @@ func PossibleRecurrenceFrequencyValues() []RecurrenceFrequency { return []RecurrenceFrequency{Day, Hour, Minute, Month, NotSpecified, Week, Year} } +// SalesforceSinkWriteBehavior enumerates the values for salesforce sink write behavior. +type SalesforceSinkWriteBehavior string + +const ( + // Insert ... + Insert SalesforceSinkWriteBehavior = "Insert" + // Upsert ... + Upsert SalesforceSinkWriteBehavior = "Upsert" +) + +// PossibleSalesforceSinkWriteBehaviorValues returns an array of possible values for the SalesforceSinkWriteBehavior const type. +func PossibleSalesforceSinkWriteBehaviorValues() []SalesforceSinkWriteBehavior { + return []SalesforceSinkWriteBehavior{Insert, Upsert} +} + +// SalesforceSourceReadBehavior enumerates the values for salesforce source read behavior. +type SalesforceSourceReadBehavior string + +const ( + // Query ... + Query SalesforceSourceReadBehavior = "Query" + // QueryAll ... + QueryAll SalesforceSourceReadBehavior = "QueryAll" +) + +// PossibleSalesforceSourceReadBehaviorValues returns an array of possible values for the SalesforceSourceReadBehavior const type. +func PossibleSalesforceSourceReadBehaviorValues() []SalesforceSourceReadBehavior { + return []SalesforceSourceReadBehavior{Query, QueryAll} +} + +// SapCloudForCustomerSinkWriteBehavior enumerates the values for sap cloud for customer sink write behavior. +type SapCloudForCustomerSinkWriteBehavior string + +const ( + // SapCloudForCustomerSinkWriteBehaviorInsert ... + SapCloudForCustomerSinkWriteBehaviorInsert SapCloudForCustomerSinkWriteBehavior = "Insert" + // SapCloudForCustomerSinkWriteBehaviorUpdate ... + SapCloudForCustomerSinkWriteBehaviorUpdate SapCloudForCustomerSinkWriteBehavior = "Update" +) + +// PossibleSapCloudForCustomerSinkWriteBehaviorValues returns an array of possible values for the SapCloudForCustomerSinkWriteBehavior const type. +func PossibleSapCloudForCustomerSinkWriteBehaviorValues() []SapCloudForCustomerSinkWriteBehavior { + return []SapCloudForCustomerSinkWriteBehavior{SapCloudForCustomerSinkWriteBehaviorInsert, SapCloudForCustomerSinkWriteBehaviorUpdate} +} + // SapHanaAuthenticationType enumerates the values for sap hana authentication type. type SapHanaAuthenticationType string @@ -797,6 +948,31 @@ func PossibleSsisPackageLocationTypeValues() []SsisPackageLocationType { return []SsisPackageLocationType{File, SSISDB} } +// StoredProcedureParameterType enumerates the values for stored procedure parameter type. +type StoredProcedureParameterType string + +const ( + // Boolean ... + Boolean StoredProcedureParameterType = "Boolean" + // Date ... + Date StoredProcedureParameterType = "Date" + // Decimal ... + Decimal StoredProcedureParameterType = "Decimal" + // GUID ... + GUID StoredProcedureParameterType = "Guid" + // Int ... + Int StoredProcedureParameterType = "Int" + // Int64 ... + Int64 StoredProcedureParameterType = "Int64" + // String ... + String StoredProcedureParameterType = "String" +) + +// PossibleStoredProcedureParameterTypeValues returns an array of possible values for the StoredProcedureParameterType const type. +func PossibleStoredProcedureParameterTypeValues() []StoredProcedureParameterType { + return []StoredProcedureParameterType{Boolean, Date, Decimal, GUID, Int, Int64, String} +} + // SybaseAuthenticationType enumerates the values for sybase authentication type. type SybaseAuthenticationType string @@ -848,17 +1024,17 @@ func PossibleTriggerRunStatusValues() []TriggerRunStatus { type TriggerRuntimeState string const ( - // TriggerRuntimeStateDisabled ... - TriggerRuntimeStateDisabled TriggerRuntimeState = "Disabled" - // TriggerRuntimeStateStarted ... - TriggerRuntimeStateStarted TriggerRuntimeState = "Started" - // TriggerRuntimeStateStopped ... - TriggerRuntimeStateStopped TriggerRuntimeState = "Stopped" + // Disabled ... + Disabled TriggerRuntimeState = "Disabled" + // Started ... + Started TriggerRuntimeState = "Started" + // Stopped ... + Stopped TriggerRuntimeState = "Stopped" ) // PossibleTriggerRuntimeStateValues returns an array of possible values for the TriggerRuntimeState const type. func PossibleTriggerRuntimeStateValues() []TriggerRuntimeState { - return []TriggerRuntimeState{TriggerRuntimeStateDisabled, TriggerRuntimeStateStarted, TriggerRuntimeStateStopped} + return []TriggerRuntimeState{Disabled, Started, Stopped} } // TumblingWindowFrequency enumerates the values for tumbling window frequency. diff --git a/services/preview/datafactory/mgmt/2017-09-01-preview/datafactory/models.go b/services/preview/datafactory/mgmt/2017-09-01-preview/datafactory/models.go index 7a99c26e23f4..43b05c34e10e 100644 --- a/services/preview/datafactory/mgmt/2017-09-01-preview/datafactory/models.go +++ b/services/preview/datafactory/mgmt/2017-09-01-preview/datafactory/models.go @@ -13196,8 +13196,8 @@ type AzureSearchIndexDatasetTypeProperties struct { // AzureSearchIndexSink a copy activity Azure Search Index sink. type AzureSearchIndexSink struct { - // WriteBehavior - Specify the write behavior when upserting documents into Azure Search Index. - WriteBehavior interface{} `json:"writeBehavior,omitempty"` + // WriteBehavior - Specify the write behavior when upserting documents into Azure Search Index. Possible values include: 'Merge', 'Upload' + WriteBehavior AzureSearchIndexWriteBehaviorType `json:"writeBehavior,omitempty"` // AdditionalProperties - Unmatched properties from the message are deserialized this collection AdditionalProperties map[string]interface{} `json:""` // WriteBatchSize - Write batch size. Type: integer (or Expression with resultType integer), minimum: 0. @@ -13216,7 +13216,7 @@ type AzureSearchIndexSink struct { func (asis AzureSearchIndexSink) MarshalJSON() ([]byte, error) { asis.Type = TypeAzureSearchIndexSink objectMap := make(map[string]interface{}) - if asis.WriteBehavior != nil { + if asis.WriteBehavior != "" { objectMap["writeBehavior"] = asis.WriteBehavior } if asis.WriteBatchSize != nil { @@ -13331,7 +13331,7 @@ func (asis *AzureSearchIndexSink) UnmarshalJSON(body []byte) error { switch k { case "writeBehavior": if v != nil { - var writeBehavior interface{} + var writeBehavior AzureSearchIndexWriteBehaviorType err = json.Unmarshal(*v, &writeBehavior) if err != nil { return err @@ -17495,7 +17495,7 @@ type BlobEventsTrigger struct { AdditionalProperties map[string]interface{} `json:""` // Description - Trigger description. Description *string `json:"description,omitempty"` - // RuntimeState - READ-ONLY; Indicates if trigger is running or not. Updated when Start/Stop APIs are called on the Trigger. Possible values include: 'TriggerRuntimeStateStarted', 'TriggerRuntimeStateStopped', 'TriggerRuntimeStateDisabled' + // RuntimeState - READ-ONLY; Indicates if trigger is running or not. Updated when Start/Stop APIs are called on the Trigger. Possible values include: 'Started', 'Stopped', 'Disabled' RuntimeState TriggerRuntimeState `json:"runtimeState,omitempty"` // Type - Possible values include: 'TypeTrigger', 'TypeTumblingWindowTrigger', 'TypeBlobEventsTrigger', 'TypeBlobTrigger', 'TypeScheduleTrigger', 'TypeMultiplePipelineTrigger' Type TypeBasicTrigger `json:"type,omitempty"` @@ -18295,7 +18295,7 @@ type BlobTrigger struct { AdditionalProperties map[string]interface{} `json:""` // Description - Trigger description. Description *string `json:"description,omitempty"` - // RuntimeState - READ-ONLY; Indicates if trigger is running or not. Updated when Start/Stop APIs are called on the Trigger. Possible values include: 'TriggerRuntimeStateStarted', 'TriggerRuntimeStateStopped', 'TriggerRuntimeStateDisabled' + // RuntimeState - READ-ONLY; Indicates if trigger is running or not. Updated when Start/Stop APIs are called on the Trigger. Possible values include: 'Started', 'Stopped', 'Disabled' RuntimeState TriggerRuntimeState `json:"runtimeState,omitempty"` // Type - Possible values include: 'TypeTrigger', 'TypeTumblingWindowTrigger', 'TypeBlobEventsTrigger', 'TypeBlobTrigger', 'TypeScheduleTrigger', 'TypeMultiplePipelineTrigger' Type TypeBasicTrigger `json:"type,omitempty"` @@ -19020,8 +19020,8 @@ func (clstp *CassandraLinkedServiceTypeProperties) UnmarshalJSON(body []byte) er type CassandraSource struct { // Query - Database query. Should be a SQL-92 query expression or Cassandra Query Language (CQL) command. Type: string (or Expression with resultType string). Query interface{} `json:"query,omitempty"` - // ConsistencyLevel - The consistency level specifies how many Cassandra servers must respond to a read request before returning data to the client application. Cassandra checks the specified number of Cassandra servers for data to satisfy the read request. Must be one of cassandraSourceReadConsistencyLevels. The default value is 'ONE'. It is case-insensitive. - ConsistencyLevel interface{} `json:"consistencyLevel,omitempty"` + // ConsistencyLevel - The consistency level specifies how many Cassandra servers must respond to a read request before returning data to the client application. Cassandra checks the specified number of Cassandra servers for data to satisfy the read request. Must be one of cassandraSourceReadConsistencyLevels. The default value is 'ONE'. It is case-insensitive. Possible values include: 'ALL', 'EACHQUORUM', 'QUORUM', 'LOCALQUORUM', 'ONE', 'TWO', 'THREE', 'LOCALONE', 'SERIAL', 'LOCALSERIAL' + ConsistencyLevel CassandraSourceReadConsistencyLevels `json:"consistencyLevel,omitempty"` // AdditionalProperties - Unmatched properties from the message are deserialized this collection AdditionalProperties map[string]interface{} `json:""` // SourceRetryCount - Source retry count. Type: integer (or Expression with resultType integer). @@ -19039,7 +19039,7 @@ func (cs CassandraSource) MarshalJSON() ([]byte, error) { if cs.Query != nil { objectMap["query"] = cs.Query } - if cs.ConsistencyLevel != nil { + if cs.ConsistencyLevel != "" { objectMap["consistencyLevel"] = cs.ConsistencyLevel } if cs.SourceRetryCount != nil { @@ -19337,7 +19337,7 @@ func (cs *CassandraSource) UnmarshalJSON(body []byte) error { } case "consistencyLevel": if v != nil { - var consistencyLevel interface{} + var consistencyLevel CassandraSourceReadConsistencyLevels err = json.Unmarshal(*v, &consistencyLevel) if err != nil { return err @@ -27375,8 +27375,8 @@ func (dc *DatasetCompression) UnmarshalJSON(body []byte) error { // DatasetDeflateCompression the Deflate compression method used on a dataset. type DatasetDeflateCompression struct { - // Level - The Deflate compression level. - Level interface{} `json:"level,omitempty"` + // Level - The Deflate compression level. Possible values include: 'Optimal', 'Fastest' + Level DatasetCompressionLevel `json:"level,omitempty"` // AdditionalProperties - Unmatched properties from the message are deserialized this collection AdditionalProperties map[string]interface{} `json:""` // Type - Possible values include: 'TypeDatasetCompression', 'TypeZipDeflate', 'TypeDeflate', 'TypeGZip', 'TypeBZip2' @@ -27387,7 +27387,7 @@ type DatasetDeflateCompression struct { func (ddc DatasetDeflateCompression) MarshalJSON() ([]byte, error) { ddc.Type = TypeDeflate objectMap := make(map[string]interface{}) - if ddc.Level != nil { + if ddc.Level != "" { objectMap["level"] = ddc.Level } if ddc.Type != "" { @@ -27440,7 +27440,7 @@ func (ddc *DatasetDeflateCompression) UnmarshalJSON(body []byte) error { switch k { case "level": if v != nil { - var level interface{} + var level DatasetCompressionLevel err = json.Unmarshal(*v, &level) if err != nil { return err @@ -27476,8 +27476,8 @@ func (ddc *DatasetDeflateCompression) UnmarshalJSON(body []byte) error { // DatasetGZipCompression the GZip compression method used on a dataset. type DatasetGZipCompression struct { - // Level - The GZip compression level. - Level interface{} `json:"level,omitempty"` + // Level - The GZip compression level. Possible values include: 'Optimal', 'Fastest' + Level DatasetCompressionLevel `json:"level,omitempty"` // AdditionalProperties - Unmatched properties from the message are deserialized this collection AdditionalProperties map[string]interface{} `json:""` // Type - Possible values include: 'TypeDatasetCompression', 'TypeZipDeflate', 'TypeDeflate', 'TypeGZip', 'TypeBZip2' @@ -27488,7 +27488,7 @@ type DatasetGZipCompression struct { func (dgzc DatasetGZipCompression) MarshalJSON() ([]byte, error) { dgzc.Type = TypeGZip objectMap := make(map[string]interface{}) - if dgzc.Level != nil { + if dgzc.Level != "" { objectMap["level"] = dgzc.Level } if dgzc.Type != "" { @@ -27541,7 +27541,7 @@ func (dgzc *DatasetGZipCompression) UnmarshalJSON(body []byte) error { switch k { case "level": if v != nil { - var level interface{} + var level DatasetCompressionLevel err = json.Unmarshal(*v, &level) if err != nil { return err @@ -28025,8 +28025,8 @@ func (dsf *DatasetStorageFormat) UnmarshalJSON(body []byte) error { // DatasetZipDeflateCompression the ZipDeflate compression method used on a dataset. type DatasetZipDeflateCompression struct { - // Level - The ZipDeflate compression level. - Level interface{} `json:"level,omitempty"` + // Level - The ZipDeflate compression level. Possible values include: 'Optimal', 'Fastest' + Level DatasetCompressionLevel `json:"level,omitempty"` // AdditionalProperties - Unmatched properties from the message are deserialized this collection AdditionalProperties map[string]interface{} `json:""` // Type - Possible values include: 'TypeDatasetCompression', 'TypeZipDeflate', 'TypeDeflate', 'TypeGZip', 'TypeBZip2' @@ -28037,7 +28037,7 @@ type DatasetZipDeflateCompression struct { func (dzdc DatasetZipDeflateCompression) MarshalJSON() ([]byte, error) { dzdc.Type = TypeZipDeflate objectMap := make(map[string]interface{}) - if dzdc.Level != nil { + if dzdc.Level != "" { objectMap["level"] = dzdc.Level } if dzdc.Type != "" { @@ -28090,7 +28090,7 @@ func (dzdc *DatasetZipDeflateCompression) UnmarshalJSON(body []byte) error { switch k { case "level": if v != nil { - var level interface{} + var level DatasetCompressionLevel err = json.Unmarshal(*v, &level) if err != nil { return err @@ -31874,8 +31874,8 @@ func (dls *DynamicsLinkedService) UnmarshalJSON(body []byte) error { // DynamicsLinkedServiceTypeProperties dynamics linked service properties. type DynamicsLinkedServiceTypeProperties struct { - // DeploymentType - The deployment type of the Dynamics instance. 'Online' for Dynamics Online and 'OnPremisesWithIfd' for Dynamics on-premises with Ifd. Type: string (or Expression with resultType string). - DeploymentType interface{} `json:"deploymentType,omitempty"` + // DeploymentType - The deployment type of the Dynamics instance. 'Online' for Dynamics Online and 'OnPremisesWithIfd' for Dynamics on-premises with Ifd. Type: string (or Expression with resultType string). Possible values include: 'Online', 'OnPremisesWithIfd' + DeploymentType DynamicsDeploymentType `json:"deploymentType,omitempty"` // HostName - The host name of the on-premises Dynamics server. The property is required for on-prem and not allowed for online. Type: string (or Expression with resultType string). HostName interface{} `json:"hostName,omitempty"` // Port - The port of on-premises Dynamics server. The property is required for on-prem and not allowed for online. Default is 443. Type: integer (or Expression with resultType integer), minimum: 0. @@ -31884,8 +31884,8 @@ type DynamicsLinkedServiceTypeProperties struct { ServiceURI interface{} `json:"serviceUri,omitempty"` // OrganizationName - The organization name of the Dynamics instance. The property is required for on-prem and required for online when there are more than one Dynamics instances associated with the user. Type: string (or Expression with resultType string). OrganizationName interface{} `json:"organizationName,omitempty"` - // AuthenticationType - The authentication type to connect to Dynamics server. 'Office365' for online scenario, 'Ifd' for on-premises with Ifd scenario. Type: string (or Expression with resultType string). - AuthenticationType interface{} `json:"authenticationType,omitempty"` + // AuthenticationType - The authentication type to connect to Dynamics server. 'Office365' for online scenario, 'Ifd' for on-premises with Ifd scenario. Type: string (or Expression with resultType string). Possible values include: 'Office365', 'Ifd' + AuthenticationType DynamicsAuthenticationType `json:"authenticationType,omitempty"` // Username - User name to access the Dynamics instance. Type: string (or Expression with resultType string). Username interface{} `json:"username,omitempty"` // Password - Password to access the Dynamics instance. @@ -31905,7 +31905,7 @@ func (dlstp *DynamicsLinkedServiceTypeProperties) UnmarshalJSON(body []byte) err switch k { case "deploymentType": if v != nil { - var deploymentType interface{} + var deploymentType DynamicsDeploymentType err = json.Unmarshal(*v, &deploymentType) if err != nil { return err @@ -31950,7 +31950,7 @@ func (dlstp *DynamicsLinkedServiceTypeProperties) UnmarshalJSON(body []byte) err } case "authenticationType": if v != nil { - var authenticationType interface{} + var authenticationType DynamicsAuthenticationType err = json.Unmarshal(*v, &authenticationType) if err != nil { return err @@ -31992,7 +31992,7 @@ func (dlstp *DynamicsLinkedServiceTypeProperties) UnmarshalJSON(body []byte) err // DynamicsSink a copy activity Dynamics sink. type DynamicsSink struct { // WriteBehavior - The write behavior for the operation. - WriteBehavior interface{} `json:"writeBehavior,omitempty"` + WriteBehavior *string `json:"writeBehavior,omitempty"` // IgnoreNullValues - The flag indicating whether ignore null values from input dataset (except key fields) during write operation. Default is false. Type: boolean (or Expression with resultType boolean). IgnoreNullValues interface{} `json:"ignoreNullValues,omitempty"` // AdditionalProperties - Unmatched properties from the message are deserialized this collection @@ -32131,12 +32131,12 @@ func (ds *DynamicsSink) UnmarshalJSON(body []byte) error { switch k { case "writeBehavior": if v != nil { - var writeBehavior interface{} + var writeBehavior string err = json.Unmarshal(*v, &writeBehavior) if err != nil { return err } - ds.WriteBehavior = writeBehavior + ds.WriteBehavior = &writeBehavior } case "ignoreNullValues": if v != nil { @@ -53547,7 +53547,7 @@ type IntegrationRuntimeStatus struct { AdditionalProperties map[string]interface{} `json:""` // DataFactoryName - READ-ONLY; The data factory name which the integration runtime belong to. DataFactoryName *string `json:"dataFactoryName,omitempty"` - // State - READ-ONLY; The state of integration runtime. Possible values include: 'Initial', 'Stopped', 'Started', 'Starting', 'Stopping', 'NeedRegistration', 'Online', 'Limited', 'Offline' + // State - READ-ONLY; The state of integration runtime. Possible values include: 'IntegrationRuntimeStateInitial', 'IntegrationRuntimeStateStopped', 'IntegrationRuntimeStateStarted', 'IntegrationRuntimeStateStarting', 'IntegrationRuntimeStateStopping', 'IntegrationRuntimeStateNeedRegistration', 'IntegrationRuntimeStateOnline', 'IntegrationRuntimeStateLimited', 'IntegrationRuntimeStateOffline' State IntegrationRuntimeState `json:"state,omitempty"` // Type - Possible values include: 'TypeBasicIntegrationRuntimeStatusTypeIntegrationRuntimeStatus', 'TypeBasicIntegrationRuntimeStatusTypeSelfHosted', 'TypeBasicIntegrationRuntimeStatusTypeManaged' Type TypeBasicIntegrationRuntimeStatus `json:"type,omitempty"` @@ -58360,7 +58360,7 @@ func (ms *MagentoSource) UnmarshalJSON(body []byte) error { // ManagedIntegrationRuntime managed integration runtime, including managed elastic and managed dedicated // integration runtimes. type ManagedIntegrationRuntime struct { - // State - READ-ONLY; Integration runtime state, only valid for managed dedicated integration runtime. Possible values include: 'Initial', 'Stopped', 'Started', 'Starting', 'Stopping', 'NeedRegistration', 'Online', 'Limited', 'Offline' + // State - READ-ONLY; Integration runtime state, only valid for managed dedicated integration runtime. Possible values include: 'IntegrationRuntimeStateInitial', 'IntegrationRuntimeStateStopped', 'IntegrationRuntimeStateStarted', 'IntegrationRuntimeStateStarting', 'IntegrationRuntimeStateStopping', 'IntegrationRuntimeStateNeedRegistration', 'IntegrationRuntimeStateOnline', 'IntegrationRuntimeStateLimited', 'IntegrationRuntimeStateOffline' State IntegrationRuntimeState `json:"state,omitempty"` // ManagedIntegrationRuntimeTypeProperties - Managed integration runtime properties. *ManagedIntegrationRuntimeTypeProperties `json:"typeProperties,omitempty"` @@ -58496,7 +58496,7 @@ func (mire ManagedIntegrationRuntimeError) MarshalJSON() ([]byte, error) { type ManagedIntegrationRuntimeNode struct { // NodeID - READ-ONLY; The managed integration runtime node id. NodeID *string `json:"nodeId,omitempty"` - // Status - READ-ONLY; The managed integration runtime node status. Possible values include: 'ManagedIntegrationRuntimeNodeStatusStarting', 'ManagedIntegrationRuntimeNodeStatusAvailable', 'ManagedIntegrationRuntimeNodeStatusRecycling', 'ManagedIntegrationRuntimeNodeStatusUnavailable' + // Status - READ-ONLY; The managed integration runtime node status. Possible values include: 'Starting', 'Available', 'Recycling', 'Unavailable' Status ManagedIntegrationRuntimeNodeStatus `json:"status,omitempty"` // Errors - The errors that occurred on this integration runtime node. Errors *[]ManagedIntegrationRuntimeError `json:"errors,omitempty"` @@ -58541,7 +58541,7 @@ type ManagedIntegrationRuntimeStatus struct { AdditionalProperties map[string]interface{} `json:""` // DataFactoryName - READ-ONLY; The data factory name which the integration runtime belong to. DataFactoryName *string `json:"dataFactoryName,omitempty"` - // State - READ-ONLY; The state of integration runtime. Possible values include: 'Initial', 'Stopped', 'Started', 'Starting', 'Stopping', 'NeedRegistration', 'Online', 'Limited', 'Offline' + // State - READ-ONLY; The state of integration runtime. Possible values include: 'IntegrationRuntimeStateInitial', 'IntegrationRuntimeStateStopped', 'IntegrationRuntimeStateStarted', 'IntegrationRuntimeStateStarting', 'IntegrationRuntimeStateStopping', 'IntegrationRuntimeStateNeedRegistration', 'IntegrationRuntimeStateOnline', 'IntegrationRuntimeStateLimited', 'IntegrationRuntimeStateOffline' State IntegrationRuntimeState `json:"state,omitempty"` // Type - Possible values include: 'TypeBasicIntegrationRuntimeStatusTypeIntegrationRuntimeStatus', 'TypeBasicIntegrationRuntimeStatusTypeSelfHosted', 'TypeBasicIntegrationRuntimeStatusTypeManaged' Type TypeBasicIntegrationRuntimeStatus `json:"type,omitempty"` @@ -62683,7 +62683,7 @@ type MultiplePipelineTrigger struct { AdditionalProperties map[string]interface{} `json:""` // Description - Trigger description. Description *string `json:"description,omitempty"` - // RuntimeState - READ-ONLY; Indicates if trigger is running or not. Updated when Start/Stop APIs are called on the Trigger. Possible values include: 'TriggerRuntimeStateStarted', 'TriggerRuntimeStateStopped', 'TriggerRuntimeStateDisabled' + // RuntimeState - READ-ONLY; Indicates if trigger is running or not. Updated when Start/Stop APIs are called on the Trigger. Possible values include: 'Started', 'Stopped', 'Disabled' RuntimeState TriggerRuntimeState `json:"runtimeState,omitempty"` // Type - Possible values include: 'TypeTrigger', 'TypeTumblingWindowTrigger', 'TypeBlobEventsTrigger', 'TypeBlobTrigger', 'TypeScheduleTrigger', 'TypeMultiplePipelineTrigger' Type TypeBasicTrigger `json:"type,omitempty"` @@ -71616,8 +71616,8 @@ type PipelineRunQueryResponse struct { type PolybaseSettings struct { // AdditionalProperties - Unmatched properties from the message are deserialized this collection AdditionalProperties map[string]interface{} `json:""` - // RejectType - Reject type. - RejectType interface{} `json:"rejectType,omitempty"` + // RejectType - Reject type. Possible values include: 'Value', 'Percentage' + RejectType PolybaseSettingsRejectType `json:"rejectType,omitempty"` // RejectValue - Specifies the value or the percentage of rows that can be rejected before the query fails. Type: number (or Expression with resultType number), minimum: 0. RejectValue interface{} `json:"rejectValue,omitempty"` // RejectSampleValue - Determines the number of rows to attempt to retrieve before the PolyBase recalculates the percentage of rejected rows. Type: integer (or Expression with resultType integer), minimum: 0. @@ -71629,7 +71629,7 @@ type PolybaseSettings struct { // MarshalJSON is the custom marshaler for PolybaseSettings. func (ps PolybaseSettings) MarshalJSON() ([]byte, error) { objectMap := make(map[string]interface{}) - if ps.RejectType != nil { + if ps.RejectType != "" { objectMap["rejectType"] = ps.RejectType } if ps.RejectValue != nil { @@ -71670,7 +71670,7 @@ func (ps *PolybaseSettings) UnmarshalJSON(body []byte) error { } case "rejectType": if v != nil { - var rejectType interface{} + var rejectType PolybaseSettingsRejectType err = json.Unmarshal(*v, &rejectType) if err != nil { return err @@ -79745,8 +79745,8 @@ type SalesforceObjectDatasetTypeProperties struct { // SalesforceSink a copy activity Salesforce sink. type SalesforceSink struct { - // WriteBehavior - The write behavior for the operation. Default is Insert. - WriteBehavior interface{} `json:"writeBehavior,omitempty"` + // WriteBehavior - The write behavior for the operation. Default is Insert. Possible values include: 'Insert', 'Upsert' + WriteBehavior SalesforceSinkWriteBehavior `json:"writeBehavior,omitempty"` // ExternalIDFieldName - The name of the external ID field for upsert operation. Default value is 'Id' column. Type: string (or Expression with resultType string). ExternalIDFieldName interface{} `json:"externalIdFieldName,omitempty"` // IgnoreNullValues - The flag indicating whether or not to ignore null values from input dataset (except key fields) during write operation. Default value is false. If set it to true, it means ADF will leave the data in the destination object unchanged when doing upsert/update operation and insert defined default value when doing insert operation, versus ADF will update the data in the destination object to NULL when doing upsert/update operation and insert NULL value when doing insert operation. Type: boolean (or Expression with resultType boolean). @@ -79769,7 +79769,7 @@ type SalesforceSink struct { func (ss SalesforceSink) MarshalJSON() ([]byte, error) { ss.Type = TypeSalesforceSink objectMap := make(map[string]interface{}) - if ss.WriteBehavior != nil { + if ss.WriteBehavior != "" { objectMap["writeBehavior"] = ss.WriteBehavior } if ss.ExternalIDFieldName != nil { @@ -79890,7 +79890,7 @@ func (ss *SalesforceSink) UnmarshalJSON(body []byte) error { switch k { case "writeBehavior": if v != nil { - var writeBehavior interface{} + var writeBehavior SalesforceSinkWriteBehavior err = json.Unmarshal(*v, &writeBehavior) if err != nil { return err @@ -79982,8 +79982,8 @@ func (ss *SalesforceSink) UnmarshalJSON(body []byte) error { type SalesforceSource struct { // Query - Database query. Type: string (or Expression with resultType string). Query interface{} `json:"query,omitempty"` - // ReadBehavior - The read behavior for the operation. Default is Query. - ReadBehavior interface{} `json:"readBehavior,omitempty"` + // ReadBehavior - The read behavior for the operation. Default is Query. Possible values include: 'Query', 'QueryAll' + ReadBehavior SalesforceSourceReadBehavior `json:"readBehavior,omitempty"` // AdditionalProperties - Unmatched properties from the message are deserialized this collection AdditionalProperties map[string]interface{} `json:""` // SourceRetryCount - Source retry count. Type: integer (or Expression with resultType integer). @@ -80001,7 +80001,7 @@ func (ss SalesforceSource) MarshalJSON() ([]byte, error) { if ss.Query != nil { objectMap["query"] = ss.Query } - if ss.ReadBehavior != nil { + if ss.ReadBehavior != "" { objectMap["readBehavior"] = ss.ReadBehavior } if ss.SourceRetryCount != nil { @@ -80299,7 +80299,7 @@ func (ss *SalesforceSource) UnmarshalJSON(body []byte) error { } case "readBehavior": if v != nil { - var readBehavior interface{} + var readBehavior SalesforceSourceReadBehavior err = json.Unmarshal(*v, &readBehavior) if err != nil { return err @@ -81896,8 +81896,8 @@ type SapCloudForCustomerResourceDatasetTypeProperties struct { // SapCloudForCustomerSink a copy activity SAP Cloud for Customer sink. type SapCloudForCustomerSink struct { - // WriteBehavior - The write behavior for the operation. Default is 'Insert'. - WriteBehavior interface{} `json:"writeBehavior,omitempty"` + // WriteBehavior - The write behavior for the operation. Default is 'Insert'. Possible values include: 'SapCloudForCustomerSinkWriteBehaviorInsert', 'SapCloudForCustomerSinkWriteBehaviorUpdate' + WriteBehavior SapCloudForCustomerSinkWriteBehavior `json:"writeBehavior,omitempty"` // AdditionalProperties - Unmatched properties from the message are deserialized this collection AdditionalProperties map[string]interface{} `json:""` // WriteBatchSize - Write batch size. Type: integer (or Expression with resultType integer), minimum: 0. @@ -81916,7 +81916,7 @@ type SapCloudForCustomerSink struct { func (scfcs SapCloudForCustomerSink) MarshalJSON() ([]byte, error) { scfcs.Type = TypeSapCloudForCustomerSink objectMap := make(map[string]interface{}) - if scfcs.WriteBehavior != nil { + if scfcs.WriteBehavior != "" { objectMap["writeBehavior"] = scfcs.WriteBehavior } if scfcs.WriteBatchSize != nil { @@ -82031,7 +82031,7 @@ func (scfcs *SapCloudForCustomerSink) UnmarshalJSON(body []byte) error { switch k { case "writeBehavior": if v != nil { - var writeBehavior interface{} + var writeBehavior SapCloudForCustomerSinkWriteBehavior err = json.Unmarshal(*v, &writeBehavior) if err != nil { return err @@ -84360,7 +84360,7 @@ type ScheduleTrigger struct { AdditionalProperties map[string]interface{} `json:""` // Description - Trigger description. Description *string `json:"description,omitempty"` - // RuntimeState - READ-ONLY; Indicates if trigger is running or not. Updated when Start/Stop APIs are called on the Trigger. Possible values include: 'TriggerRuntimeStateStarted', 'TriggerRuntimeStateStopped', 'TriggerRuntimeStateDisabled' + // RuntimeState - READ-ONLY; Indicates if trigger is running or not. Updated when Start/Stop APIs are called on the Trigger. Possible values include: 'Started', 'Stopped', 'Disabled' RuntimeState TriggerRuntimeState `json:"runtimeState,omitempty"` // Type - Possible values include: 'TypeTrigger', 'TypeTumblingWindowTrigger', 'TypeBlobEventsTrigger', 'TypeBlobTrigger', 'TypeScheduleTrigger', 'TypeMultiplePipelineTrigger' Type TypeBasicTrigger `json:"type,omitempty"` @@ -84918,7 +84918,7 @@ type SelfHostedIntegrationRuntimeStatus struct { AdditionalProperties map[string]interface{} `json:""` // DataFactoryName - READ-ONLY; The data factory name which the integration runtime belong to. DataFactoryName *string `json:"dataFactoryName,omitempty"` - // State - READ-ONLY; The state of integration runtime. Possible values include: 'Initial', 'Stopped', 'Started', 'Starting', 'Stopping', 'NeedRegistration', 'Online', 'Limited', 'Offline' + // State - READ-ONLY; The state of integration runtime. Possible values include: 'IntegrationRuntimeStateInitial', 'IntegrationRuntimeStateStopped', 'IntegrationRuntimeStateStarted', 'IntegrationRuntimeStateStarting', 'IntegrationRuntimeStateStopping', 'IntegrationRuntimeStateNeedRegistration', 'IntegrationRuntimeStateOnline', 'IntegrationRuntimeStateLimited', 'IntegrationRuntimeStateOffline' State IntegrationRuntimeState `json:"state,omitempty"` // Type - Possible values include: 'TypeBasicIntegrationRuntimeStatusTypeIntegrationRuntimeStatus', 'TypeBasicIntegrationRuntimeStatusTypeSelfHosted', 'TypeBasicIntegrationRuntimeStatusTypeManaged' Type TypeBasicIntegrationRuntimeStatus `json:"type,omitempty"` @@ -94056,8 +94056,8 @@ func (ss *StagingSettings) UnmarshalJSON(body []byte) error { type StoredProcedureParameter struct { // Value - Stored procedure parameter value. Type: string (or Expression with resultType string). Value interface{} `json:"value,omitempty"` - // Type - Stored procedure parameter type. - Type interface{} `json:"type,omitempty"` + // Type - Stored procedure parameter type. Possible values include: 'String', 'Int', 'Int64', 'Decimal', 'GUID', 'Boolean', 'Date' + Type StoredProcedureParameterType `json:"type,omitempty"` } // SubResource azure Data Factory nested resource, which belongs to a factory. @@ -95483,7 +95483,7 @@ type Trigger struct { AdditionalProperties map[string]interface{} `json:""` // Description - Trigger description. Description *string `json:"description,omitempty"` - // RuntimeState - READ-ONLY; Indicates if trigger is running or not. Updated when Start/Stop APIs are called on the Trigger. Possible values include: 'TriggerRuntimeStateStarted', 'TriggerRuntimeStateStopped', 'TriggerRuntimeStateDisabled' + // RuntimeState - READ-ONLY; Indicates if trigger is running or not. Updated when Start/Stop APIs are called on the Trigger. Possible values include: 'Started', 'Stopped', 'Disabled' RuntimeState TriggerRuntimeState `json:"runtimeState,omitempty"` // Type - Possible values include: 'TypeTrigger', 'TypeTumblingWindowTrigger', 'TypeBlobEventsTrigger', 'TypeBlobTrigger', 'TypeScheduleTrigger', 'TypeMultiplePipelineTrigger' Type TypeBasicTrigger `json:"type,omitempty"` @@ -96285,7 +96285,7 @@ type TumblingWindowTrigger struct { AdditionalProperties map[string]interface{} `json:""` // Description - Trigger description. Description *string `json:"description,omitempty"` - // RuntimeState - READ-ONLY; Indicates if trigger is running or not. Updated when Start/Stop APIs are called on the Trigger. Possible values include: 'TriggerRuntimeStateStarted', 'TriggerRuntimeStateStopped', 'TriggerRuntimeStateDisabled' + // RuntimeState - READ-ONLY; Indicates if trigger is running or not. Updated when Start/Stop APIs are called on the Trigger. Possible values include: 'Started', 'Stopped', 'Disabled' RuntimeState TriggerRuntimeState `json:"runtimeState,omitempty"` // Type - Possible values include: 'TypeTrigger', 'TypeTumblingWindowTrigger', 'TypeBlobEventsTrigger', 'TypeBlobTrigger', 'TypeScheduleTrigger', 'TypeMultiplePipelineTrigger' Type TypeBasicTrigger `json:"type,omitempty"` @@ -98584,6 +98584,8 @@ type WebActivityTypeProperties struct { Body interface{} `json:"body,omitempty"` // Authentication - Authentication method used for calling the endpoint. Authentication *WebActivityAuthentication `json:"authentication,omitempty"` + // DisableCertValidation - When set to true, Certificate validation will be disabled. + DisableCertValidation *bool `json:"disableCertValidation,omitempty"` // Datasets - List of datasets passed to web endpoint. Datasets *[]DatasetReference `json:"datasets,omitempty"` // LinkedServices - List of linked services passed to web endpoint.