helpers

package
v1.0.1 Latest Latest
Warning

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

 Go to latest Published: Dec 20, 2024 License: MIT Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AssertErrorContainsPartsFunc added in v0.93.0 

func AssertErrorContainsPartsFunc(t *testing.T, parts []string) resource.ErrorCheckFunc

AssertErrorContainsPartsFunc returns a function asserting error message contains each string in parts

func EnsureQuotedIdentifiersIgnoreCaseIsSetToFalse added in v0.92.0 

func EnsureQuotedIdentifiersIgnoreCaseIsSetToFalse(client *sdk.Client, ctx context.Context) error

func EnsureScimProvisionerRolesExist added in v0.93.0 

func EnsureScimProvisionerRolesExist(client *sdk.Client, ctx context.Context) error

func FindParameter added in v0.93.0 

func FindParameter[T ~string](t *testing.T, parameters []*sdk.Parameter, parameter T) *sdk.Parameter

func FullInvalidTomlConfigForServiceUser added in v1.0.0 

func FullInvalidTomlConfigForServiceUser(t *testing.T, profile string) string

FullInvalidTomlConfigForServiceUser is a temporary function used to test provider configuration

func FullTomlConfigForServiceUser added in v1.0.0 

func FullTomlConfigForServiceUser(t *testing.T, profile string, userId sdk.AccountObjectIdentifier, roleId sdk.AccountObjectIdentifier, warehouseId sdk.AccountObjectIdentifier, accountIdentifier sdk.AccountIdentifier, privateKey string) string

FullTomlConfigForServiceUser is a temporary function used to test provider configuration TODO [SNOW-1827309]: use toml marshaling from "github.com/pelletier/go-toml/v2" TODO [SNOW-1827309]: add builders for our toml config struct

func TomlConfigForLegacyServiceUser added in v1.0.0 

func TomlConfigForLegacyServiceUser(t *testing.T, profile string, userId sdk.AccountObjectIdentifier, roleId sdk.AccountObjectIdentifier, warehouseId sdk.AccountObjectIdentifier, accountIdentifier sdk.AccountIdentifier, pass string) string

TomlConfigForLegacyServiceUser is a temporary function used to test provider configuration

func TomlConfigForServiceUser added in v1.0.0 

func TomlConfigForServiceUser(t *testing.T, profile string, userId sdk.AccountObjectIdentifier, roleId sdk.AccountObjectIdentifier, warehouseId sdk.AccountObjectIdentifier, accountIdentifier sdk.AccountIdentifier, privateKey string) string

TomlConfigForServiceUser is a temporary function used to test provider configuration

func TomlConfigForServiceUserWithEncryptedKey added in v1.0.0 

func TomlConfigForServiceUserWithEncryptedKey(t *testing.T, profile string, userId sdk.AccountObjectIdentifier, roleId sdk.AccountObjectIdentifier, warehouseId sdk.AccountObjectIdentifier, accountIdentifier sdk.AccountIdentifier, privateKey string, pass string) string

TomlConfigForServiceUserWithEncryptedKey is a temporary function used to test provider configuration

func TomlIncorrectConfigForServiceUser added in v1.0.0 

func TomlIncorrectConfigForServiceUser(t *testing.T, profile string, accountIdentifier sdk.AccountIdentifier) string

TomlIncorrectConfigForServiceUser is a temporary function used to test provider configuration

Types

type AccountClient 

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

func NewAccountClient 

func NewAccountClient(context *TestClientContext, idsGenerator *IdsGenerator) *AccountClient

func (*AccountClient) Alter added in v1.0.0 

func (c *AccountClient) Alter(t *testing.T, opts *sdk.AlterAccountOptions)

func (*AccountClient) Create added in v1.0.0 

func (c *AccountClient) Create(t *testing.T) (*sdk.Account, func())

func (*AccountClient) CreateAndLogIn added in v1.0.0 

func (c *AccountClient) CreateAndLogIn(t *testing.T) (*sdk.Account, *sdk.Client, func())

func (*AccountClient) CreateWithRequest added in v1.0.0 

func (c *AccountClient) CreateWithRequest(t *testing.T, id sdk.AccountObjectIdentifier, opts *sdk.CreateAccountOptions) (*sdk.Account, func())

func (*AccountClient) Drop added in v1.0.0 

func (c *AccountClient) Drop(t *testing.T, id sdk.AccountObjectIdentifier) error

func (*AccountClient) DropFunc added in v1.0.0 

func (c *AccountClient) DropFunc(t *testing.T, id sdk.AccountObjectIdentifier) func()

func (*AccountClient) GetAccountIdentifier 

func (c *AccountClient) GetAccountIdentifier(t *testing.T) sdk.AccountIdentifier

GetAccountIdentifier gets the account identifier from Snowflake API, by fetching the account locator and by filtering the list of accounts in replication accounts by it (because there is no direct way to get).

func (*AccountClient) Show added in v1.0.0 

func (c *AccountClient) Show(t *testing.T, id sdk.AccountObjectIdentifier) (*sdk.Account, error)

func (*AccountClient) ShowRegions added in v1.0.0 

func (c *AccountClient) ShowRegions(t *testing.T) []Region

type AggregationPolicyClient added in v0.95.0 

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

TODO(SNOW-1564954): change raw sqls to proper client

func NewAggregationPolicyClient added in v0.95.0 

func NewAggregationPolicyClient(context *TestClientContext, idsGenerator *IdsGenerator) *AggregationPolicyClient

func (*AggregationPolicyClient) CreateAggregationPolicy added in v0.95.0 

func (c *AggregationPolicyClient) CreateAggregationPolicy(t *testing.T) (sdk.SchemaObjectIdentifier, func())

func (*AggregationPolicyClient) DropAggregationPolicyFunc added in v0.95.0 

func (c *AggregationPolicyClient) DropAggregationPolicyFunc(t *testing.T, id sdk.SchemaObjectIdentifier) func()

type AlertClient 

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

func NewAlertClient 

func NewAlertClient(context *TestClientContext, idsGenerator *IdsGenerator) *AlertClient

func (*AlertClient) CreateAlert 

func (c *AlertClient) CreateAlert(t *testing.T) (*sdk.Alert, func())

func (*AlertClient) CreateAlertWithOptions 

func (c *AlertClient) CreateAlertWithOptions(t *testing.T, schedule string, condition string, action string, opts *sdk.CreateAlertOptions) (*sdk.Alert, func())

func (*AlertClient) DropAlertFunc 

func (c *AlertClient) DropAlertFunc(t *testing.T, id sdk.SchemaObjectIdentifier) func()

type ApiIntegrationClient 

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

func NewApiIntegrationClient 

func NewApiIntegrationClient(context *TestClientContext, idsGenerator *IdsGenerator) *ApiIntegrationClient

func (*ApiIntegrationClient) CreateApiIntegration 

func (c *ApiIntegrationClient) CreateApiIntegration(t *testing.T) (*sdk.ApiIntegration, func())

func (*ApiIntegrationClient) DropApiIntegrationFunc 

func (c *ApiIntegrationClient) DropApiIntegrationFunc(t *testing.T, id sdk.AccountObjectIdentifier) func()

type ApplicationClient 

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

func NewApplicationClient 

func NewApplicationClient(context *TestClientContext, idsGenerator *IdsGenerator) *ApplicationClient

func (*ApplicationClient) CreateApplication 

func (c *ApplicationClient) CreateApplication(t *testing.T, packageId sdk.AccountObjectIdentifier, version string) (*sdk.Application, func())

func (*ApplicationClient) DropApplicationFunc 

func (c *ApplicationClient) DropApplicationFunc(t *testing.T, id sdk.AccountObjectIdentifier) func()

type ApplicationPackageClient 

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

func NewApplicationPackageClient 

func NewApplicationPackageClient(context *TestClientContext, idsGenerator *IdsGenerator) *ApplicationPackageClient

func (*ApplicationPackageClient) AddApplicationPackageVersion 

func (c *ApplicationPackageClient) AddApplicationPackageVersion(t *testing.T, id sdk.AccountObjectIdentifier, stageId sdk.SchemaObjectIdentifier, versionName string)

func (*ApplicationPackageClient) CreateApplicationPackage 

func (c *ApplicationPackageClient) CreateApplicationPackage(t *testing.T) (*sdk.ApplicationPackage, func())

func (*ApplicationPackageClient) DropApplicationPackageFunc 

func (c *ApplicationPackageClient) DropApplicationPackageFunc(t *testing.T, id sdk.AccountObjectIdentifier) func()

func (*ApplicationPackageClient) ShowVersions 

func (c *ApplicationPackageClient) ShowVersions(t *testing.T, id sdk.AccountObjectIdentifier) []ApplicationPackageVersion

type ApplicationPackageVersion 

type ApplicationPackageVersion struct {
	Version string `json:"version"`
	Patch   int    `json:"patch"`
}

type AuthenticationPolicyClient added in v0.96.0 

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

func NewAuthenticationPolicyClient added in v0.96.0 

func NewAuthenticationPolicyClient(context *TestClientContext, idsGenerator *IdsGenerator) *AuthenticationPolicyClient

func (*AuthenticationPolicyClient) Create added in v0.96.0 

func (c *AuthenticationPolicyClient) Create(t *testing.T) (*sdk.AuthenticationPolicy, func())

func (*AuthenticationPolicyClient) CreateWithOptions added in v0.96.0 

func (c *AuthenticationPolicyClient) CreateWithOptions(t *testing.T, id sdk.SchemaObjectIdentifier, request *sdk.CreateAuthenticationPolicyRequest) (*sdk.AuthenticationPolicy, func())

func (*AuthenticationPolicyClient) DropFunc added in v0.96.0 

func (c *AuthenticationPolicyClient) DropFunc(t *testing.T, id sdk.SchemaObjectIdentifier) func()

func (*AuthenticationPolicyClient) Show added in v0.96.0 

func (c *AuthenticationPolicyClient) Show(t *testing.T, id sdk.SchemaObjectIdentifier) (*sdk.AuthenticationPolicy, error)

type BcrBundlesClient added in v0.95.0 

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

func NewBcrBundlesClient added in v0.95.0 

func NewBcrBundlesClient(context *TestClientContext) *BcrBundlesClient

func (*BcrBundlesClient) DisableBcrBundleFunc added in v0.95.0 

func (c *BcrBundlesClient) DisableBcrBundleFunc(t *testing.T, name string) func()

func (*BcrBundlesClient) EnableBcrBundle added in v0.95.0 

func (c *BcrBundlesClient) EnableBcrBundle(t *testing.T, name string)

type CatalogIntegrationClient added in v0.92.0 

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

func NewCatalogIntegrationClient added in v0.92.0 

func NewCatalogIntegrationClient(context *TestClientContext, idsGenerator *IdsGenerator) *CatalogIntegrationClient

func (*CatalogIntegrationClient) Create added in v0.92.0 

func (c *CatalogIntegrationClient) Create(t *testing.T) (sdk.AccountObjectIdentifier, func())

TODO(SNOW-999142): Use SDK implementation for Catalog once it's available

func (*CatalogIntegrationClient) DropFunc added in v0.92.0 

func (c *CatalogIntegrationClient) DropFunc(t *testing.T, id sdk.AccountObjectIdentifier) func()

type ComputePoolClient added in v0.98.0 

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

TODO [SNOW-1790174]: change raw sqls to proper client

func NewComputePoolClient added in v0.98.0 

func NewComputePoolClient(context *TestClientContext, idsGenerator *IdsGenerator) *ComputePoolClient

func (*ComputePoolClient) CreateComputePool added in v0.98.0 

func (c *ComputePoolClient) CreateComputePool(t *testing.T) (sdk.AccountObjectIdentifier, func())

func (*ComputePoolClient) DropComputePoolFunc added in v0.98.0 

func (c *ComputePoolClient) DropComputePoolFunc(t *testing.T, id sdk.AccountObjectIdentifier) func()

type ConnectionClient added in v0.98.0 

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

func NewConnectionClient added in v0.98.0 

func NewConnectionClient(context *TestClientContext, idsGenerator *IdsGenerator) *ConnectionClient

func (*ConnectionClient) Alter added in v0.98.0 

func (c *ConnectionClient) Alter(t *testing.T, req *sdk.AlterConnectionRequest)

func (*ConnectionClient) Create added in v0.98.0 

func (c *ConnectionClient) Create(t *testing.T, id sdk.AccountObjectIdentifier) (*sdk.Connection, func())

func (*ConnectionClient) CreateReplication added in v0.98.0 

func (c *ConnectionClient) CreateReplication(t *testing.T, id sdk.AccountObjectIdentifier, replicaOf sdk.ExternalObjectIdentifier) (*sdk.Connection, func())

func (*ConnectionClient) DropFunc added in v0.98.0 

func (c *ConnectionClient) DropFunc(t *testing.T, id sdk.AccountObjectIdentifier) func()

func (*ConnectionClient) GetConnectionUrl added in v0.98.0 

func (c *ConnectionClient) GetConnectionUrl(organizationName, objectName string) string

func (*ConnectionClient) Show added in v0.98.0 

func (c *ConnectionClient) Show(t *testing.T, id sdk.AccountObjectIdentifier) (*sdk.Connection, error)

type ContextClient 

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

func NewContextClient 

func NewContextClient(context *TestClientContext) *ContextClient

func (*ContextClient) ACSURL added in v0.92.0 

func (c *ContextClient) ACSURL(t *testing.T) string

ACSURL returns Snowflake Assertion Consumer Service URL

func (*ContextClient) CurrentAccount 

func (c *ContextClient) CurrentAccount(t *testing.T) string

func (*ContextClient) CurrentAccountId added in v1.0.0 

