package context; import static io.grpc.MethodDescriptor.generateFullMethodName; /** */ @javax.annotation.Generated( value = "by gRPC proto compiler (version 1.38.1)", comments = "Source: context.proto") public final class ContextServiceGrpc { private ContextServiceGrpc() {} public static final String SERVICE_NAME = "context.ContextService"; // Static method descriptors that strictly reflect the proto. private static volatile io.grpc.MethodDescriptor getListContextIdsMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "ListContextIds", requestType = context.ContextOuterClass.Empty.class, responseType = context.ContextOuterClass.ContextIdList.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getListContextIdsMethod() { io.grpc.MethodDescriptor getListContextIdsMethod; if ((getListContextIdsMethod = ContextServiceGrpc.getListContextIdsMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getListContextIdsMethod = ContextServiceGrpc.getListContextIdsMethod) == null) { ContextServiceGrpc.getListContextIdsMethod = getListContextIdsMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListContextIds")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.Empty.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.ContextIdList.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("ListContextIds")) .build(); } } } return getListContextIdsMethod; } private static volatile io.grpc.MethodDescriptor getListContextsMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "ListContexts", requestType = context.ContextOuterClass.Empty.class, responseType = context.ContextOuterClass.ContextList.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getListContextsMethod() { io.grpc.MethodDescriptor getListContextsMethod; if ((getListContextsMethod = ContextServiceGrpc.getListContextsMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getListContextsMethod = ContextServiceGrpc.getListContextsMethod) == null) { ContextServiceGrpc.getListContextsMethod = getListContextsMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListContexts")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.Empty.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.ContextList.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("ListContexts")) .build(); } } } return getListContextsMethod; } private static volatile io.grpc.MethodDescriptor getGetContextMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "GetContext", requestType = context.ContextOuterClass.ContextId.class, responseType = context.ContextOuterClass.Context.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getGetContextMethod() { io.grpc.MethodDescriptor getGetContextMethod; if ((getGetContextMethod = ContextServiceGrpc.getGetContextMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getGetContextMethod = ContextServiceGrpc.getGetContextMethod) == null) { ContextServiceGrpc.getGetContextMethod = getGetContextMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetContext")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.ContextId.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.Context.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("GetContext")) .build(); } } } return getGetContextMethod; } private static volatile io.grpc.MethodDescriptor getSetContextMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "SetContext", requestType = context.ContextOuterClass.Context.class, responseType = context.ContextOuterClass.ContextId.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getSetContextMethod() { io.grpc.MethodDescriptor getSetContextMethod; if ((getSetContextMethod = ContextServiceGrpc.getSetContextMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getSetContextMethod = ContextServiceGrpc.getSetContextMethod) == null) { ContextServiceGrpc.getSetContextMethod = getSetContextMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "SetContext")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.Context.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.ContextId.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("SetContext")) .build(); } } } return getSetContextMethod; } private static volatile io.grpc.MethodDescriptor getRemoveContextMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "RemoveContext", requestType = context.ContextOuterClass.ContextId.class, responseType = context.ContextOuterClass.Empty.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getRemoveContextMethod() { io.grpc.MethodDescriptor getRemoveContextMethod; if ((getRemoveContextMethod = ContextServiceGrpc.getRemoveContextMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getRemoveContextMethod = ContextServiceGrpc.getRemoveContextMethod) == null) { ContextServiceGrpc.getRemoveContextMethod = getRemoveContextMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "RemoveContext")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.ContextId.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.Empty.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("RemoveContext")) .build(); } } } return getRemoveContextMethod; } private static volatile io.grpc.MethodDescriptor getGetContextEventsMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "GetContextEvents", requestType = context.ContextOuterClass.Empty.class, responseType = context.ContextOuterClass.ContextEvent.class, methodType = io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) public static io.grpc.MethodDescriptor getGetContextEventsMethod() { io.grpc.MethodDescriptor getGetContextEventsMethod; if ((getGetContextEventsMethod = ContextServiceGrpc.getGetContextEventsMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getGetContextEventsMethod = ContextServiceGrpc.getGetContextEventsMethod) == null) { ContextServiceGrpc.getGetContextEventsMethod = getGetContextEventsMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetContextEvents")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.Empty.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.ContextEvent.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("GetContextEvents")) .build(); } } } return getGetContextEventsMethod; } private static volatile io.grpc.MethodDescriptor getListTopologyIdsMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "ListTopologyIds", requestType = context.ContextOuterClass.ContextId.class, responseType = context.ContextOuterClass.TopologyIdList.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getListTopologyIdsMethod() { io.grpc.MethodDescriptor getListTopologyIdsMethod; if ((getListTopologyIdsMethod = ContextServiceGrpc.getListTopologyIdsMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getListTopologyIdsMethod = ContextServiceGrpc.getListTopologyIdsMethod) == null) { ContextServiceGrpc.getListTopologyIdsMethod = getListTopologyIdsMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListTopologyIds")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.ContextId.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.TopologyIdList.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("ListTopologyIds")) .build(); } } } return getListTopologyIdsMethod; } private static volatile io.grpc.MethodDescriptor getListTopologiesMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "ListTopologies", requestType = context.ContextOuterClass.ContextId.class, responseType = context.ContextOuterClass.TopologyList.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getListTopologiesMethod() { io.grpc.MethodDescriptor getListTopologiesMethod; if ((getListTopologiesMethod = ContextServiceGrpc.getListTopologiesMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getListTopologiesMethod = ContextServiceGrpc.getListTopologiesMethod) == null) { ContextServiceGrpc.getListTopologiesMethod = getListTopologiesMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListTopologies")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.ContextId.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.TopologyList.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("ListTopologies")) .build(); } } } return getListTopologiesMethod; } private static volatile io.grpc.MethodDescriptor getGetTopologyMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "GetTopology", requestType = context.ContextOuterClass.TopologyId.class, responseType = context.ContextOuterClass.Topology.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getGetTopologyMethod() { io.grpc.MethodDescriptor getGetTopologyMethod; if ((getGetTopologyMethod = ContextServiceGrpc.getGetTopologyMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getGetTopologyMethod = ContextServiceGrpc.getGetTopologyMethod) == null) { ContextServiceGrpc.getGetTopologyMethod = getGetTopologyMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetTopology")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.TopologyId.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.Topology.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("GetTopology")) .build(); } } } return getGetTopologyMethod; } private static volatile io.grpc.MethodDescriptor getSetTopologyMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "SetTopology", requestType = context.ContextOuterClass.Topology.class, responseType = context.ContextOuterClass.TopologyId.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getSetTopologyMethod() { io.grpc.MethodDescriptor getSetTopologyMethod; if ((getSetTopologyMethod = ContextServiceGrpc.getSetTopologyMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getSetTopologyMethod = ContextServiceGrpc.getSetTopologyMethod) == null) { ContextServiceGrpc.getSetTopologyMethod = getSetTopologyMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "SetTopology")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.Topology.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.TopologyId.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("SetTopology")) .build(); } } } return getSetTopologyMethod; } private static volatile io.grpc.MethodDescriptor getRemoveTopologyMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "RemoveTopology", requestType = context.ContextOuterClass.TopologyId.class, responseType = context.ContextOuterClass.Empty.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getRemoveTopologyMethod() { io.grpc.MethodDescriptor getRemoveTopologyMethod; if ((getRemoveTopologyMethod = ContextServiceGrpc.getRemoveTopologyMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getRemoveTopologyMethod = ContextServiceGrpc.getRemoveTopologyMethod) == null) { ContextServiceGrpc.getRemoveTopologyMethod = getRemoveTopologyMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "RemoveTopology")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.TopologyId.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.Empty.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("RemoveTopology")) .build(); } } } return getRemoveTopologyMethod; } private static volatile io.grpc.MethodDescriptor getGetTopologyEventsMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "GetTopologyEvents", requestType = context.ContextOuterClass.Empty.class, responseType = context.ContextOuterClass.TopologyEvent.class, methodType = io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) public static io.grpc.MethodDescriptor getGetTopologyEventsMethod() { io.grpc.MethodDescriptor getGetTopologyEventsMethod; if ((getGetTopologyEventsMethod = ContextServiceGrpc.getGetTopologyEventsMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getGetTopologyEventsMethod = ContextServiceGrpc.getGetTopologyEventsMethod) == null) { ContextServiceGrpc.getGetTopologyEventsMethod = getGetTopologyEventsMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetTopologyEvents")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.Empty.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.TopologyEvent.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("GetTopologyEvents")) .build(); } } } return getGetTopologyEventsMethod; } private static volatile io.grpc.MethodDescriptor getListDeviceIdsMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "ListDeviceIds", requestType = context.ContextOuterClass.Empty.class, responseType = context.ContextOuterClass.DeviceIdList.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getListDeviceIdsMethod() { io.grpc.MethodDescriptor getListDeviceIdsMethod; if ((getListDeviceIdsMethod = ContextServiceGrpc.getListDeviceIdsMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getListDeviceIdsMethod = ContextServiceGrpc.getListDeviceIdsMethod) == null) { ContextServiceGrpc.getListDeviceIdsMethod = getListDeviceIdsMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListDeviceIds")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.Empty.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.DeviceIdList.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("ListDeviceIds")) .build(); } } } return getListDeviceIdsMethod; } private static volatile io.grpc.MethodDescriptor getListDevicesMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "ListDevices", requestType = context.ContextOuterClass.Empty.class, responseType = context.ContextOuterClass.DeviceList.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getListDevicesMethod() { io.grpc.MethodDescriptor getListDevicesMethod; if ((getListDevicesMethod = ContextServiceGrpc.getListDevicesMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getListDevicesMethod = ContextServiceGrpc.getListDevicesMethod) == null) { ContextServiceGrpc.getListDevicesMethod = getListDevicesMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListDevices")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.Empty.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.DeviceList.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("ListDevices")) .build(); } } } return getListDevicesMethod; } private static volatile io.grpc.MethodDescriptor getGetDeviceMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "GetDevice", requestType = context.ContextOuterClass.DeviceId.class, responseType = context.ContextOuterClass.Device.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getGetDeviceMethod() { io.grpc.MethodDescriptor getGetDeviceMethod; if ((getGetDeviceMethod = ContextServiceGrpc.getGetDeviceMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getGetDeviceMethod = ContextServiceGrpc.getGetDeviceMethod) == null) { ContextServiceGrpc.getGetDeviceMethod = getGetDeviceMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetDevice")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.DeviceId.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.Device.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("GetDevice")) .build(); } } } return getGetDeviceMethod; } private static volatile io.grpc.MethodDescriptor getSetDeviceMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "SetDevice", requestType = context.ContextOuterClass.Device.class, responseType = context.ContextOuterClass.DeviceId.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getSetDeviceMethod() { io.grpc.MethodDescriptor getSetDeviceMethod; if ((getSetDeviceMethod = ContextServiceGrpc.getSetDeviceMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getSetDeviceMethod = ContextServiceGrpc.getSetDeviceMethod) == null) { ContextServiceGrpc.getSetDeviceMethod = getSetDeviceMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "SetDevice")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.Device.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.DeviceId.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("SetDevice")) .build(); } } } return getSetDeviceMethod; } private static volatile io.grpc.MethodDescriptor getRemoveDeviceMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "RemoveDevice", requestType = context.ContextOuterClass.DeviceId.class, responseType = context.ContextOuterClass.Empty.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getRemoveDeviceMethod() { io.grpc.MethodDescriptor getRemoveDeviceMethod; if ((getRemoveDeviceMethod = ContextServiceGrpc.getRemoveDeviceMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getRemoveDeviceMethod = ContextServiceGrpc.getRemoveDeviceMethod) == null) { ContextServiceGrpc.getRemoveDeviceMethod = getRemoveDeviceMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "RemoveDevice")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.DeviceId.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.Empty.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("RemoveDevice")) .build(); } } } return getRemoveDeviceMethod; } private static volatile io.grpc.MethodDescriptor getGetDeviceEventsMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "GetDeviceEvents", requestType = context.ContextOuterClass.Empty.class, responseType = context.ContextOuterClass.DeviceEvent.class, methodType = io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) public static io.grpc.MethodDescriptor getGetDeviceEventsMethod() { io.grpc.MethodDescriptor getGetDeviceEventsMethod; if ((getGetDeviceEventsMethod = ContextServiceGrpc.getGetDeviceEventsMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getGetDeviceEventsMethod = ContextServiceGrpc.getGetDeviceEventsMethod) == null) { ContextServiceGrpc.getGetDeviceEventsMethod = getGetDeviceEventsMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetDeviceEvents")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.Empty.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.DeviceEvent.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("GetDeviceEvents")) .build(); } } } return getGetDeviceEventsMethod; } private static volatile io.grpc.MethodDescriptor getListLinkIdsMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "ListLinkIds", requestType = context.ContextOuterClass.Empty.class, responseType = context.ContextOuterClass.LinkIdList.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getListLinkIdsMethod() { io.grpc.MethodDescriptor getListLinkIdsMethod; if ((getListLinkIdsMethod = ContextServiceGrpc.getListLinkIdsMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getListLinkIdsMethod = ContextServiceGrpc.getListLinkIdsMethod) == null) { ContextServiceGrpc.getListLinkIdsMethod = getListLinkIdsMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListLinkIds")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.Empty.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.LinkIdList.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("ListLinkIds")) .build(); } } } return getListLinkIdsMethod; } private static volatile io.grpc.MethodDescriptor getListLinksMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "ListLinks", requestType = context.ContextOuterClass.Empty.class, responseType = context.ContextOuterClass.LinkList.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getListLinksMethod() { io.grpc.MethodDescriptor getListLinksMethod; if ((getListLinksMethod = ContextServiceGrpc.getListLinksMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getListLinksMethod = ContextServiceGrpc.getListLinksMethod) == null) { ContextServiceGrpc.getListLinksMethod = getListLinksMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListLinks")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.Empty.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.LinkList.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("ListLinks")) .build(); } } } return getListLinksMethod; } private static volatile io.grpc.MethodDescriptor getGetLinkMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "GetLink", requestType = context.ContextOuterClass.LinkId.class, responseType = context.ContextOuterClass.Link.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getGetLinkMethod() { io.grpc.MethodDescriptor getGetLinkMethod; if ((getGetLinkMethod = ContextServiceGrpc.getGetLinkMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getGetLinkMethod = ContextServiceGrpc.getGetLinkMethod) == null) { ContextServiceGrpc.getGetLinkMethod = getGetLinkMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetLink")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.LinkId.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.Link.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("GetLink")) .build(); } } } return getGetLinkMethod; } private static volatile io.grpc.MethodDescriptor getSetLinkMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "SetLink", requestType = context.ContextOuterClass.Link.class, responseType = context.ContextOuterClass.LinkId.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getSetLinkMethod() { io.grpc.MethodDescriptor getSetLinkMethod; if ((getSetLinkMethod = ContextServiceGrpc.getSetLinkMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getSetLinkMethod = ContextServiceGrpc.getSetLinkMethod) == null) { ContextServiceGrpc.getSetLinkMethod = getSetLinkMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "SetLink")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.Link.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.LinkId.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("SetLink")) .build(); } } } return getSetLinkMethod; } private static volatile io.grpc.MethodDescriptor getRemoveLinkMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "RemoveLink", requestType = context.ContextOuterClass.LinkId.class, responseType = context.ContextOuterClass.Empty.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getRemoveLinkMethod() { io.grpc.MethodDescriptor getRemoveLinkMethod; if ((getRemoveLinkMethod = ContextServiceGrpc.getRemoveLinkMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getRemoveLinkMethod = ContextServiceGrpc.getRemoveLinkMethod) == null) { ContextServiceGrpc.getRemoveLinkMethod = getRemoveLinkMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "RemoveLink")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.LinkId.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.Empty.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("RemoveLink")) .build(); } } } return getRemoveLinkMethod; } private static volatile io.grpc.MethodDescriptor getGetLinkEventsMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "GetLinkEvents", requestType = context.ContextOuterClass.Empty.class, responseType = context.ContextOuterClass.LinkEvent.class, methodType = io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) public static io.grpc.MethodDescriptor getGetLinkEventsMethod() { io.grpc.MethodDescriptor getGetLinkEventsMethod; if ((getGetLinkEventsMethod = ContextServiceGrpc.getGetLinkEventsMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getGetLinkEventsMethod = ContextServiceGrpc.getGetLinkEventsMethod) == null) { ContextServiceGrpc.getGetLinkEventsMethod = getGetLinkEventsMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetLinkEvents")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.Empty.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.LinkEvent.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("GetLinkEvents")) .build(); } } } return getGetLinkEventsMethod; } private static volatile io.grpc.MethodDescriptor getListServiceIdsMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "ListServiceIds", requestType = context.ContextOuterClass.ContextId.class, responseType = context.ContextOuterClass.ServiceIdList.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getListServiceIdsMethod() { io.grpc.MethodDescriptor getListServiceIdsMethod; if ((getListServiceIdsMethod = ContextServiceGrpc.getListServiceIdsMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getListServiceIdsMethod = ContextServiceGrpc.getListServiceIdsMethod) == null) { ContextServiceGrpc.getListServiceIdsMethod = getListServiceIdsMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListServiceIds")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.ContextId.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.ServiceIdList.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("ListServiceIds")) .build(); } } } return getListServiceIdsMethod; } private static volatile io.grpc.MethodDescriptor getListServicesMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "ListServices", requestType = context.ContextOuterClass.ContextId.class, responseType = context.ContextOuterClass.ServiceList.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getListServicesMethod() { io.grpc.MethodDescriptor getListServicesMethod; if ((getListServicesMethod = ContextServiceGrpc.getListServicesMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getListServicesMethod = ContextServiceGrpc.getListServicesMethod) == null) { ContextServiceGrpc.getListServicesMethod = getListServicesMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListServices")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.ContextId.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.ServiceList.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("ListServices")) .build(); } } } return getListServicesMethod; } private static volatile io.grpc.MethodDescriptor getGetServiceMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "GetService", requestType = context.ContextOuterClass.ServiceId.class, responseType = context.ContextOuterClass.Service.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getGetServiceMethod() { io.grpc.MethodDescriptor getGetServiceMethod; if ((getGetServiceMethod = ContextServiceGrpc.getGetServiceMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getGetServiceMethod = ContextServiceGrpc.getGetServiceMethod) == null) { ContextServiceGrpc.getGetServiceMethod = getGetServiceMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetService")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.ServiceId.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.Service.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("GetService")) .build(); } } } return getGetServiceMethod; } private static volatile io.grpc.MethodDescriptor getSetServiceMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "SetService", requestType = context.ContextOuterClass.Service.class, responseType = context.ContextOuterClass.ServiceId.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getSetServiceMethod() { io.grpc.MethodDescriptor getSetServiceMethod; if ((getSetServiceMethod = ContextServiceGrpc.getSetServiceMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getSetServiceMethod = ContextServiceGrpc.getSetServiceMethod) == null) { ContextServiceGrpc.getSetServiceMethod = getSetServiceMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "SetService")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.Service.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.ServiceId.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("SetService")) .build(); } } } return getSetServiceMethod; } private static volatile io.grpc.MethodDescriptor getRemoveServiceMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "RemoveService", requestType = context.ContextOuterClass.ServiceId.class, responseType = context.ContextOuterClass.Empty.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getRemoveServiceMethod() { io.grpc.MethodDescriptor getRemoveServiceMethod; if ((getRemoveServiceMethod = ContextServiceGrpc.getRemoveServiceMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getRemoveServiceMethod = ContextServiceGrpc.getRemoveServiceMethod) == null) { ContextServiceGrpc.getRemoveServiceMethod = getRemoveServiceMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "RemoveService")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.ServiceId.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.Empty.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("RemoveService")) .build(); } } } return getRemoveServiceMethod; } private static volatile io.grpc.MethodDescriptor getGetServiceEventsMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "GetServiceEvents", requestType = context.ContextOuterClass.Empty.class, responseType = context.ContextOuterClass.ServiceEvent.class, methodType = io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) public static io.grpc.MethodDescriptor getGetServiceEventsMethod() { io.grpc.MethodDescriptor getGetServiceEventsMethod; if ((getGetServiceEventsMethod = ContextServiceGrpc.getGetServiceEventsMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getGetServiceEventsMethod = ContextServiceGrpc.getGetServiceEventsMethod) == null) { ContextServiceGrpc.getGetServiceEventsMethod = getGetServiceEventsMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetServiceEvents")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.Empty.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.ServiceEvent.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("GetServiceEvents")) .build(); } } } return getGetServiceEventsMethod; } private static volatile io.grpc.MethodDescriptor getListSliceIdsMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "ListSliceIds", requestType = context.ContextOuterClass.ContextId.class, responseType = context.ContextOuterClass.SliceIdList.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getListSliceIdsMethod() { io.grpc.MethodDescriptor getListSliceIdsMethod; if ((getListSliceIdsMethod = ContextServiceGrpc.getListSliceIdsMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getListSliceIdsMethod = ContextServiceGrpc.getListSliceIdsMethod) == null) { ContextServiceGrpc.getListSliceIdsMethod = getListSliceIdsMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListSliceIds")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.ContextId.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.SliceIdList.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("ListSliceIds")) .build(); } } } return getListSliceIdsMethod; } private static volatile io.grpc.MethodDescriptor getListSlicesMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "ListSlices", requestType = context.ContextOuterClass.ContextId.class, responseType = context.ContextOuterClass.SliceList.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getListSlicesMethod() { io.grpc.MethodDescriptor getListSlicesMethod; if ((getListSlicesMethod = ContextServiceGrpc.getListSlicesMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getListSlicesMethod = ContextServiceGrpc.getListSlicesMethod) == null) { ContextServiceGrpc.getListSlicesMethod = getListSlicesMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListSlices")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.ContextId.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.SliceList.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("ListSlices")) .build(); } } } return getListSlicesMethod; } private static volatile io.grpc.MethodDescriptor getGetSliceMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "GetSlice", requestType = context.ContextOuterClass.SliceId.class, responseType = context.ContextOuterClass.Slice.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getGetSliceMethod() { io.grpc.MethodDescriptor getGetSliceMethod; if ((getGetSliceMethod = ContextServiceGrpc.getGetSliceMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getGetSliceMethod = ContextServiceGrpc.getGetSliceMethod) == null) { ContextServiceGrpc.getGetSliceMethod = getGetSliceMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetSlice")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.SliceId.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.Slice.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("GetSlice")) .build(); } } } return getGetSliceMethod; } private static volatile io.grpc.MethodDescriptor getSetSliceMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "SetSlice", requestType = context.ContextOuterClass.Slice.class, responseType = context.ContextOuterClass.SliceId.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getSetSliceMethod() { io.grpc.MethodDescriptor getSetSliceMethod; if ((getSetSliceMethod = ContextServiceGrpc.getSetSliceMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getSetSliceMethod = ContextServiceGrpc.getSetSliceMethod) == null) { ContextServiceGrpc.getSetSliceMethod = getSetSliceMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "SetSlice")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.Slice.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.SliceId.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("SetSlice")) .build(); } } } return getSetSliceMethod; } private static volatile io.grpc.MethodDescriptor getRemoveSliceMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "RemoveSlice", requestType = context.ContextOuterClass.SliceId.class, responseType = context.ContextOuterClass.Empty.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getRemoveSliceMethod() { io.grpc.MethodDescriptor getRemoveSliceMethod; if ((getRemoveSliceMethod = ContextServiceGrpc.getRemoveSliceMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getRemoveSliceMethod = ContextServiceGrpc.getRemoveSliceMethod) == null) { ContextServiceGrpc.getRemoveSliceMethod = getRemoveSliceMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "RemoveSlice")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.SliceId.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.Empty.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("RemoveSlice")) .build(); } } } return getRemoveSliceMethod; } private static volatile io.grpc.MethodDescriptor getGetSliceEventsMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "GetSliceEvents", requestType = context.ContextOuterClass.Empty.class, responseType = context.ContextOuterClass.SliceEvent.class, methodType = io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) public static io.grpc.MethodDescriptor getGetSliceEventsMethod() { io.grpc.MethodDescriptor getGetSliceEventsMethod; if ((getGetSliceEventsMethod = ContextServiceGrpc.getGetSliceEventsMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getGetSliceEventsMethod = ContextServiceGrpc.getGetSliceEventsMethod) == null) { ContextServiceGrpc.getGetSliceEventsMethod = getGetSliceEventsMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetSliceEvents")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.Empty.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.SliceEvent.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("GetSliceEvents")) .build(); } } } return getGetSliceEventsMethod; } private static volatile io.grpc.MethodDescriptor getListConnectionIdsMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "ListConnectionIds", requestType = context.ContextOuterClass.ServiceId.class, responseType = context.ContextOuterClass.ConnectionIdList.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getListConnectionIdsMethod() { io.grpc.MethodDescriptor getListConnectionIdsMethod; if ((getListConnectionIdsMethod = ContextServiceGrpc.getListConnectionIdsMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getListConnectionIdsMethod = ContextServiceGrpc.getListConnectionIdsMethod) == null) { ContextServiceGrpc.getListConnectionIdsMethod = getListConnectionIdsMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListConnectionIds")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.ServiceId.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.ConnectionIdList.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("ListConnectionIds")) .build(); } } } return getListConnectionIdsMethod; } private static volatile io.grpc.MethodDescriptor getListConnectionsMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "ListConnections", requestType = context.ContextOuterClass.ServiceId.class, responseType = context.ContextOuterClass.ConnectionList.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getListConnectionsMethod() { io.grpc.MethodDescriptor getListConnectionsMethod; if ((getListConnectionsMethod = ContextServiceGrpc.getListConnectionsMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getListConnectionsMethod = ContextServiceGrpc.getListConnectionsMethod) == null) { ContextServiceGrpc.getListConnectionsMethod = getListConnectionsMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListConnections")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.ServiceId.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.ConnectionList.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("ListConnections")) .build(); } } } return getListConnectionsMethod; } private static volatile io.grpc.MethodDescriptor getGetConnectionMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "GetConnection", requestType = context.ContextOuterClass.ConnectionId.class, responseType = context.ContextOuterClass.Connection.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getGetConnectionMethod() { io.grpc.MethodDescriptor getGetConnectionMethod; if ((getGetConnectionMethod = ContextServiceGrpc.getGetConnectionMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getGetConnectionMethod = ContextServiceGrpc.getGetConnectionMethod) == null) { ContextServiceGrpc.getGetConnectionMethod = getGetConnectionMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetConnection")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.ConnectionId.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.Connection.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("GetConnection")) .build(); } } } return getGetConnectionMethod; } private static volatile io.grpc.MethodDescriptor getSetConnectionMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "SetConnection", requestType = context.ContextOuterClass.Connection.class, responseType = context.ContextOuterClass.ConnectionId.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getSetConnectionMethod() { io.grpc.MethodDescriptor getSetConnectionMethod; if ((getSetConnectionMethod = ContextServiceGrpc.getSetConnectionMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getSetConnectionMethod = ContextServiceGrpc.getSetConnectionMethod) == null) { ContextServiceGrpc.getSetConnectionMethod = getSetConnectionMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "SetConnection")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.Connection.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.ConnectionId.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("SetConnection")) .build(); } } } return getSetConnectionMethod; } private static volatile io.grpc.MethodDescriptor getRemoveConnectionMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "RemoveConnection", requestType = context.ContextOuterClass.ConnectionId.class, responseType = context.ContextOuterClass.Empty.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) public static io.grpc.MethodDescriptor getRemoveConnectionMethod() { io.grpc.MethodDescriptor getRemoveConnectionMethod; if ((getRemoveConnectionMethod = ContextServiceGrpc.getRemoveConnectionMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getRemoveConnectionMethod = ContextServiceGrpc.getRemoveConnectionMethod) == null) { ContextServiceGrpc.getRemoveConnectionMethod = getRemoveConnectionMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "RemoveConnection")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.ConnectionId.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.Empty.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("RemoveConnection")) .build(); } } } return getRemoveConnectionMethod; } private static volatile io.grpc.MethodDescriptor getGetConnectionEventsMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "GetConnectionEvents", requestType = context.ContextOuterClass.Empty.class, responseType = context.ContextOuterClass.ConnectionEvent.class, methodType = io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) public static io.grpc.MethodDescriptor getGetConnectionEventsMethod() { io.grpc.MethodDescriptor getGetConnectionEventsMethod; if ((getGetConnectionEventsMethod = ContextServiceGrpc.getGetConnectionEventsMethod) == null) { synchronized (ContextServiceGrpc.class) { if ((getGetConnectionEventsMethod = ContextServiceGrpc.getGetConnectionEventsMethod) == null) { ContextServiceGrpc.getGetConnectionEventsMethod = getGetConnectionEventsMethod = io.grpc.MethodDescriptor.newBuilder() .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetConnectionEvents")) .setSampledToLocalTracing(true) .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.Empty.getDefaultInstance())) .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( context.ContextOuterClass.ConnectionEvent.getDefaultInstance())) .setSchemaDescriptor(new ContextServiceMethodDescriptorSupplier("GetConnectionEvents")) .build(); } } } return getGetConnectionEventsMethod; } /** * Creates a new async stub that supports all call types for the service */ public static ContextServiceStub newStub(io.grpc.Channel channel) { io.grpc.stub.AbstractStub.StubFactory factory = new io.grpc.stub.AbstractStub.StubFactory() { @java.lang.Override public ContextServiceStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { return new ContextServiceStub(channel, callOptions); } }; return ContextServiceStub.newStub(factory, channel); } /** * Creates a new blocking-style stub that supports unary and streaming output calls on the service */ public static ContextServiceBlockingStub newBlockingStub( io.grpc.Channel channel) { io.grpc.stub.AbstractStub.StubFactory factory = new io.grpc.stub.AbstractStub.StubFactory() { @java.lang.Override public ContextServiceBlockingStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { return new ContextServiceBlockingStub(channel, callOptions); } }; return ContextServiceBlockingStub.newStub(factory, channel); } /** * Creates a new ListenableFuture-style stub that supports unary calls on the service */ public static ContextServiceFutureStub newFutureStub( io.grpc.Channel channel) { io.grpc.stub.AbstractStub.StubFactory factory = new io.grpc.stub.AbstractStub.StubFactory() { @java.lang.Override public ContextServiceFutureStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { return new ContextServiceFutureStub(channel, callOptions); } }; return ContextServiceFutureStub.newStub(factory, channel); } /** */ public static abstract class ContextServiceImplBase implements io.grpc.BindableService { /** */ public void listContextIds(context.ContextOuterClass.Empty request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getListContextIdsMethod(), responseObserver); } /** */ public void listContexts(context.ContextOuterClass.Empty request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getListContextsMethod(), responseObserver); } /** */ public void getContext(context.ContextOuterClass.ContextId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetContextMethod(), responseObserver); } /** */ public void setContext(context.ContextOuterClass.Context request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getSetContextMethod(), responseObserver); } /** */ public void removeContext(context.ContextOuterClass.ContextId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getRemoveContextMethod(), responseObserver); } /** */ public void getContextEvents(context.ContextOuterClass.Empty request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetContextEventsMethod(), responseObserver); } /** */ public void listTopologyIds(context.ContextOuterClass.ContextId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getListTopologyIdsMethod(), responseObserver); } /** */ public void listTopologies(context.ContextOuterClass.ContextId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getListTopologiesMethod(), responseObserver); } /** */ public void getTopology(context.ContextOuterClass.TopologyId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetTopologyMethod(), responseObserver); } /** */ public void setTopology(context.ContextOuterClass.Topology request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getSetTopologyMethod(), responseObserver); } /** */ public void removeTopology(context.ContextOuterClass.TopologyId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getRemoveTopologyMethod(), responseObserver); } /** */ public void getTopologyEvents(context.ContextOuterClass.Empty request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetTopologyEventsMethod(), responseObserver); } /** */ public void listDeviceIds(context.ContextOuterClass.Empty request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getListDeviceIdsMethod(), responseObserver); } /** */ public void listDevices(context.ContextOuterClass.Empty request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getListDevicesMethod(), responseObserver); } /** */ public void getDevice(context.ContextOuterClass.DeviceId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetDeviceMethod(), responseObserver); } /** */ public void setDevice(context.ContextOuterClass.Device request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getSetDeviceMethod(), responseObserver); } /** */ public void removeDevice(context.ContextOuterClass.DeviceId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getRemoveDeviceMethod(), responseObserver); } /** */ public void getDeviceEvents(context.ContextOuterClass.Empty request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetDeviceEventsMethod(), responseObserver); } /** */ public void listLinkIds(context.ContextOuterClass.Empty request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getListLinkIdsMethod(), responseObserver); } /** */ public void listLinks(context.ContextOuterClass.Empty request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getListLinksMethod(), responseObserver); } /** */ public void getLink(context.ContextOuterClass.LinkId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetLinkMethod(), responseObserver); } /** */ public void setLink(context.ContextOuterClass.Link request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getSetLinkMethod(), responseObserver); } /** */ public void removeLink(context.ContextOuterClass.LinkId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getRemoveLinkMethod(), responseObserver); } /** */ public void getLinkEvents(context.ContextOuterClass.Empty request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetLinkEventsMethod(), responseObserver); } /** */ public void listServiceIds(context.ContextOuterClass.ContextId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getListServiceIdsMethod(), responseObserver); } /** */ public void listServices(context.ContextOuterClass.ContextId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getListServicesMethod(), responseObserver); } /** */ public void getService(context.ContextOuterClass.ServiceId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetServiceMethod(), responseObserver); } /** */ public void setService(context.ContextOuterClass.Service request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getSetServiceMethod(), responseObserver); } /** */ public void removeService(context.ContextOuterClass.ServiceId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getRemoveServiceMethod(), responseObserver); } /** */ public void getServiceEvents(context.ContextOuterClass.Empty request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetServiceEventsMethod(), responseObserver); } /** */ public void listSliceIds(context.ContextOuterClass.ContextId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getListSliceIdsMethod(), responseObserver); } /** */ public void listSlices(context.ContextOuterClass.ContextId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getListSlicesMethod(), responseObserver); } /** */ public void getSlice(context.ContextOuterClass.SliceId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetSliceMethod(), responseObserver); } /** */ public void setSlice(context.ContextOuterClass.Slice request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getSetSliceMethod(), responseObserver); } /** */ public void removeSlice(context.ContextOuterClass.SliceId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getRemoveSliceMethod(), responseObserver); } /** */ public void getSliceEvents(context.ContextOuterClass.Empty request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetSliceEventsMethod(), responseObserver); } /** */ public void listConnectionIds(context.ContextOuterClass.ServiceId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getListConnectionIdsMethod(), responseObserver); } /** */ public void listConnections(context.ContextOuterClass.ServiceId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getListConnectionsMethod(), responseObserver); } /** */ public void getConnection(context.ContextOuterClass.ConnectionId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetConnectionMethod(), responseObserver); } /** */ public void setConnection(context.ContextOuterClass.Connection request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getSetConnectionMethod(), responseObserver); } /** */ public void removeConnection(context.ContextOuterClass.ConnectionId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getRemoveConnectionMethod(), responseObserver); } /** */ public void getConnectionEvents(context.ContextOuterClass.Empty request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetConnectionEventsMethod(), responseObserver); } @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() { return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor()) .addMethod( getListContextIdsMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.Empty, context.ContextOuterClass.ContextIdList>( this, METHODID_LIST_CONTEXT_IDS))) .addMethod( getListContextsMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.Empty, context.ContextOuterClass.ContextList>( this, METHODID_LIST_CONTEXTS))) .addMethod( getGetContextMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.ContextId, context.ContextOuterClass.Context>( this, METHODID_GET_CONTEXT))) .addMethod( getSetContextMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.Context, context.ContextOuterClass.ContextId>( this, METHODID_SET_CONTEXT))) .addMethod( getRemoveContextMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.ContextId, context.ContextOuterClass.Empty>( this, METHODID_REMOVE_CONTEXT))) .addMethod( getGetContextEventsMethod(), io.grpc.stub.ServerCalls.asyncServerStreamingCall( new MethodHandlers< context.ContextOuterClass.Empty, context.ContextOuterClass.ContextEvent>( this, METHODID_GET_CONTEXT_EVENTS))) .addMethod( getListTopologyIdsMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.ContextId, context.ContextOuterClass.TopologyIdList>( this, METHODID_LIST_TOPOLOGY_IDS))) .addMethod( getListTopologiesMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.ContextId, context.ContextOuterClass.TopologyList>( this, METHODID_LIST_TOPOLOGIES))) .addMethod( getGetTopologyMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.TopologyId, context.ContextOuterClass.Topology>( this, METHODID_GET_TOPOLOGY))) .addMethod( getSetTopologyMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.Topology, context.ContextOuterClass.TopologyId>( this, METHODID_SET_TOPOLOGY))) .addMethod( getRemoveTopologyMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.TopologyId, context.ContextOuterClass.Empty>( this, METHODID_REMOVE_TOPOLOGY))) .addMethod( getGetTopologyEventsMethod(), io.grpc.stub.ServerCalls.asyncServerStreamingCall( new MethodHandlers< context.ContextOuterClass.Empty, context.ContextOuterClass.TopologyEvent>( this, METHODID_GET_TOPOLOGY_EVENTS))) .addMethod( getListDeviceIdsMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.Empty, context.ContextOuterClass.DeviceIdList>( this, METHODID_LIST_DEVICE_IDS))) .addMethod( getListDevicesMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.Empty, context.ContextOuterClass.DeviceList>( this, METHODID_LIST_DEVICES))) .addMethod( getGetDeviceMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.DeviceId, context.ContextOuterClass.Device>( this, METHODID_GET_DEVICE))) .addMethod( getSetDeviceMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.Device, context.ContextOuterClass.DeviceId>( this, METHODID_SET_DEVICE))) .addMethod( getRemoveDeviceMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.DeviceId, context.ContextOuterClass.Empty>( this, METHODID_REMOVE_DEVICE))) .addMethod( getGetDeviceEventsMethod(), io.grpc.stub.ServerCalls.asyncServerStreamingCall( new MethodHandlers< context.ContextOuterClass.Empty, context.ContextOuterClass.DeviceEvent>( this, METHODID_GET_DEVICE_EVENTS))) .addMethod( getListLinkIdsMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.Empty, context.ContextOuterClass.LinkIdList>( this, METHODID_LIST_LINK_IDS))) .addMethod( getListLinksMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.Empty, context.ContextOuterClass.LinkList>( this, METHODID_LIST_LINKS))) .addMethod( getGetLinkMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.LinkId, context.ContextOuterClass.Link>( this, METHODID_GET_LINK))) .addMethod( getSetLinkMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.Link, context.ContextOuterClass.LinkId>( this, METHODID_SET_LINK))) .addMethod( getRemoveLinkMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.LinkId, context.ContextOuterClass.Empty>( this, METHODID_REMOVE_LINK))) .addMethod( getGetLinkEventsMethod(), io.grpc.stub.ServerCalls.asyncServerStreamingCall( new MethodHandlers< context.ContextOuterClass.Empty, context.ContextOuterClass.LinkEvent>( this, METHODID_GET_LINK_EVENTS))) .addMethod( getListServiceIdsMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.ContextId, context.ContextOuterClass.ServiceIdList>( this, METHODID_LIST_SERVICE_IDS))) .addMethod( getListServicesMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.ContextId, context.ContextOuterClass.ServiceList>( this, METHODID_LIST_SERVICES))) .addMethod( getGetServiceMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.ServiceId, context.ContextOuterClass.Service>( this, METHODID_GET_SERVICE))) .addMethod( getSetServiceMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.Service, context.ContextOuterClass.ServiceId>( this, METHODID_SET_SERVICE))) .addMethod( getRemoveServiceMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.ServiceId, context.ContextOuterClass.Empty>( this, METHODID_REMOVE_SERVICE))) .addMethod( getGetServiceEventsMethod(), io.grpc.stub.ServerCalls.asyncServerStreamingCall( new MethodHandlers< context.ContextOuterClass.Empty, context.ContextOuterClass.ServiceEvent>( this, METHODID_GET_SERVICE_EVENTS))) .addMethod( getListSliceIdsMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.ContextId, context.ContextOuterClass.SliceIdList>( this, METHODID_LIST_SLICE_IDS))) .addMethod( getListSlicesMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.ContextId, context.ContextOuterClass.SliceList>( this, METHODID_LIST_SLICES))) .addMethod( getGetSliceMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.SliceId, context.ContextOuterClass.Slice>( this, METHODID_GET_SLICE))) .addMethod( getSetSliceMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.Slice, context.ContextOuterClass.SliceId>( this, METHODID_SET_SLICE))) .addMethod( getRemoveSliceMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.SliceId, context.ContextOuterClass.Empty>( this, METHODID_REMOVE_SLICE))) .addMethod( getGetSliceEventsMethod(), io.grpc.stub.ServerCalls.asyncServerStreamingCall( new MethodHandlers< context.ContextOuterClass.Empty, context.ContextOuterClass.SliceEvent>( this, METHODID_GET_SLICE_EVENTS))) .addMethod( getListConnectionIdsMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.ServiceId, context.ContextOuterClass.ConnectionIdList>( this, METHODID_LIST_CONNECTION_IDS))) .addMethod( getListConnectionsMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.ServiceId, context.ContextOuterClass.ConnectionList>( this, METHODID_LIST_CONNECTIONS))) .addMethod( getGetConnectionMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.ConnectionId, context.ContextOuterClass.Connection>( this, METHODID_GET_CONNECTION))) .addMethod( getSetConnectionMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.Connection, context.ContextOuterClass.ConnectionId>( this, METHODID_SET_CONNECTION))) .addMethod( getRemoveConnectionMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( new MethodHandlers< context.ContextOuterClass.ConnectionId, context.ContextOuterClass.Empty>( this, METHODID_REMOVE_CONNECTION))) .addMethod( getGetConnectionEventsMethod(), io.grpc.stub.ServerCalls.asyncServerStreamingCall( new MethodHandlers< context.ContextOuterClass.Empty, context.ContextOuterClass.ConnectionEvent>( this, METHODID_GET_CONNECTION_EVENTS))) .build(); } } /** */ public static final class ContextServiceStub extends io.grpc.stub.AbstractAsyncStub { private ContextServiceStub( io.grpc.Channel channel, io.grpc.CallOptions callOptions) { super(channel, callOptions); } @java.lang.Override protected ContextServiceStub build( io.grpc.Channel channel, io.grpc.CallOptions callOptions) { return new ContextServiceStub(channel, callOptions); } /** */ public void listContextIds(context.ContextOuterClass.Empty request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getListContextIdsMethod(), getCallOptions()), request, responseObserver); } /** */ public void listContexts(context.ContextOuterClass.Empty request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getListContextsMethod(), getCallOptions()), request, responseObserver); } /** */ public void getContext(context.ContextOuterClass.ContextId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getGetContextMethod(), getCallOptions()), request, responseObserver); } /** */ public void setContext(context.ContextOuterClass.Context request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getSetContextMethod(), getCallOptions()), request, responseObserver); } /** */ public void removeContext(context.ContextOuterClass.ContextId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getRemoveContextMethod(), getCallOptions()), request, responseObserver); } /** */ public void getContextEvents(context.ContextOuterClass.Empty request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncServerStreamingCall( getChannel().newCall(getGetContextEventsMethod(), getCallOptions()), request, responseObserver); } /** */ public void listTopologyIds(context.ContextOuterClass.ContextId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getListTopologyIdsMethod(), getCallOptions()), request, responseObserver); } /** */ public void listTopologies(context.ContextOuterClass.ContextId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getListTopologiesMethod(), getCallOptions()), request, responseObserver); } /** */ public void getTopology(context.ContextOuterClass.TopologyId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getGetTopologyMethod(), getCallOptions()), request, responseObserver); } /** */ public void setTopology(context.ContextOuterClass.Topology request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getSetTopologyMethod(), getCallOptions()), request, responseObserver); } /** */ public void removeTopology(context.ContextOuterClass.TopologyId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getRemoveTopologyMethod(), getCallOptions()), request, responseObserver); } /** */ public void getTopologyEvents(context.ContextOuterClass.Empty request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncServerStreamingCall( getChannel().newCall(getGetTopologyEventsMethod(), getCallOptions()), request, responseObserver); } /** */ public void listDeviceIds(context.ContextOuterClass.Empty request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getListDeviceIdsMethod(), getCallOptions()), request, responseObserver); } /** */ public void listDevices(context.ContextOuterClass.Empty request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getListDevicesMethod(), getCallOptions()), request, responseObserver); } /** */ public void getDevice(context.ContextOuterClass.DeviceId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getGetDeviceMethod(), getCallOptions()), request, responseObserver); } /** */ public void setDevice(context.ContextOuterClass.Device request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getSetDeviceMethod(), getCallOptions()), request, responseObserver); } /** */ public void removeDevice(context.ContextOuterClass.DeviceId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getRemoveDeviceMethod(), getCallOptions()), request, responseObserver); } /** */ public void getDeviceEvents(context.ContextOuterClass.Empty request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncServerStreamingCall( getChannel().newCall(getGetDeviceEventsMethod(), getCallOptions()), request, responseObserver); } /** */ public void listLinkIds(context.ContextOuterClass.Empty request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getListLinkIdsMethod(), getCallOptions()), request, responseObserver); } /** */ public void listLinks(context.ContextOuterClass.Empty request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getListLinksMethod(), getCallOptions()), request, responseObserver); } /** */ public void getLink(context.ContextOuterClass.LinkId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getGetLinkMethod(), getCallOptions()), request, responseObserver); } /** */ public void setLink(context.ContextOuterClass.Link request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getSetLinkMethod(), getCallOptions()), request, responseObserver); } /** */ public void removeLink(context.ContextOuterClass.LinkId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getRemoveLinkMethod(), getCallOptions()), request, responseObserver); } /** */ public void getLinkEvents(context.ContextOuterClass.Empty request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncServerStreamingCall( getChannel().newCall(getGetLinkEventsMethod(), getCallOptions()), request, responseObserver); } /** */ public void listServiceIds(context.ContextOuterClass.ContextId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getListServiceIdsMethod(), getCallOptions()), request, responseObserver); } /** */ public void listServices(context.ContextOuterClass.ContextId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getListServicesMethod(), getCallOptions()), request, responseObserver); } /** */ public void getService(context.ContextOuterClass.ServiceId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getGetServiceMethod(), getCallOptions()), request, responseObserver); } /** */ public void setService(context.ContextOuterClass.Service request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getSetServiceMethod(), getCallOptions()), request, responseObserver); } /** */ public void removeService(context.ContextOuterClass.ServiceId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getRemoveServiceMethod(), getCallOptions()), request, responseObserver); } /** */ public void getServiceEvents(context.ContextOuterClass.Empty request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncServerStreamingCall( getChannel().newCall(getGetServiceEventsMethod(), getCallOptions()), request, responseObserver); } /** */ public void listSliceIds(context.ContextOuterClass.ContextId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getListSliceIdsMethod(), getCallOptions()), request, responseObserver); } /** */ public void listSlices(context.ContextOuterClass.ContextId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getListSlicesMethod(), getCallOptions()), request, responseObserver); } /** */ public void getSlice(context.ContextOuterClass.SliceId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getGetSliceMethod(), getCallOptions()), request, responseObserver); } /** */ public void setSlice(context.ContextOuterClass.Slice request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getSetSliceMethod(), getCallOptions()), request, responseObserver); } /** */ public void removeSlice(context.ContextOuterClass.SliceId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getRemoveSliceMethod(), getCallOptions()), request, responseObserver); } /** */ public void getSliceEvents(context.ContextOuterClass.Empty request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncServerStreamingCall( getChannel().newCall(getGetSliceEventsMethod(), getCallOptions()), request, responseObserver); } /** */ public void listConnectionIds(context.ContextOuterClass.ServiceId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getListConnectionIdsMethod(), getCallOptions()), request, responseObserver); } /** */ public void listConnections(context.ContextOuterClass.ServiceId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getListConnectionsMethod(), getCallOptions()), request, responseObserver); } /** */ public void getConnection(context.ContextOuterClass.ConnectionId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getGetConnectionMethod(), getCallOptions()), request, responseObserver); } /** */ public void setConnection(context.ContextOuterClass.Connection request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getSetConnectionMethod(), getCallOptions()), request, responseObserver); } /** */ public void removeConnection(context.ContextOuterClass.ConnectionId request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getRemoveConnectionMethod(), getCallOptions()), request, responseObserver); } /** */ public void getConnectionEvents(context.ContextOuterClass.Empty request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ClientCalls.asyncServerStreamingCall( getChannel().newCall(getGetConnectionEventsMethod(), getCallOptions()), request, responseObserver); } } /** */ public static final class ContextServiceBlockingStub extends io.grpc.stub.AbstractBlockingStub { private ContextServiceBlockingStub( io.grpc.Channel channel, io.grpc.CallOptions callOptions) { super(channel, callOptions); } @java.lang.Override protected ContextServiceBlockingStub build( io.grpc.Channel channel, io.grpc.CallOptions callOptions) { return new ContextServiceBlockingStub(channel, callOptions); } /** */ public context.ContextOuterClass.ContextIdList listContextIds(context.ContextOuterClass.Empty request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getListContextIdsMethod(), getCallOptions(), request); } /** */ public context.ContextOuterClass.ContextList listContexts(context.ContextOuterClass.Empty request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getListContextsMethod(), getCallOptions(), request); } /** */ public context.ContextOuterClass.Context getContext(context.ContextOuterClass.ContextId request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getGetContextMethod(), getCallOptions(), request); } /** */ public context.ContextOuterClass.ContextId setContext(context.ContextOuterClass.Context request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getSetContextMethod(), getCallOptions(), request); } /** */ public context.ContextOuterClass.Empty removeContext(context.ContextOuterClass.ContextId request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getRemoveContextMethod(), getCallOptions(), request); } /** */ public java.util.Iterator getContextEvents( context.ContextOuterClass.Empty request) { return io.grpc.stub.ClientCalls.blockingServerStreamingCall( getChannel(), getGetContextEventsMethod(), getCallOptions(), request); } /** */ public context.ContextOuterClass.TopologyIdList listTopologyIds(context.ContextOuterClass.ContextId request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getListTopologyIdsMethod(), getCallOptions(), request); } /** */ public context.ContextOuterClass.TopologyList listTopologies(context.ContextOuterClass.ContextId request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getListTopologiesMethod(), getCallOptions(), request); } /** */ public context.ContextOuterClass.Topology getTopology(context.ContextOuterClass.TopologyId request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getGetTopologyMethod(), getCallOptions(), request); } /** */ public context.ContextOuterClass.TopologyId setTopology(context.ContextOuterClass.Topology request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getSetTopologyMethod(), getCallOptions(), request); } /** */ public context.ContextOuterClass.Empty removeTopology(context.ContextOuterClass.TopologyId request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getRemoveTopologyMethod(), getCallOptions(), request); } /** */ public java.util.Iterator getTopologyEvents( context.ContextOuterClass.Empty request) { return io.grpc.stub.ClientCalls.blockingServerStreamingCall( getChannel(), getGetTopologyEventsMethod(), getCallOptions(), request); } /** */ public context.ContextOuterClass.DeviceIdList listDeviceIds(context.ContextOuterClass.Empty request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getListDeviceIdsMethod(), getCallOptions(), request); } /** */ public context.ContextOuterClass.DeviceList listDevices(context.ContextOuterClass.Empty request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getListDevicesMethod(), getCallOptions(), request); } /** */ public context.ContextOuterClass.Device getDevice(context.ContextOuterClass.DeviceId request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getGetDeviceMethod(), getCallOptions(), request); } /** */ public context.ContextOuterClass.DeviceId setDevice(context.ContextOuterClass.Device request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getSetDeviceMethod(), getCallOptions(), request); } /** */ public context.ContextOuterClass.Empty removeDevice(context.ContextOuterClass.DeviceId request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getRemoveDeviceMethod(), getCallOptions(), request); } /** */ public java.util.Iterator getDeviceEvents( context.ContextOuterClass.Empty request) { return io.grpc.stub.ClientCalls.blockingServerStreamingCall( getChannel(), getGetDeviceEventsMethod(), getCallOptions(), request); } /** */ public context.ContextOuterClass.LinkIdList listLinkIds(context.ContextOuterClass.Empty request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getListLinkIdsMethod(), getCallOptions(), request); } /** */ public context.ContextOuterClass.LinkList listLinks(context.ContextOuterClass.Empty request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getListLinksMethod(), getCallOptions(), request); } /** */ public context.ContextOuterClass.Link getLink(context.ContextOuterClass.LinkId request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getGetLinkMethod(), getCallOptions(), request); } /** */ public context.ContextOuterClass.LinkId setLink(context.ContextOuterClass.Link request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getSetLinkMethod(), getCallOptions(), request); } /** */ public context.ContextOuterClass.Empty removeLink(context.ContextOuterClass.LinkId request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getRemoveLinkMethod(), getCallOptions(), request); } /** */ public java.util.Iterator getLinkEvents( context.ContextOuterClass.Empty request) { return io.grpc.stub.ClientCalls.blockingServerStreamingCall( getChannel(), getGetLinkEventsMethod(), getCallOptions(), request); } /** */ public context.ContextOuterClass.ServiceIdList listServiceIds(context.ContextOuterClass.ContextId request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getListServiceIdsMethod(), getCallOptions(), request); } /** */ public context.ContextOuterClass.ServiceList listServices(context.ContextOuterClass.ContextId request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getListServicesMethod(), getCallOptions(), request); } /** */ public context.ContextOuterClass.Service getService(context.ContextOuterClass.ServiceId request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getGetServiceMethod(), getCallOptions(), request); } /** */ public context.ContextOuterClass.ServiceId setService(context.ContextOuterClass.Service request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getSetServiceMethod(), getCallOptions(), request); } /** */ public context.ContextOuterClass.Empty removeService(context.ContextOuterClass.ServiceId request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getRemoveServiceMethod(), getCallOptions(), request); } /** */ public java.util.Iterator getServiceEvents( context.ContextOuterClass.Empty request) { return io.grpc.stub.ClientCalls.blockingServerStreamingCall( getChannel(), getGetServiceEventsMethod(), getCallOptions(), request); } /** */ public context.ContextOuterClass.SliceIdList listSliceIds(context.ContextOuterClass.ContextId request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getListSliceIdsMethod(), getCallOptions(), request); } /** */ public context.ContextOuterClass.SliceList listSlices(context.ContextOuterClass.ContextId request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getListSlicesMethod(), getCallOptions(), request); } /** */ public context.ContextOuterClass.Slice getSlice(context.ContextOuterClass.SliceId request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getGetSliceMethod(), getCallOptions(), request); } /** */ public context.ContextOuterClass.SliceId setSlice(context.ContextOuterClass.Slice request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getSetSliceMethod(), getCallOptions(), request); } /** */ public context.ContextOuterClass.Empty removeSlice(context.ContextOuterClass.SliceId request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getRemoveSliceMethod(), getCallOptions(), request); } /** */ public java.util.Iterator getSliceEvents( context.ContextOuterClass.Empty request) { return io.grpc.stub.ClientCalls.blockingServerStreamingCall( getChannel(), getGetSliceEventsMethod(), getCallOptions(), request); } /** */ public context.ContextOuterClass.ConnectionIdList listConnectionIds(context.ContextOuterClass.ServiceId request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getListConnectionIdsMethod(), getCallOptions(), request); } /** */ public context.ContextOuterClass.ConnectionList listConnections(context.ContextOuterClass.ServiceId request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getListConnectionsMethod(), getCallOptions(), request); } /** */ public context.ContextOuterClass.Connection getConnection(context.ContextOuterClass.ConnectionId request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getGetConnectionMethod(), getCallOptions(), request); } /** */ public context.ContextOuterClass.ConnectionId setConnection(context.ContextOuterClass.Connection request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getSetConnectionMethod(), getCallOptions(), request); } /** */ public context.ContextOuterClass.Empty removeConnection(context.ContextOuterClass.ConnectionId request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getRemoveConnectionMethod(), getCallOptions(), request); } /** */ public java.util.Iterator getConnectionEvents( context.ContextOuterClass.Empty request) { return io.grpc.stub.ClientCalls.blockingServerStreamingCall( getChannel(), getGetConnectionEventsMethod(), getCallOptions(), request); } } /** */ public static final class ContextServiceFutureStub extends io.grpc.stub.AbstractFutureStub { private ContextServiceFutureStub( io.grpc.Channel channel, io.grpc.CallOptions callOptions) { super(channel, callOptions); } @java.lang.Override protected ContextServiceFutureStub build( io.grpc.Channel channel, io.grpc.CallOptions callOptions) { return new ContextServiceFutureStub(channel, callOptions); } /** */ public com.google.common.util.concurrent.ListenableFuture listContextIds( context.ContextOuterClass.Empty request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getListContextIdsMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture listContexts( context.ContextOuterClass.Empty request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getListContextsMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture getContext( context.ContextOuterClass.ContextId request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getGetContextMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture setContext( context.ContextOuterClass.Context request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getSetContextMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture removeContext( context.ContextOuterClass.ContextId request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getRemoveContextMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture listTopologyIds( context.ContextOuterClass.ContextId request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getListTopologyIdsMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture listTopologies( context.ContextOuterClass.ContextId request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getListTopologiesMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture getTopology( context.ContextOuterClass.TopologyId request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getGetTopologyMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture setTopology( context.ContextOuterClass.Topology request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getSetTopologyMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture removeTopology( context.ContextOuterClass.TopologyId request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getRemoveTopologyMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture listDeviceIds( context.ContextOuterClass.Empty request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getListDeviceIdsMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture listDevices( context.ContextOuterClass.Empty request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getListDevicesMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture getDevice( context.ContextOuterClass.DeviceId request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getGetDeviceMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture setDevice( context.ContextOuterClass.Device request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getSetDeviceMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture removeDevice( context.ContextOuterClass.DeviceId request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getRemoveDeviceMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture listLinkIds( context.ContextOuterClass.Empty request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getListLinkIdsMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture listLinks( context.ContextOuterClass.Empty request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getListLinksMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture getLink( context.ContextOuterClass.LinkId request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getGetLinkMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture setLink( context.ContextOuterClass.Link request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getSetLinkMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture removeLink( context.ContextOuterClass.LinkId request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getRemoveLinkMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture listServiceIds( context.ContextOuterClass.ContextId request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getListServiceIdsMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture listServices( context.ContextOuterClass.ContextId request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getListServicesMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture getService( context.ContextOuterClass.ServiceId request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getGetServiceMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture setService( context.ContextOuterClass.Service request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getSetServiceMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture removeService( context.ContextOuterClass.ServiceId request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getRemoveServiceMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture listSliceIds( context.ContextOuterClass.ContextId request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getListSliceIdsMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture listSlices( context.ContextOuterClass.ContextId request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getListSlicesMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture getSlice( context.ContextOuterClass.SliceId request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getGetSliceMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture setSlice( context.ContextOuterClass.Slice request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getSetSliceMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture removeSlice( context.ContextOuterClass.SliceId request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getRemoveSliceMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture listConnectionIds( context.ContextOuterClass.ServiceId request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getListConnectionIdsMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture listConnections( context.ContextOuterClass.ServiceId request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getListConnectionsMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture getConnection( context.ContextOuterClass.ConnectionId request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getGetConnectionMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture setConnection( context.ContextOuterClass.Connection request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getSetConnectionMethod(), getCallOptions()), request); } /** */ public com.google.common.util.concurrent.ListenableFuture removeConnection( context.ContextOuterClass.ConnectionId request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getRemoveConnectionMethod(), getCallOptions()), request); } } private static final int METHODID_LIST_CONTEXT_IDS = 0; private static final int METHODID_LIST_CONTEXTS = 1; private static final int METHODID_GET_CONTEXT = 2; private static final int METHODID_SET_CONTEXT = 3; private static final int METHODID_REMOVE_CONTEXT = 4; private static final int METHODID_GET_CONTEXT_EVENTS = 5; private static final int METHODID_LIST_TOPOLOGY_IDS = 6; private static final int METHODID_LIST_TOPOLOGIES = 7; private static final int METHODID_GET_TOPOLOGY = 8; private static final int METHODID_SET_TOPOLOGY = 9; private static final int METHODID_REMOVE_TOPOLOGY = 10; private static final int METHODID_GET_TOPOLOGY_EVENTS = 11; private static final int METHODID_LIST_DEVICE_IDS = 12; private static final int METHODID_LIST_DEVICES = 13; private static final int METHODID_GET_DEVICE = 14; private static final int METHODID_SET_DEVICE = 15; private static final int METHODID_REMOVE_DEVICE = 16; private static final int METHODID_GET_DEVICE_EVENTS = 17; private static final int METHODID_LIST_LINK_IDS = 18; private static final int METHODID_LIST_LINKS = 19; private static final int METHODID_GET_LINK = 20; private static final int METHODID_SET_LINK = 21; private static final int METHODID_REMOVE_LINK = 22; private static final int METHODID_GET_LINK_EVENTS = 23; private static final int METHODID_LIST_SERVICE_IDS = 24; private static final int METHODID_LIST_SERVICES = 25; private static final int METHODID_GET_SERVICE = 26; private static final int METHODID_SET_SERVICE = 27; private static final int METHODID_REMOVE_SERVICE = 28; private static final int METHODID_GET_SERVICE_EVENTS = 29; private static final int METHODID_LIST_SLICE_IDS = 30; private static final int METHODID_LIST_SLICES = 31; private static final int METHODID_GET_SLICE = 32; private static final int METHODID_SET_SLICE = 33; private static final int METHODID_REMOVE_SLICE = 34; private static final int METHODID_GET_SLICE_EVENTS = 35; private static final int METHODID_LIST_CONNECTION_IDS = 36; private static final int METHODID_LIST_CONNECTIONS = 37; private static final int METHODID_GET_CONNECTION = 38; private static final int METHODID_SET_CONNECTION = 39; private static final int METHODID_REMOVE_CONNECTION = 40; private static final int METHODID_GET_CONNECTION_EVENTS = 41; 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 ContextServiceImplBase serviceImpl; private final int methodId; MethodHandlers(ContextServiceImplBase 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_LIST_CONTEXT_IDS: serviceImpl.listContextIds((context.ContextOuterClass.Empty) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_LIST_CONTEXTS: serviceImpl.listContexts((context.ContextOuterClass.Empty) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_GET_CONTEXT: serviceImpl.getContext((context.ContextOuterClass.ContextId) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_SET_CONTEXT: serviceImpl.setContext((context.ContextOuterClass.Context) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_REMOVE_CONTEXT: serviceImpl.removeContext((context.ContextOuterClass.ContextId) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_GET_CONTEXT_EVENTS: serviceImpl.getContextEvents((context.ContextOuterClass.Empty) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_LIST_TOPOLOGY_IDS: serviceImpl.listTopologyIds((context.ContextOuterClass.ContextId) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_LIST_TOPOLOGIES: serviceImpl.listTopologies((context.ContextOuterClass.ContextId) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_GET_TOPOLOGY: serviceImpl.getTopology((context.ContextOuterClass.TopologyId) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_SET_TOPOLOGY: serviceImpl.setTopology((context.ContextOuterClass.Topology) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_REMOVE_TOPOLOGY: serviceImpl.removeTopology((context.ContextOuterClass.TopologyId) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_GET_TOPOLOGY_EVENTS: serviceImpl.getTopologyEvents((context.ContextOuterClass.Empty) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_LIST_DEVICE_IDS: serviceImpl.listDeviceIds((context.ContextOuterClass.Empty) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_LIST_DEVICES: serviceImpl.listDevices((context.ContextOuterClass.Empty) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_GET_DEVICE: serviceImpl.getDevice((context.ContextOuterClass.DeviceId) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_SET_DEVICE: serviceImpl.setDevice((context.ContextOuterClass.Device) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_REMOVE_DEVICE: serviceImpl.removeDevice((context.ContextOuterClass.DeviceId) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_GET_DEVICE_EVENTS: serviceImpl.getDeviceEvents((context.ContextOuterClass.Empty) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_LIST_LINK_IDS: serviceImpl.listLinkIds((context.ContextOuterClass.Empty) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_LIST_LINKS: serviceImpl.listLinks((context.ContextOuterClass.Empty) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_GET_LINK: serviceImpl.getLink((context.ContextOuterClass.LinkId) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_SET_LINK: serviceImpl.setLink((context.ContextOuterClass.Link) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_REMOVE_LINK: serviceImpl.removeLink((context.ContextOuterClass.LinkId) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_GET_LINK_EVENTS: serviceImpl.getLinkEvents((context.ContextOuterClass.Empty) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_LIST_SERVICE_IDS: serviceImpl.listServiceIds((context.ContextOuterClass.ContextId) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_LIST_SERVICES: serviceImpl.listServices((context.ContextOuterClass.ContextId) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_GET_SERVICE: serviceImpl.getService((context.ContextOuterClass.ServiceId) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_SET_SERVICE: serviceImpl.setService((context.ContextOuterClass.Service) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_REMOVE_SERVICE: serviceImpl.removeService((context.ContextOuterClass.ServiceId) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_GET_SERVICE_EVENTS: serviceImpl.getServiceEvents((context.ContextOuterClass.Empty) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_LIST_SLICE_IDS: serviceImpl.listSliceIds((context.ContextOuterClass.ContextId) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_LIST_SLICES: serviceImpl.listSlices((context.ContextOuterClass.ContextId) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_GET_SLICE: serviceImpl.getSlice((context.ContextOuterClass.SliceId) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_SET_SLICE: serviceImpl.setSlice((context.ContextOuterClass.Slice) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_REMOVE_SLICE: serviceImpl.removeSlice((context.ContextOuterClass.SliceId) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_GET_SLICE_EVENTS: serviceImpl.getSliceEvents((context.ContextOuterClass.Empty) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_LIST_CONNECTION_IDS: serviceImpl.listConnectionIds((context.ContextOuterClass.ServiceId) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_LIST_CONNECTIONS: serviceImpl.listConnections((context.ContextOuterClass.ServiceId) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_GET_CONNECTION: serviceImpl.getConnection((context.ContextOuterClass.ConnectionId) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_SET_CONNECTION: serviceImpl.setConnection((context.ContextOuterClass.Connection) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_REMOVE_CONNECTION: serviceImpl.removeConnection((context.ContextOuterClass.ConnectionId) request, (io.grpc.stub.StreamObserver) responseObserver); break; case METHODID_GET_CONNECTION_EVENTS: serviceImpl.getConnectionEvents((context.ContextOuterClass.Empty) 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(); } } } private static abstract class ContextServiceBaseDescriptorSupplier implements io.grpc.protobuf.ProtoFileDescriptorSupplier, io.grpc.protobuf.ProtoServiceDescriptorSupplier { ContextServiceBaseDescriptorSupplier() {} @java.lang.Override public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() { return context.ContextOuterClass.getDescriptor(); } @java.lang.Override public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() { return getFileDescriptor().findServiceByName("ContextService"); } } private static final class ContextServiceFileDescriptorSupplier extends ContextServiceBaseDescriptorSupplier { ContextServiceFileDescriptorSupplier() {} } private static final class ContextServiceMethodDescriptorSupplier extends ContextServiceBaseDescriptorSupplier implements io.grpc.protobuf.ProtoMethodDescriptorSupplier { private final String methodName; ContextServiceMethodDescriptorSupplier(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 (ContextServiceGrpc.class) { result = serviceDescriptor; if (result == null) { serviceDescriptor = result = io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME) .setSchemaDescriptor(new ContextServiceFileDescriptorSupplier()) .addMethod(getListContextIdsMethod()) .addMethod(getListContextsMethod()) .addMethod(getGetContextMethod()) .addMethod(getSetContextMethod()) .addMethod(getRemoveContextMethod()) .addMethod(getGetContextEventsMethod()) .addMethod(getListTopologyIdsMethod()) .addMethod(getListTopologiesMethod()) .addMethod(getGetTopologyMethod()) .addMethod(getSetTopologyMethod()) .addMethod(getRemoveTopologyMethod()) .addMethod(getGetTopologyEventsMethod()) .addMethod(getListDeviceIdsMethod()) .addMethod(getListDevicesMethod()) .addMethod(getGetDeviceMethod()) .addMethod(getSetDeviceMethod()) .addMethod(getRemoveDeviceMethod()) .addMethod(getGetDeviceEventsMethod()) .addMethod(getListLinkIdsMethod()) .addMethod(getListLinksMethod()) .addMethod(getGetLinkMethod()) .addMethod(getSetLinkMethod()) .addMethod(getRemoveLinkMethod()) .addMethod(getGetLinkEventsMethod()) .addMethod(getListServiceIdsMethod()) .addMethod(getListServicesMethod()) .addMethod(getGetServiceMethod()) .addMethod(getSetServiceMethod()) .addMethod(getRemoveServiceMethod()) .addMethod(getGetServiceEventsMethod()) .addMethod(getListSliceIdsMethod()) .addMethod(getListSlicesMethod()) .addMethod(getGetSliceMethod()) .addMethod(getSetSliceMethod()) .addMethod(getRemoveSliceMethod()) .addMethod(getGetSliceEventsMethod()) .addMethod(getListConnectionIdsMethod()) .addMethod(getListConnectionsMethod()) .addMethod(getGetConnectionMethod()) .addMethod(getSetConnectionMethod()) .addMethod(getRemoveConnectionMethod()) .addMethod(getGetConnectionEventsMethod()) .build(); } } } return result; } }