Package cloud.google.com/go/spanner/apiv1/spannerpb (v1.84.1)

var (
	ChangeStreamRecord_DataChangeRecord_ModType_name = map[int32]string{
		0:  "MOD_TYPE_UNSPECIFIED",
		10: "INSERT",
		20: "UPDATE",
		30: "DELETE",
	}
	ChangeStreamRecord_DataChangeRecord_ModType_value = map[string]int32{
		"MOD_TYPE_UNSPECIFIED": 0,
		"INSERT":               10,
		"UPDATE":               20,
		"DELETE":               30,
	}
)

var (
	ChangeStreamRecord_DataChangeRecord_ValueCaptureType_name = map[int32]string{
		0:  "VALUE_CAPTURE_TYPE_UNSPECIFIED",
		10: "OLD_AND_NEW_VALUES",
		20: "NEW_VALUES",
		30: "NEW_ROW",
		40: "NEW_ROW_AND_OLD_VALUES",
	}
	ChangeStreamRecord_DataChangeRecord_ValueCaptureType_value = map[string]int32{
		"VALUE_CAPTURE_TYPE_UNSPECIFIED": 0,
		"OLD_AND_NEW_VALUES":             10,
		"NEW_VALUES":                     20,
		"NEW_ROW":                        30,
		"NEW_ROW_AND_OLD_VALUES":         40,
	}
)

var (
	PlanNode_Kind_name = map[int32]string{
		0: "KIND_UNSPECIFIED",
		1: "RELATIONAL",
		2: "SCALAR",
	}
	PlanNode_Kind_value = map[string]int32{
		"KIND_UNSPECIFIED": 0,
		"RELATIONAL":       1,
		"SCALAR":           2,
	}
)

var (
	RequestOptions_Priority_name = map[int32]string{
		0: "PRIORITY_UNSPECIFIED",
		1: "PRIORITY_LOW",
		2: "PRIORITY_MEDIUM",
		3: "PRIORITY_HIGH",
	}
	RequestOptions_Priority_value = map[string]int32{
		"PRIORITY_UNSPECIFIED": 0,
		"PRIORITY_LOW":         1,
		"PRIORITY_MEDIUM":      2,
		"PRIORITY_HIGH":        3,
	}
)

var (
	DirectedReadOptions_ReplicaSelection_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "READ_WRITE",
		2: "READ_ONLY",
	}
	DirectedReadOptions_ReplicaSelection_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED": 0,
		"READ_WRITE":       1,
		"READ_ONLY":        2,
	}
)

var (
	ExecuteSqlRequest_QueryMode_name = map[int32]string{
		0: "NORMAL",
		1: "PLAN",
		2: "PROFILE",
		3: "WITH_STATS",
		4: "WITH_PLAN_AND_STATS",
	}
	ExecuteSqlRequest_QueryMode_value = map[string]int32{
		"NORMAL":              0,
		"PLAN":                1,
		"PROFILE":             2,
		"WITH_STATS":          3,
		"WITH_PLAN_AND_STATS": 4,
	}
)

var (
	ReadRequest_OrderBy_name = map[int32]string{
		0: "ORDER_BY_UNSPECIFIED",
		1: "ORDER_BY_PRIMARY_KEY",
		2: "ORDER_BY_NO_ORDER",
	}
	ReadRequest_OrderBy_value = map[string]int32{
		"ORDER_BY_UNSPECIFIED": 0,
		"ORDER_BY_PRIMARY_KEY": 1,
		"ORDER_BY_NO_ORDER":    2,
	}
)

var (
	ReadRequest_LockHint_name = map[int32]string{
		0: "LOCK_HINT_UNSPECIFIED",
		1: "LOCK_HINT_SHARED",
		2: "LOCK_HINT_EXCLUSIVE",
	}
	ReadRequest_LockHint_value = map[string]int32{
		"LOCK_HINT_UNSPECIFIED": 0,
		"LOCK_HINT_SHARED":      1,
		"LOCK_HINT_EXCLUSIVE":   2,
	}
)

var (
	TransactionOptions_IsolationLevel_name = map[int32]string{
		0: "ISOLATION_LEVEL_UNSPECIFIED",
		1: "SERIALIZABLE",
		2: "REPEATABLE_READ",
	}
	TransactionOptions_IsolationLevel_value = map[string]int32{
		"ISOLATION_LEVEL_UNSPECIFIED": 0,
		"SERIALIZABLE":                1,
		"REPEATABLE_READ":             2,
	}
)

var (
	TransactionOptions_ReadWrite_ReadLockMode_name = map[int32]string{
		0: "READ_LOCK_MODE_UNSPECIFIED",
		1: "PESSIMISTIC",
		2: "OPTIMISTIC",
	}
	TransactionOptions_ReadWrite_ReadLockMode_value = map[string]int32{
		"READ_LOCK_MODE_UNSPECIFIED": 0,
		"PESSIMISTIC":                1,
		"OPTIMISTIC":                 2,
	}
)

var (
	TypeCode_name = map[int32]string{
		0:  "TYPE_CODE_UNSPECIFIED",
		1:  "BOOL",
		2:  "INT64",
		3:  "FLOAT64",
		15: "FLOAT32",
		4:  "TIMESTAMP",
		5:  "DATE",
		6:  "STRING",
		7:  "BYTES",
		8:  "ARRAY",
		9:  "STRUCT",
		10: "NUMERIC",
		11: "JSON",
		13: "PROTO",
		14: "ENUM",
		16: "INTERVAL",
		17: "UUID",
	}
	TypeCode_value = map[string]int32{
		"TYPE_CODE_UNSPECIFIED": 0,
		"BOOL":                  1,
		"INT64":                 2,
		"FLOAT64":               3,
		"FLOAT32":               15,
		"TIMESTAMP":             4,
		"DATE":                  5,
		"STRING":                6,
		"BYTES":                 7,
		"ARRAY":                 8,
		"STRUCT":                9,
		"NUMERIC":               10,
		"JSON":                  11,
		"PROTO":                 13,
		"ENUM":                  14,
		"INTERVAL":              16,
		"UUID":                  17,
	}
)

