- 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
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
Deprecated: Use DmlAction.ProtoReflect.Descriptor instead.
func (*DmlAction) GetAutocommitIfSupported
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
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
Deprecated: Use KeyRange.ProtoReflect.Descriptor instead.
func (*KeyRange) GetLimit
func (*KeyRange) GetStart
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
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
Deprecated: Use KeySet.ProtoReflect.Descriptor instead.
func (*KeySet) GetAll
func (*KeySet) GetPoint
func (*KeySet) GetRange
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
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:
- Start batch transaction with a timestamp (StartBatchTransactionAction)
- Generate database partitions for a read or query (GenerateDbPartitionsForReadAction/GenerateDbPartitionsForQueryAction)
- Call ExecutePartitionAction for some or all partitions, process rows
- Clean up the transaction (CloseBatchTransactionAction).
More sophisticated example, with parallel processing:
- Start batch transaction with a timestamp (StartBatchTransactionAction), note the returned BatchTransactionId
- Generate database partitions for a read or query (GenerateDbPartitionsForReadAction/GenerateDbPartitionsForQueryAction)
- 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:
- 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
Deprecated: Use Value.ProtoReflect.Descriptor instead.
func (*Value) GetArrayType
func (*Value) GetArrayValue
func (*Value) GetBoolValue
func (*Value) GetBytesValue
func (*Value) GetDateDaysValue
func (*Value) GetDoubleValue
func (*Value) GetIntValue
func (*Value) GetIsCommitTimestamp
func (*Value) GetIsNull
func (*Value) GetStringValue
func (*Value) GetStructValue
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
ValueList
type ValueList struct {
// Values contained in this ValueList.
Value []*Value `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"`
// contains filtered or unexported fields
}
List of values.
func (*ValueList) Descriptor
Deprecated: Use ValueList.ProtoReflect.Descriptor instead.
func (*ValueList) GetValue
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
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