worker

package

v0.0.0-...-cdd6ff6 Latest Latest Go to latest Published: Dec 5, 2025 License: Apache-2.0 Imports: 13 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/corshatech/simi

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type Worker
- func NewWorker(conf config.WorkerConfig) (*Worker, error)

Constants ¶

View Source

const (
	DefaultJobID = "simi"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Worker ¶

type Worker struct {
	// contains filtered or unexported fields
}

func NewWorker ¶

func NewWorker(conf config.WorkerConfig) (*Worker, error)

NewWorker connects to the AMQP broker and starts the benchmark reporter.

func (*Worker) BenchOperation ¶

func (w *Worker) BenchOperation() error

BenchOperation benchmarks the operation being exercised.

func (*Worker) Close ¶

func (w *Worker) Close()

Close closes the connection used by this worker.

func (*Worker) Register ¶

func (w *Worker) Register() error

Register performs registration for the requested number of workers. Upon successful registration the Worker publishes its success status to the Consumer. The Worker then waits for a Start signal from the Consumer before beginning its benchmarking tasks.

Source Files ¶

View all Source files

worker.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL