pipelines

package

Go to main page

Versions in this module

v0

v0.20241029.1112340

Oct 29, 2024

v0.20241025.1143247

Oct 25, 2024

v0.20241023.1122425

Oct 23, 2024

v0.20241021.1074254

Oct 21, 2024

v0.20241017.1093842

Oct 17, 2024

Changes in this version

type SalesforceV2Source

+ PageSize *int64

v0.20241016.1080325

Oct 16, 2024

v0.20241009.1142232

Oct 9, 2024

Changes in this version

+ type AzureKeyVaultSecretReference struct

+ SecretName string

+ SecretVersion *string

+ Store LinkedServiceReference

+ Type string

+ func (s AzureKeyVaultSecretReference) MarshalJSON() ([]byte, error)

+ func (s AzureKeyVaultSecretReference) SecretBase() BaseSecretBaseImpl

v0.20241004.1180715

Oct 4, 2024

v0.20240927.1005214

Sep 27, 2024

Changes in this version

type ServiceNowV2Source

+ PageSize *int64

v0.20240923.1151247

Sep 23, 2024

v0.20240923.1142107

Sep 23, 2024

v0.20240920.1135249

Sep 20, 2024

Changes in this version

type Activity

+ func UnmarshalActivityImplementation(input []byte) (Activity, error)

+ Activity func() BaseActivityImpl

type AmazonMWSSource

+ func (s AmazonMWSSource) CopySource() BaseCopySourceImpl

type AmazonRdsForOracleSource

+ func (s AmazonRdsForOracleSource) CopySource() BaseCopySourceImpl

type AmazonRdsForSqlServerSource

+ func (s AmazonRdsForSqlServerSource) CopySource() BaseCopySourceImpl

type AmazonRedshiftSource

+ func (s AmazonRedshiftSource) CopySource() BaseCopySourceImpl

type AmazonS3CompatibleReadSettings

+ func (s AmazonS3CompatibleReadSettings) StoreReadSettings() BaseStoreReadSettingsImpl

type AmazonS3ReadSettings

+ func (s AmazonS3ReadSettings) StoreReadSettings() BaseStoreReadSettingsImpl

type AppendVariableActivity

+ Type string

+ func (s AppendVariableActivity) Activity() BaseActivityImpl

type AvroSink

+ func (s AvroSink) CopySink() BaseCopySinkImpl

type AvroSource

+ func (s AvroSource) CopySource() BaseCopySourceImpl

type AvroWriteSettings

+ func (s AvroWriteSettings) FormatWriteSettings() BaseFormatWriteSettingsImpl

type AzureBlobFSReadSettings

+ func (s AzureBlobFSReadSettings) StoreReadSettings() BaseStoreReadSettingsImpl

type AzureBlobFSSink

+ func (s AzureBlobFSSink) CopySink() BaseCopySinkImpl

type AzureBlobFSSource

+ func (s AzureBlobFSSource) CopySource() BaseCopySourceImpl

type AzureBlobFSWriteSettings

+ func (s AzureBlobFSWriteSettings) StoreWriteSettings() BaseStoreWriteSettingsImpl

type AzureBlobStorageReadSettings

+ func (s AzureBlobStorageReadSettings) StoreReadSettings() BaseStoreReadSettingsImpl

type AzureBlobStorageWriteSettings

+ func (s AzureBlobStorageWriteSettings) StoreWriteSettings() BaseStoreWriteSettingsImpl

type AzureDataExplorerCommandActivity

+ Type string

+ func (s AzureDataExplorerCommandActivity) Activity() BaseActivityImpl

type AzureDataExplorerSink

+ func (s AzureDataExplorerSink) CopySink() BaseCopySinkImpl

type AzureDataExplorerSource

+ func (s AzureDataExplorerSource) CopySource() BaseCopySourceImpl

type AzureDataLakeStoreReadSettings

+ func (s AzureDataLakeStoreReadSettings) StoreReadSettings() BaseStoreReadSettingsImpl

type AzureDataLakeStoreSink

+ func (s AzureDataLakeStoreSink) CopySink() BaseCopySinkImpl

type AzureDataLakeStoreSource

+ func (s AzureDataLakeStoreSource) CopySource() BaseCopySourceImpl

type AzureDataLakeStoreWriteSettings

+ func (s AzureDataLakeStoreWriteSettings) StoreWriteSettings() BaseStoreWriteSettingsImpl

type AzureDatabricksDeltaLakeExportCommand

+ func (s AzureDatabricksDeltaLakeExportCommand) ExportSettings() BaseExportSettingsImpl

type AzureDatabricksDeltaLakeImportCommand

+ func (s AzureDatabricksDeltaLakeImportCommand) ImportSettings() BaseImportSettingsImpl

type AzureDatabricksDeltaLakeSink

+ func (s AzureDatabricksDeltaLakeSink) CopySink() BaseCopySinkImpl

type AzureDatabricksDeltaLakeSource

+ func (s AzureDatabricksDeltaLakeSource) CopySource() BaseCopySourceImpl

type AzureFileStorageReadSettings

+ func (s AzureFileStorageReadSettings) StoreReadSettings() BaseStoreReadSettingsImpl

type AzureFileStorageWriteSettings

+ func (s AzureFileStorageWriteSettings) StoreWriteSettings() BaseStoreWriteSettingsImpl

type AzureFunctionActivity

+ Type string

+ func (s AzureFunctionActivity) Activity() BaseActivityImpl

type AzureMLBatchExecutionActivity

+ Type string

+ func (s AzureMLBatchExecutionActivity) Activity() BaseActivityImpl

type AzureMLExecutePipelineActivity

+ Type string

+ func (s AzureMLExecutePipelineActivity) Activity() BaseActivityImpl

type AzureMLUpdateResourceActivity

+ Type string

+ func (s AzureMLUpdateResourceActivity) Activity() BaseActivityImpl

type AzureMariaDBSource

+ func (s AzureMariaDBSource) CopySource() BaseCopySourceImpl

type AzureMySqlSink

+ func (s AzureMySqlSink) CopySink() BaseCopySinkImpl

type AzureMySqlSource

+ func (s AzureMySqlSource) CopySource() BaseCopySourceImpl

type AzurePostgreSqlSink

+ func (s AzurePostgreSqlSink) CopySink() BaseCopySinkImpl

type AzurePostgreSqlSource

+ func (s AzurePostgreSqlSource) CopySource() BaseCopySourceImpl

type AzureQueueSink

+ func (s AzureQueueSink) CopySink() BaseCopySinkImpl

type AzureSearchIndexSink

+ func (s AzureSearchIndexSink) CopySink() BaseCopySinkImpl

type AzureSqlSink

+ func (s AzureSqlSink) CopySink() BaseCopySinkImpl

type AzureSqlSource

+ func (s AzureSqlSource) CopySource() BaseCopySourceImpl

type AzureTableSink

+ func (s AzureTableSink) CopySink() BaseCopySinkImpl

type AzureTableSource

+ func (s AzureTableSource) CopySource() BaseCopySourceImpl

+ type BaseActivityImpl struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ State *ActivityState

+ Type string

+ UserProperties *[]UserProperty

+ func (s BaseActivityImpl) Activity() BaseActivityImpl

+ type BaseCompressionReadSettingsImpl struct

+ Type string

+ func (s BaseCompressionReadSettingsImpl) CompressionReadSettings() BaseCompressionReadSettingsImpl

+ type BaseCopySinkImpl struct

+ DisableMetricsCollection *bool

+ MaxConcurrentConnections *int64

+ SinkRetryCount *int64

+ SinkRetryWait *string

+ Type string

+ WriteBatchSize *int64

+ WriteBatchTimeout *string

+ func (s BaseCopySinkImpl) CopySink() BaseCopySinkImpl

+ type BaseCopySourceImpl struct

+ DisableMetricsCollection *bool

+ MaxConcurrentConnections *int64

+ SourceRetryCount *int64

+ SourceRetryWait *string

+ Type string

+ func (s BaseCopySourceImpl) CopySource() BaseCopySourceImpl

+ type BaseCopyTranslatorImpl struct

+ Type string

+ func (s BaseCopyTranslatorImpl) CopyTranslator() BaseCopyTranslatorImpl

+ type BaseExportSettingsImpl struct

+ Type string

+ func (s BaseExportSettingsImpl) ExportSettings() BaseExportSettingsImpl

+ type BaseFormatReadSettingsImpl struct

+ Type string

+ func (s BaseFormatReadSettingsImpl) FormatReadSettings() BaseFormatReadSettingsImpl

+ type BaseFormatWriteSettingsImpl struct

+ Type string

+ func (s BaseFormatWriteSettingsImpl) FormatWriteSettings() BaseFormatWriteSettingsImpl

+ type BaseImportSettingsImpl struct

+ Type string

+ func (s BaseImportSettingsImpl) ImportSettings() BaseImportSettingsImpl

+ type BaseSecretBaseImpl struct

+ Type string

+ func (s BaseSecretBaseImpl) SecretBase() BaseSecretBaseImpl

+ type BaseStoreReadSettingsImpl struct

+ DisableMetricsCollection *bool

+ MaxConcurrentConnections *int64

+ Type string

+ func (s BaseStoreReadSettingsImpl) StoreReadSettings() BaseStoreReadSettingsImpl

+ type BaseStoreWriteSettingsImpl struct

+ CopyBehavior *string

+ DisableMetricsCollection *bool

+ MaxConcurrentConnections *int64

+ Metadata *[]MetadataItem

+ Type string

+ func (s BaseStoreWriteSettingsImpl) StoreWriteSettings() BaseStoreWriteSettingsImpl

type BinaryReadSettings

+ func (s BinaryReadSettings) FormatReadSettings() BaseFormatReadSettingsImpl

type BinarySink

+ func (s BinarySink) CopySink() BaseCopySinkImpl

type BinarySource

+ func (s BinarySource) CopySource() BaseCopySourceImpl

type BlobSink

+ func (s BlobSink) CopySink() BaseCopySinkImpl

type BlobSource

+ func (s BlobSource) CopySource() BaseCopySourceImpl

type CassandraSource

+ func (s CassandraSource) CopySource() BaseCopySourceImpl

type CommonDataServiceForAppsSink

+ func (s CommonDataServiceForAppsSink) CopySink() BaseCopySinkImpl

type CommonDataServiceForAppsSource

+ func (s CommonDataServiceForAppsSource) CopySource() BaseCopySourceImpl

type CompressionReadSettings

+ func UnmarshalCompressionReadSettingsImplementation(input []byte) (CompressionReadSettings, error)

+ CompressionReadSettings func() BaseCompressionReadSettingsImpl

type ConcurSource

+ func (s ConcurSource) CopySource() BaseCopySourceImpl

type ControlActivity

+ Type string

+ func (s ControlActivity) Activity() BaseActivityImpl

type CopyActivity

+ Type string

+ func (s CopyActivity) Activity() BaseActivityImpl

type CopySink

+ func UnmarshalCopySinkImplementation(input []byte) (CopySink, error)

+ CopySink func() BaseCopySinkImpl

type CopySource

+ func UnmarshalCopySourceImplementation(input []byte) (CopySource, error)

+ CopySource func() BaseCopySourceImpl

type CopyTranslator

+ func UnmarshalCopyTranslatorImplementation(input []byte) (CopyTranslator, error)

+ CopyTranslator func() BaseCopyTranslatorImpl

type CosmosDbMongoDbApiSink

+ func (s CosmosDbMongoDbApiSink) CopySink() BaseCopySinkImpl

type CosmosDbMongoDbApiSource

+ func (s CosmosDbMongoDbApiSource) CopySource() BaseCopySourceImpl

type CosmosDbSqlApiSink

+ func (s CosmosDbSqlApiSink) CopySink() BaseCopySinkImpl

type CosmosDbSqlApiSource

+ func (s CosmosDbSqlApiSource) CopySource() BaseCopySourceImpl

type CouchbaseSource

+ func (s CouchbaseSource) CopySource() BaseCopySourceImpl

type CustomActivity

+ Type string

+ func (s CustomActivity) Activity() BaseActivityImpl

type DataLakeAnalyticsUSQLActivity

+ Type string

+ func (s DataLakeAnalyticsUSQLActivity) Activity() BaseActivityImpl

type DatabricksNotebookActivity

+ Type string

+ func (s DatabricksNotebookActivity) Activity() BaseActivityImpl

type DatabricksSparkJarActivity

+ Type string

+ func (s DatabricksSparkJarActivity) Activity() BaseActivityImpl

type DatabricksSparkPythonActivity

+ Type string

+ func (s DatabricksSparkPythonActivity) Activity() BaseActivityImpl

type Db2Source

+ func (s Db2Source) CopySource() BaseCopySourceImpl

type DeleteActivity

+ Type string

+ func (s DeleteActivity) Activity() BaseActivityImpl

type DelimitedTextReadSettings

+ func (s DelimitedTextReadSettings) FormatReadSettings() BaseFormatReadSettingsImpl

type DelimitedTextSink

+ func (s DelimitedTextSink) CopySink() BaseCopySinkImpl

type DelimitedTextSource

+ func (s DelimitedTextSource) CopySource() BaseCopySourceImpl

type DelimitedTextWriteSettings

+ func (s DelimitedTextWriteSettings) FormatWriteSettings() BaseFormatWriteSettingsImpl

type DocumentDbCollectionSink

+ func (s DocumentDbCollectionSink) CopySink() BaseCopySinkImpl

type DocumentDbCollectionSource

+ func (s DocumentDbCollectionSource) CopySource() BaseCopySourceImpl

type DrillSource

+ func (s DrillSource) CopySource() BaseCopySourceImpl

type DynamicsAXSource

+ func (s DynamicsAXSource) CopySource() BaseCopySourceImpl

type DynamicsCrmSink

+ func (s DynamicsCrmSink) CopySink() BaseCopySinkImpl

type DynamicsCrmSource

+ func (s DynamicsCrmSource) CopySource() BaseCopySourceImpl

type DynamicsSink

+ func (s DynamicsSink) CopySink() BaseCopySinkImpl

type DynamicsSource

+ func (s DynamicsSource) CopySource() BaseCopySourceImpl

type EloquaSource

+ func (s EloquaSource) CopySource() BaseCopySourceImpl

type ExcelSource

+ func (s ExcelSource) CopySource() BaseCopySourceImpl

type ExecuteDataFlowActivity

+ Type string

+ func (s ExecuteDataFlowActivity) Activity() BaseActivityImpl

type ExecutePipelineActivity

+ Type string

+ func (s ExecutePipelineActivity) Activity() BaseActivityImpl

type ExecuteSSISPackageActivity

+ Type string

+ func (s ExecuteSSISPackageActivity) Activity() BaseActivityImpl

type ExecuteWranglingDataflowActivity

+ Type string

+ func (s ExecuteWranglingDataflowActivity) Activity() BaseActivityImpl

type ExecutionActivity

+ Type string

+ func (s ExecutionActivity) Activity() BaseActivityImpl

type ExportSettings

+ func UnmarshalExportSettingsImplementation(input []byte) (ExportSettings, error)

+ ExportSettings func() BaseExportSettingsImpl

type FailActivity

+ Type string

+ func (s FailActivity) Activity() BaseActivityImpl

type FileServerReadSettings

+ func (s FileServerReadSettings) StoreReadSettings() BaseStoreReadSettingsImpl

