fake

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: Nov 24, 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 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 *armservicebus.DisasterRecoveryConfigsClientBreakPairingOptions) (resp azfake.Responder[armservicebus.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 armservicebus.CheckNameAvailability, options *armservicebus.DisasterRecoveryConfigsClientCheckNameAvailabilityOptions) (resp azfake.Responder[armservicebus.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 armservicebus.ArmDisasterRecovery, options *armservicebus.DisasterRecoveryConfigsClientCreateOrUpdateOptions) (resp azfake.Responder[armservicebus.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 *armservicebus.DisasterRecoveryConfigsClientDeleteOptions) (resp azfake.Responder[armservicebus.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 *armservicebus.DisasterRecoveryConfigsClientFailOverOptions) (resp azfake.Responder[armservicebus.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 *armservicebus.DisasterRecoveryConfigsClientGetOptions) (resp azfake.Responder[armservicebus.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 *armservicebus.DisasterRecoveryConfigsClientGetAuthorizationRuleOptions) (resp azfake.Responder[armservicebus.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 *armservicebus.DisasterRecoveryConfigsClientListOptions) (resp azfake.PagerResponder[armservicebus.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 *armservicebus.DisasterRecoveryConfigsClientListAuthorizationRulesOptions) (resp azfake.PagerResponder[armservicebus.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 *armservicebus.DisasterRecoveryConfigsClientListKeysOptions) (resp azfake.Responder[armservicebus.DisasterRecoveryConfigsClientListKeysResponse], errResp azfake.ErrorResponder)
}

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

type DisasterRecoveryConfigsServerTransport 

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

DisasterRecoveryConfigsServerTransport connects instances of armservicebus.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 armservicebus.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 MigrationConfigsServer 

type MigrationConfigsServer struct {
	// CompleteMigration is the fake for method MigrationConfigsClient.CompleteMigration
	// HTTP status codes to indicate success: http.StatusOK
	CompleteMigration func(ctx context.Context, resourceGroupName string, namespaceName string, configName armservicebus.MigrationConfigurationName, options *armservicebus.MigrationConfigsClientCompleteMigrationOptions) (resp azfake.Responder[armservicebus.MigrationConfigsClientCompleteMigrationResponse], errResp azfake.ErrorResponder)

	// BeginCreateAndStartMigration is the fake for method MigrationConfigsClient.BeginCreateAndStartMigration
	// HTTP status codes to indicate success: http.StatusOK, http.StatusCreated
	BeginCreateAndStartMigration func(ctx context.Context, resourceGroupName string, namespaceName string, configName armservicebus.MigrationConfigurationName, parameters armservicebus.MigrationConfigProperties, options *armservicebus.MigrationConfigsClientBeginCreateAndStartMigrationOptions) (resp azfake.PollerResponder[armservicebus.MigrationConfigsClientCreateAndStartMigrationResponse], errResp azfake.ErrorResponder)

	// Delete is the fake for method MigrationConfigsClient.Delete
	// HTTP status codes to indicate success: http.StatusOK, http.StatusNoContent
	Delete func(ctx context.Context, resourceGroupName string, namespaceName string, configName armservicebus.MigrationConfigurationName, options *armservicebus.MigrationConfigsClientDeleteOptions) (resp azfake.Responder[armservicebus.MigrationConfigsClientDeleteResponse], errResp azfake.ErrorResponder)

	// Get is the fake for method MigrationConfigsClient.Get
	// HTTP status codes to indicate success: http.StatusOK
	Get func(ctx context.Context, resourceGroupName string, namespaceName string, configName armservicebus.MigrationConfigurationName, options *armservicebus.MigrationConfigsClientGetOptions) (resp azfake.Responder[armservicebus.MigrationConfigsClientGetResponse], errResp azfake.ErrorResponder)

	// NewListPager is the fake for method MigrationConfigsClient.NewListPager
	// HTTP status codes to indicate success: http.StatusOK
	NewListPager func(resourceGroupName string, namespaceName string, options *armservicebus.MigrationConfigsClientListOptions) (resp azfake.PagerResponder[armservicebus.MigrationConfigsClientListResponse])

	// Revert is the fake for method MigrationConfigsClient.Revert
	// HTTP status codes to indicate success: http.StatusOK
	Revert func(ctx context.Context, resourceGroupName string, namespaceName string, configName armservicebus.MigrationConfigurationName, options *armservicebus.MigrationConfigsClientRevertOptions) (resp azfake.Responder[armservicebus.MigrationConfigsClientRevertResponse], errResp azfake.ErrorResponder)
}

MigrationConfigsServer is a fake server for instances of the armservicebus.MigrationConfigsClient type.

type MigrationConfigsServerTransport 

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

MigrationConfigsServerTransport connects instances of armservicebus.MigrationConfigsClient to instances of MigrationConfigsServer. Don't use this type directly, use NewMigrationConfigsServerTransport instead.

func NewMigrationConfigsServerTransport 

func NewMigrationConfigsServerTransport(srv *MigrationConfigsServer) *MigrationConfigsServerTransport

NewMigrationConfigsServerTransport creates a new instance of MigrationConfigsServerTransport with the provided implementation. The returned MigrationConfigsServerTransport instance is connected to an instance of armservicebus.MigrationConfigsClient via the azcore.ClientOptions.Transporter field in the client's constructor parameters.

func (*MigrationConfigsServerTransport) Do 

func (m *MigrationConfigsServerTransport) Do(req *http.Request) (*http.Response, error)

Do implements the policy.Transporter interface for MigrationConfigsServerTransport.

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 armservicebus.CheckNameAvailability, options *armservicebus.NamespacesClientCheckNameAvailabilityOptions) (resp azfake.Responder[armservicebus.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 armservicebus.SBNamespace, options *armservicebus.NamespacesClientBeginCreateOrUpdateOptions) (resp azfake.PollerResponder[armservicebus.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 armservicebus.SBAuthorizationRule, options *armservicebus.NamespacesClientCreateOrUpdateAuthorizationRuleOptions) (resp azfake.Responder[armservicebus.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 armservicebus.NetworkRuleSet, options *armservicebus.NamespacesClientCreateOrUpdateNetworkRuleSetOptions) (resp azfake.Responder[armservicebus.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 *armservicebus.NamespacesClientBeginDeleteOptions) (resp azfake.PollerResponder[armservicebus.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 *armservicebus.NamespacesClientDeleteAuthorizationRuleOptions) (resp azfake.Responder[armservicebus.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 *armservicebus.NamespacesClientGetOptions) (resp azfake.Responder[armservicebus.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 *armservicebus.NamespacesClientGetAuthorizationRuleOptions) (resp azfake.Responder[armservicebus.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 *armservicebus.NamespacesClientGetNetworkRuleSetOptions) (resp azfake.Responder[armservicebus.NamespacesClientGetNetworkRuleSetResponse], errResp azfake.ErrorResponder)

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

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

	// NewListByResourceGroupPager is the fake for method NamespacesClient.NewListByResourceGroupPager
	// HTTP status codes to indicate success: http.StatusOK
	NewListByResourceGroupPager func(resourceGroupName string, options *armservicebus.NamespacesClientListByResourceGroupOptions) (resp azfake.PagerResponder[armservicebus.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 *armservicebus.NamespacesClientListKeysOptions) (resp azfake.Responder[armservicebus.NamespacesClientListKeysResponse], errResp azfake.ErrorResponder)

	// NewListNetworkRuleSetsPager is the fake for method NamespacesClient.NewListNetworkRuleSetsPager
	// HTTP status codes to indicate success: http.StatusOK
	NewListNetworkRuleSetsPager func(resourceGroupName string, namespaceName string, options *armservicebus.NamespacesClientListNetworkRuleSetsOptions) (resp azfake.PagerResponder[armservicebus.NamespacesClientListNetworkRuleSetsResponse])

	// 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 armservicebus.RegenerateAccessKeyParameters, options *armservicebus.NamespacesClientRegenerateKeysOptions) (resp azfake.Responder[armservicebus.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 armservicebus.SBNamespaceUpdateParameters, options *armservicebus.NamespacesClientUpdateOptions) (resp azfake.Responder[armservicebus.NamespacesClientUpdateResponse], errResp azfake.ErrorResponder)
}

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

type NamespacesServerTransport 

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

NamespacesServerTransport connects instances of armservicebus.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 armservicebus.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 *armservicebus.OperationsClientListOptions) (resp azfake.PagerResponder[armservicebus.OperationsClientListResponse])
}

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

type OperationsServerTransport 

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

OperationsServerTransport connects instances of armservicebus.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 armservicebus.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 armservicebus.PrivateEndpointConnection, options *armservicebus.PrivateEndpointConnectionsClientCreateOrUpdateOptions) (resp azfake.Responder[armservicebus.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 *armservicebus.PrivateEndpointConnectionsClientBeginDeleteOptions) (resp azfake.PollerResponder[armservicebus.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 *armservicebus.PrivateEndpointConnectionsClientGetOptions) (resp azfake.Responder[armservicebus.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 *armservicebus.PrivateEndpointConnectionsClientListOptions) (resp azfake.PagerResponder[armservicebus.PrivateEndpointConnectionsClientListResponse])
}

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

type PrivateEndpointConnectionsServerTransport 

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

PrivateEndpointConnectionsServerTransport connects instances of armservicebus.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 armservicebus.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 *armservicebus.PrivateLinkResourcesClientGetOptions) (resp azfake.Responder[armservicebus.PrivateLinkResourcesClientGetResponse], errResp azfake.ErrorResponder)
}

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

type PrivateLinkResourcesServerTransport 

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

PrivateLinkResourcesServerTransport connects instances of armservicebus.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 armservicebus.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 QueuesServer 

type QueuesServer struct {
	// CreateOrUpdate is the fake for method QueuesClient.CreateOrUpdate
	// HTTP status codes to indicate success: http.StatusOK
	CreateOrUpdate func(ctx context.Context, resourceGroupName string, namespaceName string, queueName string, parameters armservicebus.SBQueue, options *armservicebus.QueuesClientCreateOrUpdateOptions) (resp azfake.Responder[armservicebus.QueuesClientCreateOrUpdateResponse], errResp azfake.ErrorResponder)

	// CreateOrUpdateAuthorizationRule is the fake for method QueuesClient.CreateOrUpdateAuthorizationRule
	// HTTP status codes to indicate success: http.StatusOK
	CreateOrUpdateAuthorizationRule func(ctx context.Context, resourceGroupName string, namespaceName string, queueName string, authorizationRuleName string, parameters armservicebus.SBAuthorizationRule, options *armservicebus.QueuesClientCreateOrUpdateAuthorizationRuleOptions) (resp azfake.Responder[armservicebus.QueuesClientCreateOrUpdateAuthorizationRuleResponse], errResp azfake.ErrorResponder)

	// Delete is the fake for method QueuesClient.Delete
	// HTTP status codes to indicate success: http.StatusOK, http.StatusNoContent
	Delete func(ctx context.Context, resourceGroupName string, namespaceName string, queueName string, options *armservicebus.QueuesClientDeleteOptions) (resp azfake.Responder[armservicebus.QueuesClientDeleteResponse], errResp azfake.ErrorResponder)

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

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

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

	// NewListAuthorizationRulesPager is the fake for method QueuesClient.NewListAuthorizationRulesPager
	// HTTP status codes to indicate success: http.StatusOK
	NewListAuthorizationRulesPager func(resourceGroupName string, namespaceName string, queueName string, options *armservicebus.QueuesClientListAuthorizationRulesOptions) (resp azfake.PagerResponder[armservicebus.QueuesClientListAuthorizationRulesResponse])

	// NewListByNamespacePager is the fake for method QueuesClient.NewListByNamespacePager
	// HTTP status codes to indicate success: http.StatusOK
	NewListByNamespacePager func(resourceGroupName string, namespaceName string, options *armservicebus.QueuesClientListByNamespaceOptions) (resp azfake.PagerResponder[armservicebus.QueuesClientListByNamespaceResponse])

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

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

QueuesServer is a fake server for instances of the armservicebus.QueuesClient type.

type QueuesServerTransport 

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

QueuesServerTransport connects instances of armservicebus.QueuesClient to instances of QueuesServer. Don't use this type directly, use NewQueuesServerTransport instead.

func NewQueuesServerTransport 

func NewQueuesServerTransport(srv *QueuesServer) *QueuesServerTransport

NewQueuesServerTransport creates a new instance of QueuesServerTransport with the provided implementation. The returned QueuesServerTransport instance is connected to an instance of armservicebus.QueuesClient via the azcore.ClientOptions.Transporter field in the client's constructor parameters.

func (*QueuesServerTransport) Do 

func (q *QueuesServerTransport) Do(req *http.Request) (*http.Response, error)

Do implements the policy.Transporter interface for QueuesServerTransport.

type RulesServer 

type RulesServer struct {
	// CreateOrUpdate is the fake for method RulesClient.CreateOrUpdate
	// HTTP status codes to indicate success: http.StatusOK
	CreateOrUpdate func(ctx context.Context, resourceGroupName string, namespaceName string, topicName string, subscriptionName string, ruleName string, parameters armservicebus.Rule, options *armservicebus.RulesClientCreateOrUpdateOptions) (resp azfake.Responder[armservicebus.RulesClientCreateOrUpdateResponse], errResp azfake.ErrorResponder)

	// Delete is the fake for method RulesClient.Delete
	// HTTP status codes to indicate success: http.StatusOK, http.StatusNoContent
	Delete func(ctx context.Context, resourceGroupName string, namespaceName string, topicName string, subscriptionName string, ruleName string, options *armservicebus.RulesClientDeleteOptions) (resp azfake.Responder[armservicebus.RulesClientDeleteResponse], errResp azfake.ErrorResponder)

	// Get is the fake for method RulesClient.Get
	// HTTP status codes to indicate success: http.StatusOK
	Get func(ctx context.Context, resourceGroupName string, namespaceName string, topicName string, subscriptionName string, ruleName string, options *armservicebus.RulesClientGetOptions) (resp azfake.Responder[armservicebus.RulesClientGetResponse], errResp azfake.ErrorResponder)

	// NewListBySubscriptionsPager is the fake for method RulesClient.NewListBySubscriptionsPager
	// HTTP status codes to indicate success: http.StatusOK
	NewListBySubscriptionsPager func(resourceGroupName string, namespaceName string, topicName string, subscriptionName string, options *armservicebus.RulesClientListBySubscriptionsOptions) (resp azfake.PagerResponder[armservicebus.RulesClientListBySubscriptionsResponse])
}

RulesServer is a fake server for instances of the armservicebus.RulesClient type.

type RulesServerTransport 

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

RulesServerTransport connects instances of armservicebus.RulesClient to instances of RulesServer. Don't use this type directly, use NewRulesServerTransport instead.

func NewRulesServerTransport 

func NewRulesServerTransport(srv *RulesServer) *RulesServerTransport

NewRulesServerTransport creates a new instance of RulesServerTransport with the provided implementation. The returned RulesServerTransport instance is connected to an instance of armservicebus.RulesClient via the azcore.ClientOptions.Transporter field in the client's constructor parameters.

func (*RulesServerTransport) Do 

func (r *RulesServerTransport) Do(req *http.Request) (*http.Response, error)

Do implements the policy.Transporter interface for RulesServerTransport.

type ServerFactory 

type ServerFactory struct {
	DisasterRecoveryConfigsServer    DisasterRecoveryConfigsServer
	MigrationConfigsServer           MigrationConfigsServer
	NamespacesServer                 NamespacesServer
	OperationsServer                 OperationsServer
	PrivateEndpointConnectionsServer PrivateEndpointConnectionsServer
	PrivateLinkResourcesServer       PrivateLinkResourcesServer
	QueuesServer                     QueuesServer
	RulesServer                      RulesServer
	SubscriptionsServer              SubscriptionsServer
	TopicsServer                     TopicsServer
}

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

type ServerFactoryTransport 

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

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

type SubscriptionsServer struct {
	// CreateOrUpdate is the fake for method SubscriptionsClient.CreateOrUpdate
	// HTTP status codes to indicate success: http.StatusOK
	CreateOrUpdate func(ctx context.Context, resourceGroupName string, namespaceName string, topicName string, subscriptionName string, parameters armservicebus.SBSubscription, options *armservicebus.SubscriptionsClientCreateOrUpdateOptions) (resp azfake.Responder[armservicebus.SubscriptionsClientCreateOrUpdateResponse], errResp azfake.ErrorResponder)

	// Delete is the fake for method SubscriptionsClient.Delete
	// HTTP status codes to indicate success: http.StatusOK, http.StatusNoContent
	Delete func(ctx context.Context, resourceGroupName string, namespaceName string, topicName string, subscriptionName string, options *armservicebus.SubscriptionsClientDeleteOptions) (resp azfake.Responder[armservicebus.SubscriptionsClientDeleteResponse], errResp azfake.ErrorResponder)

	// Get is the fake for method SubscriptionsClient.Get
	// HTTP status codes to indicate success: http.StatusOK
	Get func(ctx context.Context, resourceGroupName string, namespaceName string, topicName string, subscriptionName string, options *armservicebus.SubscriptionsClientGetOptions) (resp azfake.Responder[armservicebus.SubscriptionsClientGetResponse], errResp azfake.ErrorResponder)

	// NewListByTopicPager is the fake for method SubscriptionsClient.NewListByTopicPager
	// HTTP status codes to indicate success: http.StatusOK
	NewListByTopicPager func(resourceGroupName string, namespaceName string, topicName string, options *armservicebus.SubscriptionsClientListByTopicOptions) (resp azfake.PagerResponder[armservicebus.SubscriptionsClientListByTopicResponse])
}

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

type SubscriptionsServerTransport 

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

SubscriptionsServerTransport connects instances of armservicebus.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 armservicebus.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 TopicsServer 

type TopicsServer struct {
	// CreateOrUpdate is the fake for method TopicsClient.CreateOrUpdate
	// HTTP status codes to indicate success: http.StatusOK
	CreateOrUpdate func(ctx context.Context, resourceGroupName string, namespaceName string, topicName string, parameters armservicebus.SBTopic, options *armservicebus.TopicsClientCreateOrUpdateOptions) (resp azfake.Responder[armservicebus.TopicsClientCreateOrUpdateResponse], errResp azfake.ErrorResponder)

	// CreateOrUpdateAuthorizationRule is the fake for method TopicsClient.CreateOrUpdateAuthorizationRule
	// HTTP status codes to indicate success: http.StatusOK
	CreateOrUpdateAuthorizationRule func(ctx context.Context, resourceGroupName string, namespaceName string, topicName string, authorizationRuleName string, parameters armservicebus.SBAuthorizationRule, options *armservicebus.TopicsClientCreateOrUpdateAuthorizationRuleOptions) (resp azfake.Responder[armservicebus.TopicsClientCreateOrUpdateAuthorizationRuleResponse], errResp azfake.ErrorResponder)

	// Delete is the fake for method TopicsClient.Delete
	// HTTP status codes to indicate success: http.StatusOK, http.StatusNoContent
	Delete func(ctx context.Context, resourceGroupName string, namespaceName string, topicName string, options *armservicebus.TopicsClientDeleteOptions) (resp azfake.Responder[armservicebus.TopicsClientDeleteResponse], errResp azfake.ErrorResponder)

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

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

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

	// NewListAuthorizationRulesPager is the fake for method TopicsClient.NewListAuthorizationRulesPager
	// HTTP status codes to indicate success: http.StatusOK
	NewListAuthorizationRulesPager func(resourceGroupName string, namespaceName string, topicName string, options *armservicebus.TopicsClientListAuthorizationRulesOptions) (resp azfake.PagerResponder[armservicebus.TopicsClientListAuthorizationRulesResponse])

	// NewListByNamespacePager is the fake for method TopicsClient.NewListByNamespacePager
	// HTTP status codes to indicate success: http.StatusOK
	NewListByNamespacePager func(resourceGroupName string, namespaceName string, options *armservicebus.TopicsClientListByNamespaceOptions) (resp azfake.PagerResponder[armservicebus.TopicsClientListByNamespaceResponse])

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

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

TopicsServer is a fake server for instances of the armservicebus.TopicsClient type.

type TopicsServerTransport 

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

TopicsServerTransport connects instances of armservicebus.TopicsClient to instances of TopicsServer. Don't use this type directly, use NewTopicsServerTransport instead.

func NewTopicsServerTransport 

func NewTopicsServerTransport(srv *TopicsServer) *TopicsServerTransport

NewTopicsServerTransport creates a new instance of TopicsServerTransport with the provided implementation. The returned TopicsServerTransport instance is connected to an instance of armservicebus.TopicsClient via the azcore.ClientOptions.Transporter field in the client's constructor parameters.

func (*TopicsServerTransport) Do 

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

Do implements the policy.Transporter interface for TopicsServerTransport.

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.