aggregator

Documentation

Index

• Constants
• func RunAggregator(dc *pcache.DiskCache, storageDir string, listenAddr string, aesPwd string, ...) error
• func RunIngressProxy(sh2 *agent.Agent, aesPwd string, config ConfigIngressProxy) error
• func RunSimulator(simID int, metricsStorage *metajournal.MetricsStorage, storageDir string, ...)
• func TestLongpoll(aggAddr []string, client *rpc.Client, timeoutSec int32)
• func TestMapper(aggAddr []string, mapString string, client *rpc.Client)
• func ValidateConfigAggregator(c ConfigAggregator) error
• type Aggregator
  • func (a *Aggregator) RowDataMarshalAppendPositions(b *aggregatorBucket, rnd *rand.Rand, res []byte, historic bool) []byte
• type BuiltInStatRecord
• type ConfigAggregator
  • func DefaultConfigAggregator() ConfigAggregator
• type ConfigIngressProxy
  • func (config *ConfigIngressProxy) ReadIngressKeys(ingressPwdDir string) error
• type IngressProxy
• type TagsMapper
  • func NewTagsMapper(agg *Aggregator, sh2 *agent.Agent, metricStorage *metajournal.MetricsStorage, ...) *TagsMapper
• type TestConnection
  • func MakeTestConnection() *TestConnection
• type TestConnectionClient

Constants

const MaxTestResponseSize = 10 << 20

const MaxTestResponseTimeoutSec = 86400

Functions

func RunAggregator

func RunAggregator(dc *pcache.DiskCache, storageDir string, listenAddr string, aesPwd string, config ConfigAggregator, hostName string, logTrace bool) error

func RunIngressProxy

func RunIngressProxy(sh2 *agent.Agent, aesPwd string, config ConfigIngressProxy) error

func RunSimulator

func RunSimulator(simID int, metricsStorage *metajournal.MetricsStorage, storageDir string, aesPwd string, config agent.Config)

func TestLongpoll

func TestLongpoll(aggAddr []string, client *rpc.Client, timeoutSec int32)

func TestMapper

func TestMapper(aggAddr []string, mapString string, client *rpc.Client)

func ValidateConfigAggregator

func ValidateConfigAggregator(c ConfigAggregator) error

Types

type Aggregator

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

func (*Aggregator) RowDataMarshalAppendPositions

func (a *Aggregator) RowDataMarshalAppendPositions(b *aggregatorBucket, rnd *rand.Rand, res []byte, historic bool) []byte

type BuiltInStatRecord

type BuiltInStatRecord struct {
	Key  data_model.Key
	SKey string
	data_model.ItemValue
}

type ConfigAggregator

type ConfigAggregator struct {
	ShortWindow        int
	RecentInserters    int
	HistoricInserters  int
	InsertHistoricWhen int

	KHAddr string

	InsertBudget    int // for single replica, in bytes per contributor, when many contributors
	InsertBudget100 int // for single replica, in bytes per contributor, when 100 contributors

	CardinalityWindow int
	MaxCardinality    int

	StringTopCountInsert int

	SimulateRandomErrors float64

	MetadataNet     string
	MetadataAddr    string
	MetadataActorID uint64

	Cluster           string
	PreviousNumShards int
	ExternalPort      string

	AutoCreate bool
}

func DefaultConfigAggregator

func DefaultConfigAggregator() ConfigAggregator

type ConfigIngressProxy

type ConfigIngressProxy struct {
	Network           string
	ListenAddr        string
	ExternalAddresses []string // exactly 3 comma-separated external ingress points
	IngressKeys       []string
}

func (*ConfigIngressProxy) ReadIngressKeys

func (config *ConfigIngressProxy) ReadIngressKeys(ingressPwdDir string) error

type IngressProxy

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

type TagsMapper

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

func NewTagsMapper

func NewTagsMapper(agg *Aggregator, sh2 *agent.Agent, metricStorage *metajournal.MetricsStorage, dc *pcache.DiskCache, a *Aggregator, loader *metajournal.MetricMetaLoader, suffix string) *TagsMapper

type TestConnection

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

func MakeTestConnection

func MakeTestConnection() *TestConnection

type TestConnectionClient

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