| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/pkg/storage/stores/shipper/compactor/retention/ |
| H A D | index_test.go | 25 …{"out of scope", schemaCfg, "index_" + indexFromTime(start.Time().Add(-24*time.Hour)), chunk.Perio…
26 …{"first table", schemaCfg, "index_" + indexFromTime(dayFromTime(start).Time.Time()), schemaCfg.Con…
27 …{"4 hour after first table", schemaCfg, "index_" + indexFromTime(dayFromTime(start).Time.Time().Ad…
28 …{"second schema", schemaCfg, "index_" + indexFromTime(dayFromTime(start.Add(28*time.Hour)).Time.Ti…
29 {"now", schemaCfg, "index_" + indexFromTime(time.Now()), schemaCfg.Configs[2], true},
|
| H A D | util_test.go | 43 schemaCfg = storage.SchemaConfig{ var
88 {"v9", schemaCfg.Configs[0].From.Time, schemaCfg.Configs[0]},
89 {"v10", schemaCfg.Configs[1].From.Time, schemaCfg.Configs[1]},
90 {"v11", schemaCfg.Configs[2].From.Time, schemaCfg.Configs[2]},
117 schemaCfg storage.SchemaConfig member
188 schemaCfg.SchemaConfig,
196 store, err := storage.NewStore(t.cfg, schemaCfg, chunkStore, nil)
222 require.NoError(t, schemaCfg.SchemaConfig.Validate())
245 schemaCfg.SchemaConfig,
253 store, err := storage.NewStore(config, schemaCfg, chunkStore, nil)
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/pkg/storage/chunk/storage/ |
| H A D | factory.go | 152 schemaCfg chunk.SchemaConfig,
189 err = schemaCfg.Load()
195 for _, s := range schemaCfg.Configs {
199 index, err := NewIndexClient(s.IndexType, cfg, schemaCfg, indexClientReg)
213 chunks, err := NewChunkClient(objectStoreType, cfg, schemaCfg, chunkClientReg)
251 return gcp.NewStorageClientV1(context.Background(), cfg.GCPStorageConfig, schemaCfg)
258 return cassandra.NewStorageClient(cfg.CassandraStorageConfig, schemaCfg, registerer)
262 return grpc.NewStorageClient(cfg.GrpcConfig, schemaCfg)
287 return gcp.NewBigtableObjectClient(context.Background(), cfg.GCPStorageConfig, schemaCfg)
295 return cassandra.NewObjectClient(cfg.CassandraStorageConfig, schemaCfg, registerer)
[all …]
|
| H A D | factory_test.go | 79 schemaCfg := chunk.SchemaConfig{}
141 indexClient, err := NewIndexClient(tc.indexClientName, cfg, schemaCfg, nil)
175 schemaCfg := chunk.DefaultSchemaConfig("cassandra", "v1", model.Now().Add(-7*24*time.Hour))
176 newSchemaCfg := schemaCfg.Configs[0]
180 schemaCfg.Configs = append(schemaCfg.Configs, newSchemaCfg)
193 store, err := NewStore(cfg, storeConfig, schemaCfg, limits, nil, nil, log.NewNopLogger())
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/pkg/chunk/storage/ |
| H A D | factory.go | 149 schemaCfg chunk.SchemaConfig,
186 err = schemaCfg.Load()
192 for _, s := range schemaCfg.Configs {
196 index, err := NewIndexClient(s.IndexType, cfg, schemaCfg, indexClientReg)
210 chunks, err := NewChunkClient(objectStoreType, cfg, schemaCfg, chunkClientReg)
248 return gcp.NewStorageClientV1(context.Background(), cfg.GCPStorageConfig, schemaCfg)
255 return cassandra.NewStorageClient(cfg.CassandraStorageConfig, schemaCfg, registerer)
259 return grpc.NewStorageClient(cfg.GrpcConfig, schemaCfg)
284 return gcp.NewBigtableObjectClient(context.Background(), cfg.GCPStorageConfig, schemaCfg)
292 return cassandra.NewObjectClient(cfg.CassandraStorageConfig, schemaCfg, registerer)
[all …]
|
| H A D | factory_test.go | 79 schemaCfg := chunk.SchemaConfig{}
141 indexClient, err := NewIndexClient(tc.indexClientName, cfg, schemaCfg, nil)
175 schemaCfg := chunk.DefaultSchemaConfig("cassandra", "v1", model.Now().Add(-7*24*time.Hour))
176 newSchemaCfg := schemaCfg.Configs[0]
180 schemaCfg.Configs = append(schemaCfg.Configs, newSchemaCfg)
193 store, err := NewStore(cfg, storeConfig, schemaCfg, limits, nil, nil, log.NewNopLogger())
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/cortexproject/cortex/pkg/chunk/storage/ |
| H A D | factory.go | 149 schemaCfg chunk.SchemaConfig,
186 err = schemaCfg.Load()
192 for _, s := range schemaCfg.Configs {
196 index, err := NewIndexClient(s.IndexType, cfg, schemaCfg, indexClientReg)
210 chunks, err := NewChunkClient(objectStoreType, cfg, schemaCfg, chunkClientReg)
248 return gcp.NewStorageClientV1(context.Background(), cfg.GCPStorageConfig, schemaCfg)
255 return cassandra.NewStorageClient(cfg.CassandraStorageConfig, schemaCfg, registerer)
259 return grpc.NewStorageClient(cfg.GrpcConfig, schemaCfg)
284 return gcp.NewBigtableObjectClient(context.Background(), cfg.GCPStorageConfig, schemaCfg)
292 return cassandra.NewObjectClient(cfg.CassandraStorageConfig, schemaCfg, registerer)
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/pkg/storage/chunk/gcp/ |
| H A D | bigtable_object_client.go | 19 schemaCfg chunk.SchemaConfig member
25 func NewBigtableObjectClient(ctx context.Context, cfg Config, schemaCfg chunk.SchemaConfig) (chunk.…
34 return newBigtableObjectClient(cfg, schemaCfg, client), nil
37 func newBigtableObjectClient(cfg Config, schemaCfg chunk.SchemaConfig, client *bigtable.Client) chu…
40 schemaCfg: schemaCfg,
59 tableName, err := s.schemaCfg.ChunkTableFor(chunks[i].From)
93 tableName, err := s.schemaCfg.ChunkTableFor(c.From)
174 tableName, err := s.schemaCfg.ChunkTableFor(chunkRef.From)
|
| H A D | bigtable_index_client.go | 66 schemaCfg chunk.SchemaConfig member
77 func NewStorageClientV1(ctx context.Context, cfg Config, schemaCfg chunk.SchemaConfig) (chunk.Index…
86 return newStorageClientV1(cfg, schemaCfg, client), nil
89 func newStorageClientV1(cfg Config, schemaCfg chunk.SchemaConfig, client *bigtable.Client) *storage…
93 schemaCfg: schemaCfg,
104 func NewStorageClientColumnKey(ctx context.Context, cfg Config, schemaCfg chunk.SchemaConfig) (chun…
113 return newStorageClientColumnKey(cfg, schemaCfg, client), nil
116 func newStorageClientColumnKey(cfg Config, schemaCfg chunk.SchemaConfig, client *bigtable.Client) *…
119 schemaCfg: schemaCfg,
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/pkg/chunk/gcp/ |
| H A D | bigtable_object_client.go | 18 schemaCfg chunk.SchemaConfig member
24 func NewBigtableObjectClient(ctx context.Context, cfg Config, schemaCfg chunk.SchemaConfig) (chunk.…
33 return newBigtableObjectClient(cfg, schemaCfg, client), nil
36 func newBigtableObjectClient(cfg Config, schemaCfg chunk.SchemaConfig, client *bigtable.Client) chu…
39 schemaCfg: schemaCfg,
58 tableName, err := s.schemaCfg.ChunkTableFor(chunks[i].From)
92 tableName, err := s.schemaCfg.ChunkTableFor(c.From)
173 tableName, err := s.schemaCfg.ChunkTableFor(chunkRef.From)
|
| H A D | bigtable_index_client.go | 66 schemaCfg chunk.SchemaConfig member
77 func NewStorageClientV1(ctx context.Context, cfg Config, schemaCfg chunk.SchemaConfig) (chunk.Index…
86 return newStorageClientV1(cfg, schemaCfg, client), nil
89 func newStorageClientV1(cfg Config, schemaCfg chunk.SchemaConfig, client *bigtable.Client) *storage…
93 schemaCfg: schemaCfg,
104 func NewStorageClientColumnKey(ctx context.Context, cfg Config, schemaCfg chunk.SchemaConfig) (chun…
113 return newStorageClientColumnKey(cfg, schemaCfg, client), nil
116 func newStorageClientColumnKey(cfg Config, schemaCfg chunk.SchemaConfig, client *bigtable.Client) *…
120 schemaCfg: schemaCfg,
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/cortexproject/cortex/pkg/chunk/gcp/ |
| H A D | bigtable_object_client.go | 18 schemaCfg chunk.SchemaConfig member
24 func NewBigtableObjectClient(ctx context.Context, cfg Config, schemaCfg chunk.SchemaConfig) (chunk.…
33 return newBigtableObjectClient(cfg, schemaCfg, client), nil
36 func newBigtableObjectClient(cfg Config, schemaCfg chunk.SchemaConfig, client *bigtable.Client) chu…
39 schemaCfg: schemaCfg,
58 tableName, err := s.schemaCfg.ChunkTableFor(chunks[i].From)
92 tableName, err := s.schemaCfg.ChunkTableFor(c.From)
173 tableName, err := s.schemaCfg.ChunkTableFor(chunkRef.From)
|
| H A D | bigtable_index_client.go | 66 schemaCfg chunk.SchemaConfig member
77 func NewStorageClientV1(ctx context.Context, cfg Config, schemaCfg chunk.SchemaConfig) (chunk.Index…
86 return newStorageClientV1(cfg, schemaCfg, client), nil
89 func newStorageClientV1(cfg Config, schemaCfg chunk.SchemaConfig, client *bigtable.Client) *storage…
93 schemaCfg: schemaCfg,
104 func NewStorageClientColumnKey(ctx context.Context, cfg Config, schemaCfg chunk.SchemaConfig) (chun…
113 return newStorageClientColumnKey(cfg, schemaCfg, client), nil
116 func newStorageClientColumnKey(cfg Config, schemaCfg chunk.SchemaConfig, client *bigtable.Client) *…
120 schemaCfg: schemaCfg,
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/pkg/chunk/grpc/ |
| H A D | storage_client.go | 14 schemaCfg chunk.SchemaConfig member
20 func NewStorageClient(cfg Config, schemaCfg chunk.SchemaConfig) (*StorageClient, error) {
26 schemaCfg: schemaCfg,
47 tableName, err := s.schemaCfg.ChunkTableFor(chunks[i].From)
84 chunkInfo.TableName, err = s.schemaCfg.ChunkTableFor(inputInfo.From)
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/cortexproject/cortex/pkg/chunk/grpc/ |
| H A D | storage_client.go | 14 schemaCfg chunk.SchemaConfig member
20 func NewStorageClient(cfg Config, schemaCfg chunk.SchemaConfig) (*StorageClient, error) {
26 schemaCfg: schemaCfg,
47 tableName, err := s.schemaCfg.ChunkTableFor(chunks[i].From)
84 chunkInfo.TableName, err = s.schemaCfg.ChunkTableFor(inputInfo.From)
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/pkg/storage/chunk/grpc/ |
| H A D | storage_client.go | 14 schemaCfg chunk.SchemaConfig member
20 func NewStorageClient(cfg Config, schemaCfg chunk.SchemaConfig) (*StorageClient, error) {
26 schemaCfg: schemaCfg,
47 tableName, err := s.schemaCfg.ChunkTableFor(chunks[i].From)
88 chunkInfo.TableName, err = s.schemaCfg.ChunkTableFor(inputInfo.From)
|
| /dports/sysutils/sensu-go/sensu-go-5.11.1/graphql/ |
| H A D | service.go | 214 schemaCfg := reg.schema.Config()
215 if schemaCfg.Query != nil {
216 queryType := findType(typeMap, schemaCfg.Query.Name())
217 schemaCfg.Query = queryType.(*graphql.Object)
219 if schemaCfg.Mutation != nil {
220 mutationType := findType(typeMap, schemaCfg.Mutation.Name())
221 schemaCfg.Mutation = mutationType.(*graphql.Object)
223 if schemaCfg.Subscription != nil {
224 subscriptionType := findType(typeMap, schemaCfg.Subscription.Name())
225 schemaCfg.Subscription = subscriptionType.(*graphql.Object)
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/pkg/storage/chunk/aws/ |
| H A D | fixtures.go | 44 schemaCfg: schemaConfig,
68 schemaCfg := testutils.DefaultSchemaConfig("aws")
87 schemaCfg: schemaCfg,
90 return storage, storage, table, schemaCfg, testutils.CloserFunc(func() error {
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/pkg/chunk/aws/ |
| H A D | fixtures.go | 44 schemaCfg: schemaConfig,
67 schemaCfg := testutils.DefaultSchemaConfig("aws")
86 schemaCfg: schemaCfg,
89 return storage, storage, table, schemaCfg, testutils.CloserFunc(func() error {
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/cortexproject/cortex/pkg/chunk/aws/ |
| H A D | fixtures.go | 44 schemaCfg: schemaConfig,
67 schemaCfg := testutils.DefaultSchemaConfig("aws")
86 schemaCfg: schemaCfg,
89 return storage, storage, table, schemaCfg, testutils.CloserFunc(func() error {
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/pkg/chunk/ |
| H A D | table_manager.go | 158 schemaCfg SchemaConfig member
168 func NewTableManager(cfg TableManagerConfig, schemaCfg SchemaConfig, maxChunkAge time.Duration, tab…
173 indexTablesPeriod := schemaCfg.Configs[len(schemaCfg.Configs)-1].IndexTables.Period
181 schemaCfg: schemaCfg,
350 for i, config := range m.schemaCfg.Configs {
368 if i+1 < len(m.schemaCfg.Configs) {
370 endTime = m.schemaCfg.Configs[i+1].From.Unix()
396 if i+1 < len(m.schemaCfg.Configs) {
397 nextFrom := m.schemaCfg.Configs[i+1].From.Time.Time()
447 for _, cfg := range m.schemaCfg.Configs {
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/pkg/storage/chunk/ |
| H A D | table_manager.go | 157 schemaCfg SchemaConfig member
167 func NewTableManager(cfg TableManagerConfig, schemaCfg SchemaConfig, maxChunkAge time.Duration, tab…
172 indexTablesPeriod := schemaCfg.Configs[len(schemaCfg.Configs)-1].IndexTables.Period
180 schemaCfg: schemaCfg,
348 for i, config := range m.schemaCfg.Configs {
366 if i+1 < len(m.schemaCfg.Configs) {
368 endTime = m.schemaCfg.Configs[i+1].From.Unix()
393 if i+1 < len(m.schemaCfg.Configs) {
394 nextFrom := m.schemaCfg.Configs[i+1].From.Time.Time()
444 for _, cfg := range m.schemaCfg.Configs {
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/cortexproject/cortex/pkg/chunk/ |
| H A D | table_manager.go | 158 schemaCfg SchemaConfig member
168 func NewTableManager(cfg TableManagerConfig, schemaCfg SchemaConfig, maxChunkAge time.Duration, tab…
173 indexTablesPeriod := schemaCfg.Configs[len(schemaCfg.Configs)-1].IndexTables.Period
181 schemaCfg: schemaCfg,
350 for i, config := range m.schemaCfg.Configs {
368 if i+1 < len(m.schemaCfg.Configs) {
370 endTime = m.schemaCfg.Configs[i+1].From.Unix()
396 if i+1 < len(m.schemaCfg.Configs) {
397 nextFrom := m.schemaCfg.Configs[i+1].From.Time.Time()
447 for _, cfg := range m.schemaCfg.Configs {
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/pkg/storage/chunk/cassandra/ |
| H A D | storage_client.go | 257 schemaCfg chunk.SchemaConfig member
264 func NewStorageClient(cfg Config, schemaCfg chunk.SchemaConfig, registerer prometheus.Registerer) (…
282 schemaCfg: schemaCfg,
445 schemaCfg chunk.SchemaConfig member
452 func NewObjectClient(cfg Config, schemaCfg chunk.SchemaConfig, registerer prometheus.Registerer) (*…
470 schemaCfg: schemaCfg,
486 tableName, err := s.schemaCfg.ChunkTableFor(chunks[i].From)
515 tableName, err := s.schemaCfg.ChunkTableFor(input.From)
535 tableName, err := s.schemaCfg.ChunkTableFor(chunkRef.From)
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/pkg/chunk/cassandra/ |
| H A D | storage_client.go | 256 schemaCfg chunk.SchemaConfig member
263 func NewStorageClient(cfg Config, schemaCfg chunk.SchemaConfig, registerer prometheus.Registerer) (…
281 schemaCfg: schemaCfg,
444 schemaCfg chunk.SchemaConfig member
451 func NewObjectClient(cfg Config, schemaCfg chunk.SchemaConfig, registerer prometheus.Registerer) (*…
469 schemaCfg: schemaCfg,
485 tableName, err := s.schemaCfg.ChunkTableFor(chunks[i].From)
514 tableName, err := s.schemaCfg.ChunkTableFor(input.From)
534 tableName, err := s.schemaCfg.ChunkTableFor(chunkRef.From)
|