Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DistributeN ¶
Types ¶
type BenchCommand ¶
type BenchCommand struct { Meta ShutdownCh <-chan struct{} }
func (*BenchCommand) Help ¶
func (c *BenchCommand) Help() string
func (*BenchCommand) Recv ¶
func (c *BenchCommand) Recv(args []string) int
func (*BenchCommand) Run ¶
func (c *BenchCommand) Run(args []string) int
func (*BenchCommand) Send ¶
func (c *BenchCommand) Send(args []string) int
func (*BenchCommand) Synopsis ¶
func (c *BenchCommand) Synopsis() string
type BenchRecvConfig ¶
type BenchSendConfig ¶
type QueueCommand ¶
type QueueCommand struct {
Meta
}
func (*QueueCommand) Help ¶
func (c *QueueCommand) Help() string
func (*QueueCommand) Run ¶
func (c *QueueCommand) Run(args []string) int
func (*QueueCommand) Synopsis ¶
func (c *QueueCommand) Synopsis() string
type ServerCommand ¶
type ServerCommand struct { Meta ShutdownCh <-chan struct{} }
func (*ServerCommand) Help ¶
func (c *ServerCommand) Help() string
func (*ServerCommand) Run ¶
func (c *ServerCommand) Run(args []string) int
func (*ServerCommand) Synopsis ¶
func (c *ServerCommand) Synopsis() string
type ServerConfig ¶
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 ¶
type SessionCommand struct {
Meta
}
func (*SessionCommand) Help ¶
func (c *SessionCommand) Help() string
func (*SessionCommand) Run ¶
func (c *SessionCommand) Run(args []string) int
func (*SessionCommand) Synopsis ¶
func (c *SessionCommand) Synopsis() string
type VersionCommand ¶
func (*VersionCommand) Help ¶
func (c *VersionCommand) Help() string
func (*VersionCommand) Run ¶
func (c *VersionCommand) Run(args []string) int
func (*VersionCommand) Synopsis ¶
func (c *VersionCommand) Synopsis() string
Click to show internal directories.
Click to hide internal directories.