fivetran

package module
v0.7.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 28, 2023 License: Apache-2.0 Imports: 9 Imported by: 42

README

Fivetran SDK for Go

Go Reference

go-fivetran is the official Fivetran SDK for the Go programming language.

Checkout our CHANGELOG for information about the latest bug fixes, updates, and features added to the SDK.

Make sure you read the Fivetran REST API documentation before using the SDK.

NOTE: go-fivetran is still in ALPHA development stage. Future versions may introduce breaking changes.

Installation

go get github.com/fivetran/go-fivetran

Importing

import (
    "github.com/fivetran/go-fivetran"
)

Getting started

Initialize a new Fivetran client:

	// get apiKey and apiSecret from environment variables
	apiKey := os.Getenv("FIVETRAN_APIKEY")
	apiSecret := os.Getenv("FIVETRAN_APISECRET")

	// initialize a new client
	client := fivetran.New(apiKey, apiSecret)

Each REST API endpoint has a service. Initialize a new Service:

	// initialize a new UsersList service
	svc := client.NewUsersList()

Call the API:

	// call the REST API
	resp, err := svc.Do(context.Background())
	if err != nil {
		...
	}

Or you can simply call API in chain style. Call Do() at the end to send an HTTP request to the REST API:

	resp, err := client.NewUsersList().
		Limit(3).
		Do(context.Background())

Examples

You can find examples for all services in the examples directory.

API List

The following Fivetran REST API endpoints are implemented by the Fivetran SDK for Go:

User Management API
REST API Endpoint REST API Version SDK Service
List all Users v1 UsersListService
Retrieve user details v1 UserDetailsService
Invite a user v1 UserInviteService
Modify a user v1 UserModifyService
Delete a user v1 UserDeleteService
Group Management API
REST API Endpoint REST API Version SDK Service
Create a group v1 GroupCreateService
List all groups v1 GroupsListService
Retrieve group details v1 GroupDetailsService
Modify a group v1 GroupModifyService
List all connectors within a group v1 GroupListConnectorsService
List all users within a group v1 GroupListUsersService
Add a user to a group v1 GroupAddUserService
Remove a user from a group v1 GroupRemoveUserService
Delete a group v1 GroupDeleteService
Destination Management API
REST API Endpoint REST API Version SDK Service/Config
Create a destination v1 DestinationCreateService
Retrieve destination details v1 DestinationDetailsService
Modify a destination v1 DestinationModifyService
Run destination setup tests v1 DestinationSetupTestsService
Delete a destination v1 DestinationDeleteService
Destination Config v1 DestinationConfig
Connector Management API
REST API Endpoint REST API Version SDK Service/Config/Auth
Retrieve source metadata v1 ConnectorsSourceMetadataService
Create a connector v2 ConnectorCreateService
Retrieve connector details v2 ConnectorDetailsService
Modify a connector v2 ConnectorModifyService
Sync connector data v1 ConnectorSyncService
Re-sync connector table data v1 ConnectorReSyncTableService
Run connector setup tests v2 ConnectorSetupTestsService
Delete a connector v1 ConnectorDeleteService
Retrieve a connector schema config not implemented
Retrieve source table columns config not implemented
Reload a connector schema config not implemented
Modify a connector schema config not implemented
Modify a connector database schema config not implemented
Modify a connector table config not implemented
Modify a connector column config not implemented
Connector Config v1 ConnectorConfig
ConnectorConfigReports
ConnectorConfigProjectCredentials
ConnectorConfigCustomTables
Connector Auth v1 ConnectorAuth
ConnectorAuthClientAccess
Connect Card not implemented
Certificate Management API
REST API Endpoint REST API Version SDK Service
Approve a connector certificate v1 CertificateConnectorCertificateApproveService
Approve a connector fingerprint v1 CertificateConnectorFingerprintApproveService
Approve a destination certificate v1 CertificateDestinationCertificateApproveService
Approve a destination fingerprint v1 CertificateDestinationFingerprintApproveService

Support

Please get in touch with us through our Support Portal if you have any comments, suggestions, support requests, or bug reports.

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Debug 

func Debug(b bool)

Debug sets debug

func DebugAuth 

func DebugAuth(b bool)

DebugAuth sets authentication debug

func FetchFromMap added in v0.7.0 

func FetchFromMap(source *map[string]interface{}, target any) error

func MergeIntoMap added in v0.7.0 

func MergeIntoMap(obj any, target *map[string]interface{}) error

Types

type CertificateConnectorCertificateApproveResponse 

type CertificateConnectorCertificateApproveResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
}

type CertificateConnectorCertificateApproveService 

type CertificateConnectorCertificateApproveService struct {
	// contains filtered or unexported fields
}

CertificateConnectorCertificateApproveService implements the Certificate Management, Approve a connector certificate API. Ref. https://fivetran.com/docs/rest-api/certificates#approveaconnectorcertificate

func (*CertificateConnectorCertificateApproveService) ConnectorID 

func (s *CertificateConnectorCertificateApproveService) ConnectorID(value string) *CertificateConnectorCertificateApproveService

func (*CertificateConnectorCertificateApproveService) Do 

func (s *CertificateConnectorCertificateApproveService) Do(ctx context.Context) (CertificateConnectorCertificateApproveResponse, error)

func (*CertificateConnectorCertificateApproveService) EncodedCert 

func (s *CertificateConnectorCertificateApproveService) EncodedCert(value string) *CertificateConnectorCertificateApproveService

func (*CertificateConnectorCertificateApproveService) Hash 

func (s *CertificateConnectorCertificateApproveService) Hash(value string) *CertificateConnectorCertificateApproveService

type CertificateConnectorFingerprintApproveResponse 

type CertificateConnectorFingerprintApproveResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
}

type CertificateConnectorFingerprintApproveService 

type CertificateConnectorFingerprintApproveService struct {
	// contains filtered or unexported fields
}

CertificateConnectorFingerprintApproveService implements the Certificate Management, Approve a connector fingerprint API. Ref. https://fivetran.com/docs/rest-api/certificates#approveaconnectorfingerprint

func (*CertificateConnectorFingerprintApproveService) ConnectorID 

func (s *CertificateConnectorFingerprintApproveService) ConnectorID(value string) *CertificateConnectorFingerprintApproveService

func (*CertificateConnectorFingerprintApproveService) Do 

func (s *CertificateConnectorFingerprintApproveService) Do(ctx context.Context) (CertificateConnectorFingerprintApproveResponse, error)

func (*CertificateConnectorFingerprintApproveService) Hash 

func (s *CertificateConnectorFingerprintApproveService) Hash(value string) *CertificateConnectorFingerprintApproveService

func (*CertificateConnectorFingerprintApproveService) PublicKey 

func (s *CertificateConnectorFingerprintApproveService) PublicKey(value string) *CertificateConnectorFingerprintApproveService

type CertificateDestinationCertificateApproveResponse 

type CertificateDestinationCertificateApproveResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
}

type CertificateDestinationCertificateApproveService 

type CertificateDestinationCertificateApproveService struct {
	// contains filtered or unexported fields
}

CertificateDestinationCertificateApproveService implements the Certificate Management, Approve a destination certificate API. Ref. https://fivetran.com/docs/rest-api/certificates#approveadestinationcertificate

func (*CertificateDestinationCertificateApproveService) DestinationID 

func (s *CertificateDestinationCertificateApproveService) DestinationID(value string) *CertificateDestinationCertificateApproveService

func (*CertificateDestinationCertificateApproveService) Do 

func (s *CertificateDestinationCertificateApproveService) Do(ctx context.Context) (CertificateDestinationCertificateApproveResponse, error)

func (*CertificateDestinationCertificateApproveService) EncodedCert 

func (s *CertificateDestinationCertificateApproveService) EncodedCert(value string) *CertificateDestinationCertificateApproveService

func (*CertificateDestinationCertificateApproveService) Hash 

func (s *CertificateDestinationCertificateApproveService) Hash(value string) *CertificateDestinationCertificateApproveService

type CertificateDestinationFingerprintApproveResponse 

type CertificateDestinationFingerprintApproveResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
}

type CertificateDestinationFingerprintApproveService 

type CertificateDestinationFingerprintApproveService struct {
	// contains filtered or unexported fields
}

CertificateDestinationFingerprintApproveService implements the Certificate Management, Approve a destination fingerprint API. Ref. https://fivetran.com/docs/rest-api/certificates#approveadestinationfingerprint

func (*CertificateDestinationFingerprintApproveService) DestinationID 

func (s *CertificateDestinationFingerprintApproveService) DestinationID(value string) *CertificateDestinationFingerprintApproveService

func (*CertificateDestinationFingerprintApproveService) Do 

func (s *CertificateDestinationFingerprintApproveService) Do(ctx context.Context) (CertificateDestinationFingerprintApproveResponse, error)

func (*CertificateDestinationFingerprintApproveService) Hash 

func (s *CertificateDestinationFingerprintApproveService) Hash(value string) *CertificateDestinationFingerprintApproveService

func (*CertificateDestinationFingerprintApproveService) PublicKey 

func (s *CertificateDestinationFingerprintApproveService) PublicKey(value string) *CertificateDestinationFingerprintApproveService

type Client 

type Client struct {
	// contains filtered or unexported fields
}

Client holds client configuration

func New 

func New(apiKey, apiSecret string) *Client

New receives API Key and API Secret, and returns a new Client with the default HTTP client

func (*Client) BaseURL 

func (c *Client) BaseURL(baseURL string)

BaseURL changes Client base REST API endpoint URL

func (*Client) CustomUserAgent added in v0.3.0 

func (c *Client) CustomUserAgent(customUserAgent string)

CustomUserAgent sets custom User-Agent header in Client requests

func (*Client) NewCertificateConnectorCertificateApprove 

func (c *Client) NewCertificateConnectorCertificateApprove() *CertificateConnectorCertificateApproveService

func (*Client) NewCertificateConnectorFingerprintApprove 

func (c *Client) NewCertificateConnectorFingerprintApprove() *CertificateConnectorFingerprintApproveService

func (*Client) NewCertificateDestinationCertificateApprove 

func (c *Client) NewCertificateDestinationCertificateApprove() *CertificateDestinationCertificateApproveService

func (*Client) NewCertificateDestinationFingerprintApprove 

func (c *Client) NewCertificateDestinationFingerprintApprove() *CertificateDestinationFingerprintApproveService

func (*Client) NewConnectorCreate 

func (c *Client) NewConnectorCreate() *ConnectorCreateService

func (*Client) NewConnectorDelete 

func (c *Client) NewConnectorDelete() *ConnectorDeleteService

func (*Client) NewConnectorDetails 

func (c *Client) NewConnectorDetails() *ConnectorDetailsService

func (*Client) NewConnectorModify 

func (c *Client) NewConnectorModify() *ConnectorModifyService

func (*Client) NewConnectorReSyncTable 

func (c *Client) NewConnectorReSyncTable() *ConnectorReSyncTableService

func (*Client) NewConnectorSchemaDetails added in v0.6.0 

func (c *Client) NewConnectorSchemaDetails() *ConnectorSchemaDetailsService

func (*Client) NewConnectorSchemaReload added in v0.6.0 

func (c *Client) NewConnectorSchemaReload() *ConnectorSchemaReloadService

func (*Client) NewConnectorSchemaUpdateService added in v0.6.0 

func (c *Client) NewConnectorSchemaUpdateService() *ConnectorSchemaConfigUpdateService

func (*Client) NewConnectorSetupTests 

func (c *Client) NewConnectorSetupTests() *ConnectorSetupTestsService

func (*Client) NewConnectorSync 

func (c *Client) NewConnectorSync() *ConnectorSyncService

func (*Client) NewConnectorsSourceMetadata 

func (c *Client) NewConnectorsSourceMetadata() *ConnectorsSourceMetadataService

func (*Client) NewDestinationCreate 

func (c *Client) NewDestinationCreate() *DestinationCreateService

func (*Client) NewDestinationDelete 

func (c *Client) NewDestinationDelete() *DestinationDeleteService

func (*Client) NewDestinationDetails 

func (c *Client) NewDestinationDetails() *DestinationDetailsService

func (*Client) NewDestinationModify 

func (c *Client) NewDestinationModify() *DestinationModifyService

func (*Client) NewDestinationSetupTests 

func (c *Client) NewDestinationSetupTests() *DestinationSetupTestsService

func (*Client) NewGroupAddUser 

func (c *Client) NewGroupAddUser() *GroupAddUserService

func (*Client) NewGroupCreate 

func (c *Client) NewGroupCreate() *GroupCreateService

func (*Client) NewGroupDelete 

func (c *Client) NewGroupDelete() *GroupDeleteService

func (*Client) NewGroupDetails 

func (c *Client) NewGroupDetails() *GroupDetailsService

func (*Client) NewGroupListConnectors 

func (c *Client) NewGroupListConnectors() *GroupListConnectorsService

func (*Client) NewGroupListUsers 

func (c *Client) NewGroupListUsers() *GroupListUsersService

func (*Client) NewGroupModify 

func (c *Client) NewGroupModify() *GroupModifyService

func (*Client) NewGroupRemoveUser 

func (c *Client) NewGroupRemoveUser() *GroupRemoveUserService

func (*Client) NewGroupsList 

func (c *Client) NewGroupsList() *GroupsListService

func (*Client) NewUserDelete 

func (c *Client) NewUserDelete() *UserDeleteService

func (*Client) NewUserDetails 

func (c *Client) NewUserDetails() *UserDetailsService

func (*Client) NewUserInvite 

func (c *Client) NewUserInvite() *UserInviteService

func (*Client) NewUserModify 

func (c *Client) NewUserModify() *UserModifyService

func (*Client) NewUsersList 

func (c *Client) NewUsersList() *UsersListService

func (*Client) SetHttpClient added in v0.6.4 

func (c *Client) SetHttpClient(httpClient HttpClient)

SetHttpClient sets custom HTTP client to perform requests with

type ConnectorAuth 

type ConnectorAuth struct {
	// contains filtered or unexported fields
}

ConnectorAuth builds Connector Management, Auth. Ref. https://fivetran.com/docs/rest-api/connectors

func NewConnectorAuth 

func NewConnectorAuth() *ConnectorAuth

func (*ConnectorAuth) AccessToken 

func (ca *ConnectorAuth) AccessToken(value string) *ConnectorAuth

func (*ConnectorAuth) ClientAccess 

func (ca *ConnectorAuth) ClientAccess(value *ConnectorAuthClientAccess) *ConnectorAuth

func (*ConnectorAuth) RealmID 

func (ca *ConnectorAuth) RealmID(value string) *ConnectorAuth

func (*ConnectorAuth) RefreshToken 

func (ca *ConnectorAuth) RefreshToken(value string) *ConnectorAuth

type ConnectorAuthClientAccess 

type ConnectorAuthClientAccess struct {
	// contains filtered or unexported fields
}

ConnectorAuthClientAccess builds Connector Management, Auth Client Access. Ref. https://fivetran.com/docs/rest-api/connectors

