socketify

Dec 17, 2022

Changes in this version

type Server

+ func (s *Server) UpgradeRequests() chan *UpgradeRequest

+ type UpgradeRequest struct

+ func (u *UpgradeRequest) Request() *http.Request

+ func (u *UpgradeRequest) SetAttribute(key string, val interface{}) *UpgradeRequest

+ func (u *UpgradeRequest) SetClientID(clientID string) *UpgradeRequest

+ func (u *UpgradeRequest) Upgrade() (*Connection, error)

+ func (u *UpgradeRequest) WriteResponse(statusCode int, header http.Header, response []byte) (int, error)

Dec 16, 2022

Changes in this version

+ type UpdateError struct

+ Error error

+ Extra []string

+ Update []byte

Dec 15, 2022

Changes in this version

+ const EncryptionTypeRsaAes

+ func DataMapper(handler func(T) error) dataMapper[T]

+ type EmptyInput struct

type Update

+ Extra string

Nov 16, 2022

Changes in this version

type Client

+ func (c *Client) NextWriterCloseMessage() (r io.Writer, err error)

Nov 16, 2022

Changes in this version

type Connection

+ func (c *Connection) NextWriterBinary() (r io.Writer, err error)

+ func (c *Connection) NextWriterCloseMessage() (r io.Writer, err error)

+ func (c *Connection) NextWriterText() (r io.Writer, err error)

type Server

+ func (s *Server) Connections() chan *Connection

Nov 15, 2022

Changes in this version

type Client

+ func (c *Client) NextWriterBinary() (r io.Writer, err error)

+ func (c *Client) NextWriterText() (r io.Writer, err error)

Nov 9, 2022

Changes in this version

type Connection

+ func (c *Connection) NextReader() (messageType int, r io.Reader, err error)

Nov 9, 2022

Changes in this version

type Client

+ func (c *Client) NextReader() (messageType int, r io.Reader, err error)

Oct 31, 2022

Changes in this version

type Client

+ func (c *Client) SetRawMiddleware(fn func(message []byte)) *Client

Oct 29, 2022

Changes in this version

+ func ServerOptions() *options

type Client

+ func NewClient(address string) *Client

+ func (c *Client) Connect() error

+ func (c *Client) SetOnError(fn func(err error)) *Client

+ func (c *Client) SetRawHandler(fn func(message []byte)) *Client

+ func (c *Client) SetUpdateTypeHandler(updateType string, fn func(message json.RawMessage)) *Client

type Server

+ func NewServer(opts *options) (s *Server)

Sep 28, 2022

Changes in this version

type Client

+ func (c *Client) Errors() chan<- error

Oct 29, 2022

Changes in this version

+ type Connection struct

+ func (c *Connection) Close() error

+ func (c *Connection) Errors() <-chan error

+ func (c *Connection) GetAttribute(key string) (val string, exists bool)

+ func (c *Connection) HandleRawUpdate(handler func(message []byte))

+ func (c *Connection) HandleUpdate(updateType string, handler func(message json.RawMessage))

+ func (c *Connection) ID() string

+ func (c *Connection) InternalUpdates() <-chan []byte

+ func (c *Connection) ProcessUpdates() error

+ func (c *Connection) Server() *Server

+ func (c *Connection) SetAttribute(key, val string)

+ func (c *Connection) SetKeepAliveDuration(keepAlive time.Duration)

+ func (c *Connection) SetMiddleware(middleware func(message []byte) error)

+ func (c *Connection) SetOnClose(onClose func())

+ func (c *Connection) SetUpdateTypeMiddleware(middleware func(updateType string, data json.RawMessage) error)

+ func (c *Connection) UpgradeRequest() *http.Request

+ func (c *Connection) WriteBinaryBytes(data []byte) (err error)

+ func (c *Connection) WriteBinaryText(data []byte) (err error)

+ func (c *Connection) WriteInternalUpdate(update []byte)

+ func (c *Connection) WriteRawUpdate(data interface{}) (err error)

+ func (c *Connection) WriteText(data string) (err error)

+ func (c *Connection) WriteUpdate(updateType string, data interface{}) (err error)

+ type Server struct

+ func (s *Server) Clients() chan *Connection

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

+ func (s *Server) Server() (server *http.Server)

+ func (s *Server) Storage() *storage

Jul 13, 2022

Changes in this version

type Client

+ func (c *Client) WriteInternalUpdate(update []byte)

Jul 13, 2022

Changes in this version

type Client

+ func (c *Client) WriteBinaryText(data []byte) (err error)

Jul 13, 2022

Changes in this version

type Client

+ func (c *Client) InternalUpdates() <-chan []byte

Jun 21, 2022

Changes in this version

type Client

+ func (c *Client) WriteBinaryBytes(data []byte) (err error)

+ func (c *Client) WriteText(data string) (err error)

Jun 17, 2022

Changes in this version

type Client

+ func (c *Client) SetUpdateTypeMiddleware(middleware func(updateType string) error)

Jun 17, 2022

Changes in this version

type Client

+ func (c *Client) SetMiddleware(middleware func() error)

Jun 17, 2022

Changes in this version

type Client

+ func (c *Client) SetKeepAliveDuration(keepAlive time.Duration)

Jun 15, 2022

Changes in this version

type Client

+ func (c *Client) SetOnClose(onClose func())

May 16, 2022

Changes in this version

type Client

+ func (c *Client) GetAttribute(key string) (val string, exists bool)

+ func (c *Client) SetAttribute(key, val string)

Feb 10, 2022

Changes in this version

type Client

+ func (c *Client) Close() error

+ func (c *Client) WriteRawUpdate(data interface{})

Feb 9, 2022

Changes in this version

type Client

+ func (c *Client) HandleRawUpdate(handler func(message json.RawMessage))

Feb 9, 2022

Changes in this version

type Client

+ func (c *Client) UpgradeRequest() *http.Request

Jan 16, 2022

Changes in this version

+ func Options() *options

+ type Client struct

+ func (c *Client) CloseChannel() chan bool

+ func (c *Client) HandleUpdate(updateType string, handler func(message json.RawMessage))

+ func (c *Client) ID() string

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

+ func (c *Client) Server() *Socketify

+ func (c *Client) Updates() chan *Update

+ func (c *Client) WriteUpdate(updateType string, data interface{})

+ type Logger interface

+ Error func(args ...interface{})

+ type Socketify struct

+ func New(opts *options) (s *Socketify)

+ func (s *Socketify) Clients() chan *Client

+ func (s *Socketify) Listen() (err error)

+ func (s *Socketify) Server() (server *http.Server)

+ func (s *Socketify) Storage() *storage

+ type Update struct

+ Data json.RawMessage

+ Type string