discovery

package
v0.8.6 Latest Latest
Warning

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

 Go to latest Published: Mar 29, 2024 License: MIT Imports: 24 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	PubSubMessagePayloadKindUnknown int = iota
	PubSubMessagePayloadKindFile
	PubSubMessagePayloadKindFiles
)
View Source 
const (
	PubSubMessagePayloadCompressionNone int = iota
	PubSubMessagePayloadCompressionGZip
)

Variables

This section is empty.

Functions

This section is empty.

Types

type AWSEC2 added in v0.6.15 

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

func NewAWSEC2 added in v0.6.15 

func NewAWSEC2(options AWSEC2Options, observability *common.Observability, sinks *common.Sinks) *AWSEC2

func (*AWSEC2) Discover added in v0.6.15 

func (o *AWSEC2) Discover()

func (*AWSEC2) Name added in v0.6.15 

func (o *AWSEC2) Name() string

func (*AWSEC2) Source added in v0.6.15 

func (o *AWSEC2) Source() string

type AWSEC2Options added in v0.6.15 

type AWSEC2Options struct {
	Schedule string
	AWSOptions
}

type AWSEC2SinkObject added in v0.6.15 

type AWSEC2SinkObject struct {
	EC2 *AWSEC2
	// contains filtered or unexported fields
}

func (*AWSEC2SinkObject) Map added in v0.6.15 

func (os *AWSEC2SinkObject) Map() common.SinkMap

func (*AWSEC2SinkObject) Options added in v0.6.15 

func (os *AWSEC2SinkObject) Options() interface{}

type AWSOptions added in v0.6.15 

type AWSOptions struct {
	toolsVendors.AWSKeys
}

type Cert added in v0.5.17 

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

func NewCert added in v0.5.17 

func NewCert(source string, prometheusOptions common.PrometheusOptions, options CertOptions, observability *common.Observability, sinks *common.Sinks) *Cert

func (*Cert) Discover added in v0.5.17 

func (c *Cert) Discover()

func (*Cert) Name added in v0.6.0 

func (c *Cert) Name() string

func (*Cert) Source added in v0.6.0 

func (c *Cert) Source() string

type CertOptions added in v0.5.17 

type CertOptions struct {
	Query       string
	QueryPeriod string
	QueryStep   string
	Schedule    string
	Pattern     string
	Names       string
	Exclusion   string
}

type CertSinkObject added in v0.6.0 

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

func (*CertSinkObject) Map added in v0.6.0 

func (cs *CertSinkObject) Map() common.SinkMap

func (*CertSinkObject) Options added in v0.6.0 

func (cs *CertSinkObject) Options() interface{}

type DNS 

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

func NewDNS 

func NewDNS(source string, prometheusOptions common.PrometheusOptions, options DNSOptions, observability *common.Observability, sinks *common.Sinks) *DNS

func (*DNS) Discover 

func (d *DNS) Discover()

func (*DNS) Name added in v0.6.0 

func (d *DNS) Name() string

func (*DNS) Source added in v0.6.0 

func (d *DNS) Source() string

type DNSOptions 

type DNSOptions struct {
	Query       string
	QueryPeriod string
	QueryStep   string
	Schedule    string
	Pattern     string
	Names       string
	Exclusion   string
}

type DNSSinkObject added in v0.6.0 

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

func (*DNSSinkObject) Map added in v0.6.0 

func (ds *DNSSinkObject) Map() common.SinkMap

func (*DNSSinkObject) Options added in v0.6.0 

func (ds *DNSSinkObject) Options() interface{}

type Dumb added in v0.6.10 

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

Dumb is a discovery that sends test data to sinks

func NewDumb added in v0.6.10 

func NewDumb(options DumbOptions, obs *common.Observability, sinks *common.Sinks) *Dumb

func (*Dumb) Discover added in v0.6.10 

func (d *Dumb) Discover()

func (*Dumb) Name added in v0.6.10 

func (d *Dumb) Name() string

func (*Dumb) Source added in v0.6.10 

func (d *Dumb) Source() string

