armstreamanalytics

package module

Go to main page

Versions in this module

v1

v1.2.0

Nov 24, 2023

v1.1.1

Apr 14, 2023

v1.1.0

Mar 31, 2023

Changes in this version

type AzureDataLakeStoreOutputDataSourceProperties

+ func (a *AzureDataLakeStoreOutputDataSourceProperties) UnmarshalJSON(data []byte) error

+ func (a AzureDataLakeStoreOutputDataSourceProperties) MarshalJSON() ([]byte, error)

type AzureFunctionOutputDataSourceProperties

+ func (a *AzureFunctionOutputDataSourceProperties) UnmarshalJSON(data []byte) error

+ func (a AzureFunctionOutputDataSourceProperties) MarshalJSON() ([]byte, error)

type AzureMachineLearningWebServiceFunctionBindingProperties

+ func (a *AzureMachineLearningWebServiceFunctionBindingProperties) UnmarshalJSON(data []byte) error

type AzureMachineLearningWebServiceFunctionBindingRetrievalProperties

+ func (a *AzureMachineLearningWebServiceFunctionBindingRetrievalProperties) UnmarshalJSON(data []byte) error

+ func (a AzureMachineLearningWebServiceFunctionBindingRetrievalProperties) MarshalJSON() ([]byte, error)

type AzureMachineLearningWebServiceInputColumn

+ func (a *AzureMachineLearningWebServiceInputColumn) UnmarshalJSON(data []byte) error

+ func (a AzureMachineLearningWebServiceInputColumn) MarshalJSON() ([]byte, error)

type AzureMachineLearningWebServiceInputs

+ func (a *AzureMachineLearningWebServiceInputs) UnmarshalJSON(data []byte) error

type AzureMachineLearningWebServiceOutputColumn

+ func (a *AzureMachineLearningWebServiceOutputColumn) UnmarshalJSON(data []byte) error

+ func (a AzureMachineLearningWebServiceOutputColumn) MarshalJSON() ([]byte, error)

type AzureSQLDatabaseDataSourceProperties

+ func (a *AzureSQLDatabaseDataSourceProperties) UnmarshalJSON(data []byte) error

+ func (a AzureSQLDatabaseDataSourceProperties) MarshalJSON() ([]byte, error)

type AzureSQLDatabaseOutputDataSourceProperties

+ func (a *AzureSQLDatabaseOutputDataSourceProperties) UnmarshalJSON(data []byte) error

+ func (a AzureSQLDatabaseOutputDataSourceProperties) MarshalJSON() ([]byte, error)

type AzureSQLReferenceInputDataSourceProperties

+ func (a *AzureSQLReferenceInputDataSourceProperties) UnmarshalJSON(data []byte) error

+ func (a AzureSQLReferenceInputDataSourceProperties) MarshalJSON() ([]byte, error)

type AzureSynapseDataSourceProperties

+ func (a *AzureSynapseDataSourceProperties) UnmarshalJSON(data []byte) error

+ func (a AzureSynapseDataSourceProperties) MarshalJSON() ([]byte, error)

type AzureSynapseOutputDataSourceProperties

+ func (a *AzureSynapseOutputDataSourceProperties) UnmarshalJSON(data []byte) error

+ func (a AzureSynapseOutputDataSourceProperties) MarshalJSON() ([]byte, error)

type AzureTableOutputDataSourceProperties

+ func (a *AzureTableOutputDataSourceProperties) UnmarshalJSON(data []byte) error

type BlobDataSourceProperties

+ func (b *BlobDataSourceProperties) UnmarshalJSON(data []byte) error

type BlobOutputDataSourceProperties

+ func (b *BlobOutputDataSourceProperties) UnmarshalJSON(data []byte) error

type BlobReferenceInputDataSourceProperties

+ func (b *BlobReferenceInputDataSourceProperties) UnmarshalJSON(data []byte) error

type BlobStreamInputDataSourceProperties

+ func (b *BlobStreamInputDataSourceProperties) UnmarshalJSON(data []byte) error

type CSVSerializationProperties

+ func (c *CSVSerializationProperties) UnmarshalJSON(data []byte) error

+ func (c CSVSerializationProperties) MarshalJSON() ([]byte, error)

+ type ClientFactory struct

+ func NewClientFactory(subscriptionID string, credential azcore.TokenCredential, ...) (*ClientFactory, error)

+ func (c *ClientFactory) NewClustersClient() *ClustersClient

+ func (c *ClientFactory) NewFunctionsClient() *FunctionsClient

+ func (c *ClientFactory) NewInputsClient() *InputsClient

+ func (c *ClientFactory) NewOperationsClient() *OperationsClient

+ func (c *ClientFactory) NewOutputsClient() *OutputsClient

+ func (c *ClientFactory) NewPrivateEndpointsClient() *PrivateEndpointsClient

+ func (c *ClientFactory) NewStreamingJobsClient() *StreamingJobsClient

+ func (c *ClientFactory) NewSubscriptionsClient() *SubscriptionsClient

+ func (c *ClientFactory) NewTransformationsClient() *TransformationsClient

type Cluster

+ func (c *Cluster) UnmarshalJSON(data []byte) error

type ClusterInfo

+ func (c *ClusterInfo) UnmarshalJSON(data []byte) error

+ func (c ClusterInfo) MarshalJSON() ([]byte, error)

type ClusterJob

+ func (c *ClusterJob) UnmarshalJSON(data []byte) error

+ func (c ClusterJob) MarshalJSON() ([]byte, error)

type ClusterJobListResult

+ func (c *ClusterJobListResult) UnmarshalJSON(data []byte) error

type ClusterListResult

+ func (c *ClusterListResult) UnmarshalJSON(data []byte) error

type ClusterSKU

+ func (c *ClusterSKU) UnmarshalJSON(data []byte) error

+ func (c ClusterSKU) MarshalJSON() ([]byte, error)

type Compression

+ func (c *Compression) UnmarshalJSON(data []byte) error

+ func (c Compression) MarshalJSON() ([]byte, error)

type DiagnosticCondition

+ func (d *DiagnosticCondition) UnmarshalJSON(data []byte) error

+ func (d DiagnosticCondition) MarshalJSON() ([]byte, error)

type Diagnostics

+ func (d *Diagnostics) UnmarshalJSON(data []byte) error

type DocumentDbOutputDataSourceProperties

+ func (d *DocumentDbOutputDataSourceProperties) UnmarshalJSON(data []byte) error

+ func (d DocumentDbOutputDataSourceProperties) MarshalJSON() ([]byte, error)

type Error

+ func (e *Error) UnmarshalJSON(data []byte) error

+ func (e Error) MarshalJSON() ([]byte, error)

type ErrorDetails

+ func (e *ErrorDetails) UnmarshalJSON(data []byte) error

+ func (e ErrorDetails) MarshalJSON() ([]byte, error)

type ErrorError

+ func (e *ErrorError) UnmarshalJSON(data []byte) error

type ErrorResponse

+ func (e *ErrorResponse) UnmarshalJSON(data []byte) error

+ func (e ErrorResponse) MarshalJSON() ([]byte, error)

type EventHubDataSourceProperties

+ func (e *EventHubDataSourceProperties) UnmarshalJSON(data []byte) error

type EventHubOutputDataSourceProperties

+ func (e *EventHubOutputDataSourceProperties) UnmarshalJSON(data []byte) error

type EventHubStreamInputDataSourceProperties

+ func (e *EventHubStreamInputDataSourceProperties) UnmarshalJSON(data []byte) error

type FunctionBinding

+ func (f FunctionBinding) MarshalJSON() ([]byte, error)

type FunctionInput

+ func (f *FunctionInput) UnmarshalJSON(data []byte) error

+ func (f FunctionInput) MarshalJSON() ([]byte, error)

type FunctionListResult

+ func (f *FunctionListResult) UnmarshalJSON(data []byte) error

type FunctionOutput

+ func (f *FunctionOutput) UnmarshalJSON(data []byte) error

+ func (f FunctionOutput) MarshalJSON() ([]byte, error)

type FunctionProperties

+ func (f FunctionProperties) MarshalJSON() ([]byte, error)

type FunctionRetrieveDefaultDefinitionParameters

+ func (f FunctionRetrieveDefaultDefinitionParameters) MarshalJSON() ([]byte, error)

type Identity

+ func (i *Identity) UnmarshalJSON(data []byte) error

+ func (i Identity) MarshalJSON() ([]byte, error)

type InputListResult

+ func (i *InputListResult) UnmarshalJSON(data []byte) error

type IoTHubStreamInputDataSourceProperties

+ func (i *IoTHubStreamInputDataSourceProperties) UnmarshalJSON(data []byte) error

+ func (i IoTHubStreamInputDataSourceProperties) MarshalJSON() ([]byte, error)

type JSONSerializationProperties

+ func (j *JSONSerializationProperties) UnmarshalJSON(data []byte) error

+ func (j JSONSerializationProperties) MarshalJSON() ([]byte, error)

type JavaScriptFunctionBindingProperties

+ func (j *JavaScriptFunctionBindingProperties) UnmarshalJSON(data []byte) error

+ func (j JavaScriptFunctionBindingProperties) MarshalJSON() ([]byte, error)

type JavaScriptFunctionBindingRetrievalProperties

+ func (j *JavaScriptFunctionBindingRetrievalProperties) UnmarshalJSON(data []byte) error

+ func (j JavaScriptFunctionBindingRetrievalProperties) MarshalJSON() ([]byte, error)

type JobStorageAccount

+ func (j *JobStorageAccount) UnmarshalJSON(data []byte) error

+ func (j JobStorageAccount) MarshalJSON() ([]byte, error)

type OAuthBasedDataSourceProperties

+ func (o *OAuthBasedDataSourceProperties) UnmarshalJSON(data []byte) error

+ func (o OAuthBasedDataSourceProperties) MarshalJSON() ([]byte, error)

type Operation

+ func (o *Operation) UnmarshalJSON(data []byte) error

+ func (o Operation) MarshalJSON() ([]byte, error)

type OperationDisplay

+ func (o *OperationDisplay) UnmarshalJSON(data []byte) error

+ func (o OperationDisplay) MarshalJSON() ([]byte, error)

type OperationListResult

+ func (o *OperationListResult) UnmarshalJSON(data []byte) error

type OutputDataSource

+ func (o OutputDataSource) MarshalJSON() ([]byte, error)

type OutputListResult

+ func (o *OutputListResult) UnmarshalJSON(data []byte) error

type PowerBIOutputDataSourceProperties

+ func (p *PowerBIOutputDataSourceProperties) UnmarshalJSON(data []byte) error

+ func (p PowerBIOutputDataSourceProperties) MarshalJSON() ([]byte, error)

type PrivateEndpoint

+ func (p *PrivateEndpoint) UnmarshalJSON(data []byte) error

type PrivateEndpointListResult

+ func (p *PrivateEndpointListResult) UnmarshalJSON(data []byte) error

type PrivateEndpointProperties

+ func (p *PrivateEndpointProperties) UnmarshalJSON(data []byte) error

type PrivateLinkConnectionState

+ func (p *PrivateLinkConnectionState) UnmarshalJSON(data []byte) error

+ func (p PrivateLinkConnectionState) MarshalJSON() ([]byte, error)

type PrivateLinkServiceConnection

+ func (p *PrivateLinkServiceConnection) UnmarshalJSON(data []byte) error

+ func (p PrivateLinkServiceConnection) MarshalJSON() ([]byte, error)

type PrivateLinkServiceConnectionProperties

+ func (p *PrivateLinkServiceConnectionProperties) UnmarshalJSON(data []byte) error

type ProxyResource

+ func (p *ProxyResource) UnmarshalJSON(data []byte) error

+ func (p ProxyResource) MarshalJSON() ([]byte, error)

type ReferenceInputDataSource

+ func (r ReferenceInputDataSource) MarshalJSON() ([]byte, error)

type Resource

+ func (r *Resource) UnmarshalJSON(data []byte) error

type ResourceTestStatus

+ func (r *ResourceTestStatus) UnmarshalJSON(data []byte) error

+ func (r ResourceTestStatus) MarshalJSON() ([]byte, error)

type SKU

+ func (s *SKU) UnmarshalJSON(data []byte) error

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

type ScaleStreamingJobParameters

+ func (s *ScaleStreamingJobParameters) UnmarshalJSON(data []byte) error

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

type Serialization

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

type ServiceBusDataSourceProperties

+ func (s *ServiceBusDataSourceProperties) UnmarshalJSON(data []byte) error

type ServiceBusQueueOutputDataSourceProperties

+ func (s *ServiceBusQueueOutputDataSourceProperties) UnmarshalJSON(data []byte) error

type ServiceBusTopicOutputDataSourceProperties

+ func (s *ServiceBusTopicOutputDataSourceProperties) UnmarshalJSON(data []byte) error

type StorageAccount

+ func (s *StorageAccount) UnmarshalJSON(data []byte) error

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

type StreamInputDataSource

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

type StreamingJob

+ func (s *StreamingJob) UnmarshalJSON(data []byte) error

type StreamingJobListResult

+ func (s *StreamingJobListResult) UnmarshalJSON(data []byte) error

type SubscriptionQuotaProperties

+ func (s *SubscriptionQuotaProperties) UnmarshalJSON(data []byte) error

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

type SubscriptionQuotasListResult

+ func (s *SubscriptionQuotasListResult) UnmarshalJSON(data []byte) error

type TrackedResource

+ func (t *TrackedResource) UnmarshalJSON(data []byte) error

type TransformationProperties

+ func (t *TransformationProperties) UnmarshalJSON(data []byte) error

v1.0.0

May 18, 2022

v0

v0.5.0

Apr 18, 2022

Changes in this version

type ClustersClient

+ func (client *ClustersClient) NewListByResourceGroupPager(resourceGroupName string, options *ClustersClientListByResourceGroupOptions) *runtime.Pager[ClustersClientListByResourceGroupResponse]

+ func (client *ClustersClient) NewListBySubscriptionPager(options *ClustersClientListBySubscriptionOptions) *runtime.Pager[ClustersClientListBySubscriptionResponse]

+ func (client *ClustersClient) NewListStreamingJobsPager(resourceGroupName string, clusterName string, ...) *runtime.Pager[ClustersClientListStreamingJobsResponse]

type FunctionsClient

+ func (client *FunctionsClient) NewListByStreamingJobPager(resourceGroupName string, jobName string, ...) *runtime.Pager[FunctionsClientListByStreamingJobResponse]

type InputsClient

+ func (client *InputsClient) NewListByStreamingJobPager(resourceGroupName string, jobName string, ...) *runtime.Pager[InputsClientListByStreamingJobResponse]

