clusterstatus

Documentation

Index

• Constants
• Variables
• type ApplicationEntity
  • func NewApplicationEntity(data map[string]string) *ApplicationEntity
  • func (p *ApplicationEntity) BuildInfluxPoint(measurement string) (*InfluxClient.Point, error)
• type ClusterEntity
  • func NewClusterEntity(data map[string]string) *ClusterEntity
  • func (p *ClusterEntity) BuildInfluxPoint(measurement string) (*InfluxClient.Point, error)
• type ContainerEntity
  • func NewContainerEntity(data map[string]string) *ContainerEntity
  • func (p *ContainerEntity) BuildInfluxPoint(measurement string) (*InfluxClient.Point, error)
• type ControllerEntity
  • func NewControllerEntity(data map[string]string) *ControllerEntity
  • func (p *ControllerEntity) BuildInfluxPoint(measurement string) (*InfluxClient.Point, error)
• type NamespaceEntity
  • func NewNamespaceEntity(data map[string]string) *NamespaceEntity
  • func (p *NamespaceEntity) BuildInfluxPoint(measurement string) (*InfluxClient.Point, error)
• type NodeEntity
  • func NewNodeEntity(data map[string]string) *NodeEntity
  • func (p *NodeEntity) BuildInfluxPoint(measurement string) (*InfluxClient.Point, error)
• type PodEntity
  • func NewPodEntity(data map[string]string) *PodEntity
  • func (p *PodEntity) BuildInfluxPoint(measurement string) (*InfluxClient.Point, error)

Constants

const (
	ApplicationName        influxdb.Tag   = "name"
	ApplicationNamespace   influxdb.Tag   = "namespace"
	ApplicationClusterName influxdb.Tag   = "cluster_name"
	ApplicationUid         influxdb.Tag   = "uid"
	ApplicationDummy       influxdb.Field = "dummy"
)

const (
	ClusterName  influxdb.Tag   = "name"
	ClusterUid   influxdb.Tag   = "uid"
	ClusterValue influxdb.Field = "value"
)

const (
	ContainerName                     influxdb.Tag = "name"
	ContainerPodName                  influxdb.Tag = "pod_name"
	ContainerNamespace                influxdb.Tag = "namespace"
	ContainerNodeName                 influxdb.Tag = "node_name"
	ContainerClusterName              influxdb.Tag = "cluster_name"
	ContainerUid                      influxdb.Tag = "uid"
	ContainerTopControllerName        influxdb.Tag = "top_controller_name"
	ContainerTopControllerKind        influxdb.Tag = "top_controller_kind"
	ContainerAlamedaScalerName        influxdb.Tag = "alameda_scaler_name"
	ContainerAlamedaScalerNamespace   influxdb.Tag = "alameda_scaler_namespace"
	ContainerAlamedaScalerScalingTool influxdb.Tag = "alameda_scaler_scaling_tool"

	ContainerResourceRequestCPU                  influxdb.Field = "resource_request_cpu"
	ContainerResourceRequestMemory               influxdb.Field = "resource_request_memory"
	ContainerResourceLimitCPU                    influxdb.Field = "resource_limit_cpu"
	ContainerResourceLimitMemory                 influxdb.Field = "resource_limit_memory"
	ContainerStatusWaitingReason                 influxdb.Field = "status_waiting_reason"
	ContainerStatusWaitingMessage                influxdb.Field = "status_waiting_message"
	ContainerStatusRunningStartedAt              influxdb.Field = "status_running_start_at"
	ContainerStatusTerminatedExitCode            influxdb.Field = "status_terminated_exit_code"
	ContainerStatusTerminatedReason              influxdb.Field = "status_terminated_reason"
	ContainerStatusTerminatedMessage             influxdb.Field = "status_terminated_message"
	ContainerStatusTerminatedStartedAt           influxdb.Field = "status_terminated_started_at"
	ContainerStatusTerminatedFinishedAt          influxdb.Field = "status_terminated_finished_at"
	ContainerLastTerminationWaitingReason        influxdb.Field = "last_termination_status_waiting_reason"
	ContainerLastTerminationWaitingMessage       influxdb.Field = "last_termination_status_waiting_message"
	ContainerLastTerminationRunningStartedAt     influxdb.Field = "last_termination_status_running_start_at"
	ContainerLastTerminationTerminatedExitCode   influxdb.Field = "last_termination_status_terminated_exit_code"
	ContainerLastTerminationTerminatedReason     influxdb.Field = "last_termination_status_terminated_reason"
	ContainerLastTerminationTerminatedMessage    influxdb.Field = "last_termination_status_terminated_message"
	ContainerLastTerminationTerminatedStartedAt  influxdb.Field = "last_termination_status_terminated_started_at"
	ContainerLastTerminationTerminatedFinishedAt influxdb.Field = "last_termination_status_terminated_finished_at"
	ContainerRestartCount                        influxdb.Field = "restart_count"
)

