wfdefcommon

package
v0.0.0-...-e080771 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 10, 2025 License: BSD-3-Clause Imports: 35 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetDNS1123Name 

func GetDNS1123Name(name string) (dns1123Name string, err error)

GetDNS1123Name accepts a string a returns a version of that string that is compatible with DNS 1123. It replaces all underscores with hyphens to preserve readability and then strips anything that does not conform to then regex for the standard.

Types

type K8sClientsets 

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

K8sClientsets contains all the necessary clientsets for creating resources in K8s

func NewServiceClusterK8sClientsets 

func NewServiceClusterK8sClientsets() (*K8sClientsets, error)

NewServiceClusterK8sClientsets creates clientsets necessary for creating Kubernetes objects on the cluster this program is currently running on

func NewTestK8sClientsets 

func NewTestK8sClientsets() (*K8sClientsets, error)

NewTestK8sClientsets is used to create mock clientsets for testing

func NewUserClusterK8sClientsets 

func NewUserClusterK8sClientsets(configString string) (*K8sClientsets, error)

NewUserClusterK8sClientsets creates clientsets necessary for creating Kubernetes objects on a user's cluster using the provided config

func (*K8sClientsets) ApproveCertificateSigningRequest 

func (o *K8sClientsets) ApproveCertificateSigningRequest(approval *certificates.CertificateSigningRequest) (*certificates.CertificateSigningRequest, error)

ApproveCertificateSigningRequest ...

func (*K8sClientsets) CanI 

func (o *K8sClientsets) CanI(verb, resource string) (bool, error)

CanI checks if an verb can be performed on a resource

func (*K8sClientsets) CreateArgoWorkflow 

func (o *K8sClientsets) CreateArgoWorkflow(workflow *argotypes.Workflow, namespace string) (*argotypes.Workflow, error)

CreateArgoWorkflow ...

func (*K8sClientsets) CreateAuthorizationPolicy 

func (o *K8sClientsets) CreateAuthorizationPolicy(policy *istiosec.AuthorizationPolicy, namespace string) (*istiosec.AuthorizationPolicy, error)

CreateAuthorizationPolicy ...

func (*K8sClientsets) CreateCertificateSigningRequest 

func (o *K8sClientsets) CreateCertificateSigningRequest(csr *certificates.CertificateSigningRequest) (*certificates.CertificateSigningRequest, error)

CreateCertificateSigningRequest ...

func (*K8sClientsets) CreateClusterRole 

func (o *K8sClientsets) CreateClusterRole(cr *rbac.ClusterRole) (*rbac.ClusterRole, error)

CreateClusterRole ...

func (*K8sClientsets) CreateDeployment 

func (o *K8sClientsets) CreateDeployment(deployment *appsv1.Deployment, namespace string) (*appsv1.Deployment, error)

CreateDeployment ...

func (*K8sClientsets) CreateDestinationRule 

func (o *K8sClientsets) CreateDestinationRule(dr *istio.DestinationRule, namespace string) (*istio.DestinationRule, error)

CreateDestinationRule ...

func (*K8sClientsets) CreateFunction 

func (o *K8sClientsets) CreateFunction(fn *openfaas.Function, namespace string) (*openfaas.Function, error)

CreateFunction ...

func (*K8sClientsets) CreateGateway 

func (o *K8sClientsets) CreateGateway(gateway *istio.Gateway, namespace string) (*istio.Gateway, error)

CreateGateway ...

func (*K8sClientsets) CreateInformer 

func (o *K8sClientsets) CreateInformer(namespace string, handlers cache.ResourceEventHandlerFuncs) cache.SharedIndexInformer

CreateInformer creates a SharedIndexInformer on the specified namespace and with the attached handlers.

func (*K8sClientsets) CreateJob 

func (o *K8sClientsets) CreateJob(job *batch.Job, namespace string) (*batch.Job, error)

CreateJob ...

func (*K8sClientsets) CreateNamespace 

func (o *K8sClientsets) CreateNamespace(ns *v1.Namespace) (*v1.Namespace, error)

CreateNamespace ...

func (*K8sClientsets) CreatePods 

func (o *K8sClientsets) CreatePods(pod *v1.Pod, namespace string) (*v1.Pod, error)

