Documentation ¶
Index ¶
- type ClustersServer
- type ClustersServerTransport
- type ConfigurationServer
- type ConfigurationServerTransport
- type ConsumerGroupsServer
- type ConsumerGroupsServerTransport
- type DisasterRecoveryConfigsServer
- type DisasterRecoveryConfigsServerTransport
- type EventHubsServer
- type EventHubsServerTransport
- type NamespacesServer
- type NamespacesServerTransport
- type OperationsServer
- type OperationsServerTransport
- type PrivateEndpointConnectionsServer
- type PrivateEndpointConnectionsServerTransport
- type PrivateLinkResourcesServer
- type PrivateLinkResourcesServerTransport
- type SchemaRegistryServer
- type SchemaRegistryServerTransport
- type ServerFactory
- type ServerFactoryTransport
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
Source Files ¶
- clusters_server.go
- configuration_server.go
- consumergroups_server.go
- disasterrecoveryconfigs_server.go
- eventhubs_server.go
- internal.go
- namespaces_server.go
- operations_server.go
- privateendpointconnections_server.go
- privatelinkresources_server.go
- schemaregistry_server.go
- server_factory.go
- time_rfc3339.go