streamingjobs

package
v0.20240815.1003113 Latest Latest
Warning

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

 Go to latest Published: Aug 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 

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

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

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 (o CreateOrReplaceOperationOptions) ToHeaders() *client.Headers

func (CreateOrReplaceOperationOptions) ToOData added in v0.20240208.1095436 

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

func (CreateOrReplaceOperationOptions) ToQuery added in v0.20240208.1095436 

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

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 

func (p GetStreamingJobSkuResultOperationPredicate) Matches(input GetStreamingJobSkuResult) bool

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 (o ListByResourceGroupOperationOptions) ToHeaders() *client.Headers

func (ListByResourceGroupOperationOptions) ToOData added in v0.20240208.1095436 

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

func (ListByResourceGroupOperationOptions) ToQuery added in v0.20240208.1095436 

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

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 

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

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 

func (p StreamingJobOperationPredicate) Matches(input StreamingJob) bool

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 

func (c StreamingJobsClient) CreateOrReplace(ctx context.Context, id StreamingJobId, input StreamingJob, options CreateOrReplaceOperationOptions) (result CreateOrReplaceOperationResponse, err error)

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 

func (c StreamingJobsClient) Delete(ctx context.Context, id StreamingJobId) (result DeleteOperationResponse, err error)

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 

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

Get ...

func (StreamingJobsClient) List 

func (c StreamingJobsClient) List(ctx context.Context, id commonids.SubscriptionId, options ListOperationOptions) (result ListOperationResponse, err error)

List ...

func (StreamingJobsClient) ListByResourceGroup 

func (c StreamingJobsClient) ListByResourceGroup(ctx context.Context, id commonids.ResourceGroupId, options ListByResourceGroupOperationOptions) (result ListByResourceGroupOperationResponse, err error)

ListByResourceGroup ...

func (StreamingJobsClient) ListByResourceGroupComplete 

func (c StreamingJobsClient) ListByResourceGroupComplete(ctx context.Context, id commonids.ResourceGroupId, options ListByResourceGroupOperationOptions) (ListByResourceGroupCompleteResult, error)

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 

func (c StreamingJobsClient) ListComplete(ctx context.Context, id commonids.SubscriptionId, options ListOperationOptions) (ListCompleteResult, error)

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 

func (c StreamingJobsClient) Scale(ctx context.Context, id StreamingJobId, input ScaleStreamingJobParameters) (result ScaleOperationResponse, err error)

Scale ...

func (StreamingJobsClient) ScaleThenPoll 

func (c StreamingJobsClient) ScaleThenPoll(ctx context.Context, id StreamingJobId, input ScaleStreamingJobParameters) error

ScaleThenPoll performs Scale then polls until it's completed

func (StreamingJobsClient) SkuList 

func (c StreamingJobsClient) SkuList(ctx context.Context, id StreamingJobId) (result SkuListOperationResponse, err error)

SkuList ...

func (StreamingJobsClient) SkuListComplete 

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

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 

func (c StreamingJobsClient) Start(ctx context.Context, id StreamingJobId, input StartStreamingJobParameters) (result StartOperationResponse, err error)

Start ...

func (StreamingJobsClient) StartThenPoll 

func (c StreamingJobsClient) StartThenPoll(ctx context.Context, id StreamingJobId, input StartStreamingJobParameters) error

StartThenPoll performs Start then polls until it's completed

func (StreamingJobsClient) Stop 

func (c StreamingJobsClient) Stop(ctx context.Context, id StreamingJobId) (result StopOperationResponse, err error)

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 

func (c StreamingJobsClient) Update(ctx context.Context, id StreamingJobId, input StreamingJob, options UpdateOperationOptions) (result UpdateOperationResponse, err error)

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 

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

type UpdateOperationResponse 

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

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.