services

package
v0.1.129 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewSourceContextEnricher added in v0.1.125 

func NewSourceContextEnricher(
	registry *sources.Registry,
	fsStore repository.FilesystemStore,
	viewStore *views.ViewStore,
	backend repository.BackendRepository,
) hooks.ContextEnricher

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 AgentService added in v0.1.60 

type AgentService struct {
	pb.UnimplementedAgentServiceServer
	// contains filtered or unexported fields
}

func NewAgentService added in v0.1.60 

func NewAgentService(
	backend repository.BackendRepository,
	api *orchestration.AgentAPI,
	s2Client *common.S2Client,
) *AgentService

func (*AgentService) CancelAgentRun added in v0.1.60 

func (s *AgentService) CancelAgentRun(ctx context.Context, req *pb.CancelAgentRunRequest) (*pb.CancelAgentRunResponse, error)

func (*AgentService) CreateAgentProfile added in v0.1.60 

func (s *AgentService) CreateAgentProfile(ctx context.Context, req *pb.CreateAgentProfileRequest) (*pb.AgentProfileResponse, error)

func (*AgentService) CreateTask added in v0.1.60 

func (s *AgentService) CreateTask(ctx context.Context, req *pb.CreateTaskRequest) (*pb.AgentTaskAcceptedResponse, error)

func (*AgentService) DeleteTask added in v0.1.60 

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

func (*AgentService) EnqueueRunInput added in v0.1.60 

func (s *AgentService) EnqueueRunInput(ctx context.Context, req *pb.EnqueueRunInputRequest) (*pb.AgentTaskAcceptedResponse, error)

func (*AgentService) GetAgentProfile added in v0.1.60 

func (s *AgentService) GetAgentProfile(ctx context.Context, req *pb.GetAgentProfileRequest) (*pb.AgentProfileResponse, error)

func (*AgentService) GetAgentRun added in v0.1.60 

func (s *AgentService) GetAgentRun(ctx context.Context, req *pb.GetAgentRunRequest) (*pb.AgentRunResponse, error)

func (*AgentService) GetTask added in v0.1.60 

func (s *AgentService) GetTask(ctx context.Context, req *pb.GetTaskRequest) (*pb.AgentTaskResponse, error)

func (*AgentService) GetTaskLogs added in v0.1.60 

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

func (*AgentService) ListAgentProfiles added in v0.1.60 

func (s *AgentService) ListAgentProfiles(ctx context.Context, req *pb.ListAgentProfilesRequest) (*pb.ListAgentProfilesResponse, error)

func (*AgentService) ListAgentRunEvents added in v0.1.60 

func (s *AgentService) ListAgentRunEvents(ctx context.Context, req *pb.ListAgentRunEventsRequest) (*pb.ListAgentRunEventsResponse, error)

func (*AgentService) ListAgentRunSnapshots added in v0.1.60 

func (s *AgentService) ListAgentRunSnapshots(ctx context.Context, req *pb.ListAgentRunSnapshotsRequest) (*pb.ListAgentRunSnapshotsResponse, error)

func (*AgentService) ListAgentRuns added in v0.1.60 

func (s *AgentService) ListAgentRuns(ctx context.Context, req *pb.ListAgentRunsRequest) (*pb.ListAgentRunsResponse, error)

func (*AgentService) ListTasks added in v0.1.60 

func (s *AgentService) ListTasks(ctx context.Context, _ *pb.ListTasksRequest) (*pb.ListTasksResponse, error)

type ConfluenceFilter added in v0.1.95 

type ConfluenceFilter struct {
	CQL         string `json:"cql"`
	Space       string `json:"space"`
	ContentType string `json:"content_type"` // "page", "blogpost", or "all"
	Label       string `json:"label"`
}

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 GDriveFilter added in v0.1.50 

type GDriveFilter struct {
	NameContains   string `json:"name_contains"`
	MimeType       string `json:"mime_type"`
	SharedWithMe   *bool  `json:"shared_with_me"`
	Starred        *bool  `json:"starred"`
	ModifiedAfter  string `json:"modified_after"`
	ModifiedBefore string `json:"modified_before"`
	FolderID       string `json:"folder_id"`
}

type GatewayService 

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

func NewGatewayService 

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

func (s *GatewayService) UpdateHook(ctx context.Context, req *pb.UpdateHookRequest) (*pb.HookResponse, error)

type GitHubFilter added in v0.1.50 

type GitHubFilter struct {
	Repo        string `json:"repo"`
	Type        string `json:"type"`
	State       string `json:"state"`
	Label       string `json:"label"`
	Author      string `json:"author"`
	ContentType string `json:"content_type"`
}

