vnode

package
v0.1.147 Latest Latest
Warning

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

 Go to latest Published: Apr 7, 2026 License: AGPL-3.0, AGPL-3.0-or-later Imports: 23 Imported by: 0

Documentation

Overview

Package vnode provides virtual filesystem nodes for the FUSE layer.

SourcesVNode handles /sources/{integration}/ paths as a view-based filesystem. Content is accessed ONLY through source views - native provider content (like messages/, labels/) is not exposed directly.

Usage: 

ls /sources/gmail/unread-emails/      <- executes view query, shows results
cat /sources/gmail/unread-emails/.query.as <- shows view definition
cat /sources/gmail/unread-emails/msg.txt <- reads materialized result

Structure: 

/sources/                            <- lists available integrations
/sources/gmail/                      <- lists user-created views only
/sources/gmail/unread-emails/        <- materialized view folder (read-only)
  .query.as                          <- view definition (JSON)
  2026-01-28_invoice_abc.txt         <- materialized search results

Index

Constants

View Source 
const (
	ToolsPath         = types.PathTools
	ToolsPathPrefix   = types.PathTools + "/"
	SkillsPath        = types.PathSkills
	SkillsPathPrefix  = types.PathSkills + "/"
	TasksPath         = types.PathTasks
	TasksPathPrefix   = types.PathTasks + "/"
	SourcesPath       = types.PathSources
	SourcesPathPrefix = types.PathSources + "/"
	ConfigDir         = "/.airstore"
	ConfigFile        = "/.airstore/config"
	ConfigToolShim    = "/.airstore/tool-shim"
)

Re-export path constants from types for backward compatibility. New code should import from types directly.

View Source 
const (
	CacheSourceUnknown        = "unknown"
	CacheSourceBackendRPC     = "backend_rpc"
	CacheSourceOpenContent    = "open_content"
	CacheSourceContentCache   = "content_cache"
	CacheSourcePrefetch       = "prefetch"
	CacheSourceDirtyBuffer    = "dirty_buffer"
	CacheSourceSynthetic      = "synthetic"
	CacheSourceMetadata       = "metadata"
	CacheSourceLegacyMetadata = "legacy_metadata"
)
View Source 
const (
	// ToolsCacheTTL is the time-to-live for the tools cache
	ToolsCacheTTL = 5 * time.Second
)

Variables

View Source 
var (
	ErrReadOnly     = syscall.EROFS
	ErrNotSupported = syscall.ENOTSUP
	ErrNotFound     = syscall.ENOENT
)

Functions

func BearerToken added in v0.1.34 

func BearerToken(token string) string

BearerToken returns a precomputed "Bearer <token>" string for gRPC auth metadata. If token is empty, returns empty (caller should skip attaching metadata).

func GetOwner added in v0.1.23 

func GetOwner() (uid, gid uint32)

GetOwner returns the current owner uid/gid. Uses a single atomic load — no locks, no contention.

func InitOwner added in v0.1.23 

func InitOwner(uid, gid *uint32)

InitOwner sets file ownership for this mount (thread-safe). If uid/gid are nil, defaults to the current user. To explicitly set root ownership, pass pointers to 0.

func PathIno 

func PathIno(path string) uint64

PathIno generates a stable inode from a path (FNV-1a).

Types

type AsyncWriter added in v0.1.24 

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

AsyncWriter buffers writes in memory and flushes to the backend asynchronously with debouncing. Multiple rapid writes to the same path are coalesced into a single upload.

func NewAsyncWriter added in v0.1.24 

func NewAsyncWriter(fn WriteFn) *AsyncWriter

NewAsyncWriter creates a new async writer that calls fn for uploads.

func (*AsyncWriter) Cleanup added in v0.1.24 

func (aw *AsyncWriter) Cleanup()

Cleanup flushes all pending writes synchronously. Called on unmount.

func (*AsyncWriter) DirtyFileInfo added in v0.1.26 

func (aw *AsyncWriter) DirtyFileInfo(path string, fallbackMode uint32) *FileInfo