type DumbOptions added in v0.6.10 

type DumbOptions struct {
	Enabled   bool
	LabelsMap common.LabelsMap
	Schedule  string
}

type DumbSinkObject added in v0.6.10 

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

func (*DumbSinkObject) Map added in v0.6.10 

func (d *DumbSinkObject) Map() common.SinkMap

func (*DumbSinkObject) Options added in v0.6.10 

func (d *DumbSinkObject) Options() interface{}

type HTTP added in v0.5.9 

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

func NewHTTP added in v0.5.9 

func NewHTTP(source string, prometheusOptions common.PrometheusOptions, options HTTPOptions, observability *common.Observability, sinks *common.Sinks) *HTTP

func (*HTTP) Discover added in v0.5.9 

func (h *HTTP) Discover()

func (*HTTP) Name added in v0.6.0 

func (h *HTTP) Name() string

func (*HTTP) Source added in v0.6.0 

func (h *HTTP) Source() string

type HTTPOptions added in v0.5.9 

type HTTPOptions struct {
	Query       string
	QueryPeriod string
	QueryStep   string
	Schedule    string
	Pattern     string
	Names       string
	Exclusion   string
	NoSSL       string
	Path        string
}

type HTTPSinkObject added in v0.6.0 

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

func (*HTTPSinkObject) Map added in v0.6.0 

func (hs *HTTPSinkObject) Map() common.SinkMap

func (*HTTPSinkObject) Options added in v0.6.0 

func (hs *HTTPSinkObject) Options() interface{}

type K8s added in v0.6.6 

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

func NewK8s added in v0.6.6 

func NewK8s(options K8sOptions, obs *common.Observability, sinks *common.Sinks) *K8s

func (*K8s) Discover added in v0.6.6 

func (k *K8s) Discover()

func (*K8s) Name added in v0.6.6 

func (k *K8s) Name() string

func (*K8s) Source added in v0.6.6 

func (k *K8s) Source() string

type K8sOptions added in v0.6.6 

type K8sOptions struct {
	Schedule       string
	ClusterName    string
	NsInclude      []string
	NsExclude      []string
	AppLabel       string
	ComponentLabel string
	InstanceLabel  string
	CommonLabels   map[string]string
	SkipUnknown    bool
	Environment    string
}

type K8sSinkObject added in v0.6.6 

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

func (*K8sSinkObject) Map added in v0.6.6 

func (kso *K8sSinkObject) Map() common.SinkMap

func (*K8sSinkObject) Options added in v0.6.6 

func (kso *K8sSinkObject) Options() interface{}

type Observium added in v0.5.19 

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

func NewObservium added in v0.5.19 

func NewObservium(options ObserviumOptions, observability *common.Observability, sinks *common.Sinks) *Observium

func (*Observium) Discover added in v0.5.19 

func (o *Observium) Discover()

func (*Observium) Name added in v0.6.0 

func (o *Observium) Name() string

func (*Observium) Source added in v0.6.0 

func (o *Observium) Source() string

type ObserviumDevice added in v0.6.0 

type ObserviumDevice struct {
	Name   string `json:"sysName"`
	Host   string `json:"hostname"`
	IP     string `json:"ip"`
	Vendor string `json:"vendor"`
}

type ObserviumDeviceResponse added in v0.6.0 

type ObserviumDeviceResponse struct {
	Status  string                     `json:"status"`
	Count   int                        `json:"count"`
	Devices map[string]ObserviumDevice `json:"devices"`
}

type ObserviumOptions added in v0.5.19 

type ObserviumOptions struct {
	toolsVendors.ObserviumOptions
	Schedule string
}

type ObserviumSinkObject added in v0.6.0 

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

func (*ObserviumSinkObject) Map added in v0.6.0 

func (os *ObserviumSinkObject) Map() common.SinkMap

func (*ObserviumSinkObject) Options added in v0.6.0 

func (os *ObserviumSinkObject) Options() interface{}

type PubSub 

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

func NewPubSub 

