vrpc

Jan 11, 2026

Changes in this version

+ func ClientStreamFor[S any, T any](c *Client, ctx context.Context, service, method string, req any, src io.Reader) (*T, error)

+ func ClientStream[T any](c *Client, ctx context.Context, service, method string, req any, src io.Reader) (*T, error)

+ func ServerStreamFor[S any, T any](c *Client, ctx context.Context, service, method string, req any, dst io.Writer) (*T, error)

+ func ServerStream[T any](c *Client, ctx context.Context, service, method string, req any, dst io.Writer) (*T, error)

Jan 5, 2026

Changes in this version

+ const StatusEncodingError

+ type AAA struct

type Client

+ func (c *Client) ClientStream(ctx context.Context, service, method string, request any, src io.Reader, ...) error

+ func (c *Client) ServerStream(ctx context.Context, service, method string, request any, dst io.Writer, ...) error

type Codec

+ NewDecoder func(r io.Reader) Decoder

+ NewEncoder func(w io.Writer) Encoder

+ type Decoder interface

+ Decode func(any) error

+ type Encoder interface

+ Encode func(any) error

Dec 21, 2025

Changes in this version

+ const ErrorHeader

+ const ProtoHeader

+ var ErrNoCodec = &Error

+ var ErrNotFound = &Error

+ func CallFor[S any, R any](c *Client, ctx context.Context, method string, req any) (*R, error)

+ func Call[R any](c *Client, ctx context.Context, service, method string, req any) (*R, error)

+ func RegisterCodec(codec Codec)

+ type Client struct

+ func NewClient(options ...ClientOption) (*Client, error)

+ func (c *Client) Beacon(ctx context.Context, service, method string, request any) error

+ func (c *Client) Call(ctx context.Context, service, method string, request any, response any) error

+ func (c *Client) Notify(ctx context.Context, service, method string, request any) error

+ type ClientOption func(*clientConfig)

+ func WithClient(hc *http.Client) ClientOption

+ func WithCodec(codec Codec) ClientOption

+ func WithEndpoint(endpoint string) ClientOption

+ func WithMode(mode Mode) ClientOption

+ func WithPrefix(prefix string) ClientOption

+ func WithScheme(scheme string) ClientOption

+ type Codec interface

+ ContentType func() string

+ Decode func(r io.Reader, v any) error

+ Encode func(w io.Writer, v any) error

+ type Error struct

+ func (e *Error) Error() string

+ type Handler struct

+ func DefService(service string, impl any) *Handler

+ func Def[T any](impl any) *Handler

+ func NewHandler(service string, impl any) (*Handler, error)

+ func NewHandlerFor[T any](impl any) (*Handler, error)

+ func NewHandlerOf(impl any) (*Handler, error)

+ func NewStrictHandlerFor[T any](impl any) (*Handler, error)

+ func (h *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type Mode uint8

+ const ModeDefault

+ const ServiceToHeader

+ const ServiceToURL

+ type Mux struct

+ func NewMux(handlers ...*Handler) (*Mux, error)

+ func (m *Mux) Add(handler *Handler) error

+ func (m *Mux) ServeHTTP(w http.ResponseWriter, r *http.Request)