watch

Documentation

Index

• type ClusterWatcher
  • func NewClusterWatcher(pCtx context.Context, clusterId string, storage storage.Storage, zk zk.Zk, ...) *ClusterWatcher
  • func (cw *ClusterWatcher) Start(event chan *MetricEvent)
  • func (cw *ClusterWatcher) Stop()
• type EventType
  • func (et EventType) String() string
• type MetricEvent
• type StorageApplicationIf
• type StorageCollectorIf
• type StorageMetricIf
• type Watcher
  • func NewWatcher(storage storage.Storage, zk zk.Zk, config *config.Config) *Watcher
  • func (w *Watcher) Start() chan *MetricEvent
  • func (w *Watcher) Stop()

Types

type ClusterWatcher

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

func NewClusterWatcher

func NewClusterWatcher(pCtx context.Context, clusterId string, storage storage.Storage, zk zk.Zk, config *config.Config) *ClusterWatcher

func (*ClusterWatcher) Start

func (cw *ClusterWatcher) Start(event chan *MetricEvent)

func (*ClusterWatcher) Stop

func (cw *ClusterWatcher) Stop()

type EventType

type EventType int

const (
	EventMetricUpd EventType = iota
	EventMetricDel
	EventDynamicUpd
)

func (EventType) String

func (et EventType) String() string

type MetricEvent

type MetricEvent struct {
	ID     string
	Type   EventType
	Metric *types.Metric
	First  bool
	Last   bool
	Meta   map[string]btypes.ObjectMeta
}

type StorageApplicationIf

type StorageApplicationIf struct {
	Data string `json:"data"`
}

type StorageCollectorIf

type StorageCollectorIf struct {
	Data *types.ApplicationCollectorCfg `json:"data"`
}

type StorageMetricIf

type StorageMetricIf struct {
	ID   string        `json:"_id"`
	Data *types.Metric `json:"data"`
}

type Watcher

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

func NewWatcher

func NewWatcher(storage storage.Storage, zk zk.Zk, config *config.Config) *Watcher

func (*Watcher) Start

func (w *Watcher) Start() chan *MetricEvent

func (*Watcher) Stop

func (w *Watcher) Stop()