spanner

Nov 14, 2024

Changes in this version

type ReadWriteStmtBasedTransaction

+ func (t *ReadWriteStmtBasedTransaction) ResetForRetry(ctx context.Context) (*ReadWriteStmtBasedTransaction, error)

Nov 1, 2024

Changes in this version

type ClientConfig

+ DisableNativeMetrics bool

Oct 4, 2024

Changes in this version

type ClientConfig

+ EnableEndToEndTracing bool

Aug 16, 2024

Changes in this version

type ApplyOption

+ func ApplyCommitOptions(co CommitOptions) ApplyOption

Aug 7, 2024

Changes in this version

type SessionPoolConfig

+ MultiplexSessionCheckInterval time.Duration

Jul 1, 2024

Changes in this version

+ var ErrRowNotFound = errors.New("row not found")

type ReadOptions

+ LockHint sppb.ReadRequest_LockHint

+ OrderBy sppb.ReadRequest_OrderBy

May 15, 2024

Changes in this version

+ type NullProtoEnum struct

+ ProtoEnumVal protoreflect.Enum

+ Valid bool

+ func (n *NullProtoEnum) UnmarshalJSON(payload []byte) error

+ func (n NullProtoEnum) IsNull() bool

+ func (n NullProtoEnum) MarshalJSON() ([]byte, error)

+ func (n NullProtoEnum) String() string

+ type NullProtoMessage struct

+ ProtoMessageVal proto.Message

+ Valid bool

+ func (n *NullProtoMessage) UnmarshalJSON(payload []byte) error

+ func (n NullProtoMessage) IsNull() bool

+ func (n NullProtoMessage) MarshalJSON() ([]byte, error)

+ func (n NullProtoMessage) String() string

Apr 30, 2024

Changes in this version

type ApplyOption

+ func ExcludeTxnFromChangeStreams() ApplyOption

type BatchWriteOptions

+ ExcludeTxnFromChangeStreams bool

type Client

+ func NewMultiEndpointClient(ctx context.Context, database string, gmeCfg *grpcgcp.GCPMultiEndpointOptions, ...) (*Client, *grpcgcp.GCPMultiEndpoint, error)

+ func NewMultiEndpointClientWithConfig(ctx context.Context, database string, config ClientConfig, ...) (c *Client, gme *grpcgcp.GCPMultiEndpoint, err error)

type QueryOptions

+ ExcludeTxnFromChangeStreams bool

type TransactionOptions

+ ExcludeTxnFromChangeStreams bool

Mar 13, 2024

Changes in this version

+ type NullFloat32 struct

+ Float32 float32

+ Valid bool

+ func (n *NullFloat32) Scan(value interface{}) error

+ func (n *NullFloat32) UnmarshalJSON(payload []byte) error

+ func (n NullFloat32) GormDataType() string

+ func (n NullFloat32) IsNull() bool

+ func (n NullFloat32) MarshalJSON() ([]byte, error)

+ func (n NullFloat32) String() string

+ func (n NullFloat32) Value() (driver.Value, error)

Feb 13, 2024

Changes in this version

+ const OtInstrumentationScope

+ func EnableOpenTelemetryMetrics()

+ func IsOpenTelemetryMetricsEnabled() bool

type Client

+ func (c *Client) ClientID() string

type ClientConfig

+ OpenTelemetryMeterProvider metric.MeterProvider

type CommitOptions

+ MaxCommitDelay *time.Duration

Jan 30, 2024

Changes in this version

+ func SelectAll(rows rowIterator, destination interface{}, options ...DecodeOptions) error

+ type DecodeOptions interface

+ Apply func(s *decodeSetting)

+ func WithLenient() DecodeOptions

Jan 10, 2024

Changes in this version

type ClientConfig

+ DirectedReadOptions *sppb.DirectedReadOptions

type QueryOptions

+ DirectedReadOptions *sppb.DirectedReadOptions

type ReadOptions

