pubsub

A generic pubsub implementation for Go.

package main

import (
	"bytes"
	"context"
	"fmt"
	"log/slog"

	"github.com/google/uuid"
	"github.com/picosh/pubsub"
)

func main() {
	ctx := context.TODO()
	logger := slog.Default()
	broker := pubsub.NewMulticast(logger)

	chann := []*pubsub.Channel{
		pubsub.NewChannel("my-topic"),
	}

	go func() {
		writer := bytes.NewBufferString("my data")
		pubID := uuid.NewString()
		broker.Pub(ctx, pubID, writer, chann, false)
	}()

	reader := bytes.NewBufferString("")
	subID := uuid.NewString()
	broker.Sub(ctx, subID, reader, chann, false)

	// result
	fmt.Println("data from pub:", reader)
}

pubsub over ssh

The simplest pubsub system for everyday automation needs.

Using wish we can integrate our pubsub system into an SSH app.

# term 1
mkdir ./ssh_data
cat ~/.ssh/id_ed25519 ./ssh_data/authorized_keys
go run ./cmd/example

# term 2
ssh -p 2222 localhost sub xyz

# term 3
echo "hello world" | ssh -p 2222 localhost pub xyz