common

Jan 29, 2025

Changes in this version

type Observability

+ func (o *Observability) Panic(obj interface{}, args ...interface{})

Jul 18, 2024

Changes in this version

type BaseConfig

+ Filters []*BaseCondition

Jun 21, 2024

Changes in this version

+ func ReadFile(path, typ string) (interface{}, error)

+ func ReadJson(bytes []byte) (interface{}, error)

+ func ReadToml(bytes []byte) (interface{}, error)

+ func ReadYaml(bytes []byte) (interface{}, error)

+ type Processor interface

+ Name func() string

+ Process func(d Discovery, so SinkObject)

+ Providers func() []string

+ type Processors struct

+ func NewProcessors(observability *Observability, sinks *Sinks) *Processors

+ func (ps *Processors) Add(p Processor)

+ func (ps *Processors) Process(d Discovery, so SinkObject)

Jun 14, 2024

Changes in this version

type Labels

+ func ReplaceLabelValues(labels Labels, replacements map[string]string) Labels

Jun 13, 2024

Changes in this version

type LabelsMap

+ func ConvertSinkMapToLabelsMap(m SinkMap) LabelsMap

type Objects

+ func ConvertSinkMapToObjects(m SinkMap) Objects

Apr 11, 2024

Changes in this version

type BaseAvailabilityQuery

+ Round *int

type BaseMetric

+ Round *int

Apr 4, 2024

Changes in this version

+ func FileMd5ToString(path string) string

+ func Md5(b []byte) []byte

+ func Md5ToString(b []byte) string

+ type Object struct

+ Configs map[string]*BaseConfig

+ Files Files

+ Metrics []string

+ Vars map[string]string

+ type Objects map[string]*Object

+ func ConvertSyncMapToObjects(m SinkMap) Objects

type SinkMap

+ func ConvertObjectsToSinkMap(m Objects) SinkMap

Mar 29, 2024

Changes in this version

+ func MD5(b []byte) []byte

Mar 29, 2024

Changes in this version

+ func FileWriteWithCheckSum(path string, data []byte, checksum bool) (bool, error)

Mar 19, 2024

Changes in this version

+ type Application struct

+ Configs map[string]*BaseConfig

+ Files Files

+ Metrics []string

+ Vars map[string]string

+ type Applications map[string]*Application

+ func ConvertSyncMapToApplications(m SinkMap) Applications

type SinkMap

+ func ConvertApplicationsToSinkMap(m Applications) SinkMap

Dec 18, 2023

Changes in this version

+ func StringSliceToMap(lines []string) map[string]string

type HostSink

+ Cluster string

+ Server string

type Labels

+ func MergeLabels(labels ...Labels) Labels

Dec 13, 2023

Changes in this version

type HostSink

+ OS string

Dec 12, 2023

Changes in this version

type Sink

+ Providers func() []string

Dec 12, 2023

Changes in this version

+ func AppendHostSink(m SinkMap, name string, hs HostSink)

+ func FilterStringMap(m map[string]string, keys []string) map[string]string

+ func RemoveEmptyStrings(items []string) []string

type Discovery

+ Name func() string

+ Source func() string

+ type Files map[string]*File

+ type HostSink struct

+ Host string

+ IP string

+ Vendor string

+ type LabelsMap map[string]Labels

+ func ConvertSyncMapToLabelsMap(m SinkMap) LabelsMap

type PromDiscoveryObject

+ Password string

+ User string

type PrometheusOptions

+ Password string

+ User string

+ type Services map[string]*Service

+ func ConvertSyncMapToServices(m SinkMap) Services

+ type Sink interface

+ Name func() string

+ Pass func() []string

+ Process func(d Discovery, so SinkObject)

+ type SinkMap map[string]interface

+ func ConvertLabelsMapToSinkMap(m LabelsMap) SinkMap

+ func ConvertServicesToSinkMap(m Services) SinkMap

+ type SinkObject interface

+ Map func() SinkMap

+ Options func() interface{}

+ type Sinks struct

+ func NewSinks(observability *Observability) *Sinks

+ func (ss *Sinks) Add(s Sink)

+ func (ss *Sinks) Process(d Discovery, so SinkObject)

Dec 11, 2023

Changes in this version

type BaseConfig

+ Prefix string

Nov 21, 2023

Changes in this version

+ type PromDiscoveryObject struct

+ HttpPassword string

+ HttpUsername string

+ Name string

+ URL string

type PrometheusOptions

+ HttpPassword string

+ HttpUsername string

Oct 3, 2023

Changes in this version

+ func GetLabelsKeys(arr map[string]Labels) []string

Sep 22, 2023

Changes in this version

+ func GetDomainKeys(arr map[string]Labels) []string

+ func GetPrometheusDiscoveriesByInstances(names string) map[string]string

+ func ParsePeriodFromNow(period string, t time.Time) string

+ func Render(def string, obj interface{}, observability *Observability) string

+ type Discovery interface

+ Discover func()

+ type Labels map[string]string

+ type PrometheusOptions struct

+ Insecure bool

+ Names string

+ Timeout int

+ URL string

+ type PrometheusResponse struct

+ Data *PrometheusResponseData

+ Status string

+ type PrometheusResponseData struct

+ Result []*PrometheusResponseDataVector

+ ResultType string

+ type PrometheusResponseDataVector struct

+ Labels map[string]string

Aug 24, 2023

Changes in this version

type BaseConfig

+ func (bc *BaseConfig) Contains(pattern string) bool

