Versions in this module Expand all Collapse all v1 v1.1.4 Sep 7, 2022 Changes in this version + type ClustersClientAPI interface + CreateOrUpdate func(ctx context.Context, cluster streamanalytics.Cluster, resourceGroupName string, ...) (result streamanalytics.ClustersCreateOrUpdateFuture, err error) + Delete func(ctx context.Context, resourceGroupName string, clusterName string) (result streamanalytics.ClustersDeleteFuture, err error) + Get func(ctx context.Context, resourceGroupName string, clusterName string) (result streamanalytics.Cluster, err error) + ListByResourceGroup func(ctx context.Context, resourceGroupName string) (result streamanalytics.ClusterListResultPage, err error) + ListByResourceGroupComplete func(ctx context.Context, resourceGroupName string) (result streamanalytics.ClusterListResultIterator, err error) + ListBySubscription func(ctx context.Context) (result streamanalytics.ClusterListResultPage, err error) + ListBySubscriptionComplete func(ctx context.Context) (result streamanalytics.ClusterListResultIterator, err error) + ListStreamingJobs func(ctx context.Context, resourceGroupName string, clusterName string) (result streamanalytics.ClusterJobListResultPage, err error) + ListStreamingJobsComplete func(ctx context.Context, resourceGroupName string, clusterName string) (result streamanalytics.ClusterJobListResultIterator, err error) + Update func(ctx context.Context, cluster streamanalytics.Cluster, resourceGroupName string, ...) (result streamanalytics.ClustersUpdateFuture, err error) + type FunctionsClientAPI interface + CreateOrReplace func(ctx context.Context, function streamanalytics.Function, ...) (result streamanalytics.Function, err error) + Delete func(ctx context.Context, resourceGroupName string, jobName string, ...) (result autorest.Response, err error) + Get func(ctx context.Context, resourceGroupName string, jobName string, ...) (result streamanalytics.Function, err error) + ListByStreamingJob func(ctx context.Context, resourceGroupName string, jobName string, ...) (result streamanalytics.FunctionListResultPage, err error) + ListByStreamingJobComplete func(ctx context.Context, resourceGroupName string, jobName string, ...) (result streamanalytics.FunctionListResultIterator, err error) + RetrieveDefaultDefinition func(ctx context.Context, resourceGroupName string, jobName string, ...) (result streamanalytics.Function, err error) + Test func(ctx context.Context, resourceGroupName string, jobName string, ...) (result streamanalytics.FunctionsTestFuture, err error) + Update func(ctx context.Context, function streamanalytics.Function, ...) (result streamanalytics.Function, err error) + type InputsClientAPI interface + CreateOrReplace func(ctx context.Context, input streamanalytics.Input, resourceGroupName string, ...) (result streamanalytics.Input, err error) + Delete func(ctx context.Context, resourceGroupName string, jobName string, ...) (result autorest.Response, err error) + Get func(ctx context.Context, resourceGroupName string, jobName string, ...) (result streamanalytics.Input, err error) + ListByStreamingJob func(ctx context.Context, resourceGroupName string, jobName string, ...) (result streamanalytics.InputListResultPage, err error) + ListByStreamingJobComplete func(ctx context.Context, resourceGroupName string, jobName string, ...) (result streamanalytics.InputListResultIterator, err error) + Test func(ctx context.Context, resourceGroupName string, jobName string, ...) (result streamanalytics.InputsTestFuture, err error) + Update func(ctx context.Context, input streamanalytics.Input, resourceGroupName string, ...) (result streamanalytics.Input, err error) + type OperationsClientAPI interface + List func(ctx context.Context) (result streamanalytics.OperationListResultPage, err error) + ListComplete func(ctx context.Context) (result streamanalytics.OperationListResultIterator, err error) + type OutputsClientAPI interface + CreateOrReplace func(ctx context.Context, output streamanalytics.Output, resourceGroupName string, ...) (result streamanalytics.Output, err error) + Delete func(ctx context.Context, resourceGroupName string, jobName string, ...) (result autorest.Response, err error) + Get func(ctx context.Context, resourceGroupName string, jobName string, ...) (result streamanalytics.Output, err error) + ListByStreamingJob func(ctx context.Context, resourceGroupName string, jobName string, ...) (result streamanalytics.OutputListResultPage, err error) + ListByStreamingJobComplete func(ctx context.Context, resourceGroupName string, jobName string, ...) (result streamanalytics.OutputListResultIterator, err error) + Test func(ctx context.Context, resourceGroupName string, jobName string, ...) (result streamanalytics.OutputsTestFuture, err error) + Update func(ctx context.Context, output streamanalytics.Output, resourceGroupName string, ...) (result streamanalytics.Output, err error) + type PrivateEndpointsClientAPI interface + CreateOrUpdate func(ctx context.Context, privateEndpoint streamanalytics.PrivateEndpoint, ...) (result streamanalytics.PrivateEndpoint, err error) + Delete func(ctx context.Context, resourceGroupName string, clusterName string, ...) (result streamanalytics.PrivateEndpointsDeleteFuture, err error) + Get func(ctx context.Context, resourceGroupName string, clusterName string, ...) (result streamanalytics.PrivateEndpoint, err error) + ListByCluster func(ctx context.Context, resourceGroupName string, clusterName string) (result streamanalytics.PrivateEndpointListResultPage, err error) + ListByClusterComplete func(ctx context.Context, resourceGroupName string, clusterName string) (result streamanalytics.PrivateEndpointListResultIterator, err error) + type StreamingJobsClientAPI interface + CreateOrReplace func(ctx context.Context, streamingJob streamanalytics.StreamingJob, ...) (result streamanalytics.StreamingJobsCreateOrReplaceFuture, err error) + Delete func(ctx context.Context, resourceGroupName string, jobName string) (result streamanalytics.StreamingJobsDeleteFuture, err error) + Get func(ctx context.Context, resourceGroupName string, jobName string, expand string) (result streamanalytics.StreamingJob, err error) + List func(ctx context.Context, expand string) (result streamanalytics.StreamingJobListResultPage, err error) + ListByResourceGroup func(ctx context.Context, resourceGroupName string, expand string) (result streamanalytics.StreamingJobListResultPage, err error) + ListByResourceGroupComplete func(ctx context.Context, resourceGroupName string, expand string) (result streamanalytics.StreamingJobListResultIterator, err error) + ListComplete func(ctx context.Context, expand string) (result streamanalytics.StreamingJobListResultIterator, err error) + Start func(ctx context.Context, resourceGroupName string, jobName string, ...) (result streamanalytics.StreamingJobsStartFuture, err error) + Stop func(ctx context.Context, resourceGroupName string, jobName string) (result streamanalytics.StreamingJobsStopFuture, err error) + Update func(ctx context.Context, streamingJob streamanalytics.StreamingJob, ...) (result streamanalytics.StreamingJob, err error) + type SubscriptionsClientAPI interface + ListQuotas func(ctx context.Context, location string) (result streamanalytics.SubscriptionQuotasListResult, err error) + type TransformationsClientAPI interface + CreateOrReplace func(ctx context.Context, transformation streamanalytics.Transformation, ...) (result streamanalytics.Transformation, err error) + Get func(ctx context.Context, resourceGroupName string, jobName string, ...) (result streamanalytics.Transformation, err error) + Update func(ctx context.Context, transformation streamanalytics.Transformation, ...) (result streamanalytics.Transformation, err error)