fivetran

package module
v0.7.9 Latest Latest
Warning

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

 Go to latest Published: Sep 12, 2023 License: Apache-2.0 Imports: 10 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
Transformations Management API
REST API Endpoint REST API Version SDK Service
Create dbt Project v1 DbtProjectCreateService
Retrieve dbt Project Details v1 DbtProjectDetailsService
Retrieve dbt Projects List v1 DbtProjectsListService
Retrieve dbt Model Details v1 DbtModelDetailsService
Retrieve dbt Models List v1 DbtModelsListService
Update dbt Project v1 DbtProjectModifyService
Delete dbt Project v1 DbtProjectDeleteService
Create dbt Transformation v1 DbtTransformationCreateService
Retrieve dbt Transformation Details v1 DbtTransformationDetailsService
Update dbt Transformation v1 DbtTransformationModifyService
Delete dbt Transformation v1 DbtTransformationDeleteService
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
Log Service Management
REST API Endpoint REST API Version SDK Service/Config
Create a Log Service v1 ExternalLoggingCreateService
Retrieve Log Service Details v1 ExternalLoggingDetailsService
Update a Log Service v1 ExternalLoggingModifyService
Delete a Log Service v1 ExternalLoggingDeleteService
Run Log Service Setup Tests v1 ExternalLoggingSetupTestsService
Metadata API
REST API Endpoint REST API Version SDK Service/Config
Retrieve schema metadata v1 MetadataSchemaListService
Retrieve table metadata v1 MetadataTablesListService
Retrieve column metadata v1 MetadataColumnListService
Webhook Management

--- | --- | --- Create account webhook | v1 | WebhookAccountCreateService Create group webhook | v1 | WebhookGroupCreateService Retrieve webhook details | v1 | WebhookDetailsService Update webhook | v1 | WebhookModifyService Delete webhook | v1 | WebhookDeleteService Retrieve the list of webhooks | v1 | WebhookListService Test webhook | v1 | WebhookTestService

Role Management
REST API Endpoint REST API Version SDK Service/Config
List all roles v1 RolesListService

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) NewDbtModelDetails added in v0.7.7 

func (c *Client) NewDbtModelDetails() *DbtModelDetailsService

func (*Client) NewDbtModelsList added in v0.7.7 

func (c *Client) NewDbtModelsList() *DbtModelsListService

func (*Client) NewDbtProjectCreate added in v0.7.4 

func (c *Client) NewDbtProjectCreate() *DbtProjectCreateService

func (*Client) NewDbtProjectDelete added in v0.7.7 

func (c *Client) NewDbtProjectDelete() *DbtProjectDeleteService

func (*Client) NewDbtProjectDetails added in v0.7.9 

func (c *Client) NewDbtProjectDetails() *DbtProjectDetailsService

func (*Client) NewDbtProjectModify added in v0.7.7 

func (c *Client) NewDbtProjectModify() *DbtProjectModifyService

func (*Client) NewDbtProjectsList added in v0.7.7 

func (c *Client) NewDbtProjectsList() *DbtProjectsListService

func (*Client) NewDbtTransformationCreateService added in v0.7.4 

func (c *Client) NewDbtTransformationCreateService() *DbtTransformationCreateService

func (*Client) NewDbtTransformationDeleteService added in v0.7.4 

func (c *Client) NewDbtTransformationDeleteService() *DbtTransformationDeleteService

func (*Client) NewDbtTransformationDetailsService added in v0.7.4 

func (c *Client) NewDbtTransformationDetailsService() *DbtTransformationDetailsService

func (*Client) NewDbtTransformationModifyService added in v0.7.4 

func (c *Client) NewDbtTransformationModifyService() *DbtTransformationModifyService

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) NewExternalLoggingCreate added in v0.7.5 

func (c *Client) NewExternalLoggingCreate() *ExternalLoggingCreateService

func (*Client) NewExternalLoggingDelete added in v0.7.5 

func (c *Client) NewExternalLoggingDelete() *ExternalLoggingDeleteService

func (*Client) NewExternalLoggingDetails added in v0.7.5 

func (c *Client) NewExternalLoggingDetails() *ExternalLoggingDetailsService

func (*Client) NewExternalLoggingModify added in v0.7.5 

func (c *Client) NewExternalLoggingModify() *ExternalLoggingModifyService

func (*Client) NewExternalLoggingSetupTests added in v0.7.5 

func (c *Client) NewExternalLoggingSetupTests() *ExternalLoggingSetupTestsService

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) NewMetadataColumnsList added in v0.7.7 

func (c *Client) NewMetadataColumnsList() *MetadataColumnsListService

func (*Client) NewMetadataSchemasList added in v0.7.7 

func (c *Client) NewMetadataSchemasList() *MetadataSchemasListService

func (*Client) NewMetadataTablesList added in v0.7.7 

func (c *Client) NewMetadataTablesList() *MetadataTablesListService

func (*Client) NewRolesList added in v0.7.7 

func (c *Client) NewRolesList() *RolesListService

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) NewWebhookAccountCreate added in v0.7.7 

func (c *Client) NewWebhookAccountCreate() *WebhookAccountCreateService

func (*Client) NewWebhookDelete added in v0.7.7 

func (c *Client) NewWebhookDelete() *WebhookDeleteService

func (*Client) NewWebhookDetails added in v0.7.7 

func (c *Client) NewWebhookDetails() *WebhookDetailsService