func NewConnectorAuthClientAccess 

func NewConnectorAuthClientAccess() *ConnectorAuthClientAccess

func (*ConnectorAuthClientAccess) ClientID 

func (ca *ConnectorAuthClientAccess) ClientID(value string) *ConnectorAuthClientAccess

func (*ConnectorAuthClientAccess) ClientSecret 

func (ca *ConnectorAuthClientAccess) ClientSecret(value string) *ConnectorAuthClientAccess

func (*ConnectorAuthClientAccess) DeveloperToken 

func (ca *ConnectorAuthClientAccess) DeveloperToken(value string) *ConnectorAuthClientAccess

func (*ConnectorAuthClientAccess) UserAgent 

func (ca *ConnectorAuthClientAccess) UserAgent(value string) *ConnectorAuthClientAccess

type ConnectorConfig 

type ConnectorConfig struct {
	// contains filtered or unexported fields
}

ConnectorConfig builds Connector Management, Connector Config. Ref. https://fivetran.com/docs/rest-api/connectors/config

func NewConnectorConfig 

func NewConnectorConfig() *ConnectorConfig

func (*ConnectorConfig) ABSConnectionString 

func (cc *ConnectorConfig) ABSConnectionString(value string) *ConnectorConfig

func (*ConnectorConfig) ABSContainerName 

func (cc *ConnectorConfig) ABSContainerName(value string) *ConnectorConfig

func (*ConnectorConfig) APIAccessToken 

func (cc *ConnectorConfig) APIAccessToken(value string) *ConnectorConfig

func (*ConnectorConfig) APIKey 

func (cc *ConnectorConfig) APIKey(value string) *ConnectorConfig

func (*ConnectorConfig) APIKeys 

func (cc *ConnectorConfig) APIKeys(value []string) *ConnectorConfig

func (*ConnectorConfig) APIQuota 

func (cc *ConnectorConfig) APIQuota(value int) *ConnectorConfig

func (*ConnectorConfig) APISecret 

func (cc *ConnectorConfig) APISecret(value string) *ConnectorConfig

func (*ConnectorConfig) APIToken 

func (cc *ConnectorConfig) APIToken(value string) *ConnectorConfig

func (*ConnectorConfig) APIURL 

func (cc *ConnectorConfig) APIURL(value string) *ConnectorConfig

func (*ConnectorConfig) APIVersion 

func (cc *ConnectorConfig) APIVersion(value string) *ConnectorConfig

func (*ConnectorConfig) AWSRegionCode 

func (cc *ConnectorConfig) AWSRegionCode(value string) *ConnectorConfig

func (*ConnectorConfig) AccessKeyID 

func (cc *ConnectorConfig) AccessKeyID(value string) *ConnectorConfig

func (*ConnectorConfig) AccessToken 

func (cc *ConnectorConfig) AccessToken(value string) *ConnectorConfig

func (*ConnectorConfig) Account 

func (cc *ConnectorConfig) Account(value string) *ConnectorConfig

func (*ConnectorConfig) AccountID 

func (cc *ConnectorConfig) AccountID(value string) *ConnectorConfig

func (*ConnectorConfig) AccountIDs 

func (cc *ConnectorConfig) AccountIDs(value []string) *ConnectorConfig

func (*ConnectorConfig) Accounts 

func (cc *ConnectorConfig) Accounts(value []string) *ConnectorConfig

func (*ConnectorConfig) ActionBreakdowns 

func (cc *ConnectorConfig) ActionBreakdowns(value []string) *ConnectorConfig

func (*ConnectorConfig) ActionReportTime 

func (cc *ConnectorConfig) ActionReportTime(value string) *ConnectorConfig

func (*ConnectorConfig) AdobeAnalyticsConfigurations added in v0.4.0 

func (cc *ConnectorConfig) AdobeAnalyticsConfigurations(value []*ConnectorConfigAdobeAnalyticsConfiguration) *ConnectorConfig

func (*ConnectorConfig) Advertisables 

func (cc *ConnectorConfig) Advertisables(value []string) *ConnectorConfig

func (*ConnectorConfig) Advertisers 

func (cc *ConnectorConfig) Advertisers(value []string) *ConnectorConfig

func (*ConnectorConfig) AdvertisersID 

func (cc *ConnectorConfig) AdvertisersID(value []string) *ConnectorConfig

func (*ConnectorConfig) Aggregation 

func (cc *ConnectorConfig) Aggregation(value string) *ConnectorConfig

func (*ConnectorConfig) AlwaysEncrypted added in v0.5.2 

func (cc *ConnectorConfig) AlwaysEncrypted(value bool) *ConnectorConfig

func (*ConnectorConfig) ApiType added in v0.5.3 

func (cc *ConnectorConfig) ApiType(value string) *ConnectorConfig

func (*ConnectorConfig) AppSyncMode 

func (cc *ConnectorConfig) AppSyncMode(value string) *ConnectorConfig

func (*ConnectorConfig) AppendFileOption 

func (cc *ConnectorConfig) AppendFileOption(value string) *ConnectorConfig

func (*ConnectorConfig) Apps 

func (cc *ConnectorConfig) Apps(value []string) *ConnectorConfig

func (*ConnectorConfig) ArchivePattern 

func (cc *ConnectorConfig) ArchivePattern(value string) *ConnectorConfig

func (*ConnectorConfig) AuthMode 

func (cc *ConnectorConfig) AuthMode(value string) *ConnectorConfig

func (*ConnectorConfig) AuthType added in v0.2.0 

func (cc *ConnectorConfig) AuthType(value string) *ConnectorConfig

func (*ConnectorConfig) BaseUrl added in v0.5.4 

func (cc *ConnectorConfig) BaseUrl(value string) *ConnectorConfig

func (*ConnectorConfig) Breakdowns 

func (cc *ConnectorConfig) Breakdowns(value []string) *ConnectorConfig

func (*ConnectorConfig) Bucket 

func (cc *ConnectorConfig) Bucket(value string) *ConnectorConfig

func (*ConnectorConfig) BucketName 

func (cc *ConnectorConfig) BucketName(value string) *ConnectorConfig

func (*ConnectorConfig) BucketService 

func (cc *ConnectorConfig) BucketService(value string) *ConnectorConfig

func (*ConnectorConfig) Certificate 

func (cc *ConnectorConfig) Certificate(value string) *ConnectorConfig

func (*ConnectorConfig) ClickAttributionWindow 

func (cc *ConnectorConfig) ClickAttributionWindow(value string) *ConnectorConfig

func (*ConnectorConfig) ClientID 

func (cc *ConnectorConfig) ClientID(value string) *ConnectorConfig

func (*ConnectorConfig) ClientSecret 

func (cc *ConnectorConfig) ClientSecret(value string) *ConnectorConfig

func (*ConnectorConfig) CloudStorageType 

func (cc *ConnectorConfig) CloudStorageType(value string) *ConnectorConfig

func (*ConnectorConfig) Columns 

func (cc *ConnectorConfig) Columns(value []string) *ConnectorConfig

func (*ConnectorConfig) Compression 

func (cc *ConnectorConfig) Compression(value string) *ConnectorConfig

func (*ConnectorConfig) ConfigMethod 

func (cc *ConnectorConfig) ConfigMethod(value string) *ConnectorConfig

func (*ConnectorConfig) ConfigType 

func (cc *ConnectorConfig) ConfigType(value string) *ConnectorConfig

func (*ConnectorConfig) ConnectionString 

func (cc *ConnectorConfig) ConnectionString(value string) *ConnectorConfig

func (*ConnectorConfig) ConnectionType added in v0.5.1 

func (cc *ConnectorConfig) ConnectionType(value string) *ConnectorConfig

func (*ConnectorConfig) ConsumerGroup 

func (cc *ConnectorConfig) ConsumerGroup(value string) *ConnectorConfig

func (*ConnectorConfig) ConsumerKey 

func (cc *ConnectorConfig) ConsumerKey(value string) *ConnectorConfig

func (*ConnectorConfig) ConsumerSecret 

func (cc *ConnectorConfig) ConsumerSecret(value string) *ConnectorConfig

func (*ConnectorConfig) ContainerName 

func (cc *ConnectorConfig) ContainerName(value string) *ConnectorConfig

func (*ConnectorConfig) ConversionReportTime 

func (cc *ConnectorConfig) ConversionReportTime(value string) *ConnectorConfig

func (*ConnectorConfig) ConversionWindowSize 

func (cc *ConnectorConfig) ConversionWindowSize(value int) *ConnectorConfig

func (*ConnectorConfig) CustomTables 

func (cc *ConnectorConfig) CustomTables(value []*ConnectorConfigCustomTables) *ConnectorConfig

func (*ConnectorConfig) CustomerID 

func (cc *ConnectorConfig) CustomerID(value string) *ConnectorConfig

func (*ConnectorConfig) DailyAPICallLimit 

func (cc *ConnectorConfig) DailyAPICallLimit(value int) *ConnectorConfig

func (*ConnectorConfig) DataCenter 

func (cc *ConnectorConfig) DataCenter(value string) *ConnectorConfig

func (*ConnectorConfig) Database 

func (cc *ConnectorConfig) Database(value string) *ConnectorConfig

func (*ConnectorConfig) DatasetID 

func (cc *ConnectorConfig) DatasetID(value string) *ConnectorConfig

func (*ConnectorConfig) Datasource 

func (cc *ConnectorConfig) Datasource(value string) *ConnectorConfig

func (*ConnectorConfig) DateGranularity 

func (cc *ConnectorConfig) DateGranularity(value string) *ConnectorConfig

func (*ConnectorConfig) Delimiter 

func (cc *ConnectorConfig) Delimiter(value string) *ConnectorConfig

func (*ConnectorConfig) DimensionAttributes 

func (cc *ConnectorConfig) DimensionAttributes(value []string) *ConnectorConfig

func (*ConnectorConfig) Dimensions 

func (cc *ConnectorConfig) Dimensions(value []string) *ConnectorConfig

func (*ConnectorConfig) Domain 

func (cc *ConnectorConfig) Domain(value string) *ConnectorConfig

func (*ConnectorConfig) DomainName 

func (cc *ConnectorConfig) DomainName(value string) *ConnectorConfig

func (*ConnectorConfig) Elements 

func (cc *ConnectorConfig) Elements(value []string) *ConnectorConfig

func (*ConnectorConfig) Email 

func (cc *ConnectorConfig) Email(value string) *ConnectorConfig

func (*ConnectorConfig) EnableAllDimensionCombinations 

func (cc *ConnectorConfig) EnableAllDimensionCombinations(value bool) *ConnectorConfig

func (*ConnectorConfig) EncryptionKey added in v0.5.4 

func (cc *ConnectorConfig) EncryptionKey(value string) *ConnectorConfig

func (*ConnectorConfig) Endpoint 

func (cc *ConnectorConfig) Endpoint(value string) *ConnectorConfig

func (*ConnectorConfig) EngagementAttributionWindow 

func (cc *ConnectorConfig) EngagementAttributionWindow(value string) *ConnectorConfig

func (*ConnectorConfig) EntityId added in v0.5.4 

func (cc *ConnectorConfig) EntityId(value string) *ConnectorConfig

func (*ConnectorConfig) EscapeChar 

func (cc *ConnectorConfig) EscapeChar(value string) *ConnectorConfig

func (*ConnectorConfig) EuRegion added in v0.5.10 

func (cc *ConnectorConfig) EuRegion(value bool) *ConnectorConfig

func (*ConnectorConfig) ExternalID 

func (cc *ConnectorConfig) ExternalID(value string) *ConnectorConfig

func (*ConnectorConfig) FTPHost 

func (cc *ConnectorConfig) FTPHost(value string) *ConnectorConfig

func (*ConnectorConfig) FTPPassword 

func (cc *ConnectorConfig) FTPPassword(value string) *ConnectorConfig

func (*ConnectorConfig) FTPPort 

func (cc *ConnectorConfig) FTPPort(value int) *ConnectorConfig

func (*ConnectorConfig) FTPUser 

func (cc *ConnectorConfig) FTPUser(value string) *ConnectorConfig

func (*ConnectorConfig) Fields 

func (cc *ConnectorConfig) Fields(value []string) *ConnectorConfig

func (*ConnectorConfig) FileType 

func (cc *ConnectorConfig) FileType(value string) *ConnectorConfig

func (*ConnectorConfig) FinanceAccountSyncMode 

func (cc *ConnectorConfig) FinanceAccountSyncMode(value string) *ConnectorConfig

func (*ConnectorConfig) FinanceAccounts 

func (cc *ConnectorConfig) FinanceAccounts(value []string) *ConnectorConfig

func (*ConnectorConfig) FolderId added in v0.5.5 

func (cc *ConnectorConfig) FolderId(value string) *ConnectorConfig

func (*ConnectorConfig) Function 

func (cc *ConnectorConfig) Function(value string) *ConnectorConfig

func (*ConnectorConfig) FunctionApp 

func (cc *ConnectorConfig) FunctionApp(value string) *ConnectorConfig

func (*ConnectorConfig) FunctionKey 

func (cc *ConnectorConfig) FunctionKey(value string) *ConnectorConfig

func (*ConnectorConfig) FunctionName 

func (cc *ConnectorConfig) FunctionName(value string) *ConnectorConfig

func (*ConnectorConfig) FunctionTrigger 

func (cc *ConnectorConfig) FunctionTrigger(value string) *ConnectorConfig

func (*ConnectorConfig) GCSBucket 

func (cc *ConnectorConfig) GCSBucket(value string) *ConnectorConfig

func (*ConnectorConfig) GCSFolder 

func (cc *ConnectorConfig) GCSFolder(value string) *ConnectorConfig

func (*ConnectorConfig) HomeFolder 

func (cc *ConnectorConfig) HomeFolder(value string) *ConnectorConfig

func (*ConnectorConfig) Host 

func (cc *ConnectorConfig) Host(value string) *ConnectorConfig

func (*ConnectorConfig) Hosts 

func (cc *ConnectorConfig) Hosts(value []string) *ConnectorConfig

func (*ConnectorConfig) Identity 

func (cc *ConnectorConfig) Identity(value string) *ConnectorConfig

func (*ConnectorConfig) Instance 

func (cc *ConnectorConfig) Instance(value string) *ConnectorConfig

func (*ConnectorConfig) IntegrationKey 

func (cc *ConnectorConfig) IntegrationKey(value string) *ConnectorConfig

func (*ConnectorConfig) IsFTPS 

func (cc *ConnectorConfig) IsFTPS(value bool) *ConnectorConfig

func (*ConnectorConfig) IsKeypair added in v0.7.0 

func (cc *ConnectorConfig) IsKeypair(value bool) *ConnectorConfig

func (*ConnectorConfig) IsMultiEntityFeatureEnabled added in v0.5.2 

func (cc *ConnectorConfig) IsMultiEntityFeatureEnabled(value bool) *ConnectorConfig

