Skip to content

Commit 6f33b71

Browse files
committed
Add constructors to remaining DTO objects
1 parent 43bf5d3 commit 6f33b71

10 files changed

+253
-14
lines changed

src/main/java/org/sourcelab/kafka/connect/apiclient/request/dto/ConnectServerVersion.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@ public class ConnectServerVersion {
2626
private String kafkaClusterId;
2727

2828
/**
29-
* Constructor.
29+
* Default Constructor.
3030
*/
3131
public ConnectServerVersion()
3232
{

src/main/java/org/sourcelab/kafka/connect/apiclient/request/dto/ConnectorDefinition.java

Lines changed: 33 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,8 @@
1717

1818
package org.sourcelab.kafka.connect.apiclient.request.dto;
1919

20+
import java.util.ArrayList;
21+
import java.util.HashMap;
2022
import java.util.List;
2123
import java.util.Map;
2224

@@ -29,6 +31,23 @@ public final class ConnectorDefinition {
2931
private Map<String, String> config;
3032
private List<TaskDefinition> tasks;
3133

34+
/**
35+
* Default constructor.
36+
*/
37+
public ConnectorDefinition()
38+
{
39+
}
40+
41+
/**
42+
* Constructor.
43+
*/
44+
public ConnectorDefinition(final String name, final String type, final Map<String, String> config, final List<TaskDefinition> tasks) {
45+
this.name = name;
46+
this.type = type;
47+
this.config = new HashMap<>(config);
48+
this.tasks = new ArrayList<>(tasks);
49+
}
50+
3251
public String getName() {
3352
return name;
3453
}
@@ -62,6 +81,20 @@ public static final class TaskDefinition {
6281
private String connector;
6382
private int task;
6483

84+
/**
85+
* Default Constructor.
86+
*/
87+
public TaskDefinition() {
88+
}
89+
90+
/**
91+
* Constructor.
92+
*/
93+
public TaskDefinition(final String connector, final int task) {
94+
this.connector = connector;
95+
this.task = task;
96+
}
97+
6598
public String getConnector() {
6699
return connector;
67100
}

src/main/java/org/sourcelab/kafka/connect/apiclient/request/dto/ConnectorPlugin.java

Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,21 @@ public final class ConnectorPlugin {
2828
private String type;
2929
private String version;
3030

31+
/**
32+
* Default constructor.
33+
*/
34+
public ConnectorPlugin() {
35+
}
36+
37+
/**
38+
* Constructor.
39+
*/
40+
public ConnectorPlugin(final String className, final String type, final String version) {
41+
this.className = className;
42+
this.type = type;
43+
this.version = version;
44+
}
45+
3146
public String getClassName() {
3247
return className;
3348
}
@@ -44,6 +59,8 @@ public String getVersion() {
4459
public String toString() {
4560
return "ConnectorPlugin{"
4661
+ "className='" + className + '\''
62+
+ ", type='" + type + '\''
63+
+ ", version='" + version + '\''
4764
+ '}';
4865
}
4966
}

src/main/java/org/sourcelab/kafka/connect/apiclient/request/dto/ConnectorPluginConfigDefinition.java

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,14 @@ public final class ConnectorPluginConfigDefinition {
2828
private final String name;
2929
private final Map<String, String> config;
3030

31+
/**
32+
* Create new Builder instance for ConnectorPluginConfigDefinition.
33+
* @return Builder instance for ConnectorPluginConfigDefinition.
34+
*/
35+
public static ConnectorPluginConfigDefinition.Builder newBuilder() {
36+
return new ConnectorPluginConfigDefinition.Builder();
37+
}
38+
3139
/**
3240
* Constructor.
3341
* @param connectorPluginName Name of Connector Plugin.
@@ -46,10 +54,6 @@ public Map<String, String> getConfig() {
4654
return config;
4755
}
4856

49-
public static ConnectorPluginConfigDefinition.Builder newBuilder() {
50-
return new ConnectorPluginConfigDefinition.Builder();
51-
}
52-
5357
@Override
5458
public String toString() {
5559
return "ConnectorPluginConfigDefinition{"

src/main/java/org/sourcelab/kafka/connect/apiclient/request/dto/ConnectorPluginConfigValidationResults.java

Lines changed: 93 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,27 @@ public final class ConnectorPluginConfigValidationResults {
2929
private Collection<String> groups = new ArrayList<>();
3030
private Collection<Config> configs = new ArrayList<>();
3131

32+
/**
33+
* Default constructor.
34+
*/
35+
public ConnectorPluginConfigValidationResults() {
36+
}
37+
38+
/**
39+
* Constructor.
40+
*/
41+
public ConnectorPluginConfigValidationResults(
42+
final String name,
43+
final int errorCount,
44+
final Collection<String> groups,
45+
final Collection<Config> configs
46+
) {
47+
this.name = name;
48+
this.errorCount = errorCount;
49+
this.groups = new ArrayList<>(groups);
50+
this.configs = new ArrayList<>(configs);
51+
}
52+
3253
public String getName() {
3354
return name;
3455
}
@@ -62,6 +83,20 @@ public static final class Config {
6283
private Definition definition;
6384
private Value value;
6485

86+
/**
87+
* Default constructor.
88+
*/
89+
public Config() {
90+
}
91+
92+
/**
93+
* Constructor.
94+
*/
95+
public Config(final Definition definition, final Value value) {
96+
this.definition = definition;
97+
this.value = value;
98+
}
99+
65100
public Definition getDefinition() {
66101
return definition;
67102
}
@@ -94,6 +129,41 @@ public static final class Definition {
94129
private Collection<String> dependents = new ArrayList<>();
95130
private int order;
96131

132+
/**
133+
* Default constructor.
134+
*/
135+
public Definition() {
136+
}
137+
138+
/**
139+
* Constructor.
140+
*/
141+
public Definition(
142+
final String name,
143+
final String type,
144+
final boolean required,
145+
final String defaultValue,
146+
final String importance,
147+
final String documentation,
148+
final String group,
149+
final String width,
150+
final String displayName,
151+
final Collection<String> dependents,
152+
final int order
153+
) {
154+
this.name = name;
155+
this.type = type;
156+
this.required = required;
157+
this.defaultValue = defaultValue;
158+
this.importance = importance;
159+
this.documentation = documentation;
160+
this.group = group;
161+
this.width = width;
162+
this.displayName = displayName;
163+
this.dependents = new ArrayList<>(dependents);
164+
this.order = order;
165+
}
166+
97167
public String getName() {
98168
return name;
99169
}
@@ -166,6 +236,29 @@ public static final class Value {
166236
private Collection<String> errors = new ArrayList<>();
167237
private boolean visible = true;
168238

239+
/**
240+
* Default constructor.
241+
*/
242+
public Value() {
243+
}
244+
245+
/**
246+
* Constructor.
247+
*/
248+
public Value(
249+
final String name,
250+
final String value,
251+
final Collection<String> recommendedValues,
252+
final Collection<String> errors,
253+
final boolean visible
254+
) {
255+
this.name = name;
256+
this.value = value;
257+
this.recommendedValues = new ArrayList<>(recommendedValues);
258+
this.errors = new ArrayList<>(errors);
259+
this.visible = visible;
260+
}
261+
169262
public String getName() {
170263
return name;
171264
}

src/main/java/org/sourcelab/kafka/connect/apiclient/request/dto/ConnectorStatus.java

Lines changed: 34 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,9 @@
1717

1818
package org.sourcelab.kafka.connect.apiclient.request.dto;
1919

20+
import java.util.ArrayList;
2021
import java.util.Collections;
22+
import java.util.HashMap;
2123
import java.util.List;
2224
import java.util.Map;
2325

@@ -30,6 +32,22 @@ public class ConnectorStatus {
3032
private Map<String, String> connector;
3133
private List<TaskStatus> tasks;
3234

35+
/**
36+
* Default constructor.
37+
*/
38+
public ConnectorStatus() {
39+
}
40+
41+
/**
42+
* Constructor.
43+
*/
44+
public ConnectorStatus(final String name, final String type, final Map<String, String> connector, final List<TaskStatus> tasks) {
45+
this.name = name;
46+
this.type = type;
47+
this.connector = new HashMap<>(connector);
48+
this.tasks = new ArrayList<>(tasks);
49+
}
50+
3351
public String getName() {
3452
return name;
3553
}
@@ -65,6 +83,22 @@ public static class TaskStatus {
6583
private String workerId;
6684
private String trace;
6785

86+
/**
87+
* Default constructor.
88+
*/
89+
public TaskStatus() {
90+
}
91+
92+
/**
93+
* Constructor.
94+
*/
95+
public TaskStatus(final int id, final String state, final String workerId, final String trace) {
96+
this.id = id;
97+
this.state = state;
98+
this.workerId = workerId;
99+
this.trace = trace;
100+
}
101+
68102
public int getId() {
69103
return id;
70104
}

src/main/java/org/sourcelab/kafka/connect/apiclient/request/dto/ConnectorsWithExpandedMetadata.java

Lines changed: 28 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,14 +29,27 @@
2929
/**
3030
* Deployed Connectors extended with all available associated Metadata.
3131
*
32-
* Currently this includes both 'info' and 'status' metadata.
32+
* Currently, this includes both 'info' and 'status' metadata.
3333
*
3434
* Requires Kafka-Connect server 2.3.0+
3535
*/
3636
public class ConnectorsWithExpandedMetadata implements ConnectorsWithExpandedInfo, ConnectorsWithExpandedStatus {
3737
@JsonAnySetter
3838
private Map<String, ConnectorsWithExpandedMetadata.ConnectorWithExpandedMetadata> results = new HashMap<>();
3939

40+
/**
41+
* Default Constructor.
42+
*/
43+
public ConnectorsWithExpandedMetadata() {
44+
}
45+
46+
/**
47+
* Constructor.
48+
*/
49+
public ConnectorsWithExpandedMetadata(final Map<String, ConnectorWithExpandedMetadata> results) {
50+
this.results = new HashMap<>(results);
51+
}
52+
4053
@Override
4154
public Collection<String> getConnectorNames() {
4255
return results.keySet();
@@ -114,6 +127,20 @@ public static class ConnectorWithExpandedMetadata {
114127
@JsonProperty("status")
115128
private ConnectorStatus status;
116129

130+
/**
131+
* Default constructor.
132+
*/
133+
public ConnectorWithExpandedMetadata() {
134+
}
135+
136+
/**
137+
* Constructor.
138+
*/
139+
public ConnectorWithExpandedMetadata(final ConnectorDefinition info, final ConnectorStatus status) {
140+
this.info = info;
141+
this.status = status;
142+
}
143+
117144
public ConnectorStatus getStatus() {
118145
return status;
119146
}

src/main/java/org/sourcelab/kafka/connect/apiclient/request/dto/NewConnectorDefinition.java

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,14 @@ public final class NewConnectorDefinition {
2828
private final String name;
2929
private final Map<String, String> config;
3030

31+
/**
32+
* Create new Builder instance for NewConnectorDefinition.
33+
* @return new Builder instance for NewConnectorDefinition.
34+
*/
35+
public static Builder newBuilder() {
36+
return new Builder();
37+
}
38+
3139
/**
3240
* Constructor.
3341
* @param name Name of Connector.
@@ -46,10 +54,6 @@ public Map<String, String> getConfig() {
4654
return config;
4755
}
4856

49-
public static Builder newBuilder() {
50-
return new Builder();
51-
}
52-
5357
@Override
5458
public String toString() {
5559
return "NewConnectorDefinition{"

0 commit comments

Comments
 (0)