func (*Client) NewWebhookGroupCreate added in v0.7.7 

func (c *Client) NewWebhookGroupCreate() *WebhookGroupCreateService

func (*Client) NewWebhookList added in v0.7.7 

func (c *Client) NewWebhookList() *WebhookListService

func (*Client) NewWebhookModify added in v0.7.7 

func (c *Client) NewWebhookModify() *WebhookModifyService

func (*Client) SetHandleRateLimits added in v0.7.4 

func (c *Client) SetHandleRateLimits(handleRateLimits bool)

SetHandleRateLimits sets custom HTTP client to handle rate limits automatically

func (*Client) SetHttpClient added in v0.6.4 

func (c *Client) SetHttpClient(httpClient HttpClient)

SetHttpClient sets custom HTTP client to perform requests with

func (*Client) SetMaxRetryAttempts added in v0.7.4 

func (c *Client) SetMaxRetryAttempts(maxRetryAttempts int)

SetMaxRetryAttempts sets custom HTTP client maximum retry attempts count

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 ConnectorTasks added in v0.7.7 

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

type ConnectorWarning added in v0.7.7 

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

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 ConnectorsStatus added in v0.7.7 

type ConnectorsStatus struct {
	SetupState       string             `json:"setup_state"`
	SyncState        string             `json:"sync_state"`
	UpdateState      string             `json:"update_state"`
	IsHistoricalSync *bool              `json:"is_historical_sync"`
	Tasks            []ConnectorTasks   `json:"tasks"`
	Warnings         []ConnectorWarning `json:"warnings"`
}

type DbtModelDetailsResponse added in v0.7.7 

type DbtModelDetailsResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		ID        string `json:"id"`
		ModelName string `json:"model_name"`
		Scheduled bool   `json:"scheduled"`
	} `json:"data"`
}

type DbtModelDetailsService added in v0.7.7 

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

func (*DbtModelDetailsService) Do added in v0.7.7 

func (s *DbtModelDetailsService) Do(ctx context.Context) (DbtModelDetailsResponse, error)

func (*DbtModelDetailsService) ModelId added in v0.7.7 

func (s *DbtModelDetailsService) ModelId(value string) *DbtModelDetailsService

type DbtModelsListResponse added in v0.7.7 

type DbtModelsListResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		Items []struct {
			ID        string `json:"id"`
			ModelName string `json:"model_name"`
			Scheduled bool   `json:"scheduled"`
		} `json:"items"`
		NextCursor string `json:"next_cursor"`
	} `json:"data"`
}

type DbtModelsListService added in v0.7.7 

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

func (*DbtModelsListService) Cursor added in v0.7.7 

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

func (*DbtModelsListService) Do added in v0.7.7 

func (s *DbtModelsListService) Do(ctx context.Context) (DbtModelsListResponse, error)

func (*DbtModelsListService) Limit added in v0.7.7 

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

func (*DbtModelsListService) ProjectId added in v0.7.7 

func (s *DbtModelsListService) ProjectId(value string) *DbtModelsListService

type DbtProjectConfig added in v0.7.7 

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

func NewDbtProjectConfig added in v0.7.7 

func NewDbtProjectConfig() *DbtProjectConfig

func (*DbtProjectConfig) FolderPath added in v0.7.7 

func (dc *DbtProjectConfig) FolderPath(value string) *DbtProjectConfig

func (*DbtProjectConfig) GitBranch added in v0.7.7 

func (dc *DbtProjectConfig) GitBranch(value string) *DbtProjectConfig

func (*DbtProjectConfig) GitRemoteUrl added in v0.7.7 

func (dc *DbtProjectConfig) GitRemoteUrl(value string) *DbtProjectConfig

type DbtProjectConfigResponse added in v0.7.7 

type DbtProjectConfigResponse struct {
	GitRemoteUrl string `json:"git_remote_url"`
	GitBranch    string `json:"git_branch"`
	FolderPath   string `json:"folder_path"`
}

type DbtProjectCreateService added in v0.7.4 

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

func (*DbtProjectCreateService) DbtVersion added in v0.7.4 

func (s *DbtProjectCreateService) DbtVersion(value string) *DbtProjectCreateService

func (*DbtProjectCreateService) DefaultSchema added in v0.7.4 

func (s *DbtProjectCreateService) DefaultSchema(value string) *DbtProjectCreateService

func (*DbtProjectCreateService) Do added in v0.7.4 

func (s *DbtProjectCreateService) Do(ctx context.Context) (DbtProjectDetailsResponse, error)

func (*DbtProjectCreateService) EnvironmentVars added in v0.7.7 

func (s *DbtProjectCreateService) EnvironmentVars(value []string) *DbtProjectCreateService

func (*DbtProjectCreateService) GroupID added in v0.7.4 

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

func (*DbtProjectCreateService) ProjectConfig added in v0.7.7 

func (s *DbtProjectCreateService) ProjectConfig(value *DbtProjectConfig) *DbtProjectCreateService

func (*DbtProjectCreateService) TargetName added in v0.7.4 

func (s *DbtProjectCreateService) TargetName(value string) *DbtProjectCreateService

func (*DbtProjectCreateService) Threads added in v0.7.4 

func (s *DbtProjectCreateService) Threads(value int) *DbtProjectCreateService

func (*DbtProjectCreateService) Type added in v0.7.7 

