chpool

Documentation

Index

• type RequestRouter
  • func (r *RequestRouter) Loop()

Types

type RequestRouter

type RequestRouter struct {
	Die     <-chan struct{}
	Source  <-chan *rpcmux.Request
	Targets []chan<- *rpcmux.Request
	K1, K2  uint64
}

func (*RequestRouter) Loop

func (r *RequestRouter) Loop()