Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -502,21 +502,18 @@ public Builder setDeploymentOptions(WorkerDeploymentOptions deploymentOptions) {
* <p>If the sticky queue is enabled, the poller behavior will be used for the sticky queue as
* well.
*/
@Experimental
public Builder setWorkflowTaskPollersBehavior(PollerBehavior pollerBehavior) {
this.workflowTaskPollersBehavior = pollerBehavior;
return this;
}

/** Set the poller behavior for activity task pollers. */
@Experimental
public Builder setActivityTaskPollersBehavior(PollerBehavior pollerBehavior) {
this.activityTaskPollersBehavior = pollerBehavior;
return this;
}

/** Set the poller behavior for nexus task pollers. */
@Experimental
public Builder setNexusTaskPollersBehavior(PollerBehavior pollerBehavior) {
this.nexusTaskPollersBehavior = pollerBehavior;
return this;
Expand Down Expand Up @@ -894,17 +891,14 @@ public WorkerDeploymentOptions getDeploymentOptions() {
return deploymentOptions;
}

@Experimental
public PollerBehavior getWorkflowTaskPollersBehavior() {
return workflowTaskPollersBehavior;
}

@Experimental
public PollerBehavior getActivityTaskPollersBehavior() {
return activityTaskPollersBehavior;
}

@Experimental
public PollerBehavior getNexusTaskPollersBehavior() {
return nexusTaskPollersBehavior;
}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,7 +1,5 @@
package io.temporal.worker.tuning;

import io.temporal.common.Experimental;

/**
* Defines the behavior of a poller.
*
Expand All @@ -10,5 +8,4 @@
* PollerBehaviorSimpleMaximum}. For all intents and purpose this interface should be considered
* sealed.
*/
@Experimental
public interface PollerBehavior {}
Original file line number Diff line number Diff line change
@@ -1,6 +1,5 @@
package io.temporal.worker.tuning;

import io.temporal.common.Experimental;
import java.util.Objects;
import javax.annotation.Nullable;

Expand All @@ -11,7 +10,6 @@
* <p>If the server does not support autoscaling, then the number of pollers will stay at the
* initial number of pollers.
*/
@Experimental
public final class PollerBehaviorAutoscaling implements PollerBehavior {
private final int minConcurrentTaskPollers;
private final int maxConcurrentTaskPollers;
Expand Down
Loading