wsserver

Documentation

Index

• Variables
• func StartEPollServer(ctx context.Context, g *errgroup.Group, listenAddr string, poolSize int, ...)
• func StartSimpleServer(ctx context.Context, g *errgroup.Group, listenAddr string, ...)
• type Pool
  • func NewPool(size int) *Pool
  • func (p *Pool) Schedule(task func())
  • func (p *Pool) ScheduleTimeout(timeout time.Duration, task func()) error
• type Session
• type SessionRegistrar

Variables

var ErrScheduleTimeout = fmt.Errorf("schedule error: timed out")

Functions

func StartEPollServer

func StartEPollServer(ctx context.Context, g *errgroup.Group, listenAddr string, poolSize int, registrar SessionRegistrar)

func StartSimpleServer

func StartSimpleServer(ctx context.Context, g *errgroup.Group, listenAddr string, registrar SessionRegistrar)

Types

type Pool

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

func NewPool

func NewPool(size int) *Pool

func (*Pool) Schedule

func (p *Pool) Schedule(task func())

func (*Pool) ScheduleTimeout

func (p *Pool) ScheduleTimeout(timeout time.Duration, task func()) error

type Session

type Session interface {
	Context() context.Context
	Close(err error)
	Write(msg proto.Message) error
	OnRead(f func(msg proto.Message) error)
}

type SessionRegistrar

type SessionRegistrar func(session Session)