Create schema endpoint (#107)

fivetran · Jun 17, 2024 · 2a94b66 · 2a94b66
1 parent 81a4624
commit 2a94b66
Show file tree

Hide file tree

Showing 6 changed files with 386 additions and 139 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -5,7 +5,13 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
-## [Unreleased](https://github.com/fivetran/go-fivetran/compare/v0.8.6...HEAD)
+## [Unreleased](https://github.com/fivetran/go-fivetran/compare/v0.8.7...HEAD)
+
+## [0.8.7](https://github.com/fivetran/go-fivetran/compare/v0.8.6...v0.8.7)
+
+## Added
+Support for a new endpoints:
+- [Create a Connector Schema Config](https://fivetran.com/docs/rest-api/connectors#createaconnectorschemaconfig)
 
 ## [0.8.6](https://github.com/fivetran/go-fivetran/compare/v0.8.5...v0.8.6)
 

diff --git a/README.md b/README.md
@@ -133,6 +133,7 @@ REST API Endpoint | REST API Version | SDK Service/Config/Auth
 [Retrieve a connector schema config](https://fivetran.com/docs/rest-api/connectors#retrieveaconnectorschemaconfig) | v1 | [ConnectorSchemaDetailsService](https://pkg.go.dev/github.com/fivetran/go-fivetran#ConnectorSchemaDetailsService)
 [Retrieve source table columns config](https://fivetran.com/docs/rest-api/connectors#retrievesourcetablecolumnsconfig) | v1 | [ConnectorColumnConfigListService](https://pkg.go.dev/github.com/fivetran/go-fivetran#ConnectorColumnConfigListService)
 [Reload a connector schema config](https://fivetran.com/docs/rest-api/connectors#reloadaconnectorschemaconfig) | v1 | [ConnectorSchemaReloadService](https://pkg.go.dev/github.com/fivetran/go-fivetran#ConnectorSchemaReloadService)
+[Create a Connector Schema Config](https://fivetran.com/docs/rest-api/connectors#createaconnectorschemaconfig) | v1 | [ConnectorSchemaConfigCreateService](https://pkg.go.dev/github.com/fivetran/go-fivetran#ConnectorSchemaConfigCreateService)
 [Modify a connector schema config](https://fivetran.com/docs/rest-api/connectors#modifyaconnectorschemaconfig) | v1 | [ConnectorSchemaConfigUpdateService](https://pkg.go.dev/github.com/fivetran/go-fivetran#ConnectorSchemaConfigUpdateService)
 [Modify a connector database schema config](https://fivetran.com/docs/rest-api/connectors#modifyaconnectordatabaseschemaconfig) | v1 | [ConnectorDatabaseSchemaConfigModifyService](https://pkg.go.dev/github.com/fivetran/go-fivetran#ConnectorDatabaseSchemaConfigModifyService)
 [Modify a connector table config](https://fivetran.com/docs/rest-api/connectors#modifyaconnectortableconfig) | v1 | [ConnectorTableConfigModifyService](https://pkg.go.dev/github.com/fivetran/go-fivetran#ConnectorTableConfigModifyService)

diff --git a/client.go b/client.go
@@ -14,13 +14,13 @@ import (
 	"github.com/fivetran/go-fivetran/fingerprints"
 	"github.com/fivetran/go-fivetran/groups"
 	httputils "github.com/fivetran/go-fivetran/http_utils"
-	privatelink "github.com/fivetran/go-fivetran/private_link"
 	localprocessingagent "github.com/fivetran/go-fivetran/local_processing_agent"
+	privatelink "github.com/fivetran/go-fivetran/private_link"
+	"github.com/fivetran/go-fivetran/proxy"
 	"github.com/fivetran/go-fivetran/roles"
 	"github.com/fivetran/go-fivetran/teams"
 	"github.com/fivetran/go-fivetran/users"
 	"github.com/fivetran/go-fivetran/webhooks"
-	"github.com/fivetran/go-fivetran/proxy"
 )
 
 // Client holds client configuration
@@ -575,6 +575,10 @@ func (c *Client) NewConnectorSchemaUpdateService() *connectors.ConnectorSchemaCo
 	return &connectors.ConnectorSchemaConfigUpdateService{HttpService: c.NewHttpService()}
 }
 
+func (c *Client) NewConnectorSchemaCreateService() *connectors.ConnectorSchemaConfigCreateService {
+	return &connectors.ConnectorSchemaConfigCreateService{HttpService: c.NewHttpService()}
+}
+
 func (c *Client) NewConnectorTableConfigModifyService() *connectors.ConnectorTableConfigModifyService {
 	return &connectors.ConnectorTableConfigModifyService{HttpService: c.NewHttpService()}
 }
@@ -644,4 +648,4 @@ func (c *Client) NewLocalProcessingAgentList() *localprocessingagent.LocalProces
 
 func (c *Client) NewLocalProcessingAgentReAuth() *localprocessingagent.LocalProcessingAgentReAuthService {
 	return &localprocessingagent.LocalProcessingAgentReAuthService{HttpService: c.NewHttpService()}
-}
+}