finder

Documentation

Index

• type Finder
  • func NewFinder(db fdb.Database, opts ...FinderOption) (exp *Finder, err error)
  • func (exp *Finder) GetBoundaryKeys() (boundaryKeys []fdb.Key, err error)
  • func (exp *Finder) GetLocations(boundaryKeys []fdb.Key, skipHostResolution bool) (pmap *PartitionMap, err error)
• type FinderOption
  • func Logger(logger *zap.Logger) FinderOption
• type PartitionMap
• type RangeLocation
• type StorageGroup

Types

type Finder

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

func NewFinder

func NewFinder(db fdb.Database,
	opts ...FinderOption,
) (exp *Finder, err error)

func (*Finder) GetBoundaryKeys

func (exp *Finder) GetBoundaryKeys() (boundaryKeys []fdb.Key, err error)

func (*Finder) GetLocations

func (exp *Finder) GetLocations(boundaryKeys []fdb.Key, skipHostResolution bool) (pmap *PartitionMap, err error)

type FinderOption

type FinderOption func(exp *Finder)

func Logger

func Logger(logger *zap.Logger) FinderOption

type PartitionMap

type PartitionMap struct {
	Nodes  map[string]StorageGroup
	Ranges []RangeLocation
}

type RangeLocation

type RangeLocation struct {
	Krange fdb.KeyRange
	Hosts  []string
}

rangeLocation represents a set of hosts holding the given range.

type StorageGroup

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

storageGroup represents a set of ranges hosted by a single node A slice of storageGroup representing entire cluster will have many ranges with overlapping contents - since same range will be stored in multiple nodes.