DirtyFileInfo returns a FileInfo reflecting pending dirty data for a path. If fallbackMode is 0, defaults to S_IFREG|0644. Used by Getattr to report the correct size for files that have been written but not yet uploaded.

func (*AsyncWriter) Enqueue added in v0.1.24 

func (aw *AsyncWriter) Enqueue(path string, off int64, data []byte)

Enqueue buffers a write for async upload. Returns immediately. Repeated calls for the same path reset the debounce timer and replace the pending data, so only the latest version is uploaded.

func (*AsyncWriter) EnqueueNoTimer added in v0.1.24 

func (aw *AsyncWriter) EnqueueNoTimer(path string, off int64, data []byte)

EnqueueNoTimer stores data without starting the debounce timer. Used by Truncate(0) to mark the file as empty without racing against the subsequent Write that supplies the real content. The timer will be started by the next regular Enqueue (from flushWriteBuffer when real data arrives). If no Write follows, ForceFlush in Release/Fsync will still upload the data.

func (*AsyncWriter) ForceFlush added in v0.1.24 

func (aw *AsyncWriter) ForceFlush(path string) error

ForceFlush synchronously flushes any pending write for the given path. Blocks until all pending data has been uploaded. Used by Fsync and Release.

func (*AsyncWriter) Get added in v0.1.24 

func (aw *AsyncWriter) Get(path string) (data []byte, off int64, ok bool)

Get returns the pending (dirty) data for a path, if any. Used by Read to serve data that hasn't been uploaded yet.

type CacheEntry 

type CacheEntry struct {
	Info      *FileInfo
	Children  []DirEntry
	ChildMeta map[string]*FileInfo
}

CacheEntry holds cached metadata

type ChmodNode added in v0.1.66 

type ChmodNode interface {
	Chmod(path string, mode uint32) error
}

ChmodNode is an optional vnode capability for chmod support. Filesystem delegates chmod calls to nodes implementing this interface.

type Config 

type Config struct {
	GatewayAddr string `json:"gateway_addr"`
	Token       string `json:"token,omitempty"`
}

Config holds the filesystem configuration exposed to tools

type ConfigVNode 

type ConfigVNode struct {
	ReadOnlyBase // Embeds read-only defaults for write operations
	// contains filtered or unexported fields
}

ConfigVNode exposes filesystem configuration at /.airstore Tools read /.airstore/config to discover gateway settings

func NewConfigVNode 

func NewConfigVNode(gatewayAddr, token string, toolShim []byte) *ConfigVNode

NewConfigVNode creates a ConfigVNode with the given settings

func (*ConfigVNode) Getattr 

func (c *ConfigVNode) Getattr(path string) (*FileInfo, error)

Getattr returns file attributes

func (*ConfigVNode) Open 

func (c *ConfigVNode) Open(path string, flags int) (FileHandle, error)

Open opens a file

func (*ConfigVNode) Prefix 

func (c *ConfigVNode) Prefix() string

Prefix returns the path prefix this node handles

func (*ConfigVNode) Read 

func (c *ConfigVNode) Read(path string, buf []byte, off int64, fh FileHandle) (int, error)

Read reads from the config file

func (*ConfigVNode) Readdir 

func (c *ConfigVNode) Readdir(path string) ([]DirEntry, error)

Readdir returns directory entries

type ContentCache added in v0.1.17 

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

ContentCache is a small in-memory cache for file contents. Entries are served only if the current mtime matches.

func NewContentCache added in v0.1.17 

func NewContentCache() *ContentCache

NewContentCache creates a new content cache for small files.

func (*ContentCache) Get added in v0.1.17 

func (c *ContentCache) Get(path string, currentMtime int64) ([]byte, bool)

Get returns cached content only if mtime matches.

func (*ContentCache) Invalidate added in v0.1.70 

func (c *ContentCache) Invalidate(path string)

Invalidate removes a cached content entry for a path.

func (*ContentCache) Set added in v0.1.17 

func (c *ContentCache) Set(path string, data []byte, mtime int64)

