Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrPublicAddr = errors.New("no public address")
)
Functions ¶
This section is empty.
Types ¶
type MatchController ¶
type MatchController struct {
// contains filtered or unexported fields
}
func NewMatchController ¶
func NewMatchController() *MatchController
func (*MatchController) DealRecvConn ¶
func (*MatchController) DealSendConn ¶
func (mc *MatchController) DealSendConn(sc *SendConn, timeout time.Duration) (cacheCount int64, err error)
block until there is a same ID recv conn or timeout
type Worker ¶
type Worker struct {
// contains filtered or unexported fields
}
func (*Worker) DetectPublicAddr ¶
func (*Worker) PublicAddr ¶
func (*Worker) RunKeepAlive ¶
func (w *Worker) RunKeepAlive(closeCallback func())
type WorkerGroup ¶
type WorkerGroup struct {
// contains filtered or unexported fields
}
func NewWorkerGroup ¶
func NewWorkerGroup() *WorkerGroup
func (*WorkerGroup) GetAvailableWorkerAddrs ¶
func (wg *WorkerGroup) GetAvailableWorkerAddrs() []string
func (*WorkerGroup) RegisterWorker ¶
func (wg *WorkerGroup) RegisterWorker(w *Worker)
Click to show internal directories.
Click to hide internal directories.