bigtable

package

Go to main page

Versions in this module

v0

v0.7.0

Mar 10, 2017

Changes in this version

type AdminClient

+ func (ac *AdminClient) CreatePresplitTable(ctx context.Context, table string, split_keys []string) error

type Filter

+ func ConditionFilter(predicateFilter, trueFilter, falseFilter Filter) Filter

+ func ValueRangeFilter(start, end []byte) Filter

type InstanceAdminClient

+ func (iac *InstanceAdminClient) CreateInstance(ctx context.Context, conf *InstanceConf) error

+ func (iac *InstanceAdminClient) DeleteInstance(ctx context.Context, instanceId string) error

+ type InstanceConf struct

+ ClusterId string

+ DisplayName string

+ InstanceId string

+ NumNodes int32

+ StorageType StorageType

+ Zone string

+ type StorageType int

+ const HDD

+ const SSD

type Timestamp

+ func (ts Timestamp) TruncateToMilliseconds() Timestamp

v0.6.0

Dec 10, 2016

v0.5.0

Nov 30, 2016

Changes in this version

type Filter

+ func ColumnRangeFilter(family, start, end string) Filter

+ func TimestampRangeFilterMicros(startTime Timestamp, endTime Timestamp) Filter

v0.4.0

Nov 1, 2016

Changes in this version

type Filter

+ func TimestampRangeFilter(startTime time.Time, endTime time.Time) Filter

v0.3.0

Oct 14, 2016

v0.2.0

Oct 3, 2016

v0.1.0

Aug 3, 2016

Changes in this version

+ const AdminScope

+ const InstanceAdminScope

+ const ReadonlyScope

+ const Scope

+ type AdminClient struct

+ func NewAdminClient(ctx context.Context, project, instance string, opts ...option.ClientOption) (*AdminClient, error)

+ func (ac *AdminClient) Close() error

+ func (ac *AdminClient) CreateColumnFamily(ctx context.Context, table, family string) error

+ func (ac *AdminClient) CreateTable(ctx context.Context, table string) error

+ func (ac *AdminClient) DeleteColumnFamily(ctx context.Context, table, family string) error

+ func (ac *AdminClient) DeleteTable(ctx context.Context, table string) error

+ func (ac *AdminClient) SetGCPolicy(ctx context.Context, table, family string, policy GCPolicy) error

+ func (ac *AdminClient) TableInfo(ctx context.Context, table string) (*TableInfo, error)

+ func (ac *AdminClient) Tables(ctx context.Context) ([]string, error)

+ type ApplyOption interface

+ func GetCondMutationResult(matched *bool) ApplyOption

+ type Client struct

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

+ func (c *Client) Close() error

+ func (c *Client) Open(table string) *Table

+ type Filter interface

+ String func() string

+ func ChainFilters(sub ...Filter) Filter

+ func ColumnFilter(pattern string) Filter

+ func FamilyFilter(pattern string) Filter

+ func InterleaveFilters(sub ...Filter) Filter

+ func LatestNFilter(n int) Filter

+ func RowKeyFilter(pattern string) Filter

+ func StripValueFilter() Filter

+ func ValueFilter(pattern string) Filter

+ type GCPolicy interface

+ String func() string

+ func IntersectionPolicy(sub ...GCPolicy) GCPolicy

+ func MaxAgePolicy(d time.Duration) GCPolicy

+ func MaxVersionsPolicy(n int) GCPolicy

+ func UnionPolicy(sub ...GCPolicy) GCPolicy

+ type InstanceAdminClient struct

+ func NewInstanceAdminClient(ctx context.Context, project string, opts ...option.ClientOption) (*InstanceAdminClient, error)

+ func (cac *InstanceAdminClient) Instances(ctx context.Context) ([]*InstanceInfo, error)

+ func (iac *InstanceAdminClient) Close() error

+ type InstanceInfo struct

+ DisplayName string

+ Name string

+ type Mutation struct

+ func NewCondMutation(cond Filter, mtrue, mfalse *Mutation) *Mutation

+ func NewMutation() *Mutation

+ func (m *Mutation) DeleteCellsInColumn(family, column string)

+ func (m *Mutation) DeleteCellsInFamily(family string)

+ func (m *Mutation) DeleteRow()

+ func (m *Mutation) DeleteTimestampRange(family, column string, start, end Timestamp)

+ func (m *Mutation) Set(family, column string, ts Timestamp, value []byte)

+ type ReadItem struct

+ Column string

+ Row string

+ Timestamp Timestamp

+ Value []byte

+ type ReadModifyWrite struct

+ func NewReadModifyWrite() *ReadModifyWrite

+ func (m *ReadModifyWrite) AppendValue(family, column string, v []byte)

+ func (m *ReadModifyWrite) Increment(family, column string, delta int64)

+ type ReadOption interface

+ func LimitRows(limit int64) ReadOption

+ func RowFilter(f Filter) ReadOption

+ type Row map[string][]ReadItem

+ func (r Row) Key() string

+ type RowList []string

+ type RowRange struct

+ func InfiniteRange(start string) RowRange

+ func NewRange(begin, end string) RowRange

+ func PrefixRange(prefix string) RowRange

+ func SingleRow(row string) RowRange

+ func (r RowRange) Contains(row string) bool

+ func (r RowRange) String() string

+ func (r RowRange) Unbounded() bool

+ type RowSet interface

+ type Table struct

+ func (t *Table) Apply(ctx context.Context, row string, m *Mutation, opts ...ApplyOption) error

+ func (t *Table) ApplyBulk(ctx context.Context, rowKeys []string, muts []*Mutation, opts ...ApplyOption) ([]error, error)

+ func (t *Table) ApplyReadModifyWrite(ctx context.Context, row string, m *ReadModifyWrite) (Row, error)

+ func (t *Table) ReadRow(ctx context.Context, row string, opts ...ReadOption) (Row, error)

+ func (t *Table) ReadRows(ctx context.Context, arg RowSet, f func(Row) bool, opts ...ReadOption) error

+ type TableInfo struct

+ Families []string

+ type Timestamp int64

+ const ServerTime

+ func Now() Timestamp

+ func Time(t time.Time) Timestamp

+ func (ts Timestamp) Time() time.Time

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