Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

update thrift #507

Merged
merged 1 commit into from
Feb 6, 2023
Merged

update thrift #507

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
109 changes: 107 additions & 2 deletions client/src/main/generated/GetStateResponse.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -32,6 +32,7 @@ public class GetStateResponse implements TBase, java.io.Serializable, Cloneable,
private static final TField LAST_LOG_ID_FIELD_DESC = new TField("last_log_id", TType.I64, (short)6);
private static final TField LAST_LOG_TERM_FIELD_DESC = new TField("last_log_term", TType.I64, (short)7);
private static final TField STATUS_FIELD_DESC = new TField("status", TType.I32, (short)8);
private static final TField PEERS_FIELD_DESC = new TField("peers", TType.LIST, (short)9);

/**
*
Expand All @@ -53,6 +54,7 @@ public class GetStateResponse implements TBase, java.io.Serializable, Cloneable,
* @see Status
*/
public Status status;
public List<byte[]> peers;
public static final int ERROR_CODE = 1;
public static final int ROLE = 2;
public static final int TERM = 3;
Expand All @@ -61,6 +63,7 @@ public class GetStateResponse implements TBase, java.io.Serializable, Cloneable,
public static final int LAST_LOG_ID = 6;
public static final int LAST_LOG_TERM = 7;
public static final int STATUS = 8;
public static final int PEERS = 9;

// isset id assignments
private static final int __TERM_ISSET_ID = 0;
Expand Down Expand Up @@ -90,6 +93,9 @@ public class GetStateResponse implements TBase, java.io.Serializable, Cloneable,
new FieldValueMetaData(TType.I64)));
tmpMetaDataMap.put(STATUS, new FieldMetaData("status", TFieldRequirementType.DEFAULT,
new FieldValueMetaData(TType.I32)));
tmpMetaDataMap.put(PEERS, new FieldMetaData("peers", TFieldRequirementType.DEFAULT,
new ListMetaData(TType.LIST,
new FieldValueMetaData(TType.STRING))));
metaDataMap = Collections.unmodifiableMap(tmpMetaDataMap);
}

