Package org.yamcs.client.archive

Class ArchiveClient

java.lang.Object

org.yamcs.client.archive.ArchiveClient

public class ArchiveClient
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	ArchiveClient.ListOptions
static final class	ArchiveClient.RangeOptions
static final class	ArchiveClient.StreamOptions
static class	ArchiveClient.TableLoader

Constructor Summary

Constructors

Constructor	Description
ArchiveClient(MethodHandler handler, String instance)

Method Summary

Modifier and Type	Method	Description
ArchiveClient.TableLoader	createTableLoader(String table)
CompletableFuture<Void>	dumpTable(String table, StreamReceiver<Table.Row> consumer)
CompletableFuture<Command>	getCommand(String id)
CompletableFuture<List<String>>	getEventSources()
String	getInstance()
CompletableFuture<List<Pvalue.Ranges.Range>>	getRanges(String parameter, Instant start, Instant stop, ArchiveClient.RangeOptions.RangeOption... options)
CompletableFuture<List<Pvalue.TimeSeries.Sample>>	getSamples(String parameter, Instant start, Instant stop)
CompletableFuture<List<AlarmData>>	listAlarms()
CompletableFuture<List<AlarmData>>	listAlarms(String parameter)
CompletableFuture<List<AlarmData>>	listAlarms(String alarmName, Instant start, Instant stop)
CompletableFuture<List<AlarmData>>	listAlarms(Instant start, Instant stop)
CompletableFuture<Page<IndexGroup>>	listCommandIndex(Instant start, Instant stop, ArchiveClient.ListOptions.ListOption... options)
CompletableFuture<Page<Command>>	listCommands()
CompletableFuture<Page<Command>>	listCommands(Instant start, Instant stop)
CompletableFuture<Page<IndexGroup>>	listCompletenessIndex(Instant start, Instant stop, ArchiveClient.ListOptions.ListOption... options)
CompletableFuture<Page<IndexGroup>>	listEventIndex(Instant start, Instant stop, ArchiveClient.ListOptions.ListOption... options)
CompletableFuture<Page<Event>>	listEvents()
CompletableFuture<Page<Event>>	listEvents(Instant start, Instant stop)
CompletableFuture<Page<IndexGroup>>	listPacketIndex(Instant start, Instant stop, ArchiveClient.ListOptions.ListOption... options)
CompletableFuture<Page<IndexGroup>>	listParameterIndex(Instant start, Instant stop, ArchiveClient.ListOptions.ListOption... options)
CompletableFuture<List<Table.TableData.TableRecord>>	listRecords(String table)
CompletableFuture<Page<Pvalue.ParameterValue>>	listValues(String parameter, Instant start, Instant stop, ArchiveClient.ListOptions.ListOption... options)
CompletableFuture<Page<Pvalue.ParameterValue>>	listValues(String parameter, ArchiveClient.ListOptions.ListOption... options)
CompletableFuture<Void>	streamCommandIndex(StreamReceiver<Yamcs.ArchiveRecord> consumer, Instant start, Instant stop)
CompletableFuture<Void>	streamCommands(StreamReceiver<Command> consumer, Instant start, Instant stop, ArchiveClient.StreamOptions.StreamOption... options)
CompletableFuture<Void>	streamCompletenessIndex(StreamReceiver<Yamcs.ArchiveRecord> consumer, Instant start, Instant stop)
CompletableFuture<Void>	streamEventIndex(StreamReceiver<Yamcs.ArchiveRecord> consumer, Instant start, Instant stop)
CompletableFuture<Void>	streamEvents(StreamReceiver<Event> consumer, Instant start, Instant stop, ArchiveClient.StreamOptions.StreamOption... options)
CompletableFuture<Void>	streamPacketIndex(StreamReceiver<Yamcs.ArchiveRecord> consumer, Instant start, Instant stop, ArchiveClient.StreamOptions.StreamOption... options)
CompletableFuture<Void>	streamPackets(StreamReceiver<TmPacketData> consumer, Instant start, Instant stop, ArchiveClient.StreamOptions.StreamOption... options)
CompletableFuture<Void>	streamParameterIndex(StreamReceiver<Yamcs.ArchiveRecord> consumer, Instant start, Instant stop)
CompletableFuture<Void>	streamValues(List<String> parameters, List<String> tmLinks, StreamReceiver<Map<String,Pvalue.ParameterValue>> consumer, Instant start, Instant stop)
CompletableFuture<Void>	streamValues(List<String> parameters, StreamReceiver<Map<String,Pvalue.ParameterValue>> consumer, Instant start, Instant stop)

Methods inherited from class java.lang.Object

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

Constructor Details

ArchiveClient

public ArchiveClient(MethodHandler handler,
 String instance)

Method Details

getInstance

public String getInstance()

listCommandIndex

