bigtable

Sep 9, 2024

Changes in this version

+ type StringUtf8BytesEncoding struct

+ type TypeUnspecified struct

Aug 27, 2024

Changes in this version

+ func Equal(a, b Type) bool

+ func MarshalJSON(t Type) ([]byte, error)

type AdminClient

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

type Type

+ func UnmarshalJSON(data []byte) (Type, error)

+ type UpdateFamilyOption GCPolicyOption

Aug 5, 2024

Changes in this version

+ type HllppUniqueCountAggregator struct

+ type MaxAggregator struct

+ type MinAggregator struct

type Mutation

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

type Type

+ func ProtoToType(pb *btapb.Type) Type

Jul 25, 2024

Changes in this version

type ClientConfig

+ MetricsProvider MetricsProvider

+ type MetricsProvider interface

+ type NoopMetricsProvider struct

Jul 23, 2024

Changes in this version

type FamilyInfo

+ ValueType Type

Jun 20, 2024

Changes in this version

+ type StringEncoding interface

+ type StringType struct

+ Encoding StringEncoding

+ type StringUtf8Encoding struct

May 28, 2024

Changes in this version

type AdminClient

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

+ func (ac *AdminClient) UpdateTableDisableAutomatedBackupPolicy(ctx context.Context, tableID string) error

+ func (ac *AdminClient) UpdateTableWithAutomatedBackupPolicy(ctx context.Context, tableID string, ...) error

+ type GCPolicyOption interface

+ func IgnoreWarnings() GCPolicyOption

+ type TableAutomatedBackupConfig interface

+ type TableAutomatedBackupPolicy struct

+ Frequency optional.Duration

+ RetentionPeriod optional.Duration

type TableConf

+ AutomatedBackupConfig TableAutomatedBackupConfig

type TableInfo

+ AutomatedBackupConfig TableAutomatedBackupConfig

Apr 29, 2024

Changes in this version

type AdminClient

+ func (ac *AdminClient) AuthorizedViewIAM(table, authorizedView string) *iam.Handle

+ func (ac *AdminClient) AuthorizedViewInfo(ctx context.Context, tableID, authorizedViewID string) (*AuthorizedViewInfo, error)

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

+ func (ac *AdminClient) CreateAuthorizedView(ctx context.Context, conf *AuthorizedViewConf) error

+ func (ac *AdminClient) DeleteAuthorizedView(ctx context.Context, tableID, authorizedViewID string) error

+ func (ac *AdminClient) UpdateAuthorizedView(ctx context.Context, conf UpdateAuthorizedViewConf) error

+ type AuthorizedViewConf struct

+ AuthorizedView isAuthorizedView

+ AuthorizedViewID string

+ DeletionProtection DeletionProtection

+ TableID string

+ type AuthorizedViewInfo struct

+ AuthorizedView isAuthorizedViewInfo

+ AuthorizedViewID string

+ DeletionProtection DeletionProtection

+ TableID string

type Client

+ func (c *Client) OpenAuthorizedView(table, authorizedView string) TableAPI

+ func (c *Client) OpenTable(table string) TableAPI

+ type FamilySubset struct

+ QualifierPrefixes [][]byte

+ Qualifiers [][]byte

+ type SubsetViewConf struct

+ FamilySubsets map[string]FamilySubset

+ RowPrefixes [][]byte

+ func (s *SubsetViewConf) AddFamilySubsetQualifier(familyName string, qualifier []byte)

+ func (s *SubsetViewConf) AddFamilySubsetQualifierPrefix(familyName string, qualifierPrefix []byte)

+ func (s *SubsetViewConf) AddRowPrefix(prefix []byte)

+ type SubsetViewInfo struct

+ FamilySubsets map[string]FamilySubset

+ RowPrefixes [][]byte

+ type TableAPI interface

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

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

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

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

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

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

+ type UpdateAuthorizedViewConf struct

+ AuthorizedViewConf AuthorizedViewConf

+ IgnoreWarnings bool

Mar 11, 2024

Changes in this version

type AdminClient

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

+ type AggregateType struct

+ Aggregator Aggregator

+ Input Type

+ type Aggregator interface

+ type BigEndianBytesEncoding struct

+ Bytes BytesType

+ type BytesEncoding interface

+ type BytesType struct

+ Encoding BytesEncoding

+ type Family struct

+ GCPolicy GCPolicy

+ ValueType Type

+ type Int64Encoding interface

+ type Int64Type struct

+ Encoding Int64Encoding

type Mutation

+ func (m *Mutation) AddIntToCell(family, column string, ts Timestamp, value int64)

+ type RawBytesEncoding struct

+ type SumAggregator struct

type TableConf

+ ColumnFamilies map[string]Family

+ type Type interface

Dec 4, 2023

Changes in this version

type AdminClient

+ func (ac *AdminClient) CopyBackup(ctx context.Context, ...) error

type BackupInfo

+ SourceBackup string

type ReadOption

+ func ReverseScan() ReadOption

type RowRange

+ func InfiniteReverseRange(end string) RowRange

+ func NewClosedOpenRange(start, end string) RowRange

+ func NewClosedRange(start, end string) RowRange

