part

Jan 3, 2024

Changes in this version

+ var ErrCliDeal = errors.New("ErrCliDeal")

+ var ErrCliDecode = errors.New("ErrCliDecode")

+ var ErrCliEncode = errors.New("ErrCliEncode")

+ var ErrDial = errors.New("ErrDial")

+ var ErrRegister = errors.New("ErrRegister")

+ var ErrSerDeal = errors.New("ErrSerDeal")

+ var ErrSerDecode = errors.New("ErrSerDecode")

+ var ErrSerEncode = errors.New("ErrSerEncode")

+ var ErrSerGob = errors.New("ErrSerGob")

+ func Call[T, E any](it *T, ot *E, host, path string) error

+ func Register[T, E any](t *Server, path string, deal func(it *T, ot *E) error) error

+ func UnRegister(t *Server, path string)

type Gob

+ Err error

+ type Server struct

+ Shutdown func(ctx ...context.Context)

+ func NewServer(host string) *Server

Nov 25, 2023

Changes in this version

+ type DealGob struct

+ func (t *DealGob) Deal(i *Gob, o *Gob) error

+ type Gob struct

+ Data []byte

+ Key string

+ func NewGob(k string) *Gob

+ func (t *Gob) Decode(e any) (err error)

+ func (t *Gob) Encode(e any) (err error)

+ type Pob struct

+ Host string

+ Path string

+ func (t *Pob) Client() (pobClient *PobClient, err error)

+ func (t *Pob) Server(deal func(i, o *Gob) error) (shutdown func(), err error)

+ type PobClient struct

+ func (t *PobClient) Call(g *Gob) (err error)

+ func (t *PobClient) CallIO(i, o *Gob) (err error)

+ func (t *PobClient) Close()

+ func (t *PobClient) Go(g *Gob, done chan *rpc.Call) *rpc.Call

+ func (t *PobClient) GoIO(i, o *Gob, done chan *rpc.Call) *rpc.Call