Package crawlercommons.urlfrontier

Class URLFrontierGrpc

java.lang.Object

crawlercommons.urlfrontier.URLFrontierGrpc

public final class URLFrontierGrpc
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	URLFrontierGrpc.AsyncService
static final class	URLFrontierGrpc.URLFrontierBlockingStub	A stub to allow clients to do synchronous rpc calls to service URLFrontier.
static final class	URLFrontierGrpc.URLFrontierFutureStub	A stub to allow clients to do ListenableFuture-style rpc calls to service URLFrontier.
static class	URLFrontierGrpc.URLFrontierImplBase	Base class for the server implementation of the service URLFrontier.
static final class	URLFrontierGrpc.URLFrontierStub	A stub to allow clients to do asynchronous rpc calls to service URLFrontier.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	SERVICE_NAME

Method Summary

Modifier and Type	Method	Description
static final io.grpc.ServerServiceDefinition	bindService(URLFrontierGrpc.AsyncService service)
static io.grpc.MethodDescriptor<Urlfrontier.BlockQueueParams,Urlfrontier.Empty>	getBlockQueueUntilMethod()
static io.grpc.MethodDescriptor<Urlfrontier.DeleteCrawlMessage,Urlfrontier.Long>	getDeleteCrawlMethod()
static io.grpc.MethodDescriptor<Urlfrontier.QueueWithinCrawlParams,Urlfrontier.Long>	getDeleteQueueMethod()
static io.grpc.MethodDescriptor<Urlfrontier.Local,Urlfrontier.Boolean>	getGetActiveMethod()
static io.grpc.MethodDescriptor<Urlfrontier.QueueWithinCrawlParams,Urlfrontier.Stats>	getGetStatsMethod()
static io.grpc.MethodDescriptor<Urlfrontier.GetParams,Urlfrontier.URLInfo>	getGetURLsMethod()
static io.grpc.MethodDescriptor<Urlfrontier.URLStatusRequest,Urlfrontier.URLItem>	getGetURLStatusMethod()
static io.grpc.MethodDescriptor<Urlfrontier.Local,Urlfrontier.StringList>	getListCrawlsMethod()
static io.grpc.MethodDescriptor<Urlfrontier.Empty,Urlfrontier.StringList>	getListNodesMethod()
static io.grpc.MethodDescriptor<Urlfrontier.Pagination,Urlfrontier.QueueList>	getListQueuesMethod()
static io.grpc.MethodDescriptor<Urlfrontier.ListUrlParams,Urlfrontier.URLItem>	getListURLsMethod()
static io.grpc.MethodDescriptor<Urlfrontier.URLItem,Urlfrontier.AckMessage>	getPutURLsMethod()
static io.grpc.ServiceDescriptor	getServiceDescriptor()
static io.grpc.MethodDescriptor<Urlfrontier.Active,Urlfrontier.Empty>	getSetActiveMethod()
static io.grpc.MethodDescriptor<Urlfrontier.CrawlLimitParams,Urlfrontier.Empty>	getSetCrawlLimitMethod()
static io.grpc.MethodDescriptor<Urlfrontier.QueueDelayParams,Urlfrontier.Empty>	getSetDelayMethod()
static io.grpc.MethodDescriptor<Urlfrontier.LogLevelParams,Urlfrontier.Empty>	getSetLogLevelMethod()
static URLFrontierGrpc.URLFrontierBlockingStub	newBlockingStub(io.grpc.Channel channel)	Creates a new blocking-style stub that supports unary and streaming output calls on the service
static URLFrontierGrpc.URLFrontierFutureStub	newFutureStub(io.grpc.Channel channel)	Creates a new ListenableFuture-style stub that supports unary calls on the service
static URLFrontierGrpc.URLFrontierStub	newStub(io.grpc.Channel channel)	Creates a new async stub that supports all call types for the service

Methods inherited from class java.lang.Object

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

Field Details

SERVICE_NAME

public static final String SERVICE_NAME

See Also:

• Constant Field Values

Method Details

getListNodesMethod

public static io.grpc.MethodDescriptor<Urlfrontier.Empty,Urlfrontier.StringList> getListNodesMethod()

getListCrawlsMethod

public static io.grpc.MethodDescriptor<Urlfrontier.Local,Urlfrontier.StringList> getListCrawlsMethod()

getDeleteCrawlMethod

public static io.grpc.MethodDescriptor<Urlfrontier.DeleteCrawlMessage,Urlfrontier.Long> getDeleteCrawlMethod()

getListQueuesMethod

public static io.grpc.MethodDescriptor<Urlfrontier.Pagination,Urlfrontier.QueueList> getListQueuesMethod()

getGetURLsMethod

public static io.grpc.MethodDescriptor<Urlfrontier.GetParams,Urlfrontier.URLInfo> getGetURLsMethod()

getPutURLsMethod

public static io.grpc.MethodDescriptor<Urlfrontier.URLItem,Urlfrontier.AckMessage> getPutURLsMethod()

getGetStatsMethod

public static io.grpc.MethodDescriptor<Urlfrontier.QueueWithinCrawlParams,Urlfrontier.Stats> getGetStatsMethod()

getDeleteQueueMethod

public static io.grpc.MethodDescriptor<Urlfrontier.QueueWithinCrawlParams,Urlfrontier.Long> getDeleteQueueMethod()

getBlockQueueUntilMethod

public static io.grpc.MethodDescriptor<Urlfrontier.BlockQueueParams,Urlfrontier.Empty> getBlockQueueUntilMethod()

getSetActiveMethod

public static io.grpc.MethodDescriptor<Urlfrontier.Active,Urlfrontier.Empty> getSetActiveMethod()

getGetActiveMethod

public static io.grpc.MethodDescriptor<Urlfrontier.Local,Urlfrontier.Boolean> getGetActiveMethod()

getSetDelayMethod

public static io.grpc.MethodDescriptor<Urlfrontier.QueueDelayParams,Urlfrontier.Empty> getSetDelayMethod()

getSetLogLevelMethod

public static io.grpc.MethodDescriptor<Urlfrontier.LogLevelParams,Urlfrontier.Empty> getSetLogLevelMethod()

getSetCrawlLimitMethod

public static io.grpc.MethodDescriptor<Urlfrontier.CrawlLimitParams,Urlfrontier.Empty> getSetCrawlLimitMethod()

getGetURLStatusMethod

public static io.grpc.MethodDescriptor<Urlfrontier.URLStatusRequest,Urlfrontier.URLItem> getGetURLStatusMethod()

getListURLsMethod

public static io.grpc.MethodDescriptor<Urlfrontier.ListUrlParams,Urlfrontier.URLItem> getListURLsMethod()

newStub

public static URLFrontierGrpc.URLFrontierStub newStub(io.grpc.Channel channel)

Creates a new async stub that supports all call types for the service

newBlockingStub

public static URLFrontierGrpc.URLFrontierBlockingStub newBlockingStub(io.grpc.Channel channel)

Creates a new blocking-style stub that supports unary and streaming output calls on the service

newFutureStub

public static URLFrontierGrpc.URLFrontierFutureStub newFutureStub(io.grpc.Channel channel)

Creates a new ListenableFuture-style stub that supports unary calls on the service

bindService

public static final io.grpc.ServerServiceDefinition bindService(URLFrontierGrpc.AsyncService service)

getServiceDescriptor

public static io.grpc.ServiceDescriptor getServiceDescriptor()