Versions in this module Expand all Collapse all v1 v1.0.0 Apr 24, 2023 Changes in this version + const DEFAULT_LOG_ENCODING + const DEFAULT_LOG_LEVEL + type ClientConn interface + Close func() error + GetID func() string + GetKey func() string + GetTopics func() []string + ReadMessage func() (messageType int, p []byte, err error) + SetTopics func([]string) + UpdateKey func(string) error + WriteMessage func(messageType int, data []byte) error + type EmitOpts struct + Rules []EmitRule + type EmitRule struct + AnyOfTopics []string + OnlyKeys []string + type LoggerOpts struct + Encoding string + LogLevel *zapcore.Level + Logger *zap.Logger + type MagicSocket interface + Emit func(opts EmitOpts, message []byte) + GetClients func() map[string]ClientConn + GetPort func() int + SetOnConnect func(onConnectFunc) + Start func() error + Stop func() error + func New(opts MagicSocketOpts) MagicSocket + type MagicSocketOpts struct + GracePeriod time.Duration + LoggerOpts LoggerOpts + OnConnect onConnectFunc + Port int + type RegisterClientOpts struct + Key string + OnDisconnect func() error + OnIncoming func(messageType int, data []byte) error + OnOutgoing func(messageType int, data []byte) error + OnPing func() error + Topics []string