fake

package
v2.0.0-beta.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 25, 2024 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ClustersServer 

type ClustersServer struct {
	// BeginCreateOrUpdate is the fake for method ClustersClient.BeginCreateOrUpdate
	// HTTP status codes to indicate success: http.StatusOK, http.StatusCreated
	BeginCreateOrUpdate func(ctx context.Context, resourceGroupName string, clusterName string, cluster armstreamanalytics.Cluster, options *armstreamanalytics.ClustersClientBeginCreateOrUpdateOptions) (resp azfake.PollerResponder[armstreamanalytics.ClustersClientCreateOrUpdateResponse], errResp azfake.ErrorResponder)

	// BeginDelete is the fake for method ClustersClient.BeginDelete
	// HTTP status codes to indicate success: http.StatusOK, http.StatusAccepted, http.StatusNoContent
	BeginDelete func(ctx context.Context, resourceGroupName string, clusterName string, options *armstreamanalytics.ClustersClientBeginDeleteOptions) (resp azfake.PollerResponder[armstreamanalytics.ClustersClientDeleteResponse], errResp azfake.ErrorResponder)

	// Get is the fake for method ClustersClient.Get
	// HTTP status codes to indicate success: http.StatusOK
	Get func(ctx context.Context, resourceGroupName string, clusterName string, options *armstreamanalytics.ClustersClientGetOptions) (resp azfake.Responder[armstreamanalytics.ClustersClientGetResponse], errResp azfake.ErrorResponder)

	// NewListByResourceGroupPager is the fake for method ClustersClient.NewListByResourceGroupPager
	// HTTP status codes to indicate success: http.StatusOK
	NewListByResourceGroupPager func(resourceGroupName string, options *armstreamanalytics.ClustersClientListByResourceGroupOptions) (resp azfake.PagerResponder[armstreamanalytics.ClustersClientListByResourceGroupResponse])

	// NewListBySubscriptionPager is the fake for method ClustersClient.NewListBySubscriptionPager
	// HTTP status codes to indicate success: http.StatusOK
	NewListBySubscriptionPager func(options *armstreamanalytics.ClustersClientListBySubscriptionOptions) (resp azfake.PagerResponder[armstreamanalytics.ClustersClientListBySubscriptionResponse])

	// NewListStreamingJobsPager is the fake for method ClustersClient.NewListStreamingJobsPager
	// HTTP status codes to indicate success: http.StatusOK
	NewListStreamingJobsPager func(resourceGroupName string, clusterName string, options *armstreamanalytics.ClustersClientListStreamingJobsOptions) (resp azfake.PagerResponder[armstreamanalytics.ClustersClientListStreamingJobsResponse])

	// BeginUpdate is the fake for method ClustersClient.BeginUpdate
	// HTTP status codes to indicate success: http.StatusOK, http.StatusAccepted
	BeginUpdate func(ctx context.Context, resourceGroupName string, clusterName string, cluster armstreamanalytics.Cluster, options *armstreamanalytics.ClustersClientBeginUpdateOptions) (resp azfake.PollerResponder[armstreamanalytics.ClustersClientUpdateResponse], errResp azfake.ErrorResponder)
}

ClustersServer is a fake server for instances of the armstreamanalytics.ClustersClient type.

type ClustersServerTransport 

type ClustersServerTransport struct {
	// contains filtered or unexported fields
}

ClustersServerTransport connects instances of armstreamanalytics.ClustersClient to instances of ClustersServer. Don't use this type directly, use NewClustersServerTransport instead.

func NewClustersServerTransport 

func NewClustersServerTransport(srv *ClustersServer) *ClustersServerTransport

NewClustersServerTransport creates a new instance of ClustersServerTransport with the provided implementation. The returned ClustersServerTransport instance is connected to an instance of armstreamanalytics.ClustersClient via the azcore.ClientOptions.Transporter field in the client's constructor parameters.

func (*ClustersServerTransport) Do 

func (c *ClustersServerTransport) Do(req *http.Request) (*http.Response, error)

Do implements the policy.Transporter interface for ClustersServerTransport.

type FunctionsServer 

