streamingjobs

package
v0.20240715.1100358 Latest Latest
Warning

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

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

README

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

The streamingjobs SDK allows for interaction with the Azure Resource Manager Service 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-helpers/resourcemanager/commonids"
import "github.com/hashicorp/go-azure-sdk/resource-manager/streamanalytics/2021-10-01-preview/streamingjobs"

Client Initialization

client := streamingjobs.NewStreamingJobsClientWithBaseURI("https://management.azure.com")
client.Client.Authorizer = authorizer

Example Usage: StreamingJobsClient.CreateOrReplace

ctx := context.TODO()
id := streamingjobs.NewStreamingJobID("12345678-1234-9876-4563-123456789012", "example-resource-group", "streamingJobValue")

payload := streamingjobs.StreamingJob{
	// ...
}


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

Example Usage: StreamingJobsClient.Delete

ctx := context.TODO()
id := streamingjobs.NewStreamingJobID("12345678-1234-9876-4563-123456789012", "example-resource-group", "streamingJobValue")

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

Example Usage: StreamingJobsClient.Get

ctx := context.TODO()
id := streamingjobs.NewStreamingJobID("12345678-1234-9876-4563-123456789012", "example-resource-group", "streamingJobValue")

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

Example Usage: StreamingJobsClient.List

ctx := context.TODO()
id := commonids.NewSubscriptionID("12345678-1234-9876-4563-123456789012")

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

Example Usage: StreamingJobsClient.ListByResourceGroup

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

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

Example Usage: StreamingJobsClient.Scale

ctx := context.TODO()
id := streamingjobs.NewStreamingJobID("12345678-1234-9876-4563-123456789012", "example-resource-group", "streamingJobValue")

payload := streamingjobs.ScaleStreamingJobParameters{
	// ...
}


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

Example Usage: StreamingJobsClient.SkuList

ctx := context.TODO()
id := streamingjobs.NewStreamingJobID("12345678-1234-9876-4563-123456789012", "example-resource-group", "streamingJobValue")

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

Example Usage: StreamingJobsClient.Start

ctx := context.TODO()
id := streamingjobs.NewStreamingJobID("12345678-1234-9876-4563-123456789012", "example-resource-group", "streamingJobValue")

payload := streamingjobs.StartStreamingJobParameters{
	// ...
}


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

Example Usage: StreamingJobsClient.Stop

ctx := context.TODO()
id := streamingjobs.NewStreamingJobID("12345678-1234-9876-4563-123456789012", "example-resource-group", "streamingJobValue")

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

Example Usage: StreamingJobsClient.Update

ctx := context.TODO()
id := streamingjobs.NewStreamingJobID("12345678-1234-9876-4563-123456789012", "example-resource-group", "streamingJobValue")

payload := streamingjobs.StreamingJob{
	// ...
}


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

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 PossibleValuesForRefreshType

func PossibleValuesForRefreshType() []string

func PossibleValuesForResourceType

func PossibleValuesForResourceType() []string

func PossibleValuesForSkuCapacityScaleType

func PossibleValuesForSkuCapacityScaleType() []string

func PossibleValuesForSkuName

func PossibleValuesForSkuName() []string

func PossibleValuesForUpdatableUdfRefreshType

func PossibleValuesForUpdatableUdfRefreshType() []string

func PossibleValuesForUpdateMode

func PossibleValuesForUpdateMode() []string

func ValidateStreamingJobID

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

ValidateStreamingJobID checks that 'input' can be parsed as a Streaming Job ID

Types

type AggregateFunctionProperties

type AggregateFunctionProperties struct {

	// Fields inherited from FunctionProperties
	Etag       *string                `json:"etag,omitempty"`
	Properties *FunctionConfiguration `json:"properties,omitempty"`
}

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"`
}

func (AvroSerialization) MarshalJSON

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

type AzureDataExplorerOutputDataSource

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

func (AzureDataExplorerOutputDataSource) MarshalJSON

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

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"`
}

func (AzureDataLakeStoreOutputDataSource) MarshalJSON

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

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"`
}

func (AzureFunctionOutputDataSource) MarshalJSON

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

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"`
}

