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 warmUpTimeInMilliseconds;
    private final int tickInterval;

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

        this.requestsPerSecond = builder.requestsPerSecond;
        this.maxLoadThreads = builder.maxLoadThreads;
        this.warmUpTimeInMilliseconds = builder.warmUpTimeInMilliseconds;
        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 = 500;
        static final int DEFAULT_WARM_UP_TIME = -1;
        private final long requestsPerSecond;
        private long maxLoadThreads;
        private long warmUpTimeInMilliseconds;

        // 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.warmUpTimeInMilliseconds = 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 withWarmUpTimeInMilliseconds(long warmUpTimeInMilliseconds) {
            if (warmUpTimeInMilliseconds < 0) {
                throw new IllegalArgumentException(
                        String.format("The warm up time value in milliseconds. must be >= 0. Provided value is %s", warmUpTimeInMilliseconds));
            }
            this.warmUpTimeInMilliseconds = warmUpTimeInMilliseconds;
            return this;
        }
    }

    public long getRequestsPerSecond() {
        return requestsPerSecond;
    }

    public long getMaxLoadThreads() {
        return maxLoadThreads;
    }

    public long getWarmUpTimeInMilliseconds() {
        return warmUpTimeInMilliseconds;
    }

    public int getTickInterval() {
        return tickInterval;
    }
}