var (
	TypeAnnotationCode_name = map[int32]string{
		0: "TYPE_ANNOTATION_CODE_UNSPECIFIED",
		2: "PG_NUMERIC",
		3: "PG_JSONB",
		4: "PG_OID",
	}
	TypeAnnotationCode_value = map[string]int32{
		"TYPE_ANNOTATION_CODE_UNSPECIFIED": 0,
		"PG_NUMERIC":                       2,
		"PG_JSONB":                         3,
		"PG_OID":                           4,
	}
)

var File_google_spanner_v1_change_stream_proto protoreflect.FileDescriptor

var File_google_spanner_v1_commit_response_proto protoreflect.FileDescriptor

var File_google_spanner_v1_keys_proto protoreflect.FileDescriptor

var File_google_spanner_v1_mutation_proto protoreflect.FileDescriptor

var File_google_spanner_v1_query_plan_proto protoreflect.FileDescriptor

var File_google_spanner_v1_result_set_proto protoreflect.FileDescriptor

var File_google_spanner_v1_spanner_proto protoreflect.FileDescriptor

var File_google_spanner_v1_transaction_proto protoreflect.FileDescriptor

var File_google_spanner_v1_type_proto protoreflect.FileDescriptor

func RegisterSpannerServer(s *grpc.Server, srv SpannerServer)

