Lines Matching refs:storeRef
166 stores map[string]*storeRef
200 stores: make(map[string]*storeRef),
207 type storeRef struct { struct
223 func (s *storeRef) Update(labelSets []storepb.LabelSet, minTime int64, maxTime int64, storeType com… argument
233 func (s *storeRef) StoreType() component.StoreAPI { argument
240 func (s *storeRef) LabelSets() []storepb.LabelSet { argument
266 func (s *storeRef) LabelSetsString() string { argument
294 func (s *storeRef) TimeRange() (mint int64, maxt int64) { argument
301 func (s *storeRef) String() string { argument
306 func (s *storeRef) Addr() string { argument
310 func (s *storeRef) Close() { argument
329 stores := make(map[string]*storeRef, len(s.stores))
387 …StoreSet) getHealthyStores(ctx context.Context, stores map[string]*storeRef) map[string]*storeRef {
390 healthyStores = make(map[string]*storeRef, len(stores))
417 s.updateStoreStatus(&storeRef{addr: addr}, err)
421 … st = &storeRef{StoreClient: storepb.NewStoreClient(conn), cc: conn, addr: addr, logger: s.logger}
449 func (s *StoreSet) updateStoreStatus(store *storeRef, err error) {
508 s.stores = map[string]*storeRef{}
511 func (s *StoreSet) cleanUpStoreStatuses(stores map[string]*storeRef) {