services

package
v0.1.21 Latest Latest
Warning

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

 Go to latest Published: Feb 4, 2026 License: AGPL-3.0, AGPL-3.0-or-later Imports: 30 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ContextService 

type ContextService struct {
	pb.UnimplementedContextServiceServer
	// contains filtered or unexported fields
}

ContextService provides S3-backed file storage for workspace context.

func NewContextService 

func NewContextService(cfg types.S3Config) (*ContextService, error)

NewContextService creates a new context service with retry and timeout configuration

func (*ContextService) Create 

func (s *ContextService) Create(ctx context.Context, req *pb.ContextCreateRequest) (*pb.ContextCreateResponse, error)

Create creates a new empty file

func (*ContextService) Delete 

func (s *ContextService) Delete(ctx context.Context, req *pb.ContextDeleteRequest) (*pb.ContextDeleteResponse, error)

Delete removes a file or directory

func (*ContextService) ListTree 

func (s *ContextService) ListTree(ctx context.Context, req *pb.ListTreeRequest) (*pb.ListTreeResponse, error)

ListTree returns flat listing of subtree (for future prefetching)

func (*ContextService) Mkdir 

func (s *ContextService) Mkdir(ctx context.Context, req *pb.ContextMkdirRequest) (*pb.ContextMkdirResponse, error)

Mkdir creates a directory

func (*ContextService) Read 

func (s *ContextService) Read(ctx context.Context, req *pb.ContextReadRequest) (*pb.ContextReadResponse, error)

Read reads file content with size limits to prevent OOM

func (*ContextService) ReadDir 

func (s *ContextService) ReadDir(ctx context.Context, req *pb.ContextReadDirRequest) (*pb.ContextReadDirResponse, error)

ReadDir lists directory contents with full metadata 

func (s *ContextService) Readlink(ctx context.Context, req *pb.ContextReadlinkRequest) (*pb.ContextReadlinkResponse, error)

Readlink reads a symbolic link target

func (*ContextService) Rename 

func (s *ContextService) Rename(ctx context.Context, req *pb.ContextRenameRequest) (*pb.ContextRenameResponse, error)

Rename moves/renames a file or directory (copy then delete)

func (*ContextService) Stat 

func (s *ContextService) Stat(ctx context.Context, req *pb.ContextStatRequest) (*pb.ContextStatResponse, error)

Stat returns file/directory attributes 

func (s *ContextService) Symlink(ctx context.Context, req *pb.ContextSymlinkRequest) (*pb.ContextSymlinkResponse, error)

Symlink creates a symbolic link

func (*ContextService) Truncate 

func (s *ContextService) Truncate(ctx context.Context, req *pb.ContextTruncateRequest) (*pb.ContextTruncateResponse, error)

Truncate changes file size

func (*ContextService) Write 

func (s *ContextService) Write(ctx context.Context, req *pb.ContextWriteRequest) (*pb.ContextWriteResponse, error)

Write writes file content with size limits

type FilesystemService 

type FilesystemService struct {
	pb.UnimplementedFilesystemServiceServer
	// contains filtered or unexported fields
}

FilesystemService provides gRPC filesystem metadata operations. This service is used by the FUSE client for caching metadata.

func NewFilesystemService 

func NewFilesystemService(store repository.FilesystemStore) *FilesystemService

NewFilesystemService creates a new FilesystemService.

func (*FilesystemService) Chmod 

func (s *FilesystemService) Chmod(ctx context.Context, req *pb.ChmodRequest) (*pb.ChmodResponse, error)

Chmod changes file permissions.

func (*FilesystemService) Create 

func (s *FilesystemService) Create(ctx context.Context, req *pb.CreateRequest) (*pb.CreateResponse, error)

Create creates a file.

func (*FilesystemService) Mkdir 

func (s *FilesystemService) Mkdir(ctx context.Context, req *pb.MkdirRequest) (*pb.MkdirResponse, error)

Mkdir creates a directory.

func (*FilesystemService) ReadDir 

func (s *FilesystemService) ReadDir(ctx context.Context, req *pb.ReadDirRequest) (*pb.ReadDirResponse, error)

ReadDir returns directory entries.

func (*FilesystemService) Remove 

func (s *FilesystemService) Remove(ctx context.Context, req *pb.RemoveRequest) (*pb.RemoveResponse, error)

Remove removes a file or directory.

func (*FilesystemService) Rename 

func (s *FilesystemService) Rename(ctx context.Context, req *pb.RenameRequest) (*pb.RenameResponse, error)

Rename renames a file or directory.

func (*FilesystemService) Stat 

