mirror of https://github.com/dapr/java-sdk.git
Fix : Typo in code comments (#1381)
* Fix Typo in Comments Signed-off-by: Deepak <sdeepaksharma15@gmail.com> * Update review comments Signed-off-by: Deepak <sdeepaksharma15@gmail.com> --------- Signed-off-by: Deepak <sdeepaksharma15@gmail.com> Co-authored-by: artur-ciocanu <artur.ciocanu@gmail.com>
This commit is contained in:
parent
e84d2c4e61
commit
c3592b446d
|
@ -23,7 +23,7 @@ import org.springframework.boot.autoconfigure.SpringBootApplication;
|
|||
public class DaprApplication {
|
||||
|
||||
/**
|
||||
* Starts Dapr's callback in a given port and specified protocal.
|
||||
* Starts Dapr's callback in a given port and specified protocol.
|
||||
*
|
||||
* @param port Port to listen to.
|
||||
* @param protocal select Http or gRPC to run.
|
||||
|
|
|
@ -42,7 +42,7 @@ class ActorProxyImpl implements ActorProxy, InvocationHandler {
|
|||
private final String actorType;
|
||||
|
||||
/**
|
||||
* Serializer/deserialzier to exchange message for Actors.
|
||||
* Serializer/deserializer to exchange message for Actors.
|
||||
*/
|
||||
private final DaprObjectSerializer serializer;
|
||||
|
||||
|
|
|
@ -55,7 +55,7 @@ public class ActorStateIT extends BaseIT {
|
|||
new ActorProxyBuilder(actorType, ActorProxy.class, deferClose(run.newActorClient()));
|
||||
ActorProxy proxy = proxyBuilder.build(actorId);
|
||||
|
||||
// wating for actor to be activated
|
||||
// waiting for actor to be activated
|
||||
Thread.sleep(5000);
|
||||
|
||||
// Validate conditional read works.
|
||||
|
|
|
@ -331,7 +331,7 @@ public abstract class AbstractStateClientIT extends BaseIT {
|
|||
|
||||
|
||||
response = daprClient.getState(STATE_STORE_NAME, new State<>(stateKey, (MyData) null, null), MyData.class);
|
||||
//retrive the data wihout any etag
|
||||
//retrieve the data without any etag
|
||||
myDataResponse = response.block();
|
||||
|
||||
//review that state value changes
|
||||
|
@ -509,7 +509,7 @@ public abstract class AbstractStateClientIT extends BaseIT {
|
|||
public void saveUpdateAndGetStateWithEtagAndStateOptionsFirstWrite() {
|
||||
final String stateKey = "keyToBeUpdatedWithEtagAndOptions";
|
||||
|
||||
//create option with concurrency with first writte and consistency of strong
|
||||
//create option with concurrency with first write and consistency of strong
|
||||
StateOptions stateOptions = new StateOptions(StateOptions.Consistency.STRONG,
|
||||
StateOptions.Concurrency.FIRST_WRITE);
|
||||
|
||||
|
@ -571,7 +571,7 @@ public abstract class AbstractStateClientIT extends BaseIT {
|
|||
public void saveUpdateAndGetStateWithEtagAndStateOptionsLastWrite() {
|
||||
final String stateKey = "keyToBeUpdatedWithEtagAndOptions";
|
||||
|
||||
//create option with concurrency with first writte and consistency of strong
|
||||
//create option with concurrency with first write and consistency of strong
|
||||
StateOptions stateOptions = new StateOptions(StateOptions.Consistency.STRONG, StateOptions.Concurrency.LAST_WRITE);
|
||||
|
||||
//create dapr client
|
||||
|
@ -599,7 +599,7 @@ public abstract class AbstractStateClientIT extends BaseIT {
|
|||
assertEquals("data in property A", myDataResponse.getValue().getPropertyA());
|
||||
assertEquals("data in property B", myDataResponse.getValue().getPropertyB());
|
||||
|
||||
//change data to be udpated
|
||||
//change data to be updated
|
||||
data.setPropertyA("data in property A2");
|
||||
data.setPropertyB("data in property B2");
|
||||
//create deferred action to update the action with options
|
||||
|
|
|
@ -156,7 +156,7 @@ public class DaprClientBuilder {
|
|||
}
|
||||
|
||||
/**
|
||||
* Creates an instance of the GPRC Client.
|
||||
* Creates an instance of the GRPC Client.
|
||||
*
|
||||
* @return the GRPC Client.
|
||||
* @throws java.lang.IllegalStateException if either host is missing or if port is missing or a negative number.
|
||||
|
|
|
@ -17,7 +17,7 @@ import java.util.Collections;
|
|||
import java.util.Map;
|
||||
|
||||
/**
|
||||
* This class reprent what a State is.
|
||||
* This class represents what a State is.
|
||||
*
|
||||
* @param <T> The type of the value of the sate
|
||||
*/
|
||||
|
|
|
@ -1365,7 +1365,7 @@ public class DaprClientGrpcTest {
|
|||
* you will not find the state.
|
||||
* <p>This test will execute the following flow:</p>
|
||||
* <ol>
|
||||
* <li>Exeucte client getState for Key=key1</li>
|
||||
* <li>Execute client getState for Key=key1</li>
|
||||
* <li>Block for result to the the state</li>
|
||||
* <li>Assert the Returned State is the expected to key1</li>
|
||||
* <li>Execute client getState for Key=key2</li>
|
||||
|
|
|
@ -7,7 +7,7 @@
|
|||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the sppecific language governing permissions and
|
||||
* See the License for the specific language governing permissions and
|
||||
limitations under the License.
|
||||
*/
|
||||
|
||||
|
|
|
@ -14,7 +14,7 @@ fi
|
|||
#
|
||||
# NOTE: the containerd config patch is not necessary with images from kind v0.27.0+
|
||||
# It may enable some older images to work similarly.
|
||||
# If you're only supporting newer relases, you can just use `kind create cluster` here.
|
||||
# If you're only supporting newer releases, you can just use `kind create cluster` here.
|
||||
#
|
||||
# See:
|
||||
# https://github.com/kubernetes-sigs/kind/issues/2875
|
||||
|
|
Loading…
Reference in New Issue