type GmailFilter added in v0.1.50 

type GmailFilter struct {
	From               string `json:"from"`
	To                 string `json:"to"`
	Subject            string `json:"subject"`
	Label              string `json:"label"`
	Filename           string `json:"filename"`
	NewerThan          string `json:"newer_than"`
	OlderThan          string `json:"older_than"`
	HasAttachment      *bool  `json:"has_attachment"`
	IsUnread           *bool  `json:"is_unread"`
	IsStarred          *bool  `json:"is_starred"`
	IncludeAttachments *bool  `json:"include_attachments"`
	IncludeInline      *bool  `json:"include_inline"`
	IncludeMessageBody *bool  `json:"include_message_body"`
}

type LinearFilter added in v0.1.50 

type LinearFilter struct {
	Type     string `json:"type"`
	Team     string `json:"team"`
	State    string `json:"state"`
	Assignee string `json:"assignee"`
	Priority string `json:"priority"`
	Label    string `json:"label"`
	Project  string `json:"project"`
}

type NotionFilter added in v0.1.50 

type NotionFilter struct {
	Search string `json:"search"`
}

type PostHogFilter added in v0.1.50 

type PostHogFilter struct {
	Type      string `json:"type"`
	Query     string `json:"query"`
	ProjectID int    `json:"project_id"`
}

type SlackFilter added in v0.1.50 

type SlackFilter struct {
	Channel     string `json:"channel"`
	From        string `json:"from"`
	After       string `json:"after"`
	Before      string `json:"before"`
	HasLink     *bool  `json:"has_link"`
	HasReaction *bool  `json:"has_reaction"`
}

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) CleanupTaskSourceWatches added in v0.1.110 

func (s *SourceService) CleanupTaskSourceWatches(ctx context.Context, task *types.AgentTask) error

func (*SourceService) CreateView added in v0.1.50 

func (s *SourceService) CreateView(ctx context.Context, req *pb.CreateViewRequest) (*pb.CreateViewResponse, error)

func (*SourceService) DeleteView added in v0.1.50 

func (s *SourceService) DeleteView(ctx context.Context, req *pb.DeleteViewRequest) (*pb.DeleteViewResponse, error)

func (*SourceService) ExecuteView added in v0.1.50 

func (s *SourceService) ExecuteView(ctx context.Context, req *pb.ExecuteViewRequest) (*pb.ExecuteViewResponse, error)

ExecuteView runs a view's query and returns materialized results.

func (*SourceService) GetView added in v0.1.50 

func (s *SourceService) GetView(ctx context.Context, req *pb.GetViewRequest) (*pb.GetViewResponse, 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) ListResources added in v0.1.50 

func (s *SourceService) ListResources(ctx context.Context, req *pb.ListResourcesRequest) (*pb.ListResourcesResponse, error)

func (*SourceService) ListViews added in v0.1.50 

