mocks

Documentation

Index

• type ClusterManagerServer
  • func NewClusterManagerServer(t interface{ ... }) *ClusterManagerServer
  • func (_m *ClusterManagerServer) CancelOperation(_a0 context.Context, _a1 *containerpb.CancelOperationRequest) (*emptypb.Empty, error)
  • func (_m *ClusterManagerServer) CheckAutopilotCompatibility(_a0 context.Context, _a1 *containerpb.CheckAutopilotCompatibilityRequest) (*containerpb.CheckAutopilotCompatibilityResponse, error)
  • func (_m *ClusterManagerServer) CompleteIPRotation(_a0 context.Context, _a1 *containerpb.CompleteIPRotationRequest) (*containerpb.Operation, error)
  • func (_m *ClusterManagerServer) CompleteNodePoolUpgrade(_a0 context.Context, _a1 *containerpb.CompleteNodePoolUpgradeRequest) (*emptypb.Empty, error)
  • func (_m *ClusterManagerServer) CreateCluster(_a0 context.Context, _a1 *containerpb.CreateClusterRequest) (*containerpb.Operation, error)
  • func (_m *ClusterManagerServer) CreateNodePool(_a0 context.Context, _a1 *containerpb.CreateNodePoolRequest) (*containerpb.Operation, error)
  • func (_m *ClusterManagerServer) DeleteCluster(_a0 context.Context, _a1 *containerpb.DeleteClusterRequest) (*containerpb.Operation, error)
  • func (_m *ClusterManagerServer) DeleteNodePool(_a0 context.Context, _a1 *containerpb.DeleteNodePoolRequest) (*containerpb.Operation, error)
  • func (_m *ClusterManagerServer) EXPECT() *ClusterManagerServer_Expecter
  • func (_m *ClusterManagerServer) GetCluster(_a0 context.Context, _a1 *containerpb.GetClusterRequest) (*containerpb.Cluster, error)
  • func (_m *ClusterManagerServer) GetJSONWebKeys(_a0 context.Context, _a1 *containerpb.GetJSONWebKeysRequest) (*containerpb.GetJSONWebKeysResponse, error)
  • func (_m *ClusterManagerServer) GetNodePool(_a0 context.Context, _a1 *containerpb.GetNodePoolRequest) (*containerpb.NodePool, error)
  • func (_m *ClusterManagerServer) GetOperation(_a0 context.Context, _a1 *containerpb.GetOperationRequest) (*containerpb.Operation, error)
  • func (_m *ClusterManagerServer) GetServerConfig(_a0 context.Context, _a1 *containerpb.GetServerConfigRequest) (*containerpb.ServerConfig, error)
  • func (_m *ClusterManagerServer) ListClusters(_a0 context.Context, _a1 *containerpb.ListClustersRequest) (*containerpb.ListClustersResponse, error)
  • func (_m *ClusterManagerServer) ListNodePools(_a0 context.Context, _a1 *containerpb.ListNodePoolsRequest) (*containerpb.ListNodePoolsResponse, error)
  • func (_m *ClusterManagerServer) ListOperations(_a0 context.Context, _a1 *containerpb.ListOperationsRequest) (*containerpb.ListOperationsResponse, error)
  • func (_m *ClusterManagerServer) ListUsableSubnetworks(_a0 context.Context, _a1 *containerpb.ListUsableSubnetworksRequest) (*containerpb.ListUsableSubnetworksResponse, error)
  • func (_m *ClusterManagerServer) RollbackNodePoolUpgrade(_a0 context.Context, _a1 *containerpb.RollbackNodePoolUpgradeRequest) (*containerpb.Operation, error)
  • func (_m *ClusterManagerServer) SetAddonsConfig(_a0 context.Context, _a1 *containerpb.SetAddonsConfigRequest) (*containerpb.Operation, error)
  • func (_m *ClusterManagerServer) SetLabels(_a0 context.Context, _a1 *containerpb.SetLabelsRequest) (*containerpb.Operation, error)
  • func (_m *ClusterManagerServer) SetLegacyAbac(_a0 context.Context, _a1 *containerpb.SetLegacyAbacRequest) (*containerpb.Operation, error)
  • func (_m *ClusterManagerServer) SetLocations(_a0 context.Context, _a1 *containerpb.SetLocationsRequest) (*containerpb.Operation, error)
  • func (_m *ClusterManagerServer) SetLoggingService(_a0 context.Context, _a1 *containerpb.SetLoggingServiceRequest) (*containerpb.Operation, error)
  • func (_m *ClusterManagerServer) SetMaintenancePolicy(_a0 context.Context, _a1 *containerpb.SetMaintenancePolicyRequest) (*containerpb.Operation, error)
  • func (_m *ClusterManagerServer) SetMasterAuth(_a0 context.Context, _a1 *containerpb.SetMasterAuthRequest) (*containerpb.Operation, error)
  • func (_m *ClusterManagerServer) SetMonitoringService(_a0 context.Context, _a1 *containerpb.SetMonitoringServiceRequest) (*containerpb.Operation, error)
  • func (_m *ClusterManagerServer) SetNetworkPolicy(_a0 context.Context, _a1 *containerpb.SetNetworkPolicyRequest) (*containerpb.Operation, error)
  • func (_m *ClusterManagerServer) SetNodePoolAutoscaling(_a0 context.Context, _a1 *containerpb.SetNodePoolAutoscalingRequest) (*containerpb.Operation, error)
  • func (_m *ClusterManagerServer) SetNodePoolManagement(_a0 context.Context, _a1 *containerpb.SetNodePoolManagementRequest) (*containerpb.Operation, error)
  • func (_m *ClusterManagerServer) SetNodePoolSize(_a0 context.Context, _a1 *containerpb.SetNodePoolSizeRequest) (*containerpb.Operation, error)
  • func (_m *ClusterManagerServer) StartIPRotation(_a0 context.Context, _a1 *containerpb.StartIPRotationRequest) (*containerpb.Operation, error)
  • func (_m *ClusterManagerServer) UpdateCluster(_a0 context.Context, _a1 *containerpb.UpdateClusterRequest) (*containerpb.Operation, error)
  • func (_m *ClusterManagerServer) UpdateMaster(_a0 context.Context, _a1 *containerpb.UpdateMasterRequest) (*containerpb.Operation, error)
  • func (_m *ClusterManagerServer) UpdateNodePool(_a0 context.Context, _a1 *containerpb.UpdateNodePoolRequest) (*containerpb.Operation, error)
• type ClusterManagerServer_CancelOperation_Call
  • 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 *containerpb.CancelOperationRequest)) *ClusterManagerServer_CancelOperation_Call
  • func (_c *ClusterManagerServer_CancelOperation_Call) RunAndReturn(...) *ClusterManagerServer_CancelOperation_Call
• type ClusterManagerServer_CheckAutopilotCompatibility_Call
  • 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_CompleteIPRotation_Call
  • func (_c *ClusterManagerServer_CompleteIPRotation_Call) Return(_a0 *containerpb.Operation, _a1 error) *ClusterManagerServer_CompleteIPRotation_Call
  • func (_c *ClusterManagerServer_CompleteIPRotation_Call) Run(run func(_a0 context.Context, _a1 *containerpb.CompleteIPRotationRequest)) *ClusterManagerServer_CompleteIPRotation_Call
  • func (_c *ClusterManagerServer_CompleteIPRotation_Call) RunAndReturn(...) *ClusterManagerServer_CompleteIPRotation_Call
• type ClusterManagerServer_CompleteNodePoolUpgrade_Call
  • 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 *containerpb.CompleteNodePoolUpgradeRequest)) *ClusterManagerServer_CompleteNodePoolUpgrade_Call
  • func (_c *ClusterManagerServer_CompleteNodePoolUpgrade_Call) RunAndReturn(...) *ClusterManagerServer_CompleteNodePoolUpgrade_Call
• type ClusterManagerServer_CreateCluster_Call
  • func (_c *ClusterManagerServer_CreateCluster_Call) Return(_a0 *containerpb.Operation, _a1 error) *ClusterManagerServer_CreateCluster_Call
  • func (_c *ClusterManagerServer_CreateCluster_Call) Run(run func(_a0 context.Context, _a1 *containerpb.CreateClusterRequest)) *ClusterManagerServer_CreateCluster_Call
  • func (_c *ClusterManagerServer_CreateCluster_Call) RunAndReturn(...) *ClusterManagerServer_CreateCluster_Call
• type ClusterManagerServer_CreateNodePool_Call
  • func (_c *ClusterManagerServer_CreateNodePool_Call) Return(_a0 *containerpb.Operation, _a1 error) *ClusterManagerServer_CreateNodePool_Call
  • func (_c *ClusterManagerServer_CreateNodePool_Call) Run(run func(_a0 context.Context, _a1 *containerpb.CreateNodePoolRequest)) *ClusterManagerServer_CreateNodePool_Call
  • func (_c *ClusterManagerServer_CreateNodePool_Call) RunAndReturn(...) *ClusterManagerServer_CreateNodePool_Call
• type ClusterManagerServer_DeleteCluster_Call
  • func (_c *ClusterManagerServer_DeleteCluster_Call) Return(_a0 *containerpb.Operation, _a1 error) *ClusterManagerServer_DeleteCluster_Call
  • func (_c *ClusterManagerServer_DeleteCluster_Call) Run(run func(_a0 context.Context, _a1 *containerpb.DeleteClusterRequest)) *ClusterManagerServer_DeleteCluster_Call
  • func (_c *ClusterManagerServer_DeleteCluster_Call) RunAndReturn(...) *ClusterManagerServer_DeleteCluster_Call
• type ClusterManagerServer_DeleteNodePool_Call
  • func (_c *ClusterManagerServer_DeleteNodePool_Call) Return(_a0 *containerpb.Operation, _a1 error) *ClusterManagerServer_DeleteNodePool_Call
  • func (_c *ClusterManagerServer_DeleteNodePool_Call) Run(run func(_a0 context.Context, _a1 *containerpb.DeleteNodePoolRequest)) *ClusterManagerServer_DeleteNodePool_Call
  • func (_c *ClusterManagerServer_DeleteNodePool_Call) RunAndReturn(...) *ClusterManagerServer_DeleteNodePool_Call
