Documentation ¶
Index ¶
- type ClusterManagerServer
- func (_m *ClusterManagerServer) CancelOperation(_a0 context.Context, _a1 *containerpb.CancelOperationRequest) (*emptypb.Empty, 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
- 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
- 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
- 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
- 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
- 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
- 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
- type ClusterManagerServer_Expecter
- func (_e *ClusterManagerServer_Expecter) CancelOperation(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_CancelOperation_Call
- func (_e *ClusterManagerServer_Expecter) CompleteIPRotation(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_CompleteIPRotation_Call
- func (_e *ClusterManagerServer_Expecter) CompleteNodePoolUpgrade(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_CompleteNodePoolUpgrade_Call
- func (_e *ClusterManagerServer_Expecter) CreateCluster(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_CreateCluster_Call
- func (_e *ClusterManagerServer_Expecter) CreateNodePool(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_CreateNodePool_Call
- func (_e *ClusterManagerServer_Expecter) DeleteCluster(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_DeleteCluster_Call
- func (_e *ClusterManagerServer_Expecter) DeleteNodePool(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_DeleteNodePool_Call
- func (_e *ClusterManagerServer_Expecter) GetCluster(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_GetCluster_Call
- func (_e *ClusterManagerServer_Expecter) GetJSONWebKeys(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_GetJSONWebKeys_Call
- func (_e *ClusterManagerServer_Expecter) GetNodePool(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_GetNodePool_Call
- func (_e *ClusterManagerServer_Expecter) GetOperation(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_GetOperation_Call
- func (_e *ClusterManagerServer_Expecter) GetServerConfig(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_GetServerConfig_Call
- func (_e *ClusterManagerServer_Expecter) ListClusters(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_ListClusters_Call
- func (_e *ClusterManagerServer_Expecter) ListNodePools(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_ListNodePools_Call
- func (_e *ClusterManagerServer_Expecter) ListOperations(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_ListOperations_Call
- func (_e *ClusterManagerServer_Expecter) ListUsableSubnetworks(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_ListUsableSubnetworks_Call
- func (_e *ClusterManagerServer_Expecter) RollbackNodePoolUpgrade(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_RollbackNodePoolUpgrade_Call
- func (_e *ClusterManagerServer_Expecter) SetAddonsConfig(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_SetAddonsConfig_Call
- func (_e *ClusterManagerServer_Expecter) SetLabels(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_SetLabels_Call
- func (_e *ClusterManagerServer_Expecter) SetLegacyAbac(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_SetLegacyAbac_Call
- func (_e *ClusterManagerServer_Expecter) SetLocations(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_SetLocations_Call
- func (_e *ClusterManagerServer_Expecter) SetLoggingService(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_SetLoggingService_Call
- func (_e *ClusterManagerServer_Expecter) SetMaintenancePolicy(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_SetMaintenancePolicy_Call
- func (_e *ClusterManagerServer_Expecter) SetMasterAuth(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_SetMasterAuth_Call
- func (_e *ClusterManagerServer_Expecter) SetMonitoringService(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_SetMonitoringService_Call
- func (_e *ClusterManagerServer_Expecter) SetNetworkPolicy(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_SetNetworkPolicy_Call
- func (_e *ClusterManagerServer_Expecter) SetNodePoolAutoscaling(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_SetNodePoolAutoscaling_Call
- func (_e *ClusterManagerServer_Expecter) SetNodePoolManagement(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_SetNodePoolManagement_Call
- func (_e *ClusterManagerServer_Expecter) SetNodePoolSize(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_SetNodePoolSize_Call
- func (_e *ClusterManagerServer_Expecter) StartIPRotation(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_StartIPRotation_Call
- func (_e *ClusterManagerServer_Expecter) UpdateCluster(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_UpdateCluster_Call
- func (_e *ClusterManagerServer_Expecter) UpdateMaster(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_UpdateMaster_Call
- func (_e *ClusterManagerServer_Expecter) UpdateNodePool(_a0 interface{}, _a1 interface{}) *ClusterManagerServer_UpdateNodePool_Call
- type ClusterManagerServer_GetCluster_Call
- 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
- type ClusterManagerServer_GetNodePool_Call
- type 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
- 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
- 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
- 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
- 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
- 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
- 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
- type 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
- type 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
- 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
- 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
- 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
- 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
- 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
- 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
- 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
- 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
- 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
- type 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
- type 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
- type 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
- 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
- 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
- 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
- type PublisherServer_ListTopics_Call
- type PublisherServer_Publish_Call
- type PublisherServer_UpdateTopic_Call
- type 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
- type SubscriberServer_CreateSnapshot_Call
- type SubscriberServer_CreateSubscription_Call
- type 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
- 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
- type SubscriberServer_GetSubscription_Call
- type 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
- type SubscriberServer_ModifyAckDeadline_Call
- type SubscriberServer_ModifyPushConfig_Call
- type SubscriberServer_Pull_Call
- type SubscriberServer_Seek_Call
- type SubscriberServer_StreamingPull_Call
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClusterManagerServer ¶
ClusterManagerServer is an autogenerated mock type for the ClusterManagerServer type
func NewClusterManagerServer ¶
func NewClusterManagerServer(t mockConstructorTestingTNewClusterManagerServer) *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.
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) 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 ¶
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
type ClusterManagerServer_CompleteIPRotation_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
type ClusterManagerServer_CompleteNodePoolUpgrade_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
type ClusterManagerServer_CreateCluster_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
type ClusterManagerServer_CreateNodePool_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
type ClusterManagerServer_DeleteCluster_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
type ClusterManagerServer_DeleteNodePool_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
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) 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 ¶
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
type ClusterManagerServer_GetJSONWebKeys_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
type ClusterManagerServer_GetNodePool_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
type ClusterManagerServer_GetOperation_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
type ClusterManagerServer_GetServerConfig_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
type ClusterManagerServer_ListClusters_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
type ClusterManagerServer_ListNodePools_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
type ClusterManagerServer_ListOperations_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
type ClusterManagerServer_ListUsableSubnetworks_Call ¶
ClusterManagerServer_ListUsableSubnetworks_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListUsableSubnetworks'
func (*ClusterManagerServer_ListUsableSubnetworks_Call) Run ¶
func (_c *ClusterManagerServer_ListUsableSubnetworks_Call) Run(run func(_a0 context.Context, _a1 *containerpb.ListUsableSubnetworksRequest)) *ClusterManagerServer_ListUsableSubnetworks_Call
type ClusterManagerServer_RollbackNodePoolUpgrade_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
type ClusterManagerServer_SetAddonsConfig_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
type ClusterManagerServer_SetLabels_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
type ClusterManagerServer_SetLegacyAbac_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
type ClusterManagerServer_SetLocations_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
type ClusterManagerServer_SetLoggingService_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
type ClusterManagerServer_SetMaintenancePolicy_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
type ClusterManagerServer_SetMasterAuth_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
type ClusterManagerServer_SetMonitoringService_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
type ClusterManagerServer_SetNetworkPolicy_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
type ClusterManagerServer_SetNodePoolAutoscaling_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
type ClusterManagerServer_SetNodePoolManagement_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
type ClusterManagerServer_SetNodePoolSize_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
type ClusterManagerServer_StartIPRotation_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
type ClusterManagerServer_UpdateCluster_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
type ClusterManagerServer_UpdateMaster_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
type ClusterManagerServer_UpdateNodePool_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
type PublisherServer ¶
PublisherServer is an autogenerated mock type for the PublisherServer type
func NewPublisherServer ¶
func NewPublisherServer(t mockConstructorTestingTNewPublisherServer) *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.
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 ¶
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
type PublisherServer_DeleteTopic_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
type PublisherServer_DetachSubscription_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
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 ¶
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
type PublisherServer_ListTopicSnapshots_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
type PublisherServer_ListTopicSubscriptions_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
type PublisherServer_ListTopics_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
type PublisherServer_Publish_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
type PublisherServer_UpdateTopic_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
type SubscriberServer ¶
SubscriberServer is an autogenerated mock type for the SubscriberServer type
func NewSubscriberServer ¶
func NewSubscriberServer(t mockConstructorTestingTNewSubscriberServer) *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.
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 ¶
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
type SubscriberServer_CreateSnapshot_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
type SubscriberServer_CreateSubscription_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
type SubscriberServer_DeleteSnapshot_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
type SubscriberServer_DeleteSubscription_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
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 ¶
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
type SubscriberServer_GetSubscription_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
type SubscriberServer_ListSnapshots_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
type SubscriberServer_ListSubscriptions_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
type SubscriberServer_ModifyAckDeadline_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
type SubscriberServer_ModifyPushConfig_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
type SubscriberServer_Pull_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
type SubscriberServer_Seek_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
type SubscriberServer_StreamingPull_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
type SubscriberServer_UpdateSnapshot_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
type SubscriberServer_UpdateSubscription_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