server

Feb 13, 2025

Changes in this version

type MqttConnect

+ func NewMqttConnect() *MqttConnect

Feb 12, 2025

Changes in this version

+ const CORE_MQTT_SERVER

Nov 7, 2024

Changes in this version

+ func RunInterceptor(interceptor XhttpInterceptor, handlers ...*XhttpExecutor)

+ func XhttpPerform(executor *XhttpExecutor, writer http.ResponseWriter, request *http.Request)

+ type XhttpInterceptor interface

+ Registry func(*XhttpExecutor) http.Handler

Nov 4, 2024

Changes in this version

+ func XhttpContainsOptions(xRequest *structs.ZeroRequest, option string) bool

Mar 21, 2024

Changes in this version

type MqttConnect

+ func (mqttconn *MqttConnect) UpdateSerialNnumber(serialNnumber uint16)

Mar 19, 2024

Changes in this version

type MqttConnect

+ func (mqttconn *MqttConnect) UseSerialNnumber() uint16

Mar 19, 2024

Changes in this version

type MqttConnect

+ func (mqttconn *MqttConnect) AddListener(xListener MqttMessageListener)

Mar 19, 2024

Changes in this version

+ type MqttMessageListener interface

+ Publish func(*MqttMessage) error

Mar 11, 2024

Changes in this version

+ func XhttpURIParams(req *http.Request, xPattern string) map[string]string

Mar 11, 2024

Changes in this version

+ func XhttpKeyValueRequest(req *http.Request) map[string]string

+ type XhttpFromFile struct

+ func XhttpFromFileRequest(req *http.Request, maxmem int64) ([]*XhttpFromFile, error)

+ func (xfile *XhttpFromFile) FileHeader() *multipart.FileHeader

+ func (xfile *XhttpFromFile) FileName() string

+ func (xfile *XhttpFromFile) FileSize() int64

+ func (xfile *XhttpFromFile) FilesBytes() []byte

+ func (xfile *XhttpFromFile) MIMEHeader() textproto.MIMEHeader

Feb 29, 2024

Changes in this version

+ const XHTTP_QUERY_OPTIONS_ALL

+ func XhttpQueryOptions(xRequest *structs.ZeroRequest) []string

Feb 29, 2024

Changes in this version

+ func XhttpCompleteQueryOperation(xRequest *structs.ZeroRequest, xProcessor processors.ZeroQueryOperation, ...) (processors.ZeroQueryOperation, *processors.ZeroQuery, error)

+ func XhttpMysqlQueryOperation(xRequest *structs.ZeroRequest, tableName string) (processors.ZeroQueryOperation, *processors.ZeroQuery, error)

+ func XhttpPostgresQueryOperation(xRequest *structs.ZeroRequest, tableName string) (processors.ZeroQueryOperation, *processors.ZeroQuery, error)

Feb 28, 2024

Changes in this version

+ func XhttpEQuery(xRequest *structs.ZeroRequest) (*database.EQuerySearch, error)

+ func XhttpEQueryRequest(xRequest *structs.ZeroRequest, indexName string) (*database.EQueryRequest, *database.EQuerySearch, error)

Feb 23, 2024

Changes in this version

type ZeroConnect

+ AcceptTime func() int64

+ HeartbeatTime func() int64

type ZeroSocketConnect

+ func (zSock *ZeroSocketConnect) AcceptTime() int64

+ func (zSock *ZeroSocketConnect) HeartbeatTime() int64

Feb 20, 2024

Changes in this version

+ func XhttpZeroQueryOperation(xRequest *structs.ZeroRequest, tableName string) (*processors.ZeroQueryOperation, *processors.ZeroQuery, error)

Jan 23, 2024

Changes in this version

+ type TCPClient struct

+ func NewTCPClient(address string, authWaitSeconds int64, heartbeatSeconds int64, ...) *TCPClient

+ func (client *TCPClient) Active() bool

+ func (client *TCPClient) AddChecker(checker ZeroDataChecker)

+ func (client *TCPClient) AddListener(xListener ZeroClientListener)

+ func (client *TCPClient) CheckPackageData(data []byte) []byte

+ func (client *TCPClient) Close() error

+ func (client *TCPClient) Connect() error

+ func (client *TCPClient) Heartbeat()

+ func (client *TCPClient) HeartbeatCheck(heartbeatSeconds int64) bool

+ func (client *TCPClient) OnMessage(datas []byte) error

+ func (client *TCPClient) RemoteAddr() string

+ func (client *TCPClient) This() interface{}

+ func (client *TCPClient) Write(datas []byte) error

+ type ZeroClientConnect interface

+ Active func() bool

+ AddChecker func(ZeroDataChecker)

+ AddListener func(ZeroClientListener)

+ CheckPackageData func([]byte) []byte

+ Close func() error

+ Connect func() error

+ Heartbeat func()

+ HeartbeatCheck func(int64) bool

+ OnMessage func([]byte) error

+ RemoteAddr func() string

+ Write func([]byte) error

