entities

Documentation

Index

• type EntitiesWatcher
  • func NewEntitiesWatcher(observer_ *kuber.Observer, version int) *EntitiesWatcher
  • func (ew *EntitiesWatcher) AddResourceEventsHandler(handler ResourceEventsHandler)
  • func (ew *EntitiesWatcher) GetAllEntitiesByGvrk() (map[kuber.GroupVersionResourceKind][]unstructured.Unstructured, []error)
  • func (ew *EntitiesWatcher) GetParents(namespace string, kind string, name string) (*kuber.ParentController, bool)
  • func (ew *EntitiesWatcher) OnAdd(gvrk kuber.GroupVersionResourceKind, obj unstructured.Unstructured)
  • func (ew *EntitiesWatcher) OnDelete(gvrk kuber.GroupVersionResourceKind, obj unstructured.Unstructured)
  • func (ew *EntitiesWatcher) OnUpdate(gvrk kuber.GroupVersionResourceKind, oldObj, newObj unstructured.Unstructured)
  • func (ew *EntitiesWatcher) SetDeltasHandler(handler agent.DeltasHandler)
  • func (ew *EntitiesWatcher) SetEntitiesResyncHandler(handler agent.EntitiesResyncHandler)
  • func (ew *EntitiesWatcher) Start(ctx context.Context) error
  • func (ew *EntitiesWatcher) Stop() error
  • func (ew *EntitiesWatcher) WaitForCacheSync()
  • func (ew *EntitiesWatcher) WatcherFor(gvrk kuber.GroupVersionResourceKind) (kuber.Watcher, error)
• type EntitiesWatcherSource
• type ResourceEventsHandler

Types

type EntitiesWatcher

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

func NewEntitiesWatcher

func NewEntitiesWatcher(
	observer_ *kuber.Observer,
	version int,
) *EntitiesWatcher

func (*EntitiesWatcher) AddResourceEventsHandler

func (ew *EntitiesWatcher) AddResourceEventsHandler(handler ResourceEventsHandler)

func (*EntitiesWatcher) GetAllEntitiesByGvrk

func (ew *EntitiesWatcher) GetAllEntitiesByGvrk() (map[kuber.GroupVersionResourceKind][]unstructured.Unstructured, []error)

func (*EntitiesWatcher) GetParents

func (ew *EntitiesWatcher) GetParents(namespace string, kind string, name string) (*kuber.ParentController, bool)

func (*EntitiesWatcher) OnAdd

func (ew *EntitiesWatcher) OnAdd(
	gvrk kuber.GroupVersionResourceKind,
	obj unstructured.Unstructured,
)

func (*EntitiesWatcher) OnDelete

func (ew *EntitiesWatcher) OnDelete(
	gvrk kuber.GroupVersionResourceKind,
	obj unstructured.Unstructured,
)

func (*EntitiesWatcher) OnUpdate

func (ew *EntitiesWatcher) OnUpdate(
	gvrk kuber.GroupVersionResourceKind,
	oldObj, newObj unstructured.Unstructured,
)

func (*EntitiesWatcher) SetDeltasHandler

func (ew *EntitiesWatcher) SetDeltasHandler(handler agent.DeltasHandler)

func (*EntitiesWatcher) SetEntitiesResyncHandler

func (ew *EntitiesWatcher) SetEntitiesResyncHandler(handler agent.EntitiesResyncHandler)

func (*EntitiesWatcher) Start

func (ew *EntitiesWatcher) Start(ctx context.Context) error

func (*EntitiesWatcher) Stop

func (ew *EntitiesWatcher) Stop() error

func (*EntitiesWatcher) WaitForCacheSync

func (ew *EntitiesWatcher) WaitForCacheSync()

func (*EntitiesWatcher) WatcherFor

func (ew *EntitiesWatcher) WatcherFor(
	gvrk kuber.GroupVersionResourceKind,
) (kuber.Watcher, error)

type EntitiesWatcherSource

type EntitiesWatcherSource interface {
	AddResourceEventsHandler(handler ResourceEventsHandler)
	GetAllEntitiesByGvrk() (map[kuber.GroupVersionResourceKind][]unstructured.Unstructured, []error)
	GetParents(namespace string, kind string, name string) (*kuber.ParentController, bool)
}

type ResourceEventsHandler

type ResourceEventsHandler interface {
	OnResourceAdd(gvrk kuber.GroupVersionResourceKind, obj unstructured.Unstructured)
	OnResourceUpdate(gvrk kuber.GroupVersionResourceKind, oldObj, newObj unstructured.Unstructured)
	OnResourceDelete(gvrk kuber.GroupVersionResourceKind, obj unstructured.Unstructured)
	OnCacheSync()
}