chirp

Oct 29, 2025

Changes in this version

type Peer

+ func (p *Peer) RemoteAddr() net.Addr

Aug 20, 2025

Changes in this version

+ const MaxMethodLen

+ var ErrUnknownMethod errUnknownMethod

+ func SplitAddress(s string) (network, address string)

+ type CallError struct

+ Err error

+ Response *Response

+ func (c *CallError) Error() string

+ func (c *CallError) Unwrap() error

+ type Cancel struct

+ RequestID uint32

+ func (c *Cancel) Decode(data []byte) error

+ func (c Cancel) Encode() []byte

+ func (c Cancel) String() string

+ type Channel interface

+ Close func() error

+ Recv func() (*Packet, error)

+ Send func(*Packet) error

+ type ErrorData struct

+ Code uint16

+ Data []byte

+ Message string

+ func (e *ErrorData) Decode(data []byte) error

+ func (e ErrorData) Encode() []byte

+ func (e ErrorData) Error() string

+ type Handler func(context.Context, *Request) ([]byte, error)

+ type Packet struct

+ Payload []byte

+ Protocol byte

+ Type PacketType

+ func (p *Packet) ReadFrom(r io.Reader) (int64, error)

+ func (p *Packet) String() string

+ func (p Packet) WriteTo(w io.Writer) (int64, error)

+ type PacketDir string

+ const Recv

+ const Send

+ type PacketHandler func(context.Context, *Packet) error

+ type PacketLogger func(pkt *Packet, dir PacketDir)

+ type PacketType uint16

+ const PacketCancel

+ const PacketRequest

+ const PacketResponse

+ func (p PacketType) String() string

+ type Peer struct

+ func ContextPeer(ctx context.Context) *Peer

+ func NewPeer() *Peer

+ func (p *Peer) Call(ctx context.Context, method string, data []byte) (_ *Response, err error)

+ func (p *Peer) Clone() *Peer

+ func (p *Peer) Detach() *Peer

+ func (p *Peer) Exec(ctx context.Context, method string, data []byte) ([]byte, error)

+ func (p *Peer) Handle(method string, handler Handler) *Peer

+ func (p *Peer) HandlePacket(ptype PacketType, handler PacketHandler) *Peer

+ func (p *Peer) LogPackets(log PacketLogger) *Peer

+ func (p *Peer) Metrics() *expvar.Map

+ func (p *Peer) NewContext(base func() context.Context) *Peer

+ func (p *Peer) SendPacket(ptype PacketType, payload []byte) error

+ func (p *Peer) Start(ch Channel) *Peer

+ func (p *Peer) Stop() error

+ func (p *Peer) Wait() error

+ type Request struct

+ Data []byte

+ Method string

+ RequestID uint32

+ func (r *Request) Decode(data []byte) error

+ func (r Request) Encode() []byte

+ func (r Request) String() string

+ type Response struct

+ Code ResultCode

+ Data []byte

+ RequestID uint32

+ func (r *Response) Decode(data []byte) error

+ func (r Response) Encode() []byte

+ func (r Response) String() string

+ type ResultCode byte

+ const CodeCanceled

+ const CodeDuplicateID

+ const CodeServiceError

+ const CodeSuccess

+ const CodeUnknownMethod

+ func (c ResultCode) String() string