wspool

README

wsPool

Like ConnPool but for websockets

Documentation

Index

• type Logger
• type NewConnectionFunc
• type Pool
  • func (p *Pool) Do(ctx context.Context, work Work) error
• type Work

Types

type Logger

type Logger interface {
	Debugf(format string, a ...interface{})
	Infof(format string, a ...interface{})
	Warnf(format string, a ...interface{})
	Errorf(format string, a ...interface{})
}

type NewConnectionFunc

type NewConnectionFunc func(context.Context) (*websocket.Conn, error)

type Pool

type Pool struct {
	NewConnection NewConnectionFunc
	TTL           time.Duration
	Delay         time.Duration
	Logger        Logger
	// contains filtered or unexported fields
}

func (*Pool) Do

func (p *Pool) Do(ctx context.Context, work Work) error

type Work

type Work func(*websocket.Conn) error