node

Aug 21, 2024

Changes in this version

+ func StartNodeEncipher(addr string, enc Encipher)

+ type DefaultEncipher struct

+ func NewDefaultEncipher() *DefaultEncipher

+ func (s *DefaultEncipher) Decrypt(input string) (string, error)

+ func (s *DefaultEncipher) Encrypt(input string) (string, error)

+ func (s *DefaultEncipher) Signature(input string) string

+ func (s *DefaultEncipher) VerifySignature(input, sign string) bool

+ type Encipher interface

+ Decrypt func(input string) (string, error)

+ Encrypt func(input string) (string, error)

+ Signature func(input string) string

+ VerifySignature func(input, sign string) bool

+ type EncipherParam struct

+ EncryptKey string

+ SignDepth int

+ SignKey string

Mar 8, 2024

Changes in this version

type DevConn

+ Sub string

Feb 29, 2024

Changes in this version

type DevConn

+ Ready bool

type WsServer

+ func (self *WsServer) GetAllConn() map[string]cache2.Item

Feb 22, 2024

Changes in this version

type WsServer

+ Debug bool

Feb 21, 2024

Changes in this version

+ type ConnPool map[string]map[string]*DevConn

+ type DevConn struct

+ Conn *websocket.Conn

+ Ctx *Context

+ Dev string

+ Last int64

+ Life int64

+ type Handle func(*Context, []byte) (interface{}, error)

+ type Ping struct

+ HealthCheck string

+ type TokenAuth struct

+ Secret string

+ Token string

+ type WsClient struct

+ Addr string

+ AuthCall func() (string, string, error)

+ Origin string

+ Path string

+ ReceiveCall func(message []byte) (interface{}, error)

+ func (client *WsClient) Ready() bool

+ func (client *WsClient) SendMessage(reply interface{}) error

+ func (client *WsClient) StartWebsocket(auto bool, n ...int)

+ type WsServer struct

+ func (self *WsServer) AddJwtConfig(config jwt.JwtConfig)

+ func (self *WsServer) AddRouter(path string, handle Handle, routerConfig *RouterConfig)

+ func (self *WsServer) NewPool(maxConn, limit, bucket int)

+ func (self *WsServer) SendMessage(data interface{}, subject string, dev ...string) error

+ func (self *WsServer) StartWebsocket(addr string)

Dec 20, 2023

Changes in this version

type Context

+ func (self *Context) GetHeader(key string) string

+ func (self *Context) GetPostBody() string

Nov 2, 2023

Changes in this version

+ func ErrorMsgToLang(ctx *Context, msg string) string

Oct 26, 2023

Changes in this version

type HttpNode

+ func (self *HttpNode) AddLanguageByJson(langDs string, bs []byte) error

Aug 2, 2023

Changes in this version

+ type ErrorHandle func(ctx *Context, throw ex.Throw) error

type HttpNode

+ func (self *HttpNode) AddErrorHandle(errorHandle func(ctx *Context, throw ex.Throw) error) error

Aug 1, 2023

Changes in this version

type Context

+ func (self *Context) Json(data interface{}) error

+ func (self *Context) Text(data string) error

Jul 13, 2023

Changes in this version

+ type System struct

+ AcceptTimeout int64

+ Name string

+ Version string

Jul 11, 2023

Changes in this version

type Context

+ System string

type HttpNode

+ func (self *HttpNode) AddRoleRealm(roleRealm func(ctx *Context, onlyRole bool) (*Permission, error)) error

+ func (self *HttpNode) SetSystem(name string)

type Permission

+ HasRole []int64

+ MatchAll bool

Jul 6, 2023

Changes in this version

+ const MAX_CODE_LEN

+ const MAX_TOKEN_LEN

+ type Configs struct

Jun 15, 2023

Changes in this version

type Context

+ func (self *Context) ClientLanguage() string

type HttpNode

+ func (self *HttpNode) AddLanguage(langDs, filePath string) error

Jun 14, 2023

Changes in this version

type Context

+ func (self *Context) ClientDevice() string

+ func (self *Context) RemoteIP() string

Jun 14, 2023

Changes in this version

type Context

+ ClientIP string

Apr 15, 2023

Changes in this version

type Context

+ EnableECC bool

type HttpNode

+ func (self *HttpNode) AddCipher(cipher crypto.Cipher)

+ func (self *HttpNode) EnableECC(enable bool)

Oct 18, 2022

Changes in this version

type RouterConfig

+ UseHAX bool

Oct 10, 2022

Changes in this version

type JsonBody

