storage

package
v0.0.2 Latest Latest
Warning

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

Go to latest
Published: Nov 24, 2025 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AttributeProvider

type AttributeProvider interface {
	// GetUserAttributes fetches user attributes (roles, department, metadata)
	GetUserAttributes(ctx context.Context, userID xid.ID) (map[string]interface{}, error)

	// GetResourceAttributes fetches resource attributes (owner, tags, metadata)
	GetResourceAttributes(ctx context.Context, resourceType string, resourceID xid.ID) (map[string]interface{}, error)

	// GetRequestAttributes fetches request context (IP, time, geo)
	GetRequestAttributes(ctx context.Context) (map[string]interface{}, error)
}

AttributeProvider fetches attributes for ABAC evaluation Updated for V2 architecture: App → Environment → Organization

type AuditFilters

type AuditFilters struct {
	ActorID      *xid.ID
	Action       *string
	ResourceType *string
	StartTime    *time.Time
	EndTime      *time.Time
	Limit        int
	Offset       int
}

AuditFilters defines filtering options for audit queries

type Cache

type Cache interface {
	// Get retrieves a compiled policy from cache
	Get(ctx context.Context, key string) (*engine.CompiledPolicy, error)

	// Set stores a compiled policy in cache
	Set(ctx context.Context, key string, policy *engine.CompiledPolicy, ttl time.Duration) error

	// Delete removes a policy from cache
	Delete(ctx context.Context, key string) error

	// DeleteByApp removes all policies for an app
	DeleteByApp(ctx context.Context, appID xid.ID) error

	// DeleteByOrganization removes all policies for a user-created organization
	DeleteByOrganization(ctx context.Context, appID xid.ID, userOrgID xid.ID) error

	// GetMulti retrieves multiple policies
	GetMulti(ctx context.Context, keys []string) (map[string]*engine.CompiledPolicy, error)

	// SetMulti stores multiple policies
	SetMulti(ctx context.Context, policies map[string]*engine.CompiledPolicy, ttl time.Duration) error

	// Stats returns cache statistics
	Stats() CacheStats
}

Cache defines the caching interface for compiled policies Updated for V2 architecture: App → Environment → Organization

func NewMemoryCache

func NewMemoryCache(config interface{}) Cache

NewMemoryCache creates a new memory cache (stub)

func NewRedisCache

func NewRedisCache(client *redis.Client, config interface{}) Cache

NewRedisCache creates a new Redis cache (stub)

type CacheStats

type CacheStats struct {
	Hits        int64
	Misses      int64
	Evictions   int64
	Size        int64
	HitRate     float64
	LastUpdated time.Time
}

CacheStats provides cache performance metrics

type MemoryCache

type MemoryCache struct{}

MemoryCache is an in-memory cache implementation (stub) Updated for V2 architecture: App → Environment → Organization

func (*MemoryCache) Delete

func (c *MemoryCache) Delete(ctx context.Context, key string) error

func (*MemoryCache) DeleteByApp

func (c *MemoryCache) DeleteByApp(ctx context.Context, appID xid.ID) error

func (*MemoryCache) DeleteByOrganization

func (c *MemoryCache) DeleteByOrganization(ctx context.Context, appID xid.ID, userOrgID xid.ID) error

func (*MemoryCache) Get

func (*MemoryCache) GetMulti

func (c *MemoryCache) GetMulti(ctx context.Context, keys []string) (map[string]*engine.CompiledPolicy, error)

func (*MemoryCache) Set

func (c *MemoryCache) Set(ctx context.Context, key string, policy *engine.CompiledPolicy, ttl time.Duration) error

func (*MemoryCache) SetMulti

func (c *MemoryCache) SetMulti(ctx context.Context, policies map[string]*engine.CompiledPolicy, ttl time.Duration) error

func (*MemoryCache) Stats

func (c *MemoryCache) Stats() CacheStats

type PolicyFilters

type PolicyFilters struct {
	ResourceType *string
	Actions      []string
	Enabled      *bool
	NamespaceID  *xid.ID
	Limit        int
	Offset       int
}

PolicyFilters defines filtering options for policy queries

type RedisCache

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

RedisCache is a Redis-backed cache implementation (stub) Updated for V2 architecture: App → Environment → Organization

func (*RedisCache) Delete

func (c *RedisCache) Delete(ctx context.Context, key string) error

func (*RedisCache) DeleteByApp

func (c *RedisCache) DeleteByApp(ctx context.Context, appID xid.ID) error

func (*RedisCache) DeleteByOrganization

func (c *RedisCache) DeleteByOrganization(ctx context.Context, appID xid.ID, userOrgID xid.ID) error

func (*RedisCache) Get

func (*RedisCache) GetMulti

func (c *RedisCache) GetMulti(ctx context.Context, keys []string) (map[string]*engine.CompiledPolicy, error)

func (*RedisCache) Set

func (c *RedisCache) Set(ctx context.Context, key string, policy *engine.CompiledPolicy, ttl time.Duration) error

func (*RedisCache) SetMulti

func (c *RedisCache) SetMulti(ctx context.Context, policies map[string]*engine.CompiledPolicy, ttl time.Duration) error

func (*RedisCache) Stats

func (c *RedisCache) Stats() CacheStats

type Repository

type Repository interface {
	// Policy operations
	CreatePolicy(ctx context.Context, policy *core.Policy) error
	GetPolicy(ctx context.Context, id xid.ID) (*core.Policy, error)
	ListPolicies(ctx context.Context, appID xid.ID, userOrgID *xid.ID, filters PolicyFilters) ([]*core.Policy, error)
	UpdatePolicy(ctx context.Context, policy *core.Policy) error
	DeletePolicy(ctx context.Context, id xid.ID) error
	GetPoliciesByResourceType(ctx context.Context, appID xid.ID, userOrgID *xid.ID, resourceType string) ([]*core.Policy, error)
	GetActivePolicies(ctx context.Context, appID xid.ID, userOrgID *xid.ID) ([]*core.Policy, error)

	// Namespace operations
	CreateNamespace(ctx context.Context, ns *core.Namespace) error
	GetNamespace(ctx context.Context, id xid.ID) (*core.Namespace, error)
	GetNamespaceByScope(ctx context.Context, appID xid.ID, userOrgID *xid.ID) (*core.Namespace, error)
	UpdateNamespace(ctx context.Context, ns *core.Namespace) error
	DeleteNamespace(ctx context.Context, id xid.ID) error

	// Resource definition operations
	CreateResourceDefinition(ctx context.Context, res *core.ResourceDefinition) error
	ListResourceDefinitions(ctx context.Context, namespaceID xid.ID) ([]*core.ResourceDefinition, error)
	DeleteResourceDefinition(ctx context.Context, id xid.ID) error

	// Action definition operations
	CreateActionDefinition(ctx context.Context, action *core.ActionDefinition) error
	ListActionDefinitions(ctx context.Context, namespaceID xid.ID) ([]*core.ActionDefinition, error)
	DeleteActionDefinition(ctx context.Context, id xid.ID) error

	// Audit operations
	CreateAuditEvent(ctx context.Context, event *core.AuditEvent) error
	ListAuditEvents(ctx context.Context, appID xid.ID, userOrgID *xid.ID, filters AuditFilters) ([]*core.AuditEvent, error)
}

Repository defines the data access interface for permissions Updated for V2 architecture: App → Environment → Organization

func NewRepository

func NewRepository(db *bun.DB) Repository

NewRepository creates a new Bun repository

Jump to

Keyboard shortcuts

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