controllers

Documentation

Index

• Constants
• type MonitorReconciler
  • func NewMonitorReconciler(mgr ctrl.Manager) (*MonitorReconciler, error)
  • func (r *MonitorReconciler) DropMonitorCollectionOlder() error
  • func (r *MonitorReconciler) MonitorTrafficUsed(startTime, endTime time.Time) error
  • func (r *MonitorReconciler) StartReconciler(ctx context.Context) error

Constants

const (
	PrometheusURL         = "PROM_URL"
	ObjectStorageInstance = "OBJECT_STORAGE_INSTANCE"
	ConcurrentLimit       = "CONCURRENT_LIMIT"
)

const (
	DefaultConcurrencyLimit = 1000
)

Types

type MonitorReconciler

type MonitorReconciler struct {
	client.Client
	logr.Logger
	Interval time.Duration
	Scheme   *runtime.Scheme

	NvidiaGpu     map[string]gpu.NvidiaGPU
	DBClient      database.Interface
	TrafficClient database.Interface
	Properties    *resources.PropertyTypeLS
	PromURL       string

	ObjStorageClient        *minio.Client
	ObjStorageMetricsClient *objstorage.MetricsClient
	ObjectStorageInstance   string
	// contains filtered or unexported fields
}

MonitorReconciler reconciles a Monitor object

func NewMonitorReconciler

func NewMonitorReconciler(mgr ctrl.Manager) (*MonitorReconciler, error)

func (*MonitorReconciler) DropMonitorCollectionOlder

func (r *MonitorReconciler) DropMonitorCollectionOlder() error

func (*MonitorReconciler) MonitorTrafficUsed

func (r *MonitorReconciler) MonitorTrafficUsed(startTime, endTime time.Time) error

func (*MonitorReconciler) StartReconciler

func (r *MonitorReconciler) StartReconciler(ctx context.Context) error