package mockserver

import "cloud.google.com/go/bigtable/internal/mockserver"

Index ¶

• type Server
• func NewServer(laddr string, opt ...grpc.ServerOption) (*Server, error)
• func (s *Server) CheckAndMutateRow(ctx context.Context, srv *btpb.CheckAndMutateRowRequest) (*btpb.CheckAndMutateRowResponse, error)
• func (s *Server) Close() error
• func (s *Server) MutateRow(ctx context.Context, req *btpb.MutateRowRequest) (*btpb.MutateRowResponse, error)
• func (s *Server) MutateRows(req *btpb.MutateRowsRequest, srv btpb.Bigtable_MutateRowsServer) error
• func (s *Server) PingAndWarm(ctx context.Context, srv *btpb.PingAndWarmRequest) (*btpb.PingAndWarmResponse, error)
• func (s *Server) ReadModifyWriteRow(ctx context.Context, srv *btpb.ReadModifyWriteRowRequest) (*btpb.ReadModifyWriteRowResponse, error)
• func (s *Server) ReadRows(req *btpb.ReadRowsRequest, srv btpb.Bigtable_ReadRowsServer) error
• func (s *Server) SampleRowKeys(req *btpb.SampleRowKeysRequest, srv btpb.Bigtable_SampleRowKeysServer) error

Types ¶

type Server ¶

type Server struct {
	Addr string

	// Any unimplemented methods will cause a panic when called.
	btpb.BigtableServer

	// ReadRowsFn mocks ReadRows.
	ReadRowsFn func(*btpb.ReadRowsRequest, btpb.Bigtable_ReadRowsServer) error
	// SampleRowKeysFn mocks SampleRowKeys.
	SampleRowKeysFn func(*btpb.SampleRowKeysRequest, btpb.Bigtable_SampleRowKeysServer) error
	// MutateRowFn mocks MutateRow.
	MutateRowFn func(context.Context, *btpb.MutateRowRequest) (*btpb.MutateRowResponse, error)
	// MutateRowsFn mocks MutateRows.
	MutateRowsFn func(*btpb.MutateRowsRequest, btpb.Bigtable_MutateRowsServer) error
	// CheckAndMutateRowFn mocks CheckAndMutateRow.
	CheckAndMutateRowFn func(context.Context, *btpb.CheckAndMutateRowRequest) (*btpb.CheckAndMutateRowResponse, error)
	// PingAndWarmFn mocks PingAndWarm.
	PingAndWarmFn func(context.Context, *btpb.PingAndWarmRequest) (*btpb.PingAndWarmResponse, error)
	// ReadModifyWriteRowFn mocks ReadModifyWriteRow.
	ReadModifyWriteRowFn func(context.Context, *btpb.ReadModifyWriteRowRequest) (*btpb.ReadModifyWriteRowResponse, error)
	// contains filtered or unexported fields
}

Server is an in-memory Cloud Bigtable fake. It is unauthenticated, and only a rough approximation.

func NewServer ¶

func NewServer(laddr string, opt ...grpc.ServerOption) (*Server, error)

NewServer creates a new Server. The Server will be listening for gRPC connections, without TLS, on the provided address. The resolved address is named by the Addr field.

func (*Server) CheckAndMutateRow ¶

func (s *Server) CheckAndMutateRow(ctx context.Context, srv *btpb.CheckAndMutateRowRequest) (*btpb.CheckAndMutateRowResponse, error)

CheckAndMutateRow implements CheckAndMutateRow of the BigtableServer interface.

func (*Server) Close ¶

func (s *Server) Close() error

Close closes the server.

func (*Server) MutateRow ¶

func (s *Server) MutateRow(ctx context.Context, req *btpb.MutateRowRequest) (*btpb.MutateRowResponse, error)

MutateRow implements MutateRow of the BigtableServer interface.

func (*Server) MutateRows ¶

func (s *Server) MutateRows(req *btpb.MutateRowsRequest, srv btpb.Bigtable_MutateRowsServer) error

MutateRows implements MutateRows of the BigtableServer interface.

func (*Server) PingAndWarm ¶

func (s *Server) PingAndWarm(ctx context.Context, srv *btpb.PingAndWarmRequest) (*btpb.PingAndWarmResponse, error)

PingAndWarm implements PingAndWarm of the BigtableServer interface.

func (*Server) ReadModifyWriteRow ¶

func (s *Server) ReadModifyWriteRow(ctx context.Context, srv *btpb.ReadModifyWriteRowRequest) (*btpb.ReadModifyWriteRowResponse, error)

ReadModifyWriteRow implements ReadModifyWriteRow of the BigtableServer interface.

func (*Server) ReadRows ¶

func (s *Server) ReadRows(req *btpb.ReadRowsRequest, srv btpb.Bigtable_ReadRowsServer) error

ReadRows implements ReadRows of the BigtableServer interface.

func (*Server) SampleRowKeys ¶

func (s *Server) SampleRowKeys(req *btpb.SampleRowKeysRequest, srv btpb.Bigtable_SampleRowKeysServer) error

SampleRowKeys implements SampleRowKeys of the BigtableServer interface.

Source Files ¶

inmem.go