@@ -68,8 +68,8 @@ public class DaprContainer extends GenericContainer<DaprContainer> {
68
68
private String appChannelAddress = "localhost" ;
69
69
private String placementService = "placement" ;
70
70
private String schedulerService = "scheduler" ;
71
- private String placementDockerImageName = DAPR_PLACEMENT_IMAGE_TAG ;
72
- private String schedulerDockerImageName = DAPR_SCHEDULER_IMAGE_TAG ;
71
+ private DockerImageName placementDockerImageName = DockerImageName . parse ( DAPR_PLACEMENT_IMAGE_TAG ) ;
72
+ private DockerImageName schedulerDockerImageName = DockerImageName . parse ( DAPR_SCHEDULER_IMAGE_TAG ) ;
73
73
74
74
private Configuration configuration ;
75
75
private DaprPlacementContainer placementContainer ;
@@ -166,16 +166,26 @@ public DaprContainer withHttpEndpoint(HttpEndpoint httpEndpoint) {
166
166
return this ;
167
167
}
168
168
169
- public DaprContainer withPlacementImage (String placementDockerImageName ) {
169
+ public DaprContainer withPlacementImage (DockerImageName placementDockerImageName ) {
170
170
this .placementDockerImageName = placementDockerImageName ;
171
171
return this ;
172
172
}
173
173
174
- public DaprContainer withSchedulerImage (String schedulerDockerImageName ) {
174
+ public DaprContainer withPlacementImage (String placementDockerImageName ) {
175
+ this .placementDockerImageName = DockerImageName .parse (placementDockerImageName );
176
+ return this ;
177
+ }
178
+
179
+ public DaprContainer withSchedulerImage (DockerImageName schedulerDockerImageName ) {
175
180
this .schedulerDockerImageName = schedulerDockerImageName ;
176
181
return this ;
177
182
}
178
183
184
+ public DaprContainer withSchedulerImage (String schedulerDockerImageName ) {
185
+ this .schedulerDockerImageName = DockerImageName .parse (schedulerDockerImageName );
186
+ return this ;
187
+ }
188
+
179
189
public DaprContainer withReusablePlacement (boolean shouldReusePlacement ) {
180
190
this .shouldReusePlacement = shouldReusePlacement ;
181
191
return this ;
0 commit comments