type FunctionsServer struct {
	// CreateOrReplace is the fake for method FunctionsClient.CreateOrReplace
	// HTTP status codes to indicate success: http.StatusOK, http.StatusCreated
	CreateOrReplace func(ctx context.Context, resourceGroupName string, jobName string, functionName string, function armstreamanalytics.Function, options *armstreamanalytics.FunctionsClientCreateOrReplaceOptions) (resp azfake.Responder[armstreamanalytics.FunctionsClientCreateOrReplaceResponse], errResp azfake.ErrorResponder)

	// Delete is the fake for method FunctionsClient.Delete
	// HTTP status codes to indicate success: http.StatusOK, http.StatusNoContent
	Delete func(ctx context.Context, resourceGroupName string, jobName string, functionName string, options *armstreamanalytics.FunctionsClientDeleteOptions) (resp azfake.Responder[armstreamanalytics.FunctionsClientDeleteResponse], errResp azfake.ErrorResponder)

	// Get is the fake for method FunctionsClient.Get
	// HTTP status codes to indicate success: http.StatusOK
	Get func(ctx context.Context, resourceGroupName string, jobName string, functionName string, options *armstreamanalytics.FunctionsClientGetOptions) (resp azfake.Responder[armstreamanalytics.FunctionsClientGetResponse], errResp azfake.ErrorResponder)

	// NewListByStreamingJobPager is the fake for method FunctionsClient.NewListByStreamingJobPager
	// HTTP status codes to indicate success: http.StatusOK
	NewListByStreamingJobPager func(resourceGroupName string, jobName string, options *armstreamanalytics.FunctionsClientListByStreamingJobOptions) (resp azfake.PagerResponder[armstreamanalytics.FunctionsClientListByStreamingJobResponse])

	// RetrieveDefaultDefinition is the fake for method FunctionsClient.RetrieveDefaultDefinition
	// HTTP status codes to indicate success: http.StatusOK
	RetrieveDefaultDefinition func(ctx context.Context, resourceGroupName string, jobName string, functionName string, options *armstreamanalytics.FunctionsClientRetrieveDefaultDefinitionOptions) (resp azfake.Responder[armstreamanalytics.FunctionsClientRetrieveDefaultDefinitionResponse], errResp azfake.ErrorResponder)

	// BeginTest is the fake for method FunctionsClient.BeginTest
	// HTTP status codes to indicate success: http.StatusOK, http.StatusAccepted
	BeginTest func(ctx context.Context, resourceGroupName string, jobName string, functionName string, options *armstreamanalytics.FunctionsClientBeginTestOptions) (resp azfake.PollerResponder[armstreamanalytics.FunctionsClientTestResponse], errResp azfake.ErrorResponder)

	// Update is the fake for method FunctionsClient.Update
	// HTTP status codes to indicate success: http.StatusOK
	Update func(ctx context.Context, resourceGroupName string, jobName string, functionName string, function armstreamanalytics.Function, options *armstreamanalytics.FunctionsClientUpdateOptions) (resp azfake.Responder[armstreamanalytics.FunctionsClientUpdateResponse], errResp azfake.ErrorResponder)
}

FunctionsServer is a fake server for instances of the armstreamanalytics.FunctionsClient type.

type FunctionsServerTransport 

type FunctionsServerTransport struct {
	// contains filtered or unexported fields
}

FunctionsServerTransport connects instances of armstreamanalytics.FunctionsClient to instances of FunctionsServer. Don't use this type directly, use NewFunctionsServerTransport instead.

func NewFunctionsServerTransport 

func NewFunctionsServerTransport(srv *FunctionsServer) *FunctionsServerTransport

NewFunctionsServerTransport creates a new instance of FunctionsServerTransport with the provided implementation. The returned FunctionsServerTransport instance is connected to an instance of armstreamanalytics.FunctionsClient via the azcore.ClientOptions.Transporter field in the client's constructor parameters.

func (*FunctionsServerTransport) Do 

func (f *FunctionsServerTransport) Do(req *http.Request) (*http.Response, error)

Do implements the policy.Transporter interface for FunctionsServerTransport.

type InputsServer 

