Class: Pione::Agent::TaskWorkerBalancer

Inherits:

Object

• Object
• Pione::Agent::TaskWorkerBalancer

Defined in:

lib/pione/agent/broker.rb

Overview

TaskWorkerBalancer is a base class for balancing task workers.

Direct Known Subclasses

EasyTaskWorkerBalancer

Instance Method Summary

• #balance ⇒ Object

  Execute task worker balancing.

• #initialize(broker) ⇒ TaskWorkerBalancer constructor

  Create a new balancer.

Constructor Details

#initialize(broker) ⇒ TaskWorkerBalancer

Create a new balancer.

# File 'lib/pione/agent/broker.rb', line 222

def initialize(broker)
  @broker = broker
end

Instance Method Details

#balance ⇒ Object

Execute task worker balancing. If this method returned true, broker executes rebalance chain with no span. If false, broker sleeps a little.

Raises:

• (NotImplementedError)

# File 'lib/pione/agent/broker.rb', line 228

def balance
  raise NotImplementedError
end