func (*ConnectorConfig) IsNewPackage added in v0.4.0 

func (cc *ConnectorConfig) IsNewPackage(value bool) *ConnectorConfig

func (*ConnectorConfig) IsSecure 

func (cc *ConnectorConfig) IsSecure(value bool) *ConnectorConfig

func (*ConnectorConfig) Key 

func (cc *ConnectorConfig) Key(value string) *ConnectorConfig

func (*ConnectorConfig) ManagerAccounts 

func (cc *ConnectorConfig) ManagerAccounts(value []string) *ConnectorConfig

func (*ConnectorConfig) MerchantID 

func (cc *ConnectorConfig) MerchantID(value string) *ConnectorConfig

func (*ConnectorConfig) MessageType 

func (cc *ConnectorConfig) MessageType(value string) *ConnectorConfig

func (*ConnectorConfig) Metrics 

func (cc *ConnectorConfig) Metrics(value []string) *ConnectorConfig

func (*ConnectorConfig) NamedRange 

func (cc *ConnectorConfig) NamedRange(value string) *ConnectorConfig

func (*ConnectorConfig) NetworkCode 

func (cc *ConnectorConfig) NetworkCode(value string) *ConnectorConfig

func (*ConnectorConfig) NullSequence 

func (cc *ConnectorConfig) NullSequence(value string) *ConnectorConfig

func (*ConnectorConfig) OauthToken 

func (cc *ConnectorConfig) OauthToken(value string) *ConnectorConfig

func (*ConnectorConfig) OauthTokenSecret 

func (cc *ConnectorConfig) OauthTokenSecret(value string) *ConnectorConfig

func (*ConnectorConfig) OnError 

func (cc *ConnectorConfig) OnError(value string) *ConnectorConfig

func (*ConnectorConfig) OnPremise 

func (cc *ConnectorConfig) OnPremise(value bool) *ConnectorConfig

func (*ConnectorConfig) OrganizationID 

func (cc *ConnectorConfig) OrganizationID(value string) *ConnectorConfig

func (*ConnectorConfig) Organizations 

func (cc *ConnectorConfig) Organizations(value []string) *ConnectorConfig

func (*ConnectorConfig) PAT added in v0.5.11 

func (cc *ConnectorConfig) PAT(value string) *ConnectorConfig

func (*ConnectorConfig) PEMCertificate 

func (cc *ConnectorConfig) PEMCertificate(value string) *ConnectorConfig

func (*ConnectorConfig) Pages 

func (cc *ConnectorConfig) Pages(value []string) *ConnectorConfig

func (*ConnectorConfig) Password 

func (cc *ConnectorConfig) Password(value string) *ConnectorConfig

func (*ConnectorConfig) Path 

func (cc *ConnectorConfig) Path(value string) *ConnectorConfig

func (*ConnectorConfig) Pattern 

func (cc *ConnectorConfig) Pattern(value string) *ConnectorConfig

func (*ConnectorConfig) Port 

func (cc *ConnectorConfig) Port(value int) *ConnectorConfig

func (*ConnectorConfig) PostClickAttributionWindowSize 

func (cc *ConnectorConfig) PostClickAttributionWindowSize(value string) *ConnectorConfig

func (*ConnectorConfig) PrebuiltReport 

func (cc *ConnectorConfig) PrebuiltReport(value string) *ConnectorConfig

func (*ConnectorConfig) Prefix 

func (cc *ConnectorConfig) Prefix(value string) *ConnectorConfig

func (*ConnectorConfig) PrivateKey 

func (cc *ConnectorConfig) PrivateKey(value string) *ConnectorConfig

func (*ConnectorConfig) Profiles 

func (cc *ConnectorConfig) Profiles(value []string) *ConnectorConfig

func (*ConnectorConfig) ProjectCredentials 

func (cc *ConnectorConfig) ProjectCredentials(value []*ConnectorConfigProjectCredentials) *ConnectorConfig

func (*ConnectorConfig) ProjectID 

func (cc *ConnectorConfig) ProjectID(value string) *ConnectorConfig

func (*ConnectorConfig) Projects 

func (cc *ConnectorConfig) Projects(value []string) *ConnectorConfig

func (*ConnectorConfig) PublicKey 

func (cc *ConnectorConfig) PublicKey(value string) *ConnectorConfig

func (*ConnectorConfig) PublicationName added in v0.5.9 

func (cc *ConnectorConfig) PublicationName(value string) *ConnectorConfig

func (*ConnectorConfig) QueryID 

func (cc *ConnectorConfig) QueryID(value string) *ConnectorConfig

func (*ConnectorConfig) Region 

func (cc *ConnectorConfig) Region(value string) *ConnectorConfig

func (*ConnectorConfig) ReplicationSlot 

func (cc *ConnectorConfig) ReplicationSlot(value string) *ConnectorConfig

func (*ConnectorConfig) ReportConfigurationIDs 

func (cc *ConnectorConfig) ReportConfigurationIDs(value []string) *ConnectorConfig

func (*ConnectorConfig) ReportSuites 

func (cc *ConnectorConfig) ReportSuites(value []string) *ConnectorConfig

func (*ConnectorConfig) ReportType 

func (cc *ConnectorConfig) ReportType(value string) *ConnectorConfig

func (*ConnectorConfig) ReportURL 

func (cc *ConnectorConfig) ReportURL(value string) *ConnectorConfig

func (*ConnectorConfig) Reports 

func (cc *ConnectorConfig) Reports(value []*ConnectorConfigReports) *ConnectorConfig

func (*ConnectorConfig) Repositories 

func (cc *ConnectorConfig) Repositories(value []string) *ConnectorConfig

func (*ConnectorConfig) ResourceURL 

func (cc *ConnectorConfig) ResourceURL(value string) *ConnectorConfig

func (*ConnectorConfig) Role 

func (cc *ConnectorConfig) Role(value string) *ConnectorConfig

func (*ConnectorConfig) RoleArn 

func (cc *ConnectorConfig) RoleArn(value string) *ConnectorConfig

func (*ConnectorConfig) S3Bucket 

func (cc *ConnectorConfig) S3Bucket(value string) *ConnectorConfig

func (*ConnectorConfig) S3ExternalID 

func (cc *ConnectorConfig) S3ExternalID(value string) *ConnectorConfig

func (*ConnectorConfig) S3Folder 

func (cc *ConnectorConfig) S3Folder(value string) *ConnectorConfig

func (*ConnectorConfig) S3RoleArn 

func (cc *ConnectorConfig) S3RoleArn(value string) *ConnectorConfig

func (*ConnectorConfig) SFTPHost 

func (cc *ConnectorConfig) SFTPHost(value string) *ConnectorConfig

func (*ConnectorConfig) SFTPIsKeyPair 

func (cc *ConnectorConfig) SFTPIsKeyPair(value bool) *ConnectorConfig

func (*ConnectorConfig) SFTPPassword 

func (cc *ConnectorConfig) SFTPPassword(value string) *ConnectorConfig

func (*ConnectorConfig) SFTPPort 

func (cc *ConnectorConfig) SFTPPort(value int) *ConnectorConfig

func (*ConnectorConfig) SFTPUser 

func (cc *ConnectorConfig) SFTPUser(value string) *ConnectorConfig

func (*ConnectorConfig) SID 

func (cc *ConnectorConfig) SID(value string) *ConnectorConfig

func (*ConnectorConfig) SalesAccountSyncMode 

func (cc *ConnectorConfig) SalesAccountSyncMode(value string) *ConnectorConfig

func (*ConnectorConfig) SalesAccounts 

func (cc *ConnectorConfig) SalesAccounts(value []string) *ConnectorConfig

func (*ConnectorConfig) Schema 

func (cc *ConnectorConfig) Schema(value string) *ConnectorConfig

func (*ConnectorConfig) SchemaPrefix 

func (cc *ConnectorConfig) SchemaPrefix(value string) *ConnectorConfig

func (*ConnectorConfig) Secret 

func (cc *ConnectorConfig) Secret(value string) *ConnectorConfig

func (*ConnectorConfig) SecretKey 

func (cc *ConnectorConfig) SecretKey(value string) *ConnectorConfig

func (*ConnectorConfig) Secrets 

func (cc *ConnectorConfig) Secrets(value string) *ConnectorConfig

func (*ConnectorConfig) SecretsList added in v0.7.0 

func (cc *ConnectorConfig) SecretsList(value []*FunctionSecret) *ConnectorConfig

func (*ConnectorConfig) SecurityProtocol 

func (cc *ConnectorConfig) SecurityProtocol(value string) *ConnectorConfig

func (*ConnectorConfig) SelectedExports 

func (cc *ConnectorConfig) SelectedExports(value []string) *ConnectorConfig

func (*ConnectorConfig) ServerURL 

func (cc *ConnectorConfig) ServerURL(value string) *ConnectorConfig

func (*ConnectorConfig) Servers 

func (cc *ConnectorConfig) Servers(value string) *ConnectorConfig

func (*ConnectorConfig) ShareURL added in v0.7.0 

func (cc *ConnectorConfig) ShareURL(value string) *ConnectorConfig

func (*ConnectorConfig) SheetID 

func (cc *ConnectorConfig) SheetID(value string) *ConnectorConfig

func (*ConnectorConfig) Shop 

func (cc *ConnectorConfig) Shop(value string) *ConnectorConfig

func (*ConnectorConfig) SiteURLs 

func (cc *ConnectorConfig) SiteURLs(value []string) *ConnectorConfig

func (*ConnectorConfig) SkipAfter 

func (cc *ConnectorConfig) SkipAfter(value int) *ConnectorConfig

func (*ConnectorConfig) SkipBefore 

func (cc *ConnectorConfig) SkipBefore(value int) *ConnectorConfig

func (*ConnectorConfig) SoapUri added in v0.5.4 

func (cc *ConnectorConfig) SoapUri(value string) *ConnectorConfig

func (*ConnectorConfig) Source 

func (cc *ConnectorConfig) Source(value string) *ConnectorConfig

func (*ConnectorConfig) SubDomain 

func (cc *ConnectorConfig) SubDomain(value string) *ConnectorConfig

func (*ConnectorConfig) Subdomain 

func (cc *ConnectorConfig) Subdomain(value string) *ConnectorConfig

func (*ConnectorConfig) SwipeAttributionWindow 

func (cc *ConnectorConfig) SwipeAttributionWindow(value string) *ConnectorConfig

func (*ConnectorConfig) SyncDataLocker 

func (cc *ConnectorConfig) SyncDataLocker(value bool) *ConnectorConfig

func (*ConnectorConfig) SyncFormat 

func (cc *ConnectorConfig) SyncFormat(value string) *ConnectorConfig

func (*ConnectorConfig) SyncMode 

func (cc *ConnectorConfig) SyncMode(value string) *ConnectorConfig

func (*ConnectorConfig) SyncType 

func (cc *ConnectorConfig) SyncType(value string) *ConnectorConfig

func (*ConnectorConfig) Table 

func (cc *ConnectorConfig) Table(value string) *ConnectorConfig

func (*ConnectorConfig) TechnicalAccountID 

func (cc *ConnectorConfig) TechnicalAccountID(value string) *ConnectorConfig

func (*ConnectorConfig) TestTableName 

func (cc *ConnectorConfig) TestTableName(value string) *ConnectorConfig

func (*ConnectorConfig) TimeZone 

func (cc *ConnectorConfig) TimeZone(value string) *ConnectorConfig

func (*ConnectorConfig) TimeframeMonths 

func (cc *ConnectorConfig) TimeframeMonths(value string) *ConnectorConfig

func (*ConnectorConfig) TokenKey added in v0.6.2 

func (cc *ConnectorConfig) TokenKey(value string) *ConnectorConfig

func (*ConnectorConfig) TokenSecret added in v0.6.2 

func (cc *ConnectorConfig) TokenSecret(value string) *ConnectorConfig

func (*ConnectorConfig) TunnelHost 

func (cc *ConnectorConfig) TunnelHost(value string) *ConnectorConfig

func (*ConnectorConfig) TunnelPort 

func (cc *ConnectorConfig) TunnelPort(value int) *ConnectorConfig

func (*ConnectorConfig) TunnelUser 

func (cc *ConnectorConfig) TunnelUser(value string) *ConnectorConfig

func (*ConnectorConfig) UniqueID 

func (cc *ConnectorConfig) UniqueID(value string) *ConnectorConfig

func (*ConnectorConfig) UpdateConfigOnEachSync 

func (cc *ConnectorConfig) UpdateConfigOnEachSync(value bool) *ConnectorConfig

func (*ConnectorConfig) UpdateMethod 

func (cc *ConnectorConfig) UpdateMethod(value string) *ConnectorConfig

func (*ConnectorConfig) UseAPIKeys 

func (cc *ConnectorConfig) UseAPIKeys(value bool) *ConnectorConfig

func (*ConnectorConfig) UseWebhooks 

func (cc *ConnectorConfig) UseWebhooks(value bool) *ConnectorConfig

func (*ConnectorConfig) User 

func (cc *ConnectorConfig) User(value string) *ConnectorConfig

func (*ConnectorConfig) UserId added in v0.5.4 

func (cc *ConnectorConfig) UserId(value string) *ConnectorConfig

func (*ConnectorConfig) UserKey 

func (cc *ConnectorConfig) UserKey(value string) *ConnectorConfig

func (*ConnectorConfig) UserName 

func (cc *ConnectorConfig) UserName(value string) *ConnectorConfig

func (*ConnectorConfig) UserProfiles 

func (cc *ConnectorConfig) UserProfiles(value []string) *ConnectorConfig

func (*ConnectorConfig) Username 

func (cc *ConnectorConfig) Username(value string) *ConnectorConfig

func (*ConnectorConfig) ViewAttributionWindow 

func (cc *ConnectorConfig) ViewAttributionWindow(value string) *ConnectorConfig

func (*ConnectorConfig) ViewThroughAttributionWindowSize 

func (cc *ConnectorConfig) ViewThroughAttributionWindowSize(value string) *ConnectorConfig

type ConnectorConfigAdobeAnalyticsConfiguration added in v0.4.0 

type ConnectorConfigAdobeAnalyticsConfiguration struct {
	// contains filtered or unexported fields
}

func NewConnectorConfigAdobeAnalyticsConfiguration added in v0.4.0 

func NewConnectorConfigAdobeAnalyticsConfiguration() *ConnectorConfigAdobeAnalyticsConfiguration

func (*ConnectorConfigAdobeAnalyticsConfiguration) CalculatedMetrics added in v0.4.0 

func (c *ConnectorConfigAdobeAnalyticsConfiguration) CalculatedMetrics(value []string) *ConnectorConfigAdobeAnalyticsConfiguration

func (*ConnectorConfigAdobeAnalyticsConfiguration) Elements added in v0.4.0 

func (c *ConnectorConfigAdobeAnalyticsConfiguration) Elements(value []string) *ConnectorConfigAdobeAnalyticsConfiguration

func (*ConnectorConfigAdobeAnalyticsConfiguration) Metrics added in v0.4.0 

