Commit 2672cdde authored by Fotis Soldatos's avatar Fotis Soldatos
Browse files

chore(policy): update application.yml

parent ed91fd7a

src/policy/src/main/resources/application.yml

+9 −5
Original line number Diff line number Diff line
@@ -13,28 +13,32 @@ 
# limitations under the License.



quarkus:

  banner:

    path: teraflow-policy-banner.txt

  grpc:

    server:

      port: 9999

      enable-reflection-service: true

  http:

    port: 8080



  container-image:

    group: teraflow-h2020

    name: controller/policy

    registry: registry.gitlab.com



  kubernetes:

    name: policyservice

    image-pull-policy: Always

    add-version-to-label-selectors: false

    labels:

      app: policyservice

    add-version-to-label-selectors: false

    readiness-probe:

      initial-delay: 5s

      period: 45s

      initial-delay: 2s

      period: 10s

    liveness-probe:

      initial-delay: 5s

      period: 45s

      initial-delay: 2s

      period: 10s

    ports:

      http:

        host-port: 8080

src/policy/src/main/resources/teraflow-policy-banner.txt

0 → 100644
+9 −0
Original line number Diff line number Diff line 


  _______             ______ _                 _____      _ _

 |__   __|           |  ____| |               |  __ \    | (_)

    | | ___ _ __ __ _| |__  | | _____      __ | |__) |__ | |_  ___ _   _

    | |/ _ \ '__/ _` |  __| | |/ _ \ \ /\ / / |  ___/ _ \| | |/ __| | | |

    | |  __/ | | (_| | |    | | (_) \ V  V /  | |  | (_) | | | (__| |_| |

    |_|\___|_|  \__,_|_|    |_|\___/ \_/\_/   |_|   \___/|_|_|\___|\__, |

                                                                    __/ |

                                                                   |___/

src/policy/target/generated-sources/grpc/context/ContextOuterClass.java

+6512 −202

File changed.

Preview size limit exceeded, changes collapsed.

src/policy/target/generated-sources/grpc/context/ContextService.java

+12 −0
Original line number Diff line number Diff line
@@ -58,6 +58,16 @@ public interface ContextService extends MutinyService { 
    

    io.smallrye.mutiny.Uni<context.ContextOuterClass.Empty> removeService(context.ContextOuterClass.ServiceId request);

    

    io.smallrye.mutiny.Uni<context.ContextOuterClass.SliceIdList> listSliceIds(context.ContextOuterClass.ContextId request);

    

    io.smallrye.mutiny.Uni<context.ContextOuterClass.SliceList> listSlices(context.ContextOuterClass.ContextId request);

    

    io.smallrye.mutiny.Uni<context.ContextOuterClass.Slice> getSlice(context.ContextOuterClass.SliceId request);

    

    io.smallrye.mutiny.Uni<context.ContextOuterClass.SliceId> setSlice(context.ContextOuterClass.Slice request);

    

    io.smallrye.mutiny.Uni<context.ContextOuterClass.Empty> removeSlice(context.ContextOuterClass.SliceId request);

    

    io.smallrye.mutiny.Uni<context.ContextOuterClass.ConnectionIdList> listConnectionIds(context.ContextOuterClass.ServiceId request);

    

    io.smallrye.mutiny.Uni<context.ContextOuterClass.ConnectionList> listConnections(context.ContextOuterClass.ServiceId request);
@@ -79,6 +89,8 @@ public interface ContextService extends MutinyService { 
    

    io.smallrye.mutiny.Multi<context.ContextOuterClass.ServiceEvent> getServiceEvents(context.ContextOuterClass.Empty request);

    

    io.smallrye.mutiny.Multi<context.ContextOuterClass.SliceEvent> getSliceEvents(context.ContextOuterClass.Empty request);

    

    io.smallrye.mutiny.Multi<context.ContextOuterClass.ConnectionEvent> getConnectionEvents(context.ContextOuterClass.Empty request);

src/policy/target/generated-sources/grpc/context/ContextServiceBean.java

+49 −0
Original line number Diff line number Diff line
@@ -216,6 +216,46 @@ public class ContextServiceBean extends MutinyContextServiceGrpc.ContextServiceI 
       }

    }

    @Override

    public io.smallrye.mutiny.Uni<context.ContextOuterClass.SliceIdList> listSliceIds(context.ContextOuterClass.ContextId request) {

       try {

         return delegate.listSliceIds(request);

       } catch (UnsupportedOperationException e) {

          throw new io.grpc.StatusRuntimeException(io.grpc.Status.UNIMPLEMENTED);

       }

    }

    @Override

    public io.smallrye.mutiny.Uni<context.ContextOuterClass.SliceList> listSlices(context.ContextOuterClass.ContextId request) {

       try {

         return delegate.listSlices(request);

       } catch (UnsupportedOperationException e) {

          throw new io.grpc.StatusRuntimeException(io.grpc.Status.UNIMPLEMENTED);

       }

    }

    @Override

    public io.smallrye.mutiny.Uni<context.ContextOuterClass.Slice> getSlice(context.ContextOuterClass.SliceId request) {

       try {

         return delegate.getSlice(request);

       } catch (UnsupportedOperationException e) {

          throw new io.grpc.StatusRuntimeException(io.grpc.Status.UNIMPLEMENTED);

       }

    }

    @Override

    public io.smallrye.mutiny.Uni<context.ContextOuterClass.SliceId> setSlice(context.ContextOuterClass.Slice request) {

       try {

         return delegate.setSlice(request);

       } catch (UnsupportedOperationException e) {

          throw new io.grpc.StatusRuntimeException(io.grpc.Status.UNIMPLEMENTED);

       }

    }

    @Override

    public io.smallrye.mutiny.Uni<context.ContextOuterClass.Empty> removeSlice(context.ContextOuterClass.SliceId request) {

       try {

         return delegate.removeSlice(request);

       } catch (UnsupportedOperationException e) {

          throw new io.grpc.StatusRuntimeException(io.grpc.Status.UNIMPLEMENTED);

       }

    }

    @Override

    public io.smallrye.mutiny.Uni<context.ContextOuterClass.ConnectionIdList> listConnectionIds(context.ContextOuterClass.ServiceId request) {

       try {

         return delegate.listConnectionIds(request);
@@ -301,6 +341,15 @@ public class ContextServiceBean extends MutinyContextServiceGrpc.ContextServiceI 
       }

    }



    @Override

    public io.smallrye.mutiny.Multi<context.ContextOuterClass.SliceEvent> getSliceEvents(context.ContextOuterClass.Empty request) {

       try {

         return delegate.getSliceEvents(request);

       } catch (UnsupportedOperationException e) {

          throw new io.grpc.StatusRuntimeException(io.grpc.Status.UNIMPLEMENTED);

       }

    }



    @Override

    public io.smallrye.mutiny.Multi<context.ContextOuterClass.ConnectionEvent> getConnectionEvents(context.ContextOuterClass.Empty request) {

       try {