func (AzureMachineLearningServiceFunctionBinding) MarshalJSON

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"`
}

func (AzureMachineLearningStudioFunctionBinding) MarshalJSON

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"`
}

func (AzureSqlDatabaseOutputDataSource) MarshalJSON

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

type AzureSqlReferenceInputDataSource

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

func (AzureSqlReferenceInputDataSource) MarshalJSON

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

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"`
}

func (AzureSynapseOutputDataSource) MarshalJSON

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

type AzureTableOutputDataSource

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

func (AzureTableOutputDataSource) MarshalJSON

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

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 BlobOutputDataSource

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

func (BlobOutputDataSource) MarshalJSON

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

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"`
}

func (BlobReferenceInputDataSource) MarshalJSON

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

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"`
}

func (BlobStreamInputDataSource) MarshalJSON

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

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"`
}

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 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 CreateOrReplaceOperationOptions

type CreateOrReplaceOperationOptions struct {
	IfMatch     *string
	IfNoneMatch *string
}

func DefaultCreateOrReplaceOperationOptions

func DefaultCreateOrReplaceOperationOptions() CreateOrReplaceOperationOptions

func (CreateOrReplaceOperationOptions) ToHeaders added in v0.20240208.1095436

func (CreateOrReplaceOperationOptions) ToOData added in v0.20240208.1095436

func (CreateOrReplaceOperationOptions) ToQuery added in v0.20240208.1095436

type CreateOrReplaceOperationResponse

type CreateOrReplaceOperationResponse struct {
	Poller       pollers.Poller
	HttpResponse *http.Response
	OData        *odata.OData
	Model        *StreamingJob
}

type CsvSerialization

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

func (CsvSerialization) MarshalJSON

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

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"`
}

func (CustomClrSerialization) MarshalJSON

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

type CustomClrSerializationProperties

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

type DeleteOperationResponse

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

type DeltaSerialization

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

func (DeltaSerialization) MarshalJSON

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

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"`
}

func (DocumentDbOutputDataSource) MarshalJSON

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

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 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"`
}

func (EventGridStreamInputDataSource) MarshalJSON

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

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"`
}

func (EventHubOutputDataSource) MarshalJSON

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

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"`
}

func (EventHubStreamInputDataSource) MarshalJSON

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

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"`
}

func (EventHubV2OutputDataSource) MarshalJSON

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

type EventHubV2StreamInputDataSource

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

func (EventHubV2StreamInputDataSource) MarshalJSON

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

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"`
}

func (FileReferenceInputDataSource) MarshalJSON

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

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 {
}

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 {
}

type GatewayMessageBusOutputDataSource

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

func (GatewayMessageBusOutputDataSource) MarshalJSON

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

type GatewayMessageBusSourceProperties

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

type GatewayMessageBusStreamInputDataSource

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

func (GatewayMessageBusStreamInputDataSource) MarshalJSON

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

type GetOperationOptions

type GetOperationOptions struct {
	Expand *string
}

func DefaultGetOperationOptions

func DefaultGetOperationOptions() GetOperationOptions

func (GetOperationOptions) ToHeaders added in v0.20240208.1095436

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

func (GetOperationOptions) ToOData added in v0.20240208.1095436

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

func (GetOperationOptions) ToQuery added in v0.20240208.1095436

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

type GetOperationResponse

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

type GetStreamingJobSkuResult

type GetStreamingJobSkuResult struct {
	Capacity     *SkuCapacity                 `json:"capacity,omitempty"`
	ResourceType *ResourceType                `json:"resourceType,omitempty"`
	Sku          *GetStreamingJobSkuResultSku `json:"sku,omitempty"`
}

type GetStreamingJobSkuResultOperationPredicate

type GetStreamingJobSkuResultOperationPredicate struct {
}

func (GetStreamingJobSkuResultOperationPredicate) Matches

type GetStreamingJobSkuResultSku

type GetStreamingJobSkuResultSku struct {
	Name *SkuName `json:"name,omitempty"`
}

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 {
}

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"`
}

func (IoTHubStreamInputDataSource) MarshalJSON

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

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"`
}

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"`
}

