testproxypb

package
v0.0.2 Latest Latest
Warning

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

 Go to latest Published: Oct 23, 2023 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var CloudBigtableV2TestProxy_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "google.bigtable.testproxy.CloudBigtableV2TestProxy",
	HandlerType: (*CloudBigtableV2TestProxyServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateClient",
			Handler:    _CloudBigtableV2TestProxy_CreateClient_Handler,
		},
		{
			MethodName: "CloseClient",
			Handler:    _CloudBigtableV2TestProxy_CloseClient_Handler,
		},
		{
			MethodName: "RemoveClient",
			Handler:    _CloudBigtableV2TestProxy_RemoveClient_Handler,
		},
		{
			MethodName: "ReadRow",
			Handler:    _CloudBigtableV2TestProxy_ReadRow_Handler,
		},
		{
			MethodName: "ReadRows",
			Handler:    _CloudBigtableV2TestProxy_ReadRows_Handler,
		},
		{
			MethodName: "MutateRow",
			Handler:    _CloudBigtableV2TestProxy_MutateRow_Handler,
		},
		{
			MethodName: "BulkMutateRows",
			Handler:    _CloudBigtableV2TestProxy_BulkMutateRows_Handler,
		},
		{
			MethodName: "CheckAndMutateRow",
			Handler:    _CloudBigtableV2TestProxy_CheckAndMutateRow_Handler,
		},
		{
			MethodName: "SampleRowKeys",
			Handler:    _CloudBigtableV2TestProxy_SampleRowKeys_Handler,
		},
		{
			MethodName: "ReadModifyWriteRow",
			Handler:    _CloudBigtableV2TestProxy_ReadModifyWriteRow_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "test_proxy.proto",
}

CloudBigtableV2TestProxy_ServiceDesc is the grpc.ServiceDesc for CloudBigtableV2TestProxy service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_test_proxy_proto protoreflect.FileDescriptor

Functions

func RegisterCloudBigtableV2TestProxyServer 

func RegisterCloudBigtableV2TestProxyServer(s grpc.ServiceRegistrar, srv CloudBigtableV2TestProxyServer)

Types

type CheckAndMutateRowRequest 

