arpc

Feb 18, 2025

Changes in this version

type Session

+ func (s *Session) CallJSON(ctx context.Context, method string, payload interface{}, v interface{}) error

Feb 18, 2025

Changes in this version

+ type HandlerFunc func(req Request) (Response, error)

+ type ReconnectConfig struct

+ AutoReconnect bool

+ DialFunc func() (net.Conn, error)

+ InitialBackoff time.Duration

+ MaxBackoff time.Duration

+ ReconnectCtx context.Context

+ UpgradeFunc func(net.Conn) (*Session, error)

+ type Request struct

+ Headers http.Header

+ Method string

+ Payload json.RawMessage

+ type Response struct

+ Data interface{}

+ Message string

+ Status int

+ type Router struct

+ func NewRouter() *Router

+ func (r *Router) Handle(method string, handler HandlerFunc)

+ func (r *Router) ServeStream(stream *smux.Stream)

+ type Session struct

+ func DialWithBackoff(ctx context.Context, dialFunc func() (net.Conn, error), ...) (*Session, error)

+ func HijackUpgradeHTTP(w http.ResponseWriter, r *http.Request, config *smux.Config) (*Session, error)

+ func NewClientSession(conn net.Conn, config *smux.Config) (*Session, error)

+ func NewServerSession(conn net.Conn, config *smux.Config) (*Session, error)

+ func UpgradeHTTPClient(conn net.Conn, requestPath, host string, headers http.Header, ...) (*Session, error)

+ func (s *Session) Call(method string, payload interface{}) (*Response, error)

+ func (s *Session) CallContext(ctx context.Context, method string, payload interface{}) (*Response, error)

+ func (s *Session) CallWithHeaders(ctx context.Context, method string, payload interface{}, headers http.Header) (*Response, error)

+ func (s *Session) Close() error

+ func (s *Session) EnableAutoReconnect(rc *ReconnectConfig)

+ func (s *Session) Serve(router *Router) error