services

Documentation

Index

• Constants
• func Bootstrap(ctx context.Context, flags *config.Flags, logger log.Logger) (*config.Flags, error)
• func Execute(ctx context.Context, flags *config.Flags, logger log.Logger) (govnr.ShutdownWaiter, error)
• func GetSerializedMetrics(registry *prometheus.Registry) (value string, err error)
• func GetStatusAndMetrics(ctx context.Context, logger log.Logger, flags *config.Flags, ...) (status StatusResponse, metrics Metrics)
• func InitializeAndUpdatePrometheusMetrics(registry *prometheus.Registry, metrics Metrics)
• func WatchAndReportStatusAndMetrics(ctx context.Context, logger log.Logger, flags *config.Flags) govnr.ShutdownWaiter
• type BoyarService
  • func NewCoreBoyarService(logger log.Logger) *BoyarService
  • func (coreBoyar *BoyarService) CheckForUpdates(flags *config.Flags, options adapter.ExecutableImageOptions) (shouldExit bool)
  • func (coreBoyar *BoyarService) OnConfigChange(ctx context.Context, cfg config.NodeConfiguration) error
  • func (coreBoyar *BoyarService) SelfUpdate(targetPath string, image adapter.ExecutableImageOptions) error
• type DiskMetric
  • func ReadDiskMetrics(logger log.Logger) (diskMetrics []DiskMetric, errors []error)
• type Metrics
  • func CollectMetrics(ctx context.Context, logger log.Logger, startupTimestamp time.Time) (metrics Metrics, aggregateError error)
• type ProcessMetric
• type PrometheusMetrics
• type StatusResponse

Constants

const MAX_CPU_LOAD = 75

const MAX_MEMORY_USED = 75

const SERVICE_STATUS_REPORT_PERIOD = 30 * time.Second

const SERVICE_STATUS_REPORT_TIMEOUT = 15 * time.Second

Functions

func Bootstrap

func Bootstrap(ctx context.Context, flags *config.Flags, logger log.Logger) (*config.Flags, error)

func Execute

func Execute(ctx context.Context, flags *config.Flags, logger log.Logger) (govnr.ShutdownWaiter, error)

func GetSerializedMetrics

func GetSerializedMetrics(registry *prometheus.Registry) (value string, err error)

func GetStatusAndMetrics

func GetStatusAndMetrics(ctx context.Context, logger log.Logger, flags *config.Flags, startupTimestamp time.Time, dockerStatusPeriod time.Duration) (status StatusResponse, metrics Metrics)

func InitializeAndUpdatePrometheusMetrics

func InitializeAndUpdatePrometheusMetrics(registry *prometheus.Registry, metrics Metrics)

func WatchAndReportStatusAndMetrics

func WatchAndReportStatusAndMetrics(ctx context.Context, logger log.Logger, flags *config.Flags) govnr.ShutdownWaiter

Types

type BoyarService

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

func NewCoreBoyarService

func NewCoreBoyarService(logger log.Logger) *BoyarService

func (*BoyarService) CheckForUpdates

func (coreBoyar *BoyarService) CheckForUpdates(flags *config.Flags, options adapter.ExecutableImageOptions) (shouldExit bool)

func (*BoyarService) OnConfigChange

func (coreBoyar *BoyarService) OnConfigChange(ctx context.Context, cfg config.NodeConfiguration) error

func (*BoyarService) SelfUpdate

func (coreBoyar *BoyarService) SelfUpdate(targetPath string, image adapter.ExecutableImageOptions) error

type DiskMetric

type DiskMetric struct {
	Mountpoint  string
	TotalMbytes float64
	UsedMbytes  float64
	UsedPercent float64
}

func ReadDiskMetrics

func ReadDiskMetrics(logger log.Logger) (diskMetrics []DiskMetric, errors []error)

type Metrics

type Metrics struct {
	BoyarUptime       float64
	CPULoadPercent    float64
	MemoryUsedPercent float64
	MemoryUsedMBytes  float64
	MemoryTotalMBytes float64
	EFSAccessTimeMs   uint64
	Disks             []DiskMetric
	Processes         []ProcessMetric
}

func CollectMetrics

func CollectMetrics(ctx context.Context, logger log.Logger, startupTimestamp time.Time) (metrics Metrics, aggregateError error)

type ProcessMetric

type ProcessMetric struct {
	Name             string
	Command          string
	MemoryUsedMbytes float64
	PID              int32
	ParentPID        int32
}

type PrometheusMetrics

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

type StatusResponse

type StatusResponse struct {
	Timestamp time.Time
	Status    string
	Error     string
	Payload   map[string]interface{}
}