pipelines

package
v0.20240708.1080555 Latest Latest
Warning

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

 Go to latest Published: Jul 8, 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                  *int64  `json:"retry,omitempty"`
	RetryIntervalInSeconds *int64  `json:"retryIntervalInSeconds,omitempty"`
	SecureInput            *bool   `json:"secureInput,omitempty"`
	SecureOutput           *bool   `json:"secureOutput,omitempty"`
	Timeout                *string `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *string      `json:"partitionColumnName,omitempty"`
	PartitionLowerBound *string      `json:"partitionLowerBound,omitempty"`
	PartitionNames      *interface{} `json:"partitionNames,omitempty"`
	PartitionUpperBound *string      `json:"partitionUpperBound,omitempty"`
}

type AmazonRdsForOracleSource ¶ added in v0.20240320.1143605 

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

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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               *string               `json:"isolationLevel,omitempty"`
	PartitionOption              *interface{}          `json:"partitionOption,omitempty"`
	PartitionSettings            *SqlPartitionSettings `json:"partitionSettings,omitempty"`
	ProduceAdditionalTypes       *interface{}          `json:"produceAdditionalTypes,omitempty"`
	QueryTimeout                 *string               `json:"queryTimeout,omitempty"`
	SqlReaderQuery               *string               `json:"sqlReaderQuery,omitempty"`
	SqlReaderStoredProcedureName *string               `json:"sqlReaderStoredProcedureName,omitempty"`
	StoredProcedureParameters    *interface{}          `json:"storedProcedureParameters,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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                  *string                 `json:"query,omitempty"`
	QueryTimeout           *string                 `json:"queryTimeout,omitempty"`
	RedshiftUnloadSettings *RedshiftUnloadSettings `json:"redshiftUnloadSettings,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *bool   `json:"deleteFilesAfterCompletion,omitempty"`
	EnablePartitionDiscovery   *bool   `json:"enablePartitionDiscovery,omitempty"`
	FileListPath               *string `json:"fileListPath,omitempty"`
	ModifiedDatetimeEnd        *string `json:"modifiedDatetimeEnd,omitempty"`
	ModifiedDatetimeStart      *string `json:"modifiedDatetimeStart,omitempty"`
	PartitionRootPath          *string `json:"partitionRootPath,omitempty"`
	Prefix                     *string `json:"prefix,omitempty"`
	Recursive                  *bool   `json:"recursive,omitempty"`
	WildcardFileName           *string `json:"wildcardFileName,omitempty"`
	WildcardFolderPath         *string `json:"wildcardFolderPath,omitempty"`

	// Fields inherited from StoreReadSettings
	DisableMetricsCollection *bool  `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64 `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 *bool   `json:"deleteFilesAfterCompletion,omitempty"`
	EnablePartitionDiscovery   *bool   `json:"enablePartitionDiscovery,omitempty"`
	FileListPath               *string `json:"fileListPath,omitempty"`
	ModifiedDatetimeEnd        *string `json:"modifiedDatetimeEnd,omitempty"`
	ModifiedDatetimeStart      *string `json:"modifiedDatetimeStart,omitempty"`
	PartitionRootPath          *string `json:"partitionRootPath,omitempty"`
	Prefix                     *string `json:"prefix,omitempty"`
	Recursive                  *bool   `json:"recursive,omitempty"`
	WildcardFileName           *string `json:"wildcardFileName,omitempty"`
	WildcardFolderPath         *string `json:"wildcardFolderPath,omitempty"`

	// Fields inherited from StoreReadSettings
	DisableMetricsCollection *bool  `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64 `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 *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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 *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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  *string `json:"fileNamePrefix,omitempty"`
	MaxRowsPerFile  *int64  `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 *bool   `json:"deleteFilesAfterCompletion,omitempty"`
	EnablePartitionDiscovery   *bool   `json:"enablePartitionDiscovery,omitempty"`
	FileListPath               *string `json:"fileListPath,omitempty"`
	ModifiedDatetimeEnd        *string `json:"modifiedDatetimeEnd,omitempty"`
	ModifiedDatetimeStart      *string `json:"modifiedDatetimeStart,omitempty"`
	PartitionRootPath          *string `json:"partitionRootPath,omitempty"`
	Recursive                  *bool   `json:"recursive,omitempty"`
	WildcardFileName           *string `json:"wildcardFileName,omitempty"`
	WildcardFolderPath         *string `json:"wildcardFolderPath,omitempty"`

	// Fields inherited from StoreReadSettings
	DisableMetricsCollection *bool  `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64 `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 *string         `json:"copyBehavior,omitempty"`
	Metadata     *[]MetadataItem `json:"metadata,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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           *bool  `json:"recursive,omitempty"`
	SkipHeaderLineCount *int64 `json:"skipHeaderLineCount,omitempty"`
	TreatEmptyAsNull    *bool  `json:"treatEmptyAsNull,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *int64 `json:"blockSizeInMB,omitempty"`

	// Fields inherited from StoreWriteSettings
	CopyBehavior             *string         `json:"copyBehavior,omitempty"`
	DisableMetricsCollection *bool           `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64          `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 *bool   `json:"deleteFilesAfterCompletion,omitempty"`
	EnablePartitionDiscovery   *bool   `json:"enablePartitionDiscovery,omitempty"`
	FileListPath               *string `json:"fileListPath,omitempty"`
	ModifiedDatetimeEnd        *string `json:"modifiedDatetimeEnd,omitempty"`
	ModifiedDatetimeStart      *string `json:"modifiedDatetimeStart,omitempty"`
	PartitionRootPath          *string `json:"partitionRootPath,omitempty"`
	Prefix                     *string `json:"prefix,omitempty"`
	Recursive                  *bool   `json:"recursive,omitempty"`
	WildcardFileName           *string `json:"wildcardFileName,omitempty"`
	WildcardFolderPath         *string `json:"wildcardFolderPath,omitempty"`

	// Fields inherited from StoreReadSettings
	DisableMetricsCollection *bool  `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64 `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 *int64 `json:"blockSizeInMB,omitempty"`

	// Fields inherited from StoreWriteSettings
	CopyBehavior             *string         `json:"copyBehavior,omitempty"`
	DisableMetricsCollection *bool           `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64          `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        string  `json:"command"`
	CommandTimeout *string `json:"commandTimeout,omitempty"`
}

