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      *container.Container
	Syncing        bool
	ContainerQueue chan *container.Container      `json:"-"`
	ReadinessChan  chan *container.ReadinessState `json:"-"`
	DependencyChan chan *dependency.State         `json:"-"`
	Ctx            context.Context                `json:"-" `
	Cancel         context.CancelFunc             `json:"-"`
	Ticker         *time.Ticker                   `json:"-"`
	Logger         *zap.Logger
	EventChannel   chan *hub.Event
	User           *authentication.User `json:"-"`
}

type ContainerWatcher

type ContainerWatcher struct {
	Container map[string]*Container
}

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)