type InputsServer struct {
	// CreateOrReplace is the fake for method InputsClient.CreateOrReplace
	// HTTP status codes to indicate success: http.StatusOK, http.StatusCreated
	CreateOrReplace func(ctx context.Context, resourceGroupName string, jobName string, inputName string, input armstreamanalytics.Input, options *armstreamanalytics.InputsClientCreateOrReplaceOptions) (resp azfake.Responder[armstreamanalytics.InputsClientCreateOrReplaceResponse], errResp azfake.ErrorResponder)

	// Delete is the fake for method InputsClient.Delete
	// HTTP status codes to indicate success: http.StatusOK, http.StatusNoContent
	Delete func(ctx context.Context, resourceGroupName string, jobName string, inputName string, options *armstreamanalytics.InputsClientDeleteOptions) (resp azfake.Responder[armstreamanalytics.InputsClientDeleteResponse], errResp azfake.ErrorResponder)

	// Get is the fake for method InputsClient.Get
	// HTTP status codes to indicate success: http.StatusOK
	Get func(ctx context.Context, resourceGroupName string, jobName string, inputName string, options *armstreamanalytics.InputsClientGetOptions) (resp azfake.Responder[armstreamanalytics.InputsClientGetResponse], errResp azfake.ErrorResponder)

	// NewListByStreamingJobPager is the fake for method InputsClient.NewListByStreamingJobPager
	// HTTP status codes to indicate success: http.StatusOK
	NewListByStreamingJobPager func(resourceGroupName string, jobName string, options *armstreamanalytics.InputsClientListByStreamingJobOptions) (resp azfake.PagerResponder[armstreamanalytics.InputsClientListByStreamingJobResponse])

	// BeginTest is the fake for method InputsClient.BeginTest
	// HTTP status codes to indicate success: http.StatusOK, http.StatusAccepted
	BeginTest func(ctx context.Context, resourceGroupName string, jobName string, inputName string, options *armstreamanalytics.InputsClientBeginTestOptions) (resp azfake.PollerResponder[armstreamanalytics.InputsClientTestResponse], errResp azfake.ErrorResponder)

	// Update is the fake for method InputsClient.Update
	// HTTP status codes to indicate success: http.StatusOK
	Update func(ctx context.Context, resourceGroupName string, jobName string, inputName string, input armstreamanalytics.Input, options *armstreamanalytics.InputsClientUpdateOptions) (resp azfake.Responder[armstreamanalytics.InputsClientUpdateResponse], errResp azfake.ErrorResponder)
}

InputsServer is a fake server for instances of the armstreamanalytics.InputsClient type.

type InputsServerTransport 

type InputsServerTransport struct {
	// contains filtered or unexported fields
}

InputsServerTransport connects instances of armstreamanalytics.InputsClient to instances of InputsServer. Don't use this type directly, use NewInputsServerTransport instead.

func NewInputsServerTransport 

func NewInputsServerTransport(srv *InputsServer) *InputsServerTransport

NewInputsServerTransport creates a new instance of InputsServerTransport with the provided implementation. The returned InputsServerTransport instance is connected to an instance of armstreamanalytics.InputsClient via the azcore.ClientOptions.Transporter field in the client's constructor parameters.

func (*InputsServerTransport) Do 

func (i *InputsServerTransport) Do(req *http.Request) (*http.Response, error)

Do implements the policy.Transporter interface for InputsServerTransport.

type OperationsServer 

type OperationsServer struct {
	// NewListPager is the fake for method OperationsClient.NewListPager
	// HTTP status codes to indicate success: http.StatusOK
	NewListPager func(options *armstreamanalytics.OperationsClientListOptions) (resp azfake.PagerResponder[armstreamanalytics.OperationsClientListResponse])
}

OperationsServer is a fake server for instances of the armstreamanalytics.OperationsClient type.

type OperationsServerTransport 

type OperationsServerTransport struct {
	// contains filtered or unexported fields
}

OperationsServerTransport connects instances of armstreamanalytics.OperationsClient to instances of OperationsServer. Don't use this type directly, use NewOperationsServerTransport instead.

func NewOperationsServerTransport 

func NewOperationsServerTransport(srv *OperationsServer) *OperationsServerTransport

NewOperationsServerTransport creates a new instance of OperationsServerTransport with the provided implementation. The returned OperationsServerTransport instance is connected to an instance of armstreamanalytics.OperationsClient via the azcore.ClientOptions.Transporter field in the client's constructor parameters.

