util

Documentation

Index

• func GetNextRevisionNumber(revisions []*appsv1.ControllerRevision) int64
• func GetNonLiveHistory(revisions []*appsv1.ControllerRevision, historyLimit int) []*appsv1.ControllerRevision
• func GetPodLogs(clientset *kubernetes.Clientset, pod *corev1.Pod) (string, error)
• func GetRevisionWithNameNumber(cr *appsv1.ControllerRevision) string
• func GetTime(timeStr string) time.Time
• func HasTimeElapsed(timeToCheckStr string, now time.Time, intervalSec int) bool
• func IsBlank(s *string) bool
• func MapDiff[K comparable, V any](a, b map[K]V) map[K]DiffValue
• func SetTimestamp(target *string)
• func UpperBoundedResourceList(resources corev1.ResourceRequirements) *corev1.ResourceList
• type DiffValue
• type TimeConverter
  • func (tc *TimeConverter) FromString(timeStr string) time.Time
  • func (tc *TimeConverter) ToString(timestamp time.Time) string

Functions

func GetNextRevisionNumber

func GetNextRevisionNumber(revisions []*appsv1.ControllerRevision) int64

func GetNonLiveHistory

func GetNonLiveHistory(revisions []*appsv1.ControllerRevision, historyLimit int) []*appsv1.ControllerRevision

func GetPodLogs

func GetPodLogs(clientset *kubernetes.Clientset, pod *corev1.Pod) (string, error)

func GetRevisionWithNameNumber

func GetRevisionWithNameNumber(cr *appsv1.ControllerRevision) string

Compose revision in FlinkClusterStatus with name and number of ControllerRevision

func GetTime

func GetTime(timeStr string) time.Time

func HasTimeElapsed

func HasTimeElapsed(timeToCheckStr string, now time.Time, intervalSec int) bool

Check time has passed

func IsBlank

func IsBlank(s *string) bool

func MapDiff

func MapDiff[K comparable, V any](a, b map[K]V) map[K]DiffValue

func SetTimestamp

func SetTimestamp(target *string)

SetTimestamp sets the current timestamp to the target.

func UpperBoundedResourceList

func UpperBoundedResourceList(resources corev1.ResourceRequirements) *corev1.ResourceList

Types

type DiffValue

type DiffValue struct {
	Left  any
	Right any
}

type TimeConverter

type TimeConverter struct{}

TimeConverter converts between time.Time and string.

func (*TimeConverter) FromString

func (tc *TimeConverter) FromString(timeStr string) time.Time

FromString converts string to time.Time.

func (*TimeConverter) ToString

func (tc *TimeConverter) ToString(timestamp time.Time) string

ToString converts time.Time to string.