Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
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
2 changes: 1 addition & 1 deletion api_version.lock
Original file line number Diff line number Diff line change
@@ -1 +1 @@
v0.1.569
v0.1.576
6,914 changes: 5,663 additions & 1,251 deletions core/sdk/src/main/gen/com/viam/component/arm/v1/Arm.java

Large diffs are not rendered by default.

Original file line number Diff line number Diff line change
Expand Up @@ -165,6 +165,36 @@ com.viam.component.arm.v1.Arm.MoveThroughJointPositionsResponse> getMoveThroughJ
return getMoveThroughJointPositionsMethod;
}

private static volatile io.grpc.MethodDescriptor<com.viam.component.arm.v1.Arm.MoveThroughJointPositionsStreamedRequest,
com.viam.component.arm.v1.Arm.MoveThroughJointPositionsStreamedResponse> getMoveThroughJointPositionsStreamedMethod;

@io.grpc.stub.annotations.RpcMethod(
fullMethodName = SERVICE_NAME + '/' + "MoveThroughJointPositionsStreamed",
requestType = com.viam.component.arm.v1.Arm.MoveThroughJointPositionsStreamedRequest.class,
responseType = com.viam.component.arm.v1.Arm.MoveThroughJointPositionsStreamedResponse.class,
methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
public static io.grpc.MethodDescriptor<com.viam.component.arm.v1.Arm.MoveThroughJointPositionsStreamedRequest,
com.viam.component.arm.v1.Arm.MoveThroughJointPositionsStreamedResponse> getMoveThroughJointPositionsStreamedMethod() {
io.grpc.MethodDescriptor<com.viam.component.arm.v1.Arm.MoveThroughJointPositionsStreamedRequest, com.viam.component.arm.v1.Arm.MoveThroughJointPositionsStreamedResponse> getMoveThroughJointPositionsStreamedMethod;
if ((getMoveThroughJointPositionsStreamedMethod = ArmServiceGrpc.getMoveThroughJointPositionsStreamedMethod) == null) {
synchronized (ArmServiceGrpc.class) {
if ((getMoveThroughJointPositionsStreamedMethod = ArmServiceGrpc.getMoveThroughJointPositionsStreamedMethod) == null) {
ArmServiceGrpc.getMoveThroughJointPositionsStreamedMethod = getMoveThroughJointPositionsStreamedMethod =
io.grpc.MethodDescriptor.<com.viam.component.arm.v1.Arm.MoveThroughJointPositionsStreamedRequest, com.viam.component.arm.v1.Arm.MoveThroughJointPositionsStreamedResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
.setFullMethodName(generateFullMethodName(SERVICE_NAME, "MoveThroughJointPositionsStreamed"))
.setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
com.viam.component.arm.v1.Arm.MoveThroughJointPositionsStreamedRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
com.viam.component.arm.v1.Arm.MoveThroughJointPositionsStreamedResponse.getDefaultInstance()))
.build();
}
}
}
return getMoveThroughJointPositionsStreamedMethod;
}

private static volatile io.grpc.MethodDescriptor<com.viam.component.arm.v1.Arm.StopRequest,
com.viam.component.arm.v1.Arm.StopResponse> getStopMethod;

Expand Down Expand Up @@ -495,6 +525,13 @@ default void moveThroughJointPositions(com.viam.component.arm.v1.Arm.MoveThrough
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getMoveThroughJointPositionsMethod(), responseObserver);
}

/**
*/
default io.grpc.stub.StreamObserver<com.viam.component.arm.v1.Arm.MoveThroughJointPositionsStreamedRequest> moveThroughJointPositionsStreamed(
io.grpc.stub.StreamObserver<com.viam.component.arm.v1.Arm.MoveThroughJointPositionsStreamedResponse> responseObserver) {
return io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall(getMoveThroughJointPositionsStreamedMethod(), responseObserver);
}

