edu.sc.seis.crocus.dhi

Class CrocusDataCenter

java.lang.Object

edu.sc.seis.crocus.dhi.CrocusDataCenter

All Implemented Interfaces:

edu.sc.seis.cormorant.seismogram.CacheableDataCenter

public class CrocusDataCenter
extends java.lang.Object
implements edu.sc.seis.cormorant.seismogram.CacheableDataCenter

Constructor Summary

Constructors

Constructor and Description
CrocusDataCenter(com.netflix.astyanax.Keyspace keyspace)

Method Summary

Modifier and Type	Method and Description
java.util.List<edu.iris.Fissures.IfSeismogramDC.RequestFilter>	availableData(java.util.List<edu.iris.Fissures.IfSeismogramDC.RequestFilter> request)
void	cancel_request(java.lang.String a_request)
java.util.List<edu.iris.Fissures.IfSeismogramDC.RequestFilter>	knownUnavailableData(java.util.List<edu.iris.Fissures.IfSeismogramDC.RequestFilter> rfList)
java.util.List<edu.iris.Fissures.seismogramDC.LocalSeismogramImpl>	processOneChannel(java.util.List<edu.iris.Fissures.IfSeismogramDC.RequestFilter> request) Processes a list of requests, all of which must be from the same channel.
java.lang.String	queue_seismograms(edu.iris.Fissures.IfSeismogramDC.RequestFilter[] a_filterseq)
java.lang.String	request_seismograms(edu.iris.Fissures.IfSeismogramDC.RequestFilter[] a_filterseq, edu.iris.Fissures.IfSeismogramDC.DataCenterCallBack a_client, boolean long_lived, edu.iris.Fissures.Time expiration_time)
java.lang.String	request_status(java.lang.String a_request)
edu.iris.Fissures.IfSeismogramDC.LocalSeismogram[]	retrieve_queue(java.lang.String a_request)
edu.iris.Fissures.IfSeismogramDC.LocalSeismogram[]	retrieve_seismograms(edu.iris.Fissures.IfSeismogramDC.RequestFilter[] request)
java.util.List<edu.iris.Fissures.seismogramDC.LocalSeismogramImpl>	retrieveData(java.util.List<edu.iris.Fissures.IfSeismogramDC.RequestFilter> rfList)

Methods inherited from class java.lang.Object

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

Constructor Detail

CrocusDataCenter

public CrocusDataCenter(com.netflix.astyanax.Keyspace keyspace)

Method Detail

availableData

public java.util.List<edu.iris.Fissures.IfSeismogramDC.RequestFilter> availableData(java.util.List<edu.iris.Fissures.IfSeismogramDC.RequestFilter> request)

Specified by:

availableData in interface edu.sc.seis.cormorant.seismogram.CacheableDataCenter

request_seismograms

public java.lang.String request_seismograms(edu.iris.Fissures.IfSeismogramDC.RequestFilter[] a_filterseq,
                                            edu.iris.Fissures.IfSeismogramDC.DataCenterCallBack a_client,
                                            boolean long_lived,
                                            edu.iris.Fissures.Time expiration_time)
                                     throws edu.iris.Fissures.FissuresException

Throws:

edu.iris.Fissures.FissuresException

retrieve_seismograms

public edu.iris.Fissures.IfSeismogramDC.LocalSeismogram[] retrieve_seismograms(edu.iris.Fissures.IfSeismogramDC.RequestFilter[] request)
                                                                        throws edu.iris.Fissures.FissuresException

Throws:

edu.iris.Fissures.FissuresException

processOneChannel

public java.util.List<edu.iris.Fissures.seismogramDC.LocalSeismogramImpl> processOneChannel(java.util.List<edu.iris.Fissures.IfSeismogramDC.RequestFilter> request)
                                                                                     throws edu.iris.Fissures.FissuresException

Processes a list of requests, all of which must be from the same channel.

Throws:

edu.iris.Fissures.FissuresException

queue_seismograms

public java.lang.String queue_seismograms(edu.iris.Fissures.IfSeismogramDC.RequestFilter[] a_filterseq)
                                   throws edu.iris.Fissures.FissuresException

Throws:

edu.iris.Fissures.FissuresException

retrieve_queue

public edu.iris.Fissures.IfSeismogramDC.LocalSeismogram[] retrieve_queue(java.lang.String a_request)
                                                                  throws edu.iris.Fissures.FissuresException

Throws:

edu.iris.Fissures.FissuresException

cancel_request

public void cancel_request(java.lang.String a_request)
                    throws edu.iris.Fissures.FissuresException

Throws:

edu.iris.Fissures.FissuresException

request_status

public java.lang.String request_status(java.lang.String a_request)
                                throws edu.iris.Fissures.FissuresException

Throws:

edu.iris.Fissures.FissuresException

knownUnavailableData

public java.util.List<edu.iris.Fissures.IfSeismogramDC.RequestFilter> knownUnavailableData(java.util.List<edu.iris.Fissures.IfSeismogramDC.RequestFilter> rfList)

Specified by:

knownUnavailableData in interface edu.sc.seis.cormorant.seismogram.CacheableDataCenter

retrieveData

public java.util.List<edu.iris.Fissures.seismogramDC.LocalSeismogramImpl> retrieveData(java.util.List<edu.iris.Fissures.IfSeismogramDC.RequestFilter> rfList)
                                                                                throws edu.iris.Fissures.FissuresException

Specified by:

retrieveData in interface edu.sc.seis.cormorant.seismogram.CacheableDataCenter

Throws:

edu.iris.Fissures.FissuresException