util

package
v1.6.0 Latest Latest
Warning

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

 Go to latest Published: Mar 25, 2021 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause, + 8 more Imports: 35 Imported by: 76

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 BuildExternalMonitoringClientSetWithName 

func BuildExternalMonitoringClientSetWithName(ctx context.Context, platformClient platformversionedclient.PlatformV1Interface, name string) (monitoringclient.Interface, error)

BuildExternalMonitoringClientSetWithName creates the clientset of prometheus operator by given cluster name 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 CheckClusterHealthzWithTimeout 

func CheckClusterHealthzWithTimeout(ctx context.Context, platformClient platformversionedclient.PlatformV1Interface, name string, timeout time.Duration) error

CheckClusterHealthzWithTimeout check cluster status within timeout

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 GetClusterCredential added in v1.3.1 

func GetClusterCredential(ctx context.Context, client platforminternalclient.PlatformInterface, cluster *platform.Cluster) (*platform.ClusterCredential, error)

GetClusterCredential returns the cluster's credential

func GetClusterCredentialV1 added in v1.3.1 

func GetClusterCredentialV1(ctx context.Context, client platformversionedclient.PlatformV1Interface, cluster *platformv1.Cluster) (*platformv1.ClusterCredential, error)

GetClusterCredentialV1 returns the versioned cluster's credential

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.