type FileServerWriteSettings

+ func (s FileServerWriteSettings) StoreWriteSettings() BaseStoreWriteSettingsImpl

type FileSystemSink

+ func (s FileSystemSink) CopySink() BaseCopySinkImpl

type FileSystemSource

+ func (s FileSystemSource) CopySource() BaseCopySourceImpl

type FilterActivity

+ Type string

+ func (s FilterActivity) Activity() BaseActivityImpl

type ForEachActivity

+ Type string

+ func (s ForEachActivity) Activity() BaseActivityImpl

type FormatReadSettings

+ func UnmarshalFormatReadSettingsImplementation(input []byte) (FormatReadSettings, error)

+ FormatReadSettings func() BaseFormatReadSettingsImpl

type FormatWriteSettings

+ func UnmarshalFormatWriteSettingsImplementation(input []byte) (FormatWriteSettings, error)

+ FormatWriteSettings func() BaseFormatWriteSettingsImpl

type FtpReadSettings

+ func (s FtpReadSettings) StoreReadSettings() BaseStoreReadSettingsImpl

type GetMetadataActivity

+ Type string

+ func (s GetMetadataActivity) Activity() BaseActivityImpl

type GoogleAdWordsSource

+ func (s GoogleAdWordsSource) CopySource() BaseCopySourceImpl

type GoogleBigQuerySource

+ func (s GoogleBigQuerySource) CopySource() BaseCopySourceImpl

type GoogleBigQueryV2Source

+ func (s GoogleBigQueryV2Source) CopySource() BaseCopySourceImpl

type GoogleCloudStorageReadSettings

+ func (s GoogleCloudStorageReadSettings) StoreReadSettings() BaseStoreReadSettingsImpl

type GreenplumSource

+ func (s GreenplumSource) CopySource() BaseCopySourceImpl

type HBaseSource

+ func (s HBaseSource) CopySource() BaseCopySourceImpl

type HDInsightHiveActivity

+ Type string

+ func (s HDInsightHiveActivity) Activity() BaseActivityImpl

type HDInsightMapReduceActivity

+ Type string

+ func (s HDInsightMapReduceActivity) Activity() BaseActivityImpl

type HDInsightPigActivity

+ Type string

+ func (s HDInsightPigActivity) Activity() BaseActivityImpl

type HDInsightSparkActivity

+ Type string

+ func (s HDInsightSparkActivity) Activity() BaseActivityImpl

type HDInsightStreamingActivity

+ Type string

+ func (s HDInsightStreamingActivity) Activity() BaseActivityImpl

type HTTPReadSettings

+ func (s HTTPReadSettings) StoreReadSettings() BaseStoreReadSettingsImpl

type HTTPSource

+ func (s HTTPSource) CopySource() BaseCopySourceImpl

type HdfsReadSettings

+ func (s HdfsReadSettings) StoreReadSettings() BaseStoreReadSettingsImpl

type HdfsSource

+ func (s HdfsSource) CopySource() BaseCopySourceImpl

type HiveSource

+ func (s HiveSource) CopySource() BaseCopySourceImpl

type HubspotSource

+ func (s HubspotSource) CopySource() BaseCopySourceImpl

type IcebergSink

+ Type string

+ func (s IcebergSink) CopySink() BaseCopySinkImpl

type IcebergWriteSettings

+ Type string

+ func (s IcebergWriteSettings) FormatWriteSettings() BaseFormatWriteSettingsImpl

type IfConditionActivity

+ Type string

+ func (s IfConditionActivity) Activity() BaseActivityImpl

type ImpalaSource

+ func (s ImpalaSource) CopySource() BaseCopySourceImpl

type ImportSettings

+ func UnmarshalImportSettingsImplementation(input []byte) (ImportSettings, error)

+ ImportSettings func() BaseImportSettingsImpl

type InformixSink

+ func (s InformixSink) CopySink() BaseCopySinkImpl

type InformixSource

+ func (s InformixSource) CopySource() BaseCopySourceImpl

type JiraSource

+ func (s JiraSource) CopySource() BaseCopySourceImpl

type JsonReadSettings

+ func (s JsonReadSettings) FormatReadSettings() BaseFormatReadSettingsImpl

type JsonSink

+ func (s JsonSink) CopySink() BaseCopySinkImpl

type JsonSource

+ func (s JsonSource) CopySource() BaseCopySourceImpl

type JsonWriteSettings

+ func (s JsonWriteSettings) FormatWriteSettings() BaseFormatWriteSettingsImpl

type LakeHouseReadSettings

+ func (s LakeHouseReadSettings) StoreReadSettings() BaseStoreReadSettingsImpl

type LakeHouseTableSink

+ func (s LakeHouseTableSink) CopySink() BaseCopySinkImpl

type LakeHouseTableSource

+ func (s LakeHouseTableSource) CopySource() BaseCopySourceImpl

type LakeHouseWriteSettings

+ func (s LakeHouseWriteSettings) StoreWriteSettings() BaseStoreWriteSettingsImpl

type LookupActivity

+ Type string

+ func (s LookupActivity) Activity() BaseActivityImpl

type MagentoSource

+ func (s MagentoSource) CopySource() BaseCopySourceImpl

type MariaDBSource

+ func (s MariaDBSource) CopySource() BaseCopySourceImpl

type MarketoSource

+ func (s MarketoSource) CopySource() BaseCopySourceImpl

type MicrosoftAccessSink

+ func (s MicrosoftAccessSink) CopySink() BaseCopySinkImpl

type MicrosoftAccessSource

+ func (s MicrosoftAccessSource) CopySource() BaseCopySourceImpl

type MongoDbAtlasSink

+ func (s MongoDbAtlasSink) CopySink() BaseCopySinkImpl

type MongoDbAtlasSource

+ func (s MongoDbAtlasSource) CopySource() BaseCopySourceImpl

type MongoDbSource

+ func (s MongoDbSource) CopySource() BaseCopySourceImpl

type MongoDbV2Sink

+ func (s MongoDbV2Sink) CopySink() BaseCopySinkImpl

type MongoDbV2Source

+ func (s MongoDbV2Source) CopySource() BaseCopySourceImpl

type MySqlSource

+ func (s MySqlSource) CopySource() BaseCopySourceImpl

type NetezzaSource

+ func (s NetezzaSource) CopySource() BaseCopySourceImpl

type ODataSource

+ func (s ODataSource) CopySource() BaseCopySourceImpl

type OdbcSink

+ func (s OdbcSink) CopySink() BaseCopySinkImpl

type OdbcSource

+ func (s OdbcSource) CopySource() BaseCopySourceImpl

type Office365Source

+ func (s Office365Source) CopySource() BaseCopySourceImpl

type OracleCloudStorageReadSettings

+ func (s OracleCloudStorageReadSettings) StoreReadSettings() BaseStoreReadSettingsImpl

type OracleServiceCloudSource

+ func (s OracleServiceCloudSource) CopySource() BaseCopySourceImpl

type OracleSink

+ func (s OracleSink) CopySink() BaseCopySinkImpl

type OracleSource

+ func (s OracleSource) CopySource() BaseCopySourceImpl

type OrcSink

+ func (s OrcSink) CopySink() BaseCopySinkImpl

type OrcSource

+ func (s OrcSource) CopySource() BaseCopySourceImpl

type OrcWriteSettings

+ func (s OrcWriteSettings) FormatWriteSettings() BaseFormatWriteSettingsImpl

type ParquetReadSettings

+ func (s ParquetReadSettings) FormatReadSettings() BaseFormatReadSettingsImpl

type ParquetSink

+ func (s ParquetSink) CopySink() BaseCopySinkImpl

type ParquetSource

+ func (s ParquetSource) CopySource() BaseCopySourceImpl

type ParquetWriteSettings

+ func (s ParquetWriteSettings) FormatWriteSettings() BaseFormatWriteSettingsImpl

type PaypalSource

+ func (s PaypalSource) CopySource() BaseCopySourceImpl

type PhoenixSource

+ func (s PhoenixSource) CopySource() BaseCopySourceImpl

type PostgreSqlSource

+ func (s PostgreSqlSource) CopySource() BaseCopySourceImpl

type PostgreSqlV2Source

+ func (s PostgreSqlV2Source) CopySource() BaseCopySourceImpl

type PrestoSource

+ func (s PrestoSource) CopySource() BaseCopySourceImpl

type QuickBooksSource

+ func (s QuickBooksSource) CopySource() BaseCopySourceImpl

type RawActivityImpl

+ func (s RawActivityImpl) Activity() BaseActivityImpl

type RawCompressionReadSettingsImpl

+ func (s RawCompressionReadSettingsImpl) CompressionReadSettings() BaseCompressionReadSettingsImpl

type RawCopySinkImpl

+ func (s RawCopySinkImpl) CopySink() BaseCopySinkImpl

type RawCopySourceImpl

+ func (s RawCopySourceImpl) CopySource() BaseCopySourceImpl

type RawCopyTranslatorImpl

+ func (s RawCopyTranslatorImpl) CopyTranslator() BaseCopyTranslatorImpl

type RawExportSettingsImpl

+ func (s RawExportSettingsImpl) ExportSettings() BaseExportSettingsImpl

type RawFormatReadSettingsImpl

+ func (s RawFormatReadSettingsImpl) FormatReadSettings() BaseFormatReadSettingsImpl

type RawFormatWriteSettingsImpl

+ func (s RawFormatWriteSettingsImpl) FormatWriteSettings() BaseFormatWriteSettingsImpl

type RawImportSettingsImpl

+ func (s RawImportSettingsImpl) ImportSettings() BaseImportSettingsImpl

type RawSecretBaseImpl

+ func (s RawSecretBaseImpl) SecretBase() BaseSecretBaseImpl

type RawStoreReadSettingsImpl

+ func (s RawStoreReadSettingsImpl) StoreReadSettings() BaseStoreReadSettingsImpl

type RawStoreWriteSettingsImpl

+ func (s RawStoreWriteSettingsImpl) StoreWriteSettings() BaseStoreWriteSettingsImpl

type RelationalSource

+ func (s RelationalSource) CopySource() BaseCopySourceImpl

type ResponsysSource

+ func (s ResponsysSource) CopySource() BaseCopySourceImpl

type RestSink

+ func (s RestSink) CopySink() BaseCopySinkImpl

type RestSource

+ func (s RestSource) CopySource() BaseCopySourceImpl

type SalesforceMarketingCloudSource

+ func (s SalesforceMarketingCloudSource) CopySource() BaseCopySourceImpl

type SalesforceServiceCloudSink

+ func (s SalesforceServiceCloudSink) CopySink() BaseCopySinkImpl

type SalesforceServiceCloudSource

+ func (s SalesforceServiceCloudSource) CopySource() BaseCopySourceImpl

type SalesforceServiceCloudV2Sink

+ func (s SalesforceServiceCloudV2Sink) CopySink() BaseCopySinkImpl

type SalesforceServiceCloudV2Source

+ func (s SalesforceServiceCloudV2Source) CopySource() BaseCopySourceImpl

type SalesforceSink

+ func (s SalesforceSink) CopySink() BaseCopySinkImpl

type SalesforceSource

+ func (s SalesforceSource) CopySource() BaseCopySourceImpl

type SalesforceV2Sink

+ func (s SalesforceV2Sink) CopySink() BaseCopySinkImpl

type SalesforceV2Source

+ func (s SalesforceV2Source) CopySource() BaseCopySourceImpl

type SapBwSource

+ func (s SapBwSource) CopySource() BaseCopySourceImpl

type SapCloudForCustomerSink

+ func (s SapCloudForCustomerSink) CopySink() BaseCopySinkImpl

type SapCloudForCustomerSource

+ func (s SapCloudForCustomerSource) CopySource() BaseCopySourceImpl

type SapEccSource

+ func (s SapEccSource) CopySource() BaseCopySourceImpl

type SapHanaSource

+ func (s SapHanaSource) CopySource() BaseCopySourceImpl

type SapOdpSource

+ func (s SapOdpSource) CopySource() BaseCopySourceImpl

type SapOpenHubSource

+ func (s SapOpenHubSource) CopySource() BaseCopySourceImpl

type SapTableSource

+ func (s SapTableSource) CopySource() BaseCopySourceImpl

type ScriptActivity

+ Type string

+ func (s ScriptActivity) Activity() BaseActivityImpl

type SecretBase

+ func UnmarshalSecretBaseImplementation(input []byte) (SecretBase, error)

+ SecretBase func() BaseSecretBaseImpl

type SecureString

+ Type string

+ func (s SecureString) SecretBase() BaseSecretBaseImpl

type ServiceNowSource

+ func (s ServiceNowSource) CopySource() BaseCopySourceImpl

type ServiceNowV2Source

+ func (s ServiceNowV2Source) CopySource() BaseCopySourceImpl

type SetVariableActivity

+ Type string

+ func (s SetVariableActivity) Activity() BaseActivityImpl

type SftpReadSettings

+ func (s SftpReadSettings) StoreReadSettings() BaseStoreReadSettingsImpl

type SftpWriteSettings

+ func (s SftpWriteSettings) StoreWriteSettings() BaseStoreWriteSettingsImpl

type SharePointOnlineListSource

+ func (s SharePointOnlineListSource) CopySource() BaseCopySourceImpl

type ShopifySource

+ func (s ShopifySource) CopySource() BaseCopySourceImpl

type SnowflakeExportCopyCommand

+ func (s SnowflakeExportCopyCommand) ExportSettings() BaseExportSettingsImpl

type SnowflakeImportCopyCommand

+ func (s SnowflakeImportCopyCommand) ImportSettings() BaseImportSettingsImpl

type SnowflakeSink

+ func (s SnowflakeSink) CopySink() BaseCopySinkImpl

type SnowflakeSource

+ func (s SnowflakeSource) CopySource() BaseCopySourceImpl

type SnowflakeV2Sink

+ func (s SnowflakeV2Sink) CopySink() BaseCopySinkImpl

type SnowflakeV2Source

+ func (s SnowflakeV2Source) CopySource() BaseCopySourceImpl

type SparkSource

+ func (s SparkSource) CopySource() BaseCopySourceImpl

type SqlDWSink

+ func (s SqlDWSink) CopySink() BaseCopySinkImpl

type SqlDWSource

+ func (s SqlDWSource) CopySource() BaseCopySourceImpl

type SqlMISink

+ func (s SqlMISink) CopySink() BaseCopySinkImpl

type SqlMISource

+ func (s SqlMISource) CopySource() BaseCopySourceImpl

type SqlServerSink

+ func (s SqlServerSink) CopySink() BaseCopySinkImpl

type SqlServerSource

+ func (s SqlServerSource) CopySource() BaseCopySourceImpl

type SqlServerStoredProcedureActivity

+ Type string

+ func (s SqlServerStoredProcedureActivity) Activity() BaseActivityImpl

type SqlSink

+ func (s SqlSink) CopySink() BaseCopySinkImpl

type SqlSource

+ func (s SqlSource) CopySource() BaseCopySourceImpl

type SquareSource

+ func (s SquareSource) CopySource() BaseCopySourceImpl

type StoreReadSettings

+ func UnmarshalStoreReadSettingsImplementation(input []byte) (StoreReadSettings, error)

+ StoreReadSettings func() BaseStoreReadSettingsImpl

type StoreWriteSettings

