org.yamcs.protobuf

Class AbstractTableApi<T>

java.lang.Object

org.yamcs.protobuf.AbstractTableApi<T>

All Implemented Interfaces:

Api<T>

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

Service for reading and writing to Yarch tables and streams

Constructor Summary

Constructors

Constructor and Description
AbstractTableApi()

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)
abstract void	executeSql(T ctx, Table.ExecuteSqlRequest request, Observer<Table.ExecuteSqlResponse> observer) Execute SQL
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	getStream(T ctx, Table.GetStreamRequest request, Observer<Table.StreamInfo> observer) Get a stream
abstract void	getTable(T ctx, Table.GetTableRequest request, Observer<Table.TableInfo> observer) Get a table
abstract void	getTableData(T ctx, Table.GetTableDataRequest request, Observer<Table.TableData> observer) Get table data
abstract void	listStreams(T ctx, Table.ListStreamsRequest request, Observer<Table.ListStreamsResponse> observer) List streams
abstract void	listTables(T ctx, Table.ListTablesRequest request, Observer<Table.ListTablesResponse> observer) List tables
abstract void	readRows(T ctx, Table.ReadRowsRequest request, Observer<Table.Row> observer) Streams back the contents of all rows in key order

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractTableApi

public AbstractTableApi()

Method Detail

executeSql

public abstract void executeSql(T ctx,
                                Table.ExecuteSqlRequest request,
                                Observer<Table.ExecuteSqlResponse> observer)

Execute SQL

listStreams

public abstract void listStreams(T ctx,
                                 Table.ListStreamsRequest request,
                                 Observer<Table.ListStreamsResponse> observer)

List streams

getStream

public abstract void getStream(T ctx,
                               Table.GetStreamRequest request,
                               Observer<Table.StreamInfo> observer)

Get a stream

listTables

public abstract void listTables(T ctx,
                                Table.ListTablesRequest request,
                                Observer<Table.ListTablesResponse> observer)

List tables

getTable

public abstract void getTable(T ctx,
                              Table.GetTableRequest request,
                              Observer<Table.TableInfo> observer)

Get a table

getTableData

public abstract void getTableData(T ctx,
                                  Table.GetTableDataRequest request,
                                  Observer<Table.TableData> observer)

Get table data

readRows

public abstract void readRows(T ctx,
                              Table.ReadRowsRequest request,
                              Observer<Table.Row> observer)

Streams back the contents of all rows in key order

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>