ring

Jun 20, 2016

Changes in this version

+ type OnUpdate func(prev, curr []address.Range, local bool)

type Ring

+ func (r *Ring) OwnedRangesOfPeer(peer mesh.PeerName) (result []address.Range)

+ func (r *Ring) Restore(other *Ring)

Dec 17, 2015

Changes in this version

+ type RangeInfo struct

+ Peer mesh.PeerName

+ Version uint32

type Ring

+ func (r *Ring) AllRangeInfo() (result []RangeInfo)

Oct 22, 2015

Changes in this version

+ var ErrDifferentSeeds = errors.New("Received ring was seeded differently from ours!")

type Ring

+ Seeds []router.PeerName

Sep 7, 2015

Changes in this version

+ var ErrDifferentRange = errors.New("Received range differs from ours!")

type Ring

+ func (r *Ring) Range() address.Range

Aug 18, 2015

Changes in this version

type Ring

+ func (r *Ring) ChoosePeersToAskForSpace(start, end address.Address) []router.PeerName

May 26, 2015

Changes in this version

+ var ErrDifferentSubnets = errors.New("IP Allocator with different subnet detected")

+ var ErrEntryInMyRange = errors.New("Received new entry in my range!")

+ var ErrInvalidEntry = errors.New("Received invalid state update!")

+ var ErrInvalidTimeout = errors.New("dt must be greater than 0")

+ var ErrNewerVersion = errors.New("Received new version for entry I own!")

+ var ErrNoFreeSpace = errors.New("No free space found!")

+ var ErrNotFound = errors.New("No entries for peer found")

+ var ErrNotSorted = errors.New("Ring not sorted")

+ var ErrTokenOutOfRange = errors.New("Token is out of range")

+ var ErrTokenRepeated = errors.New("Token appears twice in ring")

+ var ErrTooMuchFreeSpace = errors.New("Entry reporting too much free space!")

+ type Ring struct

+ End address.Address

+ Entries entries

+ Peer router.PeerName

+ Start address.Address

+ func New(start, end address.Address, peer router.PeerName) *Ring

+ func (r *Ring) ChoosePeerToAskForSpace() (result router.PeerName, err error)

+ func (r *Ring) ClaimForPeers(peers []router.PeerName)

+ func (r *Ring) ClaimItAll()

+ func (r *Ring) Contains(addr address.Address) bool

+ func (r *Ring) Empty() bool

+ func (r *Ring) FprintWithNicknames(w io.Writer, m map[router.PeerName]string)

+ func (r *Ring) GrantRangeToHost(start, end address.Address, peer router.PeerName)

+ func (r *Ring) Merge(gossip Ring) error

+ func (r *Ring) OwnedRanges() (result []address.Range)

+ func (r *Ring) Owner(token address.Address) router.PeerName

+ func (r *Ring) PeerNames() map[router.PeerName]struct{}

+ func (r *Ring) PickPeerForTransfer() router.PeerName

+ func (r *Ring) ReportFree(freespace map[address.Address]address.Offset)

+ func (r *Ring) String() string

+ func (r *Ring) TotalRemoteFree() address.Offset

+ func (r *Ring) Transfer(from, to router.PeerName) (error, []address.Range)