+ func UnmarshalStoreWriteSettingsImplementation(input []byte) (StoreWriteSettings, error)

+ StoreWriteSettings func() BaseStoreWriteSettingsImpl

type SwitchActivity

+ Type string

+ func (s SwitchActivity) Activity() BaseActivityImpl

type SybaseSource

+ func (s SybaseSource) CopySource() BaseCopySourceImpl

type SynapseNotebookActivity

+ Type string

+ func (s SynapseNotebookActivity) Activity() BaseActivityImpl

type SynapseSparkJobDefinitionActivity

+ Type string

+ func (s SynapseSparkJobDefinitionActivity) Activity() BaseActivityImpl

type TabularSource

+ func (s TabularSource) CopySource() BaseCopySourceImpl

type TabularTranslator

+ Type string

+ func (s TabularTranslator) CopyTranslator() BaseCopyTranslatorImpl

type TarGZipReadSettings

+ func (s TarGZipReadSettings) CompressionReadSettings() BaseCompressionReadSettingsImpl

type TarReadSettings

+ func (s TarReadSettings) CompressionReadSettings() BaseCompressionReadSettingsImpl

type TeradataSource

+ func (s TeradataSource) CopySource() BaseCopySourceImpl

type UntilActivity

+ Type string

+ func (s UntilActivity) Activity() BaseActivityImpl

type ValidationActivity

+ Type string

+ func (s ValidationActivity) Activity() BaseActivityImpl

type VerticaSource

+ func (s VerticaSource) CopySource() BaseCopySourceImpl

type WaitActivity

+ Type string

+ func (s WaitActivity) Activity() BaseActivityImpl

type WarehouseSink

+ func (s WarehouseSink) CopySink() BaseCopySinkImpl

type WarehouseSource

+ func (s WarehouseSource) CopySource() BaseCopySourceImpl

type WebActivity

+ Type string

+ func (s WebActivity) Activity() BaseActivityImpl

type WebHookActivity

+ Type string

+ func (s WebHookActivity) Activity() BaseActivityImpl

type WebSource

+ func (s WebSource) CopySource() BaseCopySourceImpl

type XeroSource

+ func (s XeroSource) CopySource() BaseCopySourceImpl

type XmlReadSettings

+ func (s XmlReadSettings) FormatReadSettings() BaseFormatReadSettingsImpl

type XmlSource

+ func (s XmlSource) CopySource() BaseCopySourceImpl

type ZipDeflateReadSettings

+ func (s ZipDeflateReadSettings) CompressionReadSettings() BaseCompressionReadSettingsImpl

type ZohoSource

+ func (s ZohoSource) CopySource() BaseCopySourceImpl

v0.20240920.1081703

Sep 20, 2024

v0.20240906.1232634

Sep 6, 2024

v0.20240903.1131440

Sep 3, 2024

Changes in this version

+ type IcebergSink struct

+ DisableMetricsCollection *bool

+ FormatSettings FormatWriteSettings

+ MaxConcurrentConnections *int64

+ SinkRetryCount *int64

+ SinkRetryWait *string

+ StoreSettings StoreWriteSettings

+ WriteBatchSize *int64

+ WriteBatchTimeout *string

+ func (s *IcebergSink) UnmarshalJSON(bytes []byte) error

+ func (s IcebergSink) MarshalJSON() ([]byte, error)

+ type IcebergWriteSettings struct

+ func (s IcebergWriteSettings) MarshalJSON() ([]byte, error)

v0.20240903.1111904

Sep 3, 2024

v0.20240826.1115152

Aug 26, 2024

v0.20240819.1075239

Aug 19, 2024

v0.20240815.1003113

Aug 15, 2024

v0.20240731.1212841

Jul 31, 2024

v0.20240731.1170959

Jul 31, 2024

v0.20240715.1103416

Jul 15, 2024

v0.20240715.1100358

Jul 15, 2024

v0.20240712.1173055

Jul 12, 2024

v0.20240712.1145105

Jul 12, 2024

v0.20240710.1114656

Jul 10, 2024

v0.20240710.1100952

Jul 10, 2024

v0.20240710.1075622

Jul 10, 2024

v0.20240708.1080555

Jul 8, 2024

v0.20240701.1094750

Jul 1, 2024

v0.20240701.1082110

Jul 1, 2024

v0.20240628.1153531

Jun 28, 2024

Changes in this version

+ type ListByFactoryCustomPager struct

+ NextLink *odata.Link

+ func (p *ListByFactoryCustomPager) NextPageLink() *odata.Link

v0.20240628.1082451

Jun 28, 2024

v0.20240627.1145836

Jun 27, 2024

v0.20240627.1143641

Jun 27, 2024

v0.20240627.1122744

Jun 27, 2024

v0.20240625.1131926

Jun 25, 2024

v0.20240625.1123713

Jun 25, 2024

v0.20240624.1135538

Jun 24, 2024

v0.20240624.1113120

Jun 24, 2024

v0.20240621.1183335

Jun 21, 2024

v0.20240621.1124930

Jun 21, 2024

v0.20240620.1161515

Jun 20, 2024

v0.20240617.1101532

Jun 17, 2024

v0.20240617.1095803

Jun 17, 2024

Changes in this version

type SnowflakeExportCopyCommand

+ StorageIntegration *interface{}

type SnowflakeImportCopyCommand

+ StorageIntegration *interface{}

v0.20240612.1122027

Jun 12, 2024

v0.20240612.1084144

Jun 12, 2024

v0.20240611.1112045

Jun 11, 2024

Changes in this version

+ type ContinuationSettingsReference struct

+ ContinuationTtlInMinutes *interface{}

+ CustomizedCheckpointKey *interface{}

+ IdleCondition *interface{}

type ExecuteDataFlowActivityTypeProperties

+ ContinuationSettings *ContinuationSettingsReference

type ExecutePowerQueryActivityTypeProperties

+ ContinuationSettings *ContinuationSettingsReference

v0.20240611.1085123

Jun 11, 2024

v0.20240610.1130722

Jun 10, 2024

v0.20240610.1112704

Jun 10, 2024

v0.20240606.1065251

Jun 6, 2024

v0.20240604.1114748

Jun 4, 2024

v0.20240603.1222802

Jun 3, 2024

v0.20240603.1170338

Jun 3, 2024

v0.20240603.1145333

Jun 3, 2024

v0.20240530.1123407

May 30, 2024

v0.20240529.1155048

May 29, 2024

v0.20240529.1094411

May 29, 2024

v0.20240527.1094340

May 27, 2024

v0.20240524.1090207

May 24, 2024

v0.20240524.1074426

May 24, 2024

v0.20240523.1095414

May 23, 2024

v0.20240522.1080424

May 22, 2024

v0.20240521.1173452

May 21, 2024

v0.20240521.1091020

May 21, 2024

v0.20240516.1091934

May 16, 2024

Changes in this version

type ExpressionV2

+ Operators *[]string

type ExpressionV2Type

+ const ExpressionV2TypeNAry

v0.20240516.1080701

May 16, 2024

v0.20240513.1085605

May 13, 2024

Changes in this version

type SalesforceServiceCloudV2Source

+ Query *interface{}

type SalesforceV2Source

+ Query *interface{}

v0.20240510.1003452

May 10, 2024

v0.20240507.1095453

May 7, 2024

v0.20240506.1094936

May 6, 2024

v0.20240425.1225320

Apr 25, 2024

v0.20240425.1122754

Apr 25, 2024

v0.20240424.1114424

Apr 24, 2024

v0.20240422.1195251

Apr 22, 2024

v0.20240422.1120051

Apr 22, 2024

v0.20240422.1112441

Apr 22, 2024

v0.20240419.1132837

Apr 19, 2024

v0.20240417.1084633

Apr 17, 2024

v0.20240416.1115834

Apr 16, 2024

v0.20240416.1114103

Apr 16, 2024

v0.20240412.1150433

Apr 12, 2024

v0.20240411.1145857

Apr 11, 2024

v0.20240411.1104331

Apr 11, 2024

v0.20240409.1113035

Apr 9, 2024

v0.20240408.1091446

Apr 8, 2024

v0.20240404.1145457

Apr 4, 2024

v0.20240404.1103618

Apr 4, 2024

v0.20240403.1161138

Apr 3, 2024

v0.20240403.1135041

Apr 3, 2024

v0.20240402.1085733

Apr 2, 2024

v0.20240402.1064951

Apr 2, 2024

v0.20240327.1161949

Mar 27, 2024

v0.20240327.1133120

Mar 27, 2024

v0.20240327.1093302

Mar 27, 2024

v0.20240327.1081628

Mar 27, 2024

Changes in this version

type AmazonMWSSource

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

type AmazonRdsForOracleSource

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

type AmazonRdsForSqlServerSource

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

type AmazonRedshiftSource

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

type AmazonS3CompatibleReadSettings

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

type AmazonS3ReadSettings

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

type AvroSink

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

type AvroSource

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

type AvroWriteSettings

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

type AzureBlobFSReadSettings

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

type AzureBlobFSSink

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

type AzureBlobFSSource

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

type AzureBlobFSWriteSettings

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

type AzureBlobStorageReadSettings

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

type AzureBlobStorageWriteSettings

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

type AzureDataExplorerSink

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

type AzureDataExplorerSource

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

type AzureDataLakeStoreReadSettings

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

type AzureDataLakeStoreSink

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

type AzureDataLakeStoreSource

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

type AzureDataLakeStoreWriteSettings

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

type AzureDatabricksDeltaLakeExportCommand

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

type AzureDatabricksDeltaLakeImportCommand

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

type AzureDatabricksDeltaLakeSink

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

type AzureDatabricksDeltaLakeSource

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

type AzureFileStorageReadSettings

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

type AzureFileStorageWriteSettings

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

type AzureMariaDBSource

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

type AzureMySqlSink

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

type AzureMySqlSource

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

type AzurePostgreSqlSink

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

type AzurePostgreSqlSource

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

type AzureQueueSink

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

type AzureSearchIndexSink

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

type AzureSqlSink

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

type AzureSqlSource

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

type AzureTableSink

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

type AzureTableSource

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

type BinaryReadSettings

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

type BinarySink

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

type BinarySource

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

type BlobSink

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

type BlobSource

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

type CassandraSource

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

type CommonDataServiceForAppsSink

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

type CommonDataServiceForAppsSource

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

type ConcurSource

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

+ type CopyTranslator interface

type CosmosDbMongoDbApiSink

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

type CosmosDbMongoDbApiSource

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

type CosmosDbSqlApiSink

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

type CosmosDbSqlApiSource

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

type CouchbaseSource

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

+ type DataFlowSink struct

+ Dataset *DatasetReference

+ Description *string

+ Flowlet *DataFlowReference

+ LinkedService *LinkedServiceReference

+ Name string

+ RejectedDataLinkedService *LinkedServiceReference

+ SchemaLinkedService *LinkedServiceReference

type Db2Source

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

type DelimitedTextReadSettings

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

type DelimitedTextSink

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

type DelimitedTextSource

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

type DelimitedTextWriteSettings

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

type DocumentDbCollectionSink

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

type DocumentDbCollectionSource

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

type DrillSource

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

type DynamicsAXSource

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

type DynamicsCrmSink

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

type DynamicsCrmSource

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

type DynamicsSink

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

type DynamicsSource

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

type EloquaSource

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

type ExcelSource

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

+ type ExportSettings interface

type FileServerReadSettings

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

type FileServerWriteSettings

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

type FileSystemSink

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

type FileSystemSource

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

+ type FormatWriteSettings interface

type FtpReadSettings

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

type GoogleAdWordsSource

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

type GoogleBigQuerySource

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

type GoogleBigQueryV2Source

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

type GoogleCloudStorageReadSettings

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

type GreenplumSource

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

type HBaseSource

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

type HTTPReadSettings

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

type HTTPSource

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

type HdfsReadSettings

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

type HdfsSource

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

type HiveSource

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

type HubspotSource

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

type ImpalaSource

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

+ type ImportSettings interface

type InformixSink

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

type InformixSource

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

type JiraSource

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

type JsonReadSettings

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

type JsonSink

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

type JsonSource

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

type JsonWriteSettings

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

type LakeHouseReadSettings

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

type LakeHouseTableSink

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

type LakeHouseTableSource

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

type LakeHouseWriteSettings

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

type MagentoSource

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

type MariaDBSource

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

type MarketoSource

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

type MicrosoftAccessSink

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

type MicrosoftAccessSource

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

type MongoDbAtlasSink

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

type MongoDbAtlasSource

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

type MongoDbSource

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

type MongoDbV2Sink

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

type MongoDbV2Source

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

type MySqlSource

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

type NetezzaSource

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

type ODataSource

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

type OdbcSink

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

type OdbcSource

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

type Office365Source

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

type OracleCloudStorageReadSettings

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

type OracleServiceCloudSource

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

type OracleSink

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

type OracleSource

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

type OrcSink

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

type OrcSource

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

type OrcWriteSettings

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

type ParquetReadSettings

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

type ParquetSink

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

type ParquetSource

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

type ParquetWriteSettings

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

type PaypalSource

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

type PhoenixSource

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

type PostgreSqlSource

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

type PostgreSqlV2Source

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

type PrestoSource

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

type QuickBooksSource

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

+ type RawCopyTranslatorImpl struct

+ Type string

+ Values map[string]interface{}

+ type RawExportSettingsImpl struct

+ Type string

+ Values map[string]interface{}

+ type RawFormatWriteSettingsImpl struct

+ Type string

+ Values map[string]interface{}

+ type RawImportSettingsImpl struct

+ Type string

+ Values map[string]interface{}

type RelationalSource

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

type ResponsysSource

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

type RestSink

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

type RestSource

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

type SalesforceMarketingCloudSource

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

type SalesforceServiceCloudSink

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

type SalesforceServiceCloudSource

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

type SalesforceServiceCloudV2Sink

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

type SalesforceServiceCloudV2Source

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

type SalesforceSink

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

type SalesforceSource

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

type SalesforceV2Sink

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

type SalesforceV2Source

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

type SapBwSource

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

type SapCloudForCustomerSink

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

type SapCloudForCustomerSource

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

type SapEccSource

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

type SapHanaSource

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

type SapOdpSource

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

type SapOpenHubSource

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

type SapTableSource

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

type ServiceNowSource

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

type ServiceNowV2Source

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

type SftpReadSettings

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

type SftpWriteSettings

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

type SharePointOnlineListSource

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

type ShopifySource

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

type SnowflakeExportCopyCommand

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

type SnowflakeImportCopyCommand

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

type SnowflakeSink

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

type SnowflakeSource

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

type SnowflakeV2Sink

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

type SnowflakeV2Source

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

type SparkSource

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

type SqlDWSink

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

type SqlDWSource

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

type SqlMISink

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

type SqlMISource

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

type SqlServerSink

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

type SqlServerSource

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

type SqlSink

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

type SqlSource

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

type SquareSource

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

type SybaseSource

+ func (s SybaseSource) MarshalJSON() ([]byte, error)

type TabularSource

+ func (s TabularSource) MarshalJSON() ([]byte, error)

+ type TabularTranslator struct

+ CollectionReference *interface{}

+ ColumnMappings *interface{}

+ MapComplexValuesToString *interface{}

+ Mappings *interface{}

+ SchemaMapping *interface{}

+ TypeConversion *interface{}

