upgradecheck

Documentation

Index

• func ManagedScheduler(m manager.Manager, openshift bool, url, version string) error
• type CacheWithWait
• type CheckForUpgradesScheduler
  • func (s *CheckForUpgradesScheduler) NeedLeaderElection() bool
  • func (s *CheckForUpgradesScheduler) Start(ctx context.Context) error
• type HTTPClient

Functions

func ManagedScheduler

func ManagedScheduler(m manager.Manager, openshift bool, url, version string) error

ManagedScheduler creates a CheckForUpgradesScheduler and adds it to m.

Types

type CacheWithWait

type CacheWithWait interface {
	WaitForCacheSync(ctx context.Context) bool
}

Creating an interface for cache with WaitForCacheSync to allow easier mocking

type CheckForUpgradesScheduler

type CheckForUpgradesScheduler struct {
	Client crclient.Client
	Config *rest.Config

	OpenShift    bool
	Refresh      time.Duration
	URL, Version string
}

func (*CheckForUpgradesScheduler) NeedLeaderElection

func (s *CheckForUpgradesScheduler) NeedLeaderElection() bool

NeedLeaderElection returns true so that s runs only on the single manager.Manager that is elected leader in the Kubernetes cluster.

func (*CheckForUpgradesScheduler) Start

func (s *CheckForUpgradesScheduler) Start(ctx context.Context) error

Start checks for upgrades periodically. It blocks until ctx is cancelled.

type HTTPClient

type HTTPClient interface {
	Do(req *http.Request) (*http.Response, error)
}