+ type ZeroClientListener interface

+ OnConnect func(ZeroClientConnect) error

+ OnHeartbeat func(ZeroClientConnect) error

Jan 18, 2024

Changes in this version

+ func XhttpZeroQuery(xRequest *structs.ZeroRequest) (*processors.ZeroQuery, error)

Jan 18, 2024

Changes in this version

+ func XhttpZeroRequest(req *http.Request) (*structs.ZeroRequest, error)

Dec 27, 2023

Changes in this version

type ZeroConnect

+ AddChecker func(ZeroDataChecker)

type ZeroSocketConnect

+ func (zSock *ZeroSocketConnect) AddChecker(checker ZeroDataChecker)

Dec 25, 2023

Changes in this version

type ZeroSocketConnect

+ func (zSock *ZeroSocketConnect) This() interface{}

Dec 22, 2023

Changes in this version

type ZeroServ

+ UseConnect func(string) (ZeroConnect, error)

type ZeroSocketServer

+ func (sockServer *ZeroSocketServer) UseConnect(registerId string) (ZeroConnect, error)

Dec 22, 2023

Changes in this version

type ZeroSocketServer

+ ConnectBuilder ZeroConnectBuilder

Dec 22, 2023

Changes in this version

+ const CONNACK

+ const CONNECT

+ const CONNECT_VARIABLE_HEADER_LEN

+ const DISCONNECT

+ const LESS_LENGTH_LIMIT1

+ const LESS_LENGTH_LIMIT2

+ const LESS_LENGTH_LIMIT3

+ const LESS_LENGTH_LIMIT4

+ const MQTT_HEADER

+ const MQTT_LEVEL_3_1_1

+ const PINGREQ

+ const PINGRESP

+ const PUBACK

+ const PUBCOMP

+ const PUBLISH

+ const PUBREC

+ const PUBREL

+ const SUBACK

+ const SUBSCRIBE

+ const UNSUBACK

+ const UNSUBSCRIBE

+ type IPCServer struct

+ func NewIPCServer(ipcsock string, heartbeatSeconds int64, heartbeatCheckInterval int64, ...) *IPCServer

+ func (ipcserv *IPCServer) RunServer()

+ type MqttConnackVariableHeader struct

+ func (connackHeader *MqttConnackVariableHeader) ReturnCode() byte

+ func (connackHeader *MqttConnackVariableHeader) SessionPresent() byte

+ type MqttConnect struct

+ func (mqttconn *MqttConnect) Accept(zserv ZeroServ, connect net.Conn) error

+ func (mqttconn *MqttConnect) Close() error

+ func (mqttconn *MqttConnect) OnMessage(datas []byte) error

+ func (mqttconn *MqttConnect) RegisterId() string

+ type MqttConnectVariableHeader struct

+ func (connectHeader *MqttConnectVariableHeader) CleanSession() byte

+ func (connectHeader *MqttConnectVariableHeader) KeepAlive() int

+ func (connectHeader *MqttConnectVariableHeader) Level() byte

+ func (connectHeader *MqttConnectVariableHeader) PasswordFlag() byte

+ func (connectHeader *MqttConnectVariableHeader) Protocol() string

+ func (connectHeader *MqttConnectVariableHeader) ProtocolLength() int

+ func (connectHeader *MqttConnectVariableHeader) Reserved() byte

+ func (connectHeader *MqttConnectVariableHeader) UserNameFlag() byte

+ func (connectHeader *MqttConnectVariableHeader) WillFlag() byte

+ func (connectHeader *MqttConnectVariableHeader) WillQos() byte

+ func (connectHeader *MqttConnectVariableHeader) WillRetain() byte

+ type MqttCorePayload interface

+ Payload func() []byte

+ type MqttCoreVariableHeader interface

+ VariableHeader func() []byte

+ type MqttFixedHeader struct

+ func (fixedHeader *MqttFixedHeader) B0() byte

+ func (fixedHeader *MqttFixedHeader) B1() byte

+ func (fixedHeader *MqttFixedHeader) B2() byte

+ func (fixedHeader *MqttFixedHeader) B3() byte

+ func (fixedHeader *MqttFixedHeader) BTvarL(bytes []byte) int

+ func (fixedHeader *MqttFixedHeader) LessLength() int

+ func (fixedHeader *MqttFixedHeader) MessageType() byte

+ func (fixedHeader *MqttFixedHeader) MessageTypeString() string

+ type MqttIdentifierVariableHeader struct

+ func (identifierHeader *MqttIdentifierVariableHeader) Identifier() uint16

+ type MqttMessage struct

+ func (message *MqttMessage) Bytes() []byte

+ func (message *MqttMessage) FixedHeader() *MqttFixedHeader

+ func (message *MqttMessage) MakeConnackMessage()

+ func (message *MqttMessage) MakePingrespMessage()

+ func (message *MqttMessage) MakePubackMessage(identifier uint16)

+ func (message *MqttMessage) MakePublistMessage(topic string, identifier uint16, data []byte)

