Aaronontheweb

// -----------------------------------------------------------------------
//  <copyright file="GenericChildPerEntityParent.cs" company="Akka.NET Project">
//      Copyright (C) 2015-2023 .NET Petabridge, LLC
//  </copyright>
// -----------------------------------------------------------------------

using Akka.Actor;
using Akka.Cluster.Sharding;

namespace Sdkbin.NuGet.Actors.Utility;

Aaronontheweb

apiVersion: v1
kind: Service
metadata:
  name: grafana-loadbalancer
  namespace: observability
spec:
  type: LoadBalancer
  selector:
    app.kubernetes.io/name: grafana
  ports:

Aaronontheweb

#!/bin/bash

# create the docker data drive
mkdir /mnt/docker-base

# allow the root service account, which docker runs as, to own this directory and have write permissions
chown -R root:root /mnt/docker-base
chmod 701 /mnt/docker-base

# create a `daemon.json` file for the docker runtime

Aaronontheweb

Engineering Spec

💡 Use this template to help structure new engineering projects into specifications. Make sure you attach this spec to the right project - if it’s not a flagship technology then it goes under "Other Projects"

Abstract

Problem statement - what is the nature of the issue we’re going to try to solve with this specification?

Aaronontheweb

Install .NET 8 on Raspberry pi

Install .NET via the following script:

• https://learn.microsoft.com/en-us/dotnet/core/tools/dotnet-install-script

1. Perform dry run and review envvar DOTNET_INSTALL_DIR

I advise to first do a dry run and to enable verbose mode to review if envvar DOTNET_INSTALL_DIR is set correctly:

Aaronontheweb

async Task Main()
{
	var actorSystem = ActorSystem.Create("Sys");

	var persistentActor = actorSystem.ActorOf<ExamplePersistentActor>("exampleActor");
	var watch = persistentActor.WatchAsync();

	// Sending multiple "save" commands to create snapshots
	persistentActor.Tell("save-1");
	await Task.Delay(TimeSpan.FromSeconds(1)); // spacing out snapshots, time-wise

Aaronontheweb

version: '3.7'

services:
  jaeger:
    image: jaegertracing/all-in-one:1.55
    hostname: jaeger
    restart: always
    ports:
      - '16686:16686'
      - '5775:5775/udp'

Aaronontheweb

 Command<ProjectionStarting>(_ =>
        {
            // TODO: seeing multiple of these being logged, which makes me think there's a problem with our Akka.Streams graph
            _log.Info("Projection for Tag [{0}] is starting from Offset [{1}] - instance [{2}] rand [{3}]", NuGetPersistenceTags.NuGetProductTag,
                CurrentState.LastOffset.AsLong(), Self.Path.Uid, Random.Shared.Next());
            Sender.Tell(ProjectionAck.Instance);
        });

        Command<ProjectionCompleted>(_ =>
        {

Aaronontheweb

// requires the `Akka` NuGet package to be installed in the query

int entitiesPerNodeFactor = 100;
List<string> nodes = Enumerable.Range(0, 10).Select(c => $"hostname-{c}").ToList();
Dictionary<string, int> entityToNodeAllocations = nodes.ToDictionary(c => c, k => 0);

var entityIds = Enumerable.Range(0, nodes.Count * entitiesPerNodeFactor).Select(e => $"entity-{e}");

foreach(var e in entityIds){
	var hashCode = MurmurHash.StringHash(e);

Aaronontheweb

async Task Main()
{
	var actorSystem = ActorSystem.Create("Sys");
	
	var producerSettings = ProducerController.Settings.Create(actorSystem);
	using var cts = new CancellationTokenSource();
	var (queue, producerController) = StreamConstruction.CreateProducerStream<IMessageProtocol>(actorSystem, producerSettings, "myproducer", cts.Token);
	
	var myConsumer = actorSystem.ActorOf(Props.Create(() => new ConsumerActor(producerController)), "consumer");