part

Documentation

Index

• type DealGob
  • func (t *DealGob) Deal(i *Gob, o *Gob) error
• type Gob
  • func NewGob(k string) *Gob
  • func (t *Gob) Decode(e any) (err error)
  • func (t *Gob) Encode(e any) (err error)
• type Pob
  • func (t *Pob) Client() (pobClient *PobClient, err error)
  • func (t *Pob) Server(deal func(i, o *Gob) error) (shutdown func(ctx ...context.Context), err error)
• type PobClient
  • 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

Types

type DealGob

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

func (*DealGob) Deal

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

type Gob

type Gob struct {
	Key  string
	Data []byte
}

func NewGob

func NewGob(k string) *Gob

func (*Gob) Decode

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

func (*Gob) Encode

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

type Pob

type Pob struct {
	Host string `json:"host"`
	Path string `json:"path"`
	// contains filtered or unexported fields
}

func (*Pob) Client

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

func (*Pob) Server

func (t *Pob) Server(deal func(i, o *Gob) error) (shutdown func(ctx ...context.Context), err error)

type PobClient

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

func (*PobClient) Call

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

func (*PobClient) CallIO

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

func (*PobClient) Close

func (t *PobClient) Close()

func (*PobClient) Go

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

func (*PobClient) GoIO

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