Versions in this module Expand all Collapse all v1 v1.0.1 Aug 15, 2024 Changes in this version + const InstancePhaseDead + const InstancePhaseHealthy + const InstancePhaseRunning + const InstancePhaseUnHealthy + const PodPhaseFailed + const PodPhasePending + const PodPhaseRunning + const PodPhaseSucceeded + const PodPhaseUnknown + const ServicePhaseHealthy + const ServicePhaseUnHealthy + type AddonPrebuild struct + AddonName string + ApplicationID string + BuildFrom int + Config string + CreatedAt time.Time + DeleteStatus int + Deleted string + Env string + GitBranch string + ID uint64 + InstanceID string + InstanceName string + Options string + Plan string + RoutingInstanceID string + RuntimeID string + UpdatedAt time.Time + func (AddonPrebuild) TableName() string + type Client struct + func New(db *dbengine.DBEngine) *Client + func (c *Client) CreateHPAEventInfo(hpaEvent dbclient.HPAEventInfo) error + func (c *Client) CreateVPARecommendation(vpaRecommendation dbclient.RuntimeVPAContainerRecommendation) error + func (c *Client) DeletedOldVPARecommendations(interval int) error + func (c *Client) GetLatestVPARecommendation(runtimeId uint64, ruleId, serviceName, containerName string) (dbclient.RuntimeVPAContainerRecommendation, error) + func (c *Client) GetRuntimeID(instanceID string) (string, error) + func (c *Client) InstanceReader() *InstanceReader + func (c *Client) InstanceWriter() *instanceWriter + func (c *Client) PodReader() *PodReader + func (c *Client) PodWriter() *podWriter + func (c *Client) ServiceReader() *ServiceReader + func (c *Client) ServiceWriter() *serviceWriter + func (c *Client) UpdateClusterInfo(clusterName, clusterInfo string) error + type ClusterInfo struct + ClusterInfo string + ClusterName string + func (ClusterInfo) TableName() string + type InstanceInfo struct + AddonID string + ApplicationID string + ApplicationName string + Cluster string + ContainerID string + ContainerIP string + CpuLimit float64 + CpuOrigin float64 + CpuRequest float64 + EdgeApplicationName string + EdgeSite string + ExitCode int + FinishedAt *time.Time + HostIP string + Image string + MemLimit int + MemOrigin int + MemRequest int + Message string + Meta string + Name string + Namespace string + OrgID string + OrgName string + Phase InstancePhase + ProjectID string + ProjectName string + RuntimeID string + RuntimeName string + ServiceName string + ServiceType string + StartedAt time.Time + TaskID string + Workspace string + func (InstanceInfo) TableName() string + func (i InstanceInfo) Metadata(k string) (string, bool) + type InstancePhase string + type InstanceReader struct + func (r *InstanceReader) ByAddonID(id string) *InstanceReader + func (r *InstanceReader) ByApplicationID(id string) *InstanceReader + func (r *InstanceReader) ByApplicationName(name string) *InstanceReader + func (r *InstanceReader) ByCluster(clustername string) *InstanceReader + func (r *InstanceReader) ByContainerID(id string) *InstanceReader + func (r *InstanceReader) ByEdgeApplicationName(name string) *InstanceReader + func (r *InstanceReader) ByEdgeSite(name string) *InstanceReader + func (r *InstanceReader) ByFinishedTime(beforeNday int) *InstanceReader + func (r *InstanceReader) ByHostIP(ips ...string) *InstanceReader + func (r *InstanceReader) ByInstanceIP(ips ...string) *InstanceReader + func (r *InstanceReader) ByMetaLike(s string) *InstanceReader + func (r *InstanceReader) ByName(name string) *InstanceReader + func (r *InstanceReader) ByNamespace(ns string) *InstanceReader + func (r *InstanceReader) ByNotTaskID(id string) *InstanceReader + func (r *InstanceReader) ByOrgID(id string) *InstanceReader + func (r *InstanceReader) ByOrgName(name string) *InstanceReader + func (r *InstanceReader) ByPhase(phase string) *InstanceReader + func (r *InstanceReader) ByPhases(phases ...string) *InstanceReader + func (r *InstanceReader) ByProjectID(id string) *InstanceReader + func (r *InstanceReader) ByProjectName(name string) *InstanceReader + func (r *InstanceReader) ByRuntimeID(id string) *InstanceReader + func (r *InstanceReader) ByRuntimeName(name string) *InstanceReader + func (r *InstanceReader) ByService(name string) *InstanceReader + func (r *InstanceReader) ByServiceType(tp string) *InstanceReader + func (r *InstanceReader) ByTaskID(id string) *InstanceReader + func (r *InstanceReader) ByUpdatedTime(beforeNSecs int) *InstanceReader + func (r *InstanceReader) ByWorkspace(ws string) *InstanceReader + func (r *InstanceReader) Do() ([]InstanceInfo, error) + func (r *InstanceReader) Limit(n int) *InstanceReader + type PodInfo struct + AddonID string + ApplicationID string + ApplicationName string + Cluster string + CpuLimit float64 + CpuRequest float64 + HostIP string + K8sNamespace string + MemLimit int + MemRequest int + Message string + Name string + Namespace string + OrgID string + OrgName string + Phase PodPhase + PodIP string + PodName string + ProjectID string + ProjectName string + RuntimeID string + RuntimeName string + ServiceName string + ServiceType string + StartedAt *time.Time + Uid string + Workspace string + func (PodInfo) TableName() string + type PodPhase string + type PodReader struct + func (r *PodReader) ByAddonID(id string) *PodReader + func (r *PodReader) ByApplicationID(id string) *PodReader + func (r *PodReader) ByApplicationName(name string) *PodReader + func (r *PodReader) ByCluster(clustername string) *PodReader + func (r *PodReader) ByK8SNamespace(namespace string) *PodReader + func (r *PodReader) ByName(name string) *PodReader + func (r *PodReader) ByNamespace(ns string) *PodReader + func (r *PodReader) ByOrgID(id string) *PodReader + func (r *PodReader) ByOrgName(name string) *PodReader + func (r *PodReader) ByPhase(phase string) *PodReader + func (r *PodReader) ByPhases(phases ...string) *PodReader + func (r *PodReader) ByPodName(podname string) *PodReader + func (r *PodReader) ByProjectID(id string) *PodReader + func (r *PodReader) ByProjectName(name string) *PodReader + func (r *PodReader) ByRuntimeID(id string) *PodReader + func (r *PodReader) ByRuntimeName(name string) *PodReader + func (r *PodReader) ByService(name string) *PodReader + func (r *PodReader) ByServiceType(tp string) *PodReader + func (r *PodReader) ByUid(uid string) *PodReader + func (r *PodReader) ByUpdatedTime(beforeNSecs int) *PodReader + func (r *PodReader) ByWorkspace(ws string) *PodReader + func (r *PodReader) Do() ([]PodInfo, error) + func (r *PodReader) Limit(n int) *PodReader + type ServiceInfo struct + ApplicationID string + ApplicationName string + Cluster string + FinishedAt *time.Time + Message string + Meta string + Name string + Namespace string + OrgID string + OrgName string + Phase ServicePhase + ProjectID string + ProjectName string + RuntimeID string + RuntimeName string + ServiceName string + ServiceType string + StartedAt time.Time + Workspace string + func (ServiceInfo) TableName() string + type ServicePhase string + type ServiceReader struct + func (r *ServiceReader) ByApplicationID(id string) *ServiceReader + func (r *ServiceReader) ByApplicationName(name string) *ServiceReader + func (r *ServiceReader) ByName(name string) *ServiceReader + func (r *ServiceReader) ByNamespace(ns string) *ServiceReader + func (r *ServiceReader) ByOrgID(id string) *ServiceReader + func (r *ServiceReader) ByOrgName(name string) *ServiceReader + func (r *ServiceReader) ByProjectID(id string) *ServiceReader + func (r *ServiceReader) ByProjectName(name string) *ServiceReader + func (r *ServiceReader) ByRuntimeID(id string) *ServiceReader + func (r *ServiceReader) ByRuntimeName(name string) *ServiceReader + func (r *ServiceReader) ByService(name string) *ServiceReader + func (r *ServiceReader) ByServiceType(tp string) *ServiceReader + func (r *ServiceReader) ByWorkspace(ws string) *ServiceReader + func (r *ServiceReader) Do() ([]ServiceInfo, error)