fake

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: Nov 27, 2023 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, http.StatusAccepted
	BeginCreateOrUpdate func(ctx context.Context, resourceGroupName string, clusterName string, parameters armeventhub.Cluster, options *armeventhub.ClustersClientBeginCreateOrUpdateOptions) (resp azfake.PollerResponder[armeventhub.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 *armeventhub.ClustersClientBeginDeleteOptions) (resp azfake.PollerResponder[armeventhub.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 *armeventhub.ClustersClientGetOptions) (resp azfake.Responder[armeventhub.ClustersClientGetResponse], errResp azfake.ErrorResponder)

	// ListAvailableClusterRegion is the fake for method ClustersClient.ListAvailableClusterRegion
	// HTTP status codes to indicate success: http.StatusOK
	ListAvailableClusterRegion func(ctx context.Context, options *armeventhub.ClustersClientListAvailableClusterRegionOptions) (resp azfake.Responder[armeventhub.ClustersClientListAvailableClusterRegionResponse], errResp azfake.ErrorResponder)

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

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

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

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

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

type ClustersServerTransport 

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

ClustersServerTransport connects instances of armeventhub.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 armeventhub.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 ConfigurationServer 

type ConfigurationServer struct {
	// Get is the fake for method ConfigurationClient.Get
	// HTTP status codes to indicate success: http.StatusOK
	Get func(ctx context.Context, resourceGroupName string, clusterName string, options *armeventhub.ConfigurationClientGetOptions) (resp azfake.Responder[armeventhub.ConfigurationClientGetResponse], errResp azfake.ErrorResponder)

	// Patch is the fake for method ConfigurationClient.Patch
	// HTTP status codes to indicate success: http.StatusOK, http.StatusCreated, http.StatusAccepted
	Patch func(ctx context.Context, resourceGroupName string, clusterName string, parameters armeventhub.ClusterQuotaConfigurationProperties, options *armeventhub.ConfigurationClientPatchOptions) (resp azfake.Responder[armeventhub.ConfigurationClientPatchResponse], errResp azfake.ErrorResponder)
}

ConfigurationServer is a fake server for instances of the armeventhub.ConfigurationClient type.

type ConfigurationServerTransport 

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

ConfigurationServerTransport connects instances of armeventhub.ConfigurationClient to instances of ConfigurationServer. Don't use this type directly, use NewConfigurationServerTransport instead.

func NewConfigurationServerTransport 

func NewConfigurationServerTransport(srv *ConfigurationServer) *ConfigurationServerTransport

NewConfigurationServerTransport creates a new instance of ConfigurationServerTransport with the provided implementation. The returned ConfigurationServerTransport instance is connected to an instance of armeventhub.ConfigurationClient via the azcore.ClientOptions.Transporter field in the client's constructor parameters.

func (*ConfigurationServerTransport) Do 

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

Do implements the policy.Transporter interface for ConfigurationServerTransport.

type ConsumerGroupsServer 

type ConsumerGroupsServer struct {
	// CreateOrUpdate is the fake for method ConsumerGroupsClient.CreateOrUpdate
	// HTTP status codes to indicate success: http.StatusOK
	CreateOrUpdate func(ctx context.Context, resourceGroupName string, namespaceName string, eventHubName string, consumerGroupName string, parameters armeventhub.ConsumerGroup, options *armeventhub.ConsumerGroupsClientCreateOrUpdateOptions) (resp azfake.Responder[armeventhub.ConsumerGroupsClientCreateOrUpdateResponse], errResp azfake.ErrorResponder)

	// Delete is the fake for method ConsumerGroupsClient.Delete
	// HTTP status codes to indicate success: http.StatusOK, http.StatusNoContent
	Delete func(ctx context.Context, resourceGroupName string, namespaceName string, eventHubName string, consumerGroupName string, options *armeventhub.ConsumerGroupsClientDeleteOptions) (resp azfake.Responder[armeventhub.ConsumerGroupsClientDeleteResponse], errResp azfake.ErrorResponder)

	// Get is the fake for method ConsumerGroupsClient.Get
	// HTTP status codes to indicate success: http.StatusOK
	Get func(ctx context.Context, resourceGroupName string, namespaceName string, eventHubName string, consumerGroupName string, options *armeventhub.ConsumerGroupsClientGetOptions) (resp azfake.Responder[armeventhub.ConsumerGroupsClientGetResponse], errResp azfake.ErrorResponder)

	// NewListByEventHubPager is the fake for method ConsumerGroupsClient.NewListByEventHubPager
	// HTTP status codes to indicate success: http.StatusOK
	NewListByEventHubPager func(resourceGroupName string, namespaceName string, eventHubName string, options *armeventhub.ConsumerGroupsClientListByEventHubOptions) (resp azfake.PagerResponder[armeventhub.ConsumerGroupsClientListByEventHubResponse])
}

ConsumerGroupsServer is a fake server for instances of the armeventhub.ConsumerGroupsClient type.

type ConsumerGroupsServerTransport 

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

ConsumerGroupsServerTransport connects instances of armeventhub.ConsumerGroupsClient to instances of ConsumerGroupsServer. Don't use this type directly, use NewConsumerGroupsServerTransport instead.

func NewConsumerGroupsServerTransport 

func NewConsumerGroupsServerTransport(srv *ConsumerGroupsServer) *ConsumerGroupsServerTransport

NewConsumerGroupsServerTransport creates a new instance of ConsumerGroupsServerTransport with the provided implementation. The returned ConsumerGroupsServerTransport instance is connected to an instance of armeventhub.ConsumerGroupsClient via the azcore.ClientOptions.Transporter field in the client's constructor parameters.

func (*ConsumerGroupsServerTransport) Do 

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

Do implements the policy.Transporter interface for ConsumerGroupsServerTransport.

type DisasterRecoveryConfigsServer 

type DisasterRecoveryConfigsServer struct {
	// BreakPairing is the fake for method DisasterRecoveryConfigsClient.BreakPairing
	// HTTP status codes to indicate success: http.StatusOK
	BreakPairing func(ctx context.Context, resourceGroupName string, namespaceName string, alias string, options *armeventhub.DisasterRecoveryConfigsClientBreakPairingOptions) (resp azfake.Responder[armeventhub.DisasterRecoveryConfigsClientBreakPairingResponse], errResp azfake.ErrorResponder)

	// CheckNameAvailability is the fake for method DisasterRecoveryConfigsClient.CheckNameAvailability
	// HTTP status codes to indicate success: http.StatusOK
	CheckNameAvailability func(ctx context.Context, resourceGroupName string, namespaceName string, parameters armeventhub.CheckNameAvailabilityParameter, options *armeventhub.DisasterRecoveryConfigsClientCheckNameAvailabilityOptions) (resp azfake.Responder[armeventhub.DisasterRecoveryConfigsClientCheckNameAvailabilityResponse], errResp azfake.ErrorResponder)

	// CreateOrUpdate is the fake for method DisasterRecoveryConfigsClient.CreateOrUpdate
	// HTTP status codes to indicate success: http.StatusOK, http.StatusCreated
	CreateOrUpdate func(ctx context.Context, resourceGroupName string, namespaceName string, alias string, parameters armeventhub.ArmDisasterRecovery, options *armeventhub.DisasterRecoveryConfigsClientCreateOrUpdateOptions) (resp azfake.Responder[armeventhub.DisasterRecoveryConfigsClientCreateOrUpdateResponse], errResp azfake.ErrorResponder)

	// Delete is the fake for method DisasterRecoveryConfigsClient.Delete
	// HTTP status codes to indicate success: http.StatusOK, http.StatusNoContent
	Delete func(ctx context.Context, resourceGroupName string, namespaceName string, alias string, options *armeventhub.DisasterRecoveryConfigsClientDeleteOptions) (resp azfake.Responder[armeventhub.DisasterRecoveryConfigsClientDeleteResponse], errResp azfake.ErrorResponder)

	// FailOver is the fake for method DisasterRecoveryConfigsClient.FailOver
	// HTTP status codes to indicate success: http.StatusOK
	FailOver func(ctx context.Context, resourceGroupName string, namespaceName string, alias string, options *armeventhub.DisasterRecoveryConfigsClientFailOverOptions) (resp azfake.Responder[armeventhub.DisasterRecoveryConfigsClientFailOverResponse], errResp azfake.ErrorResponder)

	// Get is the fake for method DisasterRecoveryConfigsClient.Get
	// HTTP status codes to indicate success: http.StatusOK
	Get func(ctx context.Context, resourceGroupName string, namespaceName string, alias string, options *armeventhub.DisasterRecoveryConfigsClientGetOptions) (resp azfake.Responder[armeventhub.DisasterRecoveryConfigsClientGetResponse], errResp azfake.ErrorResponder)

	// GetAuthorizationRule is the fake for method DisasterRecoveryConfigsClient.GetAuthorizationRule
	// HTTP status codes to indicate success: http.StatusOK
	GetAuthorizationRule func(ctx context.Context, resourceGroupName string, namespaceName string, alias string, authorizationRuleName string, options *armeventhub.DisasterRecoveryConfigsClientGetAuthorizationRuleOptions) (resp azfake.Responder[armeventhub.DisasterRecoveryConfigsClientGetAuthorizationRuleResponse], errResp azfake.ErrorResponder)

	// NewListPager is the fake for method DisasterRecoveryConfigsClient.NewListPager
	// HTTP status codes to indicate success: http.StatusOK
	NewListPager func(resourceGroupName string, namespaceName string, options *armeventhub.DisasterRecoveryConfigsClientListOptions) (resp azfake.PagerResponder[armeventhub.DisasterRecoveryConfigsClientListResponse])

	// NewListAuthorizationRulesPager is the fake for method DisasterRecoveryConfigsClient.NewListAuthorizationRulesPager
	// HTTP status codes to indicate success: http.StatusOK
	NewListAuthorizationRulesPager func(resourceGroupName string, namespaceName string, alias string, options *armeventhub.DisasterRecoveryConfigsClientListAuthorizationRulesOptions) (resp azfake.PagerResponder[armeventhub.DisasterRecoveryConfigsClientListAuthorizationRulesResponse])

	// ListKeys is the fake for method DisasterRecoveryConfigsClient.ListKeys
	// HTTP status codes to indicate success: http.StatusOK
	ListKeys func(ctx context.Context, resourceGroupName string, namespaceName string, alias string, authorizationRuleName string, options *armeventhub.DisasterRecoveryConfigsClientListKeysOptions) (resp azfake.Responder[armeventhub.DisasterRecoveryConfigsClientListKeysResponse], errResp azfake.ErrorResponder)
}

DisasterRecoveryConfigsServer is a fake server for instances of the armeventhub.DisasterRecoveryConfigsClient type.

type DisasterRecoveryConfigsServerTransport 

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

DisasterRecoveryConfigsServerTransport connects instances of armeventhub.DisasterRecoveryConfigsClient to instances of DisasterRecoveryConfigsServer. Don't use this type directly, use NewDisasterRecoveryConfigsServerTransport instead.

func NewDisasterRecoveryConfigsServerTransport 

func NewDisasterRecoveryConfigsServerTransport(srv *DisasterRecoveryConfigsServer) *DisasterRecoveryConfigsServerTransport

NewDisasterRecoveryConfigsServerTransport creates a new instance of DisasterRecoveryConfigsServerTransport with the provided implementation. The returned DisasterRecoveryConfigsServerTransport instance is connected to an instance of armeventhub.DisasterRecoveryConfigsClient via the azcore.ClientOptions.Transporter field in the client's constructor parameters.

func (*DisasterRecoveryConfigsServerTransport) Do 

func (d *DisasterRecoveryConfigsServerTransport) Do(req *http.Request) (*http.Response, error)

Do implements the policy.Transporter interface for DisasterRecoveryConfigsServerTransport.

type EventHubsServer 

type EventHubsServer struct {
	// CreateOrUpdate is the fake for method EventHubsClient.CreateOrUpdate
	// HTTP status codes to indicate success: http.StatusOK
	CreateOrUpdate func(ctx context.Context, resourceGroupName string, namespaceName string, eventHubName string, parameters armeventhub.Eventhub, options *armeventhub.EventHubsClientCreateOrUpdateOptions) (resp azfake.Responder[armeventhub.EventHubsClientCreateOrUpdateResponse], errResp azfake.ErrorResponder)

	// CreateOrUpdateAuthorizationRule is the fake for method EventHubsClient.CreateOrUpdateAuthorizationRule
	// HTTP status codes to indicate success: http.StatusOK
	CreateOrUpdateAuthorizationRule func(ctx context.Context, resourceGroupName string, namespaceName string, eventHubName string, authorizationRuleName string, parameters armeventhub.AuthorizationRule, options *armeventhub.EventHubsClientCreateOrUpdateAuthorizationRuleOptions) (resp azfake.Responder[armeventhub.EventHubsClientCreateOrUpdateAuthorizationRuleResponse], errResp azfake.ErrorResponder)

	// Delete is the fake for method EventHubsClient.Delete
	// HTTP status codes to indicate success: http.StatusOK, http.StatusNoContent
	Delete func(ctx context.Context, resourceGroupName string, namespaceName string, eventHubName string, options *armeventhub.EventHubsClientDeleteOptions) (resp azfake.Responder[armeventhub.EventHubsClientDeleteResponse], errResp azfake.ErrorResponder)

	// DeleteAuthorizationRule is the fake for method EventHubsClient.DeleteAuthorizationRule
	// HTTP status codes to indicate success: http.StatusOK, http.StatusNoContent
	DeleteAuthorizationRule func(ctx context.Context, resourceGroupName string, namespaceName string, eventHubName string, authorizationRuleName string, options *armeventhub.EventHubsClientDeleteAuthorizationRuleOptions) (resp azfake.Responder[armeventhub.EventHubsClientDeleteAuthorizationRuleResponse], errResp azfake.ErrorResponder)

	// Get is the fake for method EventHubsClient.Get
	// HTTP status codes to indicate success: http.StatusOK
	Get func(ctx context.Context, resourceGroupName string, namespaceName string, eventHubName string, options *armeventhub.EventHubsClientGetOptions) (resp azfake.Responder[armeventhub.EventHubsClientGetResponse], errResp azfake.ErrorResponder)

	// GetAuthorizationRule is the fake for method EventHubsClient.GetAuthorizationRule
	// HTTP status codes to indicate success: http.StatusOK
	GetAuthorizationRule func(ctx context.Context, resourceGroupName string, namespaceName string, eventHubName string, authorizationRuleName string, options *armeventhub.EventHubsClientGetAuthorizationRuleOptions) (resp azfake.Responder[armeventhub.EventHubsClientGetAuthorizationRuleResponse], errResp azfake.ErrorResponder)

	// NewListAuthorizationRulesPager is the fake for method EventHubsClient.NewListAuthorizationRulesPager
	// HTTP status codes to indicate success: http.StatusOK
	NewListAuthorizationRulesPager func(resourceGroupName string, namespaceName string, eventHubName string, options *armeventhub.EventHubsClientListAuthorizationRulesOptions) (resp azfake.PagerResponder[armeventhub.EventHubsClientListAuthorizationRulesResponse])

	// NewListByNamespacePager is the fake for method EventHubsClient.NewListByNamespacePager
	// HTTP status codes to indicate success: http.StatusOK
	NewListByNamespacePager func(resourceGroupName string, namespaceName string, options *armeventhub.EventHubsClientListByNamespaceOptions) (resp azfake.PagerResponder[armeventhub.EventHubsClientListByNamespaceResponse])

	// ListKeys is the fake for method EventHubsClient.ListKeys
	// HTTP status codes to indicate success: http.StatusOK
	ListKeys func(ctx context.Context, resourceGroupName string, namespaceName string, eventHubName string, authorizationRuleName string, options *armeventhub.EventHubsClientListKeysOptions) (resp azfake.Responder[armeventhub.EventHubsClientListKeysResponse], errResp azfake.ErrorResponder)

	// RegenerateKeys is the fake for method EventHubsClient.RegenerateKeys
	// HTTP status codes to indicate success: http.StatusOK
	RegenerateKeys func(ctx context.Context, resourceGroupName string, namespaceName string, eventHubName string, authorizationRuleName string, parameters armeventhub.RegenerateAccessKeyParameters, options *armeventhub.EventHubsClientRegenerateKeysOptions) (resp azfake.Responder[armeventhub.EventHubsClientRegenerateKeysResponse], errResp azfake.ErrorResponder)
}

EventHubsServer is a fake server for instances of the armeventhub.EventHubsClient type.

type EventHubsServerTransport 

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

EventHubsServerTransport connects instances of armeventhub.EventHubsClient to instances of EventHubsServer. Don't use this type directly, use NewEventHubsServerTransport instead.

func NewEventHubsServerTransport 

func NewEventHubsServerTransport(srv *EventHubsServer) *EventHubsServerTransport

NewEventHubsServerTransport creates a new instance of EventHubsServerTransport with the provided implementation. The returned EventHubsServerTransport instance is connected to an instance of armeventhub.EventHubsClient via the azcore.ClientOptions.Transporter field in the client's constructor parameters.

func (*EventHubsServerTransport) Do 

func (e *EventHubsServerTransport) Do(req *http.Request) (*http.Response, error)

Do implements the policy.Transporter interface for EventHubsServerTransport.

type NamespacesServer 

type NamespacesServer struct {
	// CheckNameAvailability is the fake for method NamespacesClient.CheckNameAvailability
	// HTTP status codes to indicate success: http.StatusOK
	CheckNameAvailability func(ctx context.Context, parameters armeventhub.CheckNameAvailabilityParameter, options *armeventhub.NamespacesClientCheckNameAvailabilityOptions) (resp azfake.Responder[armeventhub.NamespacesClientCheckNameAvailabilityResponse], errResp azfake.ErrorResponder)

	// BeginCreateOrUpdate is the fake for method NamespacesClient.BeginCreateOrUpdate
	// HTTP status codes to indicate success: http.StatusOK, http.StatusCreated, http.StatusAccepted
	BeginCreateOrUpdate func(ctx context.Context, resourceGroupName string, namespaceName string, parameters armeventhub.EHNamespace, options *armeventhub.NamespacesClientBeginCreateOrUpdateOptions) (resp azfake.PollerResponder[armeventhub.NamespacesClientCreateOrUpdateResponse], errResp azfake.ErrorResponder)

	// CreateOrUpdateAuthorizationRule is the fake for method NamespacesClient.CreateOrUpdateAuthorizationRule
	// HTTP status codes to indicate success: http.StatusOK
	CreateOrUpdateAuthorizationRule func(ctx context.Context, resourceGroupName string, namespaceName string, authorizationRuleName string, parameters armeventhub.AuthorizationRule, options *armeventhub.NamespacesClientCreateOrUpdateAuthorizationRuleOptions) (resp azfake.Responder[armeventhub.NamespacesClientCreateOrUpdateAuthorizationRuleResponse], errResp azfake.ErrorResponder)

	// CreateOrUpdateNetworkRuleSet is the fake for method NamespacesClient.CreateOrUpdateNetworkRuleSet
	// HTTP status codes to indicate success: http.StatusOK
	CreateOrUpdateNetworkRuleSet func(ctx context.Context, resourceGroupName string, namespaceName string, parameters armeventhub.NetworkRuleSet, options *armeventhub.NamespacesClientCreateOrUpdateNetworkRuleSetOptions) (resp azfake.Responder[armeventhub.NamespacesClientCreateOrUpdateNetworkRuleSetResponse], errResp azfake.ErrorResponder)

	// BeginDelete is the fake for method NamespacesClient.BeginDelete
	// HTTP status codes to indicate success: http.StatusOK, http.StatusAccepted, http.StatusNoContent
	BeginDelete func(ctx context.Context, resourceGroupName string, namespaceName string, options *armeventhub.NamespacesClientBeginDeleteOptions) (resp azfake.PollerResponder[armeventhub.NamespacesClientDeleteResponse], errResp azfake.ErrorResponder)

	// DeleteAuthorizationRule is the fake for method NamespacesClient.DeleteAuthorizationRule
	// HTTP status codes to indicate success: http.StatusOK, http.StatusNoContent
	DeleteAuthorizationRule func(ctx context.Context, resourceGroupName string, namespaceName string, authorizationRuleName string, options *armeventhub.NamespacesClientDeleteAuthorizationRuleOptions) (resp azfake.Responder[armeventhub.NamespacesClientDeleteAuthorizationRuleResponse], errResp azfake.ErrorResponder)

	// Get is the fake for method NamespacesClient.Get
	// HTTP status codes to indicate success: http.StatusOK
	Get func(ctx context.Context, resourceGroupName string, namespaceName string, options *armeventhub.NamespacesClientGetOptions) (resp azfake.Responder[armeventhub.NamespacesClientGetResponse], errResp azfake.ErrorResponder)

	// GetAuthorizationRule is the fake for method NamespacesClient.GetAuthorizationRule
	// HTTP status codes to indicate success: http.StatusOK
	GetAuthorizationRule func(ctx context.Context, resourceGroupName string, namespaceName string, authorizationRuleName string, options *armeventhub.NamespacesClientGetAuthorizationRuleOptions) (resp azfake.Responder[armeventhub.NamespacesClientGetAuthorizationRuleResponse], errResp azfake.ErrorResponder)

	// GetNetworkRuleSet is the fake for method NamespacesClient.GetNetworkRuleSet
	// HTTP status codes to indicate success: http.StatusOK
	GetNetworkRuleSet func(ctx context.Context, resourceGroupName string, namespaceName string, options *armeventhub.NamespacesClientGetNetworkRuleSetOptions) (resp azfake.Responder[armeventhub.NamespacesClientGetNetworkRuleSetResponse], errResp azfake.ErrorResponder)

	// NewListPager is the fake for method NamespacesClient.NewListPager
	// HTTP status codes to indicate success: http.StatusOK
	NewListPager func(options *armeventhub.NamespacesClientListOptions) (resp azfake.PagerResponder[armeventhub.NamespacesClientListResponse])

	// NewListAuthorizationRulesPager is the fake for method NamespacesClient.NewListAuthorizationRulesPager
	// HTTP status codes to indicate success: http.StatusOK
	NewListAuthorizationRulesPager func(resourceGroupName string, namespaceName string, options *armeventhub.NamespacesClientListAuthorizationRulesOptions) (resp azfake.PagerResponder[armeventhub.NamespacesClientListAuthorizationRulesResponse])

	// NewListByResourceGroupPager is the fake for method NamespacesClient.NewListByResourceGroupPager
	// HTTP status codes to indicate success: http.StatusOK
	NewListByResourceGroupPager func(resourceGroupName string, options *armeventhub.NamespacesClientListByResourceGroupOptions) (resp azfake.PagerResponder[armeventhub.NamespacesClientListByResourceGroupResponse])

	// ListKeys is the fake for method NamespacesClient.ListKeys
	// HTTP status codes to indicate success: http.StatusOK
	ListKeys func(ctx context.Context, resourceGroupName string, namespaceName string, authorizationRuleName string, options *armeventhub.NamespacesClientListKeysOptions) (resp azfake.Responder[armeventhub.NamespacesClientListKeysResponse], errResp azfake.ErrorResponder)

	// ListNetworkRuleSet is the fake for method NamespacesClient.ListNetworkRuleSet
	// HTTP status codes to indicate success: http.StatusOK
	ListNetworkRuleSet func(ctx context.Context, resourceGroupName string, namespaceName string, options *armeventhub.NamespacesClientListNetworkRuleSetOptions) (resp azfake.Responder[armeventhub.NamespacesClientListNetworkRuleSetResponse], errResp azfake.ErrorResponder)

	// RegenerateKeys is the fake for method NamespacesClient.RegenerateKeys
	// HTTP status codes to indicate success: http.StatusOK
	RegenerateKeys func(ctx context.Context, resourceGroupName string, namespaceName string, authorizationRuleName string, parameters armeventhub.RegenerateAccessKeyParameters, options *armeventhub.NamespacesClientRegenerateKeysOptions) (resp azfake.Responder[armeventhub.NamespacesClientRegenerateKeysResponse], errResp azfake.ErrorResponder)

	// Update is the fake for method NamespacesClient.Update
	// HTTP status codes to indicate success: http.StatusOK, http.StatusCreated, http.StatusAccepted
	Update func(ctx context.Context, resourceGroupName string, namespaceName string, parameters armeventhub.EHNamespace, options *armeventhub.NamespacesClientUpdateOptions) (resp azfake.Responder[armeventhub.NamespacesClientUpdateResponse], errResp azfake.ErrorResponder)
}

NamespacesServer is a fake server for instances of the armeventhub.NamespacesClient type.

type NamespacesServerTransport 

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

NamespacesServerTransport connects instances of armeventhub.NamespacesClient to instances of NamespacesServer. Don't use this type directly, use NewNamespacesServerTransport instead.

func NewNamespacesServerTransport 

func NewNamespacesServerTransport(srv *NamespacesServer) *NamespacesServerTransport

NewNamespacesServerTransport creates a new instance of NamespacesServerTransport with the provided implementation. The returned NamespacesServerTransport instance is connected to an instance of armeventhub.NamespacesClient via the azcore.ClientOptions.Transporter field in the client's constructor parameters.

func (*NamespacesServerTransport) Do 

func (n *NamespacesServerTransport) Do(req *http.Request) (*http.Response, error)

Do implements the policy.Transporter interface for NamespacesServerTransport.

type OperationsServer 

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

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

type OperationsServerTransport 

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

OperationsServerTransport connects instances of armeventhub.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 armeventhub.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 PrivateEndpointConnectionsServer 

type PrivateEndpointConnectionsServer struct {
	// CreateOrUpdate is the fake for method PrivateEndpointConnectionsClient.CreateOrUpdate
	// HTTP status codes to indicate success: http.StatusOK, http.StatusCreated
	CreateOrUpdate func(ctx context.Context, resourceGroupName string, namespaceName string, privateEndpointConnectionName string, parameters armeventhub.PrivateEndpointConnection, options *armeventhub.PrivateEndpointConnectionsClientCreateOrUpdateOptions) (resp azfake.Responder[armeventhub.PrivateEndpointConnectionsClientCreateOrUpdateResponse], errResp azfake.ErrorResponder)

	// BeginDelete is the fake for method PrivateEndpointConnectionsClient.BeginDelete
	// HTTP status codes to indicate success: http.StatusOK, http.StatusAccepted, http.StatusNoContent
	BeginDelete func(ctx context.Context, resourceGroupName string, namespaceName string, privateEndpointConnectionName string, options *armeventhub.PrivateEndpointConnectionsClientBeginDeleteOptions) (resp azfake.PollerResponder[armeventhub.PrivateEndpointConnectionsClientDeleteResponse], errResp azfake.ErrorResponder)

	// Get is the fake for method PrivateEndpointConnectionsClient.Get
	// HTTP status codes to indicate success: http.StatusOK
	Get func(ctx context.Context, resourceGroupName string, namespaceName string, privateEndpointConnectionName string, options *armeventhub.PrivateEndpointConnectionsClientGetOptions) (resp azfake.Responder[armeventhub.PrivateEndpointConnectionsClientGetResponse], errResp azfake.ErrorResponder)

	// NewListPager is the fake for method PrivateEndpointConnectionsClient.NewListPager
	// HTTP status codes to indicate success: http.StatusOK
	NewListPager func(resourceGroupName string, namespaceName string, options *armeventhub.PrivateEndpointConnectionsClientListOptions) (resp azfake.PagerResponder[armeventhub.PrivateEndpointConnectionsClientListResponse])
}

PrivateEndpointConnectionsServer is a fake server for instances of the armeventhub.PrivateEndpointConnectionsClient type.

type PrivateEndpointConnectionsServerTransport 

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

PrivateEndpointConnectionsServerTransport connects instances of armeventhub.PrivateEndpointConnectionsClient to instances of PrivateEndpointConnectionsServer. Don't use this type directly, use NewPrivateEndpointConnectionsServerTransport instead.

func NewPrivateEndpointConnectionsServerTransport 

func NewPrivateEndpointConnectionsServerTransport(srv *PrivateEndpointConnectionsServer) *PrivateEndpointConnectionsServerTransport

NewPrivateEndpointConnectionsServerTransport creates a new instance of PrivateEndpointConnectionsServerTransport with the provided implementation. The returned PrivateEndpointConnectionsServerTransport instance is connected to an instance of armeventhub.PrivateEndpointConnectionsClient via the azcore.ClientOptions.Transporter field in the client's constructor parameters.

func (*PrivateEndpointConnectionsServerTransport) Do 

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

Do implements the policy.Transporter interface for PrivateEndpointConnectionsServerTransport.

type PrivateLinkResourcesServer 

type PrivateLinkResourcesServer struct {
	// Get is the fake for method PrivateLinkResourcesClient.Get
	// HTTP status codes to indicate success: http.StatusOK
	Get func(ctx context.Context, resourceGroupName string, namespaceName string, options *armeventhub.PrivateLinkResourcesClientGetOptions) (resp azfake.Responder[armeventhub.PrivateLinkResourcesClientGetResponse], errResp azfake.ErrorResponder)
}

PrivateLinkResourcesServer is a fake server for instances of the armeventhub.PrivateLinkResourcesClient type.

type PrivateLinkResourcesServerTransport 

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

PrivateLinkResourcesServerTransport connects instances of armeventhub.PrivateLinkResourcesClient to instances of PrivateLinkResourcesServer. Don't use this type directly, use NewPrivateLinkResourcesServerTransport instead.

func NewPrivateLinkResourcesServerTransport 

func NewPrivateLinkResourcesServerTransport(srv *PrivateLinkResourcesServer) *PrivateLinkResourcesServerTransport

NewPrivateLinkResourcesServerTransport creates a new instance of PrivateLinkResourcesServerTransport with the provided implementation. The returned PrivateLinkResourcesServerTransport instance is connected to an instance of armeventhub.PrivateLinkResourcesClient via the azcore.ClientOptions.Transporter field in the client's constructor parameters.

func (*PrivateLinkResourcesServerTransport) Do 

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

Do implements the policy.Transporter interface for PrivateLinkResourcesServerTransport.

type SchemaRegistryServer 

type SchemaRegistryServer struct {
	// CreateOrUpdate is the fake for method SchemaRegistryClient.CreateOrUpdate
	// HTTP status codes to indicate success: http.StatusOK
	CreateOrUpdate func(ctx context.Context, resourceGroupName string, namespaceName string, schemaGroupName string, parameters armeventhub.SchemaGroup, options *armeventhub.SchemaRegistryClientCreateOrUpdateOptions) (resp azfake.Responder[armeventhub.SchemaRegistryClientCreateOrUpdateResponse], errResp azfake.ErrorResponder)

	// Delete is the fake for method SchemaRegistryClient.Delete
	// HTTP status codes to indicate success: http.StatusOK, http.StatusNoContent
	Delete func(ctx context.Context, resourceGroupName string, namespaceName string, schemaGroupName string, options *armeventhub.SchemaRegistryClientDeleteOptions) (resp azfake.Responder[armeventhub.SchemaRegistryClientDeleteResponse], errResp azfake.ErrorResponder)

	// Get is the fake for method SchemaRegistryClient.Get
	// HTTP status codes to indicate success: http.StatusOK
	Get func(ctx context.Context, resourceGroupName string, namespaceName string, schemaGroupName string, options *armeventhub.SchemaRegistryClientGetOptions) (resp azfake.Responder[armeventhub.SchemaRegistryClientGetResponse], errResp azfake.ErrorResponder)

	// NewListByNamespacePager is the fake for method SchemaRegistryClient.NewListByNamespacePager
	// HTTP status codes to indicate success: http.StatusOK
	NewListByNamespacePager func(resourceGroupName string, namespaceName string, options *armeventhub.SchemaRegistryClientListByNamespaceOptions) (resp azfake.PagerResponder[armeventhub.SchemaRegistryClientListByNamespaceResponse])
}

SchemaRegistryServer is a fake server for instances of the armeventhub.SchemaRegistryClient type.

type SchemaRegistryServerTransport 

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

SchemaRegistryServerTransport connects instances of armeventhub.SchemaRegistryClient to instances of SchemaRegistryServer. Don't use this type directly, use NewSchemaRegistryServerTransport instead.

func NewSchemaRegistryServerTransport 

func NewSchemaRegistryServerTransport(srv *SchemaRegistryServer) *SchemaRegistryServerTransport

NewSchemaRegistryServerTransport creates a new instance of SchemaRegistryServerTransport with the provided implementation. The returned SchemaRegistryServerTransport instance is connected to an instance of armeventhub.SchemaRegistryClient via the azcore.ClientOptions.Transporter field in the client's constructor parameters.

func (*SchemaRegistryServerTransport) Do 

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

Do implements the policy.Transporter interface for SchemaRegistryServerTransport.

type ServerFactory 

type ServerFactory struct {
	ClustersServer                   ClustersServer
	ConfigurationServer              ConfigurationServer
	ConsumerGroupsServer             ConsumerGroupsServer
	DisasterRecoveryConfigsServer    DisasterRecoveryConfigsServer
	EventHubsServer                  EventHubsServer
	NamespacesServer                 NamespacesServer
	OperationsServer                 OperationsServer
	PrivateEndpointConnectionsServer PrivateEndpointConnectionsServer
	PrivateLinkResourcesServer       PrivateLinkResourcesServer
	SchemaRegistryServer             SchemaRegistryServer
}

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

type ServerFactoryTransport 

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

ServerFactoryTransport connects instances of armeventhub.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 armeventhub.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.

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.