Skip to content

Commit

Permalink
init module
Browse files Browse the repository at this point in the history
  • Loading branch information
@michal-harish
michal-harish committed Aug 19, 2019
1 parent 0d71e2c commit 9c489d0
Show file tree
Hide file tree
Showing 69 changed files with 152 additions and 105 deletions.
0 ...oc/coder/avro/avro.coder.fixtures/user.go → coder/avro/avro.coder.fixtures/user.go
View file
File renamed without changes.
2 changes: 1 addition & 1 deletion pkg/goc/coder/avro/decoder.go → coder/avro/decoder.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ package avro
import (
"encoding/binary"
"github.com/amient/avro"
"github.com/amient/goconnect/pkg/goc"
"github.com/amient/goconnect"
"reflect"
)

Expand Down
2 changes: 1 addition & 1 deletion pkg/goc/coder/avro/encoder.go → coder/avro/encoder.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ import (
"bytes"
"encoding/binary"
"github.com/amient/avro"
"github.com/amient/goconnect/pkg/goc"
"github.com/amient/goconnect"
"reflect"
)

Expand Down
0 pkg/goc/coder/avro/projector.go → coder/avro/projector.go
View file
File renamed without changes.
0 pkg/goc/coder/avro/types.go → coder/avro/types.go
View file
File renamed without changes.
2 changes: 1 addition & 1 deletion pkg/goc/coder/gzip/decoder.go → coder/gzip/decoder.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ package gzip
import (
"bytes"
"compress/gzip"
"github.com/amient/goconnect/pkg/goc"
"github.com/amient/goconnect"
"reflect"
)

Expand Down
0 pkg/goc/coder/gzip/encoder.go → coder/gzip/encoder.go
View file
File renamed without changes.
2 changes: 1 addition & 1 deletion pkg/goc/coder/kv/decoder.go → coder/kv/decoder.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@
package kv

import (
"github.com/amient/goconnect/pkg/goc"
"github.com/amient/goconnect"
"reflect"
)

Expand Down
2 changes: 1 addition & 1 deletion pkg/goc/coder/kv/encoder.go → coder/kv/encoder.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@
package kv

import (
"github.com/amient/goconnect/pkg/goc"
"github.com/amient/goconnect"
"reflect"
)

Expand Down
10 changes: 5 additions & 5 deletions pkg/goc/coder/registry.go → coder/registry.go
View file
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@
package coder

import (
"github.com/amient/goconnect/pkg/goc"
"github.com/amient/goconnect/pkg/goc/coder/kv"
"github.com/amient/goconnect/pkg/goc/coder/str"
"github.com/amient/goconnect/pkg/goc/coder/url"
"github.com/amient/goconnect/pkg/goc/coder/xml"
"github.com/amient/goconnect"
"github.com/amient/goconnect/coder/kv"
"github.com/amient/goconnect/coder/str"
"github.com/amient/goconnect/coder/url"
"github.com/amient/goconnect/coder/xml"
)

