Documentation ¶
Index ¶
- Variables
- type BTree2D
- type HashRingSelector
- type Iterator
- type Pair
- type RandomSelector
- type Reducer
- type Registry
- func (self *Registry) Close()
- func (self *Registry) Discover(r Selector, sname generic.T, reducer Reducer) (generic.U, bool)
- func (self *Registry) DiscoverTimeout(r Selector, sname generic.T, wait time.Duration, reducer Reducer) (srv generic.U, found bool)
- func (self *Registry) Iter() Iterator
- func (self *Registry) Pop(id generic.T, srv generic.U)
- func (self *Registry) Push(id generic.T, srv generic.U, action ...func())
- func (self *Registry) Sync(other *Registry, onAdd, onDelete func(generic.T, generic.U))
- type SecondaryLayer
- type Selector
Constants ¶
This section is empty.
Variables ¶
View Source
var BTreeNew func() BTree2D
Functions ¶
This section is empty.
Types ¶
type BTree2D ¶
type BTree2D interface { Sync(next BTree2D, onAdd, onDel func(key1 generic.T, key2 generic.U)) GetLayer(key1 generic.T) (SecondaryLayer, bool) SetLayer(key1 generic.T, layer SecondaryLayer) ForEach(fn func(key generic.T, layer SecondaryLayer) bool) ForEach2(key1 generic.T, fn func(key2 generic.U) bool) Put(key1 generic.T, key2 generic.U, finalizers ...func()) Delete(key1 generic.T, key2 generic.U) bool Drop(key1 generic.T) bool }
type HashRingSelector ¶
type HashRingSelector struct {
VBucket int
}
type RandomSelector ¶
type RandomSelector struct { }
type Registry ¶
type Registry struct {
// contains filtered or unexported fields
}
func (*Registry) DiscoverTimeout ¶
type SecondaryLayer ¶
type SecondaryLayer interface{}
Click to show internal directories.
Click to hide internal directories.