type AzureDataExplorerSink ¶ added in v0.20240320.1143605 

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

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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             string       `json:"query"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *bool   `json:"deleteFilesAfterCompletion,omitempty"`
	EnablePartitionDiscovery   *bool   `json:"enablePartitionDiscovery,omitempty"`
	FileListPath               *string `json:"fileListPath,omitempty"`
	ListAfter                  *string `json:"listAfter,omitempty"`
	ListBefore                 *string `json:"listBefore,omitempty"`
	ModifiedDatetimeEnd        *string `json:"modifiedDatetimeEnd,omitempty"`
	ModifiedDatetimeStart      *string `json:"modifiedDatetimeStart,omitempty"`
	PartitionRootPath          *string `json:"partitionRootPath,omitempty"`
	Recursive                  *bool   `json:"recursive,omitempty"`
	WildcardFileName           *string `json:"wildcardFileName,omitempty"`
	WildcardFolderPath         *string `json:"wildcardFolderPath,omitempty"`

	// Fields inherited from StoreReadSettings
	DisableMetricsCollection *bool  `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64 `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                 *string `json:"copyBehavior,omitempty"`
	EnableAdlsSingleFileParallel *bool   `json:"enableAdlsSingleFileParallel,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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 *bool `json:"recursive,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *string `json:"expiryDateTime,omitempty"`

	// Fields inherited from StoreWriteSettings
	CopyBehavior             *string         `json:"copyBehavior,omitempty"`
	DisableMetricsCollection *bool           `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64          `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      *string `json:"dateFormat,omitempty"`
	TimestampFormat *string `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      *string `json:"dateFormat,omitempty"`
	TimestampFormat *string `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  *string                                `json:"preCopyScript,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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          *string                                `json:"query,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *bool   `json:"deleteFilesAfterCompletion,omitempty"`
	EnablePartitionDiscovery   *bool   `json:"enablePartitionDiscovery,omitempty"`
	FileListPath               *string `json:"fileListPath,omitempty"`
	ModifiedDatetimeEnd        *string `json:"modifiedDatetimeEnd,omitempty"`
	ModifiedDatetimeStart      *string `json:"modifiedDatetimeStart,omitempty"`
	PartitionRootPath          *string `json:"partitionRootPath,omitempty"`
	Prefix                     *string `json:"prefix,omitempty"`
	Recursive                  *bool   `json:"recursive,omitempty"`
	WildcardFileName           *string `json:"wildcardFileName,omitempty"`
	WildcardFolderPath         *string `json:"wildcardFolderPath,omitempty"`

	// Fields inherited from StoreReadSettings
	DisableMetricsCollection *bool  `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64 `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             *string         `json:"copyBehavior,omitempty"`
	DisableMetricsCollection *bool           `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64          `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         *string                     `json:"body,omitempty"`
	FunctionName string                      `json:"functionName"`
	Headers      *map[string]string          `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]string                `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 *bool              `json:"continueOnStepFailure,omitempty"`
	DataPathAssignments   *interface{}       `json:"dataPathAssignments,omitempty"`
	ExperimentName        *string            `json:"experimentName,omitempty"`
	MlParentRunId         *string            `json:"mlParentRunId,omitempty"`
	MlPipelineEndpointId  *string            `json:"mlPipelineEndpointId,omitempty"`
	MlPipelineId          *string            `json:"mlPipelineId,omitempty"`
	MlPipelineParameters  *map[string]string `json:"mlPipelineParameters,omitempty"`
	Version               *string            `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          string                 `json:"trainedModelFilePath"`
	TrainedModelLinkedServiceName LinkedServiceReference `json:"trainedModelLinkedServiceName"`
	TrainedModelName              string                 `json:"trainedModelName"`
}

type AzureMLWebServiceFile ¶ added in v0.20240320.1143605 

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

type AzureMariaDBSource ¶ added in v0.20240320.1143605 

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

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *string `json:"preCopyScript,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *string `json:"preCopyScript,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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 *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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                         *string            `json:"preCopyScript,omitempty"`
	SqlWriterStoredProcedureName          *string            `json:"sqlWriterStoredProcedureName,omitempty"`
	SqlWriterTableType                    *string            `json:"sqlWriterTableType,omitempty"`
	SqlWriterUseTableLock                 *bool              `json:"sqlWriterUseTableLock,omitempty"`
	StoredProcedureParameters             *interface{}       `json:"storedProcedureParameters,omitempty"`
	StoredProcedureTableTypeParameterName *string            `json:"storedProcedureTableTypeParameterName,omitempty"`
	TableOption                           *string            `json:"tableOption,omitempty"`
	UpsertSettings                        *SqlUpsertSettings `json:"upsertSettings,omitempty"`
	WriteBehavior                         *interface{}       `json:"writeBehavior,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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               *string               `json:"isolationLevel,omitempty"`
	PartitionOption              *string               `json:"partitionOption,omitempty"`
	PartitionSettings            *SqlPartitionSettings `json:"partitionSettings,omitempty"`
	ProduceAdditionalTypes       *interface{}          `json:"produceAdditionalTypes,omitempty"`
	QueryTimeout                 *string               `json:"queryTimeout,omitempty"`
	SqlReaderQuery               *string               `json:"sqlReaderQuery,omitempty"`
	SqlReaderStoredProcedureName *string               `json:"sqlReaderStoredProcedureName,omitempty"`
	StoredProcedureParameters    *interface{}          `json:"storedProcedureParameters,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *string `json:"azureTableDefaultPartitionKeyValue,omitempty"`
	AzureTableInsertType               *string `json:"azureTableInsertType,omitempty"`
	AzureTablePartitionKeyName         *string `json:"azureTablePartitionKeyName,omitempty"`
	AzureTableRowKeyName               *string `json:"azureTableRowKeyName,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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 *bool        `json:"azureTableSourceIgnoreTableNotFound,omitempty"`
	AzureTableSourceQuery               *string      `json:"azureTableSourceQuery,omitempty"`
	QueryTimeout                        *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 string                   `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 *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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 *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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      *bool           `json:"blobWriterAddHeader,omitempty"`
	BlobWriterDateTimeFormat *string         `json:"blobWriterDateTimeFormat,omitempty"`
	BlobWriterOverwriteFiles *bool           `json:"blobWriterOverwriteFiles,omitempty"`
	CopyBehavior             *interface{}    `json:"copyBehavior,omitempty"`
	Metadata                 *[]MetadataItem `json:"metadata,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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           *bool  `json:"recursive,omitempty"`
	SkipHeaderLineCount *int64 `json:"skipHeaderLineCount,omitempty"`
	TreatEmptyAsNull    *bool  `json:"treatEmptyAsNull,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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             *string                               `json:"query,omitempty"`
	QueryTimeout      *string                               `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *string                   `json:"alternateKeyName,omitempty"`
	IgnoreNullValues *bool                     `json:"ignoreNullValues,omitempty"`
	WriteBehavior    DynamicsSinkWriteBehavior `json:"writeBehavior"`

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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             *string      `json:"query,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 ContinuationSettingsReference ¶ added in v0.20240611.1112045 

type ContinuationSettingsReference struct {
	ContinuationTtlInMinutes *int64  `json:"continuationTtlInMinutes,omitempty"`
	CustomizedCheckpointKey  *string `json:"customizedCheckpointKey,omitempty"`
	IdleCondition            *string `json:"idleCondition,omitempty"`
}

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 *bool   `json:"enableReliableLogging,omitempty"`
	LogLevel              *string `json:"logLevel,omitempty"`
}

type CopyActivityTypeProperties ¶ added in v0.20240320.1143605 

