JParallelTestsGroup.java

Go to the documentation of this file.

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

import com.griddynamics.jagger.engine.e1.Provider;
import com.griddynamics.jagger.engine.e1.collector.testgroup.TestGroupDecisionMakerListener;
import com.griddynamics.jagger.engine.e1.collector.testgroup.TestGroupListener;
import com.griddynamics.jagger.user.test.configurations.auxiliary.Id;

import com.google.common.collect.Lists;

import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.stream.Collectors;

public class JParallelTestsGroup {
    private final String id;
    private final List<JLoadTest> tests;
    private final List<Provider<TestGroupListener>> listeners;
    private final List<Provider<TestGroupDecisionMakerListener>> decisionMakerListeners;

    public static Builder builder(Id id, List<JLoadTest> tests) {
        return new Builder(id, tests);
    }

    public static Builder builder(Id id, JLoadTest test, JLoadTest... tests) {
        
        List<JLoadTest> testList = new ArrayList<>();
        testList.add(test);
        Collections.addAll(testList, tests);
        
        return new Builder(id, testList);
    }

    private JParallelTestsGroup(Builder builder) {
        this.id = builder.id.value();
        this.tests = builder.tests;
        this.listeners = builder.listeners;
        this.decisionMakerListeners = builder.decisionMakerListeners;
    }

    public static class Builder {
        
        private final Id id;
        private final List<JLoadTest> tests;
        private List<Provider<TestGroupListener>> listeners = Lists.newArrayList();
        private List<Provider<TestGroupDecisionMakerListener>> decisionMakerListeners = Lists.newArrayList();
    
        public Builder(Id id, List<JLoadTest> tests) {
            this.id = id;
            this.tests = tests;
        }
    
        public Builder addListener(Provider<TestGroupListener> listener) {
            this.listeners.add(listener);
            return this;
        }
    
        public Builder addListeners(List<Provider<TestGroupListener>> listeners) {
            this.listeners.addAll(listeners);
            return this;
        }
    
        public Builder addDecisionMakerListener(Provider<TestGroupDecisionMakerListener> listener) {
            this.decisionMakerListeners.add(listener);
            return this;
        }
    
        public Builder addDecisionMakerListeners(List<Provider<TestGroupDecisionMakerListener>> listeners) {
            this.decisionMakerListeners.addAll(listeners);
            return this;
        }

        public JParallelTestsGroup build() {
    
            if (tests.stream().map(JLoadTest::getId).collect(Collectors.toSet()).size() < tests.size()) {
                throw new IllegalStateException("JLoadTest ids inside one JParallelTestsGroup are not all unique");
            }
            
            return new JParallelTestsGroup(this);
        }

    }

    public List<JLoadTest> getTests() {
        return tests;
    }

    public String getId() {
        return id;
    }
    
    public List<Provider<TestGroupListener>> getListeners() {
        return listeners;
    }
    
    public List<Provider<TestGroupDecisionMakerListener>> getDecisionMakerListeners() {
        return decisionMakerListeners;
    }
}