utils

package

v0.5.1 Latest Latest Go to latest Published: Jul 4, 2022 License: Apache-2.0 Imports: 16 Imported by: 4

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/liqotech/liqo

Links

Open Source Insights

Documentation ¶

Overview ¶

Package utils contains shared utility methods for the Liqonet package.

Index ¶

Constants
func FromResult(result controllerutil.OperationResult) klog.Level
func GetClusterID(ctx context.Context, cl kubernetes.Interface, namespace string) (string, error)
func GetClusterIdentityWithControllerClient(ctx context.Context, controllerClient client.Client, namespace string) (discoveryv1alpha1.ClusterIdentity, error)
func GetClusterIdentityWithNativeClient(ctx context.Context, nativeClient kubernetes.Interface, namespace string) (discoveryv1alpha1.ClusterIdentity, error)
func GetClusterName(ctx context.Context, k8sClient kubernetes.Interface, namespace string) (string, error)
func GetNodeClusterID(selectedNode *corev1.Node) (string, bool)
func GetOwnerByKind(ownerReferences *[]v1.OwnerReference, kind string) *v1.OwnerReference
func GetRestConfig(configPath string) (config *rest.Config, err error)
func IsNodeReady(node *corev1.Node) bool
func IsVirtualNode(node *corev1.Node) bool
func MergeMaps(m1, m2 map[string]string) map[string]string
func MergeNodeSelector(ns1, ns2 *corev1.NodeSelector) corev1.NodeSelector
func RandomString(n int) string
func SubMaps(m1, m2 map[string]string) map[string]string
func UserConfig(configPath string) (*rest.Config, error)
func WriteFile(filepath string, content []byte) error

Constants ¶

View Source

const (
	// LogInfoLevel -> level associated with informational messages.
	LogInfoLevel = 0
	// LogDebugLevel -> level associated with debug messages.
	LogDebugLevel = 4
)

Variables ¶

This section is empty.

Functions ¶

func FromResult ¶ added in v0.3.0

func FromResult(result controllerutil.OperationResult) klog.Level

FromResult returns a logger level, given the result of a CreateOrUpdate operation.

func GetClusterID ¶ added in v0.3.2

func GetClusterID(ctx context.Context, cl kubernetes.Interface, namespace string) (string, error)

GetClusterID returns the local clusterID.

func GetClusterIdentityWithControllerClient ¶ added in v0.3.2

func GetClusterIdentityWithControllerClient(ctx context.Context,
	controllerClient client.Client, namespace string) (discoveryv1alpha1.ClusterIdentity, error)

GetClusterIdentityWithControllerClient returns cluster identity using a client.Client client.

func GetClusterIdentityWithNativeClient ¶ added in v0.3.2

func GetClusterIdentityWithNativeClient(ctx context.Context,
	nativeClient kubernetes.Interface, namespace string) (discoveryv1alpha1.ClusterIdentity, error)

GetClusterIdentityWithNativeClient returns cluster identity using a kubernetes.Interface client.

func GetClusterName ¶ added in v0.3.2

func GetClusterName(ctx context.Context, k8sClient kubernetes.Interface, namespace string) (string, error)

GetClusterName returns the local cluster name.

func GetNodeClusterID ¶ added in v0.3.2

func GetNodeClusterID(selectedNode *corev1.Node) (string, bool)

GetNodeClusterID returns the clusterID given a virtual node.

func GetOwnerByKind ¶ added in v0.3.0

func GetOwnerByKind(ownerReferences *[]v1.OwnerReference, kind string) *v1.OwnerReference

func GetRestConfig ¶ added in v0.3.0

func GetRestConfig(configPath string) (config *rest.Config, err error)

GetRestConfig returns a rest.Config object to initialize a client to the target cluster.

func IsNodeReady ¶ added in v0.3.0

func IsNodeReady(node *corev1.Node) bool

IsNodeReady returns true if the passed node has the NodeReady condition = True, false otherwise.

func IsVirtualNode ¶ added in v0.3.2

func IsVirtualNode(node *corev1.Node) bool

IsVirtualNode returns true if the passed node is a virtual node, false otherwise.

func MergeMaps ¶ added in v0.3.0

func MergeMaps(m1, m2 map[string]string) map[string]string

MergeMaps merges two maps.

func MergeNodeSelector ¶ added in v0.3.2

func MergeNodeSelector(ns1, ns2 *corev1.NodeSelector) corev1.NodeSelector

MergeNodeSelector merges two nodeSelectors. Every MatchExpression of the first one must be merged with all the MatchExpressions of the second one: n first MatchExpressions. m second MatchExpressions. m * n MergedNodeSelector MatchExpressions. For each term in the first selector, AND each term of the second selector: (A || B) && (C || D) -> (A && C) || (A && D) || (B && C) || (B && D).

func RandomString ¶ added in v0.4.0

func RandomString(n int) string

RandomString generates a random string of the given length.

func SubMaps ¶ added in v0.3.0

func SubMaps(m1, m2 map[string]string) map[string]string

SubMaps removes elements of m2 from m1.

func UserConfig ¶

func UserConfig(configPath string) (*rest.Config, error)

func WriteFile ¶

func WriteFile(filepath string, content []byte) error

Types ¶

This section is empty.

Source Files ¶

View all Source files

Directories ¶

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL

Path	Synopsis
apiserver Package apiserver contains utility functions to configure the connection parameters to the Kubernetes API server to advertise to peering clusters.	Package apiserver contains utility functions to configure the connection parameters to the Kubernetes API server to advertise to peering clusters.
args Package args contains shared utility methods for argument parsing and validation.	Package args contains shared utility methods for argument parsing and validation.
authenticationtoken Package authenticationtoken contains shared utility methods for the management of the authentication token.	Package authenticationtoken contains shared utility methods for the management of the authentication token.
cachedClient Package cachedclient contains utility methods to create a new controller runtime client with cache.	Package cachedclient contains utility methods to create a new controller runtime client with cache.
errors Package errors contains utility functions to deal with errors.	Package errors contains utility functions to deal with errors.
foreignCluster Package foreigncluster contains shared utility methods to handle the ForeignCluster resources.	Package foreigncluster contains shared utility methods to handle the ForeignCluster resources.
getters Package getters contains utility functions to get k8s resources and at the same time to extract data from the same resources.	Package getters contains utility functions to get k8s resources and at the same time to extract data from the same resources.
labels Package labels label selectors used throughout the liqo code in order to get k8s resources.	Package labels label selectors used throughout the liqo code in order to get k8s resources.
mapper Package mapper contains the utility functions for k8s resource REST mapping.	Package mapper contains the utility functions for k8s resource REST mapping.
peeringConditions Package peeringconditionsutils contains shared utility methods to handle the PeeringCondition resource.	Package peeringconditionsutils contains shared utility methods to handle the PeeringCondition resource.
pod Package pod contains utilities to deal with Pod objects.	Package pod contains utilities to deal with Pod objects.
restcfg Package restcfg contains utility functions to deal with rest configs.	Package restcfg contains utility functions to deal with rest configs.
slice Package slice contains utility functions to manage slices.	Package slice contains utility functions to manage slices.
syncset Package syncset provides a structure describing a set of elements safe for concurrent usage.	Package syncset provides a structure describing a set of elements safe for concurrent usage.
testutil Package testutil contains some methods useful to mock components while testing	Package testutil contains some methods useful to mock components while testing
trace Package trace contains utility functions to deal with traces.	Package trace contains utility functions to deal with traces.