client

package
v1.1.1 Latest Latest
Warning

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

 Go to latest Published: Mar 13, 2024 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Overview

Some code in this file was adopted from https://github.com/atlasmap/atlasmap-operator

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type APIGroupInfo 

type APIGroupInfo struct {
	Group            string
	PreferredVersion string
	Versions         []string
}

type CRDClient 

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

func NewCRDClient 

func NewCRDClient(log *zap.Logger, scheme *runtime.Scheme, config *rest.Config) *CRDClient

func (*CRDClient) GetApicurioRegistry 

func (this *CRDClient) GetApicurioRegistry(namespace common.Namespace, name common.Name) (*ar.ApicurioRegistry, error)

TODO Returns nil if the resource is not found, but request was OK

func (*CRDClient) PatchApicurioRegistry 

func (this *CRDClient) PatchApicurioRegistry(namespace common.Namespace, name common.Name, patchData []byte) (*ar.ApicurioRegistry, error)

func (*CRDClient) PatchApicurioRegistryStatus 

func (this *CRDClient) PatchApicurioRegistryStatus(namespace common.Namespace, name common.Name, patchData []byte) (*ar.ApicurioRegistryStatus, error)

func (*CRDClient) UpdateApicurioRegistry 

func (this *CRDClient) UpdateApicurioRegistry(namespace common.Namespace, value *ar.ApicurioRegistry) (*ar.ApicurioRegistry, error)

type Clients 

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

func NewClients 

func NewClients(log *zap.Logger, scheme *runtime.Scheme, config *rest.Config) *Clients

func (*Clients) CRD 

func (this *Clients) CRD() *CRDClient

func (*Clients) Discovery 

func (this *Clients) Discovery() *DiscoveryClient

func (*Clients) Kube 

func (this *Clients) Kube() *KubeClient

func (*Clients) Monitoring 

func (this *Clients) Monitoring() *MonitoringClient

func (*Clients) OCP 

func (this *Clients) OCP() *OCPClient

type DiscoveryClient 

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

func NewDiscoveryClient 

func NewDiscoveryClient(log *zap.Logger, clientConfig *rest.Config) *DiscoveryClient

func (*DiscoveryClient) GetVersionInfoForAPIGroup 

func (this *DiscoveryClient) GetVersionInfoForAPIGroup(apiGroup string) (*APIGroupInfo, error)

Get information about the given API group. Returns an error if the API Group does not exist or the info could not be determined.

func (*DiscoveryClient) IsMonitoringInstalled 

func (this *DiscoveryClient) IsMonitoringInstalled() (bool, error)

func (*DiscoveryClient) IsOCP 

func (this *DiscoveryClient) IsOCP() (bool, error)

type KubeClient 

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

func NewKubeClient 

func NewKubeClient(log *zap.Logger, scheme *runtime.Scheme, config *rest.Config) *KubeClient

func (*KubeClient) CreateDeployment 

func (this *KubeClient) CreateDeployment(owner meta.Object, namespace common.Namespace, value *apps.Deployment) (*apps.Deployment, error)

func (*KubeClient) CreateIngress 

func (this *KubeClient) CreateIngress(owner meta.Object, namespace common.Namespace, value *networking.Ingress) (*networking.Ingress, error)

func (*KubeClient) CreateNetworkPolicy 

func (this *KubeClient) CreateNetworkPolicy(owner meta.Object, namespace common.Namespace, value *networking.NetworkPolicy) (*networking.NetworkPolicy, error)

func (*KubeClient) CreatePodDisruptionBudgetV1 

func (this *KubeClient) CreatePodDisruptionBudgetV1(owner meta.Object, namespace common.Namespace, value *policy_v1.PodDisruptionBudget) (*policy_v1.PodDisruptionBudget, error)

func (*KubeClient) CreatePodDisruptionBudgetV1beta1 

func (this *KubeClient) CreatePodDisruptionBudgetV1beta1(owner meta.Object, namespace common.Namespace, value *policy_v1beta1.PodDisruptionBudget) (*policy_v1beta1.PodDisruptionBudget, error)

func (*KubeClient) CreateSecret 

func (this *KubeClient) CreateSecret(owner meta.Object, namespace common.Namespace, value *core.Secret) (*core.Secret, error)

func (*KubeClient) CreateService 

func (this *KubeClient) CreateService(owner meta.Object, namespace common.Namespace, value *core.Service) (*core.Service, error)

func (*KubeClient) DeleteDeployment 

func (this *KubeClient) DeleteDeployment(value *apps.Deployment) error