+ TypeConversionSettings *TypeConversionSettings

+ func (s TabularTranslator) MarshalJSON() ([]byte, error)

type TarGZipReadSettings

+ func (s TarGZipReadSettings) MarshalJSON() ([]byte, error)

type TarReadSettings

+ func (s TarReadSettings) MarshalJSON() ([]byte, error)

type TeradataSource

+ func (s TeradataSource) MarshalJSON() ([]byte, error)

+ type TypeConversionSettings struct

+ AllowDataTruncation *interface{}

+ Culture *interface{}

+ DateTimeFormat *interface{}

+ DateTimeOffsetFormat *interface{}

+ TimeSpanFormat *interface{}

+ TreatBooleanAsNumber *interface{}

type VerticaSource

+ func (s VerticaSource) MarshalJSON() ([]byte, error)

type WarehouseSink

+ func (s WarehouseSink) MarshalJSON() ([]byte, error)

type WarehouseSource

+ func (s WarehouseSource) MarshalJSON() ([]byte, error)

type WebSource

+ func (s WebSource) MarshalJSON() ([]byte, error)

type XeroSource

+ func (s XeroSource) MarshalJSON() ([]byte, error)

type XmlReadSettings

+ func (s XmlReadSettings) MarshalJSON() ([]byte, error)

type XmlSource

+ func (s XmlSource) MarshalJSON() ([]byte, error)

type ZipDeflateReadSettings

+ func (s ZipDeflateReadSettings) MarshalJSON() ([]byte, error)

type ZohoSource

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

v0.20240327.1073535

Mar 27, 2024

v0.20240326.1143657

Mar 26, 2024

v0.20240326.1130143

Mar 26, 2024

v0.20240326.1110218

Mar 26, 2024

v0.20240325.1135512

Mar 25, 2024

v0.20240325.1113504

Mar 25, 2024

v0.20240322.1155759

Mar 22, 2024

v0.20240321.1145953

Mar 21, 2024

v0.20240321.1111417

Mar 21, 2024

v0.20240320.1144505

Mar 20, 2024

v0.20240320.1143605

Mar 20, 2024

Changes in this version

+ func PossibleValuesForAzureFunctionActivityMethod() []string

+ func PossibleValuesForAzureSearchIndexWriteBehaviorType() []string

+ func PossibleValuesForBigDataPoolReferenceType() []string

+ func PossibleValuesForCassandraSourceReadConsistencyLevels() []string

+ func PossibleValuesForConfigurationType() []string

+ func PossibleValuesForCredentialReferenceType() []string

+ func PossibleValuesForDataFlowReferenceType() []string

+ func PossibleValuesForDatasetReferenceType() []string

+ func PossibleValuesForDynamicsSinkWriteBehavior() []string

+ func PossibleValuesForExpressionType() []string

+ func PossibleValuesForExpressionV2Type() []string

+ func PossibleValuesForHDInsightActivityDebugInfoOption() []string

+ func PossibleValuesForIntegrationRuntimeReferenceType() []string

+ func PossibleValuesForNotebookParameterType() []string

+ func PossibleValuesForNotebookReferenceType() []string

+ func PossibleValuesForPipelineReferenceType() []string

+ func PossibleValuesForPolybaseSettingsRejectType() []string

+ func PossibleValuesForSalesforceSinkWriteBehavior() []string

+ func PossibleValuesForSalesforceV2SinkWriteBehavior() []string

+ func PossibleValuesForSapCloudForCustomerSinkWriteBehavior() []string

+ func PossibleValuesForScriptActivityLogDestination() []string

+ func PossibleValuesForScriptActivityParameterDirection() []string

+ func PossibleValuesForScriptActivityParameterType() []string

+ func PossibleValuesForScriptType() []string

+ func PossibleValuesForSparkConfigurationReferenceType() []string

+ func PossibleValuesForSparkJobReferenceType() []string

+ func PossibleValuesForSsisLogLocationType() []string

+ func PossibleValuesForSsisPackageLocationType() []string

+ func PossibleValuesForType() []string

+ func PossibleValuesForWebActivityMethod() []string

+ func PossibleValuesForWebHookActivityMethod() []string

+ type ActivityPolicy struct

+ Retry *interface{}

+ RetryIntervalInSeconds *int64

+ SecureInput *bool

+ SecureOutput *bool

+ Timeout *interface{}

+ type AmazonMWSSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type AmazonRdsForOraclePartitionSettings struct

+ PartitionColumnName *interface{}

+ PartitionLowerBound *interface{}

+ PartitionNames *interface{}

+ PartitionUpperBound *interface{}

+ type AmazonRdsForOracleSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ OracleReaderQuery *interface{}

+ PartitionOption *interface{}

+ PartitionSettings *AmazonRdsForOraclePartitionSettings

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type AmazonRdsForSqlServerSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ IsolationLevel *interface{}

+ MaxConcurrentConnections *interface{}

+ PartitionOption *interface{}

+ PartitionSettings *SqlPartitionSettings

+ ProduceAdditionalTypes *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ SqlReaderQuery *interface{}

+ SqlReaderStoredProcedureName *interface{}

+ StoredProcedureParameters *interface{}

+ Type string

+ type AmazonRedshiftSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ RedshiftUnloadSettings *RedshiftUnloadSettings

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type AmazonS3CompatibleReadSettings struct

+ DeleteFilesAfterCompletion *interface{}

+ DisableMetricsCollection *interface{}

+ EnablePartitionDiscovery *interface{}

+ FileListPath *interface{}

+ MaxConcurrentConnections *interface{}

+ ModifiedDatetimeEnd *interface{}

+ ModifiedDatetimeStart *interface{}

+ PartitionRootPath *interface{}

+ Prefix *interface{}

+ Recursive *interface{}

+ Type string

+ WildcardFileName *interface{}

+ WildcardFolderPath *interface{}

+ type AmazonS3ReadSettings struct

+ DeleteFilesAfterCompletion *interface{}

+ DisableMetricsCollection *interface{}

+ EnablePartitionDiscovery *interface{}

+ FileListPath *interface{}

+ MaxConcurrentConnections *interface{}

+ ModifiedDatetimeEnd *interface{}

+ ModifiedDatetimeStart *interface{}

+ PartitionRootPath *interface{}

+ Prefix *interface{}

+ Recursive *interface{}

+ Type string

+ WildcardFileName *interface{}

+ WildcardFolderPath *interface{}

+ type AppendVariableActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ State *ActivityState

+ TypeProperties AppendVariableActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type AppendVariableActivityTypeProperties struct

+ Value *interface{}

+ VariableName *string

+ type AvroSink struct

+ DisableMetricsCollection *interface{}

+ FormatSettings *AvroWriteSettings

+ MaxConcurrentConnections *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ StoreSettings StoreWriteSettings

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

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

+ type AvroSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ StoreSettings StoreReadSettings

+ Type string

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

+ type AvroWriteSettings struct

+ FileNamePrefix *interface{}

+ MaxRowsPerFile *interface{}

+ RecordName *string

+ RecordNamespace *string

+ Type string

+ type AzureBlobFSReadSettings struct

+ DeleteFilesAfterCompletion *interface{}

+ DisableMetricsCollection *interface{}

+ EnablePartitionDiscovery *interface{}

+ FileListPath *interface{}

+ MaxConcurrentConnections *interface{}

+ ModifiedDatetimeEnd *interface{}

+ ModifiedDatetimeStart *interface{}

+ PartitionRootPath *interface{}

+ Recursive *interface{}

+ Type string

+ WildcardFileName *interface{}

+ WildcardFolderPath *interface{}

+ type AzureBlobFSSink struct

+ CopyBehavior *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Metadata *[]MetadataItem

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ type AzureBlobFSSource struct

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Recursive *interface{}

+ SkipHeaderLineCount *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ TreatEmptyAsNull *interface{}

+ Type string

+ type AzureBlobFSWriteSettings struct

+ BlockSizeInMB *interface{}

+ CopyBehavior *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Metadata *[]MetadataItem

+ Type string

+ type AzureBlobStorageReadSettings struct

+ DeleteFilesAfterCompletion *interface{}

+ DisableMetricsCollection *interface{}

+ EnablePartitionDiscovery *interface{}

+ FileListPath *interface{}

+ MaxConcurrentConnections *interface{}

+ ModifiedDatetimeEnd *interface{}

+ ModifiedDatetimeStart *interface{}

+ PartitionRootPath *interface{}

+ Prefix *interface{}

+ Recursive *interface{}

+ Type string

+ WildcardFileName *interface{}

+ WildcardFolderPath *interface{}

+ type AzureBlobStorageWriteSettings struct

+ BlockSizeInMB *interface{}

+ CopyBehavior *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Metadata *[]MetadataItem

+ Type string

+ type AzureDataExplorerCommandActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ LinkedServiceName *LinkedServiceReference

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ Policy *ActivityPolicy

+ State *ActivityState

+ TypeProperties AzureDataExplorerCommandActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type AzureDataExplorerCommandActivityTypeProperties struct

+ Command interface{}

+ CommandTimeout *interface{}

+ type AzureDataExplorerSink struct

+ DisableMetricsCollection *interface{}

+ FlushImmediately *interface{}

+ IngestionMappingAsJson *interface{}

+ IngestionMappingName *interface{}

+ MaxConcurrentConnections *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ type AzureDataExplorerSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ NoTruncation *interface{}

+ Query interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type AzureDataLakeStoreReadSettings struct

+ DeleteFilesAfterCompletion *interface{}

+ DisableMetricsCollection *interface{}

+ EnablePartitionDiscovery *interface{}

+ FileListPath *interface{}

+ ListAfter *interface{}

+ ListBefore *interface{}

+ MaxConcurrentConnections *interface{}

+ ModifiedDatetimeEnd *interface{}

+ ModifiedDatetimeStart *interface{}

+ PartitionRootPath *interface{}

+ Recursive *interface{}

+ Type string

+ WildcardFileName *interface{}

+ WildcardFolderPath *interface{}

+ type AzureDataLakeStoreSink struct

+ CopyBehavior *interface{}

+ DisableMetricsCollection *interface{}

+ EnableAdlsSingleFileParallel *interface{}

+ MaxConcurrentConnections *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ type AzureDataLakeStoreSource struct

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Recursive *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type AzureDataLakeStoreWriteSettings struct

+ CopyBehavior *interface{}

+ DisableMetricsCollection *interface{}

+ ExpiryDateTime *interface{}

+ MaxConcurrentConnections *interface{}

+ Metadata *[]MetadataItem

+ Type string

+ type AzureDatabricksDeltaLakeExportCommand struct

+ DateFormat *interface{}

+ TimestampFormat *interface{}

+ Type string

+ type AzureDatabricksDeltaLakeImportCommand struct

+ DateFormat *interface{}

+ TimestampFormat *interface{}

+ Type string

+ type AzureDatabricksDeltaLakeSink struct

+ DisableMetricsCollection *interface{}

+ ImportSettings *AzureDatabricksDeltaLakeImportCommand

+ MaxConcurrentConnections *interface{}

+ PreCopyScript *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ type AzureDatabricksDeltaLakeSource struct

+ DisableMetricsCollection *interface{}

+ ExportSettings *AzureDatabricksDeltaLakeExportCommand

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type AzureFileStorageReadSettings struct

+ DeleteFilesAfterCompletion *interface{}

+ DisableMetricsCollection *interface{}

+ EnablePartitionDiscovery *interface{}

+ FileListPath *interface{}

+ MaxConcurrentConnections *interface{}

+ ModifiedDatetimeEnd *interface{}

+ ModifiedDatetimeStart *interface{}

+ PartitionRootPath *interface{}

+ Prefix *interface{}

+ Recursive *interface{}

+ Type string

+ WildcardFileName *interface{}

+ WildcardFolderPath *interface{}

+ type AzureFileStorageWriteSettings struct

+ CopyBehavior *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Metadata *[]MetadataItem

+ Type string

+ type AzureFunctionActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ LinkedServiceName *LinkedServiceReference

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ Policy *ActivityPolicy

+ State *ActivityState

+ TypeProperties AzureFunctionActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type AzureFunctionActivityMethod string

+ const AzureFunctionActivityMethodDELETE

+ const AzureFunctionActivityMethodGET

+ const AzureFunctionActivityMethodHEAD

+ const AzureFunctionActivityMethodOPTIONS

+ const AzureFunctionActivityMethodPOST

+ const AzureFunctionActivityMethodPUT

+ const AzureFunctionActivityMethodTRACE

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

+ type AzureFunctionActivityTypeProperties struct

+ Body *interface{}

+ FunctionName interface{}

+ Headers *map[string]interface{}

+ Method AzureFunctionActivityMethod

+ type AzureMLBatchExecutionActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ LinkedServiceName *LinkedServiceReference

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ Policy *ActivityPolicy

+ State *ActivityState

+ TypeProperties AzureMLBatchExecutionActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type AzureMLBatchExecutionActivityTypeProperties struct

+ GlobalParameters *map[string]interface{}

+ WebServiceInputs *map[string]AzureMLWebServiceFile

+ WebServiceOutputs *map[string]AzureMLWebServiceFile

+ type AzureMLExecutePipelineActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ LinkedServiceName *LinkedServiceReference

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ Policy *ActivityPolicy

+ State *ActivityState

+ TypeProperties AzureMLExecutePipelineActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type AzureMLExecutePipelineActivityTypeProperties struct

+ ContinueOnStepFailure *interface{}

+ DataPathAssignments *interface{}

+ ExperimentName *interface{}

+ MlParentRunId *interface{}

+ MlPipelineEndpointId *interface{}

+ MlPipelineId *interface{}

+ MlPipelineParameters *interface{}

+ Version *interface{}

+ type AzureMLUpdateResourceActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ LinkedServiceName *LinkedServiceReference

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ Policy *ActivityPolicy

+ State *ActivityState

+ TypeProperties AzureMLUpdateResourceActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type AzureMLUpdateResourceActivityTypeProperties struct

+ TrainedModelFilePath interface{}

+ TrainedModelLinkedServiceName LinkedServiceReference

+ TrainedModelName interface{}

+ type AzureMLWebServiceFile struct

+ FilePath interface{}

+ LinkedServiceName LinkedServiceReference

+ type AzureMariaDBSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type AzureMySqlSink struct

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ PreCopyScript *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ type AzureMySqlSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type AzurePostgreSqlSink struct

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ PreCopyScript *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ type AzurePostgreSqlSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type AzureQueueSink struct

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ type AzureSearchIndexSink struct

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ WriteBehavior *AzureSearchIndexWriteBehaviorType

+ type AzureSearchIndexWriteBehaviorType string

+ const AzureSearchIndexWriteBehaviorTypeMerge

+ const AzureSearchIndexWriteBehaviorTypeUpload

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

+ type AzureSqlSink struct

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ PreCopyScript *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ SqlWriterStoredProcedureName *interface{}

+ SqlWriterTableType *interface{}

+ SqlWriterUseTableLock *interface{}

+ StoredProcedureParameters *interface{}

+ StoredProcedureTableTypeParameterName *interface{}

+ TableOption *interface{}

+ Type string

+ UpsertSettings *SqlUpsertSettings

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ WriteBehavior *interface{}

+ type AzureSqlSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ IsolationLevel *interface{}

