JLoadProfileRps.java

Go to the documentation of this file.

package com.griddynamics.jagger.user.test.configurations.load;

import com.griddynamics.jagger.user.test.configurations.load.auxiliary.RequestsPerSecond;

import java.util.Objects;

public class JLoadProfileRps implements JLoadProfile {

    private final long requestsPerSecond;
    private final long maxLoadThreads;
    private final long warmUpTimeInSeconds;
    private final int tickInterval;

    private JLoadProfileRps(Builder builder) {
        Objects.requireNonNull(builder);

        this.requestsPerSecond = builder.requestsPerSecond;
        this.maxLoadThreads = builder.maxLoadThreads;
        this.warmUpTimeInSeconds = builder.warmUpTimeInSeconds;
        this.tickInterval = builder.tickInterval;
    }

    public static Builder builder(RequestsPerSecond requestsPerSecond) {
        return new Builder(requestsPerSecond);
    }

    public static class Builder {
        static final int DEFAULT_TICK_INTERVAL = 1000;
        static final int DEFAULT_MAX_LOAD_THREADS = 4000;
        static final int DEFAULT_WARM_UP_TIME = -1;
        private final long requestsPerSecond;
        private long maxLoadThreads;
        private long warmUpTimeInSeconds;

        // Tick interval doesn't have setter, since it's unclear if this field is needed. Check https://issues.griddynamics.net/browse/JFG-1000
        private int tickInterval;

        public Builder(RequestsPerSecond requestsPerSecond) {
            Objects.requireNonNull(requestsPerSecond);

            this.requestsPerSecond = requestsPerSecond.value();
            this.maxLoadThreads = DEFAULT_MAX_LOAD_THREADS;
            this.warmUpTimeInSeconds = DEFAULT_WARM_UP_TIME;
            this.tickInterval = DEFAULT_TICK_INTERVAL;
        }

        public JLoadProfileRps build() {
            return new JLoadProfileRps(this);
        }

        public Builder withMaxLoadThreads(long maxLoadThreads) {
            if (maxLoadThreads <= 0) {
                throw new IllegalArgumentException(String.format("The maximum number of threads must be > 0. Provided value is %s", maxLoadThreads));
            }
            this.maxLoadThreads = maxLoadThreads;
            return this;
        }

        public Builder withWarmUpTimeInSeconds(long warmUpTimeInSeconds) {
            if (warmUpTimeInSeconds < 0) {
                throw new IllegalArgumentException(
                        String.format("The warm up time value in seconds. must be >= 0. Provided value is %s", warmUpTimeInSeconds));
            }
            this.warmUpTimeInSeconds = warmUpTimeInSeconds;
            return this;
        }
    }

    public long getRequestsPerSecond() {
        return requestsPerSecond;
    }

    public long getMaxLoadThreads() {
        return maxLoadThreads;
    }

    public long getWarmUpTimeInSeconds() {
        return warmUpTimeInSeconds;
    }

    public int getTickInterval() {
        return tickInterval;
    }
}