+ DirectedReadOptions *sppb.DirectedReadOptions

Dec 14, 2023

Changes in this version

+ func UseNumberWithJSONDecoderEncoder(useNumber bool)

Nov 15, 2023

Changes in this version

type InactiveTransactionRemovalOptions

+ ActionOnInactiveTransaction ActionOnInactiveTransactionKind

Nov 15, 2023

Changes in this version

+ type ActionOnInactiveTransactionKind int

+ const Close

+ const NoAction

+ const Warn

+ const WarnAndClose

+ type BatchWriteOptions struct

+ Priority sppb.RequestOptions_Priority

+ TransactionTag string

+ type BatchWriteResponseIterator struct

+ func (r *BatchWriteResponseIterator) Do(f func(r *sppb.BatchWriteResponse) error) error

+ func (r *BatchWriteResponseIterator) Next() (*sppb.BatchWriteResponse, error)

+ func (r *BatchWriteResponseIterator) Stop()

type Client

+ func (c *Client) BatchWrite(ctx context.Context, mgs []*MutationGroup) *BatchWriteResponseIterator

+ func (c *Client) BatchWriteWithOptions(ctx context.Context, mgs []*MutationGroup, opts BatchWriteOptions) *BatchWriteResponseIterator

type ClientConfig

+ BatchWriteOptions BatchWriteOptions

+ type InactiveTransactionRemovalOptions struct

+ type MutationGroup struct

+ Mutations []*Mutation

type Partition

+ func (p *Partition) GetPartitionToken() []byte

type Row

+ func (r *Row) ColumnType(i int) *sppb.Type

+ func (r *Row) ColumnValue(i int) *proto3.Value

Jun 20, 2023

Changes in this version

type ClientConfig

+ BatchTimeout time.Duration

+ Compression string

type QueryOptions

+ DataBoostEnabled bool

type ReadOptions

+ DataBoostEnabled bool

Apr 10, 2023

Changes in this version

type ClientConfig

+ DisableRouteToLeader bool

Feb 2, 2023

Changes in this version

type TransactionOptions

+ ReadLockMode sppb.TransactionOptions_ReadWrite_ReadLockMode

Dec 14, 2022

Changes in this version

type ClientConfig

+ DatabaseRole string

Nov 3, 2022

Changes in this version

type ClientConfig

+ Logger *log.Logger

+ type PGJsonB struct

+ Valid bool

+ Value interface{}

+ func (n *PGJsonB) UnmarshalJSON(payload []byte) error

+ func (n PGJsonB) IsNull() bool

+ func (n PGJsonB) MarshalJSON() ([]byte, error)

+ func (n PGJsonB) String() string

Sep 3, 2022

Changes in this version

type ClientConfig

+ UserAgent string

Aug 29, 2022

Changes in this version

type ClientConfig

+ ApplyOptions []ApplyOption

+ ReadOptions ReadOptions

+ TransactionOptions TransactionOptions

Mar 4, 2022

Changes in this version

+ type PGNumeric struct

+ Numeric string

+ Valid bool

+ func (n *PGNumeric) UnmarshalJSON(payload []byte) error

+ func (n PGNumeric) IsNull() bool

+ func (n PGNumeric) MarshalJSON() ([]byte, error)

+ func (n PGNumeric) String() string

Jan 6, 2022

Changes in this version

+ var GFEHeaderMissingCount = stats.Int64(statsPrefix + "gfe_header_missing_count", ...)

+ var GFEHeaderMissingCountView = &view.View

+ var GFELatency = stats.Int64(statsPrefix + "gfe_latency", ...)

+ var GFELatencyView = &view.View

+ func DisableGfeLatencyAndHeaderMissingCountViews()

+ func EnableGfeHeaderMissingCountView() error

+ func EnableGfeLatencyAndHeaderMissingCountViews() error

+ func EnableGfeLatencyView() error

type BatchReadOnlyTransaction

