testproxypb

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
}

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
}

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
}

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

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)
}

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
}

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
}

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

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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

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
}

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
}

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
}

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
}

type UnimplementedCloudBigtableV2TestProxyServer struct {
}

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