Set stores content if it is small enough to cache.

type ContentEntry added in v0.1.17 

type ContentEntry struct {
	Data     []byte
	Mtime    int64
	Size     int64
	CachedAt time.Time
}

ContentEntry holds cached file contents with mtime validation.

type ContextVNodeGRPC 

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

ContextVNodeGRPC implements VirtualNode for S3-backed context storage. It supports all read and write operations. The prefix determines the mount path (e.g., "/skills").

func NewContextVNodeGRPC 

func NewContextVNodeGRPC(conn *grpc.ClientConn, token string, prefix string) *ContextVNodeGRPC

NewContextVNodeGRPC creates a new context virtual node with the given prefix. The prefix determines the mount path (e.g., types.PathSkills).

func (*ContextVNodeGRPC) Chmod added in v0.1.66 

func (c *ContextVNodeGRPC) Chmod(path string, mode uint32) error

Chmod updates mode metadata for files/directories.

func (*ContextVNodeGRPC) Cleanup added in v0.1.24 

func (c *ContextVNodeGRPC) Cleanup()

Cleanup stops background goroutines and flushes all pending async writes.

func (*ContextVNodeGRPC) Create 

func (c *ContextVNodeGRPC) Create(path string, flags int, mode uint32) (FileHandle, error)

Create creates a new file

func (*ContextVNodeGRPC) Fsync 

func (c *ContextVNodeGRPC) Fsync(path string, fh FileHandle) error

Fsync forces all pending writes to be uploaded to S3.

func (*ContextVNodeGRPC) Getattr 

func (c *ContextVNodeGRPC) Getattr(path string) (*FileInfo, error)

Getattr returns file attributes with caching

func (*ContextVNodeGRPC) Mkdir 

func (c *ContextVNodeGRPC) Mkdir(path string, mode uint32) error

Mkdir creates a directory

func (*ContextVNodeGRPC) Open 

func (c *ContextVNodeGRPC) Open(path string, flags int) (FileHandle, error)

Open opens a file, using cache to avoid redundant Stat calls. On macOS, some paths use Open with O_CREAT instead of Create, so we handle that here.

func (*ContextVNodeGRPC) OpenHandleCount added in v0.1.86 

func (c *ContextVNodeGRPC) OpenHandleCount() int

func (*ContextVNodeGRPC) Prefix 

func (c *ContextVNodeGRPC) Prefix() string

func (*ContextVNodeGRPC) Read 

func (c *ContextVNodeGRPC) Read(path string, buf []byte, off int64, fh FileHandle) (int, error)

Read reads file data

func (*ContextVNodeGRPC) ReadWithAttribution added in v0.1.47 

func (c *ContextVNodeGRPC) ReadWithAttribution(path string, buf []byte, off int64, fh FileHandle) (int, *ReadAttribution, error)

func (*ContextVNodeGRPC) Readdir 

func (c *ContextVNodeGRPC) Readdir(path string) ([]DirEntry, error)

Readdir returns directory entries, caching child metadata from enriched response 

func (c *ContextVNodeGRPC) Readlink(path string) (string, error)

Readlink reads symlink target

func (*ContextVNodeGRPC) Release 

func (c *ContextVNodeGRPC) Release(path string, fh FileHandle) error

Release closes a file handle

func (*ContextVNodeGRPC) Rename 

func (c *ContextVNodeGRPC) Rename(oldpath, newpath string) error

Rename moves or renames a file or directory

func (*ContextVNodeGRPC) Rmdir 

func (c *ContextVNodeGRPC) Rmdir(path string) error

Rmdir removes a directory 

func (c *ContextVNodeGRPC) Symlink(target, linkPath string) error

Symlink creates a symbolic link

func (*ContextVNodeGRPC) Truncate 

func (c *ContextVNodeGRPC) Truncate(path string, size int64, fh FileHandle) error

Truncate changes file size

func (*ContextVNodeGRPC) Type 

func (c *ContextVNodeGRPC) Type() VNodeType
func (c *ContextVNodeGRPC) Unlink(path string) error