type CopyActivityTypeProperties struct {
	DataIntegrationUnits            *int64                           `json:"dataIntegrationUnits,omitempty"`
	EnableSkipIncompatibleRow       *bool                            `json:"enableSkipIncompatibleRow,omitempty"`
	EnableStaging                   *bool                            `json:"enableStaging,omitempty"`
	LogSettings                     *LogSettings                     `json:"logSettings,omitempty"`
	LogStorageSettings              *LogStorageSettings              `json:"logStorageSettings,omitempty"`
	ParallelCopies                  *int64                           `json:"parallelCopies,omitempty"`
	Preserve                        *[]string                        `json:"preserve,omitempty"`
	PreserveRules                   *[]string                        `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         *bool                            `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 *string `json:"writeBehavior,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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         *int64                          `json:"batchSize,omitempty"`
	CursorMethods     *MongoDbCursorMethodsProperties `json:"cursorMethods,omitempty"`
	Filter            *string                         `json:"filter,omitempty"`
	QueryTimeout      *string                         `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *string `json:"writeBehavior,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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    *bool        `json:"detectDatetime,omitempty"`
	PageSize          *int64       `json:"pageSize,omitempty"`
	PreferredRegions  *[]string    `json:"preferredRegions,omitempty"`
	Query             *string      `json:"query,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 (o CreateOrUpdateOperationOptions) ToHeaders() *client.Headers

func (CreateOrUpdateOperationOptions) ToOData ¶ 

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

func (CreateOrUpdateOperationOptions) ToQuery ¶ 

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

type CreateOrUpdateOperationResponse ¶ 

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

type CreateRunOperationOptions ¶ 

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

func DefaultCreateRunOperationOptions ¶ 

func DefaultCreateRunOperationOptions() CreateRunOperationOptions

func (CreateRunOperationOptions) ToHeaders ¶ 

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

func (CreateRunOperationOptions) ToOData ¶ 

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

func (CreateRunOperationOptions) ToQuery ¶ 

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

type CreateRunOperationResponse ¶ 

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

type CreateRunResponse ¶ 

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

type CredentialReference ¶ 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 *string                        `json:"autoUserSpecification,omitempty"`
	Command               string                         `json:"command"`
	ExtendedProperties    *map[string]string             `json:"extendedProperties,omitempty"`
	FolderPath            *string                        `json:"folderPath,omitempty"`
	ReferenceObjects      *CustomActivityReferenceObject `json:"referenceObjects,omitempty"`
	ResourceLinkedService *LinkedServiceReference        `json:"resourceLinkedService,omitempty"`
	RetentionTimeInDays   *float64                       `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    *string                 `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     *string                `json:"compilationMode,omitempty"`
	DegreeOfParallelism *int64                 `json:"degreeOfParallelism,omitempty"`
	Parameters          *map[string]string     `json:"parameters,omitempty"`
	Priority            *int64                 `json:"priority,omitempty"`
	RuntimeVersion      *string                `json:"runtimeVersion,omitempty"`
	ScriptLinkedService LinkedServiceReference `json:"scriptLinkedService"`
	ScriptPath          string                 `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]string        `json:"baseParameters,omitempty"`
	Libraries      *[]map[string]interface{} `json:"libraries,omitempty"`
	NotebookPath   string                    `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 string                    `json:"mainClassName"`
	Parameters    *[]string                 `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 *[]string                 `json:"parameters,omitempty"`
	PythonFile string                    `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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            *bool               `json:"enableLogging,omitempty"`
	LogStorageSettings       *LogStorageSettings `json:"logStorageSettings,omitempty"`
	MaxConcurrentConnections *int64              `json:"maxConcurrentConnections,omitempty"`
	Recursive                *bool               `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         *int64                  `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 *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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 *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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  string  `json:"fileExtension"`
	FileNamePrefix *string `json:"fileNamePrefix,omitempty"`
	MaxRowsPerFile *int64  `json:"maxRowsPerFile,omitempty"`
	QuoteAllText   *bool   `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           *string `json:"distcpOptions,omitempty"`
	ResourceManagerEndpoint string  `json:"resourceManagerEndpoint"`
	TempScriptPath          string  `json:"tempScriptPath"`
}

type DocumentDbCollectionSink ¶ added in v0.20240320.1143605 

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

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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  *string      `json:"nestingSeparator,omitempty"`
	Query             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *string      `json:"httpRequestTimeout,omitempty"`
	Query              *string      `json:"query,omitempty"`
	QueryTimeout       *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *string                   `json:"alternateKeyName,omitempty"`
	IgnoreNullValues *bool                     `json:"ignoreNullValues,omitempty"`
	WriteBehavior    DynamicsSinkWriteBehavior `json:"writeBehavior"`

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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             *string      `json:"query,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *string                   `json:"alternateKeyName,omitempty"`
	IgnoreNullValues *bool                     `json:"ignoreNullValues,omitempty"`
	WriteBehavior    DynamicsSinkWriteBehavior `json:"writeBehavior"`

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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             *string      `json:"query,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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"`
	ContinuationSettings     *ContinuationSettingsReference                `json:"continuationSettings,omitempty"`
	ContinueOnError          *bool                                         `json:"continueOnError,omitempty"`
	DataFlow                 DataFlowReference                             `json:"dataFlow"`
	IntegrationRuntime       *IntegrationRuntimeReference                  `json:"integrationRuntime,omitempty"`
	RunConcurrently          *bool                                         `json:"runConcurrently,omitempty"`
	SourceStagingConcurrency *int64                                        `json:"sourceStagingConcurrency,omitempty"`
	Staging                  *DataFlowStagingInfo                          `json:"staging,omitempty"`
	TraceLevel               *string                                       `json:"traceLevel,omitempty"`
}

type ExecuteDataFlowActivityTypePropertiesCompute ¶ added in v0.20240320.1143605 

