aggregator

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

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

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
}

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

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

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

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

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