datahub

package
v4.3.1008+incompatible Latest Latest
Warning

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

 Go to latest Published: Sep 21, 2020 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var MetricTypeValue = map[string]common.MetricType{
	"undefined":                common.MetricType_METRICS_TYPE_UNDEFINED,
	"cpu_seconds_total":        common.MetricType_CPU_SECONDS_TOTAL,
	"cpu_cores_alloc":          common.MetricType_CPU_CORES_ALLOCATABLE,
	"cpu_millicores_total":     common.MetricType_CPU_MILLICORES_TOTAL,
	"cpu_millicores_avail":     common.MetricType_CPU_MILLICORES_AVAIL,
	"cpu_millicores_usage":     common.MetricType_CPU_MILLICORES_USAGE,
	"cpu_millicores_usage_pct": common.MetricType_CPU_MILLICORES_USAGE_PCT,
	"memory_bytes_alloc":       common.MetricType_MEMORY_BYTES_ALLOCATABLE,
	"memory_bytes_total":       common.MetricType_MEMORY_BYTES_TOTAL,
	"memory_bytes_avail":       common.MetricType_MEMORY_BYTES_AVAIL,
	"memory_bytes_usage":       common.MetricType_MEMORY_BYTES_USAGE,
	"memory_bytes_usage_pct":   common.MetricType_MEMORY_BYTES_USAGE_PCT,
	"fs_bytes_total":           common.MetricType_FS_BYTES_TOTAL,
	"fs_bytes_avail":           common.MetricType_FS_BYTES_AVAIL,
	"fs_bytes_usage":           common.MetricType_FS_BYTES_USAGE,
	"fs_bytes_usage_pct":       common.MetricType_FS_BYTES_USAGE_PCT,
	"http_req_count":           common.MetricType_HTTP_REQUESTS_COUNT,
	"http_req_total":           common.MetricType_HTTP_REQUESTS_TOTAL,
	"http_response_count":      common.MetricType_HTTP_RESPONSE_COUNT,
	"http_response_total":      common.MetricType_HTTP_RESPONSE_TOTAL,
	"disk_io_seconds_total":    common.MetricType_DISK_IO_SECONDS_TOTAL,
	"disk_io_util":             common.MetricType_DISK_IO_UTILIZATION,
	"restarts_total":           common.MetricType_RESTARTS_TOTAL,
	"unschedulable":            common.MetricType_UNSCHEDULABLE,
	"health":                   common.MetricType_HEALTH,
	"power_usage_watts":        common.MetricType_POWER_USAGE_WATTS,
	"temperature_celsius":      common.MetricType_TEMPERATURE_CELSIUS,
	"duty_cycle":               common.MetricType_DUTY_CYCLE,
	"current_offset":           common.MetricType_CURRENT_OFFSET,
	"lag":                      common.MetricType_LAG,
	"latency":                  common.MetricType_LATENCY,
	"number":                   common.MetricType_NUMBER,
}
View Source 
var ResourceBoundaryValue = map[string]common.ResourceBoundary{
	"undefined":   common.ResourceBoundary_RESOURCE_BOUNDARY_UNDEFINED,
	"raw":         common.ResourceBoundary_RESOURCE_RAW,
	"upper_bound": common.ResourceBoundary_RESOURCE_UPPER_BOUND,
	"lower_bound": common.ResourceBoundary_RESOURCE_LOWER_BOUND,
}
View Source 
var ResourceQuotaValue = map[string]common.ResourceQuota{
	"undefined":       common.ResourceQuota_RESOURCE_QUOTA_UNDEFINED,
	"limit":           common.ResourceQuota_RESOURCE_LIMIT,
	"request":         common.ResourceQuota_RESOURCE_REQUEST,
	"initial_limit":   common.ResourceQuota_RESOURCE_INITIAL_LIMIT,
	"initial_request": common.ResourceQuota_RESOURCE_INITIAL_REQUEST,
}
View Source 
var ScopeValue = map[string]schemas.Scope{
	"undefined":      schemas.Scope_SCOPE_UNDEFINED,
	"application":    schemas.Scope_SCOPE_APPLICATION,
	"config":         schemas.Scope_SCOPE_CONFIG,
	"fedemeter":      schemas.Scope_SCOPE_FEDEMETER,
	"metering":       schemas.Scope_SCOPE_METERING,
	"metric":         schemas.Scope_SCOPE_METRIC,
	"planning":       schemas.Scope_SCOPE_PLANNING,
	"prediction":     schemas.Scope_SCOPE_PREDICTION,
	"recommendation": schemas.Scope_SCOPE_RECOMMENDATION,
	"resource":       schemas.Scope_SCOPE_RESOURCE,
	"target":         schemas.Scope_SCOPE_TARGET,
}

