ziface

package

Go to main page

Versions in this module

v1

v1.2.6

Apr 25, 2024

v1.2.5

Apr 24, 2024

v1.2.4

Apr 19, 2024

Changes in this version

type BaseRequest

+ func (br *BaseRequest) Copy() IRequest

+ func (br *BaseRequest) Get(key string) (value interface{}, exists bool)

+ func (br *BaseRequest) Set(key string, value interface{})

type IConnection

+ AddCloseCallback func(handler, key interface{}, callback func())

+ InvokeCloseCallbacks func()

+ RemoveCloseCallback func(handler, key interface{})

type IRequest

+ Copy func() IRequest

+ Get func(key string) (value interface{}, exists bool)

+ Set func(key string, value interface{})

v0

v0.1.3

Apr 18, 2024

v0.1.2

Jan 10, 2024

v0.1.1

Nov 14, 2023

v0.1.0

Nov 13, 2023

v0.0.2

Nov 14, 2023

Changes in this version

+ const HeartBeatDefaultMsgID

+ const ZinxDataPack

+ const ZinxDataPackOld

+ const ZinxMessage

+ type BaseRequest struct

+ func (br *BaseRequest) Abort()

+ func (br *BaseRequest) BindRouter(router IRouter)

+ func (br *BaseRequest) BindRouterSlices([]RouterHandler)

+ func (br *BaseRequest) Call()

+ func (br *BaseRequest) GetConnection() IConnection

+ func (br *BaseRequest) GetData() []byte

+ func (br *BaseRequest) GetMessage() IMessage

+ func (br *BaseRequest) GetMsgID() uint32

+ func (br *BaseRequest) GetResponse() IcResp

+ func (br *BaseRequest) Goto(HandleStep)

+ func (br *BaseRequest) RouterSlicesNext()

+ func (br *BaseRequest) SetResponse(resp IcResp)

+ type HandleStep int

+ type HeartBeatFunc func(IConnection) error

+ type HeartBeatMsgFunc func(IConnection) []byte

+ type HeartBeatOption struct

+ HeartBeatMsgID uint32

+ MakeMsg HeartBeatMsgFunc

+ OnRemoteNotAlive OnRemoteNotAlive

+ Router IRouter

+ RouterSlices []RouterHandler

+ type IChain interface

+ GetIMessage func() IMessage

+ Proceed func(IcReq) IcResp

+ ProceedWithIMessage func(IMessage, IcReq) IcResp

+ Request func() IcReq

+ type IClient interface

+ AddInterceptor func(IInterceptor)

+ AddRouter func(msgID uint32, router IRouter)

+ Conn func() IConnection

+ GetErrChan func() chan error

+ GetLengthField func() *LengthField

+ GetMsgHandler func() IMsgHandle

+ GetName func() string

+ GetOnConnStart func() func(IConnection)

+ GetOnConnStop func() func(IConnection)

+ GetPacket func() IDataPack

+ Restart func()

+ SetDecoder func(IDecoder)

+ SetName func(string)

+ SetOnConnStart func(func(IConnection))

+ SetOnConnStop func(func(IConnection))

+ SetPacket func(IDataPack)

+ Start func()

+ StartHeartBeat func(time.Duration)

+ StartHeartBeatWithOption func(time.Duration, *HeartBeatOption)

+ Stop func()

+ type IConnManager interface

+ Add func(IConnection)

+ ClearConn func()

+ Get func(uint64) (IConnection, error)

+ Get2 func(string) (IConnection, error)

+ GetAllConnID func() []uint64

+ GetAllConnIdStr func() []string

+ Len func() int

+ Range func(func(uint64, IConnection, interface{}) error, interface{}) error

+ Range2 func(func(string, IConnection, interface{}) error, interface{}) error

+ Remove func(IConnection)

+ type IConnection interface

+ Context func() context.Context

+ GetConnID func() uint64

+ GetConnIdStr func() string

+ GetConnection func() net.Conn

+ GetMsgHandler func() IMsgHandle

+ GetName func() string

+ GetProperty func(key string) (interface{}, error)

+ GetTCPConnection func() net.Conn

+ GetWorkerID func() uint32

+ GetWsConn func() *websocket.Conn

+ IsAlive func() bool

+ LocalAddr func() net.Addr

+ LocalAddrString func() string

+ RemoteAddr func() net.Addr

+ RemoteAddrString func() string

+ RemoveProperty func(key string)

+ Send func(data []byte) error

+ SendBuffMsg func(msgID uint32, data []byte) error

+ SendMsg func(msgID uint32, data []byte) error

+ SendToQueue func(data []byte) error

+ SetProperty func(key string, value interface{})

+ Start func()

+ Stop func()

+ type IDataPack interface

+ GetHeadLen func() uint32

+ Pack func(msg IMessage) ([]byte, error)

+ Unpack func([]byte) (IMessage, error)

+ type IDecoder interface

+ GetLengthField func() *LengthField

+ type IFrameDecoder interface

