confsys

Documentation

Index

• type Service
  • func Instance() *Service
  • func (s *Service) GenerateWorkflowDescriptor(wfPath string, vars map[string]string) string
  • func (s *Service) GetComponentConfiguration(path string) (payload string, err error)
  • func (s *Service) GetConsulPath() string
  • func (s *Service) GetDefaultRepo() (defaultRepo string, err error)
  • func (s *Service) GetDefaultRevision() (defaultRevision string, err error)
  • func (s *Service) GetDefaults() map[string]string
  • func (s *Service) GetMesosFID() (fidValue string, err error)
  • func (s *Service) GetROSource() configuration.ROSource
  • func (s *Service) GetRepoDefaultRevisions() (map[string]string, error)
  • func (s *Service) GetReposPath() string
  • func (s *Service) GetVars() map[string]string
  • func (s *Service) NewDefaultRepo(defaultRepo string) error
  • func (s *Service) NewDefaultRevision(defaultRevision string) error
  • func (s *Service) NewMesosFID(fidValue string) error
  • func (s *Service) NewRunNumber() (runNumber uint32, err error)
  • func (s *Service) RefreshRepositories()
  • func (s *Service) SetRepoDefaultRevisions(defaultRevisions map[string]string) error

Types

type Service

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

func Instance

func Instance() *Service

func (*Service) GenerateWorkflowDescriptor

func (s *Service) GenerateWorkflowDescriptor(wfPath string, vars map[string]string) string

Returns a YAML file OR even a structure made of Roles or Nodes with: import() functions already computed and resolved vars inserted

func (*Service) GetComponentConfiguration

func (s *Service) GetComponentConfiguration(path string) (payload string, err error)

func (*Service) GetConsulPath

func (s *Service) GetConsulPath() string

func (*Service) GetDefaultRepo

func (s *Service) GetDefaultRepo() (defaultRepo string, err error)

func (*Service) GetDefaultRevision

func (s *Service) GetDefaultRevision() (defaultRevision string, err error)

func (*Service) GetDefaults

func (s *Service) GetDefaults() map[string]string

maybe this one shouldn't exist at all, because vars should get inserted response: but not all of them! some vars will likely only get parsed at deployment time i.e. right before pushing TaskInfos

func (*Service) GetMesosFID

func (s *Service) GetMesosFID() (fidValue string, err error)

Retrieve Mesos Framework ID from Consul, or local file.

func (*Service) GetROSource

func (s *Service) GetROSource() configuration.ROSource

func (*Service) GetRepoDefaultRevisions

func (s *Service) GetRepoDefaultRevisions() (map[string]string, error)

func (*Service) GetReposPath

func (s *Service) GetReposPath() string

func (*Service) GetVars

func (s *Service) GetVars() map[string]string

func (*Service) NewDefaultRepo

func (s *Service) NewDefaultRepo(defaultRepo string) error

func (*Service) NewDefaultRevision

func (s *Service) NewDefaultRevision(defaultRevision string) error

func (*Service) NewMesosFID

func (s *Service) NewMesosFID(fidValue string) error

Persist Mesos Framework ID by saving to Consul, or to a local file.

func (*Service) NewRunNumber

func (s *Service) NewRunNumber() (runNumber uint32, err error)

func (*Service) RefreshRepositories

func (s *Service) RefreshRepositories()

Or maybe even "RefreshConfig" which will refresh all the things that happen to be runtime-refreshable

func (*Service) SetRepoDefaultRevisions

func (s *Service) SetRepoDefaultRevisions(defaultRevisions map[string]string) error