(t *testing.T, limits overrides.Config)
| 1853 | } |
| 1854 | |
| 1855 | func setupDependencies(t *testing.T, limits overrides.Config) (Config, overrides.Service, dslog.Level, receiver.Middleware) { |
| 1856 | t.Helper() |
| 1857 | |
| 1858 | var distributorConfig Config |
| 1859 | |
| 1860 | overridesSvc, err := overrides.NewOverrides(limits, nil, prometheus.DefaultRegisterer) |
| 1861 | require.NoError(t, err) |
| 1862 | |
| 1863 | distributorConfig.MaxAttributeBytes = 1000 |
| 1864 | distributorConfig.DistributorRing.HeartbeatPeriod = 100 * time.Millisecond |
| 1865 | distributorConfig.DistributorRing.InstanceID = strconv.Itoa(rand.Int()) |
| 1866 | distributorConfig.DistributorRing.KVStore.Mock = nil |
| 1867 | distributorConfig.DistributorRing.InstanceInterfaceNames = []string{"eth0", "en0", "lo0"} |
| 1868 | |
| 1869 | l := dslog.Level{} |
| 1870 | _ = l.Set("error") |
| 1871 | mw := receiver.MultiTenancyMiddleware() |
| 1872 | |
| 1873 | return distributorConfig, overridesSvc, l, mw |
| 1874 | } |
| 1875 | |
| 1876 | type singlePartitionRingReader struct{} |
| 1877 |
no test coverage detected