server

Documentation

Index

• func ListenAndServe(addr string, url string, auth string) error
• func NewRedisPool() *redis.Pool
• func Serve(hub *Hub, w http.ResponseWriter, r *http.Request)
• type Hub
  • func NewHub(url string, auth string) *Hub
  • func (h *Hub) Auth() string
  • func (h *Hub) Run()
• type Redis
  • func NewRedis(hub *Hub) *Redis
  • func (r *Redis) Delete(ctx context.Context, k string) error
  • func (r *Redis) Expire(ctx context.Context, k string, dt time.Duration) error
  • func (r *Redis) Get(ctx context.Context, k string) (string, error)
  • func (r *Redis) Increment(ctx context.Context, k string) (int64, error)
  • func (r *Redis) Set(ctx context.Context, k string, v string) error
  • func (r *Redis) Subscribe() error

Functions

func ListenAndServe

func ListenAndServe(addr string, url string, auth string) error

ListenAndServe starts the server.

func NewRedisPool

func NewRedisPool() *redis.Pool

NewRedisPool from env.

func Serve

func Serve(hub *Hub, w http.ResponseWriter, r *http.Request)

Serve handles websocket requests from the peer.

Types

type Hub

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

Hub maintains the set of active clients and broadcasts messages to the clients.

func NewHub

func NewHub(url string, auth string) *Hub

NewHub ...

func (*Hub) Auth

func (h *Hub) Auth() string

func (*Hub) Run

func (h *Hub) Run()

Run hub.

type Redis

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

Redis ...

func NewRedis

func NewRedis(hub *Hub) *Redis

NewRedis ...

func (*Redis) Delete

func (r *Redis) Delete(ctx context.Context, k string) error

Delete value.

func (*Redis) Expire

func (r *Redis) Expire(ctx context.Context, k string, dt time.Duration) error

Expire value.

func (*Redis) Get

func (r *Redis) Get(ctx context.Context, k string) (string, error)

Get value.

func (*Redis) Increment

func (r *Redis) Increment(ctx context.Context, k string) (int64, error)

Increment value.

func (*Redis) Set

func (r *Redis) Set(ctx context.Context, k string, v string) error

Set value.

func (*Redis) Subscribe

func (r *Redis) Subscribe() error

Subscribe ...