Documentation ¶
Index ¶
- type Config
- type Server
- func (s *Server) CreateAlamedaNodes(ctx context.Context, in *datahub_v1alpha1.CreateAlamedaNodesRequest) (*status.Status, error)
- func (s *Server) CreateControllerRecommendations(ctx context.Context, ...) (*status.Status, error)
- func (s *Server) CreateControllers(ctx context.Context, in *datahub_v1alpha1.CreateControllersRequest) (*status.Status, error)
- func (s *Server) CreateNodePredictions(ctx context.Context, in *datahub_v1alpha1.CreateNodePredictionsRequest) (*status.Status, error)
- func (s *Server) CreatePodPredictions(ctx context.Context, in *datahub_v1alpha1.CreatePodPredictionsRequest) (*status.Status, error)
- func (s *Server) CreatePodRecommendations(ctx context.Context, in *datahub_v1alpha1.CreatePodRecommendationsRequest) (*status.Status, error)
- func (s *Server) CreatePods(ctx context.Context, in *datahub_v1alpha1.CreatePodsRequest) (*status.Status, error)
- func (s *Server) CreateSimulatedSchedulingScores(ctx context.Context, ...) (*status.Status, error)
- func (s *Server) DeleteAlamedaNodes(ctx context.Context, in *datahub_v1alpha1.DeleteAlamedaNodesRequest) (*status.Status, error)
- func (s *Server) DeleteControllers(ctx context.Context, in *datahub_v1alpha1.DeleteControllersRequest) (*status.Status, error)
- func (s *Server) DeletePods(ctx context.Context, in *datahub_v1alpha1.DeletePodsRequest) (*status.Status, error)
- func (s *Server) Err() <-chan error
- func (s *Server) GetWeaveScopeContainerDetails(ctx context.Context, in *datahub_v1alpha1.ListWeaveScopeContainersRequest) (*datahub_v1alpha1.WeaveScopeResponse, error)
- func (s *Server) GetWeaveScopeHostDetails(ctx context.Context, in *datahub_v1alpha1.ListWeaveScopeHostsRequest) (*datahub_v1alpha1.WeaveScopeResponse, error)
- func (s *Server) GetWeaveScopePodDetails(ctx context.Context, in *datahub_v1alpha1.ListWeaveScopePodsRequest) (*datahub_v1alpha1.WeaveScopeResponse, error)
- func (s *Server) InitInfluxdbDatabase()
- func (s *Server) ListAlamedaNodes(ctx context.Context, in *datahub_v1alpha1.ListAlamedaNodesRequest) (*datahub_v1alpha1.ListNodesResponse, error)
- func (s *Server) ListAlamedaPods(ctx context.Context, in *datahub_v1alpha1.ListAlamedaPodsRequest) (*datahub_v1alpha1.ListPodsResponse, error)
- func (s *Server) ListAvailablePodRecommendations(ctx context.Context, in *datahub_v1alpha1.ListPodRecommendationsRequest) (*datahub_v1alpha1.ListPodRecommendationsResponse, error)
- func (s *Server) ListControllerRecommendations(ctx context.Context, in *datahub_v1alpha1.ListControllerRecommendationsRequest) (*datahub_v1alpha1.ListControllerRecommendationsResponse, error)
- func (s *Server) ListControllers(ctx context.Context, in *datahub_v1alpha1.ListControllersRequest) (*datahub_v1alpha1.ListControllersResponse, error)
- func (s *Server) ListNodeMetrics(ctx context.Context, in *datahub_v1alpha1.ListNodeMetricsRequest) (*datahub_v1alpha1.ListNodeMetricsResponse, error)
- func (s *Server) ListNodePredictions(ctx context.Context, in *datahub_v1alpha1.ListNodePredictionsRequest) (*datahub_v1alpha1.ListNodePredictionsResponse, error)
- func (s *Server) ListNodes(ctx context.Context, in *datahub_v1alpha1.ListNodesRequest) (*datahub_v1alpha1.ListNodesResponse, error)
- func (s *Server) ListPodMetrics(ctx context.Context, in *datahub_v1alpha1.ListPodMetricsRequest) (*datahub_v1alpha1.ListPodMetricsResponse, error)
- func (s *Server) ListPodMetricsDemo(ctx context.Context, in *datahub_v1alpha1.ListPodMetricsRequest) (*datahub_v1alpha1.ListPodMetricsResponse, error)
- func (s *Server) ListPodPredictions(ctx context.Context, in *datahub_v1alpha1.ListPodPredictionsRequest) (*datahub_v1alpha1.ListPodPredictionsResponse, error)
- func (s *Server) ListPodPredictionsDemo(ctx context.Context, in *datahub_v1alpha1.ListPodPredictionsRequest) (*datahub_v1alpha1.ListPodPredictionsResponse, error)
- func (s *Server) ListPodRecommendations(ctx context.Context, in *datahub_v1alpha1.ListPodRecommendationsRequest) (*datahub_v1alpha1.ListPodRecommendationsResponse, error)
- func (s *Server) ListPodsByNodeName(ctx context.Context, in *datahub_v1alpha1.ListPodsByNodeNamesRequest) (*datahub_v1alpha1.ListPodsResponse, error)
- func (s *Server) ListSimulatedSchedulingScores(ctx context.Context, in *datahub_v1alpha1.ListSimulatedSchedulingScoresRequest) (*datahub_v1alpha1.ListSimulatedSchedulingScoresResponse, error)
- func (s *Server) ListWeaveScopeContainers(ctx context.Context, in *datahub_v1alpha1.ListWeaveScopeContainersRequest) (*datahub_v1alpha1.WeaveScopeResponse, error)
- func (s *Server) ListWeaveScopeContainersByHostname(ctx context.Context, in *datahub_v1alpha1.ListWeaveScopeContainersRequest) (*datahub_v1alpha1.WeaveScopeResponse, error)
- func (s *Server) ListWeaveScopeContainersByImage(ctx context.Context, in *datahub_v1alpha1.ListWeaveScopeContainersRequest) (*datahub_v1alpha1.WeaveScopeResponse, error)
- func (s *Server) ListWeaveScopeHosts(ctx context.Context, in *datahub_v1alpha1.ListWeaveScopeHostsRequest) (*datahub_v1alpha1.WeaveScopeResponse, error)
- func (s *Server) ListWeaveScopePods(ctx context.Context, in *datahub_v1alpha1.ListWeaveScopePodsRequest) (*datahub_v1alpha1.WeaveScopeResponse, error)
- func (s *Server) Run() error
- func (s *Server) Stop() error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct { BindAddress string `mapstructure:"bind-address"` Prometheus *prometheus.Config `mapstructure:"prometheus"` InfluxDB *influxdb_repository.Config `mapstructure:"influxdb"` WeaveScope *weavescope.Config `mapstructure:"weavescope"` Log *log.Config `mapstructure:"log"` }
func NewDefaultConfig ¶
func NewDefaultConfig() Config
type Server ¶
type Server struct { Config Config K8SClient client.Client // contains filtered or unexported fields }
func (*Server) CreateAlamedaNodes ¶
func (s *Server) CreateAlamedaNodes(ctx context.Context, in *datahub_v1alpha1.CreateAlamedaNodesRequest) (*status.Status, error)
CreateAlamedaNodes add node information to database
func (*Server) CreateControllerRecommendations ¶ added in v0.3.8
func (s *Server) CreateControllerRecommendations(ctx context.Context, in *datahub_v1alpha1.CreateControllerRecommendationsRequest) (*status.Status, error)
CreatePodRecommendations add pod recommendations information to database
func (*Server) CreateControllers ¶ added in v0.3.9
func (s *Server) CreateControllers(ctx context.Context, in *datahub_v1alpha1.CreateControllersRequest) (*status.Status, error)
func (*Server) CreateNodePredictions ¶
func (s *Server) CreateNodePredictions(ctx context.Context, in *datahub_v1alpha1.CreateNodePredictionsRequest) (*status.Status, error)
CreateNodePredictions add node predictions information to database
func (*Server) CreatePodPredictions ¶
func (s *Server) CreatePodPredictions(ctx context.Context, in *datahub_v1alpha1.CreatePodPredictionsRequest) (*status.Status, error)
CreatePodPredictions add pod predictions information to database
func (*Server) CreatePodRecommendations ¶
func (s *Server) CreatePodRecommendations(ctx context.Context, in *datahub_v1alpha1.CreatePodRecommendationsRequest) (*status.Status, error)
CreatePodRecommendations add pod recommendations information to database
func (*Server) CreatePods ¶
func (s *Server) CreatePods(ctx context.Context, in *datahub_v1alpha1.CreatePodsRequest) (*status.Status, error)
CreatePods add containers information of pods to database
func (*Server) CreateSimulatedSchedulingScores ¶
func (s *Server) CreateSimulatedSchedulingScores(ctx context.Context, in *datahub_v1alpha1.CreateSimulatedSchedulingScoresRequest) (*status.Status, error)
CreateSimulatedSchedulingScores add simulated scheduling scores to database
func (*Server) DeleteAlamedaNodes ¶
func (s *Server) DeleteAlamedaNodes(ctx context.Context, in *datahub_v1alpha1.DeleteAlamedaNodesRequest) (*status.Status, error)
DeleteAlamedaNodes remove node information to database
func (*Server) DeleteControllers ¶ added in v0.3.11
func (s *Server) DeleteControllers(ctx context.Context, in *datahub_v1alpha1.DeleteControllersRequest) (*status.Status, error)
func (*Server) DeletePods ¶
func (s *Server) DeletePods(ctx context.Context, in *datahub_v1alpha1.DeletePodsRequest) (*status.Status, error)
DeletePods update containers information of pods to database
func (*Server) GetWeaveScopeContainerDetails ¶ added in v0.3.21
func (s *Server) GetWeaveScopeContainerDetails(ctx context.Context, in *datahub_v1alpha1.ListWeaveScopeContainersRequest) (*datahub_v1alpha1.WeaveScopeResponse, error)
func (*Server) GetWeaveScopeHostDetails ¶ added in v0.3.21
func (s *Server) GetWeaveScopeHostDetails(ctx context.Context, in *datahub_v1alpha1.ListWeaveScopeHostsRequest) (*datahub_v1alpha1.WeaveScopeResponse, error)
func (*Server) GetWeaveScopePodDetails ¶ added in v0.3.21
func (s *Server) GetWeaveScopePodDetails(ctx context.Context, in *datahub_v1alpha1.ListWeaveScopePodsRequest) (*datahub_v1alpha1.WeaveScopeResponse, error)
func (*Server) InitInfluxdbDatabase ¶ added in v0.3.8
func (s *Server) InitInfluxdbDatabase()
func (*Server) ListAlamedaNodes ¶
func (s *Server) ListAlamedaNodes(ctx context.Context, in *datahub_v1alpha1.ListAlamedaNodesRequest) (*datahub_v1alpha1.ListNodesResponse, error)
ListAlamedaNodes list nodes in cluster
func (*Server) ListAlamedaPods ¶
func (s *Server) ListAlamedaPods(ctx context.Context, in *datahub_v1alpha1.ListAlamedaPodsRequest) (*datahub_v1alpha1.ListPodsResponse, error)
ListAlamedaPods returns predicted pods
func (*Server) ListAvailablePodRecommendations ¶ added in v0.3.8
func (s *Server) ListAvailablePodRecommendations(ctx context.Context, in *datahub_v1alpha1.ListPodRecommendationsRequest) (*datahub_v1alpha1.ListPodRecommendationsResponse, error)
ListAvailablePodRecommendations list pod recommendations
func (*Server) ListControllerRecommendations ¶ added in v0.3.8
func (s *Server) ListControllerRecommendations(ctx context.Context, in *datahub_v1alpha1.ListControllerRecommendationsRequest) (*datahub_v1alpha1.ListControllerRecommendationsResponse, error)
ListControllerRecommendations list controller recommendations
func (*Server) ListControllers ¶ added in v0.3.9
func (s *Server) ListControllers(ctx context.Context, in *datahub_v1alpha1.ListControllersRequest) (*datahub_v1alpha1.ListControllersResponse, error)
func (*Server) ListNodeMetrics ¶
func (s *Server) ListNodeMetrics(ctx context.Context, in *datahub_v1alpha1.ListNodeMetricsRequest) (*datahub_v1alpha1.ListNodeMetricsResponse, error)
ListNodeMetrics list nodes' metrics
func (*Server) ListNodePredictions ¶
func (s *Server) ListNodePredictions(ctx context.Context, in *datahub_v1alpha1.ListNodePredictionsRequest) (*datahub_v1alpha1.ListNodePredictionsResponse, error)
ListNodePredictions list nodes' predictions
func (*Server) ListNodes ¶ added in v0.3.0
func (s *Server) ListNodes(ctx context.Context, in *datahub_v1alpha1.ListNodesRequest) (*datahub_v1alpha1.ListNodesResponse, error)
func (*Server) ListPodMetrics ¶
func (s *Server) ListPodMetrics(ctx context.Context, in *datahub_v1alpha1.ListPodMetricsRequest) (*datahub_v1alpha1.ListPodMetricsResponse, error)
ListPodMetrics list pods' metrics
func (*Server) ListPodMetricsDemo ¶ added in v0.3.8
func (s *Server) ListPodMetricsDemo(ctx context.Context, in *datahub_v1alpha1.ListPodMetricsRequest) (*datahub_v1alpha1.ListPodMetricsResponse, error)
ListPodMetrics list pods' metrics for demo
func (*Server) ListPodPredictions ¶
func (s *Server) ListPodPredictions(ctx context.Context, in *datahub_v1alpha1.ListPodPredictionsRequest) (*datahub_v1alpha1.ListPodPredictionsResponse, error)
ListPodPredictions list pods' predictions
func (*Server) ListPodPredictionsDemo ¶ added in v0.3.8
func (s *Server) ListPodPredictionsDemo(ctx context.Context, in *datahub_v1alpha1.ListPodPredictionsRequest) (*datahub_v1alpha1.ListPodPredictionsResponse, error)
ListPodPredictions list pods' predictions for demo
func (*Server) ListPodRecommendations ¶
func (s *Server) ListPodRecommendations(ctx context.Context, in *datahub_v1alpha1.ListPodRecommendationsRequest) (*datahub_v1alpha1.ListPodRecommendationsResponse, error)
ListPodRecommendations list pod recommendations
func (*Server) ListPodsByNodeName ¶
func (s *Server) ListPodsByNodeName(ctx context.Context, in *datahub_v1alpha1.ListPodsByNodeNamesRequest) (*datahub_v1alpha1.ListPodsResponse, error)
ListPodsByNodeName list pods running on specific nodes
func (*Server) ListSimulatedSchedulingScores ¶
func (s *Server) ListSimulatedSchedulingScores(ctx context.Context, in *datahub_v1alpha1.ListSimulatedSchedulingScoresRequest) (*datahub_v1alpha1.ListSimulatedSchedulingScoresResponse, error)
ListSimulatedSchedulingScores list simulated scheduling scores
func (*Server) ListWeaveScopeContainers ¶ added in v0.3.21
func (s *Server) ListWeaveScopeContainers(ctx context.Context, in *datahub_v1alpha1.ListWeaveScopeContainersRequest) (*datahub_v1alpha1.WeaveScopeResponse, error)
func (*Server) ListWeaveScopeContainersByHostname ¶ added in v0.3.21
func (s *Server) ListWeaveScopeContainersByHostname(ctx context.Context, in *datahub_v1alpha1.ListWeaveScopeContainersRequest) (*datahub_v1alpha1.WeaveScopeResponse, error)
func (*Server) ListWeaveScopeContainersByImage ¶ added in v0.3.21
func (s *Server) ListWeaveScopeContainersByImage(ctx context.Context, in *datahub_v1alpha1.ListWeaveScopeContainersRequest) (*datahub_v1alpha1.WeaveScopeResponse, error)
func (*Server) ListWeaveScopeHosts ¶ added in v0.3.21
func (s *Server) ListWeaveScopeHosts(ctx context.Context, in *datahub_v1alpha1.ListWeaveScopeHostsRequest) (*datahub_v1alpha1.WeaveScopeResponse, error)
func (*Server) ListWeaveScopePods ¶ added in v0.3.21
func (s *Server) ListWeaveScopePods(ctx context.Context, in *datahub_v1alpha1.ListWeaveScopePodsRequest) (*datahub_v1alpha1.WeaveScopeResponse, error)