util

package
v1.9.3 Latest Latest
Warning

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

 Go to latest Published: Nov 27, 2024 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	SHA256New scram.HashGeneratorFcn = sha256.New
	SHA512New scram.HashGeneratorFcn = sha512.New
)
View Source 
var (
	DefaultBackoff = aev1.Backoff{
		Steps:    5,
		Duration: &defaultDuration,
		Factor:   &defaultFactor,
		Jitter:   &defaultJitter,
	}
)

Functions

func Convert2WaitBackoff 

func Convert2WaitBackoff(backoff *aev1.Backoff) (*wait.Backoff, error)

Convert2WaitBackoff converts to a wait backoff option

func DoWithRetry 

func DoWithRetry(backoff *aev1.Backoff, f func() error) error

func ElementsMatch 

func ElementsMatch(first []string, second []string) bool

ElementsMatch returns true if the two provided string slices contain the same elements while avoiding duplications. WARN: this method avoids duplications.

func ErrEventSourceTypeMismatch 

func ErrEventSourceTypeMismatch(eventSourceType string) string

func FormatEndpoint 

func FormatEndpoint(endpoint string) string

FormatEndpoint returns a formatted api endpoint

func FormattedURL 

func FormattedURL(url, endpoint string) string

FormattedURL returns a formatted url

func GenerateConfigMapVolumeSpecs 

func GenerateConfigMapVolumeSpecs(selector *v1.ConfigMapKeySelector) (v1.Volume, v1.VolumeMount)

GenerateConfigMapVolumeSpecs builds a "volume" and "volumeMount"spec with a configMapKeySelector

func GenerateEnvFromConfigMapSpec 

func GenerateEnvFromConfigMapSpec(selector *v1.ConfigMapKeySelector) v1.EnvFromSource

GenerateEnvFromConfigMapSpec builds a "envFrom" spec with a configMapKeySelector

func GenerateEnvFromSecretSpec 

func GenerateEnvFromSecretSpec(selector *v1.SecretKeySelector) v1.EnvFromSource

GenerateEnvFromSecretSpec builds a "envFrom" spec with a secretKeySelector

func GenerateSecretVolumeSpecs 

func GenerateSecretVolumeSpecs(selector *v1.SecretKeySelector) (v1.Volume, v1.VolumeMount)

GenerateSecretVolumeSpecs builds a "volume" and "volumeMount"spec with a secretKeySelector

func GetClientConfig 

func GetClientConfig(kubeconfig string) (*rest.Config, error)

GetClientConfig return rest config, if path not specified, assume in cluster config

func GetConfigMapFromVolume 

func GetConfigMapFromVolume(selector *v1.ConfigMapKeySelector) (string, error)

GetConfigMapFromVolume retrieves the value of mounted config map volume "/argo-events/config/${configMapRef.name}/${configMapRef.key}" is expected to be the file path

func GetConfigMapVolumePath 

func GetConfigMapVolumePath(selector *v1.ConfigMapKeySelector) (string, error)

GetConfigMapVolumePath returns the path of the mounted configmap

func GetEnvFromConfigMap 

func GetEnvFromConfigMap(selector *v1.ConfigMapKeySelector) (string, bool)

GetEnvFromConfigMap retrieves the value of envFrom.configMapRef "${configMapRef.name}_" is expected to be defined as "prefix"

func GetEnvFromSecret 

func GetEnvFromSecret(selector *v1.SecretKeySelector) (string, bool)

GetEnvFromSecret retrieves the value of envFrom.secretRef "${secretRef.name}_" is expected to be defined as "prefix"

func GetImagePullPolicy 

func GetImagePullPolicy() v1.PullPolicy

func GetObjectHash 

func GetObjectHash(obj metav1.Object) (string, error)

GetObjectHash returns hash of a given object

func GetSaramaConfigFromYAMLString 

func GetSaramaConfigFromYAMLString(yaml string) (*sarama.Config, error)

GetSaramaConfigFromYAMLString parse yaml string to sarama.config. Note: All the time.Duration config can not be correctly decoded because it does not implement the decode function.

func GetSecretFromVolume 

func GetSecretFromVolume(selector *v1.SecretKeySelector) (string, error)

