Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func PartitionIndex ¶
Types ¶
type Context ¶
type Context struct {
// Every command should use Context as the fmt.Fprint's writer.
io.Writer
pegasus.Client
Meta *session.MetaManager
// default to nil
UseTable pegasus.TableConnector
UseTableName string
// default to 0
UseTablePartitionCount int
// default to nil
Compressor util.BytesCompression
HashKeyEnc, SortKeyEnc, ValueEnc util.Encoder
}
type ScanCommand ¶
type ScanCommand struct {
HashKey string
// optional
From, To *string
Prefix, Suffix, Contains *string
// only calculate the count of sortkeys under this hashkey.
// default to false.
CountOnly bool
}
ScanCommand wraps scan command input.
func (*ScanCommand) IterateAll ¶
func (s *ScanCommand) IterateAll(rootCtx *Context) error
IterateAll iterates over the table according to the command.
func (*ScanCommand) Validate ¶
func (s *ScanCommand) Validate() error
Validate if ScanCommand is valid.
Click to show internal directories.
Click to hide internal directories.