util

package
v1.8.0 Latest Latest
Warning

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

 Go to latest Published: Sep 28, 2021 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause, + 8 more Imports: 35 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func APIServerLocation 

func APIServerLocation(ctx context.Context, platformClient platforminternalclient.PlatformInterface) (*url.URL, http.RoundTripper, string, error)

APIServerLocation returns a URL and transport which one can use to send traffic for the specified kube api server.

func APIServerLocationByCluster 

func APIServerLocationByCluster(ctx context.Context, cluster *platform.Cluster, platformClient platforminternalclient.PlatformInterface) (*url.URL, http.RoundTripper, string, error)

APIServerLocationByCluster returns a URL and transport which one can use to send traffic for the specified cluster api server.

func BuildClientSet 

func BuildClientSet(ctx context.Context, cluster *platform.Cluster, credential *platform.ClusterCredential) (*kubernetes.Clientset, error)

BuildClientSet creates client based on cluster information and returns it.

func BuildExternalClientSet 

func BuildExternalClientSet(ctx context.Context, cluster *platformv1.Cluster, client platformversionedclient.PlatformV1Interface) (*kubernetes.Clientset, error)

BuildExternalClientSet creates the clientset of kubernetes by given cluster object and returns it.

func BuildExternalClientSetWithName 

func BuildExternalClientSetWithName(ctx context.Context, platformClient platformversionedclient.PlatformV1Interface, name string) (*kubernetes.Clientset, error)

BuildExternalClientSetWithName creates the clientset of kubernetes by given cluster name and returns it.

func BuildExternalDynamicClientSet 

func BuildExternalDynamicClientSet(cluster *platformv1.Cluster, credential *platformv1.ClusterCredential) (dynamic.Interface, error)

BuildExternalDynamicClientSet creates the dynamic clientset of kubernetes by given cluster object and returns it.

func BuildExternalDynamicClientSetNoStatus 

func BuildExternalDynamicClientSetNoStatus(cluster *platformv1.Cluster, credential *platformv1.ClusterCredential) (dynamic.Interface, error)

BuildExternalDynamicClientSetNoStatus creates the dynamic clientset of kubernetes by given cluster object and returns it.

func BuildExternalExtensionClientSet 

func BuildExternalExtensionClientSet(ctx context.Context, cluster *platformv1.Cluster, client platformversionedclient.PlatformV1Interface) (*apiextensionsclient.Clientset, error)

BuildExternalExtensionClientSet creates the api extension clientset of kubernetes by given cluster object and returns it.

func BuildExternalExtensionClientSetNoStatus 

func BuildExternalExtensionClientSetNoStatus(ctx context.Context, cluster *platformv1.Cluster, client platformversionedclient.PlatformV1Interface) (*apiextensionsclient.Clientset, error)

BuildExternalExtensionClientSetNoStatus creates the api extension clientset of kubernetes by given cluster object and returns it.

func BuildExternalMonitoringClientSet 

func BuildExternalMonitoringClientSet(ctx context.Context, cluster *platformv1.Cluster, client platformversionedclient.PlatformV1Interface) (monitoringclient.Interface, error)

BuildExternalMonitoringClientSet creates the monitoring clientset of prometheus operator by given cluster object and returns it.

func BuildExternalMonitoringClientSetNoStatus 

func BuildExternalMonitoringClientSetNoStatus(ctx context.Context, cluster *platformv1.Cluster, client platformversionedclient.PlatformV1Interface) (monitoringclient.Interface, error)

BuildExternalMonitoringClientSetNoStatus creates the monitoring clientset of prometheus operator by given cluster object and returns it.

func BuildInternalDynamicClientSet 

func BuildInternalDynamicClientSet(cluster *platform.Cluster, credential *platform.ClusterCredential) (dynamic.Interface, error)

BuildInternalDynamicClientSet creates the dynamic clientset of kubernetes by given cluster object and returns it.

func BuildInternalDynamicClientSetNoStatus 

func BuildInternalDynamicClientSetNoStatus(cluster *platform.Cluster, credential *platform.ClusterCredential) (dynamic.Interface, error)

BuildInternalDynamicClientSetNoStatus creates the dynamic clientset of kubernetes by given cluster object and returns it.

func BuildKubeAggregatorClientSet added in v1.6.0 

func BuildKubeAggregatorClientSet(ctx context.Context, cluster *platformv1.Cluster, client platformversionedclient.PlatformV1Interface) (*kubeaggregatorclientset.Clientset, error)

BuildKubeAggregatorClientSet creates the kube-aggregator clientset of kubernetes by given cluster object and returns it.

func BuildKubeAggregatorClientSetNoStatus added in v1.6.0 

func BuildKubeAggregatorClientSetNoStatus(ctx context.Context, cluster *platformv1.Cluster, client platformversionedclient.PlatformV1Interface) (*kubeaggregatorclientset.Clientset, error)

BuildKubeAggregatorClientSetNoStatus creates the kube-aggregator clientset of kubernetes by given cluster object and returns it.

func BuildTransport 

func BuildTransport(credential *platform.ClusterCredential) (http.RoundTripper, error)

BuildTransport create the http transport for communicate to backend kubernetes api server.

func BuildVersionedClientSet 

func BuildVersionedClientSet(cluster *platformv1.Cluster, credential *platformv1.ClusterCredential) (*kubernetes.Clientset, error)

BuildVersionedClientSet creates the clientset of kubernetes by given cluster object and returns it.

func ClientSetByCluster 

func ClientSetByCluster(ctx context.Context, cluster *platform.Cluster, platformClient platforminternalclient.PlatformInterface) (*kubernetes.Clientset, error)

ClientSetByCluster returns the backend kubernetes clientSet by given cluster object

func ClusterAddress added in v1.2.5 

func ClusterAddress(cluster *platform.Cluster) (*platform.ClusterAddress, error)

func ClusterHost 

func ClusterHost(cluster *platform.Cluster) (string, error)

ClusterHost returns host and port for kube-apiserver of cluster.

func ClusterV1Host 

func ClusterV1Host(c *platformv1.Cluster) (string, error)

ClusterV1Host returns host and port for kube-apiserver of versioned cluster resource.

func DynamicClientByCluster 

func DynamicClientByCluster(ctx context.Context, cluster *platform.Cluster, platformClient platforminternalclient.PlatformInterface) (dynamic.Interface, error)

func FilterCSIOperator 

func FilterCSIOperator(ctx context.Context, csiOperator *platform.CSIOperator) error

FilterCSIOperator is used to filter csi operator that do not belong to the tenant.

func FilterCluster 

func FilterCluster(ctx context.Context, cluster *platform.Cluster) error

FilterCluster is used to filter clusters that do not belong to the tenant.

func FilterClusterCredential 

func FilterClusterCredential(ctx context.Context, obj *platform.ClusterCredential) error

FilterClusterCredential is used to filter ClusterCredential that do not belong to the tenant.

func FilterCronHPA 

func FilterCronHPA(ctx context.Context, cronHPA *platform.CronHPA) error

FilterCronHPA is used to filter CronHPA that do not belong to the tenant.

func FilterHelm 

func FilterHelm(ctx context.Context, helm *platform.Helm) error

FilterHelm is used to filter helm that do not belong to the tenant.

func FilterIPAM 

func FilterIPAM(ctx context.Context, ipam *platform.IPAM) error

FilterIPAM is used to filter ipam that do not belong to the tenant.

func FilterLBCF 

func FilterLBCF(ctx context.Context, lbcf *platform.LBCF) error

FilterLBCF is used to filter LBCF that do not belong to the tenant.

func FilterLogCollector 

func FilterLogCollector(ctx context.Context, decorator *platform.LogCollector) error

FilterLogCollector is used to filter log collector that do not belong to the tenant.

func FilterMachine 

func FilterMachine(ctx context.Context, machine *platform.Machine) error

FilterMachine is used to filter machine that do not belong to the tenant.

func FilterPersistentEvent 

func FilterPersistentEvent(ctx context.Context, pe *platform.PersistentEvent) error

FilterPersistentEvent is used to filter persistent event that do not belong to the tenant.

func FilterPrometheus 

func FilterPrometheus(ctx context.Context, prom *platform.Prometheus) error

FilterPrometheus is used to filter helm that do not belong to the tenant.

func FilterRegistry 

func FilterRegistry(ctx context.Context, registry *platform.Registry) error

FilterRegistry is used to filter registry that do not belong to the tenant.

func FilterTappController 

func FilterTappController(ctx context.Context, tappController *platform.TappController) error

FilterTappController is used to filter tapp controller that do not belong to the tenant.

func FilterVolumeDecorator 

func FilterVolumeDecorator(ctx context.Context, decorator *platform.VolumeDecorator) error

FilterVolumeDecorator is used to filter volume decorator that do not belong to the tenant.

func GetEvents 

func GetEvents(ctx context.Context, client *kubernetes.Clientset, uid, namespace, name, kind string) (*corev1.EventList, error)

GetEvents list the resource events by resource namespace and name.

func GetExternalRestConfig 

func GetExternalRestConfig(cluster *platformv1.Cluster, credential *platformv1.ClusterCredential) (*restclient.Config, error)

GetExternalRestConfig returns rest config according to cluster

func GetInternalRestConfig 

func GetInternalRestConfig(cluster *platform.Cluster, credential *platform.ClusterCredential) (*restclient.Config, error)

GetInternalRestConfig returns rest config according to cluster

func GetPlatformVersionsFromClusterInfo added in v1.6.0 

func GetPlatformVersionsFromClusterInfo(ctx context.Context, client kubernetes.Interface) (tkeVersion string, k8sValidVersions []string, err error)

func ResourceFromKind 

func ResourceFromKind(kind string) string

ResourceFromKind returns the resource name by kind.

Types

type CustomResource 

type CustomResource struct {
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// Spec defines the desired identities of pods in this crd.
	Spec CustomResourceSpec `json:"spec,omitempty"`
}

CustomResource is simple version of struct crd, it is used for unmarshall.

type CustomResourceSpec 

type CustomResourceSpec struct {
	Selector *metav1.LabelSelector `json:"selector,omitempty"`
}

CustomResourceSpec is spec for CustomResource.

type EventSlice 

type EventSlice []corev1.Event

EventSlice implements sort.Interface for []Event based on the EventTime field.

func (EventSlice) Len 

func (e EventSlice) Len() int

func (EventSlice) Less 

func (e EventSlice) Less(i, j int) bool

func (EventSlice) Swap 

func (e EventSlice) Swap(i, j int)

Source Files

View all Source files

Directories

Path Synopsis

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.