utils

package
v1.14.0-rc.12 Latest Latest
Warning

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

Go to latest
Published: Aug 13, 2024 License: Apache-2.0 Imports: 16 Imported by: 4

Documentation

Index

Constants

View Source
const (
	// DefaultKubeClusterDomain is the default value of KubeClusterDomain.
	DefaultKubeClusterDomain = "cluster.local"
)
View Source
const (
	DotDelimiter = "."
)
View Source
const (
	// HostIPEnvVar is the environment variable to override host's chosen IP address.
	HostIPEnvVar = "DAPR_HOST_IP"
)

Variables

View Source
var (
	KubeConfigVar = "KUBE_CONFIG"
)

Functions

func ComponentLogName added in v1.10.0

func ComponentLogName(name, typ, version string) string

ComponentLogName returns the name of a component that can be used in logging.

func Contains added in v1.9.0

func Contains[T comparable](s []T, v T) bool

Contains reports whether v is present in s. Similar to https://pkg.go.dev/golang.org/x/exp/slices#Contains.

func ContainsPrefixed added in v1.11.0

func ContainsPrefixed(prefixes []string, v string) bool

ContainsPrefixed reports whether v is prefixed by any of the strings in s.

func Filter added in v1.10.0

func Filter[T any](items []T, test func(item T) bool) []T

Filter returns a new slice containing all items in the given slice that satisfy the given test.

func GetConfig

func GetConfig() *rest.Config

GetConfig gets a kubernetes rest config.

func GetEnvOrElse added in v1.9.0

func GetEnvOrElse(name, orElse string) string

GetEnvOrElse get the value from the OS environment or use the else value if variable is not present.

func GetHostAddress added in v0.8.0

func GetHostAddress() (string, error)

GetHostAddress selects a valid outbound IP address for the host.

func GetIntValOrDefault added in v1.10.0

func GetIntValOrDefault(val int, defaultValue int) int

GetIntValOrDefault returns an int value if greater than 0 OR default value.

func GetKubeClient

func GetKubeClient() *kubernetes.Clientset

GetKubeClient gets a kubernetes client.

func GetKubeClusterDomain added in v1.3.0

func GetKubeClusterDomain() (string, error)

GetKubeClusterDomain search KubeClusterDomain value from /etc/resolv.conf file.

func GetNamespaceOrDefault added in v1.11.0

func GetNamespaceOrDefault(defaultNamespace string) string

GetNamespaceOrDefault returns the namespace for Dapr, or the default namespace if it is not set.

func IsSocket added in v1.9.0

func IsSocket(f fs.FileInfo) bool

IsSocket returns if the given file is a unix socket.

func MapToSlice added in v1.11.0

func MapToSlice[T comparable, V any](m map[T]V) []T

MapToSlice is the inversion of SliceToMap. Order is not guaranteed as map retrieval order is not.

func ParseServiceAddr added in v1.13.0

func ParseServiceAddr(val string) []string

func PopulateMetadataForBulkPublishEntry added in v1.10.0

func PopulateMetadataForBulkPublishEntry(reqMeta, entryMeta map[string]string) map[string]string

func SetEnvVariables added in v1.8.0

func SetEnvVariables(variables map[string]string) error

SetEnvVariables set variables to environment.

func SocketExists added in v1.9.0

func SocketExists(socketPath string) bool

SocketExists returns true if the file in that path is an unix socket.

func UppercaseRequestMiddleware added in v1.10.0

func UppercaseRequestMiddleware(next http.Handler) http.Handler

UppercaseRequestMiddleware is a HTTP middleware that transforms the request body to uppercase

func UppercaseResponseMiddleware added in v1.10.0

func UppercaseResponseMiddleware(next http.Handler) http.Handler

UppercaseResponseMiddleware is a HTTP middleware that transforms the response body to uppercase

Types

This section is empty.

Jump to

Keyboard shortcuts

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