command

type BenchCommand struct {
	Meta

	ShutdownCh <-chan struct{}
}

type BenchRecvConfig struct {
	QueueName string `envconfig:"queue_name"`

	NumberOfMessages int
}

type BenchSendConfig struct {
	QueueName       string `envconfig:"queue_name"`
	TargetQueueName string `envconfig:"target_queue_name"`

	NumberOfMessages int
	Concurrency      int
	Duration         int
}

type Meta struct {
	Ui cli.Ui
}

type QueueCommand struct {
	Meta
}

type ServerCommand struct {
	Meta

	ShutdownCh <-chan struct{}
}

type ServerConfig struct {
	WorkerID  string `envconfig:"worker_id"`
	DSN       string `envconfig:"dsn"`
	QueueName string `envconfig:"queue_name"`

	ShutdownDuration  int `envconfig:"shutdown_duration"`
	NumConsumerFactor int `envconfig:"num_consumer_factor"`
	NumRelayFactor    int `envconfig:"num_relay_factor"`

	HTTPServer string

	LeaveMessagesOrphanedAtShutdown bool
}

type SessionCommand struct {
	Meta
}

type VersionCommand struct {
	Meta

	Name     string
	Version  string
	Revision string
}