func (s *DbtProjectCreateService) Type(value string) *DbtProjectCreateService

type DbtProjectDeleteResponse added in v0.7.7 

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

type DbtProjectDeleteService added in v0.7.7 

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

ProjectDeleteService implements the Project Management, Delete a project API. Ref. https://fivetran.com/docs/rest-api/projects#deleteaproject

func (*DbtProjectDeleteService) DbtProjectID added in v0.7.8 

func (s *DbtProjectDeleteService) DbtProjectID(value string) *DbtProjectDeleteService

func (*DbtProjectDeleteService) Do added in v0.7.7 

func (s *DbtProjectDeleteService) Do(ctx context.Context) (DbtProjectDeleteResponse, error)

type DbtProjectDetailsData added in v0.7.7 

type DbtProjectDetailsData struct {
	ID              string                   `json:"id"`
	DbtVersion      string                   `json:"dbt_version"`
	GroupID         string                   `json:"group_id"`
	CreatedAt       string                   `json:"created_at"`
	CreatedById     string                   `json:"created_by_id"`
	PublicKey       string                   `json:"public_key"`
	DefaultSchema   string                   `json:"default_schema"`
	TargetName      string                   `json:"target_name"`
	Threads         int                      `json:"threads"`
	EnvironmentVars []string                 `json:"environment_vars"`
	Type            string                   `json:"type"`
	ProjectConfig   DbtProjectConfigResponse `json:"project_config"`
	Status          string                   `json:"status"`
	Errors          []string                 `json:"errors"`
}

type DbtProjectDetailsResponse added in v0.7.4 

type DbtProjectDetailsResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		DbtProjectDetailsData
	} `json:"data"`
}

type DbtProjectDetailsService added in v0.7.4 

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

func (*DbtProjectDetailsService) DbtProjectID added in v0.7.4 

func (s *DbtProjectDetailsService) DbtProjectID(value string) *DbtProjectDetailsService

func (*DbtProjectDetailsService) Do added in v0.7.4 

func (s *DbtProjectDetailsService) Do(ctx context.Context) (DbtProjectDetailsResponse, error)

type DbtProjectModifyService added in v0.7.7 

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

func (*DbtProjectModifyService) DbtProjectID added in v0.7.8 

func (s *DbtProjectModifyService) DbtProjectID(value string) *DbtProjectModifyService

func (*DbtProjectModifyService) DbtVersion added in v0.7.7 

func (s *DbtProjectModifyService) DbtVersion(value string) *DbtProjectModifyService

func (*DbtProjectModifyService) Do added in v0.7.7 

func (s *DbtProjectModifyService) Do(ctx context.Context) (DbtProjectDetailsResponse, error)

func (*DbtProjectModifyService) EnvironmentVars added in v0.7.7 

func (s *DbtProjectModifyService) EnvironmentVars(value []string) *DbtProjectModifyService

func (*DbtProjectModifyService) ProjectConfig added in v0.7.7 

func (s *DbtProjectModifyService) ProjectConfig(value *DbtProjectConfig) *DbtProjectModifyService

func (*DbtProjectModifyService) TargetName added in v0.7.7 

func (s *DbtProjectModifyService) TargetName(value string) *DbtProjectModifyService

func (*DbtProjectModifyService) Threads added in v0.7.7 

func (s *DbtProjectModifyService) Threads(value int) *DbtProjectModifyService

type DbtProjectsListResponse added in v0.7.7 

type DbtProjectsListResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		Items []struct {
			ID          string `json:"id"`
			GroupId     string `json:"group_id"`
			CreatedAt   string `json:"created_at"`
			CreatedById string `json:"created_by_id"`
		} `json:"items"`
		NextCursor string `json:"next_cursor"`
	} `json:"data"`
}

type DbtProjectsListService added in v0.7.7 

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

func (*DbtProjectsListService) Cursor added in v0.7.7 

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

func (*DbtProjectsListService) Do added in v0.7.7 

func (s *DbtProjectsListService) Do(ctx context.Context) (DbtProjectsListResponse, error)

func (*DbtProjectsListService) Limit added in v0.7.7 

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

type DbtTransformationCreateService added in v0.7.4 

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

func (*DbtTransformationCreateService) DbtModelId added in v0.7.4 

func (s *DbtTransformationCreateService) DbtModelId(value string) *DbtTransformationCreateService

func (*DbtTransformationCreateService) Do added in v0.7.4 

func (s *DbtTransformationCreateService) Do(ctx context.Context) (DbtTransformationResponse, error)

func (*DbtTransformationCreateService) Paused added in v0.7.5 

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

func (*DbtTransformationCreateService) RunTests added in v0.7.4 

func (s *DbtTransformationCreateService) RunTests(value bool) *DbtTransformationCreateService

func (*DbtTransformationCreateService) Schedule added in v0.7.4 

func (s *DbtTransformationCreateService) Schedule(value *DbtTransformationSchedule) *DbtTransformationCreateService

type DbtTransformationDeleteResponse added in v0.7.4 

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

type DbtTransformationDeleteService added in v0.7.4 

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

func (*DbtTransformationDeleteService) Do added in v0.7.4 

func (s *DbtTransformationDeleteService) Do(ctx context.Context) (DbtTransformationDeleteResponse, error)

func (*DbtTransformationDeleteService) TransformationId added in v0.7.4 

func (s *DbtTransformationDeleteService) TransformationId(value string) *DbtTransformationDeleteService

