loadrunner

type Command interface {
	Run() error
}

type CommandFactory interface {

	// Name returns the name of the command
	Name() string

	// CreateCommand creates a Command instance
	CreateCommand(loadRunnerNodeID int, commandConfig string) Command
}

type Config struct {
	NodeID                   int
	APIServerListenAddresses []string
}

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

type ExecStatementCommandFactory struct {
}

type ExecuteStatementCommandCfg struct {
	// LoadRunnerNodeID is the ID of the load runner node from where to execute this statement
	LoadRunnerNodeID int `json:"load_runner_node_id"`
	// NumIters is the number of times to execute the statement
	NumIters int `json:"num_iters"`
	// Concurrency determines the number of goroutines that will be created to execute the statements. Each
	// goroutine executes the statement numIters times
	Concurrency int `json:"concurrency"`
	// The gRPC API host_name of the Prana server to execute the statement on
	PranaHostname string `json:"prana_host_name"`
	// SchemaName is the schema name
	SchemaName string `json:"schema_name"`
	// Statement is the statement to execute
	Statement string `json:"statement"`
}

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

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

type PublishCommandCfg struct {
	// GeneratorName is the name of the generator which actually creates the Kafka messages
	GeneratorName string `json:"generator_name"`
	// TopicName is the name of the topic to send the messages to
	TopicName string `json:"topic_name"`
	// Partitions is the number of partitions in the topic
	Partitions int `json:"partitions"`
	// Delay is the delay between sending each message
	Delay time.Duration `json:"delay"`
	// NumMessages is the total number of messages to send
	NumMessages int64 `json:"num_messages"`
	// IndexStart determines the start ID of the first message sent
	IndexStart int64 `json:"index_start"`
	// KafkaProperties - properties when making the connection to Kafka
	KafkaProperties map[string]string `json:"kafka_properties"`
}

type PublishCommandFactory struct {
}