ziface

package

Go to main page

Versions in this module

v1

v1.2.6

Jul 12, 2024

Changes in this version

type IMsgHandle

+ SetHeadInterceptor func(interceptor IInterceptor)

v1.2.5

May 6, 2024

v1.2.3

Apr 9, 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{})

v1.2.2

Dec 12, 2023

v1.2.1

Aug 15, 2023

v1.2.0

Jul 21, 2023

Changes in this version

type HeartBeatOption

+ HeartBeatMsgID uint32

type IConnManager

+ Get2 func(string) (IConnection, error)

+ GetAllConnIdStr func() []string

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

type IConnection

+ GetConnIdStr func() string

+ GetWorkerID func() uint32

v1.1.33

Aug 29, 2024

v1.1.32

Aug 28, 2024

v1.1.31

Aug 28, 2024

Changes in this version

type IClient

+ GetFrameDecoder func() IFrameDecoder

+ SetFrameDecoder func(IFrameDecoder)

type IServer

+ GetFrameDecoder func() IFrameDecoder

+ SetFrameDecoder func(IFrameDecoder)

v1.1.30

Jun 26, 2024

v1.1.29

Jun 20, 2024

v1.1.28

Jun 14, 2024

v1.1.27

Jun 5, 2024

v1.1.26

May 22, 2024

v1.1.25

May 17, 2024

v1.1.24

Mar 26, 2024

v1.1.23

Mar 26, 2024

v1.1.22

May 12, 2023

v1.1.21

May 12, 2023

v1.1.20

May 16, 2023

v1.1.19

May 10, 2023

v1.1.18

May 10, 2023

Changes in this version

+ 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 HeartBeatOption

+ RouterSlices []RouterHandler

type IClient

+ GetName func() string

+ Restart func()

+ SetName func(string)

type IConnection

+ GetMsgHandler func() IMsgHandle

+ GetName func() string

+ LocalAddrString func() string

+ RemoteAddrString func() string

+ type IFuncRequest interface

+ CallFunc func()

+ type IGroupRouterSlices interface

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

+ Use func(Handlers ...RouterHandler)

type IHeartbeatChecker

+ BindRouterSlices func(uint32, ...RouterHandler)

+ RouterSlices func() []RouterHandler

type IMsgHandle

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

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

+ Use func(Handlers ...RouterHandler) IRouterSlices

type IRequest

+ BindRouterSlices func([]RouterHandler)

+ RouterSlicesNext func()

+ 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

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

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

+ ServerName func() string

+ Use func(Handlers ...RouterHandler) IRouterSlices

+ type RouterHandler func(request IRequest)

v1.1.17

Apr 14, 2023

Changes in this version

+ const ZinxDataPackOld

type IChain

+ GetIMessage func() IMessage

+ ProceedWithIMessage func(IMessage, IcReq) IcResp

type IClient

+ GetErrChan func() chan error

type IServer

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

v1.1.16

Apr 9, 2023

v1.1.15

Apr 4, 2023

Changes in this version

+ type HeartBeatFunc func(IConnection) error

+ type IBuilder interface

+ AddInterceptor func(interceptor IInterceptor)

+ Execute func(request IcReq) IcResp

+ Head func(interceptor IInterceptor)

+ Tail func(interceptor IInterceptor)

+ type IChain interface

+ Proceed func(IcReq) IcResp

+ Request func() IcReq

type IConnection

+ GetWsConn func() *websocket.Conn

+ type IFrameDecoder interface

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

type IHeartbeatChecker

+ SetHeartbeatFunc func(HeartBeatFunc)

+ type IInterceptor interface

+ Intercept func(IChain) IcResp

type IMsgHandle

+ Execute func(request IRequest)

+ type IcReq interface

+ type IcResp interface

v1.1.14

Mar 27, 2023

Changes in this version

type IConnection

+ SetHeartBeat func(checker IHeartbeatChecker)

v1.1.12

Mar 27, 2023

Changes in this version

type IConnManager

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

+ type IHeartbeatChecker interface

+ BindConn func(IConnection)

+ BindRouter func(uint32, IRouter)

+ Clone func() IHeartbeatChecker

+ MsgID func() uint32

+ Router func() IRouter

+ SendHeartBeatMsg func() error

+ SetHeartbeatMsgFunc func(HeartBeatMsgFunc)

+ SetOnRemoteNotAlive func(OnRemoteNotAlive)

+ Start func()

+ Stop func()

type IServer

+ GetHeartBeat func() IHeartbeatChecker

v1.1.11

Mar 23, 2023

v1.1.10

Mar 23, 2023

v1.1.9

Mar 23, 2023

v1.1.8

Mar 23, 2023

v1.1.7

Mar 22, 2023

v1.1.6

Mar 22, 2023

v1.1.5

Mar 22, 2023

v1.1.4

Mar 21, 2023

Changes in this version

type IMessage

+ GetRawData func() []byte

v1.1.3

Mar 21, 2023

Changes in this version

type IClient