+ MaxConcurrentConnections *interface{}

+ PartitionOption *interface{}

+ PartitionSettings *SqlPartitionSettings

+ ProduceAdditionalTypes *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ SqlReaderQuery *interface{}

+ SqlReaderStoredProcedureName *interface{}

+ StoredProcedureParameters *interface{}

+ Type string

+ type AzureTableSink struct

+ AzureTableDefaultPartitionKeyValue *interface{}

+ AzureTableInsertType *interface{}

+ AzureTablePartitionKeyName *interface{}

+ AzureTableRowKeyName *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ type AzureTableSource struct

+ AdditionalColumns *interface{}

+ AzureTableSourceIgnoreTableNotFound *interface{}

+ AzureTableSourceQuery *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type BigDataPoolParametrizationReference struct

+ ReferenceName interface{}

+ Type BigDataPoolReferenceType

+ type BigDataPoolReferenceType string

+ const BigDataPoolReferenceTypeBigDataPoolReference

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

+ type BinaryReadSettings struct

+ CompressionProperties CompressionReadSettings

+ Type string

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

+ type BinarySink struct

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ StoreSettings StoreWriteSettings

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

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

+ type BinarySource struct

+ DisableMetricsCollection *interface{}

+ FormatSettings *BinaryReadSettings

+ MaxConcurrentConnections *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ StoreSettings StoreReadSettings

+ Type string

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

+ type BlobSink struct

+ BlobWriterAddHeader *interface{}

+ BlobWriterDateTimeFormat *interface{}

+ BlobWriterOverwriteFiles *interface{}

+ CopyBehavior *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Metadata *[]MetadataItem

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ type BlobSource struct

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Recursive *interface{}

+ SkipHeaderLineCount *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ TreatEmptyAsNull *interface{}

+ Type string

+ type CassandraSource struct

+ AdditionalColumns *interface{}

+ ConsistencyLevel *CassandraSourceReadConsistencyLevels

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type CassandraSourceReadConsistencyLevels string

+ const CassandraSourceReadConsistencyLevelsALL

+ const CassandraSourceReadConsistencyLevelsEACHQUORUM

+ const CassandraSourceReadConsistencyLevelsLOCALONE

+ const CassandraSourceReadConsistencyLevelsLOCALQUORUM

+ const CassandraSourceReadConsistencyLevelsLOCALSERIAL

+ const CassandraSourceReadConsistencyLevelsONE

+ const CassandraSourceReadConsistencyLevelsQUORUM

+ const CassandraSourceReadConsistencyLevelsSERIAL

+ const CassandraSourceReadConsistencyLevelsTHREE

+ const CassandraSourceReadConsistencyLevelsTWO

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

+ type CommonDataServiceForAppsSink struct

+ AlternateKeyName *interface{}

+ DisableMetricsCollection *interface{}

+ IgnoreNullValues *interface{}

+ MaxConcurrentConnections *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ WriteBehavior DynamicsSinkWriteBehavior

+ type CommonDataServiceForAppsSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type CompressionReadSettings interface

+ type ConcurSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type ConfigurationType string

+ const ConfigurationTypeArtifact

+ const ConfigurationTypeCustomized

+ const ConfigurationTypeDefault

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

+ type ControlActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ State *ActivityState

+ UserProperties *[]UserProperty

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

+ type CopyActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ Inputs *[]DatasetReference

+ LinkedServiceName *LinkedServiceReference

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ Outputs *[]DatasetReference

+ Policy *ActivityPolicy

+ State *ActivityState

+ TypeProperties CopyActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type CopyActivityLogSettings struct

+ EnableReliableLogging *interface{}

+ LogLevel *interface{}

+ type CopyActivityTypeProperties struct

+ DataIntegrationUnits *interface{}

+ EnableSkipIncompatibleRow *interface{}

+ EnableStaging *interface{}

+ LogSettings *LogSettings

+ LogStorageSettings *LogStorageSettings

+ ParallelCopies *interface{}

+ Preserve *[]interface{}

+ PreserveRules *[]interface{}

+ RedirectIncompatibleRowSettings *RedirectIncompatibleRowSettings

+ Sink CopySink

+ SkipErrorFile *SkipErrorFile

+ Source CopySource

+ StagingSettings *StagingSettings

+ Translator *interface{}

+ ValidateDataConsistency *interface{}

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

+ type CopySink interface

+ type CopySource interface

+ type CosmosDbMongoDbApiSink struct

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ WriteBehavior *interface{}

+ type CosmosDbMongoDbApiSource struct

+ AdditionalColumns *interface{}

+ BatchSize *interface{}

+ CursorMethods *MongoDbCursorMethodsProperties

+ DisableMetricsCollection *interface{}

+ Filter *interface{}

+ MaxConcurrentConnections *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type CosmosDbSqlApiSink struct

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ WriteBehavior *interface{}

+ type CosmosDbSqlApiSource struct

+ AdditionalColumns *interface{}

+ DetectDatetime *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ PageSize *interface{}

+ PreferredRegions *interface{}

+ Query *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type CouchbaseSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type CredentialReference struct

+ ReferenceName string

+ Type CredentialReferenceType

+ type CredentialReferenceType string

+ const CredentialReferenceTypeCredentialReference

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

+ type CustomActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ LinkedServiceName *LinkedServiceReference

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ Policy *ActivityPolicy

+ State *ActivityState

+ TypeProperties CustomActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type CustomActivityReferenceObject struct

+ Datasets *[]DatasetReference

+ LinkedServices *[]LinkedServiceReference

+ type CustomActivityTypeProperties struct

+ AutoUserSpecification *interface{}

+ Command interface{}

+ ExtendedProperties *map[string]interface{}

+ FolderPath *interface{}

+ ReferenceObjects *CustomActivityReferenceObject

+ ResourceLinkedService *LinkedServiceReference

+ RetentionTimeInDays *interface{}

+ type DWCopyCommandDefaultValue struct

+ ColumnName *interface{}

+ DefaultValue *interface{}

+ type DWCopyCommandSettings struct

+ AdditionalOptions *map[string]string

+ DefaultValues *[]DWCopyCommandDefaultValue

+ type DataFlowReference struct

+ DatasetParameters *interface{}

+ Parameters *map[string]interface{}

+ ReferenceName string

+ Type DataFlowReferenceType

+ type DataFlowReferenceType string

+ const DataFlowReferenceTypeDataFlowReference

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

+ type DataFlowStagingInfo struct

+ FolderPath *interface{}

+ LinkedService *LinkedServiceReference

+ type DataLakeAnalyticsUSQLActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ LinkedServiceName *LinkedServiceReference

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ Policy *ActivityPolicy

+ State *ActivityState

+ TypeProperties DataLakeAnalyticsUSQLActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type DataLakeAnalyticsUSQLActivityTypeProperties struct

+ CompilationMode *interface{}

+ DegreeOfParallelism *interface{}

+ Parameters *map[string]interface{}

+ Priority *interface{}

+ RuntimeVersion *interface{}

+ ScriptLinkedService LinkedServiceReference

+ ScriptPath interface{}

+ type DatabricksNotebookActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ LinkedServiceName *LinkedServiceReference

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ Policy *ActivityPolicy

+ State *ActivityState

+ TypeProperties DatabricksNotebookActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type DatabricksNotebookActivityTypeProperties struct

+ BaseParameters *map[string]interface{}

+ Libraries *[]map[string]interface{}

+ NotebookPath interface{}

+ type DatabricksSparkJarActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ LinkedServiceName *LinkedServiceReference

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ Policy *ActivityPolicy

+ State *ActivityState

+ TypeProperties DatabricksSparkJarActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type DatabricksSparkJarActivityTypeProperties struct

+ Libraries *[]map[string]interface{}

+ MainClassName interface{}

+ Parameters *[]interface{}

+ type DatabricksSparkPythonActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ LinkedServiceName *LinkedServiceReference

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ Policy *ActivityPolicy

+ State *ActivityState

+ TypeProperties DatabricksSparkPythonActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type DatabricksSparkPythonActivityTypeProperties struct

+ Libraries *[]map[string]interface{}

+ Parameters *[]interface{}

+ PythonFile interface{}

+ type DatasetReference struct

+ Parameters *map[string]interface{}

+ ReferenceName string

+ Type DatasetReferenceType

+ type DatasetReferenceType string

+ const DatasetReferenceTypeDatasetReference

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

+ type Db2Source struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type DeleteActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ LinkedServiceName *LinkedServiceReference

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ Policy *ActivityPolicy

+ State *ActivityState

+ TypeProperties DeleteActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type DeleteActivityTypeProperties struct

+ Dataset DatasetReference

+ EnableLogging *interface{}

+ LogStorageSettings *LogStorageSettings

+ MaxConcurrentConnections *int64

+ Recursive *interface{}

+ StoreSettings StoreReadSettings

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

+ type DelimitedTextReadSettings struct

+ CompressionProperties CompressionReadSettings

+ SkipLineCount *interface{}

+ Type string

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

+ type DelimitedTextSink struct

+ DisableMetricsCollection *interface{}

+ FormatSettings *DelimitedTextWriteSettings

+ MaxConcurrentConnections *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ StoreSettings StoreWriteSettings

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

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

+ type DelimitedTextSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ FormatSettings *DelimitedTextReadSettings

+ MaxConcurrentConnections *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ StoreSettings StoreReadSettings

+ Type string

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

+ type DelimitedTextWriteSettings struct

+ FileExtension interface{}

+ FileNamePrefix *interface{}

+ MaxRowsPerFile *interface{}

+ QuoteAllText *interface{}

+ Type string

+ type DistcpSettings struct

+ DistcpOptions *interface{}

+ ResourceManagerEndpoint interface{}

+ TempScriptPath interface{}

+ type DocumentDbCollectionSink struct

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ NestingSeparator *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ WriteBehavior *interface{}

+ type DocumentDbCollectionSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ NestingSeparator *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type DrillSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type DynamicsAXSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ HTTPRequestTimeout *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type DynamicsCrmSink struct

+ AlternateKeyName *interface{}

+ DisableMetricsCollection *interface{}

+ IgnoreNullValues *interface{}

+ MaxConcurrentConnections *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ WriteBehavior DynamicsSinkWriteBehavior

+ type DynamicsCrmSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type DynamicsSink struct

+ AlternateKeyName *interface{}

+ DisableMetricsCollection *interface{}

+ IgnoreNullValues *interface{}

+ MaxConcurrentConnections *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ WriteBehavior DynamicsSinkWriteBehavior

+ type DynamicsSinkWriteBehavior string

+ const DynamicsSinkWriteBehaviorUpsert

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

+ type DynamicsSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type EloquaSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type ExcelSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ StoreSettings StoreReadSettings

+ Type string

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

+ type ExecuteDataFlowActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ LinkedServiceName *LinkedServiceReference

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ Policy *ActivityPolicy

+ State *ActivityState

+ TypeProperties ExecuteDataFlowActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type ExecuteDataFlowActivityTypeProperties struct

+ Compute *ExecuteDataFlowActivityTypePropertiesCompute

+ ContinueOnError *interface{}

+ DataFlow DataFlowReference

+ IntegrationRuntime *IntegrationRuntimeReference

+ RunConcurrently *interface{}

+ SourceStagingConcurrency *interface{}

+ Staging *DataFlowStagingInfo

+ TraceLevel *interface{}

+ type ExecuteDataFlowActivityTypePropertiesCompute struct

+ ComputeType *interface{}

+ CoreCount *interface{}

+ type ExecutePipelineActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ Policy *ExecutePipelineActivityPolicy

+ State *ActivityState

+ TypeProperties ExecutePipelineActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type ExecutePipelineActivityPolicy struct

+ SecureInput *bool

+ type ExecutePipelineActivityTypeProperties struct

+ Parameters *map[string]interface{}

+ Pipeline PipelineReference

+ WaitOnCompletion *bool

+ type ExecutePowerQueryActivityTypeProperties struct

+ Compute *ExecuteDataFlowActivityTypePropertiesCompute

+ ContinueOnError *interface{}

+ DataFlow DataFlowReference

+ IntegrationRuntime *IntegrationRuntimeReference

+ Queries *[]PowerQuerySinkMapping

+ RunConcurrently *interface{}

+ Sinks *map[string]PowerQuerySink

+ SourceStagingConcurrency *interface{}

+ Staging *DataFlowStagingInfo

+ TraceLevel *interface{}

+ type ExecuteSSISPackageActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ LinkedServiceName *LinkedServiceReference

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ Policy *ActivityPolicy

+ State *ActivityState

+ TypeProperties ExecuteSSISPackageActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type ExecuteSSISPackageActivityTypeProperties struct

+ ConnectVia IntegrationRuntimeReference

+ EnvironmentPath *interface{}

+ ExecutionCredential *SSISExecutionCredential

+ LogLocation *SSISLogLocation

+ LoggingLevel *interface{}

+ PackageConnectionManagers *map[string]map[string]SSISExecutionParameter

+ PackageLocation SSISPackageLocation

+ PackageParameters *map[string]SSISExecutionParameter

+ ProjectConnectionManagers *map[string]map[string]SSISExecutionParameter

+ ProjectParameters *map[string]SSISExecutionParameter

+ PropertyOverrides *map[string]SSISPropertyOverride

+ Runtime *interface{}

+ type ExecuteWranglingDataflowActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ Policy *ActivityPolicy

+ State *ActivityState

+ TypeProperties ExecutePowerQueryActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type ExecutionActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ LinkedServiceName *LinkedServiceReference

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ Policy *ActivityPolicy

+ State *ActivityState

+ UserProperties *[]UserProperty

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

+ type Expression struct

+ Type ExpressionType

+ Value string

+ type ExpressionType string

+ const ExpressionTypeExpression

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

+ type ExpressionV2 struct

+ Operands *[]ExpressionV2

+ Operator *string

+ Type *ExpressionV2Type

+ Value *string

+ type ExpressionV2Type string

+ const ExpressionV2TypeBinary

+ const ExpressionV2TypeConstant

+ const ExpressionV2TypeField

+ const ExpressionV2TypeUnary

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

+ type FailActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ State *ActivityState

+ TypeProperties FailActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type FailActivityTypeProperties struct

+ ErrorCode interface{}

+ Message interface{}

+ type FileServerReadSettings struct

+ DeleteFilesAfterCompletion *interface{}

+ DisableMetricsCollection *interface{}

+ EnablePartitionDiscovery *interface{}

+ FileFilter *interface{}

+ FileListPath *interface{}

+ MaxConcurrentConnections *interface{}

+ ModifiedDatetimeEnd *interface{}

+ ModifiedDatetimeStart *interface{}

+ PartitionRootPath *interface{}

+ Recursive *interface{}

+ Type string

+ WildcardFileName *interface{}

+ WildcardFolderPath *interface{}

+ type FileServerWriteSettings struct

+ CopyBehavior *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Metadata *[]MetadataItem

+ Type string

+ type FileSystemSink struct

+ CopyBehavior *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ type FileSystemSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Recursive *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type FilterActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ State *ActivityState

+ TypeProperties FilterActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type FilterActivityTypeProperties struct

+ Condition Expression

+ Items Expression

+ type ForEachActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ State *ActivityState

+ TypeProperties ForEachActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type ForEachActivityTypeProperties struct

+ Activities []Activity

+ BatchCount *int64

+ IsSequential *bool

+ Items Expression

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

+ type FormatReadSettings interface

+ type FtpReadSettings struct

+ DeleteFilesAfterCompletion *interface{}

+ DisableChunking *interface{}

+ DisableMetricsCollection *interface{}

+ EnablePartitionDiscovery *interface{}

+ FileListPath *interface{}

+ MaxConcurrentConnections *interface{}

+ PartitionRootPath *interface{}

+ Recursive *interface{}

+ Type string

+ UseBinaryTransfer *interface{}

+ WildcardFileName *interface{}

+ WildcardFolderPath *interface{}

+ type GetMetadataActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ LinkedServiceName *LinkedServiceReference

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ Policy *ActivityPolicy

+ State *ActivityState

+ TypeProperties GetMetadataActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type GetMetadataActivityTypeProperties struct

+ Dataset DatasetReference

+ FieldList *[]interface{}

+ FormatSettings FormatReadSettings

+ StoreSettings StoreReadSettings

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

+ type GoogleAdWordsSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type GoogleBigQuerySource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type GoogleBigQueryV2Source struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type GoogleCloudStorageReadSettings struct

+ DeleteFilesAfterCompletion *interface{}

+ DisableMetricsCollection *interface{}

+ EnablePartitionDiscovery *interface{}

+ FileListPath *interface{}

+ MaxConcurrentConnections *interface{}

+ ModifiedDatetimeEnd *interface{}

+ ModifiedDatetimeStart *interface{}

+ PartitionRootPath *interface{}

+ Prefix *interface{}

+ Recursive *interface{}

+ Type string

+ WildcardFileName *interface{}

+ WildcardFolderPath *interface{}

+ type GreenplumSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type HBaseSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type HDInsightActivityDebugInfoOption string

+ const HDInsightActivityDebugInfoOptionAlways

+ const HDInsightActivityDebugInfoOptionFailure

+ const HDInsightActivityDebugInfoOptionNone

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

+ type HDInsightHiveActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ LinkedServiceName *LinkedServiceReference

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ Policy *ActivityPolicy

+ State *ActivityState

+ TypeProperties HDInsightHiveActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type HDInsightHiveActivityTypeProperties struct

+ Arguments *[]interface{}

+ Defines *map[string]interface{}

+ GetDebugInfo *HDInsightActivityDebugInfoOption

+ QueryTimeout *int64

+ ScriptLinkedService *LinkedServiceReference

+ ScriptPath *interface{}

+ StorageLinkedServices *[]LinkedServiceReference

+ Variables *map[string]interface{}

+ type HDInsightMapReduceActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ LinkedServiceName *LinkedServiceReference

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ Policy *ActivityPolicy

+ State *ActivityState

+ TypeProperties HDInsightMapReduceActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type HDInsightMapReduceActivityTypeProperties struct

+ Arguments *[]interface{}

+ ClassName interface{}

+ Defines *map[string]interface{}

+ GetDebugInfo *HDInsightActivityDebugInfoOption

+ JarFilePath interface{}

+ JarLibs *[]interface{}

+ JarLinkedService *LinkedServiceReference

+ StorageLinkedServices *[]LinkedServiceReference

+ type HDInsightPigActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ LinkedServiceName *LinkedServiceReference

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ Policy *ActivityPolicy

+ State *ActivityState

+ TypeProperties HDInsightPigActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type HDInsightPigActivityTypeProperties struct

+ Arguments *interface{}

+ Defines *map[string]interface{}

+ GetDebugInfo *HDInsightActivityDebugInfoOption

+ ScriptLinkedService *LinkedServiceReference

+ ScriptPath *interface{}

+ StorageLinkedServices *[]LinkedServiceReference

+ type HDInsightSparkActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ LinkedServiceName *LinkedServiceReference

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ Policy *ActivityPolicy

+ State *ActivityState

+ TypeProperties HDInsightSparkActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type HDInsightSparkActivityTypeProperties struct

+ Arguments *[]interface{}

+ ClassName *string

+ EntryFilePath interface{}

+ GetDebugInfo *HDInsightActivityDebugInfoOption

+ ProxyUser *interface{}

+ RootPath interface{}

+ SparkConfig *map[string]interface{}

+ SparkJobLinkedService *LinkedServiceReference

+ type HDInsightStreamingActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ LinkedServiceName *LinkedServiceReference

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ Policy *ActivityPolicy

+ State *ActivityState

+ TypeProperties HDInsightStreamingActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type HDInsightStreamingActivityTypeProperties struct

+ Arguments *[]interface{}

+ Combiner *interface{}

+ CommandEnvironment *[]interface{}

+ Defines *map[string]interface{}

+ FileLinkedService *LinkedServiceReference

+ FilePaths []interface{}

+ GetDebugInfo *HDInsightActivityDebugInfoOption

+ Input interface{}

+ Mapper interface{}

+ Output interface{}

+ Reducer interface{}

+ StorageLinkedServices *[]LinkedServiceReference

+ type HTTPReadSettings struct

+ AdditionalColumns *interface{}

+ AdditionalHeaders *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ RequestBody *interface{}

+ RequestMethod *interface{}

+ RequestTimeout *interface{}

+ Type string

+ type HTTPSource struct

+ DisableMetricsCollection *interface{}

+ HTTPRequestTimeout *interface{}

+ MaxConcurrentConnections *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type HdfsReadSettings struct

+ DeleteFilesAfterCompletion *interface{}

+ DisableMetricsCollection *interface{}

+ DistcpSettings *DistcpSettings

+ EnablePartitionDiscovery *interface{}

+ FileListPath *interface{}

+ MaxConcurrentConnections *interface{}

+ ModifiedDatetimeEnd *interface{}

+ ModifiedDatetimeStart *interface{}

+ PartitionRootPath *interface{}

+ Recursive *interface{}

+ Type string

+ WildcardFileName *interface{}

+ WildcardFolderPath *interface{}

+ type HdfsSource struct

+ DisableMetricsCollection *interface{}

+ DistcpSettings *DistcpSettings

+ MaxConcurrentConnections *interface{}

+ Recursive *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type HiveSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type HubspotSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type IfConditionActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ State *ActivityState

+ TypeProperties IfConditionActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type IfConditionActivityTypeProperties struct

+ Expression Expression

+ IfFalseActivities *[]Activity

+ IfTrueActivities *[]Activity

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

+ type ImpalaSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type InformixSink struct

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ PreCopyScript *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ type InformixSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type IntegrationRuntimeReference struct

+ Parameters *map[string]interface{}

+ ReferenceName string

+ Type IntegrationRuntimeReferenceType

+ type IntegrationRuntimeReferenceType string

+ const IntegrationRuntimeReferenceTypeIntegrationRuntimeReference

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

+ type JiraSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type JsonReadSettings struct

+ CompressionProperties CompressionReadSettings

+ Type string

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

+ type JsonSink struct

+ DisableMetricsCollection *interface{}

+ FormatSettings *JsonWriteSettings

+ MaxConcurrentConnections *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ StoreSettings StoreWriteSettings

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

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

+ type JsonSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ FormatSettings *JsonReadSettings

+ MaxConcurrentConnections *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ StoreSettings StoreReadSettings

+ Type string

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

+ type JsonWriteSettings struct

+ FilePattern *interface{}

+ Type string

+ type LakeHouseReadSettings struct

+ DeleteFilesAfterCompletion *interface{}

+ DisableMetricsCollection *interface{}

+ EnablePartitionDiscovery *interface{}

+ FileListPath *interface{}

+ MaxConcurrentConnections *interface{}

+ ModifiedDatetimeEnd *interface{}

+ ModifiedDatetimeStart *interface{}

+ PartitionRootPath *interface{}

+ Recursive *interface{}

+ Type string

+ WildcardFileName *interface{}

+ WildcardFolderPath *interface{}

+ type LakeHouseTableSink struct

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ PartitionNameList *interface{}

+ PartitionOption *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ TableActionOption *interface{}

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ type LakeHouseTableSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ TimestampAsOf *interface{}

+ Type string

+ VersionAsOf *interface{}

+ type LakeHouseWriteSettings struct

+ CopyBehavior *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Metadata *[]MetadataItem

+ Type string

+ type LinkedServiceReference struct

+ Parameters *map[string]interface{}

+ ReferenceName string

+ Type Type

+ type LogLocationSettings struct

+ LinkedServiceName LinkedServiceReference

+ Path *interface{}

+ type LogSettings struct

+ CopyActivityLogSettings *CopyActivityLogSettings

+ EnableCopyActivityLog *interface{}

+ LogLocationSettings LogLocationSettings

+ type LogStorageSettings struct

+ EnableReliableLogging *interface{}

+ LinkedServiceName LinkedServiceReference

+ LogLevel *interface{}

+ Path *interface{}

+ type LookupActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ LinkedServiceName *LinkedServiceReference

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ Policy *ActivityPolicy

+ State *ActivityState

+ TypeProperties LookupActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type LookupActivityTypeProperties struct

+ Dataset DatasetReference

+ FirstRowOnly *interface{}

+ Source CopySource

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

+ type MagentoSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type MariaDBSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type MarketoSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type MetadataItem struct

+ Name *interface{}

+ Value *interface{}

+ type MicrosoftAccessSink struct

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ PreCopyScript *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ type MicrosoftAccessSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type MongoDbAtlasSink struct

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ WriteBehavior *interface{}

+ type MongoDbAtlasSource struct

+ AdditionalColumns *interface{}

+ BatchSize *interface{}

+ CursorMethods *MongoDbCursorMethodsProperties

+ DisableMetricsCollection *interface{}

+ Filter *interface{}

+ MaxConcurrentConnections *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type MongoDbCursorMethodsProperties struct

+ Limit *interface{}

+ Project *interface{}

+ Skip *interface{}

+ Sort *interface{}

+ type MongoDbSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type MongoDbV2Sink struct

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ WriteBehavior *interface{}

+ type MongoDbV2Source struct

+ AdditionalColumns *interface{}

+ BatchSize *interface{}

+ CursorMethods *MongoDbCursorMethodsProperties

+ DisableMetricsCollection *interface{}

+ Filter *interface{}

+ MaxConcurrentConnections *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type MySqlSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type NetezzaPartitionSettings struct

+ PartitionColumnName *interface{}

+ PartitionLowerBound *interface{}

+ PartitionUpperBound *interface{}

+ type NetezzaSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ PartitionOption *interface{}

+ PartitionSettings *NetezzaPartitionSettings

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type NotebookParameter struct

+ Type *NotebookParameterType

+ Value *interface{}

+ type NotebookParameterType string

+ const NotebookParameterTypeBool

+ const NotebookParameterTypeFloat

+ const NotebookParameterTypeInt

+ const NotebookParameterTypeString

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

+ type NotebookReferenceType string

+ const NotebookReferenceTypeNotebookReference

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

+ type ODataSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ HTTPRequestTimeout *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type OdbcSink struct

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ PreCopyScript *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ type OdbcSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type Office365Source struct

+ AllowedGroups *interface{}

+ DateFilterColumn *interface{}

+ DisableMetricsCollection *interface{}

+ EndTime *interface{}

+ MaxConcurrentConnections *interface{}

+ OutputColumns *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ StartTime *interface{}

+ Type string

+ UserScopeFilterUri *interface{}

+ type OracleCloudStorageReadSettings struct

+ DeleteFilesAfterCompletion *interface{}

+ DisableMetricsCollection *interface{}

+ EnablePartitionDiscovery *interface{}

+ FileListPath *interface{}

+ MaxConcurrentConnections *interface{}

+ ModifiedDatetimeEnd *interface{}

+ ModifiedDatetimeStart *interface{}

+ PartitionRootPath *interface{}

+ Prefix *interface{}

+ Recursive *interface{}

+ Type string

+ WildcardFileName *interface{}

+ WildcardFolderPath *interface{}

+ type OraclePartitionSettings struct

+ PartitionColumnName *interface{}

+ PartitionLowerBound *interface{}

+ PartitionNames *interface{}

+ PartitionUpperBound *interface{}

+ type OracleServiceCloudSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type OracleSink struct

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ PreCopyScript *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ type OracleSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ OracleReaderQuery *interface{}

+ PartitionOption *interface{}

+ PartitionSettings *OraclePartitionSettings

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type OrcSink struct

+ DisableMetricsCollection *interface{}

+ FormatSettings *OrcWriteSettings

+ MaxConcurrentConnections *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ StoreSettings StoreWriteSettings

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

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

+ type OrcSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ StoreSettings StoreReadSettings

+ Type string

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

+ type OrcWriteSettings struct

+ FileNamePrefix *interface{}

+ MaxRowsPerFile *interface{}

+ Type string

+ type ParquetReadSettings struct

+ CompressionProperties CompressionReadSettings

+ Type string

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

+ type ParquetSink struct

+ DisableMetricsCollection *interface{}

+ FormatSettings *ParquetWriteSettings

+ MaxConcurrentConnections *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ StoreSettings StoreWriteSettings

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

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

+ type ParquetSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ FormatSettings *ParquetReadSettings

+ MaxConcurrentConnections *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ StoreSettings StoreReadSettings

+ Type string

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

+ type ParquetWriteSettings struct

+ FileNamePrefix *interface{}

+ MaxRowsPerFile *interface{}

+ Type string

+ type PaypalSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type PhoenixSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

type Pipeline

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

+ type PipelineReference struct

+ Name *string

+ ReferenceName string

+ Type PipelineReferenceType

+ type PipelineReferenceType string

+ const PipelineReferenceTypePipelineReference

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

+ type PolybaseSettings struct

+ RejectSampleValue *interface{}

+ RejectType *PolybaseSettingsRejectType

+ RejectValue *interface{}

+ UseTypeDefault *interface{}

+ type PolybaseSettingsRejectType string

+ const PolybaseSettingsRejectTypePercentage

+ const PolybaseSettingsRejectTypeValue

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

+ type PostgreSqlSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type PostgreSqlV2Source struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type PowerQuerySink struct

+ Dataset *DatasetReference

+ Description *string

+ Flowlet *DataFlowReference

+ LinkedService *LinkedServiceReference

+ Name string

+ RejectedDataLinkedService *LinkedServiceReference

+ SchemaLinkedService *LinkedServiceReference

+ Script *string

+ type PowerQuerySinkMapping struct

+ DataflowSinks *[]PowerQuerySink

+ QueryName *string

+ type PrestoSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type QuickBooksSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type RawActivityImpl struct

+ Type string

+ Values map[string]interface{}

+ type RawCompressionReadSettingsImpl struct

+ Type string

+ Values map[string]interface{}

+ type RawCopySinkImpl struct

+ Type string

+ Values map[string]interface{}

+ type RawCopySourceImpl struct

+ Type string

+ Values map[string]interface{}

+ type RawFormatReadSettingsImpl struct

+ Type string

+ Values map[string]interface{}

+ type RawSecretBaseImpl struct

+ Type string

+ Values map[string]interface{}

+ type RawStoreReadSettingsImpl struct

+ Type string

+ Values map[string]interface{}

+ type RawStoreWriteSettingsImpl struct

+ Type string

+ Values map[string]interface{}

+ type RedirectIncompatibleRowSettings struct

+ LinkedServiceName interface{}

+ Path *interface{}

