- Add the pulsar-cli-aliases.shfile content to your~/.bashrcor~/.zshrc.
- Fill pulsar_jwt,pulsar_url,pulsar_admin_urlwith your values.
- Then use short commands like pa topics stats public/default/topic-ainstead of
pulsar-admin \
| dev: | |
| quarkus dev | |
| jshell: | |
| #!/usr/bin/env jbang --jsh | |
| //DEPS com.github.javafaker:javafaker:1.0.2 | |
| var faker = new com.github.javafaker.Faker(); | |
| println(faker.nation().nationality()); | |
| java: | 
| const std = @import("std"); | |
| pub fn build(b: *std.Build) void { | |
| // Standard target options allows the person running `zig build` to choose | |
| // what target to build for. Here we do not override the defaults, which | |
| // means any target is allowed, and the default is native. Other options | |
| // for restricting supported target set are available. | |
| const target = b.standardTargetOptions(.{}); | |
| // Standard optimization options allow the person running `zig build` to select | 
| // Oto Brglez - <[email protected]> - May 2021 | |
| package com.pinkstack.gen4 | |
| import cats.effect.implicits._ | |
| import cats.effect.{ExitCode, IO, IOApp} | |
| import cats.implicits._ | |
| import com.pinkstack.gen1.CoinMarketCap.Implicits._ | |
| import com.pinkstack.gen1.CoinMarketCap._ | |
| import sttp.client3._ | |
| import sttp.client3.circe._ | 
| /* | |
| Copyright 2021 Jakub Kozłowski | |
| Licensed under the Apache License, Version 2.0 (the "License"); | |
| you may not use this file except in compliance with the License. | |
| You may obtain a copy of the License at | |
| http://www.apache.org/licenses/LICENSE-2.0 | |
| Unless required by applicable law or agreed to in writing, software | 
Most data serialization formats, like JSON, YAML, and EDN, feature a similar set of basic building blocks, namely:
I completely agree with the fact that those are basic building blocks for data inside any information system. However, as a Haskeller I always miss one additional part of my toolbox: variants. Variants are essentially tagged values which contain further values inside.
| default['sshd']['sshd_config']['AuthenticationMethods'] = 'publickey,keyboard-interactive:pam' | |
| default['sshd']['sshd_config']['ChallengeResponseAuthentication'] = 'yes' | |
| default['sshd']['sshd_config']['PasswordAuthentication'] = 'no' | 
| def switchMap[F[_]: Async, A, B](f: A => Stream[F, B]): Pipe[F, A, B] = { | |
| def go( | |
| outer: ScopedFuture[F, Pull[F, Nothing, (NonEmptyChunk[A], Handle[F, A])]], | |
| inner: ScopedFuture[F, Pull[F, Nothing, (NonEmptyChunk[B], Handle[F, B])]] | |
| ): Pull[F, B, Nothing] = { | |
| (outer race inner).pull.flatMap { | |
| case Left(outer) => | |
| outer.optional.flatMap { | |
| case None => | |
| inner.pull.flatMap(identity).flatMap { case (hd, tl) => Pull.output(hd) >> tl.echo } |