pipelines

README

github.com/hashicorp/go-azure-sdk/resource-manager/datafactory/2018-06-01/pipelines Documentation

The pipelines SDK allows for interaction with the Azure Resource Manager Service datafactory (API Version 2018-06-01).

This readme covers example usages, but further information on using this SDK can be found in the project root.

Import Path

import "github.com/hashicorp/go-azure-sdk/resource-manager/datafactory/2018-06-01/pipelines"

Client Initialization

client := pipelines.NewPipelinesClientWithBaseURI("https://management.azure.com")
client.Client.Authorizer = authorizer

Example Usage: PipelinesClient.CreateOrUpdate

ctx := context.TODO()
id := pipelines.NewPipelineID("12345678-1234-9876-4563-123456789012", "example-resource-group", "factoryValue", "pipelineValue")

payload := pipelines.PipelineResource{
	// ...
}


read, err := client.CreateOrUpdate(ctx, id, payload, pipelines.DefaultCreateOrUpdateOperationOptions())
if err != nil {
	// handle the error
}
if model := read.Model; model != nil {
	// do something with the model/response object
}

Example Usage: PipelinesClient.CreateRun

ctx := context.TODO()
id := pipelines.NewPipelineID("12345678-1234-9876-4563-123456789012", "example-resource-group", "factoryValue", "pipelineValue")
var payload map[string]interface{}

read, err := client.CreateRun(ctx, id, payload, pipelines.DefaultCreateRunOperationOptions())
if err != nil {
	// handle the error
}
if model := read.Model; model != nil {
	// do something with the model/response object
}

Example Usage: PipelinesClient.Delete

ctx := context.TODO()
id := pipelines.NewPipelineID("12345678-1234-9876-4563-123456789012", "example-resource-group", "factoryValue", "pipelineValue")

read, err := client.Delete(ctx, id)
if err != nil {
	// handle the error
}
if model := read.Model; model != nil {
	// do something with the model/response object
}

Example Usage: PipelinesClient.Get

ctx := context.TODO()
id := pipelines.NewPipelineID("12345678-1234-9876-4563-123456789012", "example-resource-group", "factoryValue", "pipelineValue")

read, err := client.Get(ctx, id, pipelines.DefaultGetOperationOptions())
if err != nil {
	// handle the error
}
if model := read.Model; model != nil {
	// do something with the model/response object
}

Example Usage: PipelinesClient.ListByFactory

ctx := context.TODO()
id := pipelines.NewFactoryID("12345678-1234-9876-4563-123456789012", "example-resource-group", "factoryValue")

// alternatively `client.ListByFactory(ctx, id)` can be used to do batched pagination
items, err := client.ListByFactoryComplete(ctx, id)
if err != nil {
	// handle the error
}
for _, item := range items {
	// do something
}

Documentation

Index

• func PossibleValuesForActivityOnInactiveMarkAs() []string
• func PossibleValuesForActivityState() []string
• func PossibleValuesForAzureFunctionActivityMethod() []string
• func PossibleValuesForAzureSearchIndexWriteBehaviorType() []string
• func PossibleValuesForBigDataPoolReferenceType() []string
• func PossibleValuesForCassandraSourceReadConsistencyLevels() []string
• func PossibleValuesForConfigurationType() []string
• func PossibleValuesForCredentialReferenceType() []string
• func PossibleValuesForDataFlowReferenceType() []string
• func PossibleValuesForDatasetReferenceType() []string
• func PossibleValuesForDependencyCondition() []string
• func PossibleValuesForDynamicsSinkWriteBehavior() []string
• func PossibleValuesForExpressionType() []string
• func PossibleValuesForExpressionV2Type() []string
• func PossibleValuesForHDInsightActivityDebugInfoOption() []string
• func PossibleValuesForIntegrationRuntimeReferenceType() []string
• func PossibleValuesForNotebookParameterType() []string
• func PossibleValuesForNotebookReferenceType() []string
• func PossibleValuesForParameterType() []string
• func PossibleValuesForPipelineReferenceType() []string
• func PossibleValuesForPolybaseSettingsRejectType() []string
• func PossibleValuesForSalesforceSinkWriteBehavior() []string
• func PossibleValuesForSalesforceV2SinkWriteBehavior() []string
• func PossibleValuesForSapCloudForCustomerSinkWriteBehavior() []string
• func PossibleValuesForScriptActivityLogDestination() []string
• func PossibleValuesForScriptActivityParameterDirection() []string
• func PossibleValuesForScriptActivityParameterType() []string
• func PossibleValuesForScriptType() []string
• func PossibleValuesForSparkConfigurationReferenceType() []string
• func PossibleValuesForSparkJobReferenceType() []string
• func PossibleValuesForSsisLogLocationType() []string
• func PossibleValuesForSsisPackageLocationType() []string
• func PossibleValuesForType() []string
• func PossibleValuesForVariableType() []string
• func PossibleValuesForWebActivityMethod() []string
• func PossibleValuesForWebHookActivityMethod() []string
• func ValidateFactoryID(input interface{}, key string) (warnings []string, errors []error)
• func ValidatePipelineID(input interface{}, key string) (warnings []string, errors []error)
• type Activity
• type ActivityDependency
• type ActivityOnInactiveMarkAs
  • func (s *ActivityOnInactiveMarkAs) UnmarshalJSON(bytes []byte) error
• type ActivityPolicy
• type ActivityState
  • func (s *ActivityState) UnmarshalJSON(bytes []byte) error
• type AmazonMWSSource
• type AmazonRdsForOraclePartitionSettings
• type AmazonRdsForOracleSource
• type AmazonRdsForSqlServerSource
• type AmazonRedshiftSource
• type AmazonS3CompatibleReadSettings
• type AmazonS3ReadSettings
• type AppendVariableActivity
  • func (s AppendVariableActivity) MarshalJSON() ([]byte, error)
• type AppendVariableActivityTypeProperties
• type AvroSink
  • func (s *AvroSink) UnmarshalJSON(bytes []byte) error
• type AvroSource
  • func (s *AvroSource) UnmarshalJSON(bytes []byte) error
• type AvroWriteSettings
• type AzureBlobFSReadSettings
• type AzureBlobFSSink
• type AzureBlobFSSource
• type AzureBlobFSWriteSettings
• type AzureBlobStorageReadSettings
• type AzureBlobStorageWriteSettings
• type AzureDataExplorerCommandActivity
  • func (s AzureDataExplorerCommandActivity) MarshalJSON() ([]byte, error)
• type AzureDataExplorerCommandActivityTypeProperties
• type AzureDataExplorerSink
• type AzureDataExplorerSource
• type AzureDataLakeStoreReadSettings
• type AzureDataLakeStoreSink
• type AzureDataLakeStoreSource
• type AzureDataLakeStoreWriteSettings
• type AzureDatabricksDeltaLakeExportCommand
• type AzureDatabricksDeltaLakeImportCommand
• type AzureDatabricksDeltaLakeSink
• type AzureDatabricksDeltaLakeSource
• type AzureFileStorageReadSettings
• type AzureFileStorageWriteSettings
• type AzureFunctionActivity
  • func (s AzureFunctionActivity) MarshalJSON() ([]byte, error)
• type AzureFunctionActivityMethod
  • func (s *AzureFunctionActivityMethod) UnmarshalJSON(bytes []byte) error
• type AzureFunctionActivityTypeProperties
• type AzureMLBatchExecutionActivity
  • func (s AzureMLBatchExecutionActivity) MarshalJSON() ([]byte, error)
• type AzureMLBatchExecutionActivityTypeProperties
• type AzureMLExecutePipelineActivity
  • func (s AzureMLExecutePipelineActivity) MarshalJSON() ([]byte, error)
• type AzureMLExecutePipelineActivityTypeProperties
• type AzureMLUpdateResourceActivity
  • func (s AzureMLUpdateResourceActivity) MarshalJSON() ([]byte, error)
• type AzureMLUpdateResourceActivityTypeProperties
• type AzureMLWebServiceFile
• type AzureMariaDBSource
• type AzureMySqlSink
• type AzureMySqlSource
• type AzurePostgreSqlSink
• type AzurePostgreSqlSource
• type AzureQueueSink
• type AzureSearchIndexSink
• type AzureSearchIndexWriteBehaviorType
  • func (s *AzureSearchIndexWriteBehaviorType) UnmarshalJSON(bytes []byte) error
• type AzureSqlSink
• type AzureSqlSource
• type AzureTableSink
• type AzureTableSource
• type BigDataPoolParametrizationReference
• type BigDataPoolReferenceType
  • func (s *BigDataPoolReferenceType) UnmarshalJSON(bytes []byte) error
• type BinaryReadSettings
  • func (s *BinaryReadSettings) UnmarshalJSON(bytes []byte) error
• type BinarySink
  • func (s *BinarySink) UnmarshalJSON(bytes []byte) error
• type BinarySource
  • func (s *BinarySource) UnmarshalJSON(bytes []byte) error
• type BlobSink
• type BlobSource
• type CassandraSource
• type CassandraSourceReadConsistencyLevels
  • func (s *CassandraSourceReadConsistencyLevels) UnmarshalJSON(bytes []byte) error
• type CommonDataServiceForAppsSink
• type CommonDataServiceForAppsSource
• type CompressionReadSettings
• type ConcurSource
• type ConfigurationType
  • func (s *ConfigurationType) UnmarshalJSON(bytes []byte) error
• type ControlActivity
  • func (s ControlActivity) MarshalJSON() ([]byte, error)
• type CopyActivity
  • func (s CopyActivity) MarshalJSON() ([]byte, error)
• type CopyActivityLogSettings
• type CopyActivityTypeProperties
  • func (s *CopyActivityTypeProperties) UnmarshalJSON(bytes []byte) error
• type CopySink
• type CopySource
• type CosmosDbMongoDbApiSink
• type CosmosDbMongoDbApiSource
• type CosmosDbSqlApiSink
• type CosmosDbSqlApiSource
• type CouchbaseSource
• type CreateOrUpdateOperationOptions
  • func DefaultCreateOrUpdateOperationOptions() CreateOrUpdateOperationOptions
  • func (o CreateOrUpdateOperationOptions) ToHeaders() *client.Headers
  • func (o CreateOrUpdateOperationOptions) ToOData() *odata.Query
  • func (o CreateOrUpdateOperationOptions) ToQuery() *client.QueryParams
• type CreateOrUpdateOperationResponse
• type CreateRunOperationOptions
  • func DefaultCreateRunOperationOptions() CreateRunOperationOptions
  • func (o CreateRunOperationOptions) ToHeaders() *client.Headers
  • func (o CreateRunOperationOptions) ToOData() *odata.Query
  • func (o CreateRunOperationOptions) ToQuery() *client.QueryParams
• type CreateRunOperationResponse
• type CreateRunResponse
• type CredentialReference
• type CredentialReferenceType
  • func (s *CredentialReferenceType) UnmarshalJSON(bytes []byte) error
• type CustomActivity
  • func (s CustomActivity) MarshalJSON() ([]byte, error)
• type CustomActivityReferenceObject
• type CustomActivityTypeProperties
• type DWCopyCommandDefaultValue
• type DWCopyCommandSettings
• type DataFlowReference
• type DataFlowReferenceType
  • func (s *DataFlowReferenceType) UnmarshalJSON(bytes []byte) error
• type DataFlowStagingInfo
• type DataLakeAnalyticsUSQLActivity
  • func (s DataLakeAnalyticsUSQLActivity) MarshalJSON() ([]byte, error)
• type DataLakeAnalyticsUSQLActivityTypeProperties
• type DatabricksNotebookActivity
  • func (s DatabricksNotebookActivity) MarshalJSON() ([]byte, error)
• type DatabricksNotebookActivityTypeProperties
• type DatabricksSparkJarActivity
  • func (s DatabricksSparkJarActivity) MarshalJSON() ([]byte, error)
• type DatabricksSparkJarActivityTypeProperties
• type DatabricksSparkPythonActivity
  • func (s DatabricksSparkPythonActivity) MarshalJSON() ([]byte, error)
• type DatabricksSparkPythonActivityTypeProperties
• type DatasetReference
• type DatasetReferenceType
  • func (s *DatasetReferenceType) UnmarshalJSON(bytes []byte) error
• type Db2Source
• type DeleteActivity
  • func (s DeleteActivity) MarshalJSON() ([]byte, error)
• type DeleteActivityTypeProperties
  • func (s *DeleteActivityTypeProperties) UnmarshalJSON(bytes []byte) error
• type DeleteOperationResponse
• type DelimitedTextReadSettings
  • func (s *DelimitedTextReadSettings) UnmarshalJSON(bytes []byte) error
• type DelimitedTextSink
  • func (s *DelimitedTextSink) UnmarshalJSON(bytes []byte) error
• type DelimitedTextSource
  • func (s *DelimitedTextSource) UnmarshalJSON(bytes []byte) error
• type DelimitedTextWriteSettings
• type DependencyCondition
  • func (s *DependencyCondition) UnmarshalJSON(bytes []byte) error
• type DistcpSettings
• type DocumentDbCollectionSink
• type DocumentDbCollectionSource
• type DrillSource
• type DynamicsAXSource
• type DynamicsCrmSink
• type DynamicsCrmSource
• type DynamicsSink
• type DynamicsSinkWriteBehavior
  • func (s *DynamicsSinkWriteBehavior) UnmarshalJSON(bytes []byte) error
• type DynamicsSource
• type EloquaSource
• type ExcelSource
  • func (s *ExcelSource) UnmarshalJSON(bytes []byte) error
• type ExecuteDataFlowActivity
  • func (s ExecuteDataFlowActivity) MarshalJSON() ([]byte, error)
• type ExecuteDataFlowActivityTypeProperties
• type ExecuteDataFlowActivityTypePropertiesCompute
• type ExecutePipelineActivity
  • func (s ExecutePipelineActivity) MarshalJSON() ([]byte, error)
• type ExecutePipelineActivityPolicy
• type ExecutePipelineActivityTypeProperties
• type ExecutePowerQueryActivityTypeProperties
• type ExecuteSSISPackageActivity
  • func (s ExecuteSSISPackageActivity) MarshalJSON() ([]byte, error)
• type ExecuteSSISPackageActivityTypeProperties
• type ExecuteWranglingDataflowActivity
  • func (s ExecuteWranglingDataflowActivity) MarshalJSON() ([]byte, error)
• type ExecutionActivity
  • func (s ExecutionActivity) MarshalJSON() ([]byte, error)
• type Expression
• type ExpressionType
  • func (s *ExpressionType) UnmarshalJSON(bytes []byte) error
• type ExpressionV2
• type ExpressionV2Type
  • func (s *ExpressionV2Type) UnmarshalJSON(bytes []byte) error
• type FactoryId
  • func NewFactoryID(subscriptionId string, resourceGroupName string, factoryName string) FactoryId
  • func ParseFactoryID(input string) (*FactoryId, error)
  • func ParseFactoryIDInsensitively(input string) (*FactoryId, error)
  • func (id *FactoryId) FromParseResult(input resourceids.ParseResult) error
  • func (id FactoryId) ID() string
  • func (id FactoryId) Segments() []resourceids.Segment
  • func (id FactoryId) String() string
• type FailActivity
  • func (s FailActivity) MarshalJSON() ([]byte, error)
• type FailActivityTypeProperties
• type FileServerReadSettings
• type FileServerWriteSettings
• type FileSystemSink
• type FileSystemSource
• type FilterActivity
  • func (s FilterActivity) MarshalJSON() ([]byte, error)
• type FilterActivityTypeProperties
• type ForEachActivity
  • func (s ForEachActivity) MarshalJSON() ([]byte, error)
• type ForEachActivityTypeProperties
  • func (s *ForEachActivityTypeProperties) UnmarshalJSON(bytes []byte) error
• type FormatReadSettings
• type FtpReadSettings
• type GetMetadataActivity
  • func (s GetMetadataActivity) MarshalJSON() ([]byte, error)
• type GetMetadataActivityTypeProperties
  • func (s *GetMetadataActivityTypeProperties) UnmarshalJSON(bytes []byte) error
• type GetOperationOptions
  • func DefaultGetOperationOptions() GetOperationOptions
  • func (o GetOperationOptions) ToHeaders() *client.Headers
  • func (o GetOperationOptions) ToOData() *odata.Query
  • func (o GetOperationOptions) ToQuery() *client.QueryParams
• type GetOperationResponse
• type GoogleAdWordsSource
• type GoogleBigQuerySource
• type GoogleBigQueryV2Source
• type GoogleCloudStorageReadSettings
• type GreenplumSource
• type HBaseSource
• type HDInsightActivityDebugInfoOption
  • func (s *HDInsightActivityDebugInfoOption) UnmarshalJSON(bytes []byte) error
• type HDInsightHiveActivity
  • func (s HDInsightHiveActivity) MarshalJSON() ([]byte, error)
• type HDInsightHiveActivityTypeProperties
• type HDInsightMapReduceActivity
  • func (s HDInsightMapReduceActivity) MarshalJSON() ([]byte, error)
• type HDInsightMapReduceActivityTypeProperties
• type HDInsightPigActivity
  • func (s HDInsightPigActivity) MarshalJSON() ([]byte, error)
• type HDInsightPigActivityTypeProperties
• type HDInsightSparkActivity
  • func (s HDInsightSparkActivity) MarshalJSON() ([]byte, error)
• type HDInsightSparkActivityTypeProperties
• type HDInsightStreamingActivity
  • func (s HDInsightStreamingActivity) MarshalJSON() ([]byte, error)
• type HDInsightStreamingActivityTypeProperties
• type HTTPReadSettings
• type HTTPSource
• type HdfsReadSettings
• type HdfsSource
• type HiveSource
• type HubspotSource
• type IfConditionActivity
  • func (s IfConditionActivity) MarshalJSON() ([]byte, error)
• type IfConditionActivityTypeProperties
  • func (s *IfConditionActivityTypeProperties) UnmarshalJSON(bytes []byte) error
• type ImpalaSource
• type InformixSink
• type InformixSource
• type IntegrationRuntimeReference
• type IntegrationRuntimeReferenceType
  • func (s *IntegrationRuntimeReferenceType) UnmarshalJSON(bytes []byte) error
• type JiraSource
• type JsonReadSettings
  • func (s *JsonReadSettings) UnmarshalJSON(bytes []byte) error
• type JsonSink
  • func (s *JsonSink) UnmarshalJSON(bytes []byte) error
• type JsonSource
  • func (s *JsonSource) UnmarshalJSON(bytes []byte) error
• type JsonWriteSettings
• type LakeHouseReadSettings
• type LakeHouseTableSink
• type LakeHouseTableSource
• type LakeHouseWriteSettings
• type LinkedServiceReference
• type ListByFactoryCompleteResult
• type ListByFactoryOperationResponse
• type LogLocationSettings
• type LogSettings
• type LogStorageSettings
• type LookupActivity
  • func (s LookupActivity) MarshalJSON() ([]byte, error)
• type LookupActivityTypeProperties
  • func (s *LookupActivityTypeProperties) UnmarshalJSON(bytes []byte) error
• type MagentoSource
• type MariaDBSource
• type MarketoSource
• type MetadataItem
• type MicrosoftAccessSink
• type MicrosoftAccessSource
• type MongoDbAtlasSink
• type MongoDbAtlasSource
• type MongoDbCursorMethodsProperties
• type MongoDbSource
• type MongoDbV2Sink
• type MongoDbV2Source
• type MySqlSource
• type NetezzaPartitionSettings
• type NetezzaSource
• type NotebookParameter
• type NotebookParameterType
  • func (s *NotebookParameterType) UnmarshalJSON(bytes []byte) error
• type NotebookReferenceType
  • func (s *NotebookReferenceType) UnmarshalJSON(bytes []byte) error
• type ODataSource
• type OdbcSink
• type OdbcSource
• type Office365Source
• type OracleCloudStorageReadSettings
• type OraclePartitionSettings
• type OracleServiceCloudSource
• type OracleSink
• type OracleSource
• type OrcSink
  • func (s *OrcSink) UnmarshalJSON(bytes []byte) error
• type OrcSource
  • func (s *OrcSource) UnmarshalJSON(bytes []byte) error
• type OrcWriteSettings
• type ParameterSpecification
• type ParameterType
  • func (s *ParameterType) UnmarshalJSON(bytes []byte) error
• type ParquetReadSettings
  • func (s *ParquetReadSettings) UnmarshalJSON(bytes []byte) error
• type ParquetSink
  • func (s *ParquetSink) UnmarshalJSON(bytes []byte) error
• type ParquetSource
  • func (s *ParquetSource) UnmarshalJSON(bytes []byte) error
• type ParquetWriteSettings
• type PaypalSource
• type PhoenixSource
• type Pipeline
  • func (s *Pipeline) UnmarshalJSON(bytes []byte) error
• type PipelineElapsedTimeMetricPolicy
• type PipelineFolder
• type PipelineId
  • func NewPipelineID(subscriptionId string, resourceGroupName string, factoryName string, ...) PipelineId
  • func ParsePipelineID(input string) (*PipelineId, error)
  • func ParsePipelineIDInsensitively(input string) (*PipelineId, error)
  • func (id *PipelineId) FromParseResult(input resourceids.ParseResult) error
  • func (id PipelineId) ID() string
  • func (id PipelineId) Segments() []resourceids.Segment
  • func (id PipelineId) String() string
• type PipelinePolicy
• type PipelineReference
• type PipelineReferenceType
  • func (s *PipelineReferenceType) UnmarshalJSON(bytes []byte) error
• type PipelineResource
• type PipelineResourceOperationPredicate
  • func (p PipelineResourceOperationPredicate) Matches(input PipelineResource) bool
• type PipelinesClient
  • func NewPipelinesClientWithBaseURI(sdkApi sdkEnv.Api) (*PipelinesClient, error)
  • func (c PipelinesClient) CreateOrUpdate(ctx context.Context, id PipelineId, input PipelineResource, ...) (result CreateOrUpdateOperationResponse, err error)
  • func (c PipelinesClient) CreateRun(ctx context.Context, id PipelineId, input map[string]interface{}, ...) (result CreateRunOperationResponse, err error)
  • func (c PipelinesClient) Delete(ctx context.Context, id PipelineId) (result DeleteOperationResponse, err error)
  • func (c PipelinesClient) Get(ctx context.Context, id PipelineId, options GetOperationOptions) (result GetOperationResponse, err error)
  • func (c PipelinesClient) ListByFactory(ctx context.Context, id FactoryId) (result ListByFactoryOperationResponse, err error)
  • func (c PipelinesClient) ListByFactoryComplete(ctx context.Context, id FactoryId) (ListByFactoryCompleteResult, error)
  • func (c PipelinesClient) ListByFactoryCompleteMatchingPredicate(ctx context.Context, id FactoryId, ...) (result ListByFactoryCompleteResult, err error)
• type PolybaseSettings
• type PolybaseSettingsRejectType
  • func (s *PolybaseSettingsRejectType) UnmarshalJSON(bytes []byte) error
• type PostgreSqlSource
• type PostgreSqlV2Source
• type PowerQuerySink
• type PowerQuerySinkMapping
• type PrestoSource
• type QuickBooksSource
• type RawActivityImpl
• type RawCompressionReadSettingsImpl
• type RawCopySinkImpl
• type RawCopySourceImpl
• type RawFormatReadSettingsImpl
• type RawSecretBaseImpl
• type RawStoreReadSettingsImpl
• type RawStoreWriteSettingsImpl
• type RedirectIncompatibleRowSettings
• type RedshiftUnloadSettings
• type RelationalSource
• type ResponsysSource
• type RestSink
• type RestSource
• type SSISAccessCredential
  • func (s *SSISAccessCredential) UnmarshalJSON(bytes []byte) error
• type SSISChildPackage
• type SSISExecutionCredential
• type SSISExecutionParameter
• type SSISLogLocation
• type SSISLogLocationTypeProperties
• type SSISPackageLocation
• type SSISPackageLocationTypeProperties
  • func (s *SSISPackageLocationTypeProperties) UnmarshalJSON(bytes []byte) error
• type SSISPropertyOverride
• type SalesforceMarketingCloudSource
• type SalesforceServiceCloudSink
• type SalesforceServiceCloudSource
• type SalesforceServiceCloudV2Sink
• type SalesforceServiceCloudV2Source
• type SalesforceSink
• type SalesforceSinkWriteBehavior
  • func (s *SalesforceSinkWriteBehavior) UnmarshalJSON(bytes []byte) error
• type SalesforceSource
• type SalesforceV2Sink
• type SalesforceV2SinkWriteBehavior
  • func (s *SalesforceV2SinkWriteBehavior) UnmarshalJSON(bytes []byte) error
• type SalesforceV2Source
• type SapBwSource
• type SapCloudForCustomerSink
• type SapCloudForCustomerSinkWriteBehavior
  • func (s *SapCloudForCustomerSinkWriteBehavior) UnmarshalJSON(bytes []byte) error
• type SapCloudForCustomerSource
• type SapEccSource
• type SapHanaPartitionSettings
• type SapHanaSource
• type SapOdpSource
• type SapOpenHubSource
• type SapTablePartitionSettings
• type SapTableSource
• type ScriptActivity
  • func (s ScriptActivity) MarshalJSON() ([]byte, error)