func Registry() []goc.Transform {
Expand Down
2 changes: 1 addition & 1 deletion pkg/goc/coder/str/decoder.go → coder/str/decoder.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@
package str

import (
"github.com/amient/goconnect/pkg/goc"
"github.com/amient/goconnect"
"reflect"
)

Expand Down
2 changes: 1 addition & 1 deletion pkg/goc/coder/str/encoder.go → coder/str/encoder.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@
package str

import (
"github.com/amient/goconnect/pkg/goc"
"github.com/amient/goconnect"
"reflect"
)

Expand Down
2 changes: 1 addition & 1 deletion pkg/goc/coder/str/splitter.go → coder/str/splitter.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@
package str

import (
"github.com/amient/goconnect/pkg/goc"
"github.com/amient/goconnect"
"reflect"
"strings"
)
Expand Down
4 changes: 2 additions & 2 deletions pkg/goc/coder/url/decoder.go → coder/url/decoder.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -22,8 +22,8 @@ package url
import (
"bytes"
"encoding/binary"
"github.com/amient/goconnect/pkg/goc"
"github.com/amient/goconnect/pkg/goc/util"
"github.com/amient/goconnect"
"github.com/amient/goconnect/util"
"reflect"
)

Expand Down
4 changes: 2 additions & 2 deletions pkg/goc/coder/url/encoder.go → coder/url/encoder.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -22,8 +22,8 @@ package url
import (
"bytes"
"encoding/binary"
"github.com/amient/goconnect/pkg/goc"
"github.com/amient/goconnect/pkg/goc/util"
"github.com/amient/goconnect"
"github.com/amient/goconnect/util"
"reflect"
)

Expand Down
0 pkg/goc/coder/url/url.go → coder/url/url.go
View file
File renamed without changes.
0 pkg/goc/coder/xml/NOTICE → coder/xml/NOTICE
View file
File renamed without changes.
2 changes: 1 addition & 1 deletion pkg/goc/coder/xml/decoder.go → coder/xml/decoder.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@ package xml

import (
"bytes"
"github.com/amient/goconnect/pkg/goc"
"github.com/amient/goconnect"
"reflect"
)

Expand Down
2 changes: 1 addition & 1 deletion pkg/goc/coder/xml/encoder.go → coder/xml/encoder.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ package xml
import (
"bufio"
"bytes"
"github.com/amient/goconnect/pkg/goc"
"github.com/amient/goconnect"
"reflect"
)

Expand Down
0 pkg/goc/coder/xml/node.go → coder/xml/node.go
View file
File renamed without changes.
0 pkg/goc/coder/xml/reader.go → coder/xml/reader.go
View file
File renamed without changes.
2 changes: 1 addition & 1 deletion pkg/goc/coder/xml/writer.go → coder/xml/writer.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@ package xml

import (
"fmt"
"github.com/amient/goconnect/pkg/goc/util"
"github.com/amient/goconnect/util"
"io"
)

Expand Down
2 changes: 1 addition & 1 deletion pkg/goc/context.go → context.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
* limitations under the License.
*/

package goc
package goconnect

import (
"fmt"
Expand Down
2 changes: 1 addition & 1 deletion pkg/goc/def.go → def.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
* limitations under the License.
*/

package goc
package goconnect

import (
"reflect"
Expand Down
2 changes: 1 addition & 1 deletion pkg/goc/element.go → element.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
* limitations under the License.
*/

package goc
package goconnect

/**
Checkpoint is a map of int identifiers and values. The identifiers are specific to each transform, some
Expand Down
8 changes: 4 additions & 4 deletions examples/amqp-kafka/main.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -21,10 +21,10 @@ package main

import (
"flag"
"github.com/amient/goconnect/pkg/goc"
"github.com/amient/goconnect/pkg/goc/coder"
"github.com/amient/goconnect/pkg/goc/io/amqp09"
"github.com/amient/goconnect/pkg/goc/io/kafka1"
"github.com/amient/goconnect"
"github.com/amient/goconnect/coder"
"github.com/amient/goconnect/io/amqp09"
"github.com/amient/goconnect/io/kafka1"
"github.com/confluentinc/confluent-kafka-go/kafka"
)

Expand Down
8 changes: 4 additions & 4 deletions examples/kafka-count-stdout/main.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -21,10 +21,10 @@ package main

import (
"flag"
"github.com/amient/goconnect/pkg/goc"
"github.com/amient/goconnect/pkg/goc/coder"
"github.com/amient/goconnect/pkg/goc/io/kafka1"
"github.com/amient/goconnect/pkg/goc/io/std"
"github.com/amient/goconnect"
"github.com/amient/goconnect/coder"
"github.com/amient/goconnect/io/kafka1"
"github.com/amient/goconnect/io/std"
"github.com/confluentinc/confluent-kafka-go/kafka"
"time"
)
Expand Down
10 changes: 5 additions & 5 deletions examples/kafka-custom-avro-stdout/main.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -23,11 +23,11 @@ import (
"flag"
"fmt"
"github.com/amient/goconnect/examples/kafka-custom-avro-stdout/io.amient.kafka.metrics"
"github.com/amient/goconnect/pkg/goc"
"github.com/amient/goconnect/pkg/goc/coder"
"github.com/amient/goconnect/pkg/goc/coder/avro"
"github.com/amient/goconnect/pkg/goc/io/kafka1"
"github.com/amient/goconnect/pkg/goc/io/std"
"github.com/amient/goconnect"
"github.com/amient/goconnect/coder"
"github.com/amient/goconnect/coder/avro"
"github.com/amient/goconnect/io/kafka1"
"github.com/amient/goconnect/io/std"
"github.com/confluentinc/confluent-kafka-go/kafka"
"reflect"
)
Expand Down
6 changes: 3 additions & 3 deletions examples/kafka-kafka/main.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -21,9 +21,9 @@ package main

import (
"flag"
"github.com/amient/goconnect/pkg/goc"
"github.com/amient/goconnect/pkg/goc/coder"
"github.com/amient/goconnect/pkg/goc/io/kafka1"
"github.com/amient/goconnect"
"github.com/amient/goconnect/coder"
"github.com/amient/goconnect/io/kafka1"
"github.com/confluentinc/confluent-kafka-go/kafka"
)

Expand Down
10 changes: 5 additions & 5 deletions examples/kafka-sr-avro-json-sqs/main.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -21,11 +21,11 @@ package main

import (
"flag"
"github.com/amient/goconnect/pkg/goc"
"github.com/amient/goconnect/pkg/goc/coder"
"github.com/amient/goconnect/pkg/goc/coder/avro"
"github.com/amient/goconnect/pkg/goc/io/kafka1"
"github.com/amient/goconnect/pkg/goc/io/std"
"github.com/amient/goconnect"
"github.com/amient/goconnect/coder"
"github.com/amient/goconnect/coder/avro"
"github.com/amient/goconnect/io/kafka1"
"github.com/amient/goconnect/io/std"
"github.com/confluentinc/confluent-kafka-go/kafka"
avrolib "github.com/amient/avro"
)
Expand Down
8 changes: 4 additions & 4 deletions examples/kafka-sr1-avro-sr2-kafka/main.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -21,10 +21,10 @@ package main

import (
"flag"
"github.com/amient/goconnect/pkg/goc"
"github.com/amient/goconnect/pkg/goc/coder"
"github.com/amient/goconnect/pkg/goc/coder/avro"
"github.com/amient/goconnect/pkg/goc/io/kafka1"
"github.com/amient/goconnect"
"github.com/amient/goconnect/coder"
"github.com/amient/goconnect/coder/avro"
"github.com/amient/goconnect/io/kafka1"
"github.com/confluentinc/confluent-kafka-go/kafka"
avrolib "github.com/amient/avro"
)
Expand Down
8 changes: 4 additions & 4 deletions examples/list-amqp/main.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -21,10 +21,10 @@ package main

import (
"flag"
"github.com/amient/goconnect/pkg/goc"
"github.com/amient/goconnect/pkg/goc/coder"
"github.com/amient/goconnect/pkg/goc/io"
"github.com/amient/goconnect/pkg/goc/io/amqp09"
"github.com/amient/goconnect"
"github.com/amient/goconnect/coder"
"github.com/amient/goconnect/io"
"github.com/amient/goconnect/io/amqp09"
)

var (
Expand Down
10 changes: 5 additions & 5 deletions examples/list-avro-sr-kafka/main.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -21,11 +21,11 @@ package main

import (
"flag"
"github.com/amient/goconnect/pkg/goc"
"github.com/amient/goconnect/pkg/goc/coder"
"github.com/amient/goconnect/pkg/goc/coder/avro"
"github.com/amient/goconnect/pkg/goc/io"
"github.com/amient/goconnect/pkg/goc/io/kafka1"
"github.com/amient/goconnect"
"github.com/amient/goconnect/coder"
"github.com/amient/goconnect/coder/avro"
"github.com/amient/goconnect/io"
"github.com/amient/goconnect/io/kafka1"
"github.com/confluentinc/confluent-kafka-go/kafka"
)
import avrolib "github.com/amient/avro"
Expand Down
8 changes: 4 additions & 4 deletions examples/list-kafka/main.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -21,10 +21,10 @@ package main

import (
"flag"
"github.com/amient/goconnect/pkg/goc"
"github.com/amient/goconnect/pkg/goc/coder"
"github.com/amient/goconnect/pkg/goc/io"
"github.com/amient/goconnect/pkg/goc/io/kafka1"
"github.com/amient/goconnect"
"github.com/amient/goconnect/coder"
"github.com/amient/goconnect/io"
"github.com/amient/goconnect/io/kafka1"
"github.com/confluentinc/confluent-kafka-go/kafka"
)

Expand Down
12 changes: 6 additions & 6 deletions examples/list-split-scatter-map-gather-stdout/main.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -21,12 +21,12 @@ package main

import (
"flag"
"github.com/amient/goconnect/pkg/goc"
"github.com/amient/goconnect/pkg/goc/coder"
"github.com/amient/goconnect/pkg/goc/coder/str"
"github.com/amient/goconnect/pkg/goc/io"
"github.com/amient/goconnect/pkg/goc/io/std"
"github.com/amient/goconnect/pkg/goc/network"
"github.com/amient/goconnect"
"github.com/amient/goconnect/coder"
"github.com/amient/goconnect/coder/str"
"github.com/amient/goconnect/io"
"github.com/amient/goconnect/io/std"
"github.com/amient/goconnect/network"
"strings"
)

Expand Down
2 changes: 1 addition & 1 deletion examples/list-xml-filter-stdout/compare.go
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package main

import (
"github.com/amient/goconnect/pkg/goc/coder/xml"
"github.com/amient/goconnect/coder/xml"
"log"
"strings"
"time"
Expand Down
10 changes: 5 additions & 5 deletions examples/list-xml-filter-stdout/main.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -20,11 +20,11 @@
package main

import (
"github.com/amient/goconnect/pkg/goc"
"github.com/amient/goconnect/pkg/goc/coder"
"github.com/amient/goconnect/pkg/goc/coder/xml"
"github.com/amient/goconnect/pkg/goc/io"
"github.com/amient/goconnect/pkg/goc/io/std"
"github.com/amient/goconnect"
"github.com/amient/goconnect/coder"
"github.com/amient/goconnect/coder/xml"
"github.com/amient/goconnect/io"
"github.com/amient/goconnect/io/std"
"strings"
)

Expand Down
10 changes: 5 additions & 5 deletions examples/localfs-subflow-localfs/main.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -21,11 +21,11 @@ package main

import (
"flag"
"github.com/amient/goconnect/pkg/goc"
"github.com/amient/goconnect/pkg/goc/coder"
"github.com/amient/goconnect/pkg/goc/io/file"
"github.com/amient/goconnect/pkg/goc/io/std"
"github.com/amient/goconnect/pkg/goc/network"
"github.com/amient/goconnect"
"github.com/amient/goconnect/coder"
"github.com/amient/goconnect/io/file"
"github.com/amient/goconnect/io/std"
"github.com/amient/goconnect/network"
"strings"
)

Expand Down
2 changes: 1 addition & 1 deletion pkg/goc/fn.go → fn.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
* limitations under the License.
*/

package goc
package goconnect

import (
"reflect"
Expand Down
10 changes: 10 additions & 0 deletions go.mod
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,10 @@
module github.com/amient/goconnect

go 1.12

require (
github.com/amient/avro v0.4.8
github.com/armon/go-metrics v0.0.0-20190430140413-ec5e00d3c878 // indirect
github.com/confluentinc/confluent-kafka-go v0.11.6
gotest.tools/v3 v3.0.0
)
Loading

0 comments on commit 9c489d0

Please sign in to comment.