jsonrpc2

Feb 5, 2020

Changes in this version

type Conn

+ func (c *Conn) AddHandler(handler Handler)

+ type Direction bool

+ func (d Direction) String() string

type Handler

+ Cancel func(ctx context.Context, conn *Conn, id ID, canceled bool) bool

+ Deliver func(ctx context.Context, r *Request, delivered bool) bool

+ Done func(ctx context.Context, err error)

+ Error func(ctx context.Context, err error)

+ Read func(ctx context.Context, n int64) context.Context

+ Request func(ctx context.Context, conn *Conn, direction Direction, r *WireRequest) context.Context

+ Response func(ctx context.Context, conn *Conn, direction Direction, r *WireResponse) context.Context

+ Write func(ctx context.Context, n int64) context.Context

type Options

+ func WithHandlers(hs ...Handler) Options

+ type WireRequest struct

+ ID *ID

+ JSONRPC string

+ Method string

+ Params *json.RawMessage

+ type WireResponse struct

+ Error *Error

+ ID *ID

+ JSONRPC string

+ Result *json.RawMessage

Jun 29, 2019

Changes in this version

+ const ContentModified

+ const InternalError

+ const InvalidParams

+ const InvalidRequest

+ const MethodNotFound

+ const ParseError

+ const RequestCancelled

+ const ServerNotInitialized

+ const ServerOverloaded

+ const UnknownError

type Request

+ func (r *Request) Conn() *Conn

+ func (r *Request) Parallel()

+ func (r *Request) Reply(ctx context.Context, result interface{}, err error) error

Apr 16, 2019

Changes in this version

+ const ContentTypeJSONRPC

+ const ContentTypeVSCodeJSONRPC

+ const HeaderContentLength

+ const HeaderContentLengthFmt

+ const HeaderContentSeparator

+ const HeaderContentType

+ const HeaderContentTypeFmt

+ const Receive

+ const Send

+ const Version

type Code

+ const CodeServerOverloaded

+ type Combined struct

+ Error *Error

+ ID *ID

+ JSONRPC string

+ Method string

+ Params *json.RawMessage

+ Result *json.RawMessage

+ func (v *Combined) IsNil() bool

+ func (v *Combined) MarshalJSONObject(enc *gojay.Encoder)

+ func (v *Combined) NKeys() int

+ func (v *Combined) UnmarshalJSONObject(dec *gojay.Decoder, k string) error

type Conn

+ Canceler Canceler

+ Capacity int

+ Handler Handler

+ Logger *zap.Logger

+ RejectIfOverloaded bool

+ func (c *Conn) Run(ctx context.Context) (err error)

type Error

+ func NewError(c Code, args ...interface{}) *Error

type Interface

+ Run func(ctx context.Context) (err error)

type NotificationMessage

+ JSONRPC string

type Options

+ func WithCapacity(capacity int) Options

+ func WithLogger(logger *zap.Logger) Options

+ func WithOverloaded(rejectIfOverloaded bool) Options

+ type RawMessage gojay.EmbeddedJSON

+ func (m *RawMessage) UnmarshalJSON(data []byte) error

+ func (m RawMessage) MarshalJSON() ([]byte, error)

+ func (m RawMessage) String() string

type Request

+ JSONRPC string

type Response

+ JSONRPC string

Apr 6, 2019

Changes in this version

+ type Canceler func(context.Context, *Conn, *Request)

+ type Code int64

+ const CodeContentModified

+ const CodeInternalError

+ const CodeInvalidParams

+ const CodeInvalidRequest

+ const CodeMethodNotFound

+ const CodeParseError

+ const CodeRequestCancelled

+ const CodeServerNotInitialized

+ const CodeUnknownError

+ type Conn struct

+ func NewConn(ctx context.Context, s Stream, options ...Options) *Conn

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

+ func (c *Conn) Cancel(id ID)

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

+ func (c *Conn) Reply(ctx context.Context, req *Request, result interface{}, err error) error

+ func (c *Conn) Wait(ctx context.Context) error

+ type Error struct

+ Code Code

+ Data []byte

+ Message string

+ func Errorf(c Code, format string, args ...interface{}) *Error

+ func (e *Error) Error() string

+ func (e *Error) Format(s fmt.State, c rune)

+ func (e *Error) FormatError(p xerrors.Printer) (next error)

+ func (e *Error) Unwrap() error

+ func (v *Error) IsNil() bool

+ func (v *Error) MarshalJSONObject(enc *gojay.Encoder)

+ func (v *Error) NKeys() int

+ func (v *Error) UnmarshalJSONObject(dec *gojay.Decoder, k string) error

+ type Handler func(context.Context, *Conn, *Request)

+ type ID struct

+ Name string

+ Number int64

+ func (id *ID) IsNil() bool

+ func (id *ID) MarshalJSON() ([]byte, error)

+ func (id *ID) String() string

+ func (id *ID) UnmarshalJSON(data []byte) error

+ func (v *ID) MarshalJSONObject(enc *gojay.Encoder)

+ func (v *ID) NKeys() int

+ func (v *ID) UnmarshalJSONObject(dec *gojay.Decoder, k string) error

+ type Interface interface

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

+ Cancel func(id ID)

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

+ Reply func(ctx context.Context, req *Request, result interface{}, err error) error

+ Wait func(ctx context.Context) error

+ type Message struct

+ JSONRPC string

+ type NotificationMessage struct

+ Method string

+ Params interface{}

+ func (v *NotificationMessage) IsNil() bool

+ func (v *NotificationMessage) MarshalJSONObject(enc *gojay.Encoder)

+ func (v *NotificationMessage) NKeys() int

+ func (v *NotificationMessage) UnmarshalJSONObject(dec *gojay.Decoder, k string) error

+ type Options func(*Conn)

+ func WithCanceler(cancel Canceler) Options

+ func WithHandler(h Handler) Options

+ type Request struct

+ ID *ID

+ Method string

+ Params *gojay.EmbeddedJSON

+ func (r *Request) IsNotify() bool

+ func (v *Request) IsNil() bool

+ func (v *Request) MarshalJSONObject(enc *gojay.Encoder)

+ func (v *Request) NKeys() int

+ func (v *Request) UnmarshalJSONObject(dec *gojay.Decoder, k string) error

+ type Response struct

+ Error *Error

+ ID *ID

+ Result *gojay.EmbeddedJSON

+ func (v *Response) IsNil() bool

+ func (v *Response) MarshalJSONObject(enc *gojay.Encoder)

+ func (v *Response) NKeys() int

+ func (v *Response) UnmarshalJSONObject(dec *gojay.Decoder, k string) error

+ type Stream interface

+ Read func(context.Context) ([]byte, error)

+ Write func(context.Context, []byte) error

+ func NewStream(in io.Reader, out io.Writer) Stream