func NewPubSub(source string, options PubSubOptions, observability *common.Observability, sinks *common.Sinks) *PubSub

func (*PubSub) Discover 

func (ps *PubSub) Discover()

func (*PubSub) Name added in v0.6.0 

func (ps *PubSub) Name() string

func (*PubSub) Source added in v0.6.0 

func (ps *PubSub) Source() string

type PubSubMessage added in v0.8.1 

type PubSubMessage struct {
	Payload map[string]*PubSubMessagePayload `json:"payload"`
}

type PubSubMessagePayload added in v0.8.1 

type PubSubMessagePayload struct {
	Kind        PubSubMessagePayloadKind        `json:"kind"`
	Compression PubSubMessagePayloadCompression `json:"compression"`
	Data        []byte                          `json:"data"`
}

type PubSubMessagePayloadCompression added in v0.8.5 

type PubSubMessagePayloadCompression = int

type PubSubMessagePayloadFile added in v0.8.1 

type PubSubMessagePayloadFile struct {
	Path string `json:"path"`
	Data []byte `json:"data"`
}

type PubSubMessagePayloadFiles added in v0.8.5 

type PubSubMessagePayloadFiles = []*PubSubMessagePayloadFile

type PubSubMessagePayloadKind added in v0.8.1 

type PubSubMessagePayloadKind = int

type PubSubOptions 

type PubSubOptions struct {
	Credentials  string
	Project      string
	Topic        string
	Subscription string
	AckDeadline  int
	Retention    int
}

type PubSubSinkObject added in v0.8.1 

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

func (*PubSubSinkObject) Map added in v0.8.1 

func (so *PubSubSinkObject) Map() common.SinkMap

func (*PubSubSinkObject) Options added in v0.8.1 

func (so *PubSubSinkObject) Options() interface{}

type Signal 

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

func NewSignal 

func NewSignal(source string, prometheusOptions common.PrometheusOptions, options SignalOptions, observability *common.Observability, sinks *common.Sinks) *Signal

func (*Signal) Discover 

func (s *Signal) Discover()

func (*Signal) Name added in v0.6.0 

func (s *Signal) Name() string

func (*Signal) Source added in v0.6.0 

func (s *Signal) Source() string

type SignalOptions 

type SignalOptions struct {
	URL          string
	User         string
	Password     string
	Disabled     []string
	Schedule     string
	Query        string
	QueryPeriod  string
	QueryStep    string
	Metric       string
	Application  string
	Field        string
	BaseTemplate string
	Vars         string
	Files        string
}

type SignalSinkObject added in v0.6.0 

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

func (*SignalSinkObject) Map added in v0.6.0 

func (ss *SignalSinkObject) Map() common.SinkMap

func (*SignalSinkObject) Options added in v0.6.0 

func (ss *SignalSinkObject) Options() interface{}

type TCP added in v0.5.10 

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

func NewTCP added in v0.5.10 

func NewTCP(source string, prometheusOptions common.PrometheusOptions, options TCPOptions, observability *common.Observability, sinks *common.Sinks) *TCP

func (*TCP) Discover added in v0.5.10 

func (t *TCP) Discover()

func (*TCP) Name added in v0.6.0 

func (t *TCP) Name() string

func (*TCP) Source added in v0.6.0 

func (t *TCP) Source() string

type TCPOptions added in v0.5.10 

type TCPOptions struct {
	Query       string
	QueryPeriod string
	QueryStep   string
	Schedule    string
	Pattern     string
	Names       string
	Exclusion   string
	NoSSL       string
}

type TCPSinkObject added in v0.6.0 

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

func (*TCPSinkObject) Map added in v0.6.0 

func (ts *TCPSinkObject) Map() common.SinkMap

func (*TCPSinkObject) Options added in v0.6.0 

func (ts *TCPSinkObject) Options() interface{}

type VCenter added in v0.6.7 

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

func NewVCenter added in v0.6.7 

func NewVCenter(options VCenterOptions, observability *common.Observability, sinks *common.Sinks) *VCenter

func (*VCenter) Discover added in v0.6.7 

