example.go

1client := shared.NewPicoPipeClient(ctx, logger)
2drain := client.sub("container-drain -k")
3send := client.pub("metric-drain -b=false")