Functions

func DeepCopyEntity 

func DeepCopyEntity(entities interface{}, results *data.Data)

func ExtractField 

func ExtractField(entities interface{}, fieldName string) reflect.StructField

func NewColumns 

func NewColumns(entities interface{}, fields []string) []string

func NewCondition 

func NewCondition(opt Option) *common.Condition

func NewDeleteData 

func NewDeleteData(entities interface{}, opts ...Option) *data.DeleteData

func NewDeleteDataRequest 

func NewDeleteDataRequest(entities interface{}, opts ...Option) *data.DeleteDataRequest

func NewFunction 

func NewFunction(function *Function) *common.Function

func NewQueryCondition 

func NewQueryCondition(selects []string, timeRange *TimeRange, function *Function, opts ...Option) *common.QueryCondition

func NewReadData 

func NewReadData(entities interface{}, fields []string, timeRange *TimeRange, function *Function, opts ...Option) *data.ReadData

func NewReadDataRequest 

func NewReadDataRequest(entities interface{}, fields []string, timeRange *TimeRange, function *Function, opts ...Option) *data.ReadDataRequest

func NewRow 

func NewRow(value reflect.Value, columns []string) *common.Row

func NewRows 

func NewRows(entities interface{}, columns []string) []*common.Row

func NewSchemaMeta 

func NewSchemaMeta(entities interface{}) *schemas.SchemaMeta

func NewTimeRange 

func NewTimeRange(tr *TimeRange) *common.TimeRange

func NewWriteData 

func NewWriteData(entities interface{}, fields []string) *data.WriteData

func NewWriteDataRequest 

func NewWriteDataRequest(entities interface{}, fields []string) *data.WriteDataRequest

Types

type Client 

type Client struct {
	datahub.DatahubServiceClient
	keycodes.KeycodesServiceClient

	RWLock  *sync.RWMutex
	Address string
	// contains filtered or unexported fields
}

func NewClient 

func NewClient(address string) *Client

func (*Client) ActivateRegistrationData 

func (p *Client) ActivateRegistrationData(request *keycodes.ActivateRegistrationDataRequest) (*status.Status, error)

func (*Client) AddKeycode 

func (p *Client) AddKeycode(request *keycodes.AddKeycodeRequest) (*keycodes.AddKeycodeResponse, error)

func (*Client) CheckConnection 

func (p *Client) CheckConnection() error

func (*Client) Close 

func (p *Client) Close() error

func (*Client) Connect 

func (p *Client) Connect(retry, timeout int) error

func (*Client) Create 

func (p *Client) Create(entities interface{}, fields ...string) error

func (*Client) CreateApplicationMetrics 

func (p *Client) CreateApplicationMetrics(request *metrics.CreateApplicationMetricsRequest) (*status.Status, error)

func (*Client) CreateApplicationPlannings 

func (p *Client) CreateApplicationPlannings(request *plannings.CreateApplicationPlanningsRequest) (*status.Status, error)

func (*Client) CreateApplicationPredictions 

func (p *Client) CreateApplicationPredictions(request *predictions.CreateApplicationPredictionsRequest) (*status.Status, error)

func (*Client) CreateApplicationRecommendations 

func (p *Client) CreateApplicationRecommendations(request *recommendations.CreateApplicationRecommendationsRequest) (*status.Status, error)

func (*Client) CreateApplications 

func (p *Client) CreateApplications(request *resources.CreateApplicationsRequest) (*status.Status, error)

func (*Client) CreateClusterMetrics 

func (p *Client) CreateClusterMetrics(request *metrics.CreateClusterMetricsRequest) (*status.Status, error)

func (*Client) CreateClusterPlannings 

func (p *Client) CreateClusterPlannings(request *plannings.CreateClusterPlanningsRequest) (*status.Status, error)

func (*Client) CreateClusterPredictions 

func (p *Client) CreateClusterPredictions(request *predictions.CreateClusterPredictionsRequest) (*status.Status, error)

func (*Client) CreateClusterRecommendations 

func (p *Client) CreateClusterRecommendations(request *recommendations.CreateClusterRecommendationsRequest) (*status.Status, error)

func (*Client) CreateClusters 

func (p *Client) CreateClusters(request *resources.CreateClustersRequest) (*status.Status, error)

func (*Client) CreateControllerMetrics 

func (p *Client) CreateControllerMetrics(request *metrics.CreateControllerMetricsRequest) (*status.Status, error)

func (*Client) CreateControllerPlannings 

