docs

CMSgov · Jan 29, 2025 · 6654b3e · 6654b3e
1 parent 901c225
commit 6654b3e
Show file tree

Hide file tree

Showing 4 changed files with 12 additions and 12 deletions.
diff --git a/...d-pipeline/bfd-pipeline-rda-grpc/src/main/java/gov/cms/bfd/pipeline/rda/grpc/RdaSink.java b/...d-pipeline/bfd-pipeline-rda-grpc/src/main/java/gov/cms/bfd/pipeline/rda/grpc/RdaSink.java
@@ -193,9 +193,9 @@ Optional<TClaim> transformMessage(String apiVersion, TMessage message)
   int writeClaims(Collection<TClaim> objects) throws ProcessingException;
 
   /**
-   * test.
+   * Updates the available range of sequence numbers.
    *
-   * @param sequenceNumberRange test
+   * @param sequenceNumberRange Current range of sequence numbers.
    */
   void updateSequenceNumberRange(ClaimSequenceNumberRange sequenceNumberRange);
 

diff --git a/...d-pipeline-rda-grpc/src/main/java/gov/cms/bfd/pipeline/rda/grpc/server/MessageSource.java b/...d-pipeline-rda-grpc/src/main/java/gov/cms/bfd/pipeline/rda/grpc/server/MessageSource.java
@@ -40,9 +40,9 @@ public interface MessageSource<T> extends AutoCloseable {
   MessageSource<T> skipTo(long startingSequenceNumber) throws Exception;
 
   /**
-   * test.
+   * Returns the current range of sequence numbers.
    *
-   * @return test
+   * @return sequence number range
    */
   ClaimSequenceNumberRange getSequenceNumberRange();
 }
diff --git a/...da-grpc/src/main/java/gov/cms/bfd/pipeline/rda/grpc/sink/direct/AbstractClaimRdaSink.java b/...da-grpc/src/main/java/gov/cms/bfd/pipeline/rda/grpc/sink/direct/AbstractClaimRdaSink.java
@@ -540,10 +540,10 @@ static class Metrics {
     /** The number of insert statements executed. */
     private final DistributionSummary insertCount;
 
-    /** test. */
+    /** Maximum available sequence number. */
     private final AtomicLong maxSequenceNumber;
 
-    /** test. */
+    /** The value returned by the maxSequenceNumber gauge. */
     private final AtomicLong maxSequenceNumberValue;
 
     /**
@@ -588,9 +588,9 @@ void setLatestSequenceNumber(long value) {
     }
 
     /**
-     * test.
+     * Sets the {@link #maxSequenceNumber}.
      *
-     * @param value test
+     * @param value value to set
      */
     void setMaxSequenceNumber(long value) {
       maxSequenceNumberValue.set(value);

diff --git a/...ipeline-rda-grpc/src/main/java/gov/cms/bfd/pipeline/rda/grpc/source/GrpcStreamCaller.java b/...ipeline-rda-grpc/src/main/java/gov/cms/bfd/pipeline/rda/grpc/source/GrpcStreamCaller.java
@@ -64,11 +64,11 @@ public abstract GrpcResponseStream<TResponse> callService(
       throws Exception;
 
   /**
-   * test.
+   * Calls the service to get the sequence number range.
    *
-   * @param channel test
-   * @param callOptions test
-   * @return test
+   * @param channel an already open channel to the service being called
+   * @param callOptions the CallOptions object to use for the API call
+   * @return sequence number range
    */
   public abstract ClaimSequenceNumberRange callSequenceNumberRangeService(
       ManagedChannel channel, CallOptions callOptions);