Unlink removes a file

func (*ContextVNodeGRPC) Write 

func (c *ContextVNodeGRPC) Write(path string, buf []byte, off int64, fh FileHandle) (int, error)

Write writes file data

type DirEntry 

type DirEntry struct {
	Name  string
	Mode  uint32
	Ino   uint64
	Size  int64 // File size (0 for directories)
	Mtime int64 // Unix timestamp (0 = use current time)
}

type FileHandle 

type FileHandle uint64

type FileInfo 

type FileInfo struct {
	Ino                 uint64
	Size                int64
	Mode, Nlink         uint32
	Uid, Gid            uint32
	Atime, Mtime, Ctime time.Time
}

func NewDirInfo 

func NewDirInfo(ino uint64) *FileInfo

func NewExecFileInfo 

func NewExecFileInfo(ino uint64, size int64) *FileInfo

func NewFileInfo 

func NewFileInfo(ino uint64, size int64, mode uint32) *FileInfo

func NewSymlinkInfo 

func NewSymlinkInfo(ino uint64, targetLen int64) *FileInfo

type MetadataCache 

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

MetadataCache wraps an LRU cache for filesystem metadata with parent-child awareness.

func NewMetadataCache 

func NewMetadataCache() *MetadataCache

NewMetadataCache creates a new cache

func (*MetadataCache) AddChild added in v0.1.17 

func (c *MetadataCache) AddChild(parentPath string, child DirEntry, childInfo *FileInfo)

AddChild adds a new child entry to parent's cache without invalidating existing siblings. This is useful after creating a new file/directory.

func (*MetadataCache) Get 

func (c *MetadataCache) Get(p string) *CacheEntry

Get returns cached entry or nil

func (*MetadataCache) GetInfo 

func (c *MetadataCache) GetInfo(p string) *FileInfo

GetInfo returns FileInfo from cache, checking parent's ChildMeta on miss

func (*MetadataCache) Invalidate 

func (c *MetadataCache) Invalidate(p string)

Invalidate removes path and parent's children cache

func (*MetadataCache) InvalidateChild added in v0.1.17 

func (c *MetadataCache) InvalidateChild(parentPath, childName string)

InvalidateChild removes a specific child from parent's cache without invalidating siblings. This is more efficient than Invalidate when only one child has changed.

func (*MetadataCache) IsNegative 

func (c *MetadataCache) IsNegative(p string) bool

IsNegative returns true if path is known to not exist

func (*MetadataCache) Set 

func (c *MetadataCache) Set(p string, info *FileInfo)

Set caches metadata for a path

func (*MetadataCache) SetNegative 

func (c *MetadataCache) SetNegative(p string)

SetNegative marks path as non-existent

func (*MetadataCache) SetWithChildren 

func (c *MetadataCache) SetWithChildren(p string, children []DirEntry, childMeta map[string]*FileInfo)

SetWithChildren caches directory with enriched child metadata

type ReadAttribution added in v0.1.47 

type ReadAttribution struct {
	CacheSource      string
	Integration      string
	SourceURI        string
	QueryPath        string
	ResultID         string
	Strategy         string
	Outcome          string
	OriginalBytes    int
	CompressedBytes  int
	OriginalTokens   int
	CompressedTokens int
	CompressionMs    int64
	FetchMs          int64 // e2e content fetch duration (e.g. time to fetch from Gmail during Open)
}

ReadAttribution carries read-path metadata used by mount-level access logs. It is emitted per logical read and can be attached by vnodes that know where bytes came from (cache vs backend) and, for source reads, token-cost details.

func AttributionForCache added in v0.1.47 

func AttributionForCache(cacheSource string) *ReadAttribution

func AttributionFromCostHint added in v0.1.47 

func AttributionFromCostHint(cacheSource string, hint *pb.SourceReadCostHint) *ReadAttribution

type ReadAttributionNode added in v0.1.47 

type ReadAttributionNode interface {
	ReadWithAttribution(path string, buf []byte, off int64, fh FileHandle) (int, *ReadAttribution, error)
}

