exporter

Documentation

Index

• Variables
• func GetInitiatedCollectors() map[string]Collector
• func IsNoDataError(err error) bool
• func NewApplicationCollector(cli *argo.Client) func(_ *log.Logger) (Collector, error)
• func NewCertCollectorFunc() func(*log.Logger) (Collector, error)
• func NewClusterCollector(agents *agents.ClientSet, db *database.Database) func(_ *log.Logger) (Collector, error)
• func NewEnvironmentCollector(db *database.Database) func(_ *log.Logger) (Collector, error)
• func NewPluginCollectorFunc(cluster cluster.Interface) func(*log.Logger) (Collector, error)
• type ApplicationCollector
  • func (c *ApplicationCollector) Update(ch chan<- prometheus.Metric) error
• type BaseCollector
  • func (n BaseCollector) Collect(ch chan<- prometheus.Metric)
  • func (n BaseCollector) Describe(ch chan<- *prometheus.Desc)
• type CertCollector
  • func (c *CertCollector) Update(ch chan<- prometheus.Metric) error
• type ClusterCollector
  • func (c *ClusterCollector) Update(ch chan<- prometheus.Metric) error
• type Collector
  • func NewCertCollector(_ *log.Logger) (Collector, error)
  • func NewPluginCollector(_ *log.Logger, clus cluster.Interface) (Collector, error)
• type Collectorfunc
  • func NewRequestCollector() Collectorfunc
  • func NewUserCollector(db *database.Database) Collectorfunc
• type EnvironmentCollector
  • func (c *EnvironmentCollector) Update(ch chan<- prometheus.Metric) error
• type Handler
  • func NewHandler(namespace string, collectors map[string]Collectorfunc) *Handler
  • func (h *Handler) Run(ctx context.Context, opts *gempro.ExporterOptions) error
  • func (h *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type PluginCollector
  • func (c *PluginCollector) Update(ch chan<- prometheus.Metric) error
• type RequestCollector
  • func GetRequestCollector() *RequestCollector
  • func (rc *RequestCollector) HandlerFunc() gin.HandlerFunc
  • func (rc *RequestCollector) Update(ch chan<- prometheus.Metric) error
• type UserCollector
  • func (c *UserCollector) Update(ch chan<- prometheus.Metric) error

Variables

var (
	MetricPath             = utils.StrOrDef(os.Getenv("METRIC_PATH"), "/metrics")
	IncludeExporterMetrics = false
	MaxRequests            = 40
)

var ErrNoData = errors.New("collector returned no data")

ErrNoData indicates the collector found no data to collect, but had no other error.

Functions

func GetInitiatedCollectors

func GetInitiatedCollectors() map[string]Collector

func IsNoDataError

func IsNoDataError(err error) bool

func NewApplicationCollector

func NewApplicationCollector(cli *argo.Client) func(_ *log.Logger) (Collector, error)

func NewCertCollectorFunc

func NewCertCollectorFunc() func(*log.Logger) (Collector, error)

func NewClusterCollector

func NewClusterCollector(agents *agents.ClientSet, db *database.Database) func(_ *log.Logger) (Collector, error)

func NewEnvironmentCollector

func NewEnvironmentCollector(db *database.Database) func(_ *log.Logger) (Collector, error)

func NewPluginCollectorFunc

func NewPluginCollectorFunc(cluster cluster.Interface) func(*log.Logger) (Collector, error)

Types

type ApplicationCollector

type ApplicationCollector struct {
	*argo.Client
	// contains filtered or unexported fields
}

func (*ApplicationCollector) Update

func (c *ApplicationCollector) Update(ch chan<- prometheus.Metric) error

type BaseCollector

type BaseCollector struct {
	Collectors map[string]Collector
	// contains filtered or unexported fields
}

BaseCollector implements the prometheus.Collector interface.

func (BaseCollector) Collect

func (n BaseCollector) Collect(ch chan<- prometheus.Metric)

Collect implements the prometheus.Collector interface.

func (BaseCollector) Describe

func (n BaseCollector) Describe(ch chan<- *prometheus.Desc)

Describe implements the prometheus.Collector interface.

type CertCollector

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

func (*CertCollector) Update

func (c *CertCollector) Update(ch chan<- prometheus.Metric) error

type ClusterCollector

type ClusterCollector struct {
	*database.Database
	// contains filtered or unexported fields
}

func (*ClusterCollector) Update

func (c *ClusterCollector) Update(ch chan<- prometheus.Metric) error

type Collector

type Collector interface {
	// Get new metrics and expose them via prometheus registry.
	Update(ch chan<- prometheus.Metric) error
}

Collector is the interface a collector has to implement.

func NewCertCollector

func NewCertCollector(_ *log.Logger) (Collector, error)

func NewPluginCollector

func NewPluginCollector(_ *log.Logger, clus cluster.Interface) (Collector, error)

type Collectorfunc

type Collectorfunc func(logger *log.Logger) (Collector, error)

func NewRequestCollector

func NewRequestCollector() Collectorfunc

func NewUserCollector

func NewUserCollector(db *database.Database) Collectorfunc

type EnvironmentCollector

type EnvironmentCollector struct {
	*database.Database
	// contains filtered or unexported fields
}

func (*EnvironmentCollector) Update

func (c *EnvironmentCollector) Update(ch chan<- prometheus.Metric) error

type Handler

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

Handler wraps an unfiltered http.Handler but uses a filtered Handler, created on the fly, if filtering is requested. Create instances with newHandler.

func NewHandler

func NewHandler(namespace string, collectors map[string]Collectorfunc) *Handler

func (*Handler) Run

func (h *Handler) Run(ctx context.Context, opts *gempro.ExporterOptions) error

func (*Handler) ServeHTTP

func (h *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request)

ServeHTTP implements http.Handler.

type PluginCollector

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

func (*PluginCollector) Update

func (c *PluginCollector) Update(ch chan<- prometheus.Metric) error

type RequestCollector

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

func GetRequestCollector

func GetRequestCollector() *RequestCollector

func (*RequestCollector) HandlerFunc

func (rc *RequestCollector) HandlerFunc() gin.HandlerFunc

func (*RequestCollector) Update

func (rc *RequestCollector) Update(ch chan<- prometheus.Metric) error

Update implements Collector

type UserCollector

type UserCollector struct {
	*database.Database
	// contains filtered or unexported fields
}

func (*UserCollector) Update

func (c *UserCollector) Update(ch chan<- prometheus.Metric) error