public CompletableFuture<Page<IndexGroup>> listCommandIndex(Instant start,
 Instant stop,
 ArchiveClient.ListOptions.ListOption... options)

listPacketIndex

public CompletableFuture<Page<IndexGroup>> listPacketIndex(Instant start,
 Instant stop,
 ArchiveClient.ListOptions.ListOption... options)

listParameterIndex

public CompletableFuture<Page<IndexGroup>> listParameterIndex(Instant start,
 Instant stop,
 ArchiveClient.ListOptions.ListOption... options)

listEventIndex

public CompletableFuture<Page<IndexGroup>> listEventIndex(Instant start,
 Instant stop,
 ArchiveClient.ListOptions.ListOption... options)

listCompletenessIndex

public CompletableFuture<Page<IndexGroup>> listCompletenessIndex(Instant start,
 Instant stop,
 ArchiveClient.ListOptions.ListOption... options)

streamPacketIndex

public CompletableFuture<Void> streamPacketIndex(StreamReceiver<Yamcs.ArchiveRecord> consumer,
 Instant start,
 Instant stop,
 ArchiveClient.StreamOptions.StreamOption... options)

streamParameterIndex

public CompletableFuture<Void> streamParameterIndex(StreamReceiver<Yamcs.ArchiveRecord> consumer,
 Instant start,
 Instant stop)

streamCommandIndex

public CompletableFuture<Void> streamCommandIndex(StreamReceiver<Yamcs.ArchiveRecord> consumer,
 Instant start,
 Instant stop)

streamEventIndex

public CompletableFuture<Void> streamEventIndex(StreamReceiver<Yamcs.ArchiveRecord> consumer,
 Instant start,
 Instant stop)

streamCompletenessIndex

public CompletableFuture<Void> streamCompletenessIndex(StreamReceiver<Yamcs.ArchiveRecord> consumer,
 Instant start,
 Instant stop)

listCommands

public CompletableFuture<Page<Command>> listCommands()

listCommands

public CompletableFuture<Page<Command>> listCommands(Instant start,
 Instant stop)

getCommand

public CompletableFuture<Command> getCommand(String id)

streamCommands

public CompletableFuture<Void> streamCommands(StreamReceiver<Command> consumer,
 Instant start,
 Instant stop,
 ArchiveClient.StreamOptions.StreamOption... options)

listEvents

public CompletableFuture<Page<Event>> listEvents()

listEvents

public CompletableFuture<Page<Event>> listEvents(Instant start,
 Instant stop)

streamEvents

public CompletableFuture<Void> streamEvents(StreamReceiver<Event> consumer,
 Instant start,
 Instant stop,
 ArchiveClient.StreamOptions.StreamOption... options)

streamPackets

public CompletableFuture<Void> streamPackets(StreamReceiver<TmPacketData> consumer,
 Instant start,
 Instant stop,
 ArchiveClient.StreamOptions.StreamOption... options)

streamValues

public CompletableFuture<Void> streamValues(List<String> parameters,
 StreamReceiver<Map<String,Pvalue.ParameterValue>> consumer,
 Instant start,
 Instant stop)

streamValues

public CompletableFuture<Void> streamValues(List<String> parameters,
 List<String> tmLinks,
 StreamReceiver<Map<String,Pvalue.ParameterValue>> consumer,
 Instant start,
 Instant stop)

listAlarms

public CompletableFuture<List<AlarmData>> listAlarms()

listAlarms

public CompletableFuture<List<AlarmData>> listAlarms(String parameter)

listAlarms

public CompletableFuture<List<AlarmData>> listAlarms(Instant start,
 Instant stop)

listAlarms

public CompletableFuture<List<AlarmData>> listAlarms(String alarmName,
 Instant start,
 Instant stop)

listRecords

public CompletableFuture<List<Table.TableData.TableRecord>> listRecords(String table)

listValues

public CompletableFuture<Page<Pvalue.ParameterValue>> listValues(String parameter,
 ArchiveClient.ListOptions.ListOption... options)

listValues

public CompletableFuture<Page<Pvalue.ParameterValue>> listValues(String parameter,
 Instant start,
 Instant stop,
 ArchiveClient.ListOptions.ListOption... options)

getSamples

public CompletableFuture<List<Pvalue.TimeSeries.Sample>> getSamples(String parameter,
 Instant start,
 Instant stop)

getRanges

public CompletableFuture<List<Pvalue.Ranges.Range>> getRanges(String parameter,
 Instant start,
 Instant stop,
 ArchiveClient.RangeOptions.RangeOption... options)

getEventSources

public CompletableFuture<List<String>> getEventSources()

dumpTable

public CompletableFuture<Void> dumpTable(String table,
 StreamReceiver<Table.Row> consumer)

createTableLoader

public ArchiveClient.TableLoader createTableLoader(String table)