gnetws

README

gnetws

Documentation

Index

• Variables
• type Broadcast
  • func NewBroadcast(wrapper Packing, docodec Serialize) *Broadcast
  • func (self *Broadcast) RegisterConn(c gnet.Conn)
  • func (self *Broadcast) SendMessage(x interface{}) (err error)
  • func (self *Broadcast) WriteOffConn(c gnet.Conn)
• type Buffer
  • func (self *Buffer) Read(p []byte) (int, error)
  • func (self *Buffer) Write(b []byte) (int, error)
• type Decode
• type Encode
• type Packing
• type Pool
• type PoolWithFunc
• type Serialize
• type WebSocketWrapper
  • func NewWebSocketWrapper() *WebSocketWrapper
  • func (self *WebSocketWrapper) Flush() error
  • func (self *WebSocketWrapper) SubPackage() []byte
  • func (self *WebSocketWrapper) Write(p []byte) (int, error)

Variables

var (
	// Nonblocking decides what to do when submitting a new task to a full worker pool: waiting for a available worker
	// or returning nil directly.
	Nonblocking = true

	// ExpiryDuration is the interval time to clean up those expired workers.
	ExpiryDuration = 10 * time.Second

	// DefaultAntsPoolSize sets up the capacity of worker pool, 1024 * cpu.
	DefaultAntsPoolSize = (1 << 10) * runtime.NumCPU() * 2
)

var GoroutinePool = func() func() Pool {
	var pool Pool
	once := sync.Once{}
	options := ants.Options{
		Nonblocking:    Nonblocking,
		ExpiryDuration: ExpiryDuration,
	}

	return func() Pool {
		once.Do(func() {
			pool, _ = ants.NewPool(
				DefaultAntsPoolSize, ants.WithOptions(options),
			)
		})
		return pool
	}
}()

Types

type Broadcast

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

func NewBroadcast

func NewBroadcast(wrapper Packing, docodec Serialize) *Broadcast

func (*Broadcast) RegisterConn

func (self *Broadcast) RegisterConn(c gnet.Conn)

func (*Broadcast) SendMessage

func (self *Broadcast) SendMessage(x interface{}) (err error)

func (*Broadcast) WriteOffConn

func (self *Broadcast) WriteOffConn(c gnet.Conn)

type Buffer

type Buffer struct {
	sync.Mutex
	bytes.Buffer
}

func (*Buffer) Read

func (self *Buffer) Read(p []byte) (int, error)

func (*Buffer) Write

func (self *Buffer) Write(b []byte) (int, error)

type Decode

type Decode interface {
	Decode(x interface{}) (err error)
}

type Encode

type Encode interface {
	Encode(x interface{}) (err error)
}

type Packing

type Packing interface {
	io.Writer
	Flush() error
	SubPackage() (p []byte)
}

type Pool

type Pool = *ants.Pool

type PoolWithFunc

type PoolWithFunc = *ants.PoolWithFunc

type Serialize

type Serialize interface {
	NewEnCodec(w io.Writer) Encode
	NewDeCodec(r io.Reader) Decode
}

Serialize 序列化器

type WebSocketWrapper

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

func NewWebSocketWrapper

func NewWebSocketWrapper() *WebSocketWrapper

func (*WebSocketWrapper) Flush

func (self *WebSocketWrapper) Flush() error

func (*WebSocketWrapper) SubPackage

func (self *WebSocketWrapper) SubPackage() []byte

func (*WebSocketWrapper) Write

func (self *WebSocketWrapper) Write(p []byte) (int, error)