+ func (t *BatchReadOnlyTransaction) ReadRowWithOptions(ctx context.Context, table string, key Key, columns []string, ...) (*Row, error)

type ReadOnlyTransaction

+ func (t *ReadOnlyTransaction) ReadRowWithOptions(ctx context.Context, table string, key Key, columns []string, ...) (*Row, error)

type ReadWriteStmtBasedTransaction

+ func (t *ReadWriteStmtBasedTransaction) ReadRowWithOptions(ctx context.Context, table string, key Key, columns []string, ...) (*Row, error)

type ReadWriteTransaction

+ func (t *ReadWriteTransaction) ReadRowWithOptions(ctx context.Context, table string, key Key, columns []string, ...) (*Row, error)

Dec 6, 2021

Changes in this version

type Row

+ func (r *Row) ToStructLenient(p interface{}) error

Oct 20, 2021

Changes in this version

type NullBool

+ func (n *NullBool) Scan(value interface{}) error

+ func (n NullBool) GormDataType() string

+ func (n NullBool) Value() (driver.Value, error)

type NullDate

+ func (n *NullDate) Scan(value interface{}) error

+ func (n NullDate) GormDataType() string

+ func (n NullDate) Value() (driver.Value, error)

type NullFloat64

+ func (n *NullFloat64) Scan(value interface{}) error

+ func (n NullFloat64) GormDataType() string

+ func (n NullFloat64) Value() (driver.Value, error)

type NullInt64

+ func (n *NullInt64) Scan(value interface{}) error

+ func (n NullInt64) GormDataType() string

+ func (n NullInt64) Value() (driver.Value, error)

type NullJSON

+ func (n NullJSON) GormDataType() string

type NullNumeric

+ func (n *NullNumeric) Scan(value interface{}) error

+ func (n NullNumeric) GormDataType() string

+ func (n NullNumeric) Value() (driver.Value, error)

type NullString

+ func (n *NullString) Scan(value interface{}) error

+ func (n NullString) GormDataType() string

+ func (n NullString) Value() (driver.Value, error)

type NullTime

+ func (n *NullTime) Scan(value interface{}) error

+ func (n NullTime) GormDataType() string

+ func (n NullTime) Value() (driver.Value, error)

Aug 25, 2021

Changes in this version

+ type LossOfPrecisionHandlingOption int

+ const NumericError

+ const NumericRound

+ var LossOfPrecisionHandling LossOfPrecisionHandlingOption

+ type NullJSON struct

+ Valid bool

+ Value interface{}

+ func (n *NullJSON) UnmarshalJSON(payload []byte) error

+ func (n NullJSON) IsNull() bool

+ func (n NullJSON) MarshalJSON() ([]byte, error)

+ func (n NullJSON) String() string

Jul 30, 2021

Changes in this version

type Row

+ func (r *Row) String() string

Jun 30, 2021

Changes in this version

type ApplyOption

+ func TransactionTag(tag string) ApplyOption

type BatchReadOnlyTransaction

+ func (t *BatchReadOnlyTransaction) PartitionReadUsingIndexWithOptions(ctx context.Context, table, index string, keys KeySet, columns []string, ...) ([]*Partition, error)

+ func (t *BatchReadOnlyTransaction) PartitionReadWithOptions(ctx context.Context, table string, keys KeySet, columns []string, ...) ([]*Partition, error)

type QueryOptions

+ RequestTag string

type ReadOptions

+ RequestTag string

type TransactionOptions

+ TransactionTag string

Jun 3, 2021

Changes in this version

type Client

+ func (c *Client) DatabaseName() string

Mar 31, 2021

Changes in this version

type ApplyOption

+ func Priority(priority sppb.RequestOptions_Priority) ApplyOption

type QueryOptions

+ Priority sppb.RequestOptions_Priority

type ReadOptions

+ Priority sppb.RequestOptions_Priority

type ReadWriteTransaction

