cluster

Mar 22, 2018

Changes in this version

+ func CalculateAdvertiseIP(bindHost, advertiseHost string, resolver Resolver, logger log.Logger) (net.IP, error)

+ type Resolver interface

+ LookupIPAddr func(ctx context.Context, address string) ([]net.IPAddr, error)

May 31, 2017

Changes in this version

+ func CalculateAdvertiseAddress(bindAddr, advertiseAddr string) (net.IP, error)

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