lakeformation

package

Go to main page

Versions in this module

v1

v1.3.0

Aug 3, 2026

v1.2.0

Aug 3, 2026

Changes in this version

+ type AllRowsWildcard struct

+ type BatchPermissionsRequestEntry struct

+ Condition *Condition

+ ID string

+ Permissions []string

+ PermissionsWithGrantOption []string

+ Principal *DataLakePrincipal

+ Resource *Resource

type CatalogResource

+ ID string

+ type ColumnWildcard struct

+ ExcludedColumnNames []string

+ type Condition struct

+ Expression string

type DataCellsFilter

+ ColumnWildcard *ColumnWildcard

+ VersionID string

+ type DataCellsFilterResource struct

+ DatabaseName string

+ Name string

+ TableCatalogID string

+ TableName string

type DataLakeSettings

+ ExternalDataFilteringAllowList []DataLakePrincipal

type DataLocationResource

+ CatalogID string

type DatabaseResource

+ CatalogID string

type LFOptIn

+ Condition *Condition

+ type LFTagExpressionResource struct

+ CatalogID string

+ Name string

+ type LFTagKeyResource struct

+ CatalogID string

+ TagKey string

+ TagValues []string

+ type LFTagPolicyResource struct

+ CatalogID string

+ Expression []LFTag

+ ExpressionName string

+ ResourceType string

type PermissionEntry

+ Condition *Condition

+ LastUpdated *time.Time

+ LastUpdatedBy string

+ type RegisterResourceOptions struct

+ ExpectedResourceOwnerAccount string

+ HybridAccessEnabled bool

+ WithFederation bool

+ WithPrivilegedAccess bool

type Resource

+ DataCellsFilter *DataCellsFilterResource

+ LFTag *LFTagKeyResource

+ LFTagExpression *LFTagExpressionResource

+ LFTagPolicy *LFTagPolicyResource

type ResourceInfo

+ ExpectedResourceOwnerAccount string

+ HybridAccessEnabled bool

+ VerificationStatus string

+ WithFederation bool

+ WithPrivilegedAccess bool

type RowFilter

+ AllRowsWildcard *AllRowsWildcard

type TableResource

+ TableWildcard *TableWildcard

+ type TableWildcard struct

type TableWithColumnsResource

+ ColumnWildcard *ColumnWildcard

v1.1.4

Jul 20, 2026

v1.1.3

Jul 20, 2026

v1.1.2

Jul 20, 2026

v1.1.1

Jul 20, 2026

v1.1.0

Jul 19, 2026

Changes in this version

+ var ErrNilAppContext = errors.New("lakeformation: nil AppContext")

+ var ErrValidation = errors.New("validation error")

+ type AuditContext struct

+ AdditionalAuditContext string

+ type BatchFailureEntry struct

+ Error *errorDetail

+ RequestEntry *PermissionEntry

+ type CatalogResource struct

+ type ColumnLFTag struct

+ LFTags []LFTagPair

+ Name string

+ type DataCellsFilter struct

+ ColumnNames []string

+ DatabaseName string

+ Name string

+ RowFilter *RowFilter

+ TableCatalogID string

+ TableName string

+ type DataLakePrincipal struct

+ DataLakePrincipalIdentifier string

+ type DataLakeSettings struct

+ AllowExternalDataFiltering *bool

+ AllowFullTableExternalDataAccess *bool

+ AuthorizedSessionTagValueList []string

+ CreateDatabaseDefaultPermissions []PrincipalPermissions

+ CreateTableDefaultPermissions []PrincipalPermissions

+ DataLakeAdmins []DataLakePrincipal

+ Parameters map[string]string

+ ReadOnlyAdmins []DataLakePrincipal

+ TrustedResourceOwners []string

+ type DataLocationResource struct

+ ResourceArn string

+ type DatabaseResource struct

+ Name string

+ type ExecutionStatistics struct

+ AverageExecutionTimeMillis *int64

+ DataScannedBytes *int64

+ WorkUnitsExecutedCount *int64

+ type ExportedResourceInfo = ResourceInfo

+ type ExternalFilteringConfiguration struct

+ AuthorizedTargets []string

+ Status string

+ type Handler struct

+ AccountID string

+ Backend StorageBackend

+ DefaultRegion string

+ func NewHandler(backend StorageBackend) *Handler

+ func (h *Handler) ChaosOperations() []string

+ func (h *Handler) ChaosRegions() []string

+ func (h *Handler) ChaosServiceName() string

+ func (h *Handler) ExtractOperation(c *echo.Context) string