type DbtTransformationDetailsService added in v0.7.4 

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

func (*DbtTransformationDetailsService) Do added in v0.7.4 

func (s *DbtTransformationDetailsService) Do(ctx context.Context) (DbtTransformationResponse, error)

func (*DbtTransformationDetailsService) TransformationId added in v0.7.4 

func (s *DbtTransformationDetailsService) TransformationId(value string) *DbtTransformationDetailsService

type DbtTransformationModifyService added in v0.7.4 

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

func (*DbtTransformationModifyService) DbtTransformationId added in v0.7.4 

func (s *DbtTransformationModifyService) DbtTransformationId(value string) *DbtTransformationModifyService

func (*DbtTransformationModifyService) Do added in v0.7.4 

func (s *DbtTransformationModifyService) Do(ctx context.Context) (DbtTransformationResponse, error)

func (*DbtTransformationModifyService) Paused added in v0.7.5 

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

func (*DbtTransformationModifyService) RunTests added in v0.7.4 

func (s *DbtTransformationModifyService) RunTests(value bool) *DbtTransformationModifyService

func (*DbtTransformationModifyService) Schedule added in v0.7.4 

func (s *DbtTransformationModifyService) Schedule(value *DbtTransformationSchedule) *DbtTransformationModifyService

type DbtTransformationResponse added in v0.7.5 

type DbtTransformationResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		ID              string                            `json:"id"`
		Status          string                            `json:"status"`
		Schedule        DbtTransformationScheduleResponse `json:"schedule"`
		LastRun         string                            `json:"last_run"`
		OutputModelName string                            `json:"output_model_name"`
		DbtProjectId    string                            `json:"dbt_project_id"`
		DbtModelId      string                            `json:"dbt_model_id"`
		NextRun         string                            `json:"next_run"`
		CreatedAt       string                            `json:"created_at"`
		ModelIds        []string                          `json:"model_ids"`
		ConnectorIds    []string                          `json:"connector_ids"`
		RunTests        bool                              `json:"run_tests"`
		Paused          bool                              `json:"paused"`
	} `json:"data"`
}

type DbtTransformationSchedule added in v0.7.4 

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

func NewDbtTransformationSchedule added in v0.7.4 

func NewDbtTransformationSchedule() *DbtTransformationSchedule

func (*DbtTransformationSchedule) DaysOfWeek added in v0.7.4 

func (dbtTransformationSchedule *DbtTransformationSchedule) DaysOfWeek(value []string) *DbtTransformationSchedule

func (*DbtTransformationSchedule) Interval added in v0.7.4 

func (dbtTransformationSchedule *DbtTransformationSchedule) Interval(value int) *DbtTransformationSchedule

func (*DbtTransformationSchedule) ScheduleType added in v0.7.4 

func (dbtTransformationSchedule *DbtTransformationSchedule) ScheduleType(value string) *DbtTransformationSchedule

func (*DbtTransformationSchedule) TimeOfDay added in v0.7.4 

func (dbtTransformationSchedule *DbtTransformationSchedule) TimeOfDay(value string) *DbtTransformationSchedule

type DbtTransformationScheduleResponse added in v0.7.5 

type DbtTransformationScheduleResponse struct {
	ScheduleType string   `json:"schedule_type"`
	DaysOfWeek   []string `json:"days_of_week"`
	Interval     int      `json:"interval"`
	TimeOfDay    string   `json:"time_of_day"`
}

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 ExternalLoggingConfig added in v0.7.5 

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

ExternalLoggingConfig builds Log Management, Log Config. Ref. https://fivetran.com/docs/rest-api/log-service-management#logservicesetupconfigurations

func NewExternalLoggingConfig added in v0.7.5 

func NewExternalLoggingConfig() *ExternalLoggingConfig

func (*ExternalLoggingConfig) ApiKey added in v0.7.5 

func (elc *ExternalLoggingConfig) ApiKey(value string) *ExternalLoggingConfig

func (*ExternalLoggingConfig) Channel added in v0.7.5 

func (elc *ExternalLoggingConfig) Channel(value string) *ExternalLoggingConfig

func (*ExternalLoggingConfig) EnableSsl added in v0.7.5 

func (elc *ExternalLoggingConfig) EnableSsl(value string) *ExternalLoggingConfig

func (*ExternalLoggingConfig) ExternalId added in v0.7.5 

func (elc *ExternalLoggingConfig) ExternalId(value string) *ExternalLoggingConfig

func (*ExternalLoggingConfig) Host added in v0.7.5 

func (elc *ExternalLoggingConfig) Host(value string) *ExternalLoggingConfig

func (*ExternalLoggingConfig) Hostname added in v0.7.5 

func (elc *ExternalLoggingConfig) Hostname(value string) *ExternalLoggingConfig

func (*ExternalLoggingConfig) LogGroupName added in v0.7.5 

func (elc *ExternalLoggingConfig) LogGroupName(value string) *ExternalLoggingConfig

func (*ExternalLoggingConfig) Port added in v0.7.5 

func (elc *ExternalLoggingConfig) Port(value int) *ExternalLoggingConfig

func (*ExternalLoggingConfig) PrimaryKey added in v0.7.5 

func (elc *ExternalLoggingConfig) PrimaryKey(value string) *ExternalLoggingConfig

func (*ExternalLoggingConfig) Region added in v0.7.5 

