Class LinkResource

java.lang.Object

io.confluent.kafkarest.resources.v3.LinkResource

@Path("/v3/clusters/{clusterId}/links")
public final class LinkResource
extends Object

Constructor Summary

Constructors

Constructor	Description
LinkResource(jakarta.inject.Provider<LinkManager> linkManager, io.confluent.kafkarest.response.UrlFactory urlFactory)

Method Summary

Modifier and Type	Method	Description
void	createLink(jakarta.ws.rs.container.AsyncResponse asyncResponse, String clusterId, @NotNull(message="link_name is required") String linkName, boolean validateLink, boolean validateOnly, @Valid CreateLinkRequest request)
void	deleteLink(jakarta.ws.rs.container.AsyncResponse asyncResponse, String clusterId, String linkName, boolean force, boolean validateOnly)
void	getLink(jakarta.ws.rs.container.AsyncResponse asyncResponse, String clusterId, String linkName, Boolean includeTasks)
void	listLinks(jakarta.ws.rs.container.AsyncResponse asyncResponse, String clusterId)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

LinkResource

@Inject
public LinkResource(jakarta.inject.Provider<LinkManager> linkManager,
 io.confluent.kafkarest.response.UrlFactory urlFactory)

Method Details

deleteLink

@DELETE
@Path("/{linkName}")
@Produces("application/json")
@PerformanceMetric("v3.links.delete")
public void deleteLink(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @PathParam("clusterId")
 String clusterId,
 @PathParam("linkName")
 String linkName,
 @QueryParam("force") @DefaultValue("false")
 boolean force,
 @QueryParam("validate_only") @DefaultValue("false")
 boolean validateOnly)

listLinks

@GET
@Produces("application/json")
@PerformanceMetric("v3.links.list")
public void listLinks(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @PathParam("clusterId")
 String clusterId)

getLink

@GET
@Path("/{linkName}")
@Produces("application/json")
@PerformanceMetric("v3.links.get")
public void getLink(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @PathParam("clusterId")
 String clusterId,
 @PathParam("linkName")
 String linkName,
 @QueryParam("include_tasks")
 Boolean includeTasks)

createLink

@POST
@Consumes("application/json")
@Produces("application/json")
@PerformanceMetric("v3.links.create")
public void createLink(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @PathParam("clusterId")
 String clusterId,
 @NotNull(message="link_name is required") @QueryParam("link_name")
 @NotNull(message="link_name is required") String linkName,
 @QueryParam("validate_link") @DefaultValue("true")
 boolean validateLink,
 @QueryParam("validate_only") @DefaultValue("false")
 boolean validateOnly,
 @Valid
 @Valid CreateLinkRequest request)