+ func (t *ReadWriteTransaction) BatchUpdateWithOptions(ctx context.Context, stmts []Statement, opts QueryOptions) (_ []int64, err error)

type TransactionOptions

+ CommitPriority sppb.RequestOptions_Priority

Feb 9, 2021

Changes in this version

+ type CommitOptions struct

+ ReturnCommitStats bool

type CommitResponse

+ CommitStats *sppb.CommitResponse_CommitStats

type ReadWriteStmtBasedTransaction

+ func (t *ReadWriteStmtBasedTransaction) CommitWithReturnResp(ctx context.Context) (CommitResponse, error)

type TransactionOptions

+ CommitOptions CommitOptions

Nov 10, 2020

Changes in this version

+ func ToSpannerError(err error) error

type Client

+ func (c *Client) ReadWriteTransactionWithOptions(ctx context.Context, f func(context.Context, *ReadWriteTransaction) error, ...) (resp CommitResponse, err error)

+ type CommitResponse struct

+ CommitTs time.Time

type ReadWriteStmtBasedTransaction

+ func NewReadWriteStmtBasedTransactionWithOptions(ctx context.Context, c *Client, options TransactionOptions) (*ReadWriteStmtBasedTransaction, error)

type RowIterator

+ Metadata *sppb.ResultSetMetadata

+ type TransactionOptions struct

Oct 20, 2020

Changes in this version

type KeySet

+ func KeySetFromKeys(keys ...Key) KeySet

Sep 9, 2020

Changes in this version

+ const NumericPrecisionDigits

+ const NumericScaleDigits

+ func NumericString(r *big.Rat) string

+ type NullNumeric struct

+ Numeric big.Rat

+ Valid bool

+ func (n *NullNumeric) UnmarshalJSON(payload []byte) error

+ func (n NullNumeric) IsNull() bool

+ func (n NullNumeric) MarshalJSON() ([]byte, error)

+ func (n NullNumeric) String() string

Aug 17, 2020

Changes in this version

+ type Decoder interface

+ DecodeSpanner func(input interface{}) error

+ type Encoder interface

+ EncodeSpanner func() (interface{}, error)

Jul 21, 2020

Changes in this version

+ func ExtractRetryDelay(err error) (time.Duration, bool)

type ClientConfig

+ CallOptions *vkit.CallOptions

+ type ReadWriteStmtBasedTransaction struct

+ func NewReadWriteStmtBasedTransaction(ctx context.Context, c *Client) (*ReadWriteStmtBasedTransaction, error)

+ func (t *ReadWriteStmtBasedTransaction) AnalyzeQuery(ctx context.Context, statement Statement) (*sppb.QueryPlan, error)

+ func (t *ReadWriteStmtBasedTransaction) Commit(ctx context.Context) (time.Time, error)

+ func (t *ReadWriteStmtBasedTransaction) Query(ctx context.Context, statement Statement) *RowIterator

+ func (t *ReadWriteStmtBasedTransaction) QueryWithOptions(ctx context.Context, statement Statement, opts QueryOptions) *RowIterator

+ func (t *ReadWriteStmtBasedTransaction) QueryWithStats(ctx context.Context, statement Statement) *RowIterator

+ func (t *ReadWriteStmtBasedTransaction) Read(ctx context.Context, table string, keys KeySet, columns []string) *RowIterator

+ func (t *ReadWriteStmtBasedTransaction) ReadRow(ctx context.Context, table string, key Key, columns []string) (*Row, error)

+ func (t *ReadWriteStmtBasedTransaction) ReadRowUsingIndex(ctx context.Context, table string, index string, key Key, columns []string) (*Row, error)

+ func (t *ReadWriteStmtBasedTransaction) ReadUsingIndex(ctx context.Context, table, index string, keys KeySet, columns []string) (ri *RowIterator)

+ func (t *ReadWriteStmtBasedTransaction) ReadWithOptions(ctx context.Context, table string, keys KeySet, columns []string, ...) (ri *RowIterator)

