info

Documentation

Index

• Constants
• func NewComponent(_ context.Context, apiServer *echo.Echo, config *config.File, ...) component.Component
• type Component
  • func (c *Component) CollectMetric(ctx context.Context, value string)
  • func (c *Component) GetActivityCount(ctx echo.Context) error
  • func (c *Component) GetNodeOperator(ctx echo.Context) error
  • func (c *Component) GetWorkersStatus(ctx echo.Context) error
  • func (c *Component) InitMeter() (err error)
  • func (c *Component) Name() string
• type StatisticResponse
• type WorkerInfo
• type WorkerKey
• type WorkerResponse
• type WorkerStatusAggregator

Constants

const Name = "info"

Functions

func NewComponent

func NewComponent(_ context.Context, apiServer *echo.Echo, config *config.File, databaseClient database.Client, redisClient rueidis.Client) component.Component

Types

type Component

type Component struct {
	// contains filtered or unexported fields
}

func (*Component) CollectMetric

func (c *Component) CollectMetric(ctx context.Context, value string)

func (*Component) GetActivityCount

func (c *Component) GetActivityCount(ctx echo.Context) error

GetActivityCount returns the total number of activities indexed by this Node.

func (*Component) GetNodeOperator

func (c *Component) GetNodeOperator(ctx echo.Context) error

GetNodeOperator returns the node information.

func (*Component) GetWorkersStatus

func (c *Component) GetWorkersStatus(ctx echo.Context) error

GetWorkersStatus returns the status of all workers.

func (*Component) InitMeter

func (c *Component) InitMeter() (err error)

func (*Component) Name

func (c *Component) Name() string

type StatisticResponse

type StatisticResponse struct {
	Count      int64      `json:"count"`
	LastUpdate *time.Time `json:"last_update,omitempty"`
}

type WorkerInfo

type WorkerInfo struct {
	Network  network.Network `json:"network"`
	Worker   worker.Worker   `json:"worker"`
	Tags     []tag.Tag       `json:"tags"`
	Platform worker.Platform `json:"platform"`
	Status   worker.Status   `json:"status"`
}

type WorkerKey

type WorkerKey struct {
	Network network.Network
	Worker  worker.Worker
}

WorkerKey is the key for the worker status aggregator.

type WorkerResponse

type WorkerResponse struct {
	Data []*WorkerInfo `json:"data"`
}

type WorkerStatusAggregator

type WorkerStatusAggregator struct {
	Statuses []worker.Status
}

WorkerStatusAggregator aggregates the statuses of workers with the same Network+Worker.