schema

Documentation

Index

• Constants
• type SchemaConfig
  • func (c SchemaConfig) GetSchemas(sch string, local SchemaConfig, diag *diag.Diagnostics) []interface{}
  • func (c SchemaConfig) HasUpdates() bool
  • func (c *SchemaConfig) Override(local *SchemaConfig, sch string) error
  • func (c SchemaConfig) PrepareCreateRequest(svc *connectors.ConnectorSchemaConfigCreateService) *connectors.ConnectorSchemaConfigCreateService
  • func (c SchemaConfig) PrepareRequest(svc *connectors.ConnectorSchemaConfigUpdateService) *connectors.ConnectorSchemaConfigUpdateService
  • func (c *SchemaConfig) ReadFromRawSourceData(d []interface{}, sch string)
  • func (c *SchemaConfig) ReadFromResponse(response connectors.ConnectorSchemaDetailsResponse)
  • func (c SchemaConfig) ValidateSchemas(connectorId string, ...) (error, bool)

Constants

const (
	ID           = "id"
	CONNECTOR_ID = "connector_id"

	ALLOW_ALL     = "ALLOW_ALL"
	ALLOW_COLUMNS = "ALLOW_COLUMNS"
	BLOCK_ALL     = "BLOCK_ALL"
	SOFT_DELETE   = "SOFT_DELETE"
	HISTORY       = "HISTORY"
	LIVE          = "LIVE"

	SCHEMA_CHANGE_HANDLING = "schema_change_handling"
	SCHEMA                 = "schema"
	TABLE                  = "table"
	COLUMN                 = "column"
	NAME                   = "name"
	ENABLED                = "enabled"
	HASHED                 = "hashed"
	SYNC_MODE              = "sync_mode"

	HANDLED       = "handled"
	EXCLUDED      = "excluded"
	PATCH_ALLOWED = "patch_allowed"
)

Types

type SchemaConfig

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

func (SchemaConfig) GetSchemas

func (c SchemaConfig) GetSchemas(sch string, local SchemaConfig, diag *diag.Diagnostics) []interface{}

func (SchemaConfig) HasUpdates

func (c SchemaConfig) HasUpdates() bool

func (*SchemaConfig) Override

func (c *SchemaConfig) Override(local *SchemaConfig, sch string) error

func (SchemaConfig) PrepareCreateRequest

func (c SchemaConfig) PrepareCreateRequest(svc *connectors.ConnectorSchemaConfigCreateService) *connectors.ConnectorSchemaConfigCreateService

func (SchemaConfig) PrepareRequest

func (c SchemaConfig) PrepareRequest(svc *connectors.ConnectorSchemaConfigUpdateService) *connectors.ConnectorSchemaConfigUpdateService

func (*SchemaConfig) ReadFromRawSourceData

func (c *SchemaConfig) ReadFromRawSourceData(d []interface{}, sch string)

func (*SchemaConfig) ReadFromResponse

func (c *SchemaConfig) ReadFromResponse(response connectors.ConnectorSchemaDetailsResponse)

func (SchemaConfig) ValidateSchemas

func (c SchemaConfig) ValidateSchemas(
	connectorId string,
	schemas map[string]*connectors.ConnectorSchemaConfigSchemaResponse,
	client fivetran.Client,
	ctx context.Context,
	validateColumns bool) (error, bool)