Documentation
¶
Index ¶
- func SetDebug(w io.Writer)
- type Config
- type Gossip
- type GossipLayer
- func (l *GossipLayer) DialTimeout(addr string, timeout time.Duration) (net.Conn, error)
- func (l *GossipLayer) FinalAdvertiseAddr(ip string, port int) (net.IP, int, error)
- func (l *GossipLayer) Handoff(c net.Conn) error
- func (l *GossipLayer) PacketCh() <-chan *memberlist.Packet
- func (l *GossipLayer) Shutdown() error
- func (l *GossipLayer) StreamCh() <-chan net.Conn
- func (l *GossipLayer) Type() rpc.RPCType
- func (l *GossipLayer) WriteTo(b []byte, addr string) (time.Time, error)
- type Member
- type NodeMeta
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Gossip ¶
type Gossip struct { *memberlist.Memberlist // contains filtered or unexported fields }
TODO: gossip should be the top level membership with myriad.Cluster?
func (*Gossip) Events ¶
func (g *Gossip) Events() <-chan memberlist.NodeEvent
func (*Gossip) SetLocalNode ¶
type GossipLayer ¶
type GossipLayer struct {
// contains filtered or unexported fields
}
func NewGossipLayer ¶
func NewGossipLayer(addr string) (*GossipLayer, error)
func (*GossipLayer) DialTimeout ¶
func (*GossipLayer) FinalAdvertiseAddr ¶
func (*GossipLayer) PacketCh ¶
func (l *GossipLayer) PacketCh() <-chan *memberlist.Packet
func (*GossipLayer) Shutdown ¶
func (l *GossipLayer) Shutdown() error
func (*GossipLayer) StreamCh ¶
func (l *GossipLayer) StreamCh() <-chan net.Conn
func (*GossipLayer) Type ¶
func (l *GossipLayer) Type() rpc.RPCType
Click to show internal directories.
Click to hide internal directories.