Documentation ¶
Overview ¶
Package mockcbt mocks Google Cloud BigTable for Golang testing.
Index ¶
- type MockBtAdminServer
- func (s *MockBtAdminServer) CreateAppProfile(ctx context.Context, req *pb.CreateAppProfileRequest) (*pb.AppProfile, error)
- func (s *MockBtAdminServer) CreateCluster(ctx context.Context, req *pb.CreateClusterRequest) (*longrunning.Operation, error)
- func (s *MockBtAdminServer) CreateInstance(ctx context.Context, req *pb.CreateInstanceRequest) (*longrunning.Operation, error)
- func (s *MockBtAdminServer) DeleteAppProfile(ctx context.Context, req *pb.DeleteAppProfileRequest) (*empty.Empty, error)
- func (s *MockBtAdminServer) DeleteCluster(ctx context.Context, req *pb.DeleteClusterRequest) (*empty.Empty, error)
- func (s *MockBtAdminServer) DeleteInstance(ctx context.Context, req *pb.DeleteInstanceRequest) (*empty.Empty, error)
- func (s *MockBtAdminServer) GetAppProfile(ctx context.Context, req *pb.GetAppProfileRequest) (*pb.AppProfile, error)
- func (s *MockBtAdminServer) GetCluster(ctx context.Context, req *pb.GetClusterRequest) (*pb.Cluster, error)
- func (s *MockBtAdminServer) GetIamPolicy(ctx context.Context, req *v1.GetIamPolicyRequest) (*v1.Policy, error)
- func (s *MockBtAdminServer) GetInstance(ctx context.Context, req *pb.GetInstanceRequest) (*pb.Instance, error)
- func (s *MockBtAdminServer) ListAppProfiles(ctx context.Context, req *pb.ListAppProfilesRequest) (*pb.ListAppProfilesResponse, error)
- func (s *MockBtAdminServer) ListClusters(ctx context.Context, req *pb.ListClustersRequest) (*pb.ListClustersResponse, error)
- func (s *MockBtAdminServer) ListHotTablets(ctx context.Context, req *pb.ListHotTabletsRequest) (*pb.ListHotTabletsResponse, error)
- func (s *MockBtAdminServer) ListInstances(ctx context.Context, req *pb.ListInstancesRequest) (*pb.ListInstancesResponse, error)
- func (s *MockBtAdminServer) PartialUpdateCluster(ctx context.Context, req *pb.PartialUpdateClusterRequest) (*longrunning.Operation, error)
- func (s *MockBtAdminServer) PartialUpdateInstance(ctx context.Context, req *pb.PartialUpdateInstanceRequest) (*longrunning.Operation, error)
- func (s *MockBtAdminServer) SetIamPolicy(ctx context.Context, req *v1.SetIamPolicyRequest) (*v1.Policy, error)
- func (s *MockBtAdminServer) TestIamPermissions(ctx context.Context, req *v1.TestIamPermissionsRequest) (*v1.TestIamPermissionsResponse, error)
- func (s *MockBtAdminServer) UpdateAppProfile(ctx context.Context, req *pb.UpdateAppProfileRequest) (*longrunning.Operation, error)
- func (s *MockBtAdminServer) UpdateCluster(ctx context.Context, req *pb.Cluster) (*longrunning.Operation, error)
- func (s *MockBtAdminServer) UpdateInstance(ctx context.Context, req *pb.Instance) (*pb.Instance, error)
- type MockBtServer
- func (s *MockBtServer) CheckAndMutateRow(ctx context.Context, req *pb.CheckAndMutateRowRequest) (*pb.CheckAndMutateRowResponse, error)
- func (s *MockBtServer) MutateRow(ctx context.Context, req *pb.MutateRowRequest) (*pb.MutateRowResponse, error)
- func (s *MockBtServer) MutateRows(req *pb.MutateRowsRequest, svr pb.Bigtable_MutateRowsServer) error
- func (s *MockBtServer) ReadModifyWriteRow(ctx context.Context, req *pb.ReadModifyWriteRowRequest) (*pb.ReadModifyWriteRowResponse, error)
- func (s *MockBtServer) ReadRows(req *pb.ReadRowsRequest, svr pb.Bigtable_ReadRowsServer) error
- func (s *MockBtServer) SampleRowKeys(req *pb.SampleRowKeysRequest, svr pb.Bigtable_SampleRowKeysServer) error
- type MockServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockBtAdminServer ¶
type MockBtAdminServer struct {
*MockServer
}
func NewAdmin ¶
func NewAdmin() (*bigtable.AdminClient, *MockBtAdminServer, error)
NewAdmin creates a new BigTable AdminClient and MockServer
func (*MockBtAdminServer) CreateAppProfile ¶
func (s *MockBtAdminServer) CreateAppProfile(ctx context.Context, req *pb.CreateAppProfileRequest) (*pb.AppProfile, error)
Creates an app profile within an instance.
func (*MockBtAdminServer) CreateCluster ¶
func (s *MockBtAdminServer) CreateCluster(ctx context.Context, req *pb.CreateClusterRequest) (*longrunning.Operation, error)
Creates a cluster within an instance.
func (*MockBtAdminServer) CreateInstance ¶
func (s *MockBtAdminServer) CreateInstance(ctx context.Context, req *pb.CreateInstanceRequest) (*longrunning.Operation, error)
Create an instance within a project.
func (*MockBtAdminServer) DeleteAppProfile ¶
func (s *MockBtAdminServer) DeleteAppProfile(ctx context.Context, req *pb.DeleteAppProfileRequest) (*empty.Empty, error)
Deletes an app profile from an instance.
func (*MockBtAdminServer) DeleteCluster ¶
func (s *MockBtAdminServer) DeleteCluster(ctx context.Context, req *pb.DeleteClusterRequest) (*empty.Empty, error)
Deletes a cluster from an instance.
func (*MockBtAdminServer) DeleteInstance ¶
func (s *MockBtAdminServer) DeleteInstance(ctx context.Context, req *pb.DeleteInstanceRequest) (*empty.Empty, error)
Delete an instance from a project.
func (*MockBtAdminServer) GetAppProfile ¶
func (s *MockBtAdminServer) GetAppProfile(ctx context.Context, req *pb.GetAppProfileRequest) (*pb.AppProfile, error)
Gets information about an app profile.
func (*MockBtAdminServer) GetCluster ¶
func (s *MockBtAdminServer) GetCluster(ctx context.Context, req *pb.GetClusterRequest) (*pb.Cluster, error)
Gets information about a cluster.
func (*MockBtAdminServer) GetIamPolicy ¶
func (s *MockBtAdminServer) GetIamPolicy(ctx context.Context, req *v1.GetIamPolicyRequest) (*v1.Policy, error)
Gets the access control policy for an instance resource. Returns an empty policy if an instance exists but does not have a policy set.
func (*MockBtAdminServer) GetInstance ¶
func (s *MockBtAdminServer) GetInstance(ctx context.Context, req *pb.GetInstanceRequest) (*pb.Instance, error)
Gets information about an instance.
func (*MockBtAdminServer) ListAppProfiles ¶
func (s *MockBtAdminServer) ListAppProfiles(ctx context.Context, req *pb.ListAppProfilesRequest) (*pb.ListAppProfilesResponse, error)
Lists information about app profiles in an instance.
func (*MockBtAdminServer) ListClusters ¶
func (s *MockBtAdminServer) ListClusters(ctx context.Context, req *pb.ListClustersRequest) (*pb.ListClustersResponse, error)
Lists information about clusters in an instance.
func (*MockBtAdminServer) ListHotTablets ¶ added in v1.0.3
func (s *MockBtAdminServer) ListHotTablets(ctx context.Context, req *pb.ListHotTabletsRequest) (*pb.ListHotTabletsResponse, error)
Lists hot tablets in a cluster, within the time range provided. Hot tablets are ordered based on CPU usage.
func (*MockBtAdminServer) ListInstances ¶
func (s *MockBtAdminServer) ListInstances(ctx context.Context, req *pb.ListInstancesRequest) (*pb.ListInstancesResponse, error)
Lists information about instances in a project.
func (*MockBtAdminServer) PartialUpdateCluster ¶ added in v1.0.3
func (s *MockBtAdminServer) PartialUpdateCluster(ctx context.Context, req *pb.PartialUpdateClusterRequest) (*longrunning.Operation, error)
To disable autoscaling, clear cluster_config.cluster_autoscaling_config, and explicitly set a serve_node count via the update_mask.
func (*MockBtAdminServer) PartialUpdateInstance ¶
func (s *MockBtAdminServer) PartialUpdateInstance(ctx context.Context, req *pb.PartialUpdateInstanceRequest) (*longrunning.Operation, error)
Partially updates an instance within a project.
func (*MockBtAdminServer) SetIamPolicy ¶
func (s *MockBtAdminServer) SetIamPolicy(ctx context.Context, req *v1.SetIamPolicyRequest) (*v1.Policy, error)
Sets the access control policy on an instance resource. Replaces any existing policy.
func (*MockBtAdminServer) TestIamPermissions ¶
func (s *MockBtAdminServer) TestIamPermissions(ctx context.Context, req *v1.TestIamPermissionsRequest) (*v1.TestIamPermissionsResponse, error)
Returns permissions that the caller has on the specified instance resource.
func (*MockBtAdminServer) UpdateAppProfile ¶
func (s *MockBtAdminServer) UpdateAppProfile(ctx context.Context, req *pb.UpdateAppProfileRequest) (*longrunning.Operation, error)
Updates an app profile within an instance.
func (*MockBtAdminServer) UpdateCluster ¶
func (s *MockBtAdminServer) UpdateCluster(ctx context.Context, req *pb.Cluster) (*longrunning.Operation, error)
Updates a cluster within an instance.
func (*MockBtAdminServer) UpdateInstance ¶
func (s *MockBtAdminServer) UpdateInstance(ctx context.Context, req *pb.Instance) (*pb.Instance, error)
Updates an instance within a project.
type MockBtServer ¶
type MockBtServer struct {
*MockServer
}
func New ¶
func New() (*bigtable.Client, *MockBtServer, error)
New creates a new BigTable Client and MockServer
func (*MockBtServer) CheckAndMutateRow ¶
func (s *MockBtServer) CheckAndMutateRow(ctx context.Context, req *pb.CheckAndMutateRowRequest) (*pb.CheckAndMutateRowResponse, error)
CheckAndMutateRow mutates a row atomically based on the output of a predicate Reader filter.
func (*MockBtServer) MutateRow ¶
func (s *MockBtServer) MutateRow(ctx context.Context, req *pb.MutateRowRequest) (*pb.MutateRowResponse, error)
MutateRow mutates a row atomically. Cells already present in the row are left unchanged unless explicitly changed by `mutation`.
func (*MockBtServer) MutateRows ¶
func (s *MockBtServer) MutateRows(req *pb.MutateRowsRequest, svr pb.Bigtable_MutateRowsServer) error
MutateRows mutates multiple rows in a batch. Each individual row is mutated atomically as in MutateRow, but the entire batch is not executed atomically.
func (*MockBtServer) ReadModifyWriteRow ¶
func (s *MockBtServer) ReadModifyWriteRow(ctx context.Context, req *pb.ReadModifyWriteRowRequest) (*pb.ReadModifyWriteRowResponse, error)
ReadModifyWriteRow modifies a row atomically on the server. The method reads the latest existing timestamp and value from the specified columns and writes a new entry based on predefined read/modify/write rules. The new value for the timestamp is the greater of the existing timestamp or the current server time. The method returns the new contents of all modified cells.
func (*MockBtServer) ReadRows ¶
func (s *MockBtServer) ReadRows(req *pb.ReadRowsRequest, svr pb.Bigtable_ReadRowsServer) error
ReadRows streams back the contents of all requested rows in key order, optionally applying the same Reader filter to each. Depending on their size, rows and cells may be broken up across multiple responses, but atomicity of each row will still be preserved. See the ReadRowsResponse documentation for details.
func (*MockBtServer) SampleRowKeys ¶
func (s *MockBtServer) SampleRowKeys(req *pb.SampleRowKeysRequest, svr pb.Bigtable_SampleRowKeysServer) error
type MockServer ¶
type MockServer struct { pb.BigtableServer Addr string // contains filtered or unexported fields }
MockServer mocks the pb.BigtableServer interface
func (*MockServer) AddRPC ¶
func (s *MockServer) AddRPC(wantReq proto.Message, resp interface{})
AddRPC adds a (request, response) pair to the server's list of expected interactions. The server will compare the incoming request with wantReq using proto.Equal. The response can be a message or an error.
For the Listen RPC, resp should be a []interface{}, where each element is either ListenResponse or an error.
Passing nil for wantReq disables the request check.
func (*MockServer) AddRPCAdjust ¶
func (s *MockServer) AddRPCAdjust(wantReq proto.Message, resp interface{}, adjust func(gotReq proto.Message))
AddRPCAdjust is like AddRPC, but accepts a function that can be used to tweak the requests before comparison, for example to adjust for randomness.
func (*MockServer) Reset ¶
func (s *MockServer) Reset()
Reset returns the MockServer to an empty state.