func (c *ConnectorConfigAdobeAnalyticsConfiguration) Metrics(value []string) *ConnectorConfigAdobeAnalyticsConfiguration

func (*ConnectorConfigAdobeAnalyticsConfiguration) ReportSuites added in v0.4.0 

func (c *ConnectorConfigAdobeAnalyticsConfiguration) ReportSuites(value []string) *ConnectorConfigAdobeAnalyticsConfiguration

func (*ConnectorConfigAdobeAnalyticsConfiguration) Segments added in v0.4.0 

func (c *ConnectorConfigAdobeAnalyticsConfiguration) Segments(value []string) *ConnectorConfigAdobeAnalyticsConfiguration

func (*ConnectorConfigAdobeAnalyticsConfiguration) SyncMode added in v0.4.0 

func (c *ConnectorConfigAdobeAnalyticsConfiguration) SyncMode(value string) *ConnectorConfigAdobeAnalyticsConfiguration

type ConnectorConfigAdobeAnalyticsConfigurationResponse added in v0.4.0 

type ConnectorConfigAdobeAnalyticsConfigurationResponse struct {
	SyncMode          string   `json:"sync_mode"`
	ReportSuites      []string `json:"report_suites"`
	Elements          []string `json:"elements"`
	Metrics           []string `json:"metrics"`
	CalculatedMetrics []string `json:"calculated_metrics"`
	Segments          []string `json:"segments"`
}

type ConnectorConfigCustomTables 

type ConnectorConfigCustomTables struct {
	// contains filtered or unexported fields
}

ConnectorConfigCustomTables builds Connector Management, Connector Config Custom Tables. Ref. https://fivetran.com/docs/rest-api/connectors/config

func NewConnectorConfigCustomTables 

func NewConnectorConfigCustomTables() *ConnectorConfigCustomTables

func (*ConnectorConfigCustomTables) ActionBreakdowns 

func (ct *ConnectorConfigCustomTables) ActionBreakdowns(value []string) *ConnectorConfigCustomTables

func (*ConnectorConfigCustomTables) ActionReportTime 

func (ct *ConnectorConfigCustomTables) ActionReportTime(value string) *ConnectorConfigCustomTables

func (*ConnectorConfigCustomTables) Aggregation 

func (ct *ConnectorConfigCustomTables) Aggregation(value string) *ConnectorConfigCustomTables

func (*ConnectorConfigCustomTables) Breakdowns 

func (ct *ConnectorConfigCustomTables) Breakdowns(value []string) *ConnectorConfigCustomTables

func (*ConnectorConfigCustomTables) ClickAttributionWindow 

func (ct *ConnectorConfigCustomTables) ClickAttributionWindow(value string) *ConnectorConfigCustomTables

func (*ConnectorConfigCustomTables) ConfigType 

func (ct *ConnectorConfigCustomTables) ConfigType(value string) *ConnectorConfigCustomTables

func (*ConnectorConfigCustomTables) Fields 

func (ct *ConnectorConfigCustomTables) Fields(value []string) *ConnectorConfigCustomTables

func (*ConnectorConfigCustomTables) PrebuiltReportName 

func (ct *ConnectorConfigCustomTables) PrebuiltReportName(value string) *ConnectorConfigCustomTables

func (*ConnectorConfigCustomTables) TableName 

func (ct *ConnectorConfigCustomTables) TableName(value string) *ConnectorConfigCustomTables

func (*ConnectorConfigCustomTables) ViewAttributionWindow 

func (ct *ConnectorConfigCustomTables) ViewAttributionWindow(value string) *ConnectorConfigCustomTables

type ConnectorConfigCustomTablesResponse 

type ConnectorConfigCustomTablesResponse struct {
	TableName              string   `json:"table_name"`
	ConfigType             string   `json:"config_type"`
	Fields                 []string `json:"fields"`
	Breakdowns             []string `json:"breakdowns"`
	ActionBreakdowns       []string `json:"action_breakdowns"`
	Aggregation            string   `json:"aggregation"`
	ActionReportTime       string   `json:"action_report_time"`
	ClickAttributionWindow string   `json:"click_attribution_window"`
	ViewAttributionWindow  string   `json:"view_attribution_window"`
	PrebuiltReportName     string   `json:"prebuilt_report_name"`
}

type ConnectorConfigProjectCredentials 

type ConnectorConfigProjectCredentials struct {
	// contains filtered or unexported fields
}

ConnectorConfigProjectCredentials builds Connector Management, Connector Config Project Credentials. Ref. https://fivetran.com/docs/rest-api/connectors/config

func NewConnectorConfigProjectCredentials 

func NewConnectorConfigProjectCredentials() *ConnectorConfigProjectCredentials

func (*ConnectorConfigProjectCredentials) APIKey 

func (pc *ConnectorConfigProjectCredentials) APIKey(value string) *ConnectorConfigProjectCredentials

func (*ConnectorConfigProjectCredentials) Project 

func (pc *ConnectorConfigProjectCredentials) Project(value string) *ConnectorConfigProjectCredentials

func (*ConnectorConfigProjectCredentials) SecretKey 

func (pc *ConnectorConfigProjectCredentials) SecretKey(value string) *ConnectorConfigProjectCredentials

type ConnectorConfigProjectCredentialsResponse 

type ConnectorConfigProjectCredentialsResponse struct {
	Project   string `json:"project"`
	APIKey    string `json:"api_key"`
	SecretKey string `json:"secret_key"`
}

type ConnectorConfigReports 

type ConnectorConfigReports struct {
	// contains filtered or unexported fields
}

ConnectorConfigReports builds Connector Management, Connector Config Reports. Ref. https://fivetran.com/docs/rest-api/connectors/config

func NewConnectorConfigReports 

func NewConnectorConfigReports() *ConnectorConfigReports

func (*ConnectorConfigReports) ConfigType 

func (r *ConnectorConfigReports) ConfigType(value string) *ConnectorConfigReports

func (*ConnectorConfigReports) Dimensions 

func (r *ConnectorConfigReports) Dimensions(value []string) *ConnectorConfigReports

func (*ConnectorConfigReports) Fields 

func (r *ConnectorConfigReports) Fields(value []string) *ConnectorConfigReports

func (*ConnectorConfigReports) Filter 

func (r *ConnectorConfigReports) Filter(value string) *ConnectorConfigReports

func (*ConnectorConfigReports) Metrics 

func (r *ConnectorConfigReports) Metrics(value []string) *ConnectorConfigReports

func (*ConnectorConfigReports) PrebuiltReport 

func (r *ConnectorConfigReports) PrebuiltReport(value string) *ConnectorConfigReports

func (*ConnectorConfigReports) ReportType 

func (r *ConnectorConfigReports) ReportType(value string) *ConnectorConfigReports

func (*ConnectorConfigReports) Segments 

func (r *ConnectorConfigReports) Segments(value []string) *ConnectorConfigReports

func (*ConnectorConfigReports) Table 

func (r *ConnectorConfigReports) Table(value string) *ConnectorConfigReports

type ConnectorConfigReportsResponse 

type ConnectorConfigReportsResponse struct {
	Table          string   `json:"table"`
	ConfigType     string   `json:"config_type"`
	PrebuiltReport string   `json:"prebuilt_report"`
	ReportType     string   `json:"report_type"`
	Fields         []string `json:"fields"`
	Dimensions     []string `json:"dimensions"`
	Metrics        []string `json:"metrics"`
	Segments       []string `json:"segments"`
	Filter         string   `json:"filter"`
}

type ConnectorConfigResponse 

type ConnectorConfigResponse struct {
	AdobeAnalyticsConfigurations     []ConnectorConfigAdobeAnalyticsConfigurationResponse `json:"adobe_analytics_configurations"`
	Schema                           string                                               `json:"schema"`
	Table                            string                                               `json:"table"`
	SheetID                          string                                               `json:"sheet_id"`
	NamedRange                       string                                               `json:"named_range"`
	ClientID                         string                                               `json:"client_id"`
	ClientSecret                     string                                               `json:"client_secret"`
	TechnicalAccountID               string                                               `json:"technical_account_id"`
	OrganizationID                   string                                               `json:"organization_id"`
	PrivateKey                       string                                               `json:"private_key"`
	SyncMode                         string                                               `json:"sync_mode"`
	ReportSuites                     []string                                             `json:"report_suites"`
	Elements                         []string                                             `json:"elements"`
	Metrics                          []string                                             `json:"metrics"`
	DateGranularity                  string                                               `json:"date_granularity"`
	TimeframeMonths                  string                                               `json:"timeframe_months"`
	Source                           string                                               `json:"source"`
	S3Bucket                         string                                               `json:"s3bucket"`
	S3RoleArn                        string                                               `json:"s3role_arn"`
	ABSConnectionString              string                                               `json:"abs_connection_string"`
	ABSContainerName                 string                                               `json:"abs_container_name"`
	FolderId                         string                                               `json:"folder_id"`
	FTPHost                          string                                               `json:"ftp_host"`
	FTPPort                          *int                                                 `json:"ftp_port"`
	FTPUser                          string                                               `json:"ftp_user"`
	FTPPassword                      string                                               `json:"ftp_password"`
	IsFTPS                           *bool                                                `json:"is_ftps"`
	SFTPHost                         string                                               `json:"sftp_host"`
	SFTPPort                         *int                                                 `json:"sftp_port"`
	SFTPUser                         string                                               `json:"sftp_user"`
	SFTPPassword                     string                                               `json:"sftp_password"`
	SFTPIsKeyPair                    *bool                                                `json:"sftp_is_key_pair"`
	IsKeypair                        *bool                                                `json:"is_keypair"`
	Advertisables                    []string                                             `json:"advertisables"`
	ReportType                       string                                               `json:"report_type"`
	Dimensions                       []string                                             `json:"dimensions"`
	SchemaPrefix                     string                                               `json:"schema_prefix"`
	APIKey                           string                                               `json:"api_key"`
	ExternalID                       string                                               `json:"external_id"`
	RoleArn                          string                                               `json:"role_arn"`
	Bucket                           string                                               `json:"bucket"`
	Prefix                           string                                               `json:"prefix"`
	Pattern                          string                                               `json:"pattern"`
	PAT                              string                                               `json:"pat"`
	FileType                         string                                               `json:"file_type"`
	Compression                      string                                               `json:"compression"`
	OnError                          string                                               `json:"on_error"`
	AppendFileOption                 string                                               `json:"append_file_option"`
	ArchivePattern                   string                                               `json:"archive_pattern"`
	NullSequence                     string                                               `json:"null_sequence"`
	Delimiter                        string                                               `json:"delimiter"`
	EscapeChar                       string                                               `json:"escape_char"`
	SkipBefore                       *int                                                 `json:"skip_before"`
	SkipAfter                        *int                                                 `json:"skip_after"`
	SecretsList                      []FunctionSecretResponse                             `json:"secrets_list"`
	ProjectCredentials               []ConnectorConfigProjectCredentialsResponse          `json:"project_credentials"`
	AuthMode                         string                                               `json:"auth_mode"`
	Username                         string                                               `json:"username"`
	Password                         string                                               `json:"password"`
	Certificate                      string                                               `json:"certificate"`
	SelectedExports                  []string                                             `json:"selected_exports"`
	ConsumerGroup                    string                                               `json:"consumer_group"`
	Servers                          string                                               `json:"servers"`
	MessageType                      string                                               `json:"message_type"`
	SyncType                         string                                               `json:"sync_type"`
	SecurityProtocol                 string                                               `json:"security_protocol"`
	Apps                             []string                                             `json:"apps"`
	SalesAccounts                    []string                                             `json:"sales_accounts"`
	FinanceAccounts                  []string                                             `json:"finance_accounts"`
	AppSyncMode                      string                                               `json:"app_sync_mode"`
	SalesAccountSyncMode             string                                               `json:"sales_account_sync_mode"`
	FinanceAccountSyncMode           string                                               `json:"finance_account_sync_mode"`
	PEMCertificate                   string                                               `json:"pem_certificate"`
	AccessKeyID                      string                                               `json:"access_key_id"`
	SecretKey                        string                                               `json:"secret_key"`
	HomeFolder                       string                                               `json:"home_folder"`
	SyncDataLocker                   *bool                                                `json:"sync_data_locker"`
	Projects                         []string                                             `json:"projects"`
	Function                         string                                               `json:"function"`
	Region                           string                                               `json:"region"`
	Secrets                          string                                               `json:"secrets"`
	ContainerName                    string                                               `json:"container_name"`
	ConnectionString                 string                                               `json:"connection_string"`
	FunctionApp                      string                                               `json:"function_app"`
	FunctionName                     string                                               `json:"function_name"`
	FunctionKey                      string                                               `json:"function_key"`
	PublicKey                        string                                               `json:"public_key"`
	MerchantID                       string                                               `json:"merchant_id"`
	APIURL                           string                                               `json:"api_url"`
	CloudStorageType                 string                                               `json:"cloud_storage_type"`
	S3ExternalID                     string                                               `json:"s3external_id"`
	S3Folder                         string                                               `json:"s3folder"`
	GCSBucket                        string                                               `json:"gcs_bucket"`
	GCSFolder                        string                                               `json:"gcs_folder"`
	UserProfiles                     []string                                             `json:"user_profiles"`
	ReportConfigurationIDs           []string                                             `json:"report_configuration_ids"`
	EnableAllDimensionCombinations   *bool                                                `json:"enable_all_dimension_combinations"`
	Instance                         string                                               `json:"instance"`
	AWSRegionCode                    string                                               `json:"aws_region_code"`
	Accounts                         []string                                             `json:"accounts"`
	Fields                           []string                                             `json:"fields"`
	Breakdowns                       []string                                             `json:"breakdowns"`
	ActionBreakdowns                 []string                                             `json:"action_breakdowns"`
	Aggregation                      string                                               `json:"aggregation"`
	ConfigType                       string                                               `json:"config_type"`
	PrebuiltReport                   string                                               `json:"prebuilt_report"`
	ActionReportTime                 string                                               `json:"action_report_time"`
	ClickAttributionWindow           string                                               `json:"click_attribution_window"`
	ViewAttributionWindow            string                                               `json:"view_attribution_window"`
	CustomTables                     []ConnectorConfigCustomTablesResponse                `json:"custom_tables"`
	Pages                            []string                                             `json:"pages"`
	Subdomain                        string                                               `json:"subdomain"`
	Host                             string                                               `json:"host"`
	Port                             *int                                                 `json:"port"`
	User                             string                                               `json:"user"`
	IsSecure                         *bool                                                `json:"is_secure"`
	Repositories                     []string                                             `json:"repositories"`
	UseWebhooks                      *bool                                                `json:"use_webhooks"`
	DimensionAttributes              []string                                             `json:"dimension_attributes"`
	Columns                          []string                                             `json:"columns"`
	NetworkCode                      string                                               `json:"network_code"`
	CustomerID                       string                                               `json:"customer_id"`
	ManagerAccounts                  []string                                             `json:"manager_accounts"`
	Reports                          []ConnectorConfigReportsResponse                     `json:"reports"`
	ConversionWindowSize             *int                                                 `json:"conversion_window_size"`
	Profiles                         []string                                             `json:"profiles"`
	ProjectID                        string                                               `json:"project_id"`
	DatasetID                        string                                               `json:"dataset_id"`
	BucketName                       string                                               `json:"bucket_name"`
	FunctionTrigger                  string                                               `json:"function_trigger"`
	ConfigMethod                     string                                               `json:"config_method"`
	QueryID                          string                                               `json:"query_id"`
	UpdateConfigOnEachSync           *bool                                                `json:"update_config_on_each_sync"`
	SiteURLs                         []string                                             `json:"site_urls"`
	Path                             string                                               `json:"path"`
	OnPremise                        *bool                                                `json:"on_premise"`
	AccessToken                      string                                               `json:"access_token"`
	ViewThroughAttributionWindowSize string                                               `json:"view_through_attribution_window_size"`
	PostClickAttributionWindowSize   string                                               `json:"post_click_attribution_window_size"`
	UseAPIKeys                       *bool                                                `json:"use_api_keys"`
	APIKeys                          []string                                             `json:"api_keys"`
	Endpoint                         string                                               `json:"endpoint"`
	Identity                         string                                               `json:"identity"`
	APIQuota                         *int                                                 `json:"api_quota"`
	DomainName                       string                                               `json:"domain_name"`
	ResourceURL                      string                                               `json:"resource_url"`
	APISecret                        string                                               `json:"api_secret"`
	Hosts                            []string                                             `json:"hosts"`
	TunnelHost                       string                                               `json:"tunnel_host"`
	TunnelPort                       *int                                                 `json:"tunnel_port"`
	TunnelUser                       string                                               `json:"tunnel_user"`
	Database                         string                                               `json:"database"`
	Datasource                       string                                               `json:"datasource"`
	Account                          string                                               `json:"account"`
	Role                             string                                               `json:"role"`
	Email                            string                                               `json:"email"`
	AccountID                        string                                               `json:"account_id"`
	ServerURL                        string                                               `json:"server_url"`
	UserKey                          string                                               `json:"user_key"`
	APIVersion                       string                                               `json:"api_version"`
	DailyAPICallLimit                *int                                                 `json:"daily_api_call_limit"`
	TimeZone                         string                                               `json:"time_zone"`
	IntegrationKey                   string                                               `json:"integration_key"`
	Advertisers                      []string                                             `json:"advertisers"`
	EngagementAttributionWindow      string                                               `json:"engagement_attribution_window"`
	ConversionReportTime             string                                               `json:"conversion_report_time"`
	Domain                           string                                               `json:"domain"`
	UpdateMethod                     string                                               `json:"update_method"`
	ReplicationSlot                  string                                               `json:"replication_slot"`
	PublicationName                  string                                               `json:"publication_name"`
	DataCenter                       string                                               `json:"data_center"`
	APIToken                         string                                               `json:"api_token"`
	SubDomain                        string                                               `json:"sub_domain"`
	TestTableName                    string                                               `json:"test_table_name"`
	Shop                             string                                               `json:"shop"`
	Organizations                    []string                                             `json:"organizations"`
	SwipeAttributionWindow           string                                               `json:"swipe_attribution_window"`
	APIAccessToken                   string                                               `json:"api_access_token"`
	AccountIDs                       []string                                             `json:"account_ids"`
	SID                              string                                               `json:"sid"`
	Secret                           string                                               `json:"secret"`
	OauthToken                       string                                               `json:"oauth_token"`
	OauthTokenSecret                 string                                               `json:"oauth_token_secret"`
	ConsumerKey                      string                                               `json:"consumer_key"`
	ConsumerSecret                   string                                               `json:"consumer_secret"`
	Key                              string                                               `json:"key"`
	AdvertisersID                    []string                                             `json:"advertisers_id"`
	SyncFormat                       string                                               `json:"sync_format"`
	BucketService                    string                                               `json:"bucket_service"`
	UserName                         string                                               `json:"user_name"`
	ReportURL                        string                                               `json:"report_url"`
	UniqueID                         string                                               `json:"unique_id"`
	AuthType                         string                                               `json:"auth_type"`
	LatestVersion                    string                                               `json:"latest_version"`
	AuthorizationMethod              string                                               `json:"authorization_method"`
	ServiceVersion                   string                                               `json:"service_version"`
	LastSyncedChangesUtc             string                                               `json:"last_synced_changes__utc_"`
	IsNewPackage                     *bool                                                `json:"is_new_package"`
	ConnectionType                   string                                               `json:"connection_type"`
	IsMultiEntityFeatureEnabled      *bool                                                `json:"is_multi_entity_feature_enabled"`
	AlwaysEncrypted                  *bool                                                `json:"always_encrypted"`
	ApiType                          string                                               `json:"api_type"`
	BaseUrl                          string                                               `json:"base_url"`
	EntityId                         string                                               `json:"entity_id"`
	SoapUri                          string                                               `json:"soap_uri"`
	UserId                           string                                               `json:"user_id"`
	EncryptionKey                    string                                               `json:"encryption_key"`
	EuRegion                         *bool                                                `json:"eu_region"`
	TokenKey                         string                                               `json:"token_key"`
	TokenSecret                      string                                               `json:"token_secret"`
	ShareURL                         string                                               `json:"share_url"`
}

