LBRYFoundation/reflector.go
1
0
Fork 0
mirror of https://github.com/LBRYFoundation/reflector.go.git synced 2025-08-23 17:27:25 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

temporarily disable reflector and db

Browse source
This commit is contained in:
Alex Grintsvayg 2019-06-25 13:08:35 -04:00
parent ad1eea1e8e
commit fb2f807e6a
No known key found for this signature in database
GPG key ID: AEB3F089F86A22B5
1 changed files with 15 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

32
cmd/reflector.go
View file

@ -3,14 +3,12 @@ package cmd
import (
"os"
"os/signal"
"strconv"
"syscall"
"time"
"github.com/lbryio/reflector.go/db"
"github.com/lbryio/reflector.go/meta"
"github.com/lbryio/reflector.go/peer"
"github.com/lbryio/reflector.go/reflector"
"github.com/lbryio/reflector.go/store"
log "github.com/sirupsen/logrus"
@ -35,22 +33,22 @@ func reflectorCmd(cmd *cobra.Command, args []string) {
}
s3 := store.NewS3BlobStore(globalConfig.AwsID, globalConfig.AwsSecret, globalConfig.BucketRegion, globalConfig.BucketName)
combo := store.NewDBBackedS3Store(s3, db)
//combo := store.NewDBBackedS3Store(s3, db)
reflectorServer := reflector.NewServer(combo)
reflectorServer.Timeout = 3 * time.Minute
if globalConfig.SlackHookURL != "" {
reflectorServer.StatLogger = log.StandardLogger()
reflectorServer.StatReportFrequency = 1 * time.Hour
}
reflectorServer.EnableBlocklist = true
//reflectorServer := reflector.NewServer(combo)
//reflectorServer.Timeout = 3 * time.Minute
//if globalConfig.SlackHookURL != "" {
// reflectorServer.StatLogger = log.StandardLogger()
// reflectorServer.StatReportFrequency = 1 * time.Hour
//}
//reflectorServer.EnableBlocklist = true
//
//err = reflectorServer.Start(":" + strconv.Itoa(reflector.DefaultPort))
//if err != nil {
// log.Fatal(err)
//}
err = reflectorServer.Start(":" + strconv.Itoa(reflector.DefaultPort))
if err != nil {
log.Fatal(err)
}
peerServer := peer.NewServer(combo)
peerServer := peer.NewServer(s3)
if globalConfig.SlackHookURL != "" {
peerServer.StatLogger = log.StandardLogger()
peerServer.StatReportFrequency = 1 * time.Hour
@ -64,5 +62,5 @@ func reflectorCmd(cmd *cobra.Command, args []string) {
signal.Notify(interruptChan, os.Interrupt, syscall.SIGTERM)
<-interruptChan
peerServer.Shutdown()
reflectorServer.Shutdown()
//reflectorServer.Shutdown()
}