conn

Jan 17, 2018

Changes in this version

type Node

+ func (n *Node) SaveSnapshot(s raftpb.Snapshot)

Dec 1, 2017

Changes in this version

type Node

+ func (n *Node) DoneConfChange(id uint64, err error)

+ func (n *Node) PeerMap() map[uint64]string

+ func (n *Node) SetPeerMap(m map[uint64]string)

type Pool

+ func (p *Pool) UpdateHealthStatus()

Nov 20, 2017

Changes in this version

type Node

+ func (n *Node) DeletePeer(pid uint64)

+ func (n *Node) ProposePeerRemoval(ctx context.Context, id uint64) error

type Pools

+ func (p *Pools) Remove(addr string)

Nov 14, 2017

Changes in this version

type Node

+ func (n *Node) WaitForMinProposal(ctx context.Context, read *protos.LinRead) error

Oct 9, 2017

Changes in this version

+ var ErrDuplicateRaftId = x.Errorf("Node is already part of group")

+ var ErrUnhealthyConnection = fmt.Errorf("Unhealthy connection")

+ type Node struct

+ Applied x.WaterMark

+ Cfg *raft.Config

+ Id uint64

+ MyAddr string

+ RaftContext *protos.RaftContext

+ RequestCh chan linReadReq

+ Store *raft.MemoryStorage

+ Wal *raftwal.Wal

+ func NewNode(rc *protos.RaftContext) *Node

+ func (n *Node) AddToCluster(ctx context.Context, pid uint64) error

+ func (n *Node) BatchAndSendMessages()

+ func (n *Node) ConfState() *raftpb.ConfState

+ func (n *Node) Connect(pid uint64, addr string)

+ func (n *Node) InitFromWal(wal *raftwal.Wal) (idx uint64, restart bool, rerr error)

+ func (n *Node) Peer(pid uint64) (string, bool)

+ func (n *Node) Raft() raft.Node

+ func (n *Node) ReadIndex(ctx context.Context) (chan uint64, error)

+ func (n *Node) RunReadIndexLoop(closer *y.Closer, readStateCh <-chan raft.ReadState)

+ func (n *Node) SaveToStorage(s raftpb.Snapshot, h raftpb.HardState, es []raftpb.Entry)

+ func (n *Node) Send(m raftpb.Message)

+ func (n *Node) SetConfState(cs *raftpb.ConfState)

+ func (n *Node) SetPeer(pid uint64, addr string)

+ func (n *Node) SetRaft(r raft.Node)

+ func (n *Node) WaitLinearizableRead(ctx context.Context) error

type Pool

+ func (p *Pool) IsHealthy() bool

+ func (p *Pool) MonitorHealth()

+ type RaftServer struct

+ Node *Node

+ func (w *RaftServer) Echo(ctx context.Context, in *protos.Payload) (*protos.Payload, error)

+ func (w *RaftServer) GetNode() *Node

+ func (w *RaftServer) JoinCluster(ctx context.Context, rc *protos.RaftContext) (*protos.Payload, error)

+ func (w *RaftServer) RaftMessage(ctx context.Context, query *protos.Payload) (*protos.Payload, error)

Sep 20, 2017

Changes in this version

+ var ErrNoConnection = fmt.Errorf("No connection exists")

+ func TestConnection(p *Pool) error

+ type Pool struct

+ Addr string

+ func NewPool(addr string) (*Pool, error)

+ func (p *Pool) AddOwner()

+ func (p *Pool) Get() *grpc.ClientConn

+ type Pools struct

+ func Get() *Pools

+ func (p *Pools) Any() (*Pool, error)

+ func (p *Pools) Connect(addr string) *Pool

+ func (p *Pools) Get(addr string) (*Pool, error)

+ func (p *Pools) Release(pl *Pool)