const (
	ControllerName                         influxdb.Tag   = "name"
	ControllerNamespace                    influxdb.Tag   = "namespace"
	ControllerClusterName                  influxdb.Tag   = "cluster_name"
	ControllerUid                          influxdb.Tag   = "uid"
	ControllerKind                         influxdb.Tag   = "kind"
	ControllerAlamedaSpecScalerName        influxdb.Tag   = "alameda_scaler_name"
	ControllerAlamedaSpecScalerNamespace   influxdb.Tag   = "alameda_scaler_namespace"
	ControllerAlamedaSpecScalerScalingTool influxdb.Tag   = "alameda_scaler_scaling_tool"
	ControllerReplicas                     influxdb.Field = "replicas"
	ControllerSpecReplicas                 influxdb.Field = "spec_replicas"
	ControllerAlamedaSpecPolicy            influxdb.Field = "policy"
	ControllerMinReplicas                  influxdb.Field = "resource_k8s_min_replicas"
	ControllerMaxReplicas                  influxdb.Field = "resource_k8s_max_replicas"
	ControllerAlamedaSpecEnableExecution   influxdb.Field = "enable_execution"
)

const (
	Keycode influxdb.Tag = "keycode"

	KeycodeStatus          influxdb.Field = "status"
	KeycodeType            influxdb.Field = "type"
	KeycodeState           influxdb.Field = "state"
	KeycodeRegistered      influxdb.Field = "registered"
	KeycodeExpireTimestamp influxdb.Field = "expire_timestamp"
	KeycodeRawdata         influxdb.Field = "rawdata"
)

const (
	NamespaceName        influxdb.Tag   = "name"
	NamespaceClusterName influxdb.Tag   = "cluster_name"
	NamespaceUid         influxdb.Tag   = "uid"
	NamespaceValue       influxdb.Field = "value"
)

const (
	NodeName        influxdb.Tag = "name" // NodeName is the name of node
	NodeClusterName influxdb.Tag = "cluster_name"
	NodeUid         influxdb.Tag = "uid"

	NodeCreateTime     influxdb.Field = "create_time"
	NodeCPUCores       influxdb.Field = "node_cpu_cores"    // NodeCPUCores is the amount of cores in node
	NodeMemoryBytes    influxdb.Field = "node_memory_bytes" // NodeMemoryBytes is the amount of memory bytes in node
	NodeNetworkMbps    influxdb.Field = "node_network_mbps" // NodeNetworkMbps is mega bits per second
	NodeIOProvider     influxdb.Field = "io_provider"       // Cloud service provider
	NodeIOInstanceType influxdb.Field = "io_instance_type"
	NodeIORegion       influxdb.Field = "io_region"
	NodeIOZone         influxdb.Field = "io_zone"
	NodeIOOS           influxdb.Field = "io_os"
	NodeIORole         influxdb.Field = "io_role"
	NodeIOInstanceID   influxdb.Field = "io_instance_id"
	NodeIOStorageSize  influxdb.Field = "io_storage_size"
)