+ func NewOpenClosedRange(start, end string) RowRange

+ func NewOpenRange(start, end string) RowRange

Jul 7, 2023

Changes in this version

type AdminClient

+ func (ac *AdminClient) UpdateTableDisableChangeStream(ctx context.Context, tableID string) error

+ func (ac *AdminClient) UpdateTableWithChangeStream(ctx context.Context, tableID string, ...) error

+ type ChangeStreamRetention optional.Duration

type TableConf

+ ChangeStreamRetention ChangeStreamRetention

type TableInfo

+ ChangeStreamRetention ChangeStreamRetention

Nov 10, 2022

Changes in this version

+ type FullReadStats struct

+ ReadIterationStats ReadIterationStats

+ RequestLatencyStats RequestLatencyStats

+ type FullReadStatsFunc func(*FullReadStats)

+ type ReadIterationStats struct

+ CellsReturnedCount int64

+ CellsSeenCount int64

+ RowsReturnedCount int64

+ RowsSeenCount int64

type ReadOption

+ func WithFullReadStats(f FullReadStatsFunc) ReadOption

+ type RequestLatencyStats struct

+ FrontendServerLatency time.Duration

Nov 3, 2022

Changes in this version

type AdminClient

+ func (ac *AdminClient) UpdateTableWithDeletionProtection(ctx context.Context, tableID string, deletionProtection DeletionProtection) error

+ type DeletionProtection int

+ const None

+ const Protected

+ const Unprotected

type TableConf

+ DeletionProtection DeletionProtection

type TableInfo

+ DeletionProtection DeletionProtection

+ type UpdateTableConf struct

Jul 27, 2022

Changes in this version

type AutoscalingConfig

+ StorageUtilizationPerNode int

+ type IntersectionGCPolicy struct

+ Children []GCPolicy

+ func (ip IntersectionGCPolicy) String() string

+ type MaxAgeGCPolicy time.Duration

+ func (ma MaxAgeGCPolicy) GetDurationString() string

+ func (ma MaxAgeGCPolicy) String() string

+ type MaxVersionsGCPolicy int

+ func (mvp MaxVersionsGCPolicy) String() string

+ type PolicyType int

+ const PolicyIntersection

+ const PolicyMaxAge

+ const PolicyMaxVersion

+ const PolicyUnion

+ const PolicyUnspecified

+ func GetPolicyType(gc GCPolicy) PolicyType

+ type UnionGCPolicy struct

+ Children []GCPolicy

+ func (up UnionGCPolicy) String() string

Jul 7, 2022

Changes in this version

type FamilyInfo

+ FullGCPolicy GCPolicy

Jan 25, 2022

Changes in this version

+ type AutoscalingConfig struct

+ CPUTargetPercent int

+ MaxNodes int

+ MinNodes int

type ClusterConfig

+ AutoscalingConfig *AutoscalingConfig

type ClusterInfo

+ AutoscalingConfig *AutoscalingConfig

type InstanceAdminClient

+ func (iac *InstanceAdminClient) SetAutoscaling(ctx context.Context, instanceID, clusterID string, conf AutoscalingConfig) error

type InstanceConf

+ AutoscalingConfig *AutoscalingConfig

May 3, 2021

Changes in this version

type AdminClient

+ func (ac *AdminClient) RestoreTableFrom(ctx context.Context, sourceInstance, table, sourceCluster, backup string) error

Apr 30, 2021

Changes in this version

type AdminClient

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

type BackupInfo

+ EncryptionInfo *EncryptionInfo

type ClusterConfig

+ KMSKeyName string

type ClusterInfo

+ KMSKeyName string

+ type EncryptionInfo struct

+ KMSKeyVersion string

+ Status *Status

+ Type EncryptionType

+ type EncryptionInfoByCluster map[string][]*EncryptionInfo

+ type EncryptionType int32

+ const CustomerManagedEncryption

+ const EncryptionTypeUnspecified

+ const GoogleDefaultEncryption

+ type Status = status.Status

Jan 19, 2021

Changes in this version

type AdminClient

+ func (ac *AdminClient) BackupIAM(cluster, backup string) *iam.Handle

Sep 15, 2020

Changes in this version

+ type ErrPartiallyUnavailable struct

+ Locations []string

+ func (e ErrPartiallyUnavailable) Error() string

type Filter

+ func LabelFilter(label string) Filter

type ReadItem

+ Labels []string

Jul 21, 2020

Changes in this version

type AdminClient

+ func (ac *AdminClient) BackupInfo(ctx context.Context, cluster, backup string) (*BackupInfo, error)

+ func (ac *AdminClient) Backups(ctx context.Context, cluster string) *BackupIterator

+ func (ac *AdminClient) CreateBackup(ctx context.Context, table, cluster, backup string, expireTime time.Time) error

+ func (ac *AdminClient) DeleteBackup(ctx context.Context, cluster, backup string) error

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

+ func (ac *AdminClient) UpdateBackup(ctx context.Context, cluster, backup string, expireTime time.Time) error

+ type BackupInfo struct

+ EndTime time.Time

+ ExpireTime time.Time

+ Name string

