publish

Documentation

Index

• type Command
  • func (cmd *Command) ParseFlags(args ...string) (Options, error)
  • func (cmd *Command) Run(args ...string) error
• type Options
• type Server
  • func (srv *Server) Run(ctx context.Context)

Types

type Command

type Command struct {
	Server *Server
}

Command represents the command executed by `go run pub_benchmark.go`

func (*Command) ParseFlags

func (cmd *Command) ParseFlags(args ...string) (Options, error)

ParseFlags parses the args into Options.

func (*Command) Run

func (cmd *Command) Run(args ...string) error

Run parses the command arguments and starts the server.

type Options

type Options struct {
	Host               string //default:  localhost
	Port               string //default: :1883
	Username           string
	Password           string
	Qos                int
	Topic              string
	ConnectionInterval int
	PublishInterval    int //
	Number             int //number of messages  to publish per client
	Count              int //number of clients
	Size               int //payload bytes, default to 256
	SubCount           int //number of clients which subscribe topic # , default to 0
	SubQos             int //qos level of subscriptions, default to 0
	CleanSession       bool
	Time               int //timeout
}

Options represents the publish benchmark options

type Server

type Server struct {
	Options Options

	StartAt    time.Time
	FinishedAt time.Time
	// contains filtered or unexported fields
}

Server represents the publish benchmark server.

func (*Server) Run

func (srv *Server) Run(ctx context.Context)

Run starts the server.