subscriptions

package
v0.20241004.1180715 Latest Latest
Warning

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

 Go to latest Published: Oct 4, 2024 License: MPL-2.0 Imports: 15 Imported by: 1

README

github.com/hashicorp/go-azure-sdk/resource-manager/streamanalytics/2021-10-01-preview/subscriptions Documentation

The subscriptions SDK allows for interaction with Azure Resource Manager streamanalytics (API Version 2021-10-01-preview).

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

Import Path

import "github.com/hashicorp/go-azure-sdk/resource-manager/streamanalytics/2021-10-01-preview/subscriptions"

Client Initialization

client := subscriptions.NewSubscriptionsClientWithBaseURI("https://management.azure.com")
client.Client.Authorizer = authorizer

Example Usage: SubscriptionsClient.CompileQuery

ctx := context.TODO()
id := subscriptions.NewLocationID("12345678-1234-9876-4563-123456789012", "location")

payload := subscriptions.CompileQuery{
	// ...
}


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

Example Usage: SubscriptionsClient.ListQuotas

ctx := context.TODO()
id := subscriptions.NewLocationID("12345678-1234-9876-4563-123456789012", "location")

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

Example Usage: SubscriptionsClient.SampleInput

ctx := context.TODO()
id := subscriptions.NewLocationID("12345678-1234-9876-4563-123456789012", "location")

payload := subscriptions.SampleInput{
	// ...
}


if err := client.SampleInputThenPoll(ctx, id, payload); err != nil {
	// handle the error
}

Example Usage: SubscriptionsClient.TestInput

ctx := context.TODO()
id := subscriptions.NewLocationID("12345678-1234-9876-4563-123456789012", "location")

payload := subscriptions.TestInput{
	// ...
}


if err := client.TestInputThenPoll(ctx, id, payload); err != nil {
	// handle the error
}

Example Usage: SubscriptionsClient.TestOutput

ctx := context.TODO()
id := subscriptions.NewLocationID("12345678-1234-9876-4563-123456789012", "location")

payload := subscriptions.TestOutput{
	// ...
}


if err := client.TestOutputThenPoll(ctx, id, payload); err != nil {
	// handle the error
}

Example Usage: SubscriptionsClient.TestQuery

ctx := context.TODO()
id := subscriptions.NewLocationID("12345678-1234-9876-4563-123456789012", "location")

payload := subscriptions.TestQuery{
	// ...
}


if err := client.TestQueryThenPoll(ctx, id, payload); err != nil {
	// handle the error
}

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func PossibleValuesForAuthenticationMode 

func PossibleValuesForAuthenticationMode() []string

func PossibleValuesForBlobWriteMode 

func PossibleValuesForBlobWriteMode() []string

func PossibleValuesForCompatibilityLevel 

func PossibleValuesForCompatibilityLevel() []string

func PossibleValuesForCompressionType 

func PossibleValuesForCompressionType() []string

func PossibleValuesForContentStoragePolicy 

func PossibleValuesForContentStoragePolicy() []string

func PossibleValuesForEncoding 

func PossibleValuesForEncoding() []string

func PossibleValuesForEventGridEventSchemaType 

func PossibleValuesForEventGridEventSchemaType() []string

func PossibleValuesForEventSerializationType 

func PossibleValuesForEventSerializationType() []string

func PossibleValuesForEventsOutOfOrderPolicy 

func PossibleValuesForEventsOutOfOrderPolicy() []string

func PossibleValuesForInputWatermarkMode 

func PossibleValuesForInputWatermarkMode() []string

func PossibleValuesForJobType 

func PossibleValuesForJobType() []string

func PossibleValuesForJsonOutputSerializationFormat 

func PossibleValuesForJsonOutputSerializationFormat() []string

func PossibleValuesForOutputErrorPolicy 

func PossibleValuesForOutputErrorPolicy() []string

func PossibleValuesForOutputStartMode 

func PossibleValuesForOutputStartMode() []string

func PossibleValuesForOutputWatermarkMode 

func PossibleValuesForOutputWatermarkMode() []string

func PossibleValuesForQueryTestingResultStatus 

func PossibleValuesForQueryTestingResultStatus() []string

func PossibleValuesForRefreshType 

func PossibleValuesForRefreshType() []string

func PossibleValuesForSampleInputResultStatus 

func PossibleValuesForSampleInputResultStatus() []string

func PossibleValuesForSkuName 

func PossibleValuesForSkuName() []string

func PossibleValuesForTestDatasourceResultStatus 

func PossibleValuesForTestDatasourceResultStatus() []string

func PossibleValuesForUpdatableUdfRefreshType 

func PossibleValuesForUpdatableUdfRefreshType() []string

func PossibleValuesForUpdateMode 

func PossibleValuesForUpdateMode() []string

func ValidateLocationID 

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

ValidateLocationID checks that 'input' can be parsed as a Location ID

Types

type AggregateFunctionProperties 

type AggregateFunctionProperties struct {
	Etag       *string                `json:"etag,omitempty"`
	Properties *FunctionConfiguration `json:"properties,omitempty"`
	Type       string                 `json:"type"`
}

func (AggregateFunctionProperties) FunctionProperties added in v0.20240920.1135249 

func (s AggregateFunctionProperties) FunctionProperties() BaseFunctionPropertiesImpl

func (AggregateFunctionProperties) MarshalJSON 

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

type AuthenticationMode 

type AuthenticationMode string
const (
	AuthenticationModeConnectionString AuthenticationMode = "ConnectionString"
	AuthenticationModeMsi              AuthenticationMode = "Msi"
	AuthenticationModeUserToken        AuthenticationMode = "UserToken"
)

func (*AuthenticationMode) UnmarshalJSON added in v0.20240208.1095436 

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

type AvroSerialization 

type AvroSerialization struct {
	Properties *interface{} `json:"properties,omitempty"`

	Type EventSerializationType `json:"type"`
}

func (AvroSerialization) MarshalJSON 

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

func (AvroSerialization) Serialization added in v0.20240920.1135249 

func (s AvroSerialization) Serialization() BaseSerializationImpl

type AzureDataExplorerOutputDataSource 

