/*
* Copyright (C) 2018-2021 Lightbend Inc. <https://www.lightbend.com>
*/
// Generated by the protocol buffer compiler. DO NOT EDIT!
// source: google/protobuf/descriptor.proto
package akka.protobuf;
public final class DescriptorProtos {
private DescriptorProtos() {}
public static void registerAllExtensions(
akka.protobuf.ExtensionRegistry registry) {
}
public interface FileDescriptorSetOrBuilder
extends akka.protobuf.MessageOrBuilder {
// repeated .google.protobuf.FileDescriptorProto file = 1;
/**
* <code>repeated .google.protobuf.FileDescriptorProto file = 1;</code>
*/
java.util.List<akka.protobuf.DescriptorProtos.FileDescriptorProto>
getFileList();
/**
* <code>repeated .google.protobuf.FileDescriptorProto file = 1;</code>
*/
akka.protobuf.DescriptorProtos.FileDescriptorProto getFile(int index);
/**
* <code>repeated .google.protobuf.FileDescriptorProto file = 1;</code>
*/
int getFileCount();
/**
* <code>repeated .google.protobuf.FileDescriptorProto file = 1;</code>
*/
java.util.List<? extends akka.protobuf.DescriptorProtos.FileDescriptorProtoOrBuilder>
getFileOrBuilderList();
/**
* <code>repeated .google.protobuf.FileDescriptorProto file = 1;</code>
*/
akka.protobuf.DescriptorProtos.FileDescriptorProtoOrBuilder getFileOrBuilder(
int index);
}
/**
* Protobuf type {@code google.protobuf.FileDescriptorSet}
*
* <pre>
* The protocol compiler can output a FileDescriptorSet containing the .proto
* files it parses.
* </pre>
*/
public static final class FileDescriptorSet extends
akka.protobuf.GeneratedMessage
implements FileDescriptorSetOrBuilder {
// Use FileDescriptorSet.newBuilder() to construct.
private FileDescriptorSet(akka.protobuf.GeneratedMessage.Builder<?> builder) {
super(builder);
this.unknownFields = builder.getUnknownFields();
}
private FileDescriptorSet(boolean noInit) { this.unknownFields = akka.protobuf.UnknownFieldSet.getDefaultInstance(); }
private static final FileDescriptorSet defaultInstance;
public static FileDescriptorSet getDefaultInstance() {
return defaultInstance;
}
public FileDescriptorSet getDefaultInstanceForType() {
return defaultInstance;
}
private final akka.protobuf.UnknownFieldSet unknownFields;
@java.lang.Override
public final akka.protobuf.UnknownFieldSet
getUnknownFields() {
return this.unknownFields;
}
private FileDescriptorSet(
akka.protobuf.CodedInputStream input,
akka.protobuf.ExtensionRegistryLite extensionRegistry)
throws akka.protobuf.InvalidProtocolBufferException {
initFields();
int mutable_bitField0_ = 0;
akka.protobuf.UnknownFieldSet.Builder unknownFields =
akka.protobuf.UnknownFieldSet.newBuilder();
try {
boolean done = false;
while (!done) {
int tag = input.readTag();
switch (tag) {
case 0:
done = true;
break;
default: {
if (!parseUnknownField(input, unknownFields,
extensionRegistry, tag)) {
done = true;
}
break;
}
case 10: {
if (!((mutable_bitField0_ & 0x00000001) == 0x00000001)) {
file_ = new java.util.ArrayList<akka.protobuf.DescriptorProtos.FileDescriptorProto>();
mutable_bitField0_ |= 0x00000001;
}
file_.add(input.readMessage(akka.protobuf.DescriptorProtos.FileDescriptorProto.PARSER, extensionRegistry));
break;
}
}
}
} catch (akka.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new akka.protobuf.InvalidProtocolBufferException(
e.getMessage()).setUnfinishedMessage(this);
} finally {
if (((mutable_bitField0_ & 0x00000001) == 0x00000001)) {
file_ = java.util.Collections.unmodifiableList(file_);
}
this.unknownFields = unknownFields.build();
makeExtensionsImmutable();
}
}
public static final akka.protobuf.Descriptors.Descriptor
getDescriptor() {
return akka.protobuf.DescriptorProtos.internal_static_google_protobuf_FileDescriptorSet_descriptor;
}
protected akka.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() {
return akka.protobuf.DescriptorProtos.internal_static_google_protobuf_FileDescriptorSet_fieldAccessorTable
.ensureFieldAccessorsInitialized(
akka.protobuf.DescriptorProtos.FileDescriptorSet.class, akka.protobuf.DescriptorProtos.FileDescriptorSet.Builder.class);
}
public static akka.protobuf.Parser<FileDescriptorSet> PARSER =
new akka.protobuf.AbstractParser<FileDescriptorSet>() {
public FileDescriptorSet parsePartialFrom(
akka.protobuf.CodedInputStream input,
akka.protobuf.ExtensionRegistryLite extensionRegistry)
throws akka.protobuf.InvalidProtocolBufferException {
return new FileDescriptorSet(input, extensionRegistry);
}
};
@java.lang.Override
public akka.protobuf.Parser<FileDescriptorSet> getParserForType() {
return PARSER;
}
// repeated .google.protobuf.FileDescriptorProto file = 1;
public static final int FILE_FIELD_NUMBER = 1;
private java.util.List<akka.protobuf.DescriptorProtos.FileDescriptorProto> file_;
/**
* <code>repeated .google.protobuf.FileDescriptorProto file = 1;</code>
*/
public java.util.List<akka.protobuf.DescriptorProtos.FileDescriptorProto> getFileList() {
return file_;
}
/**
* <code>repeated .google.protobuf.FileDescriptorProto file = 1;</code>
*/
public java.util.List<? extends akka.protobuf.DescriptorProtos.FileDescriptorProtoOrBuilder>
getFileOrBuilderList() {
return file_;
}
/**
* <code>repeated .google.protobuf.FileDescriptorProto file = 1;</code>
*/
public int getFileCount() {
return file_.size();
}
/**
* <code>repeated .google.protobuf.FileDescriptorProto file = 1;</code>
*/
public akka.protobuf.DescriptorProtos.FileDescriptorProto getFile(int index) {
return file_.get(index);
}
/**
* <code>repeated .google.protobuf.FileDescriptorProto file = 1;</code>
*/
public akka.protobuf.DescriptorProtos.FileDescriptorProtoOrBuilder getFileOrBuilder(
int index) {
return file_.get(index);
}
private void initFields() {
file_ = java.util.Collections.emptyList();
}
private byte memoizedIsInitialized = -1;
public final boolean isInitialized() {
byte isInitialized = memoizedIsInitialized;
if (isInitialized != -1) return isInitialized == 1;
for (int i = 0; i < getFileCount(); i++) {
if (!getFile(i).isInitialized()) {
memoizedIsInitialized = 0;
return false;
}
}
memoizedIsInitialized = 1;
return true;
}
public void writeTo(akka.protobuf.CodedOutputStream output)
throws java.io.IOException {
getSerializedSize();
for (int i = 0; i < file_.size(); i++) {
output.writeMessage(1, file_.get(i));
}
getUnknownFields().writeTo(output);
}
private int memoizedSerializedSize = -1;
public int getSerializedSize() {
int size = memoizedSerializedSize;
if (size != -1) return size;
size = 0;
for (int i = 0; i < file_.size(); i++) {
size += akka.protobuf.CodedOutputStream
.computeMessageSize(1, file_.get(i));
}
size += getUnknownFields().getSerializedSize();
memoizedSerializedSize = size;
return size;
没有合适的资源?快使用搜索试试~ 我知道了~
akka actor模型开发库 v2.6.14 pc端
共2000个文件
scala:841个
java:552个
md:398个
1.该资源内容由用户上传,如若侵权请联系客服进行举报
2.虚拟产品一经售出概不退款(资源遇到问题,请及时私信上传者)
2.虚拟产品一经售出概不退款(资源遇到问题,请及时私信上传者)
版权申诉
0 下载量 179 浏览量
2023-11-04
17:13:53
上传
评论
收藏 15.07MB ZIP 举报
温馨提示
该软件是为了解决分布式编程中一系列的编程问题而设计,是非常实用的Java和Scala的Actor模型应用,支持多种运行系统进行使用,且安全性高,操作简单,用起来也是非常的方便的! 1、Actor之间完全独立; 2、Actor由标识和当前行为描述; 3、在收到消息时Actor所采取的所有动作都是并行的,在一个方法中的动作没有明确的顺序; 4、系统中的所有事物都可以扮演一个Actor; 5、Actor可能被分成原始(primitive)和非原始(non primitive)类别; 1.支持多个actor同时使用,不用担心相互干扰 2.清晰的页面设计方便大家进行各种功能性的查找和使用 3.消息传递是非阻塞和异步的,且消息发送都是一并进行的
资源推荐
资源详情
资源评论
收起资源包目录
akka actor模型开发库 v2.6.14 pc端 (2000个子文件)
29903-actor-testkit-typed-timer-support 191B
akka-cluster 7KB
reference.conf 58KB
reference.conf 23KB
reference.conf 13KB
reference.conf 9KB
reference.conf 5KB
reference.conf 3KB
reference.conf 1KB
reference.conf 1KB
reference.conf 999B
.sbt-java-formatter.conf 913B
reference.conf 850B
reference.conf 660B
reference.conf 192B
application.conf 188B
mailbox-config-sample.conf 107B
application-test.conf 60B
reference.conf 59B
application.conf 55B
artery-node003.example.com.crt 1KB
artery-node001.example.com.crt 1KB
artery-node002.example.com.crt 1KB
rsa-client.example.com.crt 1KB
node.example.com.crt 1KB
domain.crt 1KB
client.example.com.crt 961B
one.example.com.crt 957B
two.example.com.crt 957B
island.example.com.crt 945B
exampleca.crt 837B
28473-upgrade-ScalaTest-to-3-1-0.excludes 9KB
_existing.excludes 7KB
2.5.9.backwards.excludes 3KB
2.5.4.backwards.excludes 2KB
_existing.excludes 2KB
_existing.excludes 2KB
2.5.12.backwards.excludes 2KB
2.5.4.backwards.excludes 2KB
2.5.9.backwards.excludes 2KB
2.5.19.backwards.excludes 2KB
pr-28305-JFR-based-flight-recording.excludes 1KB
2.5.25.backwards.excludes 1KB
2.5.18.backwards.excludes 1KB
_existing.excludes 1KB
29217-active-active-event-sourcing.excludes 1003B
2.6.0.excludes 982B
28331-timestamp-PersistentRepr.excludes 876B
issue-27300-appVersion.excludes 856B
2.5.15.backwards.excludes 761B
2.5.11.backwards.excludes 723B
2.5.4.backwards.excludes 708B
issue-27922-logging.excludes 696B
28294-add-ExtensionId-apply-get-overloads.excludes 675B
pr-29672-snapshot-after-event-replay.excludes 667B
issue-23712-testkit.excludes 648B
28629-writeInProgress-race.excludes 646B
issue-27788-remove-auto-down.excludes 597B
issue-27994-inmem-journal.excludes 596B
down-when-quarantined.excludes 552B
28695-watch-flush.excludes 520B
2.5.10.backwards.excludes 515B
2.5.7.backwards.excludes 513B
issue-13654-no-class-manifests-for-cluster-serializer-step1.excludes 501B
_existing.excludes 485B
28294-add-ExtensionId-apply-get-overloads.excludes 465B
29687-java-TestProbe-awaitAssert-support-checked-exception.excludes 403B
issue-25216-typed-persistence-recovery-strategies.excludes 401B
28300-fix-2.6.0-mima.excludes 398B
29217-replicated-event-sourcing.excludes 367B
2.5.11.backwards.excludes 350B
2.5.17.backwards.excludes 349B
2.5.26-vs-2.6.0-RC1.excludes 347B
29288-leveldb-cleanups.excludes 346B
2.5.6.backwards.excludes 341B
2.5.3.backwards.excludes 317B
issue-28297-deathpactexception.excludes 307B
2.5.2.backwards.excludes 303B
29294-receptionist-inbox.excludes 300B
pr-29246-remove-prng-constans.excludes 295B
pr-30007-internal-logger-for-es-behavior.excludes 295B
issue-30090-sbr-release-lease.excludes 287B
2.5.21.backwards.excludes 286B
issue-29828-resolve-cache.excludes 283B
27338-ActorTestKit-system.excludes 275B
28294-add-ExtensionId-apply-get-overloads.excludes 267B
28294-add-ExtensionId-apply-get-overloads.excludes 262B
pr-29928-testprobe-is-recipientref.excludes 255B
2.5.17.backwards.excludes 251B
28294-add-ExtensionId-apply-get-overloads.excludes 243B
2.5.6.backwards.excludes 242B
2.5.12.backwards.excludes 224B
28331-timestamp-PersistentRepr.excludes 213B
_existing.excludes 212B
2.5.21.backwards.excludes 184B
2.5.25.backwards.excludes 182B
jdk11-specific-classes.backwards.excludes 173B
fish-for-message-pf.excludes 169B
2.5.3.backwards.excludes 157B
2.5.17.backwards.excludes 157B
共 2000 条
- 1
- 2
- 3
- 4
- 5
- 6
- 20
资源评论
DNCS高级工程师
- 粉丝: 761
- 资源: 551
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功