func (elc *ExternalLoggingConfig) Region(value string) *ExternalLoggingConfig

func (*ExternalLoggingConfig) RoleArn added in v0.7.5 

func (elc *ExternalLoggingConfig) RoleArn(value string) *ExternalLoggingConfig

func (*ExternalLoggingConfig) SubDomain added in v0.7.5 

func (elc *ExternalLoggingConfig) SubDomain(value string) *ExternalLoggingConfig

func (*ExternalLoggingConfig) Token added in v0.7.5 

func (elc *ExternalLoggingConfig) Token(value string) *ExternalLoggingConfig

func (*ExternalLoggingConfig) WorkspaceId added in v0.7.5 

func (elc *ExternalLoggingConfig) WorkspaceId(value string) *ExternalLoggingConfig

type ExternalLoggingConfigResponse added in v0.7.5 

type ExternalLoggingConfigResponse struct {
	WorkspaceId  string `json:"workspace_id"`
	PrimaryKey   string `json:"primary_key"`
	LogGroupName string `json:"log_group_name"`
	RoleArn      string `json:"role_arn"`
	ExternalId   string `json:"external_id"`
	Region       string `json:"region"`
	ApiKey       string `json:"api_key"`
	SubDomain    string `json:"sub_domain"`
	Host         string `json:"host"`
	Hostname     string `json:"hostname"`
	Channel      string `json:"channel"`
	EnableSsl    string `json:"enable_ssl"`
	Token        string `json:"token"`
	Port         int    `json:"port"`
}

type ExternalLoggingCreateResponse added in v0.7.5 

type ExternalLoggingCreateResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		ExternalLoggingCreateResponseBase
		Config ExternalLoggingConfigResponse `json:"config"`
	} `json:"data"`
}

type ExternalLoggingCreateResponseBase added in v0.7.6 

type ExternalLoggingCreateResponseBase struct {
	Id      string `json:"id"`
	Service string `json:"service"`
	Enabled bool   `json:"enabled"`
}

type ExternalLoggingCreateService added in v0.7.5 

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

ExternalLoggingCreateService implements the Log Management, Create a Log Service API. Ref. https://fivetran.com/docs/rest-api/log-service-management#createalogservice

func (*ExternalLoggingCreateService) Config added in v0.7.5 

func (s *ExternalLoggingCreateService) Config(value *ExternalLoggingConfig) *ExternalLoggingCreateService

func (*ExternalLoggingCreateService) ConfigCustom added in v0.7.6 

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

func (*ExternalLoggingCreateService) Do added in v0.7.5 

func (s *ExternalLoggingCreateService) Do(ctx context.Context) (ExternalLoggingCreateResponse, error)

func (*ExternalLoggingCreateService) DoCustom added in v0.7.6 

func (s *ExternalLoggingCreateService) DoCustom(ctx context.Context) (ExternalLoggingCustomCreateResponse, error)

func (*ExternalLoggingCreateService) DoCustomMerged added in v0.7.6 

func (s *ExternalLoggingCreateService) DoCustomMerged(ctx context.Context) (ExternalLoggingCustomMergedCreateResponse, error)

func (*ExternalLoggingCreateService) Enabled added in v0.7.5 

func (s *ExternalLoggingCreateService) Enabled(value bool) *ExternalLoggingCreateService

func (*ExternalLoggingCreateService) GroupId added in v0.7.5 

func (s *ExternalLoggingCreateService) GroupId(value string) *ExternalLoggingCreateService

func (*ExternalLoggingCreateService) Service added in v0.7.5 

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

type ExternalLoggingCustomCreateResponse added in v0.7.6 

type ExternalLoggingCustomCreateResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		ExternalLoggingCreateResponseBase
		Config ExternalLoggingConfigResponse `json:"config"`
	} `json:"data"`
}

type ExternalLoggingCustomMergedCreateResponse added in v0.7.6 

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

type ExternalLoggingDeleteResponse added in v0.7.5 

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

type ExternalLoggingDeleteService added in v0.7.5 

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

ExternalLoggingDeleteService implements the Log Management, Delete a Log Service API. Ref. https://fivetran.com/docs/rest-api/log-service-management#deletealogservice

func (*ExternalLoggingDeleteService) Do added in v0.7.5 

func (s *ExternalLoggingDeleteService) Do(ctx context.Context) (ExternalLoggingDeleteResponse, error)

func (*ExternalLoggingDeleteService) ExternalLoggingId added in v0.7.5 

func (s *ExternalLoggingDeleteService) ExternalLoggingId(value string) *ExternalLoggingDeleteService

type ExternalLoggingDetailsResponse added in v0.7.5 

type ExternalLoggingDetailsResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		Id      string                        `json:"id"`
		Service string                        `json:"service"`
		Enabled bool                          `json:"enabled"`
		Config  ExternalLoggingConfigResponse `json:"config"`
	} `json:"data"`
}

type ExternalLoggingDetailsService added in v0.7.5 

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

ExternalLoggingDetailsService implements the Log Management, Retrieve Log Service details API. Ref. https://fivetran.com/docs/rest-api/log-service-management#retrievelogservicedetails

func (*ExternalLoggingDetailsService) Do added in v0.7.5 

func (s *ExternalLoggingDetailsService) Do(ctx context.Context) (ExternalLoggingDetailsResponse, error)

func (*ExternalLoggingDetailsService) ExternalLoggingId added in v0.7.5 