+ func (self *JsonBody) ParseData(dst interface{}) error

+ func (self *JsonBody) RawData() []byte

type RouterConfig

+ UseRSA bool

Sep 17, 2022

Changes in this version

+ type CacheAware func(ds ...string) (cache.Cache, error)

type Context

+ RSA gorsa.RSA

type HttpNode

+ func (self *HttpNode) AddCache(aware CacheAware)

+ func (self *HttpNode) AddRSA(rsa gorsa.RSA)

Sep 14, 2022

Changes in this version

+ const RandomCode

type Context

+ func (self *Context) DelStorage(k string)

Sep 11, 2022

Changes in this version

+ const ANDROID

+ const APPLICATION_JSON

+ const Authorization

+ const CLIENT_PUBKEY

+ const DELETE

+ const GET

+ const GatewayRateLimiterFilterName

+ const HEAD

+ const IOS

+ const MAX_VALUE_LEN

+ const OPTIONS

+ const PATCH

+ const POST

+ const PUT

+ const ParameterFilterName

+ const PostHandleFilterName

+ const RenderHandleFilterName

+ const ReplayFilterName

+ const RoleFilterName

+ const SessionFilterName

+ const TEXT_PLAIN

+ const UTF8

+ const UserRateLimiterFilterName

+ const WEB

+ func NewGracefulListener(address string, maxWaitTime time.Duration) net.Listener

+ func SetGatewayRateLimiter(option rate.Option)

+ func SetMethodRateLimiter(option rate.Option)

+ func SetUserRateLimiter(option rate.Option)

+ type Context struct

+ AcceptTimeout int64

+ CacheAware func(ds ...string) (cache.Cache, error)

+ CreateAt int64

+ Device string

+ JsonBody *JsonBody

+ Method string

+ Path string

+ PermConfig func(uid, url string, isRole ...bool) ([]int64, Permission, error)

+ RequestCtx *fasthttp.RequestCtx

+ Response *Response

+ RouterConfig *RouterConfig

+ ServerTLS *gorsa.RsaObj

+ Storage map[string]interface{}

+ Subject *jwt.Payload

+ Token string

+ func (self *Context) AddStorage(k string, v interface{})

+ func (self *Context) Authenticated() bool

+ func (self *Context) GetHmac256Sign(d, n string, t, p int64, key ...string) string

+ func (self *Context) GetJwtConfig() jwt.JwtConfig

+ func (self *Context) GetStorage(k string) interface{}

+ func (self *Context) GetTokenSecret() string

+ func (self *Context) Handle() error

+ func (self *Context) Parser(v interface{}) error

+ type DefaultCacheSessionAware struct

+ func NewLocalCacheSessionAware() *DefaultCacheSessionAware

+ func (self *DefaultCacheSessionAware) CreateSession(s Session) error

+ func (self *DefaultCacheSessionAware) DeleteSession(s Session) error

+ func (self *DefaultCacheSessionAware) GetActiveSessions() []Session

+ func (self *DefaultCacheSessionAware) ReadSession(s string) (Session, error)

+ func (self *DefaultCacheSessionAware) UpdateSession(s Session) error

+ type Filter interface

+ DoFilter func(chain Filter, ctx *Context, args ...interface{}) error

+ type FilterObject struct

+ Filter Filter

+ MatchPattern []string

+ Name string

+ Order int

+ type GatewayRateLimiterFilter struct

+ func (self *GatewayRateLimiterFilter) DoFilter(chain Filter, ctx *Context, args ...interface{}) error

+ type GracefulListener struct

+ func (ln *GracefulListener) Accept() (net.Conn, error)

+ func (ln *GracefulListener) Addr() net.Addr

+ func (ln *GracefulListener) Close() error

+ type HookNode struct

+ Context *Context

+ type HttpLog struct

+ CostMill int64

+ CreateAt int64

+ LogNo string

+ Method string

+ UpdateAt int64

+ type HttpNode struct

+ func (self *HttpNode) AddCacheAware(cacheAware func(ds ...string) (cache.Cache, error))

+ func (self *HttpNode) AddFilter(object *FilterObject)

+ func (self *HttpNode) AddJwtConfig(config jwt.JwtConfig)

+ func (self *HttpNode) ClearFilterChain()

+ func (self *HttpNode) DELETE(path string, handle func(ctx *Context) error, routerConfig *RouterConfig)

+ func (self *HttpNode) GET(path string, handle func(ctx *Context) error, routerConfig *RouterConfig)

