util

Documentation

Index

• Constants
• func ContainsInSlice(slice []string, s string) bool
• func GetErrorMessage(err error) string
• func IsUnimplementedError(err error) bool
• func RemoveFromSlice(slice []string, s string) []string
• type Config
  • func NewConfig() Config
  • func (cfg *Config) ReadConfigMap(ctx context.Context, kubeClient *kubernetes.Clientset) error

Constants

const (
	ReclaimSpaceTimeoutKey     = "reclaim-space-timeout"
	MaxConcurrentReconcilesKey = "max-concurrent-reconciles"
)

Functions

func ContainsInSlice

func ContainsInSlice(slice []string, s string) bool

ConstainsInSlice find given string in given slice.

func GetErrorMessage

func GetErrorMessage(err error) string

GetErrorMessage returns the message from the error if it is a grpc error, else returns err.Error().

func IsUnimplementedError

func IsUnimplementedError(err error) bool

IsUnimplementedError returns true if the error is Unimplemented error.

func RemoveFromSlice

func RemoveFromSlice(slice []string, s string) []string

RemoveFromSlice removes given string from given slice.

Types

type Config

type Config struct {
	Namespace               string
	ReclaimSpaceTimeout     time.Duration
	MaxConcurrentReconciles int
}

Config holds the configuration options that can be overrrided via a config file.

func NewConfig

func NewConfig() Config

NewConfig returns a new Config object with default values.

func (*Config) ReadConfigMap

func (cfg *Config) ReadConfigMap(ctx context.Context, kubeClient *kubernetes.Clientset) error

ReadConfigFile fetches the config file and updates the config options with values read from the config map.