updater

Documentation

Index

• func NewGitHubClientWrapper(client *github.Client) release.GitHubClientInterface
• type UpdateCacheItem
• type Updater
  • func New(cfg *config.Config, currentVersion string, k8sClient *k8s.KubeClient, ...) *Updater
  • func (self *Updater) CheckDeploymentsReady(ctx context.Context, version string) (bool, error)
  • func (self *Updater) CheckForUpdates(ctx context.Context) ([]string, error)
  • func (self *Updater) GetLatestVersion(ctx context.Context) (string, error)
  • func (self *Updater) GetNextAvailableVersion(ctx context.Context, currentVersion string) (string, error)
  • func (self *Updater) GetUpdatePath(ctx context.Context, targetVersion string) ([]string, error)
  • func (self *Updater) UpdateToVersion(ctx context.Context, targetVersion string) error

Functions

func NewGitHubClientWrapper

func NewGitHubClientWrapper(client *github.Client) release.GitHubClientInterface

NewGitHubClientWrapper creates a new wrapper around the GitHub client

Types

type UpdateCacheItem

type UpdateCacheItem struct {
	Updates   []string
	CheckedAt time.Time
}

type Updater

type Updater struct {
	CurrentVersion string
	// contains filtered or unexported fields
}

Updater handles the update process for the application

func New

func New(cfg *config.Config, currentVersion string, k8sClient *k8s.KubeClient, redisClient *redis.Client) *Updater

New creates a new updater instance

func (*Updater) CheckDeploymentsReady

func (self *Updater) CheckDeploymentsReady(ctx context.Context, version string) (bool, error)

CheckDeploymentsReady checks if all deployments are running with the specified version

func (*Updater) CheckForUpdates

func (self *Updater) CheckForUpdates(ctx context.Context) ([]string, error)

CheckForUpdates checks if there are any available updates

func (*Updater) GetLatestVersion

func (self *Updater) GetLatestVersion(ctx context.Context) (string, error)

GetLatestVersion returns the latest available version

func (*Updater) GetNextAvailableVersion

func (self *Updater) GetNextAvailableVersion(ctx context.Context, currentVersion string) (string, error)

GetNextAvailableVersion returns the next version that can be updated to from the current version

func (*Updater) GetUpdatePath

func (self *Updater) GetUpdatePath(ctx context.Context, targetVersion string) ([]string, error)

GetUpdatePath returns the ordered list of versions needed to update from current to target

func (*Updater) UpdateToVersion

func (self *Updater) UpdateToVersion(ctx context.Context, targetVersion string) error

UpdateToVersion updates the application to the specified version