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, startupTimestamp time.Time, ...) (status StatusResponse, metrics Metrics)
• func InitializeAndUpdatePrometheusMetrics(registry *prometheus.Registry, metrics Metrics)
• func WatchAndReportStatusAndMetrics(ctx context.Context, logger log.Logger, statusFilePath string, ...) govnr.ShutdownWaiter
• type BoyarService
  • func NewCoreBoyarService(logger log.Logger) *BoyarService
  • func (coreBoyar *BoyarService) OnConfigChange(ctx context.Context, cfg config.NodeConfiguration) error
• type ConfigurationPollService
  • func NewConfigurationPollService(flags *config.Flags, logger log.Logger) *ConfigurationPollService
  • func (service *ConfigurationPollService) Resend()
  • func (service *ConfigurationPollService) Start(ctx context.Context) govnr.ShutdownWaiter
• 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 PrometheusMetrics
• type StatusResponse

Constants

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, 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, statusFilePath string, metricsFilePath string) govnr.ShutdownWaiter

Types

type BoyarService

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

func NewCoreBoyarService

func NewCoreBoyarService(logger log.Logger) *BoyarService

func (*BoyarService) OnConfigChange

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

type ConfigurationPollService

type ConfigurationPollService struct {
	Output <-chan config.NodeConfiguration
	// contains filtered or unexported fields
}

func NewConfigurationPollService

func NewConfigurationPollService(flags *config.Flags, logger log.Logger) *ConfigurationPollService

func (*ConfigurationPollService) Resend

func (service *ConfigurationPollService) Resend()

func (*ConfigurationPollService) Start

func (service *ConfigurationPollService) Start(ctx context.Context) govnr.ShutdownWaiter

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
}

func CollectMetrics

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

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{}
}