 Documentation
      ¶
      Documentation
      ¶
    
    
  
    
  
    Index ¶
- Constants
- func NotifyFrom(conf notify.Config, m *SourceManager, l *logger.Logger) error
- func Start(conf Config) error
- type APIConfig
- type BackendConfig
- type Cache
- type CacheObject
- type Config
- type Core
- type PathObject
- type PopulateStats
- type RunInfo
- type RunTiming
- type SchedulerState
- type SchedulerTask
- type Source
- type SourceManager
- type WorkerDump
- type WorkerState
- type YAMLKey
Constants ¶
      View Source
      
  
    const ( MinAuthInterval = 5 * time.Second ExpiredRetryInterval = 5 * time.Minute )
      View Source
      
  
const ( //WorkerStateIdle means the worker is currently waiting for a task WorkerStateIdle = iota //WorkerStateRunning means the worker is currently running a task WorkerStateRunning //WorkerStateScheduling means the worker is currently scheduling a future task WorkerStateScheduling )
Variables ¶
This section is empty.
Functions ¶
func NotifyFrom ¶
Types ¶
type BackendConfig ¶
type Cache ¶
type Cache struct {
	// contains filtered or unexported fields
}
    Cache stores all the certificate data.
func (*Cache) ApplyDiff ¶
ApplyDiff calculates a diff between o and n, and then atomically inserts things new to "n" and deletes things from "o" that are no longer in "n".
func (*Cache) Map ¶
func (c *Cache) Map() map[string]CacheObject
func (*Cache) Merge ¶
func (c *Cache) Merge(key string, obj CacheObject)
func (*Cache) Store ¶
func (c *Cache) Store(key string, value CacheObject)
type CacheObject ¶
type CacheObject struct {
	Subject  pkix.Name
	NotAfter time.Time
	Paths    []PathObject
}
    type Config ¶
type Config struct {
	Backends      []BackendConfig `yaml:"backends"`
	Server        APIConfig       `yaml:"server"`
	Notifications notify.Config   `yaml:"notifications"`
}
    func ParseConfig ¶
type PathObject ¶
func (PathObject) LessThan ¶
func (lhs PathObject) LessThan(rhs PathObject) bool
type PopulateStats ¶
type SchedulerState ¶
type SchedulerState struct {
	Running []SchedulerTask `json:"running"`
	Pending []SchedulerTask `json:"pending"`
	Workers []WorkerDump    `json:"workers"`
}
    func (SchedulerState) String ¶
func (s SchedulerState) String() string
type SchedulerTask ¶
type Source ¶
func (*Source) CalcNextAuth ¶
CalcNextAuth returns the time of the next authentication to attempt. The second return value is true if this should never be scheduled again
func (*Source) CalcNextRefresh ¶
type SourceManager ¶
type SourceManager struct {
	// contains filtered or unexported fields
}
    func NewSourceManager ¶
func NewSourceManager(sources []Source, log *logger.Logger) *SourceManager
func (*SourceManager) BackgroundScheduler ¶
func (s *SourceManager) BackgroundScheduler() error
func (*SourceManager) Data ¶
func (s *SourceManager) Data() doomsday.CacheItems
func (*SourceManager) RefreshAll ¶
func (s *SourceManager) RefreshAll()
func (*SourceManager) SchedulerState ¶
func (s *SourceManager) SchedulerState() SchedulerState
type WorkerDump ¶
type WorkerState ¶
type WorkerState uint
WorkerState is the current thing the worker is doing. i.e. idle vs running
func (WorkerState) String ¶
func (w WorkerState) String() string
       Source Files
      ¶
      Source Files
      ¶
    
   Click to show internal directories. 
   Click to hide internal directories.