+ type RedshiftUnloadSettings struct

+ BucketName interface{}

+ S3LinkedServiceName LinkedServiceReference

+ type RelationalSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type ResponsysSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type RestSink struct

+ AdditionalHeaders *interface{}

+ DisableMetricsCollection *interface{}

+ HTTPCompressionType *interface{}

+ HTTPRequestTimeout *interface{}

+ MaxConcurrentConnections *interface{}

+ RequestInterval *interface{}

+ RequestMethod *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ type RestSource struct

+ AdditionalColumns *interface{}

+ AdditionalHeaders *interface{}

+ DisableMetricsCollection *interface{}

+ HTTPRequestTimeout *interface{}

+ MaxConcurrentConnections *interface{}

+ PaginationRules *interface{}

+ RequestBody *interface{}

+ RequestInterval *interface{}

+ RequestMethod *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type SSISAccessCredential struct

+ Domain interface{}

+ Password SecretBase

+ UserName interface{}

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

+ type SSISChildPackage struct

+ PackageContent interface{}

+ PackageLastModifiedDate *string

+ PackageName *string

+ PackagePath interface{}

+ type SSISExecutionCredential struct

+ Domain interface{}

+ Password SecureString

+ UserName interface{}

+ type SSISExecutionParameter struct

+ Value interface{}

+ type SSISLogLocation struct

+ LogPath interface{}

+ Type SsisLogLocationType

+ TypeProperties SSISLogLocationTypeProperties

+ type SSISLogLocationTypeProperties struct

+ AccessCredential *SSISAccessCredential

+ LogRefreshInterval *interface{}

+ type SSISPackageLocation struct

+ PackagePath *interface{}

+ Type *SsisPackageLocationType

+ TypeProperties *SSISPackageLocationTypeProperties

+ type SSISPackageLocationTypeProperties struct

+ AccessCredential *SSISAccessCredential

+ ChildPackages *[]SSISChildPackage

+ ConfigurationAccessCredential *SSISAccessCredential

+ ConfigurationPath *interface{}

+ PackageContent *interface{}

+ PackageLastModifiedDate *string

+ PackageName *string

+ PackagePassword SecretBase

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

+ type SSISPropertyOverride struct

+ IsSensitive *bool

+ Value interface{}

+ type SalesforceMarketingCloudSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type SalesforceServiceCloudSink struct

+ DisableMetricsCollection *interface{}

+ ExternalIdFieldName *interface{}

+ IgnoreNullValues *interface{}

+ MaxConcurrentConnections *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ WriteBehavior *SalesforceSinkWriteBehavior

+ type SalesforceServiceCloudSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ ReadBehavior *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type SalesforceServiceCloudV2Sink struct

+ DisableMetricsCollection *interface{}

+ ExternalIdFieldName *interface{}

+ IgnoreNullValues *interface{}

+ MaxConcurrentConnections *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ WriteBehavior *SalesforceV2SinkWriteBehavior

+ type SalesforceServiceCloudV2Source struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ IncludeDeletedObjects *interface{}

+ MaxConcurrentConnections *interface{}

+ SOQLQuery *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type SalesforceSink struct

+ DisableMetricsCollection *interface{}

+ ExternalIdFieldName *interface{}

+ IgnoreNullValues *interface{}

+ MaxConcurrentConnections *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ WriteBehavior *SalesforceSinkWriteBehavior

+ type SalesforceSinkWriteBehavior string

+ const SalesforceSinkWriteBehaviorInsert

+ const SalesforceSinkWriteBehaviorUpsert

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

+ type SalesforceSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ ReadBehavior *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type SalesforceV2Sink struct

+ DisableMetricsCollection *interface{}

+ ExternalIdFieldName *interface{}

+ IgnoreNullValues *interface{}

+ MaxConcurrentConnections *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ WriteBehavior *SalesforceV2SinkWriteBehavior

+ type SalesforceV2SinkWriteBehavior string

+ const SalesforceV2SinkWriteBehaviorInsert

+ const SalesforceV2SinkWriteBehaviorUpsert

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

+ type SalesforceV2Source struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ IncludeDeletedObjects *interface{}

+ MaxConcurrentConnections *interface{}

+ QueryTimeout *interface{}

+ SOQLQuery *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type SapBwSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type SapCloudForCustomerSink struct

+ DisableMetricsCollection *interface{}

+ HTTPRequestTimeout *interface{}

+ MaxConcurrentConnections *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ WriteBehavior *SapCloudForCustomerSinkWriteBehavior

+ type SapCloudForCustomerSinkWriteBehavior string

+ const SapCloudForCustomerSinkWriteBehaviorInsert

+ const SapCloudForCustomerSinkWriteBehaviorUpdate

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

+ type SapCloudForCustomerSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ HTTPRequestTimeout *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type SapEccSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ HTTPRequestTimeout *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type SapHanaPartitionSettings struct

+ PartitionColumnName *interface{}

+ type SapHanaSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ PacketSize *interface{}

+ PartitionOption *interface{}

+ PartitionSettings *SapHanaPartitionSettings

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type SapOdpSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ ExtractionMode *interface{}

+ MaxConcurrentConnections *interface{}

+ Projection *interface{}

+ QueryTimeout *interface{}

+ Selection *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ SubscriberProcess *interface{}

+ Type string

+ type SapOpenHubSource struct

+ AdditionalColumns *interface{}

+ BaseRequestId *interface{}

+ CustomRfcReadTableFunctionModule *interface{}

+ DisableMetricsCollection *interface{}

+ ExcludeLastRequest *interface{}

+ MaxConcurrentConnections *interface{}

+ QueryTimeout *interface{}

+ SapDataColumnDelimiter *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type SapTablePartitionSettings struct

+ MaxPartitionsNumber *interface{}

+ PartitionColumnName *interface{}

+ PartitionLowerBound *interface{}

+ PartitionUpperBound *interface{}

+ type SapTableSource struct

+ AdditionalColumns *interface{}

+ BatchSize *interface{}

+ CustomRfcReadTableFunctionModule *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ PartitionOption *interface{}

+ PartitionSettings *SapTablePartitionSettings

+ QueryTimeout *interface{}

+ RfcTableFields *interface{}

+ RfcTableOptions *interface{}

+ RowCount *interface{}

+ RowSkips *interface{}

+ SapDataColumnDelimiter *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type ScriptActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ LinkedServiceName *LinkedServiceReference

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ Policy *ActivityPolicy

+ State *ActivityState

+ TypeProperties ScriptActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type ScriptActivityLogDestination string

+ const ScriptActivityLogDestinationActivityOutput

+ const ScriptActivityLogDestinationExternalStore

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

+ type ScriptActivityParameter struct

+ Direction *ScriptActivityParameterDirection

+ Name *interface{}

+ Size *int64

+ Type *ScriptActivityParameterType

+ Value *interface{}

+ type ScriptActivityParameterDirection string

+ const ScriptActivityParameterDirectionInput

+ const ScriptActivityParameterDirectionInputOutput

+ const ScriptActivityParameterDirectionOutput

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

+ type ScriptActivityParameterType string

+ const ScriptActivityParameterTypeBoolean

+ const ScriptActivityParameterTypeDateTime

+ const ScriptActivityParameterTypeDateTimeOffset

+ const ScriptActivityParameterTypeDecimal

+ const ScriptActivityParameterTypeDouble

+ const ScriptActivityParameterTypeGuid

+ const ScriptActivityParameterTypeIntOneSix

+ const ScriptActivityParameterTypeIntSixFour

+ const ScriptActivityParameterTypeIntThreeTwo

+ const ScriptActivityParameterTypeSingle

+ const ScriptActivityParameterTypeString

+ const ScriptActivityParameterTypeTimespan

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

+ type ScriptActivityScriptBlock struct

+ Parameters *[]ScriptActivityParameter

+ Text interface{}

+ Type ScriptType

+ type ScriptActivityTypeProperties struct

+ LogSettings *ScriptActivityTypePropertiesLogSettings

+ ScriptBlockExecutionTimeout *interface{}

+ Scripts *[]ScriptActivityScriptBlock

+ type ScriptActivityTypePropertiesLogSettings struct

+ LogDestination ScriptActivityLogDestination

+ LogLocationSettings *LogLocationSettings

+ type ScriptType string

+ const ScriptTypeNonQuery

+ const ScriptTypeQuery

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

+ type SecretBase interface

+ type SecureInputOutputPolicy struct

+ SecureInput *bool

+ SecureOutput *bool

+ type SecureString struct

+ Value string

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

+ type ServiceNowSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type ServiceNowV2Source struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ Expression *ExpressionV2

+ MaxConcurrentConnections *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type SetVariableActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ Policy *SecureInputOutputPolicy

+ State *ActivityState

+ TypeProperties SetVariableActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type SetVariableActivityTypeProperties struct

+ SetSystemVariable *bool

+ Value *interface{}

+ VariableName *string

+ type SftpReadSettings struct

+ DeleteFilesAfterCompletion *interface{}

+ DisableChunking *interface{}

+ DisableMetricsCollection *interface{}

+ EnablePartitionDiscovery *interface{}

+ FileListPath *interface{}

+ MaxConcurrentConnections *interface{}

+ ModifiedDatetimeEnd *interface{}

+ ModifiedDatetimeStart *interface{}

+ PartitionRootPath *interface{}

+ Recursive *interface{}

+ Type string

+ WildcardFileName *interface{}

+ WildcardFolderPath *interface{}

+ type SftpWriteSettings struct

+ CopyBehavior *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Metadata *[]MetadataItem

+ OperationTimeout *interface{}

+ Type string

+ UseTempFileRename *interface{}

+ type SharePointOnlineListSource struct

+ DisableMetricsCollection *interface{}

+ HTTPRequestTimeout *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type ShopifySource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type SkipErrorFile struct

+ DataInconsistency *interface{}

+ FileMissing *interface{}

+ type SnowflakeExportCopyCommand struct

+ AdditionalCopyOptions *map[string]interface{}

+ AdditionalFormatOptions *map[string]interface{}

+ Type string

+ type SnowflakeImportCopyCommand struct

+ AdditionalCopyOptions *map[string]interface{}

+ AdditionalFormatOptions *map[string]interface{}

+ Type string

+ type SnowflakeSink struct

+ DisableMetricsCollection *interface{}

+ ImportSettings *SnowflakeImportCopyCommand

+ MaxConcurrentConnections *interface{}

+ PreCopyScript *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ type SnowflakeSource struct

+ DisableMetricsCollection *interface{}

+ ExportSettings SnowflakeExportCopyCommand

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type SnowflakeV2Sink struct

+ DisableMetricsCollection *interface{}

+ ImportSettings *SnowflakeImportCopyCommand

+ MaxConcurrentConnections *interface{}

+ PreCopyScript *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ type SnowflakeV2Source struct

+ DisableMetricsCollection *interface{}

+ ExportSettings SnowflakeExportCopyCommand

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type SparkConfigurationParametrizationReference struct

+ ReferenceName interface{}

+ Type SparkConfigurationReferenceType

+ type SparkConfigurationReferenceType string

+ const SparkConfigurationReferenceTypeSparkConfigurationReference

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

+ type SparkJobReferenceType string

+ const SparkJobReferenceTypeSparkJobDefinitionReference

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

+ type SparkSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type SqlDWSink struct

+ AllowCopyCommand *interface{}

+ AllowPolyBase *interface{}

+ CopyCommandSettings *DWCopyCommandSettings

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ PolyBaseSettings *PolybaseSettings

+ PreCopyScript *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ SqlWriterUseTableLock *interface{}

+ TableOption *interface{}

+ Type string

+ UpsertSettings *SqlDWUpsertSettings

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ WriteBehavior *interface{}

+ type SqlDWSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ IsolationLevel *interface{}

+ MaxConcurrentConnections *interface{}

+ PartitionOption *interface{}

+ PartitionSettings *SqlPartitionSettings

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ SqlReaderQuery *interface{}

+ SqlReaderStoredProcedureName *interface{}

+ StoredProcedureParameters *interface{}

+ Type string

+ type SqlDWUpsertSettings struct

+ InterimSchemaName *interface{}

+ Keys *interface{}

+ type SqlMISink struct

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ PreCopyScript *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ SqlWriterStoredProcedureName *interface{}

+ SqlWriterTableType *interface{}

+ SqlWriterUseTableLock *interface{}

+ StoredProcedureParameters *interface{}

+ StoredProcedureTableTypeParameterName *interface{}

+ TableOption *interface{}

+ Type string

+ UpsertSettings *SqlUpsertSettings

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ WriteBehavior *interface{}

+ type SqlMISource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ IsolationLevel *interface{}

+ MaxConcurrentConnections *interface{}

+ PartitionOption *interface{}

+ PartitionSettings *SqlPartitionSettings

+ ProduceAdditionalTypes *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ SqlReaderQuery *interface{}

+ SqlReaderStoredProcedureName *interface{}

+ StoredProcedureParameters *interface{}

+ Type string

+ type SqlPartitionSettings struct

+ PartitionColumnName *interface{}

+ PartitionLowerBound *interface{}

+ PartitionUpperBound *interface{}

+ type SqlServerSink struct

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ PreCopyScript *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ SqlWriterStoredProcedureName *interface{}

+ SqlWriterTableType *interface{}

+ SqlWriterUseTableLock *interface{}

+ StoredProcedureParameters *interface{}

+ StoredProcedureTableTypeParameterName *interface{}

+ TableOption *interface{}

+ Type string

+ UpsertSettings *SqlUpsertSettings

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ WriteBehavior *interface{}

+ type SqlServerSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ IsolationLevel *interface{}

+ MaxConcurrentConnections *interface{}

+ PartitionOption *interface{}

+ PartitionSettings *SqlPartitionSettings

+ ProduceAdditionalTypes *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ SqlReaderQuery *interface{}

+ SqlReaderStoredProcedureName *interface{}

+ StoredProcedureParameters *interface{}

+ Type string

+ type SqlServerStoredProcedureActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ LinkedServiceName *LinkedServiceReference

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ Policy *ActivityPolicy

+ State *ActivityState

+ TypeProperties SqlServerStoredProcedureActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type SqlServerStoredProcedureActivityTypeProperties struct

+ StoredProcedureName interface{}

+ StoredProcedureParameters *interface{}

+ type SqlSink struct

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ PreCopyScript *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ SqlWriterStoredProcedureName *interface{}

+ SqlWriterTableType *interface{}

+ SqlWriterUseTableLock *interface{}

+ StoredProcedureParameters *interface{}

+ StoredProcedureTableTypeParameterName *interface{}

+ TableOption *interface{}

+ Type string

+ UpsertSettings *SqlUpsertSettings

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ WriteBehavior *interface{}

+ type SqlSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ IsolationLevel *interface{}

+ MaxConcurrentConnections *interface{}

+ PartitionOption *interface{}

+ PartitionSettings *SqlPartitionSettings

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ SqlReaderQuery *interface{}

+ SqlReaderStoredProcedureName *interface{}

+ StoredProcedureParameters *interface{}

+ Type string

+ type SqlUpsertSettings struct

+ InterimSchemaName *interface{}

+ Keys *interface{}

+ UseTempDB *interface{}

+ type SquareSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type SsisLogLocationType string

+ const SsisLogLocationTypeFile

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

+ type SsisPackageLocationType string

