certusone
/
dc4bc
mirror of https://github.com/certusone/dc4bc.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

fix dc4bc_d

This commit is contained in:
programmer10110 2020-10-19 15:01:17 +03:00
parent 703b30d0ae
commit 834eba6e06
1 changed files with 10 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
cmd/dc4bc_d/main.go
View File

@ -94,15 +94,15 @@ func startClientCommand() *cobra.Command {
log.Fatalf("failed to read configuration: %v", err)
}
//storageDBDSN, err := cmd.Flags().GetString(flagStorageDBDSN)
//if err != nil {
// log.Fatalf("failed to read configuration: %v", err)
//}
//
//storageTopic, err := cmd.Flags().GetString(flagStorageTopic)
//if err != nil {
// log.Fatalf("failed to read configuration: %v", err)
//}
storageDBDSN, err := cmd.Flags().GetString(flagStorageDBDSN)
if err != nil {
log.Fatalf("failed to read configuration: %v", err)
}
storageTopic, err := cmd.Flags().GetString(flagStorageTopic)
if err != nil {
log.Fatalf("failed to read configuration: %v", err)
}
keyStoreDBDSN, err := cmd.Flags().GetString(flagStoreDBDSN)
if err != nil {
@ -117,8 +117,7 @@ func startClientCommand() *cobra.Command {
log.Fatalf("Failed to init state client: %v", err)
}
//stg, err := storage.NewKafkaStorage(ctx, storageDBDSN, storageTopic)
stg, err := storage.NewFileStorage("/tmp/dc4bc_storage")
stg, err := storage.NewKafkaStorage(ctx, storageDBDSN, storageTopic)
if err != nil {
log.Fatalf("Failed to init storage client: %v", err)
}