Versions in this module Expand all Collapse all v1 v1.4.0 Jul 27, 2024 v1.3.1 Jul 25, 2024 v1.3.0 Jul 25, 2024 Changes in this version type Options + SocketFileMode os.FileMode v1.2.0 Jul 25, 2024 Changes in this version type Options + Socket string v1.1.0 Jul 20, 2024 Changes in this version + func MakeRequest[T any](client *Client, method, channel string, data any) (value T, err error) + type AuthCallback func(conn Connection) (err error) + type BootCallback func() (err error) + type ChannelData struct + Channel string + Method string + type Client struct + func (x *Client) Auth(callbacks ...AuthCallback) + func (x *Client) Boot(callbacks ...BootCallback) + func (x *Client) Connect(opts *Options) (errChan chan error) + func (x *Client) On(method, channel string, handler UpdateHandler) + func (x *Client) Request(method, channel string, data any) (value Data, err error) + func (x *Client) Run() (err error) + func (x *Client) SetRequestTimeout(timeout int) + func (x *Client) Start(opts *Options) chan error + func (x *Client) Stop() (err error) + func (x *Client) Updates(callbacks ...UpdateRouterCallback) + type ClientInitCallback func(i InboundConnection) (err error) + type ClientUpdateRouter struct + func (x *ClientUpdateRouter) Clear(method, channel string) + func (x *ClientUpdateRouter) On(method, channel string, handler UpdateHandler) + func (x *ClientUpdateRouter) Send(method, channel string, data Data) + type Conn struct + func (x *Conn) Close() error + func (x *Conn) Read(p []byte) (n int, err error) + func (x *Conn) ReadBytes(delim byte) (b []byte, err error) + func (x *Conn) ReadLine() (b []byte, err error) + func (x *Conn) ReadString(delim byte) (s string, err error) + func (x *Conn) ReadStringLine() (s string, err error) + func (x *Conn) Write(p []byte) (n int, err error) + func (x *Conn) WriteLine(p []byte) (n int, err error) + func (x *Conn) WriteString(s string) (n int, err error) + func (x *Conn) WriteStringLine(s string) (n int, err error) + type Connection interface + ReadBytes func(delim byte) (b []byte, err error) + ReadLine func() (b []byte, err error) + ReadString func(delim byte) (s string, err error) + ReadStringLine func() (s string, err error) + Write func(p []byte) (n int, err error) + WriteLine func(p []byte) (n int, err error) + WriteString func(s string) (n int, err error) + WriteStringLine func(s string) (n int, err error) + type Context struct + func (x *Context) Data(v any, code ...int) Output + func (x *Context) Error(v any, code ...int) Output + func (x *Context) Update(v any, code ...int) (err error) + func (x *Context) UpdateAll(v any, code ...int) (err error) + func (x Context) Bind(v any) (err error) + type Data struct + Code int + Content []byte + func (x *Data) SetContent(v any) (err error) + func (x Data) Bind(v any) (err error) + func (x Data) GetCode() int + func (x Data) GetContent() any + func (x Data) IsError() bool + type Error struct + Code int + Message string + UUID string + func (x Error) Error() (err error) + func (x Error) GetCode() int + func (x Error) GetContent() any + func (x Error) ToData() (data Data) + type Inbound struct + func (x *Inbound) Run() + func (x *Inbound) Update(method, channel string, v any, code ...int) (err error) + func (x *Inbound) UpdateAll(method, channel string, v any, code ...int) (err error) + type InboundConnection interface + Update func(method, channel string, v any, code ...int) (err error) + type InboundPredicate func(i *Inbound) (err error) + type Info struct + Description string + Name string + UUID string + func (x *Info) GenerateUUID() + type Options struct + Host string + Network string + Port any + SocketPath string + type Output interface + GetCode func() int + GetContent func() any + type OutputData interface + Bind func(v any) (err error) + GetCode func() int + type Request struct + Content []byte + UUID string + func (x *Request) SetContent(v any) (err error) + func (x Request) Bind(v any) (err error) + type RequestHander func(ctx *Context) Output + type RequestRouter interface + Set func(method, channel string, handler RequestHander) + type RequestRouterCallback func(router RequestRouter) + type Response struct + Request Request + UUID string + type Server struct + func (x *Server) Auth(callbacks ...AuthCallback) + func (x *Server) Boot(callbacks ...BootCallback) + func (x *Server) Connect(opts *Options) (errChan chan error) + func (x *Server) Listen(opts *Options) (err error) + func (x *Server) OnClientInit(callbacks ...ClientInitCallback) + func (x *Server) Routes(callbacks ...RequestRouterCallback) + func (x *Server) Run() (err error) + func (x *Server) Stop() (err error) + type ServerRequestRouter struct + func (x *ServerRequestRouter) Delete(method, channel string) + func (x *ServerRequestRouter) Get(method, channel string) (handler RequestHander, ok bool) + func (x *ServerRequestRouter) Set(method, channel string, handler RequestHander) + type Update struct + Code int + Content []byte + func (x *Update) SetContent(v any) (err error) + func (x Update) Bind(v any) (err error) + func (x Update) Data() Data + type UpdateHandler func(data OutputData) + type UpdateRouter interface + On func(method, channel string, handler UpdateHandler) + type UpdateRouterCallback func(router UpdateRouter)
Go to main page