List of syncToStorage() Examples

Examples of syncToStorage()

net.opentsdb.meta.Annotation.syncToStorage()
Attempts a CompareAndSet storage call, loading the object from storage, synchronizing changes, and attempting a put. Note: If the local object didn't have any fields set by the caller or there weren't any changes, then the data will not be written and an exception will be thrown. @param tsdb The TSDB to use for storage access @param overwrite When the RPC method is PUT, will overwrite all useraccessible fields True if the storage call was successful, false if the object was modified in storage during the CAS call. If false, retry the call. Other failures will result in an exception being thrown. @throws HBaseException if there was an issue @throws IllegalArgumentException if required data was missing such as the {@code #start_time} @throws IllegalStateException if the data hasn't changed. This is OK! @throws JSONException if the object could not be serialized
net.opentsdb.meta.TSMeta.syncToStorage()
Attempts a CompareAndSet storage call, loading the object from storage, synchronizing changes, and attempting a put. Also verifies that associated UID name mappings exist before merging. Note: If the local object didn't have any fields set by the caller or there weren't any changes, then the data will not be written and an exception will be thrown. Note: We do not store the UIDMeta information with TSMeta's since users may change a single UIDMeta object and we don't want to update every TSUID that includes that object with the new data. Instead, UIDMetas are merged into the TSMeta on retrieval so we always have canonical data. This also saves space in storage. @param tsdb The TSDB to use for storage access @param overwrite When the RPC method is PUT, will overwrite all useraccessible fields @return True if the storage call was successful, false if the object wasmodified in storage during the CAS call. If false, retry the call. Other failures will result in an exception being thrown. @throws HBaseException if there was an issue @throws IllegalArgumentException if parsing failed @throws NoSuchUniqueId If any of the UID name mappings do not exist @throws IllegalStateException if the data hasn't changed. This is OK! @throws JSONException if the object could not be serialized
net.opentsdb.meta.UIDMeta.syncToStorage()
Attempts a CompareAndSet storage call, loading the object from storage, synchronizing changes, and attempting a put. Note: If the local object didn't have any fields set by the caller then the data will not be written. @param tsdb The TSDB to use for storage access @param overwrite When the RPC method is PUT, will overwrite all useraccessible fields @return True if the storage call was successful, false if the object wasmodified in storage during the CAS call. If false, retry the call. Other failures will result in an exception being thrown. @throws HBaseException if there was an issue fetching @throws IllegalArgumentException if parsing failed @throws NoSuchUniqueId If the UID does not exist @throws IllegalStateException if the data hasn't changed. This is OK! @throws JSONException if the object could not be serialized
net.opentsdb.tree.TreeRule.syncToStorage()
Attempts to write the rule to storage via CompareAndSet, merging changes with an existing rule. Note: If the local object didn't have any fields set by the caller or there weren't any changes, then the data will not be written and an exception will be thrown. Note: This method also validates the rule, making sure that proper combinations of data exist before writing to storage. @param tsdb The TSDB to use for storage access @param overwrite When the RPC method is PUT, will overwrite all useraccessible fields @return True if the CAS call succeeded, false if the stored data wasmodified in flight. This should be retried if that happens. @throws HBaseException if there was an issue @throws IllegalArgumentException if parsing failed or the tree ID was invalid or validation failed @throws IllegalStateException if the data hasn't changed. This is OK! @throws JSONException if the object could not be serialized

Examples of net.opentsdb.meta.UIDMeta.syncToStorage()

        }
        
      }
      
      try {
        final Deferred<UIDMeta> process_meta = meta.syncToStorage(tsdb, 
            method == HttpMethod.PUT).addCallbackDeferring(new SyncCB());
        final UIDMeta updated_meta = process_meta.joinUninterruptibly();
        tsdb.indexUIDMeta(updated_meta);
        query.sendReply(query.serializer().formatUidMetaV1(updated_meta));
      } catch (IllegalStateException e) {

View Full Code Here

Examples of net.opentsdb.tree.TreeRule.syncToStorage()

    rule.setLevel(1);
    rule.setOrder(0);
    rule.setType(TreeRuleType.TAGV_CUSTOM);
    rule.setNotes("Just some notes");
    rule.setField("foo");
    rule.syncToStorage(storage.getTSDB(), false).joinUninterruptibly();
  }
  
  @Test (expected = IllegalArgumentException.class)
  public void storeRuleInvalidMissingCustomFieldMetricCustom() throws Exception {
    setupStorage();

View Full Code Here

Examples of net.opentsdb.tree.TreeRule.syncToStorage()

    rule.setLevel(1);
    rule.setOrder(0);
    rule.setType(TreeRuleType.METRIC_CUSTOM);
    rule.setNotes("Just some notes");
    rule.setField("foo");
    rule.syncToStorage(storage.getTSDB(), false).joinUninterruptibly();
  }
  
  @Test (expected = IllegalArgumentException.class)
  public void storeRuleInvalidRegexIdx() throws Exception {
    setupStorage();

View Full Code Here

Examples of net.opentsdb.tree.TreeRule.syncToStorage()

    rule.setLevel(1);
    rule.setOrder(0);
    rule.setType(TreeRuleType.TAGK);
    rule.setRegex("^.*$");
    rule.setRegexGroupIdx(-1);
    rule.syncToStorage(storage.getTSDB(), false).joinUninterruptibly();
  }
  
  @Test
  public void deleteRule() throws Exception {
    setupStorage();

View Full Code Here

Examples of net.opentsdb.tree.TreeRule.syncToStorage()

    final TreeRule rule = new TreeRule(1);
    rule.setLevel(1);
    rule.setOrder(0);
    rule.setType(TreeRuleType.METRIC);
    rule.setNotes("Just some notes");
    assertTrue(rule.syncToStorage(storage.getTSDB(), false).joinUninterruptibly());
    assertEquals(3, storage.numColumns(new byte[] { 0, 1 }));
  }
  
  @Test
  public void storeRuleMege() throws Exception {

View Full Code Here

Examples of net.opentsdb.tree.TreeRule.syncToStorage()

    setupStorage();
    final TreeRule rule = new TreeRule(1);
    rule.setLevel(2);
    rule.setOrder(1);
    rule.setNotes("Just some notes");
    assertTrue(rule.syncToStorage(storage.getTSDB(), false).joinUninterruptibly());
    assertEquals(2, storage.numColumns(new byte[] { 0, 1 }));
    final TreeRule stored = JSON.parseToObject(
        storage.getColumn(new byte[] { 0, 1 }, 
        "tree_rule:2:1".getBytes(MockBase.ASCII())), TreeRule.class);
    assertEquals("Host owner", stored.getDescription());

View Full Code Here

Examples of net.opentsdb.tree.TreeRule.syncToStorage()

  
  @Test (expected = IllegalArgumentException.class)
  public void storeRuleBadID0() throws Exception {
    setupStorage();
    final TreeRule rule = new TreeRule(0);
    rule.syncToStorage(storage.getTSDB(), false);
  }
  
  @Test (expected = IllegalArgumentException.class)
  public void storeRuleBadID65536() throws Exception {
    setupStorage();

View Full Code Here

Examples of net.opentsdb.tree.TreeRule.syncToStorage()

  
  @Test (expected = IllegalArgumentException.class)
  public void storeRuleBadID65536() throws Exception {
    setupStorage();
    final TreeRule rule = new TreeRule(65536);
    rule.syncToStorage(storage.getTSDB(), false);
  }
  
  @Test (expected = IllegalStateException.class)
  public void storeRuleNoChanges() throws Exception {
    setupStorage();

View Full Code Here

Examples of net.opentsdb.tree.TreeRule.syncToStorage()

  @Test (expected = IllegalStateException.class)
  public void storeRuleNoChanges() throws Exception {
    setupStorage();
    final TreeRule rule = TreeRule.fetchRule(storage.getTSDB(), 1, 2, 1)
      .joinUninterruptibly();
    rule.syncToStorage(storage.getTSDB(), false);
  }
  
  @Test (expected = IllegalArgumentException.class)
  public void storeRuleInvalidType() throws Exception {
    setupStorage();

View Full Code Here

Examples of net.opentsdb.tree.TreeRule.syncToStorage()

    setupStorage();
    final TreeRule rule = new TreeRule(1);
    rule.setLevel(1);
    rule.setOrder(0);
    rule.setNotes("Just some notes");
    rule.syncToStorage(storage.getTSDB(), false).joinUninterruptibly();
  }
  
  @Test (expected = IllegalArgumentException.class)
  public void storeRuleInvalidMissingFieldTagk() throws Exception {
    setupStorage();

View Full Code Here

0 1 2

TOP

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.