github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-24 06:37:19 -04:00
Code Issues Projects Releases Packages Wiki Activity

Remove unused code and cleanup javadoc comments

Browse source 
Fixes #10233
This commit is contained in:
Dan Hermann 2018-12-21 17:08:12 -06:00
parent 134818e69e
commit 4152f89022
75 changed files with 0 additions and 386 deletions
Download patch file Download diff file Expand all files Collapse all files

3
logstash-core/src/main/java/org/logstash/KeyNode.java
View file

@ -2,9 +2,6 @@ package org.logstash;
import java.util.List;
/**
* Created by ph on 15-05-22.
*/
public class KeyNode {
private KeyNode() {

3
logstash-core/src/main/java/org/logstash/common/IncompleteSourceWithMetadataException.java
View file

@ -2,9 +2,6 @@ package org.logstash.common;
import org.logstash.config.ir.InvalidIRException;
/**
* Created by andrewvc on 6/12/17.
*/
public class IncompleteSourceWithMetadataException extends InvalidIRException {
private static final long serialVersionUID = 456422097113787583L;

3
logstash-core/src/main/java/org/logstash/common/SourceWithMetadata.java
View file

@ -9,9 +9,6 @@ import java.util.Objects;
import java.util.regex.Pattern;
import java.util.stream.Collectors;
/**
* Created by andrewvc on 9/6/16.
*/
public class SourceWithMetadata implements HashableWithSource {
// Either 'file' or something else
private final String protocol;

3
logstash-core/src/main/java/org/logstash/common/Util.java
View file

@ -4,9 +4,6 @@ import java.nio.charset.StandardCharsets;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
/**
* Created by andrewvc on 12/23/16.
*/
public class Util {
// Modified from http://stackoverflow.com/a/11009612/11105

3
logstash-core/src/main/java/org/logstash/config/ir/BaseSourceComponent.java
View file

@ -3,11 +3,8 @@ package org.logstash.config.ir;
import org.logstash.common.SourceWithMetadata;
/**
* Created by andrewvc on 9/6/16.
*
* This class is useful to inherit from for things that need to be source components
* since it handles storage of the meta property for you and reduces a lot of boilerplate.
*
*/
public abstract class BaseSourceComponent implements SourceComponent {
private final SourceWithMetadata meta;

3
logstash-core/src/main/java/org/logstash/config/ir/DSL.java
View file

@ -35,9 +35,6 @@ import org.logstash.config.ir.imperative.NoopStatement;
import org.logstash.config.ir.imperative.PluginStatement;
import org.logstash.config.ir.imperative.Statement;
/**
* Created by andrewvc on 9/15/16.
*/
public class DSL {
public static EventValueExpression eEventValue(SourceWithMetadata meta, String fieldName) {
return new EventValueExpression(meta, fieldName);

3
logstash-core/src/main/java/org/logstash/config/ir/Hashable.java
View file

@ -1,8 +1,5 @@
package org.logstash.config.ir;
/**
* Created by andrewvc on 12/23/16.
*/
public interface Hashable {
String uniqueHash();
}

3
logstash-core/src/main/java/org/logstash/config/ir/HashableWithSource.java
View file

@ -2,9 +2,6 @@ package org.logstash.config.ir;
import org.logstash.common.Util;
/**
* Created by andrewvc on 6/12/17.
*/
public interface HashableWithSource extends Hashable {
@Override
default String uniqueHash() {

3
logstash-core/src/main/java/org/logstash/config/ir/InvalidIRException.java
View file

@ -1,8 +1,5 @@
package org.logstash.config.ir;
/**
* Created by andrewvc on 9/6/16.
*/
public class InvalidIRException extends Exception {
public InvalidIRException(String s) {
super(s);

3
logstash-core/src/main/java/org/logstash/config/ir/PipelineIR.java
View file

@ -9,9 +9,6 @@ import org.logstash.config.ir.graph.PluginVertex;
import org.logstash.config.ir.graph.QueueVertex;
import org.logstash.config.ir.graph.Vertex;
/**
* Created by andrewvc on 9/20/16.
*/
public final class PipelineIR implements Hashable {
private final String uniqueHash;

3
logstash-core/src/main/java/org/logstash/config/ir/PluginDefinition.java
View file

@ -8,9 +8,6 @@ import java.util.Set;
import org.logstash.ObjectMappers;
import org.logstash.common.SourceWithMetadata;
/**
* Created by andrewvc on 9/20/16.
*/
public final class PluginDefinition implements SourceComponent, HashableWithSource {
@Override

3
logstash-core/src/main/java/org/logstash/config/ir/SourceComponent.java
View file

@ -2,9 +2,6 @@ package org.logstash.config.ir;
import org.logstash.common.SourceWithMetadata;
/**
* Created by andrewvc on 9/16/16.
*/
public interface SourceComponent {
boolean sourceComponentEquals(SourceComponent sourceComponent);
SourceWithMetadata getSourceWithMetadata();

3
logstash-core/src/main/java/org/logstash/config/ir/expression/BinaryBooleanExpression.java
View file

@ -4,9 +4,6 @@ import org.logstash.common.SourceWithMetadata;
import org.logstash.common.Util;
import org.logstash.config.ir.SourceComponent;
/**
* Created by andrewvc on 9/6/16.
*/
public abstract class BinaryBooleanExpression extends BooleanExpression {
@Override
public boolean sourceComponentEquals(SourceComponent sourceComponent) {

3
logstash-core/src/main/java/org/logstash/config/ir/expression/BooleanExpression.java
View file

@ -2,9 +2,6 @@ package org.logstash.config.ir.expression;
import org.logstash.common.SourceWithMetadata;
/**
* Created by andrewvc on 9/14/16.
*/
public abstract class BooleanExpression extends Expression {
public BooleanExpression(SourceWithMetadata meta) {
super(meta);

3
logstash-core/src/main/java/org/logstash/config/ir/expression/EventValueExpression.java
View file

@ -3,9 +3,6 @@ package org.logstash.config.ir.expression;
import org.logstash.config.ir.SourceComponent;
import org.logstash.common.SourceWithMetadata;
/**
* Created by andrewvc on 9/13/16.
*/
public class EventValueExpression extends Expression {
private final String fieldName;

1
logstash-core/src/main/java/org/logstash/config/ir/expression/Expression.java
View file

@ -10,7 +10,6 @@ import org.logstash.config.ir.HashableWithSource;
*
* if [foo]
* notnull(eEventValue("foo"))
* Created by andrewvc on 9/6/16.
*/
public abstract class Expression extends BaseSourceComponent implements HashableWithSource {

3
logstash-core/src/main/java/org/logstash/config/ir/expression/RegexValueExpression.java
View file

@ -4,9 +4,6 @@ import org.logstash.common.SourceWithMetadata;
import org.logstash.config.ir.InvalidIRException;
import org.logstash.config.ir.SourceComponent;
/**
* Created by andrewvc on 9/15/16.
*/
public class RegexValueExpression extends ValueExpression {
private final String regex;

3
logstash-core/src/main/java/org/logstash/config/ir/expression/UnaryBooleanExpression.java
View file

@ -3,9 +3,6 @@ package org.logstash.config.ir.expression;
import org.logstash.config.ir.InvalidIRException;
import org.logstash.common.SourceWithMetadata;
/**
* Created by andrewvc on 9/13/16.
*/
public abstract class UnaryBooleanExpression extends BooleanExpression {
private final Expression expression;

3
logstash-core/src/main/java/org/logstash/config/ir/expression/ValueExpression.java
View file

@ -8,9 +8,6 @@ import org.logstash.common.SourceWithMetadata;
import org.logstash.config.ir.InvalidIRException;
import org.logstash.config.ir.SourceComponent;
/**
* Created by andrewvc on 9/13/16.
*/
public class ValueExpression extends Expression {
protected final Object value;

3
logstash-core/src/main/java/org/logstash/config/ir/expression/binary/And.java
View file

@ -4,9 +4,6 @@ import org.logstash.common.SourceWithMetadata;
import org.logstash.config.ir.expression.BinaryBooleanExpression;
import org.logstash.config.ir.expression.Expression;
/**
* Created by andrewvc on 9/21/16.
*/
public class And extends BinaryBooleanExpression {
public And(SourceWithMetadata meta, Expression left, Expression right) {
super(meta, left, right);

3
logstash-core/src/main/java/org/logstash/config/ir/expression/binary/Eq.java
View file

@ -4,9 +4,6 @@ import org.logstash.common.SourceWithMetadata;
import org.logstash.config.ir.expression.BinaryBooleanExpression;
import org.logstash.config.ir.expression.Expression;
/**
* Created by andrewvc on 9/21/16.
*/
public class Eq extends BinaryBooleanExpression {
public Eq(SourceWithMetadata meta, Expression left, Expression right) {
super(meta, left, right);

3
logstash-core/src/main/java/org/logstash/config/ir/expression/binary/Gt.java
View file

@ -4,9 +4,6 @@ import org.logstash.common.SourceWithMetadata;
import org.logstash.config.ir.expression.BinaryBooleanExpression;
import org.logstash.config.ir.expression.Expression;
/**
* Created by andrewvc on 9/21/16.
*/
public class Gt extends BinaryBooleanExpression {
public Gt(SourceWithMetadata meta, Expression left, Expression right) {
super(meta, left, right);

3
logstash-core/src/main/java/org/logstash/config/ir/expression/binary/Gte.java
View file

@ -4,9 +4,6 @@ import org.logstash.common.SourceWithMetadata;
import org.logstash.config.ir.expression.BinaryBooleanExpression;
import org.logstash.config.ir.expression.Expression;
/**
* Created by andrewvc on 9/21/16.
*/
public class Gte extends BinaryBooleanExpression {
public Gte(SourceWithMetadata meta, Expression left, Expression right) {
super(meta, left, right);

3
logstash-core/src/main/java/org/logstash/config/ir/expression/binary/In.java
View file

@ -4,9 +4,6 @@ import org.logstash.common.SourceWithMetadata;
import org.logstash.config.ir.expression.BinaryBooleanExpression;
import org.logstash.config.ir.expression.Expression;
/**
* Created by andrewvc on 9/21/16.
*/
public class In extends BinaryBooleanExpression {
public In(SourceWithMetadata meta, Expression left, Expression right) {
super(meta, left, right);

3
logstash-core/src/main/java/org/logstash/config/ir/expression/binary/Lt.java
View file

@ -4,9 +4,6 @@ import org.logstash.common.SourceWithMetadata;
import org.logstash.config.ir.expression.BinaryBooleanExpression;
import org.logstash.config.ir.expression.Expression;
/**
* Created by andrewvc on 9/21/16.
*/
public class Lt extends BinaryBooleanExpression {
public Lt(SourceWithMetadata meta, Expression left, Expression right) {
super(meta, left, right);

3
logstash-core/src/main/java/org/logstash/config/ir/expression/binary/Lte.java
View file

@ -4,9 +4,6 @@ import org.logstash.common.SourceWithMetadata;
import org.logstash.config.ir.expression.BinaryBooleanExpression;
import org.logstash.config.ir.expression.Expression;
/**
* Created by andrewvc on 9/21/16.
*/
public class Lte extends BinaryBooleanExpression {
public Lte(SourceWithMetadata meta, Expression left, Expression right) {
super(meta, left, right);

3
logstash-core/src/main/java/org/logstash/config/ir/expression/binary/Neq.java
View file

@ -4,9 +4,6 @@ import org.logstash.common.SourceWithMetadata;
import org.logstash.config.ir.expression.BinaryBooleanExpression;
import org.logstash.config.ir.expression.Expression;
/**
* Created by andrewvc on 9/21/16.
*/
public class Neq extends BinaryBooleanExpression {
public Neq(SourceWithMetadata meta, Expression left, Expression right) {
super(meta, left, right);

3
logstash-core/src/main/java/org/logstash/config/ir/expression/binary/Or.java
View file

@ -4,9 +4,6 @@ import org.logstash.common.SourceWithMetadata;
import org.logstash.config.ir.expression.BinaryBooleanExpression;
import org.logstash.config.ir.expression.Expression;
/**
* Created by andrewvc on 9/21/16.
*/
public class Or extends BinaryBooleanExpression {
public Or(SourceWithMetadata meta, Expression left, Expression right) {
super(meta, left, right);

3
logstash-core/src/main/java/org/logstash/config/ir/expression/binary/RegexEq.java
View file

@ -6,9 +6,6 @@ import org.logstash.config.ir.expression.BinaryBooleanExpression;
import org.logstash.config.ir.expression.Expression;
import org.logstash.config.ir.expression.RegexValueExpression;
/**
* Created by andrewvc on 9/21/16.
*/
public class RegexEq extends BinaryBooleanExpression {
public RegexEq(SourceWithMetadata meta, Expression left, Expression right) throws InvalidIRException {
super(meta, left, right);

3
logstash-core/src/main/java/org/logstash/config/ir/expression/unary/Not.java
View file

@ -6,9 +6,6 @@ import org.logstash.common.SourceWithMetadata;
import org.logstash.config.ir.expression.Expression;
import org.logstash.config.ir.expression.UnaryBooleanExpression;
/**
* Created by andrewvc on 9/21/16.
*/
public class Not extends UnaryBooleanExpression {
public Not(SourceWithMetadata meta, Expression expression) throws InvalidIRException {
super(meta, expression);

3
logstash-core/src/main/java/org/logstash/config/ir/expression/unary/Truthy.java
View file

@ -6,9 +6,6 @@ import org.logstash.common.SourceWithMetadata;
import org.logstash.config.ir.expression.Expression;
import org.logstash.config.ir.expression.UnaryBooleanExpression;
/**
* Created by andrewvc on 9/21/16.
*/
public class Truthy extends UnaryBooleanExpression {
public Truthy(SourceWithMetadata meta, Expression expression) throws InvalidIRException {
super(meta, expression);

3
logstash-core/src/main/java/org/logstash/config/ir/graph/BooleanEdge.java
View file

@ -4,9 +4,6 @@ import org.logstash.common.Util;
import org.logstash.config.ir.SourceComponent;
import org.logstash.config.ir.InvalidIRException;
/**
* Created by andrewvc on 9/15/16.
*/
public final class BooleanEdge extends Edge {
public static class BooleanEdgeFactory extends EdgeFactory {
public Boolean getEdgeType() {

3
logstash-core/src/main/java/org/logstash/config/ir/graph/Edge.java
View file

@ -5,9 +5,6 @@ import org.logstash.common.SourceWithMetadata;
import org.logstash.config.ir.InvalidIRException;
import org.logstash.config.ir.SourceComponent;
/**
* Created by andrewvc on 9/15/16.
*/
public abstract class Edge implements SourceComponent {
private final Vertex from;

4
logstash-core/src/main/java/org/logstash/config/ir/graph/Graph.java
View file

@ -9,15 +9,11 @@ import org.logstash.config.ir.graph.algorithms.BreadthFirst;
import org.logstash.config.ir.graph.algorithms.GraphDiff;
import org.logstash.config.ir.graph.algorithms.TopologicalSort;
import java.security.MessageDigest;
import java.util.*;
import java.util.function.BiFunction;
import java.util.stream.Collectors;
import java.util.stream.Stream;
/**
* Created by andrewvc on 9/15/16.
*/
public final class Graph implements SourceComponent, Hashable {
private final Set<Vertex> vertices = new LinkedHashSet<>();
private final Set<Edge> edges = new LinkedHashSet<>();

3
logstash-core/src/main/java/org/logstash/config/ir/graph/IfVertex.java
View file

@ -8,9 +8,6 @@ import org.logstash.common.SourceWithMetadata;
import org.logstash.config.ir.SourceComponent;
import org.logstash.config.ir.expression.BooleanExpression;
/**
* Created by andrewvc on 9/15/16.
*/
public class IfVertex extends Vertex {
public BooleanExpression getBooleanExpression() {

3
logstash-core/src/main/java/org/logstash/config/ir/graph/PlainEdge.java
View file

@ -3,9 +3,6 @@ package org.logstash.config.ir.graph;
import org.logstash.common.Util;
import org.logstash.config.ir.InvalidIRException;
/**
* Created by andrewvc on 9/19/16.
*/
public class PlainEdge extends Edge {
public static class PlainEdgeFactory extends Edge.EdgeFactory {
@Override

6
logstash-core/src/main/java/org/logstash/config/ir/graph/PluginVertex.java
View file

@ -1,15 +1,9 @@
package org.logstash.config.ir.graph;
import com.fasterxml.jackson.core.JsonProcessingException;
import org.logstash.ObjectMappers;
import org.logstash.common.SourceWithMetadata;
import org.logstash.common.Util;
import org.logstash.config.ir.PluginDefinition;
import org.logstash.config.ir.SourceComponent;
/**
* Created by andrewvc on 9/15/16.
*/
public class PluginVertex extends Vertex {
private final PluginDefinition pluginDefinition;

3
logstash-core/src/main/java/org/logstash/config/ir/graph/QueueVertex.java
View file

@ -5,9 +5,6 @@ import org.logstash.common.Util;
import org.logstash.config.ir.SourceComponent;
import org.logstash.common.SourceWithMetadata;
/**
* Created by andrewvc on 9/15/16.
*/
public final class QueueVertex extends Vertex {
public QueueVertex() throws IncompleteSourceWithMetadataException {
super(new SourceWithMetadata("internal", "queue", 0,0,"queue"));

5
logstash-core/src/main/java/org/logstash/config/ir/graph/Vertex.java
View file

@ -9,16 +9,11 @@ import org.logstash.config.ir.SourceComponent;
import org.logstash.config.ir.InvalidIRException;
import org.logstash.config.ir.graph.algorithms.DepthFirst;
import java.nio.charset.StandardCharsets;
import java.security.MessageDigest;
import java.util.Collection;
import java.util.Collections;
import java.util.stream.Collectors;
import java.util.stream.Stream;
/**
* Created by andrewvc on 9/15/16.
*/
public abstract class Vertex implements SourceComponent, HashableWithSource {
private static final AtomicInteger SEQUENCE = new AtomicInteger();

4
logstash-core/src/main/java/org/logstash/config/ir/graph/algorithms/BreadthFirst.java
View file

@ -6,10 +6,6 @@ import java.util.*;
import java.util.function.Consumer;
import java.util.stream.Stream;
/**
* Created by andrewvc on 1/5/17.
*
*/
public class BreadthFirst {
public static BfsResult breadthFirst(Collection<Vertex> roots) {
return breadthFirst(roots, false, null);

3
logstash-core/src/main/java/org/logstash/config/ir/graph/algorithms/DepthFirst.java
View file

@ -7,9 +7,6 @@ import java.util.*;
import java.util.stream.Stream;
import java.util.stream.StreamSupport;
/**
* Created by andrewvc on 1/5/17.
*/
public class DepthFirst {
public static Stream<Vertex> depthFirst(Graph g) {
return depthFirst(g.getRoots());

3
logstash-core/src/main/java/org/logstash/config/ir/graph/algorithms/GraphDiff.java
View file

@ -9,9 +9,6 @@ import org.logstash.config.ir.graph.Edge;
import org.logstash.config.ir.graph.Graph;
import org.logstash.config.ir.graph.Vertex;
/**
* Created by andrewvc on 1/5/17.
*/
public class GraphDiff {
public static DiffResult diff(Graph left, Graph right) {
List<Edge> removedEdges = left.edges().filter(e -> !right.hasEquivalentEdge(e)).collect(Collectors.toList());

106
logstash-core/src/main/java/org/logstash/config/ir/graph/algorithms/ShortestPath.java
View file

@ -1,106 +0,0 @@
package org.logstash.config.ir.graph.algorithms;
import org.logstash.config.ir.graph.Vertex;
import java.util.*;
import java.util.stream.Collectors;
import java.util.stream.Stream;
/**
* Created by andrewvc on 1/5/17.
* This class isn't currently used anywhere, I wrote it for some code that is now removed, however, I'm sure it will be
* useful shortly, so we should hold onto it for a while.
*/
public class ShortestPath {
static class InvalidShortestPathArguments extends Exception {
private static final long serialVersionUID = -1493537067800744231L;
private final Collection<Vertex> invalidVertices;
public InvalidShortestPathArguments(Collection<Vertex> invalidVertices) {
super();
this.invalidVertices = invalidVertices;
}
@Override
public String getMessage() {
String verticesMessage = invalidVertices.stream().map(Vertex::toString).collect(Collectors.joining(", "));
return "Attempted to determine path for vertex that is not in the search space!" + verticesMessage;
}
}
public static List<Vertex> shortestPath(Vertex from, Vertex to) throws InvalidShortestPathArguments {
return shortestPath(from, Collections.singleton(to)).get(to);
}
public static Map<Vertex, List<Vertex>> shortestPath(Vertex from, Collection<Vertex> to) throws InvalidShortestPathArguments {
return shortestPath(from, to, false);
}
// Finds the shortest paths to the specified vertices traversing edges backward using Dijkstra's algorithm.
// The items in `to` must be ancestors of this Vertex!
public static Map<Vertex, List<Vertex>> shortestReversePath(Vertex from, Collection<Vertex> to) throws InvalidShortestPathArguments {
return shortestPath(from, to, true);
}
// Finds the shortest paths to the specified vertices using Dijkstra's algorithm.
// The items in `to` must be ancestors of this Vertex!
public static Map<Vertex, List<Vertex>> shortestPath(Vertex from, Collection<Vertex> to, boolean reverseSearch) throws InvalidShortestPathArguments {
Map<Vertex, Integer> vertexDistances = new HashMap<>();
Map<Vertex, Vertex> vertexPathPrevious = new HashMap<>();
List<Vertex> pending = new ArrayList<>();
Stream<Vertex> searchSpace = reverseSearch ? from.ancestors() : from.descendants();
searchSpace.forEach((vertex) -> {
pending.add(vertex);
// Max value is an unknown distance
// using this is more convenient and concise than null in later code
vertexDistances.put(vertex, Integer.MAX_VALUE);
});
pending.add(from);
vertexDistances.put(from, 0);
Collection<Vertex> invalidVertices = to.stream().filter(v -> !pending.contains(v)).collect(Collectors.toList());
if (!invalidVertices.isEmpty()) {
throw new InvalidShortestPathArguments(invalidVertices);
}
while (!pending.isEmpty()) {
Vertex current = pending.stream().min(Comparator.comparing(vertexDistances::get)).get();
int currentDistance = vertexDistances.get(current);
pending.remove(current);
Stream<Vertex> toProcess = reverseSearch ? current.incomingVertices() : current.outgoingVertices();
toProcess.forEach((v) -> {
Integer curDistance = vertexDistances.get(v);
int altDistance = currentDistance + 1; // Fixed cost per edge of 1
if (altDistance < curDistance) {
vertexDistances.put(v, altDistance);
vertexPathPrevious.put(v, current);
}
});
}
Map<Vertex, List<Vertex>> result = new HashMap<>(to.size());
for (Vertex toVertex : to) {
int toVertexDistance = vertexDistances.get(toVertex);
List<Vertex> path = new ArrayList<>(toVertexDistance+1);
Vertex pathCurrentVertex = toVertex;
while (pathCurrentVertex != from) {
path.add(pathCurrentVertex);
pathCurrentVertex = vertexPathPrevious.get(pathCurrentVertex);
}
path.add(from);
Collections.reverse(path);
result.put(toVertex, path);
}
return result;
}
}

3
logstash-core/src/main/java/org/logstash/config/ir/graph/algorithms/TopologicalSort.java
View file

@ -6,9 +6,6 @@ import org.logstash.config.ir.graph.Vertex;
import java.util.*;
/**
* Created by andrewvc on 1/7/17.
*/
public class TopologicalSort {
public static class UnexpectedGraphCycleError extends Exception {
private static final long serialVersionUID = 1778155790783320839L;

3
logstash-core/src/main/java/org/logstash/config/ir/imperative/ComposedParallelStatement.java
View file

@ -6,9 +6,6 @@ import org.logstash.config.ir.graph.Graph;
import java.util.List;
/**
* Created by andrewvc on 9/22/16.
*/
public class ComposedParallelStatement extends ComposedStatement {
public ComposedParallelStatement(SourceWithMetadata meta, List<Statement> statements) throws InvalidIRException {
super(meta, statements);

3
logstash-core/src/main/java/org/logstash/config/ir/imperative/ComposedSequenceStatement.java
View file

@ -6,9 +6,6 @@ import org.logstash.config.ir.graph.Graph;
import java.util.List;
/**
* Created by andrewvc on 9/22/16.
*/
public class ComposedSequenceStatement extends ComposedStatement {
public ComposedSequenceStatement(SourceWithMetadata meta, List<Statement> statements) throws InvalidIRException {
super(meta, statements);

3
logstash-core/src/main/java/org/logstash/config/ir/imperative/ComposedStatement.java
View file

@ -7,9 +7,6 @@ import org.logstash.common.SourceWithMetadata;
import java.util.List;
import java.util.stream.Collectors;
/**
* Created by andrewvc on 9/6/16.
*/
public abstract class ComposedStatement extends Statement {
public interface IFactory {
ComposedStatement make(SourceWithMetadata meta, List<Statement> statements) throws InvalidIRException;

1
logstash-core/src/main/java/org/logstash/config/ir/imperative/IfStatement.java
View file

@ -13,7 +13,6 @@ import java.util.Collection;
import java.util.stream.Collectors;
/**
* Created by andrewvc on 9/6/16.
* if 5 {
*
* }

3
logstash-core/src/main/java/org/logstash/config/ir/imperative/NoopStatement.java
View file

@ -4,9 +4,6 @@ import org.logstash.config.ir.SourceComponent;
import org.logstash.common.SourceWithMetadata;
import org.logstash.config.ir.graph.Graph;
/**
* Created by andrewvc on 9/15/16.
*/
public class NoopStatement extends Statement {
public NoopStatement(SourceWithMetadata meta) {

3
logstash-core/src/main/java/org/logstash/config/ir/imperative/PluginStatement.java
View file

@ -8,9 +8,6 @@ import org.logstash.config.ir.graph.Graph;
import org.logstash.config.ir.graph.PluginVertex;
import org.logstash.config.ir.graph.Vertex;
/**
* Created by andrewvc on 9/6/16.
*/
public class PluginStatement extends Statement {
private final PluginDefinition pluginDefinition;

3
logstash-core/src/main/java/org/logstash/config/ir/imperative/Statement.java
View file

@ -5,9 +5,6 @@ import org.logstash.config.ir.BaseSourceComponent;
import org.logstash.common.SourceWithMetadata;
import org.logstash.config.ir.graph.Graph;
/**
* Created by andrewvc on 9/6/16.
*/
public abstract class Statement extends BaseSourceComponent {
public Statement(SourceWithMetadata meta) {
super(meta);

1
logstash-core/src/main/java/org/logstash/instrument/monitors/HotThreadsMonitor.java
View file

@ -18,7 +18,6 @@ import org.apache.logging.log4j.Logger;
/**
* Hot threads monitoring class. This class pulls information out of the JVM #
* provided beans and lest the different consumers query it.
* Created by purbon on 12/12/15.
*/
public final class HotThreadsMonitor {

3
logstash-core/src/main/java/org/logstash/instrument/monitors/MemoryMonitor.java
View file

@ -8,9 +8,6 @@ import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
* Based on code created by purbon on 13/12/15.
*/
public final class MemoryMonitor {
private MemoryMonitor() {

3
logstash-core/src/main/java/org/logstash/instrument/monitors/ProcessMonitor.java
View file

@ -8,9 +8,6 @@ import java.util.Map;
import java.util.concurrent.TimeUnit;
import javax.management.MBeanServer;
/**
* Created by andrewvc on 5/12/16.
*/
public class ProcessMonitor {
private static final OperatingSystemMXBean osMxBean = ManagementFactory.getOperatingSystemMXBean();
private static final MBeanServer platformMxBean = ManagementFactory.getPlatformMBeanServer();

1
logstash-core/src/main/java/org/logstash/instrument/monitors/SystemMonitor.java
View file

@ -7,7 +7,6 @@ import java.util.Map;
/**
* System information as returned by the different JVM's MxBeans
* Created by purbon on 13/12/15.
*/
public class SystemMonitor {

21
logstash-core/src/main/java/org/logstash/instrument/reports/SystemReport.java
View file

@ -1,21 +0,0 @@
package org.logstash.instrument.reports;
import org.logstash.instrument.monitors.SystemMonitor;
import java.util.Map;
/**
* Created by purbon on 12/12/15.
*/
public class SystemReport {
/**
* Build a report with current System information
* @return a Map with the current system report
*/
public static Map<String, Object> generate() {
return SystemMonitor.detect().toMap();
}
}

1
logstash-core/src/main/java/org/logstash/instrument/reports/ThreadsReport.java
View file

@ -9,7 +9,6 @@ import java.util.stream.Collectors;
/**
* A ThreadsReport object used to hold the hot threads information
* Created by purbon on 12/12/15.
*/
public class ThreadsReport {

3
logstash-core/src/test/java/org/logstash/common/SourceWithMetadataTest.java
View file

@ -6,9 +6,6 @@ import org.junit.runners.Parameterized;
import java.util.Arrays;
/**
* Created by andrewvc on 6/12/17.
*/
@RunWith(Parameterized.class)
public class SourceWithMetadataTest {
private final ParameterGroup parameterGroup;

6
logstash-core/src/test/java/org/logstash/config/ir/IRHelpers.java
View file

@ -10,22 +10,16 @@ import org.logstash.config.ir.graph.Edge;
import org.logstash.config.ir.graph.Graph;
import org.logstash.config.ir.graph.Vertex;
import org.logstash.config.ir.graph.algorithms.GraphDiff;
import org.logstash.config.ir.imperative.Statement;
import javax.xml.transform.Source;
import java.util.HashMap;
import java.util.Objects;
import java.util.Random;
import java.util.UUID;
import java.util.concurrent.Callable;
import java.util.stream.IntStream;
import static org.logstash.config.ir.DSL.*;
import static org.logstash.config.ir.PluginDefinition.Type.*;
/**
* Created by andrewvc on 9/19/16.
*/
public class IRHelpers {
public static void assertSyntaxEquals(SourceComponent left, SourceComponent right) {
String message = String.format("Expected '%s' to equal '%s'", left, right);

3
logstash-core/src/test/java/org/logstash/config/ir/PipelineIRTest.java
View file

@ -9,9 +9,6 @@ import static org.logstash.config.ir.DSL.*;
import static org.logstash.config.ir.PluginDefinition.Type.*;
import static org.logstash.config.ir.IRHelpers.randMeta;
/**
* Created by andrewvc on 9/20/16.
*/
public class PipelineIRTest {
public Graph makeInputSection() throws InvalidIRException {
return iComposeParallel(iPlugin(randMeta(), INPUT, "generator"), iPlugin(randMeta(), INPUT, "stdin")).toGraph();

3
logstash-core/src/test/java/org/logstash/config/ir/graph/BooleanEdgeTest.java
View file

@ -10,9 +10,6 @@ import static org.hamcrest.CoreMatchers.*;
import static org.junit.Assert.assertThat;
import static org.logstash.config.ir.IRHelpers.*;
/**
* Created by andrewvc on 11/21/16.
*/
@RunWith(Theories.class)
public class BooleanEdgeTest {
@DataPoint

4
logstash-core/src/test/java/org/logstash/config/ir/graph/EdgeTest.java
View file

@ -7,10 +7,6 @@ import org.logstash.config.ir.InvalidIRException;
import static org.junit.Assert.*;
import static org.hamcrest.CoreMatchers.*;
/**
* Created by andrewvc on 11/21/16.
*/
public class EdgeTest {
@Test
public void testBasicEdge() throws InvalidIRException {

7
logstash-core/src/test/java/org/logstash/config/ir/graph/GraphTest.java
View file

@ -2,15 +2,11 @@ package org.logstash.config.ir.graph;
import org.junit.Test;
import org.logstash.common.SourceWithMetadata;
import org.logstash.config.ir.DSL;
import org.logstash.config.ir.IRHelpers;
import org.logstash.config.ir.InvalidIRException;
import org.logstash.config.ir.PluginDefinition;
import org.logstash.config.ir.imperative.IfStatement;
import java.util.Collection;
import java.util.Collections;
import java.util.Random;
import static org.hamcrest.CoreMatchers.instanceOf;
import static org.hamcrest.CoreMatchers.is;
@ -19,9 +15,6 @@ import static org.logstash.config.ir.IRHelpers.createTestExpression;
import static org.logstash.config.ir.IRHelpers.createTestVertex;
import static org.logstash.config.ir.IRHelpers.randMeta;
/**
* Created by andrewvc on 11/18/16.
*/
public class GraphTest {
@Test
public void testGraphBasics() throws InvalidIRException {

3
logstash-core/src/test/java/org/logstash/config/ir/graph/IfVertexTest.java
View file

@ -7,9 +7,6 @@ import static org.hamcrest.CoreMatchers.*;
import static org.junit.Assert.assertThat;
import static org.logstash.config.ir.IRHelpers.*;
/**
* Created by andrewvc on 11/22/16.
*/
public class IfVertexTest {
@Test
public void testIfVertexCreation() throws InvalidIRException {

3
logstash-core/src/test/java/org/logstash/config/ir/graph/PlainEdgeTest.java
View file

@ -4,9 +4,6 @@ import org.junit.Test;
import org.logstash.config.ir.IRHelpers;
import org.logstash.config.ir.InvalidIRException;
/**
* Created by andrewvc on 11/22/16.
*/
public class PlainEdgeTest {
@Test
public void creationDoesNotRaiseException() throws InvalidIRException {

3
logstash-core/src/test/java/org/logstash/config/ir/graph/PluginVertexTest.java
View file

@ -12,9 +12,6 @@ import static org.hamcrest.CoreMatchers.*;
import static org.junit.Assert.assertThat;
import static org.logstash.config.ir.IRHelpers.*;
/**
* Created by andrewvc on 11/22/16.
*/
public class PluginVertexTest {
@Test
public void testConstructionIdHandlingWhenNoExplicitId() throws InvalidIRException {

3
logstash-core/src/test/java/org/logstash/config/ir/graph/QueueVertexTest.java
View file

@ -3,9 +3,6 @@ package org.logstash.config.ir.graph;
import org.junit.Test;
import org.logstash.common.IncompleteSourceWithMetadataException;
/**
* Created by andrewvc on 11/22/16.
*/
public class QueueVertexTest {
@Test
public void testConstruction() {

3
logstash-core/src/test/java/org/logstash/config/ir/graph/VertexTest.java
View file

@ -6,9 +6,6 @@ import org.logstash.config.ir.InvalidIRException;
import static org.junit.Assert.*;
/**
* Created by andrewvc on 11/21/16.
*/
public class VertexTest {
@Test
public void TestVertexBasics() throws InvalidIRException {

3
logstash-core/src/test/java/org/logstash/config/ir/graph/algorithms/BreadthFirstTest.java
View file

@ -11,9 +11,6 @@ import static junit.framework.TestCase.assertEquals;
import static org.hamcrest.CoreMatchers.is;
import static org.hamcrest.MatcherAssert.assertThat;
/**
* Created by andrewvc on 1/5/17.
*/
public class BreadthFirstTest {
@Test
public void testBFSBasic() throws InvalidIRException {

3
logstash-core/src/test/java/org/logstash/config/ir/graph/algorithms/DepthFirstTest.java
View file

@ -13,9 +13,6 @@ import java.util.concurrent.atomic.AtomicInteger;
import static junit.framework.TestCase.assertEquals;
/**
* Created by andrewvc on 1/5/17.
*/
public class DepthFirstTest {
Graph g = Graph.empty();
final AtomicInteger visitCount = new AtomicInteger();

3
logstash-core/src/test/java/org/logstash/config/ir/graph/algorithms/GraphDiffTest.java
View file

@ -12,9 +12,6 @@ import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertTrue;
import static org.logstash.config.ir.IRHelpers.createTestVertex;
/**
* Created by andrewvc on 1/5/17.
*/
public class GraphDiffTest {
@Test
public void testIdenticalGraphs() throws InvalidIRException {

38
logstash-core/src/test/java/org/logstash/config/ir/graph/algorithms/ShortestPathTest.java
View file

@ -1,38 +0,0 @@
package org.logstash.config.ir.graph.algorithms;
import org.junit.Test;
import org.logstash.config.ir.InvalidIRException;
import org.logstash.config.ir.graph.Graph;
import org.logstash.config.ir.graph.Vertex;
import java.util.Arrays;
import java.util.List;
import static org.hamcrest.CoreMatchers.is;
import static org.hamcrest.MatcherAssert.assertThat;
import static org.logstash.config.ir.IRHelpers.createTestVertex;
/**
* Created by andrewvc on 1/5/17.
*/
public class ShortestPathTest {
@Test
public void testShortestPathBasic() throws InvalidIRException, ShortestPath.InvalidShortestPathArguments {
Graph g = Graph.empty();
Vertex v1 = createTestVertex("v1");
g.addVertex(v1);
Vertex v2 = createTestVertex("v2");
g.addVertex(v2);
Vertex v3 = createTestVertex("v3");
g.addVertex(v3);
Vertex v4 = createTestVertex("v4");
g.addVertex(v4);
g.chainVertices(v1, v2, v3, v4);
g.chainVertices(v2, v4);
List<Vertex> path = ShortestPath.shortestPath(v1, v4);
List<Vertex> expected = Arrays.asList(v1,v2,v4);
assertThat(path, is(expected));
}
}

3
logstash-core/src/test/java/org/logstash/config/ir/graph/algorithms/TopologicalSortTest.java
View file

@ -12,9 +12,6 @@ import static org.hamcrest.MatcherAssert.assertThat;
import static org.hamcrest.core.AnyOf.anyOf;
import static org.hamcrest.core.Is.is;
/**
* Created by andrewvc on 1/7/17.
*/
public class TopologicalSortTest {
@Test(expected = InvalidIRException.class)
public void testGraphCycleDetection() throws InvalidIRException {

3
logstash-core/src/test/java/org/logstash/config/ir/imperative/DSLTest.java
View file

@ -10,9 +10,6 @@ import static org.logstash.config.ir.IRHelpers.assertSyntaxEquals;
import static org.logstash.config.ir.PluginDefinition.Type.*;
import static org.logstash.config.ir.IRHelpers.randMeta;
/**
* Created by andrewvc on 9/13/16.
*/
public class DSLTest {
@Test
public void testDSLOnePluginEquality() throws IncompleteSourceWithMetadataException {

3
logstash-core/src/test/java/org/logstash/config/ir/imperative/ImperativeToGraphtest.java
View file

@ -11,9 +11,6 @@ import static org.logstash.config.ir.IRHelpers.assertSyntaxEquals;
import static org.logstash.config.ir.IRHelpers.randMeta;
import static org.logstash.config.ir.PluginDefinition.Type.*;
/**
* Created by andrewvc on 9/15/16.
*/
public class ImperativeToGraphtest {
@Test