workload

Documentation

Index

• Variables
• func LoopAbilities(handlers ...Handler)
• func ObjIntoPod(objs ...runtime.Object) []corev1.Pod
• func ObjUnmarshal(obj runtime.Object, container interface{}) error
• func Register(ability Workload, gvrs ...schema.GroupVersionResource)
• type GreyscaleReleaser
• type Handler
• type HealthStatusGetter
• type PodsLister
• type Revision
• type Step
• type Workload
  • func GetAbility(gk schema.GroupKind) (Workload, error)

Variables

var Resources = make([]regioninformers.Resource, 0, 16)

Functions

func LoopAbilities

func LoopAbilities(handlers ...Handler)

func ObjIntoPod

func ObjIntoPod(objs ...runtime.Object) []corev1.Pod

func ObjUnmarshal

func ObjUnmarshal(obj runtime.Object, container interface{}) error

func Register

func Register(ability Workload, gvrs ...schema.GroupVersionResource)

Types

type GreyscaleReleaser

type GreyscaleReleaser interface {
	Workload
	GetSteps(node *v1alpha1.ResourceNode, client *kube.Client) (*Step, error)
}

type Handler

type Handler func(workload Workload) bool

type HealthStatusGetter

type HealthStatusGetter interface {
	Workload
	IsHealthy(node *v1alpha1.ResourceNode, client *kube.Client) (bool, error)
}

type PodsLister

type PodsLister interface {
	Workload
	ListPods(node *v1alpha1.ResourceNode,
		factory dynamicinformer.DynamicSharedInformerFactory) ([]corev1.Pod, error)
}

type Revision

type Revision struct {
	Name string
	Pods []v1.Pod
}

type Step

type Step struct {
	Index        int
	Total        int
	Replicas     []int
	ManualPaused bool
	AutoPromote  bool
	Extra        *string
}

type Workload

type Workload interface {
	MatchGK(gk schema.GroupKind) bool
	Action(aName string, un *unstructured.Unstructured) (*unstructured.Unstructured, error)
}

func GetAbility

func GetAbility(gk schema.GroupKind) (Workload, error)