type ConnectorCreateResponse 

type ConnectorCreateResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		ConnectorCreateResponseDataBase
		Config ConnectorConfigResponse `json:"config"`
	} `json:"data"`
}

type ConnectorCreateResponseDataBase added in v0.7.0 

type ConnectorCreateResponseDataBase struct {
	ID              string    `json:"id"`
	GroupID         string    `json:"group_id"`
	Service         string    `json:"service"`
	ServiceVersion  *int      `json:"service_version"`
	Schema          string    `json:"schema"`
	ConnectedBy     string    `json:"connected_by"`
	CreatedAt       time.Time `json:"created_at"`
	SucceededAt     time.Time `json:"succeeded_at"`
	FailedAt        time.Time `json:"failed_at"`
	SyncFrequency   *int      `json:"sync_frequency"`
	ScheduleType    string    `json:"schedule_type"`
	Paused          *bool     `json:"paused"`
	PauseAfterTrial *bool     `json:"pause_after_trial"`
	DailySyncTime   string    `json:"daily_sync_time"`
	Status          struct {
		SetupState       string `json:"setup_state"`
		SyncState        string `json:"sync_state"`
		UpdateState      string `json:"update_state"`
		IsHistoricalSync *bool  `json:"is_historical_sync"`
		Tasks            []struct {
			Code    string `json:"code"`
			Message string `json:"message"`
		} `json:"tasks"`
		Warnings []struct {
			Code    string `json:"code"`
			Message string `json:"message"`
		} `json:"warnings"`
	} `json:"status"`
	SetupTests []struct {
		Title   string `json:"title"`
		Status  string `json:"status"`
		Message string `json:"message"`
	} `json:"setup_tests"`
}

type ConnectorCreateService 

type ConnectorCreateService struct {
	// contains filtered or unexported fields
}

func (*ConnectorCreateService) Auth 

func (s *ConnectorCreateService) Auth(value *ConnectorAuth) *ConnectorCreateService

func (*ConnectorCreateService) AuthCustom added in v0.7.0 

func (s *ConnectorCreateService) AuthCustom(value *map[string]interface{}) *ConnectorCreateService

func (*ConnectorCreateService) Config 

func (s *ConnectorCreateService) Config(value *ConnectorConfig) *ConnectorCreateService

func (*ConnectorCreateService) ConfigCustom added in v0.7.0 

func (s *ConnectorCreateService) ConfigCustom(value *map[string]interface{}) *ConnectorCreateService

func (*ConnectorCreateService) DailySyncTime added in v0.2.0 

func (s *ConnectorCreateService) DailySyncTime(value string) *ConnectorCreateService

func (*ConnectorCreateService) Do 

func (s *ConnectorCreateService) Do(ctx context.Context) (ConnectorCreateResponse, error)

func (*ConnectorCreateService) DoCustom added in v0.7.0 

func (s *ConnectorCreateService) DoCustom(ctx context.Context) (ConnectorCustomCreateResponse, error)

func (*ConnectorCreateService) DoCustomMerged added in v0.7.0 

func (s *ConnectorCreateService) DoCustomMerged(ctx context.Context) (ConnectorCustomMergedCreateResponse, error)

func (*ConnectorCreateService) GroupID 

func (s *ConnectorCreateService) GroupID(value string) *ConnectorCreateService

func (*ConnectorCreateService) PauseAfterTrial added in v0.2.0 

func (s *ConnectorCreateService) PauseAfterTrial(value bool) *ConnectorCreateService

func (*ConnectorCreateService) Paused 

func (s *ConnectorCreateService) Paused(value bool) *ConnectorCreateService

func (*ConnectorCreateService) RunSetupTests 

func (s *ConnectorCreateService) RunSetupTests(value bool) *ConnectorCreateService

func (*ConnectorCreateService) Service 

func (s *ConnectorCreateService) Service(value string) *ConnectorCreateService

func (*ConnectorCreateService) SyncFrequency added in v0.2.0 

func (s *ConnectorCreateService) SyncFrequency(value int) *ConnectorCreateService

func (*ConnectorCreateService) TrustCertificates 

func (s *ConnectorCreateService) TrustCertificates(value bool) *ConnectorCreateService

func (*ConnectorCreateService) TrustFingerprints 

func (s *ConnectorCreateService) TrustFingerprints(value bool) *ConnectorCreateService

type ConnectorCustomCreateResponse added in v0.7.0 

type ConnectorCustomCreateResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		ConnectorCreateResponseDataBase
		Config map[string]interface{} `json:"config"`
	} `json:"data"`
}

type ConnectorCustomDetailsResponse added in v0.7.0 

type ConnectorCustomDetailsResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		ConnectorDetailsdataBase
		Config map[string]interface{} `json:"config"`
	} `json:"data"`
}

type ConnectorCustomMergedCreateResponse added in v0.7.0 

type ConnectorCustomMergedCreateResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		ConnectorCreateResponseDataBase
		CustomConfig map[string]interface{}  `json:"config"`
		Config       ConnectorConfigResponse // no mapping here
	} `json:"data"`
}

type ConnectorCustomMergedDetailsResponse added in v0.7.0 

type ConnectorCustomMergedDetailsResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		ConnectorDetailsdataBase
		CustomConfig map[string]interface{}  `json:"config"`
		Config       ConnectorConfigResponse // no mapping here
	} `json:"data"`
}

type ConnectorCustomMergedModifyResponse added in v0.7.0 

type ConnectorCustomMergedModifyResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		ConnectorModifyResponseDataBase
		CustomConfig map[string]interface{}  `json:"config"`
		Config       ConnectorConfigResponse // no mapping here
	} `json:"data"`
}

type ConnectorCustomModifyResponse added in v0.7.0 

type ConnectorCustomModifyResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		ConnectorModifyResponseDataBase
		Config map[string]interface{} `json:"config"`
	} `json:"data"`
}

type ConnectorDeleteResponse 

type ConnectorDeleteResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
}

type ConnectorDeleteService 

type ConnectorDeleteService struct {
	// contains filtered or unexported fields
}

ConnectorDeleteService implements the Connector Management, Delete a Connector API. Ref. https://fivetran.com/docs/rest-api/connectors#deleteaconnector

func (*ConnectorDeleteService) ConnectorID 

func (s *ConnectorDeleteService) ConnectorID(connectorID string) *ConnectorDeleteService

func (*ConnectorDeleteService) Do 

func (s *ConnectorDeleteService) Do(ctx context.Context) (ConnectorDeleteResponse, error)

type ConnectorDetailsResponse 

type ConnectorDetailsResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		ConnectorDetailsdataBase
		Config ConnectorConfigResponse `json:"config"`
	} `json:"data"`
}

type ConnectorDetailsService 

type ConnectorDetailsService struct {
	// contains filtered or unexported fields
}

ConnectorDetailsService implements the Connector Management, Retrieve Connector Details API. Ref. https://fivetran.com/docs/rest-api/connectors#retrieveconnectordetails

func (*ConnectorDetailsService) ConnectorID 

func (s *ConnectorDetailsService) ConnectorID(value string) *ConnectorDetailsService

func (*ConnectorDetailsService) Do 

func (s *ConnectorDetailsService) Do(ctx context.Context) (ConnectorDetailsResponse, error)

func (*ConnectorDetailsService) DoCustom added in v0.7.0 

func (s *ConnectorDetailsService) DoCustom(ctx context.Context) (ConnectorCustomDetailsResponse, error)

func (*ConnectorDetailsService) DoCustomMerged added in v0.7.0 

func (s *ConnectorDetailsService) DoCustomMerged(ctx context.Context) (ConnectorCustomMergedDetailsResponse, error)

type ConnectorDetailsdataBase added in v0.7.0 

type ConnectorDetailsdataBase struct {
	ID              string    `json:"id"`
	GroupID         string    `json:"group_id"`
	Service         string    `json:"service"`
	ServiceVersion  *int      `json:"service_version"`
	Schema          string    `json:"schema"`
	ConnectedBy     string    `json:"connected_by"`
	CreatedAt       time.Time `json:"created_at"`
	SucceededAt     time.Time `json:"succeeded_at"`
	FailedAt        time.Time `json:"failed_at"`
	Paused          *bool     `json:"paused"`
	PauseAfterTrial *bool     `json:"pause_after_trial"`
	DailySyncTime   string    `json:"daily_sync_time"`
	SyncFrequency   *int      `json:"sync_frequency"`
	ScheduleType    string    `json:"schedule_type"`
	Status          struct {
		SetupState       string `json:"setup_state"`
		SyncState        string `json:"sync_state"`
		UpdateState      string `json:"update_state"`
		IsHistoricalSync *bool  `json:"is_historical_sync"`
		Tasks            []struct {
			Code    string `json:"code"`
			Message string `json:"message"`
		} `json:"tasks"`
		Warnings []struct {
			Code    string `json:"code"`
			Message string `json:"message"`
		} `json:"warnings"`
	} `json:"status"`
}

type ConnectorModifyResponse 

type ConnectorModifyResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		ConnectorModifyResponseDataBase
		Config ConnectorConfigResponse `json:"config"`
	} `json:"data"`
}

type ConnectorModifyResponseDataBase added in v0.7.0 

