pipelines

package
v0.20240610.1112704 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 10, 2024 License: MPL-2.0 Imports: 11 Imported by: 1

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 ¶

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func PossibleValuesForActivityOnInactiveMarkAs ¶

func PossibleValuesForActivityOnInactiveMarkAs() []string

func PossibleValuesForActivityState ¶

func PossibleValuesForActivityState() []string

func PossibleValuesForAzureFunctionActivityMethod ¶ added in v0.20240320.1143605

func PossibleValuesForAzureFunctionActivityMethod() []string

func PossibleValuesForAzureSearchIndexWriteBehaviorType ¶ added in v0.20240320.1143605

func PossibleValuesForAzureSearchIndexWriteBehaviorType() []string

func PossibleValuesForBigDataPoolReferenceType ¶ added in v0.20240320.1143605

func PossibleValuesForBigDataPoolReferenceType() []string

func PossibleValuesForCassandraSourceReadConsistencyLevels ¶ added in v0.20240320.1143605

func PossibleValuesForCassandraSourceReadConsistencyLevels() []string

func PossibleValuesForConfigurationType ¶ added in v0.20240320.1143605

func PossibleValuesForConfigurationType() []string

func PossibleValuesForCredentialReferenceType ¶ added in v0.20240320.1143605

func PossibleValuesForCredentialReferenceType() []string

func PossibleValuesForDataFlowReferenceType ¶ added in v0.20240320.1143605

func PossibleValuesForDataFlowReferenceType() []string

func PossibleValuesForDatasetReferenceType ¶ added in v0.20240320.1143605

func PossibleValuesForDatasetReferenceType() []string

func PossibleValuesForDependencyCondition ¶

func PossibleValuesForDependencyCondition() []string

func PossibleValuesForDynamicsSinkWriteBehavior ¶ added in v0.20240320.1143605

func PossibleValuesForDynamicsSinkWriteBehavior() []string

func PossibleValuesForExpressionType ¶ added in v0.20240320.1143605

func PossibleValuesForExpressionType() []string

func PossibleValuesForExpressionV2Type ¶ added in v0.20240320.1143605

func PossibleValuesForExpressionV2Type() []string

func PossibleValuesForHDInsightActivityDebugInfoOption ¶ added in v0.20240320.1143605

func PossibleValuesForHDInsightActivityDebugInfoOption() []string

func PossibleValuesForIntegrationRuntimeReferenceType ¶ added in v0.20240320.1143605

func PossibleValuesForIntegrationRuntimeReferenceType() []string

func PossibleValuesForNotebookParameterType ¶ added in v0.20240320.1143605

func PossibleValuesForNotebookParameterType() []string

func PossibleValuesForNotebookReferenceType ¶ added in v0.20240320.1143605

func PossibleValuesForNotebookReferenceType() []string

func PossibleValuesForParameterType ¶

func PossibleValuesForParameterType() []string

func PossibleValuesForPipelineReferenceType ¶ added in v0.20240320.1143605

func PossibleValuesForPipelineReferenceType() []string

func PossibleValuesForPolybaseSettingsRejectType ¶ added in v0.20240320.1143605

func PossibleValuesForPolybaseSettingsRejectType() []string

func PossibleValuesForSalesforceSinkWriteBehavior ¶ added in v0.20240320.1143605

func PossibleValuesForSalesforceSinkWriteBehavior() []string

func PossibleValuesForSalesforceV2SinkWriteBehavior ¶ added in v0.20240320.1143605

func PossibleValuesForSalesforceV2SinkWriteBehavior() []string

func PossibleValuesForSapCloudForCustomerSinkWriteBehavior ¶ added in v0.20240320.1143605

func PossibleValuesForSapCloudForCustomerSinkWriteBehavior() []string

func PossibleValuesForScriptActivityLogDestination ¶ added in v0.20240320.1143605

func PossibleValuesForScriptActivityLogDestination() []string

func PossibleValuesForScriptActivityParameterDirection ¶ added in v0.20240320.1143605

func PossibleValuesForScriptActivityParameterDirection() []string

func PossibleValuesForScriptActivityParameterType ¶ added in v0.20240320.1143605

func PossibleValuesForScriptActivityParameterType() []string

func PossibleValuesForSparkConfigurationReferenceType ¶ added in v0.20240320.1143605

func PossibleValuesForSparkConfigurationReferenceType() []string

func PossibleValuesForSparkJobReferenceType ¶ added in v0.20240320.1143605

func PossibleValuesForSparkJobReferenceType() []string

func PossibleValuesForSsisLogLocationType ¶ added in v0.20240320.1143605

func PossibleValuesForSsisLogLocationType() []string

func PossibleValuesForSsisPackageLocationType ¶ added in v0.20240320.1143605

func PossibleValuesForSsisPackageLocationType() []string

func PossibleValuesForType ¶ added in v0.20240320.1143605

func PossibleValuesForType() []string

func PossibleValuesForVariableType ¶

func PossibleValuesForVariableType() []string

func PossibleValuesForWebActivityMethod ¶ added in v0.20240320.1143605

func PossibleValuesForWebActivityMethod() []string

func PossibleValuesForWebHookActivityMethod ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

type AmazonMWSSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (AmazonMWSSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type AmazonRdsForOraclePartitionSettings ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

type AmazonRdsForOracleSource struct {
	AdditionalColumns *interface{}                         `json:"additionalColumns,omitempty"`
	OracleReaderQuery *interface{}                         `json:"oracleReaderQuery,omitempty"`
	PartitionOption   *interface{}                         `json:"partitionOption,omitempty"`
	PartitionSettings *AmazonRdsForOraclePartitionSettings `json:"partitionSettings,omitempty"`
	QueryTimeout      *interface{}                         `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (AmazonRdsForOracleSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type AmazonRdsForSqlServerSource ¶ added in v0.20240320.1143605

type AmazonRdsForSqlServerSource struct {
	AdditionalColumns            *interface{}          `json:"additionalColumns,omitempty"`
	IsolationLevel               *interface{}          `json:"isolationLevel,omitempty"`
	PartitionOption              *interface{}          `json:"partitionOption,omitempty"`
	PartitionSettings            *SqlPartitionSettings `json:"partitionSettings,omitempty"`
	ProduceAdditionalTypes       *interface{}          `json:"produceAdditionalTypes,omitempty"`
	QueryTimeout                 *interface{}          `json:"queryTimeout,omitempty"`
	SqlReaderQuery               *interface{}          `json:"sqlReaderQuery,omitempty"`
	SqlReaderStoredProcedureName *interface{}          `json:"sqlReaderStoredProcedureName,omitempty"`
	StoredProcedureParameters    *interface{}          `json:"storedProcedureParameters,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (AmazonRdsForSqlServerSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type AmazonRedshiftSource ¶ added in v0.20240320.1143605

type AmazonRedshiftSource struct {
	AdditionalColumns      *interface{}            `json:"additionalColumns,omitempty"`
	Query                  *interface{}            `json:"query,omitempty"`
	QueryTimeout           *interface{}            `json:"queryTimeout,omitempty"`
	RedshiftUnloadSettings *RedshiftUnloadSettings `json:"redshiftUnloadSettings,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (AmazonRedshiftSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type AmazonS3CompatibleReadSettings ¶ added in v0.20240320.1143605

type AmazonS3CompatibleReadSettings struct {
	DeleteFilesAfterCompletion *interface{} `json:"deleteFilesAfterCompletion,omitempty"`
	EnablePartitionDiscovery   *interface{} `json:"enablePartitionDiscovery,omitempty"`
	FileListPath               *interface{} `json:"fileListPath,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"`
	WildcardFileName           *interface{} `json:"wildcardFileName,omitempty"`
	WildcardFolderPath         *interface{} `json:"wildcardFolderPath,omitempty"`

	// Fields inherited from StoreReadSettings
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
}

func (AmazonS3CompatibleReadSettings) MarshalJSON ¶ added in v0.20240327.1081628

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

type AmazonS3ReadSettings ¶ added in v0.20240320.1143605

type AmazonS3ReadSettings struct {
	DeleteFilesAfterCompletion *interface{} `json:"deleteFilesAfterCompletion,omitempty"`
	EnablePartitionDiscovery   *interface{} `json:"enablePartitionDiscovery,omitempty"`
	FileListPath               *interface{} `json:"fileListPath,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"`
	WildcardFileName           *interface{} `json:"wildcardFileName,omitempty"`
	WildcardFolderPath         *interface{} `json:"wildcardFolderPath,omitempty"`

	// Fields inherited from StoreReadSettings
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
}

func (AmazonS3ReadSettings) MarshalJSON ¶ added in v0.20240327.1081628

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

type AppendVariableActivity ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type AppendVariableActivityTypeProperties ¶ added in v0.20240320.1143605

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

type AvroSink ¶ added in v0.20240320.1143605

type AvroSink struct {
	FormatSettings *AvroWriteSettings `json:"formatSettings,omitempty"`
	StoreSettings  StoreWriteSettings `json:"storeSettings"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (AvroSink) MarshalJSON ¶ added in v0.20240327.1081628

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

func (*AvroSink) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type AvroSource ¶ added in v0.20240320.1143605

type AvroSource struct {
	AdditionalColumns *interface{}      `json:"additionalColumns,omitempty"`
	StoreSettings     StoreReadSettings `json:"storeSettings"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (AvroSource) MarshalJSON ¶ added in v0.20240327.1081628

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

func (*AvroSource) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type AvroWriteSettings ¶ added in v0.20240320.1143605

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

func (AvroWriteSettings) MarshalJSON ¶ added in v0.20240327.1081628

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

type AzureBlobFSReadSettings ¶ added in v0.20240320.1143605

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

	// Fields inherited from StoreReadSettings
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
}

func (AzureBlobFSReadSettings) MarshalJSON ¶ added in v0.20240327.1081628

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

type AzureBlobFSSink ¶ added in v0.20240320.1143605

type AzureBlobFSSink struct {
	CopyBehavior *interface{}    `json:"copyBehavior,omitempty"`
	Metadata     *[]MetadataItem `json:"metadata,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (AzureBlobFSSink) MarshalJSON ¶ added in v0.20240327.1081628

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

type AzureBlobFSSource ¶ added in v0.20240320.1143605

type AzureBlobFSSource struct {
	Recursive           *interface{} `json:"recursive,omitempty"`
	SkipHeaderLineCount *interface{} `json:"skipHeaderLineCount,omitempty"`
	TreatEmptyAsNull    *interface{} `json:"treatEmptyAsNull,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (AzureBlobFSSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type AzureBlobFSWriteSettings ¶ added in v0.20240320.1143605

type AzureBlobFSWriteSettings struct {
	BlockSizeInMB *interface{} `json:"blockSizeInMB,omitempty"`

	// Fields inherited from StoreWriteSettings
	CopyBehavior             *interface{}    `json:"copyBehavior,omitempty"`
	DisableMetricsCollection *interface{}    `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{}    `json:"maxConcurrentConnections,omitempty"`
	Metadata                 *[]MetadataItem `json:"metadata,omitempty"`
}

func (AzureBlobFSWriteSettings) MarshalJSON ¶ added in v0.20240327.1081628

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

type AzureBlobStorageReadSettings ¶ added in v0.20240320.1143605

type AzureBlobStorageReadSettings struct {
	DeleteFilesAfterCompletion *interface{} `json:"deleteFilesAfterCompletion,omitempty"`
	EnablePartitionDiscovery   *interface{} `json:"enablePartitionDiscovery,omitempty"`
	FileListPath               *interface{} `json:"fileListPath,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"`
	WildcardFileName           *interface{} `json:"wildcardFileName,omitempty"`
	WildcardFolderPath         *interface{} `json:"wildcardFolderPath,omitempty"`

	// Fields inherited from StoreReadSettings
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
}

func (AzureBlobStorageReadSettings) MarshalJSON ¶ added in v0.20240327.1081628

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

type AzureBlobStorageWriteSettings ¶ added in v0.20240320.1143605

type AzureBlobStorageWriteSettings struct {
	BlockSizeInMB *interface{} `json:"blockSizeInMB,omitempty"`

	// Fields inherited from StoreWriteSettings
	CopyBehavior             *interface{}    `json:"copyBehavior,omitempty"`
	DisableMetricsCollection *interface{}    `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{}    `json:"maxConcurrentConnections,omitempty"`
	Metadata                 *[]MetadataItem `json:"metadata,omitempty"`
}

func (AzureBlobStorageWriteSettings) MarshalJSON ¶ added in v0.20240327.1081628

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

type AzureDataExplorerCommandActivity ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type AzureDataExplorerCommandActivityTypeProperties ¶ added in v0.20240320.1143605

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

type AzureDataExplorerSink ¶ added in v0.20240320.1143605

type AzureDataExplorerSink struct {
	FlushImmediately       *interface{} `json:"flushImmediately,omitempty"`
	IngestionMappingAsJson *interface{} `json:"ingestionMappingAsJson,omitempty"`
	IngestionMappingName   *interface{} `json:"ingestionMappingName,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (AzureDataExplorerSink) MarshalJSON ¶ added in v0.20240327.1081628

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

type AzureDataExplorerSource ¶ added in v0.20240320.1143605

type AzureDataExplorerSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	NoTruncation      *interface{} `json:"noTruncation,omitempty"`
	Query             interface{}  `json:"query"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (AzureDataExplorerSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type AzureDataLakeStoreReadSettings ¶ added in v0.20240320.1143605

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

	// Fields inherited from StoreReadSettings
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
}

func (AzureDataLakeStoreReadSettings) MarshalJSON ¶ added in v0.20240327.1081628

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

type AzureDataLakeStoreSink ¶ added in v0.20240320.1143605

type AzureDataLakeStoreSink struct {
	CopyBehavior                 *interface{} `json:"copyBehavior,omitempty"`
	EnableAdlsSingleFileParallel *interface{} `json:"enableAdlsSingleFileParallel,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (AzureDataLakeStoreSink) MarshalJSON ¶ added in v0.20240327.1081628

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

type AzureDataLakeStoreSource ¶ added in v0.20240320.1143605

type AzureDataLakeStoreSource struct {
	Recursive *interface{} `json:"recursive,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (AzureDataLakeStoreSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type AzureDataLakeStoreWriteSettings ¶ added in v0.20240320.1143605

type AzureDataLakeStoreWriteSettings struct {
	ExpiryDateTime *interface{} `json:"expiryDateTime,omitempty"`

	// Fields inherited from StoreWriteSettings
	CopyBehavior             *interface{}    `json:"copyBehavior,omitempty"`
	DisableMetricsCollection *interface{}    `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{}    `json:"maxConcurrentConnections,omitempty"`
	Metadata                 *[]MetadataItem `json:"metadata,omitempty"`
}

func (AzureDataLakeStoreWriteSettings) MarshalJSON ¶ added in v0.20240327.1081628

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

type AzureDatabricksDeltaLakeExportCommand ¶ added in v0.20240320.1143605

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

func (AzureDatabricksDeltaLakeExportCommand) MarshalJSON ¶ added in v0.20240327.1081628

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

type AzureDatabricksDeltaLakeImportCommand ¶ added in v0.20240320.1143605

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

func (AzureDatabricksDeltaLakeImportCommand) MarshalJSON ¶ added in v0.20240327.1081628

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

type AzureDatabricksDeltaLakeSink ¶ added in v0.20240320.1143605

type AzureDatabricksDeltaLakeSink struct {
	ImportSettings *AzureDatabricksDeltaLakeImportCommand `json:"importSettings,omitempty"`
	PreCopyScript  *interface{}                           `json:"preCopyScript,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (AzureDatabricksDeltaLakeSink) MarshalJSON ¶ added in v0.20240327.1081628

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

type AzureDatabricksDeltaLakeSource ¶ added in v0.20240320.1143605

type AzureDatabricksDeltaLakeSource struct {
	ExportSettings *AzureDatabricksDeltaLakeExportCommand `json:"exportSettings,omitempty"`
	Query          *interface{}                           `json:"query,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (AzureDatabricksDeltaLakeSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type AzureFileStorageReadSettings ¶ added in v0.20240320.1143605

type AzureFileStorageReadSettings struct {
	DeleteFilesAfterCompletion *interface{} `json:"deleteFilesAfterCompletion,omitempty"`
	EnablePartitionDiscovery   *interface{} `json:"enablePartitionDiscovery,omitempty"`
	FileListPath               *interface{} `json:"fileListPath,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"`
	WildcardFileName           *interface{} `json:"wildcardFileName,omitempty"`
	WildcardFolderPath         *interface{} `json:"wildcardFolderPath,omitempty"`

	// Fields inherited from StoreReadSettings
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
}

func (AzureFileStorageReadSettings) MarshalJSON ¶ added in v0.20240327.1081628

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

type AzureFileStorageWriteSettings ¶ added in v0.20240320.1143605

type AzureFileStorageWriteSettings struct {

	// Fields inherited from StoreWriteSettings
	CopyBehavior             *interface{}    `json:"copyBehavior,omitempty"`
	DisableMetricsCollection *interface{}    `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{}    `json:"maxConcurrentConnections,omitempty"`
	Metadata                 *[]MetadataItem `json:"metadata,omitempty"`
}

func (AzureFileStorageWriteSettings) MarshalJSON ¶ added in v0.20240327.1081628

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

type AzureFunctionActivity ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type AzureFunctionActivityMethod ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type AzureFunctionActivityTypeProperties ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type AzureMLBatchExecutionActivityTypeProperties ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type AzureMLExecutePipelineActivityTypeProperties ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type AzureMLUpdateResourceActivityTypeProperties ¶ added in v0.20240320.1143605

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

type AzureMLWebServiceFile ¶ added in v0.20240320.1143605

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

type AzureMariaDBSource ¶ added in v0.20240320.1143605

type AzureMariaDBSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (AzureMariaDBSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type AzureMySqlSink ¶ added in v0.20240320.1143605

type AzureMySqlSink struct {
	PreCopyScript *interface{} `json:"preCopyScript,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (AzureMySqlSink) MarshalJSON ¶ added in v0.20240327.1081628

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

type AzureMySqlSource ¶ added in v0.20240320.1143605

type AzureMySqlSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (AzureMySqlSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type AzurePostgreSqlSink ¶ added in v0.20240320.1143605

type AzurePostgreSqlSink struct {
	PreCopyScript *interface{} `json:"preCopyScript,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (AzurePostgreSqlSink) MarshalJSON ¶ added in v0.20240327.1081628

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

type AzurePostgreSqlSource ¶ added in v0.20240320.1143605

type AzurePostgreSqlSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (AzurePostgreSqlSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type AzureQueueSink ¶ added in v0.20240320.1143605

type AzureQueueSink struct {

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (AzureQueueSink) MarshalJSON ¶ added in v0.20240327.1081628

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

type AzureSearchIndexSink ¶ added in v0.20240320.1143605

type AzureSearchIndexSink struct {
	WriteBehavior *AzureSearchIndexWriteBehaviorType `json:"writeBehavior,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (AzureSearchIndexSink) MarshalJSON ¶ added in v0.20240327.1081628

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

type AzureSearchIndexWriteBehaviorType ¶ added in v0.20240320.1143605

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

func (*AzureSearchIndexWriteBehaviorType) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type AzureSqlSink ¶ added in v0.20240320.1143605

type AzureSqlSink struct {
	PreCopyScript                         *interface{}       `json:"preCopyScript,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"`
	UpsertSettings                        *SqlUpsertSettings `json:"upsertSettings,omitempty"`
	WriteBehavior                         *interface{}       `json:"writeBehavior,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (AzureSqlSink) MarshalJSON ¶ added in v0.20240327.1081628

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

type AzureSqlSource ¶ added in v0.20240320.1143605

type AzureSqlSource struct {
	AdditionalColumns            *interface{}          `json:"additionalColumns,omitempty"`
	IsolationLevel               *interface{}          `json:"isolationLevel,omitempty"`
	PartitionOption              *interface{}          `json:"partitionOption,omitempty"`
	PartitionSettings            *SqlPartitionSettings `json:"partitionSettings,omitempty"`
	ProduceAdditionalTypes       *interface{}          `json:"produceAdditionalTypes,omitempty"`
	QueryTimeout                 *interface{}          `json:"queryTimeout,omitempty"`
	SqlReaderQuery               *interface{}          `json:"sqlReaderQuery,omitempty"`
	SqlReaderStoredProcedureName *interface{}          `json:"sqlReaderStoredProcedureName,omitempty"`
	StoredProcedureParameters    *interface{}          `json:"storedProcedureParameters,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (AzureSqlSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type AzureTableSink ¶ added in v0.20240320.1143605

type AzureTableSink struct {
	AzureTableDefaultPartitionKeyValue *interface{} `json:"azureTableDefaultPartitionKeyValue,omitempty"`
	AzureTableInsertType               *interface{} `json:"azureTableInsertType,omitempty"`
	AzureTablePartitionKeyName         *interface{} `json:"azureTablePartitionKeyName,omitempty"`
	AzureTableRowKeyName               *interface{} `json:"azureTableRowKeyName,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (AzureTableSink) MarshalJSON ¶ added in v0.20240327.1081628

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

type AzureTableSource ¶ added in v0.20240320.1143605

type AzureTableSource struct {
	AdditionalColumns                   *interface{} `json:"additionalColumns,omitempty"`
	AzureTableSourceIgnoreTableNotFound *interface{} `json:"azureTableSourceIgnoreTableNotFound,omitempty"`
	AzureTableSourceQuery               *interface{} `json:"azureTableSourceQuery,omitempty"`
	QueryTimeout                        *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (AzureTableSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type BigDataPoolParametrizationReference ¶ added in v0.20240320.1143605

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

type BigDataPoolReferenceType ¶ added in v0.20240320.1143605

type BigDataPoolReferenceType string
const (
	BigDataPoolReferenceTypeBigDataPoolReference BigDataPoolReferenceType = "BigDataPoolReference"
)

func (*BigDataPoolReferenceType) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type BinaryReadSettings ¶ added in v0.20240320.1143605

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

func (BinaryReadSettings) MarshalJSON ¶ added in v0.20240327.1081628

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

func (*BinaryReadSettings) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type BinarySink ¶ added in v0.20240320.1143605

type BinarySink struct {
	StoreSettings StoreWriteSettings `json:"storeSettings"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (BinarySink) MarshalJSON ¶ added in v0.20240327.1081628

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

func (*BinarySink) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type BinarySource ¶ added in v0.20240320.1143605

type BinarySource struct {
	FormatSettings *BinaryReadSettings `json:"formatSettings,omitempty"`
	StoreSettings  StoreReadSettings   `json:"storeSettings"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (BinarySource) MarshalJSON ¶ added in v0.20240327.1081628

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

func (*BinarySource) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type BlobSink ¶ added in v0.20240320.1143605

type BlobSink struct {
	BlobWriterAddHeader      *interface{}    `json:"blobWriterAddHeader,omitempty"`
	BlobWriterDateTimeFormat *interface{}    `json:"blobWriterDateTimeFormat,omitempty"`
	BlobWriterOverwriteFiles *interface{}    `json:"blobWriterOverwriteFiles,omitempty"`
	CopyBehavior             *interface{}    `json:"copyBehavior,omitempty"`
	Metadata                 *[]MetadataItem `json:"metadata,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (BlobSink) MarshalJSON ¶ added in v0.20240327.1081628

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

type BlobSource ¶ added in v0.20240320.1143605

type BlobSource struct {
	Recursive           *interface{} `json:"recursive,omitempty"`
	SkipHeaderLineCount *interface{} `json:"skipHeaderLineCount,omitempty"`
	TreatEmptyAsNull    *interface{} `json:"treatEmptyAsNull,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (BlobSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type CassandraSource ¶ added in v0.20240320.1143605

type CassandraSource struct {
	AdditionalColumns *interface{}                          `json:"additionalColumns,omitempty"`
	ConsistencyLevel  *CassandraSourceReadConsistencyLevels `json:"consistencyLevel,omitempty"`
	Query             *interface{}                          `json:"query,omitempty"`
	QueryTimeout      *interface{}                          `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (CassandraSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type CassandraSourceReadConsistencyLevels ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type CommonDataServiceForAppsSink ¶ added in v0.20240320.1143605

type CommonDataServiceForAppsSink struct {
	AlternateKeyName *interface{}              `json:"alternateKeyName,omitempty"`
	IgnoreNullValues *interface{}              `json:"ignoreNullValues,omitempty"`
	WriteBehavior    DynamicsSinkWriteBehavior `json:"writeBehavior"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (CommonDataServiceForAppsSink) MarshalJSON ¶ added in v0.20240327.1081628

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

type CommonDataServiceForAppsSource ¶ added in v0.20240320.1143605

type CommonDataServiceForAppsSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (CommonDataServiceForAppsSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type CompressionReadSettings ¶ added in v0.20240320.1143605

type CompressionReadSettings interface {
}

type ConcurSource ¶ added in v0.20240320.1143605

type ConcurSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (ConcurSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type ConfigurationType ¶ added in v0.20240320.1143605

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

func (*ConfigurationType) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type ControlActivity ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type CopyActivity ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type CopyActivityLogSettings ¶ added in v0.20240320.1143605

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

type CopyActivityTypeProperties ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type CopySink ¶ added in v0.20240320.1143605

type CopySink interface {
}

type CopySource ¶ added in v0.20240320.1143605

type CopySource interface {
}

type CopyTranslator ¶ added in v0.20240327.1081628

type CopyTranslator interface {
}

type CosmosDbMongoDbApiSink ¶ added in v0.20240320.1143605

type CosmosDbMongoDbApiSink struct {
	WriteBehavior *interface{} `json:"writeBehavior,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (CosmosDbMongoDbApiSink) MarshalJSON ¶ added in v0.20240327.1081628

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

type CosmosDbMongoDbApiSource ¶ added in v0.20240320.1143605

type CosmosDbMongoDbApiSource struct {
	AdditionalColumns *interface{}                    `json:"additionalColumns,omitempty"`
	BatchSize         *interface{}                    `json:"batchSize,omitempty"`
	CursorMethods     *MongoDbCursorMethodsProperties `json:"cursorMethods,omitempty"`
	Filter            *interface{}                    `json:"filter,omitempty"`
	QueryTimeout      *interface{}                    `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (CosmosDbMongoDbApiSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type CosmosDbSqlApiSink ¶ added in v0.20240320.1143605

type CosmosDbSqlApiSink struct {
	WriteBehavior *interface{} `json:"writeBehavior,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (CosmosDbSqlApiSink) MarshalJSON ¶ added in v0.20240327.1081628

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

type CosmosDbSqlApiSource ¶ added in v0.20240320.1143605

type CosmosDbSqlApiSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	DetectDatetime    *interface{} `json:"detectDatetime,omitempty"`
	PageSize          *interface{} `json:"pageSize,omitempty"`
	PreferredRegions  *interface{} `json:"preferredRegions,omitempty"`
	Query             *interface{} `json:"query,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (CosmosDbSqlApiSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type CouchbaseSource ¶ added in v0.20240320.1143605

type CouchbaseSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (CouchbaseSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type CreateOrUpdateOperationOptions ¶

type CreateOrUpdateOperationOptions struct {
	IfMatch *string
}

func DefaultCreateOrUpdateOperationOptions ¶

func DefaultCreateOrUpdateOperationOptions() CreateOrUpdateOperationOptions

func (CreateOrUpdateOperationOptions) ToHeaders ¶

func (CreateOrUpdateOperationOptions) ToOData ¶

func (CreateOrUpdateOperationOptions) ToQuery ¶

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 ¶

type CreateRunOperationResponse ¶

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

type CreateRunResponse ¶

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

type CredentialReference ¶ added in v0.20240320.1143605

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

type CredentialReferenceType ¶ added in v0.20240320.1143605

type CredentialReferenceType string
const (
	CredentialReferenceTypeCredentialReference CredentialReferenceType = "CredentialReference"
)

func (*CredentialReferenceType) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type CustomActivity ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type CustomActivityReferenceObject ¶ added in v0.20240320.1143605

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

type CustomActivityTypeProperties ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type DWCopyCommandSettings ¶ added in v0.20240320.1143605

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

type DataFlowReference ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

type DataFlowReferenceType string
const (
	DataFlowReferenceTypeDataFlowReference DataFlowReferenceType = "DataFlowReference"
)

func (*DataFlowReferenceType) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type DataFlowStagingInfo ¶ added in v0.20240320.1143605

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

type DataLakeAnalyticsUSQLActivity ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type DataLakeAnalyticsUSQLActivityTypeProperties ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type DatabricksNotebookActivityTypeProperties ¶ added in v0.20240320.1143605

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

type DatabricksSparkJarActivity ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type DatabricksSparkJarActivityTypeProperties ¶ added in v0.20240320.1143605

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

type DatabricksSparkPythonActivity ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type DatabricksSparkPythonActivityTypeProperties ¶ added in v0.20240320.1143605

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

type DatasetReference ¶ added in v0.20240320.1143605

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

type DatasetReferenceType ¶ added in v0.20240320.1143605

type DatasetReferenceType string
const (
	DatasetReferenceTypeDatasetReference DatasetReferenceType = "DatasetReference"
)

func (*DatasetReferenceType) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type Db2Source ¶ added in v0.20240320.1143605

type Db2Source struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (Db2Source) MarshalJSON ¶ added in v0.20240327.1081628

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

type DeleteActivity ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type DeleteActivityTypeProperties ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type DeleteOperationResponse ¶

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

type DelimitedTextReadSettings ¶ added in v0.20240320.1143605

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

func (DelimitedTextReadSettings) MarshalJSON ¶ added in v0.20240327.1081628

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

func (*DelimitedTextReadSettings) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type DelimitedTextSink ¶ added in v0.20240320.1143605

type DelimitedTextSink struct {
	FormatSettings *DelimitedTextWriteSettings `json:"formatSettings,omitempty"`
	StoreSettings  StoreWriteSettings          `json:"storeSettings"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (DelimitedTextSink) MarshalJSON ¶ added in v0.20240327.1081628

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

func (*DelimitedTextSink) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type DelimitedTextSource ¶ added in v0.20240320.1143605

type DelimitedTextSource struct {
	AdditionalColumns *interface{}               `json:"additionalColumns,omitempty"`
	FormatSettings    *DelimitedTextReadSettings `json:"formatSettings,omitempty"`
	StoreSettings     StoreReadSettings          `json:"storeSettings"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (DelimitedTextSource) MarshalJSON ¶ added in v0.20240327.1081628

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

func (*DelimitedTextSource) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type DelimitedTextWriteSettings ¶ added in v0.20240320.1143605

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

func (DelimitedTextWriteSettings) MarshalJSON ¶ added in v0.20240327.1081628

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

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 ¶ added in v0.20240320.1143605

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

type DocumentDbCollectionSink ¶ added in v0.20240320.1143605

type DocumentDbCollectionSink struct {
	NestingSeparator *interface{} `json:"nestingSeparator,omitempty"`
	WriteBehavior    *interface{} `json:"writeBehavior,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (DocumentDbCollectionSink) MarshalJSON ¶ added in v0.20240327.1081628

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

type DocumentDbCollectionSource ¶ added in v0.20240320.1143605

type DocumentDbCollectionSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	NestingSeparator  *interface{} `json:"nestingSeparator,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (DocumentDbCollectionSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type DrillSource ¶ added in v0.20240320.1143605

type DrillSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (DrillSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type DynamicsAXSource ¶ added in v0.20240320.1143605

type DynamicsAXSource struct {
	AdditionalColumns  *interface{} `json:"additionalColumns,omitempty"`
	HTTPRequestTimeout *interface{} `json:"httpRequestTimeout,omitempty"`
	Query              *interface{} `json:"query,omitempty"`
	QueryTimeout       *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (DynamicsAXSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type DynamicsCrmSink ¶ added in v0.20240320.1143605

type DynamicsCrmSink struct {
	AlternateKeyName *interface{}              `json:"alternateKeyName,omitempty"`
	IgnoreNullValues *interface{}              `json:"ignoreNullValues,omitempty"`
	WriteBehavior    DynamicsSinkWriteBehavior `json:"writeBehavior"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (DynamicsCrmSink) MarshalJSON ¶ added in v0.20240327.1081628

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

type DynamicsCrmSource ¶ added in v0.20240320.1143605

type DynamicsCrmSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (DynamicsCrmSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type DynamicsSink ¶ added in v0.20240320.1143605

type DynamicsSink struct {
	AlternateKeyName *interface{}              `json:"alternateKeyName,omitempty"`
	IgnoreNullValues *interface{}              `json:"ignoreNullValues,omitempty"`
	WriteBehavior    DynamicsSinkWriteBehavior `json:"writeBehavior"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (DynamicsSink) MarshalJSON ¶ added in v0.20240327.1081628

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

type DynamicsSinkWriteBehavior ¶ added in v0.20240320.1143605

type DynamicsSinkWriteBehavior string
const (
	DynamicsSinkWriteBehaviorUpsert DynamicsSinkWriteBehavior = "Upsert"
)

func (*DynamicsSinkWriteBehavior) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type DynamicsSource ¶ added in v0.20240320.1143605

type DynamicsSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (DynamicsSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type EloquaSource ¶ added in v0.20240320.1143605

type EloquaSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (EloquaSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type ExcelSource ¶ added in v0.20240320.1143605

type ExcelSource struct {
	AdditionalColumns *interface{}      `json:"additionalColumns,omitempty"`
	StoreSettings     StoreReadSettings `json:"storeSettings"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (ExcelSource) MarshalJSON ¶ added in v0.20240327.1081628

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

func (*ExcelSource) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type ExecuteDataFlowActivity ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type ExecuteDataFlowActivityTypeProperties ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type ExecutePipelineActivity ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type ExecutePipelineActivityPolicy ¶ added in v0.20240320.1143605

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

type ExecutePipelineActivityTypeProperties ¶ added in v0.20240320.1143605

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

type ExecutePowerQueryActivityTypeProperties ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type ExecuteSSISPackageActivityTypeProperties ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type ExecutionActivity ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type ExportSettings ¶ added in v0.20240327.1081628

type ExportSettings interface {
}

type Expression ¶ added in v0.20240320.1143605

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

type ExpressionType ¶ added in v0.20240320.1143605

type ExpressionType string
const (
	ExpressionTypeExpression ExpressionType = "Expression"
)

func (*ExpressionType) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type ExpressionV2 ¶ added in v0.20240320.1143605

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

type ExpressionV2Type ¶ added in v0.20240320.1143605

type ExpressionV2Type string
const (
	ExpressionV2TypeBinary   ExpressionV2Type = "Binary"
	ExpressionV2TypeConstant ExpressionV2Type = "Constant"
	ExpressionV2TypeField    ExpressionV2Type = "Field"
	ExpressionV2TypeNAry     ExpressionV2Type = "NAry"
	ExpressionV2TypeUnary    ExpressionV2Type = "Unary"
)

func (*ExpressionV2Type) UnmarshalJSON ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type FailActivityTypeProperties ¶ added in v0.20240320.1143605

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

type FileServerReadSettings ¶ added in v0.20240320.1143605

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

	// Fields inherited from StoreReadSettings
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
}

func (FileServerReadSettings) MarshalJSON ¶ added in v0.20240327.1081628

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

type FileServerWriteSettings ¶ added in v0.20240320.1143605

type FileServerWriteSettings struct {

	// Fields inherited from StoreWriteSettings
	CopyBehavior             *interface{}    `json:"copyBehavior,omitempty"`
	DisableMetricsCollection *interface{}    `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{}    `json:"maxConcurrentConnections,omitempty"`
	Metadata                 *[]MetadataItem `json:"metadata,omitempty"`
}

func (FileServerWriteSettings) MarshalJSON ¶ added in v0.20240327.1081628

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

type FileSystemSink ¶ added in v0.20240320.1143605

type FileSystemSink struct {
	CopyBehavior *interface{} `json:"copyBehavior,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (FileSystemSink) MarshalJSON ¶ added in v0.20240327.1081628

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

type FileSystemSource ¶ added in v0.20240320.1143605

type FileSystemSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Recursive         *interface{} `json:"recursive,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (FileSystemSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type FilterActivity ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type FilterActivityTypeProperties ¶ added in v0.20240320.1143605

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

type ForEachActivity ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type ForEachActivityTypeProperties ¶ added in v0.20240320.1143605

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

func (*ForEachActivityTypeProperties) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type FormatReadSettings ¶ added in v0.20240320.1143605

type FormatReadSettings interface {
}

type FormatWriteSettings ¶ added in v0.20240327.1081628

type FormatWriteSettings interface {
}

type FtpReadSettings ¶ added in v0.20240320.1143605

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

	// Fields inherited from StoreReadSettings
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
}

func (FtpReadSettings) MarshalJSON ¶ added in v0.20240327.1081628

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

type GetMetadataActivity ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type GetMetadataActivityTypeProperties ¶ added in v0.20240320.1143605

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

func (*GetMetadataActivityTypeProperties) UnmarshalJSON ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

type GoogleAdWordsSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (GoogleAdWordsSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type GoogleBigQuerySource ¶ added in v0.20240320.1143605

type GoogleBigQuerySource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (GoogleBigQuerySource) MarshalJSON ¶ added in v0.20240327.1081628

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

type GoogleBigQueryV2Source ¶ added in v0.20240320.1143605

type GoogleBigQueryV2Source struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (GoogleBigQueryV2Source) MarshalJSON ¶ added in v0.20240327.1081628

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

type GoogleCloudStorageReadSettings ¶ added in v0.20240320.1143605

type GoogleCloudStorageReadSettings struct {
	DeleteFilesAfterCompletion *interface{} `json:"deleteFilesAfterCompletion,omitempty"`
	EnablePartitionDiscovery   *interface{} `json:"enablePartitionDiscovery,omitempty"`
	FileListPath               *interface{} `json:"fileListPath,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"`
	WildcardFileName           *interface{} `json:"wildcardFileName,omitempty"`
	WildcardFolderPath         *interface{} `json:"wildcardFolderPath,omitempty"`

	// Fields inherited from StoreReadSettings
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
}

func (GoogleCloudStorageReadSettings) MarshalJSON ¶ added in v0.20240327.1081628

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

type GreenplumSource ¶ added in v0.20240320.1143605

type GreenplumSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (GreenplumSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type HBaseSource ¶ added in v0.20240320.1143605

type HBaseSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (HBaseSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type HDInsightActivityDebugInfoOption ¶ added in v0.20240320.1143605

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

func (*HDInsightActivityDebugInfoOption) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type HDInsightHiveActivity ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type HDInsightHiveActivityTypeProperties ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type HDInsightMapReduceActivityTypeProperties ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type HDInsightPigActivityTypeProperties ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type HDInsightSparkActivityTypeProperties ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type HDInsightStreamingActivityTypeProperties ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

type HTTPReadSettings struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	AdditionalHeaders *interface{} `json:"additionalHeaders,omitempty"`
	RequestBody       *interface{} `json:"requestBody,omitempty"`
	RequestMethod     *interface{} `json:"requestMethod,omitempty"`
	RequestTimeout    *interface{} `json:"requestTimeout,omitempty"`

	// Fields inherited from StoreReadSettings
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
}

func (HTTPReadSettings) MarshalJSON ¶ added in v0.20240327.1081628

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

type HTTPSource ¶ added in v0.20240320.1143605

type HTTPSource struct {
	HTTPRequestTimeout *interface{} `json:"httpRequestTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (HTTPSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type HdfsReadSettings ¶ added in v0.20240320.1143605

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

	// Fields inherited from StoreReadSettings
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
}

func (HdfsReadSettings) MarshalJSON ¶ added in v0.20240327.1081628

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

type HdfsSource ¶ added in v0.20240320.1143605

type HdfsSource struct {
	DistcpSettings *DistcpSettings `json:"distcpSettings,omitempty"`
	Recursive      *interface{}    `json:"recursive,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (HdfsSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type HiveSource ¶ added in v0.20240320.1143605

type HiveSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (HiveSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type HubspotSource ¶ added in v0.20240320.1143605

type HubspotSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (HubspotSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type IfConditionActivity ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type IfConditionActivityTypeProperties ¶ added in v0.20240320.1143605

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

func (*IfConditionActivityTypeProperties) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type ImpalaSource ¶ added in v0.20240320.1143605

type ImpalaSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (ImpalaSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type ImportSettings ¶ added in v0.20240327.1081628

type ImportSettings interface {
}

type InformixSink ¶ added in v0.20240320.1143605

type InformixSink struct {
	PreCopyScript *interface{} `json:"preCopyScript,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (InformixSink) MarshalJSON ¶ added in v0.20240327.1081628

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

type InformixSource ¶ added in v0.20240320.1143605

type InformixSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (InformixSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type IntegrationRuntimeReference ¶ added in v0.20240320.1143605

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

type IntegrationRuntimeReferenceType ¶ added in v0.20240320.1143605

type IntegrationRuntimeReferenceType string
const (
	IntegrationRuntimeReferenceTypeIntegrationRuntimeReference IntegrationRuntimeReferenceType = "IntegrationRuntimeReference"
)

func (*IntegrationRuntimeReferenceType) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type JiraSource ¶ added in v0.20240320.1143605

type JiraSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (JiraSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type JsonReadSettings ¶ added in v0.20240320.1143605

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

func (JsonReadSettings) MarshalJSON ¶ added in v0.20240327.1081628

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

func (*JsonReadSettings) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type JsonSink ¶ added in v0.20240320.1143605

type JsonSink struct {
	FormatSettings *JsonWriteSettings `json:"formatSettings,omitempty"`
	StoreSettings  StoreWriteSettings `json:"storeSettings"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (JsonSink) MarshalJSON ¶ added in v0.20240327.1081628

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

func (*JsonSink) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type JsonSource ¶ added in v0.20240320.1143605

type JsonSource struct {
	AdditionalColumns *interface{}      `json:"additionalColumns,omitempty"`
	FormatSettings    *JsonReadSettings `json:"formatSettings,omitempty"`
	StoreSettings     StoreReadSettings `json:"storeSettings"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (JsonSource) MarshalJSON ¶ added in v0.20240327.1081628

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

func (*JsonSource) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type JsonWriteSettings ¶ added in v0.20240320.1143605

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

func (JsonWriteSettings) MarshalJSON ¶ added in v0.20240327.1081628

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

type LakeHouseReadSettings ¶ added in v0.20240320.1143605

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

	// Fields inherited from StoreReadSettings
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
}

func (LakeHouseReadSettings) MarshalJSON ¶ added in v0.20240327.1081628

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

type LakeHouseTableSink ¶ added in v0.20240320.1143605

type LakeHouseTableSink struct {
	PartitionNameList *interface{} `json:"partitionNameList,omitempty"`
	PartitionOption   *interface{} `json:"partitionOption,omitempty"`
	TableActionOption *interface{} `json:"tableActionOption,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (LakeHouseTableSink) MarshalJSON ¶ added in v0.20240327.1081628

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

type LakeHouseTableSource ¶ added in v0.20240320.1143605

type LakeHouseTableSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	TimestampAsOf     *interface{} `json:"timestampAsOf,omitempty"`
	VersionAsOf       *interface{} `json:"versionAsOf,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (LakeHouseTableSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type LakeHouseWriteSettings ¶ added in v0.20240320.1143605

type LakeHouseWriteSettings struct {

	// Fields inherited from StoreWriteSettings
	CopyBehavior             *interface{}    `json:"copyBehavior,omitempty"`
	DisableMetricsCollection *interface{}    `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{}    `json:"maxConcurrentConnections,omitempty"`
	Metadata                 *[]MetadataItem `json:"metadata,omitempty"`
}

func (LakeHouseWriteSettings) MarshalJSON ¶ added in v0.20240327.1081628

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

type LinkedServiceReference ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type LogSettings ¶ added in v0.20240320.1143605

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

type LogStorageSettings ¶ added in v0.20240320.1143605

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

type LookupActivity ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type LookupActivityTypeProperties ¶ added in v0.20240320.1143605

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

func (*LookupActivityTypeProperties) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type MagentoSource ¶ added in v0.20240320.1143605

type MagentoSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (MagentoSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type MariaDBSource ¶ added in v0.20240320.1143605

type MariaDBSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (MariaDBSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type MarketoSource ¶ added in v0.20240320.1143605

type MarketoSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (MarketoSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type MetadataItem ¶ added in v0.20240320.1143605

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

type MicrosoftAccessSink ¶ added in v0.20240320.1143605

type MicrosoftAccessSink struct {
	PreCopyScript *interface{} `json:"preCopyScript,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (MicrosoftAccessSink) MarshalJSON ¶ added in v0.20240327.1081628

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

type MicrosoftAccessSource ¶ added in v0.20240320.1143605

type MicrosoftAccessSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (MicrosoftAccessSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type MongoDbAtlasSink ¶ added in v0.20240320.1143605

type MongoDbAtlasSink struct {
	WriteBehavior *interface{} `json:"writeBehavior,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (MongoDbAtlasSink) MarshalJSON ¶ added in v0.20240327.1081628

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

type MongoDbAtlasSource ¶ added in v0.20240320.1143605

type MongoDbAtlasSource struct {
	AdditionalColumns *interface{}                    `json:"additionalColumns,omitempty"`
	BatchSize         *interface{}                    `json:"batchSize,omitempty"`
	CursorMethods     *MongoDbCursorMethodsProperties `json:"cursorMethods,omitempty"`
	Filter            *interface{}                    `json:"filter,omitempty"`
	QueryTimeout      *interface{}                    `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (MongoDbAtlasSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type MongoDbCursorMethodsProperties ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

type MongoDbSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (MongoDbSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type MongoDbV2Sink ¶ added in v0.20240320.1143605

type MongoDbV2Sink struct {
	WriteBehavior *interface{} `json:"writeBehavior,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (MongoDbV2Sink) MarshalJSON ¶ added in v0.20240327.1081628

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

type MongoDbV2Source ¶ added in v0.20240320.1143605

type MongoDbV2Source struct {
	AdditionalColumns *interface{}                    `json:"additionalColumns,omitempty"`
	BatchSize         *interface{}                    `json:"batchSize,omitempty"`
	CursorMethods     *MongoDbCursorMethodsProperties `json:"cursorMethods,omitempty"`
	Filter            *interface{}                    `json:"filter,omitempty"`
	QueryTimeout      *interface{}                    `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (MongoDbV2Source) MarshalJSON ¶ added in v0.20240327.1081628

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

type MySqlSource ¶ added in v0.20240320.1143605

type MySqlSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (MySqlSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type NetezzaPartitionSettings ¶ added in v0.20240320.1143605

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

type NetezzaSource ¶ added in v0.20240320.1143605

type NetezzaSource struct {
	AdditionalColumns *interface{}              `json:"additionalColumns,omitempty"`
	PartitionOption   *interface{}              `json:"partitionOption,omitempty"`
	PartitionSettings *NetezzaPartitionSettings `json:"partitionSettings,omitempty"`
	Query             *interface{}              `json:"query,omitempty"`
	QueryTimeout      *interface{}              `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (NetezzaSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type NotebookParameter ¶ added in v0.20240320.1143605

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

type NotebookParameterType ¶ added in v0.20240320.1143605

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

func (*NotebookParameterType) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type NotebookReferenceType ¶ added in v0.20240320.1143605

type NotebookReferenceType string
const (
	NotebookReferenceTypeNotebookReference NotebookReferenceType = "NotebookReference"
)

func (*NotebookReferenceType) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type ODataSource ¶ added in v0.20240320.1143605

type ODataSource struct {
	AdditionalColumns  *interface{} `json:"additionalColumns,omitempty"`
	HTTPRequestTimeout *interface{} `json:"httpRequestTimeout,omitempty"`
	Query              *interface{} `json:"query,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (ODataSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type OdbcSink ¶ added in v0.20240320.1143605

type OdbcSink struct {
	PreCopyScript *interface{} `json:"preCopyScript,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (OdbcSink) MarshalJSON ¶ added in v0.20240327.1081628

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

type OdbcSource ¶ added in v0.20240320.1143605

type OdbcSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (OdbcSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type Office365Source ¶ added in v0.20240320.1143605

type Office365Source struct {
	AllowedGroups      *interface{} `json:"allowedGroups,omitempty"`
	DateFilterColumn   *interface{} `json:"dateFilterColumn,omitempty"`
	EndTime            *interface{} `json:"endTime,omitempty"`
	OutputColumns      *interface{} `json:"outputColumns,omitempty"`
	StartTime          *interface{} `json:"startTime,omitempty"`
	UserScopeFilterUri *interface{} `json:"userScopeFilterUri,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (Office365Source) MarshalJSON ¶ added in v0.20240327.1081628

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

type OracleCloudStorageReadSettings ¶ added in v0.20240320.1143605

type OracleCloudStorageReadSettings struct {
	DeleteFilesAfterCompletion *interface{} `json:"deleteFilesAfterCompletion,omitempty"`
	EnablePartitionDiscovery   *interface{} `json:"enablePartitionDiscovery,omitempty"`
	FileListPath               *interface{} `json:"fileListPath,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"`
	WildcardFileName           *interface{} `json:"wildcardFileName,omitempty"`
	WildcardFolderPath         *interface{} `json:"wildcardFolderPath,omitempty"`

	// Fields inherited from StoreReadSettings
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
}

func (OracleCloudStorageReadSettings) MarshalJSON ¶ added in v0.20240327.1081628

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

type OraclePartitionSettings ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

type OracleServiceCloudSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (OracleServiceCloudSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type OracleSink ¶ added in v0.20240320.1143605

type OracleSink struct {
	PreCopyScript *interface{} `json:"preCopyScript,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (OracleSink) MarshalJSON ¶ added in v0.20240327.1081628

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

type OracleSource ¶ added in v0.20240320.1143605

type OracleSource struct {
	AdditionalColumns *interface{}             `json:"additionalColumns,omitempty"`
	OracleReaderQuery *interface{}             `json:"oracleReaderQuery,omitempty"`
	PartitionOption   *interface{}             `json:"partitionOption,omitempty"`
	PartitionSettings *OraclePartitionSettings `json:"partitionSettings,omitempty"`
	QueryTimeout      *interface{}             `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (OracleSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type OrcSink ¶ added in v0.20240320.1143605

type OrcSink struct {
	FormatSettings *OrcWriteSettings  `json:"formatSettings,omitempty"`
	StoreSettings  StoreWriteSettings `json:"storeSettings"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (OrcSink) MarshalJSON ¶ added in v0.20240327.1081628

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

func (*OrcSink) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type OrcSource ¶ added in v0.20240320.1143605

type OrcSource struct {
	AdditionalColumns *interface{}      `json:"additionalColumns,omitempty"`
	StoreSettings     StoreReadSettings `json:"storeSettings"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (OrcSource) MarshalJSON ¶ added in v0.20240327.1081628

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

func (*OrcSource) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type OrcWriteSettings ¶ added in v0.20240320.1143605

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

func (OrcWriteSettings) MarshalJSON ¶ added in v0.20240327.1081628

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

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 ¶ added in v0.20240320.1143605

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

func (ParquetReadSettings) MarshalJSON ¶ added in v0.20240327.1081628

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

func (*ParquetReadSettings) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type ParquetSink ¶ added in v0.20240320.1143605

type ParquetSink struct {
	FormatSettings *ParquetWriteSettings `json:"formatSettings,omitempty"`
	StoreSettings  StoreWriteSettings    `json:"storeSettings"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (ParquetSink) MarshalJSON ¶ added in v0.20240327.1081628

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

func (*ParquetSink) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type ParquetSource ¶ added in v0.20240320.1143605

type ParquetSource struct {
	AdditionalColumns *interface{}         `json:"additionalColumns,omitempty"`
	FormatSettings    *ParquetReadSettings `json:"formatSettings,omitempty"`
	StoreSettings     StoreReadSettings    `json:"storeSettings"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (ParquetSource) MarshalJSON ¶ added in v0.20240327.1081628

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

func (*ParquetSource) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type ParquetWriteSettings ¶ added in v0.20240320.1143605

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

func (ParquetWriteSettings) MarshalJSON ¶ added in v0.20240327.1081628

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

type PaypalSource ¶ added in v0.20240320.1143605

type PaypalSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (PaypalSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type PhoenixSource ¶ added in v0.20240320.1143605

type PhoenixSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (PhoenixSource) MarshalJSON ¶ added in v0.20240327.1081628

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

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 ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type PipelineReferenceType ¶ added in v0.20240320.1143605

type PipelineReferenceType string
const (
	PipelineReferenceTypePipelineReference PipelineReferenceType = "PipelineReference"
)

func (*PipelineReferenceType) UnmarshalJSON ¶ added in v0.20240320.1143605

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 ¶

type PipelinesClient ¶

type PipelinesClient struct {
	Client *resourcemanager.Client
}

func NewPipelinesClientWithBaseURI ¶

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

func (PipelinesClient) CreateOrUpdate ¶

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 ¶

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 ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

func (*PolybaseSettingsRejectType) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type PostgreSqlSource ¶ added in v0.20240320.1143605

type PostgreSqlSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (PostgreSqlSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type PostgreSqlV2Source ¶ added in v0.20240320.1143605

type PostgreSqlV2Source struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (PostgreSqlV2Source) MarshalJSON ¶ added in v0.20240327.1081628

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

type PowerQuerySink ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type PrestoSource ¶ added in v0.20240320.1143605

type PrestoSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (PrestoSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type QuickBooksSource ¶ added in v0.20240320.1143605

type QuickBooksSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (QuickBooksSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type RawActivityImpl ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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 RawCopyTranslatorImpl ¶ added in v0.20240327.1081628

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

RawCopyTranslatorImpl 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 RawExportSettingsImpl ¶ added in v0.20240327.1081628

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

RawExportSettingsImpl 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 ¶ added in v0.20240320.1143605

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 RawFormatWriteSettingsImpl ¶ added in v0.20240327.1081628

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

RawFormatWriteSettingsImpl 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 RawImportSettingsImpl ¶ added in v0.20240327.1081628

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

RawImportSettingsImpl 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 ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type RedshiftUnloadSettings ¶ added in v0.20240320.1143605

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

type RelationalSource ¶ added in v0.20240320.1143605

type RelationalSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (RelationalSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type ResponsysSource ¶ added in v0.20240320.1143605

type ResponsysSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (ResponsysSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type RestSink ¶ added in v0.20240320.1143605

type RestSink struct {
	AdditionalHeaders   *interface{} `json:"additionalHeaders,omitempty"`
	HTTPCompressionType *interface{} `json:"httpCompressionType,omitempty"`
	HTTPRequestTimeout  *interface{} `json:"httpRequestTimeout,omitempty"`
	RequestInterval     *interface{} `json:"requestInterval,omitempty"`
	RequestMethod       *interface{} `json:"requestMethod,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (RestSink) MarshalJSON ¶ added in v0.20240327.1081628

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

type RestSource ¶ added in v0.20240320.1143605

type RestSource struct {
	AdditionalColumns  *interface{} `json:"additionalColumns,omitempty"`
	AdditionalHeaders  *interface{} `json:"additionalHeaders,omitempty"`
	HTTPRequestTimeout *interface{} `json:"httpRequestTimeout,omitempty"`
	PaginationRules    *interface{} `json:"paginationRules,omitempty"`
	RequestBody        *interface{} `json:"requestBody,omitempty"`
	RequestInterval    *interface{} `json:"requestInterval,omitempty"`
	RequestMethod      *interface{} `json:"requestMethod,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (RestSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type SSISAccessCredential ¶ added in v0.20240320.1143605

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

func (*SSISAccessCredential) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type SSISChildPackage ¶ added in v0.20240320.1143605

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

type SSISExecutionCredential ¶ added in v0.20240320.1143605

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

type SSISExecutionParameter ¶ added in v0.20240320.1143605

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

type SSISLogLocation ¶ added in v0.20240320.1143605

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

type SSISLogLocationTypeProperties ¶ added in v0.20240320.1143605

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

type SSISPackageLocation ¶ added in v0.20240320.1143605

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

type SSISPackageLocationTypeProperties ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type SSISPropertyOverride ¶ added in v0.20240320.1143605

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

type SalesforceMarketingCloudSource ¶ added in v0.20240320.1143605

type SalesforceMarketingCloudSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (SalesforceMarketingCloudSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type SalesforceServiceCloudSink ¶ added in v0.20240320.1143605

type SalesforceServiceCloudSink struct {
	ExternalIdFieldName *interface{}                 `json:"externalIdFieldName,omitempty"`
	IgnoreNullValues    *interface{}                 `json:"ignoreNullValues,omitempty"`
	WriteBehavior       *SalesforceSinkWriteBehavior `json:"writeBehavior,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (SalesforceServiceCloudSink) MarshalJSON ¶ added in v0.20240327.1081628

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

type SalesforceServiceCloudSource ¶ added in v0.20240320.1143605

type SalesforceServiceCloudSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	ReadBehavior      *interface{} `json:"readBehavior,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (SalesforceServiceCloudSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type SalesforceServiceCloudV2Sink ¶ added in v0.20240320.1143605

type SalesforceServiceCloudV2Sink struct {
	ExternalIdFieldName *interface{}                   `json:"externalIdFieldName,omitempty"`
	IgnoreNullValues    *interface{}                   `json:"ignoreNullValues,omitempty"`
	WriteBehavior       *SalesforceV2SinkWriteBehavior `json:"writeBehavior,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (SalesforceServiceCloudV2Sink) MarshalJSON ¶ added in v0.20240327.1081628

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

type SalesforceServiceCloudV2Source ¶ added in v0.20240320.1143605

type SalesforceServiceCloudV2Source struct {
	AdditionalColumns     *interface{} `json:"additionalColumns,omitempty"`
	IncludeDeletedObjects *interface{} `json:"includeDeletedObjects,omitempty"`
	Query                 *interface{} `json:"query,omitempty"`
	SOQLQuery             *interface{} `json:"SOQLQuery,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (SalesforceServiceCloudV2Source) MarshalJSON ¶ added in v0.20240327.1081628

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

type SalesforceSink ¶ added in v0.20240320.1143605

type SalesforceSink struct {
	ExternalIdFieldName *interface{}                 `json:"externalIdFieldName,omitempty"`
	IgnoreNullValues    *interface{}                 `json:"ignoreNullValues,omitempty"`
	WriteBehavior       *SalesforceSinkWriteBehavior `json:"writeBehavior,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (SalesforceSink) MarshalJSON ¶ added in v0.20240327.1081628

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

type SalesforceSinkWriteBehavior ¶ added in v0.20240320.1143605

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

func (*SalesforceSinkWriteBehavior) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type SalesforceSource ¶ added in v0.20240320.1143605

type SalesforceSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`
	ReadBehavior      *interface{} `json:"readBehavior,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (SalesforceSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type SalesforceV2Sink ¶ added in v0.20240320.1143605

type SalesforceV2Sink struct {
	ExternalIdFieldName *interface{}                   `json:"externalIdFieldName,omitempty"`
	IgnoreNullValues    *interface{}                   `json:"ignoreNullValues,omitempty"`
	WriteBehavior       *SalesforceV2SinkWriteBehavior `json:"writeBehavior,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (SalesforceV2Sink) MarshalJSON ¶ added in v0.20240327.1081628

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

type SalesforceV2SinkWriteBehavior ¶ added in v0.20240320.1143605

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

func (*SalesforceV2SinkWriteBehavior) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type SalesforceV2Source ¶ added in v0.20240320.1143605

type SalesforceV2Source struct {
	AdditionalColumns     *interface{} `json:"additionalColumns,omitempty"`
	IncludeDeletedObjects *interface{} `json:"includeDeletedObjects,omitempty"`
	Query                 *interface{} `json:"query,omitempty"`
	QueryTimeout          *interface{} `json:"queryTimeout,omitempty"`
	SOQLQuery             *interface{} `json:"SOQLQuery,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (SalesforceV2Source) MarshalJSON ¶ added in v0.20240327.1081628

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

type SapBwSource ¶ added in v0.20240320.1143605

type SapBwSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (SapBwSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type SapCloudForCustomerSink ¶ added in v0.20240320.1143605

type SapCloudForCustomerSink struct {
	HTTPRequestTimeout *interface{}                          `json:"httpRequestTimeout,omitempty"`
	WriteBehavior      *SapCloudForCustomerSinkWriteBehavior `json:"writeBehavior,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (SapCloudForCustomerSink) MarshalJSON ¶ added in v0.20240327.1081628

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

type SapCloudForCustomerSinkWriteBehavior ¶ added in v0.20240320.1143605

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

func (*SapCloudForCustomerSinkWriteBehavior) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type SapCloudForCustomerSource ¶ added in v0.20240320.1143605

type SapCloudForCustomerSource struct {
	AdditionalColumns  *interface{} `json:"additionalColumns,omitempty"`
	HTTPRequestTimeout *interface{} `json:"httpRequestTimeout,omitempty"`
	Query              *interface{} `json:"query,omitempty"`
	QueryTimeout       *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (SapCloudForCustomerSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type SapEccSource ¶ added in v0.20240320.1143605

type SapEccSource struct {
	AdditionalColumns  *interface{} `json:"additionalColumns,omitempty"`
	HTTPRequestTimeout *interface{} `json:"httpRequestTimeout,omitempty"`
	Query              *interface{} `json:"query,omitempty"`
	QueryTimeout       *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (SapEccSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type SapHanaPartitionSettings ¶ added in v0.20240320.1143605

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

type SapHanaSource ¶ added in v0.20240320.1143605

type SapHanaSource struct {
	AdditionalColumns *interface{}              `json:"additionalColumns,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"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (SapHanaSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type SapOdpSource ¶ added in v0.20240320.1143605

type SapOdpSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	ExtractionMode    *interface{} `json:"extractionMode,omitempty"`
	Projection        *interface{} `json:"projection,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`
	Selection         *interface{} `json:"selection,omitempty"`
	SubscriberProcess *interface{} `json:"subscriberProcess,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (SapOdpSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type SapOpenHubSource ¶ added in v0.20240320.1143605

type SapOpenHubSource struct {
	AdditionalColumns                *interface{} `json:"additionalColumns,omitempty"`
	BaseRequestId                    *interface{} `json:"baseRequestId,omitempty"`
	CustomRfcReadTableFunctionModule *interface{} `json:"customRfcReadTableFunctionModule,omitempty"`
	ExcludeLastRequest               *interface{} `json:"excludeLastRequest,omitempty"`
	QueryTimeout                     *interface{} `json:"queryTimeout,omitempty"`
	SapDataColumnDelimiter           *interface{} `json:"sapDataColumnDelimiter,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (SapOpenHubSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type SapTablePartitionSettings ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

type SapTableSource struct {
	AdditionalColumns                *interface{}               `json:"additionalColumns,omitempty"`
	BatchSize                        *interface{}               `json:"batchSize,omitempty"`
	CustomRfcReadTableFunctionModule *interface{}               `json:"customRfcReadTableFunctionModule,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"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (SapTableSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type ScriptActivity ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type ScriptActivityLogDestination ¶ added in v0.20240320.1143605

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

func (*ScriptActivityLogDestination) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type ScriptActivityParameter ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

func (*ScriptActivityParameterDirection) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type ScriptActivityParameterType ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type ScriptActivityScriptBlock ¶ added in v0.20240320.1143605

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

type ScriptActivityTypeProperties ¶ added in v0.20240320.1143605

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

type ScriptActivityTypePropertiesLogSettings ¶ added in v0.20240320.1143605

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

type SecretBase ¶ added in v0.20240320.1143605

type SecretBase interface {
}

type SecureInputOutputPolicy ¶ added in v0.20240320.1143605

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

type SecureString ¶ added in v0.20240320.1143605

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

func (SecureString) MarshalJSON ¶ added in v0.20240320.1143605

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

type ServiceNowSource ¶ added in v0.20240320.1143605

type ServiceNowSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (ServiceNowSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type ServiceNowV2Source ¶ added in v0.20240320.1143605

type ServiceNowV2Source struct {
	AdditionalColumns *interface{}  `json:"additionalColumns,omitempty"`
	Expression        *ExpressionV2 `json:"expression,omitempty"`
	QueryTimeout      *interface{}  `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (ServiceNowV2Source) MarshalJSON ¶ added in v0.20240327.1081628

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

type SetVariableActivity ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type SetVariableActivityTypeProperties ¶ added in v0.20240320.1143605

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

type SftpReadSettings ¶ added in v0.20240320.1143605

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

	// Fields inherited from StoreReadSettings
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
}

func (SftpReadSettings) MarshalJSON ¶ added in v0.20240327.1081628

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

type SftpWriteSettings ¶ added in v0.20240320.1143605

type SftpWriteSettings struct {
	OperationTimeout  *interface{} `json:"operationTimeout,omitempty"`
	UseTempFileRename *interface{} `json:"useTempFileRename,omitempty"`

	// Fields inherited from StoreWriteSettings
	CopyBehavior             *interface{}    `json:"copyBehavior,omitempty"`
	DisableMetricsCollection *interface{}    `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{}    `json:"maxConcurrentConnections,omitempty"`
	Metadata                 *[]MetadataItem `json:"metadata,omitempty"`
}

func (SftpWriteSettings) MarshalJSON ¶ added in v0.20240327.1081628

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

type SharePointOnlineListSource ¶ added in v0.20240320.1143605

type SharePointOnlineListSource struct {
	HTTPRequestTimeout *interface{} `json:"httpRequestTimeout,omitempty"`
	Query              *interface{} `json:"query,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (SharePointOnlineListSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type ShopifySource ¶ added in v0.20240320.1143605

type ShopifySource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (ShopifySource) MarshalJSON ¶ added in v0.20240327.1081628

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

type SkipErrorFile ¶ added in v0.20240320.1143605

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

type SnowflakeExportCopyCommand ¶ added in v0.20240320.1143605

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

func (SnowflakeExportCopyCommand) MarshalJSON ¶ added in v0.20240327.1081628

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

type SnowflakeImportCopyCommand ¶ added in v0.20240320.1143605

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

func (SnowflakeImportCopyCommand) MarshalJSON ¶ added in v0.20240327.1081628

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

type SnowflakeSink ¶ added in v0.20240320.1143605

type SnowflakeSink struct {
	ImportSettings *SnowflakeImportCopyCommand `json:"importSettings,omitempty"`
	PreCopyScript  *interface{}                `json:"preCopyScript,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (SnowflakeSink) MarshalJSON ¶ added in v0.20240327.1081628

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

type SnowflakeSource ¶ added in v0.20240320.1143605

type SnowflakeSource struct {
	ExportSettings SnowflakeExportCopyCommand `json:"exportSettings"`
	Query          *interface{}               `json:"query,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (SnowflakeSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type SnowflakeV2Sink ¶ added in v0.20240320.1143605

type SnowflakeV2Sink struct {
	ImportSettings *SnowflakeImportCopyCommand `json:"importSettings,omitempty"`
	PreCopyScript  *interface{}                `json:"preCopyScript,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (SnowflakeV2Sink) MarshalJSON ¶ added in v0.20240327.1081628

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

type SnowflakeV2Source ¶ added in v0.20240320.1143605

type SnowflakeV2Source struct {
	ExportSettings SnowflakeExportCopyCommand `json:"exportSettings"`
	Query          *interface{}               `json:"query,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (SnowflakeV2Source) MarshalJSON ¶ added in v0.20240327.1081628

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

type SparkConfigurationParametrizationReference ¶ added in v0.20240320.1143605

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

type SparkConfigurationReferenceType ¶ added in v0.20240320.1143605

type SparkConfigurationReferenceType string
const (
	SparkConfigurationReferenceTypeSparkConfigurationReference SparkConfigurationReferenceType = "SparkConfigurationReference"
)

func (*SparkConfigurationReferenceType) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type SparkJobReferenceType ¶ added in v0.20240320.1143605

type SparkJobReferenceType string
const (
	SparkJobReferenceTypeSparkJobDefinitionReference SparkJobReferenceType = "SparkJobDefinitionReference"
)

func (*SparkJobReferenceType) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type SparkSource ¶ added in v0.20240320.1143605

type SparkSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (SparkSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type SqlDWSink ¶ added in v0.20240320.1143605

type SqlDWSink struct {
	AllowCopyCommand      *interface{}           `json:"allowCopyCommand,omitempty"`
	AllowPolyBase         *interface{}           `json:"allowPolyBase,omitempty"`
	CopyCommandSettings   *DWCopyCommandSettings `json:"copyCommandSettings,omitempty"`
	PolyBaseSettings      *PolybaseSettings      `json:"polyBaseSettings,omitempty"`
	PreCopyScript         *interface{}           `json:"preCopyScript,omitempty"`
	SqlWriterUseTableLock *interface{}           `json:"sqlWriterUseTableLock,omitempty"`
	TableOption           *interface{}           `json:"tableOption,omitempty"`
	UpsertSettings        *SqlDWUpsertSettings   `json:"upsertSettings,omitempty"`
	WriteBehavior         *interface{}           `json:"writeBehavior,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (SqlDWSink) MarshalJSON ¶ added in v0.20240327.1081628

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

type SqlDWSource ¶ added in v0.20240320.1143605

type SqlDWSource struct {
	AdditionalColumns            *interface{}          `json:"additionalColumns,omitempty"`
	IsolationLevel               *interface{}          `json:"isolationLevel,omitempty"`
	PartitionOption              *interface{}          `json:"partitionOption,omitempty"`
	PartitionSettings            *SqlPartitionSettings `json:"partitionSettings,omitempty"`
	QueryTimeout                 *interface{}          `json:"queryTimeout,omitempty"`
	SqlReaderQuery               *interface{}          `json:"sqlReaderQuery,omitempty"`
	SqlReaderStoredProcedureName *interface{}          `json:"sqlReaderStoredProcedureName,omitempty"`
	StoredProcedureParameters    *interface{}          `json:"storedProcedureParameters,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (SqlDWSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type SqlDWUpsertSettings ¶ added in v0.20240320.1143605

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

type SqlMISink ¶ added in v0.20240320.1143605

type SqlMISink struct {
	PreCopyScript                         *interface{}       `json:"preCopyScript,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"`
	UpsertSettings                        *SqlUpsertSettings `json:"upsertSettings,omitempty"`
	WriteBehavior                         *interface{}       `json:"writeBehavior,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (SqlMISink) MarshalJSON ¶ added in v0.20240327.1081628

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

type SqlMISource ¶ added in v0.20240320.1143605

type SqlMISource struct {
	AdditionalColumns            *interface{}          `json:"additionalColumns,omitempty"`
	IsolationLevel               *interface{}          `json:"isolationLevel,omitempty"`
	PartitionOption              *interface{}          `json:"partitionOption,omitempty"`
	PartitionSettings            *SqlPartitionSettings `json:"partitionSettings,omitempty"`
	ProduceAdditionalTypes       *interface{}          `json:"produceAdditionalTypes,omitempty"`
	QueryTimeout                 *interface{}          `json:"queryTimeout,omitempty"`
	SqlReaderQuery               *interface{}          `json:"sqlReaderQuery,omitempty"`
	SqlReaderStoredProcedureName *interface{}          `json:"sqlReaderStoredProcedureName,omitempty"`
	StoredProcedureParameters    *interface{}          `json:"storedProcedureParameters,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (SqlMISource) MarshalJSON ¶ added in v0.20240327.1081628

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

type SqlPartitionSettings ¶ added in v0.20240320.1143605

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

type SqlServerSink ¶ added in v0.20240320.1143605

type SqlServerSink struct {
	PreCopyScript                         *interface{}       `json:"preCopyScript,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"`
	UpsertSettings                        *SqlUpsertSettings `json:"upsertSettings,omitempty"`
	WriteBehavior                         *interface{}       `json:"writeBehavior,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (SqlServerSink) MarshalJSON ¶ added in v0.20240327.1081628

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

type SqlServerSource ¶ added in v0.20240320.1143605

type SqlServerSource struct {
	AdditionalColumns            *interface{}          `json:"additionalColumns,omitempty"`
	IsolationLevel               *interface{}          `json:"isolationLevel,omitempty"`
	PartitionOption              *interface{}          `json:"partitionOption,omitempty"`
	PartitionSettings            *SqlPartitionSettings `json:"partitionSettings,omitempty"`
	ProduceAdditionalTypes       *interface{}          `json:"produceAdditionalTypes,omitempty"`
	QueryTimeout                 *interface{}          `json:"queryTimeout,omitempty"`
	SqlReaderQuery               *interface{}          `json:"sqlReaderQuery,omitempty"`
	SqlReaderStoredProcedureName *interface{}          `json:"sqlReaderStoredProcedureName,omitempty"`
	StoredProcedureParameters    *interface{}          `json:"storedProcedureParameters,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (SqlServerSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type SqlServerStoredProcedureActivity ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type SqlServerStoredProcedureActivityTypeProperties ¶ added in v0.20240320.1143605

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

type SqlSink ¶ added in v0.20240320.1143605

type SqlSink struct {
	PreCopyScript                         *interface{}       `json:"preCopyScript,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"`
	UpsertSettings                        *SqlUpsertSettings `json:"upsertSettings,omitempty"`
	WriteBehavior                         *interface{}       `json:"writeBehavior,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (SqlSink) MarshalJSON ¶ added in v0.20240327.1081628

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

type SqlSource ¶ added in v0.20240320.1143605

type SqlSource struct {
	AdditionalColumns            *interface{}          `json:"additionalColumns,omitempty"`
	IsolationLevel               *interface{}          `json:"isolationLevel,omitempty"`
	PartitionOption              *interface{}          `json:"partitionOption,omitempty"`
	PartitionSettings            *SqlPartitionSettings `json:"partitionSettings,omitempty"`
	QueryTimeout                 *interface{}          `json:"queryTimeout,omitempty"`
	SqlReaderQuery               *interface{}          `json:"sqlReaderQuery,omitempty"`
	SqlReaderStoredProcedureName *interface{}          `json:"sqlReaderStoredProcedureName,omitempty"`
	StoredProcedureParameters    *interface{}          `json:"storedProcedureParameters,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (SqlSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type SqlUpsertSettings ¶ added in v0.20240320.1143605

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

type SquareSource ¶ added in v0.20240320.1143605

type SquareSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (SquareSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type SsisLogLocationType ¶ added in v0.20240320.1143605

type SsisLogLocationType string
const (
	SsisLogLocationTypeFile SsisLogLocationType = "File"
)

func (*SsisLogLocationType) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type SsisPackageLocationType ¶ added in v0.20240320.1143605

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

func (*SsisPackageLocationType) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type StagingSettings ¶ added in v0.20240320.1143605

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

type StoreReadSettings ¶ added in v0.20240320.1143605

type StoreReadSettings interface {
}

type StoreWriteSettings ¶ added in v0.20240320.1143605

type StoreWriteSettings interface {
}

type SwitchActivity ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type SwitchActivityTypeProperties ¶ added in v0.20240320.1143605

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

func (*SwitchActivityTypeProperties) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type SwitchCase ¶ added in v0.20240320.1143605

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

func (*SwitchCase) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type SybaseSource ¶ added in v0.20240320.1143605

type SybaseSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (SybaseSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type SynapseNotebookActivity ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type SynapseNotebookActivityTypeProperties ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type SynapseSparkJobActivityTypeProperties ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type SynapseSparkJobReference ¶ added in v0.20240320.1143605

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

type TabularSource ¶ added in v0.20240320.1143605

type TabularSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (TabularSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type TabularTranslator ¶ added in v0.20240327.1081628

type TabularTranslator struct {
	CollectionReference      *interface{}            `json:"collectionReference,omitempty"`
	ColumnMappings           *interface{}            `json:"columnMappings,omitempty"`
	MapComplexValuesToString *interface{}            `json:"mapComplexValuesToString,omitempty"`
	Mappings                 *interface{}            `json:"mappings,omitempty"`
	SchemaMapping            *interface{}            `json:"schemaMapping,omitempty"`
	TypeConversion           *interface{}            `json:"typeConversion,omitempty"`
	TypeConversionSettings   *TypeConversionSettings `json:"typeConversionSettings,omitempty"`
}

func (TabularTranslator) MarshalJSON ¶ added in v0.20240327.1081628

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

type TarGZipReadSettings ¶ added in v0.20240320.1143605

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

func (TarGZipReadSettings) MarshalJSON ¶ added in v0.20240327.1081628

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

type TarReadSettings ¶ added in v0.20240320.1143605

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

func (TarReadSettings) MarshalJSON ¶ added in v0.20240327.1081628

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

type TeradataPartitionSettings ¶ added in v0.20240320.1143605

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

type TeradataSource ¶ added in v0.20240320.1143605

type TeradataSource struct {
	AdditionalColumns *interface{}               `json:"additionalColumns,omitempty"`
	PartitionOption   *interface{}               `json:"partitionOption,omitempty"`
	PartitionSettings *TeradataPartitionSettings `json:"partitionSettings,omitempty"`
	Query             *interface{}               `json:"query,omitempty"`
	QueryTimeout      *interface{}               `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (TeradataSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type Type ¶ added in v0.20240320.1143605

type Type string
const (
	TypeLinkedServiceReference Type = "LinkedServiceReference"
)

func (*Type) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type TypeConversionSettings ¶ added in v0.20240327.1081628

type TypeConversionSettings struct {
	AllowDataTruncation  *interface{} `json:"allowDataTruncation,omitempty"`
	Culture              *interface{} `json:"culture,omitempty"`
	DateTimeFormat       *interface{} `json:"dateTimeFormat,omitempty"`
	DateTimeOffsetFormat *interface{} `json:"dateTimeOffsetFormat,omitempty"`
	TimeSpanFormat       *interface{} `json:"timeSpanFormat,omitempty"`
	TreatBooleanAsNumber *interface{} `json:"treatBooleanAsNumber,omitempty"`
}

type UntilActivity ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type UntilActivityTypeProperties ¶ added in v0.20240320.1143605

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

func (*UntilActivityTypeProperties) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type UserProperty ¶

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

type ValidationActivity ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type ValidationActivityTypeProperties ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

type VerticaSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (VerticaSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type WaitActivity ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type WaitActivityTypeProperties ¶ added in v0.20240320.1143605

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

type WarehouseSink ¶ added in v0.20240320.1143605

type WarehouseSink struct {
	AllowCopyCommand    *interface{}           `json:"allowCopyCommand,omitempty"`
	CopyCommandSettings *DWCopyCommandSettings `json:"copyCommandSettings,omitempty"`
	PreCopyScript       *interface{}           `json:"preCopyScript,omitempty"`
	TableOption         *interface{}           `json:"tableOption,omitempty"`
	WriteBehavior       *interface{}           `json:"writeBehavior,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *interface{} `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *interface{} `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *interface{} `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *interface{} `json:"writeBatchTimeout,omitempty"`
}

func (WarehouseSink) MarshalJSON ¶ added in v0.20240327.1081628

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

type WarehouseSource ¶ added in v0.20240320.1143605

type WarehouseSource struct {
	AdditionalColumns            *interface{}          `json:"additionalColumns,omitempty"`
	IsolationLevel               *interface{}          `json:"isolationLevel,omitempty"`
	PartitionOption              *interface{}          `json:"partitionOption,omitempty"`
	PartitionSettings            *SqlPartitionSettings `json:"partitionSettings,omitempty"`
	QueryTimeout                 *interface{}          `json:"queryTimeout,omitempty"`
	SqlReaderQuery               *interface{}          `json:"sqlReaderQuery,omitempty"`
	SqlReaderStoredProcedureName *interface{}          `json:"sqlReaderStoredProcedureName,omitempty"`
	StoredProcedureParameters    *interface{}          `json:"storedProcedureParameters,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (WarehouseSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type WebActivity ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type WebActivityAuthentication ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type WebActivityMethod ¶ added in v0.20240320.1143605

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

func (*WebActivityMethod) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type WebActivityTypeProperties ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

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

type WebHookActivityMethod ¶ added in v0.20240320.1143605

type WebHookActivityMethod string
const (
	WebHookActivityMethodPOST WebHookActivityMethod = "POST"
)

func (*WebHookActivityMethod) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type WebHookActivityTypeProperties ¶ added in v0.20240320.1143605

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 ¶ added in v0.20240320.1143605

type WebSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (WebSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type XeroSource ¶ added in v0.20240320.1143605

type XeroSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (XeroSource) MarshalJSON ¶ added in v0.20240327.1081628

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

type XmlReadSettings ¶ added in v0.20240320.1143605

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

func (XmlReadSettings) MarshalJSON ¶ added in v0.20240327.1081628

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

func (*XmlReadSettings) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type XmlSource ¶ added in v0.20240320.1143605

type XmlSource struct {
	AdditionalColumns *interface{}      `json:"additionalColumns,omitempty"`
	FormatSettings    *XmlReadSettings  `json:"formatSettings,omitempty"`
	StoreSettings     StoreReadSettings `json:"storeSettings"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (XmlSource) MarshalJSON ¶ added in v0.20240327.1081628

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

func (*XmlSource) UnmarshalJSON ¶ added in v0.20240320.1143605

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

type ZipDeflateReadSettings ¶ added in v0.20240320.1143605

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

func (ZipDeflateReadSettings) MarshalJSON ¶ added in v0.20240327.1081628

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

type ZohoSource ¶ added in v0.20240320.1143605

type ZohoSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	Query             *interface{} `json:"query,omitempty"`
	QueryTimeout      *interface{} `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *interface{} `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *interface{} `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *interface{} `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *interface{} `json:"sourceRetryWait,omitempty"`
}

func (ZohoSource) MarshalJSON ¶ added in v0.20240327.1081628

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

Source Files ¶

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL