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

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",
	}
	ExecuteSqlRequest_QueryMode_value = map[string]int32{
		"NORMAL":  0,
		"PLAN":    1,
		"PROFILE": 2,
	}
)

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_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",
	}
	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,
	}
)

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_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 {
	Session string `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`

	RequestOptions *RequestOptions `protobuf:"bytes,3,opt,name=request_options,json=requestOptions,proto3" json:"request_options,omitempty"`

	MutationGroups []*BatchWriteRequest_MutationGroup `protobuf:"bytes,4,rep,name=mutation_groups,json=mutationGroups,proto3" json:"mutation_groups,omitempty"`

	ExcludeTxnFromChangeStreams bool "" /* 149 byte string literal not displayed */

}

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"`
	// contains filtered or unexported fields
}

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

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 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"`
	// contains filtered or unexported fields
}

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

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

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

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"`
	// contains filtered or unexported fields
}

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

func (x *CommitResponse) GetCommitStats() *CommitResponse_CommitStats

func (x *CommitResponse) GetCommitTimestamp() *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 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
}

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

func (x *DeleteSessionRequest) GetName() string

func (*DeleteSessionRequest) ProtoMessage()

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

func (x *DeleteSessionRequest) Reset()

func (x *DeleteSessionRequest) String() string

type DirectedReadOptions struct {

	// Required. At most one of either include_replicas or exclude_replicas
	// should be present in the message.
	//
	// Types that are assignable to Replicas:
	//
	//	*DirectedReadOptions_IncludeReplicas_
	//	*DirectedReadOptions_ExcludeReplicas_
	Replicas isDirectedReadOptions_Replicas `protobuf_oneof:"replicas"`
	// contains filtered or unexported fields
}

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

func (x *DirectedReadOptions) GetExcludeReplicas() *DirectedReadOptions_ExcludeReplicas

func (x *DirectedReadOptions) GetIncludeReplicas() *DirectedReadOptions_IncludeReplicas

func (m *DirectedReadOptions) GetReplicas() isDirectedReadOptions_Replicas

func (*DirectedReadOptions) ProtoMessage()

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

func (x *DirectedReadOptions) Reset()

func (x *DirectedReadOptions) String() string

