internal

package

v1.3.5 Latest Latest Go to latest Published: Nov 21, 2024 License: MIT Imports: 11 Imported by: 0

Documentation ¶

Index ¶

func BuildTableSettingsInput(settings map[string]any) (*pc.TableSettingsInput, error)
func ClickHouseDataSourceCreate(ctx context.Context, d *schema.ResourceData, c graphql.Client) (string, error)
func ClickHouseDataSourceSchema() *schema.Schema
func ClickHouseDataSourceUpdate(ctx context.Context, d *schema.ResourceData, c graphql.Client) error
func HandleClickHouseConnectionSettings(response *pc.DataSourceResponse, d *schema.ResourceData) error
func HandleHttpConnectionSettings(response *pc.DataSourceResponse, d *schema.ResourceData) error
func HandleKafkaConnectionSettings(response *pc.DataSourceResponse, d *schema.ResourceData) error
func HandleS3ConnectionSettings(response *pc.DataSourceResponse, d *schema.ResourceData) error
func HandleSnowflakeConnectionSettings(response *pc.DataSourceResponse, d *schema.ResourceData) error
func HandleWebhookConnectionSettings(response *pc.DataSourceResponse, d *schema.ResourceData) error
func HttpDataSourceCreate(ctx context.Context, d *schema.ResourceData, c graphql.Client) (string, error)
func HttpDataSourceSchema() *schema.Schema
func HttpDataSourceUpdate(ctx context.Context, d *schema.ResourceData, c graphql.Client) error
func KafkaDataSourceCreate(ctx context.Context, d *schema.ResourceData, c graphql.Client) (string, error)
func KafkaDataSourceSchema() *schema.Schema
func KafkaDataSourceUpdate(ctx context.Context, d *schema.ResourceData, c graphql.Client) error
func ParseTableSettings(settingsData pc.TableSettingsData) map[string]any
func S3DataSourceCreate(ctx context.Context, d *schema.ResourceData, c graphql.Client) (string, error)
func S3DataSourceSchema() *schema.Schema
func S3DataSourceUpdate(ctx context.Context, d *schema.ResourceData, c graphql.Client) error
func SnowflakeDataSourceCreate(ctx context.Context, d *schema.ResourceData, c graphql.Client) (string, error)
func SnowflakeDataSourceSchema() *schema.Schema
func SnowflakeDataSourceUpdate(ctx context.Context, d *schema.ResourceData, c graphql.Client) error
func TableSettingsSchema() *schema.Schema
func WaitForAddColumnJobSucceeded(ctx context.Context, client graphql.Client, id string, timeout time.Duration) error
func WaitForDataPoolDeletion(ctx context.Context, client graphql.Client, id string, timeout time.Duration) error
func WaitForDataPoolLive(ctx context.Context, client graphql.Client, id string, timeout time.Duration) error
func WebhookDataSourceCreate(ctx context.Context, d *schema.ResourceData, c graphql.Client) (string, error)
func WebhookDataSourceDelete(ctx context.Context, d *schema.ResourceData, c graphql.Client) error
func WebhookDataSourceSchema() *schema.Schema
func WebhookDataSourceUpdate(ctx context.Context, d *schema.ResourceData, c graphql.Client) error

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func BuildTableSettingsInput ¶

func BuildTableSettingsInput(settings map[string]any) (*pc.TableSettingsInput, error)

func ClickHouseDataSourceCreate ¶

func ClickHouseDataSourceCreate(ctx context.Context, d *schema.ResourceData, c graphql.Client) (string, error)

func ClickHouseDataSourceSchema ¶

func ClickHouseDataSourceSchema() *schema.Schema

func ClickHouseDataSourceUpdate ¶

func ClickHouseDataSourceUpdate(ctx context.Context, d *schema.ResourceData, c graphql.Client) error

func HandleClickHouseConnectionSettings ¶

func HandleClickHouseConnectionSettings(response *pc.DataSourceResponse, d *schema.ResourceData) error

func HandleHttpConnectionSettings ¶

func HandleHttpConnectionSettings(response *pc.DataSourceResponse, d *schema.ResourceData) error

func HandleKafkaConnectionSettings ¶

func HandleKafkaConnectionSettings(response *pc.DataSourceResponse, d *schema.ResourceData) error

func HandleS3ConnectionSettings ¶

func HandleS3ConnectionSettings(response *pc.DataSourceResponse, d *schema.ResourceData) error

func HandleSnowflakeConnectionSettings ¶

func HandleSnowflakeConnectionSettings(response *pc.DataSourceResponse, d *schema.ResourceData) error

func HandleWebhookConnectionSettings ¶

func HandleWebhookConnectionSettings(response *pc.DataSourceResponse, d *schema.ResourceData) error

func HttpDataSourceCreate ¶

func HttpDataSourceCreate(ctx context.Context, d *schema.ResourceData, c graphql.Client) (string, error)

func HttpDataSourceSchema ¶

func HttpDataSourceSchema() *schema.Schema

func HttpDataSourceUpdate ¶

func HttpDataSourceUpdate(ctx context.Context, d *schema.ResourceData, c graphql.Client) error

func KafkaDataSourceCreate ¶

func KafkaDataSourceCreate(ctx context.Context, d *schema.ResourceData, c graphql.Client) (string, error)

func KafkaDataSourceSchema ¶

func KafkaDataSourceSchema() *schema.Schema

func KafkaDataSourceUpdate ¶

func KafkaDataSourceUpdate(ctx context.Context, d *schema.ResourceData, c graphql.Client) error

func ParseTableSettings ¶

func ParseTableSettings(settingsData pc.TableSettingsData) map[string]any

func S3DataSourceCreate ¶

func S3DataSourceCreate(ctx context.Context, d *schema.ResourceData, c graphql.Client) (string, error)

func S3DataSourceSchema ¶

func S3DataSourceSchema() *schema.Schema

func S3DataSourceUpdate ¶

func S3DataSourceUpdate(ctx context.Context, d *schema.ResourceData, c graphql.Client) error

func SnowflakeDataSourceCreate ¶

func SnowflakeDataSourceCreate(ctx context.Context, d *schema.ResourceData, c graphql.Client) (string, error)

func SnowflakeDataSourceSchema ¶

func SnowflakeDataSourceSchema() *schema.Schema

func SnowflakeDataSourceUpdate ¶

func SnowflakeDataSourceUpdate(ctx context.Context, d *schema.ResourceData, c graphql.Client) error

func TableSettingsSchema ¶

func TableSettingsSchema() *schema.Schema

func WaitForAddColumnJobSucceeded ¶

func WaitForAddColumnJobSucceeded(ctx context.Context, client graphql.Client, id string, timeout time.Duration) error

func WaitForDataPoolDeletion ¶

func WaitForDataPoolDeletion(ctx context.Context, client graphql.Client, id string, timeout time.Duration) error

func WaitForDataPoolLive ¶

func WaitForDataPoolLive(ctx context.Context, client graphql.Client, id string, timeout time.Duration) error

func WebhookDataSourceCreate ¶

func WebhookDataSourceCreate(ctx context.Context, d *schema.ResourceData, c graphql.Client) (string, error)

func WebhookDataSourceDelete ¶

func WebhookDataSourceDelete(ctx context.Context, d *schema.ResourceData, c graphql.Client) error

func WebhookDataSourceSchema ¶

func WebhookDataSourceSchema() *schema.Schema

func WebhookDataSourceUpdate ¶

func WebhookDataSourceUpdate(ctx context.Context, d *schema.ResourceData, c graphql.Client) error

Types ¶

This section is empty.

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
utils

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL