daemon

package
v0.0.0-...-3705e9c Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 23, 2016 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source
const (
	NATS        = "nats"
	Beanstalkd  = "beanstalkd"
	Kafka       = "kafka"
	Kestrel     = "kestrel"
	ActiveMQ    = "activemq"
	RabbitMQ    = "rabbitmq"
	NSQ         = "nsq"
	CloudPubSub = "pubsub"
)

These are supported message brokers.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
	GoogleCloudProjectID string
	GoogleCloudJSONKey   string
}

Config contains configuration settings for the Flotilla daemon.

type Daemon

type Daemon struct {
	mangos.Socket
	// contains filtered or unexported fields
}

Daemon is the server portion of Flotilla which runs on machines we want to communicate with and include in our benchmarks.

func NewDaemon

func NewDaemon(config *Config) (*Daemon, error)

NewDaemon creates and returns a new Daemon from the provided Config. An error is returned if the Daemon cannot be created.

func (*Daemon) Start

func (d *Daemon) Start(port int) error

Start will allow the Daemon to begin processing requests. This is a blocking call.

Directories

Path Synopsis
nsq

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL