neffos

May 18, 2020

Changes in this version

type Server

+ FireDisconnectAlways bool

Dec 10, 2019

Changes in this version

type NSConn

+ func (ns *NSConn) EmitBinary(event string, body []byte) bool

Dec 10, 2019

Changes in this version

+ const BinaryMessage

+ const TextMessage

+ type MessageType uint8

Aug 10, 2019

Changes in this version

type Server

+ SyncBroadcaster bool

Jul 17, 2019

Changes in this version

type Conn

+ func (c *Conn) Decrement(key string) int

+ func (c *Conn) Increment(key string) int

type Events

+ func (e Events) On(eventName string, msgHandler MessageHandlerFunc)

type Namespaces

+ func (nss Namespaces) On(namespace, eventName string, msgHandler MessageHandlerFunc) Events

Jul 14, 2019

Changes in this version

type Conn

+ func (c *Conn) Get(key string) interface{}

+ func (c *Conn) Set(key string, value interface{})

type Message

+ func DeserializeMessage(decrypt MessageDecrypt, b []byte, ...) Message

+ func (m *Message) ClearWait() bool

+ func (m *Message) IsWait(isClientConn bool) bool

type Server

+ func (s *Server) Ask(ctx context.Context, msg Message) (Message, error)

+ func (s *Server) UseStackExchange(exc StackExchange) error

type StackExchange

+ Ask func(ctx context.Context, msg Message, token string) (Message, error)

+ NotifyAsk func(msg Message, token string) error

+ type StackExchangeInitializer interface

+ Init func(Namespaces) error

Jul 11, 2019

Changes in this version

+ func DebugEach(mapOrSlice interface{}, onDebugVisitor interface{})

+ func Debugf(format string, args ...interface{})

type Conn

+ func (c *Conn) DeserializeMessage(payload []byte) Message

+ func (c *Conn) HandlePayload(payload []byte) error

+ func (c *Conn) Is(connID string) bool

type Message

+ FromExplicit string

+ FromStackExchange bool

+ func (m Message) Serialize() []byte

type Server

+ StackExchange StackExchange

+ type StackExchange interface

+ OnConnect func(c *Conn) error

+ OnDisconnect func(c *Conn)

+ Publish func(msg Message) bool

+ Subscribe func(c *Conn, namespace string)

+ Unsubscribe func(c *Conn, namespace string)

Jul 9, 2019

Changes in this version

type ConnHandler

+ GetNamespaces func() Namespaces

type Events

+ func (e Events) GetNamespaces() Namespaces

type Namespaces

+ func (nss Namespaces) GetNamespaces() Namespaces

type Struct

+ func (s *Struct) GetNamespaces() Namespaces

+ func (s *Struct) SetInjector(fn StructInjector) *Struct

+ type StructInjector func(structType reflect.Type, nsConn *NSConn) (structValue reflect.Value)

type WithTimeout

+ func (t WithTimeout) GetNamespaces() Namespaces

Jul 7, 2019

Changes in this version

+ func EnableDebug(printer interface{})

type NSConn

+ Value atomic.Value

type Struct

+ func (s *Struct) Events() Events

+ func (s *Struct) SetTimeouts(read, write time.Duration) *Struct

Jul 5, 2019

Changes in this version

+ var EventPrefixMatcher = func(prefix string) EventMatcherFunc

+ var EventTrimPrefixMatcher = func(prefixToTrim string) EventMatcherFunc

+ type EventMatcherFunc = func(methodName string) (string, bool)

+ type Struct struct

+ func NewStruct(ptr interface{}) *Struct

+ func (s *Struct) SetEventMatcher(matcher EventMatcherFunc) *Struct

+ func (s *Struct) SetNamespace(namespace string) *Struct

Jun 30, 2019

Changes in this version

+ func IsTryingToReconnect(err error) (ok bool)

+ func RegisterKnownError(err error)

type Conn

+ ReconnectTries int

+ func (c *Conn) WasReconnected() bool

Jun 12, 2019

Changes in this version

+ const URLParamAsHeaderPrefix

+ var DefaultMarshaler = json.Marshal

+ var DefaultUnmarshaler = json.Unmarshal

+ var ErrBadNamespace = errors.New("bad namespace")

+ var ErrBadRoom = errors.New("bad room")

+ var ErrInvalidPayload = errors.New("invalid payload")

+ var ErrWrite = errors.New("write closed")

+ var OnAnyEvent = "_OnAnyEvent"

+ var OnNamespaceConnect = "_OnNamespaceConnect"

+ var OnNamespaceConnected = "_OnNamespaceConnected"

+ var OnNamespaceDisconnect = "_OnNamespaceDisconnect"

+ var OnNativeMessage = "_OnNativeMessage"

+ var OnRoomJoin = "_OnRoomJoin"

+ var OnRoomJoined = "_OnRoomJoined"

+ var OnRoomLeave = "_OnRoomLeave"

