worker

Documentation

Index

• func NewPostgresDBValidator() *postgresDBvalidator
• type CustomLogger
  • func NewLogger() *CustomLogger
  • func (c *CustomLogger) Error(message string)
  • func (c *CustomLogger) Fatal(message string)
  • func (c *CustomLogger) Info(message string)
• type DBWorker
  • func NewDBWorker(r core.DBCreateGetter, c core.CredentialsStorer, m core.MetricsExporterCreator, ...) *DBWorker
  • func (w *DBWorker) OnCreate(obj interface{})
  • func (w *DBWorker) OnDelete(obj interface{})
  • func (w *DBWorker) OnUpdate(obj interface{}, newObj interface{})
• type DBWorkerConfig
  • func NewConfig(c int, s string) *DBWorkerConfig
• type Logger
• type Optimus
  • func NewOptimus() *Optimus
  • func (o *Optimus) CRDToRequest(crd *v1alpha1.PostgresDB) *database.Request
• type PostgresDBValidator
• type Transformer

Functions

func NewPostgresDBValidator

func NewPostgresDBValidator() *postgresDBvalidator

Types

type CustomLogger

type CustomLogger struct{}

func NewLogger

func NewLogger() *CustomLogger

func (*CustomLogger) Error

func (c *CustomLogger) Error(message string)

func (*CustomLogger) Fatal

func (c *CustomLogger) Fatal(message string)

func (*CustomLogger) Info

func (c *CustomLogger) Info(message string)

type DBWorker

type DBWorker struct {
	*DBWorkerConfig
	PostgresDBValidator
	Transformer
	Logger
	core.DBCreateGetter
	core.StatusUpdater
	core.CredentialsStorer
	core.MetricsExporterCreator
}

func NewDBWorker

func NewDBWorker(
	r core.DBCreateGetter,
	c core.CredentialsStorer,
	m core.MetricsExporterCreator,
	cfg *DBWorkerConfig,
	p PostgresDBValidator,
	l Logger,
	t Transformer,
	u core.StatusUpdater,
) *DBWorker

NewRDSWorker returns new DBWorker instance for handling change events on postgresDB crd

func (*DBWorker) OnCreate

func (w *DBWorker) OnCreate(obj interface{})

func (*DBWorker) OnDelete

func (w *DBWorker) OnDelete(obj interface{})

OnDelete handles delete event of postgresdb

func (*DBWorker) OnUpdate

func (w *DBWorker) OnUpdate(obj interface{}, newObj interface{})

OnUpdate handles update event of postgresdb

type DBWorkerConfig

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

func NewConfig

func NewConfig(c int, s string) *DBWorkerConfig

type Logger

type Logger interface {
	Error(message string)
	Info(message string)
	Fatal(message string)
}

type Optimus

type Optimus struct{}

func NewOptimus

func NewOptimus() *Optimus

func (*Optimus) CRDToRequest

func (o *Optimus) CRDToRequest(crd *v1alpha1.PostgresDB) *database.Request

type PostgresDBValidator

type PostgresDBValidator interface {
	Validate(crd *v1alpha1.PostgresDB) error
}

type Transformer

type Transformer interface {
	CRDToRequest(crd *v1alpha1.PostgresDB) *database.Request
}