util

Documentation

Index

• func GetRaftCmdReq() *raft_cmdpb.RaftCmdRequest
• func GetRaftCmdResp() *raft_cmdpb.RaftCmdResponse
• func GetRaftReq() *raft_cmdpb.Request
• func PutRaftCmdReq(req *raft_cmdpb.RaftCmdRequest)
• func PutRaftCmdResp(resp *raft_cmdpb.RaftCmdResponse)
• func PutRaftReq(req *raft_cmdpb.Request)
• func ReadMessage(r io.Reader, msg proto.Message) (uint64, error)
• func ReadMessageBytes(r io.Reader, msg proto.Message) (uint64, int, error)
• func WriteMessage(w io.Writer, msgID uint64, msg proto.Message) error
• func WriteMessageBytes(w io.Writer, msgID uint64, msg proto.Message) (int, error)

Functions

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)