• type ScriptActivityLogDestination
  • func (s *ScriptActivityLogDestination) UnmarshalJSON(bytes []byte) error
• type ScriptActivityParameter
• type ScriptActivityParameterDirection
  • func (s *ScriptActivityParameterDirection) UnmarshalJSON(bytes []byte) error
• type ScriptActivityParameterType
  • func (s *ScriptActivityParameterType) UnmarshalJSON(bytes []byte) error
• type ScriptActivityScriptBlock
• type ScriptActivityTypeProperties
• type ScriptActivityTypePropertiesLogSettings
• type ScriptType
  • func (s *ScriptType) UnmarshalJSON(bytes []byte) error
• type SecretBase
• type SecureInputOutputPolicy
• type SecureString
  • func (s SecureString) MarshalJSON() ([]byte, error)
• type ServiceNowSource
• type ServiceNowV2Source
• type SetVariableActivity
  • func (s SetVariableActivity) MarshalJSON() ([]byte, error)
• type SetVariableActivityTypeProperties
• type SftpReadSettings
• type SftpWriteSettings
• type SharePointOnlineListSource
• type ShopifySource
• type SkipErrorFile
• type SnowflakeExportCopyCommand
• type SnowflakeImportCopyCommand
• type SnowflakeSink
• type SnowflakeSource
• type SnowflakeV2Sink
• type SnowflakeV2Source
• type SparkConfigurationParametrizationReference
• type SparkConfigurationReferenceType
  • func (s *SparkConfigurationReferenceType) UnmarshalJSON(bytes []byte) error
• type SparkJobReferenceType
  • func (s *SparkJobReferenceType) UnmarshalJSON(bytes []byte) error
• type SparkSource
• type SqlDWSink
• type SqlDWSource
• type SqlDWUpsertSettings
• type SqlMISink
• type SqlMISource
• type SqlPartitionSettings
• type SqlServerSink
• type SqlServerSource
• type SqlServerStoredProcedureActivity
  • func (s SqlServerStoredProcedureActivity) MarshalJSON() ([]byte, error)
• type SqlServerStoredProcedureActivityTypeProperties
• type SqlSink
• type SqlSource
• type SqlUpsertSettings
• type SquareSource
• type SsisLogLocationType
  • func (s *SsisLogLocationType) UnmarshalJSON(bytes []byte) error
• type SsisPackageLocationType
  • func (s *SsisPackageLocationType) UnmarshalJSON(bytes []byte) error
• type StagingSettings
• type StoreReadSettings
• type StoreWriteSettings
• type SwitchActivity
  • func (s SwitchActivity) MarshalJSON() ([]byte, error)
• type SwitchActivityTypeProperties
  • func (s *SwitchActivityTypeProperties) UnmarshalJSON(bytes []byte) error
• type SwitchCase
  • func (s *SwitchCase) UnmarshalJSON(bytes []byte) error
• type SybaseSource
• type SynapseNotebookActivity
  • func (s SynapseNotebookActivity) MarshalJSON() ([]byte, error)
• type SynapseNotebookActivityTypeProperties
• type SynapseNotebookReference
• type SynapseSparkJobActivityTypeProperties
• type SynapseSparkJobDefinitionActivity
  • func (s SynapseSparkJobDefinitionActivity) MarshalJSON() ([]byte, error)
• type SynapseSparkJobReference
• type TabularSource
• type TarGZipReadSettings
• type TarReadSettings
• type TeradataPartitionSettings
• type TeradataSource
• type Type
  • func (s *Type) UnmarshalJSON(bytes []byte) error
• type UntilActivity
  • func (s UntilActivity) MarshalJSON() ([]byte, error)
• type UntilActivityTypeProperties
  • func (s *UntilActivityTypeProperties) UnmarshalJSON(bytes []byte) error
• type UserProperty
• type ValidationActivity
  • func (s ValidationActivity) MarshalJSON() ([]byte, error)
• type ValidationActivityTypeProperties
• type VariableSpecification
• type VariableType
  • func (s *VariableType) UnmarshalJSON(bytes []byte) error
• type VerticaSource
• type WaitActivity
  • func (s WaitActivity) MarshalJSON() ([]byte, error)
• type WaitActivityTypeProperties
• type WarehouseSink
• type WarehouseSource
• type WebActivity
  • func (s WebActivity) MarshalJSON() ([]byte, error)
• type WebActivityAuthentication
  • func (s *WebActivityAuthentication) UnmarshalJSON(bytes []byte) error
• type WebActivityMethod
  • func (s *WebActivityMethod) UnmarshalJSON(bytes []byte) error
• type WebActivityTypeProperties
• type WebHookActivity
  • func (s WebHookActivity) MarshalJSON() ([]byte, error)
• type WebHookActivityMethod
  • func (s *WebHookActivityMethod) UnmarshalJSON(bytes []byte) error
• type WebHookActivityTypeProperties
• type WebSource
• type XeroSource
• type XmlReadSettings
  • func (s *XmlReadSettings) UnmarshalJSON(bytes []byte) error
• type XmlSource
  • func (s *XmlSource) UnmarshalJSON(bytes []byte) error
• type ZipDeflateReadSettings
• type ZohoSource

Functions

func PossibleValuesForActivityOnInactiveMarkAs

func PossibleValuesForActivityOnInactiveMarkAs() []string

func PossibleValuesForActivityState

func PossibleValuesForActivityState() []string

func PossibleValuesForAzureFunctionActivityMethod

func PossibleValuesForAzureFunctionActivityMethod() []string

func PossibleValuesForAzureSearchIndexWriteBehaviorType

func PossibleValuesForAzureSearchIndexWriteBehaviorType() []string

func PossibleValuesForBigDataPoolReferenceType

func PossibleValuesForBigDataPoolReferenceType() []string

func PossibleValuesForCassandraSourceReadConsistencyLevels

func PossibleValuesForCassandraSourceReadConsistencyLevels() []string

func PossibleValuesForConfigurationType

func PossibleValuesForConfigurationType() []string

func PossibleValuesForCredentialReferenceType

func PossibleValuesForCredentialReferenceType() []string

func PossibleValuesForDataFlowReferenceType

func PossibleValuesForDataFlowReferenceType() []string

func PossibleValuesForDatasetReferenceType

func PossibleValuesForDatasetReferenceType() []string

func PossibleValuesForDependencyCondition

func PossibleValuesForDependencyCondition() []string

func PossibleValuesForDynamicsSinkWriteBehavior

func PossibleValuesForDynamicsSinkWriteBehavior() []string

func PossibleValuesForExpressionType

func PossibleValuesForExpressionType() []string

func PossibleValuesForExpressionV2Type

func PossibleValuesForExpressionV2Type() []string

func PossibleValuesForHDInsightActivityDebugInfoOption

func PossibleValuesForHDInsightActivityDebugInfoOption() []string

func PossibleValuesForIntegrationRuntimeReferenceType

func PossibleValuesForIntegrationRuntimeReferenceType() []string

func PossibleValuesForNotebookParameterType

func PossibleValuesForNotebookParameterType() []string

func PossibleValuesForNotebookReferenceType

func PossibleValuesForNotebookReferenceType() []string

func PossibleValuesForParameterType

func PossibleValuesForParameterType() []string

func PossibleValuesForPipelineReferenceType

func PossibleValuesForPipelineReferenceType() []string

func PossibleValuesForPolybaseSettingsRejectType

func PossibleValuesForPolybaseSettingsRejectType() []string

func PossibleValuesForSalesforceSinkWriteBehavior

func PossibleValuesForSalesforceSinkWriteBehavior() []string

func PossibleValuesForSalesforceV2SinkWriteBehavior

func PossibleValuesForSalesforceV2SinkWriteBehavior() []string

func PossibleValuesForSapCloudForCustomerSinkWriteBehavior

func PossibleValuesForSapCloudForCustomerSinkWriteBehavior() []string

func PossibleValuesForScriptActivityLogDestination

func PossibleValuesForScriptActivityLogDestination() []string

func PossibleValuesForScriptActivityParameterDirection

func PossibleValuesForScriptActivityParameterDirection() []string

func PossibleValuesForScriptActivityParameterType

func PossibleValuesForScriptActivityParameterType() []string

func PossibleValuesForScriptType

func PossibleValuesForScriptType() []string

func PossibleValuesForSparkConfigurationReferenceType

func PossibleValuesForSparkConfigurationReferenceType() []string

func PossibleValuesForSparkJobReferenceType

func PossibleValuesForSparkJobReferenceType() []string

func PossibleValuesForSsisLogLocationType

func PossibleValuesForSsisLogLocationType() []string

func PossibleValuesForSsisPackageLocationType

func PossibleValuesForSsisPackageLocationType() []string

func PossibleValuesForType

func PossibleValuesForType() []string

func PossibleValuesForVariableType

func PossibleValuesForVariableType() []string

func PossibleValuesForWebActivityMethod

func PossibleValuesForWebActivityMethod() []string

func PossibleValuesForWebHookActivityMethod

func PossibleValuesForWebHookActivityMethod() []string

func ValidateFactoryID

func ValidateFactoryID(input interface{}, key string) (warnings []string, errors []error)

ValidateFactoryID checks that 'input' can be parsed as a Factory ID

func ValidatePipelineID

func ValidatePipelineID(input interface{}, key string) (warnings []string, errors []error)

ValidatePipelineID checks that 'input' can be parsed as a Pipeline ID

Types

type Activity

type Activity interface {
}

type ActivityDependency

type ActivityDependency struct {
	Activity             string                `json:"activity"`
	DependencyConditions []DependencyCondition `json:"dependencyConditions"`
}

type ActivityOnInactiveMarkAs

type ActivityOnInactiveMarkAs string

const (
	ActivityOnInactiveMarkAsFailed    ActivityOnInactiveMarkAs = "Failed"
	ActivityOnInactiveMarkAsSkipped   ActivityOnInactiveMarkAs = "Skipped"
	ActivityOnInactiveMarkAsSucceeded ActivityOnInactiveMarkAs = "Succeeded"
)

func (*ActivityOnInactiveMarkAs) UnmarshalJSON

func (s *ActivityOnInactiveMarkAs) UnmarshalJSON(bytes []byte) error

type ActivityPolicy

type ActivityPolicy struct {
	Retry                  *interface{} `json:"retry,omitempty"`
	RetryIntervalInSeconds *int64       `json:"retryIntervalInSeconds,omitempty"`
	SecureInput            *bool        `json:"secureInput,omitempty"`
	SecureOutput           *bool        `json:"secureOutput,omitempty"`
	Timeout                *interface{} `json:"timeout,omitempty"`
}

type ActivityState

type ActivityState string

const (
	ActivityStateActive   ActivityState = "Active"
	ActivityStateInactive ActivityState = "Inactive"
)

func (*ActivityState) UnmarshalJSON

func (s *ActivityState) UnmarshalJSON(bytes []byte) error

type AmazonMWSSource

type AmazonMWSSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type AmazonRdsForOraclePartitionSettings

type AmazonRdsForOraclePartitionSettings struct {
	PartitionColumnName *interface{} `json:"partitionColumnName,omitempty"`
	PartitionLowerBound *interface{} `json:"partitionLowerBound,omitempty"`
	PartitionNames      *interface{} `json:"partitionNames,omitempty"`
	PartitionUpperBound *interface{} `json:"partitionUpperBound,omitempty"`
}

type AmazonRdsForOracleSource

type AmazonRdsForOracleSource struct {
	AdditionalColumns        *interface{}                         `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{}                         `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{}                         `json:"maxConcurrentConnections,omitempty"`
	OracleReaderQuery        *interface{}                         `json:"oracleReaderQuery,omitempty"`
	PartitionOption          *interface{}                         `json:"partitionOption,omitempty"`
	PartitionSettings        *AmazonRdsForOraclePartitionSettings `json:"partitionSettings,omitempty"`
	QueryTimeout             *interface{}                         `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{}                         `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{}                         `json:"sourceRetryWait,omitempty"`
	Type                     string                               `json:"type"`
}

type AmazonRdsForSqlServerSource

type AmazonRdsForSqlServerSource struct {
	AdditionalColumns            *interface{}          `json:"additionalColumns,omitempty"`
	DisableMetricsCollection     *interface{}          `json:"disableMetricsCollection,omitempty"`
	IsolationLevel               *interface{}          `json:"isolationLevel,omitempty"`
	MaxConcurrentConnections     *interface{}          `json:"maxConcurrentConnections,omitempty"`
	PartitionOption              *interface{}          `json:"partitionOption,omitempty"`
	PartitionSettings            *SqlPartitionSettings `json:"partitionSettings,omitempty"`
	ProduceAdditionalTypes       *interface{}          `json:"produceAdditionalTypes,omitempty"`
	QueryTimeout                 *interface{}          `json:"queryTimeout,omitempty"`
	SourceRetryCount             *interface{}          `json:"sourceRetryCount,omitempty"`
	SourceRetryWait              *interface{}          `json:"sourceRetryWait,omitempty"`
	SqlReaderQuery               *interface{}          `json:"sqlReaderQuery,omitempty"`
	SqlReaderStoredProcedureName *interface{}          `json:"sqlReaderStoredProcedureName,omitempty"`
	StoredProcedureParameters    *interface{}          `json:"storedProcedureParameters,omitempty"`
	Type                         string                `json:"type"`
}

type AmazonRedshiftSource

type AmazonRedshiftSource struct {
	AdditionalColumns        *interface{}            `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{}            `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{}            `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{}            `json:"query,omitempty"`
	QueryTimeout             *interface{}            `json:"queryTimeout,omitempty"`
	RedshiftUnloadSettings   *RedshiftUnloadSettings `json:"redshiftUnloadSettings,omitempty"`
	SourceRetryCount         *interface{}            `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{}            `json:"sourceRetryWait,omitempty"`
	Type                     string                  `json:"type"`
}

type AmazonS3CompatibleReadSettings

type AmazonS3CompatibleReadSettings struct {
	DeleteFilesAfterCompletion *interface{} `json:"deleteFilesAfterCompletion,omitempty"`
	DisableMetricsCollection   *interface{} `json:"disableMetricsCollection,omitempty"`
	EnablePartitionDiscovery   *interface{} `json:"enablePartitionDiscovery,omitempty"`
	FileListPath               *interface{} `json:"fileListPath,omitempty"`
	MaxConcurrentConnections   *interface{} `json:"maxConcurrentConnections,omitempty"`
	ModifiedDatetimeEnd        *interface{} `json:"modifiedDatetimeEnd,omitempty"`
	ModifiedDatetimeStart      *interface{} `json:"modifiedDatetimeStart,omitempty"`
	PartitionRootPath          *interface{} `json:"partitionRootPath,omitempty"`
	Prefix                     *interface{} `json:"prefix,omitempty"`
	Recursive                  *interface{} `json:"recursive,omitempty"`
	Type                       string       `json:"type"`
	WildcardFileName           *interface{} `json:"wildcardFileName,omitempty"`
	WildcardFolderPath         *interface{} `json:"wildcardFolderPath,omitempty"`
}

type AmazonS3ReadSettings

type AmazonS3ReadSettings struct {
	DeleteFilesAfterCompletion *interface{} `json:"deleteFilesAfterCompletion,omitempty"`
	DisableMetricsCollection   *interface{} `json:"disableMetricsCollection,omitempty"`
	EnablePartitionDiscovery   *interface{} `json:"enablePartitionDiscovery,omitempty"`
	FileListPath               *interface{} `json:"fileListPath,omitempty"`
	MaxConcurrentConnections   *interface{} `json:"maxConcurrentConnections,omitempty"`
	ModifiedDatetimeEnd        *interface{} `json:"modifiedDatetimeEnd,omitempty"`
	ModifiedDatetimeStart      *interface{} `json:"modifiedDatetimeStart,omitempty"`
	PartitionRootPath          *interface{} `json:"partitionRootPath,omitempty"`
	Prefix                     *interface{} `json:"prefix,omitempty"`
	Recursive                  *interface{} `json:"recursive,omitempty"`
	Type                       string       `json:"type"`
	WildcardFileName           *interface{} `json:"wildcardFileName,omitempty"`
	WildcardFolderPath         *interface{} `json:"wildcardFolderPath,omitempty"`
}

type AppendVariableActivity

