executorpb

package
v1.64.0 Latest Latest
Warning

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

 Go to latest Published: Jul 1, 2024 License: Apache-2.0 Imports: 15 Imported by: 4

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_google_spanner_executor_v1_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
	//	*AdminAction_ChangeQuorumCloudDatabase
	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) GetChangeQuorumCloudDatabase added in v1.61.0 

func (x *AdminAction) GetChangeQuorumCloudDatabase() *ChangeQuorumCloudDatabaseAction

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_ChangeQuorumCloudDatabase added in v1.61.0 

type AdminAction_ChangeQuorumCloudDatabase struct {
	// Action that changes quorum of a Cloud Spanner database.
	ChangeQuorumCloudDatabase *ChangeQuorumCloudDatabaseAction `protobuf:"bytes,28,opt,name=change_quorum_cloud_database,json=changeQuorumCloudDatabase,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 ChangeQuorumCloudDatabaseAction added in v1.61.0 

type ChangeQuorumCloudDatabaseAction struct {

	// The fully qualified uri of the database whose quorum has to be changed.
	DatabaseUri *string `protobuf:"bytes,1,opt,name=database_uri,json=databaseUri,proto3,oneof" json:"database_uri,omitempty"`
	// The locations of the serving regions, e.g. "asia-south1".
	ServingLocations []string `protobuf:"bytes,2,rep,name=serving_locations,json=servingLocations,proto3" json:"serving_locations,omitempty"`
	// contains filtered or unexported fields
}

Action that changes quorum of a Cloud Spanner database.

func (*ChangeQuorumCloudDatabaseAction) Descriptor deprecated added in v1.61.0 

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

Deprecated: Use ChangeQuorumCloudDatabaseAction.ProtoReflect.Descriptor instead.

func (*ChangeQuorumCloudDatabaseAction) GetDatabaseUri added in v1.61.0 

func (x *ChangeQuorumCloudDatabaseAction) GetDatabaseUri() string

func (*ChangeQuorumCloudDatabaseAction) GetServingLocations added in v1.61.0 

func (x *ChangeQuorumCloudDatabaseAction) GetServingLocations() []string

func (*ChangeQuorumCloudDatabaseAction) ProtoMessage added in v1.61.0 

func (*ChangeQuorumCloudDatabaseAction) ProtoMessage()

func (*ChangeQuorumCloudDatabaseAction) ProtoReflect added in v1.61.0 

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

func (*ChangeQuorumCloudDatabaseAction) Reset added in v1.61.0 

func (x *ChangeQuorumCloudDatabaseAction) Reset()

func (*ChangeQuorumCloudDatabaseAction) String added in v1.61.0 

func (x *ChangeQuorumCloudDatabaseAction) 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 (x *ChildPartitionsRecord) GetChildPartitions() []*ChildPartitionsRecord_ChildPartition

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 (x *ChildPartitionsRecord_ChildPartition) GetToken() string

func (*ChildPartitionsRecord_ChildPartition) ProtoMessage 

func (*ChildPartitionsRecord_ChildPartition) ProtoMessage()

func (*ChildPartitionsRecord_ChildPartition) ProtoReflect 

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

func (*ChildPartitionsRecord_ChildPartition) Reset 

func (x *ChildPartitionsRecord_ChildPartition) Reset()

func (*ChildPartitionsRecord_ChildPartition) String 

func (x *ChildPartitionsRecord_ChildPartition) String() 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 (x *CloseBatchTransactionAction) ProtoReflect() protoreflect.Message

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 (x *CloudInstanceConfigResponse) ProtoReflect() protoreflect.Message

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"`
	// The KMS key(s) used to encrypt the backup to be created if the backup
	// should be CMEK protected.
	EncryptionConfig *databasepb.EncryptionConfig `protobuf:"bytes,7,opt,name=encryption_config,json=encryptionConfig,proto3" json:"encryption_config,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) GetEncryptionConfig added in v1.61.0 

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

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"`
	ProtoDescriptors []byte  `protobuf:"bytes,7,opt,name=proto_descriptors,json=protoDescriptors,proto3,oneof" json:"proto_descriptors,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) GetProtoDescriptors 

func (x *CreateCloudDatabaseAction) GetProtoDescriptors() []byte

func (*CreateCloudDatabaseAction) GetSdlStatement 

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

func (*CreateCloudDatabaseAction) ProtoMessage 

func (*CreateCloudDatabaseAction) ProtoMessage()

func (*CreateCloudDatabaseAction) ProtoReflect 

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

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"`
	// The autoscaling config for this instance. If non-empty, an autoscaling
	// instance will be created (processing_units and node_count should be set to
	// 0 if used).
	AutoscalingConfig *instancepb.AutoscalingConfig `protobuf:"bytes,7,opt,name=autoscaling_config,json=autoscalingConfig,proto3,oneof" json:"autoscaling_config,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) GetAutoscalingConfig 

func (x *CreateCloudInstanceAction) GetAutoscalingConfig() *instancepb.AutoscalingConfig

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 (x *CreateCloudInstanceAction) ProtoReflect() protoreflect.Message

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 (x *CreateUserInstanceConfigAction) GetReplicas() []*instancepb.ReplicaInfo

func (*CreateUserInstanceConfigAction) GetUserConfigId 

func (x *CreateUserInstanceConfigAction) GetUserConfigId() string

func (*CreateUserInstanceConfigAction) ProtoMessage 

func (*CreateUserInstanceConfigAction) ProtoMessage()

func (*CreateUserInstanceConfigAction) ProtoReflect 

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

func (*CreateUserInstanceConfigAction) Reset 

func (x *CreateUserInstanceConfigAction) Reset()

func (*CreateUserInstanceConfigAction) String 

func (x *CreateUserInstanceConfigAction) String() 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 (x *DataChangeRecord_ColumnType) ProtoReflect() protoreflect.Message

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 (x *DeleteCloudInstanceAction) ProtoReflect() protoreflect.Message

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 (x *DeleteUserInstanceConfigAction) ProtoReflect() protoreflect.Message

func (*DeleteUserInstanceConfigAction) Reset 

func (x *DeleteUserInstanceConfigAction) Reset()

func (*DeleteUserInstanceConfigAction) String 

func (x *DeleteUserInstanceConfigAction) String() 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 (x *ExecuteChangeStreamQuery) GetEndTime() *timestamppb.Timestamp

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 (x *FinishTransactionAction) GetMode() FinishTransactionAction_Mode

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) Descriptor() protoreflect.EnumDescriptor

func (FinishTransactionAction_Mode) Enum 

func (x FinishTransactionAction_Mode) Enum() *FinishTransactionAction_Mode

func (FinishTransactionAction_Mode) EnumDescriptor deprecated 

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

Deprecated: Use FinishTransactionAction_Mode.Descriptor instead.

func (FinishTransactionAction_Mode) Number 

func (x FinishTransactionAction_Mode) Number() protoreflect.EnumNumber

func (FinishTransactionAction_Mode) String 

func (x FinishTransactionAction_Mode) String() string

func (FinishTransactionAction_Mode) Type 

func (FinishTransactionAction_Mode) Type() protoreflect.EnumType

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 (x *GenerateDbPartitionsForQueryAction) GetQuery() *QueryAction

func (*GenerateDbPartitionsForQueryAction) ProtoMessage 

func (*GenerateDbPartitionsForQueryAction) ProtoMessage()

func (*GenerateDbPartitionsForQueryAction) ProtoReflect 

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

func (*GenerateDbPartitionsForQueryAction) Reset 

func (x *GenerateDbPartitionsForQueryAction) Reset()

func (*GenerateDbPartitionsForQueryAction) String 

func (x *GenerateDbPartitionsForQueryAction) String() 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 (x *GenerateDbPartitionsForReadAction) GetRead() *ReadAction

func (*GenerateDbPartitionsForReadAction) GetTable 

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

func (*GenerateDbPartitionsForReadAction) ProtoMessage 

func (*GenerateDbPartitionsForReadAction) ProtoMessage()

func (*GenerateDbPartitionsForReadAction) ProtoReflect 

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

func (*GenerateDbPartitionsForReadAction) Reset 

func (x *GenerateDbPartitionsForReadAction) Reset()

func (*GenerateDbPartitionsForReadAction) String 

func (x *GenerateDbPartitionsForReadAction) String() 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 (x *GetCloudInstanceConfigAction) ProtoReflect() protoreflect.Message

func (*GetCloudInstanceConfigAction) Reset 

func (x *GetCloudInstanceConfigAction) Reset()

func (*GetCloudInstanceConfigAction) String 

func (x *GetCloudInstanceConfigAction) String() 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) Descriptor() protoreflect.EnumDescriptor

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 (x KeyRange_Type) Number() protoreflect.EnumNumber

func (KeyRange_Type) String 

func (x KeyRange_Type) String() string

func (KeyRange_Type) Type 

func (KeyRange_Type) Type() protoreflect.EnumType

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 (x *ListCloudBackupOperationsAction) ProtoReflect() protoreflect.Message

func (*ListCloudBackupOperationsAction) Reset 

func (x *ListCloudBackupOperationsAction) Reset()

func (*ListCloudBackupOperationsAction) String 

func (x *ListCloudBackupOperationsAction) String() 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 (x *ListCloudDatabaseOperationsAction) GetFilter() string

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 (x *ListCloudDatabaseOperationsAction) ProtoReflect() protoreflect.Message

func (*ListCloudDatabaseOperationsAction) Reset 

func (x *ListCloudDatabaseOperationsAction) Reset()

func (*ListCloudDatabaseOperationsAction) String 

func (x *ListCloudDatabaseOperationsAction) String() 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 (x *ListCloudInstanceConfigsAction) ProtoReflect() protoreflect.Message

func (*ListCloudInstanceConfigsAction) Reset 

func (x *ListCloudInstanceConfigsAction) Reset()

func (*ListCloudInstanceConfigsAction) String 

func (x *ListCloudInstanceConfigsAction) String() 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 (x *MutationAction_InsertArgs) ProtoReflect() protoreflect.Message

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 (x *MutationAction_Mod) GetInsert() *MutationAction_InsertArgs

func (*MutationAction_Mod) GetInsertOrUpdate 

func (x *MutationAction_Mod) GetInsertOrUpdate() *MutationAction_InsertArgs

func (*MutationAction_Mod) GetReplace 

func (x *MutationAction_Mod) GetReplace() *MutationAction_InsertArgs

func (*MutationAction_Mod) GetTable 

func (x *MutationAction_Mod) GetTable() string

func (*MutationAction_Mod) GetUpdate 

func (x *MutationAction_Mod) GetUpdate() *MutationAction_UpdateArgs

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 (x *MutationAction_UpdateArgs) ProtoReflect() protoreflect.Message

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 (x *PartitionedUpdateAction) GetOptions() *PartitionedUpdateAction_ExecutePartitionedUpdateOptions

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 

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

Deprecated: Use PartitionedUpdateAction_ExecutePartitionedUpdateOptions.ProtoReflect.Descriptor instead.

func (*PartitionedUpdateAction_ExecutePartitionedUpdateOptions) GetRpcPriority 

func (x *PartitionedUpdateAction_ExecutePartitionedUpdateOptions) GetRpcPriority() spannerpb.RequestOptions_Priority

func (*PartitionedUpdateAction_ExecutePartitionedUpdateOptions) GetTag 

func (x *PartitionedUpdateAction_ExecutePartitionedUpdateOptions) GetTag() string

func (*PartitionedUpdateAction_ExecutePartitionedUpdateOptions) ProtoMessage 

func (*PartitionedUpdateAction_ExecutePartitionedUpdateOptions) ProtoMessage()

func (*PartitionedUpdateAction_ExecutePartitionedUpdateOptions) ProtoReflect 

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

func (*PartitionedUpdateAction_ExecutePartitionedUpdateOptions) Reset 

func (x *PartitionedUpdateAction_ExecutePartitionedUpdateOptions) Reset()

func (*PartitionedUpdateAction_ExecutePartitionedUpdateOptions) String 

func (x *PartitionedUpdateAction_ExecutePartitionedUpdateOptions) String() 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 QueryCancellationAction added in v1.62.0 

type QueryCancellationAction struct {

	// Long running query.
	LongRunningSql string `protobuf:"bytes,1,opt,name=long_running_sql,json=longRunningSql,proto3" json:"long_running_sql,omitempty"`
	// Format of the cancel query for the cloud database dialect.
	CancelQuery string `protobuf:"bytes,2,opt,name=cancel_query,json=cancelQuery,proto3" json:"cancel_query,omitempty"`
	// contains filtered or unexported fields
}

Query cancellation action defines the long running query and the cancel query format depening on the Cloud database dialect.

func (*QueryCancellationAction) Descriptor deprecated added in v1.62.0 

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

Deprecated: Use QueryCancellationAction.ProtoReflect.Descriptor instead.

func (*QueryCancellationAction) GetCancelQuery added in v1.62.0 

func (x *QueryCancellationAction) GetCancelQuery() string

func (*QueryCancellationAction) GetLongRunningSql added in v1.62.0 

func (x *QueryCancellationAction) GetLongRunningSql() string

func (*QueryCancellationAction) ProtoMessage added in v1.62.0 

func (*QueryCancellationAction) ProtoMessage()

func (*QueryCancellationAction) ProtoReflect added in v1.62.0 

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

func (*QueryCancellationAction) Reset added in v1.62.0 

func (x *QueryCancellationAction) Reset()

func (*QueryCancellationAction) String added in v1.62.0 

func (x *QueryCancellationAction) 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"`
	// The KMS key(s) used to encrypt the restored database to be created if the
	// restored database should be CMEK protected.
	EncryptionConfig *databasepb.EncryptionConfig `protobuf:"bytes,7,opt,name=encryption_config,json=encryptionConfig,proto3" json:"encryption_config,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) GetEncryptionConfig added in v1.61.0 

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

func (*RestoreCloudDatabaseAction) GetProjectId 

func (x *RestoreCloudDatabaseAction) GetProjectId() string

func (*RestoreCloudDatabaseAction) ProtoMessage 

func (*RestoreCloudDatabaseAction) ProtoMessage()

func (*RestoreCloudDatabaseAction) ProtoReflect 

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

func (*RestoreCloudDatabaseAction) Reset 

func (x *RestoreCloudDatabaseAction) Reset()

func (*RestoreCloudDatabaseAction) String 

func (x *RestoreCloudDatabaseAction) String() string

type SessionPoolOptions added in v1.61.0 

type SessionPoolOptions struct {

	// passing this as true, will make applicable RPCs use multiplexed sessions
	// instead of regular sessions
	UseMultiplexed bool `protobuf:"varint,1,opt,name=use_multiplexed,json=useMultiplexed,proto3" json:"use_multiplexed,omitempty"`
	// contains filtered or unexported fields
}

Options for the session pool used by the DatabaseClient.

func (*SessionPoolOptions) Descriptor deprecated added in v1.61.0 

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

Deprecated: Use SessionPoolOptions.ProtoReflect.Descriptor instead.

func (*SessionPoolOptions) GetUseMultiplexed added in v1.61.0 

func (x *SessionPoolOptions) GetUseMultiplexed() bool

func (*SessionPoolOptions) ProtoMessage added in v1.61.0 

func (*SessionPoolOptions) ProtoMessage()

func (*SessionPoolOptions) ProtoReflect added in v1.61.0 

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

func (*SessionPoolOptions) Reset added in v1.61.0 

func (x *SessionPoolOptions) Reset()

func (*SessionPoolOptions) String added in v1.61.0 

func (x *SessionPoolOptions) 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"`
	// Configuration options for Spanner backend
	SpannerOptions *SpannerOptions `protobuf:"bytes,2,opt,name=spanner_options,json=spannerOptions,proto3" json:"spanner_options,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
	//	*SpannerAction_QueryCancellation
	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) GetQueryCancellation added in v1.62.0 

func (x *SpannerAction) GetQueryCancellation() *QueryCancellationAction

func (*SpannerAction) GetRead 

func (x *SpannerAction) GetRead() *ReadAction

func (*SpannerAction) GetSpannerOptions added in v1.61.0 

func (x *SpannerAction) GetSpannerOptions() *SpannerOptions

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_QueryCancellation added in v1.62.0 

type SpannerAction_QueryCancellation struct {
	// Query cancellation action for testing the cancellation of a query.
	QueryCancellation *QueryCancellationAction `protobuf:"bytes,51,opt,name=query_cancellation,json=queryCancellation,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 (x *SpannerAsyncActionRequest) ProtoReflect() protoreflect.Message

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 (x *SpannerAsyncActionResponse) GetOutcome() *SpannerActionOutcome

func (*SpannerAsyncActionResponse) ProtoMessage 

func (*SpannerAsyncActionResponse) ProtoMessage()

func (*SpannerAsyncActionResponse) ProtoReflect 

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

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.

func NewSpannerExecutorProxyClient 

func NewSpannerExecutorProxyClient(cc grpc.ClientConnInterface) SpannerExecutorProxyClient

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 SpannerOptions added in v1.61.0 

type SpannerOptions struct {

	// Options for configuring the session pool
	SessionPoolOptions *SessionPoolOptions `protobuf:"bytes,1,opt,name=session_pool_options,json=sessionPoolOptions,proto3" json:"session_pool_options,omitempty"`
	// contains filtered or unexported fields
}

Options for Cloud Spanner Service.

func (*SpannerOptions) Descriptor deprecated added in v1.61.0 

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

Deprecated: Use SpannerOptions.ProtoReflect.Descriptor instead.

func (*SpannerOptions) GetSessionPoolOptions added in v1.61.0 

func (x *SpannerOptions) GetSessionPoolOptions() *SessionPoolOptions

func (*SpannerOptions) ProtoMessage added in v1.61.0 

func (*SpannerOptions) ProtoMessage()

func (*SpannerOptions) ProtoReflect added in v1.61.0 

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

func (*SpannerOptions) Reset added in v1.61.0 

func (x *SpannerOptions) Reset()

func (*SpannerOptions) String added in v1.61.0 

func (x *SpannerOptions) String() string

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 (x *StartBatchTransactionAction) ProtoReflect() protoreflect.Message

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 (x *TransactionExecutionOptions) ProtoReflect() protoreflect.Message

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 

func (*UnimplementedSpannerExecutorProxyServer) ExecuteActionAsync(SpannerExecutorProxy_ExecuteActionAsyncServer) error

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 (x *UpdateCloudDatabaseAction) ProtoReflect() protoreflect.Message

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"`
	ProtoDescriptors []byte `protobuf:"bytes,6,opt,name=proto_descriptors,json=protoDescriptors,proto3,oneof" json:"proto_descriptors,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) GetProtoDescriptors 

func (x *UpdateCloudDatabaseDdlAction) GetProtoDescriptors() []byte

func (*UpdateCloudDatabaseDdlAction) GetSdlStatement 

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

func (*UpdateCloudDatabaseDdlAction) ProtoMessage 

func (*UpdateCloudDatabaseDdlAction) ProtoMessage()

func (*UpdateCloudDatabaseDdlAction) ProtoReflect 

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

func (*UpdateCloudDatabaseDdlAction) Reset 

func (x *UpdateCloudDatabaseDdlAction) Reset()

func (*UpdateCloudDatabaseDdlAction) String 

func (x *UpdateCloudDatabaseDdlAction) String() 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"`
	// The autoscaling config for this instance. If non-empty, this instance is
	// using autoscaling (processing_units and node_count should be set to
	// 0 if used).
	AutoscalingConfig *instancepb.AutoscalingConfig `protobuf:"bytes,7,opt,name=autoscaling_config,json=autoscalingConfig,proto3,oneof" json:"autoscaling_config,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) GetAutoscalingConfig 

func (x *UpdateCloudInstanceAction) GetAutoscalingConfig() *instancepb.AutoscalingConfig

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 (x *UpdateCloudInstanceAction) ProtoReflect() protoreflect.Message

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 (x *UpdateUserInstanceConfigAction) ProtoReflect() protoreflect.Message

func (*UpdateUserInstanceConfigAction) Reset 

func (x *UpdateUserInstanceConfigAction) Reset()

func (*UpdateUserInstanceConfigAction) String 

func (x *UpdateUserInstanceConfigAction) String() 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.