+ func (h *Handler) ExtractResource(_ *echo.Context) string

+ func (h *Handler) GetSupportedOperations() []string

+ func (h *Handler) Handler() echo.HandlerFunc

+ func (h *Handler) HandlerOpsLen() int

+ func (h *Handler) MatchPriority() int

+ func (h *Handler) Name() string

+ func (h *Handler) Reset()

+ func (h *Handler) Restore(ctx context.Context, data []byte) error

+ func (h *Handler) RouteMatcher() service.Matcher

+ func (h *Handler) Snapshot(ctx context.Context) []byte

+ type IdentityCenterConfiguration struct

+ ApplicationArn string

+ ApplicationStatus string

+ CatalogID string

+ ExternalFiltering *ExternalFilteringConfiguration

+ InstanceArn string

+ ShareRecipients []DataLakePrincipal

+ type InMemoryBackend struct

+ func NewInMemoryBackend() *InMemoryBackend

+ func (b *InMemoryBackend) AddDataCellsFilterInternal(filter *DataCellsFilter)

+ func (b *InMemoryBackend) AddLFTagExpressionInternal(expr *LFTagExpression)

+ func (b *InMemoryBackend) AddLFTagInternal(catalogID, tagKey string, tagValues []string)

+ func (b *InMemoryBackend) AddLFTagsToResource(catalogID string, resource *Resource, lfTags []LFTagPair) []LFTagError

+ func (b *InMemoryBackend) AddPermissionInternal(entry *PermissionEntry)

+ func (b *InMemoryBackend) AddResourceInternal(resourceArn, roleArn string)

+ func (b *InMemoryBackend) AssumeDecoratedRoleWithSAML(_, _, _ string, durationSeconds *int32) *SAMLCredentials

+ func (b *InMemoryBackend) BatchGrantPermissions(entries []*PermissionEntry) []*BatchFailureEntry

+ func (b *InMemoryBackend) BatchRevokePermissions(entries []*PermissionEntry) []*BatchFailureEntry

+ func (b *InMemoryBackend) CancelTransaction(transactionID string) error

+ func (b *InMemoryBackend) CommitTransaction(transactionID string) (string, error)

+ func (b *InMemoryBackend) CreateDataCellsFilter(filter *DataCellsFilter) error

+ func (b *InMemoryBackend) CreateLFTag(catalogID, tagKey string, tagValues []string) error

+ func (b *InMemoryBackend) CreateLFTagExpression(name, description, catalogID string, expression []LFTag) error

+ func (b *InMemoryBackend) CreateLakeFormationIdentityCenterConfiguration(catalogID, instanceArn string, ...) (string, error)

+ func (b *InMemoryBackend) CreateLakeFormationOptIn(principal *DataLakePrincipal, resource *Resource) error

+ func (b *InMemoryBackend) DataCellsFilterCount() int

+ func (b *InMemoryBackend) DeleteDataCellsFilter(tableCatalogID, databaseName, tableName, name string) error

+ func (b *InMemoryBackend) DeleteLFTag(catalogID, tagKey string) error

+ func (b *InMemoryBackend) DeleteLFTagExpression(name, catalogID string) error

+ func (b *InMemoryBackend) DeleteLakeFormationIdentityCenterConfiguration(catalogID string) error

+ func (b *InMemoryBackend) DeleteLakeFormationOptIn(principal *DataLakePrincipal, resource *Resource) error

+ func (b *InMemoryBackend) DeleteObjectsOnCancel(transactionID string) error

+ func (b *InMemoryBackend) DeregisterResource(resourceArn string) error

+ func (b *InMemoryBackend) DescribeLakeFormationIdentityCenterConfiguration(catalogID string) (*IdentityCenterConfiguration, error)

+ func (b *InMemoryBackend) DescribeResource(resourceArn string) (*ResourceInfo, error)

+ func (b *InMemoryBackend) DescribeTransaction(transactionID string) (*Transaction, error)

+ func (b *InMemoryBackend) ExtendTransaction(transactionID string) error

+ func (b *InMemoryBackend) GetDataCellsFilter(tableCatalogID, databaseName, tableName, name string) (*DataCellsFilter, error)

+ func (b *InMemoryBackend) GetDataLakePrincipal(ctx context.Context) *DataLakePrincipal

+ func (b *InMemoryBackend) GetDataLakeSettings() *DataLakeSettings

+ func (b *InMemoryBackend) GetEffectivePermissionsForPath(resourceArn string, maxResults int, nextToken string) ([]*PermissionEntry, string)

+ func (b *InMemoryBackend) GetLFTag(catalogID, tagKey string) (*LFTag, error)

