mocks

Oct 11, 2023

Changes in this version

type ClusterManagerServer

+ func (_m *ClusterManagerServer) CheckAutopilotCompatibility(_a0 context.Context, _a1 *containerpb.CheckAutopilotCompatibilityRequest) (*containerpb.CheckAutopilotCompatibilityResponse, error)

+ type ClusterManagerServer_CheckAutopilotCompatibility_Call struct

+ func (_c *ClusterManagerServer_CheckAutopilotCompatibility_Call) Return(_a0 *containerpb.CheckAutopilotCompatibilityResponse, _a1 error) *ClusterManagerServer_CheckAutopilotCompatibility_Call

+ func (_c *ClusterManagerServer_CheckAutopilotCompatibility_Call) Run(...) *ClusterManagerServer_CheckAutopilotCompatibility_Call

+ func (_c *ClusterManagerServer_CheckAutopilotCompatibility_Call) RunAndReturn(...) *ClusterManagerServer_CheckAutopilotCompatibility_Call

type ClusterManagerServer_Expecter

+ func (_e *ClusterManagerServer_Expecter) CheckAutopilotCompatibility(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_CheckAutopilotCompatibility_Call

Sep 20, 2023

Changes in this version

type ClusterManagerServer_CancelOperation_Call

+ func (_c *ClusterManagerServer_CancelOperation_Call) RunAndReturn(...) *ClusterManagerServer_CancelOperation_Call

type ClusterManagerServer_CompleteIPRotation_Call

+ func (_c *ClusterManagerServer_CompleteIPRotation_Call) RunAndReturn(...) *ClusterManagerServer_CompleteIPRotation_Call

type ClusterManagerServer_CompleteNodePoolUpgrade_Call

+ func (_c *ClusterManagerServer_CompleteNodePoolUpgrade_Call) RunAndReturn(...) *ClusterManagerServer_CompleteNodePoolUpgrade_Call

type ClusterManagerServer_CreateCluster_Call

+ func (_c *ClusterManagerServer_CreateCluster_Call) RunAndReturn(...) *ClusterManagerServer_CreateCluster_Call

type ClusterManagerServer_CreateNodePool_Call

+ func (_c *ClusterManagerServer_CreateNodePool_Call) RunAndReturn(...) *ClusterManagerServer_CreateNodePool_Call

type ClusterManagerServer_DeleteCluster_Call

+ func (_c *ClusterManagerServer_DeleteCluster_Call) RunAndReturn(...) *ClusterManagerServer_DeleteCluster_Call

type ClusterManagerServer_DeleteNodePool_Call

+ func (_c *ClusterManagerServer_DeleteNodePool_Call) RunAndReturn(...) *ClusterManagerServer_DeleteNodePool_Call

type ClusterManagerServer_GetCluster_Call

+ func (_c *ClusterManagerServer_GetCluster_Call) RunAndReturn(...) *ClusterManagerServer_GetCluster_Call

type ClusterManagerServer_GetJSONWebKeys_Call

+ func (_c *ClusterManagerServer_GetJSONWebKeys_Call) RunAndReturn(...) *ClusterManagerServer_GetJSONWebKeys_Call

type ClusterManagerServer_GetNodePool_Call

+ func (_c *ClusterManagerServer_GetNodePool_Call) RunAndReturn(...) *ClusterManagerServer_GetNodePool_Call

type ClusterManagerServer_GetOperation_Call

+ func (_c *ClusterManagerServer_GetOperation_Call) RunAndReturn(...) *ClusterManagerServer_GetOperation_Call

type ClusterManagerServer_GetServerConfig_Call

+ func (_c *ClusterManagerServer_GetServerConfig_Call) RunAndReturn(...) *ClusterManagerServer_GetServerConfig_Call

type ClusterManagerServer_ListClusters_Call

+ func (_c *ClusterManagerServer_ListClusters_Call) RunAndReturn(...) *ClusterManagerServer_ListClusters_Call

type ClusterManagerServer_ListNodePools_Call

+ func (_c *ClusterManagerServer_ListNodePools_Call) RunAndReturn(...) *ClusterManagerServer_ListNodePools_Call

type ClusterManagerServer_ListOperations_Call

+ func (_c *ClusterManagerServer_ListOperations_Call) RunAndReturn(...) *ClusterManagerServer_ListOperations_Call

type ClusterManagerServer_ListUsableSubnetworks_Call

+ func (_c *ClusterManagerServer_ListUsableSubnetworks_Call) RunAndReturn(...) *ClusterManagerServer_ListUsableSubnetworks_Call

type ClusterManagerServer_RollbackNodePoolUpgrade_Call

+ func (_c *ClusterManagerServer_RollbackNodePoolUpgrade_Call) RunAndReturn(...) *ClusterManagerServer_RollbackNodePoolUpgrade_Call

type ClusterManagerServer_SetAddonsConfig_Call

+ func (_c *ClusterManagerServer_SetAddonsConfig_Call) RunAndReturn(...) *ClusterManagerServer_SetAddonsConfig_Call

type ClusterManagerServer_SetLabels_Call

+ func (_c *ClusterManagerServer_SetLabels_Call) RunAndReturn(...) *ClusterManagerServer_SetLabels_Call

type ClusterManagerServer_SetLegacyAbac_Call

+ func (_c *ClusterManagerServer_SetLegacyAbac_Call) RunAndReturn(...) *ClusterManagerServer_SetLegacyAbac_Call

type ClusterManagerServer_SetLocations_Call

+ func (_c *ClusterManagerServer_SetLocations_Call) RunAndReturn(...) *ClusterManagerServer_SetLocations_Call

type ClusterManagerServer_SetLoggingService_Call

+ func (_c *ClusterManagerServer_SetLoggingService_Call) RunAndReturn(...) *ClusterManagerServer_SetLoggingService_Call

type ClusterManagerServer_SetMaintenancePolicy_Call

+ func (_c *ClusterManagerServer_SetMaintenancePolicy_Call) RunAndReturn(...) *ClusterManagerServer_SetMaintenancePolicy_Call

type ClusterManagerServer_SetMasterAuth_Call

+ func (_c *ClusterManagerServer_SetMasterAuth_Call) RunAndReturn(...) *ClusterManagerServer_SetMasterAuth_Call

type ClusterManagerServer_SetMonitoringService_Call

+ func (_c *ClusterManagerServer_SetMonitoringService_Call) RunAndReturn(...) *ClusterManagerServer_SetMonitoringService_Call

type ClusterManagerServer_SetNetworkPolicy_Call

+ func (_c *ClusterManagerServer_SetNetworkPolicy_Call) RunAndReturn(...) *ClusterManagerServer_SetNetworkPolicy_Call

type ClusterManagerServer_SetNodePoolAutoscaling_Call

+ func (_c *ClusterManagerServer_SetNodePoolAutoscaling_Call) RunAndReturn(...) *ClusterManagerServer_SetNodePoolAutoscaling_Call

type ClusterManagerServer_SetNodePoolManagement_Call

+ func (_c *ClusterManagerServer_SetNodePoolManagement_Call) RunAndReturn(...) *ClusterManagerServer_SetNodePoolManagement_Call

type ClusterManagerServer_SetNodePoolSize_Call

+ func (_c *ClusterManagerServer_SetNodePoolSize_Call) RunAndReturn(...) *ClusterManagerServer_SetNodePoolSize_Call

type ClusterManagerServer_StartIPRotation_Call

+ func (_c *ClusterManagerServer_StartIPRotation_Call) RunAndReturn(...) *ClusterManagerServer_StartIPRotation_Call

type ClusterManagerServer_UpdateCluster_Call

+ func (_c *ClusterManagerServer_UpdateCluster_Call) RunAndReturn(...) *ClusterManagerServer_UpdateCluster_Call

type ClusterManagerServer_UpdateMaster_Call

+ func (_c *ClusterManagerServer_UpdateMaster_Call) RunAndReturn(...) *ClusterManagerServer_UpdateMaster_Call

type ClusterManagerServer_UpdateNodePool_Call

+ func (_c *ClusterManagerServer_UpdateNodePool_Call) RunAndReturn(...) *ClusterManagerServer_UpdateNodePool_Call

type PublisherServer_CreateTopic_Call

+ func (_c *PublisherServer_CreateTopic_Call) RunAndReturn(run func(context.Context, *pubsubpb.Topic) (*pubsubpb.Topic, error)) *PublisherServer_CreateTopic_Call

type PublisherServer_DeleteTopic_Call

+ func (_c *PublisherServer_DeleteTopic_Call) RunAndReturn(...) *PublisherServer_DeleteTopic_Call

type PublisherServer_DetachSubscription_Call

+ func (_c *PublisherServer_DetachSubscription_Call) RunAndReturn(...) *PublisherServer_DetachSubscription_Call

type PublisherServer_GetTopic_Call

+ func (_c *PublisherServer_GetTopic_Call) RunAndReturn(run func(context.Context, *pubsubpb.GetTopicRequest) (*pubsubpb.Topic, error)) *PublisherServer_GetTopic_Call

type PublisherServer_ListTopicSnapshots_Call

+ func (_c *PublisherServer_ListTopicSnapshots_Call) RunAndReturn(...) *PublisherServer_ListTopicSnapshots_Call

type PublisherServer_ListTopicSubscriptions_Call

+ func (_c *PublisherServer_ListTopicSubscriptions_Call) RunAndReturn(...) *PublisherServer_ListTopicSubscriptions_Call

type PublisherServer_ListTopics_Call

+ func (_c *PublisherServer_ListTopics_Call) RunAndReturn(...) *PublisherServer_ListTopics_Call

type PublisherServer_Publish_Call

+ func (_c *PublisherServer_Publish_Call) RunAndReturn(...) *PublisherServer_Publish_Call

type PublisherServer_UpdateTopic_Call

+ func (_c *PublisherServer_UpdateTopic_Call) RunAndReturn(...) *PublisherServer_UpdateTopic_Call

type SubscriberServer_Acknowledge_Call

+ func (_c *SubscriberServer_Acknowledge_Call) RunAndReturn(...) *SubscriberServer_Acknowledge_Call

type SubscriberServer_CreateSnapshot_Call

+ func (_c *SubscriberServer_CreateSnapshot_Call) RunAndReturn(...) *SubscriberServer_CreateSnapshot_Call

type SubscriberServer_CreateSubscription_Call

+ func (_c *SubscriberServer_CreateSubscription_Call) RunAndReturn(...) *SubscriberServer_CreateSubscription_Call

type SubscriberServer_DeleteSnapshot_Call

+ func (_c *SubscriberServer_DeleteSnapshot_Call) RunAndReturn(...) *SubscriberServer_DeleteSnapshot_Call

type SubscriberServer_DeleteSubscription_Call

+ func (_c *SubscriberServer_DeleteSubscription_Call) RunAndReturn(...) *SubscriberServer_DeleteSubscription_Call

type SubscriberServer_GetSnapshot_Call

+ func (_c *SubscriberServer_GetSnapshot_Call) RunAndReturn(...) *SubscriberServer_GetSnapshot_Call

type SubscriberServer_GetSubscription_Call

+ func (_c *SubscriberServer_GetSubscription_Call) RunAndReturn(...) *SubscriberServer_GetSubscription_Call

type SubscriberServer_ListSnapshots_Call

+ func (_c *SubscriberServer_ListSnapshots_Call) RunAndReturn(...) *SubscriberServer_ListSnapshots_Call

type SubscriberServer_ListSubscriptions_Call

+ func (_c *SubscriberServer_ListSubscriptions_Call) RunAndReturn(...) *SubscriberServer_ListSubscriptions_Call

type SubscriberServer_ModifyAckDeadline_Call

+ func (_c *SubscriberServer_ModifyAckDeadline_Call) RunAndReturn(...) *SubscriberServer_ModifyAckDeadline_Call

type SubscriberServer_ModifyPushConfig_Call

+ func (_c *SubscriberServer_ModifyPushConfig_Call) RunAndReturn(...) *SubscriberServer_ModifyPushConfig_Call

type SubscriberServer_Pull_Call

+ func (_c *SubscriberServer_Pull_Call) RunAndReturn(...) *SubscriberServer_Pull_Call

type SubscriberServer_Seek_Call

+ func (_c *SubscriberServer_Seek_Call) RunAndReturn(...) *SubscriberServer_Seek_Call

type SubscriberServer_StreamingPull_Call

+ func (_c *SubscriberServer_StreamingPull_Call) RunAndReturn(run func(pubsubpb.Subscriber_StreamingPullServer) error) *SubscriberServer_StreamingPull_Call

type SubscriberServer_UpdateSnapshot_Call

+ func (_c *SubscriberServer_UpdateSnapshot_Call) RunAndReturn(...) *SubscriberServer_UpdateSnapshot_Call

type SubscriberServer_UpdateSubscription_Call

+ func (_c *SubscriberServer_UpdateSubscription_Call) RunAndReturn(...) *SubscriberServer_UpdateSubscription_Call

Nov 17, 2022

Changes in this version

+ type ClusterManagerServer struct

+ func NewClusterManagerServer(t mockConstructorTestingTNewClusterManagerServer) *ClusterManagerServer

+ func (_m *ClusterManagerServer) CancelOperation(_a0 context.Context, _a1 *container.CancelOperationRequest) (*emptypb.Empty, error)

+ func (_m *ClusterManagerServer) CompleteIPRotation(_a0 context.Context, _a1 *container.CompleteIPRotationRequest) (*container.Operation, error)

+ func (_m *ClusterManagerServer) CompleteNodePoolUpgrade(_a0 context.Context, _a1 *container.CompleteNodePoolUpgradeRequest) (*emptypb.Empty, error)

+ func (_m *ClusterManagerServer) CreateCluster(_a0 context.Context, _a1 *container.CreateClusterRequest) (*container.Operation, error)

+ func (_m *ClusterManagerServer) CreateNodePool(_a0 context.Context, _a1 *container.CreateNodePoolRequest) (*container.Operation, error)

+ func (_m *ClusterManagerServer) DeleteCluster(_a0 context.Context, _a1 *container.DeleteClusterRequest) (*container.Operation, error)

+ func (_m *ClusterManagerServer) DeleteNodePool(_a0 context.Context, _a1 *container.DeleteNodePoolRequest) (*container.Operation, error)

+ func (_m *ClusterManagerServer) EXPECT() *ClusterManagerServer_Expecter

+ func (_m *ClusterManagerServer) GetCluster(_a0 context.Context, _a1 *container.GetClusterRequest) (*container.Cluster, error)

+ func (_m *ClusterManagerServer) GetJSONWebKeys(_a0 context.Context, _a1 *container.GetJSONWebKeysRequest) (*container.GetJSONWebKeysResponse, error)

+ func (_m *ClusterManagerServer) GetNodePool(_a0 context.Context, _a1 *container.GetNodePoolRequest) (*container.NodePool, error)

+ func (_m *ClusterManagerServer) GetOperation(_a0 context.Context, _a1 *container.GetOperationRequest) (*container.Operation, error)

+ func (_m *ClusterManagerServer) GetServerConfig(_a0 context.Context, _a1 *container.GetServerConfigRequest) (*container.ServerConfig, error)

+ func (_m *ClusterManagerServer) ListClusters(_a0 context.Context, _a1 *container.ListClustersRequest) (*container.ListClustersResponse, error)

+ func (_m *ClusterManagerServer) ListNodePools(_a0 context.Context, _a1 *container.ListNodePoolsRequest) (*container.ListNodePoolsResponse, error)

+ func (_m *ClusterManagerServer) ListOperations(_a0 context.Context, _a1 *container.ListOperationsRequest) (*container.ListOperationsResponse, error)

+ func (_m *ClusterManagerServer) ListUsableSubnetworks(_a0 context.Context, _a1 *container.ListUsableSubnetworksRequest) (*container.ListUsableSubnetworksResponse, error)

+ func (_m *ClusterManagerServer) RollbackNodePoolUpgrade(_a0 context.Context, _a1 *container.RollbackNodePoolUpgradeRequest) (*container.Operation, error)

+ func (_m *ClusterManagerServer) SetAddonsConfig(_a0 context.Context, _a1 *container.SetAddonsConfigRequest) (*container.Operation, error)

+ func (_m *ClusterManagerServer) SetLabels(_a0 context.Context, _a1 *container.SetLabelsRequest) (*container.Operation, error)

+ func (_m *ClusterManagerServer) SetLegacyAbac(_a0 context.Context, _a1 *container.SetLegacyAbacRequest) (*container.Operation, error)

+ func (_m *ClusterManagerServer) SetLocations(_a0 context.Context, _a1 *container.SetLocationsRequest) (*container.Operation, error)

+ func (_m *ClusterManagerServer) SetLoggingService(_a0 context.Context, _a1 *container.SetLoggingServiceRequest) (*container.Operation, error)

+ func (_m *ClusterManagerServer) SetMaintenancePolicy(_a0 context.Context, _a1 *container.SetMaintenancePolicyRequest) (*container.Operation, error)

+ func (_m *ClusterManagerServer) SetMasterAuth(_a0 context.Context, _a1 *container.SetMasterAuthRequest) (*container.Operation, error)

+ func (_m *ClusterManagerServer) SetMonitoringService(_a0 context.Context, _a1 *container.SetMonitoringServiceRequest) (*container.Operation, error)

+ func (_m *ClusterManagerServer) SetNetworkPolicy(_a0 context.Context, _a1 *container.SetNetworkPolicyRequest) (*container.Operation, error)

+ func (_m *ClusterManagerServer) SetNodePoolAutoscaling(_a0 context.Context, _a1 *container.SetNodePoolAutoscalingRequest) (*container.Operation, error)

+ func (_m *ClusterManagerServer) SetNodePoolManagement(_a0 context.Context, _a1 *container.SetNodePoolManagementRequest) (*container.Operation, error)

+ func (_m *ClusterManagerServer) SetNodePoolSize(_a0 context.Context, _a1 *container.SetNodePoolSizeRequest) (*container.Operation, error)

+ func (_m *ClusterManagerServer) StartIPRotation(_a0 context.Context, _a1 *container.StartIPRotationRequest) (*container.Operation, error)

+ func (_m *ClusterManagerServer) UpdateCluster(_a0 context.Context, _a1 *container.UpdateClusterRequest) (*container.Operation, error)

+ func (_m *ClusterManagerServer) UpdateMaster(_a0 context.Context, _a1 *container.UpdateMasterRequest) (*container.Operation, error)

+ func (_m *ClusterManagerServer) UpdateNodePool(_a0 context.Context, _a1 *container.UpdateNodePoolRequest) (*container.Operation, error)

+ type ClusterManagerServer_CancelOperation_Call struct

+ func (_c *ClusterManagerServer_CancelOperation_Call) Return(_a0 *emptypb.Empty, _a1 error) *ClusterManagerServer_CancelOperation_Call

+ func (_c *ClusterManagerServer_CancelOperation_Call) Run(run func(_a0 context.Context, _a1 *container.CancelOperationRequest)) *ClusterManagerServer_CancelOperation_Call

+ type ClusterManagerServer_CompleteIPRotation_Call struct

+ func (_c *ClusterManagerServer_CompleteIPRotation_Call) Return(_a0 *container.Operation, _a1 error) *ClusterManagerServer_CompleteIPRotation_Call

+ func (_c *ClusterManagerServer_CompleteIPRotation_Call) Run(run func(_a0 context.Context, _a1 *container.CompleteIPRotationRequest)) *ClusterManagerServer_CompleteIPRotation_Call

+ type ClusterManagerServer_CompleteNodePoolUpgrade_Call struct

+ func (_c *ClusterManagerServer_CompleteNodePoolUpgrade_Call) Return(_a0 *emptypb.Empty, _a1 error) *ClusterManagerServer_CompleteNodePoolUpgrade_Call

+ func (_c *ClusterManagerServer_CompleteNodePoolUpgrade_Call) Run(run func(_a0 context.Context, _a1 *container.CompleteNodePoolUpgradeRequest)) *ClusterManagerServer_CompleteNodePoolUpgrade_Call

+ type ClusterManagerServer_CreateCluster_Call struct

+ func (_c *ClusterManagerServer_CreateCluster_Call) Return(_a0 *container.Operation, _a1 error) *ClusterManagerServer_CreateCluster_Call

+ func (_c *ClusterManagerServer_CreateCluster_Call) Run(run func(_a0 context.Context, _a1 *container.CreateClusterRequest)) *ClusterManagerServer_CreateCluster_Call

+ type ClusterManagerServer_CreateNodePool_Call struct

+ func (_c *ClusterManagerServer_CreateNodePool_Call) Return(_a0 *container.Operation, _a1 error) *ClusterManagerServer_CreateNodePool_Call

+ func (_c *ClusterManagerServer_CreateNodePool_Call) Run(run func(_a0 context.Context, _a1 *container.CreateNodePoolRequest)) *ClusterManagerServer_CreateNodePool_Call

+ type ClusterManagerServer_DeleteCluster_Call struct

+ func (_c *ClusterManagerServer_DeleteCluster_Call) Return(_a0 *container.Operation, _a1 error) *ClusterManagerServer_DeleteCluster_Call

+ func (_c *ClusterManagerServer_DeleteCluster_Call) Run(run func(_a0 context.Context, _a1 *container.DeleteClusterRequest)) *ClusterManagerServer_DeleteCluster_Call

+ type ClusterManagerServer_DeleteNodePool_Call struct

+ func (_c *ClusterManagerServer_DeleteNodePool_Call) Return(_a0 *container.Operation, _a1 error) *ClusterManagerServer_DeleteNodePool_Call

+ func (_c *ClusterManagerServer_DeleteNodePool_Call) Run(run func(_a0 context.Context, _a1 *container.DeleteNodePoolRequest)) *ClusterManagerServer_DeleteNodePool_Call

+ type ClusterManagerServer_Expecter struct

+ func (_e *ClusterManagerServer_Expecter) CancelOperation(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_CancelOperation_Call

+ func (_e *ClusterManagerServer_Expecter) CompleteIPRotation(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_CompleteIPRotation_Call

+ func (_e *ClusterManagerServer_Expecter) CompleteNodePoolUpgrade(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_CompleteNodePoolUpgrade_Call

+ func (_e *ClusterManagerServer_Expecter) CreateCluster(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_CreateCluster_Call

+ func (_e *ClusterManagerServer_Expecter) CreateNodePool(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_CreateNodePool_Call

+ func (_e *ClusterManagerServer_Expecter) DeleteCluster(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_DeleteCluster_Call

+ func (_e *ClusterManagerServer_Expecter) DeleteNodePool(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_DeleteNodePool_Call

+ func (_e *ClusterManagerServer_Expecter) GetCluster(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_GetCluster_Call

+ func (_e *ClusterManagerServer_Expecter) GetJSONWebKeys(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_GetJSONWebKeys_Call

+ func (_e *ClusterManagerServer_Expecter) GetNodePool(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_GetNodePool_Call

+ func (_e *ClusterManagerServer_Expecter) GetOperation(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_GetOperation_Call

+ func (_e *ClusterManagerServer_Expecter) GetServerConfig(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_GetServerConfig_Call

+ func (_e *ClusterManagerServer_Expecter) ListClusters(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_ListClusters_Call

+ func (_e *ClusterManagerServer_Expecter) ListNodePools(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_ListNodePools_Call

+ func (_e *ClusterManagerServer_Expecter) ListOperations(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_ListOperations_Call

+ func (_e *ClusterManagerServer_Expecter) ListUsableSubnetworks(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_ListUsableSubnetworks_Call

+ func (_e *ClusterManagerServer_Expecter) RollbackNodePoolUpgrade(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_RollbackNodePoolUpgrade_Call

+ func (_e *ClusterManagerServer_Expecter) SetAddonsConfig(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_SetAddonsConfig_Call

+ func (_e *ClusterManagerServer_Expecter) SetLabels(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_SetLabels_Call

+ func (_e *ClusterManagerServer_Expecter) SetLegacyAbac(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_SetLegacyAbac_Call

+ func (_e *ClusterManagerServer_Expecter) SetLocations(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_SetLocations_Call

+ func (_e *ClusterManagerServer_Expecter) SetLoggingService(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_SetLoggingService_Call

+ func (_e *ClusterManagerServer_Expecter) SetMaintenancePolicy(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_SetMaintenancePolicy_Call

+ func (_e *ClusterManagerServer_Expecter) SetMasterAuth(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_SetMasterAuth_Call

+ func (_e *ClusterManagerServer_Expecter) SetMonitoringService(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_SetMonitoringService_Call

+ func (_e *ClusterManagerServer_Expecter) SetNetworkPolicy(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_SetNetworkPolicy_Call

+ func (_e *ClusterManagerServer_Expecter) SetNodePoolAutoscaling(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_SetNodePoolAutoscaling_Call

+ func (_e *ClusterManagerServer_Expecter) SetNodePoolManagement(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_SetNodePoolManagement_Call

+ func (_e *ClusterManagerServer_Expecter) SetNodePoolSize(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_SetNodePoolSize_Call

+ func (_e *ClusterManagerServer_Expecter) StartIPRotation(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_StartIPRotation_Call

+ func (_e *ClusterManagerServer_Expecter) UpdateCluster(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_UpdateCluster_Call

+ func (_e *ClusterManagerServer_Expecter) UpdateMaster(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_UpdateMaster_Call

+ func (_e *ClusterManagerServer_Expecter) UpdateNodePool(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_UpdateNodePool_Call

+ type ClusterManagerServer_GetCluster_Call struct

+ func (_c *ClusterManagerServer_GetCluster_Call) Return(_a0 *container.Cluster, _a1 error) *ClusterManagerServer_GetCluster_Call

+ func (_c *ClusterManagerServer_GetCluster_Call) Run(run func(_a0 context.Context, _a1 *container.GetClusterRequest)) *ClusterManagerServer_GetCluster_Call

+ type ClusterManagerServer_GetJSONWebKeys_Call struct

+ func (_c *ClusterManagerServer_GetJSONWebKeys_Call) Return(_a0 *container.GetJSONWebKeysResponse, _a1 error) *ClusterManagerServer_GetJSONWebKeys_Call

+ func (_c *ClusterManagerServer_GetJSONWebKeys_Call) Run(run func(_a0 context.Context, _a1 *container.GetJSONWebKeysRequest)) *ClusterManagerServer_GetJSONWebKeys_Call

+ type ClusterManagerServer_GetNodePool_Call struct

+ func (_c *ClusterManagerServer_GetNodePool_Call) Return(_a0 *container.NodePool, _a1 error) *ClusterManagerServer_GetNodePool_Call

+ func (_c *ClusterManagerServer_GetNodePool_Call) Run(run func(_a0 context.Context, _a1 *container.GetNodePoolRequest)) *ClusterManagerServer_GetNodePool_Call

+ type ClusterManagerServer_GetOperation_Call struct

+ func (_c *ClusterManagerServer_GetOperation_Call) Return(_a0 *container.Operation, _a1 error) *ClusterManagerServer_GetOperation_Call

+ func (_c *ClusterManagerServer_GetOperation_Call) Run(run func(_a0 context.Context, _a1 *container.GetOperationRequest)) *ClusterManagerServer_GetOperation_Call

+ type ClusterManagerServer_GetServerConfig_Call struct

+ func (_c *ClusterManagerServer_GetServerConfig_Call) Return(_a0 *container.ServerConfig, _a1 error) *ClusterManagerServer_GetServerConfig_Call

+ func (_c *ClusterManagerServer_GetServerConfig_Call) Run(run func(_a0 context.Context, _a1 *container.GetServerConfigRequest)) *ClusterManagerServer_GetServerConfig_Call

+ type ClusterManagerServer_ListClusters_Call struct

+ func (_c *ClusterManagerServer_ListClusters_Call) Return(_a0 *container.ListClustersResponse, _a1 error) *ClusterManagerServer_ListClusters_Call

+ func (_c *ClusterManagerServer_ListClusters_Call) Run(run func(_a0 context.Context, _a1 *container.ListClustersRequest)) *ClusterManagerServer_ListClusters_Call

+ type ClusterManagerServer_ListNodePools_Call struct

+ func (_c *ClusterManagerServer_ListNodePools_Call) Return(_a0 *container.ListNodePoolsResponse, _a1 error) *ClusterManagerServer_ListNodePools_Call

+ func (_c *ClusterManagerServer_ListNodePools_Call) Run(run func(_a0 context.Context, _a1 *container.ListNodePoolsRequest)) *ClusterManagerServer_ListNodePools_Call

+ type ClusterManagerServer_ListOperations_Call struct

+ func (_c *ClusterManagerServer_ListOperations_Call) Return(_a0 *container.ListOperationsResponse, _a1 error) *ClusterManagerServer_ListOperations_Call

+ func (_c *ClusterManagerServer_ListOperations_Call) Run(run func(_a0 context.Context, _a1 *container.ListOperationsRequest)) *ClusterManagerServer_ListOperations_Call

+ type ClusterManagerServer_ListUsableSubnetworks_Call struct

+ func (_c *ClusterManagerServer_ListUsableSubnetworks_Call) Return(_a0 *container.ListUsableSubnetworksResponse, _a1 error) *ClusterManagerServer_ListUsableSubnetworks_Call

+ func (_c *ClusterManagerServer_ListUsableSubnetworks_Call) Run(run func(_a0 context.Context, _a1 *container.ListUsableSubnetworksRequest)) *ClusterManagerServer_ListUsableSubnetworks_Call

+ type ClusterManagerServer_RollbackNodePoolUpgrade_Call struct

+ func (_c *ClusterManagerServer_RollbackNodePoolUpgrade_Call) Return(_a0 *container.Operation, _a1 error) *ClusterManagerServer_RollbackNodePoolUpgrade_Call

+ func (_c *ClusterManagerServer_RollbackNodePoolUpgrade_Call) Run(run func(_a0 context.Context, _a1 *container.RollbackNodePoolUpgradeRequest)) *ClusterManagerServer_RollbackNodePoolUpgrade_Call

+ type ClusterManagerServer_SetAddonsConfig_Call struct

+ func (_c *ClusterManagerServer_SetAddonsConfig_Call) Return(_a0 *container.Operation, _a1 error) *ClusterManagerServer_SetAddonsConfig_Call

+ func (_c *ClusterManagerServer_SetAddonsConfig_Call) Run(run func(_a0 context.Context, _a1 *container.SetAddonsConfigRequest)) *ClusterManagerServer_SetAddonsConfig_Call

+ type ClusterManagerServer_SetLabels_Call struct

+ func (_c *ClusterManagerServer_SetLabels_Call) Return(_a0 *container.Operation, _a1 error) *ClusterManagerServer_SetLabels_Call

+ func (_c *ClusterManagerServer_SetLabels_Call) Run(run func(_a0 context.Context, _a1 *container.SetLabelsRequest)) *ClusterManagerServer_SetLabels_Call

+ type ClusterManagerServer_SetLegacyAbac_Call struct

+ func (_c *ClusterManagerServer_SetLegacyAbac_Call) Return(_a0 *container.Operation, _a1 error) *ClusterManagerServer_SetLegacyAbac_Call

+ func (_c *ClusterManagerServer_SetLegacyAbac_Call) Run(run func(_a0 context.Context, _a1 *container.SetLegacyAbacRequest)) *ClusterManagerServer_SetLegacyAbac_Call

+ type ClusterManagerServer_SetLocations_Call struct

+ func (_c *ClusterManagerServer_SetLocations_Call) Return(_a0 *container.Operation, _a1 error) *ClusterManagerServer_SetLocations_Call

+ func (_c *ClusterManagerServer_SetLocations_Call) Run(run func(_a0 context.Context, _a1 *container.SetLocationsRequest)) *ClusterManagerServer_SetLocations_Call

+ type ClusterManagerServer_SetLoggingService_Call struct

+ func (_c *ClusterManagerServer_SetLoggingService_Call) Return(_a0 *container.Operation, _a1 error) *ClusterManagerServer_SetLoggingService_Call

+ func (_c *ClusterManagerServer_SetLoggingService_Call) Run(run func(_a0 context.Context, _a1 *container.SetLoggingServiceRequest)) *ClusterManagerServer_SetLoggingService_Call

+ type ClusterManagerServer_SetMaintenancePolicy_Call struct

+ func (_c *ClusterManagerServer_SetMaintenancePolicy_Call) Return(_a0 *container.Operation, _a1 error) *ClusterManagerServer_SetMaintenancePolicy_Call

+ func (_c *ClusterManagerServer_SetMaintenancePolicy_Call) Run(run func(_a0 context.Context, _a1 *container.SetMaintenancePolicyRequest)) *ClusterManagerServer_SetMaintenancePolicy_Call

+ type ClusterManagerServer_SetMasterAuth_Call struct

+ func (_c *ClusterManagerServer_SetMasterAuth_Call) Return(_a0 *container.Operation, _a1 error) *ClusterManagerServer_SetMasterAuth_Call

+ func (_c *ClusterManagerServer_SetMasterAuth_Call) Run(run func(_a0 context.Context, _a1 *container.SetMasterAuthRequest)) *ClusterManagerServer_SetMasterAuth_Call

+ type ClusterManagerServer_SetMonitoringService_Call struct

+ func (_c *ClusterManagerServer_SetMonitoringService_Call) Return(_a0 *container.Operation, _a1 error) *ClusterManagerServer_SetMonitoringService_Call

+ func (_c *ClusterManagerServer_SetMonitoringService_Call) Run(run func(_a0 context.Context, _a1 *container.SetMonitoringServiceRequest)) *ClusterManagerServer_SetMonitoringService_Call

+ type ClusterManagerServer_SetNetworkPolicy_Call struct

+ func (_c *ClusterManagerServer_SetNetworkPolicy_Call) Return(_a0 *container.Operation, _a1 error) *ClusterManagerServer_SetNetworkPolicy_Call

+ func (_c *ClusterManagerServer_SetNetworkPolicy_Call) Run(run func(_a0 context.Context, _a1 *container.SetNetworkPolicyRequest)) *ClusterManagerServer_SetNetworkPolicy_Call

+ type ClusterManagerServer_SetNodePoolAutoscaling_Call struct

+ func (_c *ClusterManagerServer_SetNodePoolAutoscaling_Call) Return(_a0 *container.Operation, _a1 error) *ClusterManagerServer_SetNodePoolAutoscaling_Call

+ func (_c *ClusterManagerServer_SetNodePoolAutoscaling_Call) Run(run func(_a0 context.Context, _a1 *container.SetNodePoolAutoscalingRequest)) *ClusterManagerServer_SetNodePoolAutoscaling_Call

+ type ClusterManagerServer_SetNodePoolManagement_Call struct

+ func (_c *ClusterManagerServer_SetNodePoolManagement_Call) Return(_a0 *container.Operation, _a1 error) *ClusterManagerServer_SetNodePoolManagement_Call

+ func (_c *ClusterManagerServer_SetNodePoolManagement_Call) Run(run func(_a0 context.Context, _a1 *container.SetNodePoolManagementRequest)) *ClusterManagerServer_SetNodePoolManagement_Call

+ type ClusterManagerServer_SetNodePoolSize_Call struct

+ func (_c *ClusterManagerServer_SetNodePoolSize_Call) Return(_a0 *container.Operation, _a1 error) *ClusterManagerServer_SetNodePoolSize_Call

+ func (_c *ClusterManagerServer_SetNodePoolSize_Call) Run(run func(_a0 context.Context, _a1 *container.SetNodePoolSizeRequest)) *ClusterManagerServer_SetNodePoolSize_Call

+ type ClusterManagerServer_StartIPRotation_Call struct

+ func (_c *ClusterManagerServer_StartIPRotation_Call) Return(_a0 *container.Operation, _a1 error) *ClusterManagerServer_StartIPRotation_Call

+ func (_c *ClusterManagerServer_StartIPRotation_Call) Run(run func(_a0 context.Context, _a1 *container.StartIPRotationRequest)) *ClusterManagerServer_StartIPRotation_Call

+ type ClusterManagerServer_UpdateCluster_Call struct

+ func (_c *ClusterManagerServer_UpdateCluster_Call) Return(_a0 *container.Operation, _a1 error) *ClusterManagerServer_UpdateCluster_Call

+ func (_c *ClusterManagerServer_UpdateCluster_Call) Run(run func(_a0 context.Context, _a1 *container.UpdateClusterRequest)) *ClusterManagerServer_UpdateCluster_Call

+ type ClusterManagerServer_UpdateMaster_Call struct

+ func (_c *ClusterManagerServer_UpdateMaster_Call) Return(_a0 *container.Operation, _a1 error) *ClusterManagerServer_UpdateMaster_Call

+ func (_c *ClusterManagerServer_UpdateMaster_Call) Run(run func(_a0 context.Context, _a1 *container.UpdateMasterRequest)) *ClusterManagerServer_UpdateMaster_Call

+ type ClusterManagerServer_UpdateNodePool_Call struct

+ func (_c *ClusterManagerServer_UpdateNodePool_Call) Return(_a0 *container.Operation, _a1 error) *ClusterManagerServer_UpdateNodePool_Call

+ func (_c *ClusterManagerServer_UpdateNodePool_Call) Run(run func(_a0 context.Context, _a1 *container.UpdateNodePoolRequest)) *ClusterManagerServer_UpdateNodePool_Call

+ type PublisherServer struct

+ func NewPublisherServer(t mockConstructorTestingTNewPublisherServer) *PublisherServer

+ func (_m *PublisherServer) CreateTopic(_a0 context.Context, _a1 *pubsub.Topic) (*pubsub.Topic, error)

+ func (_m *PublisherServer) DeleteTopic(_a0 context.Context, _a1 *pubsub.DeleteTopicRequest) (*emptypb.Empty, error)

+ func (_m *PublisherServer) DetachSubscription(_a0 context.Context, _a1 *pubsub.DetachSubscriptionRequest) (*pubsub.DetachSubscriptionResponse, error)

+ func (_m *PublisherServer) EXPECT() *PublisherServer_Expecter

+ func (_m *PublisherServer) GetTopic(_a0 context.Context, _a1 *pubsub.GetTopicRequest) (*pubsub.Topic, error)

+ func (_m *PublisherServer) ListTopicSnapshots(_a0 context.Context, _a1 *pubsub.ListTopicSnapshotsRequest) (*pubsub.ListTopicSnapshotsResponse, error)

+ func (_m *PublisherServer) ListTopicSubscriptions(_a0 context.Context, _a1 *pubsub.ListTopicSubscriptionsRequest) (*pubsub.ListTopicSubscriptionsResponse, error)

+ func (_m *PublisherServer) ListTopics(_a0 context.Context, _a1 *pubsub.ListTopicsRequest) (*pubsub.ListTopicsResponse, error)

+ func (_m *PublisherServer) Publish(_a0 context.Context, _a1 *pubsub.PublishRequest) (*pubsub.PublishResponse, error)

+ func (_m *PublisherServer) UpdateTopic(_a0 context.Context, _a1 *pubsub.UpdateTopicRequest) (*pubsub.Topic, error)

+ type PublisherServer_CreateTopic_Call struct

+ func (_c *PublisherServer_CreateTopic_Call) Return(_a0 *pubsub.Topic, _a1 error) *PublisherServer_CreateTopic_Call

+ func (_c *PublisherServer_CreateTopic_Call) Run(run func(_a0 context.Context, _a1 *pubsub.Topic)) *PublisherServer_CreateTopic_Call

+ type PublisherServer_DeleteTopic_Call struct

+ func (_c *PublisherServer_DeleteTopic_Call) Return(_a0 *emptypb.Empty, _a1 error) *PublisherServer_DeleteTopic_Call

+ func (_c *PublisherServer_DeleteTopic_Call) Run(run func(_a0 context.Context, _a1 *pubsub.DeleteTopicRequest)) *PublisherServer_DeleteTopic_Call

+ type PublisherServer_DetachSubscription_Call struct

+ func (_c *PublisherServer_DetachSubscription_Call) Return(_a0 *pubsub.DetachSubscriptionResponse, _a1 error) *PublisherServer_DetachSubscription_Call

+ func (_c *PublisherServer_DetachSubscription_Call) Run(run func(_a0 context.Context, _a1 *pubsub.DetachSubscriptionRequest)) *PublisherServer_DetachSubscription_Call

+ type PublisherServer_Expecter struct

+ func (_e *PublisherServer_Expecter) CreateTopic(_a0 interface{}, _a1 interface{}) *PublisherServer_CreateTopic_Call

+ func (_e *PublisherServer_Expecter) DeleteTopic(_a0 interface{}, _a1 interface{}) *PublisherServer_DeleteTopic_Call

+ func (_e *PublisherServer_Expecter) DetachSubscription(_a0 interface{}, _a1 interface{}) *PublisherServer_DetachSubscription_Call

+ func (_e *PublisherServer_Expecter) GetTopic(_a0 interface{}, _a1 interface{}) *PublisherServer_GetTopic_Call

+ func (_e *PublisherServer_Expecter) ListTopicSnapshots(_a0 interface{}, _a1 interface{}) *PublisherServer_ListTopicSnapshots_Call

+ func (_e *PublisherServer_Expecter) ListTopicSubscriptions(_a0 interface{}, _a1 interface{}) *PublisherServer_ListTopicSubscriptions_Call

+ func (_e *PublisherServer_Expecter) ListTopics(_a0 interface{}, _a1 interface{}) *PublisherServer_ListTopics_Call

+ func (_e *PublisherServer_Expecter) Publish(_a0 interface{}, _a1 interface{}) *PublisherServer_Publish_Call

+ func (_e *PublisherServer_Expecter) UpdateTopic(_a0 interface{}, _a1 interface{}) *PublisherServer_UpdateTopic_Call

+ type PublisherServer_GetTopic_Call struct

+ func (_c *PublisherServer_GetTopic_Call) Return(_a0 *pubsub.Topic, _a1 error) *PublisherServer_GetTopic_Call

+ func (_c *PublisherServer_GetTopic_Call) Run(run func(_a0 context.Context, _a1 *pubsub.GetTopicRequest)) *PublisherServer_GetTopic_Call

+ type PublisherServer_ListTopicSnapshots_Call struct

+ func (_c *PublisherServer_ListTopicSnapshots_Call) Return(_a0 *pubsub.ListTopicSnapshotsResponse, _a1 error) *PublisherServer_ListTopicSnapshots_Call

+ func (_c *PublisherServer_ListTopicSnapshots_Call) Run(run func(_a0 context.Context, _a1 *pubsub.ListTopicSnapshotsRequest)) *PublisherServer_ListTopicSnapshots_Call

+ type PublisherServer_ListTopicSubscriptions_Call struct

+ func (_c *PublisherServer_ListTopicSubscriptions_Call) Return(_a0 *pubsub.ListTopicSubscriptionsResponse, _a1 error) *PublisherServer_ListTopicSubscriptions_Call

+ func (_c *PublisherServer_ListTopicSubscriptions_Call) Run(run func(_a0 context.Context, _a1 *pubsub.ListTopicSubscriptionsRequest)) *PublisherServer_ListTopicSubscriptions_Call

+ type PublisherServer_ListTopics_Call struct

+ func (_c *PublisherServer_ListTopics_Call) Return(_a0 *pubsub.ListTopicsResponse, _a1 error) *PublisherServer_ListTopics_Call

+ func (_c *PublisherServer_ListTopics_Call) Run(run func(_a0 context.Context, _a1 *pubsub.ListTopicsRequest)) *PublisherServer_ListTopics_Call

+ type PublisherServer_Publish_Call struct

+ func (_c *PublisherServer_Publish_Call) Return(_a0 *pubsub.PublishResponse, _a1 error) *PublisherServer_Publish_Call

+ func (_c *PublisherServer_Publish_Call) Run(run func(_a0 context.Context, _a1 *pubsub.PublishRequest)) *PublisherServer_Publish_Call

+ type PublisherServer_UpdateTopic_Call struct

+ func (_c *PublisherServer_UpdateTopic_Call) Return(_a0 *pubsub.Topic, _a1 error) *PublisherServer_UpdateTopic_Call

+ func (_c *PublisherServer_UpdateTopic_Call) Run(run func(_a0 context.Context, _a1 *pubsub.UpdateTopicRequest)) *PublisherServer_UpdateTopic_Call

+ type SubscriberServer struct

+ func NewSubscriberServer(t mockConstructorTestingTNewSubscriberServer) *SubscriberServer

+ func (_m *SubscriberServer) Acknowledge(_a0 context.Context, _a1 *pubsub.AcknowledgeRequest) (*emptypb.Empty, error)

+ func (_m *SubscriberServer) CreateSnapshot(_a0 context.Context, _a1 *pubsub.CreateSnapshotRequest) (*pubsub.Snapshot, error)

+ func (_m *SubscriberServer) CreateSubscription(_a0 context.Context, _a1 *pubsub.Subscription) (*pubsub.Subscription, error)

+ func (_m *SubscriberServer) DeleteSnapshot(_a0 context.Context, _a1 *pubsub.DeleteSnapshotRequest) (*emptypb.Empty, error)

+ func (_m *SubscriberServer) DeleteSubscription(_a0 context.Context, _a1 *pubsub.DeleteSubscriptionRequest) (*emptypb.Empty, error)

+ func (_m *SubscriberServer) EXPECT() *SubscriberServer_Expecter

+ func (_m *SubscriberServer) GetSnapshot(_a0 context.Context, _a1 *pubsub.GetSnapshotRequest) (*pubsub.Snapshot, error)

+ func (_m *SubscriberServer) GetSubscription(_a0 context.Context, _a1 *pubsub.GetSubscriptionRequest) (*pubsub.Subscription, error)

+ func (_m *SubscriberServer) ListSnapshots(_a0 context.Context, _a1 *pubsub.ListSnapshotsRequest) (*pubsub.ListSnapshotsResponse, error)

+ func (_m *SubscriberServer) ListSubscriptions(_a0 context.Context, _a1 *pubsub.ListSubscriptionsRequest) (*pubsub.ListSubscriptionsResponse, error)

+ func (_m *SubscriberServer) ModifyAckDeadline(_a0 context.Context, _a1 *pubsub.ModifyAckDeadlineRequest) (*emptypb.Empty, error)

+ func (_m *SubscriberServer) ModifyPushConfig(_a0 context.Context, _a1 *pubsub.ModifyPushConfigRequest) (*emptypb.Empty, error)

+ func (_m *SubscriberServer) Pull(_a0 context.Context, _a1 *pubsub.PullRequest) (*pubsub.PullResponse, error)

+ func (_m *SubscriberServer) Seek(_a0 context.Context, _a1 *pubsub.SeekRequest) (*pubsub.SeekResponse, error)

+ func (_m *SubscriberServer) StreamingPull(_a0 pubsub.Subscriber_StreamingPullServer) error

+ func (_m *SubscriberServer) UpdateSnapshot(_a0 context.Context, _a1 *pubsub.UpdateSnapshotRequest) (*pubsub.Snapshot, error)

+ func (_m *SubscriberServer) UpdateSubscription(_a0 context.Context, _a1 *pubsub.UpdateSubscriptionRequest) (*pubsub.Subscription, error)

+ type SubscriberServer_Acknowledge_Call struct

+ func (_c *SubscriberServer_Acknowledge_Call) Return(_a0 *emptypb.Empty, _a1 error) *SubscriberServer_Acknowledge_Call

+ func (_c *SubscriberServer_Acknowledge_Call) Run(run func(_a0 context.Context, _a1 *pubsub.AcknowledgeRequest)) *SubscriberServer_Acknowledge_Call

+ type SubscriberServer_CreateSnapshot_Call struct

+ func (_c *SubscriberServer_CreateSnapshot_Call) Return(_a0 *pubsub.Snapshot, _a1 error) *SubscriberServer_CreateSnapshot_Call

+ func (_c *SubscriberServer_CreateSnapshot_Call) Run(run func(_a0 context.Context, _a1 *pubsub.CreateSnapshotRequest)) *SubscriberServer_CreateSnapshot_Call

+ type SubscriberServer_CreateSubscription_Call struct

+ func (_c *SubscriberServer_CreateSubscription_Call) Return(_a0 *pubsub.Subscription, _a1 error) *SubscriberServer_CreateSubscription_Call

+ func (_c *SubscriberServer_CreateSubscription_Call) Run(run func(_a0 context.Context, _a1 *pubsub.Subscription)) *SubscriberServer_CreateSubscription_Call

+ type SubscriberServer_DeleteSnapshot_Call struct

+ func (_c *SubscriberServer_DeleteSnapshot_Call) Return(_a0 *emptypb.Empty, _a1 error) *SubscriberServer_DeleteSnapshot_Call

+ func (_c *SubscriberServer_DeleteSnapshot_Call) Run(run func(_a0 context.Context, _a1 *pubsub.DeleteSnapshotRequest)) *SubscriberServer_DeleteSnapshot_Call

+ type SubscriberServer_DeleteSubscription_Call struct

+ func (_c *SubscriberServer_DeleteSubscription_Call) Return(_a0 *emptypb.Empty, _a1 error) *SubscriberServer_DeleteSubscription_Call

+ func (_c *SubscriberServer_DeleteSubscription_Call) Run(run func(_a0 context.Context, _a1 *pubsub.DeleteSubscriptionRequest)) *SubscriberServer_DeleteSubscription_Call

+ type SubscriberServer_Expecter struct

+ func (_e *SubscriberServer_Expecter) Acknowledge(_a0 interface{}, _a1 interface{}) *SubscriberServer_Acknowledge_Call

+ func (_e *SubscriberServer_Expecter) CreateSnapshot(_a0 interface{}, _a1 interface{}) *SubscriberServer_CreateSnapshot_Call

+ func (_e *SubscriberServer_Expecter) CreateSubscription(_a0 interface{}, _a1 interface{}) *SubscriberServer_CreateSubscription_Call

+ func (_e *SubscriberServer_Expecter) DeleteSnapshot(_a0 interface{}, _a1 interface{}) *SubscriberServer_DeleteSnapshot_Call

+ func (_e *SubscriberServer_Expecter) DeleteSubscription(_a0 interface{}, _a1 interface{}) *SubscriberServer_DeleteSubscription_Call

+ func (_e *SubscriberServer_Expecter) GetSnapshot(_a0 interface{}, _a1 interface{}) *SubscriberServer_GetSnapshot_Call

+ func (_e *SubscriberServer_Expecter) GetSubscription(_a0 interface{}, _a1 interface{}) *SubscriberServer_GetSubscription_Call

+ func (_e *SubscriberServer_Expecter) ListSnapshots(_a0 interface{}, _a1 interface{}) *SubscriberServer_ListSnapshots_Call

+ func (_e *SubscriberServer_Expecter) ListSubscriptions(_a0 interface{}, _a1 interface{}) *SubscriberServer_ListSubscriptions_Call

+ func (_e *SubscriberServer_Expecter) ModifyAckDeadline(_a0 interface{}, _a1 interface{}) *SubscriberServer_ModifyAckDeadline_Call

+ func (_e *SubscriberServer_Expecter) ModifyPushConfig(_a0 interface{}, _a1 interface{}) *SubscriberServer_ModifyPushConfig_Call

+ func (_e *SubscriberServer_Expecter) Pull(_a0 interface{}, _a1 interface{}) *SubscriberServer_Pull_Call

+ func (_e *SubscriberServer_Expecter) Seek(_a0 interface{}, _a1 interface{}) *SubscriberServer_Seek_Call

+ func (_e *SubscriberServer_Expecter) StreamingPull(_a0 interface{}) *SubscriberServer_StreamingPull_Call

+ func (_e *SubscriberServer_Expecter) UpdateSnapshot(_a0 interface{}, _a1 interface{}) *SubscriberServer_UpdateSnapshot_Call

+ func (_e *SubscriberServer_Expecter) UpdateSubscription(_a0 interface{}, _a1 interface{}) *SubscriberServer_UpdateSubscription_Call

+ type SubscriberServer_GetSnapshot_Call struct

+ func (_c *SubscriberServer_GetSnapshot_Call) Return(_a0 *pubsub.Snapshot, _a1 error) *SubscriberServer_GetSnapshot_Call

+ func (_c *SubscriberServer_GetSnapshot_Call) Run(run func(_a0 context.Context, _a1 *pubsub.GetSnapshotRequest)) *SubscriberServer_GetSnapshot_Call

+ type SubscriberServer_GetSubscription_Call struct

+ func (_c *SubscriberServer_GetSubscription_Call) Return(_a0 *pubsub.Subscription, _a1 error) *SubscriberServer_GetSubscription_Call

+ func (_c *SubscriberServer_GetSubscription_Call) Run(run func(_a0 context.Context, _a1 *pubsub.GetSubscriptionRequest)) *SubscriberServer_GetSubscription_Call

+ type SubscriberServer_ListSnapshots_Call struct

+ func (_c *SubscriberServer_ListSnapshots_Call) Return(_a0 *pubsub.ListSnapshotsResponse, _a1 error) *SubscriberServer_ListSnapshots_Call

+ func (_c *SubscriberServer_ListSnapshots_Call) Run(run func(_a0 context.Context, _a1 *pubsub.ListSnapshotsRequest)) *SubscriberServer_ListSnapshots_Call

+ type SubscriberServer_ListSubscriptions_Call struct

+ func (_c *SubscriberServer_ListSubscriptions_Call) Return(_a0 *pubsub.ListSubscriptionsResponse, _a1 error) *SubscriberServer_ListSubscriptions_Call

+ func (_c *SubscriberServer_ListSubscriptions_Call) Run(run func(_a0 context.Context, _a1 *pubsub.ListSubscriptionsRequest)) *SubscriberServer_ListSubscriptions_Call

+ type SubscriberServer_ModifyAckDeadline_Call struct

+ func (_c *SubscriberServer_ModifyAckDeadline_Call) Return(_a0 *emptypb.Empty, _a1 error) *SubscriberServer_ModifyAckDeadline_Call

+ func (_c *SubscriberServer_ModifyAckDeadline_Call) Run(run func(_a0 context.Context, _a1 *pubsub.ModifyAckDeadlineRequest)) *SubscriberServer_ModifyAckDeadline_Call

+ type SubscriberServer_ModifyPushConfig_Call struct

+ func (_c *SubscriberServer_ModifyPushConfig_Call) Return(_a0 *emptypb.Empty, _a1 error) *SubscriberServer_ModifyPushConfig_Call

+ func (_c *SubscriberServer_ModifyPushConfig_Call) Run(run func(_a0 context.Context, _a1 *pubsub.ModifyPushConfigRequest)) *SubscriberServer_ModifyPushConfig_Call

+ type SubscriberServer_Pull_Call struct

+ func (_c *SubscriberServer_Pull_Call) Return(_a0 *pubsub.PullResponse, _a1 error) *SubscriberServer_Pull_Call

+ func (_c *SubscriberServer_Pull_Call) Run(run func(_a0 context.Context, _a1 *pubsub.PullRequest)) *SubscriberServer_Pull_Call

+ type SubscriberServer_Seek_Call struct

+ func (_c *SubscriberServer_Seek_Call) Return(_a0 *pubsub.SeekResponse, _a1 error) *SubscriberServer_Seek_Call

+ func (_c *SubscriberServer_Seek_Call) Run(run func(_a0 context.Context, _a1 *pubsub.SeekRequest)) *SubscriberServer_Seek_Call

+ type SubscriberServer_StreamingPull_Call struct

+ func (_c *SubscriberServer_StreamingPull_Call) Return(_a0 error) *SubscriberServer_StreamingPull_Call

+ func (_c *SubscriberServer_StreamingPull_Call) Run(run func(_a0 pubsub.Subscriber_StreamingPullServer)) *SubscriberServer_StreamingPull_Call

+ type SubscriberServer_UpdateSnapshot_Call struct

+ func (_c *SubscriberServer_UpdateSnapshot_Call) Return(_a0 *pubsub.Snapshot, _a1 error) *SubscriberServer_UpdateSnapshot_Call

+ func (_c *SubscriberServer_UpdateSnapshot_Call) Run(run func(_a0 context.Context, _a1 *pubsub.UpdateSnapshotRequest)) *SubscriberServer_UpdateSnapshot_Call

+ type SubscriberServer_UpdateSubscription_Call struct

+ func (_c *SubscriberServer_UpdateSubscription_Call) Return(_a0 *pubsub.Subscription, _a1 error) *SubscriberServer_UpdateSubscription_Call

+ func (_c *SubscriberServer_UpdateSubscription_Call) Run(run func(_a0 context.Context, _a1 *pubsub.UpdateSubscriptionRequest)) *SubscriberServer_UpdateSubscription_Call