utils

Documentation

Index

• Constants
• func CaculateNodeGroupStatus(unitSet sets.String, ng *sitev1.NodeGroup) (*sitev1.NodeGroupStatus, error)
• func CaculateNodeUnitStatus(nodeMap map[string]*corev1.Node, nu *sitev1.NodeUnit) (*sitev1.NodeUnitStatus, error)
• func CreateDefaultUnit(ctx context.Context, crdClient *crdClientset.Clientset) error
• func DeleteNodeUnitFromSetNode(crdClient *crdClientset.Clientset, ng *sitev1.NodeGroup, ...) error
• func DeleteNodesFromSetNode(kubeClient clientset.Interface, nu *sitev1.NodeUnit, ...) error
• func FoundNode(nodes []string, node string) bool
• func GetGroupsByUnit(groupLister crdv1listers.NodeGroupLister, nu *sitev1.NodeUnit) (nodeGroups []*sitev1.NodeGroup, groupList []string, err error)
• func GetNodesByUnit(nodeLister corelisters.NodeLister, nu *sitev1.NodeUnit) (sets.String, map[string]*corev1.Node, error)
• func GetUnitByGroup(unitLister crdv1listers.NodeUnitLister, ng *sitev1.NodeGroup) (sets.String, map[string]*sitev1.NodeUnit, error)
• func GetUnitsByNode(unitLister crdv1listers.NodeUnitLister, node *corev1.Node) (nodeUnits []*sitev1.NodeUnit, unitList []string, err error)
• func HashAutoFindKeys(keyslices []string) string
• func InitAllRosource(ctx context.Context, crdClient *crdClientset.Clientset, ...) error
• func ListNodeFromLister(nodeLister corelisters.NodeLister, selector labels.Selector, ...) error
• func ListNodeUnitFromLister(unitLister crdv1listers.NodeUnitLister, selector labels.Selector, ...) error
• func Migrator_v1alpha1_NodeGroup_To_v1alpha2_NodeGroup(ctx context.Context, crdClient *crdClientset.Clientset, ...) error
• func Migrator_v1alpha1_NodeUnit_To_v1alpha2_NodeUnit(ctx context.Context, crdClient *crdClientset.Clientset, ...) error
• func SetNodeToNodeUnits(crdClient *crdClientset.Clientset, ng *v1alpha2.NodeGroup, ...) error
• func SetNodeToNodes(kubeClient clientset.Interface, nu *sitev1.NodeUnit, ...) error
• func TaintInSlices(taintSlice []corev1.Taint, target corev1.Taint) bool

Constants

const (
	AllNodeUnit            = "unit-node-all"
	EdgeNodeUnit           = "unit-node-edge"
	CloudNodeUnit          = "unit-node-cloud"
	MasterNodeUnit         = "unit-node-master"
	MigrationCompletedAnno = "site.superedge.io/migration-done"
	NodeUnitCRDName        = "nodeunits.site.superedge.io"
	NodeGroupCRDName       = "nodegroups.site.superedge.io"
	KinsRoleLabelKey       = "site.superedge.io/kins-role"
	KinsResourceLabelKey   = "site.superedge.io/kins-resource"
)

const Finalizers = `
{"metadata":{"finalizers":null}}
`

Functions

func CaculateNodeGroupStatus

func CaculateNodeGroupStatus(unitSet sets.String, ng *sitev1.NodeGroup) (*sitev1.NodeGroupStatus, error)

func CaculateNodeUnitStatus

func CaculateNodeUnitStatus(nodeMap map[string]*corev1.Node, nu *sitev1.NodeUnit) (*sitev1.NodeUnitStatus, error)

func CreateDefaultUnit

func CreateDefaultUnit(ctx context.Context, crdClient *crdClientset.Clientset) error

func DeleteNodeUnitFromSetNode

func DeleteNodeUnitFromSetNode(crdClient *crdClientset.Clientset, ng *sitev1.NodeGroup, unitMaps map[string]*sitev1.NodeUnit) error

func DeleteNodesFromSetNode

func DeleteNodesFromSetNode(kubeClient clientset.Interface, nu *sitev1.NodeUnit, nodeMaps map[string]*corev1.Node) error

func FoundNode

func FoundNode(nodes []string, node string) bool

func GetGroupsByUnit

func GetGroupsByUnit(groupLister crdv1listers.NodeGroupLister, nu *sitev1.NodeUnit) (nodeGroups []*sitev1.NodeGroup, groupList []string, err error)

GetUnitsByNode

func GetNodesByUnit

func GetNodesByUnit(nodeLister corelisters.NodeLister, nu *sitev1.NodeUnit) (sets.String, map[string]*corev1.Node, error)

func GetUnitByGroup

func GetUnitByGroup(unitLister crdv1listers.NodeUnitLister, ng *sitev1.NodeGroup) (sets.String, map[string]*sitev1.NodeUnit, error)

func GetUnitsByNode

func GetUnitsByNode(unitLister crdv1listers.NodeUnitLister, node *corev1.Node) (nodeUnits []*sitev1.NodeUnit, unitList []string, err error)

GetUnitsByNode

func HashAutoFindKeys

func HashAutoFindKeys(keyslices []string) string

func InitAllRosource

func InitAllRosource(ctx context.Context, crdClient *crdClientset.Clientset, extentionClient extensionclientset.Interface) error

func ListNodeFromLister

func ListNodeFromLister(nodeLister corelisters.NodeLister, selector labels.Selector, appendFn cache.AppendFunc) error

func ListNodeUnitFromLister

func ListNodeUnitFromLister(unitLister crdv1listers.NodeUnitLister, selector labels.Selector, appendFn cache.AppendFunc) error

func Migrator_v1alpha1_NodeGroup_To_v1alpha2_NodeGroup

func Migrator_v1alpha1_NodeGroup_To_v1alpha2_NodeGroup(ctx context.Context, crdClient *crdClientset.Clientset, extentionClient extensionclientset.Interface) error

func Migrator_v1alpha1_NodeUnit_To_v1alpha2_NodeUnit

func Migrator_v1alpha1_NodeUnit_To_v1alpha2_NodeUnit(ctx context.Context, crdClient *crdClientset.Clientset, extentionClient extensionclientset.Interface) error

func SetNodeToNodeUnits

func SetNodeToNodeUnits(crdClient *crdClientset.Clientset, ng *v1alpha2.NodeGroup, unitMaps map[string]*v1alpha2.NodeUnit) error

func SetNodeToNodes

func SetNodeToNodes(kubeClient clientset.Interface, nu *sitev1.NodeUnit, nodeMaps map[string]*corev1.Node) error

func TaintInSlices

func TaintInSlices(taintSlice []corev1.Taint, target corev1.Taint) bool