Package com.opengamma.id

Examples of com.opengamma.id.ObjectId

599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
  public void test_ReplaceVersion_noUid() {
    Clock origClock = _exgMaster.getClock();
    try {
      Instant now = Instant.now();

      ObjectId baseOid = setupTestData(now);
      _exgMaster.setClock(Clock.fixed(now.plus(2, HOURS), ZoneOffset.UTC));

      final ExternalIdBundle bundle = ExternalIdBundle.of("B", "B0");
      final ExternalIdBundle region = ExternalIdBundle.of("R", "R0");
      List<ExchangeDocument> replacement = newArrayList();
      for (int i = 0; i <= 2; i++) {
        ManageableExchange ex = new ManageableExchange(bundle, "replace_" + i, region, null);
        ExchangeDocument doc = new ExchangeDocument(ex);
        doc.setVersionFromInstant(now.plus(1, MINUTES).plus(i * 20, SECONDS));
        replacement.add(doc);
      }

      _exgMaster.replaceVersion(baseOid.atVersion("no such uid"), replacement);
    } finally {
      _exgMaster.setClock(origClock);
    }
  }
View Full Code Here
49
50
51
52
53
54
55
56
    _htsMaster.updateTimeSeriesDataPoints(ObjectId.of("DbHts", "DP101"), null);
  }

  @Test(expectedExceptions = DataNotFoundException.class)
  public void test_update_versioned_notFoundId() {
    ObjectId oid = ObjectId.of("DbHts", "DP0");
    _htsMaster.updateTimeSeriesDataPoints(oid, ImmutableLocalDateDoubleTimeSeries.EMPTY_SERIES);
  }