func (JsonSerialization) MarshalJSON

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

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 ListByResourceGroupCompleteResult

type ListByResourceGroupCompleteResult struct {
	LatestHttpResponse *http.Response
	Items              []StreamingJob
}

type ListByResourceGroupCustomPager added in v0.20240628.1153531

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

type ListByResourceGroupOperationOptions

type ListByResourceGroupOperationOptions struct {
	Expand *string
}

func DefaultListByResourceGroupOperationOptions

func DefaultListByResourceGroupOperationOptions() ListByResourceGroupOperationOptions

func (ListByResourceGroupOperationOptions) ToHeaders added in v0.20240208.1095436

func (ListByResourceGroupOperationOptions) ToOData added in v0.20240208.1095436

func (ListByResourceGroupOperationOptions) ToQuery added in v0.20240208.1095436

type ListByResourceGroupOperationResponse

type ListByResourceGroupOperationResponse struct {
	HttpResponse *http.Response
	OData        *odata.OData
	Model        *[]StreamingJob
}

type ListCompleteResult

type ListCompleteResult struct {
	LatestHttpResponse *http.Response
	Items              []StreamingJob
}

type ListCustomPager added in v0.20240628.1153531

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

type ListOperationOptions

type ListOperationOptions struct {
	Expand *string
}

func DefaultListOperationOptions

func DefaultListOperationOptions() ListOperationOptions

func (ListOperationOptions) ToHeaders added in v0.20240208.1095436

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

func (ListOperationOptions) ToOData added in v0.20240208.1095436

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

func (ListOperationOptions) ToQuery added in v0.20240208.1095436

type ListOperationResponse

type ListOperationResponse struct {
	HttpResponse *http.Response
	OData        *odata.OData
	Model        *[]StreamingJob
}

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 {
}

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"`
}

func (ParquetSerialization) MarshalJSON

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

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"`
}

func (PostgreSQLOutputDataSource) MarshalJSON

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

type PowerBIOutputDataSource

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

func (PowerBIOutputDataSource) MarshalJSON

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

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 RawFunctionBindingImpl

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

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).

type RawFunctionPropertiesImpl

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

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).

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{}
}

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).

type RawOutputDataSourceImpl

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

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).

type RawOutputDatasource

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

func (RawOutputDatasource) MarshalJSON

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

type RawOutputDatasourceProperties

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

type RawReferenceInputDataSource

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

func (RawReferenceInputDataSource) MarshalJSON

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

type RawReferenceInputDataSourceImpl

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

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).

type RawSerializationImpl

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

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).

type RawStreamInputDataSource

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

func (RawStreamInputDataSource) MarshalJSON

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

type RawStreamInputDataSourceImpl

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

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).

type ReferenceInputDataSource

type ReferenceInputDataSource interface {
}

type ReferenceInputProperties

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

	// Fields inherited from InputProperties
	Compression       *Compression              `json:"compression,omitempty"`
	Diagnostics       *Diagnostics              `json:"diagnostics,omitempty"`
	Etag              *string                   `json:"etag,omitempty"`
	PartitionKey      *string                   `json:"partitionKey,omitempty"`
	Serialization     Serialization             `json:"serialization"`
	WatermarkSettings *InputWatermarkProperties `json:"watermarkSettings,omitempty"`
}

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 ResourceType

type ResourceType string
const (
	ResourceTypeMicrosoftPointStreamAnalyticsStreamingjobs ResourceType = "Microsoft.StreamAnalytics/streamingjobs"
)

func (*ResourceType) UnmarshalJSON added in v0.20240208.1095436

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

type ScalarFunctionProperties

type ScalarFunctionProperties struct {

	// Fields inherited from FunctionProperties
	Etag       *string                `json:"etag,omitempty"`
	Properties *FunctionConfiguration `json:"properties,omitempty"`
}

func (ScalarFunctionProperties) MarshalJSON

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

type ScaleOperationResponse

type ScaleOperationResponse struct {
	Poller       pollers.Poller
	HttpResponse *http.Response
	OData        *odata.OData
}

type ScaleStreamingJobParameters

