com.linecorp.centraldogma.internal.thrift.WatchFileResult类的使用及代码示例

x33g5p2x  于2022-02-03 转载在 其他  
字(8.6k)|赞(0)|评价(0)|浏览(124)

本文整理了Java中com.linecorp.centraldogma.internal.thrift.WatchFileResult类的一些代码示例，展示了WatchFileResult类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。WatchFileResult类的具体详情如下：
包路径：com.linecorp.centraldogma.internal.thrift.WatchFileResult
类名称：WatchFileResult

WatchFileResult介绍

暂无

代码示例

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-common-legacy-shaded

public WatchFileResult deepCopy() {
 return new WatchFileResult(this);
}

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-common-legacy-shaded

public void setFieldValue(_Fields field, Object value) {
 switch (field) {
 case REVISION:
  if (value == null) {
   unsetRevision();
  } else {
   setRevision((Revision)value);
  }
  break;
 case TYPE:
  if (value == null) {
   unsetType();
  } else {
   setType((EntryType)value);
  }
  break;
 case CONTENT:
  if (value == null) {
   unsetContent();
  } else {
   setContent((String)value);
  }
  break;
 }
}

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-common-legacy-shaded

public Object getFieldValue(_Fields field) {
 switch (field) {
 case REVISION:
  return getRevision();
 case TYPE:
  return getType();
 case CONTENT:
  return getContent();
 }
 throw new IllegalStateException();
}

代码示例来源：origin: line/centraldogma

/** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
public boolean isSet(_Fields field) {
 if (field == null) {
  throw new IllegalArgumentException();
 }
 switch (field) {
 case REVISION:
  return isSetRevision();
 case TYPE:
  return isSetType();
 case CONTENT:
  return isSetContent();
 }
 throw new IllegalStateException();
}

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-server

private static void handleWatchFileResult(
    CompletableFuture<com.linecorp.centraldogma.common.Entry<Object>> future,
    AsyncMethodCallback resultHandler) {
  future.handle((res, cause) -> {
    if (cause == null) {
      final WatchFileResult wfr = new WatchFileResult();
      wfr.setRevision(convert(res.revision()));
      wfr.setType(convert(res.type()));
      wfr.setContent(res.contentAsText());
      resultHandler.onComplete(wfr);
    } else if (cause instanceof CancellationException) {
      resultHandler.onComplete(CentralDogmaConstants.EMPTY_WATCH_FILE_RESULT);
    } else {
      logAndInvokeOnError("watchFile", resultHandler, cause);
    }
    return null;
  });
}

代码示例来源：origin: line/centraldogma

public void write(org.apache.thrift.protocol.TProtocol oprot, WatchFileResult struct) throws org.apache.thrift.TException {
 struct.validate();
 oprot.writeStructBegin(STRUCT_DESC);
 if (struct.revision != null) {
  if (struct.isSetRevision()) {
   oprot.writeFieldBegin(REVISION_FIELD_DESC);
   struct.revision.write(oprot);
   oprot.writeFieldEnd();
  }
 }
 if (struct.type != null) {
  if (struct.isSetType()) {
   oprot.writeFieldBegin(TYPE_FIELD_DESC);
   oprot.writeI32(struct.type.getValue());
   oprot.writeFieldEnd();
  }
 }
 if (struct.content != null) {
  if (struct.isSetContent()) {
   oprot.writeFieldBegin(CONTENT_FIELD_DESC);
   oprot.writeString(struct.content);
   oprot.writeFieldEnd();
  }
 }
 oprot.writeFieldStop();
 oprot.writeStructEnd();
}

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-common-legacy-shaded

@Override
public boolean equals(Object that) {
 if (that == null)
  return false;
 if (that instanceof WatchFileResult)
  return this.equals((WatchFileResult)that);
 return false;
}

代码示例来源：origin: line/centraldogma

private static void handleWatchFileResult(
    CompletableFuture<com.linecorp.centraldogma.common.Entry<Object>> future,
    AsyncMethodCallback resultHandler) {
  future.handle((res, cause) -> {
    if (cause == null) {
      final WatchFileResult wfr = new WatchFileResult();
      wfr.setRevision(convert(res.revision()));
      wfr.setType(convert(res.type()));
      wfr.setContent(res.contentAsText());
      resultHandler.onComplete(wfr);
    } else if (cause instanceof CancellationException) {
      resultHandler.onComplete(CentralDogmaConstants.EMPTY_WATCH_FILE_RESULT);
    } else {
      logAndInvokeOnError("watchFile", resultHandler, cause);
    }
    return null;
  });
}

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-common-legacy-shaded

/** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
public boolean isSet(_Fields field) {
 if (field == null) {
  throw new IllegalArgumentException();
 }
 switch (field) {
 case REVISION:
  return isSetRevision();
 case TYPE:
  return isSetType();
 case CONTENT:
  return isSetContent();
 }
 throw new IllegalStateException();
}

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-common-legacy-shaded

public void write(org.apache.thrift.protocol.TProtocol oprot, WatchFileResult struct) throws org.apache.thrift.TException {
 struct.validate();
 oprot.writeStructBegin(STRUCT_DESC);
 if (struct.revision != null) {
  if (struct.isSetRevision()) {
   oprot.writeFieldBegin(REVISION_FIELD_DESC);
   struct.revision.write(oprot);
   oprot.writeFieldEnd();
  }
 }
 if (struct.type != null) {
  if (struct.isSetType()) {
   oprot.writeFieldBegin(TYPE_FIELD_DESC);
   oprot.writeI32(struct.type.getValue());
   oprot.writeFieldEnd();
  }
 }
 if (struct.content != null) {
  if (struct.isSetContent()) {
   oprot.writeFieldBegin(CONTENT_FIELD_DESC);
   oprot.writeString(struct.content);
   oprot.writeFieldEnd();
  }
 }
 oprot.writeFieldStop();
 oprot.writeStructEnd();
}

代码示例来源：origin: line/centraldogma

@Override
public boolean equals(Object that) {
 if (that == null)
  return false;
 if (that instanceof WatchFileResult)
  return this.equals((WatchFileResult)that);
 return false;
}

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-server-shaded

private static void handleWatchFileResult(
    CompletableFuture<com.linecorp.centraldogma.common.Entry<Object>> future,
    AsyncMethodCallback resultHandler) {
  future.handle(voidFunction((res, cause) -> {
    if (cause == null) {
      final WatchFileResult wfr = new WatchFileResult();
      wfr.setRevision(convert(res.revision()));
      wfr.setType(convert(res.type()));
      wfr.setContent(res.contentAsText());
      resultHandler.onComplete(wfr);
    } else if (cause instanceof CancellationException) {
      resultHandler.onComplete(CentralDogmaConstants.EMPTY_WATCH_FILE_RESULT);
    } else {
      logAndInvokeOnError("watchFile", resultHandler, cause);
    }
  }));
}

代码示例来源：origin: line/centraldogma

public void setFieldValue(_Fields field, Object value) {
 switch (field) {
 case REVISION:
  if (value == null) {
   unsetRevision();
  } else {
   setRevision((Revision)value);
  }
  break;
 case TYPE:
  if (value == null) {
   unsetType();
  } else {
   setType((EntryType)value);
  }
  break;
 case CONTENT:
  if (value == null) {
   unsetContent();
  } else {
   setContent((String)value);
  }
  break;
 }
}

代码示例来源：origin: line/centraldogma

public Object getFieldValue(_Fields field) {
 switch (field) {
 case REVISION:
  return getRevision();
 case TYPE:
  return getType();
 case CONTENT:
  return getContent();
 }
 throw new IllegalStateException();
}

代码示例来源：origin: line/centraldogma

/**
 * Performs a deep copy on <i>other</i>.
 */
