seriesvolume

Documentation

Index

• Constants
• func AggregateBySeries(aggregateBy string) bool
• func MapToVolumeResponse(mergedVolumes map[string]uint64, limit int) *logproto.VolumeResponse
• func Merge(responses []*logproto.VolumeResponse, limit int32) *logproto.VolumeResponse
• func ValidateAggregateBy(aggregateBy string) bool
• type Accumulator
  • func NewAccumulator(limit int32, maxSize int) *Accumulator
  • func (acc *Accumulator) AddVolume(name string, size uint64) error
  • func (acc *Accumulator) Volumes() *logproto.VolumeResponse

Constants

const (
	MatchAny     = "{}"
	DefaultLimit = 100
	Series       = "series"
	Labels       = "labels"

	DefaultAggregateBy = Series

	ErrVolumeMaxSeriesHit = "the query hit the max number of series limit (limit: %d series)"
)

Functions

func AggregateBySeries

func AggregateBySeries(aggregateBy string) bool

func MapToVolumeResponse

func MapToVolumeResponse(mergedVolumes map[string]uint64, limit int) *logproto.VolumeResponse

func Merge

func Merge(responses []*logproto.VolumeResponse, limit int32) *logproto.VolumeResponse

func ValidateAggregateBy

func ValidateAggregateBy(aggregateBy string) bool

Types

type Accumulator

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

TODO(masslessparticle): Lock striping to reduce contention on this map

func NewAccumulator

func NewAccumulator(limit int32, maxSize int) *Accumulator

func (*Accumulator) AddVolume

func (acc *Accumulator) AddVolume(name string, size uint64) error

func (*Accumulator) Volumes

func (acc *Accumulator) Volumes() *logproto.VolumeResponse