type ScaleStreamingJobParameters struct {
	StreamingUnits *int64 `json:"streamingUnits,omitempty"`
}

type Serialization

type Serialization interface {
}

type ServiceBusQueueOutputDataSource

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

func (ServiceBusQueueOutputDataSource) MarshalJSON

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

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"`
}

func (ServiceBusTopicOutputDataSource) MarshalJSON

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

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 SkuCapacity

type SkuCapacity struct {
	AllowedValues *[]int64              `json:"allowedValues,omitempty"`
	Default       *int64                `json:"default,omitempty"`
	Maximum       *int64                `json:"maximum,omitempty"`
	Minimum       *int64                `json:"minimum,omitempty"`
	ScaleType     *SkuCapacityScaleType `json:"scaleType,omitempty"`
}

type SkuCapacityScaleType

type SkuCapacityScaleType string
const (
	SkuCapacityScaleTypeAutomatic SkuCapacityScaleType = "automatic"
	SkuCapacityScaleTypeManual    SkuCapacityScaleType = "manual"
	SkuCapacityScaleTypeNone      SkuCapacityScaleType = "none"
)

func (*SkuCapacityScaleType) UnmarshalJSON added in v0.20240208.1095436

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

type SkuListCompleteResult

type SkuListCompleteResult struct {
	LatestHttpResponse *http.Response
	Items              []GetStreamingJobSkuResult
}

type SkuListCustomPager added in v0.20240628.1153531

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

type SkuListOperationResponse

type SkuListOperationResponse struct {
	HttpResponse *http.Response
	OData        *odata.OData
	Model        *[]GetStreamingJobSkuResult
}

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 StartOperationResponse

type StartOperationResponse struct {
	Poller       pollers.Poller
	HttpResponse *http.Response
	OData        *odata.OData
}

type StartStreamingJobParameters

type StartStreamingJobParameters struct {
	OutputStartMode *OutputStartMode `json:"outputStartMode,omitempty"`
	OutputStartTime *string          `json:"outputStartTime,omitempty"`
}

func (*StartStreamingJobParameters) GetOutputStartTimeAsTime

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

func (*StartStreamingJobParameters) SetOutputStartTimeAsTime

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

type StopOperationResponse

type StopOperationResponse struct {
	Poller       pollers.Poller
	HttpResponse *http.Response
	OData        *odata.OData
}

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 {
}

type StreamInputProperties

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

	// Fields inherited from InputProperties
	Compression       *Compression              `json:"compression,omitempty"`
	Diagnostics       *Diagnostics              `json:"diagnostics,omitempty"`
	Etag              *string                   `json:"etag,omitempty"`
	PartitionKey      *string                   `json:"partitionKey,omitempty"`
	Serialization     Serialization             `json:"serialization"`
	WatermarkSettings *InputWatermarkProperties `json:"watermarkSettings,omitempty"`
}

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 StreamingJobId

type StreamingJobId struct {
	SubscriptionId    string
	ResourceGroupName string
	StreamingJobName  string
}

StreamingJobId is a struct representing the Resource ID for a Streaming Job

func NewStreamingJobID

func NewStreamingJobID(subscriptionId string, resourceGroupName string, streamingJobName string) StreamingJobId

NewStreamingJobID returns a new StreamingJobId struct

func ParseStreamingJobID

func ParseStreamingJobID(input string) (*StreamingJobId, error)

ParseStreamingJobID parses 'input' into a StreamingJobId

func ParseStreamingJobIDInsensitively

func ParseStreamingJobIDInsensitively(input string) (*StreamingJobId, error)

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

func (*StreamingJobId) FromParseResult

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

func (StreamingJobId) ID

func (id StreamingJobId) ID() string

ID returns the formatted Streaming Job ID

func (StreamingJobId) Segments

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

Segments returns a slice of Resource ID Segments which comprise this Streaming Job ID

func (StreamingJobId) String

func (id StreamingJobId) String() string

String returns a human-readable description of this Streaming Job ID

type StreamingJobOperationPredicate

type StreamingJobOperationPredicate struct {
	Id       *string
	Location *string
	Name     *string
	Type     *string
}