+ const SsisPackageLocationTypeFile

+ const SsisPackageLocationTypeInlinePackage

+ const SsisPackageLocationTypePackageStore

+ const SsisPackageLocationTypeSSISDB

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

+ type StagingSettings struct

+ EnableCompression *interface{}

+ LinkedServiceName LinkedServiceReference

+ Path *interface{}

+ type StoreReadSettings interface

+ type StoreWriteSettings interface

+ type SwitchActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ State *ActivityState

+ TypeProperties SwitchActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type SwitchActivityTypeProperties struct

+ Cases *[]SwitchCase

+ DefaultActivities *[]Activity

+ On Expression

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

+ type SwitchCase struct

+ Activities *[]Activity

+ Value *string

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

+ type SybaseSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type SynapseNotebookActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ LinkedServiceName *LinkedServiceReference

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ Policy *ActivityPolicy

+ State *ActivityState

+ TypeProperties SynapseNotebookActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type SynapseNotebookActivityTypeProperties struct

+ Conf *interface{}

+ ConfigurationType *ConfigurationType

+ DriverSize *interface{}

+ ExecutorSize *interface{}

+ Notebook SynapseNotebookReference

+ NumExecutors *interface{}

+ Parameters *map[string]NotebookParameter

+ SparkConfig *map[string]interface{}

+ SparkPool *BigDataPoolParametrizationReference

+ TargetSparkConfiguration *SparkConfigurationParametrizationReference

+ type SynapseNotebookReference struct

+ ReferenceName interface{}

+ Type NotebookReferenceType

+ type SynapseSparkJobActivityTypeProperties struct

+ Args *[]interface{}

+ ClassName *interface{}

+ Conf *interface{}

+ ConfigurationType *ConfigurationType

+ DriverSize *interface{}

+ ExecutorSize *interface{}

+ File *interface{}

+ Files *[]interface{}

+ FilesV2 *[]interface{}

+ NumExecutors *interface{}

+ PythonCodeReference *[]interface{}

+ ScanFolder *interface{}

+ SparkConfig *map[string]interface{}

+ SparkJob SynapseSparkJobReference

+ TargetBigDataPool *BigDataPoolParametrizationReference

+ TargetSparkConfiguration *SparkConfigurationParametrizationReference

+ type SynapseSparkJobDefinitionActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ LinkedServiceName *LinkedServiceReference

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ Policy *ActivityPolicy

+ State *ActivityState

+ TypeProperties SynapseSparkJobActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type SynapseSparkJobReference struct

+ ReferenceName interface{}

+ Type SparkJobReferenceType

+ type TabularSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type TarGZipReadSettings struct

+ PreserveCompressionFileNameAsFolder *interface{}

+ Type string

+ type TarReadSettings struct

+ PreserveCompressionFileNameAsFolder *interface{}

+ Type string

+ type TeradataPartitionSettings struct

+ PartitionColumnName *interface{}

+ PartitionLowerBound *interface{}

+ PartitionUpperBound *interface{}

+ type TeradataSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ PartitionOption *interface{}

+ PartitionSettings *TeradataPartitionSettings

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type Type string

+ const TypeLinkedServiceReference

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

+ type UntilActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ State *ActivityState

+ TypeProperties UntilActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type UntilActivityTypeProperties struct

+ Activities []Activity

+ Expression Expression

+ Timeout *interface{}

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

+ type ValidationActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ State *ActivityState

+ TypeProperties ValidationActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type ValidationActivityTypeProperties struct

+ ChildItems *interface{}

+ Dataset DatasetReference

+ MinimumSize *interface{}

+ Sleep *interface{}

+ Timeout *interface{}

+ type VerticaSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type WaitActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ State *ActivityState

+ TypeProperties WaitActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type WaitActivityTypeProperties struct

+ WaitTimeInSeconds interface{}

+ type WarehouseSink struct

+ AllowCopyCommand *interface{}

+ CopyCommandSettings *DWCopyCommandSettings

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ PreCopyScript *interface{}

+ SinkRetryCount *interface{}

+ SinkRetryWait *interface{}

+ TableOption *interface{}

+ Type string

+ WriteBatchSize *interface{}

+ WriteBatchTimeout *interface{}

+ WriteBehavior *interface{}

+ type WarehouseSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ IsolationLevel *interface{}

+ MaxConcurrentConnections *interface{}

+ PartitionOption *interface{}

+ PartitionSettings *SqlPartitionSettings

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ SqlReaderQuery *interface{}

+ SqlReaderStoredProcedureName *interface{}

+ StoredProcedureParameters *interface{}

+ Type string

+ type WebActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ LinkedServiceName *LinkedServiceReference

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ Policy *ActivityPolicy

+ State *ActivityState

+ TypeProperties WebActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type WebActivityAuthentication struct

+ Credential *CredentialReference

+ Password SecretBase

+ Pfx SecretBase

+ Resource *interface{}

+ Type *string

+ UserTenant *interface{}

+ Username *interface{}

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

+ type WebActivityMethod string

+ const WebActivityMethodDELETE

+ const WebActivityMethodGET

+ const WebActivityMethodPOST

+ const WebActivityMethodPUT

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

+ type WebActivityTypeProperties struct

+ Authentication *WebActivityAuthentication

+ Body *interface{}

+ ConnectVia *IntegrationRuntimeReference

+ Datasets *[]DatasetReference

+ DisableCertValidation *bool

+ HTTPRequestTimeout *interface{}

+ Headers *map[string]interface{}

+ LinkedServices *[]LinkedServiceReference

+ Method WebActivityMethod

+ TurnOffAsync *bool

+ Url interface{}

+ type WebHookActivity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ Policy *SecureInputOutputPolicy

+ State *ActivityState

+ TypeProperties WebHookActivityTypeProperties

+ UserProperties *[]UserProperty

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

+ type WebHookActivityMethod string

+ const WebHookActivityMethodPOST

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

+ type WebHookActivityTypeProperties struct

+ Authentication *WebActivityAuthentication

+ Body *interface{}

+ Headers *map[string]interface{}

+ Method WebHookActivityMethod

+ ReportStatusOnCallBack *interface{}

+ Timeout *string

+ Url interface{}

+ type WebSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type XeroSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

+ type XmlReadSettings struct

+ CompressionProperties CompressionReadSettings

+ DetectDataType *interface{}

+ NamespacePrefixes *interface{}

+ Namespaces *interface{}

+ Type string

+ ValidationMode *interface{}

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

+ type XmlSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ FormatSettings *XmlReadSettings

+ MaxConcurrentConnections *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ StoreSettings StoreReadSettings

+ Type string

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

+ type ZipDeflateReadSettings struct

+ PreserveZipFileNameAsFolder *interface{}

+ Type string

+ type ZohoSource struct

+ AdditionalColumns *interface{}

+ DisableMetricsCollection *interface{}

+ MaxConcurrentConnections *interface{}

+ Query *interface{}

+ QueryTimeout *interface{}

+ SourceRetryCount *interface{}

+ SourceRetryWait *interface{}

+ Type string

v0.20240320.1105218

Mar 20, 2024

v0.20240320.1000025

Mar 20, 2024

v0.20240319.1180522

Mar 19, 2024

v0.20240319.1093754

Mar 19, 2024

v0.20240318.1145438

Mar 18, 2024

v0.20240315.1103122

Mar 15, 2024

v0.20240315.1084643

Mar 15, 2024

v0.20240314.1083835

Mar 14, 2024

v0.20240313.1132601

Mar 13, 2024

v0.20240312.1161024

Mar 12, 2024

v0.20240312.1134121

Mar 12, 2024

v0.20240312.1123713

Mar 12, 2024

v0.20240311.1163512

Mar 11, 2024

v0.20240306.1111727

Mar 6, 2024

v0.20240304.1112406

Mar 4, 2024

v0.20240301.1111622

Mar 1, 2024

v0.20240301.1091357

Mar 1, 2024

v0.20240229.1102109

Feb 29, 2024

v0.20240228.1142829

Feb 28, 2024

v0.20240228.1135502

Feb 28, 2024

v0.20240228.1133018

Feb 28, 2024

v0.20240227.1200200

Feb 27, 2024

v0.20240227.1172434

Feb 27, 2024

v0.20240227.1165506

Feb 27, 2024

v0.20240227.1130345

Feb 27, 2024

v0.20240226.1173038

Feb 26, 2024

v0.20240223.1153421

Feb 23, 2024

v0.20240223.1145617

Feb 23, 2024

v0.20240223.1130721

Feb 23, 2024

v0.20240222.1164640

Feb 22, 2024

v0.20240222.1121651

Feb 22, 2024

v0.20240221.1182059

Feb 21, 2024

v0.20240221.1170458

Feb 21, 2024

v0.20240221.1115631

Feb 21, 2024

v0.20240219.1162256

Feb 19, 2024

v0.20240219.1082313

Feb 19, 2024

v0.20240215.1143935

Feb 15, 2024

v0.20240214.1142753

Feb 14, 2024

v0.20240214.1100807

Feb 14, 2024

v0.20240213.1120950

Feb 13, 2024

v0.20240212.1141705

Feb 12, 2024

v0.20240209.1164150

Feb 9, 2024

v0.20240209.1123314

Feb 9, 2024

v0.20240209.1120443

Feb 9, 2024

v0.20240208.1165011

Feb 8, 2024

v0.20240208.1160128

Feb 8, 2024

v0.20240208.1105228

Feb 8, 2024

v0.20240208.1095436

Feb 8, 2024

v0.20240207.1162109

Feb 7, 2024

v0.20240206.1080438

Feb 6, 2024

v0.20240201.1165154

Feb 1, 2024

v0.20240201.1155633

Feb 1, 2024

v0.20240201.1064937

Feb 1, 2024

v0.20240131.1195211

Jan 31, 2024

v0.20240131.1131852

Jan 31, 2024

v0.20240131.1125554

Jan 31, 2024

v0.20240131.1120756

Jan 31, 2024

v0.20240131.1112007

Jan 31, 2024

v0.20240131.1085516

Jan 31, 2024

v0.20240130.1181631

Jan 30, 2024

v0.20240130.1163644

Jan 30, 2024

v0.20240130.1054849

Jan 30, 2024

v0.20240126.1105227

Jan 26, 2024

v0.20240125.1172517

Jan 25, 2024

v0.20240125.1170241

Jan 25, 2024

v0.20240125.1150118

Jan 25, 2024

v0.20240125.1122928

Jan 25, 2024

v0.20240125.1115017

Jan 25, 2024

v0.20240125.1111756

Jan 25, 2024

Changes in this version

+ func PossibleValuesForActivityOnInactiveMarkAs() []string

+ func PossibleValuesForActivityState() []string

+ func PossibleValuesForDependencyCondition() []string

+ func PossibleValuesForParameterType() []string

+ func PossibleValuesForVariableType() []string

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

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

+ type Activity struct

+ DependsOn *[]ActivityDependency

+ Description *string

+ Name string

+ OnInactiveMarkAs *ActivityOnInactiveMarkAs

+ State *ActivityState

+ Type string

+ UserProperties *[]UserProperty

+ type ActivityDependency struct

+ Activity string

+ DependencyConditions []DependencyCondition

+ type ActivityOnInactiveMarkAs string

+ const ActivityOnInactiveMarkAsFailed

+ const ActivityOnInactiveMarkAsSkipped

+ const ActivityOnInactiveMarkAsSucceeded

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

+ type ActivityState string

+ const ActivityStateActive

+ const ActivityStateInactive

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

+ type CreateOrUpdateOperationOptions struct

+ IfMatch *string

+ func DefaultCreateOrUpdateOperationOptions() CreateOrUpdateOperationOptions

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

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

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

+ type CreateOrUpdateOperationResponse struct

+ HttpResponse *http.Response

+ Model *PipelineResource

+ OData *odata.OData

+ type CreateRunOperationOptions struct

+ IsRecovery *bool

+ ReferencePipelineRunId *string

+ StartActivityName *string

+ StartFromFailure *bool

+ func DefaultCreateRunOperationOptions() CreateRunOperationOptions

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

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

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

+ type CreateRunOperationResponse struct

+ HttpResponse *http.Response

+ Model *CreateRunResponse

+ OData *odata.OData

+ type CreateRunResponse struct

+ RunId string

+ type DeleteOperationResponse struct

+ HttpResponse *http.Response

+ OData *odata.OData

+ type DependencyCondition string

+ const DependencyConditionCompleted

+ const DependencyConditionFailed

+ const DependencyConditionSkipped

+ const DependencyConditionSucceeded

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

+ type FactoryId struct

+ FactoryName string

+ ResourceGroupName string

+ SubscriptionId string

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

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

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

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

+ func (id FactoryId) ID() string

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

+ func (id FactoryId) String() string

+ type GetOperationOptions struct

+ IfNoneMatch *string

+ func DefaultGetOperationOptions() GetOperationOptions

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

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

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

+ type GetOperationResponse struct

+ HttpResponse *http.Response

+ Model *PipelineResource

+ OData *odata.OData

+ type ListByFactoryCompleteResult struct

+ Items []PipelineResource

+ LatestHttpResponse *http.Response

+ type ListByFactoryOperationResponse struct

+ HttpResponse *http.Response

+ Model *[]PipelineResource

+ OData *odata.OData

+ type ParameterSpecification struct

+ DefaultValue *interface{}

+ Type ParameterType

+ type ParameterType string

+ const ParameterTypeArray

+ const ParameterTypeBool

+ const ParameterTypeFloat

+ const ParameterTypeInt

+ const ParameterTypeObject

+ const ParameterTypeSecureString

+ const ParameterTypeString

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

+ type Pipeline struct

+ Activities *[]Activity

+ Annotations *[]interface{}

+ Concurrency *int64

+ Description *string

+ Folder *PipelineFolder

+ Parameters *map[string]ParameterSpecification

+ Policy *PipelinePolicy

+ RunDimensions *map[string]interface{}

+ Variables *map[string]VariableSpecification

+ type PipelineElapsedTimeMetricPolicy struct

+ Duration *interface{}

+ type PipelineFolder struct

+ Name *string

+ type PipelineId struct

+ FactoryName string

+ PipelineName string

+ ResourceGroupName string

+ SubscriptionId string

+ func NewPipelineID(subscriptionId string, resourceGroupName string, factoryName string, ...) PipelineId

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

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

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

+ func (id PipelineId) ID() string

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

+ func (id PipelineId) String() string

+ type PipelinePolicy struct

+ ElapsedTimeMetric *PipelineElapsedTimeMetricPolicy

+ type PipelineResource struct

+ Etag *string

+ Id *string

+ Name *string

+ Properties Pipeline

+ Type *string

+ type PipelineResourceOperationPredicate struct

+ Etag *string

+ Id *string

+ Name *string

+ Type *string

+ func (p PipelineResourceOperationPredicate) Matches(input PipelineResource) bool

+ type PipelinesClient struct

+ Client *resourcemanager.Client

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

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

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

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

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

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

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

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

+ type UserProperty struct

+ Name string

+ Value interface{}

+ type VariableSpecification struct

+ DefaultValue *interface{}

+ Type VariableType

+ type VariableType string

+ const VariableTypeArray

+ const VariableTypeBool

+ const VariableTypeString

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

Other modules containing this package

github.com/hashicorp/go-azure-sdk

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL