guidoschmidt17’s gists

guidoschmidt17 / example_zpure_eventsourcing_1.scala

Last active March 21, 2023 16:29

	import zio.*
	import zio.prelude.*
	import zio.prelude.fx.*

	object BaseSyntax:

	type Program[S, R, E, A] = ZPure[Nothing, S, S, R, E, A]

	type LoggedProgram[W, S, R, E, A] = ZPure[W, S, S, R, E, A]

guidoschmidt17 / flamegraph_zpure_stresstest_4mio_elements_01.html

Created January 18, 2023 18:32

	<!DOCTYPE html>
	<html lang='en'>
	<head>
	<meta charset='utf-8'>
	<style>
	body {margin: 0; padding: 10px; background-color: #ffffff}
	h1 {margin: 5px 0 0 0; font-size: 18px; font-weight: normal; text-align: center}
	header {margin: -24px 0 5px 0; line-height: 24px}
	button {font: 12px sans-serif; cursor: pointer}
	p {margin: 5px 0 5px 0}

guidoschmidt17 / flamegraph_2_with_fix_to_fix_761.html

Created December 16, 2022 19:27

This file has been truncated, but you can view the full file.

	<!DOCTYPE html>
	<html lang='en'>
	<head>
	<meta charset='utf-8'>
	<style>
	body {margin: 0; padding: 10px; background-color: #ffffff}
	h1 {margin: 5px 0 0 0; font-size: 18px; font-weight: normal; text-align: center}
	header {margin: -24px 0 5px 0; line-height: 24px}
	button {font: 12px sans-serif; cursor: pointer}
	p {margin: 5px 0 5px 0}

guidoschmidt17 / flamegraph_2_with_fix_761.html

Created December 16, 2022 18:19

This file has been truncated, but you can view the full file.

	<!DOCTYPE html>
	<html lang='en'>
	<head>
	<meta charset='utf-8'>
	<style>
	body {margin: 0; padding: 10px; background-color: #ffffff}
	h1 {margin: 5px 0 0 0; font-size: 18px; font-weight: normal; text-align: center}
	header {margin: -24px 0 5px 0; line-height: 24px}
	button {font: 12px sans-serif; cursor: pointer}
	p {margin: 5px 0 5px 0}

guidoschmidt17 / readResultWithOffset_2.scala

Last active December 17, 2022 11:15

	...

	def loopResult(out: Queue[Take[StreamingError, B]], offsetRef: Ref[Long], n: Long) =

	def resultStream(offset: Long, limit: Long) =
	sessionPool
	.use(session => {
	session
	.prepare(query)
	.toScopedZIO

guidoschmidt17 / log_fs2stream_zioqueue_1.log

Last active December 16, 2022 09:51

	...
	handle 18d6aade:11 ReadFactsBySerialId(0,[],500) -> Accepted(TransportEncodedStream)
	before
	stream 500 500
	after
	handle 18d6aade:12 ReadFactsBySerialId(0,[],500) -> Accepted(TransportEncodedStream)
	before
	stream 64 64
	stream 128 64
	stream 192 64

guidoschmidt17 / readResultWithOffset_1.scala

Last active December 15, 2022 15:55

	def readResultWithOffset[A, B](
	check: Option[Query[A, Long]],
	query: Query[A ~ Long ~ Long, B],
	args: A,
	message: String,
	chunksize: Int,
	limit: Long = Long.MaxValue
	) =

	val checkResult =

guidoschmidt17 / stresstest_1.html

Created December 14, 2022 22:36

This file has been truncated, but you can view the full file.

	<!DOCTYPE html>
	<html lang='en'>
	<head>
	<meta charset='utf-8'>
	<style>
	body {margin: 0; padding: 10px; background-color: #ffffff}
	h1 {margin: 5px 0 0 0; font-size: 18px; font-weight: normal; text-align: center}
	header {margin: -24px 0 5px 0; line-height: 24px}
	button {font: 12px sans-serif; cursor: pointer}
	p {margin: 5px 0 5px 0}

guidoschmidt17 / SkunkWithZIO1.scala

Last active December 13, 2022 22:39

	package cqrs
	package eventstore
	package server

	import cats.effect.std.Console
	import fs2.io.net.SocketOption.*
	import natchez.Trace.Implicits.noop
	import skunk.Session
	import zio.*
	import zio.interop.catz.*

guidoschmidt17 / AbstractEventStore.scala

Created November 14, 2022 18:27

	package cqrs
	package eventstore
	package client

	import sttp.capabilities.WebSockets
	import sttp.capabilities.zio.ZioStreams
	import sttp.client3.*
	import sttp.model.Uri
	import sttp.ws.*
	import zio.*

Guido Schmidt guidoschmidt17