utils

Oct 11, 2020

Changes in this version

type Labels

+ func (ls Labels) HashWithName() uint64

type LabelsIfc

+ HashWithName func() uint64

Jul 1, 2020

Changes in this version

+ const OneSecondMs

Mar 24, 2020

Changes in this version

type AsyncItemsCursor

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

Mar 10, 2020

Changes in this version

+ func IsNotExistsOrConflictError(err error) bool

Feb 16, 2020

Changes in this version

+ func IsFalseConditionError(err error) bool

Jan 2, 2019

Changes in this version

type Labels

+ func (ls Labels) Filter(keep []string) LabelsIfc

+ func (ls Labels) LabelNames() []string

type LabelsIfc

+ Filter func([]string) LabelsIfc

+ LabelNames func() []string

Dec 24, 2018

Changes in this version

type NullSeriesIterator

+ func (s NullSeriesIterator) AtString() (t int64, v string)

+ func (s NullSeriesIterator) Encoding() chunkenc.Encoding

type SeriesIterator

+ AtString func() (t int64, v string)

+ Encoding func() chunkenc.Encoding

Dec 6, 2018

Changes in this version

type Labels

+ func LabelsFromString(lbls string) (Labels, error)

+ func LabelsFromStringList(ss ...string) Labels

+ func LabelsFromStringWithName(name, lbls string) (Labels, error)

+ type NullSeriesIterator struct

+ func (s NullSeriesIterator) At() (t int64, v float64)

+ func (s NullSeriesIterator) Err() error

+ func (s NullSeriesIterator) Next() bool

+ func (s NullSeriesIterator) Seek(t int64) bool

+ type NullSeriesSet struct

+ func (s NullSeriesSet) At() Series

+ func (s NullSeriesSet) Err() error

+ func (s NullSeriesSet) Next() bool

+ type Series interface

+ GetKey func() uint64

+ Iterator func() SeriesIterator

+ Labels func() Labels

+ type SeriesIterator interface

+ At func() (t int64, v float64)

+ Err func() error

+ Next func() bool

+ Seek func(t int64) bool

+ type SeriesSet interface

+ At func() Series

+ Err func() error

+ Next func() bool

Nov 7, 2018

Changes in this version

type Labels

+ func (ls Labels) HashWithMetricName() uint64

Oct 14, 2018

Changes in this version

type Labels

+ func LabelsFromMap(m map[string]string) Labels

+ func LabelsFromStrings(ss ...string) Labels

+ func ToLabels(ls ...Label) Labels

Oct 2, 2018

Changes in this version

+ const OneDayMs

+ const OneHourMs

+ const OneMinuteMs

+ func CurrentTimeInMillis() int64

+ func IsNotExistsError(err error) bool

Aug 20, 2018

Changes in this version

+ func IsValidLabelName(labelName string) error

+ func IsValidMetricName(name string) error

Aug 19, 2018

Changes in this version

+ func FloatToNormalizedScientificStr(val float64) string

+ func IsDefined(value float64) bool

+ func IsUndefined(value float64) bool

Jul 25, 2018

Changes in this version

+ const AlertName

+ const BucketLabel

+ const InstanceName

+ const MetricName

+ func AsInt64Array(val []byte) []uint64

+ func Compare(a, b Labels) int

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

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

+ func Equal(ls, o Labels) bool

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

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

+ func Str2duration(duration string) (int64, error)

+ func Str2unixTime(tstr string) (int64, error)

+ type AsyncItemsCursor struct

+ Cnt int

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

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

+ func (ic *AsyncItemsCursor) Err() error

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

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

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

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

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

+ func (ic *AsyncItemsCursor) Next() bool

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

+ func (ic *AsyncItemsCursor) Release()

+ type Builder struct

+ func NewBuilder(base Labels) *Builder

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

+ func (b *Builder) Labels() Labels

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

+ type ItemsCursor interface

+ Err func() error

+ GetField func(name string) interface{}

+ GetFields func() map[string]interface{}

+ Next func() bool

+ type Label struct

+ Name string

+ Value string

+ type Labels []Label

+ func FromMap(m map[string]string) Labels

+ func FromStrings(ss ...string) Labels

+ func New(ls ...Label) Labels

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

+ func (ls Labels) Copy() Labels

+ func (ls Labels) Get(name string) string

+ func (ls Labels) GetExpr() string

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

+ func (ls Labels) Has(name string) bool

+ func (ls Labels) Hash() uint64

+ func (ls Labels) Len() int

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

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

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

+ func (ls Labels) String() string

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

+ type LabelsIfc interface

+ GetExpr func() string

+ GetKey func() (string, string, uint64)