type AppendVariableActivity struct {
	TypeProperties AppendVariableActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (AppendVariableActivity) MarshalJSON

func (s AppendVariableActivity) MarshalJSON() ([]byte, error)

type AppendVariableActivityTypeProperties

type AppendVariableActivityTypeProperties struct {
	Value        *interface{} `json:"value,omitempty"`
	VariableName *string      `json:"variableName,omitempty"`
}

type AvroSink

type AvroSink struct {
	DisableMetricsCollection *interface{}       `json:"disableMetricsCollection,omitempty"`
	FormatSettings           *AvroWriteSettings `json:"formatSettings,omitempty"`
	MaxConcurrentConnections *interface{}       `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{}       `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{}       `json:"sinkRetryWait,omitempty"`
	StoreSettings            StoreWriteSettings `json:"storeSettings"`
	Type                     string             `json:"type"`
	WriteBatchSize           *interface{}       `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{}       `json:"writeBatchTimeout,omitempty"`
}

func (*AvroSink) UnmarshalJSON

func (s *AvroSink) UnmarshalJSON(bytes []byte) error

type AvroSource

type AvroSource struct {
	AdditionalColumns        *interface{}      `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{}      `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{}      `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{}      `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{}      `json:"sourceRetryWait,omitempty"`
	StoreSettings            StoreReadSettings `json:"storeSettings"`
	Type                     string            `json:"type"`
}

func (*AvroSource) UnmarshalJSON

func (s *AvroSource) UnmarshalJSON(bytes []byte) error

type AvroWriteSettings

type AvroWriteSettings struct {
	FileNamePrefix  *interface{} `json:"fileNamePrefix,omitempty"`
	MaxRowsPerFile  *interface{} `json:"maxRowsPerFile,omitempty"`
	RecordName      *string      `json:"recordName,omitempty"`
	RecordNamespace *string      `json:"recordNamespace,omitempty"`
	Type            string       `json:"type"`
}

type AzureBlobFSReadSettings

type AzureBlobFSReadSettings struct {
	DeleteFilesAfterCompletion *interface{} `json:"deleteFilesAfterCompletion,omitempty"`
	DisableMetricsCollection   *interface{} `json:"disableMetricsCollection,omitempty"`
	EnablePartitionDiscovery   *interface{} `json:"enablePartitionDiscovery,omitempty"`
	FileListPath               *interface{} `json:"fileListPath,omitempty"`
	MaxConcurrentConnections   *interface{} `json:"maxConcurrentConnections,omitempty"`
	ModifiedDatetimeEnd        *interface{} `json:"modifiedDatetimeEnd,omitempty"`
	ModifiedDatetimeStart      *interface{} `json:"modifiedDatetimeStart,omitempty"`
	PartitionRootPath          *interface{} `json:"partitionRootPath,omitempty"`
	Recursive                  *interface{} `json:"recursive,omitempty"`
	Type                       string       `json:"type"`
	WildcardFileName           *interface{} `json:"wildcardFileName,omitempty"`
	WildcardFolderPath         *interface{} `json:"wildcardFolderPath,omitempty"`
}

type AzureBlobFSSink

type AzureBlobFSSink struct {
	CopyBehavior             *interface{}    `json:"copyBehavior,omitempty"`
	DisableMetricsCollection *interface{}    `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{}    `json:"maxConcurrentConnections,omitempty"`
	Metadata                 *[]MetadataItem `json:"metadata,omitempty"`
	SinkRetryCount           *interface{}    `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{}    `json:"sinkRetryWait,omitempty"`
	Type                     string          `json:"type"`
	WriteBatchSize           *interface{}    `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{}    `json:"writeBatchTimeout,omitempty"`
}

type AzureBlobFSSource

type AzureBlobFSSource struct {
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Recursive                *interface{} `json:"recursive,omitempty"`
	SkipHeaderLineCount      *interface{} `json:"skipHeaderLineCount,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	TreatEmptyAsNull         *interface{} `json:"treatEmptyAsNull,omitempty"`
	Type                     string       `json:"type"`
}

type AzureBlobFSWriteSettings

type AzureBlobFSWriteSettings struct {
	BlockSizeInMB            *interface{}    `json:"blockSizeInMB,omitempty"`
	CopyBehavior             *interface{}    `json:"copyBehavior,omitempty"`
	DisableMetricsCollection *interface{}    `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{}    `json:"maxConcurrentConnections,omitempty"`
	Metadata                 *[]MetadataItem `json:"metadata,omitempty"`
	Type                     string          `json:"type"`
}

type AzureBlobStorageReadSettings

type AzureBlobStorageReadSettings struct {
	DeleteFilesAfterCompletion *interface{} `json:"deleteFilesAfterCompletion,omitempty"`
	DisableMetricsCollection   *interface{} `json:"disableMetricsCollection,omitempty"`
	EnablePartitionDiscovery   *interface{} `json:"enablePartitionDiscovery,omitempty"`
	FileListPath               *interface{} `json:"fileListPath,omitempty"`
	MaxConcurrentConnections   *interface{} `json:"maxConcurrentConnections,omitempty"`
	ModifiedDatetimeEnd        *interface{} `json:"modifiedDatetimeEnd,omitempty"`
	ModifiedDatetimeStart      *interface{} `json:"modifiedDatetimeStart,omitempty"`
	PartitionRootPath          *interface{} `json:"partitionRootPath,omitempty"`
	Prefix                     *interface{} `json:"prefix,omitempty"`
	Recursive                  *interface{} `json:"recursive,omitempty"`
	Type                       string       `json:"type"`
	WildcardFileName           *interface{} `json:"wildcardFileName,omitempty"`
	WildcardFolderPath         *interface{} `json:"wildcardFolderPath,omitempty"`
}

type AzureBlobStorageWriteSettings

type AzureBlobStorageWriteSettings struct {
	BlockSizeInMB            *interface{}    `json:"blockSizeInMB,omitempty"`
	CopyBehavior             *interface{}    `json:"copyBehavior,omitempty"`
	DisableMetricsCollection *interface{}    `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{}    `json:"maxConcurrentConnections,omitempty"`
	Metadata                 *[]MetadataItem `json:"metadata,omitempty"`
	Type                     string          `json:"type"`
}

type AzureDataExplorerCommandActivity

type AzureDataExplorerCommandActivity struct {
	LinkedServiceName *LinkedServiceReference                        `json:"linkedServiceName,omitempty"`
	Policy            *ActivityPolicy                                `json:"policy,omitempty"`
	TypeProperties    AzureDataExplorerCommandActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (AzureDataExplorerCommandActivity) MarshalJSON

func (s AzureDataExplorerCommandActivity) MarshalJSON() ([]byte, error)

type AzureDataExplorerCommandActivityTypeProperties

type AzureDataExplorerCommandActivityTypeProperties struct {
	Command        interface{}  `json:"command"`
	CommandTimeout *interface{} `json:"commandTimeout,omitempty"`
}

type AzureDataExplorerSink

type AzureDataExplorerSink struct {
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	FlushImmediately         *interface{} `json:"flushImmediately,omitempty"`
	IngestionMappingAsJson   *interface{} `json:"ingestionMappingAsJson,omitempty"`
	IngestionMappingName     *interface{} `json:"ingestionMappingName,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	Type                     string       `json:"type"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

type AzureDataExplorerSource

type AzureDataExplorerSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	NoTruncation             *interface{} `json:"noTruncation,omitempty"`
	Query                    interface{}  `json:"query"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type AzureDataLakeStoreReadSettings

type AzureDataLakeStoreReadSettings struct {
	DeleteFilesAfterCompletion *interface{} `json:"deleteFilesAfterCompletion,omitempty"`
	DisableMetricsCollection   *interface{} `json:"disableMetricsCollection,omitempty"`
	EnablePartitionDiscovery   *interface{} `json:"enablePartitionDiscovery,omitempty"`
	FileListPath               *interface{} `json:"fileListPath,omitempty"`
	ListAfter                  *interface{} `json:"listAfter,omitempty"`
	ListBefore                 *interface{} `json:"listBefore,omitempty"`
	MaxConcurrentConnections   *interface{} `json:"maxConcurrentConnections,omitempty"`
	ModifiedDatetimeEnd        *interface{} `json:"modifiedDatetimeEnd,omitempty"`
	ModifiedDatetimeStart      *interface{} `json:"modifiedDatetimeStart,omitempty"`
	PartitionRootPath          *interface{} `json:"partitionRootPath,omitempty"`
	Recursive                  *interface{} `json:"recursive,omitempty"`
	Type                       string       `json:"type"`
	WildcardFileName           *interface{} `json:"wildcardFileName,omitempty"`
	WildcardFolderPath         *interface{} `json:"wildcardFolderPath,omitempty"`
}

type AzureDataLakeStoreSink

type AzureDataLakeStoreSink struct {
	CopyBehavior                 *interface{} `json:"copyBehavior,omitempty"`
	DisableMetricsCollection     *interface{} `json:"disableMetricsCollection,omitempty"`
	EnableAdlsSingleFileParallel *interface{} `json:"enableAdlsSingleFileParallel,omitempty"`
	MaxConcurrentConnections     *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount               *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait                *interface{} `json:"sinkRetryWait,omitempty"`
	Type                         string       `json:"type"`
	WriteBatchSize               *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout            *interface{} `json:"writeBatchTimeout,omitempty"`
}

type AzureDataLakeStoreSource

type AzureDataLakeStoreSource struct {
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Recursive                *interface{} `json:"recursive,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type AzureDataLakeStoreWriteSettings

type AzureDataLakeStoreWriteSettings struct {
	CopyBehavior             *interface{}    `json:"copyBehavior,omitempty"`
	DisableMetricsCollection *interface{}    `json:"disableMetricsCollection,omitempty"`
	ExpiryDateTime           *interface{}    `json:"expiryDateTime,omitempty"`
	MaxConcurrentConnections *interface{}    `json:"maxConcurrentConnections,omitempty"`
	Metadata                 *[]MetadataItem `json:"metadata,omitempty"`
	Type                     string          `json:"type"`
}

type AzureDatabricksDeltaLakeExportCommand

type AzureDatabricksDeltaLakeExportCommand struct {
	DateFormat      *interface{} `json:"dateFormat,omitempty"`
	TimestampFormat *interface{} `json:"timestampFormat,omitempty"`
	Type            string       `json:"type"`
}

type AzureDatabricksDeltaLakeImportCommand

type AzureDatabricksDeltaLakeImportCommand struct {
	DateFormat      *interface{} `json:"dateFormat,omitempty"`
	TimestampFormat *interface{} `json:"timestampFormat,omitempty"`
	Type            string       `json:"type"`
}

type AzureDatabricksDeltaLakeSink

type AzureDatabricksDeltaLakeSink struct {
	DisableMetricsCollection *interface{}                           `json:"disableMetricsCollection,omitempty"`
	ImportSettings           *AzureDatabricksDeltaLakeImportCommand `json:"importSettings,omitempty"`
	MaxConcurrentConnections *interface{}                           `json:"maxConcurrentConnections,omitempty"`
	PreCopyScript            *interface{}                           `json:"preCopyScript,omitempty"`
	SinkRetryCount           *interface{}                           `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{}                           `json:"sinkRetryWait,omitempty"`
	Type                     string                                 `json:"type"`
	WriteBatchSize           *interface{}                           `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{}                           `json:"writeBatchTimeout,omitempty"`
}

type AzureDatabricksDeltaLakeSource

type AzureDatabricksDeltaLakeSource struct {
	DisableMetricsCollection *interface{}                           `json:"disableMetricsCollection,omitempty"`
	ExportSettings           *AzureDatabricksDeltaLakeExportCommand `json:"exportSettings,omitempty"`
	MaxConcurrentConnections *interface{}                           `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{}                           `json:"query,omitempty"`
	SourceRetryCount         *interface{}                           `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{}                           `json:"sourceRetryWait,omitempty"`
	Type                     string                                 `json:"type"`
}

type AzureFileStorageReadSettings

type AzureFileStorageReadSettings struct {
	DeleteFilesAfterCompletion *interface{} `json:"deleteFilesAfterCompletion,omitempty"`
	DisableMetricsCollection   *interface{} `json:"disableMetricsCollection,omitempty"`
	EnablePartitionDiscovery   *interface{} `json:"enablePartitionDiscovery,omitempty"`
	FileListPath               *interface{} `json:"fileListPath,omitempty"`
	MaxConcurrentConnections   *interface{} `json:"maxConcurrentConnections,omitempty"`
	ModifiedDatetimeEnd        *interface{} `json:"modifiedDatetimeEnd,omitempty"`
	ModifiedDatetimeStart      *interface{} `json:"modifiedDatetimeStart,omitempty"`
	PartitionRootPath          *interface{} `json:"partitionRootPath,omitempty"`
	Prefix                     *interface{} `json:"prefix,omitempty"`
	Recursive                  *interface{} `json:"recursive,omitempty"`
	Type                       string       `json:"type"`
	WildcardFileName           *interface{} `json:"wildcardFileName,omitempty"`
	WildcardFolderPath         *interface{} `json:"wildcardFolderPath,omitempty"`
}

type AzureFileStorageWriteSettings

type AzureFileStorageWriteSettings struct {
	CopyBehavior             *interface{}    `json:"copyBehavior,omitempty"`
	DisableMetricsCollection *interface{}    `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{}    `json:"maxConcurrentConnections,omitempty"`
	Metadata                 *[]MetadataItem `json:"metadata,omitempty"`
	Type                     string          `json:"type"`
}

type AzureFunctionActivity

type AzureFunctionActivity struct {
	LinkedServiceName *LinkedServiceReference             `json:"linkedServiceName,omitempty"`
	Policy            *ActivityPolicy                     `json:"policy,omitempty"`
	TypeProperties    AzureFunctionActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (AzureFunctionActivity) MarshalJSON

func (s AzureFunctionActivity) MarshalJSON() ([]byte, error)

type AzureFunctionActivityMethod

type AzureFunctionActivityMethod string

const (
	AzureFunctionActivityMethodDELETE  AzureFunctionActivityMethod = "DELETE"
	AzureFunctionActivityMethodGET     AzureFunctionActivityMethod = "GET"
	AzureFunctionActivityMethodHEAD    AzureFunctionActivityMethod = "HEAD"
	AzureFunctionActivityMethodOPTIONS AzureFunctionActivityMethod = "OPTIONS"
	AzureFunctionActivityMethodPOST    AzureFunctionActivityMethod = "POST"
	AzureFunctionActivityMethodPUT     AzureFunctionActivityMethod = "PUT"
	AzureFunctionActivityMethodTRACE   AzureFunctionActivityMethod = "TRACE"
)

func (*AzureFunctionActivityMethod) UnmarshalJSON

func (s *AzureFunctionActivityMethod) UnmarshalJSON(bytes []byte) error

type AzureFunctionActivityTypeProperties

type AzureFunctionActivityTypeProperties struct {
	Body         *interface{}                `json:"body,omitempty"`
	FunctionName interface{}                 `json:"functionName"`
	Headers      *map[string]interface{}     `json:"headers,omitempty"`
	Method       AzureFunctionActivityMethod `json:"method"`
}

type AzureMLBatchExecutionActivity

type AzureMLBatchExecutionActivity struct {
	LinkedServiceName *LinkedServiceReference                     `json:"linkedServiceName,omitempty"`
	Policy            *ActivityPolicy                             `json:"policy,omitempty"`
	TypeProperties    AzureMLBatchExecutionActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (AzureMLBatchExecutionActivity) MarshalJSON

func (s AzureMLBatchExecutionActivity) MarshalJSON() ([]byte, error)

type AzureMLBatchExecutionActivityTypeProperties

type AzureMLBatchExecutionActivityTypeProperties struct {
	GlobalParameters  *map[string]interface{}           `json:"globalParameters,omitempty"`
	WebServiceInputs  *map[string]AzureMLWebServiceFile `json:"webServiceInputs,omitempty"`
	WebServiceOutputs *map[string]AzureMLWebServiceFile `json:"webServiceOutputs,omitempty"`
}

type AzureMLExecutePipelineActivity

type AzureMLExecutePipelineActivity struct {
	LinkedServiceName *LinkedServiceReference                      `json:"linkedServiceName,omitempty"`
	Policy            *ActivityPolicy                              `json:"policy,omitempty"`
	TypeProperties    AzureMLExecutePipelineActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (AzureMLExecutePipelineActivity) MarshalJSON

func (s AzureMLExecutePipelineActivity) MarshalJSON() ([]byte, error)

type AzureMLExecutePipelineActivityTypeProperties

type AzureMLExecutePipelineActivityTypeProperties struct {
	ContinueOnStepFailure *interface{} `json:"continueOnStepFailure,omitempty"`
	DataPathAssignments   *interface{} `json:"dataPathAssignments,omitempty"`
	ExperimentName        *interface{} `json:"experimentName,omitempty"`
	MlParentRunId         *interface{} `json:"mlParentRunId,omitempty"`
	MlPipelineEndpointId  *interface{} `json:"mlPipelineEndpointId,omitempty"`
	MlPipelineId          *interface{} `json:"mlPipelineId,omitempty"`
	MlPipelineParameters  *interface{} `json:"mlPipelineParameters,omitempty"`
	Version               *interface{} `json:"version,omitempty"`
}

type AzureMLUpdateResourceActivity

type AzureMLUpdateResourceActivity struct {
	LinkedServiceName *LinkedServiceReference                     `json:"linkedServiceName,omitempty"`
	Policy            *ActivityPolicy                             `json:"policy,omitempty"`
	TypeProperties    AzureMLUpdateResourceActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (AzureMLUpdateResourceActivity) MarshalJSON

func (s AzureMLUpdateResourceActivity) MarshalJSON() ([]byte, error)

type AzureMLUpdateResourceActivityTypeProperties

type AzureMLUpdateResourceActivityTypeProperties struct {
	TrainedModelFilePath          interface{}            `json:"trainedModelFilePath"`
	TrainedModelLinkedServiceName LinkedServiceReference `json:"trainedModelLinkedServiceName"`
	TrainedModelName              interface{}            `json:"trainedModelName"`
}

type AzureMLWebServiceFile

type AzureMLWebServiceFile struct {
	FilePath          interface{}            `json:"filePath"`
	LinkedServiceName LinkedServiceReference `json:"linkedServiceName"`
}

type AzureMariaDBSource

type AzureMariaDBSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type AzureMySqlSink

type AzureMySqlSink struct {
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	PreCopyScript            *interface{} `json:"preCopyScript,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	Type                     string       `json:"type"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

type AzureMySqlSource

type AzureMySqlSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type AzurePostgreSqlSink

type AzurePostgreSqlSink struct {
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	PreCopyScript            *interface{} `json:"preCopyScript,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	Type                     string       `json:"type"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

type AzurePostgreSqlSource

type AzurePostgreSqlSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type AzureQueueSink

type AzureQueueSink struct {
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	Type                     string       `json:"type"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

type AzureSearchIndexSink

type AzureSearchIndexSink struct {
	DisableMetricsCollection *interface{}                       `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{}                       `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{}                       `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{}                       `json:"sinkRetryWait,omitempty"`
	Type                     string                             `json:"type"`
	WriteBatchSize           *interface{}                       `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{}                       `json:"writeBatchTimeout,omitempty"`
	WriteBehavior            *AzureSearchIndexWriteBehaviorType `json:"writeBehavior,omitempty"`
}

type AzureSearchIndexWriteBehaviorType

type AzureSearchIndexWriteBehaviorType string

const (
	AzureSearchIndexWriteBehaviorTypeMerge  AzureSearchIndexWriteBehaviorType = "Merge"
	AzureSearchIndexWriteBehaviorTypeUpload AzureSearchIndexWriteBehaviorType = "Upload"
)

func (*AzureSearchIndexWriteBehaviorType) UnmarshalJSON

func (s *AzureSearchIndexWriteBehaviorType) UnmarshalJSON(bytes []byte) error

type AzureSqlSink

type AzureSqlSink struct {
	DisableMetricsCollection              *interface{}       `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections              *interface{}       `json:"maxConcurrentConnections,omitempty"`
	PreCopyScript                         *interface{}       `json:"preCopyScript,omitempty"`
	SinkRetryCount                        *interface{}       `json:"sinkRetryCount,omitempty"`
	SinkRetryWait                         *interface{}       `json:"sinkRetryWait,omitempty"`
	SqlWriterStoredProcedureName          *interface{}       `json:"sqlWriterStoredProcedureName,omitempty"`
	SqlWriterTableType                    *interface{}       `json:"sqlWriterTableType,omitempty"`
	SqlWriterUseTableLock                 *interface{}       `json:"sqlWriterUseTableLock,omitempty"`
	StoredProcedureParameters             *interface{}       `json:"storedProcedureParameters,omitempty"`
	StoredProcedureTableTypeParameterName *interface{}       `json:"storedProcedureTableTypeParameterName,omitempty"`
	TableOption                           *interface{}       `json:"tableOption,omitempty"`
	Type                                  string             `json:"type"`
	UpsertSettings                        *SqlUpsertSettings `json:"upsertSettings,omitempty"`
	WriteBatchSize                        *interface{}       `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout                     *interface{}       `json:"writeBatchTimeout,omitempty"`
	WriteBehavior                         *interface{}       `json:"writeBehavior,omitempty"`
}

type AzureSqlSource

type AzureSqlSource struct {
	AdditionalColumns            *interface{}          `json:"additionalColumns,omitempty"`
	DisableMetricsCollection     *interface{}          `json:"disableMetricsCollection,omitempty"`
	IsolationLevel               *interface{}          `json:"isolationLevel,omitempty"`
	MaxConcurrentConnections     *interface{}          `json:"maxConcurrentConnections,omitempty"`
	PartitionOption              *interface{}          `json:"partitionOption,omitempty"`
	PartitionSettings            *SqlPartitionSettings `json:"partitionSettings,omitempty"`
	ProduceAdditionalTypes       *interface{}          `json:"produceAdditionalTypes,omitempty"`
	QueryTimeout                 *interface{}          `json:"queryTimeout,omitempty"`
	SourceRetryCount             *interface{}          `json:"sourceRetryCount,omitempty"`
	SourceRetryWait              *interface{}          `json:"sourceRetryWait,omitempty"`
	SqlReaderQuery               *interface{}          `json:"sqlReaderQuery,omitempty"`
	SqlReaderStoredProcedureName *interface{}          `json:"sqlReaderStoredProcedureName,omitempty"`
	StoredProcedureParameters    *interface{}          `json:"storedProcedureParameters,omitempty"`
	Type                         string                `json:"type"`
}

type AzureTableSink

type AzureTableSink struct {
	AzureTableDefaultPartitionKeyValue *interface{} `json:"azureTableDefaultPartitionKeyValue,omitempty"`
	AzureTableInsertType               *interface{} `json:"azureTableInsertType,omitempty"`
	AzureTablePartitionKeyName         *interface{} `json:"azureTablePartitionKeyName,omitempty"`
	AzureTableRowKeyName               *interface{} `json:"azureTableRowKeyName,omitempty"`
	DisableMetricsCollection           *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections           *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount                     *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait                      *interface{} `json:"sinkRetryWait,omitempty"`
	Type                               string       `json:"type"`
	WriteBatchSize                     *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout                  *interface{} `json:"writeBatchTimeout,omitempty"`
}

type AzureTableSource

type AzureTableSource struct {
	AdditionalColumns                   *interface{} `json:"additionalColumns,omitempty"`
	AzureTableSourceIgnoreTableNotFound *interface{} `json:"azureTableSourceIgnoreTableNotFound,omitempty"`
	AzureTableSourceQuery               *interface{} `json:"azureTableSourceQuery,omitempty"`
	DisableMetricsCollection            *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections            *interface{} `json:"maxConcurrentConnections,omitempty"`
	QueryTimeout                        *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount                    *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait                     *interface{} `json:"sourceRetryWait,omitempty"`
	Type                                string       `json:"type"`
}

type BigDataPoolParametrizationReference

type BigDataPoolParametrizationReference struct {
	ReferenceName interface{}              `json:"referenceName"`
	Type          BigDataPoolReferenceType `json:"type"`
}

type BigDataPoolReferenceType

type BigDataPoolReferenceType string

const (
	BigDataPoolReferenceTypeBigDataPoolReference BigDataPoolReferenceType = "BigDataPoolReference"
)

func (*BigDataPoolReferenceType) UnmarshalJSON

func (s *BigDataPoolReferenceType) UnmarshalJSON(bytes []byte) error

type BinaryReadSettings

type BinaryReadSettings struct {
	CompressionProperties CompressionReadSettings `json:"compressionProperties"`
	Type                  string                  `json:"type"`
}

func (*BinaryReadSettings) UnmarshalJSON

func (s *BinaryReadSettings) UnmarshalJSON(bytes []byte) error

type BinarySink

type BinarySink struct {
	DisableMetricsCollection *interface{}       `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{}       `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{}       `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{}       `json:"sinkRetryWait,omitempty"`
	StoreSettings            StoreWriteSettings `json:"storeSettings"`
	Type                     string             `json:"type"`
	WriteBatchSize           *interface{}       `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{}       `json:"writeBatchTimeout,omitempty"`
}

func (*BinarySink) UnmarshalJSON

func (s *BinarySink) UnmarshalJSON(bytes []byte) error

type BinarySource

type BinarySource struct {
	DisableMetricsCollection *interface{}        `json:"disableMetricsCollection,omitempty"`
	FormatSettings           *BinaryReadSettings `json:"formatSettings,omitempty"`
	MaxConcurrentConnections *interface{}        `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{}        `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{}        `json:"sourceRetryWait,omitempty"`
	StoreSettings            StoreReadSettings   `json:"storeSettings"`
	Type                     string              `json:"type"`
}

func (*BinarySource) UnmarshalJSON

func (s *BinarySource) UnmarshalJSON(bytes []byte) error

type BlobSink

type BlobSink struct {
	BlobWriterAddHeader      *interface{}    `json:"blobWriterAddHeader,omitempty"`
	BlobWriterDateTimeFormat *interface{}    `json:"blobWriterDateTimeFormat,omitempty"`
	BlobWriterOverwriteFiles *interface{}    `json:"blobWriterOverwriteFiles,omitempty"`
	CopyBehavior             *interface{}    `json:"copyBehavior,omitempty"`
	DisableMetricsCollection *interface{}    `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{}    `json:"maxConcurrentConnections,omitempty"`
	Metadata                 *[]MetadataItem `json:"metadata,omitempty"`
	SinkRetryCount           *interface{}    `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{}    `json:"sinkRetryWait,omitempty"`
	Type                     string          `json:"type"`
	WriteBatchSize           *interface{}    `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{}    `json:"writeBatchTimeout,omitempty"`
}

type BlobSource

type BlobSource struct {
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Recursive                *interface{} `json:"recursive,omitempty"`
	SkipHeaderLineCount      *interface{} `json:"skipHeaderLineCount,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	TreatEmptyAsNull         *interface{} `json:"treatEmptyAsNull,omitempty"`
	Type                     string       `json:"type"`
}

type CassandraSource

type CassandraSource struct {
	AdditionalColumns        *interface{}                          `json:"additionalColumns,omitempty"`
	ConsistencyLevel         *CassandraSourceReadConsistencyLevels `json:"consistencyLevel,omitempty"`
	DisableMetricsCollection *interface{}                          `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{}                          `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{}                          `json:"query,omitempty"`
	QueryTimeout             *interface{}                          `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{}                          `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{}                          `json:"sourceRetryWait,omitempty"`
	Type                     string                                `json:"type"`
}

type CassandraSourceReadConsistencyLevels

type CassandraSourceReadConsistencyLevels string

const (
	CassandraSourceReadConsistencyLevelsALL         CassandraSourceReadConsistencyLevels = "ALL"
	CassandraSourceReadConsistencyLevelsEACHQUORUM  CassandraSourceReadConsistencyLevels = "EACH_QUORUM"
	CassandraSourceReadConsistencyLevelsLOCALONE    CassandraSourceReadConsistencyLevels = "LOCAL_ONE"
	CassandraSourceReadConsistencyLevelsLOCALQUORUM CassandraSourceReadConsistencyLevels = "LOCAL_QUORUM"
	CassandraSourceReadConsistencyLevelsLOCALSERIAL CassandraSourceReadConsistencyLevels = "LOCAL_SERIAL"
	CassandraSourceReadConsistencyLevelsONE         CassandraSourceReadConsistencyLevels = "ONE"
	CassandraSourceReadConsistencyLevelsQUORUM      CassandraSourceReadConsistencyLevels = "QUORUM"
	CassandraSourceReadConsistencyLevelsSERIAL      CassandraSourceReadConsistencyLevels = "SERIAL"
	CassandraSourceReadConsistencyLevelsTHREE       CassandraSourceReadConsistencyLevels = "THREE"
	CassandraSourceReadConsistencyLevelsTWO         CassandraSourceReadConsistencyLevels = "TWO"
)

func (*CassandraSourceReadConsistencyLevels) UnmarshalJSON

func (s *CassandraSourceReadConsistencyLevels) UnmarshalJSON(bytes []byte) error

type CommonDataServiceForAppsSink

type CommonDataServiceForAppsSink struct {
	AlternateKeyName         *interface{}              `json:"alternateKeyName,omitempty"`
	DisableMetricsCollection *interface{}              `json:"disableMetricsCollection,omitempty"`
	IgnoreNullValues         *interface{}              `json:"ignoreNullValues,omitempty"`
	MaxConcurrentConnections *interface{}              `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{}              `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{}              `json:"sinkRetryWait,omitempty"`
	Type                     string                    `json:"type"`
	WriteBatchSize           *interface{}              `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{}              `json:"writeBatchTimeout,omitempty"`
	WriteBehavior            DynamicsSinkWriteBehavior `json:"writeBehavior"`
}

type CommonDataServiceForAppsSource

type CommonDataServiceForAppsSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type CompressionReadSettings

type CompressionReadSettings interface {
}

type ConcurSource

type ConcurSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type ConfigurationType

type ConfigurationType string

const (
	ConfigurationTypeArtifact   ConfigurationType = "Artifact"
	ConfigurationTypeCustomized ConfigurationType = "Customized"
	ConfigurationTypeDefault    ConfigurationType = "Default"
)

func (*ConfigurationType) UnmarshalJSON

func (s *ConfigurationType) UnmarshalJSON(bytes []byte) error

type ControlActivity

type ControlActivity struct {

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (ControlActivity) MarshalJSON

func (s ControlActivity) MarshalJSON() ([]byte, error)

type CopyActivity

type CopyActivity struct {
	Inputs            *[]DatasetReference        `json:"inputs,omitempty"`
	LinkedServiceName *LinkedServiceReference    `json:"linkedServiceName,omitempty"`
	Outputs           *[]DatasetReference        `json:"outputs,omitempty"`
	Policy            *ActivityPolicy            `json:"policy,omitempty"`
	TypeProperties    CopyActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (CopyActivity) MarshalJSON

func (s CopyActivity) MarshalJSON() ([]byte, error)

type CopyActivityLogSettings

type CopyActivityLogSettings struct {
	EnableReliableLogging *interface{} `json:"enableReliableLogging,omitempty"`
	LogLevel              *interface{} `json:"logLevel,omitempty"`
}

type CopyActivityTypeProperties

type CopyActivityTypeProperties struct {
	DataIntegrationUnits            *interface{}                     `json:"dataIntegrationUnits,omitempty"`
	EnableSkipIncompatibleRow       *interface{}                     `json:"enableSkipIncompatibleRow,omitempty"`
	EnableStaging                   *interface{}                     `json:"enableStaging,omitempty"`
	LogSettings                     *LogSettings                     `json:"logSettings,omitempty"`
	LogStorageSettings              *LogStorageSettings              `json:"logStorageSettings,omitempty"`
	ParallelCopies                  *interface{}                     `json:"parallelCopies,omitempty"`
	Preserve                        *[]interface{}                   `json:"preserve,omitempty"`
	PreserveRules                   *[]interface{}                   `json:"preserveRules,omitempty"`
	RedirectIncompatibleRowSettings *RedirectIncompatibleRowSettings `json:"redirectIncompatibleRowSettings,omitempty"`
	Sink                            CopySink                         `json:"sink"`
	SkipErrorFile                   *SkipErrorFile                   `json:"skipErrorFile,omitempty"`
	Source                          CopySource                       `json:"source"`
	StagingSettings                 *StagingSettings                 `json:"stagingSettings,omitempty"`
	Translator                      *interface{}                     `json:"translator,omitempty"`
	ValidateDataConsistency         *interface{}                     `json:"validateDataConsistency,omitempty"`
}

func (*CopyActivityTypeProperties) UnmarshalJSON

func (s *CopyActivityTypeProperties) UnmarshalJSON(bytes []byte) error

type CopySink

type CopySink interface {
}

type CopySource

type CopySource interface {
}

type CosmosDbMongoDbApiSink

type CosmosDbMongoDbApiSink struct {
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	Type                     string       `json:"type"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
	WriteBehavior            *interface{} `json:"writeBehavior,omitempty"`
}

type CosmosDbMongoDbApiSource

type CosmosDbMongoDbApiSource struct {
	AdditionalColumns        *interface{}                    `json:"additionalColumns,omitempty"`
	BatchSize                *interface{}                    `json:"batchSize,omitempty"`
	CursorMethods            *MongoDbCursorMethodsProperties `json:"cursorMethods,omitempty"`
	DisableMetricsCollection *interface{}                    `json:"disableMetricsCollection,omitempty"`
	Filter                   *interface{}                    `json:"filter,omitempty"`
	MaxConcurrentConnections *interface{}                    `json:"maxConcurrentConnections,omitempty"`
	QueryTimeout             *interface{}                    `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{}                    `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{}                    `json:"sourceRetryWait,omitempty"`
	Type                     string                          `json:"type"`
}

type CosmosDbSqlApiSink

type CosmosDbSqlApiSink struct {
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	Type                     string       `json:"type"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
	WriteBehavior            *interface{} `json:"writeBehavior,omitempty"`
}

type CosmosDbSqlApiSource

type CosmosDbSqlApiSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DetectDatetime           *interface{} `json:"detectDatetime,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	PageSize                 *interface{} `json:"pageSize,omitempty"`
	PreferredRegions         *interface{} `json:"preferredRegions,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type CouchbaseSource

type CouchbaseSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type CreateOrUpdateOperationOptions

type CreateOrUpdateOperationOptions struct {
	IfMatch *string
}

func DefaultCreateOrUpdateOperationOptions

func DefaultCreateOrUpdateOperationOptions() CreateOrUpdateOperationOptions

func (CreateOrUpdateOperationOptions) ToHeaders

func (o CreateOrUpdateOperationOptions) ToHeaders() *client.Headers

func (CreateOrUpdateOperationOptions) ToOData

func (o CreateOrUpdateOperationOptions) ToOData() *odata.Query

func (CreateOrUpdateOperationOptions) ToQuery

func (o CreateOrUpdateOperationOptions) ToQuery() *client.QueryParams

type CreateOrUpdateOperationResponse

type CreateOrUpdateOperationResponse struct {
	HttpResponse *http.Response
	OData        *odata.OData
	Model        *PipelineResource
}

type CreateRunOperationOptions

type CreateRunOperationOptions struct {
	IsRecovery             *bool
	ReferencePipelineRunId *string
	StartActivityName      *string
	StartFromFailure       *bool
}

func DefaultCreateRunOperationOptions

func DefaultCreateRunOperationOptions() CreateRunOperationOptions

func (CreateRunOperationOptions) ToHeaders

func (o CreateRunOperationOptions) ToHeaders() *client.Headers

func (CreateRunOperationOptions) ToOData

func (o CreateRunOperationOptions) ToOData() *odata.Query

func (CreateRunOperationOptions) ToQuery

func (o CreateRunOperationOptions) ToQuery() *client.QueryParams

type CreateRunOperationResponse

type CreateRunOperationResponse struct {
	HttpResponse *http.Response
	OData        *odata.OData
	Model        *CreateRunResponse
}

type CreateRunResponse

type CreateRunResponse struct {
	RunId string `json:"runId"`
}

type CredentialReference

type CredentialReference struct {
	ReferenceName string                  `json:"referenceName"`
	Type          CredentialReferenceType `json:"type"`
}

type CredentialReferenceType

type CredentialReferenceType string

const (
	CredentialReferenceTypeCredentialReference CredentialReferenceType = "CredentialReference"
)

func (*CredentialReferenceType) UnmarshalJSON

func (s *CredentialReferenceType) UnmarshalJSON(bytes []byte) error

type CustomActivity

type CustomActivity struct {
	LinkedServiceName *LinkedServiceReference      `json:"linkedServiceName,omitempty"`
	Policy            *ActivityPolicy              `json:"policy,omitempty"`
	TypeProperties    CustomActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (CustomActivity) MarshalJSON

func (s CustomActivity) MarshalJSON() ([]byte, error)

type CustomActivityReferenceObject

type CustomActivityReferenceObject struct {
	Datasets       *[]DatasetReference       `json:"datasets,omitempty"`
	LinkedServices *[]LinkedServiceReference `json:"linkedServices,omitempty"`
}

type CustomActivityTypeProperties

type CustomActivityTypeProperties struct {
	AutoUserSpecification *interface{}                   `json:"autoUserSpecification,omitempty"`
	Command               interface{}                    `json:"command"`
	ExtendedProperties    *map[string]interface{}        `json:"extendedProperties,omitempty"`
	FolderPath            *interface{}                   `json:"folderPath,omitempty"`
	ReferenceObjects      *CustomActivityReferenceObject `json:"referenceObjects,omitempty"`
	ResourceLinkedService *LinkedServiceReference        `json:"resourceLinkedService,omitempty"`
	RetentionTimeInDays   *interface{}                   `json:"retentionTimeInDays,omitempty"`
}

type DWCopyCommandDefaultValue

type DWCopyCommandDefaultValue struct {
	ColumnName   *interface{} `json:"columnName,omitempty"`
	DefaultValue *interface{} `json:"defaultValue,omitempty"`
}

type DWCopyCommandSettings

type DWCopyCommandSettings struct {
	AdditionalOptions *map[string]string           `json:"additionalOptions,omitempty"`
	DefaultValues     *[]DWCopyCommandDefaultValue `json:"defaultValues,omitempty"`
}

type DataFlowReference

type DataFlowReference struct {
	DatasetParameters *interface{}            `json:"datasetParameters,omitempty"`
	Parameters        *map[string]interface{} `json:"parameters,omitempty"`
	ReferenceName     string                  `json:"referenceName"`
	Type              DataFlowReferenceType   `json:"type"`
}

type DataFlowReferenceType

type DataFlowReferenceType string

const (
	DataFlowReferenceTypeDataFlowReference DataFlowReferenceType = "DataFlowReference"
)

func (*DataFlowReferenceType) UnmarshalJSON

func (s *DataFlowReferenceType) UnmarshalJSON(bytes []byte) error

type DataFlowStagingInfo

type DataFlowStagingInfo struct {
	FolderPath    *interface{}            `json:"folderPath,omitempty"`
	LinkedService *LinkedServiceReference `json:"linkedService,omitempty"`
}

type DataLakeAnalyticsUSQLActivity

type DataLakeAnalyticsUSQLActivity struct {
	LinkedServiceName *LinkedServiceReference                     `json:"linkedServiceName,omitempty"`
	Policy            *ActivityPolicy                             `json:"policy,omitempty"`
	TypeProperties    DataLakeAnalyticsUSQLActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (DataLakeAnalyticsUSQLActivity) MarshalJSON

func (s DataLakeAnalyticsUSQLActivity) MarshalJSON() ([]byte, error)

type DataLakeAnalyticsUSQLActivityTypeProperties

type DataLakeAnalyticsUSQLActivityTypeProperties struct {
	CompilationMode     *interface{}            `json:"compilationMode,omitempty"`
	DegreeOfParallelism *interface{}            `json:"degreeOfParallelism,omitempty"`
	Parameters          *map[string]interface{} `json:"parameters,omitempty"`
	Priority            *interface{}            `json:"priority,omitempty"`
	RuntimeVersion      *interface{}            `json:"runtimeVersion,omitempty"`
	ScriptLinkedService LinkedServiceReference  `json:"scriptLinkedService"`
	ScriptPath          interface{}             `json:"scriptPath"`
}

type DatabricksNotebookActivity

type DatabricksNotebookActivity struct {
	LinkedServiceName *LinkedServiceReference                  `json:"linkedServiceName,omitempty"`
	Policy            *ActivityPolicy                          `json:"policy,omitempty"`
	TypeProperties    DatabricksNotebookActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (DatabricksNotebookActivity) MarshalJSON

func (s DatabricksNotebookActivity) MarshalJSON() ([]byte, error)

type DatabricksNotebookActivityTypeProperties

type DatabricksNotebookActivityTypeProperties struct {
	BaseParameters *map[string]interface{}   `json:"baseParameters,omitempty"`
	Libraries      *[]map[string]interface{} `json:"libraries,omitempty"`
	NotebookPath   interface{}               `json:"notebookPath"`
}

type DatabricksSparkJarActivity

type DatabricksSparkJarActivity struct {
	LinkedServiceName *LinkedServiceReference                  `json:"linkedServiceName,omitempty"`
	Policy            *ActivityPolicy                          `json:"policy,omitempty"`
	TypeProperties    DatabricksSparkJarActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (DatabricksSparkJarActivity) MarshalJSON

func (s DatabricksSparkJarActivity) MarshalJSON() ([]byte, error)

type DatabricksSparkJarActivityTypeProperties

type DatabricksSparkJarActivityTypeProperties struct {
	Libraries     *[]map[string]interface{} `json:"libraries,omitempty"`
	MainClassName interface{}               `json:"mainClassName"`
	Parameters    *[]interface{}            `json:"parameters,omitempty"`
}

type DatabricksSparkPythonActivity

type DatabricksSparkPythonActivity struct {
	LinkedServiceName *LinkedServiceReference                     `json:"linkedServiceName,omitempty"`
	Policy            *ActivityPolicy                             `json:"policy,omitempty"`
	TypeProperties    DatabricksSparkPythonActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (DatabricksSparkPythonActivity) MarshalJSON

func (s DatabricksSparkPythonActivity) MarshalJSON() ([]byte, error)

type DatabricksSparkPythonActivityTypeProperties

type DatabricksSparkPythonActivityTypeProperties struct {
	Libraries  *[]map[string]interface{} `json:"libraries,omitempty"`
	Parameters *[]interface{}            `json:"parameters,omitempty"`
	PythonFile interface{}               `json:"pythonFile"`
}

type DatasetReference

type DatasetReference struct {
	Parameters    *map[string]interface{} `json:"parameters,omitempty"`
	ReferenceName string                  `json:"referenceName"`
	Type          DatasetReferenceType    `json:"type"`
}

type DatasetReferenceType

type DatasetReferenceType string

const (
	DatasetReferenceTypeDatasetReference DatasetReferenceType = "DatasetReference"
)

func (*DatasetReferenceType) UnmarshalJSON

func (s *DatasetReferenceType) UnmarshalJSON(bytes []byte) error

type Db2Source

type Db2Source struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type DeleteActivity

type DeleteActivity struct {
	LinkedServiceName *LinkedServiceReference      `json:"linkedServiceName,omitempty"`
	Policy            *ActivityPolicy              `json:"policy,omitempty"`
	TypeProperties    DeleteActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (DeleteActivity) MarshalJSON

func (s DeleteActivity) MarshalJSON() ([]byte, error)

type DeleteActivityTypeProperties

type DeleteActivityTypeProperties struct {
	Dataset                  DatasetReference    `json:"dataset"`
	EnableLogging            *interface{}        `json:"enableLogging,omitempty"`
	LogStorageSettings       *LogStorageSettings `json:"logStorageSettings,omitempty"`
	MaxConcurrentConnections *int64              `json:"maxConcurrentConnections,omitempty"`
	Recursive                *interface{}        `json:"recursive,omitempty"`
	StoreSettings            StoreReadSettings   `json:"storeSettings"`
}

func (*DeleteActivityTypeProperties) UnmarshalJSON

func (s *DeleteActivityTypeProperties) UnmarshalJSON(bytes []byte) error

type DeleteOperationResponse

type DeleteOperationResponse struct {
	HttpResponse *http.Response
	OData        *odata.OData
}

type DelimitedTextReadSettings

type DelimitedTextReadSettings struct {
	CompressionProperties CompressionReadSettings `json:"compressionProperties"`
	SkipLineCount         *interface{}            `json:"skipLineCount,omitempty"`
	Type                  string                  `json:"type"`
}

func (*DelimitedTextReadSettings) UnmarshalJSON

func (s *DelimitedTextReadSettings) UnmarshalJSON(bytes []byte) error

type DelimitedTextSink

type DelimitedTextSink struct {
	DisableMetricsCollection *interface{}                `json:"disableMetricsCollection,omitempty"`
	FormatSettings           *DelimitedTextWriteSettings `json:"formatSettings,omitempty"`
	MaxConcurrentConnections *interface{}                `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{}                `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{}                `json:"sinkRetryWait,omitempty"`
	StoreSettings            StoreWriteSettings          `json:"storeSettings"`
	Type                     string                      `json:"type"`
	WriteBatchSize           *interface{}                `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{}                `json:"writeBatchTimeout,omitempty"`
}

func (*DelimitedTextSink) UnmarshalJSON

func (s *DelimitedTextSink) UnmarshalJSON(bytes []byte) error

type DelimitedTextSource

type DelimitedTextSource struct {
	AdditionalColumns        *interface{}               `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{}               `json:"disableMetricsCollection,omitempty"`
	FormatSettings           *DelimitedTextReadSettings `json:"formatSettings,omitempty"`
	MaxConcurrentConnections *interface{}               `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{}               `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{}               `json:"sourceRetryWait,omitempty"`
	StoreSettings            StoreReadSettings          `json:"storeSettings"`
	Type                     string                     `json:"type"`
}

func (*DelimitedTextSource) UnmarshalJSON

func (s *DelimitedTextSource) UnmarshalJSON(bytes []byte) error

type DelimitedTextWriteSettings

type DelimitedTextWriteSettings struct {
	FileExtension  interface{}  `json:"fileExtension"`
	FileNamePrefix *interface{} `json:"fileNamePrefix,omitempty"`
	MaxRowsPerFile *interface{} `json:"maxRowsPerFile,omitempty"`
	QuoteAllText   *interface{} `json:"quoteAllText,omitempty"`
	Type           string       `json:"type"`
}

type DependencyCondition

type DependencyCondition string

const (
	DependencyConditionCompleted DependencyCondition = "Completed"
	DependencyConditionFailed    DependencyCondition = "Failed"
	DependencyConditionSkipped   DependencyCondition = "Skipped"
	DependencyConditionSucceeded DependencyCondition = "Succeeded"
)

func (*DependencyCondition) UnmarshalJSON

func (s *DependencyCondition) UnmarshalJSON(bytes []byte) error

type DistcpSettings

type DistcpSettings struct {
	DistcpOptions           *interface{} `json:"distcpOptions,omitempty"`
	ResourceManagerEndpoint interface{}  `json:"resourceManagerEndpoint"`
	TempScriptPath          interface{}  `json:"tempScriptPath"`
}

type DocumentDbCollectionSink

type DocumentDbCollectionSink struct {
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	NestingSeparator         *interface{} `json:"nestingSeparator,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	Type                     string       `json:"type"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
	WriteBehavior            *interface{} `json:"writeBehavior,omitempty"`
}

type DocumentDbCollectionSource

type DocumentDbCollectionSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	NestingSeparator         *interface{} `json:"nestingSeparator,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type DrillSource

type DrillSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type DynamicsAXSource

type DynamicsAXSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	HTTPRequestTimeout       *interface{} `json:"httpRequestTimeout,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type DynamicsCrmSink

type DynamicsCrmSink struct {
	AlternateKeyName         *interface{}              `json:"alternateKeyName,omitempty"`
	DisableMetricsCollection *interface{}              `json:"disableMetricsCollection,omitempty"`
	IgnoreNullValues         *interface{}              `json:"ignoreNullValues,omitempty"`
	MaxConcurrentConnections *interface{}              `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{}              `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{}              `json:"sinkRetryWait,omitempty"`
	Type                     string                    `json:"type"`
	WriteBatchSize           *interface{}              `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{}              `json:"writeBatchTimeout,omitempty"`
	WriteBehavior            DynamicsSinkWriteBehavior `json:"writeBehavior"`
}

type DynamicsCrmSource

type DynamicsCrmSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type DynamicsSink

type DynamicsSink struct {
	AlternateKeyName         *interface{}              `json:"alternateKeyName,omitempty"`
	DisableMetricsCollection *interface{}              `json:"disableMetricsCollection,omitempty"`
	IgnoreNullValues         *interface{}              `json:"ignoreNullValues,omitempty"`
	MaxConcurrentConnections *interface{}              `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{}              `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{}              `json:"sinkRetryWait,omitempty"`
	Type                     string                    `json:"type"`
	WriteBatchSize           *interface{}              `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{}              `json:"writeBatchTimeout,omitempty"`
	WriteBehavior            DynamicsSinkWriteBehavior `json:"writeBehavior"`
}

type DynamicsSinkWriteBehavior

type DynamicsSinkWriteBehavior string

const (
	DynamicsSinkWriteBehaviorUpsert DynamicsSinkWriteBehavior = "Upsert"
)

func (*DynamicsSinkWriteBehavior) UnmarshalJSON

func (s *DynamicsSinkWriteBehavior) UnmarshalJSON(bytes []byte) error

type DynamicsSource

type DynamicsSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type EloquaSource

type EloquaSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type ExcelSource

type ExcelSource struct {
	AdditionalColumns        *interface{}      `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{}      `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{}      `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{}      `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{}      `json:"sourceRetryWait,omitempty"`
	StoreSettings            StoreReadSettings `json:"storeSettings"`
	Type                     string            `json:"type"`
}

func (*ExcelSource) UnmarshalJSON

func (s *ExcelSource) UnmarshalJSON(bytes []byte) error

type ExecuteDataFlowActivity

type ExecuteDataFlowActivity struct {
	LinkedServiceName *LinkedServiceReference               `json:"linkedServiceName,omitempty"`
	Policy            *ActivityPolicy                       `json:"policy,omitempty"`
	TypeProperties    ExecuteDataFlowActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (ExecuteDataFlowActivity) MarshalJSON

func (s ExecuteDataFlowActivity) MarshalJSON() ([]byte, error)

type ExecuteDataFlowActivityTypeProperties

type ExecuteDataFlowActivityTypeProperties struct {
	Compute                  *ExecuteDataFlowActivityTypePropertiesCompute `json:"compute,omitempty"`
	ContinueOnError          *interface{}                                  `json:"continueOnError,omitempty"`
	DataFlow                 DataFlowReference                             `json:"dataFlow"`
	IntegrationRuntime       *IntegrationRuntimeReference                  `json:"integrationRuntime,omitempty"`
	RunConcurrently          *interface{}                                  `json:"runConcurrently,omitempty"`
	SourceStagingConcurrency *interface{}                                  `json:"sourceStagingConcurrency,omitempty"`
	Staging                  *DataFlowStagingInfo                          `json:"staging,omitempty"`
	TraceLevel               *interface{}                                  `json:"traceLevel,omitempty"`
}

type ExecuteDataFlowActivityTypePropertiesCompute

type ExecuteDataFlowActivityTypePropertiesCompute struct {
	ComputeType *interface{} `json:"computeType,omitempty"`
	CoreCount   *interface{} `json:"coreCount,omitempty"`
}

type ExecutePipelineActivity

type ExecutePipelineActivity struct {
	Policy         *ExecutePipelineActivityPolicy        `json:"policy,omitempty"`
	TypeProperties ExecutePipelineActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (ExecutePipelineActivity) MarshalJSON

func (s ExecutePipelineActivity) MarshalJSON() ([]byte, error)

type ExecutePipelineActivityPolicy

type ExecutePipelineActivityPolicy struct {
	SecureInput *bool `json:"secureInput,omitempty"`
}

type ExecutePipelineActivityTypeProperties

type ExecutePipelineActivityTypeProperties struct {
	Parameters       *map[string]interface{} `json:"parameters,omitempty"`
	Pipeline         PipelineReference       `json:"pipeline"`
	WaitOnCompletion *bool                   `json:"waitOnCompletion,omitempty"`
}

type ExecutePowerQueryActivityTypeProperties

type ExecutePowerQueryActivityTypeProperties struct {
	Compute                  *ExecuteDataFlowActivityTypePropertiesCompute `json:"compute,omitempty"`
	ContinueOnError          *interface{}                                  `json:"continueOnError,omitempty"`
	DataFlow                 DataFlowReference                             `json:"dataFlow"`
	IntegrationRuntime       *IntegrationRuntimeReference                  `json:"integrationRuntime,omitempty"`
	Queries                  *[]PowerQuerySinkMapping                      `json:"queries,omitempty"`
	RunConcurrently          *interface{}                                  `json:"runConcurrently,omitempty"`
	Sinks                    *map[string]PowerQuerySink                    `json:"sinks,omitempty"`
	SourceStagingConcurrency *interface{}                                  `json:"sourceStagingConcurrency,omitempty"`
	Staging                  *DataFlowStagingInfo                          `json:"staging,omitempty"`
	TraceLevel               *interface{}                                  `json:"traceLevel,omitempty"`
}

type ExecuteSSISPackageActivity

type ExecuteSSISPackageActivity struct {
	LinkedServiceName *LinkedServiceReference                  `json:"linkedServiceName,omitempty"`
	Policy            *ActivityPolicy                          `json:"policy,omitempty"`
	TypeProperties    ExecuteSSISPackageActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (ExecuteSSISPackageActivity) MarshalJSON

func (s ExecuteSSISPackageActivity) MarshalJSON() ([]byte, error)

type ExecuteSSISPackageActivityTypeProperties

type ExecuteSSISPackageActivityTypeProperties struct {
	ConnectVia                IntegrationRuntimeReference                   `json:"connectVia"`
	EnvironmentPath           *interface{}                                  `json:"environmentPath,omitempty"`
	ExecutionCredential       *SSISExecutionCredential                      `json:"executionCredential,omitempty"`
	LogLocation               *SSISLogLocation                              `json:"logLocation,omitempty"`
	LoggingLevel              *interface{}                                  `json:"loggingLevel,omitempty"`
	PackageConnectionManagers *map[string]map[string]SSISExecutionParameter `json:"packageConnectionManagers,omitempty"`
	PackageLocation           SSISPackageLocation                           `json:"packageLocation"`
	PackageParameters         *map[string]SSISExecutionParameter            `json:"packageParameters,omitempty"`
	ProjectConnectionManagers *map[string]map[string]SSISExecutionParameter `json:"projectConnectionManagers,omitempty"`
	ProjectParameters         *map[string]SSISExecutionParameter            `json:"projectParameters,omitempty"`
	PropertyOverrides         *map[string]SSISPropertyOverride              `json:"propertyOverrides,omitempty"`
	Runtime                   *interface{}                                  `json:"runtime,omitempty"`
}

type ExecuteWranglingDataflowActivity

type ExecuteWranglingDataflowActivity struct {
	Policy         *ActivityPolicy                         `json:"policy,omitempty"`
	TypeProperties ExecutePowerQueryActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (ExecuteWranglingDataflowActivity) MarshalJSON

func (s ExecuteWranglingDataflowActivity) MarshalJSON() ([]byte, error)

type ExecutionActivity

type ExecutionActivity struct {
	LinkedServiceName *LinkedServiceReference `json:"linkedServiceName,omitempty"`
	Policy            *ActivityPolicy         `json:"policy,omitempty"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (ExecutionActivity) MarshalJSON

func (s ExecutionActivity) MarshalJSON() ([]byte, error)

type Expression

type Expression struct {
	Type  ExpressionType `json:"type"`
	Value string         `json:"value"`
}

type ExpressionType

type ExpressionType string

const (
	ExpressionTypeExpression ExpressionType = "Expression"
)

func (*ExpressionType) UnmarshalJSON

func (s *ExpressionType) UnmarshalJSON(bytes []byte) error

type ExpressionV2

type ExpressionV2 struct {
	Operands *[]ExpressionV2   `json:"operands,omitempty"`
	Operator *string           `json:"operator,omitempty"`
	Type     *ExpressionV2Type `json:"type,omitempty"`
	Value    *string           `json:"value,omitempty"`
}

type ExpressionV2Type

type ExpressionV2Type string

const (
	ExpressionV2TypeBinary   ExpressionV2Type = "Binary"
	ExpressionV2TypeConstant ExpressionV2Type = "Constant"
	ExpressionV2TypeField    ExpressionV2Type = "Field"
	ExpressionV2TypeUnary    ExpressionV2Type = "Unary"
)

func (*ExpressionV2Type) UnmarshalJSON

func (s *ExpressionV2Type) UnmarshalJSON(bytes []byte) error

type FactoryId

type FactoryId struct {
	SubscriptionId    string
	ResourceGroupName string
	FactoryName       string
}

FactoryId is a struct representing the Resource ID for a Factory

func NewFactoryID

func NewFactoryID(subscriptionId string, resourceGroupName string, factoryName string) FactoryId

NewFactoryID returns a new FactoryId struct

func ParseFactoryID

func ParseFactoryID(input string) (*FactoryId, error)

ParseFactoryID parses 'input' into a FactoryId

func ParseFactoryIDInsensitively

func ParseFactoryIDInsensitively(input string) (*FactoryId, error)

ParseFactoryIDInsensitively parses 'input' case-insensitively into a FactoryId note: this method should only be used for API response data and not user input

func (*FactoryId) FromParseResult

func (id *FactoryId) FromParseResult(input resourceids.ParseResult) error

func (FactoryId) ID

func (id FactoryId) ID() string

ID returns the formatted Factory ID

func (FactoryId) Segments

func (id FactoryId) Segments() []resourceids.Segment

Segments returns a slice of Resource ID Segments which comprise this Factory ID

func (FactoryId) String

func (id FactoryId) String() string

String returns a human-readable description of this Factory ID

type FailActivity

type FailActivity struct {
	TypeProperties FailActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (FailActivity) MarshalJSON

func (s FailActivity) MarshalJSON() ([]byte, error)

type FailActivityTypeProperties

type FailActivityTypeProperties struct {
	ErrorCode interface{} `json:"errorCode"`
	Message   interface{} `json:"message"`
}

type FileServerReadSettings

type FileServerReadSettings struct {
	DeleteFilesAfterCompletion *interface{} `json:"deleteFilesAfterCompletion,omitempty"`
	DisableMetricsCollection   *interface{} `json:"disableMetricsCollection,omitempty"`
	EnablePartitionDiscovery   *interface{} `json:"enablePartitionDiscovery,omitempty"`
	FileFilter                 *interface{} `json:"fileFilter,omitempty"`
	FileListPath               *interface{} `json:"fileListPath,omitempty"`
	MaxConcurrentConnections   *interface{} `json:"maxConcurrentConnections,omitempty"`
	ModifiedDatetimeEnd        *interface{} `json:"modifiedDatetimeEnd,omitempty"`
	ModifiedDatetimeStart      *interface{} `json:"modifiedDatetimeStart,omitempty"`
	PartitionRootPath          *interface{} `json:"partitionRootPath,omitempty"`
	Recursive                  *interface{} `json:"recursive,omitempty"`
	Type                       string       `json:"type"`
	WildcardFileName           *interface{} `json:"wildcardFileName,omitempty"`
	WildcardFolderPath         *interface{} `json:"wildcardFolderPath,omitempty"`
}

type FileServerWriteSettings

type FileServerWriteSettings struct {
	CopyBehavior             *interface{}    `json:"copyBehavior,omitempty"`
	DisableMetricsCollection *interface{}    `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{}    `json:"maxConcurrentConnections,omitempty"`
	Metadata                 *[]MetadataItem `json:"metadata,omitempty"`
	Type                     string          `json:"type"`
}

type FileSystemSink

type FileSystemSink struct {
	CopyBehavior             *interface{} `json:"copyBehavior,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	Type                     string       `json:"type"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

type FileSystemSource

type FileSystemSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Recursive                *interface{} `json:"recursive,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type FilterActivity

type FilterActivity struct {
	TypeProperties FilterActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (FilterActivity) MarshalJSON

func (s FilterActivity) MarshalJSON() ([]byte, error)

type FilterActivityTypeProperties

type FilterActivityTypeProperties struct {
	Condition Expression `json:"condition"`
	Items     Expression `json:"items"`
}

type ForEachActivity

type ForEachActivity struct {
	TypeProperties ForEachActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (ForEachActivity) MarshalJSON

func (s ForEachActivity) MarshalJSON() ([]byte, error)

type ForEachActivityTypeProperties

type ForEachActivityTypeProperties struct {
	Activities   []Activity `json:"activities"`
	BatchCount   *int64     `json:"batchCount,omitempty"`
	IsSequential *bool      `json:"isSequential,omitempty"`
	Items        Expression `json:"items"`
}

func (*ForEachActivityTypeProperties) UnmarshalJSON

func (s *ForEachActivityTypeProperties) UnmarshalJSON(bytes []byte) error

type FormatReadSettings

type FormatReadSettings interface {
}

type FtpReadSettings

type FtpReadSettings struct {
	DeleteFilesAfterCompletion *interface{} `json:"deleteFilesAfterCompletion,omitempty"`
	DisableChunking            *interface{} `json:"disableChunking,omitempty"`
	DisableMetricsCollection   *interface{} `json:"disableMetricsCollection,omitempty"`
	EnablePartitionDiscovery   *interface{} `json:"enablePartitionDiscovery,omitempty"`
	FileListPath               *interface{} `json:"fileListPath,omitempty"`
	MaxConcurrentConnections   *interface{} `json:"maxConcurrentConnections,omitempty"`
	PartitionRootPath          *interface{} `json:"partitionRootPath,omitempty"`
	Recursive                  *interface{} `json:"recursive,omitempty"`
	Type                       string       `json:"type"`
	UseBinaryTransfer          *interface{} `json:"useBinaryTransfer,omitempty"`
	WildcardFileName           *interface{} `json:"wildcardFileName,omitempty"`
	WildcardFolderPath         *interface{} `json:"wildcardFolderPath,omitempty"`
}

type GetMetadataActivity

type GetMetadataActivity struct {
	LinkedServiceName *LinkedServiceReference           `json:"linkedServiceName,omitempty"`
	Policy            *ActivityPolicy                   `json:"policy,omitempty"`
	TypeProperties    GetMetadataActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (GetMetadataActivity) MarshalJSON

func (s GetMetadataActivity) MarshalJSON() ([]byte, error)

type GetMetadataActivityTypeProperties

type GetMetadataActivityTypeProperties struct {
	Dataset        DatasetReference   `json:"dataset"`
	FieldList      *[]interface{}     `json:"fieldList,omitempty"`
	FormatSettings FormatReadSettings `json:"formatSettings"`
	StoreSettings  StoreReadSettings  `json:"storeSettings"`
}

func (*GetMetadataActivityTypeProperties) UnmarshalJSON

func (s *GetMetadataActivityTypeProperties) UnmarshalJSON(bytes []byte) error

type GetOperationOptions

type GetOperationOptions struct {
	IfNoneMatch *string
}

func DefaultGetOperationOptions

func DefaultGetOperationOptions() GetOperationOptions

func (GetOperationOptions) ToHeaders

func (o GetOperationOptions) ToHeaders() *client.Headers

func (GetOperationOptions) ToOData

func (o GetOperationOptions) ToOData() *odata.Query

func (GetOperationOptions) ToQuery

func (o GetOperationOptions) ToQuery() *client.QueryParams

type GetOperationResponse

type GetOperationResponse struct {
	HttpResponse *http.Response
	OData        *odata.OData
	Model        *PipelineResource
}

type GoogleAdWordsSource

type GoogleAdWordsSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type GoogleBigQuerySource

type GoogleBigQuerySource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type GoogleBigQueryV2Source

type GoogleBigQueryV2Source struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type GoogleCloudStorageReadSettings

type GoogleCloudStorageReadSettings struct {
	DeleteFilesAfterCompletion *interface{} `json:"deleteFilesAfterCompletion,omitempty"`
	DisableMetricsCollection   *interface{} `json:"disableMetricsCollection,omitempty"`
	EnablePartitionDiscovery   *interface{} `json:"enablePartitionDiscovery,omitempty"`
	FileListPath               *interface{} `json:"fileListPath,omitempty"`
	MaxConcurrentConnections   *interface{} `json:"maxConcurrentConnections,omitempty"`
	ModifiedDatetimeEnd        *interface{} `json:"modifiedDatetimeEnd,omitempty"`
	ModifiedDatetimeStart      *interface{} `json:"modifiedDatetimeStart,omitempty"`
	PartitionRootPath          *interface{} `json:"partitionRootPath,omitempty"`
	Prefix                     *interface{} `json:"prefix,omitempty"`
	Recursive                  *interface{} `json:"recursive,omitempty"`
	Type                       string       `json:"type"`
	WildcardFileName           *interface{} `json:"wildcardFileName,omitempty"`
	WildcardFolderPath         *interface{} `json:"wildcardFolderPath,omitempty"`
}

type GreenplumSource

type GreenplumSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type HBaseSource

type HBaseSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type HDInsightActivityDebugInfoOption

type HDInsightActivityDebugInfoOption string

const (
	HDInsightActivityDebugInfoOptionAlways  HDInsightActivityDebugInfoOption = "Always"
	HDInsightActivityDebugInfoOptionFailure HDInsightActivityDebugInfoOption = "Failure"
	HDInsightActivityDebugInfoOptionNone    HDInsightActivityDebugInfoOption = "None"
)

func (*HDInsightActivityDebugInfoOption) UnmarshalJSON

func (s *HDInsightActivityDebugInfoOption) UnmarshalJSON(bytes []byte) error

type HDInsightHiveActivity

type HDInsightHiveActivity struct {
	LinkedServiceName *LinkedServiceReference             `json:"linkedServiceName,omitempty"`
	Policy            *ActivityPolicy                     `json:"policy,omitempty"`
	TypeProperties    HDInsightHiveActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (HDInsightHiveActivity) MarshalJSON

func (s HDInsightHiveActivity) MarshalJSON() ([]byte, error)

type HDInsightHiveActivityTypeProperties

type HDInsightHiveActivityTypeProperties struct {
	Arguments             *[]interface{}                    `json:"arguments,omitempty"`
	Defines               *map[string]interface{}           `json:"defines,omitempty"`
	GetDebugInfo          *HDInsightActivityDebugInfoOption `json:"getDebugInfo,omitempty"`
	QueryTimeout          *int64                            `json:"queryTimeout,omitempty"`
	ScriptLinkedService   *LinkedServiceReference           `json:"scriptLinkedService,omitempty"`
	ScriptPath            *interface{}                      `json:"scriptPath,omitempty"`
	StorageLinkedServices *[]LinkedServiceReference         `json:"storageLinkedServices,omitempty"`
	Variables             *map[string]interface{}           `json:"variables,omitempty"`
}

type HDInsightMapReduceActivity

type HDInsightMapReduceActivity struct {
	LinkedServiceName *LinkedServiceReference                  `json:"linkedServiceName,omitempty"`
	Policy            *ActivityPolicy                          `json:"policy,omitempty"`
	TypeProperties    HDInsightMapReduceActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (HDInsightMapReduceActivity) MarshalJSON

func (s HDInsightMapReduceActivity) MarshalJSON() ([]byte, error)

type HDInsightMapReduceActivityTypeProperties

type HDInsightMapReduceActivityTypeProperties struct {
	Arguments             *[]interface{}                    `json:"arguments,omitempty"`
	ClassName             interface{}                       `json:"className"`
	Defines               *map[string]interface{}           `json:"defines,omitempty"`
	GetDebugInfo          *HDInsightActivityDebugInfoOption `json:"getDebugInfo,omitempty"`
	JarFilePath           interface{}                       `json:"jarFilePath"`
	JarLibs               *[]interface{}                    `json:"jarLibs,omitempty"`
	JarLinkedService      *LinkedServiceReference           `json:"jarLinkedService,omitempty"`
	StorageLinkedServices *[]LinkedServiceReference         `json:"storageLinkedServices,omitempty"`
}

type HDInsightPigActivity

type HDInsightPigActivity struct {
	LinkedServiceName *LinkedServiceReference            `json:"linkedServiceName,omitempty"`
	Policy            *ActivityPolicy                    `json:"policy,omitempty"`
	TypeProperties    HDInsightPigActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (HDInsightPigActivity) MarshalJSON

func (s HDInsightPigActivity) MarshalJSON() ([]byte, error)

type HDInsightPigActivityTypeProperties

type HDInsightPigActivityTypeProperties struct {
	Arguments             *interface{}                      `json:"arguments,omitempty"`
	Defines               *map[string]interface{}           `json:"defines,omitempty"`
	GetDebugInfo          *HDInsightActivityDebugInfoOption `json:"getDebugInfo,omitempty"`
	ScriptLinkedService   *LinkedServiceReference           `json:"scriptLinkedService,omitempty"`
	ScriptPath            *interface{}                      `json:"scriptPath,omitempty"`
	StorageLinkedServices *[]LinkedServiceReference         `json:"storageLinkedServices,omitempty"`
}

type HDInsightSparkActivity

type HDInsightSparkActivity struct {
	LinkedServiceName *LinkedServiceReference              `json:"linkedServiceName,omitempty"`
	Policy            *ActivityPolicy                      `json:"policy,omitempty"`
	TypeProperties    HDInsightSparkActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (HDInsightSparkActivity) MarshalJSON

func (s HDInsightSparkActivity) MarshalJSON() ([]byte, error)

type HDInsightSparkActivityTypeProperties

type HDInsightSparkActivityTypeProperties struct {
	Arguments             *[]interface{}                    `json:"arguments,omitempty"`
	ClassName             *string                           `json:"className,omitempty"`
	EntryFilePath         interface{}                       `json:"entryFilePath"`
	GetDebugInfo          *HDInsightActivityDebugInfoOption `json:"getDebugInfo,omitempty"`
	ProxyUser             *interface{}                      `json:"proxyUser,omitempty"`
	RootPath              interface{}                       `json:"rootPath"`
	SparkConfig           *map[string]interface{}           `json:"sparkConfig,omitempty"`
	SparkJobLinkedService *LinkedServiceReference           `json:"sparkJobLinkedService,omitempty"`
}

type HDInsightStreamingActivity

type HDInsightStreamingActivity struct {
	LinkedServiceName *LinkedServiceReference                  `json:"linkedServiceName,omitempty"`
	Policy            *ActivityPolicy                          `json:"policy,omitempty"`
	TypeProperties    HDInsightStreamingActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (HDInsightStreamingActivity) MarshalJSON

func (s HDInsightStreamingActivity) MarshalJSON() ([]byte, error)

type HDInsightStreamingActivityTypeProperties

type HDInsightStreamingActivityTypeProperties struct {
	Arguments             *[]interface{}                    `json:"arguments,omitempty"`
	Combiner              *interface{}                      `json:"combiner,omitempty"`
	CommandEnvironment    *[]interface{}                    `json:"commandEnvironment,omitempty"`
	Defines               *map[string]interface{}           `json:"defines,omitempty"`
	FileLinkedService     *LinkedServiceReference           `json:"fileLinkedService,omitempty"`
	FilePaths             []interface{}                     `json:"filePaths"`
	GetDebugInfo          *HDInsightActivityDebugInfoOption `json:"getDebugInfo,omitempty"`
	Input                 interface{}                       `json:"input"`
	Mapper                interface{}                       `json:"mapper"`
	Output                interface{}                       `json:"output"`
	Reducer               interface{}                       `json:"reducer"`
	StorageLinkedServices *[]LinkedServiceReference         `json:"storageLinkedServices,omitempty"`
}

type HTTPReadSettings

type HTTPReadSettings struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	AdditionalHeaders        *interface{} `json:"additionalHeaders,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	RequestBody              *interface{} `json:"requestBody,omitempty"`
	RequestMethod            *interface{} `json:"requestMethod,omitempty"`
	RequestTimeout           *interface{} `json:"requestTimeout,omitempty"`
	Type                     string       `json:"type"`
}

type HTTPSource

type HTTPSource struct {
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	HTTPRequestTimeout       *interface{} `json:"httpRequestTimeout,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type HdfsReadSettings

type HdfsReadSettings struct {
	DeleteFilesAfterCompletion *interface{}    `json:"deleteFilesAfterCompletion,omitempty"`
	DisableMetricsCollection   *interface{}    `json:"disableMetricsCollection,omitempty"`
	DistcpSettings             *DistcpSettings `json:"distcpSettings,omitempty"`
	EnablePartitionDiscovery   *interface{}    `json:"enablePartitionDiscovery,omitempty"`
	FileListPath               *interface{}    `json:"fileListPath,omitempty"`
	MaxConcurrentConnections   *interface{}    `json:"maxConcurrentConnections,omitempty"`
	ModifiedDatetimeEnd        *interface{}    `json:"modifiedDatetimeEnd,omitempty"`
	ModifiedDatetimeStart      *interface{}    `json:"modifiedDatetimeStart,omitempty"`
	PartitionRootPath          *interface{}    `json:"partitionRootPath,omitempty"`
	Recursive                  *interface{}    `json:"recursive,omitempty"`
	Type                       string          `json:"type"`
	WildcardFileName           *interface{}    `json:"wildcardFileName,omitempty"`
	WildcardFolderPath         *interface{}    `json:"wildcardFolderPath,omitempty"`
}

type HdfsSource

type HdfsSource struct {
	DisableMetricsCollection *interface{}    `json:"disableMetricsCollection,omitempty"`
	DistcpSettings           *DistcpSettings `json:"distcpSettings,omitempty"`
	MaxConcurrentConnections *interface{}    `json:"maxConcurrentConnections,omitempty"`
	Recursive                *interface{}    `json:"recursive,omitempty"`
	SourceRetryCount         *interface{}    `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{}    `json:"sourceRetryWait,omitempty"`
	Type                     string          `json:"type"`
}

type HiveSource

type HiveSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type HubspotSource

type HubspotSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type IfConditionActivity

type IfConditionActivity struct {
	TypeProperties IfConditionActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (IfConditionActivity) MarshalJSON

func (s IfConditionActivity) MarshalJSON() ([]byte, error)

type IfConditionActivityTypeProperties

type IfConditionActivityTypeProperties struct {
	Expression        Expression  `json:"expression"`
	IfFalseActivities *[]Activity `json:"ifFalseActivities,omitempty"`
	IfTrueActivities  *[]Activity `json:"ifTrueActivities,omitempty"`
}

func (*IfConditionActivityTypeProperties) UnmarshalJSON

func (s *IfConditionActivityTypeProperties) UnmarshalJSON(bytes []byte) error

type ImpalaSource

type ImpalaSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type InformixSink

type InformixSink struct {
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	PreCopyScript            *interface{} `json:"preCopyScript,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	Type                     string       `json:"type"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

type InformixSource

type InformixSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type IntegrationRuntimeReference

type IntegrationRuntimeReference struct {
	Parameters    *map[string]interface{}         `json:"parameters,omitempty"`
	ReferenceName string                          `json:"referenceName"`
	Type          IntegrationRuntimeReferenceType `json:"type"`
}

type IntegrationRuntimeReferenceType

type IntegrationRuntimeReferenceType string

const (
	IntegrationRuntimeReferenceTypeIntegrationRuntimeReference IntegrationRuntimeReferenceType = "IntegrationRuntimeReference"
)

func (*IntegrationRuntimeReferenceType) UnmarshalJSON

func (s *IntegrationRuntimeReferenceType) UnmarshalJSON(bytes []byte) error

type JiraSource

type JiraSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type JsonReadSettings

type JsonReadSettings struct {
	CompressionProperties CompressionReadSettings `json:"compressionProperties"`
	Type                  string                  `json:"type"`
}

func (*JsonReadSettings) UnmarshalJSON

func (s *JsonReadSettings) UnmarshalJSON(bytes []byte) error

type JsonSink

type JsonSink struct {
	DisableMetricsCollection *interface{}       `json:"disableMetricsCollection,omitempty"`
	FormatSettings           *JsonWriteSettings `json:"formatSettings,omitempty"`
	MaxConcurrentConnections *interface{}       `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{}       `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{}       `json:"sinkRetryWait,omitempty"`
	StoreSettings            StoreWriteSettings `json:"storeSettings"`
	Type                     string             `json:"type"`
	WriteBatchSize           *interface{}       `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{}       `json:"writeBatchTimeout,omitempty"`
}

func (*JsonSink) UnmarshalJSON

func (s *JsonSink) UnmarshalJSON(bytes []byte) error

type JsonSource

type JsonSource struct {
	AdditionalColumns        *interface{}      `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{}      `json:"disableMetricsCollection,omitempty"`
	FormatSettings           *JsonReadSettings `json:"formatSettings,omitempty"`
	MaxConcurrentConnections *interface{}      `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{}      `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{}      `json:"sourceRetryWait,omitempty"`
	StoreSettings            StoreReadSettings `json:"storeSettings"`
	Type                     string            `json:"type"`
}

func (*JsonSource) UnmarshalJSON

func (s *JsonSource) UnmarshalJSON(bytes []byte) error

type JsonWriteSettings

type JsonWriteSettings struct {
	FilePattern *interface{} `json:"filePattern,omitempty"`
	Type        string       `json:"type"`
}

type LakeHouseReadSettings

type LakeHouseReadSettings struct {
	DeleteFilesAfterCompletion *interface{} `json:"deleteFilesAfterCompletion,omitempty"`
	DisableMetricsCollection   *interface{} `json:"disableMetricsCollection,omitempty"`
	EnablePartitionDiscovery   *interface{} `json:"enablePartitionDiscovery,omitempty"`
	FileListPath               *interface{} `json:"fileListPath,omitempty"`
	MaxConcurrentConnections   *interface{} `json:"maxConcurrentConnections,omitempty"`
	ModifiedDatetimeEnd        *interface{} `json:"modifiedDatetimeEnd,omitempty"`
	ModifiedDatetimeStart      *interface{} `json:"modifiedDatetimeStart,omitempty"`
	PartitionRootPath          *interface{} `json:"partitionRootPath,omitempty"`
	Recursive                  *interface{} `json:"recursive,omitempty"`
	Type                       string       `json:"type"`
	WildcardFileName           *interface{} `json:"wildcardFileName,omitempty"`
	WildcardFolderPath         *interface{} `json:"wildcardFolderPath,omitempty"`
}

type LakeHouseTableSink

type LakeHouseTableSink struct {
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	PartitionNameList        *interface{} `json:"partitionNameList,omitempty"`
	PartitionOption          *interface{} `json:"partitionOption,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	TableActionOption        *interface{} `json:"tableActionOption,omitempty"`
	Type                     string       `json:"type"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

type LakeHouseTableSource

type LakeHouseTableSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	TimestampAsOf            *interface{} `json:"timestampAsOf,omitempty"`
	Type                     string       `json:"type"`
	VersionAsOf              *interface{} `json:"versionAsOf,omitempty"`
}

type LakeHouseWriteSettings

type LakeHouseWriteSettings struct {
	CopyBehavior             *interface{}    `json:"copyBehavior,omitempty"`
	DisableMetricsCollection *interface{}    `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{}    `json:"maxConcurrentConnections,omitempty"`
	Metadata                 *[]MetadataItem `json:"metadata,omitempty"`
	Type                     string          `json:"type"`
}

type LinkedServiceReference

type LinkedServiceReference struct {
	Parameters    *map[string]interface{} `json:"parameters,omitempty"`
	ReferenceName string                  `json:"referenceName"`
	Type          Type                    `json:"type"`
}

type ListByFactoryCompleteResult

type ListByFactoryCompleteResult struct {
	LatestHttpResponse *http.Response
	Items              []PipelineResource
}

type ListByFactoryOperationResponse

type ListByFactoryOperationResponse struct {
	HttpResponse *http.Response
	OData        *odata.OData
	Model        *[]PipelineResource
}

type LogLocationSettings

type LogLocationSettings struct {
	LinkedServiceName LinkedServiceReference `json:"linkedServiceName"`
	Path              *interface{}           `json:"path,omitempty"`
}

type LogSettings

type LogSettings struct {
	CopyActivityLogSettings *CopyActivityLogSettings `json:"copyActivityLogSettings,omitempty"`
	EnableCopyActivityLog   *interface{}             `json:"enableCopyActivityLog,omitempty"`
	LogLocationSettings     LogLocationSettings      `json:"logLocationSettings"`
}

type LogStorageSettings

type LogStorageSettings struct {
	EnableReliableLogging *interface{}           `json:"enableReliableLogging,omitempty"`
	LinkedServiceName     LinkedServiceReference `json:"linkedServiceName"`
	LogLevel              *interface{}           `json:"logLevel,omitempty"`
	Path                  *interface{}           `json:"path,omitempty"`
}

type LookupActivity

type LookupActivity struct {
	LinkedServiceName *LinkedServiceReference      `json:"linkedServiceName,omitempty"`
	Policy            *ActivityPolicy              `json:"policy,omitempty"`
	TypeProperties    LookupActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (LookupActivity) MarshalJSON

func (s LookupActivity) MarshalJSON() ([]byte, error)

type LookupActivityTypeProperties

type LookupActivityTypeProperties struct {
	Dataset      DatasetReference `json:"dataset"`
	FirstRowOnly *interface{}     `json:"firstRowOnly,omitempty"`
	Source       CopySource       `json:"source"`
}

func (*LookupActivityTypeProperties) UnmarshalJSON

func (s *LookupActivityTypeProperties) UnmarshalJSON(bytes []byte) error

type MagentoSource

type MagentoSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type MariaDBSource

type MariaDBSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type MarketoSource

type MarketoSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type MetadataItem

type MetadataItem struct {
	Name  *interface{} `json:"name,omitempty"`
	Value *interface{} `json:"value,omitempty"`
}

type MicrosoftAccessSink

type MicrosoftAccessSink struct {
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	PreCopyScript            *interface{} `json:"preCopyScript,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	Type                     string       `json:"type"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

type MicrosoftAccessSource

type MicrosoftAccessSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type MongoDbAtlasSink

type MongoDbAtlasSink struct {
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	Type                     string       `json:"type"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
	WriteBehavior            *interface{} `json:"writeBehavior,omitempty"`
}

type MongoDbAtlasSource

type MongoDbAtlasSource struct {
	AdditionalColumns        *interface{}                    `json:"additionalColumns,omitempty"`
	BatchSize                *interface{}                    `json:"batchSize,omitempty"`
	CursorMethods            *MongoDbCursorMethodsProperties `json:"cursorMethods,omitempty"`
	DisableMetricsCollection *interface{}                    `json:"disableMetricsCollection,omitempty"`
	Filter                   *interface{}                    `json:"filter,omitempty"`
	MaxConcurrentConnections *interface{}                    `json:"maxConcurrentConnections,omitempty"`
	QueryTimeout             *interface{}                    `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{}                    `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{}                    `json:"sourceRetryWait,omitempty"`
	Type                     string                          `json:"type"`
}

type MongoDbCursorMethodsProperties

type MongoDbCursorMethodsProperties struct {
	Limit   *interface{} `json:"limit,omitempty"`
	Project *interface{} `json:"project,omitempty"`
	Skip    *interface{} `json:"skip,omitempty"`
	Sort    *interface{} `json:"sort,omitempty"`
}

type MongoDbSource

type MongoDbSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type MongoDbV2Sink

type MongoDbV2Sink struct {
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	Type                     string       `json:"type"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
	WriteBehavior            *interface{} `json:"writeBehavior,omitempty"`
}

type MongoDbV2Source

type MongoDbV2Source struct {
	AdditionalColumns        *interface{}                    `json:"additionalColumns,omitempty"`
	BatchSize                *interface{}                    `json:"batchSize,omitempty"`
	CursorMethods            *MongoDbCursorMethodsProperties `json:"cursorMethods,omitempty"`
	DisableMetricsCollection *interface{}                    `json:"disableMetricsCollection,omitempty"`
	Filter                   *interface{}                    `json:"filter,omitempty"`
	MaxConcurrentConnections *interface{}                    `json:"maxConcurrentConnections,omitempty"`
	QueryTimeout             *interface{}                    `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{}                    `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{}                    `json:"sourceRetryWait,omitempty"`
	Type                     string                          `json:"type"`
}

type MySqlSource

type MySqlSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type NetezzaPartitionSettings

type NetezzaPartitionSettings struct {
	PartitionColumnName *interface{} `json:"partitionColumnName,omitempty"`
	PartitionLowerBound *interface{} `json:"partitionLowerBound,omitempty"`
	PartitionUpperBound *interface{} `json:"partitionUpperBound,omitempty"`
}

type NetezzaSource

type NetezzaSource struct {
	AdditionalColumns        *interface{}              `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{}              `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{}              `json:"maxConcurrentConnections,omitempty"`
	PartitionOption          *interface{}              `json:"partitionOption,omitempty"`
	PartitionSettings        *NetezzaPartitionSettings `json:"partitionSettings,omitempty"`
	Query                    *interface{}              `json:"query,omitempty"`
	QueryTimeout             *interface{}              `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{}              `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{}              `json:"sourceRetryWait,omitempty"`
	Type                     string                    `json:"type"`
}

type NotebookParameter

type NotebookParameter struct {
	Type  *NotebookParameterType `json:"type,omitempty"`
	Value *interface{}           `json:"value,omitempty"`
}

type NotebookParameterType

type NotebookParameterType string

const (
	NotebookParameterTypeBool   NotebookParameterType = "bool"
	NotebookParameterTypeFloat  NotebookParameterType = "float"
	NotebookParameterTypeInt    NotebookParameterType = "int"
	NotebookParameterTypeString NotebookParameterType = "string"
)

func (*NotebookParameterType) UnmarshalJSON

func (s *NotebookParameterType) UnmarshalJSON(bytes []byte) error

type NotebookReferenceType

type NotebookReferenceType string

const (
	NotebookReferenceTypeNotebookReference NotebookReferenceType = "NotebookReference"
)

func (*NotebookReferenceType) UnmarshalJSON

func (s *NotebookReferenceType) UnmarshalJSON(bytes []byte) error

type ODataSource

type ODataSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	HTTPRequestTimeout       *interface{} `json:"httpRequestTimeout,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type OdbcSink

type OdbcSink struct {
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	PreCopyScript            *interface{} `json:"preCopyScript,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	Type                     string       `json:"type"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

type OdbcSource

type OdbcSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type Office365Source

type Office365Source struct {
	AllowedGroups            *interface{} `json:"allowedGroups,omitempty"`
	DateFilterColumn         *interface{} `json:"dateFilterColumn,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	EndTime                  *interface{} `json:"endTime,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	OutputColumns            *interface{} `json:"outputColumns,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	StartTime                *interface{} `json:"startTime,omitempty"`
	Type                     string       `json:"type"`
	UserScopeFilterUri       *interface{} `json:"userScopeFilterUri,omitempty"`
}

type OracleCloudStorageReadSettings

type OracleCloudStorageReadSettings struct {
	DeleteFilesAfterCompletion *interface{} `json:"deleteFilesAfterCompletion,omitempty"`
	DisableMetricsCollection   *interface{} `json:"disableMetricsCollection,omitempty"`
	EnablePartitionDiscovery   *interface{} `json:"enablePartitionDiscovery,omitempty"`
	FileListPath               *interface{} `json:"fileListPath,omitempty"`
	MaxConcurrentConnections   *interface{} `json:"maxConcurrentConnections,omitempty"`
	ModifiedDatetimeEnd        *interface{} `json:"modifiedDatetimeEnd,omitempty"`
	ModifiedDatetimeStart      *interface{} `json:"modifiedDatetimeStart,omitempty"`
	PartitionRootPath          *interface{} `json:"partitionRootPath,omitempty"`
	Prefix                     *interface{} `json:"prefix,omitempty"`
	Recursive                  *interface{} `json:"recursive,omitempty"`
	Type                       string       `json:"type"`
	WildcardFileName           *interface{} `json:"wildcardFileName,omitempty"`
	WildcardFolderPath         *interface{} `json:"wildcardFolderPath,omitempty"`
}

type OraclePartitionSettings

type OraclePartitionSettings struct {
	PartitionColumnName *interface{} `json:"partitionColumnName,omitempty"`
	PartitionLowerBound *interface{} `json:"partitionLowerBound,omitempty"`
	PartitionNames      *interface{} `json:"partitionNames,omitempty"`
	PartitionUpperBound *interface{} `json:"partitionUpperBound,omitempty"`
}

type OracleServiceCloudSource

type OracleServiceCloudSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type OracleSink

type OracleSink struct {
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	PreCopyScript            *interface{} `json:"preCopyScript,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	Type                     string       `json:"type"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

type OracleSource

type OracleSource struct {
	AdditionalColumns        *interface{}             `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{}             `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{}             `json:"maxConcurrentConnections,omitempty"`
	OracleReaderQuery        *interface{}             `json:"oracleReaderQuery,omitempty"`
	PartitionOption          *interface{}             `json:"partitionOption,omitempty"`
	PartitionSettings        *OraclePartitionSettings `json:"partitionSettings,omitempty"`
	QueryTimeout             *interface{}             `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{}             `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{}             `json:"sourceRetryWait,omitempty"`
	Type                     string                   `json:"type"`
}

type OrcSink

type OrcSink struct {
	DisableMetricsCollection *interface{}       `json:"disableMetricsCollection,omitempty"`
	FormatSettings           *OrcWriteSettings  `json:"formatSettings,omitempty"`
	MaxConcurrentConnections *interface{}       `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{}       `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{}       `json:"sinkRetryWait,omitempty"`
	StoreSettings            StoreWriteSettings `json:"storeSettings"`
	Type                     string             `json:"type"`
	WriteBatchSize           *interface{}       `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{}       `json:"writeBatchTimeout,omitempty"`
}

func (*OrcSink) UnmarshalJSON

func (s *OrcSink) UnmarshalJSON(bytes []byte) error

type OrcSource

type OrcSource struct {
	AdditionalColumns        *interface{}      `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{}      `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{}      `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{}      `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{}      `json:"sourceRetryWait,omitempty"`
	StoreSettings            StoreReadSettings `json:"storeSettings"`
	Type                     string            `json:"type"`
}

func (*OrcSource) UnmarshalJSON

func (s *OrcSource) UnmarshalJSON(bytes []byte) error

type OrcWriteSettings

type OrcWriteSettings struct {
	FileNamePrefix *interface{} `json:"fileNamePrefix,omitempty"`
	MaxRowsPerFile *interface{} `json:"maxRowsPerFile,omitempty"`
	Type           string       `json:"type"`
}

type ParameterSpecification

type ParameterSpecification struct {
	DefaultValue *interface{}  `json:"defaultValue,omitempty"`
	Type         ParameterType `json:"type"`
}

type ParameterType

type ParameterType string

const (
	ParameterTypeArray        ParameterType = "Array"
	ParameterTypeBool         ParameterType = "Bool"
	ParameterTypeFloat        ParameterType = "Float"
	ParameterTypeInt          ParameterType = "Int"
	ParameterTypeObject       ParameterType = "Object"
	ParameterTypeSecureString ParameterType = "SecureString"
	ParameterTypeString       ParameterType = "String"
)

func (*ParameterType) UnmarshalJSON

func (s *ParameterType) UnmarshalJSON(bytes []byte) error

type ParquetReadSettings

type ParquetReadSettings struct {
	CompressionProperties CompressionReadSettings `json:"compressionProperties"`
	Type                  string                  `json:"type"`
}

func (*ParquetReadSettings) UnmarshalJSON

func (s *ParquetReadSettings) UnmarshalJSON(bytes []byte) error

type ParquetSink

type ParquetSink struct {
	DisableMetricsCollection *interface{}          `json:"disableMetricsCollection,omitempty"`
	FormatSettings           *ParquetWriteSettings `json:"formatSettings,omitempty"`
	MaxConcurrentConnections *interface{}          `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{}          `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{}          `json:"sinkRetryWait,omitempty"`
	StoreSettings            StoreWriteSettings    `json:"storeSettings"`
	Type                     string                `json:"type"`
	WriteBatchSize           *interface{}          `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{}          `json:"writeBatchTimeout,omitempty"`
}

func (*ParquetSink) UnmarshalJSON

func (s *ParquetSink) UnmarshalJSON(bytes []byte) error

type ParquetSource

type ParquetSource struct {
	AdditionalColumns        *interface{}         `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{}         `json:"disableMetricsCollection,omitempty"`
	FormatSettings           *ParquetReadSettings `json:"formatSettings,omitempty"`
	MaxConcurrentConnections *interface{}         `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{}         `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{}         `json:"sourceRetryWait,omitempty"`
	StoreSettings            StoreReadSettings    `json:"storeSettings"`
	Type                     string               `json:"type"`
}

func (*ParquetSource) UnmarshalJSON

func (s *ParquetSource) UnmarshalJSON(bytes []byte) error

type ParquetWriteSettings

type ParquetWriteSettings struct {
	FileNamePrefix *interface{} `json:"fileNamePrefix,omitempty"`
	MaxRowsPerFile *interface{} `json:"maxRowsPerFile,omitempty"`
	Type           string       `json:"type"`
}

type PaypalSource

type PaypalSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type PhoenixSource

type PhoenixSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type Pipeline

type Pipeline struct {
	Activities    *[]Activity                        `json:"activities,omitempty"`
	Annotations   *[]interface{}                     `json:"annotations,omitempty"`
	Concurrency   *int64                             `json:"concurrency,omitempty"`
	Description   *string                            `json:"description,omitempty"`
	Folder        *PipelineFolder                    `json:"folder,omitempty"`
	Parameters    *map[string]ParameterSpecification `json:"parameters,omitempty"`
	Policy        *PipelinePolicy                    `json:"policy,omitempty"`
	RunDimensions *map[string]interface{}            `json:"runDimensions,omitempty"`
	Variables     *map[string]VariableSpecification  `json:"variables,omitempty"`
}

func (*Pipeline) UnmarshalJSON

func (s *Pipeline) UnmarshalJSON(bytes []byte) error

type PipelineElapsedTimeMetricPolicy

type PipelineElapsedTimeMetricPolicy struct {
	Duration *interface{} `json:"duration,omitempty"`
}

type PipelineFolder

type PipelineFolder struct {
	Name *string `json:"name,omitempty"`
}

type PipelineId

type PipelineId struct {
	SubscriptionId    string
	ResourceGroupName string
	FactoryName       string
	PipelineName      string
}

PipelineId is a struct representing the Resource ID for a Pipeline

func NewPipelineID

func NewPipelineID(subscriptionId string, resourceGroupName string, factoryName string, pipelineName string) PipelineId

NewPipelineID returns a new PipelineId struct

func ParsePipelineID

func ParsePipelineID(input string) (*PipelineId, error)

ParsePipelineID parses 'input' into a PipelineId

func ParsePipelineIDInsensitively

func ParsePipelineIDInsensitively(input string) (*PipelineId, error)

ParsePipelineIDInsensitively parses 'input' case-insensitively into a PipelineId note: this method should only be used for API response data and not user input

func (*PipelineId) FromParseResult

func (id *PipelineId) FromParseResult(input resourceids.ParseResult) error

func (PipelineId) ID

func (id PipelineId) ID() string

ID returns the formatted Pipeline ID

func (PipelineId) Segments

func (id PipelineId) Segments() []resourceids.Segment

Segments returns a slice of Resource ID Segments which comprise this Pipeline ID

func (PipelineId) String

func (id PipelineId) String() string

String returns a human-readable description of this Pipeline ID

type PipelinePolicy

type PipelinePolicy struct {
	ElapsedTimeMetric *PipelineElapsedTimeMetricPolicy `json:"elapsedTimeMetric,omitempty"`
}

type PipelineReference

type PipelineReference struct {
	Name          *string               `json:"name,omitempty"`
	ReferenceName string                `json:"referenceName"`
	Type          PipelineReferenceType `json:"type"`
}

type PipelineReferenceType

type PipelineReferenceType string

const (
	PipelineReferenceTypePipelineReference PipelineReferenceType = "PipelineReference"
)

func (*PipelineReferenceType) UnmarshalJSON

func (s *PipelineReferenceType) UnmarshalJSON(bytes []byte) error

type PipelineResource

type PipelineResource struct {
	Etag       *string  `json:"etag,omitempty"`
	Id         *string  `json:"id,omitempty"`
	Name       *string  `json:"name,omitempty"`
	Properties Pipeline `json:"properties"`
	Type       *string  `json:"type,omitempty"`
}

type PipelineResourceOperationPredicate

type PipelineResourceOperationPredicate struct {
	Etag *string
	Id   *string
	Name *string
	Type *string
}

func (PipelineResourceOperationPredicate) Matches

func (p PipelineResourceOperationPredicate) Matches(input PipelineResource) bool

type PipelinesClient

type PipelinesClient struct {
	Client *resourcemanager.Client
}

func NewPipelinesClientWithBaseURI

func NewPipelinesClientWithBaseURI(sdkApi sdkEnv.Api) (*PipelinesClient, error)

func (PipelinesClient) CreateOrUpdate

func (c PipelinesClient) CreateOrUpdate(ctx context.Context, id PipelineId, input PipelineResource, options CreateOrUpdateOperationOptions) (result CreateOrUpdateOperationResponse, err error)

CreateOrUpdate ...

func (PipelinesClient) CreateRun

func (c PipelinesClient) CreateRun(ctx context.Context, id PipelineId, input map[string]interface{}, options CreateRunOperationOptions) (result CreateRunOperationResponse, err error)

CreateRun ...

func (PipelinesClient) Delete

func (c PipelinesClient) Delete(ctx context.Context, id PipelineId) (result DeleteOperationResponse, err error)

Delete ...

func (PipelinesClient) Get

func (c PipelinesClient) Get(ctx context.Context, id PipelineId, options GetOperationOptions) (result GetOperationResponse, err error)

Get ...

func (PipelinesClient) ListByFactory

func (c PipelinesClient) ListByFactory(ctx context.Context, id FactoryId) (result ListByFactoryOperationResponse, err error)

ListByFactory ...

func (PipelinesClient) ListByFactoryComplete

func (c PipelinesClient) ListByFactoryComplete(ctx context.Context, id FactoryId) (ListByFactoryCompleteResult, error)

ListByFactoryComplete retrieves all the results into a single object

func (PipelinesClient) ListByFactoryCompleteMatchingPredicate

func (c PipelinesClient) ListByFactoryCompleteMatchingPredicate(ctx context.Context, id FactoryId, predicate PipelineResourceOperationPredicate) (result ListByFactoryCompleteResult, err error)

ListByFactoryCompleteMatchingPredicate retrieves all the results and then applies the predicate

type PolybaseSettings

type PolybaseSettings struct {
	RejectSampleValue *interface{}                `json:"rejectSampleValue,omitempty"`
	RejectType        *PolybaseSettingsRejectType `json:"rejectType,omitempty"`
	RejectValue       *interface{}                `json:"rejectValue,omitempty"`
	UseTypeDefault    *interface{}                `json:"useTypeDefault,omitempty"`
}

type PolybaseSettingsRejectType

type PolybaseSettingsRejectType string

const (
	PolybaseSettingsRejectTypePercentage PolybaseSettingsRejectType = "percentage"
	PolybaseSettingsRejectTypeValue      PolybaseSettingsRejectType = "value"
)

func (*PolybaseSettingsRejectType) UnmarshalJSON

func (s *PolybaseSettingsRejectType) UnmarshalJSON(bytes []byte) error

type PostgreSqlSource

type PostgreSqlSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type PostgreSqlV2Source

type PostgreSqlV2Source struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type PowerQuerySink

type PowerQuerySink struct {
	Dataset                   *DatasetReference       `json:"dataset,omitempty"`
	Description               *string                 `json:"description,omitempty"`
	Flowlet                   *DataFlowReference      `json:"flowlet,omitempty"`
	LinkedService             *LinkedServiceReference `json:"linkedService,omitempty"`
	Name                      string                  `json:"name"`
	RejectedDataLinkedService *LinkedServiceReference `json:"rejectedDataLinkedService,omitempty"`
	SchemaLinkedService       *LinkedServiceReference `json:"schemaLinkedService,omitempty"`
	Script                    *string                 `json:"script,omitempty"`
}

type PowerQuerySinkMapping

type PowerQuerySinkMapping struct {
	DataflowSinks *[]PowerQuerySink `json:"dataflowSinks,omitempty"`
	QueryName     *string           `json:"queryName,omitempty"`
}

type PrestoSource

type PrestoSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type QuickBooksSource

type QuickBooksSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type RawActivityImpl

type RawActivityImpl struct {
	Type   string
	Values map[string]interface{}
}

RawActivityImpl is returned when the Discriminated Value doesn't match any of the defined types NOTE: this should only be used when a type isn't defined for this type of Object (as a workaround) and is used only for Deserialization (e.g. this cannot be used as a Request Payload).

type RawCompressionReadSettingsImpl

type RawCompressionReadSettingsImpl struct {
	Type   string
	Values map[string]interface{}
}

RawCompressionReadSettingsImpl is returned when the Discriminated Value doesn't match any of the defined types NOTE: this should only be used when a type isn't defined for this type of Object (as a workaround) and is used only for Deserialization (e.g. this cannot be used as a Request Payload).

type RawCopySinkImpl

type RawCopySinkImpl struct {
	Type   string
	Values map[string]interface{}
}

RawCopySinkImpl is returned when the Discriminated Value doesn't match any of the defined types NOTE: this should only be used when a type isn't defined for this type of Object (as a workaround) and is used only for Deserialization (e.g. this cannot be used as a Request Payload).

type RawCopySourceImpl

type RawCopySourceImpl struct {
	Type   string
	Values map[string]interface{}
}

RawCopySourceImpl is returned when the Discriminated Value doesn't match any of the defined types NOTE: this should only be used when a type isn't defined for this type of Object (as a workaround) and is used only for Deserialization (e.g. this cannot be used as a Request Payload).

type RawFormatReadSettingsImpl

type RawFormatReadSettingsImpl struct {
	Type   string
	Values map[string]interface{}
}

RawFormatReadSettingsImpl is returned when the Discriminated Value doesn't match any of the defined types NOTE: this should only be used when a type isn't defined for this type of Object (as a workaround) and is used only for Deserialization (e.g. this cannot be used as a Request Payload).

type RawSecretBaseImpl

type RawSecretBaseImpl struct {
	Type   string
	Values map[string]interface{}
}

RawSecretBaseImpl is returned when the Discriminated Value doesn't match any of the defined types NOTE: this should only be used when a type isn't defined for this type of Object (as a workaround) and is used only for Deserialization (e.g. this cannot be used as a Request Payload).

type RawStoreReadSettingsImpl

type RawStoreReadSettingsImpl struct {
	Type   string
	Values map[string]interface{}
}

RawStoreReadSettingsImpl is returned when the Discriminated Value doesn't match any of the defined types NOTE: this should only be used when a type isn't defined for this type of Object (as a workaround) and is used only for Deserialization (e.g. this cannot be used as a Request Payload).

type RawStoreWriteSettingsImpl

type RawStoreWriteSettingsImpl struct {
	Type   string
	Values map[string]interface{}
}

RawStoreWriteSettingsImpl is returned when the Discriminated Value doesn't match any of the defined types NOTE: this should only be used when a type isn't defined for this type of Object (as a workaround) and is used only for Deserialization (e.g. this cannot be used as a Request Payload).

type RedirectIncompatibleRowSettings

type RedirectIncompatibleRowSettings struct {
	LinkedServiceName interface{}  `json:"linkedServiceName"`
	Path              *interface{} `json:"path,omitempty"`
}

type RedshiftUnloadSettings

type RedshiftUnloadSettings struct {
	BucketName          interface{}            `json:"bucketName"`
	S3LinkedServiceName LinkedServiceReference `json:"s3LinkedServiceName"`
}

type RelationalSource

type RelationalSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type ResponsysSource

type ResponsysSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type RestSink

type RestSink struct {
	AdditionalHeaders        *interface{} `json:"additionalHeaders,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	HTTPCompressionType      *interface{} `json:"httpCompressionType,omitempty"`
	HTTPRequestTimeout       *interface{} `json:"httpRequestTimeout,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	RequestInterval          *interface{} `json:"requestInterval,omitempty"`
	RequestMethod            *interface{} `json:"requestMethod,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	Type                     string       `json:"type"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

type RestSource

type RestSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	AdditionalHeaders        *interface{} `json:"additionalHeaders,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	HTTPRequestTimeout       *interface{} `json:"httpRequestTimeout,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	PaginationRules          *interface{} `json:"paginationRules,omitempty"`
	RequestBody              *interface{} `json:"requestBody,omitempty"`
	RequestInterval          *interface{} `json:"requestInterval,omitempty"`
	RequestMethod            *interface{} `json:"requestMethod,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type SSISAccessCredential

type SSISAccessCredential struct {
	Domain   interface{} `json:"domain"`
	Password SecretBase  `json:"password"`
	UserName interface{} `json:"userName"`
}

func (*SSISAccessCredential) UnmarshalJSON

func (s *SSISAccessCredential) UnmarshalJSON(bytes []byte) error

type SSISChildPackage

type SSISChildPackage struct {
	PackageContent          interface{} `json:"packageContent"`
	PackageLastModifiedDate *string     `json:"packageLastModifiedDate,omitempty"`
	PackageName             *string     `json:"packageName,omitempty"`
	PackagePath             interface{} `json:"packagePath"`
}

type SSISExecutionCredential

type SSISExecutionCredential struct {
	Domain   interface{}  `json:"domain"`
	Password SecureString `json:"password"`
	UserName interface{}  `json:"userName"`
}

type SSISExecutionParameter

type SSISExecutionParameter struct {
	Value interface{} `json:"value"`
}

type SSISLogLocation

type SSISLogLocation struct {
	LogPath        interface{}                   `json:"logPath"`
	Type           SsisLogLocationType           `json:"type"`
	TypeProperties SSISLogLocationTypeProperties `json:"typeProperties"`
}

type SSISLogLocationTypeProperties

type SSISLogLocationTypeProperties struct {
	AccessCredential   *SSISAccessCredential `json:"accessCredential,omitempty"`
	LogRefreshInterval *interface{}          `json:"logRefreshInterval,omitempty"`
}

type SSISPackageLocation

type SSISPackageLocation struct {
	PackagePath    *interface{}                       `json:"packagePath,omitempty"`
	Type           *SsisPackageLocationType           `json:"type,omitempty"`
	TypeProperties *SSISPackageLocationTypeProperties `json:"typeProperties,omitempty"`
}

type SSISPackageLocationTypeProperties

type SSISPackageLocationTypeProperties struct {
	AccessCredential              *SSISAccessCredential `json:"accessCredential,omitempty"`
	ChildPackages                 *[]SSISChildPackage   `json:"childPackages,omitempty"`
	ConfigurationAccessCredential *SSISAccessCredential `json:"configurationAccessCredential,omitempty"`
	ConfigurationPath             *interface{}          `json:"configurationPath,omitempty"`
	PackageContent                *interface{}          `json:"packageContent,omitempty"`
	PackageLastModifiedDate       *string               `json:"packageLastModifiedDate,omitempty"`
	PackageName                   *string               `json:"packageName,omitempty"`
	PackagePassword               SecretBase            `json:"packagePassword"`
}

func (*SSISPackageLocationTypeProperties) UnmarshalJSON

func (s *SSISPackageLocationTypeProperties) UnmarshalJSON(bytes []byte) error

type SSISPropertyOverride

type SSISPropertyOverride struct {
	IsSensitive *bool       `json:"isSensitive,omitempty"`
	Value       interface{} `json:"value"`
}

type SalesforceMarketingCloudSource

type SalesforceMarketingCloudSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type SalesforceServiceCloudSink

type SalesforceServiceCloudSink struct {
	DisableMetricsCollection *interface{}                 `json:"disableMetricsCollection,omitempty"`
	ExternalIdFieldName      *interface{}                 `json:"externalIdFieldName,omitempty"`
	IgnoreNullValues         *interface{}                 `json:"ignoreNullValues,omitempty"`
	MaxConcurrentConnections *interface{}                 `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{}                 `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{}                 `json:"sinkRetryWait,omitempty"`
	Type                     string                       `json:"type"`
	WriteBatchSize           *interface{}                 `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{}                 `json:"writeBatchTimeout,omitempty"`
	WriteBehavior            *SalesforceSinkWriteBehavior `json:"writeBehavior,omitempty"`
}

type SalesforceServiceCloudSource

type SalesforceServiceCloudSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	ReadBehavior             *interface{} `json:"readBehavior,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type SalesforceServiceCloudV2Sink

type SalesforceServiceCloudV2Sink struct {
	DisableMetricsCollection *interface{}                   `json:"disableMetricsCollection,omitempty"`
	ExternalIdFieldName      *interface{}                   `json:"externalIdFieldName,omitempty"`
	IgnoreNullValues         *interface{}                   `json:"ignoreNullValues,omitempty"`
	MaxConcurrentConnections *interface{}                   `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{}                   `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{}                   `json:"sinkRetryWait,omitempty"`
	Type                     string                         `json:"type"`
	WriteBatchSize           *interface{}                   `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{}                   `json:"writeBatchTimeout,omitempty"`
	WriteBehavior            *SalesforceV2SinkWriteBehavior `json:"writeBehavior,omitempty"`
}

type SalesforceServiceCloudV2Source

type SalesforceServiceCloudV2Source struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	IncludeDeletedObjects    *interface{} `json:"includeDeletedObjects,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SOQLQuery                *interface{} `json:"SOQLQuery,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type SalesforceSink

type SalesforceSink struct {
	DisableMetricsCollection *interface{}                 `json:"disableMetricsCollection,omitempty"`
	ExternalIdFieldName      *interface{}                 `json:"externalIdFieldName,omitempty"`
	IgnoreNullValues         *interface{}                 `json:"ignoreNullValues,omitempty"`
	MaxConcurrentConnections *interface{}                 `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{}                 `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{}                 `json:"sinkRetryWait,omitempty"`
	Type                     string                       `json:"type"`
	WriteBatchSize           *interface{}                 `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{}                 `json:"writeBatchTimeout,omitempty"`
	WriteBehavior            *SalesforceSinkWriteBehavior `json:"writeBehavior,omitempty"`
}

type SalesforceSinkWriteBehavior

type SalesforceSinkWriteBehavior string

const (
	SalesforceSinkWriteBehaviorInsert SalesforceSinkWriteBehavior = "Insert"
	SalesforceSinkWriteBehaviorUpsert SalesforceSinkWriteBehavior = "Upsert"
)

func (*SalesforceSinkWriteBehavior) UnmarshalJSON

func (s *SalesforceSinkWriteBehavior) UnmarshalJSON(bytes []byte) error

type SalesforceSource

type SalesforceSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	ReadBehavior             *interface{} `json:"readBehavior,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type SalesforceV2Sink

type SalesforceV2Sink struct {
	DisableMetricsCollection *interface{}                   `json:"disableMetricsCollection,omitempty"`
	ExternalIdFieldName      *interface{}                   `json:"externalIdFieldName,omitempty"`
	IgnoreNullValues         *interface{}                   `json:"ignoreNullValues,omitempty"`
	MaxConcurrentConnections *interface{}                   `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{}                   `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{}                   `json:"sinkRetryWait,omitempty"`
	Type                     string                         `json:"type"`
	WriteBatchSize           *interface{}                   `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{}                   `json:"writeBatchTimeout,omitempty"`
	WriteBehavior            *SalesforceV2SinkWriteBehavior `json:"writeBehavior,omitempty"`
}

type SalesforceV2SinkWriteBehavior

type SalesforceV2SinkWriteBehavior string

const (
	SalesforceV2SinkWriteBehaviorInsert SalesforceV2SinkWriteBehavior = "Insert"
	SalesforceV2SinkWriteBehaviorUpsert SalesforceV2SinkWriteBehavior = "Upsert"
)

func (*SalesforceV2SinkWriteBehavior) UnmarshalJSON

func (s *SalesforceV2SinkWriteBehavior) UnmarshalJSON(bytes []byte) error

type SalesforceV2Source

type SalesforceV2Source struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	IncludeDeletedObjects    *interface{} `json:"includeDeletedObjects,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SOQLQuery                *interface{} `json:"SOQLQuery,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type SapBwSource

type SapBwSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type SapCloudForCustomerSink

type SapCloudForCustomerSink struct {
	DisableMetricsCollection *interface{}                          `json:"disableMetricsCollection,omitempty"`
	HTTPRequestTimeout       *interface{}                          `json:"httpRequestTimeout,omitempty"`
	MaxConcurrentConnections *interface{}                          `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{}                          `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{}                          `json:"sinkRetryWait,omitempty"`
	Type                     string                                `json:"type"`
	WriteBatchSize           *interface{}                          `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{}                          `json:"writeBatchTimeout,omitempty"`
	WriteBehavior            *SapCloudForCustomerSinkWriteBehavior `json:"writeBehavior,omitempty"`
}

type SapCloudForCustomerSinkWriteBehavior

type SapCloudForCustomerSinkWriteBehavior string

const (
	SapCloudForCustomerSinkWriteBehaviorInsert SapCloudForCustomerSinkWriteBehavior = "Insert"
	SapCloudForCustomerSinkWriteBehaviorUpdate SapCloudForCustomerSinkWriteBehavior = "Update"
)

func (*SapCloudForCustomerSinkWriteBehavior) UnmarshalJSON

func (s *SapCloudForCustomerSinkWriteBehavior) UnmarshalJSON(bytes []byte) error

type SapCloudForCustomerSource

type SapCloudForCustomerSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	HTTPRequestTimeout       *interface{} `json:"httpRequestTimeout,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type SapEccSource

type SapEccSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	HTTPRequestTimeout       *interface{} `json:"httpRequestTimeout,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type SapHanaPartitionSettings

type SapHanaPartitionSettings struct {
	PartitionColumnName *interface{} `json:"partitionColumnName,omitempty"`
}

type SapHanaSource

type SapHanaSource struct {
	AdditionalColumns        *interface{}              `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{}              `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{}              `json:"maxConcurrentConnections,omitempty"`
	PacketSize               *interface{}              `json:"packetSize,omitempty"`
	PartitionOption          *interface{}              `json:"partitionOption,omitempty"`
	PartitionSettings        *SapHanaPartitionSettings `json:"partitionSettings,omitempty"`
	Query                    *interface{}              `json:"query,omitempty"`
	QueryTimeout             *interface{}              `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{}              `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{}              `json:"sourceRetryWait,omitempty"`
	Type                     string                    `json:"type"`
}

type SapOdpSource

type SapOdpSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	ExtractionMode           *interface{} `json:"extractionMode,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Projection               *interface{} `json:"projection,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	Selection                *interface{} `json:"selection,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	SubscriberProcess        *interface{} `json:"subscriberProcess,omitempty"`
	Type                     string       `json:"type"`
}

type SapOpenHubSource

type SapOpenHubSource struct {
	AdditionalColumns                *interface{} `json:"additionalColumns,omitempty"`
	BaseRequestId                    *interface{} `json:"baseRequestId,omitempty"`
	CustomRfcReadTableFunctionModule *interface{} `json:"customRfcReadTableFunctionModule,omitempty"`
	DisableMetricsCollection         *interface{} `json:"disableMetricsCollection,omitempty"`
	ExcludeLastRequest               *interface{} `json:"excludeLastRequest,omitempty"`
	MaxConcurrentConnections         *interface{} `json:"maxConcurrentConnections,omitempty"`
	QueryTimeout                     *interface{} `json:"queryTimeout,omitempty"`
	SapDataColumnDelimiter           *interface{} `json:"sapDataColumnDelimiter,omitempty"`
	SourceRetryCount                 *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait                  *interface{} `json:"sourceRetryWait,omitempty"`
	Type                             string       `json:"type"`
}

type SapTablePartitionSettings

type SapTablePartitionSettings struct {
	MaxPartitionsNumber *interface{} `json:"maxPartitionsNumber,omitempty"`
	PartitionColumnName *interface{} `json:"partitionColumnName,omitempty"`
	PartitionLowerBound *interface{} `json:"partitionLowerBound,omitempty"`
	PartitionUpperBound *interface{} `json:"partitionUpperBound,omitempty"`
}

type SapTableSource

type SapTableSource struct {
	AdditionalColumns                *interface{}               `json:"additionalColumns,omitempty"`
	BatchSize                        *interface{}               `json:"batchSize,omitempty"`
	CustomRfcReadTableFunctionModule *interface{}               `json:"customRfcReadTableFunctionModule,omitempty"`
	DisableMetricsCollection         *interface{}               `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections         *interface{}               `json:"maxConcurrentConnections,omitempty"`
	PartitionOption                  *interface{}               `json:"partitionOption,omitempty"`
	PartitionSettings                *SapTablePartitionSettings `json:"partitionSettings,omitempty"`
	QueryTimeout                     *interface{}               `json:"queryTimeout,omitempty"`
	RfcTableFields                   *interface{}               `json:"rfcTableFields,omitempty"`
	RfcTableOptions                  *interface{}               `json:"rfcTableOptions,omitempty"`
	RowCount                         *interface{}               `json:"rowCount,omitempty"`
	RowSkips                         *interface{}               `json:"rowSkips,omitempty"`
	SapDataColumnDelimiter           *interface{}               `json:"sapDataColumnDelimiter,omitempty"`
	SourceRetryCount                 *interface{}               `json:"sourceRetryCount,omitempty"`
	SourceRetryWait                  *interface{}               `json:"sourceRetryWait,omitempty"`
	Type                             string                     `json:"type"`
}

type ScriptActivity

type ScriptActivity struct {
	LinkedServiceName *LinkedServiceReference      `json:"linkedServiceName,omitempty"`
	Policy            *ActivityPolicy              `json:"policy,omitempty"`
	TypeProperties    ScriptActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (ScriptActivity) MarshalJSON

func (s ScriptActivity) MarshalJSON() ([]byte, error)

type ScriptActivityLogDestination

type ScriptActivityLogDestination string

const (
	ScriptActivityLogDestinationActivityOutput ScriptActivityLogDestination = "ActivityOutput"
	ScriptActivityLogDestinationExternalStore  ScriptActivityLogDestination = "ExternalStore"
)

func (*ScriptActivityLogDestination) UnmarshalJSON

func (s *ScriptActivityLogDestination) UnmarshalJSON(bytes []byte) error

type ScriptActivityParameter

type ScriptActivityParameter struct {
	Direction *ScriptActivityParameterDirection `json:"direction,omitempty"`
	Name      *interface{}                      `json:"name,omitempty"`
	Size      *int64                            `json:"size,omitempty"`
	Type      *ScriptActivityParameterType      `json:"type,omitempty"`
	Value     *interface{}                      `json:"value,omitempty"`
}

type ScriptActivityParameterDirection

type ScriptActivityParameterDirection string

const (
	ScriptActivityParameterDirectionInput       ScriptActivityParameterDirection = "Input"
	ScriptActivityParameterDirectionInputOutput ScriptActivityParameterDirection = "InputOutput"
	ScriptActivityParameterDirectionOutput      ScriptActivityParameterDirection = "Output"
)

func (*ScriptActivityParameterDirection) UnmarshalJSON

func (s *ScriptActivityParameterDirection) UnmarshalJSON(bytes []byte) error

type ScriptActivityParameterType

type ScriptActivityParameterType string

const (
	ScriptActivityParameterTypeBoolean        ScriptActivityParameterType = "Boolean"
	ScriptActivityParameterTypeDateTime       ScriptActivityParameterType = "DateTime"
	ScriptActivityParameterTypeDateTimeOffset ScriptActivityParameterType = "DateTimeOffset"
	ScriptActivityParameterTypeDecimal        ScriptActivityParameterType = "Decimal"
	ScriptActivityParameterTypeDouble         ScriptActivityParameterType = "Double"
	ScriptActivityParameterTypeGuid           ScriptActivityParameterType = "Guid"
	ScriptActivityParameterTypeIntOneSix      ScriptActivityParameterType = "Int16"
	ScriptActivityParameterTypeIntSixFour     ScriptActivityParameterType = "Int64"
	ScriptActivityParameterTypeIntThreeTwo    ScriptActivityParameterType = "Int32"
	ScriptActivityParameterTypeSingle         ScriptActivityParameterType = "Single"
	ScriptActivityParameterTypeString         ScriptActivityParameterType = "String"
	ScriptActivityParameterTypeTimespan       ScriptActivityParameterType = "Timespan"
)

func (*ScriptActivityParameterType) UnmarshalJSON

func (s *ScriptActivityParameterType) UnmarshalJSON(bytes []byte) error

type ScriptActivityScriptBlock

type ScriptActivityScriptBlock struct {
	Parameters *[]ScriptActivityParameter `json:"parameters,omitempty"`
	Text       interface{}                `json:"text"`
	Type       ScriptType                 `json:"type"`
}

type ScriptActivityTypeProperties

type ScriptActivityTypeProperties struct {
	LogSettings                 *ScriptActivityTypePropertiesLogSettings `json:"logSettings,omitempty"`
	ScriptBlockExecutionTimeout *interface{}                             `json:"scriptBlockExecutionTimeout,omitempty"`
	Scripts                     *[]ScriptActivityScriptBlock             `json:"scripts,omitempty"`
}

type ScriptActivityTypePropertiesLogSettings

type ScriptActivityTypePropertiesLogSettings struct {
	LogDestination      ScriptActivityLogDestination `json:"logDestination"`
	LogLocationSettings *LogLocationSettings         `json:"logLocationSettings,omitempty"`
}

type ScriptType

type ScriptType string

const (
	ScriptTypeNonQuery ScriptType = "NonQuery"
	ScriptTypeQuery    ScriptType = "Query"
)

func (*ScriptType) UnmarshalJSON

func (s *ScriptType) UnmarshalJSON(bytes []byte) error

type SecretBase

type SecretBase interface {
}

type SecureInputOutputPolicy

type SecureInputOutputPolicy struct {
	SecureInput  *bool `json:"secureInput,omitempty"`
	SecureOutput *bool `json:"secureOutput,omitempty"`
}

type SecureString

type SecureString struct {
	Value string `json:"value"`
}

func (SecureString) MarshalJSON

func (s SecureString) MarshalJSON() ([]byte, error)

type ServiceNowSource

type ServiceNowSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type ServiceNowV2Source

type ServiceNowV2Source struct {
	AdditionalColumns        *interface{}  `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{}  `json:"disableMetricsCollection,omitempty"`
	Expression               *ExpressionV2 `json:"expression,omitempty"`
	MaxConcurrentConnections *interface{}  `json:"maxConcurrentConnections,omitempty"`
	QueryTimeout             *interface{}  `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{}  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{}  `json:"sourceRetryWait,omitempty"`
	Type                     string        `json:"type"`
}

type SetVariableActivity

type SetVariableActivity struct {
	Policy         *SecureInputOutputPolicy          `json:"policy,omitempty"`
	TypeProperties SetVariableActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (SetVariableActivity) MarshalJSON

func (s SetVariableActivity) MarshalJSON() ([]byte, error)

type SetVariableActivityTypeProperties

type SetVariableActivityTypeProperties struct {
	SetSystemVariable *bool        `json:"setSystemVariable,omitempty"`
	Value             *interface{} `json:"value,omitempty"`
	VariableName      *string      `json:"variableName,omitempty"`
}

type SftpReadSettings

type SftpReadSettings struct {
	DeleteFilesAfterCompletion *interface{} `json:"deleteFilesAfterCompletion,omitempty"`
	DisableChunking            *interface{} `json:"disableChunking,omitempty"`
	DisableMetricsCollection   *interface{} `json:"disableMetricsCollection,omitempty"`
	EnablePartitionDiscovery   *interface{} `json:"enablePartitionDiscovery,omitempty"`
	FileListPath               *interface{} `json:"fileListPath,omitempty"`
	MaxConcurrentConnections   *interface{} `json:"maxConcurrentConnections,omitempty"`
	ModifiedDatetimeEnd        *interface{} `json:"modifiedDatetimeEnd,omitempty"`
	ModifiedDatetimeStart      *interface{} `json:"modifiedDatetimeStart,omitempty"`
	PartitionRootPath          *interface{} `json:"partitionRootPath,omitempty"`
	Recursive                  *interface{} `json:"recursive,omitempty"`
	Type                       string       `json:"type"`
	WildcardFileName           *interface{} `json:"wildcardFileName,omitempty"`
	WildcardFolderPath         *interface{} `json:"wildcardFolderPath,omitempty"`
}

type SftpWriteSettings

type SftpWriteSettings struct {
	CopyBehavior             *interface{}    `json:"copyBehavior,omitempty"`
	DisableMetricsCollection *interface{}    `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{}    `json:"maxConcurrentConnections,omitempty"`
	Metadata                 *[]MetadataItem `json:"metadata,omitempty"`
	OperationTimeout         *interface{}    `json:"operationTimeout,omitempty"`
	Type                     string          `json:"type"`
	UseTempFileRename        *interface{}    `json:"useTempFileRename,omitempty"`
}

type SharePointOnlineListSource

type SharePointOnlineListSource struct {
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	HTTPRequestTimeout       *interface{} `json:"httpRequestTimeout,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type ShopifySource

type ShopifySource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type SkipErrorFile

type SkipErrorFile struct {
	DataInconsistency *interface{} `json:"dataInconsistency,omitempty"`
	FileMissing       *interface{} `json:"fileMissing,omitempty"`
}

type SnowflakeExportCopyCommand

type SnowflakeExportCopyCommand struct {
	AdditionalCopyOptions   *map[string]interface{} `json:"additionalCopyOptions,omitempty"`
	AdditionalFormatOptions *map[string]interface{} `json:"additionalFormatOptions,omitempty"`
	Type                    string                  `json:"type"`
}

type SnowflakeImportCopyCommand

type SnowflakeImportCopyCommand struct {
	AdditionalCopyOptions   *map[string]interface{} `json:"additionalCopyOptions,omitempty"`
	AdditionalFormatOptions *map[string]interface{} `json:"additionalFormatOptions,omitempty"`
	Type                    string                  `json:"type"`
}

type SnowflakeSink

type SnowflakeSink struct {
	DisableMetricsCollection *interface{}                `json:"disableMetricsCollection,omitempty"`
	ImportSettings           *SnowflakeImportCopyCommand `json:"importSettings,omitempty"`
	MaxConcurrentConnections *interface{}                `json:"maxConcurrentConnections,omitempty"`
	PreCopyScript            *interface{}                `json:"preCopyScript,omitempty"`
	SinkRetryCount           *interface{}                `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{}                `json:"sinkRetryWait,omitempty"`
	Type                     string                      `json:"type"`
	WriteBatchSize           *interface{}                `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{}                `json:"writeBatchTimeout,omitempty"`
}

type SnowflakeSource

type SnowflakeSource struct {
	DisableMetricsCollection *interface{}               `json:"disableMetricsCollection,omitempty"`
	ExportSettings           SnowflakeExportCopyCommand `json:"exportSettings"`
	MaxConcurrentConnections *interface{}               `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{}               `json:"query,omitempty"`
	SourceRetryCount         *interface{}               `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{}               `json:"sourceRetryWait,omitempty"`
	Type                     string                     `json:"type"`
}

type SnowflakeV2Sink

type SnowflakeV2Sink struct {
	DisableMetricsCollection *interface{}                `json:"disableMetricsCollection,omitempty"`
	ImportSettings           *SnowflakeImportCopyCommand `json:"importSettings,omitempty"`
	MaxConcurrentConnections *interface{}                `json:"maxConcurrentConnections,omitempty"`
	PreCopyScript            *interface{}                `json:"preCopyScript,omitempty"`
	SinkRetryCount           *interface{}                `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{}                `json:"sinkRetryWait,omitempty"`
	Type                     string                      `json:"type"`
	WriteBatchSize           *interface{}                `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{}                `json:"writeBatchTimeout,omitempty"`
}

type SnowflakeV2Source

type SnowflakeV2Source struct {
	DisableMetricsCollection *interface{}               `json:"disableMetricsCollection,omitempty"`
	ExportSettings           SnowflakeExportCopyCommand `json:"exportSettings"`
	MaxConcurrentConnections *interface{}               `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{}               `json:"query,omitempty"`
	SourceRetryCount         *interface{}               `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{}               `json:"sourceRetryWait,omitempty"`
	Type                     string                     `json:"type"`
}

type SparkConfigurationParametrizationReference

type SparkConfigurationParametrizationReference struct {
	ReferenceName interface{}                     `json:"referenceName"`
	Type          SparkConfigurationReferenceType `json:"type"`
}

type SparkConfigurationReferenceType

type SparkConfigurationReferenceType string

const (
	SparkConfigurationReferenceTypeSparkConfigurationReference SparkConfigurationReferenceType = "SparkConfigurationReference"
)

func (*SparkConfigurationReferenceType) UnmarshalJSON

func (s *SparkConfigurationReferenceType) UnmarshalJSON(bytes []byte) error

type SparkJobReferenceType

type SparkJobReferenceType string

const (
	SparkJobReferenceTypeSparkJobDefinitionReference SparkJobReferenceType = "SparkJobDefinitionReference"
)

func (*SparkJobReferenceType) UnmarshalJSON

func (s *SparkJobReferenceType) UnmarshalJSON(bytes []byte) error

type SparkSource

type SparkSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type SqlDWSink

type SqlDWSink struct {
	AllowCopyCommand         *interface{}           `json:"allowCopyCommand,omitempty"`
	AllowPolyBase            *interface{}           `json:"allowPolyBase,omitempty"`
	CopyCommandSettings      *DWCopyCommandSettings `json:"copyCommandSettings,omitempty"`
	DisableMetricsCollection *interface{}           `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{}           `json:"maxConcurrentConnections,omitempty"`
	PolyBaseSettings         *PolybaseSettings      `json:"polyBaseSettings,omitempty"`
	PreCopyScript            *interface{}           `json:"preCopyScript,omitempty"`
	SinkRetryCount           *interface{}           `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{}           `json:"sinkRetryWait,omitempty"`
	SqlWriterUseTableLock    *interface{}           `json:"sqlWriterUseTableLock,omitempty"`
	TableOption              *interface{}           `json:"tableOption,omitempty"`
	Type                     string                 `json:"type"`
	UpsertSettings           *SqlDWUpsertSettings   `json:"upsertSettings,omitempty"`
	WriteBatchSize           *interface{}           `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{}           `json:"writeBatchTimeout,omitempty"`
	WriteBehavior            *interface{}           `json:"writeBehavior,omitempty"`
}

type SqlDWSource

type SqlDWSource struct {
	AdditionalColumns            *interface{}          `json:"additionalColumns,omitempty"`
	DisableMetricsCollection     *interface{}          `json:"disableMetricsCollection,omitempty"`
	IsolationLevel               *interface{}          `json:"isolationLevel,omitempty"`
	MaxConcurrentConnections     *interface{}          `json:"maxConcurrentConnections,omitempty"`
	PartitionOption              *interface{}          `json:"partitionOption,omitempty"`
	PartitionSettings            *SqlPartitionSettings `json:"partitionSettings,omitempty"`
	QueryTimeout                 *interface{}          `json:"queryTimeout,omitempty"`
	SourceRetryCount             *interface{}          `json:"sourceRetryCount,omitempty"`
	SourceRetryWait              *interface{}          `json:"sourceRetryWait,omitempty"`
	SqlReaderQuery               *interface{}          `json:"sqlReaderQuery,omitempty"`
	SqlReaderStoredProcedureName *interface{}          `json:"sqlReaderStoredProcedureName,omitempty"`
	StoredProcedureParameters    *interface{}          `json:"storedProcedureParameters,omitempty"`
	Type                         string                `json:"type"`
}

type SqlDWUpsertSettings

type SqlDWUpsertSettings struct {
	InterimSchemaName *interface{} `json:"interimSchemaName,omitempty"`
	Keys              *interface{} `json:"keys,omitempty"`
}

type SqlMISink

type SqlMISink struct {
	DisableMetricsCollection              *interface{}       `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections              *interface{}       `json:"maxConcurrentConnections,omitempty"`
	PreCopyScript                         *interface{}       `json:"preCopyScript,omitempty"`
	SinkRetryCount                        *interface{}       `json:"sinkRetryCount,omitempty"`
	SinkRetryWait                         *interface{}       `json:"sinkRetryWait,omitempty"`
	SqlWriterStoredProcedureName          *interface{}       `json:"sqlWriterStoredProcedureName,omitempty"`
	SqlWriterTableType                    *interface{}       `json:"sqlWriterTableType,omitempty"`
	SqlWriterUseTableLock                 *interface{}       `json:"sqlWriterUseTableLock,omitempty"`
	StoredProcedureParameters             *interface{}       `json:"storedProcedureParameters,omitempty"`
	StoredProcedureTableTypeParameterName *interface{}       `json:"storedProcedureTableTypeParameterName,omitempty"`
	TableOption                           *interface{}       `json:"tableOption,omitempty"`
	Type                                  string             `json:"type"`
	UpsertSettings                        *SqlUpsertSettings `json:"upsertSettings,omitempty"`
	WriteBatchSize                        *interface{}       `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout                     *interface{}       `json:"writeBatchTimeout,omitempty"`
	WriteBehavior                         *interface{}       `json:"writeBehavior,omitempty"`
}

type SqlMISource

type SqlMISource struct {
	AdditionalColumns            *interface{}          `json:"additionalColumns,omitempty"`
	DisableMetricsCollection     *interface{}          `json:"disableMetricsCollection,omitempty"`
	IsolationLevel               *interface{}          `json:"isolationLevel,omitempty"`
	MaxConcurrentConnections     *interface{}          `json:"maxConcurrentConnections,omitempty"`
	PartitionOption              *interface{}          `json:"partitionOption,omitempty"`
	PartitionSettings            *SqlPartitionSettings `json:"partitionSettings,omitempty"`
	ProduceAdditionalTypes       *interface{}          `json:"produceAdditionalTypes,omitempty"`
	QueryTimeout                 *interface{}          `json:"queryTimeout,omitempty"`
	SourceRetryCount             *interface{}          `json:"sourceRetryCount,omitempty"`
	SourceRetryWait              *interface{}          `json:"sourceRetryWait,omitempty"`
	SqlReaderQuery               *interface{}          `json:"sqlReaderQuery,omitempty"`
	SqlReaderStoredProcedureName *interface{}          `json:"sqlReaderStoredProcedureName,omitempty"`
	StoredProcedureParameters    *interface{}          `json:"storedProcedureParameters,omitempty"`
	Type                         string                `json:"type"`
}

type SqlPartitionSettings

type SqlPartitionSettings struct {
	PartitionColumnName *interface{} `json:"partitionColumnName,omitempty"`
	PartitionLowerBound *interface{} `json:"partitionLowerBound,omitempty"`
	PartitionUpperBound *interface{} `json:"partitionUpperBound,omitempty"`
}

type SqlServerSink

type SqlServerSink struct {
	DisableMetricsCollection              *interface{}       `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections              *interface{}       `json:"maxConcurrentConnections,omitempty"`
	PreCopyScript                         *interface{}       `json:"preCopyScript,omitempty"`
	SinkRetryCount                        *interface{}       `json:"sinkRetryCount,omitempty"`
	SinkRetryWait                         *interface{}       `json:"sinkRetryWait,omitempty"`
	SqlWriterStoredProcedureName          *interface{}       `json:"sqlWriterStoredProcedureName,omitempty"`
	SqlWriterTableType                    *interface{}       `json:"sqlWriterTableType,omitempty"`
	SqlWriterUseTableLock                 *interface{}       `json:"sqlWriterUseTableLock,omitempty"`
	StoredProcedureParameters             *interface{}       `json:"storedProcedureParameters,omitempty"`
	StoredProcedureTableTypeParameterName *interface{}       `json:"storedProcedureTableTypeParameterName,omitempty"`
	TableOption                           *interface{}       `json:"tableOption,omitempty"`
	Type                                  string             `json:"type"`
	UpsertSettings                        *SqlUpsertSettings `json:"upsertSettings,omitempty"`
	WriteBatchSize                        *interface{}       `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout                     *interface{}       `json:"writeBatchTimeout,omitempty"`
	WriteBehavior                         *interface{}       `json:"writeBehavior,omitempty"`
}

type SqlServerSource

type SqlServerSource struct {
	AdditionalColumns            *interface{}          `json:"additionalColumns,omitempty"`
	DisableMetricsCollection     *interface{}          `json:"disableMetricsCollection,omitempty"`
	IsolationLevel               *interface{}          `json:"isolationLevel,omitempty"`
	MaxConcurrentConnections     *interface{}          `json:"maxConcurrentConnections,omitempty"`
	PartitionOption              *interface{}          `json:"partitionOption,omitempty"`
	PartitionSettings            *SqlPartitionSettings `json:"partitionSettings,omitempty"`
	ProduceAdditionalTypes       *interface{}          `json:"produceAdditionalTypes,omitempty"`
	QueryTimeout                 *interface{}          `json:"queryTimeout,omitempty"`
	SourceRetryCount             *interface{}          `json:"sourceRetryCount,omitempty"`
	SourceRetryWait              *interface{}          `json:"sourceRetryWait,omitempty"`
	SqlReaderQuery               *interface{}          `json:"sqlReaderQuery,omitempty"`
	SqlReaderStoredProcedureName *interface{}          `json:"sqlReaderStoredProcedureName,omitempty"`
	StoredProcedureParameters    *interface{}          `json:"storedProcedureParameters,omitempty"`
	Type                         string                `json:"type"`
}

type SqlServerStoredProcedureActivity

type SqlServerStoredProcedureActivity struct {
	LinkedServiceName *LinkedServiceReference                        `json:"linkedServiceName,omitempty"`
	Policy            *ActivityPolicy                                `json:"policy,omitempty"`
	TypeProperties    SqlServerStoredProcedureActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (SqlServerStoredProcedureActivity) MarshalJSON

func (s SqlServerStoredProcedureActivity) MarshalJSON() ([]byte, error)

type SqlServerStoredProcedureActivityTypeProperties

type SqlServerStoredProcedureActivityTypeProperties struct {
	StoredProcedureName       interface{}  `json:"storedProcedureName"`
	StoredProcedureParameters *interface{} `json:"storedProcedureParameters,omitempty"`
}

type SqlSink

type SqlSink struct {
	DisableMetricsCollection              *interface{}       `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections              *interface{}       `json:"maxConcurrentConnections,omitempty"`
	PreCopyScript                         *interface{}       `json:"preCopyScript,omitempty"`
	SinkRetryCount                        *interface{}       `json:"sinkRetryCount,omitempty"`
	SinkRetryWait                         *interface{}       `json:"sinkRetryWait,omitempty"`
	SqlWriterStoredProcedureName          *interface{}       `json:"sqlWriterStoredProcedureName,omitempty"`
	SqlWriterTableType                    *interface{}       `json:"sqlWriterTableType,omitempty"`
	SqlWriterUseTableLock                 *interface{}       `json:"sqlWriterUseTableLock,omitempty"`
	StoredProcedureParameters             *interface{}       `json:"storedProcedureParameters,omitempty"`
	StoredProcedureTableTypeParameterName *interface{}       `json:"storedProcedureTableTypeParameterName,omitempty"`
	TableOption                           *interface{}       `json:"tableOption,omitempty"`
	Type                                  string             `json:"type"`
	UpsertSettings                        *SqlUpsertSettings `json:"upsertSettings,omitempty"`
	WriteBatchSize                        *interface{}       `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout                     *interface{}       `json:"writeBatchTimeout,omitempty"`
	WriteBehavior                         *interface{}       `json:"writeBehavior,omitempty"`
}

type SqlSource

type SqlSource struct {
	AdditionalColumns            *interface{}          `json:"additionalColumns,omitempty"`
	DisableMetricsCollection     *interface{}          `json:"disableMetricsCollection,omitempty"`
	IsolationLevel               *interface{}          `json:"isolationLevel,omitempty"`
	MaxConcurrentConnections     *interface{}          `json:"maxConcurrentConnections,omitempty"`
	PartitionOption              *interface{}          `json:"partitionOption,omitempty"`
	PartitionSettings            *SqlPartitionSettings `json:"partitionSettings,omitempty"`
	QueryTimeout                 *interface{}          `json:"queryTimeout,omitempty"`
	SourceRetryCount             *interface{}          `json:"sourceRetryCount,omitempty"`
	SourceRetryWait              *interface{}          `json:"sourceRetryWait,omitempty"`
	SqlReaderQuery               *interface{}          `json:"sqlReaderQuery,omitempty"`
	SqlReaderStoredProcedureName *interface{}          `json:"sqlReaderStoredProcedureName,omitempty"`
	StoredProcedureParameters    *interface{}          `json:"storedProcedureParameters,omitempty"`
	Type                         string                `json:"type"`
}

type SqlUpsertSettings

type SqlUpsertSettings struct {
	InterimSchemaName *interface{} `json:"interimSchemaName,omitempty"`
	Keys              *interface{} `json:"keys,omitempty"`
	UseTempDB         *interface{} `json:"useTempDB,omitempty"`
}

type SquareSource

type SquareSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type SsisLogLocationType

type SsisLogLocationType string

const (
	SsisLogLocationTypeFile SsisLogLocationType = "File"
)

func (*SsisLogLocationType) UnmarshalJSON

func (s *SsisLogLocationType) UnmarshalJSON(bytes []byte) error

type SsisPackageLocationType

type SsisPackageLocationType string

const (
	SsisPackageLocationTypeFile          SsisPackageLocationType = "File"
	SsisPackageLocationTypeInlinePackage SsisPackageLocationType = "InlinePackage"
	SsisPackageLocationTypePackageStore  SsisPackageLocationType = "PackageStore"
	SsisPackageLocationTypeSSISDB        SsisPackageLocationType = "SSISDB"
)

func (*SsisPackageLocationType) UnmarshalJSON

func (s *SsisPackageLocationType) UnmarshalJSON(bytes []byte) error

type StagingSettings

type StagingSettings struct {
	EnableCompression *interface{}           `json:"enableCompression,omitempty"`
	LinkedServiceName LinkedServiceReference `json:"linkedServiceName"`
	Path              *interface{}           `json:"path,omitempty"`
}

type StoreReadSettings

type StoreReadSettings interface {
}

type StoreWriteSettings

type StoreWriteSettings interface {
}

type SwitchActivity

type SwitchActivity struct {
	TypeProperties SwitchActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (SwitchActivity) MarshalJSON

func (s SwitchActivity) MarshalJSON() ([]byte, error)

type SwitchActivityTypeProperties

type SwitchActivityTypeProperties struct {
	Cases             *[]SwitchCase `json:"cases,omitempty"`
	DefaultActivities *[]Activity   `json:"defaultActivities,omitempty"`
	On                Expression    `json:"on"`
}

func (*SwitchActivityTypeProperties) UnmarshalJSON

func (s *SwitchActivityTypeProperties) UnmarshalJSON(bytes []byte) error

type SwitchCase

type SwitchCase struct {
	Activities *[]Activity `json:"activities,omitempty"`
	Value      *string     `json:"value,omitempty"`
}

func (*SwitchCase) UnmarshalJSON

func (s *SwitchCase) UnmarshalJSON(bytes []byte) error

type SybaseSource

type SybaseSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type SynapseNotebookActivity

type SynapseNotebookActivity struct {
	LinkedServiceName *LinkedServiceReference               `json:"linkedServiceName,omitempty"`
	Policy            *ActivityPolicy                       `json:"policy,omitempty"`
	TypeProperties    SynapseNotebookActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (SynapseNotebookActivity) MarshalJSON

func (s SynapseNotebookActivity) MarshalJSON() ([]byte, error)

type SynapseNotebookActivityTypeProperties

type SynapseNotebookActivityTypeProperties struct {
	Conf                     *interface{}                                `json:"conf,omitempty"`
	ConfigurationType        *ConfigurationType                          `json:"configurationType,omitempty"`
	DriverSize               *interface{}                                `json:"driverSize,omitempty"`
	ExecutorSize             *interface{}                                `json:"executorSize,omitempty"`
	Notebook                 SynapseNotebookReference                    `json:"notebook"`
	NumExecutors             *interface{}                                `json:"numExecutors,omitempty"`
	Parameters               *map[string]NotebookParameter               `json:"parameters,omitempty"`
	SparkConfig              *map[string]interface{}                     `json:"sparkConfig,omitempty"`
	SparkPool                *BigDataPoolParametrizationReference        `json:"sparkPool,omitempty"`
	TargetSparkConfiguration *SparkConfigurationParametrizationReference `json:"targetSparkConfiguration,omitempty"`
}

type SynapseNotebookReference

type SynapseNotebookReference struct {
	ReferenceName interface{}           `json:"referenceName"`
	Type          NotebookReferenceType `json:"type"`
}

type SynapseSparkJobActivityTypeProperties

type SynapseSparkJobActivityTypeProperties struct {
	Args                     *[]interface{}                              `json:"args,omitempty"`
	ClassName                *interface{}                                `json:"className,omitempty"`
	Conf                     *interface{}                                `json:"conf,omitempty"`
	ConfigurationType        *ConfigurationType                          `json:"configurationType,omitempty"`
	DriverSize               *interface{}                                `json:"driverSize,omitempty"`
	ExecutorSize             *interface{}                                `json:"executorSize,omitempty"`
	File                     *interface{}                                `json:"file,omitempty"`
	Files                    *[]interface{}                              `json:"files,omitempty"`
	FilesV2                  *[]interface{}                              `json:"filesV2,omitempty"`
	NumExecutors             *interface{}                                `json:"numExecutors,omitempty"`
	PythonCodeReference      *[]interface{}                              `json:"pythonCodeReference,omitempty"`
	ScanFolder               *interface{}                                `json:"scanFolder,omitempty"`
	SparkConfig              *map[string]interface{}                     `json:"sparkConfig,omitempty"`
	SparkJob                 SynapseSparkJobReference                    `json:"sparkJob"`
	TargetBigDataPool        *BigDataPoolParametrizationReference        `json:"targetBigDataPool,omitempty"`
	TargetSparkConfiguration *SparkConfigurationParametrizationReference `json:"targetSparkConfiguration,omitempty"`
}

type SynapseSparkJobDefinitionActivity

type SynapseSparkJobDefinitionActivity struct {
	LinkedServiceName *LinkedServiceReference               `json:"linkedServiceName,omitempty"`
	Policy            *ActivityPolicy                       `json:"policy,omitempty"`
	TypeProperties    SynapseSparkJobActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (SynapseSparkJobDefinitionActivity) MarshalJSON

func (s SynapseSparkJobDefinitionActivity) MarshalJSON() ([]byte, error)

type SynapseSparkJobReference

type SynapseSparkJobReference struct {
	ReferenceName interface{}           `json:"referenceName"`
	Type          SparkJobReferenceType `json:"type"`
}

type TabularSource

type TabularSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type TarGZipReadSettings

type TarGZipReadSettings struct {
	PreserveCompressionFileNameAsFolder *interface{} `json:"preserveCompressionFileNameAsFolder,omitempty"`
	Type                                string       `json:"type"`
}

type TarReadSettings

type TarReadSettings struct {
	PreserveCompressionFileNameAsFolder *interface{} `json:"preserveCompressionFileNameAsFolder,omitempty"`
	Type                                string       `json:"type"`
}

type TeradataPartitionSettings

type TeradataPartitionSettings struct {
	PartitionColumnName *interface{} `json:"partitionColumnName,omitempty"`
	PartitionLowerBound *interface{} `json:"partitionLowerBound,omitempty"`
	PartitionUpperBound *interface{} `json:"partitionUpperBound,omitempty"`
}

type TeradataSource

type TeradataSource struct {
	AdditionalColumns        *interface{}               `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{}               `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{}               `json:"maxConcurrentConnections,omitempty"`
	PartitionOption          *interface{}               `json:"partitionOption,omitempty"`
	PartitionSettings        *TeradataPartitionSettings `json:"partitionSettings,omitempty"`
	Query                    *interface{}               `json:"query,omitempty"`
	QueryTimeout             *interface{}               `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{}               `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{}               `json:"sourceRetryWait,omitempty"`
	Type                     string                     `json:"type"`
}

type Type

type Type string

const (
	TypeLinkedServiceReference Type = "LinkedServiceReference"
)

func (*Type) UnmarshalJSON

func (s *Type) UnmarshalJSON(bytes []byte) error

type UntilActivity

type UntilActivity struct {
	TypeProperties UntilActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (UntilActivity) MarshalJSON

func (s UntilActivity) MarshalJSON() ([]byte, error)

type UntilActivityTypeProperties

type UntilActivityTypeProperties struct {
	Activities []Activity   `json:"activities"`
	Expression Expression   `json:"expression"`
	Timeout    *interface{} `json:"timeout,omitempty"`
}

func (*UntilActivityTypeProperties) UnmarshalJSON

func (s *UntilActivityTypeProperties) UnmarshalJSON(bytes []byte) error

type UserProperty

type UserProperty struct {
	Name  string      `json:"name"`
	Value interface{} `json:"value"`
}

type ValidationActivity

type ValidationActivity struct {
	TypeProperties ValidationActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (ValidationActivity) MarshalJSON

func (s ValidationActivity) MarshalJSON() ([]byte, error)

type ValidationActivityTypeProperties

type ValidationActivityTypeProperties struct {
	ChildItems  *interface{}     `json:"childItems,omitempty"`
	Dataset     DatasetReference `json:"dataset"`
	MinimumSize *interface{}     `json:"minimumSize,omitempty"`
	Sleep       *interface{}     `json:"sleep,omitempty"`
	Timeout     *interface{}     `json:"timeout,omitempty"`
}

type VariableSpecification

type VariableSpecification struct {
	DefaultValue *interface{} `json:"defaultValue,omitempty"`
	Type         VariableType `json:"type"`
}

type VariableType

type VariableType string

const (
	VariableTypeArray  VariableType = "Array"
	VariableTypeBool   VariableType = "Bool"
	VariableTypeString VariableType = "String"
)

func (*VariableType) UnmarshalJSON

func (s *VariableType) UnmarshalJSON(bytes []byte) error

type VerticaSource

type VerticaSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type WaitActivity

type WaitActivity struct {
	TypeProperties WaitActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (WaitActivity) MarshalJSON

func (s WaitActivity) MarshalJSON() ([]byte, error)

type WaitActivityTypeProperties

type WaitActivityTypeProperties struct {
	WaitTimeInSeconds interface{} `json:"waitTimeInSeconds"`
}

type WarehouseSink

type WarehouseSink struct {
	AllowCopyCommand         *interface{}           `json:"allowCopyCommand,omitempty"`
	CopyCommandSettings      *DWCopyCommandSettings `json:"copyCommandSettings,omitempty"`
	DisableMetricsCollection *interface{}           `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{}           `json:"maxConcurrentConnections,omitempty"`
	PreCopyScript            *interface{}           `json:"preCopyScript,omitempty"`
	SinkRetryCount           *interface{}           `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{}           `json:"sinkRetryWait,omitempty"`
	TableOption              *interface{}           `json:"tableOption,omitempty"`
	Type                     string                 `json:"type"`
	WriteBatchSize           *interface{}           `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{}           `json:"writeBatchTimeout,omitempty"`
	WriteBehavior            *interface{}           `json:"writeBehavior,omitempty"`
}

type WarehouseSource

type WarehouseSource struct {
	AdditionalColumns            *interface{}          `json:"additionalColumns,omitempty"`
	DisableMetricsCollection     *interface{}          `json:"disableMetricsCollection,omitempty"`
	IsolationLevel               *interface{}          `json:"isolationLevel,omitempty"`
	MaxConcurrentConnections     *interface{}          `json:"maxConcurrentConnections,omitempty"`
	PartitionOption              *interface{}          `json:"partitionOption,omitempty"`
	PartitionSettings            *SqlPartitionSettings `json:"partitionSettings,omitempty"`
	QueryTimeout                 *interface{}          `json:"queryTimeout,omitempty"`
	SourceRetryCount             *interface{}          `json:"sourceRetryCount,omitempty"`
	SourceRetryWait              *interface{}          `json:"sourceRetryWait,omitempty"`
	SqlReaderQuery               *interface{}          `json:"sqlReaderQuery,omitempty"`
	SqlReaderStoredProcedureName *interface{}          `json:"sqlReaderStoredProcedureName,omitempty"`
	StoredProcedureParameters    *interface{}          `json:"storedProcedureParameters,omitempty"`
	Type                         string                `json:"type"`
}

type WebActivity

type WebActivity struct {
	LinkedServiceName *LinkedServiceReference   `json:"linkedServiceName,omitempty"`
	Policy            *ActivityPolicy           `json:"policy,omitempty"`
	TypeProperties    WebActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (WebActivity) MarshalJSON

func (s WebActivity) MarshalJSON() ([]byte, error)

type WebActivityAuthentication

type WebActivityAuthentication struct {
	Credential *CredentialReference `json:"credential,omitempty"`
	Password   SecretBase           `json:"password"`
	Pfx        SecretBase           `json:"pfx"`
	Resource   *interface{}         `json:"resource,omitempty"`
	Type       *string              `json:"type,omitempty"`
	UserTenant *interface{}         `json:"userTenant,omitempty"`
	Username   *interface{}         `json:"username,omitempty"`
}

func (*WebActivityAuthentication) UnmarshalJSON

func (s *WebActivityAuthentication) UnmarshalJSON(bytes []byte) error

type WebActivityMethod

type WebActivityMethod string

const (
	WebActivityMethodDELETE WebActivityMethod = "DELETE"
	WebActivityMethodGET    WebActivityMethod = "GET"
	WebActivityMethodPOST   WebActivityMethod = "POST"
	WebActivityMethodPUT    WebActivityMethod = "PUT"
)

func (*WebActivityMethod) UnmarshalJSON

func (s *WebActivityMethod) UnmarshalJSON(bytes []byte) error

type WebActivityTypeProperties

type WebActivityTypeProperties struct {
	Authentication        *WebActivityAuthentication   `json:"authentication,omitempty"`
	Body                  *interface{}                 `json:"body,omitempty"`
	ConnectVia            *IntegrationRuntimeReference `json:"connectVia,omitempty"`
	Datasets              *[]DatasetReference          `json:"datasets,omitempty"`
	DisableCertValidation *bool                        `json:"disableCertValidation,omitempty"`
	HTTPRequestTimeout    *interface{}                 `json:"httpRequestTimeout,omitempty"`
	Headers               *map[string]interface{}      `json:"headers,omitempty"`
	LinkedServices        *[]LinkedServiceReference    `json:"linkedServices,omitempty"`
	Method                WebActivityMethod            `json:"method"`
	TurnOffAsync          *bool                        `json:"turnOffAsync,omitempty"`
	Url                   interface{}                  `json:"url"`
}

type WebHookActivity

type WebHookActivity struct {
	Policy         *SecureInputOutputPolicy      `json:"policy,omitempty"`
	TypeProperties WebHookActivityTypeProperties `json:"typeProperties"`

	// Fields inherited from Activity
	DependsOn        *[]ActivityDependency     `json:"dependsOn,omitempty"`
	Description      *string                   `json:"description,omitempty"`
	Name             string                    `json:"name"`
	OnInactiveMarkAs *ActivityOnInactiveMarkAs `json:"onInactiveMarkAs,omitempty"`
	State            *ActivityState            `json:"state,omitempty"`
	UserProperties   *[]UserProperty           `json:"userProperties,omitempty"`
}

func (WebHookActivity) MarshalJSON

func (s WebHookActivity) MarshalJSON() ([]byte, error)

type WebHookActivityMethod

type WebHookActivityMethod string

const (
	WebHookActivityMethodPOST WebHookActivityMethod = "POST"
)

func (*WebHookActivityMethod) UnmarshalJSON

func (s *WebHookActivityMethod) UnmarshalJSON(bytes []byte) error

type WebHookActivityTypeProperties

type WebHookActivityTypeProperties struct {
	Authentication         *WebActivityAuthentication `json:"authentication,omitempty"`
	Body                   *interface{}               `json:"body,omitempty"`
	Headers                *map[string]interface{}    `json:"headers,omitempty"`
	Method                 WebHookActivityMethod      `json:"method"`
	ReportStatusOnCallBack *interface{}               `json:"reportStatusOnCallBack,omitempty"`
	Timeout                *string                    `json:"timeout,omitempty"`
	Url                    interface{}                `json:"url"`
}

type WebSource

type WebSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type XeroSource

type XeroSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}

type XmlReadSettings

type XmlReadSettings struct {
	CompressionProperties CompressionReadSettings `json:"compressionProperties"`
	DetectDataType        *interface{}            `json:"detectDataType,omitempty"`
	NamespacePrefixes     *interface{}            `json:"namespacePrefixes,omitempty"`
	Namespaces            *interface{}            `json:"namespaces,omitempty"`
	Type                  string                  `json:"type"`
	ValidationMode        *interface{}            `json:"validationMode,omitempty"`
}

func (*XmlReadSettings) UnmarshalJSON

func (s *XmlReadSettings) UnmarshalJSON(bytes []byte) error

type XmlSource

type XmlSource struct {
	AdditionalColumns        *interface{}      `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{}      `json:"disableMetricsCollection,omitempty"`
	FormatSettings           *XmlReadSettings  `json:"formatSettings,omitempty"`
	MaxConcurrentConnections *interface{}      `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{}      `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{}      `json:"sourceRetryWait,omitempty"`
	StoreSettings            StoreReadSettings `json:"storeSettings"`
	Type                     string            `json:"type"`
}

func (*XmlSource) UnmarshalJSON

func (s *XmlSource) UnmarshalJSON(bytes []byte) error

type ZipDeflateReadSettings

type ZipDeflateReadSettings struct {
	PreserveZipFileNameAsFolder *interface{} `json:"preserveZipFileNameAsFolder,omitempty"`
	Type                        string       `json:"type"`
}

type ZohoSource

type ZohoSource struct {
	AdditionalColumns        *interface{} `json:"additionalColumns,omitempty"`
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	Query                    *interface{} `json:"query,omitempty"`
	QueryTimeout             *interface{} `json:"queryTimeout,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
	Type                     string       `json:"type"`
}