load

Documentation

Index

• type App
  • func NewApp(seed int, name string, c AppConfig) *App
  • func (a *App) CreateInput(from, to time.Time) Input
  • func (a *App) MergedTree() *tree.Tree
• type AppConfig
• type Input
• type Stats
• type StorageWriteSuite
  • func NewStorageWriteSuite(c StorageWriteSuiteConfig) *StorageWriteSuite
  • func (s *StorageWriteSuite) AddApp(app *App) *StorageWriteSuite
  • func (s *StorageWriteSuite) AddAppWithConfig(name string, c AppConfig) *StorageWriteSuite
  • func (s *StorageWriteSuite) Start()
  • func (s *StorageWriteSuite) Stats() Stats
• type StorageWriteSuiteConfig
• type Tag
• type TagsGenerator
  • func NewTagGenerator(seed int, appName string) *TagsGenerator
  • func (g *TagsGenerator) Add(name string, card, min, max int) *TagsGenerator
  • func (g *TagsGenerator) Next() map[string]string
• type TreeConfig
• type TreeGenerator
  • func NewTreeGenerator(seed, trees int, c TreeConfig) *TreeGenerator
  • func (g *TreeGenerator) Next() *tree.Tree

Types

type App

type App struct {
	Name            string
	SpyName         string
	SampleRate      uint32
	Units           metadata.Units
	AggregationType metadata.AggregationType
	// contains filtered or unexported fields
}

func NewApp

func NewApp(seed int, name string, c AppConfig) *App

func (*App) CreateInput

func (a *App) CreateInput(from, to time.Time) Input

func (*App) MergedTree

func (a *App) MergedTree() *tree.Tree

type AppConfig

type AppConfig struct {
	SpyName         string                   `yaml:"spyName"`
	SampleRate      uint32                   `yaml:"sampleRate"`
	Units           metadata.Units           `yaml:"units"`
	AggregationType metadata.AggregationType `yaml:"aggregationType"`

	Tags       []Tag `yaml:"tags"`
	Trees      int   `yaml:"trees"`
	TreeConfig `yaml:"treeConfig"`
}

type Input

type Input struct {
	StartTime       time.Time
	EndTime         time.Time
	Key             *segment.Key
	Val             *tree.Tree
	SpyName         string
	SampleRate      uint32
	Units           metadata.Units
	AggregationType metadata.AggregationType
}

type Stats

type Stats struct {
	RemainingPeriod time.Duration
}

type StorageWriteSuite

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

func NewStorageWriteSuite

func NewStorageWriteSuite(c StorageWriteSuiteConfig) *StorageWriteSuite

func (*StorageWriteSuite) AddApp

func (s *StorageWriteSuite) AddApp(app *App) *StorageWriteSuite

func (*StorageWriteSuite) AddAppWithConfig

func (s *StorageWriteSuite) AddAppWithConfig(name string, c AppConfig) *StorageWriteSuite

func (*StorageWriteSuite) Start

func (s *StorageWriteSuite) Start()

func (*StorageWriteSuite) Stats

func (s *StorageWriteSuite) Stats() Stats

type StorageWriteSuiteConfig

type StorageWriteSuiteConfig struct {
	Sources  int
	Interval time.Duration
	Period   time.Duration
	From     time.Time

	Seed    int
	Writers int
	WriteFn func(Input)
}

type Tag

type Tag struct {
	Name        string `yaml:"name"`
	Cardinality int    `yaml:"cardinality"`
	MinLen      int    `yaml:"minLen"`
	MaxLen      int    `yaml:"maxLen"`
}

type TagsGenerator

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

func NewTagGenerator

func NewTagGenerator(seed int, appName string) *TagsGenerator

func (*TagsGenerator) Add

func (g *TagsGenerator) Add(name string, card, min, max int) *TagsGenerator

func (*TagsGenerator) Next

func (g *TagsGenerator) Next() map[string]string

type TreeConfig

type TreeConfig struct {
	MaxSymLen int `yaml:"maxSymLen"`
	MaxDepth  int `yaml:"maxDepth"`
	Width     int `yaml:"width"`
}

type TreeGenerator

type TreeGenerator struct {
	TreeConfig
	// contains filtered or unexported fields
}

func NewTreeGenerator

func NewTreeGenerator(seed, trees int, c TreeConfig) *TreeGenerator

func (*TreeGenerator) Next

func (g *TreeGenerator) Next() *tree.Tree