From fae0c61f6e451ccb888db06ae740c0a549ae3ed7 Mon Sep 17 00:00:00 2001 From: Edouard Paris Date: Tue, 26 Mar 2019 10:06:32 +0100 Subject: [PATCH] pubsub and events --- events/events.go | 3 +++ pubsub/pubsub.go | 19 +++++++++++++++++++ 2 files changed, 22 insertions(+) create mode 100644 events/events.go create mode 100644 pubsub/pubsub.go 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 +}