type OperationsClient

+ func (client *OperationsClient) NewListPager(options *OperationsClientListOptions) *runtime.Pager[OperationsClientListResponse]

type OutputsClient

+ func (client *OutputsClient) NewListByStreamingJobPager(resourceGroupName string, jobName string, ...) *runtime.Pager[OutputsClientListByStreamingJobResponse]

type PrivateEndpointsClient

+ func (client *PrivateEndpointsClient) NewListByClusterPager(resourceGroupName string, clusterName string, ...) *runtime.Pager[PrivateEndpointsClientListByClusterResponse]

type StreamingJobsClient

+ func (client *StreamingJobsClient) NewListByResourceGroupPager(resourceGroupName string, ...) *runtime.Pager[StreamingJobsClientListByResourceGroupResponse]

+ func (client *StreamingJobsClient) NewListPager(options *StreamingJobsClientListOptions) *runtime.Pager[StreamingJobsClientListResponse]

v0.4.0

Apr 13, 2022

Changes in this version

type AggregateFunctionProperties

+ Etag *string

+ Properties *FunctionConfiguration

+ Type *string

+ func (a *AggregateFunctionProperties) GetFunctionProperties() *FunctionProperties

+ func (a *AggregateFunctionProperties) UnmarshalJSON(data []byte) error

type AzureFunctionOutputDataSource

+ Type *string

+ func (a *AzureFunctionOutputDataSource) GetOutputDataSource() *OutputDataSource

type BlobDataSourceProperties

+ AuthenticationMode *AuthenticationMode

type BlobReferenceInputDataSourceProperties

+ AuthenticationMode *AuthenticationMode

type BlobStreamInputDataSourceProperties

+ AuthenticationMode *AuthenticationMode

type ClustersClientBeginCreateOrUpdateOptions

+ ResumeToken string

type ClustersClientBeginDeleteOptions

+ ResumeToken string

type ClustersClientBeginUpdateOptions

+ ResumeToken string

type FunctionsClientBeginTestOptions

+ ResumeToken string

type FunctionsClientCreateOrReplaceResponse

+ ETag *string

type FunctionsClientGetResponse

+ ETag *string

type FunctionsClientUpdateResponse

+ ETag *string

type InputsClientBeginTestOptions

+ ResumeToken string

type InputsClientCreateOrReplaceResponse

+ ETag *string

type InputsClientGetResponse

+ ETag *string

type InputsClientUpdateResponse

+ ETag *string

type OutputsClientBeginTestOptions

+ ResumeToken string

type OutputsClientCreateOrReplaceResponse

+ ETag *string

type OutputsClientGetResponse

+ ETag *string

type OutputsClientUpdateResponse

+ ETag *string

type PrivateEndpointsClientBeginDeleteOptions

+ ResumeToken string

type StreamingJobsClientBeginCreateOrReplaceOptions

+ ResumeToken string

type StreamingJobsClientBeginDeleteOptions

+ ResumeToken string

type StreamingJobsClientBeginScaleOptions

+ ResumeToken string

type StreamingJobsClientBeginStartOptions

+ ResumeToken string

type StreamingJobsClientBeginStopOptions

+ ResumeToken string

type StreamingJobsClientGetResponse

+ ETag *string

type StreamingJobsClientUpdateResponse

+ ETag *string

type TransformationsClientCreateOrReplaceResponse

+ ETag *string

type TransformationsClientGetResponse

+ ETag *string

type TransformationsClientUpdateResponse

+ ETag *string

v0.3.1

Feb 21, 2022

v0.3.0

Jan 14, 2022

Changes in this version

type AvroSerialization

+ Type *EventSerializationType

+ func (a *AvroSerialization) GetSerialization() *Serialization

type AzureDataLakeStoreOutputDataSource

+ Type *string

+ func (a *AzureDataLakeStoreOutputDataSource) GetOutputDataSource() *OutputDataSource

type AzureDataLakeStoreOutputDataSourceProperties

+ RefreshToken *string

+ TokenUserDisplayName *string

+ TokenUserPrincipalName *string

+ type AzureMachineLearningWebServiceFunctionBinding struct

+ Properties *AzureMachineLearningWebServiceFunctionBindingProperties

+ Type *string

+ func (a *AzureMachineLearningWebServiceFunctionBinding) GetFunctionBinding() *FunctionBinding

+ func (a *AzureMachineLearningWebServiceFunctionBinding) UnmarshalJSON(data []byte) error

+ func (a AzureMachineLearningWebServiceFunctionBinding) MarshalJSON() ([]byte, error)

+ type AzureMachineLearningWebServiceFunctionBindingProperties struct

+ APIKey *string

+ BatchSize *int32

+ Endpoint *string

+ Inputs *AzureMachineLearningWebServiceInputs

+ Outputs []*AzureMachineLearningWebServiceOutputColumn

+ func (a AzureMachineLearningWebServiceFunctionBindingProperties) MarshalJSON() ([]byte, error)

+ type AzureMachineLearningWebServiceFunctionBindingRetrievalProperties struct

+ ExecuteEndpoint *string

+ UdfType *string

+ type AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters struct

+ BindingRetrievalProperties *AzureMachineLearningWebServiceFunctionBindingRetrievalProperties

+ BindingType *string

+ func (a *AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters) GetFunctionRetrieveDefaultDefinitionParameters() *FunctionRetrieveDefaultDefinitionParameters

+ func (a *AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters) UnmarshalJSON(data []byte) error

+ func (a AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters) MarshalJSON() ([]byte, error)

+ type AzureMachineLearningWebServiceInputColumn struct

+ DataType *string

+ MapTo *int32

+ Name *string

+ type AzureMachineLearningWebServiceInputs struct

+ ColumnNames []*AzureMachineLearningWebServiceInputColumn

+ Name *string

+ func (a AzureMachineLearningWebServiceInputs) MarshalJSON() ([]byte, error)

+ type AzureMachineLearningWebServiceOutputColumn struct

+ DataType *string

+ Name *string

type AzureSQLDatabaseOutputDataSource

+ Type *string

+ func (a *AzureSQLDatabaseOutputDataSource) GetOutputDataSource() *OutputDataSource

type AzureSQLDatabaseOutputDataSourceProperties

+ AuthenticationMode *AuthenticationMode

+ Database *string

+ MaxBatchCount *float32

+ MaxWriterCount *float32

+ Password *string

+ Server *string

+ Table *string

+ User *string

type AzureSQLReferenceInputDataSource

+ Type *string

+ func (a *AzureSQLReferenceInputDataSource) GetReferenceInputDataSource() *ReferenceInputDataSource

type AzureSynapseOutputDataSource

+ Type *string

+ func (a *AzureSynapseOutputDataSource) GetOutputDataSource() *OutputDataSource

type AzureSynapseOutputDataSourceProperties

+ Database *string

+ Password *string

+ Server *string

+ Table *string

+ User *string

type AzureTableOutputDataSource

+ Type *string

+ func (a *AzureTableOutputDataSource) GetOutputDataSource() *OutputDataSource

type BlobOutputDataSource

+ Type *string

+ func (b *BlobOutputDataSource) GetOutputDataSource() *OutputDataSource

type BlobOutputDataSourceProperties

+ Container *string

+ DateFormat *string

+ PathPattern *string

+ StorageAccounts []*StorageAccount

+ TimeFormat *string

type BlobReferenceInputDataSource

+ Type *string

+ func (b *BlobReferenceInputDataSource) GetReferenceInputDataSource() *ReferenceInputDataSource

type BlobReferenceInputDataSourceProperties

+ Container *string

+ DateFormat *string

+ PathPattern *string

+ StorageAccounts []*StorageAccount

+ TimeFormat *string

+ func (b BlobReferenceInputDataSourceProperties) MarshalJSON() ([]byte, error)

type BlobStreamInputDataSource

+ Type *string

+ func (b *BlobStreamInputDataSource) GetStreamInputDataSource() *StreamInputDataSource

type BlobStreamInputDataSourceProperties

+ Container *string

+ DateFormat *string

+ PathPattern *string

+ StorageAccounts []*StorageAccount

+ TimeFormat *string

type CSVSerialization

+ Type *EventSerializationType

+ func (c *CSVSerialization) GetSerialization() *Serialization

type Cluster

+ ID *string

+ Location *string

+ Name *string

+ Tags map[string]*string

+ Type *string

+ type ClustersClientBeginCreateOrUpdateOptions struct

+ IfMatch *string

+ IfNoneMatch *string

+ type ClustersClientBeginDeleteOptions struct

+ type ClustersClientBeginUpdateOptions struct

+ IfMatch *string

+ type ClustersClientCreateOrUpdatePoller struct

+ func (p *ClustersClientCreateOrUpdatePoller) Done() bool

+ func (p *ClustersClientCreateOrUpdatePoller) FinalResponse(ctx context.Context) (ClustersClientCreateOrUpdateResponse, error)

+ func (p *ClustersClientCreateOrUpdatePoller) Poll(ctx context.Context) (*http.Response, error)

+ func (p *ClustersClientCreateOrUpdatePoller) ResumeToken() (string, error)

+ type ClustersClientCreateOrUpdatePollerResponse struct

+ Poller *ClustersClientCreateOrUpdatePoller

+ RawResponse *http.Response

+ func (l *ClustersClientCreateOrUpdatePollerResponse) Resume(ctx context.Context, client *ClustersClient, token string) error

+ func (l ClustersClientCreateOrUpdatePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (ClustersClientCreateOrUpdateResponse, error)

+ type ClustersClientCreateOrUpdateResponse struct

+ RawResponse *http.Response

+ type ClustersClientCreateOrUpdateResult struct

+ type ClustersClientDeletePoller struct

+ func (p *ClustersClientDeletePoller) Done() bool

+ func (p *ClustersClientDeletePoller) FinalResponse(ctx context.Context) (ClustersClientDeleteResponse, error)

+ func (p *ClustersClientDeletePoller) Poll(ctx context.Context) (*http.Response, error)

+ func (p *ClustersClientDeletePoller) ResumeToken() (string, error)

+ type ClustersClientDeletePollerResponse struct

+ Poller *ClustersClientDeletePoller

+ RawResponse *http.Response

+ func (l *ClustersClientDeletePollerResponse) Resume(ctx context.Context, client *ClustersClient, token string) error

+ func (l ClustersClientDeletePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (ClustersClientDeleteResponse, error)

+ type ClustersClientDeleteResponse struct

+ RawResponse *http.Response

+ type ClustersClientGetOptions struct

+ type ClustersClientGetResponse struct

+ RawResponse *http.Response

+ type ClustersClientGetResult struct

+ type ClustersClientListByResourceGroupOptions struct

+ type ClustersClientListByResourceGroupPager struct

+ func (p *ClustersClientListByResourceGroupPager) Err() error

+ func (p *ClustersClientListByResourceGroupPager) NextPage(ctx context.Context) bool

+ func (p *ClustersClientListByResourceGroupPager) PageResponse() ClustersClientListByResourceGroupResponse

+ type ClustersClientListByResourceGroupResponse struct

+ RawResponse *http.Response

+ type ClustersClientListByResourceGroupResult struct

+ type ClustersClientListBySubscriptionOptions struct

+ type ClustersClientListBySubscriptionPager struct

+ func (p *ClustersClientListBySubscriptionPager) Err() error

+ func (p *ClustersClientListBySubscriptionPager) NextPage(ctx context.Context) bool

+ func (p *ClustersClientListBySubscriptionPager) PageResponse() ClustersClientListBySubscriptionResponse

+ type ClustersClientListBySubscriptionResponse struct

+ RawResponse *http.Response

+ type ClustersClientListBySubscriptionResult struct

+ type ClustersClientListStreamingJobsOptions struct

+ type ClustersClientListStreamingJobsPager struct

+ func (p *ClustersClientListStreamingJobsPager) Err() error

+ func (p *ClustersClientListStreamingJobsPager) NextPage(ctx context.Context) bool

+ func (p *ClustersClientListStreamingJobsPager) PageResponse() ClustersClientListStreamingJobsResponse

+ type ClustersClientListStreamingJobsResponse struct

+ RawResponse *http.Response

+ type ClustersClientListStreamingJobsResult struct

+ type ClustersClientUpdatePoller struct

+ func (p *ClustersClientUpdatePoller) Done() bool

+ func (p *ClustersClientUpdatePoller) FinalResponse(ctx context.Context) (ClustersClientUpdateResponse, error)

+ func (p *ClustersClientUpdatePoller) Poll(ctx context.Context) (*http.Response, error)

+ func (p *ClustersClientUpdatePoller) ResumeToken() (string, error)

+ type ClustersClientUpdatePollerResponse struct

+ Poller *ClustersClientUpdatePoller

+ RawResponse *http.Response

+ func (l *ClustersClientUpdatePollerResponse) Resume(ctx context.Context, client *ClustersClient, token string) error

+ func (l ClustersClientUpdatePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (ClustersClientUpdateResponse, error)

+ type ClustersClientUpdateResponse struct

+ RawResponse *http.Response

+ type ClustersClientUpdateResult struct

type CompatibilityLevel

+ const CompatibilityLevelOne2

+ type CompressionType string

+ const CompressionTypeDeflate

+ const CompressionTypeGZip

+ const CompressionTypeNone

+ func PossibleCompressionTypeValues() []CompressionType

+ func (c CompressionType) ToPtr() *CompressionType

type DocumentDbOutputDataSource

+ Type *string

+ func (d *DocumentDbOutputDataSource) GetOutputDataSource() *OutputDataSource

type EventHubDataSourceProperties

+ AuthenticationMode *AuthenticationMode

+ ServiceBusNamespace *string

+ SharedAccessPolicyKey *string

+ SharedAccessPolicyName *string

type EventHubOutputDataSource

+ Type *string

+ func (e *EventHubOutputDataSource) GetOutputDataSource() *OutputDataSource

type EventHubOutputDataSourceProperties

+ AuthenticationMode *AuthenticationMode

+ EventHubName *string

+ ServiceBusNamespace *string

+ SharedAccessPolicyKey *string

+ SharedAccessPolicyName *string

type EventHubStreamInputDataSource

+ Type *string

+ func (e *EventHubStreamInputDataSource) GetStreamInputDataSource() *StreamInputDataSource

type EventHubStreamInputDataSourceProperties

+ AuthenticationMode *AuthenticationMode

+ EventHubName *string

+ ServiceBusNamespace *string

+ SharedAccessPolicyKey *string

+ SharedAccessPolicyName *string

type EventHubV2OutputDataSource

+ Type *string

+ func (e *EventHubV2OutputDataSource) GetOutputDataSource() *OutputDataSource

type EventHubV2StreamInputDataSource

+ Type *string

+ func (e *EventHubV2StreamInputDataSource) GetStreamInputDataSource() *StreamInputDataSource

type Function

+ ID *string

+ Name *string

+ Type *string

+ type FunctionsClientBeginTestOptions struct

+ Function *Function

+ type FunctionsClientCreateOrReplaceOptions struct

+ IfMatch *string

+ IfNoneMatch *string

+ type FunctionsClientCreateOrReplaceResponse struct

+ RawResponse *http.Response

+ type FunctionsClientCreateOrReplaceResult struct

+ ETag *string

+ type FunctionsClientDeleteOptions struct

+ type FunctionsClientDeleteResponse struct

+ RawResponse *http.Response

+ type FunctionsClientGetOptions struct

+ type FunctionsClientGetResponse struct

+ RawResponse *http.Response

+ type FunctionsClientGetResult struct

+ ETag *string

+ type FunctionsClientListByStreamingJobOptions struct

+ Select *string

+ type FunctionsClientListByStreamingJobPager struct

+ func (p *FunctionsClientListByStreamingJobPager) Err() error

+ func (p *FunctionsClientListByStreamingJobPager) NextPage(ctx context.Context) bool

+ func (p *FunctionsClientListByStreamingJobPager) PageResponse() FunctionsClientListByStreamingJobResponse

+ type FunctionsClientListByStreamingJobResponse struct

+ RawResponse *http.Response

+ type FunctionsClientListByStreamingJobResult struct

+ type FunctionsClientRetrieveDefaultDefinitionOptions struct

+ FunctionRetrieveDefaultDefinitionParameters FunctionRetrieveDefaultDefinitionParametersClassification

+ type FunctionsClientRetrieveDefaultDefinitionResponse struct

+ RawResponse *http.Response

+ type FunctionsClientRetrieveDefaultDefinitionResult struct

+ type FunctionsClientTestPoller struct

+ func (p *FunctionsClientTestPoller) Done() bool

+ func (p *FunctionsClientTestPoller) FinalResponse(ctx context.Context) (FunctionsClientTestResponse, error)

+ func (p *FunctionsClientTestPoller) Poll(ctx context.Context) (*http.Response, error)

+ func (p *FunctionsClientTestPoller) ResumeToken() (string, error)

+ type FunctionsClientTestPollerResponse struct

+ Poller *FunctionsClientTestPoller

+ RawResponse *http.Response

+ func (l *FunctionsClientTestPollerResponse) Resume(ctx context.Context, client *FunctionsClient, token string) error

+ func (l FunctionsClientTestPollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (FunctionsClientTestResponse, error)

+ type FunctionsClientTestResponse struct

+ RawResponse *http.Response

+ type FunctionsClientTestResult struct

+ type FunctionsClientUpdateOptions struct

+ IfMatch *string

+ type FunctionsClientUpdateResponse struct

+ RawResponse *http.Response

+ type FunctionsClientUpdateResult struct

+ ETag *string

type Input

+ ID *string

+ Name *string

+ Type *string

type InputProperties

+ func (i InputProperties) MarshalJSON() ([]byte, error)

+ type InputsClientBeginTestOptions struct

+ Input *Input

+ type InputsClientCreateOrReplaceOptions struct

+ IfMatch *string

+ IfNoneMatch *string

+ type InputsClientCreateOrReplaceResponse struct

+ RawResponse *http.Response

+ type InputsClientCreateOrReplaceResult struct

+ ETag *string

+ type InputsClientDeleteOptions struct

+ type InputsClientDeleteResponse struct

+ RawResponse *http.Response

+ type InputsClientGetOptions struct

+ type InputsClientGetResponse struct

+ RawResponse *http.Response

+ type InputsClientGetResult struct

+ ETag *string

+ type InputsClientListByStreamingJobOptions struct

+ Select *string

+ type InputsClientListByStreamingJobPager struct

+ func (p *InputsClientListByStreamingJobPager) Err() error

+ func (p *InputsClientListByStreamingJobPager) NextPage(ctx context.Context) bool

+ func (p *InputsClientListByStreamingJobPager) PageResponse() InputsClientListByStreamingJobResponse

+ type InputsClientListByStreamingJobResponse struct

+ RawResponse *http.Response

+ type InputsClientListByStreamingJobResult struct

+ type InputsClientTestPoller struct

+ func (p *InputsClientTestPoller) Done() bool

+ func (p *InputsClientTestPoller) FinalResponse(ctx context.Context) (InputsClientTestResponse, error)

+ func (p *InputsClientTestPoller) Poll(ctx context.Context) (*http.Response, error)

+ func (p *InputsClientTestPoller) ResumeToken() (string, error)

+ type InputsClientTestPollerResponse struct

+ Poller *InputsClientTestPoller

+ RawResponse *http.Response

+ func (l *InputsClientTestPollerResponse) Resume(ctx context.Context, client *InputsClient, token string) error

+ func (l InputsClientTestPollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (InputsClientTestResponse, error)

+ type InputsClientTestResponse struct

+ RawResponse *http.Response

+ type InputsClientTestResult struct

+ type InputsClientUpdateOptions struct

+ IfMatch *string

+ type InputsClientUpdateResponse struct

+ RawResponse *http.Response

+ type InputsClientUpdateResult struct

+ ETag *string

type IoTHubStreamInputDataSource

+ Type *string

+ func (i *IoTHubStreamInputDataSource) GetStreamInputDataSource() *StreamInputDataSource

type JSONSerialization

+ Type *EventSerializationType

+ func (j *JSONSerialization) GetSerialization() *Serialization

type JavaScriptFunctionBinding

+ Type *string

+ func (j *JavaScriptFunctionBinding) GetFunctionBinding() *FunctionBinding

type JavaScriptFunctionRetrieveDefaultDefinitionParameters

+ BindingType *string

+ func (j *JavaScriptFunctionRetrieveDefaultDefinitionParameters) GetFunctionRetrieveDefaultDefinitionParameters() *FunctionRetrieveDefaultDefinitionParameters

type JobStorageAccount

+ AccountKey *string

+ AccountName *string

type Operation

+ IsDataAction *bool

+ type OperationsClientListOptions struct

+ type OperationsClientListPager struct

+ func (p *OperationsClientListPager) Err() error

+ func (p *OperationsClientListPager) NextPage(ctx context.Context) bool

+ func (p *OperationsClientListPager) PageResponse() OperationsClientListResponse

+ type OperationsClientListResponse struct

+ RawResponse *http.Response

+ type OperationsClientListResult struct

type Output

+ ID *string

+ Name *string

+ Type *string

+ type OutputsClientBeginTestOptions struct

+ Output *Output

+ type OutputsClientCreateOrReplaceOptions struct

+ IfMatch *string

+ IfNoneMatch *string

+ type OutputsClientCreateOrReplaceResponse struct

+ RawResponse *http.Response

+ type OutputsClientCreateOrReplaceResult struct

+ ETag *string

+ type OutputsClientDeleteOptions struct

+ type OutputsClientDeleteResponse struct

+ RawResponse *http.Response

+ type OutputsClientGetOptions struct

+ type OutputsClientGetResponse struct

+ RawResponse *http.Response

+ type OutputsClientGetResult struct

+ ETag *string

+ type OutputsClientListByStreamingJobOptions struct

+ Select *string

+ type OutputsClientListByStreamingJobPager struct

+ func (p *OutputsClientListByStreamingJobPager) Err() error

+ func (p *OutputsClientListByStreamingJobPager) NextPage(ctx context.Context) bool

+ func (p *OutputsClientListByStreamingJobPager) PageResponse() OutputsClientListByStreamingJobResponse

+ type OutputsClientListByStreamingJobResponse struct

+ RawResponse *http.Response

+ type OutputsClientListByStreamingJobResult struct

+ type OutputsClientTestPoller struct

+ func (p *OutputsClientTestPoller) Done() bool

+ func (p *OutputsClientTestPoller) FinalResponse(ctx context.Context) (OutputsClientTestResponse, error)

+ func (p *OutputsClientTestPoller) Poll(ctx context.Context) (*http.Response, error)

+ func (p *OutputsClientTestPoller) ResumeToken() (string, error)

+ type OutputsClientTestPollerResponse struct

+ Poller *OutputsClientTestPoller

+ RawResponse *http.Response

+ func (l *OutputsClientTestPollerResponse) Resume(ctx context.Context, client *OutputsClient, token string) error

+ func (l OutputsClientTestPollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (OutputsClientTestResponse, error)

+ type OutputsClientTestResponse struct

+ RawResponse *http.Response

+ type OutputsClientTestResult struct

+ type OutputsClientUpdateOptions struct

+ IfMatch *string

+ type OutputsClientUpdateResponse struct

+ RawResponse *http.Response

+ type OutputsClientUpdateResult struct

+ ETag *string

type ParquetSerialization

+ Type *EventSerializationType

+ func (p *ParquetSerialization) GetSerialization() *Serialization

type PowerBIOutputDataSource

+ Type *string

+ func (p *PowerBIOutputDataSource) GetOutputDataSource() *OutputDataSource

type PowerBIOutputDataSourceProperties

+ RefreshToken *string

+ TokenUserDisplayName *string

+ TokenUserPrincipalName *string

type PrivateEndpoint

+ ID *string

+ Name *string

+ Type *string

+ type PrivateEndpointsClientBeginDeleteOptions struct

+ type PrivateEndpointsClientCreateOrUpdateOptions struct

+ IfMatch *string

+ IfNoneMatch *string

+ type PrivateEndpointsClientCreateOrUpdateResponse struct

+ RawResponse *http.Response

+ type PrivateEndpointsClientCreateOrUpdateResult struct

+ type PrivateEndpointsClientDeletePoller struct

+ func (p *PrivateEndpointsClientDeletePoller) Done() bool

+ func (p *PrivateEndpointsClientDeletePoller) FinalResponse(ctx context.Context) (PrivateEndpointsClientDeleteResponse, error)

+ func (p *PrivateEndpointsClientDeletePoller) Poll(ctx context.Context) (*http.Response, error)

+ func (p *PrivateEndpointsClientDeletePoller) ResumeToken() (string, error)

+ type PrivateEndpointsClientDeletePollerResponse struct

+ Poller *PrivateEndpointsClientDeletePoller

+ RawResponse *http.Response

+ func (l *PrivateEndpointsClientDeletePollerResponse) Resume(ctx context.Context, client *PrivateEndpointsClient, token string) error

+ func (l PrivateEndpointsClientDeletePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (PrivateEndpointsClientDeleteResponse, error)

+ type PrivateEndpointsClientDeleteResponse struct

+ RawResponse *http.Response

+ type PrivateEndpointsClientGetOptions struct

+ type PrivateEndpointsClientGetResponse struct

+ RawResponse *http.Response

+ type PrivateEndpointsClientGetResult struct

+ type PrivateEndpointsClientListByClusterOptions struct

+ type PrivateEndpointsClientListByClusterPager struct

+ func (p *PrivateEndpointsClientListByClusterPager) Err() error

+ func (p *PrivateEndpointsClientListByClusterPager) NextPage(ctx context.Context) bool

+ func (p *PrivateEndpointsClientListByClusterPager) PageResponse() PrivateEndpointsClientListByClusterResponse

+ type PrivateEndpointsClientListByClusterResponse struct

+ RawResponse *http.Response

+ type PrivateEndpointsClientListByClusterResult struct

type ProxyResource

+ ID *string

+ Name *string

+ Type *string

type ReferenceInputProperties

+ Compression *Compression

+ Diagnostics *Diagnostics

+ Etag *string

+ PartitionKey *string

+ Serialization SerializationClassification

+ Type *string

+ func (r *ReferenceInputProperties) GetInputProperties() *InputProperties

+ type RefreshType string

+ const RefreshTypeRefreshPeriodicallyWithDelta

+ const RefreshTypeRefreshPeriodicallyWithFull

+ const RefreshTypeStatic

+ func PossibleRefreshTypeValues() []RefreshType

+ func (c RefreshType) ToPtr() *RefreshType

+ type SKU struct

+ Name *SKUName

+ type SKUName string

+ const SKUNameStandard

+ func PossibleSKUNameValues() []SKUName

+ func (c SKUName) ToPtr() *SKUName

+ type ScalarFunctionConfiguration struct

+ Binding FunctionBindingClassification

+ Inputs []*FunctionInput

+ Output *FunctionOutput

+ func (s *ScalarFunctionConfiguration) UnmarshalJSON(data []byte) error

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

type ScalarFunctionProperties

+ Etag *string

+ Properties *ScalarFunctionConfiguration

+ Type *string

+ func (s *ScalarFunctionProperties) GetFunctionProperties() *FunctionProperties

+ func (s *ScalarFunctionProperties) UnmarshalJSON(data []byte) error

+ type ScaleStreamingJobParameters struct

+ StreamingUnits *int32

type ServiceBusQueueOutputDataSource

+ Type *string

+ func (s *ServiceBusQueueOutputDataSource) GetOutputDataSource() *OutputDataSource

type ServiceBusQueueOutputDataSourceProperties

+ AuthenticationMode *AuthenticationMode

+ ServiceBusNamespace *string

+ SharedAccessPolicyKey *string

+ SharedAccessPolicyName *string

type ServiceBusTopicOutputDataSource

+ Type *string

+ func (s *ServiceBusTopicOutputDataSource) GetOutputDataSource() *OutputDataSource

type ServiceBusTopicOutputDataSourceProperties

+ AuthenticationMode *AuthenticationMode

+ ServiceBusNamespace *string

+ SharedAccessPolicyKey *string

+ SharedAccessPolicyName *string

type StreamInputProperties

+ Compression *Compression

+ Diagnostics *Diagnostics

+ Etag *string

+ PartitionKey *string

+ Serialization SerializationClassification

+ Type *string

+ func (s *StreamInputProperties) GetInputProperties() *InputProperties

type StreamingJob

+ ID *string

+ Location *string

+ Name *string

+ Tags map[string]*string

+ Type *string

type StreamingJobsClient

+ func (client *StreamingJobsClient) BeginScale(ctx context.Context, resourceGroupName string, jobName string, ...) (StreamingJobsClientScalePollerResponse, error)

+ type StreamingJobsClientBeginCreateOrReplaceOptions struct

+ IfMatch *string

+ IfNoneMatch *string

+ type StreamingJobsClientBeginDeleteOptions struct

+ type StreamingJobsClientBeginScaleOptions struct

+ ScaleJobParameters *ScaleStreamingJobParameters

+ type StreamingJobsClientBeginStartOptions struct

+ StartJobParameters *StartStreamingJobParameters

+ type StreamingJobsClientBeginStopOptions struct

+ type StreamingJobsClientCreateOrReplacePoller struct

+ func (p *StreamingJobsClientCreateOrReplacePoller) Done() bool

+ func (p *StreamingJobsClientCreateOrReplacePoller) FinalResponse(ctx context.Context) (StreamingJobsClientCreateOrReplaceResponse, error)

+ func (p *StreamingJobsClientCreateOrReplacePoller) Poll(ctx context.Context) (*http.Response, error)

+ func (p *StreamingJobsClientCreateOrReplacePoller) ResumeToken() (string, error)

+ type StreamingJobsClientCreateOrReplacePollerResponse struct

+ Poller *StreamingJobsClientCreateOrReplacePoller

+ RawResponse *http.Response

+ func (l *StreamingJobsClientCreateOrReplacePollerResponse) Resume(ctx context.Context, client *StreamingJobsClient, token string) error

+ func (l StreamingJobsClientCreateOrReplacePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (StreamingJobsClientCreateOrReplaceResponse, error)

+ type StreamingJobsClientCreateOrReplaceResponse struct

+ RawResponse *http.Response

+ type StreamingJobsClientCreateOrReplaceResult struct

+ type StreamingJobsClientDeletePoller struct

+ func (p *StreamingJobsClientDeletePoller) Done() bool

+ func (p *StreamingJobsClientDeletePoller) FinalResponse(ctx context.Context) (StreamingJobsClientDeleteResponse, error)

+ func (p *StreamingJobsClientDeletePoller) Poll(ctx context.Context) (*http.Response, error)

+ func (p *StreamingJobsClientDeletePoller) ResumeToken() (string, error)

+ type StreamingJobsClientDeletePollerResponse struct

+ Poller *StreamingJobsClientDeletePoller

+ RawResponse *http.Response

+ func (l *StreamingJobsClientDeletePollerResponse) Resume(ctx context.Context, client *StreamingJobsClient, token string) error

+ func (l StreamingJobsClientDeletePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (StreamingJobsClientDeleteResponse, error)

+ type StreamingJobsClientDeleteResponse struct

+ RawResponse *http.Response

+ type StreamingJobsClientGetOptions struct

+ Expand *string

+ type StreamingJobsClientGetResponse struct

+ RawResponse *http.Response

+ type StreamingJobsClientGetResult struct

+ ETag *string

+ type StreamingJobsClientListByResourceGroupOptions struct

+ Expand *string

+ type StreamingJobsClientListByResourceGroupPager struct

+ func (p *StreamingJobsClientListByResourceGroupPager) Err() error

+ func (p *StreamingJobsClientListByResourceGroupPager) NextPage(ctx context.Context) bool

+ func (p *StreamingJobsClientListByResourceGroupPager) PageResponse() StreamingJobsClientListByResourceGroupResponse

+ type StreamingJobsClientListByResourceGroupResponse struct

+ RawResponse *http.Response

+ type StreamingJobsClientListByResourceGroupResult struct

+ type StreamingJobsClientListOptions struct

+ Expand *string

+ type StreamingJobsClientListPager struct

+ func (p *StreamingJobsClientListPager) Err() error

+ func (p *StreamingJobsClientListPager) NextPage(ctx context.Context) bool

+ func (p *StreamingJobsClientListPager) PageResponse() StreamingJobsClientListResponse

+ type StreamingJobsClientListResponse struct

+ RawResponse *http.Response

+ type StreamingJobsClientListResult struct

+ type StreamingJobsClientScalePoller struct

+ func (p *StreamingJobsClientScalePoller) Done() bool

+ func (p *StreamingJobsClientScalePoller) FinalResponse(ctx context.Context) (StreamingJobsClientScaleResponse, error)

+ func (p *StreamingJobsClientScalePoller) Poll(ctx context.Context) (*http.Response, error)

+ func (p *StreamingJobsClientScalePoller) ResumeToken() (string, error)

+ type StreamingJobsClientScalePollerResponse struct

+ Poller *StreamingJobsClientScalePoller

+ RawResponse *http.Response

+ func (l *StreamingJobsClientScalePollerResponse) Resume(ctx context.Context, client *StreamingJobsClient, token string) error

+ func (l StreamingJobsClientScalePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (StreamingJobsClientScaleResponse, error)

+ type StreamingJobsClientScaleResponse struct

+ RawResponse *http.Response

+ type StreamingJobsClientStartPoller struct

+ func (p *StreamingJobsClientStartPoller) Done() bool

+ func (p *StreamingJobsClientStartPoller) FinalResponse(ctx context.Context) (StreamingJobsClientStartResponse, error)

+ func (p *StreamingJobsClientStartPoller) Poll(ctx context.Context) (*http.Response, error)

+ func (p *StreamingJobsClientStartPoller) ResumeToken() (string, error)

+ type StreamingJobsClientStartPollerResponse struct

+ Poller *StreamingJobsClientStartPoller

+ RawResponse *http.Response

+ func (l *StreamingJobsClientStartPollerResponse) Resume(ctx context.Context, client *StreamingJobsClient, token string) error

+ func (l StreamingJobsClientStartPollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (StreamingJobsClientStartResponse, error)

+ type StreamingJobsClientStartResponse struct

+ RawResponse *http.Response

+ type StreamingJobsClientStopPoller struct

+ func (p *StreamingJobsClientStopPoller) Done() bool

+ func (p *StreamingJobsClientStopPoller) FinalResponse(ctx context.Context) (StreamingJobsClientStopResponse, error)

+ func (p *StreamingJobsClientStopPoller) Poll(ctx context.Context) (*http.Response, error)

+ func (p *StreamingJobsClientStopPoller) ResumeToken() (string, error)

+ type StreamingJobsClientStopPollerResponse struct

+ Poller *StreamingJobsClientStopPoller

+ RawResponse *http.Response

+ func (l *StreamingJobsClientStopPollerResponse) Resume(ctx context.Context, client *StreamingJobsClient, token string) error

+ func (l StreamingJobsClientStopPollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (StreamingJobsClientStopResponse, error)

+ type StreamingJobsClientStopResponse struct

+ RawResponse *http.Response

+ type StreamingJobsClientUpdateOptions struct

+ IfMatch *string

+ type StreamingJobsClientUpdateResponse struct

+ RawResponse *http.Response

+ type StreamingJobsClientUpdateResult struct

+ ETag *string

type SubscriptionQuota

+ ID *string

+ Name *string

+ Type *string

+ type SubscriptionsClientListQuotasOptions struct

+ type SubscriptionsClientListQuotasResponse struct

+ RawResponse *http.Response

+ type SubscriptionsClientListQuotasResult struct

type TrackedResource

+ ID *string

+ Name *string

+ Type *string

type Transformation

+ ID *string

+ Name *string

+ Type *string

type TransformationProperties

+ ValidStreamingUnits []*int32

+ func (t TransformationProperties) MarshalJSON() ([]byte, error)

+ type TransformationsClientCreateOrReplaceOptions struct

+ IfMatch *string

+ IfNoneMatch *string

+ type TransformationsClientCreateOrReplaceResponse struct

+ RawResponse *http.Response

+ type TransformationsClientCreateOrReplaceResult struct

+ ETag *string

+ type TransformationsClientGetOptions struct

+ type TransformationsClientGetResponse struct

+ RawResponse *http.Response

+ type TransformationsClientGetResult struct

+ ETag *string

+ type TransformationsClientUpdateOptions struct

+ IfMatch *string

+ type TransformationsClientUpdateResponse struct

+ RawResponse *http.Response

+ type TransformationsClientUpdateResult struct

+ ETag *string

v0.2.0

Nov 1, 2021

v0.1.0

Oct 26, 2021

Changes in this version

+ type AggregateFunctionProperties struct

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

+ type AuthenticationMode string

+ const AuthenticationModeConnectionString

+ const AuthenticationModeMsi

+ const AuthenticationModeUserToken

+ func PossibleAuthenticationModeValues() []AuthenticationMode

+ func (c AuthenticationMode) ToPtr() *AuthenticationMode

+ type AvroSerialization struct

+ Properties map[string]interface{}

+ func (a *AvroSerialization) UnmarshalJSON(data []byte) error

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

+ type AzureDataLakeStoreOutputDataSource struct

+ Properties *AzureDataLakeStoreOutputDataSourceProperties

+ func (a *AzureDataLakeStoreOutputDataSource) UnmarshalJSON(data []byte) error

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

+ type AzureDataLakeStoreOutputDataSourceProperties struct

+ AccountName *string

+ AuthenticationMode *AuthenticationMode

+ DateFormat *string

+ FilePathPrefix *string

+ TenantID *string

+ TimeFormat *string

+ type AzureFunctionOutputDataSource struct

+ Properties *AzureFunctionOutputDataSourceProperties

+ func (a *AzureFunctionOutputDataSource) UnmarshalJSON(data []byte) error

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

+ type AzureFunctionOutputDataSourceProperties struct

+ APIKey *string

+ FunctionAppName *string

+ FunctionName *string

+ MaxBatchCount *float32

+ MaxBatchSize *float32

+ type AzureMachineLearningServiceFunctionBinding struct

+ Properties *AzureMachineLearningServiceFunctionBindingProperties

+ func (a *AzureMachineLearningServiceFunctionBinding) UnmarshalJSON(data []byte) error

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

+ type AzureMachineLearningServiceFunctionBindingProperties struct

+ APIKey *string

+ BatchSize *int32

+ Endpoint *string

+ Inputs []*AzureMachineLearningServiceInputColumn

+ NumberOfParallelRequests *int32

+ Outputs []*AzureMachineLearningServiceOutputColumn

+ func (a AzureMachineLearningServiceFunctionBindingProperties) MarshalJSON() ([]byte, error)

+ type AzureMachineLearningServiceFunctionBindingRetrievalProperties struct

+ ExecuteEndpoint *string

+ UdfType *string

+ type AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters struct

+ BindingRetrievalProperties *AzureMachineLearningServiceFunctionBindingRetrievalProperties

+ func (a *AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters) UnmarshalJSON(data []byte) error

+ func (a AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters) MarshalJSON() ([]byte, error)

+ type AzureMachineLearningServiceInputColumn struct

+ DataType *string

+ MapTo *int32

+ Name *string

+ type AzureMachineLearningServiceInputs struct

+ ColumnNames []*AzureMachineLearningServiceInputColumn

+ Name *string

+ func (a AzureMachineLearningServiceInputs) MarshalJSON() ([]byte, error)

+ type AzureMachineLearningServiceOutputColumn struct

+ DataType *string

+ MapTo *int32

+ Name *string

+ type AzureMachineLearningStudioFunctionBinding struct

+ Properties *AzureMachineLearningStudioFunctionBindingProperties

+ func (a *AzureMachineLearningStudioFunctionBinding) UnmarshalJSON(data []byte) error

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

+ type AzureMachineLearningStudioFunctionBindingProperties struct

+ APIKey *string

+ BatchSize *int32

+ Endpoint *string

+ Inputs *AzureMachineLearningStudioInputs

+ Outputs []*AzureMachineLearningStudioOutputColumn

+ func (a AzureMachineLearningStudioFunctionBindingProperties) MarshalJSON() ([]byte, error)

+ type AzureMachineLearningStudioFunctionBindingRetrievalProperties struct

+ ExecuteEndpoint *string

+ UdfType *string

+ type AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters struct

+ BindingRetrievalProperties *AzureMachineLearningStudioFunctionBindingRetrievalProperties

+ func (a *AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters) UnmarshalJSON(data []byte) error

+ func (a AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters) MarshalJSON() ([]byte, error)

+ type AzureMachineLearningStudioInputColumn struct

+ DataType *string

+ MapTo *int32

+ Name *string

+ type AzureMachineLearningStudioInputs struct

+ ColumnNames []*AzureMachineLearningStudioInputColumn

+ Name *string

+ func (a AzureMachineLearningStudioInputs) MarshalJSON() ([]byte, error)

+ type AzureMachineLearningStudioOutputColumn struct

+ DataType *string

+ Name *string

+ type AzureSQLDatabaseDataSourceProperties struct

+ AuthenticationMode *AuthenticationMode

+ Database *string

+ MaxBatchCount *float32

+ MaxWriterCount *float32

+ Password *string

+ Server *string

+ Table *string

+ User *string

+ type AzureSQLDatabaseOutputDataSource struct

+ Properties *AzureSQLDatabaseOutputDataSourceProperties

+ func (a *AzureSQLDatabaseOutputDataSource) UnmarshalJSON(data []byte) error

+ func (a AzureSQLDatabaseOutputDataSource) MarshalJSON() ([]byte, error)

+ type AzureSQLDatabaseOutputDataSourceProperties struct

+ type AzureSQLReferenceInputDataSource struct

+ Properties *AzureSQLReferenceInputDataSourceProperties

+ func (a *AzureSQLReferenceInputDataSource) UnmarshalJSON(data []byte) error

+ func (a AzureSQLReferenceInputDataSource) MarshalJSON() ([]byte, error)

+ type AzureSQLReferenceInputDataSourceProperties struct

+ Database *string

+ DeltaSnapshotQuery *string

+ FullSnapshotQuery *string

+ Password *string

+ RefreshRate *string

+ RefreshType *string

+ Server *string

+ Table *string

+ User *string

+ type AzureSynapseDataSourceProperties struct

+ Database *string

+ Password *string

+ Server *string

+ Table *string

+ User *string

+ type AzureSynapseOutputDataSource struct

+ Properties *AzureSynapseOutputDataSourceProperties

+ func (a *AzureSynapseOutputDataSource) UnmarshalJSON(data []byte) error

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

+ type AzureSynapseOutputDataSourceProperties struct

+ type AzureTableOutputDataSource struct

+ Properties *AzureTableOutputDataSourceProperties

+ func (a *AzureTableOutputDataSource) UnmarshalJSON(data []byte) error

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

+ type AzureTableOutputDataSourceProperties struct

+ AccountKey *string

+ AccountName *string

+ BatchSize *int32

+ ColumnsToRemove []*string

+ PartitionKey *string

+ RowKey *string

+ Table *string

+ func (a AzureTableOutputDataSourceProperties) MarshalJSON() ([]byte, error)

+ type BlobDataSourceProperties struct

+ Container *string

+ DateFormat *string

+ PathPattern *string

+ StorageAccounts []*StorageAccount

+ TimeFormat *string

+ func (b BlobDataSourceProperties) MarshalJSON() ([]byte, error)

+ type BlobOutputDataSource struct

+ Properties *BlobOutputDataSourceProperties

+ func (b *BlobOutputDataSource) UnmarshalJSON(data []byte) error

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

+ type BlobOutputDataSourceProperties struct

+ AuthenticationMode *AuthenticationMode

+ func (b BlobOutputDataSourceProperties) MarshalJSON() ([]byte, error)

+ type BlobReferenceInputDataSource struct

+ Properties *BlobReferenceInputDataSourceProperties

+ func (b *BlobReferenceInputDataSource) UnmarshalJSON(data []byte) error

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

+ type BlobReferenceInputDataSourceProperties struct

+ type BlobStreamInputDataSource struct

+ Properties *BlobStreamInputDataSourceProperties

+ func (b *BlobStreamInputDataSource) UnmarshalJSON(data []byte) error

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

+ type BlobStreamInputDataSourceProperties struct

+ SourcePartitionCount *int32

+ func (b BlobStreamInputDataSourceProperties) MarshalJSON() ([]byte, error)

+ type CSVSerialization struct

+ Properties *CSVSerializationProperties

+ func (c *CSVSerialization) UnmarshalJSON(data []byte) error

+ func (c CSVSerialization) MarshalJSON() ([]byte, error)

+ type CSVSerializationProperties struct

+ Encoding *Encoding

+ FieldDelimiter *string

+ type CSharpFunctionBinding struct

+ Properties *CSharpFunctionBindingProperties

+ func (c *CSharpFunctionBinding) UnmarshalJSON(data []byte) error

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

+ type CSharpFunctionBindingProperties struct

+ Class *string

+ DllPath *string

+ Method *string

+ Script *string

+ type CSharpFunctionBindingRetrievalProperties struct

+ Script *string

+ UdfType *string

+ type CSharpFunctionRetrieveDefaultDefinitionParameters struct

+ BindingRetrievalProperties *CSharpFunctionBindingRetrievalProperties

+ func (c *CSharpFunctionRetrieveDefaultDefinitionParameters) UnmarshalJSON(data []byte) error

+ func (c CSharpFunctionRetrieveDefaultDefinitionParameters) MarshalJSON() ([]byte, error)

+ type Cluster struct

+ Etag *string

+ Properties *ClusterProperties

+ SKU *ClusterSKU

+ func (c Cluster) MarshalJSON() ([]byte, error)

+ type ClusterInfo struct

+ ID *string

+ type ClusterJob struct

+ ID *string

+ JobState *JobState

+ StreamingUnits *int32

+ type ClusterJobListResult struct

+ NextLink *string

+ Value []*ClusterJob

+ func (c ClusterJobListResult) MarshalJSON() ([]byte, error)

+ type ClusterListResult struct

+ NextLink *string

+ Value []*Cluster

+ func (c ClusterListResult) MarshalJSON() ([]byte, error)

+ type ClusterProperties struct

+ CapacityAllocated *int32

+ CapacityAssigned *int32

+ ClusterID *string

+ CreatedDate *time.Time

+ ProvisioningState *ClusterProvisioningState

+ func (c *ClusterProperties) UnmarshalJSON(data []byte) error

+ func (c ClusterProperties) MarshalJSON() ([]byte, error)

+ type ClusterProvisioningState string

+ const ClusterProvisioningStateCanceled

+ const ClusterProvisioningStateFailed

+ const ClusterProvisioningStateInProgress

+ const ClusterProvisioningStateSucceeded

+ func PossibleClusterProvisioningStateValues() []ClusterProvisioningState

+ func (c ClusterProvisioningState) ToPtr() *ClusterProvisioningState

+ type ClusterSKU struct

+ Capacity *int32

+ Name *ClusterSKUName

+ type ClusterSKUName string

+ const ClusterSKUNameDefault

+ func PossibleClusterSKUNameValues() []ClusterSKUName

+ func (c ClusterSKUName) ToPtr() *ClusterSKUName

+ type ClustersBeginCreateOrUpdateOptions struct

+ IfMatch *string

+ IfNoneMatch *string

+ type ClustersBeginDeleteOptions struct

+ type ClustersBeginUpdateOptions struct

+ IfMatch *string

+ type ClustersClient struct

+ func NewClustersClient(con *arm.Connection, subscriptionID string) *ClustersClient

+ func (client *ClustersClient) BeginCreateOrUpdate(ctx context.Context, resourceGroupName string, clusterName string, ...) (ClustersCreateOrUpdatePollerResponse, error)

+ func (client *ClustersClient) BeginDelete(ctx context.Context, resourceGroupName string, clusterName string, ...) (ClustersDeletePollerResponse, error)

+ func (client *ClustersClient) BeginUpdate(ctx context.Context, resourceGroupName string, clusterName string, ...) (ClustersUpdatePollerResponse, error)

+ func (client *ClustersClient) Get(ctx context.Context, resourceGroupName string, clusterName string, ...) (ClustersGetResponse, error)

+ func (client *ClustersClient) ListByResourceGroup(resourceGroupName string, options *ClustersListByResourceGroupOptions) *ClustersListByResourceGroupPager

+ func (client *ClustersClient) ListBySubscription(options *ClustersListBySubscriptionOptions) *ClustersListBySubscriptionPager

+ func (client *ClustersClient) ListStreamingJobs(resourceGroupName string, clusterName string, ...) *ClustersListStreamingJobsPager

+ type ClustersCreateOrUpdatePoller struct

+ func (p *ClustersCreateOrUpdatePoller) Done() bool

+ func (p *ClustersCreateOrUpdatePoller) FinalResponse(ctx context.Context) (ClustersCreateOrUpdateResponse, error)

+ func (p *ClustersCreateOrUpdatePoller) Poll(ctx context.Context) (*http.Response, error)

+ func (p *ClustersCreateOrUpdatePoller) ResumeToken() (string, error)

+ type ClustersCreateOrUpdatePollerResponse struct

+ Poller *ClustersCreateOrUpdatePoller

+ RawResponse *http.Response

+ func (l *ClustersCreateOrUpdatePollerResponse) Resume(ctx context.Context, client *ClustersClient, token string) error

+ func (l ClustersCreateOrUpdatePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (ClustersCreateOrUpdateResponse, error)

+ type ClustersCreateOrUpdateResponse struct

+ RawResponse *http.Response

+ type ClustersCreateOrUpdateResult struct

+ type ClustersDeletePoller struct

+ func (p *ClustersDeletePoller) Done() bool

+ func (p *ClustersDeletePoller) FinalResponse(ctx context.Context) (ClustersDeleteResponse, error)

+ func (p *ClustersDeletePoller) Poll(ctx context.Context) (*http.Response, error)

+ func (p *ClustersDeletePoller) ResumeToken() (string, error)

+ type ClustersDeletePollerResponse struct

+ Poller *ClustersDeletePoller

+ RawResponse *http.Response

+ func (l *ClustersDeletePollerResponse) Resume(ctx context.Context, client *ClustersClient, token string) error

+ func (l ClustersDeletePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (ClustersDeleteResponse, error)

+ type ClustersDeleteResponse struct

+ RawResponse *http.Response

+ type ClustersGetOptions struct

+ type ClustersGetResponse struct

+ RawResponse *http.Response

+ type ClustersGetResult struct

+ type ClustersListByResourceGroupOptions struct

+ type ClustersListByResourceGroupPager struct

+ func (p *ClustersListByResourceGroupPager) Err() error

+ func (p *ClustersListByResourceGroupPager) NextPage(ctx context.Context) bool

+ func (p *ClustersListByResourceGroupPager) PageResponse() ClustersListByResourceGroupResponse

+ type ClustersListByResourceGroupResponse struct

+ RawResponse *http.Response

+ type ClustersListByResourceGroupResult struct

+ type ClustersListBySubscriptionOptions struct

+ type ClustersListBySubscriptionPager struct

+ func (p *ClustersListBySubscriptionPager) Err() error

+ func (p *ClustersListBySubscriptionPager) NextPage(ctx context.Context) bool

+ func (p *ClustersListBySubscriptionPager) PageResponse() ClustersListBySubscriptionResponse

+ type ClustersListBySubscriptionResponse struct

+ RawResponse *http.Response

+ type ClustersListBySubscriptionResult struct

+ type ClustersListStreamingJobsOptions struct

+ type ClustersListStreamingJobsPager struct

+ func (p *ClustersListStreamingJobsPager) Err() error

+ func (p *ClustersListStreamingJobsPager) NextPage(ctx context.Context) bool

+ func (p *ClustersListStreamingJobsPager) PageResponse() ClustersListStreamingJobsResponse

+ type ClustersListStreamingJobsResponse struct

+ RawResponse *http.Response

+ type ClustersListStreamingJobsResult struct

+ type ClustersUpdatePoller struct

+ func (p *ClustersUpdatePoller) Done() bool

+ func (p *ClustersUpdatePoller) FinalResponse(ctx context.Context) (ClustersUpdateResponse, error)

+ func (p *ClustersUpdatePoller) Poll(ctx context.Context) (*http.Response, error)

+ func (p *ClustersUpdatePoller) ResumeToken() (string, error)

+ type ClustersUpdatePollerResponse struct

+ Poller *ClustersUpdatePoller

+ RawResponse *http.Response

+ func (l *ClustersUpdatePollerResponse) Resume(ctx context.Context, client *ClustersClient, token string) error

+ func (l ClustersUpdatePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (ClustersUpdateResponse, error)

+ type ClustersUpdateResponse struct

+ RawResponse *http.Response

+ type ClustersUpdateResult struct

+ type CompatibilityLevel string

+ const CompatibilityLevelOne0

+ func PossibleCompatibilityLevelValues() []CompatibilityLevel

+ func (c CompatibilityLevel) ToPtr() *CompatibilityLevel

+ type CompileQuery struct

+ CompatibilityLevel *CompatibilityLevel

+ Functions []*QueryFunction

+ Inputs []*QueryInput

+ JobType *JobType

+ Query *string

+ func (c CompileQuery) MarshalJSON() ([]byte, error)

+ type Compression struct

+ Type *string

+ type ContentStoragePolicy string

+ const ContentStoragePolicyJobStorageAccount

+ const ContentStoragePolicySystemAccount

+ func PossibleContentStoragePolicyValues() []ContentStoragePolicy

+ func (c ContentStoragePolicy) ToPtr() *ContentStoragePolicy

+ type CustomClrSerialization struct

+ Properties *CustomClrSerializationProperties

+ func (c *CustomClrSerialization) UnmarshalJSON(data []byte) error

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

+ type CustomClrSerializationProperties struct

+ SerializationClassName *string

+ SerializationDllPath *string

+ type DiagnosticCondition struct

+ Code *string

+ Message *string

+ Since *string

+ type Diagnostics struct

+ Conditions []*DiagnosticCondition

+ func (d Diagnostics) MarshalJSON() ([]byte, error)

+ type DocumentDbOutputDataSource struct

+ Properties *DocumentDbOutputDataSourceProperties

+ func (d *DocumentDbOutputDataSource) UnmarshalJSON(data []byte) error

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

+ type DocumentDbOutputDataSourceProperties struct

+ AccountID *string

+ AccountKey *string

+ CollectionNamePattern *string

+ Database *string

+ DocumentID *string

+ PartitionKey *string

+ type Encoding string

+ const EncodingUTF8

+ func PossibleEncodingValues() []Encoding

+ func (c Encoding) ToPtr() *Encoding

+ type Error struct

+ InnerError *ErrorError

+ func (e Error) Error() string

+ type ErrorDetails struct

+ Code *string

+ Message *string

+ Target *string

+ type ErrorError struct

+ Code *string

+ Details []*ErrorDetails

+ Message *string

+ Target *string

+ func (e ErrorError) MarshalJSON() ([]byte, error)

+ type ErrorResponse struct

+ Code *string

+ Message *string

+ type EventHubDataSourceProperties struct

+ EventHubName *string

+ func (e EventHubDataSourceProperties) MarshalJSON() ([]byte, error)

+ type EventHubOutputDataSource struct

+ Properties *EventHubOutputDataSourceProperties

+ func (e *EventHubOutputDataSource) UnmarshalJSON(data []byte) error

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

+ type EventHubOutputDataSourceProperties struct

+ PartitionKey *string

+ PropertyColumns []*string

+ func (e EventHubOutputDataSourceProperties) MarshalJSON() ([]byte, error)

+ type EventHubStreamInputDataSource struct

+ Properties *EventHubStreamInputDataSourceProperties

+ func (e *EventHubStreamInputDataSource) UnmarshalJSON(data []byte) error

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

+ type EventHubStreamInputDataSourceProperties struct

+ ConsumerGroupName *string

+ func (e EventHubStreamInputDataSourceProperties) MarshalJSON() ([]byte, error)

+ type EventHubV2OutputDataSource struct

+ Properties *EventHubOutputDataSourceProperties

+ func (e *EventHubV2OutputDataSource) UnmarshalJSON(data []byte) error

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

+ type EventHubV2StreamInputDataSource struct

+ Properties *EventHubStreamInputDataSourceProperties

+ func (e *EventHubV2StreamInputDataSource) UnmarshalJSON(data []byte) error

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

+ type EventSerializationType string

+ const EventSerializationTypeAvro

+ const EventSerializationTypeCSV

+ const EventSerializationTypeCustomClr

+ const EventSerializationTypeJSON

+ const EventSerializationTypeParquet

+ func PossibleEventSerializationTypeValues() []EventSerializationType

+ func (c EventSerializationType) ToPtr() *EventSerializationType

+ type EventsOutOfOrderPolicy string

+ const EventsOutOfOrderPolicyAdjust

+ const EventsOutOfOrderPolicyDrop

+ func PossibleEventsOutOfOrderPolicyValues() []EventsOutOfOrderPolicy

+ func (c EventsOutOfOrderPolicy) ToPtr() *EventsOutOfOrderPolicy

+ type External struct

+ Container *string

+ Path *string

+ StorageAccount *StorageAccount

+ type Function struct

+ Properties FunctionPropertiesClassification

+ func (f *Function) UnmarshalJSON(data []byte) error

+ func (f Function) MarshalJSON() ([]byte, error)

+ type FunctionBinding struct

+ Type *string

+ func (f *FunctionBinding) GetFunctionBinding() *FunctionBinding

+ func (f *FunctionBinding) UnmarshalJSON(data []byte) error

+ type FunctionBindingClassification interface

+ GetFunctionBinding func() *FunctionBinding

+ type FunctionConfiguration struct

+ Binding FunctionBindingClassification

+ Inputs []*FunctionInput

+ Output *FunctionOutput

+ func (f *FunctionConfiguration) UnmarshalJSON(data []byte) error

+ func (f FunctionConfiguration) MarshalJSON() ([]byte, error)

+ type FunctionInput struct

+ DataType *string

+ IsConfigurationParameter *bool

+ type FunctionListResult struct

+ NextLink *string

+ Value []*Function

+ func (f FunctionListResult) MarshalJSON() ([]byte, error)

+ type FunctionOutput struct

+ DataType *string

+ type FunctionProperties struct

+ Etag *string

+ Properties *FunctionConfiguration

+ Type *string

+ func (f *FunctionProperties) GetFunctionProperties() *FunctionProperties

+ func (f *FunctionProperties) UnmarshalJSON(data []byte) error

+ type FunctionPropertiesClassification interface

+ GetFunctionProperties func() *FunctionProperties

+ type FunctionRetrieveDefaultDefinitionParameters struct

+ BindingType *string

+ func (f *FunctionRetrieveDefaultDefinitionParameters) GetFunctionRetrieveDefaultDefinitionParameters() *FunctionRetrieveDefaultDefinitionParameters

+ func (f *FunctionRetrieveDefaultDefinitionParameters) UnmarshalJSON(data []byte) error

+ type FunctionRetrieveDefaultDefinitionParametersClassification interface

+ GetFunctionRetrieveDefaultDefinitionParameters func() *FunctionRetrieveDefaultDefinitionParameters

+ type FunctionsBeginTestOptions struct

+ Function *Function

+ type FunctionsClient struct

+ func NewFunctionsClient(con *arm.Connection, subscriptionID string) *FunctionsClient

+ func (client *FunctionsClient) BeginTest(ctx context.Context, resourceGroupName string, jobName string, ...) (FunctionsTestPollerResponse, error)

+ func (client *FunctionsClient) CreateOrReplace(ctx context.Context, resourceGroupName string, jobName string, ...) (FunctionsCreateOrReplaceResponse, error)

+ func (client *FunctionsClient) Delete(ctx context.Context, resourceGroupName string, jobName string, ...) (FunctionsDeleteResponse, error)

+ func (client *FunctionsClient) Get(ctx context.Context, resourceGroupName string, jobName string, ...) (FunctionsGetResponse, error)

+ func (client *FunctionsClient) ListByStreamingJob(resourceGroupName string, jobName string, ...) *FunctionsListByStreamingJobPager

+ func (client *FunctionsClient) RetrieveDefaultDefinition(ctx context.Context, resourceGroupName string, jobName string, ...) (FunctionsRetrieveDefaultDefinitionResponse, error)

+ func (client *FunctionsClient) Update(ctx context.Context, resourceGroupName string, jobName string, ...) (FunctionsUpdateResponse, error)

+ type FunctionsCreateOrReplaceOptions struct

+ IfMatch *string

+ IfNoneMatch *string

+ type FunctionsCreateOrReplaceResponse struct

+ RawResponse *http.Response

+ type FunctionsCreateOrReplaceResult struct

+ ETag *string

+ type FunctionsDeleteOptions struct

+ type FunctionsDeleteResponse struct

+ RawResponse *http.Response

+ type FunctionsGetOptions struct

+ type FunctionsGetResponse struct

+ RawResponse *http.Response

+ type FunctionsGetResult struct

+ ETag *string

+ type FunctionsListByStreamingJobOptions struct

+ Select *string

+ type FunctionsListByStreamingJobPager struct

+ func (p *FunctionsListByStreamingJobPager) Err() error

+ func (p *FunctionsListByStreamingJobPager) NextPage(ctx context.Context) bool

+ func (p *FunctionsListByStreamingJobPager) PageResponse() FunctionsListByStreamingJobResponse

+ type FunctionsListByStreamingJobResponse struct

+ RawResponse *http.Response

+ type FunctionsListByStreamingJobResult struct

+ type FunctionsRetrieveDefaultDefinitionOptions struct

+ FunctionRetrieveDefaultDefinitionParameters FunctionRetrieveDefaultDefinitionParametersClassification

+ type FunctionsRetrieveDefaultDefinitionResponse struct

+ RawResponse *http.Response

+ type FunctionsRetrieveDefaultDefinitionResult struct

+ type FunctionsTestPoller struct

+ func (p *FunctionsTestPoller) Done() bool

+ func (p *FunctionsTestPoller) FinalResponse(ctx context.Context) (FunctionsTestResponse, error)

+ func (p *FunctionsTestPoller) Poll(ctx context.Context) (*http.Response, error)

+ func (p *FunctionsTestPoller) ResumeToken() (string, error)

+ type FunctionsTestPollerResponse struct

+ Poller *FunctionsTestPoller

+ RawResponse *http.Response

+ func (l *FunctionsTestPollerResponse) Resume(ctx context.Context, client *FunctionsClient, token string) error

+ func (l FunctionsTestPollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (FunctionsTestResponse, error)

+ type FunctionsTestResponse struct

+ RawResponse *http.Response

+ type FunctionsTestResult struct

+ type FunctionsUpdateOptions struct

+ IfMatch *string

+ type FunctionsUpdateResponse struct

+ RawResponse *http.Response

+ type FunctionsUpdateResult struct

+ ETag *string

+ type Identity struct

+ PrincipalID *string

+ TenantID *string

+ Type *string

+ type Input struct

+ Properties InputPropertiesClassification

+ func (i *Input) UnmarshalJSON(data []byte) error

+ func (i Input) MarshalJSON() ([]byte, error)

+ type InputListResult struct

+ NextLink *string

+ Value []*Input

+ func (i InputListResult) MarshalJSON() ([]byte, error)

+ type InputProperties struct

+ Compression *Compression

+ Diagnostics *Diagnostics

+ Etag *string

+ PartitionKey *string

+ Serialization SerializationClassification

+ Type *string

+ func (i *InputProperties) GetInputProperties() *InputProperties

+ func (i *InputProperties) UnmarshalJSON(data []byte) error

+ type InputPropertiesClassification interface

+ GetInputProperties func() *InputProperties

+ type InputsBeginTestOptions struct

+ Input *Input

+ type InputsClient struct

+ func NewInputsClient(con *arm.Connection, subscriptionID string) *InputsClient

+ func (client *InputsClient) BeginTest(ctx context.Context, resourceGroupName string, jobName string, ...) (InputsTestPollerResponse, error)

+ func (client *InputsClient) CreateOrReplace(ctx context.Context, resourceGroupName string, jobName string, ...) (InputsCreateOrReplaceResponse, error)

+ func (client *InputsClient) Delete(ctx context.Context, resourceGroupName string, jobName string, ...) (InputsDeleteResponse, error)

+ func (client *InputsClient) Get(ctx context.Context, resourceGroupName string, jobName string, ...) (InputsGetResponse, error)

+ func (client *InputsClient) ListByStreamingJob(resourceGroupName string, jobName string, ...) *InputsListByStreamingJobPager

+ func (client *InputsClient) Update(ctx context.Context, resourceGroupName string, jobName string, ...) (InputsUpdateResponse, error)

+ type InputsCreateOrReplaceOptions struct

+ IfMatch *string

+ IfNoneMatch *string

+ type InputsCreateOrReplaceResponse struct

+ RawResponse *http.Response

+ type InputsCreateOrReplaceResult struct

+ ETag *string

+ type InputsDeleteOptions struct

+ type InputsDeleteResponse struct

+ RawResponse *http.Response

+ type InputsGetOptions struct

+ type InputsGetResponse struct

+ RawResponse *http.Response

+ type InputsGetResult struct

+ ETag *string

+ type InputsListByStreamingJobOptions struct

+ Select *string

+ type InputsListByStreamingJobPager struct

+ func (p *InputsListByStreamingJobPager) Err() error

+ func (p *InputsListByStreamingJobPager) NextPage(ctx context.Context) bool

+ func (p *InputsListByStreamingJobPager) PageResponse() InputsListByStreamingJobResponse

+ type InputsListByStreamingJobResponse struct

+ RawResponse *http.Response

+ type InputsListByStreamingJobResult struct

+ type InputsTestPoller struct

+ func (p *InputsTestPoller) Done() bool

+ func (p *InputsTestPoller) FinalResponse(ctx context.Context) (InputsTestResponse, error)

+ func (p *InputsTestPoller) Poll(ctx context.Context) (*http.Response, error)

+ func (p *InputsTestPoller) ResumeToken() (string, error)

+ type InputsTestPollerResponse struct

+ Poller *InputsTestPoller

+ RawResponse *http.Response

+ func (l *InputsTestPollerResponse) Resume(ctx context.Context, client *InputsClient, token string) error

+ func (l InputsTestPollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (InputsTestResponse, error)

+ type InputsTestResponse struct

+ RawResponse *http.Response

+ type InputsTestResult struct

+ type InputsUpdateOptions struct

+ IfMatch *string

+ type InputsUpdateResponse struct

+ RawResponse *http.Response

+ type InputsUpdateResult struct

+ ETag *string

+ type IoTHubStreamInputDataSource struct

+ Properties *IoTHubStreamInputDataSourceProperties

+ func (i *IoTHubStreamInputDataSource) UnmarshalJSON(data []byte) error

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

+ type IoTHubStreamInputDataSourceProperties struct

+ ConsumerGroupName *string

+ Endpoint *string

+ IotHubNamespace *string

+ SharedAccessPolicyKey *string

+ SharedAccessPolicyName *string

+ type JSONOutputSerializationFormat string

+ const JSONOutputSerializationFormatArray

+ const JSONOutputSerializationFormatLineSeparated

+ func PossibleJSONOutputSerializationFormatValues() []JSONOutputSerializationFormat

+ func (c JSONOutputSerializationFormat) ToPtr() *JSONOutputSerializationFormat

+ type JSONSerialization struct

+ Properties *JSONSerializationProperties

+ func (j *JSONSerialization) UnmarshalJSON(data []byte) error

+ func (j JSONSerialization) MarshalJSON() ([]byte, error)

+ type JSONSerializationProperties struct

+ Encoding *Encoding

+ Format *JSONOutputSerializationFormat

+ type JavaScriptFunctionBinding struct

+ Properties *JavaScriptFunctionBindingProperties

+ func (j *JavaScriptFunctionBinding) UnmarshalJSON(data []byte) error

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

+ type JavaScriptFunctionBindingProperties struct

+ Script *string

+ type JavaScriptFunctionBindingRetrievalProperties struct

+ Script *string

+ UdfType *string

+ type JavaScriptFunctionRetrieveDefaultDefinitionParameters struct

+ BindingRetrievalProperties *JavaScriptFunctionBindingRetrievalProperties

+ func (j *JavaScriptFunctionRetrieveDefaultDefinitionParameters) UnmarshalJSON(data []byte) error

+ func (j JavaScriptFunctionRetrieveDefaultDefinitionParameters) MarshalJSON() ([]byte, error)

+ type JobState string

+ const JobStateCreated

+ const JobStateDegraded

+ const JobStateDeleting

+ const JobStateFailed

+ const JobStateRestarting

+ const JobStateRunning

+ const JobStateScaling

+ const JobStateStarting

+ const JobStateStopped

+ const JobStateStopping

+ func PossibleJobStateValues() []JobState

+ func (c JobState) ToPtr() *JobState

+ type JobStorageAccount struct

+ AuthenticationMode *AuthenticationMode

+ type JobType string

+ const JobTypeCloud

+ const JobTypeEdge

+ func PossibleJobTypeValues() []JobType

+ func (c JobType) ToPtr() *JobType

+ type OAuthBasedDataSourceProperties struct

+ RefreshToken *string

+ TokenUserDisplayName *string

+ TokenUserPrincipalName *string

+ type Operation struct

+ Display *OperationDisplay

+ Name *string

+ type OperationDisplay struct

+ Description *string

+ Operation *string

+ Provider *string

+ Resource *string

+ type OperationListResult struct

+ NextLink *string

+ Value []*Operation

+ func (o OperationListResult) MarshalJSON() ([]byte, error)

+ type OperationsClient struct

+ func NewOperationsClient(con *arm.Connection) *OperationsClient

+ func (client *OperationsClient) List(options *OperationsListOptions) *OperationsListPager

+ type OperationsListOptions struct

+ type OperationsListPager struct

+ func (p *OperationsListPager) Err() error

+ func (p *OperationsListPager) NextPage(ctx context.Context) bool

+ func (p *OperationsListPager) PageResponse() OperationsListResponse

+ type OperationsListResponse struct

+ RawResponse *http.Response

+ type OperationsListResult struct

+ type Output struct

+ Properties *OutputProperties

+ func (o *Output) UnmarshalJSON(data []byte) error

+ func (o Output) MarshalJSON() ([]byte, error)

+ type OutputDataSource struct

+ Type *string

+ func (o *OutputDataSource) GetOutputDataSource() *OutputDataSource

+ func (o *OutputDataSource) UnmarshalJSON(data []byte) error

+ type OutputDataSourceClassification interface

+ GetOutputDataSource func() *OutputDataSource

+ type OutputErrorPolicy string

+ const OutputErrorPolicyDrop

+ const OutputErrorPolicyStop

+ func PossibleOutputErrorPolicyValues() []OutputErrorPolicy

+ func (c OutputErrorPolicy) ToPtr() *OutputErrorPolicy

+ type OutputListResult struct

+ NextLink *string

+ Value []*Output

+ func (o OutputListResult) MarshalJSON() ([]byte, error)

+ type OutputProperties struct

+ Datasource OutputDataSourceClassification

+ Diagnostics *Diagnostics

+ Etag *string

+ Serialization SerializationClassification

+ SizeWindow *float32

+ TimeWindow *string

+ func (o *OutputProperties) UnmarshalJSON(data []byte) error

+ func (o OutputProperties) MarshalJSON() ([]byte, error)

+ type OutputStartMode string

+ const OutputStartModeCustomTime

+ const OutputStartModeJobStartTime

+ const OutputStartModeLastOutputEventTime

+ func PossibleOutputStartModeValues() []OutputStartMode

+ func (c OutputStartMode) ToPtr() *OutputStartMode

+ type OutputsBeginTestOptions struct

+ Output *Output

+ type OutputsClient struct

+ func NewOutputsClient(con *arm.Connection, subscriptionID string) *OutputsClient

+ func (client *OutputsClient) BeginTest(ctx context.Context, resourceGroupName string, jobName string, ...) (OutputsTestPollerResponse, error)

+ func (client *OutputsClient) CreateOrReplace(ctx context.Context, resourceGroupName string, jobName string, ...) (OutputsCreateOrReplaceResponse, error)

+ func (client *OutputsClient) Delete(ctx context.Context, resourceGroupName string, jobName string, ...) (OutputsDeleteResponse, error)

+ func (client *OutputsClient) Get(ctx context.Context, resourceGroupName string, jobName string, ...) (OutputsGetResponse, error)

+ func (client *OutputsClient) ListByStreamingJob(resourceGroupName string, jobName string, ...) *OutputsListByStreamingJobPager

+ func (client *OutputsClient) Update(ctx context.Context, resourceGroupName string, jobName string, ...) (OutputsUpdateResponse, error)

+ type OutputsCreateOrReplaceOptions struct

+ IfMatch *string

+ IfNoneMatch *string

+ type OutputsCreateOrReplaceResponse struct

+ RawResponse *http.Response

+ type OutputsCreateOrReplaceResult struct

+ ETag *string

+ type OutputsDeleteOptions struct

+ type OutputsDeleteResponse struct

+ RawResponse *http.Response

+ type OutputsGetOptions struct

+ type OutputsGetResponse struct

+ RawResponse *http.Response

+ type OutputsGetResult struct

+ ETag *string

+ type OutputsListByStreamingJobOptions struct

+ Select *string

+ type OutputsListByStreamingJobPager struct

+ func (p *OutputsListByStreamingJobPager) Err() error

+ func (p *OutputsListByStreamingJobPager) NextPage(ctx context.Context) bool

+ func (p *OutputsListByStreamingJobPager) PageResponse() OutputsListByStreamingJobResponse

+ type OutputsListByStreamingJobResponse struct

+ RawResponse *http.Response

+ type OutputsListByStreamingJobResult struct

+ type OutputsTestPoller struct

+ func (p *OutputsTestPoller) Done() bool

+ func (p *OutputsTestPoller) FinalResponse(ctx context.Context) (OutputsTestResponse, error)

+ func (p *OutputsTestPoller) Poll(ctx context.Context) (*http.Response, error)

+ func (p *OutputsTestPoller) ResumeToken() (string, error)

+ type OutputsTestPollerResponse struct

+ Poller *OutputsTestPoller

+ RawResponse *http.Response

+ func (l *OutputsTestPollerResponse) Resume(ctx context.Context, client *OutputsClient, token string) error

+ func (l OutputsTestPollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (OutputsTestResponse, error)

+ type OutputsTestResponse struct

+ RawResponse *http.Response

+ type OutputsTestResult struct

+ type OutputsUpdateOptions struct

+ IfMatch *string

+ type OutputsUpdateResponse struct

+ RawResponse *http.Response

+ type OutputsUpdateResult struct

+ ETag *string

+ type ParquetSerialization struct

+ Properties map[string]interface{}

+ func (p *ParquetSerialization) UnmarshalJSON(data []byte) error

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

+ type PowerBIOutputDataSource struct

+ Properties *PowerBIOutputDataSourceProperties

+ func (p *PowerBIOutputDataSource) UnmarshalJSON(data []byte) error

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

+ type PowerBIOutputDataSourceProperties struct

+ AuthenticationMode *AuthenticationMode

+ Dataset *string

+ GroupID *string

+ GroupName *string

+ Table *string

+ type PrivateEndpoint struct

+ Etag *string

+ Properties *PrivateEndpointProperties

+ func (p PrivateEndpoint) MarshalJSON() ([]byte, error)

+ type PrivateEndpointListResult struct

+ NextLink *string

+ Value []*PrivateEndpoint

+ func (p PrivateEndpointListResult) MarshalJSON() ([]byte, error)

+ type PrivateEndpointProperties struct

+ CreatedDate *string

+ ManualPrivateLinkServiceConnections []*PrivateLinkServiceConnection

+ func (p PrivateEndpointProperties) MarshalJSON() ([]byte, error)

+ type PrivateEndpointsBeginDeleteOptions struct

+ type PrivateEndpointsClient struct

+ func NewPrivateEndpointsClient(con *arm.Connection, subscriptionID string) *PrivateEndpointsClient

+ func (client *PrivateEndpointsClient) BeginDelete(ctx context.Context, resourceGroupName string, clusterName string, ...) (PrivateEndpointsDeletePollerResponse, error)

+ func (client *PrivateEndpointsClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, clusterName string, ...) (PrivateEndpointsCreateOrUpdateResponse, error)

+ func (client *PrivateEndpointsClient) Get(ctx context.Context, resourceGroupName string, clusterName string, ...) (PrivateEndpointsGetResponse, error)

+ func (client *PrivateEndpointsClient) ListByCluster(resourceGroupName string, clusterName string, ...) *PrivateEndpointsListByClusterPager

+ type PrivateEndpointsCreateOrUpdateOptions struct

+ IfMatch *string

+ IfNoneMatch *string

+ type PrivateEndpointsCreateOrUpdateResponse struct

+ RawResponse *http.Response

+ type PrivateEndpointsCreateOrUpdateResult struct

+ type PrivateEndpointsDeletePoller struct

+ func (p *PrivateEndpointsDeletePoller) Done() bool

+ func (p *PrivateEndpointsDeletePoller) FinalResponse(ctx context.Context) (PrivateEndpointsDeleteResponse, error)

+ func (p *PrivateEndpointsDeletePoller) Poll(ctx context.Context) (*http.Response, error)

+ func (p *PrivateEndpointsDeletePoller) ResumeToken() (string, error)

+ type PrivateEndpointsDeletePollerResponse struct

+ Poller *PrivateEndpointsDeletePoller

+ RawResponse *http.Response

+ func (l *PrivateEndpointsDeletePollerResponse) Resume(ctx context.Context, client *PrivateEndpointsClient, token string) error

+ func (l PrivateEndpointsDeletePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (PrivateEndpointsDeleteResponse, error)

+ type PrivateEndpointsDeleteResponse struct

+ RawResponse *http.Response

+ type PrivateEndpointsGetOptions struct

+ type PrivateEndpointsGetResponse struct

+ RawResponse *http.Response

+ type PrivateEndpointsGetResult struct

+ type PrivateEndpointsListByClusterOptions struct

+ type PrivateEndpointsListByClusterPager struct

+ func (p *PrivateEndpointsListByClusterPager) Err() error

+ func (p *PrivateEndpointsListByClusterPager) NextPage(ctx context.Context) bool

+ func (p *PrivateEndpointsListByClusterPager) PageResponse() PrivateEndpointsListByClusterResponse

+ type PrivateEndpointsListByClusterResponse struct

+ RawResponse *http.Response

+ type PrivateEndpointsListByClusterResult struct

+ type PrivateLinkConnectionState struct

+ ActionsRequired *string

+ Description *string

+ Status *string

+ type PrivateLinkServiceConnection struct

+ Properties *PrivateLinkServiceConnectionProperties

+ type PrivateLinkServiceConnectionProperties struct

+ GroupIDs []*string

+ PrivateLinkServiceConnectionState *PrivateLinkConnectionState

+ PrivateLinkServiceID *string

+ RequestMessage *string

+ func (p PrivateLinkServiceConnectionProperties) MarshalJSON() ([]byte, error)

+ type ProxyResource struct

+ type QueryCompilationError struct

+ EndColumn *int32

+ EndLine *int32

+ IsGlobal *bool

+ Message *string

+ StartColumn *int32

+ StartLine *int32

+ type QueryCompilationResult struct

+ Errors []*QueryCompilationError

+ Functions []*string

+ Inputs []*string

+ Outputs []*string

+ Warnings []*string

+ func (q QueryCompilationResult) MarshalJSON() ([]byte, error)

+ type QueryFunction struct

+ BindingType *string

+ Inputs []*FunctionInput

+ Name *string

+ Output *FunctionOutput

+ Type *string

+ func (q QueryFunction) MarshalJSON() ([]byte, error)

+ type QueryInput struct

+ Name *string

+ Type *string

+ type QueryTestingResult struct

+ OutputURI *string

+ Status *QueryTestingResultStatus

+ type QueryTestingResultStatus string

+ const QueryTestingResultStatusCompilerError

+ const QueryTestingResultStatusRuntimeError

+ const QueryTestingResultStatusStarted

+ const QueryTestingResultStatusSuccess

+ const QueryTestingResultStatusTimeout

+ const QueryTestingResultStatusUnknownError

+ func PossibleQueryTestingResultStatusValues() []QueryTestingResultStatus

+ func (c QueryTestingResultStatus) ToPtr() *QueryTestingResultStatus

+ type RawInputDatasourceProperties struct

+ Payload *string

+ PayloadURI *string

+ type RawOutputDatasource struct

+ Properties *RawOutputDatasourceProperties

+ func (r *RawOutputDatasource) UnmarshalJSON(data []byte) error

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

+ type RawOutputDatasourceProperties struct

+ PayloadURI *string

+ type RawReferenceInputDataSource struct

+ Properties *RawInputDatasourceProperties

+ func (r *RawReferenceInputDataSource) UnmarshalJSON(data []byte) error

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

+ type RawStreamInputDataSource struct

+ Properties *RawInputDatasourceProperties

+ func (r *RawStreamInputDataSource) UnmarshalJSON(data []byte) error

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

+ type ReferenceInputDataSource struct

+ Type *string

+ func (r *ReferenceInputDataSource) GetReferenceInputDataSource() *ReferenceInputDataSource

+ func (r *ReferenceInputDataSource) UnmarshalJSON(data []byte) error

+ type ReferenceInputDataSourceClassification interface

+ GetReferenceInputDataSource func() *ReferenceInputDataSource

+ type ReferenceInputProperties struct

+ Datasource ReferenceInputDataSourceClassification

+ func (r *ReferenceInputProperties) UnmarshalJSON(data []byte) error

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

+ type Resource struct

+ ID *string

+ Name *string

+ Type *string

+ func (r Resource) MarshalJSON() ([]byte, error)

+ type ResourceTestStatus struct

+ Error *ErrorResponse

+ Status *string

+ type SampleInput struct

+ CompatibilityLevel *string

+ DataLocale *string

+ EventsURI *string

+ Input *Input

+ type SampleInputResult struct

+ Diagnostics []*string

+ EventsDownloadURL *string

+ LastArrivalTime *string

+ Status *SampleInputResultStatus

+ type SampleInputResultStatus string

+ const SampleInputResultStatusErrorConnectingToInput

+ const SampleInputResultStatusNoEventsFoundInRange

+ const SampleInputResultStatusReadAllEventsInRange

+ func PossibleSampleInputResultStatusValues() []SampleInputResultStatus

+ func (c SampleInputResultStatus) ToPtr() *SampleInputResultStatus

+ type ScalarFunctionProperties struct

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

+ type Serialization struct

+ Type *EventSerializationType

+ func (s *Serialization) GetSerialization() *Serialization

+ func (s *Serialization) UnmarshalJSON(data []byte) error

+ type SerializationClassification interface

+ GetSerialization func() *Serialization

+ type ServiceBusDataSourceProperties struct

+ AuthenticationMode *AuthenticationMode

+ ServiceBusNamespace *string

+ SharedAccessPolicyKey *string

+ SharedAccessPolicyName *string

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

+ type ServiceBusQueueOutputDataSource struct

+ Properties *ServiceBusQueueOutputDataSourceProperties

+ func (s *ServiceBusQueueOutputDataSource) UnmarshalJSON(data []byte) error

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

+ type ServiceBusQueueOutputDataSourceProperties struct

+ PropertyColumns []*string

+ QueueName *string

+ SystemPropertyColumns map[string]*string

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

+ type ServiceBusTopicOutputDataSource struct

+ Properties *ServiceBusTopicOutputDataSourceProperties

+ func (s *ServiceBusTopicOutputDataSource) UnmarshalJSON(data []byte) error

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

+ type ServiceBusTopicOutputDataSourceProperties struct

+ PropertyColumns []*string

+ SystemPropertyColumns map[string]*string

+ TopicName *string

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

+ type StartStreamingJobParameters struct

+ OutputStartMode *OutputStartMode

+ OutputStartTime *time.Time

+ func (s *StartStreamingJobParameters) UnmarshalJSON(data []byte) error

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

+ type StorageAccount struct

+ AccountKey *string

+ AccountName *string

+ type StreamInputDataSource struct

+ Type *string

+ func (s *StreamInputDataSource) GetStreamInputDataSource() *StreamInputDataSource

+ func (s *StreamInputDataSource) UnmarshalJSON(data []byte) error

+ type StreamInputDataSourceClassification interface

+ GetStreamInputDataSource func() *StreamInputDataSource

+ type StreamInputProperties struct

+ Datasource StreamInputDataSourceClassification

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

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

+ type StreamingJob struct

+ Identity *Identity

+ Properties *StreamingJobProperties

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

+ type StreamingJobListResult struct

+ NextLink *string

+ Value []*StreamingJob

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

+ type StreamingJobProperties struct

+ Cluster *ClusterInfo

+ CompatibilityLevel *CompatibilityLevel

+ ContentStoragePolicy *ContentStoragePolicy

+ CreatedDate *time.Time

+ DataLocale *string

+ Etag *string

+ EventsLateArrivalMaxDelayInSeconds *int32

+ EventsOutOfOrderMaxDelayInSeconds *int32

+ EventsOutOfOrderPolicy *EventsOutOfOrderPolicy

+ Externals *External

+ Functions []*Function

+ Inputs []*Input

+ JobID *string

+ JobState *string

+ JobStorageAccount *JobStorageAccount

+ JobType *JobType

+ LastOutputEventTime *time.Time

+ OutputErrorPolicy *OutputErrorPolicy

+ OutputStartMode *OutputStartMode

+ OutputStartTime *time.Time

+ Outputs []*Output

+ ProvisioningState *string

+ SKU *StreamingJobSKU

+ Transformation *Transformation

+ func (s *StreamingJobProperties) UnmarshalJSON(data []byte) error

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

+ type StreamingJobSKU struct

+ Name *StreamingJobSKUName

+ type StreamingJobSKUName string

+ const StreamingJobSKUNameStandard

+ func PossibleStreamingJobSKUNameValues() []StreamingJobSKUName

+ func (c StreamingJobSKUName) ToPtr() *StreamingJobSKUName

+ type StreamingJobsBeginCreateOrReplaceOptions struct

+ IfMatch *string

+ IfNoneMatch *string

+ type StreamingJobsBeginDeleteOptions struct

+ type StreamingJobsBeginStartOptions struct

+ StartJobParameters *StartStreamingJobParameters

+ type StreamingJobsBeginStopOptions struct

+ type StreamingJobsClient struct

+ func NewStreamingJobsClient(con *arm.Connection, subscriptionID string) *StreamingJobsClient

+ func (client *StreamingJobsClient) BeginCreateOrReplace(ctx context.Context, resourceGroupName string, jobName string, ...) (StreamingJobsCreateOrReplacePollerResponse, error)

+ func (client *StreamingJobsClient) BeginDelete(ctx context.Context, resourceGroupName string, jobName string, ...) (StreamingJobsDeletePollerResponse, error)

+ func (client *StreamingJobsClient) BeginStart(ctx context.Context, resourceGroupName string, jobName string, ...) (StreamingJobsStartPollerResponse, error)

+ func (client *StreamingJobsClient) BeginStop(ctx context.Context, resourceGroupName string, jobName string, ...) (StreamingJobsStopPollerResponse, error)

+ func (client *StreamingJobsClient) Get(ctx context.Context, resourceGroupName string, jobName string, ...) (StreamingJobsGetResponse, error)

+ func (client *StreamingJobsClient) List(options *StreamingJobsListOptions) *StreamingJobsListPager

+ func (client *StreamingJobsClient) ListByResourceGroup(resourceGroupName string, options *StreamingJobsListByResourceGroupOptions) *StreamingJobsListByResourceGroupPager

+ func (client *StreamingJobsClient) Update(ctx context.Context, resourceGroupName string, jobName string, ...) (StreamingJobsUpdateResponse, error)

+ type StreamingJobsCreateOrReplacePoller struct

+ func (p *StreamingJobsCreateOrReplacePoller) Done() bool

+ func (p *StreamingJobsCreateOrReplacePoller) FinalResponse(ctx context.Context) (StreamingJobsCreateOrReplaceResponse, error)

+ func (p *StreamingJobsCreateOrReplacePoller) Poll(ctx context.Context) (*http.Response, error)

+ func (p *StreamingJobsCreateOrReplacePoller) ResumeToken() (string, error)

+ type StreamingJobsCreateOrReplacePollerResponse struct

+ Poller *StreamingJobsCreateOrReplacePoller

+ RawResponse *http.Response

+ func (l *StreamingJobsCreateOrReplacePollerResponse) Resume(ctx context.Context, client *StreamingJobsClient, token string) error

+ func (l StreamingJobsCreateOrReplacePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (StreamingJobsCreateOrReplaceResponse, error)

+ type StreamingJobsCreateOrReplaceResponse struct

+ RawResponse *http.Response

+ type StreamingJobsCreateOrReplaceResult struct

+ type StreamingJobsDeletePoller struct

+ func (p *StreamingJobsDeletePoller) Done() bool

+ func (p *StreamingJobsDeletePoller) FinalResponse(ctx context.Context) (StreamingJobsDeleteResponse, error)

+ func (p *StreamingJobsDeletePoller) Poll(ctx context.Context) (*http.Response, error)

+ func (p *StreamingJobsDeletePoller) ResumeToken() (string, error)

+ type StreamingJobsDeletePollerResponse struct

+ Poller *StreamingJobsDeletePoller

+ RawResponse *http.Response

+ func (l *StreamingJobsDeletePollerResponse) Resume(ctx context.Context, client *StreamingJobsClient, token string) error

+ func (l StreamingJobsDeletePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (StreamingJobsDeleteResponse, error)

+ type StreamingJobsDeleteResponse struct

+ RawResponse *http.Response

+ type StreamingJobsGetOptions struct

+ Expand *string

+ type StreamingJobsGetResponse struct

+ RawResponse *http.Response

+ type StreamingJobsGetResult struct

+ ETag *string

+ type StreamingJobsListByResourceGroupOptions struct

+ Expand *string

+ type StreamingJobsListByResourceGroupPager struct

+ func (p *StreamingJobsListByResourceGroupPager) Err() error

+ func (p *StreamingJobsListByResourceGroupPager) NextPage(ctx context.Context) bool

+ func (p *StreamingJobsListByResourceGroupPager) PageResponse() StreamingJobsListByResourceGroupResponse

+ type StreamingJobsListByResourceGroupResponse struct

+ RawResponse *http.Response

+ type StreamingJobsListByResourceGroupResult struct

+ type StreamingJobsListOptions struct

+ Expand *string

+ type StreamingJobsListPager struct

+ func (p *StreamingJobsListPager) Err() error

+ func (p *StreamingJobsListPager) NextPage(ctx context.Context) bool

+ func (p *StreamingJobsListPager) PageResponse() StreamingJobsListResponse

+ type StreamingJobsListResponse struct

+ RawResponse *http.Response

+ type StreamingJobsListResult struct

+ type StreamingJobsStartPoller struct

+ func (p *StreamingJobsStartPoller) Done() bool

+ func (p *StreamingJobsStartPoller) FinalResponse(ctx context.Context) (StreamingJobsStartResponse, error)

+ func (p *StreamingJobsStartPoller) Poll(ctx context.Context) (*http.Response, error)

+ func (p *StreamingJobsStartPoller) ResumeToken() (string, error)

+ type StreamingJobsStartPollerResponse struct

+ Poller *StreamingJobsStartPoller

+ RawResponse *http.Response

+ func (l *StreamingJobsStartPollerResponse) Resume(ctx context.Context, client *StreamingJobsClient, token string) error

+ func (l StreamingJobsStartPollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (StreamingJobsStartResponse, error)

+ type StreamingJobsStartResponse struct

+ RawResponse *http.Response

+ type StreamingJobsStopPoller struct

+ func (p *StreamingJobsStopPoller) Done() bool

+ func (p *StreamingJobsStopPoller) FinalResponse(ctx context.Context) (StreamingJobsStopResponse, error)

+ func (p *StreamingJobsStopPoller) Poll(ctx context.Context) (*http.Response, error)

+ func (p *StreamingJobsStopPoller) ResumeToken() (string, error)

+ type StreamingJobsStopPollerResponse struct

+ Poller *StreamingJobsStopPoller

+ RawResponse *http.Response

+ func (l *StreamingJobsStopPollerResponse) Resume(ctx context.Context, client *StreamingJobsClient, token string) error

+ func (l StreamingJobsStopPollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (StreamingJobsStopResponse, error)

+ type StreamingJobsStopResponse struct

+ RawResponse *http.Response

+ type StreamingJobsUpdateOptions struct

+ IfMatch *string

+ type StreamingJobsUpdateResponse struct

+ RawResponse *http.Response

+ type StreamingJobsUpdateResult struct

+ ETag *string

+ type SubResource struct

+ ID *string

+ Name *string

+ Type *string

+ func (s *SubResource) UnmarshalJSON(data []byte) error

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

+ type SubscriptionQuota struct

+ Properties *SubscriptionQuotaProperties

+ func (s *SubscriptionQuota) UnmarshalJSON(data []byte) error

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

+ type SubscriptionQuotaProperties struct

+ CurrentCount *int32

+ MaxCount *int32

+ type SubscriptionQuotasListResult struct

+ Value []*SubscriptionQuota

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

+ type SubscriptionsBeginSampleInputOptions struct

+ type SubscriptionsBeginTestInputOptions struct

+ type SubscriptionsBeginTestOutputOptions struct

+ type SubscriptionsBeginTestQueryOptions struct

+ type SubscriptionsClient struct

+ func NewSubscriptionsClient(con *arm.Connection, subscriptionID string) *SubscriptionsClient

+ func (client *SubscriptionsClient) BeginSampleInput(ctx context.Context, location string, sampleInput SampleInput, ...) (SubscriptionsSampleInputPollerResponse, error)

+ func (client *SubscriptionsClient) BeginTestInput(ctx context.Context, location string, testInput TestInput, ...) (SubscriptionsTestInputPollerResponse, error)

+ func (client *SubscriptionsClient) BeginTestOutput(ctx context.Context, location string, testOutput TestOutput, ...) (SubscriptionsTestOutputPollerResponse, error)

+ func (client *SubscriptionsClient) BeginTestQuery(ctx context.Context, location string, testQuery TestQuery, ...) (SubscriptionsTestQueryPollerResponse, error)

+ func (client *SubscriptionsClient) CompileQuery(ctx context.Context, location string, compileQuery CompileQuery, ...) (SubscriptionsCompileQueryResponse, error)

+ func (client *SubscriptionsClient) ListQuotas(ctx context.Context, location string, options *SubscriptionsListQuotasOptions) (SubscriptionsListQuotasResponse, error)

+ type SubscriptionsCompileQueryOptions struct

+ type SubscriptionsCompileQueryResponse struct

+ RawResponse *http.Response

+ type SubscriptionsCompileQueryResult struct

+ type SubscriptionsListQuotasOptions struct

+ type SubscriptionsListQuotasResponse struct

+ RawResponse *http.Response

+ type SubscriptionsListQuotasResult struct

+ type SubscriptionsSampleInputPoller struct

+ func (p *SubscriptionsSampleInputPoller) Done() bool

+ func (p *SubscriptionsSampleInputPoller) FinalResponse(ctx context.Context) (SubscriptionsSampleInputResponse, error)

+ func (p *SubscriptionsSampleInputPoller) Poll(ctx context.Context) (*http.Response, error)

+ func (p *SubscriptionsSampleInputPoller) ResumeToken() (string, error)

+ type SubscriptionsSampleInputPollerResponse struct

+ Poller *SubscriptionsSampleInputPoller

+ RawResponse *http.Response

+ func (l *SubscriptionsSampleInputPollerResponse) Resume(ctx context.Context, client *SubscriptionsClient, token string) error

+ func (l SubscriptionsSampleInputPollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (SubscriptionsSampleInputResponse, error)

+ type SubscriptionsSampleInputResponse struct

+ RawResponse *http.Response

+ type SubscriptionsSampleInputResult struct

+ type SubscriptionsTestInputPoller struct

+ func (p *SubscriptionsTestInputPoller) Done() bool

+ func (p *SubscriptionsTestInputPoller) FinalResponse(ctx context.Context) (SubscriptionsTestInputResponse, error)

+ func (p *SubscriptionsTestInputPoller) Poll(ctx context.Context) (*http.Response, error)

+ func (p *SubscriptionsTestInputPoller) ResumeToken() (string, error)

+ type SubscriptionsTestInputPollerResponse struct

+ Poller *SubscriptionsTestInputPoller

+ RawResponse *http.Response

+ func (l *SubscriptionsTestInputPollerResponse) Resume(ctx context.Context, client *SubscriptionsClient, token string) error

+ func (l SubscriptionsTestInputPollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (SubscriptionsTestInputResponse, error)

+ type SubscriptionsTestInputResponse struct

+ RawResponse *http.Response

+ type SubscriptionsTestInputResult struct

+ type SubscriptionsTestOutputPoller struct

+ func (p *SubscriptionsTestOutputPoller) Done() bool

+ func (p *SubscriptionsTestOutputPoller) FinalResponse(ctx context.Context) (SubscriptionsTestOutputResponse, error)

+ func (p *SubscriptionsTestOutputPoller) Poll(ctx context.Context) (*http.Response, error)

+ func (p *SubscriptionsTestOutputPoller) ResumeToken() (string, error)

+ type SubscriptionsTestOutputPollerResponse struct

+ Poller *SubscriptionsTestOutputPoller

+ RawResponse *http.Response

+ func (l *SubscriptionsTestOutputPollerResponse) Resume(ctx context.Context, client *SubscriptionsClient, token string) error

+ func (l SubscriptionsTestOutputPollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (SubscriptionsTestOutputResponse, error)

+ type SubscriptionsTestOutputResponse struct

+ RawResponse *http.Response

+ type SubscriptionsTestOutputResult struct

+ type SubscriptionsTestQueryPoller struct

+ func (p *SubscriptionsTestQueryPoller) Done() bool

+ func (p *SubscriptionsTestQueryPoller) FinalResponse(ctx context.Context) (SubscriptionsTestQueryResponse, error)

+ func (p *SubscriptionsTestQueryPoller) Poll(ctx context.Context) (*http.Response, error)

+ func (p *SubscriptionsTestQueryPoller) ResumeToken() (string, error)

+ type SubscriptionsTestQueryPollerResponse struct

+ Poller *SubscriptionsTestQueryPoller

+ RawResponse *http.Response

+ func (l *SubscriptionsTestQueryPollerResponse) Resume(ctx context.Context, client *SubscriptionsClient, token string) error

+ func (l SubscriptionsTestQueryPollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (SubscriptionsTestQueryResponse, error)

+ type SubscriptionsTestQueryResponse struct

+ RawResponse *http.Response

+ type SubscriptionsTestQueryResult struct

+ type TestDatasourceResult struct

+ Status *TestDatasourceResultStatus

+ type TestDatasourceResultStatus string

+ const TestDatasourceResultStatusTestFailed

+ const TestDatasourceResultStatusTestSucceeded

+ func PossibleTestDatasourceResultStatusValues() []TestDatasourceResultStatus

+ func (c TestDatasourceResultStatus) ToPtr() *TestDatasourceResultStatus

+ type TestInput struct

+ Input *Input

+ type TestOutput struct

+ Output *Output

+ type TestQuery struct

+ Diagnostics *TestQueryDiagnostics

+ StreamingJob *StreamingJob

+ type TestQueryDiagnostics struct

+ Path *string

+ WriteURI *string

+ type TrackedResource struct

+ Location *string

+ Tags map[string]*string

+ func (t TrackedResource) MarshalJSON() ([]byte, error)

+ type Transformation struct

+ Properties *TransformationProperties

+ func (t *Transformation) UnmarshalJSON(data []byte) error

+ func (t Transformation) MarshalJSON() ([]byte, error)

+ type TransformationProperties struct

+ Etag *string

+ Query *string

+ StreamingUnits *int32

+ type TransformationsClient struct

+ func NewTransformationsClient(con *arm.Connection, subscriptionID string) *TransformationsClient

+ func (client *TransformationsClient) CreateOrReplace(ctx context.Context, resourceGroupName string, jobName string, ...) (TransformationsCreateOrReplaceResponse, error)

+ func (client *TransformationsClient) Get(ctx context.Context, resourceGroupName string, jobName string, ...) (TransformationsGetResponse, error)

+ func (client *TransformationsClient) Update(ctx context.Context, resourceGroupName string, jobName string, ...) (TransformationsUpdateResponse, error)

+ type TransformationsCreateOrReplaceOptions struct

+ IfMatch *string

+ IfNoneMatch *string

+ type TransformationsCreateOrReplaceResponse struct

+ RawResponse *http.Response

+ type TransformationsCreateOrReplaceResult struct

+ ETag *string

+ type TransformationsGetOptions struct

+ type TransformationsGetResponse struct

+ RawResponse *http.Response

+ type TransformationsGetResult struct

+ ETag *string

+ type TransformationsUpdateOptions struct

+ IfMatch *string

+ type TransformationsUpdateResponse struct

+ RawResponse *http.Response

+ type TransformationsUpdateResult struct

+ ETag *string

Other modules containing this package

github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics/v2

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