Home
last modified time | relevance | path

Searched refs:retryState (Results 1 – 14 of 14) sorted by relevance

/dports/devel/spark/spark-2.1.1/mesos/src/main/scala/org/apache/spark/deploy/mesos/
H A DMesosDriverDescription.scala47 val retryState: Option[MesosClusterRetryState] = None) constant
63 retryState: Option[MesosClusterRetryState] = retryState): MesosDriverDescription = {
66 submissionId, submissionDate, retryState)
/dports/databases/tile38/tile38-1.12.0/vendor/github.com/Shopify/sarama/
H A Dasync_producer.go378 retryState []partitionRetryState member
395 retryState: make([]partitionRetryState, p.conf.Producer.Retry.Max+1),
421 pp.retryState[msg.retries].expectChaser = false
424 pp.retryState[msg.retries].buf = append(pp.retryState[msg.retries].buf, msg)
430 pp.retryState[pp.highWatermark].expectChaser = false
463 pp.retryState[pp.highWatermark].expectChaser = true
480 pp.parent.returnErrors(pp.retryState[pp.highWatermark].buf, err)
486 for _, msg := range pp.retryState[pp.highWatermark].buf {
491 pp.retryState[pp.highWatermark].buf = nil
492 if pp.retryState[pp.highWatermark].expectChaser {
/dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/google/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/
H A Dasync_producer.go372 retryState []partitionRetryState member
389 retryState: make([]partitionRetryState, p.conf.Producer.Retry.Max+1),
415 pp.retryState[msg.retries].expectChaser = false
418 pp.retryState[msg.retries].buf = append(pp.retryState[msg.retries].buf, msg)
424 pp.retryState[pp.highWatermark].expectChaser = false
457 pp.retryState[pp.highWatermark].expectChaser = true
474 pp.parent.returnErrors(pp.retryState[pp.highWatermark].buf, err)
480 for _, msg := range pp.retryState[pp.highWatermark].buf {
485 pp.retryState[pp.highWatermark].buf = nil
486 if pp.retryState[pp.highWatermark].expectChaser {
/dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/sarama-1.19.0/
H A Dasync_producer.go406 retryState []partitionRetryState member
423 retryState: make([]partitionRetryState, p.conf.Producer.Retry.Max+1),
449 pp.retryState[msg.retries].expectChaser = false
452 pp.retryState[msg.retries].buf = append(pp.retryState[msg.retries].buf, msg)
458 pp.retryState[pp.highWatermark].expectChaser = false
491 pp.retryState[pp.highWatermark].expectChaser = true
508 pp.parent.returnErrors(pp.retryState[pp.highWatermark].buf, err)
514 for _, msg := range pp.retryState[pp.highWatermark].buf {
519 pp.retryState[pp.highWatermark].buf = nil
520 if pp.retryState[pp.highWatermark].expectChaser {
/dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/
H A Dasync_producer.go406 retryState []partitionRetryState member
423 retryState: make([]partitionRetryState, p.conf.Producer.Retry.Max+1),
449 pp.retryState[msg.retries].expectChaser = false
452 pp.retryState[msg.retries].buf = append(pp.retryState[msg.retries].buf, msg)
458 pp.retryState[pp.highWatermark].expectChaser = false
491 pp.retryState[pp.highWatermark].expectChaser = true
508 pp.parent.returnErrors(pp.retryState[pp.highWatermark].buf, err)
514 for _, msg := range pp.retryState[pp.highWatermark].buf {
519 pp.retryState[pp.highWatermark].buf = nil
520 if pp.retryState[pp.highWatermark].expectChaser {
/dports/devel/spark/spark-2.1.1/mesos/src/main/scala/org/apache/spark/deploy/mesos/ui/
H A DMesosClusterPage.scala106 <td>{submission.retryState.get.lastFailureStatus}</td>
107 <td>{submission.retryState.get.nextRetry}</td>
108 <td>{submission.retryState.get.retries}</td>
H A DDriverPage.scala67 retryHeaders, retryRow, Iterable.apply(driverState.description.retryState))
164 private def retryRow(retryState: Option[MesosClusterRetryState]): Seq[Node] = {
165 retryState.map { state =>
/dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/sarama-1.26.4/
H A Dasync_producer.go486 retryState []partitionRetryState member
503 retryState: make([]partitionRetryState, p.conf.Producer.Retry.Max+1),
561 pp.retryState[msg.retries].expectChaser = false
564 pp.retryState[msg.retries].buf = append(pp.retryState[msg.retries].buf, msg)
570 pp.retryState[pp.highWatermark].expectChaser = false
608 pp.retryState[pp.highWatermark].expectChaser = true
625 pp.parent.returnErrors(pp.retryState[pp.highWatermark].buf, err)
631 for _, msg := range pp.retryState[pp.highWatermark].buf {
636 pp.retryState[pp.highWatermark].buf = nil
637 if pp.retryState[pp.highWatermark].expectChaser {
/dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/
H A Dasync_producer.go486 retryState []partitionRetryState member
503 retryState: make([]partitionRetryState, p.conf.Producer.Retry.Max+1),
561 pp.retryState[msg.retries].expectChaser = false
564 pp.retryState[msg.retries].buf = append(pp.retryState[msg.retries].buf, msg)
570 pp.retryState[pp.highWatermark].expectChaser = false
608 pp.retryState[pp.highWatermark].expectChaser = true
625 pp.parent.returnErrors(pp.retryState[pp.highWatermark].buf, err)
631 for _, msg := range pp.retryState[pp.highWatermark].buf {
636 pp.retryState[pp.highWatermark].buf = nil
637 if pp.retryState[pp.highWatermark].expectChaser {
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/Shopify/sarama/
H A Dasync_producer.go493 retryState []partitionRetryState member
510 retryState: make([]partitionRetryState, p.conf.Producer.Retry.Max+1),
568 pp.retryState[msg.retries].expectChaser = false
571 pp.retryState[msg.retries].buf = append(pp.retryState[msg.retries].buf, msg)
577 pp.retryState[pp.highWatermark].expectChaser = false
615 pp.retryState[pp.highWatermark].expectChaser = true
632 pp.parent.returnErrors(pp.retryState[pp.highWatermark].buf, err)
638 for _, msg := range pp.retryState[pp.highWatermark].buf {
643 pp.retryState[pp.highWatermark].buf = nil
644 if pp.retryState[pp.highWatermark].expectChaser {
/dports/devel/spark/spark-2.1.1/mesos/src/main/scala/org/apache/spark/scheduler/cluster/mesos/
H A DMesosClusterScheduler.scala238 .get.retryState.get.lastFailureStatus
594 d.retryState.get.nextRetry.before(currentTime)
674 val retryState: Option[MesosClusterRetryState] = state.driverDescription.retryState constant
675 val (retries, waitTimeSec) = retryState
681 retryState = Some(new MesosClusterRetryState(status, retries, nextRetry, waitTimeSec)))
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/thanos-io/thanos/pkg/receive/
H A Dhandler.go97 peerStates map[string]*retryState
183 h.peerStates = make(map[string]*retryState)
541 h.peerStates[endpoint] = &retryState{nextAllowed: time.Now().Add(h.expBackoff.ForAttempt(0))}
686 type retryState struct { struct
/dports/www/ilias/ILIAS-5.4.25/libs/composer/vendor/simplesamlphp/simplesamlphp/modules/negotiate/docs/
H A Dnegotiate.md212 $retryState = SimpleSAML_Auth_State::cloneState($state);
213 unset($retryState[SimpleSAML_Auth_State::ID]);
214 …$nego_retry = SimpleSAML_Auth_State::saveState($retryState, 'sspmod_negotiate_Auth_Source_Negotiat…
/dports/deskutils/egroupware/egroupware/vendor/simplesamlphp/simplesamlphp/modules/negotiate/docs/
H A Dnegotiate.md212 $retryState = \SimpleSAML\Auth\State::cloneState($state);
213 unset($retryState[\SimpleSAML\Auth\State::ID]);
214 …$nego_retry = \SimpleSAML\Auth\State::saveState($retryState, '\SimpleSAML\Module\negotiate\Auth\So…