/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_;
|