cacheproxy

Documentation

Index

• type Service
  • func NewService(base configuration.Service) (*Service, error)
  • 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) ResolveComponentQuery(query *componentcfg.Query) (resolved *componentcfg.Query, err error)
  • func (s Service) SetRuntimeEntry(component string, key string, value string) error

Types

type Service

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

Implements a cache proxy Service for the configuration system. Only DetectorForHost/DetectorsForHosts are cached, all other calls are passed through.

func NewService

func NewService(base configuration.Service) (*Service, error)

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

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

func (s Service) ResolveComponentQuery(query *componentcfg.Query) (resolved *componentcfg.Query, err error)

func (Service) SetRuntimeEntry

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