func (*KubeClient) DeleteIngress 

func (this *KubeClient) DeleteIngress(value *networking.Ingress) error

func (*KubeClient) DeleteNetworkPolicy 

func (this *KubeClient) DeleteNetworkPolicy(value *networking.NetworkPolicy) error

func (*KubeClient) DeletePodDisruptionBudgetV1 

func (this *KubeClient) DeletePodDisruptionBudgetV1(value *policy_v1.PodDisruptionBudget) error

func (*KubeClient) DeletePodDisruptionBudgetV1beta1 

func (this *KubeClient) DeletePodDisruptionBudgetV1beta1(value *policy_v1beta1.PodDisruptionBudget) error

func (*KubeClient) DeleteSecret 

func (this *KubeClient) DeleteSecret(value *core.Secret, options *meta.DeleteOptions) error

func (*KubeClient) DeleteService 

func (this *KubeClient) DeleteService(value *core.Service) error

func (*KubeClient) GetDeployment 

func (this *KubeClient) GetDeployment(namespace common.Namespace, name common.Name) (*apps.Deployment, error)

func (*KubeClient) GetDeployments 

func (this *KubeClient) GetDeployments(namespace common.Namespace, options meta.ListOptions) (*apps.DeploymentList, error)

func (*KubeClient) GetIngress 

func (this *KubeClient) GetIngress(namespace common.Namespace, name common.Name, options *meta.GetOptions) (*networking.Ingress, error)

func (*KubeClient) GetIngresses 

func (this *KubeClient) GetIngresses(namespace common.Namespace, options meta.ListOptions) (*networking.IngressList, error)

func (*KubeClient) GetNetworkPolicies 

func (this *KubeClient) GetNetworkPolicies(namespace common.Namespace, options meta.ListOptions) (*networking.NetworkPolicyList, error)

func (*KubeClient) GetNetworkPolicy 

func (this *KubeClient) GetNetworkPolicy(namespace common.Namespace, name common.Name, options *meta.GetOptions) (*networking.NetworkPolicy, error)

func (*KubeClient) GetPod 

func (this *KubeClient) GetPod(namespace common.Namespace, name common.Name) (*core.Pod, error)

func (*KubeClient) GetPodDisruptionBudgetV1 

func (this *KubeClient) GetPodDisruptionBudgetV1(namespace common.Namespace, name common.Name) (*policy_v1.PodDisruptionBudget, error)

func (*KubeClient) GetPodDisruptionBudgetV1beta1 

func (this *KubeClient) GetPodDisruptionBudgetV1beta1(namespace common.Namespace, name common.Name) (*policy_v1beta1.PodDisruptionBudget, error)

func (*KubeClient) GetPodDisruptionBudgetsV1 

func (this *KubeClient) GetPodDisruptionBudgetsV1(namespace common.Namespace, options meta.ListOptions) (*policy_v1.PodDisruptionBudgetList, error)

func (*KubeClient) GetPodDisruptionBudgetsV1beta1 

func (this *KubeClient) GetPodDisruptionBudgetsV1beta1(namespace common.Namespace, options meta.ListOptions) (*policy_v1beta1.PodDisruptionBudgetList, error)

func (*KubeClient) GetSecret 

func (this *KubeClient) GetSecret(namespace common.Namespace, name common.Name, options *meta.GetOptions) (*core.Secret, error)

func (*KubeClient) GetService 

func (this *KubeClient) GetService(namespace common.Namespace, name common.Name) (*core.Service, error)

func (*KubeClient) GetServices 

func (this *KubeClient) GetServices(namespace common.Namespace, options meta.ListOptions) (*core.ServiceList, error)

func (*KubeClient) PatchDeployment 

func (this *KubeClient) PatchDeployment(namespace common.Namespace, name common.Name, patchData []byte) (*apps.Deployment, error)

func (*KubeClient) PatchIngress 

func (this *KubeClient) PatchIngress(namespace common.Namespace, name common.Name, patchData []byte) (*networking.Ingress, error)

func (*KubeClient) PatchNetworkPolicy 

func (this *KubeClient) PatchNetworkPolicy(namespace common.Namespace, name common.Name, patchData []byte) (*networking.NetworkPolicy, error)

func (*KubeClient) PatchPodDisruptionBudgetV1 

func (this *KubeClient) PatchPodDisruptionBudgetV1(namespace common.Namespace, name common.Name, patchData []byte) (*policy_v1.PodDisruptionBudget, error)