type ConnectorModifyResponseDataBase struct {
	ID              string    `json:"id"`
	GroupID         string    `json:"group_id"`
	Service         string    `json:"service"`
	ServiceVersion  *int      `json:"service_version"`
	Schema          string    `json:"schema"`
	ConnectedBy     string    `json:"connected_by"`
	CreatedAt       time.Time `json:"created_at"`
	SucceededAt     time.Time `json:"succeeded_at"`
	FailedAt        time.Time `json:"failed_at"`
	SyncFrequency   *int      `json:"sync_frequency"`
	Paused          *bool     `json:"paused"`
	PauseAfterTrial *bool     `json:"pause_after_trial"`
	ScheduleType    string    `json:"schedule_type"`
	Status          struct {
		SetupState       string `json:"setup_state"`
		SyncState        string `json:"sync_state"`
		UpdateState      string `json:"update_state"`
		IsHistoricalSync *bool  `json:"is_historical_sync"`
		Tasks            []struct {
			Code    string `json:"code"`
			Message string `json:"message"`
		} `json:"tasks"`
		Warnings []struct {
			Code    string `json:"code"`
			Message string `json:"message"`
		} `json:"warnings"`
	} `json:"status"`
	SetupTests []struct {
		Title   string `json:"title"`
		Status  string `json:"status"`
		Message string `json:"message"`
	} `json:"setup_tests"`
}

type ConnectorModifyService 

type ConnectorModifyService struct {
	// contains filtered or unexported fields
}

ConnectorModifyService implements the Connector Management, Modify a Connector API. Ref. https://fivetran.com/docs/rest-api/connectors#modifyaconnector

func (*ConnectorModifyService) Auth 

func (s *ConnectorModifyService) Auth(value *ConnectorAuth) *ConnectorModifyService

func (*ConnectorModifyService) AuthCustom added in v0.7.0 

func (s *ConnectorModifyService) AuthCustom(value *map[string]interface{}) *ConnectorModifyService

func (*ConnectorModifyService) Config 

func (s *ConnectorModifyService) Config(value *ConnectorConfig) *ConnectorModifyService

func (*ConnectorModifyService) ConfigCustom added in v0.7.0 

func (s *ConnectorModifyService) ConfigCustom(value *map[string]interface{}) *ConnectorModifyService

func (*ConnectorModifyService) ConnectorID 

func (s *ConnectorModifyService) ConnectorID(value string) *ConnectorModifyService

func (*ConnectorModifyService) DailySyncTime 

func (s *ConnectorModifyService) DailySyncTime(value string) *ConnectorModifyService

func (*ConnectorModifyService) Do 

func (s *ConnectorModifyService) Do(ctx context.Context) (ConnectorModifyResponse, error)

func (*ConnectorModifyService) DoCustom added in v0.7.0 

func (s *ConnectorModifyService) DoCustom(ctx context.Context) (ConnectorCustomModifyResponse, error)

func (*ConnectorModifyService) DoCustomMerged added in v0.7.0 

func (s *ConnectorModifyService) DoCustomMerged(ctx context.Context) (ConnectorCustomMergedModifyResponse, error)

func (*ConnectorModifyService) IsHistoricalSync 

func (s *ConnectorModifyService) IsHistoricalSync(value bool) *ConnectorModifyService

func (*ConnectorModifyService) PauseAfterTrial added in v0.2.0 

func (s *ConnectorModifyService) PauseAfterTrial(value bool) *ConnectorModifyService

func (*ConnectorModifyService) Paused 

func (s *ConnectorModifyService) Paused(value bool) *ConnectorModifyService

func (*ConnectorModifyService) RunSetupTests 

func (s *ConnectorModifyService) RunSetupTests(value bool) *ConnectorModifyService

func (*ConnectorModifyService) ScheduleType 

func (s *ConnectorModifyService) ScheduleType(value string) *ConnectorModifyService

func (*ConnectorModifyService) SyncFrequency 

func (s *ConnectorModifyService) SyncFrequency(value int) *ConnectorModifyService

func (*ConnectorModifyService) TrustCertificates 

func (s *ConnectorModifyService) TrustCertificates(value bool) *ConnectorModifyService

func (*ConnectorModifyService) TrustFingerprints 

func (s *ConnectorModifyService) TrustFingerprints(value bool) *ConnectorModifyService

type ConnectorReSyncTableResponse 

type ConnectorReSyncTableResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
}

type ConnectorReSyncTableService 

type ConnectorReSyncTableService struct {
	// contains filtered or unexported fields
}

ConnectorReSyncTableService implements the Connector Management, Re-sync Connector Table Data API. Ref. https://fivetran.com/docs/rest-api/connectors#resyncconnectortabledata

func (*ConnectorReSyncTableService) ConnectorID 

func (s *ConnectorReSyncTableService) ConnectorID(value string) *ConnectorReSyncTableService

func (*ConnectorReSyncTableService) Do 

func (s *ConnectorReSyncTableService) Do(ctx context.Context) (ConnectorReSyncTableResponse, error)

func (*ConnectorReSyncTableService) Schema 

func (s *ConnectorReSyncTableService) Schema(value string) *ConnectorReSyncTableService

func (*ConnectorReSyncTableService) Table 

func (s *ConnectorReSyncTableService) Table(value string) *ConnectorReSyncTableService

type ConnectorSchemaConfigColumn added in v0.6.0 

type ConnectorSchemaConfigColumn struct {
	// contains filtered or unexported fields
}

func NewConnectorSchemaConfigColumn added in v0.6.0 

func NewConnectorSchemaConfigColumn() *ConnectorSchemaConfigColumn

func (*ConnectorSchemaConfigColumn) Enabled added in v0.6.0 

func (csc *ConnectorSchemaConfigColumn) Enabled(value bool) *ConnectorSchemaConfigColumn

func (*ConnectorSchemaConfigColumn) Hashed added in v0.6.0 

func (csc *ConnectorSchemaConfigColumn) Hashed(value bool) *ConnectorSchemaConfigColumn

type ConnectorSchemaConfigColumnResponse added in v0.6.0 

type ConnectorSchemaConfigColumnResponse struct {
	NameInDestination    *string `json:"name_in_destination"`
	Enabled              *bool   `json:"enabled"`
	Hashed               *bool   `json:"hashed"`
	EnabledPatchSettings struct {
		Allowed    *bool   `json:"allowed"`
		ReasonCode *string `json:"reason_code"`
		Reason     *string `json:"reason"`
	} `json:"enabled_patch_settings"`
}

type ConnectorSchemaConfigSchema added in v0.6.0 

type ConnectorSchemaConfigSchema struct {
	// contains filtered or unexported fields
}

func NewConnectorSchemaConfigSchema added in v0.6.0 

func NewConnectorSchemaConfigSchema() *ConnectorSchemaConfigSchema

func (*ConnectorSchemaConfigSchema) Enabled added in v0.6.0 

func (css *ConnectorSchemaConfigSchema) Enabled(value bool) *ConnectorSchemaConfigSchema

func (*ConnectorSchemaConfigSchema) Table added in v0.6.0 

func (css *ConnectorSchemaConfigSchema) Table(name string, table *ConnectorSchemaConfigTable) *ConnectorSchemaConfigSchema

type ConnectorSchemaConfigSchemaResponse added in v0.6.0 

type ConnectorSchemaConfigSchemaResponse struct {
	NameInDestination *string                                        `json:"name_in_destination"`
	Enabled           *bool                                          `json:"enabled"`
	Tables            map[string]*ConnectorSchemaConfigTableResponse `json:"tables"`
}

type ConnectorSchemaConfigTable added in v0.6.0 

type ConnectorSchemaConfigTable struct {
	// contains filtered or unexported fields
}

func NewConnectorSchemaConfigTable added in v0.6.0 

func NewConnectorSchemaConfigTable() *ConnectorSchemaConfigTable

func (*ConnectorSchemaConfigTable) Column added in v0.6.0 

func (cst *ConnectorSchemaConfigTable) Column(name string, value *ConnectorSchemaConfigColumn) *ConnectorSchemaConfigTable

func (*ConnectorSchemaConfigTable) Enabled added in v0.6.0 

func (cst *ConnectorSchemaConfigTable) Enabled(value bool) *ConnectorSchemaConfigTable

func (*ConnectorSchemaConfigTable) SyncMode added in v0.6.7 

func (cst *ConnectorSchemaConfigTable) SyncMode(value string) *ConnectorSchemaConfigTable

type ConnectorSchemaConfigTableResponse added in v0.6.1 

type ConnectorSchemaConfigTableResponse struct {
	NameInDestination    *string                                         `json:"name_in_destination"`
	Enabled              *bool                                           `json:"enabled"`
	SyncMode             *string                                         `json:"sync_mode"`
	Columns              map[string]*ConnectorSchemaConfigColumnResponse `json:"columns"`
	EnabledPatchSettings struct {
		Allowed    *bool   `json:"allowed"`
		ReasonCode *string `json:"reason_code"`
		Reason     *string `json:"reason"`
	} `json:"enabled_patch_settings"`
}

type ConnectorSchemaConfigUpdateService added in v0.6.0 

type ConnectorSchemaConfigUpdateService struct {
	// contains filtered or unexported fields
}

ConnectorSchemaConfigUpdateService implements the Connector Management, Modify a Connector Schema Config API. Ref. https://fivetran.com/docs/rest-api/connectors#modifyaconnectorschemaconfig

func (*ConnectorSchemaConfigUpdateService) ConnectorID added in v0.6.0 

func (csu *ConnectorSchemaConfigUpdateService) ConnectorID(value string) *ConnectorSchemaConfigUpdateService

func (*ConnectorSchemaConfigUpdateService) Do added in v0.6.0 

func (csu *ConnectorSchemaConfigUpdateService) Do(ctx context.Context) (ConnectorSchemaDetailsResponse, error)

func (*ConnectorSchemaConfigUpdateService) Schema added in v0.6.0 

func (csu *ConnectorSchemaConfigUpdateService) Schema(name string, schema *ConnectorSchemaConfigSchema) *ConnectorSchemaConfigUpdateService

func (*ConnectorSchemaConfigUpdateService) SchemaChangeHandling added in v0.6.0 

func (csu *ConnectorSchemaConfigUpdateService) SchemaChangeHandling(value string) *ConnectorSchemaConfigUpdateService

type ConnectorSchemaDetailsResponse added in v0.6.0 

type ConnectorSchemaDetailsResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		SchemaChangeHandling string                                          `json:"schema_change_handling"`
		Schemas              map[string]*ConnectorSchemaConfigSchemaResponse `json:"schemas"`
	} `json:"data"`
}

type ConnectorSchemaDetailsService added in v0.6.0 

type ConnectorSchemaDetailsService struct {
	// contains filtered or unexported fields
}

ConnectorSchemaDetailsService implements the Connector Management, Retrieve a Connector Schema Config API. Ref. https://fivetran.com/docs/rest-api/connectors#retrieveaconnectorschemaconfig

func (*ConnectorSchemaDetailsService) ConnectorID added in v0.6.0 

func (s *ConnectorSchemaDetailsService) ConnectorID(value string) *ConnectorSchemaDetailsService

func (*ConnectorSchemaDetailsService) Do added in v0.6.0 

func (s *ConnectorSchemaDetailsService) Do(ctx context.Context) (ConnectorSchemaDetailsResponse, error)

type ConnectorSchemaReloadService added in v0.6.0 

type ConnectorSchemaReloadService struct {
	// contains filtered or unexported fields
}

ConnectorSchemaReloadService implements the Connector Management, Reload a Connector Schema Config API. Ref. https://fivetran.com/docs/rest-api/connectors#reloadaconnectorschemaconfig

func (*ConnectorSchemaReloadService) ConnectorID added in v0.6.0 

func (s *ConnectorSchemaReloadService) ConnectorID(value string) *ConnectorSchemaReloadService

func (*ConnectorSchemaReloadService) Do added in v0.6.0 

func (s *ConnectorSchemaReloadService) Do(ctx context.Context) (ConnectorSchemaDetailsResponse, error)

func (*ConnectorSchemaReloadService) ExcludeMode added in v0.6.0 

func (s *ConnectorSchemaReloadService) ExcludeMode(value string) *ConnectorSchemaReloadService

type ConnectorSetupTestsResponse 

type ConnectorSetupTestsResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		ID             string    `json:"id"`
		GroupID        string    `json:"group_id"`
		Service        string    `json:"service"`
		ServiceVersion *int      `json:"service_version"`
		Schema         string    `json:"schema"`
		ConnectedBy    string    `json:"connected_by"`
		CreatedAt      time.Time `json:"created_at"`
		SucceededAt    time.Time `json:"succeeded_at"`
		FailedAt       time.Time `json:"failed_at"`
		SyncFrequency  *int      `json:"sync_frequency"`
		ScheduleType   string    `json:"schedule_type"`
		Status         struct {
			SetupState       string `json:"setup_state"`
			SyncState        string `json:"sync_state"`
			UpdateState      string `json:"update_state"`
			IsHistoricalSync *bool  `json:"is_historical_sync"`
			Tasks            []struct {
				Code    string `json:"code"`
				Message string `json:"message"`
			} `json:"tasks"`
			Warnings []struct {
				Code    string `json:"code"`
				Message string `json:"message"`
			} `json:"warnings"`
		} `json:"status"`
		SetupTests []struct {
			Title   string `json:"title"`
			Status  string `json:"status"`
			Message string `json:"message"`
		} `json:"setup_tests"`
		Config ConnectorConfigResponse `json:"config"`
	} `json:"data"`
}

type ConnectorSetupTestsService 

type ConnectorSetupTestsService struct {
	// contains filtered or unexported fields
}

ConnectorSetupTestsService implements the Connector Management, Run connector setup tests API. Ref. https://fivetran.com/docs/rest-api/connectors#runconnectorsetuptests

func (*ConnectorSetupTestsService) ConnectorID 

func (s *ConnectorSetupTestsService) ConnectorID(value string) *ConnectorSetupTestsService

func (*ConnectorSetupTestsService) Do 

func (s *ConnectorSetupTestsService) Do(ctx context.Context) (ConnectorSetupTestsResponse, error)

func (*ConnectorSetupTestsService) TrustCertificates 

func (s *ConnectorSetupTestsService) TrustCertificates(value bool) *ConnectorSetupTestsService

func (*ConnectorSetupTestsService) TrustFingerprints 

func (s *ConnectorSetupTestsService) TrustFingerprints(value bool) *ConnectorSetupTestsService

type ConnectorSyncResponse 

type ConnectorSyncResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
}

type ConnectorSyncService 

type ConnectorSyncService struct {
	// contains filtered or unexported fields
}

ConnectorSyncService implements the Connector Management, Sync Connector Data API. Ref. https://fivetran.com/docs/rest-api/connectors#syncconnectordata

func (*ConnectorSyncService) ConnectorID 

func (s *ConnectorSyncService) ConnectorID(connectorID string) *ConnectorSyncService

func (*ConnectorSyncService) Do 

func (s *ConnectorSyncService) Do(ctx context.Context) (ConnectorSyncResponse, error)

type ConnectorsSourceMetadataResponse 

type ConnectorsSourceMetadataResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		Items []struct {
			ID          string `json:"id"`
			Name        string `json:"name"`
			Type        string `json:"type"`
			Description string `json:"description"`
			IconURL     string `json:"icon_url"`
			LinkToDocs  string `json:"link_to_docs"`
			LinkToErd   string `json:"link_to_erd"`
		} `json:"items"`
		NextCursor string `json:"next_cursor"`
	} `json:"data"`
}

