Install .NET via the following script:
I advise to first do a dry run and to enable verbose mode to review if envvar DOTNET_INSTALL_DIR
is set correctly:
apiVersion: v1 | |
kind: Service | |
metadata: | |
name: grafana-loadbalancer | |
namespace: observability | |
spec: | |
type: LoadBalancer | |
selector: | |
app.kubernetes.io/name: grafana | |
ports: |
#!/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 |
Install .NET via the following script:
I advise to first do a dry run and to enable verbose mode to review if envvar DOTNET_INSTALL_DIR
is set correctly:
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 |
version: '3.7' | |
services: | |
jaeger: | |
image: jaegertracing/all-in-one:1.55 | |
hostname: jaeger | |
restart: always | |
ports: | |
- '16686:16686' | |
- '5775:5775/udp' |
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>(_ => | |
{ |
// ----------------------------------------------------------------------- | |
// <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; |
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"); | |
$processNameContains = "func" | |
try { | |
# Get all processes where the name contains 'func' | |
$processesToKill = Get-Process | Where-Object { $_.ProcessName -like "*$processNameContains*" } | |
# Check if there are any processes to kill | |
if ($processesToKill) { | |
# Kill each process | |
foreach ($process in $processesToKill) { |
using Akka.Actor; | |
using System.Threading.Tasks; | |
public sealed class MyActor : ReceiveActor{ | |
public MyActor(){ | |
Receive<string>(str => { | |
async Task<int> LocalFunction(){ | |
await Task.Delay(10); | |
return str.Length; |