apiv1

package
v0.59.0 Latest Latest
Warning

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

 Go to latest Published: Sep 17, 2026 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// DefaultStreamCycleDuration is the default duration before a watch stream closes and prompts the client to reconnect.
	DefaultStreamCycleDuration = 30 * time.Second
	// DefaultUpdateInterval is the default interval between task graph snapshot emissions.
	DefaultUpdateInterval = 1 * time.Second
)

Variables

This section is empty.

Functions

This section is empty.

Types

type CELValidationServer 

type CELValidationServer struct{}

CELValidationServer implements the CELValidationServiceHandler interface.

func NewCELValidationServer 

func NewCELValidationServer() *CELValidationServer

NewCELValidationServer creates a new instance of CELValidationServer.

func (*CELValidationServer) ValidateLogQuery 

func (s *CELValidationServer) ValidateLogQuery(
	ctx context.Context,
	req *connect.Request[v1.ValidateLogQueryRequest],
) (*connect.Response[v1.ValidateLogQueryResponse], error)

ValidateLogQuery validates a CEL log expression syntax and schema types.

func (*CELValidationServer) ValidateTimelineQuery 

func (s *CELValidationServer) ValidateTimelineQuery(
	ctx context.Context,
	req *connect.Request[v1.ValidateTimelineQueryRequest],
) (*connect.Response[v1.ValidateTimelineQueryResponse], error)

ValidateTimelineQuery validates a CEL timeline expression syntax and schema types.

type FileParameterUploadServiceServer 

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

FileParameterUploadServiceServer implements the apiv1connect.FileParameterUploadServiceHandler interface.

func NewFileParameterUploadServiceServer 

func NewFileParameterUploadServiceServer(manager *upload.FileParameterUploadManager) *FileParameterUploadServiceServer

NewFileParameterUploadServiceServer creates a new FileParameterUploadServiceServer backed by the given manager.

func (*FileParameterUploadServiceServer) AbortFileUpload 

func (s *FileParameterUploadServiceServer) AbortFileUpload(
	ctx context.Context,
	req *connect.Request[apiv1.AbortFileUploadRequest],
) (*connect.Response[apiv1.AbortFileUploadResponse], error)

AbortFileUpload cancels the upload session and deletes temporary chunks.

func (*FileParameterUploadServiceServer) CompleteFileUpload 

func (s *FileParameterUploadServiceServer) CompleteFileUpload(
	ctx context.Context,
	req *connect.Request[apiv1.CompleteFileUploadRequest],
) (*connect.Response[apiv1.CompleteFileUploadResponse], error)

CompleteFileUpload finalizes the upload session and prepares the uploaded file for task execution.

func (*FileParameterUploadServiceServer) StartFileUpload 

func (s *FileParameterUploadServiceServer) StartFileUpload(
	ctx context.Context,
	req *connect.Request[apiv1.StartFileUploadRequest],
) (*connect.Response[apiv1.StartFileUploadResponse], error)

StartFileUpload initializes a chunked file parameter upload session.

func (*FileParameterUploadServiceServer) UploadFileChunk 

func (s *FileParameterUploadServiceServer) UploadFileChunk(
	ctx context.Context,
	req *connect.Request[apiv1.UploadFileChunkRequest],
) (*connect.Response[apiv1.UploadFileChunkResponse], error)

UploadFileChunk receives and appends a single chunk of data for the active upload session.

type ImportInspectionServiceServer 

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

ImportInspectionServiceServer implements the apiv1connect.ImportInspectionServiceHandler interface.

func NewImportInspectionServiceServer 

func NewImportInspectionServiceServer(manager *importinspection.ImportSessionManager, indexManager *workbench.InspectionIndexManager) *ImportInspectionServiceServer

NewImportInspectionServiceServer creates a new ImportInspectionServiceServer backed by the given manager.

func (*ImportInspectionServiceServer) AbortImportInspection 

func (s *ImportInspectionServiceServer) AbortImportInspection(
	ctx context.Context,
	req *connect.Request[apiv1.AbortImportInspectionRequest],
) (*connect.Response[apiv1.AbortImportInspectionResponse], error)

AbortImportInspection aborts an in-progress import session and cleans up temporary resources.

func (*ImportInspectionServiceServer) CompleteImportInspection 

func (s *ImportInspectionServiceServer) CompleteImportInspection(
	ctx context.Context,
	req *connect.Request[apiv1.CompleteImportInspectionRequest],
) (*connect.Response[apiv1.CompleteImportInspectionResponse], error)

