j2rpc

Documentation

Index

• Constants
• Variables
• func IndirectValue(val reflect.Value) reflect.Value
• func JSONDecode(data []byte, v interface{}) error
• func JSONEncode(v interface{}) ([]byte, error)
• func ZeroValue(typ reflect.Type) reflect.Value
• type CallerBody
• type Context
  • func NewContext(ctx context.Context, writer http.ResponseWriter, req *http.Request) Context
• type Decoder
  • func NewDecoder(r io.Reader) *Decoder
• type Delim
• type Encoder
  • func NewEncoder(w io.Writer) *Encoder
• type Error
  • func NewError(code ErrorCode, Msg string, data ...interface{}) *Error
  • func (e *Error) Error() string
  • func (e *Error) ErrorCode() int
  • func (e *Error) ErrorData() interface{}
• type ErrorCode
• type Group
  • func NewGroup(path string) Group
• type Handler
  • func Recover() Handler
• type ImplRPCMethodProvider
• type ImplRPCTypeName
• type ItfJ2rpcError
• type Option
  • func WithCallerAfterReadBody(fn CallerBody) Option
  • func WithCallerBeforeWrite(fn CallerBody) Option
• type RPCMessage
• type RawMessage
• type Server
  • func NewServer(opt ...Option) Server
• type ServerOption

Constants

const (
	BodyContextKey      = "___j2rpc.body"
	TimeBeginContextKey = "___j2rpc.timeBegin"
)

const Separator = "."

Variables

var MethodNameProvider = func(name string) string {

	return strings.ToLower(name[:1]) + name[1:]
}

Functions

func IndirectValue

func IndirectValue(val reflect.Value) reflect.Value

func JSONDecode

func JSONDecode(data []byte, v interface{}) error

func JSONEncode

func JSONEncode(v interface{}) ([]byte, error)

func ZeroValue

func ZeroValue(typ reflect.Type) reflect.Value

Types

type CallerBody

type CallerBody func([]byte) ([]byte, error)

type Context

type Context interface {
	context.Context
	Abort()
	AddHandler(handlers ...Handler)
	GetContext() context.Context
	GetValue(key string) (interface{}, bool)
	IsAbort() bool
	Msg() *RPCMessage
	Next()
	Request() *http.Request
	Server() Server
	SetValue(key string, val interface{})
	Writer() http.ResponseWriter
	StopWriteStringStatus(status int, str string)
	WriteResponse(args ...interface{})
	Wrote() bool
}

func NewContext

func NewContext(ctx context.Context, writer http.ResponseWriter, req *http.Request) Context

type Decoder

type Decoder = json.Decoder

func NewDecoder

func NewDecoder(r io.Reader) *Decoder

type Delim

type Delim = json.Delim

type Encoder

type Encoder = json.Encoder

func NewEncoder

func NewEncoder(w io.Writer) *Encoder

type Error

type Error struct {
	Code    ErrorCode   `json:"code"`
	Message string      `json:"message,omitempty"`
	Data    interface{} `json:"data,omitempty"`
}

Error ... Error codes

func NewError

func NewError(code ErrorCode, Msg string, data ...interface{}) *Error

NewError ...

func (*Error) Error

func (e *Error) Error() string

func (*Error) ErrorCode

func (e *Error) ErrorCode() int

func (*Error) ErrorData

func (e *Error) ErrorData() interface{}

type ErrorCode

type ErrorCode int

ErrorCode ... Error codes

const (
	ErrParse          ErrorCode = -32700
	ErrInvalidRequest ErrorCode = -32600
	ErrNoMethod       ErrorCode = -32601
	ErrBadParams      ErrorCode = -32602
	ErrInternal       ErrorCode = -32603
	ErrServer         ErrorCode = -32000

	ErrAuthorization ErrorCode = 401
	ErrForbidden     ErrorCode = 403
)

type Group

type Group interface {
	Handlers() []Handler
	Use(handlers ...Handler) Group
}

func NewGroup

func NewGroup(path string) Group

type Handler

type Handler func(c Context)

func Recover

func Recover() Handler

type ImplRPCMethodProvider

type ImplRPCMethodProvider interface {
	RPCMethodProvider(methodName string) string
}

type ImplRPCTypeName

type ImplRPCTypeName interface {
	RPCTypeName() string
}

type ItfJ2rpcError

type ItfJ2rpcError interface {
	ErrorCode() int
	Error() string
	ErrorData() interface{}
}

type Option

type Option func(option *ServerOption)

func WithCallerAfterReadBody

func WithCallerAfterReadBody(fn CallerBody) Option

func WithCallerBeforeWrite

func WithCallerBeforeWrite(fn CallerBody) Option

type RPCMessage

type RPCMessage struct {
	ID      RawMessage `json:"id,omitempty"`
	Version string     `json:"jsonrpc,omitempty"`
	Method  string     `json:"method,omitempty"`
	Params  RawMessage `json:"params,omitempty"`
	Result  RawMessage `json:"result,omitempty"`
	Error   *Error     `json:"error,omitempty"`
}

type RawMessage

type RawMessage = json.RawMessage

type Server

type Server interface {
	Handler(c Context)
	Option() *ServerOption
	RegisterFunc(args ...interface{})
	RegisterType(args ...interface{})
	RegisterTypeBus(bus interface{})
	ServeHTTP(writer http.ResponseWriter, request *http.Request)
	Use(path string, handlers ...Handler) Group
}

func NewServer

func NewServer(opt ...Option) Server

type ServerOption

type ServerOption struct {
	CallerAfterReadBody CallerBody
	CallerBeforeWrite   CallerBody
}