monitoring

Documentation

Index

• func Migrate(ctx context.Context, clientFactory K8sClientFactory, ...) error
• type ChartConfig
  • func (c ChartConfig) Validate() error
• type ChartsConfig
• type Config
  • func (c Config) Validate() error
• type GrafanaConfig
  • func (c GrafanaConfig) Validate() error
• type ImageConfig
  • func (c ImageConfig) Validate() error
• type ImagesConfig
• type IntegratedServiceManager
  • func MakeIntegratedServiceManager(clusterGetter integratedserviceadapter.ClusterGetter, ...) IntegratedServiceManager
  • func (m IntegratedServiceManager) GetOutput(ctx context.Context, clusterID uint, ...) (integratedservices.IntegratedServiceOutput, error)
  • func (IntegratedServiceManager) Name() string
  • func (IntegratedServiceManager) ValidateSpec(ctx context.Context, spec integratedservices.IntegratedServiceSpec) error
• type IntegratedServiceOperator
  • func MakeIntegratedServiceOperator(clusterGetter integratedserviceadapter.ClusterGetter, ...) IntegratedServiceOperator
  • func (op IntegratedServiceOperator) Apply(ctx context.Context, clusterID uint, ...) error
  • func (op IntegratedServiceOperator) Deactivate(ctx context.Context, clusterID uint, ...) error
  • func (IntegratedServiceOperator) Name() string
• type K8sClientFactory
• type KubernetesService
• type Migrator
• type PrometheusSpecValues

Functions

func Migrate

func Migrate(ctx context.Context, clientFactory K8sClientFactory, namespace, oldChartVersion, newChartVersion string) error

Types

type ChartConfig

type ChartConfig struct {
	Chart   string
	Version string
	Values  map[string]interface{}
}

func (ChartConfig) Validate

func (c ChartConfig) Validate() error

type ChartsConfig

type ChartsConfig struct {
	Operator    ChartConfig
	Pushgateway ChartConfig
}

type Config

type Config struct {
	Namespace string
	Grafana   GrafanaConfig
	Charts    ChartsConfig
	Images    ImagesConfig
}

Config contains configuration for the monitoring integrated service.

func (Config) Validate

func (c Config) Validate() error

type GrafanaConfig

type GrafanaConfig struct {
	AdminUser string
}

func (GrafanaConfig) Validate

func (c GrafanaConfig) Validate() error

type ImageConfig

type ImageConfig struct {
	Repository string
	Tag        string
}

func (ImageConfig) Validate

func (c ImageConfig) Validate() error

type ImagesConfig

type ImagesConfig struct {
	Operator         ImageConfig
	Prometheus       ImageConfig
	Alertmanager     ImageConfig
	Grafana          ImageConfig
	Kubestatemetrics ImageConfig
	Nodeexporter     ImageConfig
	Pushgateway      ImageConfig
}

type IntegratedServiceManager

type IntegratedServiceManager struct {
	integratedservices.PassthroughIntegratedServiceSpecPreparer
	// contains filtered or unexported fields
}

IntegratedServiceManager implements the Monitoring integrated service manager

func MakeIntegratedServiceManager

func MakeIntegratedServiceManager(
	clusterGetter integratedserviceadapter.ClusterGetter,
	secretStore services.SecretStore,
	endpointsService endpoints.EndpointService,
	helmService services.HelmService,
	config Config,
	logger common.Logger,
) IntegratedServiceManager

func (IntegratedServiceManager) GetOutput

func (m IntegratedServiceManager) GetOutput(ctx context.Context, clusterID uint, spec integratedservices.IntegratedServiceSpec) (integratedservices.IntegratedServiceOutput, error)

GetOutput returns the Monitoring integrated service'output

func (IntegratedServiceManager) Name

func (IntegratedServiceManager) Name() string

Name returns the integrated service' name

func (IntegratedServiceManager) ValidateSpec

func (IntegratedServiceManager) ValidateSpec(ctx context.Context, spec integratedservices.IntegratedServiceSpec) error

ValidateSpec validates a Monitoring integrated service specification

type IntegratedServiceOperator

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

IntegratedServiceOperator implements the Monitoring integrated service operator

func MakeIntegratedServiceOperator

func MakeIntegratedServiceOperator(
	clusterGetter integratedserviceadapter.ClusterGetter,
	clusterService integratedservices.ClusterService,
	helmService services.HelmService,
	kubernetesService KubernetesService,
	config Config,
	logger common.Logger,
	secretStore services.SecretStore,
	migrator Migrator,
) IntegratedServiceOperator

MakeIntegratedServiceOperator returns a Monitoring integrated service operator

func (IntegratedServiceOperator) Apply

func (op IntegratedServiceOperator) Apply(ctx context.Context, clusterID uint, spec integratedservices.IntegratedServiceSpec) error

Apply applies the provided specification to the integrated service

func (IntegratedServiceOperator) Deactivate

func (op IntegratedServiceOperator) Deactivate(ctx context.Context, clusterID uint, spec integratedservices.IntegratedServiceSpec) error

Deactivate deactivates the cluster integrated service

func (IntegratedServiceOperator) Name

func (IntegratedServiceOperator) Name() string

Name returns the name of the DNS integrated service

type K8sClientFactory

type K8sClientFactory func() (kubernetes.Interface, error)

type KubernetesService

type KubernetesService interface {
	// List lists Objects on specific cluster.
	List(ctx context.Context, clusterID uint, labels map[string]string, o client.ObjectList) error

	// DeleteObject deletes the passed in object from the cluster
	DeleteObject(ctx context.Context, clusterID uint, o client.Object) error
}

type Migrator

type Migrator func(ctx context.Context, configFactory K8sClientFactory, namespace, oldChartVersion, newChartVersion string) error

type PrometheusSpecValues

type PrometheusSpecValues struct {
	RetentionSize                           string                 `json:"retentionSize"`
	Retention                               string                 `json:"retention"`
	StorageSpec                             map[string]interface{} `json:"storageSpec"`
	ServiceMonitorSelectorNilUsesHelmValues bool                   `json:"serviceMonitorSelectorNilUsesHelmValues"`
	// contains filtered or unexported fields
}