CreatePods ...

func (*K8sClientsets) CreateRequestAuthentication 

func (o *K8sClientsets) CreateRequestAuthentication(requestAuthentication *istiosec.RequestAuthentication, namespace string) (*istiosec.RequestAuthentication, error)

CreateRequestAuthentication ...

func (*K8sClientsets) CreateRole 

func (o *K8sClientsets) CreateRole(role *rbac.Role, namespace string) (*rbac.Role, error)

CreateRole ...

func (*K8sClientsets) CreateRoleBinding 

func (o *K8sClientsets) CreateRoleBinding(rolebinding *rbac.RoleBinding, namespace string) (*rbac.RoleBinding, error)

CreateRoleBinding ...

func (*K8sClientsets) CreateScaledObject 

func (o *K8sClientsets) CreateScaledObject(scaledObject *unstructured.Unstructured, namespace string) (*unstructured.Unstructured, error)

CreateScaledObject ...

func (*K8sClientsets) CreateSecret 

func (o *K8sClientsets) CreateSecret(secret *v1.Secret, namespace string) (*v1.Secret, error)

CreateSecret ...

func (*K8sClientsets) CreateService 

func (o *K8sClientsets) CreateService(service *v1.Service, namespace string) (*v1.Service, error)

CreateService ...

func (*K8sClientsets) CreateServiceEntry 

func (o *K8sClientsets) CreateServiceEntry(se *istio.ServiceEntry, namespace string) (*istio.ServiceEntry, error)

CreateServiceEntry ...

func (*K8sClientsets) CreateVirtualService 

func (o *K8sClientsets) CreateVirtualService(vs *istio.VirtualService, namespace string) (*istio.VirtualService, error)

CreateVirtualService ...

func (*K8sClientsets) DeleteArgoWorkflow 

func (o *K8sClientsets) DeleteArgoWorkflow(name, namespace string) error

DeleteArgoWorkflow ...

func (*K8sClientsets) DeleteAuthorizationPolicy 

func (o *K8sClientsets) DeleteAuthorizationPolicy(name, namespace string) error

DeleteAuthorizationPolicy ...

func (*K8sClientsets) DeleteCertificateSigningRequest 

func (o *K8sClientsets) DeleteCertificateSigningRequest(name string) error

DeleteCertificateSigningRequest ...

func (*K8sClientsets) DeleteDeployment 

func (o *K8sClientsets) DeleteDeployment(name, namespace string) error

DeleteDeployment ...

func (*K8sClientsets) DeleteDestinationRule 

func (o *K8sClientsets) DeleteDestinationRule(name, namespace string) error

DeleteDestinationRule ...

func (*K8sClientsets) DeleteFunction 

func (o *K8sClientsets) DeleteFunction(name, namespace string) error

DeleteFunction ...

func (*K8sClientsets) DeleteGateway 

func (o *K8sClientsets) DeleteGateway(name, namespace string) error

DeleteGateway ...

func (*K8sClientsets) DeleteJob 

func (o *K8sClientsets) DeleteJob(name, namespace string) error

DeleteJob ...

func (*K8sClientsets) DeletePods 

func (o *K8sClientsets) DeletePods(name, namespace string) error

DeletePods ...

func (*K8sClientsets) DeleteRequestAuthentication 

func (o *K8sClientsets) DeleteRequestAuthentication(name, namespace string) error

DeleteRequestAuthentication ...

func (*K8sClientsets) DeleteScaledObject 

func (o *K8sClientsets) DeleteScaledObject(name, namespace string) error

DeleteScaledObject ...

func (*K8sClientsets) DeleteSecret 

func (o *K8sClientsets) DeleteSecret(name, namespace string) error

DeleteSecret ...

func (*K8sClientsets) DeleteService 

func (o *K8sClientsets) DeleteService(name, namespace string) error

DeleteService ...

func (*K8sClientsets) DeleteServiceEntry 

func (o *K8sClientsets) DeleteServiceEntry(name, namespace string) error

DeleteServiceEntry ...

func (*K8sClientsets) DeleteVirtualService 

func (o *K8sClientsets) DeleteVirtualService(name, namespace string) error

DeleteVirtualService ...

func (*K8sClientsets) GetArgoWorkflow 

