(cmd *cobra.Command, args []string)
| 333 | } |
| 334 | |
| 335 | func runShardWrite(cmd *cobra.Command, args []string) { |
| 336 | setupLogger() |
| 337 | |
| 338 | ds := initDataShard() |
| 339 | |
| 340 | bs := readInputBytes() |
| 341 | |
| 342 | commit := common.HexToHash(*commitString) |
| 343 | encodingKey := es.CalcEncodeKey(commit, *kvIdx, ds.Miner()) |
| 344 | log.Info("Write info", "commit", commit, "encodingKey", encodingKey) |
| 345 | |
| 346 | err := ds.Write(*kvIdx, bs, commit) |
| 347 | if err != nil { |
| 348 | log.Crit("Write failed", "error", err) |
| 349 | } |
| 350 | log.Info("Write value", "kvIdx", *kvIdx, "bytes", len(bs)) |
| 351 | } |
| 352 | |
| 353 | func runSampleRead(cmd *cobra.Command, args []string) { |
| 354 | setupLogger() |
nothing calls this directly
no test coverage detected