watcher

Documentation

Index

• type Container
• type ContainerWatcher
  • func (ContainerWatcher *ContainerWatcher) AddOrUpdate(groupidentifier string, container *Container)
  • func (ContainerWatcher *ContainerWatcher) Find(groupidentifier string) *Container
  • func (ContainerWatcher *ContainerWatcher) Remove(groupidentifier string)

Types

type Container

type Container struct {
	Container      platforms.IContainer
	Syncing        bool
	ContainerQueue chan platforms.IContainer      `json:"-"`
	ReadinessChan  chan *readiness.ReadinessState `json:"-"`
	DependencyChan chan *dependency.State         `json:"-"`
	Ctx            context.Context                `json:"-" `
	Cancel         context.CancelFunc             `json:"-"`
	Ticker         *time.Ticker                   `json:"-"`
	Logger         *zap.Logger
	User           *authentication.User `json:"-"`
}

type ContainerWatcher

type ContainerWatcher struct {
	Container    map[string]*Container
	EventChannel chan *types.Events
}

func (*ContainerWatcher) AddOrUpdate

func (ContainerWatcher *ContainerWatcher) AddOrUpdate(groupidentifier string, container *Container)

func (*ContainerWatcher) Find

func (ContainerWatcher *ContainerWatcher) Find(groupidentifier string) *Container

func (*ContainerWatcher) Remove

func (ContainerWatcher *ContainerWatcher) Remove(groupidentifier string)