repository

Documentation

Index

• type ConfigMapClient
• type DoguConfigRepository
  • func NewDoguConfigRepository(client ConfigMapClient) *DoguConfigRepository
  • func NewSensitiveDoguConfigRepository(client SecretClient) *DoguConfigRepository
  • func (dcr DoguConfigRepository) Create(ctx context.Context, doguConfig config.DoguConfig) (config.DoguConfig, error)
  • func (dcr DoguConfigRepository) Delete(ctx context.Context, name dogu.SimpleName) error
  • func (dcr DoguConfigRepository) Get(ctx context.Context, name dogu.SimpleName) (config.DoguConfig, error)
  • func (dcr DoguConfigRepository) SaveOrMerge(ctx context.Context, doguConfig config.DoguConfig) (config.DoguConfig, error)
  • func (dcr DoguConfigRepository) Update(ctx context.Context, doguConfig config.DoguConfig) (config.DoguConfig, error)
  • func (dcr DoguConfigRepository) Watch(ctx context.Context, dName dogu.SimpleName, filters ...config.WatchFilter) (<-chan DoguConfigWatchResult, error)
• type DoguConfigWatchResult
• type GlobalConfigRepository
  • func NewGlobalConfigRepository(client ConfigMapClient) *GlobalConfigRepository
  • func (gcr GlobalConfigRepository) Create(ctx context.Context, globalConfig config.GlobalConfig) (config.GlobalConfig, error)
  • func (gcr GlobalConfigRepository) Delete(ctx context.Context) error
  • func (gcr GlobalConfigRepository) Get(ctx context.Context) (config.GlobalConfig, error)
  • func (gcr GlobalConfigRepository) SaveOrMerge(ctx context.Context, globalConfig config.GlobalConfig) (config.GlobalConfig, error)
  • func (gcr GlobalConfigRepository) Update(ctx context.Context, globalConfig config.GlobalConfig) (config.GlobalConfig, error)
  • func (gcr GlobalConfigRepository) Watch(ctx context.Context, filters ...config.WatchFilter) (<-chan GlobalConfigWatchResult, error)
• type GlobalConfigWatchResult
• type MaintenanceModeAdapter
  • func NewMaintenanceModeAdapter(owner string, client ConfigMapClient) *MaintenanceModeAdapter
  • func (mma *MaintenanceModeAdapter) Activate(ctx context.Context, content MaintenanceModeDescription) error
  • func (mma *MaintenanceModeAdapter) Deactivate(ctx context.Context) error
• type MaintenanceModeDescription
• type SecretClient

Types

type ConfigMapClient

type ConfigMapClient interface {
	corev1client.ConfigMapInterface
}

type DoguConfigRepository

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

func NewDoguConfigRepository

func NewDoguConfigRepository(client ConfigMapClient) *DoguConfigRepository

func NewSensitiveDoguConfigRepository

func NewSensitiveDoguConfigRepository(client SecretClient) *DoguConfigRepository

func (DoguConfigRepository) Create

func (dcr DoguConfigRepository) Create(ctx context.Context, doguConfig config.DoguConfig) (config.DoguConfig, error)

func (DoguConfigRepository) Delete

func (dcr DoguConfigRepository) Delete(ctx context.Context, name dogu.SimpleName) error

func (DoguConfigRepository) Get

func (dcr DoguConfigRepository) Get(ctx context.Context, name dogu.SimpleName) (config.DoguConfig, error)

func (DoguConfigRepository) SaveOrMerge

func (dcr DoguConfigRepository) SaveOrMerge(ctx context.Context, doguConfig config.DoguConfig) (config.DoguConfig, error)

func (DoguConfigRepository) Update

func (dcr DoguConfigRepository) Update(ctx context.Context, doguConfig config.DoguConfig) (config.DoguConfig, error)

func (DoguConfigRepository) Watch

func (dcr DoguConfigRepository) Watch(ctx context.Context, dName dogu.SimpleName, filters ...config.WatchFilter) (<-chan DoguConfigWatchResult, error)

type DoguConfigWatchResult

type DoguConfigWatchResult struct {
	PrevState config.DoguConfig
	NewState  config.DoguConfig
	Err       error
}

type GlobalConfigRepository

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

func NewGlobalConfigRepository

func NewGlobalConfigRepository(client ConfigMapClient) *GlobalConfigRepository

func (GlobalConfigRepository) Create

func (gcr GlobalConfigRepository) Create(ctx context.Context, globalConfig config.GlobalConfig) (config.GlobalConfig, error)

func (GlobalConfigRepository) Delete

func (gcr GlobalConfigRepository) Delete(ctx context.Context) error

func (GlobalConfigRepository) Get

func (gcr GlobalConfigRepository) Get(ctx context.Context) (config.GlobalConfig, error)

func (GlobalConfigRepository) SaveOrMerge

func (gcr GlobalConfigRepository) SaveOrMerge(ctx context.Context, globalConfig config.GlobalConfig) (config.GlobalConfig, error)

func (GlobalConfigRepository) Update

func (gcr GlobalConfigRepository) Update(ctx context.Context, globalConfig config.GlobalConfig) (config.GlobalConfig, error)

func (GlobalConfigRepository) Watch

func (gcr GlobalConfigRepository) Watch(ctx context.Context, filters ...config.WatchFilter) (<-chan GlobalConfigWatchResult, error)

type GlobalConfigWatchResult

type GlobalConfigWatchResult struct {
	PrevState config.GlobalConfig
	NewState  config.GlobalConfig
	Err       error
}

type MaintenanceModeAdapter

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

func NewMaintenanceModeAdapter

func NewMaintenanceModeAdapter(owner string, client ConfigMapClient) *MaintenanceModeAdapter

NewMaintenanceModeAdapter creates a new adapter to handel the maintenance mode

func (*MaintenanceModeAdapter) Activate

func (mma *MaintenanceModeAdapter) Activate(ctx context.Context, content MaintenanceModeDescription) error

Activate enables the maintenance mode and blocks the execution until the maintenance mode is activated. You can set timeouts via the go context. ConflictError if another component already activated the maintenance mode ConnectionError at any connection issues Generic Error at any other issue

func (*MaintenanceModeAdapter) Deactivate

func (mma *MaintenanceModeAdapter) Deactivate(ctx context.Context) error

Deactivate disables the maintenance mode if it is active. ConflictError if another component activated the maintenance mode ConnectionError at any connection issues Generic Error at any other issue

type MaintenanceModeDescription

type MaintenanceModeDescription struct {
	Title string
	Text  string
}

MaintenanceModeDescription contains data that gets displayed when the maintenance mode is active.

type SecretClient

type SecretClient interface {
	corev1client.SecretInterface
}