config

Documentation

Index

• Variables
• func FindPlan(cfg *v1.Config, planID string) *v1.Plan
• func FindRepo(cfg *v1.Config, repoID string) *v1.Repo
• func FindRepoByGUID(cfg *v1.Config, guid string) *v1.Repo
• func NewDefaultConfig() *v1.Config
• func ValidateConfig(c *v1.Config) error
• type CachingValidatingStore
  • func (c *CachingValidatingStore) Get() (*v1.Config, error)
  • func (c *CachingValidatingStore) Update(config *v1.Config) error
• type ConfigManager
  • func (m *ConfigManager) Get() (*v1.Config, error)
  • func (m *ConfigManager) StopWatching(ch <-chan struct{}) bool
  • func (m *ConfigManager) Update(config *v1.Config) error
  • func (m *ConfigManager) Watch() <-chan struct{}
• type ConfigStore
• type JsonFileStore
  • func (f *JsonFileStore) Get() (*v1.Config, error)
  • func (f *JsonFileStore) Update(config *v1.Config) error
• type MemoryStore
  • func (c *MemoryStore) Get() (*v1.Config, error)
  • func (c *MemoryStore) Update(config *v1.Config) error

Variables

var ErrConfigNotFound = fmt.Errorf("config not found")

Functions

func FindPlan

func FindPlan(cfg *v1.Config, planID string) *v1.Plan

func FindRepo

func FindRepo(cfg *v1.Config, repoID string) *v1.Repo

func FindRepoByGUID

func FindRepoByGUID(cfg *v1.Config, guid string) *v1.Repo

func NewDefaultConfig

func NewDefaultConfig() *v1.Config

func ValidateConfig

func ValidateConfig(c *v1.Config) error

Types

type CachingValidatingStore

type CachingValidatingStore struct {
	ConfigStore
	// contains filtered or unexported fields
}

TODO: merge caching validating store functions into config manager

func (*CachingValidatingStore) Get

func (c *CachingValidatingStore) Get() (*v1.Config, error)

func (*CachingValidatingStore) Update

func (c *CachingValidatingStore) Update(config *v1.Config) error

type ConfigManager

type ConfigManager struct {
	Store ConfigStore
	// contains filtered or unexported fields
}

func (*ConfigManager) Get

func (m *ConfigManager) Get() (*v1.Config, error)

func (*ConfigManager) StopWatching

func (m *ConfigManager) StopWatching(ch <-chan struct{}) bool

func (*ConfigManager) Update

func (m *ConfigManager) Update(config *v1.Config) error

func (*ConfigManager) Watch

func (m *ConfigManager) Watch() <-chan struct{}

type ConfigStore

type ConfigStore interface {
	Get() (*v1.Config, error)
	Update(config *v1.Config) error
}

type JsonFileStore

type JsonFileStore struct {
	Path string
	// contains filtered or unexported fields
}

func (*JsonFileStore) Get

func (f *JsonFileStore) Get() (*v1.Config, error)

func (*JsonFileStore) Update

func (f *JsonFileStore) Update(config *v1.Config) error

type MemoryStore

type MemoryStore struct {
	Config *v1.Config
	// contains filtered or unexported fields
}

func (*MemoryStore) Get

func (c *MemoryStore) Get() (*v1.Config, error)

func (*MemoryStore) Update

func (c *MemoryStore) Update(config *v1.Config) error