Expand All @@ -108,7 +114,8 @@ public GetStateResponse(
long committed_log_id,
long last_log_id,
long last_log_term,
Status status) {
Status status,
List<byte[]> peers) {
this();
this.error_code = error_code;
this.role = role;
Expand All @@ -123,6 +130,7 @@ public GetStateResponse(
this.last_log_term = last_log_term;
setLast_log_termIsSet(true);
this.status = status;
this.peers = peers;
}

public static class Builder {
Expand All @@ -134,6 +142,7 @@ public static class Builder {
private long last_log_id;
private long last_log_term;
private Status status;
private List<byte[]> peers;

BitSet __optional_isset = new BitSet(5);

Expand Down Expand Up @@ -185,6 +194,11 @@ public Builder setStatus(final Status status) {
return this;
}

public Builder setPeers(final List<byte[]> peers) {
this.peers = peers;
return this;
}

public GetStateResponse build() {
GetStateResponse result = new GetStateResponse();
result.setError_code(this.error_code);
Expand All @@ -205,6 +219,7 @@ public GetStateResponse build() {
result.setLast_log_term(this.last_log_term);
}
result.setStatus(this.status);
result.setPeers(this.peers);
return result;
}
}
Expand Down Expand Up @@ -233,6 +248,9 @@ public GetStateResponse(GetStateResponse other) {
if (other.isSetStatus()) {
this.status = TBaseHelper.deepCopy(other.status);
}
if (other.isSetPeers()) {
this.peers = TBaseHelper.deepCopy(other.peers);
}
}

public GetStateResponse deepCopy() {
Expand Down Expand Up @@ -450,6 +468,31 @@ public void setStatusIsSet(boolean __value) {
}
}

public List<byte[]> getPeers() {
return this.peers;
}

public GetStateResponse setPeers(List<byte[]> peers) {
this.peers = peers;
return this;
}

public void unsetPeers() {
this.peers = null;
}

// Returns true if field peers is set (has been assigned a value) and false otherwise
public boolean isSetPeers() {
return this.peers != null;
}

public void setPeersIsSet(boolean __value) {
if (!__value) {
this.peers = null;
}
}

@SuppressWarnings("unchecked")
public void setFieldValue(int fieldID, Object __value) {
switch (fieldID) {
case ERROR_CODE:
Expand Down Expand Up @@ -516,6 +559,14 @@ public void setFieldValue(int fieldID, Object __value) {
}
break;

case PEERS:
if (__value == null) {
unsetPeers();
} else {
setPeers((List<byte[]>)__value);
}
break;

default:
throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
}
Expand Down Expand Up @@ -547,6 +598,9 @@ public Object getFieldValue(int fieldID) {
case STATUS:
return getStatus();

case PEERS:
return getPeers();

default:
throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
}
Expand Down Expand Up @@ -578,12 +632,14 @@ public boolean equals(Object _that) {

if (!TBaseHelper.equalsNobinary(this.isSetStatus(), that.isSetStatus(), this.status, that.status)) { return false; }

if (!TBaseHelper.equalsSlow(this.isSetPeers(), that.isSetPeers(), this.peers, that.peers)) { return false; }

return true;
}

@Override
public int hashCode() {
return Arrays.deepHashCode(new Object[] {error_code, role, term, is_leader, committed_log_id, last_log_id, last_log_term, status});
return Arrays.deepHashCode(new Object[] {error_code, role, term, is_leader, committed_log_id, last_log_id, last_log_term, status, peers});
}

@Override
Expand Down Expand Up @@ -662,6 +718,14 @@ public int compareTo(GetStateResponse other) {
if (lastComparison != 0) {
return lastComparison;
}
lastComparison = Boolean.valueOf(isSetPeers()).compareTo(other.isSetPeers());
if (lastComparison != 0) {
return lastComparison;
}
lastComparison = TBaseHelper.compareTo(peers, other.peers);
if (lastComparison != 0) {
return lastComparison;
}
return 0;
}

Expand Down Expand Up @@ -737,6 +801,25 @@ public void read(TProtocol iprot) throws TException {
TProtocolUtil.skip(iprot, __field.type);
}
break;
case PEERS:
if (__field.type == TType.LIST) {
{
TList _list8 = iprot.readListBegin();
this.peers = new ArrayList<byte[]>(Math.max(0, _list8.size));
for (int _i9 = 0;
(_list8.size < 0) ? iprot.peekList() : (_i9 < _list8.size);
++_i9)
{
byte[] _elem10;
_elem10 = iprot.readBinary();
this.peers.add(_elem10);
}
iprot.readListEnd();
}
} else {
TProtocolUtil.skip(iprot, __field.type);
}
break;
default:
TProtocolUtil.skip(iprot, __field.type);
break;
Expand Down Expand Up @@ -784,6 +867,17 @@ public void write(TProtocol oprot) throws TException {
oprot.writeI32(this.status == null ? 0 : this.status.getValue());
oprot.writeFieldEnd();
}
if (this.peers != null) {
oprot.writeFieldBegin(PEERS_FIELD_DESC);
{
oprot.writeListBegin(new TList(TType.STRING, this.peers.size()));
for (byte[] _iter11 : this.peers) {
oprot.writeBinary(_iter11);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
oprot.writeFieldStop();
oprot.writeStructEnd();
}
Expand Down Expand Up @@ -895,6 +989,17 @@ public String toString(int indent, boolean prettyPrint) {
}
}
first = false;
if (!first) sb.append("," + newLine);
sb.append(indentStr);
sb.append("peers");
sb.append(space);
sb.append(":").append(space);
if (this.getPeers() == null) {
sb.append("null");
} else {
sb.append(TBaseHelper.toString(this.getPeers(), indent + 1, prettyPrint));
}
first = false;
sb.append(newLine + TBaseHelper.reduceIndent(indentStr));
sb.append(")");
return sb.toString();
Expand Down
40 changes: 20 additions & 20 deletions client/src/main/generated/RaftexService.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -327,17 +327,17 @@ public AsyncClient(TProtocolFactory protocolFactory, TAsyncClientManager clientM
super(protocolFactory, clientManager, transport);
}

public void askForVote(AskForVoteRequest req, AsyncMethodCallback resultHandler16) throws TException {
public void askForVote(AskForVoteRequest req, AsyncMethodCallback resultHandler20) throws TException {
checkReady();
askForVote_call method_call = new askForVote_call(req, resultHandler16, this, ___protocolFactory, ___transport);
askForVote_call method_call = new askForVote_call(req, resultHandler20, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}

public static class askForVote_call extends TAsyncMethodCall {
private AskForVoteRequest req;
public askForVote_call(AskForVoteRequest req, AsyncMethodCallback resultHandler17, TAsyncClient client13, TProtocolFactory protocolFactory14, TNonblockingTransport transport15) throws TException {
super(client13, protocolFactory14, transport15, resultHandler17, false);
public askForVote_call(AskForVoteRequest req, AsyncMethodCallback resultHandler21, TAsyncClient client17, TProtocolFactory protocolFactory18, TNonblockingTransport transport19) throws TException {
super(client17, protocolFactory18, transport19, resultHandler21, false);
this.req = req;
}

Expand All @@ -359,17 +359,17 @@ public AskForVoteResponse getResult() throws TException {
}
}

public void appendLog(AppendLogRequest req, AsyncMethodCallback resultHandler21) throws TException {
public void appendLog(AppendLogRequest req, AsyncMethodCallback resultHandler25) throws TException {
checkReady();
appendLog_call method_call = new appendLog_call(req, resultHandler21, this, ___protocolFactory, ___transport);
appendLog_call method_call = new appendLog_call(req, resultHandler25, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}

public static class appendLog_call extends TAsyncMethodCall {
private AppendLogRequest req;
public appendLog_call(AppendLogRequest req, AsyncMethodCallback resultHandler22, TAsyncClient client18, TProtocolFactory protocolFactory19, TNonblockingTransport transport20) throws TException {
super(client18, protocolFactory19, transport20, resultHandler22, false);
public appendLog_call(AppendLogRequest req, AsyncMethodCallback resultHandler26, TAsyncClient client22, TProtocolFactory protocolFactory23, TNonblockingTransport transport24) throws TException {
super(client22, protocolFactory23, transport24, resultHandler26, false);
this.req = req;
}

Expand All @@ -391,17 +391,17 @@ public AppendLogResponse getResult() throws TException {
}
}

public void sendSnapshot(SendSnapshotRequest req, AsyncMethodCallback resultHandler26) throws TException {
public void sendSnapshot(SendSnapshotRequest req, AsyncMethodCallback resultHandler30) throws TException {
checkReady();
sendSnapshot_call method_call = new sendSnapshot_call(req, resultHandler26, this, ___protocolFactory, ___transport);
sendSnapshot_call method_call = new sendSnapshot_call(req, resultHandler30, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}

public static class sendSnapshot_call extends TAsyncMethodCall {
private SendSnapshotRequest req;
public sendSnapshot_call(SendSnapshotRequest req, AsyncMethodCallback resultHandler27, TAsyncClient client23, TProtocolFactory protocolFactory24, TNonblockingTransport transport25) throws TException {
super(client23, protocolFactory24, transport25, resultHandler27, false);
public sendSnapshot_call(SendSnapshotRequest req, AsyncMethodCallback resultHandler31, TAsyncClient client27, TProtocolFactory protocolFactory28, TNonblockingTransport transport29) throws TException {
super(client27, protocolFactory28, transport29, resultHandler31, false);
this.req = req;
}

Expand All @@ -423,17 +423,17 @@ public SendSnapshotResponse getResult() throws TException {
}
}

public void heartbeat(HeartbeatRequest req, AsyncMethodCallback resultHandler31) throws TException {
public void heartbeat(HeartbeatRequest req, AsyncMethodCallback resultHandler35) throws TException {
checkReady();
heartbeat_call method_call = new heartbeat_call(req, resultHandler31, this, ___protocolFactory, ___transport);
heartbeat_call method_call = new heartbeat_call(req, resultHandler35, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}

public static class heartbeat_call extends TAsyncMethodCall {
private HeartbeatRequest req;
public heartbeat_call(HeartbeatRequest req, AsyncMethodCallback resultHandler32, TAsyncClient client28, TProtocolFactory protocolFactory29, TNonblockingTransport transport30) throws TException {
super(client28, protocolFactory29, transport30, resultHandler32, false);
public heartbeat_call(HeartbeatRequest req, AsyncMethodCallback resultHandler36, TAsyncClient client32, TProtocolFactory protocolFactory33, TNonblockingTransport transport34) throws TException {
super(client32, protocolFactory33, transport34, resultHandler36, false);
this.req = req;
}

Expand All @@ -455,17 +455,17 @@ public HeartbeatResponse getResult() throws TException {
}
}

public void getState(GetStateRequest req, AsyncMethodCallback resultHandler36) throws TException {
public void getState(GetStateRequest req, AsyncMethodCallback resultHandler40) throws TException {
checkReady();
getState_call method_call = new getState_call(req, resultHandler36, this, ___protocolFactory, ___transport);
getState_call method_call = new getState_call(req, resultHandler40, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}

public static class getState_call extends TAsyncMethodCall {
private GetStateRequest req;
public getState_call(GetStateRequest req, AsyncMethodCallback resultHandler37, TAsyncClient client33, TProtocolFactory protocolFactory34, TNonblockingTransport transport35) throws TException {
super(client33, protocolFactory34, transport35, resultHandler37, false);
public getState_call(GetStateRequest req, AsyncMethodCallback resultHandler41, TAsyncClient client37, TProtocolFactory protocolFactory38, TNonblockingTransport transport39) throws TException {
super(client37, protocolFactory38, transport39, resultHandler41, false);
this.req = req;
}

Expand Down
Loading