mocks

package
v1.0.19 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 1, 2022 License: BSD-3-Clause Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ClusterManagerServer 

type ClusterManagerServer struct {
	mock.Mock
}

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 *container.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 *container.CompleteIPRotationRequest) (*container.Operation, error)

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

func (*ClusterManagerServer) CompleteNodePoolUpgrade 

func (_m *ClusterManagerServer) CompleteNodePoolUpgrade(_a0 context.Context, _a1 *container.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 *container.CreateClusterRequest) (*container.Operation, error)

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

func (*ClusterManagerServer) CreateNodePool 

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

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

func (*ClusterManagerServer) DeleteCluster 

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

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

func (*ClusterManagerServer) DeleteNodePool 

func (_m *ClusterManagerServer) DeleteNodePool(_a0 context.Context, _a1 *container.DeleteNodePoolRequest) (*container.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 *container.GetClusterRequest) (*container.Cluster, error)

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

func (*ClusterManagerServer) GetJSONWebKeys 

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

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

func (*ClusterManagerServer) GetNodePool 

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

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

func (*ClusterManagerServer) GetOperation 

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

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

func (*ClusterManagerServer) GetServerConfig 

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

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

func (*ClusterManagerServer) ListClusters 

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

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

func (*ClusterManagerServer) ListNodePools 

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

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

func (*ClusterManagerServer) ListOperations 

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

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

func (*ClusterManagerServer) ListUsableSubnetworks 

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

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

func (*ClusterManagerServer) RollbackNodePoolUpgrade 

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

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

func (*ClusterManagerServer) SetAddonsConfig 

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

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

func (*ClusterManagerServer) SetLabels 

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

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

func (*ClusterManagerServer) SetLegacyAbac 

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

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

func (*ClusterManagerServer) SetLocations 

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

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

func (*ClusterManagerServer) SetLoggingService 

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

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

func (*ClusterManagerServer) SetMaintenancePolicy 

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

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

func (*ClusterManagerServer) SetMasterAuth 

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

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

func (*ClusterManagerServer) SetMonitoringService 

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

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

func (*ClusterManagerServer) SetNetworkPolicy 

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

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

func (*ClusterManagerServer) SetNodePoolAutoscaling 

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

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

func (*ClusterManagerServer) SetNodePoolManagement 

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

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

func (*ClusterManagerServer) SetNodePoolSize 

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

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

func (*ClusterManagerServer) StartIPRotation 

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

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

func (*ClusterManagerServer) UpdateCluster 

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

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

func (*ClusterManagerServer) UpdateMaster 

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

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

func (*ClusterManagerServer) UpdateNodePool 

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

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

type ClusterManagerServer_CancelOperation_Call 

type ClusterManagerServer_CancelOperation_Call struct {
	*mock.Call
}

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

func (*ClusterManagerServer_CancelOperation_Call) Return 

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

func (*ClusterManagerServer_CancelOperation_Call) Run 

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

type ClusterManagerServer_CompleteIPRotation_Call 

type ClusterManagerServer_CompleteIPRotation_Call struct {
	*mock.Call
}

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

func (*ClusterManagerServer_CompleteIPRotation_Call) Return 

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

func (*ClusterManagerServer_CompleteIPRotation_Call) Run 

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

type ClusterManagerServer_CompleteNodePoolUpgrade_Call 

type ClusterManagerServer_CompleteNodePoolUpgrade_Call struct {
	*mock.Call
}

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

func (*ClusterManagerServer_CompleteNodePoolUpgrade_Call) Return 

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

func (*ClusterManagerServer_CompleteNodePoolUpgrade_Call) Run 

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

type ClusterManagerServer_CreateCluster_Call 

type ClusterManagerServer_CreateCluster_Call struct {
	*mock.Call
}

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

func (*ClusterManagerServer_CreateCluster_Call) Return 

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

func (*ClusterManagerServer_CreateCluster_Call) Run 

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