+ var OnRoomLeft = "_OnRoomLeft"

+ func Exclude(connID string) fmt.Stringer

+ func IsCloseError(err error) bool

+ func IsDisconnectError(err error) bool

+ func IsSystemEvent(event string) bool

+ func IsTimeoutError(err error) bool

+ func Marshal(v interface{}) []byte

+ func Reply(body []byte) error

+ type Client struct

+ ID string

+ NotifyClose <-chan struct{}

+ func Dial(ctx context.Context, dial Dialer, url string, connHandler ConnHandler) (*Client, error)

+ func (c *Client) Close()

+ func (c *Client) Connect(ctx context.Context, namespace string) (*NSConn, error)

+ func (c *Client) WaitServerConnect(ctx context.Context, namespace string) (*NSConn, error)

+ type CloseError struct

+ Code int

+ func (err CloseError) Error() string

+ type Conn struct

+ func (c *Conn) Ask(ctx context.Context, msg Message) (Message, error)

+ func (c *Conn) Close()

+ func (c *Conn) Connect(ctx context.Context, namespace string) (*NSConn, error)

+ func (c *Conn) DisconnectAll(ctx context.Context) error

+ func (c *Conn) ID() string

+ func (c *Conn) IsClient() bool

+ func (c *Conn) IsClosed() bool

+ func (c *Conn) Namespace(namespace string) *NSConn

+ func (c *Conn) Server() *Server

+ func (c *Conn) Socket() Socket

+ func (c *Conn) String() string

+ func (c *Conn) WaitConnect(ctx context.Context, namespace string) (ns *NSConn, err error)

+ func (c *Conn) Write(msg Message) bool

+ type ConnHandler interface

+ func JoinConnHandlers(connHandlers ...ConnHandler) ConnHandler

+ type Dialer func(ctx context.Context, url string) (Socket, error)

+ type Events map[string]MessageHandlerFunc

+ type IDGenerator func(w http.ResponseWriter, r *http.Request) string

+ var DefaultIDGenerator IDGenerator = func(http.ResponseWriter, *http.Request) string { ... }

+ type Message struct

+ Body []byte

+ Err error

+ Event string

+ IsForced bool

+ IsLocal bool

+ IsNative bool

+ Namespace string

+ Room string

+ SetBinary bool

+ To string

+ func (m *Message) Unmarshal(outPtr interface{}) error

+ type MessageDecrypt func(in []byte) []byte

+ type MessageEncrypt func(out []byte) []byte

+ type MessageHandlerFunc func(*NSConn, Message) error

+ type MessageObjectMarshaler interface

+ Marshal func() ([]byte, error)

+ type MessageObjectUnmarshaler interface

+ Unmarshal func(body []byte) error

+ type NSConn struct

+ Conn *Conn

+ func (ns *NSConn) Ask(ctx context.Context, event string, body []byte) (Message, error)

+ func (ns *NSConn) Disconnect(ctx context.Context) error

+ func (ns *NSConn) Emit(event string, body []byte) bool

+ func (ns *NSConn) JoinRoom(ctx context.Context, roomName string) (*Room, error)

+ func (ns *NSConn) LeaveAll(ctx context.Context) error

+ func (ns *NSConn) Room(roomName string) *Room

+ func (ns *NSConn) Rooms() []*Room

+ func (ns *NSConn) String() string

+ type Namespaces map[string]Events

+ type Room struct

+ NSConn *NSConn

+ Name string

+ func (r *Room) Emit(event string, body []byte) bool

+ func (r *Room) Leave(ctx context.Context) error

+ func (r *Room) String() string

+ type Server struct

+ IDGenerator IDGenerator

+ OnConnect func(c *Conn) error

+ OnDisconnect func(c *Conn)

+ OnUpgradeError func(err error)

+ func New(upgrader Upgrader, connHandler ConnHandler) *Server

+ func (s *Server) Broadcast(exceptSender fmt.Stringer, msg Message)

+ func (s *Server) Close()

+ func (s *Server) Do(fn func(*Conn), async bool)

+ func (s *Server) GetConnections() map[string]*Conn

+ func (s *Server) GetConnectionsByNamespace(namespace string) map[string]*NSConn

+ func (s *Server) GetTotalConnections() uint64

+ func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (s *Server) Upgrade(w http.ResponseWriter, r *http.Request, socketWrapper func(Socket) Socket) (*Conn, error)

+ type Socket interface

+ NetConn func() net.Conn

+ ReadData func(timeout time.Duration) (body []byte, err error)

+ Request func() *http.Request

+ WriteBinary func(body []byte, timeout time.Duration) error

+ WriteText func(body []byte, timeout time.Duration) error

+ type Upgrader func(w http.ResponseWriter, r *http.Request) (Socket, error)

+ type WithTimeout struct

+ Events Events

+ Namespaces Namespaces

+ ReadTimeout time.Duration

+ WriteTimeout time.Duration