func (StreamingJobOperationPredicate) Matches

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 StreamingJobsClient

type StreamingJobsClient struct {
	Client *resourcemanager.Client
}

func NewStreamingJobsClientWithBaseURI

func NewStreamingJobsClientWithBaseURI(sdkApi sdkEnv.Api) (*StreamingJobsClient, error)

func (StreamingJobsClient) CreateOrReplace

CreateOrReplace ...

func (StreamingJobsClient) CreateOrReplaceThenPoll

func (c StreamingJobsClient) CreateOrReplaceThenPoll(ctx context.Context, id StreamingJobId, input StreamingJob, options CreateOrReplaceOperationOptions) error

CreateOrReplaceThenPoll performs CreateOrReplace then polls until it's completed

func (StreamingJobsClient) Delete

Delete ...

func (StreamingJobsClient) DeleteThenPoll

func (c StreamingJobsClient) DeleteThenPoll(ctx context.Context, id StreamingJobId) error

DeleteThenPoll performs Delete then polls until it's completed

func (StreamingJobsClient) Get

Get ...

func (StreamingJobsClient) List

List ...

func (StreamingJobsClient) ListByResourceGroup

ListByResourceGroup ...

func (StreamingJobsClient) ListByResourceGroupComplete

ListByResourceGroupComplete retrieves all the results into a single object

func (StreamingJobsClient) ListByResourceGroupCompleteMatchingPredicate

func (c StreamingJobsClient) ListByResourceGroupCompleteMatchingPredicate(ctx context.Context, id commonids.ResourceGroupId, options ListByResourceGroupOperationOptions, predicate StreamingJobOperationPredicate) (result ListByResourceGroupCompleteResult, err error)

ListByResourceGroupCompleteMatchingPredicate retrieves all the results and then applies the predicate

func (StreamingJobsClient) ListComplete

ListComplete retrieves all the results into a single object

func (StreamingJobsClient) ListCompleteMatchingPredicate

func (c StreamingJobsClient) ListCompleteMatchingPredicate(ctx context.Context, id commonids.SubscriptionId, options ListOperationOptions, predicate StreamingJobOperationPredicate) (result ListCompleteResult, err error)

ListCompleteMatchingPredicate retrieves all the results and then applies the predicate

func (StreamingJobsClient) Scale

Scale ...

func (StreamingJobsClient) ScaleThenPoll

ScaleThenPoll performs Scale then polls until it's completed

func (StreamingJobsClient) SkuList

SkuList ...

func (StreamingJobsClient) SkuListComplete

SkuListComplete retrieves all the results into a single object

func (StreamingJobsClient) SkuListCompleteMatchingPredicate

func (c StreamingJobsClient) SkuListCompleteMatchingPredicate(ctx context.Context, id StreamingJobId, predicate GetStreamingJobSkuResultOperationPredicate) (result SkuListCompleteResult, err error)

SkuListCompleteMatchingPredicate retrieves all the results and then applies the predicate

func (StreamingJobsClient) Start

Start ...

func (StreamingJobsClient) StartThenPoll

StartThenPoll performs Start then polls until it's completed

func (StreamingJobsClient) Stop

Stop ...

func (StreamingJobsClient) StopThenPoll

func (c StreamingJobsClient) StopThenPoll(ctx context.Context, id StreamingJobId) error

StopThenPoll performs Stop then polls until it's completed

func (StreamingJobsClient) Update

Update ...

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

type UpdateOperationOptions

type UpdateOperationOptions struct {
	IfMatch *string
}

func DefaultUpdateOperationOptions

func DefaultUpdateOperationOptions() UpdateOperationOptions

func (UpdateOperationOptions) ToHeaders added in v0.20240208.1095436

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

func (UpdateOperationOptions) ToOData added in v0.20240208.1095436

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

func (UpdateOperationOptions) ToQuery added in v0.20240208.1095436

type UpdateOperationResponse

type UpdateOperationResponse struct {
	HttpResponse *http.Response
	OData        *odata.OData
	Model        *StreamingJob
}

Source Files

Jump to

Keyboard shortcuts

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