Package cloud.google.com/go/spanner/executor/apiv1/executorpb (v1.68.0)

Version 1.68.0

• 1.73.0 (latest)
• 1.72.0
• 1.71.0
• 1.70.0
• 1.69.0
• 1.68.0
• 1.67.0
• 1.66.0
• 1.65.0
• 1.64.0
• 1.63.0
• 1.62.0
• 1.61.0
• 1.60.0
• 1.59.0
• 1.58.0
• 1.57.0
• 1.56.0
• 1.55.0
• 1.54.0
• 1.53.1
• 1.52.0
• 1.49.0
• 1.48.0
• 1.47.0
• 1.46.0
• 1.45.1
• 1.44.0
• 1.43.0
• 1.42.0
• 1.41.0
• 1.40.0
• 1.39.0
• 1.38.0
• 1.37.0
• 1.36.0
• 1.35.0
• 1.34.1
• 1.33.0
• 1.32.0
• 1.31.0
• 1.30.1
• 1.29.0
• 1.28.0
• 1.27.0
• 1.26.0
• 1.25.0
• 1.24.1
• 1.23.0
• 1.22.0
• 1.21.0
• 1.20.0
• 1.19.0
• 1.18.0
• 1.17.0
• 1.16.0
• 1.15.0
• 1.14.1
• 1.13.0

Note: To get more information about this package, such as access to older versions, view this package on pkg.go.dev.

Variables

KeyRange_Type_name, KeyRange_Type_value

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.

FinishTransactionAction_Mode_name, FinishTransactionAction_Mode_value

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.

File_google_spanner_executor_v1_cloud_executor_proto

var File_google_spanner_executor_v1_cloud_executor_proto protoreflect.FileDescriptor

Functions

func RegisterSpannerExecutorProxyServer

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

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

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

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

AdminAction_CancelOperation

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

AdminAction_ChangeQuorumCloudDatabase

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

AdminAction_GetOperation

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

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

AdminResult

type AdminResult struct {
	BackupResponse *CloudBackupResponse `protobuf:"bytes,1,opt,name=backup_response,json=backupResponse,proto3" json:"backup_response,omitempty"`

	OperationResponse *OperationResponse `protobuf:"bytes,2,opt,name=operation_response,json=operationResponse,proto3" json:"operation_response,omitempty"`

	DatabaseResponse *CloudDatabaseResponse `protobuf:"bytes,3,opt,name=database_response,json=databaseResponse,proto3" json:"database_response,omitempty"`

	InstanceResponse *CloudInstanceResponse `protobuf:"bytes,4,opt,name=instance_response,json=instanceResponse,proto3" json:"instance_response,omitempty"`

	InstanceConfigResponse *CloudInstanceConfigResponse "" /* 129 byte string literal not displayed */

}

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

func (*AdminResult) Descriptor

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

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

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

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

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

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

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

ChangeQuorumCloudDatabaseAction

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

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

Deprecated: Use ChangeQuorumCloudDatabaseAction.ProtoReflect.Descriptor instead.

func (*ChangeQuorumCloudDatabaseAction) GetDatabaseUri

func (x *ChangeQuorumCloudDatabaseAction) GetDatabaseUri() string

func (*ChangeQuorumCloudDatabaseAction) GetServingLocations

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

func (*ChangeQuorumCloudDatabaseAction) ProtoMessage

func (*ChangeQuorumCloudDatabaseAction) ProtoMessage()

func (*ChangeQuorumCloudDatabaseAction) ProtoReflect

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

func (*ChangeQuorumCloudDatabaseAction) Reset

func (x *ChangeQuorumCloudDatabaseAction) Reset()

func (*ChangeQuorumCloudDatabaseAction) String

func (x *ChangeQuorumCloudDatabaseAction) String() string

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

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

ChangeStreamRecord_ChildPartition

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

ChangeStreamRecord_DataChange

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

ChangeStreamRecord_Heartbeat

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

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

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

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 `protobuf:"bytes,2,rep,name=parent_partition_tokens,json=parentPartitionTokens,proto3" json:"parent_partition_tokens,omitempty"`
	// contains filtered or unexported fields
}

A single child partition.

func (*ChildPartitionsRecord_ChildPartition) Descriptor

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

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

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

CloudBackupResponse

