k8s

Documentation

Index

• Constants
• type KubernetesAPI
  • func CreateKubernetesAPI() KubernetesAPI
  • func (k KubernetesAPI) CreateCronJob(sj scheduler.SimpleJob) error
  • func (k KubernetesAPI) CreateJob(sj scheduler.SimpleJob) error
  • func (k KubernetesAPI) DeleteCronJob(name string, namespace string) error
  • func (k KubernetesAPI) DeleteJob(name string, namespace string) error
  • func (k KubernetesAPI) FetchCronJob(name string, namespace string) (*batchv1beta1.CronJob, error)
  • func (k KubernetesAPI) FetchJob(name string, namespace string) (*batchv1.Job, error)
  • func (k KubernetesAPI) ListCronJobs(namespace string) ([]batchv1beta1.CronJob, error)
  • func (k KubernetesAPI) ListJobs(namespace string) ([]batchv1.Job, error)
  • func (k KubernetesAPI) UpdateCronJob(sj scheduler.SimpleJob) error

Constants

const AllNamespaces = ""

Types

type KubernetesAPI

type KubernetesAPI struct {
	Client kubernetes.Interface
}

func CreateKubernetesAPI

func CreateKubernetesAPI() KubernetesAPI

func (KubernetesAPI) CreateCronJob

func (k KubernetesAPI) CreateCronJob(sj scheduler.SimpleJob) error

func (KubernetesAPI) CreateJob

func (k KubernetesAPI) CreateJob(sj scheduler.SimpleJob) error

func (KubernetesAPI) DeleteCronJob

func (k KubernetesAPI) DeleteCronJob(name string, namespace string) error

func (KubernetesAPI) DeleteJob

func (k KubernetesAPI) DeleteJob(name string, namespace string) error

func (KubernetesAPI) FetchCronJob

func (k KubernetesAPI) FetchCronJob(name string, namespace string) (*batchv1beta1.CronJob, error)

func (KubernetesAPI) FetchJob

func (k KubernetesAPI) FetchJob(name string, namespace string) (*batchv1.Job, error)

func (KubernetesAPI) ListCronJobs

func (k KubernetesAPI) ListCronJobs(namespace string) ([]batchv1beta1.CronJob, error)

func (KubernetesAPI) ListJobs

func (k KubernetesAPI) ListJobs(namespace string) ([]batchv1.Job, error)

func (KubernetesAPI) UpdateCronJob

func (k KubernetesAPI) UpdateCronJob(sj scheduler.SimpleJob) error