| /dports/security/vault/vault-1.8.2/vendor/go.opentelemetry.io/otel/sdk/metric/processor/reducer/ |
| H A D | reducer.go | 27 export.Checkpointer anonMember
39 var _ export.Checkpointer = &Processor{}
43 func New(filterSelector LabelFilterSelector, ckpter export.Checkpointer) *Processor { argument
45 Checkpointer: ckpter,
59 return p.Checkpointer.Process(
|
| /dports/security/vuls/vuls-0.13.7/vendor/go.opentelemetry.io/otel/sdk/metric/processor/reducer/ |
| H A D | reducer.go | 27 export.Checkpointer anonMember
39 var _ export.Checkpointer = &Processor{}
43 func New(filterSelector LabelFilterSelector, ckpter export.Checkpointer) *Processor { argument
45 Checkpointer: ckpter,
59 return p.Checkpointer.Process(
|
| /dports/security/go-cve-dictionary/go-cve-dictionary-0.5.5/vendor/go.opentelemetry.io/otel/sdk/metric/processor/reducer/ |
| H A D | reducer.go | 27 export.Checkpointer anonMember
39 var _ export.Checkpointer = &Processor{}
43 func New(filterSelector LabelFilterSelector, ckpter export.Checkpointer) *Processor { argument
45 Checkpointer: ckpter,
59 return p.Checkpointer.Process(
|
| /dports/www/oauth2-proxy/oauth2-proxy-7.2.0/vendor/go.opentelemetry.io/otel/sdk/metric/processor/reducer/ |
| H A D | reducer.go | 27 export.Checkpointer anonMember
39 var _ export.Checkpointer = &Processor{}
43 func New(filterSelector LabelFilterSelector, ckpter export.Checkpointer) *Processor { argument
45 Checkpointer: ckpter,
59 return p.Checkpointer.Process(
|
| /dports/games/automuteus/automuteus-6.15.2/vendor/go.opentelemetry.io/otel/sdk/metric/processor/reducer/ |
| H A D | reducer.go | 27 export.Checkpointer anonMember
39 var _ export.Checkpointer = &Processor{}
43 func New(filterSelector LabelFilterSelector, ckpter export.Checkpointer) *Processor { argument
45 Checkpointer: ckpter,
59 return p.Checkpointer.Process(
|
| /dports/net/storj/storj-1.45.3/vendor/go.opentelemetry.io/otel/sdk/metric/processor/reducer/ |
| H A D | reducer.go | 27 export.Checkpointer anonMember
39 var _ export.Checkpointer = &Processor{}
43 func New(filterSelector LabelFilterSelector, ckpter export.Checkpointer) *Processor { argument
45 Checkpointer: ckpter,
59 return p.Checkpointer.Process(
|
| /dports/www/grafana8/grafana-8.3.6/vendor/go.opentelemetry.io/otel/sdk/metric/processor/reducer/ |
| H A D | reducer.go | 27 export.Checkpointer anonMember
39 var _ export.Checkpointer = &Processor{}
43 func New(filterSelector LabelFilterSelector, ckpter export.Checkpointer) *Processor { argument
45 Checkpointer: ckpter,
59 return p.Checkpointer.Process(
|
| /dports/sysutils/vector/vector-0.10.0/lib/file-source/src/ |
| H A D | file_server.rs | 80 let mut checkpointer = Checkpointer::new(&self.data_dir); in run()
304 checkpointer: &Checkpointer, in watch_new_file() argument
335 pub struct Checkpointer { struct
341 impl Checkpointer { impl
342 pub fn new(data_dir: &Path) -> Checkpointer { in new() argument
345 Checkpointer { in new()
485 use super::{Checkpointer, FileFingerprint, FilePosition, Fingerprinter};
633 let mut chkptr = Checkpointer::new(&data_dir.path()); in test_checkpointer_basics()
648 let mut chkptr = Checkpointer::new(&data_dir.path()); in test_checkpointer_restart()
654 let mut chkptr = Checkpointer::new(&data_dir.path()); in test_checkpointer_restart()
|
| /dports/sysutils/terraform/terraform-1.0.11/vendor/github.com/aliyun/aliyun-tablestore-go-sdk/tunnel/ |
| H A D | processor.go | 15 NewProcessor(tunnelId, clientId, channelId string, checkpointer Checkpointer) ChannelProcessor argument
34 …tory) NewProcessor(tunnelId, clientId, channelId string, checkpointer Checkpointer) ChannelProcess…
64 checkpointer Checkpointer
|
| /dports/security/vuls/vuls-0.13.7/vendor/go.opentelemetry.io/otel/sdk/metric/controller/pull/ |
| H A D | pull.go | 38 checkpointer export.Checkpointer
53 func New(checkpointer export.Checkpointer, options ...Option) *Controller { argument
|
| /dports/security/go-cve-dictionary/go-cve-dictionary-0.5.5/vendor/go.opentelemetry.io/otel/sdk/metric/controller/pull/ |
| H A D | pull.go | 38 checkpointer export.Checkpointer
53 func New(checkpointer export.Checkpointer, options ...Option) *Controller { argument
|
| /dports/www/oauth2-proxy/oauth2-proxy-7.2.0/vendor/go.opentelemetry.io/otel/sdk/metric/controller/pull/ |
| H A D | pull.go | 38 checkpointer export.Checkpointer
53 func New(checkpointer export.Checkpointer, options ...Option) *Controller { argument
|
| /dports/sysutils/vector/vector-0.10.0/src/sources/ |
| H A D | journald.rs | 110 let checkpointer = Checkpointer::new(data_dir) in build()
138 mut checkpointer: Checkpointer, in source() argument
314 checkpointer: Checkpointer,
466 struct Checkpointer { struct
470 impl Checkpointer { implementation
478 Ok(Checkpointer { file }) in new()
527 Checkpointer::new(tempdir.path().to_path_buf()).expect("Creating checkpointer failed!"); in journald_checkpointer_works()
610 Checkpointer::new(tempdir.path().to_path_buf()).expect("Creating checkpointer failed!"); in run_journal()
|
| /dports/www/grafana8/grafana-8.3.6/vendor/go.opentelemetry.io/otel/sdk/export/metric/ |
| H A D | metric.go | 105 type Checkpointer interface { interface
130 NewCheckpointer() Checkpointer
|
| /dports/security/vuls/vuls-0.13.7/vendor/go.opentelemetry.io/otel/sdk/metric/controller/push/ |
| H A D | push.go | 38 checkpointer export.Checkpointer
51 func New(checkpointer export.Checkpointer, exporter export.Exporter, opts ...Option) *Controller { argument
|
| H A D | push_test.go | 74 func newCheckpointer() export.Checkpointer {
75 return processorTest.Checkpointer(
|
| /dports/security/go-cve-dictionary/go-cve-dictionary-0.5.5/vendor/go.opentelemetry.io/otel/sdk/metric/controller/push/ |
| H A D | push.go | 38 checkpointer export.Checkpointer
51 func New(checkpointer export.Checkpointer, exporter export.Exporter, opts ...Option) *Controller { argument
|
| H A D | push_test.go | 74 func newCheckpointer() export.Checkpointer {
75 return processorTest.Checkpointer(
|
| /dports/www/oauth2-proxy/oauth2-proxy-7.2.0/vendor/go.opentelemetry.io/otel/sdk/metric/controller/push/ |
| H A D | push.go | 38 checkpointer export.Checkpointer
51 func New(checkpointer export.Checkpointer, exporter export.Exporter, opts ...Option) *Controller { argument
|
| H A D | push_test.go | 74 func newCheckpointer() export.Checkpointer {
75 return processorTest.Checkpointer(
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/pkg/ingester/ |
| H A D | checkpoint.go | 525 type Checkpointer struct { struct
534 …eriesIter, writer CheckpointWriter, metrics *ingesterMetrics, quit <-chan struct{}) *Checkpointer {
535 return &Checkpointer{
544 func (c *Checkpointer) PerformCheckpoint() (err error) { argument
609 func (c *Checkpointer) Run() { argument
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/ |
| H A D | Checkpointer.java | 58 class Checkpointer extends Daemon { class
60 LogFactory.getLog(Checkpointer.class.getName());
81 Checkpointer(Configuration conf, BackupNode bnNode) throws IOException { in Checkpointer() method in Checkpointer
|
| /dports/biology/bowtie2/bowtie2-2.4.4/ |
| H A D | sse_util.cpp | 27 void Checkpointer::commitCol( in commitCol()
|
| /dports/biology/hisat2/hisat2-2.2.1/ |
| H A D | sse_util.cpp | 27 void Checkpointer::commitCol( in commitCol()
|
| /dports/security/vault/vault-1.8.2/vendor/go.opentelemetry.io/otel/sdk/metric/controller/basic/ |
| H A D | controller.go | 61 checkpointer export.Checkpointer
80 func New(checkpointer export.Checkpointer, opts ...Option) *Controller { argument
|