services

package
v0.1.49 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ParseSourceURI added in v0.1.47 

func ParseSourceURI(uri string) (integration, resultID string, err error)

ParseSourceURI splits "integration://resultID" into its parts.

Types

type AccessService added in v0.1.47 

type AccessService struct {
	pb.UnimplementedAccessLogServiceServer
	// contains filtered or unexported fields
}

AccessService ingests batched logical-read events emitted by mounts. Events are normalized with auth-derived workspace/session fields and persisted via the shared recorder.

func NewAccessService added in v0.1.47 

func NewAccessService(recorder instrumentation.AccessRecorder, rdb *common.RedisClient) *AccessService

func (*AccessService) IngestAccessEvents added in v0.1.47 

func (s *AccessService) IngestAccessEvents(ctx context.Context, req *pb.IngestAccessEventsRequest) (*pb.IngestAccessEventsResponse, error)

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

func NewSourceServiceWithOAuth 

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

func (*SourceService) CreateSmartQuery 

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

func (*SourceService) DeleteSmartQuery 

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

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)

func (*SourceService) InvalidateConnectionCache added in v0.1.34 

func (s *SourceService) InvalidateConnectionCache(workspaceId uint)

func (*SourceService) InvalidateQueryCache 

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

InvalidateQueryCache invalidates cached results for a query path.

func (*SourceService) ListSmartQueries 

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

func (*SourceService) Read 

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

func (*SourceService) ReadBySourceURI added in v0.1.47 

func (s *SourceService) ReadBySourceURI(ctx context.Context, workspaceId uint, memberId uint, sourceURI string) ([]byte, error)

ReadBySourceURI fetches content directly from a provider using a source URI of the form "integration://resultID". This bypasses the smart-folder layer entirely, so it works even if the query results have changed since the original read was recorded.

func (*SourceService) ReadDir 

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

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 for new results. Called ONLY by the source poller — never by user browsing or task reads. This prevents a feedback loop where hook-triggered tasks re-fire hooks.

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.

func (*SourceService) Stat 

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

func (*SourceService) UpdateSmartQuery 

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

type SourceServiceOption added in v0.1.28 

type SourceServiceOption func(*SourceService)

func WithCompressionMiddleware added in v0.1.43 

func WithCompressionMiddleware(
	compressor compression.ContextCompressor,
	store *compression.CompressedStore,
	cfg compression.Config,
) SourceServiceOption

func WithHookStream added in v0.1.28 

func WithHookStream(emitter common.EventEmitter) SourceServiceOption

func WithRecorder added in v0.1.47 

func WithRecorder(recorder instrumentation.AccessRecorder) SourceServiceOption

func WithSeenTracker added in v0.1.28 

func WithSeenTracker(tracker *hooks.SeenTracker) SourceServiceOption

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.