Introduce raft.spi.ByteArray 05/116105/8
authorRobert Varga <robert.varga@pantheon.tech>
Fri, 28 Mar 2025 10:10:14 +0000 (11:10 +0100)
committerRobert Varga <robert.varga@pantheon.tech>
Fri, 28 Mar 2025 14:51:17 +0000 (15:51 +0100)
commit8b15d9cbfc8937ca80a9a1e60dcf4ef0c88ee3e0
treefcf6abf0478f1e7a00e5fdb3b90d1e74578b2a55
parented1d4927bd4aeeec3f5e7af9ef8a15cb5312edb9
Introduce raft.spi.ByteArray

This patch replaces uses of ByteSource with InputStreamProvider, of
which ByteArray is a convenient implementation of. This eliminates the
need to use yangtools.concepts.Either, as we are expressing the two
options via class hierarchy.

JIRA: CONTROLLER-2134
Change-Id: I249f572fe8be0e64de796fdf7d48cbf2ba9b95c3
Signed-off-by: Robert Varga <robert.varga@pantheon.tech>
33 files changed:
features/odl-raft-spi/pom.xml
features/odl-raft-spi/src/main/feature/template.xml
opendaylight/md-sal/sal-akka-raft-example/src/main/java/org/opendaylight/controller/cluster/example/ExampleActor.java
opendaylight/md-sal/sal-clustering-commons/src/main/java/org/opendaylight/controller/cluster/persistence/LocalSnapshotStore.java
opendaylight/md-sal/sal-distributed-datastore/pom.xml
opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ShardSnapshotCohort.java
opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/persisted/CT.java
opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/persisted/CommitTransactionPayload.java
opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/actors/ShardSnapshotActorTest.java
raft/raft-spi/pom.xml
raft/raft-spi/src/main/java/module-info.java
raft/raft-spi/src/main/java/org/opendaylight/raft/spi/ByteArray.java [new file with mode: 0644]
raft/raft-spi/src/main/java/org/opendaylight/raft/spi/ChunkedByteArray.java
raft/raft-spi/src/main/java/org/opendaylight/raft/spi/ChunkedOutputStream.java
raft/raft-spi/src/main/java/org/opendaylight/raft/spi/InputOutputStreamFactory.java
raft/raft-spi/src/main/java/org/opendaylight/raft/spi/InputStreamProvider.java
raft/raft-spi/src/main/java/org/opendaylight/raft/spi/LZ4InputOutputStreamSupport.java
raft/raft-spi/src/main/java/org/opendaylight/raft/spi/PlainInputOutputStreamSupport.java
raft/raft-spi/src/main/java/org/opendaylight/raft/spi/WrappedByteArray.java [new file with mode: 0644]
raft/raft-spi/src/test/java/org/opendaylight/raft/spi/ChunkedOutputStreamTest.java
raft/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/NoopRaftActorSnapshotCohort.java
raft/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActorSnapshotCohort.java
raft/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/SnapshotManager.java
raft/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/behaviors/Follower.java
raft/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/behaviors/SnapshotTracker.java
raft/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/MigratedMessagesTest.java
raft/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/MockRaftActor.java
raft/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/MockRaftActorContext.java
raft/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/RaftActorServerConfigurationSupportTest.java
raft/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/RaftActorSnapshotMessageSupportTest.java
raft/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/RaftActorTest.java
raft/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/behaviors/FollowerTest.java
raft/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/behaviors/SnapshotTrackerTest.java