+ func (b *InMemoryBackend) GetLFTagExpression(name, catalogID string) (*LFTagExpression, error)

+ func (b *InMemoryBackend) GetQueryState(queryID string) (string, error)

+ func (b *InMemoryBackend) GetQueryStatistics(queryID string) (*ExecutionStatistics, *PlanningStatistics, error)

+ func (b *InMemoryBackend) GetResourceLFTags(_ string, resource *Resource) ([]LFTagPair, error)

+ func (b *InMemoryBackend) GetTableObjects(catalogID, databaseName, tableName, _ string, maxResults int, nextToken string) ([]PartitionedTableObjectsList, string)

+ func (b *InMemoryBackend) GetTemporaryCredentials(durationSeconds *int32) *TemporaryCredentials

+ func (b *InMemoryBackend) GetWorkUnitResults(queryID, _ string) (string, error)

+ func (b *InMemoryBackend) GetWorkUnits(queryID string) ([]WorkUnitRange, string, error)

+ func (b *InMemoryBackend) GrantPermissions(entry *PermissionEntry) error

+ func (b *InMemoryBackend) IdentityCenterConfigCount() int

+ func (b *InMemoryBackend) LFTagExpressionCount() int

+ func (b *InMemoryBackend) ListDataCellsFilter(tableCatalogID, databaseName, tableName string, maxResults int, ...) ([]*DataCellsFilter, string)

+ func (b *InMemoryBackend) ListLFTagExpressions(catalogID string, maxResults int, nextToken string) ([]*LFTagExpression, string)

+ func (b *InMemoryBackend) ListLFTags(catalogID string, maxResults int, nextToken string) ([]*LFTag, string)

+ func (b *InMemoryBackend) ListLakeFormationOptIns(principalIdentifier string, resource *Resource, maxResults int, ...) ([]*LFOptIn, string)

+ func (b *InMemoryBackend) ListPermissions(resourceArn string, maxResults int, nextToken string, ...) ([]*PermissionEntry, string)

+ func (b *InMemoryBackend) ListResources(maxResults int, nextToken string) ([]*ResourceInfo, string)

+ func (b *InMemoryBackend) ListTableStorageOptimizers(catalogID, databaseName, tableName, storageOptimizerType string) []StorageOptimizer

+ func (b *InMemoryBackend) ListTransactions(statusFilter string, maxResults int, nextToken string) ([]*Transaction, string)

+ func (b *InMemoryBackend) OptInCount() int

+ func (b *InMemoryBackend) PermissionCount() int

+ func (b *InMemoryBackend) PutDataLakeSettings(settings *DataLakeSettings)

+ func (b *InMemoryBackend) RegisterResource(resourceArn, roleArn string) error

+ func (b *InMemoryBackend) RemoveLFTagsFromResource(_ string, resource *Resource, lfTags []LFTagPair) []LFTagError

+ func (b *InMemoryBackend) Reset()

+ func (b *InMemoryBackend) ResourceCount() int

+ func (b *InMemoryBackend) ResourceLFTagCount() int

+ func (b *InMemoryBackend) Restore(ctx context.Context, data []byte) error

+ func (b *InMemoryBackend) RevokePermissions(entry *PermissionEntry) error

+ func (b *InMemoryBackend) SearchDatabasesByLFTags(expression []LFTag, _ string, maxResults int, nextToken string) ([]TaggedDatabase, string)

+ func (b *InMemoryBackend) SearchTablesByLFTags(expression []LFTag, catalogID string, maxResults int, nextToken string) ([]TaggedTable, string)

+ func (b *InMemoryBackend) Snapshot() ([]byte, error)

+ func (b *InMemoryBackend) StartJanitor(ctx context.Context)

+ func (b *InMemoryBackend) StartQueryPlanning(queryString string) string

+ func (b *InMemoryBackend) StartTransaction(transactionType string) string

+ func (b *InMemoryBackend) TagCount() int

+ func (b *InMemoryBackend) TransactionCount() int

+ func (b *InMemoryBackend) UpdateDataCellsFilter(filter *DataCellsFilter) error

+ func (b *InMemoryBackend) UpdateLFTag(catalogID, tagKey string, tagValuesToAdd, tagValuesToDelete []string) error

+ func (b *InMemoryBackend) UpdateLFTagExpression(name, catalogID, description string, expression []LFTag) error

+ func (b *InMemoryBackend) UpdateLakeFormationIdentityCenterConfiguration(catalogID string, externalFiltering *ExternalFilteringConfiguration, ...) error

