A generic pubsub implementation for Go.
package main
import (
"bytes"
"context"
"fmt"
"log/slog"
"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")
_ = broker.Pub(ctx, "pubID", writer, chann, false)
}()
reader := bytes.NewBufferString("")
_ = broker.Sub(ctx, "subID", reader, chann, false)
// result
fmt.Println("data from pub:", reader)
}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