type CloudBackupResponse struct {
	ListedBackups []*databasepb.Backup `protobuf:"bytes,1,rep,name=listed_backups,json=listedBackups,proto3" json:"listed_backups,omitempty"`

	ListedBackupOperations []*longrunningpb.Operation "" /* 129 byte string literal not displayed */

	NextPageToken string `protobuf:"bytes,3,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`

	Backup *databasepb.Backup `protobuf:"bytes,4,opt,name=backup,proto3" json:"backup,omitempty"`

}

CloudBackupResponse contains results returned by cloud backup related actions.

func (*CloudBackupResponse) Descriptor

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

CloudDatabaseResponse

type CloudDatabaseResponse struct {
	ListedDatabases []*databasepb.Database `protobuf:"bytes,1,rep,name=listed_databases,json=listedDatabases,proto3" json:"listed_databases,omitempty"`

	ListedDatabaseOperations []*longrunningpb.Operation "" /* 135 byte string literal not displayed */

	NextPageToken string `protobuf:"bytes,3,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`

	Database *databasepb.Database `protobuf:"bytes,4,opt,name=database,proto3" json:"database,omitempty"`

}

CloudDatabaseResponse contains results returned by cloud database related actions.

func (*CloudDatabaseResponse) Descriptor

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

CloudInstanceConfigResponse

type CloudInstanceConfigResponse struct {

	// List of instance configs returned by ListCloudInstanceConfigsAction.
	ListedInstanceConfigs []*instancepb.InstanceConfig `protobuf:"bytes,1,rep,name=listed_instance_configs,json=listedInstanceConfigs,proto3" json:"listed_instance_configs,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 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

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

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

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

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

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

Concurrency

type Concurrency struct {
	ConcurrencyMode isConcurrency_ConcurrencyMode `protobuf_oneof:"concurrency_mode"`

	SnapshotEpochRead bool `protobuf:"varint,7,opt,name=snapshot_epoch_read,json=snapshotEpochRead,proto3" json:"snapshot_epoch_read,omitempty"`

	SnapshotEpochRootTable string "" /* 131 byte string literal not displayed */

	BatchReadTimestampMicros int64 "" /* 138 byte string literal not displayed */

}

Concurrency for read-only transactions.

func (*Concurrency) Descriptor

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

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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/

Action that copies a Cloud Spanner database backup.

func (*CopyCloudBackupAction) Descriptor

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

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

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

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

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

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

CreateCloudInstanceAction

type CreateCloudInstanceAction struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`

	ProjectId string `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`

	InstanceConfigId string `protobuf:"bytes,3,opt,name=instance_config_id,json=instanceConfigId,proto3" json:"instance_config_id,omitempty"`

	NodeCount *int32 `protobuf:"varint,4,opt,name=node_count,json=nodeCount,proto3,oneof" json:"node_count,omitempty"`

	ProcessingUnits *int32 `protobuf:"varint,6,opt,name=processing_units,json=processingUnits,proto3,oneof" json:"processing_units,omitempty"`

	AutoscalingConfig *instancepb.AutoscalingConfig `protobuf:"bytes,7,opt,name=autoscaling_config,json=autoscalingConfig,proto3,oneof" json:"autoscaling_config,omitempty"`

	Labels map[string]string "" /* 153 byte string literal not displayed */

}

Action that creates a Cloud Spanner instance.

func (*CreateCloudInstanceAction) Descriptor

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

DmlAction

type DmlAction struct {
	Update *QueryAction `protobuf:"bytes,1,opt,name=update,proto3" json:"update,omitempty"`

	AutocommitIfSupported *bool "" /* 133 byte string literal not displayed */

}

A single DML statement.

func (*DmlAction) Descriptor

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

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

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

ExecuteChangeStreamQuery

type ExecuteChangeStreamQuery struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`

	StartTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`

	EndTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=end_time,json=endTime,proto3,oneof" json:"end_time,omitempty"`

	PartitionToken *string `protobuf:"bytes,4,opt,name=partition_token,json=partitionToken,proto3,oneof" json:"partition_token,omitempty"`

	ReadOptions []string `protobuf:"bytes,5,rep,name=read_options,json=readOptions,proto3" json:"read_options,omitempty"`

	HeartbeatMilliseconds *int32 "" /* 131 byte string literal not displayed */

	DeadlineSeconds *int64 `protobuf:"varint,7,opt,name=deadline_seconds,json=deadlineSeconds,proto3,oneof" json:"deadline_seconds,omitempty"`

	CloudDatabaseRole *string `protobuf:"bytes,8,opt,name=cloud_database_role,json=cloudDatabaseRole,proto3,oneof" json:"cloud_database_role,omitempty"`

}