const (
	PodName                         influxdb.Tag = "name"
	PodNamespace                    influxdb.Tag = "namespace"
	PodNodeName                     influxdb.Tag = "node_name"
	PodClusterName                  influxdb.Tag = "cluster_name"
	PodUid                          influxdb.Tag = "uid"
	PodTopControllerName            influxdb.Tag = "top_controller_name"
	PodTopControllerKind            influxdb.Tag = "top_controller_kind"
	PodAlamedaSpecScalerName        influxdb.Tag = "alameda_scaler_name"
	PodAlamedaSpecScalerNamespace   influxdb.Tag = "alameda_scaler_namespace"
	PodAlamedaSpecScalerScalingTool influxdb.Tag = "alameda_scaler_scaling_tool"
	PodAppName                      influxdb.Tag = "app_name"
	PodAppPartOf                    influxdb.Tag = "app_part_of"

	PodCreateTime                       influxdb.Field = "pod_create_time"
	PodResourceLink                     influxdb.Field = "resource_link"
	PodTopControllerReplicas            influxdb.Field = "top_controller_replicas"
	PodStatusPhase                      influxdb.Field = "pod_phase"
	PodStatusMessage                    influxdb.Field = "pod_message"
	PodStatusReason                     influxdb.Field = "pod_reason"
	PodAlamedaSpecPolicy                influxdb.Field = "policy"
	PodAlamedaSpecUsedRecommendationID  influxdb.Field = "used_recommendation_id"
	PodAlamedaSpecResourceLimitCPU      influxdb.Field = "alameda_scaler_resource_limit_cpu"
	PodAlamedaSpecResourceLimitMemory   influxdb.Field = "alameda_scaler_resource_limit_memory"
	PodAlamedaSpecResourceRequestCPU    influxdb.Field = "alameda_scaler_resource_request_cpu"
	PodAlamedaSpecResourceRequestMemory influxdb.Field = "alameda_scaler_resource_request_memory"
)

Variables

var (
	ApplicationTags = []influxdb.Tag{
		ApplicationName,
		ApplicationNamespace,
		ApplicationClusterName,
		ApplicationUid,
	}

	ApplicationFields = []influxdb.Field{
		ApplicationDummy,
	}

	ApplicationColumns = []string{
		string(ApplicationName),
		string(ApplicationNamespace),
		string(ApplicationClusterName),
		string(ApplicationUid),
		string(ApplicationDummy),
	}
)

var (
	ClusterTags = []influxdb.Tag{
		ClusterName,
		ClusterUid,
	}

	ClusterFields = []influxdb.Field{
		ClusterValue,
	}

	ClusterColumns = []string{
		string(ClusterName),
		string(ClusterUid),
		string(ClusterValue),
	}
)

var (
	// ContainerTags is the list of container measurement tags
	ContainerTags = []influxdb.Tag{
		ContainerName,
		ContainerPodName,
		ContainerNamespace,
		ContainerNodeName,
		ContainerClusterName,
		ContainerUid,
		ContainerTopControllerName,
		ContainerTopControllerKind,
		ContainerAlamedaScalerName,
		ContainerAlamedaScalerNamespace,
		ContainerAlamedaScalerScalingTool,
	}

	// ContainerFields is the list of container measurement fields
	ContainerFields = []influxdb.Field{
		ContainerResourceRequestCPU,
		ContainerResourceRequestMemory,
		ContainerResourceLimitCPU,
		ContainerResourceLimitMemory,
		ContainerStatusWaitingReason,
		ContainerStatusWaitingMessage,
		ContainerStatusRunningStartedAt,
		ContainerStatusTerminatedExitCode,
		ContainerStatusTerminatedReason,
		ContainerStatusTerminatedMessage,
		ContainerStatusTerminatedStartedAt,
		ContainerStatusTerminatedFinishedAt,
		ContainerLastTerminationWaitingReason,
		ContainerLastTerminationWaitingMessage,
		ContainerLastTerminationRunningStartedAt,
		ContainerLastTerminationTerminatedExitCode,
		ContainerLastTerminationTerminatedReason,
		ContainerLastTerminationTerminatedMessage,
		ContainerLastTerminationTerminatedStartedAt,
		ContainerLastTerminationTerminatedFinishedAt,
		ContainerRestartCount,
	}
)

var (
	// ControllerTags is list of tags of alameda_controller_recommendation measurement
	ControllerTags = []influxdb.Tag{
		ControllerName,
		ControllerNamespace,
		ControllerClusterName,
		ControllerUid,
		ControllerKind,
		ControllerAlamedaSpecScalerName,
		ControllerAlamedaSpecScalerNamespace,
		ControllerAlamedaSpecScalerScalingTool,
	}

	// ControllerFields is list of fields of alameda_controller_recommendation measurement
	ControllerFields = []influxdb.Field{
		ControllerReplicas,
		ControllerSpecReplicas,
		ControllerAlamedaSpecPolicy,
		ControllerMinReplicas,
		ControllerMaxReplicas,
		ControllerAlamedaSpecEnableExecution,
	}

	ControllerColumns = []string{
		string(ControllerName),
		string(ControllerNamespace),
		string(ControllerClusterName),
		string(ControllerUid),
		string(ControllerKind),
		string(ControllerAlamedaSpecScalerName),
		string(ControllerAlamedaSpecScalerNamespace),
		string(ControllerAlamedaSpecScalerScalingTool),
		string(ControllerReplicas),
		string(ControllerSpecReplicas),
		string(ControllerAlamedaSpecPolicy),
		string(ControllerMinReplicas),
		string(ControllerMaxReplicas),
		string(ControllerAlamedaSpecEnableExecution),
	}
)