type ExecuteDataFlowActivityTypePropertiesCompute struct {
	ComputeType *string `json:"computeType,omitempty"`
	CoreCount   *int64  `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"`
	ContinuationSettings     *ContinuationSettingsReference                `json:"continuationSettings,omitempty"`
	ContinueOnError          *bool                                         `json:"continueOnError,omitempty"`
	DataFlow                 DataFlowReference                             `json:"dataFlow"`
	IntegrationRuntime       *IntegrationRuntimeReference                  `json:"integrationRuntime,omitempty"`
	Queries                  *[]PowerQuerySinkMapping                      `json:"queries,omitempty"`
	RunConcurrently          *bool                                         `json:"runConcurrently,omitempty"`
	Sinks                    *map[string]PowerQuerySink                    `json:"sinks,omitempty"`
	SourceStagingConcurrency *int64                                        `json:"sourceStagingConcurrency,omitempty"`
	Staging                  *DataFlowStagingInfo                          `json:"staging,omitempty"`
	TraceLevel               *string                                       `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           *string                                       `json:"environmentPath,omitempty"`
	ExecutionCredential       *SSISExecutionCredential                      `json:"executionCredential,omitempty"`
	LogLocation               *SSISLogLocation                              `json:"logLocation,omitempty"`
	LoggingLevel              *string                                       `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                   *string                                       `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 string `json:"errorCode"`
	Message   string `json:"message"`
}

type FileServerReadSettings ¶ added in v0.20240320.1143605 

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

	// Fields inherited from StoreReadSettings
	DisableMetricsCollection *bool  `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64 `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             *string         `json:"copyBehavior,omitempty"`
	DisableMetricsCollection *bool           `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64          `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 *string `json:"copyBehavior,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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         *bool        `json:"recursive,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *bool   `json:"deleteFilesAfterCompletion,omitempty"`
	DisableChunking            *bool   `json:"disableChunking,omitempty"`
	EnablePartitionDiscovery   *bool   `json:"enablePartitionDiscovery,omitempty"`
	FileListPath               *string `json:"fileListPath,omitempty"`
	PartitionRootPath          *string `json:"partitionRootPath,omitempty"`
	Recursive                  *bool   `json:"recursive,omitempty"`
	UseBinaryTransfer          *bool   `json:"useBinaryTransfer,omitempty"`
	WildcardFileName           *string `json:"wildcardFileName,omitempty"`
	WildcardFolderPath         *string `json:"wildcardFolderPath,omitempty"`

	// Fields inherited from StoreReadSettings
	DisableMetricsCollection *bool  `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64 `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      *[]string          `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *bool   `json:"deleteFilesAfterCompletion,omitempty"`
	EnablePartitionDiscovery   *bool   `json:"enablePartitionDiscovery,omitempty"`
	FileListPath               *string `json:"fileListPath,omitempty"`
	ModifiedDatetimeEnd        *string `json:"modifiedDatetimeEnd,omitempty"`
	ModifiedDatetimeStart      *string `json:"modifiedDatetimeStart,omitempty"`
	PartitionRootPath          *string `json:"partitionRootPath,omitempty"`
	Prefix                     *string `json:"prefix,omitempty"`
	Recursive                  *bool   `json:"recursive,omitempty"`
	WildcardFileName           *string `json:"wildcardFileName,omitempty"`
	WildcardFolderPath         *string `json:"wildcardFolderPath,omitempty"`

	// Fields inherited from StoreReadSettings
	DisableMetricsCollection *bool  `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64 `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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             *[]string                         `json:"arguments,omitempty"`
	Defines               *map[string]string                `json:"defines,omitempty"`
	GetDebugInfo          *HDInsightActivityDebugInfoOption `json:"getDebugInfo,omitempty"`
	QueryTimeout          *int64                            `json:"queryTimeout,omitempty"`
	ScriptLinkedService   *LinkedServiceReference           `json:"scriptLinkedService,omitempty"`
	ScriptPath            *string                           `json:"scriptPath,omitempty"`
	StorageLinkedServices *[]LinkedServiceReference         `json:"storageLinkedServices,omitempty"`
	Variables             *map[string]string                `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             *[]string                         `json:"arguments,omitempty"`
	ClassName             string                            `json:"className"`
	Defines               *map[string]string                `json:"defines,omitempty"`
	GetDebugInfo          *HDInsightActivityDebugInfoOption `json:"getDebugInfo,omitempty"`
	JarFilePath           string                            `json:"jarFilePath"`
	JarLibs               *[]string                         `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             *[]string                         `json:"arguments,omitempty"`
	Defines               *map[string]string                `json:"defines,omitempty"`
	GetDebugInfo          *HDInsightActivityDebugInfoOption `json:"getDebugInfo,omitempty"`
	ScriptLinkedService   *LinkedServiceReference           `json:"scriptLinkedService,omitempty"`
	ScriptPath            *string                           `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             *[]string                         `json:"arguments,omitempty"`
	ClassName             *string                           `json:"className,omitempty"`
	EntryFilePath         string                            `json:"entryFilePath"`
	GetDebugInfo          *HDInsightActivityDebugInfoOption `json:"getDebugInfo,omitempty"`
	ProxyUser             *string                           `json:"proxyUser,omitempty"`
	RootPath              string                            `json:"rootPath"`
	SparkConfig           *map[string]string                `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             *[]string                         `json:"arguments,omitempty"`
	Combiner              *string                           `json:"combiner,omitempty"`
	CommandEnvironment    *[]string                         `json:"commandEnvironment,omitempty"`
	Defines               *map[string]string                `json:"defines,omitempty"`
	FileLinkedService     *LinkedServiceReference           `json:"fileLinkedService,omitempty"`
	FilePaths             []string                          `json:"filePaths"`
	GetDebugInfo          *HDInsightActivityDebugInfoOption `json:"getDebugInfo,omitempty"`
	Input                 string                            `json:"input"`
	Mapper                string                            `json:"mapper"`
	Output                string                            `json:"output"`
	Reducer               string                            `json:"reducer"`
	StorageLinkedServices *[]LinkedServiceReference         `json:"storageLinkedServices,omitempty"`
}

type HTTPReadSettings ¶ added in v0.20240320.1143605 

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

	// Fields inherited from StoreReadSettings
	DisableMetricsCollection *bool  `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64 `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 *string `json:"httpRequestTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *bool           `json:"deleteFilesAfterCompletion,omitempty"`
	DistcpSettings             *DistcpSettings `json:"distcpSettings,omitempty"`
	EnablePartitionDiscovery   *bool           `json:"enablePartitionDiscovery,omitempty"`
	FileListPath               *string         `json:"fileListPath,omitempty"`
	ModifiedDatetimeEnd        *string         `json:"modifiedDatetimeEnd,omitempty"`
	ModifiedDatetimeStart      *string         `json:"modifiedDatetimeStart,omitempty"`
	PartitionRootPath          *string         `json:"partitionRootPath,omitempty"`
	Recursive                  *bool           `json:"recursive,omitempty"`
	WildcardFileName           *string         `json:"wildcardFileName,omitempty"`
	WildcardFolderPath         *string         `json:"wildcardFolderPath,omitempty"`

	// Fields inherited from StoreReadSettings
	DisableMetricsCollection *bool  `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64 `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      *bool           `json:"recursive,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *string `json:"preCopyScript,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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 *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *string `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 *bool   `json:"deleteFilesAfterCompletion,omitempty"`
	EnablePartitionDiscovery   *bool   `json:"enablePartitionDiscovery,omitempty"`
	FileListPath               *string `json:"fileListPath,omitempty"`
	ModifiedDatetimeEnd        *string `json:"modifiedDatetimeEnd,omitempty"`
	ModifiedDatetimeStart      *string `json:"modifiedDatetimeStart,omitempty"`
	PartitionRootPath          *string `json:"partitionRootPath,omitempty"`
	Recursive                  *bool   `json:"recursive,omitempty"`
	WildcardFileName           *string `json:"wildcardFileName,omitempty"`
	WildcardFolderPath         *string `json:"wildcardFolderPath,omitempty"`

	// Fields inherited from StoreReadSettings
	DisableMetricsCollection *bool  `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64 `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   *string      `json:"partitionOption,omitempty"`
	TableActionOption *string      `json:"tableActionOption,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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     *string      `json:"timestampAsOf,omitempty"`
	VersionAsOf       *int64       `json:"versionAsOf,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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             *string         `json:"copyBehavior,omitempty"`
	DisableMetricsCollection *bool           `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64          `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 ListByFactoryCustomPager ¶ added in v0.20240628.1153531 

type ListByFactoryCustomPager struct {
	NextLink *odata.Link `json:"nextLink"`
}
func (p *ListByFactoryCustomPager) NextPageLink() *odata.Link

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              *string                `json:"path,omitempty"`
}

