Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ReadKey ¶
Types ¶
type Batch ¶
type Batch struct { Keys []*aerospike.Key Records []*aerospike.Record }
type BatchIterator ¶
type BatchIterator struct {
// contains filtered or unexported fields
}
BatchIterator represents a helper iterator for full scan, in this case keys were scanned first from each node separately to be used by this batch iterator, after keys files are fully process they will be removed.
func NewBatchIterator ¶
func NewBatchIterator(client *aerospike.Client, batchPolicy *aerospike.BatchPolicy, batchSize int, namespace, table string, fileNames []string, binNames ...string) *BatchIterator
func (*BatchIterator) HasNext ¶
func (i *BatchIterator) HasNext() bool
HasNext check is has more record, if needed it will scan keys from files to batch corresponding records
func (*BatchIterator) Next ¶
func (i *BatchIterator) Next(target interface{}) error
type KeyScanner ¶
type KeyScanner struct {
// contains filtered or unexported fields
}
func NewKeyScanner ¶
func NewKeyScanner(client *aerospike.Client, scanPolicy *aerospike.ScanPolicy, baseDirectory, namespace, dataSet string) *KeyScanner
func (*KeyScanner) Scan ¶
func (s *KeyScanner) Scan() ([]string, error)
Click to show internal directories.
Click to hide internal directories.