monitor

Documentation

Index

• Constants
• type Monitor
  • func NewMonitor(c client.Client, ns string, log logr.Logger) *Monitor
  • func (m *Monitor) Start(ctx context.Context)
  • func (m *Monitor) Stop()
• type Worker
  • func NewWorker(c client.Client) *Worker
  • func (m *Worker) Start(ctx context.Context, ch <-chan types.NamespacedName)
  • func (m *Worker) WithLogger(log logr.Logger) *Worker

Constants

const (
	// DefaultMonitorQueueSize is the default size of the monitor queue.  Potentially
	// make this configurable in the future.
	DefaultMonitorQueueSize = 1000
	DefaultMonitorWorkers   = 1
	DefaultMonitorInterval  = 5 * time.Second
)

Types

type Monitor

type Monitor struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewMonitor

func NewMonitor(c client.Client, ns string, log logr.Logger) *Monitor

func (*Monitor) Start

func (m *Monitor) Start(ctx context.Context)

func (*Monitor) Stop

func (m *Monitor) Stop()

type Worker

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

func NewWorker

func NewWorker(c client.Client) *Worker

func (*Worker) Start

func (m *Worker) Start(ctx context.Context, ch <-chan types.NamespacedName)

func (*Worker) WithLogger

func (m *Worker) WithLogger(log logr.Logger) *Worker