Jul 21, 2023

Changes in this version

+ func GetFileKeys(arr map[string]*File) []string

Jul 19, 2023

Changes in this version

+ func StringContainsAny(s string, arr []string) bool

type BaseAvailability

+ Disabled bool

type BaseConfig

+ Disabled bool

type BaseMetric

+ Disabled bool

type Service

+ Metrics []string

Jul 11, 2023

Changes in this version

type BaseConfig

+ Disbaled bool

Jun 9, 2023

Changes in this version

+ func MergeInterfacegMaps(maps ...map[string]interface{}) map[string]interface

+ func MergeStringMaps(maps ...map[string]string) map[string]string

May 30, 2023

Changes in this version

+ type BaseCondition struct

+ Labels map[string]string

+ Metric string

type BaseConfig

+ Conditions []*BaseCondition

+ func (bc *BaseConfig) LabelsExist(c *BaseCondition, labels map[string]string) bool

May 25, 2023

Changes in this version

+ type File struct

+ Obj interface{}

+ Path string

+ Type string

type Service

+ Files map[string]*File

May 16, 2023

Changes in this version

type TelegrafConfig

+ Observability *Observability

Apr 24, 2023

Changes in this version

type BaseAvailabilityQuery

+ Composite string

Apr 20, 2023

Changes in this version

type TelegrafInputPrometheusHttp

+ File []*TelegrafInputPrometheusHttpFile

+ type TelegrafInputPrometheusHttpFile struct

+ Name string

+ Path string

+ Type string

Apr 11, 2023

Changes in this version

type BaseAvailability

+ Query string

+ Suffix string

+ UniqueBy []string

type TelegrafConfigOptions

+ AvailabilityName string

type TelegrafInputPrometheusHttp

+ Availability []*TelegrafInputPrometheusHttpAvailability

Mar 21, 2023

Changes in this version

type TelegrafInputPrometheusHttp

+ Name string

Mar 17, 2023

Changes in this version

type TelegrafConfigOptions

+ VarFormat string

Mar 15, 2023

Changes in this version

+ func GetBaseConfigKeys(arr map[string]*BaseConfig) []string

+ func GetStringKeys(arr map[string]string) []string

+ func SortStringMapByKeys(m map[string]string, keys []string) map[string]string

Mar 6, 2023

Changes in this version

+ func ByteMD5(b []byte) []byte

+ func FileMD5(path string) []byte

+ func GetKeys(arr map[string]string) []string

+ func IfDef(v, def interface{}) interface

+ func MergeMaps(maps ...map[string]string) map[string]string

+ func ReadFiles(pattern string) ([]string, error)

+ func RenderTemplate(tpl *toolsRender.TextTemplate, def string, obj interface{}) (string, error)

+ func StringInArr(a string, arr []string) bool

+ type BaseAvailability struct

+ GroupBy []string

+ Labels map[string]string

+ Queries []*BaseAvailabilityQuery

+ type BaseAvailabilityQuery struct

+ Labels map[string]string

+ Query string

+ Source string

+ Suffix string

+ Timeout string

+ UseCRD string

+ Weight interface{}

+ type BaseConfig struct

+ Availability *BaseAvailability

+ Labels map[string]string

+ Metrics []*BaseMetric

+ Qualities []*BaseQuality

+ Vars map[string]string

+ func (bc *BaseConfig) MetricExists(query string) bool

+ type BaseMetric struct

+ Labels map[string]string

+ Name string

+ Query string

+ UniqueBy []string

+ type BaseQuality struct

+ Every string

+ Points int

+ Query string

+ Range string

+ type Observability struct

+ func NewObservability(logs *sre.Logs, metrics *sre.Metrics) *Observability

+ func (o *Observability) Debug(obj interface{}, args ...interface{})

+ func (o *Observability) Error(obj interface{}, args ...interface{})

+ func (o *Observability) Info(obj interface{}, args ...interface{})

+ func (o *Observability) Logs() *sre.Logs

+ func (o *Observability) Metrics() *sre.Metrics

+ func (o *Observability) Warn(obj interface{}, args ...interface{})

+ type Service struct

+ Configs []*BaseConfig

+ Labels map[string]string

+ Vars map[string]string

+ type TelegrafConfig struct

+ Inputs TelegrafInputs

+ func (tc *TelegrafConfig) GenerateServiceBytes(s *Service, opts TelegrafConfigOptions) ([]byte, error)

+ type TelegrafConfigOptions struct

+ AvailbailityName string

+ DefaultTags []string

+ Duration string

+ Interval string

+ MetricName string

+ Params string

+ Prefix string

+ QualityEvery string

+ QualityName string

+ QualityPoints int

+ QualityQuery string

+ QualityRange string

+ Timeout string

+ URL string

+ Version string

+ type TelegrafInputPrometheusHttp struct

+ Duration string

+ Include []string

+ Interval string

+ Metric []*TelegrafInputPrometheusHttpMetric

+ Params string

+ Prefix string

+ SkipEmptyTags bool

+ Tags map[string]string

+ Timeout string

+ URL string

+ Version string

+ type TelegrafInputPrometheusHttpAvailability struct

+ Name string

+ Query string

+ Tags map[string]string

+ UniqueBy []string

+ type TelegrafInputPrometheusHttpMetric struct

+ Name string

+ Query string

+ Tags map[string]string

+ UniqueBy []string

+ type TelegrafInputs struct

+ PrometheusHttp []*TelegrafInputPrometheusHttp