callback

package
v0.0.0-...-a3a5c94 Latest Latest
Warning

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

 Go to latest Published: Aug 21, 2021 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type App 

type App struct {
	discover.Callback
	Prometheus *prometheus.Manager
	// contains filtered or unexported fields
}

App refers to app runtime information, which comes from node on all child nodes 127.0.0.1:6100/app/metrics

func (*App) Add 

func (e *App) Add(event *watch.Event)

Add

func (*App) AddEndpoint 

func (e *App) AddEndpoint(end *config.Endpoint)

AddEndpoint

func (*App) Delete 

func (e *App) Delete(event *watch.Event)

Delete

func (*App) Error 

func (e *App) Error(err error)

func (*App) Modify 

func (e *App) Modify(event *watch.Event)

Modify

func (*App) Name 

func (e *App) Name() string

Name

func (*App) UpdateEndpoints 

func (e *App) UpdateEndpoints(endpoints ...*config.Endpoint)

UpdateEndpoints update endpoint

type Builder 

type Builder struct {
	discover.Callback
	Prometheus *prometheus.Manager
	// contains filtered or unexported fields
}

Builder

func (*Builder) Error 

func (b *Builder) Error(err error)

Error handler

func (*Builder) Name 

func (b *Builder) Name() string

Name

func (*Builder) UpdateEndpoints 

func (b *Builder) UpdateEndpoints(endpoints ...*config.Endpoint)

UpdateEndpoints update endpoints

type Cadvisor 

type Cadvisor struct {
	discover.Callback
	Prometheus *prometheus.Manager

	ListenPort int
	// contains filtered or unexported fields
}

Cadvisor refers to container monitoring data, which comes from kubelet on all child nodes 127.0.0.1:4194/metrics

func (*Cadvisor) Add 

func (c *Cadvisor) Add(event *watch.Event)

Add

func (*Cadvisor) AddEndpoint 

func (c *Cadvisor) AddEndpoint(end *config.Endpoint)

AddEndpoint

func (*Cadvisor) Delete 

func (c *Cadvisor) Delete(event *watch.Event)

Delete

func (*Cadvisor) Error 

func (c *Cadvisor) Error(err error)

func (*Cadvisor) Modify 

func (c *Cadvisor) Modify(event *watch.Event)

Modify

func (*Cadvisor) Name 

func (c *Cadvisor) Name() string

Name

func (*Cadvisor) UpdateEndpoints 

func (c *Cadvisor) UpdateEndpoints(endpoints ...*config.Endpoint)

UpdateEndpoints

type Etcd 

type Etcd struct {
	discover.Callback
	Prometheus *prometheus.Manager
	Scheme     string
	TLSConfig  prometheus.TLSConfig
	// contains filtered or unexported fields
}

Etcd discover

func (*Etcd) Error 

func (e *Etcd) Error(err error)

func (*Etcd) Name 

func (e *Etcd) Name() string

Name

func (*Etcd) UpdateEndpoints 

func (e *Etcd) UpdateEndpoints(endpoints ...*config.Endpoint)

UpdateEndpoints

type EventLog 

type EventLog struct {
	discover.Callback
	Prometheus *prometheus.Manager
	// contains filtered or unexported fields
}

EventLog

func (*EventLog) Error 

func (e *EventLog) Error(err error)

func (*EventLog) Name 

func (e *EventLog) Name() string

Name

func (*EventLog) UpdateEndpoints 

func (e *EventLog) UpdateEndpoints(endpoints ...*config.Endpoint)

UpdateEndpoints

type GatewayNode 

type GatewayNode struct {
	discover.Callback
	Prometheus *prometheus.Manager
	// contains filtered or unexported fields
}

GatewayNode discover

func (*GatewayNode) AddEndpoint 

func (e *GatewayNode) AddEndpoint(end *config.Endpoint)

AddEndpoint

func (*GatewayNode) Error 

func (e *GatewayNode) Error(err error)

func (*GatewayNode) Name 

func (e *GatewayNode) Name() string

Name

func (*GatewayNode) UpdateEndpoints 

func (e *GatewayNode) UpdateEndpoints(endpoints ...*config.Endpoint)

UpdateEndpoints

type Mq 

type Mq struct {
	discover.Callback
	Prometheus *prometheus.Manager
	// contains filtered or unexported fields
}

Mq discover

func (*Mq) Error 

func (m *Mq) Error(err error)

func (*Mq) Name 

func (m *Mq) Name() string

Name

func (*Mq) UpdateEndpoints 

func (m *Mq) UpdateEndpoints(endpoints ...*config.Endpoint)

UpdateEndpoints

type Node 

type Node struct {
	discover.Callback
	Prometheus *prometheus.Manager
	// contains filtered or unexported fields
}

Node discover

func (*Node) Add 

func (e *Node) Add(event *watch.Event)

Add

func (*Node) AddEndpoint 

func (e *Node) AddEndpoint(end *config.Endpoint)

AddEndpoint

func (*Node) Delete 

func (e *Node) Delete(event *watch.Event)

Delete

func (*Node) Error 

func (e *Node) Error(err error)

func (*Node) Modify 

func (e *Node) Modify(event *watch.Event)

Modify

func (*Node) Name 

func (e *Node) Name() string

Name

func (*Node) UpdateEndpoints 

func (e *Node) UpdateEndpoints(endpoints ...*config.Endpoint)

UpdateEndpoints

type Prometheus 

type Prometheus struct {
	discover.Callback
	Prometheus *prometheus.Manager
	// contains filtered or unexported fields
}

Prometheus refers to the operating indicators of prometheus, and the data comes from prometheus' own API

func (*Prometheus) Error 

func (e *Prometheus) Error(err error)

Error

func (*Prometheus) Name 

func (e *Prometheus) Name() string

Name

func (*Prometheus) UpdateEndpoints 

func (e *Prometheus) UpdateEndpoints(endpoints ...*config.Endpoint)

UpdateEndpoints

type RbdAPI 

type RbdAPI struct {
	discover.Callback
	Prometheus *prometheus.Manager
	// contains filtered or unexported fields
}

RbdAPI rbd api metrics

func (*RbdAPI) Error 

func (b *RbdAPI) Error(err error)

Error handle error

func (*RbdAPI) Name 

func (b *RbdAPI) Name() string

Name

func (*RbdAPI) UpdateEndpoints 

func (b *RbdAPI) UpdateEndpoints(endpoints ...*config.Endpoint)

UpdateEndpoints update endpoint

type Webcli 

type Webcli struct {
	discover.Callback
	Prometheus *prometheus.Manager
	// contains filtered or unexported fields
}

Webcli

func (*Webcli) Error 

func (w *Webcli) Error(err error)

Error

func (*Webcli) Name 

func (w *Webcli) Name() string

Name

func (*Webcli) UpdateEndpoints 

func (w *Webcli) UpdateEndpoints(endpoints ...*config.Endpoint)

UpdateEndpoints

type Worker 

type Worker struct {
	discover.Callback
	Prometheus *prometheus.Manager
	// contains filtered or unexported fields
}

Worker worker monitor 127.0.0.1:6369/metrics

func (*Worker) Error 

func (e *Worker) Error(err error)

func (*Worker) Name 

func (e *Worker) Name() string

Name return name

func (*Worker) UpdateEndpoints 

func (e *Worker) UpdateEndpoints(endpoints ...*config.Endpoint)

UpdateEndpoints update endpoint

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.