cluster

Jan 16, 2017

Changes in this version

+ const PeerTypeIngest

+ const PeerTypeIngestStore

+ const PeerTypeStore

+ type Peer struct

+ func NewPeer(addr string, port int, existing []string, t PeerType, apiPort int, ...) (*Peer, error)

+ func (p *Peer) ClusterSize() int

+ func (p *Peer) Current(t PeerType) []string

+ func (p *Peer) Leave(timeout time.Duration) error

+ func (p *Peer) Name() string

+ func (p *Peer) State() map[string]interface{}

+ type PeerType string