Documentation
¶
Index ¶
- Constants
- Variables
- func Bool(b bool) *bool
- func DefaultConfig() *gosnowflake.Config
- func EnvConfig() *gosnowflake.Config
- func Float64(f float64) *float64
- func Int(i int) *int
- func IsValidDataType(v string) bool
- func MergeConfig(baseConfig *gosnowflake.Config, mergeConfig *gosnowflake.Config) *gosnowflake.Config
- func Pointer[K any](v K) *K
- func ProfileConfig(profile string) (*gosnowflake.Config, error)
- func String(s string) *string
- func Sweep(client *Client, prefix string) error
- func SweepAll(client *Client) error
- type Account
- type AccountAlterOptions
- type AccountCreateOptions
- type AccountDrop
- type AccountEdition
- type AccountIdentifier
- type AccountLevelParameters
- type AccountLevelParametersUnset
- type AccountObjectIdentifier
- type AccountParameter
- type AccountParameters
- type AccountParametersUnset
- type AccountRename
- type AccountSet
- type AccountShowOptions
- type AccountUnset
- type Accounts
- type AlterSessionOptions
- type BinaryInputFormat
- type Client
- type CloudType
- type Comments
- type ContextFunctions
- type DataType
- type Database
- type DatabaseAlterOptions
- type DatabaseCreateOptions
- type DatabaseDetails
- type DatabaseDropOptions
- type DatabaseShowOptions
- type Databases
- type ExternalObjectIdentifier
- type FailoverGroup
- type FailoverGroupAdd
- type FailoverGroupAlterSourceOptions
- type FailoverGroupAlterTargetOptions
- type FailoverGroupCreateOptions
- type FailoverGroupCreateSecondaryReplicationGroupOptions
- type FailoverGroupDropOptions
- type FailoverGroupMove
- type FailoverGroupRemove
- type FailoverGroupSecondaryState
- type FailoverGroupSet
- type FailoverGroupShowOptions
- type FailoverGroups
- type GeographyOutputFormat
- type Grant
- type GrantPrivilegeToShareOn
- type Grants
- type Identifier
- type In
- type IntProperty
- type IntegrationType
- type Like
- type LimitFrom
- type LogLevel
- type MaskingPolicies
- type MaskingPolicy
- type MaskingPolicyAlterOptions
- type MaskingPolicyCreateOptions
- type MaskingPolicyDetails
- type MaskingPolicyDropOptions
- type MaskingPolicySet
- type MaskingPolicyShowOptions
- type MaskingPolicyUnset
- type Object
- type ObjectIdentifier
- type ObjectParameter
- type ObjectParameters
- type ObjectParametersUnset
- type ObjectType
- type OnTable
- type OnView
- type Parameter
- type ParameterType
- type ParametersIn
- type PasswordPolicies
- type PasswordPolicy
- type PasswordPolicyAlterOptions
- type PasswordPolicyCreateOptions
- type PasswordPolicyDetails
- type PasswordPolicyDropOptions
- type PasswordPolicySet
- type PasswordPolicyShowOptions
- type PasswordPolicyUnset
- type PluralObjectType
- type Privilege
- type Region
- type ReplicationAccount
- type ReplicationFunctions
- type ResourceMonitor
- type ResourceMonitorAlterOptions
- type ResourceMonitorCreateOptions
- type ResourceMonitorShowOptions
- type ResourceMonitors
- type RevokePrivilegeFromShareOn
- type Role
- type RoleAlterOptions
- type RoleCreateOptions
- type RoleDropOptions
- type RoleShowOptions
- type Roles
- type ScalingPolicy
- type Schema
- type SchemaIdentifier
- type SchemaObjectIdentifier
- type SessionParameter
- type SessionParameters
- type SessionParametersUnset
- type SessionPolicies
- type SessionPolicy
- type SessionPolicyAlterOptions
- type SessionPolicyCreateOptions
- type SessionPolicyDetails
- type SessionPolicyDropOptions
- type SessionSet
- type SessionUnset
- type Sessions
- type SetColumnCommentOpts
- type SetCommentOpts
- type Share
- type ShareAdd
- type ShareAlterOptions
- type ShareCreateOptions
- type ShareDetails
- type ShareInfo
- type ShareKind
- type ShareRemove
- type ShareSet
- type ShareShowOptions
- type ShareUnset
- type Shares
- type ShowGrantsOf
- type ShowGrantsOn
- type ShowGrantsOptions
- type ShowGrantsTo
- type ShowParametersOptions
- type ShowRegionsOptions
- type StringProperty
- type SystemFunctions
- type TableColumnIdentifier
- type TableColumnSignature
- type Tag
- type TagAssociation
- type TagCreateOptions
- type TraceLevel
- type TransactionDefaultIsolationLevel
- type UnsupportedDDLAction
- type User
- type UserAlterOptions
- type UserCreateOptions
- type UserDetails
- type UserDropOptions
- type UserParameter
- type UserParameters
- type UserParametersUnset
- type UserShowOptions
- type Users
- type Warehouse
- type WarehouseAlterOptions
- type WarehouseCreateOptions
- type WarehouseDetails
- type WarehouseDropOptions
- type WarehouseSet
- type WarehouseShowOptions
- type WarehouseSize
- type WarehouseState
- type WarehouseType
- type WarehouseUnset
- type Warehouses
Constants ¶
const ( NoQuotes quoteModifier = "no_quotes" DoubleQuotes quoteModifier = "double_quotes" SingleQuotes quoteModifier = "single_quotes" )
const ( NoParentheses parenModifier = "no_parentheses" Parentheses parenModifier = "parentheses" )
const ( NoReverse reverseModifier = "no_reverse" Reverse reverseModifier = "reverse" )
const ( Equals equalsModifier = "equals" NoEquals equalsModifier = "no_equals" )
Variables ¶
Functions ¶
func DefaultConfig ¶
func DefaultConfig() *gosnowflake.Config
func EnvConfig ¶
func EnvConfig() *gosnowflake.Config
func IsValidDataType ¶
func MergeConfig ¶
func MergeConfig(baseConfig *gosnowflake.Config, mergeConfig *gosnowflake.Config) *gosnowflake.Config
func Pointer ¶ added in v0.65.0
func Pointer[K any](v K) *K
Pointer is a generic function that returns a pointer to a given value.
func ProfileConfig ¶
func ProfileConfig(profile string) (*gosnowflake.Config, error)
Types ¶
type Account ¶ added in v0.65.0
type Account struct {
OrganizationName string
AccountName string
RegionGroup string
SnowflakeRegion string
Edition AccountEdition
AccountURL string
CreatedOn time.Time
Comment string
AccountLocator string
AccountLocatorURL string
ManagedAccounts int
ConsumptionBillingEntityName string
MarketplaceConsumerBillingEntityName string
MarketplaceProviderBillingEntityName string
OldAccountURL string
IsOrgAdmin bool
}
func (*Account) AccountID ¶ added in v0.65.0
func (v *Account) AccountID() AccountIdentifier
func (*Account) ID ¶ added in v0.65.0
func (v *Account) ID() AccountObjectIdentifier
type AccountAlterOptions ¶ added in v0.65.0
type AccountAlterOptions struct {
Set *AccountSet `ddl:"keyword" db:"SET"`
Unset *AccountUnset `ddl:"list,no_parentheses" db:"UNSET"`
Rename *AccountRename `ddl:"-"`
Drop *AccountDrop `ddl:"-"`
// contains filtered or unexported fields
}
type AccountCreateOptions ¶ added in v0.65.0
type AccountCreateOptions struct {
// Object properties
AdminName string `ddl:"parameter,single_quotes" db:"ADMIN_NAME"`
AdminPassword *string `ddl:"parameter,single_quotes" db:"ADMIN_PASSWORD"`
AdminRSAPublicKey *string `ddl:"parameter,single_quotes" db:"ADMIN_RSA_PUBLIC_KEY"`
FirstName *string `ddl:"parameter,single_quotes" db:"FIRST_NAME"`
LastName *string `ddl:"parameter,single_quotes" db:"LAST_NAME"`
Email string `ddl:"parameter,single_quotes" db:"EMAIL"`
MustChangePassword *bool `ddl:"parameter" db:"MUST_CHANGE_PASSWORD"`
Edition AccountEdition `ddl:"parameter" db:"EDITION"`
RegionGroup *string `ddl:"parameter,single_quotes" db:"REGION_GROUP"`
Region *string `ddl:"parameter,single_quotes" db:"REGION"`
Comment *string `ddl:"parameter,single_quotes" db:"COMMENT"`
// contains filtered or unexported fields
}
type AccountDrop ¶ added in v0.65.0
type AccountDrop struct {
Name AccountObjectIdentifier `ddl:"identifier"`
OldURL *bool `ddl:"keyword" db:"DROP OLD URL"`
}
type AccountEdition ¶ added in v0.65.0
type AccountEdition string
var ( EditionStandard AccountEdition = "STANDARD" EditionEnterprise AccountEdition = "ENTERPRISE" EditionBusinessCritical AccountEdition = "BUSINESS_CRITICAL" )
type AccountIdentifier ¶ added in v0.65.0
type AccountIdentifier struct {
// contains filtered or unexported fields
}
func NewAccountIdentifier ¶ added in v0.65.0
func NewAccountIdentifier(organizationName, accountName string) AccountIdentifier
func NewAccountIdentifierFromAccountLocator ¶ added in v0.65.0
func NewAccountIdentifierFromAccountLocator(accountLocator string) AccountIdentifier
func (AccountIdentifier) Name ¶ added in v0.65.0
func (i AccountIdentifier) Name() string
type AccountLevelParameters ¶ added in v0.65.0
type AccountLevelParameters struct {
AccountParameters *AccountParameters `ddl:"list,no_parentheses"`
SessionParameters *SessionParameters `ddl:"list,no_parentheses"`
ObjectParameters *ObjectParameters `ddl:"list,no_parentheses"`
UserParameters *UserParameters `ddl:"list,no_parentheses"`
}
type AccountLevelParametersUnset ¶ added in v0.65.0
type AccountLevelParametersUnset struct {
AccountParameters *AccountParametersUnset `ddl:"list,no_parentheses"`
SessionParameters *SessionParametersUnset `ddl:"list,no_parentheses"`
ObjectParameters *ObjectParametersUnset `ddl:"list,no_parentheses"`
UserParameters *UserParametersUnset `ddl:"list,no_parentheses"`
}
type AccountObjectIdentifier ¶
type AccountObjectIdentifier struct {
// contains filtered or unexported fields
}
func NewAccountObjectIdentifier ¶
func NewAccountObjectIdentifier(name string) AccountObjectIdentifier
func (AccountObjectIdentifier) FullyQualifiedName ¶
func (i AccountObjectIdentifier) FullyQualifiedName() string
func (AccountObjectIdentifier) Name ¶
func (i AccountObjectIdentifier) Name() string
type AccountParameter ¶ added in v0.65.0
type AccountParameter string
const ( // Account Parameters AccountParameterAllowClientMFACaching AccountParameter = "ALLOW_CLIENT_MFA_CACHING" AccountParameterAllowIDToken AccountParameter = "ALLOW_ID_TOKEN" // #nosec G101 AccountParameterClientEncryptionKeySize AccountParameter = "CLIENT_ENCRYPTION_KEY_SIZE" AccountParameterEnableInternalStagesPrivatelink AccountParameter = "ENABLE_INTERNAL_STAGES_PRIVATELINK" AccountParameterEventTable AccountParameter = "EVENT_TABLE" AccountParameterExternalOAuthAddPrivilegedRolesToBlockedList AccountParameter = "EXTERNAL_OAUTH_ADD_PRIVILEGED_ROLES_TO_BLOCKED_LIST" AccountParameterInitialReplicationSizeLimitInTB AccountParameter = "INITIAL_REPLICATION_SIZE_LIMIT_IN_TB" AccountParameterMinDataRetentionTimeInDays AccountParameter = "MIN_DATA_RETENTION_TIME_IN_DAYS" AccountParameterNetworkPolicy AccountParameter = "NETWORK_POLICY" AccountParameterPeriodicDataRekeying AccountParameter = "PERIODIC_DATA_REKEYING" AccountParameterPreventUnloadToInlineURL AccountParameter = "PREVENT_UNLOAD_TO_INLINE_URL" AccountParameterPreventUnloadToInternalStages AccountParameter = "PREVENT_UNLOAD_TO_INTERNAL_STAGES" AccountParameterRequireStorageIntegrationForStageCreation AccountParameter = "REQUIRE_STORAGE_INTEGRATION_FOR_STAGE_CREATION" AccountParameterRequireStorageIntegrationForStageOperation AccountParameter = "REQUIRE_STORAGE_INTEGRATION_FOR_STAGE_OPERATION" AccountParameterSSOLoginPage AccountParameter = "SSO_LOGIN_PAGE" // Session Parameters (inherited) AccountParameterAbortDetachedQuery AccountParameter = "ABORT_DETACHED_QUERY" AccountParameterAutocommit AccountParameter = "AUTOCOMMIT" AccountParameterBinaryInputFormat AccountParameter = "BINARY_INPUT_FORMAT" AccountParameterBinaryOutputFormat AccountParameter = "BINARY_OUTPUT_FORMAT" AccountParameterDateInputFormat AccountParameter = "DATE_INPUT_FORMAT" AccountParameterDateOutputFormat AccountParameter = "DATE_OUTPUT_FORMAT" AccountParameterErrorOnNondeterministicMerge AccountParameter = "ERROR_ON_NONDETERMINISTIC_MERGE" AccountParameterErrorOnNondeterministicUpdate AccountParameter = "ERROR_ON_NONDETERMINISTIC_UPDATE" AccountParameterGeographyOutputFormat AccountParameter = "GEOGRAPHY_OUTPUT_FORMAT" AccountParameterJSONIndent AccountParameter = "JSON_INDENT" AccountParameterLockTimeout AccountParameter = "LOCK_TIMEOUT" AccountParameterQueryTag AccountParameter = "QUERY_TAG" AccountParameterRowsPerResultset AccountParameter = "ROWS_PER_RESULTSET" AccountParameterSimulatedDataSharingConsumer AccountParameter = "SIMULATED_DATA_SHARING_CONSUMER" AccountParameterStatementTimeoutInSeconds AccountParameter = "STATEMENT_TIMEOUT_IN_SECONDS" AccountParameterStrictJSONOutput AccountParameter = "STRICT_JSON_OUTPUT" AccountParameterTimestampDayIsAlways24h AccountParameter = "TIMESTAMP_DAY_IS_ALWAYS_24H" AccountParameterTimestampInputFormat AccountParameter = "TIMESTAMP_INPUT_FORMAT" AccountParameterTimestampLTZOutputFormat AccountParameter = "TIMESTAMP_LTZ_OUTPUT_FORMAT" AccountParameterTimestampNTZOutputFormat AccountParameter = "TIMESTAMP_NTZ_OUTPUT_FORMAT" AccountParameterTimestampOutputFormat AccountParameter = "TIMESTAMP_OUTPUT_FORMAT" AccountParameterTimestampTypeMapping AccountParameter = "TIMESTAMP_TYPE_MAPPING" AccountParameterTimestampTZOutputFormat AccountParameter = "TIMESTAMP_TZ_OUTPUT_FORMAT" AccountParameterTimezone AccountParameter = "TIMEZONE" AccountParameterTimeInputFormat AccountParameter = "TIME_INPUT_FORMAT" AccountParameterTimeOutputFormat AccountParameter = "TIME_OUTPUT_FORMAT" AccountParameterTransactionDefaultIsolationLevel AccountParameter = "TRANSACTION_DEFAULT_ISOLATION_LEVEL" AccountParameterTwoDigitCenturyStart AccountParameter = "TWO_DIGIT_CENTURY_START" AccountParameterUnsupportedDDLAction AccountParameter = "UNSUPPORTED_DDL_ACTION" AccountParameterUseCachedResult AccountParameter = "USE_CACHED_RESULT" AccountParameterWeekOfYearPolicy AccountParameter = "WEEK_OF_YEAR_POLICY" AccountParameterWeekStart AccountParameter = "WEEK_START" // Object Parameters (inherited) AccountParameterDataRetentionTimeInDays AccountParameter = "DATA_RETENTION_TIME_IN_DAYS" AccountParameterDefaultDDLCollation AccountParameter = "DEFAULT_DDL_COLLATION" AccountParameterLogLevel AccountParameter = "LOG_LEVEL" AccountParameterMaxConcurrencyLevel AccountParameter = "MAX_CONCURRENCY_LEVEL" AccountParameterMaxDataExtensionTimeInDays AccountParameter = "MAX_DATA_EXTENSION_TIME_IN_DAYS" AccountParameterPipeExecutionPaused AccountParameter = "PIPE_EXECUTION_PAUSED" AccountParameterStatementQueuedTimeoutInSeconds AccountParameter = "STATEMENT_QUEUED_TIMEOUT_IN_SECONDS" AccountParameterSuspendTaskAfterNumFailures AccountParameter = "SUSPEND_TASK_AFTER_NUM_FAILURES" AccountParameterTraceLevel AccountParameter = "TRACE_LEVEL" AccountParameterUserTaskManagedInitialWarehouseSize AccountParameter = "USER_TASK_MANAGED_INITIAL_WAREHOUSE_SIZE" AccountParameterUserTaskTimeoutMs AccountParameter = "USER_TASK_TIMEOUT_MS" // User Parameters (inherited) AccountParameterEnableUnredactedQuerySyntaxError AccountParameter = "ENABLE_UNREDACTED_QUERY_SYNTAX_ERROR" )
There is a hierarchical relationship between the different parameter types. Account parameters can set any of account, user, session or object parameters https://docs.snowflake.com/en/sql-reference/parameters#parameter-hierarchy-and-types Account Parameters include Session Parameters, Object Parameters and User Parameters
type AccountParameters ¶ added in v0.65.0
type AccountParameters struct {
// Account Parameters
AllowClientMFACaching *bool `ddl:"parameter" db:"ALLOW_CLIENT_MFA_CACHING"`
AllowIDToken *bool `ddl:"parameter" db:"ALLOW_ID_TOKEN"`
ClientEncryptionKeySize *int `ddl:"parameter" db:"CLIENT_ENCRYPTION_KEY_SIZE"`
EnableInternalStagesPrivatelink *bool `ddl:"parameter" db:"ENABLE_INTERNAL_STAGES_PRIVATELINK"`
EventTable *string `ddl:"parameter,single_quotes" db:"EVENT_TABLE"`
ExternalOAuthAddPrivilegedRolesToBlockedList *bool `ddl:"parameter" db:"EXTERNAL_OAUTH_ADD_PRIVILEGED_ROLES_TO_BLOCKED_LIST"`
InitialReplicationSizeLimitInTB *float64 `ddl:"parameter" db:"INITIAL_REPLICATION_SIZE_LIMIT_IN_TB"`
MinDataRetentionTimeInDays *int `ddl:"parameter" db:"MIN_DATA_RETENTION_TIME_IN_DAYS"`
NetworkPolicy *string `ddl:"parameter,single_quotes" db:"NETWORK_POLICY"`
PeriodicDataRekeying *bool `ddl:"parameter" db:"PERIODIC_DATA_REKEYING"`
PreventUnloadToInlineURL *bool `ddl:"parameter" db:"PREVENT_UNLOAD_TO_INLINE_URL"`
PreventUnloadToInternalStages *bool `ddl:"parameter" db:"PREVENT_UNLOAD_TO_INTERNAL_STAGES"`
RequireStorageIntegrationForStageCreation *bool `ddl:"parameter" db:"REQUIRE_STORAGE_INTEGRATION_FOR_STAGE_CREATION"`
RequireStorageIntegrationForStageOperation *bool `ddl:"parameter" db:"REQUIRE_STORAGE_INTEGRATION_FOR_STAGE_OPERATION"`
SSOLoginPage *bool `ddl:"parameter" db:"SSO_LOGIN_PAGE"`
}
type AccountParametersUnset ¶ added in v0.65.0
type AccountParametersUnset struct {
AllowClientMFACaching *bool `ddl:"keyword" db:"ALLOW_CLIENT_MFA_CACHING"`
AllowIDToken *bool `ddl:"keyword" db:"ALLOW_ID_TOKEN"`
ClientEncryptionKeySize *bool `ddl:"keyword" db:"CLIENT_ENCRYPTION_KEY_SIZE"`
EnableInternalStagesPrivatelink *bool `ddl:"keyword" db:"ENABLE_INTERNAL_STAGES_PRIVATELINK"`
EventTable *bool `ddl:"keyword" db:"EVENT_TABLE"`
ExternalOAuthAddPrivilegedRolesToBlockedList *bool `ddl:"keyword" db:"EXTERNAL_OAUTH_ADD_PRIVILEGED_ROLES_TO_BLOCKED_LIST"`
InitialReplicationSizeLimitInTB *bool `ddl:"keyword" db:"INITIAL_REPLICATION_SIZE_LIMIT_IN_TB"`
MinDataRetentionTimeInDays *bool `ddl:"keyword" db:"MIN_DATA_RETENTION_TIME_IN_DAYS"`
NetworkPolicy *bool `ddl:"keyword,single_quotes" db:"NETWORK_POLICY"`
PeriodicDataRekeying *bool `ddl:"keyword" db:"PERIODIC_DATA_REKEYING"`
PreventUnloadToInlineURL *bool `ddl:"keyword" db:"PREVENT_UNLOAD_TO_INLINE_URL"`
PreventUnloadToInternalStages *bool `ddl:"keyword" db:"PREVENT_UNLOAD_TO_INTERNAL_STAGES"`
RequireStorageIntegrationForStageCreation *bool `ddl:"keyword" db:"REQUIRE_STORAGE_INTEGRATION_FOR_STAGE_CREATION"`
RequireStorageIntegrationForStageOperation *bool `ddl:"keyword" db:"REQUIRE_STORAGE_INTEGRATION_FOR_STAGE_OPERATION"`
SSOLoginPage *bool `ddl:"keyword" db:"SSO_LOGIN_PAGE"`
}
type AccountRename ¶ added in v0.65.0
type AccountRename struct {
Name AccountObjectIdentifier `ddl:"identifier"`
NewName AccountObjectIdentifier `ddl:"identifier" db:"RENAME TO"`
SaveOldURL *bool `ddl:"parameter" db:"SAVE_OLD_URL"`
}
type AccountSet ¶ added in v0.65.0
type AccountSet struct {
Parameters *AccountLevelParameters `ddl:"list,no_parentheses"`
ResourceMonitor AccountObjectIdentifier `ddl:"identifier,equals" db:"RESOURCE_MONITOR"`
PasswordPolicy SchemaObjectIdentifier `ddl:"identifier" db:"PASSWORD POLICY"`
SessionPolicy SchemaObjectIdentifier `ddl:"identifier" db:"SESSION POLICY"`
Tag []TagAssociation `ddl:"keyword" db:"TAG"`
}
type AccountShowOptions ¶ added in v0.65.0
type AccountShowOptions struct {
Like *Like `ddl:"keyword" db:"LIKE"`
// contains filtered or unexported fields
}
type AccountUnset ¶ added in v0.65.0
type AccountUnset struct {
Parameters *AccountLevelParametersUnset `ddl:"list,no_parentheses"`
PasswordPolicy *bool `ddl:"keyword" db:"PASSWORD POLICY"`
SessionPolicy *bool `ddl:"keyword" db:"SESSION POLICY"`
Tag []ObjectIdentifier `ddl:"keyword" db:"TAG"`
}
type Accounts ¶ added in v0.65.0
type Accounts interface {
// Create creates an account.
Create(ctx context.Context, id AccountObjectIdentifier, opts *AccountCreateOptions) error
// Alter modifies an existing account
Alter(ctx context.Context, opts *AccountAlterOptions) error
// Show returns a list of accounts.
Show(ctx context.Context, opts *AccountShowOptions) ([]*Account, error)
// ShowByID returns an account by id
ShowByID(ctx context.Context, id AccountObjectIdentifier) (*Account, error)
}
type AlterSessionOptions ¶ added in v0.65.0
type AlterSessionOptions struct {
Set *SessionSet `ddl:"keyword" db:"SET"`
Unset *SessionUnset `ddl:"keyword" db:"UNSET"`
// contains filtered or unexported fields
}
type BinaryInputFormat ¶ added in v0.65.0
type BinaryInputFormat string
const ( BinaryInputFormatHex BinaryInputFormat = "HEX" BinaryInputFormatBase64 BinaryInputFormat = "BASE64" BinaryInputFormatUTF8 BinaryInputFormat = "UTF8" )
type Client ¶
type Client struct {
Accounts Accounts
Comments Comments
ContextFunctions ContextFunctions
Databases Databases
FailoverGroups FailoverGroups
Grants Grants
MaskingPolicies MaskingPolicies
PasswordPolicies PasswordPolicies
ReplicationFunctions ReplicationFunctions
ResourceMonitors ResourceMonitors
Roles Roles
SessionPolicies SessionPolicies
Sessions Sessions
SystemFunctions SystemFunctions
Warehouses Warehouses
// contains filtered or unexported fields
}
func NewClientFromDB ¶
func NewDefaultClient ¶
type Comments ¶ added in v0.65.0
type Comments interface {
Set(ctx context.Context, opts *SetCommentOpts) error
SetColumn(ctx context.Context, opts *SetColumnCommentOpts) error
}
type ContextFunctions ¶
type ContextFunctions interface {
// Session functions.
CurrentAccount(ctx context.Context) (string, error)
CurrentRole(ctx context.Context) (string, error)
CurrentRegion(ctx context.Context) (string, error)
CurrentSession(ctx context.Context) (string, error)
CurrentUser(ctx context.Context) (string, error)
// Session Object functions.
CurrentDatabase(ctx context.Context) (string, error)
CurrentSchema(ctx context.Context) (string, error)
CurrentWarehouse(ctx context.Context) (string, error)
IsRoleInSession(ctx context.Context, role AccountObjectIdentifier) (bool, error)
}
type DataType ¶
type DataType string
const ( DataTypeNumber DataType = "NUMBER" DataTypeFloat DataType = "FLOAT" DataTypeVARCHAR DataType = "VARCHAR" DataTypeBinary DataType = "BINARY" DataTypeBoolean DataType = "BOOLEAN" DataTypeDate DataType = "DATE" DataTypeTime DataType = "TIME" DataTypeTimestampLTZ DataType = "TIMESTAMP_LTZ" DataTypeTimestampNTZ DataType = "TIMESTAMP_NTZ" DataTypeTimestampTZ DataType = "TIMESTAMP_TZ" DataTypeVariant DataType = "VARIANT" DataTypeObject DataType = "OBJECT" DataTypeArray DataType = "ARRAY" DataTypeGeography DataType = "GEOGRAPHY" DataTypeGeometry DataType = "GEOMETRY" // DataTypeUnknown is used for testing purposes only. DataTypeUnknown DataType = "UNKNOWN" )
func DataTypeFromString ¶
type Database ¶
type Database struct {
Name string
}
func (*Database) ID ¶
func (v *Database) ID() AccountObjectIdentifier
func (*Database) ObjectType ¶ added in v0.65.0
func (v *Database) ObjectType() ObjectType
type DatabaseAlterOptions ¶ added in v0.65.0
type DatabaseAlterOptions struct{}
placeholder for the real implementation.
type DatabaseCreateOptions ¶
type DatabaseCreateOptions struct{}
placeholder for the real implementation.
type DatabaseDetails ¶ added in v0.65.0
type DatabaseDetails struct {
Name string
}
type DatabaseDropOptions ¶ added in v0.65.0
type DatabaseDropOptions struct {
IfExists *bool `ddl:"keyword" db:"IF EXISTS"`
// contains filtered or unexported fields
}
placeholder for the real implementation.
type DatabaseShowOptions ¶ added in v0.65.0
type DatabaseShowOptions struct{}
placeholder for the real implementation.
type Databases ¶ added in v0.65.0
type Databases interface {
// Create creates a database.
Create(ctx context.Context, id AccountObjectIdentifier, opts *DatabaseCreateOptions) error
// Alter modifies an existing database
Alter(ctx context.Context, id AccountObjectIdentifier, opts *DatabaseAlterOptions) error
// Drop removes a database.
Drop(ctx context.Context, id AccountObjectIdentifier, opts *DatabaseDropOptions) error
// Show returns a list of databases.
Show(ctx context.Context, opts *DatabaseShowOptions) ([]*Database, error)
// ShowByID returns a database by ID
ShowByID(ctx context.Context, id AccountObjectIdentifier) (*Database, error)
// Describe returns the details of a database.
Describe(ctx context.Context, id AccountObjectIdentifier) (*DatabaseDetails, error)
}
type ExternalObjectIdentifier ¶ added in v0.65.0
type ExternalObjectIdentifier struct {
// contains filtered or unexported fields
}
for objects that live in other accounts
func NewExternalObjectIdentifier ¶ added in v0.65.0
func NewExternalObjectIdentifier(accountIdentifier AccountIdentifier, objectIdentifier ObjectIdentifier) ExternalObjectIdentifier
func NewExternalObjectIdentifierFromFullyQualifiedName ¶ added in v0.65.0
func NewExternalObjectIdentifierFromFullyQualifiedName(fullyQualifiedName string) ExternalObjectIdentifier
func (ExternalObjectIdentifier) FullyQualifiedName ¶ added in v0.65.0
func (i ExternalObjectIdentifier) FullyQualifiedName() string
func (ExternalObjectIdentifier) Name ¶ added in v0.65.0
func (i ExternalObjectIdentifier) Name() string
type FailoverGroup ¶ added in v0.65.0
type FailoverGroup struct {
RegionGroup string
SnowflakeRegion string
CreatedOn time.Time
AccountName string
Name string
Type string
Comment string
IsPrimary bool
Primary ExternalObjectIdentifier
ObjectTypes []PluralObjectType
AllowedIntegrationTypes []IntegrationType
AllowedAccounts []AccountIdentifier
OrganizationName string
AccountLocator string
ReplicationSchedule string
SecondaryState FailoverGroupSecondaryState
NextScheduledRefresh string
Owner string
}
FailoverGroups is a user friendly result for a CREATE FAILOVER GROUP query.
func (*FailoverGroup) ExternalID ¶ added in v0.65.0
func (v *FailoverGroup) ExternalID() ExternalObjectIdentifier
func (*FailoverGroup) ID ¶ added in v0.65.0
func (v *FailoverGroup) ID() AccountObjectIdentifier
func (*FailoverGroup) ObjectType ¶ added in v0.65.0
func (v *FailoverGroup) ObjectType() ObjectType
type FailoverGroupAdd ¶ added in v0.65.0
type FailoverGroupAdd struct {
AllowedDatabases []AccountObjectIdentifier `ddl:"parameter,reverse" db:"TO ALLOWED_DATABASES"`
AllowedAccounts []AccountIdentifier `ddl:"parameter,reverse" db:"TO ALLOWED_ACCOUNTS"`
IgnoreEditionCheck *bool `ddl:"keyword" db:"IGNORE_EDITION_CHECK"`
}
type FailoverGroupAlterSourceOptions ¶ added in v0.65.0
type FailoverGroupAlterSourceOptions struct {
IfExists *bool `ddl:"keyword" db:"IF EXISTS"`
NewName AccountObjectIdentifier `ddl:"identifier" db:"RENAME TO"`
Set *FailoverGroupSet `ddl:"keyword" db:"SET"`
Add *FailoverGroupAdd `ddl:"keyword" db:"ADD"`
Move *FailoverGroupMove `ddl:"keyword" db:"MOVE"`
Remove *FailoverGroupRemove `ddl:"keyword" db:"REMOVE"`
// contains filtered or unexported fields
}
type FailoverGroupAlterTargetOptions ¶ added in v0.65.0
type FailoverGroupAlterTargetOptions struct {
IfExists *bool `ddl:"keyword" db:"IF EXISTS"`
Refresh *bool `ddl:"keyword" db:"REFRESH"`
Primary *bool `ddl:"keyword" db:"PRIMARY"`
Suspend *bool `ddl:"keyword" db:"SUSPEND"`
Resume *bool `ddl:"keyword" db:"RESUME"`
// contains filtered or unexported fields
}
type FailoverGroupCreateOptions ¶ added in v0.65.0
type FailoverGroupCreateOptions struct {
IfNotExists *bool `ddl:"keyword" db:"IF NOT EXISTS"`
AllowedDatabases []AccountObjectIdentifier `ddl:"parameter" db:"ALLOWED_DATABASES"`
AllowedIntegrationTypes []IntegrationType `ddl:"parameter" db:"ALLOWED_INTEGRATION_TYPES"`
IgnoreEditionCheck *bool `ddl:"keyword" db:"IGNORE EDITION CHECK"`
ReplicationSchedule *string `ddl:"parameter,single_quotes" db:"REPLICATION_SCHEDULE"`
// contains filtered or unexported fields
}
type FailoverGroupCreateSecondaryReplicationGroupOptions ¶ added in v0.65.0
type FailoverGroupCreateSecondaryReplicationGroupOptions struct {
IfNotExists *bool `ddl:"keyword" db:"IF NOT EXISTS"`
// contains filtered or unexported fields
}
type FailoverGroupDropOptions ¶ added in v0.65.0
type FailoverGroupDropOptions struct {
IfExists *bool `ddl:"keyword" db:"IF EXISTS"`
// contains filtered or unexported fields
}
type FailoverGroupMove ¶ added in v0.65.0
type FailoverGroupMove struct {
Databases []AccountObjectIdentifier `ddl:"parameter,no_equals" db:"DATABASES"`
To AccountObjectIdentifier `ddl:"identifier" db:"TO FAILOVER GROUP"`
}
type FailoverGroupRemove ¶ added in v0.65.0
type FailoverGroupRemove struct {
AllowedDatabases []AccountObjectIdentifier `ddl:"parameter,reverse" db:"FROM ALLOWED_DATABASES"`
AllowedAccounts []AccountIdentifier `ddl:"parameter,reverse" db:"FROM ALLOWED_ACCOUNTS"`
}
type FailoverGroupSecondaryState ¶ added in v0.65.0
type FailoverGroupSecondaryState string
const ( FailoverGroupSecondaryStateSuspended FailoverGroupSecondaryState = "SUSPENDED" FailoverGroupSecondaryStateStarted FailoverGroupSecondaryState = "STARTED" FailoverGroupSecondaryStateNull FailoverGroupSecondaryState = "NULL" )
type FailoverGroupSet ¶ added in v0.65.0
type FailoverGroupSet struct {
ObjectTypes []PluralObjectType `ddl:"parameter" db:"OBJECT_TYPES"`
ReplicationSchedule *string `ddl:"parameter,single_quotes" db:"REPLICATION_SCHEDULE"`
AllowedIntegrationTypes []IntegrationType `ddl:"parameter" db:"ALLOWED_INTEGRATION_TYPES"`
}
type FailoverGroupShowOptions ¶ added in v0.65.0
type FailoverGroupShowOptions struct {
InAccount AccountIdentifier `ddl:"identifier" db:"IN ACCOUNT"`
// contains filtered or unexported fields
}
FailoverGroupShowOptions represents the options for listing failover groups.
type FailoverGroups ¶ added in v0.65.0
type FailoverGroups interface {
// Create creates a new failover group.
Create(ctx context.Context, id AccountObjectIdentifier, objectTypes []PluralObjectType, allowedAccounts []AccountIdentifier, opts *FailoverGroupCreateOptions) error
// CreateSecondaryReplicationGroup creates a new secondary replication group.
CreateSecondaryReplicationGroup(ctx context.Context, id AccountObjectIdentifier, primaryFailoverGroupID ExternalObjectIdentifier, opts *FailoverGroupCreateSecondaryReplicationGroupOptions) error
// Alter modifies an existing failover group in a source acount.
AlterSource(ctx context.Context, id AccountObjectIdentifier, opts *FailoverGroupAlterSourceOptions) error
// AlterTarget modifies an existing failover group in a target acount.
AlterTarget(ctx context.Context, id AccountObjectIdentifier, opts *FailoverGroupAlterTargetOptions) error
// Drop removes a failover group.
Drop(ctx context.Context, id AccountObjectIdentifier, opts *FailoverGroupDropOptions) error
// Show returns a list of failover groups.
Show(ctx context.Context, opts *FailoverGroupShowOptions) ([]*FailoverGroup, error)
// ShowByID returns a failover group by ID
ShowByID(ctx context.Context, id AccountObjectIdentifier) (*FailoverGroup, error)
// ShowDatabases returns a list of databases in a failover group.
ShowDatabases(ctx context.Context, id AccountObjectIdentifier) ([]AccountObjectIdentifier, error)
ShowShares(ctx context.Context, id AccountObjectIdentifier) ([]AccountObjectIdentifier, error)
}
FailoverGroups describes all the failover group related methods that the Snowflake API supports.
type GeographyOutputFormat ¶ added in v0.65.0
type GeographyOutputFormat string
const ( GeographyOutputFormatGeoJSON GeographyOutputFormat = "GeoJSON" GeographyOutputFormatWKT GeographyOutputFormat = "WKT" GeographyOutputFormatWKB GeographyOutputFormat = "WKB" GeographyOutputFormatEWKT GeographyOutputFormat = "EWKT" )
type Grant ¶ added in v0.65.0
type Grant struct {
CreatedOn time.Time
Privilege Privilege
GrantedOn ObjectType
Name ObjectIdentifier
GrantedTo ObjectType
GranteeName AccountObjectIdentifier
GrantOption bool
GrantedBy AccountObjectIdentifier
}
func (*Grant) ID ¶ added in v0.65.0
func (v *Grant) ID() ObjectIdentifier
type GrantPrivilegeToShareOn ¶ added in v0.65.0
type GrantPrivilegeToShareOn struct {
}
type Grants ¶ added in v0.65.0
type Grants interface {
Show(ctx context.Context, opts *ShowGrantsOptions) ([]*Grant, error)
}
type Identifier ¶ added in v0.65.0
type Identifier interface {
Name() string
}
type In ¶
type In struct {
Account *bool `ddl:"keyword" db:"ACCOUNT"`
Database AccountObjectIdentifier `ddl:"identifier" db:"DATABASE"`
Schema SchemaIdentifier `ddl:"identifier" db:"SCHEMA"`
}
type IntProperty ¶
type IntegrationType ¶ added in v0.65.0
type IntegrationType string
IntegrationType is the type of integration.
const ( IntegrationTypeSecurityIntegrations IntegrationType = "SECURITY INTEGRATIONS" IntegrationTypeAPIIntegrations IntegrationType = "API INTEGRATIONS" IntegrationTypeNotificationIntegrations IntegrationType = "NOTIFICATION INTEGRATIONS" )
type MaskingPolicies ¶
type MaskingPolicies interface {
// Create creates a new masking policy.
Create(ctx context.Context, id SchemaObjectIdentifier, signature []TableColumnSignature, returns DataType, expression string, opts *MaskingPolicyCreateOptions) error
// Alter modifies an existing masking policy.
Alter(ctx context.Context, id SchemaObjectIdentifier, opts *MaskingPolicyAlterOptions) error
// Drop removes a masking policy.
Drop(ctx context.Context, id SchemaObjectIdentifier) error
// Show returns a list of masking policies.
Show(ctx context.Context, opts *MaskingPolicyShowOptions) ([]*MaskingPolicy, error)
// ShowByID returns a masking policy by ID
ShowByID(ctx context.Context, id SchemaObjectIdentifier) (*MaskingPolicy, error)
// Describe returns the details of a masking policy.
Describe(ctx context.Context, id SchemaObjectIdentifier) (*MaskingPolicyDetails, error)
}
MaskingPolicies describes all the masking policy related methods that the Snowflake API supports.
type MaskingPolicy ¶
type MaskingPolicy struct {
CreatedOn time.Time
Name string
DatabaseName string
SchemaName string
Kind string
Owner string
Comment string
ExemptOtherPolicies bool
}
MaskingPolicys is a user friendly result for a CREATE MASKING POLICY query.
func (*MaskingPolicy) ID ¶
func (v *MaskingPolicy) ID() SchemaObjectIdentifier
func (*MaskingPolicy) ObjectType ¶ added in v0.65.0
func (v *MaskingPolicy) ObjectType() ObjectType
type MaskingPolicyAlterOptions ¶
type MaskingPolicyAlterOptions struct {
IfExists *bool `ddl:"keyword" db:"IF EXISTS"`
NewName SchemaObjectIdentifier `ddl:"identifier" db:"RENAME TO"`
Set *MaskingPolicySet `ddl:"keyword" db:"SET"`
Unset *MaskingPolicyUnset `ddl:"keyword" db:"UNSET"`
// contains filtered or unexported fields
}
type MaskingPolicyCreateOptions ¶
type MaskingPolicyCreateOptions struct {
OrReplace *bool `ddl:"keyword" db:"OR REPLACE"`
IfNotExists *bool `ddl:"keyword" db:"IF NOT EXISTS"`
// optional
Comment *string `ddl:"parameter,single_quotes" db:"COMMENT"`
ExemptOtherPolicies *bool `ddl:"parameter" db:"EXEMPT_OTHER_POLICIES"`
// contains filtered or unexported fields
}
type MaskingPolicyDetails ¶
type MaskingPolicyDetails struct {
Name string
Signature []TableColumnSignature
ReturnType DataType
Body string
}
type MaskingPolicyDropOptions ¶
type MaskingPolicyDropOptions struct {
// contains filtered or unexported fields
}
type MaskingPolicySet ¶
type MaskingPolicySet struct {
Body *string `ddl:"parameter,no_equals" db:"BODY ->"`
Tag []TagAssociation `ddl:"keyword" db:"TAG"`
Comment *string `ddl:"parameter,single_quotes" db:"COMMENT"`
}
type MaskingPolicyShowOptions ¶
type MaskingPolicyShowOptions struct {
Like *Like `ddl:"keyword" db:"LIKE"`
In *In `ddl:"keyword" db:"IN"`
Limit *int `ddl:"parameter,no_equals" db:"LIMIT"`
// contains filtered or unexported fields
}
MaskingPolicyShowOptions represents the options for listing masking policies.
type MaskingPolicyUnset ¶
type MaskingPolicyUnset struct {
Tag []ObjectIdentifier `ddl:"keyword" db:"TAG"`
Comment *bool `ddl:"keyword" db:"COMMENT"`
}
type Object ¶ added in v0.65.0
type Object struct {
ObjectType ObjectType `ddl:"keyword"`
Name ObjectIdentifier `ddl:"identifier"`
}
Object bundles together the object type and name. Its used for DDL statements.
type ObjectIdentifier ¶
type ObjectIdentifier interface {
Identifier
FullyQualifiedName() string
}
func NewObjectIdentifierFromFullyQualifiedName ¶ added in v0.65.0
func NewObjectIdentifierFromFullyQualifiedName(fullyQualifiedName string) ObjectIdentifier
type ObjectParameter ¶ added in v0.65.0
type ObjectParameter string
const ( // Object Parameters ObjectParameterDataRetentionTimeInDays ObjectParameter = "DATA_RETENTION_TIME_IN_DAYS" ObjectParameterDefaultDDLCollation ObjectParameter = "DEFAULT_DDL_COLLATION" ObjectParameterLogLevel ObjectParameter = "LOG_LEVEL" ObjectParameterMaxConcurrencyLevel ObjectParameter = "MAX_CONCURRENCY_LEVEL" ObjectParameterMaxDataExtensionTimeInDays ObjectParameter = "MAX_DATA_EXTENSION_TIME_IN_DAYS" ObjectParameterPipeExecutionPaused ObjectParameter = "PIPE_EXECUTION_PAUSED" ObjectParameterPreventUnloadToInternalStages ObjectParameter = "PREVENT_UNLOAD_TO_INTERNAL_STAGES" // also an account param ObjectParameterStatementQueuedTimeoutInSeconds ObjectParameter = "STATEMENT_QUEUED_TIMEOUT_IN_SECONDS" ObjectParameterNetworkPolicy ObjectParameter = "NETWORK_POLICY" // also an account param ObjectParameterSuspendTaskAfterNumFailures ObjectParameter = "SUSPEND_TASK_AFTER_NUM_FAILURES" ObjectParameterTraceLevel ObjectParameter = "TRACE_LEVEL" ObjectParameterUserTaskManagedInitialWarehouseSize ObjectParameter = "USER_TASK_MANAGED_INITIAL_WAREHOUSE_SIZE" ObjectParameterUserTaskTimeoutMs ObjectParameter = "USER_TASK_TIMEOUT_MS" // User Parameters ObjectParameterEnableUnredactedQuerySyntaxError ObjectParameter = "ENABLE_UNREDACTED_QUERY_SYNTAX_ERROR" )
type ObjectParameters ¶ added in v0.65.0
type ObjectParameters struct {
DataRetentionTimeInDays *int `ddl:"parameter" db:"DATA_RETENTION_TIME_IN_DAYS"`
DefaultDDLCollation *string `ddl:"parameter,single_quotes" db:"DEFAULT_DDL_COLLATION"`
LogLevel *LogLevel `ddl:"parameter" db:"LOG_LEVEL"`
MaxConcurrencyLevel *int `ddl:"parameter" db:"MAX_CONCURRENCY_LEVEL"`
MaxDataExtensionTimeInDays *int `ddl:"parameter" db:"MAX_DATA_EXTENSION_TIME_IN_DAYS"`
PipeExecutionPaused *bool `ddl:"parameter" db:"PIPE_EXECUTION_PAUSED"`
PreventUnloadToInternalStages *bool `ddl:"parameter" db:"PREVENT_UNLOAD_TO_INTERNAL_STAGES"`
StatementQueuedTimeoutInSeconds *int `ddl:"parameter" db:"STATEMENT_QUEUED_TIMEOUT_IN_SECONDS"`
NetworkPolicy *string `ddl:"parameter,single_quotes" db:"NETWORK_POLICY"`
SuspendTaskAfterNumFailures *int `ddl:"parameter" db:"SUSPEND_TASK_AFTER_NUM_FAILURES"`
TraceLevel *TraceLevel `ddl:"parameter" db:"TRACE_LEVEL"`
UserTaskManagedInitialWarehouseSize *WarehouseSize `ddl:"parameter" db:"USER_TASK_MANAGED_INITIAL_WAREHOUSE_SIZE"`
UserTaskTimeoutMs *int `ddl:"parameter" db:"USER_TASK_TIMEOUT_MS"`
}
type ObjectParametersUnset ¶ added in v0.65.0
type ObjectParametersUnset struct {
DataRetentionTimeInDays *bool `ddl:"keyword" db:"DATA_RETENTION_TIME_IN_DAYS"`
DefaultDDLCollation *bool `ddl:"keyword" db:"DEFAULT_DDL_COLLATION"`
LogLevel *bool `ddl:"keyword" db:"LOG_LEVEL"`
MaxConcurrencyLevel *bool `ddl:"keyword" db:"MAX_CONCURRENCY_LEVEL"`
MaxDataExtensionTimeInDays *bool `ddl:"keyword" db:"MAX_DATA_EXTENSION_TIME_IN_DAYS"`
PipeExecutionPaused *bool `ddl:"keyword" db:"PIPE_EXECUTION_PAUSED"`
PreventUnloadToInternalStages *bool `ddl:"keyword" db:"PREVENT_UNLOAD_TO_INTERNAL_STAGES"`
StatementQueuedTimeoutInSeconds *bool `ddl:"keyword" db:"STATEMENT_QUEUED_TIMEOUT_IN_SECONDS"`
NetworkPolicy *bool `ddl:"keyword,single_quotes" db:"NETWORK_POLICY"`
SuspendTaskAfterNumFailures *bool `ddl:"keyword" db:"SUSPEND_TASK_AFTER_NUM_FAILURES"`
TraceLevel *bool `ddl:"keyword" db:"TRACE_LEVEL"`
UserTaskManagedInitialWarehouseSize *bool `ddl:"keyword" db:"USER_TASK_MANAGED_INITIAL_WAREHOUSE_SIZE"`
UserTaskTimeoutMs *bool `ddl:"keyword" db:"USER_TASK_TIMEOUT_MS"`
}
type ObjectType ¶
type ObjectType string
ObjectType is the type of object.
const ( ObjectTypeAccount ObjectType = "ACCOUNT" ObjectTypeAccountParameter ObjectType = "ACCOUNT PARAMETER" ObjectTypeDatabase ObjectType = "DATABASE" ObjectTypeFailoverGroup ObjectType = "FAILOVER GROUP" ObjectTypeIntegration ObjectType = "INTEGRATION" ObjectTypeMaskingPolicy ObjectType = "MASKING POLICY" ObjectTypeNetworkPolicy ObjectType = "NETWORK POLICY" ObjectTypePasswordPolicy ObjectType = "PASSWORD POLICY" ObjectTypeResourceMonitor ObjectType = "RESOURCE MONITOR" ObjectTypeRole ObjectType = "ROLE" ObjectTypeSchema ObjectType = "SCHEMA" ObjectTypeSessionPolicy ObjectType = "SESSION POLICY" ObjectTypeTable ObjectType = "TABLE" ObjectTypeTag ObjectType = "TAG" ObjectTypeTask ObjectType = "TASK" ObjectTypeUser ObjectType = "USER" ObjectTypeWarehouse ObjectType = "WAREHOUSE" )
func (ObjectType) GetObjectIdentifier ¶ added in v0.65.0
func (o ObjectType) GetObjectIdentifier(fullyQualifiedName string) ObjectIdentifier
GetObjectIdentifier returns the ObjectIdentifier for the ObjectType and fully qualified name.
func (ObjectType) Plural ¶ added in v0.65.0
func (o ObjectType) Plural() PluralObjectType
func (ObjectType) String ¶
func (o ObjectType) String() string
type OnTable ¶ added in v0.65.0
type OnTable struct {
Name SchemaObjectIdentifier `ddl:"identifier" db:"TABLE"`
AllInSchema SchemaIdentifier `ddl:"identifier" db:"ALL TABLES IN SCHEMA"`
}
type OnView ¶ added in v0.65.0
type OnView struct {
Name SchemaObjectIdentifier `ddl:"identifier" db:"VIEW"`
AllInSchema SchemaIdentifier `ddl:"identifier" db:"ALL VIEWS IN SCHEMA"`
}
type Parameter ¶ added in v0.65.0
type Parameter struct {
Key string
Value string
Default string
Level ParameterType
Description string
}
type ParameterType ¶ added in v0.65.0
type ParameterType string
const ( ParameterTypeAccount ParameterType = "ACCOUNT" ParameterTypeUser ParameterType = "USER" ParameterTypeSession ParameterType = "SESSION" ParameterTypeObject ParameterType = "OBJECT" )
type ParametersIn ¶ added in v0.65.0
type ParametersIn struct {
Session *bool `ddl:"keyword" db:"SESSION"`
Account *bool `ddl:"keyword" db:"ACCOUNT"`
User AccountObjectIdentifier `ddl:"identifier" db:"USER"`
Warehouse AccountObjectIdentifier `ddl:"identifier" db:"WAREHOUSE"`
Database AccountObjectIdentifier `ddl:"identifier" db:"DATABASE"`
Schema SchemaIdentifier `ddl:"identifier" db:"SCHEMA"`
Task SchemaObjectIdentifier `ddl:"identifier" db:"TASK"`
Table SchemaObjectIdentifier `ddl:"identifier" db:"TABLE"`
}
type PasswordPolicies ¶
type PasswordPolicies interface {
// Create creates a new password policy.
Create(ctx context.Context, id SchemaObjectIdentifier, opts *PasswordPolicyCreateOptions) error
// Alter modifies an existing password policy.
Alter(ctx context.Context, id SchemaObjectIdentifier, opts *PasswordPolicyAlterOptions) error
// Drop removes a password policy.
Drop(ctx context.Context, id SchemaObjectIdentifier, opts *PasswordPolicyDropOptions) error
// Show returns a list of password policies.
Show(ctx context.Context, opts *PasswordPolicyShowOptions) ([]*PasswordPolicy, error)
// ShowByID returns a password policy by ID.
ShowByID(ctx context.Context, id SchemaObjectIdentifier) (*PasswordPolicy, error)
// Describe returns the details of a password policy.
Describe(ctx context.Context, id SchemaObjectIdentifier) (*PasswordPolicyDetails, error)
}
PasswordPolicies describes all the password policy related methods that the Snowflake API supports.
type PasswordPolicy ¶
type PasswordPolicy struct {
CreatedOn time.Time
Name string
DatabaseName string
SchemaName string
Kind string
Owner string
Comment string
}
PasswordPolicys is a user friendly result for a CREATE PASSWORD POLICY query.
func (*PasswordPolicy) ID ¶
func (v *PasswordPolicy) ID() SchemaObjectIdentifier
func (*PasswordPolicy) ObjectType ¶ added in v0.65.0
func (v *PasswordPolicy) ObjectType() ObjectType
type PasswordPolicyAlterOptions ¶
type PasswordPolicyAlterOptions struct {
IfExists *bool `ddl:"keyword" db:"IF EXISTS"`
NewName SchemaObjectIdentifier `ddl:"identifier" db:"RENAME TO"`
Set *PasswordPolicySet `ddl:"keyword" db:"SET"`
Unset *PasswordPolicyUnset `ddl:"keyword" db:"UNSET"`
// contains filtered or unexported fields
}
type PasswordPolicyCreateOptions ¶
type PasswordPolicyCreateOptions struct {
OrReplace *bool `ddl:"keyword" db:"OR REPLACE"`
IfNotExists *bool `ddl:"keyword" db:"IF NOT EXISTS"`
PasswordMinLength *int `ddl:"parameter" db:"PASSWORD_MIN_LENGTH"`
PasswordMaxLength *int `ddl:"parameter" db:"PASSWORD_MAX_LENGTH"`
PasswordMinUpperCaseChars *int `ddl:"parameter" db:"PASSWORD_MIN_UPPER_CASE_CHARS"`
PasswordMinLowerCaseChars *int `ddl:"parameter" db:"PASSWORD_MIN_LOWER_CASE_CHARS"`
PasswordMinNumericChars *int `ddl:"parameter" db:"PASSWORD_MIN_NUMERIC_CHARS"`
PasswordMinSpecialChars *int `ddl:"parameter" db:"PASSWORD_MIN_SPECIAL_CHARS"`
PasswordMaxAgeDays *int `ddl:"parameter" db:"PASSWORD_MAX_AGE_DAYS"`
PasswordMaxRetries *int `ddl:"parameter" db:"PASSWORD_MAX_RETRIES"`
PasswordLockoutTimeMins *int `ddl:"parameter" db:"PASSWORD_LOCKOUT_TIME_MINS"`
Comment *string `ddl:"parameter,single_quotes" db:"COMMENT"`
// contains filtered or unexported fields
}
type PasswordPolicyDetails ¶
type PasswordPolicyDetails struct {
Name *StringProperty
Owner *StringProperty
Comment *StringProperty
PasswordMinLength *IntProperty
PasswordMaxLength *IntProperty
PasswordMinUpperCaseChars *IntProperty
PasswordMinLowerCaseChars *IntProperty
PasswordMinNumericChars *IntProperty
PasswordMinSpecialChars *IntProperty
PasswordMaxAgeDays *IntProperty
PasswordMaxRetries *IntProperty
PasswordLockoutTimeMins *IntProperty
}
type PasswordPolicyDropOptions ¶
type PasswordPolicyDropOptions struct {
IfExists *bool `ddl:"keyword" db:"IF EXISTS"`
// contains filtered or unexported fields
}
type PasswordPolicySet ¶
type PasswordPolicySet struct {
PasswordMinLength *int `ddl:"parameter" db:"PASSWORD_MIN_LENGTH"`
PasswordMaxLength *int `ddl:"parameter" db:"PASSWORD_MAX_LENGTH"`
PasswordMinUpperCaseChars *int `ddl:"parameter" db:"PASSWORD_MIN_UPPER_CASE_CHARS"`
PasswordMinLowerCaseChars *int `ddl:"parameter" db:"PASSWORD_MIN_LOWER_CASE_CHARS"`
PasswordMinNumericChars *int `ddl:"parameter" db:"PASSWORD_MIN_NUMERIC_CHARS"`
PasswordMinSpecialChars *int `ddl:"parameter" db:"PASSWORD_MIN_SPECIAL_CHARS"`
PasswordMaxAgeDays *int `ddl:"parameter" db:"PASSWORD_MAX_AGE_DAYS"`
PasswordMaxRetries *int `ddl:"parameter" db:"PASSWORD_MAX_RETRIES"`
PasswordLockoutTimeMins *int `ddl:"parameter" db:"PASSWORD_LOCKOUT_TIME_MINS"`
Comment *string `ddl:"parameter,single_quotes" db:"COMMENT"`
}
type PasswordPolicyShowOptions ¶
type PasswordPolicyShowOptions struct {
Like *Like `ddl:"keyword" db:"LIKE"`
In *In `ddl:"keyword" db:"IN"`
Limit *int `ddl:"parameter,no_equals" db:"LIMIT"`
// contains filtered or unexported fields
}
PasswordPolicyShowOptions represents the options for listing password policies.
type PasswordPolicyUnset ¶
type PasswordPolicyUnset struct {
PasswordMinLength *bool `ddl:"keyword" db:"PASSWORD_MIN_LENGTH"`
PasswordMaxLength *bool `ddl:"keyword" db:"PASSWORD_MAX_LENGTH"`
PasswordMinUpperCaseChars *bool `ddl:"keyword" db:"PASSWORD_MIN_UPPER_CASE_CHARS"`
PasswordMinLowerCaseChars *bool `ddl:"keyword" db:"PASSWORD_MIN_LOWER_CASE_CHARS"`
PasswordMinNumericChars *bool `ddl:"keyword" db:"PASSWORD_MIN_NUMERIC_CHARS"`
PasswordMinSpecialChars *bool `ddl:"keyword" db:"PASSWORD_MIN_SPECIAL_CHARS"`
PasswordMaxAgeDays *bool `ddl:"keyword" db:"PASSWORD_MAX_AGE_DAYS"`
PasswordMaxRetries *bool `ddl:"keyword" db:"PASSWORD_MAX_RETRIES"`
PasswordLockoutTimeMins *bool `ddl:"keyword" db:"PASSWORD_LOCKOUT_TIME_MINS"`
Comment *bool `ddl:"keyword" db:"COMMENT"`
}
type PluralObjectType ¶ added in v0.65.0
type PluralObjectType string
const ( PluralObjectTypeAccountParameters PluralObjectType = "ACCOUNT PARAMETERS" PluralObjectTypeDatabases PluralObjectType = "DATABASES" PluralObjectTypeTypeFailoverGroups PluralObjectType = "FAILOVER GROUPS" PluralObjectTypeIntegrations PluralObjectType = "INTEGRATIONS" PluralObjectTypeMaskingPolicies PluralObjectType = "MASKING POLICIES" PluralObjectTypeNetworkPolicies PluralObjectType = "NETWORK POLICIES" PluralObjectTypePasswordPolicies PluralObjectType = "PASSWORD POLICIES" PluralObjectTypeResourceMonitors PluralObjectType = "RESOURCE MONITORS" PluralObjectTypeRoles PluralObjectType = "ROLES" PluralObjectTypeSchemas PluralObjectType = "SCHEMAS" PluralObjectTypeSessionPolicies PluralObjectType = "SESSION POLICIES" PluralObjectTypeTables PluralObjectType = "TABLES" PluralObjectTypeTags PluralObjectType = "TAGS" PluralObjectTypeTasks PluralObjectType = "TASKS" PluralObjectTypeUsers PluralObjectType = "USERS" PluralObjectTypeWarehouses PluralObjectType = "WAREHOUSES" )
func (PluralObjectType) Singular ¶ added in v0.65.0
func (p PluralObjectType) Singular() ObjectType
func (PluralObjectType) String ¶ added in v0.65.0
func (p PluralObjectType) String() string
type ReplicationAccount ¶ added in v0.65.0
type ReplicationAccount struct {
SnowflakeRegion string `db:"snowflake_region"`
CreatedOn time.Time `db:"created_on"`
AccountName string `db:"account_name"`
AccountLocator string `db:"account_locator"`
Comment string `db:"comment"`
OrganizationName string `db:"organization_name"`
IsOrgAdmin bool `db:"is_org_admin"`
}
func (*ReplicationAccount) ID ¶ added in v0.65.0
func (v *ReplicationAccount) ID() AccountIdentifier
type ReplicationFunctions ¶ added in v0.65.0
type ReplicationFunctions interface {
ShowReplicationAcccounts(ctx context.Context) ([]*ReplicationAccount, error)
// todo: ShowReplicationDatabases(ctx context.Context, opts *ShowReplicationDatabasesOptions) ([]*ReplicationDatabase, error)
ShowRegions(ctx context.Context, opts *ShowRegionsOptions) ([]*Region, error)
}
type ResourceMonitor ¶ added in v0.65.0
type ResourceMonitor struct {
Name string
}
func (*ResourceMonitor) ID ¶ added in v0.65.0
func (v *ResourceMonitor) ID() AccountObjectIdentifier
func (*ResourceMonitor) ObjectType ¶ added in v0.65.0
func (v *ResourceMonitor) ObjectType() ObjectType
type ResourceMonitorAlterOptions ¶ added in v0.65.0
type ResourceMonitorAlterOptions struct{}
ResourceMonitorAlterOptions contains options for altering a resource monitor.
type ResourceMonitorCreateOptions ¶ added in v0.65.0
type ResourceMonitorCreateOptions struct {
// contains filtered or unexported fields
}
ResourceMonitorCreateOptions contains options for creating a resource monitor.
type ResourceMonitorShowOptions ¶ added in v0.65.0
type ResourceMonitorShowOptions struct {
Like *Like `ddl:"keyword" db:"LIKE"`
// contains filtered or unexported fields
}
ResourceMonitorShowOptions contains options for listing resource monitors.
type ResourceMonitors ¶ added in v0.65.0
type ResourceMonitors interface {
// Create creates a resource monitor.
Create(ctx context.Context, id AccountObjectIdentifier, opts *ResourceMonitorCreateOptions) error
// Alter modifies an existing resource monitor
Alter(ctx context.Context, id AccountObjectIdentifier, opts *ResourceMonitorAlterOptions) error
// Drop removes a resource monitor.
Drop(ctx context.Context, id AccountObjectIdentifier) error
// Show returns a list of resource monitor.
Show(ctx context.Context, opts *ResourceMonitorShowOptions) ([]*ResourceMonitor, error)
// ShowByID returns a resource monitor by ID
ShowByID(ctx context.Context, id AccountObjectIdentifier) (*ResourceMonitor, error)
}
type RevokePrivilegeFromShareOn ¶ added in v0.65.0
type RevokePrivilegeFromShareOn struct {
}
type Role ¶ added in v0.65.0
type Role struct {
Name string `db:"name"`
}
func (*Role) ID ¶ added in v0.65.0
func (v *Role) ID() AccountObjectIdentifier
func (*Role) ObjectType ¶ added in v0.65.0
func (v *Role) ObjectType() ObjectType
type RoleAlterOptions ¶ added in v0.65.0
type RoleAlterOptions struct{}
RoleAlterOptions contains options for altering a user.
type RoleCreateOptions ¶ added in v0.65.0
type RoleCreateOptions struct{}
RoleCreateOptions contains options for creating a role.
type RoleDropOptions ¶ added in v0.65.0
type RoleDropOptions struct{}
RoleDropOptions contains options for dropping a role.
type RoleShowOptions ¶ added in v0.65.0
type RoleShowOptions struct{}
RoleShowOptions contains options for listing roles.
type Roles ¶ added in v0.65.0
type Roles interface {
// Create creates a role.
Create(ctx context.Context, id AccountObjectIdentifier, opts *RoleCreateOptions) error
// Alter modifies an existing role
Alter(ctx context.Context, id AccountObjectIdentifier, opts *RoleAlterOptions) error
// Drop removes a role.
Drop(ctx context.Context, id AccountObjectIdentifier, opts *RoleDropOptions) error
// Show returns a list of roles.
Show(ctx context.Context, opts *RoleShowOptions) ([]*Role, error)
// ShowByID returns a user by ID
ShowByID(ctx context.Context, id AccountObjectIdentifier) (*Role, error)
}
type ScalingPolicy ¶ added in v0.65.0
type ScalingPolicy string
var ( ScalingPolicyStandard ScalingPolicy = "STANDARD" ScalingPolicyEconomy ScalingPolicy = "ECONOMY" )
type Schema ¶
placeholder for the real implementation.
func (*Schema) ID ¶
func (v *Schema) ID() SchemaIdentifier
func (*Schema) ObjectType ¶ added in v0.65.0
func (v *Schema) ObjectType() ObjectType
type SchemaIdentifier ¶
type SchemaIdentifier struct {
// contains filtered or unexported fields
}
func NewSchemaIdentifier ¶
func NewSchemaIdentifier(databaseName, schemaName string) SchemaIdentifier
func NewSchemaIdentifierFromFullyQualifiedName ¶
func NewSchemaIdentifierFromFullyQualifiedName(fullyQualifiedName string) SchemaIdentifier
func (SchemaIdentifier) DatabaseName ¶
func (i SchemaIdentifier) DatabaseName() string
func (SchemaIdentifier) FullyQualifiedName ¶
func (i SchemaIdentifier) FullyQualifiedName() string
func (SchemaIdentifier) Name ¶
func (i SchemaIdentifier) Name() string
type SchemaObjectIdentifier ¶
type SchemaObjectIdentifier struct {
// contains filtered or unexported fields
}
func NewSchemaObjectIdentifier ¶
func NewSchemaObjectIdentifier(databaseName, schemaName, name string) SchemaObjectIdentifier
func NewSchemaObjectIdentifierFromFullyQualifiedName ¶
func NewSchemaObjectIdentifierFromFullyQualifiedName(fullyQualifiedName string) SchemaObjectIdentifier
func (SchemaObjectIdentifier) DatabaseName ¶
func (i SchemaObjectIdentifier) DatabaseName() string
func (SchemaObjectIdentifier) FullyQualifiedName ¶
func (i SchemaObjectIdentifier) FullyQualifiedName() string
func (SchemaObjectIdentifier) Name ¶
func (i SchemaObjectIdentifier) Name() string
func (SchemaObjectIdentifier) SchemaName ¶
func (i SchemaObjectIdentifier) SchemaName() string
type SessionParameter ¶ added in v0.65.0
type SessionParameter string
const ( SessionParameterAbortDetachedQuery SessionParameter = "ABORT_DETACHED_QUERY" SessionParameterAutocommit SessionParameter = "AUTOCOMMIT" SessionParameterBinaryInputFormat SessionParameter = "BINARY_INPUT_FORMAT" SessionParameterBinaryOutputFormat SessionParameter = "BINARY_OUTPUT_FORMAT" SessionParameterDateInputFormat SessionParameter = "DATE_INPUT_FORMAT" SessionParameterDateOutputFormat SessionParameter = "DATE_OUTPUT_FORMAT" SessionParameterErrorOnNondeterministicMerge SessionParameter = "ERROR_ON_NONDETERMINISTIC_MERGE" SessionParameterErrorOnNondeterministicUpdate SessionParameter = "ERROR_ON_NONDETERMINISTIC_UPDATE" SessionParameterGeographyOutputFormat SessionParameter = "GEOGRAPHY_OUTPUT_FORMAT" SessionParameterJSONIndent SessionParameter = "JSON_INDENT" SessionParameterLockTimeout SessionParameter = "LOCK_TIMEOUT" SessionParameterQueryTag SessionParameter = "QUERY_TAG" SessionParameterRowsPerResultset SessionParameter = "ROWS_PER_RESULTSET" SessionParameterSimulatedDataSharingConsumer SessionParameter = "SIMULATED_DATA_SHARING_CONSUMER" SessionParameterStatementTimeoutInSeconds SessionParameter = "STATEMENT_TIMEOUT_IN_SECONDS" SessionParameterStrictJSONOutput SessionParameter = "STRICT_JSON_OUTPUT" SessionParameterTimestampDayIsAlways24h SessionParameter = "TIMESTAMP_DAY_IS_ALWAYS_24H" SessionParameterTimestampInputFormat SessionParameter = "TIMESTAMP_INPUT_FORMAT" SessionParameterTimestampLTZOutputFormat SessionParameter = "TIMESTAMP_LTZ_OUTPUT_FORMAT" SessionParameterTimestampNTZOutputFormat SessionParameter = "TIMESTAMP_NTZ_OUTPUT_FORMAT" SessionParameterTimestampOutputFormat SessionParameter = "TIMESTAMP_OUTPUT_FORMAT" SessionParameterTimestampTypeMapping SessionParameter = "TIMESTAMP_TYPE_MAPPING" SessionParameterTimestampTZOutputFormat SessionParameter = "TIMESTAMP_TZ_OUTPUT_FORMAT" SessionParameterTimezone SessionParameter = "TIMEZONE" SessionParameterTimeInputFormat SessionParameter = "TIME_INPUT_FORMAT" SessionParameterTimeOutputFormat SessionParameter = "TIME_OUTPUT_FORMAT" SessionParameterTransactionDefaultIsolationLevel SessionParameter = "TRANSACTION_DEFAULT_ISOLATION_LEVEL" SessionParameterTwoDigitCenturyStart SessionParameter = "TWO_DIGIT_CENTURY_START" SessionParameterUnsupportedDDLAction SessionParameter = "UNSUPPORTED_DDL_ACTION" SessionParameterUseCachedResult SessionParameter = "USE_CACHED_RESULT" SessionParameterWeekOfYearPolicy SessionParameter = "WEEK_OF_YEAR_POLICY" SessionParameterWeekStart SessionParameter = "WEEK_START" )
type SessionParameters ¶ added in v0.65.0
type SessionParameters struct {
AbortDetachedQuery *bool `ddl:"parameter" db:"ABORT_DETACHED_QUERY"`
Autocommit *bool `ddl:"parameter" db:"AUTOCOMMIT"`
BinaryInputFormat *string `ddl:"parameter,single_quotes" db:"BINARY_INPUT_FORMAT"`
BinaryOutputFormat *BinaryInputFormat `ddl:"parameter,single_quotes" db:"BINARY_OUTPUT_FORMAT"`
DateInputFormat *string `ddl:"parameter,single_quotes" db:"DATE_INPUT_FORMAT"`
DateOutputFormat *string `ddl:"parameter,single_quotes" db:"DATE_OUTPUT_FORMAT"`
ErrorOnNondeterministicMerge *bool `ddl:"parameter" db:"ERROR_ON_NONDETERMINISTIC_MERGE"`
ErrorOnNondeterministicUpdate *bool `ddl:"parameter" db:"ERROR_ON_NONDETERMINISTIC_UPDATE"`
GeographyOutputFormat *GeographyOutputFormat `ddl:"parameter,single_quotes" db:"GEOGRAPHY_OUTPUT_FORMAT"`
JSONIndent *int `ddl:"parameter" db:"JSON_INDENT"`
LockTimeout *int `ddl:"parameter" db:"LOCK_TIMEOUT"`
QueryTag *string `ddl:"parameter,single_quotes" db:"QUERY_TAG"`
RowsPerResultset *int `ddl:"parameter" db:"ROWS_PER_RESULTSET"`
SimulatedDataSharingConsumer *string `ddl:"parameter,single_quotes" db:"SIMULATED_DATA_SHARING_CONSUMER"`
StatementTimeoutInSeconds *int `ddl:"parameter" db:"STATEMENT_TIMEOUT_IN_SECONDS"`
StrictJSONOutput *bool `ddl:"parameter" db:"STRICT_JSON_OUTPUT"`
TimestampDayIsAlways24h *bool `ddl:"parameter" db:"TIMESTAMP_DAY_IS_ALWAYS_24H"`
TimestampInputFormat *string `ddl:"parameter,single_quotes" db:"TIMESTAMP_INPUT_FORMAT"`
TimestampLTZOutputFormat *string `ddl:"parameter,single_quotes" db:"TIMESTAMP_LTZ_OUTPUT_FORMAT"`
TimestampNTZOutputFormat *string `ddl:"parameter,single_quotes" db:"TIMESTAMP_NTZ_OUTPUT_FORMAT"`
TimestampOutputFormat *string `ddl:"parameter,single_quotes" db:"TIMESTAMP_OUTPUT_FORMAT"`
TimestampTypeMapping *string `ddl:"parameter,single_quotes" db:"TIMESTAMP_TYPE_MAPPING"`
TimestampTZOutputFormat *string `ddl:"parameter,single_quotes" db:"TIMESTAMP_TZ_OUTPUT_FORMAT"`
Timezone *string `ddl:"parameter,single_quotes" db:"TIMEZONE"`
TimeInputFormat *string `ddl:"parameter,single_quotes" db:"TIME_INPUT_FORMAT"`
TimeOutputFormat *string `ddl:"parameter,single_quotes" db:"TIME_OUTPUT_FORMAT"`
TransactionDefaultIsolationLevel *TransactionDefaultIsolationLevel `ddl:"parameter,single_quotes" db:"TRANSACTION_DEFAULT_ISOLATION_LEVEL"`
TwoDigitCenturyStart *int `ddl:"parameter" db:"TWO_DIGIT_CENTURY_START"`
UnsupportedDDLAction *UnsupportedDDLAction `ddl:"parameter,single_quotes" db:"UNSUPPORTED_DDL_ACTION"`
UseCachedResult *bool `ddl:"parameter" db:"USE_CACHED_RESULT"`
WeekOfYearPolicy *int `ddl:"parameter" db:"WEEK_OF_YEAR_POLICY"`
WeekStart *int `ddl:"parameter" db:"WEEK_START"`
}
type SessionParametersUnset ¶ added in v0.65.0
type SessionParametersUnset struct {
AbortDetachedQuery *bool `ddl:"keyword" db:"ABORT_DETACHED_QUERY"`
Autocommit *bool `ddl:"keyword" db:"AUTOCOMMIT"`
BinaryInputFormat *bool `ddl:"keyword" db:"BINARY_INPUT_FORMAT"`
BinaryOutputFormat *bool `ddl:"keyword" db:"BINARY_OUTPUT_FORMAT"`
DateInputFormat *bool `ddl:"keyword" db:"DATE_INPUT_FORMAT"`
DateOutputFormat *bool `ddl:"keyword" db:"DATE_OUTPUT_FORMAT"`
ErrorOnNondeterministicMerge *bool `ddl:"keyword" db:"ERROR_ON_NONDETERMINISTIC_MERGE"`
ErrorOnNondeterministicUpdate *bool `ddl:"keyword" db:"ERROR_ON_NONDETERMINISTIC_UPDATE"`
GeographyOutputFormat *bool `ddl:"keyword" db:"GEOGRAPHY_OUTPUT_FORMAT"`
JSONIndent *bool `ddl:"keyword" db:"JSON_INDENT"`
LockTimeout *bool `ddl:"keyword" db:"LOCK_TIMEOUT"`
QueryTag *bool `ddl:"keyword" db:"QUERY_TAG"`
RowsPerResultset *bool `ddl:"keyword" db:"ROWS_PER_RESULTSET"`
SimulatedDataSharingConsumer *bool `ddl:"keyword" db:"SIMULATED_DATA_SHARING_CONSUMER"`
StatementTimeoutInSeconds *bool `ddl:"keyword" db:"STATEMENT_TIMEOUT_IN_SECONDS"`
StrictJSONOutput *bool `ddl:"keyword" db:"STRICT_JSON_OUTPUT"`
TimestampDayIsAlways24h *bool `ddl:"keyword" db:"TIMESTAMP_DAY_IS_ALWAYS_24H"`
TimestampInputFormat *bool `ddl:"keyword" db:"TIMESTAMP_INPUT_FORMAT"`
TimestampLTZOutputFormat *bool `ddl:"keyword" db:"TIMESTAMP_LTZ_OUTPUT_FORMAT"`
TimestampNTZOutputFormat *bool `ddl:"keyword" db:"TIMESTAMP_NTZ_OUTPUT_FORMAT"`
TimestampOutputFormat *bool `ddl:"keyword" db:"TIMESTAMP_OUTPUT_FORMAT"`
TimestampTypeMapping *bool `ddl:"keyword" db:"TIMESTAMP_TYPE_MAPPING"`
TimestampTZOutputFormat *bool `ddl:"keyword" db:"TIMESTAMP_TZ_OUTPUT_FORMAT"`
Timezone *bool `ddl:"keyword" db:"TIMEZONE"`
TimeInputFormat *bool `ddl:"keyword" db:"TIME_INPUT_FORMAT"`
TimeOutputFormat *bool `ddl:"keyword" db:"TIME_OUTPUT_FORMAT"`
TransactionDefaultIsolationLevel *bool `ddl:"keyword" db:"TRANSACTION_DEFAULT_ISOLATION_LEVEL"`
TwoDigitCenturyStart *bool `ddl:"keyword" db:"TWO_DIGIT_CENTURY_START"`
UnsupportedDDLAction *bool `ddl:"keyword" db:"UNSUPPORTED_DDL_ACTION"`
UseCachedResult *bool `ddl:"keyword" db:"USE_CACHED_RESULT"`
WeekOfYearPolicy *bool `ddl:"keyword" db:"WEEK_OF_YEAR_POLICY"`
WeekStart *bool `ddl:"keyword" db:"WEEK_START"`
}
type SessionPolicies ¶ added in v0.65.0
type SessionPolicies interface {
// Create creates a session policy.
Create(ctx context.Context, id SchemaObjectIdentifier, opts *SessionPolicyCreateOptions) error
// Alter modifies an existing session policy
Alter(ctx context.Context, id SchemaObjectIdentifier, opts *SessionPolicyAlterOptions) error
// Drop removes a session policy.
Drop(ctx context.Context, id SchemaObjectIdentifier, opts *SessionPolicyDropOptions) error
// Show returns a list of session policy.
Show(ctx context.Context) ([]*SessionPolicy, error)
// ShowByID returns a session policy by ID
ShowByID(ctx context.Context, id SchemaObjectIdentifier) (*SessionPolicy, error)
// Describe returns the details of a session policy.
Describe(ctx context.Context, id SchemaObjectIdentifier) (*SessionPolicyDetails, error)
}
type SessionPolicy ¶ added in v0.65.0
func (*SessionPolicy) ID ¶ added in v0.65.0
func (v *SessionPolicy) ID() SchemaObjectIdentifier
func (*SessionPolicy) ObjectType ¶ added in v0.65.0
func (v *SessionPolicy) ObjectType() ObjectType
type SessionPolicyAlterOptions ¶ added in v0.65.0
type SessionPolicyAlterOptions struct{}
SessionPolicyAlterOptions contains options for altering a session policy.
type SessionPolicyCreateOptions ¶ added in v0.65.0
type SessionPolicyCreateOptions struct {
// contains filtered or unexported fields
}
SessionPolicyCreateOptions contains options for creating a session policy.
type SessionPolicyDetails ¶ added in v0.65.0
type SessionPolicyDetails struct{}
type SessionPolicyDropOptions ¶ added in v0.65.0
type SessionPolicyDropOptions struct {
IfExists *bool `ddl:"keyword" db:"IF EXISTS"`
// contains filtered or unexported fields
}
SessionPolicyDropOptions contains options for dropping a session policy.
type SessionSet ¶ added in v0.65.0
type SessionSet struct {
SessionParameters *SessionParameters `ddl:"list"`
}
type SessionUnset ¶ added in v0.65.0
type SessionUnset struct {
SessionParametersUnset *SessionParametersUnset `ddl:"list"`
}
type Sessions ¶
type Sessions interface {
// Parameters
AlterSession(ctx context.Context, opts *AlterSessionOptions) error
ShowParameters(ctx context.Context, opts *ShowParametersOptions) ([]*Parameter, error)
ShowAccountParameter(ctx context.Context, parameter AccountParameter) (*Parameter, error)
ShowSessionParameter(ctx context.Context, parameter SessionParameter) (*Parameter, error)
ShowUserParameter(ctx context.Context, parameter UserParameter, user AccountObjectIdentifier) (*Parameter, error)
ShowObjectParameter(ctx context.Context, parameter ObjectParameter, objectType ObjectType, objectID Identifier) (*Parameter, error)
// Context
UseWarehouse(ctx context.Context, warehouse AccountObjectIdentifier) error
UseDatabase(ctx context.Context, database AccountObjectIdentifier) error
UseSchema(ctx context.Context, schema SchemaIdentifier) error
}
type SetColumnCommentOpts ¶ added in v0.65.0
type SetColumnCommentOpts struct {
IfExists *bool `ddl:"keyword" db:"IF EXISTS"`
Column ObjectIdentifier `ddl:"identifier" db:"COLUMN"`
Value *string `ddl:"parameter,single_quotes,no_equals" db:"IS"`
// contains filtered or unexported fields
}
type SetCommentOpts ¶ added in v0.65.0
type SetCommentOpts struct {
IfExists *bool `ddl:"keyword" db:"IF EXISTS"`
ObjectType ObjectType `ddl:"keyword"`
ObjectName ObjectIdentifier `ddl:"identifier"`
Value *string `ddl:"parameter,single_quotes,no_equals" db:"IS"`
// contains filtered or unexported fields
}
type Share ¶ added in v0.65.0
type Share struct {
}
func (*Share) ExternalID ¶ added in v0.65.0
func (v *Share) ExternalID() ExternalObjectIdentifier
func (*Share) ID ¶ added in v0.65.0
func (v *Share) ID() AccountObjectIdentifier
func (*Share) ObjectType ¶ added in v0.65.0
func (v *Share) ObjectType() ObjectType
type ShareAlterOptions ¶ added in v0.65.0
type ShareAlterOptions struct {
// contains filtered or unexported fields
}
type ShareCreateOptions ¶ added in v0.65.0
type ShareCreateOptions struct {
// contains filtered or unexported fields
}
type ShareDetails ¶ added in v0.65.0
type ShareDetails struct {
}
type ShareRemove ¶ added in v0.65.0
type ShareRemove struct {
}
type ShareShowOptions ¶ added in v0.65.0
type ShareShowOptions struct {
// contains filtered or unexported fields
}
type ShareUnset ¶ added in v0.65.0
type ShareUnset struct {
}
type Shares ¶ added in v0.65.0
type Shares interface {
Create(ctx context.Context, id AccountObjectIdentifier, opts *ShareCreateOptions) error
Alter(ctx context.Context, id AccountObjectIdentifier, opts *ShareAlterOptions) error
Drop(ctx context.Context, id AccountObjectIdentifier) error
Show(ctx context.Context, opts *ShareShowOptions) ([]*Share, error)
ShowByID(ctx context.Context, id AccountObjectIdentifier) (*Share, error)
DescribeProvider(ctx context.Context, id AccountObjectIdentifier) (*ShareDetails, error)
DescribeConsumer(ctx context.Context, id ExternalObjectIdentifier) (*ShareDetails, error)
}
type ShowGrantsOf ¶ added in v0.65.0
type ShowGrantsOf struct {
Role AccountObjectIdentifier `ddl:"identifier" db:"ROLE"`
}
type ShowGrantsOn ¶ added in v0.65.0
type ShowGrantsOptions ¶ added in v0.65.0
type ShowGrantsOptions struct {
On *ShowGrantsOn `ddl:"keyword" db:"ON"`
To *ShowGrantsTo `ddl:"keyword" db:"TO"`
Of *ShowGrantsOf `ddl:"keyword" db:"OF"`
// contains filtered or unexported fields
}
type ShowGrantsTo ¶ added in v0.65.0
type ShowGrantsTo struct {
Role AccountObjectIdentifier `ddl:"identifier" db:"ROLE"`
User AccountObjectIdentifier `ddl:"identifier" db:"USER"`
}
type ShowParametersOptions ¶ added in v0.65.0
type ShowParametersOptions struct {
Like *Like `ddl:"keyword" db:"LIKE"`
In *ParametersIn `ddl:"keyword" db:"IN"`
// contains filtered or unexported fields
}
type ShowRegionsOptions ¶ added in v0.65.0
type ShowRegionsOptions struct {
Like *Like `ddl:"keyword" db:"LIKE"`
// contains filtered or unexported fields
}
type StringProperty ¶
type SystemFunctions ¶
type SystemFunctions interface {
GetTag(ctx context.Context, tagID ObjectIdentifier, objectID ObjectIdentifier, objectType ObjectType) (string, error)
}
type TableColumnIdentifier ¶
type TableColumnIdentifier struct {
// contains filtered or unexported fields
}
func NewTableColumnIdentifier ¶
func NewTableColumnIdentifier(databaseName, schemaName, tableName, columnName string) TableColumnIdentifier
func NewTableColumnIdentifierFromFullyQualifiedName ¶
func NewTableColumnIdentifierFromFullyQualifiedName(fullyQualifiedName string) TableColumnIdentifier
func (TableColumnIdentifier) DatabaseName ¶
func (i TableColumnIdentifier) DatabaseName() string
func (TableColumnIdentifier) FullyQualifiedName ¶
func (i TableColumnIdentifier) FullyQualifiedName() string
func (TableColumnIdentifier) Name ¶
func (i TableColumnIdentifier) Name() string
func (TableColumnIdentifier) SchemaName ¶
func (i TableColumnIdentifier) SchemaName() string
func (TableColumnIdentifier) TableName ¶
func (i TableColumnIdentifier) TableName() string
type TableColumnSignature ¶
type Tag ¶
func (*Tag) ID ¶
func (v *Tag) ID() SchemaObjectIdentifier
func (*Tag) ObjectType ¶ added in v0.65.0
func (v *Tag) ObjectType() ObjectType
type TagAssociation ¶
type TagAssociation struct {
Name ObjectIdentifier `ddl:"identifier"`
Value string `ddl:"parameter,single_quotes"`
}
type TraceLevel ¶ added in v0.65.0
type TraceLevel string
const ( TraceLevelAlways TraceLevel = "ALWAYS" TraceLevelOnEvent TraceLevel = "ON_EVENT" TraceLevelOff TraceLevel = "OFF" )
type TransactionDefaultIsolationLevel ¶ added in v0.65.0
type TransactionDefaultIsolationLevel string
const (
TransactionDefaultIsolationLevelReadCommitted TransactionDefaultIsolationLevel = "READ COMMITTED"
)
type UnsupportedDDLAction ¶ added in v0.65.0
type UnsupportedDDLAction string
const ( UnsupportedDDLActionIgnore UnsupportedDDLAction = "IGNORE" UnsupportedDDLActionFail UnsupportedDDLAction = "FAIL" )
type User ¶ added in v0.65.0
type User struct{}
func (*User) ID ¶ added in v0.65.0
func (v *User) ID() AccountObjectIdentifier
func (*User) ObjectType ¶ added in v0.65.0
func (v *User) ObjectType() ObjectType
type UserAlterOptions ¶ added in v0.65.0
type UserAlterOptions struct{}
UserAlterOptions contains options for altering a user.
type UserCreateOptions ¶ added in v0.65.0
type UserCreateOptions struct{}
UserCreateOptions contains options for creating a user.
type UserDetails ¶ added in v0.65.0
type UserDetails struct{}
UserDetails contains details about a user.
type UserDropOptions ¶ added in v0.65.0
type UserDropOptions struct{}
UserDropOptions contains options for dropping a user.
type UserParameter ¶ added in v0.65.0
type UserParameter string
const ( // User Parameters UserParameterEnableUnredactedQuerySyntaxError UserParameter = "ENABLE_UNREDACTED_QUERY_SYNTAX_ERROR" // Session Parameters (inherited) UserParameterAbortDetachedQuery UserParameter = "ABORT_DETACHED_QUERY" UserParameterAutocommit UserParameter = "AUTOCOMMIT" UserParameterBinaryInputFormat UserParameter = "BINARY_INPUT_FORMAT" UserParameterBinaryOutputFormat UserParameter = "BINARY_OUTPUT_FORMAT" UserParameterDateInputFormat UserParameter = "DATE_INPUT_FORMAT" UserParameterDateOutputFormat UserParameter = "DATE_OUTPUT_FORMAT" UserParameterErrorOnNondeterministicMerge UserParameter = "ERROR_ON_NONDETERMINISTIC_MERGE" UserParameterErrorOnNondeterministicUpdate UserParameter = "ERROR_ON_NONDETERMINISTIC_UPDATE" UserParameterGeographyOutputFormat UserParameter = "GEOGRAPHY_OUTPUT_FORMAT" UserParameterJSONIndent UserParameter = "JSON_INDENT" UserParameterLockTimeout UserParameter = "LOCK_TIMEOUT" UserParameterQueryTag UserParameter = "QUERY_TAG" UserParameterRowsPerResultset UserParameter = "ROWS_PER_RESULTSET" UserParameterSimulatedDataSharingConsumer UserParameter = "SIMULATED_DATA_SHARING_CONSUMER" UserParameterStatementTimeoutInSeconds UserParameter = "STATEMENT_TIMEOUT_IN_SECONDS" UserParameterStrictJSONOutput UserParameter = "STRICT_JSON_OUTPUT" UserParameterTimestampDayIsAlways24h UserParameter = "TIMESTAMP_DAY_IS_ALWAYS_24H" UserParameterTimestampInputFormat UserParameter = "TIMESTAMP_INPUT_FORMAT" UserParameterTimestampLTZOutputFormat UserParameter = "TIMESTAMP_LTZ_OUTPUT_FORMAT" UserParameterTimestampNTZOutputFormat UserParameter = "TIMESTAMP_NTZ_OUTPUT_FORMAT" UserParameterTimestampOutputFormat UserParameter = "TIMESTAMP_OUTPUT_FORMAT" UserParameterTimestampTypeMapping UserParameter = "TIMESTAMP_TYPE_MAPPING" UserParameterTimestampTZOutputFormat UserParameter = "TIMESTAMP_TZ_OUTPUT_FORMAT" UserParameterTimezone UserParameter = "TIMEZONE" UserParameterTimeInputFormat UserParameter = "TIME_INPUT_FORMAT" UserParameterTimeOutputFormat UserParameter = "TIME_OUTPUT_FORMAT" UserParameterTransactionDefaultIsolationLevel UserParameter = "TRANSACTION_DEFAULT_ISOLATION_LEVEL" UserParameterTwoDigitCenturyStart UserParameter = "TWO_DIGIT_CENTURY_START" UserParameterUnsupportedDDLAction UserParameter = "UNSUPPORTED_DDL_ACTION" UserParameterUseCachedResult UserParameter = "USE_CACHED_RESULT" UserParameterWeekOfYearPolicy UserParameter = "WEEK_OF_YEAR_POLICY" UserParameterWeekStart UserParameter = "WEEK_START" )
type UserParameters ¶ added in v0.65.0
type UserParameters struct {
EnableUnredactedQuerySyntaxError *bool `ddl:"parameter" db:"ENABLE_UNREDACTED_QUERY_SYNTAX_ERROR"`
}
type UserParametersUnset ¶ added in v0.65.0
type UserParametersUnset struct {
EnableUnredactedQuerySyntaxError *bool `ddl:"keyword" db:"ENABLE_UNREDACTED_QUERY_SYNTAX_ERROR"`
}
type UserShowOptions ¶ added in v0.65.0
type UserShowOptions struct{}
UserShowOptions contains options for listing users.
type Users ¶ added in v0.65.0
type Users interface {
// Create creates a user.
Create(ctx context.Context, id AccountObjectIdentifier, opts *UserCreateOptions) error
// Alter modifies an existing user
Alter(ctx context.Context, id AccountObjectIdentifier, opts *UserAlterOptions) error
// Drop removes a user.
Drop(ctx context.Context, id AccountObjectIdentifier, opts *UserDropOptions) error
// Describe returns the details of a user.
Describe(ctx context.Context, id AccountObjectIdentifier) (*UserDetails, error)
// Show returns a list of users.
Show(ctx context.Context, opts *UserShowOptions) ([]*User, error)
// ShowByID returns a user by ID
ShowByID(ctx context.Context, id AccountObjectIdentifier) (*User, error)
}
type Warehouse ¶
type Warehouse struct {
Name string
State WarehouseState
Type WarehouseType
Size WarehouseSize
MinClusterCount int
MaxClusterCount int
StartedClusters int
Running int
Queued int
IsDefault bool
IsCurrent bool
AutoSuspend int
AutoResume bool
Available float64
Provisioning float64
Quiescing float64
Other float64
CreatedOn time.Time
ResumedOn time.Time
UpdatedOn time.Time
Owner string
Comment string
EnableQueryAcceleration bool
QueryAccelerationMaxScaleFactor int
ResourceMonitor string
ScalingPolicy ScalingPolicy
}
func (*Warehouse) ID ¶
func (v *Warehouse) ID() AccountObjectIdentifier
func (*Warehouse) ObjectType ¶ added in v0.65.0
func (v *Warehouse) ObjectType() ObjectType
type WarehouseAlterOptions ¶
type WarehouseAlterOptions struct {
IfExists *bool `ddl:"keyword" db:"IF EXISTS"`
Suspend *bool `ddl:"keyword" db:"SUSPEND"`
Resume *bool `ddl:"keyword" db:"RESUME"`
IfSuspended *bool `ddl:"keyword" db:"IF SUSPENDED"`
AbortAllQueries *bool `ddl:"keyword" db:"ABORT ALL QUERIES"`
NewName AccountObjectIdentifier `ddl:"identifier" db:"RENAME TO"`
Set *WarehouseSet `ddl:"keyword" db:"SET"`
Unset *WarehouseUnset `ddl:"list,no_parentheses" db:"UNSET"`
// contains filtered or unexported fields
}
type WarehouseCreateOptions ¶
type WarehouseCreateOptions struct {
OrReplace *bool `ddl:"keyword" db:"OR REPLACE"`
IfNotExists *bool `ddl:"keyword" db:"IF NOT EXISTS"`
// Object properties
WarehouseType *WarehouseType `ddl:"parameter,single_quotes" db:"WAREHOUSE_TYPE"`
WarehouseSize *WarehouseSize `ddl:"parameter,single_quotes" db:"WAREHOUSE_SIZE"`
MaxClusterCount *int `ddl:"parameter" db:"MAX_CLUSTER_COUNT"`
MinClusterCount *int `ddl:"parameter" db:"MIN_CLUSTER_COUNT"`
ScalingPolicy *ScalingPolicy `ddl:"parameter,single_quotes" db:"SCALING_POLICY"`
AutoSuspend *int `ddl:"parameter" db:"AUTO_SUSPEND"`
AutoResume *bool `ddl:"parameter" db:"AUTO_RESUME"`
InitiallySuspended *bool `ddl:"parameter" db:"INITIALLY_SUSPENDED"`
ResourceMonitor *string `ddl:"parameter,double_quotes" db:"RESOURCE_MONITOR"`
Comment *string `ddl:"parameter,single_quotes" db:"COMMENT"`
EnableQueryAcceleration *bool `ddl:"parameter" db:"ENABLE_QUERY_ACCELERATION"`
QueryAccelerationMaxScaleFactor *int `ddl:"parameter" db:"QUERY_ACCELERATION_MAX_SCALE_FACTOR"`
// Object params
MaxConcurrencyLevel *int `ddl:"parameter" db:"MAX_CONCURRENCY_LEVEL"`
StatementQueuedTimeoutInSeconds *int `ddl:"parameter" db:"STATEMENT_QUEUED_TIMEOUT_IN_SECONDS"`
StatementTimeoutInSeconds *int `ddl:"parameter" db:"STATEMENT_TIMEOUT_IN_SECONDS"`
Tag []TagAssociation `ddl:"keyword,parentheses" db:"TAG"`
// contains filtered or unexported fields
}
type WarehouseDetails ¶
type WarehouseDropOptions ¶
type WarehouseDropOptions struct {
IfExists *bool `ddl:"keyword" db:"IF EXISTS"`
// contains filtered or unexported fields
}
type WarehouseSet ¶ added in v0.65.0
type WarehouseSet struct {
// Object properties
WarehouseType *WarehouseType `ddl:"parameter,single_quotes" db:"WAREHOUSE_TYPE"`
WarehouseSize *WarehouseSize `ddl:"parameter,single_quotes" db:"WAREHOUSE_SIZE"`
WaitForCompletion *bool `ddl:"parameter" db:"WAIT_FOR_COMPLETION"`
MaxClusterCount *int `ddl:"parameter" db:"MAX_CLUSTER_COUNT"`
MinClusterCount *int `ddl:"parameter" db:"MIN_CLUSTER_COUNT"`
ScalingPolicy *ScalingPolicy `ddl:"parameter,single_quotes" db:"SCALING_POLICY"`
AutoSuspend *int `ddl:"parameter" db:"AUTO_SUSPEND"`
AutoResume *bool `ddl:"parameter" db:"AUTO_RESUME"`
ResourceMonitor AccountObjectIdentifier `ddl:"identifier,equals" db:"RESOURCE_MONITOR"`
Comment *string `ddl:"parameter,single_quotes" db:"COMMENT"`
EnableQueryAcceleration *bool `ddl:"parameter" db:"ENABLE_QUERY_ACCELERATION"`
QueryAccelerationMaxScaleFactor *int `ddl:"parameter" db:"QUERY_ACCELERATION_MAX_SCALE_FACTOR"`
// Object params
MaxConcurrencyLevel *int `ddl:"parameter" db:"MAX_CONCURRENCY_LEVEL"`
StatementQueuedTimeoutInSeconds *int `ddl:"parameter" db:"STATEMENT_QUEUED_TIMEOUT_IN_SECONDS"`
StatementTimeoutInSeconds *int `ddl:"parameter" db:"STATEMENT_TIMEOUT_IN_SECONDS"`
Tag []TagAssociation `ddl:"keyword" db:"TAG"`
}
type WarehouseShowOptions ¶
type WarehouseShowOptions struct {
Like *Like `ddl:"keyword" db:"LIKE"`
// contains filtered or unexported fields
}
type WarehouseSize ¶ added in v0.65.0
type WarehouseSize string
var ( WarehouseSizeXSmall WarehouseSize = "XSMALL" WarehouseSizeSmall WarehouseSize = "SMALL" WarehouseSizeMedium WarehouseSize = "MEDIUM" WarehouseSizeLarge WarehouseSize = "LARGE" WarehouseSizeXLarge WarehouseSize = "XLARGE" WarehouseSizeXXLarge WarehouseSize = "XXLARGE" WarehouseSizeXXXLarge WarehouseSize = "XXXLARGE" WarehouseSizeX4Large WarehouseSize = "X4LARGE" WarehouseSizeX5Large WarehouseSize = "X5LARGE" WarehouseSizeX6Large WarehouseSize = "X6LARGE" )
type WarehouseState ¶ added in v0.65.0
type WarehouseState string
const ( WarehouseStateSuspended WarehouseState = "SUSPENDED" WarehouseStateSuspending WarehouseState = "SUSPENDING" WarehouseStateStarted WarehouseState = "STARTED" WarehouseStateResizing WarehouseState = "RESIZING" WarehouseStateResuming WarehouseState = "RESUMING" )
type WarehouseType ¶ added in v0.65.0
type WarehouseType string
var ( WarehouseTypeStandard WarehouseType = "STANDARD" WarehouseTypeSnowparkOptimized WarehouseType = "SNOWPARK-OPTIMIZED" )
type WarehouseUnset ¶ added in v0.65.0
type WarehouseUnset struct {
// Object properties
WarehouseType *bool `ddl:"keyword" db:"WAREHOUSE_TYPE"`
WarehouseSize *bool `ddl:"keyword" db:"WAREHOUSE_SIZE"`
WaitForCompletion *bool `ddl:"keyword" db:"WAIT_FOR_COMPLETION"`
MaxClusterCount *bool `ddl:"keyword" db:"MAX_CLUSTER_COUNT"`
MinClusterCount *bool `ddl:"keyword" db:"MIN_CLUSTER_COUNT"`
ScalingPolicy *bool `ddl:"keyword" db:"SCALING_POLICY"`
AutoSuspend *bool `ddl:"keyword" db:"AUTO_SUSPEND"`
AutoResume *bool `ddl:"keyword" db:"AUTO_RESUME"`
ResourceMonitor *bool `ddl:"keyword" db:"RESOURCE_MONITOR"`
Comment *bool `ddl:"keyword" db:"COMMENT"`
EnableQueryAcceleration *bool `ddl:"keyword" db:"ENABLE_QUERY_ACCELERATION"`
QueryAccelerationMaxScaleFactor *bool `ddl:"keyword" db:"QUERY_ACCELERATION_MAX_SCALE_FACTOR"`
// Object params
MaxConcurrencyLevel *bool `ddl:"keyword" db:"MAX_CONCURRENCY_LEVEL"`
StatementQueuedTimeoutInSeconds *bool `ddl:"keyword" db:"STATEMENT_QUEUED_TIMEOUT_IN_SECONDS"`
StatementTimeoutInSeconds *bool `ddl:"keyword" db:"STATEMENT_TIMEOUT_IN_SECONDS"`
Tag []ObjectIdentifier `ddl:"keyword" db:"TAG"`
}
type Warehouses ¶
type Warehouses interface {
// Create creates a warehouse.
Create(ctx context.Context, id AccountObjectIdentifier, opts *WarehouseCreateOptions) error
// Alter modifies an existing warehouse
Alter(ctx context.Context, id AccountObjectIdentifier, opts *WarehouseAlterOptions) error
// Drop removes a warehouse.
Drop(ctx context.Context, id AccountObjectIdentifier, opts *WarehouseDropOptions) error
// Show returns a list of warehouses.
Show(ctx context.Context, opts *WarehouseShowOptions) ([]*Warehouse, error)
// ShowByID returns a warehouse by ID
ShowByID(ctx context.Context, id AccountObjectIdentifier) (*Warehouse, error)
// Describe returns the details of a warehouse.
Describe(ctx context.Context, id AccountObjectIdentifier) (*WarehouseDetails, error)
}
Source Files
¶
- accounts.go
- client.go
- comments.go
- common_types.go
- config.go
- context_functions.go
- data_types.go
- databases.go
- errors.go
- failover_groups.go
- grants.go
- identifier_helpers.go
- masking_policy.go
- object_types.go
- parameters.go
- password_policy.go
- privileges.go
- replication_functions.go
- resource_monitors.go
- roles.go
- schemas.go
- session_policies.go
- sessions.go
- shares.go
- sql_builder.go
- sweepers.go
- system_functions.go
- tags.go
- type_helpers.go
- users.go
- validations.go
- warehouses.go