From e293279fdb4fdea48eeb13ddde63e3e7253d4452 Mon Sep 17 00:00:00 2001 From: SDKAuto Date: Tue, 17 Nov 2020 03:24:52 +0000 Subject: [PATCH] CodeGen from PR 11640 in Azure/azure-rest-api-specs add traceLevel, continueOnError, and runConcurrently properties to Dataflow activity properties (#11640) --- .../mgmt/2018-06-01/datafactory/enums.go | 4 +- .../mgmt/2018-06-01/datafactory/models.go | 256 +++++++++++++----- 2 files changed, 189 insertions(+), 71 deletions(-) diff --git a/services/datafactory/mgmt/2018-06-01/datafactory/enums.go b/services/datafactory/mgmt/2018-06-01/datafactory/enums.go index 8c05febdc8ff..2f2a723670c2 100644 --- a/services/datafactory/mgmt/2018-06-01/datafactory/enums.go +++ b/services/datafactory/mgmt/2018-06-01/datafactory/enums.go @@ -1472,11 +1472,13 @@ const ( TumblingWindowFrequencyHour TumblingWindowFrequency = "Hour" // TumblingWindowFrequencyMinute ... TumblingWindowFrequencyMinute TumblingWindowFrequency = "Minute" + // TumblingWindowFrequencyMonth ... + TumblingWindowFrequencyMonth TumblingWindowFrequency = "Month" ) // PossibleTumblingWindowFrequencyValues returns an array of possible values for the TumblingWindowFrequency const type. func PossibleTumblingWindowFrequencyValues() []TumblingWindowFrequency { - return []TumblingWindowFrequency{TumblingWindowFrequencyHour, TumblingWindowFrequencyMinute} + return []TumblingWindowFrequency{TumblingWindowFrequencyHour, TumblingWindowFrequencyMinute, TumblingWindowFrequencyMonth} } // Type enumerates the values for type. diff --git a/services/datafactory/mgmt/2018-06-01/datafactory/models.go b/services/datafactory/mgmt/2018-06-01/datafactory/models.go index a27e41780ff2..da9076787d7e 100644 --- a/services/datafactory/mgmt/2018-06-01/datafactory/models.go +++ b/services/datafactory/mgmt/2018-06-01/datafactory/models.go @@ -6364,12 +6364,16 @@ func (asls *AmazonS3LinkedService) UnmarshalJSON(body []byte) error { // AmazonS3LinkedServiceTypeProperties amazon S3 linked service properties. type AmazonS3LinkedServiceTypeProperties struct { + // AuthenticationType - The authentication type of S3. Allowed value: AccessKey (default) or TemporarySecurityCredentials. Type: string (or Expression with resultType string). + AuthenticationType interface{} `json:"authenticationType,omitempty"` // AccessKeyID - The access key identifier of the Amazon S3 Identity and Access Management (IAM) user. Type: string (or Expression with resultType string). AccessKeyID interface{} `json:"accessKeyId,omitempty"` // SecretAccessKey - The secret access key of the Amazon S3 Identity and Access Management (IAM) user. SecretAccessKey BasicSecretBase `json:"secretAccessKey,omitempty"` // ServiceURL - This value specifies the endpoint to access with the S3 Connector. This is an optional property; change it only if you want to try a different service endpoint or want to switch between https and http. Type: string (or Expression with resultType string). ServiceURL interface{} `json:"serviceUrl,omitempty"` + // SessionToken - The session token for the S3 temporary security credential. + SessionToken BasicSecretBase `json:"sessionToken,omitempty"` // EncryptedCredential - The encrypted credential used for authentication. Credentials are encrypted using the integration runtime credential manager. Type: string (or Expression with resultType string). EncryptedCredential interface{} `json:"encryptedCredential,omitempty"` } @@ -6383,6 +6387,15 @@ func (aslstp *AmazonS3LinkedServiceTypeProperties) UnmarshalJSON(body []byte) er } for k, v := range m { switch k { + case "authenticationType": + if v != nil { + var authenticationType interface{} + err = json.Unmarshal(*v, &authenticationType) + if err != nil { + return err + } + aslstp.AuthenticationType = authenticationType + } case "accessKeyId": if v != nil { var accessKeyID interface{} @@ -6409,6 +6422,14 @@ func (aslstp *AmazonS3LinkedServiceTypeProperties) UnmarshalJSON(body []byte) er } aslstp.ServiceURL = serviceURL } + case "sessionToken": + if v != nil { + sessionToken, err := unmarshalBasicSecretBase(*v) + if err != nil { + return err + } + aslstp.SessionToken = sessionToken + } case "encryptedCredential": if v != nil { var encryptedCredential interface{} @@ -17394,7 +17415,8 @@ func (addls *AzureDatabricksDeltaLakeSource) UnmarshalJSON(body []byte) error { return nil } -// AzureDatabricksDetltaLakeLinkedServiceTypeProperties azure Databricks Delta Lake linked service properties. +// AzureDatabricksDetltaLakeLinkedServiceTypeProperties azure Databricks Delta Lake linked service +// properties. type AzureDatabricksDetltaLakeLinkedServiceTypeProperties struct { // Domain - .azuredatabricks.net, domain name of your Databricks deployment. Type: string (or Expression with resultType string). Domain interface{} `json:"domain,omitempty"` @@ -51957,9 +51979,9 @@ type CassandraTableDatasetTypeProperties struct { } // ChainingTrigger trigger that allows the referenced pipeline to depend on other pipeline runs based on -// runDimension Name/Value pairs. Upstream pipelines should declare the same runDimension Name and their runs -// should have the values for those runDimensions. The referenced pipeline run would be triggered if the values -// for the runDimension match for all upstream pipeline runs. +// runDimension Name/Value pairs. Upstream pipelines should declare the same runDimension Name and their +// runs should have the values for those runDimensions. The referenced pipeline run would be triggered if +// the values for the runDimension match for all upstream pipeline runs. type ChainingTrigger struct { // Pipeline - Pipeline for which runs are created when all upstream pipelines complete successfully. Pipeline *TriggerPipelineReference `json:"pipeline,omitempty"` @@ -52971,7 +52993,8 @@ func (cdsfaed *CommonDataServiceForAppsEntityDataset) UnmarshalJSON(body []byte) return nil } -// CommonDataServiceForAppsEntityDatasetTypeProperties common Data Service for Apps entity dataset properties. +// CommonDataServiceForAppsEntityDatasetTypeProperties common Data Service for Apps entity dataset +// properties. type CommonDataServiceForAppsEntityDatasetTypeProperties struct { // EntityName - The logical name of the entity. Type: string (or Expression with resultType string). EntityName interface{} `json:"entityName,omitempty"` @@ -53604,7 +53627,8 @@ func (cdsfals *CommonDataServiceForAppsLinkedService) UnmarshalJSON(body []byte) return nil } -// CommonDataServiceForAppsLinkedServiceTypeProperties common Data Service for Apps linked service properties. +// CommonDataServiceForAppsLinkedServiceTypeProperties common Data Service for Apps linked service +// properties. type CommonDataServiceForAppsLinkedServiceTypeProperties struct { // DeploymentType - The deployment type of the Common Data Service for Apps instance. 'Online' for Common Data Service for Apps Online and 'OnPremisesWithIfd' for Common Data Service for Apps on-premises with Ifd. Type: string (or Expression with resultType string). Possible values include: 'Online', 'OnPremisesWithIfd' DeploymentType DynamicsDeploymentType `json:"deploymentType,omitempty"` @@ -55572,6 +55596,8 @@ func (cls *ConcurLinkedService) UnmarshalJSON(body []byte) error { // ConcurLinkedServiceTypeProperties concur Service linked service properties. type ConcurLinkedServiceTypeProperties struct { + // ConnectionProperties - Properties used to connect to Concur. It is mutually exclusive with any other properties in the linked service. Type: object. + ConnectionProperties interface{} `json:"connectionProperties,omitempty"` // ClientID - Application client_id supplied by Concur App Management. ClientID interface{} `json:"clientId,omitempty"` // Username - The user name that you use to access Concur Service. @@ -55597,6 +55623,15 @@ func (clstp *ConcurLinkedServiceTypeProperties) UnmarshalJSON(body []byte) error } for k, v := range m { switch k { + case "connectionProperties": + if v != nil { + var connectionProperties interface{} + err = json.Unmarshal(*v, &connectionProperties) + if err != nil { + return err + } + clstp.ConnectionProperties = connectionProperties + } case "clientId": if v != nil { var clientID interface{} @@ -57729,6 +57764,14 @@ func (ca *CopyActivity) UnmarshalJSON(body []byte) error { return nil } +// CopyActivityLogSettings settings for copy activity log. +type CopyActivityLogSettings struct { + // LogLevel - Gets or sets the log level, support: Info, Warning. Type: string (or Expression with resultType string). + LogLevel interface{} `json:"logLevel,omitempty"` + // EnableReliableLogging - Specifies whether to enable reliable logging. Type: boolean (or Expression with resultType boolean). + EnableReliableLogging interface{} `json:"enableReliableLogging,omitempty"` +} + // CopyActivityTypeProperties copy activity properties. type CopyActivityTypeProperties struct { // Source - Copy activity source. @@ -57749,8 +57792,10 @@ type CopyActivityTypeProperties struct { EnableSkipIncompatibleRow interface{} `json:"enableSkipIncompatibleRow,omitempty"` // RedirectIncompatibleRowSettings - Redirect incompatible row settings when EnableSkipIncompatibleRow is true. RedirectIncompatibleRowSettings *RedirectIncompatibleRowSettings `json:"redirectIncompatibleRowSettings,omitempty"` - // LogStorageSettings - Log storage settings customer need to provide when enabling session log. + // LogStorageSettings - (Deprecated. Please use LogSettings) Log storage settings customer need to provide when enabling session log. LogStorageSettings *LogStorageSettings `json:"logStorageSettings,omitempty"` + // LogSettings - Log settings customer needs provide when enabling log. + LogSettings *LogSettings `json:"logSettings,omitempty"` // PreserveRules - Preserve Rules. PreserveRules *[]interface{} `json:"preserveRules,omitempty"` // Preserve - Preserve rules. @@ -57858,6 +57903,15 @@ func (catp *CopyActivityTypeProperties) UnmarshalJSON(body []byte) error { } catp.LogStorageSettings = &logStorageSettings } + case "logSettings": + if v != nil { + var logSettings LogSettings + err = json.Unmarshal(*v, &logSettings) + if err != nil { + return err + } + catp.LogSettings = &logSettings + } case "preserveRules": if v != nil { var preserveRules []interface{} @@ -69390,8 +69444,8 @@ func (dfdr *DataFlowDebugResource) UnmarshalJSON(body []byte) error { return nil } -// DataFlowDebugSessionCreateFuture an abstraction for monitoring and retrieving the results of a long-running -// operation. +// DataFlowDebugSessionCreateFuture an abstraction for monitoring and retrieving the results of a +// long-running operation. type DataFlowDebugSessionCreateFuture struct { azure.Future } @@ -69775,8 +69829,11 @@ func (page DataFlowListResponsePage) Values() []DataFlowResource { } // Creates a new instance of the DataFlowListResponsePage type. -func NewDataFlowListResponsePage(getNextPage func(context.Context, DataFlowListResponse) (DataFlowListResponse, error)) DataFlowListResponsePage { - return DataFlowListResponsePage{fn: getNextPage} +func NewDataFlowListResponsePage(cur DataFlowListResponse, getNextPage func(context.Context, DataFlowListResponse) (DataFlowListResponse, error)) DataFlowListResponsePage { + return DataFlowListResponsePage{ + fn: getNextPage, + dflr: cur, + } } // DataFlowReference data flow reference type. @@ -71932,7 +71989,8 @@ func (ddc *DatasetDeflateCompression) UnmarshalJSON(body []byte) error { return nil } -// DatasetFolder the folder that this Dataset is in. If not specified, Dataset will appear at the root level. +// DatasetFolder the folder that this Dataset is in. If not specified, Dataset will appear at the root +// level. type DatasetFolder struct { // Name - The name of the folder that this Dataset is in. Name *string `json:"name,omitempty"` @@ -72201,8 +72259,11 @@ func (page DatasetListResponsePage) Values() []DatasetResource { } // Creates a new instance of the DatasetListResponsePage type. -func NewDatasetListResponsePage(getNextPage func(context.Context, DatasetListResponse) (DatasetListResponse, error)) DatasetListResponsePage { - return DatasetListResponsePage{fn: getNextPage} +func NewDatasetListResponsePage(cur DatasetListResponse, getNextPage func(context.Context, DatasetListResponse) (DatasetListResponse, error)) DatasetListResponsePage { + return DatasetListResponsePage{ + fn: getNextPage, + dlr: cur, + } } // BasicDatasetLocation dataset location. @@ -91844,14 +91905,20 @@ type ExecuteDataFlowActivityTypeProperties struct { IntegrationRuntime *IntegrationRuntimeReference `json:"integrationRuntime,omitempty"` // Compute - Compute properties for data flow activity. Compute *ExecuteDataFlowActivityTypePropertiesCompute `json:"compute,omitempty"` + // TraceLevel - Trace level setting used for data flow monitoring output. Supported values are: 'coarse', 'fine', and 'none'. Type: string (or Expression with resultType string) + TraceLevel interface{} `json:"traceLevel,omitempty"` + // ContinueOnError - Continue on error setting used for data flow execution. Enables processing to continue if a sink fails. Type: boolean (or Expression with resultType boolean) + ContinueOnError interface{} `json:"continueOnError,omitempty"` + // RunConcurrently - Concurrent run setting used for data flow execution. Allows sinks with the same save order to be processed concurrently. Type: boolean (or Expression with resultType boolean) + RunConcurrently interface{} `json:"runConcurrently,omitempty"` } // ExecuteDataFlowActivityTypePropertiesCompute compute properties for data flow activity. type ExecuteDataFlowActivityTypePropertiesCompute struct { - // ComputeType - Compute type of the cluster which will execute data flow job. Possible values include: 'General', 'MemoryOptimized', 'ComputeOptimized' - ComputeType DataFlowComputeType `json:"computeType,omitempty"` - // CoreCount - Core count of the cluster which will execute data flow job. Supported values are: 8, 16, 32, 48, 80, 144 and 272. - CoreCount *int32 `json:"coreCount,omitempty"` + // ComputeType - Compute type of the cluster which will execute data flow job. Possible values include: 'General', 'MemoryOptimized', 'ComputeOptimized'. Type: string (or Expression with resultType string) + ComputeType interface{} `json:"computeType,omitempty"` + // CoreCount - Core count of the cluster which will execute data flow job. Supported values are: 8, 16, 32, 48, 80, 144 and 272. Type: integer (or Expression with resultType integer) + CoreCount interface{} `json:"coreCount,omitempty"` } // ExecutePipelineActivity execute pipeline activity. @@ -93668,8 +93735,11 @@ func (page FactoryListResponsePage) Values() []Factory { } // Creates a new instance of the FactoryListResponsePage type. -func NewFactoryListResponsePage(getNextPage func(context.Context, FactoryListResponse) (FactoryListResponse, error)) FactoryListResponsePage { - return FactoryListResponsePage{fn: getNextPage} +func NewFactoryListResponsePage(cur FactoryListResponse, getNextPage func(context.Context, FactoryListResponse) (FactoryListResponse, error)) FactoryListResponsePage { + return FactoryListResponsePage{ + fn: getNextPage, + flr: cur, + } } // FactoryProperties factory resource properties. @@ -120809,8 +120879,9 @@ func (hs *HubspotSource) UnmarshalJSON(body []byte) error { return nil } -// IfConditionActivity this activity evaluates a boolean expression and executes either the activities under -// the ifTrueActivities property or the ifFalseActivities property depending on the result of the expression. +// IfConditionActivity this activity evaluates a boolean expression and executes either the activities +// under the ifTrueActivities property or the ifFalseActivities property depending on the result of the +// expression. type IfConditionActivity struct { // IfConditionActivityTypeProperties - IfCondition activity properties. *IfConditionActivityTypeProperties `json:"typeProperties,omitempty"` @@ -126206,8 +126277,8 @@ type IntegrationRuntimeListResponse struct { NextLink *string `json:"nextLink,omitempty"` } -// IntegrationRuntimeListResponseIterator provides access to a complete listing of IntegrationRuntimeResource -// values. +// IntegrationRuntimeListResponseIterator provides access to a complete listing of +// IntegrationRuntimeResource values. type IntegrationRuntimeListResponseIterator struct { i int page IntegrationRuntimeListResponsePage @@ -126350,8 +126421,11 @@ func (page IntegrationRuntimeListResponsePage) Values() []IntegrationRuntimeReso } // Creates a new instance of the IntegrationRuntimeListResponsePage type. -func NewIntegrationRuntimeListResponsePage(getNextPage func(context.Context, IntegrationRuntimeListResponse) (IntegrationRuntimeListResponse, error)) IntegrationRuntimeListResponsePage { - return IntegrationRuntimeListResponsePage{fn: getNextPage} +func NewIntegrationRuntimeListResponsePage(cur IntegrationRuntimeListResponse, getNextPage func(context.Context, IntegrationRuntimeListResponse) (IntegrationRuntimeListResponse, error)) IntegrationRuntimeListResponsePage { + return IntegrationRuntimeListResponsePage{ + fn: getNextPage, + irlr: cur, + } } // IntegrationRuntimeMonitoringData get monitoring data response. @@ -126500,8 +126574,8 @@ func (irnmd *IntegrationRuntimeNodeMonitoringData) UnmarshalJSON(body []byte) er return nil } -// IntegrationRuntimeObjectMetadataRefreshFuture an abstraction for monitoring and retrieving the results of a -// long-running operation. +// IntegrationRuntimeObjectMetadataRefreshFuture an abstraction for monitoring and retrieving the results +// of a long-running operation. type IntegrationRuntimeObjectMetadataRefreshFuture struct { azure.Future } @@ -126878,8 +126952,8 @@ func (irsp *IntegrationRuntimeSsisProperties) UnmarshalJSON(body []byte) error { return nil } -// IntegrationRuntimesStartFuture an abstraction for monitoring and retrieving the results of a long-running -// operation. +// IntegrationRuntimesStartFuture an abstraction for monitoring and retrieving the results of a +// long-running operation. type IntegrationRuntimesStartFuture struct { azure.Future } @@ -132830,8 +132904,11 @@ func (page LinkedServiceListResponsePage) Values() []LinkedServiceResource { } // Creates a new instance of the LinkedServiceListResponsePage type. -func NewLinkedServiceListResponsePage(getNextPage func(context.Context, LinkedServiceListResponse) (LinkedServiceListResponse, error)) LinkedServiceListResponsePage { - return LinkedServiceListResponsePage{fn: getNextPage} +func NewLinkedServiceListResponsePage(cur LinkedServiceListResponse, getNextPage func(context.Context, LinkedServiceListResponse) (LinkedServiceListResponse, error)) LinkedServiceListResponsePage { + return LinkedServiceListResponsePage{ + fn: getNextPage, + lslr: cur, + } } // LinkedServiceReference linked service reference type. @@ -132940,7 +133017,25 @@ func (lsr *LinkedServiceResource) UnmarshalJSON(body []byte) error { return nil } -// LogStorageSettings log storage settings. +// LogLocationSettings log location settings. +type LogLocationSettings struct { + // LinkedServiceName - Log storage linked service reference. + LinkedServiceName *LinkedServiceReference `json:"linkedServiceName,omitempty"` + // Path - The path to storage for storing detailed logs of activity execution. Type: string (or Expression with resultType string). + Path interface{} `json:"path,omitempty"` +} + +// LogSettings log settings. +type LogSettings struct { + // EnableCopyActivityLog - Specifies whether to enable copy activity log. Type: boolean (or Expression with resultType boolean). + EnableCopyActivityLog interface{} `json:"enableCopyActivityLog,omitempty"` + // CopyActivityLogSettings - Specifies settings for copy activity log. + CopyActivityLogSettings *CopyActivityLogSettings `json:"copyActivityLogSettings,omitempty"` + // LogLocationSettings - Log location settings customer needs to provide when enabling log. + LogLocationSettings *LogLocationSettings `json:"logLocationSettings,omitempty"` +} + +// LogStorageSettings (Deprecated. Please use LogSettings) Log storage settings. type LogStorageSettings struct { // AdditionalProperties - Unmatched properties from the message are deserialized this collection AdditionalProperties map[string]interface{} `json:""` @@ -135990,8 +136085,11 @@ func (page ManagedPrivateEndpointListResponsePage) Values() []ManagedPrivateEndp } // Creates a new instance of the ManagedPrivateEndpointListResponsePage type. -func NewManagedPrivateEndpointListResponsePage(getNextPage func(context.Context, ManagedPrivateEndpointListResponse) (ManagedPrivateEndpointListResponse, error)) ManagedPrivateEndpointListResponsePage { - return ManagedPrivateEndpointListResponsePage{fn: getNextPage} +func NewManagedPrivateEndpointListResponsePage(cur ManagedPrivateEndpointListResponse, getNextPage func(context.Context, ManagedPrivateEndpointListResponse) (ManagedPrivateEndpointListResponse, error)) ManagedPrivateEndpointListResponsePage { + return ManagedPrivateEndpointListResponsePage{ + fn: getNextPage, + mpelr: cur, + } } // ManagedPrivateEndpointResource managed private endpoint resource type. @@ -136235,8 +136333,11 @@ func (page ManagedVirtualNetworkListResponsePage) Values() []ManagedVirtualNetwo } // Creates a new instance of the ManagedVirtualNetworkListResponsePage type. -func NewManagedVirtualNetworkListResponsePage(getNextPage func(context.Context, ManagedVirtualNetworkListResponse) (ManagedVirtualNetworkListResponse, error)) ManagedVirtualNetworkListResponsePage { - return ManagedVirtualNetworkListResponsePage{fn: getNextPage} +func NewManagedVirtualNetworkListResponsePage(cur ManagedVirtualNetworkListResponse, getNextPage func(context.Context, ManagedVirtualNetworkListResponse) (ManagedVirtualNetworkListResponse, error)) ManagedVirtualNetworkListResponsePage { + return ManagedVirtualNetworkListResponsePage{ + fn: getNextPage, + mvnlr: cur, + } } // ManagedVirtualNetworkResource managed Virtual Network resource type. @@ -159260,8 +159361,11 @@ func (page OperationListResponsePage) Values() []Operation { } // Creates a new instance of the OperationListResponsePage type. -func NewOperationListResponsePage(getNextPage func(context.Context, OperationListResponse) (OperationListResponse, error)) OperationListResponsePage { - return OperationListResponsePage{fn: getNextPage} +func NewOperationListResponsePage(cur OperationListResponse, getNextPage func(context.Context, OperationListResponse) (OperationListResponse, error)) OperationListResponsePage { + return OperationListResponsePage{ + fn: getNextPage, + olr: cur, + } } // OperationLogSpecification details about an operation related to logs. @@ -171704,8 +171808,11 @@ func (page PipelineListResponsePage) Values() []PipelineResource { } // Creates a new instance of the PipelineListResponsePage type. -func NewPipelineListResponsePage(getNextPage func(context.Context, PipelineListResponse) (PipelineListResponse, error)) PipelineListResponsePage { - return PipelineListResponsePage{fn: getNextPage} +func NewPipelineListResponsePage(cur PipelineListResponse, getNextPage func(context.Context, PipelineListResponse) (PipelineListResponse, error)) PipelineListResponsePage { + return PipelineListResponsePage{ + fn: getNextPage, + plr: cur, + } } // PipelineReference pipeline reference type. @@ -176117,8 +176224,8 @@ type QueryDataFlowDebugSessionsResponse struct { NextLink *string `json:"nextLink,omitempty"` } -// QueryDataFlowDebugSessionsResponseIterator provides access to a complete listing of DataFlowDebugSessionInfo -// values. +// QueryDataFlowDebugSessionsResponseIterator provides access to a complete listing of +// DataFlowDebugSessionInfo values. type QueryDataFlowDebugSessionsResponseIterator struct { i int page QueryDataFlowDebugSessionsResponsePage @@ -176261,8 +176368,11 @@ func (page QueryDataFlowDebugSessionsResponsePage) Values() []DataFlowDebugSessi } // Creates a new instance of the QueryDataFlowDebugSessionsResponsePage type. -func NewQueryDataFlowDebugSessionsResponsePage(getNextPage func(context.Context, QueryDataFlowDebugSessionsResponse) (QueryDataFlowDebugSessionsResponse, error)) QueryDataFlowDebugSessionsResponsePage { - return QueryDataFlowDebugSessionsResponsePage{fn: getNextPage} +func NewQueryDataFlowDebugSessionsResponsePage(cur QueryDataFlowDebugSessionsResponse, getNextPage func(context.Context, QueryDataFlowDebugSessionsResponse) (QueryDataFlowDebugSessionsResponse, error)) QueryDataFlowDebugSessionsResponsePage { + return QueryDataFlowDebugSessionsResponsePage{ + fn: getNextPage, + qdfdsr: cur, + } } // QuickBooksLinkedService quickBooks server linked service. @@ -178525,8 +178635,8 @@ func (rirs *RedirectIncompatibleRowSettings) UnmarshalJSON(body []byte) error { } // RedshiftUnloadSettings the Amazon S3 settings needed for the interim Amazon S3 when copying from Amazon -// Redshift with unload. With this, data from Amazon Redshift source will be unloaded into S3 first and then -// copied into the targeted sink from the interim S3. +// Redshift with unload. With this, data from Amazon Redshift source will be unloaded into S3 first and +// then copied into the targeted sink from the interim S3. type RedshiftUnloadSettings struct { // S3LinkedServiceName - The name of the Amazon S3 linked service which will be used for the unload operation when copying from the Amazon Redshift source. S3LinkedServiceName *LinkedServiceReference `json:"s3LinkedServiceName,omitempty"` @@ -179791,8 +179901,8 @@ type RelationalTableDatasetTypeProperties struct { TableName interface{} `json:"tableName,omitempty"` } -// RerunTumblingWindowTrigger trigger that schedules pipeline reruns for all fixed time interval windows from a -// requested start time to requested end time. +// RerunTumblingWindowTrigger trigger that schedules pipeline reruns for all fixed time interval windows +// from a requested start time to requested end time. type RerunTumblingWindowTrigger struct { // RerunTumblingWindowTriggerTypeProperties - Rerun Trigger properties. *RerunTumblingWindowTriggerTypeProperties `json:"typeProperties,omitempty"` @@ -185848,7 +185958,8 @@ func (smcls *SalesforceMarketingCloudLinkedService) UnmarshalJSON(body []byte) e return nil } -// SalesforceMarketingCloudLinkedServiceTypeProperties salesforce Marketing Cloud linked service properties. +// SalesforceMarketingCloudLinkedServiceTypeProperties salesforce Marketing Cloud linked service +// properties. type SalesforceMarketingCloudLinkedServiceTypeProperties struct { // ConnectionProperties - Properties used to connect to Salesforce Marketing Cloud. It is mutually exclusive with any other properties in the linked service. Type: object. ConnectionProperties interface{} `json:"connectionProperties,omitempty"` @@ -194508,7 +194619,8 @@ func (scfcrd *SapCloudForCustomerResourceDataset) UnmarshalJSON(body []byte) err return nil } -// SapCloudForCustomerResourceDatasetTypeProperties sap Cloud For Customer OData resource dataset properties. +// SapCloudForCustomerResourceDatasetTypeProperties sap Cloud For Customer OData resource dataset +// properties. type SapCloudForCustomerResourceDatasetTypeProperties struct { // Path - The path of the SAP Cloud for Customer OData entity. Type: string (or Expression with resultType string). Path interface{} `json:"path,omitempty"` @@ -204207,8 +204319,8 @@ func (sb SecretBase) AsBasicSecretBase() (BasicSecretBase, bool) { return &sb, true } -// SecureString azure Data Factory secure string definition. The string value will be masked with asterisks '*' -// during Get or List API calls. +// SecureString azure Data Factory secure string definition. The string value will be masked with asterisks +// '*' during Get or List API calls. type SecureString struct { // Value - Value of secure string. Value *string `json:"value,omitempty"` @@ -226303,8 +226415,8 @@ type SubResourceDebugResource struct { Name *string `json:"name,omitempty"` } -// SwitchActivity this activity evaluates an expression and executes activities under the cases property that -// correspond to the expression evaluation expected in the equals property. +// SwitchActivity this activity evaluates an expression and executes activities under the cases property +// that correspond to the expression evaluation expected in the equals property. type SwitchActivity struct { // SwitchActivityTypeProperties - Switch activity properties. *SwitchActivityTypeProperties `json:"typeProperties,omitempty"` @@ -232757,8 +232869,11 @@ func (page TriggerListResponsePage) Values() []TriggerResource { } // Creates a new instance of the TriggerListResponsePage type. -func NewTriggerListResponsePage(getNextPage func(context.Context, TriggerListResponse) (TriggerListResponse, error)) TriggerListResponsePage { - return TriggerListResponsePage{fn: getNextPage} +func NewTriggerListResponsePage(cur TriggerListResponse, getNextPage func(context.Context, TriggerListResponse) (TriggerListResponse, error)) TriggerListResponsePage { + return TriggerListResponsePage{ + fn: getNextPage, + tlr: cur, + } } // TriggerPipelineReference pipeline that needs to be triggered with the given parameters. @@ -233040,7 +233155,8 @@ type TriggerRunsQueryResponse struct { ContinuationToken *string `json:"continuationToken,omitempty"` } -// TriggersStartFuture an abstraction for monitoring and retrieving the results of a long-running operation. +// TriggersStartFuture an abstraction for monitoring and retrieving the results of a long-running +// operation. type TriggersStartFuture struct { azure.Future } @@ -233084,8 +233200,8 @@ func (future *TriggersStopFuture) Result(client TriggersClient) (ar autorest.Res return } -// TriggersSubscribeToEventsFuture an abstraction for monitoring and retrieving the results of a long-running -// operation. +// TriggersSubscribeToEventsFuture an abstraction for monitoring and retrieving the results of a +// long-running operation. type TriggersSubscribeToEventsFuture struct { azure.Future } @@ -233151,8 +233267,8 @@ func (future *TriggersUnsubscribeFromEventsFuture) Result(client TriggersClient) return } -// TumblingWindowTrigger trigger that schedules pipeline runs for all fixed time interval windows from a start -// time without gaps and also supports backfill scenarios (when start time is in the past). +// TumblingWindowTrigger trigger that schedules pipeline runs for all fixed time interval windows from a +// start time without gaps and also supports backfill scenarios (when start time is in the past). type TumblingWindowTrigger struct { // Pipeline - Pipeline for which runs are created when an event is fired for trigger window that is ready. Pipeline *TriggerPipelineReference `json:"pipeline,omitempty"` @@ -233389,7 +233505,7 @@ func (twtdr TumblingWindowTriggerDependencyReference) AsBasicDependencyReference // TumblingWindowTriggerTypeProperties tumbling Window Trigger properties. type TumblingWindowTriggerTypeProperties struct { - // Frequency - The frequency of the time windows. Possible values include: 'TumblingWindowFrequencyMinute', 'TumblingWindowFrequencyHour' + // Frequency - The frequency of the time windows. Possible values include: 'TumblingWindowFrequencyMinute', 'TumblingWindowFrequencyHour', 'TumblingWindowFrequencyMonth' Frequency TumblingWindowFrequency `json:"frequency,omitempty"` // Interval - The interval of the time windows. The minimum interval allowed is 15 Minutes. Interval *int32 `json:"interval,omitempty"` @@ -233509,8 +233625,8 @@ type TypeConversionSettings struct { Culture interface{} `json:"culture,omitempty"` } -// UntilActivity this activity executes inner activities until the specified boolean expression results to true -// or timeout is reached, whichever is earlier. +// UntilActivity this activity executes inner activities until the specified boolean expression results to +// true or timeout is reached, whichever is earlier. type UntilActivity struct { // UntilActivityTypeProperties - Until activity properties. *UntilActivityTypeProperties `json:"typeProperties,omitempty"` @@ -236965,8 +237081,8 @@ type WebActivityTypeProperties struct { ConnectVia *IntegrationRuntimeReference `json:"connectVia,omitempty"` } -// WebAnonymousAuthentication a WebLinkedService that uses anonymous authentication to communicate with an HTTP -// endpoint. +// WebAnonymousAuthentication a WebLinkedService that uses anonymous authentication to communicate with an +// HTTP endpoint. type WebAnonymousAuthentication struct { // URL - The URL of the web service endpoint, e.g. http://www.microsoft.com . Type: string (or Expression with resultType string). URL interface{} `json:"url,omitempty"` @@ -237117,9 +237233,9 @@ func (wba *WebBasicAuthentication) UnmarshalJSON(body []byte) error { return nil } -// WebClientCertificateAuthentication a WebLinkedService that uses client certificate based authentication to -// communicate with an HTTP endpoint. This scheme follows mutual authentication; the server must also provide -// valid credentials to the client. +// WebClientCertificateAuthentication a WebLinkedService that uses client certificate based authentication +// to communicate with an HTTP endpoint. This scheme follows mutual authentication; the server must also +// provide valid credentials to the client. type WebClientCertificateAuthentication struct { // Pfx - Base64-encoded contents of a PFX file. Pfx BasicSecretBase `json:"pfx,omitempty"`