var (
	// List of tags of keycode measurement
	KeycodeTags = []influxdb.Tag{
		Keycode,
	}
	// List of fields of keycode measurement
	KeycodeFields = []influxdb.Field{
		KeycodeStatus,
		KeycodeType,
		KeycodeState,
		KeycodeRegistered,
		KeycodeExpireTimestamp,
		KeycodeRawdata,
	}
)

var (
	NamespaceTags = []influxdb.Tag{
		NamespaceName,
		NamespaceClusterName,
		NamespaceUid,
	}

	NamespaceFields = []influxdb.Field{
		NamespaceValue,
	}

	NamespaceColumns = []string{
		string(NamespaceName),
		string(NamespaceClusterName),
		string(NamespaceUid),
		string(NamespaceValue),
	}
)

var (
	// NodeTags list tags of node measurement
	NodeTags = []influxdb.Tag{
		NodeName,
		NodeClusterName,
		NodeUid,
	}

	// NodeFields list fields of node measurement
	NodeFields = []influxdb.Field{
		NodeCreateTime,
		NodeCPUCores,
		NodeMemoryBytes,
		NodeNetworkMbps,
		NodeIOProvider,
		NodeIOInstanceType,
		NodeIORegion,
		NodeIOZone,
		NodeIOOS,
		NodeIORole,
		NodeIOInstanceID,
		NodeIOStorageSize,
	}
)

var (
	PodTags = []influxdb.Tag{
		PodName,
		PodNamespace,
		PodNodeName,
		PodClusterName,
		PodUid,
		PodTopControllerName,
		PodTopControllerKind,
		PodAlamedaSpecScalerName,
		PodAlamedaSpecScalerNamespace,
		PodAlamedaSpecScalerScalingTool,
		PodAppName,
		PodAppPartOf,
	}

	PodFields = []influxdb.Field{
		PodCreateTime,
		PodResourceLink,
		PodTopControllerReplicas,
		PodStatusPhase,
		PodStatusMessage,
		PodStatusReason,
		PodAlamedaSpecPolicy,
		PodAlamedaSpecUsedRecommendationID,
		PodAlamedaSpecResourceLimitCPU,
		PodAlamedaSpecResourceLimitMemory,
		PodAlamedaSpecResourceRequestCPU,
		PodAlamedaSpecResourceRequestMemory,
	}
)

Types

type ApplicationEntity

type ApplicationEntity struct {
	// InfluxDB tags
	Time        time.Time
	Name        string
	Namespace   string
	ClusterName string
	Uid         string

	// InfluxDB fields
	Dummy string
}

func NewApplicationEntity

func NewApplicationEntity(data map[string]string) *ApplicationEntity

func (*ApplicationEntity) BuildInfluxPoint

func (p *ApplicationEntity) BuildInfluxPoint(measurement string) (*InfluxClient.Point, error)

type ClusterEntity

type ClusterEntity struct {
	Time  time.Time
	Name  string
	Uid   string
	Value string
}

func NewClusterEntity

func NewClusterEntity(data map[string]string) *ClusterEntity

func (*ClusterEntity) BuildInfluxPoint

func (p *ClusterEntity) BuildInfluxPoint(measurement string) (*InfluxClient.Point, error)

type ContainerEntity

