/*
* Copyright (C) 2023 Lightbend Inc. <https://www.lightbend.com>
*/
// Generated by the protocol buffer compiler. DO NOT EDIT!
// source: ReplicatorMessages.proto
package akka.cluster.ddata.protobuf.msg;
public final class ReplicatorMessages {
private ReplicatorMessages() {}
public static void registerAllExtensions(
akka.protobufv3.internal.ExtensionRegistryLite registry) {
}
public static void registerAllExtensions(
akka.protobufv3.internal.ExtensionRegistry registry) {
registerAllExtensions(
(akka.protobufv3.internal.ExtensionRegistryLite) registry);
}
public interface GetOrBuilder extends
// @@protoc_insertion_point(interface_extends:akka.cluster.ddata.Get)
akka.protobufv3.internal.MessageOrBuilder {
/**
* <code>required .akka.cluster.ddata.OtherMessage key = 1;</code>
* @return Whether the key field is set.
*/
boolean hasKey();
/**
* <code>required .akka.cluster.ddata.OtherMessage key = 1;</code>
* @return The key.
*/
akka.cluster.ddata.protobuf.msg.ReplicatorMessages.OtherMessage getKey();
/**
* <code>required .akka.cluster.ddata.OtherMessage key = 1;</code>
*/
akka.cluster.ddata.protobuf.msg.ReplicatorMessages.OtherMessageOrBuilder getKeyOrBuilder();
/**
* <code>required sint32 consistency = 2;</code>
* @return Whether the consistency field is set.
*/
boolean hasConsistency();
/**
* <code>required sint32 consistency = 2;</code>
* @return The consistency.
*/
int getConsistency();
/**
* <code>required uint32 timeout = 3;</code>
* @return Whether the timeout field is set.
*/
boolean hasTimeout();
/**
* <code>required uint32 timeout = 3;</code>
* @return The timeout.
*/
int getTimeout();
/**
* <code>optional .akka.cluster.ddata.OtherMessage request = 4;</code>
* @return Whether the request field is set.
*/
boolean hasRequest();
/**
* <code>optional .akka.cluster.ddata.OtherMessage request = 4;</code>
* @return The request.
*/
akka.cluster.ddata.protobuf.msg.ReplicatorMessages.OtherMessage getRequest();
/**
* <code>optional .akka.cluster.ddata.OtherMessage request = 4;</code>
*/
akka.cluster.ddata.protobuf.msg.ReplicatorMessages.OtherMessageOrBuilder getRequestOrBuilder();
/**
* <code>optional int32 consistencyMinCap = 5;</code>
* @return Whether the consistencyMinCap field is set.
*/
boolean hasConsistencyMinCap();
/**
* <code>optional int32 consistencyMinCap = 5;</code>
* @return The consistencyMinCap.
*/
int getConsistencyMinCap();
/**
* <code>optional int32 consistencyAdditional = 6;</code>
* @return Whether the consistencyAdditional field is set.
*/
boolean hasConsistencyAdditional();
/**
* <code>optional int32 consistencyAdditional = 6;</code>
* @return The consistencyAdditional.
*/
int getConsistencyAdditional();
}
/**
* Protobuf type {@code akka.cluster.ddata.Get}
*/
public static final class Get extends
akka.protobufv3.internal.GeneratedMessageV3 implements
// @@protoc_insertion_point(message_implements:akka.cluster.ddata.Get)
GetOrBuilder {
private static final long serialVersionUID = 0L;
// Use Get.newBuilder() to construct.
private Get(akka.protobufv3.internal.GeneratedMessageV3.Builder<?> builder) {
super(builder);
}
private Get() {
}
@java.lang.Override
@SuppressWarnings({"unused"})
protected java.lang.Object newInstance(
akka.protobufv3.internal.GeneratedMessageV3.UnusedPrivateParameter unused) {
return new Get();
}
public static final akka.protobufv3.internal.Descriptors.Descriptor
getDescriptor() {
return akka.cluster.ddata.protobuf.msg.ReplicatorMessages.internal_static_akka_cluster_ddata_Get_descriptor;
}
@java.lang.Override
protected akka.protobufv3.internal.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
return akka.cluster.ddata.protobuf.msg.ReplicatorMessages.internal_static_akka_cluster_ddata_Get_fieldAccessorTable
.ensureFieldAccessorsInitialized(
akka.cluster.ddata.protobuf.msg.ReplicatorMessages.Get.class, akka.cluster.ddata.protobuf.msg.ReplicatorMessages.Get.Builder.class);
}
private int bitField0_;
public static final int KEY_FIELD_NUMBER = 1;
private akka.cluster.ddata.protobuf.msg.ReplicatorMessages.OtherMessage key_;
/**
* <code>required .akka.cluster.ddata.OtherMessage key = 1;</code>
* @return Whether the key field is set.
*/
@java.lang.Override
public boolean hasKey() {
return ((bitField0_ & 0x00000001) != 0);
}
/**
* <code>required .akka.cluster.ddata.OtherMessage key = 1;</code>
* @return The key.
*/
@java.lang.Override
public akka.cluster.ddata.protobuf.msg.ReplicatorMessages.OtherMessage getKey() {
return key_ == null ? akka.cluster.ddata.protobuf.msg.ReplicatorMessages.OtherMessage.getDefaultInstance() : key_;
}
/**
* <code>required .akka.cluster.ddata.OtherMessage key = 1;</code>
*/
@java.lang.Override
public akka.cluster.ddata.protobuf.msg.ReplicatorMessages.OtherMessageOrBuilder getKeyOrBuilder() {
return key_ == null ? akka.cluster.ddata.protobuf.msg.ReplicatorMessages.OtherMessage.getDefaultInstance() : key_;
}
public static final int CONSISTENCY_FIELD_NUMBER = 2;
private int consistency_ = 0;
/**
* <code>required sint32 consistency = 2;</code>
* @return Whether the consistency field is set.
*/
@java.lang.Override
public boolean hasConsistency() {
return ((bitField0_ & 0x00000002) != 0);
}
/**
* <code>required sint32 consistency = 2;</code>
* @return The consistency.
*/
@java.lang.Override
public int getConsistency() {
return consistency_;
}
public static final int TIMEOUT_FIELD_NUMBER = 3;
private int timeout_ = 0;
/**
* <code>required uint32 timeout = 3;</code>
* @return Whether the timeout field is set.
*/
@java.lang.Override
public boolean hasTimeout() {
return ((bitField0_ & 0x00000004) != 0);
}
/**
* <code>required uint32 timeout = 3;</code>
* @return The timeout.
*/
@java.lang.Override
public int getTimeout() {
return timeout_;
}
public static final int REQUEST_FIELD_NUMBER = 4;
private akka.cluster.ddata.protobuf.msg.ReplicatorMessages.OtherMessage request_;
/**
* <code>optional .akka.cluster.ddata.OtherMessage request = 4;</code>
* @return Whether the request field is set.
*/
@java.lang.Override
public boolean hasRequest() {
return ((bitField0_ & 0x00000008) != 0);
}
/**
* <code>optional .akka.cluster.ddata.OtherMessage request = 4;</code>
* @return The request.
*/
@java.lang.Override
public akka.cluster.ddata.protobuf.msg.ReplicatorMessages.OtherMessage getRequest() {
return request_ == null ? akka.cluster.ddata.protobuf.msg.ReplicatorMessages.OtherMessage.getDefaultInstance() : request_;
}
/**
* <code>optional .akka.cluster.ddata.OtherMessage request = 4;</code>
*/
@java.lang.Override
public akka.cluster.ddata.protobuf.msg.ReplicatorMessages.OtherMessageOrBuilder getRequestOrBuilder() {
return request_ == null ? akka.cluster.ddata.protobuf.msg.ReplicatorMessages.OtherMessage.getDefaultInstance() : request_;
}
public static final int CONSISTENCYMINCAP_FIELD_NUMBER = 5;
private int consistencyMinCap_ = 0;
/**
* <code>optional int32 consistencyMinCap = 5;</code>
* @return Whether the consistencyMinCap field is set.
*/
@java.lang.Override
public boolean hasConsistencyMinCap() {
return ((bitField0_ & 0x00000010)
没有合适的资源?快使用搜索试试~ 我知道了~
Akka Actor模型开发库 v2.9.1.zip
共2000个文件
scala:834个
java:515个
md:426个
1.该资源内容由用户上传,如若侵权请联系客服进行举报
2.虚拟产品一经售出概不退款(资源遇到问题,请及时私信上传者)
2.虚拟产品一经售出概不退款(资源遇到问题,请及时私信上传者)
版权申诉
0 下载量 198 浏览量
2024-03-18
21:21:49
上传
评论
收藏 15.17MB ZIP 举报
温馨提示
Akka Actor模型开发库 v2.9.1.zip
资源推荐
资源详情
资源评论
收起资源包目录
Akka Actor模型开发库 v2.9.1.zip (2000个子文件)
29903-actor-testkit-typed-timer-support 191B
akka-cluster 7KB
reference.conf 36KB
reference.conf 23KB
reference.conf 14KB
reference.conf 5KB
reference.conf 4KB
reference.conf 4KB
reference.conf 1KB
reference.conf 1KB
application.conf 188B
mailbox-config-sample.conf 107B
application-test.conf 60B
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
.editorconfig 202B
28473-upgrade-ScalaTest-to-3-1-0.excludes 9KB
remove-classic-remoting.backwards.excludes 7KB
_existing.excludes 7KB
drop-persistent-fsm.excludes 6KB
2.5.9.backwards.excludes 3KB
2.5.4.backwards.excludes 2KB
drop-deprecated-since-2.5.excludes 2KB
stabilize-timestamp-offset.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
28331-timestamp-PersistentRepr.excludes 876B
issue-27300-appVersion.excludes 856B
pr-31817-EventEnvelope-filtered.excludes 778B
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
28629-writeInProgress-race.excludes 646B
tags-in-typed-envelope.excludes 619B
issue-27788-remove-auto-down.excludes 597B
issue-27994-inmem-journal.excludes 596B
down-when-quarantined.excludes 552B
28695-watch-flush.excludes 520B
product-iterator-type-signature-with-scala-2.13.7.excludes 518B
2.5.10.backwards.excludes 515B
2.5.7.backwards.excludes 513B
31673.ask-behaviortestkit.excludes 507B
issue-13654-no-class-manifests-for-cluster-serializer-step1.excludes 501B
_existing.excludes 485B
persistence-query-leveldb.excludes 483B
28294-add-ExtensionId-apply-get-overloads.excludes 465B
typed-behaviour-testkit.excludes 450B
bypassCircuitBreaker.excludes 446B
29687-java-TestProbe-awaitAssert-support-checked-exception.excludes 403B
28300-fix-2.6.0-mima.excludes 398B
excess-checking.excludes 393B
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
2.5.2.backwards.excludes 303B
29294-receptionist-inbox.excludes 300B
30446-deleteObject.excludes 300B
pr-29246-remove-prng-constans.excludes 295B
issue-30090-sbr-release-lease.excludes 287B
2.5.21.backwards.excludes 286B
issue-29828-resolve-cache.excludes 283B
issue-30135-flush-ack.backwards.excludes 282B
27338-ActorTestKit-system.excludes 275B
28294-add-ExtensionId-apply-get-overloads.excludes 267B
compile-on-scala-3.backwards.excludes 266B
simplified-reverse-logic-in-lease-majority.excludes 266B
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
rename-fishing-outcomes-continue-java.excludes 237B
2.5.12.backwards.excludes 224B
effectful-ask.excludes 223B
issue-31095-quarantine-harmless.excludes 217B
28331-timestamp-PersistentRepr.excludes 213B
共 2000 条
- 1
- 2
- 3
- 4
- 5
- 6
- 20
资源评论
芝麻粒儿
- 粉丝: 5w+
- 资源: 2万+
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功