func (p *Client) CreateControllerPlannings(request *plannings.CreateControllerPlanningsRequest) (*status.Status, error)

func (*Client) CreateControllerPredictions 

func (p *Client) CreateControllerPredictions(request *predictions.CreateControllerPredictionsRequest) (*status.Status, error)

func (*Client) CreateControllerRecommendations 

func (p *Client) CreateControllerRecommendations(request *recommendations.CreateControllerRecommendationsRequest) (*status.Status, error)

func (*Client) CreateControllers 

func (p *Client) CreateControllers(request *resources.CreateControllersRequest) (*status.Status, error)

func (*Client) CreateEvents 

func (p *Client) CreateEvents(request *events.CreateEventsRequest) (*status.Status, error)

func (*Client) CreateGpuPredictions 

func (p *Client) CreateGpuPredictions(request *gpu.CreateGpuPredictionsRequest) (*status.Status, error)

func (*Client) CreateNamespaceMetrics 

func (p *Client) CreateNamespaceMetrics(request *metrics.CreateNamespaceMetricsRequest) (*status.Status, error)

func (*Client) CreateNamespacePlannings 

func (p *Client) CreateNamespacePlannings(request *plannings.CreateNamespacePlanningsRequest) (*status.Status, error)

func (*Client) CreateNamespacePredictions 

func (p *Client) CreateNamespacePredictions(request *predictions.CreateNamespacePredictionsRequest) (*status.Status, error)

func (*Client) CreateNamespaceRecommendations 

func (p *Client) CreateNamespaceRecommendations(request *recommendations.CreateNamespaceRecommendationsRequest) (*status.Status, error)

func (*Client) CreateNamespaces 

func (p *Client) CreateNamespaces(request *resources.CreateNamespacesRequest) (*status.Status, error)

func (*Client) CreateNodeMetrics 

func (p *Client) CreateNodeMetrics(request *metrics.CreateNodeMetricsRequest) (*status.Status, error)

func (*Client) CreateNodePlannings 

func (p *Client) CreateNodePlannings(request *plannings.CreateNodePlanningsRequest) (*status.Status, error)

func (*Client) CreateNodePredictions 

func (p *Client) CreateNodePredictions(request *predictions.CreateNodePredictionsRequest) (*status.Status, error)

func (*Client) CreateNodeRecommendations 

func (p *Client) CreateNodeRecommendations(request *recommendations.CreateNodeRecommendationsRequest) (*status.Status, error)

func (*Client) CreateNodes 

func (p *Client) CreateNodes(request *resources.CreateNodesRequest) (*status.Status, error)

func (*Client) CreatePodMetrics 

func (p *Client) CreatePodMetrics(request *metrics.CreatePodMetricsRequest) (*status.Status, error)

func (*Client) CreatePodPlannings 

func (p *Client) CreatePodPlannings(request *plannings.CreatePodPlanningsRequest) (*status.Status, error)

func (*Client) CreatePodPredictions 

func (p *Client) CreatePodPredictions(request *predictions.CreatePodPredictionsRequest) (*status.Status, error)

func (*Client) CreatePodRecommendations 

func (p *Client) CreatePodRecommendations(request *recommendations.CreatePodRecommendationsRequest) (*status.Status, error)

func (*Client) CreatePods 

func (p *Client) CreatePods(request *resources.CreatePodsRequest) (*status.Status, error)

func (*Client) CreateSchemas 

func (p *Client) CreateSchemas(request *schemas.CreateSchemasRequest) (*status.Status, error)

func (*Client) CreateSimulatedSchedulingScores 

func (p *Client) CreateSimulatedSchedulingScores(request *scores.CreateSimulatedSchedulingScoresRequest) (*status.Status, error)

func (*Client) Delete 

func (p *Client) Delete(entities interface{}) error

Delete by tags

func (*Client) DeleteApplications 

func (p *Client) DeleteApplications(request *resources.DeleteApplicationsRequest) (*status.Status, error)

func (*Client) DeleteByOpts 

func (p *Client) DeleteByOpts(entity interface{}, opts ...Option) error

Entity is indicator, delete by options

func (*Client) DeleteClusters 

func (p *Client) DeleteClusters(request *resources.DeleteClustersRequest) (*status.Status, error)

func (*Client) DeleteControllers 

func (p *Client) DeleteControllers(request *resources.DeleteControllersRequest) (*status.Status, error)

func (*Client) DeleteData 

func (p *Client) DeleteData(request *data.DeleteDataRequest) (*status.Status, error)

func (*Client) DeleteKeycode 

func (p *Client) DeleteKeycode(request *keycodes.DeleteKeycodeRequest) (*status.Status, error)