type LogSettings ¶ added in v0.20240320.1143605 

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

type LogStorageSettings ¶ added in v0.20240320.1143605 

type LogStorageSettings struct {
	EnableReliableLogging *bool                  `json:"enableReliableLogging,omitempty"`
	LinkedServiceName     LinkedServiceReference `json:"linkedServiceName"`
	LogLevel              *string                `json:"logLevel,omitempty"`
	Path                  *string                `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 *bool            `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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  *string `json:"name,omitempty"`
	Value *string `json:"value,omitempty"`
}

type MicrosoftAccessSink ¶ added in v0.20240320.1143605 

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

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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             *string      `json:"query,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *string `json:"writeBehavior,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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         *int64                          `json:"batchSize,omitempty"`
	CursorMethods     *MongoDbCursorMethodsProperties `json:"cursorMethods,omitempty"`
	Filter            *string                         `json:"filter,omitempty"`
	QueryTimeout      *string                         `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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   *int64  `json:"limit,omitempty"`
	Project *string `json:"project,omitempty"`
	Skip    *int64  `json:"skip,omitempty"`
	Sort    *string `json:"sort,omitempty"`
}

type MongoDbSource ¶ added in v0.20240320.1143605 

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

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *string `json:"writeBehavior,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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         *int64                          `json:"batchSize,omitempty"`
	CursorMethods     *MongoDbCursorMethodsProperties `json:"cursorMethods,omitempty"`
	Filter            *string                         `json:"filter,omitempty"`
	QueryTimeout      *string                         `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *string `json:"partitionColumnName,omitempty"`
	PartitionLowerBound *string `json:"partitionLowerBound,omitempty"`
	PartitionUpperBound *string `json:"partitionUpperBound,omitempty"`
}

type NetezzaSource ¶ added in v0.20240320.1143605 

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

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *string                `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 *string      `json:"httpRequestTimeout,omitempty"`
	Query              *string      `json:"query,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *string `json:"preCopyScript,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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      *[]string    `json:"allowedGroups,omitempty"`
	DateFilterColumn   *string      `json:"dateFilterColumn,omitempty"`
	EndTime            *string      `json:"endTime,omitempty"`
	OutputColumns      *interface{} `json:"outputColumns,omitempty"`
	StartTime          *string      `json:"startTime,omitempty"`
	UserScopeFilterUri *string      `json:"userScopeFilterUri,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *bool   `json:"deleteFilesAfterCompletion,omitempty"`
	EnablePartitionDiscovery   *bool   `json:"enablePartitionDiscovery,omitempty"`
	FileListPath               *string `json:"fileListPath,omitempty"`
	ModifiedDatetimeEnd        *string `json:"modifiedDatetimeEnd,omitempty"`
	ModifiedDatetimeStart      *string `json:"modifiedDatetimeStart,omitempty"`
	PartitionRootPath          *string `json:"partitionRootPath,omitempty"`
	Prefix                     *string `json:"prefix,omitempty"`
	Recursive                  *bool   `json:"recursive,omitempty"`
	WildcardFileName           *string `json:"wildcardFileName,omitempty"`
	WildcardFolderPath         *string `json:"wildcardFolderPath,omitempty"`

	// Fields inherited from StoreReadSettings
	DisableMetricsCollection *bool  `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64 `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 *string      `json:"partitionColumnName,omitempty"`
	PartitionLowerBound *string      `json:"partitionLowerBound,omitempty"`
	PartitionNames      *interface{} `json:"partitionNames,omitempty"`
	PartitionUpperBound *string      `json:"partitionUpperBound,omitempty"`
}

type OracleServiceCloudSource ¶ added in v0.20240320.1143605 

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

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *string `json:"preCopyScript,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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 *string                  `json:"oracleReaderQuery,omitempty"`
	PartitionOption   *string                  `json:"partitionOption,omitempty"`
	PartitionSettings *OraclePartitionSettings `json:"partitionSettings,omitempty"`
	QueryTimeout      *string                  `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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 *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *string `json:"fileNamePrefix,omitempty"`
	MaxRowsPerFile *int64  `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 *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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 *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *string `json:"fileNamePrefix,omitempty"`
	MaxRowsPerFile *int64  `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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]string                 `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 ¶ 

func (p PipelineResourceOperationPredicate) Matches(input PipelineResource) bool

type PipelinesClient ¶ 

type PipelinesClient struct {
	Client *resourcemanager.Client
}

func NewPipelinesClientWithBaseURI ¶ 

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

func (PipelinesClient) CreateOrUpdate ¶ 

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

CreateOrUpdate ...

func (PipelinesClient) CreateRun ¶ 

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

CreateRun ...

func (PipelinesClient) Delete ¶ 

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

Delete ...

func (PipelinesClient) Get ¶ 

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

Get ...

func (PipelinesClient) ListByFactory ¶ 

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

ListByFactory ...

func (PipelinesClient) ListByFactoryComplete ¶ 

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

ListByFactoryComplete retrieves all the results into a single object

func (PipelinesClient) ListByFactoryCompleteMatchingPredicate ¶ 

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

ListByFactoryCompleteMatchingPredicate retrieves all the results and then applies the predicate

type PolybaseSettings ¶ added in v0.20240320.1143605 

type PolybaseSettings struct {
	RejectSampleValue *int64                      `json:"rejectSampleValue,omitempty"`
	RejectType        *PolybaseSettingsRejectType `json:"rejectType,omitempty"`
	RejectValue       *int64                      `json:"rejectValue,omitempty"`
	UseTypeDefault    *bool                       `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 string  `json:"linkedServiceName"`
	Path              *string `json:"path,omitempty"`
}

type RedshiftUnloadSettings ¶ added in v0.20240320.1143605 

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

type RelationalSource ¶ added in v0.20240320.1143605 

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

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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   *map[string]string `json:"additionalHeaders,omitempty"`
	HTTPCompressionType *string            `json:"httpCompressionType,omitempty"`
	HTTPRequestTimeout  *string            `json:"httpRequestTimeout,omitempty"`
	RequestInterval     *interface{}       `json:"requestInterval,omitempty"`
	RequestMethod       *string            `json:"requestMethod,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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  *map[string]string `json:"additionalColumns,omitempty"`
	AdditionalHeaders  *string            `json:"additionalHeaders,omitempty"`
	HTTPRequestTimeout *string            `json:"httpRequestTimeout,omitempty"`
	PaginationRules    *string            `json:"paginationRules,omitempty"`
	RequestBody        *string            `json:"requestBody,omitempty"`
	RequestInterval    *interface{}       `json:"requestInterval,omitempty"`
	RequestMethod      *string            `json:"requestMethod,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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   string     `json:"domain"`
	Password SecretBase `json:"password"`
	UserName string     `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          string  `json:"packageContent"`
	PackageLastModifiedDate *string `json:"packageLastModifiedDate,omitempty"`
	PackageName             *string `json:"packageName,omitempty"`
	PackagePath             string  `json:"packagePath"`
}

type SSISExecutionCredential ¶ added in v0.20240320.1143605 

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

type SSISExecutionParameter ¶ added in v0.20240320.1143605 

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

