Versions in this module Expand all Collapse all v0 v0.3.2 May 10, 2018 v0.3.0 Apr 8, 2018 Changes in this version + const ConnReadTimeout + const ConnWriteTimeout + var ErrExceedSizeLimit = errors.New("rafthttp: error limit exceeded") + var ProbingPrefix = path.Join(RaftPrefix, "probing") + var RaftPrefix = "/raft" + var RaftSnapshotPrefix = path.Join(RaftPrefix, "snapshot") + var RaftStreamPrefix = path.Join(RaftPrefix, "stream") + func NewListener(u url.URL, tlscfg *transport.TLSInfo) (net.Listener, error) + func NewRoundTripper(tlsInfo transport.TLSInfo, dialTimeout time.Duration) (http.RoundTripper, error) + func SetLogLevel(level int) + type ISnapSaver interface + SaveDBFrom func(io.Reader, raftpb.Message) (int64, error) + type Pausable interface + Pause func() + Resume func() + type Peer interface + type Raft interface + IsPeerRemoved func(id uint64) bool + Process func(ctx context.Context, m raftpb.Message) error + ReportSnapshot func(id uint64, group raftpb.Group, status raft.SnapshotStatus) + ReportUnreachable func(id uint64, group raftpb.Group) + type Transport struct + ClusterID string + DialTimeout time.Duration + ErrorC chan error + ID types.ID + PeersStats *stats.PeersStats + Raft Raft + Snapshotter ISnapSaver + TLSInfo transport.TLSInfo + TrStats *stats.TransportStats + URLs types.URLs + func (t *Transport) ActiveSince(id types.ID) time.Time + func (t *Transport) AddRemote(id types.ID, us []string) + func (t *Transport) CutPeer(id types.ID) + func (t *Transport) Get(id types.ID) Peer + func (t *Transport) GetAllPeers() []types.ID + func (t *Transport) Handler() http.Handler + func (t *Transport) IsStarted() bool + func (t *Transport) MendPeer(id types.ID) + func (t *Transport) Pause() + func (t *Transport) RemoveAllPeers() + func (t *Transport) RemovePeer(id types.ID) + func (t *Transport) Resume() + func (t *Transport) Send(msgs []raftpb.Message) + func (t *Transport) SendSnapshot(m snap.Message) + func (t *Transport) Start() error + func (t *Transport) Stop() + func (t *Transport) UpdatePeer(id types.ID, us []string) + type Transporter interface + ActiveSince func(id types.ID) time.Time + AddRemote func(id types.ID, urls []string) + Handler func() http.Handler + IsStarted func() bool + RemoveAllPeers func() + RemovePeer func(id types.ID) + Send func(m []raftpb.Message) + SendSnapshot func(m snap.Message) + Start func() error + Stop func() + UpdatePeer func(id types.ID, urls []string) + func NewNopTransporter() Transporter + func NewSnapTransporter(snapDir string) (Transporter, <-chan snap.Message)