watcher

Documentation

Index

• type Container
  • func New(containerObj platforms.IContainer, startState string, ...) *Container
• type Containers
  • func (ContainerWatcher *Containers) AddOrUpdate(groupidentifier string, container *Container)
  • func (ContainerWatcher *Containers) Find(groupidentifier string) *Container
  • func (ContainerWatcher *Containers) 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:"-" `
	Done           bool                           `json:"-"`
	Cancel         context.CancelFunc             `json:"-"`
	Ticker         *time.Ticker                   `json:"-"`
	Retry          int                            `json:"-"`
	Logger         *zap.Logger
	User           *authentication.User `json:"-"`
}

func New

func New(containerObj platforms.IContainer, startState string, user *authentication.User) *Container

type Containers

type Containers struct {
	Watchers map[string]*Container
}

func (*Containers) AddOrUpdate

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

func (*Containers) Find

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

func (*Containers) Remove

func (ContainerWatcher *Containers) Remove(groupidentifier string)