module.yaml

kind: io.statefun.endpoints.v2/http
spec:
  functions: hesse.storage/*
  urlPathTemplate: http://hesse:1108/
  transport:
    type: io.statefun.transports.v1/async
---
kind: io.statefun.endpoints.v2/http
spec:
  functions: hesse.applications/*
  urlPathTemplate: http://hesse:1108/
  transport:
    type: io.statefun.transports.v1/async
---
kind: io.statefun.endpoints.v2/http
spec:
  functions: hesse.query/*
  urlPathTemplate: http://hesse:1108/
  transport:
    type: io.statefun.transports.v1/async
---
kind: io.statefun.endpoints.v2/http
spec:
  functions: hesse.coordination/*
  urlPathTemplate: http://hesse:1108/
  transport:
    type: io.statefun.transports.v1/async
---
kind: io.statefun.endpoints.v2/http
spec:
  functions: hesse.benchmarks/*
  urlPathTemplate: http://hesse:1108/
  transport:
    type: io.statefun.transports.v1/async
---
kind: io.statefun.kafka.v1/ingress
spec:
  id: hesse.io/temporal-graph
  address: kafka:9092
  consumerGroupId: hesse
  startupPosition:
    type: earliest
  topics:
  - topic: temporal-graph
    valueType: hesse.types/temporal_edge
    targets:
    - hesse.storage/vertex-storage
---
kind: io.statefun.kafka.v1/ingress
spec:
  id: hesse.io/query
  address: kafka:9092
  consumerGroupId: hesse
  startupPosition:
    type: earliest
  topics:
  - topic: query
    valueType: hesse.types/query
    targets:
    - hesse.query/temporal-query-handler
---
kind: io.statefun.kafka.v1/egress
spec:
  id: hesse.io/query-results
  address: kafka:9092
  deliverySemantic:
    type: at-least-once
---
kind: io.statefun.kafka.v1/egress
spec:
  id: hesse.io/storage-time
  address: kafka:9092
  deliverySemantic:
    type: at-least-once
---
kind: io.statefun.kafka.v1/egress
spec:
  id: hesse.io/filter-time
  address: kafka:9092
  deliverySemantic:
    type: at-least-once