org.yamcs.protobuf

Class AbstractServerApi<T>

java.lang.Object

org.yamcs.protobuf.AbstractServerApi<T>

All Implemented Interfaces:

Api<T>

Direct Known Subclasses:

ServerApiClient

public abstract class AbstractServerApi<T>
extends Object
implements Api<T>

  Handles incoming requests related to api routes
 

Constructor Summary

Constructors

Constructor and Description
AbstractServerApi()

Method Summary

Modifier and Type	Method and Description
void	callMethod(com.google.protobuf.Descriptors.MethodDescriptor method, T ctx, com.google.protobuf.Message request, Observer<com.google.protobuf.Message> future)
Observer<com.google.protobuf.Message>	callMethod(com.google.protobuf.Descriptors.MethodDescriptor method, T ctx, Observer<com.google.protobuf.Message> future)
abstract void	closeConnection(T ctx, CloseConnectionRequest request, Observer<com.google.protobuf.Empty> observer) Close a client connection
abstract void	dumpThreads(T ctx, com.google.protobuf.Empty request, Observer<HttpBody> observer) Get a text-dump with thread information
com.google.protobuf.Descriptors.ServiceDescriptor	getDescriptorForType()
com.google.protobuf.Message	getRequestPrototype(com.google.protobuf.Descriptors.MethodDescriptor method)
com.google.protobuf.Message	getResponsePrototype(com.google.protobuf.Descriptors.MethodDescriptor method)
abstract void	getServerInfo(T ctx, com.google.protobuf.Empty request, Observer<GetServerInfoResponse> observer) Get general server info
abstract void	getThread(T ctx, GetThreadRequest request, Observer<ThreadInfo> observer) Get info on a single thread
abstract void	listClientConnections(T ctx, com.google.protobuf.Empty request, Observer<ListClientConnectionsResponse> observer) List client connections
abstract void	listRoutes(T ctx, com.google.protobuf.Empty request, Observer<ListRoutesResponse> observer) List routes
abstract void	listThreads(T ctx, ListThreadsRequest request, Observer<ListThreadsResponse> observer) List threads
abstract void	listTopics(T ctx, com.google.protobuf.Empty request, Observer<ListTopicsResponse> observer) List topics

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractServerApi

public AbstractServerApi()

Method Detail

getServerInfo

public abstract void getServerInfo(T ctx,
                                   com.google.protobuf.Empty request,
                                   Observer<GetServerInfoResponse> observer)

  Get general server info
 

listRoutes

public abstract void listRoutes(T ctx,
                                com.google.protobuf.Empty request,
                                Observer<ListRoutesResponse> observer)

  List routes
 

listTopics

public abstract void listTopics(T ctx,
                                com.google.protobuf.Empty request,
                                Observer<ListTopicsResponse> observer)

  List topics
 

listThreads

public abstract void listThreads(T ctx,
                                 ListThreadsRequest request,
                                 Observer<ListThreadsResponse> observer)

  List threads
 

getThread

public abstract void getThread(T ctx,
                               GetThreadRequest request,
                               Observer<ThreadInfo> observer)

  Get info on a single thread
 

dumpThreads

public abstract void dumpThreads(T ctx,
                                 com.google.protobuf.Empty request,
                                 Observer<HttpBody> observer)

  Get a text-dump with thread information
 

listClientConnections

public abstract void listClientConnections(T ctx,
                                           com.google.protobuf.Empty request,
                                           Observer<ListClientConnectionsResponse> observer)

  List client connections
 

closeConnection

public abstract void closeConnection(T ctx,
                                     CloseConnectionRequest request,
                                     Observer<com.google.protobuf.Empty> observer)

  Close a client connection
 

getDescriptorForType

public final com.google.protobuf.Descriptors.ServiceDescriptor getDescriptorForType()

Specified by:

getDescriptorForType in interface Api<T>

getRequestPrototype

public final com.google.protobuf.Message getRequestPrototype(com.google.protobuf.Descriptors.MethodDescriptor method)

Specified by:

getRequestPrototype in interface Api<T>

getResponsePrototype

public final com.google.protobuf.Message getResponsePrototype(com.google.protobuf.Descriptors.MethodDescriptor method)

Specified by:

getResponsePrototype in interface Api<T>

callMethod

public final void callMethod(com.google.protobuf.Descriptors.MethodDescriptor method,
                             T ctx,
                             com.google.protobuf.Message request,
                             Observer<com.google.protobuf.Message> future)

Specified by:

callMethod in interface Api<T>

callMethod

public final Observer<com.google.protobuf.Message> callMethod(com.google.protobuf.Descriptors.MethodDescriptor method,
                                                              T ctx,
                                                              Observer<com.google.protobuf.Message> future)

Specified by:

callMethod in interface Api<T>