+ func (self *HttpNode) HEAD(path string, handle func(ctx *Context) error, routerConfig *RouterConfig)

+ func (self *HttpNode) Json(ctx *Context, data interface{}) error

+ func (self *HttpNode) OPTIONS(path string, handle func(ctx *Context) error, routerConfig *RouterConfig)

+ func (self *HttpNode) PATCH(path string, handle func(ctx *Context) error, routerConfig *RouterConfig)

+ func (self *HttpNode) POST(path string, handle func(ctx *Context) error, routerConfig *RouterConfig)

+ func (self *HttpNode) PUT(path string, handle func(ctx *Context) error, routerConfig *RouterConfig)

+ func (self *HttpNode) StartServer(addr string)

+ func (self *HttpNode) Text(ctx *Context, data string) error

+ type JWTSession struct

+ Attributes map[string]interface{}

+ Expire bool

+ Host string

+ Id string

+ LastAccessTime int64

+ StartTimestamp int64

+ StopTime int64

+ Timeout int64

+ func (self *JWTSession) GetAttribute(k string) (interface{}, error)

+ func (self *JWTSession) GetAttributeKeys() ([]string, error)

+ func (self *JWTSession) GetHost() string

+ func (self *JWTSession) GetId() string

+ func (self *JWTSession) GetLastAccessTime() int64

+ func (self *JWTSession) GetStartTimestamp() int64

+ func (self *JWTSession) GetTimeout() (int64, error)

+ func (self *JWTSession) Invalid() bool

+ func (self *JWTSession) IsTimeout() bool

+ func (self *JWTSession) RemoveAttribute(k string) error

+ func (self *JWTSession) SetAttribute(k string, v interface{}) error

+ func (self *JWTSession) SetHost(host string)

+ func (self *JWTSession) SetTimeout(t int64) error

+ func (self *JWTSession) Stop() error

+ func (self *JWTSession) Touch() error

+ func (self *JWTSession) Validate(accessToken, secretKey string) (int64, error)

+ type JsonBody struct

+ Data interface{}

+ Nonce string

+ Plan int64

+ Sign string

+ Time int64

+ type JsonResp struct

+ Code int

+ Data interface{}

+ Message string

+ Nonce string

+ Plan int64

+ Sign string

+ Time int64

+ type ParameterFilter struct

+ func (self *ParameterFilter) DoFilter(chain Filter, ctx *Context, args ...interface{}) error

+ type Permission struct

+ MathchAll int64

+ NeedLogin int64

+ NeedRole []int64

+ Ready bool

+ type PostHandle func(*Context) error

+ type PostHandleFilter struct

+ func (self *PostHandleFilter) DoFilter(chain Filter, ctx *Context, args ...interface{}) error

+ type RenderHandleFilter struct

+ func (self *RenderHandleFilter) DoFilter(chain Filter, ctx *Context, args ...interface{}) error

+ type ReplayFilter struct

+ func (self *ReplayFilter) DoFilter(chain Filter, ctx *Context, args ...interface{}) error

+ type Response struct

+ ContentEntity interface{}

+ ContentEntityByte []byte

+ ContentType string

+ Encoding string

+ StatusCode int

+ type RoleFilter struct

+ func (self *RoleFilter) DoFilter(chain Filter, ctx *Context, args ...interface{}) error

+ type RouterConfig struct

+ AesRequest bool

+ AesResponse bool

+ Guest bool

+ Login bool

+ type Session interface

+ GetAttribute func(k string) (interface{}, error)

+ GetAttributeKeys func() ([]string, error)

+ GetHost func() string

+ GetId func() string

+ GetLastAccessTime func() int64

+ GetStartTimestamp func() int64

+ GetTimeout func() (int64, error)

+ Invalid func() bool

+ IsTimeout func() bool

+ RemoveAttribute func(k string) error

+ SetAttribute func(k string, v interface{}) error

+ SetHost func(host string)

+ SetTimeout func(t int64) error

+ Stop func() error

+ Touch func() error

+ Validate func(accessToken, secretKey string) (int64, error)

+ type SessionAware interface

+ CreateSession func(s Session) error

+ DeleteSession func(s Session) error

+ GetActiveSessions func() []Session

+ ReadSession func(s string) (Session, error)

+ UpdateSession func(s Session) error

+ type SessionFilter struct

+ func (self *SessionFilter) DoFilter(chain Filter, ctx *Context, args ...interface{}) error

+ type UserRateLimiterFilter struct

+ func (self *UserRateLimiterFilter) DoFilter(chain Filter, ctx *Context, args ...interface{}) error