• type ClusterManagerServer_Expecter
  • func (_e *ClusterManagerServer_Expecter) CancelOperation(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_CancelOperation_Call
  • func (_e *ClusterManagerServer_Expecter) CheckAutopilotCompatibility(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_CheckAutopilotCompatibility_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
  • func (_c *ClusterManagerServer_GetCluster_Call) Return(_a0 *containerpb.Cluster, _a1 error) *ClusterManagerServer_GetCluster_Call
  • func (_c *ClusterManagerServer_GetCluster_Call) Run(run func(_a0 context.Context, _a1 *containerpb.GetClusterRequest)) *ClusterManagerServer_GetCluster_Call
  • func (_c *ClusterManagerServer_GetCluster_Call) RunAndReturn(...) *ClusterManagerServer_GetCluster_Call
• type ClusterManagerServer_GetJSONWebKeys_Call
  • func (_c *ClusterManagerServer_GetJSONWebKeys_Call) Return(_a0 *containerpb.GetJSONWebKeysResponse, _a1 error) *ClusterManagerServer_GetJSONWebKeys_Call
  • func (_c *ClusterManagerServer_GetJSONWebKeys_Call) Run(run func(_a0 context.Context, _a1 *containerpb.GetJSONWebKeysRequest)) *ClusterManagerServer_GetJSONWebKeys_Call
  • func (_c *ClusterManagerServer_GetJSONWebKeys_Call) RunAndReturn(...) *ClusterManagerServer_GetJSONWebKeys_Call
• type ClusterManagerServer_GetNodePool_Call
  • func (_c *ClusterManagerServer_GetNodePool_Call) Return(_a0 *containerpb.NodePool, _a1 error) *ClusterManagerServer_GetNodePool_Call
  • func (_c *ClusterManagerServer_GetNodePool_Call) Run(run func(_a0 context.Context, _a1 *containerpb.GetNodePoolRequest)) *ClusterManagerServer_GetNodePool_Call
  • func (_c *ClusterManagerServer_GetNodePool_Call) RunAndReturn(...) *ClusterManagerServer_GetNodePool_Call
• type ClusterManagerServer_GetOperation_Call
  • func (_c *ClusterManagerServer_GetOperation_Call) Return(_a0 *containerpb.Operation, _a1 error) *ClusterManagerServer_GetOperation_Call
  • func (_c *ClusterManagerServer_GetOperation_Call) Run(run func(_a0 context.Context, _a1 *containerpb.GetOperationRequest)) *ClusterManagerServer_GetOperation_Call
  • func (_c *ClusterManagerServer_GetOperation_Call) RunAndReturn(...) *ClusterManagerServer_GetOperation_Call
• type ClusterManagerServer_GetServerConfig_Call
  • func (_c *ClusterManagerServer_GetServerConfig_Call) Return(_a0 *containerpb.ServerConfig, _a1 error) *ClusterManagerServer_GetServerConfig_Call
  • func (_c *ClusterManagerServer_GetServerConfig_Call) Run(run func(_a0 context.Context, _a1 *containerpb.GetServerConfigRequest)) *ClusterManagerServer_GetServerConfig_Call
  • func (_c *ClusterManagerServer_GetServerConfig_Call) RunAndReturn(...) *ClusterManagerServer_GetServerConfig_Call
• type ClusterManagerServer_ListClusters_Call
  • func (_c *ClusterManagerServer_ListClusters_Call) Return(_a0 *containerpb.ListClustersResponse, _a1 error) *ClusterManagerServer_ListClusters_Call
  • func (_c *ClusterManagerServer_ListClusters_Call) Run(run func(_a0 context.Context, _a1 *containerpb.ListClustersRequest)) *ClusterManagerServer_ListClusters_Call
  • func (_c *ClusterManagerServer_ListClusters_Call) RunAndReturn(...) *ClusterManagerServer_ListClusters_Call
• type ClusterManagerServer_ListNodePools_Call
  • func (_c *ClusterManagerServer_ListNodePools_Call) Return(_a0 *containerpb.ListNodePoolsResponse, _a1 error) *ClusterManagerServer_ListNodePools_Call
  • func (_c *ClusterManagerServer_ListNodePools_Call) Run(run func(_a0 context.Context, _a1 *containerpb.ListNodePoolsRequest)) *ClusterManagerServer_ListNodePools_Call
  • func (_c *ClusterManagerServer_ListNodePools_Call) RunAndReturn(...) *ClusterManagerServer_ListNodePools_Call
• type ClusterManagerServer_ListOperations_Call
  • func (_c *ClusterManagerServer_ListOperations_Call) Return(_a0 *containerpb.ListOperationsResponse, _a1 error) *ClusterManagerServer_ListOperations_Call
  • func (_c *ClusterManagerServer_ListOperations_Call) Run(run func(_a0 context.Context, _a1 *containerpb.ListOperationsRequest)) *ClusterManagerServer_ListOperations_Call
  • func (_c *ClusterManagerServer_ListOperations_Call) RunAndReturn(...) *ClusterManagerServer_ListOperations_Call
• type ClusterManagerServer_ListUsableSubnetworks_Call
  • func (_c *ClusterManagerServer_ListUsableSubnetworks_Call) Return(_a0 *containerpb.ListUsableSubnetworksResponse, _a1 error) *ClusterManagerServer_ListUsableSubnetworks_Call
  • func (_c *ClusterManagerServer_ListUsableSubnetworks_Call) Run(run func(_a0 context.Context, _a1 *containerpb.ListUsableSubnetworksRequest)) *ClusterManagerServer_ListUsableSubnetworks_Call
  • func (_c *ClusterManagerServer_ListUsableSubnetworks_Call) RunAndReturn(...) *ClusterManagerServer_ListUsableSubnetworks_Call
• type ClusterManagerServer_RollbackNodePoolUpgrade_Call
  • func (_c *ClusterManagerServer_RollbackNodePoolUpgrade_Call) Return(_a0 *containerpb.Operation, _a1 error) *ClusterManagerServer_RollbackNodePoolUpgrade_Call
  • func (_c *ClusterManagerServer_RollbackNodePoolUpgrade_Call) Run(run func(_a0 context.Context, _a1 *containerpb.RollbackNodePoolUpgradeRequest)) *ClusterManagerServer_RollbackNodePoolUpgrade_Call
  • func (_c *ClusterManagerServer_RollbackNodePoolUpgrade_Call) RunAndReturn(...) *ClusterManagerServer_RollbackNodePoolUpgrade_Call
• type ClusterManagerServer_SetAddonsConfig_Call
  • func (_c *ClusterManagerServer_SetAddonsConfig_Call) Return(_a0 *containerpb.Operation, _a1 error) *ClusterManagerServer_SetAddonsConfig_Call
  • func (_c *ClusterManagerServer_SetAddonsConfig_Call) Run(run func(_a0 context.Context, _a1 *containerpb.SetAddonsConfigRequest)) *ClusterManagerServer_SetAddonsConfig_Call
  • func (_c *ClusterManagerServer_SetAddonsConfig_Call) RunAndReturn(...) *ClusterManagerServer_SetAddonsConfig_Call
• type ClusterManagerServer_SetLabels_Call
  • func (_c *ClusterManagerServer_SetLabels_Call) Return(_a0 *containerpb.Operation, _a1 error) *ClusterManagerServer_SetLabels_Call
  • func (_c *ClusterManagerServer_SetLabels_Call) Run(run func(_a0 context.Context, _a1 *containerpb.SetLabelsRequest)) *ClusterManagerServer_SetLabels_Call
  • func (_c *ClusterManagerServer_SetLabels_Call) RunAndReturn(...) *ClusterManagerServer_SetLabels_Call
• type ClusterManagerServer_SetLegacyAbac_Call
  • func (_c *ClusterManagerServer_SetLegacyAbac_Call) Return(_a0 *containerpb.Operation, _a1 error) *ClusterManagerServer_SetLegacyAbac_Call
  • func (_c *ClusterManagerServer_SetLegacyAbac_Call) Run(run func(_a0 context.Context, _a1 *containerpb.SetLegacyAbacRequest)) *ClusterManagerServer_SetLegacyAbac_Call
  • func (_c *ClusterManagerServer_SetLegacyAbac_Call) RunAndReturn(...) *ClusterManagerServer_SetLegacyAbac_Call
• type ClusterManagerServer_SetLocations_Call
  • func (_c *ClusterManagerServer_SetLocations_Call) Return(_a0 *containerpb.Operation, _a1 error) *ClusterManagerServer_SetLocations_Call
  • func (_c *ClusterManagerServer_SetLocations_Call) Run(run func(_a0 context.Context, _a1 *containerpb.SetLocationsRequest)) *ClusterManagerServer_SetLocations_Call
  • func (_c *ClusterManagerServer_SetLocations_Call) RunAndReturn(...) *ClusterManagerServer_SetLocations_Call
• type ClusterManagerServer_SetLoggingService_Call
  • func (_c *ClusterManagerServer_SetLoggingService_Call) Return(_a0 *containerpb.Operation, _a1 error) *ClusterManagerServer_SetLoggingService_Call
  • func (_c *ClusterManagerServer_SetLoggingService_Call) Run(run func(_a0 context.Context, _a1 *containerpb.SetLoggingServiceRequest)) *ClusterManagerServer_SetLoggingService_Call
  • func (_c *ClusterManagerServer_SetLoggingService_Call) RunAndReturn(...) *ClusterManagerServer_SetLoggingService_Call
• type ClusterManagerServer_SetMaintenancePolicy_Call
  • func (_c *ClusterManagerServer_SetMaintenancePolicy_Call) Return(_a0 *containerpb.Operation, _a1 error) *ClusterManagerServer_SetMaintenancePolicy_Call
  • func (_c *ClusterManagerServer_SetMaintenancePolicy_Call) Run(run func(_a0 context.Context, _a1 *containerpb.SetMaintenancePolicyRequest)) *ClusterManagerServer_SetMaintenancePolicy_Call
  • func (_c *ClusterManagerServer_SetMaintenancePolicy_Call) RunAndReturn(...) *ClusterManagerServer_SetMaintenancePolicy_Call
• type ClusterManagerServer_SetMasterAuth_Call
  • func (_c *ClusterManagerServer_SetMasterAuth_Call) Return(_a0 *containerpb.Operation, _a1 error) *ClusterManagerServer_SetMasterAuth_Call
  • func (_c *ClusterManagerServer_SetMasterAuth_Call) Run(run func(_a0 context.Context, _a1 *containerpb.SetMasterAuthRequest)) *ClusterManagerServer_SetMasterAuth_Call
  • func (_c *ClusterManagerServer_SetMasterAuth_Call) RunAndReturn(...) *ClusterManagerServer_SetMasterAuth_Call
• type ClusterManagerServer_SetMonitoringService_Call
  • func (_c *ClusterManagerServer_SetMonitoringService_Call) Return(_a0 *containerpb.Operation, _a1 error) *ClusterManagerServer_SetMonitoringService_Call
  • func (_c *ClusterManagerServer_SetMonitoringService_Call) Run(run func(_a0 context.Context, _a1 *containerpb.SetMonitoringServiceRequest)) *ClusterManagerServer_SetMonitoringService_Call
  • func (_c *ClusterManagerServer_SetMonitoringService_Call) RunAndReturn(...) *ClusterManagerServer_SetMonitoringService_Call
• type ClusterManagerServer_SetNetworkPolicy_Call
  • func (_c *ClusterManagerServer_SetNetworkPolicy_Call) Return(_a0 *containerpb.Operation, _a1 error) *ClusterManagerServer_SetNetworkPolicy_Call
  • func (_c *ClusterManagerServer_SetNetworkPolicy_Call) Run(run func(_a0 context.Context, _a1 *containerpb.SetNetworkPolicyRequest)) *ClusterManagerServer_SetNetworkPolicy_Call
  • func (_c *ClusterManagerServer_SetNetworkPolicy_Call) RunAndReturn(...) *ClusterManagerServer_SetNetworkPolicy_Call
• type ClusterManagerServer_SetNodePoolAutoscaling_Call
  • func (_c *ClusterManagerServer_SetNodePoolAutoscaling_Call) Return(_a0 *containerpb.Operation, _a1 error) *ClusterManagerServer_SetNodePoolAutoscaling_Call
  • func (_c *ClusterManagerServer_SetNodePoolAutoscaling_Call) Run(run func(_a0 context.Context, _a1 *containerpb.SetNodePoolAutoscalingRequest)) *ClusterManagerServer_SetNodePoolAutoscaling_Call
  • func (_c *ClusterManagerServer_SetNodePoolAutoscaling_Call) RunAndReturn(...) *ClusterManagerServer_SetNodePoolAutoscaling_Call
• type ClusterManagerServer_SetNodePoolManagement_Call
  • func (_c *ClusterManagerServer_SetNodePoolManagement_Call) Return(_a0 *containerpb.Operation, _a1 error) *ClusterManagerServer_SetNodePoolManagement_Call
  • func (_c *ClusterManagerServer_SetNodePoolManagement_Call) Run(run func(_a0 context.Context, _a1 *containerpb.SetNodePoolManagementRequest)) *ClusterManagerServer_SetNodePoolManagement_Call
  • func (_c *ClusterManagerServer_SetNodePoolManagement_Call) RunAndReturn(...) *ClusterManagerServer_SetNodePoolManagement_Call
• type ClusterManagerServer_SetNodePoolSize_Call
  • func (_c *ClusterManagerServer_SetNodePoolSize_Call) Return(_a0 *containerpb.Operation, _a1 error) *ClusterManagerServer_SetNodePoolSize_Call
  • func (_c *ClusterManagerServer_SetNodePoolSize_Call) Run(run func(_a0 context.Context, _a1 *containerpb.SetNodePoolSizeRequest)) *ClusterManagerServer_SetNodePoolSize_Call
  • func (_c *ClusterManagerServer_SetNodePoolSize_Call) RunAndReturn(...) *ClusterManagerServer_SetNodePoolSize_Call
• type ClusterManagerServer_StartIPRotation_Call
  • func (_c *ClusterManagerServer_StartIPRotation_Call) Return(_a0 *containerpb.Operation, _a1 error) *ClusterManagerServer_StartIPRotation_Call
  • func (_c *ClusterManagerServer_StartIPRotation_Call) Run(run func(_a0 context.Context, _a1 *containerpb.StartIPRotationRequest)) *ClusterManagerServer_StartIPRotation_Call
  • func (_c *ClusterManagerServer_StartIPRotation_Call) RunAndReturn(...) *ClusterManagerServer_StartIPRotation_Call
• type ClusterManagerServer_UpdateCluster_Call
  • func (_c *ClusterManagerServer_UpdateCluster_Call) Return(_a0 *containerpb.Operation, _a1 error) *ClusterManagerServer_UpdateCluster_Call
  • func (_c *ClusterManagerServer_UpdateCluster_Call) Run(run func(_a0 context.Context, _a1 *containerpb.UpdateClusterRequest)) *ClusterManagerServer_UpdateCluster_Call
  • func (_c *ClusterManagerServer_UpdateCluster_Call) RunAndReturn(...) *ClusterManagerServer_UpdateCluster_Call
• type ClusterManagerServer_UpdateMaster_Call
  • func (_c *ClusterManagerServer_UpdateMaster_Call) Return(_a0 *containerpb.Operation, _a1 error) *ClusterManagerServer_UpdateMaster_Call
  • func (_c *ClusterManagerServer_UpdateMaster_Call) Run(run func(_a0 context.Context, _a1 *containerpb.UpdateMasterRequest)) *ClusterManagerServer_UpdateMaster_Call
  • func (_c *ClusterManagerServer_UpdateMaster_Call) RunAndReturn(...) *ClusterManagerServer_UpdateMaster_Call
• type ClusterManagerServer_UpdateNodePool_Call
  • func (_c *ClusterManagerServer_UpdateNodePool_Call) Return(_a0 *containerpb.Operation, _a1 error) *ClusterManagerServer_UpdateNodePool_Call
  • func (_c *ClusterManagerServer_UpdateNodePool_Call) Run(run func(_a0 context.Context, _a1 *containerpb.UpdateNodePoolRequest)) *ClusterManagerServer_UpdateNodePool_Call
  • func (_c *ClusterManagerServer_UpdateNodePool_Call) RunAndReturn(...) *ClusterManagerServer_UpdateNodePool_Call
• type PublisherServer
  • func NewPublisherServer(t interface{ ... }) *PublisherServer
  • func (_m *PublisherServer) CreateTopic(_a0 context.Context, _a1 *pubsubpb.Topic) (*pubsubpb.Topic, error)
  • func (_m *PublisherServer) DeleteTopic(_a0 context.Context, _a1 *pubsubpb.DeleteTopicRequest) (*emptypb.Empty, error)
  • func (_m *PublisherServer) DetachSubscription(_a0 context.Context, _a1 *pubsubpb.DetachSubscriptionRequest) (*pubsubpb.DetachSubscriptionResponse, error)
  • func (_m *PublisherServer) EXPECT() *PublisherServer_Expecter
  • func (_m *PublisherServer) GetTopic(_a0 context.Context, _a1 *pubsubpb.GetTopicRequest) (*pubsubpb.Topic, error)
  • func (_m *PublisherServer) ListTopicSnapshots(_a0 context.Context, _a1 *pubsubpb.ListTopicSnapshotsRequest) (*pubsubpb.ListTopicSnapshotsResponse, error)
  • func (_m *PublisherServer) ListTopicSubscriptions(_a0 context.Context, _a1 *pubsubpb.ListTopicSubscriptionsRequest) (*pubsubpb.ListTopicSubscriptionsResponse, error)
  • func (_m *PublisherServer) ListTopics(_a0 context.Context, _a1 *pubsubpb.ListTopicsRequest) (*pubsubpb.ListTopicsResponse, error)
  • func (_m *PublisherServer) Publish(_a0 context.Context, _a1 *pubsubpb.PublishRequest) (*pubsubpb.PublishResponse, error)
  • func (_m *PublisherServer) UpdateTopic(_a0 context.Context, _a1 *pubsubpb.UpdateTopicRequest) (*pubsubpb.Topic, error)
• type PublisherServer_CreateTopic_Call
  • func (_c *PublisherServer_CreateTopic_Call) Return(_a0 *pubsubpb.Topic, _a1 error) *PublisherServer_CreateTopic_Call
  • func (_c *PublisherServer_CreateTopic_Call) Run(run func(_a0 context.Context, _a1 *pubsubpb.Topic)) *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) Return(_a0 *emptypb.Empty, _a1 error) *PublisherServer_DeleteTopic_Call
  • func (_c *PublisherServer_DeleteTopic_Call) Run(run func(_a0 context.Context, _a1 *pubsubpb.DeleteTopicRequest)) *PublisherServer_DeleteTopic_Call
  • func (_c *PublisherServer_DeleteTopic_Call) RunAndReturn(...) *PublisherServer_DeleteTopic_Call
• type PublisherServer_DetachSubscription_Call
  • func (_c *PublisherServer_DetachSubscription_Call) Return(_a0 *pubsubpb.DetachSubscriptionResponse, _a1 error) *PublisherServer_DetachSubscription_Call
  • func (_c *PublisherServer_DetachSubscription_Call) Run(run func(_a0 context.Context, _a1 *pubsubpb.DetachSubscriptionRequest)) *PublisherServer_DetachSubscription_Call
  • func (_c *PublisherServer_DetachSubscription_Call) RunAndReturn(...) *PublisherServer_DetachSubscription_Call
• type PublisherServer_Expecter
  • 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
  • func (_c *PublisherServer_GetTopic_Call) Return(_a0 *pubsubpb.Topic, _a1 error) *PublisherServer_GetTopic_Call
  • func (_c *PublisherServer_GetTopic_Call) Run(run func(_a0 context.Context, _a1 *pubsubpb.GetTopicRequest)) *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) Return(_a0 *pubsubpb.ListTopicSnapshotsResponse, _a1 error) *PublisherServer_ListTopicSnapshots_Call
  • func (_c *PublisherServer_ListTopicSnapshots_Call) Run(run func(_a0 context.Context, _a1 *pubsubpb.ListTopicSnapshotsRequest)) *PublisherServer_ListTopicSnapshots_Call
  • func (_c *PublisherServer_ListTopicSnapshots_Call) RunAndReturn(...) *PublisherServer_ListTopicSnapshots_Call
