bigtable

Aug 7, 2018

Changes in this version

type Filter

+ func RowSampleFilter(p float64) Filter

type ProfileAttrsToUpdate

+ IgnoreWarnings bool

type ProfileConf

+ IgnoreWarnings bool

Jul 12, 2018

Changes in this version

type GCPolicy

+ func NoGcPolicy() GCPolicy

Jun 20, 2018

Changes in this version

+ const MultiClusterRouting

+ const SingleClusterRouting

type AdminClient

+ func (ac *AdminClient) Snapshots(ctx context.Context, cluster string) *SnapshotIterator

type InstanceAdminClient

+ func (iac *InstanceAdminClient) CreateAppProfile(ctx context.Context, profile ProfileConf) (*btapb.AppProfile, error)

+ func (iac *InstanceAdminClient) DeleteAppProfile(ctx context.Context, instanceID, name string) error

+ func (iac *InstanceAdminClient) GetAppProfile(ctx context.Context, instanceID, name string) (*btapb.AppProfile, error)

+ func (iac *InstanceAdminClient) InstanceIAM(instanceID string) *iam.Handle

+ func (iac *InstanceAdminClient) ListAppProfiles(ctx context.Context, instanceID string) *ProfileIterator

+ func (iac *InstanceAdminClient) UpdateAppProfile(ctx context.Context, instanceID, profileID string, ...) error

+ type ProfileAttrsToUpdate struct

+ AllowTransactionalWrites bool

+ ClusterID string

+ Description optional.String

+ RoutingPolicy optional.String

+ func (p *ProfileAttrsToUpdate) GetFieldMaskPath() []string

+ type ProfileConf struct

+ AllowTransactionalWrites bool

+ ClusterID string

+ Description string

+ Etag string

+ InstanceID string

+ Name string

+ ProfileID string

+ RoutingPolicy string

+ type ProfileIterator struct

+ func (it *ProfileIterator) Next() (*btapb.AppProfile, error)

+ func (it *ProfileIterator) PageInfo() *iterator.PageInfo

Mar 22, 2018

Changes in this version

type Table

+ func (t *Table) SampleRowKeys(ctx context.Context) ([]string, error)

Feb 27, 2018

Changes in this version

type InstanceAdminClient

+ func (iac *InstanceAdminClient) GetCluster(ctx context.Context, instanceID, clusterID string) (*ClusterInfo, error)

Jan 19, 2018

Changes in this version

+ const DefaultSnapshotDuration

type AdminClient

+ func (ac *AdminClient) CreateTableFromSnapshot(ctx context.Context, table, cluster, snapshot string) error

+ func (ac *AdminClient) DeleteSnapshot(ctx context.Context, cluster, snapshot string) error

+ func (ac *AdminClient) ListSnapshots(ctx context.Context, cluster string) *SnapshotIterator

+ func (ac *AdminClient) SnapshotInfo(ctx context.Context, cluster, snapshot string) (*SnapshotInfo, error)

+ func (ac *AdminClient) SnapshotTable(ctx context.Context, table, cluster, snapshot string, ttl time.Duration) error

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

type Client

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

+ type ClientConfig struct

+ AppProfile string

+ type ClusterConfig struct

+ ClusterID string

+ InstanceID string

+ NumNodes int32

+ StorageType StorageType

+ Zone string

+ type ClusterInfo struct

+ Name string

+ ServeNodes int

+ State string

+ Zone string

type InstanceAdminClient

+ func (iac *InstanceAdminClient) Clusters(ctx context.Context, instanceId string) ([]*ClusterInfo, error)

+ func (iac *InstanceAdminClient) CreateCluster(ctx context.Context, conf *ClusterConfig) error

+ func (iac *InstanceAdminClient) CreateInstanceWithClusters(ctx context.Context, conf *InstanceWithClustersConfig) error

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

+ func (iac *InstanceAdminClient) UpdateCluster(ctx context.Context, instanceId, clusterId string, serveNodes int32) error

+ type InstanceWithClustersConfig struct

+ Clusters []ClusterConfig

+ DisplayName string

+ InstanceID string

+ InstanceType InstanceType

+ type SnapshotInfo struct

+ CreateTime time.Time

+ DataSize int64

+ DeleteTime time.Time

+ Name string

+ SourceTable string

+ type SnapshotIterator struct

+ func (it *SnapshotIterator) Next() (*SnapshotInfo, error)

+ func (it *SnapshotIterator) PageInfo() *iterator.PageInfo

Jul 31, 2017

Changes in this version

type AdminClient

+ func (ac *AdminClient) CreateTableFromConf(ctx context.Context, conf *TableConf) error

type Filter

+ func CellsPerRowLimitFilter(n int) Filter

+ func CellsPerRowOffsetFilter(n int) Filter

type InstanceConf

+ InstanceType InstanceType

+ type InstanceType int32

+ const DEVELOPMENT

+ const PRODUCTION

+ type TableConf struct

+ Families map[string]GCPolicy

+ SplitKeys []string

+ TableID string

Jun 30, 2017

Changes in this version

type InstanceAdminClient

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

Jun 14, 2017

Changes in this version

+ func GCRuleToString(rule *bttdpb.GcRule) string

type AdminClient

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

+ type FamilyInfo struct

+ GCPolicy string

+ Name string

+ type RowRangeList []RowRange

type TableInfo

+ FamilyInfos []FamilyInfo

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

Nov 30, 2016

Changes in this version

type Filter

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

+ func TimestampRangeFilterMicros(startTime Timestamp, endTime Timestamp) Filter

Nov 1, 2016

Changes in this version

type Filter

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

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