type CheckAndMutateRowRequest struct {

	// The ID of the target client object.
	ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// The raw request to the Bigtable server.
	Request *v2.CheckAndMutateRowRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

Request to test proxy service to check and mutate a row.

func (*CheckAndMutateRowRequest) Descriptor deprecated 

func (*CheckAndMutateRowRequest) Descriptor() ([]byte, []int)

Deprecated: Use CheckAndMutateRowRequest.ProtoReflect.Descriptor instead.

func (*CheckAndMutateRowRequest) GetClientId 

func (x *CheckAndMutateRowRequest) GetClientId() string

func (*CheckAndMutateRowRequest) GetRequest 

func (x *CheckAndMutateRowRequest) GetRequest() *v2.CheckAndMutateRowRequest

func (*CheckAndMutateRowRequest) ProtoMessage 

func (*CheckAndMutateRowRequest) ProtoMessage()

func (*CheckAndMutateRowRequest) ProtoReflect 

func (x *CheckAndMutateRowRequest) ProtoReflect() protoreflect.Message

func (*CheckAndMutateRowRequest) Reset 

func (x *CheckAndMutateRowRequest) Reset()

func (*CheckAndMutateRowRequest) String 

func (x *CheckAndMutateRowRequest) String() string

type CheckAndMutateRowResult 

type CheckAndMutateRowResult struct {

	// The RPC status from the client binding.
	Status *status.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// The raw response from the Bigtable server.
	Result *v2.CheckAndMutateRowResponse `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

Response from test proxy service for CheckAndMutateRowRequest.

func (*CheckAndMutateRowResult) Descriptor deprecated 

func (*CheckAndMutateRowResult) Descriptor() ([]byte, []int)

Deprecated: Use CheckAndMutateRowResult.ProtoReflect.Descriptor instead.

func (*CheckAndMutateRowResult) GetResult 

func (x *CheckAndMutateRowResult) GetResult() *v2.CheckAndMutateRowResponse

func (*CheckAndMutateRowResult) GetStatus 

func (x *CheckAndMutateRowResult) GetStatus() *status.Status

func (*CheckAndMutateRowResult) ProtoMessage 

func (*CheckAndMutateRowResult) ProtoMessage()

func (*CheckAndMutateRowResult) ProtoReflect 

func (x *CheckAndMutateRowResult) ProtoReflect() protoreflect.Message

func (*CheckAndMutateRowResult) Reset 

func (x *CheckAndMutateRowResult) Reset()

func (*CheckAndMutateRowResult) String 

func (x *CheckAndMutateRowResult) String() string

type CloseClientRequest 

type CloseClientRequest struct {

	// The ID of the target client object.
	ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// contains filtered or unexported fields
}

Request to test proxy service to close a client object.

func (*CloseClientRequest) Descriptor deprecated 

func (*CloseClientRequest) Descriptor() ([]byte, []int)

Deprecated: Use CloseClientRequest.ProtoReflect.Descriptor instead.

func (*CloseClientRequest) GetClientId 

func (x *CloseClientRequest) GetClientId() string

func (*CloseClientRequest) ProtoMessage 

func (*CloseClientRequest) ProtoMessage()

func (*CloseClientRequest) ProtoReflect 

func (x *CloseClientRequest) ProtoReflect() protoreflect.Message

func (*CloseClientRequest) Reset 

func (x *CloseClientRequest) Reset()

func (*CloseClientRequest) String 

func (x *CloseClientRequest) String() string

type CloseClientResponse 

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

Response from test proxy service for CloseClientRequest.

func (*CloseClientResponse) Descriptor deprecated 

func (*CloseClientResponse) Descriptor() ([]byte, []int)

Deprecated: Use CloseClientResponse.ProtoReflect.Descriptor instead.

func (*CloseClientResponse) ProtoMessage 

func (*CloseClientResponse) ProtoMessage()

func (*CloseClientResponse) ProtoReflect 

func (x *CloseClientResponse) ProtoReflect() protoreflect.Message

func (*CloseClientResponse) Reset 

func (x *CloseClientResponse) Reset()

func (*CloseClientResponse) String 

func (x *CloseClientResponse) String() string

type CloudBigtableV2TestProxyClient 

type CloudBigtableV2TestProxyClient interface {
	// Client management:
	//
	// Creates a client in the proxy.
	// Each client has its own dedicated channel(s), and can be used concurrently
	// and independently with other clients.
	CreateClient(ctx context.Context, in *CreateClientRequest, opts ...grpc.CallOption) (*CreateClientResponse, error)
	// Closes a client in the proxy, making it not accept new requests.
	CloseClient(ctx context.Context, in *CloseClientRequest, opts ...grpc.CallOption) (*CloseClientResponse, error)
	// Removes a client in the proxy, making it inaccessible. Client closing
	// should be done by CloseClient() separately.
	RemoveClient(ctx context.Context, in *RemoveClientRequest, opts ...grpc.CallOption) (*RemoveClientResponse, error)
	// Bigtable operations: for each operation, you should use the synchronous or
	// asynchronous variant of the client method based on the `use_async_method`
	// setting of the client instance. For starters, you can choose to implement
	// one variant, and return UNIMPLEMENTED status for the other.
	//
	// Reads a row with the client instance.
	// The result row may not be present in the response.
	// Callers should check for it (e.g. calling has_row() in C++).
	ReadRow(ctx context.Context, in *ReadRowRequest, opts ...grpc.CallOption) (*RowResult, error)
	// Reads rows with the client instance.
	ReadRows(ctx context.Context, in *ReadRowsRequest, opts ...grpc.CallOption) (*RowsResult, error)
	// Writes a row with the client instance.
	MutateRow(ctx context.Context, in *MutateRowRequest, opts ...grpc.CallOption) (*MutateRowResult, error)
	// Writes multiple rows with the client instance.
	BulkMutateRows(ctx context.Context, in *MutateRowsRequest, opts ...grpc.CallOption) (*MutateRowsResult, error)
	// Performs a check-and-mutate-row operation with the client instance.
	CheckAndMutateRow(ctx context.Context, in *CheckAndMutateRowRequest, opts ...grpc.CallOption) (*CheckAndMutateRowResult, error)
	// Obtains a row key sampling with the client instance.
	SampleRowKeys(ctx context.Context, in *SampleRowKeysRequest, opts ...grpc.CallOption) (*SampleRowKeysResult, error)
	// Performs a read-modify-write operation with the client.
	ReadModifyWriteRow(ctx context.Context, in *ReadModifyWriteRowRequest, opts ...grpc.CallOption) (*RowResult, error)
}

CloudBigtableV2TestProxyClient is the client API for CloudBigtableV2TestProxy service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewCloudBigtableV2TestProxyClient 

func NewCloudBigtableV2TestProxyClient(cc grpc.ClientConnInterface) CloudBigtableV2TestProxyClient

type CloudBigtableV2TestProxyServer 

type CloudBigtableV2TestProxyServer interface {
	// Client management:
	//
	// Creates a client in the proxy.
	// Each client has its own dedicated channel(s), and can be used concurrently
	// and independently with other clients.
	CreateClient(context.Context, *CreateClientRequest) (*CreateClientResponse, error)
	// Closes a client in the proxy, making it not accept new requests.
	CloseClient(context.Context, *CloseClientRequest) (*CloseClientResponse, error)
	// Removes a client in the proxy, making it inaccessible. Client closing
	// should be done by CloseClient() separately.
	RemoveClient(context.Context, *RemoveClientRequest) (*RemoveClientResponse, error)
	// Bigtable operations: for each operation, you should use the synchronous or
	// asynchronous variant of the client method based on the `use_async_method`
	// setting of the client instance. For starters, you can choose to implement
	// one variant, and return UNIMPLEMENTED status for the other.
	//
	// Reads a row with the client instance.
	// The result row may not be present in the response.
	// Callers should check for it (e.g. calling has_row() in C++).
	ReadRow(context.Context, *ReadRowRequest) (*RowResult, error)
	// Reads rows with the client instance.
	ReadRows(context.Context, *ReadRowsRequest) (*RowsResult, error)
	// Writes a row with the client instance.
	MutateRow(context.Context, *MutateRowRequest) (*MutateRowResult, error)
	// Writes multiple rows with the client instance.
	BulkMutateRows(context.Context, *MutateRowsRequest) (*MutateRowsResult, error)
	// Performs a check-and-mutate-row operation with the client instance.
	CheckAndMutateRow(context.Context, *CheckAndMutateRowRequest) (*CheckAndMutateRowResult, error)
	// Obtains a row key sampling with the client instance.
	SampleRowKeys(context.Context, *SampleRowKeysRequest) (*SampleRowKeysResult, error)
	// Performs a read-modify-write operation with the client.
	ReadModifyWriteRow(context.Context, *ReadModifyWriteRowRequest) (*RowResult, error)
	// contains filtered or unexported methods
}

CloudBigtableV2TestProxyServer is the server API for CloudBigtableV2TestProxy service. All implementations must embed UnimplementedCloudBigtableV2TestProxyServer for forward compatibility

type CreateClientRequest 

type CreateClientRequest struct {

	// A unique ID associated with the client object to be created.
	ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// The "host:port" address of the data API endpoint (i.e. the backend being
	// proxied to). Example: 127.0.0.1:38543. If you want to connect to a local
	// emulator via BIGTABLE_EMULATOR_HOST environment variable, you can use
	// "emulator" instead of "host:port" for this field.
	DataTarget string `protobuf:"bytes,2,opt,name=data_target,json=dataTarget,proto3" json:"data_target,omitempty"`
	// The project for all calls on this client.
	ProjectId string `protobuf:"bytes,3,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// The instance for all calls on this client.
	InstanceId string `protobuf:"bytes,4,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// Optional app profile for all calls on this client.
	// Some client bindings allow specifying the app profile on a per-operation
	// basis. We don't yet support this in the proxy API, but may in the future.
	AppProfileId string `protobuf:"bytes,5,opt,name=app_profile_id,json=appProfileId,proto3" json:"app_profile_id,omitempty"`
	// If provided, a custom timeout will be set for each API call conducted by
	// the created client. Otherwise, the default timeout from the client library
	// will be used. Note that the override applies to all the methods.
	PerOperationTimeout *durationpb.Duration `protobuf:"bytes,6,opt,name=per_operation_timeout,json=perOperationTimeout,proto3" json:"per_operation_timeout,omitempty"`
	// contains filtered or unexported fields
}

Request to test proxy service to create a client object.

func (*CreateClientRequest) Descriptor deprecated 

func (*CreateClientRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateClientRequest.ProtoReflect.Descriptor instead.

func (*CreateClientRequest) GetAppProfileId 

func (x *CreateClientRequest) GetAppProfileId() string

func (*CreateClientRequest) GetClientId 

func (x *CreateClientRequest) GetClientId() string

func (*CreateClientRequest) GetDataTarget 

func (x *CreateClientRequest) GetDataTarget() string

func (*CreateClientRequest) GetInstanceId 

func (x *CreateClientRequest) GetInstanceId() string

func (*CreateClientRequest) GetPerOperationTimeout 

func (x *CreateClientRequest) GetPerOperationTimeout() *durationpb.Duration

func (*CreateClientRequest) GetProjectId 

func (x *CreateClientRequest) GetProjectId() string

func (*CreateClientRequest) ProtoMessage 

func (*CreateClientRequest) ProtoMessage()

func (*CreateClientRequest) ProtoReflect 

func (x *CreateClientRequest) ProtoReflect() protoreflect.Message

func (*CreateClientRequest) Reset 

func (x *CreateClientRequest) Reset()

func (*CreateClientRequest) String 

func (x *CreateClientRequest) String() string

type CreateClientResponse 

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

Response from test proxy service for CreateClientRequest.

func (*CreateClientResponse) Descriptor deprecated 

func (*CreateClientResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateClientResponse.ProtoReflect.Descriptor instead.

func (*CreateClientResponse) ProtoMessage 

func (*CreateClientResponse) ProtoMessage()

func (*CreateClientResponse) ProtoReflect 

func (x *CreateClientResponse) ProtoReflect() protoreflect.Message

func (*CreateClientResponse) Reset 

func (x *CreateClientResponse) Reset()

func (*CreateClientResponse) String 

func (x *CreateClientResponse) String() string

type MutateRowRequest 

type MutateRowRequest struct {

	// The ID of the target client object.
	ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// The raw request to the Bigtable server.
	Request *v2.MutateRowRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

Request to test proxy service to mutate a row.

func (*MutateRowRequest) Descriptor deprecated 

func (*MutateRowRequest) Descriptor() ([]byte, []int)

Deprecated: Use MutateRowRequest.ProtoReflect.Descriptor instead.

func (*MutateRowRequest) GetClientId 

func (x *MutateRowRequest) GetClientId() string

func (*MutateRowRequest) GetRequest 

func (x *MutateRowRequest) GetRequest() *v2.MutateRowRequest

func (*MutateRowRequest) ProtoMessage 

func (*MutateRowRequest) ProtoMessage()

func (*MutateRowRequest) ProtoReflect 

func (x *MutateRowRequest) ProtoReflect() protoreflect.Message

func (*MutateRowRequest) Reset 

func (x *MutateRowRequest) Reset()

func (*MutateRowRequest) String 

func (x *MutateRowRequest) String() string

type MutateRowResult 

type MutateRowResult struct {

	// The RPC status from the client binding.
	Status *status.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

Response from test proxy service for MutateRowRequest.

func (*MutateRowResult) Descriptor deprecated 

func (*MutateRowResult) Descriptor() ([]byte, []int)

Deprecated: Use MutateRowResult.ProtoReflect.Descriptor instead.

func (*MutateRowResult) GetStatus 

func (x *MutateRowResult) GetStatus() *status.Status

func (*MutateRowResult) ProtoMessage 

func (*MutateRowResult) ProtoMessage()

func (*MutateRowResult) ProtoReflect 

func (x *MutateRowResult) ProtoReflect() protoreflect.Message

func (*MutateRowResult) Reset 

func (x *MutateRowResult) Reset()

func (*MutateRowResult) String 

func (x *MutateRowResult) String() string

type MutateRowsRequest 

type MutateRowsRequest struct {

	// The ID of the target client object.
	ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// The raw request to the Bigtable server.
	Request *v2.MutateRowsRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

Request to test proxy service to mutate rows.

func (*MutateRowsRequest) Descriptor deprecated 

func (*MutateRowsRequest) Descriptor() ([]byte, []int)

Deprecated: Use MutateRowsRequest.ProtoReflect.Descriptor instead.

func (*MutateRowsRequest) GetClientId 

func (x *MutateRowsRequest) GetClientId() string

func (*MutateRowsRequest) GetRequest 

func (x *MutateRowsRequest) GetRequest() *v2.MutateRowsRequest

func (*MutateRowsRequest) ProtoMessage 

func (*MutateRowsRequest) ProtoMessage()

func (*MutateRowsRequest) ProtoReflect 

func (x *MutateRowsRequest) ProtoReflect() protoreflect.Message

func (*MutateRowsRequest) Reset 

func (x *MutateRowsRequest) Reset()

func (*MutateRowsRequest) String 

func (x *MutateRowsRequest) String() string

type MutateRowsResult 

type MutateRowsResult struct {

	// The RPC status from the client binding, corresponding to the
	// whole operation.
	Status *status.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// The results corresponding to the failed rows.
	Entries []*v2.MutateRowsResponse_Entry `protobuf:"bytes,2,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

Response from test proxy service for MutateRowsRequest.

func (*MutateRowsResult) Descriptor deprecated 

func (*MutateRowsResult) Descriptor() ([]byte, []int)

Deprecated: Use MutateRowsResult.ProtoReflect.Descriptor instead.

func (*MutateRowsResult) GetEntries 

func (x *MutateRowsResult) GetEntries() []*v2.MutateRowsResponse_Entry

func (*MutateRowsResult) GetStatus 

func (x *MutateRowsResult) GetStatus() *status.Status

func (*MutateRowsResult) ProtoMessage 

func (*MutateRowsResult) ProtoMessage()

func (*MutateRowsResult) ProtoReflect 

func (x *MutateRowsResult) ProtoReflect() protoreflect.Message

func (*MutateRowsResult) Reset 

func (x *MutateRowsResult) Reset()

func (*MutateRowsResult) String 

func (x *MutateRowsResult) String() string

type ReadModifyWriteRowRequest 

type ReadModifyWriteRowRequest struct {

	// The ID of the target client object.
	ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// The raw request to the Bigtable server.
	Request *v2.ReadModifyWriteRowRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

Request to test proxy service to read modify write a row.

func (*ReadModifyWriteRowRequest) Descriptor deprecated 

func (*ReadModifyWriteRowRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReadModifyWriteRowRequest.ProtoReflect.Descriptor instead.

func (*ReadModifyWriteRowRequest) GetClientId 

func (x *ReadModifyWriteRowRequest) GetClientId() string

func (*ReadModifyWriteRowRequest) GetRequest 

func (x *ReadModifyWriteRowRequest) GetRequest() *v2.ReadModifyWriteRowRequest

func (*ReadModifyWriteRowRequest) ProtoMessage 

func (*ReadModifyWriteRowRequest) ProtoMessage()

func (*ReadModifyWriteRowRequest) ProtoReflect 

func (x *ReadModifyWriteRowRequest) ProtoReflect() protoreflect.Message

func (*ReadModifyWriteRowRequest) Reset 

func (x *ReadModifyWriteRowRequest) Reset()

func (*ReadModifyWriteRowRequest) String 

func (x *ReadModifyWriteRowRequest) String() string

type ReadRowRequest 

type ReadRowRequest struct {

	// The ID of the target client object.
	ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// The unique name of the table from which to read the row.
	// Values are of the form
	// `projects/<project>/instances/<instance>/tables/<table>`.
	TableName string `protobuf:"bytes,4,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	// The row key of the target row.
	RowKey string `protobuf:"bytes,2,opt,name=row_key,json=rowKey,proto3" json:"row_key,omitempty"`
	// The row filter to be applied to the target row.
	Filter *v2.RowFilter `protobuf:"bytes,3,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

Request to test proxy service to read a row.

func (*ReadRowRequest) Descriptor deprecated 

func (*ReadRowRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReadRowRequest.ProtoReflect.Descriptor instead.

func (*ReadRowRequest) GetClientId 

func (x *ReadRowRequest) GetClientId() string

func (*ReadRowRequest) GetFilter 

func (x *ReadRowRequest) GetFilter() *v2.RowFilter

func (*ReadRowRequest) GetRowKey 

func (x *ReadRowRequest) GetRowKey() string

func (*ReadRowRequest) GetTableName 

func (x *ReadRowRequest) GetTableName() string

func (*ReadRowRequest) ProtoMessage 

func (*ReadRowRequest) ProtoMessage()

func (*ReadRowRequest) ProtoReflect 

func (x *ReadRowRequest) ProtoReflect() protoreflect.Message

func (*ReadRowRequest) Reset 

func (x *ReadRowRequest) Reset()

func (*ReadRowRequest) String 

func (x *ReadRowRequest) String() string

type ReadRowsRequest 

type ReadRowsRequest struct {

	// The ID of the target client object.
	ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// The raw request to the Bigtable server.
	Request *v2.ReadRowsRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	// The streaming read can be canceled before all items are seen.
	// Has no effect if non-positive.
	CancelAfterRows int32 `protobuf:"varint,3,opt,name=cancel_after_rows,json=cancelAfterRows,proto3" json:"cancel_after_rows,omitempty"`
	// contains filtered or unexported fields
}

Request to test proxy service to read rows.

func (*ReadRowsRequest) Descriptor deprecated 

func (*ReadRowsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReadRowsRequest.ProtoReflect.Descriptor instead.

func (*ReadRowsRequest) GetCancelAfterRows 

func (x *ReadRowsRequest) GetCancelAfterRows() int32

func (*ReadRowsRequest) GetClientId 

func (x *ReadRowsRequest) GetClientId() string

func (*ReadRowsRequest) GetRequest 

func (x *ReadRowsRequest) GetRequest() *v2.ReadRowsRequest

func (*ReadRowsRequest) ProtoMessage 

func (*ReadRowsRequest) ProtoMessage()

func (*ReadRowsRequest) ProtoReflect 

func (x *ReadRowsRequest) ProtoReflect() protoreflect.Message

func (*ReadRowsRequest) Reset 

func (x *ReadRowsRequest) Reset()

func (*ReadRowsRequest) String 

func (x *ReadRowsRequest) String() string

type RemoveClientRequest 

type RemoveClientRequest struct {

	// The ID of the target client object.
	ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// contains filtered or unexported fields
}

Request to test proxy service to remove a client object.

func (*RemoveClientRequest) Descriptor deprecated 

func (*RemoveClientRequest) Descriptor() ([]byte, []int)

Deprecated: Use RemoveClientRequest.ProtoReflect.Descriptor instead.

func (*RemoveClientRequest) GetClientId 

func (x *RemoveClientRequest) GetClientId() string

func (*RemoveClientRequest) ProtoMessage 

func (*RemoveClientRequest) ProtoMessage()

func (*RemoveClientRequest) ProtoReflect 

func (x *RemoveClientRequest) ProtoReflect() protoreflect.Message

func (*RemoveClientRequest) Reset 

func (x *RemoveClientRequest) Reset()

func (*RemoveClientRequest) String 

func (x *RemoveClientRequest) String() string

type RemoveClientResponse 

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

Response from test proxy service for RemoveClientRequest.

func (*RemoveClientResponse) Descriptor deprecated 

func (*RemoveClientResponse) Descriptor() ([]byte, []int)

Deprecated: Use RemoveClientResponse.ProtoReflect.Descriptor instead.

func (*RemoveClientResponse) ProtoMessage 

func (*RemoveClientResponse) ProtoMessage()

func (*RemoveClientResponse) ProtoReflect 

func (x *RemoveClientResponse) ProtoReflect() protoreflect.Message

func (*RemoveClientResponse) Reset 

func (x *RemoveClientResponse) Reset()

func (*RemoveClientResponse) String 

func (x *RemoveClientResponse) String() string

type RowResult 

type RowResult struct {

	// The RPC status from the client binding.
	Status *status.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// The contents of a single row.
	Row *v2.Row `protobuf:"bytes,2,opt,name=row,proto3" json:"row,omitempty"`
	// contains filtered or unexported fields
}

Response from test proxy service for ReadRowRequest or ReadModifyWriteRowRequest.

func (*RowResult) Descriptor deprecated 

func (*RowResult) Descriptor() ([]byte, []int)

Deprecated: Use RowResult.ProtoReflect.Descriptor instead.

func (*RowResult) GetRow 

func (x *RowResult) GetRow() *v2.Row

func (*RowResult) GetStatus 

func (x *RowResult) GetStatus() *status.Status

func (*RowResult) ProtoMessage 

func (*RowResult) ProtoMessage()

func (*RowResult) ProtoReflect 

func (x *RowResult) ProtoReflect() protoreflect.Message

func (*RowResult) Reset 

func (x *RowResult) Reset()

func (*RowResult) String 

func (x *RowResult) String() string

type RowsResult 

type RowsResult struct {

	// The RPC status from the client binding.
	Status *status.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// The contents of rows.
	Rows []*v2.Row `protobuf:"bytes,2,rep,name=rows,proto3" json:"rows,omitempty"`
	// contains filtered or unexported fields
}

Response from test proxy service for ReadRowsRequest.

func (*RowsResult) Descriptor deprecated 

func (*RowsResult) Descriptor() ([]byte, []int)

Deprecated: Use RowsResult.ProtoReflect.Descriptor instead.

func (*RowsResult) GetRows 

func (x *RowsResult) GetRows() []*v2.Row

func (*RowsResult) GetStatus 

func (x *RowsResult) GetStatus() *status.Status

func (*RowsResult) ProtoMessage 

func (*RowsResult) ProtoMessage()

func (*RowsResult) ProtoReflect 

func (x *RowsResult) ProtoReflect() protoreflect.Message

func (*RowsResult) Reset 

func (x *RowsResult) Reset()

func (*RowsResult) String 

func (x *RowsResult) String() string

type SampleRowKeysRequest 

type SampleRowKeysRequest struct {

	// The ID of the target client object.
	ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// The raw request to the Bigtable server.
	Request *v2.SampleRowKeysRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

Request to test proxy service to sample row keys.

func (*SampleRowKeysRequest) Descriptor deprecated 

func (*SampleRowKeysRequest) Descriptor() ([]byte, []int)

Deprecated: Use SampleRowKeysRequest.ProtoReflect.Descriptor instead.

func (*SampleRowKeysRequest) GetClientId 

func (x *SampleRowKeysRequest) GetClientId() string

func (*SampleRowKeysRequest) GetRequest 

func (x *SampleRowKeysRequest) GetRequest() *v2.SampleRowKeysRequest

func (*SampleRowKeysRequest) ProtoMessage 

func (*SampleRowKeysRequest) ProtoMessage()

func (*SampleRowKeysRequest) ProtoReflect 

func (x *SampleRowKeysRequest) ProtoReflect() protoreflect.Message

func (*SampleRowKeysRequest) Reset 

func (x *SampleRowKeysRequest) Reset()

func (*SampleRowKeysRequest) String 

func (x *SampleRowKeysRequest) String() string

type SampleRowKeysResult 

type SampleRowKeysResult struct {

	// The RPC status from the client binding.
	Status *status.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// The raw responses from the Bigtable server.
	Samples []*v2.SampleRowKeysResponse `protobuf:"bytes,2,rep,name=samples,proto3" json:"samples,omitempty"`
	// contains filtered or unexported fields
}

Response from test proxy service for SampleRowKeysRequest.

func (*SampleRowKeysResult) Descriptor deprecated 

func (*SampleRowKeysResult) Descriptor() ([]byte, []int)

Deprecated: Use SampleRowKeysResult.ProtoReflect.Descriptor instead.

func (*SampleRowKeysResult) GetSamples 

func (x *SampleRowKeysResult) GetSamples() []*v2.SampleRowKeysResponse

func (*SampleRowKeysResult) GetStatus 

func (x *SampleRowKeysResult) GetStatus() *status.Status

func (*SampleRowKeysResult) ProtoMessage 

func (*SampleRowKeysResult) ProtoMessage()

func (*SampleRowKeysResult) ProtoReflect 

func (x *SampleRowKeysResult) ProtoReflect() protoreflect.Message

func (*SampleRowKeysResult) Reset 

func (x *SampleRowKeysResult) Reset()

func (*SampleRowKeysResult) String 

func (x *SampleRowKeysResult) String() string

type UnimplementedCloudBigtableV2TestProxyServer 

type UnimplementedCloudBigtableV2TestProxyServer struct {
}

UnimplementedCloudBigtableV2TestProxyServer must be embedded to have forward compatible implementations.

func (UnimplementedCloudBigtableV2TestProxyServer) BulkMutateRows 

func (UnimplementedCloudBigtableV2TestProxyServer) BulkMutateRows(context.Context, *MutateRowsRequest) (*MutateRowsResult, error)

func (UnimplementedCloudBigtableV2TestProxyServer) CheckAndMutateRow 

func (UnimplementedCloudBigtableV2TestProxyServer) CheckAndMutateRow(context.Context, *CheckAndMutateRowRequest) (*CheckAndMutateRowResult, error)

func (UnimplementedCloudBigtableV2TestProxyServer) CloseClient 

func (UnimplementedCloudBigtableV2TestProxyServer) CloseClient(context.Context, *CloseClientRequest) (*CloseClientResponse, error)

func (UnimplementedCloudBigtableV2TestProxyServer) CreateClient 

func (UnimplementedCloudBigtableV2TestProxyServer) CreateClient(context.Context, *CreateClientRequest) (*CreateClientResponse, error)

func (UnimplementedCloudBigtableV2TestProxyServer) MutateRow 

func (UnimplementedCloudBigtableV2TestProxyServer) MutateRow(context.Context, *MutateRowRequest) (*MutateRowResult, error)

func (UnimplementedCloudBigtableV2TestProxyServer) ReadModifyWriteRow 

func (UnimplementedCloudBigtableV2TestProxyServer) ReadModifyWriteRow(context.Context, *ReadModifyWriteRowRequest) (*RowResult, error)

func (UnimplementedCloudBigtableV2TestProxyServer) ReadRow 

func (UnimplementedCloudBigtableV2TestProxyServer) ReadRow(context.Context, *ReadRowRequest) (*RowResult, error)

func (UnimplementedCloudBigtableV2TestProxyServer) ReadRows 

func (UnimplementedCloudBigtableV2TestProxyServer) ReadRows(context.Context, *ReadRowsRequest) (*RowsResult, error)

func (UnimplementedCloudBigtableV2TestProxyServer) RemoveClient 

func (UnimplementedCloudBigtableV2TestProxyServer) RemoveClient(context.Context, *RemoveClientRequest) (*RemoveClientResponse, error)

func (UnimplementedCloudBigtableV2TestProxyServer) SampleRowKeys 

func (UnimplementedCloudBigtableV2TestProxyServer) SampleRowKeys(context.Context, *SampleRowKeysRequest) (*SampleRowKeysResult, error)

type UnsafeCloudBigtableV2TestProxyServer 

type UnsafeCloudBigtableV2TestProxyServer interface {
	// contains filtered or unexported methods
}

UnsafeCloudBigtableV2TestProxyServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CloudBigtableV2TestProxyServer will result in compilation errors.

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.