public WatchFileResult(WatchFileResult other) {
 if (other.isSetRevision()) {
  this.revision = new Revision(other.revision);
 }
 if (other.isSetType()) {
  this.type = other.type;
 }
 if (other.isSetContent()) {
  this.content = other.content;
 }
}

代码示例来源：origin: line/centraldogma

public WatchFileResult deepCopy() {
 return new WatchFileResult(this);
}

代码示例来源：origin: line/centraldogma

@Test
public void watchFile() throws Exception {
  doAnswer(invocation -> {
    AsyncMethodCallback<WatchFileResult> callback = invocation.getArgument(5);
    callback.onComplete(new WatchFileResult().setRevision(new TRevision(42))
                         .setType(TEntryType.TEXT)
                         .setContent("foo"));
    return null;
  }).when(iface).watchFile(any(), any(), any(), any(), anyLong(), any());
  assertThat(client.watchFile("project", "repo", new Revision(1), Query.ofText("/a.txt"), 100).get())
      .isEqualTo(Entry.ofText(new Revision(42), "/a.txt", "foo"));
  verify(iface).watchFile(eq("project"), eq("repo"), any(), any(), eq(100L), any());
}

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-client-armeria-legacy-shaded

final Revision revision = RevisionConverter.TO_MODEL.convert(r.getRevision());
if (revision == null) {
  return null;
switch (r.getType()) {
  case JSON:
    try {
      converted = unsafeCast(Entry.ofJson(revision, query.path(), r.getContent()));
    } catch (JsonParseException e) {
      throw new CompletionException("failed to parse the query result: " + query, e);
    converted = unsafeCast(Entry.ofText(revision, query.path(), r.getContent()));
    break;
  case DIRECTORY:
    break;
  default:
    throw new Error("unknown entry type: " + r.getType());

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-common-legacy-shaded

/**
 * Performs a deep copy on <i>other</i>.
 */
public WatchFileResult(WatchFileResult other) {
 if (other.isSetRevision()) {
  this.revision = new Revision(other.revision);
 }
 if (other.isSetType()) {
  this.type = other.type;
 }
 if (other.isSetContent()) {
  this.content = other.content;
 }
}

代码示例来源：origin: line/centraldogma

@Test
  public void watchFileTimedOut() throws Exception {
    doAnswer(invocation -> {
      AsyncMethodCallback<WatchFileResult> callback = invocation.getArgument(5);
      callback.onComplete(new WatchFileResult());
      return null;
    }).when(iface).watchFile(any(), any(), any(), any(), anyLong(), any());
    assertThat(client.watchFile("project", "repo", new Revision(1),
                  Query.ofText("/a.txt"), 100).get()).isNull();
    verify(iface).watchFile(eq("project"), eq("repo"), any(), any(), eq(100L), any());
  }
}

内容来源于网络，如有侵权，请联系作者删除！

WatchFileResult

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com