services

package
v0.1.38 Latest Latest
Warning

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

 Go to latest Published: Feb 11, 2026 License: AGPL-3.0, AGPL-3.0-or-later Imports: 33 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. Uses pipelined Redis lookup (single round-trip for dir + file + symlink).

type GatewayService 

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

func NewGatewayService 

func NewGatewayService(backend repository.BackendRepository, s2Client *common.S2Client, fsStore repository.FilesystemStore, eventBus *common.EventBus, sourceRegistry *sources.Registry) *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) CreateHook added in v0.1.28 

func (s *GatewayService) CreateHook(ctx context.Context, req *pb.CreateHookRequest) (*pb.HookResponse, error)

func (*GatewayService) CreateTask added in v0.1.31 

func (s *GatewayService) CreateTask(ctx context.Context, req *pb.CreateTaskRequest) (*pb.TaskResponse, 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) DeleteHook added in v0.1.28 

func (s *GatewayService) DeleteHook(ctx context.Context, req *pb.DeleteHookRequest) (*pb.DeleteResponse, error)

func (*GatewayService) DeleteTask added in v0.1.31 

func (s *GatewayService) DeleteTask(ctx context.Context, req *pb.DeleteTaskRequest) (*pb.DeleteResponse, error)

func (*GatewayService) DeleteWorkspace 

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

func (*GatewayService) GetHook added in v0.1.28 

func (s *GatewayService) GetHook(ctx context.Context, req *pb.GetHookRequest) (*pb.HookResponse, 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) ListHookRuns added in v0.1.28 

func (s *GatewayService) ListHookRuns(ctx context.Context, req *pb.ListHookRunsRequest) (*pb.ListHookRunsResponse, error)

func (*GatewayService) ListHooks added in v0.1.28 

func (s *GatewayService) ListHooks(ctx context.Context, req *pb.ListHooksRequest) (*pb.ListHooksResponse, 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)

func (*GatewayService) SetSourceService added in v0.1.34 

func (s *GatewayService) SetSourceService(svc *SourceService)

SetSourceService injects the SourceService so that connection mutations (add/remove) can invalidate the connected-integrations cache immediately.

func (*GatewayService) SetTaskQueue added in v0.1.31 

func (s *GatewayService) SetTaskQueue(queue repository.TaskQueue, defaultImage string)

SetTaskQueue wires the task queue and default image for CreateTask. Called after the queue is initialized during gateway startup.

func (*GatewayService) UpdateHook added in v0.1.28 

func (s *GatewayService) UpdateHook(ctx context.Context, req *pb.UpdateHookRequest) (*pb.HookResponse, 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, opts ...SourceServiceOption) *SourceService

NewSourceService creates a new SourceService.

func NewSourceServiceWithOAuth 

func NewSourceServiceWithOAuth(registry *sources.Registry, backend repository.BackendRepository, fsStore repository.FilesystemStore, oauthRegistry *oauth.Registry, opts ...SourceServiceOption) *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) InvalidateConnectionCache added in v0.1.34 

func (s *SourceService) InvalidateConnectionCache(workspaceId uint)

InvalidateConnectionCache evicts the cached connected-integrations set for a workspace. Call this when connections are added or removed so that subsequent ReadDir/Stat/Read calls reflect the change immediately.

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) RefreshQuery added in v0.1.28 

func (s *SourceService) RefreshQuery(ctx context.Context, query *types.FilesystemQuery) error

RefreshQuery re-executes a query and emits hook events if new results are found. ONLY called by the source poller — never by user browsing or task filesystem reads. This prevents a feedback loop where hook-triggered tasks re-trigger hooks. Satisfies hooks.QueryRefresher.

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 SourceServiceOption added in v0.1.28 

type SourceServiceOption func(*SourceService)

SourceServiceOption configures optional dependencies on SourceService.

func WithHookStream added in v0.1.28 

func WithHookStream(emitter common.EventEmitter) SourceServiceOption

WithHookStream sets the event emitter for hook event emission.

func WithSeenTracker added in v0.1.28 

func WithSeenTracker(tracker *hooks.SeenTracker) SourceServiceOption

WithSeenTracker sets the seen tracker for change detection.

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) SetHookStream added in v0.1.28 

func (s *StorageService) SetHookStream(emitter common.EventEmitter)

SetHookStream sets the event emitter for hook event emission.

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, workerRepo repository.WorkerRepository) *WorkerService

func (*WorkerService) AllocateIP added in v0.1.23 

func (s *WorkerService) AllocateIP(ctx context.Context, req *pb.AllocateIPRequest) (*pb.AllocateIPResponse, error)

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) ListWorkers added in v0.1.23 

func (s *WorkerService) ListWorkers(ctx context.Context, req *pb.ListWorkersRequest) (*pb.ListWorkersResponse, error)

func (*WorkerService) RegisterWorker 

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

func (*WorkerService) ReleaseIP added in v0.1.23 

func (s *WorkerService) ReleaseIP(ctx context.Context, req *pb.ReleaseIPRequest) (*pb.ReleaseIPResponse, error)

func (*WorkerService) SetTaskResult 

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

func (*WorkerService) SetTaskStarted added in v0.1.28 

func (s *WorkerService) SetTaskStarted(ctx context.Context, req *pb.SetTaskStartedRequest) (*pb.SetTaskStartedResponse, 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.