func (*Client) DeleteNamespaces 

func (p *Client) DeleteNamespaces(request *resources.DeleteNamespacesRequest) (*status.Status, error)

func (*Client) DeleteNodes 

func (p *Client) DeleteNodes(request *resources.DeleteNodesRequest) (*status.Status, error)

func (*Client) DeletePods 

func (p *Client) DeletePods(request *resources.DeletePodsRequest) (*status.Status, error)

func (*Client) DeleteSchemas 

func (p *Client) DeleteSchemas(request *schemas.DeleteSchemasRequest) (*status.Status, error)

func (*Client) GenerateRegistrationData 

func (p *Client) GenerateRegistrationData(request *empty.Empty) (*keycodes.GenerateRegistrationDataResponse, error)

func (*Client) GetLicense 

func (p *Client) GetLicense(request *empty.Empty) (*licenses.GetLicenseResponse, error)

func (*Client) IsAlive 

func (p *Client) IsAlive() bool

func (*Client) List 

func (p *Client) List(entities interface{}, opts ...Option) error

func (*Client) ListApplicationMetrics 

func (p *Client) ListApplicationMetrics(request *metrics.ListApplicationMetricsRequest) (*metrics.ListApplicationMetricsResponse, error)

func (*Client) ListApplicationPlannings 

func (p *Client) ListApplicationPlannings(request *plannings.ListApplicationPlanningsRequest) (*plannings.ListApplicationPlanningsResponse, error)

func (*Client) ListApplicationPredictions 

func (p *Client) ListApplicationPredictions(request *predictions.ListApplicationPredictionsRequest) (*predictions.ListApplicationPredictionsResponse, error)

func (*Client) ListApplicationRecommendations 

func (p *Client) ListApplicationRecommendations(request *recommendations.ListApplicationRecommendationsRequest) (*recommendations.ListApplicationRecommendationsResponse, error)

func (*Client) ListApplications 

func (p *Client) ListApplications(request *resources.ListApplicationsRequest) (*resources.ListApplicationsResponse, error)

func (*Client) ListClusterMetrics 

func (p *Client) ListClusterMetrics(request *metrics.ListClusterMetricsRequest) (*metrics.ListClusterMetricsResponse, error)

func (*Client) ListClusterPlannings 

func (p *Client) ListClusterPlannings(request *plannings.ListClusterPlanningsRequest) (*plannings.ListClusterPlanningsResponse, error)

func (*Client) ListClusterPredictions 

func (p *Client) ListClusterPredictions(request *predictions.ListClusterPredictionsRequest) (*predictions.ListClusterPredictionsResponse, error)

func (*Client) ListClusterRecommendations 

func (p *Client) ListClusterRecommendations(request *recommendations.ListClusterRecommendationsRequest) (*recommendations.ListClusterRecommendationsResponse, error)

func (*Client) ListClusters 

func (p *Client) ListClusters(request *resources.ListClustersRequest) (*resources.ListClustersResponse, error)

func (*Client) ListControllerMetrics 

func (p *Client) ListControllerMetrics(request *metrics.ListControllerMetricsRequest) (*metrics.ListControllerMetricsResponse, error)

func (*Client) ListControllerPlannings 

func (p *Client) ListControllerPlannings(request *plannings.ListControllerPlanningsRequest) (*plannings.ListControllerPlanningsResponse, error)

func (*Client) ListControllerPredictions 

func (p *Client) ListControllerPredictions(request *predictions.ListControllerPredictionsRequest) (*predictions.ListControllerPredictionsResponse, error)

func (*Client) ListControllerRecommendations 

func (p *Client) ListControllerRecommendations(request *recommendations.ListControllerRecommendationsRequest) (*recommendations.ListControllerRecommendationsResponse, error)

func (*Client) ListControllers 

func (p *Client) ListControllers(request *resources.ListControllersRequest) (*resources.ListControllersResponse, error)

func (*Client) ListEvents 

func (p *Client) ListEvents(request *events.ListEventsRequest) (*events.ListEventsResponse, error)

func (*Client) ListGpuMetrics 

func (p *Client) ListGpuMetrics(request *gpu.ListGpuMetricsRequest) (*gpu.ListGpuMetricsResponse, error)

func (*Client) ListGpuPredictions 

func (p *Client) ListGpuPredictions(request *gpu.ListGpuPredictionsRequest) (*gpu.ListGpuPredictionsResponse, error)

func (*Client) ListGpus 

func (p *Client) ListGpus(request *gpu.ListGpusRequest) (*gpu.ListGpusResponse, error)

func (*Client) ListKeycodes 