func (s *FilesystemService) Stat(ctx context.Context, req *pb.StatRequest) (*pb.StatResponse, error)

Stat returns metadata for a path.

type GatewayService 

type GatewayService struct {
	pb.UnimplementedGatewayServiceServer
	// contains filtered or unexported fields
}

func NewGatewayService 

func NewGatewayService(backend repository.BackendRepository, s2Client *common.S2Client) *GatewayService

func (*GatewayService) AddConnection 

func (s *GatewayService) AddConnection(ctx context.Context, req *pb.AddConnectionRequest) (*pb.ConnectionResponse, error)

func (*GatewayService) AddMember 

func (s *GatewayService) AddMember(ctx context.Context, req *pb.AddMemberRequest) (*pb.MemberResponse, error)

func (*GatewayService) CreateToken 

func (s *GatewayService) CreateToken(ctx context.Context, req *pb.CreateTokenRequest) (*pb.CreateTokenResponse, error)

func (*GatewayService) CreateWorkerToken 

func (s *GatewayService) CreateWorkerToken(ctx context.Context, req *pb.CreateWorkerTokenRequest) (*pb.CreateTokenResponse, error)

func (*GatewayService) CreateWorkspace 

func (s *GatewayService) CreateWorkspace(ctx context.Context, req *pb.CreateWorkspaceRequest) (*pb.WorkspaceResponse, error)

func (*GatewayService) DeleteWorkspace 

func (s *GatewayService) DeleteWorkspace(ctx context.Context, req *pb.DeleteWorkspaceRequest) (*pb.DeleteResponse, error)

func (*GatewayService) GetTask 

func (s *GatewayService) GetTask(ctx context.Context, req *pb.GetTaskRequest) (*pb.TaskResponse, error)

func (*GatewayService) GetTaskLogs 

func (s *GatewayService) GetTaskLogs(ctx context.Context, req *pb.GetTaskLogsRequest) (*pb.GetTaskLogsResponse, error)

func (*GatewayService) GetWorkspace 

func (s *GatewayService) GetWorkspace(ctx context.Context, req *pb.GetWorkspaceRequest) (*pb.WorkspaceResponse, error)

func (*GatewayService) ListConnections 

func (s *GatewayService) ListConnections(ctx context.Context, req *pb.ListConnectionsRequest) (*pb.ListConnectionsResponse, error)

func (*GatewayService) ListMembers 

func (s *GatewayService) ListMembers(ctx context.Context, req *pb.ListMembersRequest) (*pb.ListMembersResponse, error)

func (*GatewayService) ListTasks 

func (s *GatewayService) ListTasks(ctx context.Context, req *pb.ListTasksRequest) (*pb.ListTasksResponse, error)

func (*GatewayService) ListTokens 

func (s *GatewayService) ListTokens(ctx context.Context, req *pb.ListTokensRequest) (*pb.ListTokensResponse, error)

func (*GatewayService) ListWorkerTokens 

func (s *GatewayService) ListWorkerTokens(ctx context.Context, req *pb.ListWorkerTokensRequest) (*pb.ListTokensResponse, error)

func (*GatewayService) ListWorkspaces 

func (s *GatewayService) ListWorkspaces(ctx context.Context, req *pb.ListWorkspacesRequest) (*pb.ListWorkspacesResponse, error)

func (*GatewayService) RemoveConnection 

func (s *GatewayService) RemoveConnection(ctx context.Context, req *pb.RemoveConnectionRequest) (*pb.DeleteResponse, error)

func (*GatewayService) RemoveMember 

func (s *GatewayService) RemoveMember(ctx context.Context, req *pb.RemoveMemberRequest) (*pb.DeleteResponse, error)

func (*GatewayService) RevokeToken 

func (s *GatewayService) RevokeToken(ctx context.Context, req *pb.RevokeTokenRequest) (*pb.DeleteResponse, error)

type SourceService 

type SourceService struct {
	pb.UnimplementedSourceServiceServer
	// contains filtered or unexported fields
}

SourceService implements the gRPC SourceService for integration access.

func NewSourceService 

func NewSourceService(registry *sources.Registry, backend repository.BackendRepository, fsStore repository.FilesystemStore) *SourceService

NewSourceService creates a new SourceService.

func NewSourceServiceWithOAuth 

func NewSourceServiceWithOAuth(registry *sources.Registry, backend repository.BackendRepository, fsStore repository.FilesystemStore, oauthRegistry *oauth.Registry) *SourceService

NewSourceServiceWithOAuth creates a SourceService with OAuth refresh support.

