socketer

Documentation

Index

• Variables
• type Client
• type Config
• type Ws
  • func New(config ...Config) Ws

Variables

var (
	ErrorInvalidClient = errors.New("invalid client")
)

Types

type Client

type Client interface {
	Write(bytes []byte) error

	MustWrite(bytes []byte)
}

type Config

type Config struct {
	ReadLimit  int64
	WriteLimit int64

	ReadBufferSize  int
	WriteBufferSize int
}

type Ws

type Ws interface {
	Broadcast(bytes []byte)
	Find(id ...string) ([]Client, error)
	FindOne(id string) (Client, error)
	Upgrade(req *http.Request, res http.ResponseWriter, id string) error
	OnRead(fn func(bytes []byte)) Ws

	MustFind(id ...string) []Client
	MustFindOne(id string) Client
	MustUpgrade(req *http.Request, res http.ResponseWriter, id string)
}

func New

func New(config ...Config) Ws