streamingjobs

Sep 20, 2024

Changes in this version

type AggregateFunctionProperties

+ Type string

+ func (s AggregateFunctionProperties) FunctionProperties() BaseFunctionPropertiesImpl

type AvroSerialization

+ Type EventSerializationType

+ func (s AvroSerialization) Serialization() BaseSerializationImpl

type AzureDataExplorerOutputDataSource

+ Type string

+ func (s AzureDataExplorerOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type AzureDataLakeStoreOutputDataSource

+ Type string

+ func (s AzureDataLakeStoreOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type AzureFunctionOutputDataSource

+ Type string

+ func (s AzureFunctionOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type AzureMachineLearningServiceFunctionBinding

+ Type string

+ func (s AzureMachineLearningServiceFunctionBinding) FunctionBinding() BaseFunctionBindingImpl

type AzureMachineLearningStudioFunctionBinding

+ Type string

+ func (s AzureMachineLearningStudioFunctionBinding) FunctionBinding() BaseFunctionBindingImpl

type AzureSqlDatabaseOutputDataSource

+ Type string

+ func (s AzureSqlDatabaseOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type AzureSqlReferenceInputDataSource

+ Type string

+ func (s AzureSqlReferenceInputDataSource) ReferenceInputDataSource() BaseReferenceInputDataSourceImpl

type AzureSynapseOutputDataSource

+ Type string

+ func (s AzureSynapseOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type AzureTableOutputDataSource

+ Type string

+ func (s AzureTableOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

+ type BaseFunctionBindingImpl struct

+ Type string

+ func (s BaseFunctionBindingImpl) FunctionBinding() BaseFunctionBindingImpl

+ type BaseFunctionPropertiesImpl struct

+ Etag *string

+ Properties *FunctionConfiguration

+ Type string

+ func (s BaseFunctionPropertiesImpl) FunctionProperties() BaseFunctionPropertiesImpl

+ type BaseInputPropertiesImpl struct

+ Compression *Compression

+ Diagnostics *Diagnostics

+ Etag *string

+ PartitionKey *string

+ Serialization Serialization

+ Type string

+ WatermarkSettings *InputWatermarkProperties

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

+ func (s BaseInputPropertiesImpl) InputProperties() BaseInputPropertiesImpl

+ type BaseOutputDataSourceImpl struct

+ Type string

+ func (s BaseOutputDataSourceImpl) OutputDataSource() BaseOutputDataSourceImpl

+ type BaseReferenceInputDataSourceImpl struct

+ Type string

+ func (s BaseReferenceInputDataSourceImpl) ReferenceInputDataSource() BaseReferenceInputDataSourceImpl

+ type BaseSerializationImpl struct

+ Type EventSerializationType

+ func (s BaseSerializationImpl) Serialization() BaseSerializationImpl

+ type BaseStreamInputDataSourceImpl struct

+ Type string

+ func (s BaseStreamInputDataSourceImpl) StreamInputDataSource() BaseStreamInputDataSourceImpl

type BlobOutputDataSource

+ Type string

+ func (s BlobOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type BlobReferenceInputDataSource

+ Type string

+ func (s BlobReferenceInputDataSource) ReferenceInputDataSource() BaseReferenceInputDataSourceImpl

type BlobStreamInputDataSource

+ Type string

+ func (s BlobStreamInputDataSource) StreamInputDataSource() BaseStreamInputDataSourceImpl

type CSharpFunctionBinding

+ Type string

+ func (s CSharpFunctionBinding) FunctionBinding() BaseFunctionBindingImpl

type CsvSerialization

+ Type EventSerializationType

+ func (s CsvSerialization) Serialization() BaseSerializationImpl

type CustomClrSerialization

+ Type EventSerializationType

+ func (s CustomClrSerialization) Serialization() BaseSerializationImpl

type DeltaSerialization

+ Type EventSerializationType

+ func (s DeltaSerialization) Serialization() BaseSerializationImpl

type DocumentDbOutputDataSource

+ Type string

+ func (s DocumentDbOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type EventGridStreamInputDataSource

+ Type string

+ func (s EventGridStreamInputDataSource) StreamInputDataSource() BaseStreamInputDataSourceImpl

type EventHubOutputDataSource

+ Type string

+ func (s EventHubOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type EventHubStreamInputDataSource

+ Type string

+ func (s EventHubStreamInputDataSource) StreamInputDataSource() BaseStreamInputDataSourceImpl

type EventHubV2OutputDataSource

+ Type string

+ func (s EventHubV2OutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type EventHubV2StreamInputDataSource

+ Type string

+ func (s EventHubV2StreamInputDataSource) StreamInputDataSource() BaseStreamInputDataSourceImpl

type FileReferenceInputDataSource

+ Type string

+ func (s FileReferenceInputDataSource) ReferenceInputDataSource() BaseReferenceInputDataSourceImpl

type FunctionBinding

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

+ FunctionBinding func() BaseFunctionBindingImpl

type FunctionProperties

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

+ FunctionProperties func() BaseFunctionPropertiesImpl

type GatewayMessageBusOutputDataSource

+ Type string

+ func (s GatewayMessageBusOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type GatewayMessageBusStreamInputDataSource

+ Type string

+ func (s GatewayMessageBusStreamInputDataSource) StreamInputDataSource() BaseStreamInputDataSourceImpl

type InputProperties

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

+ InputProperties func() BaseInputPropertiesImpl

type IoTHubStreamInputDataSource

+ Type string

+ func (s IoTHubStreamInputDataSource) StreamInputDataSource() BaseStreamInputDataSourceImpl

type JavaScriptFunctionBinding

+ Type string

+ func (s JavaScriptFunctionBinding) FunctionBinding() BaseFunctionBindingImpl

type JsonSerialization

+ Type EventSerializationType

+ func (s JsonSerialization) Serialization() BaseSerializationImpl

type OutputDataSource

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

+ OutputDataSource func() BaseOutputDataSourceImpl

type ParquetSerialization

+ Type EventSerializationType

+ func (s ParquetSerialization) Serialization() BaseSerializationImpl

type PostgreSQLOutputDataSource

+ Type string

+ func (s PostgreSQLOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type PowerBIOutputDataSource

+ Type string

+ func (s PowerBIOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type RawFunctionBindingImpl

+ func (s RawFunctionBindingImpl) FunctionBinding() BaseFunctionBindingImpl

type RawFunctionPropertiesImpl

+ func (s RawFunctionPropertiesImpl) FunctionProperties() BaseFunctionPropertiesImpl

type RawInputPropertiesImpl

+ func (s RawInputPropertiesImpl) InputProperties() BaseInputPropertiesImpl

type RawOutputDataSourceImpl

+ func (s RawOutputDataSourceImpl) OutputDataSource() BaseOutputDataSourceImpl

type RawOutputDatasource

+ Type string

+ func (s RawOutputDatasource) OutputDataSource() BaseOutputDataSourceImpl

type RawReferenceInputDataSource

+ Type string

+ func (s RawReferenceInputDataSource) ReferenceInputDataSource() BaseReferenceInputDataSourceImpl

type RawReferenceInputDataSourceImpl

+ func (s RawReferenceInputDataSourceImpl) ReferenceInputDataSource() BaseReferenceInputDataSourceImpl

type RawSerializationImpl

+ func (s RawSerializationImpl) Serialization() BaseSerializationImpl

type RawStreamInputDataSource

+ Type string

+ func (s RawStreamInputDataSource) StreamInputDataSource() BaseStreamInputDataSourceImpl

type RawStreamInputDataSourceImpl

+ func (s RawStreamInputDataSourceImpl) StreamInputDataSource() BaseStreamInputDataSourceImpl

type ReferenceInputDataSource

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

+ ReferenceInputDataSource func() BaseReferenceInputDataSourceImpl

type ReferenceInputProperties

+ Type string

+ func (s ReferenceInputProperties) InputProperties() BaseInputPropertiesImpl

type ScalarFunctionProperties

+ Type string

+ func (s ScalarFunctionProperties) FunctionProperties() BaseFunctionPropertiesImpl

type Serialization

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

+ Serialization func() BaseSerializationImpl

type ServiceBusQueueOutputDataSource

+ Type string

+ func (s ServiceBusQueueOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type ServiceBusTopicOutputDataSource

+ Type string

+ func (s ServiceBusTopicOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl

type StreamInputDataSource

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

+ StreamInputDataSource func() BaseStreamInputDataSourceImpl

type StreamInputProperties

+ Type string

+ func (s StreamInputProperties) InputProperties() BaseInputPropertiesImpl

Jun 28, 2024

Changes in this version

+ type ListByResourceGroupCustomPager struct

+ NextLink *odata.Link

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

+ type ListCustomPager struct

+ NextLink *odata.Link

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

+ type SkuListCustomPager struct

+ NextLink *odata.Link

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

Feb 8, 2024

Changes in this version

type AuthenticationMode

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

type BlobWriteMode

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

type CompatibilityLevel

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

type CompressionType

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

type ContentStoragePolicy

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

type CreateOrReplaceOperationOptions

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

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

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

type CreateOrReplaceOperationResponse

+ OData *odata.OData

type DeleteOperationResponse

+ OData *odata.OData

type Encoding

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

type EventGridEventSchemaType

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

type EventSerializationType

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

type EventsOutOfOrderPolicy

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

type GetOperationOptions

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

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

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

type GetOperationResponse

+ OData *odata.OData

type InputWatermarkMode

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

type JobType

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

type JsonOutputSerializationFormat

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

type ListByResourceGroupCompleteResult

+ LatestHttpResponse *http.Response

type ListByResourceGroupOperationOptions

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

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

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

type ListByResourceGroupOperationResponse

+ OData *odata.OData

type ListCompleteResult

+ LatestHttpResponse *http.Response

type ListOperationOptions

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

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

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

type ListOperationResponse

+ OData *odata.OData

type OutputErrorPolicy

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

type OutputStartMode

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

type OutputWatermarkMode

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

type RefreshType

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

type ResourceType

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

type ScaleOperationResponse

+ OData *odata.OData

type SkuCapacityScaleType

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

type SkuListCompleteResult

+ LatestHttpResponse *http.Response

type SkuListOperationResponse

+ OData *odata.OData

type SkuName

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

type StartOperationResponse

+ OData *odata.OData

type StopOperationResponse

+ OData *odata.OData

type UpdatableUdfRefreshType

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

type UpdateMode

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

type UpdateOperationOptions

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

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

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

type UpdateOperationResponse

+ OData *odata.OData

Jan 25, 2024

Changes in this version

+ func PossibleValuesForAuthenticationMode() []string

+ func PossibleValuesForBlobWriteMode() []string

+ func PossibleValuesForCompatibilityLevel() []string

+ func PossibleValuesForCompressionType() []string

+ func PossibleValuesForContentStoragePolicy() []string

+ func PossibleValuesForEncoding() []string

+ func PossibleValuesForEventGridEventSchemaType() []string

+ func PossibleValuesForEventSerializationType() []string

+ func PossibleValuesForEventsOutOfOrderPolicy() []string

+ func PossibleValuesForInputWatermarkMode() []string

+ func PossibleValuesForJobType() []string

+ func PossibleValuesForJsonOutputSerializationFormat() []string

+ func PossibleValuesForOutputErrorPolicy() []string

+ func PossibleValuesForOutputStartMode() []string

+ func PossibleValuesForOutputWatermarkMode() []string

+ func PossibleValuesForRefreshType() []string

+ func PossibleValuesForResourceType() []string

+ func PossibleValuesForSkuCapacityScaleType() []string

+ func PossibleValuesForSkuName() []string

+ func PossibleValuesForUpdatableUdfRefreshType() []string

+ func PossibleValuesForUpdateMode() []string

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

+ type AggregateFunctionProperties struct

+ Etag *string

+ Properties *FunctionConfiguration

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

+ type AuthenticationMode string

+ const AuthenticationModeConnectionString

+ const AuthenticationModeMsi

+ const AuthenticationModeUserToken

+ type AvroSerialization struct

+ Properties *interface{}

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

+ type AzureDataExplorerOutputDataSource struct

+ Properties *AzureDataExplorerOutputDataSourceProperties

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

+ type AzureDataExplorerOutputDataSourceProperties struct

+ AuthenticationMode *AuthenticationMode

+ Cluster *string

+ Database *string

+ Table *string

+ type AzureDataLakeStoreOutputDataSource struct

+ Properties *AzureDataLakeStoreOutputDataSourceProperties

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

+ type AzureDataLakeStoreOutputDataSourceProperties struct

+ AccountName *string

+ AuthenticationMode *AuthenticationMode

+ DateFormat *string

+ FilePathPrefix *string

+ RefreshToken *string

+ TenantId *string

+ TimeFormat *string

+ TokenUserDisplayName *string

+ TokenUserPrincipalName *string

+ type AzureFunctionOutputDataSource struct

+ Properties *AzureFunctionOutputDataSourceProperties

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

+ type AzureFunctionOutputDataSourceProperties struct

+ ApiKey *string

+ FunctionAppName *string

+ FunctionName *string

+ MaxBatchCount *float64

+ MaxBatchSize *float64

+ type AzureMachineLearningServiceFunctionBinding struct

+ Properties *AzureMachineLearningServiceFunctionBindingProperties

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

+ type AzureMachineLearningServiceFunctionBindingProperties struct

+ ApiKey *string

+ BatchSize *int64

+ Endpoint *string

+ InputRequestName *string

+ Inputs *[]AzureMachineLearningServiceInputColumn

+ NumberOfParallelRequests *int64

+ OutputResponseName *string

+ Outputs *[]AzureMachineLearningServiceOutputColumn

+ type AzureMachineLearningServiceInputColumn struct

+ DataType *string

+ MapTo *int64

+ Name *string

+ type AzureMachineLearningServiceOutputColumn struct

+ DataType *string

+ MapTo *int64

+ Name *string

+ type AzureMachineLearningStudioFunctionBinding struct

+ Properties *AzureMachineLearningStudioFunctionBindingProperties

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

+ type AzureMachineLearningStudioFunctionBindingProperties struct

+ ApiKey *string

+ BatchSize *int64

+ Endpoint *string

+ Inputs *AzureMachineLearningStudioInputs

+ Outputs *[]AzureMachineLearningStudioOutputColumn

+ type AzureMachineLearningStudioInputColumn struct

+ DataType *string

+ MapTo *int64

+ Name *string

+ type AzureMachineLearningStudioInputs struct

+ ColumnNames *[]AzureMachineLearningStudioInputColumn

+ Name *string

+ type AzureMachineLearningStudioOutputColumn struct

+ DataType *string

+ Name *string

+ type AzureSqlDatabaseDataSourceProperties struct

+ AuthenticationMode *AuthenticationMode

+ Database *string

+ MaxBatchCount *float64

+ MaxWriterCount *float64

+ Password *string

+ Server *string

+ Table *string

+ User *string

+ type AzureSqlDatabaseOutputDataSource struct

+ Properties *AzureSqlDatabaseDataSourceProperties

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

+ type AzureSqlReferenceInputDataSource struct

+ Properties *AzureSqlReferenceInputDataSourceProperties

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

+ type AzureSqlReferenceInputDataSourceProperties struct

+ AuthenticationMode *AuthenticationMode

+ Database *string

+ DeltaSnapshotQuery *string

+ FullSnapshotQuery *string

+ Password *string

+ RefreshRate *string

+ RefreshType *RefreshType

+ Server *string

+ User *string

+ type AzureSynapseDataSourceProperties struct

+ AuthenticationMode *AuthenticationMode

+ Database *string

+ Password *string

+ Server *string

+ Table *string

+ User *string

+ type AzureSynapseOutputDataSource struct

+ Properties *AzureSynapseDataSourceProperties

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

+ type AzureTableOutputDataSource struct

+ Properties *AzureTableOutputDataSourceProperties

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

+ type AzureTableOutputDataSourceProperties struct

+ AccountKey *string

+ AccountName *string

+ BatchSize *int64

+ ColumnsToRemove *[]string

+ PartitionKey *string

+ RowKey *string

+ Table *string

+ type BlobOutputDataSource struct

+ Properties *BlobOutputDataSourceProperties

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

+ type BlobOutputDataSourceProperties struct

+ AuthenticationMode *AuthenticationMode

+ BlobPathPrefix *string

+ BlobWriteMode *BlobWriteMode

+ Container *string

+ DateFormat *string

+ PathPattern *string

+ StorageAccounts *[]StorageAccount

+ TimeFormat *string

+ type BlobReferenceInputDataSource struct

+ Properties *BlobReferenceInputDataSourceProperties

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

+ type BlobReferenceInputDataSourceProperties struct

+ AuthenticationMode *AuthenticationMode

+ BlobName *string

+ Container *string

+ DateFormat *string

+ DeltaPathPattern *string

+ DeltaSnapshotRefreshRate *string

+ FullSnapshotRefreshRate *string

+ PathPattern *string

+ SourcePartitionCount *int64

+ StorageAccounts *[]StorageAccount

+ TimeFormat *string

+ type BlobStreamInputDataSource struct

+ Properties *BlobStreamInputDataSourceProperties

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

+ type BlobStreamInputDataSourceProperties struct

+ AuthenticationMode *AuthenticationMode

+ Container *string

+ DateFormat *string

+ PathPattern *string

+ SourcePartitionCount *int64

+ StorageAccounts *[]StorageAccount

+ TimeFormat *string

+ type BlobWriteMode string

+ const BlobWriteModeAppend

+ const BlobWriteModeOnce

+ type CSharpFunctionBinding struct

+ Properties *CSharpFunctionBindingProperties

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

+ type CSharpFunctionBindingProperties struct

+ Class *string

+ DllPath *string

+ Method *string

+ UpdateMode *UpdateMode

+ type ClusterInfo struct

+ Id *string

+ type CompatibilityLevel string

+ const CompatibilityLevelOnePointTwo

+ const CompatibilityLevelOnePointZero

+ type Compression struct

+ Type CompressionType

+ type CompressionType string

+ const CompressionTypeDeflate

+ const CompressionTypeGZip

+ const CompressionTypeNone

+ type ContentStoragePolicy string

+ const ContentStoragePolicyJobStorageAccount

+ const ContentStoragePolicySystemAccount

+ type CreateOrReplaceOperationOptions struct

+ IfMatch *string

+ IfNoneMatch *string

+ func DefaultCreateOrReplaceOperationOptions() CreateOrReplaceOperationOptions

+ type CreateOrReplaceOperationResponse struct

+ HttpResponse *http.Response

+ Model *StreamingJob

+ Poller polling.LongRunningPoller

+ type CsvSerialization struct

+ Properties *CsvSerializationProperties

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

+ type CsvSerializationProperties struct

+ Encoding *Encoding

+ FieldDelimiter *string

+ type CustomClrSerialization struct

+ Properties *CustomClrSerializationProperties

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

+ type CustomClrSerializationProperties struct

+ SerializationClassName *string

+ SerializationDllPath *string

+ type DeleteOperationResponse struct

+ HttpResponse *http.Response

+ Poller polling.LongRunningPoller

+ type DeltaSerialization struct

+ Properties *DeltaSerializationProperties

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

+ type DeltaSerializationProperties struct

+ DeltaTablePath string

+ PartitionColumns *[]string

+ type DiagnosticCondition struct

+ Code *string

+ Message *string

+ Since *string

+ type Diagnostics struct

+ Conditions *[]DiagnosticCondition

+ type DocumentDbOutputDataSource struct

+ Properties *DocumentDbOutputDataSourceProperties

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

+ type DocumentDbOutputDataSourceProperties struct

+ AccountId *string

+ AccountKey *string

+ AuthenticationMode *AuthenticationMode

+ CollectionNamePattern *string

+ Database *string

+ DocumentId *string

+ PartitionKey *string

+ type Encoding string

+ const EncodingUTFEight

+ type EventGridEventSchemaType string

+ const EventGridEventSchemaTypeCloudEventSchema

+ const EventGridEventSchemaTypeEventGridEventSchema

+ type EventGridStreamInputDataSource struct

+ Properties *EventGridStreamInputDataSourceProperties

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

+ type EventGridStreamInputDataSourceProperties struct

+ EventTypes *[]string

+ Schema *EventGridEventSchemaType

+ StorageAccounts *[]StorageAccount

+ Subscriber *EventHubV2StreamInputDataSource

+ type EventHubOutputDataSource struct

+ Properties *EventHubOutputDataSourceProperties

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

+ type EventHubOutputDataSourceProperties struct

+ AuthenticationMode *AuthenticationMode

+ EventHubName *string

+ PartitionCount *int64

+ PartitionKey *string

+ PropertyColumns *[]string

+ ServiceBusNamespace *string

+ SharedAccessPolicyKey *string

+ SharedAccessPolicyName *string

+ type EventHubStreamInputDataSource struct

+ Properties *EventHubStreamInputDataSourceProperties

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

+ type EventHubStreamInputDataSourceProperties struct

+ AuthenticationMode *AuthenticationMode

+ ConsumerGroupName *string

+ EventHubName *string

+ PartitionCount *int64

+ PrefetchCount *int64

+ ServiceBusNamespace *string

+ SharedAccessPolicyKey *string

+ SharedAccessPolicyName *string

+ type EventHubV2OutputDataSource struct

+ Properties *EventHubOutputDataSourceProperties

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

+ type EventHubV2StreamInputDataSource struct

+ Properties *EventHubStreamInputDataSourceProperties

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

+ type EventSerializationType string

+ const EventSerializationTypeAvro

+ const EventSerializationTypeCsv

+ const EventSerializationTypeCustomClr

+ const EventSerializationTypeDelta

+ const EventSerializationTypeJson

+ const EventSerializationTypeParquet

+ type EventsOutOfOrderPolicy string

+ const EventsOutOfOrderPolicyAdjust

+ const EventsOutOfOrderPolicyDrop

+ type External struct

+ Container *string

+ Path *string

+ RefreshConfiguration *RefreshConfiguration

+ StorageAccount *StorageAccount

+ type FileReferenceInputDataSource struct

+ Properties *FileReferenceInputDataSourceProperties

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

+ type FileReferenceInputDataSourceProperties struct

+ Path *string

+ type Function struct

+ Id *string

+ Name *string

+ Properties FunctionProperties

+ Type *string

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

+ type FunctionBinding interface

+ type FunctionConfiguration struct

+ Binding FunctionBinding

+ Inputs *[]FunctionInput

+ Output *FunctionOutput

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

+ type FunctionInput struct

+ DataType *string

+ IsConfigurationParameter *bool

+ type FunctionOutput struct

+ DataType *string

+ type FunctionProperties interface

+ type GatewayMessageBusOutputDataSource struct

+ Properties *GatewayMessageBusSourceProperties

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

+ type GatewayMessageBusSourceProperties struct

+ Topic *string

+ type GatewayMessageBusStreamInputDataSource struct

+ Properties *GatewayMessageBusSourceProperties

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

+ type GetOperationOptions struct

+ Expand *string

+ func DefaultGetOperationOptions() GetOperationOptions

+ type GetOperationResponse struct

+ HttpResponse *http.Response

+ Model *StreamingJob

+ type GetStreamingJobSkuResult struct

+ Capacity *SkuCapacity

+ ResourceType *ResourceType

+ Sku *GetStreamingJobSkuResultSku

+ type GetStreamingJobSkuResultOperationPredicate struct

+ func (p GetStreamingJobSkuResultOperationPredicate) Matches(input GetStreamingJobSkuResult) bool

+ type GetStreamingJobSkuResultSku struct

+ Name *SkuName

+ type Identity struct

+ PrincipalId *string

+ TenantId *string

+ Type *string

+ UserAssignedIdentities *map[string]interface{}

+ type Input struct

+ Id *string

+ Name *string

+ Properties InputProperties

+ Type *string

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

+ type InputProperties interface

+ type InputWatermarkMode string

+ const InputWatermarkModeNone

+ const InputWatermarkModeReadWatermark

+ type InputWatermarkProperties struct

+ WatermarkMode *InputWatermarkMode

+ type IoTHubStreamInputDataSource struct

+ Properties *IoTHubStreamInputDataSourceProperties

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

+ type IoTHubStreamInputDataSourceProperties struct

+ ConsumerGroupName *string

+ Endpoint *string

+ IotHubNamespace *string

+ SharedAccessPolicyKey *string

+ SharedAccessPolicyName *string

+ type JavaScriptFunctionBinding struct

+ Properties *JavaScriptFunctionBindingProperties

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

+ type JavaScriptFunctionBindingProperties struct

+ Script *string

+ type JobStorageAccount struct

+ AccountKey *string

+ AccountName *string

+ AuthenticationMode *AuthenticationMode

+ type JobType string

+ const JobTypeCloud

+ const JobTypeEdge

+ type JsonOutputSerializationFormat string

+ const JsonOutputSerializationFormatArray

+ const JsonOutputSerializationFormatLineSeparated

+ type JsonSerialization struct

+ Properties *JsonSerializationProperties

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

+ type JsonSerializationProperties struct

+ Encoding *Encoding

+ Format *JsonOutputSerializationFormat

+ type LastOutputEventTimestamp struct

+ LastOutputEventTime *string

+ LastUpdateTime *string

+ type ListByResourceGroupCompleteResult struct

+ Items []StreamingJob

+ type ListByResourceGroupOperationOptions struct

+ Expand *string

+ func DefaultListByResourceGroupOperationOptions() ListByResourceGroupOperationOptions

+ type ListByResourceGroupOperationResponse struct

+ HttpResponse *http.Response

+ Model *[]StreamingJob

+ func (r ListByResourceGroupOperationResponse) HasMore() bool

+ func (r ListByResourceGroupOperationResponse) LoadMore(ctx context.Context) (resp ListByResourceGroupOperationResponse, err error)

+ type ListCompleteResult struct

+ Items []StreamingJob

+ type ListOperationOptions struct

+ Expand *string

+ func DefaultListOperationOptions() ListOperationOptions

+ type ListOperationResponse struct

+ HttpResponse *http.Response

+ Model *[]StreamingJob

+ func (r ListOperationResponse) HasMore() bool

+ func (r ListOperationResponse) LoadMore(ctx context.Context) (resp ListOperationResponse, err error)

+ type Output struct

+ Id *string

+ Name *string

+ Properties *OutputProperties

+ Type *string

+ type OutputDataSource interface

+ type OutputErrorPolicy string

+ const OutputErrorPolicyDrop

+ const OutputErrorPolicyStop

+ type OutputProperties struct

+ Datasource OutputDataSource

+ Diagnostics *Diagnostics

+ Etag *string

+ LastOutputEventTimestamps *[]LastOutputEventTimestamp

+ Serialization Serialization

+ SizeWindow *int64

+ TimeWindow *string

+ WatermarkSettings *OutputWatermarkProperties

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

+ type OutputStartMode string

+ const OutputStartModeCustomTime

+ const OutputStartModeJobStartTime

+ const OutputStartModeLastOutputEventTime

+ type OutputWatermarkMode string

+ const OutputWatermarkModeNone

+ const OutputWatermarkModeSendCurrentPartitionWatermark

+ const OutputWatermarkModeSendLowestWatermarkAcrossPartitions

+ type OutputWatermarkProperties struct

+ MaxWatermarkDifferenceAcrossPartitions *string

+ WatermarkMode *OutputWatermarkMode

+ type ParquetSerialization struct

+ Properties *interface{}

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

+ type PostgreSQLDataSourceProperties struct

+ AuthenticationMode *AuthenticationMode

+ Database *string

+ MaxWriterCount *float64

+ Password *string

+ Server *string

+ Table *string

+ User *string

+ type PostgreSQLOutputDataSource struct

+ Properties *PostgreSQLDataSourceProperties

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

+ type PowerBIOutputDataSource struct

+ Properties *PowerBIOutputDataSourceProperties

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

+ type PowerBIOutputDataSourceProperties struct

+ AuthenticationMode *AuthenticationMode

+ Dataset *string

+ GroupId *string

+ GroupName *string

+ RefreshToken *string

+ Table *string

+ TokenUserDisplayName *string

+ TokenUserPrincipalName *string

+ type RawFunctionBindingImpl struct

+ Type string

+ Values map[string]interface{}

+ type RawFunctionPropertiesImpl struct

+ Type string

+ Values map[string]interface{}

+ type RawInputDatasourceProperties struct

+ Payload *string

+ PayloadUri *string

+ type RawInputPropertiesImpl struct

+ Type string

+ Values map[string]interface{}

+ type RawOutputDataSourceImpl struct

+ Type string

+ Values map[string]interface{}

+ type RawOutputDatasource struct

+ Properties *RawOutputDatasourceProperties

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

+ type RawOutputDatasourceProperties struct

+ PayloadUri *string

+ type RawReferenceInputDataSource struct

+ Properties *RawInputDatasourceProperties

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

+ type RawReferenceInputDataSourceImpl struct

+ Type string

+ Values map[string]interface{}

+ type RawSerializationImpl struct

+ Type string

+ Values map[string]interface{}

+ type RawStreamInputDataSource struct

+ Properties *RawInputDatasourceProperties

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

+ type RawStreamInputDataSourceImpl struct

+ Type string

+ Values map[string]interface{}

+ type ReferenceInputDataSource interface

+ type ReferenceInputProperties struct

+ Compression *Compression

+ Datasource ReferenceInputDataSource

+ Diagnostics *Diagnostics

+ Etag *string

+ PartitionKey *string

+ Serialization Serialization

+ WatermarkSettings *InputWatermarkProperties

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

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

+ type RefreshConfiguration struct

+ DateFormat *string

+ PathPattern *string

+ RefreshInterval *string

+ RefreshType *UpdatableUdfRefreshType

+ TimeFormat *string

+ type RefreshType string

+ const RefreshTypeRefreshPeriodicallyWithDelta

+ const RefreshTypeRefreshPeriodicallyWithFull

+ const RefreshTypeStatic

+ type ResourceType string

+ const ResourceTypeMicrosoftPointStreamAnalyticsStreamingjobs

+ type ScalarFunctionProperties struct

+ Etag *string

+ Properties *FunctionConfiguration

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

+ type ScaleOperationResponse struct

+ HttpResponse *http.Response

+ Poller polling.LongRunningPoller

+ type ScaleStreamingJobParameters struct

+ StreamingUnits *int64

+ type Serialization interface

+ type ServiceBusQueueOutputDataSource struct

+ Properties *ServiceBusQueueOutputDataSourceProperties

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

+ type ServiceBusQueueOutputDataSourceProperties struct

+ AuthenticationMode *AuthenticationMode

+ PropertyColumns *[]string

+ QueueName *string

+ ServiceBusNamespace *string

+ SharedAccessPolicyKey *string

+ SharedAccessPolicyName *string

+ SystemPropertyColumns *interface{}

+ type ServiceBusTopicOutputDataSource struct

+ Properties *ServiceBusTopicOutputDataSourceProperties

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

+ type ServiceBusTopicOutputDataSourceProperties struct

+ AuthenticationMode *AuthenticationMode

+ PropertyColumns *[]string

+ ServiceBusNamespace *string

+ SharedAccessPolicyKey *string

+ SharedAccessPolicyName *string

+ SystemPropertyColumns *map[string]string

+ TopicName *string

+ type Sku struct

+ Capacity *int64

+ Name *SkuName

+ type SkuCapacity struct

+ AllowedValues *[]int64

+ Default *int64

+ Maximum *int64

+ Minimum *int64

+ ScaleType *SkuCapacityScaleType

+ type SkuCapacityScaleType string

+ const SkuCapacityScaleTypeAutomatic

+ const SkuCapacityScaleTypeManual

+ const SkuCapacityScaleTypeNone

+ type SkuListCompleteResult struct

+ Items []GetStreamingJobSkuResult

+ type SkuListOperationResponse struct

+ HttpResponse *http.Response

+ Model *[]GetStreamingJobSkuResult

+ func (r SkuListOperationResponse) HasMore() bool

+ func (r SkuListOperationResponse) LoadMore(ctx context.Context) (resp SkuListOperationResponse, err error)

+ type SkuName string

+ const SkuNameStandard

+ type StartOperationResponse struct

+ HttpResponse *http.Response

+ Poller polling.LongRunningPoller

+ type StartStreamingJobParameters struct

+ OutputStartMode *OutputStartMode

+ OutputStartTime *string

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

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

+ type StopOperationResponse struct

+ HttpResponse *http.Response

+ Poller polling.LongRunningPoller

+ type StorageAccount struct

+ AccountKey *string

+ AccountName *string

+ AuthenticationMode *AuthenticationMode

+ type StreamInputDataSource interface

+ type StreamInputProperties struct

+ Compression *Compression

+ Datasource StreamInputDataSource

+ Diagnostics *Diagnostics

+ Etag *string

+ PartitionKey *string

+ Serialization Serialization

+ WatermarkSettings *InputWatermarkProperties

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

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

+ type StreamingJob struct

+ Id *string

+ Identity *Identity

+ Location *string

+ Name *string

+ Properties *StreamingJobProperties

+ Sku *Sku

+ Tags *map[string]string

+ Type *string

+ type StreamingJobId struct

+ ResourceGroupName string

+ StreamingJobName string

+ SubscriptionId string

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

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

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

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

+ func (id StreamingJobId) ID() string

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

+ func (id StreamingJobId) String() string

+ type StreamingJobOperationPredicate struct

+ Id *string

+ Location *string

+ Name *string

+ Type *string

+ func (p StreamingJobOperationPredicate) Matches(input StreamingJob) bool

+ type StreamingJobProperties struct

+ Cluster *ClusterInfo

+ CompatibilityLevel *CompatibilityLevel

+ ContentStoragePolicy *ContentStoragePolicy

+ CreatedDate *string

+ DataLocale *string

+ Etag *string

+ EventsLateArrivalMaxDelayInSeconds *int64

+ EventsOutOfOrderMaxDelayInSeconds *int64

+ EventsOutOfOrderPolicy *EventsOutOfOrderPolicy

+ Externals *External

+ Functions *[]Function

+ Inputs *[]Input

+ JobId *string

+ JobState *string

+ JobStorageAccount *JobStorageAccount

+ JobType *JobType

+ LastOutputEventTime *string

+ OutputErrorPolicy *OutputErrorPolicy

+ OutputStartMode *OutputStartMode

+ OutputStartTime *string

+ Outputs *[]Output

+ ProvisioningState *string

+ Sku *Sku

+ Transformation *Transformation

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

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

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

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

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

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

+ type StreamingJobsClient struct

+ Client autorest.Client

+ func NewStreamingJobsClientWithBaseURI(endpoint string) StreamingJobsClient

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

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

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

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

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

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

+ func (c StreamingJobsClient) ListByResourceGroup(ctx context.Context, id commonids.ResourceGroupId, ...) (resp ListByResourceGroupOperationResponse, err error)

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

+ func (c StreamingJobsClient) ListByResourceGroupCompleteMatchingPredicate(ctx context.Context, id commonids.ResourceGroupId, ...) (resp ListByResourceGroupCompleteResult, err error)

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

+ func (c StreamingJobsClient) ListCompleteMatchingPredicate(ctx context.Context, id commonids.SubscriptionId, options ListOperationOptions, ...) (resp ListCompleteResult, err error)

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

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

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

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

+ func (c StreamingJobsClient) SkuListCompleteMatchingPredicate(ctx context.Context, id StreamingJobId, ...) (resp SkuListCompleteResult, err error)

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

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

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

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

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

+ type Transformation struct

+ Id *string

+ Name *string

+ Properties *TransformationProperties

+ Type *string

+ type TransformationProperties struct

+ Etag *string

+ Query *string

+ StreamingUnits *int64

+ ValidStreamingUnits *[]int64

+ type UpdatableUdfRefreshType string

+ const UpdatableUdfRefreshTypeBlocking

+ const UpdatableUdfRefreshTypeNonblocking

+ type UpdateMode string

+ const UpdateModeRefreshable

+ const UpdateModeStatic

+ type UpdateOperationOptions struct

+ IfMatch *string

+ func DefaultUpdateOperationOptions() UpdateOperationOptions

+ type UpdateOperationResponse struct

+ HttpResponse *http.Response

+ Model *StreamingJob