Documentation ¶
Index ¶
Constants ¶
View Source
const ( ContextName = "NAME" MessageCache int = 10000 NumWorkers = 10 )
Variables ¶
View Source
var (
DistributedLock *lock.Client
)
Functions ¶
This section is empty.
Types ¶
type Poller ¶
type Poller struct { ID string `json:"id" toml:"id" yaml:"id"` Name string `json:"name" toml:"name" yaml:"name"` Address string `json:"address" toml:"address" yaml:"address"` // contains filtered or unexported fields }
func New ¶
func New(config *config.Configuration, logger hclog.Logger) *Poller
New creates a new main poller instance
func (*Poller) UnmarshalText ¶
type WorkerPool ¶
type WorkerPool struct {
// contains filtered or unexported fields
}
func NewWorkerPool ¶
func NewWorkerPool(nWorker int, nRequester int, logger hclog.Logger) *WorkerPool
func (*WorkerPool) Balance ¶
func (b *WorkerPool) Balance(j chan *transport.Message)
Click to show internal directories.
Click to hide internal directories.