func (p *Client) ListKeycodes(request *keycodes.ListKeycodesRequest) (*keycodes.ListKeycodesResponse, error)

func (*Client) ListNamespaceMetrics 

func (p *Client) ListNamespaceMetrics(request *metrics.ListNamespaceMetricsRequest) (*metrics.ListNamespaceMetricsResponse, error)

func (*Client) ListNamespacePlannings 

func (p *Client) ListNamespacePlannings(request *plannings.ListNamespacePlanningsRequest) (*plannings.ListNamespacePlanningsResponse, error)

func (*Client) ListNamespacePredictions 

func (p *Client) ListNamespacePredictions(request *predictions.ListNamespacePredictionsRequest) (*predictions.ListNamespacePredictionsResponse, error)

func (*Client) ListNamespaceRecommendations 

func (p *Client) ListNamespaceRecommendations(request *recommendations.ListNamespaceRecommendationsRequest) (*recommendations.ListNamespaceRecommendationsResponse, error)

func (*Client) ListNamespaces 

func (p *Client) ListNamespaces(request *resources.ListNamespacesRequest) (*resources.ListNamespacesResponse, error)

func (*Client) ListNodeMetrics 

func (p *Client) ListNodeMetrics(request *metrics.ListNodeMetricsRequest) (*metrics.ListNodeMetricsResponse, error)

func (*Client) ListNodePlannings 

func (p *Client) ListNodePlannings(request *plannings.ListNodePlanningsRequest) (*plannings.ListNodePlanningsResponse, error)

func (*Client) ListNodePredictions 

func (p *Client) ListNodePredictions(request *predictions.ListNodePredictionsRequest) (*predictions.ListNodePredictionsResponse, error)

func (*Client) ListNodeRecommendations 

func (p *Client) ListNodeRecommendations(request *recommendations.ListNodeRecommendationsRequest) (*recommendations.ListNodeRecommendationsResponse, error)

func (*Client) ListNodes 

func (p *Client) ListNodes(request *resources.ListNodesRequest) (*resources.ListNodesResponse, error)

func (*Client) ListPodMetrics 

func (p *Client) ListPodMetrics(request *metrics.ListPodMetricsRequest) (*metrics.ListPodMetricsResponse, error)

func (*Client) ListPodPlannings 

func (p *Client) ListPodPlannings(request *plannings.ListPodPlanningsRequest) (*plannings.ListPodPlanningsResponse, error)

func (*Client) ListPodPredictions 

func (p *Client) ListPodPredictions(request *predictions.ListPodPredictionsRequest) (*predictions.ListPodPredictionsResponse, error)

func (*Client) ListPodRecommendations 

func (p *Client) ListPodRecommendations(request *recommendations.ListPodRecommendationsRequest) (*recommendations.ListPodRecommendationsResponse, error)

func (*Client) ListPods 

func (p *Client) ListPods(request *resources.ListPodsRequest) (*resources.ListPodsResponse, error)

func (*Client) ListSchemas 

func (p *Client) ListSchemas(request *schemas.ListSchemasRequest) (*schemas.ListSchemasResponse, error)

func (*Client) ListSimulatedSchedulingScores 

func (p *Client) ListSimulatedSchedulingScores(request *scores.ListSimulatedSchedulingScoresRequest) (*scores.ListSimulatedSchedulingScoresResponse, error)

func (*Client) ListTS 

func (p *Client) ListTS(entities interface{}, timeRange *TimeRange, function *Function, fields []string, opts ...Option) error

func (*Client) Ping 

func (p *Client) Ping(request *empty.Empty) (*status.Status, error)

func (*Client) ReadData 

func (p *Client) ReadData(request *data.ReadDataRequest) (*data.ReadDataResponse, error)

func (*Client) ReadRawdata 

func (p *Client) ReadRawdata(request *rawdata.ReadRawdataRequest) (*rawdata.ReadRawdataResponse, error)

func (*Client) WriteData 

func (p *Client) WriteData(request *data.WriteDataRequest) (*status.Status, error)

func (*Client) WriteMeta 

func (p *Client) WriteMeta(request *data.WriteMetaRequest) (*status.Status, error)

func (*Client) WriteRawdata 

func (p *Client) WriteRawdata(request *rawdata.WriteRawdataRequest) (*status.Status, error)

type Function 

type Function struct {
	Type   DBCommon.FunctionType
	Target string
	Unit   string
	Number int64
}

type Option 

type Option struct {
	Entity interface{}
	Fields []string
}

type TimeRange 

type TimeRange struct {
	StartTime *time.Time
	EndTime   *time.Time
	Order     DBCommon.Order
	Limit     uint64
	Step      int
}

Source Files

View all Source files

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.