type BatchCreateSessionsRequest struct {

	// Required. The database in which the new sessions are created.
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	// Parameters to be applied to each created session.
	SessionTemplate *Session `protobuf:"bytes,2,opt,name=session_template,json=sessionTemplate,proto3" json:"session_template,omitempty"`
	// Required. The number of sessions to be created in this batch call.
	// The API may return fewer than the requested number of sessions. If a
	// specific number of sessions are desired, the client can make additional
	// calls to BatchCreateSessions (adjusting
	// [session_count][google.spanner.v1.BatchCreateSessionsRequest.session_count]
	// as necessary).
	SessionCount int32 `protobuf:"varint,3,opt,name=session_count,json=sessionCount,proto3" json:"session_count,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *BatchCreateSessionsRequest) GetDatabase() string

func (x *BatchCreateSessionsRequest) GetSessionCount() int32

func (x *BatchCreateSessionsRequest) GetSessionTemplate() *Session

func (*BatchCreateSessionsRequest) ProtoMessage()

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

func (x *BatchCreateSessionsRequest) Reset()

func (x *BatchCreateSessionsRequest) String() string

type BatchCreateSessionsResponse struct {

	// The freshly created sessions.
	Session []*Session `protobuf:"bytes,1,rep,name=session,proto3" json:"session,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *BatchCreateSessionsResponse) GetSession() []*Session

func (*BatchCreateSessionsResponse) ProtoMessage()

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

func (x *BatchCreateSessionsResponse) Reset()

func (x *BatchCreateSessionsResponse) String() string

type BatchWriteRequest struct {

	// Required. The session in which the batch request is to be run.
	Session string `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	// Common options for this request.
	RequestOptions *RequestOptions `protobuf:"bytes,3,opt,name=request_options,json=requestOptions,proto3" json:"request_options,omitempty"`
	// Required. The groups of mutations to be applied.
	MutationGroups []*BatchWriteRequest_MutationGroup `protobuf:"bytes,4,rep,name=mutation_groups,json=mutationGroups,proto3" json:"mutation_groups,omitempty"`
	// Optional. When `exclude_txn_from_change_streams` is set to `true`:
	//   - Mutations from all transactions in this batch write operation will not
	//     be recorded in change streams with DDL option `allow_txn_exclusion=true`
	//     that are tracking columns modified by these transactions.
	//   - Mutations from all transactions in this batch write operation will be
	//     recorded in change streams with DDL option `allow_txn_exclusion=false or
	//     not set` that are tracking columns modified by these transactions.
	//
	// When `exclude_txn_from_change_streams` is set to `false` or not set,
	// mutations from all transactions in this batch write operation will be
	// recorded in all change streams that are tracking columns modified by these
	// transactions.
	ExcludeTxnFromChangeStreams bool `protobuf:"varint,5,opt,name=exclude_txn_from_change_streams,json=excludeTxnFromChangeStreams,proto3" json:"exclude_txn_from_change_streams,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *BatchWriteRequest) GetExcludeTxnFromChangeStreams() bool

func (x *BatchWriteRequest) GetMutationGroups() []*BatchWriteRequest_MutationGroup

func (x *BatchWriteRequest) GetRequestOptions() *RequestOptions

func (x *BatchWriteRequest) GetSession() string

func (*BatchWriteRequest) ProtoMessage()

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

func (x *BatchWriteRequest) Reset()

func (x *BatchWriteRequest) String() string

type BatchWriteRequest_MutationGroup struct {

	// Required. The mutations in this group.
	Mutations []*Mutation `protobuf:"bytes,1,rep,name=mutations,proto3" json:"mutations,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *BatchWriteRequest_MutationGroup) GetMutations() []*Mutation

func (*BatchWriteRequest_MutationGroup) ProtoMessage()

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

func (x *BatchWriteRequest_MutationGroup) Reset()

func (x *BatchWriteRequest_MutationGroup) String() string

type BatchWriteResponse struct {

	// The mutation groups applied in this batch. The values index into the
	// `mutation_groups` field in the corresponding `BatchWriteRequest`.
	Indexes []int32 `protobuf:"varint,1,rep,packed,name=indexes,proto3" json:"indexes,omitempty"`
	// An `OK` status indicates success. Any other status indicates a failure.
	Status *status.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// The commit timestamp of the transaction that applied this batch.
	// Present if `status` is `OK`, absent otherwise.
	CommitTimestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=commit_timestamp,json=commitTimestamp,proto3" json:"commit_timestamp,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *BatchWriteResponse) GetCommitTimestamp() *timestamppb.Timestamp

func (x *BatchWriteResponse) GetIndexes() []int32

func (x *BatchWriteResponse) GetStatus() *status.Status

func (*BatchWriteResponse) ProtoMessage()

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

func (x *BatchWriteResponse) Reset()

func (x *BatchWriteResponse) String() string

type BeginTransactionRequest struct {

	// Required. The session in which the transaction runs.
	Session string `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	// Required. Options for the new transaction.
	Options *TransactionOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// Common options for this request.
	// Priority is ignored for this request. Setting the priority in this
	// request_options struct will not do anything. To set the priority for a
	// transaction, set it on the reads and writes that are part of this
	// transaction instead.
	RequestOptions *RequestOptions `protobuf:"bytes,3,opt,name=request_options,json=requestOptions,proto3" json:"request_options,omitempty"`
	// Optional. Required for read-write transactions on a multiplexed session
	// that commit mutations but do not perform any reads or queries. Clients
	// should randomly select one of the mutations from the mutation set and send
	// it as a part of this request.
	// This feature is not yet supported and will result in an UNIMPLEMENTED
	// error.
	MutationKey *Mutation `protobuf:"bytes,4,opt,name=mutation_key,json=mutationKey,proto3" json:"mutation_key,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *BeginTransactionRequest) GetMutationKey() *Mutation

func (x *BeginTransactionRequest) GetOptions() *TransactionOptions

func (x *BeginTransactionRequest) GetRequestOptions() *RequestOptions

func (x *BeginTransactionRequest) GetSession() string

func (*BeginTransactionRequest) ProtoMessage()

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

func (x *BeginTransactionRequest) Reset()

func (x *BeginTransactionRequest) String() string

type ChangeStreamRecord struct {

	// One of the change stream subrecords.
	//
	// Types that are assignable to Record:
	//
	//	*ChangeStreamRecord_DataChangeRecord_
	//	*ChangeStreamRecord_HeartbeatRecord_
	//	*ChangeStreamRecord_PartitionStartRecord_
	//	*ChangeStreamRecord_PartitionEndRecord_
	//	*ChangeStreamRecord_PartitionEventRecord_
	Record isChangeStreamRecord_Record `protobuf_oneof:"record"`
	// contains filtered or unexported fields
}

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

func (x *ChangeStreamRecord) GetDataChangeRecord() *ChangeStreamRecord_DataChangeRecord

func (x *ChangeStreamRecord) GetHeartbeatRecord() *ChangeStreamRecord_HeartbeatRecord

func (x *ChangeStreamRecord) GetPartitionEndRecord() *ChangeStreamRecord_PartitionEndRecord

func (x *ChangeStreamRecord) GetPartitionEventRecord() *ChangeStreamRecord_PartitionEventRecord

func (x *ChangeStreamRecord) GetPartitionStartRecord() *ChangeStreamRecord_PartitionStartRecord

func (m *ChangeStreamRecord) GetRecord() isChangeStreamRecord_Record

func (*ChangeStreamRecord) ProtoMessage()

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

func (x *ChangeStreamRecord) Reset()

func (x *ChangeStreamRecord) String() string

type ChangeStreamRecord_DataChangeRecord struct {

	// Indicates the timestamp in which the change was committed.
	// DataChangeRecord.commit_timestamps,
	// PartitionStartRecord.start_timestamps,
	// PartitionEventRecord.commit_timestamps, and
	// PartitionEndRecord.end_timestamps can have the same value in the same
	// partition.
	CommitTimestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=commit_timestamp,json=commitTimestamp,proto3" json:"commit_timestamp,omitempty"`
	// Record sequence numbers are unique and monotonically increasing (but not
	// necessarily contiguous) for a specific timestamp across record
	// types in the same partition. To guarantee ordered processing, the reader
	// should process records (of potentially different types) in
	// record_sequence order for a specific timestamp in the same partition.
	//
	// The record sequence number ordering across partitions is only meaningful
	// in the context of a specific transaction. Record sequence numbers are
	// unique across partitions for a specific transaction. Sort the
	// DataChangeRecords for the same
	// [server_transaction_id][google.spanner.v1.ChangeStreamRecord.DataChangeRecord.server_transaction_id]
	// by
	// [record_sequence][google.spanner.v1.ChangeStreamRecord.DataChangeRecord.record_sequence]
	// to reconstruct the ordering of the changes within the transaction.
	RecordSequence string `protobuf:"bytes,2,opt,name=record_sequence,json=recordSequence,proto3" json:"record_sequence,omitempty"`
	// Provides a globally unique string that represents the transaction in
	// which the change was committed. Multiple transactions can have the same
	// commit timestamp, but each transaction has a unique
	// server_transaction_id.
	ServerTransactionId string `protobuf:"bytes,3,opt,name=server_transaction_id,json=serverTransactionId,proto3" json:"server_transaction_id,omitempty"`
	// Indicates whether this is the last record for a transaction in the
	//
	//	current partition. Clients can use this field to determine when all
	//	records for a transaction in the current partition have been received.
	IsLastRecordInTransactionInPartition bool `protobuf:"varint,4,opt,name=is_last_record_in_transaction_in_partition,json=isLastRecordInTransactionInPartition,proto3" json:"is_last_record_in_transaction_in_partition,omitempty"`
	// Name of the table affected by the change.
	Table string `protobuf:"bytes,5,opt,name=table,proto3" json:"table,omitempty"`
	// Provides metadata describing the columns associated with the
	// [mods][google.spanner.v1.ChangeStreamRecord.DataChangeRecord.mods] listed
	// below.
	ColumnMetadata []*ChangeStreamRecord_DataChangeRecord_ColumnMetadata `protobuf:"bytes,6,rep,name=column_metadata,json=columnMetadata,proto3" json:"column_metadata,omitempty"`
	// Describes the changes that were made.
	Mods []*ChangeStreamRecord_DataChangeRecord_Mod `protobuf:"bytes,7,rep,name=mods,proto3" json:"mods,omitempty"`
	// Describes the type of change.
	ModType ChangeStreamRecord_DataChangeRecord_ModType `protobuf:"varint,8,opt,name=mod_type,json=modType,proto3,enum=google.spanner.v1.ChangeStreamRecord_DataChangeRecord_ModType" json:"mod_type,omitempty"`
	// Describes the value capture type that was specified in the change stream
	// configuration when this change was captured.
	ValueCaptureType ChangeStreamRecord_DataChangeRecord_ValueCaptureType `protobuf:"varint,9,opt,name=value_capture_type,json=valueCaptureType,proto3,enum=google.spanner.v1.ChangeStreamRecord_DataChangeRecord_ValueCaptureType" json:"value_capture_type,omitempty"`
	// Indicates the number of data change records that are part of this
	// transaction across all change stream partitions. This value can be used
	// to assemble all the records associated with a particular transaction.
	NumberOfRecordsInTransaction int32 `protobuf:"varint,10,opt,name=number_of_records_in_transaction,json=numberOfRecordsInTransaction,proto3" json:"number_of_records_in_transaction,omitempty"`
	// Indicates the number of partitions that return data change records for
	// this transaction. This value can be helpful in assembling all records
	// associated with a particular transaction.
	NumberOfPartitionsInTransaction int32 `protobuf:"varint,11,opt,name=number_of_partitions_in_transaction,json=numberOfPartitionsInTransaction,proto3" json:"number_of_partitions_in_transaction,omitempty"`
	// Indicates the transaction tag associated with this transaction.
	TransactionTag string `protobuf:"bytes,12,opt,name=transaction_tag,json=transactionTag,proto3" json:"transaction_tag,omitempty"`
	// Indicates whether the transaction is a system transaction. System
	// transactions include those issued by time-to-live (TTL), column backfill,
	// etc.
	IsSystemTransaction bool `protobuf:"varint,13,opt,name=is_system_transaction,json=isSystemTransaction,proto3" json:"is_system_transaction,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *ChangeStreamRecord_DataChangeRecord) GetColumnMetadata() []*ChangeStreamRecord_DataChangeRecord_ColumnMetadata

func (x *ChangeStreamRecord_DataChangeRecord) GetCommitTimestamp() *timestamppb.Timestamp

func (x *ChangeStreamRecord_DataChangeRecord) GetIsLastRecordInTransactionInPartition() bool

func (x *ChangeStreamRecord_DataChangeRecord) GetIsSystemTransaction() bool

func (x *ChangeStreamRecord_DataChangeRecord) GetModType() ChangeStreamRecord_DataChangeRecord_ModType

func (x *ChangeStreamRecord_DataChangeRecord) GetMods() []*ChangeStreamRecord_DataChangeRecord_Mod

func (x *ChangeStreamRecord_DataChangeRecord) GetNumberOfPartitionsInTransaction() int32

func (x *ChangeStreamRecord_DataChangeRecord) GetNumberOfRecordsInTransaction() int32

func (x *ChangeStreamRecord_DataChangeRecord) GetRecordSequence() string

func (x *ChangeStreamRecord_DataChangeRecord) GetServerTransactionId() string

func (x *ChangeStreamRecord_DataChangeRecord) GetTable() string

func (x *ChangeStreamRecord_DataChangeRecord) GetTransactionTag() string

func (x *ChangeStreamRecord_DataChangeRecord) GetValueCaptureType() ChangeStreamRecord_DataChangeRecord_ValueCaptureType

func (*ChangeStreamRecord_DataChangeRecord) ProtoMessage()

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

func (x *ChangeStreamRecord_DataChangeRecord) Reset()

func (x *ChangeStreamRecord_DataChangeRecord) String() string

type ChangeStreamRecord_DataChangeRecord_ struct {
	// Data change record describing a data change for a change stream
	// partition.
	DataChangeRecord *ChangeStreamRecord_DataChangeRecord `protobuf:"bytes,1,opt,name=data_change_record,json=dataChangeRecord,proto3,oneof"`
}

type ChangeStreamRecord_DataChangeRecord_ColumnMetadata struct {

	// Name of the column.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Type of the column.
	Type *Type `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// Indicates 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"`
	// Ordinal position of the column based on the original table definition
	// in the schema starting with a value of 1.
	OrdinalPosition int64 `protobuf:"varint,4,opt,name=ordinal_position,json=ordinalPosition,proto3" json:"ordinal_position,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *ChangeStreamRecord_DataChangeRecord_ColumnMetadata) GetIsPrimaryKey() bool

func (x *ChangeStreamRecord_DataChangeRecord_ColumnMetadata) GetName() string

func (x *ChangeStreamRecord_DataChangeRecord_ColumnMetadata) GetOrdinalPosition() int64

func (x *ChangeStreamRecord_DataChangeRecord_ColumnMetadata) GetType() *Type

func (*ChangeStreamRecord_DataChangeRecord_ColumnMetadata) ProtoMessage()

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

func (x *ChangeStreamRecord_DataChangeRecord_ColumnMetadata) Reset()

func (x *ChangeStreamRecord_DataChangeRecord_ColumnMetadata) String() string

type ChangeStreamRecord_DataChangeRecord_Mod struct {

	// Returns the value of the primary key of the modified row.
	Keys []*ChangeStreamRecord_DataChangeRecord_ModValue `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// Returns the old values before the change for the modified columns.
	// Always empty for
	// [INSERT][google.spanner.v1.ChangeStreamRecord.DataChangeRecord.ModType.INSERT],
	// or if old values are not being captured specified by
	// [value_capture_type][google.spanner.v1.ChangeStreamRecord.DataChangeRecord.ValueCaptureType].
	OldValues []*ChangeStreamRecord_DataChangeRecord_ModValue `protobuf:"bytes,2,rep,name=old_values,json=oldValues,proto3" json:"old_values,omitempty"`
	// Returns the new values after the change for the modified columns.
	// Always empty for
	// [DELETE][google.spanner.v1.ChangeStreamRecord.DataChangeRecord.ModType.DELETE].
	NewValues []*ChangeStreamRecord_DataChangeRecord_ModValue `protobuf:"bytes,3,rep,name=new_values,json=newValues,proto3" json:"new_values,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *ChangeStreamRecord_DataChangeRecord_Mod) GetKeys() []*ChangeStreamRecord_DataChangeRecord_ModValue

func (x *ChangeStreamRecord_DataChangeRecord_Mod) GetNewValues() []*ChangeStreamRecord_DataChangeRecord_ModValue

func (x *ChangeStreamRecord_DataChangeRecord_Mod) GetOldValues() []*ChangeStreamRecord_DataChangeRecord_ModValue

func (*ChangeStreamRecord_DataChangeRecord_Mod) ProtoMessage()

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

func (x *ChangeStreamRecord_DataChangeRecord_Mod) Reset()

func (x *ChangeStreamRecord_DataChangeRecord_Mod) String() string

type ChangeStreamRecord_DataChangeRecord_ModType int32

const (
	// Not specified.
	ChangeStreamRecord_DataChangeRecord_MOD_TYPE_UNSPECIFIED ChangeStreamRecord_DataChangeRecord_ModType = 0
	// Indicates data was inserted.
	ChangeStreamRecord_DataChangeRecord_INSERT ChangeStreamRecord_DataChangeRecord_ModType = 10
	// Indicates existing data was updated.
	ChangeStreamRecord_DataChangeRecord_UPDATE ChangeStreamRecord_DataChangeRecord_ModType = 20
	// Indicates existing data was deleted.
	ChangeStreamRecord_DataChangeRecord_DELETE ChangeStreamRecord_DataChangeRecord_ModType = 30
)

func (ChangeStreamRecord_DataChangeRecord_ModType) Descriptor() protoreflect.EnumDescriptor

func (x ChangeStreamRecord_DataChangeRecord_ModType) Enum() *ChangeStreamRecord_DataChangeRecord_ModType

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

func (x ChangeStreamRecord_DataChangeRecord_ModType) Number() protoreflect.EnumNumber

func (x ChangeStreamRecord_DataChangeRecord_ModType) String() string

func (ChangeStreamRecord_DataChangeRecord_ModType) Type() protoreflect.EnumType

type ChangeStreamRecord_DataChangeRecord_ModValue struct {

	// Index within the repeated
	// [column_metadata][google.spanner.v1.ChangeStreamRecord.DataChangeRecord.column_metadata]
	// field, to obtain the column metadata for the column that was modified.
	ColumnMetadataIndex int32 `protobuf:"varint,1,opt,name=column_metadata_index,json=columnMetadataIndex,proto3" json:"column_metadata_index,omitempty"`
	// The value of the column.
	Value *structpb.Value `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *ChangeStreamRecord_DataChangeRecord_ModValue) GetColumnMetadataIndex() int32

func (x *ChangeStreamRecord_DataChangeRecord_ModValue) GetValue() *structpb.Value

func (*ChangeStreamRecord_DataChangeRecord_ModValue) ProtoMessage()

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

func (x *ChangeStreamRecord_DataChangeRecord_ModValue) Reset()

func (x *ChangeStreamRecord_DataChangeRecord_ModValue) String() string

type ChangeStreamRecord_DataChangeRecord_ValueCaptureType int32

const (
	// Not specified.
	ChangeStreamRecord_DataChangeRecord_VALUE_CAPTURE_TYPE_UNSPECIFIED ChangeStreamRecord_DataChangeRecord_ValueCaptureType = 0
	// Records both old and new values of the modified watched columns.
	ChangeStreamRecord_DataChangeRecord_OLD_AND_NEW_VALUES ChangeStreamRecord_DataChangeRecord_ValueCaptureType = 10
	// Records only new values of the modified watched columns.
	ChangeStreamRecord_DataChangeRecord_NEW_VALUES ChangeStreamRecord_DataChangeRecord_ValueCaptureType = 20
	// Records new values of all watched columns, including modified and
	// unmodified columns.
	ChangeStreamRecord_DataChangeRecord_NEW_ROW ChangeStreamRecord_DataChangeRecord_ValueCaptureType = 30
	// Records the new values of all watched columns, including modified and
	// unmodified columns. Also records the old values of the modified
	// columns.
	ChangeStreamRecord_DataChangeRecord_NEW_ROW_AND_OLD_VALUES ChangeStreamRecord_DataChangeRecord_ValueCaptureType = 40
)

func (ChangeStreamRecord_DataChangeRecord_ValueCaptureType) Descriptor() protoreflect.EnumDescriptor

func (x ChangeStreamRecord_DataChangeRecord_ValueCaptureType) Enum() *ChangeStreamRecord_DataChangeRecord_ValueCaptureType

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

func (x ChangeStreamRecord_DataChangeRecord_ValueCaptureType) Number() protoreflect.EnumNumber

func (x ChangeStreamRecord_DataChangeRecord_ValueCaptureType) String() string

func (ChangeStreamRecord_DataChangeRecord_ValueCaptureType) Type() protoreflect.EnumType

type ChangeStreamRecord_HeartbeatRecord struct {

	// Indicates the timestamp at which the query has returned all the records
	// in the change stream partition with timestamp <= heartbeat="" timestamp.="" the="" heartbeat="" timestamp="" will="" not="" be="" the="" same="" as="" the="" timestamps="" of="" other="" record="" types="" in="" the="" same="" partition.="" timestamp="">timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *ChangeStreamRecord_HeartbeatRecord) GetTimestamp() *timestamppb.Timestamp

func (*ChangeStreamRecord_HeartbeatRecord) ProtoMessage()

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

func (x *ChangeStreamRecord_HeartbeatRecord) Reset()

func (x *ChangeStreamRecord_HeartbeatRecord) String() string

type ChangeStreamRecord_HeartbeatRecord_ struct {
	// Heartbeat record describing a heartbeat for a change stream partition.
	HeartbeatRecord *ChangeStreamRecord_HeartbeatRecord `protobuf:"bytes,2,opt,name=heartbeat_record,json=heartbeatRecord,proto3,oneof"`
}

type ChangeStreamRecord_PartitionEndRecord struct {

	// End timestamp at which the change stream partition is terminated. All
	// changes generated by this partition will have timestamps <= end_timestamp.="" datachangerecord.commit_timestamps,="" partitionstartrecord.start_timestamps,="" partitioneventrecord.commit_timestamps,="" and="" partitionendrecord.end_timestamps="" can="" have="" the="" same="" value="" in="" the="" same="" partition.="" partitionendrecord="" is="" the="" last="" record="" returned="" for="" a="" partition.="" endtimestamp="">timestamppb.Timestamp `protobuf:"bytes,1,opt,name=end_timestamp,json=endTimestamp,proto3" json:"end_timestamp,omitempty"`
	// Record sequence numbers are unique and monotonically increasing (but not
	// necessarily contiguous) for a specific timestamp across record
	// types in the same partition. To guarantee ordered processing, the reader
	// should process records (of potentially different types) in
	// record_sequence order for a specific timestamp in the same partition.
	RecordSequence string `protobuf:"bytes,2,opt,name=record_sequence,json=recordSequence,proto3" json:"record_sequence,omitempty"`
	// Unique partition identifier describing the terminated change stream
	// partition.
	// [partition_token][google.spanner.v1.ChangeStreamRecord.PartitionEndRecord.partition_token]
	// is equal to the partition token of the change stream partition currently
	// queried to return this PartitionEndRecord.
	PartitionToken string `protobuf:"bytes,3,opt,name=partition_token,json=partitionToken,proto3" json:"partition_token,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *ChangeStreamRecord_PartitionEndRecord) GetEndTimestamp() *timestamppb.Timestamp

func (x *ChangeStreamRecord_PartitionEndRecord) GetPartitionToken() string

func (x *ChangeStreamRecord_PartitionEndRecord) GetRecordSequence() string

func (*ChangeStreamRecord_PartitionEndRecord) ProtoMessage()

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

func (x *ChangeStreamRecord_PartitionEndRecord) Reset()

func (x *ChangeStreamRecord_PartitionEndRecord) String() string

type ChangeStreamRecord_PartitionEndRecord_ struct {
	// Partition end record describing a terminated change stream partition.
	PartitionEndRecord *ChangeStreamRecord_PartitionEndRecord `protobuf:"bytes,4,opt,name=partition_end_record,json=partitionEndRecord,proto3,oneof"`
}

type ChangeStreamRecord_PartitionEventRecord struct {

	// Indicates the commit timestamp at which the key range change occurred.
	// DataChangeRecord.commit_timestamps,
	// PartitionStartRecord.start_timestamps,
	// PartitionEventRecord.commit_timestamps, and
	// PartitionEndRecord.end_timestamps can have the same value in the same
	// partition.
	CommitTimestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=commit_timestamp,json=commitTimestamp,proto3" json:"commit_timestamp,omitempty"`
	// Record sequence numbers are unique and monotonically increasing (but not
	// necessarily contiguous) for a specific timestamp across record
	// types in the same partition. To guarantee ordered processing, the reader
	// should process records (of potentially different types) in
	// record_sequence order for a specific timestamp in the same partition.
	RecordSequence string `protobuf:"bytes,2,opt,name=record_sequence,json=recordSequence,proto3" json:"record_sequence,omitempty"`
	// Unique partition identifier describing the partition this event
	// occurred on.
	// [partition_token][google.spanner.v1.ChangeStreamRecord.PartitionEventRecord.partition_token]
	// is equal to the partition token of the change stream partition currently
	// queried to return this PartitionEventRecord.
	PartitionToken string `protobuf:"bytes,3,opt,name=partition_token,json=partitionToken,proto3" json:"partition_token,omitempty"`
	// Set when one or more key ranges are moved into the change stream
	// partition identified by
	// [partition_token][google.spanner.v1.ChangeStreamRecord.PartitionEventRecord.partition_token].
	//
	// Example: Two key ranges are moved into partition (P1) from partition (P2)
	// and partition (P3) in a single transaction at timestamp T.
	//
	// The PartitionEventRecord returned in P1 will reflect the move as:
	//
	//	PartitionEventRecord {
	//	  commit_timestamp: T
	//	  partition_token: "P1"
	//	  move_in_events {
	//	    source_partition_token: "P2"
	//	  }
	//	  move_in_events {
	//	    source_partition_token: "P3"
	//	  }
	//	}
	//
	// The PartitionEventRecord returned in P2 will reflect the move as:
	//
	//	PartitionEventRecord {
	//	  commit_timestamp: T
	//	  partition_token: "P2"
	//	  move_out_events {
	//	    destination_partition_token: "P1"
	//	  }
	//	}
	//
	// The PartitionEventRecord returned in P3 will reflect the move as:
	//
	//	PartitionEventRecord {
	//	  commit_timestamp: T
	//	  partition_token: "P3"
	//	  move_out_events {
	//	    destination_partition_token: "P1"
	//	  }
	//	}
	MoveInEvents []*ChangeStreamRecord_PartitionEventRecord_MoveInEvent `protobuf:"bytes,4,rep,name=move_in_events,json=moveInEvents,proto3" json:"move_in_events,omitempty"`
	// Set when one or more key ranges are moved out of the change stream
	// partition identified by
	// [partition_token][google.spanner.v1.ChangeStreamRecord.PartitionEventRecord.partition_token].
	//
	// Example: Two key ranges are moved out of partition (P1) to partition (P2)
	// and partition (P3) in a single transaction at timestamp T.
	//
	// The PartitionEventRecord returned in P1 will reflect the move as:
	//
	//	PartitionEventRecord {
	//	  commit_timestamp: T
	//	  partition_token: "P1"
	//	  move_out_events {
	//	    destination_partition_token: "P2"
	//	  }
	//	  move_out_events {
	//	    destination_partition_token: "P3"
	//	  }
	//	}
	//
	// The PartitionEventRecord returned in P2 will reflect the move as:
	//
	//	PartitionEventRecord {
	//	  commit_timestamp: T
	//	  partition_token: "P2"
	//	  move_in_events {
	//	    source_partition_token: "P1"
	//	  }
	//	}
	//
	// The PartitionEventRecord returned in P3 will reflect the move as:
	//
	//	PartitionEventRecord {
	//	  commit_timestamp: T
	//	  partition_token: "P3"
	//	  move_in_events {
	//	    source_partition_token: "P1"
	//	  }
	//	}
	MoveOutEvents []*ChangeStreamRecord_PartitionEventRecord_MoveOutEvent `protobuf:"bytes,5,rep,name=move_out_events,json=moveOutEvents,proto3" json:"move_out_events,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *ChangeStreamRecord_PartitionEventRecord) GetCommitTimestamp() *timestamppb.Timestamp

func (x *ChangeStreamRecord_PartitionEventRecord) GetMoveInEvents() []*ChangeStreamRecord_PartitionEventRecord_MoveInEvent

func (x *ChangeStreamRecord_PartitionEventRecord) GetMoveOutEvents() []*ChangeStreamRecord_PartitionEventRecord_MoveOutEvent

func (x *ChangeStreamRecord_PartitionEventRecord) GetPartitionToken() string

func (x *ChangeStreamRecord_PartitionEventRecord) GetRecordSequence() string

func (*ChangeStreamRecord_PartitionEventRecord) ProtoMessage()

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

func (x *ChangeStreamRecord_PartitionEventRecord) Reset()

func (x *ChangeStreamRecord_PartitionEventRecord) String() string

type ChangeStreamRecord_PartitionEventRecord_ struct {
	// Partition event record describing key range changes for a change stream
	// partition.
	PartitionEventRecord *ChangeStreamRecord_PartitionEventRecord `protobuf:"bytes,5,opt,name=partition_event_record,json=partitionEventRecord,proto3,oneof"`
}

type ChangeStreamRecord_PartitionEventRecord_MoveInEvent struct {

	// An unique partition identifier describing the source change stream
	// partition that recorded changes for the key range that is moving
	// into this partition.
	SourcePartitionToken string `protobuf:"bytes,1,opt,name=source_partition_token,json=sourcePartitionToken,proto3" json:"source_partition_token,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *ChangeStreamRecord_PartitionEventRecord_MoveInEvent) GetSourcePartitionToken() string

func (*ChangeStreamRecord_PartitionEventRecord_MoveInEvent) ProtoMessage()

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

func (x *ChangeStreamRecord_PartitionEventRecord_MoveInEvent) Reset()

func (x *ChangeStreamRecord_PartitionEventRecord_MoveInEvent) String() string

type ChangeStreamRecord_PartitionEventRecord_MoveOutEvent struct {

	// An unique partition identifier describing the destination change
	// stream partition that will record changes for the key range that is
	// moving out of this partition.
	DestinationPartitionToken string `protobuf:"bytes,1,opt,name=destination_partition_token,json=destinationPartitionToken,proto3" json:"destination_partition_token,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *ChangeStreamRecord_PartitionEventRecord_MoveOutEvent) GetDestinationPartitionToken() string

func (*ChangeStreamRecord_PartitionEventRecord_MoveOutEvent) ProtoMessage()

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

func (x *ChangeStreamRecord_PartitionEventRecord_MoveOutEvent) Reset()

func (x *ChangeStreamRecord_PartitionEventRecord_MoveOutEvent) String() string

type ChangeStreamRecord_PartitionStartRecord struct {

	// Start timestamp at which the partitions should be queried to return
	// change stream records with timestamps >= start_timestamp.
	// DataChangeRecord.commit_timestamps,
	// PartitionStartRecord.start_timestamps,
	// PartitionEventRecord.commit_timestamps, and
	// PartitionEndRecord.end_timestamps can have the same value in the same
	// partition.
	StartTimestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start_timestamp,json=startTimestamp,proto3" json:"start_timestamp,omitempty"`
	// Record sequence numbers are unique and monotonically increasing (but not
	// necessarily contiguous) for a specific timestamp across record
	// types in the same partition. To guarantee ordered processing, the reader
	// should process records (of potentially different types) in
	// record_sequence order for a specific timestamp in the same partition.
	RecordSequence string `protobuf:"bytes,2,opt,name=record_sequence,json=recordSequence,proto3" json:"record_sequence,omitempty"`
	// Unique partition identifiers to be used in queries.
	PartitionTokens []string `protobuf:"bytes,3,rep,name=partition_tokens,json=partitionTokens,proto3" json:"partition_tokens,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *ChangeStreamRecord_PartitionStartRecord) GetPartitionTokens() []string

func (x *ChangeStreamRecord_PartitionStartRecord) GetRecordSequence() string

func (x *ChangeStreamRecord_PartitionStartRecord) GetStartTimestamp() *timestamppb.Timestamp

func (*ChangeStreamRecord_PartitionStartRecord) ProtoMessage()

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

func (x *ChangeStreamRecord_PartitionStartRecord) Reset()

func (x *ChangeStreamRecord_PartitionStartRecord) String() string

type ChangeStreamRecord_PartitionStartRecord_ struct {
	// Partition start record describing a new change stream partition.
	PartitionStartRecord *ChangeStreamRecord_PartitionStartRecord `protobuf:"bytes,3,opt,name=partition_start_record,json=partitionStartRecord,proto3,oneof"`
}

type CommitRequest struct {

	// Required. The session in which the transaction to be committed is running.
	Session string `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	// Required. The transaction in which to commit.
	//
	// Types that are assignable to Transaction:
	//
	//	*CommitRequest_TransactionId
	//	*CommitRequest_SingleUseTransaction
	Transaction isCommitRequest_Transaction `protobuf_oneof:"transaction"`
	// The mutations to be executed when this transaction commits. All
	// mutations are applied atomically, in the order they appear in
	// this list.
	Mutations []*Mutation `protobuf:"bytes,4,rep,name=mutations,proto3" json:"mutations,omitempty"`
	// If `true`, then statistics related to the transaction will be included in
	// the [CommitResponse][google.spanner.v1.CommitResponse.commit_stats].
	// Default value is `false`.
	ReturnCommitStats bool `protobuf:"varint,5,opt,name=return_commit_stats,json=returnCommitStats,proto3" json:"return_commit_stats,omitempty"`
	// Optional. The amount of latency this request is willing to incur in order
	// to improve throughput. If this field is not set, Spanner assumes requests
	// are relatively latency sensitive and automatically determines an
	// appropriate delay time. You can specify a batching delay value between 0
	// and 500 ms.
	MaxCommitDelay *durationpb.Duration `protobuf:"bytes,8,opt,name=max_commit_delay,json=maxCommitDelay,proto3" json:"max_commit_delay,omitempty"`
	// Common options for this request.
	RequestOptions *RequestOptions `protobuf:"bytes,6,opt,name=request_options,json=requestOptions,proto3" json:"request_options,omitempty"`
	// Optional. If the read-write transaction was executed on a multiplexed
	// session, the precommit token with the highest sequence number received in
	// this transaction attempt, should be included here. Failing to do so will
	// result in a FailedPrecondition error.
	// This feature is not yet supported and will result in an UNIMPLEMENTED
	// error.
	PrecommitToken *MultiplexedSessionPrecommitToken `protobuf:"bytes,9,opt,name=precommit_token,json=precommitToken,proto3" json:"precommit_token,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *CommitRequest) GetMaxCommitDelay() *durationpb.Duration

func (x *CommitRequest) GetMutations() []*Mutation

func (x *CommitRequest) GetPrecommitToken() *MultiplexedSessionPrecommitToken

func (x *CommitRequest) GetRequestOptions() *RequestOptions

func (x *CommitRequest) GetReturnCommitStats() bool

func (x *CommitRequest) GetSession() string

func (x *CommitRequest) GetSingleUseTransaction() *TransactionOptions

func (m *CommitRequest) GetTransaction() isCommitRequest_Transaction

func (x *CommitRequest) GetTransactionId() []byte

func (*CommitRequest) ProtoMessage()

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

func (x *CommitRequest) Reset()

func (x *CommitRequest) String() string

type CommitRequest_SingleUseTransaction struct {
	// Execute mutations in a temporary transaction. Note that unlike
	// commit of a previously-started transaction, commit with a
	// temporary transaction is non-idempotent. That is, if the
	// `CommitRequest` is sent to Cloud Spanner more than once (for
	// instance, due to retries in the application, or in the
	// transport library), it is possible that the mutations are
	// executed more than once. If this is undesirable, use
	// [BeginTransaction][google.spanner.v1.Spanner.BeginTransaction] and
	// [Commit][google.spanner.v1.Spanner.Commit] instead.
	SingleUseTransaction *TransactionOptions `protobuf:"bytes,3,opt,name=single_use_transaction,json=singleUseTransaction,proto3,oneof"`
}

type CommitRequest_TransactionId struct {
	// Commit a previously-started transaction.
	TransactionId []byte `protobuf:"bytes,2,opt,name=transaction_id,json=transactionId,proto3,oneof"`
}

type CommitResponse struct {

	// The Cloud Spanner timestamp at which the transaction committed.
	CommitTimestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=commit_timestamp,json=commitTimestamp,proto3" json:"commit_timestamp,omitempty"`
	// The statistics about this `Commit`. Not returned by default.
	// For more information, see
	// [CommitRequest.return_commit_stats][google.spanner.v1.CommitRequest.return_commit_stats].
	CommitStats *CommitResponse_CommitStats `protobuf:"bytes,2,opt,name=commit_stats,json=commitStats,proto3" json:"commit_stats,omitempty"`
	// You must examine and retry the commit if the following is populated.
	//
	// Types that are assignable to MultiplexedSessionRetry:
	//
	//	*CommitResponse_PrecommitToken
	MultiplexedSessionRetry isCommitResponse_MultiplexedSessionRetry `protobuf_oneof:"MultiplexedSessionRetry"`
	// If `TransactionOptions.isolation_level` is set to
	// `IsolationLevel.REPEATABLE_READ`, then the snapshot timestamp is the
	// timestamp at which all reads in the transaction ran. This timestamp is
	// never returned.
	SnapshotTimestamp *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=snapshot_timestamp,json=snapshotTimestamp,proto3" json:"snapshot_timestamp,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *CommitResponse) GetCommitStats() *CommitResponse_CommitStats

func (x *CommitResponse) GetCommitTimestamp() *timestamppb.Timestamp

func (m *CommitResponse) GetMultiplexedSessionRetry() isCommitResponse_MultiplexedSessionRetry

func (x *CommitResponse) GetPrecommitToken() *MultiplexedSessionPrecommitToken

func (x *CommitResponse) GetSnapshotTimestamp() *timestamppb.Timestamp

func (*CommitResponse) ProtoMessage()

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

func (x *CommitResponse) Reset()

func (x *CommitResponse) String() string

type CommitResponse_CommitStats struct {

	// The total number of mutations for the transaction. Knowing the
	// `mutation_count` value can help you maximize the number of mutations
	// in a transaction and minimize the number of API round trips. You can
	// also monitor this value to prevent transactions from exceeding the system
	// [limit](https://cloud.google.com/spanner/quotas#limits_for_creating_reading_updating_and_deleting_data).
	// If the number of mutations exceeds the limit, the server returns
	// [INVALID_ARGUMENT](https://cloud.google.com/spanner/docs/reference/rest/v1/Code#ENUM_VALUES.INVALID_ARGUMENT).
	MutationCount int64 `protobuf:"varint,1,opt,name=mutation_count,json=mutationCount,proto3" json:"mutation_count,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *CommitResponse_CommitStats) GetMutationCount() int64

func (*CommitResponse_CommitStats) ProtoMessage()

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

func (x *CommitResponse_CommitStats) Reset()

func (x *CommitResponse_CommitStats) String() string

type CommitResponse_PrecommitToken struct {
	// If specified, transaction has not committed yet.
	// You must retry the commit with the new precommit token.
	PrecommitToken *MultiplexedSessionPrecommitToken `protobuf:"bytes,4,opt,name=precommit_token,json=precommitToken,proto3,oneof"`
}

type CreateSessionRequest struct {

	// Required. The database in which the new session is created.
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	// Required. The session to create.
	Session *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *CreateSessionRequest) GetDatabase() string

func (x *CreateSessionRequest) GetSession() *Session

func (*CreateSessionRequest) ProtoMessage()

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

func (x *CreateSessionRequest) Reset()

func (x *CreateSessionRequest) String() string

type DeleteSessionRequest struct {

	// Required. The name of the session to delete.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}