type SSISLogLocation ¶ added in v0.20240320.1143605 

type SSISLogLocation struct {
	LogPath        string                        `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 *string               `json:"logRefreshInterval,omitempty"`
}

type SSISPackageLocation ¶ added in v0.20240320.1143605 

type SSISPackageLocation struct {
	PackagePath    *string                            `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             *string               `json:"configurationPath,omitempty"`
	PackageContent                *string               `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       string `json:"value"`
}

type SalesforceMarketingCloudSource ¶ added in v0.20240320.1143605 

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

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *string                      `json:"externalIdFieldName,omitempty"`
	IgnoreNullValues    *bool                        `json:"ignoreNullValues,omitempty"`
	WriteBehavior       *SalesforceSinkWriteBehavior `json:"writeBehavior,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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             *string      `json:"query,omitempty"`
	ReadBehavior      *string      `json:"readBehavior,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *string                        `json:"externalIdFieldName,omitempty"`
	IgnoreNullValues    *bool                          `json:"ignoreNullValues,omitempty"`
	WriteBehavior       *SalesforceV2SinkWriteBehavior `json:"writeBehavior,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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 *bool        `json:"includeDeletedObjects,omitempty"`
	Query                 *string      `json:"query,omitempty"`
	SOQLQuery             *string      `json:"SOQLQuery,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *string                      `json:"externalIdFieldName,omitempty"`
	IgnoreNullValues    *bool                        `json:"ignoreNullValues,omitempty"`
	WriteBehavior       *SalesforceSinkWriteBehavior `json:"writeBehavior,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`
	ReadBehavior      *string      `json:"readBehavior,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *string                        `json:"externalIdFieldName,omitempty"`
	IgnoreNullValues    *bool                          `json:"ignoreNullValues,omitempty"`
	WriteBehavior       *SalesforceV2SinkWriteBehavior `json:"writeBehavior,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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 *bool        `json:"includeDeletedObjects,omitempty"`
	Query                 *string      `json:"query,omitempty"`
	QueryTimeout          *string      `json:"queryTimeout,omitempty"`
	SOQLQuery             *string      `json:"SOQLQuery,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *string                               `json:"httpRequestTimeout,omitempty"`
	WriteBehavior      *SapCloudForCustomerSinkWriteBehavior `json:"writeBehavior,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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 *string      `json:"httpRequestTimeout,omitempty"`
	Query              *string      `json:"query,omitempty"`
	QueryTimeout       *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *string      `json:"httpRequestTimeout,omitempty"`
	Query              *string      `json:"query,omitempty"`
	QueryTimeout       *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *string `json:"partitionColumnName,omitempty"`
}

type SapHanaSource ¶ added in v0.20240320.1143605 

type SapHanaSource struct {
	AdditionalColumns *interface{}              `json:"additionalColumns,omitempty"`
	PacketSize        *int64                    `json:"packetSize,omitempty"`
	PartitionOption   *string                   `json:"partitionOption,omitempty"`
	PartitionSettings *SapHanaPartitionSettings `json:"partitionSettings,omitempty"`
	Query             *string                   `json:"query,omitempty"`
	QueryTimeout      *string                   `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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    *string      `json:"extractionMode,omitempty"`
	Projection        *interface{} `json:"projection,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`
	Selection         *interface{} `json:"selection,omitempty"`
	SubscriberProcess *string      `json:"subscriberProcess,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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                    *int64       `json:"baseRequestId,omitempty"`
	CustomRfcReadTableFunctionModule *string      `json:"customRfcReadTableFunctionModule,omitempty"`
	ExcludeLastRequest               *bool        `json:"excludeLastRequest,omitempty"`
	QueryTimeout                     *string      `json:"queryTimeout,omitempty"`
	SapDataColumnDelimiter           *string      `json:"sapDataColumnDelimiter,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *int64  `json:"maxPartitionsNumber,omitempty"`
	PartitionColumnName *string `json:"partitionColumnName,omitempty"`
	PartitionLowerBound *string `json:"partitionLowerBound,omitempty"`
	PartitionUpperBound *string `json:"partitionUpperBound,omitempty"`
}

type SapTableSource ¶ added in v0.20240320.1143605 

type SapTableSource struct {
	AdditionalColumns                *interface{}               `json:"additionalColumns,omitempty"`
	BatchSize                        *int64                     `json:"batchSize,omitempty"`
	CustomRfcReadTableFunctionModule *string                    `json:"customRfcReadTableFunctionModule,omitempty"`
	PartitionOption                  *interface{}               `json:"partitionOption,omitempty"`
	PartitionSettings                *SapTablePartitionSettings `json:"partitionSettings,omitempty"`
	QueryTimeout                     *string                    `json:"queryTimeout,omitempty"`
	RfcTableFields                   *string                    `json:"rfcTableFields,omitempty"`
	RfcTableOptions                  *string                    `json:"rfcTableOptions,omitempty"`
	RowCount                         *int64                     `json:"rowCount,omitempty"`
	RowSkips                         *int64                     `json:"rowSkips,omitempty"`
	SapDataColumnDelimiter           *string                    `json:"sapDataColumnDelimiter,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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      *string                           `json:"name,omitempty"`
	Size      *int64                            `json:"size,omitempty"`
	Type      *ScriptActivityParameterType      `json:"type,omitempty"`
	Value     *string                           `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       string                     `json:"text"`
	Type       string                     `json:"type"`
}

type ScriptActivityTypeProperties ¶ added in v0.20240320.1143605 

