utils

Documentation

Index

• Constants
• Variables
• func ComponentLogName(name, typ, version string) string
• func Contains[T comparable](s []T, v T) bool
• func CurrentNamespaceOrError() (string, error)
• func Filter[T any](items []T, test func(item T) bool) []T
• func GetConfig() *rest.Config
• func GetEnvOrElse(name, orElse string) string
• func GetHostAddress() (string, error)
• func GetIntValOrDefault(val int, defaultValue int) int
• func GetKubeClient() *kubernetes.Clientset
• func GetKubeClusterDomain() (string, error)
• func IsSocket(f fs.FileInfo) bool
• func IsTruthy(val string) bool
• func IsYaml(fileName string) bool
• func PopulateMetadataForBulkPublishEntry(reqMeta, entryMeta map[string]string) map[string]string
• func SetEnvVariables(variables map[string]string) error
• func SocketExists(socketPath string) bool
• func UppercaseRequestMiddleware(next http.Handler) http.Handler
• func UppercaseResponseMiddleware(next http.Handler) http.Handler
• type ByteSlicePool
  • func NewByteSlicePool(minCap int) *ByteSlicePool
  • func (sp ByteSlicePool) Get(cap int) []byte
  • func (sp ByteSlicePool) Put(bs []byte)
  • func (sp ByteSlicePool) Resize(orig []byte, size int) []byte

Constants

const (
	// DefaultKubeClusterDomain is the default value of KubeClusterDomain.
	DefaultKubeClusterDomain = "cluster.local"
)

const (
	// HostIPEnvVar is the environment variable to override host's chosen IP address.
	HostIPEnvVar = "DAPR_HOST_IP"
)

Variables

var (
	KubeConfigVar = "KUBE_CONFIG"
)

Functions

func ComponentLogName

func ComponentLogName(name, typ, version string) string

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

func Contains

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 CurrentNamespaceOrError

func CurrentNamespaceOrError() (string, error)

CurrentNamespaceOrError returns the namespace of this workload. If current Namespace is not found, error.

func Filter

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

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

func GetHostAddress() (string, error)

GetHostAddress selects a valid outbound IP address for the host.

func GetIntValOrDefault

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

func GetKubeClusterDomain() (string, error)

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

func IsSocket

func IsSocket(f fs.FileInfo) bool

IsSocket returns if the given file is a unix socket.

func IsTruthy

func IsTruthy(val string) bool

IsTruthy returns true if a string is a truthy value. Truthy values are "y", "yes", "true", "t", "on", "1" (case-insensitive); everything else is false.

func IsYaml

func IsYaml(fileName string) bool

IsYaml checks whether the file is yaml or not.

func PopulateMetadataForBulkPublishEntry

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

func SetEnvVariables

func SetEnvVariables(variables map[string]string) error

SetEnvVariables set variables to environment.

func SocketExists

func SocketExists(socketPath string) bool

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

func UppercaseRequestMiddleware

func UppercaseRequestMiddleware(next http.Handler) http.Handler

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

func UppercaseResponseMiddleware

func UppercaseResponseMiddleware(next http.Handler) http.Handler

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

Types

type ByteSlicePool

type ByteSlicePool struct {
	MinCap int
	// contains filtered or unexported fields
}

ByteSlicePool is a wrapper around sync.Pool to get []byte objects with a given capacity.

func NewByteSlicePool

func NewByteSlicePool(minCap int) *ByteSlicePool

NewByteSlicePool returns a new ByteSlicePool object.

func (ByteSlicePool) Get

func (sp ByteSlicePool) Get(cap int) []byte

Get a slice from the pool. The cap parameter is used only if we need to allocate a new byte slice; there's no guarantee a slice retrieved from the pool will have enough capacity for that.

func (ByteSlicePool) Put

func (sp ByteSlicePool) Put(bs []byte)

Put a slice back in the pool.

func (ByteSlicePool) Resize

func (sp ByteSlicePool) Resize(orig []byte, size int) []byte

Resize a byte slice, making sure that it has enough capacity for a given size.