Package org.threeten.bp

Examples of org.threeten.bp.Instant

88
89
90
91
92
93
94
95
96
    return hateoasResponse(uriInfo);
  }

  @Path("valuationTime/{valuationTime}")
  public DependencyGraphTraceProviderResource setValuationTime(@PathParam("valuationTime") final String valuationTime) {
    Instant parsedValuationTime = Instant.parse(valuationTime);
    DependencyGraphTraceBuilderProperties properties = _properties.valuationTime(parsedValuationTime);
    return new DependencyGraphTraceProviderResource(_provider, _fudgeContext, properties);
  }
View Full Code Here
85
86
87
88
89
90
91
92
93
94
95
    _htsMaster.correct(doc);
  }

  @Test
  public void test_correct_getUpdateGet() {
    Instant now = Instant.now(_htsMaster.getClock());
   
    HistoricalTimeSeriesInfoDocument base = _htsMaster.get(UniqueId.of("DbHts", "101", "0"));
    ManageableHistoricalTimeSeriesInfo info = new ManageableHistoricalTimeSeriesInfo();
    info.setUniqueId(UniqueId.of("DbHts", "101", "0"));
    info.setName("Corrected");
View Full Code Here
52
53
54
55
56
57
58
59
60
61
62
    _htsMaster.add(doc);
  }

  @Test
  public void test_add_add() {
    Instant now = Instant.now(_htsMaster.getClock());
   
    ManageableHistoricalTimeSeriesInfo info = new ManageableHistoricalTimeSeriesInfo();
    info.setName("Added");
    info.setDataField("DF");
    info.setDataSource("DS");
View Full Code Here
105
106
107
108
109
110
111
112
113
114
115
    _htsMaster.update(doc);
  }

  @Test
  public void test_update_getUpdateGet() {
    Instant now = Instant.now(_htsMaster.getClock());
   
    HistoricalTimeSeriesInfoDocument base = _htsMaster.get(UniqueId.of("DbHts", "101", "0"));
    ManageableHistoricalTimeSeriesInfo info = new ManageableHistoricalTimeSeriesInfo();
    info.setUniqueId(UniqueId.of("DbHts", "101", "0"));
    info.setName("Updated");
View Full Code Here
355
356
357
358
359
360
361
362
363
364
365
  //-------------------------------------------------------------------------


  protected Instant restartRunInTransaction(RiskRun riskRun) {
    Instant now = now();
    riskRun.setStartInstant(now);
    riskRun.setNumRestarts(riskRun.getNumRestarts() + 1);
    riskRun.setComplete(false);

    getHibernateTemplate().update(riskRun);
View Full Code Here
581
582
583
584
585
586
587
588
589
590
    //
    _statusCacheByRunId.remove(run.getId());
    _computeFailureCacheByRunId.remove(run.getId());
    _riskRunsByIds.remove(run.getId());
    //
    Instant now = now();
    run.setEndInstant(now);
    run.setComplete(true);
    getHibernateTemplate().update(run);
  }
View Full Code Here
677
678
679
680
681
682
683
684
685
686
687
    final VersionCorrection versionCorrection,
    final Instant valuationTime,
    final Map<String, String> batchParameters,
    final SnapshotMode snapshotMode) {

    Instant now = Instant.now();

    MarketData values = createOrGetMarketDataInTransaction(baseMarketDataSnapshotUid);

    RiskRun riskRun = new RiskRun();
    riskRun.setMarketData(values);
View Full Code Here
912
913
914
915
916
917
918
919
920
921
922
      List<SqlParameterSource> targetProperties = newArrayList();
      List<SqlParameterSource> successes = newArrayList();
      List<SqlParameterSource> failures = newArrayList();
      List<SqlParameterSource> failureReasons = newArrayList();

      Instant evalInstant = Instant.now();

      long calcConfId = _calculationConfigurations.get(calcConfigName);

      for (final ComputationTargetSpecification targetSpec : viewCalculationResultModel.getAllTargets()) {
        final long computationTargetId = _computationTargets.get(targetSpec);
View Full Code Here
40
41
42
43
44
45
46
47
48
49
50
   */
  protected abstract Collection<T> getResources();
 
  //-------------------------------------------------------------------------
  private void removeStaleResources() {
    Instant timeoutBefore = Instant.now().minusMillis(getResourceTimeoutMillis());
    Collection<T> currentResources = getResources();
    Iterator<T> iterator = currentResources.iterator();
    while (iterator.hasNext()) {
      T resource = iterator.next();
      if (resource.isTerminated()) {
View Full Code Here
57
58
59
60
61
62
63
64
65
66
67
    _posMaster.add(doc);
  }

  @Test
  public void test_add_add() {
    Instant now = Instant.now(_posMaster.getClock());
   
    ManageablePosition position = new ManageablePosition(BigDecimal.TEN, ExternalId.of("A", "B"));
    PositionDocument doc = new PositionDocument();
    doc.setPosition(position);
    PositionDocument test = _posMaster.add(doc);
View Full Code Here
TOP

Related Classes of org.threeten.bp.Instant

  • com.opengamma.bbg.replay.BloombergTickWriter
  • com.opengamma.core.FudgeUniqueIdResolutionTools
  • com.opengamma.engine.calcnode.CalculationJobSpecificationTest
  • com.opengamma.engine.calcnode.stats.DataFunctionCostsMasterResource
  • com.opengamma.engine.depgraph.DepGraphTestHelper
  • com.opengamma.engine.exec.PlanExecutorTest
  • com.opengamma.engine.fudgemsg.CalculationJobSpecificationFudgeBuilder
  • com.opengamma.engine.fudgemsg.CompiledViewDefinitionFudgeBuilder
  • com.opengamma.engine.fudgemsg.ViewDefinitionCompilationFailedCallFudgeBuilder
  • com.opengamma.engine.fudgemsg.ViewDeltaResultModelFudgeBuilder
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.