• type PublisherServer_ListTopicSubscriptions_Call
  • func (_c *PublisherServer_ListTopicSubscriptions_Call) Return(_a0 *pubsubpb.ListTopicSubscriptionsResponse, _a1 error) *PublisherServer_ListTopicSubscriptions_Call
  • func (_c *PublisherServer_ListTopicSubscriptions_Call) Run(run func(_a0 context.Context, _a1 *pubsubpb.ListTopicSubscriptionsRequest)) *PublisherServer_ListTopicSubscriptions_Call
  • func (_c *PublisherServer_ListTopicSubscriptions_Call) RunAndReturn(...) *PublisherServer_ListTopicSubscriptions_Call
• type PublisherServer_ListTopics_Call
  • func (_c *PublisherServer_ListTopics_Call) Return(_a0 *pubsubpb.ListTopicsResponse, _a1 error) *PublisherServer_ListTopics_Call
  • func (_c *PublisherServer_ListTopics_Call) Run(run func(_a0 context.Context, _a1 *pubsubpb.ListTopicsRequest)) *PublisherServer_ListTopics_Call
  • func (_c *PublisherServer_ListTopics_Call) RunAndReturn(...) *PublisherServer_ListTopics_Call
• type PublisherServer_Publish_Call
  • func (_c *PublisherServer_Publish_Call) Return(_a0 *pubsubpb.PublishResponse, _a1 error) *PublisherServer_Publish_Call
  • func (_c *PublisherServer_Publish_Call) Run(run func(_a0 context.Context, _a1 *pubsubpb.PublishRequest)) *PublisherServer_Publish_Call
  • func (_c *PublisherServer_Publish_Call) RunAndReturn(...) *PublisherServer_Publish_Call
• type PublisherServer_UpdateTopic_Call
  • func (_c *PublisherServer_UpdateTopic_Call) Return(_a0 *pubsubpb.Topic, _a1 error) *PublisherServer_UpdateTopic_Call
  • func (_c *PublisherServer_UpdateTopic_Call) Run(run func(_a0 context.Context, _a1 *pubsubpb.UpdateTopicRequest)) *PublisherServer_UpdateTopic_Call
  • func (_c *PublisherServer_UpdateTopic_Call) RunAndReturn(...) *PublisherServer_UpdateTopic_Call
• type SubscriberServer
  • func NewSubscriberServer(t interface{ ... }) *SubscriberServer
  • func (_m *SubscriberServer) Acknowledge(_a0 context.Context, _a1 *pubsubpb.AcknowledgeRequest) (*emptypb.Empty, error)
  • func (_m *SubscriberServer) CreateSnapshot(_a0 context.Context, _a1 *pubsubpb.CreateSnapshotRequest) (*pubsubpb.Snapshot, error)
  • func (_m *SubscriberServer) CreateSubscription(_a0 context.Context, _a1 *pubsubpb.Subscription) (*pubsubpb.Subscription, error)
  • func (_m *SubscriberServer) DeleteSnapshot(_a0 context.Context, _a1 *pubsubpb.DeleteSnapshotRequest) (*emptypb.Empty, error)
  • func (_m *SubscriberServer) DeleteSubscription(_a0 context.Context, _a1 *pubsubpb.DeleteSubscriptionRequest) (*emptypb.Empty, error)
  • func (_m *SubscriberServer) EXPECT() *SubscriberServer_Expecter
  • func (_m *SubscriberServer) GetSnapshot(_a0 context.Context, _a1 *pubsubpb.GetSnapshotRequest) (*pubsubpb.Snapshot, error)
  • func (_m *SubscriberServer) GetSubscription(_a0 context.Context, _a1 *pubsubpb.GetSubscriptionRequest) (*pubsubpb.Subscription, error)
  • func (_m *SubscriberServer) ListSnapshots(_a0 context.Context, _a1 *pubsubpb.ListSnapshotsRequest) (*pubsubpb.ListSnapshotsResponse, error)
  • func (_m *SubscriberServer) ListSubscriptions(_a0 context.Context, _a1 *pubsubpb.ListSubscriptionsRequest) (*pubsubpb.ListSubscriptionsResponse, error)
  • func (_m *SubscriberServer) ModifyAckDeadline(_a0 context.Context, _a1 *pubsubpb.ModifyAckDeadlineRequest) (*emptypb.Empty, error)
  • func (_m *SubscriberServer) ModifyPushConfig(_a0 context.Context, _a1 *pubsubpb.ModifyPushConfigRequest) (*emptypb.Empty, error)
  • func (_m *SubscriberServer) Pull(_a0 context.Context, _a1 *pubsubpb.PullRequest) (*pubsubpb.PullResponse, error)
  • func (_m *SubscriberServer) Seek(_a0 context.Context, _a1 *pubsubpb.SeekRequest) (*pubsubpb.SeekResponse, error)
  • func (_m *SubscriberServer) StreamingPull(_a0 pubsubpb.Subscriber_StreamingPullServer) error
  • func (_m *SubscriberServer) UpdateSnapshot(_a0 context.Context, _a1 *pubsubpb.UpdateSnapshotRequest) (*pubsubpb.Snapshot, error)
  • func (_m *SubscriberServer) UpdateSubscription(_a0 context.Context, _a1 *pubsubpb.UpdateSubscriptionRequest) (*pubsubpb.Subscription, error)
• type SubscriberServer_Acknowledge_Call
  • 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 *pubsubpb.AcknowledgeRequest)) *SubscriberServer_Acknowledge_Call
  • func (_c *SubscriberServer_Acknowledge_Call) RunAndReturn(...) *SubscriberServer_Acknowledge_Call
• type SubscriberServer_CreateSnapshot_Call
  • func (_c *SubscriberServer_CreateSnapshot_Call) Return(_a0 *pubsubpb.Snapshot, _a1 error) *SubscriberServer_CreateSnapshot_Call
  • func (_c *SubscriberServer_CreateSnapshot_Call) Run(run func(_a0 context.Context, _a1 *pubsubpb.CreateSnapshotRequest)) *SubscriberServer_CreateSnapshot_Call
  • func (_c *SubscriberServer_CreateSnapshot_Call) RunAndReturn(...) *SubscriberServer_CreateSnapshot_Call
• type SubscriberServer_CreateSubscription_Call
  • func (_c *SubscriberServer_CreateSubscription_Call) Return(_a0 *pubsubpb.Subscription, _a1 error) *SubscriberServer_CreateSubscription_Call
  • func (_c *SubscriberServer_CreateSubscription_Call) Run(run func(_a0 context.Context, _a1 *pubsubpb.Subscription)) *SubscriberServer_CreateSubscription_Call
  • func (_c *SubscriberServer_CreateSubscription_Call) RunAndReturn(...) *SubscriberServer_CreateSubscription_Call
• type SubscriberServer_DeleteSnapshot_Call
  • 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 *pubsubpb.DeleteSnapshotRequest)) *SubscriberServer_DeleteSnapshot_Call
  • func (_c *SubscriberServer_DeleteSnapshot_Call) RunAndReturn(...) *SubscriberServer_DeleteSnapshot_Call
• type SubscriberServer_DeleteSubscription_Call
  • 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 *pubsubpb.DeleteSubscriptionRequest)) *SubscriberServer_DeleteSubscription_Call
  • func (_c *SubscriberServer_DeleteSubscription_Call) RunAndReturn(...) *SubscriberServer_DeleteSubscription_Call
• type SubscriberServer_Expecter
  • 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
  • func (_c *SubscriberServer_GetSnapshot_Call) Return(_a0 *pubsubpb.Snapshot, _a1 error) *SubscriberServer_GetSnapshot_Call
  • func (_c *SubscriberServer_GetSnapshot_Call) Run(run func(_a0 context.Context, _a1 *pubsubpb.GetSnapshotRequest)) *SubscriberServer_GetSnapshot_Call
  • func (_c *SubscriberServer_GetSnapshot_Call) RunAndReturn(...) *SubscriberServer_GetSnapshot_Call