+ SizeBytes int64

+ SourceTable string

+ StartTime time.Time

+ State string

+ type BackupIterator struct

+ func (it *BackupIterator) Next() (*BackupInfo, error)

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

Jun 30, 2020

Changes in this version

+ const Creating

+ const NotKnown

+ const Ready

type InstanceConf

+ Labels map[string]string

type InstanceInfo

+ InstanceState InstanceState

+ Labels map[string]string

+ type InstanceState int32

type InstanceWithClustersConfig

+ Labels map[string]string

Oct 29, 2019

Changes in this version

type AdminClient

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

+ func (ac *AdminClient) TableIAM(tableID string) *iam.Handle

type ClusterInfo

+ StorageType StorageType

+ type UpdateInstanceResults struct

+ CreatedClusters []string

+ DeletedClusters []string

+ InstanceUpdated bool

+ UpdatedClusters []string

+ func UpdateInstanceAndSyncClusters(ctx context.Context, iac *InstanceAdminClient, ...) (*UpdateInstanceResults, error)

+ func (r *UpdateInstanceResults) String() string

Aug 13, 2019

Changes in this version

+ const AdminScope

+ const DEVELOPMENT

+ const DefaultSnapshotDuration

+ const InstanceAdminScope

+ const MultiClusterRouting

+ const PRODUCTION

+ const ReadonlyScope

+ const Scope

+ const SingleClusterRouting

+ const UNSPECIFIED

+ func GCRuleToString(rule *bttdpb.GcRule) string

+ 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) CreatePresplitTable(ctx context.Context, table string, splitKeys []string) error

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

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

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

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

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

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

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

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

+ 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) Snapshots(ctx context.Context, cluster string) *SnapshotIterator

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

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

+ func (ac *AdminClient) WaitForReplication(ctx context.Context, table 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 NewClientWithConfig(ctx context.Context, project, instance string, config ClientConfig, ...) (*Client, error)

+ func (c *Client) Close() error

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

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

+ GCPolicy string

+ Name string

+ type Filter interface

+ String func() string

+ func BlockAllFilter() Filter

+ func CellsPerRowLimitFilter(n int) Filter

+ func CellsPerRowOffsetFilter(n int) Filter

+ func ChainFilters(sub ...Filter) Filter

+ func ColumnFilter(pattern string) Filter

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

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

+ func FamilyFilter(pattern string) Filter

+ func InterleaveFilters(sub ...Filter) Filter

+ func LatestNFilter(n int) Filter

+ func PassAllFilter() Filter

+ func RowKeyFilter(pattern string) Filter

+ func RowSampleFilter(p float64) Filter

+ func StripValueFilter() Filter

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

+ func TimestampRangeFilterMicros(startTime Timestamp, endTime Timestamp) Filter

+ func ValueFilter(pattern string) Filter

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

+ type GCPolicy interface

+ String func() string

+ func IntersectionPolicy(sub ...GCPolicy) GCPolicy

+ func MaxAgePolicy(d time.Duration) GCPolicy

+ func MaxVersionsPolicy(n int) GCPolicy

+ func NoGcPolicy() GCPolicy

+ func UnionPolicy(sub ...GCPolicy) GCPolicy

+ type InstanceAdminClient struct

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

+ func (iac *InstanceAdminClient) Close() error

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type InstanceConf struct

+ ClusterId string

+ DisplayName string

+ InstanceId string

+ InstanceType InstanceType

+ NumNodes int32

+ StorageType StorageType

+ Zone string

+ type InstanceInfo struct

+ DisplayName string

+ InstanceType InstanceType

+ Name string

+ type InstanceType int32

+ type InstanceWithClustersConfig struct

+ Clusters []ClusterConfig

+ DisplayName string

+ InstanceID string

+ InstanceType InstanceType

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

+ AllowTransactionalWrites bool

+ ClusterID string

+ Description optional.String

+ IgnoreWarnings bool

+ RoutingPolicy optional.String

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

+ type ProfileConf struct

+ AllowTransactionalWrites bool

+ ClusterID string

+ Description string

+ Etag string

+ IgnoreWarnings bool

+ InstanceID string

+ Name string

+ ProfileID string

+ RoutingPolicy string

+ type ProfileIterator struct

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

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

+ 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 (r RowRange) Contains(row string) bool

+ func (r RowRange) String() string

+ func (r RowRange) Unbounded() bool

+ type RowRangeList []RowRange

+ type RowSet interface

+ func SingleRow(row string) RowSet

+ 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

+ type StorageType int

+ const HDD

+ const SSD

+ type Table struct

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

+ func (t *Table) ApplyBulk(ctx context.Context, rowKeys []string, muts []*Mutation, opts ...ApplyOption) (errs []error, err 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) (err error)

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

+ type TableConf struct

+ Families map[string]GCPolicy

+ SplitKeys []string

+ TableID string

+ type TableInfo struct

+ Families []string

+ FamilyInfos []FamilyInfo

+ type Timestamp int64

+ const ServerTime

+ func Now() Timestamp

+ func Time(t time.Time) Timestamp

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

+ func (ts Timestamp) TruncateToMilliseconds() Timestamp