framulate

Documentation

Index

• type Config
  • func NewConfigFromContentsOrPath(configContents []byte, configPath string) (*Config, error)
• type Framulate
  • func NewFramulate(ctx context.Context, loggerInstance logger.Logger, config *Config) (*Framulate, error)
  • func (f *Framulate) Start() error
• type ScenarioConfig
• type Transport
• type WriteVerifyConfig

Types

type Config

type Config struct {
	ContainerName string         `json:"container_name,omitempty"`
	UserName      string         `json:"username,omitempty"`
	AccessKey     string         `json:"access_key,omitempty"`
	Cleanup       bool           `json:"cleanup,omitempty"`
	MaxTasks      int            `json:"max_tasks,omitempty"`
	Scenario      ScenarioConfig `json:"scenario,omitempty"`
	Transport     Transport      `json:"transport,omitempty"`
}

func NewConfigFromContentsOrPath

func NewConfigFromContentsOrPath(configContents []byte, configPath string) (*Config, error)

type Framulate

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

func NewFramulate

func NewFramulate(ctx context.Context, loggerInstance logger.Logger, config *Config) (*Framulate, error)

func (*Framulate) Start

func (f *Framulate) Start() error

type ScenarioConfig

type ScenarioConfig struct {
	Kind        scenarioKind
	WriteVerify WriteVerifyConfig
}

type Transport

type Transport struct {
	URL                 string `json:"url,omitempty"`
	MaxInflightRequests int    `json:"max_inflight_requests,omitempty"`
}

type WriteVerifyConfig

type WriteVerifyConfig struct {
	NumTables               int    `json:"num_tables,omitempty"`
	NumSeriesPerTable       int    `json:"num_series_per_table,omitempty"`
	MaxParallelTablesCreate int    `json:"max_parallel_tables_create,omitempty"`
	MaxParallelSeriesWrite  int    `json:"max_parallel_series_write,omitempty"`
	MaxParallelSeriesVerify int    `json:"max_parallel_series_verify,omitempty"`
	WriteDummySeries        bool   `json:"write_dummy_series,omitempty"`
	NumDatapointsPerSeries  int    `json:"num_datapoints_per_series,omitempty"`
	WriteDelay              string `json:"write_delay,omitempty"`
	VerificationDelay       string `json:"verification_delay,omitempty"`
	Verify                  bool   `json:"verify,omitempty"`
	// contains filtered or unexported fields
}