• type SubscriberServer_GetSubscription_Call
  • func (_c *SubscriberServer_GetSubscription_Call) Return(_a0 *pubsubpb.Subscription, _a1 error) *SubscriberServer_GetSubscription_Call
  • func (_c *SubscriberServer_GetSubscription_Call) Run(run func(_a0 context.Context, _a1 *pubsubpb.GetSubscriptionRequest)) *SubscriberServer_GetSubscription_Call
  • func (_c *SubscriberServer_GetSubscription_Call) RunAndReturn(...) *SubscriberServer_GetSubscription_Call
• type SubscriberServer_ListSnapshots_Call
  • func (_c *SubscriberServer_ListSnapshots_Call) Return(_a0 *pubsubpb.ListSnapshotsResponse, _a1 error) *SubscriberServer_ListSnapshots_Call
  • func (_c *SubscriberServer_ListSnapshots_Call) Run(run func(_a0 context.Context, _a1 *pubsubpb.ListSnapshotsRequest)) *SubscriberServer_ListSnapshots_Call
  • func (_c *SubscriberServer_ListSnapshots_Call) RunAndReturn(...) *SubscriberServer_ListSnapshots_Call
• type SubscriberServer_ListSubscriptions_Call
  • func (_c *SubscriberServer_ListSubscriptions_Call) Return(_a0 *pubsubpb.ListSubscriptionsResponse, _a1 error) *SubscriberServer_ListSubscriptions_Call
  • func (_c *SubscriberServer_ListSubscriptions_Call) Run(run func(_a0 context.Context, _a1 *pubsubpb.ListSubscriptionsRequest)) *SubscriberServer_ListSubscriptions_Call
  • func (_c *SubscriberServer_ListSubscriptions_Call) RunAndReturn(...) *SubscriberServer_ListSubscriptions_Call
• type SubscriberServer_ModifyAckDeadline_Call
  • 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 *pubsubpb.ModifyAckDeadlineRequest)) *SubscriberServer_ModifyAckDeadline_Call
  • func (_c *SubscriberServer_ModifyAckDeadline_Call) RunAndReturn(...) *SubscriberServer_ModifyAckDeadline_Call
• type SubscriberServer_ModifyPushConfig_Call
  • 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 *pubsubpb.ModifyPushConfigRequest)) *SubscriberServer_ModifyPushConfig_Call
  • func (_c *SubscriberServer_ModifyPushConfig_Call) RunAndReturn(...) *SubscriberServer_ModifyPushConfig_Call
• type SubscriberServer_Pull_Call
  • func (_c *SubscriberServer_Pull_Call) Return(_a0 *pubsubpb.PullResponse, _a1 error) *SubscriberServer_Pull_Call
  • func (_c *SubscriberServer_Pull_Call) Run(run func(_a0 context.Context, _a1 *pubsubpb.PullRequest)) *SubscriberServer_Pull_Call
  • func (_c *SubscriberServer_Pull_Call) RunAndReturn(...) *SubscriberServer_Pull_Call
• type SubscriberServer_Seek_Call
  • func (_c *SubscriberServer_Seek_Call) Return(_a0 *pubsubpb.SeekResponse, _a1 error) *SubscriberServer_Seek_Call
  • func (_c *SubscriberServer_Seek_Call) Run(run func(_a0 context.Context, _a1 *pubsubpb.SeekRequest)) *SubscriberServer_Seek_Call
  • func (_c *SubscriberServer_Seek_Call) RunAndReturn(...) *SubscriberServer_Seek_Call
• type SubscriberServer_StreamingPull_Call
  • func (_c *SubscriberServer_StreamingPull_Call) Return(_a0 error) *SubscriberServer_StreamingPull_Call
  • func (_c *SubscriberServer_StreamingPull_Call) Run(run func(_a0 pubsubpb.Subscriber_StreamingPullServer)) *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) Return(_a0 *pubsubpb.Snapshot, _a1 error) *SubscriberServer_UpdateSnapshot_Call
  • func (_c *SubscriberServer_UpdateSnapshot_Call) Run(run func(_a0 context.Context, _a1 *pubsubpb.UpdateSnapshotRequest)) *SubscriberServer_UpdateSnapshot_Call
  • func (_c *SubscriberServer_UpdateSnapshot_Call) RunAndReturn(...) *SubscriberServer_UpdateSnapshot_Call
• type SubscriberServer_UpdateSubscription_Call
  • func (_c *SubscriberServer_UpdateSubscription_Call) Return(_a0 *pubsubpb.Subscription, _a1 error) *SubscriberServer_UpdateSubscription_Call
  • func (_c *SubscriberServer_UpdateSubscription_Call) Run(run func(_a0 context.Context, _a1 *pubsubpb.UpdateSubscriptionRequest)) *SubscriberServer_UpdateSubscription_Call
  • func (_c *SubscriberServer_UpdateSubscription_Call) RunAndReturn(...) *SubscriberServer_UpdateSubscription_Call

Types

type ClusterManagerServer

type ClusterManagerServer struct {
	mock.Mock
}

ClusterManagerServer is an autogenerated mock type for the ClusterManagerServer type

func NewClusterManagerServer

func NewClusterManagerServer(t interface {
	mock.TestingT
	Cleanup(func())
}) *ClusterManagerServer

NewClusterManagerServer creates a new instance of ClusterManagerServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ClusterManagerServer) CancelOperation

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

CancelOperation provides a mock function with given fields: _a0, _a1

func (*ClusterManagerServer) CheckAutopilotCompatibility

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

CheckAutopilotCompatibility provides a mock function with given fields: _a0, _a1

func (*ClusterManagerServer) CompleteIPRotation

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

CompleteIPRotation provides a mock function with given fields: _a0, _a1

func (*ClusterManagerServer) CompleteNodePoolUpgrade

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

CompleteNodePoolUpgrade provides a mock function with given fields: _a0, _a1

func (*ClusterManagerServer) CreateCluster

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

CreateCluster provides a mock function with given fields: _a0, _a1

func (*ClusterManagerServer) CreateNodePool

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

CreateNodePool provides a mock function with given fields: _a0, _a1

func (*ClusterManagerServer) DeleteCluster

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

DeleteCluster provides a mock function with given fields: _a0, _a1

func (*ClusterManagerServer) DeleteNodePool

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

DeleteNodePool provides a mock function with given fields: _a0, _a1

func (*ClusterManagerServer) EXPECT

func (_m *ClusterManagerServer) EXPECT() *ClusterManagerServer_Expecter

func (*ClusterManagerServer) GetCluster

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

GetCluster provides a mock function with given fields: _a0, _a1

func (*ClusterManagerServer) GetJSONWebKeys

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

GetJSONWebKeys provides a mock function with given fields: _a0, _a1

func (*ClusterManagerServer) GetNodePool

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

GetNodePool provides a mock function with given fields: _a0, _a1

func (*ClusterManagerServer) GetOperation

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

GetOperation provides a mock function with given fields: _a0, _a1

func (*ClusterManagerServer) GetServerConfig

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

GetServerConfig provides a mock function with given fields: _a0, _a1

func (*ClusterManagerServer) ListClusters

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

ListClusters provides a mock function with given fields: _a0, _a1

func (*ClusterManagerServer) ListNodePools

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

ListNodePools provides a mock function with given fields: _a0, _a1

func (*ClusterManagerServer) ListOperations

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

ListOperations provides a mock function with given fields: _a0, _a1

func (*ClusterManagerServer) ListUsableSubnetworks

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

ListUsableSubnetworks provides a mock function with given fields: _a0, _a1

func (*ClusterManagerServer) RollbackNodePoolUpgrade

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

RollbackNodePoolUpgrade provides a mock function with given fields: _a0, _a1

func (*ClusterManagerServer) SetAddonsConfig

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

SetAddonsConfig provides a mock function with given fields: _a0, _a1

func (*ClusterManagerServer) SetLabels

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

SetLabels provides a mock function with given fields: _a0, _a1

func (*ClusterManagerServer) SetLegacyAbac

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

SetLegacyAbac provides a mock function with given fields: _a0, _a1

func (*ClusterManagerServer) SetLocations

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

SetLocations provides a mock function with given fields: _a0, _a1

func (*ClusterManagerServer) SetLoggingService

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

SetLoggingService provides a mock function with given fields: _a0, _a1

func (*ClusterManagerServer) SetMaintenancePolicy

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

SetMaintenancePolicy provides a mock function with given fields: _a0, _a1

func (*ClusterManagerServer) SetMasterAuth

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

SetMasterAuth provides a mock function with given fields: _a0, _a1

func (*ClusterManagerServer) SetMonitoringService

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

SetMonitoringService provides a mock function with given fields: _a0, _a1

func (*ClusterManagerServer) SetNetworkPolicy

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

SetNetworkPolicy provides a mock function with given fields: _a0, _a1

func (*ClusterManagerServer) SetNodePoolAutoscaling

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

SetNodePoolAutoscaling provides a mock function with given fields: _a0, _a1

func (*ClusterManagerServer) SetNodePoolManagement

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

SetNodePoolManagement provides a mock function with given fields: _a0, _a1

func (*ClusterManagerServer) SetNodePoolSize

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

SetNodePoolSize provides a mock function with given fields: _a0, _a1

func (*ClusterManagerServer) StartIPRotation

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

StartIPRotation provides a mock function with given fields: _a0, _a1

func (*ClusterManagerServer) UpdateCluster

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

UpdateCluster provides a mock function with given fields: _a0, _a1

func (*ClusterManagerServer) UpdateMaster

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

UpdateMaster provides a mock function with given fields: _a0, _a1

func (*ClusterManagerServer) UpdateNodePool

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

UpdateNodePool provides a mock function with given fields: _a0, _a1

type ClusterManagerServer_CancelOperation_Call

type ClusterManagerServer_CancelOperation_Call struct {
	*mock.Call
}

ClusterManagerServer_CancelOperation_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CancelOperation'

func (*ClusterManagerServer_CancelOperation_Call) Return

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

func (*ClusterManagerServer_CancelOperation_Call) Run

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

func (*ClusterManagerServer_CancelOperation_Call) RunAndReturn

func (_c *ClusterManagerServer_CancelOperation_Call) RunAndReturn(run func(context.Context, *containerpb.CancelOperationRequest) (*emptypb.Empty, error)) *ClusterManagerServer_CancelOperation_Call

type ClusterManagerServer_CheckAutopilotCompatibility_Call

type ClusterManagerServer_CheckAutopilotCompatibility_Call struct {
	*mock.Call
}

ClusterManagerServer_CheckAutopilotCompatibility_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CheckAutopilotCompatibility'

func (*ClusterManagerServer_CheckAutopilotCompatibility_Call) Return

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

func (*ClusterManagerServer_CheckAutopilotCompatibility_Call) Run

func (_c *ClusterManagerServer_CheckAutopilotCompatibility_Call) Run(run func(_a0 context.Context, _a1 *containerpb.CheckAutopilotCompatibilityRequest)) *ClusterManagerServer_CheckAutopilotCompatibility_Call

func (*ClusterManagerServer_CheckAutopilotCompatibility_Call) RunAndReturn

func (_c *ClusterManagerServer_CheckAutopilotCompatibility_Call) RunAndReturn(run func(context.Context, *containerpb.CheckAutopilotCompatibilityRequest) (*containerpb.CheckAutopilotCompatibilityResponse, error)) *ClusterManagerServer_CheckAutopilotCompatibility_Call

type ClusterManagerServer_CompleteIPRotation_Call

type ClusterManagerServer_CompleteIPRotation_Call struct {
	*mock.Call
}

ClusterManagerServer_CompleteIPRotation_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CompleteIPRotation'

func (*ClusterManagerServer_CompleteIPRotation_Call) Return

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

func (*ClusterManagerServer_CompleteIPRotation_Call) Run

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

func (*ClusterManagerServer_CompleteIPRotation_Call) RunAndReturn

func (_c *ClusterManagerServer_CompleteIPRotation_Call) RunAndReturn(run func(context.Context, *containerpb.CompleteIPRotationRequest) (*containerpb.Operation, error)) *ClusterManagerServer_CompleteIPRotation_Call

type ClusterManagerServer_CompleteNodePoolUpgrade_Call

type ClusterManagerServer_CompleteNodePoolUpgrade_Call struct {
	*mock.Call
}

ClusterManagerServer_CompleteNodePoolUpgrade_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CompleteNodePoolUpgrade'

func (*ClusterManagerServer_CompleteNodePoolUpgrade_Call) Return

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

func (*ClusterManagerServer_CompleteNodePoolUpgrade_Call) Run

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

func (*ClusterManagerServer_CompleteNodePoolUpgrade_Call) RunAndReturn

func (_c *ClusterManagerServer_CompleteNodePoolUpgrade_Call) RunAndReturn(run func(context.Context, *containerpb.CompleteNodePoolUpgradeRequest) (*emptypb.Empty, error)) *ClusterManagerServer_CompleteNodePoolUpgrade_Call

type ClusterManagerServer_CreateCluster_Call

type ClusterManagerServer_CreateCluster_Call struct {
	*mock.Call
}