+ func (t *ReadWriteStmtBasedTransaction) Rollback(ctx context.Context)

Apr 14, 2020

Changes in this version

+ var AcquiredSessionsCount = stats.Int64(statsPrefix + "num_acquired_sessions", ...)

+ var AcquiredSessionsCountView = &view.View

+ var GetSessionTimeoutsCount = stats.Int64(statsPrefix + "get_session_timeouts", ...)

+ var GetSessionTimeoutsCountView = &view.View

+ var MaxAllowedSessionsCount = stats.Int64(statsPrefix + "max_allowed_sessions", ...)

+ var MaxAllowedSessionsCountView = &view.View

+ var MaxInUseSessionsCount = stats.Int64(statsPrefix + "max_in_use_sessions", ...)

+ var MaxInUseSessionsCountView = &view.View

+ var ReleasedSessionsCount = stats.Int64(statsPrefix + "num_released_sessions", ...)

+ var ReleasedSessionsCountView = &view.View

+ var SessionsCount = stats.Int64(statsPrefix + "num_sessions_in_pool", ...)

+ var SessionsCountView = &view.View

+ func EnableStatViews() error

Mar 17, 2020

Changes in this version

type BatchReadOnlyTransaction

+ func (t *BatchReadOnlyTransaction) PartitionQueryWithOptions(ctx context.Context, statement Statement, opt PartitionOptions, ...) ([]*Partition, error)

+ func (t *BatchReadOnlyTransaction) QueryWithOptions(ctx context.Context, statement Statement, opts QueryOptions) *RowIterator

type Client

+ func (c *Client) PartitionedUpdateWithOptions(ctx context.Context, statement Statement, opts QueryOptions) (count int64, err error)

type ClientConfig

+ QueryOptions QueryOptions

type NullBool

+ func (n *NullBool) UnmarshalJSON(payload []byte) error

+ func (n NullBool) MarshalJSON() ([]byte, error)

type NullDate

+ func (n *NullDate) UnmarshalJSON(payload []byte) error

+ func (n NullDate) MarshalJSON() ([]byte, error)

type NullFloat64

+ func (n *NullFloat64) UnmarshalJSON(payload []byte) error

+ func (n NullFloat64) MarshalJSON() ([]byte, error)

type NullInt64

+ func (n *NullInt64) UnmarshalJSON(payload []byte) error

+ func (n NullInt64) MarshalJSON() ([]byte, error)

type NullString

+ func (n *NullString) UnmarshalJSON(payload []byte) error

+ func (n NullString) MarshalJSON() ([]byte, error)

type NullTime

+ func (n *NullTime) UnmarshalJSON(payload []byte) error

+ func (n NullTime) MarshalJSON() ([]byte, error)

+ type QueryOptions struct

+ Mode *sppb.ExecuteSqlRequest_QueryMode

+ Options *sppb.ExecuteSqlRequest_QueryOptions

type ReadOnlyTransaction

+ func (t *ReadOnlyTransaction) QueryWithOptions(ctx context.Context, statement Statement, opts QueryOptions) *RowIterator

type ReadWriteTransaction

+ func (t *ReadWriteTransaction) QueryWithOptions(ctx context.Context, statement Statement, opts QueryOptions) *RowIterator

+ func (t *ReadWriteTransaction) UpdateWithOptions(ctx context.Context, stmt Statement, opts QueryOptions) (rowCount int64, err error)

+ type TransactionOutcomeUnknownError struct

+ func (*TransactionOutcomeUnknownError) Error() string

+ func (e *TransactionOutcomeUnknownError) Unwrap() error

Jan 28, 2020

Changes in this version

type BatchReadOnlyTransaction

+ func (t *BatchReadOnlyTransaction) ReadRowUsingIndex(ctx context.Context, table string, index string, key Key, columns []string) (*Row, error)

type Error

+ func (e *Error) Unwrap() error

type ReadOnlyTransaction

