- 1.75.0 (latest)
- 1.74.0
- 1.73.0
- 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_ReconfigureCloudDatabase
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) 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) GetReconfigureCloudDatabase
func (x *AdminAction) GetReconfigureCloudDatabase() *ReconfigureCloudDatabaseAction
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_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_ReconfigureCloudDatabase
type AdminAction_ReconfigureCloudDatabase struct {
// Action that reconfigures a Cloud Spanner database.
ReconfigureCloudDatabase *ReconfigureCloudDatabaseAction `protobuf:"bytes,28,opt,name=reconfigure_cloud_database,json=reconfigureCloudDatabase,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
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"`
// 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) 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.