util

Documentation

Index

• func AddSelectiveInfoInResourceNode(resourceNode *bean.ResourceNode, gvk schema.GroupVersionKind, ...)
• func BuildAppHealthStatus(nodes []*bean.ResourceNode) *bean.HealthStatusCode
• func ComputePodHash(template *coreV1.PodTemplateSpec, collisionCount *int32) string
• func ConvertToV1Deployment(nodeObj map[string]interface{}) (*v1beta1.Deployment, error)
• func ConvertToV1ReplicaSet(nodeObj map[string]interface{}) (*v1beta1.ReplicaSet, error)
• func DeepHashObject(hasher hash.Hash, objectToWrite interface{})
• func ExtractAllDockerImages(manifests []unstructured.Unstructured) ([]string, error)
• func GetAppId(clusterId int32, release *release.Release) string
• func GetAppStatusOnBasisOfHealthyNonHealthy(healthStatusArray []*bean.HealthStatus) *bean.HealthStatusCode
• func GetHookMetadata(manifest *unstructured.Unstructured) (bool, string)
• func GetMessageFromReleaseStatus(releaseStatus release.Status) string
• func GetPorts(manifest *unstructured.Unstructured, gvk schema.GroupVersionKind) []int64
• func GetReplicaSetPodHash(replicasetObj *v1beta1.ReplicaSet, collisionCount *int32) string
• func GetRolloutPodHash(rollout map[string]interface{}) string
• func GetRolloutPodTemplateHash(replicasetNode *bean.ResourceNode) string
• func GetUpdateRevisionForStatefulSet(obj map[string]interface{}) string
• func IsMapSubset(mapSet interface{}, mapSubset interface{}) bool
• func IsReleaseNotFoundError(err error) bool
• type ExtraNodeInfo

Functions

func AddSelectiveInfoInResourceNode

func AddSelectiveInfoInResourceNode(resourceNode *bean.ResourceNode, gvk schema.GroupVersionKind, obj map[string]interface{})

func BuildAppHealthStatus

func BuildAppHealthStatus(nodes []*bean.ResourceNode) *bean.HealthStatusCode

app health is worst of the nodes health or if app status is healthy then check for hibernation status

func ComputePodHash

func ComputePodHash(template *coreV1.PodTemplateSpec, collisionCount *int32) string

func ConvertToV1Deployment

func ConvertToV1Deployment(nodeObj map[string]interface{}) (*v1beta1.Deployment, error)

func ConvertToV1ReplicaSet

func ConvertToV1ReplicaSet(nodeObj map[string]interface{}) (*v1beta1.ReplicaSet, error)

func DeepHashObject

func DeepHashObject(hasher hash.Hash, objectToWrite interface{})

DeepHashObject writes specified object to hash using the spew library which follows pointers and prints actual values of the nested objects ensuring the hash does not change when a pointer changes.

func ExtractAllDockerImages

func ExtractAllDockerImages(manifests []unstructured.Unstructured) ([]string, error)

func GetAppId

func GetAppId(clusterId int32, release *release.Release) string

GetAppId returns AppID by logic cluster_id|namespace|release_name

func GetAppStatusOnBasisOfHealthyNonHealthy

func GetAppStatusOnBasisOfHealthyNonHealthy(healthStatusArray []*bean.HealthStatus) *bean.HealthStatusCode

func GetHookMetadata

func GetHookMetadata(manifest *unstructured.Unstructured) (bool, string)

func GetMessageFromReleaseStatus

func GetMessageFromReleaseStatus(releaseStatus release.Status) string

func GetPorts

func GetPorts(manifest *unstructured.Unstructured, gvk schema.GroupVersionKind) []int64

func GetReplicaSetPodHash

func GetReplicaSetPodHash(replicasetObj *v1beta1.ReplicaSet, collisionCount *int32) string

func GetRolloutPodHash

func GetRolloutPodHash(rollout map[string]interface{}) string

func GetRolloutPodTemplateHash

func GetRolloutPodTemplateHash(replicasetNode *bean.ResourceNode) string

func GetUpdateRevisionForStatefulSet

func GetUpdateRevisionForStatefulSet(obj map[string]interface{}) string

func IsMapSubset

func IsMapSubset(mapSet interface{}, mapSubset interface{}) bool

func IsReleaseNotFoundError

func IsReleaseNotFoundError(err error) bool

Types

type ExtraNodeInfo

type ExtraNodeInfo struct {
	// UpdateRevision is only used for StatefulSets, if not empty, indicates the version of the StatefulSet used to generate Pods in the sequence
	UpdateRevision         string
	ResourceNetworkingInfo *bean.ResourceNetworkingInfo
	RolloutCurrentPodHash  string
}