type ConnectorsSourceMetadataService 

type ConnectorsSourceMetadataService struct {
	// contains filtered or unexported fields
}

ConnectorsSourceMetadataService implements the Connector Management, Retrieve source metadata API. Ref. https://fivetran.com/docs/rest-api/connectors#retrievesourcemetadata

func (*ConnectorsSourceMetadataService) Cursor 

func (s *ConnectorsSourceMetadataService) Cursor(value string) *ConnectorsSourceMetadataService

func (*ConnectorsSourceMetadataService) Do 

func (s *ConnectorsSourceMetadataService) Do(ctx context.Context) (ConnectorsSourceMetadataResponse, error)

func (*ConnectorsSourceMetadataService) Limit 

func (s *ConnectorsSourceMetadataService) Limit(value int) *ConnectorsSourceMetadataService

type DestinationConfig 

type DestinationConfig struct {
	// contains filtered or unexported fields
}

DestinationConfig builds Destination Management, Destination Config. Ref. https://fivetran.com/docs/rest-api/destinations/config

func NewDestinationConfig 

func NewDestinationConfig() *DestinationConfig

func (*DestinationConfig) Auth 

func (dc *DestinationConfig) Auth(value string) *DestinationConfig

func (*DestinationConfig) AuthType 

func (dc *DestinationConfig) AuthType(value string) *DestinationConfig

func (*DestinationConfig) Bucket 

func (dc *DestinationConfig) Bucket(value string) *DestinationConfig

func (*DestinationConfig) Catalog added in v0.6.10 

func (dc *DestinationConfig) Catalog(value string) *DestinationConfig

func (*DestinationConfig) ClusterId added in v0.3.1 

func (dc *DestinationConfig) ClusterId(value string) *DestinationConfig

func (*DestinationConfig) ClusterRegion added in v0.3.1 

func (dc *DestinationConfig) ClusterRegion(value string) *DestinationConfig

func (*DestinationConfig) ConnectionType 

func (dc *DestinationConfig) ConnectionType(value string) *DestinationConfig

func (*DestinationConfig) CreateExternalTables 

func (dc *DestinationConfig) CreateExternalTables(value bool) *DestinationConfig

func (*DestinationConfig) DataSetLocation 

func (dc *DestinationConfig) DataSetLocation(value string) *DestinationConfig

func (*DestinationConfig) Database 

func (dc *DestinationConfig) Database(value string) *DestinationConfig

func (*DestinationConfig) ExternalLocation 

func (dc *DestinationConfig) ExternalLocation(value string) *DestinationConfig

func (*DestinationConfig) FivetranRoleArn added in v0.7.3 

func (dc *DestinationConfig) FivetranRoleArn(value string) *DestinationConfig

func (*DestinationConfig) HTTPPath 

func (dc *DestinationConfig) HTTPPath(value string) *DestinationConfig

func (*DestinationConfig) Host 

func (dc *DestinationConfig) Host(value string) *DestinationConfig

func (*DestinationConfig) IsPrivateKeyEncrypted added in v0.6.8 

func (dc *DestinationConfig) IsPrivateKeyEncrypted(value bool) *DestinationConfig

func (*DestinationConfig) Passphrase added in v0.6.8 

func (dc *DestinationConfig) Passphrase(value string) *DestinationConfig

func (*DestinationConfig) Password 

func (dc *DestinationConfig) Password(value string) *DestinationConfig

func (*DestinationConfig) PersonalAccessToken 

func (dc *DestinationConfig) PersonalAccessToken(value string) *DestinationConfig

func (*DestinationConfig) Port 

func (dc *DestinationConfig) Port(value int) *DestinationConfig

func (*DestinationConfig) PrefixPath added in v0.7.3 

func (dc *DestinationConfig) PrefixPath(value string) *DestinationConfig

func (*DestinationConfig) PrivateKey added in v0.6.5 

func (dc *DestinationConfig) PrivateKey(value string) *DestinationConfig

func (*DestinationConfig) ProjectID 

func (dc *DestinationConfig) ProjectID(value string) *DestinationConfig

func (*DestinationConfig) Region added in v0.7.3 

func (dc *DestinationConfig) Region(value string) *DestinationConfig

func (*DestinationConfig) Role added in v0.6.8 

func (dc *DestinationConfig) Role(value string) *DestinationConfig

func (*DestinationConfig) RoleArn 

func (dc *DestinationConfig) RoleArn(value string) *DestinationConfig

func (*DestinationConfig) SecretKey added in v0.2.2 

func (dc *DestinationConfig) SecretKey(value string) *DestinationConfig

func (*DestinationConfig) ServerHostName 

func (dc *DestinationConfig) ServerHostName(value string) *DestinationConfig

func (*DestinationConfig) TunnelHost 

func (dc *DestinationConfig) TunnelHost(value string) *DestinationConfig

func (*DestinationConfig) TunnelPort 

func (dc *DestinationConfig) TunnelPort(value string) *DestinationConfig

func (*DestinationConfig) TunnelUser 

func (dc *DestinationConfig) TunnelUser(value string) *DestinationConfig

func (*DestinationConfig) User 

func (dc *DestinationConfig) User(value string) *DestinationConfig

type DestinationConfigResponse 

type DestinationConfigResponse struct {
	Host                  string `json:"host"`
	Port                  string `json:"port"` // Port is sent as `string` but returned as `int`. T-97508
	Database              string `json:"database"`
	Auth                  string `json:"auth"`
	User                  string `json:"user"`
	Password              string `json:"password"`
	ConnectionType        string `json:"connection_type"` // ConnectionMethod is the REST API's response of ConnectionType. T-111758
	TunnelHost            string `json:"tunnel_host"`
	TunnelPort            string `json:"tunnel_port"`
	TunnelUser            string `json:"tunnel_user"`
	ProjectID             string `json:"project_id"`
	DataSetLocation       string `json:"data_set_location"`
	Location              string `json:"location"` // Big Query returns `data_set_location` as `location` in response (will be fixed with migration to API V2)
	Bucket                string `json:"bucket"`
	ServerHostName        string `json:"server_host_name"`
	HTTPPath              string `json:"http_path"`
	PersonalAccessToken   string `json:"personal_access_token"`
	CreateExternalTables  string `json:"create_external_tables"`
	ExternalLocation      string `json:"external_location"`
	AuthType              string `json:"auth_type"`
	RoleArn               string `json:"role_arn"`
	SecretKey             string `json:"secret_key"`
	PublicKey             string `json:"public_key"` // Readonly field
	PrivateKey            string `json:"private_key"`
	ClusterId             string `json:"cluster_id"`
	ClusterRegion         string `json:"cluster_region"`
	Role                  string `json:"role"`
	IsPrivateKeyEncrypted string `json:"is_private_key_encrypted"`
	Passphrase            string `json:"passphrase"`
	Catalog               string `json:"catalog"`
	FivetranRoleArn       string `json:"fivetran_role_arn"`
	PrefixPath            string `json:"prefix_path"`
	Region                string `json:"region"`
}

type DestinationCreateResponse 

type DestinationCreateResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		ID             string `json:"id"`
		GroupID        string `json:"group_id"`
		Service        string `json:"service"`
		Region         string `json:"region"`
		TimeZoneOffset string `json:"time_zone_offset"`
		SetupStatus    string `json:"setup_status"`
		SetupTests     []struct {
			Title   string `json:"title"`
			Status  string `json:"status"`
			Message string `json:"message"`
		} `json:"setup_tests"`
		Config DestinationConfigResponse `json:"config"`
	} `json:"data"`
}

type DestinationCreateService 

type DestinationCreateService struct {
	// contains filtered or unexported fields
}

DestinationCreateService implements the Destination Management, Create a Destination API. Ref. https://fivetran.com/docs/rest-api/destinations#createadestination

func (*DestinationCreateService) Config 

func (s *DestinationCreateService) Config(value *DestinationConfig) *DestinationCreateService

func (*DestinationCreateService) Do 

func (s *DestinationCreateService) Do(ctx context.Context) (DestinationCreateResponse, error)

func (*DestinationCreateService) GroupID 

func (s *DestinationCreateService) GroupID(value string) *DestinationCreateService

func (*DestinationCreateService) Region 

func (s *DestinationCreateService) Region(value string) *DestinationCreateService

func (*DestinationCreateService) RunSetupTests 

func (s *DestinationCreateService) RunSetupTests(value bool) *DestinationCreateService

func (*DestinationCreateService) Service 

func (s *DestinationCreateService) Service(value string) *DestinationCreateService

func (*DestinationCreateService) TimeZoneOffset 

func (s *DestinationCreateService) TimeZoneOffset(value string) *DestinationCreateService

func (*DestinationCreateService) TrustCertificates 

func (s *DestinationCreateService) TrustCertificates(value bool) *DestinationCreateService

func (*DestinationCreateService) TrustFingerprints 

func (s *DestinationCreateService) TrustFingerprints(value bool) *DestinationCreateService

type DestinationDeleteResponse 

type DestinationDeleteResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
}

type DestinationDeleteService 

type DestinationDeleteService struct {
	// contains filtered or unexported fields
}

DestinationDeleteService implements the Destination Management, Delete a destination API. Ref. https://fivetran.com/docs/rest-api/destinations#deleteadestination

func (*DestinationDeleteService) DestinationID 

func (s *DestinationDeleteService) DestinationID(value string) *DestinationDeleteService

func (*DestinationDeleteService) Do 

func (s *DestinationDeleteService) Do(ctx context.Context) (DestinationDeleteResponse, error)

type DestinationDetailsResponse 

type DestinationDetailsResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		ID             string                    `json:"id"`
		GroupID        string                    `json:"group_id"`
		Service        string                    `json:"service"`
		Region         string                    `json:"region"`
		TimeZoneOffset string                    `json:"time_zone_offset"`
		SetupStatus    string                    `json:"setup_status"`
		Config         DestinationConfigResponse `json:"config"`
	} `json:"data"`
}

type DestinationDetailsService 

type DestinationDetailsService struct {
	// contains filtered or unexported fields
}

DestinationDetailsService implements the Destination Management, Retrieve destination details API. Ref. https://fivetran.com/docs/rest-api/destinations#retrievedestinationdetails

func (*DestinationDetailsService) DestinationID 

func (s *DestinationDetailsService) DestinationID(value string) *DestinationDetailsService

func (*DestinationDetailsService) Do 

func (s *DestinationDetailsService) Do(ctx context.Context) (DestinationDetailsResponse, error)

type DestinationModifyResponse 

type DestinationModifyResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		ID             string `json:"id"`
		GroupID        string `json:"group_id"`
		Service        string `json:"service"`
		Region         string `json:"region"`
		TimeZoneOffset string `json:"time_zone_offset"`
		SetupStatus    string `json:"setup_status"`
		SetupTests     []struct {
			Title   string `json:"title"`
			Status  string `json:"status"`
			Message string `json:"message"`
		} `json:"setup_tests"`
		Config DestinationConfigResponse `json:"config"`
	} `json:"data"`
}

type DestinationModifyService 

type DestinationModifyService struct {
	// contains filtered or unexported fields
}

DestinationModifyService implements the Destination Management, Modify a Destination API. Ref. https://fivetran.com/docs/rest-api/destinations#modifyadestination

func (*DestinationModifyService) Config 

func (s *DestinationModifyService) Config(value *DestinationConfig) *DestinationModifyService

func (*DestinationModifyService) DestinationID 

func (s *DestinationModifyService) DestinationID(value string) *DestinationModifyService

func (*DestinationModifyService) Do 

func (s *DestinationModifyService) Do(ctx context.Context) (DestinationModifyResponse, error)

func (*DestinationModifyService) Region 

func (s *DestinationModifyService) Region(value string) *DestinationModifyService

func (*DestinationModifyService) RunSetupTests 

func (s *DestinationModifyService) RunSetupTests(value bool) *DestinationModifyService

func (*DestinationModifyService) TimeZoneOffset 

func (s *DestinationModifyService) TimeZoneOffset(value string) *DestinationModifyService

func (*DestinationModifyService) TrustCertificates 

func (s *DestinationModifyService) TrustCertificates(value bool) *DestinationModifyService

func (*DestinationModifyService) TrustFingerprints 

func (s *DestinationModifyService) TrustFingerprints(value bool) *DestinationModifyService

type DestinationSetupTestsResponse 

type DestinationSetupTestsResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		ID             string `json:"id"`
		GroupID        string `json:"group_id"`
		Service        string `json:"service"`
		Region         string `json:"region"`
		TimeZoneOffset string `json:"time_zone_offset"`
		SetupStatus    string `json:"setup_status"`
		SetupTests     []struct {
			Title   string `json:"title"`
			Status  string `json:"status"`
			Message string `json:"message"`
		} `json:"setup_tests"`
		Config DestinationConfigResponse `json:"config"`
	} `json:"data"`
}

type DestinationSetupTestsService 

type DestinationSetupTestsService struct {
	// contains filtered or unexported fields
}

DestinationSetupTestsService implements the Destination Management, Run destination setup tests API. Ref. https://fivetran.com/docs/rest-api/destinations#rundestinationsetuptests

func (*DestinationSetupTestsService) DestinationID 

func (s *DestinationSetupTestsService) DestinationID(value string) *DestinationSetupTestsService

func (*DestinationSetupTestsService) Do 

func (s *DestinationSetupTestsService) Do(ctx context.Context) (DestinationSetupTestsResponse, error)

func (*DestinationSetupTestsService) TrustCertificates 

func (s *DestinationSetupTestsService) TrustCertificates(value bool) *DestinationSetupTestsService

func (*DestinationSetupTestsService) TrustFingerprints 

func (s *DestinationSetupTestsService) TrustFingerprints(value bool) *DestinationSetupTestsService

type FunctionSecret added in v0.7.0 

type FunctionSecret struct {
	// contains filtered or unexported fields
}

func NewFunctionSecret added in v0.7.0 

func NewFunctionSecret() *FunctionSecret

func (*FunctionSecret) Key added in v0.7.0 

func (fs *FunctionSecret) Key(value string) *FunctionSecret

func (*FunctionSecret) Value added in v0.7.0 

func (fs *FunctionSecret) Value(value string) *FunctionSecret

type FunctionSecretResponse added in v0.7.0 

type FunctionSecretResponse struct {
	Key   string `json:"key"`
	Value string `json:"value"`
}

type GroupAddUserResponse 

type GroupAddUserResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
}

type GroupAddUserService 

type GroupAddUserService struct {
	// contains filtered or unexported fields
}

GroupAddUserService implements the Group Management, Add a User to a Group API. Ref. https://fivetran.com/docs/rest-api/groups#addausertoagroup

func (*GroupAddUserService) Do 

func (s *GroupAddUserService) Do(ctx context.Context) (GroupAddUserResponse, error)

