package testproxypb

import "github.com/googleapis/cloud-bigtable-clients-test/testproxypb"

Index

Variables

var (
	OptionalFeatureConfig_name = map[int32]string{
		0: "OPTIONAL_FEATURE_CONFIG_DEFAULT",
		1: "OPTIONAL_FEATURE_CONFIG_ENABLE_ALL",
	}
	OptionalFeatureConfig_value = map[string]int32{
		"OPTIONAL_FEATURE_CONFIG_DEFAULT":    0,
		"OPTIONAL_FEATURE_CONFIG_ENABLE_ALL": 1,
	}
)

Enum value maps for OptionalFeatureConfig.

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)

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

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

Deprecated: Use CheckAndMutateRowRequest.ProtoReflect.Descriptor instead.

func (*CheckAndMutateRowRequest) GetClientId

func (x *CheckAndMutateRowRequest) GetClientId() string

func (*CheckAndMutateRowRequest) GetRequest

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

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

Deprecated: Use CheckAndMutateRowResult.ProtoReflect.Descriptor instead.

func (*CheckAndMutateRowResult) GetResult

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

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

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"`
	// Optional config that dictates how the optional features should be enabled
	// during the client creation. Please check the enum type's docstring above.
	OptionalFeatureConfig OptionalFeatureConfig `protobuf:"varint,7,opt,name=optional_feature_config,json=optionalFeatureConfig,proto3,enum=google.bigtable.testproxy.OptionalFeatureConfig" json:"optional_feature_config,omitempty"`
	// contains filtered or unexported fields
}

Request to test proxy service to create a client object.

func (*CreateClientRequest) Descriptor

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

func (x *CreateClientRequest) GetOptionalFeatureConfig() OptionalFeatureConfig

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

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

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

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

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

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 OptionalFeatureConfig

type OptionalFeatureConfig int32

A config flag that dictates how the optional features should be enabled during the client creation. The optional features customize how the client interacts with the server, and are defined in https://github.com/googleapis/googleapis/blob/master/google/bigtable/v2/feature_flags.proto

const (
	OptionalFeatureConfig_OPTIONAL_FEATURE_CONFIG_DEFAULT    OptionalFeatureConfig = 0
	OptionalFeatureConfig_OPTIONAL_FEATURE_CONFIG_ENABLE_ALL OptionalFeatureConfig = 1
)

func (OptionalFeatureConfig) Descriptor

func (OptionalFeatureConfig) Enum

func (OptionalFeatureConfig) EnumDescriptor

func (OptionalFeatureConfig) EnumDescriptor() ([]byte, []int)

Deprecated: Use OptionalFeatureConfig.Descriptor instead.

func (OptionalFeatureConfig) Number

func (OptionalFeatureConfig) String

func (x OptionalFeatureConfig) String() string

func (OptionalFeatureConfig) Type

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

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

Deprecated: Use ReadModifyWriteRowRequest.ProtoReflect.Descriptor instead.

func (*ReadModifyWriteRowRequest) GetClientId

func (x *ReadModifyWriteRowRequest) GetClientId() string

func (*ReadModifyWriteRowRequest) GetRequest

func (*ReadModifyWriteRowRequest) ProtoMessage

func (*ReadModifyWriteRowRequest) ProtoMessage()

func (*ReadModifyWriteRowRequest) ProtoReflect

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

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

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

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

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

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

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

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

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

func (UnimplementedCloudBigtableV2TestProxyServer) CloseClient

func (UnimplementedCloudBigtableV2TestProxyServer) CreateClient

func (UnimplementedCloudBigtableV2TestProxyServer) MutateRow

func (UnimplementedCloudBigtableV2TestProxyServer) ReadModifyWriteRow

func (UnimplementedCloudBigtableV2TestProxyServer) ReadRow

func (UnimplementedCloudBigtableV2TestProxyServer) ReadRows

func (UnimplementedCloudBigtableV2TestProxyServer) RemoveClient

func (UnimplementedCloudBigtableV2TestProxyServer) SampleRowKeys

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

test_proxy.pb.go test_proxy_grpc.pb.go

Version
v0.0.3 (latest)
Published
Dec 19, 2024
Platform
js/wasm
Imports
12 packages
Last checked
now

Tools for package owners.