Versions in this module Expand all Collapse all v0 v0.0.10 Apr 10, 2026 v0.0.9 Mar 17, 2026 Changes in this version + type NodeServiceImpl struct + CleanBeforeHours int64 + CleanCron string + MetricBatchIntervalSeconds int64 + MetricBatchSize int + MetricTopic string + func (i *NodeServiceImpl) CleanMetric(ctx context.Context, in *node.CleanMetricRequest) (*node.CleanMetricResponse, error) + func (i *NodeServiceImpl) Close(ctx context.Context) + func (i *NodeServiceImpl) DescribeLatestMetric(ctx context.Context, agentId string) (*node.NodeMetric, error) + func (i *NodeServiceImpl) DescribeNode(ctx context.Context, nodeName string) (*node.Node, error) + func (i *NodeServiceImpl) GetMetricBufferSize() int + func (i *NodeServiceImpl) Init() error + func (i *NodeServiceImpl) Name() string + func (i *NodeServiceImpl) QueryAgentMetric(ctx context.Context, in *node.QueryAgentMetricRequest) (*types.Set[*node.NodeMetric], error) + func (i *NodeServiceImpl) QueryNodes(ctx context.Context, in *node.QueryNodeRequest) (*types.Set[*node.Node], error) + func (i *NodeServiceImpl) RegisterNode(ctx context.Context, in *node.RegisterNodeRequest) (*node.Node, error) + func (i *NodeServiceImpl) SaveAgentMetric(ctx context.Context, in *node.NodeMetric) error + func (i *NodeServiceImpl) UnregisterNode(ctx context.Context, nodeName string) error + func (i *NodeServiceImpl) UpdateNodeHeartbeat(ctx context.Context, nodeName string) error
Go to main page