Home
last modified time | relevance | path

Searched refs:shipper (Results 1 – 25 of 293) sorted by relevance

12345678910>>...12

/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/pkg/ingester/
H A Dingester_test.go387 name: "not using boltdb-shipper",
396 name: "just one periodic config with boltdb-shipper",
400 IndexType: "boltdb-shipper",
406 name: "active config boltdb-shipper, previous config non boltdb-shipper",
414 IndexType: "boltdb-shipper",
420 name: "current and previous config both using boltdb-shipper",
424 IndexType: "boltdb-shipper",
428 IndexType: "boltdb-shipper",
434 name: "active config non boltdb-shipper, previous config boltdb-shipper",
438 IndexType: "boltdb-shipper",
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/pkg/storage/stores/shipper/indexgateway/
H A Dgateway.go17 shipper chunk.IndexClient member
20 func NewIndexGateway(shipperIndexClient *shipper.Shipper) *gateway {
22 shipper: shipperIndexClient,
25 g.shipper.Stop()
45 …outerErr = g.shipper.QueryPages(server.Context(), queries, func(query chunk.IndexQuery, batch chun…
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/pkg/storage/
H A Dstore.go40 BoltDBShipperConfig shipper.Config `yaml:"boltdb_shipper"`
63 …if cfg.Configs[activePCIndex].IndexType == shipper.BoltDBShipperType && cfg.Configs[activePCIndex]…
68 …if len(cfg.Configs)-1 > activePCIndex && (cfg.Configs[activePCIndex+1].IndexType == shipper.BoltDB…
139 if name == shipper.BoltDBShipperType {
413 storage.RegisterIndexStore(shipper.BoltDBShipperType, func() (chunk.IndexClient, error) {
418 …if cfg.BoltDBShipperConfig.Mode == shipper.ModeReadOnly && cfg.BoltDBShipperConfig.IndexGatewayCli…
419 …gateway, err := shipper.NewGatewayClient(cfg.BoltDBShipperConfig.IndexGatewayClientConfig, registe…
433 …boltDBIndexClientWithShipper, err = shipper.NewShipper(cfg.BoltDBShipperConfig, objectClient, regi…
442 …return shipper.NewBoltDBShipperTableClient(objectClient, cfg.BoltDBShipperConfig.SharedStoreKeyPre…
462 if configs[activePCIndex].IndexType == shipper.BoltDBShipperType ||
[all …]
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/cmd/loki/
H A Dloki-docker-config.yaml23 store: boltdb-shipper
32 active_index_directory: /loki/boltdb-shipper-active
33 cache_location: /loki/boltdb-shipper-cache
40 working_directory: /loki/boltdb-shipper-compactor
H A Dloki-local-config.yaml27 store: boltdb-shipper
36 active_index_directory: /tmp/loki/boltdb-shipper-active
37 cache_location: /tmp/loki/boltdb-shipper-cache
44 working_directory: /tmp/loki/boltdb-shipper-compactor
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/production/docker/
H A Ddocker-compose-ha-memberlist.yaml42 …command: "-config.file=/etc/loki/loki-docker-memberlist-boltdb-shipper.yaml -target=query-frontend"
57 command: "-config.file=/etc/loki/loki-docker-memberlist-boltdb-shipper.yaml -target=all"
70 command: "-config.file=/etc/loki/loki-docker-memberlist-boltdb-shipper.yaml -target=all"
84 command: "-config.file=/etc/loki/loki-docker-memberlist-boltdb-shipper.yaml -target=all"
/dports/net-mgmt/thanos/thanos-0.11.0/pkg/shipper/
H A Dshipper_e2e_test.go4 package shipper package
42 …shipper := New(log.NewLogfmtLogger(os.Stderr), nil, dir, bkt, func() labels.Labels { return extLse…
95 b, err := shipper.Sync(ctx)
113 b, err = shipper.Sync(ctx)
150 minTotal, maxSync, err := shipper.Timestamps()
203 …shipper := NewWithCompacted(log.NewLogfmtLogger(os.Stderr), nil, dir, bkt, func() labels.Labels { …
252 b, err := shipper.Sync(ctx)
270 b, err = shipper.Sync(ctx)
302 minTotal, maxSync, err := shipper.Timestamps()
H A Dshipper_test.go4 package shipper package
127 shipper := New(nil, nil, dir, nil, nil, metadata.TestSource)
128 if err := shipper.iterBlockMetas(func(m *metadata.Meta) error {
170 shipper := New(nil, nil, dir, nil, nil, metadata.TestSource)
171 if err := shipper.iterBlockMetas(func(m *metadata.Meta) error {
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/docs/sources/operations/storage/
H A Dboltdb-shipper.md2 title: Single Store (boltdb-shipper)
4 # Single Store Loki (boltdb-shipper index type)
11 …shipper works best with 24h periodic index files. It is a requirement to have index period set to …
12 …-shipper already has created index files with 7 days period, and you want to retain previous data …
22 store: boltdb-shipper
50 Here `<period-number-since-epoch>` in case of boltdb-shipper would be day number since epoch.
81 … store instantly while index is not since we only upload them every 15 Minutes with BoltDB shipper.
105 … set the address (with gRPC port) of the Index Gateway with the `-boltdb.shipper.index-gateway-cli…
112 The problem with write deduplication when using `boltdb-shipper` though is ingesters only keep uplo…
116 …ation of index when the replication factor is greater than 1 and `boltdb-shipper` is an active or …
[all …]
H A Dretention.md9 …shipper](../boltdb-shipper) store and chunk/index store. However retention through the [Compactor]…
16 The [Compactor](../boltdb-shipper#compactor) can deduplicate index entries. It can also apply granu…
36 - boltdb-shipper indexes are refreshed from the shared store on components using it (querier and ru…
62 store: boltdb-shipper
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/docs/sources/storage/
H A D_index.md15 Loki 2.0 brings an index mechanism named 'boltdb-shipper' and is what we now call Single Store Loki.
17 …n can be found on the [operations page]({{< relref "../operations/storage/boltdb-shipper.md" >}}).
182 active_index_directory: /loki/boltdb-shipper-active
183 cache_location: /loki/boltdb-shipper-cache
192 store: boltdb-shipper
273 active_index_directory: /loki/boltdb-shipper-active
274 cache_location: /loki/boltdb-shipper-cache
281 store: boltdb-shipper
300 store: boltdb-shipper
311 active_index_directory: /data/loki/boltdb-shipper-active
[all …]
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/thanos-io/thanos/pkg/shipper/
H A Dshipper_e2e_test.go4 package shipper package
48 …shipper := New(log.NewLogfmtLogger(os.Stderr), nil, dir, metricsBucket, func() labels.Labels { ret…
101 b, err := shipper.Sync(ctx)
119 b, err = shipper.Sync(ctx)
173 minTotal, maxSync, err := shipper.Timestamps()
227 …shipper := New(log.NewLogfmtLogger(os.Stderr), nil, dir, bkt, func() labels.Labels { return extLse…
276 b, err := shipper.Sync(ctx)
294 b, err = shipper.Sync(ctx)
330 minTotal, maxSync, err := shipper.Timestamps()
H A Dshipper_test.go4 package shipper package
132 shipper := New(nil, nil, dir, nil, nil, metadata.TestSource, false, false, metadata.NoneFunc)
133 metas, err := shipper.blockMetasFromOldest()
167 shipper := New(nil, nil, dir, nil, nil, metadata.TestSource, false, false, metadata.NoneFunc)
169 _, err = shipper.blockMetasFromOldest()
/dports/textproc/nux/nux/samples/data/
H A Dns-order.xsd12 <xs:element name="shipper" type="po:shipper" minOccurs="0"/>
30 <xs:complexType name="shipper">
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/production/ksonnet/loki/
H A Dboltdb_shipper.libsonnet11 …// run ingesters and queriers as statefulsets when using boltdb-shipper to avoid using node disk f…
33 // we don't dedupe index writes when using boltdb-shipper so don't deploy a cache for it.
46 'boltdb.shipper.compactor.working-directory': '/data/compactor',
47 'boltdb.shipper.compactor.shared-store': $._config.boltdb_shipper_shared_store,
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/thanos-io/thanos/pkg/receive/
H A Dmultitsdb.go83 ship *shipper.Shipper
105 func (t *tenant) shipper() *shipper.Shipper { func
111 func (t *tenant) set(storeTSDB *store.TSDBStore, tenantTSDB *tsdb.DB, ship *shipper.Shipper) {
209 s := tenant.shipper()
288 var ship *shipper.Shipper
290 ship = shipper.New(
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/nomad/website/source/guides/operating-a-job/
H A Daccessing-logs.html.md104 # signal the log shipper task to gracefully shutdown when the server exits.
108 task "log-shipper" {
115 and will be producing the logs. The `log-shipper` reads those logs from the
119 When using the log shipper pattern, especially for batch jobs, the main task
122 within the group will be gracefully shutdown. This allows the log shipper to
123 finish sending any logs and then exiting itself. The log shipper should set a
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/thanos-io/thanos/cmd/thanos/
H A Dsidecar.go150 … if err := validatePrometheus(ctx, m.client, logger, conf.shipper.ignoreBlockSize, m); err != nil {
286 s := shipper.New(logger, reg, conf.tsdb.path, bkt, m.Labels, metadata.SidecarSource,
287 …conf.shipper.uploadCompacted, conf.shipper.allowOutOfOrderUpload, metadata.HashFunc(conf.shipper.h…
409 shipper shipperConfig member
422 sc.shipper.registerFlag(cmd)
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/docs/sources/upgrading/
H A D_index.md237 * [IMPORTANT boltdb-shipper upgrade considerations](#important-boltdb-shipper-upgrade-consideration…
250 In 2.0 the defaults are now v11 schema and the `boltdb-shipper` index type.
276 …looking at moving to the v11 schema and boltdb-shipper [see below](#upgrading-schema-to-use-boltdb…
310 …the jsonnet config to use the `boltdb-shipper` type is the same as [below](#upgrading-schema-to-us…
329 ### IMPORTANT: boltdb-shipper upgrade considerations.
377 ### Upgrading schema to use boltdb-shipper and/or v11 schema
396 store: boltdb-shipper
407 ⑤ 24h is required for boltdb-shipper
467 ### Experimental boltdb-shipper changes
479 store: boltdb-shipper
[all …]
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/pkg/storage/stores/shipper/
H A Dshipper_index_client.go1 package shipper package
98 shipper := Shipper{
103 err := shipper.init(storageClient, registerer)
110 return &shipper, nil
/dports/devel/deheader/deheader-b408c9013f4e1d917cc12f06edda4e1782e64888/
H A DMakefile42 shipper version=$(VERS) | sh -e -x
45 shipper -N -w version=$(VERS) | sh -e -x
/dports/converters/showkey/showkey-1.7/
H A DMakefile40 shipper version=$(VERS) | sh -e -x
43 shipper -N -w version=$(VERS) | sh -e -x
/dports/games/galaxis/galaxis-1.10/
H A DMakefile47 shipper version=$(VERS) | sh -e -x
50 shipper -N -w version=$(VERS) | sh -e -x
/dports/textproc/py-pygments/Pygments-2.7.2/tests/examplefiles/
H A Dtest.sol68 require(msg.sender == shipper);
72 shipper.transfer(this.balance);
/dports/textproc/py-pygments-25/Pygments-2.5.2/tests/examplefiles/
H A Dtest.sol68 require(msg.sender == shipper);
72 shipper.transfer(this.balance);

12345678910>>...12