CompleteImportInspection finalizes the upload, validates the KHI file, and registers the inspection.

func (*ImportInspectionServiceServer) StartImportInspection 

func (s *ImportInspectionServiceServer) StartImportInspection(
	ctx context.Context,
	req *connect.Request[apiv1.StartImportInspectionRequest],
) (*connect.Response[apiv1.StartImportInspectionResponse], error)

StartImportInspection initializes an import session and returns an upload token and suggested chunk size.

func (*ImportInspectionServiceServer) UploadInspectionChunk 

func (s *ImportInspectionServiceServer) UploadInspectionChunk(
	ctx context.Context,
	req *connect.Request[apiv1.UploadInspectionChunkRequest],
) (*connect.Response[apiv1.UploadInspectionChunkResponse], error)

UploadInspectionChunk receives and appends a single chunk of data to the session's temporary file.

type InspectionServiceServer 

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

InspectionServiceServer implements the apiv1connect.InspectionServiceHandler interface.

func NewInspectionServiceServer 

func NewInspectionServiceServer(inspectionServer *coreinspection.InspectionTaskServer) *InspectionServiceServer

NewInspectionServiceServer creates a new InspectionServiceServer with default 30s stream cycle and 1s interval.

func NewInspectionServiceServerWithIntervals 

func NewInspectionServiceServerWithIntervals(
	inspectionServer *coreinspection.InspectionTaskServer,
	streamCycleDuration time.Duration,
	updateInterval time.Duration,
) *InspectionServiceServer

NewInspectionServiceServerWithIntervals creates a new InspectionServiceServer with configurable stream intervals.

func (*InspectionServiceServer) CancelInspection 

func (s *InspectionServiceServer) CancelInspection(
	ctx context.Context,
	req *connect.Request[apiv1.CancelInspectionRequest],
) (*connect.Response[apiv1.CancelInspectionResponse], error)

CancelInspection aborts an in-progress inspection run.

func (*InspectionServiceServer) CreateInspection 

func (s *InspectionServiceServer) CreateInspection(
	ctx context.Context,
	req *connect.Request[apiv1.CreateInspectionRequest],
) (*connect.Response[apiv1.CreateInspectionResponse], error)

CreateInspection instantiates a new inspection runner session for a given inspection type.

func (*InspectionServiceServer) DryRunInspection 

func (s *InspectionServiceServer) DryRunInspection(
	ctx context.Context,
	req *connect.Request[apiv1.DryRunInspectionRequest],
) (*connect.Response[apiv1.DryRunInspectionResponse], error)

DryRunInspection dry-runs an inspection task graph and evaluates form fields with the given parameters.

func (*InspectionServiceServer) GetInspectionDataChunk 

func (s *InspectionServiceServer) GetInspectionDataChunk(
	ctx context.Context,
	req *connect.Request[apiv1.GetInspectionDataChunkRequest],
) (*connect.Response[apiv1.GetInspectionDataChunkResponse], error)

GetInspectionDataChunk downloads a slice of binary data from the generated .khi archive.

func (*InspectionServiceServer) GetInspectionFeatures 

func (s *InspectionServiceServer) GetInspectionFeatures(
	ctx context.Context,
	req *connect.Request[apiv1.GetInspectionFeaturesRequest],
) (*connect.Response[apiv1.GetInspectionFeaturesResponse], error)

GetInspectionFeatures retrieves the list of toggleable features for an inspection runner.

func (*InspectionServiceServer) GetInspectionMetadata 

func (s *InspectionServiceServer) GetInspectionMetadata(
	ctx context.Context,
	req *connect.Request[apiv1.GetInspectionMetadataRequest],
) (*connect.Response[apiv1.GetInspectionMetadataResponse], error)

GetInspectionMetadata returns serializable metadata for a completed inspection run.

func (*InspectionServiceServer) GetInspectionTypes 

func (s *InspectionServiceServer) GetInspectionTypes(
	ctx context.Context,
	req *connect.Request[apiv1.GetInspectionTypesRequest],
) (*connect.Response[apiv1.GetInspectionTypesResponse], error)

GetInspectionTypes returns all supported inspection types registered on the server.

func (*InspectionServiceServer) GetInspections 

func (s *InspectionServiceServer) GetInspections(
	ctx context.Context,
	req *connect.Request[apiv1.GetInspectionsRequest],
) (*connect.Response[apiv1.GetInspectionsResponse], error)