ClusterManagerServer_CreateCluster_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateCluster'

func (*ClusterManagerServer_CreateCluster_Call) Return

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

func (*ClusterManagerServer_CreateCluster_Call) Run

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

func (*ClusterManagerServer_CreateCluster_Call) RunAndReturn

func (_c *ClusterManagerServer_CreateCluster_Call) RunAndReturn(run func(context.Context, *containerpb.CreateClusterRequest) (*containerpb.Operation, error)) *ClusterManagerServer_CreateCluster_Call

type ClusterManagerServer_CreateNodePool_Call

type ClusterManagerServer_CreateNodePool_Call struct {
	*mock.Call
}

ClusterManagerServer_CreateNodePool_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateNodePool'

func (*ClusterManagerServer_CreateNodePool_Call) Return

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

func (*ClusterManagerServer_CreateNodePool_Call) Run

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

func (*ClusterManagerServer_CreateNodePool_Call) RunAndReturn

func (_c *ClusterManagerServer_CreateNodePool_Call) RunAndReturn(run func(context.Context, *containerpb.CreateNodePoolRequest) (*containerpb.Operation, error)) *ClusterManagerServer_CreateNodePool_Call

type ClusterManagerServer_DeleteCluster_Call

type ClusterManagerServer_DeleteCluster_Call struct {
	*mock.Call
}

ClusterManagerServer_DeleteCluster_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteCluster'

func (*ClusterManagerServer_DeleteCluster_Call) Return

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

func (*ClusterManagerServer_DeleteCluster_Call) Run

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

func (*ClusterManagerServer_DeleteCluster_Call) RunAndReturn

func (_c *ClusterManagerServer_DeleteCluster_Call) RunAndReturn(run func(context.Context, *containerpb.DeleteClusterRequest) (*containerpb.Operation, error)) *ClusterManagerServer_DeleteCluster_Call

type ClusterManagerServer_DeleteNodePool_Call

type ClusterManagerServer_DeleteNodePool_Call struct {
	*mock.Call
}

ClusterManagerServer_DeleteNodePool_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteNodePool'

func (*ClusterManagerServer_DeleteNodePool_Call) Return

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

func (*ClusterManagerServer_DeleteNodePool_Call) Run

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

func (*ClusterManagerServer_DeleteNodePool_Call) RunAndReturn

func (_c *ClusterManagerServer_DeleteNodePool_Call) RunAndReturn(run func(context.Context, *containerpb.DeleteNodePoolRequest) (*containerpb.Operation, error)) *ClusterManagerServer_DeleteNodePool_Call

type ClusterManagerServer_Expecter

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

func (*ClusterManagerServer_Expecter) CancelOperation

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

CancelOperation is a helper method to define mock.On call

• _a0 context.Context
• _a1 *containerpb.CancelOperationRequest

func (*ClusterManagerServer_Expecter) CheckAutopilotCompatibility

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

CheckAutopilotCompatibility is a helper method to define mock.On call

• _a0 context.Context
• _a1 *containerpb.CheckAutopilotCompatibilityRequest

func (*ClusterManagerServer_Expecter) CompleteIPRotation

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

CompleteIPRotation is a helper method to define mock.On call

• _a0 context.Context
• _a1 *containerpb.CompleteIPRotationRequest

func (*ClusterManagerServer_Expecter) CompleteNodePoolUpgrade

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

CompleteNodePoolUpgrade is a helper method to define mock.On call

• _a0 context.Context
• _a1 *containerpb.CompleteNodePoolUpgradeRequest

func (*ClusterManagerServer_Expecter) CreateCluster

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

CreateCluster is a helper method to define mock.On call

• _a0 context.Context
• _a1 *containerpb.CreateClusterRequest

func (*ClusterManagerServer_Expecter) CreateNodePool

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

CreateNodePool is a helper method to define mock.On call

• _a0 context.Context
• _a1 *containerpb.CreateNodePoolRequest

func (*ClusterManagerServer_Expecter) DeleteCluster

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

DeleteCluster is a helper method to define mock.On call

• _a0 context.Context
• _a1 *containerpb.DeleteClusterRequest

func (*ClusterManagerServer_Expecter) DeleteNodePool

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

DeleteNodePool is a helper method to define mock.On call

• _a0 context.Context
• _a1 *containerpb.DeleteNodePoolRequest

func (*ClusterManagerServer_Expecter) GetCluster

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

GetCluster is a helper method to define mock.On call

• _a0 context.Context
• _a1 *containerpb.GetClusterRequest

func (*ClusterManagerServer_Expecter) GetJSONWebKeys

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

GetJSONWebKeys is a helper method to define mock.On call

• _a0 context.Context
• _a1 *containerpb.GetJSONWebKeysRequest

func (*ClusterManagerServer_Expecter) GetNodePool

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

GetNodePool is a helper method to define mock.On call

• _a0 context.Context
• _a1 *containerpb.GetNodePoolRequest

func (*ClusterManagerServer_Expecter) GetOperation

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

GetOperation is a helper method to define mock.On call

• _a0 context.Context
• _a1 *containerpb.GetOperationRequest

func (*ClusterManagerServer_Expecter) GetServerConfig

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

GetServerConfig is a helper method to define mock.On call

• _a0 context.Context
• _a1 *containerpb.GetServerConfigRequest

func (*ClusterManagerServer_Expecter) ListClusters

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

ListClusters is a helper method to define mock.On call

• _a0 context.Context
• _a1 *containerpb.ListClustersRequest

func (*ClusterManagerServer_Expecter) ListNodePools

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

ListNodePools is a helper method to define mock.On call

• _a0 context.Context
• _a1 *containerpb.ListNodePoolsRequest

func (*ClusterManagerServer_Expecter) ListOperations

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

ListOperations is a helper method to define mock.On call

• _a0 context.Context
• _a1 *containerpb.ListOperationsRequest

func (*ClusterManagerServer_Expecter) ListUsableSubnetworks

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

ListUsableSubnetworks is a helper method to define mock.On call

• _a0 context.Context
• _a1 *containerpb.ListUsableSubnetworksRequest

func (*ClusterManagerServer_Expecter) RollbackNodePoolUpgrade

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

RollbackNodePoolUpgrade is a helper method to define mock.On call

• _a0 context.Context
• _a1 *containerpb.RollbackNodePoolUpgradeRequest

func (*ClusterManagerServer_Expecter) SetAddonsConfig

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

SetAddonsConfig is a helper method to define mock.On call

• _a0 context.Context
• _a1 *containerpb.SetAddonsConfigRequest

func (*ClusterManagerServer_Expecter) SetLabels

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

SetLabels is a helper method to define mock.On call

• _a0 context.Context
• _a1 *containerpb.SetLabelsRequest

func (*ClusterManagerServer_Expecter) SetLegacyAbac

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

SetLegacyAbac is a helper method to define mock.On call

• _a0 context.Context
• _a1 *containerpb.SetLegacyAbacRequest

func (*ClusterManagerServer_Expecter) SetLocations

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

SetLocations is a helper method to define mock.On call

• _a0 context.Context
• _a1 *containerpb.SetLocationsRequest

func (*ClusterManagerServer_Expecter) SetLoggingService

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

SetLoggingService is a helper method to define mock.On call

• _a0 context.Context
• _a1 *containerpb.SetLoggingServiceRequest

func (*ClusterManagerServer_Expecter) SetMaintenancePolicy

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

SetMaintenancePolicy is a helper method to define mock.On call

• _a0 context.Context
• _a1 *containerpb.SetMaintenancePolicyRequest

func (*ClusterManagerServer_Expecter) SetMasterAuth

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

SetMasterAuth is a helper method to define mock.On call

• _a0 context.Context
• _a1 *containerpb.SetMasterAuthRequest

func (*ClusterManagerServer_Expecter) SetMonitoringService

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

SetMonitoringService is a helper method to define mock.On call

• _a0 context.Context
• _a1 *containerpb.SetMonitoringServiceRequest

func (*ClusterManagerServer_Expecter) SetNetworkPolicy

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

SetNetworkPolicy is a helper method to define mock.On call

• _a0 context.Context
• _a1 *containerpb.SetNetworkPolicyRequest

func (*ClusterManagerServer_Expecter) SetNodePoolAutoscaling

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

SetNodePoolAutoscaling is a helper method to define mock.On call

• _a0 context.Context
• _a1 *containerpb.SetNodePoolAutoscalingRequest

func (*ClusterManagerServer_Expecter) SetNodePoolManagement

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

SetNodePoolManagement is a helper method to define mock.On call

• _a0 context.Context
• _a1 *containerpb.SetNodePoolManagementRequest

func (*ClusterManagerServer_Expecter) SetNodePoolSize

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

SetNodePoolSize is a helper method to define mock.On call

• _a0 context.Context
• _a1 *containerpb.SetNodePoolSizeRequest

func (*ClusterManagerServer_Expecter) StartIPRotation

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

StartIPRotation is a helper method to define mock.On call

• _a0 context.Context
• _a1 *containerpb.StartIPRotationRequest

func (*ClusterManagerServer_Expecter) UpdateCluster

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

UpdateCluster is a helper method to define mock.On call

• _a0 context.Context
• _a1 *containerpb.UpdateClusterRequest

func (*ClusterManagerServer_Expecter) UpdateMaster

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

UpdateMaster is a helper method to define mock.On call

• _a0 context.Context
• _a1 *containerpb.UpdateMasterRequest

func (*ClusterManagerServer_Expecter) UpdateNodePool

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

UpdateNodePool is a helper method to define mock.On call

• _a0 context.Context
• _a1 *containerpb.UpdateNodePoolRequest

type ClusterManagerServer_GetCluster_Call

type ClusterManagerServer_GetCluster_Call struct {
	*mock.Call
}

ClusterManagerServer_GetCluster_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetCluster'

func (*ClusterManagerServer_GetCluster_Call) Return

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

func (*ClusterManagerServer_GetCluster_Call) Run

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

func (*ClusterManagerServer_GetCluster_Call) RunAndReturn

func (_c *ClusterManagerServer_GetCluster_Call) RunAndReturn(run func(context.Context, *containerpb.GetClusterRequest) (*containerpb.Cluster, error)) *ClusterManagerServer_GetCluster_Call

type ClusterManagerServer_GetJSONWebKeys_Call

type ClusterManagerServer_GetJSONWebKeys_Call struct {
	*mock.Call
}

ClusterManagerServer_GetJSONWebKeys_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetJSONWebKeys'

func (*ClusterManagerServer_GetJSONWebKeys_Call) Return

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

func (*ClusterManagerServer_GetJSONWebKeys_Call) Run

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

func (*ClusterManagerServer_GetJSONWebKeys_Call) RunAndReturn

func (_c *ClusterManagerServer_GetJSONWebKeys_Call) RunAndReturn(run func(context.Context, *containerpb.GetJSONWebKeysRequest) (*containerpb.GetJSONWebKeysResponse, error)) *ClusterManagerServer_GetJSONWebKeys_Call

type ClusterManagerServer_GetNodePool_Call

type ClusterManagerServer_GetNodePool_Call struct {
	*mock.Call
}

ClusterManagerServer_GetNodePool_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetNodePool'

func (*ClusterManagerServer_GetNodePool_Call) Return

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

func (*ClusterManagerServer_GetNodePool_Call) Run

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

func (*ClusterManagerServer_GetNodePool_Call) RunAndReturn

func (_c *ClusterManagerServer_GetNodePool_Call) RunAndReturn(run func(context.Context, *containerpb.GetNodePoolRequest) (*containerpb.NodePool, error)) *ClusterManagerServer_GetNodePool_Call

type ClusterManagerServer_GetOperation_Call

type ClusterManagerServer_GetOperation_Call struct {
	*mock.Call
}

ClusterManagerServer_GetOperation_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetOperation'

func (*ClusterManagerServer_GetOperation_Call) Return

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

func (*ClusterManagerServer_GetOperation_Call) Run

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

func (*ClusterManagerServer_GetOperation_Call) RunAndReturn

func (_c *ClusterManagerServer_GetOperation_Call) RunAndReturn(run func(context.Context, *containerpb.GetOperationRequest) (*containerpb.Operation, error)) *ClusterManagerServer_GetOperation_Call

type ClusterManagerServer_GetServerConfig_Call

type ClusterManagerServer_GetServerConfig_Call struct {
	*mock.Call
}

ClusterManagerServer_GetServerConfig_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetServerConfig'

func (*ClusterManagerServer_GetServerConfig_Call) Return

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

func (*ClusterManagerServer_GetServerConfig_Call) Run

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

func (*ClusterManagerServer_GetServerConfig_Call) RunAndReturn

func (_c *ClusterManagerServer_GetServerConfig_Call) RunAndReturn(run func(context.Context, *containerpb.GetServerConfigRequest) (*containerpb.ServerConfig, error)) *ClusterManagerServer_GetServerConfig_Call

type ClusterManagerServer_ListClusters_Call

