jsonlrpc

README

jsonl-rpc

A implementation of net/rpc ClientCodec and ServerCodec, which can transfer JSONL(JSON Lines) stream.

Usage

Refer to db-proxy as ServerCodec and db-proxy-driver as ClientCodec.

Documentation

Index

• func Dial(network, address string) (*rpc.Client, error)
• func NewClient(conn io.ReadWriteCloser) *rpc.Client
• func NewClientCodec(conn io.ReadWriteCloser) rpc.ClientCodec
• func NewServerCodec(conn io.ReadWriteCloser) rpc.ServerCodec
• func Reconnect(client **rpc.Client, maxRetry int, network, address string) func() error
• func ServeConn(conn io.ReadWriteCloser)
• type FnCollectJSONLs
• type JSONLClientResponse
• type JSONLResponse
• type JSONLServerResponse

Functions

func Dial

func Dial(network, address string) (*rpc.Client, error)

Dial connects to server at the specified network address.

func NewClient

func NewClient(conn io.ReadWriteCloser) *rpc.Client

NewClient returns a new rpc.Client to handle requests to the set of services at the other end of the connection.

func NewClientCodec

func NewClientCodec(conn io.ReadWriteCloser) rpc.ClientCodec

NewClientCodec returns a new rpc.ClientCodec on conn.

func NewServerCodec

func NewServerCodec(conn io.ReadWriteCloser) rpc.ServerCodec

NewServerCodec returns a new rpc.ServerCodec on conn.

func Reconnect

func Reconnect(client **rpc.Client, maxRetry int, network, address string) func() error

func ServeConn

func ServeConn(conn io.ReadWriteCloser)

ServeConn runs the server on a single connection. ServeConn blocks, serving the connection until the client hangs up. The caller typically invokes ServeConn in a go statement.

Types

type FnCollectJSONLs

type FnCollectJSONLs func(res json.RawMessage, jsonls <-chan interface{})

type JSONLClientResponse

type JSONLClientResponse struct {
	JSONLResponse
	Result        json.RawMessage `json:"result"`
	CollectJSONLs FnCollectJSONLs `json:"-"`
}

type JSONLResponse

type JSONLResponse struct {
	Code      int    `json:"code"`
	Msg       string `json:"msg"`
	HasJSONLs bool   `json:"has-jsonls"`
}

type JSONLServerResponse

type JSONLServerResponse struct {
	JSONLResponse
	Result interface{}        `json:"result"`
	JSONLs <-chan interface{} `json:"-"`
}