node

type AppNode interface {
	HandlePubSub(msg []byte)
}

type Controller interface {
	Shutdown() error
	Authenticate(sid string, env *common.SessionEnv) (*common.ConnectResult, error)
	Subscribe(sid string, env *common.SessionEnv, id string, channel string) (*common.CommandResult, error)
	Unsubscribe(sid string, env *common.SessionEnv, id string, channel string) (*common.CommandResult, error)
	Perform(sid string, env *common.SessionEnv, id string, channel string, data string) (*common.CommandResult, error)
	Disconnect(sid string, env *common.SessionEnv, id string, subscriptions []string) error
}

type DisconnectQueue struct {
	// contains filtered or unexported fields
}

type DisconnectQueueConfig struct {
	// Limit the number of Disconnect RPC calls per second
	Rate int
	// How much time wait to call all enqueued calls at exit (in seconds)
	ShutdownTimeout int
}

type Disconnector interface {
	Run() error
	Shutdown() error
	Enqueue(*Session) error
	Size() int
}

type Hub struct {
	// contains filtered or unexported fields
}

type HubRegistration struct {
	// contains filtered or unexported fields
}

type HubSubscription struct {
	// contains filtered or unexported fields
}

type Node struct {
	Metrics *metrics.Metrics
	// contains filtered or unexported fields
}

type NoopDisconnectQueue struct{}

type Session struct {
	UID         string
	Identifiers string
	Log         *log.Entry
	// contains filtered or unexported fields
}

type WSConfig struct {
	ReadBufferSize    int
	WriteBufferSize   int
	MaxMessageSize    int64
	EnableCompression bool
}