func (*KubeClient) PatchPodDisruptionBudgetV1beta1 

func (this *KubeClient) PatchPodDisruptionBudgetV1beta1(namespace common.Namespace, name common.Name, patchData []byte) (*policy_v1beta1.PodDisruptionBudget, error)

func (*KubeClient) PatchService 

func (this *KubeClient) PatchService(namespace common.Namespace, name common.Name, patchData []byte) (*core.Service, error)

func (*KubeClient) UpdateDeployment 

func (this *KubeClient) UpdateDeployment(namespace common.Namespace, value *apps.Deployment) (*apps.Deployment, error)

func (*KubeClient) UpdateIngress 

func (this *KubeClient) UpdateIngress(namespace common.Namespace, value *networking.Ingress) (*networking.Ingress, error)

func (*KubeClient) UpdateNetworkPolicy 

func (this *KubeClient) UpdateNetworkPolicy(namespace common.Namespace, value *networking.NetworkPolicy) (*networking.NetworkPolicy, error)

func (*KubeClient) UpdatePodDisruptionBudgetV1 

func (this *KubeClient) UpdatePodDisruptionBudgetV1(namespace common.Namespace, value *policy_v1.PodDisruptionBudget) (*policy_v1.PodDisruptionBudget, error)

func (*KubeClient) UpdatePodDisruptionBudgetV1beta1 

func (this *KubeClient) UpdatePodDisruptionBudgetV1beta1(namespace common.Namespace, value *policy_v1beta1.PodDisruptionBudget) (*policy_v1beta1.PodDisruptionBudget, error)

func (*KubeClient) UpdateService 

func (this *KubeClient) UpdateService(namespace common.Namespace, value *core.Service) (*core.Service, error)

type MonitoringClient 

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

func NewMonitoringClient 

func NewMonitoringClient(log *zap.Logger, scheme *runtime.Scheme, config *rest.Config) *MonitoringClient

func (*MonitoringClient) CreateServiceMonitor 

func (this *MonitoringClient) CreateServiceMonitor(owner meta.Object, namespace common.Namespace, obj *monitoring.ServiceMonitor) (*monitoring.ServiceMonitor, error)

func (*MonitoringClient) DeleteServiceMonitor 

func (this *MonitoringClient) DeleteServiceMonitor(value *monitoring.ServiceMonitor) error

func (*MonitoringClient) GetServiceMonitor 

func (this *MonitoringClient) GetServiceMonitor(namespace common.Namespace, name common.Name) (*monitoring.ServiceMonitor, error)

func (*MonitoringClient) UpdateServiceMonitor 

func (this *MonitoringClient) UpdateServiceMonitor(namespace common.Namespace, obj *monitoring.ServiceMonitor) (*monitoring.ServiceMonitor, error)

type OCPClient 

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

func NewOCPClient 

func NewOCPClient(log *zap.Logger, scheme *runtime.Scheme, clientConfig *rest.Config) *OCPClient

func (*OCPClient) CreateDeployment 

func (this *OCPClient) CreateDeployment(owner meta.Object, namespace common.Namespace, value *ocp_apps.DeploymentConfig) (*ocp_apps.DeploymentConfig, error)

func (*OCPClient) DeleteDeployment 

func (this *OCPClient) DeleteDeployment(value *ocp_apps.DeploymentConfig, options *meta.DeleteOptions) error

func (*OCPClient) GetDeployment 

func (this *OCPClient) GetDeployment(namespace common.Namespace, name common.Name, options *meta.GetOptions) (*ocp_apps.DeploymentConfig, error)

func (*OCPClient) GetDeployments 

func (this *OCPClient) GetDeployments(namespace common.Namespace, options *meta.ListOptions) (*ocp_apps.DeploymentConfigList, error)

func (*OCPClient) GetRoute 

func (this *OCPClient) GetRoute(namespace common.Namespace, name common.Name, options *meta.GetOptions) (*ocp_route.Route, error)

func (*OCPClient) GetRoutes 

func (this *OCPClient) GetRoutes(namespace common.Namespace, options *meta.ListOptions) (*ocp_route.RouteList, error)

func (*OCPClient) PatchDeployment 

func (this *OCPClient) PatchDeployment(namespace common.Namespace, name common.Name, patchData []byte) (*ocp_apps.DeploymentConfig, error)

func (*OCPClient) UpdateDeployment 

func (this *OCPClient) UpdateDeployment(namespace common.Namespace, value *ocp_apps.DeploymentConfig) (*ocp_apps.DeploymentConfig, error)

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.