datahub

Documentation

Index

• type Config
  • func NewDefaultConfig() Config
  • func (c *Config) Validate() error
• type Server
  • func NewServer(cfg Config) (*Server, error)
  • func (s *Server) CreateAlamedaNodes(ctx context.Context, in *datahub_v1alpha1.CreateAlamedaNodesRequest) (*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) DeletePods(ctx context.Context, in *datahub_v1alpha1.DeletePodsRequest) (*status.Status, error)
  • func (s *Server) Err() <-chan error
  • func (s *Server) ListAlamedaNodes(ctx context.Context, in *empty.Empty) (*datahub_v1alpha1.ListNodesResponse, error)
  • func (s *Server) ListAlamedaPods(ctx context.Context, in *datahub_v1alpha1.ListAlamedaPodsRequest) (*datahub_v1alpha1.ListPodsResponse, 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) ListPodPredictions(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) Run() error
  • func (s *Server) Stop() error

Types

type Config

type Config struct {
	BindAddress string                      `mapstructure:"bind-address"`
	Prometheus  *prometheus.Config          `mapstructure:"prometheus"`
	InfluxDB    *influxdb_repository.Config `mapstructure:"influxdb"`
	Log         *log.Config                 `mapstructure:"log"`
}

func NewDefaultConfig

func NewDefaultConfig() Config

func (*Config) Validate

func (c *Config) Validate() error

type Server

type Server struct {
	Config    Config
	K8SClient client.Client
	// contains filtered or unexported fields
}

func NewServer

func NewServer(cfg Config) (*Server, error)

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) 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) 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) Err

func (s *Server) Err() <-chan error

func (*Server) ListAlamedaNodes

func (s *Server) ListAlamedaNodes(ctx context.Context, in *empty.Empty) (*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) 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

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) ListPodPredictions

func (s *Server) ListPodPredictions(ctx context.Context, in *datahub_v1alpha1.ListPodPredictionsRequest) (*datahub_v1alpha1.ListPodPredictionsResponse, error)

ListPodPredictions list pods' predictions

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) Run

func (s *Server) Run() error

func (*Server) Stop

func (s *Server) Stop() error