callback

Documentation

Index

• type App
  • func (e *App) Add(event *watch.Event)
  • func (e *App) AddEndpoint(end *config.Endpoint)
  • func (e *App) Delete(event *watch.Event)
  • func (e *App) Error(err error)
  • func (e *App) Modify(event *watch.Event)
  • func (e *App) Name() string
  • func (e *App) UpdateEndpoints(endpoints ...*config.Endpoint)
• type Builder
  • func (e *Builder) Error(err error)
  • func (e *Builder) Name() string
  • func (b *Builder) UpdateEndpoints(endpoints ...*config.Endpoint)
• type Cadvisor
  • func (c *Cadvisor) Add(event *watch.Event)
  • func (c *Cadvisor) AddEndpoint(end *config.Endpoint)
  • func (c *Cadvisor) Delete(event *watch.Event)
  • func (c *Cadvisor) Error(err error)
  • func (c *Cadvisor) Modify(event *watch.Event)
  • func (c *Cadvisor) Name() string
  • func (c *Cadvisor) UpdateEndpoints(endpoints ...*config.Endpoint)
• type Entrance
  • func (e *Entrance) Error(err error)
  • func (e *Entrance) Name() string
  • func (e *Entrance) UpdateEndpoints(endpoints ...*config.Endpoint)
• type Etcd
  • func (e *Etcd) Error(err error)
  • func (e *Etcd) Name() string
  • func (e *Etcd) UpdateEndpoints(endpoints ...*config.Endpoint)
• type EventLog
  • func (e *EventLog) Error(err error)
  • func (e *EventLog) Name() string
  • func (e *EventLog) UpdateEndpoints(endpoints ...*config.Endpoint)
• type Mq
  • func (m *Mq) Error(err error)
  • func (m *Mq) Name() string
  • func (m *Mq) UpdateEndpoints(endpoints ...*config.Endpoint)
• type Node
  • func (e *Node) Add(event *watch.Event)
  • func (e *Node) AddEndpoint(end *config.Endpoint)
  • func (e *Node) Delete(event *watch.Event)
  • func (e *Node) Error(err error)
  • func (e *Node) Modify(event *watch.Event)
  • func (e *Node) Name() string
  • func (e *Node) UpdateEndpoints(endpoints ...*config.Endpoint)
• type Prometheus
  • func (e *Prometheus) Error(err error)
  • func (e *Prometheus) Name() string
  • func (e *Prometheus) UpdateEndpoints(endpoints ...*config.Endpoint)
• type Webcli
  • func (w *Webcli) Error(err error)
  • func (w *Webcli) Name() string
  • func (w *Webcli) UpdateEndpoints(endpoints ...*config.Endpoint)
• type Worker
  • func (e *Worker) Error(err error)
  • func (e *Worker) Name() string
  • func (e *Worker) UpdateEndpoints(endpoints ...*config.Endpoint)

Types

type App

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

App 指app运行时信息，来源于所有子节点上的node 127.0.0.1:6100/app/metrics

func (*App) Add

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

Add add

func (*App) AddEndpoint

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

AddEndpoint add endpoint

func (*App) Delete

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

Delete Delete

func (*App) Error

func (e *App) Error(err error)

func (*App) Modify

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

Modify Modify

func (*App) Name

func (e *App) Name() string

func (*App) UpdateEndpoints

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

type Builder

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

func (*Builder) Error

func (e *Builder) Error(err error)

func (*Builder) Name

func (e *Builder) Name() string

func (*Builder) UpdateEndpoints

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

type Cadvisor

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

	ListenPort int
	// contains filtered or unexported fields
}

Cadvisor 指容器监控数据，来源于所有子节点上的kubelet 127.0.0.1:4194/metrics

func (*Cadvisor) Add

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

Add add

func (*Cadvisor) AddEndpoint

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

AddEndpoint add endpoint

func (*Cadvisor) Delete

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

Delete delete

func (*Cadvisor) Error

func (c *Cadvisor) Error(err error)

func (*Cadvisor) Modify

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

Modify update

func (*Cadvisor) Name

func (c *Cadvisor) Name() string

Name name

func (*Cadvisor) UpdateEndpoints

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

UpdateEndpoints update endpoint

type Entrance

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

func (*Entrance) Error

func (e *Entrance) Error(err error)

func (*Entrance) Name

func (e *Entrance) Name() string

func (*Entrance) UpdateEndpoints

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

type Etcd

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

func (*Etcd) Error

func (e *Etcd) Error(err error)

func (*Etcd) Name

func (e *Etcd) Name() string

func (*Etcd) UpdateEndpoints

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

type EventLog

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

func (*EventLog) Error

func (e *EventLog) Error(err error)

func (*EventLog) Name

func (e *EventLog) Name() string

func (*EventLog) UpdateEndpoints

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

type Mq

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

func (*Mq) Error

func (m *Mq) Error(err error)

func (*Mq) Name

func (m *Mq) Name() string

func (*Mq) UpdateEndpoints

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

type Node

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

func (*Node) Add

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

func (*Node) AddEndpoint

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

func (*Node) Delete

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

func (*Node) Error

func (e *Node) Error(err error)

func (*Node) Modify

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

func (*Node) Name

func (e *Node) Name() string

func (*Node) UpdateEndpoints

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

type Prometheus

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

Prometheus 指prometheus的运行指标，数据来源于prometheus自身API

func (*Prometheus) Error

func (e *Prometheus) Error(err error)

func (*Prometheus) Name

func (e *Prometheus) Name() string

func (*Prometheus) UpdateEndpoints

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

type Webcli

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

func (*Webcli) Error

func (w *Webcli) Error(err error)

func (*Webcli) Name

func (w *Webcli) Name() string

func (*Webcli) UpdateEndpoints

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

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