type ClusterManagerServer_CreateNodePool_Call 

type ClusterManagerServer_CreateNodePool_Call struct {
	*mock.Call
}

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

func (*ClusterManagerServer_CreateNodePool_Call) Return 

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

func (*ClusterManagerServer_CreateNodePool_Call) Run 

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

type ClusterManagerServer_DeleteCluster_Call 

type ClusterManagerServer_DeleteCluster_Call struct {
	*mock.Call
}

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

func (*ClusterManagerServer_DeleteCluster_Call) Return 

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

func (*ClusterManagerServer_DeleteCluster_Call) Run 

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

type ClusterManagerServer_DeleteNodePool_Call 

type ClusterManagerServer_DeleteNodePool_Call struct {
	*mock.Call
}

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

func (*ClusterManagerServer_DeleteNodePool_Call) Return 

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

func (*ClusterManagerServer_DeleteNodePool_Call) Run 

func (_c *ClusterManagerServer_DeleteNodePool_Call) Run(run func(_a0 context.Context, _a1 *container.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 *container.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 *container.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 *container.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 *container.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 *container.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 *container.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 *container.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 *container.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 *container.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 *container.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 *container.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 *container.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 *container.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 *container.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 *container.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 *container.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 *container.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 *container.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 *container.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 *container.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 *container.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 *container.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 *container.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 *container.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 *container.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 *container.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 *container.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 *container.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 *container.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 *container.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 *container.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 *container.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 *container.UpdateNodePoolRequest

type ClusterManagerServer_GetCluster_Call 

type ClusterManagerServer_GetCluster_Call struct {
	*mock.Call
}

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

func (*ClusterManagerServer_GetCluster_Call) Return 

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

func (*ClusterManagerServer_GetCluster_Call) Run 

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

type ClusterManagerServer_GetJSONWebKeys_Call 

type ClusterManagerServer_GetJSONWebKeys_Call struct {
	*mock.Call
}

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

func (*ClusterManagerServer_GetJSONWebKeys_Call) Return 

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

func (*ClusterManagerServer_GetJSONWebKeys_Call) Run 

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

type ClusterManagerServer_GetNodePool_Call 

type ClusterManagerServer_GetNodePool_Call struct {
	*mock.Call
}

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

func (*ClusterManagerServer_GetNodePool_Call) Return 

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

func (*ClusterManagerServer_GetNodePool_Call) Run 

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

type ClusterManagerServer_GetOperation_Call 

type ClusterManagerServer_GetOperation_Call struct {
	*mock.Call
}

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

func (*ClusterManagerServer_GetOperation_Call) Return 

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

func (*ClusterManagerServer_GetOperation_Call) Run 

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

type ClusterManagerServer_GetServerConfig_Call 

type ClusterManagerServer_GetServerConfig_Call struct {
	*mock.Call
}

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

func (*ClusterManagerServer_GetServerConfig_Call) Return 

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

func (*ClusterManagerServer_GetServerConfig_Call) Run 

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

type ClusterManagerServer_ListClusters_Call 

type ClusterManagerServer_ListClusters_Call struct {
	*mock.Call
}

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

func (*ClusterManagerServer_ListClusters_Call) Return 

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

func (*ClusterManagerServer_ListClusters_Call) Run 

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

type ClusterManagerServer_ListNodePools_Call 

type ClusterManagerServer_ListNodePools_Call struct {
	*mock.Call
}

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

func (*ClusterManagerServer_ListNodePools_Call) Return 

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

func (*ClusterManagerServer_ListNodePools_Call) Run 

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

type ClusterManagerServer_ListOperations_Call 

type ClusterManagerServer_ListOperations_Call struct {
	*mock.Call
}

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

func (*ClusterManagerServer_ListOperations_Call) Return 

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

func (*ClusterManagerServer_ListOperations_Call) Run 

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

type ClusterManagerServer_ListUsableSubnetworks_Call 

type ClusterManagerServer_ListUsableSubnetworks_Call struct {
	*mock.Call
}

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

func (*ClusterManagerServer_ListUsableSubnetworks_Call) Return 

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

func (*ClusterManagerServer_ListUsableSubnetworks_Call) Run 

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

type ClusterManagerServer_RollbackNodePoolUpgrade_Call 

type ClusterManagerServer_RollbackNodePoolUpgrade_Call struct {
	*mock.Call
}

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

func (*ClusterManagerServer_RollbackNodePoolUpgrade_Call) Return 

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

func (*ClusterManagerServer_RollbackNodePoolUpgrade_Call) Run 

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

type ClusterManagerServer_SetAddonsConfig_Call 

type ClusterManagerServer_SetAddonsConfig_Call struct {
	*mock.Call
}

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

func (*ClusterManagerServer_SetAddonsConfig_Call) Return 

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

func (*ClusterManagerServer_SetAddonsConfig_Call) Run 

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

type ClusterManagerServer_SetLabels_Call 

type ClusterManagerServer_SetLabels_Call struct {
	*mock.Call
}

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

func (*ClusterManagerServer_SetLabels_Call) Return 

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

func (*ClusterManagerServer_SetLabels_Call) Run 

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

type ClusterManagerServer_SetLegacyAbac_Call 

type ClusterManagerServer_SetLegacyAbac_Call struct {
	*mock.Call
}

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

func (*ClusterManagerServer_SetLegacyAbac_Call) Return 

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

func (*ClusterManagerServer_SetLegacyAbac_Call) Run 

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

type ClusterManagerServer_SetLocations_Call 

type ClusterManagerServer_SetLocations_Call struct {
	*mock.Call
}

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

func (*ClusterManagerServer_SetLocations_Call) Return 

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

func (*ClusterManagerServer_SetLocations_Call) Run 

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

type ClusterManagerServer_SetLoggingService_Call 

type ClusterManagerServer_SetLoggingService_Call struct {
	*mock.Call
}

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

func (*ClusterManagerServer_SetLoggingService_Call) Return 

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

func (*ClusterManagerServer_SetLoggingService_Call) Run 

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

type ClusterManagerServer_SetMaintenancePolicy_Call 

type ClusterManagerServer_SetMaintenancePolicy_Call struct {
	*mock.Call
}

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

func (*ClusterManagerServer_SetMaintenancePolicy_Call) Return 

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

func (*ClusterManagerServer_SetMaintenancePolicy_Call) Run 

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

type ClusterManagerServer_SetMasterAuth_Call 

type ClusterManagerServer_SetMasterAuth_Call struct {
	*mock.Call
}

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

func (*ClusterManagerServer_SetMasterAuth_Call) Return 

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

func (*ClusterManagerServer_SetMasterAuth_Call) Run 

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

type ClusterManagerServer_SetMonitoringService_Call 

type ClusterManagerServer_SetMonitoringService_Call struct {
	*mock.Call
}

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

func (*ClusterManagerServer_SetMonitoringService_Call) Return 

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

func (*ClusterManagerServer_SetMonitoringService_Call) Run 

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

type ClusterManagerServer_SetNetworkPolicy_Call 

type ClusterManagerServer_SetNetworkPolicy_Call struct {
	*mock.Call
}

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

func (*ClusterManagerServer_SetNetworkPolicy_Call) Return 

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

func (*ClusterManagerServer_SetNetworkPolicy_Call) Run 

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

type ClusterManagerServer_SetNodePoolAutoscaling_Call 

type ClusterManagerServer_SetNodePoolAutoscaling_Call struct {
	*mock.Call
}

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

func (*ClusterManagerServer_SetNodePoolAutoscaling_Call) Return 

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

func (*ClusterManagerServer_SetNodePoolAutoscaling_Call) Run 

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

type ClusterManagerServer_SetNodePoolManagement_Call 

type ClusterManagerServer_SetNodePoolManagement_Call struct {
	*mock.Call
}

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

func (*ClusterManagerServer_SetNodePoolManagement_Call) Return 

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

func (*ClusterManagerServer_SetNodePoolManagement_Call) Run 

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

type ClusterManagerServer_SetNodePoolSize_Call 

type ClusterManagerServer_SetNodePoolSize_Call struct {
	*mock.Call
}

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

func (*ClusterManagerServer_SetNodePoolSize_Call) Return 

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

func (*ClusterManagerServer_SetNodePoolSize_Call) Run 

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

type ClusterManagerServer_StartIPRotation_Call 

type ClusterManagerServer_StartIPRotation_Call struct {
	*mock.Call
}

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

func (*ClusterManagerServer_StartIPRotation_Call) Return 

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

func (*ClusterManagerServer_StartIPRotation_Call) Run 

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

type ClusterManagerServer_UpdateCluster_Call 

type ClusterManagerServer_UpdateCluster_Call struct {
	*mock.Call
}

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

func (*ClusterManagerServer_UpdateCluster_Call) Return 

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

func (*ClusterManagerServer_UpdateCluster_Call) Run 

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

type ClusterManagerServer_UpdateMaster_Call 

type ClusterManagerServer_UpdateMaster_Call struct {
	*mock.Call
}

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

func (*ClusterManagerServer_UpdateMaster_Call) Return 

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

func (*ClusterManagerServer_UpdateMaster_Call) Run 

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

type ClusterManagerServer_UpdateNodePool_Call 

type ClusterManagerServer_UpdateNodePool_Call struct {
	*mock.Call
}

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

func (*ClusterManagerServer_UpdateNodePool_Call) Return 

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

func (*ClusterManagerServer_UpdateNodePool_Call) Run 

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

type PublisherServer 

type PublisherServer struct {
	mock.Mock
}

PublisherServer is an autogenerated mock type for the PublisherServer type

func NewPublisherServer 

func NewPublisherServer(t 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 *pubsub.Topic) (*pubsub.Topic, error)

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

func (*PublisherServer) DeleteTopic 

func (_m *PublisherServer) DeleteTopic(_a0 context.Context, _a1 *pubsub.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 *pubsub.DetachSubscriptionRequest) (*pubsub.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 *pubsub.GetTopicRequest) (*pubsub.Topic, error)

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

func (*PublisherServer) ListTopicSnapshots 

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

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

func (*PublisherServer) ListTopicSubscriptions 

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

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

func (*PublisherServer) ListTopics 

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

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

func (*PublisherServer) Publish 

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

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

func (*PublisherServer) UpdateTopic 

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

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

type PublisherServer_CreateTopic_Call 

type PublisherServer_CreateTopic_Call struct {
	*mock.Call
}

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

func (*PublisherServer_CreateTopic_Call) Return 

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

func (*PublisherServer_CreateTopic_Call) Run 

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

type PublisherServer_DeleteTopic_Call 

type PublisherServer_DeleteTopic_Call struct {
	*mock.Call
}

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

func (*PublisherServer_DeleteTopic_Call) Return 

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

func (*PublisherServer_DeleteTopic_Call) Run 

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

type PublisherServer_DetachSubscription_Call 

type PublisherServer_DetachSubscription_Call struct {
	*mock.Call
}

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

func (*PublisherServer_DetachSubscription_Call) Return 

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

func (*PublisherServer_DetachSubscription_Call) Run 

func (_c *PublisherServer_DetachSubscription_Call) Run(run func(_a0 context.Context, _a1 *pubsub.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 *pubsub.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 *pubsub.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 *pubsub.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 *pubsub.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 *pubsub.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 *pubsub.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 *pubsub.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 *pubsub.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 *pubsub.UpdateTopicRequest

type PublisherServer_GetTopic_Call 

type PublisherServer_GetTopic_Call struct {
	*mock.Call
}

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

func (*PublisherServer_GetTopic_Call) Return 

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

func (*PublisherServer_GetTopic_Call) Run 

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

type PublisherServer_ListTopicSnapshots_Call 

type PublisherServer_ListTopicSnapshots_Call struct {
	*mock.Call
}

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

func (*PublisherServer_ListTopicSnapshots_Call) Return 

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

func (*PublisherServer_ListTopicSnapshots_Call) Run 

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

type PublisherServer_ListTopicSubscriptions_Call 

type PublisherServer_ListTopicSubscriptions_Call struct {
	*mock.Call
}

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

func (*PublisherServer_ListTopicSubscriptions_Call) Return 

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

func (*PublisherServer_ListTopicSubscriptions_Call) Run 

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

type PublisherServer_ListTopics_Call 

type PublisherServer_ListTopics_Call struct {
	*mock.Call
}

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

func (*PublisherServer_ListTopics_Call) Return 

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

func (*PublisherServer_ListTopics_Call) Run 

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

type PublisherServer_Publish_Call 

type PublisherServer_Publish_Call struct {
	*mock.Call
}

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

func (*PublisherServer_Publish_Call) Return 

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

func (*PublisherServer_Publish_Call) Run 

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

type PublisherServer_UpdateTopic_Call 

type PublisherServer_UpdateTopic_Call struct {
	*mock.Call
}

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

func (*PublisherServer_UpdateTopic_Call) Return 

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

func (*PublisherServer_UpdateTopic_Call) Run 

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

type SubscriberServer 

type SubscriberServer struct {
	mock.Mock
}

SubscriberServer is an autogenerated mock type for the SubscriberServer type

func NewSubscriberServer 

func NewSubscriberServer(t 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 *pubsub.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 *pubsub.CreateSnapshotRequest) (*pubsub.Snapshot, error)

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

func (*SubscriberServer) CreateSubscription 

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

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

func (*SubscriberServer) DeleteSnapshot 

func (_m *SubscriberServer) DeleteSnapshot(_a0 context.Context, _a1 *pubsub.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 *pubsub.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 *pubsub.GetSnapshotRequest) (*pubsub.Snapshot, error)

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

func (*SubscriberServer) GetSubscription 

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

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

func (*SubscriberServer) ListSnapshots 

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

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

func (*SubscriberServer) ListSubscriptions 

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

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

func (*SubscriberServer) ModifyAckDeadline 

func (_m *SubscriberServer) ModifyAckDeadline(_a0 context.Context, _a1 *pubsub.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 *pubsub.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 *pubsub.PullRequest) (*pubsub.PullResponse, error)

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

func (*SubscriberServer) Seek 

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

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

func (*SubscriberServer) StreamingPull 

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

StreamingPull provides a mock function with given fields: _a0

func (*SubscriberServer) UpdateSnapshot 

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

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

func (*SubscriberServer) UpdateSubscription 

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

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

type SubscriberServer_Acknowledge_Call 

type SubscriberServer_Acknowledge_Call struct {
	*mock.Call
}

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

func (*SubscriberServer_Acknowledge_Call) Return 

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

func (*SubscriberServer_Acknowledge_Call) Run 

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

type SubscriberServer_CreateSnapshot_Call 

type SubscriberServer_CreateSnapshot_Call struct {
	*mock.Call
}

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

func (*SubscriberServer_CreateSnapshot_Call) Return 

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

func (*SubscriberServer_CreateSnapshot_Call) Run 

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

type SubscriberServer_CreateSubscription_Call 

type SubscriberServer_CreateSubscription_Call struct {
	*mock.Call
}

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

func (*SubscriberServer_CreateSubscription_Call) Return 

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

func (*SubscriberServer_CreateSubscription_Call) Run 

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

type SubscriberServer_DeleteSnapshot_Call 

type SubscriberServer_DeleteSnapshot_Call struct {
	*mock.Call
}

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

func (*SubscriberServer_DeleteSnapshot_Call) Return 

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

func (*SubscriberServer_DeleteSnapshot_Call) Run 

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

type SubscriberServer_DeleteSubscription_Call 

type SubscriberServer_DeleteSubscription_Call struct {
	*mock.Call
}

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

func (*SubscriberServer_DeleteSubscription_Call) Return 

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

func (*SubscriberServer_DeleteSubscription_Call) Run 

func (_c *SubscriberServer_DeleteSubscription_Call) Run(run func(_a0 context.Context, _a1 *pubsub.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 *pubsub.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 *pubsub.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 *pubsub.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 *pubsub.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 *pubsub.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 *pubsub.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 *pubsub.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 *pubsub.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 *pubsub.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 *pubsub.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 *pubsub.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 *pubsub.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 *pubsub.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 pubsub.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 *pubsub.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 *pubsub.UpdateSubscriptionRequest

type SubscriberServer_GetSnapshot_Call 

type SubscriberServer_GetSnapshot_Call struct {
	*mock.Call
}

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

func (*SubscriberServer_GetSnapshot_Call) Return 

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

func (*SubscriberServer_GetSnapshot_Call) Run 

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

type SubscriberServer_GetSubscription_Call 

type SubscriberServer_GetSubscription_Call struct {
	*mock.Call
}

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

func (*SubscriberServer_GetSubscription_Call) Return 

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

func (*SubscriberServer_GetSubscription_Call) Run 

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

type SubscriberServer_ListSnapshots_Call 

type SubscriberServer_ListSnapshots_Call struct {
	*mock.Call
}

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

func (*SubscriberServer_ListSnapshots_Call) Return 

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

func (*SubscriberServer_ListSnapshots_Call) Run 

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

type SubscriberServer_ListSubscriptions_Call 

type SubscriberServer_ListSubscriptions_Call struct {
	*mock.Call
}

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

func (*SubscriberServer_ListSubscriptions_Call) Return 

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

func (*SubscriberServer_ListSubscriptions_Call) Run 

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

type SubscriberServer_ModifyAckDeadline_Call 

type SubscriberServer_ModifyAckDeadline_Call struct {
	*mock.Call
}

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

func (*SubscriberServer_ModifyAckDeadline_Call) Return 

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

func (*SubscriberServer_ModifyAckDeadline_Call) Run 

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

type SubscriberServer_ModifyPushConfig_Call 

type SubscriberServer_ModifyPushConfig_Call struct {
	*mock.Call
}

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

func (*SubscriberServer_ModifyPushConfig_Call) Return 

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

func (*SubscriberServer_ModifyPushConfig_Call) Run 

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

type SubscriberServer_Pull_Call 

type SubscriberServer_Pull_Call struct {
	*mock.Call
}

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

func (*SubscriberServer_Pull_Call) Return 

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

func (*SubscriberServer_Pull_Call) Run 

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

type SubscriberServer_Seek_Call 

type SubscriberServer_Seek_Call struct {
	*mock.Call
}

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

func (*SubscriberServer_Seek_Call) Return 

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

func (*SubscriberServer_Seek_Call) Run 

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

type SubscriberServer_StreamingPull_Call 

type SubscriberServer_StreamingPull_Call struct {
	*mock.Call
}

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

func (*SubscriberServer_StreamingPull_Call) Return 

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

func (*SubscriberServer_StreamingPull_Call) Run 

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

type SubscriberServer_UpdateSnapshot_Call 

type SubscriberServer_UpdateSnapshot_Call struct {
	*mock.Call
}

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

func (*SubscriberServer_UpdateSnapshot_Call) Return 

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

func (*SubscriberServer_UpdateSnapshot_Call) Run 

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

type SubscriberServer_UpdateSubscription_Call 

type SubscriberServer_UpdateSubscription_Call struct {
	*mock.Call
}

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

func (*SubscriberServer_UpdateSubscription_Call) Return 

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

func (*SubscriberServer_UpdateSubscription_Call) Run 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.