type ScriptActivityTypeProperties struct {
	LogSettings                 *ScriptActivityTypePropertiesLogSettings `json:"logSettings,omitempty"`
	ScriptBlockExecutionTimeout *string                                  `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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      *string       `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *bool   `json:"deleteFilesAfterCompletion,omitempty"`
	DisableChunking            *bool   `json:"disableChunking,omitempty"`
	EnablePartitionDiscovery   *bool   `json:"enablePartitionDiscovery,omitempty"`
	FileListPath               *string `json:"fileListPath,omitempty"`
	ModifiedDatetimeEnd        *string `json:"modifiedDatetimeEnd,omitempty"`
	ModifiedDatetimeStart      *string `json:"modifiedDatetimeStart,omitempty"`
	PartitionRootPath          *string `json:"partitionRootPath,omitempty"`
	Recursive                  *bool   `json:"recursive,omitempty"`
	WildcardFileName           *string `json:"wildcardFileName,omitempty"`
	WildcardFolderPath         *string `json:"wildcardFolderPath,omitempty"`

	// Fields inherited from StoreReadSettings
	DisableMetricsCollection *bool  `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64 `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  *string `json:"operationTimeout,omitempty"`
	UseTempFileRename *bool   `json:"useTempFileRename,omitempty"`

	// Fields inherited from StoreWriteSettings
	CopyBehavior             *string         `json:"copyBehavior,omitempty"`
	DisableMetricsCollection *bool           `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64          `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 *string `json:"httpRequestTimeout,omitempty"`
	Query              *string `json:"query,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *bool `json:"dataInconsistency,omitempty"`
	FileMissing       *bool `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"`
	StorageIntegration      *string                 `json:"storageIntegration,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"`
	StorageIntegration      *string                 `json:"storageIntegration,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  *string                     `json:"preCopyScript,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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          *string                    `json:"query,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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  *string                     `json:"preCopyScript,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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          *string                    `json:"query,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 string                          `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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      *bool                  `json:"allowCopyCommand,omitempty"`
	AllowPolyBase         *bool                  `json:"allowPolyBase,omitempty"`
	CopyCommandSettings   *DWCopyCommandSettings `json:"copyCommandSettings,omitempty"`
	PolyBaseSettings      *PolybaseSettings      `json:"polyBaseSettings,omitempty"`
	PreCopyScript         *string                `json:"preCopyScript,omitempty"`
	SqlWriterUseTableLock *bool                  `json:"sqlWriterUseTableLock,omitempty"`
	TableOption           *string                `json:"tableOption,omitempty"`
	UpsertSettings        *SqlDWUpsertSettings   `json:"upsertSettings,omitempty"`
	WriteBehavior         *string                `json:"writeBehavior,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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               *string               `json:"isolationLevel,omitempty"`
	PartitionOption              *string               `json:"partitionOption,omitempty"`
	PartitionSettings            *SqlPartitionSettings `json:"partitionSettings,omitempty"`
	QueryTimeout                 *string               `json:"queryTimeout,omitempty"`
	SqlReaderQuery               *string               `json:"sqlReaderQuery,omitempty"`
	SqlReaderStoredProcedureName *string               `json:"sqlReaderStoredProcedureName,omitempty"`
	StoredProcedureParameters    *interface{}          `json:"storedProcedureParameters,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *string   `json:"interimSchemaName,omitempty"`
	Keys              *[]string `json:"keys,omitempty"`
}

type SqlMISink ¶ added in v0.20240320.1143605 

type SqlMISink struct {
	PreCopyScript                         *string            `json:"preCopyScript,omitempty"`
	SqlWriterStoredProcedureName          *string            `json:"sqlWriterStoredProcedureName,omitempty"`
	SqlWriterTableType                    *string            `json:"sqlWriterTableType,omitempty"`
	SqlWriterUseTableLock                 *bool              `json:"sqlWriterUseTableLock,omitempty"`
	StoredProcedureParameters             *interface{}       `json:"storedProcedureParameters,omitempty"`
	StoredProcedureTableTypeParameterName *string            `json:"storedProcedureTableTypeParameterName,omitempty"`
	TableOption                           *string            `json:"tableOption,omitempty"`
	UpsertSettings                        *SqlUpsertSettings `json:"upsertSettings,omitempty"`
	WriteBehavior                         *string            `json:"writeBehavior,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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               *string               `json:"isolationLevel,omitempty"`
	PartitionOption              *string               `json:"partitionOption,omitempty"`
	PartitionSettings            *SqlPartitionSettings `json:"partitionSettings,omitempty"`
	ProduceAdditionalTypes       *interface{}          `json:"produceAdditionalTypes,omitempty"`
	QueryTimeout                 *string               `json:"queryTimeout,omitempty"`
	SqlReaderQuery               *string               `json:"sqlReaderQuery,omitempty"`
	SqlReaderStoredProcedureName *string               `json:"sqlReaderStoredProcedureName,omitempty"`
	StoredProcedureParameters    *interface{}          `json:"storedProcedureParameters,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *string `json:"partitionColumnName,omitempty"`
	PartitionLowerBound *string `json:"partitionLowerBound,omitempty"`
	PartitionUpperBound *string `json:"partitionUpperBound,omitempty"`
}

type SqlServerSink ¶ added in v0.20240320.1143605 

type SqlServerSink struct {
	PreCopyScript                         *string            `json:"preCopyScript,omitempty"`
	SqlWriterStoredProcedureName          *string            `json:"sqlWriterStoredProcedureName,omitempty"`
	SqlWriterTableType                    *string            `json:"sqlWriterTableType,omitempty"`
	SqlWriterUseTableLock                 *bool              `json:"sqlWriterUseTableLock,omitempty"`
	StoredProcedureParameters             *interface{}       `json:"storedProcedureParameters,omitempty"`
	StoredProcedureTableTypeParameterName *string            `json:"storedProcedureTableTypeParameterName,omitempty"`
	TableOption                           *string            `json:"tableOption,omitempty"`
	UpsertSettings                        *SqlUpsertSettings `json:"upsertSettings,omitempty"`
	WriteBehavior                         *string            `json:"writeBehavior,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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               *string               `json:"isolationLevel,omitempty"`
	PartitionOption              *string               `json:"partitionOption,omitempty"`
	PartitionSettings            *SqlPartitionSettings `json:"partitionSettings,omitempty"`
	ProduceAdditionalTypes       *interface{}          `json:"produceAdditionalTypes,omitempty"`
	QueryTimeout                 *string               `json:"queryTimeout,omitempty"`
	SqlReaderQuery               *string               `json:"sqlReaderQuery,omitempty"`
	SqlReaderStoredProcedureName *string               `json:"sqlReaderStoredProcedureName,omitempty"`
	StoredProcedureParameters    *interface{}          `json:"storedProcedureParameters,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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       string       `json:"storedProcedureName"`
	StoredProcedureParameters *interface{} `json:"storedProcedureParameters,omitempty"`
}

type SqlSink ¶ added in v0.20240320.1143605 

type SqlSink struct {
	PreCopyScript                         *string            `json:"preCopyScript,omitempty"`
	SqlWriterStoredProcedureName          *string            `json:"sqlWriterStoredProcedureName,omitempty"`
	SqlWriterTableType                    *string            `json:"sqlWriterTableType,omitempty"`
	SqlWriterUseTableLock                 *bool              `json:"sqlWriterUseTableLock,omitempty"`
	StoredProcedureParameters             *interface{}       `json:"storedProcedureParameters,omitempty"`
	StoredProcedureTableTypeParameterName *string            `json:"storedProcedureTableTypeParameterName,omitempty"`
	TableOption                           *string            `json:"tableOption,omitempty"`
	UpsertSettings                        *SqlUpsertSettings `json:"upsertSettings,omitempty"`
	WriteBehavior                         *string            `json:"writeBehavior,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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               *string               `json:"isolationLevel,omitempty"`
	PartitionOption              *string               `json:"partitionOption,omitempty"`
	PartitionSettings            *SqlPartitionSettings `json:"partitionSettings,omitempty"`
	QueryTimeout                 *string               `json:"queryTimeout,omitempty"`
	SqlReaderQuery               *string               `json:"sqlReaderQuery,omitempty"`
	SqlReaderStoredProcedureName *string               `json:"sqlReaderStoredProcedureName,omitempty"`
	StoredProcedureParameters    *interface{}          `json:"storedProcedureParameters,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *string   `json:"interimSchemaName,omitempty"`
	Keys              *[]string `json:"keys,omitempty"`
	UseTempDB         *bool     `json:"useTempDB,omitempty"`
}

