util

Documentation

Index

• Constants
• func ContainsKillingStoppingContainerEvents(c kubernetes.Interface, name, namespace string) bool
• func GetDefaultClient() *http.Client
• func GetNamespace() string
• func GetNodeSummary(c kubernetes.Interface, name string) ([]byte, error)
• func GetNodes(c kubernetes.Interface) (*v1.NodeList, error)
• func GetPVNameFromPVC(c kubernetes.Interface, namespace, pvcName string) (string, error)
• func GetPodContainerLogs(c kubernetes.Interface, name, container, namespace string, previous bool, ...) string
• func GetPodEvents(c kubernetes.Interface, name, namespace string) (*v1.EventList, error)
• func GetPodEventsStr(events *[]v1.Event) string
• func JsonEscape(i string) string
• func NewHTTPClient(timeout time.Duration) *http.Client
• func RandomString(n int) string
• func SetLogFormatter(formatter string)

Constants

const (
	DefaultHTTPTimeout = 30 * time.Second
)

Functions

func ContainsKillingStoppingContainerEvents

func ContainsKillingStoppingContainerEvents(
	c kubernetes.Interface,
	name,
	namespace string) bool

ContainsKillingStoppingContainerEvents checks if the events contain an event with "Killing Stopping container" which indicates that a container could not be gracefully shutdown

func GetDefaultClient

func GetDefaultClient() *http.Client

func GetNamespace

func GetNamespace() string

GetNamespace returns the namespace where kwatch is running. It reads from POD_NAMESPACE environment variable and falls back to "kwatch".

func GetNodeSummary

func GetNodeSummary(c kubernetes.Interface, name string) ([]byte, error)

GetNodeSummary gets a list of nodes

func GetNodes

func GetNodes(c kubernetes.Interface) (*v1.NodeList, error)

GetNodes gets a list of nodes

func GetPVNameFromPVC

func GetPVNameFromPVC(
	c kubernetes.Interface,
	namespace, pvcName string) (string, error)

GetPVNameFromPVC returns the name of persistent volume given a namespace and persistent volume claim name

func GetPodContainerLogs

func GetPodContainerLogs(
	c kubernetes.Interface, name, container, namespace string,
	previous bool,
	maxRecentLogLines int64) string

GetPodContainerLogs returns logs for specified container in pod

func GetPodEvents

func GetPodEvents(
	c kubernetes.Interface,
	name,
	namespace string) (*v1.EventList, error)

GetPodEvents retrieves the events for a specific pod

func GetPodEventsStr

func GetPodEventsStr(events *[]v1.Event) string

GetPodEventsStr returns formatted events as a string for specified pod

func JsonEscape

func JsonEscape(i string) string

JsonEscape escapes the json special characters in a string

func NewHTTPClient

func NewHTTPClient(timeout time.Duration) *http.Client

func RandomString

func RandomString(n int) string

RandomString generates random string with provided n size

func SetLogFormatter

func SetLogFormatter(formatter string)

SetLogFormatter sets the log formatter based on the provided format string