func (*SourceService) CreateSmartQuery 

func (s *SourceService) CreateSmartQuery(ctx context.Context, req *pb.CreateSmartQueryRequest) (*pb.CreateSmartQueryResponse, error)

CreateSmartQuery creates a new smart query via LLM inference

func (*SourceService) DeleteSmartQuery 

func (s *SourceService) DeleteSmartQuery(ctx context.Context, req *pb.DeleteSmartQueryRequest) (*pb.DeleteSmartQueryResponse, error)

DeleteSmartQuery removes a smart query by external_id

func (*SourceService) ExecuteSmartQuery 

func (s *SourceService) ExecuteSmartQuery(ctx context.Context, req *pb.ExecuteSmartQueryRequest) (*pb.ExecuteSmartQueryResponse, error)

ExecuteSmartQuery runs a query and returns materialized results

func (*SourceService) GetSmartQuery 

func (s *SourceService) GetSmartQuery(ctx context.Context, req *pb.GetSmartQueryRequest) (*pb.GetSmartQueryResponse, error)

GetSmartQuery retrieves a smart query by path

func (*SourceService) InvalidateQueryCache 

func (s *SourceService) InvalidateQueryCache(ctx context.Context, workspaceId uint, queryPath string) error

InvalidateQueryCache invalidates cached results for a query path. Call this before ReadDir when refresh=true to force re-execution.

func (*SourceService) ListSmartQueries 

func (s *SourceService) ListSmartQueries(ctx context.Context, req *pb.ListSmartQueriesRequest) (*pb.ListSmartQueriesResponse, error)

ListSmartQueries lists queries under a parent path

func (*SourceService) Read 

func (s *SourceService) Read(ctx context.Context, req *pb.SourceReadRequest) (*pb.SourceReadResponse, error)

Read reads file content

func (*SourceService) ReadDir 

func (s *SourceService) ReadDir(ctx context.Context, req *pb.SourceReadDirRequest) (*pb.SourceReadDirResponse, error)

ReadDir lists directory contents 

func (s *SourceService) Readlink(ctx context.Context, req *pb.SourceReadlinkRequest) (*pb.SourceReadlinkResponse, error)

Readlink reads a symbolic link target

func (*SourceService) RefreshSmartQuery 

func (s *SourceService) RefreshSmartQuery(ctx context.Context, queryPath string) ([]repository.QueryResult, error)

RefreshSmartQuery forces re-execution of a smart query, bypassing all caches. Returns the fresh results from the provider (e.g., Gmail API).

func (*SourceService) Stat 

func (s *SourceService) Stat(ctx context.Context, req *pb.SourceStatRequest) (*pb.SourceStatResponse, error)

Stat returns file/directory attributes for a source path

func (*SourceService) UpdateSmartQuery 

func (s *SourceService) UpdateSmartQuery(ctx context.Context, req *pb.UpdateSmartQueryRequest) (*pb.UpdateSmartQueryResponse, error)

UpdateSmartQuery updates an existing query's name and/or guidance

type StorageService 

type StorageService struct {
	pb.UnimplementedContextServiceServer
	// contains filtered or unexported fields
}

StorageService provides S3-backed file storage with per-workspace buckets

func NewStorageService 

func NewStorageService(client *clients.StorageClient, eventBus *common.EventBus) (*StorageService, error)

func (*StorageService) Create 

func (s *StorageService) Create(ctx context.Context, req *pb.ContextCreateRequest) (*pb.ContextCreateResponse, error)

Create creates an empty file

func (*StorageService) Delete 

func (s *StorageService) Delete(ctx context.Context, req *pb.ContextDeleteRequest) (*pb.ContextDeleteResponse, error)

Delete removes a file or directory

func (*StorageService) GetDownloadURL 

func (s *StorageService) GetDownloadURL(ctx context.Context, path string) (string, error)

GetDownloadURL generates a presigned GET URL for downloading a file

func (*StorageService) GetUploadURL 

func (s *StorageService) GetUploadURL(ctx context.Context, path, contentType string) (string, string, error)

GetUploadURL generates a presigned PUT URL for uploading a file

func (*StorageService) InvalidateCache added in v0.1.14 

func (s *StorageService) InvalidateCache(ctx context.Context, path string)

InvalidateCache clears the cache for a path (used when client requests fresh data)

func (*StorageService) ListTree 

func (s *StorageService) ListTree(ctx context.Context, req *pb.ListTreeRequest) (*pb.ListTreeResponse, error)

ListTree returns flat listing of subtree for prefetching

func (*StorageService) Mkdir 

