Versions in this module Expand all Collapse all v1 v1.3.0-beta.1 Nov 27, 2023 v1.2.0 Nov 27, 2023 Changes in this version + type ClustersServer struct + BeginCreateOrUpdate func(ctx context.Context, resourceGroupName string, clusterName string, ...) (resp azfake.PollerResponder[armeventhub.ClustersClientCreateOrUpdateResponse], ...) + BeginDelete func(ctx context.Context, resourceGroupName string, clusterName string, ...) (resp azfake.PollerResponder[armeventhub.ClustersClientDeleteResponse], ...) + BeginUpdate func(ctx context.Context, resourceGroupName string, clusterName string, ...) (resp azfake.PollerResponder[armeventhub.ClustersClientUpdateResponse], ...) + Get func(ctx context.Context, resourceGroupName string, clusterName string, ...) (resp azfake.Responder[armeventhub.ClustersClientGetResponse], ...) + ListAvailableClusterRegion func(ctx context.Context, ...) (...) + ListNamespaces func(ctx context.Context, resourceGroupName string, clusterName string, ...) (resp azfake.Responder[armeventhub.ClustersClientListNamespacesResponse], ...) + NewListByResourceGroupPager func(resourceGroupName string, ...) (...) + NewListBySubscriptionPager func(options *armeventhub.ClustersClientListBySubscriptionOptions) (...) + type ClustersServerTransport struct + func NewClustersServerTransport(srv *ClustersServer) *ClustersServerTransport + func (c *ClustersServerTransport) Do(req *http.Request) (*http.Response, error) + type ConfigurationServer struct + Get func(ctx context.Context, resourceGroupName string, clusterName string, ...) (resp azfake.Responder[armeventhub.ConfigurationClientGetResponse], ...) + Patch func(ctx context.Context, resourceGroupName string, clusterName string, ...) (resp azfake.Responder[armeventhub.ConfigurationClientPatchResponse], ...) + type ConfigurationServerTransport struct + func NewConfigurationServerTransport(srv *ConfigurationServer) *ConfigurationServerTransport + func (c *ConfigurationServerTransport) Do(req *http.Request) (*http.Response, error) + type ConsumerGroupsServer struct + CreateOrUpdate func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (resp azfake.Responder[armeventhub.ConsumerGroupsClientCreateOrUpdateResponse], ...) + Delete func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (resp azfake.Responder[armeventhub.ConsumerGroupsClientDeleteResponse], ...) + Get func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (resp azfake.Responder[armeventhub.ConsumerGroupsClientGetResponse], ...) + NewListByEventHubPager func(resourceGroupName string, namespaceName string, eventHubName string, ...) (...) + type ConsumerGroupsServerTransport struct + func NewConsumerGroupsServerTransport(srv *ConsumerGroupsServer) *ConsumerGroupsServerTransport + func (c *ConsumerGroupsServerTransport) Do(req *http.Request) (*http.Response, error) + type DisasterRecoveryConfigsServer struct + BreakPairing func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (...) + CheckNameAvailability func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (...) + CreateOrUpdate func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (...) + Delete func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (resp azfake.Responder[armeventhub.DisasterRecoveryConfigsClientDeleteResponse], ...) + FailOver func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (...) + Get func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (resp azfake.Responder[armeventhub.DisasterRecoveryConfigsClientGetResponse], ...) + GetAuthorizationRule func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (...) + ListKeys func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (...) + NewListAuthorizationRulesPager func(resourceGroupName string, namespaceName string, alias string, ...) (...) + NewListPager func(resourceGroupName string, namespaceName string, ...) (...) + type DisasterRecoveryConfigsServerTransport struct + func NewDisasterRecoveryConfigsServerTransport(srv *DisasterRecoveryConfigsServer) *DisasterRecoveryConfigsServerTransport + func (d *DisasterRecoveryConfigsServerTransport) Do(req *http.Request) (*http.Response, error) + type EventHubsServer struct + CreateOrUpdate func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (resp azfake.Responder[armeventhub.EventHubsClientCreateOrUpdateResponse], ...) + CreateOrUpdateAuthorizationRule func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (...) + Delete func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (resp azfake.Responder[armeventhub.EventHubsClientDeleteResponse], ...) + DeleteAuthorizationRule func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (...) + Get func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (resp azfake.Responder[armeventhub.EventHubsClientGetResponse], ...) + GetAuthorizationRule func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (resp azfake.Responder[armeventhub.EventHubsClientGetAuthorizationRuleResponse], ...) + ListKeys func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (resp azfake.Responder[armeventhub.EventHubsClientListKeysResponse], ...) + NewListAuthorizationRulesPager func(resourceGroupName string, namespaceName string, eventHubName string, ...) (...) + NewListByNamespacePager func(resourceGroupName string, namespaceName string, ...) (resp azfake.PagerResponder[armeventhub.EventHubsClientListByNamespaceResponse]) + RegenerateKeys func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (resp azfake.Responder[armeventhub.EventHubsClientRegenerateKeysResponse], ...) + type EventHubsServerTransport struct + func NewEventHubsServerTransport(srv *EventHubsServer) *EventHubsServerTransport + func (e *EventHubsServerTransport) Do(req *http.Request) (*http.Response, error) + type NamespacesServer struct + BeginCreateOrUpdate func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (...) + BeginDelete func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (resp azfake.PollerResponder[armeventhub.NamespacesClientDeleteResponse], ...) + CheckNameAvailability func(ctx context.Context, parameters armeventhub.CheckNameAvailabilityParameter, ...) (...) + CreateOrUpdateAuthorizationRule func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (...) + CreateOrUpdateNetworkRuleSet func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (...) + DeleteAuthorizationRule func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (...) + Get func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (resp azfake.Responder[armeventhub.NamespacesClientGetResponse], ...) + GetAuthorizationRule func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (...) + GetNetworkRuleSet func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (resp azfake.Responder[armeventhub.NamespacesClientGetNetworkRuleSetResponse], ...) + ListKeys func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (resp azfake.Responder[armeventhub.NamespacesClientListKeysResponse], ...) + ListNetworkRuleSet func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (resp azfake.Responder[armeventhub.NamespacesClientListNetworkRuleSetResponse], ...) + NewListAuthorizationRulesPager func(resourceGroupName string, namespaceName string, ...) (...) + NewListByResourceGroupPager func(resourceGroupName string, ...) (...) + NewListPager func(options *armeventhub.NamespacesClientListOptions) (resp azfake.PagerResponder[armeventhub.NamespacesClientListResponse]) + RegenerateKeys func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (resp azfake.Responder[armeventhub.NamespacesClientRegenerateKeysResponse], ...) + Update func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (resp azfake.Responder[armeventhub.NamespacesClientUpdateResponse], ...) + type NamespacesServerTransport struct + func NewNamespacesServerTransport(srv *NamespacesServer) *NamespacesServerTransport + func (n *NamespacesServerTransport) Do(req *http.Request) (*http.Response, error) + type OperationsServer struct + NewListPager func(options *armeventhub.OperationsClientListOptions) (resp azfake.PagerResponder[armeventhub.OperationsClientListResponse]) + type OperationsServerTransport struct + func NewOperationsServerTransport(srv *OperationsServer) *OperationsServerTransport + func (o *OperationsServerTransport) Do(req *http.Request) (*http.Response, error) + type PrivateEndpointConnectionsServer struct + BeginDelete func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (...) + CreateOrUpdate func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (...) + Get func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (resp azfake.Responder[armeventhub.PrivateEndpointConnectionsClientGetResponse], ...) + NewListPager func(resourceGroupName string, namespaceName string, ...) (...) + type PrivateEndpointConnectionsServerTransport struct + func NewPrivateEndpointConnectionsServerTransport(srv *PrivateEndpointConnectionsServer) *PrivateEndpointConnectionsServerTransport + func (p *PrivateEndpointConnectionsServerTransport) Do(req *http.Request) (*http.Response, error) + type PrivateLinkResourcesServer struct + Get func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (resp azfake.Responder[armeventhub.PrivateLinkResourcesClientGetResponse], ...) + type PrivateLinkResourcesServerTransport struct + func NewPrivateLinkResourcesServerTransport(srv *PrivateLinkResourcesServer) *PrivateLinkResourcesServerTransport + func (p *PrivateLinkResourcesServerTransport) Do(req *http.Request) (*http.Response, error) + type SchemaRegistryServer struct + CreateOrUpdate func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (resp azfake.Responder[armeventhub.SchemaRegistryClientCreateOrUpdateResponse], ...) + Delete func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (resp azfake.Responder[armeventhub.SchemaRegistryClientDeleteResponse], ...) + Get func(ctx context.Context, resourceGroupName string, namespaceName string, ...) (resp azfake.Responder[armeventhub.SchemaRegistryClientGetResponse], ...) + NewListByNamespacePager func(resourceGroupName string, namespaceName string, ...) (...) + type SchemaRegistryServerTransport struct + func NewSchemaRegistryServerTransport(srv *SchemaRegistryServer) *SchemaRegistryServerTransport + func (s *SchemaRegistryServerTransport) Do(req *http.Request) (*http.Response, error) + type ServerFactory struct + ClustersServer ClustersServer + ConfigurationServer ConfigurationServer + ConsumerGroupsServer ConsumerGroupsServer + DisasterRecoveryConfigsServer DisasterRecoveryConfigsServer + EventHubsServer EventHubsServer + NamespacesServer NamespacesServer + OperationsServer OperationsServer + PrivateEndpointConnectionsServer PrivateEndpointConnectionsServer + PrivateLinkResourcesServer PrivateLinkResourcesServer + SchemaRegistryServer SchemaRegistryServer + type ServerFactoryTransport struct + func NewServerFactoryTransport(srv *ServerFactory) *ServerFactoryTransport + func (s *ServerFactoryTransport) Do(req *http.Request) (*http.Response, error)