Class LinkConfigResource

java.lang.Object

io.confluent.kafkarest.resources.v3.LinkConfigResource

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

Constructor Summary

Constructors

Constructor	Description
LinkConfigResource(jakarta.inject.Provider<LinkConfigManager> linkConfigManager, io.confluent.kafkarest.response.UrlFactory urlFactory)

Method Summary

Modifier and Type	Method	Description
void	getLinkConfig(jakarta.ws.rs.container.AsyncResponse asyncResponse, String clusterId, String linkName, String configName)
void	listLinkConfigs(jakarta.ws.rs.container.AsyncResponse asyncResponse, String clusterId, String linkName)
void	resetLinkConfig(jakarta.ws.rs.container.AsyncResponse asyncResponse, String clusterId, String linkName, String configName)
void	updateLinkConfig(jakarta.ws.rs.container.AsyncResponse asyncResponse, String clusterId, String linkName, String configName, @Valid UpdateLinkConfigRequest request)

Methods inherited from class java.lang.Object

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

Constructor Details

LinkConfigResource

@Inject
public LinkConfigResource(jakarta.inject.Provider<LinkConfigManager> linkConfigManager,
 io.confluent.kafkarest.response.UrlFactory urlFactory)

Method Details

listLinkConfigs

@GET
@Produces("application/json")
@PerformanceMetric("v3.link-configs.list")
public void listLinkConfigs(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @PathParam("clusterId")
 String clusterId,
 @PathParam("linkName")
 String linkName)

getLinkConfig

@GET
@Path("/{configName}")
@Produces("application/json")
@PerformanceMetric("v3.link-configs.get")
public void getLinkConfig(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @PathParam("clusterId")
 String clusterId,
 @PathParam("linkName")
 String linkName,
 @PathParam("configName")
 String configName)

updateLinkConfig

@PUT
@Path("/{configName}")
@Produces("application/json")
@PerformanceMetric("v3.link-configs.update")
public void updateLinkConfig(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @PathParam("clusterId")
 String clusterId,
 @PathParam("linkName")
 String linkName,
 @PathParam("configName")
 String configName,
 @Valid
 @Valid UpdateLinkConfigRequest request)

resetLinkConfig

@DELETE
@Path("/{configName}")
@Produces("application/json")
@PerformanceMetric("v3.link-configs.delete")
public void resetLinkConfig(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @PathParam("clusterId")
 String clusterId,
 @PathParam("linkName")
 String linkName,
 @PathParam("configName")
 String configName)