daemon

Documentation

Index

• Constants
• type Config
• type Daemon
  • func NewDaemon(config *Config) (*Daemon, error)
  • func (d *Daemon) Start(port int) error

Constants

const (
	NATS       = "nats"
	Beanstalkd = "beanstalkd"
	Kafka      = "kafka"
	ActiveMQ   = "activemq"
	RabbitMQ   = "rabbitmq"
	NSQ        = "nsq"
)

These are supported message brokers.

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.