callback

package
v3.6.1+incompatible Latest Latest
Warning

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

Go to latest
Published: Jul 11, 2018 License: LGPL-3.0 Imports: 10 Imported by: 6

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 指app运行时信息,来源于所有子节点上的node 127.0.0.1:6100/app/metrics

func (*App) Add

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

func (*App) AddEndpoint

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

func (*App) Delete

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

func (*App) Error

func (e *App) Error(err error)

func (*App) Modify

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

func (*App) Name

func (e *App) Name() string

func (*App) UpdateEndpoints

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

type AppStatus

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

AppStatus 指app性能数据,被选举为leader的worker,也就是app_sync_runtime_server所在的节点 127.0.0.1:6369/metrics

func (*AppStatus) Error

func (e *AppStatus) Error(err error)

func (*AppStatus) Name

func (e *AppStatus) Name() string

func (*AppStatus) UpdateEndpoints

func (e *AppStatus) UpdateEndpoints(endpoints ...*config.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 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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL