rainbond: github.com/goodrain/rainbond/monitor/callback Index | Files

package callback

import "github.com/goodrain/rainbond/monitor/callback"

Index

Package Files

app.go appstatus.go builder.go cadvisor.go etcd.go eventlog.go gateway.go mq.go node.go promethes.go webcli.go

type App Uses

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 Uses

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

Add add

func (*App) AddEndpoint Uses

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

AddEndpoint add endpoint

func (*App) Delete Uses

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

Delete Delete

func (*App) Error Uses

func (e *App) Error(err error)

func (*App) Modify Uses

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

Modify Modify

func (*App) Name Uses

func (e *App) Name() string

Name name

func (*App) UpdateEndpoints Uses

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

UpdateEndpoints update endpoint

type Builder Uses

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

Builder builder

func (*Builder) Error Uses

func (b *Builder) Error(err error)

Error handle error

func (*Builder) Name Uses

func (b *Builder) Name() string

Name name

func (*Builder) UpdateEndpoints Uses

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

UpdateEndpoints update endpoints

type Cadvisor Uses

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 Uses

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

Add add

func (*Cadvisor) AddEndpoint Uses

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

AddEndpoint add endpoint

func (*Cadvisor) Delete Uses

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

Delete delete

func (*Cadvisor) Error Uses

func (c *Cadvisor) Error(err error)

func (*Cadvisor) Modify Uses

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

Modify update

func (*Cadvisor) Name Uses

func (c *Cadvisor) Name() string

Name name

func (*Cadvisor) UpdateEndpoints Uses

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

UpdateEndpoints update endpoint

type Etcd Uses

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

Etcd etcd discover

func (*Etcd) Error Uses

func (e *Etcd) Error(err error)

func (*Etcd) Name Uses

func (e *Etcd) Name() string

Name name

func (*Etcd) UpdateEndpoints Uses

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

UpdateEndpoints update endpoints

type EventLog Uses

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

EventLog event log

func (*EventLog) Error Uses

func (e *EventLog) Error(err error)

func (*EventLog) Name Uses

func (e *EventLog) Name() string

Name name

func (*EventLog) UpdateEndpoints Uses

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

UpdateEndpoints update endpoint

type GatewayNode Uses

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

GatewayNode node discover

func (*GatewayNode) AddEndpoint Uses

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

AddEndpoint add endpoint

func (*GatewayNode) Error Uses

func (e *GatewayNode) Error(err error)

func (*GatewayNode) Name Uses

func (e *GatewayNode) Name() string

Name name

func (*GatewayNode) UpdateEndpoints Uses

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

UpdateEndpoints update endpoints

type Mq Uses

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

Mq discover

func (*Mq) Error Uses

func (m *Mq) Error(err error)

func (*Mq) Name Uses

func (m *Mq) Name() string

Name name

func (*Mq) UpdateEndpoints Uses

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

UpdateEndpoints update endpoint

type Node Uses

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

Node node discover

func (*Node) Add Uses

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

Add add

func (*Node) AddEndpoint Uses

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

AddEndpoint add endpoint

func (*Node) Delete Uses

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

Delete delete

func (*Node) Error Uses

func (e *Node) Error(err error)

func (*Node) Modify Uses

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

Modify modify

func (*Node) Name Uses

func (e *Node) Name() string

Name name

func (*Node) UpdateEndpoints Uses

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

UpdateEndpoints update endpoints

type Prometheus Uses

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

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

func (*Prometheus) Error Uses

func (e *Prometheus) Error(err error)

Error handle error

func (*Prometheus) Name Uses

func (e *Prometheus) Name() string

Name name

func (*Prometheus) UpdateEndpoints Uses

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

UpdateEndpoints update endpoint

type Webcli Uses

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

Webcli webcli

func (*Webcli) Error Uses

func (w *Webcli) Error(err error)

Error handle error

func (*Webcli) Name Uses

func (w *Webcli) Name() string

Name name

func (*Webcli) UpdateEndpoints Uses

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

UpdateEndpoints update endpoints

type Worker Uses

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 Uses

func (e *Worker) Error(err error)

func (*Worker) Name Uses

func (e *Worker) Name() string

Name return name

func (*Worker) UpdateEndpoints Uses

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

UpdateEndpoints update endpoint

Package callback imports 11 packages (graph) and is imported by 1 packages. Updated 2019-05-12. Refresh now. Tools for package owners.