type ClusterManagerServer_ListClusters_Call struct {
	*mock.Call
}

ClusterManagerServer_ListClusters_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListClusters'

func (*ClusterManagerServer_ListClusters_Call) Return

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

func (*ClusterManagerServer_ListClusters_Call) Run

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

func (*ClusterManagerServer_ListClusters_Call) RunAndReturn

func (_c *ClusterManagerServer_ListClusters_Call) RunAndReturn(run func(context.Context, *containerpb.ListClustersRequest) (*containerpb.ListClustersResponse, error)) *ClusterManagerServer_ListClusters_Call

type ClusterManagerServer_ListNodePools_Call

type ClusterManagerServer_ListNodePools_Call struct {
	*mock.Call
}

ClusterManagerServer_ListNodePools_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListNodePools'

func (*ClusterManagerServer_ListNodePools_Call) Return

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

func (*ClusterManagerServer_ListNodePools_Call) Run

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

func (*ClusterManagerServer_ListNodePools_Call) RunAndReturn

func (_c *ClusterManagerServer_ListNodePools_Call) RunAndReturn(run func(context.Context, *containerpb.ListNodePoolsRequest) (*containerpb.ListNodePoolsResponse, error)) *ClusterManagerServer_ListNodePools_Call

type ClusterManagerServer_ListOperations_Call

type ClusterManagerServer_ListOperations_Call struct {
	*mock.Call
}

ClusterManagerServer_ListOperations_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListOperations'

func (*ClusterManagerServer_ListOperations_Call) Return

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

func (*ClusterManagerServer_ListOperations_Call) Run

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

func (*ClusterManagerServer_ListOperations_Call) RunAndReturn

func (_c *ClusterManagerServer_ListOperations_Call) RunAndReturn(run func(context.Context, *containerpb.ListOperationsRequest) (*containerpb.ListOperationsResponse, error)) *ClusterManagerServer_ListOperations_Call

type ClusterManagerServer_ListUsableSubnetworks_Call

type ClusterManagerServer_ListUsableSubnetworks_Call struct {
	*mock.Call
}

ClusterManagerServer_ListUsableSubnetworks_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListUsableSubnetworks'

func (*ClusterManagerServer_ListUsableSubnetworks_Call) Return

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

func (*ClusterManagerServer_ListUsableSubnetworks_Call) Run

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

func (*ClusterManagerServer_ListUsableSubnetworks_Call) RunAndReturn

func (_c *ClusterManagerServer_ListUsableSubnetworks_Call) RunAndReturn(run func(context.Context, *containerpb.ListUsableSubnetworksRequest) (*containerpb.ListUsableSubnetworksResponse, error)) *ClusterManagerServer_ListUsableSubnetworks_Call

type ClusterManagerServer_RollbackNodePoolUpgrade_Call

type ClusterManagerServer_RollbackNodePoolUpgrade_Call struct {
	*mock.Call
}

ClusterManagerServer_RollbackNodePoolUpgrade_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RollbackNodePoolUpgrade'

func (*ClusterManagerServer_RollbackNodePoolUpgrade_Call) Return

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

func (*ClusterManagerServer_RollbackNodePoolUpgrade_Call) Run

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

func (*ClusterManagerServer_RollbackNodePoolUpgrade_Call) RunAndReturn

func (_c *ClusterManagerServer_RollbackNodePoolUpgrade_Call) RunAndReturn(run func(context.Context, *containerpb.RollbackNodePoolUpgradeRequest) (*containerpb.Operation, error)) *ClusterManagerServer_RollbackNodePoolUpgrade_Call

type ClusterManagerServer_SetAddonsConfig_Call

type ClusterManagerServer_SetAddonsConfig_Call struct {
	*mock.Call
}

ClusterManagerServer_SetAddonsConfig_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetAddonsConfig'

func (*ClusterManagerServer_SetAddonsConfig_Call) Return

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

func (*ClusterManagerServer_SetAddonsConfig_Call) Run

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

func (*ClusterManagerServer_SetAddonsConfig_Call) RunAndReturn

func (_c *ClusterManagerServer_SetAddonsConfig_Call) RunAndReturn(run func(context.Context, *containerpb.SetAddonsConfigRequest) (*containerpb.Operation, error)) *ClusterManagerServer_SetAddonsConfig_Call

type ClusterManagerServer_SetLabels_Call

type ClusterManagerServer_SetLabels_Call struct {
	*mock.Call
}

ClusterManagerServer_SetLabels_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetLabels'

func (*ClusterManagerServer_SetLabels_Call) Return

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

func (*ClusterManagerServer_SetLabels_Call) Run

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

func (*ClusterManagerServer_SetLabels_Call) RunAndReturn

func (_c *ClusterManagerServer_SetLabels_Call) RunAndReturn(run func(context.Context, *containerpb.SetLabelsRequest) (*containerpb.Operation, error)) *ClusterManagerServer_SetLabels_Call

type ClusterManagerServer_SetLegacyAbac_Call

type ClusterManagerServer_SetLegacyAbac_Call struct {
	*mock.Call
}

ClusterManagerServer_SetLegacyAbac_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetLegacyAbac'

func (*ClusterManagerServer_SetLegacyAbac_Call) Return

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

func (*ClusterManagerServer_SetLegacyAbac_Call) Run

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

func (*ClusterManagerServer_SetLegacyAbac_Call) RunAndReturn

func (_c *ClusterManagerServer_SetLegacyAbac_Call) RunAndReturn(run func(context.Context, *containerpb.SetLegacyAbacRequest) (*containerpb.Operation, error)) *ClusterManagerServer_SetLegacyAbac_Call

type ClusterManagerServer_SetLocations_Call

type ClusterManagerServer_SetLocations_Call struct {
	*mock.Call
}

ClusterManagerServer_SetLocations_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetLocations'

func (*ClusterManagerServer_SetLocations_Call) Return

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

func (*ClusterManagerServer_SetLocations_Call) Run

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

func (*ClusterManagerServer_SetLocations_Call) RunAndReturn

func (_c *ClusterManagerServer_SetLocations_Call) RunAndReturn(run func(context.Context, *containerpb.SetLocationsRequest) (*containerpb.Operation, error)) *ClusterManagerServer_SetLocations_Call

type ClusterManagerServer_SetLoggingService_Call

type ClusterManagerServer_SetLoggingService_Call struct {
	*mock.Call
}

ClusterManagerServer_SetLoggingService_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetLoggingService'

func (*ClusterManagerServer_SetLoggingService_Call) Return

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

func (*ClusterManagerServer_SetLoggingService_Call) Run

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

func (*ClusterManagerServer_SetLoggingService_Call) RunAndReturn

func (_c *ClusterManagerServer_SetLoggingService_Call) RunAndReturn(run func(context.Context, *containerpb.SetLoggingServiceRequest) (*containerpb.Operation, error)) *ClusterManagerServer_SetLoggingService_Call

type ClusterManagerServer_SetMaintenancePolicy_Call

type ClusterManagerServer_SetMaintenancePolicy_Call struct {
	*mock.Call
}

ClusterManagerServer_SetMaintenancePolicy_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetMaintenancePolicy'

func (*ClusterManagerServer_SetMaintenancePolicy_Call) Return

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

func (*ClusterManagerServer_SetMaintenancePolicy_Call) Run

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

func (*ClusterManagerServer_SetMaintenancePolicy_Call) RunAndReturn

func (_c *ClusterManagerServer_SetMaintenancePolicy_Call) RunAndReturn(run func(context.Context, *containerpb.SetMaintenancePolicyRequest) (*containerpb.Operation, error)) *ClusterManagerServer_SetMaintenancePolicy_Call

type ClusterManagerServer_SetMasterAuth_Call

type ClusterManagerServer_SetMasterAuth_Call struct {
	*mock.Call
}

ClusterManagerServer_SetMasterAuth_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetMasterAuth'

func (*ClusterManagerServer_SetMasterAuth_Call) Return

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

func (*ClusterManagerServer_SetMasterAuth_Call) Run

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

func (*ClusterManagerServer_SetMasterAuth_Call) RunAndReturn

func (_c *ClusterManagerServer_SetMasterAuth_Call) RunAndReturn(run func(context.Context, *containerpb.SetMasterAuthRequest) (*containerpb.Operation, error)) *ClusterManagerServer_SetMasterAuth_Call

type ClusterManagerServer_SetMonitoringService_Call

type ClusterManagerServer_SetMonitoringService_Call struct {
	*mock.Call
}

ClusterManagerServer_SetMonitoringService_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetMonitoringService'

func (*ClusterManagerServer_SetMonitoringService_Call) Return

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

func (*ClusterManagerServer_SetMonitoringService_Call) Run

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

func (*ClusterManagerServer_SetMonitoringService_Call) RunAndReturn

func (_c *ClusterManagerServer_SetMonitoringService_Call) RunAndReturn(run func(context.Context, *containerpb.SetMonitoringServiceRequest) (*containerpb.Operation, error)) *ClusterManagerServer_SetMonitoringService_Call

type ClusterManagerServer_SetNetworkPolicy_Call

type ClusterManagerServer_SetNetworkPolicy_Call struct {
	*mock.Call
}

ClusterManagerServer_SetNetworkPolicy_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetNetworkPolicy'

func (*ClusterManagerServer_SetNetworkPolicy_Call) Return

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

func (*ClusterManagerServer_SetNetworkPolicy_Call) Run

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

func (*ClusterManagerServer_SetNetworkPolicy_Call) RunAndReturn

func (_c *ClusterManagerServer_SetNetworkPolicy_Call) RunAndReturn(run func(context.Context, *containerpb.SetNetworkPolicyRequest) (*containerpb.Operation, error)) *ClusterManagerServer_SetNetworkPolicy_Call

type ClusterManagerServer_SetNodePoolAutoscaling_Call

type ClusterManagerServer_SetNodePoolAutoscaling_Call struct {
	*mock.Call
}

ClusterManagerServer_SetNodePoolAutoscaling_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetNodePoolAutoscaling'

func (*ClusterManagerServer_SetNodePoolAutoscaling_Call) Return

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

func (*ClusterManagerServer_SetNodePoolAutoscaling_Call) Run

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

func (*ClusterManagerServer_SetNodePoolAutoscaling_Call) RunAndReturn

func (_c *ClusterManagerServer_SetNodePoolAutoscaling_Call) RunAndReturn(run func(context.Context, *containerpb.SetNodePoolAutoscalingRequest) (*containerpb.Operation, error)) *ClusterManagerServer_SetNodePoolAutoscaling_Call

type ClusterManagerServer_SetNodePoolManagement_Call

type ClusterManagerServer_SetNodePoolManagement_Call struct {
	*mock.Call
}

ClusterManagerServer_SetNodePoolManagement_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetNodePoolManagement'

func (*ClusterManagerServer_SetNodePoolManagement_Call) Return

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

func (*ClusterManagerServer_SetNodePoolManagement_Call) Run

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

func (*ClusterManagerServer_SetNodePoolManagement_Call) RunAndReturn

func (_c *ClusterManagerServer_SetNodePoolManagement_Call) RunAndReturn(run func(context.Context, *containerpb.SetNodePoolManagementRequest) (*containerpb.Operation, error)) *ClusterManagerServer_SetNodePoolManagement_Call

type ClusterManagerServer_SetNodePoolSize_Call

type ClusterManagerServer_SetNodePoolSize_Call struct {
	*mock.Call
}

ClusterManagerServer_SetNodePoolSize_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetNodePoolSize'

func (*ClusterManagerServer_SetNodePoolSize_Call) Return

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

func (*ClusterManagerServer_SetNodePoolSize_Call) Run

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

func (*ClusterManagerServer_SetNodePoolSize_Call) RunAndReturn

func (_c *ClusterManagerServer_SetNodePoolSize_Call) RunAndReturn(run func(context.Context, *containerpb.SetNodePoolSizeRequest) (*containerpb.Operation, error)) *ClusterManagerServer_SetNodePoolSize_Call

type ClusterManagerServer_StartIPRotation_Call

type ClusterManagerServer_StartIPRotation_Call struct {
	*mock.Call
}

ClusterManagerServer_StartIPRotation_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StartIPRotation'

func (*ClusterManagerServer_StartIPRotation_Call) Return

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

func (*ClusterManagerServer_StartIPRotation_Call) Run

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

func (*ClusterManagerServer_StartIPRotation_Call) RunAndReturn

func (_c *ClusterManagerServer_StartIPRotation_Call) RunAndReturn(run func(context.Context, *containerpb.StartIPRotationRequest) (*containerpb.Operation, error)) *ClusterManagerServer_StartIPRotation_Call

type ClusterManagerServer_UpdateCluster_Call

type ClusterManagerServer_UpdateCluster_Call struct {
	*mock.Call
}

ClusterManagerServer_UpdateCluster_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateCluster'

func (*ClusterManagerServer_UpdateCluster_Call) Return

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

func (*ClusterManagerServer_UpdateCluster_Call) Run

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

