util

func GetRaftCmdReq ¶

func GetRaftCmdReq() *raft_cmdpb.RaftCmdRequest

func GetRaftCmdResp ¶

func GetRaftCmdResp() *raft_cmdpb.RaftCmdResponse

func GetRaftReq ¶

func GetRaftReq() *raft_cmdpb.Request

func PutRaftCmdReq ¶

func PutRaftCmdReq(req *raft_cmdpb.RaftCmdRequest)

func PutRaftCmdResp ¶

func PutRaftCmdResp(resp *raft_cmdpb.RaftCmdResponse)

func PutRaftReq ¶

func PutRaftReq(req *raft_cmdpb.Request)

func ReadMessage ¶

func ReadMessage(r io.Reader, msg proto.Message) (uint64, error)

ReadMessage reads a protocol buffer message from reader.

func ReadMessageBytes ¶

func ReadMessageBytes(r io.Reader, msg proto.Message) (uint64, int, error)

func WriteMessage ¶

func WriteMessage(w io.Writer, msgID uint64, msg proto.Message) error

WriteMessage writes a protocol buffer message to writer.

func WriteMessageBytes ¶

func WriteMessageBytes(w io.Writer, msgID uint64, msg proto.Message) (int, error)