Skip to content

Commit

Permalink
Merge pull request #85 from ml054/v6.0
Browse files Browse the repository at this point in the history
V6.0
  • Loading branch information
ml054 authored Jan 13, 2024
2 parents 492c2ce + 322cc32 commit f7b7a92
Show file tree
Hide file tree
Showing 4 changed files with 36 additions and 11 deletions.
5 changes: 3 additions & 2 deletions .github/workflows/RavenClient.yml
Original file line number Diff line number Diff line change
Expand Up @@ -27,12 +27,13 @@ jobs:
fail-fast: false

steps:
- uses: actions/checkout@v2
- uses: actions/checkout@v4

- name: Set up JDK ${{ matrix.java-version }}
uses: actions/setup-java@v1
uses: actions/setup-java@v4
with:
java-version: ${{ matrix.java-version }}
distribution: "zulu"

- name: Download RavenDB Server
run: wget -O RavenDB.tar.bz2 "https://hibernatingrhinos.com/downloads/RavenDB%20for%20Linux%20x64/latest?buildType=${{ env.RAVENDB_BUILD_TYPE }}&version=${{ matrix.serverVersion }}"
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,8 +16,8 @@ public class SubscriptionState {
private String nodeTag;
private Date lastBatchAckTime;
private Date lastClientConnectionTime;
private long raftCommandIndex;
private boolean disabled;
private Long raftCommandIndex;

private ArchivedDataProcessingBehavior archivedDataProcessingBehavior;
private SubscriptionShardingState shardingState;
Expand Down Expand Up @@ -78,14 +78,6 @@ public void setNodeTag(String nodeTag) {
this.nodeTag = nodeTag;
}

public Long getRaftCommandIndex() {
return raftCommandIndex;
}

public void setRaftCommandIndex(Long raftCommandIndex) {
this.raftCommandIndex = raftCommandIndex;
}

public Date getLastBatchAckTime() {
return lastBatchAckTime;
}
Expand All @@ -102,6 +94,14 @@ public void setLastClientConnectionTime(Date lastClientConnectionTime) {
this.lastClientConnectionTime = lastClientConnectionTime;
}

public long getRaftCommandIndex() {
return raftCommandIndex;
}

public void setRaftCommandIndex(long raftCommandIndex) {
this.raftCommandIndex = raftCommandIndex;
}

public boolean isDisabled() {
return disabled;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -63,6 +63,7 @@ public static class Parameters {
private Duration retentionTime;
private Long retentionSize;
private boolean compress;
private boolean persist;

public Parameters(GetLogsConfigurationResult getLogs) {
mode = getLogs.getMode();
Expand Down Expand Up @@ -105,5 +106,13 @@ public LogMode getMode() {
public void setMode(LogMode mode) {
this.mode = mode;
}

public boolean isPersist() {
return persist;
}

public void setPersist(boolean persist) {
this.persist = persist;
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -67,6 +67,7 @@ public static class Parameters {
private List<String> httpMethods;
private List<TrafficWatchChangeType> changeTypes;
private List<String> certificateThumbprints;
private boolean persist;

/**
* @return Traffic Watch logging mode.
Expand Down Expand Up @@ -193,5 +194,19 @@ public List<String> getCertificateThumbprints() {
public void setCertificateThumbprints(List<String> certificateThumbprints) {
this.certificateThumbprints = certificateThumbprints;
}

/**
* @return Indicates if the configuration should be persisted to the configuration file
*/
public boolean isPersist() {
return persist;
}

/**
* @param persist Indicates if the configuration should be persisted to the configuration file
*/
public void setPersist(boolean persist) {
this.persist = persist;
}
}
}

0 comments on commit f7b7a92

Please sign in to comment.