jobs

package
v1.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 1, 2020 License: Apache-2.0 Imports: 7 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AlertCleanupJob

type AlertCleanupJob struct {
	TargetDatabase metrics.Database
	MaxAgeInDays   int
}

AlertCleanupJob is a Job used to cleanup old array alerts in the given database

func (*AlertCleanupJob) Description

func (m *AlertCleanupJob) Description() string

Description gets a string description of this job

func (*AlertCleanupJob) Execute

func (m *AlertCleanupJob) Execute()

Execute cleans up the old alerts in the given database

type ArrayAlertPushJob

type ArrayAlertPushJob struct {
	TargetDatabase metrics.Database
	Alerts         []*metrics.Alert
}

ArrayAlertPushJob pushes the given alerts to the given database

func (*ArrayAlertPushJob) Description

func (a *ArrayAlertPushJob) Description() string

Description gets a string description of this job

func (*ArrayAlertPushJob) Execute

func (a *ArrayAlertPushJob) Execute()

Execute pushes the given alerts to the given database

type ArrayMetricCollectJob

type ArrayMetricCollectJob struct {
	TargetArray      *resources.ArrayRegistrationInfo
	CollectorFactory resources.CollectorFactory
	TargetDatabase   metrics.Database
	TargetPool       *workerpool.Pool
}

ArrayMetricCollectJob is a Job used to fetch the metrics for a given array which then kicks off more jobs to push the metrics to the given database (Collects volume metrics only for FlashArray)

func (*ArrayMetricCollectJob) Description

func (m *ArrayMetricCollectJob) Description() string

Description gets a string description of this job

func (*ArrayMetricCollectJob) Execute

func (m *ArrayMetricCollectJob) Execute()

Execute cleans up the old metrics in the given database

type ArrayMetricPushJob

type ArrayMetricPushJob struct {
	TargetDatabase metrics.Database
	Metric         *metrics.ArrayMetric
}

ArrayMetricPushJob pushes the given metric to the given database

func (*ArrayMetricPushJob) Description

func (a *ArrayMetricPushJob) Description() string

Description gets a string description of this job

func (*ArrayMetricPushJob) Execute

func (a *ArrayMetricPushJob) Execute()

Execute pushes the given array metric to the given database

type ArrayVolumeMetricCollectJob

type ArrayVolumeMetricCollectJob struct {
	TargetArray      *resources.ArrayRegistrationInfo
	CollectorFactory resources.CollectorFactory
	TargetDatabase   metrics.Database
	TargetPool       *workerpool.Pool
	TimeWindow       int64
}

ArrayVolumeMetricCollectJob is a Job used to fetch the volume metrics for a given array which then kicks off another job to push the metrics to the given database (Used by FlashBlade only)

func (*ArrayVolumeMetricCollectJob) Description

func (m *ArrayVolumeMetricCollectJob) Description() string

Description gets a string description of this job

func (*ArrayVolumeMetricCollectJob) Execute

func (m *ArrayVolumeMetricCollectJob) Execute()

Execute cleans up the old metrics in the given database

type ArrayVolumeMetricPushJob

type ArrayVolumeMetricPushJob struct {
	TargetDatabase metrics.Database
	Metrics        []*metrics.VolumeMetric
}

ArrayVolumeMetricPushJob pushes the given volume metrics to the given database

func (*ArrayVolumeMetricPushJob) Description

func (a *ArrayVolumeMetricPushJob) Description() string

Description gets a string description of this job

func (*ArrayVolumeMetricPushJob) Execute

func (a *ArrayVolumeMetricPushJob) Execute()

Execute pushes the given volume metrics to the given database

type ErrorLogCleanupJob

type ErrorLogCleanupJob struct {
	TargetDatabase metrics.Database
	MaxAgeInDays   int
}

ErrorLogCleanupJob is a job used to clean up error logs in the given database

func (*ErrorLogCleanupJob) Description

func (m *ErrorLogCleanupJob) Description() string

Description gets a string description of this job

func (*ErrorLogCleanupJob) Execute

func (m *ErrorLogCleanupJob) Execute()

Execute cleans up the old alerts in the given database

type MetricCleanupJob

type MetricCleanupJob struct {
	TargetDatabase metrics.Database
	MaxAgeInDays   int
}

MetricCleanupJob is a Job used to cleanup old array metrics in the given database

func (*MetricCleanupJob) Description

func (m *MetricCleanupJob) Description() string

Description gets a string description of this job

func (*MetricCleanupJob) Execute

func (m *MetricCleanupJob) Execute()

Execute cleans up the old metrics in the given database

type MonitorCheckJob

type MonitorCheckJob struct {
	DeviceInfo    *resources.ArrayRegistrationInfo
	DeviceFactory resources.CollectorFactory
	Metadata      resources.ArrayMetadata
}

MonitorCheckJob is a job that a) attempts to connect to the given device, and b) updates the API server with the new status

func (*MonitorCheckJob) Description

func (m *MonitorCheckJob) Description() string

Description gets a string description of this job

func (*MonitorCheckJob) Execute

func (m *MonitorCheckJob) Execute()

Execute attempts to connect to the device and pulls metadata, pushing it to the API server

type TimerLogCleanupJob

type TimerLogCleanupJob struct {
	TargetDatabase metrics.Database
	MaxAgeInDays   int
}

TimerLogCleanupJob is a job used to clean up stage timer logs in the given database

func (*TimerLogCleanupJob) Description

func (m *TimerLogCleanupJob) Description() string

Description gets a string description of this job

func (*TimerLogCleanupJob) Execute

func (m *TimerLogCleanupJob) Execute()

Execute cleans up the old alerts in the given database

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL