executorpb

package
v1.53.0 Latest Latest
Warning

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

Go to latest
Published: Nov 15, 2023 License: Apache-2.0 Imports: 15 Imported by: 0

README

Regenerating protos

Cloud Spanner Executor Framework - To generate code manually for cloud_executor.proto file using protoc, run the command below.

cd spanner/test/cloudexecutor/proto
protoc --go_out=plugins=grpc:. -I=<local path to googleapis> -I=./ cloud_executor.proto

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	KeyRange_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "CLOSED_CLOSED",
		2: "CLOSED_OPEN",
		3: "OPEN_CLOSED",
		4: "OPEN_OPEN",
	}
	KeyRange_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED": 0,
		"CLOSED_CLOSED":    1,
		"CLOSED_OPEN":      2,
		"OPEN_CLOSED":      3,
		"OPEN_OPEN":        4,
	}
)

Enum value maps for KeyRange_Type.

View Source
var (
	FinishTransactionAction_Mode_name = map[int32]string{
		0: "MODE_UNSPECIFIED",
		1: "COMMIT",
		2: "ABANDON",
	}
	FinishTransactionAction_Mode_value = map[string]int32{
		"MODE_UNSPECIFIED": 0,
		"COMMIT":           1,
		"ABANDON":          2,
	}
)

Enum value maps for FinishTransactionAction_Mode.

View Source
var File_cloud_executor_proto protoreflect.FileDescriptor

Functions

func RegisterSpannerExecutorProxyServer

func RegisterSpannerExecutorProxyServer(s *grpc.Server, srv SpannerExecutorProxyServer)

Types

type AdminAction

type AdminAction struct {

	// Exactly one of the actions below will be performed in AdminAction.
	//
	// Types that are assignable to Action:
	//
	//	*AdminAction_CreateUserInstanceConfig
	//	*AdminAction_UpdateUserInstanceConfig
	//	*AdminAction_DeleteUserInstanceConfig
	//	*AdminAction_GetCloudInstanceConfig
	//	*AdminAction_ListInstanceConfigs
	//	*AdminAction_CreateCloudInstance
	//	*AdminAction_UpdateCloudInstance
	//	*AdminAction_DeleteCloudInstance
	//	*AdminAction_ListCloudInstances
	//	*AdminAction_GetCloudInstance
	//	*AdminAction_CreateCloudDatabase
	//	*AdminAction_UpdateCloudDatabaseDdl
	//	*AdminAction_UpdateCloudDatabase
	//	*AdminAction_DropCloudDatabase
	//	*AdminAction_ListCloudDatabases
	//	*AdminAction_ListCloudDatabaseOperations
	//	*AdminAction_RestoreCloudDatabase
	//	*AdminAction_GetCloudDatabase
	//	*AdminAction_CreateCloudBackup
	//	*AdminAction_CopyCloudBackup
	//	*AdminAction_GetCloudBackup
	//	*AdminAction_UpdateCloudBackup
	//	*AdminAction_DeleteCloudBackup
	//	*AdminAction_ListCloudBackups
	//	*AdminAction_ListCloudBackupOperations
	//	*AdminAction_GetOperation
	//	*AdminAction_CancelOperation
	Action isAdminAction_Action `protobuf_oneof:"action"`
	// contains filtered or unexported fields
}

AdminAction defines all the cloud spanner admin actions, including instance/database admin ops, backup ops and operation actions.

func (*AdminAction) Descriptor deprecated

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

Deprecated: Use AdminAction.ProtoReflect.Descriptor instead.

func (*AdminAction) GetAction

func (m *AdminAction) GetAction() isAdminAction_Action

func (*AdminAction) GetCancelOperation

func (x *AdminAction) GetCancelOperation() *CancelOperationAction

func (*AdminAction) GetCopyCloudBackup

func (x *AdminAction) GetCopyCloudBackup() *CopyCloudBackupAction

func (*AdminAction) GetCreateCloudBackup

func (x *AdminAction) GetCreateCloudBackup() *CreateCloudBackupAction

func (*AdminAction) GetCreateCloudDatabase

func (x *AdminAction) GetCreateCloudDatabase() *CreateCloudDatabaseAction

func (*AdminAction) GetCreateCloudInstance

func (x *AdminAction) GetCreateCloudInstance() *CreateCloudInstanceAction

func (*AdminAction) GetCreateUserInstanceConfig

func (x *AdminAction) GetCreateUserInstanceConfig() *CreateUserInstanceConfigAction

func (*AdminAction) GetDeleteCloudBackup

func (x *AdminAction) GetDeleteCloudBackup() *DeleteCloudBackupAction

func (*AdminAction) GetDeleteCloudInstance

func (x *AdminAction) GetDeleteCloudInstance() *DeleteCloudInstanceAction

func (*AdminAction) GetDeleteUserInstanceConfig

func (x *AdminAction) GetDeleteUserInstanceConfig() *DeleteUserInstanceConfigAction

func (*AdminAction) GetDropCloudDatabase

func (x *AdminAction) GetDropCloudDatabase() *DropCloudDatabaseAction

func (*AdminAction) GetGetCloudBackup

func (x *AdminAction) GetGetCloudBackup() *GetCloudBackupAction

func (*AdminAction) GetGetCloudDatabase

func (x *AdminAction) GetGetCloudDatabase() *GetCloudDatabaseAction

func (*AdminAction) GetGetCloudInstance

func (x *AdminAction) GetGetCloudInstance() *GetCloudInstanceAction

func (*AdminAction) GetGetCloudInstanceConfig

func (x *AdminAction) GetGetCloudInstanceConfig() *GetCloudInstanceConfigAction

func (*AdminAction) GetGetOperation

func (x *AdminAction) GetGetOperation() *GetOperationAction

func (*AdminAction) GetListCloudBackupOperations

func (x *AdminAction) GetListCloudBackupOperations() *ListCloudBackupOperationsAction

func (*AdminAction) GetListCloudBackups

func (x *AdminAction) GetListCloudBackups() *ListCloudBackupsAction

func (*AdminAction) GetListCloudDatabaseOperations

func (x *AdminAction) GetListCloudDatabaseOperations() *ListCloudDatabaseOperationsAction

func (*AdminAction) GetListCloudDatabases

func (x *AdminAction) GetListCloudDatabases() *ListCloudDatabasesAction

func (*AdminAction) GetListCloudInstances

func (x *AdminAction) GetListCloudInstances() *ListCloudInstancesAction

func (*AdminAction) GetListInstanceConfigs

func (x *AdminAction) GetListInstanceConfigs() *ListCloudInstanceConfigsAction

func (*AdminAction) GetRestoreCloudDatabase

func (x *AdminAction) GetRestoreCloudDatabase() *RestoreCloudDatabaseAction

func (*AdminAction) GetUpdateCloudBackup

func (x *AdminAction) GetUpdateCloudBackup() *UpdateCloudBackupAction

func (*AdminAction) GetUpdateCloudDatabase

func (x *AdminAction) GetUpdateCloudDatabase() *UpdateCloudDatabaseAction

func (*AdminAction) GetUpdateCloudDatabaseDdl

func (x *AdminAction) GetUpdateCloudDatabaseDdl() *UpdateCloudDatabaseDdlAction

func (*AdminAction) GetUpdateCloudInstance

func (x *AdminAction) GetUpdateCloudInstance() *UpdateCloudInstanceAction

func (*AdminAction) GetUpdateUserInstanceConfig

func (x *AdminAction) GetUpdateUserInstanceConfig() *UpdateUserInstanceConfigAction

func (*AdminAction) ProtoMessage

func (*AdminAction) ProtoMessage()

func (*AdminAction) ProtoReflect

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

func (*AdminAction) Reset

func (x *AdminAction) Reset()

func (*AdminAction) String

func (x *AdminAction) String() string

type AdminAction_CancelOperation

type AdminAction_CancelOperation struct {
	// Action that cancels an operation.
	CancelOperation *CancelOperationAction `protobuf:"bytes,26,opt,name=cancel_operation,json=cancelOperation,proto3,oneof"`
}

type AdminAction_CopyCloudBackup

type AdminAction_CopyCloudBackup struct {
	// Action that copies a Cloud Spanner database backup.
	CopyCloudBackup *CopyCloudBackupAction `protobuf:"bytes,19,opt,name=copy_cloud_backup,json=copyCloudBackup,proto3,oneof"`
}

type AdminAction_CreateCloudBackup

type AdminAction_CreateCloudBackup struct {
	// Action that creates a Cloud Spanner database backup.
	CreateCloudBackup *CreateCloudBackupAction `protobuf:"bytes,18,opt,name=create_cloud_backup,json=createCloudBackup,proto3,oneof"`
}

type AdminAction_CreateCloudDatabase

type AdminAction_CreateCloudDatabase struct {
	// Action that creates a Cloud Spanner database.
	CreateCloudDatabase *CreateCloudDatabaseAction `protobuf:"bytes,11,opt,name=create_cloud_database,json=createCloudDatabase,proto3,oneof"`
}

type AdminAction_CreateCloudInstance

type AdminAction_CreateCloudInstance struct {
	// Action that creates a Cloud Spanner instance.
	CreateCloudInstance *CreateCloudInstanceAction `protobuf:"bytes,6,opt,name=create_cloud_instance,json=createCloudInstance,proto3,oneof"`
}

type AdminAction_CreateUserInstanceConfig

type AdminAction_CreateUserInstanceConfig struct {
	// Action that creates a user instance config.
	CreateUserInstanceConfig *CreateUserInstanceConfigAction `protobuf:"bytes,1,opt,name=create_user_instance_config,json=createUserInstanceConfig,proto3,oneof"`
}

type AdminAction_DeleteCloudBackup

type AdminAction_DeleteCloudBackup struct {
	// Action that deletes a Cloud Spanner database backup.
	DeleteCloudBackup *DeleteCloudBackupAction `protobuf:"bytes,22,opt,name=delete_cloud_backup,json=deleteCloudBackup,proto3,oneof"`
}

type AdminAction_DeleteCloudInstance

type AdminAction_DeleteCloudInstance struct {
	// Action that deletes a Cloud Spanner instance.
	DeleteCloudInstance *DeleteCloudInstanceAction `protobuf:"bytes,8,opt,name=delete_cloud_instance,json=deleteCloudInstance,proto3,oneof"`
}

type AdminAction_DeleteUserInstanceConfig

type AdminAction_DeleteUserInstanceConfig struct {
	// Action that deletes a user instance config.
	DeleteUserInstanceConfig *DeleteUserInstanceConfigAction `protobuf:"bytes,3,opt,name=delete_user_instance_config,json=deleteUserInstanceConfig,proto3,oneof"`
}

type AdminAction_DropCloudDatabase

type AdminAction_DropCloudDatabase struct {
	// Action that drops a Cloud Spanner database.
	DropCloudDatabase *DropCloudDatabaseAction `protobuf:"bytes,13,opt,name=drop_cloud_database,json=dropCloudDatabase,proto3,oneof"`
}

type AdminAction_GetCloudBackup

type AdminAction_GetCloudBackup struct {
	// Action that gets a Cloud Spanner database backup.
	GetCloudBackup *GetCloudBackupAction `protobuf:"bytes,20,opt,name=get_cloud_backup,json=getCloudBackup,proto3,oneof"`
}

type AdminAction_GetCloudDatabase

type AdminAction_GetCloudDatabase struct {
	// Action that gets a Cloud Spanner database.
	GetCloudDatabase *GetCloudDatabaseAction `protobuf:"bytes,17,opt,name=get_cloud_database,json=getCloudDatabase,proto3,oneof"`
}

type AdminAction_GetCloudInstance

type AdminAction_GetCloudInstance struct {
	// Action that retrieves a Cloud Spanner instance.
	GetCloudInstance *GetCloudInstanceAction `protobuf:"bytes,10,opt,name=get_cloud_instance,json=getCloudInstance,proto3,oneof"`
}

type AdminAction_GetCloudInstanceConfig

type AdminAction_GetCloudInstanceConfig struct {
	// Action that gets a user instance config.
	GetCloudInstanceConfig *GetCloudInstanceConfigAction `protobuf:"bytes,4,opt,name=get_cloud_instance_config,json=getCloudInstanceConfig,proto3,oneof"`
}

type AdminAction_GetOperation

type AdminAction_GetOperation struct {
	// Action that gets an operation.
	GetOperation *GetOperationAction `protobuf:"bytes,25,opt,name=get_operation,json=getOperation,proto3,oneof"`
}

type AdminAction_ListCloudBackupOperations

type AdminAction_ListCloudBackupOperations struct {
	// Action that lists Cloud Spanner database backup operations.
	ListCloudBackupOperations *ListCloudBackupOperationsAction `protobuf:"bytes,24,opt,name=list_cloud_backup_operations,json=listCloudBackupOperations,proto3,oneof"`
}

type AdminAction_ListCloudBackups

type AdminAction_ListCloudBackups struct {
	// Action that lists Cloud Spanner database backups.
	ListCloudBackups *ListCloudBackupsAction `protobuf:"bytes,23,opt,name=list_cloud_backups,json=listCloudBackups,proto3,oneof"`
}

type AdminAction_ListCloudDatabaseOperations

type AdminAction_ListCloudDatabaseOperations struct {
	// Action that lists Cloud Spanner database operations.
	ListCloudDatabaseOperations *ListCloudDatabaseOperationsAction `protobuf:"bytes,15,opt,name=list_cloud_database_operations,json=listCloudDatabaseOperations,proto3,oneof"`
}

type AdminAction_ListCloudDatabases

type AdminAction_ListCloudDatabases struct {
	// Action that lists Cloud Spanner databases.
	ListCloudDatabases *ListCloudDatabasesAction `protobuf:"bytes,14,opt,name=list_cloud_databases,json=listCloudDatabases,proto3,oneof"`
}

type AdminAction_ListCloudInstances

type AdminAction_ListCloudInstances struct {
	// Action that lists Cloud Spanner instances.
	ListCloudInstances *ListCloudInstancesAction `protobuf:"bytes,9,opt,name=list_cloud_instances,json=listCloudInstances,proto3,oneof"`
}

type AdminAction_ListInstanceConfigs

type AdminAction_ListInstanceConfigs struct {
	// Action that lists user instance configs.
	ListInstanceConfigs *ListCloudInstanceConfigsAction `protobuf:"bytes,5,opt,name=list_instance_configs,json=listInstanceConfigs,proto3,oneof"`
}

type AdminAction_RestoreCloudDatabase

type AdminAction_RestoreCloudDatabase struct {
	// Action that restores a Cloud Spanner database from a backup.
	RestoreCloudDatabase *RestoreCloudDatabaseAction `protobuf:"bytes,16,opt,name=restore_cloud_database,json=restoreCloudDatabase,proto3,oneof"`
}

type AdminAction_UpdateCloudBackup

type AdminAction_UpdateCloudBackup struct {
	// Action that updates a Cloud Spanner database backup.
	UpdateCloudBackup *UpdateCloudBackupAction `protobuf:"bytes,21,opt,name=update_cloud_backup,json=updateCloudBackup,proto3,oneof"`
}

type AdminAction_UpdateCloudDatabase

type AdminAction_UpdateCloudDatabase struct {
	// Action that updates the schema of a Cloud Spanner database.
	UpdateCloudDatabase *UpdateCloudDatabaseAction `protobuf:"bytes,27,opt,name=update_cloud_database,json=updateCloudDatabase,proto3,oneof"`
}

type AdminAction_UpdateCloudDatabaseDdl

type AdminAction_UpdateCloudDatabaseDdl struct {
	// Action that updates the schema of a Cloud Spanner database.
	UpdateCloudDatabaseDdl *UpdateCloudDatabaseDdlAction `protobuf:"bytes,12,opt,name=update_cloud_database_ddl,json=updateCloudDatabaseDdl,proto3,oneof"`
}

type AdminAction_UpdateCloudInstance

type AdminAction_UpdateCloudInstance struct {
	// Action that updates a Cloud Spanner instance.
	UpdateCloudInstance *UpdateCloudInstanceAction `protobuf:"bytes,7,opt,name=update_cloud_instance,json=updateCloudInstance,proto3,oneof"`
}

type AdminAction_UpdateUserInstanceConfig

type AdminAction_UpdateUserInstanceConfig struct {
	// Action that updates a user instance config.
	UpdateUserInstanceConfig *UpdateUserInstanceConfigAction `protobuf:"bytes,2,opt,name=update_user_instance_config,json=updateUserInstanceConfig,proto3,oneof"`
}

type AdminResult