+ func (t *ReadOnlyTransaction) ReadRowUsingIndex(ctx context.Context, table string, index string, key Key, columns []string) (*Row, error)

type ReadWriteTransaction

+ func (t *ReadWriteTransaction) ReadRowUsingIndex(ctx context.Context, table string, index string, key Key, columns []string) (*Row, error)

type SessionPoolConfig

+ TrackSessionHandles bool

Nov 6, 2019

Changes in this version

+ var DefaultSessionPoolConfig = SessionPoolConfig

type NullBool

+ func (n NullBool) IsNull() bool

type NullDate

+ func (n NullDate) IsNull() bool

type NullFloat64

+ func (n NullFloat64) IsNull() bool

type NullInt64

+ func (n NullInt64) IsNull() bool

type NullString

+ func (n NullString) IsNull() bool

type NullTime

+ func (n NullTime) IsNull() bool

+ type NullableValue interface

+ IsNull func() bool

Sep 13, 2019

Changes in this version

+ const AdminScope

+ const Scope

+ var CommitTimestamp = commitTimestamp

+ var DefaultRetryBackoff = gax.Backoff

+ var OpenSessionCount = stats.Int64(statsPrefix + "open_session_count", "Number of sessions currently opened", ...)

+ var OpenSessionCountView = &view.View

+ func ErrCode(err error) codes.Code

+ func ErrDesc(err error) string

+ type ApplyOption func(*applyOption)

+ func ApplyAtLeastOnce() ApplyOption

+ type BatchReadOnlyTransaction struct

+ ID BatchReadOnlyTransactionID

+ func (t *BatchReadOnlyTransaction) AnalyzeQuery(ctx context.Context, statement Statement) (*sppb.QueryPlan, error)

+ func (t *BatchReadOnlyTransaction) Cleanup(ctx context.Context)

+ func (t *BatchReadOnlyTransaction) Close()

+ func (t *BatchReadOnlyTransaction) Execute(ctx context.Context, p *Partition) *RowIterator

+ func (t *BatchReadOnlyTransaction) PartitionQuery(ctx context.Context, statement Statement, opt PartitionOptions) ([]*Partition, error)

+ func (t *BatchReadOnlyTransaction) PartitionRead(ctx context.Context, table string, keys KeySet, columns []string, ...) ([]*Partition, error)

+ func (t *BatchReadOnlyTransaction) PartitionReadUsingIndex(ctx context.Context, table, index string, keys KeySet, columns []string, ...) ([]*Partition, error)

+ func (t *BatchReadOnlyTransaction) Query(ctx context.Context, statement Statement) *RowIterator

+ func (t *BatchReadOnlyTransaction) QueryWithStats(ctx context.Context, statement Statement) *RowIterator

+ func (t *BatchReadOnlyTransaction) Read(ctx context.Context, table string, keys KeySet, columns []string) *RowIterator

+ func (t *BatchReadOnlyTransaction) ReadRow(ctx context.Context, table string, key Key, columns []string) (*Row, error)

+ func (t *BatchReadOnlyTransaction) ReadUsingIndex(ctx context.Context, table, index string, keys KeySet, columns []string) (ri *RowIterator)

+ func (t *BatchReadOnlyTransaction) ReadWithOptions(ctx context.Context, table string, keys KeySet, columns []string, ...) (ri *RowIterator)

+ type BatchReadOnlyTransactionID struct

+ func (tid *BatchReadOnlyTransactionID) UnmarshalBinary(data []byte) error

+ func (tid BatchReadOnlyTransactionID) MarshalBinary() (data []byte, err error)

+ type Client struct

+ func NewClient(ctx context.Context, database string, opts ...option.ClientOption) (*Client, error)

+ func NewClientWithConfig(ctx context.Context, database string, config ClientConfig, ...) (c *Client, err error)

+ func (c *Client) Apply(ctx context.Context, ms []*Mutation, opts ...ApplyOption) (commitTimestamp time.Time, err error)

+ func (c *Client) BatchReadOnlyTransaction(ctx context.Context, tb TimestampBound) (*BatchReadOnlyTransaction, error)

+ func (c *Client) BatchReadOnlyTransactionFromID(tid BatchReadOnlyTransactionID) *BatchReadOnlyTransaction

+ func (c *Client) Close()

+ func (c *Client) PartitionedUpdate(ctx context.Context, statement Statement) (count int64, err error)

+ func (c *Client) ReadOnlyTransaction() *ReadOnlyTransaction

+ func (c *Client) ReadWriteTransaction(ctx context.Context, f func(context.Context, *ReadWriteTransaction) error) (commitTimestamp time.Time, err error)

+ func (c *Client) Single() *ReadOnlyTransaction

+ type ClientConfig struct

+ NumChannels int

+ SessionLabels map[string]string

+ type Error struct

+ Code codes.Code

+ Desc string

+ func (e *Error) Error() string

+ func (e *Error) GRPCStatus() *status.Status

+ type GenericColumnValue struct

+ Type *sppb.Type

+ Value *proto3.Value

+ func (v GenericColumnValue) Decode(ptr interface{}) error

+ type Key []interface

+ func (key Key) AsPrefix() KeyRange

+ func (key Key) String() string

+ type KeyRange struct

+ End Key

+ Kind KeyRangeKind

+ Start Key

+ func (r KeyRange) String() string

+ type KeyRangeKind int

+ const ClosedClosed

+ const ClosedOpen

+ const OpenClosed

+ const OpenOpen

+ type KeySet interface

+ func AllKeys() KeySet

+ func KeySets(keySets ...KeySet) KeySet

+ type Mutation struct

+ func Delete(table string, ks KeySet) *Mutation

+ func Insert(table string, cols []string, vals []interface{}) *Mutation

+ func InsertMap(table string, in map[string]interface{}) *Mutation

+ func InsertOrUpdate(table string, cols []string, vals []interface{}) *Mutation

+ func InsertOrUpdateMap(table string, in map[string]interface{}) *Mutation

+ func InsertOrUpdateStruct(table string, in interface{}) (*Mutation, error)

+ func InsertStruct(table string, in interface{}) (*Mutation, error)

+ func Replace(table string, cols []string, vals []interface{}) *Mutation

+ func ReplaceMap(table string, in map[string]interface{}) *Mutation

+ func ReplaceStruct(table string, in interface{}) (*Mutation, error)

+ func Update(table string, cols []string, vals []interface{}) *Mutation

+ func UpdateMap(table string, in map[string]interface{}) *Mutation

+ func UpdateStruct(table string, in interface{}) (*Mutation, error)

+ type NullBool struct

+ Bool bool

+ Valid bool

+ func (n NullBool) String() string

+ type NullDate struct

+ Date civil.Date

+ Valid bool

+ func (n NullDate) String() string

+ type NullFloat64 struct

+ Float64 float64

+ Valid bool

+ func (n NullFloat64) String() string

+ type NullInt64 struct

+ Int64 int64

+ Valid bool

+ func (n NullInt64) String() string

+ type NullRow struct

+ Row Row

+ Valid bool

+ type NullString struct

+ StringVal string

+ Valid bool

+ func (n NullString) String() string

+ type NullTime struct

+ Time time.Time

+ Valid bool

+ func (n NullTime) String() string

+ type Partition struct

+ func (p *Partition) UnmarshalBinary(data []byte) error

+ func (p Partition) MarshalBinary() (data []byte, err error)

+ type PartitionOptions struct

+ MaxPartitions int64

+ PartitionBytes int64

+ type ReadOnlyTransaction struct

+ func (t *ReadOnlyTransaction) AnalyzeQuery(ctx context.Context, statement Statement) (*sppb.QueryPlan, error)

+ func (t *ReadOnlyTransaction) Close()

+ func (t *ReadOnlyTransaction) Query(ctx context.Context, statement Statement) *RowIterator

