controller

Documentation

Index

• func SortInitContainerStatuses(p *v1.Pod, statuses []v1.ContainerStatus)
• func UpdateAnnotation(ctx context.Context, nodeName string) error
• type DownstreamController
  • func NewDownstreamController(config *v1alpha1.EdgeController, ...) (*DownstreamController, error)
  • func (dc *DownstreamController) Start() error
• type SortedContainerStatuses
  • func (s SortedContainerStatuses) Len() int
  • func (s SortedContainerStatuses) Less(i, j int) bool
  • func (s SortedContainerStatuses) Swap(i, j int)
• type UpstreamController
  • func NewUpstreamController(config *v1alpha1.EdgeController, factory k8sinformer.SharedInformerFactory) (*UpstreamController, error)
  • func (uc *UpstreamController) Start() error

Functions

func SortInitContainerStatuses

func SortInitContainerStatuses(p *v1.Pod, statuses []v1.ContainerStatus)

SortInitContainerStatuses ensures that statuses are in the order that their init container appears in the pod spec

func UpdateAnnotation

func UpdateAnnotation(ctx context.Context, nodeName string) error

Types

type DownstreamController

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

DownstreamController watch kubernetes api server and send change to edge

func NewDownstreamController

func NewDownstreamController(config *v1alpha1.EdgeController, k8sInformerFactory k8sinformers.SharedInformerFactory, keInformerFactory informers.KubeEdgeCustomInformer,
	crdInformerFactory crdinformers.SharedInformerFactory) (*DownstreamController, error)

NewDownstreamController create a DownstreamController from config

func (*DownstreamController) Start

func (dc *DownstreamController) Start() error

Start DownstreamController

type SortedContainerStatuses

type SortedContainerStatuses []v1.ContainerStatus

SortedContainerStatuses define A type to help sort container statuses based on container names.

func (SortedContainerStatuses) Len

func (s SortedContainerStatuses) Len() int

func (SortedContainerStatuses) Less

func (s SortedContainerStatuses) Less(i, j int) bool

func (SortedContainerStatuses) Swap

func (s SortedContainerStatuses) Swap(i, j int)

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(config *v1alpha1.EdgeController, factory k8sinformer.SharedInformerFactory) (*UpstreamController, error)

NewUpstreamController create UpstreamController from config

func (*UpstreamController) Start

func (uc *UpstreamController) Start() error

Start UpstreamController