job

Documentation

Index

• func MakeCleanCockroachJob(cockroach Cockroach, logger log.Logger) (*job.Job, error)
• func MakeElasticsearchCleanIndexJob(elasticClient ElasticsearchClient, healthCheckValidity time.Duration) (*job.Job, error)
• func MakeElasticsearchJob(elasticsearch ElasticsearchHealthChecker, healthCheckValidity time.Duration, ...) (*job.Job, error)
• func MakeFlakiJob(flaki FlakiHealthChecker, healthCheckValidity time.Duration, ...) (*job.Job, error)
• func MakeInfluxJob(influx InfluxHealthChecker, healthCheckValidity time.Duration, ...) (*job.Job, error)
• func MakeJaegerJob(jaeger JaegerHealthChecker, healthCheckValidity time.Duration, ...) (*job.Job, error)
• func MakeRedisJob(redis RedisHealthChecker, healthCheckValidity time.Duration, ...) (*job.Job, error)
• func MakeSentryJob(sentry SentryHealthChecker, healthCheckValidity time.Duration, ...) (*job.Job, error)
• type Cockroach
• type ElasticsearchClient
• type ElasticsearchHealthChecker
• type Flaki
• type FlakiHealthChecker
• type InfluxHealthChecker
• type JaegerHealthChecker
• type RedisHealthChecker
• type SentryHealthChecker

Functions

func MakeCleanCockroachJob

func MakeCleanCockroachJob(cockroach Cockroach, logger log.Logger) (*job.Job, error)

MakeCleanCockroachJob creates the job that periodically exectutes the health checks and save the result in DB.

func MakeElasticsearchCleanIndexJob

func MakeElasticsearchCleanIndexJob(elasticClient ElasticsearchClient, healthCheckValidity time.Duration) (*job.Job, error)

MakeElasticsearchCleanIndexJob creates the job that periodically clean the indexes in ElasticSearch.

func MakeElasticsearchJob

func MakeElasticsearchJob(elasticsearch ElasticsearchHealthChecker, healthCheckValidity time.Duration, cockroach Cockroach) (*job.Job, error)

MakeElasticsearchJob creates the job that periodically exectutes the health checks and save the result in DB.

func MakeFlakiJob

func MakeFlakiJob(flaki FlakiHealthChecker, healthCheckValidity time.Duration, cockroach Cockroach) (*job.Job, error)

MakeFlakiJob creates the job that periodically exectutes the health checks and save the result in DB.

func MakeInfluxJob

func MakeInfluxJob(influx InfluxHealthChecker, healthCheckValidity time.Duration, cockroach Cockroach) (*job.Job, error)

MakeInfluxJob creates the job that periodically exectutes the health checks and save the result in DB.

func MakeJaegerJob

func MakeJaegerJob(jaeger JaegerHealthChecker, healthCheckValidity time.Duration, cockroach Cockroach) (*job.Job, error)

MakeJaegerJob creates the job that periodically exectutes the health checks and save the result in DB.

func MakeRedisJob

func MakeRedisJob(redis RedisHealthChecker, healthCheckValidity time.Duration, cockroach Cockroach) (*job.Job, error)

MakeRedisJob creates the job that periodically exectutes the health checks and save the result in DB.

func MakeSentryJob

func MakeSentryJob(sentry SentryHealthChecker, healthCheckValidity time.Duration, cockroach Cockroach) (*job.Job, error)

MakeSentryJob creates the job that periodically exectutes the health checks and save the result in DB.

Types

type Cockroach

type Cockroach interface {
	Update(unit string, validity time.Duration, jsonReports json.RawMessage) error
	Clean() error
}

Cockroach is the interface of the module that stores the health reports in the DB.

type ElasticsearchClient

type ElasticsearchClient interface {
	ListIndexes() ([]client.IndexRepresentation, error)
	DeleteIndex(string) error
}

type ElasticsearchHealthChecker

type ElasticsearchHealthChecker interface {
	HealthChecks(context.Context) []health.ElasticsearchReport
}

ElasticsearchHealthChecker is the interface of the elasticsearch health check module.

type Flaki

type Flaki interface {
	NextValidIDString() string
}

Flaki is the interface of the IDs generator.

type FlakiHealthChecker

type FlakiHealthChecker interface {
	HealthChecks(context.Context) []common.FlakiReport
}

FlakiHealthChecker is the interface of the flaki health check module.

type InfluxHealthChecker

type InfluxHealthChecker interface {
	HealthChecks(context.Context) []common.InfluxReport
}

InfluxHealthChecker is the interface of the influx health check module.

type JaegerHealthChecker

type JaegerHealthChecker interface {
	HealthChecks(context.Context) []common.JaegerReport
}

JaegerHealthChecker is the interface of the jaeger health check module.

type RedisHealthChecker

type RedisHealthChecker interface {
	HealthChecks(context.Context) []common.RedisReport
}

RedisHealthChecker is the interface of the redis health check module.

type SentryHealthChecker

type SentryHealthChecker interface {
	HealthChecks(context.Context) []common.SentryReport
}

SentryHealthChecker is the interface of the sentry health check module.