+ Decode func(buff []byte) [][]byte

+ type IFuncRequest interface

+ CallFunc func()

+ type IGroupRouterSlices interface

+ AddHandler func(MsgId uint32, Handlers ...RouterHandler)

+ Use func(Handlers ...RouterHandler)

+ type IHeartbeatChecker interface

+ BindRouter func(uint32, IRouter)

+ BindRouterSlices func(uint32, ...RouterHandler)

+ Clone func() IHeartbeatChecker

+ MsgID func() uint32

+ Router func() IRouter

+ RouterSlices func() []RouterHandler

+ SendHeartBeatMsg func() error

+ SetHeartbeatFunc func(HeartBeatFunc)

+ SetHeartbeatMsgFunc func(HeartBeatMsgFunc)

+ SetOnRemoteNotAlive func(OnRemoteNotAlive)

+ Start func()

+ Stop func()

+ type IInterceptor interface

+ Intercept func(IChain) IcResp

+ type ILogger interface

+ DebugF func(format string, v ...interface{})

+ DebugFX func(ctx context.Context, format string, v ...interface{})

+ ErrorF func(format string, v ...interface{})

+ ErrorFX func(ctx context.Context, format string, v ...interface{})

+ InfoF func(format string, v ...interface{})

+ InfoFX func(ctx context.Context, format string, v ...interface{})

+ type IMessage interface

+ GetData func() []byte

+ GetDataLen func() uint32

+ GetMsgID func() uint32

+ GetRawData func() []byte

+ SetData func([]byte)

+ SetDataLen func(uint32)

+ SetMsgID func(uint32)

+ type IMsgHandle interface

+ AddInterceptor func(interceptor IInterceptor)

+ AddRouter func(msgID uint32, router IRouter)

+ AddRouterSlices func(msgId uint32, handler ...RouterHandler) IRouterSlices

+ Execute func(request IRequest)

+ Group func(start, end uint32, Handlers ...RouterHandler) IGroupRouterSlices

+ SendMsgToTaskQueue func(request IRequest)

+ StartWorkerPool func()

+ Use func(Handlers ...RouterHandler) IRouterSlices

+ type IRequest interface

+ Abort func()

+ BindRouter func(router IRouter)

+ BindRouterSlices func([]RouterHandler)

+ Call func()

+ GetConnection func() IConnection

+ GetData func() []byte

+ GetMessage func() IMessage

+ GetMsgID func() uint32

+ GetResponse func() IcResp

+ Goto func(HandleStep)

+ RouterSlicesNext func()

+ SetResponse func(IcResp)

+ type IRouter interface

+ Handle func(request IRequest)

+ PostHandle func(request IRequest)

+ PreHandle func(request IRequest)

+ type IRouterSlices interface

+ AddHandler func(msgId uint32, handlers ...RouterHandler)

+ GetHandlers func(MsgId uint32) ([]RouterHandler, bool)

+ Group func(start, end uint32, Handlers ...RouterHandler) IGroupRouterSlices

+ Use func(Handlers ...RouterHandler)

+ type IServer interface

+ AddInterceptor func(IInterceptor)

+ AddRouter func(msgID uint32, router IRouter)

+ AddRouterSlices func(msgID uint32, router ...RouterHandler) IRouterSlices

+ GetConnMgr func() IConnManager

+ GetLengthField func() *LengthField

+ GetMsgHandler func() IMsgHandle

+ GetOnConnStart func() func(IConnection)

+ GetOnConnStop func() func(IConnection)

+ GetPacket func() IDataPack

+ Group func(start, end uint32, Handlers ...RouterHandler) IGroupRouterSlices

+ Serve func()

+ ServerName func() string

+ SetDecoder func(IDecoder)

+ SetOnConnStart func(func(IConnection))

+ SetOnConnStop func(func(IConnection))

+ SetPacket func(IDataPack)

+ SetWebsocketAuth func(func(r *http.Request) error)

+ Start func()

+ Stop func()

+ Use func(Handlers ...RouterHandler) IRouterSlices

+ type IcReq interface

+ type IcResp interface

+ type Inotify interface

+ ConnNums func() int

+ DelNotifyByID func(Id uint64)

+ GetNotifyByID func(Id uint64) (IConnection, error)

+ HasIdConn func(id uint64) bool

+ NotifyAll func(MsgId uint32, data []byte) error

+ NotifyBuffAll func(MsgId uint32, data []byte) error

+ NotifyBuffToConnByID func(Id uint64, MsgId uint32, data []byte) error

+ NotifyToConnByID func(Id uint64, MsgId uint32, data []byte) error

+ SetNotifyID func(Id uint64, conn IConnection)

+ type LengthField struct

+ InitialBytesToStrip int

+ LengthAdjustment int

+ LengthFieldLength int

+ LengthFieldOffset int

+ MaxFrameLength uint64

+ Order binary.ByteOrder

+ type OnRemoteNotAlive func(IConnection)

+ type RouterHandler func(request IRequest)

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