interfaces

type ConfigManager interface {
	Get() *config.Config
	Reload() error
	OnReload(func(*config.Config))
}

type Logger interface {
	Info(msg string, args ...interface{})
	Error(msg string, args ...interface{})
	Debug(msg string, args ...interface{})
	Sync() error
}

type Processor interface {
	Start(ctx context.Context) error
	UpdateConfig(cfg *config.Config)
}

type Queue interface {
	Load() error
	Save() error
	Size() int
	Enqueue(item *model.Item) error
	Dequeue() *model.Item
	Requeue(item *model.Item, err error) error
}

type VaultClient interface {
	Close() error
}

type Watcher interface {
	Start(ctx context.Context) error
	UpdateConfig(cfg *config.Config) error
}