func (s *ExternalLoggingDetailsService) ExternalLoggingId(value string) *ExternalLoggingDetailsService

type ExternalLoggingModifyCustomMergedResponse added in v0.7.7 

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

type ExternalLoggingModifyCustomResponse added in v0.7.7 

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

type ExternalLoggingModifyResponse added in v0.7.5 

type ExternalLoggingModifyResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		ExternalLoggingModifyResponseDataBased
		Config ExternalLoggingConfigResponse `json:"config"`
	} `json:"data"`
}

type ExternalLoggingModifyResponseDataBased added in v0.7.7 

type ExternalLoggingModifyResponseDataBased struct {
	Id      string `json:"id"`
	Service string `json:"service"`
	Enabled bool   `json:"enabled"`
}

type ExternalLoggingModifyService added in v0.7.5 

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

ExternalLoggingModifyService implements the Log Management, Modify a Log Service API. Ref. https://fivetran.com/docs/rest-api/log-service-management#updatealogservice

func (*ExternalLoggingModifyService) Config added in v0.7.5 

func (s *ExternalLoggingModifyService) Config(value *ExternalLoggingConfig) *ExternalLoggingModifyService

func (*ExternalLoggingModifyService) ConfigCustom added in v0.7.6 

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

func (*ExternalLoggingModifyService) Do added in v0.7.5 

func (s *ExternalLoggingModifyService) Do(ctx context.Context) (ExternalLoggingModifyResponse, error)

func (*ExternalLoggingModifyService) DoCustom added in v0.7.6 

func (s *ExternalLoggingModifyService) DoCustom(ctx context.Context) (ExternalLoggingModifyCustomResponse, error)

func (*ExternalLoggingModifyService) DoCustomMerged added in v0.7.7 

func (s *ExternalLoggingModifyService) DoCustomMerged(ctx context.Context) (ExternalLoggingModifyCustomMergedResponse, error)

func (*ExternalLoggingModifyService) Enabled added in v0.7.5 

func (s *ExternalLoggingModifyService) Enabled(value bool) *ExternalLoggingModifyService

func (*ExternalLoggingModifyService) ExternalLoggingId added in v0.7.5 

func (s *ExternalLoggingModifyService) ExternalLoggingId(value string) *ExternalLoggingModifyService

func (*ExternalLoggingModifyService) RunSetupTests added in v0.7.5 

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

type ExternalLoggingSetupTestsResponse added in v0.7.5 

type ExternalLoggingSetupTestsResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		SetupTests []struct {
			Title   string `json:"title"`
			Status  string `json:"status"`
			Message string `json:"message"`
		} `json:"setup_tests"`
	} `json:"data"`
}

type ExternalLoggingSetupTestsService added in v0.7.5 

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

ExternalLoggingSetupTestsService implements the Log Management, Run Log service setup tests API. Ref. https://fivetran.com/docs/rest-api/log-service-management#runlogservicesetuptests

func (*ExternalLoggingSetupTestsService) Do added in v0.7.5 

func (s *ExternalLoggingSetupTestsService) Do(ctx context.Context) (ExternalLoggingSetupTestsResponse, error)

func (*ExternalLoggingSetupTestsService) ExternalLoggingId added in v0.7.5 

