org.openspaces.admin.internal.pipelines

Class Consumer

java.lang.Object

org.openspaces.admin.internal.pipelines.Consumer

public class Consumer
extends Object

Constructor Summary

Constructors

Constructor and Description
Consumer()

Method Summary

Modifier and Type	Method and Description
static HTTPResponse	deleteConsumer(String url)
static HTTPResponse	deleteKafkaTopic(String url, String topicName)
static HTTPResponse	getHasKafkaDelta(String url)
static HTTPResponse	getStatus(String url)
static HTTPResponse	getThreadStatus(String url)
static HTTPResponse	getTotalOperation(String url)
static HTTPResponse	isKafkaTopicExists(String url, String topicName)
static HTTPResponse	startConsumer(String url, String offset, Integer parallelism)
static HTTPResponse	startPopulationOfDeletedTables(String url)
static HTTPResponse	stopConsumer(String url)
static HTTPResponse	stopPopulationOfDeletedTables(String url)

Methods inherited from class java.lang.Object

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

Constructor Detail

Consumer

public Consumer()

Method Detail

getStatus

public static HTTPResponse getStatus(String url)

getThreadStatus

public static HTTPResponse getThreadStatus(String url)

getHasKafkaDelta

public static HTTPResponse getHasKafkaDelta(String url)

getTotalOperation

public static HTTPResponse getTotalOperation(String url)

startConsumer

public static HTTPResponse startConsumer(String url,
                                         String offset,
                                         Integer parallelism)

stopConsumer

public static HTTPResponse stopConsumer(String url)

deleteConsumer

public static HTTPResponse deleteConsumer(String url)

startPopulationOfDeletedTables

public static HTTPResponse startPopulationOfDeletedTables(String url)

stopPopulationOfDeletedTables

public static HTTPResponse stopPopulationOfDeletedTables(String url)

deleteKafkaTopic

public static HTTPResponse deleteKafkaTopic(String url,
                                            String topicName)

isKafkaTopicExists

public static HTTPResponse isKafkaTopicExists(String url,
                                              String topicName)