GetInspections returns the current snapshot of active inspection runner sessions.

func (*InspectionServiceServer) PullInspections 

func (s *InspectionServiceServer) PullInspections(
	ctx context.Context,
	req *connect.Request[apiv1.PullInspectionsRequest],
) (*connect.Response[apiv1.PullInspectionsResponse], error)

PullInspections pulls active inspection runner sessions snapshot without opening a persistent stream.

func (*InspectionServiceServer) RunInspection 

func (s *InspectionServiceServer) RunInspection(
	ctx context.Context,
	req *connect.Request[apiv1.RunInspectionRequest],
) (*connect.Response[apiv1.RunInspectionResponse], error)

RunInspection kicks off asynchronous execution of an inspection task graph with the given parameters.

func (*InspectionServiceServer) UpdateInspection 

func (s *InspectionServiceServer) UpdateInspection(
	ctx context.Context,
	req *connect.Request[apiv1.UpdateInspectionRequest],
) (*connect.Response[apiv1.UpdateInspectionResponse], error)

UpdateInspection updates metadata of an inspection runner session.

func (*InspectionServiceServer) UpdateInspectionFeatures 

func (s *InspectionServiceServer) UpdateInspectionFeatures(
	ctx context.Context,
	req *connect.Request[apiv1.UpdateInspectionFeaturesRequest],
) (*connect.Response[apiv1.UpdateInspectionFeaturesResponse], error)

UpdateInspectionFeatures updates the enabled states of features for an inspection runner.

func (*InspectionServiceServer) WatchInspections 

func (s *InspectionServiceServer) WatchInspections(
	ctx context.Context,
	req *connect.Request[apiv1.WatchInspectionsRequest],
	stream *connect.ServerStream[apiv1.WatchInspectionsResponse],
) error

WatchInspections streams active inspection runner session updates and closes after streamCycleDuration.

type InspectionTaskGraphServer added in v0.59.0 

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

InspectionTaskGraphServer implements the apiv1connect.InspectionTaskGraphServiceHandler interface.

func NewInspectionTaskGraphServer added in v0.59.0 

func NewInspectionTaskGraphServer(
	inspectionServer *coreinspection.InspectionTaskServer,
	streamCycleDuration time.Duration,
	updateInterval time.Duration,
) *InspectionTaskGraphServer

NewInspectionTaskGraphServer creates a new InspectionTaskGraphServer with the given stream intervals.

func (*InspectionTaskGraphServer) GetInspectionTaskRegistry added in v0.59.0 

func (s *InspectionTaskGraphServer) GetInspectionTaskRegistry(
	ctx context.Context,
	req *connect.Request[apiv1.GetInspectionTaskRegistryRequest],
) (*connect.Response[apiv1.GetInspectionTaskRegistryResponse], error)

GetInspectionTaskRegistry returns all registered tasks grouped by reference identifier and all inspection types.

func (*InspectionTaskGraphServer) PullInspectionRunTaskGraph added in v0.59.0 

func (s *InspectionTaskGraphServer) PullInspectionRunTaskGraph(
	ctx context.Context,
	req *connect.Request[apiv1.PullInspectionRunTaskGraphRequest],
) (*connect.Response[apiv1.PullInspectionRunTaskGraphResponse], error)

PullInspectionRunTaskGraph returns a single progress snapshot of an inspection run without opening a stream.

func (*InspectionTaskGraphServer) ResolveInspectionTaskGraph added in v0.59.0 

func (s *InspectionTaskGraphServer) ResolveInspectionTaskGraph(
	ctx context.Context,
	req *connect.Request[apiv1.ResolveInspectionTaskGraphRequest],
) (*connect.Response[apiv1.ResolveInspectionTaskGraphResponse], error)

ResolveInspectionTaskGraph resolves task filtering against an inspection type and feature configuration, and returns step-by-step filtering results alongside the resolved execution DAG.

func (*InspectionTaskGraphServer) WatchInspectionRunTaskGraph added in v0.59.0 

func (s *InspectionTaskGraphServer) WatchInspectionRunTaskGraph(
	ctx context.Context,
	req *connect.Request[apiv1.WatchInspectionRunTaskGraphRequest],
	stream *connect.ServerStream[apiv1.WatchInspectionRunTaskGraphResponse],
) error

WatchInspectionRunTaskGraph streams progress snapshots of an inspection run. The stream closes when the run reaches its terminal state, or after streamCycleDuration to prompt the client to reconnect.