func (s *ExternalLoggingSetupTestsService) ExternalLoggingId(value string) *ExternalLoggingSetupTestsService

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 GroupDeleteResponse added in v0.7.7 

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

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         ConnectorsStatus `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"`
			Active     *bool     `json:"active"`
		} `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 MetadataColumnsListResponse added in v0.7.7 

type MetadataColumnsListResponse struct {
	Code string `json:"code"`
	Data struct {
		Items []struct {
			Id                string `json:"id"`
			ParentId          string `json:"parent_id"`
			NameInSource      string `json:"name_in_source"`
			NameInDestination string `json:"name_in_destination"`
			TypeInSource      string `json:"type_in_source"`
			TypeInDestination string `json:"type_in_destination"`
			IsPrimaryKey      *bool  `json:"is_primary_key"`
			IsForeignKey      *bool  `json:"is_foreign_key"`
		} `json:"items"`
		NextCursor string `json:"next_cursor"`
	} `json:"data"`
}

type MetadataColumnsListService added in v0.7.7 

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

MetadataColumnsListService implements the Metadata Management, Retrieve Column metadata Ref. https://fivetran.com/docs/rest-api/metadata#retrievecolumnmetadata

func (*MetadataColumnsListService) ConnectorId added in v0.7.7 

func (s *MetadataColumnsListService) ConnectorId(value string) *MetadataColumnsListService

func (*MetadataColumnsListService) Cursor added in v0.7.7 

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

func (*MetadataColumnsListService) Do added in v0.7.7 

func (s *MetadataColumnsListService) Do(ctx context.Context) (MetadataColumnsListResponse, error)

func (*MetadataColumnsListService) Limit added in v0.7.7 

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

type MetadataSchemasListResponse added in v0.7.7 

type MetadataSchemasListResponse struct {
	Code string `json:"code"`
	Data struct {
		Items []struct {
			Id                string `json:"id"`
			NameInSource      string `json:"name_in_source"`
			NameInDestination string `json:"name_in_destination"`
		} `json:"items"`
		NextCursor string `json:"next_cursor"`
	} `json:"data"`
}

type MetadataSchemasListService added in v0.7.7 

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

MetadataSchemasListService implements the Metadata Management, Retrieve schema metadata Ref. https://fivetran.com/docs/rest-api/metadata#retrieveschemametadata

func (*MetadataSchemasListService) ConnectorId added in v0.7.7 

func (s *MetadataSchemasListService) ConnectorId(value string) *MetadataSchemasListService

func (*MetadataSchemasListService) Cursor added in v0.7.7 

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

func (*MetadataSchemasListService) Do added in v0.7.7 

func (s *MetadataSchemasListService) Do(ctx context.Context) (MetadataSchemasListResponse, error)

func (*MetadataSchemasListService) Limit added in v0.7.7 

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

type MetadataTablesListResponse added in v0.7.7 

type MetadataTablesListResponse struct {
	Code string `json:"code"`
	Data struct {
		Items []struct {
			Id                string `json:"id"`
			ParentId          string `json:"parent_id"`
			NameInSource      string `json:"name_in_source"`
			NameInDestination string `json:"name_in_destination"`
		} `json:"items"`
		NextCursor string `json:"next_cursor"`
	} `json:"data"`
}

type MetadataTablesListService added in v0.7.7 

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

MetadataTableListService implements the Metadata Management, Retrieve table metadata Ref. https://fivetran.com/docs/rest-api/metadata#retrievetablemetadata

func (*MetadataTablesListService) ConnectorId added in v0.7.7 

func (s *MetadataTablesListService) ConnectorId(value string) *MetadataTablesListService

func (*MetadataTablesListService) Cursor added in v0.7.7 

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

func (*MetadataTablesListService) Do added in v0.7.7 

func (s *MetadataTablesListService) Do(ctx context.Context) (MetadataTablesListResponse, error)

func (*MetadataTablesListService) Limit added in v0.7.7 

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

type RolesListResponse added in v0.7.7 

type RolesListResponse struct {
	Code string `json:"code"`
	Data struct {
		Items []struct {
			Name        string   `json:"name"`
			Description string   `json:"description"`
			IsCustom    *bool    `json:"is_custom"`
			Scope       []string `json:"scope"`
		} `json:"items"`
		NextCursor string `json:"next_cursor"`
	} `json:"data"`
}

type RolesListService added in v0.7.7 

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

RolesListService implements the Group Management, List All Roles API. Ref. https://fivetran.com/docs/rest-api/roles

func (*RolesListService) Cursor added in v0.7.7 

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

func (*RolesListService) Do added in v0.7.7 

func (s *RolesListService) Do(ctx context.Context) (RolesListResponse, error)

func (*RolesListService) Limit added in v0.7.7 

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

type UserDeleteResponse added in v0.7.4 

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

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 UserDetailsData added in v0.7.4 

type UserDetailsData 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"`
}

type UserDetailsResponse 

type UserDetailsResponse struct {
	Code    string          `json:"code"`
	Message string          `json:"message"`
	Data    UserDetailsData `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 UserModifyData added in v0.7.4 

type UserModifyData 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"`
}

type UserModifyResponse 

