watcher

Documentation

Index

• Variables
• type DefaultWatcher
  • func NewDefaultWatcher() *DefaultWatcher
  • func (dw *DefaultWatcher) Attach(et EventType, o Observer)
  • func (dw *DefaultWatcher) Detach(et EventType, o Observer)
  • func (dw *DefaultWatcher) Notify(et EventType, entity WatchMarshaller) error
  • func (dw *DefaultWatcher) OnEvent(et EventType, entity WatchMarshaller) error
• type DefaultWatcherManager
  • func NewDefaultWatcherManager(state bool) *DefaultWatcherManager
  • func (d *DefaultWatcherManager) AddWatcher(clusterId string, watcher Watcher)
  • func (d *DefaultWatcherManager) Disable()
  • func (d *DefaultWatcherManager) Enable()
  • func (d *DefaultWatcherManager) GetCluster(clusterId string) []Watcher
  • func (d *DefaultWatcherManager) GetState() bool
  • func (d *DefaultWatcherManager) Notify(clusterId string, et EventType, data WatchMarshaller) error
  • func (d *DefaultWatcherManager) RemoveCluster(clusterId string)
• type EventType
• type Manager
• type Observer
• type WatchMarshaller
• type Watcher

Variables

var ErrUnknownType = errors.New("unknown event type")

Types

type DefaultWatcher

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

func NewDefaultWatcher

func NewDefaultWatcher() *DefaultWatcher

func (*DefaultWatcher) Attach

func (dw *DefaultWatcher) Attach(et EventType, o Observer)

func (*DefaultWatcher) Detach

func (dw *DefaultWatcher) Detach(et EventType, o Observer)

func (*DefaultWatcher) Notify

func (dw *DefaultWatcher) Notify(et EventType, entity WatchMarshaller) error

func (*DefaultWatcher) OnEvent

func (dw *DefaultWatcher) OnEvent(et EventType, entity WatchMarshaller) error

type DefaultWatcherManager

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

func NewDefaultWatcherManager

func NewDefaultWatcherManager(state bool) *DefaultWatcherManager

func (*DefaultWatcherManager) AddWatcher

func (d *DefaultWatcherManager) AddWatcher(clusterId string, watcher Watcher)

func (*DefaultWatcherManager) Disable

func (d *DefaultWatcherManager) Disable()

func (*DefaultWatcherManager) Enable

func (d *DefaultWatcherManager) Enable()

func (*DefaultWatcherManager) GetCluster

func (d *DefaultWatcherManager) GetCluster(clusterId string) []Watcher

func (*DefaultWatcherManager) GetState

func (d *DefaultWatcherManager) GetState() bool

func (*DefaultWatcherManager) Notify

func (d *DefaultWatcherManager) Notify(clusterId string, et EventType, data WatchMarshaller) error

func (*DefaultWatcherManager) RemoveCluster

func (d *DefaultWatcherManager) RemoveCluster(clusterId string)

type EventType

type EventType string

const (
	EventTypeCreate         EventType = "create"
	EventTypeDelete         EventType = "remove"
	EventTypeUpdate         EventType = "update"
	EventTypeResolutionTime EventType = "resolution_time"
)

type Manager

type Manager interface {
	AddWatcher(clusterId string, watcher Watcher)
	RemoveCluster(clusterId string)
	GetCluster(clusterId string) []Watcher
	Notify(clusterId string, et EventType, data WatchMarshaller) error
	Enable()
	Disable()
	GetState() bool
}

type Observer

type Observer interface {
	Update(EventType, map[string]any) error
	GetId() string
}

type WatchMarshaller

type WatchMarshaller interface {
	GetArgs() map[string]any
}

type Watcher

type Watcher interface {
	Attach(EventType, Observer)
	Detach(EventType, Observer)
	OnEvent(EventType, WatchMarshaller) error
}