spanner

package

Go to main page

Versions in this module

v0

v0.23.0

May 18, 2018

v0.22.0

May 9, 2018

Changes in this version

type ClientConfig

+ SessionLabels map[string]string

v0.21.0

Apr 9, 2018

Changes in this version

+ var CommitTimestamp time.Time = commitTimestamp

v0.20.0

Mar 22, 2018

Changes in this version

+ 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

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

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

+ 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

v0.19.0

Feb 27, 2018

v0.18.0

Jan 19, 2018

Changes in this version

type ReadOnlyTransaction

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

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

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

+ type ReadOptions struct

+ Index string

+ Limit int

type ReadWriteTransaction

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

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

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

type RowIterator

+ QueryPlan *sppb.QueryPlan

+ QueryStats map[string]interface{}

v0.17.0

Dec 11, 2017

v0.16.0

Nov 1, 2017

v0.15.0

Oct 3, 2017

v0.14.0

Sep 27, 2017

v0.13.0

Sep 11, 2017

v0.12.0

Aug 22, 2017

v0.11.0

Jul 31, 2017

Changes in this version

type SessionPoolConfig

+ MaxIdle uint64

v0.10.0

Jun 30, 2017

v0.9.0

Jun 21, 2017

v0.8.0

Jun 14, 2017

Changes in this version

type Key

+ func (k Key) AsPrefix() KeyRange

type KeySet

+ func KeySets(keySets ...KeySet) KeySet

v0.7.0

Mar 10, 2017

Changes in this version

+ const AdminScope

+ const Scope

+ func ErrCode(err error) codes.Code

+ func ErrDesc(err error) string

+ type ApplyOption func(*applyOption)

+ func ApplyAtLeastOnce() ApplyOption

+ type Client struct

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

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

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

+ func (c *Client) Close()

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

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

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

+ type ClientConfig struct

+ NumChannels int

+ type Error struct

+ Code codes.Code

+ Desc string

+ func (e *Error) Error() string

+ type GenericColumnValue struct

+ Type *sppb.Type

+ Value *proto3.Value

+ func NewGenericColumnValue(v interface{}) (*GenericColumnValue, error)

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

+ type Key []interface

+ 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 struct

+ All bool

+ Keys []Key

+ Ranges []KeyRange

+ func AllKeys() KeySet

+ func Keys(keys ...Key) KeySet

+ func PrefixRange(prefix Key) KeySet

+ func Range(r KeyRange) KeySet

+ func UnionKeySets(keySets ...KeySet) KeySet

+ type Mutation struct

+ func Delete(table string, key Key) *Mutation

+ func DeleteKeyRange(table string, r KeyRange) *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 ReadOnlyTransaction struct

+ func (t *ReadOnlyTransaction) Close()

+ func (t *ReadOnlyTransaction) Query(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) *RowIterator

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

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

+ type ReadWriteTransaction struct

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

+ func (t *ReadWriteTransaction) Query(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) *RowIterator

+ 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

+ 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

+ MaxOpened uint64

+ MaxSessionAge time.Duration

+ 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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL