tasks

Documentation

Index

• type AlertmanagerTask
  • func NewAlertmanagerTask(client *client.Client, factory *manifests.Factory) *AlertmanagerTask
  • func (t *AlertmanagerTask) Run() error
• type ClusterMonitoringOperatorTask
  • func NewClusterMonitoringOperatorTask(client *client.Client, factory *manifests.Factory) *ClusterMonitoringOperatorTask
  • func (t *ClusterMonitoringOperatorTask) Run() error
• type GrafanaTask
  • func NewGrafanaTask(client *client.Client, factory *manifests.Factory) *GrafanaTask
  • func (t *GrafanaTask) Run() error
• type KubeStateMetricsTask
  • func NewKubeStateMetricsTask(client *client.Client, factory *manifests.Factory) *KubeStateMetricsTask
  • func (t *KubeStateMetricsTask) Run() error
• type NodeExporterTask
  • func NewNodeExporterTask(client *client.Client, factory *manifests.Factory) *NodeExporterTask
  • func (t *NodeExporterTask) Run() error
• type PrometheusOperatorTask
  • func NewPrometheusOperatorTask(client *client.Client, factory *manifests.Factory) *PrometheusOperatorTask
  • func (t *PrometheusOperatorTask) Run() error
• type PrometheusTask
  • func NewPrometheusTask(client *client.Client, factory *manifests.Factory, config *manifests.Config) *PrometheusTask
  • func (t *PrometheusTask) Run() error
• type Task
• type TaskRunner
  • func NewTaskRunner(client *client.Client, tasks []*TaskSpec) *TaskRunner
  • func (tl *TaskRunner) ExecuteTask(ts *TaskSpec) error
  • func (tl *TaskRunner) RunAll() error
• type TaskSpec
  • func NewTaskSpec(name string, task Task) *TaskSpec

Types

type AlertmanagerTask

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

func NewAlertmanagerTask

func NewAlertmanagerTask(client *client.Client, factory *manifests.Factory) *AlertmanagerTask

func (*AlertmanagerTask) Run

func (t *AlertmanagerTask) Run() error

type ClusterMonitoringOperatorTask

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

func NewClusterMonitoringOperatorTask

func NewClusterMonitoringOperatorTask(client *client.Client, factory *manifests.Factory) *ClusterMonitoringOperatorTask

func (*ClusterMonitoringOperatorTask) Run

func (t *ClusterMonitoringOperatorTask) Run() error

type GrafanaTask

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

func NewGrafanaTask

func NewGrafanaTask(client *client.Client, factory *manifests.Factory) *GrafanaTask

func (*GrafanaTask) Run

func (t *GrafanaTask) Run() error

type KubeStateMetricsTask

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

func NewKubeStateMetricsTask

func NewKubeStateMetricsTask(client *client.Client, factory *manifests.Factory) *KubeStateMetricsTask

func (*KubeStateMetricsTask) Run

func (t *KubeStateMetricsTask) Run() error

type NodeExporterTask

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

func NewNodeExporterTask

func NewNodeExporterTask(client *client.Client, factory *manifests.Factory) *NodeExporterTask

func (*NodeExporterTask) Run

func (t *NodeExporterTask) Run() error

type PrometheusOperatorTask

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

func NewPrometheusOperatorTask

func NewPrometheusOperatorTask(client *client.Client, factory *manifests.Factory) *PrometheusOperatorTask

func (*PrometheusOperatorTask) Run

func (t *PrometheusOperatorTask) Run() error

type PrometheusTask

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

func NewPrometheusTask

func NewPrometheusTask(client *client.Client, factory *manifests.Factory, config *manifests.Config) *PrometheusTask

func (*PrometheusTask) Run

func (t *PrometheusTask) Run() error

type Task

type Task interface {
	Run() error
}

type TaskRunner

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

func NewTaskRunner

func NewTaskRunner(client *client.Client, tasks []*TaskSpec) *TaskRunner

func (*TaskRunner) ExecuteTask

func (tl *TaskRunner) ExecuteTask(ts *TaskSpec) error

func (*TaskRunner) RunAll

func (tl *TaskRunner) RunAll() error

type TaskSpec

type TaskSpec struct {
	Name string
	Task Task
}

func NewTaskSpec

func NewTaskSpec(name string, task Task) *TaskSpec