| /dports/databases/erlang-eredis/eredis-1.1.0/src/ |
| H A D | eredis_sub.erl | 32 MaxQueueSize, QueueBehaviour)
37 (is_integer(MaxQueueSize) orelse MaxQueueSize =:= infinity) andalso
41 MaxQueueSize, QueueBehaviour).
51 MaxQueueSize = proplists:get_value(max_queue_size, Args, infinity),
54 MaxQueueSize, QueueBehaviour).
|
| /dports/net-im/matterircd/matterircd-0.25.0/vendor/github.com/mattermost/mattermost-server/v5/shared/mlog/ |
| H A D | logr.go | 35 MaxQueueSize int member
80 if t.MaxQueueSize == 0 {
81 t.MaxQueueSize = DefaultMaxTargetQueue
137 newTarget := target.NewWriterTarget(filter, formatter, w, t.MaxQueueSize)
164 newTarget := target.NewFileTarget(filter, formatter, opts, t.MaxQueueSize)
180 return NewSyslogTarget(filter, formatter, options, t.MaxQueueSize)
195 return NewTcpTarget(filter, formatter, options, t.MaxQueueSize)
|
| /dports/net-im/matterbridge/matterbridge-1.22.3/vendor/github.com/mattermost/mattermost-server/v5/mlog/ |
| H A D | logr.go | 35 MaxQueueSize int member
83 if t.MaxQueueSize == 0 {
84 t.MaxQueueSize = DefaultMaxTargetQueue
140 newTarget := target.NewWriterTarget(filter, formatter, w, t.MaxQueueSize)
167 newTarget := target.NewFileTarget(filter, formatter, opts, t.MaxQueueSize)
183 return NewSyslogTarget(filter, formatter, options, t.MaxQueueSize)
198 return NewTcpTarget(filter, formatter, options, t.MaxQueueSize)
|
| /dports/net/concourse-fly/concourse-6.7.1/vendor/go.opentelemetry.io/otel/sdk/trace/ |
| H A D | batch_span_processor.go | 42 MaxQueueSize int member
90 MaxQueueSize: defaultMaxQueueSize,
101 bsp.queue = make(chan *export.SpanData, bsp.o.MaxQueueSize)
146 o.MaxQueueSize = size
|
| /dports/misc/concourse/concourse-6.7.2/vendor/go.opentelemetry.io/otel/sdk/trace/ |
| H A D | batch_span_processor.go | 42 MaxQueueSize int member
90 MaxQueueSize: defaultMaxQueueSize,
101 bsp.queue = make(chan *export.SpanData, bsp.o.MaxQueueSize)
146 o.MaxQueueSize = size
|
| /dports/www/oauth2-proxy/oauth2-proxy-7.2.0/vendor/go.opentelemetry.io/otel/sdk/trace/ |
| H A D | batch_span_processor.go | 44 MaxQueueSize int member
94 MaxQueueSize: DefaultMaxQueueSize,
105 queue: make(chan *export.SpanData, o.MaxQueueSize),
139 o.MaxQueueSize = size
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/centrifugal/centrifuge/ |
| H A D | writer.go | 12 MaxQueueSize int member
122 if w.config.MaxQueueSize > 0 && w.messages.Size() > w.config.MaxQueueSize {
|
| H A D | writer_test.go | 186 MaxQueueSize: 10 * 1024,
225 MaxQueueSize: 10 * 1024,
254 MaxQueueSize: 1,
268 MaxQueueSize: 1,
284 MaxQueueSize: 1,
|
| /dports/security/vuls/vuls-0.13.7/vendor/go.opentelemetry.io/otel/sdk/trace/ |
| H A D | batch_span_processor.go | 40 MaxQueueSize int member
89 MaxQueueSize: DefaultMaxQueueSize,
100 queue: make(chan *export.SpanData, o.MaxQueueSize),
154 o.MaxQueueSize = size
|
| /dports/security/go-cve-dictionary/go-cve-dictionary-0.5.5/vendor/go.opentelemetry.io/otel/sdk/trace/ |
| H A D | batch_span_processor.go | 40 MaxQueueSize int member
89 MaxQueueSize: DefaultMaxQueueSize,
100 queue: make(chan *export.SpanData, o.MaxQueueSize),
154 o.MaxQueueSize = size
|
| /dports/net/storj/storj-1.45.3/vendor/go.opentelemetry.io/otel/sdk/trace/ |
| H A D | batch_span_processor.go | 40 MaxQueueSize int member
89 MaxQueueSize: DefaultMaxQueueSize,
100 queue: make(chan *export.SpanSnapshot, o.MaxQueueSize),
159 o.MaxQueueSize = size
|
| /dports/net-im/matterircd/matterircd-0.25.0/vendor/github.com/mattermost/mattermost-server/v6/shared/mlog/ |
| H A D | options.go | 12 func MaxQueueSize(size int) Option { func
13 return logr.MaxQueueSize(size)
|
| /dports/www/mattermost-server/mattermost-server-6.0.2/shared/mlog/ |
| H A D | options.go | 12 func MaxQueueSize(size int) Option { func
13 return logr.MaxQueueSize(size)
|
| /dports/games/automuteus/automuteus-6.15.2/vendor/go.opentelemetry.io/otel/sdk/trace/ |
| H A D | batch_span_processor.go | 40 MaxQueueSize int member
86 MaxQueueSize: DefaultMaxQueueSize,
97 queue: make(chan *export.SpanSnapshot, o.MaxQueueSize),
156 o.MaxQueueSize = size
|
| /dports/net-p2p/bitmark-recorder/bitmarkd-0.13.3/vendor/github.com/cihub/seelog/ |
| H A D | behavior_asynclogger.go | 35 MaxQueueSize = 10000 const
129 if asnLogger.msgQueue.Len() >= MaxQueueSize {
130 … fmt.Printf("Seelog queue overflow: more than %v messages in the queue. Flushing.\n", MaxQueueSize)
|
| /dports/net-p2p/bitmark/bitmarkd-0.13.3/vendor/github.com/cihub/seelog/ |
| H A D | behavior_asynclogger.go | 35 MaxQueueSize = 10000 const
129 if asnLogger.msgQueue.Len() >= MaxQueueSize {
130 … fmt.Printf("Seelog queue overflow: more than %v messages in the queue. Flushing.\n", MaxQueueSize)
|
| /dports/net-p2p/bitmark-cli/bitmarkd-0.13.3/vendor/github.com/cihub/seelog/ |
| H A D | behavior_asynclogger.go | 35 MaxQueueSize = 10000
129 if asnLogger.msgQueue.Len() >= MaxQueueSize {
130 … fmt.Printf("Seelog queue overflow: more than %v messages in the queue. Flushing.\n", MaxQueueSize)
|
| /dports/net-p2p/bitmark-daemon/bitmarkd-0.13.3/vendor/github.com/cihub/seelog/ |
| H A D | behavior_asynclogger.go | 35 MaxQueueSize = 10000 const
129 if asnLogger.msgQueue.Len() >= MaxQueueSize {
130 … fmt.Printf("Seelog queue overflow: more than %v messages in the queue. Flushing.\n", MaxQueueSize)
|
| /dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/sample/app/connect/ |
| H A D | ncbi_usage_report_sample.ini | 6 ; You can write "MaxQueueSize" or "maxqueuesize" for example.
23 MaxQueueSize = 100 key
|
| /dports/security/vault/vault-1.8.2/vendor/go.opentelemetry.io/otel/sdk/trace/ |
| H A D | batch_span_processor.go | 40 MaxQueueSize int member
92 MaxQueueSize: DefaultMaxQueueSize,
103 queue: make(chan *SpanSnapshot, o.MaxQueueSize),
178 o.MaxQueueSize = size
|
| /dports/sysutils/kubectl/kubernetes-1.22.2/vendor/go.opentelemetry.io/otel/sdk/trace/ |
| H A D | batch_span_processor.go | 40 MaxQueueSize int member
92 MaxQueueSize: DefaultMaxQueueSize,
103 queue: make(chan *SpanSnapshot, o.MaxQueueSize),
178 o.MaxQueueSize = size
|
| /dports/www/grafana8/grafana-8.3.6/vendor/go.opentelemetry.io/otel/sdk/trace/ |
| H A D | batch_span_processor.go | 42 MaxQueueSize int member
94 MaxQueueSize: DefaultMaxQueueSize,
105 queue: make(chan ReadOnlySpan, o.MaxQueueSize),
197 o.MaxQueueSize = size
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-database-couchbase/vendor/github.com/couchbase/gocbcore/v9/ |
| H A D | agentgroup_config.go | 43 MaxQueueSize: config.MaxQueueSize,
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/couchbase/gocbcore/v9/ |
| H A D | agentgroup_config.go | 43 MaxQueueSize: config.MaxQueueSize,
|
| /dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/connect/ |
| H A D | ncbi_usage_report.cpp | 74 NCBI_PARAM_DECL(unsigned, USAGE_REPORT, MaxQueueSize);
75 NCBI_PARAM_DEF_EX(unsigned, USAGE_REPORT, MaxQueueSize, kDefault_MaxQueueSize, eParam_NoThread, NCB…
144 NCBI_PARAM_TYPE(USAGE_REPORT, MaxQueueSize)::SetDefault(n ? n : kDefault_MaxQueueSize); in SetMaxQueueSize()
180 return NCBI_PARAM_TYPE(USAGE_REPORT, MaxQueueSize)::GetDefault(); in GetMaxQueueSize()
|