fdrpc

Documentation

Index

• func Dial(path string) (*rpcplus.Client, error)
• func ListenAndServe(path string) error
• func NewClient(conn *net.UnixConn) *rpcplus.Client
• func ServeConn(conn *net.UnixConn)
• type FD
• type FDReader
  • func NewFDReader(conn *net.UnixConn) *FDReader
  • func (r *FDReader) Close() error
  • func (r *FDReader) GetFD(index int) (int, error)
  • func (r *FDReader) Read(b []byte) (int, error)
  • func (r *FDReader) Write(b []byte) (int, error)
• type FDWriter
  • func NewFDWriter(conn *net.UnixConn) *FDWriter
  • func (w *FDWriter) AddFD(fd int) int
  • func (w *FDWriter) Close() error
  • func (w *FDWriter) Read(b []byte) (int, error)
  • func (w *FDWriter) Write(b []byte) (int, error)

Functions

func Dial

func Dial(path string) (*rpcplus.Client, error)

func ListenAndServe

func ListenAndServe(path string) error

func NewClient

func NewClient(conn *net.UnixConn) *rpcplus.Client

func ServeConn

func ServeConn(conn *net.UnixConn)

Types

type FD

type FD struct {
	FD int
}

type FDReader

type FDReader struct {
	FDs map[int]int
	// contains filtered or unexported fields
}

func NewFDReader

func NewFDReader(conn *net.UnixConn) *FDReader

func (*FDReader) Close

func (r *FDReader) Close() error

func (*FDReader) GetFD

func (r *FDReader) GetFD(index int) (int, error)

func (*FDReader) Read

func (r *FDReader) Read(b []byte) (int, error)

func (*FDReader) Write

func (r *FDReader) Write(b []byte) (int, error)

type FDWriter

type FDWriter struct {
	// contains filtered or unexported fields
}

func NewFDWriter

func NewFDWriter(conn *net.UnixConn) *FDWriter

func (*FDWriter) AddFD

func (w *FDWriter) AddFD(fd int) int

func (*FDWriter) Close

func (w *FDWriter) Close() error

func (*FDWriter) Read

func (w *FDWriter) Read(b []byte) (int, error)

func (*FDWriter) Write

func (w *FDWriter) Write(b []byte) (int, error)