ReadAttributionNode is an optional vnode extension that returns attribution metadata alongside read bytes.

type ReadOnlyBase 

type ReadOnlyBase struct{}

ReadOnlyBase returns ErrReadOnly for all write operations. Embed this in VNodes that don't support writes (e.g., /tools/).

func (ReadOnlyBase) Create 

func (ReadOnlyBase) Create(string, int, uint32) (FileHandle, error)

func (ReadOnlyBase) Fsync 

func (ReadOnlyBase) Fsync(string, FileHandle) error

func (ReadOnlyBase) Mkdir 

func (ReadOnlyBase) Mkdir(string, uint32) error
func (ReadOnlyBase) Readlink(string) (string, error)

func (ReadOnlyBase) Release 

func (ReadOnlyBase) Release(string, FileHandle) error

func (ReadOnlyBase) Rename 

func (ReadOnlyBase) Rename(string, string) error

func (ReadOnlyBase) Rmdir 

func (ReadOnlyBase) Rmdir(string) error
func (ReadOnlyBase) Symlink(string, string) error

func (ReadOnlyBase) Truncate 

func (ReadOnlyBase) Truncate(string, int64, FileHandle) error

func (ReadOnlyBase) Type 

func (ReadOnlyBase) Type() VNodeType
func (ReadOnlyBase) Unlink(string) error

func (ReadOnlyBase) Write 

func (ReadOnlyBase) Write(string, []byte, int64, FileHandle) (int, error)

type Registry 

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

Registry matches paths to virtual nodes.

func NewRegistry 

func NewRegistry() *Registry

func (*Registry) Fallback 

func (r *Registry) Fallback() VirtualNode

func (*Registry) List 

func (r *Registry) List() []VirtualNode

func (*Registry) Match 

func (r *Registry) Match(path string) VirtualNode

Match returns the VirtualNode whose prefix matches path, or nil. Zero allocations — prefixes are precomputed at registration time.

func (*Registry) MatchOrFallback 

func (r *Registry) MatchOrFallback(path string) VirtualNode

func (*Registry) Register 

func (r *Registry) Register(node VirtualNode)

func (*Registry) SetFallback 

func (r *Registry) SetFallback(node VirtualNode)

type SourcesVNode 

type SourcesVNode struct {
	ReadOnlyBase
	// contains filtered or unexported fields
}

func NewSourcesVNode 

func NewSourcesVNode(conn *grpc.ClientConn, token string, opts ...SourcesVNodeOption) *SourcesVNode

NewSourcesVNode creates a new SourcesVNode.

func (*SourcesVNode) Cleanup 

func (v *SourcesVNode) Cleanup()

Cleanup stops background goroutines. Called when filesystem is unmounted.

func (*SourcesVNode) Create 

func (v *SourcesVNode) Create(path string, flags int, mode uint32) (FileHandle, error)

Create is not supported for /sources in the mounted VFS. Source views are managed by gateway-side APIs, not filesystem writes.

func (*SourcesVNode) Getattr 

func (v *SourcesVNode) Getattr(path string) (*FileInfo, error)

Getattr returns file/directory attributes.

func (*SourcesVNode) Mkdir 

func (v *SourcesVNode) Mkdir(path string, mode uint32) error

Mkdir is not supported for /sources in the mounted VFS. Source views are managed by gateway-side APIs, not filesystem writes.

func (*SourcesVNode) Open 

func (v *SourcesVNode) Open(path string, flags int) (FileHandle, error)

Open opens a file.

func (*SourcesVNode) Prefix 

func (v *SourcesVNode) Prefix() string

func (*SourcesVNode) Read 

func (v *SourcesVNode) Read(path string, buf []byte, off int64, fh FileHandle) (int, error)

Read reads file data.

func (*SourcesVNode) ReadWithAttribution added in v0.1.47 

func (v *SourcesVNode) ReadWithAttribution(path string, buf []byte, off int64, fh FileHandle) (int, *ReadAttribution, error)

func (*SourcesVNode) Readdir 

