fastrpc

README

fastrpc

Documentation

Index

• func Serve(event Event, addr string) (err error)
• type Action
• type CompressType
• type Conn
• type Event
• type Header
• type Option
• type Options
  • func SetOption(options ...Option) *Options
• type Package
• type PayloadType
• type Server

Functions

func Serve

func Serve(event Event, addr string) (err error)

Types

type Action

type Action int

const (
	None Action = iota
	Close
	Shutdown
)

type CompressType

type CompressType byte

const (
	CompressTypeGzip CompressType = iota
	CompressTypeSnappy
)

type Conn

type Conn interface {
	LocalAddr() net.Addr
	RemoteAddr() net.Addr
}

type Event

type Event struct {
	LoopNum int
	Open    func(c Conn) (out []byte, opts Options, action Action)
	Close   func(c Conn, err error) (action Action)
	Data    func(c Conn, in []byte) (out []byte, action Action)
	Serve   func(svr Server) (action Action)
}

type Header

type Header [11]byte // 0: magicNumber | 1:(0): heartbeat | 1:(1-3): payloadType | 1:(4-6): compressType | 1:(7): status | 2-9: uuid | 10:(0-3): bodyLength

type Option

type Option func(opts *Options)

type Options

type Options struct {
	KeepAliveSec int
}

func SetOption

func SetOption(options ...Option) *Options

type Package

type Package struct {
	*Header
	RpcPath   string
	RpcMethod string
	Payload   []byte
	Data      []byte
}

type PayloadType

type PayloadType byte

const (
	PayloadTypeJson PayloadType = iota
	PayloadTypeProtobuf
)

type Server

type Server struct {
	Addr    net.Addr
	LoopNum int
}