type DirectedReadOptions_ExcludeReplicas struct {

	// The directed read replica selector.
	ReplicaSelections []*DirectedReadOptions_ReplicaSelection `protobuf:"bytes,1,rep,name=replica_selections,json=replicaSelections,proto3" json:"replica_selections,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *DirectedReadOptions_ExcludeReplicas) GetReplicaSelections() []*DirectedReadOptions_ReplicaSelection

func (*DirectedReadOptions_ExcludeReplicas) ProtoMessage()

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

func (x *DirectedReadOptions_ExcludeReplicas) Reset()

func (x *DirectedReadOptions_ExcludeReplicas) String() string

type DirectedReadOptions_ExcludeReplicas_ struct {
	// Exclude_replicas indicates that specified replicas should be excluded
	// from serving requests. Spanner will not route requests to the replicas
	// in this list.
	ExcludeReplicas *DirectedReadOptions_ExcludeReplicas `protobuf:"bytes,2,opt,name=exclude_replicas,json=excludeReplicas,proto3,oneof"`
}

type DirectedReadOptions_IncludeReplicas struct {

	// The directed read replica selector.
	ReplicaSelections []*DirectedReadOptions_ReplicaSelection `protobuf:"bytes,1,rep,name=replica_selections,json=replicaSelections,proto3" json:"replica_selections,omitempty"`
	// If true, Spanner will not route requests to a replica outside the
	// include_replicas list when all of the specified replicas are unavailable
	// or unhealthy. Default value is `false`.
	AutoFailoverDisabled bool `protobuf:"varint,2,opt,name=auto_failover_disabled,json=autoFailoverDisabled,proto3" json:"auto_failover_disabled,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *DirectedReadOptions_IncludeReplicas) GetAutoFailoverDisabled() bool

func (x *DirectedReadOptions_IncludeReplicas) GetReplicaSelections() []*DirectedReadOptions_ReplicaSelection

func (*DirectedReadOptions_IncludeReplicas) ProtoMessage()

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

func (x *DirectedReadOptions_IncludeReplicas) Reset()

func (x *DirectedReadOptions_IncludeReplicas) String() string

type DirectedReadOptions_IncludeReplicas_ struct {
	// Include_replicas indicates the order of replicas (as they appear in
	// this list) to process the request. If auto_failover_disabled is set to
	// true and all replicas are exhausted without finding a healthy replica,
	// Spanner will wait for a replica in the list to become available, requests
	// may fail due to `DEADLINE_EXCEEDED` errors.
	IncludeReplicas *DirectedReadOptions_IncludeReplicas `protobuf:"bytes,1,opt,name=include_replicas,json=includeReplicas,proto3,oneof"`
}

type DirectedReadOptions_ReplicaSelection struct {
	Location string `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`

	Type DirectedReadOptions_ReplicaSelection_Type "" /* 127 byte string literal not displayed */

}

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

func (x *DirectedReadOptions_ReplicaSelection) GetLocation() string

func (x *DirectedReadOptions_ReplicaSelection) GetType() DirectedReadOptions_ReplicaSelection_Type

func (*DirectedReadOptions_ReplicaSelection) ProtoMessage()

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

func (x *DirectedReadOptions_ReplicaSelection) Reset()

func (x *DirectedReadOptions_ReplicaSelection) String() string

type DirectedReadOptions_ReplicaSelection_Type int32

const (
	// Not specified.
	DirectedReadOptions_ReplicaSelection_TYPE_UNSPECIFIED DirectedReadOptions_ReplicaSelection_Type = 0
	// Read-write replicas support both reads and writes.
	DirectedReadOptions_ReplicaSelection_READ_WRITE DirectedReadOptions_ReplicaSelection_Type = 1
	// Read-only replicas only support reads (not writes).
	DirectedReadOptions_ReplicaSelection_READ_ONLY DirectedReadOptions_ReplicaSelection_Type = 2
)

func (DirectedReadOptions_ReplicaSelection_Type) Descriptor() protoreflect.EnumDescriptor

func (x DirectedReadOptions_ReplicaSelection_Type) Enum() *DirectedReadOptions_ReplicaSelection_Type

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

func (x DirectedReadOptions_ReplicaSelection_Type) Number() protoreflect.EnumNumber

func (x DirectedReadOptions_ReplicaSelection_Type) String() string

func (DirectedReadOptions_ReplicaSelection_Type) Type() protoreflect.EnumType

type ExecuteBatchDmlRequest struct {

	// Required. The session in which the DML statements should be performed.
	Session string `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	// Required. The transaction to use. Must be a read-write transaction.
	//
	// To protect against replays, single-use transactions are not supported. The
	// caller must either supply an existing transaction ID or begin a new
	// transaction.
	Transaction *TransactionSelector `protobuf:"bytes,2,opt,name=transaction,proto3" json:"transaction,omitempty"`
	// Required. The list of statements to execute in this batch. Statements are
	// executed serially, such that the effects of statement `i` are visible to
	// statement `i+1`. Each statement must be a DML statement. Execution stops at
	// the first failed statement; the remaining statements are not executed.
	//
	// Callers must provide at least one statement.
	Statements []*ExecuteBatchDmlRequest_Statement `protobuf:"bytes,3,rep,name=statements,proto3" json:"statements,omitempty"`
	// Required. A per-transaction sequence number used to identify this request.
	// This field makes each request idempotent such that if the request is
	// received multiple times, at most one will succeed.
	//
	// The sequence number must be monotonically increasing within the
	// transaction. If a request arrives for the first time with an out-of-order
	// sequence number, the transaction may be aborted. Replays of previously
	// handled requests will yield the same response as the first execution.
	Seqno int64 `protobuf:"varint,4,opt,name=seqno,proto3" json:"seqno,omitempty"`
	// Common options for this request.
	RequestOptions *RequestOptions `protobuf:"bytes,5,opt,name=request_options,json=requestOptions,proto3" json:"request_options,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *ExecuteBatchDmlRequest) GetRequestOptions() *RequestOptions

func (x *ExecuteBatchDmlRequest) GetSeqno() int64

func (x *ExecuteBatchDmlRequest) GetSession() string

func (x *ExecuteBatchDmlRequest) GetStatements() []*ExecuteBatchDmlRequest_Statement

func (x *ExecuteBatchDmlRequest) GetTransaction() *TransactionSelector

func (*ExecuteBatchDmlRequest) ProtoMessage()

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

func (x *ExecuteBatchDmlRequest) Reset()

func (x *ExecuteBatchDmlRequest) String() string

type ExecuteBatchDmlRequest_Statement struct {
	Sql string `protobuf:"bytes,1,opt,name=sql,proto3" json:"sql,omitempty"`

	Params *structpb.Struct `protobuf:"bytes,2,opt,name=params,proto3" json:"params,omitempty"`

	ParamTypes map[string]*Type "" /* 179 byte string literal not displayed */

}

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

func (x *ExecuteBatchDmlRequest_Statement) GetParamTypes() map[string]*Type

func (x *ExecuteBatchDmlRequest_Statement) GetParams() *structpb.Struct

func (x *ExecuteBatchDmlRequest_Statement) GetSql() string

func (*ExecuteBatchDmlRequest_Statement) ProtoMessage()

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

func (x *ExecuteBatchDmlRequest_Statement) Reset()

func (x *ExecuteBatchDmlRequest_Statement) String() string

type ExecuteBatchDmlResponse struct {

	// One [ResultSet][google.spanner.v1.ResultSet] for each statement in the
	// request that ran successfully, in the same order as the statements in the
	// request. Each [ResultSet][google.spanner.v1.ResultSet] does not contain any
	// rows. The [ResultSetStats][google.spanner.v1.ResultSetStats] in each
	// [ResultSet][google.spanner.v1.ResultSet] contain the number of rows
	// modified by the statement.
	//
	// Only the first [ResultSet][google.spanner.v1.ResultSet] in the response
	// contains valid [ResultSetMetadata][google.spanner.v1.ResultSetMetadata].
	ResultSets []*ResultSet `protobuf:"bytes,1,rep,name=result_sets,json=resultSets,proto3" json:"result_sets,omitempty"`
	// If all DML statements are executed successfully, the status is `OK`.
	// Otherwise, the error status of the first failed statement.
	Status *status.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *ExecuteBatchDmlResponse) GetResultSets() []*ResultSet

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

func (*ExecuteBatchDmlResponse) ProtoMessage()

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

func (x *ExecuteBatchDmlResponse) Reset()

func (x *ExecuteBatchDmlResponse) String() string

type ExecuteSqlRequest struct {
	Session string `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`

	Transaction *TransactionSelector `protobuf:"bytes,2,opt,name=transaction,proto3" json:"transaction,omitempty"`

	Sql string `protobuf:"bytes,3,opt,name=sql,proto3" json:"sql,omitempty"`

	Params *structpb.Struct `protobuf:"bytes,4,opt,name=params,proto3" json:"params,omitempty"`

	ParamTypes map[string]*Type "" /* 179 byte string literal not displayed */

	ResumeToken []byte `protobuf:"bytes,6,opt,name=resume_token,json=resumeToken,proto3" json:"resume_token,omitempty"`

	QueryMode ExecuteSqlRequest_QueryMode "" /* 140 byte string literal not displayed */

	PartitionToken []byte `protobuf:"bytes,8,opt,name=partition_token,json=partitionToken,proto3" json:"partition_token,omitempty"`

	Seqno int64 `protobuf:"varint,9,opt,name=seqno,proto3" json:"seqno,omitempty"`

	QueryOptions *ExecuteSqlRequest_QueryOptions `protobuf:"bytes,10,opt,name=query_options,json=queryOptions,proto3" json:"query_options,omitempty"`

	RequestOptions *RequestOptions `protobuf:"bytes,11,opt,name=request_options,json=requestOptions,proto3" json:"request_options,omitempty"`

	DirectedReadOptions *DirectedReadOptions `protobuf:"bytes,15,opt,name=directed_read_options,json=directedReadOptions,proto3" json:"directed_read_options,omitempty"`

	DataBoostEnabled bool `protobuf:"varint,16,opt,name=data_boost_enabled,json=dataBoostEnabled,proto3" json:"data_boost_enabled,omitempty"`

}

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

func (x *ExecuteSqlRequest) GetDataBoostEnabled() bool

func (x *ExecuteSqlRequest) GetDirectedReadOptions() *DirectedReadOptions

func (x *ExecuteSqlRequest) GetParamTypes() map[string]*Type

func (x *ExecuteSqlRequest) GetParams() *structpb.Struct

func (x *ExecuteSqlRequest) GetPartitionToken() []byte

func (x *ExecuteSqlRequest) GetQueryMode() ExecuteSqlRequest_QueryMode

func (x *ExecuteSqlRequest) GetQueryOptions() *ExecuteSqlRequest_QueryOptions

func (x *ExecuteSqlRequest) GetRequestOptions() *RequestOptions

func (x *ExecuteSqlRequest) GetResumeToken() []byte

func (x *ExecuteSqlRequest) GetSeqno() int64

func (x *ExecuteSqlRequest) GetSession() string

func (x *ExecuteSqlRequest) GetSql() string

func (x *ExecuteSqlRequest) GetTransaction() *TransactionSelector

func (*ExecuteSqlRequest) ProtoMessage()

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

func (x *ExecuteSqlRequest) Reset()

func (x *ExecuteSqlRequest) String() string

type ExecuteSqlRequest_QueryMode int32

const (
	// The default mode. Only the statement results are returned.
	ExecuteSqlRequest_NORMAL ExecuteSqlRequest_QueryMode = 0
	// This mode returns only the query plan, without any results or
	// execution statistics information.
	ExecuteSqlRequest_PLAN ExecuteSqlRequest_QueryMode = 1
	// This mode returns both the query plan and the execution statistics along
	// with the results.
	ExecuteSqlRequest_PROFILE ExecuteSqlRequest_QueryMode = 2
)

func (ExecuteSqlRequest_QueryMode) Descriptor() protoreflect.EnumDescriptor

func (x ExecuteSqlRequest_QueryMode) Enum() *ExecuteSqlRequest_QueryMode

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

func (x ExecuteSqlRequest_QueryMode) Number() protoreflect.EnumNumber

func (x ExecuteSqlRequest_QueryMode) String() string

func (ExecuteSqlRequest_QueryMode) Type() protoreflect.EnumType

type ExecuteSqlRequest_QueryOptions struct {
	OptimizerVersion string `protobuf:"bytes,1,opt,name=optimizer_version,json=optimizerVersion,proto3" json:"optimizer_version,omitempty"`

	OptimizerStatisticsPackage string "" /* 141 byte string literal not displayed */

}

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

func (x *ExecuteSqlRequest_QueryOptions) GetOptimizerStatisticsPackage() string

func (x *ExecuteSqlRequest_QueryOptions) GetOptimizerVersion() string

func (*ExecuteSqlRequest_QueryOptions) ProtoMessage()

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

func (x *ExecuteSqlRequest_QueryOptions) Reset()

func (x *ExecuteSqlRequest_QueryOptions) String() string

type GetSessionRequest struct {

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

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

func (x *GetSessionRequest) GetName() string

func (*GetSessionRequest) ProtoMessage()

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

func (x *GetSessionRequest) Reset()

func (x *GetSessionRequest) String() string

type KeyRange struct {

	// The start key must be provided. It can be either closed or open.
	//
	// Types that are assignable to StartKeyType:
	//
	//	*KeyRange_StartClosed
	//	*KeyRange_StartOpen
	StartKeyType isKeyRange_StartKeyType `protobuf_oneof:"start_key_type"`
	// The end key must be provided. It can be either closed or open.
	//
	// Types that are assignable to EndKeyType:
	//
	//	*KeyRange_EndClosed
	//	*KeyRange_EndOpen
	EndKeyType isKeyRange_EndKeyType `protobuf_oneof:"end_key_type"`
	// contains filtered or unexported fields
}

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

func (x *KeyRange) GetEndClosed() *structpb.ListValue

func (m *KeyRange) GetEndKeyType() isKeyRange_EndKeyType

func (x *KeyRange) GetEndOpen() *structpb.ListValue

func (x *KeyRange) GetStartClosed() *structpb.ListValue

func (m *KeyRange) GetStartKeyType() isKeyRange_StartKeyType

func (x *KeyRange) GetStartOpen() *structpb.ListValue

func (*KeyRange) ProtoMessage()

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

func (x *KeyRange) Reset()

func (x *KeyRange) String() string

type KeyRange_EndClosed struct {
	// If the end is closed, then the range includes all rows whose
	// first `len(end_closed)` key columns exactly match `end_closed`.
	EndClosed *structpb.ListValue `protobuf:"bytes,3,opt,name=end_closed,json=endClosed,proto3,oneof"`
}

type KeyRange_EndOpen struct {
	// If the end is open, then the range excludes rows whose first
	// `len(end_open)` key columns exactly match `end_open`.
	EndOpen *structpb.ListValue `protobuf:"bytes,4,opt,name=end_open,json=endOpen,proto3,oneof"`
}

type KeyRange_StartClosed struct {
	// If the start is closed, then the range includes all rows whose
	// first `len(start_closed)` key columns exactly match `start_closed`.
	StartClosed *structpb.ListValue `protobuf:"bytes,1,opt,name=start_closed,json=startClosed,proto3,oneof"`
}

type KeyRange_StartOpen struct {
	// If the start is open, then the range excludes rows whose first
	// `len(start_open)` key columns exactly match `start_open`.
	StartOpen *structpb.ListValue `protobuf:"bytes,2,opt,name=start_open,json=startOpen,proto3,oneof"`
}

type KeySet struct {

	// A list of specific keys. Entries in `keys` should have exactly as
	// many elements as there are columns in the primary or index key
	// with which this `KeySet` is used.  Individual key values are
	// encoded as described [here][google.spanner.v1.TypeCode].
	Keys []*structpb.ListValue `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// A list of key ranges. See [KeyRange][google.spanner.v1.KeyRange] for more information about
	// key range specifications.
	Ranges []*KeyRange `protobuf:"bytes,2,rep,name=ranges,proto3" json:"ranges,omitempty"`
	// For convenience `all` can be set to `true` to indicate that this
	// `KeySet` matches all keys in the table or index. Note that any keys
	// specified in `keys` or `ranges` are only yielded once.
	All bool `protobuf:"varint,3,opt,name=all,proto3" json:"all,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *KeySet) GetAll() bool

func (x *KeySet) GetKeys() []*structpb.ListValue

func (x *KeySet) GetRanges() []*KeyRange

func (*KeySet) ProtoMessage()

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

func (x *KeySet) Reset()

func (x *KeySet) String() string

type ListSessionsRequest struct {

	// Required. The database in which to list sessions.
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	// Number of sessions to be returned in the response. If 0 or less, defaults
	// to the server's maximum allowed page size.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// If non-empty, `page_token` should contain a
	// [next_page_token][google.spanner.v1.ListSessionsResponse.next_page_token]
	// from a previous
	// [ListSessionsResponse][google.spanner.v1.ListSessionsResponse].
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// An expression for filtering the results of the request. Filter rules are
	// case insensitive. The fields eligible for filtering are:
	//
	//   - `labels.key` where key is the name of a label
	//
	// Some examples of using filters are:
	//
	//   - `labels.env:*` --> The session has the label "env".
	//   - `labels.env:dev` --> The session has the label "env" and the value of
	//     the label contains the string "dev".
	Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *ListSessionsRequest) GetDatabase() string

func (x *ListSessionsRequest) GetFilter() string

func (x *ListSessionsRequest) GetPageSize() int32

func (x *ListSessionsRequest) GetPageToken() string

func (*ListSessionsRequest) ProtoMessage()

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

func (x *ListSessionsRequest) Reset()

func (x *ListSessionsRequest) String() string

type ListSessionsResponse struct {

	// The list of requested sessions.
	Sessions []*Session `protobuf:"bytes,1,rep,name=sessions,proto3" json:"sessions,omitempty"`
	// `next_page_token` can be sent in a subsequent
	// [ListSessions][google.spanner.v1.Spanner.ListSessions] call to fetch more
	// of the matching sessions.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *ListSessionsResponse) GetNextPageToken() string

func (x *ListSessionsResponse) GetSessions() []*Session