func (*ClusterManagerServer_UpdateCluster_Call) RunAndReturn

func (_c *ClusterManagerServer_UpdateCluster_Call) RunAndReturn(run func(context.Context, *containerpb.UpdateClusterRequest) (*containerpb.Operation, error)) *ClusterManagerServer_UpdateCluster_Call

type ClusterManagerServer_UpdateMaster_Call

type ClusterManagerServer_UpdateMaster_Call struct {
	*mock.Call
}

ClusterManagerServer_UpdateMaster_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateMaster'

func (*ClusterManagerServer_UpdateMaster_Call) Return

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

func (*ClusterManagerServer_UpdateMaster_Call) Run

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

func (*ClusterManagerServer_UpdateMaster_Call) RunAndReturn

func (_c *ClusterManagerServer_UpdateMaster_Call) RunAndReturn(run func(context.Context, *containerpb.UpdateMasterRequest) (*containerpb.Operation, error)) *ClusterManagerServer_UpdateMaster_Call

type ClusterManagerServer_UpdateNodePool_Call

type ClusterManagerServer_UpdateNodePool_Call struct {
	*mock.Call
}

ClusterManagerServer_UpdateNodePool_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateNodePool'

func (*ClusterManagerServer_UpdateNodePool_Call) Return

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

func (*ClusterManagerServer_UpdateNodePool_Call) Run

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

func (*ClusterManagerServer_UpdateNodePool_Call) RunAndReturn

func (_c *ClusterManagerServer_UpdateNodePool_Call) RunAndReturn(run func(context.Context, *containerpb.UpdateNodePoolRequest) (*containerpb.Operation, error)) *ClusterManagerServer_UpdateNodePool_Call

type PublisherServer

type PublisherServer struct {
	mock.Mock
}

PublisherServer is an autogenerated mock type for the PublisherServer type

func NewPublisherServer

func NewPublisherServer(t interface {
	mock.TestingT
	Cleanup(func())
}) *PublisherServer

NewPublisherServer creates a new instance of PublisherServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*PublisherServer) CreateTopic

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

CreateTopic provides a mock function with given fields: _a0, _a1

func (*PublisherServer) DeleteTopic

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

DeleteTopic provides a mock function with given fields: _a0, _a1

func (*PublisherServer) DetachSubscription

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

DetachSubscription provides a mock function with given fields: _a0, _a1

func (*PublisherServer) EXPECT

func (_m *PublisherServer) EXPECT() *PublisherServer_Expecter

func (*PublisherServer) GetTopic

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

GetTopic provides a mock function with given fields: _a0, _a1

func (*PublisherServer) ListTopicSnapshots

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

ListTopicSnapshots provides a mock function with given fields: _a0, _a1

func (*PublisherServer) ListTopicSubscriptions

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

ListTopicSubscriptions provides a mock function with given fields: _a0, _a1

func (*PublisherServer) ListTopics

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

ListTopics provides a mock function with given fields: _a0, _a1

func (*PublisherServer) Publish

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

Publish provides a mock function with given fields: _a0, _a1

func (*PublisherServer) UpdateTopic

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

UpdateTopic provides a mock function with given fields: _a0, _a1

type PublisherServer_CreateTopic_Call

type PublisherServer_CreateTopic_Call struct {
	*mock.Call
}

PublisherServer_CreateTopic_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateTopic'

func (*PublisherServer_CreateTopic_Call) Return

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

func (*PublisherServer_CreateTopic_Call) Run

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

func (*PublisherServer_CreateTopic_Call) RunAndReturn

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

type PublisherServer_DeleteTopic_Call

type PublisherServer_DeleteTopic_Call struct {
	*mock.Call
}

PublisherServer_DeleteTopic_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteTopic'

func (*PublisherServer_DeleteTopic_Call) Return

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

func (*PublisherServer_DeleteTopic_Call) Run

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

func (*PublisherServer_DeleteTopic_Call) RunAndReturn

func (_c *PublisherServer_DeleteTopic_Call) RunAndReturn(run func(context.Context, *pubsubpb.DeleteTopicRequest) (*emptypb.Empty, error)) *PublisherServer_DeleteTopic_Call

type PublisherServer_DetachSubscription_Call

type PublisherServer_DetachSubscription_Call struct {
	*mock.Call
}

PublisherServer_DetachSubscription_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DetachSubscription'

func (*PublisherServer_DetachSubscription_Call) Return

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

func (*PublisherServer_DetachSubscription_Call) Run

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

func (*PublisherServer_DetachSubscription_Call) RunAndReturn

func (_c *PublisherServer_DetachSubscription_Call) RunAndReturn(run func(context.Context, *pubsubpb.DetachSubscriptionRequest) (*pubsubpb.DetachSubscriptionResponse, error)) *PublisherServer_DetachSubscription_Call

type PublisherServer_Expecter

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

func (*PublisherServer_Expecter) CreateTopic

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

CreateTopic is a helper method to define mock.On call

• _a0 context.Context
• _a1 *pubsubpb.Topic

func (*PublisherServer_Expecter) DeleteTopic

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

DeleteTopic is a helper method to define mock.On call

• _a0 context.Context
• _a1 *pubsubpb.DeleteTopicRequest

func (*PublisherServer_Expecter) DetachSubscription

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

DetachSubscription is a helper method to define mock.On call

• _a0 context.Context
• _a1 *pubsubpb.DetachSubscriptionRequest

func (*PublisherServer_Expecter) GetTopic

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

GetTopic is a helper method to define mock.On call

• _a0 context.Context
• _a1 *pubsubpb.GetTopicRequest

func (*PublisherServer_Expecter) ListTopicSnapshots

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

ListTopicSnapshots is a helper method to define mock.On call

• _a0 context.Context
• _a1 *pubsubpb.ListTopicSnapshotsRequest

func (*PublisherServer_Expecter) ListTopicSubscriptions

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

ListTopicSubscriptions is a helper method to define mock.On call

• _a0 context.Context
• _a1 *pubsubpb.ListTopicSubscriptionsRequest

func (*PublisherServer_Expecter) ListTopics

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

ListTopics is a helper method to define mock.On call

• _a0 context.Context
• _a1 *pubsubpb.ListTopicsRequest

func (*PublisherServer_Expecter) Publish

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

Publish is a helper method to define mock.On call

• _a0 context.Context
• _a1 *pubsubpb.PublishRequest

func (*PublisherServer_Expecter) UpdateTopic

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

UpdateTopic is a helper method to define mock.On call

• _a0 context.Context
• _a1 *pubsubpb.UpdateTopicRequest

type PublisherServer_GetTopic_Call

type PublisherServer_GetTopic_Call struct {
	*mock.Call
}

PublisherServer_GetTopic_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTopic'

func (*PublisherServer_GetTopic_Call) Return

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

func (*PublisherServer_GetTopic_Call) Run

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

func (*PublisherServer_GetTopic_Call) RunAndReturn

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

type PublisherServer_ListTopicSnapshots_Call

type PublisherServer_ListTopicSnapshots_Call struct {
	*mock.Call
}

PublisherServer_ListTopicSnapshots_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListTopicSnapshots'

func (*PublisherServer_ListTopicSnapshots_Call) Return

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

func (*PublisherServer_ListTopicSnapshots_Call) Run

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

func (*PublisherServer_ListTopicSnapshots_Call) RunAndReturn

func (_c *PublisherServer_ListTopicSnapshots_Call) RunAndReturn(run func(context.Context, *pubsubpb.ListTopicSnapshotsRequest) (*pubsubpb.ListTopicSnapshotsResponse, error)) *PublisherServer_ListTopicSnapshots_Call

type PublisherServer_ListTopicSubscriptions_Call

type PublisherServer_ListTopicSubscriptions_Call struct {
	*mock.Call
}

PublisherServer_ListTopicSubscriptions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListTopicSubscriptions'

func (*PublisherServer_ListTopicSubscriptions_Call) Return

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

func (*PublisherServer_ListTopicSubscriptions_Call) Run

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

func (*PublisherServer_ListTopicSubscriptions_Call) RunAndReturn

func (_c *PublisherServer_ListTopicSubscriptions_Call) RunAndReturn(run func(context.Context, *pubsubpb.ListTopicSubscriptionsRequest) (*pubsubpb.ListTopicSubscriptionsResponse, error)) *PublisherServer_ListTopicSubscriptions_Call

type PublisherServer_ListTopics_Call

type PublisherServer_ListTopics_Call struct {
	*mock.Call
}

PublisherServer_ListTopics_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListTopics'

func (*PublisherServer_ListTopics_Call) Return

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

func (*PublisherServer_ListTopics_Call) Run

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

func (*PublisherServer_ListTopics_Call) RunAndReturn

func (_c *PublisherServer_ListTopics_Call) RunAndReturn(run func(context.Context, *pubsubpb.ListTopicsRequest) (*pubsubpb.ListTopicsResponse, error)) *PublisherServer_ListTopics_Call

type PublisherServer_Publish_Call

type PublisherServer_Publish_Call struct {
	*mock.Call
}

PublisherServer_Publish_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Publish'

func (*PublisherServer_Publish_Call) Return

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

func (*PublisherServer_Publish_Call) Run

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

func (*PublisherServer_Publish_Call) RunAndReturn

func (_c *PublisherServer_Publish_Call) RunAndReturn(run func(context.Context, *pubsubpb.PublishRequest) (*pubsubpb.PublishResponse, error)) *PublisherServer_Publish_Call

type PublisherServer_UpdateTopic_Call

type PublisherServer_UpdateTopic_Call struct {
	*mock.Call
}

PublisherServer_UpdateTopic_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateTopic'

func (*PublisherServer_UpdateTopic_Call) Return

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

func (*PublisherServer_UpdateTopic_Call) Run

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

func (*PublisherServer_UpdateTopic_Call) RunAndReturn

func (_c *PublisherServer_UpdateTopic_Call) RunAndReturn(run func(context.Context, *pubsubpb.UpdateTopicRequest) (*pubsubpb.Topic, error)) *PublisherServer_UpdateTopic_Call

type SubscriberServer

type SubscriberServer struct {
	mock.Mock
}

SubscriberServer is an autogenerated mock type for the SubscriberServer type

func NewSubscriberServer

func NewSubscriberServer(t interface {
	mock.TestingT
	Cleanup(func())
}) *SubscriberServer

NewSubscriberServer creates a new instance of SubscriberServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*SubscriberServer) Acknowledge

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

Acknowledge provides a mock function with given fields: _a0, _a1

func (*SubscriberServer) CreateSnapshot

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

CreateSnapshot provides a mock function with given fields: _a0, _a1

func (*SubscriberServer) CreateSubscription

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

CreateSubscription provides a mock function with given fields: _a0, _a1

func (*SubscriberServer) DeleteSnapshot

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

DeleteSnapshot provides a mock function with given fields: _a0, _a1

func (*SubscriberServer) DeleteSubscription

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

DeleteSubscription provides a mock function with given fields: _a0, _a1

func (*SubscriberServer) EXPECT

func (_m *SubscriberServer) EXPECT() *SubscriberServer_Expecter

func (*SubscriberServer) GetSnapshot

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

GetSnapshot provides a mock function with given fields: _a0, _a1

func (*SubscriberServer) GetSubscription

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

GetSubscription provides a mock function with given fields: _a0, _a1

func (*SubscriberServer) ListSnapshots

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

ListSnapshots provides a mock function with given fields: _a0, _a1

func (*SubscriberServer) ListSubscriptions

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

ListSubscriptions provides a mock function with given fields: _a0, _a1

func (*SubscriberServer) ModifyAckDeadline

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

ModifyAckDeadline provides a mock function with given fields: _a0, _a1

func (*SubscriberServer) ModifyPushConfig

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

ModifyPushConfig provides a mock function with given fields: _a0, _a1

func (*SubscriberServer) Pull

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

Pull provides a mock function with given fields: _a0, _a1

func (*SubscriberServer) Seek

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

Seek provides a mock function with given fields: _a0, _a1

func (*SubscriberServer) StreamingPull

func (_m *SubscriberServer) StreamingPull(_a0 pubsubpb.Subscriber_StreamingPullServer) error

StreamingPull provides a mock function with given fields: _a0

func (*SubscriberServer) UpdateSnapshot

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

UpdateSnapshot provides a mock function with given fields: _a0, _a1

func (*SubscriberServer) UpdateSubscription

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

UpdateSubscription provides a mock function with given fields: _a0, _a1

type SubscriberServer_Acknowledge_Call

type SubscriberServer_Acknowledge_Call struct {
	*mock.Call
}

SubscriberServer_Acknowledge_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Acknowledge'

func (*SubscriberServer_Acknowledge_Call) Return

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

func (*SubscriberServer_Acknowledge_Call) Run

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

func (*SubscriberServer_Acknowledge_Call) RunAndReturn

