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"
	Kestrel     = "kestrel"
	ActiveMQ    = "activemq"
	RabbitMQ    = "rabbitmq"
	NSQ         = "nsq"
	CloudPubSub = "pubsub"
)

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.