common

package
v0.13.2 Latest Latest
Warning

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

 Go to latest Published: Sep 27, 2024 License: MIT Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AppendHostSink added in v0.6.0 

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

func FileMD5 

func FileMD5(path string) []byte

func FileMd5ToString added in v0.9.0 

func FileMd5ToString(path string) string

func FileWriteWithCheckSum added in v0.8.1 

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

func FilterStringMap added in v0.6.0 

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

func GetBaseConfigKeys added in v0.0.5 

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

func GetFileKeys added in v0.3.15 

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

func GetLabelsKeys added in v0.5.10 

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

func GetStringKeys added in v0.0.5 

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

func IfDef 

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

func Md5 added in v0.9.0 

func Md5(b []byte) []byte

func Md5ToString added in v0.9.0 

func Md5ToString(b []byte) string

func MergeInterfacegMaps added in v0.3.6 

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

func MergeStringMaps added in v0.3.6 

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

func ParsePeriodFromNow added in v0.5.3 

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

func ReadFile added in v0.11.0 

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

func ReadFiles 

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

func ReadJson added in v0.11.0 

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

func ReadToml added in v0.11.0 

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

func ReadYaml added in v0.11.0 

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

func RemoveEmptyStrings added in v0.6.0 

func RemoveEmptyStrings(items []string) []string

func Render added in v0.5.3 

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

func RenderTemplate 

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

func SortStringMapByKeys added in v0.0.5 

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

func StringContainsAny added in v0.3.13 

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

func StringInArr 

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

func StringSliceToMap added in v0.6.8 

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

Types

type BaseAvailability 

type BaseAvailability struct {
	Disabled bool                     `yaml:"disabled"`
	Queries  []*BaseAvailabilityQuery `yaml:"queries"`
	GroupBy  []string                 `yaml:"group_by"`
	Labels   Labels                   `yaml:"labels"`
}

type BaseAvailabilityQuery 

type BaseAvailabilityQuery struct {
	Query     string      `yaml:"query"`
	Round     *int        `yaml:"round"`
	Suffix    string      `yaml:"suffix"`
	Weight    interface{} `yaml:"weight"`
	Labels    Labels      `yaml:"labels"`
	UseCRD    string      `yaml:"crd"`
	Composite string      `yaml:"composite"`
	Source    string      `yaml:"source"`
	Timeout   string      `yaml:"timeout"`
}

type BaseCondition added in v0.3.5 

type BaseCondition struct {
	Metric string `yaml:"metric"`
	Labels Labels `yaml:"labels"`
}

type BaseConfig 

type BaseConfig struct {
	Disabled     bool              `yaml:"disabled"`
	Prefix       string            `yaml:"prefix"`
	Vars         map[string]string `yaml:"vars"`
	Labels       Labels            `yaml:"labels"`
	Conditions   []*BaseCondition  `yaml:"if"`
	Filters      []*BaseCondition  `yaml:"not"`
	Qualities    []*BaseQuality    `yaml:"quality"`
	Metrics      []*BaseMetric     `yaml:"metrics"`
	Availability *BaseAvailability `yaml:"availability"`
}

func (*BaseConfig) Contains added in v0.3.18 

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

func (*BaseConfig) LabelsExist added in v0.3.5 

func (bc *BaseConfig) LabelsExist(c *BaseCondition, labels Labels) bool

func (*BaseConfig) MetricExists 

func (bc *BaseConfig) MetricExists(query string, labels Labels) bool

type BaseMetric 

type BaseMetric struct {
	Disabled bool     `yaml:"disabled"`
	Query    string   `yaml:"query"`
	Name     string   `yaml:"name"`
	Round    *int     `yaml:"round"`
	UniqueBy []string `yaml:"unique_by"`
	Labels   Labels   `yaml:"labels"`
}

type BaseQuality 

type BaseQuality struct {
	Range  string `yaml:"range"`
	Every  string `yaml:"every"`
	Points int    `yaml:"points"`
	Query  string `yaml:"query"`
}

