watcher

Documentation

Index

• type Watcher
  • func New(log *slog.Logger, d deployer.Deployer, cfg config.Sync) *Watcher
  • func (w *Watcher) QueueOperations(ops []models.PodOperation)
  • func (w *Watcher) Start()
  • func (w *Watcher) Stop()

Types

type Watcher

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

func New

func New(log *slog.Logger, d deployer.Deployer, cfg config.Sync) *Watcher

func (*Watcher) QueueOperations

func (w *Watcher) QueueOperations(ops []models.PodOperation)

QueueOperations заносит операции в очередь на выполнение.

func (*Watcher) Start

func (w *Watcher) Start()

func (*Watcher) Stop

func (w *Watcher) Stop()

Stop отправляет сигнал об остановке и ожидает ответного сигнала об остановке.

TODO: Добавить context.Context остановки.