Documentation ¶
Index ¶
- Constants
- Variables
- type ClientLoader
- type KCPOptions
- type ListenerAndServer
- type MemberMap
- type Membered
- func (m *Membered) AddLocal(bu *bucketstore.Bucket)
- func (m *Membered) GetBroadcasts(overhead, limit int) [][]byte
- func (m *Membered) ListenAndServe()
- func (m *Membered) LocalState(join bool) []byte
- func (m *Membered) MergeRemoteState(buf []byte, join bool)
- func (m *Membered) NodeMeta(limit int) []byte
- func (m *Membered) NotifyAlive(peer *memberlist.Node) error
- func (m *Membered) NotifyJoin(n *memberlist.Node)
- func (m *Membered) NotifyLeave(n *memberlist.Node)
- func (m *Membered) NotifyMerge(peers []*memberlist.Node) error
- func (m *Membered) NotifyMsg([]byte)
- func (m *Membered) NotifyUpdate(n *memberlist.Node)
- type MetaData
- type NodeError
- type OtherMember
Constants ¶
View Source
const ( Proto_HTTP = iota Proto_OO Proto_KCP )
Variables ¶
View Source
var ClientPlugins = map[uint]ClientLoader{ Proto_HTTP: ccHttp, Proto_OO: ccOO, Proto_KCP: ccKcp, }
View Source
var ENodeError error = NodeError(0)
View Source
var ServerPlugins = map[uint]ListenerAndServer{ Proto_HTTP: lasHttp, Proto_OO: lasOO, Proto_KCP: lasKCP, }
Functions ¶
This section is empty.
Types ¶
type ClientLoader ¶
type ClientLoader func(*MetaData, net.IP) remote.HttpClient
type KCPOptions ¶
type ListenerAndServer ¶
type ListenerAndServer func(*MetaData, fasthttp.RequestHandler)
type MemberMap ¶
type MemberMap map[string]*OtherMember
type Membered ¶
func NewMembered ¶
func NewMembered() *Membered
func (*Membered) AddLocal ¶
func (m *Membered) AddLocal(bu *bucketstore.Bucket)
func (*Membered) GetBroadcasts ¶
func (*Membered) ListenAndServe ¶
func (m *Membered) ListenAndServe()
func (*Membered) LocalState ¶
func (*Membered) MergeRemoteState ¶
func (*Membered) NotifyAlive ¶
func (m *Membered) NotifyAlive(peer *memberlist.Node) error
func (*Membered) NotifyJoin ¶
func (m *Membered) NotifyJoin(n *memberlist.Node)
func (*Membered) NotifyLeave ¶
func (m *Membered) NotifyLeave(n *memberlist.Node)
func (*Membered) NotifyMerge ¶
func (m *Membered) NotifyMerge(peers []*memberlist.Node) error
func (*Membered) NotifyUpdate ¶
func (m *Membered) NotifyUpdate(n *memberlist.Node)
type OtherMember ¶
type OtherMember struct { Client remote.HttpClient Meta MetaData }
Click to show internal directories.
Click to hide internal directories.