+ func (message *MqttMessage) MakePubrelMessage(identifier uint16)

+ func (message *MqttMessage) MakeSubackMessage(identifier uint16, results []byte)

+ func (message *MqttMessage) Payload() MqttCorePayload

+ func (message *MqttMessage) VariableHeader() MqttCoreVariableHeader

+ type MqttMessageProcessor interface

+ Publish func(*MqttMessage) error

+ type MqttParamsPayload struct

+ func (connectPayload *MqttParamsPayload) Params() []string

+ type MqttPayload struct

+ func (payload *MqttPayload) Payload() []byte

+ type MqttPublishVariableHeader struct

+ func (publishVariableHeader *MqttPublishVariableHeader) Identifier() uint16

+ func (publishVariableHeader *MqttPublishVariableHeader) Topic() string

+ type MqttServer struct

+ func NewMqttServer(address string, heartbeatSeconds int64, heartbeatCheckInterval int64, ...) *MqttServer

+ func (mqttserv *MqttServer) RunServer()

+ type MqttSubscribePayload struct

+ func (subscribePayload *MqttSubscribePayload) Topics() []*MqttTopic

+ type MqttTopic struct

+ Qos byte

+ TopicName string

+ type MqttVariableHeader struct

+ func (variableHeader *MqttVariableHeader) VariableHeader() []byte

+ type TCPServer struct

+ func NewTCPServer(address string, heartbeatSeconds int64, heartbeatCheckInterval int64, ...) *TCPServer

+ func (tcpserv *TCPServer) RunServer()

+ type UDPMessageProcesser interface

+ OnMessage func([]byte) error

+ type UDPServer struct

+ func NewUDPServer(port int, bufferSize int, checker ZeroDataChecker, ...) *UDPServer

+ func (udpserv *UDPServer) RunServer()

+ func (udpserv *UDPServer) Write(datas []byte, addr *net.UDPAddr) error

+ type ZeroConnect interface

+ Accept func(ZeroServ, net.Conn) error

+ Active func() bool

+ Authorized func(authMessage ...byte) bool

+ CheckPackageData func(data []byte) []byte

+ Close func() error

+ ConnectId func() string

+ Heartbeat func()

+ HeartbeatCheck func(heartbeatSeconds int64) bool

+ OnMessage func(datas []byte) error

+ RegisterId func() string

+ RemoteAddr func() string

+ Write func([]byte) error

+ type ZeroConnectBuilder interface

+ NewConnect func() ZeroConnect

+ type ZeroDataChecker interface

+ CheckPackageData func(data []byte) []byte

+ type ZeroServ interface

+ OnAuthorized func(ZeroConnect) error

+ OnConnect func(ZeroConnect) error

+ OnDisconnect func(ZeroConnect) error

+ type ZeroSocketConnect struct

+ func (zSock *ZeroSocketConnect) Accept(zserv ZeroServ, connect net.Conn) error

+ func (zSock *ZeroSocketConnect) Active() bool

+ func (zSock *ZeroSocketConnect) Authorized(authMessage ...byte) bool

+ func (zSock *ZeroSocketConnect) CheckPackageData(data []byte) []byte

+ func (zSock *ZeroSocketConnect) Close() error

+ func (zSock *ZeroSocketConnect) ConnectId() string

+ func (zSock *ZeroSocketConnect) Heartbeat()

+ func (zSock *ZeroSocketConnect) HeartbeatCheck(heartbeatSeconds int64) bool

+ func (zSock *ZeroSocketConnect) OnMessage(datas []byte) error

+ func (zSock *ZeroSocketConnect) RegisterId() string

+ func (zSock *ZeroSocketConnect) RemoteAddr() string

+ func (zSock *ZeroSocketConnect) Write(datas []byte) error

+ type ZeroSocketServer struct

+ func (sockServer *ZeroSocketServer) OnAuthorized(conn ZeroConnect) error

+ func (sockServer *ZeroSocketServer) OnConnect(conn ZeroConnect) error

+ func (sockServer *ZeroSocketServer) OnDisconnect(conn ZeroConnect) error

+ func (sockServer *ZeroSocketServer) RunServer()

Nov 29, 2023

Changes in this version

+ func XhttpResponseDatas(writer http.ResponseWriter, code int, message string, datas []interface{}, ...)

+ func XhttpResponseMaps(writer http.ResponseWriter, code int, message string, ...)

+ func XhttpResponseMessages(writer http.ResponseWriter, code int, message string)

Nov 29, 2023

Changes in this version

+ type XhttpExecutor struct

+ func XhttpFuncHandle(funcx func(http.ResponseWriter, *http.Request), path ...string) *XhttpExecutor

+ func XhttpHandle(handler http.Handler, path ...string) *XhttpExecutor

Nov 27, 2023

Changes in this version

+ func HttpHandler(funcx func(http.ResponseWriter, *http.Request), path ...string) *xHttpHandler

+ func RunHttpServer(handlers ...*xHttpHandler)