server

Documentation

Overview

Package server is core logic shared by wspc wsps

Index

• func New(config *Config) http.Handler
• func NewWithHandler(config *Config, handler http.Handler) http.Handler
• type Config
  • func (c *Config) EnbleSSL() bool
• type Hub
  • func (s *Hub) Exist(channel string) (exist bool)
  • func (s *Hub) Load(channel string) (interface{}, bool)
  • func (s *Hub) Remove(channel string)
  • func (s *Hub) Store(channel string, r interface{})
• type SSL
• type Wsps
  • func (s *Wsps) ServeHTTP(rw http.ResponseWriter, r *http.Request)
  • func (s *Wsps) ServeProxy(w http.ResponseWriter, r *http.Request)

Functions

func New

func New(config *Config) http.Handler

func NewWithHandler

func NewWithHandler(config *Config, handler http.Handler) http.Handler

Types

type Config

type Config struct {
	Log logger.Config `json:"log,omitempty"`

	SSL  SSL    `json:"ssl,omitempty"`
	Host string `json:"host,omitempty"`
	Auth string `json:"auth,omitempty"`
	Path string `json:"path,omitempty"`
	Port uint64 `json:"port,omitempty"`
}

func (*Config) EnbleSSL

func (c *Config) EnbleSSL() bool

type Hub

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

func (*Hub) Exist

func (s *Hub) Exist(channel string) (exist bool)

func (*Hub) Load

func (s *Hub) Load(channel string) (interface{}, bool)

func (*Hub) Remove

func (s *Hub) Remove(channel string)

func (*Hub) Store

func (s *Hub) Store(channel string, r interface{})

type SSL

type SSL struct {
	Enable bool   `json:"enable,omitempty"`
	Key    string `json:"key,omitempty"`
	Cert   string `json:"cert,omitempty"`
}

type Wsps

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

func (*Wsps) ServeHTTP

func (s *Wsps) ServeHTTP(rw http.ResponseWriter, r *http.Request)

func (*Wsps) ServeProxy

func (s *Wsps) ServeProxy(w http.ResponseWriter, r *http.Request)