+ func (t *ReadOnlyTransaction) QueryWithStats(ctx context.Context, statement Statement) *RowIterator

+ func (t *ReadOnlyTransaction) Read(ctx context.Context, table string, keys KeySet, columns []string) *RowIterator

+ func (t *ReadOnlyTransaction) ReadRow(ctx context.Context, table string, key Key, columns []string) (*Row, error)

+ func (t *ReadOnlyTransaction) ReadUsingIndex(ctx context.Context, table, index string, keys KeySet, columns []string) (ri *RowIterator)

+ func (t *ReadOnlyTransaction) ReadWithOptions(ctx context.Context, table string, keys KeySet, columns []string, ...) (ri *RowIterator)

+ func (t *ReadOnlyTransaction) Timestamp() (time.Time, error)

+ func (t *ReadOnlyTransaction) WithTimestampBound(tb TimestampBound) *ReadOnlyTransaction

+ type ReadOptions struct

+ Index string

+ Limit int

+ type ReadWriteTransaction struct

+ func (t *ReadWriteTransaction) AnalyzeQuery(ctx context.Context, statement Statement) (*sppb.QueryPlan, error)

+ func (t *ReadWriteTransaction) BatchUpdate(ctx context.Context, stmts []Statement) (_ []int64, err error)

+ func (t *ReadWriteTransaction) BufferWrite(ms []*Mutation) error

+ func (t *ReadWriteTransaction) Query(ctx context.Context, statement Statement) *RowIterator

+ func (t *ReadWriteTransaction) QueryWithStats(ctx context.Context, statement Statement) *RowIterator

+ func (t *ReadWriteTransaction) Read(ctx context.Context, table string, keys KeySet, columns []string) *RowIterator

+ func (t *ReadWriteTransaction) ReadRow(ctx context.Context, table string, key Key, columns []string) (*Row, error)

+ func (t *ReadWriteTransaction) ReadUsingIndex(ctx context.Context, table, index string, keys KeySet, columns []string) (ri *RowIterator)

+ func (t *ReadWriteTransaction) ReadWithOptions(ctx context.Context, table string, keys KeySet, columns []string, ...) (ri *RowIterator)

+ func (t *ReadWriteTransaction) Update(ctx context.Context, stmt Statement) (rowCount int64, err error)

+ type Row struct

+ func NewRow(columnNames []string, columnValues []interface{}) (*Row, error)

+ func (r *Row) Column(i int, ptr interface{}) error

+ func (r *Row) ColumnByName(name string, ptr interface{}) error

+ func (r *Row) ColumnIndex(name string) (int, error)

+ func (r *Row) ColumnName(i int) string

+ func (r *Row) ColumnNames() []string

+ func (r *Row) Columns(ptrs ...interface{}) error

+ func (r *Row) Size() int

+ func (r *Row) ToStruct(p interface{}) error

+ type RowIterator struct

+ QueryPlan *sppb.QueryPlan

+ QueryStats map[string]interface{}

+ RowCount int64

+ func (r *RowIterator) Do(f func(r *Row) error) error

+ func (r *RowIterator) Next() (*Row, error)

+ func (r *RowIterator) Stop()

+ type SessionPoolConfig struct

+ HealthCheckInterval time.Duration

+ HealthCheckWorkers int

+ MaxBurst uint64

+ MaxIdle uint64

+ MaxOpened uint64

+ MinOpened uint64

+ WriteSessions float64

+ type Statement struct

+ Params map[string]interface{}

+ SQL string

+ func NewStatement(sql string) Statement

+ type TimestampBound struct

+ func ExactStaleness(d time.Duration) TimestampBound

+ func MaxStaleness(d time.Duration) TimestampBound

+ func MinReadTimestamp(t time.Time) TimestampBound

+ func ReadTimestamp(t time.Time) TimestampBound

+ func StrongRead() TimestampBound

+ func (tb TimestampBound) String() string