Versions in this module Expand all Collapse all v1 v1.61.0 Apr 30, 2024 Changes in this version + var File_google_spanner_executor_v1_cloud_executor_proto protoreflect.FileDescriptor + var FinishTransactionAction_Mode_name = map[int32]string + var FinishTransactionAction_Mode_value = map[string]int32 + var KeyRange_Type_name = map[int32]string + var KeyRange_Type_value = map[string]int32 + func RegisterSpannerExecutorProxyServer(s *grpc.Server, srv SpannerExecutorProxyServer) + type AdminAction struct + Action isAdminAction_Action + func (*AdminAction) Descriptor() ([]byte, []int) + func (*AdminAction) ProtoMessage() + func (m *AdminAction) GetAction() isAdminAction_Action + func (x *AdminAction) GetCancelOperation() *CancelOperationAction + func (x *AdminAction) GetChangeQuorumCloudDatabase() *ChangeQuorumCloudDatabaseAction + func (x *AdminAction) GetCopyCloudBackup() *CopyCloudBackupAction + func (x *AdminAction) GetCreateCloudBackup() *CreateCloudBackupAction + func (x *AdminAction) GetCreateCloudDatabase() *CreateCloudDatabaseAction + func (x *AdminAction) GetCreateCloudInstance() *CreateCloudInstanceAction + func (x *AdminAction) GetCreateUserInstanceConfig() *CreateUserInstanceConfigAction + func (x *AdminAction) GetDeleteCloudBackup() *DeleteCloudBackupAction + func (x *AdminAction) GetDeleteCloudInstance() *DeleteCloudInstanceAction + func (x *AdminAction) GetDeleteUserInstanceConfig() *DeleteUserInstanceConfigAction + func (x *AdminAction) GetDropCloudDatabase() *DropCloudDatabaseAction + func (x *AdminAction) GetGetCloudBackup() *GetCloudBackupAction + func (x *AdminAction) GetGetCloudDatabase() *GetCloudDatabaseAction + func (x *AdminAction) GetGetCloudInstance() *GetCloudInstanceAction + func (x *AdminAction) GetGetCloudInstanceConfig() *GetCloudInstanceConfigAction + func (x *AdminAction) GetGetOperation() *GetOperationAction + func (x *AdminAction) GetListCloudBackupOperations() *ListCloudBackupOperationsAction + func (x *AdminAction) GetListCloudBackups() *ListCloudBackupsAction + func (x *AdminAction) GetListCloudDatabaseOperations() *ListCloudDatabaseOperationsAction + func (x *AdminAction) GetListCloudDatabases() *ListCloudDatabasesAction + func (x *AdminAction) GetListCloudInstances() *ListCloudInstancesAction + func (x *AdminAction) GetListInstanceConfigs() *ListCloudInstanceConfigsAction + func (x *AdminAction) GetRestoreCloudDatabase() *RestoreCloudDatabaseAction + func (x *AdminAction) GetUpdateCloudBackup() *UpdateCloudBackupAction + func (x *AdminAction) GetUpdateCloudDatabase() *UpdateCloudDatabaseAction + func (x *AdminAction) GetUpdateCloudDatabaseDdl() *UpdateCloudDatabaseDdlAction + func (x *AdminAction) GetUpdateCloudInstance() *UpdateCloudInstanceAction + func (x *AdminAction) GetUpdateUserInstanceConfig() *UpdateUserInstanceConfigAction + func (x *AdminAction) ProtoReflect() protoreflect.Message + func (x *AdminAction) Reset() + func (x *AdminAction) String() string + type AdminAction_CancelOperation struct + CancelOperation *CancelOperationAction + type AdminAction_ChangeQuorumCloudDatabase struct + ChangeQuorumCloudDatabase *ChangeQuorumCloudDatabaseAction + type AdminAction_CopyCloudBackup struct + CopyCloudBackup *CopyCloudBackupAction + type AdminAction_CreateCloudBackup struct + CreateCloudBackup *CreateCloudBackupAction + type AdminAction_CreateCloudDatabase struct + CreateCloudDatabase *CreateCloudDatabaseAction + type AdminAction_CreateCloudInstance struct + CreateCloudInstance *CreateCloudInstanceAction + type AdminAction_CreateUserInstanceConfig struct + CreateUserInstanceConfig *CreateUserInstanceConfigAction + type AdminAction_DeleteCloudBackup struct + DeleteCloudBackup *DeleteCloudBackupAction + type AdminAction_DeleteCloudInstance struct + DeleteCloudInstance *DeleteCloudInstanceAction + type AdminAction_DeleteUserInstanceConfig struct + DeleteUserInstanceConfig *DeleteUserInstanceConfigAction + type AdminAction_DropCloudDatabase struct + DropCloudDatabase *DropCloudDatabaseAction + type AdminAction_GetCloudBackup struct + GetCloudBackup *GetCloudBackupAction + type AdminAction_GetCloudDatabase struct + GetCloudDatabase *GetCloudDatabaseAction + type AdminAction_GetCloudInstance struct + GetCloudInstance *GetCloudInstanceAction + type AdminAction_GetCloudInstanceConfig struct + GetCloudInstanceConfig *GetCloudInstanceConfigAction + type AdminAction_GetOperation struct + GetOperation *GetOperationAction + type AdminAction_ListCloudBackupOperations struct + ListCloudBackupOperations *ListCloudBackupOperationsAction + type AdminAction_ListCloudBackups struct + ListCloudBackups *ListCloudBackupsAction + type AdminAction_ListCloudDatabaseOperations struct + ListCloudDatabaseOperations *ListCloudDatabaseOperationsAction + type AdminAction_ListCloudDatabases struct + ListCloudDatabases *ListCloudDatabasesAction + type AdminAction_ListCloudInstances struct + ListCloudInstances *ListCloudInstancesAction + type AdminAction_ListInstanceConfigs struct + ListInstanceConfigs *ListCloudInstanceConfigsAction + type AdminAction_RestoreCloudDatabase struct + RestoreCloudDatabase *RestoreCloudDatabaseAction + type AdminAction_UpdateCloudBackup struct + UpdateCloudBackup *UpdateCloudBackupAction + type AdminAction_UpdateCloudDatabase struct + UpdateCloudDatabase *UpdateCloudDatabaseAction + type AdminAction_UpdateCloudDatabaseDdl struct + UpdateCloudDatabaseDdl *UpdateCloudDatabaseDdlAction + type AdminAction_UpdateCloudInstance struct + UpdateCloudInstance *UpdateCloudInstanceAction + type AdminAction_UpdateUserInstanceConfig struct + UpdateUserInstanceConfig *UpdateUserInstanceConfigAction + type AdminResult struct + BackupResponse *CloudBackupResponse + DatabaseResponse *CloudDatabaseResponse + InstanceConfigResponse *CloudInstanceConfigResponse + InstanceResponse *CloudInstanceResponse + OperationResponse *OperationResponse + func (*AdminResult) Descriptor() ([]byte, []int) + func (*AdminResult) ProtoMessage() + func (x *AdminResult) GetBackupResponse() *CloudBackupResponse + func (x *AdminResult) GetDatabaseResponse() *CloudDatabaseResponse + func (x *AdminResult) GetInstanceConfigResponse() *CloudInstanceConfigResponse + func (x *AdminResult) GetInstanceResponse() *CloudInstanceResponse + func (x *AdminResult) GetOperationResponse() *OperationResponse + func (x *AdminResult) ProtoReflect() protoreflect.Message + func (x *AdminResult) Reset() + func (x *AdminResult) String() string + type BatchDmlAction struct + Updates []*QueryAction + func (*BatchDmlAction) Descriptor() ([]byte, []int) + func (*BatchDmlAction) ProtoMessage() + func (x *BatchDmlAction) GetUpdates() []*QueryAction + func (x *BatchDmlAction) ProtoReflect() protoreflect.Message + func (x *BatchDmlAction) Reset() + func (x *BatchDmlAction) String() string + type BatchPartition struct + Index *string + Partition []byte + PartitionToken []byte + Table *string + func (*BatchPartition) Descriptor() ([]byte, []int) + func (*BatchPartition) ProtoMessage() + func (x *BatchPartition) GetIndex() string + func (x *BatchPartition) GetPartition() []byte + func (x *BatchPartition) GetPartitionToken() []byte + func (x *BatchPartition) GetTable() string + func (x *BatchPartition) ProtoReflect() protoreflect.Message + func (x *BatchPartition) Reset() + func (x *BatchPartition) String() string + type CancelOperationAction struct + Operation string + func (*CancelOperationAction) Descriptor() ([]byte, []int) + func (*CancelOperationAction) ProtoMessage() + func (x *CancelOperationAction) GetOperation() string + func (x *CancelOperationAction) ProtoReflect() protoreflect.Message + func (x *CancelOperationAction) Reset() + func (x *CancelOperationAction) String() string + type ChangeQuorumCloudDatabaseAction struct + DatabaseUri *string + ServingLocations []string + func (*ChangeQuorumCloudDatabaseAction) Descriptor() ([]byte, []int) + func (*ChangeQuorumCloudDatabaseAction) ProtoMessage() + func (x *ChangeQuorumCloudDatabaseAction) GetDatabaseUri() string + func (x *ChangeQuorumCloudDatabaseAction) GetServingLocations() []string + func (x *ChangeQuorumCloudDatabaseAction) ProtoReflect() protoreflect.Message + func (x *ChangeQuorumCloudDatabaseAction) Reset() + func (x *ChangeQuorumCloudDatabaseAction) String() string + type ChangeStreamRecord struct + Record isChangeStreamRecord_Record + func (*ChangeStreamRecord) Descriptor() ([]byte, []int) + func (*ChangeStreamRecord) ProtoMessage() + func (m *ChangeStreamRecord) GetRecord() isChangeStreamRecord_Record + func (x *ChangeStreamRecord) GetChildPartition() *ChildPartitionsRecord + func (x *ChangeStreamRecord) GetDataChange() *DataChangeRecord + func (x *ChangeStreamRecord) GetHeartbeat() *HeartbeatRecord + func (x *ChangeStreamRecord) ProtoReflect() protoreflect.Message + func (x *ChangeStreamRecord) Reset() + func (x *ChangeStreamRecord) String() string + type ChangeStreamRecord_ChildPartition struct + ChildPartition *ChildPartitionsRecord + type ChangeStreamRecord_DataChange struct + DataChange *DataChangeRecord + type ChangeStreamRecord_Heartbeat struct + Heartbeat *HeartbeatRecord + type ChildPartitionsRecord struct + ChildPartitions []*ChildPartitionsRecord_ChildPartition + RecordSequence string + StartTime *timestamppb.Timestamp + func (*ChildPartitionsRecord) Descriptor() ([]byte, []int) + func (*ChildPartitionsRecord) ProtoMessage() + func (x *ChildPartitionsRecord) GetChildPartitions() []*ChildPartitionsRecord_ChildPartition + func (x *ChildPartitionsRecord) GetRecordSequence() string + func (x *ChildPartitionsRecord) GetStartTime() *timestamppb.Timestamp + func (x *ChildPartitionsRecord) ProtoReflect() protoreflect.Message + func (x *ChildPartitionsRecord) Reset() + func (x *ChildPartitionsRecord) String() string + type ChildPartitionsRecord_ChildPartition struct + ParentPartitionTokens []string + Token string + func (*ChildPartitionsRecord_ChildPartition) Descriptor() ([]byte, []int) + func (*ChildPartitionsRecord_ChildPartition) ProtoMessage() + func (x *ChildPartitionsRecord_ChildPartition) GetParentPartitionTokens() []string + func (x *ChildPartitionsRecord_ChildPartition) GetToken() string + func (x *ChildPartitionsRecord_ChildPartition) ProtoReflect() protoreflect.Message + func (x *ChildPartitionsRecord_ChildPartition) Reset() + func (x *ChildPartitionsRecord_ChildPartition) String() string + type CloseBatchTransactionAction struct + Cleanup bool + func (*CloseBatchTransactionAction) Descriptor() ([]byte, []int) + func (*CloseBatchTransactionAction) ProtoMessage() + func (x *CloseBatchTransactionAction) GetCleanup() bool + func (x *CloseBatchTransactionAction) ProtoReflect() protoreflect.Message + func (x *CloseBatchTransactionAction) Reset() + func (x *CloseBatchTransactionAction) String() string + type CloudBackupResponse struct + Backup *databasepb.Backup + ListedBackupOperations []*longrunningpb.Operation + ListedBackups []*databasepb.Backup + NextPageToken string + func (*CloudBackupResponse) Descriptor() ([]byte, []int) + func (*CloudBackupResponse) ProtoMessage() + func (x *CloudBackupResponse) GetBackup() *databasepb.Backup + func (x *CloudBackupResponse) GetListedBackupOperations() []*longrunningpb.Operation + func (x *CloudBackupResponse) GetListedBackups() []*databasepb.Backup + func (x *CloudBackupResponse) GetNextPageToken() string + func (x *CloudBackupResponse) ProtoReflect() protoreflect.Message + func (x *CloudBackupResponse) Reset() + func (x *CloudBackupResponse) String() string + type CloudDatabaseResponse struct + Database *databasepb.Database + ListedDatabaseOperations []*longrunningpb.Operation + ListedDatabases []*databasepb.Database + NextPageToken string + func (*CloudDatabaseResponse) Descriptor() ([]byte, []int) + func (*CloudDatabaseResponse) ProtoMessage() + func (x *CloudDatabaseResponse) GetDatabase() *databasepb.Database + func (x *CloudDatabaseResponse) GetListedDatabaseOperations() []*longrunningpb.Operation + func (x *CloudDatabaseResponse) GetListedDatabases() []*databasepb.Database + func (x *CloudDatabaseResponse) GetNextPageToken() string + func (x *CloudDatabaseResponse) ProtoReflect() protoreflect.Message + func (x *CloudDatabaseResponse) Reset() + func (x *CloudDatabaseResponse) String() string + type CloudInstanceConfigResponse struct + InstanceConfig *instancepb.InstanceConfig + ListedInstanceConfigs []*instancepb.InstanceConfig + NextPageToken string + func (*CloudInstanceConfigResponse) Descriptor() ([]byte, []int) + func (*CloudInstanceConfigResponse) ProtoMessage() + func (x *CloudInstanceConfigResponse) GetInstanceConfig() *instancepb.InstanceConfig + func (x *CloudInstanceConfigResponse) GetListedInstanceConfigs() []*instancepb.InstanceConfig + func (x *CloudInstanceConfigResponse) GetNextPageToken() string + func (x *CloudInstanceConfigResponse) ProtoReflect() protoreflect.Message + func (x *CloudInstanceConfigResponse) Reset() + func (x *CloudInstanceConfigResponse) String() string + type CloudInstanceResponse struct + Instance *instancepb.Instance + ListedInstances []*instancepb.Instance + NextPageToken string + func (*CloudInstanceResponse) Descriptor() ([]byte, []int) + func (*CloudInstanceResponse) ProtoMessage() + func (x *CloudInstanceResponse) GetInstance() *instancepb.Instance + func (x *CloudInstanceResponse) GetListedInstances() []*instancepb.Instance + func (x *CloudInstanceResponse) GetNextPageToken() string + func (x *CloudInstanceResponse) ProtoReflect() protoreflect.Message + func (x *CloudInstanceResponse) Reset() + func (x *CloudInstanceResponse) String() string + type ColumnMetadata struct + Name string + Type *spannerpb.Type + func (*ColumnMetadata) Descriptor() ([]byte, []int) + func (*ColumnMetadata) ProtoMessage() + func (x *ColumnMetadata) GetName() string + func (x *ColumnMetadata) GetType() *spannerpb.Type + func (x *ColumnMetadata) ProtoReflect() protoreflect.Message + func (x *ColumnMetadata) Reset() + func (x *ColumnMetadata) String() string + type Concurrency struct + BatchReadTimestampMicros int64 + ConcurrencyMode isConcurrency_ConcurrencyMode + SnapshotEpochRead bool + SnapshotEpochRootTable string + func (*Concurrency) Descriptor() ([]byte, []int) + func (*Concurrency) ProtoMessage() + func (m *Concurrency) GetConcurrencyMode() isConcurrency_ConcurrencyMode + func (x *Concurrency) GetBatch() bool + func (x *Concurrency) GetBatchReadTimestampMicros() int64 + func (x *Concurrency) GetExactTimestampMicros() int64 + func (x *Concurrency) GetMaxStalenessSeconds() float64 + func (x *Concurrency) GetMinReadTimestampMicros() int64 + func (x *Concurrency) GetSnapshotEpochRead() bool + func (x *Concurrency) GetSnapshotEpochRootTable() string + func (x *Concurrency) GetStalenessSeconds() float64 + func (x *Concurrency) GetStrong() bool + func (x *Concurrency) ProtoReflect() protoreflect.Message + func (x *Concurrency) Reset() + func (x *Concurrency) String() string + type Concurrency_Batch struct + Batch bool + type Concurrency_ExactTimestampMicros struct + ExactTimestampMicros int64 + type Concurrency_MaxStalenessSeconds struct + MaxStalenessSeconds float64 + type Concurrency_MinReadTimestampMicros struct + MinReadTimestampMicros int64 + type Concurrency_StalenessSeconds struct + StalenessSeconds float64 + type Concurrency_Strong struct + Strong bool + type CopyCloudBackupAction struct + BackupId string + ExpireTime *timestamppb.Timestamp + InstanceId string + ProjectId string + SourceBackup string + func (*CopyCloudBackupAction) Descriptor() ([]byte, []int) + func (*CopyCloudBackupAction) ProtoMessage() + func (x *CopyCloudBackupAction) GetBackupId() string + func (x *CopyCloudBackupAction) GetExpireTime() *timestamppb.Timestamp + func (x *CopyCloudBackupAction) GetInstanceId() string + func (x *CopyCloudBackupAction) GetProjectId() string + func (x *CopyCloudBackupAction) GetSourceBackup() string + func (x *CopyCloudBackupAction) ProtoReflect() protoreflect.Message + func (x *CopyCloudBackupAction) Reset() + func (x *CopyCloudBackupAction) String() string + type CreateCloudBackupAction struct + BackupId string + DatabaseId string + EncryptionConfig *databasepb.EncryptionConfig + ExpireTime *timestamppb.Timestamp + InstanceId string + ProjectId string + VersionTime *timestamppb.Timestamp + func (*CreateCloudBackupAction) Descriptor() ([]byte, []int) + func (*CreateCloudBackupAction) ProtoMessage() + func (x *CreateCloudBackupAction) GetBackupId() string + func (x *CreateCloudBackupAction) GetDatabaseId() string + func (x *CreateCloudBackupAction) GetEncryptionConfig() *databasepb.EncryptionConfig + func (x *CreateCloudBackupAction) GetExpireTime() *timestamppb.Timestamp + func (x *CreateCloudBackupAction) GetInstanceId() string + func (x *CreateCloudBackupAction) GetProjectId() string + func (x *CreateCloudBackupAction) GetVersionTime() *timestamppb.Timestamp + func (x *CreateCloudBackupAction) ProtoReflect() protoreflect.Message + func (x *CreateCloudBackupAction) Reset() + func (x *CreateCloudBackupAction) String() string + type CreateCloudDatabaseAction struct + DatabaseId string + Dialect *string + EncryptionConfig *databasepb.EncryptionConfig + InstanceId string + ProjectId string + ProtoDescriptors []byte + SdlStatement []string + func (*CreateCloudDatabaseAction) Descriptor() ([]byte, []int) + func (*CreateCloudDatabaseAction) ProtoMessage() + func (x *CreateCloudDatabaseAction) GetDatabaseId() string + func (x *CreateCloudDatabaseAction) GetDialect() string + func (x *CreateCloudDatabaseAction) GetEncryptionConfig() *databasepb.EncryptionConfig + func (x *CreateCloudDatabaseAction) GetInstanceId() string + func (x *CreateCloudDatabaseAction) GetProjectId() string + func (x *CreateCloudDatabaseAction) GetProtoDescriptors() []byte + func (x *CreateCloudDatabaseAction) GetSdlStatement() []string + func (x *CreateCloudDatabaseAction) ProtoReflect() protoreflect.Message + func (x *CreateCloudDatabaseAction) Reset() + func (x *CreateCloudDatabaseAction) String() string + type CreateCloudInstanceAction struct + AutoscalingConfig *instancepb.AutoscalingConfig + InstanceConfigId string + InstanceId string + Labels map[string]string + NodeCount *int32 + ProcessingUnits *int32 + ProjectId string + func (*CreateCloudInstanceAction) Descriptor() ([]byte, []int) + func (*CreateCloudInstanceAction) ProtoMessage() + func (x *CreateCloudInstanceAction) GetAutoscalingConfig() *instancepb.AutoscalingConfig + func (x *CreateCloudInstanceAction) GetInstanceConfigId() string + func (x *CreateCloudInstanceAction) GetInstanceId() string + func (x *CreateCloudInstanceAction) GetLabels() map[string]string + func (x *CreateCloudInstanceAction) GetNodeCount() int32 + func (x *CreateCloudInstanceAction) GetProcessingUnits() int32 + func (x *CreateCloudInstanceAction) GetProjectId() string + func (x *CreateCloudInstanceAction) ProtoReflect() protoreflect.Message + func (x *CreateCloudInstanceAction) Reset() + func (x *CreateCloudInstanceAction) String() string + type CreateUserInstanceConfigAction struct + BaseConfigId string + ProjectId string + Replicas []*instancepb.ReplicaInfo + UserConfigId string + func (*CreateUserInstanceConfigAction) Descriptor() ([]byte, []int) + func (*CreateUserInstanceConfigAction) ProtoMessage() + func (x *CreateUserInstanceConfigAction) GetBaseConfigId() string + func (x *CreateUserInstanceConfigAction) GetProjectId() string + func (x *CreateUserInstanceConfigAction) GetReplicas() []*instancepb.ReplicaInfo + func (x *CreateUserInstanceConfigAction) GetUserConfigId() string + func (x *CreateUserInstanceConfigAction) ProtoReflect() protoreflect.Message + func (x *CreateUserInstanceConfigAction) Reset() + func (x *CreateUserInstanceConfigAction) String() string + type DataChangeRecord struct + ColumnTypes []*DataChangeRecord_ColumnType + CommitTime *timestamppb.Timestamp + IsLastRecord bool + IsSystemTransaction bool + ModType string + Mods []*DataChangeRecord_Mod + PartitionCount int64 + RecordCount int64 + RecordSequence string + Table string + TransactionId string + TransactionTag string + ValueCaptureType string + func (*DataChangeRecord) Descriptor() ([]byte, []int) + func (*DataChangeRecord) ProtoMessage() + func (x *DataChangeRecord) GetColumnTypes() []*DataChangeRecord_ColumnType + func (x *DataChangeRecord) GetCommitTime() *timestamppb.Timestamp + func (x *DataChangeRecord) GetIsLastRecord() bool + func (x *DataChangeRecord) GetIsSystemTransaction() bool + func (x *DataChangeRecord) GetModType() string + func (x *DataChangeRecord) GetMods() []*DataChangeRecord_Mod + func (x *DataChangeRecord) GetPartitionCount() int64 + func (x *DataChangeRecord) GetRecordCount() int64 + func (x *DataChangeRecord) GetRecordSequence() string + func (x *DataChangeRecord) GetTable() string + func (x *DataChangeRecord) GetTransactionId() string + func (x *DataChangeRecord) GetTransactionTag() string + func (x *DataChangeRecord) GetValueCaptureType() string + func (x *DataChangeRecord) ProtoReflect() protoreflect.Message + func (x *DataChangeRecord) Reset() + func (x *DataChangeRecord) String() string + type DataChangeRecord_ColumnType struct + IsPrimaryKey bool + Name string + OrdinalPosition int64 + Type string + func (*DataChangeRecord_ColumnType) Descriptor() ([]byte, []int) + func (*DataChangeRecord_ColumnType) ProtoMessage() + func (x *DataChangeRecord_ColumnType) GetIsPrimaryKey() bool + func (x *DataChangeRecord_ColumnType) GetName() string + func (x *DataChangeRecord_ColumnType) GetOrdinalPosition() int64 + func (x *DataChangeRecord_ColumnType) GetType() string + func (x *DataChangeRecord_ColumnType) ProtoReflect() protoreflect.Message + func (x *DataChangeRecord_ColumnType) Reset() + func (x *DataChangeRecord_ColumnType) String() string + type DataChangeRecord_Mod struct + Keys string + NewValues string + OldValues string + func (*DataChangeRecord_Mod) Descriptor() ([]byte, []int) + func (*DataChangeRecord_Mod) ProtoMessage() + func (x *DataChangeRecord_Mod) GetKeys() string + func (x *DataChangeRecord_Mod) GetNewValues() string + func (x *DataChangeRecord_Mod) GetOldValues() string + func (x *DataChangeRecord_Mod) ProtoReflect() protoreflect.Message + func (x *DataChangeRecord_Mod) Reset() + func (x *DataChangeRecord_Mod) String() string + type DeleteCloudBackupAction struct + BackupId string + InstanceId string + ProjectId string + func (*DeleteCloudBackupAction) Descriptor() ([]byte, []int) + func (*DeleteCloudBackupAction) ProtoMessage() + func (x *DeleteCloudBackupAction) GetBackupId() string + func (x *DeleteCloudBackupAction) GetInstanceId() string + func (x *DeleteCloudBackupAction) GetProjectId() string + func (x *DeleteCloudBackupAction) ProtoReflect() protoreflect.Message + func (x *DeleteCloudBackupAction) Reset() + func (x *DeleteCloudBackupAction) String() string + type DeleteCloudInstanceAction struct + InstanceId string + ProjectId string + func (*DeleteCloudInstanceAction) Descriptor() ([]byte, []int) + func (*DeleteCloudInstanceAction) ProtoMessage() + func (x *DeleteCloudInstanceAction) GetInstanceId() string + func (x *DeleteCloudInstanceAction) GetProjectId() string + func (x *DeleteCloudInstanceAction) ProtoReflect() protoreflect.Message + func (x *DeleteCloudInstanceAction) Reset() + func (x *DeleteCloudInstanceAction) String() string + type DeleteUserInstanceConfigAction struct + ProjectId string + UserConfigId string + func (*DeleteUserInstanceConfigAction) Descriptor() ([]byte, []int) + func (*DeleteUserInstanceConfigAction) ProtoMessage() + func (x *DeleteUserInstanceConfigAction) GetProjectId() string + func (x *DeleteUserInstanceConfigAction) GetUserConfigId() string + func (x *DeleteUserInstanceConfigAction) ProtoReflect() protoreflect.Message + func (x *DeleteUserInstanceConfigAction) Reset() + func (x *DeleteUserInstanceConfigAction) String() string + type DmlAction struct + AutocommitIfSupported *bool + Update *QueryAction + func (*DmlAction) Descriptor() ([]byte, []int) + func (*DmlAction) ProtoMessage() + func (x *DmlAction) GetAutocommitIfSupported() bool + func (x *DmlAction) GetUpdate() *QueryAction + func (x *DmlAction) ProtoReflect() protoreflect.Message + func (x *DmlAction) Reset() + func (x *DmlAction) String() string + type DropCloudDatabaseAction struct + DatabaseId string + InstanceId string + ProjectId string + func (*DropCloudDatabaseAction) Descriptor() ([]byte, []int) + func (*DropCloudDatabaseAction) ProtoMessage() + func (x *DropCloudDatabaseAction) GetDatabaseId() string + func (x *DropCloudDatabaseAction) GetInstanceId() string + func (x *DropCloudDatabaseAction) GetProjectId() string + func (x *DropCloudDatabaseAction) ProtoReflect() protoreflect.Message + func (x *DropCloudDatabaseAction) Reset() + func (x *DropCloudDatabaseAction) String() string + type ExecuteChangeStreamQuery struct + CloudDatabaseRole *string + DeadlineSeconds *int64 + EndTime *timestamppb.Timestamp + HeartbeatMilliseconds *int32 + Name string + PartitionToken *string + ReadOptions []string + StartTime *timestamppb.Timestamp + func (*ExecuteChangeStreamQuery) Descriptor() ([]byte, []int) + func (*ExecuteChangeStreamQuery) ProtoMessage() + func (x *ExecuteChangeStreamQuery) GetCloudDatabaseRole() string + func (x *ExecuteChangeStreamQuery) GetDeadlineSeconds() int64 + func (x *ExecuteChangeStreamQuery) GetEndTime() *timestamppb.Timestamp + func (x *ExecuteChangeStreamQuery) GetHeartbeatMilliseconds() int32 + func (x *ExecuteChangeStreamQuery) GetName() string + func (x *ExecuteChangeStreamQuery) GetPartitionToken() string + func (x *ExecuteChangeStreamQuery) GetReadOptions() []string + func (x *ExecuteChangeStreamQuery) GetStartTime() *timestamppb.Timestamp + func (x *ExecuteChangeStreamQuery) ProtoReflect() protoreflect.Message + func (x *ExecuteChangeStreamQuery) Reset() + func (x *ExecuteChangeStreamQuery) String() string + type ExecutePartitionAction struct + Partition *BatchPartition + func (*ExecutePartitionAction) Descriptor() ([]byte, []int) + func (*ExecutePartitionAction) ProtoMessage() + func (x *ExecutePartitionAction) GetPartition() *BatchPartition + func (x *ExecutePartitionAction) ProtoReflect() protoreflect.Message + func (x *ExecutePartitionAction) Reset() + func (x *ExecutePartitionAction) String() string + type FinishTransactionAction struct + Mode FinishTransactionAction_Mode + func (*FinishTransactionAction) Descriptor() ([]byte, []int) + func (*FinishTransactionAction) ProtoMessage() + func (x *FinishTransactionAction) GetMode() FinishTransactionAction_Mode + func (x *FinishTransactionAction) ProtoReflect() protoreflect.Message + func (x *FinishTransactionAction) Reset() + func (x *FinishTransactionAction) String() string + type FinishTransactionAction_Mode int32 + const FinishTransactionAction_ABANDON + const FinishTransactionAction_COMMIT + const FinishTransactionAction_MODE_UNSPECIFIED + func (FinishTransactionAction_Mode) Descriptor() protoreflect.EnumDescriptor + func (FinishTransactionAction_Mode) EnumDescriptor() ([]byte, []int) + func (FinishTransactionAction_Mode) Type() protoreflect.EnumType + func (x FinishTransactionAction_Mode) Enum() *FinishTransactionAction_Mode + func (x FinishTransactionAction_Mode) Number() protoreflect.EnumNumber + func (x FinishTransactionAction_Mode) String() string + type GenerateDbPartitionsForQueryAction struct + DesiredBytesPerPartition *int64 + Query *QueryAction + func (*GenerateDbPartitionsForQueryAction) Descriptor() ([]byte, []int) + func (*GenerateDbPartitionsForQueryAction) ProtoMessage() + func (x *GenerateDbPartitionsForQueryAction) GetDesiredBytesPerPartition() int64 + func (x *GenerateDbPartitionsForQueryAction) GetQuery() *QueryAction + func (x *GenerateDbPartitionsForQueryAction) ProtoReflect() protoreflect.Message + func (x *GenerateDbPartitionsForQueryAction) Reset() + func (x *GenerateDbPartitionsForQueryAction) String() string + type GenerateDbPartitionsForReadAction struct + DesiredBytesPerPartition *int64 + MaxPartitionCount *int64 + Read *ReadAction + Table []*TableMetadata + func (*GenerateDbPartitionsForReadAction) Descriptor() ([]byte, []int) + func (*GenerateDbPartitionsForReadAction) ProtoMessage() + func (x *GenerateDbPartitionsForReadAction) GetDesiredBytesPerPartition() int64 + func (x *GenerateDbPartitionsForReadAction) GetMaxPartitionCount() int64 + func (x *GenerateDbPartitionsForReadAction) GetRead() *ReadAction + func (x *GenerateDbPartitionsForReadAction) GetTable() []*TableMetadata + func (x *GenerateDbPartitionsForReadAction) ProtoReflect() protoreflect.Message + func (x *GenerateDbPartitionsForReadAction) Reset() + func (x *GenerateDbPartitionsForReadAction) String() string + type GetCloudBackupAction struct + BackupId string + InstanceId string + ProjectId string + func (*GetCloudBackupAction) Descriptor() ([]byte, []int) + func (*GetCloudBackupAction) ProtoMessage() + func (x *GetCloudBackupAction) GetBackupId() string + func (x *GetCloudBackupAction) GetInstanceId() string + func (x *GetCloudBackupAction) GetProjectId() string + func (x *GetCloudBackupAction) ProtoReflect() protoreflect.Message + func (x *GetCloudBackupAction) Reset() + func (x *GetCloudBackupAction) String() string + type GetCloudDatabaseAction struct + DatabaseId string + InstanceId string + ProjectId string + func (*GetCloudDatabaseAction) Descriptor() ([]byte, []int) + func (*GetCloudDatabaseAction) ProtoMessage() + func (x *GetCloudDatabaseAction) GetDatabaseId() string + func (x *GetCloudDatabaseAction) GetInstanceId() string + func (x *GetCloudDatabaseAction) GetProjectId() string + func (x *GetCloudDatabaseAction) ProtoReflect() protoreflect.Message + func (x *GetCloudDatabaseAction) Reset() + func (x *GetCloudDatabaseAction) String() string + type GetCloudInstanceAction struct + InstanceId string + ProjectId string + func (*GetCloudInstanceAction) Descriptor() ([]byte, []int) + func (*GetCloudInstanceAction) ProtoMessage() + func (x *GetCloudInstanceAction) GetInstanceId() string + func (x *GetCloudInstanceAction) GetProjectId() string + func (x *GetCloudInstanceAction) ProtoReflect() protoreflect.Message + func (x *GetCloudInstanceAction) Reset() + func (x *GetCloudInstanceAction) String() string + type GetCloudInstanceConfigAction struct + InstanceConfigId string + ProjectId string + func (*GetCloudInstanceConfigAction) Descriptor() ([]byte, []int) + func (*GetCloudInstanceConfigAction) ProtoMessage() + func (x *GetCloudInstanceConfigAction) GetInstanceConfigId() string + func (x *GetCloudInstanceConfigAction) GetProjectId() string + func (x *GetCloudInstanceConfigAction) ProtoReflect() protoreflect.Message + func (x *GetCloudInstanceConfigAction) Reset() + func (x *GetCloudInstanceConfigAction) String() string + type GetOperationAction struct + Operation string + func (*GetOperationAction) Descriptor() ([]byte, []int) + func (*GetOperationAction) ProtoMessage() + func (x *GetOperationAction) GetOperation() string + func (x *GetOperationAction) ProtoReflect() protoreflect.Message + func (x *GetOperationAction) Reset() + func (x *GetOperationAction) String() string + type HeartbeatRecord struct + HeartbeatTime *timestamppb.Timestamp + func (*HeartbeatRecord) Descriptor() ([]byte, []int) + func (*HeartbeatRecord) ProtoMessage() + func (x *HeartbeatRecord) GetHeartbeatTime() *timestamppb.Timestamp + func (x *HeartbeatRecord) ProtoReflect() protoreflect.Message + func (x *HeartbeatRecord) Reset() + func (x *HeartbeatRecord) String() string + type KeyRange struct + Limit *ValueList + Start *ValueList + Type *KeyRange_Type + func (*KeyRange) Descriptor() ([]byte, []int) + func (*KeyRange) ProtoMessage() + func (x *KeyRange) GetLimit() *ValueList + func (x *KeyRange) GetStart() *ValueList + func (x *KeyRange) GetType() KeyRange_Type + func (x *KeyRange) ProtoReflect() protoreflect.Message + func (x *KeyRange) Reset() + func (x *KeyRange) String() string + type KeyRange_Type int32 + const KeyRange_CLOSED_CLOSED + const KeyRange_CLOSED_OPEN + const KeyRange_OPEN_CLOSED + const KeyRange_OPEN_OPEN + const KeyRange_TYPE_UNSPECIFIED + func (KeyRange_Type) Descriptor() protoreflect.EnumDescriptor + func (KeyRange_Type) EnumDescriptor() ([]byte, []int) + func (KeyRange_Type) Type() protoreflect.EnumType + func (x KeyRange_Type) Enum() *KeyRange_Type + func (x KeyRange_Type) Number() protoreflect.EnumNumber + func (x KeyRange_Type) String() string + type KeySet struct + All bool + Point []*ValueList + Range []*KeyRange + func (*KeySet) Descriptor() ([]byte, []int) + func (*KeySet) ProtoMessage() + func (x *KeySet) GetAll() bool + func (x *KeySet) GetPoint() []*ValueList + func (x *KeySet) GetRange() []*KeyRange + func (x *KeySet) ProtoReflect() protoreflect.Message + func (x *KeySet) Reset() + func (x *KeySet) String() string + type ListCloudBackupOperationsAction struct + Filter string + InstanceId string + PageSize int32 + PageToken string + ProjectId string + func (*ListCloudBackupOperationsAction) Descriptor() ([]byte, []int) + func (*ListCloudBackupOperationsAction) ProtoMessage() + func (x *ListCloudBackupOperationsAction) GetFilter() string + func (x *ListCloudBackupOperationsAction) GetInstanceId() string + func (x *ListCloudBackupOperationsAction) GetPageSize() int32 + func (x *ListCloudBackupOperationsAction) GetPageToken() string + func (x *ListCloudBackupOperationsAction) GetProjectId() string + func (x *ListCloudBackupOperationsAction) ProtoReflect() protoreflect.Message + func (x *ListCloudBackupOperationsAction) Reset() + func (x *ListCloudBackupOperationsAction) String() string + type ListCloudBackupsAction struct + Filter string + InstanceId string + PageSize int32 + PageToken string + ProjectId string + func (*ListCloudBackupsAction) Descriptor() ([]byte, []int) + func (*ListCloudBackupsAction) ProtoMessage() + func (x *ListCloudBackupsAction) GetFilter() string + func (x *ListCloudBackupsAction) GetInstanceId() string + func (x *ListCloudBackupsAction) GetPageSize() int32 + func (x *ListCloudBackupsAction) GetPageToken() string + func (x *ListCloudBackupsAction) GetProjectId() string + func (x *ListCloudBackupsAction) ProtoReflect() protoreflect.Message + func (x *ListCloudBackupsAction) Reset() + func (x *ListCloudBackupsAction) String() string + type ListCloudDatabaseOperationsAction struct + Filter string + InstanceId string + PageSize int32 + PageToken string + ProjectId string + func (*ListCloudDatabaseOperationsAction) Descriptor() ([]byte, []int) + func (*ListCloudDatabaseOperationsAction) ProtoMessage() + func (x *ListCloudDatabaseOperationsAction) GetFilter() string + func (x *ListCloudDatabaseOperationsAction) GetInstanceId() string + func (x *ListCloudDatabaseOperationsAction) GetPageSize() int32 + func (x *ListCloudDatabaseOperationsAction) GetPageToken() string + func (x *ListCloudDatabaseOperationsAction) GetProjectId() string + func (x *ListCloudDatabaseOperationsAction) ProtoReflect() protoreflect.Message + func (x *ListCloudDatabaseOperationsAction) Reset() + func (x *ListCloudDatabaseOperationsAction) String() string + type ListCloudDatabasesAction struct + InstanceId string + PageSize int32 + PageToken string + ProjectId string + func (*ListCloudDatabasesAction) Descriptor() ([]byte, []int) + func (*ListCloudDatabasesAction) ProtoMessage() + func (x *ListCloudDatabasesAction) GetInstanceId() string + func (x *ListCloudDatabasesAction) GetPageSize() int32 + func (x *ListCloudDatabasesAction) GetPageToken() string + func (x *ListCloudDatabasesAction) GetProjectId() string + func (x *ListCloudDatabasesAction) ProtoReflect() protoreflect.Message + func (x *ListCloudDatabasesAction) Reset() + func (x *ListCloudDatabasesAction) String() string + type ListCloudInstanceConfigsAction struct + PageSize *int32 + PageToken *string + ProjectId string + func (*ListCloudInstanceConfigsAction) Descriptor() ([]byte, []int) + func (*ListCloudInstanceConfigsAction) ProtoMessage() + func (x *ListCloudInstanceConfigsAction) GetPageSize() int32 + func (x *ListCloudInstanceConfigsAction) GetPageToken() string + func (x *ListCloudInstanceConfigsAction) GetProjectId() string + func (x *ListCloudInstanceConfigsAction) ProtoReflect() protoreflect.Message + func (x *ListCloudInstanceConfigsAction) Reset() + func (x *ListCloudInstanceConfigsAction) String() string + type ListCloudInstancesAction struct + Filter *string + PageSize *int32 + PageToken *string + ProjectId string + func (*ListCloudInstancesAction) Descriptor() ([]byte, []int) + func (*ListCloudInstancesAction) ProtoMessage() + func (x *ListCloudInstancesAction) GetFilter() string + func (x *ListCloudInstancesAction) GetPageSize() int32 + func (x *ListCloudInstancesAction) GetPageToken() string + func (x *ListCloudInstancesAction) GetProjectId() string + func (x *ListCloudInstancesAction) ProtoReflect() protoreflect.Message + func (x *ListCloudInstancesAction) Reset() + func (x *ListCloudInstancesAction) String() string + type MutationAction struct + Mod []*MutationAction_Mod + func (*MutationAction) Descriptor() ([]byte, []int) + func (*MutationAction) ProtoMessage() + func (x *MutationAction) GetMod() []*MutationAction_Mod + func (x *MutationAction) ProtoReflect() protoreflect.Message + func (x *MutationAction) Reset() + func (x *MutationAction) String() string + type MutationAction_InsertArgs struct + Column []string + Type []*spannerpb.Type + Values []*ValueList + func (*MutationAction_InsertArgs) Descriptor() ([]byte, []int) + func (*MutationAction_InsertArgs) ProtoMessage() + func (x *MutationAction_InsertArgs) GetColumn() []string + func (x *MutationAction_InsertArgs) GetType() []*spannerpb.Type + func (x *MutationAction_InsertArgs) GetValues() []*ValueList + func (x *MutationAction_InsertArgs) ProtoReflect() protoreflect.Message + func (x *MutationAction_InsertArgs) Reset() + func (x *MutationAction_InsertArgs) String() string + type MutationAction_Mod struct + DeleteKeys *KeySet + Insert *MutationAction_InsertArgs + InsertOrUpdate *MutationAction_InsertArgs + Replace *MutationAction_InsertArgs + Table string + Update *MutationAction_UpdateArgs + func (*MutationAction_Mod) Descriptor() ([]byte, []int) + func (*MutationAction_Mod) ProtoMessage() + func (x *MutationAction_Mod) GetDeleteKeys() *KeySet + func (x *MutationAction_Mod) GetInsert() *MutationAction_InsertArgs + func (x *MutationAction_Mod) GetInsertOrUpdate() *MutationAction_InsertArgs + func (x *MutationAction_Mod) GetReplace() *MutationAction_InsertArgs + func (x *MutationAction_Mod) GetTable() string + func (x *MutationAction_Mod) GetUpdate() *MutationAction_UpdateArgs + func (x *MutationAction_Mod) ProtoReflect() protoreflect.Message + func (x *MutationAction_Mod) Reset() + func (x *MutationAction_Mod) String() string + type MutationAction_UpdateArgs struct + Column []string + Type []*spannerpb.Type + Values []*ValueList + func (*MutationAction_UpdateArgs) Descriptor() ([]byte, []int) + func (*MutationAction_UpdateArgs) ProtoMessage() + func (x *MutationAction_UpdateArgs) GetColumn() []string + func (x *MutationAction_UpdateArgs) GetType() []*spannerpb.Type + func (x *MutationAction_UpdateArgs) GetValues() []*ValueList + func (x *MutationAction_UpdateArgs) ProtoReflect() protoreflect.Message + func (x *MutationAction_UpdateArgs) Reset() + func (x *MutationAction_UpdateArgs) String() string + type OperationResponse struct + ListedOperations []*longrunningpb.Operation + NextPageToken string + Operation *longrunningpb.Operation + func (*OperationResponse) Descriptor() ([]byte, []int) + func (*OperationResponse) ProtoMessage() + func (x *OperationResponse) GetListedOperations() []*longrunningpb.Operation + func (x *OperationResponse) GetNextPageToken() string + func (x *OperationResponse) GetOperation() *longrunningpb.Operation + func (x *OperationResponse) ProtoReflect() protoreflect.Message + func (x *OperationResponse) Reset() + func (x *OperationResponse) String() string + type PartitionedUpdateAction struct + Options *PartitionedUpdateAction_ExecutePartitionedUpdateOptions + Update *QueryAction + func (*PartitionedUpdateAction) Descriptor() ([]byte, []int) + func (*PartitionedUpdateAction) ProtoMessage() + func (x *PartitionedUpdateAction) GetOptions() *PartitionedUpdateAction_ExecutePartitionedUpdateOptions + func (x *PartitionedUpdateAction) GetUpdate() *QueryAction + func (x *PartitionedUpdateAction) ProtoReflect() protoreflect.Message + func (x *PartitionedUpdateAction) Reset() + func (x *PartitionedUpdateAction) String() string + type PartitionedUpdateAction_ExecutePartitionedUpdateOptions struct + RpcPriority *spannerpb.RequestOptions_Priority + Tag *string + func (*PartitionedUpdateAction_ExecutePartitionedUpdateOptions) Descriptor() ([]byte, []int) + func (*PartitionedUpdateAction_ExecutePartitionedUpdateOptions) ProtoMessage() + func (x *PartitionedUpdateAction_ExecutePartitionedUpdateOptions) GetRpcPriority() spannerpb.RequestOptions_Priority + func (x *PartitionedUpdateAction_ExecutePartitionedUpdateOptions) GetTag() string + func (x *PartitionedUpdateAction_ExecutePartitionedUpdateOptions) ProtoReflect() protoreflect.Message + func (x *PartitionedUpdateAction_ExecutePartitionedUpdateOptions) Reset() + func (x *PartitionedUpdateAction_ExecutePartitionedUpdateOptions) String() string + type QueryAction struct + Params []*QueryAction_Parameter + Sql string + func (*QueryAction) Descriptor() ([]byte, []int) + func (*QueryAction) ProtoMessage() + func (x *QueryAction) GetParams() []*QueryAction_Parameter + func (x *QueryAction) GetSql() string + func (x *QueryAction) ProtoReflect() protoreflect.Message + func (x *QueryAction) Reset() + func (x *QueryAction) String() string + type QueryAction_Parameter struct + Name string + Type *spannerpb.Type + Value *Value + func (*QueryAction_Parameter) Descriptor() ([]byte, []int) + func (*QueryAction_Parameter) ProtoMessage() + func (x *QueryAction_Parameter) GetName() string + func (x *QueryAction_Parameter) GetType() *spannerpb.Type + func (x *QueryAction_Parameter) GetValue() *Value + func (x *QueryAction_Parameter) ProtoReflect() protoreflect.Message + func (x *QueryAction_Parameter) Reset() + func (x *QueryAction_Parameter) String() string + type QueryResult struct + Row []*ValueList + RowType *spannerpb.StructType + func (*QueryResult) Descriptor() ([]byte, []int) + func (*QueryResult) ProtoMessage() + func (x *QueryResult) GetRow() []*ValueList + func (x *QueryResult) GetRowType() *spannerpb.StructType + func (x *QueryResult) ProtoReflect() protoreflect.Message + func (x *QueryResult) Reset() + func (x *QueryResult) String() string + type ReadAction struct + Column []string + Index *string + Keys *KeySet + Limit int32 + Table string + func (*ReadAction) Descriptor() ([]byte, []int) + func (*ReadAction) ProtoMessage() + func (x *ReadAction) GetColumn() []string + func (x *ReadAction) GetIndex() string + func (x *ReadAction) GetKeys() *KeySet + func (x *ReadAction) GetLimit() int32 + func (x *ReadAction) GetTable() string + func (x *ReadAction) ProtoReflect() protoreflect.Message + func (x *ReadAction) Reset() + func (x *ReadAction) String() string + type ReadResult struct + Index *string + RequestIndex *int32 + Row []*ValueList + RowType *spannerpb.StructType + Table string + func (*ReadResult) Descriptor() ([]byte, []int) + func (*ReadResult) ProtoMessage() + func (x *ReadResult) GetIndex() string + func (x *ReadResult) GetRequestIndex() int32 + func (x *ReadResult) GetRow() []*ValueList + func (x *ReadResult) GetRowType() *spannerpb.StructType + func (x *ReadResult) GetTable() string + func (x *ReadResult) ProtoReflect() protoreflect.Message + func (x *ReadResult) Reset() + func (x *ReadResult) String() string + type RestoreCloudDatabaseAction struct + BackupId string + BackupInstanceId string + DatabaseId string + DatabaseInstanceId string + EncryptionConfig *databasepb.EncryptionConfig + ProjectId string + func (*RestoreCloudDatabaseAction) Descriptor() ([]byte, []int) + func (*RestoreCloudDatabaseAction) ProtoMessage() + func (x *RestoreCloudDatabaseAction) GetBackupId() string + func (x *RestoreCloudDatabaseAction) GetBackupInstanceId() string + func (x *RestoreCloudDatabaseAction) GetDatabaseId() string + func (x *RestoreCloudDatabaseAction) GetDatabaseInstanceId() string + func (x *RestoreCloudDatabaseAction) GetEncryptionConfig() *databasepb.EncryptionConfig + func (x *RestoreCloudDatabaseAction) GetProjectId() string + func (x *RestoreCloudDatabaseAction) ProtoReflect() protoreflect.Message + func (x *RestoreCloudDatabaseAction) Reset() + func (x *RestoreCloudDatabaseAction) String() string + type SessionPoolOptions struct + UseMultiplexed bool + func (*SessionPoolOptions) Descriptor() ([]byte, []int) + func (*SessionPoolOptions) ProtoMessage() + func (x *SessionPoolOptions) GetUseMultiplexed() bool + func (x *SessionPoolOptions) ProtoReflect() protoreflect.Message + func (x *SessionPoolOptions) Reset() + func (x *SessionPoolOptions) String() string + type SpannerAction struct + Action isSpannerAction_Action + DatabasePath string + SpannerOptions *SpannerOptions + func (*SpannerAction) Descriptor() ([]byte, []int) + func (*SpannerAction) ProtoMessage() + func (m *SpannerAction) GetAction() isSpannerAction_Action + func (x *SpannerAction) GetAdmin() *AdminAction + func (x *SpannerAction) GetBatchDml() *BatchDmlAction + func (x *SpannerAction) GetCloseBatchTxn() *CloseBatchTransactionAction + func (x *SpannerAction) GetDatabasePath() string + func (x *SpannerAction) GetDml() *DmlAction + func (x *SpannerAction) GetExecuteChangeStreamQuery() *ExecuteChangeStreamQuery + func (x *SpannerAction) GetExecutePartition() *ExecutePartitionAction + func (x *SpannerAction) GetFinish() *FinishTransactionAction + func (x *SpannerAction) GetGenerateDbPartitionsQuery() *GenerateDbPartitionsForQueryAction + func (x *SpannerAction) GetGenerateDbPartitionsRead() *GenerateDbPartitionsForReadAction + func (x *SpannerAction) GetMutation() *MutationAction + func (x *SpannerAction) GetPartitionedUpdate() *PartitionedUpdateAction + func (x *SpannerAction) GetQuery() *QueryAction + func (x *SpannerAction) GetRead() *ReadAction + func (x *SpannerAction) GetSpannerOptions() *SpannerOptions + func (x *SpannerAction) GetStart() *StartTransactionAction + func (x *SpannerAction) GetStartBatchTxn() *StartBatchTransactionAction + func (x *SpannerAction) GetWrite() *WriteMutationsAction + func (x *SpannerAction) ProtoReflect() protoreflect.Message + func (x *SpannerAction) Reset() + func (x *SpannerAction) String() string + type SpannerActionOutcome struct + AdminResult *AdminResult + BatchTxnId []byte + ChangeStreamRecords []*ChangeStreamRecord + CommitTime *timestamppb.Timestamp + DbPartition []*BatchPartition + DmlRowsModified []int64 + QueryResult *QueryResult + ReadResult *ReadResult + Status *status.Status + TransactionRestarted *bool + func (*SpannerActionOutcome) Descriptor() ([]byte, []int) + func (*SpannerActionOutcome) ProtoMessage() + func (x *SpannerActionOutcome) GetAdminResult() *AdminResult + func (x *SpannerActionOutcome) GetBatchTxnId() []byte + func (x *SpannerActionOutcome) GetChangeStreamRecords() []*ChangeStreamRecord + func (x *SpannerActionOutcome) GetCommitTime() *timestamppb.Timestamp + func (x *SpannerActionOutcome) GetDbPartition() []*BatchPartition + func (x *SpannerActionOutcome) GetDmlRowsModified() []int64 + func (x *SpannerActionOutcome) GetQueryResult() *QueryResult + func (x *SpannerActionOutcome) GetReadResult() *ReadResult + func (x *SpannerActionOutcome) GetStatus() *status.Status + func (x *SpannerActionOutcome) GetTransactionRestarted() bool + func (x *SpannerActionOutcome) ProtoReflect() protoreflect.Message + func (x *SpannerActionOutcome) Reset() + func (x *SpannerActionOutcome) String() string + type SpannerAction_Admin struct + Admin *AdminAction + type SpannerAction_BatchDml struct + BatchDml *BatchDmlAction + type SpannerAction_CloseBatchTxn struct + CloseBatchTxn *CloseBatchTransactionAction + type SpannerAction_Dml struct + Dml *DmlAction + type SpannerAction_ExecuteChangeStreamQuery struct + ExecuteChangeStreamQuery *ExecuteChangeStreamQuery + type SpannerAction_ExecutePartition struct + ExecutePartition *ExecutePartitionAction + type SpannerAction_Finish struct + Finish *FinishTransactionAction + type SpannerAction_GenerateDbPartitionsQuery struct + GenerateDbPartitionsQuery *GenerateDbPartitionsForQueryAction + type SpannerAction_GenerateDbPartitionsRead struct + GenerateDbPartitionsRead *GenerateDbPartitionsForReadAction + type SpannerAction_Mutation struct + Mutation *MutationAction + type SpannerAction_PartitionedUpdate struct + PartitionedUpdate *PartitionedUpdateAction + type SpannerAction_Query struct + Query *QueryAction + type SpannerAction_Read struct + Read *ReadAction + type SpannerAction_Start struct + Start *StartTransactionAction + type SpannerAction_StartBatchTxn struct + StartBatchTxn *StartBatchTransactionAction + type SpannerAction_Write struct + Write *WriteMutationsAction + type SpannerAsyncActionRequest struct + Action *SpannerAction + ActionId int32 + func (*SpannerAsyncActionRequest) Descriptor() ([]byte, []int) + func (*SpannerAsyncActionRequest) ProtoMessage() + func (x *SpannerAsyncActionRequest) GetAction() *SpannerAction + func (x *SpannerAsyncActionRequest) GetActionId() int32 + func (x *SpannerAsyncActionRequest) ProtoReflect() protoreflect.Message + func (x *SpannerAsyncActionRequest) Reset() + func (x *SpannerAsyncActionRequest) String() string + type SpannerAsyncActionResponse struct + ActionId int32 + Outcome *SpannerActionOutcome + func (*SpannerAsyncActionResponse) Descriptor() ([]byte, []int) + func (*SpannerAsyncActionResponse) ProtoMessage() + func (x *SpannerAsyncActionResponse) GetActionId() int32 + func (x *SpannerAsyncActionResponse) GetOutcome() *SpannerActionOutcome + func (x *SpannerAsyncActionResponse) ProtoReflect() protoreflect.Message + func (x *SpannerAsyncActionResponse) Reset() + func (x *SpannerAsyncActionResponse) String() string + type SpannerExecutorProxyClient interface + ExecuteActionAsync func(ctx context.Context, opts ...grpc.CallOption) (SpannerExecutorProxy_ExecuteActionAsyncClient, error) + func NewSpannerExecutorProxyClient(cc grpc.ClientConnInterface) SpannerExecutorProxyClient + type SpannerExecutorProxyServer interface + ExecuteActionAsync func(SpannerExecutorProxy_ExecuteActionAsyncServer) error + type SpannerExecutorProxy_ExecuteActionAsyncClient interface + Recv func() (*SpannerAsyncActionResponse, error) + Send func(*SpannerAsyncActionRequest) error + type SpannerExecutorProxy_ExecuteActionAsyncServer interface + Recv func() (*SpannerAsyncActionRequest, error) + Send func(*SpannerAsyncActionResponse) error + type SpannerOptions struct + SessionPoolOptions *SessionPoolOptions + func (*SpannerOptions) Descriptor() ([]byte, []int) + func (*SpannerOptions) ProtoMessage() + func (x *SpannerOptions) GetSessionPoolOptions() *SessionPoolOptions + func (x *SpannerOptions) ProtoReflect() protoreflect.Message + func (x *SpannerOptions) Reset() + func (x *SpannerOptions) String() string + type StartBatchTransactionAction struct + CloudDatabaseRole string + Param isStartBatchTransactionAction_Param + func (*StartBatchTransactionAction) Descriptor() ([]byte, []int) + func (*StartBatchTransactionAction) ProtoMessage() + func (m *StartBatchTransactionAction) GetParam() isStartBatchTransactionAction_Param + func (x *StartBatchTransactionAction) GetBatchTxnTime() *timestamppb.Timestamp + func (x *StartBatchTransactionAction) GetCloudDatabaseRole() string + func (x *StartBatchTransactionAction) GetTid() []byte + func (x *StartBatchTransactionAction) ProtoReflect() protoreflect.Message + func (x *StartBatchTransactionAction) Reset() + func (x *StartBatchTransactionAction) String() string + type StartBatchTransactionAction_BatchTxnTime struct + BatchTxnTime *timestamppb.Timestamp + type StartBatchTransactionAction_Tid struct + Tid []byte + type StartTransactionAction struct + Concurrency *Concurrency + ExecutionOptions *TransactionExecutionOptions + Table []*TableMetadata + TransactionSeed string + func (*StartTransactionAction) Descriptor() ([]byte, []int) + func (*StartTransactionAction) ProtoMessage() + func (x *StartTransactionAction) GetConcurrency() *Concurrency + func (x *StartTransactionAction) GetExecutionOptions() *TransactionExecutionOptions + func (x *StartTransactionAction) GetTable() []*TableMetadata + func (x *StartTransactionAction) GetTransactionSeed() string + func (x *StartTransactionAction) ProtoReflect() protoreflect.Message + func (x *StartTransactionAction) Reset() + func (x *StartTransactionAction) String() string + type TableMetadata struct + Column []*ColumnMetadata + KeyColumn []*ColumnMetadata + Name string + func (*TableMetadata) Descriptor() ([]byte, []int) + func (*TableMetadata) ProtoMessage() + func (x *TableMetadata) GetColumn() []*ColumnMetadata + func (x *TableMetadata) GetKeyColumn() []*ColumnMetadata + func (x *TableMetadata) GetName() string + func (x *TableMetadata) ProtoReflect() protoreflect.Message + func (x *TableMetadata) Reset() + func (x *TableMetadata) String() string + type TransactionExecutionOptions struct + Optimistic bool + func (*TransactionExecutionOptions) Descriptor() ([]byte, []int) + func (*TransactionExecutionOptions) ProtoMessage() + func (x *TransactionExecutionOptions) GetOptimistic() bool + func (x *TransactionExecutionOptions) ProtoReflect() protoreflect.Message + func (x *TransactionExecutionOptions) Reset() + func (x *TransactionExecutionOptions) String() string + type UnimplementedSpannerExecutorProxyServer struct + func (*UnimplementedSpannerExecutorProxyServer) ExecuteActionAsync(SpannerExecutorProxy_ExecuteActionAsyncServer) error + type UpdateCloudBackupAction struct + BackupId string + ExpireTime *timestamppb.Timestamp + InstanceId string + ProjectId string + func (*UpdateCloudBackupAction) Descriptor() ([]byte, []int) + func (*UpdateCloudBackupAction) ProtoMessage() + func (x *UpdateCloudBackupAction) GetBackupId() string + func (x *UpdateCloudBackupAction) GetExpireTime() *timestamppb.Timestamp + func (x *UpdateCloudBackupAction) GetInstanceId() string + func (x *UpdateCloudBackupAction) GetProjectId() string + func (x *UpdateCloudBackupAction) ProtoReflect() protoreflect.Message + func (x *UpdateCloudBackupAction) Reset() + func (x *UpdateCloudBackupAction) String() string + type UpdateCloudDatabaseAction struct + DatabaseName string + EnableDropProtection bool + InstanceId string + ProjectId string + func (*UpdateCloudDatabaseAction) Descriptor() ([]byte, []int) + func (*UpdateCloudDatabaseAction) ProtoMessage() + func (x *UpdateCloudDatabaseAction) GetDatabaseName() string + func (x *UpdateCloudDatabaseAction) GetEnableDropProtection() bool + func (x *UpdateCloudDatabaseAction) GetInstanceId() string + func (x *UpdateCloudDatabaseAction) GetProjectId() string + func (x *UpdateCloudDatabaseAction) ProtoReflect() protoreflect.Message + func (x *UpdateCloudDatabaseAction) Reset() + func (x *UpdateCloudDatabaseAction) String() string + type UpdateCloudDatabaseDdlAction struct + DatabaseId string + InstanceId string + OperationId string + ProjectId string + ProtoDescriptors []byte + SdlStatement []string + func (*UpdateCloudDatabaseDdlAction) Descriptor() ([]byte, []int) + func (*UpdateCloudDatabaseDdlAction) ProtoMessage() + func (x *UpdateCloudDatabaseDdlAction) GetDatabaseId() string + func (x *UpdateCloudDatabaseDdlAction) GetInstanceId() string + func (x *UpdateCloudDatabaseDdlAction) GetOperationId() string + func (x *UpdateCloudDatabaseDdlAction) GetProjectId() string + func (x *UpdateCloudDatabaseDdlAction) GetProtoDescriptors() []byte + func (x *UpdateCloudDatabaseDdlAction) GetSdlStatement() []string + func (x *UpdateCloudDatabaseDdlAction) ProtoReflect() protoreflect.Message + func (x *UpdateCloudDatabaseDdlAction) Reset() + func (x *UpdateCloudDatabaseDdlAction) String() string + type UpdateCloudInstanceAction struct + AutoscalingConfig *instancepb.AutoscalingConfig + DisplayName *string + InstanceId string + Labels map[string]string + NodeCount *int32 + ProcessingUnits *int32 + ProjectId string + func (*UpdateCloudInstanceAction) Descriptor() ([]byte, []int) + func (*UpdateCloudInstanceAction) ProtoMessage() + func (x *UpdateCloudInstanceAction) GetAutoscalingConfig() *instancepb.AutoscalingConfig + func (x *UpdateCloudInstanceAction) GetDisplayName() string + func (x *UpdateCloudInstanceAction) GetInstanceId() string + func (x *UpdateCloudInstanceAction) GetLabels() map[string]string + func (x *UpdateCloudInstanceAction) GetNodeCount() int32 + func (x *UpdateCloudInstanceAction) GetProcessingUnits() int32 + func (x *UpdateCloudInstanceAction) GetProjectId() string + func (x *UpdateCloudInstanceAction) ProtoReflect() protoreflect.Message + func (x *UpdateCloudInstanceAction) Reset() + func (x *UpdateCloudInstanceAction) String() string + type UpdateUserInstanceConfigAction struct + DisplayName *string + Labels map[string]string + ProjectId string + UserConfigId string + func (*UpdateUserInstanceConfigAction) Descriptor() ([]byte, []int) + func (*UpdateUserInstanceConfigAction) ProtoMessage() + func (x *UpdateUserInstanceConfigAction) GetDisplayName() string + func (x *UpdateUserInstanceConfigAction) GetLabels() map[string]string + func (x *UpdateUserInstanceConfigAction) GetProjectId() string + func (x *UpdateUserInstanceConfigAction) GetUserConfigId() string + func (x *UpdateUserInstanceConfigAction) ProtoReflect() protoreflect.Message + func (x *UpdateUserInstanceConfigAction) Reset() + func (x *UpdateUserInstanceConfigAction) String() string + type Value struct + ArrayType *spannerpb.Type + ValueType isValue_ValueType + func (*Value) Descriptor() ([]byte, []int) + func (*Value) ProtoMessage() + func (m *Value) GetValueType() isValue_ValueType + func (x *Value) GetArrayType() *spannerpb.Type + func (x *Value) GetArrayValue() *ValueList + func (x *Value) GetBoolValue() bool + func (x *Value) GetBytesValue() []byte + func (x *Value) GetDateDaysValue() int32 + func (x *Value) GetDoubleValue() float64 + func (x *Value) GetIntValue() int64 + func (x *Value) GetIsCommitTimestamp() bool + func (x *Value) GetIsNull() bool + func (x *Value) GetStringValue() string + func (x *Value) GetStructValue() *ValueList + func (x *Value) GetTimestampValue() *timestamppb.Timestamp + func (x *Value) ProtoReflect() protoreflect.Message + func (x *Value) Reset() + func (x *Value) String() string + type ValueList struct + Value []*Value + func (*ValueList) Descriptor() ([]byte, []int) + func (*ValueList) ProtoMessage() + func (x *ValueList) GetValue() []*Value + func (x *ValueList) ProtoReflect() protoreflect.Message + func (x *ValueList) Reset() + func (x *ValueList) String() string + type Value_ArrayValue struct + ArrayValue *ValueList + type Value_BoolValue struct + BoolValue bool + type Value_BytesValue struct + BytesValue []byte + type Value_DateDaysValue struct + DateDaysValue int32 + type Value_DoubleValue struct + DoubleValue float64 + type Value_IntValue struct + IntValue int64 + type Value_IsCommitTimestamp struct + IsCommitTimestamp bool + type Value_IsNull struct + IsNull bool + type Value_StringValue struct + StringValue string + type Value_StructValue struct + StructValue *ValueList + type Value_TimestampValue struct + TimestampValue *timestamppb.Timestamp + type WriteMutationsAction struct + Mutation *MutationAction + func (*WriteMutationsAction) Descriptor() ([]byte, []int) + func (*WriteMutationsAction) ProtoMessage() + func (x *WriteMutationsAction) GetMutation() *MutationAction + func (x *WriteMutationsAction) ProtoReflect() protoreflect.Message + func (x *WriteMutationsAction) Reset() + func (x *WriteMutationsAction) String() string