monitoring

Documentation

Index

• type Inspector
  • func NewInspector(events chan *docker.LogEvent, ctx context.Context, db *gorm.DB, ...) *Inspector
• type LogWatcher
  • func NewLogWatcher(clients map[string]docker.Client, db *gorm.DB) *LogWatcher
  • func (w *LogWatcher) RemoveTrigger(cid string, tid uint)
  • func (w *LogWatcher) TrackContainer(ctr models.MonitoredContainer)
• type Observable
  • func NewObservable() *Observable
  • func (o *Observable) Add(key string, value interface{})
  • func (o *Observable) Get(key string) (interface{}, bool)
  • func (o *Observable) RegisterListener(listener func(key string, value interface{}, action string))
  • func (o *Observable) Remove(key string)

Types

type Inspector

type Inspector struct {
	Events chan *docker.LogEvent
	// contains filtered or unexported fields
}

func NewInspector

func NewInspector(events chan *docker.LogEvent, ctx context.Context, db *gorm.DB, triggers []models.Trigger) *Inspector

type LogWatcher

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

func NewLogWatcher

func NewLogWatcher(clients map[string]docker.Client, db *gorm.DB) *LogWatcher

func (*LogWatcher) RemoveTrigger

func (w *LogWatcher) RemoveTrigger(cid string, tid uint)

func (*LogWatcher) TrackContainer

func (w *LogWatcher) TrackContainer(ctr models.MonitoredContainer)

type Observable

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

func NewObservable

func NewObservable() *Observable

func (*Observable) Add

func (o *Observable) Add(key string, value interface{})

func (*Observable) Get

func (o *Observable) Get(key string) (interface{}, bool)

func (*Observable) RegisterListener

func (o *Observable) RegisterListener(listener func(key string, value interface{}, action string))

func (*Observable) Remove

func (o *Observable) Remove(key string)