}
eventSource := &pgEventSource{
- PgConfig: cfg.Postgres,
- QueueSize: cfg.ServerEventQueue,
+ DataSource: cfg.Postgres.ConnectionString(),
+ QueueSize: cfg.ServerEventQueue,
}
srv := &http.Server{
Addr: cfg.Listen,
},
}
eventSource.NewSink().Stop()
+
+ log.Printf("listening at %s", srv.Addr)
log.Fatal(srv.ListenAndServe())
}