func (s *SourceService) ListViews(ctx context.Context, req *pb.ListViewsRequest) (*pb.ListViewsResponse, 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 source-view 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 processes new results. Called by the source poller.

For task_followup queries with a TaskWaker configured, this bypasses the Redis SeenTracker + stream pipeline entirely: it compares results against a durable Postgres baseline and delivers input directly to the sleeping task. This is atomic, retry-safe, and works across replicas.

For all other queries, the existing SeenTracker + hook stream path is used.

func (*SourceService) RegisterTaskSourceWatches added in v0.1.110 

func (s *SourceService) RegisterTaskSourceWatches(
	ctx context.Context,
	task *types.AgentTask,
	wakeSignal *types.RunExecutionWakeSignal,
	requests []*types.SourceWatchRequest,
) (*types.TaskBlockerSpec, error)

func (*SourceService) SeedSeenBaseline added in v0.1.119 

func (s *SourceService) SeedSeenBaseline(ctx context.Context, workspaceID uint, query *types.FilesystemQuery)

SeedSeenBaseline marks a query path as "initialized" in the SeenTracker with the cached results the agent last saw, so the first poller run diffs properly against the agent's perspective instead of a fresh query.

Using cached results (not a fresh query) is critical: a fresh query could include items that arrived after the agent's last read but before watch registration, permanently baking them into the baseline so they never trigger a wake.

func (*SourceService) SetContextEnricher added in v0.1.125 

func (s *SourceService) SetContextEnricher(enricher hooks.ContextEnricher)

func (*SourceService) SetTaskWaker added in v0.1.122 

func (s *SourceService) SetTaskWaker(waker TaskWaker)

func (*SourceService) Stat 

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

func (*SourceService) SyncView added in v0.1.50 

func (s *SourceService) SyncView(ctx context.Context, req *pb.SyncViewRequest) (*pb.SyncViewResponse, error)

SyncView handles the gRPC SyncView RPC.

func (*SourceService) SyncViewByExternalId added in v0.1.50 

func (s *SourceService) SyncViewByExternalId(ctx context.Context, externalId string) (*SyncResult, error)

SyncViewByExternalId syncs a view by its external ID.

func (*SourceService) SyncViewByPath added in v0.1.50 

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

SyncViewByPath forces re-execution of a source view by path, bypassing all caches. Returns the results and emits hook events for newly seen items.

func (*SourceService) UpdateView added in v0.1.50 

func (s *SourceService) UpdateView(ctx context.Context, req *pb.UpdateViewRequest) (*pb.UpdateViewResponse, 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 WithEventBus added in v0.1.119 

func WithEventBus(bus *common.EventBus) 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

func WithTaskWaker added in v0.1.122 

func WithTaskWaker(waker TaskWaker) 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) SetEventRecorder added in v0.1.95 

func (s *StorageService) SetEventRecorder(r instrumentation.EventRecorder)

SetEventRecorder sets the product analytics event recorder.

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 SyncResult added in v0.1.50 

type SyncResult struct {
	Query        *types.FilesystemQuery
	ResultsCount int
	NewResults   int
}

SyncResult is the outcome of a view sync operation.

type TaskWaker added in v0.1.122 

type TaskWaker interface {
	WakeTask(ctx context.Context, workspaceID uint, taskID string, message string) error
}

TaskWaker delivers a wake message to a sleeping task. The implementation wraps AgentAPI.SubmitTaskInput with InputKindFreeText.

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

func (*ToolService) SetEventRecorder added in v0.1.95 

func (s *ToolService) SetEventRecorder(r instrumentation.EventRecorder)

SetEventRecorder sets the product analytics event recorder.

type WebFilter added in v0.1.50 

type WebFilter struct {
	Mode         string   `json:"mode"` // "map" or "search"
	URL          string   `json:"url"`
	Query        string   `json:"query"`
	IncludePaths []string `json:"include_paths"`
}

type WorkerService 

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

func NewWorkerService 

func NewWorkerService(
	sched *scheduler.Scheduler,
	backend repository.BackendRepository,
	workerRepo repository.WorkerRepository,
	taskQueue repository.TaskQueue,
	redisClient *common.RedisClient,
	schedulerConfig types.SchedulerConfig,
	viewStore *views.ViewStore,
	viewSync *views.ViewSync,
) *WorkerService

func (*WorkerService) AckTaskInput added in v0.1.98 

func (s *WorkerService) AckTaskInput(ctx context.Context, req *pb.AckTaskInputRequest) (*pb.AckTaskInputResponse, error)

func (*WorkerService) AllocateIP added in v0.1.23 

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

func (*WorkerService) AppendTaskOutputRows added in v0.1.96 

func (s *WorkerService) AppendTaskOutputRows(ctx context.Context, req *pb.AppendTaskOutputRowsRequest) (*pb.AppendTaskOutputRowsResponse, error)

func (*WorkerService) ClaimTaskInput added in v0.1.98 

func (s *WorkerService) ClaimTaskInput(ctx context.Context, req *pb.ClaimTaskInputRequest) (*pb.ClaimTaskInputResponse, error)

func (*WorkerService) CreateTaskOutput added in v0.1.96 

func (s *WorkerService) CreateTaskOutput(ctx context.Context, req *pb.CreateTaskOutputRequest) (*pb.CreateTaskOutputResponse, error)

func (*WorkerService) Deregister 

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

func (*WorkerService) FinalizeTaskOutput added in v0.1.96 

func (s *WorkerService) FinalizeTaskOutput(ctx context.Context, req *pb.FinalizeTaskOutputRequest) (*pb.FinalizeTaskOutputResponse, 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) StartRecoveryLoop added in v0.1.66 

func (s *WorkerService) StartRecoveryLoop(ctx context.Context)

func (*WorkerService) UpdateStatus 

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

func (*WorkerService) UpdateTaskOutputStatus added in v0.1.106 

func (s *WorkerService) UpdateTaskOutputStatus(ctx context.Context, req *pb.UpdateTaskOutputStatusRequest) (*pb.UpdateTaskOutputStatusResponse, error)

func (*WorkerService) UpdateTaskState added in v0.1.96 

func (s *WorkerService) UpdateTaskState(ctx context.Context, req *pb.UpdateTaskStateRequest) (*pb.UpdateTaskStateResponse, 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.