/**
* <pre>
* Stop stops a robot's arm
Expand Down Expand Up @@ -658,6 +695,14 @@ public void moveThroughJointPositions(com.viam.component.arm.v1.Arm.MoveThroughJ
getChannel().newCall(getMoveThroughJointPositionsMethod(), getCallOptions()), request, responseObserver);
}

/**
*/
public io.grpc.stub.StreamObserver<com.viam.component.arm.v1.Arm.MoveThroughJointPositionsStreamedRequest> moveThroughJointPositionsStreamed(
io.grpc.stub.StreamObserver<com.viam.component.arm.v1.Arm.MoveThroughJointPositionsStreamedResponse> responseObserver) {
return io.grpc.stub.ClientCalls.asyncBidiStreamingCall(
getChannel().newCall(getMoveThroughJointPositionsStreamedMethod(), getCallOptions()), responseObserver);
}

/**
* <pre>
* Stop stops a robot's arm
Expand Down Expand Up @@ -809,6 +854,15 @@ public com.viam.component.arm.v1.Arm.MoveThroughJointPositionsResponse moveThrou
getChannel(), getMoveThroughJointPositionsMethod(), getCallOptions(), request);
}

/**
*/
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
public io.grpc.stub.BlockingClientCall<com.viam.component.arm.v1.Arm.MoveThroughJointPositionsStreamedRequest, com.viam.component.arm.v1.Arm.MoveThroughJointPositionsStreamedResponse>
moveThroughJointPositionsStreamed() {
return io.grpc.stub.ClientCalls.blockingBidiStreamingCall(
getChannel(), getMoveThroughJointPositionsStreamedMethod(), getCallOptions());
}

/**
* <pre>
* Stop stops a robot's arm
Expand Down Expand Up @@ -1192,6 +1246,7 @@ public com.google.common.util.concurrent.ListenableFuture<com.viam.common.v1.Com
private static final int METHODID_GET_KINEMATICS = 9;
private static final int METHODID_GET_GEOMETRIES = 10;
private static final int METHODID_GET3DMODELS = 11;
private static final int METHODID_MOVE_THROUGH_JOINT_POSITIONS_STREAMED = 12;

private static final class MethodHandlers<Req, Resp> implements
io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
Expand Down Expand Up @@ -1268,6 +1323,9 @@ public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserv
public io.grpc.stub.StreamObserver<Req> invoke(
io.grpc.stub.StreamObserver<Resp> responseObserver) {
switch (methodId) {
case METHODID_MOVE_THROUGH_JOINT_POSITIONS_STREAMED:
return (io.grpc.stub.StreamObserver<Req>) serviceImpl.moveThroughJointPositionsStreamed(
(io.grpc.stub.StreamObserver<com.viam.component.arm.v1.Arm.MoveThroughJointPositionsStreamedResponse>) responseObserver);
default:
throw new AssertionError();
}
Expand Down Expand Up @@ -1311,6 +1369,13 @@ public static final io.grpc.ServerServiceDefinition bindService(AsyncService ser
com.viam.component.arm.v1.Arm.MoveThroughJointPositionsRequest,
com.viam.component.arm.v1.Arm.MoveThroughJointPositionsResponse>(
service, METHODID_MOVE_THROUGH_JOINT_POSITIONS)))
.addMethod(
getMoveThroughJointPositionsStreamedMethod(),
io.grpc.stub.ServerCalls.asyncBidiStreamingCall(
new MethodHandlers<
com.viam.component.arm.v1.Arm.MoveThroughJointPositionsStreamedRequest,
com.viam.component.arm.v1.Arm.MoveThroughJointPositionsStreamedResponse>(
service, METHODID_MOVE_THROUGH_JOINT_POSITIONS_STREAMED)))
.addMethod(
getStopMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
Expand Down Expand Up @@ -1377,6 +1442,7 @@ public static io.grpc.ServiceDescriptor getServiceDescriptor() {
.addMethod(getGetJointPositionsMethod())
.addMethod(getMoveToJointPositionsMethod())
.addMethod(getMoveThroughJointPositionsMethod())
.addMethod(getMoveThroughJointPositionsStreamedMethod())
.addMethod(getStopMethod())
.addMethod(getIsMovingMethod())
.addMethod(getDoCommandMethod())
Expand Down
Loading
Loading