Documentation
¶
Index ¶
- Constants
- func CompareDaemonObjects(newDaemon *appsv1.DaemonSet, oldDaemon *appsv1.DaemonSet) bool
- func CompareDeployObjects(newDeploy *appsv1.Deployment, oldDeploy *appsv1.Deployment) bool
- func CompareNodeObjects(newNode *v1.Node, oldNode *v1.Node) bool
- func CompareRsObjects(newRs *appsv1.ReplicaSet, oldRs *appsv1.ReplicaSet) bool
- func GetEPStats(ep *v1.Endpoints) (int, int, bool)
- func IsUpdatable(fieldName string) bool
- func UpdateField(fieldName string, current *reflect.Value, updated *reflect.Value)
- type AdqlSearch
- type AgentRequest
- func (ar *AgentRequest) BiQRequested() bool
- func (ar *AgentRequest) Clone() AgentRequest
- func (ar *AgentRequest) EnvRequired() bool
- func (self *AgentRequest) Equals(ar *AgentRequest) bool
- func (ar *AgentRequest) GetAgentImageName(bag *AppDBag) string
- func (ar *AgentRequest) InitContainerRequired() bool
- func (ar *AgentRequest) IsBiQRemote() bool
- func (ar *AgentRequest) String() string
- func (ar *AgentRequest) ToAnnotation() string
- func (ar *AgentRequest) Valid() bool
- type AgentRequestList
- func (al *AgentRequestList) ApplyInstrumentationMethod(m InstrumentationMethod)
- func (al *AgentRequestList) BiQRequested() bool
- func (al *AgentRequestList) EnvRequired() bool
- func (self *AgentRequestList) Equals(al *AgentRequestList) bool
- func (al *AgentRequestList) GetBiQOption() string
- func (al *AgentRequestList) GetContainerNames() *[]string
- func (al *AgentRequestList) GetFirstRequest() *AgentRequest
- func (al *AgentRequestList) GetRequest(cname string) *AgentRequest
- func (al *AgentRequestList) InitContainerRequired() bool
- func (al *AgentRequestList) String() string
- func (al *AgentRequestList) ToAnnotation() string
- type AgentRetryRequest
- type AgentStatus
- type AppDBag
- type AppDMetric
- type AppDMetricInterface
- type AppDMetricList
- type AppDMetricMetadata
- type AppDSchemaInterface
- type AttachStatus
- type BiQDeploymentOption
- type ClusterAppMetrics
- type ClusterContainerMetrics
- type ClusterDaemonMetrics
- type ClusterDeployMetrics
- type ClusterEventMetrics
- type ClusterInstanceMetrics
- type ClusterInstancePortMetrics
- type ClusterJobMetrics
- type ClusterNodeMetrics
- type ClusterPodMetrics
- type ClusterRsMetrics
- type ClusterServiceEPMetrics
- type ClusterServiceMetrics
- type ColorPalette
- type ContainerObjList
- type ContainerPort
- type ContainerSchema
- type ContainerSchemaDef
- type ContainerSchemaDefWrapper
- type DaemonObjList
- type DaemonSchema
- type DaemonSchemaDef
- type DaemonSchemaDefWrapper
- type Dashboard
- type DashboardBag
- type DashboardType
- type DataSeriesTemplate
- type DeployObjList
- type DeploySchema
- type DeploySchemaDef
- type DeploySchemaDefWrapper
- type EPAddress
- type EpSchema
- type EpSchemaDef
- type EpSchemaDefWrapper
- type EventObjList
- type EventSchema
- type EventSchemaDef
- type EventSchemaDefWrapper
- type HeatNode
- type Ingress
- type InstrumentationMethod
- type JobObjList
- type JobSchema
- type JobSchemaDef
- type JobSchemaDefWrapper
- type LogObjList
- type LogSchema
- type LogSchemaDef
- type LogSchemaDefWrapper
- type MetricExpression
- type MetricExpression2
- type MetricExpressionTemplate
- type MetricMatchCriteriaTemplate
- type NodeMetricsObj
- type NodeMetricsObjList
- type NodeObjList
- type NodeSchema
- type NodeSchemaDef
- type NodeSchemaDefWrapper
- type NsSchema
- type NsSchemaDef
- type NsSchemaDefWrapper
- type Operator
- type PodMetricsObj
- type PodMetricsObjList
- type PodObjList
- type PodSchema
- type PodSchemaDef
- type PodSchemaDefWrapper
- type RQFields
- type RQSchemaObj
- func (rq *RQSchemaObj) AddQuotaStatsToAppMetrics(metrics *ClusterAppMetrics)
- func (rq *RQSchemaObj) AddQuotaStatsToNamespaceMetrics(metrics *ClusterPodMetrics)
- func (rq *RQSchemaObj) AppliesToNamespace(ns string) bool
- func (rq *RQSchemaObj) AppliesToPod(podObject *PodSchema) bool
- func (rq *RQSchemaObj) IncrementQuotaStatsClusterMetrics(metrics *ClusterPodMetrics)
- type RqSchema
- type RqSchemaDef
- type RqSchemaDefWrapper
- type RsObjList
- type RsSchema
- type RsSchemaDef
- type RsSchemaDefWrapper
- type ScopeEntity
- type ServiceEndpoint
- type ServicePort
- type ServiceSchema
- func (svcSchema *ServiceSchema) ExternallyReferenced(referenced bool)
- func (svc *ServiceSchema) GetEndPointsStats() (int, map[string]int, map[string]int)
- func (svcSchema *ServiceSchema) IsPortAvailable(cp *ContainerPort, podSchema *PodSchema) (bool, bool)
- func (svcSchema *ServiceSchema) MatchesPod(podObject *v1.Pod) bool
- type StaticThreshold
- type TechnologyName
- type UsageStats
- type Utilization
- type WidgetTemplate
Constants ¶
View Source
const ( REQUEST_SEPARATOR string = ";" FIELD_SEPARATOR string = "__" Java TechnologyName = "java" DotNet TechnologyName = "dotnet" NodeJS TechnologyName = "nodejs" ALL_CONTAINERS string = "all" FIRST_CONTAINER string = "all" VERSION_LATEST string = "latest" )
View Source
const ( DEPLOYMENT_TYPE_DEPLOYMENT string = "d" DEPLOYMENT_TYPE_RS string = "rs" DEPLOYMENT_TYPE_DS string = "ds" )
View Source
const ALL string = "all"
View Source
const METRIC_PATH_APPS string = "Deployments"
View Source
const METRIC_PATH_CONT string = "Containers"
View Source
const METRIC_PATH_EVENTS string = "Events"
View Source
const METRIC_PATH_INSTANCES string = "Instances"
View Source
const METRIC_PATH_NAMESPACES string = "Namespaces"
View Source
const METRIC_PATH_NODES string = "Nodes"
View Source
const METRIC_PATH_PORTS string = "Ports"
View Source
const METRIC_PATH_RQSPEC string = "QuotaSpecs"
View Source
const METRIC_PATH_RQUSED string = "QuotaUsed"
View Source
const METRIC_PATH_SERVICES string = "Services"
View Source
const METRIC_PATH_SERVICES_EP string = "Endpoints"
View Source
const METRIC_SEPARATOR string = "|"
View Source
const RootPath string = "Server|Component:%s|Custom Metrics|Cluster Stats|"
Variables ¶
This section is empty.
Functions ¶
func CompareDaemonObjects ¶
func CompareDeployObjects ¶
func CompareDeployObjects(newDeploy *appsv1.Deployment, oldDeploy *appsv1.Deployment) bool
func CompareNodeObjects ¶
func CompareNodeObjects(newNode *v1.Node, oldNode *v1.Node) bool
func CompareRsObjects ¶
func CompareRsObjects(newRs *appsv1.ReplicaSet, oldRs *appsv1.ReplicaSet) bool
func GetEPStats ¶
func IsUpdatable ¶
Types ¶
type AdqlSearch ¶
type AdqlSearch struct {
ID int64 `json:"id"`
SearchName string `json:"searchName"`
Query string `json:"-"`
SchemaName string `json:"-"`
SchemaDef AppDSchemaInterface `json:"-"`
}
type AgentRequest ¶
type AgentRequest struct {
Namespaces []string
AppName string
TierName string
AppDAppLabel string
AppDTierLabel string
Tech TechnologyName
ContainerName string //first (default), all, name
Version string
MatchString []string //string matched against deployment names and labels, supports regex
Method InstrumentationMethod
BiQ string //"sidecar" or reference to the remote analytics agent
AppNameLiteral string
AgentEnvVar string
}
func NewAgentRequest ¶
func RequestFromAnnotation ¶
func RequestFromAnnotation(annotation string) AgentRequest
func (*AgentRequest) BiQRequested ¶
func (ar *AgentRequest) BiQRequested() bool
func (*AgentRequest) Clone ¶
func (ar *AgentRequest) Clone() AgentRequest
func (*AgentRequest) EnvRequired ¶
func (ar *AgentRequest) EnvRequired() bool
func (*AgentRequest) Equals ¶ added in v0.1.13
func (self *AgentRequest) Equals(ar *AgentRequest) bool
func (*AgentRequest) GetAgentImageName ¶
func (ar *AgentRequest) GetAgentImageName(bag *AppDBag) string
func (*AgentRequest) InitContainerRequired ¶
func (ar *AgentRequest) InitContainerRequired() bool
func (*AgentRequest) IsBiQRemote ¶
func (ar *AgentRequest) IsBiQRemote() bool
func (*AgentRequest) String ¶
func (ar *AgentRequest) String() string
func (*AgentRequest) ToAnnotation ¶
func (ar *AgentRequest) ToAnnotation() string
func (*AgentRequest) Valid ¶
func (ar *AgentRequest) Valid() bool
type AgentRequestList ¶
type AgentRequestList struct {
Items []AgentRequest
}
func FromAnnotation ¶
func FromAnnotation(annotation string) *AgentRequestList
func NewAgentRequestList ¶
func NewAgentRequestListFromArray ¶
func NewAgentRequestListFromArray(ar []AgentRequest, bag *AppDBag, containers []v1.Container) *AgentRequestList
func (*AgentRequestList) ApplyInstrumentationMethod ¶
func (al *AgentRequestList) ApplyInstrumentationMethod(m InstrumentationMethod)
func (*AgentRequestList) BiQRequested ¶
func (al *AgentRequestList) BiQRequested() bool
func (*AgentRequestList) EnvRequired ¶
func (al *AgentRequestList) EnvRequired() bool
func (*AgentRequestList) Equals ¶ added in v0.1.13
func (self *AgentRequestList) Equals(al *AgentRequestList) bool
func (*AgentRequestList) GetBiQOption ¶
func (al *AgentRequestList) GetBiQOption() string
func (*AgentRequestList) GetContainerNames ¶
func (al *AgentRequestList) GetContainerNames() *[]string
func (*AgentRequestList) GetFirstRequest ¶
func (al *AgentRequestList) GetFirstRequest() *AgentRequest
func (*AgentRequestList) GetRequest ¶
func (al *AgentRequestList) GetRequest(cname string) *AgentRequest
func (*AgentRequestList) InitContainerRequired ¶
func (al *AgentRequestList) InitContainerRequired() bool
func (*AgentRequestList) String ¶
func (al *AgentRequestList) String() string
func (*AgentRequestList) ToAnnotation ¶
func (al *AgentRequestList) ToAnnotation() string
type AgentRetryRequest ¶
type AgentRetryRequest struct {
Request *AgentRequest
Pod *v1.Pod
}
type AgentStatus ¶
type AgentStatus struct {
Version string
MetricsSyncInterval int
SnapshotSyncInterval int
LogLevel string
LogLines int
NsToMonitor []string
NsToMonitorExclude []string
NodesToMonitor []string
NodesToMonitorExclude []string
NsToInstrument []string
NsToInstrumentExclude []string
NSInstrumentRule []AgentRequest
InstrumentationMethod InstrumentationMethod
DefaultInstrumentationTech TechnologyName
InstrumentMatchString []string
BiqService string
AnalyticsAgentImage string
AppDJavaAttachImage string
AppDDotNetAttachImage string
}
type AppDBag ¶
type AppDBag struct {
AgentNamespace string
AppName string
TierName string
NodeName string
AppID int
TierID int
NodeID int
Account string
GlobalAccount string
AccessKey string
ControllerUrl string
ControllerPort uint16
RestAPIUrl string
SSLEnabled bool
SystemSSLCert string
AgentSSLCert string
EventKey string
EventServiceUrl string
RestAPICred string
EventAPILimit int
PodSchemaName string
NodeSchemaName string
DeploySchemaName string
RSSchemaName string
DaemonSchemaName string
EventSchemaName string
ContainerSchemaName string
EpSchemaName string
NsSchemaName string
RqSchemaName string
JobSchemaName string
LogSchemaName string
DashboardTemplatePath string
DashboardSuffix string
DashboardDelayMin int
AgentEnvVar string
AgentLabel string
AppNameLiteral string
AppDAppLabel string
AppDTierLabel string
AppDAnalyticsLabel string
AgentLogOverride string
AgentUserOverride string
AgentMountName string
AgentMountPath string
AppLogMountName string
AppLogMountPath string
JDKMountName string
JDKMountPath string
NodeNamePrefix string
AnalyticsAgentUrl string
AnalyticsAgentImage string
AnalyticsAgentContainerName string
AppDInitContainerName string
AppDJavaAttachImage string
AppDDotNetAttachImage string
AppDNodeJSAttachImage string
ProxyUrl string
ProxyHost string
ProxyPort string
ProxyUser string
ProxyPass string
InitContainerDir string
MetricsSyncInterval int // Frequency of metrics pushes to the controller, sec
SnapshotSyncInterval int // Frequency of snapshot pushes to events api, sec
AgentServerPort int
NsToMonitor []string
NsToMonitorExclude []string
DeploysToDashboard []string
NodesToMonitor []string
NodesToMonitorExclude []string
NsToInstrument []string
NsToInstrumentExclude []string
NSInstrumentRule []AgentRequest
InstrumentationMethod InstrumentationMethod
DefaultInstrumentationTech TechnologyName
BiqService string
InstrumentContainer string //all, first, name
InstrumentMatchString []string
InitRequestMem string
InitRequestCpu string
BiqRequestMem string
BiqRequestCpu string
LogLines int //0 - no logging
PodEventNumber int
RemoteBiqProtocol string
RemoteBiqHost string
RemoteBiqPort int
SchemaUpdateCache []string
SchemaSkipCache []string
LogLevel string
OverconsumptionThreshold int //percent
ControllerVer1 int
ControllerVer2 int
ControllerVer3 int
ControllerVer4 int
InstrumentationUpdated bool
}
func GetDefaultProperties ¶
func GetDefaultProperties() *AppDBag
func (*AppDBag) CompareControllerVersions ¶
/ current controller version is -1 = older, 1 - newer or equal
func (*AppDBag) EnsureDefaults ¶
func (self *AppDBag) EnsureDefaults()
func (*AppDBag) PrintControllerVersion ¶
type AppDMetric ¶
type AppDMetric struct {
MetricName string
MetricValue int64
MetricPath string
MetricAlias string
MetricMultiplier float64
MetricAggregationType string
MetricTimeRollUpType appd.RollupType
MetricClusterRollUpType appd.ClusterRollupType
MetricDelta bool
}
func NewAppDMetric ¶
func NewAppDMetric(name string, val int64, path string) AppDMetric
func (AppDMetric) ToString ¶
func (am AppDMetric) ToString() string
type AppDMetricInterface ¶
type AppDMetricList ¶
type AppDMetricList struct {
Items []AppDMetric
}
func NewAppDMetricList ¶
func NewAppDMetricList() AppDMetricList
func (AppDMetricList) AddMetrics ¶
func (l AppDMetricList) AddMetrics(obj AppDMetric) []AppDMetric
type AppDMetricMetadata ¶
func NewAppDMetricMetadata ¶
func NewAppDMetricMetadata(name, schema, path, query string) AppDMetricMetadata
type AppDSchemaInterface ¶
type AppDSchemaInterface interface {
Unwrap() *map[string]interface{}
}
type AttachStatus ¶
type BiQDeploymentOption ¶
type BiQDeploymentOption string
const ( NoBiq BiQDeploymentOption = "none" Sidecar BiQDeploymentOption = "sidecar" Remote BiQDeploymentOption = "remote" )
type ClusterAppMetrics ¶
type ClusterAppMetrics struct {
Path string
Metadata map[string]AppDMetricMetadata
Namespace string
TierName string
PodCount int64
Privileged int64
Evictions int64
PodRestarts int64
PodRunning int64
PodFailed int64
PodPending int64
PendingTime int64
UpTime int64
ContainerCount int64
InitContainerCount int64
RequestCpu int64
RequestMemory int64
LimitCpu int64
LimitMemory int64
UseCpu int64
UseMemory int64
ConsumptionCpu int64
ConsumptionMem int64
NoLimits int64
NoReadinessProbe int64
NoLivenessProbe int64
MissingDependencies int64
NoConnectivity int64
Services []ClusterServiceMetrics
QuotasSpec RQFields
QuotasUsed RQFields
}
func NewClusterAppMetrics ¶
func NewClusterAppMetrics(bag *AppDBag, podObject *PodSchema) ClusterAppMetrics
func NewClusterAppMetricsMetadata ¶
func NewClusterAppMetricsMetadata(bag *AppDBag, podObject *PodSchema) ClusterAppMetrics
func (ClusterAppMetrics) GetPath ¶
func (cpm ClusterAppMetrics) GetPath() string
func (ClusterAppMetrics) GetQuotaSpecMetrics ¶
func (cpm ClusterAppMetrics) GetQuotaSpecMetrics() RQFields
func (ClusterAppMetrics) GetQuotaUsedMetrics ¶
func (cpm ClusterAppMetrics) GetQuotaUsedMetrics() RQFields
func (ClusterAppMetrics) ShouldExcludeField ¶
func (cpm ClusterAppMetrics) ShouldExcludeField(fieldName string) bool
func (ClusterAppMetrics) Unwrap ¶
func (cpm ClusterAppMetrics) Unwrap() *map[string]interface{}
type ClusterContainerMetrics ¶
type ClusterContainerMetrics struct {
Path string
Metadata map[string]AppDMetricMetadata
Namespace string
TierName string
ContainerName string
Restarts int64
ContainerCount int64
RequestCpu int64
RequestMemory int64
LimitCpu int64
LimitMemory int64
PodStorageRequest int64
PodStorageLimit int64
StorageRequest int64
StorageCapacity int64
NoLimits int64
NoReadinessProbe int64
NoLivenessProbe int64
}
func NewClusterContainerMetrics ¶
func NewClusterContainerMetrics(bag *AppDBag, ns string, tierName string, containerName string) ClusterContainerMetrics
func NewClusterContainerMetricsMetadata ¶
func NewClusterContainerMetricsMetadata(bag *AppDBag, ns string, tierName string, containerName string) ClusterContainerMetrics
func (ClusterContainerMetrics) GetPath ¶
func (cpm ClusterContainerMetrics) GetPath() string
func (ClusterContainerMetrics) ShouldExcludeField ¶
func (cpm ClusterContainerMetrics) ShouldExcludeField(fieldName string) bool
func (ClusterContainerMetrics) Unwrap ¶
func (cpm ClusterContainerMetrics) Unwrap() *map[string]interface{}
type ClusterDaemonMetrics ¶
type ClusterDaemonMetrics struct {
Path string
Namespace string
DaemonCount int64
DaemonReplicasAvailable int64
DaemonReplicasUnAvailable int64
DaemonCollisionCount int64
DaemonMissScheduled int64
}
func NewClusterDaemonMetrics ¶
func NewClusterDaemonMetrics(bag *AppDBag, ns string) ClusterDaemonMetrics
func (ClusterDaemonMetrics) GetPath ¶
func (cpm ClusterDaemonMetrics) GetPath() string
func (ClusterDaemonMetrics) ShouldExcludeField ¶
func (cpm ClusterDaemonMetrics) ShouldExcludeField(fieldName string) bool
func (ClusterDaemonMetrics) Unwrap ¶
func (cpm ClusterDaemonMetrics) Unwrap() *map[string]interface{}
type ClusterDeployMetrics ¶
type ClusterDeployMetrics struct {
Path string
Namespace string
DeployCount int64
DeployReplicas int64
DeployReplicasUnAvailable int64
DeployCollisionCount int64
}
func NewClusterDeployMetrics ¶
func NewClusterDeployMetrics(bag *AppDBag, ns string) ClusterDeployMetrics
func (ClusterDeployMetrics) GetPath ¶
func (cpm ClusterDeployMetrics) GetPath() string
func (ClusterDeployMetrics) ShouldExcludeField ¶
func (cpm ClusterDeployMetrics) ShouldExcludeField(fieldName string) bool
func (ClusterDeployMetrics) Unwrap ¶
func (cpm ClusterDeployMetrics) Unwrap() *map[string]interface{}
type ClusterEventMetrics ¶
type ClusterEventMetrics struct {
Path string
Metadata map[string]AppDMetricMetadata
Namespace string
TierName string
EventCount int64
EventError int64
EventInfo int64
ScaleDowns int64
CrashLoops int64
QuotaViolations int64
PodIssues int64
PodKills int64
EvictionThreats int64
ImagePullErrors int64
ImagePulls int64
StorageIssues int64
}
func NewClusterEventMetrics ¶
func NewClusterEventMetrics(bag *AppDBag, ns string, tierName string) ClusterEventMetrics
func NewClusterEventMetricsMetadata ¶
func NewClusterEventMetricsMetadata(bag *AppDBag, ns string, tierName string) ClusterEventMetrics
func (ClusterEventMetrics) GetPath ¶
func (cpm ClusterEventMetrics) GetPath() string
func (ClusterEventMetrics) ShouldExcludeField ¶
func (cpm ClusterEventMetrics) ShouldExcludeField(fieldName string) bool
func (ClusterEventMetrics) Unwrap ¶
func (cpm ClusterEventMetrics) Unwrap() *map[string]interface{}
type ClusterInstanceMetrics ¶
type ClusterInstanceMetrics struct {
Path string
Metadata map[string]AppDMetricMetadata
Namespace string
TierName string
ContainerName string
PodName string
Restarts int64
UseCpu int64
UseMemory int64
PortMetrics []ClusterInstancePortMetrics
}
func NewClusterInstanceMetrics ¶
func NewClusterInstanceMetrics(bag *AppDBag, podObject *PodSchema, containerName string) ClusterInstanceMetrics
func NewClusterInstanceMetricsMetadata ¶
func NewClusterInstanceMetricsMetadata(bag *AppDBag, podObject *PodSchema, containerName string) ClusterInstanceMetrics
func (ClusterInstanceMetrics) GetPath ¶
func (cpm ClusterInstanceMetrics) GetPath() string
func (ClusterInstanceMetrics) ShouldExcludeField ¶
func (cpm ClusterInstanceMetrics) ShouldExcludeField(fieldName string) bool
func (ClusterInstanceMetrics) Unwrap ¶
func (cpm ClusterInstanceMetrics) Unwrap() *map[string]interface{}
type ClusterInstancePortMetrics ¶
type ClusterInstancePortMetrics struct {
Path string
Namespace string
TierName string
ContainerName string
PodName string
PortName string
Mapped int64 //0 or 1
Ready int64 // 0 or 1
}
func (ClusterInstancePortMetrics) GetPath ¶
func (cpm ClusterInstancePortMetrics) GetPath() string
func (ClusterInstancePortMetrics) ShouldExcludeField ¶
func (cpm ClusterInstancePortMetrics) ShouldExcludeField(fieldName string) bool
func (ClusterInstancePortMetrics) Unwrap ¶
func (cpm ClusterInstancePortMetrics) Unwrap() *map[string]interface{}
type ClusterJobMetrics ¶
type ClusterJobMetrics struct {
Path string
Metadata map[string]AppDMetricMetadata
Namespace string
JobCount int64
JobActiveCount int64
JobSuccessCount int64
JobFailedCount int64
JobDuration int64
}
func NewClusterJobMetrics ¶
func NewClusterJobMetrics(bag *AppDBag, ns string, node string) ClusterJobMetrics
func NewClusterJobMetricsMetadata ¶
func NewClusterJobMetricsMetadata(bag *AppDBag, ns string, node string) ClusterJobMetrics
func (ClusterJobMetrics) Unwrap ¶
func (cpm ClusterJobMetrics) Unwrap() *map[string]interface{}
type ClusterNodeMetrics ¶
type ClusterNodeMetrics struct {
Path string
Metadata map[string]AppDMetricMetadata
Nodename string
ReadyNodes int64
OutOfDiskNodes int64
MemoryPressureNodes int64
DiskPressureNodes int64
TaintsTotal int64
Masters int64
Workers int64
CapacityMemory int64
CapacityCpu int64
CapacityPods int64
AllocationsMemory int64
AllocationsCpu int64
UseMemory int64
UseCpu int64
}
func NewClusterNodeMetrics ¶
func NewClusterNodeMetrics(bag *AppDBag, node string) ClusterNodeMetrics
func NewClusterNodeMetricsMetadata ¶
func NewClusterNodeMetricsMetadata(bag *AppDBag, node string) ClusterNodeMetrics
func (ClusterNodeMetrics) GetPath ¶
func (cpm ClusterNodeMetrics) GetPath() string
func (ClusterNodeMetrics) ShouldExcludeField ¶
func (cpm ClusterNodeMetrics) ShouldExcludeField(fieldName string) bool
func (ClusterNodeMetrics) Unwrap ¶
func (cpm ClusterNodeMetrics) Unwrap() *map[string]interface{}
type ClusterPodMetrics ¶
type ClusterPodMetrics struct {
Path string
Metadata map[string]AppDMetricMetadata
Namespace string
Nodename string
PodCount int64
NamespaceCount int64
NamespaceNoQuotas int64
ServiceCount int64
EndpointCount int64
EPReadyCount int64
EPNotReadyCount int64
OrphanEndpoint int64
ExtServiceCount int64
Evictions int64
PodRestarts int64
PodRunning int64
PodFailed int64
PodPending int64
PendingTime int64
UpTime int64
ContainerCount int64
InitContainerCount int64
NoLimits int64
NoReadinessProbe int64
NoLivenessProbe int64
Privileged int64
PodStorageRequest int64
PodStorageLimit int64
StorageRequest int64
StorageCapacity int64
RequestCpu int64
RequestMemory int64
LimitCpu int64
LimitMemory int64
UseCpu int64
UseMemory int64
ConsumptionCpu int64
ConsumptionMem int64
MissingDependencies int64
NoConnectivity int64
QuotasSpec RQFields
QuotasUsed RQFields
}
func NewClusterPodMetrics ¶
func NewClusterPodMetrics(bag *AppDBag, ns string, node string) ClusterPodMetrics
func NewClusterPodMetricsMetadata ¶
func NewClusterPodMetricsMetadata(bag *AppDBag, ns string, node string) ClusterPodMetrics
func (ClusterPodMetrics) GetPath ¶
func (cpm ClusterPodMetrics) GetPath() string
func (ClusterPodMetrics) GetQuotaSpecMetrics ¶
func (cpm ClusterPodMetrics) GetQuotaSpecMetrics() RQFields
func (ClusterPodMetrics) GetQuotaUsedMetrics ¶
func (cpm ClusterPodMetrics) GetQuotaUsedMetrics() RQFields
func (ClusterPodMetrics) ShouldExcludeField ¶
func (cpm ClusterPodMetrics) ShouldExcludeField(fieldName string) bool
func (ClusterPodMetrics) Unwrap ¶
func (cpm ClusterPodMetrics) Unwrap() *map[string]interface{}
type ClusterRsMetrics ¶
type ClusterRsMetrics struct {
Path string
Namespace string
RsCount int64
RsStaleCount int64
RsReplicas int64
RsReplicasAvailable int64
RsReplicasUnAvailable int64
}
func NewClusterRsMetrics ¶
func NewClusterRsMetrics(bag *AppDBag, ns string) ClusterRsMetrics
func (ClusterRsMetrics) GetPath ¶
func (cpm ClusterRsMetrics) GetPath() string
func (ClusterRsMetrics) ShouldExcludeField ¶
func (cpm ClusterRsMetrics) ShouldExcludeField(fieldName string) bool
func (ClusterRsMetrics) Unwrap ¶
func (cpm ClusterRsMetrics) Unwrap() *map[string]interface{}
type ClusterServiceEPMetrics ¶
type ClusterServiceEPMetrics struct {
Path string
Metadata map[string]AppDMetricMetadata
Namespace string
TierName string
ServiceName string
EndpointName string
EndpointsReady int64
EndpointsNotReady int64
}
func NewClusterServiceEPMetrics ¶
func NewClusterServiceEPMetrics(bag *AppDBag, ns string, tierName string, svcSchema *ServiceSchema, endpointName string) ClusterServiceEPMetrics
func (ClusterServiceEPMetrics) GetPath ¶
func (cpm ClusterServiceEPMetrics) GetPath() string
func (ClusterServiceEPMetrics) ShouldExcludeField ¶
func (cpm ClusterServiceEPMetrics) ShouldExcludeField(fieldName string) bool
func (ClusterServiceEPMetrics) Unwrap ¶
func (cpm ClusterServiceEPMetrics) Unwrap() *map[string]interface{}
type ClusterServiceMetrics ¶
type ClusterServiceMetrics struct {
Path string
Metadata map[string]AppDMetricMetadata
Namespace string
TierName string
ServiceName string
Accessible int64 //0 or 1
EndpointsTotal int64
Endpoints map[string]ClusterServiceEPMetrics
}
func NewClusterServiceMetrics ¶
func NewClusterServiceMetrics(bag *AppDBag, ns string, tierName string, svcSchema *ServiceSchema) ClusterServiceMetrics
func (ClusterServiceMetrics) GetPath ¶
func (cpm ClusterServiceMetrics) GetPath() string
func (ClusterServiceMetrics) ShouldExcludeField ¶
func (cpm ClusterServiceMetrics) ShouldExcludeField(fieldName string) bool
func (ClusterServiceMetrics) Unwrap ¶
func (cpm ClusterServiceMetrics) Unwrap() *map[string]interface{}
type ColorPalette ¶
type ColorPalette struct {
Colors []int `json: "colors"`
}
type ContainerObjList ¶
type ContainerObjList struct {
Items []ContainerSchema
}
func NewContainerObjList ¶
func NewContainerObjList() ContainerObjList
func (ContainerObjList) AddItem ¶
func (l ContainerObjList) AddItem(obj ContainerSchema) []ContainerSchema
func (ContainerObjList) Clear ¶
func (l ContainerObjList) Clear() []ContainerSchema
type ContainerPort ¶
type ContainerSchema ¶
type ContainerSchema struct {
Name string `json:"name"`
Init bool `json:"init"`
Namespace string `json:"namespace"`
ClusterName string `json:"clusterName"`
NodeName string `json:"nodeName"`
PodName string `json:"podName"`
PodInitTime time.Time `json:"podInitTime"`
StartTime *time.Time `json:"startTime"`
LiveProbes int `json:"liveProbes"`
ReadyProbes int `json:"readyProbes"`
Restarts int32 `json:"restarts"`
Privileged int `json:"privileged"`
Ports string `json:"ports"`
MemRequest int64 `json:"memRequest"`
CpuRequest int64 `json:"cpuRequest"`
CpuLimit int64 `json:"cpuLimit"`
MemLimit int64 `json:"memLimit"`
PodStorageRequest int64 `json:"podStorageRequest"`
PodStorageLimit int64 `json:"podStorageLimit"`
StorageRequest int64 `json:"storageRequest"`
StorageCapacity int64 `json:"storageCapacity"`
CpuUse int64 `json:"cpuUse"`
MemUse int64 `json:"memUse"`
Image string `json:"image"`
WaitReason string `json:"waitReason"`
TermReason string `json:"termReason"`
TerminationTime time.Time `json:"terminationTime"`
Mounts string `json:"mounts"`
MissingConfigs string `json:"missingConfigs"`
MissingSecrets string `json:"missingSecrets"`
MissingServices string `json:"missingServices"`
ConsumptionCpu float64 `json:"consumptionCpu"`
ConsumptionMem float64 `json:"consumptionMem"`
Index int8 `json:"-"`
ContainerPorts []ContainerPort `json:"-"`
LastTerminationTime *time.Time `json:"-"`
ExitCode int32 `json:"-"`
LimitsDefined bool `json:"-"`
RequestCpuString string `json:"-"`
RequestMemString string `json:"-"`
LimitCpuString string `json:"-"`
LimitMemString string `json:"-"`
ConsumptionCpuString string `json:"-"`
ConsumptionMemString string `json:"-"`
PendingTime int64 `json:"-"`
}
func NewContainerObj ¶
func NewContainerObj() ContainerSchema
func (*ContainerSchema) HasMissingDependencies ¶
func (p *ContainerSchema) HasMissingDependencies() bool
func (*ContainerSchema) NoConnectivity ¶
func (p *ContainerSchema) NoConnectivity() bool
func (ContainerSchema) ToString ¶
func (p ContainerSchema) ToString() string
type ContainerSchemaDef ¶
type ContainerSchemaDef struct {
Name string `json:"name"`
Init string `json:"init"`
Namespace string `json:"namespace"`
ClusterName string `json:"clusterName"`
NodeName string `json:"nodeName"`
PodName string `json:"podName"`
PodInitTime string `json:"podInitTime"`
StartTime string `json:"startTime"`
LiveProbes string `json:"liveProbes"`
ReadyProbes string `json:"readyProbes"`
Restarts string `json:"restarts"`
Privileged string `json:"privileged"`
Ports string `json:"ports"`
MemRequest string `json:"memRequest"`
CpuRequest string `json:"cpuRequest"`
CpuLimit string `json:"cpuLimit"`
MemLimit string `json:"memLimit"`
PodStorageRequest string `json:"podStorageRequest"`
PodStorageLimit string `json:"podStorageLimit"`
StorageRequest string `json:"storageRequest"`
StorageCapacity string `json:"storageCapacity"`
CpuUse string `json:"cpuUse"`
MemUse string `json:"memUse"`
Image string `json:"image"`
WaitReason string `json:"waitReason"`
TermReason string `json:"termReason"`
TerminationTime string `json:"terminationTime"`
Mounts string `json:"mounts"`
MissingConfigs string `json:"missingConfigs"`
MissingSecrets string `json:"missingSecrets"`
MissingServices string `json:"missingServices"`
ConsumptionCpu string `json:"consumptionCpu"`
ConsumptionMem string `json:"consumptionMem"`
}
func NewContainerSchemaDef ¶
func NewContainerSchemaDef() ContainerSchemaDef
func (ContainerSchemaDef) Unwrap ¶
func (sd ContainerSchemaDef) Unwrap() *map[string]interface{}
type ContainerSchemaDefWrapper ¶
type ContainerSchemaDefWrapper struct {
Schema ContainerSchemaDef `json:"schema"`
}
func NewContainerSchemaDefWrapper ¶
func NewContainerSchemaDefWrapper() ContainerSchemaDefWrapper
func (ContainerSchemaDefWrapper) Unwrap ¶
func (sd ContainerSchemaDefWrapper) Unwrap() *map[string]interface{}
type DaemonObjList ¶
type DaemonObjList struct {
Items []DaemonSchema
}
func NewDaemonObjList ¶
func NewDaemonObjList() DaemonObjList
func (DaemonObjList) AddItem ¶
func (l DaemonObjList) AddItem(obj DaemonSchema) []DaemonSchema
func (DaemonObjList) Clear ¶
func (l DaemonObjList) Clear() []DaemonSchema
type DaemonSchema ¶
type DaemonSchema struct {
Name string `json:"name"`
ClusterName string `json:"clusterName"`
Namespace string `json:"namespace"`
ObjectUid string `json:"objectUid"`
CreationTimestamp time.Time `json:"creationTimestamp"`
DeletionTimestamp time.Time `json:"deletionTimestamp"`
MinReadySecs int32 `json:"minReadySecs"`
RevisionHistoryLimits int32 `json:"revisionHistoryLimits"`
ReplicasAvailable int32 `json:"replicasAvailable"`
ReplicasUnAvailable int32 `json:"ReplicasUnAvailable"`
CollisionCount int32 `json:"collisionCount"`
ReplicasReady int32 `json:"replicasReady"`
NumberScheduled int32 `json:"numberScheduled"`
DesiredNumber int32 `json:"desiredNumber"`
MissScheduled int32 `json:"missScheduled"`
UpdatedNumberScheduled int32 `json:"updatedNumberScheduled"`
}
func NewDaemonObj ¶
func NewDaemonObj() DaemonSchema
func (*DaemonSchema) Equals ¶
func (ps *DaemonSchema) Equals(obj *DaemonSchema) bool
func (*DaemonSchema) GetDaemonKey ¶
func (ps *DaemonSchema) GetDaemonKey() string
type DaemonSchemaDef ¶
type DaemonSchemaDef struct {
Name string `json:"name"`
ClusterName string `json:"clusterName"`
Namespace string `json:"namespace"`
ObjectUid string `json:"objectUid"`
CreationTimestamp string `json:"creationTimestamp"`
DeletionTimestamp string `json:"deletionTimestamp"`
MinReadySecs string `json:"minReadySecs"`
RevisionHistoryLimits string `json:"revisionHistoryLimits"`
ReplicasAvailable string `json:"replicasAvailable"`
ReplicasUnAvailable string `json:"ReplicasUnAvailable"`
CollisionCount string `json:"collisionCount"`
ReplicasReady string `json:"replicasReady"`
NumberScheduled string `json:"numberScheduled"`
DesiredNumber string `json:"desiredNumber"`
MissScheduled string `json:"missScheduled"`
UpdatedNumberScheduled string `json:"updatedNumberScheduled"`
}
func NewDaemonSchemaDef ¶
func NewDaemonSchemaDef() DaemonSchemaDef
type DaemonSchemaDefWrapper ¶
type DaemonSchemaDefWrapper struct {
Schema DaemonSchemaDef `json:"schema"`
}
func NewDaemonSchemaDefWrapper ¶
func NewDaemonSchemaDefWrapper() DaemonSchemaDefWrapper
func (DaemonSchemaDefWrapper) Unwrap ¶
func (sd DaemonSchemaDefWrapper) Unwrap() *map[string]interface{}
type Dashboard ¶
type Dashboard struct {
ID float64 `json:"id"`
Version float64 `json:"version"`
BuiltIn bool `json:"builtIn"`
NameUnique bool `json:"nameUnique"`
SecurityToken *string `json:"securityToken"`
SharingRevoked bool `json:"sharingRevoked"`
Disabled bool `json:"disabled"`
Name string `json:"name"`
CreatedBy string `json:"createdBy"`
CreatedOn float64 `json:"createdOn"`
ModifiedBy string `json:"modifiedBy"`
ModifiedOn float64 `json:"modifiedOn"`
Template bool `json:"template"`
TemplateEntityType string `json:"templateEntityType"`
BackgroundColor int `json:"backgroundColor"`
Color int `json:"color"`
RefreshInterval int `json:"refreshInterval"`
Widgets []map[string]interface{} `json:"widgets"`
Description *string `json:"description"`
CanvasType string `json:"canvasType"`
MinutesBeforeAnchorTime int `json:"minutesBeforeAnchorTime"`
Width float64 `json:"width"`
LayoutType string `json:"layoutType"`
WarRoom bool `json:"warRoom"`
Properties *[]interface{} `json:"properties"`
StartTime *int `json:"startTime"`
EndTime *int `json:"endTime"`
Height float64 `json:"height"`
}
type DashboardBag ¶
type DashboardBag struct {
Type DashboardType //cluster/tier/node/namespace
ClusterName string
Namespace string
AppName string
TierName string
ClusterAppID int
ClusterTierID int
ClusterNodeID int
AppID int
TierID int
NodeID int
Pods []PodSchema
NSMap map[string]map[string][]HeatNode
}
func NewDashboardBagCluster ¶
func NewDashboardBagCluster() *DashboardBag
func NewDashboardBagTier ¶
func NewDashboardBagTier(ns string, tierName string, pods []PodSchema) DashboardBag
func (*DashboardBag) AddNode ¶
func (db *DashboardBag) AddNode(hn *HeatNode)
type DashboardType ¶
type DashboardType string
const ( Cluster DashboardType = "cluster" Tier DashboardType = "tier" Node DashboardType = "node" Namespace DashboardType = "namespace" )
type DataSeriesTemplate ¶
type DataSeriesTemplate struct {
MetricType string `json:"metricType"`
SeriesType string `json:"seriesType"`
AxisPosition *string `json:"axisPosition"`
Name string `json:"name"`
ShowRawMetricName bool `json:"showRawMetricName"`
ColorPalette ColorPalette `json:"colorPalette"`
MetricMatchCriteriaTemplate MetricMatchCriteriaTemplate `json:"metricMatchCriteriaTemplate"`
}
type DeployObjList ¶
type DeployObjList struct {
Items []DeploySchema
}
func NewDeployObjList ¶
func NewDeployObjList() DeployObjList
func (DeployObjList) AddItem ¶
func (l DeployObjList) AddItem(obj DeploySchema) []DeploySchema
func (DeployObjList) Clear ¶
func (l DeployObjList) Clear() []DeploySchema
type DeploySchema ¶
type DeploySchema struct {
Name string `json:"name"`
ClusterName string `json:"clusterName"`
Namespace string `json:"namespace"`
ObjectUid string `json:"objectUid"`
CreationTimestamp time.Time `json:"creationTimestamp"`
DeletionTimestamp time.Time `json:"deletionTimestamp"`
Labels string `json:"labels"`
Annotations string `json:"annotations"`
MinReadySecs int32 `json:"minReadySecs"`
ProgressDeadlineSecs int32 `json:"progressDeadlineSecs"`
Replicas int32 `json:"replicas"`
RevisionHistoryLimits int32 `json:"revisionHistoryLimits"`
Strategy string `json:"strategy"`
MaxSurge string `json:"maxSurge"`
ReplicasAvailable int32 `json:"replicasAvailable"`
ReplicasUnAvailable int32 `json:"ReplicasUnAvailable"`
ReplicasUpdated int32 `json:"replicasUpdated"`
CollisionCount int32 `json:"collisionCount"`
ReplicasReady int32 `json:"replicasReady"`
ReplicasLabeled int32 `json:"replicasLabeled"`
NumberScheduled int32 `json:"numberScheduled"`
DesiredNumber int32 `json:"desiredNumber"`
MissScheduled int32 `json:"missScheduled"`
UpdatedNumberScheduled int32 `json:"updatedNumberScheduled"`
DeploymentType string `json:"deploymentType"`
}
func NewDeployObj ¶
func NewDeployObj() DeploySchema
func (*DeploySchema) Equals ¶
func (ps *DeploySchema) Equals(obj *DeploySchema) bool
func (*DeploySchema) GetDeployKey ¶
func (ps *DeploySchema) GetDeployKey() string
type DeploySchemaDef ¶
type DeploySchemaDef struct {
Name string `json:"name"`
ClusterName string `json:"clusterName"`
Namespace string `json:"namespace"`
ObjectUid string `json:"objectUid"`
CreationTimestamp string `json:"creationTimestamp"`
DeletionTimestamp string `json:"deletionTimestamp"`
Labels string `json:"labels"`
Annotations string `json:"annotations"`
MinReadySecs string `json:"minReadySecs"`
ProgressDeadlineSecs string `json:"progressDeadlineSecs"`
Replicas string `json:"replicas"`
RevisionHistoryLimits string `json:"revisionHistoryLimits"`
Strategy string `json:"strategy"`
MaxSurge string `json:"maxSurge"`
ReplicasAvailable string `json:"replicasAvailable"`
ReplicasUnAvailable string `json:"ReplicasUnAvailable"`
ReplicasUpdated string `json:"replicasUpdated"`
CollisionCount string `json:"collisionCount"`
ReplicasReady string `json:"replicasReady"`
ReplicasLabeled string `json:"replicasLabeled"`
NumberScheduled string `json:"numberScheduled"`
DesiredNumber string `json:"desiredNumber"`
MissScheduled string `json:"missScheduled"`
UpdatedNumberScheduled string `json:"updatedNumberScheduled"`
DeploymentType string `json:"deploymentType"`
}
func NewDeploySchemaDef ¶
func NewDeploySchemaDef() DeploySchemaDef
func (DeploySchemaDef) Unwrap ¶
func (sd DeploySchemaDef) Unwrap() *map[string]interface{}
type DeploySchemaDefWrapper ¶
type DeploySchemaDefWrapper struct {
Schema DeploySchemaDef `json:"schema"`
}
func NewDeploySchemaDefWrapper ¶
func NewDeploySchemaDefWrapper() DeploySchemaDefWrapper
func (DeploySchemaDefWrapper) Unwrap ¶
func (sd DeploySchemaDefWrapper) Unwrap() *map[string]interface{}
type EpSchema ¶
type EpSchema struct {
ClusterName string `json:"clusterName"`
Name string `json:"name"`
Namespace string `json:"namespace"`
Ports string `json:"ports"`
ReadyIPs string `json:"readyIPs"`
NotReadyIPs string `json:"notReadyIPs"`
Pods string `json:"pods"`
PodCount int `json:"podCount"`
IsOrphan bool `json:"isOrphan"`
}
func NewEpSchema ¶
func NewEpSchema(ep *v1.Endpoints) EpSchema
type EpSchemaDef ¶
type EpSchemaDef struct {
ClusterName string `json:"clusterName"`
Name string `json:"name"`
Namespace string `json:"namespace"`
Ports string `json:"ports"`
ReadyIPs string `json:"readyIPs"`
NotReadyIPs string `json:"notReadyIPs"`
Pods string `json:"pods"`
PodCount string `json:"podCount"`
IsOrphan string `json:"isOrphan"`
}
func NewEpSchemaDef ¶
func NewEpSchemaDef() EpSchemaDef
func (EpSchemaDef) Unwrap ¶
func (sd EpSchemaDef) Unwrap() *map[string]interface{}
type EpSchemaDefWrapper ¶
type EpSchemaDefWrapper struct {
Schema EpSchemaDef `json:"schema"`
}
func NewEpSchemaDefWrapper ¶
func NewEpSchemaDefWrapper() EpSchemaDefWrapper
func (EpSchemaDefWrapper) Unwrap ¶
func (sd EpSchemaDefWrapper) Unwrap() *map[string]interface{}
type EventObjList ¶
type EventObjList struct {
Items []EventSchema
}
func NewEventObjList ¶
func NewEventObjList() EventObjList
func (EventObjList) AddItem ¶
func (l EventObjList) AddItem(obj EventSchema) []EventSchema
func (EventObjList) Clear ¶
func (l EventObjList) Clear() []EventSchema
type EventSchema ¶
type EventSchema struct {
ObjectKind string `json:"objectKind"`
ObjectName string `json:"objectName"`
ClusterName string `json:"clusterName"`
ObjectNamespace string `json:"objectNamespace"`
ObjectResourceVersion string `json:"objectResourceVersion"`
ObjectUid string `json:"objectUid"`
LastTimestamp time.Time `json:"lastTimestamp"`
Message string `json:"message"`
CreationTimestamp time.Time `json:"creationTimestamp"`
DeletionTimestamp time.Time `json:"deletionTimestamp"`
GenerateName string `json:"generateName"`
Generation int64 `json:"generation"`
Name string `json:"name"`
Namespace string `json:"namespace"`
OwnerReferences string `json:"ownerReferences"`
ResourceVersion string `json:"resourceVersion"`
SelfLink string `json:"selfLink"`
Type string `json:"type"`
Category string `json:"category"`
SubCategory string `json:"subCategory"`
Count int32 `json:"count"`
SourceComponent string `json:"sourceComponent"`
SourceHost string `json:"sourceHost"`
Reason string `json:"reason"`
}
func NewEventObj ¶
func NewEventObj() EventSchema
func (*EventSchema) Equals ¶
func (ps *EventSchema) Equals(obj *EventSchema) bool
func (EventSchema) ToString ¶
func (p EventSchema) ToString() string
type EventSchemaDef ¶
type EventSchemaDef struct {
ObjectKind string `json:"objectKind"`
ObjectName string `json:"objectName"`
ClusterName string `json:"clusterName"`
ObjectNamespace string `json:"objectNamespace"`
ObjectResourceVersion string `json:"objectResourceVersion"`
ObjectUid string `json:"objectUid"`
LastTimestamp string `json:"lastTimestamp"`
Message string `json:"message"`
CreationTimestamp string `json:"creationTimestamp"`
DeletionTimestamp string `json:"deletionTimestamp"`
GenerateName string `json:"generateName"`
Generation string `json:"generation"`
Name string `json:"name"`
Namespace string `json:"namespace"`
OwnerReferences string `json:"ownerReferences"`
ResourceVersion string `json:"resourceVersion"`
SelfLink string `json:"selfLink"`
Type string `json:"type"`
Category string `json:"category"`
SubCategory string `json:"subCategory"`
Count string `json:"count"`
SourceComponent string `json:"sourceComponent"`
SourceHost string `json:"sourceHost"`
Reason string `json:"reason"`
}
func NewEventSchemaDef ¶
func NewEventSchemaDef() EventSchemaDef
func (EventSchemaDef) Unwrap ¶
func (sd EventSchemaDef) Unwrap() *map[string]interface{}
type EventSchemaDefWrapper ¶
type EventSchemaDefWrapper struct {
Schema EventSchemaDef `json:"schema"`
}
func NewEventSchemaDefWrapper ¶
func NewEventSchemaDefWrapper() EventSchemaDefWrapper
func (EventSchemaDefWrapper) Unwrap ¶
func (sd EventSchemaDefWrapper) Unwrap() *map[string]interface{}
type HeatNode ¶
type HeatNode struct {
Namespace string
Nodename string
Podname string
Owner string
State string
PendingTime int64
APM bool
AppID int
TierID int
NodeID int
Restarts int32
Events []string
Containers map[string]Utilization
}
func NewHeatNode ¶
func (*HeatNode) FormatPendingTime ¶
func (*HeatNode) GetContainerCount ¶
func (*HeatNode) GetContainerStatsFormatted ¶
func (*HeatNode) GetEventsFormatted ¶
func (*HeatNode) IsOverconsuming ¶
type InstrumentationMethod ¶
type InstrumentationMethod string
const ( None InstrumentationMethod = "none" CopyAttach InstrumentationMethod = "copyAttach" MountAttach InstrumentationMethod = "mountAttach" MountEnv InstrumentationMethod = "mountEnv" )
type JobObjList ¶
type JobObjList struct {
Items []JobSchema
}
func NewJobObjList ¶
func NewJobObjList() JobObjList
func (JobObjList) AddItem ¶
func (l JobObjList) AddItem(obj JobSchema) []JobSchema
func (JobObjList) Clear ¶
func (l JobObjList) Clear() []JobSchema
type JobSchema ¶
type JobSchema struct {
Name string `json:"name"`
Namespace string `json:"namespace"`
ClusterName string `json:"clusterName"`
Labels string `json:"labels"`
Annotations string `json:"annotations"`
StartTime time.Time `json:"startTime"`
EndTime time.Time `json:"endTime"`
Active int32 `json:"active"`
Failed int32 `json:"failed"`
Success int32 `json:"success"`
ActiveDeadlineSeconds int64 `json:"activeDeadlineSeconds"`
Completions int32 `json:"completions"`
BackoffLimit int32 `json:"backoffLimit"`
Parallelism int32 `json:"parallelism"`
Duration float64 `json:"duration"`
}
type JobSchemaDef ¶
type JobSchemaDef struct {
Name string `json:"name"`
Namespace string `json:"namespace"`
ClusterName string `json:"clusterName"`
Labels string `json:"labels"`
Annotations string `json:"annotations"`
StartTime string `json:"startTime"`
EndTime string `json:"endTime"`
Active string `json:"active"`
Failed string `json:"failed"`
Success string `json:"success"`
ActiveDeadlineSeconds string `json:"activeDeadlineSeconds"`
Completions string `json:"completions"`
BackoffLimit string `json:"backoffLimit"`
Parallelism string `json:"parallelism"`
Duration string `json:"duration"`
}
func NewJobSchemaDef ¶
func NewJobSchemaDef() JobSchemaDef
type JobSchemaDefWrapper ¶
type JobSchemaDefWrapper struct {
Schema JobSchemaDef `json:"schema"`
}
func NewJobSchemaDefWrapper ¶
func NewJobSchemaDefWrapper() JobSchemaDefWrapper
func (JobSchemaDefWrapper) Unwrap ¶
func (sd JobSchemaDefWrapper) Unwrap() *map[string]interface{}
type LogObjList ¶
type LogObjList struct {
Items []LogSchema
}
func NewLogObjList ¶
func NewLogObjList() LogObjList
func (LogObjList) AddItem ¶
func (l LogObjList) AddItem(obj LogSchema) []LogSchema
func (LogObjList) Clear ¶
func (l LogObjList) Clear() []LogSchema
type LogSchema ¶
type LogSchema struct {
ClusterName string `json:"clusterName"`
Namespace string `json:"namespace"`
PodOwner string `json:"podOwner"`
PodName string `json:"pod"`
ContainerName string `json:"container"`
Message string `json:"message"`
BatchTimestamp int64 `json:"batchTimestamp"`
Timestamp *time.Time `json:"timestamp"`
}
type LogSchemaDef ¶
type LogSchemaDef struct {
ClusterName string `json:"clusterName"`
Namespace string `json:"namespace"`
PodOwner string `json:"podOwner"`
PodName string `json:"pod"`
ContainerName string `json:"container"`
Message string `json:"message"`
BatchTimestamp string `json:"batchTimestamp"`
Timestamp string `json:"timestamp"`
}
func NewLogSchemaDef ¶
func NewLogSchemaDef() LogSchemaDef
type LogSchemaDefWrapper ¶
type LogSchemaDefWrapper struct {
Schema LogSchemaDef `json:"schema"`
}
func NewLogSchemaDefWrapper ¶
func NewLogSchemaDefWrapper() LogSchemaDefWrapper
type MetricExpression ¶
type MetricExpression struct {
InputMetricPath *string `json: "inputMetricPath"`
DisplayName string `json: "displayName"`
FunctionType string `json: "functionType"`
InputMetricText bool `json: "inputMetricText"`
MetricPath string `json: "metricPath"`
ScopeEntity ScopeEntity `json: "scopeEntity"`
MetricExpressionType string `json: "metricExpressionType"`
LiteralValue float64 `json: "literalValue"`
Operator Operator `json: "operator, omitempty"`
Expression2 MetricExpression2 `json: "expression2, omitempty"`
}
type MetricExpression2 ¶
type MetricExpression2 struct {
InputMetricPath *string `json: "inputMetricPath"`
DisplayName string `json: "displayName"`
FunctionType string `json: "functionType"`
InputMetricText bool `json: "inputMetricText"`
MetricPath string `json: "metricPath"`
ScopeEntity ScopeEntity `json: "scopeEntity"`
MetricExpressionType string `json: "metricExpressionType"`
LiteralValue float64 `json: "literalValue"`
Operator Operator `json: "operator, omitempty"`
}
type MetricExpressionTemplate ¶
type MetricExpressionTemplate struct {
InputMetricPath *string `json: "inputMetricPath, omitempty"`
DisplayName string `json: "displayName, omitempty"`
FunctionType string `json: "functionType, omitempty"`
InputMetricText bool `json: "inputMetricText, omitempty"`
MetricPath string `json: "metricPath, omitempty"`
ScopeEntity ScopeEntity `json: "scopeEntity, omitempty"`
MetricExpressionType string `json: "metricExpressionType, omitempty"`
Operator Operator `json: "operator, omitempty"`
Expression1 MetricExpression `json: "expression1, omitempty"`
Expression2 MetricExpression2 `json: "expression2, omitempty"`
}
type MetricMatchCriteriaTemplate ¶
type MetricMatchCriteriaTemplate struct {
EvaluationScopeType *string `json:"evaluationScopeType"`
RollupMetricData bool `json:"rollupMetricData"`
MaxResults int `json:"maxResults"`
EntityMatchCriteria *string `json:"entityMatchCriteria"`
UseActiveBaseline bool `json:"useActiveBaseline"`
SortResultsAscending bool `json:"sortResultsAscending"`
MetricExpressionTemplate map[string]interface{} `json:"metricExpressionTemplate" `
MetricDisplayNameCustomFormat string `json:"metricDisplayNameCustomFormat"`
ExpressionString string `json:"expressionString"`
BaselineName *string `json:"baselineName"`
ApplicationName string `json:"applicationName"`
MetricDisplayNameStyle string `json:"metricDisplayNameStyle"`
}
type NodeMetricsObj ¶
type NodeMetricsObj struct {
Kind string
Metadata struct {
Name string
SelfLink string
// contains filtered or unexported fields
}
Timestamp string
Window string
Usage struct {
Cpu string
Memory string
}
}
func (NodeMetricsObj) GetNodeUsage ¶
func (mobj NodeMetricsObj) GetNodeUsage() UsageStats
type NodeMetricsObjList ¶
type NodeMetricsObjList struct {
Kind string
Items []struct {
Metadata struct {
Name string
SelfLink string
// contains filtered or unexported fields
}
Timestamp string
Window string
Usage struct {
Cpu string
Memory string
}
}
}
func (NodeMetricsObjList) PrintNodeList ¶
func (m NodeMetricsObjList) PrintNodeList() map[string]UsageStats
type NodeObjList ¶
type NodeObjList struct {
Items []NodeSchema
}
func NewNodeObjList ¶
func NewNodeObjList() NodeObjList
func (NodeObjList) AddItem ¶
func (l NodeObjList) AddItem(obj NodeSchema) []NodeSchema
func (NodeObjList) Clear ¶
func (l NodeObjList) Clear() []NodeSchema
type NodeSchema ¶
type NodeSchema struct {
NodeName string `json:"nodeName"`
ClusterName string `json:"clusterName"`
PodCIDR string `json:"podCIDR"`
Taints string `json:"taints"`
Phase string `json:"phase"`
Addresses string `json:"addresses"`
Labels string `json:"labels"`
Role string `json:"role"`
CpuUse int64 `json:"cpuUse"`
MemUse int64 `json:"memUse"`
CpuCapacity int64 `json:"cpuCapacity"`
MemCapacity int64 `json:"memCapacity"`
PodCapacity int64 `json:"podCapacity"`
CpuAllocations int64 `json:"cpuAllocations"`
MemAllocations int64 `json:"memAllocations"`
PodAllocations int64 `json:"podAllocations"`
KubeletPort int32 `json:"kubeletPort"`
OsArch string `json:"osArch"`
KubeletVersion string `json:"kubeletVersion"`
RuntimeVersion string `json:"runtimeVersion"`
MachineID string `json:"machineID"`
OsName string `json:"osName"`
AttachedVolumes string `json:"attachedVolumes"`
VolumesInUse string `json:"volumesInUse"`
Ready string `json:"ready"`
OutOfDisk string `json:"outOfDisk"`
MemoryPressure string `json:"memoryPressure"`
DiskPressure string `json:"diskPressure"`
TaintsNumber int `json:"-"`
}
func NewNodeObj ¶
func NewNodeObj() NodeSchema
func (*NodeSchema) Equals ¶
func (ps *NodeSchema) Equals(obj *NodeSchema) bool
func (*NodeSchema) GetNodeKey ¶
func (ps *NodeSchema) GetNodeKey() string
type NodeSchemaDef ¶
type NodeSchemaDef struct {
NodeName string `json:"nodeName"`
ClusterName string `json:"clusterName"`
PodCIDR string `json:"podCIDR"`
Taints string `json:"taints"`
Phase string `json:"phase"`
Addresses string `json:"addresses"`
Labels string `json:"labels"`
Role string `json:"role"`
CpuUse string `json:"cpuUse"`
MemUse string `json:"memUse"`
CpuCapacity string `json:"cpuCapacity"`
MemCapacity string `json:"memCapacity"`
PodCapacity string `json:"podCapacity"`
CpuAllocations string `json:"cpuAllocations"`
MemAllocations string `json:"memAllocations"`
PodAllocations string `json:"podAllocations"`
KubeletPort string `json:"kubeletPort"`
OsArch string `json:"osArch"`
KubeletVersion string `json:"kubeletVersion"`
RuntimeVersion string `json:"runtimeVersion"`
MachineID string `json:"machineID"`
OsName string `json:"osName"`
AttachedVolumes string `json:"attachedVolumes"`
VolumesInUse string `json:"volumesInUse"`
Ready string `json:"ready"`
OutOfDisk string `json:"outOfDisk"`
MemoryPressure string `json:"memoryPressure"`
DiskPressure string `json:"diskPressure"`
}
func NewNodeSchemaDef ¶
func NewNodeSchemaDef() NodeSchemaDef
func (NodeSchemaDef) Unwrap ¶
func (sd NodeSchemaDef) Unwrap() *map[string]interface{}
type NodeSchemaDefWrapper ¶
type NodeSchemaDefWrapper struct {
Schema NodeSchemaDef `json:"schema"`
}
func NewNodeSchemaDefWrapper ¶
func NewNodeSchemaDefWrapper() NodeSchemaDefWrapper
func (NodeSchemaDefWrapper) Unwrap ¶
func (sd NodeSchemaDefWrapper) Unwrap() *map[string]interface{}
type NsSchema ¶
type NsSchema struct {
ClusterName string `json:"clusterName"`
Name string `json:"name"`
Status string `json:"status"`
Quotas int `json:"quotas"`
}
func NewNsSchema ¶
type NsSchemaDef ¶
type NsSchemaDef struct {
ClusterName string `json:"clusterName"`
Name string `json:"name"`
Status string `json:"status"`
Quotas string `json:"quotas"`
}
func NewNsSchemaDef ¶
func NewNsSchemaDef() NsSchemaDef
func (NsSchemaDef) Unwrap ¶
func (sd NsSchemaDef) Unwrap() *map[string]interface{}
type NsSchemaDefWrapper ¶
type NsSchemaDefWrapper struct {
Schema NsSchemaDef `json:"schema"`
}
func NewNsSchemaDefWrapper ¶
func NewNsSchemaDefWrapper() NsSchemaDefWrapper
func (NsSchemaDefWrapper) Unwrap ¶
func (sd NsSchemaDefWrapper) Unwrap() *map[string]interface{}
type PodMetricsObj ¶
type PodMetricsObj struct {
Kind string
Metadata struct {
Name string
SelfLink string
// contains filtered or unexported fields
}
Timestamp string
Window string
Containers []struct {
Name string
Usage struct {
Cpu string
Memory string
}
}
}
func (PodMetricsObj) GetContainerUsage ¶
func (mobj PodMetricsObj) GetContainerUsage(containerName string) UsageStats
func (PodMetricsObj) GetPodUsage ¶
func (mobj PodMetricsObj) GetPodUsage() UsageStats
type PodMetricsObjList ¶
type PodMetricsObjList struct {
Kind string
Items []struct {
Metadata struct {
Name string
SelfLink string
// contains filtered or unexported fields
}
Timestamp string
Window string
Containers []struct {
Name string
Usage struct {
Cpu string
Memory string
}
}
}
}
func (PodMetricsObjList) PrintPodList ¶
func (m PodMetricsObjList) PrintPodList() map[string]UsageStats
type PodObjList ¶
type PodObjList struct {
Items []PodSchema
}
func NewPodObjList ¶
func NewPodObjList() PodObjList
func (PodObjList) AddItem ¶
func (l PodObjList) AddItem(obj PodSchema) []PodSchema
func (PodObjList) Clear ¶
func (l PodObjList) Clear() []PodSchema
type PodSchema ¶
type PodSchema struct {
Name string `json:"name"`
Namespace string `json:"namespace"`
ClusterName string `json:"clusterName"`
Labels string `json:"labels"`
Annotations string `json:"annotations"`
ContainerCount int `json:"containerCount"`
InitContainerCount int `json:"initContainerCount"`
NodeName string `json:"nodeName"`
Priority int32 `json:"priority"`
RestartPolicy string `json:"restartPolicy"`
ServiceAccountName string `json:"serviceAccountName"`
TerminationGracePeriodSeconds int64 `json:"terminationGracePeriodSeconds"`
Tolerations string `json:"tolerations"`
NodeAffinityPreferred string `json:"nodeAffinityPreferred"`
NodeAffinityRequired string `json:"nodeAffinityRequired"`
PodAffinityPreferred string `json:"podAffinityPreferred"`
PodAffinityRequired string `json:"podAffinityRequired"`
PodAntiAffinityPreferred string `json:"podAntiAffinityPreferred"`
PodAntiAffinityRequired string `json:"podAntiAffinityRequired"`
HostIP string `json:"hostIP"`
Phase string `json:"phase"`
PodIP string `json:"podIP"`
Reason string `json:"reason"`
StartTime time.Time `json:"startTime"`
LastTransitionTimeCondition *time.Time `json:"lastTransitionTimeCondition"`
ReasonCondition string `json:"reasonCondition"`
StatusCondition string `json:"statusCondition"`
TypeCondition string `json:"typeCondition"`
LimitsDefined bool `json:"limitsDefined"`
LiveProbes int `json:"liveProbes"`
ReadyProbes int `json:"readyProbes"`
PodRestarts int32 `json:"podRestarts"`
NumPrivileged int `json:"numPrivileged"`
Ports string `json:"ports"`
MemRequest int64 `json:"memRequest"`
CpuRequest int64 `json:"cpuRequest"`
CpuLimit int64 `json:"cpuLimit"`
MemLimit int64 `json:"memLimit"`
PodStorageRequest int64 `json:"podStorageRequest"`
PodStorageLimit int64 `json:"podStorageLimit"`
StorageRequest int64 `json:"storageRequest"`
StorageCapacity int64 `json:"storageCapacity"`
CpuUse int64 `json:"cpuUse"`
MemUse int64 `json:"memUse"`
Images string `json:"images"`
WaitReasons string `json:"waitReasons"`
TermReasons string `json:"termReasons"`
RunningStartTime *time.Time `json:"runningStartTime"`
TerminationTime *time.Time `json:"terminationTime"`
PendingTime int64 `json:"-"`
Containers map[string]ContainerSchema `json:"-"`
InitContainers map[string]ContainerSchema `json:"-"`
Owner string `json:"-"`
IsEvicted bool `json:"-"`
AppID int `json:"-"`
TierID int `json:"-"`
NodeID int `json:"-"`
AppName string `json:"-"`
TierName string `json:"-"`
APMNodeName string `json:"-"`
Services []ServiceSchema `json:"-"`
Endpoints []v1.Endpoints `json:"-"`
StartTimeMillis int64 `json:"-"`
RunningStartTimeMillis int64 `json:"-"`
TerminationTimeMillis int64 `json:"-"`
UpTimeMillis int64 `json:"-"`
BreakPointMillis int64 `json:"-"` //time when a container exited
MissingDependencies bool `json:"-"`
NoConnectivity bool `json:"-"`
ConsumptionCpu float64 `json:"-"`
ConsumptionMem float64 `json:"-"`
}
type PodSchemaDef ¶
type PodSchemaDef struct {
Name string `json:"name"`
Namespace string `json:"namespace"`
ClusterName string `json:"clusterName"`
Labels string `json:"labels"`
Annotations string `json:"annotations"`
ContainerCount string `json:"containerCount"`
InitContainerCount string `json:"initContainerCount"`
NodeName string `json:"nodeName"`
Priority string `json:"priority"`
RestartPolicy string `json:"restartPolicy"`
ServiceAccountName string `json:"serviceAccountName"`
TerminationGracePeriodSeconds string `json:"terminationGracePeriodSeconds"`
Tolerations string `json:"tolerations"`
NodeAffinityPreferred string `json:"nodeAffinityPreferred"`
NodeAffinityRequired string `json:"nodeAffinityRequired"`
PodAffinityPreferred string `json:"podAffinityPreferred"`
PodAffinityRequired string `json:"podAffinityRequired"`
PodAntiAffinityPreferred string `json:"podAntiAffinityPreferred"`
PodAntiAffinityRequired string `json:"podAntiAffinityRequired"`
HostIP string `json:"hostIP"`
Phase string `json:"phase"`
PodIP string `json:"podIP"`
Reason string `json:"reason"`
StartTime string `json:"startTime"`
LastTransitionTimeCondition string `json:"lastTransitionTimeCondition"`
ReasonCondition string `json:"reasonCondition"`
StatusCondition string `json:"statusCondition"`
TypeCondition string `json:"typeCondition"`
LimitsDefined string `json:"limitsDefined"`
LiveProbes string `json:"liveProbes"`
ReadyProbes string `json:"readyProbes"`
PodRestarts string `json:"podRestarts"`
NumPrivileged string `json:"numPrivileged"`
Ports string `json:"ports"`
MemRequest string `json:"memRequest"`
CpuRequest string `json:"cpuRequest"`
CpuLimit string `json:"cpuLimit"`
MemLimit string `json:"memLimit"`
PodStorageRequest string `json:"podStorageRequest"`
PodStorageLimit string `json:"podStorageLimit"`
StorageRequest string `json:"storageRequest"`
StorageCapacity string `json:"storageCapacity"`
CpuUse string `json:"cpuUse"`
MemUse string `json:"memUse"`
Images string `json:"images"`
WaitReasons string `json:"waitReasons"`
TermReasons string `json:"termReasons"`
RunningStartTime string `json:"runningStartTime"`
TerminationTime string `json:"terminationTime"`
}
func NewPodSchemaDef ¶
func NewPodSchemaDef() PodSchemaDef
func (PodSchemaDef) Unwrap ¶
func (sd PodSchemaDef) Unwrap() *map[string]interface{}
type PodSchemaDefWrapper ¶
type PodSchemaDefWrapper struct {
Schema PodSchemaDef `json:"schema"`
}
func NewPodSchemaDefWrapper ¶
func NewPodSchemaDefWrapper() PodSchemaDefWrapper
func (PodSchemaDefWrapper) Unwrap ¶
func (sd PodSchemaDefWrapper) Unwrap() *map[string]interface{}
type RQFields ¶
type RQFields struct {
Name string
Namespace string
RequestCpu int64
RequestMemory int64
LimitCpu int64
LimitMemory int64
StoragePod int64
Storage int64
PVC int64
Pods int64
Path string
Metadata map[string]AppDMetricMetadata
}
func NewRQFields ¶
func NewRQFields() RQFields
func (RQFields) ShouldExcludeField ¶
type RQSchemaObj ¶
type RQSchemaObj struct {
Name string
Namespace string
Selector string
PodsOnly bool
Spec RQFields
Used RQFields
}
func NewRQ ¶
func NewRQ(rq *v1.ResourceQuota) RQSchemaObj
func (*RQSchemaObj) AddQuotaStatsToAppMetrics ¶
func (rq *RQSchemaObj) AddQuotaStatsToAppMetrics(metrics *ClusterAppMetrics)
func (*RQSchemaObj) AddQuotaStatsToNamespaceMetrics ¶
func (rq *RQSchemaObj) AddQuotaStatsToNamespaceMetrics(metrics *ClusterPodMetrics)
func (*RQSchemaObj) AppliesToNamespace ¶
func (rq *RQSchemaObj) AppliesToNamespace(ns string) bool
func (*RQSchemaObj) AppliesToPod ¶
func (rq *RQSchemaObj) AppliesToPod(podObject *PodSchema) bool
func (*RQSchemaObj) IncrementQuotaStatsClusterMetrics ¶
func (rq *RQSchemaObj) IncrementQuotaStatsClusterMetrics(metrics *ClusterPodMetrics)
type RqSchema ¶
type RqSchema struct {
ClusterName string `json:"clusterName"`
Name string `json:"name"`
Namespace string `json:"namespace"`
SpecRequestCpu int64 `json:"specRequestCpu"`
SpecRequestMemory int64 `json:"specRequestMemory"`
SpecLimitCpu int64 `json:"specLimitCpu"`
SpecLimitMemory int64 `json:"specLimitMemory"`
SpecStoragePod int64 `json:"specStoragePod"`
SpecStorage int64 `json:"specStorage"`
SpecPVC int64 `json:"specPVC"`
SpecPods int64 `json:"specPods"`
UsedRequestCpu int64 `json:"usedRequestCpu"`
UsedRequestMemory int64 `json:"usedRequestMemory"`
UsedLimitCpu int64 `json:"usedLimitCpu"`
UsedLimitMemory int64 `json:"usedLimitMemory"`
UsedStoragePod int64 `json:"usedStoragePod"`
UsedStorage int64 `json:"usedStorage"`
UsedPVC int64 `json:"usedPVC"`
UsedPods int64 `json:"usedPods"`
}
func NewRQSchema ¶
func NewRQSchema(rq *v1.ResourceQuota) RqSchema
type RqSchemaDef ¶
type RqSchemaDef struct {
ClusterName string `json:"clusterName"`
Name string `json:"name"`
Namespace string `json:"namespace"`
SpecRequestCpu string `json:"specRequestCpu"`
SpecRequestMemory string `json:"specRequestMemory"`
SpecLimitCpu string `json:"specLimitCpu"`
SpecLimitMemory string `json:"specLimitMemory"`
SpecStoragePod string `json:"specStoragePod"`
SpecStorage string `json:"specStorage"`
SpecPVC string `json:"specPVC"`
SpecPods string `json:"specPods"`
UsedRequestCpu string `json:"usedRequestCpu"`
UsedRequestMemory string `json:"usedRequestMemory"`
UsedLimitCpu string `json:"usedLimitCpu"`
UsedLimitMemory string `json:"usedLimitMemory"`
UsedStoragePod string `json:"usedStoragePod"`
UsedStorage string `json:"usedStorage"`
UsedPVC string `json:"usedPVC"`
UsedPods string `json:"usedPods"`
}
func NewRqSchemaDef ¶
func NewRqSchemaDef() RqSchemaDef
type RqSchemaDefWrapper ¶
type RqSchemaDefWrapper struct {
Schema RqSchemaDef `json:"schema"`
}
func NewRqSchemaDefWrapper ¶
func NewRqSchemaDefWrapper() RqSchemaDefWrapper
func (RqSchemaDefWrapper) Unwrap ¶
func (sd RqSchemaDefWrapper) Unwrap() *map[string]interface{}
type RsObjList ¶
type RsObjList struct {
Items []RsSchema
}
func NewRsObjList ¶
func NewRsObjList() RsObjList
type RsSchema ¶
type RsSchema struct {
Name string `json:"name"`
ClusterName string `json:"clusterName"`
Namespace string `json:"namespace"`
ObjectUid string `json:"objectUid"`
CreationTimestamp time.Time `json:"creationTimestamp"`
DeletionTimestamp time.Time `json:"deletionTimestamp"`
MinReadySecs int32 `json:"minReadySecs"`
RsReplicas int32 `json:"rsReplicas"`
RsReplicasAvailable int32 `json:"rsReplicasAvailable"`
RsReplicasUnAvailable int32 `json:"rsReplicasUnAvailable"`
RsReplicasLabeled int32 `json:"rsReplicasLabeled"`
RsReplicasReady int32 `json:"rsReplicasReady"`
}
type RsSchemaDef ¶
type RsSchemaDef struct {
Name string `json:"name"`
ClusterName string `json:"clusterName"`
Namespace string `json:"namespace"`
ObjectUid string `json:"objectUid"`
CreationTimestamp string `json:"creationTimestamp"`
DeletionTimestamp string `json:"deletionTimestamp"`
MinReadySecs string `json:"minReadySecs"`
RsReplicas string `json:"rsReplicas"`
RsReplicasAvailable string `json:"rsReplicasAvailable"`
RsReplicasUnAvailable string `json:"rsReplicasUnAvailable"`
RsReplicasLabeled string `json:"rsReplicasLabeled"`
RsReplicasReady string `json:"rsReplicasReady"`
}
func NewRsSchemaDef ¶
func NewRsSchemaDef() RsSchemaDef
type RsSchemaDefWrapper ¶
type RsSchemaDefWrapper struct {
Schema RsSchemaDef `json:"schema"`
}
func NewRsSchemaDefWrapper ¶
func NewRsSchemaDefWrapper() RsSchemaDefWrapper
func (RsSchemaDefWrapper) Unwrap ¶
func (sd RsSchemaDefWrapper) Unwrap() *map[string]interface{}
type ScopeEntity ¶
type ServiceEndpoint ¶
func NewServiceEndpoint ¶
func NewServiceEndpoint(name string, portNumber int32) ServiceEndpoint
type ServicePort ¶
type ServiceSchema ¶
type ServiceSchema struct {
Name string
Namespace string
Selector map[string]string
Ports []ServicePort
Routes []Ingress
Endpoints map[int32]ServiceEndpoint
ExternalName string
ExternalSvcValid bool
HasNodePort bool
HasIngress bool
HasExternalService bool
IsAccessible bool
ReferencedExternally bool
}
func NewServiceSchema ¶
func NewServiceSchema(svc *v1.Service) *ServiceSchema
func (*ServiceSchema) ExternallyReferenced ¶
func (svcSchema *ServiceSchema) ExternallyReferenced(referenced bool)
func (*ServiceSchema) GetEndPointsStats ¶
func (*ServiceSchema) IsPortAvailable ¶
func (svcSchema *ServiceSchema) IsPortAvailable(cp *ContainerPort, podSchema *PodSchema) (bool, bool)
func (*ServiceSchema) MatchesPod ¶
func (svcSchema *ServiceSchema) MatchesPod(podObject *v1.Pod) bool
type StaticThreshold ¶
type StaticThreshold struct {
}
type TechnologyName ¶
type TechnologyName string
type UsageStats ¶
type Utilization ¶
type Utilization struct {
CpuUse float64
MemUse float64
CpuUseString string
MemUseString string
Overconsume bool
CpuGoal float64
MemGoal float64
Restarts int32
}
func (*Utilization) CheckStatus ¶
func (u *Utilization) CheckStatus(threshold float64, cpuRequest float64, memRequest float64)
type WidgetTemplate ¶
type WidgetTemplate struct {
UseMetricBrowserAsDrillDown bool `json:"useMetricBrowserAsDrillDown"`
BorderColor int `json:"borderColor"`
ShowValues bool `json:"showValues"`
Color int `json:"color"`
CompactMode bool `json:"compactMode"`
ShowTimeRange bool `json:"showTimeRange"`
LegendColumnCount *int `json:"legendColumnCount"`
ShowLegend bool `json:"showLegend"`
Description *string `json:"description"`
BackgroundAlpha float32 `json:"backgroundAlpha"`
FormatNumber bool `json:"formatNumber"`
Title *string `json:"title"`
ApplicationReference *ScopeEntity `json:"applicationReference,omitempty"`
EntityReferences *[]ScopeEntity `json:"entityReferences,omitempty"`
DataSeriesTemplates []DataSeriesTemplate `json:"dataSeriesTemplates"`
MinHeight int `json:"minHeight"`
BorderThickness int `json:"borderThickness"`
UseAutomaticFontSize bool `json:"useAutomaticFontSize"`
RemoveZeros bool `json:"removeZeros"`
DrillDownUrl *string `json:"drillDownUrl"`
ImageURL *string `json:"imageURL"`
StartTime *int `json:"startTime"`
Text string `json:"text"`
DrillDownActionType *string `json:"drillDownActionType"`
Height int `json:"height"`
NumDecimals int `json:"numDecimals"`
BackgroundColor int `json:"backgroundColor"`
Margin int `json:"margin"`
TextAlign string `json:"textAlign"`
MinWidth int `json:"minWidth"`
PropertiesMap *string `json:"propertiesMap"`
Label *string `json:"label"`
RenderIn3D bool `json:"renderIn3D"`
MinutesBeforeAnchorTime int `json:"minutesBeforeAnchorTime"`
WidgetType string `json:"widgetType"`
BackgroundColorsStr string `json:"backgroundColorsStr"`
BorderEnabled bool `json:"borderEnabled"`
Width int `json:"width"`
X int `json:"x"`
BackgroundColors *[]interface{} `json:"backgroundColors"`
IsGlobal bool `json:"isGlobal"`
Y int `json:"y"`
FontSize int `json:"fontSize"`
LegendPosition *string `json:"legendPosition"`
EndTime *int `json:"endTime"`
CustomVerticalAxisMin *int `json:"customVerticalAxisMin"`
CustomVerticalAxisMax *int `json:"customVerticalAxisMax"`
MultipleYAxis *string `json:"multipleYAxis"`
StaticThresholdList []StaticThreshold `json:"staticThresholdList"`
ShowAllTooltips bool `json:"showAllTooltips"`
AxisType string `json:"axisType"`
HorizontalAxisLabel *string `json:"horizontalAxisLabel"`
VerticalAxisLabel *string `json:"verticalAxisLabel"`
ShowEvents *string `json:"showEvents"`
HideHorizontalAxis *string `json:"hideHorizontalAxis"`
StackMode bool `json:"stackMode"`
InterpolateDataGaps bool `json:"interpolateDataGaps"`
EventFilterTemplate *string `json:"eventFilterTemplate"`
EntityType *string `json:"entityType"`
EntitySelectionType *string `json:"entitySelectionType"`
}
Source Files
¶
- AdqlSearch.go
- agentrequest.go
- appdbag.go
- appdmetricmetadata.go
- appdmetrics.go
- attachstatus.go
- biq.go
- clusterappmetrics.go
- clustercontainermetrics.go
- clusterdaemonmetrics.go
- clusterdeploymetrics.go
- clustereventmetrics.go
- clusterinstancemetrics.go
- clusterjobmetrics.go
- clusternodemetrics.go
- clusterpodmetrics.go
- clusterrsmetrics.go
- containerschema.go
- daemonschema.go
- dashBag.go
- dashboard.go
- deployschema.go
- epschema.go
- eventschema.go
- heatnode.go
- jobschema.go
- metricsObj.go
- nodeschema.go
- nsschema.go
- podlogschema.go
- podschema.go
- rqschema.go
- rsschema.go
- serviceschema.go
Click to show internal directories.
Click to hide internal directories.