func (s *StorageService) Mkdir(ctx context.Context, req *pb.ContextMkdirRequest) (*pb.ContextMkdirResponse, error)

Mkdir creates a directory

func (*StorageService) NotifyUploadComplete 

func (s *StorageService) NotifyUploadComplete(ctx context.Context, path string) error

NotifyUploadComplete invalidates caches after a file upload

func (*StorageService) Read 

func (s *StorageService) Read(ctx context.Context, req *pb.ContextReadRequest) (*pb.ContextReadResponse, error)

Read reads file content

func (*StorageService) ReadDir 

func (s *StorageService) ReadDir(ctx context.Context, req *pb.ContextReadDirRequest) (*pb.ContextReadDirResponse, error)

ReadDir lists directory contents 

func (s *StorageService) Readlink(ctx context.Context, req *pb.ContextReadlinkRequest) (*pb.ContextReadlinkResponse, error)

Readlink reads symbolic link target

func (*StorageService) Rename 

func (s *StorageService) Rename(ctx context.Context, req *pb.ContextRenameRequest) (*pb.ContextRenameResponse, error)

Rename moves/renames a file or directory

func (*StorageService) Stat 

func (s *StorageService) Stat(ctx context.Context, req *pb.ContextStatRequest) (*pb.ContextStatResponse, error)

Stat returns file/directory attributes 

func (s *StorageService) Symlink(ctx context.Context, req *pb.ContextSymlinkRequest) (*pb.ContextSymlinkResponse, error)

Symlink creates a symbolic link

func (*StorageService) Truncate 

func (s *StorageService) Truncate(ctx context.Context, req *pb.ContextTruncateRequest) (*pb.ContextTruncateResponse, error)

Truncate changes file size

func (*StorageService) Write 

func (s *StorageService) Write(ctx context.Context, req *pb.ContextWriteRequest) (*pb.ContextWriteResponse, error)

Write writes file content

type ToolService 

type ToolService struct {
	pb.UnimplementedToolServiceServer
	// contains filtered or unexported fields
}

func NewToolService 

func NewToolService(registry *tools.Registry) *ToolService

func NewToolServiceWithBackend 

func NewToolServiceWithBackend(registry *tools.Registry, backend repository.BackendRepository) *ToolService

func NewToolServiceWithOAuth 

func NewToolServiceWithOAuth(registry *tools.Registry, backend repository.BackendRepository, oauthRegistry *oauth.Registry) *ToolService

func (*ToolService) ExecuteTool 

func (s *ToolService) ExecuteTool(req *pb.ExecuteToolRequest, stream pb.ToolService_ExecuteToolServer) error

func (*ToolService) GetToolHelp 

func (s *ToolService) GetToolHelp(ctx context.Context, req *pb.GetToolHelpRequest) (*pb.GetToolHelpResponse, error)

func (*ToolService) ListTools 

func (s *ToolService) ListTools(ctx context.Context, req *pb.ListToolsRequest) (*pb.ListToolsResponse, error)

func (*ToolService) Resolver 

func (s *ToolService) Resolver() *tools.WorkspaceToolResolver

Resolver returns the workspace tool resolver for use by other components

type WorkerService 

type WorkerService struct {
	pb.UnimplementedWorkerServiceServer
	// contains filtered or unexported fields
}

func NewWorkerService 

func NewWorkerService(sched *scheduler.Scheduler, backend *repository.PostgresBackend) *WorkerService

func (*WorkerService) Deregister 

func (s *WorkerService) Deregister(ctx context.Context, req *pb.DeregisterRequest) (*pb.DeregisterResponse, error)

func (*WorkerService) GetWorker 

func (s *WorkerService) GetWorker(ctx context.Context, req *pb.GetWorkerRequest) (*pb.GetWorkerResponse, error)

func (*WorkerService) Heartbeat 

func (s *WorkerService) Heartbeat(ctx context.Context, req *pb.HeartbeatRequest) (*pb.HeartbeatResponse, error)

func (*WorkerService) RegisterWorker 

func (s *WorkerService) RegisterWorker(ctx context.Context, req *pb.RegisterWorkerRequest) (*pb.RegisterWorkerResponse, error)

func (*WorkerService) SetTaskResult 

func (s *WorkerService) SetTaskResult(ctx context.Context, req *pb.SetTaskResultRequest) (*pb.SetTaskResultResponse, error)

func (*WorkerService) UpdateStatus 

func (s *WorkerService) UpdateStatus(ctx context.Context, req *pb.UpdateStatusRequest) (*pb.UpdateStatusResponse, error)

Source Files

View all Source files

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.