func (c *ContextClient) CurrentAccountId(t *testing.T) sdk.AccountIdentifier

func (*ContextClient) CurrentAccountIdentifier added in v0.99.0 

func (c *ContextClient) CurrentAccountIdentifier(t *testing.T) sdk.AccountIdentifier

func (*ContextClient) CurrentAccountName added in v1.0.0 

func (c *ContextClient) CurrentAccountName(t *testing.T) string

func (*ContextClient) CurrentRegion 

func (c *ContextClient) CurrentRegion(t *testing.T) string

func (*ContextClient) CurrentRole 

func (c *ContextClient) CurrentRole(t *testing.T) sdk.AccountObjectIdentifier

func (*ContextClient) CurrentUser 

func (c *ContextClient) CurrentUser(t *testing.T) sdk.AccountObjectIdentifier

func (*ContextClient) IsRoleInSession 

func (c *ContextClient) IsRoleInSession(t *testing.T, id sdk.AccountObjectIdentifier) bool

func (*ContextClient) IssuerURL added in v0.92.0 

func (c *ContextClient) IssuerURL(t *testing.T) string

IssuerURL returns a URL containing the EntityID / Issuer for the Snowflake service provider

func (*ContextClient) LastQueryId added in v0.97.0 

func (c *ContextClient) LastQueryId(t *testing.T) string

type CortexSearchServiceClient added in v0.93.0 

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

func NewCortexSearchServiceClient added in v0.93.0 

func NewCortexSearchServiceClient(context *TestClientContext, idsGenerator *IdsGenerator) *CortexSearchServiceClient

func (*CortexSearchServiceClient) CreateCortexSearchService added in v0.93.0 

func (c *CortexSearchServiceClient) CreateCortexSearchService(t *testing.T, tableId sdk.SchemaObjectIdentifier) (*sdk.CortexSearchService, func())

func (*CortexSearchServiceClient) CreateCortexSearchServiceWithOptions added in v0.93.0 

func (c *CortexSearchServiceClient) CreateCortexSearchServiceWithOptions(t *testing.T, id sdk.SchemaObjectIdentifier, warehouseId sdk.AccountObjectIdentifier, tableId sdk.SchemaObjectIdentifier, column string) (*sdk.CortexSearchService, func())

func (*CortexSearchServiceClient) DropCortexSearchServiceFunc added in v0.93.0 

func (c *CortexSearchServiceClient) DropCortexSearchServiceFunc(t *testing.T, id sdk.SchemaObjectIdentifier) func()

type DataMetricFunctionClient added in v0.95.0 

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

TODO(SNOW-1564959): change raw sqls to proper client

func NewDataMetricFunctionClient added in v0.95.0 

func NewDataMetricFunctionClient(context *TestClientContext, idsGenerator *IdsGenerator) *DataMetricFunctionClient

func (*DataMetricFunctionClient) CreateDataMetricFunction added in v0.95.0 

func (c *DataMetricFunctionClient) CreateDataMetricFunction(t *testing.T, viewID sdk.SchemaObjectIdentifier) (sdk.SchemaObjectIdentifier, func())

func (*DataMetricFunctionClient) DropDataMetricFunctionFunc added in v0.95.0 

func (c *DataMetricFunctionClient) DropDataMetricFunctionFunc(t *testing.T, id sdk.SchemaObjectIdentifier) func()

type DataMetricFunctionReferencesClient added in v0.95.0 

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

func NewDataMetricFunctionReferencesClient added in v0.95.0 

func NewDataMetricFunctionReferencesClient(context *TestClientContext) *DataMetricFunctionReferencesClient

func (*DataMetricFunctionReferencesClient) GetDataMetricFunctionReferences added in v0.95.0 

func (c *DataMetricFunctionReferencesClient) GetDataMetricFunctionReferences(t *testing.T, id sdk.SchemaObjectIdentifier, domain sdk.DataMetricFuncionRefEntityDomainOption) []sdk.DataMetricFunctionReference

GetDataMetricFunctionReferences is based on https://docs.snowflake.com/en/sql-reference/functions/data_metric_function_references.

type DatabaseClient 

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

func NewDatabaseClient 

func NewDatabaseClient(context *TestClientContext, idsGenerator *IdsGenerator) *DatabaseClient

func (*DatabaseClient) Alter added in v0.98.0 

func (c *DatabaseClient) Alter(t *testing.T, id sdk.AccountObjectIdentifier, opts *sdk.AlterDatabaseOptions)

func (*DatabaseClient) CreateDatabase 

func (c *DatabaseClient) CreateDatabase(t *testing.T) (*sdk.Database, func())

func (*DatabaseClient) CreateDatabaseFromShareTemporarily added in v0.96.0 

func (c *DatabaseClient) CreateDatabaseFromShareTemporarily(t *testing.T, externalShareId sdk.ExternalObjectIdentifier)

