utils

package
v0.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 25, 2018 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Overview

Copyright 2017 The Prometheus Authors Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

Constants

View Source 
const (
	MetricName   = "__name__"
	AlertName    = "alertname"
	BucketLabel  = "le"
	InstanceName = "instance"
)

Well-known label names used by Prometheus components.

Variables

This section is empty.

Functions

func AsInt64Array 

func AsInt64Array(val []byte) []uint64

convert v3io blob to Int array

func Compare 

func Compare(a, b Labels) int

Compare compares the two label sets. The result will be 0 if a==b, <0 if a < b, and >0 if a > b.

func CreateContainer 

func CreateContainer(logger logger.Logger, addr, cont, username, password string, workers int) (*v3io.Container, error)

func DeleteTable 

func DeleteTable(container *v3io.Container, path, filter string, workers int) error

func Equal 

func Equal(ls, o Labels) bool

Equal returns whether the two label sets are equal.

func GetTimeFromRange 

func GetTimeFromRange(from, to, last, step string) (f int64, t int64, s int64, err error)

func NewLogger 

func NewLogger(verbose string) (logger.Logger, error)

func Str2duration 

func Str2duration(duration string) (int64, error)

convert duration string e.g. 24h to time (unix milisecond)

func Str2unixTime 

func Str2unixTime(tstr string) (int64, error)

convert time string to time (unix milisecond)

Types

type AsyncItemsCursor 

type AsyncItemsCursor struct {
	Cnt int
	// contains filtered or unexported fields
}

func NewAsyncItemsCursor 

func NewAsyncItemsCursor(container *v3io.Container, input *v3io.GetItemsInput, workers int) (*AsyncItemsCursor, error)

func (*AsyncItemsCursor) All 

func (ic *AsyncItemsCursor) All() ([]v3io.Item, error)

gets all items

func (*AsyncItemsCursor) Err 

func (ic *AsyncItemsCursor) Err() error

Err returns the last error

func (*AsyncItemsCursor) GetField 

func (ic *AsyncItemsCursor) GetField(name string) interface{}

func (*AsyncItemsCursor) GetFieldInt 

func (ic *AsyncItemsCursor) GetFieldInt(name string) (int, error)

func (*AsyncItemsCursor) GetFieldString 

func (ic *AsyncItemsCursor) GetFieldString(name string) (string, error)

func (*AsyncItemsCursor) GetFields 

func (ic *AsyncItemsCursor) GetFields() map[string]interface{}

func (*AsyncItemsCursor) GetItem 

func (ic *AsyncItemsCursor) GetItem() v3io.Item

func (*AsyncItemsCursor) Next 

func (ic *AsyncItemsCursor) Next() bool

Next gets the next matching item. this may potentially block as this lazy loads items from the collection

func (*AsyncItemsCursor) NextItem 

func (ic *AsyncItemsCursor) NextItem() (v3io.Item, error)

NextItem gets the next matching item. this may potentially block as this lazy loads items from the collection

func (*AsyncItemsCursor) Release 

func (ic *AsyncItemsCursor) Release()

Release releases a cursor and its underlying resources

type Builder 

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

Builder allows modifiying Labels.

func NewBuilder 

func NewBuilder(base Labels) *Builder

NewBuilder returns a new LabelsBuilder

func (*Builder) Del 

func (b *Builder) Del(ns ...string) *Builder

Del deletes the label of the given name.

func (*Builder) Labels 

func (b *Builder) Labels() Labels

Labels returns the labels from the builder. If no modifications were made, the original labels are returned.

func (*Builder) Set 

func (b *Builder) Set(n, v string) *Builder

Set the name/value pair as a label.

type ItemsCursor 

type ItemsCursor interface {
	Err() error
	Next() bool
	GetField(name string) interface{}
	GetFields() map[string]interface{}
}

type Label 

type Label struct {
	Name, Value string
}

Label is a key/value pair of strings.

type Labels 

type Labels []Label

Labels is a sorted set of labels. Order has to be guaranteed upon instantiation.

func FromMap 

func FromMap(m map[string]string) Labels

FromMap returns new sorted Labels from the given map.

func FromStrings 

func FromStrings(ss ...string) Labels

FromStrings creates new labels from pairs of strings.

func New 

func New(ls ...Label) Labels

New returns a sorted Labels from the given labels. The caller has to guarantee that all label names are unique.

func (Labels) Copy 

func (ls Labels) Copy() Labels

Copy returns a copy of the labels.

func (Labels) Get 

func (ls Labels) Get(name string) string

Get returns the value for the label with the given name. Returns an empty string if the label doesn't exist.

func (Labels) GetExpr 

func (ls Labels) GetExpr() string

create update expression

func (Labels) GetKey 

func (ls Labels) GetKey() (string, string, uint64)

convert Label set to a string in the form key1=v1,key2=v2.. + name + hash

func (Labels) Has 

func (ls Labels) Has(name string) bool

Has returns true if the label with the given name is present.

func (Labels) Hash 

func (ls Labels) Hash() uint64

Hash returns a hash value for the label set.

func (Labels) Len 

func (ls Labels) Len() int

func (Labels) Less 

func (ls Labels) Less(i, j int) bool

func (Labels) Map 

func (ls Labels) Map() map[string]string

Map returns a string map of the labels.

func (Labels) MarshalJSON 

func (ls Labels) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler.

func (Labels) String 

func (ls Labels) String() string

func (Labels) Swap 

func (ls Labels) Swap(i, j int)

func (*Labels) UnmarshalJSON 

func (ls *Labels) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler.

type LabelsIfc 

type LabelsIfc interface {
	GetKey() (string, string, uint64)
	GetExpr() string
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.