{
private LivestreamServiceBlockingStub(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected LivestreamServiceBlockingStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new LivestreamServiceBlockingStub(channel, callOptions);
}
/**
*
*
*
* Creates a channel with the provided unique ID in the specified
* region.
*
*/
public com.google.longrunning.Operation createChannel(
com.google.cloud.video.livestream.v1.CreateChannelRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateChannelMethod(), getCallOptions(), request);
}
/**
*
*
*
* Returns a list of all channels in the specified region.
*
*/
public com.google.cloud.video.livestream.v1.ListChannelsResponse listChannels(
com.google.cloud.video.livestream.v1.ListChannelsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListChannelsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Returns the specified channel.
*
*/
public com.google.cloud.video.livestream.v1.Channel getChannel(
com.google.cloud.video.livestream.v1.GetChannelRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetChannelMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes the specified channel.
*
*/
public com.google.longrunning.Operation deleteChannel(
com.google.cloud.video.livestream.v1.DeleteChannelRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteChannelMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates the specified channel.
*
*/
public com.google.longrunning.Operation updateChannel(
com.google.cloud.video.livestream.v1.UpdateChannelRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateChannelMethod(), getCallOptions(), request);
}
/**
*
*
*
* Starts the specified channel. Part of the video pipeline will be created
* only when the StartChannel request is received by the server.
*
*/
public com.google.longrunning.Operation startChannel(
com.google.cloud.video.livestream.v1.StartChannelRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getStartChannelMethod(), getCallOptions(), request);
}
/**
*
*
*
* Stops the specified channel. Part of the video pipeline will be released
* when the StopChannel request is received by the server.
*
*/
public com.google.longrunning.Operation stopChannel(
com.google.cloud.video.livestream.v1.StopChannelRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getStopChannelMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates an input with the provided unique ID in the specified region.
*
*/
public com.google.longrunning.Operation createInput(
com.google.cloud.video.livestream.v1.CreateInputRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateInputMethod(), getCallOptions(), request);
}
/**
*
*
*
* Returns a list of all inputs in the specified region.
*
*/
public com.google.cloud.video.livestream.v1.ListInputsResponse listInputs(
com.google.cloud.video.livestream.v1.ListInputsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListInputsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Returns the specified input.
*
*/
public com.google.cloud.video.livestream.v1.Input getInput(
com.google.cloud.video.livestream.v1.GetInputRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetInputMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes the specified input.
*
*/
public com.google.longrunning.Operation deleteInput(
com.google.cloud.video.livestream.v1.DeleteInputRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteInputMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates the specified input.
*
*/
public com.google.longrunning.Operation updateInput(
com.google.cloud.video.livestream.v1.UpdateInputRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateInputMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates an event with the provided unique ID in the specified channel.
*
*/
public com.google.cloud.video.livestream.v1.Event createEvent(
com.google.cloud.video.livestream.v1.CreateEventRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateEventMethod(), getCallOptions(), request);
}
/**
*
*
*
* Returns a list of all events in the specified channel.
*
*/
public com.google.cloud.video.livestream.v1.ListEventsResponse listEvents(
com.google.cloud.video.livestream.v1.ListEventsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListEventsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Returns the specified event.
*
*/
public com.google.cloud.video.livestream.v1.Event getEvent(
com.google.cloud.video.livestream.v1.GetEventRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetEventMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes the specified event.
*
*/
public com.google.protobuf.Empty deleteEvent(
com.google.cloud.video.livestream.v1.DeleteEventRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteEventMethod(), getCallOptions(), request);
}
}
/**
* A stub to allow clients to do ListenableFuture-style rpc calls to service LivestreamService.
*
*
* Using Live Stream API, you can generate live streams in the various
* renditions and streaming formats. The streaming format include HTTP Live
* Streaming (HLS) and Dynamic Adaptive Streaming over HTTP (DASH). You can send
* a source stream in the various ways, including Real-Time Messaging
* Protocol (RTMP) and Secure Reliable Transport (SRT).
*
*/
public static final class LivestreamServiceFutureStub
extends io.grpc.stub.AbstractFutureStub {
private LivestreamServiceFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected LivestreamServiceFutureStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new LivestreamServiceFutureStub(channel, callOptions);
}
/**
*
*
*
* Creates a channel with the provided unique ID in the specified
* region.
*
*/
public com.google.common.util.concurrent.ListenableFuture
createChannel(com.google.cloud.video.livestream.v1.CreateChannelRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateChannelMethod(), getCallOptions()), request);
}
/**
*
*
*
* Returns a list of all channels in the specified region.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.video.livestream.v1.ListChannelsResponse>
listChannels(com.google.cloud.video.livestream.v1.ListChannelsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListChannelsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Returns the specified channel.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.video.livestream.v1.Channel>
getChannel(com.google.cloud.video.livestream.v1.GetChannelRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetChannelMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes the specified channel.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteChannel(com.google.cloud.video.livestream.v1.DeleteChannelRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteChannelMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates the specified channel.
*
*/
public com.google.common.util.concurrent.ListenableFuture
updateChannel(com.google.cloud.video.livestream.v1.UpdateChannelRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateChannelMethod(), getCallOptions()), request);
}
/**
*
*
*
* Starts the specified channel. Part of the video pipeline will be created
* only when the StartChannel request is received by the server.
*
*/
public com.google.common.util.concurrent.ListenableFuture
startChannel(com.google.cloud.video.livestream.v1.StartChannelRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getStartChannelMethod(), getCallOptions()), request);
}
/**
*
*
*
* Stops the specified channel. Part of the video pipeline will be released
* when the StopChannel request is received by the server.
*
*/
public com.google.common.util.concurrent.ListenableFuture
stopChannel(com.google.cloud.video.livestream.v1.StopChannelRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getStopChannelMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates an input with the provided unique ID in the specified region.
*
*/
public com.google.common.util.concurrent.ListenableFuture
createInput(com.google.cloud.video.livestream.v1.CreateInputRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateInputMethod(), getCallOptions()), request);
}
/**
*
*
*
* Returns a list of all inputs in the specified region.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.video.livestream.v1.ListInputsResponse>
listInputs(com.google.cloud.video.livestream.v1.ListInputsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListInputsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Returns the specified input.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.video.livestream.v1.Input>
getInput(com.google.cloud.video.livestream.v1.GetInputRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetInputMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes the specified input.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteInput(com.google.cloud.video.livestream.v1.DeleteInputRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteInputMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates the specified input.
*
*/
public com.google.common.util.concurrent.ListenableFuture
updateInput(com.google.cloud.video.livestream.v1.UpdateInputRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateInputMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates an event with the provided unique ID in the specified channel.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.video.livestream.v1.Event>
createEvent(com.google.cloud.video.livestream.v1.CreateEventRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateEventMethod(), getCallOptions()), request);
}
/**
*
*
*
* Returns a list of all events in the specified channel.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.video.livestream.v1.ListEventsResponse>
listEvents(com.google.cloud.video.livestream.v1.ListEventsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListEventsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Returns the specified event.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.video.livestream.v1.Event>
getEvent(com.google.cloud.video.livestream.v1.GetEventRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetEventMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes the specified event.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteEvent(com.google.cloud.video.livestream.v1.DeleteEventRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteEventMethod(), getCallOptions()), request);
}
}
private static final int METHODID_CREATE_CHANNEL = 0;
private static final int METHODID_LIST_CHANNELS = 1;
private static final int METHODID_GET_CHANNEL = 2;
private static final int METHODID_DELETE_CHANNEL = 3;
private static final int METHODID_UPDATE_CHANNEL = 4;
private static final int METHODID_START_CHANNEL = 5;
private static final int METHODID_STOP_CHANNEL = 6;
private static final int METHODID_CREATE_INPUT = 7;
private static final int METHODID_LIST_INPUTS = 8;
private static final int METHODID_GET_INPUT = 9;
private static final int METHODID_DELETE_INPUT = 10;
private static final int METHODID_UPDATE_INPUT = 11;
private static final int METHODID_CREATE_EVENT = 12;
private static final int METHODID_LIST_EVENTS = 13;
private static final int METHODID_GET_EVENT = 14;
private static final int METHODID_DELETE_EVENT = 15;
private static final class MethodHandlers
implements io.grpc.stub.ServerCalls.UnaryMethod,
io.grpc.stub.ServerCalls.ServerStreamingMethod,
io.grpc.stub.ServerCalls.ClientStreamingMethod,
io.grpc.stub.ServerCalls.BidiStreamingMethod {
private final AsyncService serviceImpl;
private final int methodId;
MethodHandlers(AsyncService serviceImpl, int methodId) {
this.serviceImpl = serviceImpl;
this.methodId = methodId;
}
@java.lang.Override
@java.lang.SuppressWarnings("unchecked")
public void invoke(Req request, io.grpc.stub.StreamObserver responseObserver) {
switch (methodId) {
case METHODID_CREATE_CHANNEL:
serviceImpl.createChannel(
(com.google.cloud.video.livestream.v1.CreateChannelRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_LIST_CHANNELS:
serviceImpl.listChannels(
(com.google.cloud.video.livestream.v1.ListChannelsRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.video.livestream.v1.ListChannelsResponse>)
responseObserver);
break;
case METHODID_GET_CHANNEL:
serviceImpl.getChannel(
(com.google.cloud.video.livestream.v1.GetChannelRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_DELETE_CHANNEL:
serviceImpl.deleteChannel(
(com.google.cloud.video.livestream.v1.DeleteChannelRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_UPDATE_CHANNEL:
serviceImpl.updateChannel(
(com.google.cloud.video.livestream.v1.UpdateChannelRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_START_CHANNEL:
serviceImpl.startChannel(
(com.google.cloud.video.livestream.v1.StartChannelRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_STOP_CHANNEL:
serviceImpl.stopChannel(
(com.google.cloud.video.livestream.v1.StopChannelRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_CREATE_INPUT:
serviceImpl.createInput(
(com.google.cloud.video.livestream.v1.CreateInputRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_LIST_INPUTS:
serviceImpl.listInputs(
(com.google.cloud.video.livestream.v1.ListInputsRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_GET_INPUT:
serviceImpl.getInput(
(com.google.cloud.video.livestream.v1.GetInputRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_DELETE_INPUT:
serviceImpl.deleteInput(
(com.google.cloud.video.livestream.v1.DeleteInputRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_UPDATE_INPUT:
serviceImpl.updateInput(
(com.google.cloud.video.livestream.v1.UpdateInputRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_CREATE_EVENT:
serviceImpl.createEvent(
(com.google.cloud.video.livestream.v1.CreateEventRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_LIST_EVENTS:
serviceImpl.listEvents(
(com.google.cloud.video.livestream.v1.ListEventsRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_GET_EVENT:
serviceImpl.getEvent(
(com.google.cloud.video.livestream.v1.GetEventRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_DELETE_EVENT:
serviceImpl.deleteEvent(
(com.google.cloud.video.livestream.v1.DeleteEventRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
default:
throw new AssertionError();
}
}
@java.lang.Override
@java.lang.SuppressWarnings("unchecked")
public io.grpc.stub.StreamObserver invoke(
io.grpc.stub.StreamObserver responseObserver) {
switch (methodId) {
default:
throw new AssertionError();
}
}
}
public static final io.grpc.ServerServiceDefinition bindService(AsyncService service) {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
.addMethod(
getCreateChannelMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.video.livestream.v1.CreateChannelRequest,
com.google.longrunning.Operation>(service, METHODID_CREATE_CHANNEL)))
.addMethod(
getListChannelsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.video.livestream.v1.ListChannelsRequest,
com.google.cloud.video.livestream.v1.ListChannelsResponse>(
service, METHODID_LIST_CHANNELS)))
.addMethod(
getGetChannelMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.video.livestream.v1.GetChannelRequest,
com.google.cloud.video.livestream.v1.Channel>(service, METHODID_GET_CHANNEL)))
.addMethod(
getDeleteChannelMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.video.livestream.v1.DeleteChannelRequest,
com.google.longrunning.Operation>(service, METHODID_DELETE_CHANNEL)))
.addMethod(
getUpdateChannelMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.video.livestream.v1.UpdateChannelRequest,
com.google.longrunning.Operation>(service, METHODID_UPDATE_CHANNEL)))
.addMethod(
getStartChannelMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.video.livestream.v1.StartChannelRequest,
com.google.longrunning.Operation>(service, METHODID_START_CHANNEL)))
.addMethod(
getStopChannelMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.video.livestream.v1.StopChannelRequest,
com.google.longrunning.Operation>(service, METHODID_STOP_CHANNEL)))
.addMethod(
getCreateInputMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.video.livestream.v1.CreateInputRequest,
com.google.longrunning.Operation>(service, METHODID_CREATE_INPUT)))
.addMethod(
getListInputsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.video.livestream.v1.ListInputsRequest,
com.google.cloud.video.livestream.v1.ListInputsResponse>(
service, METHODID_LIST_INPUTS)))
.addMethod(
getGetInputMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.video.livestream.v1.GetInputRequest,
com.google.cloud.video.livestream.v1.Input>(service, METHODID_GET_INPUT)))
.addMethod(
getDeleteInputMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.video.livestream.v1.DeleteInputRequest,
com.google.longrunning.Operation>(service, METHODID_DELETE_INPUT)))
.addMethod(
getUpdateInputMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.video.livestream.v1.UpdateInputRequest,
com.google.longrunning.Operation>(service, METHODID_UPDATE_INPUT)))
.addMethod(
getCreateEventMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.video.livestream.v1.CreateEventRequest,
com.google.cloud.video.livestream.v1.Event>(service, METHODID_CREATE_EVENT)))
.addMethod(
getListEventsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.video.livestream.v1.ListEventsRequest,
com.google.cloud.video.livestream.v1.ListEventsResponse>(
service, METHODID_LIST_EVENTS)))
.addMethod(
getGetEventMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.video.livestream.v1.GetEventRequest,
com.google.cloud.video.livestream.v1.Event>(service, METHODID_GET_EVENT)))
.addMethod(
getDeleteEventMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.video.livestream.v1.DeleteEventRequest,
com.google.protobuf.Empty>(service, METHODID_DELETE_EVENT)))
.build();
}
private abstract static class LivestreamServiceBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
io.grpc.protobuf.ProtoServiceDescriptorSupplier {
LivestreamServiceBaseDescriptorSupplier() {}
@java.lang.Override
public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
return com.google.cloud.video.livestream.v1.ServiceProto.getDescriptor();
}
@java.lang.Override
public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
return getFileDescriptor().findServiceByName("LivestreamService");
}
}
private static final class LivestreamServiceFileDescriptorSupplier
extends LivestreamServiceBaseDescriptorSupplier {
LivestreamServiceFileDescriptorSupplier() {}
}
private static final class LivestreamServiceMethodDescriptorSupplier
extends LivestreamServiceBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
private final String methodName;
LivestreamServiceMethodDescriptorSupplier(String methodName) {
this.methodName = methodName;
}
@java.lang.Override
public com.google.protobuf.Descriptors.MethodDescriptor getMethodDescriptor() {
return getServiceDescriptor().findMethodByName(methodName);
}
}
private static volatile io.grpc.ServiceDescriptor serviceDescriptor;
public static io.grpc.ServiceDescriptor getServiceDescriptor() {
io.grpc.ServiceDescriptor result = serviceDescriptor;
if (result == null) {
synchronized (LivestreamServiceGrpc.class) {
result = serviceDescriptor;
if (result == null) {
serviceDescriptor =
result =
io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
.setSchemaDescriptor(new LivestreamServiceFileDescriptorSupplier())
.addMethod(getCreateChannelMethod())
.addMethod(getListChannelsMethod())
.addMethod(getGetChannelMethod())
.addMethod(getDeleteChannelMethod())
.addMethod(getUpdateChannelMethod())
.addMethod(getStartChannelMethod())
.addMethod(getStopChannelMethod())
.addMethod(getCreateInputMethod())
.addMethod(getListInputsMethod())
.addMethod(getGetInputMethod())
.addMethod(getDeleteInputMethod())
.addMethod(getUpdateInputMethod())
.addMethod(getCreateEventMethod())
.addMethod(getListEventsMethod())
.addMethod(getGetEventMethod())
.addMethod(getDeleteEventMethod())
.build();
}
}
}
return result;
}
}