func (*OperationsServerTransport) Do 

func (o *OperationsServerTransport) Do(req *http.Request) (*http.Response, error)

Do implements the policy.Transporter interface for OperationsServerTransport.

type OutputsServer 

type OutputsServer struct {
	// CreateOrReplace is the fake for method OutputsClient.CreateOrReplace
	// HTTP status codes to indicate success: http.StatusOK, http.StatusCreated
	CreateOrReplace func(ctx context.Context, resourceGroupName string, jobName string, outputName string, output armstreamanalytics.Output, options *armstreamanalytics.OutputsClientCreateOrReplaceOptions) (resp azfake.Responder[armstreamanalytics.OutputsClientCreateOrReplaceResponse], errResp azfake.ErrorResponder)

	// Delete is the fake for method OutputsClient.Delete
	// HTTP status codes to indicate success: http.StatusOK, http.StatusNoContent
	Delete func(ctx context.Context, resourceGroupName string, jobName string, outputName string, options *armstreamanalytics.OutputsClientDeleteOptions) (resp azfake.Responder[armstreamanalytics.OutputsClientDeleteResponse], errResp azfake.ErrorResponder)

	// Get is the fake for method OutputsClient.Get
	// HTTP status codes to indicate success: http.StatusOK
	Get func(ctx context.Context, resourceGroupName string, jobName string, outputName string, options *armstreamanalytics.OutputsClientGetOptions) (resp azfake.Responder[armstreamanalytics.OutputsClientGetResponse], errResp azfake.ErrorResponder)

	// NewListByStreamingJobPager is the fake for method OutputsClient.NewListByStreamingJobPager
	// HTTP status codes to indicate success: http.StatusOK
	NewListByStreamingJobPager func(resourceGroupName string, jobName string, options *armstreamanalytics.OutputsClientListByStreamingJobOptions) (resp azfake.PagerResponder[armstreamanalytics.OutputsClientListByStreamingJobResponse])

	// BeginTest is the fake for method OutputsClient.BeginTest
	// HTTP status codes to indicate success: http.StatusOK, http.StatusAccepted
	BeginTest func(ctx context.Context, resourceGroupName string, jobName string, outputName string, options *armstreamanalytics.OutputsClientBeginTestOptions) (resp azfake.PollerResponder[armstreamanalytics.OutputsClientTestResponse], errResp azfake.ErrorResponder)

	// Update is the fake for method OutputsClient.Update
	// HTTP status codes to indicate success: http.StatusOK
	Update func(ctx context.Context, resourceGroupName string, jobName string, outputName string, output armstreamanalytics.Output, options *armstreamanalytics.OutputsClientUpdateOptions) (resp azfake.Responder[armstreamanalytics.OutputsClientUpdateResponse], errResp azfake.ErrorResponder)
}

OutputsServer is a fake server for instances of the armstreamanalytics.OutputsClient type.

type OutputsServerTransport 

type OutputsServerTransport struct {
	// contains filtered or unexported fields
}

OutputsServerTransport connects instances of armstreamanalytics.OutputsClient to instances of OutputsServer. Don't use this type directly, use NewOutputsServerTransport instead.

func NewOutputsServerTransport 

func NewOutputsServerTransport(srv *OutputsServer) *OutputsServerTransport

NewOutputsServerTransport creates a new instance of OutputsServerTransport with the provided implementation. The returned OutputsServerTransport instance is connected to an instance of armstreamanalytics.OutputsClient via the azcore.ClientOptions.Transporter field in the client's constructor parameters.

func (*OutputsServerTransport) Do 

func (o *OutputsServerTransport) Do(req *http.Request) (*http.Response, error)

Do implements the policy.Transporter interface for OutputsServerTransport.

type PrivateEndpointsServer 

