time

Documentation

Overview

Package time contains controllers managing time, synchronization, etc.

Index

• type NTPSyncer
• type NewNTPSyncerFunc
• type SyncController
  • func (ctrl *SyncController) Inputs() []controller.Input
  • func (ctrl *SyncController) Name() string
  • func (ctrl *SyncController) Outputs() []controller.Output
  • func (ctrl *SyncController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Types

type NTPSyncer

type NTPSyncer interface {
	Run(ctx context.Context)
	Synced() <-chan struct{}
	EpochChange() <-chan struct{}
	SetTimeServers([]string)
}

NTPSyncer interface is implemented by ntp.Syncer, interface for mocking.

type NewNTPSyncerFunc

type NewNTPSyncerFunc func(*zap.Logger, []string) NTPSyncer

NewNTPSyncerFunc function allows to replace ntp.Syncer with the mock.

type SyncController

type SyncController struct {
	V1Alpha1Mode v1alpha1runtime.Mode
	NewNTPSyncer NewNTPSyncerFunc
}

SyncController manages v1alpha1.TimeSync based on configuration and NTP sync process.

func (*SyncController) Inputs

func (ctrl *SyncController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*SyncController) Name

func (ctrl *SyncController) Name() string

Name implements controller.Controller interface.

func (*SyncController) Outputs

func (ctrl *SyncController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*SyncController) Run

func (ctrl *SyncController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.