Skip to content

Commit de3c6b7

Browse files
authored
Usability fixe (#7)
- If web API URL has no scheme, default to http - Print record being written into stream
1 parent 514da74 commit de3c6b7

File tree

2 files changed

+10
-0
lines changed

2 files changed

+10
-0
lines changed

pkg/v3ctl/root.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@ package v3ctl
22

33
import (
44
"os"
5+
"strings"
56
"sync"
67

78
"github.com/nuclio/errors"
@@ -45,6 +46,9 @@ func NewRootCommandeer() (*RootCommandeer, error) {
4546
}
4647

4748
defaultV3ioServer := os.Getenv("V3IO_API")
49+
if !strings.HasPrefix(defaultV3ioServer, "http") {
50+
defaultV3ioServer = "http://" + defaultV3ioServer
51+
}
4852

4953
cmd.PersistentFlags().StringVarP(&commandeer.logLevel, "log-level", "v", "info",
5054
`Verbose output. Add "=<level>" to set the log level -

pkg/v3ctl/stream/createrecord.go

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
package stream
22

33
import (
4+
"fmt"
45
"strings"
56

67
"github.com/nuclio/errors"
@@ -61,6 +62,11 @@ func newCreateRecordCommandeer(createStreamCommandeer *createStreamCommandeer) (
6162

6263
defer response.Release()
6364

65+
fmt.Printf("Wrote %d bytes to %s:%d\n",
66+
len(commandeer.data),
67+
streamPath,
68+
commandeer.shardID)
69+
6470
return nil
6571
},
6672
}

0 commit comments

Comments
 (0)