in internal/proto/connectrequest.go [55:83]
func (r *ConnectRequest) Read(dec jute.Decoder) (err error) {
if err = dec.ReadStart(); err != nil {
return err
}
r.ProtocolVersion, err = dec.ReadInt()
if err != nil {
return err
}
r.LastZxidSeen, err = dec.ReadLong()
if err != nil {
return err
}
r.TimeOut, err = dec.ReadInt()
if err != nil {
return err
}
r.SessionId, err = dec.ReadLong()
if err != nil {
return err
}
r.Passwd, err = dec.ReadBuffer()
if err != nil {
return err
}
if err = dec.ReadEnd(); err != nil {
return err
}
return nil
}