Versions in this module Expand all Collapse all v0 v0.20241126.2320 Nov 26, 2024 v0.20241126.1723 Nov 26, 2024 Changes in this version + func PossibleValuesForAuthenticationMode() []string + func PossibleValuesForCompatibilityLevel() []string + func PossibleValuesForCompressionType() []string + func PossibleValuesForContentStoragePolicy() []string + func PossibleValuesForEncoding() []string + func PossibleValuesForEventSerializationType() []string + func PossibleValuesForEventsOutOfOrderPolicy() []string + func PossibleValuesForJobType() []string + func PossibleValuesForJsonOutputSerializationFormat() []string + func PossibleValuesForOutputErrorPolicy() []string + func PossibleValuesForOutputStartMode() []string + func PossibleValuesForRefreshType() []string + func PossibleValuesForSkuName() []string + func ValidateStreamingJobID(input interface{}, key string) (warnings []string, errors []error) + type AggregateFunctionProperties struct + Etag *string + Properties *FunctionConfiguration + Type string + func (s AggregateFunctionProperties) FunctionProperties() BaseFunctionPropertiesImpl + func (s AggregateFunctionProperties) MarshalJSON() ([]byte, error) + type AuthenticationMode string + const AuthenticationModeConnectionString + const AuthenticationModeMsi + const AuthenticationModeUserToken + func (s *AuthenticationMode) UnmarshalJSON(bytes []byte) error + type AvroSerialization struct + Properties *interface{} + Type EventSerializationType + func (s AvroSerialization) MarshalJSON() ([]byte, error) + func (s AvroSerialization) Serialization() BaseSerializationImpl + type AzureDataLakeStoreOutputDataSource struct + Properties *AzureDataLakeStoreOutputDataSourceProperties + Type string + func (s AzureDataLakeStoreOutputDataSource) MarshalJSON() ([]byte, error) + func (s AzureDataLakeStoreOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl + 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 + Type string + func (s AzureFunctionOutputDataSource) MarshalJSON() ([]byte, error) + func (s AzureFunctionOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl + type AzureFunctionOutputDataSourceProperties struct + ApiKey *string + FunctionAppName *string + FunctionName *string + MaxBatchCount *float64 + MaxBatchSize *float64 + type AzureMachineLearningWebServiceFunctionBinding struct + Properties *AzureMachineLearningWebServiceFunctionBindingProperties + Type string + func (s AzureMachineLearningWebServiceFunctionBinding) FunctionBinding() BaseFunctionBindingImpl + func (s AzureMachineLearningWebServiceFunctionBinding) MarshalJSON() ([]byte, error) + type AzureMachineLearningWebServiceFunctionBindingProperties struct + ApiKey *string + BatchSize *int64 + Endpoint *string + Inputs *AzureMachineLearningWebServiceInputs + Outputs *[]AzureMachineLearningWebServiceOutputColumn + type AzureMachineLearningWebServiceInputColumn struct + DataType *string + MapTo *int64 + Name *string + type AzureMachineLearningWebServiceInputs struct + ColumnNames *[]AzureMachineLearningWebServiceInputColumn + Name *string + type AzureMachineLearningWebServiceOutputColumn 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 + Type string + func (s AzureSqlDatabaseOutputDataSource) MarshalJSON() ([]byte, error) + func (s AzureSqlDatabaseOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl + type AzureSqlReferenceInputDataSource struct + Properties *AzureSqlReferenceInputDataSourceProperties + Type string + func (s AzureSqlReferenceInputDataSource) MarshalJSON() ([]byte, error) + func (s AzureSqlReferenceInputDataSource) ReferenceInputDataSource() BaseReferenceInputDataSourceImpl + type AzureSqlReferenceInputDataSourceProperties struct + Database *string + DeltaSnapshotQuery *string + FullSnapshotQuery *string + Password *string + RefreshRate *string + RefreshType *RefreshType + Server *string + Table *string + User *string + type AzureSynapseDataSourceProperties struct + Database *string + Password *string + Server *string + Table *string + User *string + type AzureSynapseOutputDataSource struct + Properties *AzureSynapseDataSourceProperties + Type string + func (s AzureSynapseOutputDataSource) MarshalJSON() ([]byte, error) + func (s AzureSynapseOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl + type AzureTableOutputDataSource struct + Properties *AzureTableOutputDataSourceProperties + Type string + func (s AzureTableOutputDataSource) MarshalJSON() ([]byte, error) + func (s AzureTableOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl + type AzureTableOutputDataSourceProperties struct + AccountKey *string + AccountName *string + BatchSize *int64 + ColumnsToRemove *[]string + PartitionKey *string + RowKey *string + Table *string + 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 + 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 BlobDataSourceProperties struct + AuthenticationMode *AuthenticationMode + Container *string + DateFormat *string + PathPattern *string + StorageAccounts *[]StorageAccount + TimeFormat *string + type BlobOutputDataSource struct + Properties *BlobOutputDataSourceProperties + Type string + func (s BlobOutputDataSource) MarshalJSON() ([]byte, error) + func (s BlobOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl + type BlobOutputDataSourceProperties struct + AuthenticationMode *AuthenticationMode + BlobPathPrefix *string + Container *string + DateFormat *string + PathPattern *string + StorageAccounts *[]StorageAccount + TimeFormat *string + type BlobReferenceInputDataSource struct + Properties *BlobDataSourceProperties + Type string + func (s BlobReferenceInputDataSource) MarshalJSON() ([]byte, error) + func (s BlobReferenceInputDataSource) ReferenceInputDataSource() BaseReferenceInputDataSourceImpl + type BlobStreamInputDataSource struct + Properties *BlobStreamInputDataSourceProperties + Type string + func (s BlobStreamInputDataSource) MarshalJSON() ([]byte, error) + func (s BlobStreamInputDataSource) StreamInputDataSource() BaseStreamInputDataSourceImpl + type BlobStreamInputDataSourceProperties struct + AuthenticationMode *AuthenticationMode + Container *string + DateFormat *string + PathPattern *string + SourcePartitionCount *int64 + StorageAccounts *[]StorageAccount + TimeFormat *string + type ClusterInfo struct + Id *string + type CompatibilityLevel string + const CompatibilityLevelOnePointTwo + const CompatibilityLevelOnePointZero + func (s *CompatibilityLevel) UnmarshalJSON(bytes []byte) error + type Compression struct + Type CompressionType + type CompressionType string + const CompressionTypeDeflate + const CompressionTypeGZip + const CompressionTypeNone + func (s *CompressionType) UnmarshalJSON(bytes []byte) error + type ContentStoragePolicy string + const ContentStoragePolicyJobStorageAccount + const ContentStoragePolicySystemAccount + func (s *ContentStoragePolicy) UnmarshalJSON(bytes []byte) error + type CreateOrReplaceOperationOptions struct + IfMatch *string + IfNoneMatch *string + func DefaultCreateOrReplaceOperationOptions() CreateOrReplaceOperationOptions + func (o CreateOrReplaceOperationOptions) ToHeaders() *client.Headers + func (o CreateOrReplaceOperationOptions) ToOData() *odata.Query + func (o CreateOrReplaceOperationOptions) ToQuery() *client.QueryParams + type CreateOrReplaceOperationResponse struct + HttpResponse *http.Response + Model *StreamingJob + OData *odata.OData + Poller pollers.Poller + type CsvSerialization struct + Properties *CsvSerializationProperties + Type EventSerializationType + func (s CsvSerialization) MarshalJSON() ([]byte, error) + func (s CsvSerialization) Serialization() BaseSerializationImpl + type CsvSerializationProperties struct + Encoding *Encoding + FieldDelimiter *string + type DeleteOperationResponse struct + HttpResponse *http.Response + OData *odata.OData + Poller pollers.Poller + type DiagnosticCondition struct + Code *string + Message *string + Since *string + type Diagnostics struct + Conditions *[]DiagnosticCondition + type DocumentDbOutputDataSource struct + Properties *DocumentDbOutputDataSourceProperties + Type string + func (s DocumentDbOutputDataSource) MarshalJSON() ([]byte, error) + func (s DocumentDbOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl + type DocumentDbOutputDataSourceProperties struct + AccountId *string + AccountKey *string + CollectionNamePattern *string + Database *string + DocumentId *string + PartitionKey *string + type Encoding string + const EncodingUTFEight + func (s *Encoding) UnmarshalJSON(bytes []byte) error + type EventHubOutputDataSource struct + Properties *EventHubOutputDataSourceProperties + Type string + func (s EventHubOutputDataSource) MarshalJSON() ([]byte, error) + func (s EventHubOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl + type EventHubOutputDataSourceProperties struct + AuthenticationMode *AuthenticationMode + EventHubName *string + PartitionKey *string + PropertyColumns *[]string + ServiceBusNamespace *string + SharedAccessPolicyKey *string + SharedAccessPolicyName *string + type EventHubStreamInputDataSource struct + Properties *EventHubStreamInputDataSourceProperties + Type string + func (s EventHubStreamInputDataSource) MarshalJSON() ([]byte, error) + func (s EventHubStreamInputDataSource) StreamInputDataSource() BaseStreamInputDataSourceImpl + type EventHubStreamInputDataSourceProperties struct + AuthenticationMode *AuthenticationMode + ConsumerGroupName *string + EventHubName *string + ServiceBusNamespace *string + SharedAccessPolicyKey *string + SharedAccessPolicyName *string + type EventHubV2OutputDataSource struct + Properties *EventHubOutputDataSourceProperties + Type string + func (s EventHubV2OutputDataSource) MarshalJSON() ([]byte, error) + func (s EventHubV2OutputDataSource) OutputDataSource() BaseOutputDataSourceImpl + type EventHubV2StreamInputDataSource struct + Properties *EventHubStreamInputDataSourceProperties + Type string + func (s EventHubV2StreamInputDataSource) MarshalJSON() ([]byte, error) + func (s EventHubV2StreamInputDataSource) StreamInputDataSource() BaseStreamInputDataSourceImpl + type EventSerializationType string + const EventSerializationTypeAvro + const EventSerializationTypeCsv + const EventSerializationTypeJson + const EventSerializationTypeParquet + func (s *EventSerializationType) UnmarshalJSON(bytes []byte) error + type EventsOutOfOrderPolicy string + const EventsOutOfOrderPolicyAdjust + const EventsOutOfOrderPolicyDrop + func (s *EventsOutOfOrderPolicy) UnmarshalJSON(bytes []byte) error + type FileReferenceInputDataSource struct + Properties *FileReferenceInputDataSourceProperties + Type string + func (s FileReferenceInputDataSource) MarshalJSON() ([]byte, error) + func (s FileReferenceInputDataSource) ReferenceInputDataSource() BaseReferenceInputDataSourceImpl + 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 + FunctionBinding func() BaseFunctionBindingImpl + func UnmarshalFunctionBindingImplementation(input []byte) (FunctionBinding, error) + 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 + FunctionProperties func() BaseFunctionPropertiesImpl + func UnmarshalFunctionPropertiesImplementation(input []byte) (FunctionProperties, error) + type GatewayMessageBusOutputDataSource struct + Properties *GatewayMessageBusSourceProperties + Type string + func (s GatewayMessageBusOutputDataSource) MarshalJSON() ([]byte, error) + func (s GatewayMessageBusOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl + type GatewayMessageBusSourceProperties struct + Topic *string + type GatewayMessageBusStreamInputDataSource struct + Properties *GatewayMessageBusSourceProperties + Type string + func (s GatewayMessageBusStreamInputDataSource) MarshalJSON() ([]byte, error) + func (s GatewayMessageBusStreamInputDataSource) StreamInputDataSource() BaseStreamInputDataSourceImpl + type GetOperationOptions struct + Expand *string + func DefaultGetOperationOptions() GetOperationOptions + func (o GetOperationOptions) ToHeaders() *client.Headers + func (o GetOperationOptions) ToOData() *odata.Query + func (o GetOperationOptions) ToQuery() *client.QueryParams + type GetOperationResponse struct + HttpResponse *http.Response + Model *StreamingJob + OData *odata.OData + type Input struct + Id *string + Name *string + Properties InputProperties + Type *string + func (s *Input) UnmarshalJSON(bytes []byte) error + type InputProperties interface + InputProperties func() BaseInputPropertiesImpl + func UnmarshalInputPropertiesImplementation(input []byte) (InputProperties, error) + type IoTHubStreamInputDataSource struct + Properties *IoTHubStreamInputDataSourceProperties + Type string + func (s IoTHubStreamInputDataSource) MarshalJSON() ([]byte, error) + func (s IoTHubStreamInputDataSource) StreamInputDataSource() BaseStreamInputDataSourceImpl + type IoTHubStreamInputDataSourceProperties struct + ConsumerGroupName *string + Endpoint *string + IotHubNamespace *string + SharedAccessPolicyKey *string + SharedAccessPolicyName *string + type JavaScriptFunctionBinding struct + Properties *JavaScriptFunctionBindingProperties + Type string + func (s JavaScriptFunctionBinding) FunctionBinding() BaseFunctionBindingImpl + 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 + func (s *JobType) UnmarshalJSON(bytes []byte) error + type JsonOutputSerializationFormat string + const JsonOutputSerializationFormatArray + const JsonOutputSerializationFormatLineSeparated + func (s *JsonOutputSerializationFormat) UnmarshalJSON(bytes []byte) error + type JsonSerialization struct + Properties *JsonSerializationProperties + Type EventSerializationType + func (s JsonSerialization) MarshalJSON() ([]byte, error) + func (s JsonSerialization) Serialization() BaseSerializationImpl + type JsonSerializationProperties struct + Encoding *Encoding + Format *JsonOutputSerializationFormat + type ListByResourceGroupCompleteResult struct + Items []StreamingJob + LatestHttpResponse *http.Response + type ListByResourceGroupCustomPager struct + NextLink *odata.Link + func (p *ListByResourceGroupCustomPager) NextPageLink() *odata.Link + type ListByResourceGroupOperationOptions struct + Expand *string + func DefaultListByResourceGroupOperationOptions() ListByResourceGroupOperationOptions + func (o ListByResourceGroupOperationOptions) ToHeaders() *client.Headers + func (o ListByResourceGroupOperationOptions) ToOData() *odata.Query + func (o ListByResourceGroupOperationOptions) ToQuery() *client.QueryParams + type ListByResourceGroupOperationResponse struct + HttpResponse *http.Response + Model *[]StreamingJob + OData *odata.OData + type ListCompleteResult struct + Items []StreamingJob + LatestHttpResponse *http.Response + type ListCustomPager struct + NextLink *odata.Link + func (p *ListCustomPager) NextPageLink() *odata.Link + type ListOperationOptions struct + Expand *string + func DefaultListOperationOptions() ListOperationOptions + func (o ListOperationOptions) ToHeaders() *client.Headers + func (o ListOperationOptions) ToOData() *odata.Query + func (o ListOperationOptions) ToQuery() *client.QueryParams + type ListOperationResponse struct + HttpResponse *http.Response + Model *[]StreamingJob + OData *odata.OData + type Output struct + Id *string + Name *string + Properties *OutputProperties + Type *string + type OutputDataSource interface + OutputDataSource func() BaseOutputDataSourceImpl + func UnmarshalOutputDataSourceImplementation(input []byte) (OutputDataSource, error) + type OutputErrorPolicy string + const OutputErrorPolicyDrop + const OutputErrorPolicyStop + func (s *OutputErrorPolicy) UnmarshalJSON(bytes []byte) error + type OutputProperties struct + Datasource OutputDataSource + Diagnostics *Diagnostics + Etag *string + Serialization Serialization + SizeWindow *int64 + TimeWindow *string + func (s *OutputProperties) UnmarshalJSON(bytes []byte) error + type OutputStartMode string + const OutputStartModeCustomTime + const OutputStartModeJobStartTime + const OutputStartModeLastOutputEventTime + func (s *OutputStartMode) UnmarshalJSON(bytes []byte) error + type ParquetSerialization struct + Properties *interface{} + Type EventSerializationType + func (s ParquetSerialization) MarshalJSON() ([]byte, error) + func (s ParquetSerialization) Serialization() BaseSerializationImpl + type PowerBIOutputDataSource struct + Properties *PowerBIOutputDataSourceProperties + Type string + func (s PowerBIOutputDataSource) MarshalJSON() ([]byte, error) + func (s PowerBIOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl + 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{} + func (s RawFunctionBindingImpl) FunctionBinding() BaseFunctionBindingImpl + type RawFunctionPropertiesImpl struct + Type string + Values map[string]interface{} + func (s RawFunctionPropertiesImpl) FunctionProperties() BaseFunctionPropertiesImpl + type RawInputPropertiesImpl struct + Type string + Values map[string]interface{} + func (s RawInputPropertiesImpl) InputProperties() BaseInputPropertiesImpl + type RawOutputDataSourceImpl struct + Type string + Values map[string]interface{} + func (s RawOutputDataSourceImpl) OutputDataSource() BaseOutputDataSourceImpl + type RawReferenceInputDataSourceImpl struct + Type string + Values map[string]interface{} + func (s RawReferenceInputDataSourceImpl) ReferenceInputDataSource() BaseReferenceInputDataSourceImpl + type RawSerializationImpl struct + Type string + Values map[string]interface{} + func (s RawSerializationImpl) Serialization() BaseSerializationImpl + type RawStreamInputDataSourceImpl struct + Type string + Values map[string]interface{} + func (s RawStreamInputDataSourceImpl) StreamInputDataSource() BaseStreamInputDataSourceImpl + type ReferenceInputDataSource interface + ReferenceInputDataSource func() BaseReferenceInputDataSourceImpl + func UnmarshalReferenceInputDataSourceImplementation(input []byte) (ReferenceInputDataSource, error) + type ReferenceInputProperties struct + Compression *Compression + Datasource ReferenceInputDataSource + Diagnostics *Diagnostics + Etag *string + PartitionKey *string + Serialization Serialization + Type string + func (s *ReferenceInputProperties) UnmarshalJSON(bytes []byte) error + func (s ReferenceInputProperties) InputProperties() BaseInputPropertiesImpl + func (s ReferenceInputProperties) MarshalJSON() ([]byte, error) + type RefreshType string + const RefreshTypeRefreshPeriodicallyWithDelta + const RefreshTypeRefreshPeriodicallyWithFull + const RefreshTypeStatic + func (s *RefreshType) UnmarshalJSON(bytes []byte) error + type ScalarFunctionProperties struct + Etag *string + Properties *FunctionConfiguration + Type string + func (s ScalarFunctionProperties) FunctionProperties() BaseFunctionPropertiesImpl + func (s ScalarFunctionProperties) MarshalJSON() ([]byte, error) + type ScaleOperationResponse struct + HttpResponse *http.Response + OData *odata.OData + Poller pollers.Poller + type ScaleStreamingJobParameters struct + StreamingUnits *int64 + type Serialization interface + Serialization func() BaseSerializationImpl + func UnmarshalSerializationImplementation(input []byte) (Serialization, error) + type ServiceBusQueueOutputDataSource struct + Properties *ServiceBusQueueOutputDataSourceProperties + Type string + func (s ServiceBusQueueOutputDataSource) MarshalJSON() ([]byte, error) + func (s ServiceBusQueueOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl + type ServiceBusQueueOutputDataSourceProperties struct + AuthenticationMode *AuthenticationMode + PropertyColumns *[]string + QueueName *string + ServiceBusNamespace *string + SharedAccessPolicyKey *string + SharedAccessPolicyName *string + SystemPropertyColumns *interface{} + type ServiceBusTopicOutputDataSource struct + Properties *ServiceBusTopicOutputDataSourceProperties + Type string + func (s ServiceBusTopicOutputDataSource) MarshalJSON() ([]byte, error) + func (s ServiceBusTopicOutputDataSource) OutputDataSource() BaseOutputDataSourceImpl + type ServiceBusTopicOutputDataSourceProperties struct + AuthenticationMode *AuthenticationMode + PropertyColumns *[]string + ServiceBusNamespace *string + SharedAccessPolicyKey *string + SharedAccessPolicyName *string + SystemPropertyColumns *map[string]string + TopicName *string + type Sku struct + Name *SkuName + type SkuName string + const SkuNameStandard + func (s *SkuName) UnmarshalJSON(bytes []byte) error + type StartOperationResponse struct + HttpResponse *http.Response + OData *odata.OData + Poller pollers.Poller + 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 + OData *odata.OData + Poller pollers.Poller + type StorageAccount struct + AccountKey *string + AccountName *string + type StreamInputDataSource interface + StreamInputDataSource func() BaseStreamInputDataSourceImpl + func UnmarshalStreamInputDataSourceImplementation(input []byte) (StreamInputDataSource, error) + type StreamInputProperties struct + Compression *Compression + Datasource StreamInputDataSource + Diagnostics *Diagnostics + Etag *string + PartitionKey *string + Serialization Serialization + Type string + func (s *StreamInputProperties) UnmarshalJSON(bytes []byte) error + func (s StreamInputProperties) InputProperties() BaseInputPropertiesImpl + func (s StreamInputProperties) MarshalJSON() ([]byte, error) + type StreamingJob struct + Id *string + Identity *identity.SystemAssigned + Location *string + Name *string + Properties *StreamingJobProperties + 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 + 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 *resourcemanager.Client + func NewStreamingJobsClientWithBaseURI(sdkApi sdkEnv.Api) (*StreamingJobsClient, error) + 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) (result ListOperationResponse, err error) + func (c StreamingJobsClient) ListByResourceGroup(ctx context.Context, id commonids.ResourceGroupId, ...) (result 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, ...) (result 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, ...) (result 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) 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 UpdateOperationOptions struct + IfMatch *string + func DefaultUpdateOperationOptions() UpdateOperationOptions + func (o UpdateOperationOptions) ToHeaders() *client.Headers + func (o UpdateOperationOptions) ToOData() *odata.Query + func (o UpdateOperationOptions) ToQuery() *client.QueryParams + type UpdateOperationResponse struct + HttpResponse *http.Response + Model *StreamingJob + OData *odata.OData
Go to main page