k8s

Documentation

Index

• Constants
• type HostStatusPredicate
  • func (p *HostStatusPredicate) Clone() IPredicate
  • func (p *HostStatusPredicate) Execute(cli *kubernetes.Clientset, pod *v1.Pod, node *v1.Node, ...) (bool, error)
  • func (p *HostStatusPredicate) Name() string
  • func (p *HostStatusPredicate) PreExecute(cli *kubernetes.Clientset, pod *v1.Pod, node *v1.Node, ...) bool
• type IPredicate
• type LocalVolumePredicate
  • func (p *LocalVolumePredicate) Clone() IPredicate
  • func (p *LocalVolumePredicate) Execute(cli *kubernetes.Clientset, pod *v1.Pod, node *v1.Node, ...) (bool, error)
  • func (p *LocalVolumePredicate) Name() string
  • func (p *LocalVolumePredicate) PreExecute(cli *kubernetes.Clientset, pod *v1.Pod, node *v1.Node, ...) bool
• type NetworkPredicate
  • func (p *NetworkPredicate) Clone() IPredicate
  • func (p *NetworkPredicate) Execute(cli *kubernetes.Clientset, pod *v1.Pod, node *v1.Node, ...) (bool, error)
  • func (p *NetworkPredicate) Name() string
  • func (p *NetworkPredicate) PreExecute(cli *kubernetes.Clientset, pod *v1.Pod, node *v1.Node, ...) bool
• type SPredicatesManager
  • func (man *SPredicatesManager) DoFilter(k8sCli *kubernetes.Clientset, pod *v1.Pod, node *v1.Node, ...) (bool, error)
  • func (man *SPredicatesManager) Has(newPre IPredicate) bool
  • func (man *SPredicatesManager) Register(pres ...IPredicate) *SPredicatesManager

Constants

const (
	// k8s annotations for create pod
	YUNION_CNI_NETWORK_ANNOTATION = "cni.yunion.io/network"
	YUNION_CNI_IPADDR_ANNOTATION  = "cni.yunion.io/ip"
)

const (
	YUNION_CSI_STORAGECLASS = "csi-yunion"
)

Types

type HostStatusPredicate

type HostStatusPredicate struct{}

func (*HostStatusPredicate) Clone

func (p *HostStatusPredicate) Clone() IPredicate

func (*HostStatusPredicate) Execute

func (p *HostStatusPredicate) Execute(cli *kubernetes.Clientset, pod *v1.Pod, node *v1.Node, host *candidate.HostDesc) (bool, error)

func (*HostStatusPredicate) Name

func (p *HostStatusPredicate) Name() string

func (*HostStatusPredicate) PreExecute

func (p *HostStatusPredicate) PreExecute(cli *kubernetes.Clientset, pod *v1.Pod, node *v1.Node, host *candidate.HostDesc) bool

type IPredicate

type IPredicate interface {
	Name() string
	Clone() IPredicate
	PreExecute(cli *kubernetes.Clientset, pod *v1.Pod, node *v1.Node, host *candidate.HostDesc) bool
	Execute(cli *kubernetes.Clientset, pod *v1.Pod, node *v1.Node, host *candidate.HostDesc) (bool, error)
}

type LocalVolumePredicate

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

func (*LocalVolumePredicate) Clone

func (p *LocalVolumePredicate) Clone() IPredicate

func (*LocalVolumePredicate) Execute

func (p *LocalVolumePredicate) Execute(cli *kubernetes.Clientset, pod *v1.Pod, node *v1.Node, host *candidate.HostDesc) (bool, error)

func (*LocalVolumePredicate) Name

func (p *LocalVolumePredicate) Name() string

func (*LocalVolumePredicate) PreExecute

func (p *LocalVolumePredicate) PreExecute(cli *kubernetes.Clientset, pod *v1.Pod, node *v1.Node, host *candidate.HostDesc) bool

type NetworkPredicate

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

func (*NetworkPredicate) Clone

func (p *NetworkPredicate) Clone() IPredicate

func (*NetworkPredicate) Execute

func (p *NetworkPredicate) Execute(cli *kubernetes.Clientset, pod *v1.Pod, node *v1.Node, host *candidate.HostDesc) (bool, error)

func (*NetworkPredicate) Name

func (p *NetworkPredicate) Name() string

func (*NetworkPredicate) PreExecute

func (p *NetworkPredicate) PreExecute(cli *kubernetes.Clientset, pod *v1.Pod, node *v1.Node, host *candidate.HostDesc) bool

type SPredicatesManager

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

var PredicatesManager *SPredicatesManager

func (*SPredicatesManager) DoFilter

func (man *SPredicatesManager) DoFilter(
	k8sCli *kubernetes.Clientset,
	pod *v1.Pod,
	node *v1.Node,
	host *candidate.HostDesc,
) (bool, error)

func (*SPredicatesManager) Has

func (man *SPredicatesManager) Has(newPre IPredicate) bool

func (*SPredicatesManager) Register

func (man *SPredicatesManager) Register(pres ...IPredicate) *SPredicatesManager