diff --git a/events/events.go b/events/events.go new file mode 100644 index 0000000..491f4dc --- /dev/null +++ b/events/events.go @@ -0,0 +1,3 @@ +package events + +type Event struct{} diff --git a/pubsub/pubsub.go b/pubsub/pubsub.go new file mode 100644 index 0000000..c039279 --- /dev/null +++ b/pubsub/pubsub.go @@ -0,0 +1,19 @@ +package pubsub + +import ( + "context" + "sync" + + "github.com/edouardparis/lntop/app" + "github.com/edouardparis/lntop/events" + "github.com/edouardparis/lntop/logging" +) + +func Run(ctx context.Context, app *app.App, sub chan *events.Event) error { + logger := app.Logger.With(logging.String("logger", "pubsub")) + wg := &sync.WaitGroup{} + + logger.Debug("Starting...") + wg.Wait() + return nil +}