goat: more plc dump args/ergonomics (#1053)

Will probably self-merge.

plc.go

···
 
 	"github.com/bluesky-social/indigo/atproto/identity"
 	"github.com/bluesky-social/indigo/atproto/syntax"
+	"github.com/bluesky-social/indigo/util"
 
 	"github.com/urfave/cli/v2"
 )
···
 			Usage: "output full operation log, as JSON lines",
 			Flags: []cli.Flag{
 				&cli.StringFlag{
-					Name: "cursor",
+					Name:    "cursor",
+					Aliases: []string{"c"},
+					Usage:   "start at a given cursor offset (timestamp). use 'now' to start at current time",
 				},
 				&cli.BoolFlag{
-					Name: "tail",
+					Name:    "tail",
+					Aliases: []string{"f"},
+					Usage:   "continue streaming PLC ops after reaching the end of log",
+				},
+				&cli.DurationFlag{
+					Name:    "interval",
+					Aliases: []string{"i"},
+					Value:   3 * time.Second,
+					Usage:   "sleep duration between batches for tail mode",
+				},
+				&cli.IntFlag{
+					Name:    "batch-size",
+					Aliases: []string{"s"},
+					Value:   1000,
+					Usage:   "batch size of operations per HTTP API request",
 				},
 			},
 			Action: runPLCDump,
···
 func runPLCDump(cctx *cli.Context) error {
 	ctx := context.Background()
 	plcHost := cctx.String("plc-host")
-	client := http.DefaultClient
+	client := util.RobustHTTPClient()
+	size := cctx.Int("batch-size")
 	tailMode := cctx.Bool("tail")
+	interval := cctx.Duration("interval")
 
 	cursor := cctx.String("cursor")
 	if cursor == "now" {
···
 		return err
 	}
 	q := req.URL.Query()
-	q.Add("count", "1000")
+	q.Add("count", fmt.Sprintf("%d", size))
 	req.URL.RawQuery = q.Encode()
 
 	for {
···
 		lines := strings.Split(string(respBytes), "\n")
 		if len(lines) == 0 || (len(lines) == 1 && len(lines[0]) == 0) {
 			if tailMode {
-				time.Sleep(5 * time.Second)
+				time.Sleep(interval)
 				continue
 			}
 			break
···
 		}
 		if cursor != "" && cursor == lastCursor {
 			if tailMode {
-				time.Sleep(5 * time.Second)
+				time.Sleep(interval)
 				continue
 			}
 			break