type PrivateEndpointsServer struct {
	// CreateOrUpdate is the fake for method PrivateEndpointsClient.CreateOrUpdate
	// HTTP status codes to indicate success: http.StatusOK, http.StatusCreated
	CreateOrUpdate func(ctx context.Context, resourceGroupName string, clusterName string, privateEndpointName string, privateEndpoint armstreamanalytics.PrivateEndpoint, options *armstreamanalytics.PrivateEndpointsClientCreateOrUpdateOptions) (resp azfake.Responder[armstreamanalytics.PrivateEndpointsClientCreateOrUpdateResponse], errResp azfake.ErrorResponder)

	// BeginDelete is the fake for method PrivateEndpointsClient.BeginDelete
	// HTTP status codes to indicate success: http.StatusOK, http.StatusAccepted, http.StatusNoContent
	BeginDelete func(ctx context.Context, resourceGroupName string, clusterName string, privateEndpointName string, options *armstreamanalytics.PrivateEndpointsClientBeginDeleteOptions) (resp azfake.PollerResponder[armstreamanalytics.PrivateEndpointsClientDeleteResponse], errResp azfake.ErrorResponder)

	// Get is the fake for method PrivateEndpointsClient.Get
	// HTTP status codes to indicate success: http.StatusOK
	Get func(ctx context.Context, resourceGroupName string, clusterName string, privateEndpointName string, options *armstreamanalytics.PrivateEndpointsClientGetOptions) (resp azfake.Responder[armstreamanalytics.PrivateEndpointsClientGetResponse], errResp azfake.ErrorResponder)

	// NewListByClusterPager is the fake for method PrivateEndpointsClient.NewListByClusterPager
	// HTTP status codes to indicate success: http.StatusOK
	NewListByClusterPager func(resourceGroupName string, clusterName string, options *armstreamanalytics.PrivateEndpointsClientListByClusterOptions) (resp azfake.PagerResponder[armstreamanalytics.PrivateEndpointsClientListByClusterResponse])
}

PrivateEndpointsServer is a fake server for instances of the armstreamanalytics.PrivateEndpointsClient type.

type PrivateEndpointsServerTransport 

type PrivateEndpointsServerTransport struct {
	// contains filtered or unexported fields
}

PrivateEndpointsServerTransport connects instances of armstreamanalytics.PrivateEndpointsClient to instances of PrivateEndpointsServer. Don't use this type directly, use NewPrivateEndpointsServerTransport instead.

func NewPrivateEndpointsServerTransport 

func NewPrivateEndpointsServerTransport(srv *PrivateEndpointsServer) *PrivateEndpointsServerTransport

NewPrivateEndpointsServerTransport creates a new instance of PrivateEndpointsServerTransport with the provided implementation. The returned PrivateEndpointsServerTransport instance is connected to an instance of armstreamanalytics.PrivateEndpointsClient via the azcore.ClientOptions.Transporter field in the client's constructor parameters.

func (*PrivateEndpointsServerTransport) Do 

func (p *PrivateEndpointsServerTransport) Do(req *http.Request) (*http.Response, error)

Do implements the policy.Transporter interface for PrivateEndpointsServerTransport.

type SKUServer 

type SKUServer struct {
	// NewListPager is the fake for method SKUClient.NewListPager
	// HTTP status codes to indicate success: http.StatusOK
	NewListPager func(resourceGroupName string, jobName string, options *armstreamanalytics.SKUClientListOptions) (resp azfake.PagerResponder[armstreamanalytics.SKUClientListResponse])
}

SKUServer is a fake server for instances of the armstreamanalytics.SKUClient type.

type SKUServerTransport 

type SKUServerTransport struct {
	// contains filtered or unexported fields
}

SKUServerTransport connects instances of armstreamanalytics.SKUClient to instances of SKUServer. Don't use this type directly, use NewSKUServerTransport instead.

func NewSKUServerTransport 

func NewSKUServerTransport(srv *SKUServer) *SKUServerTransport

NewSKUServerTransport creates a new instance of SKUServerTransport with the provided implementation. The returned SKUServerTransport instance is connected to an instance of armstreamanalytics.SKUClient via the azcore.ClientOptions.Transporter field in the client's constructor parameters.

func (*SKUServerTransport) Do 

func (s *SKUServerTransport) Do(req *http.Request) (*http.Response, error)

Do implements the policy.Transporter interface for SKUServerTransport.

type ServerFactory 