type Discovery added in v0.5.3 

type Discovery interface {
	Discover()
	Name() string
	Source() string
}

type File added in v0.3.2 

type File struct {
	Path string
	Type string
	Obj  interface{}
}

type Files added in v0.6.0 

type Files map[string]*File

type HostSink added in v0.6.0 

type HostSink struct {
	IP      string
	Host    string
	Vendor  string
	OS      string
	Cluster string
	Server  string
}

type Labels added in v0.5.3 

type Labels map[string]string

func MergeLabels added in v0.6.8 

func MergeLabels(labels ...Labels) Labels

func ReplaceLabelValues added in v0.10.1 

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

type LabelsMap added in v0.6.0 

type LabelsMap map[string]Labels

func ConvertSinkMapToLabelsMap added in v0.10.0 

func ConvertSinkMapToLabelsMap(m SinkMap) LabelsMap

type Object added in v0.9.0 

type Object struct {
	Metrics []string
	Configs map[string]*BaseConfig
	//	Labels  Labels
	Vars  map[string]string
	Files Files
}

type Objects added in v0.9.0 

type Objects map[string]*Object

func ConvertSinkMapToObjects added in v0.10.0 

func ConvertSinkMapToObjects(m SinkMap) Objects

type Observability 

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

func NewObservability 

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

func (*Observability) Debug 

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

func (*Observability) Error 

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

func (*Observability) Info 

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

func (*Observability) Logs 

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

func (*Observability) Metrics 

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

func (*Observability) Warn 

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

type Processor added in v0.11.0 

type Processor interface {
	Process(d Discovery, so SinkObject)
	Name() string
	Providers() []string
}

type Processors added in v0.11.0 

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

func NewProcessors added in v0.11.0 

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

func (*Processors) Add added in v0.11.0 

func (ps *Processors) Add(p Processor)

func (*Processors) Process added in v0.11.0 

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

type PromDiscoveryObject added in v0.5.16 

type PromDiscoveryObject struct {
	Name     string
	URL      string
	User     string
	Password string
}

func GetPrometheusDiscoveriesByInstances added in v0.5.3 

func GetPrometheusDiscoveriesByInstances(names string, logger sreCommon.Logger) []PromDiscoveryObject

prometheus=prometheus.service.svc:9090, victoria=https://user:pass@victoria.some.where, source2=http://prometheus.location

type PrometheusOptions added in v0.5.3 

type PrometheusOptions struct {
	Names    string
	URL      string
	User     string
	Password string
	Timeout  int
	Insecure bool
}

type PrometheusResponse added in v0.5.3 

type PrometheusResponse struct {
	Status string                  `json:"status"`
	Data   *PrometheusResponseData `json:"data"`
}

type PrometheusResponseData added in v0.5.3 

type PrometheusResponseData struct {
	ResultType string                          `json:"resultType"`
	Result     []*PrometheusResponseDataVector `json:"result"`
}

type PrometheusResponseDataVector added in v0.5.3 

type PrometheusResponseDataVector struct {
	Labels map[string]string `json:"metric"`
}

type Sink added in v0.6.0 

type Sink interface {
	Process(d Discovery, so SinkObject)
	Name() string
	Providers() []string
}

type SinkMap added in v0.6.0 

type SinkMap map[string]interface{}

func ConvertLabelsMapToSinkMap added in v0.6.0 

func ConvertLabelsMapToSinkMap(m LabelsMap) SinkMap

func ConvertObjectsToSinkMap added in v0.9.0 

func ConvertObjectsToSinkMap(m Objects) SinkMap

type SinkObject added in v0.6.0 

type SinkObject interface {
	Map() SinkMap
	Options() interface{}
}

type Sinks added in v0.6.0 

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

func NewSinks added in v0.6.0 

func NewSinks(observability *Observability) *Sinks

func (*Sinks) Add added in v0.6.0 

func (ss *Sinks) Add(s Sink)

func (*Sinks) Process added in v0.6.0 

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

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.