Versions in this module Expand all Collapse all v1 v1.0.0 Mar 2, 2019 Changes in this version + const DefaultMaxResultSize + const DefaultMaxResultsPerColumnFamily + const DefaultMaxVersions + const DefaultNumberOfRows + const MaxTimestamp + const MinTimestamp + var ErrNotAStruct = errors.New("data must be a struct") + var ErrUnsupportedInts = errors.New("ints are unsupported on your platform") + var ErrUnsupportedUints = errors.New("uints are unsupported on your platform") + func AllowPartialResults() func(Call) error + func CloseScanner() func(Call) error + func DeleteOneVersion() func(Call) error + func Durability(d DurabilityType) func(Call) error + func Families(f map[string][]string) func(Call) error + func Filters(f filter.Filter) func(Call) error + func MaxResultSize(n uint64) func(Call) error + func MaxResultsPerColumnFamily(maxresults uint32) func(Call) error + func MaxVersions(versions uint32) func(Call) error + func NumberOfRows(n uint32) func(Call) error + func ResultOffset(offset uint32) func(Call) error + func Reversed() func(Call) error + func ScannerID(id uint64) func(Call) error + func SkipBatch() func(Call) error + func SplitKeys(sk [][]byte) func(*CreateTable) + func TTL(t time.Duration) func(Call) error + func TimeRange(from, to time.Time) func(Call) error + func TimeRangeUint64(from, to uint64) func(Call) error + func Timestamp(ts time.Time) func(Call) error + func TimestampUint64(ts uint64) func(Call) error + type Batchable interface + SkipBatch func() bool + type Call interface + Context func() context.Context + Key func() []byte + Name func() string + NewResponse func() proto.Message + Region func() RegionInfo + ResultChan func() chan RPCResult + SetRegion func(region RegionInfo) + Table func() []byte + ToProto func() proto.Message + type Cell pb.Cell + func (c *Cell) String() string + type CheckAndPut struct + func NewCheckAndPut(put *Mutate, family string, qualifier string, expectedValue []byte) (*CheckAndPut, error) + func (b CheckAndPut) Context() context.Context + func (b CheckAndPut) Key() []byte + func (b CheckAndPut) Options() []func(Call) error + func (b CheckAndPut) Region() RegionInfo + func (b CheckAndPut) ResultChan() chan RPCResult + func (b CheckAndPut) SetRegion(region RegionInfo) + func (b CheckAndPut) Table() []byte + func (cp *CheckAndPut) ToProto() proto.Message + type ClusterStatus struct + func NewClusterStatus() *ClusterStatus + func (b *ClusterStatus) Context() context.Context + func (b *ClusterStatus) Key() []byte + func (b *ClusterStatus) Options() []func(Call) error + func (b *ClusterStatus) Region() RegionInfo + func (b *ClusterStatus) ResultChan() chan RPCResult + func (b *ClusterStatus) SetRegion(region RegionInfo) + func (b *ClusterStatus) Table() []byte + func (c *ClusterStatus) Name() string + func (c *ClusterStatus) NewResponse() proto.Message + func (c *ClusterStatus) ToProto() proto.Message + type CreateTable struct + func NewCreateTable(ctx context.Context, table []byte, families map[string]map[string]string, ...) *CreateTable + func (b *CreateTable) Context() context.Context + func (b *CreateTable) Key() []byte + func (b *CreateTable) Options() []func(Call) error + func (b *CreateTable) Region() RegionInfo + func (b *CreateTable) ResultChan() chan RPCResult + func (b *CreateTable) SetRegion(region RegionInfo) + func (b *CreateTable) Table() []byte + func (ct *CreateTable) Name() string + func (ct *CreateTable) NewResponse() proto.Message + func (ct *CreateTable) ToProto() proto.Message + type DeleteTable struct + func NewDeleteTable(ctx context.Context, table []byte) *DeleteTable + func (b *DeleteTable) Context() context.Context + func (b *DeleteTable) Key() []byte + func (b *DeleteTable) Options() []func(Call) error + func (b *DeleteTable) Region() RegionInfo + func (b *DeleteTable) ResultChan() chan RPCResult + func (b *DeleteTable) SetRegion(region RegionInfo) + func (b *DeleteTable) Table() []byte + func (dt *DeleteTable) Name() string + func (dt *DeleteTable) NewResponse() proto.Message + func (dt *DeleteTable) ToProto() proto.Message + type DisableTable struct + func NewDisableTable(ctx context.Context, table []byte) *DisableTable + func (b *DisableTable) Context() context.Context + func (b *DisableTable) Key() []byte + func (b *DisableTable) Options() []func(Call) error + func (b *DisableTable) Region() RegionInfo + func (b *DisableTable) ResultChan() chan RPCResult + func (b *DisableTable) SetRegion(region RegionInfo) + func (b *DisableTable) Table() []byte + func (dt *DisableTable) Name() string + func (dt *DisableTable) NewResponse() proto.Message + func (dt *DisableTable) ToProto() proto.Message + type DurabilityType int32 + const AsyncWal + const FsyncWal + const SkipWal + const SyncWal + const UseDefault + type EnableTable struct + func NewEnableTable(ctx context.Context, table []byte) *EnableTable + func (b *EnableTable) Context() context.Context + func (b *EnableTable) Key() []byte + func (b *EnableTable) Options() []func(Call) error + func (b *EnableTable) Region() RegionInfo + func (b *EnableTable) ResultChan() chan RPCResult + func (b *EnableTable) SetRegion(region RegionInfo) + func (b *EnableTable) Table() []byte + func (et *EnableTable) Name() string + func (et *EnableTable) NewResponse() proto.Message + func (et *EnableTable) ToProto() proto.Message + type Get struct + func NewGet(ctx context.Context, table, key []byte, options ...func(Call) error) (*Get, error) + func NewGetStr(ctx context.Context, table, key string, options ...func(Call) error) (*Get, error) + func (b *Get) Context() context.Context + func (b *Get) Key() []byte + func (b *Get) Options() []func(Call) error + func (b *Get) Region() RegionInfo + func (b *Get) ResultChan() chan RPCResult + func (b *Get) SetRegion(region RegionInfo) + func (b *Get) Table() []byte + func (g *Get) DeserializeCellBlocks(m proto.Message, b []byte) (uint32, error) + func (g *Get) ExistsOnly() + func (g *Get) Name() string + func (g *Get) NewResponse() proto.Message + func (g *Get) SkipBatch() bool + func (g *Get) ToProto() proto.Message + type GetProcedureState struct + func NewGetProcedureState(ctx context.Context, procID uint64) *GetProcedureState + func (b *GetProcedureState) Context() context.Context + func (b *GetProcedureState) Key() []byte + func (b *GetProcedureState) Options() []func(Call) error + func (b *GetProcedureState) Region() RegionInfo + func (b *GetProcedureState) ResultChan() chan RPCResult + func (b *GetProcedureState) SetRegion(region RegionInfo) + func (b *GetProcedureState) Table() []byte + func (ps *GetProcedureState) Name() string + func (ps *GetProcedureState) NewResponse() proto.Message + func (ps *GetProcedureState) ToProto() proto.Message + type Mutate struct + func NewApp(ctx context.Context, table, key []byte, values map[string]map[string][]byte, ...) (*Mutate, error) + func NewAppStr(ctx context.Context, table, key string, values map[string]map[string][]byte, ...) (*Mutate, error) + func NewDel(ctx context.Context, table, key []byte, values map[string]map[string][]byte, ...) (*Mutate, error) + func NewDelStr(ctx context.Context, table, key string, values map[string]map[string][]byte, ...) (*Mutate, error) + func NewInc(ctx context.Context, table, key []byte, values map[string]map[string][]byte, ...) (*Mutate, error) + func NewIncSingle(ctx context.Context, table, key []byte, family, qualifier string, amount int64, ...) (*Mutate, error) + func NewIncStr(ctx context.Context, table, key string, values map[string]map[string][]byte, ...) (*Mutate, error) + func NewIncStrSingle(ctx context.Context, table, key, family, qualifier string, amount int64, ...) (*Mutate, error) + func NewPut(ctx context.Context, table, key []byte, values map[string]map[string][]byte, ...) (*Mutate, error) + func NewPutStr(ctx context.Context, table, key string, values map[string]map[string][]byte, ...) (*Mutate, error) + func (b *Mutate) Context() context.Context + func (b *Mutate) Key() []byte + func (b *Mutate) Options() []func(Call) error + func (b *Mutate) Region() RegionInfo + func (b *Mutate) ResultChan() chan RPCResult + func (b *Mutate) SetRegion(region RegionInfo) + func (b *Mutate) Table() []byte + func (m *Mutate) DeserializeCellBlocks(pm proto.Message, b []byte) (uint32, error) + func (m *Mutate) Name() string + func (m *Mutate) NewResponse() proto.Message + func (m *Mutate) SkipBatch() bool + func (m *Mutate) ToProto() proto.Message + type RPCResult struct + Error error + Msg proto.Message + type RegionClient interface + Addr func() string + Close func() + QueueRPC func(Call) + String func() string + type RegionInfo interface + AvailabilityChan func() <-chan struct{} + Client func() RegionClient + Context func() context.Context + ID func() uint64 + IsUnavailable func() bool + MarkAvailable func() + MarkDead func() + MarkUnavailable func() bool + Name func() []byte + Namespace func() []byte + SetClient func(RegionClient) + StartKey func() []byte + StopKey func() []byte + String func() string + Table func() []byte + type Result struct + Cells []*Cell + Exists *bool + Partial bool + Stale bool + func ToLocalResult(pbr *pb.Result) *Result + type Scan struct + func NewScan(ctx context.Context, table []byte, options ...func(Call) error) (*Scan, error) + func NewScanRange(ctx context.Context, table, startRow, stopRow []byte, ...) (*Scan, error) + func NewScanRangeStr(ctx context.Context, table, startRow, stopRow string, ...) (*Scan, error) + func NewScanStr(ctx context.Context, table string, options ...func(Call) error) (*Scan, error) + func (b *Scan) Context() context.Context + func (b *Scan) Key() []byte + func (b *Scan) Options() []func(Call) error + func (b *Scan) Region() RegionInfo + func (b *Scan) ResultChan() chan RPCResult + func (b *Scan) SetRegion(region RegionInfo) + func (b *Scan) Table() []byte + func (s *Scan) AllowPartialResults() bool + func (s *Scan) DeserializeCellBlocks(m proto.Message, b []byte) (uint32, error) + func (s *Scan) IsClosing() bool + func (s *Scan) Name() string + func (s *Scan) NewResponse() proto.Message + func (s *Scan) NumberOfRows() uint32 + func (s *Scan) Reversed() bool + func (s *Scan) StartRow() []byte + func (s *Scan) StopRow() []byte + func (s *Scan) String() string + func (s *Scan) ToProto() proto.Message + type Scanner interface + Close func() error + Next func() (*Result, error)