type ServerFactory struct {
	ClustersServer         ClustersServer
	FunctionsServer        FunctionsServer
	InputsServer           InputsServer
	OperationsServer       OperationsServer
	OutputsServer          OutputsServer
	PrivateEndpointsServer PrivateEndpointsServer
	SKUServer              SKUServer
	StreamingJobsServer    StreamingJobsServer
	SubscriptionsServer    SubscriptionsServer
	TransformationsServer  TransformationsServer
}

ServerFactory is a fake server for instances of the armstreamanalytics.ClientFactory type.

type ServerFactoryTransport 

type ServerFactoryTransport struct {
	// contains filtered or unexported fields
}

ServerFactoryTransport connects instances of armstreamanalytics.ClientFactory to instances of ServerFactory. Don't use this type directly, use NewServerFactoryTransport instead.

func NewServerFactoryTransport 

func NewServerFactoryTransport(srv *ServerFactory) *ServerFactoryTransport

NewServerFactoryTransport creates a new instance of ServerFactoryTransport with the provided implementation. The returned ServerFactoryTransport instance is connected to an instance of armstreamanalytics.ClientFactory via the azcore.ClientOptions.Transporter field in the client's constructor parameters.

func (*ServerFactoryTransport) Do 

func (s *ServerFactoryTransport) Do(req *http.Request) (*http.Response, error)

Do implements the policy.Transporter interface for ServerFactoryTransport.

type StreamingJobsServer 

type StreamingJobsServer struct {
	// BeginCreateOrReplace is the fake for method StreamingJobsClient.BeginCreateOrReplace
	// HTTP status codes to indicate success: http.StatusOK, http.StatusCreated
	BeginCreateOrReplace func(ctx context.Context, resourceGroupName string, jobName string, streamingJob armstreamanalytics.StreamingJob, options *armstreamanalytics.StreamingJobsClientBeginCreateOrReplaceOptions) (resp azfake.PollerResponder[armstreamanalytics.StreamingJobsClientCreateOrReplaceResponse], errResp azfake.ErrorResponder)

	// BeginDelete is the fake for method StreamingJobsClient.BeginDelete
	// HTTP status codes to indicate success: http.StatusOK, http.StatusAccepted, http.StatusNoContent
	BeginDelete func(ctx context.Context, resourceGroupName string, jobName string, options *armstreamanalytics.StreamingJobsClientBeginDeleteOptions) (resp azfake.PollerResponder[armstreamanalytics.StreamingJobsClientDeleteResponse], errResp azfake.ErrorResponder)

	// Get is the fake for method StreamingJobsClient.Get
	// HTTP status codes to indicate success: http.StatusOK
	Get func(ctx context.Context, resourceGroupName string, jobName string, options *armstreamanalytics.StreamingJobsClientGetOptions) (resp azfake.Responder[armstreamanalytics.StreamingJobsClientGetResponse], errResp azfake.ErrorResponder)

	// NewListPager is the fake for method StreamingJobsClient.NewListPager
	// HTTP status codes to indicate success: http.StatusOK
	NewListPager func(options *armstreamanalytics.StreamingJobsClientListOptions) (resp azfake.PagerResponder[armstreamanalytics.StreamingJobsClientListResponse])

	// NewListByResourceGroupPager is the fake for method StreamingJobsClient.NewListByResourceGroupPager
	// HTTP status codes to indicate success: http.StatusOK
	NewListByResourceGroupPager func(resourceGroupName string, options *armstreamanalytics.StreamingJobsClientListByResourceGroupOptions) (resp azfake.PagerResponder[armstreamanalytics.StreamingJobsClientListByResourceGroupResponse])

	// BeginScale is the fake for method StreamingJobsClient.BeginScale
	// HTTP status codes to indicate success: http.StatusOK, http.StatusAccepted
	BeginScale func(ctx context.Context, resourceGroupName string, jobName string, options *armstreamanalytics.StreamingJobsClientBeginScaleOptions) (resp azfake.PollerResponder[armstreamanalytics.StreamingJobsClientScaleResponse], errResp azfake.ErrorResponder)

	// BeginStart is the fake for method StreamingJobsClient.BeginStart
	// HTTP status codes to indicate success: http.StatusOK, http.StatusAccepted
	BeginStart func(ctx context.Context, resourceGroupName string, jobName string, options *armstreamanalytics.StreamingJobsClientBeginStartOptions) (resp azfake.PollerResponder[armstreamanalytics.StreamingJobsClientStartResponse], errResp azfake.ErrorResponder)

	// BeginStop is the fake for method StreamingJobsClient.BeginStop
	// HTTP status codes to indicate success: http.StatusOK, http.StatusAccepted
	BeginStop func(ctx context.Context, resourceGroupName string, jobName string, options *armstreamanalytics.StreamingJobsClientBeginStopOptions) (resp azfake.PollerResponder[armstreamanalytics.StreamingJobsClientStopResponse], errResp azfake.ErrorResponder)

	// Update is the fake for method StreamingJobsClient.Update
	// HTTP status codes to indicate success: http.StatusOK
	Update func(ctx context.Context, resourceGroupName string, jobName string, streamingJob armstreamanalytics.StreamingJob, options *armstreamanalytics.StreamingJobsClientUpdateOptions) (resp azfake.Responder[armstreamanalytics.StreamingJobsClientUpdateResponse], errResp azfake.ErrorResponder)
}

