mfelsche

actor Main
  new create(env: Env) =>
    env.out.print("Hello, world!")

mfelsche

actor Main
  new create(env: Env) =>
    env.out.print("Hello, world!")

mfelsche

actor Main
  new create(env: Env) =>
    env.out.print("Hello, world!")

mfelsche

actor Main
  new create(env: Env) =>
  env.out.print("Hello, world!")
  env.err.print("Hello, world!")

mfelsche

104_redpanda_elastic_correlation-tremor_out-1     | 2021-12-10T15:17:01.828694200+00:00 INFO tremor_runtime::system - Binding onramp tremor://localhost/onramp/redpanda-in/01/out
104_redpanda_elastic_correlation-tremor_out-1     | 2021-12-10T15:17:01.830056300+00:00 INFO tremor_runtime::source::kafka - [Source::tremor://localhost/onramp/redpanda-in/01/out] Starting kafka onramp
104_redpanda_elastic_correlation-tremor_out-1     | 2021-12-10T15:17:01.831848100+00:00 INFO tremor_runtime::source::kafka - [Source::tremor://localhost/onramp/redpanda-in/01/out] Subscribing to: ["tremor"]
104_redpanda_elastic_correlation-tremor_out-1     | 2021-12-10T15:17:01.832735600+00:00 INFO tremor_runtime::source::kafka - [Source::tremor://localhost/onramp/redpanda-in/01/out] Subscription initiated...
104_redpanda_elastic_correlation-tremor_out-1     | 2021-12-10T15:17:01.833342+00:00 INFO tremor_runtime::onramp - Onramp tremor://localhost/onramp/redpanda-in/01/out started.
104_redpanda_elastic_correlation-tremor_out-1     | 202

mfelsche

onramp:
  - id: udp_in
    type: udp
    codec: json
    config:
      host: localhost
      port: 65535
offramp:
  - id: kafka_out
    type: kafka

mfelsche

use sled;

fn main() {
    let db = sled::open("/path/to/sled").unwrap();
    //let db = sled::Config::default().temporary(true).open().unwrap();
    let tree = db.open_tree("events").unwrap();

    let mut cnt = 0_u64;
    let mut size = 0_u64;
    let mut last_id: Option<u64> = None;

mfelsche

use "ponybench"
use "collections"
use "random"


actor Main is BenchmarkList
  new create(env: Env) =>
    PonyBench(env, this)

  fun tag benchmarks(bench: PonyBench) =>

mfelsche

• how to handle reification of types with a HKT type-param?
  • if the hkt-type-param is not used: class Foo[F[_]]
  • if the hkt-type-param is used in method signatures:

    trait Foo[F[_]]
      def map[A](a: A): F[A]
    

  • if the hkt-type-param is used in the body of a function with a concrete type (is that even possible? where should it get that type from?):

trait Foo[F[_]]

mfelsche

The basic steps are here
```
install https://marketplace.visualstudio.com/items?itemName=npruehs.pony <- for syntax colors
install https://marketplace.visualstudio.com/items?itemName=vadimcn.vscode-lldb <- for debugging

#vscode settings should have :
    "debug.allowBreakpointsEverywhere": true

#(for example ) create an  ./examples/.vscode/launch.json file under the pony examples directory with:
{