+ func (b *InMemoryBackend) UpdateResource(resourceArn, roleArn string) error

+ func (b *InMemoryBackend) UpdateTableObjects(catalogID, databaseName, tableName, transactionID string, ...) error

+ func (b *InMemoryBackend) UpdateTableStorageOptimizer(catalogID, databaseName, tableName string, config map[string]map[string]string) string

+ type LFOptIn struct

+ LastModified string

+ LastUpdatedBy string

+ Principal *DataLakePrincipal

+ Resource *Resource

+ type LFTag struct

+ CatalogID string

+ TagKey string

+ TagValues []string

+ type LFTagError struct

+ Error *errorDetail

+ LFTag *LFTagPair

+ type LFTagExpression struct

+ CatalogID string

+ Description string

+ Expression []LFTag

+ Name string

+ type LFTagPair struct

+ CatalogID string

+ TagKey string

+ TagValues []string

+ type Partition struct

+ Values []string

+ type PartitionedTableObjectsList struct

+ Objects []TableObject

+ PartitionValues []string

+ type PermissionEntry struct

+ Permissions []string

+ PermissionsWithGrantOption []string

+ Principal *DataLakePrincipal

+ Resource *Resource

+ type PlanningStatistics struct

+ EstimatedDataToScanBytes *int64

+ PlanningTimeMillis *int64

+ QueueTimeMillis *int64

+ WorkUnitsGeneratedCount *int64

+ type PrincipalPermissions struct

+ Permissions []string

+ Principal *DataLakePrincipal

+ type Provider struct

+ func (p *Provider) Init(ctx *service.AppContext) (service.Registerable, error)

+ func (p *Provider) Name() string

+ type QueryPlanningContext struct

+ CatalogID string

+ DatabaseName string

+ QueryAsOfTime *string

+ QueryParameters map[string]string

+ TransactionID string

+ type Resource struct

+ Catalog *CatalogResource

+ DataLocation *DataLocationResource

+ Database *DatabaseResource

+ Table *TableResource

+ TableWithColumns *TableWithColumnsResource

+ type ResourceInfo struct

+ LastModified *time.Time

+ ResourceArn string

+ RoleArn string

+ type RowFilter struct

+ FilterExpression string

+ type SAMLCredentials struct

+ AccessKeyID string

+ Expiration float64

+ SecretAccessKey string

+ SessionToken string

+ type StorageBackend interface

+ AddLFTagsToResource func(catalogID string, resource *Resource, lfTags []LFTagPair) []LFTagError

+ AssumeDecoratedRoleWithSAML func(principalArn, roleArn, samlAssertion string, durationSeconds *int32) *SAMLCredentials

+ BatchGrantPermissions func(entries []*PermissionEntry) []*BatchFailureEntry

+ BatchRevokePermissions func(entries []*PermissionEntry) []*BatchFailureEntry

+ CancelTransaction func(transactionID string) error

+ CommitTransaction func(transactionID string) (string, error)

+ CreateDataCellsFilter func(filter *DataCellsFilter) error

+ CreateLFTag func(catalogID, tagKey string, tagValues []string) error

+ CreateLFTagExpression func(name, description, catalogID string, expression []LFTag) error

+ CreateLakeFormationIdentityCenterConfiguration func(catalogID, instanceArn string, ...) (string, error)

+ CreateLakeFormationOptIn func(principal *DataLakePrincipal, resource *Resource) error

+ DeleteDataCellsFilter func(tableCatalogID, databaseName, tableName, name string) error

+ DeleteLFTag func(catalogID, tagKey string) error

+ DeleteLFTagExpression func(name, catalogID string) error

+ DeleteLakeFormationIdentityCenterConfiguration func(catalogID string) error

+ DeleteLakeFormationOptIn func(principal *DataLakePrincipal, resource *Resource) error

+ DeleteObjectsOnCancel func(transactionID string) error

+ DeregisterResource func(resourceArn string) error

+ DescribeLakeFormationIdentityCenterConfiguration func(catalogID string) (*IdentityCenterConfiguration, error)

+ DescribeResource func(resourceArn string) (*ResourceInfo, error)

+ DescribeTransaction func(transactionID string) (*Transaction, error)

+ ExtendTransaction func(transactionID string) error

+ GetDataCellsFilter func(tableCatalogID, databaseName, tableName, name string) (*DataCellsFilter, error)

+ GetDataLakePrincipal func(ctx context.Context) *DataLakePrincipal

+ GetDataLakeSettings func() *DataLakeSettings

+ GetEffectivePermissionsForPath func(resourceArn string, maxResults int, nextToken string) ([]*PermissionEntry, string)

