Versions in this module Expand all Collapse all v1 v1.2.0 Nov 24, 2023 Changes in this version + type ClustersServer struct + BeginCreateOrUpdate func(ctx context.Context, resourceGroupName string, clusterName string, ...) (...) + BeginDelete func(ctx context.Context, resourceGroupName string, clusterName string, ...) (resp azfake.PollerResponder[armstreamanalytics.ClustersClientDeleteResponse], ...) + BeginUpdate func(ctx context.Context, resourceGroupName string, clusterName string, ...) (resp azfake.PollerResponder[armstreamanalytics.ClustersClientUpdateResponse], ...) + Get func(ctx context.Context, resourceGroupName string, clusterName string, ...) (resp azfake.Responder[armstreamanalytics.ClustersClientGetResponse], ...) + NewListByResourceGroupPager func(resourceGroupName string, ...) (...) + NewListBySubscriptionPager func(options *armstreamanalytics.ClustersClientListBySubscriptionOptions) (...) + NewListStreamingJobsPager func(resourceGroupName string, clusterName string, ...) (...) + type ClustersServerTransport struct + func NewClustersServerTransport(srv *ClustersServer) *ClustersServerTransport + func (c *ClustersServerTransport) Do(req *http.Request) (*http.Response, error) + type FunctionsServer struct + BeginTest func(ctx context.Context, resourceGroupName string, jobName string, ...) (resp azfake.PollerResponder[armstreamanalytics.FunctionsClientTestResponse], ...) + CreateOrReplace func(ctx context.Context, resourceGroupName string, jobName string, ...) (...) + Delete func(ctx context.Context, resourceGroupName string, jobName string, ...) (resp azfake.Responder[armstreamanalytics.FunctionsClientDeleteResponse], ...) + Get func(ctx context.Context, resourceGroupName string, jobName string, ...) (resp azfake.Responder[armstreamanalytics.FunctionsClientGetResponse], ...) + NewListByStreamingJobPager func(resourceGroupName string, jobName string, ...) (...) + RetrieveDefaultDefinition func(ctx context.Context, resourceGroupName string, jobName string, ...) (...) + Update func(ctx context.Context, resourceGroupName string, jobName string, ...) (resp azfake.Responder[armstreamanalytics.FunctionsClientUpdateResponse], ...) + type FunctionsServerTransport struct + func NewFunctionsServerTransport(srv *FunctionsServer) *FunctionsServerTransport + func (f *FunctionsServerTransport) Do(req *http.Request) (*http.Response, error) + type InputsServer struct + BeginTest func(ctx context.Context, resourceGroupName string, jobName string, ...) (resp azfake.PollerResponder[armstreamanalytics.InputsClientTestResponse], ...) + CreateOrReplace func(ctx context.Context, resourceGroupName string, jobName string, ...) (resp azfake.Responder[armstreamanalytics.InputsClientCreateOrReplaceResponse], ...) + Delete func(ctx context.Context, resourceGroupName string, jobName string, ...) (resp azfake.Responder[armstreamanalytics.InputsClientDeleteResponse], ...) + Get func(ctx context.Context, resourceGroupName string, jobName string, ...) (resp azfake.Responder[armstreamanalytics.InputsClientGetResponse], ...) + NewListByStreamingJobPager func(resourceGroupName string, jobName string, ...) (...) + Update func(ctx context.Context, resourceGroupName string, jobName string, ...) (resp azfake.Responder[armstreamanalytics.InputsClientUpdateResponse], ...) + type InputsServerTransport struct + func NewInputsServerTransport(srv *InputsServer) *InputsServerTransport + func (i *InputsServerTransport) Do(req *http.Request) (*http.Response, error) + type OperationsServer struct + NewListPager func(options *armstreamanalytics.OperationsClientListOptions) (resp azfake.PagerResponder[armstreamanalytics.OperationsClientListResponse]) + type OperationsServerTransport struct + func NewOperationsServerTransport(srv *OperationsServer) *OperationsServerTransport + func (o *OperationsServerTransport) Do(req *http.Request) (*http.Response, error) + type OutputsServer struct + BeginTest func(ctx context.Context, resourceGroupName string, jobName string, ...) (resp azfake.PollerResponder[armstreamanalytics.OutputsClientTestResponse], ...) + CreateOrReplace func(ctx context.Context, resourceGroupName string, jobName string, ...) (resp azfake.Responder[armstreamanalytics.OutputsClientCreateOrReplaceResponse], ...) + Delete func(ctx context.Context, resourceGroupName string, jobName string, ...) (resp azfake.Responder[armstreamanalytics.OutputsClientDeleteResponse], ...) + Get func(ctx context.Context, resourceGroupName string, jobName string, ...) (resp azfake.Responder[armstreamanalytics.OutputsClientGetResponse], ...) + NewListByStreamingJobPager func(resourceGroupName string, jobName string, ...) (...) + Update func(ctx context.Context, resourceGroupName string, jobName string, ...) (resp azfake.Responder[armstreamanalytics.OutputsClientUpdateResponse], ...) + type OutputsServerTransport struct + func NewOutputsServerTransport(srv *OutputsServer) *OutputsServerTransport + func (o *OutputsServerTransport) Do(req *http.Request) (*http.Response, error) + type PrivateEndpointsServer struct + BeginDelete func(ctx context.Context, resourceGroupName string, clusterName string, ...) (...) + CreateOrUpdate func(ctx context.Context, resourceGroupName string, clusterName string, ...) (...) + Get func(ctx context.Context, resourceGroupName string, clusterName string, ...) (resp azfake.Responder[armstreamanalytics.PrivateEndpointsClientGetResponse], ...) + NewListByClusterPager func(resourceGroupName string, clusterName string, ...) (...) + type PrivateEndpointsServerTransport struct + func NewPrivateEndpointsServerTransport(srv *PrivateEndpointsServer) *PrivateEndpointsServerTransport + func (p *PrivateEndpointsServerTransport) Do(req *http.Request) (*http.Response, error) + type ServerFactory struct + ClustersServer ClustersServer + FunctionsServer FunctionsServer + InputsServer InputsServer + OperationsServer OperationsServer + OutputsServer OutputsServer + PrivateEndpointsServer PrivateEndpointsServer + StreamingJobsServer StreamingJobsServer + SubscriptionsServer SubscriptionsServer + TransformationsServer TransformationsServer + type ServerFactoryTransport struct + func NewServerFactoryTransport(srv *ServerFactory) *ServerFactoryTransport + func (s *ServerFactoryTransport) Do(req *http.Request) (*http.Response, error) + type StreamingJobsServer struct + BeginCreateOrReplace func(ctx context.Context, resourceGroupName string, jobName string, ...) (...) + BeginDelete func(ctx context.Context, resourceGroupName string, jobName string, ...) (...) + BeginScale func(ctx context.Context, resourceGroupName string, jobName string, ...) (...) + BeginStart func(ctx context.Context, resourceGroupName string, jobName string, ...) (...) + BeginStop func(ctx context.Context, resourceGroupName string, jobName string, ...) (...) + Get func(ctx context.Context, resourceGroupName string, jobName string, ...) (resp azfake.Responder[armstreamanalytics.StreamingJobsClientGetResponse], ...) + NewListByResourceGroupPager func(resourceGroupName string, ...) (...) + NewListPager func(options *armstreamanalytics.StreamingJobsClientListOptions) (resp azfake.PagerResponder[armstreamanalytics.StreamingJobsClientListResponse]) + Update func(ctx context.Context, resourceGroupName string, jobName string, ...) (resp azfake.Responder[armstreamanalytics.StreamingJobsClientUpdateResponse], ...) + type StreamingJobsServerTransport struct + func NewStreamingJobsServerTransport(srv *StreamingJobsServer) *StreamingJobsServerTransport + func (s *StreamingJobsServerTransport) Do(req *http.Request) (*http.Response, error) + type SubscriptionsServer struct + ListQuotas func(ctx context.Context, location string, ...) (...) + type SubscriptionsServerTransport struct + func NewSubscriptionsServerTransport(srv *SubscriptionsServer) *SubscriptionsServerTransport + func (s *SubscriptionsServerTransport) Do(req *http.Request) (*http.Response, error) + type TransformationsServer struct + CreateOrReplace func(ctx context.Context, resourceGroupName string, jobName string, ...) (...) + Get func(ctx context.Context, resourceGroupName string, jobName string, ...) (resp azfake.Responder[armstreamanalytics.TransformationsClientGetResponse], ...) + Update func(ctx context.Context, resourceGroupName string, jobName string, ...) (resp azfake.Responder[armstreamanalytics.TransformationsClientUpdateResponse], ...) + type TransformationsServerTransport struct + func NewTransformationsServerTransport(srv *TransformationsServer) *TransformationsServerTransport + func (t *TransformationsServerTransport) Do(req *http.Request) (*http.Response, error) Other modules containing this package github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics/v2