jrpc2

Apr 21, 2019

Changes in this version

+ var ErrConnClosed = errors.New("the connection is closed")

+ var ErrInvalidVersion = Errorf(code.InvalidRequest, "incorrect version marker")

type Request

+ func ParseRequests(msg []byte) ([]*Request, error)

type Response

+ func (r *Response) MarshalJSON() ([]byte, error)

+ func (r *Response) SetID(id string)

type ServerInfo

+ func RPCServerInfo(ctx context.Context, cli *Client) (result *ServerInfo, err error)

type ServerOptions

+ CheckRequest func(ctx context.Context, req *Request) error

Jul 8, 2018

Changes in this version

type ClientOptions

+ DisableCancel bool

type ServerInfo

+ Label map[string]string

Jul 3, 2018

Changes in this version

type ServerInfo

+ StartTime time.Time

type ServerOptions

+ StartTime time.Time

Jun 18, 2018

Changes in this version

+ type Handler interface

+ Handle func(context.Context, *Request) (interface{}, error)

+ func NewHandler(fn interface{}) Handler

Jun 17, 2018

Changes in this version

+ func ServerPush(ctx context.Context, method string, params interface{}) error

type Client

+ func (c *Client) CallResult(ctx context.Context, method string, params, result interface{}) error

type Server

+ func (s *Server) Push(ctx context.Context, method string, params interface{}) error

type ServerOptions

+ AllowPush bool

Jun 12, 2018

Changes in this version

type Spec

+ Notify bool

Jun 10, 2018

Changes in this version

type Request

+ func (r *Request) HasParams() bool

type ServerOptions

+ DisableBuiltin bool

Jun 10, 2018

Changes in this version

type ServerInfo

+ UsesContext bool

Jun 9, 2018

Changes in this version

+ var ErrNotifyUnsupported = errors.New("server notifications are not enabled")

Jun 5, 2018

Changes in this version

+ func ServerNotify(ctx context.Context) func(context.Context, string, interface{}) error

type ClientOptions

+ OnNotify func(*Request)

type Server

+ func (s *Server) Notify(ctx context.Context, method string, params interface{}) error

type ServerOptions

+ AllowNotify bool

Jun 3, 2018

Changes in this version

+ const Version

+ var ErrNoData = errors.New("no data to unmarshal")

+ func DataErrorf(code Code, v interface{}, msg string, args ...interface{}) error

+ func Errorf(code Code, msg string, args ...interface{}) error

+ type Assigner interface

+ Assign func(method string) Method

+ Names func() []string

+ type Batch []*Pending

+ func (b Batch) Wait() []*Response

+ type Client struct

+ func NewClient(ch channel.Channel, opts *ClientOptions) *Client

+ func (c *Client) Batch(ctx context.Context, specs []Spec) (Batch, error)

+ func (c *Client) Call(ctx context.Context, method string, params interface{}) (*Pending, error)

+ func (c *Client) CallWait(ctx context.Context, method string, params interface{}) (*Response, error)

+ func (c *Client) Close() error

+ func (c *Client) Notify(ctx context.Context, method string, params interface{}) error

+ type ClientOptions struct

+ AllowV1 bool

+ EncodeContext func(context.Context, json.RawMessage) (json.RawMessage, error)

+ Logger *log.Logger

+ type Code int32

+ const E_Cancelled

+ const E_DeadlineExceeded

+ const E_InternalError

+ const E_InvalidParams

+ const E_InvalidRequest

+ const E_MethodNotFound

+ const E_NoError

+ const E_ParseError

+ const E_SystemError

+ func ErrorCode(err error) Code

+ func RegisterCode(value int32, message string) Code

+ func (c Code) Error() string

+ func (c Code) ToError() *Error

+ type Error struct

+ Code Code

+ Message string

+ func (e Error) Error() string

+ func (e Error) HasData() bool

+ func (e Error) UnmarshalData(v interface{}) error

+ type MapAssigner map[string]Method

+ func NewService(obj interface{}) MapAssigner

+ func (m MapAssigner) Assign(method string) Method

+ func (m MapAssigner) Names() []string

+ type Method interface

+ Call func(context.Context, *Request) (interface{}, error)

+ func NewMethod(fn interface{}) Method

+ type Metrics struct

+ func NewMetrics() *Metrics

+ func ServerMetrics(ctx context.Context) *Metrics

+ func (m *Metrics) Count(name string, n int64)

+ func (m *Metrics) CountAndSetMax(name string, n int64)

+ func (m *Metrics) SetMaxValue(name string, n int64)

+ func (m *Metrics) Snapshot(counters, maxValues map[string]int64)

+ type Pending struct

+ func (p *Pending) ID() string

+ func (p *Pending) Wait() *Response

+ type Request struct

+ func InboundRequest(ctx context.Context) *Request

+ func (r *Request) ID() string

+ func (r *Request) IsNotification() bool

+ func (r *Request) Method() string

+ func (r *Request) UnmarshalParams(v interface{}) error

+ type Response struct

+ func (r *Response) Error() *Error

+ func (r *Response) ID() string

+ func (r *Response) UnmarshalResult(v interface{}) error

+ type Server struct

+ func NewServer(mux Assigner, opts *ServerOptions) *Server

+ func (s *Server) ServerInfo() *ServerInfo

+ func (s *Server) Start(c channel.Channel) *Server

+ func (s *Server) Stop()

+ func (s *Server) Wait() error

+ type ServerInfo struct

+ Counter map[string]int64

+ MaxValue map[string]int64

+ Methods []string

+ type ServerOptions struct

+ AllowV1 bool

+ Concurrency int

+ DecodeContext func(context.Context, json.RawMessage) (context.Context, json.RawMessage, error)

+ Logger *log.Logger

+ Metrics *Metrics

+ type ServiceMapper map[string]Assigner

+ func (m ServiceMapper) Assign(method string) Method

+ func (m ServiceMapper) Names() []string

+ type Spec struct

+ Method string

+ Params interface{}