interface ConnectRestPlugin extends Closeable{
    void register(ConnectRestPluginContext restPluginContext);
}
 
interface ConnectRestPluginContext{
    ResourceConfig resourceConfig();
    WorkerConfig workerConfig();
    ConnectClusterState clusterState();
}
 
class ConnectRestPluginContextImpl implements ConnectRestPluginContext{
    private final ResourceConfig resourceConfig;
    private final WorkerConfig workerConfig;
    private final ConnectClusterState clusterState;
 
    ConnectRestPluginContext(ResourceConfig resourceConfig, WorkerConfig workerConfig, ConnectClusterState clusterState){
        this.resourceConfig = resourceConfig;
        this.workerConfig = workerConfig;
        this.clusterState = clusterState;
    }
 
    public ResourceConfig resourceConfig(){
        return this.resourceConfig;
    }
 
    public WorkerConfig workerConfig(){
        return this.workerConfig;
    }
 
    public ConnectClusterState clusterState(){
        return this.clusterState;
    }
}

interface ConnectClusterState{
    /**
     * Get a list of connectors currently running in this cluster. This is a full list of connectors in the cluster gathered
     * from the current configuration.
     */
    Collection<String> connectors();
 
    /**
     * Lookup the current status of a connector.
     * @param connName name of the connector
     */
    ConnectorStateInfo connectorStatus(String connName);
 
}
 
class ConnectClusterStateImpl implements ConnectClusterState{
    private final Herder herder;
 
    public ConnectClusterStateImpl(Herder herder){
        this.herder = herder;
    }
 
    @Override
    Collection<String> connectors(){
        //delegate to herder
    }
 
    @Override
    ConnectorStateInfo connectorStatus(String connName);{
        //delegate to herder
    }
}

class  ConfluentConnectPluginExampleConnectPlugin implements ConnectRestPlugin{
    public void register(ConnectRestPluginContext restPluginContext){
        resourceConfig.register(new AuthenticationFilter(restPluginContext.workerConfig()));
        resourceConfig.register(new HealthCheckResource(restPluginContext.workerConfig(), restPluginContext.clusterState()));
    }
 
    public void close() {
        //close any resources
    }
}
 
class AuthenticationFilter implements ContainerRequestFilter {
 
  public AuthenticationFilter(WorkerConfig workerConfig){
    //set up filter
  }
     
  @Override
  public void filter(ContainerRequestContext requestContext) {
        //authentication logic
  }
 
}
 
@Path("/connect")
class HealthCheckResource {
 
    public HealthCheckResource(WorkerConfig workerConfig, ConnectClusterState clusterState){
        //initialize resource
    }
 
    @path("/health")
    public void healthcheck(){
        //check herder health
    }
}