type ContainerEntity struct {
	Time                     time.Time
	Name                     string
	PodName                  string
	Namespace                string
	NodeName                 string
	ClusterName              string
	Uid                      string
	TopControllerName        string
	TopControllerKind        string
	AlamedaScalerName        string
	AlamedaScalerNamespace   string
	AlamedaScalerScalingTool string

	ResourceRequestCPU                  string // TODO: check if type string or float64
	ResourceRequestMemory               string // TODO: check if type string or float64
	ResourceLimitCPU                    string // TODO: check if type string or float64
	ResourceLimitMemory                 string // TODO: check if type string or float64
	StatusWaitingReason                 string
	StatusWaitingMessage                string
	StatusRunningStartedAt              int64
	StatusTerminatedExitCode            int32
	StatusTerminatedReason              string
	StatusTerminatedMessage             string
	StatusTerminatedStartedAt           int64
	StatusTerminatedFinishedAt          int64
	LastTerminationWaitingReason        string
	LastTerminationWaitingMessage       string
	LastTerminationRunningStartedAt     int64
	LastTerminationTerminatedExitCode   int32
	LastTerminationTerminatedReason     string
	LastTerminationTerminatedMessage    string
	LastTerminationTerminatedStartedAt  int64
	LastTerminationTerminatedFinishedAt int64
	RestartCount                        int32
}

ContainerEntity Entity in database

func NewContainerEntity

func NewContainerEntity(data map[string]string) *ContainerEntity

NewContainerEntityFromMap Build entity from map

func (*ContainerEntity) BuildInfluxPoint

func (p *ContainerEntity) BuildInfluxPoint(measurement string) (*InfluxClient.Point, error)

type ControllerEntity

type ControllerEntity struct {
	// InfluxDB tags
	Time                       time.Time
	Name                       string
	Namespace                  string
	ClusterName                string
	Uid                        string
	Kind                       string
	AlamedaSpecScalerName      string
	AlamedaSpecScalerNamespace string
	AlamedaSpecScalingTool     string

	// InfluxDB fields
	Replicas                   int32
	SpecReplicas               int32
	MinReplicas                int32
	MaxReplicas                int32
	AlamedaSpecPolicy          string
	AlamedaSpecEnableExecution bool
}

func NewControllerEntity

func NewControllerEntity(data map[string]string) *ControllerEntity

func (*ControllerEntity) BuildInfluxPoint

func (p *ControllerEntity) BuildInfluxPoint(measurement string) (*InfluxClient.Point, error)

type NamespaceEntity

type NamespaceEntity struct {
	// InfluxDB tags
	Time        time.Time
	Name        string
	ClusterName string
	Uid         string

	// InfluxDB fields
	Value string
}

func NewNamespaceEntity

func NewNamespaceEntity(data map[string]string) *NamespaceEntity

func (*NamespaceEntity) BuildInfluxPoint

func (p *NamespaceEntity) BuildInfluxPoint(measurement string) (*InfluxClient.Point, error)

type NodeEntity

type NodeEntity struct {
	Time        time.Time
	Name        string
	ClusterName string
	Uid         string

	CreateTime     int64
	CPUCores       int64
	MemoryBytes    int64
	NetworkMbps    int64
	IOProvider     string
	IOInstanceType string
	IORegion       string
	IOZone         string
	IOOS           string
	IORole         string
	IOInstanceID   string
	IOStorageSize  int64
}

NodeEntity is entity in database

func NewNodeEntity

func NewNodeEntity(data map[string]string) *NodeEntity

NewNodeEntityFromMap Build entity from map

func (*NodeEntity) BuildInfluxPoint

func (p *NodeEntity) BuildInfluxPoint(measurement string) (*InfluxClient.Point, error)

type PodEntity

type PodEntity struct {
	Time                         time.Time
	Name                         string
	Namespace                    string
	NodeName                     string
	ClusterName                  string
	Uid                          string
	TopControllerName            string
	TopControllerKind            string
	AlamedaSpecScalerName        string
	AlamedaSpecScalerNamespace   string
	AlamedaSpecScalerScalingTool string
	AppName                      string
	AppPartOf                    string

	CreateTime                       int64
	ResourceLink                     string
	TopControllerReplicas            int32
	StatusPhase                      string
	StatusMessage                    string
	StatusReason                     string
	AlamedaSpecPolicy                string
	AlamedaSpecUsedRecommendationID  string
	AlamedaSpecResourceLimitCPU      string // TODO: check if type string or float64
	AlamedaSpecResourceLimitMemory   string // TODO: check if type string or float64
	AlamedaSpecResourceRequestCPU    string // TODO: check if type string or float64
	AlamedaSpecResourceRequestMemory string // TODO: check if type string or float64
}

func NewPodEntity

func NewPodEntity(data map[string]string) *PodEntity

func (*PodEntity) BuildInfluxPoint

func (p *PodEntity) BuildInfluxPoint(measurement string) (*InfluxClient.Point, error)