vendors

Documentation

Index

• type File
• type PrometheusDiscovery
  • func NewPrometheusDiscovery(name string, options PrometheusDiscoveryOptions, ...) *PrometheusDiscovery
  • func (pd *PrometheusDiscovery) Discover()
• type PrometheusDiscoveryOptions
• type PrometheusDiscoveryResponse
• type PrometheusDiscoveryResponseData
• type PrometheusDiscoveryResponseDataVector
• type PubSub
  • func NewPubSubPull(options PubSubOptions, observability *common.Observability) *PubSub
  • func (ps *PubSub) PubSubPull()
• type PubSubOptions

Types

type File

type File struct {
	Time time.Time   `json:"time"`
	Type string      `json:"type"`
	Data interface{} `json:"data"`
}

type PrometheusDiscovery

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

func NewPrometheusDiscovery

func NewPrometheusDiscovery(name string, options PrometheusDiscoveryOptions, observability *common.Observability) *PrometheusDiscovery

func (*PrometheusDiscovery) Discover

func (pd *PrometheusDiscovery) Discover()

type PrometheusDiscoveryOptions

type PrometheusDiscoveryOptions struct {
	Names        string
	URL          string
	Timeout      int
	Insecure     bool
	Query        string
	QueryPeriod  string
	QueryStep    string
	Metric       string
	Service      string
	Field        string
	Disabled     []string
	Schedule     string
	BaseTemplate string
	Vars         string

	Files string

	TelegrafLabels   string
	TelegrafTemplate string
	TelegrafChecksum bool
	TelegrafOptions  common.TelegrafConfigOptions
}

type PrometheusDiscoveryResponse

type PrometheusDiscoveryResponse struct {
	Status string                           `json:"status"`
	Data   *PrometheusDiscoveryResponseData `json:"data"`
}

type PrometheusDiscoveryResponseData

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

type PrometheusDiscoveryResponseDataVector

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

type PubSub

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

func NewPubSubPull

func NewPubSubPull(options PubSubOptions, observability *common.Observability) *PubSub

func (*PubSub) PubSubPull

func (ps *PubSub) PubSubPull()

type PubSubOptions

type PubSubOptions struct {
	Enabled                 bool
	Credentials             string
	ProjectID               string
	TopicID                 string
	SubscriptionName        string
	SubscriptionAckDeadline int
	SubscriptionRetention   int
	CMDBDir                 string
}