func (v *SourcesVNode) Readdir(path string) ([]DirEntry, error)

Readdir lists directory contents. 

func (v *SourcesVNode) Readlink(path string) (string, error)

Readlink reads symlink target. Note: Symlinks are not supported in the query-only model.

func (*SourcesVNode) Release added in v0.1.23 

func (v *SourcesVNode) Release(path string, fh FileHandle) error

Release closes a file handle.

type SourcesVNodeOption added in v0.1.43 

type SourcesVNodeOption func(*SourcesVNode)

SourcesVNode handles /sources/ - both native content and source views. SourcesVNodeOption configures optional fields on a SourcesVNode.

func WithCompression added in v0.1.43 

func WithCompression(strategy string) SourcesVNodeOption

WithCompression sets the compression strategy (e.g. "strip") forwarded to the gateway via the x-airstore-compression gRPC metadata header.

type StorageVNode 

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

StorageVNode handles S3-backed storage for any path via gRPC. Used as a fallback for paths not matched by specific vnodes.

func NewStorageVNode 

func NewStorageVNode(conn *grpc.ClientConn, token string) *StorageVNode

NewStorageVNode creates a new StorageVNode.

func (*StorageVNode) Chmod added in v0.1.66 

func (s *StorageVNode) Chmod(path string, mode uint32) error

Chmod updates mode metadata for files/directories.

func (*StorageVNode) Cleanup added in v0.1.17 

func (s *StorageVNode) Cleanup()

Cleanup stops background goroutines and flushes pending writes. Called when filesystem is unmounted.

func (*StorageVNode) Create 

func (s *StorageVNode) Create(path string, flags int, mode uint32) (FileHandle, error)

func (*StorageVNode) Fsync 

func (s *StorageVNode) Fsync(path string, fh FileHandle) error

func (*StorageVNode) Getattr 

func (s *StorageVNode) Getattr(path string) (*FileInfo, error)

func (*StorageVNode) Mkdir 

func (s *StorageVNode) Mkdir(path string, mode uint32) error

func (*StorageVNode) Open 

func (s *StorageVNode) Open(path string, flags int) (FileHandle, error)

func (*StorageVNode) OpenHandleCount added in v0.1.86 

func (s *StorageVNode) OpenHandleCount() int

func (*StorageVNode) Prefix 

func (s *StorageVNode) Prefix() string

Prefix returns empty - this is a fallback handler

func (*StorageVNode) Read 

func (s *StorageVNode) Read(path string, buf []byte, off int64, fh FileHandle) (int, error)

func (*StorageVNode) ReadWithAttribution added in v0.1.47 

func (s *StorageVNode) ReadWithAttribution(path string, buf []byte, off int64, fh FileHandle) (int, *ReadAttribution, error)

func (*StorageVNode) Readdir 

func (s *StorageVNode) Readdir(path string) ([]DirEntry, error)
func (s *StorageVNode) Readlink(path string) (string, error)

func (*StorageVNode) Release 

func (s *StorageVNode) Release(path string, fh FileHandle) error

func (*StorageVNode) Rename 

func (s *StorageVNode) Rename(oldpath, newpath string) error

Rename moves or renames a file or directory

func (*StorageVNode) Rmdir 

func (s *StorageVNode) Rmdir(path string) error
func (s *StorageVNode) Symlink(target, linkPath string) error

func (*StorageVNode) Truncate 

func (s *StorageVNode) Truncate(path string, size int64, fh FileHandle) error

func (*StorageVNode) Type 

func (s *StorageVNode) Type() VNodeType
func (s *StorageVNode) Unlink(path string) error

func (*StorageVNode) Write 

func (s *StorageVNode) Write(path string, buf []byte, off int64, fh FileHandle) (int, error)

type TasksVNode 

type TasksVNode struct {
	ReadOnlyBase
	// contains filtered or unexported fields
}

TasksVNode provides /tasks directory listing tasks as files. Each task appears as a file named {task_id}.task

func NewTasksVNode 

func NewTasksVNode(backend repository.BackendRepository, token string) *TasksVNode