type SquareSource ¶ added in v0.20240320.1143605 

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

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *bool                  `json:"enableCompression,omitempty"`
	LinkedServiceName LinkedServiceReference `json:"linkedServiceName"`
	Path              *string                `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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               *string                                     `json:"driverSize,omitempty"`
	ExecutorSize             *string                                     `json:"executorSize,omitempty"`
	Notebook                 SynapseNotebookReference                    `json:"notebook"`
	NumExecutors             *int64                                      `json:"numExecutors,omitempty"`
	Parameters               *map[string]NotebookParameter               `json:"parameters,omitempty"`
	SparkConfig              *map[string]string                          `json:"sparkConfig,omitempty"`
	SparkPool                *BigDataPoolParametrizationReference        `json:"sparkPool,omitempty"`
	TargetSparkConfiguration *SparkConfigurationParametrizationReference `json:"targetSparkConfiguration,omitempty"`
}

type SynapseNotebookReference ¶ added in v0.20240320.1143605 

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

type SynapseSparkJobActivityTypeProperties ¶ added in v0.20240320.1143605 

type SynapseSparkJobActivityTypeProperties struct {
	Args                     *[]interface{}                              `json:"args,omitempty"`
	ClassName                *string                                     `json:"className,omitempty"`
	Conf                     *interface{}                                `json:"conf,omitempty"`
	ConfigurationType        *ConfigurationType                          `json:"configurationType,omitempty"`
	DriverSize               *string                                     `json:"driverSize,omitempty"`
	ExecutorSize             *string                                     `json:"executorSize,omitempty"`
	File                     *string                                     `json:"file,omitempty"`
	Files                    *[]string                                   `json:"files,omitempty"`
	FilesV2                  *[]string                                   `json:"filesV2,omitempty"`
	NumExecutors             *int64                                      `json:"numExecutors,omitempty"`
	PythonCodeReference      *[]string                                   `json:"pythonCodeReference,omitempty"`
	ScanFolder               *bool                                       `json:"scanFolder,omitempty"`
	SparkConfig              *map[string]string                          `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 string                `json:"referenceName"`
	Type          SparkJobReferenceType `json:"type"`
}

type TabularSource ¶ added in v0.20240320.1143605 

type TabularSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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           *string                 `json:"columnMappings,omitempty"`
	MapComplexValuesToString *bool                   `json:"mapComplexValuesToString,omitempty"`
	Mappings                 *interface{}            `json:"mappings,omitempty"`
	SchemaMapping            *interface{}            `json:"schemaMapping,omitempty"`
	TypeConversion           *bool                   `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 *bool `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 *bool `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 *string `json:"partitionColumnName,omitempty"`
	PartitionLowerBound *string `json:"partitionLowerBound,omitempty"`
	PartitionUpperBound *string `json:"partitionUpperBound,omitempty"`
}

type TeradataSource ¶ added in v0.20240320.1143605 

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

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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  *bool   `json:"allowDataTruncation,omitempty"`
	Culture              *string `json:"culture,omitempty"`
	DateTimeFormat       *string `json:"dateTimeFormat,omitempty"`
	DateTimeOffsetFormat *string `json:"dateTimeOffsetFormat,omitempty"`
	TimeSpanFormat       *string `json:"timeSpanFormat,omitempty"`
	TreatBooleanAsNumber *bool   `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    *string    `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 string `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  *bool            `json:"childItems,omitempty"`
	Dataset     DatasetReference `json:"dataset"`
	MinimumSize *int64           `json:"minimumSize,omitempty"`
	Sleep       *int64           `json:"sleep,omitempty"`
	Timeout     *string          `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 int64 `json:"waitTimeInSeconds"`
}

type WarehouseSink ¶ added in v0.20240320.1143605 

type WarehouseSink struct {
	AllowCopyCommand    *bool                  `json:"allowCopyCommand,omitempty"`
	CopyCommandSettings *DWCopyCommandSettings `json:"copyCommandSettings,omitempty"`
	PreCopyScript       *string                `json:"preCopyScript,omitempty"`
	TableOption         *string                `json:"tableOption,omitempty"`
	WriteBehavior       *string                `json:"writeBehavior,omitempty"`

	// Fields inherited from CopySink
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SinkRetryCount           *int64  `json:"sinkRetryCount,omitempty"`
	SinkRetryWait            *string `json:"sinkRetryWait,omitempty"`
	WriteBatchSize           *int64  `json:"writeBatchSize,omitempty"`
	WriteBatchTimeout        *string `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               *string               `json:"isolationLevel,omitempty"`
	PartitionOption              *interface{}          `json:"partitionOption,omitempty"`
	PartitionSettings            *SqlPartitionSettings `json:"partitionSettings,omitempty"`
	QueryTimeout                 *string               `json:"queryTimeout,omitempty"`
	SqlReaderQuery               *string               `json:"sqlReaderQuery,omitempty"`
	SqlReaderStoredProcedureName *string               `json:"sqlReaderStoredProcedureName,omitempty"`
	StoredProcedureParameters    *interface{}          `json:"storedProcedureParameters,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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   *string              `json:"resource,omitempty"`
	Type       *string              `json:"type,omitempty"`
	UserTenant *string              `json:"userTenant,omitempty"`
	Username   *string              `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                  *string                      `json:"body,omitempty"`
	ConnectVia            *IntegrationRuntimeReference `json:"connectVia,omitempty"`
	Datasets              *[]DatasetReference          `json:"datasets,omitempty"`
	DisableCertValidation *bool                        `json:"disableCertValidation,omitempty"`
	HTTPRequestTimeout    *string                      `json:"httpRequestTimeout,omitempty"`
	Headers               *map[string]string           `json:"headers,omitempty"`
	LinkedServices        *[]LinkedServiceReference    `json:"linkedServices,omitempty"`
	Method                WebActivityMethod            `json:"method"`
	TurnOffAsync          *bool                        `json:"turnOffAsync,omitempty"`
	Url                   string                       `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                   *string                    `json:"body,omitempty"`
	Headers                *map[string]string         `json:"headers,omitempty"`
	Method                 WebHookActivityMethod      `json:"method"`
	ReportStatusOnCallBack *bool                      `json:"reportStatusOnCallBack,omitempty"`
	Timeout                *string                    `json:"timeout,omitempty"`
	Url                    string                     `json:"url"`
}

type WebSource ¶ added in v0.20240320.1143605 

type WebSource struct {
	AdditionalColumns *interface{} `json:"additionalColumns,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

	// Fields inherited from CopySource
	DisableMetricsCollection *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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        *bool                   `json:"detectDataType,omitempty"`
	NamespacePrefixes     *map[string]string      `json:"namespacePrefixes,omitempty"`
	Namespaces            *bool                   `json:"namespaces,omitempty"`
	ValidationMode        *string                 `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 *bool   `json:"disableMetricsCollection,omitempty"`
	MaxConcurrentConnections *int64  `json:"maxConcurrentConnections,omitempty"`
	SourceRetryCount         *int64  `json:"sourceRetryCount,omitempty"`
	SourceRetryWait          *string `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 *bool `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             *string      `json:"query,omitempty"`
	QueryTimeout      *string      `json:"queryTimeout,omitempty"`

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

func (ZohoSource) MarshalJSON ¶ added in v0.20240327.1081628 

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

Source Files ¶

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.