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 ...int) ([]Client, error)
	FindOne(id int) (Client, error)
	Serve(req *http.Request, res http.ResponseWriter, id int) error
	OnRead(fn func(bytes []byte)) Ws

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

func New

func New(config ...Config) Ws