improvement: Add wait option to Statements.Insert and testcase.

.github/workflows/reviewdog.yml

@@ -0,0 +1,27 @@
+name: reviewdog on Pull Request
+on: [pull_request]
+jobs:
+  golangci-lint:
+    name: runner / golangci-lint
+    runs-on: ubuntu-latest
+    steps:
+      - name: Check out code into the Go module directory
+        uses: actions/checkout@v1
+      - name: golangci-lint
+        uses: reviewdog/action-golangci-lint@v1
+        with:
+          github_token: ${{ secrets.github_token }}
+          golangci_lint_flags: "--enable-all --exclude-use-default=false"
+          reporter: github-check
+
+  misspell:
+    name: runner / misspell
+    runs-on: ubuntu-latest
+    steps:
+      - name: Check out code.
+        uses: actions/checkout@v1
+      - name: misspell
+        uses: reviewdog/action-misspell@v1
+        with:
+          github_token: ${{ secrets.github_token }}
+          reporter: github-check

.gitignore

@@ -1,6 +1,9 @@
 .envrc
 .vscode
+.bin
+*.zip
 node_modules
+apache-livy-0.7.0-incubating-bin
 
 jars/target
 jars/project/target

.golangci.yml

@@ -0,0 +1,63 @@
+linters-settings:
+  golint:
+    # minimal confidence for issues, default is 0.8
+    min-confidence: 1.1
+
+  lll:
+    line-length: 180
+
+  funlen:
+    lines: 200
+    statements: 130
+  dupl:
+    threshold: 150
+  gocognit:
+    min-complexity: 40
+  errcheck:
+    # report about not checking of errors in type assertions: `a := b.(MyStruct)`;
+    # default is false: such cases aren't reported by default.
+    check-type-assertions: false
+
+    # report about assignment of errors to blank identifier: `num, _ := strconv.Atoi(numStr)`;
+    # default is false: such cases aren't reported by default.
+    check-blank: false
+
+    # [deprecated] comma-separated list of pairs of the form pkg:regex
+    # the regex is used to ignore names within pkg. (default "fmt:.*").
+    # see https://github.com/kisielk/errcheck#the-deprecated-method for details
+    ignore: "fmt:.*,os:.*,Close"
+
+linters:
+  disable:
+    - dupl
+    - maligned
+    - gochecknoglobals
+    - gomnd
+    - wsl
+    - godox
+    - gocyclo
+    - interfacer
+    - unconvert
+
+issues:
+  exclude-rules:
+    - path: _test\.go
+      linters:
+        - ineffassign
+        - gocyclo
+        - errcheck
+        - dupl
+        - gosec
+  # List of regexps of issue texts to exclude, empty list by default.
+  # But independently from this option we use default exclude patterns,
+  # it can be disabled by `exclude-use-default: false`. To list all
+  # excluded by default patterns execute `golangci-lint run --help`
+  exclude:
+      - should have comment or be unexported
+      - S1000
+      - ST1000
+      - ST1003
+      - ST1020
+      - ST1021
+      - G304
+      - G402

Makefile

@@ -0,0 +1,10 @@
+
+livy.install:
+	wget -q -O tmp.zip http://ftp.kddilabs.jp/infosystems/apache/incubator/livy/0.7.0-incubating/apache-livy-0.7.0-incubating-bin.zip && unzip tmp.zip && rm -f tmp.zip
+
+livy.start:
+	apache-livy-0.7.0-incubating-bin/bin/livy-server start
+
+livy.stop:
+	apache-livy-0.7.0-incubating-bin/bin/livy-server stop
+

README.md

@@ -1 +1,20 @@
 # livy-go
+
+## Getting Started
+
+### Livy Setup
+
+1. livy install
+```
+make livy.install
+```
+
+2. livy start
+```
+make livy.start
+```
+
+3. livy stop
+```
+make livy.stop
+```

batch.go

@@ -4,8 +4,6 @@ import (
 	"fmt"
 	"io"
 	"net/http"
-
-	"github.com/3-shake/livy-go/gensupport"
 )
 
 type BatchesService struct {
@@ -47,7 +45,7 @@ func (c *BatchesListCall) Do() (*Batches, error) {
 	}
 
 	batches := &Batches{}
-	err = gensupport.DecodeResponse(batches, res)
+	err = DecodeResponse(batches, res)
 	if err != nil {
 		return nil, err
 	}
@@ -62,7 +60,7 @@ func (c *BatchesListCall) doRequest() (*http.Response, error) {
 		return nil, err
 	}
 
-	return gensupport.SendRequest(c.s.client, req)
+	return SendRequest(c.s.client, req)
 }
 
 type BatchesGetCall struct {
@@ -84,7 +82,7 @@ func (c *BatchesGetCall) Do() (*Batch, error) {
 	}
 
 	batch := &Batch{}
-	err = gensupport.DecodeResponse(batch, res)
+	err = DecodeResponse(batch, res)
 	if err != nil {
 		return nil, err
 	}
@@ -99,7 +97,7 @@ func (c *BatchesGetCall) doRequest() (*http.Response, error) {
 		return nil, err
 	}
 
-	return gensupport.SendRequest(c.s.client, req)
+	return SendRequest(c.s.client, req)
 }
 
 type BatchState struct {
@@ -126,7 +124,7 @@ func (c *BatchesStateCall) Do() (*BatchState, error) {
 	}
 
 	state := &BatchState{}
-	err = gensupport.DecodeResponse(state, res)
+	err = DecodeResponse(state, res)
 	if err != nil {
 		return nil, err
 	}
@@ -141,7 +139,7 @@ func (c *BatchesStateCall) doRequest() (*http.Response, error) {
 		return nil, err
 	}
 
-	return gensupport.SendRequest(c.s.client, req)
+	return SendRequest(c.s.client, req)
 }
 
 type BatchesDeleteCall struct {
@@ -176,7 +174,7 @@ func (c *BatchesDeleteCall) doRequest() (*http.Response, error) {
 		return nil, err
 	}
 
-	return gensupport.SendRequest(c.s.client, req)
+	return SendRequest(c.s.client, req)
 }
 
 type BatchLogResponse struct {
@@ -208,7 +206,7 @@ func (c *BatchesLogCall) Do() (*BatchLogResponse, error) {
 
 	batchLog := &BatchLogResponse{}
 
-	err = gensupport.DecodeResponse(batchLog, res)
+	err = DecodeResponse(batchLog, res)
 	if err != nil {
 		return nil, err
 	}
@@ -225,5 +223,5 @@ func (c *BatchesLogCall) doRequest() (*http.Response, error) {
 		return nil, err
 	}
 
-	return gensupport.SendRequest(c.s.client, req)
+	return SendRequest(c.s.client, req)
 }