diff --git a/.gitignore b/.gitignore index e116f7b..48903e3 100644 --- a/.gitignore +++ b/.gitignore @@ -1,2 +1,2 @@ -synkit +g5 .vscode diff --git a/LICENCE b/LICENCE index daee015..2b92e9a 100644 --- a/LICENCE +++ b/LICENCE @@ -1,4 +1,4 @@ -Synkit License +Gear5 License Version 1.1, 30th June 2023 diff --git a/README.md b/README.md index c22080b..8139dba 100644 --- a/README.md +++ b/README.md @@ -1,6 +1,6 @@ -# Synkit +# Gear5 -Synkit is a new data integration protocol and specification, written in Golang, that aims to provide an alternative to existing solutions such as Airbyte, Meltano, and Singer-io. It focuses on simplicity, performance, and extensibility to enable seamless data integration between various systems and applications. +Gear5 is a new data integration protocol and specification, written in Golang, that aims to provide an alternative to existing solutions such as Airbyte, Meltano, and Singer-io. It focuses on simplicity, performance, and extensibility to enable seamless data integration between various systems and applications. ## Roadmap - [ ] Postgres @@ -11,14 +11,14 @@ Synkit is a new data integration protocol and specification, written in Golang, ## Getting Started -To start using Synkit, follow these steps: +To start using Gear5, follow these steps: -1. **Run Synkit**: Run Synkit driver/adapter images directly with config, catalog, and state files. -2. **Explore the Documentation**: Refer to the documentation for detailed information on how to use Protocol Synkit, including connector setup, data source configuration, and integration examples. +1. **Run Gear5**: Run Gear5 driver/adapter images directly with config, catalog, and state files. +2. **Explore the Documentation**: Refer to the documentation for detailed information on how to use Protocol Gear5, including connector setup, data source configuration, and integration examples. ## Contributing -We welcome contributions to Protocol Synkit! If you'd like to contribute, please follow these guidelines: +We welcome contributions to Protocol Gear5! If you'd like to contribute, please follow these guidelines: 1. Fork the repository and create a new branch for your feature or bug fix. @@ -26,18 +26,18 @@ We welcome contributions to Protocol Synkit! If you'd like to contribute, please 3. Push your changes to your forked repository. -4. Submit a pull request to the main Synkit repository, clearly describing the changes you've made and their purpose. +4. Submit a pull request to the main Gear5 repository, clearly describing the changes you've made and their purpose. 5. Participate in the code review process, addressing any feedback or suggestions. ## License -Protocol Synkit is open-source and released under a custom Licence. Please check +Protocol Gear5 is open-source and released under a custom Licence. Please check ## Contact -For any questions, feedback, or support related to Synkit, you can reach out to the development team via email at [piyushsingariya@gmail.com](mailto:piyushsingariya@gmail.com). +For any questions, feedback, or support related to Gear5, you can reach out to the development team via email at [piyushsingariya@gmail.com](mailto:piyushsingariya@gmail.com). ## Acknowledgments -We would like to acknowledge the contributions of all individuals and organizations that have helped make Synkit possible. Their feedback, ideas, and suggestions have been invaluable in shaping and improving the protocol. +We would like to acknowledge the contributions of all individuals and organizations that have helped make Gear5 possible. Their feedback, ideas, and suggestions have been invaluable in shaping and improving the protocol. diff --git a/build.sh b/build.sh index e0786ea..f6219dc 100755 --- a/build.sh +++ b/build.sh @@ -17,17 +17,17 @@ function build_and_run() { fi cd $path go mod tidy - go build -ldflags="-w -s -X constants/constants.version=${GIT_VERSION} -X constants/constants.commitsha=${GIT_COMMITSHA} -X constants/constants.releasechannel=${RELEASE_CHANNEL}" -o synkit main.go + go build -ldflags="-w -s -X constants/constants.version=${GIT_VERSION} -X constants/constants.commitsha=${GIT_COMMITSHA} -X constants/constants.releasechannel=${RELEASE_CHANNEL}" -o g5 main.go echo "============================== Executing connector: $connector with args [$joined_arguments] ==============================" - ./synkit $joined_arguments + ./g5 $joined_arguments } if [ $# -gt 0 ]; then argument="$1" # Capture and join remaining arguments - synkit + g5 remaining_arguments=("$@") joined_arguments=$( IFS=' ' diff --git a/connector.go b/connector.go index bd2ca04..3cc484d 100644 --- a/connector.go +++ b/connector.go @@ -1,12 +1,12 @@ -package synkit +package gear5 import ( "fmt" "os" - "github.com/piyushsingariya/synkit/logger" - protocol "github.com/piyushsingariya/synkit/protocol" - "github.com/piyushsingariya/synkit/safego" + "github.com/gear5sh/gear5/logger" + protocol "github.com/gear5sh/gear5/protocol" + "github.com/gear5sh/gear5/safego" "github.com/spf13/cobra" ) diff --git a/drivers/base/bulk_driver.go b/drivers/base/bulk_driver.go index de61483..7e6d041 100644 --- a/drivers/base/bulk_driver.go +++ b/drivers/base/bulk_driver.go @@ -1,9 +1,9 @@ package base import ( - "github.com/piyushsingariya/synkit/protocol" - "github.com/piyushsingariya/synkit/types" - "github.com/piyushsingariya/synkit/utils" + "github.com/gear5sh/gear5/protocol" + "github.com/gear5sh/gear5/types" + "github.com/gear5sh/gear5/utils" ) // Pass dest with all fields initialized to handle nil state case diff --git a/drivers/base/driver.go b/drivers/base/driver.go index 4d429c1..0dbc47d 100644 --- a/drivers/base/driver.go +++ b/drivers/base/driver.go @@ -1,9 +1,9 @@ package base import ( - "github.com/piyushsingariya/synkit/protocol" - "github.com/piyushsingariya/synkit/types" - "github.com/piyushsingariya/synkit/typeutils" + "github.com/gear5sh/gear5/protocol" + "github.com/gear5sh/gear5/types" + "github.com/gear5sh/gear5/typeutils" ) type Driver struct { diff --git a/drivers/base/utils.go b/drivers/base/utils.go index 266a1db..05e0eb7 100644 --- a/drivers/base/utils.go +++ b/drivers/base/utils.go @@ -3,8 +3,8 @@ package base import ( "time" - "github.com/piyushsingariya/synkit/logger" - "github.com/piyushsingariya/synkit/types" + "github.com/gear5sh/gear5/logger" + "github.com/gear5sh/gear5/types" ) type basestream interface { diff --git a/drivers/google-sheets/go.mod b/drivers/google-sheets/go.mod index 5dcb66e..ea43760 100644 --- a/drivers/google-sheets/go.mod +++ b/drivers/google-sheets/go.mod @@ -1,4 +1,4 @@ -module github.com/piyushsingariya/synkit/drivers/google-sheets +module github.com/gear5sh/gear5/drivers/google-sheets go 1.22 @@ -7,7 +7,7 @@ toolchain go1.22.3 require ( github.com/goccy/go-json v0.10.2 github.com/mozillazg/go-unidecode v0.2.0 - github.com/piyushsingariya/synkit v0.0.0-00010101000000-000000000000 + github.com/gear5sh/gear5 v0.0.0-00010101000000-000000000000 golang.org/x/oauth2 v0.10.0 gopkg.in/Iwark/spreadsheet.v2 v2.0.0-20220412131121-41eea1483964 ) @@ -46,4 +46,4 @@ require ( sigs.k8s.io/yaml v1.3.0 // indirect ) -replace github.com/piyushsingariya/synkit => ../../ +replace github.com/gear5sh/gear5 => ../../ diff --git a/drivers/google-sheets/internal/google_sheets.go b/drivers/google-sheets/internal/google_sheets.go index b67b46a..060cf8c 100644 --- a/drivers/google-sheets/internal/google_sheets.go +++ b/drivers/google-sheets/internal/google_sheets.go @@ -4,11 +4,11 @@ import ( "fmt" "strings" - "github.com/piyushsingariya/synkit/drivers/base" - "github.com/piyushsingariya/synkit/logger" - "github.com/piyushsingariya/synkit/protocol" - "github.com/piyushsingariya/synkit/types" - "github.com/piyushsingariya/synkit/utils" + "github.com/gear5sh/gear5/drivers/base" + "github.com/gear5sh/gear5/logger" + "github.com/gear5sh/gear5/protocol" + "github.com/gear5sh/gear5/types" + "github.com/gear5sh/gear5/utils" "gopkg.in/Iwark/spreadsheet.v2" ) diff --git a/drivers/google-sheets/internal/models.go b/drivers/google-sheets/internal/models.go index e198406..e136966 100644 --- a/drivers/google-sheets/internal/models.go +++ b/drivers/google-sheets/internal/models.go @@ -3,7 +3,7 @@ package driver import ( "fmt" - "github.com/piyushsingariya/synkit/types" + "github.com/gear5sh/gear5/types" ) type Config struct { diff --git a/drivers/google-sheets/internal/utils.go b/drivers/google-sheets/internal/utils.go index c37ddf0..1a0347f 100644 --- a/drivers/google-sheets/internal/utils.go +++ b/drivers/google-sheets/internal/utils.go @@ -10,10 +10,10 @@ import ( "github.com/goccy/go-json" + "github.com/gear5sh/gear5/logger" + "github.com/gear5sh/gear5/types" + "github.com/gear5sh/gear5/utils" unidecode "github.com/mozillazg/go-unidecode" - "github.com/piyushsingariya/synkit/logger" - "github.com/piyushsingariya/synkit/types" - "github.com/piyushsingariya/synkit/utils" "golang.org/x/oauth2" "golang.org/x/oauth2/google" "gopkg.in/Iwark/spreadsheet.v2" diff --git a/drivers/google-sheets/main.go b/drivers/google-sheets/main.go index 0e863fc..34e5d17 100644 --- a/drivers/google-sheets/main.go +++ b/drivers/google-sheets/main.go @@ -1,11 +1,11 @@ package main import ( - "github.com/piyushsingariya/synkit" - driver "github.com/piyushsingariya/synkit/drivers/google-sheets/internal" + "github.com/gear5sh/gear5" + driver "github.com/gear5sh/gear5/drivers/google-sheets/internal" ) func main() { driver := &driver.GoogleSheets{} - synkit.RegisterDriver(driver) + gear5.RegisterDriver(driver) } diff --git a/drivers/hubspot/go.mod b/drivers/hubspot/go.mod index 8e87477..79655b1 100644 --- a/drivers/hubspot/go.mod +++ b/drivers/hubspot/go.mod @@ -1,4 +1,4 @@ -module github.com/piyushsingariya/synkit/drivers/hubspot +module github.com/gear5sh/gear5/drivers/hubspot go 1.22 @@ -6,7 +6,7 @@ toolchain go1.22.3 require ( github.com/goccy/go-json v0.10.2 - github.com/piyushsingariya/synkit v0.0.0-20230727050722-6795340c7033 + github.com/gear5sh/gear5 v0.0.0-20230727050722-6795340c7033 golang.org/x/oauth2 v0.11.0 ) @@ -42,4 +42,4 @@ require ( sigs.k8s.io/yaml v1.3.0 // indirect ) -replace github.com/piyushsingariya/synkit => ../../ +replace github.com/gear5sh/gear5 => ../../ diff --git a/drivers/hubspot/internal/base_stream.go b/drivers/hubspot/internal/base_stream.go index d2c779f..8374f4a 100644 --- a/drivers/hubspot/internal/base_stream.go +++ b/drivers/hubspot/internal/base_stream.go @@ -15,11 +15,11 @@ import ( "github.com/goccy/go-json" - "github.com/piyushsingariya/synkit/drivers/base" - "github.com/piyushsingariya/synkit/logger" - "github.com/piyushsingariya/synkit/types" - "github.com/piyushsingariya/synkit/typeutils" - "github.com/piyushsingariya/synkit/utils" + "github.com/gear5sh/gear5/drivers/base" + "github.com/gear5sh/gear5/logger" + "github.com/gear5sh/gear5/types" + "github.com/gear5sh/gear5/typeutils" + "github.com/gear5sh/gear5/utils" ) type Stream struct { diff --git a/drivers/hubspot/internal/config.go b/drivers/hubspot/internal/config.go index f6d310e..2d4ac19 100644 --- a/drivers/hubspot/internal/config.go +++ b/drivers/hubspot/internal/config.go @@ -4,7 +4,7 @@ import ( "fmt" "time" - "github.com/piyushsingariya/synkit/logger" + "github.com/gear5sh/gear5/logger" ) type Config struct { diff --git a/drivers/hubspot/internal/crm_stream.go b/drivers/hubspot/internal/crm_stream.go index e5baac0..94353b1 100644 --- a/drivers/hubspot/internal/crm_stream.go +++ b/drivers/hubspot/internal/crm_stream.go @@ -5,12 +5,12 @@ import ( "net/http" "time" - "github.com/piyushsingariya/synkit/drivers/base" - "github.com/piyushsingariya/synkit/logger" - "github.com/piyushsingariya/synkit/safego" - "github.com/piyushsingariya/synkit/types" - "github.com/piyushsingariya/synkit/typeutils" - "github.com/piyushsingariya/synkit/utils" + "github.com/gear5sh/gear5/drivers/base" + "github.com/gear5sh/gear5/logger" + "github.com/gear5sh/gear5/safego" + "github.com/gear5sh/gear5/types" + "github.com/gear5sh/gear5/typeutils" + "github.com/gear5sh/gear5/utils" ) type CRMSearchStream struct { diff --git a/drivers/hubspot/internal/hubspot.go b/drivers/hubspot/internal/hubspot.go index 78d9926..3beb87d 100644 --- a/drivers/hubspot/internal/hubspot.go +++ b/drivers/hubspot/internal/hubspot.go @@ -5,14 +5,14 @@ import ( "io" "net/http" + "github.com/gear5sh/gear5/drivers/base" "github.com/goccy/go-json" - "github.com/piyushsingariya/synkit/drivers/base" - "github.com/piyushsingariya/synkit/jsonschema" - "github.com/piyushsingariya/synkit/jsonschema/schema" - "github.com/piyushsingariya/synkit/protocol" - "github.com/piyushsingariya/synkit/types" - "github.com/piyushsingariya/synkit/utils" + "github.com/gear5sh/gear5/jsonschema" + "github.com/gear5sh/gear5/jsonschema/schema" + "github.com/gear5sh/gear5/protocol" + "github.com/gear5sh/gear5/types" + "github.com/gear5sh/gear5/utils" ) type Hubspot struct { diff --git a/drivers/hubspot/internal/incremental_stream.go b/drivers/hubspot/internal/incremental_stream.go index c4b2b01..c51704a 100644 --- a/drivers/hubspot/internal/incremental_stream.go +++ b/drivers/hubspot/internal/incremental_stream.go @@ -4,10 +4,10 @@ import ( "net/http" "time" - "github.com/piyushsingariya/synkit/logger" - "github.com/piyushsingariya/synkit/types" - "github.com/piyushsingariya/synkit/typeutils" - "github.com/piyushsingariya/synkit/utils" + "github.com/gear5sh/gear5/logger" + "github.com/gear5sh/gear5/types" + "github.com/gear5sh/gear5/typeutils" + "github.com/gear5sh/gear5/utils" ) type IncrementalStream struct { diff --git a/drivers/hubspot/internal/interface.go b/drivers/hubspot/internal/interface.go index 0127f48..978a6bc 100644 --- a/drivers/hubspot/internal/interface.go +++ b/drivers/hubspot/internal/interface.go @@ -1,7 +1,7 @@ package driver import ( - "github.com/piyushsingariya/synkit/types" + "github.com/gear5sh/gear5/types" ) type HubspotStream interface { diff --git a/drivers/hubspot/internal/utils.go b/drivers/hubspot/internal/utils.go index cd7c57b..c6e586c 100644 --- a/drivers/hubspot/internal/utils.go +++ b/drivers/hubspot/internal/utils.go @@ -7,9 +7,9 @@ import ( "reflect" "strings" - "github.com/piyushsingariya/synkit/logger" - "github.com/piyushsingariya/synkit/types" - "github.com/piyushsingariya/synkit/utils" + "github.com/gear5sh/gear5/logger" + "github.com/gear5sh/gear5/types" + "github.com/gear5sh/gear5/utils" "golang.org/x/oauth2" ) diff --git a/drivers/hubspot/main.go b/drivers/hubspot/main.go index 1783a16..c78e095 100644 --- a/drivers/hubspot/main.go +++ b/drivers/hubspot/main.go @@ -1,11 +1,11 @@ package main import ( - "github.com/piyushsingariya/synkit" - driver "github.com/piyushsingariya/synkit/drivers/hubspot/internal" + "github.com/gear5sh/gear5" + driver "github.com/gear5sh/gear5/drivers/hubspot/internal" ) func main() { driver := &driver.Hubspot{} - synkit.RegisterDriver(driver) + gear5.RegisterDriver(driver) } diff --git a/drivers/postgres/generated.json b/drivers/postgres/generated.json index bd2f13f..cd23433 100755 --- a/drivers/postgres/generated.json +++ b/drivers/postgres/generated.json @@ -1,7 +1,7 @@ { "$schema": "https://json-schema.org/draft/2020-12/schema", "definitions": { - "github_com-piyushsingariya-synkit-utils-SSLConfig": { + "github_com-piyushsingariya-gear5-utils-SSLConfig": { "properties": { "client_cert": { "title": "Client Certificate", @@ -24,7 +24,7 @@ "required": ["mode"], "title": "SSLConfig is a dto for deserialized SSL configuration for Postgres", "type": "object", - "x-go-path": "github.com/piyushsingariya/synkit/utils/SSLConfig" + "x-go-path": "github.com/gear5sh/gear5/utils/SSLConfig" } }, "properties": { @@ -53,7 +53,7 @@ "type": "integer" }, "ssl": { - "$ref": "#/definitions/github_com-piyushsingariya-synkit-utils-SSLConfig", + "$ref": "#/definitions/github_com-piyushsingariya-gear5-utils-SSLConfig", "title": "Hostname of the database." }, "update_method": { @@ -62,7 +62,7 @@ "$schema": "https://json-schema.org/draft/2020-12/schema", "title": "Standard Sync", "type": "object", - "x-go-path": "github.com/piyushsingariya/synkit/drivers/postgres/internal/Standard" + "x-go-path": "github.com/gear5sh/gear5/drivers/postgres/internal/Standard" }, { "$schema": "https://json-schema.org/draft/2020-12/schema", @@ -81,7 +81,7 @@ "required": ["replication_slot", "intial_wait_time"], "title": "Capture Write Ahead Logs", "type": "object", - "x-go-path": "github.com/piyushsingariya/synkit/drivers/postgres/internal/CDC" + "x-go-path": "github.com/gear5sh/gear5/drivers/postgres/internal/CDC" } ], "title": "Configures how data is extracted from the database.", @@ -102,5 +102,5 @@ "update_method" ], "type": "object", - "x-go-path": "github.com/piyushsingariya/synkit/drivers/postgres/internal/Config" + "x-go-path": "github.com/gear5sh/gear5/drivers/postgres/internal/Config" } diff --git a/drivers/postgres/go.mod b/drivers/postgres/go.mod index c02a61b..c02effa 100644 --- a/drivers/postgres/go.mod +++ b/drivers/postgres/go.mod @@ -1,10 +1,10 @@ -module github.com/piyushsingariya/synkit/drivers/postgres +module github.com/gear5sh/gear5/drivers/postgres go 1.22 require ( github.com/lib/pq v1.10.2 - github.com/piyushsingariya/synkit v0.0.0-20230630130252-054496f39abb + github.com/gear5sh/gear5 v0.0.0-20230630130252-054496f39abb ) require ( diff --git a/drivers/postgres/internal/cdc.go b/drivers/postgres/internal/cdc.go index 7eb3e09..260c92e 100644 --- a/drivers/postgres/internal/cdc.go +++ b/drivers/postgres/internal/cdc.go @@ -4,13 +4,13 @@ import ( "fmt" "time" + "github.com/gear5sh/gear5/drivers/base" + "github.com/gear5sh/gear5/pkg/jdbc" + "github.com/gear5sh/gear5/pkg/waljs" + "github.com/gear5sh/gear5/protocol" + "github.com/gear5sh/gear5/safego" + "github.com/gear5sh/gear5/types" "github.com/jmoiron/sqlx" - "github.com/piyushsingariya/synkit/drivers/base" - "github.com/piyushsingariya/synkit/pkg/jdbc" - "github.com/piyushsingariya/synkit/pkg/waljs" - "github.com/piyushsingariya/synkit/protocol" - "github.com/piyushsingariya/synkit/safego" - "github.com/piyushsingariya/synkit/types" ) func (p *Postgres) prepareWALJSConfig(streams ...protocol.Stream) (*waljs.Config, error) { diff --git a/drivers/postgres/internal/config.go b/drivers/postgres/internal/config.go index e9e9cff..03500a0 100644 --- a/drivers/postgres/internal/config.go +++ b/drivers/postgres/internal/config.go @@ -5,8 +5,8 @@ import ( "net/url" "strings" + "github.com/gear5sh/gear5/utils" "github.com/lib/pq" - "github.com/piyushsingariya/synkit/utils" ) type Config struct { diff --git a/drivers/postgres/internal/datatype_conversion.go b/drivers/postgres/internal/datatype_conversion.go index 38de0b6..b7f887c 100644 --- a/drivers/postgres/internal/datatype_conversion.go +++ b/drivers/postgres/internal/datatype_conversion.go @@ -1,7 +1,7 @@ package driver import ( - "github.com/piyushsingariya/synkit/types" + "github.com/gear5sh/gear5/types" ) var pgTypeToDataTypes = map[string]types.DataType{ diff --git a/drivers/postgres/internal/postgres.go b/drivers/postgres/internal/postgres.go index 2cecaa1..6d8705f 100644 --- a/drivers/postgres/internal/postgres.go +++ b/drivers/postgres/internal/postgres.go @@ -6,14 +6,14 @@ import ( "strings" "time" + "github.com/gear5sh/gear5/drivers/base" + "github.com/gear5sh/gear5/logger" + "github.com/gear5sh/gear5/pkg/jdbc" + "github.com/gear5sh/gear5/pkg/waljs" + "github.com/gear5sh/gear5/protocol" + "github.com/gear5sh/gear5/types" + "github.com/gear5sh/gear5/utils" "github.com/jmoiron/sqlx" - "github.com/piyushsingariya/synkit/drivers/base" - "github.com/piyushsingariya/synkit/logger" - "github.com/piyushsingariya/synkit/pkg/jdbc" - "github.com/piyushsingariya/synkit/pkg/waljs" - "github.com/piyushsingariya/synkit/protocol" - "github.com/piyushsingariya/synkit/types" - "github.com/piyushsingariya/synkit/utils" ) type Postgres struct { diff --git a/drivers/postgres/internal/sync.go b/drivers/postgres/internal/sync.go index dec56db..d7e81ee 100644 --- a/drivers/postgres/internal/sync.go +++ b/drivers/postgres/internal/sync.go @@ -5,14 +5,14 @@ import ( "database/sql" "fmt" + "github.com/gear5sh/gear5/drivers/base" + "github.com/gear5sh/gear5/logger" + "github.com/gear5sh/gear5/pkg/jdbc" + "github.com/gear5sh/gear5/protocol" + "github.com/gear5sh/gear5/safego" + "github.com/gear5sh/gear5/types" + "github.com/gear5sh/gear5/utils" "github.com/jmoiron/sqlx" - "github.com/piyushsingariya/synkit/drivers/base" - "github.com/piyushsingariya/synkit/logger" - "github.com/piyushsingariya/synkit/pkg/jdbc" - "github.com/piyushsingariya/synkit/protocol" - "github.com/piyushsingariya/synkit/safego" - "github.com/piyushsingariya/synkit/types" - "github.com/piyushsingariya/synkit/utils" ) // Simple Full Refresh Sync; Loads table fully diff --git a/drivers/postgres/main.go b/drivers/postgres/main.go index 3ddc636..719481b 100644 --- a/drivers/postgres/main.go +++ b/drivers/postgres/main.go @@ -1,11 +1,11 @@ package main import ( + "github.com/gear5sh/gear5" + "github.com/gear5sh/gear5/drivers/base" + driver "github.com/gear5sh/gear5/drivers/postgres/internal" + "github.com/gear5sh/gear5/protocol" _ "github.com/jackc/pgx/v4/stdlib" - "github.com/piyushsingariya/synkit" - "github.com/piyushsingariya/synkit/drivers/base" - driver "github.com/piyushsingariya/synkit/drivers/postgres/internal" - "github.com/piyushsingariya/synkit/protocol" ) func main() { @@ -15,5 +15,5 @@ func main() { _ = protocol.BulkDriver(driver) defer driver.CloseConnection() - synkit.RegisterDriver(driver) + gear5.RegisterDriver(driver) } diff --git a/drivers/s3/go.mod b/drivers/s3/go.mod index ff48463..c674889 100644 --- a/drivers/s3/go.mod +++ b/drivers/s3/go.mod @@ -4,7 +4,7 @@ go 1.22 toolchain go1.22.3 -require github.com/piyushsingariya/synkit v0.0.0-20230727050722-6795340c7033 +require github.com/gear5sh/gear5 v0.0.0-20230727050722-6795340c7033 require ( github.com/andybalholm/brotli v1.1.0 // indirect @@ -55,4 +55,4 @@ require ( sigs.k8s.io/yaml v1.3.0 // indirect ) -replace github.com/piyushsingariya/synkit => ../../ +replace github.com/gear5sh/gear5 => ../../ diff --git a/drivers/s3/internal/models.go b/drivers/s3/internal/models.go index d7d594f..2bd2d59 100644 --- a/drivers/s3/internal/models.go +++ b/drivers/s3/internal/models.go @@ -3,8 +3,8 @@ package driver import ( "fmt" - "github.com/piyushsingariya/synkit/logger" - "github.com/piyushsingariya/synkit/utils" + "github.com/gear5sh/gear5/logger" + "github.com/gear5sh/gear5/utils" ) // Authenticate via Access and Secret Keys diff --git a/drivers/s3/internal/reader/parquet.go b/drivers/s3/internal/reader/parquet.go index 8415922..a3fb8aa 100644 --- a/drivers/s3/internal/reader/parquet.go +++ b/drivers/s3/internal/reader/parquet.go @@ -13,10 +13,10 @@ import ( _ "github.com/akrennmair/parquet-go-lzo" // registers the LZO block compressor with parquet-go _ "github.com/akrennmair/parquet-go-zstd" // registers the Zstd block compressor with parquet-go - "github.com/piyushsingariya/synkit/logger" - "github.com/piyushsingariya/synkit/types" - "github.com/piyushsingariya/synkit/typeutils" - "github.com/piyushsingariya/synkit/utils" + "github.com/gear5sh/gear5/logger" + "github.com/gear5sh/gear5/types" + "github.com/gear5sh/gear5/typeutils" + "github.com/gear5sh/gear5/utils" "github.com/aws/aws-sdk-go/service/s3" goparquet "github.com/fraugster/parquet-go" diff --git a/drivers/s3/internal/reader/reader.go b/drivers/s3/internal/reader/reader.go index e839c7d..087985b 100644 --- a/drivers/s3/internal/reader/reader.go +++ b/drivers/s3/internal/reader/reader.go @@ -5,7 +5,7 @@ import ( "strings" "github.com/aws/aws-sdk-go/service/s3" - "github.com/piyushsingariya/synkit/types" + "github.com/gear5sh/gear5/types" ) var FileTypes = []string{"parquet"} diff --git a/drivers/s3/internal/s3.go b/drivers/s3/internal/s3.go index d974006..8876302 100644 --- a/drivers/s3/internal/s3.go +++ b/drivers/s3/internal/s3.go @@ -11,17 +11,17 @@ import ( "github.com/aws/aws-sdk-go/aws" "github.com/aws/aws-sdk-go/aws/session" "github.com/aws/aws-sdk-go/service/s3" + "github.com/gear5sh/gear5/drivers/base" + "github.com/gear5sh/gear5/jsonschema" + "github.com/gear5sh/gear5/jsonschema/schema" + "github.com/gear5sh/gear5/logger" + protocol "github.com/gear5sh/gear5/protocol" + "github.com/gear5sh/gear5/safego" + "github.com/gear5sh/gear5/types" + "github.com/gear5sh/gear5/typeutils" + "github.com/gear5sh/gear5/utils" "github.com/gobwas/glob" "github.com/piyushsingariya/drivers/s3/internal/reader" - "github.com/piyushsingariya/synkit/drivers/base" - "github.com/piyushsingariya/synkit/jsonschema" - "github.com/piyushsingariya/synkit/jsonschema/schema" - "github.com/piyushsingariya/synkit/logger" - protocol "github.com/piyushsingariya/synkit/protocol" - "github.com/piyushsingariya/synkit/safego" - "github.com/piyushsingariya/synkit/types" - "github.com/piyushsingariya/synkit/typeutils" - "github.com/piyushsingariya/synkit/utils" ) const patternSymbols = "*[]!{}" diff --git a/drivers/s3/internal/utils.go b/drivers/s3/internal/utils.go index bd70183..6b8930f 100644 --- a/drivers/s3/internal/utils.go +++ b/drivers/s3/internal/utils.go @@ -7,8 +7,8 @@ import ( awscredentials "github.com/aws/aws-sdk-go/aws/credentials" "github.com/aws/aws-sdk-go/aws/session" "github.com/aws/aws-sdk-go/service/sts" - "github.com/piyushsingariya/synkit/logger" - "github.com/piyushsingariya/synkit/utils" + "github.com/gear5sh/gear5/logger" + "github.com/gear5sh/gear5/utils" ) func newSession(credentials interface{}) (*session.Session, error) { diff --git a/drivers/s3/main.go b/drivers/s3/main.go index 553ab03..da19369 100644 --- a/drivers/s3/main.go +++ b/drivers/s3/main.go @@ -1,11 +1,11 @@ package main import ( + "github.com/gear5sh/gear5" driver "github.com/piyushsingariya/drivers/s3/internal" - "github.com/piyushsingariya/synkit" ) func main() { driver := &driver.S3{} - synkit.RegisterDriver(driver) + gear5.RegisterDriver(driver) } diff --git a/go.mod b/go.mod index a6975d5..01fee4a 100644 --- a/go.mod +++ b/go.mod @@ -1,4 +1,4 @@ -module github.com/piyushsingariya/synkit +module github.com/gear5sh/gear5 go 1.22 diff --git a/jsonschema/README.md b/jsonschema/README.md index b8e6454..082a7c5 100644 --- a/jsonschema/README.md +++ b/jsonschema/README.md @@ -1,7 +1,7 @@ [![Build Status](https://travis-ci.org/brainicorn/jsonschemagen.svg?branch=master)](https://travis-ci.org/brainicorn/jsonschemagen) [![codecov](https://codecov.io/gh/brainicorn/jsonschemagen/branch/master/graph/badge.svg)](https://codecov.io/gh/brainicorn/jsonschemagen) -[![Go Report Card](https://goreportcard.com/badge/github.com/piyushsingariya/synkit/jsonschema)](https://goreportcard.com/report/github.com/piyushsingariya/synkit/jsonschema) -[![GoDoc](https://godoc.org/github.com/piyushsingariya/synkit/jsonschema?status.svg)](https://godoc.org/github.com/piyushsingariya/synkit/jsonschema) +[![Go Report Card](https://goreportcard.com/badge/github.com/gear5sh/gear5/jsonschema)](https://goreportcard.com/report/github.com/gear5sh/gear5/jsonschema) +[![GoDoc](https://godoc.org/github.com/gear5sh/gear5/jsonschema?status.svg)](https://godoc.org/github.com/gear5sh/gear5/jsonschema) # jsonschemagen @@ -9,9 +9,9 @@ JSON SchemaGen is a library and command-line tool that allows generating a JSON- Essentially, the same structs you use to consume JSON can also be used to generate a JSON-Schema. -**API Documentation:** [https://godoc.org/github.com/piyushsingariya/synkit/jsonschema](https://godoc.org/github.com/piyushsingariya/synkit/jsonschema) +**API Documentation:** [https://godoc.org/github.com/gear5sh/gear5/jsonschema](https://godoc.org/github.com/gear5sh/gear5/jsonschema) -[Issue Tracker](https://github.com/piyushsingariya/synkit/jsonschema/issues) +[Issue Tracker](https://github.com/gear5sh/gear5/jsonschema/issues) **Annotation Guide:** [jsonSchema annotation guide](annotation_guide.md) @@ -20,7 +20,7 @@ Essentially, the same structs you use to consume JSON can also be used to genera The most common way to use jsonschemagen is as a command-line tool executed via `go generate`. To install the CLI tool, simply run: ```bash -> go get -v github.com/piyushsingariya/synkit/jsonschema +> go get -v github.com/gear5sh/gear5/jsonschema ``` Once installed, you can add a comment in your main.go (or some other go file in your root package) to integrate jsonschemagen with the go generate tool. @@ -204,9 +204,9 @@ func main() { } ``` -**API Documentation:** [https://godoc.org/github.com/piyushsingariya/synkit/jsonschema](https://godoc.org/github.com/piyushsingariya/synkit/jsonschema) +**API Documentation:** [https://godoc.org/github.com/gear5sh/gear5/jsonschema](https://godoc.org/github.com/gear5sh/gear5/jsonschema) -[Issue Tracker](https://github.com/piyushsingariya/synkit/jsonschema/issues) +[Issue Tracker](https://github.com/gear5sh/gear5/jsonschema/issues) ## Contributors diff --git a/jsonschema/cmd/root.go b/jsonschema/cmd/root.go index 5f56651..456cfd0 100644 --- a/jsonschema/cmd/root.go +++ b/jsonschema/cmd/root.go @@ -15,8 +15,8 @@ import ( "github.com/goccy/go-json" - "github.com/piyushsingariya/synkit/jsonschema/generator" - "github.com/piyushsingariya/synkit/jsonschema/schema" + "github.com/gear5sh/gear5/jsonschema/generator" + "github.com/gear5sh/gear5/jsonschema/schema" "github.com/spf13/cobra" ) diff --git a/jsonschema/generator/doc_test.go b/jsonschema/generator/doc_test.go index 4913fe2..d58caf9 100644 --- a/jsonschema/generator/doc_test.go +++ b/jsonschema/generator/doc_test.go @@ -7,7 +7,7 @@ import ( "github.com/goccy/go-json" "github.com/brainicorn/ganno" - "github.com/piyushsingariya/synkit/jsonschema/schema" + "github.com/gear5sh/gear5/jsonschema/schema" "github.com/stretchr/testify/assert" ) @@ -82,7 +82,7 @@ func TestStandardDocStruct(t *testing.T) { } func TestNewlineSynopsisAndDescStruct(t *testing.T) { - pkg := "github.com/piyushsingariya/synkit/jsonschema/generator" + pkg := "github.com/gear5sh/gear5/jsonschema/generator" opts := NewOptions() opts.IncludeTests = true opts.LogLevel = VerboseLevel @@ -96,7 +96,7 @@ func TestNewlineSynopsisAndDescStruct(t *testing.T) { } func TestNewlineSynopsisDocField(t *testing.T) { - pkg := "github.com/piyushsingariya/synkit/jsonschema/generator" + pkg := "github.com/gear5sh/gear5/jsonschema/generator" opts := NewOptions() opts.IncludeTests = true opts.LogLevel = VerboseLevel diff --git a/jsonschema/generator/errorcases_test.go b/jsonschema/generator/errorcases_test.go index 729c4c0..71bb741 100644 --- a/jsonschema/generator/errorcases_test.go +++ b/jsonschema/generator/errorcases_test.go @@ -5,7 +5,7 @@ import ( //"fmt" "testing" - "github.com/piyushsingariya/synkit/jsonschema/schema" + "github.com/gear5sh/gear5/jsonschema/schema" "github.com/stretchr/testify/assert" "github.com/stretchr/testify/suite" @@ -33,7 +33,7 @@ func (suite *ErrorCaseTestSuite) SetupSuite() { suite.options = opts - suite.basePackage = "github.com/piyushsingariya/synkit/jsonschema/generator" + suite.basePackage = "github.com/gear5sh/gear5/jsonschema/generator" p, _ := NewJSONSchemaGenerator("", "", opts).loadProgram(suite.basePackage, suite.options) diff --git a/jsonschema/generator/generator.go b/jsonschema/generator/generator.go index 2893097..2eb26cb 100644 --- a/jsonschema/generator/generator.go +++ b/jsonschema/generator/generator.go @@ -9,7 +9,7 @@ import ( "time" "github.com/brainicorn/ganno" - "github.com/piyushsingariya/synkit/jsonschema/schema" + "github.com/gear5sh/gear5/jsonschema/schema" "golang.org/x/tools/go/loader" ) diff --git a/jsonschema/generator/generator_test.go b/jsonschema/generator/generator_test.go index fbfcb27..4ee4977 100644 --- a/jsonschema/generator/generator_test.go +++ b/jsonschema/generator/generator_test.go @@ -5,7 +5,7 @@ import ( "testing" "github.com/brainicorn/ganno" - "github.com/piyushsingariya/synkit/jsonschema/schema" + "github.com/gear5sh/gear5/jsonschema/schema" "github.com/stretchr/testify/assert" "github.com/stretchr/testify/suite" @@ -208,7 +208,7 @@ func (suite *GeneratorTestSuite) TestObjectAttrs() { func (suite *GeneratorTestSuite) TestRecurseObject() { suite.T().Parallel() - pkg := "github.com/piyushsingariya/synkit/jsonschema/generator" + pkg := "github.com/gear5sh/gear5/jsonschema/generator" opts := NewOptions() opts.LogLevel = InfoLevel opts.IncludeTests = true diff --git a/jsonschema/generator/logging.go b/jsonschema/generator/logging.go index d4d6587..1747615 100644 --- a/jsonschema/generator/logging.go +++ b/jsonschema/generator/logging.go @@ -1,7 +1,7 @@ package generator import ( - "github.com/piyushsingariya/synkit/logger" + "github.com/gear5sh/gear5/logger" ) // LogLevel is an enum specifying log verbosity diff --git a/jsonschema/generator/schema_attrs.go b/jsonschema/generator/schema_attrs.go index 80402e6..b4dc89a 100644 --- a/jsonschema/generator/schema_attrs.go +++ b/jsonschema/generator/schema_attrs.go @@ -8,8 +8,8 @@ import ( "unicode" "unicode/utf8" - "github.com/piyushsingariya/synkit/jsonschema/schema" - "github.com/piyushsingariya/synkit/logger" + "github.com/gear5sh/gear5/jsonschema/schema" + "github.com/gear5sh/gear5/logger" ) func (g *JSONSchemaGenerator) shouldReturnRef(decl *declInfo) bool { diff --git a/jsonschema/jsonschema.go b/jsonschema/jsonschema.go index afc9310..deaa737 100644 --- a/jsonschema/jsonschema.go +++ b/jsonschema/jsonschema.go @@ -6,8 +6,8 @@ import ( "github.com/goccy/go-json" - "github.com/piyushsingariya/synkit/jsonschema/generator" - "github.com/piyushsingariya/synkit/jsonschema/schema" + "github.com/gear5sh/gear5/jsonschema/generator" + "github.com/gear5sh/gear5/jsonschema/schema" "sigs.k8s.io/yaml" ) diff --git a/logger/console/console.go b/logger/console/console.go index 6b5a278..a3c1d89 100644 --- a/logger/console/console.go +++ b/logger/console/console.go @@ -7,7 +7,7 @@ import ( "github.com/goccy/go-json" - "github.com/piyushsingariya/synkit/types" + "github.com/gear5sh/gear5/types" ) var ( diff --git a/logger/logger.go b/logger/logger.go index 6076d76..ec2c279 100644 --- a/logger/logger.go +++ b/logger/logger.go @@ -8,8 +8,8 @@ import ( "os" "time" - "github.com/piyushsingariya/synkit/logger/console" - "github.com/piyushsingariya/synkit/types" + "github.com/gear5sh/gear5/logger/console" + "github.com/gear5sh/gear5/types" ) // Info writes record into os.stdout with log level INFO diff --git a/pkg/jdbc/jdbc.go b/pkg/jdbc/jdbc.go index 01bf48d..8f3d0df 100644 --- a/pkg/jdbc/jdbc.go +++ b/pkg/jdbc/jdbc.go @@ -4,8 +4,8 @@ import ( "fmt" "strings" - "github.com/piyushsingariya/synkit/protocol" - "github.com/piyushsingariya/synkit/types" + "github.com/gear5sh/gear5/protocol" + "github.com/gear5sh/gear5/types" ) const CDCDeletedAt = "_cdc_deleted_at" diff --git a/pkg/jdbc/reader.go b/pkg/jdbc/reader.go index 68f398c..ee489ab 100644 --- a/pkg/jdbc/reader.go +++ b/pkg/jdbc/reader.go @@ -5,8 +5,8 @@ import ( "fmt" "strings" - "github.com/piyushsingariya/synkit/safego" - "github.com/piyushsingariya/synkit/types" + "github.com/gear5sh/gear5/safego" + "github.com/gear5sh/gear5/types" ) type Reader[T types.Iterable] struct { diff --git a/pkg/waljs/filter.go b/pkg/waljs/filter.go index e3e8c53..22c95ba 100644 --- a/pkg/waljs/filter.go +++ b/pkg/waljs/filter.go @@ -6,9 +6,9 @@ import ( "github.com/goccy/go-json" + "github.com/gear5sh/gear5/protocol" + "github.com/gear5sh/gear5/utils" "github.com/jackc/pglogrepl" - "github.com/piyushsingariya/synkit/protocol" - "github.com/piyushsingariya/synkit/utils" ) type ChangeFilter struct { diff --git a/pkg/waljs/snapshotter.go b/pkg/waljs/snapshotter.go index 13d7a90..86970f5 100644 --- a/pkg/waljs/snapshotter.go +++ b/pkg/waljs/snapshotter.go @@ -3,7 +3,7 @@ package waljs import ( "context" - "github.com/piyushsingariya/synkit/protocol" + "github.com/gear5sh/gear5/protocol" "github.com/jackc/pgx/v5" _ "github.com/lib/pq" diff --git a/pkg/waljs/types.go b/pkg/waljs/types.go index f1b3b9b..c9eafce 100644 --- a/pkg/waljs/types.go +++ b/pkg/waljs/types.go @@ -5,10 +5,10 @@ import ( "net/url" "time" + "github.com/gear5sh/gear5/protocol" + "github.com/gear5sh/gear5/types" + "github.com/gear5sh/gear5/typeutils" "github.com/jackc/pglogrepl" - "github.com/piyushsingariya/synkit/protocol" - "github.com/piyushsingariya/synkit/types" - "github.com/piyushsingariya/synkit/typeutils" ) type Config struct { diff --git a/pkg/waljs/waljs.go b/pkg/waljs/waljs.go index 9bed687..69aaf17 100644 --- a/pkg/waljs/waljs.go +++ b/pkg/waljs/waljs.go @@ -7,14 +7,14 @@ import ( "io" "time" + "github.com/gear5sh/gear5/logger" + "github.com/gear5sh/gear5/pkg/jdbc" + "github.com/gear5sh/gear5/protocol" "github.com/jackc/pglogrepl" "github.com/jackc/pgx/v5" "github.com/jackc/pgx/v5/pgconn" "github.com/jackc/pgx/v5/pgproto3" "github.com/jmoiron/sqlx" - "github.com/piyushsingariya/synkit/logger" - "github.com/piyushsingariya/synkit/pkg/jdbc" - "github.com/piyushsingariya/synkit/protocol" ) const ( diff --git a/protocol/check.go b/protocol/check.go index 3db9984..5bcd28f 100644 --- a/protocol/check.go +++ b/protocol/check.go @@ -3,9 +3,9 @@ package protocol import ( "fmt" - "github.com/piyushsingariya/synkit/logger" - "github.com/piyushsingariya/synkit/types" - "github.com/piyushsingariya/synkit/utils" + "github.com/gear5sh/gear5/logger" + "github.com/gear5sh/gear5/types" + "github.com/gear5sh/gear5/utils" "github.com/spf13/cobra" ) diff --git a/protocol/discover.go b/protocol/discover.go index 6c1442b..2684b51 100644 --- a/protocol/discover.go +++ b/protocol/discover.go @@ -5,11 +5,11 @@ import ( "fmt" "sync" - "github.com/piyushsingariya/synkit/logger" - "github.com/piyushsingariya/synkit/safego" - "github.com/piyushsingariya/synkit/types" - "github.com/piyushsingariya/synkit/typeutils" - "github.com/piyushsingariya/synkit/utils" + "github.com/gear5sh/gear5/logger" + "github.com/gear5sh/gear5/safego" + "github.com/gear5sh/gear5/types" + "github.com/gear5sh/gear5/typeutils" + "github.com/gear5sh/gear5/utils" "github.com/spf13/cobra" ) diff --git a/protocol/interface.go b/protocol/interface.go index c579470..a979cba 100644 --- a/protocol/interface.go +++ b/protocol/interface.go @@ -1,7 +1,7 @@ package protocol import ( - "github.com/piyushsingariya/synkit/types" + "github.com/gear5sh/gear5/types" ) type Connector interface { diff --git a/protocol/read.go b/protocol/read.go index 49c9276..76f1687 100644 --- a/protocol/read.go +++ b/protocol/read.go @@ -6,16 +6,16 @@ import ( "sync" "time" - "github.com/piyushsingariya/synkit/logger" - "github.com/piyushsingariya/synkit/types" - "github.com/piyushsingariya/synkit/utils" + "github.com/gear5sh/gear5/logger" + "github.com/gear5sh/gear5/types" + "github.com/gear5sh/gear5/utils" "github.com/spf13/cobra" ) // ReadCmd represents the read command var ReadCmd = &cobra.Command{ Use: "read", - Short: "Synkit read command", + Short: "Gear5 read command", PersistentPreRunE: func(cmd *cobra.Command, args []string) error { if config_ == "" { return fmt.Errorf("--config not passed") diff --git a/protocol/root.go b/protocol/root.go index 7e2ad74..3a23c53 100644 --- a/protocol/root.go +++ b/protocol/root.go @@ -3,9 +3,9 @@ package protocol import ( "fmt" - "github.com/piyushsingariya/synkit/logger/console" - "github.com/piyushsingariya/synkit/types" - "github.com/piyushsingariya/synkit/utils" + "github.com/gear5sh/gear5/logger/console" + "github.com/gear5sh/gear5/types" + "github.com/gear5sh/gear5/utils" "github.com/sirupsen/logrus" "github.com/spf13/cobra" ) @@ -30,7 +30,7 @@ var ( // RootCmd represents the base command when called without any subcommands var RootCmd = &cobra.Command{ - Use: "synkit", + Use: "gear5", Short: "root command", RunE: func(cmd *cobra.Command, args []string) error { if len(args) == 0 { @@ -38,7 +38,7 @@ var RootCmd = &cobra.Command{ } if ok := utils.IsValidSubcommand(getAvailableCommands(), args[0]); !ok { - return fmt.Errorf("'%s' is an invalid command. Use 'synkit --help' to display usage guide", args[0]) + return fmt.Errorf("'%s' is an invalid command. Use 'gear5 --help' to display usage guide", args[0]) } return nil diff --git a/protocol/spec.go b/protocol/spec.go index 62332a6..c0bf257 100644 --- a/protocol/spec.go +++ b/protocol/spec.go @@ -7,9 +7,9 @@ import ( "github.com/goccy/go-json" - "github.com/piyushsingariya/synkit/jsonschema" - "github.com/piyushsingariya/synkit/logger" - "github.com/piyushsingariya/synkit/utils" + "github.com/gear5sh/gear5/jsonschema" + "github.com/gear5sh/gear5/logger" + "github.com/gear5sh/gear5/utils" "github.com/spf13/cobra" ) diff --git a/release-tool.sh b/release-tool.sh index 1b01e82..95a8fc7 100644 --- a/release-tool.sh +++ b/release-tool.sh @@ -5,7 +5,7 @@ # function chalk() { local color=$1 - synkit + g5 local color_code=0 if [[ $color == "red" ]]; then color_code=1 diff --git a/safego/safego.go b/safego/safego.go index c27c000..d545f58 100644 --- a/safego/safego.go +++ b/safego/safego.go @@ -7,7 +7,7 @@ import ( "sync" "time" - "github.com/piyushsingariya/synkit/logger" + "github.com/gear5sh/gear5/logger" ) const defaultRestartTimeout = 2 * time.Second diff --git a/types/abstract.go b/types/abstract.go index 256bd49..bcd9163 100644 --- a/types/abstract.go +++ b/types/abstract.go @@ -4,7 +4,7 @@ func ToPtr[T any](val T) *T { return &val } -const NullStruct = "github.com/piyushsingariya/synkit/types/Null" +const NullStruct = "github.com/gear5sh/gear5/types/Null" type Null struct { } diff --git a/types/batch_size.go b/types/batch_size.go index bee1235..3741fbb 100644 --- a/types/batch_size.go +++ b/types/batch_size.go @@ -3,7 +3,7 @@ package types import ( "sync/atomic" - "github.com/piyushsingariya/synkit/utils" + "github.com/gear5sh/gear5/utils" ) type BatchSizeEstimator struct { diff --git a/types/catalog.go b/types/catalog.go index e399031..d22f26e 100644 --- a/types/catalog.go +++ b/types/catalog.go @@ -4,10 +4,10 @@ import ( "fmt" "time" - "github.com/piyushsingariya/synkit/utils" + "github.com/gear5sh/gear5/utils" ) -// Message is a dto for synkit output row representation +// Message is a dto for gear5 output row representation type Message struct { Type MessageType `json:"type"` Log *Log `json:"log,omitempty"` diff --git a/types/stream.go b/types/stream.go index c076d50..b91e77f 100644 --- a/types/stream.go +++ b/types/stream.go @@ -3,8 +3,8 @@ package types import ( "github.com/goccy/go-json" - "github.com/piyushsingariya/synkit/jsonschema/schema" - "github.com/piyushsingariya/synkit/utils" + "github.com/gear5sh/gear5/jsonschema/schema" + "github.com/gear5sh/gear5/utils" ) // Output Stream Object for dsynk diff --git a/types/stream_configured.go b/types/stream_configured.go index ba5c22f..d7aae8d 100644 --- a/types/stream_configured.go +++ b/types/stream_configured.go @@ -3,7 +3,7 @@ package types import ( "fmt" - "github.com/piyushsingariya/synkit/utils" + "github.com/gear5sh/gear5/utils" ) // Input/Processed object for Stream diff --git a/typeutils/datatype.go b/typeutils/datatype.go index 7027f31..326e3db 100644 --- a/typeutils/datatype.go +++ b/typeutils/datatype.go @@ -4,8 +4,8 @@ import ( "fmt" "reflect" - "github.com/piyushsingariya/synkit/types" - "github.com/piyushsingariya/synkit/utils" + "github.com/gear5sh/gear5/types" + "github.com/gear5sh/gear5/utils" ) // TypeFromValue return DataType from v type diff --git a/typeutils/fields.go b/typeutils/fields.go index 83ad2e9..0fd42a8 100644 --- a/typeutils/fields.go +++ b/typeutils/fields.go @@ -3,8 +3,8 @@ package typeutils import ( "sort" - "github.com/piyushsingariya/synkit/logger" - "github.com/piyushsingariya/synkit/types" + "github.com/gear5sh/gear5/logger" + "github.com/gear5sh/gear5/types" ) type Fields map[string]*Field diff --git a/typeutils/reformat.go b/typeutils/reformat.go index f8bc248..9de3211 100644 --- a/typeutils/reformat.go +++ b/typeutils/reformat.go @@ -6,7 +6,7 @@ import ( "strconv" "time" - "github.com/piyushsingariya/synkit/types" + "github.com/gear5sh/gear5/types" ) type StringInterface interface { diff --git a/typeutils/resolver.go b/typeutils/resolver.go index 702bfa3..cd9eeaa 100644 --- a/typeutils/resolver.go +++ b/typeutils/resolver.go @@ -1,6 +1,6 @@ package typeutils -import "github.com/piyushsingariya/synkit/types" +import "github.com/gear5sh/gear5/types" func Resolve(stream *types.Stream, objects ...map[string]interface{}) error { allfields := Fields{}