/dports/devel/spark/spark-2.1.1/mesos/src/main/scala/org/apache/spark/deploy/mesos/ |
H A D | MesosDriverDescription.scala | 47 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 D | async_producer.go | 378 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 D | async_producer.go | 372 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 D | async_producer.go | 406 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 D | async_producer.go | 406 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 D | MesosClusterPage.scala | 106 <td>{submission.retryState.get.lastFailureStatus}</td> 107 <td>{submission.retryState.get.nextRetry}</td> 108 <td>{submission.retryState.get.retries}</td>
|
H A D | DriverPage.scala | 67 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 D | async_producer.go | 486 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 D | async_producer.go | 486 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 D | async_producer.go | 493 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 D | MesosClusterScheduler.scala | 238 .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 D | handler.go | 97 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 D | negotiate.md | 212 $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 D | negotiate.md | 212 $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…
|