type UserModifyResponse struct {
	Code    string         `json:"code"`
	Message string         `json:"message"`
	Data    UserModifyData `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

type WebhookAccountCreateResponse added in v0.7.7 

type WebhookAccountCreateResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		Id        string   `json:"id"`
		Type      string   `json:"type"`
		Url       string   `json:"url"`
		Events    []string `json:"events"`
		Active    bool     `json:"active"`
		Secret    string   `json:"secret"`
		CreatedAt string   `json:"created_at"`
		CreatedBy string   `json:"created_by"`
	} `json:"data"`
}

type WebhookAccountCreateService added in v0.7.7 

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

WebhookAccountCreateService implements the Webhook Management, Create a Account Webhook. Ref. https://fivetran.com/docs/rest-api/webhooks#createaccountwebhook

func (*WebhookAccountCreateService) Active added in v0.7.7 

func (s *WebhookAccountCreateService) Active(value bool) *WebhookAccountCreateService

func (*WebhookAccountCreateService) Do added in v0.7.7 

func (s *WebhookAccountCreateService) Do(ctx context.Context) (WebhookAccountCreateResponse, error)

func (*WebhookAccountCreateService) Events added in v0.7.7 

func (s *WebhookAccountCreateService) Events(value []string) *WebhookAccountCreateService

func (*WebhookAccountCreateService) Secret added in v0.7.7 

func (s *WebhookAccountCreateService) Secret(value string) *WebhookAccountCreateService

func (*WebhookAccountCreateService) Url added in v0.7.7 

func (s *WebhookAccountCreateService) Url(value string) *WebhookAccountCreateService

type WebhookDeleteResponse added in v0.7.7 

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

type WebhookDeleteService added in v0.7.7 

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

WebhookDeleteService implements the Webhook Management, Delete a Webhook. Ref. https://fivetran.com/docs/rest-api/webhooks#deletewebhook

func (*WebhookDeleteService) Do added in v0.7.7 

func (s *WebhookDeleteService) Do(ctx context.Context) (WebhookDeleteResponse, error)

func (*WebhookDeleteService) WebhookId added in v0.7.7 

func (s *WebhookDeleteService) WebhookId(value string) *WebhookDeleteService

type WebhookDetailsResponse added in v0.7.7 

type WebhookDetailsResponse struct {
	Code string `json:"code"`
	Data struct {
		Id        string   `json:"id"`
		Type      string   `json:"type"`
		Url       string   `json:"url"`
		GroupId   string   `json:"group_id"`
		Events    []string `json:"events"`
		Active    bool     `json:"active"`
		Secret    string   `json:"secret"`
		CreatedAt string   `json:"created_at"`
		CreatedBy string   `json:"created_by"`
	} `json:"data"`
}

type WebhookDetailsService added in v0.7.7 

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

WebhookDetailsService implements the Webhook Management, retrieve Webhook Details. Ref. https://fivetran.com/docs/rest-api/webhooks#retrievewebhookdetails

func (*WebhookDetailsService) Do added in v0.7.7 

func (s *WebhookDetailsService) Do(ctx context.Context) (WebhookDetailsResponse, error)

func (*WebhookDetailsService) WebhookId added in v0.7.7 

func (s *WebhookDetailsService) WebhookId(value string) *WebhookDetailsService

type WebhookGroupCreateResponse added in v0.7.7 

type WebhookGroupCreateResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		Id        string   `json:"id"`
		Type      string   `json:"type"`
		Url       string   `json:"url"`
		GroupId   string   `json:"group_id"`
		Events    []string `json:"events"`
		Active    bool     `json:"active"`
		Secret    string   `json:"secret"`
		CreatedAt string   `json:"created_at"`
		CreatedBy string   `json:"created_by"`
	} `json:"data"`
}

type WebhookGroupCreateService added in v0.7.7 

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

WebhookGroupCreateService implements the Webhook Management, Create a Group Webhook. Ref. https://fivetran.com/docs/rest-api/webhooks#creategroupwebhook

func (*WebhookGroupCreateService) Active added in v0.7.7 

func (s *WebhookGroupCreateService) Active(value bool) *WebhookGroupCreateService

func (*WebhookGroupCreateService) Do added in v0.7.7 

func (s *WebhookGroupCreateService) Do(ctx context.Context) (WebhookGroupCreateResponse, error)

func (*WebhookGroupCreateService) Events added in v0.7.7 

func (s *WebhookGroupCreateService) Events(value []string) *WebhookGroupCreateService

func (*WebhookGroupCreateService) GroupId added in v0.7.7 

func (s *WebhookGroupCreateService) GroupId(value string) *WebhookGroupCreateService

func (*WebhookGroupCreateService) Secret added in v0.7.7 

func (s *WebhookGroupCreateService) Secret(value string) *WebhookGroupCreateService

func (*WebhookGroupCreateService) Url added in v0.7.7 

func (s *WebhookGroupCreateService) Url(value string) *WebhookGroupCreateService

type WebhookListResponse added in v0.7.7 

type WebhookListResponse struct {
	Code string `json:"code"`
	Data struct {
		Items []struct {
			Id        string   `json:"id"`
			Type      string   `json:"type"`
			Url       string   `json:"url"`
			GroupId   string   `json:"group_id"`
			Events    []string `json:"events"`
			Active    bool     `json:"active"`
			Secret    string   `json:"secret"`
			CreatedAt string   `json:"created_at"`
			CreatedBy string   `json:"created_by"`
		} `json:"items"`
		NextCursor string `json:"next_cursor"`
	} `json:"data"`
}

type WebhookListService added in v0.7.7 

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

WebhookListService implements the Webhook Management, retrieve List Webhook. Ref. https://fivetran.com/docs/rest-api/webhooks#retrievethelistofwebhooks

func (*WebhookListService) Cursor added in v0.7.7 

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

func (*WebhookListService) Do added in v0.7.7 

func (s *WebhookListService) Do(ctx context.Context) (WebhookListResponse, error)

func (*WebhookListService) Limit added in v0.7.7 

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

type WebhookModifyResponse added in v0.7.7 

type WebhookModifyResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Data    struct {
		Id        string   `json:"id"`
		Type      string   `json:"type"`
		Url       string   `json:"url"`
		GroupId   string   `json:"group_id"`
		Events    []string `json:"events"`
		Active    bool     `json:"active"`
		Secret    string   `json:"secret"`
		CreatedAt string   `json:"created_at"`
		CreatedBy string   `json:"created_by"`
	} `json:"data"`
}

type WebhookModifyService added in v0.7.7 

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

WebhookModifyService implements the Webhook Management, Modify a Webhook. Ref. https://fivetran.com/docs/rest-api/webhooks#updatewebhook

func (*WebhookModifyService) Active added in v0.7.7 

func (s *WebhookModifyService) Active(value bool) *WebhookModifyService

func (*WebhookModifyService) Do added in v0.7.7 

func (s *WebhookModifyService) Do(ctx context.Context) (WebhookModifyResponse, error)

func (*WebhookModifyService) Events added in v0.7.7 

func (s *WebhookModifyService) Events(value []string) *WebhookModifyService

func (*WebhookModifyService) RunTests added in v0.7.7 

func (s *WebhookModifyService) RunTests(value bool) *WebhookModifyService

func (*WebhookModifyService) Secret added in v0.7.7 

func (s *WebhookModifyService) Secret(value string) *WebhookModifyService

func (*WebhookModifyService) Url added in v0.7.7 

func (s *WebhookModifyService) Url(value string) *WebhookModifyService

func (*WebhookModifyService) WebhookId added in v0.7.7 

func (s *WebhookModifyService) WebhookId(value string) *WebhookModifyService

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.