func (*GroupAddUserService) Email 

func (s *GroupAddUserService) Email(value string) *GroupAddUserService

func (*GroupAddUserService) GroupID 

func (s *GroupAddUserService) GroupID(value string) *GroupAddUserService

func (*GroupAddUserService) Role 

func (s *GroupAddUserService) Role(value string) *GroupAddUserService

type GroupCreateResponse 

type GroupCreateResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		ID        string    `json:"id"`
		Name      string    `json:"name"`
		CreatedAt time.Time `json:"created_at"`
	} `json:"data"`
}

type GroupCreateService 

type GroupCreateService struct {
	// contains filtered or unexported fields
}

GroupCreateService implements the Group Management, Create a Group API. Ref. https://fivetran.com/docs/rest-api/groups#createagroup

func (*GroupCreateService) Do 

func (s *GroupCreateService) Do(ctx context.Context) (GroupCreateResponse, error)

func (*GroupCreateService) Name 

func (s *GroupCreateService) Name(value string) *GroupCreateService

type GroupDeleteService 

type GroupDeleteService struct {
	// contains filtered or unexported fields
}

GroupDeleteService implements the Group Management, Delete a group API. Ref. https://fivetran.com/docs/rest-api/groups#deleteagroup

func (*GroupDeleteService) Do 

func (s *GroupDeleteService) Do(ctx context.Context) (groupDeleteResponse, error)

func (*GroupDeleteService) GroupID 

func (s *GroupDeleteService) GroupID(value string) *GroupDeleteService

type GroupDetailsResponse 

type GroupDetailsResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		ID        string    `json:"id"`
		Name      string    `json:"name"`
		CreatedAt time.Time `json:"created_at"`
	} `json:"data"`
}

type GroupDetailsService 

type GroupDetailsService struct {
	// contains filtered or unexported fields
}

GroupDetailsService implements the Group Management, Retrieve Group Details API. Ref. https://fivetran.com/docs/rest-api/groups#retrievegroupdetails

func (*GroupDetailsService) Do 

func (s *GroupDetailsService) Do(ctx context.Context) (GroupDetailsResponse, error)

func (*GroupDetailsService) GroupID 

func (s *GroupDetailsService) GroupID(value string) *GroupDetailsService

type GroupListConnectorsResponse 

type GroupListConnectorsResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		Items []struct {
			ID             string    `json:"id"`
			GroupID        string    `json:"group_id"`
			Service        string    `json:"service"`
			ServiceVersion *int      `json:"service_version"`
			Schema         string    `json:"schema"`
			ConnectedBy    string    `json:"connected_by"`
			CreatedAt      time.Time `json:"created_at"`
			SucceededAt    time.Time `json:"succeeded_at"`
			FailedAt       time.Time `json:"failed_at"`
			SyncFrequency  *int      `json:"sync_frequency"`
			ScheduleType   string    `json:"schedule_type"`
			Status         struct {
				SetupState       string `json:"setup_state"`
				SyncState        string `json:"sync_state"`
				UpdateState      string `json:"update_state"`
				IsHistoricalSync *bool  `json:"is_historical_sync"`
				Tasks            []struct {
					Code    string `json:"code"`
					Message string `json:"message"`
				} `json:"tasks"`
				Warnings []struct {
					Code    string `json:"code"`
					Message string `json:"message"`
				} `json:"warnings"`
			} `json:"status"`
			DailySyncTime string `json:"daily_sync_time"`
		} `json:"items"`
		NextCursor string `json:"next_cursor"`
	} `json:"data"`
}

type GroupListConnectorsService 

type GroupListConnectorsService struct {
	// contains filtered or unexported fields
}

GroupListConnectorsService implements the Group Management, List All Connectors within a Group API. Ref. https://fivetran.com/docs/rest-api/groups#listallconnectorswithinagroup

func (*GroupListConnectorsService) Cursor 

func (s *GroupListConnectorsService) Cursor(value string) *GroupListConnectorsService

func (*GroupListConnectorsService) Do 

func (s *GroupListConnectorsService) Do(ctx context.Context) (GroupListConnectorsResponse, error)

func (*GroupListConnectorsService) GroupID 

func (s *GroupListConnectorsService) GroupID(value string) *GroupListConnectorsService

func (*GroupListConnectorsService) Limit 

func (s *GroupListConnectorsService) Limit(value int) *GroupListConnectorsService

func (*GroupListConnectorsService) Schema 

func (s *GroupListConnectorsService) Schema(value string) *GroupListConnectorsService

type GroupListUsersResponse 

type GroupListUsersResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		Items []struct {
			ID         string    `json:"id"`
			Email      string    `json:"email"`
			GivenName  string    `json:"given_name"`
			FamilyName string    `json:"family_name"`
			Verified   *bool     `json:"verified"`
			Invited    *bool     `json:"invited"`
			Picture    string    `json:"picture"`
			Phone      string    `json:"phone"`
			Role       string    `json:"role"`
			LoggedInAt time.Time `json:"logged_in_at"`
			CreatedAt  time.Time `json:"created_at"`
		} `json:"items"`
		NextCursor string `json:"next_cursor"`
	} `json:"data"`
}

type GroupListUsersService 

type GroupListUsersService struct {
	// contains filtered or unexported fields
}

GroupListUsersService implements the Group Management, List All Users within a Group API. Ref. https://fivetran.com/docs/rest-api/groups#listalluserswithinagroup

func (*GroupListUsersService) Cursor 

func (s *GroupListUsersService) Cursor(value string) *GroupListUsersService

func (*GroupListUsersService) Do 

func (s *GroupListUsersService) Do(ctx context.Context) (GroupListUsersResponse, error)

func (*GroupListUsersService) GroupID 

func (s *GroupListUsersService) GroupID(value string) *GroupListUsersService

func (*GroupListUsersService) Limit 

func (s *GroupListUsersService) Limit(value int) *GroupListUsersService

type GroupModifyResponse 

type GroupModifyResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		ID        string    `json:"id"`
		Name      string    `json:"name"`
		CreatedAt time.Time `json:"created_at"`
	} `json:"data"`
}

type GroupModifyService 

type GroupModifyService struct {
	// contains filtered or unexported fields
}

GroupModifyService implements the Group Management, Modify a Group API. Ref. https://fivetran.com/docs/rest-api/groups#modifyagroup

func (*GroupModifyService) Do 

func (s *GroupModifyService) Do(ctx context.Context) (GroupModifyResponse, error)

func (*GroupModifyService) GroupID 

func (s *GroupModifyService) GroupID(value string) *GroupModifyService

func (*GroupModifyService) Name 

func (s *GroupModifyService) Name(value string) *GroupModifyService

type GroupRemoveUserResponse 

type GroupRemoveUserResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
}

type GroupRemoveUserService 

type GroupRemoveUserService struct {
	// contains filtered or unexported fields
}

GroupRemoveUserService implements the Group Management, Remove a User from a Group API. Ref. https://fivetran.com/docs/rest-api/groups#removeauserfromagroup

func (*GroupRemoveUserService) Do 

func (s *GroupRemoveUserService) Do(ctx context.Context) (GroupRemoveUserResponse, error)

func (*GroupRemoveUserService) GroupID 

func (s *GroupRemoveUserService) GroupID(value string) *GroupRemoveUserService

func (*GroupRemoveUserService) UserID 

func (s *GroupRemoveUserService) UserID(value string) *GroupRemoveUserService

type GroupsListResponse 

type GroupsListResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		Items []struct {
			ID        string    `json:"id"`
			Name      string    `json:"name"`
			CreatedAt time.Time `json:"created_at"`
		} `json:"items"`
		NextCursor string `json:"next_cursor"`
	} `json:"data"`
}

type GroupsListService 

type GroupsListService struct {
	// contains filtered or unexported fields
}

GroupsListService implements the Group Management, List All Groups API. Ref. https://fivetran.com/docs/rest-api/groups#listallgroups

func (*GroupsListService) Cursor 

func (s *GroupsListService) Cursor(value string) *GroupsListService

func (*GroupsListService) Do 

func (s *GroupsListService) Do(ctx context.Context) (GroupsListResponse, error)

func (*GroupsListService) Limit 

func (s *GroupsListService) Limit(value int) *GroupsListService

type HttpClient added in v0.6.4 

type HttpClient interface {
	Do(req *http.Request) (*http.Response, error)
}

HttpClient performs an HTTP request. Can be implemented by mocks to perform convenient unit tests

type UserDeleteService 

type UserDeleteService struct {
	// contains filtered or unexported fields
}

UserDeleteService implements the User Management, Delete a user API. Ref. https://fivetran.com/docs/rest-api/users#deleteauser

func (*UserDeleteService) Do 

func (s *UserDeleteService) Do(ctx context.Context) (userDeleteResponse, error)

func (*UserDeleteService) UserID 

func (s *UserDeleteService) UserID(value string) *UserDeleteService

type UserDetailsResponse 

type UserDetailsResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		ID         string    `json:"id"`
		Email      string    `json:"email"`
		GivenName  string    `json:"given_name"`
		FamilyName string    `json:"family_name"`
		Verified   *bool     `json:"verified"`
		Invited    *bool     `json:"invited"`
		Picture    string    `json:"picture"`
		Phone      string    `json:"phone"`
		LoggedInAt time.Time `json:"logged_in_at"`
		CreatedAt  time.Time `json:"created_at"`
		Role       string    `json:"role"`
	} `json:"data"`
}

type UserDetailsService 

type UserDetailsService struct {
	// contains filtered or unexported fields
}

UserDetailsService implements the User Management, Retrieve user details API. Ref. https://fivetran.com/docs/rest-api/users#retrieveuserdetails

func (*UserDetailsService) Do 

func (s *UserDetailsService) Do(ctx context.Context) (UserDetailsResponse, error)

func (*UserDetailsService) UserID 

func (s *UserDetailsService) UserID(value string) *UserDetailsService

type UserInviteResponse 

type UserInviteResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		ID         string    `json:"id"`
		Email      string    `json:"email"`
		GivenName  string    `json:"given_name"`
		FamilyName string    `json:"family_name"`
		Verified   *bool     `json:"verified"`
		Invited    *bool     `json:"invited"`
		Picture    string    `json:"picture"`
		Phone      string    `json:"phone"`
		LoggedInAt time.Time `json:"logged_in_at"`
		CreatedAt  time.Time `json:"created_at"`
		Role       string    `json:"role"`
	} `json:"data"`
}

type UserInviteService 

type UserInviteService struct {
	// contains filtered or unexported fields
}

UserInviteService implements the User Management, Invite a User API. Ref. https://fivetran.com/docs/rest-api/users#inviteauser

func (*UserInviteService) Do 

func (s *UserInviteService) Do(ctx context.Context) (UserInviteResponse, error)

func (*UserInviteService) Email 

func (s *UserInviteService) Email(value string) *UserInviteService

func (*UserInviteService) FamilyName 

func (s *UserInviteService) FamilyName(value string) *UserInviteService

func (*UserInviteService) GivenName 

func (s *UserInviteService) GivenName(value string) *UserInviteService

func (*UserInviteService) Phone 

func (s *UserInviteService) Phone(value string) *UserInviteService

func (*UserInviteService) Picture 

func (s *UserInviteService) Picture(value string) *UserInviteService

func (*UserInviteService) Role 

func (s *UserInviteService) Role(value string) *UserInviteService

type UserModifyResponse 

type UserModifyResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		ID         string    `json:"id"`
		Email      string    `json:"email"`
		GivenName  string    `json:"given_name"`
		FamilyName string    `json:"family_name"`
		Verified   *bool     `json:"verified"`
		Invited    *bool     `json:"invited"`
		Picture    string    `json:"picture"`
		Phone      string    `json:"phone"`
		LoggedInAt time.Time `json:"logged_in_at"`
		CreatedAt  time.Time `json:"created_at"`
		Role       string    `json:"role"`
	} `json:"data"`
}

type UserModifyService 

type UserModifyService struct {
	// contains filtered or unexported fields
}

UserModifyService implements the User Management, Modify a User API. Ref. https://fivetran.com/docs/rest-api/users#modifyauser

func (*UserModifyService) ClearPhone added in v0.7.2 

func (s *UserModifyService) ClearPhone() *UserModifyService

func (*UserModifyService) ClearPicture added in v0.7.2 

func (s *UserModifyService) ClearPicture() *UserModifyService

func (*UserModifyService) Do 

func (s *UserModifyService) Do(ctx context.Context) (UserModifyResponse, error)

func (*UserModifyService) FamilyName 

func (s *UserModifyService) FamilyName(value string) *UserModifyService

func (*UserModifyService) GivenName 

func (s *UserModifyService) GivenName(value string) *UserModifyService

func (*UserModifyService) Phone 

func (s *UserModifyService) Phone(value string) *UserModifyService

func (*UserModifyService) Picture 

func (s *UserModifyService) Picture(value string) *UserModifyService

func (*UserModifyService) Role 

func (s *UserModifyService) Role(value string) *UserModifyService

func (*UserModifyService) UserID 

func (s *UserModifyService) UserID(value string) *UserModifyService

type UsersListResponse 

type UsersListResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		Items []struct {
			ID         string    `json:"id"`
			Email      string    `json:"email"`
			GivenName  string    `json:"given_name"`
			FamilyName string    `json:"family_name"`
			Verified   *bool     `json:"verified"`
			Invited    *bool     `json:"invited"`
			Picture    string    `json:"picture"`
			Phone      string    `json:"phone"`
			Role       string    `json:"role"`
			LoggedInAt time.Time `json:"logged_in_at"`
			CreatedAt  time.Time `json:"created_at"`
		} `json:"items"`
		NextCursor string `json:"next_cursor"`
	} `json:"data"`
}

type UsersListService 

type UsersListService struct {
	// contains filtered or unexported fields
}

UsersListService implements the User Management, List All Users API. Ref. https://fivetran.com/docs/rest-api/users#listallusers

func (*UsersListService) Cursor 

func (s *UsersListService) Cursor(value string) *UsersListService

func (*UsersListService) Do 

func (s *UsersListService) Do(ctx context.Context) (UsersListResponse, error)

func (*UsersListService) Limit 

func (s *UsersListService) Limit(value int) *UsersListService

Source Files

View all Source files

Directories

Path Synopsis
examples
certificateConnectorCertificateApprove
certificateConnectorFingerprintApprove
certificateDestinationCertificateApprove
certificateDestinationFingerprintApprove
connectorCreate-1
connectorCreate-2
connectorCreate-3
connectorDelete
connectorDetails
connectorModify
connectorReSyncTable
connectorSchemaConfigManagement
connectorSetupTests
connectorSync
connectorsSourceMetadata
destinationCreate
destinationDelete
destinationDetails
destinationModify
destinationSetupTests
groupAddUser
groupCreate
groupDelete
groupDetails
groupListConnectors
groupListUsers
groupModify
groupRemoveUser
groupsList
userDelete
userDetails
userInvite
userModify
usersList
mock

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.