GetSecretFromVolume retrieves the value of mounted secret volume "/argo-events/secrets/${secretRef.name}/${secretRef.key}" is expected to be the file path

func GetSecretValue 

func GetSecretValue(ctx context.Context, client kubernetes.Interface, namespace string, selector *v1.SecretKeySelector) (string, error)

GetSecretValue retrieves the secret value from the secret in namespace with name and key

func GetSecretVolumePath 

func GetSecretVolumePath(selector *v1.SecretKeySelector) (string, error)

GetSecretVolumePath returns the path of the mounted secret

func GetTLSConfig 

func GetTLSConfig(config *aev1.TLSConfig) (*tls.Config, error)

GetTLSConfig returns a tls configuration for given cert and key or skips the certs if InsecureSkipVerify is true.

func Hasher 

func Hasher(value string) string

Hasher hashes a string

func IsRetryableKubeAPIError 

func IsRetryableKubeAPIError(err error) bool

IsRetryableKubeAPIError returns if the error is a retryable kubernetes error

func LookupEnvStringOr 

func LookupEnvStringOr(key, defaultValue string) string

func MustHash 

func MustHash(v interface{}) string

func MustJSON 

func MustJSON(in interface{}) string

func MustUnJSON 

func MustUnJSON(v interface{}, in interface{})

MustUnJSON unmarshalls JSON or panics. v - must be []byte or string in - must be a pointer.

func ParseExclusionDates 

func ParseExclusionDates(vals []string) ([]time.Time, error)

ParseExclusionDates parses the exclusion dates from the vals string according to RFC 5545

func ParseTime 

func ParseTime(t string, baseDate time.Time) (time.Time, error)

ParseTime parses time string in "HH:MM:SS" format into time.Time, which date is same as baseDate in UTC.

func PrevCronTime 

func PrevCronTime(cronSpec string, parser cronlib.Parser, t time.Time) (time.Time, error)

For a given cron specification, return the previous activation time If no time can be found to satisfy the schedule, return the zero time.

func RandomString 

func RandomString(length int) string

generate a random string with given length

func SendErrorResponse 

func SendErrorResponse(writer http.ResponseWriter, response string)

SendErrorResponse sends http error response

func SendInternalErrorResponse 

func SendInternalErrorResponse(writer http.ResponseWriter, response string)

SendInternalErrorResponse sends http internal error response

func SendResponse 

func SendResponse(writer http.ResponseWriter, statusCode int, response string)

SendResponse sends http response with given status code

func SendSuccessResponse 

func SendSuccessResponse(writer http.ResponseWriter, response string)

SendSuccessResponse sends http success response

func SliceContains 

func SliceContains(strSlice []string, targetStr string) bool

SliceContains checks if a string slice contains a specific string

func StructToMap 

func StructToMap(obj interface{}, output map[string]interface{}) error

func ViperWithLogging 

func ViperWithLogging() *viper.Viper

func VolumesFromSecretsOrConfigMaps 

func VolumesFromSecretsOrConfigMaps(t reflect.Type, objs ...interface{}) ([]v1.Volume, []v1.VolumeMount)

VolumesFromSecretsOrConfigMaps builds volumes and volumeMounts spec based on the obj and its children's secretKeyselector or configMapKeySelector

Types

type StringKeyedMap 

type StringKeyedMap[T any] struct {
	// contains filtered or unexported fields
}

Concurrent Safe String keyed map

func NewStringKeyedMap 

func NewStringKeyedMap[T any]() StringKeyedMap[T]

func (*StringKeyedMap[T]) Delete 

func (sm *StringKeyedMap[T]) Delete(key string)

func (*StringKeyedMap[T]) Load 

func (sm *StringKeyedMap[T]) Load(key string) (T, bool)

func (*StringKeyedMap[T]) Store 

func (sm *StringKeyedMap[T]) Store(key string, item T)

type XDGSCRAMClient 

type XDGSCRAMClient struct {
	*scram.Client
	*scram.ClientConversation
	scram.HashGeneratorFcn
}

func (*XDGSCRAMClient) Begin 

func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error)

func (*XDGSCRAMClient) Done 

func (x *XDGSCRAMClient) Done() bool

func (*XDGSCRAMClient) Step 

func (x *XDGSCRAMClient) Step(challenge string) (response string, err error)

Source Files

View all Source files

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.