Versions in this module Expand all Collapse all v0 v0.1.0 Dec 23, 2020 Changes in this version + const DMAPPEND + const DMAUTH + const DMDIR + const DMEXCL + const DMEXEC + const DMMOUNT + const DMREAD + const DMTMP + const DMWRITE + const DefaultAddr + const EACCES + const EEXIST + const EINVAL + const EIO + const ENOENT + const ENOTDIR + const EPERM + const IOHDRSZ + const MSIZE + const NOFID + const NOTAG + const NumFID + const NumTags + const OAPPEND + const OCEXEC + const OEXCL + const OEXEC + const ORCLOSE + const ORDWR + const OREAD + const OTRUNC + const OWRITE + const PORT + const QIDLen + const QTAPPEND + const QTAUTH + const QTDIR + const QTEXCL + const QTFILE + const QTLINK + const QTMOUNT + const QTSYMLINK + const QTTMP + var Debug = func(string, ...interface{}) + var RPCNames = map[MType]string + func Dispatch(s *Server, b *bytes.Buffer, t MType) error + func MarshalRattachPkt(b *bytes.Buffer, t Tag, QID QID) + func MarshalRclunkPkt(b *bytes.Buffer, t Tag) + func MarshalRcreatePkt(b *bytes.Buffer, t Tag, OQID QID, IOUnit MaxSize) + func MarshalRerrorPkt(b *bytes.Buffer, t Tag, Error string) + func MarshalRflushPkt(b *bytes.Buffer, t Tag) + func MarshalRopenPkt(b *bytes.Buffer, t Tag, OQID QID, IOUnit MaxSize) + func MarshalRreadPkt(b *bytes.Buffer, t Tag, Data []uint8) + func MarshalRremovePkt(b *bytes.Buffer, t Tag) + func MarshalRstatPkt(b *bytes.Buffer, t Tag, B []byte) + func MarshalRversionPkt(b *bytes.Buffer, t Tag, RMsize MaxSize, RVersion string) + func MarshalRwalkPkt(b *bytes.Buffer, t Tag, QIDs []QID) + func MarshalRwritePkt(b *bytes.Buffer, t Tag, RLen Count) + func MarshalRwstatPkt(b *bytes.Buffer, t Tag) + func MarshalTattachPkt(b *bytes.Buffer, t Tag, SFID FID, AFID FID, Uname string, Aname string) + func MarshalTclunkPkt(b *bytes.Buffer, t Tag, OFID FID) + func MarshalTcreatePkt(b *bytes.Buffer, t Tag, OFID FID, Name string, CreatePerm Perm, Omode Mode) + func MarshalTflushPkt(b *bytes.Buffer, t Tag, OTag Tag) + func MarshalTopenPkt(b *bytes.Buffer, t Tag, OFID FID, Omode Mode) + func MarshalTreadPkt(b *bytes.Buffer, t Tag, OFID FID, Off Offset, Len Count) + func MarshalTremovePkt(b *bytes.Buffer, t Tag, OFID FID) + func MarshalTstatPkt(b *bytes.Buffer, t Tag, OFID FID) + func MarshalTversionPkt(b *bytes.Buffer, t Tag, TMsize MaxSize, TVersion string) + func MarshalTwalkPkt(b *bytes.Buffer, t Tag, SFID FID, NewFID FID, Paths []string) + func MarshalTwritePkt(b *bytes.Buffer, t Tag, OFID FID, Off Offset, Data []uint8) + func MarshalTwstatPkt(b *bytes.Buffer, t Tag, OFID FID, B []byte) + func Marshaldir(b *bytes.Buffer, D Dir) + func ServeFromRWC(rwc io.ReadWriteCloser, fs NineServer, n string) + func ServerError(b *bytes.Buffer, s string) + func UnmarshalRattachPkt(b *bytes.Buffer) (QID QID, t Tag, err error) + func UnmarshalRcreatePkt(b *bytes.Buffer) (OQID QID, IOUnit MaxSize, t Tag, err error) + func UnmarshalRopenPkt(b *bytes.Buffer) (OQID QID, IOUnit MaxSize, t Tag, err error) + func UnmarshalRversionPkt(b *bytes.Buffer) (RMsize MaxSize, RVersion string, t Tag, err error) + func UnmarshalRwalkPkt(b *bytes.Buffer) (QIDs []QID, t Tag, err error) + func UnmarshalRwritePkt(b *bytes.Buffer) (RLen Count, t Tag, err error) + func UnmarshalTattachPkt(b *bytes.Buffer) (SFID FID, AFID FID, Uname string, Aname string, t Tag, err error) + func UnmarshalTclunkPkt(b *bytes.Buffer) (OFID FID, t Tag, err error) + func UnmarshalTcreatePkt(b *bytes.Buffer) (OFID FID, Name string, CreatePerm Perm, Omode Mode, t Tag, err error) + func UnmarshalTflushPkt(b *bytes.Buffer) (OTag Tag, t Tag, err error) + func UnmarshalTopenPkt(b *bytes.Buffer) (OFID FID, Omode Mode, t Tag, err error) + func UnmarshalTreadPkt(b *bytes.Buffer) (OFID FID, Off Offset, Len Count, t Tag, err error) + func UnmarshalTremovePkt(b *bytes.Buffer) (OFID FID, t Tag, err error) + func UnmarshalTstatPkt(b *bytes.Buffer) (OFID FID, t Tag, err error) + func UnmarshalTversionPkt(b *bytes.Buffer) (TMsize MaxSize, TVersion string, t Tag, err error) + func UnmarshalTwalkPkt(b *bytes.Buffer) (SFID FID, NewFID FID, Paths []string, t Tag, err error) + func UnmarshalTwritePkt(b *bytes.Buffer) (OFID FID, Off Offset, Data []uint8, t Tag, err error) + func UnmarshalTwstatPkt(b *bytes.Buffer) (OFID FID, B []byte, t Tag, err error) + type Client struct + Dead bool + FID uint64 + FromClient chan *RPCCall + FromNet io.ReadCloser + FromServer chan *RPCReply + Msize uint32 + RPC []*RPCCall + Tags chan Tag + ToNet io.WriteCloser + Trace Tracer + func NewClient(opts ...ClientOpt) (*Client, error) + func (c *Client) CallTattach(SFID FID, AFID FID, Uname string, Aname string) (QID QID, err error) + func (c *Client) CallTclunk(OFID FID) (err error) + func (c *Client) CallTcreate(OFID FID, Name string, CreatePerm Perm, Omode Mode) (OQID QID, IOUnit MaxSize, err error) + func (c *Client) CallTflush(OTag Tag) (err error) + func (c *Client) CallTopen(OFID FID, Omode Mode) (OQID QID, IOUnit MaxSize, err error) + func (c *Client) CallTread(OFID FID, Off Offset, Len Count) (Data []uint8, err error) + func (c *Client) CallTremove(OFID FID) (err error) + func (c *Client) CallTstat(OFID FID) (B []byte, err error) + func (c *Client) CallTversion(TMsize MaxSize, TVersion string) (RMsize MaxSize, RVersion string, err error) + func (c *Client) CallTwalk(SFID FID, NewFID FID, Paths []string) (QIDs []QID, err error) + func (c *Client) CallTwrite(OFID FID, Off Offset, Data []uint8) (RLen Count, err error) + func (c *Client) CallTwstat(OFID FID, B []byte) (err error) + func (c *Client) GetFID() FID + func (c *Client) GetTag() Tag + func (c *Client) IO() + func (c *Client) String() string + type ClientOpt func(*Client) error + type Count int32 + type Data []byte + type DataCnt16 byte + type Dir struct + Atime uint32 + Dev uint32 + Group string + Length uint64 + ModUser string + Mode uint32 + Mtime uint32 + Name string + QID QID + Type uint16 + User string + func Unmarshaldir(b *bytes.Buffer) (D Dir, err error) + type DirPkt struct + D Dir + type Dispatcher func(s *Server, b *bytes.Buffer, t MType) error + type Error struct + Err string + type FID uint32 + type File struct + type FileServer struct + Versioned bool + type MType uint8 + const Rattach + const Rauth + const Rclunk + const Rcreate + const Rerror + const Rflush + const Ropen + const Rread + const Rremove + const Rstat + const Rversion + const Rwalk + const Rwrite + const Rwstat + const Tattach + const Tauth + const Tclunk + const Tcreate + const Terror + const Tflush + const Tlast + const Topen + const Tread + const Tremove + const Tstat + const Tversion + const Twalk + const Twrite + const Twstat + type MaxSize uint32 + type Mode uint8 + type NetListener struct + Addr string + Trace Tracer + func NewNetListener(nsCreator NsCreator, opts ...NetListenerOpt) (*NetListener, error) + func (l *NetListener) Accept(conn net.Conn) error + func (l *NetListener) Serve(ln net.Listener) error + func (l *NetListener) Shutdown() error + func (l *NetListener) String() string + type NetListenerOpt func(*NetListener) error + type NineServer interface + Rattach func(FID, FID, string, string) (QID, error) + Rclunk func(FID) error + Rcreate func(FID, string, Perm, Mode) (QID, MaxSize, error) + Rflush func(Otag Tag) error + Ropen func(FID, Mode) (QID, MaxSize, error) + Rread func(FID, Offset, Count) ([]byte, error) + Rremove func(FID) error + Rstat func(FID) ([]byte, error) + Rversion func(MaxSize, string) (MaxSize, string, error) + Rwalk func(FID, FID, []string) ([]QID, error) + Rwrite func(FID, Offset, []byte) (Count, error) + Rwstat func(FID, []byte) error + type NsCreator func() NineServer + type NumEntries uint16 + type Offset uint64 + type Perm uint32 + type QID struct + Path uint64 + Type uint8 + Version uint32 + type RPCCall struct + Reply chan []byte + type RPCReply struct + type RattachPkt struct + QID QID + type RclunkPkt struct + type RcreatePkt struct + IOUnit MaxSize + OQID QID + type RerrorPkt struct + Error string + type RflushPkt struct + type RopenPkt struct + IOUnit MaxSize + OQID QID + type RreadPkt struct + Data []byte + type RremovePkt struct + type RstatPkt struct + B []DataCnt16 + type RversionPkt struct + RMsize MaxSize + RVersion string + type RwalkPkt struct + QIDs []QID + type RwritePkt struct + RLen Count + type RwstatPkt struct + type Server struct + D Dispatcher + NS NineServer + Versioned bool + func (s *Server) SrvRattach(b *bytes.Buffer) (err error) + func (s *Server) SrvRclunk(b *bytes.Buffer) (err error) + func (s *Server) SrvRcreate(b *bytes.Buffer) (err error) + func (s *Server) SrvRflush(b *bytes.Buffer) (err error) + func (s *Server) SrvRopen(b *bytes.Buffer) (err error) + func (s *Server) SrvRread(b *bytes.Buffer) (err error) + func (s *Server) SrvRremove(b *bytes.Buffer) (err error) + func (s *Server) SrvRstat(b *bytes.Buffer) (err error) + func (s *Server) SrvRversion(b *bytes.Buffer) (err error) + func (s *Server) SrvRwalk(b *bytes.Buffer) (err error) + func (s *Server) SrvRwrite(b *bytes.Buffer) (err error) + func (s *Server) SrvRwstat(b *bytes.Buffer) (err error) + type Service func(func() error, chan FID) + type Tag uint16 + func UnmarshalRclunkPkt(b *bytes.Buffer) (t Tag, err error) + func UnmarshalRerrorPkt(b *bytes.Buffer) (Error string, t Tag, err error) + func UnmarshalRflushPkt(b *bytes.Buffer) (t Tag, err error) + func UnmarshalRreadPkt(b *bytes.Buffer) (Data []uint8, t Tag, err error) + func UnmarshalRremovePkt(b *bytes.Buffer) (t Tag, err error) + func UnmarshalRstatPkt(b *bytes.Buffer) (B []byte, t Tag, err error) + func UnmarshalRwstatPkt(b *bytes.Buffer) (t Tag, err error) + type TattachPkt struct + AFID FID + Aname string + SFID FID + Uname string + type TclunkPkt struct + OFID FID + type TcreatePkt struct + CreatePerm Perm + Name string + OFID FID + Omode Mode + type TflushPkt struct + OTag Tag + type TopenPkt struct + OFID FID + Omode Mode + type Tracer func(string, ...interface{}) + type TreadPkt struct + Len Count + OFID FID + Off Offset + type TremovePkt struct + OFID FID + type TstatPkt struct + OFID FID + type TversionPkt struct + TMsize MaxSize + TVersion string + type TwalkPkt struct + NewFID FID + Paths []string + SFID FID + type TwritePkt struct + Data []byte + OFID FID + Off Offset + type TwstatPkt struct + B []DataCnt16 + OFID FID