measure

package

v0.3.1 Latest Latest Go to latest Published: Feb 21, 2023 License: Apache-2.0 Imports: 25 Imported by: 0

Details

Package measure implements execution operations for querying measure data.

This section is empty.

This section is empty.

func Analyze(_ context.Context, criteria *measurev1.QueryRequest, metadata *commonv1.Metadata, s logical.Schema) (logical.Plan, error)

Analyze converts logical expressions to executable operation tree represented by Plan.

func BuildSchema(measureSchema measure.Measure) (logical.Schema, error)

BuildSchema returns Schema loaded from the metadata repository.

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

TopElement seals a sortable value and its data point which this value belongs to.

func NewTopElement(dp *measurev1.DataPoint, value int64) TopElement

NewTopElement returns a TopElement.

func (e TopElement) Val() int64

Val returns the sortable value.

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

TopQueue is a sortable queue only keeps top-n members when pushed new elements.

func NewTopQueue(n int, reverted bool) *TopQueue

NewTopQueue returns a new TopQueue.

func (s *TopQueue) Elements() []TopElement

Elements returns all elements accepted by the queue.

func (s *TopQueue) Equal(other *TopQueue) bool

Equal reports whether s and other have the queue's max acceptable number and sorting order.

func (s *TopQueue) Insert(element TopElement) bool

Insert pushes a new element to the queue. It returns true if the element are accepted by the queue, returns false if it's evicted.

func (s *TopQueue) Purge()

Purge resets the queue.

func (s TopQueue) String() string

Strings shows the string represent.