TODO [SNOW-1562172]: Create a better solution for this type of situations We have to create test database from share before the actual test to check if the newly created share is ready after previous test (there's some kind of issue or delay between cleaning up a share and creating a new one right after).

func (*DatabaseClient) CreateDatabaseWithIdentifier added in v0.92.0 

func (c *DatabaseClient) CreateDatabaseWithIdentifier(t *testing.T, id sdk.AccountObjectIdentifier) (*sdk.Database, func())

func (*DatabaseClient) CreateDatabaseWithOptions 

func (c *DatabaseClient) CreateDatabaseWithOptions(t *testing.T, id sdk.AccountObjectIdentifier, opts *sdk.CreateDatabaseOptions) (*sdk.Database, func())

func (*DatabaseClient) CreatePrimaryDatabase added in v0.92.0 

func (c *DatabaseClient) CreatePrimaryDatabase(t *testing.T, enableReplicationTo []sdk.AccountIdentifier) (*sdk.Database, sdk.ExternalObjectIdentifier, func())

func (*DatabaseClient) CreateSecondaryDatabaseWithOptions 

func (c *DatabaseClient) CreateSecondaryDatabaseWithOptions(t *testing.T, id sdk.AccountObjectIdentifier, externalId sdk.ExternalObjectIdentifier, opts *sdk.CreateSecondaryDatabaseOptions) (*sdk.Database, func())

func (*DatabaseClient) Describe added in v0.95.0 

func (c *DatabaseClient) Describe(t *testing.T, id sdk.AccountObjectIdentifier) (*sdk.DatabaseDetails, error)

func (*DatabaseClient) DropDatabase added in v0.95.0 

func (c *DatabaseClient) DropDatabase(t *testing.T, id sdk.AccountObjectIdentifier) error

func (*DatabaseClient) DropDatabaseFunc 

func (c *DatabaseClient) DropDatabaseFunc(t *testing.T, id sdk.AccountObjectIdentifier) func()

func (*DatabaseClient) Show 

func (c *DatabaseClient) Show(t *testing.T, id sdk.AccountObjectIdentifier) (*sdk.Database, error)

func (*DatabaseClient) ShowAllReplicationDatabases added in v0.96.0 

func (c *DatabaseClient) ShowAllReplicationDatabases(t *testing.T) ([]sdk.ReplicationDatabase, error)

func (*DatabaseClient) UnsetCatalog added in v0.93.0 

func (c *DatabaseClient) UnsetCatalog(t *testing.T, id sdk.AccountObjectIdentifier)

func (*DatabaseClient) UpdateDataRetentionTime 

func (c *DatabaseClient) UpdateDataRetentionTime(t *testing.T, id sdk.AccountObjectIdentifier, days int)

type DatabaseRoleClient 

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

func NewDatabaseRoleClient 

func NewDatabaseRoleClient(context *TestClientContext, idsGenerator *IdsGenerator) *DatabaseRoleClient

func (*DatabaseRoleClient) CleanupDatabaseRoleFunc 

func (c *DatabaseRoleClient) CleanupDatabaseRoleFunc(t *testing.T, id sdk.DatabaseObjectIdentifier) func()

func (*DatabaseRoleClient) CreateDatabaseRole 

func (c *DatabaseRoleClient) CreateDatabaseRole(t *testing.T) (*sdk.DatabaseRole, func())

func (*DatabaseRoleClient) CreateDatabaseRoleInDatabase 

func (c *DatabaseRoleClient) CreateDatabaseRoleInDatabase(t *testing.T, databaseId sdk.AccountObjectIdentifier) (*sdk.DatabaseRole, func())

func (*DatabaseRoleClient) CreateDatabaseRoleInDatabaseWithName 

func (c *DatabaseRoleClient) CreateDatabaseRoleInDatabaseWithName(t *testing.T, databaseId sdk.AccountObjectIdentifier, name string) (*sdk.DatabaseRole, func())

func (*DatabaseRoleClient) CreateDatabaseRoleWithName 

func (c *DatabaseRoleClient) CreateDatabaseRoleWithName(t *testing.T, name string) (*sdk.DatabaseRole, func())

func (*DatabaseRoleClient) Show added in v0.95.0 

func (c *DatabaseRoleClient) Show(t *testing.T, id sdk.DatabaseObjectIdentifier) (*sdk.DatabaseRole, error)

type DynamicTableClient 

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

func NewDynamicTableClient 

func NewDynamicTableClient(context *TestClientContext, idsGenerator *IdsGenerator) *DynamicTableClient

func (*DynamicTableClient) CreateDynamicTable 

func (c *DynamicTableClient) CreateDynamicTable(t *testing.T, tableId sdk.SchemaObjectIdentifier) (*sdk.DynamicTable, func())

func (*DynamicTableClient) CreateDynamicTableWithOptions 

func (c *DynamicTableClient) CreateDynamicTableWithOptions(t *testing.T, id sdk.SchemaObjectIdentifier, warehouseId sdk.AccountObjectIdentifier, tableId sdk.SchemaObjectIdentifier) (*sdk.DynamicTable, func())

func (*DynamicTableClient) DropDynamicTableFunc 

func (c *DynamicTableClient) DropDynamicTableFunc(t *testing.T, id sdk.SchemaObjectIdentifier) func()

type EventTableClient added in v0.99.0 

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

func NewEventTableClient added in v0.99.0 

func NewEventTableClient(context *TestClientContext, idsGenerator *IdsGenerator) *EventTableClient

func (*EventTableClient) Create added in v0.99.0 

func (c *EventTableClient) Create(t *testing.T) (*sdk.EventTable, func())

func (*EventTableClient) DropFunc added in v0.99.0 

func (c *EventTableClient) DropFunc(t *testing.T, id sdk.SchemaObjectIdentifier) func()

type ExternalAccessIntegrationClient added in v0.94.0 

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

TODO(SNOW-1325215): change raw sqls to proper client

func NewExternalAccessIntegrationClient added in v0.94.0 

func NewExternalAccessIntegrationClient(context *TestClientContext, idsGenerator *IdsGenerator) *ExternalAccessIntegrationClient

func (*ExternalAccessIntegrationClient) CreateExternalAccessIntegration added in v0.94.0 

func (c *ExternalAccessIntegrationClient) CreateExternalAccessIntegration(t *testing.T, networkRuleId sdk.SchemaObjectIdentifier) (sdk.AccountObjectIdentifier, func())

func (*ExternalAccessIntegrationClient) CreateExternalAccessIntegrationWithNetworkRuleAndSecret added in v1.0.0 

func (c *ExternalAccessIntegrationClient) CreateExternalAccessIntegrationWithNetworkRuleAndSecret(t *testing.T, networkRuleId sdk.SchemaObjectIdentifier, secretId sdk.SchemaObjectIdentifier) (sdk.AccountObjectIdentifier, func())

func (*ExternalAccessIntegrationClient) DropExternalAccessIntegrationFunc added in v0.94.0 

func (c *ExternalAccessIntegrationClient) DropExternalAccessIntegrationFunc(t *testing.T, id sdk.AccountObjectIdentifier) func()

type ExternalFunctionClient added in v0.95.0 

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

func NewExternalFunctionClient added in v0.95.0 

func NewExternalFunctionClient(context *TestClientContext, idsGenerator *IdsGenerator) *ExternalFunctionClient

func (*ExternalFunctionClient) Create added in v0.95.0 

func (c *ExternalFunctionClient) Create(t *testing.T, apiIntegrationId sdk.AccountObjectIdentifier, arguments ...sdk.DataType) *sdk.ExternalFunction

func (*ExternalFunctionClient) CreateWithIdentifier added in v0.95.0 

func (c *ExternalFunctionClient) CreateWithIdentifier(t *testing.T, apiIntegrationId sdk.AccountObjectIdentifier, id sdk.SchemaObjectIdentifierWithArguments) *sdk.ExternalFunction

type ExternalTableClient added in v0.96.0 

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

func NewExternalTableClient added in v0.96.0 

func NewExternalTableClient(context *TestClientContext, idsGenerator *IdsGenerator) *ExternalTableClient

func (*ExternalTableClient) CreateInSchemaWithLocation added in v0.98.0 

func (c *ExternalTableClient) CreateInSchemaWithLocation(t *testing.T, location string, schemaId sdk.DatabaseObjectIdentifier) (*sdk.ExternalTable, func())

func (*ExternalTableClient) CreateWithLocation added in v0.97.0 

func (c *ExternalTableClient) CreateWithLocation(t *testing.T, location string) (*sdk.ExternalTable, func())

func (*ExternalTableClient) CreateWithRequest added in v0.97.0 

func (c *ExternalTableClient) CreateWithRequest(t *testing.T, req *sdk.CreateExternalTableRequest) (*sdk.ExternalTable, func())

func (*ExternalTableClient) DropFunc added in v0.97.0 

func (c *ExternalTableClient) DropFunc(t *testing.T, id sdk.SchemaObjectIdentifier) func()

func (*ExternalTableClient) PublishDataToStage added in v0.96.0 

func (c *ExternalTableClient) PublishDataToStage(t *testing.T, stageId sdk.SchemaObjectIdentifier, data []byte)

type ExternalVolumeClient added in v0.92.0 

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

func NewExternalVolumeClient added in v0.92.0 

func NewExternalVolumeClient(context *TestClientContext, idsGenerator *IdsGenerator) *ExternalVolumeClient

func (*ExternalVolumeClient) Alter added in v0.98.0 

func (c *ExternalVolumeClient) Alter(t *testing.T, req *sdk.AlterExternalVolumeRequest)

func (*ExternalVolumeClient) Create added in v0.92.0 

func (c *ExternalVolumeClient) Create(t *testing.T) (sdk.AccountObjectIdentifier, func())

TODO(SNOW-999142): Switch to returning *sdk.ExternalVolume. Need to update existing acceptance tests for this.

func (*ExternalVolumeClient) DropFunc added in v0.92.0 

func (c *ExternalVolumeClient) DropFunc(t *testing.T, id sdk.AccountObjectIdentifier) func()

type FailoverGroupClient 

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

func NewFailoverGroupClient 

func NewFailoverGroupClient(context *TestClientContext, idsGenerator *IdsGenerator) *FailoverGroupClient

func (*FailoverGroupClient) CreateFailoverGroup 

func (c *FailoverGroupClient) CreateFailoverGroup(t *testing.T) (*sdk.FailoverGroup, func())

func (*FailoverGroupClient) CreateFailoverGroupWithOptions 

func (c *FailoverGroupClient) CreateFailoverGroupWithOptions(t *testing.T, objectTypes []sdk.PluralObjectType, allowedAccounts []sdk.AccountIdentifier, opts *sdk.CreateFailoverGroupOptions) (*sdk.FailoverGroup, func())

func (*FailoverGroupClient) DropFailoverGroupFunc 

func (c *FailoverGroupClient) DropFailoverGroupFunc(t *testing.T, id sdk.AccountObjectIdentifier) func()

type FileFormatClient 

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

func NewFileFormatClient 

func NewFileFormatClient(context *TestClientContext, idsGenerator *IdsGenerator) *FileFormatClient

func (*FileFormatClient) CreateFileFormat 

func (c *FileFormatClient) CreateFileFormat(t *testing.T) (*sdk.FileFormat, func())

func (*FileFormatClient) CreateFileFormatWithOptions 

func (c *FileFormatClient) CreateFileFormatWithOptions(t *testing.T, opts *sdk.CreateFileFormatOptions) (*sdk.FileFormat, func())

func (*FileFormatClient) DropFileFormatFunc 

func (c *FileFormatClient) DropFileFormatFunc(t *testing.T, id sdk.SchemaObjectIdentifier) func()

type FunctionClient added in v0.95.0 

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

func NewFunctionClient added in v0.95.0 

func NewFunctionClient(context *TestClientContext, idsGenerator *IdsGenerator) *FunctionClient

func (*FunctionClient) Create added in v0.95.0 

func (c *FunctionClient) Create(t *testing.T, arguments ...sdk.DataType) *sdk.Function

func (*FunctionClient) CreateJava added in v1.0.0 

func (c *FunctionClient) CreateJava(t *testing.T) (*sdk.Function, func())

func (*FunctionClient) CreateScalaStaged added in v1.0.0 

func (c *FunctionClient) CreateScalaStaged(t *testing.T, id sdk.SchemaObjectIdentifierWithArguments, dataType datatypes.DataType, importPath string, handler string) (*sdk.Function, func())

func (*FunctionClient) CreateSecure added in v0.95.0 

func (c *FunctionClient) CreateSecure(t *testing.T, arguments ...sdk.DataType) *sdk.Function

TODO [SNOW-1850370]: improve this helper (all other types creation)

func (*FunctionClient) CreateSql added in v1.0.0 

func (c *FunctionClient) CreateSql(t *testing.T) (*sdk.Function, func())

func (*FunctionClient) CreateSqlNoArgs added in v1.0.0 

func (c *FunctionClient) CreateSqlNoArgs(t *testing.T) (*sdk.Function, func())

func (*FunctionClient) CreateSqlWithIdentifierAndArgument added in v1.0.0 

func (c *FunctionClient) CreateSqlWithIdentifierAndArgument(t *testing.T, id sdk.SchemaObjectIdentifier, dataType datatypes.DataType) (*sdk.Function, func())

func (*FunctionClient) CreateWithIdentifier added in v0.95.0 

func (c *FunctionClient) CreateWithIdentifier(t *testing.T, id sdk.SchemaObjectIdentifierWithArguments) *sdk.Function

func (*FunctionClient) CreateWithRequest added in v0.95.0 

func (c *FunctionClient) CreateWithRequest(t *testing.T, id sdk.SchemaObjectIdentifierWithArguments, req *sdk.CreateForSQLFunctionRequest) *sdk.Function

func (*FunctionClient) DescribeDetails added in v1.0.0 

func (c *FunctionClient) DescribeDetails(t *testing.T, id sdk.SchemaObjectIdentifierWithArguments) (*sdk.FunctionDetails, error)

func (*FunctionClient) DropFunctionFunc added in v0.98.0 

func (c *FunctionClient) DropFunctionFunc(t *testing.T, id sdk.SchemaObjectIdentifierWithArguments) func()

func (*FunctionClient) PythonIdentityDefinition added in v1.0.0 

func (c *FunctionClient) PythonIdentityDefinition(t *testing.T, funcName string, argName string) string

func (*FunctionClient) SampleJavaDefinition added in v1.0.0 

func (c *FunctionClient) SampleJavaDefinition(t *testing.T, className string, funcName string, argName string) string

func (*FunctionClient) SampleJavaDefinitionNoArgs added in v1.0.0 

func (c *FunctionClient) SampleJavaDefinitionNoArgs(t *testing.T, className string, funcName string) string

func (*FunctionClient) SampleJavascriptDefinition added in v1.0.0 

func (c *FunctionClient) SampleJavascriptDefinition(t *testing.T, argName string) string

func (*FunctionClient) SampleJavascriptDefinitionNoArgs added in v1.0.0 

func (c *FunctionClient) SampleJavascriptDefinitionNoArgs(t *testing.T) string

func (*FunctionClient) SamplePythonDefinition added in v1.0.0 

func (c *FunctionClient) SamplePythonDefinition(t *testing.T, funcName string, argName string) string

func (*FunctionClient) SampleScalaDefinition added in v1.0.0 

func (c *FunctionClient) SampleScalaDefinition(t *testing.T, className string, funcName string, argName string) string

func (*FunctionClient) SampleSqlDefinition added in v1.0.0 

func (c *FunctionClient) SampleSqlDefinition(t *testing.T) string

TODO [SNOW-1850370]: use input argument like in other samples

func (*FunctionClient) SampleSqlDefinitionWithArgument added in v1.0.0 

func (c *FunctionClient) SampleSqlDefinitionWithArgument(t *testing.T, argName string) string

func (*FunctionClient) Show added in v1.0.0 

func (c *FunctionClient) Show(t *testing.T, id sdk.SchemaObjectIdentifierWithArguments) (*sdk.Function, error)

type GrantClient added in v0.95.0 

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

func NewGrantClient added in v0.95.0 

func NewGrantClient(context *TestClientContext, idsGenerator *IdsGenerator) *GrantClient

func (*GrantClient) GrantOnSchemaToAccountRole added in v0.95.0 

func (c *GrantClient) GrantOnSchemaToAccountRole(t *testing.T, schemaId sdk.DatabaseObjectIdentifier, accountRoleId sdk.AccountObjectIdentifier, privileges ...sdk.SchemaPrivilege)

func (*GrantClient) GrantOwnershipOnSchemaObjectToAccountRole added in v0.96.0 

func (c *GrantClient) GrantOwnershipOnSchemaObjectToAccountRole(
	t *testing.T,
	accountRoleId sdk.AccountObjectIdentifier,
	objectType sdk.ObjectType,
	objectId sdk.SchemaObjectIdentifier,
	outboundPrivileges sdk.OwnershipCurrentGrantsOutboundPrivileges,
)

func (*GrantClient) GrantOwnershipToAccountRole added in v0.96.0 

func (c *GrantClient) GrantOwnershipToAccountRole(
	t *testing.T,
	accountRoleId sdk.AccountObjectIdentifier,
	objectType sdk.ObjectType,
	objectName sdk.ObjectIdentifier,
)

func (*GrantClient) GrantPrivilegeOnDatabaseToShare added in v0.96.0 

func (c *GrantClient) GrantPrivilegeOnDatabaseToShare(
	t *testing.T,
	databaseId sdk.AccountObjectIdentifier,
	shareId sdk.AccountObjectIdentifier,
	privileges []sdk.ObjectPrivilege,
) func()

func (*GrantClient) GrantPrivilegesOnDatabaseToAccountRole added in v1.0.0 

func (c *GrantClient) GrantPrivilegesOnDatabaseToAccountRole(
	t *testing.T,
	accountRoleId sdk.AccountObjectIdentifier,
	databaseId sdk.AccountObjectIdentifier,
	privileges []sdk.AccountObjectPrivilege,
	withGrantOption bool,
)

func (*GrantClient) GrantPrivilegesOnDatabaseToDatabaseRole added in v0.96.0 

func (c *GrantClient) GrantPrivilegesOnDatabaseToDatabaseRole(
	t *testing.T,
	databaseRoleId sdk.DatabaseObjectIdentifier,
	databaseId sdk.AccountObjectIdentifier,
	privileges []sdk.AccountObjectPrivilege,
	withGrantOption bool,
)

func (*GrantClient) GrantPrivilegesOnSchemaObjectToAccountRole added in v0.96.0 

func (c *GrantClient) GrantPrivilegesOnSchemaObjectToAccountRole(
	t *testing.T,
	accountRoleId sdk.AccountObjectIdentifier,
	objectType sdk.ObjectType,
	schemaObjectIdentifier sdk.SchemaObjectIdentifier,
	privileges []sdk.SchemaObjectPrivilege,
	withGrantOption bool,
)

func (*GrantClient) GrantPrivilegesOnWarehouseToAccountRole added in v1.0.0 

func (c *GrantClient) GrantPrivilegesOnWarehouseToAccountRole(
	t *testing.T,
	accountRoleId sdk.AccountObjectIdentifier,
	warehouseId sdk.AccountObjectIdentifier,
	privileges []sdk.AccountObjectPrivilege,
	withGrantOption bool,
)

func (*GrantClient) RevokePrivilegeOnDatabaseFromShare added in v0.96.0 

func (c *GrantClient) RevokePrivilegeOnDatabaseFromShare(
	t *testing.T,
	databaseId sdk.AccountObjectIdentifier,
	shareId sdk.AccountObjectIdentifier,
	privileges []sdk.ObjectPrivilege,
)

func (*GrantClient) RevokePrivilegesOnDatabaseFromDatabaseRole added in v0.96.0 

func (c *GrantClient) RevokePrivilegesOnDatabaseFromDatabaseRole(
	t *testing.T,
	databaseRoleId sdk.DatabaseObjectIdentifier,
	databaseId sdk.AccountObjectIdentifier,
	privileges []sdk.AccountObjectPrivilege,
)

func (*GrantClient) RevokePrivilegesOnSchemaObjectFromAccountRole added in v0.96.0 

func (c *GrantClient) RevokePrivilegesOnSchemaObjectFromAccountRole(
	t *testing.T,
	accountRoleId sdk.AccountObjectIdentifier,
	objectType sdk.ObjectType,
	schemaObjectIdentifier sdk.SchemaObjectIdentifier,
	privileges []sdk.SchemaObjectPrivilege,
)

func (*GrantClient) ShowGrantsOfAccountRole added in v0.96.0 

func (c *GrantClient) ShowGrantsOfAccountRole(t *testing.T, accountRoleId sdk.AccountObjectIdentifier) ([]sdk.Grant, error)

func (*GrantClient) ShowGrantsOfDatabaseRole added in v0.96.0 

func (c *GrantClient) ShowGrantsOfDatabaseRole(t *testing.T, databaseRoleId sdk.DatabaseObjectIdentifier) ([]sdk.Grant, error)

func (*GrantClient) ShowGrantsToAccountRole added in v0.96.0 

func (c *GrantClient) ShowGrantsToAccountRole(t *testing.T, accountRoleId sdk.AccountObjectIdentifier) ([]sdk.Grant, error)

func (*GrantClient) ShowGrantsToDatabaseRole added in v0.96.0 

func (c *GrantClient) ShowGrantsToDatabaseRole(t *testing.T, databaseRoleId sdk.DatabaseObjectIdentifier) ([]sdk.Grant, error)

func (*GrantClient) ShowGrantsToShare added in v0.96.0 

func (c *GrantClient) ShowGrantsToShare(t *testing.T, shareId sdk.AccountObjectIdentifier) ([]sdk.Grant, error)

type IdsGenerator 

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

func NewIdsGenerator 

func NewIdsGenerator(context *TestClientContext) *IdsGenerator

func (*IdsGenerator) AccountIdentifierWithLocator 

func (c *IdsGenerator) AccountIdentifierWithLocator() sdk.AccountIdentifier

func (*IdsGenerator) Alpha 

func (c *IdsGenerator) Alpha() string

func (*IdsGenerator) AlphaContaining 

func (c *IdsGenerator) AlphaContaining(part string) string

func (*IdsGenerator) AlphaN 

func (c *IdsGenerator) AlphaN(n int) string

func (*IdsGenerator) AlphaWithPrefix 

func (c *IdsGenerator) AlphaWithPrefix(prefix string) string

func (*IdsGenerator) DatabaseId 

func (c *IdsGenerator) DatabaseId() sdk.AccountObjectIdentifier

func (*IdsGenerator) NewDatabaseObjectIdentifier added in v0.92.0 

func (c *IdsGenerator) NewDatabaseObjectIdentifier(name string) sdk.DatabaseObjectIdentifier

func (*IdsGenerator) NewSchemaObjectIdentifier added in v0.92.0 

func (c *IdsGenerator) NewSchemaObjectIdentifier(name string) sdk.SchemaObjectIdentifier

func (*IdsGenerator) NewSchemaObjectIdentifierInSchema added in v0.92.0 

func (c *IdsGenerator) NewSchemaObjectIdentifierInSchema(name string, schemaId sdk.DatabaseObjectIdentifier) sdk.SchemaObjectIdentifier

func (*IdsGenerator) NewSchemaObjectIdentifierWithArguments added in v0.95.0 

func (c *IdsGenerator) NewSchemaObjectIdentifierWithArguments(name string, arguments ...sdk.DataType) sdk.SchemaObjectIdentifierWithArguments

func (*IdsGenerator) NewSchemaObjectIdentifierWithArgumentsInSchema added in v0.95.0 

func (c *IdsGenerator) NewSchemaObjectIdentifierWithArgumentsInSchema(name string, schemaId sdk.DatabaseObjectIdentifier, argumentDataTypes ...sdk.DataType) sdk.SchemaObjectIdentifierWithArguments

func (*IdsGenerator) NewSchemaObjectIdentifierWithArgumentsNewDataTypes added in v1.0.0 

func (c *IdsGenerator) NewSchemaObjectIdentifierWithArgumentsNewDataTypes(name string, arguments ...datatypes.DataType) sdk.SchemaObjectIdentifierWithArguments

func (*IdsGenerator) RandomAccountObjectIdentifier 

func (c *IdsGenerator) RandomAccountObjectIdentifier() sdk.AccountObjectIdentifier

func (*IdsGenerator) RandomAccountObjectIdentifierContaining 

func (c *IdsGenerator) RandomAccountObjectIdentifierContaining(part string) sdk.AccountObjectIdentifier

func (*IdsGenerator) RandomAccountObjectIdentifierWithPrefix 

func (c *IdsGenerator) RandomAccountObjectIdentifierWithPrefix(prefix string) sdk.AccountObjectIdentifier

func (*IdsGenerator) RandomDatabaseObjectIdentifier added in v0.92.0 

func (c *IdsGenerator) RandomDatabaseObjectIdentifier() sdk.DatabaseObjectIdentifier

func (*IdsGenerator) RandomDatabaseObjectIdentifierInDatabase added in v0.92.0 

func (c *IdsGenerator) RandomDatabaseObjectIdentifierInDatabase(databaseId sdk.AccountObjectIdentifier) sdk.DatabaseObjectIdentifier

func (*IdsGenerator) RandomDatabaseObjectIdentifierWithPrefix added in v0.92.0 

func (c *IdsGenerator) RandomDatabaseObjectIdentifierWithPrefix(prefix string) sdk.DatabaseObjectIdentifier

func (*IdsGenerator) RandomSchemaObjectIdentifier 

func (c *IdsGenerator) RandomSchemaObjectIdentifier() sdk.SchemaObjectIdentifier

func (*IdsGenerator) RandomSchemaObjectIdentifierInSchema added in v0.92.0 

func (c *IdsGenerator) RandomSchemaObjectIdentifierInSchema(schemaId sdk.DatabaseObjectIdentifier) sdk.SchemaObjectIdentifier

func (*IdsGenerator) RandomSchemaObjectIdentifierInSchemaWithPrefix added in v0.99.0 

func (c *IdsGenerator) RandomSchemaObjectIdentifierInSchemaWithPrefix(prefix string, schemaId sdk.DatabaseObjectIdentifier) sdk.SchemaObjectIdentifier

func (*IdsGenerator) RandomSchemaObjectIdentifierWithArguments added in v0.92.0 

func (c *IdsGenerator) RandomSchemaObjectIdentifierWithArguments(arguments ...sdk.DataType) sdk.SchemaObjectIdentifierWithArguments

func (*IdsGenerator) RandomSchemaObjectIdentifierWithArgumentsNewDataTypes added in v1.0.0 

func (c *IdsGenerator) RandomSchemaObjectIdentifierWithArgumentsNewDataTypes(arguments ...datatypes.DataType) sdk.SchemaObjectIdentifierWithArguments

func (*IdsGenerator) RandomSchemaObjectIdentifierWithArgumentsOld added in v0.95.0 

func (c *IdsGenerator) RandomSchemaObjectIdentifierWithArgumentsOld(arguments ...sdk.DataType) sdk.SchemaObjectIdentifier

func (*IdsGenerator) RandomSchemaObjectIdentifierWithPrefix added in v0.92.0 

func (c *IdsGenerator) RandomSchemaObjectIdentifierWithPrefix(prefix string) sdk.SchemaObjectIdentifier

func (*IdsGenerator) SchemaId 

func (c *IdsGenerator) SchemaId() sdk.DatabaseObjectIdentifier

func (*IdsGenerator) SnowflakeWarehouseId added in v1.0.0 

func (c *IdsGenerator) SnowflakeWarehouseId() sdk.AccountObjectIdentifier

func (*IdsGenerator) WarehouseId 

func (c *IdsGenerator) WarehouseId() sdk.AccountObjectIdentifier

type InformationSchemaClient added in v0.99.0 

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

func NewInformationSchemaClient added in v0.99.0 

func NewInformationSchemaClient(context *TestClientContext, idsGenerator *IdsGenerator) *InformationSchemaClient

func (*InformationSchemaClient) GetQueryHistory added in v0.99.0 

func (c *InformationSchemaClient) GetQueryHistory(t *testing.T, limit int) []QueryHistory

func (*InformationSchemaClient) GetQueryHistoryByQueryId added in v0.99.0 

func (c *InformationSchemaClient) GetQueryHistoryByQueryId(t *testing.T, limit int, queryId string) QueryHistory

type InformationSchemaColumns 

type InformationSchemaColumns struct {
	TableCatalog           string         `db:"TABLE_CATALOG"`
	TableSchema            string         `db:"TABLE_SCHEMA"`
	TableName              string         `db:"TABLE_NAME"`
	ColumnName             string         `db:"COLUMN_NAME"`
	OrdinalPosition        string         `db:"ORDINAL_POSITION"`
	ColumnDefault          sql.NullString `db:"COLUMN_DEFAULT"`
	IsNullable             string         `db:"IS_NULLABLE"`
	DataType               string         `db:"DATA_TYPE"`
	CharacterMaximumLength sql.NullString `db:"CHARACTER_MAXIMUM_LENGTH"`
	CharacterOctetLength   sql.NullString `db:"CHARACTER_OCTET_LENGTH"`
	NumericPrecision       sql.NullString `db:"NUMERIC_PRECISION"`
	NumericPrecisionRadix  sql.NullString `db:"NUMERIC_PRECISION_RADIX"`
	NumericScale           sql.NullString `db:"NUMERIC_SCALE"`
	DatetimePrecision      sql.NullString `db:"DATETIME_PRECISION"`
	IntervalType           sql.NullString `db:"INTERVAL_TYPE"`
	IntervalPrecision      sql.NullString `db:"INTERVAL_PRECISION"`
	CharacterSetCatalog    sql.NullString `db:"CHARACTER_SET_CATALOG"`
	CharacterSetSchema     sql.NullString `db:"CHARACTER_SET_SCHEMA"`
	CharacterSetName       sql.NullString `db:"CHARACTER_SET_NAME"`
	CollationCatalog       sql.NullString `db:"COLLATION_CATALOG"`
	CollationSchema        sql.NullString `db:"COLLATION_SCHEMA"`
	CollationName          sql.NullString `db:"COLLATION_NAME"`
	DomainCatalog          sql.NullString `db:"DOMAIN_CATALOG"`
	DomainSchema           sql.NullString `db:"DOMAIN_SCHEMA"`
	DomainName             sql.NullString `db:"DOMAIN_NAME"`
	UdtCatalog             sql.NullString `db:"UDT_CATALOG"`
	UdtSchema              sql.NullString `db:"UDT_SCHEMA"`
	UdtName                sql.NullString `db:"UDT_NAME"`
	ScopeCatalog           sql.NullString `db:"SCOPE_CATALOG"`
	ScopeSchema            sql.NullString `db:"SCOPE_SCHEMA"`
	ScopeName              sql.NullString `db:"SCOPE_NAME"`
	MaximumCardinality     sql.NullString `db:"MAXIMUM_CARDINALITY"`
	DtdIdentifier          sql.NullString `db:"DTD_IDENTIFIER"`
	IsSelfReferencing      string         `db:"IS_SELF_REFERENCING"`
	IsIdentity             string         `db:"IS_IDENTITY"`
	IdentityGeneration     sql.NullString `db:"IDENTITY_GENERATION"`
	IdentityStart          sql.NullString `db:"IDENTITY_START"`
	IdentityIncrement      sql.NullString `db:"IDENTITY_INCREMENT"`
	IdentityMaximum        sql.NullString `db:"IDENTITY_MAXIMUM"`
	IdentityMinimum        sql.NullString `db:"IDENTITY_MINIMUM"`
	IdentityCycle          sql.NullString `db:"IDENTITY_CYCLE"`
	IdentityOrdered        sql.NullString `db:"IDENTITY_ORDERED"`
	Comment                sql.NullString `db:"COMMENT"`
	SchemaEvolutionRecord  sql.NullString `db:"SCHEMA_EVOLUTION_RECORD"`
}

type MaskingPolicyClient 

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

func NewMaskingPolicyClient 

func NewMaskingPolicyClient(context *TestClientContext, idsGenerator *IdsGenerator) *MaskingPolicyClient

func (*MaskingPolicyClient) Alter added in v0.96.0 

func (c *MaskingPolicyClient) Alter(t *testing.T, id sdk.SchemaObjectIdentifier, req *sdk.AlterMaskingPolicyOptions)

func (*MaskingPolicyClient) CreateMaskingPolicy 

func (c *MaskingPolicyClient) CreateMaskingPolicy(t *testing.T) (*sdk.MaskingPolicy, func())

func (*MaskingPolicyClient) CreateMaskingPolicyIdentity 

func (c *MaskingPolicyClient) CreateMaskingPolicyIdentity(t *testing.T, columnType sdk.DataType) (*sdk.MaskingPolicy, func())

func (*MaskingPolicyClient) CreateMaskingPolicyWithOptions 

func (c *MaskingPolicyClient) CreateMaskingPolicyWithOptions(t *testing.T, signature []sdk.TableColumnSignature, returns sdk.DataType, expression string, options *sdk.CreateMaskingPolicyOptions) (*sdk.MaskingPolicy, func())

func (*MaskingPolicyClient) CreateOrReplaceMaskingPolicyWithOptions added in v0.96.0 

func (c *MaskingPolicyClient) CreateOrReplaceMaskingPolicyWithOptions(t *testing.T, id sdk.SchemaObjectIdentifier, signature []sdk.TableColumnSignature, returns sdk.DataType, expression string, options *sdk.CreateMaskingPolicyOptions) (*sdk.MaskingPolicy, func())

func (*MaskingPolicyClient) DropMaskingPolicyFunc 

func (c *MaskingPolicyClient) DropMaskingPolicyFunc(t *testing.T, id sdk.SchemaObjectIdentifier) func()

func (*MaskingPolicyClient) Show added in v0.96.0 

func (c *MaskingPolicyClient) Show(t *testing.T, id sdk.SchemaObjectIdentifier) (*sdk.MaskingPolicy, error)

type MaterializedViewClient added in v0.92.0 

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

func NewMaterializedViewClient added in v0.92.0 

func NewMaterializedViewClient(context *TestClientContext, idsGenerator *IdsGenerator) *MaterializedViewClient

func (*MaterializedViewClient) CreateMaterializedView added in v0.92.0 

func (c *MaterializedViewClient) CreateMaterializedView(t *testing.T, query string, orReplace bool) (*sdk.MaterializedView, func())

func (*MaterializedViewClient) CreateMaterializedViewWithName added in v0.92.0 

func (c *MaterializedViewClient) CreateMaterializedViewWithName(t *testing.T, id sdk.SchemaObjectIdentifier, query string, orReplace bool) (*sdk.MaterializedView, func())

func (*MaterializedViewClient) DropMaterializedViewFunc added in v0.92.0 

func (c *MaterializedViewClient) DropMaterializedViewFunc(t *testing.T, id sdk.SchemaObjectIdentifier) func()

type NetworkPolicyClient 

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

func NewNetworkPolicyClient 

func NewNetworkPolicyClient(context *TestClientContext, idsGenerator *IdsGenerator) *NetworkPolicyClient

func (*NetworkPolicyClient) CreateNetworkPolicy 

func (c *NetworkPolicyClient) CreateNetworkPolicy(t *testing.T) (*sdk.NetworkPolicy, func())

func (*NetworkPolicyClient) CreateNetworkPolicyWithRequest 

func (c *NetworkPolicyClient) CreateNetworkPolicyWithRequest(t *testing.T, request *sdk.CreateNetworkPolicyRequest) (*sdk.NetworkPolicy, func())

func (*NetworkPolicyClient) DropNetworkPolicyFunc 

func (c *NetworkPolicyClient) DropNetworkPolicyFunc(t *testing.T, id sdk.AccountObjectIdentifier) func()

func (*NetworkPolicyClient) Update added in v0.94.0 

func (c *NetworkPolicyClient) Update(t *testing.T, request *sdk.AlterNetworkPolicyRequest)

type NetworkRuleClient added in v0.94.0 

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

func NewNetworkRuleClient added in v0.94.0 

func NewNetworkRuleClient(context *TestClientContext, idsGenerator *IdsGenerator) *NetworkRuleClient

func (*NetworkRuleClient) Create added in v0.94.0 

func (c *NetworkRuleClient) Create(t *testing.T) (*sdk.NetworkRule, func())

func (*NetworkRuleClient) CreateWithIdentifier added in v0.94.0 

func (c *NetworkRuleClient) CreateWithIdentifier(t *testing.T, id sdk.SchemaObjectIdentifier) (*sdk.NetworkRule, func())

func (*NetworkRuleClient) CreateWithRequest added in v0.94.0 

func (c *NetworkRuleClient) CreateWithRequest(t *testing.T, request *sdk.CreateNetworkRuleRequest) (*sdk.NetworkRule, func())

func (*NetworkRuleClient) DropFunc added in v0.94.0 

func (c *NetworkRuleClient) DropFunc(t *testing.T, id sdk.SchemaObjectIdentifier) func()

type NotificationIntegrationClient added in v0.99.0 

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

func NewNotificationIntegrationClient added in v0.99.0 

func NewNotificationIntegrationClient(context *TestClientContext, idsGenerator *IdsGenerator) *NotificationIntegrationClient

func (*NotificationIntegrationClient) Create added in v0.99.0 

func (c *NotificationIntegrationClient) Create(t *testing.T) (*sdk.NotificationIntegration, func())

func (*NotificationIntegrationClient) CreateWithGcpPubSub added in v0.99.0 

func (c *NotificationIntegrationClient) CreateWithGcpPubSub(t *testing.T) (*sdk.NotificationIntegration, func())

func (*NotificationIntegrationClient) CreateWithRequest added in v0.99.0 

func (c *NotificationIntegrationClient) CreateWithRequest(t *testing.T, request *sdk.CreateNotificationIntegrationRequest) (*sdk.NotificationIntegration, func())

func (*NotificationIntegrationClient) DropFunc added in v0.99.0 

func (c *NotificationIntegrationClient) DropFunc(t *testing.T, id sdk.AccountObjectIdentifier) func()

type PackagesPolicyClient added in v1.0.0 

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

func NewPackagesPolicyClient added in v1.0.0 

func NewPackagesPolicyClient(context *TestClientContext, idsGenerator *IdsGenerator) *PackagesPolicyClient

func (*PackagesPolicyClient) Create added in v1.0.0 

func (c *PackagesPolicyClient) Create(t *testing.T) (sdk.SchemaObjectIdentifier, func())

type ParameterClient 

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

func NewParameterClient 

func NewParameterClient(context *TestClientContext) *ParameterClient

func (*ParameterClient) ShowAccountParameter added in v0.93.0 

func (c *ParameterClient) ShowAccountParameter(t *testing.T, parameter sdk.AccountParameter) *sdk.Parameter

func (*ParameterClient) ShowAccountParameters added in v0.93.0 

func (c *ParameterClient) ShowAccountParameters(t *testing.T) []*sdk.Parameter

func (*ParameterClient) ShowDatabaseParameters added in v0.93.0 

func (c *ParameterClient) ShowDatabaseParameters(t *testing.T, id sdk.AccountObjectIdentifier) []*sdk.Parameter

func (*ParameterClient) ShowFunctionParameters added in v1.0.0 

func (c *ParameterClient) ShowFunctionParameters(t *testing.T, id sdk.SchemaObjectIdentifierWithArguments) []*sdk.Parameter

func (*ParameterClient) ShowProcedureParameters added in v1.0.0 

func (c *ParameterClient) ShowProcedureParameters(t *testing.T, id sdk.SchemaObjectIdentifierWithArguments) []*sdk.Parameter

func (*ParameterClient) ShowSchemaParameters added in v0.94.0 

func (c *ParameterClient) ShowSchemaParameters(t *testing.T, id sdk.DatabaseObjectIdentifier) []*sdk.Parameter

func (*ParameterClient) ShowTaskParameters added in v0.97.0 

func (c *ParameterClient) ShowTaskParameters(t *testing.T, id sdk.SchemaObjectIdentifier) []*sdk.Parameter

func (*ParameterClient) ShowUserParameters added in v0.94.0 

func (c *ParameterClient) ShowUserParameters(t *testing.T, id sdk.AccountObjectIdentifier) []*sdk.Parameter

func (*ParameterClient) ShowWarehouseParameters added in v0.93.0 

func (c *ParameterClient) ShowWarehouseParameters(t *testing.T, id sdk.AccountObjectIdentifier) []*sdk.Parameter

func (*ParameterClient) UnsetAccountParameter added in v0.93.0 

func (c *ParameterClient) UnsetAccountParameter(t *testing.T, parameter sdk.AccountParameter)

TODO [SNOW-1473408]: add unset account parameter to sdk.Parameters

func (*ParameterClient) UpdateAccountParameterTemporarily 

func (c *ParameterClient) UpdateAccountParameterTemporarily(t *testing.T, parameter sdk.AccountParameter, newValue string) func()

type PasswordPolicyClient 

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

func NewPasswordPolicyClient 

func NewPasswordPolicyClient(context *TestClientContext, idsGenerator *IdsGenerator) *PasswordPolicyClient

func (*PasswordPolicyClient) CreatePasswordPolicy 

func (c *PasswordPolicyClient) CreatePasswordPolicy(t *testing.T) (*sdk.PasswordPolicy, func())

func (*PasswordPolicyClient) CreatePasswordPolicyInSchema 

func (c *PasswordPolicyClient) CreatePasswordPolicyInSchema(t *testing.T, schemaId sdk.DatabaseObjectIdentifier) (*sdk.PasswordPolicy, func())

func (*PasswordPolicyClient) CreatePasswordPolicyInSchemaWithOptions 

func (c *PasswordPolicyClient) CreatePasswordPolicyInSchemaWithOptions(t *testing.T, schemaId sdk.DatabaseObjectIdentifier, options *sdk.CreatePasswordPolicyOptions) (*sdk.PasswordPolicy, func())

func (*PasswordPolicyClient) CreatePasswordPolicyWithOptions 

func (c *PasswordPolicyClient) CreatePasswordPolicyWithOptions(t *testing.T, options *sdk.CreatePasswordPolicyOptions) (*sdk.PasswordPolicy, func())

func (*PasswordPolicyClient) DropPasswordPolicyFunc 

func (c *PasswordPolicyClient) DropPasswordPolicyFunc(t *testing.T, id sdk.SchemaObjectIdentifier) func()

type PipeClient 

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

func NewPipeClient 

func NewPipeClient(context *TestClientContext, idsGenerator *IdsGenerator) *PipeClient

func (*PipeClient) CreatePipe 

func (c *PipeClient) CreatePipe(t *testing.T, copyStatement string) (*sdk.Pipe, func())

func (*PipeClient) CreatePipeInSchema 

func (c *PipeClient) CreatePipeInSchema(t *testing.T, schemaId sdk.DatabaseObjectIdentifier, copyStatement string) (*sdk.Pipe, func())

func (*PipeClient) DropPipeFunc 

func (c *PipeClient) DropPipeFunc(t *testing.T, id sdk.SchemaObjectIdentifier) func()

type PolicyReferencesClient added in v0.95.0 

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

func NewPolicyReferencesClient added in v0.95.0 

func NewPolicyReferencesClient(context *TestClientContext) *PolicyReferencesClient

func (*PolicyReferencesClient) GetPolicyReference added in v0.95.0 

func (c *PolicyReferencesClient) GetPolicyReference(t *testing.T, id sdk.ObjectIdentifier, entity sdk.PolicyEntityDomain) (*sdk.PolicyReference, error)

GetPolicyReference is based on https://docs.snowflake.com/en/sql-reference/functions/policy_references.

func (*PolicyReferencesClient) GetPolicyReferences added in v0.95.0 

func (c *PolicyReferencesClient) GetPolicyReferences(t *testing.T, objectId sdk.ObjectIdentifier, entity sdk.PolicyEntityDomain) ([]sdk.PolicyReference, error)

GetPolicyReferences is based on https://docs.snowflake.com/en/sql-reference/functions/policy_references.

type ProcedureClient added in v0.95.0 

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

func NewProcedureClient added in v0.95.0 

func NewProcedureClient(context *TestClientContext, idsGenerator *IdsGenerator) *ProcedureClient

func (*ProcedureClient) Create added in v0.95.0 

func (c *ProcedureClient) Create(t *testing.T, arguments ...sdk.DataType) *sdk.Procedure

func (*ProcedureClient) CreateJava added in v1.0.0 

func (c *ProcedureClient) CreateJava(t *testing.T) (*sdk.Procedure, func())

func (*ProcedureClient) CreateScalaStaged added in v1.0.0 

func (c *ProcedureClient) CreateScalaStaged(t *testing.T, id sdk.SchemaObjectIdentifierWithArguments, dataType datatypes.DataType, importPath string, handler string) (*sdk.Procedure, func())

func (*ProcedureClient) CreateSql added in v1.0.0 

func (c *ProcedureClient) CreateSql(t *testing.T) (*sdk.Procedure, func())

func (*ProcedureClient) CreateSqlWithIdentifierAndArgument added in v1.0.0 

func (c *ProcedureClient) CreateSqlWithIdentifierAndArgument(t *testing.T, id sdk.SchemaObjectIdentifier, dataType datatypes.DataType, definition string) (*sdk.Procedure, func())

func (*ProcedureClient) CreateWithIdentifier added in v0.95.0 

func (c *ProcedureClient) CreateWithIdentifier(t *testing.T, id sdk.SchemaObjectIdentifierWithArguments) *sdk.Procedure

func (*ProcedureClient) DescribeDetails added in v1.0.0 

func (c *ProcedureClient) DescribeDetails(t *testing.T, id sdk.SchemaObjectIdentifierWithArguments) (*sdk.ProcedureDetails, error)

func (*ProcedureClient) DropProcedureFunc added in v1.0.0 

func (c *ProcedureClient) DropProcedureFunc(t *testing.T, id sdk.SchemaObjectIdentifierWithArguments) func()

func (*ProcedureClient) SampleJavaDefinition added in v1.0.0 

func (c *ProcedureClient) SampleJavaDefinition(t *testing.T, className string, funcName string, argName string) string

Session argument is needed: https://docs.snowflake.com/en/developer-guide/stored-procedure/stored-procedures-java#data-access-example More references: https://docs.snowflake.com/en/developer-guide/stored-procedure/stored-procedures-java

func (*ProcedureClient) SampleJavaDefinitionNoArgs added in v1.0.0 

func (c *ProcedureClient) SampleJavaDefinitionNoArgs(t *testing.T, className string, funcName string) string

func (*ProcedureClient) SampleJavascriptDefinition added in v1.0.0 

func (c *ProcedureClient) SampleJavascriptDefinition(t *testing.T, argName string) string

For more references: https://docs.snowflake.com/en/developer-guide/stored-procedure/stored-procedures-javascript

func (*ProcedureClient) SamplePythonDefinition added in v1.0.0 

func (c *ProcedureClient) SamplePythonDefinition(t *testing.T, funcName string, argName string) string

func (*ProcedureClient) SampleScalaDefinition added in v1.0.0 

func (c *ProcedureClient) SampleScalaDefinition(t *testing.T, className string, funcName string, argName string) string

https://docs.snowflake.com/en/developer-guide/stored-procedure/stored-procedures-scala

func (*ProcedureClient) SampleSqlDefinition added in v1.0.0 

func (c *ProcedureClient) SampleSqlDefinition(t *testing.T) string

func (*ProcedureClient) SampleSqlDefinitionWithArgument added in v1.0.0 

func (c *ProcedureClient) SampleSqlDefinitionWithArgument(t *testing.T) string

func (*ProcedureClient) Show added in v1.0.0 

func (c *ProcedureClient) Show(t *testing.T, id sdk.SchemaObjectIdentifierWithArguments) (*sdk.Procedure, error)

type ProjectionPolicyClient added in v0.95.0 

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

TODO(SNOW-1564959): change raw sqls to proper client

func NewProjectionPolicyClient added in v0.95.0 

func NewProjectionPolicyClient(context *TestClientContext, idsGenerator *IdsGenerator) *ProjectionPolicyClient

func (*ProjectionPolicyClient) CreateProjectionPolicy added in v0.95.0 

func (c *ProjectionPolicyClient) CreateProjectionPolicy(t *testing.T) (sdk.SchemaObjectIdentifier, func())

func (*ProjectionPolicyClient) DropProjectionPolicyFunc added in v0.95.0 

func (c *ProjectionPolicyClient) DropProjectionPolicyFunc(t *testing.T, id sdk.SchemaObjectIdentifier) func()

type QueryHistory added in v0.99.0 

type QueryHistory struct {
	QueryId   string
	QueryText string
	QueryTag  string
}

type Region added in v1.0.0 

type Region struct {
	SnowflakeRegion string `db:"snowflake_region"`
	Cloud           string `db:"cloud"`
	Region          string `db:"region"`
	DisplayName     string `db:"display_name"`
}

type ResourceMonitorClient 

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

func NewResourceMonitorClient 

func NewResourceMonitorClient(context *TestClientContext, idsGenerator *IdsGenerator) *ResourceMonitorClient

func (*ResourceMonitorClient) Alter added in v0.96.0 

func (c *ResourceMonitorClient) Alter(t *testing.T, id sdk.AccountObjectIdentifier, opts *sdk.AlterResourceMonitorOptions)

func (*ResourceMonitorClient) CreateResourceMonitor 

func (c *ResourceMonitorClient) CreateResourceMonitor(t *testing.T) (*sdk.ResourceMonitor, func())

func (*ResourceMonitorClient) CreateResourceMonitorWithOptions 

func (c *ResourceMonitorClient) CreateResourceMonitorWithOptions(t *testing.T, opts *sdk.CreateResourceMonitorOptions) (*sdk.ResourceMonitor, func())

func (*ResourceMonitorClient) DropResourceMonitorFunc 

func (c *ResourceMonitorClient) DropResourceMonitorFunc(t *testing.T, id sdk.AccountObjectIdentifier) func()

func (*ResourceMonitorClient) Show added in v0.96.0 

func (c *ResourceMonitorClient) Show(t *testing.T, id sdk.AccountObjectIdentifier) (*sdk.ResourceMonitor, error)

type RoleClient 

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

func NewRoleClient 

func NewRoleClient(context *TestClientContext, idsGenerator *IdsGenerator) *RoleClient

func (*RoleClient) CreateRole 

func (c *RoleClient) CreateRole(t *testing.T) (*sdk.Role, func())

func (*RoleClient) CreateRoleGrantedToCurrentUser 

func (c *RoleClient) CreateRoleGrantedToCurrentUser(t *testing.T) (*sdk.Role, func())

func (*RoleClient) CreateRoleWithIdentifier added in v0.92.0 

func (c *RoleClient) CreateRoleWithIdentifier(t *testing.T, id sdk.AccountObjectIdentifier) (*sdk.Role, func())

func (*RoleClient) CreateRoleWithRequest 

func (c *RoleClient) CreateRoleWithRequest(t *testing.T, req *sdk.CreateRoleRequest) (*sdk.Role, func())

func (*RoleClient) DropRoleFunc 

func (c *RoleClient) DropRoleFunc(t *testing.T, id sdk.AccountObjectIdentifier) func()

func (*RoleClient) GrantRoleToCurrentRole added in v0.92.0 

func (c *RoleClient) GrantRoleToCurrentRole(t *testing.T, id sdk.AccountObjectIdentifier)

func (*RoleClient) GrantRoleToUser added in v0.92.0 

func (c *RoleClient) GrantRoleToUser(t *testing.T, id sdk.AccountObjectIdentifier, userId sdk.AccountObjectIdentifier)

func (*RoleClient) UseRole 

func (c *RoleClient) UseRole(t *testing.T, roleId sdk.AccountObjectIdentifier) func()

type RowAccessPolicyClient 

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

func NewRowAccessPolicyClient 

func NewRowAccessPolicyClient(context *TestClientContext, idsGenerator *IdsGenerator) *RowAccessPolicyClient

func (*RowAccessPolicyClient) Alter added in v0.96.0 

func (c *RowAccessPolicyClient) Alter(t *testing.T, req sdk.AlterRowAccessPolicyRequest)

func (*RowAccessPolicyClient) CreateRowAccessPolicy 

func (c *RowAccessPolicyClient) CreateRowAccessPolicy(t *testing.T) (*sdk.RowAccessPolicy, func())

func (*RowAccessPolicyClient) CreateRowAccessPolicyWithArguments added in v0.96.0 

func (c *RowAccessPolicyClient) CreateRowAccessPolicyWithArguments(t *testing.T, args []sdk.CreateRowAccessPolicyArgsRequest) (*sdk.RowAccessPolicy, func())

func (*RowAccessPolicyClient) CreateRowAccessPolicyWithDataType added in v0.95.0 

func (c *RowAccessPolicyClient) CreateRowAccessPolicyWithDataType(t *testing.T, datatype sdk.DataType) (*sdk.RowAccessPolicy, func())

func (*RowAccessPolicyClient) CreateRowAccessPolicyWithRequest added in v0.96.0 

func (c *RowAccessPolicyClient) CreateRowAccessPolicyWithRequest(t *testing.T, req sdk.CreateRowAccessPolicyRequest) (*sdk.RowAccessPolicy, func())

func (*RowAccessPolicyClient) DropRowAccessPolicyFunc 

func (c *RowAccessPolicyClient) DropRowAccessPolicyFunc(t *testing.T, id sdk.SchemaObjectIdentifier) func()

func (*RowAccessPolicyClient) Show added in v0.96.0 

func (c *RowAccessPolicyClient) Show(t *testing.T, id sdk.SchemaObjectIdentifier) (*sdk.RowAccessPolicy, error)

type SchemaClient 

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

func NewSchemaClient 

func NewSchemaClient(context *TestClientContext, idsGenerator *IdsGenerator) *SchemaClient

func (*SchemaClient) Alter added in v0.98.0 

func (c *SchemaClient) Alter(t *testing.T, id sdk.DatabaseObjectIdentifier, opts *sdk.AlterSchemaOptions)

func (*SchemaClient) CreateSchema 

func (c *SchemaClient) CreateSchema(t *testing.T) (*sdk.Schema, func())

func (*SchemaClient) CreateSchemaInDatabase 

func (c *SchemaClient) CreateSchemaInDatabase(t *testing.T, databaseId sdk.AccountObjectIdentifier) (*sdk.Schema, func())

func (*SchemaClient) CreateSchemaWithIdentifier added in v0.92.0 

func (c *SchemaClient) CreateSchemaWithIdentifier(t *testing.T, id sdk.DatabaseObjectIdentifier) (*sdk.Schema, func())

func (*SchemaClient) CreateSchemaWithName 

func (c *SchemaClient) CreateSchemaWithName(t *testing.T, name string) (*sdk.Schema, func())

func (*SchemaClient) CreateSchemaWithOpts added in v0.94.0 

func (c *SchemaClient) CreateSchemaWithOpts(t *testing.T, id sdk.DatabaseObjectIdentifier, opts *sdk.CreateSchemaOptions) (*sdk.Schema, func())

func (*SchemaClient) DropSchemaFunc 

func (c *SchemaClient) DropSchemaFunc(t *testing.T, id sdk.DatabaseObjectIdentifier) func()

func (*SchemaClient) Show 

func (c *SchemaClient) Show(t *testing.T, id sdk.DatabaseObjectIdentifier) (*sdk.Schema, error)

func (*SchemaClient) ShowWithOptions added in v0.94.1 

func (c *SchemaClient) ShowWithOptions(t *testing.T, opts *sdk.ShowSchemaOptions) []sdk.Schema

func (*SchemaClient) UpdateDataRetentionTime 

func (c *SchemaClient) UpdateDataRetentionTime(t *testing.T, id sdk.DatabaseObjectIdentifier, days int)

func (*SchemaClient) UseDefaultSchema added in v0.93.0 

func (c *SchemaClient) UseDefaultSchema(t *testing.T)

type SecretClient added in v0.97.0 

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

func NewSecretClient added in v0.97.0 

func NewSecretClient(context *TestClientContext, idsGenerator *IdsGenerator) *SecretClient

func (*SecretClient) Alter added in v0.98.0 

func (c *SecretClient) Alter(t *testing.T, req *sdk.AlterSecretRequest)

func (*SecretClient) CreateWithBasicAuthenticationFlow added in v0.97.0 

func (c *SecretClient) CreateWithBasicAuthenticationFlow(t *testing.T, id sdk.SchemaObjectIdentifier, username, password string) (*sdk.Secret, func())

func (*SecretClient) CreateWithGenericString added in v0.97.0 

func (c *SecretClient) CreateWithGenericString(t *testing.T, id sdk.SchemaObjectIdentifier, secretString string) (*sdk.Secret, func())

func (*SecretClient) CreateWithOAuthAuthorizationCodeFlow added in v0.97.0 

func (c *SecretClient) CreateWithOAuthAuthorizationCodeFlow(t *testing.T, id sdk.SchemaObjectIdentifier, apiIntegration sdk.AccountObjectIdentifier, refreshToken, refreshTokenExpiryTime string) (*sdk.Secret, func())

func (*SecretClient) CreateWithOAuthClientCredentialsFlow added in v0.97.0 

func (c *SecretClient) CreateWithOAuthClientCredentialsFlow(t *testing.T, id sdk.SchemaObjectIdentifier, apiIntegration sdk.AccountObjectIdentifier, oauthScopes []sdk.ApiIntegrationScope) (*sdk.Secret, func())

func (*SecretClient) DropFunc added in v0.97.0 

func (c *SecretClient) DropFunc(t *testing.T, id sdk.SchemaObjectIdentifier) func()

func (*SecretClient) Show added in v0.97.0 

func (c *SecretClient) Show(t *testing.T, id sdk.SchemaObjectIdentifier) (*sdk.Secret, error)

type SecurityIntegrationClient added in v0.92.0 

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

func NewSecurityIntegrationClient added in v0.92.0 

func NewSecurityIntegrationClient(context *TestClientContext, idsGenerator *IdsGenerator) *SecurityIntegrationClient

func (*SecurityIntegrationClient) CreateApiAuthenticationClientCredentialsWithRequest added in v0.97.0 

func (c *SecurityIntegrationClient) CreateApiAuthenticationClientCredentialsWithRequest(t *testing.T, request *sdk.CreateApiAuthenticationWithClientCredentialsFlowSecurityIntegrationRequest) (*sdk.SecurityIntegration, func())

func (*SecurityIntegrationClient) CreateApiAuthenticationWithAuthorizationCodeGrantFlow added in v0.99.0 

func (c *SecurityIntegrationClient) CreateApiAuthenticationWithAuthorizationCodeGrantFlow(t *testing.T) (*sdk.SecurityIntegration, func())

func (*SecurityIntegrationClient) CreateApiAuthenticationWithClientCredentialsFlow added in v0.99.0 

func (c *SecurityIntegrationClient) CreateApiAuthenticationWithClientCredentialsFlow(t *testing.T) (*sdk.SecurityIntegration, func())

func (*SecurityIntegrationClient) CreateExternalOauth added in v0.99.0 

func (c *SecurityIntegrationClient) CreateExternalOauth(t *testing.T) (*sdk.SecurityIntegration, func())

func (*SecurityIntegrationClient) CreateOauthForCustomClients added in v0.99.0 

func (c *SecurityIntegrationClient) CreateOauthForCustomClients(t *testing.T) (*sdk.SecurityIntegration, func())

func (*SecurityIntegrationClient) CreateOauthForPartnerApplications added in v0.99.0 

func (c *SecurityIntegrationClient) CreateOauthForPartnerApplications(t *testing.T) (*sdk.SecurityIntegration, func())

func (*SecurityIntegrationClient) CreateSaml2 added in v0.92.0 

func (c *SecurityIntegrationClient) CreateSaml2(t *testing.T) (*sdk.SecurityIntegration, func())

func (*SecurityIntegrationClient) CreateSaml2WithRequest added in v0.92.0 

func (c *SecurityIntegrationClient) CreateSaml2WithRequest(t *testing.T, request *sdk.CreateSaml2SecurityIntegrationRequest) (*sdk.SecurityIntegration, func())

func (*SecurityIntegrationClient) CreateScim added in v0.92.0 

func (c *SecurityIntegrationClient) CreateScim(t *testing.T) (*sdk.SecurityIntegration, func())

func (*SecurityIntegrationClient) CreateScimWithRequest added in v0.92.0 

func (c *SecurityIntegrationClient) CreateScimWithRequest(t *testing.T, request *sdk.CreateScimSecurityIntegrationRequest) (*sdk.SecurityIntegration, func())

func (*SecurityIntegrationClient) DropSecurityIntegrationFunc added in v0.92.0 

func (c *SecurityIntegrationClient) DropSecurityIntegrationFunc(t *testing.T, id sdk.AccountObjectIdentifier) func()

func (*SecurityIntegrationClient) UpdateExternalOauth added in v0.93.0 

func (c *SecurityIntegrationClient) UpdateExternalOauth(t *testing.T, request *sdk.AlterExternalOauthSecurityIntegrationRequest)

func (*SecurityIntegrationClient) UpdateOauthForClients added in v0.93.0 

func (c *SecurityIntegrationClient) UpdateOauthForClients(t *testing.T, request *sdk.AlterOauthForCustomClientsSecurityIntegrationRequest)

func (*SecurityIntegrationClient) UpdateOauthForPartnerApplications added in v0.93.0 

func (c *SecurityIntegrationClient) UpdateOauthForPartnerApplications(t *testing.T, request *sdk.AlterOauthForPartnerApplicationsSecurityIntegrationRequest)

func (*SecurityIntegrationClient) UpdateSaml2 added in v0.93.0 

func (c *SecurityIntegrationClient) UpdateSaml2(t *testing.T, request *sdk.AlterSaml2SecurityIntegrationRequest)

func (*SecurityIntegrationClient) UpdateSaml2ForceAuthn added in v0.93.0 

func (c *SecurityIntegrationClient) UpdateSaml2ForceAuthn(t *testing.T, id sdk.AccountObjectIdentifier, forceAuthn bool)

type SessionPolicyClient 

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

func NewSessionPolicyClient 

func NewSessionPolicyClient(context *TestClientContext, idsGenerator *IdsGenerator) *SessionPolicyClient

func (*SessionPolicyClient) CreateSessionPolicy 

func (c *SessionPolicyClient) CreateSessionPolicy(t *testing.T) (*sdk.SessionPolicy, func())

func (*SessionPolicyClient) CreateSessionPolicyWithOptions 

func (c *SessionPolicyClient) CreateSessionPolicyWithOptions(t *testing.T, id sdk.SchemaObjectIdentifier, request *sdk.CreateSessionPolicyRequest) (*sdk.SessionPolicy, func())

func (*SessionPolicyClient) DropSessionPolicyFunc 

func (c *SessionPolicyClient) DropSessionPolicyFunc(t *testing.T, id sdk.SchemaObjectIdentifier) func()

type ShareClient 

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

func NewShareClient 

func NewShareClient(context *TestClientContext, idsGenerator *IdsGenerator) *ShareClient

func (*ShareClient) CreateShare 

func (c *ShareClient) CreateShare(t *testing.T) (*sdk.Share, func())

func (*ShareClient) CreateShareWithIdentifier added in v0.92.0 

func (c *ShareClient) CreateShareWithIdentifier(t *testing.T, id sdk.AccountObjectIdentifier) (*sdk.Share, func())

func (*ShareClient) CreateShareWithOptions 

func (c *ShareClient) CreateShareWithOptions(t *testing.T, id sdk.AccountObjectIdentifier, opts *sdk.CreateShareOptions) (*sdk.Share, func())

func (*ShareClient) DropShareFunc 

func (c *ShareClient) DropShareFunc(t *testing.T, id sdk.AccountObjectIdentifier) func()

func (*ShareClient) SetAccountOnShare 

func (c *ShareClient) SetAccountOnShare(t *testing.T, accountId sdk.AccountIdentifier, shareId sdk.AccountObjectIdentifier)

type StageClient 

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

func NewStageClient 

func NewStageClient(context *TestClientContext, idsGenerator *IdsGenerator) *StageClient

func (*StageClient) CopyIntoTableFromFile 

func (c *StageClient) CopyIntoTableFromFile(t *testing.T, table, stage sdk.SchemaObjectIdentifier, filename string)

func (*StageClient) CreateStage 

func (c *StageClient) CreateStage(t *testing.T) (*sdk.Stage, func())

func (*StageClient) CreateStageInSchema 

func (c *StageClient) CreateStageInSchema(t *testing.T, schemaId sdk.DatabaseObjectIdentifier) (*sdk.Stage, func())

func (*StageClient) CreateStageWithDirectory 

func (c *StageClient) CreateStageWithDirectory(t *testing.T) (*sdk.Stage, func())

func (*StageClient) CreateStageWithRequest 

func (c *StageClient) CreateStageWithRequest(t *testing.T, request *sdk.CreateInternalStageRequest) (*sdk.Stage, func())

func (*StageClient) CreateStageWithURL 

func (c *StageClient) CreateStageWithURL(t *testing.T, id sdk.SchemaObjectIdentifier) (*sdk.Stage, func())

func (*StageClient) Describe added in v0.97.0 

func (c *StageClient) Describe(t *testing.T, id sdk.SchemaObjectIdentifier) ([]sdk.StageProperty, error)

func (*StageClient) DropStageFunc 

func (c *StageClient) DropStageFunc(t *testing.T, id sdk.SchemaObjectIdentifier) func()

func (*StageClient) PutOnStage 

func (c *StageClient) PutOnStage(t *testing.T, id sdk.SchemaObjectIdentifier, filename string)

func (*StageClient) PutOnStageWithContent 

func (c *StageClient) PutOnStageWithContent(t *testing.T, id sdk.SchemaObjectIdentifier, filename string, content string)

func (*StageClient) PutOnUserStageWithContent added in v1.0.0 

func (c *StageClient) PutOnUserStageWithContent(t *testing.T, filename string, content string) string

func (*StageClient) RemoveFromStage added in v1.0.0 

func (c *StageClient) RemoveFromStage(t *testing.T, stageLocation string, pathOnStage string)

func (*StageClient) RemoveFromStageFunc added in v1.0.0 

func (c *StageClient) RemoveFromStageFunc(t *testing.T, stageLocation string, pathOnStage string) func()

func (*StageClient) RemoveFromUserStage added in v1.0.0 

func (c *StageClient) RemoveFromUserStage(t *testing.T, pathOnStage string)

func (*StageClient) RemoveFromUserStageFunc added in v1.0.0 

func (c *StageClient) RemoveFromUserStageFunc(t *testing.T, pathOnStage string) func()

func (*StageClient) Rename added in v0.95.0 

func (c *StageClient) Rename(t *testing.T, id sdk.SchemaObjectIdentifier, newId sdk.SchemaObjectIdentifier)

type StorageIntegrationClient added in v0.99.0 

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

func NewStorageIntegrationClient added in v0.99.0 

func NewStorageIntegrationClient(context *TestClientContext, idsGenerator *IdsGenerator) *StorageIntegrationClient

func (*StorageIntegrationClient) CreateS3 added in v0.99.0 

func (c *StorageIntegrationClient) CreateS3(t *testing.T, awsBucketUrl, awsRoleArn string) (*sdk.StorageIntegration, func())

func (*StorageIntegrationClient) DropFunc added in v0.99.0 

func (c *StorageIntegrationClient) DropFunc(t *testing.T, id sdk.AccountObjectIdentifier) func()

type StreamClient added in v0.97.0 

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

func NewStreamClient added in v0.97.0 

func NewStreamClient(context *TestClientContext, idsGenerator *IdsGenerator) *StreamClient

func (*StreamClient) Alter added in v0.97.0 

func (c *StreamClient) Alter(t *testing.T, req *sdk.AlterStreamRequest)

func (*StreamClient) CreateOnTable added in v0.97.0 

func (c *StreamClient) CreateOnTable(t *testing.T, tableId sdk.SchemaObjectIdentifier) (*sdk.Stream, func())

func (*StreamClient) CreateOnTableWithRequest added in v0.97.0 

func (c *StreamClient) CreateOnTableWithRequest(t *testing.T, req *sdk.CreateOnTableStreamRequest) (*sdk.Stream, func())

func (*StreamClient) CreateOnViewWithRequest added in v0.98.0 

func (c *StreamClient) CreateOnViewWithRequest(t *testing.T, req *sdk.CreateOnViewStreamRequest) (*sdk.Stream, func())

func (*StreamClient) DropFunc added in v0.97.0 

func (c *StreamClient) DropFunc(t *testing.T, id sdk.SchemaObjectIdentifier) func()

func (*StreamClient) Show added in v0.97.0 

func (c *StreamClient) Show(t *testing.T, id sdk.SchemaObjectIdentifier) (*sdk.Stream, error)

func (*StreamClient) Update added in v0.97.0 

func (c *StreamClient) Update(t *testing.T, request *sdk.AlterStreamRequest)

type StreamlitClient added in v0.94.0 

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

func NewStreamlitClient added in v0.94.0 

func NewStreamlitClient(context *TestClientContext, idsGenerator *IdsGenerator) *StreamlitClient

func (*StreamlitClient) Update added in v0.94.0 

func (c *StreamlitClient) Update(t *testing.T, request *sdk.AlterStreamlitRequest)

type TableClient 

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

func NewTableClient 

func NewTableClient(context *TestClientContext, idsGenerator *IdsGenerator) *TableClient

func (*TableClient) Create added in v0.97.0 

func (c *TableClient) Create(t *testing.T) (*sdk.Table, func())

func (*TableClient) CreateInSchema added in v0.97.0 

func (c *TableClient) CreateInSchema(t *testing.T, schemaId sdk.DatabaseObjectIdentifier) (*sdk.Table, func())

func (*TableClient) CreateWithChangeTracking added in v0.97.0 

func (c *TableClient) CreateWithChangeTracking(t *testing.T) (*sdk.Table, func())

func (*TableClient) CreateWithChangeTrackingInSchema added in v0.98.0 

func (c *TableClient) CreateWithChangeTrackingInSchema(t *testing.T, schemaId sdk.DatabaseObjectIdentifier) (*sdk.Table, func())

func (*TableClient) CreateWithColumns added in v0.97.0 

func (c *TableClient) CreateWithColumns(t *testing.T, columns []sdk.TableColumnRequest) (*sdk.Table, func())

func (*TableClient) CreateWithName added in v0.97.0 

func (c *TableClient) CreateWithName(t *testing.T, name string) (*sdk.Table, func())

func (*TableClient) CreateWithPredefinedColumns added in v0.97.0 

func (c *TableClient) CreateWithPredefinedColumns(t *testing.T) (*sdk.Table, func())

func (*TableClient) CreateWithRequest added in v0.97.0 

func (c *TableClient) CreateWithRequest(t *testing.T, req *sdk.CreateTableRequest) (*sdk.Table, func())

func (*TableClient) DropFunc added in v0.97.0 

func (c *TableClient) DropFunc(t *testing.T, id sdk.SchemaObjectIdentifier) func()

func (*TableClient) GetTableColumnsFor 

func (c *TableClient) GetTableColumnsFor(t *testing.T, tableId sdk.SchemaObjectIdentifier) []InformationSchemaColumns

GetTableColumnsFor is based on https://docs.snowflake.com/en/sql-reference/info-schema/columns. TODO: extract getting table columns as resource (like getting tag in system functions)

func (*TableClient) InsertInt added in v0.97.0 

func (c *TableClient) InsertInt(t *testing.T, tableId sdk.SchemaObjectIdentifier)

func (*TableClient) SetDataRetentionTime added in v0.92.0 

func (c *TableClient) SetDataRetentionTime(t *testing.T, id sdk.SchemaObjectIdentifier, days int)

type TagClient 

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

func NewTagClient 

func NewTagClient(context *TestClientContext, idsGenerator *IdsGenerator) *TagClient

func (*TagClient) Alter added in v0.99.0 

func (c *TagClient) Alter(t *testing.T, req *sdk.AlterTagRequest)

func (*TagClient) CreateTag 

func (c *TagClient) CreateTag(t *testing.T) (*sdk.Tag, func())

func (*TagClient) CreateTagInSchema 

func (c *TagClient) CreateTagInSchema(t *testing.T, schemaId sdk.DatabaseObjectIdentifier) (*sdk.Tag, func())

func (*TagClient) CreateTagWithIdentifier added in v0.98.0 

func (c *TagClient) CreateTagWithIdentifier(t *testing.T, id sdk.SchemaObjectIdentifier) (*sdk.Tag, func())

func (*TagClient) CreateWithRequest added in v0.98.0 

func (c *TagClient) CreateWithRequest(t *testing.T, req *sdk.CreateTagRequest) (*sdk.Tag, func())

func (*TagClient) DropTagFunc 

func (c *TagClient) DropTagFunc(t *testing.T, id sdk.SchemaObjectIdentifier) func()

func (*TagClient) GetForObject added in v1.0.0 

func (c *TagClient) GetForObject(t *testing.T, tagId sdk.SchemaObjectIdentifier, objectId sdk.ObjectIdentifier, objectType sdk.ObjectType) (*string, error)

func (*TagClient) Set added in v1.0.0 

func (c *TagClient) Set(t *testing.T, objectType sdk.ObjectType, id sdk.ObjectIdentifier, setTags []sdk.TagAssociation)

func (*TagClient) Show added in v0.98.0 

func (c *TagClient) Show(t *testing.T, id sdk.SchemaObjectIdentifier) (*sdk.Tag, error)

func (*TagClient) Unset added in v1.0.0 

func (c *TagClient) Unset(t *testing.T, objectType sdk.ObjectType, id sdk.ObjectIdentifier, unsetTags []sdk.ObjectIdentifier)

type TaskClient 

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

func NewTaskClient 

func NewTaskClient(context *TestClientContext, idsGenerator *IdsGenerator) *TaskClient

func (*TaskClient) Alter added in v0.99.0 

func (c *TaskClient) Alter(t *testing.T, req *sdk.AlterTaskRequest)

func (*TaskClient) Create added in v0.97.0 

func (c *TaskClient) Create(t *testing.T) (*sdk.Task, func())

func (*TaskClient) CreateWithAfter added in v0.97.0 

func (c *TaskClient) CreateWithAfter(t *testing.T, after ...sdk.SchemaObjectIdentifier) (*sdk.Task, func())

func (*TaskClient) CreateWithRequest added in v0.97.0 

func (c *TaskClient) CreateWithRequest(t *testing.T, request *sdk.CreateTaskRequest) (*sdk.Task, func())

func (*TaskClient) CreateWithSchedule added in v0.97.0 

func (c *TaskClient) CreateWithSchedule(t *testing.T) (*sdk.Task, func())

func (*TaskClient) DropFunc added in v0.97.0 

func (c *TaskClient) DropFunc(t *testing.T, id sdk.SchemaObjectIdentifier) func()

func (*TaskClient) Show added in v0.97.0 

func (c *TaskClient) Show(t *testing.T, id sdk.SchemaObjectIdentifier) (*sdk.Task, error)

type TestClient 

type TestClient struct {
	Ids *IdsGenerator

	Account                      *AccountClient
	AggregationPolicy            *AggregationPolicyClient
	Alert                        *AlertClient
	ApiIntegration               *ApiIntegrationClient
	Application                  *ApplicationClient
	ApplicationPackage           *ApplicationPackageClient
	AuthenticationPolicy         *AuthenticationPolicyClient
	BcrBundles                   *BcrBundlesClient
	ComputePool                  *ComputePoolClient
	Connection                   *ConnectionClient
	Context                      *ContextClient
	CortexSearchService          *CortexSearchServiceClient
	CatalogIntegration           *CatalogIntegrationClient
	Database                     *DatabaseClient
	DatabaseRole                 *DatabaseRoleClient
	DataMetricFunctionClient     *DataMetricFunctionClient
	DataMetricFunctionReferences *DataMetricFunctionReferencesClient
	DynamicTable                 *DynamicTableClient
	EventTable                   *EventTableClient
	ExternalAccessIntegration    *ExternalAccessIntegrationClient
	ExternalFunction             *ExternalFunctionClient
	ExternalTable                *ExternalTableClient
	ExternalVolume               *ExternalVolumeClient
	FailoverGroup                *FailoverGroupClient
	FileFormat                   *FileFormatClient
	Function                     *FunctionClient
	Grant                        *GrantClient
	InformationSchema            *InformationSchemaClient
	MaskingPolicy                *MaskingPolicyClient
	MaterializedView             *MaterializedViewClient
	NetworkPolicy                *NetworkPolicyClient
	NetworkRule                  *NetworkRuleClient
	NotificationIntegration      *NotificationIntegrationClient
	PackagesPolicy               *PackagesPolicyClient
	Parameter                    *ParameterClient
	PasswordPolicy               *PasswordPolicyClient
	Pipe                         *PipeClient
	Procedure                    *ProcedureClient
	ProjectionPolicy             *ProjectionPolicyClient
	PolicyReferences             *PolicyReferencesClient
	ResourceMonitor              *ResourceMonitorClient
	Role                         *RoleClient
	RowAccessPolicy              *RowAccessPolicyClient
	Schema                       *SchemaClient
	Secret                       *SecretClient
	SecurityIntegration          *SecurityIntegrationClient
	SessionPolicy                *SessionPolicyClient
	Share                        *ShareClient
	Stage                        *StageClient
	StorageIntegration           *StorageIntegrationClient
	Stream                       *StreamClient
	Streamlit                    *StreamlitClient
	Table                        *TableClient
	Tag                          *TagClient
	Task                         *TaskClient
	User                         *UserClient
	View                         *ViewClient
	Warehouse                    *WarehouseClient
	// contains filtered or unexported fields
}

func NewTestClient 

func NewTestClient(c *sdk.Client, database string, schema string, warehouse string, testObjectSuffix string) *TestClient

func (*TestClient) CreateSampleJavaFunctionAndJarInLocation added in v1.0.0 

func (c *TestClient) CreateSampleJavaFunctionAndJarInLocation(t *testing.T, stageLocation string) *TmpFunction

TODO [SNOW-1827324]: add TestClient ref to each specific client, so that we enhance specific client and not the base one

func (*TestClient) CreateSampleJavaFunctionAndJarOnStage added in v1.0.0 

func (c *TestClient) CreateSampleJavaFunctionAndJarOnStage(t *testing.T, stage *sdk.Stage) *TmpFunction

func (*TestClient) CreateSampleJavaFunctionAndJarOnUserStage added in v1.0.0 

func (c *TestClient) CreateSampleJavaFunctionAndJarOnUserStage(t *testing.T) *TmpFunction

func (*TestClient) CreateSampleJavaProcedureAndJarInLocation added in v1.0.0 

func (c *TestClient) CreateSampleJavaProcedureAndJarInLocation(t *testing.T, stageLocation string) *TmpFunction

func (*TestClient) CreateSampleJavaProcedureAndJarOnStage added in v1.0.0 

func (c *TestClient) CreateSampleJavaProcedureAndJarOnStage(t *testing.T, stage *sdk.Stage) *TmpFunction

func (*TestClient) CreateSampleJavaProcedureAndJarOnUserStage added in v1.0.0 

func (c *TestClient) CreateSampleJavaProcedureAndJarOnUserStage(t *testing.T) *TmpFunction

func (*TestClient) CreateSamplePythonFunctionAndModule added in v1.0.0 

func (c *TestClient) CreateSamplePythonFunctionAndModule(t *testing.T) *TmpFunction

func (*TestClient) GetAccountLocator added in v0.96.0 

func (c *TestClient) GetAccountLocator() string

func (*TestClient) SetUpTemporaryLegacyServiceUser added in v1.0.0 

func (c *TestClient) SetUpTemporaryLegacyServiceUser(t *testing.T) *TmpLegacyServiceUser

func (*TestClient) SetUpTemporaryServiceUser added in v1.0.0 

func (c *TestClient) SetUpTemporaryServiceUser(t *testing.T) *TmpServiceUser

func (*TestClient) StoreTempTomlConfig added in v1.0.0 

func (c *TestClient) StoreTempTomlConfig(t *testing.T, tomlProvider func(string) string) *TmpTomlConfig

func (*TestClient) TempIncorrectTomlConfigForLegacyServiceUser added in v1.0.0 

func (c *TestClient) TempIncorrectTomlConfigForLegacyServiceUser(t *testing.T, legacyServiceUser *TmpLegacyServiceUser) *TmpTomlConfig

func (*TestClient) TempIncorrectTomlConfigForServiceUser added in v1.0.0 

func (c *TestClient) TempIncorrectTomlConfigForServiceUser(t *testing.T, serviceUser *TmpServiceUser) *TmpTomlConfig

func (*TestClient) TempIncorrectTomlConfigForServiceUserWithEncryptedKey added in v1.0.0 

func (c *TestClient) TempIncorrectTomlConfigForServiceUserWithEncryptedKey(t *testing.T, serviceUser *TmpServiceUser) *TmpTomlConfig

func (*TestClient) TempTomlConfigForLegacyServiceUser added in v1.0.0 

func (c *TestClient) TempTomlConfigForLegacyServiceUser(t *testing.T, legacyServiceUser *TmpLegacyServiceUser) *TmpTomlConfig

func (*TestClient) TempTomlConfigForServiceUser added in v1.0.0 

func (c *TestClient) TempTomlConfigForServiceUser(t *testing.T, serviceUser *TmpServiceUser) *TmpTomlConfig

func (*TestClient) TempTomlConfigForServiceUserWithEncryptedKey added in v1.0.0 

func (c *TestClient) TempTomlConfigForServiceUserWithEncryptedKey(t *testing.T, serviceUser *TmpServiceUser) *TmpTomlConfig

type TestClientContext 

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

type TmpFunction added in v1.0.0 

type TmpFunction struct {
	FunctionId    sdk.SchemaObjectIdentifierWithArguments
	ClassName     string
	ModuleName    string
	FuncName      string
	ArgName       string
	ArgType       datatypes.DataType
	JarName       string
	StageLocation string
}

func (*TmpFunction) JarLocation added in v1.0.0 

func (f *TmpFunction) JarLocation() string

func (*TmpFunction) JavaHandler added in v1.0.0 

func (f *TmpFunction) JavaHandler() string

func (*TmpFunction) PythonFileName added in v1.0.0 

func (f *TmpFunction) PythonFileName() string

func (*TmpFunction) PythonHandler added in v1.0.0 

func (f *TmpFunction) PythonHandler() string

func (*TmpFunction) PythonModuleLocation added in v1.0.0 

func (f *TmpFunction) PythonModuleLocation() string

type TmpLegacyServiceUser added in v1.0.0 

type TmpLegacyServiceUser struct {
	Pass string
	TmpUser
}

type TmpServiceUser added in v1.0.0 

type TmpServiceUser struct {
	PublicKey           string
	PrivateKey          string
	EncryptedPrivateKey string
	Pass                string
	TmpUser
}

type TmpTomlConfig added in v1.0.0 

type TmpTomlConfig struct {
	Profile string
	Path    string
}

type TmpUser added in v1.0.0 

type TmpUser struct {
	UserId      sdk.AccountObjectIdentifier
	RoleId      sdk.AccountObjectIdentifier
	WarehouseId sdk.AccountObjectIdentifier
	AccountId   sdk.AccountIdentifier
}

func (*TmpUser) OrgAndAccount added in v1.0.0 

func (u *TmpUser) OrgAndAccount() string

type UserClient 

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

func NewUserClient 

func NewUserClient(context *TestClientContext, idsGenerator *IdsGenerator) *UserClient

func (*UserClient) Alter added in v0.95.0 

func (c *UserClient) Alter(t *testing.T, id sdk.AccountObjectIdentifier, opts *sdk.AlterUserOptions)

func (*UserClient) AlterCurrentUser added in v0.99.0 

func (c *UserClient) AlterCurrentUser(t *testing.T, opts *sdk.AlterUserOptions)

func (*UserClient) CreateLegacyServiceUser added in v0.97.0 

func (c *UserClient) CreateLegacyServiceUser(t *testing.T) (*sdk.User, func())

func (*UserClient) CreateServiceUser added in v0.97.0 

func (c *UserClient) CreateServiceUser(t *testing.T) (*sdk.User, func())

func (*UserClient) CreateUser 

func (c *UserClient) CreateUser(t *testing.T) (*sdk.User, func())

func (*UserClient) CreateUserWithOptions 

func (c *UserClient) CreateUserWithOptions(t *testing.T, id sdk.AccountObjectIdentifier, opts *sdk.CreateUserOptions) (*sdk.User, func())

func (*UserClient) CreateUserWithPrefix added in v0.92.0 

func (c *UserClient) CreateUserWithPrefix(t *testing.T, prefix string) (*sdk.User, func())

func (*UserClient) Disable added in v0.95.0 

func (c *UserClient) Disable(t *testing.T, id sdk.AccountObjectIdentifier)

func (*UserClient) DropUserFunc 

func (c *UserClient) DropUserFunc(t *testing.T, id sdk.AccountObjectIdentifier) func()

func (*UserClient) SetDaysToExpiry added in v0.95.0 

func (c *UserClient) SetDaysToExpiry(t *testing.T, id sdk.AccountObjectIdentifier, value int)

func (*UserClient) SetLoginName added in v0.95.0 

func (c *UserClient) SetLoginName(t *testing.T, id sdk.AccountObjectIdentifier, newLoginName string)

func (*UserClient) SetType added in v0.95.0 

func (c *UserClient) SetType(t *testing.T, id sdk.AccountObjectIdentifier, userType sdk.UserType)

func (*UserClient) Show added in v0.94.0 

func (c *UserClient) Show(t *testing.T, id sdk.AccountObjectIdentifier) (*sdk.User, error)

func (*UserClient) UnsetDefaultSecondaryRoles added in v0.95.0 

func (c *UserClient) UnsetDefaultSecondaryRoles(t *testing.T, id sdk.AccountObjectIdentifier)

func (*UserClient) UnsetType added in v0.97.0 

func (c *UserClient) UnsetType(t *testing.T, id sdk.AccountObjectIdentifier)

type ViewClient 

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

func NewViewClient 

func NewViewClient(context *TestClientContext, idsGenerator *IdsGenerator) *ViewClient

func (*ViewClient) Alter added in v0.95.0 

func (c *ViewClient) Alter(t *testing.T, req *sdk.AlterViewRequest)

func (*ViewClient) CreateView 

func (c *ViewClient) CreateView(t *testing.T, query string) (*sdk.View, func())

func (*ViewClient) CreateViewInSchema added in v0.98.0 

func (c *ViewClient) CreateViewInSchema(t *testing.T, query string, schemaId sdk.DatabaseObjectIdentifier) (*sdk.View, func())

func (*ViewClient) DropViewFunc 

func (c *ViewClient) DropViewFunc(t *testing.T, id sdk.SchemaObjectIdentifier) func()

func (*ViewClient) RecreateView added in v0.92.0 

func (c *ViewClient) RecreateView(t *testing.T, id sdk.SchemaObjectIdentifier, query string) *sdk.View

func (*ViewClient) Show added in v0.95.0 

func (c *ViewClient) Show(t *testing.T, id sdk.SchemaObjectIdentifier) (*sdk.View, error)

type WarehouseClient 

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

func NewWarehouseClient 

func NewWarehouseClient(context *TestClientContext, idsGenerator *IdsGenerator) *WarehouseClient

func (*WarehouseClient) CreateWarehouse 

func (c *WarehouseClient) CreateWarehouse(t *testing.T) (*sdk.Warehouse, func())

func (*WarehouseClient) CreateWarehouseWithOptions 

func (c *WarehouseClient) CreateWarehouseWithOptions(t *testing.T, id sdk.AccountObjectIdentifier, opts *sdk.CreateWarehouseOptions) (*sdk.Warehouse, func())

func (*WarehouseClient) DropWarehouseFunc 

func (c *WarehouseClient) DropWarehouseFunc(t *testing.T, id sdk.AccountObjectIdentifier) func()

func (*WarehouseClient) Show 

func (c *WarehouseClient) Show(t *testing.T, id sdk.AccountObjectIdentifier) (*sdk.Warehouse, error)

func (*WarehouseClient) Suspend added in v0.93.0 

func (c *WarehouseClient) Suspend(t *testing.T, id sdk.AccountObjectIdentifier)

func (*WarehouseClient) UnsetStatementTimeoutInSeconds added in v0.93.0 

func (c *WarehouseClient) UnsetStatementTimeoutInSeconds(t *testing.T, id sdk.AccountObjectIdentifier)

func (*WarehouseClient) UpdateAutoResume added in v0.93.0 

func (c *WarehouseClient) UpdateAutoResume(t *testing.T, id sdk.AccountObjectIdentifier, newAutoResume bool)

func (*WarehouseClient) UpdateAutoSuspend added in v0.93.0 

func (c *WarehouseClient) UpdateAutoSuspend(t *testing.T, id sdk.AccountObjectIdentifier, newAutoSuspend int)

func (*WarehouseClient) UpdateMaxConcurrencyLevel 

func (c *WarehouseClient) UpdateMaxConcurrencyLevel(t *testing.T, id sdk.AccountObjectIdentifier, level int)

func (*WarehouseClient) UpdateStatementTimeoutInSeconds added in v0.93.0 

func (c *WarehouseClient) UpdateStatementTimeoutInSeconds(t *testing.T, id sdk.AccountObjectIdentifier, newValue int)

func (*WarehouseClient) UpdateWarehouseSize added in v0.93.0 

func (c *WarehouseClient) UpdateWarehouseSize(t *testing.T, id sdk.AccountObjectIdentifier, newSize sdk.WarehouseSize)

func (*WarehouseClient) UpdateWarehouseType added in v0.93.0 

func (c *WarehouseClient) UpdateWarehouseType(t *testing.T, id sdk.AccountObjectIdentifier, newType sdk.WarehouseType)

func (*WarehouseClient) UseWarehouse 

func (c *WarehouseClient) UseWarehouse(t *testing.T, id sdk.AccountObjectIdentifier) func()

Source Files

View all Source files

Directories

Path Synopsis

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.