Documentation ¶
Index ¶
- Constants
- func BecomeMember(wn *mlst.WrapNode)
- type Entry
- type Subscriber
- func (s *Subscriber) Attach(wn *mlst.WrapNode)
- func (s *Subscriber) CheckSelf(head *avl.Node) bool
- func (s *Subscriber) HrRoute(w *mlst.WrapNode, d *mlst.MessageReader, msg bufferex.Binary) bool
- func (s *Subscriber) NotifyJoin(node *memberlist.Node)
- func (s *Subscriber) NotifyLeave(node *memberlist.Node)
- func (s *Subscriber) NotifyUpdate(node *memberlist.Node)
- type Table
- func (t *Table) Cleanup()
- func (t *Table) Debug_Dump()
- func (t *Table) Init()
- func (t *Table) Invalidate(name string)
- func (t *Table) Join(name string)
- func (t *Table) Leave(name string)
- func (t *Table) Left() *avl.Node
- func (t *Table) Next(id string) (node *avl.Node)
- func (t *Table) NextOrEqual(id string) (node *avl.Node)
- func (t *Table) Prev(id string) (node *avl.Node)
- func (t *Table) PrevOrEqual(id string) (node *avl.Node)
- func (t *Table) Step(to *avl.Node) *avl.Node
- func (t *Table) StepReverse(to *avl.Node) *avl.Node
- func (t *Table) Validate(name string)
Constants ¶
View Source
const ( HRF_Subscriber = 1 << iota HRF_Member )
View Source
const (
MH_HrRoute = 0x20000 + iota
)
View Source
const (
MT_HashRingFlags = 0x20000 | iota
)
View Source
const (
RTF_Last = 1 << iota
)
Route-Flags
Variables ¶
This section is empty.
Functions ¶
func BecomeMember ¶
Types ¶
type Subscriber ¶
func (*Subscriber) Attach ¶
func (s *Subscriber) Attach(wn *mlst.WrapNode)
func (*Subscriber) HrRoute ¶
func (s *Subscriber) HrRoute(w *mlst.WrapNode, d *mlst.MessageReader, msg bufferex.Binary) bool
func (*Subscriber) NotifyJoin ¶
func (s *Subscriber) NotifyJoin(node *memberlist.Node)
func (*Subscriber) NotifyLeave ¶
func (s *Subscriber) NotifyLeave(node *memberlist.Node)
func (*Subscriber) NotifyUpdate ¶
func (s *Subscriber) NotifyUpdate(node *memberlist.Node)
type Table ¶
type Table struct { HashFunc func(string) string NodeDeath time.Duration // contains filtered or unexported fields }
func (*Table) Debug_Dump ¶
func (t *Table) Debug_Dump()
func (*Table) Invalidate ¶
A node, with the hashring extension enabled turns off the hashring extension.
On nodes, with the hashring extension already turned off, this has no effect.
Click to show internal directories.
Click to hide internal directories.