manager

Documentation

Index

• type ConfigManager
  • func New[T any](repo Repository, initCfg T, scanInterval time.Duration) *ConfigManager[T]
  • func (m *ConfigManager[T]) GetConfig() T
  • func (m *ConfigManager[T]) LoadConfig(ctx context.Context) error
  • func (m *ConfigManager[T]) Run(ctx context.Context, wg *sync.WaitGroup) error
• type Repository

Types

type ConfigManager

type ConfigManager[T any] struct {
	// contains filtered or unexported fields
}

func New

func New[T any](repo Repository, initCfg T, scanInterval time.Duration) *ConfigManager[T]

func (*ConfigManager[T]) GetConfig

func (m *ConfigManager[T]) GetConfig() T

func (*ConfigManager[T]) LoadConfig

func (m *ConfigManager[T]) LoadConfig(ctx context.Context) error

func (*ConfigManager[T]) Run

func (m *ConfigManager[T]) Run(ctx context.Context, wg *sync.WaitGroup) error

type Repository

type Repository interface {
	UpdateConfig(ctx context.Context, value any) error
	GetConfig(ctx context.Context, obj, defaultValue any) error
}