Execute a change stream TVF query.

func (*ExecuteChangeStreamQuery) Descriptor

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

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

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

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

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

FinishTransactionAction_Mode

type FinishTransactionAction_Mode int32

Mode indicates how the transaction should be finished.

FinishTransactionAction_MODE_UNSPECIFIED, FinishTransactionAction_COMMIT, FinishTransactionAction_ABANDON

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

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

GenerateDbPartitionsForQueryAction

type GenerateDbPartitionsForQueryAction struct {
	Query *QueryAction `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`

	DesiredBytesPerPartition *int64 "" /* 144 byte string literal not displayed */

}

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

func (*GenerateDbPartitionsForQueryAction) Descriptor

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

GenerateDbPartitionsForReadAction

type GenerateDbPartitionsForReadAction struct {
	Read *ReadAction `protobuf:"bytes,1,opt,name=read,proto3" json:"read,omitempty"`

	Table []*TableMetadata `protobuf:"bytes,2,rep,name=table,proto3" json:"table,omitempty"`

	DesiredBytesPerPartition *int64 "" /* 144 byte string literal not displayed */

	MaxPartitionCount *int64 `protobuf:"varint,4,opt,name=max_partition_count,json=maxPartitionCount,proto3,oneof" json:"max_partition_count,omitempty"`

}

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

func (*GenerateDbPartitionsForReadAction) Descriptor

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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.

KeyRange_TYPE_UNSPECIFIED, KeyRange_CLOSED_CLOSED, KeyRange_CLOSED_OPEN, KeyRange_OPEN_CLOSED, KeyRange_OPEN_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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

PartitionedUpdateAction_ExecutePartitionedUpdateOptions

type PartitionedUpdateAction_ExecutePartitionedUpdateOptions struct {
	RpcPriority *spannerpb.RequestOptions_Priority "" /* 148 byte string literal not displayed */

	Tag *string `protobuf:"bytes,2,opt,name=tag,proto3,oneof" json:"tag,omitempty"`

}

func (*PartitionedUpdateAction_ExecutePartitionedUpdateOptions) Descriptor

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

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

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

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

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

QueryCancellationAction

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

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

Deprecated: Use QueryCancellationAction.ProtoReflect.Descriptor instead.

func (*QueryCancellationAction) GetCancelQuery

func (x *QueryCancellationAction) GetCancelQuery() string

func (*QueryCancellationAction) GetLongRunningSql

func (x *QueryCancellationAction) GetLongRunningSql() string

func (*QueryCancellationAction) ProtoMessage

func (*QueryCancellationAction) ProtoMessage()

func (*QueryCancellationAction) ProtoReflect

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

func (*QueryCancellationAction) Reset

func (x *QueryCancellationAction) Reset()

func (*QueryCancellationAction) String

func (x *QueryCancellationAction) String() string

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

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

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

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

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

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

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

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

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

SessionPoolOptions

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

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

Deprecated: Use SessionPoolOptions.ProtoReflect.Descriptor instead.

func (*SessionPoolOptions) GetUseMultiplexed

func (x *SessionPoolOptions) GetUseMultiplexed() bool

func (*SessionPoolOptions) ProtoMessage

func (*SessionPoolOptions) ProtoMessage()

func (*SessionPoolOptions) ProtoReflect

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

func (*SessionPoolOptions) Reset

func (x *SessionPoolOptions) Reset()

func (*SessionPoolOptions) String

func (x *SessionPoolOptions) String() string

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

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

func (x *SpannerAction) GetQueryCancellation() *QueryCancellationAction

func (*SpannerAction) GetRead

func (x *SpannerAction) GetRead() *ReadAction

func (*SpannerAction) GetSpannerOptions

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

SpannerActionOutcome