func (o *K8sClientsets) GetArgoWorkflow(name, namespace string) (*argotypes.Workflow, error)

GetArgoWorkflow ...

func (*K8sClientsets) GetCertificateSigningRequest 

func (o *K8sClientsets) GetCertificateSigningRequest(name string) (*certificates.CertificateSigningRequest, error)

GetCertificateSigningRequest ...

func (*K8sClientsets) GetDeployment 

func (o *K8sClientsets) GetDeployment(name, namespace string) (*appsv1.Deployment, error)

GetDeployment ...

func (*K8sClientsets) GetJob 

func (o *K8sClientsets) GetJob(name, namespace string) (*batch.Job, error)

GetJob ...

func (*K8sClientsets) GetLogs 

func (o *K8sClientsets) GetLogs(name, namespace string) ([]byte, error)

GetLogs ...

func (*K8sClientsets) GetPods 

func (o *K8sClientsets) GetPods(name, namespace string) (*v1.Pod, error)

GetPods ...

func (*K8sClientsets) GetService 

func (o *K8sClientsets) GetService(name, namespace string) (*v1.Service, error)

GetService ...

func (*K8sClientsets) ListArgoWorkflows 

func (o *K8sClientsets) ListArgoWorkflows(options metav1.ListOptions, namespace string) (*argotypes.WorkflowList, error)

ListArgoWorkflows ...

func (*K8sClientsets) ListDeployments 

func (o *K8sClientsets) ListDeployments(options metav1.ListOptions, namespace string) (*appsv1.DeploymentList, error)

ListDeployments ...

func (*K8sClientsets) ListJobs 

func (o *K8sClientsets) ListJobs(options metav1.ListOptions, namespace string) (*batch.JobList, error)

ListJobs ...

func (*K8sClientsets) ListPods 

func (o *K8sClientsets) ListPods(options metav1.ListOptions, namespace string) (*v1.PodList, error)

ListPods ...

func (*K8sClientsets) ScaleDeployment 

func (o *K8sClientsets) ScaleDeployment(name, namespace string, replicas int32) error

ScaleDeployment ...

func (*K8sClientsets) UpdateArgoWorkflow 

func (o *K8sClientsets) UpdateArgoWorkflow(workflow *argotypes.Workflow, namespace string) (*argotypes.Workflow, error)

UpdateArgoWorkflow ...

func (*K8sClientsets) UpdateDeployment 

func (o *K8sClientsets) UpdateDeployment(deployment *appsv1.Deployment, namespace string) (*appsv1.Deployment, error)

UpdateDeployment ...

func (*K8sClientsets) UpdateDestinationRule 

func (o *K8sClientsets) UpdateDestinationRule(dr *istio.DestinationRule, namespace string) (*istio.DestinationRule, error)

UpdateDestinationRule ...

func (*K8sClientsets) UpdateGateway 

func (o *K8sClientsets) UpdateGateway(gateway *istio.Gateway, namespace string) (*istio.Gateway, error)

UpdateGateway ...

func (*K8sClientsets) UpdateJob 

func (o *K8sClientsets) UpdateJob(job *batch.Job, namespace string) (*batch.Job, error)

UpdateJob ...

func (*K8sClientsets) UpdateScaledObject 

func (o *K8sClientsets) UpdateScaledObject(scaledObject *unstructured.Unstructured, namespace string) (*unstructured.Unstructured, error)

UpdateScaledObject ...

func (*K8sClientsets) UpdateSecret 

func (o *K8sClientsets) UpdateSecret(secret *v1.Secret, namespace string) (*v1.Secret, error)

UpdateSecret ...

func (*K8sClientsets) UpdateService 

func (o *K8sClientsets) UpdateService(service *v1.Service, namespace string) (*v1.Service, error)

UpdateService ...

func (*K8sClientsets) UpdateServiceEntry 

func (o *K8sClientsets) UpdateServiceEntry(se *istio.ServiceEntry, namespace string) (*istio.ServiceEntry, error)

UpdateServiceEntry ...

func (*K8sClientsets) UpdateVirtualService 

func (o *K8sClientsets) UpdateVirtualService(vs *istio.VirtualService, namespace string) (*istio.VirtualService, error)

UpdateVirtualService ...

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.