Documentation ¶
Index ¶
- Constants
- func GetLogger() *kitlog.Logger
- type Broker
- func (b *Broker) Bind(endpoint string) (err error)
- func (b *Broker) ClientMsg(sender string, msg []string)
- func (b *Broker) Close() (err error)
- func (b *Broker) Purge()
- func (b *Broker) Run(done chan bool)
- func (b *Broker) ServiceRequire(service_frame string) (service *Service)
- func (b *Broker) WorkerMsg(sender string, msg []string)
- func (b *Broker) WorkerRequire(identity string) (worker *Worker)
- type Bus
- type Endpoint
- type Relay
- type Service
- type Unit
- type Worker
Constants ¶
View Source
const ( HEARTBEAT_LIVENESS = 3 // 3-5 is reasonable HEARTBEAT_INTERVAL = 2500 * time.Millisecond // msecs HEARTBEAT_EXPIRY = HEARTBEAT_INTERVAL * HEARTBEAT_LIVENESS )
TODO: get these from config data
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Broker ¶
type Broker struct { Socket *zmq.Socket // Socket for clients & workers Waiting []*Worker // List of waiting workers HeartbeatAt time.Time // When to send HEARTBEAT // contains filtered or unexported fields }
func (*Broker) ServiceRequire ¶
func (*Broker) WorkerRequire ¶
type Bus ¶ added in v0.1.6
type Bus struct {
// contains filtered or unexported fields
}
Source Files ¶
Click to show internal directories.
Click to hide internal directories.