type SpannerActionOutcome struct {
	Status *status.Status `protobuf:"bytes,1,opt,name=status,proto3,oneof" json:"status,omitempty"`

	CommitTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=commit_time,json=commitTime,proto3,oneof" json:"commit_time,omitempty"`

	ReadResult *ReadResult `protobuf:"bytes,3,opt,name=read_result,json=readResult,proto3,oneof" json:"read_result,omitempty"`

	QueryResult *QueryResult `protobuf:"bytes,4,opt,name=query_result,json=queryResult,proto3,oneof" json:"query_result,omitempty"`

	TransactionRestarted *bool "" /* 128 byte string literal not displayed */

	BatchTxnId []byte `protobuf:"bytes,6,opt,name=batch_txn_id,json=batchTxnId,proto3,oneof" json:"batch_txn_id,omitempty"`

	DbPartition []*BatchPartition `protobuf:"bytes,7,rep,name=db_partition,json=dbPartition,proto3" json:"db_partition,omitempty"`

	AdminResult *AdminResult `protobuf:"bytes,8,opt,name=admin_result,json=adminResult,proto3,oneof" json:"admin_result,omitempty"`

	DmlRowsModified []int64 `protobuf:"varint,9,rep,packed,name=dml_rows_modified,json=dmlRowsModified,proto3" json:"dml_rows_modified,omitempty"`

	ChangeStreamRecords []*ChangeStreamRecord `protobuf:"bytes,10,rep,name=change_stream_records,json=changeStreamRecords,proto3" json:"change_stream_records,omitempty"`

}

SpannerActionOutcome defines a result of execution of a single SpannerAction.

func (*SpannerActionOutcome) Descriptor

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

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"`
}

SpannerAction_BatchDml

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

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"`
}

SpannerAction_Dml

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

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"`
}

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"`
}

SpannerAction_Finish

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

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"`
}

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"`
}

SpannerAction_Mutation

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

SpannerAction_PartitionedUpdate

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

SpannerAction_Query

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

SpannerAction_QueryCancellation

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"`
}

SpannerAction_Read

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

SpannerAction_Start

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

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"`
}

SpannerAction_Write

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

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

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

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

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

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

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.

SpannerExecutorProxy_ExecuteActionAsyncClient

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

SpannerExecutorProxy_ExecuteActionAsyncServer

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

SpannerOptions

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

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

Deprecated: Use SpannerOptions.ProtoReflect.Descriptor instead.

func (*SpannerOptions) GetSessionPoolOptions

func (x *SpannerOptions) GetSessionPoolOptions() *SessionPoolOptions

func (*SpannerOptions) ProtoMessage

func (*SpannerOptions) ProtoMessage()

func (*SpannerOptions) ProtoReflect

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

func (*SpannerOptions) Reset

func (x *SpannerOptions) Reset()

func (*SpannerOptions) String

func (x *SpannerOptions) String() string

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:

1. 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

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

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"`
}

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"`
}

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

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

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

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

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

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

UnimplementedSpannerExecutorProxyServer

type UnimplementedSpannerExecutorProxyServer struct {
}

UnimplementedSpannerExecutorProxyServer can be embedded to have forward compatible implementations.

func (*UnimplementedSpannerExecutorProxyServer) ExecuteActionAsync

func (*UnimplementedSpannerExecutorProxyServer) ExecuteActionAsync(SpannerExecutorProxy_ExecuteActionAsyncServer) error

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

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

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

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

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

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

UpdateCloudInstanceAction

type UpdateCloudInstanceAction struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`

	ProjectId string `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`

	DisplayName *string `protobuf:"bytes,3,opt,name=display_name,json=displayName,proto3,oneof" json:"display_name,omitempty"`

	NodeCount *int32 `protobuf:"varint,4,opt,name=node_count,json=nodeCount,proto3,oneof" json:"node_count,omitempty"`

	ProcessingUnits *int32 `protobuf:"varint,5,opt,name=processing_units,json=processingUnits,proto3,oneof" json:"processing_units,omitempty"`

	AutoscalingConfig *instancepb.AutoscalingConfig `protobuf:"bytes,7,opt,name=autoscaling_config,json=autoscalingConfig,proto3,oneof" json:"autoscaling_config,omitempty"`

	Labels map[string]string "" /* 153 byte string literal not displayed */

}

Action that updates a Cloud Spanner instance.

func (*UpdateCloudInstanceAction) Descriptor

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

UpdateUserInstanceConfigAction

type UpdateUserInstanceConfigAction struct {
	UserConfigId string `protobuf:"bytes,1,opt,name=user_config_id,json=userConfigId,proto3" json:"user_config_id,omitempty"`

	ProjectId string `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`

	DisplayName *string `protobuf:"bytes,3,opt,name=display_name,json=displayName,proto3,oneof" json:"display_name,omitempty"`

	Labels map[string]string "" /* 153 byte string literal not displayed */

}

Action that updates a user instance config.

func (*UpdateUserInstanceConfigAction) Descriptor

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

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

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

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

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

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"`
}

Value_BoolValue

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

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

Value_TimestampValue

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

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

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