Documentation
¶
Overview ¶
Experimental clustering for Dayfile. Really experimental. Not recommended for use.
Index ¶
- func AddDial(n string, f func(addr string) (net.Conn, error))
- func AddListen(n string, f func(addr string) (net.Listener, error))
- type DayfileNode
- type NodeFacade
- func (n *NodeFacade) GetBroadcasts(overhead, limit int) [][]byte
- func (n *NodeFacade) LocalState(join bool) []byte
- func (n *NodeFacade) MergeRemoteState(buf []byte, join bool)
- func (n *NodeFacade) NFInitialize()
- func (n *NodeFacade) NodeMeta(limit int) []byte
- func (n *NodeFacade) NotifyJoin(e *memberlist.Node)
- func (n *NodeFacade) NotifyLeave(e *memberlist.Node)
- func (n *NodeFacade) NotifyMsg([]byte)
- func (n *NodeFacade) NotifyUpdate(e *memberlist.Node)
- type NodeInfo
- type NodeObject
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type DayfileNode ¶
type DayfileNode struct {
ID []byte // Must be 16 bytes.
// contains filtered or unexported fields
}
type NodeFacade ¶
type NodeFacade struct {
LocalName string
LocalNode *NodeInfo
Handler *dbrpc.Handler
Nodes map[string]*NodeObject
Dayfile map[uuid.UUID]*NodeObject
// contains filtered or unexported fields
}
func (*NodeFacade) GetBroadcasts ¶
func (n *NodeFacade) GetBroadcasts(overhead, limit int) [][]byte
func (*NodeFacade) LocalState ¶
func (n *NodeFacade) LocalState(join bool) []byte
func (*NodeFacade) MergeRemoteState ¶
func (n *NodeFacade) MergeRemoteState(buf []byte, join bool)
func (*NodeFacade) NFInitialize ¶
func (n *NodeFacade) NFInitialize()
func (*NodeFacade) NotifyJoin ¶
func (n *NodeFacade) NotifyJoin(e *memberlist.Node)
func (*NodeFacade) NotifyLeave ¶
func (n *NodeFacade) NotifyLeave(e *memberlist.Node)
func (*NodeFacade) NotifyMsg ¶
func (n *NodeFacade) NotifyMsg([]byte)
func (*NodeFacade) NotifyUpdate ¶
func (n *NodeFacade) NotifyUpdate(e *memberlist.Node)
type NodeInfo ¶
type NodeInfo struct {
RpcPort int
RpcProtocol string // Should be "tcp"
DayfileNode *DayfileNode
// contains filtered or unexported fields
}
type NodeObject ¶
Click to show internal directories.
Click to hide internal directories.