NewTasksVNode creates a TasksVNode with database access for task listing. Use this when the backend is available (e.g., in gateway).

func NewTasksVNodeGRPC 

func NewTasksVNodeGRPC(conn *grpc.ClientConn, token string) *TasksVNode

NewTasksVNodeGRPC creates a TasksVNode that fetches tasks via gRPC from the gateway. Use this for CLI mounts where we don't have direct DB access.

func (*TasksVNode) Getattr 

func (t *TasksVNode) Getattr(path string) (*FileInfo, error)

func (*TasksVNode) Open 

func (t *TasksVNode) Open(path string, flags int) (FileHandle, error)

func (*TasksVNode) Prefix 

func (t *TasksVNode) Prefix() string

func (*TasksVNode) Read 

func (t *TasksVNode) Read(path string, buf []byte, off int64, fh FileHandle) (int, error)

func (*TasksVNode) Readdir 

func (t *TasksVNode) Readdir(path string) ([]DirEntry, error)

type ToolsVNode 

type ToolsVNode struct {
	ReadOnlyBase
	// contains filtered or unexported fields
}

ToolsVNode implements VirtualNode for the /tools directory. It serves executable wrappers for tools:

  • Gateway tools: wrapper that copies an embedded shim to local /tmp and execs it
  • Local tools: wrapper that execs the local CLI directly

func NewToolsVNode 

func NewToolsVNode(gatewayAddr string, token string) *ToolsVNode

NewToolsVNode creates a new ToolsVNode.

func (*ToolsVNode) Getattr 

func (t *ToolsVNode) Getattr(path string) (*FileInfo, error)

Getattr returns file attributes for paths under /tools

func (*ToolsVNode) Open 

func (t *ToolsVNode) Open(path string, flags int) (FileHandle, error)

Open opens a tool file

func (*ToolsVNode) Prefix 

func (t *ToolsVNode) Prefix() string

Prefix returns the path prefix this node handles

func (*ToolsVNode) Read 

func (t *ToolsVNode) Read(path string, buf []byte, off int64, fh FileHandle) (int, error)

Read reads bytes from a tool binary (served from memory)

func (*ToolsVNode) Readdir 

func (t *ToolsVNode) Readdir(path string) ([]DirEntry, error)

Readdir returns entries in /tools directory

type VNodeType 

type VNodeType int

VNodeType defines the behavior category of a virtual node 

const (
	// VNodeReadOnly is for read-only paths like /tools/, /.airstore/
	VNodeReadOnly VNodeType = iota
	// VNodeWritable is for fully writable paths like /skills/
	VNodeWritable
)

type VirtualNode 

type VirtualNode interface {
	Prefix() string
	Type() VNodeType

	// Read operations
	Getattr(path string) (*FileInfo, error)
	Readdir(path string) ([]DirEntry, error)
	Open(path string, flags int) (FileHandle, error)
	Read(path string, buf []byte, off int64, fh FileHandle) (int, error)
	Readlink(path string) (string, error)

	// Write operations (behavior depends on VNodeType)
	Create(path string, flags int, mode uint32) (FileHandle, error)
	Write(path string, buf []byte, off int64, fh FileHandle) (int, error)
	Truncate(path string, size int64, fh FileHandle) error
	Mkdir(path string, mode uint32) error
	Rmdir(path string) error
	Unlink(path string) error
	Rename(oldpath, newpath string) error
	Symlink(target, linkPath string) error

	// Lifecycle
	Release(path string, fh FileHandle) error
	Fsync(path string, fh FileHandle) error
}

VirtualNode handles a path prefix in the virtual filesystem.

Write semantics by VNodeType:

  • VNodeReadOnly: All writes return ErrReadOnly (e.g., /tools/, /.airstore/)
  • VNodeWritable: Full read/write access (e.g., /skills/)

type WriteFn added in v0.1.24 

type WriteFn func(path string, off int64, data []byte) error

WriteFn uploads data to the backend (gRPC → S3). Called asynchronously.

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.