labelvolume

Documentation

Index

• Constants
• func MapToLabelVolumeResponse(mergedVolumes map[string]map[string]uint64, limit int) *logproto.LabelVolumeResponse
• func Merge(responses []*logproto.LabelVolumeResponse, limit int32) *logproto.LabelVolumeResponse
• type Accumulator
  • func NewAccumulator(limit int32) *Accumulator
  • func (acc *Accumulator) AddVolumes(v map[string]map[string]uint64)
  • func (acc *Accumulator) Volumes() *logproto.LabelVolumeResponse

Constants

const (
	MatchAny     = "{}"
	DefaultLimit = 100
)

Functions

func MapToLabelVolumeResponse

func MapToLabelVolumeResponse(mergedVolumes map[string]map[string]uint64, limit int) *logproto.LabelVolumeResponse

func Merge

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

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) *Accumulator

func (*Accumulator) AddVolumes

func (acc *Accumulator) AddVolumes(v map[string]map[string]uint64)

func (*Accumulator) Volumes

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