type AzureDataExplorerOutputDataSource struct {
	Properties *AzureDataExplorerOutputDataSourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (AzureDataExplorerOutputDataSource) MarshalJSON 

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

func (AzureDataExplorerOutputDataSource) OutputDataSource added in v0.20240920.1135249 

func (s AzureDataExplorerOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type AzureDataExplorerOutputDataSourceProperties 

type AzureDataExplorerOutputDataSourceProperties struct {
	AuthenticationMode *AuthenticationMode `json:"authenticationMode,omitempty"`
	Cluster            *string             `json:"cluster,omitempty"`
	Database           *string             `json:"database,omitempty"`
	Table              *string             `json:"table,omitempty"`
}

type AzureDataLakeStoreOutputDataSource 

type AzureDataLakeStoreOutputDataSource struct {
	Properties *AzureDataLakeStoreOutputDataSourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (AzureDataLakeStoreOutputDataSource) MarshalJSON 

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

func (AzureDataLakeStoreOutputDataSource) OutputDataSource added in v0.20240920.1135249 

func (s AzureDataLakeStoreOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type AzureDataLakeStoreOutputDataSourceProperties 

type AzureDataLakeStoreOutputDataSourceProperties struct {
	AccountName            *string             `json:"accountName,omitempty"`
	AuthenticationMode     *AuthenticationMode `json:"authenticationMode,omitempty"`
	DateFormat             *string             `json:"dateFormat,omitempty"`
	FilePathPrefix         *string             `json:"filePathPrefix,omitempty"`
	RefreshToken           *string             `json:"refreshToken,omitempty"`
	TenantId               *string             `json:"tenantId,omitempty"`
	TimeFormat             *string             `json:"timeFormat,omitempty"`
	TokenUserDisplayName   *string             `json:"tokenUserDisplayName,omitempty"`
	TokenUserPrincipalName *string             `json:"tokenUserPrincipalName,omitempty"`
}

type AzureFunctionOutputDataSource 

type AzureFunctionOutputDataSource struct {
	Properties *AzureFunctionOutputDataSourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (AzureFunctionOutputDataSource) MarshalJSON 

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

func (AzureFunctionOutputDataSource) OutputDataSource added in v0.20240920.1135249 

func (s AzureFunctionOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type AzureFunctionOutputDataSourceProperties 

type AzureFunctionOutputDataSourceProperties struct {
	ApiKey          *string  `json:"apiKey,omitempty"`
	FunctionAppName *string  `json:"functionAppName,omitempty"`
	FunctionName    *string  `json:"functionName,omitempty"`
	MaxBatchCount   *float64 `json:"maxBatchCount,omitempty"`
	MaxBatchSize    *float64 `json:"maxBatchSize,omitempty"`
}

type AzureMachineLearningServiceFunctionBinding 

type AzureMachineLearningServiceFunctionBinding struct {
	Properties *AzureMachineLearningServiceFunctionBindingProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (AzureMachineLearningServiceFunctionBinding) FunctionBinding added in v0.20240920.1135249 

func (s AzureMachineLearningServiceFunctionBinding) FunctionBinding() BaseFunctionBindingImpl

func (AzureMachineLearningServiceFunctionBinding) MarshalJSON 

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

type AzureMachineLearningServiceFunctionBindingProperties 

type AzureMachineLearningServiceFunctionBindingProperties struct {
	ApiKey                   *string                                    `json:"apiKey,omitempty"`
	BatchSize                *int64                                     `json:"batchSize,omitempty"`
	Endpoint                 *string                                    `json:"endpoint,omitempty"`
	InputRequestName         *string                                    `json:"inputRequestName,omitempty"`
	Inputs                   *[]AzureMachineLearningServiceInputColumn  `json:"inputs,omitempty"`
	NumberOfParallelRequests *int64                                     `json:"numberOfParallelRequests,omitempty"`
	OutputResponseName       *string                                    `json:"outputResponseName,omitempty"`
	Outputs                  *[]AzureMachineLearningServiceOutputColumn `json:"outputs,omitempty"`
}

type AzureMachineLearningServiceInputColumn 

type AzureMachineLearningServiceInputColumn struct {
	DataType *string `json:"dataType,omitempty"`
	MapTo    *int64  `json:"mapTo,omitempty"`
	Name     *string `json:"name,omitempty"`
}

type AzureMachineLearningServiceOutputColumn 

type AzureMachineLearningServiceOutputColumn struct {
	DataType *string `json:"dataType,omitempty"`
	MapTo    *int64  `json:"mapTo,omitempty"`
	Name     *string `json:"name,omitempty"`
}

type AzureMachineLearningStudioFunctionBinding 

type AzureMachineLearningStudioFunctionBinding struct {
	Properties *AzureMachineLearningStudioFunctionBindingProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (AzureMachineLearningStudioFunctionBinding) FunctionBinding added in v0.20240920.1135249 

func (s AzureMachineLearningStudioFunctionBinding) FunctionBinding() BaseFunctionBindingImpl

func (AzureMachineLearningStudioFunctionBinding) MarshalJSON 

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

type AzureMachineLearningStudioFunctionBindingProperties 

type AzureMachineLearningStudioFunctionBindingProperties struct {
	ApiKey    *string                                   `json:"apiKey,omitempty"`
	BatchSize *int64                                    `json:"batchSize,omitempty"`
	Endpoint  *string                                   `json:"endpoint,omitempty"`
	Inputs    *AzureMachineLearningStudioInputs         `json:"inputs,omitempty"`
	Outputs   *[]AzureMachineLearningStudioOutputColumn `json:"outputs,omitempty"`
}

type AzureMachineLearningStudioInputColumn 

type AzureMachineLearningStudioInputColumn struct {
	DataType *string `json:"dataType,omitempty"`
	MapTo    *int64  `json:"mapTo,omitempty"`
	Name     *string `json:"name,omitempty"`
}

type AzureMachineLearningStudioInputs 

type AzureMachineLearningStudioInputs struct {
	ColumnNames *[]AzureMachineLearningStudioInputColumn `json:"columnNames,omitempty"`
	Name        *string                                  `json:"name,omitempty"`
}

type AzureMachineLearningStudioOutputColumn 

type AzureMachineLearningStudioOutputColumn struct {
	DataType *string `json:"dataType,omitempty"`
	Name     *string `json:"name,omitempty"`
}

type AzureSqlDatabaseDataSourceProperties 

type AzureSqlDatabaseDataSourceProperties struct {
	AuthenticationMode *AuthenticationMode `json:"authenticationMode,omitempty"`
	Database           *string             `json:"database,omitempty"`
	MaxBatchCount      *float64            `json:"maxBatchCount,omitempty"`
	MaxWriterCount     *float64            `json:"maxWriterCount,omitempty"`
	Password           *string             `json:"password,omitempty"`
	Server             *string             `json:"server,omitempty"`
	Table              *string             `json:"table,omitempty"`
	User               *string             `json:"user,omitempty"`
}

type AzureSqlDatabaseOutputDataSource 

type AzureSqlDatabaseOutputDataSource struct {
	Properties *AzureSqlDatabaseDataSourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (AzureSqlDatabaseOutputDataSource) MarshalJSON 

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

func (AzureSqlDatabaseOutputDataSource) OutputDataSource added in v0.20240920.1135249 

func (s AzureSqlDatabaseOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type AzureSqlReferenceInputDataSource 

type AzureSqlReferenceInputDataSource struct {
	Properties *AzureSqlReferenceInputDataSourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (AzureSqlReferenceInputDataSource) MarshalJSON 

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

func (AzureSqlReferenceInputDataSource) ReferenceInputDataSource added in v0.20240920.1135249 

func (s AzureSqlReferenceInputDataSource) ReferenceInputDataSource() BaseReferenceInputDataSourceImpl

type AzureSqlReferenceInputDataSourceProperties 

type AzureSqlReferenceInputDataSourceProperties struct {
	AuthenticationMode *AuthenticationMode `json:"authenticationMode,omitempty"`
	Database           *string             `json:"database,omitempty"`
	DeltaSnapshotQuery *string             `json:"deltaSnapshotQuery,omitempty"`
	FullSnapshotQuery  *string             `json:"fullSnapshotQuery,omitempty"`
	Password           *string             `json:"password,omitempty"`
	RefreshRate        *string             `json:"refreshRate,omitempty"`
	RefreshType        *RefreshType        `json:"refreshType,omitempty"`
	Server             *string             `json:"server,omitempty"`
	User               *string             `json:"user,omitempty"`
}

type AzureSynapseDataSourceProperties 

type AzureSynapseDataSourceProperties struct {
	AuthenticationMode *AuthenticationMode `json:"authenticationMode,omitempty"`
	Database           *string             `json:"database,omitempty"`
	Password           *string             `json:"password,omitempty"`
	Server             *string             `json:"server,omitempty"`
	Table              *string             `json:"table,omitempty"`
	User               *string             `json:"user,omitempty"`
}

type AzureSynapseOutputDataSource 

type AzureSynapseOutputDataSource struct {
	Properties *AzureSynapseDataSourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (AzureSynapseOutputDataSource) MarshalJSON 

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

func (AzureSynapseOutputDataSource) OutputDataSource added in v0.20240920.1135249 

func (s AzureSynapseOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type AzureTableOutputDataSource 

type AzureTableOutputDataSource struct {
	Properties *AzureTableOutputDataSourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (AzureTableOutputDataSource) MarshalJSON 

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

func (AzureTableOutputDataSource) OutputDataSource added in v0.20240920.1135249 

func (s AzureTableOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type AzureTableOutputDataSourceProperties 

type AzureTableOutputDataSourceProperties struct {
	AccountKey      *string   `json:"accountKey,omitempty"`
	AccountName     *string   `json:"accountName,omitempty"`
	BatchSize       *int64    `json:"batchSize,omitempty"`
	ColumnsToRemove *[]string `json:"columnsToRemove,omitempty"`
	PartitionKey    *string   `json:"partitionKey,omitempty"`
	RowKey          *string   `json:"rowKey,omitempty"`
	Table           *string   `json:"table,omitempty"`
}

type BaseFunctionBindingImpl added in v0.20240920.1135249 

type BaseFunctionBindingImpl struct {
	Type string `json:"type"`
}

func (BaseFunctionBindingImpl) FunctionBinding added in v0.20240920.1135249 

func (s BaseFunctionBindingImpl) FunctionBinding() BaseFunctionBindingImpl

type BaseFunctionPropertiesImpl added in v0.20240920.1135249 

type BaseFunctionPropertiesImpl struct {
	Etag       *string                `json:"etag,omitempty"`
	Properties *FunctionConfiguration `json:"properties,omitempty"`
	Type       string                 `json:"type"`
}

func (BaseFunctionPropertiesImpl) FunctionProperties added in v0.20240920.1135249 

func (s BaseFunctionPropertiesImpl) FunctionProperties() BaseFunctionPropertiesImpl

type BaseInputPropertiesImpl added in v0.20240920.1135249 

type BaseInputPropertiesImpl struct {
	Compression       *Compression              `json:"compression,omitempty"`
	Diagnostics       *Diagnostics              `json:"diagnostics,omitempty"`
	Etag              *string                   `json:"etag,omitempty"`
	PartitionKey      *string                   `json:"partitionKey,omitempty"`
	Serialization     Serialization             `json:"serialization"`
	Type              string                    `json:"type"`
	WatermarkSettings *InputWatermarkProperties `json:"watermarkSettings,omitempty"`
}

func (BaseInputPropertiesImpl) InputProperties added in v0.20240920.1135249 

func (s BaseInputPropertiesImpl) InputProperties() BaseInputPropertiesImpl

func (*BaseInputPropertiesImpl) UnmarshalJSON added in v0.20240920.1135249 

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

type BaseOutputDataSourceImpl added in v0.20240920.1135249 

type BaseOutputDataSourceImpl struct {
	Type string `json:"type"`
}

func (BaseOutputDataSourceImpl) OutputDataSource added in v0.20240920.1135249 

func (s BaseOutputDataSourceImpl) OutputDataSource() BaseOutputDataSourceImpl

type BaseReferenceInputDataSourceImpl added in v0.20240920.1135249 

type BaseReferenceInputDataSourceImpl struct {
	Type string `json:"type"`
}

func (BaseReferenceInputDataSourceImpl) ReferenceInputDataSource added in v0.20240920.1135249 

func (s BaseReferenceInputDataSourceImpl) ReferenceInputDataSource() BaseReferenceInputDataSourceImpl

type BaseSerializationImpl added in v0.20240920.1135249 

type BaseSerializationImpl struct {
	Type EventSerializationType `json:"type"`
}

func (BaseSerializationImpl) Serialization added in v0.20240920.1135249 

func (s BaseSerializationImpl) Serialization() BaseSerializationImpl

type BaseStreamInputDataSourceImpl added in v0.20240920.1135249 

type BaseStreamInputDataSourceImpl struct {
	Type string `json:"type"`
}

func (BaseStreamInputDataSourceImpl) StreamInputDataSource added in v0.20240920.1135249 

func (s BaseStreamInputDataSourceImpl) StreamInputDataSource() BaseStreamInputDataSourceImpl

type BlobOutputDataSource 

type BlobOutputDataSource struct {
	Properties *BlobOutputDataSourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (BlobOutputDataSource) MarshalJSON 

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

func (BlobOutputDataSource) OutputDataSource added in v0.20240920.1135249 

func (s BlobOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type BlobOutputDataSourceProperties 

type BlobOutputDataSourceProperties struct {
	AuthenticationMode *AuthenticationMode `json:"authenticationMode,omitempty"`
	BlobPathPrefix     *string             `json:"blobPathPrefix,omitempty"`
	BlobWriteMode      *BlobWriteMode      `json:"blobWriteMode,omitempty"`
	Container          *string             `json:"container,omitempty"`
	DateFormat         *string             `json:"dateFormat,omitempty"`
	PathPattern        *string             `json:"pathPattern,omitempty"`
	StorageAccounts    *[]StorageAccount   `json:"storageAccounts,omitempty"`
	TimeFormat         *string             `json:"timeFormat,omitempty"`
}

type BlobReferenceInputDataSource 

type BlobReferenceInputDataSource struct {
	Properties *BlobReferenceInputDataSourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (BlobReferenceInputDataSource) MarshalJSON 

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

func (BlobReferenceInputDataSource) ReferenceInputDataSource added in v0.20240920.1135249 

func (s BlobReferenceInputDataSource) ReferenceInputDataSource() BaseReferenceInputDataSourceImpl

type BlobReferenceInputDataSourceProperties 

type BlobReferenceInputDataSourceProperties struct {
	AuthenticationMode       *AuthenticationMode `json:"authenticationMode,omitempty"`
	BlobName                 *string             `json:"blobName,omitempty"`
	Container                *string             `json:"container,omitempty"`
	DateFormat               *string             `json:"dateFormat,omitempty"`
	DeltaPathPattern         *string             `json:"deltaPathPattern,omitempty"`
	DeltaSnapshotRefreshRate *string             `json:"deltaSnapshotRefreshRate,omitempty"`
	FullSnapshotRefreshRate  *string             `json:"fullSnapshotRefreshRate,omitempty"`
	PathPattern              *string             `json:"pathPattern,omitempty"`
	SourcePartitionCount     *int64              `json:"sourcePartitionCount,omitempty"`
	StorageAccounts          *[]StorageAccount   `json:"storageAccounts,omitempty"`
	TimeFormat               *string             `json:"timeFormat,omitempty"`
}

type BlobStreamInputDataSource 

type BlobStreamInputDataSource struct {
	Properties *BlobStreamInputDataSourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (BlobStreamInputDataSource) MarshalJSON 

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

func (BlobStreamInputDataSource) StreamInputDataSource added in v0.20240920.1135249 

func (s BlobStreamInputDataSource) StreamInputDataSource() BaseStreamInputDataSourceImpl

type BlobStreamInputDataSourceProperties 

type BlobStreamInputDataSourceProperties struct {
	AuthenticationMode   *AuthenticationMode `json:"authenticationMode,omitempty"`
	Container            *string             `json:"container,omitempty"`
	DateFormat           *string             `json:"dateFormat,omitempty"`
	PathPattern          *string             `json:"pathPattern,omitempty"`
	SourcePartitionCount *int64              `json:"sourcePartitionCount,omitempty"`
	StorageAccounts      *[]StorageAccount   `json:"storageAccounts,omitempty"`
	TimeFormat           *string             `json:"timeFormat,omitempty"`
}

type BlobWriteMode 

type BlobWriteMode string
const (
	BlobWriteModeAppend BlobWriteMode = "Append"
	BlobWriteModeOnce   BlobWriteMode = "Once"
)

func (*BlobWriteMode) UnmarshalJSON added in v0.20240208.1095436 

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

type CSharpFunctionBinding 

type CSharpFunctionBinding struct {
	Properties *CSharpFunctionBindingProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (CSharpFunctionBinding) FunctionBinding added in v0.20240920.1135249 

func (s CSharpFunctionBinding) FunctionBinding() BaseFunctionBindingImpl

func (CSharpFunctionBinding) MarshalJSON 

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

type CSharpFunctionBindingProperties 

type CSharpFunctionBindingProperties struct {
	Class      *string     `json:"class,omitempty"`
	DllPath    *string     `json:"dllPath,omitempty"`
	Method     *string     `json:"method,omitempty"`
	UpdateMode *UpdateMode `json:"updateMode,omitempty"`
}

type ClusterInfo 

type ClusterInfo struct {
	Id *string `json:"id,omitempty"`
}

type CompatibilityLevel 

type CompatibilityLevel string
const (
	CompatibilityLevelOnePointTwo  CompatibilityLevel = "1.2"
	CompatibilityLevelOnePointZero CompatibilityLevel = "1.0"
)

func (*CompatibilityLevel) UnmarshalJSON added in v0.20240208.1095436 

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

type CompileQuery 

type CompileQuery struct {
	CompatibilityLevel *CompatibilityLevel `json:"compatibilityLevel,omitempty"`
	Functions          *[]QueryFunction    `json:"functions,omitempty"`
	Inputs             *[]QueryInput       `json:"inputs,omitempty"`
	JobType            JobType             `json:"jobType"`
	Query              string              `json:"query"`
}

type CompileQueryOperationResponse 

type CompileQueryOperationResponse struct {
	HttpResponse *http.Response
	OData        *odata.OData
	Model        *QueryCompilationResult
}

type Compression 

type Compression struct {
	Type CompressionType `json:"type"`
}

type CompressionType 

type CompressionType string
const (
	CompressionTypeDeflate CompressionType = "Deflate"
	CompressionTypeGZip    CompressionType = "GZip"
	CompressionTypeNone    CompressionType = "None"
)

func (*CompressionType) UnmarshalJSON added in v0.20240208.1095436 

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

type ContentStoragePolicy 

type ContentStoragePolicy string
const (
	ContentStoragePolicyJobStorageAccount ContentStoragePolicy = "JobStorageAccount"
	ContentStoragePolicySystemAccount     ContentStoragePolicy = "SystemAccount"
)

func (*ContentStoragePolicy) UnmarshalJSON added in v0.20240208.1095436 

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

type CsvSerialization 

type CsvSerialization struct {
	Properties *CsvSerializationProperties `json:"properties,omitempty"`

	Type EventSerializationType `json:"type"`
}

func (CsvSerialization) MarshalJSON 

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

func (CsvSerialization) Serialization added in v0.20240920.1135249 

func (s CsvSerialization) Serialization() BaseSerializationImpl

type CsvSerializationProperties 

type CsvSerializationProperties struct {
	Encoding       *Encoding `json:"encoding,omitempty"`
	FieldDelimiter *string   `json:"fieldDelimiter,omitempty"`
}

type CustomClrSerialization 

type CustomClrSerialization struct {
	Properties *CustomClrSerializationProperties `json:"properties,omitempty"`

	Type EventSerializationType `json:"type"`
}

func (CustomClrSerialization) MarshalJSON 

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

func (CustomClrSerialization) Serialization added in v0.20240920.1135249 

func (s CustomClrSerialization) Serialization() BaseSerializationImpl

type CustomClrSerializationProperties 

type CustomClrSerializationProperties struct {
	SerializationClassName *string `json:"serializationClassName,omitempty"`
	SerializationDllPath   *string `json:"serializationDllPath,omitempty"`
}

type DeltaSerialization 

type DeltaSerialization struct {
	Properties *DeltaSerializationProperties `json:"properties,omitempty"`

	Type EventSerializationType `json:"type"`
}

func (DeltaSerialization) MarshalJSON 

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

func (DeltaSerialization) Serialization added in v0.20240920.1135249 

func (s DeltaSerialization) Serialization() BaseSerializationImpl

type DeltaSerializationProperties 

type DeltaSerializationProperties struct {
	DeltaTablePath   string    `json:"deltaTablePath"`
	PartitionColumns *[]string `json:"partitionColumns,omitempty"`
}

type DiagnosticCondition 

type DiagnosticCondition struct {
	Code    *string `json:"code,omitempty"`
	Message *string `json:"message,omitempty"`
	Since   *string `json:"since,omitempty"`
}

type Diagnostics 

type Diagnostics struct {
	Conditions *[]DiagnosticCondition `json:"conditions,omitempty"`
}

type DocumentDbOutputDataSource 

type DocumentDbOutputDataSource struct {
	Properties *DocumentDbOutputDataSourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (DocumentDbOutputDataSource) MarshalJSON 

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

func (DocumentDbOutputDataSource) OutputDataSource added in v0.20240920.1135249 

func (s DocumentDbOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type DocumentDbOutputDataSourceProperties 

type DocumentDbOutputDataSourceProperties struct {
	AccountId             *string             `json:"accountId,omitempty"`
	AccountKey            *string             `json:"accountKey,omitempty"`
	AuthenticationMode    *AuthenticationMode `json:"authenticationMode,omitempty"`
	CollectionNamePattern *string             `json:"collectionNamePattern,omitempty"`
	Database              *string             `json:"database,omitempty"`
	DocumentId            *string             `json:"documentId,omitempty"`
	PartitionKey          *string             `json:"partitionKey,omitempty"`
}

type Encoding 

type Encoding string
const (
	EncodingUTFEight Encoding = "UTF8"
)

func (*Encoding) UnmarshalJSON added in v0.20240208.1095436 

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

type ErrorDetails 

type ErrorDetails struct {
	Code    *string `json:"code,omitempty"`
	Message *string `json:"message,omitempty"`
	Target  *string `json:"target,omitempty"`
}

type ErrorError 

type ErrorError struct {
	Code    *string         `json:"code,omitempty"`
	Details *[]ErrorDetails `json:"details,omitempty"`
	Message *string         `json:"message,omitempty"`
	Target  *string         `json:"target,omitempty"`
}

type EventGridEventSchemaType 

type EventGridEventSchemaType string
const (
	EventGridEventSchemaTypeCloudEventSchema     EventGridEventSchemaType = "CloudEventSchema"
	EventGridEventSchemaTypeEventGridEventSchema EventGridEventSchemaType = "EventGridEventSchema"
)

func (*EventGridEventSchemaType) UnmarshalJSON added in v0.20240208.1095436 

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

type EventGridStreamInputDataSource 

type EventGridStreamInputDataSource struct {
	Properties *EventGridStreamInputDataSourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (EventGridStreamInputDataSource) MarshalJSON 

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

func (EventGridStreamInputDataSource) StreamInputDataSource added in v0.20240920.1135249 

func (s EventGridStreamInputDataSource) StreamInputDataSource() BaseStreamInputDataSourceImpl

type EventGridStreamInputDataSourceProperties 

type EventGridStreamInputDataSourceProperties struct {
	EventTypes      *[]string                        `json:"eventTypes,omitempty"`
	Schema          *EventGridEventSchemaType        `json:"schema,omitempty"`
	StorageAccounts *[]StorageAccount                `json:"storageAccounts,omitempty"`
	Subscriber      *EventHubV2StreamInputDataSource `json:"subscriber,omitempty"`
}

type EventHubOutputDataSource 

type EventHubOutputDataSource struct {
	Properties *EventHubOutputDataSourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (EventHubOutputDataSource) MarshalJSON 

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

func (EventHubOutputDataSource) OutputDataSource added in v0.20240920.1135249 

func (s EventHubOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type EventHubOutputDataSourceProperties 

type EventHubOutputDataSourceProperties struct {
	AuthenticationMode     *AuthenticationMode `json:"authenticationMode,omitempty"`
	EventHubName           *string             `json:"eventHubName,omitempty"`
	PartitionCount         *int64              `json:"partitionCount,omitempty"`
	PartitionKey           *string             `json:"partitionKey,omitempty"`
	PropertyColumns        *[]string           `json:"propertyColumns,omitempty"`
	ServiceBusNamespace    *string             `json:"serviceBusNamespace,omitempty"`
	SharedAccessPolicyKey  *string             `json:"sharedAccessPolicyKey,omitempty"`
	SharedAccessPolicyName *string             `json:"sharedAccessPolicyName,omitempty"`
}

type EventHubStreamInputDataSource 

type EventHubStreamInputDataSource struct {
	Properties *EventHubStreamInputDataSourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (EventHubStreamInputDataSource) MarshalJSON 

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

func (EventHubStreamInputDataSource) StreamInputDataSource added in v0.20240920.1135249 

func (s EventHubStreamInputDataSource) StreamInputDataSource() BaseStreamInputDataSourceImpl

type EventHubStreamInputDataSourceProperties 

type EventHubStreamInputDataSourceProperties struct {
	AuthenticationMode     *AuthenticationMode `json:"authenticationMode,omitempty"`
	ConsumerGroupName      *string             `json:"consumerGroupName,omitempty"`
	EventHubName           *string             `json:"eventHubName,omitempty"`
	PartitionCount         *int64              `json:"partitionCount,omitempty"`
	PrefetchCount          *int64              `json:"prefetchCount,omitempty"`
	ServiceBusNamespace    *string             `json:"serviceBusNamespace,omitempty"`
	SharedAccessPolicyKey  *string             `json:"sharedAccessPolicyKey,omitempty"`
	SharedAccessPolicyName *string             `json:"sharedAccessPolicyName,omitempty"`
}

type EventHubV2OutputDataSource 

type EventHubV2OutputDataSource struct {
	Properties *EventHubOutputDataSourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (EventHubV2OutputDataSource) MarshalJSON 

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

func (EventHubV2OutputDataSource) OutputDataSource added in v0.20240920.1135249 

func (s EventHubV2OutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type EventHubV2StreamInputDataSource 

type EventHubV2StreamInputDataSource struct {
	Properties *EventHubStreamInputDataSourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (EventHubV2StreamInputDataSource) MarshalJSON 

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

func (EventHubV2StreamInputDataSource) StreamInputDataSource added in v0.20240920.1135249 

func (s EventHubV2StreamInputDataSource) StreamInputDataSource() BaseStreamInputDataSourceImpl

type EventSerializationType 

type EventSerializationType string
const (
	EventSerializationTypeAvro      EventSerializationType = "Avro"
	EventSerializationTypeCsv       EventSerializationType = "Csv"
	EventSerializationTypeCustomClr EventSerializationType = "CustomClr"
	EventSerializationTypeDelta     EventSerializationType = "Delta"
	EventSerializationTypeJson      EventSerializationType = "Json"
	EventSerializationTypeParquet   EventSerializationType = "Parquet"
)

func (*EventSerializationType) UnmarshalJSON added in v0.20240208.1095436 

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

type EventsOutOfOrderPolicy 

type EventsOutOfOrderPolicy string
const (
	EventsOutOfOrderPolicyAdjust EventsOutOfOrderPolicy = "Adjust"
	EventsOutOfOrderPolicyDrop   EventsOutOfOrderPolicy = "Drop"
)

func (*EventsOutOfOrderPolicy) UnmarshalJSON added in v0.20240208.1095436 

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

type External 

type External struct {
	Container            *string               `json:"container,omitempty"`
	Path                 *string               `json:"path,omitempty"`
	RefreshConfiguration *RefreshConfiguration `json:"refreshConfiguration,omitempty"`
	StorageAccount       *StorageAccount       `json:"storageAccount,omitempty"`
}

type FileReferenceInputDataSource 

type FileReferenceInputDataSource struct {
	Properties *FileReferenceInputDataSourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (FileReferenceInputDataSource) MarshalJSON 

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

func (FileReferenceInputDataSource) ReferenceInputDataSource added in v0.20240920.1135249 

func (s FileReferenceInputDataSource) ReferenceInputDataSource() BaseReferenceInputDataSourceImpl

type FileReferenceInputDataSourceProperties 

type FileReferenceInputDataSourceProperties struct {
	Path *string `json:"path,omitempty"`
}

type Function 

type Function struct {
	Id         *string            `json:"id,omitempty"`
	Name       *string            `json:"name,omitempty"`
	Properties FunctionProperties `json:"properties"`
	Type       *string            `json:"type,omitempty"`
}

func (*Function) UnmarshalJSON 

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

type FunctionBinding 

type FunctionBinding interface {
	FunctionBinding() BaseFunctionBindingImpl
}

func UnmarshalFunctionBindingImplementation added in v0.20240920.1135249 

func UnmarshalFunctionBindingImplementation(input []byte) (FunctionBinding, error)

type FunctionConfiguration 

type FunctionConfiguration struct {
	Binding FunctionBinding  `json:"binding"`
	Inputs  *[]FunctionInput `json:"inputs,omitempty"`
	Output  *FunctionOutput  `json:"output,omitempty"`
}

func (*FunctionConfiguration) UnmarshalJSON 

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

type FunctionInput 

type FunctionInput struct {
	DataType                 *string `json:"dataType,omitempty"`
	IsConfigurationParameter *bool   `json:"isConfigurationParameter,omitempty"`
}

type FunctionOutput 

type FunctionOutput struct {
	DataType *string `json:"dataType,omitempty"`
}

type FunctionProperties 

type FunctionProperties interface {
	FunctionProperties() BaseFunctionPropertiesImpl
}

func UnmarshalFunctionPropertiesImplementation added in v0.20240920.1135249 

func UnmarshalFunctionPropertiesImplementation(input []byte) (FunctionProperties, error)

type GatewayMessageBusOutputDataSource 

type GatewayMessageBusOutputDataSource struct {
	Properties *GatewayMessageBusSourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (GatewayMessageBusOutputDataSource) MarshalJSON 

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

func (GatewayMessageBusOutputDataSource) OutputDataSource added in v0.20240920.1135249 

func (s GatewayMessageBusOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type GatewayMessageBusSourceProperties 

type GatewayMessageBusSourceProperties struct {
	Topic *string `json:"topic,omitempty"`
}

type GatewayMessageBusStreamInputDataSource 

type GatewayMessageBusStreamInputDataSource struct {
	Properties *GatewayMessageBusSourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (GatewayMessageBusStreamInputDataSource) MarshalJSON 

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

func (GatewayMessageBusStreamInputDataSource) StreamInputDataSource added in v0.20240920.1135249 

func (s GatewayMessageBusStreamInputDataSource) StreamInputDataSource() BaseStreamInputDataSourceImpl

type Input 

type Input struct {
	Id         *string         `json:"id,omitempty"`
	Name       *string         `json:"name,omitempty"`
	Properties InputProperties `json:"properties"`
	Type       *string         `json:"type,omitempty"`
}

func (*Input) UnmarshalJSON 

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

type InputProperties 

type InputProperties interface {
	InputProperties() BaseInputPropertiesImpl
}

func UnmarshalInputPropertiesImplementation added in v0.20240920.1135249 

func UnmarshalInputPropertiesImplementation(input []byte) (InputProperties, error)

type InputWatermarkMode 

type InputWatermarkMode string
const (
	InputWatermarkModeNone          InputWatermarkMode = "None"
	InputWatermarkModeReadWatermark InputWatermarkMode = "ReadWatermark"
)

func (*InputWatermarkMode) UnmarshalJSON added in v0.20240208.1095436 

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

type InputWatermarkProperties 

type InputWatermarkProperties struct {
	WatermarkMode *InputWatermarkMode `json:"watermarkMode,omitempty"`
}

type IoTHubStreamInputDataSource 

type IoTHubStreamInputDataSource struct {
	Properties *IoTHubStreamInputDataSourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (IoTHubStreamInputDataSource) MarshalJSON 

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

func (IoTHubStreamInputDataSource) StreamInputDataSource added in v0.20240920.1135249 

func (s IoTHubStreamInputDataSource) StreamInputDataSource() BaseStreamInputDataSourceImpl

type IoTHubStreamInputDataSourceProperties 

type IoTHubStreamInputDataSourceProperties struct {
	ConsumerGroupName      *string `json:"consumerGroupName,omitempty"`
	Endpoint               *string `json:"endpoint,omitempty"`
	IotHubNamespace        *string `json:"iotHubNamespace,omitempty"`
	SharedAccessPolicyKey  *string `json:"sharedAccessPolicyKey,omitempty"`
	SharedAccessPolicyName *string `json:"sharedAccessPolicyName,omitempty"`
}

type JavaScriptFunctionBinding 

type JavaScriptFunctionBinding struct {
	Properties *JavaScriptFunctionBindingProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (JavaScriptFunctionBinding) FunctionBinding added in v0.20240920.1135249 

func (s JavaScriptFunctionBinding) FunctionBinding() BaseFunctionBindingImpl

func (JavaScriptFunctionBinding) MarshalJSON 

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

type JavaScriptFunctionBindingProperties 

type JavaScriptFunctionBindingProperties struct {
	Script *string `json:"script,omitempty"`
}

type JobStorageAccount 

type JobStorageAccount struct {
	AccountKey         *string             `json:"accountKey,omitempty"`
	AccountName        *string             `json:"accountName,omitempty"`
	AuthenticationMode *AuthenticationMode `json:"authenticationMode,omitempty"`
}

type JobType 

type JobType string
const (
	JobTypeCloud JobType = "Cloud"
	JobTypeEdge  JobType = "Edge"
)

func (*JobType) UnmarshalJSON added in v0.20240208.1095436 

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

type JsonOutputSerializationFormat 

type JsonOutputSerializationFormat string
const (
	JsonOutputSerializationFormatArray         JsonOutputSerializationFormat = "Array"
	JsonOutputSerializationFormatLineSeparated JsonOutputSerializationFormat = "LineSeparated"
)

func (*JsonOutputSerializationFormat) UnmarshalJSON added in v0.20240208.1095436 

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

type JsonSerialization 

type JsonSerialization struct {
	Properties *JsonSerializationProperties `json:"properties,omitempty"`

	Type EventSerializationType `json:"type"`
}

func (JsonSerialization) MarshalJSON 

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

func (JsonSerialization) Serialization added in v0.20240920.1135249 

func (s JsonSerialization) Serialization() BaseSerializationImpl

type JsonSerializationProperties 

type JsonSerializationProperties struct {
	Encoding *Encoding                      `json:"encoding,omitempty"`
	Format   *JsonOutputSerializationFormat `json:"format,omitempty"`
}

type LastOutputEventTimestamp 

type LastOutputEventTimestamp struct {
	LastOutputEventTime *string `json:"lastOutputEventTime,omitempty"`
	LastUpdateTime      *string `json:"lastUpdateTime,omitempty"`
}

type ListQuotasOperationResponse 

type ListQuotasOperationResponse struct {
	HttpResponse *http.Response
	OData        *odata.OData
	Model        *SubscriptionQuotasListResult
}

type LocationId 

type LocationId struct {
	SubscriptionId string
	LocationName   string
}

LocationId is a struct representing the Resource ID for a Location

func NewLocationID 

func NewLocationID(subscriptionId string, locationName string) LocationId

NewLocationID returns a new LocationId struct

func ParseLocationID 

func ParseLocationID(input string) (*LocationId, error)

ParseLocationID parses 'input' into a LocationId

func ParseLocationIDInsensitively 

func ParseLocationIDInsensitively(input string) (*LocationId, error)

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

func (*LocationId) FromParseResult 

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

func (LocationId) ID 

func (id LocationId) ID() string

ID returns the formatted Location ID

func (LocationId) Segments 

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

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

func (LocationId) String 

func (id LocationId) String() string

String returns a human-readable description of this Location ID

type Output 

type Output struct {
	Id         *string           `json:"id,omitempty"`
	Name       *string           `json:"name,omitempty"`
	Properties *OutputProperties `json:"properties,omitempty"`
	Type       *string           `json:"type,omitempty"`
}

type OutputDataSource 

type OutputDataSource interface {
	OutputDataSource() BaseOutputDataSourceImpl
}

func UnmarshalOutputDataSourceImplementation added in v0.20240920.1135249 

func UnmarshalOutputDataSourceImplementation(input []byte) (OutputDataSource, error)

type OutputErrorPolicy 

type OutputErrorPolicy string
const (
	OutputErrorPolicyDrop OutputErrorPolicy = "Drop"
	OutputErrorPolicyStop OutputErrorPolicy = "Stop"
)

func (*OutputErrorPolicy) UnmarshalJSON added in v0.20240208.1095436 

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

type OutputProperties 

type OutputProperties struct {
	Datasource                OutputDataSource            `json:"datasource"`
	Diagnostics               *Diagnostics                `json:"diagnostics,omitempty"`
	Etag                      *string                     `json:"etag,omitempty"`
	LastOutputEventTimestamps *[]LastOutputEventTimestamp `json:"lastOutputEventTimestamps,omitempty"`
	Serialization             Serialization               `json:"serialization"`
	SizeWindow                *int64                      `json:"sizeWindow,omitempty"`
	TimeWindow                *string                     `json:"timeWindow,omitempty"`
	WatermarkSettings         *OutputWatermarkProperties  `json:"watermarkSettings,omitempty"`
}

func (*OutputProperties) UnmarshalJSON 

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

type OutputStartMode 

type OutputStartMode string
const (
	OutputStartModeCustomTime          OutputStartMode = "CustomTime"
	OutputStartModeJobStartTime        OutputStartMode = "JobStartTime"
	OutputStartModeLastOutputEventTime OutputStartMode = "LastOutputEventTime"
)

func (*OutputStartMode) UnmarshalJSON added in v0.20240208.1095436 

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

type OutputWatermarkMode 

type OutputWatermarkMode string
const (
	OutputWatermarkModeNone                                OutputWatermarkMode = "None"
	OutputWatermarkModeSendCurrentPartitionWatermark       OutputWatermarkMode = "SendCurrentPartitionWatermark"
	OutputWatermarkModeSendLowestWatermarkAcrossPartitions OutputWatermarkMode = "SendLowestWatermarkAcrossPartitions"
)

func (*OutputWatermarkMode) UnmarshalJSON added in v0.20240208.1095436 

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

type OutputWatermarkProperties 

type OutputWatermarkProperties struct {
	MaxWatermarkDifferenceAcrossPartitions *string              `json:"maxWatermarkDifferenceAcrossPartitions,omitempty"`
	WatermarkMode                          *OutputWatermarkMode `json:"watermarkMode,omitempty"`
}

type ParquetSerialization 

type ParquetSerialization struct {
	Properties *interface{} `json:"properties,omitempty"`

	Type EventSerializationType `json:"type"`
}

func (ParquetSerialization) MarshalJSON 

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

func (ParquetSerialization) Serialization added in v0.20240920.1135249 

func (s ParquetSerialization) Serialization() BaseSerializationImpl

type PostgreSQLDataSourceProperties 

type PostgreSQLDataSourceProperties struct {
	AuthenticationMode *AuthenticationMode `json:"authenticationMode,omitempty"`
	Database           *string             `json:"database,omitempty"`
	MaxWriterCount     *float64            `json:"maxWriterCount,omitempty"`
	Password           *string             `json:"password,omitempty"`
	Server             *string             `json:"server,omitempty"`
	Table              *string             `json:"table,omitempty"`
	User               *string             `json:"user,omitempty"`
}

type PostgreSQLOutputDataSource 

type PostgreSQLOutputDataSource struct {
	Properties *PostgreSQLDataSourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (PostgreSQLOutputDataSource) MarshalJSON 

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

func (PostgreSQLOutputDataSource) OutputDataSource added in v0.20240920.1135249 

func (s PostgreSQLOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type PowerBIOutputDataSource 

type PowerBIOutputDataSource struct {
	Properties *PowerBIOutputDataSourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (PowerBIOutputDataSource) MarshalJSON 

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

func (PowerBIOutputDataSource) OutputDataSource added in v0.20240920.1135249 

func (s PowerBIOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type PowerBIOutputDataSourceProperties 

type PowerBIOutputDataSourceProperties struct {
	AuthenticationMode     *AuthenticationMode `json:"authenticationMode,omitempty"`
	Dataset                *string             `json:"dataset,omitempty"`
	GroupId                *string             `json:"groupId,omitempty"`
	GroupName              *string             `json:"groupName,omitempty"`
	RefreshToken           *string             `json:"refreshToken,omitempty"`
	Table                  *string             `json:"table,omitempty"`
	TokenUserDisplayName   *string             `json:"tokenUserDisplayName,omitempty"`
	TokenUserPrincipalName *string             `json:"tokenUserPrincipalName,omitempty"`
}

type QueryCompilationError 

type QueryCompilationError struct {
	EndColumn   *int64  `json:"endColumn,omitempty"`
	EndLine     *int64  `json:"endLine,omitempty"`
	IsGlobal    *bool   `json:"isGlobal,omitempty"`
	Message     *string `json:"message,omitempty"`
	StartColumn *int64  `json:"startColumn,omitempty"`
	StartLine   *int64  `json:"startLine,omitempty"`
}

type QueryCompilationResult 

type QueryCompilationResult struct {
	Errors    *[]QueryCompilationError `json:"errors,omitempty"`
	Functions *[]string                `json:"functions,omitempty"`
	Inputs    *[]string                `json:"inputs,omitempty"`
	Outputs   *[]string                `json:"outputs,omitempty"`
	Warnings  *[]string                `json:"warnings,omitempty"`
}

type QueryFunction 

type QueryFunction struct {
	BindingType string          `json:"bindingType"`
	Inputs      []FunctionInput `json:"inputs"`
	Name        string          `json:"name"`
	Output      FunctionOutput  `json:"output"`
	Type        string          `json:"type"`
}

type QueryInput 

type QueryInput struct {
	Name string `json:"name"`
	Type string `json:"type"`
}

type QueryTestingResult 

type QueryTestingResult struct {
	Error     *ErrorError               `json:"error,omitempty"`
	OutputUri *string                   `json:"outputUri,omitempty"`
	Status    *QueryTestingResultStatus `json:"status,omitempty"`
}

type QueryTestingResultStatus 

type QueryTestingResultStatus string
const (
	QueryTestingResultStatusCompilerError QueryTestingResultStatus = "CompilerError"
	QueryTestingResultStatusRuntimeError  QueryTestingResultStatus = "RuntimeError"
	QueryTestingResultStatusStarted       QueryTestingResultStatus = "Started"
	QueryTestingResultStatusSuccess       QueryTestingResultStatus = "Success"
	QueryTestingResultStatusTimeout       QueryTestingResultStatus = "Timeout"
	QueryTestingResultStatusUnknownError  QueryTestingResultStatus = "UnknownError"
)

func (*QueryTestingResultStatus) UnmarshalJSON added in v0.20240208.1095436 

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

type RawFunctionBindingImpl 

type RawFunctionBindingImpl struct {
	Type   string
	Values map[string]interface{}
	// contains filtered or unexported fields
}

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

func (RawFunctionBindingImpl) FunctionBinding added in v0.20240920.1135249 

func (s RawFunctionBindingImpl) FunctionBinding() BaseFunctionBindingImpl

type RawFunctionPropertiesImpl 

type RawFunctionPropertiesImpl struct {
	Type   string
	Values map[string]interface{}
	// contains filtered or unexported fields
}

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

func (RawFunctionPropertiesImpl) FunctionProperties added in v0.20240920.1135249 

func (s RawFunctionPropertiesImpl) FunctionProperties() BaseFunctionPropertiesImpl

type RawInputDatasourceProperties 

type RawInputDatasourceProperties struct {
	Payload    *string `json:"payload,omitempty"`
	PayloadUri *string `json:"payloadUri,omitempty"`
}

type RawInputPropertiesImpl 

type RawInputPropertiesImpl struct {
	Type   string
	Values map[string]interface{}
	// contains filtered or unexported fields
}

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

func (RawInputPropertiesImpl) InputProperties added in v0.20240920.1135249 

func (s RawInputPropertiesImpl) InputProperties() BaseInputPropertiesImpl

type RawOutputDataSourceImpl 

type RawOutputDataSourceImpl struct {
	Type   string
	Values map[string]interface{}
	// contains filtered or unexported fields
}

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

func (RawOutputDataSourceImpl) OutputDataSource added in v0.20240920.1135249 

func (s RawOutputDataSourceImpl) OutputDataSource() BaseOutputDataSourceImpl

type RawOutputDatasource 

type RawOutputDatasource struct {
	Properties *RawOutputDatasourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (RawOutputDatasource) MarshalJSON 

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

func (RawOutputDatasource) OutputDataSource added in v0.20240920.1135249 

func (s RawOutputDatasource) OutputDataSource() BaseOutputDataSourceImpl

type RawOutputDatasourceProperties 

type RawOutputDatasourceProperties struct {
	PayloadUri *string `json:"payloadUri,omitempty"`
}

type RawReferenceInputDataSource 

type RawReferenceInputDataSource struct {
	Properties *RawInputDatasourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (RawReferenceInputDataSource) MarshalJSON 

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

func (RawReferenceInputDataSource) ReferenceInputDataSource added in v0.20240920.1135249 

func (s RawReferenceInputDataSource) ReferenceInputDataSource() BaseReferenceInputDataSourceImpl

type RawReferenceInputDataSourceImpl 

type RawReferenceInputDataSourceImpl struct {
	Type   string
	Values map[string]interface{}
	// contains filtered or unexported fields
}

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

func (RawReferenceInputDataSourceImpl) ReferenceInputDataSource added in v0.20240920.1135249 

func (s RawReferenceInputDataSourceImpl) ReferenceInputDataSource() BaseReferenceInputDataSourceImpl

type RawSerializationImpl 

type RawSerializationImpl struct {
	Type   string
	Values map[string]interface{}
	// contains filtered or unexported fields
}

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

func (RawSerializationImpl) Serialization added in v0.20240920.1135249 

func (s RawSerializationImpl) Serialization() BaseSerializationImpl

type RawStreamInputDataSource 

type RawStreamInputDataSource struct {
	Properties *RawInputDatasourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (RawStreamInputDataSource) MarshalJSON 

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

func (RawStreamInputDataSource) StreamInputDataSource added in v0.20240920.1135249 

func (s RawStreamInputDataSource) StreamInputDataSource() BaseStreamInputDataSourceImpl

type RawStreamInputDataSourceImpl 

type RawStreamInputDataSourceImpl struct {
	Type   string
	Values map[string]interface{}
	// contains filtered or unexported fields
}

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

func (RawStreamInputDataSourceImpl) StreamInputDataSource added in v0.20240920.1135249 

func (s RawStreamInputDataSourceImpl) StreamInputDataSource() BaseStreamInputDataSourceImpl

type ReferenceInputDataSource 

type ReferenceInputDataSource interface {
	ReferenceInputDataSource() BaseReferenceInputDataSourceImpl
}

func UnmarshalReferenceInputDataSourceImplementation added in v0.20240920.1135249 

func UnmarshalReferenceInputDataSourceImplementation(input []byte) (ReferenceInputDataSource, error)

type ReferenceInputProperties 

type ReferenceInputProperties struct {
	Datasource ReferenceInputDataSource `json:"datasource"`

	Compression       *Compression              `json:"compression,omitempty"`
	Diagnostics       *Diagnostics              `json:"diagnostics,omitempty"`
	Etag              *string                   `json:"etag,omitempty"`
	PartitionKey      *string                   `json:"partitionKey,omitempty"`
	Serialization     Serialization             `json:"serialization"`
	Type              string                    `json:"type"`
	WatermarkSettings *InputWatermarkProperties `json:"watermarkSettings,omitempty"`
}

func (ReferenceInputProperties) InputProperties added in v0.20240920.1135249 

func (s ReferenceInputProperties) InputProperties() BaseInputPropertiesImpl

func (ReferenceInputProperties) MarshalJSON 

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

func (*ReferenceInputProperties) UnmarshalJSON 

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

type RefreshConfiguration 

type RefreshConfiguration struct {
	DateFormat      *string                  `json:"dateFormat,omitempty"`
	PathPattern     *string                  `json:"pathPattern,omitempty"`
	RefreshInterval *string                  `json:"refreshInterval,omitempty"`
	RefreshType     *UpdatableUdfRefreshType `json:"refreshType,omitempty"`
	TimeFormat      *string                  `json:"timeFormat,omitempty"`
}

type RefreshType 

type RefreshType string
const (
	RefreshTypeRefreshPeriodicallyWithDelta RefreshType = "RefreshPeriodicallyWithDelta"
	RefreshTypeRefreshPeriodicallyWithFull  RefreshType = "RefreshPeriodicallyWithFull"
	RefreshTypeStatic                       RefreshType = "Static"
)

func (*RefreshType) UnmarshalJSON added in v0.20240208.1095436 

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

type SampleInput 

type SampleInput struct {
	CompatibilityLevel *string `json:"compatibilityLevel,omitempty"`
	DataLocale         *string `json:"dataLocale,omitempty"`
	EventsUri          *string `json:"eventsUri,omitempty"`
	Input              *Input  `json:"input,omitempty"`
}

type SampleInputOperationResponse 

type SampleInputOperationResponse struct {
	Poller       pollers.Poller
	HttpResponse *http.Response
	OData        *odata.OData
	Model        *SampleInputResult
}

type SampleInputResult 

type SampleInputResult struct {
	Diagnostics       *[]string                `json:"diagnostics,omitempty"`
	Error             *ErrorError              `json:"error,omitempty"`
	EventsDownloadUrl *string                  `json:"eventsDownloadUrl,omitempty"`
	LastArrivalTime   *string                  `json:"lastArrivalTime,omitempty"`
	Status            *SampleInputResultStatus `json:"status,omitempty"`
}

type SampleInputResultStatus 

type SampleInputResultStatus string
const (
	SampleInputResultStatusErrorConnectingToInput SampleInputResultStatus = "ErrorConnectingToInput"
	SampleInputResultStatusNoEventsFoundInRange   SampleInputResultStatus = "NoEventsFoundInRange"
	SampleInputResultStatusReadAllEventsInRange   SampleInputResultStatus = "ReadAllEventsInRange"
)

func (*SampleInputResultStatus) UnmarshalJSON added in v0.20240208.1095436 

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

type ScalarFunctionProperties 

type ScalarFunctionProperties struct {
	Etag       *string                `json:"etag,omitempty"`
	Properties *FunctionConfiguration `json:"properties,omitempty"`
	Type       string                 `json:"type"`
}

func (ScalarFunctionProperties) FunctionProperties added in v0.20240920.1135249 

func (s ScalarFunctionProperties) FunctionProperties() BaseFunctionPropertiesImpl

func (ScalarFunctionProperties) MarshalJSON 

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

type Serialization 

type Serialization interface {
	Serialization() BaseSerializationImpl
}

func UnmarshalSerializationImplementation added in v0.20240920.1135249 

func UnmarshalSerializationImplementation(input []byte) (Serialization, error)

type ServiceBusQueueOutputDataSource 

type ServiceBusQueueOutputDataSource struct {
	Properties *ServiceBusQueueOutputDataSourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (ServiceBusQueueOutputDataSource) MarshalJSON 

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

func (ServiceBusQueueOutputDataSource) OutputDataSource added in v0.20240920.1135249 

func (s ServiceBusQueueOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type ServiceBusQueueOutputDataSourceProperties 

type ServiceBusQueueOutputDataSourceProperties struct {
	AuthenticationMode     *AuthenticationMode `json:"authenticationMode,omitempty"`
	PropertyColumns        *[]string           `json:"propertyColumns,omitempty"`
	QueueName              *string             `json:"queueName,omitempty"`
	ServiceBusNamespace    *string             `json:"serviceBusNamespace,omitempty"`
	SharedAccessPolicyKey  *string             `json:"sharedAccessPolicyKey,omitempty"`
	SharedAccessPolicyName *string             `json:"sharedAccessPolicyName,omitempty"`
	SystemPropertyColumns  *interface{}        `json:"systemPropertyColumns,omitempty"`
}

type ServiceBusTopicOutputDataSource 

type ServiceBusTopicOutputDataSource struct {
	Properties *ServiceBusTopicOutputDataSourceProperties `json:"properties,omitempty"`

	Type string `json:"type"`
}

func (ServiceBusTopicOutputDataSource) MarshalJSON 

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

func (ServiceBusTopicOutputDataSource) OutputDataSource added in v0.20240920.1135249 

func (s ServiceBusTopicOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type ServiceBusTopicOutputDataSourceProperties 

type ServiceBusTopicOutputDataSourceProperties struct {
	AuthenticationMode     *AuthenticationMode `json:"authenticationMode,omitempty"`
	PropertyColumns        *[]string           `json:"propertyColumns,omitempty"`
	ServiceBusNamespace    *string             `json:"serviceBusNamespace,omitempty"`
	SharedAccessPolicyKey  *string             `json:"sharedAccessPolicyKey,omitempty"`
	SharedAccessPolicyName *string             `json:"sharedAccessPolicyName,omitempty"`
	SystemPropertyColumns  *map[string]string  `json:"systemPropertyColumns,omitempty"`
	TopicName              *string             `json:"topicName,omitempty"`
}

type Sku 

type Sku struct {
	Capacity *int64   `json:"capacity,omitempty"`
	Name     *SkuName `json:"name,omitempty"`
}

type SkuName 

type SkuName string
const (
	SkuNameStandard SkuName = "Standard"
)

func (*SkuName) UnmarshalJSON added in v0.20240208.1095436 

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

type StorageAccount 

type StorageAccount struct {
	AccountKey         *string             `json:"accountKey,omitempty"`
	AccountName        *string             `json:"accountName,omitempty"`
	AuthenticationMode *AuthenticationMode `json:"authenticationMode,omitempty"`
}

type StreamInputDataSource 

type StreamInputDataSource interface {
	StreamInputDataSource() BaseStreamInputDataSourceImpl
}

func UnmarshalStreamInputDataSourceImplementation added in v0.20240920.1135249 

func UnmarshalStreamInputDataSourceImplementation(input []byte) (StreamInputDataSource, error)

type StreamInputProperties 

type StreamInputProperties struct {
	Datasource StreamInputDataSource `json:"datasource"`

	Compression       *Compression              `json:"compression,omitempty"`
	Diagnostics       *Diagnostics              `json:"diagnostics,omitempty"`
	Etag              *string                   `json:"etag,omitempty"`
	PartitionKey      *string                   `json:"partitionKey,omitempty"`
	Serialization     Serialization             `json:"serialization"`
	Type              string                    `json:"type"`
	WatermarkSettings *InputWatermarkProperties `json:"watermarkSettings,omitempty"`
}

func (StreamInputProperties) InputProperties added in v0.20240920.1135249 

func (s StreamInputProperties) InputProperties() BaseInputPropertiesImpl

func (StreamInputProperties) MarshalJSON 

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

func (*StreamInputProperties) UnmarshalJSON 

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

type StreamingJob 

type StreamingJob struct {
	Id         *string                           `json:"id,omitempty"`
	Identity   *identity.SystemOrUserAssignedMap `json:"identity,omitempty"`
	Location   *string                           `json:"location,omitempty"`
	Name       *string                           `json:"name,omitempty"`
	Properties *StreamingJobProperties           `json:"properties,omitempty"`
	Sku        *Sku                              `json:"sku,omitempty"`
	Tags       *map[string]string                `json:"tags,omitempty"`
	Type       *string                           `json:"type,omitempty"`
}

type StreamingJobProperties 

type StreamingJobProperties struct {
	Cluster                            *ClusterInfo            `json:"cluster,omitempty"`
	CompatibilityLevel                 *CompatibilityLevel     `json:"compatibilityLevel,omitempty"`
	ContentStoragePolicy               *ContentStoragePolicy   `json:"contentStoragePolicy,omitempty"`
	CreatedDate                        *string                 `json:"createdDate,omitempty"`
	DataLocale                         *string                 `json:"dataLocale,omitempty"`
	Etag                               *string                 `json:"etag,omitempty"`
	EventsLateArrivalMaxDelayInSeconds *int64                  `json:"eventsLateArrivalMaxDelayInSeconds,omitempty"`
	EventsOutOfOrderMaxDelayInSeconds  *int64                  `json:"eventsOutOfOrderMaxDelayInSeconds,omitempty"`
	EventsOutOfOrderPolicy             *EventsOutOfOrderPolicy `json:"eventsOutOfOrderPolicy,omitempty"`
	Externals                          *External               `json:"externals,omitempty"`
	Functions                          *[]Function             `json:"functions,omitempty"`
	Inputs                             *[]Input                `json:"inputs,omitempty"`
	JobId                              *string                 `json:"jobId,omitempty"`
	JobState                           *string                 `json:"jobState,omitempty"`
	JobStorageAccount                  *JobStorageAccount      `json:"jobStorageAccount,omitempty"`
	JobType                            *JobType                `json:"jobType,omitempty"`
	LastOutputEventTime                *string                 `json:"lastOutputEventTime,omitempty"`
	OutputErrorPolicy                  *OutputErrorPolicy      `json:"outputErrorPolicy,omitempty"`
	OutputStartMode                    *OutputStartMode        `json:"outputStartMode,omitempty"`
	OutputStartTime                    *string                 `json:"outputStartTime,omitempty"`
	Outputs                            *[]Output               `json:"outputs,omitempty"`
	ProvisioningState                  *string                 `json:"provisioningState,omitempty"`
	Sku                                *Sku                    `json:"sku,omitempty"`
	Transformation                     *Transformation         `json:"transformation,omitempty"`
}

func (*StreamingJobProperties) GetCreatedDateAsTime 

func (o *StreamingJobProperties) GetCreatedDateAsTime() (*time.Time, error)

func (*StreamingJobProperties) GetLastOutputEventTimeAsTime 

func (o *StreamingJobProperties) GetLastOutputEventTimeAsTime() (*time.Time, error)

func (*StreamingJobProperties) GetOutputStartTimeAsTime 

func (o *StreamingJobProperties) GetOutputStartTimeAsTime() (*time.Time, error)

func (*StreamingJobProperties) SetCreatedDateAsTime 

func (o *StreamingJobProperties) SetCreatedDateAsTime(input time.Time)

func (*StreamingJobProperties) SetLastOutputEventTimeAsTime 

func (o *StreamingJobProperties) SetLastOutputEventTimeAsTime(input time.Time)

func (*StreamingJobProperties) SetOutputStartTimeAsTime 

func (o *StreamingJobProperties) SetOutputStartTimeAsTime(input time.Time)

type SubscriptionQuota 

type SubscriptionQuota struct {
	Id         *string                      `json:"id,omitempty"`
	Name       *string                      `json:"name,omitempty"`
	Properties *SubscriptionQuotaProperties `json:"properties,omitempty"`
	Type       *string                      `json:"type,omitempty"`
}

type SubscriptionQuotaProperties 

type SubscriptionQuotaProperties struct {
	CurrentCount *int64 `json:"currentCount,omitempty"`
	MaxCount     *int64 `json:"maxCount,omitempty"`
}

type SubscriptionQuotasListResult 

type SubscriptionQuotasListResult struct {
	Value *[]SubscriptionQuota `json:"value,omitempty"`
}

type SubscriptionsClient 

type SubscriptionsClient struct {
	Client *resourcemanager.Client
}

func NewSubscriptionsClientWithBaseURI 

func NewSubscriptionsClientWithBaseURI(sdkApi sdkEnv.Api) (*SubscriptionsClient, error)

func (SubscriptionsClient) CompileQuery 

func (c SubscriptionsClient) CompileQuery(ctx context.Context, id LocationId, input CompileQuery) (result CompileQueryOperationResponse, err error)

CompileQuery ...

func (SubscriptionsClient) ListQuotas 

func (c SubscriptionsClient) ListQuotas(ctx context.Context, id LocationId) (result ListQuotasOperationResponse, err error)

ListQuotas ...

func (SubscriptionsClient) SampleInput 

func (c SubscriptionsClient) SampleInput(ctx context.Context, id LocationId, input SampleInput) (result SampleInputOperationResponse, err error)

SampleInput ...

func (SubscriptionsClient) SampleInputThenPoll 

func (c SubscriptionsClient) SampleInputThenPoll(ctx context.Context, id LocationId, input SampleInput) error

SampleInputThenPoll performs SampleInput then polls until it's completed

func (SubscriptionsClient) TestInput 

func (c SubscriptionsClient) TestInput(ctx context.Context, id LocationId, input TestInput) (result TestInputOperationResponse, err error)

TestInput ...

func (SubscriptionsClient) TestInputThenPoll 

func (c SubscriptionsClient) TestInputThenPoll(ctx context.Context, id LocationId, input TestInput) error

TestInputThenPoll performs TestInput then polls until it's completed

func (SubscriptionsClient) TestOutput 

func (c SubscriptionsClient) TestOutput(ctx context.Context, id LocationId, input TestOutput) (result TestOutputOperationResponse, err error)

TestOutput ...

func (SubscriptionsClient) TestOutputThenPoll 

func (c SubscriptionsClient) TestOutputThenPoll(ctx context.Context, id LocationId, input TestOutput) error

TestOutputThenPoll performs TestOutput then polls until it's completed

func (SubscriptionsClient) TestQuery 

func (c SubscriptionsClient) TestQuery(ctx context.Context, id LocationId, input TestQuery) (result TestQueryOperationResponse, err error)

TestQuery ...

func (SubscriptionsClient) TestQueryThenPoll 

func (c SubscriptionsClient) TestQueryThenPoll(ctx context.Context, id LocationId, input TestQuery) error

TestQueryThenPoll performs TestQuery then polls until it's completed

type TestDatasourceResult 

type TestDatasourceResult struct {
	Error  *ErrorError                 `json:"error,omitempty"`
	Status *TestDatasourceResultStatus `json:"status,omitempty"`
}

type TestDatasourceResultStatus 

type TestDatasourceResultStatus string
const (
	TestDatasourceResultStatusTestFailed    TestDatasourceResultStatus = "TestFailed"
	TestDatasourceResultStatusTestSucceeded TestDatasourceResultStatus = "TestSucceeded"
)

func (*TestDatasourceResultStatus) UnmarshalJSON added in v0.20240208.1095436 

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

type TestInput 

type TestInput struct {
	Input Input `json:"input"`
}

type TestInputOperationResponse 

type TestInputOperationResponse struct {
	Poller       pollers.Poller
	HttpResponse *http.Response
	OData        *odata.OData
	Model        *TestDatasourceResult
}

type TestOutput 

type TestOutput struct {
	Output Output `json:"output"`
}

type TestOutputOperationResponse 

type TestOutputOperationResponse struct {
	Poller       pollers.Poller
	HttpResponse *http.Response
	OData        *odata.OData
	Model        *TestDatasourceResult
}

type TestQuery 

type TestQuery struct {
	Diagnostics  *TestQueryDiagnostics `json:"diagnostics,omitempty"`
	StreamingJob StreamingJob          `json:"streamingJob"`
}

type TestQueryDiagnostics 

type TestQueryDiagnostics struct {
	Path     *string `json:"path,omitempty"`
	WriteUri string  `json:"writeUri"`
}

type TestQueryOperationResponse 

type TestQueryOperationResponse struct {
	Poller       pollers.Poller
	HttpResponse *http.Response
	OData        *odata.OData
	Model        *QueryTestingResult
}

type Transformation 

type Transformation struct {
	Id         *string                   `json:"id,omitempty"`
	Name       *string                   `json:"name,omitempty"`
	Properties *TransformationProperties `json:"properties,omitempty"`
	Type       *string                   `json:"type,omitempty"`
}

type TransformationProperties 

type TransformationProperties struct {
	Etag                *string  `json:"etag,omitempty"`
	Query               *string  `json:"query,omitempty"`
	StreamingUnits      *int64   `json:"streamingUnits,omitempty"`
	ValidStreamingUnits *[]int64 `json:"validStreamingUnits,omitempty"`
}

type UpdatableUdfRefreshType 

type UpdatableUdfRefreshType string
const (
	UpdatableUdfRefreshTypeBlocking    UpdatableUdfRefreshType = "Blocking"
	UpdatableUdfRefreshTypeNonblocking UpdatableUdfRefreshType = "Nonblocking"
)

func (*UpdatableUdfRefreshType) UnmarshalJSON added in v0.20240208.1095436 

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

type UpdateMode 

type UpdateMode string
const (
	UpdateModeRefreshable UpdateMode = "Refreshable"
	UpdateModeStatic      UpdateMode = "Static"
)

func (*UpdateMode) UnmarshalJSON added in v0.20240208.1095436 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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