StreamingJobsServer is a fake server for instances of the armstreamanalytics.StreamingJobsClient type.

type StreamingJobsServerTransport 

type StreamingJobsServerTransport struct {
	// contains filtered or unexported fields
}

StreamingJobsServerTransport connects instances of armstreamanalytics.StreamingJobsClient to instances of StreamingJobsServer. Don't use this type directly, use NewStreamingJobsServerTransport instead.

func NewStreamingJobsServerTransport 

func NewStreamingJobsServerTransport(srv *StreamingJobsServer) *StreamingJobsServerTransport

NewStreamingJobsServerTransport creates a new instance of StreamingJobsServerTransport with the provided implementation. The returned StreamingJobsServerTransport instance is connected to an instance of armstreamanalytics.StreamingJobsClient via the azcore.ClientOptions.Transporter field in the client's constructor parameters.

func (*StreamingJobsServerTransport) Do 

func (s *StreamingJobsServerTransport) Do(req *http.Request) (*http.Response, error)

Do implements the policy.Transporter interface for StreamingJobsServerTransport.

type SubscriptionsServer 

type SubscriptionsServer struct {
	// CompileQuery is the fake for method SubscriptionsClient.CompileQuery
	// HTTP status codes to indicate success: http.StatusOK
	CompileQuery func(ctx context.Context, location string, compileQuery armstreamanalytics.CompileQuery, options *armstreamanalytics.SubscriptionsClientCompileQueryOptions) (resp azfake.Responder[armstreamanalytics.SubscriptionsClientCompileQueryResponse], errResp azfake.ErrorResponder)

	// ListQuotas is the fake for method SubscriptionsClient.ListQuotas
	// HTTP status codes to indicate success: http.StatusOK
	ListQuotas func(ctx context.Context, location string, options *armstreamanalytics.SubscriptionsClientListQuotasOptions) (resp azfake.Responder[armstreamanalytics.SubscriptionsClientListQuotasResponse], errResp azfake.ErrorResponder)

	// BeginSampleInput is the fake for method SubscriptionsClient.BeginSampleInput
	// HTTP status codes to indicate success: http.StatusAccepted
	BeginSampleInput func(ctx context.Context, location string, sampleInput armstreamanalytics.SampleInput, options *armstreamanalytics.SubscriptionsClientBeginSampleInputOptions) (resp azfake.PollerResponder[armstreamanalytics.SubscriptionsClientSampleInputResponse], errResp azfake.ErrorResponder)

	// BeginTestInput is the fake for method SubscriptionsClient.BeginTestInput
	// HTTP status codes to indicate success: http.StatusAccepted
	BeginTestInput func(ctx context.Context, location string, testInput armstreamanalytics.TestInput, options *armstreamanalytics.SubscriptionsClientBeginTestInputOptions) (resp azfake.PollerResponder[armstreamanalytics.SubscriptionsClientTestInputResponse], errResp azfake.ErrorResponder)

	// BeginTestOutput is the fake for method SubscriptionsClient.BeginTestOutput
	// HTTP status codes to indicate success: http.StatusAccepted
	BeginTestOutput func(ctx context.Context, location string, testOutput armstreamanalytics.TestOutput, options *armstreamanalytics.SubscriptionsClientBeginTestOutputOptions) (resp azfake.PollerResponder[armstreamanalytics.SubscriptionsClientTestOutputResponse], errResp azfake.ErrorResponder)

	// BeginTestQuery is the fake for method SubscriptionsClient.BeginTestQuery
	// HTTP status codes to indicate success: http.StatusOK, http.StatusAccepted
	BeginTestQuery func(ctx context.Context, location string, testQuery armstreamanalytics.TestQuery, options *armstreamanalytics.SubscriptionsClientBeginTestQueryOptions) (resp azfake.PollerResponder[armstreamanalytics.SubscriptionsClientTestQueryResponse], errResp azfake.ErrorResponder)
}

