controller

Documentation

Index

• func Cronjob(period string, r *Retriever)
• type Retriever
  • func NewRetriever(clientv3 *clientv3.Client, clientset *kubernetes.Clientset) *Retriever
  • func (r *Retriever) RetrieveFixedIP()
  • func (r *Retriever) RetrieveIP()

Functions

func Cronjob

func Cronjob(period string, r *Retriever)

Cronjob uses input retriever to start an IP retrieve job, every period the job will be executed once.

Types

type Retriever

type Retriever struct {
	Clientset *kubernetes.Clientset
	// contains filtered or unexported fields
}

Retriever is used to retriever IP addresses from deleted pods

func NewRetriever

func NewRetriever(clientv3 *clientv3.Client, clientset *kubernetes.Clientset) *Retriever

NewRetriever uses etcd and k8s client to create and return an IP retriever

func (*Retriever) RetrieveFixedIP

func (r *Retriever) RetrieveFixedIP()

RetrieveFixedIP retrieves fixed IP from deleted statefulset

func (*Retriever) RetrieveIP

func (r *Retriever) RetrieveIP()

RetrieveIP scans all pods and retrieve IP