local

Documentation

Index

• func NewHttpService(service configuration.Service) (svr *http.Server)
• type Cards
• type HttpService
  • func (httpsvc *HttpService) ApiGetDetectorFlps(w http.ResponseWriter, r *http.Request)
  • func (httpsvc *HttpService) ApiGetDetectorsInventory(w http.ResponseWriter, r *http.Request)
  • func (httpsvc *HttpService) ApiGetFlps(w http.ResponseWriter, r *http.Request)
  • func (httpsvc *HttpService) ApiGetHostInventory(w http.ResponseWriter, r *http.Request, detector string)
  • func (httpsvc *HttpService) ApiPrintClusterInformation(w http.ResponseWriter, r *http.Request, hosts []string, ...)
• type Service
  • func NewService(uri string) (svc *Service, err error)
  • func (s *Service) GenerateWorkflowDescriptor(wfPath string, vars map[string]string) string
  • func (s *Service) GetAndProcessComponentConfiguration(query *componentcfg.Query, varStack map[string]string) (payload string, err error)
  • func (s *Service) GetCRUCardsForHost(hostname string) (string, error)
  • func (s *Service) GetComponentConfiguration(query *componentcfg.Query) (payload string, err error)
  • func (s *Service) GetComponentConfigurationWithLastIndex(query *componentcfg.Query) (payload string, lastIndex uint64, err error)
  • func (s *Service) GetDefaults() map[string]string
  • func (s *Service) GetDetectorForHost(hostname string) (string, error)
  • func (s *Service) GetDetectorsForHosts(hosts []string) ([]string, error)
  • func (s *Service) GetDetectorsInventory() (inventory map[string][]string, err error)
  • func (s *Service) GetEndpointsForCRUCard(hostname, cardSerial string) (string, error)
  • func (s *Service) GetHostInventory(detector string) (hosts []string, err error)
  • func (s *Service) GetRuntimeEntry(component string, key string) (string, error)
  • func (s *Service) GetVars() map[string]string
  • func (s *Service) ImportComponentConfiguration(query *componentcfg.Query, payload string, newComponent bool, ...) (existingComponentUpdated bool, existingEntryUpdated bool, newTimestamp int64, ...)
  • func (s *Service) ListComponentEntries(query *componentcfg.EntriesQuery, showLatestTimestamp bool) (entries []string, err error)
  • func (s *Service) ListComponentEntryHistory(query *componentcfg.Query) (entries []string, err error)
  • func (s *Service) ListComponents() (components []string, err error)
  • func (s *Service) ListDetectors(getAll bool) (detectors []string, err error)
  • func (s *Service) ListRuntimeEntries(component string) ([]string, error)
  • func (s *Service) NewRunNumber() (runNumber uint32, err error)
  • func (s *Service) RawGetRecursive(path string) (string, error)
  • func (s *Service) SetRuntimeEntry(component string, key string, value string) error

Functions

func NewHttpService

func NewHttpService(service configuration.Service) (svr *http.Server)

Types

type Cards

type Cards struct {
	Type             string `json:"type"`
	PciAddress       string `json:"pciAddress"`
	Serial           string `json:"serial"`
	Endpoint         string `json:"endpoint"`
	Numa             string `json:"numa"`
	Firware          string `json:"firmware"`
	UserLogicVersion string `json:"userLogicVersion"`
}

type HttpService

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

func (*HttpService) ApiGetDetectorFlps

func (httpsvc *HttpService) ApiGetDetectorFlps(w http.ResponseWriter, r *http.Request)

func (*HttpService) ApiGetDetectorsInventory

func (httpsvc *HttpService) ApiGetDetectorsInventory(w http.ResponseWriter, r *http.Request)

func (*HttpService) ApiGetFlps

func (httpsvc *HttpService) ApiGetFlps(w http.ResponseWriter, r *http.Request)

func (*HttpService) ApiGetHostInventory

func (httpsvc *HttpService) ApiGetHostInventory(w http.ResponseWriter, r *http.Request, detector string)

func (*HttpService) ApiPrintClusterInformation

func (httpsvc *HttpService) ApiPrintClusterInformation(w http.ResponseWriter, r *http.Request, hosts []string, inventory map[string][]string)

type Service

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

func NewService

func NewService(uri string) (svc *Service, err error)

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) GetAndProcessComponentConfiguration

func (s *Service) GetAndProcessComponentConfiguration(query *componentcfg.Query, varStack map[string]string) (payload string, err error)

func (*Service) GetCRUCardsForHost

func (s *Service) GetCRUCardsForHost(hostname string) (string, error)

func (*Service) GetComponentConfiguration

func (s *Service) GetComponentConfiguration(query *componentcfg.Query) (payload string, err error)

func (*Service) GetComponentConfigurationWithLastIndex

func (s *Service) GetComponentConfigurationWithLastIndex(query *componentcfg.Query) (payload string, lastIndex uint64, 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) GetDetectorForHost

func (s *Service) GetDetectorForHost(hostname string) (string, error)

func (*Service) GetDetectorsForHosts

func (s *Service) GetDetectorsForHosts(hosts []string) ([]string, error)

func (*Service) GetDetectorsInventory

func (s *Service) GetDetectorsInventory() (inventory map[string][]string, err error)

func (*Service) GetEndpointsForCRUCard

func (s *Service) GetEndpointsForCRUCard(hostname, cardSerial string) (string, error)

func (*Service) GetHostInventory

func (s *Service) GetHostInventory(detector string) (hosts []string, err error)

func (*Service) GetRuntimeEntry

func (s *Service) GetRuntimeEntry(component string, key string) (string, error)

func (*Service) GetVars

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

func (*Service) ImportComponentConfiguration

func (s *Service) ImportComponentConfiguration(query *componentcfg.Query, payload string, newComponent bool, useVersioning bool) (existingComponentUpdated bool, existingEntryUpdated bool, newTimestamp int64, err error)

func (*Service) ListComponentEntries

func (s *Service) ListComponentEntries(query *componentcfg.EntriesQuery, showLatestTimestamp bool) (entries []string, err error)

func (*Service) ListComponentEntryHistory

func (s *Service) ListComponentEntryHistory(query *componentcfg.Query) (entries []string, err error)

func (*Service) ListComponents

func (s *Service) ListComponents() (components []string, err error)

func (*Service) ListDetectors

func (s *Service) ListDetectors(getAll bool) (detectors []string, err error)

func (*Service) ListRuntimeEntries

func (s *Service) ListRuntimeEntries(component string) ([]string, error)

func (*Service) NewRunNumber

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

func (*Service) RawGetRecursive

func (s *Service) RawGetRecursive(path string) (string, error)

func (*Service) SetRuntimeEntry

func (s *Service) SetRuntimeEntry(component string, key string, value string) error