type PopupServer 

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

PopupServer implements the PopupService Connect-RPC handler.

func NewPopupServer 

func NewPopupServer(manager *popup.PopupManager) *PopupServer

NewPopupServer creates a new instance of PopupServer.

func (*PopupServer) PullPopup 

func (s *PopupServer) PullPopup(
	ctx context.Context,
	req *connect.Request[v1.PullPopupRequest],
) (*connect.Response[v1.PullPopupResponse], error)

PullPopup returns the currently active popup form snapshot.

func (*PopupServer) SubmitPopupAnswer 

func (s *PopupServer) SubmitPopupAnswer(
	ctx context.Context,
	req *connect.Request[v1.SubmitPopupAnswerRequest],
) (*connect.Response[v1.SubmitPopupAnswerResponse], error)

SubmitPopupAnswer submits the finalized answer for the active popup.

func (*PopupServer) ValidatePopupAnswer 

func (s *PopupServer) ValidatePopupAnswer(
	ctx context.Context,
	req *connect.Request[v1.ValidatePopupAnswerRequest],
) (*connect.Response[v1.ValidatePopupAnswerResponse], error)

ValidatePopupAnswer validates in-progress input against the active popup.

func (*PopupServer) WatchPopup 

func (s *PopupServer) WatchPopup(
	ctx context.Context,
	req *connect.Request[v1.WatchPopupRequest],
	stream *connect.ServerStream[v1.WatchPopupResponse],
) error

WatchPopup streams real-time popup events and closes every 30s to prevent proxy timeouts.

type ServerStatusServiceServer 

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

ServerStatusServiceServer implements the apiv1connect.ServerStatusServiceHandler interface.

func NewServerStatusServiceServer 

func NewServerStatusServiceServer(monitor server.ResourceMonitor) *ServerStatusServiceServer

NewServerStatusServiceServer creates a new ServerStatusServiceServer with default 30s stream cycle and 1s interval.

func NewServerStatusServiceServerWithIntervals 

func NewServerStatusServiceServerWithIntervals(
	monitor server.ResourceMonitor,
	streamCycleDuration time.Duration,
	updateInterval time.Duration,
) *ServerStatusServiceServer

NewServerStatusServiceServerWithIntervals creates a new ServerStatusServiceServer with custom intervals for testing.

func (*ServerStatusServiceServer) PullServerStat 

func (s *ServerStatusServiceServer) PullServerStat(
	ctx context.Context,
	req *connect.Request[apiv1.PullServerStatRequest],
) (*connect.Response[apiv1.PullServerStatResponse], error)

PullServerStat pulls current server resource usage statistics as a one-off snapshot.

func (*ServerStatusServiceServer) WatchServerStat 

func (s *ServerStatusServiceServer) WatchServerStat(
	ctx context.Context,
	req *connect.Request[apiv1.WatchServerStatRequest],
	stream *connect.ServerStream[apiv1.WatchServerStatResponse],
) error

WatchServerStat streams real-time server resource usage statistics, terminating after streamCycleDuration.

type WorkbenchServiceServer 

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

WorkbenchServiceServer implements the apiv1connect.WorkbenchServiceHandler interface.

func NewWorkbenchServiceServer 

func NewWorkbenchServiceServer(manager *workbench.WorkbenchManager) *WorkbenchServiceServer

NewWorkbenchServiceServer creates a new WorkbenchServiceServer backed by the given manager.

func (*WorkbenchServiceServer) CancelFilterTimelineSync 

func (s *WorkbenchServiceServer) CancelFilterTimelineSync(
	ctx context.Context,
	req *connect.Request[apiv1.CancelFilterTimelineSyncRequest],
) (*connect.Response[apiv1.CancelFilterTimelineSyncResponse], error)

CancelFilterTimelineSync cancels an in-progress synchronous timeline filtering task.

func (*WorkbenchServiceServer) CancelOpenWorkbenchSync 

func (s *WorkbenchServiceServer) CancelOpenWorkbenchSync(
	ctx context.Context,
	req *connect.Request[apiv1.CancelOpenWorkbenchSyncRequest],
) (*connect.Response[apiv1.CancelOpenWorkbenchSyncResponse], error)

CancelOpenWorkbenchSync cancels an in-progress synchronous workbench open task.

func (*WorkbenchServiceServer) CloseWorkbench 

