calvinlfer

package io.kaizensolutions.virgil.nextlevel

import io.kaizensolutions.virgil.nextlevel.nextlevel.peopleTable

object nextlevel {

  sealed trait Table {
    type TableTag
  }
  object Table {

calvinlfer

#!/bin/sh

scala-cli --power package --native-image -f *.scala -o ziohttp.bin -- --no-fallback --enable-url-protocols=http,https -Djdk.http.auth.tunneling.disabledSchemes= --install-exit-handlers --enable-http --initialize-at-run-time=io.netty.channel.DefaultFileRegion --initialize-at-run-time=io.netty.channel.epoll.Native --initialize-at-run-time=io.netty.channel.epoll.Epoll --initialize-at-run-time=io.netty.channel.epoll.EpollEventLoop --initialize-at-run-time=io.netty.channel.epoll.EpollEventArray --initialize-at-run-time=io.netty.channel.kqueue.KQueue --initialize-at-run-time=io.netty.channel.kqueue.KQueueEventLoop --initialize-at-run-time=io.netty.channel.kqueue.KQueueEventArray --initialize-at-run-time=io.netty.channel.kqueue.Native --initialize-at-run-time=io.netty.channel.unix.Limits --initialize-at-run-time=io.netty.channel.unix.Errors --initialize-at-run-time=io.netty.channel.unix.IovArray --initialize-at-run-time=io.netty.handler.codec.compression.ZstdOptions --initialize-at-run-time=io.netty.incub

calvinlfer

package io.kaizensolutions.trace4cats.zio.extras.ziohttp.server

import trace4cats.ErrorHandler
import trace4cats.model.AttributeValue.{LongValue, StringValue}
import trace4cats.model.SemanticAttributeKeys.*
import trace4cats.model.{AttributeValue, SpanKind, SpanStatus}
import io.kaizensolutions.trace4cats.zio.extras.ZTracer
import io.kaizensolutions.trace4cats.zio.extras.ziohttp.{extractTraceHeaders, toSpanStatus}
import zio.*
import zio.http.*

calvinlfer

  def joinLManyR[Err, LeftElem, LeftKey, MiddleElem, MiddleKey, RightElem, RightKey, RightProjection](left: Iterable[LeftKey])(
    middle: Iterable[LeftKey] => Stream[Err, MiddleElem]
  )(middleKey: MiddleElem => MiddleKey)(middleToLeftKey: MiddleElem => LeftKey)(middleToRightKey: MiddleElem => RightKey)(
    right: Iterable[RightKey] => Stream[Err, RightElem]
  )(rightKey: RightElem => RightKey)(rightProjection: RightElem => RightProjection): IO[Err, Map[LeftKey, Set[RightProjection]]] =
    val extractMiddle: IO[Err, Chunk[MiddleElem]] = middle(left).runCollect

    def rightElems(in: Iterable[RightKey]): IO[Err, Chunk[RightElem]] =
      right(in).runCollect

calvinlfer

import skunk.Codec
import skunk.data.Type
import zio.ZIOAppDefault

import java.time.{OffsetDateTime, ZonedDateTime}
import java.time.format.{DateTimeFormatter, DateTimeFormatterBuilder, DateTimeParseException}
import java.time.temporal.ChronoField.*
import java.util.Locale

// TODO: account for closed and open intervals so like [x,y), (x,y), etc.

calvinlfer

version: "3.9"

services:
  zookeeper:
    restart: unless-stopped
    image: ubuntu/zookeeper:latest
    ports:
      - "2181:2181"

  kafka:

calvinlfer

object Experiment extends ZIOAppDefault {
  /**
  Collect elements and emit them in single chunks of 100
  */
  val aggregate: ZPipeline[Any, Nothing, Int, Long] = {
    def go[Err](acc: Long): ZChannel[Any, Err, Chunk[Int], Any, Err, Chunk[Long], Any] =
      ZChannel.readWith[Any, Err, Chunk[Int], Any, Err, Chunk[Long], Any](
        in = { inChunk =>
          val next = acc + inChunk.sum
          if (next > 100L) {

calvinlfer

A build process for GraalVM native images that can be deployed on AWS Lambda as Docker container images

Use zio-lambda to write your own Lambda function based on Scala and ZIO

• Checkout the example project for inspiration
• Make sure you enable the GraalVMNativeImagePlugin like the example project does and configure it with the appropriate flags to build the native image
• You may most likely need to add some reflect configuration and this post from Inner Product shows a good way to include the configuration in the project so Graal native-image will find it

If you have graal native already installed with the correct libraries in place for linking then great, otherwise use one of the following Docker images tagged with graalvm

**NOTE

calvinlfer

import java.io.{BufferedReader, FileReader}

final case class CStream[-R, +E, +A](
  private val process: ZManaged[R, Nothing, ZIO[R, Option[E], Chunk[A]]]
) { self =>

  def take(n: Int): CStream[R, E, A] = {
    def go(rem: Ref[Int], pull: ZIO[R, Option[E], Chunk[A]]): ZIO[R, Option[E], Chunk[A]] =
      rem.get.flatMap {
        case n if n <= 0 => IO.fail(None)

calvinlfer

package dev.zio.schema.example.example8.advanced

import dev.zio.schema.example.example8.Json
import zio.Chunk
import zio.schema.{Schema, StandardType}

import java.util.UUID
import scala.collection.immutable.ListMap

trait FasterDecoder[A] { self =>