Versions in this module Expand all Collapse all v0 v0.1.0 Sep 22, 2016 Changes in this version + func Do(addr string, buf []byte, args ...[]byte) (resp []byte, nbuf []byte, err error) + func ReadRawResponse(rd *bufio.Reader) (raw []byte, kind byte, err error) + type RedconTransport struct + func NewRedconTransport(bindAddr string, handle func(conn redcon.Conn, cmd redcon.Command), ...) (*RedconTransport, error) + func (t *RedconTransport) AppendEntries(target string, args *raft.AppendEntriesRequest, ...) error + func (t *RedconTransport) AppendEntriesPipeline(target string) (raft.AppendPipeline, error) + func (t *RedconTransport) Close() error + func (t *RedconTransport) Consumer() <-chan raft.RPC + func (t *RedconTransport) DecodePeer(peer []byte) string + func (t *RedconTransport) EncodePeer(peer string) []byte + func (t *RedconTransport) InstallSnapshot(target string, args *raft.InstallSnapshotRequest, ...) error + func (t *RedconTransport) LocalAddr() string + func (t *RedconTransport) RequestVote(target string, args *raft.RequestVoteRequest, resp *raft.RequestVoteResponse) error + func (t *RedconTransport) SetHeartbeatHandler(cb func(rpc raft.RPC))