func (vc *VCenter) Discover()

func (*VCenter) Name added in v0.6.7 

func (vc *VCenter) Name() string

func (*VCenter) Source added in v0.6.7 

func (vc *VCenter) Source() string

type VCenterCluster added in v0.6.7 

type VCenterCluster struct {
	Cluster string `json:"cluster"`
	Name    string `json:"name"`
	// contains filtered or unexported fields
}

type VCenterClusterResponse added in v0.6.7 

type VCenterClusterResponse struct {
	Value []*VCenterCluster `json:"value"`
}

type VCenterHost added in v0.6.7 

type VCenterHost struct {
	Host string `json:"host"`
	Name string `json:"name"`
	// contains filtered or unexported fields
}

type VCenterHostResponse added in v0.6.7 

type VCenterHostResponse struct {
	Value []*VCenterHost `json:"value"`
}

type VCenterOptions added in v0.6.7 

type VCenterOptions struct {
	toolsVendors.VCenterOptions
	Schedule string
}

type VCenterSinkObject added in v0.6.7 

type VCenterSinkObject struct {
	VCenter *VCenter
	// contains filtered or unexported fields
}

func (*VCenterSinkObject) Map added in v0.6.7 

func (os *VCenterSinkObject) Map() common.SinkMap

func (*VCenterSinkObject) Options added in v0.6.7 

func (os *VCenterSinkObject) Options() interface{}

type VCenterVM added in v0.6.7 

type VCenterVM struct {
	VM   string `json:"vm"`
	Name string `json:"name"`
	// contains filtered or unexported fields
}

type VCenterVMGuestIdentity added in v0.6.7 

type VCenterVMGuestIdentity struct {
	FullName *VCenterVMGuestIdentityFullName `json:"full_name"`
	IP       string                          `json:"ip_address"`
	Host     string                          `json:"host_name"`
	Family   string                          `json:"family"`
}

type VCenterVMGuestIdentityFullName added in v0.6.7 

type VCenterVMGuestIdentityFullName struct {
	OS string `json:"default_message"`
}

type VCenterVMGuestIdentityResponse added in v0.6.7 

type VCenterVMGuestIdentityResponse struct {
	Value *VCenterVMGuestIdentity `json:"value"`
}

type VCenterVMResponse added in v0.6.7 

type VCenterVMResponse struct {
	Value []*VCenterVM `json:"value"`
}

type Zabbix added in v0.6.3 

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

func NewZabbix added in v0.6.3 

func NewZabbix(options ZabbixOptions, observability *common.Observability, sinks *common.Sinks) *Zabbix

func (*Zabbix) Discover added in v0.6.3 

func (o *Zabbix) Discover()

func (*Zabbix) Name added in v0.6.3 

func (o *Zabbix) Name() string

func (*Zabbix) Source added in v0.6.3 

func (o *Zabbix) Source() string

type ZabbixHost added in v0.6.3 

type ZabbixHost struct {
	Name       string                 `json:"name"`
	Host       string                 `json:"host"`
	Inventory  any                    `json:"inventory"`
	Interfaces []*ZabbixHostInterface `json:"interfaces"`
}

type ZabbixHostGetResponse added in v0.6.3 

type ZabbixHostGetResponse struct {
	Result []*ZabbixHost `json:"result"`
}

type ZabbixHostInterface added in v0.6.3 

type ZabbixHostInterface struct {
	IP  string `json:"ip"`
	Dns string `json:"dns"`
}

type ZabbixOptions added in v0.6.3 

type ZabbixOptions struct {
	toolsVendors.ZabbixOptions
	Schedule string
}

type ZabbixSinkObject added in v0.6.3 

type ZabbixSinkObject struct {
	Zabbix *Zabbix
	// contains filtered or unexported fields
}

func (*ZabbixSinkObject) Map added in v0.6.3 

func (os *ZabbixSinkObject) Map() common.SinkMap

func (*ZabbixSinkObject) Options added in v0.6.3 

func (os *ZabbixSinkObject) Options() interface{}

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.