func (s *WorkbenchServiceServer) CloseWorkbench(
	ctx context.Context,
	req *connect.Request[apiv1.CloseWorkbenchRequest],
) (*connect.Response[apiv1.CloseWorkbenchResponse], error)

CloseWorkbench explicitly closes and frees the specified Workbench session.

func (*WorkbenchServiceServer) FilterTimeline 

func (s *WorkbenchServiceServer) FilterTimeline(
	ctx context.Context,
	req *connect.Request[apiv1.FilterTimelineRequest],
	stream *connect.ServerStream[apiv1.FilterTimelineResponse],
) error

FilterTimeline executes a timeline and log filtering pipeline on the server and streams progress updates followed by the final matched ID sets.

func (*WorkbenchServiceServer) FilterTimelineSync 

func (s *WorkbenchServiceServer) FilterTimelineSync(
	ctx context.Context,
	req *connect.Request[apiv1.FilterTimelineSyncRequest],
) (*connect.Response[apiv1.FilterTimelineSyncResponse], error)

FilterTimelineSync evaluates a timeline and log filtering pipeline synchronously or polls its in-progress status.

func (*WorkbenchServiceServer) GetArchitectureGraph 

func (s *WorkbenchServiceServer) GetArchitectureGraph(
	ctx context.Context,
	req *connect.Request[apiv1.GetArchitectureGraphRequest],
) (*connect.Response[apiv1.GetArchitectureGraphResponse], error)

GetArchitectureGraph builds and returns the architecture graph for the specified workbench session and timestamp.

func (*WorkbenchServiceServer) GetTimelineIDsForLogs added in v0.58.4 

func (s *WorkbenchServiceServer) GetTimelineIDsForLogs(
	ctx context.Context,
	req *connect.Request[apiv1.GetTimelineIDsForLogsRequest],
) (*connect.Response[apiv1.GetTimelineIDsForLogsResponse], error)

GetTimelineIDsForLogs retrieves timeline IDs associated with specified log IDs.

func (*WorkbenchServiceServer) HeartbeatWorkbench 

func (s *WorkbenchServiceServer) HeartbeatWorkbench(
	ctx context.Context,
	req *connect.Request[apiv1.HeartbeatWorkbenchRequest],
) (*connect.Response[apiv1.HeartbeatWorkbenchResponse], error)

HeartbeatWorkbench refreshes the lease expiration time for an active Workbench session.

func (*WorkbenchServiceServer) OpenWorkbench 

func (s *WorkbenchServiceServer) OpenWorkbench(
	ctx context.Context,
	req *connect.Request[apiv1.OpenWorkbenchRequest],
	stream *connect.ServerStream[apiv1.OpenWorkbenchResponse],
) error

OpenWorkbench opens or attaches to an in-memory Workbench session, streaming progress stages back to the client.

func (*WorkbenchServiceServer) OpenWorkbenchSync 

func (s *WorkbenchServiceServer) OpenWorkbenchSync(
	ctx context.Context,
	req *connect.Request[apiv1.OpenWorkbenchSyncRequest],
) (*connect.Response[apiv1.OpenWorkbenchSyncResponse], error)

OpenWorkbenchSync opens or polls loading progress of a Workbench session without streaming.

func (*WorkbenchServiceServer) PullIndexProgress 

func (s *WorkbenchServiceServer) PullIndexProgress(
	ctx context.Context,
	req *connect.Request[apiv1.PullIndexProgressRequest],
) (*connect.Response[apiv1.PullIndexProgressResponse], error)

PullIndexProgress retrieves the current search index construction progress and status snapshot for an active Workbench session.

func (*WorkbenchServiceServer) ReadStructYAMLs 

func (s *WorkbenchServiceServer) ReadStructYAMLs(
	ctx context.Context,
	req *connect.Request[apiv1.ReadStructYAMLsRequest],
) (*connect.Response[apiv1.ReadStructYAMLsResponse], error)

ReadStructYAMLs decodes interned structs by IDs and returns their YAML representations.

func (*WorkbenchServiceServer) WatchIndexProgress 

func (s *WorkbenchServiceServer) WatchIndexProgress(
	ctx context.Context,
	req *connect.Request[apiv1.WatchIndexProgressRequest],
	stream *connect.ServerStream[apiv1.WatchIndexProgressResponse],
) error

WatchIndexProgress streams the search index construction progress and status for an active Workbench session. The server terminates the stream every 30s to accommodate proxy timeouts, and clients are expected to reconnect.

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.