lively

Documentation

Index

• type Liveliness
• type LivelyRequest
• type Peer
  • func (p *Peer) AddPeer(other *Peer) error
  • func (e *Peer) Consesus() error
  • func (p *Peer) Liveliness(llv *LivelyRequest) (livePeers, nonLivePeers []*Liveliness, err error)
  • func (p *Peer) SetHTTPRoundTripper(rt http.RoundTripper)
• type Ping

Types

type Liveliness

type Liveliness struct {
	PeerID string `json:"peer_id"`
	Ping   *Ping  `json:"ping"`
	Err    error  `json:"error"`
	Addr   string `json:"addr,omitepty"`
}

type LivelyRequest

type LivelyRequest struct {
	ConcurrentPings int
}

type Peer

type Peer struct {
	Addr string `json:"addr"`
	ID   string `json:"id"`

	Primary bool `json:"primary"`

	Peers map[string]*Peer `json:"peers"`
	// contains filtered or unexported fields
}

func (*Peer) AddPeer

func (p *Peer) AddPeer(other *Peer) error

func (*Peer) Consesus

func (e *Peer) Consesus() error

func (*Peer) Liveliness

func (p *Peer) Liveliness(llv *LivelyRequest) (livePeers, nonLivePeers []*Liveliness, err error)

func (*Peer) SetHTTPRoundTripper

func (p *Peer) SetHTTPRoundTripper(rt http.RoundTripper)

type Ping

type Ping struct {
	PeerID string `json:"id"`
	Clock  int64  `json:"clock"`
}