+ SetDecoder func(IDecoder)

type IDecoder

+ GetLengthField func() *LengthField

+ type ILengthField interface

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

type IServer

+ SetDecoder func(IDecoder)

v1.1.2

Mar 14, 2023

Changes in this version

type IClient

+ SetLengthField func(LengthField)

type IServer

+ SetLengthField func(LengthField)

v1.1.1

Mar 13, 2023

Changes in this version

+ type Chain interface

+ Proceed func(Request) Response

+ Request func() Request

type IClient

+ AddInterceptor func(interceptor Interceptor)

+ GetLengthField func() LengthField

type IConnection

+ Send func(data []byte) error

+ SendToQueue func(data []byte) error

+ type IDecoder interface

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

type IMsgHandle

+ AddInterceptor func(interceptor Interceptor)

+ Decode func(request IRequest)

type IRequest

+ GetMessage func() IMessage

+ GetResponse func() Response

+ SetResponse func(Response)

type IServer

+ AddInterceptor func(interceptor Interceptor)

+ GetLengthField func() LengthField

+ type Interceptor interface

+ Intercept func(Chain) Response

+ type InterceptorBuilder interface

+ AddInterceptor func(interceptor Interceptor)

+ Execute func(request Request) Response

+ type LengthField struct

+ InitialBytesToStrip int

+ LengthAdjustment int

+ LengthFieldLength int

+ LengthFieldOffset int

+ MaxFrameLength int64

+ Order binary.ByteOrder

+ type Request interface

+ type Response interface

v1.1.0

Mar 8, 2023

Changes in this version

+ const HeartBeatDefaultMsgID

+ type HeartBeatMsgFunc func(IConnection) []byte

+ type HeartBeatOption struct

+ HeadBeatMsgID uint32

+ MakeMsg HeartBeatMsgFunc

+ OnRemoteNotAlive OnRemoteNotAlive

+ Router IRouter

+ type IClient interface

+ AddRouter func(msgID uint32, router IRouter)

+ Conn func() IConnection

+ GetMsgHandler func() IMsgHandle

+ GetOnConnStart func() func(IConnection)

+ GetOnConnStop func() func(IConnection)

+ GetPacket func() IDataPack

+ 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

+ GetAllConnID func() []uint32

type IConnection

+ GetConnection func() net.Conn

+ IsAlive func() bool

+ LocalAddr func() net.Addr

+ 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 IServer

+ GetMsgHandler func() IMsgHandle

+ GetOnConnStart func() func(IConnection)

+ GetOnConnStop func() func(IConnection)

+ GetPacket func() IDataPack

+ SetPacket func(IDataPack)

+ StartHeartBeat func(time.Duration)

+ StartHeartBeatWithOption func(time.Duration, *HeartBeatOption)

+ type OnRemoteNotAlive func(IConnection)

v1.0.2

Feb 23, 2023

Changes in this version

+ const ZinxDataPack

+ const ZinxMessage

+ type HandleStep int

type IRequest

+ Abort func()

+ BindRouter func(router IRouter)

+ Call func()

+ Goto func(HandleStep)

+ 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)

v1.0.1

Jan 11, 2022

Changes in this version

type IConnection

+ Context func() context.Context

type IMessage

+ GetMsgID func() uint32

+ SetMsgID func(uint32)

type IServer

+ Packet func() Packet

+ type Packet interface

+ GetHeadLen func() uint32

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

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

v1.0.0

Dec 23, 2020

Changes in this version

+ type IConnManager interface

+ Add func(conn IConnection)

+ ClearConn func()

+ Get func(connID uint32) (IConnection, error)

+ Len func() int

+ Remove func(conn IConnection)

+ type IConnection interface

+ GetConnID func() uint32

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

+ GetTCPConnection func() *net.TCPConn

+ RemoteAddr func() net.Addr

+ RemoveProperty func(key string)

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

+ SendMsg func(msgId uint32, 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 IMessage interface

+ GetData func() []byte

+ GetDataLen func() uint32

+ GetMsgId func() uint32

+ SetData func([]byte)

+ SetDataLen func(uint32)

+ SetMsgId func(uint32)

+ type IMsgHandle interface

+ AddRouter func(msgId uint32, router IRouter)

+ DoMsgHandler func(request IRequest)

+ SendMsgToTaskQueue func(request IRequest)

+ StartWorkerPool func()

+ type IRequest interface

+ GetConnection func() IConnection

+ GetData func() []byte

+ GetMsgID func() uint32

+ type IRouter interface

+ Handle func(request IRequest)

+ PostHandle func(request IRequest)

+ PreHandle func(request IRequest)

+ type IServer interface

+ AddRouter func(msgId uint32, router IRouter)

+ CallOnConnStart func(conn IConnection)

+ CallOnConnStop func(conn IConnection)

+ GetConnMgr func() IConnManager

+ Serve func()

+ SetOnConnStart func(func(IConnection))

+ SetOnConnStop func(func(IConnection))

+ Start func()

+ Stop func()

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