Documentation ¶
Index ¶
- Constants
- Variables
- func CheckHealthz() map[HealthzCheckName]HealthzCheckResponse
- func CheckMapEqual(pre, cur map[string]string) bool
- func CmpBool(a, b bool) int
- func CmpError(err1, err2 error) int
- func CmpFloat64(a, b float64) int
- func CmpInt32(a, b int32) int
- func CovertInt64ToInt(numInt64 int64) (int, error)
- func CovertUInt64ToInt(numUInt64 uint64) (int, error)
- func DeepCopyMap(origin map[string]string) map[string]string
- func EnsureDirectory(dir string) error
- func ErrorS(err error, message string, params ...interface{})
- func Errorf(message string, params ...interface{})
- func Fatalf(message string, params ...interface{})
- func GenerateHash(data []byte, length int) string
- func GetInt64PointerFromUint64Pointer(v *uint64) (*int64, error)
- func GetOneExistPath(paths []string) string
- func GetSortedMapKeys(m map[string]int) []string
- func GetStringValueFromMap(m map[string]string, key string) string
- func GetValueWithDefault(m map[string]string, key, defaultV string) string
- func InfoS(message string, params ...interface{})
- func Infof(message string, params ...interface{})
- func InfofV(level int, message string, params ...interface{})
- func IntFractionMultiply(origin int, numerator int, denominator int) int
- func IntSliceToStringSlice(a []int) []string
- func IsNameEnabled(name string, disabledByDefault sets.String, enableNames []string) bool
- func IsPathExists(path string) bool
- func IsUnmarshalTypeError(err error) bool
- func JsonPathEmpty(str []byte) bool
- func Max(a, b int) int
- func MaxInt64(a, b int64) int64
- func MaxUInt64(a, b uint64) uint64
- func MergeMap(src, override map[string]string) map[string]string
- func MergeMapInt(src, override map[string]int) map[string]int
- func Min(a, b int) int
- func MinUInt64(a, b uint64) uint64
- func ParseMapWithPrefix(prefix, selector string) (map[string]string, error)
- func ParseStringToUint64Pointer(s string) (*uint64, error)
- func ParseUint64PointerToString(v *uint64) string
- func ReadFileIntoInt(filepath string) (int, error)
- func ReadFileIntoLines(filepath string) ([]string, error)
- func RegisterFileEventWatcher(stop <-chan struct{}, fileWatcherInfo FileWatcherInfo) (<-chan struct{}, error)
- func RegisterHealthzCheckRules(name HealthzCheckName, f HealthzCheckFunc)
- func ReleaseUniqueLock(lock *Flock)
- func SumUpMapValues(m map[string]int) int
- func SumUpMultipleMapValues(m map[string]map[string]int) int
- func ToString(in interface{}) string
- func UInt64PointerToFloat64(p *uint64) float64
- func UIntPointerToFloat64(p *uint) float64
- func Warningf(message string, params ...interface{})
- type CappedSmoothWindow
- type CmpFunc
- type FileWatcherInfo
- type Flock
- type HealthzCheckFunc
- type HealthzCheckName
- type HealthzCheckResponse
- type HealthzCheckState
- type Logger
- func (l Logger) ErrorS(err error, message string, params ...interface{})
- func (l Logger) Errorf(message string, params ...interface{})
- func (l Logger) Fatalf(message string, params ...interface{})
- func (l Logger) InfoS(message string, params ...interface{})
- func (l Logger) Infof(message string, params ...interface{})
- func (l Logger) InfofV(level int, message string, params ...interface{})
- func (l Logger) Warningf(message string, params ...interface{})
- type LoggingPKG
- type MultiSorter
- type Pair
- type ResourceList
- type SmoothWindow
- type SourceList
Constants ¶
const ( FlockCoolingInterval = 6 * time.Second FlockTryLockMaxTimes = 10 )
Variables ¶
var ( // NativeEndian is the native endian NativeEndian binary.ByteOrder )
Functions ¶
func CheckHealthz ¶ added in v0.2.0
func CheckHealthz() map[HealthzCheckName]HealthzCheckResponse
CheckHealthz walks through the registered healthz functions to provide an insight about the running states of current process. if functions failed, returns HealthzCheckStateFailed as the returned state.
func CheckMapEqual ¶
func CmpFloat64 ¶
CmpFloat64 compares float64s, placing greater before smaller
func CovertInt64ToInt ¶ added in v0.2.0
func CovertUInt64ToInt ¶ added in v0.2.0
func EnsureDirectory ¶
func GenerateHash ¶
func GetOneExistPath ¶
GetOneExistPath is to get one of exist paths
func GetSortedMapKeys ¶ added in v0.2.0
GetSortedMapKeys returns a slice containing sorted keys for the given map
func GetValueWithDefault ¶
GetValueWithDefault gets value from the given map, and returns default if key not exist
func IntFractionMultiply ¶ added in v0.2.0
IntFractionMultiply is a wrapper for this kind of operation: ceil(origin * numerator / denominator)
func IntSliceToStringSlice ¶
func IsNameEnabled ¶
IsNameEnabled check if a specified name enabled or not.
func IsPathExists ¶
IsPathExists is to check this path whether exists
func IsUnmarshalTypeError ¶ added in v0.2.0
IsUnmarshalTypeError check whether is json unmarshal type error
func JsonPathEmpty ¶
JsonPathEmpty is used to check whether the given str is empty for json-patch
func MergeMapInt ¶ added in v0.2.0
MergeMapInt merges the contents from override into the src
func ParseMapWithPrefix ¶
ParseMapWithPrefix converts selector string to label map and validates keys and values
func ReadFileIntoInt ¶ added in v0.2.0
ReadFileIntoInt read contents from the given file, and parse them into integer
func ReadFileIntoLines ¶ added in v0.2.0
ReadFileIntoLines read contents from the given file, and parse them into string slice; each string indicates a line in the file
func RegisterFileEventWatcher ¶
func RegisterFileEventWatcher(stop <-chan struct{}, fileWatcherInfo FileWatcherInfo) (<-chan struct{}, error)
RegisterFileEventWatcher inotify the given file and report the changed information to the caller through returned channel
func RegisterHealthzCheckRules ¶ added in v0.2.0
func RegisterHealthzCheckRules(name HealthzCheckName, f HealthzCheckFunc)
RegisterHealthzCheckRules supports to register healthz check functions.
func ReleaseUniqueLock ¶
func ReleaseUniqueLock(lock *Flock)
ReleaseUniqueLock release the given file lock
func SumUpMapValues ¶ added in v0.2.0
SumUpMapValues accumulates total values for the given map
func SumUpMultipleMapValues ¶ added in v0.2.0
SumUpMultipleMapValues accumulates total values for the given multi-level map
func ToString ¶
func ToString(in interface{}) string
ToString transform to string for better display etc. in log
func UInt64PointerToFloat64 ¶
func UIntPointerToFloat64 ¶
Types ¶
type CappedSmoothWindow ¶
type CappedSmoothWindow struct { sync.Mutex SmoothWindow // contains filtered or unexported fields }
func NewCappedSmoothWindow ¶
func NewCappedSmoothWindow(minStep resource.Quantity, maxStep resource.Quantity, smoothWindow SmoothWindow) *CappedSmoothWindow
NewCappedSmoothWindow creates a capped SmoothWindow, which
func (*CappedSmoothWindow) GetWindowedResources ¶
func (m *CappedSmoothWindow) GetWindowedResources(value resource.Quantity) *resource.Quantity
GetWindowedResources cap the value return by smooth window min to max
type FileWatcherInfo ¶
type Flock ¶
type Flock struct { LockFile string // contains filtered or unexported fields }
func GetUniqueLock ¶
GetUniqueLock is a wrapper function for getUniqueLockWithTimeout with default configurations
type HealthzCheckFunc ¶ added in v0.2.0
type HealthzCheckFunc func() (HealthzCheckResponse, error)
HealthzCheckFunc defined as a common function to define whether the corresponding component is healthy.
type HealthzCheckName ¶ added in v0.2.0
type HealthzCheckName string
HealthzCheckName describes which rule name for this check
type HealthzCheckResponse ¶ added in v0.2.0
type HealthzCheckResponse struct { State HealthzCheckState `json:"state"` Message string `json:"message"` }
type HealthzCheckState ¶ added in v0.2.0
type HealthzCheckState string
HealthzCheckState describes the checking results
const ( HealthzCheckStateReady HealthzCheckState = "Ready" HealthzCheckStateNotReady HealthzCheckState = "NotReady" HealthzCheckStateUnknown HealthzCheckState = "Unknown" HealthzCheckStateFailed HealthzCheckState = "Failed" )
type Logger ¶ added in v0.2.0
type Logger struct {
// contains filtered or unexported fields
}
func LoggerWithPrefix ¶ added in v0.2.0
func LoggerWithPrefix(prefix string, pkg LoggingPKG) Logger
type LoggingPKG ¶ added in v0.2.0
type LoggingPKG int
const ( LoggingPKGNone LoggingPKG = iota LoggingPKGShort LoggingPKGFull )
type MultiSorter ¶
type MultiSorter struct {
// contains filtered or unexported fields
}
MultiSorter implements the Sort interface, sorting changes within.
func NewMultiSorter ¶
func NewMultiSorter(cmp ...CmpFunc) *MultiSorter
NewMultiSorter returns a Sorter that sorts using the cmp functions, in order. Call its Sort method to sort the data.
func (*MultiSorter) Sort ¶
func (ms *MultiSorter) Sort(sources SourceList)
Sort sorts the argument slice according to the Less functions passed to NewMultiSorter.
type Pair ¶ added in v0.2.0
func TraverseMapByValueDescending ¶ added in v0.2.0
type ResourceList ¶
type ResourceList v1.ResourceList
func (*ResourceList) Set ¶
func (r *ResourceList) Set(value string) error
func (*ResourceList) String ¶
func (r *ResourceList) String() string
func (*ResourceList) Type ¶
func (r *ResourceList) Type() string
type SmoothWindow ¶
type SmoothWindow interface { // GetWindowedResources receives a sample and returns the result after smoothing, // it can return nil if there are not enough samples in this window GetWindowedResources(value resource.Quantity) *resource.Quantity }
SmoothWindow is used to smooth the resource
func NewAverageWithTTLSmoothWindow ¶
func NewAverageWithTTLSmoothWindow(windowSize int, ttl time.Duration, usedMillValue bool) SmoothWindow
NewAverageWithTTLSmoothWindow create a smooth window with ttl and window size, and the window size is the sample count while the ttl is the valid lifetime of each sample, and the usedMillValue means whether calculate the result with milli-value.