socket

Jun 18, 2022

Changes in this version

+ type ClientUpdateHandler func(out *Output)

May 2, 2022

Changes in this version

type Output

+ func (o Output) GetError() (err error)

Apr 30, 2022

Changes in this version

+ const ClientRetry

+ const ErrorPrefix

+ const ErrorRcpt

+ const ResponsePrefix

+ const ResponseTxt

+ const UpdatePrefix

+ const UpdateTxt

+ func MakeRequest(c *Client, method, channel string, data any, timeout ...time.Duration) (value T, err error)

+ type BaseData struct

+ Data []byte

+ func (b *BaseData) ParseData(v any) error

+ func (b *BaseData) SetData(v any) (err error)

+ type Client struct

+ func NewClient(opts ClientOptions) *Client

+ func (c *Client) Auth(subs ...ClientAuthSubscriber)

+ func (c *Client) EnsureStarted() (err error)

+ func (c *Client) On(method, channel string, handler ClientUpdateHander)

+ func (c *Client) Start()

+ func (c *Client) Stop() (err error)

+ func (c *Client) Update(subs ...ClientUpdateSubscriber)

+ type ClientAuthSubscriber func(ref *ClientRef) (err error)

+ type ClientOptions struct

+ Alias string

+ Name string

+ ServerHost string

+ ServerPort string

+ TlsConfig *tls.Config

+ type ClientRef struct

+ func (c *ClientRef) ReadBytes(delim byte) ([]byte, error)

+ func (c *ClientRef) ReadString(delim byte) (string, error)

+ func (c *ClientRef) Write(b []byte) (int, error)

+ func (c *ClientRef) WriteString(d string) (int, error)

+ func (c *ClientRef) WriteStringln(d string) (int, error)

+ func (c *ClientRef) Writeln(b []byte) (int, error)

+ type ClientResponseCollection struct

+ func (c *ClientResponseCollection) Get(req *Request, timeout ...time.Duration) (out *Output, err error)

+ func (c *ClientResponseCollection) Set(uuid string, out *Output) (err error)

+ type ClientUpdateHander func(out *Output)

+ type ClientUpdateHandlerCollection struct

+ func (c *ClientUpdateHandlerCollection) On(method, channel string, handler ClientUpdateHander)

+ type ClientUpdateSubscriber func(collection *ClientUpdateHandlerCollection) (err error)

+ type Context struct

+ func (c *Context) Error(v any, code ...int) *Output

+ func (c *Context) ParseData(v any) error

+ func (c *Context) Success(v any) *Output

+ func (c *Context) Update(args ...any) error

+ func (c *Context) UpdateAll(args ...any)

+ type Options interface

+ type Output struct

+ Channel string

+ Code int

+ Method string

+ type Request struct

+ Channel string

+ Method string

+ UUID string

+ type Server struct

+ func NewServer(opts ServerOptions) *Server

+ func (s *Server) Auth(subs ...ServerAuthSubscriber)

+ func (s *Server) Boot(subs ...ServerBootSubscriber)

+ func (s *Server) Cleanup(subs ...ServerCleanupSubscriber)

+ func (s *Server) ClientInit(handlers ...ServerClientInitHandler)

+ func (s *Server) EnsureListening() (err error)

+ func (s *Server) Handlers(subs ...ServerHandlerSubscriber)

+ func (s *Server) IsListening() bool

+ func (s *Server) Listen()

+ func (s *Server) Setup(subs ...ServerSetupSubscriber)

+ func (s *Server) Stop() error

+ func (s *Server) UpdateAll(args ...any)

+ type ServerAuthSubscriber func(ref *ServerClientRef) (err error)

+ type ServerBootSubscriber func() (err error)

+ type ServerCleanupSubscriber func(ref *ServerClientRef) (err error)

+ type ServerClientInitHandler func(updater *ServerClientUpdater) (err error)

+ type ServerClientInstance struct

+ func (s *ServerClientInstance) Start()

+ func (s *ServerClientInstance) Stop()

+ func (s *ServerClientInstance) Update(args ...any) (err error)

+ type ServerClientRef struct

+ func (s *ServerClientRef) ReadBytes(delim byte) ([]byte, error)

+ func (s *ServerClientRef) ReadString(delim byte) (string, error)

+ func (s *ServerClientRef) Write(b []byte) (int, error)

+ func (s *ServerClientRef) WriteString(d string) (int, error)

+ func (s *ServerClientRef) WriteStringln(d string) (int, error)

+ func (s *ServerClientRef) Writeln(b []byte) (int, error)

+ type ServerClientUpdater struct

+ func (s *ServerClientUpdater) Update(args ...any) (err error)

+ type ServerHandler func(ctx *Context) *Output

+ type ServerHandlerCollection struct

+ func (s *ServerHandlerCollection) Get(method, channel string) (handler ServerHandler, err error)

+ func (s *ServerHandlerCollection) Has(method, channel string) bool

+ func (s *ServerHandlerCollection) Off(method, channel string)

+ func (s *ServerHandlerCollection) On(method, channel string, handler ServerHandler) (err error)

+ type ServerHandlerSubscriber func(subscriber *ServerHandlerCollection) (err error)

+ type ServerOptions struct

+ Alias string

+ Host string

+ Name string

+ Port string

+ TlsConfig *tls.Config

+ type ServerSetupSubscriber func(ref *ServerClientRef) (err error)