View Full Code Here
79
80
81
82
83
84
85
86
87
88
89
  public void test_update_102_startsEmpty() {
    LocalDate[] dates = {LocalDate.of(2011, 7, 1), LocalDate.of(2011, 7, 2), LocalDate.of(2011, 7, 4)};
    double[] values = {1.1d, 2.2d, 3.3d};
    LocalDateDoubleTimeSeries series = ImmutableLocalDateDoubleTimeSeries.of(dates, values);
   
    ObjectId oid = ObjectId.of("DbHts", "DP102");
    UniqueId uniqueId = _htsMaster.updateTimeSeriesDataPoints(oid, series);
   
    ManageableHistoricalTimeSeries test = _htsMaster.getTimeSeries(uniqueId);
    assertEquals(uniqueId, test.getUniqueId());
    assertEquals(series, test.getTimeSeries());
View Full Code Here
93
94
95
96
97
98
99
100
101
102
103
  public void test_update_101_startsFull() {
    LocalDate[] dates = {LocalDate.of(2011, 7, 1), LocalDate.of(2011, 7, 2), LocalDate.of(2011, 7, 4)};
    double[] values = {1.1d, 2.2d, 3.3d};
    LocalDateDoubleTimeSeries series = ImmutableLocalDateDoubleTimeSeries.of(dates, values);
   
    ObjectId oid = ObjectId.of("DbHts", "DP101");
    UniqueId uniqueId = _htsMaster.updateTimeSeriesDataPoints(oid, series);
   
    ManageableHistoricalTimeSeries testAdded = _htsMaster.getTimeSeries(uniqueId, HistoricalTimeSeriesGetFilter.ofRange(LocalDate.of(2011, 7, 1), null));
    assertEquals(uniqueId, testAdded.getUniqueId());
    assertEquals(series, testAdded.getTimeSeries());
View Full Code Here
85
86
87
88
89
90
91
92
93
94
95
      ManageableExchange exchange = new ManageableExchange(bundle, "initial", region, null);
      ExchangeDocument initialDoc = new ExchangeDocument(exchange);

      _exgMaster.add(initialDoc);

      ObjectId baseOid = initialDoc.getObjectId();

      List<ExchangeDocument> firstReplacement = newArrayList();
      for (int i = 0; i < 5; i++) {
        ManageableExchange ex = new ManageableExchange(bundle, "setup_" + i, region, null);
        ExchangeDocument doc = new ExchangeDocument(ex);
View Full Code Here
104
105
106
107
108
109
110
111
112
  }

  //-------------------------------------------------------------------------
  @Test
  public void test_getObjectId() {
    ObjectId oid = ObjectId.of("DbHts", "201");
    HistoricalTimeSeriesInfoDocument test = _htsMaster.get(oid, VersionCorrection.LATEST);
    assert203(test);
  }
View Full Code Here
111
112
113
114
115
116
117
118
119
    assert203(test);
  }

  @Test
  public void test_getObjectId_earlierCorrection() {
    ObjectId oid = ObjectId.of("DbHts", "201");
    HistoricalTimeSeriesInfoDocument test = _htsMaster.get(oid, VersionCorrection.ofCorrectedTo(_version2Instant));
    assert202(test);
  }
View Full Code Here
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
    final List<Future<Pair<UniqueId, ObjectId>>> futures = new LinkedList<Future<Pair<UniqueId, ObjectId>>>();
    PortfolioNodeTraverser.depthFirst(new AbstractPortfolioNodeTraversalCallback() {
      @Override
      public void preOrderOperation(final PortfolioNode parentNode, final Position position) {
        final ExternalId positionId = position.getUniqueId().toExternalId();
        ObjectId id = s_cache.get(positionId);
        if (id == null) {
          futures.add(_executor.submit(new Callable<Pair<UniqueId, ObjectId>>() {
            @Override
            public Pair<UniqueId, ObjectId> call() throws Exception {
              final PositionSearchRequest searchRequest = new PositionSearchRequest();
              searchRequest.setPositionProviderId(positionId);
              final PositionSearchResult searchResult = _positions.search(searchRequest);
              ObjectId id = null;
              if (searchResult.getFirstPosition() != null) {
                id = searchResult.getFirstPosition().getUniqueId().getObjectId();
                s_logger.debug("Found position {} in master at {}", position, id);
              }
              if (id == null) {
View Full Code Here
168
169
170
171
172
173
174
175
176
177
178
      future.cancel(false);
    }
  }

  protected ObjectId mapPositionIdentifier(final Position position) {
    ObjectId id = _positionMap.get(position.getUniqueId());
    if (id == null) {
      s_logger.debug("Adding position {} to master", position);
      id = _positions.add(new PositionDocument(createManageablePosition(position))).getUniqueId().getObjectId();
      _positionMap.put(position.getUniqueId(), id);
      s_cache.put(position.getUniqueId().toExternalId(), id);
View Full Code Here
403
404
405
406
407
408
409
410
411
412
413
        if (_includePosition) {
          final String posIdScheme = rs.getString("POS_KEY_SCHEME");
          final String posIdValue = rs.getString("POS_KEY_VALUE");
          if (posIdScheme != null && posIdValue != null) {
            ObjectId id = ObjectId.of(posIdScheme, posIdValue);
            if (_nodePositionIds.add(id)) {
              _node.addPosition(id);
              assert (_nodePositionIds.size() == _node.getPositionIds().size());
            }
          }
View Full Code Here
TOP

Related Classes of com.opengamma.id.ObjectId

  • com.opengamma.batch.rest.DataBatchMasterResource
  • com.opengamma.batch.rest.DataBatchMasterResourceTest
  • com.opengamma.bbg.loader.hts.BloombergHTSMasterUpdater
  • com.opengamma.core.config.impl.DataConfigSourceResource
  • com.opengamma.core.exchange.impl.DataExchangeSourceResource
  • com.opengamma.core.holiday.impl.DataHolidaySourceResource
  • com.opengamma.core.LinkUtils
  • com.opengamma.core.marketdatasnapshot.impl.DataMarketDataSnapshotSourceResource
  • com.opengamma.core.organization.impl.DataOrganizationSourceResource
  • com.opengamma.core.position.impl.DataPositionSourceResource
    • 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.