datahub

package
v4.2.160+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 26, 2019 License: Apache-2.0 Imports: 46 Imported by: 0

Documentation

Index

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

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

func (s *Server) CreateControllerPlannings(ctx context.Context, in *datahub_v1alpha1.CreateControllerPlanningsRequest) (*status.Status, error)

CreateControllerPlannings add controller plannings 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) CreatePodPlannings 

func (s *Server) CreatePodPlannings(ctx context.Context, in *datahub_v1alpha1.CreatePodPlanningsRequest) (*status.Status, error)

CreatePodPlannings add pod plannings 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) Err 

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

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

func (s *Server) ListControllerPlannings(ctx context.Context, in *datahub_v1alpha1.ListControllerPlanningsRequest) (*datahub_v1alpha1.ListControllerPlanningsResponse, error)

ListControllerPlannings list controller plannings

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

func (s *Server) ListPodPlannings(ctx context.Context, in *datahub_v1alpha1.ListPodPlanningsRequest) (*datahub_v1alpha1.ListPodPlanningsResponse, error)

ListPodPlannings list pod plannings

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)

func (*Server) Ping added in v0.3.50 

func (s *Server) Ping(ctx context.Context, in *empty.Empty) (*status.Status, error)

func (*Server) ReadRawdata added in v0.3.31 

func (s *Server) ReadRawdata(ctx context.Context, in *datahub_v1alpha1.ReadRawdataRequest) (*datahub_v1alpha1.ReadRawdataResponse, error)

Read rawdata from database

func (*Server) Run 

func (s *Server) Run() error

func (*Server) Stop 

func (s *Server) Stop() error

func (*Server) WriteRawdata added in v0.3.31 

func (s *Server) WriteRawdata(ctx context.Context, in *datahub_v1alpha1.WriteRawdataRequest) (*status.Status, error)

Write rawdata to database

Source Files

View all Source files

Directories

Path Synopsis
cmd
app
pkg
dao
dao/cluster_status
dao/cluster_status/impl
dao/metric
dao/metric/prometheus
dao/planning
dao/planning/impl
dao/prediction
dao/prediction/impl
dao/recommendation
dao/recommendation/impl
dao/score
dao/score/impl/influxdb
dao/weavescope
entity/influxdb/cluster_status
entity/influxdb/planning
entity/influxdb/prediction/container
entity/influxdb/prediction/node
entity/influxdb/recommendation
entity/influxdb/score
entity/influxdb/utils/enumconv
entity/prometheus/containerCPUUsagePercentage
entity/prometheus/containerMemoryUsageBytes
entity/prometheus/nodeCPUUsagePercentage
entity/prometheus/nodeMemoryAvailableBytes
entity/prometheus/nodeMemoryBytesTotal
entity/prometheus/nodeMemoryUsageBytes
entity/prometheus/nodeMemoryUtilization
kubernetes/metadata
metric
probe
repository/influxdb
repository/influxdb/cluster_status
repository/influxdb/planning
repository/influxdb/prediction
repository/influxdb/recommendation
repository/influxdb/score
repository/prometheus
repository/prometheus/metric
repository/weavescope
utils

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.