iotconn

package module

v0.0.0-...-bb7f942 Latest Latest Go to latest Published: Mar 22, 2021 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

gitee.com/mgr9525/iot-conn

Links

Open Source Insights

README ¶

IotConn

介绍

轻量级C/S通信协议，可在长连接、短连接之间反复横跳 (-_-||)!!!

软件架构

软件架构说明

安装教程

xxxx
xxxx
xxxx

使用说明

xxxx
xxxx
xxxx

参与贡献

Fork 本仓库
新建 Feat_xxx 分支
提交代码
新建 Pull Request

特技

Documentation ¶

Index ¶

Constants
func ReadBodyTimeout(n time.Duration)
func ReadHeadTimeout(n time.Duration)
func SetMaxBodyLen(n uint)
func SetMaxHeadLen(n uint)
type AuthFun
type ConnFun
- func ParamFunHandle(fn interface{}, authfn ...AuthFun) ConnFun
- func RPCFunHandle(t interface{}, authfn ...AuthFun) ConnFun
type Context
- func (c *Context) BodyBytes() []byte
- func (c *Context) GetConn() net.Conn
- func (c *Context) HeadBytes() []byte
- func (c *Context) ReqHeader() (*Header, error)
- func (c *Context) ResBytes(code int, bdbts []byte, hds ...[]byte) error
- func (c *Context) ResHeader() *Header
- func (c *Context) ResJson(code int, body interface{}, hds ...[]byte) error
- func (c *Context) ResString(code int, s string, hds ...[]byte) error
type Engine
- func NewEngine(ctx context.Context) *Engine
- func (c *Engine) ReadBodyTimeout(n time.Duration)
- func (c *Engine) ReadHeadTimeout(n time.Duration)
- func (c *Engine) RegFun(mcode int, fn ConnFun) bool
- func (c *Engine) Run(host string) error
- func (c *Engine) SetMaxBodyLen(n uint)
- func (c *Engine) SetMaxHeadLen(n uint)
type Header
- func ParseHeader(bts []byte) (*Header, error)
- func (c *Header) Bytes() []byte
- func (c *Header) Del(key string)
- func (c *Header) Get(key string) (interface{}, bool)
- func (c *Header) GetBool(key string) bool
- func (c *Header) GetFloat(key string) (float64, error)
- func (c *Header) GetInt(key string) (int64, error)
- func (c *Header) GetString(key string) (string, bool)
- func (c *Header) Set(key string, val interface{})
type Mp
type Request
- func NewRPCReq(addr string, path string, timeout ...time.Duration) (*Request, error)
- func NewRequest(addr string, timeout ...time.Duration) (*Request, error)
- func (c *Request) Close() error
- func (c *Request) Do(control int, body interface{}, hds ...[]byte) error
- func (c *Request) GetConn() net.Conn
- func (c *Request) ReqHeader() *Header
- func (c *Request) ResBodyBytes() []byte
- func (c *Request) ResBodyJson(bd interface{}) error
- func (c *Request) ResCode() int
- func (c *Request) ResHeadBytes() []byte
- func (c *Request) ResHeader() (*Header, error)

Constants ¶

View Source

const (
	// Status is int32
	ResStatusOk       = 1
	ResStatusErr      = 2
	ResStatusAuth     = 3
	ResStatusNotFound = 4
)

Variables ¶

This section is empty.

Functions ¶

func ReadBodyTimeout ¶

func ReadBodyTimeout(n time.Duration)

func ReadHeadTimeout ¶

func ReadHeadTimeout(n time.Duration)

func SetMaxBodyLen ¶

func SetMaxBodyLen(n uint)

func SetMaxHeadLen ¶

func SetMaxHeadLen(n uint)

Types ¶

type AuthFun ¶

type AuthFun = func(c *Context) bool

type ConnFun ¶

type ConnFun func(res *Context)

返回true则连接不会关闭

func ParamFunHandle ¶

func ParamFunHandle(fn interface{}, authfn ...AuthFun) ConnFun

func RPCFunHandle ¶

func RPCFunHandle(t interface{}, authfn ...AuthFun) ConnFun

type Context ¶

type Context struct {
	// contains filtered or unexported fields
}

func (*Context) BodyBytes ¶

func (c *Context) BodyBytes() []byte

func (*Context) GetConn ¶

func (c *Context) GetConn() net.Conn

func (*Context) HeadBytes ¶

func (c *Context) HeadBytes() []byte

func (*Context) ReqHeader ¶

func (c *Context) ReqHeader() (*Header, error)

func (*Context) ResBytes ¶

func (c *Context) ResBytes(code int, bdbts []byte, hds ...[]byte) error

func (*Context) ResHeader ¶

func (c *Context) ResHeader() *Header

func (*Context) ResJson ¶

func (c *Context) ResJson(code int, body interface{}, hds ...[]byte) error

func (*Context) ResString ¶

func (c *Context) ResString(code int, s string, hds ...[]byte) error

type Engine ¶

type Engine struct {
	// contains filtered or unexported fields
}

func NewEngine ¶

func NewEngine(ctx context.Context) *Engine

func (*Engine) ReadBodyTimeout ¶

func (c *Engine) ReadBodyTimeout(n time.Duration)

func (*Engine) ReadHeadTimeout ¶

func (c *Engine) ReadHeadTimeout(n time.Duration)

func (*Engine) RegFun ¶

func (c *Engine) RegFun(mcode int, fn ConnFun) bool

func (*Engine) Run ¶

func (c *Engine) Run(host string) error

func (*Engine) SetMaxBodyLen ¶

func (c *Engine) SetMaxBodyLen(n uint)

func (*Engine) SetMaxHeadLen ¶

func (c *Engine) SetMaxHeadLen(n uint)

type Header ¶

type Header struct {
	Path  string `json:"path"`
	RelIp string `json:"ip"`    // 真实IP
	Token string `json:"token"` // 请求token
	Times string `json:"times"` // 请求时间

	Info map[string]interface{} `json:"info"`
}

func ParseHeader ¶

func ParseHeader(bts []byte) (*Header, error)

func (c *Header) Bytes() []byte

func (c *Header) Del(key string)

func (c *Header) Get(key string) (interface{}, bool)

func (c *Header) GetBool(key string) bool

func (c *Header) GetFloat(key string) (float64, error)

func (c *Header) GetInt(key string) (int64, error)

func (c *Header) GetString(key string) (string, bool)

func (c *Header) Set(key string, val interface{})

type Mp ¶

type Mp map[string]interface{}

type Request ¶

type Request struct {
	// contains filtered or unexported fields
}

func NewRPCReq ¶

func NewRPCReq(addr string, path string, timeout ...time.Duration) (*Request, error)

func NewRequest ¶

func NewRequest(addr string, timeout ...time.Duration) (*Request, error)

func (*Request) Close ¶

func (c *Request) Close() error

func (*Request) Do ¶

func (c *Request) Do(control int, body interface{}, hds ...[]byte) error

func (*Request) GetConn ¶

func (c *Request) GetConn() net.Conn

func (*Request) ReqHeader ¶

func (c *Request) ReqHeader() *Header

func (*Request) ResBodyBytes ¶

func (c *Request) ResBodyBytes() []byte

func (*Request) ResBodyJson ¶

func (c *Request) ResBodyJson(bd interface{}) error

func (*Request) ResCode ¶

func (c *Request) ResCode() int

func (*Request) ResHeadBytes ¶

func (c *Request) ResHeadBytes() []byte

func (*Request) ResHeader ¶

func (c *Request) ResHeader() (*Header, error)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
utils

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL