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 and Description
static class	ArchiveClient.IndexOptions
static class	ArchiveClient.ListOptions
static class	ArchiveClient.RangeOptions
static class	ArchiveClient.StreamOptions
static class	ArchiveClient.TableLoader

Constructor Summary

Constructors

Constructor and Description
ArchiveClient(MethodHandler handler, String instance)

Method Summary

Modifier and Type	Method and Description
ArchiveClient.TableLoader	createTableLoader(String table)
CompletableFuture<Yamcs.ArchiveTag>	createTag(CreateTagRequest request)
CompletableFuture<Yamcs.ArchiveTag>	deleteTag(long tagTime, int tagId)
CompletableFuture<Void>	dumpTable(String table, StreamReceiver<Table.Row> consumer)
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(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<Yamcs.Event>>	listEvents()
CompletableFuture<Page<Yamcs.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<List<Yamcs.ArchiveTag>>	listTags(Instant start, Instant stop)
CompletableFuture<Page<Pvalue.ParameterValue>>	listValues(String parameter, ArchiveClient.ListOptions.ListOption... options)
CompletableFuture<Page<Pvalue.ParameterValue>>	listValues(String parameter, Instant start, Instant stop, 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<Yamcs.Event> consumer, Instant start, Instant stop, ArchiveClient.StreamOptions.StreamOption... options)
CompletableFuture<Void>	streamIndex(StreamReceiver<Yamcs.IndexResult> consumer, Instant start, Instant stop, ArchiveClient.IndexOptions.IndexOption... options)
CompletableFuture<Void>	streamPacketIndex(StreamReceiver<Yamcs.ArchiveRecord> consumer, Instant start, Instant stop)
CompletableFuture<Void>	streamPackets(StreamReceiver<Yamcs.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, StreamReceiver<Map<String,Pvalue.ParameterValue>> consumer, Instant start, Instant stop)
CompletableFuture<Yamcs.ArchiveTag>	updateTag(EditTagRequest request)

Methods inherited from class java.lang.Object

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

Constructor Detail

ArchiveClient

public ArchiveClient(MethodHandler handler,
                     String instance)

Method Detail

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)

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)

streamIndex

public CompletableFuture<Void> streamIndex(StreamReceiver<Yamcs.IndexResult> consumer,
                                           Instant start,
                                           Instant stop,
                                           ArchiveClient.IndexOptions.IndexOption... options)

listCommands

public CompletableFuture<Page<Command>> listCommands()

listCommands

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

streamCommands

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

listEvents

public CompletableFuture<Page<Yamcs.Event>> listEvents()

listEvents

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

streamEvents

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

streamPackets

public CompletableFuture<Void> streamPackets(StreamReceiver<Yamcs.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)

createTag

public CompletableFuture<Yamcs.ArchiveTag> createTag(CreateTagRequest request)

listTags

public CompletableFuture<List<Yamcs.ArchiveTag>> listTags(Instant start,
                                                          Instant stop)

updateTag

public CompletableFuture<Yamcs.ArchiveTag> updateTag(EditTagRequest request)

deleteTag

public CompletableFuture<Yamcs.ArchiveTag> deleteTag(long tagTime,
                                                     int tagId)

listAlarms

public CompletableFuture<List<AlarmData>> listAlarms()

listAlarms

public CompletableFuture<List<AlarmData>> listAlarms(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)

dumpTable

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

createTableLoader

public ArchiveClient.TableLoader createTableLoader(String table)