Generator generates random numbers and sends them to a channel.

Merge merges results from multiple workers into a single channel.

NewActiveObject creates a new active object.

NewAgent creates a new Agent.

NewCircuitBreaker creates a new CircuitBreaker instance.

NewDispatcher creates a new dispatcher with the specified number of workers.

NewDispatcher creates a new dispatcher with the specified number of workers.

NewPool creates a new pool with the given number of workers.

NewWorker creates a new worker.

NewWorker creates a new worker.

NewWorker creates a new worker with the given ID and assigns it to the job queue.

Scraper scrapes the content of a URL and sends the result to the output channel.

Worker processes numbers received from an input channel and sends the result to an output channel.

URLList represents a list of URLs to scrape.

ActiveObject represents the active object.

Agent is a simple pub/sub agent.

CircuitBreaker represents a circuit breaker pattern.

Data represents structured data for map-reduce.

Dispatcher represents a dispatcher that distributes tasks to workers.

Dispatcher represents a dispatcher that distributes tasks to workers.

Job represents a unit of work.

Pool represents a pool of workers.

Result represents the result of a scraping operation.

Task represents a unit of work to be performed by a goroutine.

Task represents a structured task data.

Task represents a unit of work.

Task represents a unit of work.

Worker represents a worker that executes tasks.

Worker represents a worker that executes tasks.

Worker represents a worker that performs jobs.