func (_c *SubscriberServer_Acknowledge_Call) RunAndReturn(run func(context.Context, *pubsubpb.AcknowledgeRequest) (*emptypb.Empty, error)) *SubscriberServer_Acknowledge_Call

type SubscriberServer_CreateSnapshot_Call

type SubscriberServer_CreateSnapshot_Call struct {
	*mock.Call
}

SubscriberServer_CreateSnapshot_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateSnapshot'

func (*SubscriberServer_CreateSnapshot_Call) Return

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

func (*SubscriberServer_CreateSnapshot_Call) Run

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

func (*SubscriberServer_CreateSnapshot_Call) RunAndReturn

func (_c *SubscriberServer_CreateSnapshot_Call) RunAndReturn(run func(context.Context, *pubsubpb.CreateSnapshotRequest) (*pubsubpb.Snapshot, error)) *SubscriberServer_CreateSnapshot_Call

type SubscriberServer_CreateSubscription_Call

type SubscriberServer_CreateSubscription_Call struct {
	*mock.Call
}

SubscriberServer_CreateSubscription_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateSubscription'

func (*SubscriberServer_CreateSubscription_Call) Return

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

func (*SubscriberServer_CreateSubscription_Call) Run

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

func (*SubscriberServer_CreateSubscription_Call) RunAndReturn

func (_c *SubscriberServer_CreateSubscription_Call) RunAndReturn(run func(context.Context, *pubsubpb.Subscription) (*pubsubpb.Subscription, error)) *SubscriberServer_CreateSubscription_Call

type SubscriberServer_DeleteSnapshot_Call

type SubscriberServer_DeleteSnapshot_Call struct {
	*mock.Call
}

SubscriberServer_DeleteSnapshot_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteSnapshot'

func (*SubscriberServer_DeleteSnapshot_Call) Return

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

func (*SubscriberServer_DeleteSnapshot_Call) Run

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

func (*SubscriberServer_DeleteSnapshot_Call) RunAndReturn

func (_c *SubscriberServer_DeleteSnapshot_Call) RunAndReturn(run func(context.Context, *pubsubpb.DeleteSnapshotRequest) (*emptypb.Empty, error)) *SubscriberServer_DeleteSnapshot_Call

type SubscriberServer_DeleteSubscription_Call

type SubscriberServer_DeleteSubscription_Call struct {
	*mock.Call
}

SubscriberServer_DeleteSubscription_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteSubscription'

func (*SubscriberServer_DeleteSubscription_Call) Return

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

func (*SubscriberServer_DeleteSubscription_Call) Run

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

func (*SubscriberServer_DeleteSubscription_Call) RunAndReturn

func (_c *SubscriberServer_DeleteSubscription_Call) RunAndReturn(run func(context.Context, *pubsubpb.DeleteSubscriptionRequest) (*emptypb.Empty, error)) *SubscriberServer_DeleteSubscription_Call

type SubscriberServer_Expecter

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

func (*SubscriberServer_Expecter) Acknowledge

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

Acknowledge is a helper method to define mock.On call

• _a0 context.Context
• _a1 *pubsubpb.AcknowledgeRequest

func (*SubscriberServer_Expecter) CreateSnapshot

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

CreateSnapshot is a helper method to define mock.On call

• _a0 context.Context
• _a1 *pubsubpb.CreateSnapshotRequest

func (*SubscriberServer_Expecter) CreateSubscription

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

CreateSubscription is a helper method to define mock.On call

• _a0 context.Context
• _a1 *pubsubpb.Subscription

func (*SubscriberServer_Expecter) DeleteSnapshot

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

DeleteSnapshot is a helper method to define mock.On call

• _a0 context.Context
• _a1 *pubsubpb.DeleteSnapshotRequest

func (*SubscriberServer_Expecter) DeleteSubscription

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

DeleteSubscription is a helper method to define mock.On call

• _a0 context.Context
• _a1 *pubsubpb.DeleteSubscriptionRequest

func (*SubscriberServer_Expecter) GetSnapshot

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

GetSnapshot is a helper method to define mock.On call

• _a0 context.Context
• _a1 *pubsubpb.GetSnapshotRequest

func (*SubscriberServer_Expecter) GetSubscription

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

GetSubscription is a helper method to define mock.On call

• _a0 context.Context
• _a1 *pubsubpb.GetSubscriptionRequest

func (*SubscriberServer_Expecter) ListSnapshots

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

ListSnapshots is a helper method to define mock.On call

• _a0 context.Context
• _a1 *pubsubpb.ListSnapshotsRequest

func (*SubscriberServer_Expecter) ListSubscriptions

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

ListSubscriptions is a helper method to define mock.On call

• _a0 context.Context
• _a1 *pubsubpb.ListSubscriptionsRequest

func (*SubscriberServer_Expecter) ModifyAckDeadline

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

ModifyAckDeadline is a helper method to define mock.On call

• _a0 context.Context
• _a1 *pubsubpb.ModifyAckDeadlineRequest

func (*SubscriberServer_Expecter) ModifyPushConfig

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

ModifyPushConfig is a helper method to define mock.On call

• _a0 context.Context
• _a1 *pubsubpb.ModifyPushConfigRequest

func (*SubscriberServer_Expecter) Pull

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

Pull is a helper method to define mock.On call

• _a0 context.Context
• _a1 *pubsubpb.PullRequest

func (*SubscriberServer_Expecter) Seek

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

Seek is a helper method to define mock.On call

• _a0 context.Context
• _a1 *pubsubpb.SeekRequest

func (*SubscriberServer_Expecter) StreamingPull

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

StreamingPull is a helper method to define mock.On call

• _a0 pubsubpb.Subscriber_StreamingPullServer

func (*SubscriberServer_Expecter) UpdateSnapshot

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

UpdateSnapshot is a helper method to define mock.On call

• _a0 context.Context
• _a1 *pubsubpb.UpdateSnapshotRequest

func (*SubscriberServer_Expecter) UpdateSubscription

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

UpdateSubscription is a helper method to define mock.On call

• _a0 context.Context
• _a1 *pubsubpb.UpdateSubscriptionRequest

type SubscriberServer_GetSnapshot_Call

type SubscriberServer_GetSnapshot_Call struct {
	*mock.Call
}

SubscriberServer_GetSnapshot_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetSnapshot'

func (*SubscriberServer_GetSnapshot_Call) Return

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

func (*SubscriberServer_GetSnapshot_Call) Run

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

func (*SubscriberServer_GetSnapshot_Call) RunAndReturn

func (_c *SubscriberServer_GetSnapshot_Call) RunAndReturn(run func(context.Context, *pubsubpb.GetSnapshotRequest) (*pubsubpb.Snapshot, error)) *SubscriberServer_GetSnapshot_Call

type SubscriberServer_GetSubscription_Call

type SubscriberServer_GetSubscription_Call struct {
	*mock.Call
}

SubscriberServer_GetSubscription_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetSubscription'

func (*SubscriberServer_GetSubscription_Call) Return

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

func (*SubscriberServer_GetSubscription_Call) Run

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

func (*SubscriberServer_GetSubscription_Call) RunAndReturn

func (_c *SubscriberServer_GetSubscription_Call) RunAndReturn(run func(context.Context, *pubsubpb.GetSubscriptionRequest) (*pubsubpb.Subscription, error)) *SubscriberServer_GetSubscription_Call

type SubscriberServer_ListSnapshots_Call

type SubscriberServer_ListSnapshots_Call struct {
	*mock.Call
}

SubscriberServer_ListSnapshots_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListSnapshots'

func (*SubscriberServer_ListSnapshots_Call) Return

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

func (*SubscriberServer_ListSnapshots_Call) Run

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

func (*SubscriberServer_ListSnapshots_Call) RunAndReturn

func (_c *SubscriberServer_ListSnapshots_Call) RunAndReturn(run func(context.Context, *pubsubpb.ListSnapshotsRequest) (*pubsubpb.ListSnapshotsResponse, error)) *SubscriberServer_ListSnapshots_Call

type SubscriberServer_ListSubscriptions_Call

type SubscriberServer_ListSubscriptions_Call struct {
	*mock.Call
}

SubscriberServer_ListSubscriptions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListSubscriptions'

func (*SubscriberServer_ListSubscriptions_Call) Return

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

func (*SubscriberServer_ListSubscriptions_Call) Run

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

func (*SubscriberServer_ListSubscriptions_Call) RunAndReturn

func (_c *SubscriberServer_ListSubscriptions_Call) RunAndReturn(run func(context.Context, *pubsubpb.ListSubscriptionsRequest) (*pubsubpb.ListSubscriptionsResponse, error)) *SubscriberServer_ListSubscriptions_Call

type SubscriberServer_ModifyAckDeadline_Call

type SubscriberServer_ModifyAckDeadline_Call struct {
	*mock.Call
}

SubscriberServer_ModifyAckDeadline_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ModifyAckDeadline'

func (*SubscriberServer_ModifyAckDeadline_Call) Return

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

func (*SubscriberServer_ModifyAckDeadline_Call) Run

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

func (*SubscriberServer_ModifyAckDeadline_Call) RunAndReturn

func (_c *SubscriberServer_ModifyAckDeadline_Call) RunAndReturn(run func(context.Context, *pubsubpb.ModifyAckDeadlineRequest) (*emptypb.Empty, error)) *SubscriberServer_ModifyAckDeadline_Call

type SubscriberServer_ModifyPushConfig_Call

type SubscriberServer_ModifyPushConfig_Call struct {
	*mock.Call
}

SubscriberServer_ModifyPushConfig_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ModifyPushConfig'

func (*SubscriberServer_ModifyPushConfig_Call) Return

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

func (*SubscriberServer_ModifyPushConfig_Call) Run

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

func (*SubscriberServer_ModifyPushConfig_Call) RunAndReturn

func (_c *SubscriberServer_ModifyPushConfig_Call) RunAndReturn(run func(context.Context, *pubsubpb.ModifyPushConfigRequest) (*emptypb.Empty, error)) *SubscriberServer_ModifyPushConfig_Call

type SubscriberServer_Pull_Call

type SubscriberServer_Pull_Call struct {
	*mock.Call
}

SubscriberServer_Pull_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Pull'

func (*SubscriberServer_Pull_Call) Return

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

func (*SubscriberServer_Pull_Call) Run

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

func (*SubscriberServer_Pull_Call) RunAndReturn

func (_c *SubscriberServer_Pull_Call) RunAndReturn(run func(context.Context, *pubsubpb.PullRequest) (*pubsubpb.PullResponse, error)) *SubscriberServer_Pull_Call

type SubscriberServer_Seek_Call

type SubscriberServer_Seek_Call struct {
	*mock.Call
}

SubscriberServer_Seek_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Seek'

func (*SubscriberServer_Seek_Call) Return

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

func (*SubscriberServer_Seek_Call) Run

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

func (*SubscriberServer_Seek_Call) RunAndReturn

func (_c *SubscriberServer_Seek_Call) RunAndReturn(run func(context.Context, *pubsubpb.SeekRequest) (*pubsubpb.SeekResponse, error)) *SubscriberServer_Seek_Call

type SubscriberServer_StreamingPull_Call

type SubscriberServer_StreamingPull_Call struct {
	*mock.Call
}

SubscriberServer_StreamingPull_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StreamingPull'

func (*SubscriberServer_StreamingPull_Call) Return

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

func (*SubscriberServer_StreamingPull_Call) Run

func (_c *SubscriberServer_StreamingPull_Call) Run(run func(_a0 pubsubpb.Subscriber_StreamingPullServer)) *SubscriberServer_StreamingPull_Call

func (*SubscriberServer_StreamingPull_Call) RunAndReturn

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

type SubscriberServer_UpdateSnapshot_Call

type SubscriberServer_UpdateSnapshot_Call struct {
	*mock.Call
}

SubscriberServer_UpdateSnapshot_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateSnapshot'

func (*SubscriberServer_UpdateSnapshot_Call) Return

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

func (*SubscriberServer_UpdateSnapshot_Call) Run

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

func (*SubscriberServer_UpdateSnapshot_Call) RunAndReturn

func (_c *SubscriberServer_UpdateSnapshot_Call) RunAndReturn(run func(context.Context, *pubsubpb.UpdateSnapshotRequest) (*pubsubpb.Snapshot, error)) *SubscriberServer_UpdateSnapshot_Call

type SubscriberServer_UpdateSubscription_Call

type SubscriberServer_UpdateSubscription_Call struct {
	*mock.Call
}

SubscriberServer_UpdateSubscription_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateSubscription'

func (*SubscriberServer_UpdateSubscription_Call) Return

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

func (*SubscriberServer_UpdateSubscription_Call) Run

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

func (*SubscriberServer_UpdateSubscription_Call) RunAndReturn

func (_c *SubscriberServer_UpdateSubscription_Call) RunAndReturn(run func(context.Context, *pubsubpb.UpdateSubscriptionRequest) (*pubsubpb.Subscription, error)) *SubscriberServer_UpdateSubscription_Call