SubscriptionsServer is a fake server for instances of the armstreamanalytics.SubscriptionsClient type.

type SubscriptionsServerTransport 

type SubscriptionsServerTransport struct {
	// contains filtered or unexported fields
}

SubscriptionsServerTransport connects instances of armstreamanalytics.SubscriptionsClient to instances of SubscriptionsServer. Don't use this type directly, use NewSubscriptionsServerTransport instead.

func NewSubscriptionsServerTransport 

func NewSubscriptionsServerTransport(srv *SubscriptionsServer) *SubscriptionsServerTransport

NewSubscriptionsServerTransport creates a new instance of SubscriptionsServerTransport with the provided implementation. The returned SubscriptionsServerTransport instance is connected to an instance of armstreamanalytics.SubscriptionsClient via the azcore.ClientOptions.Transporter field in the client's constructor parameters.

func (*SubscriptionsServerTransport) Do 

func (s *SubscriptionsServerTransport) Do(req *http.Request) (*http.Response, error)

Do implements the policy.Transporter interface for SubscriptionsServerTransport.

type TransformationsServer 

type TransformationsServer struct {
	// CreateOrReplace is the fake for method TransformationsClient.CreateOrReplace
	// HTTP status codes to indicate success: http.StatusOK, http.StatusCreated
	CreateOrReplace func(ctx context.Context, resourceGroupName string, jobName string, transformationName string, transformation armstreamanalytics.Transformation, options *armstreamanalytics.TransformationsClientCreateOrReplaceOptions) (resp azfake.Responder[armstreamanalytics.TransformationsClientCreateOrReplaceResponse], errResp azfake.ErrorResponder)

	// Get is the fake for method TransformationsClient.Get
	// HTTP status codes to indicate success: http.StatusOK
	Get func(ctx context.Context, resourceGroupName string, jobName string, transformationName string, options *armstreamanalytics.TransformationsClientGetOptions) (resp azfake.Responder[armstreamanalytics.TransformationsClientGetResponse], errResp azfake.ErrorResponder)

	// Update is the fake for method TransformationsClient.Update
	// HTTP status codes to indicate success: http.StatusOK
	Update func(ctx context.Context, resourceGroupName string, jobName string, transformationName string, transformation armstreamanalytics.Transformation, options *armstreamanalytics.TransformationsClientUpdateOptions) (resp azfake.Responder[armstreamanalytics.TransformationsClientUpdateResponse], errResp azfake.ErrorResponder)
}

TransformationsServer is a fake server for instances of the armstreamanalytics.TransformationsClient type.

type TransformationsServerTransport 

type TransformationsServerTransport struct {
	// contains filtered or unexported fields
}

TransformationsServerTransport connects instances of armstreamanalytics.TransformationsClient to instances of TransformationsServer. Don't use this type directly, use NewTransformationsServerTransport instead.

func NewTransformationsServerTransport 

func NewTransformationsServerTransport(srv *TransformationsServer) *TransformationsServerTransport

NewTransformationsServerTransport creates a new instance of TransformationsServerTransport with the provided implementation. The returned TransformationsServerTransport instance is connected to an instance of armstreamanalytics.TransformationsClient via the azcore.ClientOptions.Transporter field in the client's constructor parameters.

func (*TransformationsServerTransport) Do 

func (t *TransformationsServerTransport) Do(req *http.Request) (*http.Response, error)

Do implements the policy.Transporter interface for TransformationsServerTransport.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.