Package org.apache.bookkeeper.server.http.service

Class RecoveryBookieService

java.lang.Object

org.apache.bookkeeper.server.http.service.RecoveryBookieService

All Implemented Interfaces:

org.apache.bookkeeper.http.service.HttpEndpointService

public class RecoveryBookieService
extends java.lang.Object
implements org.apache.bookkeeper.http.service.HttpEndpointService

HttpEndpointService that handle Bookkeeper recovery related http request.

The PUT method will recovery bookie with provided parameter. The parameter of input body should be like this format: { "bookie_src": [ "bookie_src1", "bookie_src2"... ], "delete_cookie": <bool_value> }

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	RecoveryBookieService.RecoveryRequestJsonBody

Field Summary

Fields

Modifier and Type	Field	Description
protected BookKeeperAdmin	bka
protected ServerConfiguration	conf
protected java.util.concurrent.ExecutorService	executor
(package private) static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor	Description
RecoveryBookieService(ServerConfiguration conf, BookKeeperAdmin bka, java.util.concurrent.ExecutorService executor)

Method Summary

Modifier and Type	Method	Description
org.apache.bookkeeper.http.service.HttpServiceResponse	handle(org.apache.bookkeeper.http.service.HttpServiceRequest request)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

static final org.slf4j.Logger LOG

conf

protected ServerConfiguration conf

bka

protected BookKeeperAdmin bka

executor

protected java.util.concurrent.ExecutorService executor

Constructor Detail

RecoveryBookieService

public RecoveryBookieService(ServerConfiguration conf,
                             BookKeeperAdmin bka,
                             java.util.concurrent.ExecutorService executor)

Method Detail

handle

public org.apache.bookkeeper.http.service.HttpServiceResponse handle(org.apache.bookkeeper.http.service.HttpServiceRequest request)
                                                              throws java.lang.Exception

Specified by:

handle in interface org.apache.bookkeeper.http.service.HttpEndpointService

Throws:

java.lang.Exception