internal

Documentation

Index

• func NewDispatcher(bt *BigTable, config *Config) rpc.Dispatcher
• func SetClock(c timekeeper.TimeKeeper)
• func SetGcGracePeriod(p time.Duration)
• type BigTable
  • func NewBigTable(keyFile, project, zone, cluster, tableName string) (*BigTable, error)
  • func NewTestBigTable(tableName string) (*BigTable, func(), error)
  • func (b *BigTable) CountRows(ctx *context.T) (int, error)
  • func (b *BigTable) Counters(ctx *context.T) (map[string]int64, error)
  • func (b *BigTable) DeleteTable(ctx *context.T) error
  • func (b *BigTable) DumpTable(ctx *context.T) error
  • func (b *BigTable) Fsck(ctx *context.T, fix bool) error
  • func (b *BigTable) SetupTable(ctx *context.T, permissionsFile string) error
• type Config

Functions

func NewDispatcher

func NewDispatcher(bt *BigTable, config *Config) rpc.Dispatcher

func SetClock

func SetClock(c timekeeper.TimeKeeper)

For testing only.

func SetGcGracePeriod

func SetGcGracePeriod(p time.Duration)

SetGcGracePeriod sets the grace period for garbage collecting newly created nodes. Nodes are not eligible for garbage collection until after this time has passed. This function exists only for testing purposes.

Types

type BigTable

type BigTable struct {
	// contains filtered or unexported fields
}

func NewBigTable

func NewBigTable(keyFile, project, zone, cluster, tableName string) (*BigTable, error)

NewBigTable returns a BigTable object that abstracts some aspects of the Cloud Bigtable API.

func NewTestBigTable

func NewTestBigTable(tableName string) (*BigTable, func(), error)

NewTestBigTable returns a BigTable object that is connected to an in-memory fake bigtable cluster.

func (*BigTable) CountRows

func (b *BigTable) CountRows(ctx *context.T) (int, error)

func (*BigTable) Counters

func (b *BigTable) Counters(ctx *context.T) (map[string]int64, error)

func (*BigTable) DeleteTable

func (b *BigTable) DeleteTable(ctx *context.T) error

DeleteTable deletes the table.

func (*BigTable) DumpTable

func (b *BigTable) DumpTable(ctx *context.T) error

DumpTable prints all the mounttable nodes stored in the bigtable.

func (*BigTable) Fsck

func (b *BigTable) Fsck(ctx *context.T, fix bool) error

func (*BigTable) SetupTable

func (b *BigTable) SetupTable(ctx *context.T, permissionsFile string) error

SetupTable creates the table, column families, and GC policies.

type Config

type Config struct {
	GlobalAcl         access.AccessList
	MaxNodesPerUser   int64
	MaxServersPerUser int64
}