controller

Documentation

Index

• Constants
• func GetImageRepo(image string) (string, error)
• func RemoveDuplicateElement(s []string) []string
• func UpdateNodeUpgradeJobStatus(old *v1alpha1.NodeUpgradeJob, status *v1alpha1.UpgradeStatus) *v1alpha1.NodeUpgradeJob
• type DownstreamController
  • func NewDownstreamController(crdInformerFactory crdinformers.SharedInformerFactory) (*DownstreamController, error)
  • func (dc *DownstreamController) Start() error
• type UpstreamController
  • func NewUpstreamController(dc *DownstreamController) (*UpstreamController, error)
  • func (uc *UpstreamController) Start() error

Constants

const (
	NodeUpgradeJobStatusKey   = "nodeupgradejob.operations.kubeedge.io/status"
	NodeUpgradeJobStatusValue = ""
	NodeUpgradeHistoryKey     = "nodeupgradejob.operations.kubeedge.io/history"
)

const (
	NodeUpgrade = "upgrade"
)

Functions

func GetImageRepo

func GetImageRepo(image string) (string, error)

GetImageRepo gets repo from a container image

func RemoveDuplicateElement

func RemoveDuplicateElement(s []string) []string

RemoveDuplicateElement deduplicate

func UpdateNodeUpgradeJobStatus

func UpdateNodeUpgradeJobStatus(old *v1alpha1.NodeUpgradeJob, status *v1alpha1.UpgradeStatus) *v1alpha1.NodeUpgradeJob

UpdateNodeUpgradeJobStatus updates the status return the updated result

Types

type DownstreamController

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

func NewDownstreamController

func NewDownstreamController(crdInformerFactory crdinformers.SharedInformerFactory) (*DownstreamController, error)

func (*DownstreamController) Start

func (dc *DownstreamController) Start() error

Start DownstreamController

type UpstreamController

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

UpstreamController subscribe messages from edge and sync to k8s api server

func NewUpstreamController

func NewUpstreamController(dc *DownstreamController) (*UpstreamController, error)

NewUpstreamController create UpstreamController from config

func (*UpstreamController) Start

func (uc *UpstreamController) Start() error

Start UpstreamController