+ GetLFTag func(catalogID, tagKey string) (*LFTag, error)

+ GetLFTagExpression func(name, catalogID string) (*LFTagExpression, error)

+ GetQueryState func(queryID string) (string, error)

+ GetQueryStatistics func(queryID string) (*ExecutionStatistics, *PlanningStatistics, error)

+ GetResourceLFTags func(catalogID string, resource *Resource) ([]LFTagPair, error)

+ GetTableObjects func(catalogID, databaseName, tableName, transactionID string, maxResults int, ...) ([]PartitionedTableObjectsList, string)

+ GetTemporaryCredentials func(durationSeconds *int32) *TemporaryCredentials

+ GetWorkUnitResults func(queryID, workUnitToken string) (string, error)

+ GetWorkUnits func(queryID string) ([]WorkUnitRange, string, error)

+ GrantPermissions func(entry *PermissionEntry) error

+ ListDataCellsFilter func(tableCatalogID, databaseName, tableName string, maxResults int, ...) ([]*DataCellsFilter, string)

+ ListLFTagExpressions func(catalogID string, maxResults int, nextToken string) ([]*LFTagExpression, string)

+ ListLFTags func(catalogID string, maxResults int, nextToken string) ([]*LFTag, string)

+ ListLakeFormationOptIns func(principalIdentifier string, resource *Resource, maxResults int, ...) ([]*LFOptIn, string)

+ ListPermissions func(resourceArn string, maxResults int, nextToken string, ...) ([]*PermissionEntry, string)

+ ListResources func(maxResults int, nextToken string) ([]*ResourceInfo, string)

+ ListTableStorageOptimizers func(catalogID, databaseName, tableName, storageOptimizerType string) []StorageOptimizer

+ ListTransactions func(statusFilter string, maxResults int, nextToken string) ([]*Transaction, string)

+ PutDataLakeSettings func(settings *DataLakeSettings)

+ RegisterResource func(resourceArn, roleArn string) error

+ RemoveLFTagsFromResource func(catalogID string, resource *Resource, lfTags []LFTagPair) []LFTagError

+ Reset func()

+ RevokePermissions func(entry *PermissionEntry) error

+ SearchDatabasesByLFTags func(expression []LFTag, catalogID string, maxResults int, nextToken string) ([]TaggedDatabase, string)

+ SearchTablesByLFTags func(expression []LFTag, catalogID string, maxResults int, nextToken string) ([]TaggedTable, string)

+ StartQueryPlanning func(queryString string) string

+ StartTransaction func(transactionType string) string

+ UpdateDataCellsFilter func(filter *DataCellsFilter) error

+ UpdateLFTag func(catalogID, tagKey string, tagValuesToAdd, tagValuesToDelete []string) error

+ UpdateLFTagExpression func(name, catalogID, description string, expression []LFTag) error

+ UpdateLakeFormationIdentityCenterConfiguration func(catalogID string, externalFiltering *ExternalFilteringConfiguration, ...) error

+ UpdateResource func(resourceArn, roleArn string) error

+ UpdateTableObjects func(catalogID, databaseName, tableName, transactionID string, ...) error

+ UpdateTableStorageOptimizer func(catalogID, databaseName, tableName string, config map[string]map[string]string) string

+ type StorageOptimizer struct

+ Config map[string]string

+ ErrorMessage string

+ StorageOptimizerType string

+ type TableObject struct

+ ETag string

+ Size *int64

+ URI string

+ type TableResource struct

+ CatalogID string

+ DatabaseName string

+ Name string

+ type TableWithColumnsResource struct

+ CatalogID string

+ ColumnNames []string

+ DatabaseName string

+ Name string

+ type TaggedDatabase struct

+ Database *DatabaseResource

+ LFTags []LFTagPair

+ type TaggedTable struct

+ LFTagOnDatabase []LFTagPair

+ LFTagsOnColumns []ColumnLFTag

+ LFTagsOnTable []LFTagPair

+ Table *TableResource

+ type TemporaryCredentials struct

+ AccessKeyID string

+ Expiration float64

+ SecretAccessKey string

+ SessionToken string

+ type Transaction struct

+ TransactionEndTime string

+ TransactionID string

+ TransactionStartTime string

+ TransactionStatus string

+ type VirtualObject struct

+ ETag string

+ URI string

+ type WorkUnitRange struct

+ WorkUnitIDMax int64

+ WorkUnitIDMin int64

+ WorkUnitToken string

+ type WriteOperation struct

+ AddObject *TableObject

+ DeleteObject *VirtualObject

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