Home
last modified time | relevance | path

Searched defs:Batcher (Results 1 – 21 of 21) sorted by relevance

/dports/net/goreplay/goreplay-1.2.0/vendor/github.com/eapache/go-resiliency/go-resiliency-1.2.0/batcher/
H A Dbatcher.go15 type Batcher struct { struct
16 timeout time.Duration
17 prefilter func(interface{}) error
19 lock sync.Mutex
20 submit chan *work
21 doWork func([]interface{}) error
38 func (b *Batcher) Run(param interface{}) error {
64 func (b *Batcher) Prefilter(filter func(interface{}) error) {
68 func (b *Batcher) submitWork(w *work) {
80 func (b *Batcher) batch() {
[all …]
/dports/databases/tile38/tile38-1.12.0/vendor/github.com/eapache/go-resiliency/batcher/
H A Dbatcher.go15 type Batcher struct { struct
16 timeout time.Duration
17 prefilter func(interface{}) error
19 lock sync.Mutex
20 submit chan *work
21 doWork func([]interface{}) error
38 func (b *Batcher) Run(param interface{}) error {
64 func (b *Batcher) Prefilter(filter func(interface{}) error) {
68 func (b *Batcher) submitWork(w *work) {
80 func (b *Batcher) batch() {
[all …]
/dports/www/fabio/fabio-1.5.14/vendor/github.com/eapache/go-resiliency/go-resiliency-1.1.0/batcher/
H A Dbatcher.go15 type Batcher struct { struct
16 timeout time.Duration
17 prefilter func(interface{}) error
19 lock sync.Mutex
20 submit chan *work
21 doWork func([]interface{}) error
38 func (b *Batcher) Run(param interface{}) error {
64 func (b *Batcher) Prefilter(filter func(interface{}) error) {
68 func (b *Batcher) submitWork(w *work) {
80 func (b *Batcher) batch() {
[all …]
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/eapache/go-resiliency/batcher/
H A Dbatcher.go15 type Batcher struct { struct
16 timeout time.Duration
17 prefilter func(interface{}) error
19 lock sync.Mutex
20 submit chan *work
21 doWork func([]interface{}) error
38 func (b *Batcher) Run(param interface{}) error {
64 func (b *Batcher) Prefilter(filter func(interface{}) error) {
68 func (b *Batcher) submitWork(w *work) {
80 func (b *Batcher) batch() {
[all …]
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/gocloud.dev/pubsub/batcher/
H A Dbatcher.go65 type Batcher struct { struct
66 opts Options
67 handler func(interface{}) error
69 wg sync.WaitGroup // tracks active Add calls
71 mu sync.Mutex
72 pending []waiter // items waiting to be handled
74 shutdown bool
142 func (b *Batcher) AddNoWait(item interface{}) <-chan error {
173 func (b *Batcher) nextBatch() []waiter {
188 func (b *Batcher) callHandler(batch []waiter) {
[all …]
/dports/www/gohugo/hugo-0.91.2/vendor/gocloud.dev/pubsub/batcher/
H A Dbatcher.go65 type Batcher struct { struct
66 opts Options
67 handler func(interface{}) error
69 wg sync.WaitGroup // tracks active Add calls
71 mu sync.Mutex
72 pending []waiter // items waiting to be handled
74 shutdown bool
142 func (b *Batcher) AddNoWait(item interface{}) <-chan error {
173 func (b *Batcher) nextBatch() []waiter {
188 func (b *Batcher) callHandler(batch []waiter) {
[all …]
/dports/sysutils/gomplate/gomplate-3.9.0/vendor/gocloud.dev/pubsub/batcher/
H A Dbatcher.go65 type Batcher struct { struct
66 opts Options
67 handler func(interface{}) error
69 wg sync.WaitGroup // tracks active Add calls
71 mu sync.Mutex
72 pending []waiter // items waiting to be handled
74 shutdown bool
142 func (b *Batcher) AddNoWait(item interface{}) <-chan error {
173 func (b *Batcher) nextBatch() []waiter {
188 func (b *Batcher) callHandler(batch []waiter) {
[all …]
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/gocloud.dev/go-cloud-5094f54ed8bb/pubsub/batcher/
H A Dbatcher.go65 type Batcher struct { struct
66 opts Options
67 handler func(interface{}) error
69 wg sync.WaitGroup // tracks active Add calls
71 mu sync.Mutex
72 pending []waiter // items waiting to be handled
74 shutdown bool
142 func (b *Batcher) AddNoWait(item interface{}) <-chan error {
173 func (b *Batcher) nextBatch() []waiter {
188 func (b *Batcher) callHandler(batch []waiter) {
[all …]
/dports/www/gohugo/hugo-0.91.2/watcher/
H A Dbatcher.go24 type Batcher struct { struct
25 filenotify.FileWatcher
26 interval time.Duration
27 done chan struct{}
29 Events chan []fsnotify.Event // Events are returned on this channel
62 func (b *Batcher) run() {
84 func (b *Batcher) Close() {
/dports/misc/concourse/concourse-6.7.2/vendor/go.opentelemetry.io/otel/sdk/metric/batcher/defaultkeys/
H A Ddefaultkeys.go25 Batcher struct { struct
26 selector export.AggregationSelector
27 labelEncoder export.LabelEncoder
28 stateful bool
29 descKeyIndex descKeyIndexMap
30 aggCheckpoint aggCheckpointMap
67 func (b *Batcher) AggregatorFor(descriptor *export.Descriptor) export.Aggregator {
71 func (b *Batcher) Process(_ context.Context, record export.Record) error {
143 func (b *Batcher) CheckpointSet() export.CheckpointSet {
150 func (b *Batcher) FinishedCollection() {
/dports/misc/concourse/concourse-6.7.2/vendor/go.opentelemetry.io/otel/sdk/metric/batcher/ungrouped/
H A Dungrouped.go24 Batcher struct { struct
25 selector export.AggregationSelector
26 batchMap batchMap
27 stateful bool
54 func (b *Batcher) AggregatorFor(descriptor *export.Descriptor) export.Aggregator {
58 func (b *Batcher) Process(_ context.Context, record export.Record) error {
94 func (b *Batcher) CheckpointSet() export.CheckpointSet {
98 func (b *Batcher) FinishedCollection() {
/dports/textproc/zorba/zorba-2.7.0/src/runtime/base/
H A Dplan_iterator.h491 SERIALIZABLE_TEMPLATE_ABSTRACT_CLASS(Batcher) in SERIALIZABLE_TEMPLATE_ABSTRACT_CLASS() argument
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
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/ethdb/
H A Dbatch.go42 type Batcher interface { interface
/dports/graphics/opencsg/OpenCSG-1.4.2/src/
H A Dbatch.cpp44 Batcher::Batcher(const std::vector<Primitive*>& primitives) { in Batcher() function in OpenCSG::Batcher
/dports/security/fizz/fizz-2021.12.27.00/fizz/experimental/batcher/
H A DBatcher.h62 Batcher( in Batcher() function
/dports/misc/concourse/concourse-6.7.2/vendor/go.opentelemetry.io/otel/sdk/metric/controller/push/
H A Dpush.go76 func New(batcher export.Batcher, exporter export.Exporter, period time.Duration) *Controller {
/dports/security/keybase/client-v5.7.1/go/libkb/
H A Dupak_loader.go38 …Batcher(ctx context.Context, getArg func(int) *LoadUserArg, processResult func(int, *keybase1.User… methodSpec
988 func (u *CachedUPAKLoader) Batcher(ctx context.Context, getArg func(int) *LoadUserArg, processResul… func
/dports/www/gohugo/hugo-0.91.2/commands/
H A Dhugo.go915 func (c *commandeer) handleEvents(watcher *watcher.Batcher,
/dports/misc/concourse/concourse-6.7.2/vendor/go.opentelemetry.io/otel/sdk/export/metric/
H A Dmetric.go47 type Batcher interface { interface
/dports/misc/concourse/concourse-6.7.2/vendor/go.opentelemetry.io/otel/sdk/metric/
H A Dsdk.go237 func New(batcher export.Batcher, labelEncoder export.LabelEncoder) *SDK {
/dports/net/google-cloud-sdk/google-cloud-sdk/lib/googlecloudsdk/third_party/appengine/datastore/
H A Ddatastore_query.py3148 class Batcher(object): class