handler

Documentation

Index

• func NewHandler(ctx context.Context, router string, mh clientHandler, removeChan chan<- int64) *handler
• type Interface
• type MessageHandler

Functions

func NewHandler

func NewHandler(ctx context.Context, router string, mh clientHandler, removeChan chan<- int64) *handler

Types

type Interface

type Interface interface {
	RegisterId(id int64)
	Id() int64
	RegisterRemoveChan(ch chan<- int64)
	RegisterConnWriteChan(ch chan<- []byte)
	RegisterConnClose(do func())
	RegisterConnPing(do func())
	Ping()
	Handler(data []byte) (res []byte, err error)
	Run()
	Close()
}

type MessageHandler

type MessageHandler interface {
	Read() <-chan []byte
	Write(in []byte) error
}