remote

Index ¶

• Constants
• Variables
• func DetectorInventoryToPbDetectorInventory(inventory map[string][]string) map[string]*apricotpb.DetectorInventoryResponse
• func NewServer(service configuration.Service) *grpc.Server
• func NewService(configUri string) (svc configuration.Service, err error)
• func PbDetectorInventoryToDetectorInventory(inventory map[string]*apricotpb.DetectorInventoryResponse) map[string][]string
• type RemoteService
• • func (c *RemoteService) GetAndProcessComponentConfiguration(query *componentcfg.Query, varStack map[string]string) (payload string, err error)
  • func (c *RemoteService) GetCRUCardsForHost(hostname string) (cards string, err error)
  • func (c *RemoteService) GetComponentConfiguration(query *componentcfg.Query) (payload string, err error)
  • func (c *RemoteService) GetComponentConfigurationWithLastIndex(query *componentcfg.Query) (payload string, lastIndex uint64, err error)
  • func (c *RemoteService) GetDefaults() map[string]string
  • func (c *RemoteService) GetDetectorForHost(hostname string) (payload string, err error)
  • func (c *RemoteService) GetDetectorsForHosts(hosts []string) (payload []string, err error)
  • func (c *RemoteService) GetDetectorsInventory() (inventory map[string][]string, err error)
  • func (c *RemoteService) GetEndpointsForCRUCard(hostname, cardSerial string) (cards string, err error)
  • func (c *RemoteService) GetHostInventory(detector string) (hosts []string, err error)
  • func (c *RemoteService) GetRuntimeEntries(component string) (payload map[string]string, err error)
  • func (c *RemoteService) GetRuntimeEntry(component string, key string) (payload string, err error)
  • func (c *RemoteService) GetVars() map[string]string
  • func (c *RemoteService) ImportComponentConfiguration(query *componentcfg.Query, payload string, newComponent bool, ...) (existingComponentUpdated bool, existingEntryUpdated bool, newTimestamp int64, ...)
  • func (c *RemoteService) InvalidateComponentTemplateCache()
  • func (c *RemoteService) ListComponentEntries(query *componentcfg.EntriesQuery, showLatestTimestamp bool) (entries []string, err error)
  • func (c *RemoteService) ListComponentEntryHistory(query *componentcfg.Query) (entries []string, err error)
  • func (c *RemoteService) ListComponents() (components []string, err error)
  • func (c *RemoteService) ListDetectors(getAll bool) (detectors []string, err error)
  • func (c *RemoteService) ListRuntimeEntries(component string) (payload []string, err error)
  • func (c *RemoteService) NewRunNumber() (runNumber uint32, err error)
  • func (c *RemoteService) RawGetRecursive(path string) (payload string, err error)
  • func (c *RemoteService) ResolveComponentQuery(query *componentcfg.Query) (resolved *componentcfg.Query, err error)
  • func (c *RemoteService) SetRuntimeEntry(component string, key string, value string) (err error)
• type RpcServer
• • func (m *RpcServer) GetCRUCardsForHost(_ context.Context, request *apricotpb.HostRequest) (*apricotpb.CRUCardsResponse, error)
  • func (m *RpcServer) GetComponentConfiguration(_ context.Context, request *apricotpb.ComponentRequest) (*apricotpb.ComponentResponse, error)
  • func (m *RpcServer) GetComponentConfigurationWithLastIndex(_ context.Context, request *apricotpb.ComponentRequest) (*apricotpb.ComponentResponseWithLastIndex, error)
  • func (m *RpcServer) GetDefaults(_ context.Context, _ *apricotpb.Empty) (*apricotpb.StringMap, error)
  • func (m *RpcServer) GetDetectorForHost(_ context.Context, request *apricotpb.HostRequest) (*apricotpb.DetectorResponse, error)
  • func (m *RpcServer) GetDetectorsForHosts(_ context.Context, request *apricotpb.HostsRequest) (*apricotpb.DetectorsResponse, error)
  • func (m *RpcServer) GetDetectorsInventory(_ context.Context, _ *apricotpb.Empty) (*apricotpb.DetectorEntriesResponse, error)
  • func (m *RpcServer) GetEndpointsForCRUCard(_ context.Context, request *apricotpb.CardRequest) (*apricotpb.CRUCardEndpointResponse, error)
  • func (m *RpcServer) GetHostInventory(_ context.Context, request *apricotpb.HostGetRequest) (*apricotpb.HostEntriesResponse, error)
  • func (m *RpcServer) GetRuntimeEntries(_ context.Context, request *apricotpb.GetRuntimeEntriesRequest) (*apricotpb.StringMap, error)
  • func (m *RpcServer) GetRuntimeEntry(_ context.Context, request *apricotpb.GetRuntimeEntryRequest) (*apricotpb.ComponentResponse, error)
  • func (m *RpcServer) GetVars(_ context.Context, _ *apricotpb.Empty) (*apricotpb.StringMap, error)
  • func (m *RpcServer) ImportComponentConfiguration(_ context.Context, request *apricotpb.ImportComponentConfigurationRequest) (*apricotpb.ImportComponentConfigurationResponse, error)
  • func (m *RpcServer) InvalidateComponentTemplateCache(_ context.Context, _ *apricotpb.Empty) (*apricotpb.Empty, error)
  • func (m *RpcServer) ListComponentEntries(_ context.Context, request *apricotpb.ListComponentEntriesRequest) (*apricotpb.ComponentEntriesResponse, error)
  • func (m *RpcServer) ListComponentEntryHistory(_ context.Context, query *apricotpb.ComponentQuery) (*apricotpb.ComponentEntriesResponse, error)
  • func (m *RpcServer) ListComponents(_ context.Context, _ *apricotpb.Empty) (*apricotpb.ComponentEntriesResponse, error)
  • func (m *RpcServer) ListDetectors(_ context.Context, request *apricotpb.DetectorsRequest) (*apricotpb.DetectorsResponse, error)
  • func (m *RpcServer) ListRuntimeEntries(_ context.Context, request *apricotpb.ListRuntimeEntriesRequest) (*apricotpb.ComponentEntriesResponse, error)
  • func (m *RpcServer) NewRunNumber(_ context.Context, _ *apricotpb.Empty) (*apricotpb.RunNumberResponse, error)
  • func (m *RpcServer) RawGetRecursive(_ context.Context, request *apricotpb.RawGetRecursiveRequest) (*apricotpb.ComponentResponse, error)
  • func (m *RpcServer) ResolveComponentQuery(_ context.Context, request *apricotpb.ComponentQuery) (*apricotpb.ComponentQuery, error)
  • func (m *RpcServer) SetRuntimeEntry(_ context.Context, request *apricotpb.SetRuntimeEntryRequest) (*apricotpb.Empty, error)