type AdminResult struct {

	// Results of cloud backup related actions.
	BackupResponse *CloudBackupResponse `protobuf:"bytes,1,opt,name=backup_response,json=backupResponse,proto3" json:"backup_response,omitempty"`
	// Results of operation related actions.
	OperationResponse *OperationResponse `protobuf:"bytes,2,opt,name=operation_response,json=operationResponse,proto3" json:"operation_response,omitempty"`
	// Results of database related actions.
	DatabaseResponse *CloudDatabaseResponse `protobuf:"bytes,3,opt,name=database_response,json=databaseResponse,proto3" json:"database_response,omitempty"`
	// Results of instance related actions.
	InstanceResponse *CloudInstanceResponse `protobuf:"bytes,4,opt,name=instance_response,json=instanceResponse,proto3" json:"instance_response,omitempty"`
	// Results of instance config related actions.
	InstanceConfigResponse *CloudInstanceConfigResponse `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

AdminResult contains admin action results, for database/backup/operation.

func (*AdminResult) Descriptor deprecated

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

Deprecated: Use AdminResult.ProtoReflect.Descriptor instead.

func (*AdminResult) GetBackupResponse

func (x *AdminResult) GetBackupResponse() *CloudBackupResponse

func (*AdminResult) GetDatabaseResponse

func (x *AdminResult) GetDatabaseResponse() *CloudDatabaseResponse

func (*AdminResult) GetInstanceConfigResponse

func (x *AdminResult) GetInstanceConfigResponse() *CloudInstanceConfigResponse

func (*AdminResult) GetInstanceResponse

func (x *AdminResult) GetInstanceResponse() *CloudInstanceResponse

func (*AdminResult) GetOperationResponse

func (x *AdminResult) GetOperationResponse() *OperationResponse

func (*AdminResult) ProtoMessage

func (*AdminResult) ProtoMessage()

func (*AdminResult) ProtoReflect

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

func (*AdminResult) Reset

func (x *AdminResult) Reset()

func (*AdminResult) String

func (x *AdminResult) String() string

type BatchDmlAction

type BatchDmlAction struct {

	// DML statements.
	Updates []*QueryAction `protobuf:"bytes,1,rep,name=updates,proto3" json:"updates,omitempty"`
	// contains filtered or unexported fields
}

Batch of DML statements invoked using batched execution.

func (*BatchDmlAction) Descriptor deprecated

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

Deprecated: Use BatchDmlAction.ProtoReflect.Descriptor instead.

func (*BatchDmlAction) GetUpdates

func (x *BatchDmlAction) GetUpdates() []*QueryAction

func (*BatchDmlAction) ProtoMessage

func (*BatchDmlAction) ProtoMessage()

func (*BatchDmlAction) ProtoReflect

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

func (*BatchDmlAction) Reset

func (x *BatchDmlAction) Reset()

func (*BatchDmlAction) String

func (x *BatchDmlAction) String() string

type BatchPartition

type BatchPartition struct {

	// Serialized Partition instance.
	Partition []byte `protobuf:"bytes,1,opt,name=partition,proto3" json:"partition,omitempty"`
	// The partition token decrypted from partition.
	PartitionToken []byte `protobuf:"bytes,2,opt,name=partition_token,json=partitionToken,proto3" json:"partition_token,omitempty"`
	// Table name is set iff the partition was generated for a read (as opposed to
	// a query).
	Table *string `protobuf:"bytes,3,opt,name=table,proto3,oneof" json:"table,omitempty"`
	// Index name if the partition was generated for an index read.
	Index *string `protobuf:"bytes,4,opt,name=index,proto3,oneof" json:"index,omitempty"`
	// contains filtered or unexported fields
}

Identifies a database partition generated for a particular read or query. To read rows from the partition, use ExecutePartitionAction.

func (*BatchPartition) Descriptor deprecated

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

Deprecated: Use BatchPartition.ProtoReflect.Descriptor instead.

func (*BatchPartition) GetIndex

func (x *BatchPartition) GetIndex() string

func (*BatchPartition) GetPartition

func (x *BatchPartition) GetPartition() []byte

func (*BatchPartition) GetPartitionToken

func (x *BatchPartition) GetPartitionToken() []byte

func (*BatchPartition) GetTable

func (x *BatchPartition) GetTable() string

func (*BatchPartition) ProtoMessage

func (*BatchPartition) ProtoMessage()

func (*BatchPartition) ProtoReflect

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

func (*BatchPartition) Reset

func (x *BatchPartition) Reset()

func (*BatchPartition) String

func (x *BatchPartition) String() string

type CancelOperationAction

type CancelOperationAction struct {

	// The name of the operation resource to be cancelled.
	Operation string `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

Action that cancels an operation.

func (*CancelOperationAction) Descriptor deprecated

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

Deprecated: Use CancelOperationAction.ProtoReflect.Descriptor instead.

func (*CancelOperationAction) GetOperation

func (x *CancelOperationAction) GetOperation() string

func (*CancelOperationAction) ProtoMessage

func (*CancelOperationAction) ProtoMessage()

func (*CancelOperationAction) ProtoReflect

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

func (*CancelOperationAction) Reset

func (x *CancelOperationAction) Reset()

func (*CancelOperationAction) String

func (x *CancelOperationAction) String() string

type ChangeStreamRecord

type ChangeStreamRecord struct {

	// Record represents one type of the change stream record.
	//
	// Types that are assignable to Record:
	//
	//	*ChangeStreamRecord_DataChange
	//	*ChangeStreamRecord_ChildPartition
	//	*ChangeStreamRecord_Heartbeat
	Record isChangeStreamRecord_Record `protobuf_oneof:"record"`
	// contains filtered or unexported fields
}

Raw ChangeStream records. Encodes one of: DataChangeRecord, HeartbeatRecord, ChildPartitionsRecord returned from the ChangeStream API.

func (*ChangeStreamRecord) Descriptor deprecated

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

Deprecated: Use ChangeStreamRecord.ProtoReflect.Descriptor instead.

func (*ChangeStreamRecord) GetChildPartition

func (x *ChangeStreamRecord) GetChildPartition() *ChildPartitionsRecord

func (*ChangeStreamRecord) GetDataChange

func (x *ChangeStreamRecord) GetDataChange() *DataChangeRecord

func (*ChangeStreamRecord) GetHeartbeat

func (x *ChangeStreamRecord) GetHeartbeat() *HeartbeatRecord

func (*ChangeStreamRecord) GetRecord

func (m *ChangeStreamRecord) GetRecord() isChangeStreamRecord_Record

func (*ChangeStreamRecord) ProtoMessage

func (*ChangeStreamRecord) ProtoMessage()

func (*ChangeStreamRecord) ProtoReflect

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

func (*ChangeStreamRecord) Reset

func (x *ChangeStreamRecord) Reset()

func (*ChangeStreamRecord) String

func (x *ChangeStreamRecord) String() string

type ChangeStreamRecord_ChildPartition

type ChangeStreamRecord_ChildPartition struct {
	// Child partitions record.
	ChildPartition *ChildPartitionsRecord `protobuf:"bytes,2,opt,name=child_partition,json=childPartition,proto3,oneof"`
}

type ChangeStreamRecord_DataChange

type ChangeStreamRecord_DataChange struct {
	// Data change record.
	DataChange *DataChangeRecord `protobuf:"bytes,1,opt,name=data_change,json=dataChange,proto3,oneof"`
}

type ChangeStreamRecord_Heartbeat

type ChangeStreamRecord_Heartbeat struct {
	// Heartbeat record.
	Heartbeat *HeartbeatRecord `protobuf:"bytes,3,opt,name=heartbeat,proto3,oneof"`
}

type ChildPartitionsRecord

type ChildPartitionsRecord struct {

	// Data change records returned from child partitions in this child partitions
	// record will have a commit timestamp greater than or equal to start_time.
	StartTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// A monotonically increasing sequence number that can be used to define the
	// ordering of the child partitions record when there are multiple child
	// partitions records returned with the same start_time in a particular
	// partition.
	RecordSequence string `protobuf:"bytes,2,opt,name=record_sequence,json=recordSequence,proto3" json:"record_sequence,omitempty"`
	// A set of child partitions and their associated information.
	ChildPartitions []*ChildPartitionsRecord_ChildPartition `protobuf:"bytes,3,rep,name=child_partitions,json=childPartitions,proto3" json:"child_partitions,omitempty"`
	// contains filtered or unexported fields
}

ChangeStream child partition record.

func (*ChildPartitionsRecord) Descriptor deprecated

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

Deprecated: Use ChildPartitionsRecord.ProtoReflect.Descriptor instead.

func (*ChildPartitionsRecord) GetChildPartitions

func (*ChildPartitionsRecord) GetRecordSequence

func (x *ChildPartitionsRecord) GetRecordSequence() string

func (*ChildPartitionsRecord) GetStartTime

func (x *ChildPartitionsRecord) GetStartTime() *timestamppb.Timestamp

func (*ChildPartitionsRecord) ProtoMessage

func (*ChildPartitionsRecord) ProtoMessage()

func (*ChildPartitionsRecord) ProtoReflect

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

func (*ChildPartitionsRecord) Reset

func (x *ChildPartitionsRecord) Reset()

func (*ChildPartitionsRecord) String

func (x *ChildPartitionsRecord) String() string

type ChildPartitionsRecord_ChildPartition

type ChildPartitionsRecord_ChildPartition struct {

	// Partition token string used to identify the child partition in queries.
	Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	// Parent partition tokens of this child partition.
	ParentPartitionTokens []string `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

A single child partition.

func (*ChildPartitionsRecord_ChildPartition) Descriptor deprecated

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

Deprecated: Use ChildPartitionsRecord_ChildPartition.ProtoReflect.Descriptor instead.

func (*ChildPartitionsRecord_ChildPartition) GetParentPartitionTokens

func (x *ChildPartitionsRecord_ChildPartition) GetParentPartitionTokens() []string

func (*ChildPartitionsRecord_ChildPartition) GetToken

func (*ChildPartitionsRecord_ChildPartition) ProtoMessage

func (*ChildPartitionsRecord_ChildPartition) ProtoMessage()

func (*ChildPartitionsRecord_ChildPartition) ProtoReflect

func (*ChildPartitionsRecord_ChildPartition) Reset

func (*ChildPartitionsRecord_ChildPartition) String

type CloseBatchTransactionAction

type CloseBatchTransactionAction struct {

	// Indicates whether the transaction needs to be cleaned up.
	Cleanup bool `protobuf:"varint,1,opt,name=cleanup,proto3" json:"cleanup,omitempty"`
	// contains filtered or unexported fields
}

Closes or cleans up the currently opened batch read-only transaction.

Once a transaction is closed, the Executor can be disposed of or used to start start another transaction. Closing a batch transaction in one Executor doesn't affect the transaction's state in other Executors that also read from it.

When a transaction is cleaned up, it becomes globally invalid. Cleaning up is optional, but recommended.

func (*CloseBatchTransactionAction) Descriptor deprecated

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

Deprecated: Use CloseBatchTransactionAction.ProtoReflect.Descriptor instead.

func (*CloseBatchTransactionAction) GetCleanup

func (x *CloseBatchTransactionAction) GetCleanup() bool

func (*CloseBatchTransactionAction) ProtoMessage

func (*CloseBatchTransactionAction) ProtoMessage()

func (*CloseBatchTransactionAction) ProtoReflect

func (*CloseBatchTransactionAction) Reset

func (x *CloseBatchTransactionAction) Reset()

func (*CloseBatchTransactionAction) String

func (x *CloseBatchTransactionAction) String() string

type CloudBackupResponse

type CloudBackupResponse struct {

	// List of backups returned by ListCloudBackupsAction.
	ListedBackups []*databasepb.Backup `protobuf:"bytes,1,rep,name=listed_backups,json=listedBackups,proto3" json:"listed_backups,omitempty"`
	// List of operations returned by ListCloudBackupOperationsAction.
	ListedBackupOperations []*longrunningpb.Operation `` /* 129-byte string literal not displayed */
	// "next_page_token" can be sent in a subsequent list action
	// to fetch more of the matching data.
	NextPageToken string `protobuf:"bytes,3,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// Backup returned by GetCloudBackupAction/UpdateCloudBackupAction.
	Backup *databasepb.Backup `protobuf:"bytes,4,opt,name=backup,proto3" json:"backup,omitempty"`
	// contains filtered or unexported fields
}

CloudBackupResponse contains results returned by cloud backup related actions.

func (*CloudBackupResponse) Descriptor deprecated

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

Deprecated: Use CloudBackupResponse.ProtoReflect.Descriptor instead.

func (*CloudBackupResponse) GetBackup

func (x *CloudBackupResponse) GetBackup() *databasepb.Backup

func (*CloudBackupResponse) GetListedBackupOperations

func (x *CloudBackupResponse) GetListedBackupOperations() []*longrunningpb.Operation

func (*CloudBackupResponse) GetListedBackups

func (x *CloudBackupResponse) GetListedBackups() []*databasepb.Backup

func (*CloudBackupResponse) GetNextPageToken

func (x *CloudBackupResponse) GetNextPageToken() string

func (*CloudBackupResponse) ProtoMessage

func (*CloudBackupResponse) ProtoMessage()

func (*CloudBackupResponse) ProtoReflect

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

func (*CloudBackupResponse) Reset

func (x *CloudBackupResponse) Reset()

func (*CloudBackupResponse) String

func (x *CloudBackupResponse) String() string

type CloudDatabaseResponse

type CloudDatabaseResponse struct {

	// List of databases returned by ListCloudDatabasesAction.
	ListedDatabases []*databasepb.Database `protobuf:"bytes,1,rep,name=listed_databases,json=listedDatabases,proto3" json:"listed_databases,omitempty"`
	// List of operations returned by ListCloudDatabaseOperationsAction.
	ListedDatabaseOperations []*longrunningpb.Operation `` /* 135-byte string literal not displayed */
	// "next_page_token" can be sent in a subsequent list action
	// to fetch more of the matching data.
	NextPageToken string `protobuf:"bytes,3,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// Database returned by GetCloudDatabaseAction
	Database *databasepb.Database `protobuf:"bytes,4,opt,name=database,proto3" json:"database,omitempty"`
	// contains filtered or unexported fields
}

CloudDatabaseResponse contains results returned by cloud database related actions.

func (*CloudDatabaseResponse) Descriptor deprecated

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

Deprecated: Use CloudDatabaseResponse.ProtoReflect.Descriptor instead.

func (*CloudDatabaseResponse) GetDatabase

func (x *CloudDatabaseResponse) GetDatabase() *databasepb.Database

func (*CloudDatabaseResponse) GetListedDatabaseOperations

func (x *CloudDatabaseResponse) GetListedDatabaseOperations() []*longrunningpb.Operation

func (*CloudDatabaseResponse) GetListedDatabases

func (x *CloudDatabaseResponse) GetListedDatabases() []*databasepb.Database

func (*CloudDatabaseResponse) GetNextPageToken

func (x *CloudDatabaseResponse) GetNextPageToken() string

func (*CloudDatabaseResponse) ProtoMessage

func (*CloudDatabaseResponse) ProtoMessage()

func (*CloudDatabaseResponse) ProtoReflect

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

func (*CloudDatabaseResponse) Reset

func (x *CloudDatabaseResponse) Reset()

func (*CloudDatabaseResponse) String

func (x *CloudDatabaseResponse) String() string

type CloudInstanceConfigResponse

type CloudInstanceConfigResponse struct {

	// List of instance configs returned by ListCloudInstanceConfigsAction.
	ListedInstanceConfigs []*instancepb.InstanceConfig `` /* 126-byte string literal not displayed */
	// "next_page_token" can be sent in a subsequent list action
	// to fetch more of the matching data.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// Instance config returned by GetCloudInstanceConfigAction.
	InstanceConfig *instancepb.InstanceConfig `protobuf:"bytes,3,opt,name=instance_config,json=instanceConfig,proto3" json:"instance_config,omitempty"`
	// contains filtered or unexported fields
}

CloudInstanceConfigResponse contains results returned by cloud instance config related actions.

func (*CloudInstanceConfigResponse) Descriptor deprecated

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

Deprecated: Use CloudInstanceConfigResponse.ProtoReflect.Descriptor instead.

func (*CloudInstanceConfigResponse) GetInstanceConfig

func (x *CloudInstanceConfigResponse) GetInstanceConfig() *instancepb.InstanceConfig

func (*CloudInstanceConfigResponse) GetListedInstanceConfigs

func (x *CloudInstanceConfigResponse) GetListedInstanceConfigs() []*instancepb.InstanceConfig

func (*CloudInstanceConfigResponse) GetNextPageToken

func (x *CloudInstanceConfigResponse) GetNextPageToken() string

func (*CloudInstanceConfigResponse) ProtoMessage

func (*CloudInstanceConfigResponse) ProtoMessage()

func (*CloudInstanceConfigResponse) ProtoReflect

func (*CloudInstanceConfigResponse) Reset

func (x *CloudInstanceConfigResponse) Reset()

func (*CloudInstanceConfigResponse) String

func (x *CloudInstanceConfigResponse) String() string

type CloudInstanceResponse

type CloudInstanceResponse struct {

	// List of instances returned by ListCloudInstancesAction.
	ListedInstances []*instancepb.Instance `protobuf:"bytes,1,rep,name=listed_instances,json=listedInstances,proto3" json:"listed_instances,omitempty"`
	// "next_page_token" can be sent in a subsequent list action
	// to fetch more of the matching data.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// Instance returned by GetCloudInstanceAction
	Instance *instancepb.Instance `protobuf:"bytes,3,opt,name=instance,proto3" json:"instance,omitempty"`
	// contains filtered or unexported fields
}

CloudInstanceResponse contains results returned by cloud instance related actions.

func (*CloudInstanceResponse) Descriptor deprecated

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

Deprecated: Use CloudInstanceResponse.ProtoReflect.Descriptor instead.

func (*CloudInstanceResponse) GetInstance

func (x *CloudInstanceResponse) GetInstance() *instancepb.Instance

func (*CloudInstanceResponse) GetListedInstances

func (x *CloudInstanceResponse) GetListedInstances() []*instancepb.Instance

func (*CloudInstanceResponse) GetNextPageToken

func (x *CloudInstanceResponse) GetNextPageToken() string

func (*CloudInstanceResponse) ProtoMessage

func (*CloudInstanceResponse) ProtoMessage()

func (*CloudInstanceResponse) ProtoReflect

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

func (*CloudInstanceResponse) Reset

func (x *CloudInstanceResponse) Reset()

func (*CloudInstanceResponse) String

func (x *CloudInstanceResponse) String() string

type ColumnMetadata

type ColumnMetadata struct {

	// Column name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Column type.
	Type *spannerpb.Type `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

ColumnMetadata represents metadata of a single column.

func (*ColumnMetadata) Descriptor deprecated

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

Deprecated: Use ColumnMetadata.ProtoReflect.Descriptor instead.

func (*ColumnMetadata) GetName

func (x *ColumnMetadata) GetName() string

func (*ColumnMetadata) GetType

func (x *ColumnMetadata) GetType() *spannerpb.Type

func (*ColumnMetadata) ProtoMessage

func (*ColumnMetadata) ProtoMessage()

func (*ColumnMetadata) ProtoReflect

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

func (*ColumnMetadata) Reset

func (x *ColumnMetadata) Reset()

func (*ColumnMetadata) String

func (x *ColumnMetadata) String() string

type Concurrency

type Concurrency struct {

	// Concurrency mode set for read-only transactions, exactly one mode below
	// should be set.
	//
	// Types that are assignable to ConcurrencyMode:
	//
	//	*Concurrency_StalenessSeconds
	//	*Concurrency_MinReadTimestampMicros
	//	*Concurrency_MaxStalenessSeconds
	//	*Concurrency_ExactTimestampMicros
	//	*Concurrency_Strong
	//	*Concurrency_Batch
	ConcurrencyMode isConcurrency_ConcurrencyMode `protobuf_oneof:"concurrency_mode"`
	// True if exact_timestamp_micros is set, and the chosen timestamp is that of
	// a snapshot epoch.
	SnapshotEpochRead bool `protobuf:"varint,7,opt,name=snapshot_epoch_read,json=snapshotEpochRead,proto3" json:"snapshot_epoch_read,omitempty"`
	// If set, this is a snapshot epoch read constrained to read only the
	// specified log scope root table, and its children. Will not be set for full
	// database epochs.
	SnapshotEpochRootTable string `` /* 131-byte string literal not displayed */
	// Set only when batch is true.
	BatchReadTimestampMicros int64 `` /* 138-byte string literal not displayed */
	// contains filtered or unexported fields
}

Concurrency for read-only transactions.

func (*Concurrency) Descriptor deprecated

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

Deprecated: Use Concurrency.ProtoReflect.Descriptor instead.

func (*Concurrency) GetBatch

func (x *Concurrency) GetBatch() bool

func (*Concurrency) GetBatchReadTimestampMicros

func (x *Concurrency) GetBatchReadTimestampMicros() int64

func (*Concurrency) GetConcurrencyMode

func (m *Concurrency) GetConcurrencyMode() isConcurrency_ConcurrencyMode

func (*Concurrency) GetExactTimestampMicros

func (x *Concurrency) GetExactTimestampMicros() int64

func (*Concurrency) GetMaxStalenessSeconds

func (x *Concurrency) GetMaxStalenessSeconds() float64

func (*Concurrency) GetMinReadTimestampMicros

func (x *Concurrency) GetMinReadTimestampMicros() int64

func (*Concurrency) GetSnapshotEpochRead

func (x *Concurrency) GetSnapshotEpochRead() bool

func (*Concurrency) GetSnapshotEpochRootTable

func (x *Concurrency) GetSnapshotEpochRootTable() string

func (*Concurrency) GetStalenessSeconds

func (x *Concurrency) GetStalenessSeconds() float64

func (*Concurrency) GetStrong

func (x *Concurrency) GetStrong() bool

func (*Concurrency) ProtoMessage

func (*Concurrency) ProtoMessage()

func (*Concurrency) ProtoReflect

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

func (*Concurrency) Reset

func (x *Concurrency) Reset()

func (*Concurrency) String

func (x *Concurrency) String() string

type Concurrency_Batch

type Concurrency_Batch struct {
	// Indicates a batch read, must only be set to true, or unset.
	Batch bool `protobuf:"varint,6,opt,name=batch,proto3,oneof"`
}

type Concurrency_ExactTimestampMicros

type Concurrency_ExactTimestampMicros struct {
	// Indicates a read at a consistent timestamp.
	ExactTimestampMicros int64 `protobuf:"varint,4,opt,name=exact_timestamp_micros,json=exactTimestampMicros,proto3,oneof"`
}

type Concurrency_MaxStalenessSeconds

type Concurrency_MaxStalenessSeconds struct {
	// Indicates a boundedly stale read that is at most N seconds stale.
	MaxStalenessSeconds float64 `protobuf:"fixed64,3,opt,name=max_staleness_seconds,json=maxStalenessSeconds,proto3,oneof"`
}

type Concurrency_MinReadTimestampMicros

type Concurrency_MinReadTimestampMicros struct {
	// Indicates a boundedly stale read that reads at a timestamp >= T.
	MinReadTimestampMicros int64 `protobuf:"varint,2,opt,name=min_read_timestamp_micros,json=minReadTimestampMicros,proto3,oneof"`
}

type Concurrency_StalenessSeconds

type Concurrency_StalenessSeconds struct {
	// Indicates a read at a consistent timestamp that is specified relative to
	// now. That is, if the caller has specified an exact staleness of s
	// seconds, we will read at now - s.
	StalenessSeconds float64 `protobuf:"fixed64,1,opt,name=staleness_seconds,json=stalenessSeconds,proto3,oneof"`
}

type Concurrency_Strong

type Concurrency_Strong struct {
	// Indicates a strong read, must only be set to true, or unset.
	Strong bool `protobuf:"varint,5,opt,name=strong,proto3,oneof"`
}

type CopyCloudBackupAction

type CopyCloudBackupAction struct {

	// Cloud project ID, e.g. "spanner-cloud-systest".
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Cloud instance ID (not path), e.g. "test-instance".
	InstanceId string `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// The id of the backup to be created, e.g. "test-backup".
	BackupId string `protobuf:"bytes,3,opt,name=backup_id,json=backupId,proto3" json:"backup_id,omitempty"`
	// The fully qualified uri of the source backup from which this
	// backup was copied. eg.
	// "projects/<project_id>/instances/<instance_id>/backups/<backup_id>".
	SourceBackup string `protobuf:"bytes,4,opt,name=source_backup,json=sourceBackup,proto3" json:"source_backup,omitempty"`
	// Output only. The expiration time of the backup, which must be at least 6
	// hours and at most 366 days from the time the request is received.
	ExpireTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=expire_time,json=expireTime,proto3" json:"expire_time,omitempty"`
	// contains filtered or unexported fields
}

Action that copies a Cloud Spanner database backup.

func (*CopyCloudBackupAction) Descriptor deprecated

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

Deprecated: Use CopyCloudBackupAction.ProtoReflect.Descriptor instead.

func (*CopyCloudBackupAction) GetBackupId

func (x *CopyCloudBackupAction) GetBackupId() string

func (*CopyCloudBackupAction) GetExpireTime

func (x *CopyCloudBackupAction) GetExpireTime() *timestamppb.Timestamp

func (*CopyCloudBackupAction) GetInstanceId

func (x *CopyCloudBackupAction) GetInstanceId() string

func (*CopyCloudBackupAction) GetProjectId

func (x *CopyCloudBackupAction) GetProjectId() string

func (*CopyCloudBackupAction) GetSourceBackup

func (x *CopyCloudBackupAction) GetSourceBackup() string

func (*CopyCloudBackupAction) ProtoMessage

func (*CopyCloudBackupAction) ProtoMessage()

func (*CopyCloudBackupAction) ProtoReflect

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

func (*CopyCloudBackupAction) Reset

func (x *CopyCloudBackupAction) Reset()

func (*CopyCloudBackupAction) String

func (x *CopyCloudBackupAction) String() string

type CreateCloudBackupAction

type CreateCloudBackupAction struct {

	// Cloud project ID, e.g. "spanner-cloud-systest".
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Cloud instance ID (not path), e.g. "test-instance".
	InstanceId string `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// The id of the backup to be created, e.g. "test-backup".
	BackupId string `protobuf:"bytes,3,opt,name=backup_id,json=backupId,proto3" json:"backup_id,omitempty"`
	// The id of the database from which this backup was
	// created, e.g. "db0". Note that this needs to be in the
	// same instance as the backup.
	DatabaseId string `protobuf:"bytes,4,opt,name=database_id,json=databaseId,proto3" json:"database_id,omitempty"`
	// Output only. The expiration time of the backup, which must be at least 6
	// hours and at most 366 days from the time the request is received.
	ExpireTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=expire_time,json=expireTime,proto3" json:"expire_time,omitempty"`
	// The version time of the backup, which must be within the time range of
	// [earliest_version_time, NOW], where earliest_version_time is retrieved by
	// cloud spanner frontend API (See details: go/cs-pitr-lite-design).
	VersionTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=version_time,json=versionTime,proto3,oneof" json:"version_time,omitempty"`
	// contains filtered or unexported fields
}

Action that creates a Cloud Spanner database backup.

func (*CreateCloudBackupAction) Descriptor deprecated

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

Deprecated: Use CreateCloudBackupAction.ProtoReflect.Descriptor instead.

func (*CreateCloudBackupAction) GetBackupId

func (x *CreateCloudBackupAction) GetBackupId() string

func (*CreateCloudBackupAction) GetDatabaseId

func (x *CreateCloudBackupAction) GetDatabaseId() string

func (*CreateCloudBackupAction) GetExpireTime

func (x *CreateCloudBackupAction) GetExpireTime() *timestamppb.Timestamp

func (*CreateCloudBackupAction) GetInstanceId

func (x *CreateCloudBackupAction) GetInstanceId() string

func (*CreateCloudBackupAction) GetProjectId

func (x *CreateCloudBackupAction) GetProjectId() string

func (*CreateCloudBackupAction) GetVersionTime

func (x *CreateCloudBackupAction) GetVersionTime() *timestamppb.Timestamp

func (*CreateCloudBackupAction) ProtoMessage

func (*CreateCloudBackupAction) ProtoMessage()

func (*CreateCloudBackupAction) ProtoReflect

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

func (*CreateCloudBackupAction) Reset

func (x *CreateCloudBackupAction) Reset()

func (*CreateCloudBackupAction) String

func (x *CreateCloudBackupAction) String() string

type CreateCloudDatabaseAction

type CreateCloudDatabaseAction struct {

	// Cloud instance ID (not path), e.g. "test-instance".
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// Cloud project ID, e.g. "spanner-cloud-systest".
	ProjectId string `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Cloud database ID (not full path), e.g. "db0".
	DatabaseId string `protobuf:"bytes,3,opt,name=database_id,json=databaseId,proto3" json:"database_id,omitempty"`
	// SDL statements to apply to the new database.
	SdlStatement []string `protobuf:"bytes,4,rep,name=sdl_statement,json=sdlStatement,proto3" json:"sdl_statement,omitempty"`
	// The KMS key used to encrypt the database to be created if the database
	// should be CMEK protected.
	EncryptionConfig *databasepb.EncryptionConfig `protobuf:"bytes,5,opt,name=encryption_config,json=encryptionConfig,proto3" json:"encryption_config,omitempty"`
	// Optional SQL dialect (GOOGLESQL or POSTGRESQL).  Default: GOOGLESQL.
	Dialect *string `protobuf:"bytes,6,opt,name=dialect,proto3,oneof" json:"dialect,omitempty"`
	// contains filtered or unexported fields
}

Action that creates a Cloud Spanner database.

func (*CreateCloudDatabaseAction) Descriptor deprecated

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

Deprecated: Use CreateCloudDatabaseAction.ProtoReflect.Descriptor instead.

func (*CreateCloudDatabaseAction) GetDatabaseId

func (x *CreateCloudDatabaseAction) GetDatabaseId() string

func (*CreateCloudDatabaseAction) GetDialect

func (x *CreateCloudDatabaseAction) GetDialect() string

func (*CreateCloudDatabaseAction) GetEncryptionConfig

func (x *CreateCloudDatabaseAction) GetEncryptionConfig() *databasepb.EncryptionConfig

func (*CreateCloudDatabaseAction) GetInstanceId

func (x *CreateCloudDatabaseAction) GetInstanceId() string

func (*CreateCloudDatabaseAction) GetProjectId

func (x *CreateCloudDatabaseAction) GetProjectId() string

func (*CreateCloudDatabaseAction) GetSdlStatement

func (x *CreateCloudDatabaseAction) GetSdlStatement() []string

func (*CreateCloudDatabaseAction) ProtoMessage

func (*CreateCloudDatabaseAction) ProtoMessage()

func (*CreateCloudDatabaseAction) ProtoReflect

func (*CreateCloudDatabaseAction) Reset

func (x *CreateCloudDatabaseAction) Reset()

func (*CreateCloudDatabaseAction) String

func (x *CreateCloudDatabaseAction) String() string

type CreateCloudInstanceAction

type CreateCloudInstanceAction struct {

	// Cloud instance ID (not path), e.g. "test-instance".
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// Cloud project ID, e.g. "spanner-cloud-systest".
	ProjectId string `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Instance config ID, e.g. "test-config".
	InstanceConfigId string `protobuf:"bytes,3,opt,name=instance_config_id,json=instanceConfigId,proto3" json:"instance_config_id,omitempty"`
	// Number of nodes (processing_units should not be set or set to 0 if used).
	NodeCount *int32 `protobuf:"varint,4,opt,name=node_count,json=nodeCount,proto3,oneof" json:"node_count,omitempty"`
	// Number of processing units (node_count should be set to 0 if used).
	ProcessingUnits *int32 `protobuf:"varint,6,opt,name=processing_units,json=processingUnits,proto3,oneof" json:"processing_units,omitempty"`
	// labels.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

Action that creates a Cloud Spanner instance.

func (*CreateCloudInstanceAction) Descriptor deprecated

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

Deprecated: Use CreateCloudInstanceAction.ProtoReflect.Descriptor instead.

func (*CreateCloudInstanceAction) GetInstanceConfigId

func (x *CreateCloudInstanceAction) GetInstanceConfigId() string

func (*CreateCloudInstanceAction) GetInstanceId

func (x *CreateCloudInstanceAction) GetInstanceId() string

func (*CreateCloudInstanceAction) GetLabels

func (x *CreateCloudInstanceAction) GetLabels() map[string]string

func (*CreateCloudInstanceAction) GetNodeCount

func (x *CreateCloudInstanceAction) GetNodeCount() int32

func (*CreateCloudInstanceAction) GetProcessingUnits

func (x *CreateCloudInstanceAction) GetProcessingUnits() int32

func (*CreateCloudInstanceAction) GetProjectId

func (x *CreateCloudInstanceAction) GetProjectId() string

func (*CreateCloudInstanceAction) ProtoMessage

func (*CreateCloudInstanceAction) ProtoMessage()

func (*CreateCloudInstanceAction) ProtoReflect

func (*CreateCloudInstanceAction) Reset

func (x *CreateCloudInstanceAction) Reset()

func (*CreateCloudInstanceAction) String

func (x *CreateCloudInstanceAction) String() string

type CreateUserInstanceConfigAction

type CreateUserInstanceConfigAction struct {

	// User instance config ID (not path), e.g. "custom-config".
	UserConfigId string `protobuf:"bytes,1,opt,name=user_config_id,json=userConfigId,proto3" json:"user_config_id,omitempty"`
	// Cloud project ID, e.g. "spanner-cloud-systest".
	ProjectId string `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Base config ID, e.g. "test-config".
	BaseConfigId string `protobuf:"bytes,3,opt,name=base_config_id,json=baseConfigId,proto3" json:"base_config_id,omitempty"`
	// Replicas that should be included in the user config.
	Replicas []*instancepb.ReplicaInfo `protobuf:"bytes,4,rep,name=replicas,proto3" json:"replicas,omitempty"`
	// contains filtered or unexported fields
}

Action that creates a user instance config.

func (*CreateUserInstanceConfigAction) Descriptor deprecated

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

Deprecated: Use CreateUserInstanceConfigAction.ProtoReflect.Descriptor instead.

func (*CreateUserInstanceConfigAction) GetBaseConfigId

func (x *CreateUserInstanceConfigAction) GetBaseConfigId() string

func (*CreateUserInstanceConfigAction) GetProjectId

func (x *CreateUserInstanceConfigAction) GetProjectId() string

func (*CreateUserInstanceConfigAction) GetReplicas

func (*CreateUserInstanceConfigAction) GetUserConfigId

func (x *CreateUserInstanceConfigAction) GetUserConfigId() string

func (*CreateUserInstanceConfigAction) ProtoMessage

func (*CreateUserInstanceConfigAction) ProtoMessage()

func (*CreateUserInstanceConfigAction) ProtoReflect

func (*CreateUserInstanceConfigAction) Reset

func (x *CreateUserInstanceConfigAction) Reset()

func (*CreateUserInstanceConfigAction) String

type DataChangeRecord

type DataChangeRecord struct {

	// The timestamp in which the change was committed.
	CommitTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=commit_time,json=commitTime,proto3" json:"commit_time,omitempty"`
	// The sequence number for the record within the transaction.
	RecordSequence string `protobuf:"bytes,2,opt,name=record_sequence,json=recordSequence,proto3" json:"record_sequence,omitempty"`
	// A globally unique string that represents the transaction in which the
	// change was committed.
	TransactionId string `protobuf:"bytes,3,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	// Indicates whether this is the last record for a transaction in the current
	// partition.
	IsLastRecord bool `protobuf:"varint,4,opt,name=is_last_record,json=isLastRecord,proto3" json:"is_last_record,omitempty"`
	// Name of the table affected by the change.
	Table string `protobuf:"bytes,5,opt,name=table,proto3" json:"table,omitempty"`
	// Column types defined in the schema.
	ColumnTypes []*DataChangeRecord_ColumnType `protobuf:"bytes,6,rep,name=column_types,json=columnTypes,proto3" json:"column_types,omitempty"`
	// Changes made in the transaction.
	Mods []*DataChangeRecord_Mod `protobuf:"bytes,7,rep,name=mods,proto3" json:"mods,omitempty"`
	// Describes the type of change. One of INSERT, UPDATE or DELETE.
	ModType string `protobuf:"bytes,8,opt,name=mod_type,json=modType,proto3" json:"mod_type,omitempty"`
	// One of value capture type: NEW_VALUES, OLD_VALUES, OLD_AND_NEW_VALUES.
	ValueCaptureType string `protobuf:"bytes,9,opt,name=value_capture_type,json=valueCaptureType,proto3" json:"value_capture_type,omitempty"`
	// Number of records in transactions.
	RecordCount int64 `protobuf:"varint,10,opt,name=record_count,json=recordCount,proto3" json:"record_count,omitempty"`
	// Number of partitions in transactions.
	PartitionCount int64 `protobuf:"varint,11,opt,name=partition_count,json=partitionCount,proto3" json:"partition_count,omitempty"`
	// Transaction tag info.
	TransactionTag string `protobuf:"bytes,12,opt,name=transaction_tag,json=transactionTag,proto3" json:"transaction_tag,omitempty"`
	// Whether the transaction is a system transactionn.
	IsSystemTransaction bool `protobuf:"varint,13,opt,name=is_system_transaction,json=isSystemTransaction,proto3" json:"is_system_transaction,omitempty"`
	// contains filtered or unexported fields
}

ChangeStream data change record.

func (*DataChangeRecord) Descriptor deprecated

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

Deprecated: Use DataChangeRecord.ProtoReflect.Descriptor instead.

func (*DataChangeRecord) GetColumnTypes

func (x *DataChangeRecord) GetColumnTypes() []*DataChangeRecord_ColumnType

func (*DataChangeRecord) GetCommitTime

func (x *DataChangeRecord) GetCommitTime() *timestamppb.Timestamp

func (*DataChangeRecord) GetIsLastRecord

func (x *DataChangeRecord) GetIsLastRecord() bool

func (*DataChangeRecord) GetIsSystemTransaction

func (x *DataChangeRecord) GetIsSystemTransaction() bool

func (*DataChangeRecord) GetModType

func (x *DataChangeRecord) GetModType() string

func (*DataChangeRecord) GetMods

func (x *DataChangeRecord) GetMods() []*DataChangeRecord_Mod

func (*DataChangeRecord) GetPartitionCount

func (x *DataChangeRecord) GetPartitionCount() int64

func (*DataChangeRecord) GetRecordCount

func (x *DataChangeRecord) GetRecordCount() int64

func (*DataChangeRecord) GetRecordSequence

func (x *DataChangeRecord) GetRecordSequence() string

func (*DataChangeRecord) GetTable

func (x *DataChangeRecord) GetTable() string

func (*DataChangeRecord) GetTransactionId

func (x *DataChangeRecord) GetTransactionId() string

func (*DataChangeRecord) GetTransactionTag

func (x *DataChangeRecord) GetTransactionTag() string

func (*DataChangeRecord) GetValueCaptureType

func (x *DataChangeRecord) GetValueCaptureType() string

func (*DataChangeRecord) ProtoMessage

func (*DataChangeRecord) ProtoMessage()

func (*DataChangeRecord) ProtoReflect

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

func (*DataChangeRecord) Reset

func (x *DataChangeRecord) Reset()

func (*DataChangeRecord) String

func (x *DataChangeRecord) String() string

type DataChangeRecord_ColumnType

type DataChangeRecord_ColumnType struct {

	// Column name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Column type in JSON.
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// Whether the column is a primary key column.
	IsPrimaryKey bool `protobuf:"varint,3,opt,name=is_primary_key,json=isPrimaryKey,proto3" json:"is_primary_key,omitempty"`
	// The position of the column as defined in the schema.
	OrdinalPosition int64 `protobuf:"varint,4,opt,name=ordinal_position,json=ordinalPosition,proto3" json:"ordinal_position,omitempty"`
	// contains filtered or unexported fields
}

Column types.

func (*DataChangeRecord_ColumnType) Descriptor deprecated

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

Deprecated: Use DataChangeRecord_ColumnType.ProtoReflect.Descriptor instead.

func (*DataChangeRecord_ColumnType) GetIsPrimaryKey

func (x *DataChangeRecord_ColumnType) GetIsPrimaryKey() bool

func (*DataChangeRecord_ColumnType) GetName

func (x *DataChangeRecord_ColumnType) GetName() string

func (*DataChangeRecord_ColumnType) GetOrdinalPosition

func (x *DataChangeRecord_ColumnType) GetOrdinalPosition() int64

func (*DataChangeRecord_ColumnType) GetType

func (x *DataChangeRecord_ColumnType) GetType() string

func (*DataChangeRecord_ColumnType) ProtoMessage

func (*DataChangeRecord_ColumnType) ProtoMessage()

func (*DataChangeRecord_ColumnType) ProtoReflect

func (*DataChangeRecord_ColumnType) Reset

func (x *DataChangeRecord_ColumnType) Reset()

func (*DataChangeRecord_ColumnType) String

func (x *DataChangeRecord_ColumnType) String() string

type DataChangeRecord_Mod

type DataChangeRecord_Mod struct {

	// The primary key values in JSON.
	Keys string `protobuf:"bytes,1,opt,name=keys,proto3" json:"keys,omitempty"`
	// The new values of the changed columns in JSON. Only contain the non-key
	// columns.
	NewValues string `protobuf:"bytes,2,opt,name=new_values,json=newValues,proto3" json:"new_values,omitempty"`
	// The old values of the changed columns in JSON. Only contain the non-key
	// columns.
	OldValues string `protobuf:"bytes,3,opt,name=old_values,json=oldValues,proto3" json:"old_values,omitempty"`
	// contains filtered or unexported fields
}

Describes the changes that were made.

func (*DataChangeRecord_Mod) Descriptor deprecated

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

Deprecated: Use DataChangeRecord_Mod.ProtoReflect.Descriptor instead.

func (*DataChangeRecord_Mod) GetKeys

func (x *DataChangeRecord_Mod) GetKeys() string

func (*DataChangeRecord_Mod) GetNewValues

func (x *DataChangeRecord_Mod) GetNewValues() string

func (*DataChangeRecord_Mod) GetOldValues

func (x *DataChangeRecord_Mod) GetOldValues() string

func (*DataChangeRecord_Mod) ProtoMessage

func (*DataChangeRecord_Mod) ProtoMessage()

func (*DataChangeRecord_Mod) ProtoReflect

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

func (*DataChangeRecord_Mod) Reset

func (x *DataChangeRecord_Mod) Reset()

func (*DataChangeRecord_Mod) String

func (x *DataChangeRecord_Mod) String() string

type DeleteCloudBackupAction

type DeleteCloudBackupAction struct {

	// Cloud project ID, e.g. "spanner-cloud-systest".
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Cloud instance ID (not path), e.g. "test-instance".
	InstanceId string `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// The id of the backup to delete, e.g. "test-backup".
	BackupId string `protobuf:"bytes,3,opt,name=backup_id,json=backupId,proto3" json:"backup_id,omitempty"`
	// contains filtered or unexported fields
}

Action that deletes a Cloud Spanner database backup.

func (*DeleteCloudBackupAction) Descriptor deprecated

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

Deprecated: Use DeleteCloudBackupAction.ProtoReflect.Descriptor instead.

func (*DeleteCloudBackupAction) GetBackupId

func (x *DeleteCloudBackupAction) GetBackupId() string

func (*DeleteCloudBackupAction) GetInstanceId

func (x *DeleteCloudBackupAction) GetInstanceId() string

func (*DeleteCloudBackupAction) GetProjectId

func (x *DeleteCloudBackupAction) GetProjectId() string

func (*DeleteCloudBackupAction) ProtoMessage

func (*DeleteCloudBackupAction) ProtoMessage()

func (*DeleteCloudBackupAction) ProtoReflect

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

func (*DeleteCloudBackupAction) Reset

func (x *DeleteCloudBackupAction) Reset()

func (*DeleteCloudBackupAction) String

func (x *DeleteCloudBackupAction) String() string

type DeleteCloudInstanceAction

type DeleteCloudInstanceAction struct {

	// Cloud instance ID (not path), e.g. "test-instance".
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// Cloud project ID, e.g. "spanner-cloud-systest".
	ProjectId string `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

Action that deletes a Cloud Spanner instance.

func (*DeleteCloudInstanceAction) Descriptor deprecated

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

Deprecated: Use DeleteCloudInstanceAction.ProtoReflect.Descriptor instead.

func (*DeleteCloudInstanceAction) GetInstanceId

func (x *DeleteCloudInstanceAction) GetInstanceId() string

func (*DeleteCloudInstanceAction) GetProjectId

func (x *DeleteCloudInstanceAction) GetProjectId() string

func (*DeleteCloudInstanceAction) ProtoMessage

func (*DeleteCloudInstanceAction) ProtoMessage()

func (*DeleteCloudInstanceAction) ProtoReflect

func (*DeleteCloudInstanceAction) Reset

func (x *DeleteCloudInstanceAction) Reset()

func (*DeleteCloudInstanceAction) String

func (x *DeleteCloudInstanceAction) String() string

type DeleteUserInstanceConfigAction

type DeleteUserInstanceConfigAction struct {

	// User instance config ID (not path), e.g. "custom-config".
	UserConfigId string `protobuf:"bytes,1,opt,name=user_config_id,json=userConfigId,proto3" json:"user_config_id,omitempty"`
	// Cloud project ID, e.g. "spanner-cloud-systest".
	ProjectId string `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

Action that deletes a user instance configs.

func (*DeleteUserInstanceConfigAction) Descriptor deprecated

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

Deprecated: Use DeleteUserInstanceConfigAction.ProtoReflect.Descriptor instead.

func (*DeleteUserInstanceConfigAction) GetProjectId

func (x *DeleteUserInstanceConfigAction) GetProjectId() string

func (*DeleteUserInstanceConfigAction) GetUserConfigId

func (x *DeleteUserInstanceConfigAction) GetUserConfigId() string

func (*DeleteUserInstanceConfigAction) ProtoMessage

func (*DeleteUserInstanceConfigAction) ProtoMessage()

func (*DeleteUserInstanceConfigAction) ProtoReflect

func (*DeleteUserInstanceConfigAction) Reset

func (x *DeleteUserInstanceConfigAction) Reset()

func (*DeleteUserInstanceConfigAction) String

type DmlAction

type DmlAction struct {

	// DML statement.
	Update *QueryAction `protobuf:"bytes,1,opt,name=update,proto3" json:"update,omitempty"`
	// Whether to autocommit the transaction after executing the DML statement,
	// if the Executor supports autocommit.
	AutocommitIfSupported *bool `` /* 133-byte string literal not displayed */
	// contains filtered or unexported fields
}

A single DML statement.

func (*DmlAction) Descriptor deprecated

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

Deprecated: Use DmlAction.ProtoReflect.Descriptor instead.

func (*DmlAction) GetAutocommitIfSupported

func (x *DmlAction) GetAutocommitIfSupported() bool

func (*DmlAction) GetUpdate

func (x *DmlAction) GetUpdate() *QueryAction

func (*DmlAction) ProtoMessage

func (*DmlAction) ProtoMessage()

func (*DmlAction) ProtoReflect

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

func (*DmlAction) Reset

func (x *DmlAction) Reset()

func (*DmlAction) String

func (x *DmlAction) String() string

type DropCloudDatabaseAction

type DropCloudDatabaseAction struct {

	// Cloud instance ID (not path), e.g. "test-instance".
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// Cloud project ID, e.g. "spanner-cloud-systest".
	ProjectId string `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Cloud database ID (not full path), e.g. "db0".
	DatabaseId string `protobuf:"bytes,3,opt,name=database_id,json=databaseId,proto3" json:"database_id,omitempty"`
	// contains filtered or unexported fields
}

Action that drops a Cloud Spanner database.

func (*DropCloudDatabaseAction) Descriptor deprecated

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

Deprecated: Use DropCloudDatabaseAction.ProtoReflect.Descriptor instead.

func (*DropCloudDatabaseAction) GetDatabaseId

func (x *DropCloudDatabaseAction) GetDatabaseId() string

func (*DropCloudDatabaseAction) GetInstanceId

func (x *DropCloudDatabaseAction) GetInstanceId() string

func (*DropCloudDatabaseAction) GetProjectId

func (x *DropCloudDatabaseAction) GetProjectId() string

func (*DropCloudDatabaseAction) ProtoMessage

func (*DropCloudDatabaseAction) ProtoMessage()

func (*DropCloudDatabaseAction) ProtoReflect

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

func (*DropCloudDatabaseAction) Reset

func (x *DropCloudDatabaseAction) Reset()

func (*DropCloudDatabaseAction) String

func (x *DropCloudDatabaseAction) String() string

type ExecuteChangeStreamQuery

type ExecuteChangeStreamQuery struct {

	// Name for this change stream.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Specifies that records with commit_timestamp greater than or equal to
	// start_time should be returned.
	StartTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// Specifies that records with commit_timestamp less than or equal to
	// end_time should be returned.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=end_time,json=endTime,proto3,oneof" json:"end_time,omitempty"`
	// Specifies which change stream partition to query, based on the content of
	// child partitions records.
	PartitionToken *string `protobuf:"bytes,4,opt,name=partition_token,json=partitionToken,proto3,oneof" json:"partition_token,omitempty"`
	// Read options for this change stream query.
	ReadOptions []string `protobuf:"bytes,5,rep,name=read_options,json=readOptions,proto3" json:"read_options,omitempty"`
	// Determines how frequently a heartbeat ChangeRecord will be returned in case
	// there are no transactions committed in this partition, in milliseconds.
	HeartbeatMilliseconds *int32 `` /* 131-byte string literal not displayed */
	// Deadline for this change stream query, in seconds.
	DeadlineSeconds *int64 `protobuf:"varint,7,opt,name=deadline_seconds,json=deadlineSeconds,proto3,oneof" json:"deadline_seconds,omitempty"`
	// Database role to assume while performing this action. This should only be
	// set for cloud requests. Setting the database role will enforce additional
	// role-based access checks on this action.
	CloudDatabaseRole *string `protobuf:"bytes,8,opt,name=cloud_database_role,json=cloudDatabaseRole,proto3,oneof" json:"cloud_database_role,omitempty"`
	// contains filtered or unexported fields
}

Execute a change stream TVF query.

func (*ExecuteChangeStreamQuery) Descriptor deprecated

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

Deprecated: Use ExecuteChangeStreamQuery.ProtoReflect.Descriptor instead.

func (*ExecuteChangeStreamQuery) GetCloudDatabaseRole

func (x *ExecuteChangeStreamQuery) GetCloudDatabaseRole() string

func (*ExecuteChangeStreamQuery) GetDeadlineSeconds

func (x *ExecuteChangeStreamQuery) GetDeadlineSeconds() int64

func (*ExecuteChangeStreamQuery) GetEndTime

func (*ExecuteChangeStreamQuery) GetHeartbeatMilliseconds

func (x *ExecuteChangeStreamQuery) GetHeartbeatMilliseconds() int32

func (*ExecuteChangeStreamQuery) GetName

func (x *ExecuteChangeStreamQuery) GetName() string

func (*ExecuteChangeStreamQuery) GetPartitionToken

func (x *ExecuteChangeStreamQuery) GetPartitionToken() string

func (*ExecuteChangeStreamQuery) GetReadOptions

func (x *ExecuteChangeStreamQuery) GetReadOptions() []string

func (*ExecuteChangeStreamQuery) GetStartTime

func (x *ExecuteChangeStreamQuery) GetStartTime() *timestamppb.Timestamp

func (*ExecuteChangeStreamQuery) ProtoMessage

func (*ExecuteChangeStreamQuery) ProtoMessage()

func (*ExecuteChangeStreamQuery) ProtoReflect

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

func (*ExecuteChangeStreamQuery) Reset

func (x *ExecuteChangeStreamQuery) Reset()

func (*ExecuteChangeStreamQuery) String

func (x *ExecuteChangeStreamQuery) String() string

type ExecutePartitionAction

type ExecutePartitionAction struct {

	// Batch partition to execute on.
	Partition *BatchPartition `protobuf:"bytes,1,opt,name=partition,proto3" json:"partition,omitempty"`
	// contains filtered or unexported fields
}

Performs a read or query for the given partitions. This action must be executed in the context of the same transaction that was used to generate given partitions.

func (*ExecutePartitionAction) Descriptor deprecated

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

Deprecated: Use ExecutePartitionAction.ProtoReflect.Descriptor instead.

func (*ExecutePartitionAction) GetPartition

func (x *ExecutePartitionAction) GetPartition() *BatchPartition

func (*ExecutePartitionAction) ProtoMessage

func (*ExecutePartitionAction) ProtoMessage()

func (*ExecutePartitionAction) ProtoReflect

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

func (*ExecutePartitionAction) Reset

func (x *ExecutePartitionAction) Reset()

func (*ExecutePartitionAction) String

func (x *ExecutePartitionAction) String() string

type FinishTransactionAction

type FinishTransactionAction struct {

	// Defines how exactly the transaction should be completed, e.g. with
	// commit or abortion.
	Mode FinishTransactionAction_Mode `protobuf:"varint,1,opt,name=mode,proto3,enum=google.spanner.executor.v1.FinishTransactionAction_Mode" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

FinishTransactionAction defines an action of finishing a transaction.

func (*FinishTransactionAction) Descriptor deprecated

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

Deprecated: Use FinishTransactionAction.ProtoReflect.Descriptor instead.

func (*FinishTransactionAction) GetMode

func (*FinishTransactionAction) ProtoMessage

func (*FinishTransactionAction) ProtoMessage()

func (*FinishTransactionAction) ProtoReflect

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

func (*FinishTransactionAction) Reset

func (x *FinishTransactionAction) Reset()

func (*FinishTransactionAction) String

func (x *FinishTransactionAction) String() string

type FinishTransactionAction_Mode

type FinishTransactionAction_Mode int32

Mode indicates how the transaction should be finished.

const (
	// "MODE_UNSPECIFIED" is equivalent to "COMMIT".
	FinishTransactionAction_MODE_UNSPECIFIED FinishTransactionAction_Mode = 0
	// Commit the transaction.
	FinishTransactionAction_COMMIT FinishTransactionAction_Mode = 1
	// Drop the transaction without committing it.
	FinishTransactionAction_ABANDON FinishTransactionAction_Mode = 2
)

func (FinishTransactionAction_Mode) Descriptor

func (FinishTransactionAction_Mode) Enum

func (FinishTransactionAction_Mode) EnumDescriptor deprecated

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

Deprecated: Use FinishTransactionAction_Mode.Descriptor instead.

func (FinishTransactionAction_Mode) Number

func (FinishTransactionAction_Mode) String

func (FinishTransactionAction_Mode) Type

type GenerateDbPartitionsForQueryAction

type GenerateDbPartitionsForQueryAction struct {

	// Query to generate partitions for.
	Query *QueryAction `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	// Desired size of data in each partition. Spanner doesn't guarantee to
	// respect this value.
	DesiredBytesPerPartition *int64 `` /* 144-byte string literal not displayed */
	// contains filtered or unexported fields
}

Generate database partitions for the given query. Successful outcomes will contain database partitions in the db_partition field.

func (*GenerateDbPartitionsForQueryAction) Descriptor deprecated

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

Deprecated: Use GenerateDbPartitionsForQueryAction.ProtoReflect.Descriptor instead.

func (*GenerateDbPartitionsForQueryAction) GetDesiredBytesPerPartition

func (x *GenerateDbPartitionsForQueryAction) GetDesiredBytesPerPartition() int64

func (*GenerateDbPartitionsForQueryAction) GetQuery

func (*GenerateDbPartitionsForQueryAction) ProtoMessage

func (*GenerateDbPartitionsForQueryAction) ProtoMessage()

func (*GenerateDbPartitionsForQueryAction) ProtoReflect

func (*GenerateDbPartitionsForQueryAction) Reset

func (*GenerateDbPartitionsForQueryAction) String

type GenerateDbPartitionsForReadAction

type GenerateDbPartitionsForReadAction struct {

	// Read to generate partitions for.
	Read *ReadAction `protobuf:"bytes,1,opt,name=read,proto3" json:"read,omitempty"`
	// Metadata related to the tables involved in the read.
	Table []*TableMetadata `protobuf:"bytes,2,rep,name=table,proto3" json:"table,omitempty"`
	// Desired size of data in each partition. Spanner doesn't guarantee to
	// respect this value.
	DesiredBytesPerPartition *int64 `` /* 144-byte string literal not displayed */
	// If set, the desired max number of partitions. Spanner doesn't guarantee to
	// respect this value.
	MaxPartitionCount *int64 `protobuf:"varint,4,opt,name=max_partition_count,json=maxPartitionCount,proto3,oneof" json:"max_partition_count,omitempty"`
	// contains filtered or unexported fields
}

Generate database partitions for the given read. Successful outcomes will contain database partitions in the db_partition field.

func (*GenerateDbPartitionsForReadAction) Descriptor deprecated

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

Deprecated: Use GenerateDbPartitionsForReadAction.ProtoReflect.Descriptor instead.

func (*GenerateDbPartitionsForReadAction) GetDesiredBytesPerPartition

func (x *GenerateDbPartitionsForReadAction) GetDesiredBytesPerPartition() int64

func (*GenerateDbPartitionsForReadAction) GetMaxPartitionCount

func (x *GenerateDbPartitionsForReadAction) GetMaxPartitionCount() int64

func (*GenerateDbPartitionsForReadAction) GetRead

func (*GenerateDbPartitionsForReadAction) GetTable

func (*GenerateDbPartitionsForReadAction) ProtoMessage

func (*GenerateDbPartitionsForReadAction) ProtoMessage()

func (*GenerateDbPartitionsForReadAction) ProtoReflect

func (*GenerateDbPartitionsForReadAction) Reset

func (*GenerateDbPartitionsForReadAction) String

type GetCloudBackupAction

type GetCloudBackupAction struct {

	// Cloud project ID, e.g. "spanner-cloud-systest".
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Cloud instance ID (not path), e.g. "test-instance".
	InstanceId string `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// The id of the backup to get, e.g. "test-backup".
	BackupId string `protobuf:"bytes,3,opt,name=backup_id,json=backupId,proto3" json:"backup_id,omitempty"`
	// contains filtered or unexported fields
}

Action that gets a Cloud Spanner database backup.

func (*GetCloudBackupAction) Descriptor deprecated

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

Deprecated: Use GetCloudBackupAction.ProtoReflect.Descriptor instead.

func (*GetCloudBackupAction) GetBackupId

func (x *GetCloudBackupAction) GetBackupId() string

func (*GetCloudBackupAction) GetInstanceId

func (x *GetCloudBackupAction) GetInstanceId() string

func (*GetCloudBackupAction) GetProjectId

func (x *GetCloudBackupAction) GetProjectId() string

func (*GetCloudBackupAction) ProtoMessage

func (*GetCloudBackupAction) ProtoMessage()

func (*GetCloudBackupAction) ProtoReflect

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

func (*GetCloudBackupAction) Reset

func (x *GetCloudBackupAction) Reset()

func (*GetCloudBackupAction) String

func (x *GetCloudBackupAction) String() string

type GetCloudDatabaseAction

type GetCloudDatabaseAction struct {

	// Cloud project ID, e.g. "spanner-cloud-systest".
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Cloud instance ID (not path), e.g. "test-instance".
	InstanceId string `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// The id of the database to get, e.g. "db0".
	DatabaseId string `protobuf:"bytes,3,opt,name=database_id,json=databaseId,proto3" json:"database_id,omitempty"`
	// contains filtered or unexported fields
}

Action that gets a Cloud Spanner database.

func (*GetCloudDatabaseAction) Descriptor deprecated

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

Deprecated: Use GetCloudDatabaseAction.ProtoReflect.Descriptor instead.

func (*GetCloudDatabaseAction) GetDatabaseId

func (x *GetCloudDatabaseAction) GetDatabaseId() string

func (*GetCloudDatabaseAction) GetInstanceId

func (x *GetCloudDatabaseAction) GetInstanceId() string

func (*GetCloudDatabaseAction) GetProjectId

func (x *GetCloudDatabaseAction) GetProjectId() string

func (*GetCloudDatabaseAction) ProtoMessage

func (*GetCloudDatabaseAction) ProtoMessage()

func (*GetCloudDatabaseAction) ProtoReflect

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

func (*GetCloudDatabaseAction) Reset

func (x *GetCloudDatabaseAction) Reset()

func (*GetCloudDatabaseAction) String

func (x *GetCloudDatabaseAction) String() string

type GetCloudInstanceAction

type GetCloudInstanceAction struct {

	// Cloud project ID, e.g. "spanner-cloud-systest".
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Cloud instance ID (not path) to retrieve the instance from,
	// e.g. "test-instance".
	InstanceId string `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// contains filtered or unexported fields
}

Action that retrieves a Cloud Spanner instance.

func (*GetCloudInstanceAction) Descriptor deprecated

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

Deprecated: Use GetCloudInstanceAction.ProtoReflect.Descriptor instead.

func (*GetCloudInstanceAction) GetInstanceId

func (x *GetCloudInstanceAction) GetInstanceId() string

func (*GetCloudInstanceAction) GetProjectId

func (x *GetCloudInstanceAction) GetProjectId() string

func (*GetCloudInstanceAction) ProtoMessage

func (*GetCloudInstanceAction) ProtoMessage()

func (*GetCloudInstanceAction) ProtoReflect

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

func (*GetCloudInstanceAction) Reset

func (x *GetCloudInstanceAction) Reset()

func (*GetCloudInstanceAction) String

func (x *GetCloudInstanceAction) String() string

type GetCloudInstanceConfigAction

type GetCloudInstanceConfigAction struct {

	// Instance config ID (not path), e.g. "custom-config".
	InstanceConfigId string `protobuf:"bytes,1,opt,name=instance_config_id,json=instanceConfigId,proto3" json:"instance_config_id,omitempty"`
	// Cloud project ID, e.g. "spanner-cloud-systest".
	ProjectId string `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

Action that gets a user instance config.

func (*GetCloudInstanceConfigAction) Descriptor deprecated

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

Deprecated: Use GetCloudInstanceConfigAction.ProtoReflect.Descriptor instead.

func (*GetCloudInstanceConfigAction) GetInstanceConfigId

func (x *GetCloudInstanceConfigAction) GetInstanceConfigId() string

func (*GetCloudInstanceConfigAction) GetProjectId

func (x *GetCloudInstanceConfigAction) GetProjectId() string

func (*GetCloudInstanceConfigAction) ProtoMessage

func (*GetCloudInstanceConfigAction) ProtoMessage()

func (*GetCloudInstanceConfigAction) ProtoReflect

func (*GetCloudInstanceConfigAction) Reset

func (x *GetCloudInstanceConfigAction) Reset()

func (*GetCloudInstanceConfigAction) String

type GetOperationAction

type GetOperationAction struct {

	// The name of the operation resource.
	Operation string `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

Action that gets an operation.

func (*GetOperationAction) Descriptor deprecated

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

Deprecated: Use GetOperationAction.ProtoReflect.Descriptor instead.

func (*GetOperationAction) GetOperation

func (x *GetOperationAction) GetOperation() string

func (*GetOperationAction) ProtoMessage

func (*GetOperationAction) ProtoMessage()

func (*GetOperationAction) ProtoReflect

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

func (*GetOperationAction) Reset

func (x *GetOperationAction) Reset()

func (*GetOperationAction) String

func (x *GetOperationAction) String() string

type HeartbeatRecord

type HeartbeatRecord struct {

	// Timestamp for this heartbeat check.
	HeartbeatTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=heartbeat_time,json=heartbeatTime,proto3" json:"heartbeat_time,omitempty"`
	// contains filtered or unexported fields
}

ChangeStream heartbeat record.

func (*HeartbeatRecord) Descriptor deprecated

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

Deprecated: Use HeartbeatRecord.ProtoReflect.Descriptor instead.

func (*HeartbeatRecord) GetHeartbeatTime

func (x *HeartbeatRecord) GetHeartbeatTime() *timestamppb.Timestamp

func (*HeartbeatRecord) ProtoMessage

func (*HeartbeatRecord) ProtoMessage()

func (*HeartbeatRecord) ProtoReflect

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

func (*HeartbeatRecord) Reset

func (x *HeartbeatRecord) Reset()

func (*HeartbeatRecord) String

func (x *HeartbeatRecord) String() string

type KeyRange

type KeyRange struct {

	// "start" and "limit" must have the same number of key parts,
	// though they may name only a prefix of the table or index key.
	// The start key of this KeyRange.
	Start *ValueList `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	// The end key of this KeyRange.
	Limit *ValueList `protobuf:"bytes,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// "start" and "limit" type for this KeyRange.
	Type *KeyRange_Type `protobuf:"varint,3,opt,name=type,proto3,enum=google.spanner.executor.v1.KeyRange_Type,oneof" json:"type,omitempty"`
	// contains filtered or unexported fields
}

KeyRange represents a range of rows in a table or index.

A range has a start key and an end key. These keys can be open or closed, indicating if the range includes rows with that key.

Keys are represented by "ValueList", where the ith value in the list corresponds to the ith component of the table or index primary key.

func (*KeyRange) Descriptor deprecated

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

Deprecated: Use KeyRange.ProtoReflect.Descriptor instead.

func (*KeyRange) GetLimit

func (x *KeyRange) GetLimit() *ValueList

func (*KeyRange) GetStart

func (x *KeyRange) GetStart() *ValueList

func (*KeyRange) GetType

func (x *KeyRange) GetType() KeyRange_Type

func (*KeyRange) ProtoMessage

func (*KeyRange) ProtoMessage()

func (*KeyRange) ProtoReflect

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

func (*KeyRange) Reset

func (x *KeyRange) Reset()

func (*KeyRange) String

func (x *KeyRange) String() string

type KeyRange_Type

type KeyRange_Type int32

Type controls whether "start" and "limit" are open or closed. By default, "start" is closed, and "limit" is open.

const (
	// "TYPE_UNSPECIFIED" is equivalent to "CLOSED_OPEN".
	KeyRange_TYPE_UNSPECIFIED KeyRange_Type = 0
	// [start,limit]
	KeyRange_CLOSED_CLOSED KeyRange_Type = 1
	// [start,limit)
	KeyRange_CLOSED_OPEN KeyRange_Type = 2
	// (start,limit]
	KeyRange_OPEN_CLOSED KeyRange_Type = 3
	// (start,limit)
	KeyRange_OPEN_OPEN KeyRange_Type = 4
)

func (KeyRange_Type) Descriptor

func (KeyRange_Type) Enum

func (x KeyRange_Type) Enum() *KeyRange_Type

func (KeyRange_Type) EnumDescriptor deprecated

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

Deprecated: Use KeyRange_Type.Descriptor instead.

func (KeyRange_Type) Number

func (KeyRange_Type) String

func (x KeyRange_Type) String() string

func (KeyRange_Type) Type

type KeySet

type KeySet struct {

	// A list of specific keys. Entries in "keys" should have exactly as
	// many elements as there are columns in the primary or index key
	// with which this "KeySet" is used.
	Point []*ValueList `protobuf:"bytes,1,rep,name=point,proto3" json:"point,omitempty"`
	// A list of key ranges.
	Range []*KeyRange `protobuf:"bytes,2,rep,name=range,proto3" json:"range,omitempty"`
	// For convenience "all" can be set to "true" to indicate that this
	// "KeySet" matches all keys in the table or index. Note that any keys
	// specified in "keys" or "ranges" are only yielded once.
	All bool `protobuf:"varint,3,opt,name=all,proto3" json:"all,omitempty"`
	// contains filtered or unexported fields
}

KeySet defines a collection of Spanner keys and/or key ranges. All the keys are expected to be in the same table. The keys need not be sorted in any particular way.

func (*KeySet) Descriptor deprecated

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

Deprecated: Use KeySet.ProtoReflect.Descriptor instead.

func (*KeySet) GetAll

func (x *KeySet) GetAll() bool

func (*KeySet) GetPoint

func (x *KeySet) GetPoint() []*ValueList

func (*KeySet) GetRange

func (x *KeySet) GetRange() []*KeyRange

func (*KeySet) ProtoMessage

func (*KeySet) ProtoMessage()

func (*KeySet) ProtoReflect

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

func (*KeySet) Reset

func (x *KeySet) Reset()

func (*KeySet) String

func (x *KeySet) String() string

type ListCloudBackupOperationsAction

type ListCloudBackupOperationsAction struct {

	// Cloud project ID, e.g. "spanner-cloud-systest".
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Cloud instance ID (not path) to list backup operations from,
	// e.g. "test-instance".
	InstanceId string `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// A filter expression that filters what operations are returned in the
	// response.
	// The expression must specify the field name, a comparison operator,
	// and the value that you want to use for filtering.
	// Refer backup.proto.ListBackupOperationsRequest for detail.
	Filter string `protobuf:"bytes,3,opt,name=filter,proto3" json:"filter,omitempty"`
	// Number of backups to be returned in the response. If 0 or
	// less, defaults to the server's maximum allowed page size.
	PageSize int32 `protobuf:"varint,4,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// If non-empty, "page_token" should contain a next_page_token
	// from a previous ListBackupOperationsResponse to the same "parent"
	// and with the same "filter".
	PageToken string `protobuf:"bytes,5,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

Action that lists Cloud Spanner database backup operations.

func (*ListCloudBackupOperationsAction) Descriptor deprecated

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

Deprecated: Use ListCloudBackupOperationsAction.ProtoReflect.Descriptor instead.

func (*ListCloudBackupOperationsAction) GetFilter

func (x *ListCloudBackupOperationsAction) GetFilter() string

func (*ListCloudBackupOperationsAction) GetInstanceId

func (x *ListCloudBackupOperationsAction) GetInstanceId() string

func (*ListCloudBackupOperationsAction) GetPageSize

func (x *ListCloudBackupOperationsAction) GetPageSize() int32

func (*ListCloudBackupOperationsAction) GetPageToken

func (x *ListCloudBackupOperationsAction) GetPageToken() string

func (*ListCloudBackupOperationsAction) GetProjectId

func (x *ListCloudBackupOperationsAction) GetProjectId() string

func (*ListCloudBackupOperationsAction) ProtoMessage

func (*ListCloudBackupOperationsAction) ProtoMessage()

func (*ListCloudBackupOperationsAction) ProtoReflect

func (*ListCloudBackupOperationsAction) Reset

func (*ListCloudBackupOperationsAction) String

type ListCloudBackupsAction

type ListCloudBackupsAction struct {

	// Cloud project ID, e.g. "spanner-cloud-systest".
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Cloud instance ID (not path) to list backups from, e.g. "test-instance".
	InstanceId string `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// A filter expression that filters backups listed in the response.
	// The expression must specify the field name, a comparison operator,
	// and the value that you want to use for filtering.
	// Refer backup.proto.ListBackupsRequest for detail.
	Filter string `protobuf:"bytes,3,opt,name=filter,proto3" json:"filter,omitempty"`
	// Number of backups to be returned in the response. If 0 or
	// less, defaults to the server's maximum allowed page size.
	PageSize int32 `protobuf:"varint,4,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// If non-empty, "page_token" should contain a next_page_token
	// from a previous ListBackupsResponse to the same "parent"
	// and with the same "filter".
	PageToken string `protobuf:"bytes,5,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

Action that lists Cloud Spanner database backups.

func (*ListCloudBackupsAction) Descriptor deprecated

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

Deprecated: Use ListCloudBackupsAction.ProtoReflect.Descriptor instead.

func (*ListCloudBackupsAction) GetFilter

func (x *ListCloudBackupsAction) GetFilter() string

func (*ListCloudBackupsAction) GetInstanceId

func (x *ListCloudBackupsAction) GetInstanceId() string

func (*ListCloudBackupsAction) GetPageSize

func (x *ListCloudBackupsAction) GetPageSize() int32

func (*ListCloudBackupsAction) GetPageToken

func (x *ListCloudBackupsAction) GetPageToken() string

func (*ListCloudBackupsAction) GetProjectId

func (x *ListCloudBackupsAction) GetProjectId() string

func (*ListCloudBackupsAction) ProtoMessage

func (*ListCloudBackupsAction) ProtoMessage()

func (*ListCloudBackupsAction) ProtoReflect

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

func (*ListCloudBackupsAction) Reset

func (x *ListCloudBackupsAction) Reset()

func (*ListCloudBackupsAction) String

func (x *ListCloudBackupsAction) String() string

type ListCloudDatabaseOperationsAction

type ListCloudDatabaseOperationsAction struct {

	// Cloud project ID, e.g. "spanner-cloud-systest".
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Cloud instance ID (not path) to list database operations from,
	// e.g. "test-instance".
	InstanceId string `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// A filter expression that filters what operations are returned in the
	// response.
	// The expression must specify the field name, a comparison operator,
	// and the value that you want to use for filtering.
	// Refer spanner_database_admin.proto.ListDatabaseOperationsRequest for
	// detail.
	Filter string `protobuf:"bytes,3,opt,name=filter,proto3" json:"filter,omitempty"`
	// Number of databases to be returned in the response. If 0 or
	// less, defaults to the server's maximum allowed page size.
	PageSize int32 `protobuf:"varint,4,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// If non-empty, "page_token" should contain a next_page_token
	// from a previous ListDatabaseOperationsResponse to the same "parent"
	// and with the same "filter".
	PageToken string `protobuf:"bytes,5,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

Action that lists Cloud Spanner database operations.

func (*ListCloudDatabaseOperationsAction) Descriptor deprecated

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

Deprecated: Use ListCloudDatabaseOperationsAction.ProtoReflect.Descriptor instead.

func (*ListCloudDatabaseOperationsAction) GetFilter

func (*ListCloudDatabaseOperationsAction) GetInstanceId

func (x *ListCloudDatabaseOperationsAction) GetInstanceId() string

func (*ListCloudDatabaseOperationsAction) GetPageSize

func (x *ListCloudDatabaseOperationsAction) GetPageSize() int32

func (*ListCloudDatabaseOperationsAction) GetPageToken

func (x *ListCloudDatabaseOperationsAction) GetPageToken() string

func (*ListCloudDatabaseOperationsAction) GetProjectId

func (x *ListCloudDatabaseOperationsAction) GetProjectId() string

func (*ListCloudDatabaseOperationsAction) ProtoMessage

func (*ListCloudDatabaseOperationsAction) ProtoMessage()

func (*ListCloudDatabaseOperationsAction) ProtoReflect

func (*ListCloudDatabaseOperationsAction) Reset

func (*ListCloudDatabaseOperationsAction) String

type ListCloudDatabasesAction

type ListCloudDatabasesAction struct {

	// Cloud project ID, e.g. "spanner-cloud-systest".
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Cloud instance ID (not path) to list databases from, e.g. "test-instance".
	InstanceId string `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// Number of databases to be returned in the response. If 0 or
	// less, defaults to the server's maximum allowed page size.
	PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// If non-empty, "page_token" should contain a next_page_token
	// from a previous ListDatabasesResponse to the same "parent"
	// and with the same "filter".
	PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

Action that lists Cloud Spanner databases.

func (*ListCloudDatabasesAction) Descriptor deprecated

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

Deprecated: Use ListCloudDatabasesAction.ProtoReflect.Descriptor instead.

func (*ListCloudDatabasesAction) GetInstanceId

func (x *ListCloudDatabasesAction) GetInstanceId() string

func (*ListCloudDatabasesAction) GetPageSize

func (x *ListCloudDatabasesAction) GetPageSize() int32

func (*ListCloudDatabasesAction) GetPageToken

func (x *ListCloudDatabasesAction) GetPageToken() string

func (*ListCloudDatabasesAction) GetProjectId

func (x *ListCloudDatabasesAction) GetProjectId() string

func (*ListCloudDatabasesAction) ProtoMessage

func (*ListCloudDatabasesAction) ProtoMessage()

func (*ListCloudDatabasesAction) ProtoReflect

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

func (*ListCloudDatabasesAction) Reset

func (x *ListCloudDatabasesAction) Reset()

func (*ListCloudDatabasesAction) String

func (x *ListCloudDatabasesAction) String() string

type ListCloudInstanceConfigsAction

type ListCloudInstanceConfigsAction struct {

	// Cloud project ID, e.g. "spanner-cloud-systest".
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Number of instance configs to be returned in the response. If 0 or
	// less, defaults to the server's maximum allowed page size.
	PageSize *int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3,oneof" json:"page_size,omitempty"`
	// If non-empty, "page_token" should contain a next_page_token
	// from a previous ListInstanceConfigsResponse to the same "parent".
	PageToken *string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3,oneof" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

Action that lists user instance configs.

func (*ListCloudInstanceConfigsAction) Descriptor deprecated

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

Deprecated: Use ListCloudInstanceConfigsAction.ProtoReflect.Descriptor instead.

func (*ListCloudInstanceConfigsAction) GetPageSize

func (x *ListCloudInstanceConfigsAction) GetPageSize() int32

func (*ListCloudInstanceConfigsAction) GetPageToken

func (x *ListCloudInstanceConfigsAction) GetPageToken() string

func (*ListCloudInstanceConfigsAction) GetProjectId

func (x *ListCloudInstanceConfigsAction) GetProjectId() string

func (*ListCloudInstanceConfigsAction) ProtoMessage

func (*ListCloudInstanceConfigsAction) ProtoMessage()

func (*ListCloudInstanceConfigsAction) ProtoReflect

func (*ListCloudInstanceConfigsAction) Reset

func (x *ListCloudInstanceConfigsAction) Reset()

func (*ListCloudInstanceConfigsAction) String

type ListCloudInstancesAction

type ListCloudInstancesAction struct {

	// Cloud project ID, e.g. "spanner-cloud-systest".
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// A filter expression that filters what operations are returned in the
	// response.
	// The expression must specify the field name, a comparison operator,
	// and the value that you want to use for filtering.
	// Refer spanner_instance_admin.proto.ListInstancesRequest for
	// detail.
	Filter *string `protobuf:"bytes,2,opt,name=filter,proto3,oneof" json:"filter,omitempty"`
	// Number of instances to be returned in the response. If 0 or
	// less, defaults to the server's maximum allowed page size.
	PageSize *int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3,oneof" json:"page_size,omitempty"`
	// If non-empty, "page_token" should contain a next_page_token
	// from a previous ListInstancesResponse to the same "parent"
	// and with the same "filter".
	PageToken *string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3,oneof" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

Action that lists Cloud Spanner databases.

func (*ListCloudInstancesAction) Descriptor deprecated

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

Deprecated: Use ListCloudInstancesAction.ProtoReflect.Descriptor instead.

func (*ListCloudInstancesAction) GetFilter

func (x *ListCloudInstancesAction) GetFilter() string

func (*ListCloudInstancesAction) GetPageSize

func (x *ListCloudInstancesAction) GetPageSize() int32

func (*ListCloudInstancesAction) GetPageToken

func (x *ListCloudInstancesAction) GetPageToken() string

func (*ListCloudInstancesAction) GetProjectId

func (x *ListCloudInstancesAction) GetProjectId() string

func (*ListCloudInstancesAction) ProtoMessage

func (*ListCloudInstancesAction) ProtoMessage()

func (*ListCloudInstancesAction) ProtoReflect

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

func (*ListCloudInstancesAction) Reset

func (x *ListCloudInstancesAction) Reset()

func (*ListCloudInstancesAction) String

func (x *ListCloudInstancesAction) String() string

type MutationAction

type MutationAction struct {

	// Mods that contained in this mutation.
	Mod []*MutationAction_Mod `protobuf:"bytes,1,rep,name=mod,proto3" json:"mod,omitempty"`
	// contains filtered or unexported fields
}

A single mutation request.

func (*MutationAction) Descriptor deprecated

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

Deprecated: Use MutationAction.ProtoReflect.Descriptor instead.

func (*MutationAction) GetMod

func (x *MutationAction) GetMod() []*MutationAction_Mod

func (*MutationAction) ProtoMessage

func (*MutationAction) ProtoMessage()

func (*MutationAction) ProtoReflect

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

func (*MutationAction) Reset

func (x *MutationAction) Reset()

func (*MutationAction) String

func (x *MutationAction) String() string

type MutationAction_InsertArgs

type MutationAction_InsertArgs struct {

	// The names of the columns to be written.
	Column []string `protobuf:"bytes,1,rep,name=column,proto3" json:"column,omitempty"`
	// Type information for the "values" entries below.
	Type []*spannerpb.Type `protobuf:"bytes,2,rep,name=type,proto3" json:"type,omitempty"`
	// The values to be written.
	Values []*ValueList `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

Arguments to Insert, InsertOrUpdate, and Replace operations.

func (*MutationAction_InsertArgs) Descriptor deprecated

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

Deprecated: Use MutationAction_InsertArgs.ProtoReflect.Descriptor instead.

func (*MutationAction_InsertArgs) GetColumn

func (x *MutationAction_InsertArgs) GetColumn() []string

func (*MutationAction_InsertArgs) GetType

func (x *MutationAction_InsertArgs) GetType() []*spannerpb.Type

func (*MutationAction_InsertArgs) GetValues

func (x *MutationAction_InsertArgs) GetValues() []*ValueList

func (*MutationAction_InsertArgs) ProtoMessage

func (*MutationAction_InsertArgs) ProtoMessage()

func (*MutationAction_InsertArgs) ProtoReflect

func (*MutationAction_InsertArgs) Reset

func (x *MutationAction_InsertArgs) Reset()

func (*MutationAction_InsertArgs) String

func (x *MutationAction_InsertArgs) String() string

type MutationAction_Mod

type MutationAction_Mod struct {

	// The table to write.
	Table string `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// Exactly one of the remaining elements may be present.
	// Insert new rows into "table".
	Insert *MutationAction_InsertArgs `protobuf:"bytes,2,opt,name=insert,proto3" json:"insert,omitempty"`
	// Update columns stored in existing rows of "table".
	Update *MutationAction_UpdateArgs `protobuf:"bytes,3,opt,name=update,proto3" json:"update,omitempty"`
	// Insert or update existing rows of "table".
	InsertOrUpdate *MutationAction_InsertArgs `protobuf:"bytes,4,opt,name=insert_or_update,json=insertOrUpdate,proto3" json:"insert_or_update,omitempty"`
	// Replace existing rows of "table".
	Replace *MutationAction_InsertArgs `protobuf:"bytes,5,opt,name=replace,proto3" json:"replace,omitempty"`
	// Delete rows from "table".
	DeleteKeys *KeySet `protobuf:"bytes,6,opt,name=delete_keys,json=deleteKeys,proto3" json:"delete_keys,omitempty"`
	// contains filtered or unexported fields
}

Mod represents the write action that will be perform to a table. Each mod will specify exactly one action, from insert, update, insert_or_update, replace and delete.

func (*MutationAction_Mod) Descriptor deprecated

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

Deprecated: Use MutationAction_Mod.ProtoReflect.Descriptor instead.

func (*MutationAction_Mod) GetDeleteKeys

func (x *MutationAction_Mod) GetDeleteKeys() *KeySet

func (*MutationAction_Mod) GetInsert

func (*MutationAction_Mod) GetInsertOrUpdate

func (x *MutationAction_Mod) GetInsertOrUpdate() *MutationAction_InsertArgs

func (*MutationAction_Mod) GetReplace

func (*MutationAction_Mod) GetTable

func (x *MutationAction_Mod) GetTable() string

func (*MutationAction_Mod) GetUpdate

func (*MutationAction_Mod) ProtoMessage

func (*MutationAction_Mod) ProtoMessage()

func (*MutationAction_Mod) ProtoReflect

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

func (*MutationAction_Mod) Reset

func (x *MutationAction_Mod) Reset()

func (*MutationAction_Mod) String

func (x *MutationAction_Mod) String() string

type MutationAction_UpdateArgs

type MutationAction_UpdateArgs struct {

	// The columns to be updated. Identical to InsertArgs.column.
	Column []string `protobuf:"bytes,1,rep,name=column,proto3" json:"column,omitempty"`
	// Type information for "values". Identical to InsertArgs.type.
	Type []*spannerpb.Type `protobuf:"bytes,2,rep,name=type,proto3" json:"type,omitempty"`
	// The values to be updated. Identical to InsertArgs.values.
	Values []*ValueList `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

Arguments to Update.

func (*MutationAction_UpdateArgs) Descriptor deprecated

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

Deprecated: Use MutationAction_UpdateArgs.ProtoReflect.Descriptor instead.

func (*MutationAction_UpdateArgs) GetColumn

func (x *MutationAction_UpdateArgs) GetColumn() []string

func (*MutationAction_UpdateArgs) GetType

func (x *MutationAction_UpdateArgs) GetType() []*spannerpb.Type

func (*MutationAction_UpdateArgs) GetValues

func (x *MutationAction_UpdateArgs) GetValues() []*ValueList

func (*MutationAction_UpdateArgs) ProtoMessage

func (*MutationAction_UpdateArgs) ProtoMessage()

func (*MutationAction_UpdateArgs) ProtoReflect

func (*MutationAction_UpdateArgs) Reset

func (x *MutationAction_UpdateArgs) Reset()

func (*MutationAction_UpdateArgs) String

func (x *MutationAction_UpdateArgs) String() string

type OperationResponse

type OperationResponse struct {

	// List of operations returned by ListOperationsAction.
	ListedOperations []*longrunningpb.Operation `protobuf:"bytes,1,rep,name=listed_operations,json=listedOperations,proto3" json:"listed_operations,omitempty"`
	// "next_page_token" can be sent in a subsequent list action
	// to fetch more of the matching data.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// Operation returned by GetOperationAction.
	Operation *longrunningpb.Operation `protobuf:"bytes,3,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

OperationResponse contains results returned by operation related actions.

func (*OperationResponse) Descriptor deprecated

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

Deprecated: Use OperationResponse.ProtoReflect.Descriptor instead.

func (*OperationResponse) GetListedOperations

func (x *OperationResponse) GetListedOperations() []*longrunningpb.Operation

func (*OperationResponse) GetNextPageToken

func (x *OperationResponse) GetNextPageToken() string

func (*OperationResponse) GetOperation

func (x *OperationResponse) GetOperation() *longrunningpb.Operation

func (*OperationResponse) ProtoMessage

func (*OperationResponse) ProtoMessage()

func (*OperationResponse) ProtoReflect

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

func (*OperationResponse) Reset

func (x *OperationResponse) Reset()

func (*OperationResponse) String

func (x *OperationResponse) String() string

type PartitionedUpdateAction

type PartitionedUpdateAction struct {

	// Options for partitioned update.
	Options *PartitionedUpdateAction_ExecutePartitionedUpdateOptions `protobuf:"bytes,1,opt,name=options,proto3,oneof" json:"options,omitempty"`
	// Partitioned dml query.
	Update *QueryAction `protobuf:"bytes,2,opt,name=update,proto3" json:"update,omitempty"`
	// contains filtered or unexported fields
}

PartitionedUpdateAction defines an action to execute a partitioned DML which runs different partitions in parallel.

func (*PartitionedUpdateAction) Descriptor deprecated

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

Deprecated: Use PartitionedUpdateAction.ProtoReflect.Descriptor instead.

func (*PartitionedUpdateAction) GetOptions

func (*PartitionedUpdateAction) GetUpdate

func (x *PartitionedUpdateAction) GetUpdate() *QueryAction

func (*PartitionedUpdateAction) ProtoMessage

func (*PartitionedUpdateAction) ProtoMessage()

func (*PartitionedUpdateAction) ProtoReflect

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

func (*PartitionedUpdateAction) Reset

func (x *PartitionedUpdateAction) Reset()

func (*PartitionedUpdateAction) String

func (x *PartitionedUpdateAction) String() string

type PartitionedUpdateAction_ExecutePartitionedUpdateOptions

type PartitionedUpdateAction_ExecutePartitionedUpdateOptions struct {

	// RPC Priority
	RpcPriority *spannerpb.RequestOptions_Priority `` /* 148-byte string literal not displayed */
	// Transaction tag
	Tag *string `protobuf:"bytes,2,opt,name=tag,proto3,oneof" json:"tag,omitempty"`
	// contains filtered or unexported fields
}

func (*PartitionedUpdateAction_ExecutePartitionedUpdateOptions) Descriptor deprecated

Deprecated: Use PartitionedUpdateAction_ExecutePartitionedUpdateOptions.ProtoReflect.Descriptor instead.

func (*PartitionedUpdateAction_ExecutePartitionedUpdateOptions) GetRpcPriority

func (*PartitionedUpdateAction_ExecutePartitionedUpdateOptions) GetTag

func (*PartitionedUpdateAction_ExecutePartitionedUpdateOptions) ProtoMessage

func (*PartitionedUpdateAction_ExecutePartitionedUpdateOptions) ProtoReflect

func (*PartitionedUpdateAction_ExecutePartitionedUpdateOptions) Reset

func (*PartitionedUpdateAction_ExecutePartitionedUpdateOptions) String

type QueryAction

type QueryAction struct {

	// The SQL string.
	Sql string `protobuf:"bytes,1,opt,name=sql,proto3" json:"sql,omitempty"`
	// Parameters for the SQL string.
	Params []*QueryAction_Parameter `protobuf:"bytes,2,rep,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

A SQL query request.

func (*QueryAction) Descriptor deprecated

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

Deprecated: Use QueryAction.ProtoReflect.Descriptor instead.

func (*QueryAction) GetParams

func (x *QueryAction) GetParams() []*QueryAction_Parameter

func (*QueryAction) GetSql

func (x *QueryAction) GetSql() string

func (*QueryAction) ProtoMessage

func (*QueryAction) ProtoMessage()

func (*QueryAction) ProtoReflect

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

func (*QueryAction) Reset

func (x *QueryAction) Reset()

func (*QueryAction) String

func (x *QueryAction) String() string

type QueryAction_Parameter

type QueryAction_Parameter struct {

	// Name of the parameter (with no leading @).
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Type of the parameter.
	Type *spannerpb.Type `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// Value of the parameter.
	Value *Value `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Parameter that bind to placeholders in the SQL string

func (*QueryAction_Parameter) Descriptor deprecated

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

Deprecated: Use QueryAction_Parameter.ProtoReflect.Descriptor instead.

func (*QueryAction_Parameter) GetName

func (x *QueryAction_Parameter) GetName() string

func (*QueryAction_Parameter) GetType

func (x *QueryAction_Parameter) GetType() *spannerpb.Type

func (*QueryAction_Parameter) GetValue

func (x *QueryAction_Parameter) GetValue() *Value

func (*QueryAction_Parameter) ProtoMessage

func (*QueryAction_Parameter) ProtoMessage()

func (*QueryAction_Parameter) ProtoReflect

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

func (*QueryAction_Parameter) Reset

func (x *QueryAction_Parameter) Reset()

func (*QueryAction_Parameter) String

func (x *QueryAction_Parameter) String() string

type QueryResult

type QueryResult struct {

	// Rows read. Each row is a struct with multiple fields, one for each column
	// in read result. All rows have the same type.
	Row []*ValueList `protobuf:"bytes,1,rep,name=row,proto3" json:"row,omitempty"`
	// The type of rows read. It must be set if at least one row was read.
	RowType *spannerpb.StructType `protobuf:"bytes,2,opt,name=row_type,json=rowType,proto3,oneof" json:"row_type,omitempty"`
	// contains filtered or unexported fields
}

QueryResult contains result of a Query.

func (*QueryResult) Descriptor deprecated

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

Deprecated: Use QueryResult.ProtoReflect.Descriptor instead.

func (*QueryResult) GetRow

func (x *QueryResult) GetRow() []*ValueList

func (*QueryResult) GetRowType

func (x *QueryResult) GetRowType() *spannerpb.StructType

func (*QueryResult) ProtoMessage

func (*QueryResult) ProtoMessage()

func (*QueryResult) ProtoReflect

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

func (*QueryResult) Reset

func (x *QueryResult) Reset()

func (*QueryResult) String

func (x *QueryResult) String() string

type ReadAction

type ReadAction struct {

	// The table to read at.
	Table string `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// The index to read at if it's an index read.
	Index *string `protobuf:"bytes,2,opt,name=index,proto3,oneof" json:"index,omitempty"`
	// List of columns must begin with the key columns used for the read.
	Column []string `protobuf:"bytes,3,rep,name=column,proto3" json:"column,omitempty"`
	// Keys for performing this read.
	Keys *KeySet `protobuf:"bytes,4,opt,name=keys,proto3" json:"keys,omitempty"`
	// Limit on number of rows to read. If set, must be positive.
	Limit int32 `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

A single read request.

func (*ReadAction) Descriptor deprecated

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

Deprecated: Use ReadAction.ProtoReflect.Descriptor instead.

func (*ReadAction) GetColumn

func (x *ReadAction) GetColumn() []string

func (*ReadAction) GetIndex

func (x *ReadAction) GetIndex() string

func (*ReadAction) GetKeys

func (x *ReadAction) GetKeys() *KeySet

func (*ReadAction) GetLimit

func (x *ReadAction) GetLimit() int32

func (*ReadAction) GetTable

func (x *ReadAction) GetTable() string

func (*ReadAction) ProtoMessage

func (*ReadAction) ProtoMessage()

func (*ReadAction) ProtoReflect

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

func (*ReadAction) Reset

func (x *ReadAction) Reset()

func (*ReadAction) String

func (x *ReadAction) String() string

type ReadResult

type ReadResult struct {

	// Table name.
	Table string `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// Index name, if read from an index.
	Index *string `protobuf:"bytes,2,opt,name=index,proto3,oneof" json:"index,omitempty"`
	// Request index (multiread only).
	RequestIndex *int32 `protobuf:"varint,3,opt,name=request_index,json=requestIndex,proto3,oneof" json:"request_index,omitempty"`
	// Rows read. Each row is a struct with multiple fields, one for each column
	// in read result. All rows have the same type.
	Row []*ValueList `protobuf:"bytes,4,rep,name=row,proto3" json:"row,omitempty"`
	// The type of rows read. It must be set if at least one row was read.
	RowType *spannerpb.StructType `protobuf:"bytes,5,opt,name=row_type,json=rowType,proto3,oneof" json:"row_type,omitempty"`
	// contains filtered or unexported fields
}

ReadResult contains rows read.

func (*ReadResult) Descriptor deprecated

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

Deprecated: Use ReadResult.ProtoReflect.Descriptor instead.

func (*ReadResult) GetIndex

func (x *ReadResult) GetIndex() string

func (*ReadResult) GetRequestIndex

func (x *ReadResult) GetRequestIndex() int32

func (*ReadResult) GetRow

func (x *ReadResult) GetRow() []*ValueList

func (*ReadResult) GetRowType

func (x *ReadResult) GetRowType() *spannerpb.StructType

func (*ReadResult) GetTable

func (x *ReadResult) GetTable() string

func (*ReadResult) ProtoMessage

func (*ReadResult) ProtoMessage()

func (*ReadResult) ProtoReflect

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

func (*ReadResult) Reset

func (x *ReadResult) Reset()

func (*ReadResult) String

func (x *ReadResult) String() string

type RestoreCloudDatabaseAction

type RestoreCloudDatabaseAction struct {

	// Cloud project ID, e.g. "spanner-cloud-systest".
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Cloud instance ID (not path) containing the backup, e.g. "backup-instance".
	BackupInstanceId string `protobuf:"bytes,2,opt,name=backup_instance_id,json=backupInstanceId,proto3" json:"backup_instance_id,omitempty"`
	// The id of the backup from which to restore, e.g. "test-backup".
	BackupId string `protobuf:"bytes,3,opt,name=backup_id,json=backupId,proto3" json:"backup_id,omitempty"`
	// Cloud instance ID (not path) containing the database, e.g.
	// "database-instance".
	DatabaseInstanceId string `protobuf:"bytes,4,opt,name=database_instance_id,json=databaseInstanceId,proto3" json:"database_instance_id,omitempty"`
	// The id of the database to create and restore to, e.g. "db0". Note that this
	// database must not already exist.
	DatabaseId string `protobuf:"bytes,5,opt,name=database_id,json=databaseId,proto3" json:"database_id,omitempty"`
	// contains filtered or unexported fields
}

Action that restores a Cloud Spanner database from a backup.

func (*RestoreCloudDatabaseAction) Descriptor deprecated

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

Deprecated: Use RestoreCloudDatabaseAction.ProtoReflect.Descriptor instead.

func (*RestoreCloudDatabaseAction) GetBackupId

func (x *RestoreCloudDatabaseAction) GetBackupId() string

func (*RestoreCloudDatabaseAction) GetBackupInstanceId

func (x *RestoreCloudDatabaseAction) GetBackupInstanceId() string

func (*RestoreCloudDatabaseAction) GetDatabaseId

func (x *RestoreCloudDatabaseAction) GetDatabaseId() string

func (*RestoreCloudDatabaseAction) GetDatabaseInstanceId

func (x *RestoreCloudDatabaseAction) GetDatabaseInstanceId() string

func (*RestoreCloudDatabaseAction) GetProjectId

func (x *RestoreCloudDatabaseAction) GetProjectId() string

func (*RestoreCloudDatabaseAction) ProtoMessage

func (*RestoreCloudDatabaseAction) ProtoMessage()

func (*RestoreCloudDatabaseAction) ProtoReflect

func (*RestoreCloudDatabaseAction) Reset

func (x *RestoreCloudDatabaseAction) Reset()

func (*RestoreCloudDatabaseAction) String

func (x *RestoreCloudDatabaseAction) String() string

type SpannerAction

type SpannerAction struct {

	// Database against which to perform action.
	// In a context where a series of actions take place, an action may omit
	// database path if it applies to the same database as the previous action.
	DatabasePath string `protobuf:"bytes,1,opt,name=database_path,json=databasePath,proto3" json:"database_path,omitempty"`
	// Action represents a spanner action kind, there will only be one action kind
	// per SpannerAction.
	//
	// Types that are assignable to Action:
	//
	//	*SpannerAction_Start
	//	*SpannerAction_Finish
	//	*SpannerAction_Read
	//	*SpannerAction_Query
	//	*SpannerAction_Mutation
	//	*SpannerAction_Dml
	//	*SpannerAction_BatchDml
	//	*SpannerAction_Write
	//	*SpannerAction_PartitionedUpdate
	//	*SpannerAction_Admin
	//	*SpannerAction_StartBatchTxn
	//	*SpannerAction_CloseBatchTxn
	//	*SpannerAction_GenerateDbPartitionsRead
	//	*SpannerAction_GenerateDbPartitionsQuery
	//	*SpannerAction_ExecutePartition
	//	*SpannerAction_ExecuteChangeStreamQuery
	Action isSpannerAction_Action `protobuf_oneof:"action"`
	// contains filtered or unexported fields
}

SpannerAction defines a primitive action that can be performed against Spanner, such as begin or commit a transaction, or perform a read or mutation.

func (*SpannerAction) Descriptor deprecated

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

Deprecated: Use SpannerAction.ProtoReflect.Descriptor instead.

func (*SpannerAction) GetAction

func (m *SpannerAction) GetAction() isSpannerAction_Action

func (*SpannerAction) GetAdmin

func (x *SpannerAction) GetAdmin() *AdminAction

func (*SpannerAction) GetBatchDml

func (x *SpannerAction) GetBatchDml() *BatchDmlAction

func (*SpannerAction) GetCloseBatchTxn

func (x *SpannerAction) GetCloseBatchTxn() *CloseBatchTransactionAction

func (*SpannerAction) GetDatabasePath

func (x *SpannerAction) GetDatabasePath() string

func (*SpannerAction) GetDml

func (x *SpannerAction) GetDml() *DmlAction

func (*SpannerAction) GetExecuteChangeStreamQuery

func (x *SpannerAction) GetExecuteChangeStreamQuery() *ExecuteChangeStreamQuery

func (*SpannerAction) GetExecutePartition

func (x *SpannerAction) GetExecutePartition() *ExecutePartitionAction

func (*SpannerAction) GetFinish

func (x *SpannerAction) GetFinish() *FinishTransactionAction

func (*SpannerAction) GetGenerateDbPartitionsQuery

func (x *SpannerAction) GetGenerateDbPartitionsQuery() *GenerateDbPartitionsForQueryAction

func (*SpannerAction) GetGenerateDbPartitionsRead

func (x *SpannerAction) GetGenerateDbPartitionsRead() *GenerateDbPartitionsForReadAction

func (*SpannerAction) GetMutation

func (x *SpannerAction) GetMutation() *MutationAction

func (*SpannerAction) GetPartitionedUpdate

func (x *SpannerAction) GetPartitionedUpdate() *PartitionedUpdateAction

func (*SpannerAction) GetQuery

func (x *SpannerAction) GetQuery() *QueryAction

func (*SpannerAction) GetRead

func (x *SpannerAction) GetRead() *ReadAction

func (*SpannerAction) GetStart

func (x *SpannerAction) GetStart() *StartTransactionAction

func (*SpannerAction) GetStartBatchTxn

func (x *SpannerAction) GetStartBatchTxn() *StartBatchTransactionAction

func (*SpannerAction) GetWrite

func (x *SpannerAction) GetWrite() *WriteMutationsAction

func (*SpannerAction) ProtoMessage

func (*SpannerAction) ProtoMessage()

func (*SpannerAction) ProtoReflect

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

func (*SpannerAction) Reset

func (x *SpannerAction) Reset()

func (*SpannerAction) String

func (x *SpannerAction) String() string

type SpannerActionOutcome

type SpannerActionOutcome struct {

	// If an outcome is split into multiple parts, status will be set only in the
	// last part.
	Status *status.Status `protobuf:"bytes,1,opt,name=status,proto3,oneof" json:"status,omitempty"`
	// Transaction timestamp. It must be set for successful committed actions.
	CommitTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=commit_time,json=commitTime,proto3,oneof" json:"commit_time,omitempty"`
	// Result of a ReadAction. This field must be set for ReadActions even if
	// no rows were read.
	ReadResult *ReadResult `protobuf:"bytes,3,opt,name=read_result,json=readResult,proto3,oneof" json:"read_result,omitempty"`
	// Result of a Query. This field must be set for Queries even if no rows were
	// read.
	QueryResult *QueryResult `protobuf:"bytes,4,opt,name=query_result,json=queryResult,proto3,oneof" json:"query_result,omitempty"`
	// This bit indicates that Spanner has restarted the current transaction. It
	// means that the client should replay all the reads and writes.
	// Setting it to true is only valid in the context of a read-write
	// transaction, as an outcome of a committing FinishTransactionAction.
	TransactionRestarted *bool `` /* 128-byte string literal not displayed */
	// In successful StartBatchTransactionAction outcomes, this contains the ID of
	// the transaction.
	BatchTxnId []byte `protobuf:"bytes,6,opt,name=batch_txn_id,json=batchTxnId,proto3,oneof" json:"batch_txn_id,omitempty"`
	// Generated database partitions (result of a
	// GenetageDbPartitionsForReadAction/GenerateDbPartitionsForQueryAction).
	DbPartition []*BatchPartition `protobuf:"bytes,7,rep,name=db_partition,json=dbPartition,proto3" json:"db_partition,omitempty"`
	// Result of admin related actions.
	AdminResult *AdminResult `protobuf:"bytes,8,opt,name=admin_result,json=adminResult,proto3,oneof" json:"admin_result,omitempty"`
	// Stores rows modified by query in single DML or batch DML action.
	// In case of batch DML action, stores 0 as row count of errored DML query.
	DmlRowsModified []int64 `protobuf:"varint,9,rep,packed,name=dml_rows_modified,json=dmlRowsModified,proto3" json:"dml_rows_modified,omitempty"`
	// Change stream records returned by a change stream query.
	ChangeStreamRecords []*ChangeStreamRecord `protobuf:"bytes,10,rep,name=change_stream_records,json=changeStreamRecords,proto3" json:"change_stream_records,omitempty"`
	// contains filtered or unexported fields
}

SpannerActionOutcome defines a result of execution of a single SpannerAction.

func (*SpannerActionOutcome) Descriptor deprecated

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

Deprecated: Use SpannerActionOutcome.ProtoReflect.Descriptor instead.

func (*SpannerActionOutcome) GetAdminResult

func (x *SpannerActionOutcome) GetAdminResult() *AdminResult

func (*SpannerActionOutcome) GetBatchTxnId

func (x *SpannerActionOutcome) GetBatchTxnId() []byte

func (*SpannerActionOutcome) GetChangeStreamRecords

func (x *SpannerActionOutcome) GetChangeStreamRecords() []*ChangeStreamRecord

func (*SpannerActionOutcome) GetCommitTime

func (x *SpannerActionOutcome) GetCommitTime() *timestamppb.Timestamp

func (*SpannerActionOutcome) GetDbPartition

func (x *SpannerActionOutcome) GetDbPartition() []*BatchPartition

func (*SpannerActionOutcome) GetDmlRowsModified

func (x *SpannerActionOutcome) GetDmlRowsModified() []int64

func (*SpannerActionOutcome) GetQueryResult

func (x *SpannerActionOutcome) GetQueryResult() *QueryResult

func (*SpannerActionOutcome) GetReadResult

func (x *SpannerActionOutcome) GetReadResult() *ReadResult

func (*SpannerActionOutcome) GetStatus

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

func (*SpannerActionOutcome) GetTransactionRestarted

func (x *SpannerActionOutcome) GetTransactionRestarted() bool

func (*SpannerActionOutcome) ProtoMessage

func (*SpannerActionOutcome) ProtoMessage()

func (*SpannerActionOutcome) ProtoReflect

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

func (*SpannerActionOutcome) Reset

func (x *SpannerActionOutcome) Reset()

func (*SpannerActionOutcome) String

func (x *SpannerActionOutcome) String() string

type SpannerAction_Admin

type SpannerAction_Admin struct {
	// Action that contains any administrative operation, like database,
	// instance manipulation.
	Admin *AdminAction `protobuf:"bytes,30,opt,name=admin,proto3,oneof"`
}

type SpannerAction_BatchDml

type SpannerAction_BatchDml struct {
	// Action to a batch DML.
	BatchDml *BatchDmlAction `protobuf:"bytes,24,opt,name=batch_dml,json=batchDml,proto3,oneof"`
}

type SpannerAction_CloseBatchTxn

type SpannerAction_CloseBatchTxn struct {
	// Action to close a batch transaction.
	CloseBatchTxn *CloseBatchTransactionAction `protobuf:"bytes,41,opt,name=close_batch_txn,json=closeBatchTxn,proto3,oneof"`
}

type SpannerAction_Dml

type SpannerAction_Dml struct {
	// Action to a DML.
	Dml *DmlAction `protobuf:"bytes,23,opt,name=dml,proto3,oneof"`
}

type SpannerAction_ExecuteChangeStreamQuery

type SpannerAction_ExecuteChangeStreamQuery struct {
	// Action to execute change stream query.
	ExecuteChangeStreamQuery *ExecuteChangeStreamQuery `protobuf:"bytes,50,opt,name=execute_change_stream_query,json=executeChangeStreamQuery,proto3,oneof"`
}

type SpannerAction_ExecutePartition

type SpannerAction_ExecutePartition struct {
	// Action to execute batch actions on generated partitions.
	ExecutePartition *ExecutePartitionAction `protobuf:"bytes,44,opt,name=execute_partition,json=executePartition,proto3,oneof"`
}

type SpannerAction_Finish

type SpannerAction_Finish struct {
	// Action to finish a transaction.
	Finish *FinishTransactionAction `protobuf:"bytes,11,opt,name=finish,proto3,oneof"`
}

type SpannerAction_GenerateDbPartitionsQuery

type SpannerAction_GenerateDbPartitionsQuery struct {
	// Action to generate database partitions for batch query.
	GenerateDbPartitionsQuery *GenerateDbPartitionsForQueryAction `protobuf:"bytes,43,opt,name=generate_db_partitions_query,json=generateDbPartitionsQuery,proto3,oneof"`
}

type SpannerAction_GenerateDbPartitionsRead

type SpannerAction_GenerateDbPartitionsRead struct {
	// Action to generate database partitions for batch read.
	GenerateDbPartitionsRead *GenerateDbPartitionsForReadAction `protobuf:"bytes,42,opt,name=generate_db_partitions_read,json=generateDbPartitionsRead,proto3,oneof"`
}

type SpannerAction_Mutation

type SpannerAction_Mutation struct {
	// Action to buffer a mutation.
	Mutation *MutationAction `protobuf:"bytes,22,opt,name=mutation,proto3,oneof"`
}

type SpannerAction_PartitionedUpdate

type SpannerAction_PartitionedUpdate struct {
	// Action to a partitioned update.
	PartitionedUpdate *PartitionedUpdateAction `protobuf:"bytes,27,opt,name=partitioned_update,json=partitionedUpdate,proto3,oneof"`
}

type SpannerAction_Query

type SpannerAction_Query struct {
	// Action to do a query.
	Query *QueryAction `protobuf:"bytes,21,opt,name=query,proto3,oneof"`
}

type SpannerAction_Read

type SpannerAction_Read struct {
	// Action to do a normal read.
	Read *ReadAction `protobuf:"bytes,20,opt,name=read,proto3,oneof"`
}

type SpannerAction_Start

type SpannerAction_Start struct {
	// Action to start a transaction.
	Start *StartTransactionAction `protobuf:"bytes,10,opt,name=start,proto3,oneof"`
}

type SpannerAction_StartBatchTxn

type SpannerAction_StartBatchTxn struct {
	// Action to start a batch transaction.
	StartBatchTxn *StartBatchTransactionAction `protobuf:"bytes,40,opt,name=start_batch_txn,json=startBatchTxn,proto3,oneof"`
}

type SpannerAction_Write

type SpannerAction_Write struct {
	// Action to write a mutation.
	Write *WriteMutationsAction `protobuf:"bytes,25,opt,name=write,proto3,oneof"`
}

type SpannerAsyncActionRequest

type SpannerAsyncActionRequest struct {

	// Action id to uniquely identify this action request.
	ActionId int32 `protobuf:"varint,1,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
	// The actual SpannerAction to perform.
	Action *SpannerAction `protobuf:"bytes,2,opt,name=action,proto3" json:"action,omitempty"`
	// contains filtered or unexported fields
}

Request to executor service that start a new Spanner action.

func (*SpannerAsyncActionRequest) Descriptor deprecated

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

Deprecated: Use SpannerAsyncActionRequest.ProtoReflect.Descriptor instead.

func (*SpannerAsyncActionRequest) GetAction

func (x *SpannerAsyncActionRequest) GetAction() *SpannerAction

func (*SpannerAsyncActionRequest) GetActionId

func (x *SpannerAsyncActionRequest) GetActionId() int32

func (*SpannerAsyncActionRequest) ProtoMessage

func (*SpannerAsyncActionRequest) ProtoMessage()

func (*SpannerAsyncActionRequest) ProtoReflect

func (*SpannerAsyncActionRequest) Reset

func (x *SpannerAsyncActionRequest) Reset()

func (*SpannerAsyncActionRequest) String

func (x *SpannerAsyncActionRequest) String() string

type SpannerAsyncActionResponse

type SpannerAsyncActionResponse struct {

	// Action id corresponds to the request.
	ActionId int32 `protobuf:"varint,1,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
	// If action results are split into multiple responses, only the last response
	// can and should contain status.
	Outcome *SpannerActionOutcome `protobuf:"bytes,2,opt,name=outcome,proto3" json:"outcome,omitempty"`
	// contains filtered or unexported fields
}

Response from executor service.

func (*SpannerAsyncActionResponse) Descriptor deprecated

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

Deprecated: Use SpannerAsyncActionResponse.ProtoReflect.Descriptor instead.

func (*SpannerAsyncActionResponse) GetActionId

func (x *SpannerAsyncActionResponse) GetActionId() int32

func (*SpannerAsyncActionResponse) GetOutcome

func (*SpannerAsyncActionResponse) ProtoMessage

func (*SpannerAsyncActionResponse) ProtoMessage()

func (*SpannerAsyncActionResponse) ProtoReflect

func (*SpannerAsyncActionResponse) Reset

func (x *SpannerAsyncActionResponse) Reset()

func (*SpannerAsyncActionResponse) String

func (x *SpannerAsyncActionResponse) String() string

type SpannerExecutorProxyClient

type SpannerExecutorProxyClient interface {
	// ExecuteActionAsync is a streaming call that starts executing a new Spanner
	// action.
	//
	// For each request, the server will reply with one or more responses, but
	// only the last response will contain status in the outcome.
	//
	// Responses can be matched to requests by action_id. It is allowed to have
	// multiple actions in flight--in that case, actions are be executed in
	// parallel.
	ExecuteActionAsync(ctx context.Context, opts ...grpc.CallOption) (SpannerExecutorProxy_ExecuteActionAsyncClient, error)
}

SpannerExecutorProxyClient is the client API for SpannerExecutorProxy service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

type SpannerExecutorProxyServer

type SpannerExecutorProxyServer interface {
	// ExecuteActionAsync is a streaming call that starts executing a new Spanner
	// action.
	//
	// For each request, the server will reply with one or more responses, but
	// only the last response will contain status in the outcome.
	//
	// Responses can be matched to requests by action_id. It is allowed to have
	// multiple actions in flight--in that case, actions are be executed in
	// parallel.
	ExecuteActionAsync(SpannerExecutorProxy_ExecuteActionAsyncServer) error
}

SpannerExecutorProxyServer is the server API for SpannerExecutorProxy service.

type SpannerExecutorProxy_ExecuteActionAsyncClient

type SpannerExecutorProxy_ExecuteActionAsyncClient interface {
	Send(*SpannerAsyncActionRequest) error
	Recv() (*SpannerAsyncActionResponse, error)
	grpc.ClientStream
}

type SpannerExecutorProxy_ExecuteActionAsyncServer

type SpannerExecutorProxy_ExecuteActionAsyncServer interface {
	Send(*SpannerAsyncActionResponse) error
	Recv() (*SpannerAsyncActionRequest, error)
	grpc.ServerStream
}

type StartBatchTransactionAction

type StartBatchTransactionAction struct {

	// To start a new transaction, specify an exact timestamp. Alternatively, an
	// existing batch transaction ID can be used. Either one of two must be
	// set.
	//
	// Types that are assignable to Param:
	//
	//	*StartBatchTransactionAction_BatchTxnTime
	//	*StartBatchTransactionAction_Tid
	Param isStartBatchTransactionAction_Param `protobuf_oneof:"param"`
	// Database role to assume while performing this action. Setting the
	// database_role will enforce additional role-based access checks on this
	// action.
	CloudDatabaseRole string `protobuf:"bytes,3,opt,name=cloud_database_role,json=cloudDatabaseRole,proto3" json:"cloud_database_role,omitempty"`
	// contains filtered or unexported fields
}

Starts a batch read-only transaction in executor. Successful outcomes of this action will contain batch_txn_id--the identificator that can be used to start the same transaction in other Executors to parallelize partition processing.

Example of a batch read flow: 1. Start batch transaction with a timestamp (StartBatchTransactionAction) 2. Generate database partitions for a read or query (GenerateDbPartitionsForReadAction/GenerateDbPartitionsForQueryAction) 3. Call ExecutePartitionAction for some or all partitions, process rows 4. Clean up the transaction (CloseBatchTransactionAction).

More sophisticated example, with parallel processing: 1. Start batch transaction with a timestamp (StartBatchTransactionAction), note the returned BatchTransactionId 2. Generate database partitions for a read or query (GenerateDbPartitionsForReadAction/GenerateDbPartitionsForQueryAction) 3. Distribute the partitions over a pool of workers, along with the transaction ID.

In each worker: 4-1. StartBatchTransactionAction with the given transaction ID 4-2. ExecutePartitionAction for each partition it got, process read results 4-3. Close (not cleanup) the transaction (CloseBatchTransactionAction).

When all workers are done: 5. Cleanup the transaction (CloseBatchTransactionAction). This can be done either by the last worker to finish the job, or by the main Executor that initialized this transaction in the first place. It is also possible to clean it up with a brand new Executor -- just execute StartBatchTransactionAction with the ID, then clean it up right away.

Cleaning up is optional, but recommended.

func (*StartBatchTransactionAction) Descriptor deprecated

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

Deprecated: Use StartBatchTransactionAction.ProtoReflect.Descriptor instead.

func (*StartBatchTransactionAction) GetBatchTxnTime

func (x *StartBatchTransactionAction) GetBatchTxnTime() *timestamppb.Timestamp

func (*StartBatchTransactionAction) GetCloudDatabaseRole

func (x *StartBatchTransactionAction) GetCloudDatabaseRole() string

func (*StartBatchTransactionAction) GetParam

func (m *StartBatchTransactionAction) GetParam() isStartBatchTransactionAction_Param

func (*StartBatchTransactionAction) GetTid

func (x *StartBatchTransactionAction) GetTid() []byte

func (*StartBatchTransactionAction) ProtoMessage

func (*StartBatchTransactionAction) ProtoMessage()

func (*StartBatchTransactionAction) ProtoReflect

func (*StartBatchTransactionAction) Reset

func (x *StartBatchTransactionAction) Reset()

func (*StartBatchTransactionAction) String

func (x *StartBatchTransactionAction) String() string

type StartBatchTransactionAction_BatchTxnTime

type StartBatchTransactionAction_BatchTxnTime struct {
	// The exact timestamp to start the batch transaction.
	BatchTxnTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=batch_txn_time,json=batchTxnTime,proto3,oneof"`
}

type StartBatchTransactionAction_Tid

type StartBatchTransactionAction_Tid struct {
	// ID of a batch read-only transaction. It can be used to start the same
	// batch transaction on multiple executors and parallelize partition
	// processing.
	Tid []byte `protobuf:"bytes,2,opt,name=tid,proto3,oneof"`
}

type StartTransactionAction

type StartTransactionAction struct {

	// Concurrency is for read-only transactions and must be omitted for
	// read-write transactions.
	Concurrency *Concurrency `protobuf:"bytes,1,opt,name=concurrency,proto3,oneof" json:"concurrency,omitempty"`
	// Metadata about tables and columns that will be involved in this
	// transaction. It is to convert values of key parts correctly.
	Table []*TableMetadata `protobuf:"bytes,2,rep,name=table,proto3" json:"table,omitempty"`
	// Transaction_seed contains workid and op pair for this transaction, used for
	// testing.
	TransactionSeed string `protobuf:"bytes,3,opt,name=transaction_seed,json=transactionSeed,proto3" json:"transaction_seed,omitempty"`
	// Execution options (e.g., whether transaction is opaque, optimistic).
	ExecutionOptions *TransactionExecutionOptions `protobuf:"bytes,4,opt,name=execution_options,json=executionOptions,proto3,oneof" json:"execution_options,omitempty"`
	// contains filtered or unexported fields
}

StartTransactionAction defines an action of initializing a transaction.

func (*StartTransactionAction) Descriptor deprecated

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

Deprecated: Use StartTransactionAction.ProtoReflect.Descriptor instead.

func (*StartTransactionAction) GetConcurrency

func (x *StartTransactionAction) GetConcurrency() *Concurrency

func (*StartTransactionAction) GetExecutionOptions

func (x *StartTransactionAction) GetExecutionOptions() *TransactionExecutionOptions

func (*StartTransactionAction) GetTable

func (x *StartTransactionAction) GetTable() []*TableMetadata

func (*StartTransactionAction) GetTransactionSeed

func (x *StartTransactionAction) GetTransactionSeed() string

func (*StartTransactionAction) ProtoMessage

func (*StartTransactionAction) ProtoMessage()

func (*StartTransactionAction) ProtoReflect

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

func (*StartTransactionAction) Reset

func (x *StartTransactionAction) Reset()

func (*StartTransactionAction) String

func (x *StartTransactionAction) String() string

type TableMetadata

type TableMetadata struct {

	// Table name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Columns, in the same order as in the schema.
	Column []*ColumnMetadata `protobuf:"bytes,2,rep,name=column,proto3" json:"column,omitempty"`
	// Keys, in order. Column name is currently not populated.
	KeyColumn []*ColumnMetadata `protobuf:"bytes,3,rep,name=key_column,json=keyColumn,proto3" json:"key_column,omitempty"`
	// contains filtered or unexported fields
}

TableMetadata contains metadata of a single table.

func (*TableMetadata) Descriptor deprecated

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

Deprecated: Use TableMetadata.ProtoReflect.Descriptor instead.

func (*TableMetadata) GetColumn

func (x *TableMetadata) GetColumn() []*ColumnMetadata

func (*TableMetadata) GetKeyColumn

func (x *TableMetadata) GetKeyColumn() []*ColumnMetadata

func (*TableMetadata) GetName

func (x *TableMetadata) GetName() string

func (*TableMetadata) ProtoMessage

func (*TableMetadata) ProtoMessage()

func (*TableMetadata) ProtoReflect

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

func (*TableMetadata) Reset

func (x *TableMetadata) Reset()

func (*TableMetadata) String

func (x *TableMetadata) String() string

type TransactionExecutionOptions

type TransactionExecutionOptions struct {

	// Whether optimistic concurrency should be used to execute this transaction.
	Optimistic bool `protobuf:"varint,1,opt,name=optimistic,proto3" json:"optimistic,omitempty"`
	// contains filtered or unexported fields
}

Options for executing the transaction.

func (*TransactionExecutionOptions) Descriptor deprecated

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

Deprecated: Use TransactionExecutionOptions.ProtoReflect.Descriptor instead.

func (*TransactionExecutionOptions) GetOptimistic

func (x *TransactionExecutionOptions) GetOptimistic() bool

func (*TransactionExecutionOptions) ProtoMessage

func (*TransactionExecutionOptions) ProtoMessage()

func (*TransactionExecutionOptions) ProtoReflect

func (*TransactionExecutionOptions) Reset

func (x *TransactionExecutionOptions) Reset()

func (*TransactionExecutionOptions) String

func (x *TransactionExecutionOptions) String() string

type UnimplementedSpannerExecutorProxyServer

type UnimplementedSpannerExecutorProxyServer struct {
}

UnimplementedSpannerExecutorProxyServer can be embedded to have forward compatible implementations.

func (*UnimplementedSpannerExecutorProxyServer) ExecuteActionAsync

type UpdateCloudBackupAction

type UpdateCloudBackupAction struct {

	// Cloud project ID, e.g. "spanner-cloud-systest".
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Cloud instance ID (not path), e.g. "test-instance".
	InstanceId string `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// The id of the backup to update, e.g. "test-backup".
	BackupId string `protobuf:"bytes,3,opt,name=backup_id,json=backupId,proto3" json:"backup_id,omitempty"`
	// Output only. Updated value of expire_time, this is the only field
	// that supported to be updated.
	ExpireTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=expire_time,json=expireTime,proto3" json:"expire_time,omitempty"`
	// contains filtered or unexported fields
}

Action that updates a Cloud Spanner database backup.

func (*UpdateCloudBackupAction) Descriptor deprecated

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

Deprecated: Use UpdateCloudBackupAction.ProtoReflect.Descriptor instead.

func (*UpdateCloudBackupAction) GetBackupId

func (x *UpdateCloudBackupAction) GetBackupId() string

func (*UpdateCloudBackupAction) GetExpireTime

func (x *UpdateCloudBackupAction) GetExpireTime() *timestamppb.Timestamp

func (*UpdateCloudBackupAction) GetInstanceId

func (x *UpdateCloudBackupAction) GetInstanceId() string

func (*UpdateCloudBackupAction) GetProjectId

func (x *UpdateCloudBackupAction) GetProjectId() string

func (*UpdateCloudBackupAction) ProtoMessage

func (*UpdateCloudBackupAction) ProtoMessage()

func (*UpdateCloudBackupAction) ProtoReflect

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

func (*UpdateCloudBackupAction) Reset

func (x *UpdateCloudBackupAction) Reset()

func (*UpdateCloudBackupAction) String

func (x *UpdateCloudBackupAction) String() string

type UpdateCloudDatabaseAction

type UpdateCloudDatabaseAction struct {

	// Cloud instance ID (not path), e.g. "test-instance".
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// Cloud project ID, e.g. "spanner-cloud-systest".
	ProjectId string `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Cloud database name (not full path), e.g. "db0".
	DatabaseName string `protobuf:"bytes,3,opt,name=database_name,json=databaseName,proto3" json:"database_name,omitempty"`
	// Updated value of enable_drop_protection, this is the only field that has
	// supported to be updated.
	EnableDropProtection bool `protobuf:"varint,4,opt,name=enable_drop_protection,json=enableDropProtection,proto3" json:"enable_drop_protection,omitempty"`
	// contains filtered or unexported fields
}

Action that updates a Cloud Spanner database.

func (*UpdateCloudDatabaseAction) Descriptor deprecated

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

Deprecated: Use UpdateCloudDatabaseAction.ProtoReflect.Descriptor instead.

func (*UpdateCloudDatabaseAction) GetDatabaseName

func (x *UpdateCloudDatabaseAction) GetDatabaseName() string

func (*UpdateCloudDatabaseAction) GetEnableDropProtection

func (x *UpdateCloudDatabaseAction) GetEnableDropProtection() bool

func (*UpdateCloudDatabaseAction) GetInstanceId

func (x *UpdateCloudDatabaseAction) GetInstanceId() string

func (*UpdateCloudDatabaseAction) GetProjectId

func (x *UpdateCloudDatabaseAction) GetProjectId() string

func (*UpdateCloudDatabaseAction) ProtoMessage

func (*UpdateCloudDatabaseAction) ProtoMessage()

func (*UpdateCloudDatabaseAction) ProtoReflect

func (*UpdateCloudDatabaseAction) Reset

func (x *UpdateCloudDatabaseAction) Reset()

func (*UpdateCloudDatabaseAction) String

func (x *UpdateCloudDatabaseAction) String() string

type UpdateCloudDatabaseDdlAction

type UpdateCloudDatabaseDdlAction struct {

	// Cloud instance ID (not path), e.g. "test-instance".
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// Cloud project ID, e.g. "spanner-cloud-systest".
	ProjectId string `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Cloud database ID (not full path), e.g. "db0".
	DatabaseId string `protobuf:"bytes,3,opt,name=database_id,json=databaseId,proto3" json:"database_id,omitempty"`
	// SDL statements to apply to the database.
	SdlStatement []string `protobuf:"bytes,4,rep,name=sdl_statement,json=sdlStatement,proto3" json:"sdl_statement,omitempty"`
	// Op ID can be used to track progress of the update. If set, it must be
	// unique per database. If not set, Cloud Spanner will generate operation ID
	// automatically.
	OperationId string `protobuf:"bytes,5,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
	// contains filtered or unexported fields
}

Action that updates the schema of a Cloud Spanner database.

func (*UpdateCloudDatabaseDdlAction) Descriptor deprecated

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

Deprecated: Use UpdateCloudDatabaseDdlAction.ProtoReflect.Descriptor instead.

func (*UpdateCloudDatabaseDdlAction) GetDatabaseId

func (x *UpdateCloudDatabaseDdlAction) GetDatabaseId() string

func (*UpdateCloudDatabaseDdlAction) GetInstanceId

func (x *UpdateCloudDatabaseDdlAction) GetInstanceId() string

func (*UpdateCloudDatabaseDdlAction) GetOperationId

func (x *UpdateCloudDatabaseDdlAction) GetOperationId() string

func (*UpdateCloudDatabaseDdlAction) GetProjectId

func (x *UpdateCloudDatabaseDdlAction) GetProjectId() string

func (*UpdateCloudDatabaseDdlAction) GetSdlStatement

func (x *UpdateCloudDatabaseDdlAction) GetSdlStatement() []string

func (*UpdateCloudDatabaseDdlAction) ProtoMessage

func (*UpdateCloudDatabaseDdlAction) ProtoMessage()

func (*UpdateCloudDatabaseDdlAction) ProtoReflect

func (*UpdateCloudDatabaseDdlAction) Reset

func (x *UpdateCloudDatabaseDdlAction) Reset()

func (*UpdateCloudDatabaseDdlAction) String

type UpdateCloudInstanceAction

type UpdateCloudInstanceAction struct {

	// Cloud instance ID (not path), e.g. "test-instance".
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// Cloud project ID, e.g. "spanner-cloud-systest".
	ProjectId string `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// The descriptive name for this instance as it appears in UIs.
	// Must be unique per project and between 4 and 30 characters in length.
	DisplayName *string `protobuf:"bytes,3,opt,name=display_name,json=displayName,proto3,oneof" json:"display_name,omitempty"`
	// The number of nodes allocated to this instance. At most one of either
	// node_count or processing_units should be present in the message.
	NodeCount *int32 `protobuf:"varint,4,opt,name=node_count,json=nodeCount,proto3,oneof" json:"node_count,omitempty"`
	// The number of processing units allocated to this instance. At most one of
	// processing_units or node_count should be present in the message.
	ProcessingUnits *int32 `protobuf:"varint,5,opt,name=processing_units,json=processingUnits,proto3,oneof" json:"processing_units,omitempty"`
	// labels.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

Action that updates a Cloud Spanner instance.

func (*UpdateCloudInstanceAction) Descriptor deprecated

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

Deprecated: Use UpdateCloudInstanceAction.ProtoReflect.Descriptor instead.

func (*UpdateCloudInstanceAction) GetDisplayName

func (x *UpdateCloudInstanceAction) GetDisplayName() string

func (*UpdateCloudInstanceAction) GetInstanceId

func (x *UpdateCloudInstanceAction) GetInstanceId() string

func (*UpdateCloudInstanceAction) GetLabels

func (x *UpdateCloudInstanceAction) GetLabels() map[string]string

func (*UpdateCloudInstanceAction) GetNodeCount

func (x *UpdateCloudInstanceAction) GetNodeCount() int32

func (*UpdateCloudInstanceAction) GetProcessingUnits

func (x *UpdateCloudInstanceAction) GetProcessingUnits() int32

func (*UpdateCloudInstanceAction) GetProjectId

func (x *UpdateCloudInstanceAction) GetProjectId() string

func (*UpdateCloudInstanceAction) ProtoMessage

func (*UpdateCloudInstanceAction) ProtoMessage()

func (*UpdateCloudInstanceAction) ProtoReflect

func (*UpdateCloudInstanceAction) Reset

func (x *UpdateCloudInstanceAction) Reset()

func (*UpdateCloudInstanceAction) String

func (x *UpdateCloudInstanceAction) String() string

type UpdateUserInstanceConfigAction

type UpdateUserInstanceConfigAction struct {

	// User instance config ID (not path), e.g. "custom-config".
	UserConfigId string `protobuf:"bytes,1,opt,name=user_config_id,json=userConfigId,proto3" json:"user_config_id,omitempty"`
	// Cloud project ID, e.g. "spanner-cloud-systest".
	ProjectId string `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// The descriptive name for this instance config as it appears in UIs.
	DisplayName *string `protobuf:"bytes,3,opt,name=display_name,json=displayName,proto3,oneof" json:"display_name,omitempty"`
	// labels.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

Action that updates a user instance config.

func (*UpdateUserInstanceConfigAction) Descriptor deprecated

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

Deprecated: Use UpdateUserInstanceConfigAction.ProtoReflect.Descriptor instead.

func (*UpdateUserInstanceConfigAction) GetDisplayName

func (x *UpdateUserInstanceConfigAction) GetDisplayName() string

func (*UpdateUserInstanceConfigAction) GetLabels

func (x *UpdateUserInstanceConfigAction) GetLabels() map[string]string

func (*UpdateUserInstanceConfigAction) GetProjectId

func (x *UpdateUserInstanceConfigAction) GetProjectId() string

func (*UpdateUserInstanceConfigAction) GetUserConfigId

func (x *UpdateUserInstanceConfigAction) GetUserConfigId() string

func (*UpdateUserInstanceConfigAction) ProtoMessage

func (*UpdateUserInstanceConfigAction) ProtoMessage()

func (*UpdateUserInstanceConfigAction) ProtoReflect

func (*UpdateUserInstanceConfigAction) Reset

func (x *UpdateUserInstanceConfigAction) Reset()

func (*UpdateUserInstanceConfigAction) String

type Value

type Value struct {

	// Exactly one of the following fields will be present.
	//
	// Types that are assignable to ValueType:
	//
	//	*Value_IsNull
	//	*Value_IntValue
	//	*Value_BoolValue
	//	*Value_DoubleValue
	//	*Value_BytesValue
	//	*Value_StringValue
	//	*Value_StructValue
	//	*Value_TimestampValue
	//	*Value_DateDaysValue
	//	*Value_IsCommitTimestamp
	//	*Value_ArrayValue
	ValueType isValue_ValueType `protobuf_oneof:"value_type"`
	// Type of array element. Only set if value is an array.
	ArrayType *spannerpb.Type `protobuf:"bytes,12,opt,name=array_type,json=arrayType,proto3,oneof" json:"array_type,omitempty"`
	// contains filtered or unexported fields
}

Value represents a single value that can be read or written to/from Spanner.

func (*Value) Descriptor deprecated

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

Deprecated: Use Value.ProtoReflect.Descriptor instead.

func (*Value) GetArrayType

func (x *Value) GetArrayType() *spannerpb.Type

func (*Value) GetArrayValue

func (x *Value) GetArrayValue() *ValueList

func (*Value) GetBoolValue

func (x *Value) GetBoolValue() bool

func (*Value) GetBytesValue

func (x *Value) GetBytesValue() []byte

func (*Value) GetDateDaysValue

func (x *Value) GetDateDaysValue() int32

func (*Value) GetDoubleValue

func (x *Value) GetDoubleValue() float64

func (*Value) GetIntValue

func (x *Value) GetIntValue() int64

func (*Value) GetIsCommitTimestamp

func (x *Value) GetIsCommitTimestamp() bool

func (*Value) GetIsNull

func (x *Value) GetIsNull() bool

func (*Value) GetStringValue

func (x *Value) GetStringValue() string

func (*Value) GetStructValue

func (x *Value) GetStructValue() *ValueList

func (*Value) GetTimestampValue

func (x *Value) GetTimestampValue() *timestamppb.Timestamp

func (*Value) GetValueType

func (m *Value) GetValueType() isValue_ValueType

func (*Value) ProtoMessage

func (*Value) ProtoMessage()

func (*Value) ProtoReflect

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

func (*Value) Reset

func (x *Value) Reset()

func (*Value) String

func (x *Value) String() string

type ValueList

type ValueList struct {

	// Values contained in this ValueList.
	Value []*Value `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

List of values.

func (*ValueList) Descriptor deprecated

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

Deprecated: Use ValueList.ProtoReflect.Descriptor instead.

func (*ValueList) GetValue

func (x *ValueList) GetValue() []*Value

func (*ValueList) ProtoMessage

func (*ValueList) ProtoMessage()

func (*ValueList) ProtoReflect

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

func (*ValueList) Reset

func (x *ValueList) Reset()

func (*ValueList) String

func (x *ValueList) String() string

type Value_ArrayValue

type Value_ArrayValue struct {
	// Array type value. The underlying Valuelist should have values that have
	// the same type.
	ArrayValue *ValueList `protobuf:"bytes,11,opt,name=array_value,json=arrayValue,proto3,oneof"`
}

type Value_BoolValue

type Value_BoolValue struct {
	// Bool type value.
	BoolValue bool `protobuf:"varint,3,opt,name=bool_value,json=boolValue,proto3,oneof"`
}

type Value_BytesValue

type Value_BytesValue struct {
	// Bytes type value, stored in CORD. It's also used for PROTO type value.
	BytesValue []byte `protobuf:"bytes,5,opt,name=bytes_value,json=bytesValue,proto3,oneof"`
}

type Value_DateDaysValue

type Value_DateDaysValue struct {
	// Date type value. Date is specified as a number of days since Unix epoch.
	DateDaysValue int32 `protobuf:"varint,9,opt,name=date_days_value,json=dateDaysValue,proto3,oneof"`
}

type Value_DoubleValue

type Value_DoubleValue struct {
	// Double type value. It's used for all float point types, like float and
	// double.
	DoubleValue float64 `protobuf:"fixed64,4,opt,name=double_value,json=doubleValue,proto3,oneof"`
}

type Value_IntValue

type Value_IntValue struct {
	// Int type value. It's used for all integer number types, like int32 and
	// int64.
	IntValue int64 `protobuf:"varint,2,opt,name=int_value,json=intValue,proto3,oneof"`
}

type Value_IsCommitTimestamp

type Value_IsCommitTimestamp struct {
	// If set, holds the sentinel value for the transaction CommitTimestamp.
	IsCommitTimestamp bool `protobuf:"varint,10,opt,name=is_commit_timestamp,json=isCommitTimestamp,proto3,oneof"`
}

type Value_IsNull

type Value_IsNull struct {
	// If is_null is set, then this value is null.
	IsNull bool `protobuf:"varint,1,opt,name=is_null,json=isNull,proto3,oneof"`
}

type Value_StringValue

type Value_StringValue struct {
	// String type value, stored in CORD.
	StringValue string `protobuf:"bytes,6,opt,name=string_value,json=stringValue,proto3,oneof"`
}

type Value_StructValue

type Value_StructValue struct {
	// Struct type value. It contains a ValueList representing the values in
	// this struct.
	StructValue *ValueList `protobuf:"bytes,7,opt,name=struct_value,json=structValue,proto3,oneof"`
}

type Value_TimestampValue

type Value_TimestampValue struct {
	// Timestamp type value.
	TimestampValue *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=timestamp_value,json=timestampValue,proto3,oneof"`
}

type WriteMutationsAction

type WriteMutationsAction struct {

	// The mutation to write.
	Mutation *MutationAction `protobuf:"bytes,1,opt,name=mutation,proto3" json:"mutation,omitempty"`
	// contains filtered or unexported fields
}

WriteMutationAction defines an action of flushing the mutation so they are visible to subsequent operations in the transaction.

func (*WriteMutationsAction) Descriptor deprecated

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

Deprecated: Use WriteMutationsAction.ProtoReflect.Descriptor instead.

func (*WriteMutationsAction) GetMutation

func (x *WriteMutationsAction) GetMutation() *MutationAction

func (*WriteMutationsAction) ProtoMessage

func (*WriteMutationsAction) ProtoMessage()

func (*WriteMutationsAction) ProtoReflect

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

func (*WriteMutationsAction) Reset

func (x *WriteMutationsAction) Reset()

func (*WriteMutationsAction) String

func (x *WriteMutationsAction) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL