generator

type Config struct {
	NumPartitions             int           `yaml:"num_partitions"`
	NumTenants                int           `yaml:"num_tenants"`
	TenantPrefix              string        `yaml:"tenant_prefix"`
	QPSPerTenant              int           `yaml:"qps_per_tenant"`
	CreateBatchSize           int           `yaml:"create_batch_size"`
	CreateNewStreamsInterval  time.Duration `yaml:"create_new_streams_interval"`
	StreamsPerTenant          int           `yaml:"streams_per_tenant"`
	StreamLabels              []string      `yaml:"stream_labels"`
	MaxGlobalStreamsPerTenant int           `yaml:"max_global_streams_per_tenant"`
	PushMode                  PushModeType  `yaml:"push_mode"`

	// Stream size control parameter
	DesiredRate int `yaml:"desired_rate"`

	LogLevel       dskit_log.Level `yaml:"log_level,omitempty"`
	HTTPListenPort int             `yaml:"http_listen_port,omitempty"`

	// Memberlist config
	MemberlistKV memberlist.KVConfig `yaml:"memberlist,omitempty"`

	// Kafka config
	Kafka kafka.Config `yaml:"kafka,omitempty"`

	// Lifecycler config
	LifecyclerConfig ring.LifecyclerConfig `yaml:"lifecycler,omitempty"`

	// Client configs
	DistributorClientConfig distributor_client.Config `yaml:"distributor_client,omitempty"`
	FrontendClientConfig    frontend_client.Config    `yaml:"frontend_client,omitempty"`
	// contains filtered or unexported fields
}

type Generator struct {
	services.Service
	// contains filtered or unexported fields
}

type PushModeType string