loadgen

type Client struct {
	servicepb.UnimplementedLoadGenServiceServer
	// contains filtered or unexported fields
}

type ClientConfig struct {
	Monitoring metrics.Config `mapstructure:"monitoring" yaml:"monitoring"`

	Adapter     adapters.AdapterConfig  `mapstructure:",squash" yaml:",inline"`
	Stream      *workload.StreamOptions `mapstructure:"stream" yaml:"stream"`
	LoadProfile *workload.Profile       `mapstructure:"load-profile" yaml:"load-profile"`
	Limit       *adapters.GenerateLimit `mapstructure:"limit" yaml:"limit"`

	// Generate If omitted, all phases will be generated by default.
	Generate adapters.Phases `mapstructure:"generate" yaml:"generate"`
}

type ServiceAdapter interface {
	// RunWorkload apply the generated workload.
	RunWorkload(ctx context.Context, txStream *workload.StreamWithSetup) error
	// Progress returns a value that indicates progress as the number grows.
	Progress() uint64
	// Supports specify which phases an adapter supports.
	Supports() adapters.Phases
}