| /dports/security/fizz/fizz-2021.12.27.00/fizz/experimental/batcher/ |
| H A D | Batcher.h | 19 class Batcher {
62 Batcher( in Batcher() function
78 virtual ~Batcher() = default;
141 class SynchronizedBatcher : public Batcher<Hash> {
147 : Batcher<Hash>(numMsgThreshold, signer, context), in SynchronizedBatcher()
150 typename Batcher<Hash>::BatchResult addMessageAndSign( in addMessageAndSign()
161 typename Batcher<Hash>::BatchResult result( in addMessageAndSign()
199 class ThreadLocalBatcher : public Batcher<Hash> {
209 typename Batcher<Hash>::BatchResult addMessageAndSign( in addMessageAndSign()
219 typename Batcher<Hash>::BatchResult result( in addMessageAndSign()
[all …]
|
| /dports/misc/concourse/concourse-6.7.2/vendor/go.opentelemetry.io/otel/sdk/metric/batcher/ungrouped/ |
| H A D | ungrouped.go | 24 Batcher struct { struct
43 var _ export.Batcher = &Batcher{}
46 func New(selector export.AggregationSelector, stateful bool) *Batcher {
47 return &Batcher{
54 func (b *Batcher) AggregatorFor(descriptor *export.Descriptor) export.Aggregator { argument
58 func (b *Batcher) Process(_ context.Context, record export.Record) error { argument
94 func (b *Batcher) CheckpointSet() export.CheckpointSet { argument
98 func (b *Batcher) FinishedCollection() { argument
|
| /dports/net/goreplay/goreplay-1.2.0/vendor/github.com/eapache/go-resiliency/go-resiliency-1.2.0/batcher/ |
| H A D | batcher.go | 15 type Batcher struct { struct
28 func New(timeout time.Duration, doWork func([]interface{}) error) *Batcher {
29 return &Batcher{
38 func (b *Batcher) Run(param interface{}) error { argument
64 func (b *Batcher) Prefilter(filter func(interface{}) error) { argument
68 func (b *Batcher) submitWork(w *work) { argument
80 func (b *Batcher) batch() { argument
100 func (b *Batcher) timer() { argument
|
| /dports/databases/tile38/tile38-1.12.0/vendor/github.com/eapache/go-resiliency/batcher/ |
| H A D | batcher.go | 15 type Batcher struct { struct
28 func New(timeout time.Duration, doWork func([]interface{}) error) *Batcher {
29 return &Batcher{
38 func (b *Batcher) Run(param interface{}) error { argument
64 func (b *Batcher) Prefilter(filter func(interface{}) error) { argument
68 func (b *Batcher) submitWork(w *work) { argument
80 func (b *Batcher) batch() { argument
100 func (b *Batcher) timer() { argument
|
| /dports/www/fabio/fabio-1.5.14/vendor/github.com/eapache/go-resiliency/go-resiliency-1.1.0/batcher/ |
| H A D | batcher.go | 15 type Batcher struct { struct
28 func New(timeout time.Duration, doWork func([]interface{}) error) *Batcher {
29 return &Batcher{
38 func (b *Batcher) Run(param interface{}) error { argument
64 func (b *Batcher) Prefilter(filter func(interface{}) error) { argument
68 func (b *Batcher) submitWork(w *work) { argument
80 func (b *Batcher) batch() { argument
100 func (b *Batcher) timer() { argument
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/eapache/go-resiliency/batcher/ |
| H A D | batcher.go | 15 type Batcher struct { struct
28 func New(timeout time.Duration, doWork func([]interface{}) error) *Batcher {
29 return &Batcher{
38 func (b *Batcher) Run(param interface{}) error { argument
64 func (b *Batcher) Prefilter(filter func(interface{}) error) { argument
68 func (b *Batcher) submitWork(w *work) { argument
80 func (b *Batcher) batch() { argument
100 func (b *Batcher) timer() { argument
|
| /dports/misc/concourse/concourse-6.7.2/vendor/go.opentelemetry.io/otel/sdk/metric/batcher/defaultkeys/ |
| H A D | defaultkeys.go | 25 Batcher struct { struct
54 var _ export.Batcher = &Batcher{}
57 …ew(selector export.AggregationSelector, labelEncoder export.LabelEncoder, stateful bool) *Batcher {
58 return &Batcher{
67 func (b *Batcher) AggregatorFor(descriptor *export.Descriptor) export.Aggregator { argument
71 func (b *Batcher) Process(_ context.Context, record export.Record) error { argument
143 func (b *Batcher) CheckpointSet() export.CheckpointSet { argument
150 func (b *Batcher) FinishedCollection() { argument
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/gocloud.dev/pubsub/batcher/ |
| H A D | batcher.go | 65 type Batcher struct { struct
117 func New(itemType reflect.Type, opts *Options, handler func(interface{}) error) *Batcher {
118 return &Batcher{
128 func (b *Batcher) Add(ctx context.Context, item interface{}) error { argument
142 func (b *Batcher) AddNoWait(item interface{}) <-chan error { argument
173 func (b *Batcher) nextBatch() []waiter { argument
188 func (b *Batcher) callHandler(batch []waiter) { argument
217 func (b *Batcher) Shutdown() { argument
|
| /dports/www/gohugo/hugo-0.91.2/vendor/gocloud.dev/pubsub/batcher/ |
| H A D | batcher.go | 65 type Batcher struct { struct
117 func New(itemType reflect.Type, opts *Options, handler func(interface{}) error) *Batcher {
118 return &Batcher{
128 func (b *Batcher) Add(ctx context.Context, item interface{}) error { argument
142 func (b *Batcher) AddNoWait(item interface{}) <-chan error { argument
173 func (b *Batcher) nextBatch() []waiter { argument
188 func (b *Batcher) callHandler(batch []waiter) { argument
217 func (b *Batcher) Shutdown() { argument
|
| /dports/sysutils/gomplate/gomplate-3.9.0/vendor/gocloud.dev/pubsub/batcher/ |
| H A D | batcher.go | 65 type Batcher struct { struct
117 func New(itemType reflect.Type, opts *Options, handler func(interface{}) error) *Batcher {
118 return &Batcher{
128 func (b *Batcher) Add(ctx context.Context, item interface{}) error { argument
142 func (b *Batcher) AddNoWait(item interface{}) <-chan error { argument
173 func (b *Batcher) nextBatch() []waiter { argument
188 func (b *Batcher) callHandler(batch []waiter) { argument
217 func (b *Batcher) Shutdown() { argument
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/gocloud.dev/go-cloud-5094f54ed8bb/pubsub/batcher/ |
| H A D | batcher.go | 65 type Batcher struct { struct
117 func New(itemType reflect.Type, opts *Options, handler func(interface{}) error) *Batcher {
118 return &Batcher{
128 func (b *Batcher) Add(ctx context.Context, item interface{}) error { argument
142 func (b *Batcher) AddNoWait(item interface{}) <-chan error { argument
173 func (b *Batcher) nextBatch() []waiter { argument
188 func (b *Batcher) callHandler(batch []waiter) { argument
217 func (b *Batcher) Shutdown() { argument
|
| /dports/www/gohugo/hugo-0.91.2/watcher/ |
| H A D | batcher.go | 24 type Batcher struct { struct
35 func New(intervalBatcher, intervalPoll time.Duration, poll bool) (*Batcher, error) {
49 batcher := &Batcher{}
62 func (b *Batcher) run() { argument
84 func (b *Batcher) Close() { argument
|
| /dports/graphics/opencsg/OpenCSG-1.4.2/src/ |
| H A D | batch.cpp | 44 Batcher::Batcher(const std::vector<Primitive*>& primitives) { in Batcher() function in OpenCSG::Batcher
114 std::vector<Batch>::const_iterator Batcher::begin() const { in begin()
118 std::vector<Batch>::const_iterator Batcher::end() const { in end()
122 unsigned int Batcher::size() const { in size()
|
| H A D | batch.h | 40 class Batcher {
43 Batcher(const std::vector<Primitive*>& primitives);
|
| /dports/textproc/zorba/zorba-2.7.0/src/runtime/base/ |
| H A D | noarybase.h | 34 class NoaryBaseIterator : public Batcher<IterType>
39 SERIALIZABLE_CLASS_CONSTRUCTOR2(NoaryBaseIterator, Batcher<IterType>);
43 serialize_baseclass(ar, (Batcher<IterType>*)this); in serialize()
49 Batcher<IterType>(sctx, loc) in NoaryBaseIterator()
|
| H A D | plan_iterator.h | 488 class Batcher: public PlanIterator
491 SERIALIZABLE_TEMPLATE_ABSTRACT_CLASS(Batcher) in SERIALIZABLE_TEMPLATE_ABSTRACT_CLASS() argument
492 SERIALIZABLE_CLASS_CONSTRUCTOR2(Batcher, PlanIterator) in SERIALIZABLE_TEMPLATE_ABSTRACT_CLASS()
499 Batcher(const Batcher<IterType>& b) : PlanIterator(b) {} in Batcher() function
501 Batcher(static_context* sctx, const QueryLoc& loc) : PlanIterator(sctx, loc) {} in Batcher() function
503 ~Batcher() {} in ~Batcher()
|
| H A D | unarybase.h | 34 class UnaryBaseIterator : public Batcher<IterType>
41 SERIALIZABLE_CLASS_CONSTRUCTOR2(UnaryBaseIterator, Batcher<IterType>) in SERIALIZABLE_ABSTRACT_CLASS()
44 serialize_baseclass(ar, (Batcher<IterType>*)this); in SERIALIZABLE_ABSTRACT_CLASS()
54 Batcher<IterType>(sctx, loc), in UnaryBaseIterator()
|
| H A D | binarybase.h | 34 class BinaryBaseIterator : public Batcher<IterType>
42 SERIALIZABLE_CLASS_CONSTRUCTOR2(BinaryBaseIterator, Batcher<IterType>) in SERIALIZABLE_ABSTRACT_CLASS()
45 serialize_baseclass(ar, (Batcher<IterType>*)this); in SERIALIZABLE_ABSTRACT_CLASS()
57 Batcher<IterType>(sctx, loc), in BinaryBaseIterator()
|
| H A D | narybase.h | 37 class NaryBaseIterator : public Batcher<IterType>
44 SERIALIZABLE_CLASS_CONSTRUCTOR2(NaryBaseIterator, Batcher<IterType>) in SERIALIZABLE_ABSTRACT_CLASS()
47 serialize_baseclass(ar, (Batcher<IterType>*)this); in SERIALIZABLE_ABSTRACT_CLASS()
85 Batcher<IterType>(sctx, loc), in NaryBaseIterator()
|
| /dports/editors/calligra/calligra-3.2.1/plugins/stencilsdocker/stencils/Building_Site/ |
| H A D | proportioning_batcher.desktop | 2 Name=Proportioning Batcher
6 Name[da]=Proportioning Batcher
9 Name[en_GB]=Proportioning Batcher
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/ethdb/ |
| H A D | database.go | 63 Batcher
152 Batcher
|
| /dports/textproc/zorba/zorba-2.7.0/src/runtime/core/gflwor/ |
| H A D | groupby_iterator.h | 64 class GroupByIterator : public Batcher<GroupByIterator>
73 SERIALIZABLE_CLASS_CONSTRUCTOR2(GroupByIterator, Batcher<GroupByIterator>)
|
| /dports/textproc/zorba/zorba-2.7.0/src/runtime/core/ |
| H A D | item_iterator.h | 85 class IfThenElseIterator : public Batcher<IfThenElseIterator>
95 SERIALIZABLE_CLASS_CONSTRUCTOR2(IfThenElseIterator, Batcher<IfThenElseIterator>)
|
| H A D | item_iterator.cpp | 88 Batcher<IfThenElseIterator>(sctx, loc), in IfThenElseIterator()
99 serialize_baseclass(ar, (Batcher<IfThenElseIterator>*)this); in serialize()
|
| /dports/security/fizz/fizz-2021.12.27.00/fizz/experimental/server/ |
| H A D | BatchSignatureAsyncSelfCert.h | 33 BatchSignatureAsyncSelfCert(std::shared_ptr<Batcher<Hash>> batcher) in BatchSignatureAsyncSelfCert()
117 std::shared_ptr<Batcher<Hash>> batcher_;
|