Versions in this module Expand all Collapse all v0 v0.0.7 Mar 11, 2022 Changes in this version + func Del(rootCtx *Context, hashKeyStr, sortkeyStr string) error + func Get(rootCtx *Context, hashKeyStr, sortkeyStr string) error + func PartitionIndex(rootCtx *Context, hashKeyStr string) error + func Set(rootCtx *Context, hashKeyStr, sortkeyStr, valueStr string) error + type Context struct + Compressor util.BytesCompression + HashKeyEnc util.Encoder + Meta *session.MetaManager + SortKeyEnc util.Encoder + UseTable pegasus.TableConnector + UseTableName string + UseTablePartitionCount int + ValueEnc util.Encoder + func NewContext(writer io.Writer, metaAddrs []string) *Context + func (c *Context) String() string + type ScanCommand struct + Contains *string + CountOnly bool + From *string + HashKey string + Prefix *string + Suffix *string + To *string + func (s *ScanCommand) IterateAll(rootCtx *Context) error + func (s *ScanCommand) Validate() error
Go to main page