Package org.yamcs.protobuf

Class AbstractPacketsApi<T>

java.lang.Object

org.yamcs.protobuf.AbstractPacketsApi<T>

All Implemented Interfaces:

Api<T>

Direct Known Subclasses:

PacketsApiClient

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

Constructor Summary

Constructors

Constructor	Description
AbstractPacketsApi()

Method Summary

Modifier and Type	Method	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	exportPacket(T ctx, ExportPacketRequest request, Observer<HttpBody> observer)	Export a raw packet
abstract void	exportPackets(T ctx, ExportPacketsRequest request, Observer<HttpBody> observer)	Export raw packets
com.google.protobuf.Descriptors.ServiceDescriptor	getDescriptorForType()
abstract void	getPacket(T ctx, GetPacketRequest request, Observer<Yamcs.TmPacketData> observer)	Get a packet
com.google.protobuf.Message	getRequestPrototype(com.google.protobuf.Descriptors.MethodDescriptor method)
com.google.protobuf.Message	getResponsePrototype(com.google.protobuf.Descriptors.MethodDescriptor method)
abstract void	listPacketNames(T ctx, ListPacketNamesRequest request, Observer<ListPacketNamesResponse> observer)	List packet names
abstract void	listPackets(T ctx, ListPacketsRequest request, Observer<ListPacketsResponse> observer)	List packets
abstract void	streamPackets(T ctx, StreamPacketsRequest request, Observer<Yamcs.TmPacketData> observer)	Streams back packets
abstract void	subscribePackets(T ctx, SubscribePacketsRequest request, Observer<Yamcs.TmPacketData> observer)	Subscribe to packets This subscription is performed at stream level.

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractPacketsApi

public AbstractPacketsApi()

Method Detail

listPacketNames

public abstract void listPacketNames(T ctx,
                                     ListPacketNamesRequest request,
                                     Observer<ListPacketNamesResponse> observer)

  List packet names
 

listPackets

public abstract void listPackets(T ctx,
                                 ListPacketsRequest request,
                                 Observer<ListPacketsResponse> observer)

  List packets
 

getPacket

public abstract void getPacket(T ctx,
                               GetPacketRequest request,
                               Observer<Yamcs.TmPacketData> observer)

  Get a packet
 

streamPackets

public abstract void streamPackets(T ctx,
                                   StreamPacketsRequest request,
                                   Observer<Yamcs.TmPacketData> observer)

  Streams back packets
 

exportPacket

public abstract void exportPacket(T ctx,
                                  ExportPacketRequest request,
                                  Observer<HttpBody> observer)

  Export a raw packet
 

exportPackets

public abstract void exportPackets(T ctx,
                                   ExportPacketsRequest request,
                                   Observer<HttpBody> observer)

  Export raw packets
 

subscribePackets

public abstract void subscribePackets(T ctx,
                                      SubscribePacketsRequest request,
                                      Observer<Yamcs.TmPacketData> observer)

  Subscribe to packets
 
  This subscription is performed at stream level. It is not currently possible
  to subscribe to the telemetry of a processor (but most of the time the
  telemetry in a processor is coming from a stream).
 
  Because messages are received from a stream, NamedObjectId (which is the
  identifier of the packet) is not filled in.
 

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>