| 12345678910111213141516171819202122 |
- package rpc
-
- import "bytes"
-
- type HandshakeRequest struct {
- }
-
- func (r *HandshakeRequest) Bytes() []byte {
- buf := &bytes.Buffer{}
- buf.Grow(len(TagHandshake) + len(HandshakeFlags) + len(HandshakeSenderPID) + len(HandshakePeerPID))
-
- buf.Write(TagHandshake)
- buf.Write(HandshakeFlags)
- buf.Write(HandshakeSenderPID)
- buf.Write(HandshakePeerPID)
-
- return buf.Bytes()
- }
-
- func NewHandshakeRequest() *HandshakeRequest {
- return &HandshakeRequest{}
- }
|