apiv1connect

package
v0.58.2 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	// CELValidationServiceValidateTimelineQueryProcedure is the fully-qualified name of the
	// CELValidationService's ValidateTimelineQuery RPC.
	CELValidationServiceValidateTimelineQueryProcedure = "/api.v1.CELValidationService/ValidateTimelineQuery"
	// CELValidationServiceValidateLogQueryProcedure is the fully-qualified name of the
	// CELValidationService's ValidateLogQuery RPC.
	CELValidationServiceValidateLogQueryProcedure = "/api.v1.CELValidationService/ValidateLogQuery"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// FileParameterUploadServiceStartFileUploadProcedure is the fully-qualified name of the
	// FileParameterUploadService's StartFileUpload RPC.
	FileParameterUploadServiceStartFileUploadProcedure = "/api.v1.FileParameterUploadService/StartFileUpload"
	// FileParameterUploadServiceUploadFileChunkProcedure is the fully-qualified name of the
	// FileParameterUploadService's UploadFileChunk RPC.
	FileParameterUploadServiceUploadFileChunkProcedure = "/api.v1.FileParameterUploadService/UploadFileChunk"
	// FileParameterUploadServiceCompleteFileUploadProcedure is the fully-qualified name of the
	// FileParameterUploadService's CompleteFileUpload RPC.
	FileParameterUploadServiceCompleteFileUploadProcedure = "/api.v1.FileParameterUploadService/CompleteFileUpload"
	// FileParameterUploadServiceAbortFileUploadProcedure is the fully-qualified name of the
	// FileParameterUploadService's AbortFileUpload RPC.
	FileParameterUploadServiceAbortFileUploadProcedure = "/api.v1.FileParameterUploadService/AbortFileUpload"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// ImportInspectionServiceStartImportInspectionProcedure is the fully-qualified name of the
	// ImportInspectionService's StartImportInspection RPC.
	ImportInspectionServiceStartImportInspectionProcedure = "/api.v1.ImportInspectionService/StartImportInspection"
	// ImportInspectionServiceUploadInspectionChunkProcedure is the fully-qualified name of the
	// ImportInspectionService's UploadInspectionChunk RPC.
	ImportInspectionServiceUploadInspectionChunkProcedure = "/api.v1.ImportInspectionService/UploadInspectionChunk"
	// ImportInspectionServiceCompleteImportInspectionProcedure is the fully-qualified name of the
	// ImportInspectionService's CompleteImportInspection RPC.
	ImportInspectionServiceCompleteImportInspectionProcedure = "/api.v1.ImportInspectionService/CompleteImportInspection"
	// ImportInspectionServiceAbortImportInspectionProcedure is the fully-qualified name of the
	// ImportInspectionService's AbortImportInspection RPC.
	ImportInspectionServiceAbortImportInspectionProcedure = "/api.v1.ImportInspectionService/AbortImportInspection"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// InspectionServiceGetInspectionTypesProcedure is the fully-qualified name of the
	// InspectionService's GetInspectionTypes RPC.
	InspectionServiceGetInspectionTypesProcedure = "/api.v1.InspectionService/GetInspectionTypes"
	// InspectionServiceGetInspectionsProcedure is the fully-qualified name of the InspectionService's
	// GetInspections RPC.
	InspectionServiceGetInspectionsProcedure = "/api.v1.InspectionService/GetInspections"
	// InspectionServiceWatchInspectionsProcedure is the fully-qualified name of the InspectionService's
	// WatchInspections RPC.
	InspectionServiceWatchInspectionsProcedure = "/api.v1.InspectionService/WatchInspections"
	// InspectionServicePullInspectionsProcedure is the fully-qualified name of the InspectionService's
	// PullInspections RPC.
	InspectionServicePullInspectionsProcedure = "/api.v1.InspectionService/PullInspections"
	// InspectionServiceCreateInspectionProcedure is the fully-qualified name of the InspectionService's
	// CreateInspection RPC.
	InspectionServiceCreateInspectionProcedure = "/api.v1.InspectionService/CreateInspection"
	// InspectionServiceUpdateInspectionProcedure is the fully-qualified name of the InspectionService's
	// UpdateInspection RPC.
	InspectionServiceUpdateInspectionProcedure = "/api.v1.InspectionService/UpdateInspection"
	// InspectionServiceGetInspectionFeaturesProcedure is the fully-qualified name of the
	// InspectionService's GetInspectionFeatures RPC.
	InspectionServiceGetInspectionFeaturesProcedure = "/api.v1.InspectionService/GetInspectionFeatures"
	// InspectionServiceUpdateInspectionFeaturesProcedure is the fully-qualified name of the
	// InspectionService's UpdateInspectionFeatures RPC.
	InspectionServiceUpdateInspectionFeaturesProcedure = "/api.v1.InspectionService/UpdateInspectionFeatures"
	// InspectionServiceDryRunInspectionProcedure is the fully-qualified name of the InspectionService's
	// DryRunInspection RPC.
	InspectionServiceDryRunInspectionProcedure = "/api.v1.InspectionService/DryRunInspection"
	// InspectionServiceRunInspectionProcedure is the fully-qualified name of the InspectionService's
	// RunInspection RPC.
	InspectionServiceRunInspectionProcedure = "/api.v1.InspectionService/RunInspection"
	// InspectionServiceCancelInspectionProcedure is the fully-qualified name of the InspectionService's
	// CancelInspection RPC.
	InspectionServiceCancelInspectionProcedure = "/api.v1.InspectionService/CancelInspection"
	// InspectionServiceGetInspectionMetadataProcedure is the fully-qualified name of the
	// InspectionService's GetInspectionMetadata RPC.
	InspectionServiceGetInspectionMetadataProcedure = "/api.v1.InspectionService/GetInspectionMetadata"
	// InspectionServiceGetInspectionDataChunkProcedure is the fully-qualified name of the
	// InspectionService's GetInspectionDataChunk RPC.
	InspectionServiceGetInspectionDataChunkProcedure = "/api.v1.InspectionService/GetInspectionDataChunk"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// PopupServiceWatchPopupProcedure is the fully-qualified name of the PopupService's WatchPopup RPC.
	PopupServiceWatchPopupProcedure = "/api.v1.PopupService/WatchPopup"
	// PopupServiceValidatePopupAnswerProcedure is the fully-qualified name of the PopupService's
	// ValidatePopupAnswer RPC.
	PopupServiceValidatePopupAnswerProcedure = "/api.v1.PopupService/ValidatePopupAnswer"
	// PopupServiceSubmitPopupAnswerProcedure is the fully-qualified name of the PopupService's
	// SubmitPopupAnswer RPC.
	PopupServiceSubmitPopupAnswerProcedure = "/api.v1.PopupService/SubmitPopupAnswer"
	// PopupServicePullPopupProcedure is the fully-qualified name of the PopupService's PullPopup RPC.
	PopupServicePullPopupProcedure = "/api.v1.PopupService/PullPopup"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// ServerStatusServiceWatchServerStatProcedure is the fully-qualified name of the
	// ServerStatusService's WatchServerStat RPC.
	ServerStatusServiceWatchServerStatProcedure = "/api.v1.ServerStatusService/WatchServerStat"
	// ServerStatusServicePullServerStatProcedure is the fully-qualified name of the
	// ServerStatusService's PullServerStat RPC.
	ServerStatusServicePullServerStatProcedure = "/api.v1.ServerStatusService/PullServerStat"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// WorkbenchServiceOpenWorkbenchProcedure is the fully-qualified name of the WorkbenchService's
	// OpenWorkbench RPC.
	WorkbenchServiceOpenWorkbenchProcedure = "/api.v1.WorkbenchService/OpenWorkbench"
	// WorkbenchServiceOpenWorkbenchSyncProcedure is the fully-qualified name of the WorkbenchService's
	// OpenWorkbenchSync RPC.
	WorkbenchServiceOpenWorkbenchSyncProcedure = "/api.v1.WorkbenchService/OpenWorkbenchSync"
	// WorkbenchServiceCancelOpenWorkbenchSyncProcedure is the fully-qualified name of the
	// WorkbenchService's CancelOpenWorkbenchSync RPC.
	WorkbenchServiceCancelOpenWorkbenchSyncProcedure = "/api.v1.WorkbenchService/CancelOpenWorkbenchSync"
	// WorkbenchServiceWatchIndexProgressProcedure is the fully-qualified name of the WorkbenchService's
	// WatchIndexProgress RPC.
	WorkbenchServiceWatchIndexProgressProcedure = "/api.v1.WorkbenchService/WatchIndexProgress"
	// WorkbenchServicePullIndexProgressProcedure is the fully-qualified name of the WorkbenchService's
	// PullIndexProgress RPC.
	WorkbenchServicePullIndexProgressProcedure = "/api.v1.WorkbenchService/PullIndexProgress"
	// WorkbenchServiceHeartbeatWorkbenchProcedure is the fully-qualified name of the WorkbenchService's
	// HeartbeatWorkbench RPC.
	WorkbenchServiceHeartbeatWorkbenchProcedure = "/api.v1.WorkbenchService/HeartbeatWorkbench"
	// WorkbenchServiceReadStructYAMLsProcedure is the fully-qualified name of the WorkbenchService's
	// ReadStructYAMLs RPC.
	WorkbenchServiceReadStructYAMLsProcedure = "/api.v1.WorkbenchService/ReadStructYAMLs"
	// WorkbenchServiceFilterTimelineProcedure is the fully-qualified name of the WorkbenchService's
	// FilterTimeline RPC.
	WorkbenchServiceFilterTimelineProcedure = "/api.v1.WorkbenchService/FilterTimeline"
	// WorkbenchServiceFilterTimelineSyncProcedure is the fully-qualified name of the WorkbenchService's
	// FilterTimelineSync RPC.
	WorkbenchServiceFilterTimelineSyncProcedure = "/api.v1.WorkbenchService/FilterTimelineSync"
	// WorkbenchServiceCancelFilterTimelineSyncProcedure is the fully-qualified name of the
	// WorkbenchService's CancelFilterTimelineSync RPC.
	WorkbenchServiceCancelFilterTimelineSyncProcedure = "/api.v1.WorkbenchService/CancelFilterTimelineSync"
	// WorkbenchServiceGetArchitectureGraphProcedure is the fully-qualified name of the
	// WorkbenchService's GetArchitectureGraph RPC.
	WorkbenchServiceGetArchitectureGraphProcedure = "/api.v1.WorkbenchService/GetArchitectureGraph"
	// WorkbenchServiceCloseWorkbenchProcedure is the fully-qualified name of the WorkbenchService's
	// CloseWorkbench RPC.
	WorkbenchServiceCloseWorkbenchProcedure = "/api.v1.WorkbenchService/CloseWorkbench"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// CELValidationServiceName is the fully-qualified name of the CELValidationService service.
	CELValidationServiceName = "api.v1.CELValidationService"
)
View Source 
const (
	// FileParameterUploadServiceName is the fully-qualified name of the FileParameterUploadService
	// service.
	FileParameterUploadServiceName = "api.v1.FileParameterUploadService"
)
View Source 
const (
	// ImportInspectionServiceName is the fully-qualified name of the ImportInspectionService service.
	ImportInspectionServiceName = "api.v1.ImportInspectionService"
)
View Source 
const (
	// InspectionServiceName is the fully-qualified name of the InspectionService service.
	InspectionServiceName = "api.v1.InspectionService"
)
View Source 
const (
	// PopupServiceName is the fully-qualified name of the PopupService service.
	PopupServiceName = "api.v1.PopupService"
)
View Source 
const (
	// ServerStatusServiceName is the fully-qualified name of the ServerStatusService service.
	ServerStatusServiceName = "api.v1.ServerStatusService"
)
View Source 
const (
	// WorkbenchServiceName is the fully-qualified name of the WorkbenchService service.
	WorkbenchServiceName = "api.v1.WorkbenchService"
)

Variables

This section is empty.

Functions

func NewCELValidationServiceHandler 

func NewCELValidationServiceHandler(svc CELValidationServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewCELValidationServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewFileParameterUploadServiceHandler 

func NewFileParameterUploadServiceHandler(svc FileParameterUploadServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewFileParameterUploadServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewImportInspectionServiceHandler 

func NewImportInspectionServiceHandler(svc ImportInspectionServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewImportInspectionServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewInspectionServiceHandler 

func NewInspectionServiceHandler(svc InspectionServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewInspectionServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewPopupServiceHandler 

func NewPopupServiceHandler(svc PopupServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewPopupServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewServerStatusServiceHandler 

func NewServerStatusServiceHandler(svc ServerStatusServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewServerStatusServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewWorkbenchServiceHandler 

func NewWorkbenchServiceHandler(svc WorkbenchServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewWorkbenchServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

Types

type CELValidationServiceClient 

type CELValidationServiceClient interface {
	// Validates a timeline CEL query expression against registered schemas and custom functions.
	ValidateTimelineQuery(context.Context, *connect.Request[v1.ValidateTimelineQueryRequest]) (*connect.Response[v1.ValidateTimelineQueryResponse], error)
	// Validates a log CEL query expression against registered schemas and custom functions.
	ValidateLogQuery(context.Context, *connect.Request[v1.ValidateLogQueryRequest]) (*connect.Response[v1.ValidateLogQueryResponse], error)
}

CELValidationServiceClient is a client for the api.v1.CELValidationService service.

func NewCELValidationServiceClient 

func NewCELValidationServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) CELValidationServiceClient

NewCELValidationServiceClient constructs a client for the api.v1.CELValidationService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type CELValidationServiceHandler 

type CELValidationServiceHandler interface {
	// Validates a timeline CEL query expression against registered schemas and custom functions.
	ValidateTimelineQuery(context.Context, *connect.Request[v1.ValidateTimelineQueryRequest]) (*connect.Response[v1.ValidateTimelineQueryResponse], error)
	// Validates a log CEL query expression against registered schemas and custom functions.
	ValidateLogQuery(context.Context, *connect.Request[v1.ValidateLogQueryRequest]) (*connect.Response[v1.ValidateLogQueryResponse], error)
}

CELValidationServiceHandler is an implementation of the api.v1.CELValidationService service.

type FileParameterUploadServiceClient 

type FileParameterUploadServiceClient interface {
	// Starts an upload session for a file form parameter and returns a session token.
	StartFileUpload(context.Context, *connect.Request[v1.StartFileUploadRequest]) (*connect.Response[v1.StartFileUploadResponse], error)
	// Uploads a single chunk of the file parameter within an active upload session.
	UploadFileChunk(context.Context, *connect.Request[v1.UploadFileChunkRequest]) (*connect.Response[v1.UploadFileChunkResponse], error)
	// Completes the upload session, moves the assembled file to the upload store, and prepares it for task consumption.
	CompleteFileUpload(context.Context, *connect.Request[v1.CompleteFileUploadRequest]) (*connect.Response[v1.CompleteFileUploadResponse], error)
	// Aborts an in-progress upload session and cleans up temporary chunk files.
	AbortFileUpload(context.Context, *connect.Request[v1.AbortFileUploadRequest]) (*connect.Response[v1.AbortFileUploadResponse], error)
}

FileParameterUploadServiceClient is a client for the api.v1.FileParameterUploadService service.

func NewFileParameterUploadServiceClient 

func NewFileParameterUploadServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) FileParameterUploadServiceClient

NewFileParameterUploadServiceClient constructs a client for the api.v1.FileParameterUploadService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type FileParameterUploadServiceHandler 

type FileParameterUploadServiceHandler interface {
	// Starts an upload session for a file form parameter and returns a session token.
	StartFileUpload(context.Context, *connect.Request[v1.StartFileUploadRequest]) (*connect.Response[v1.StartFileUploadResponse], error)
	// Uploads a single chunk of the file parameter within an active upload session.
	UploadFileChunk(context.Context, *connect.Request[v1.UploadFileChunkRequest]) (*connect.Response[v1.UploadFileChunkResponse], error)
	// Completes the upload session, moves the assembled file to the upload store, and prepares it for task consumption.
	CompleteFileUpload(context.Context, *connect.Request[v1.CompleteFileUploadRequest]) (*connect.Response[v1.CompleteFileUploadResponse], error)
	// Aborts an in-progress upload session and cleans up temporary chunk files.
	AbortFileUpload(context.Context, *connect.Request[v1.AbortFileUploadRequest]) (*connect.Response[v1.AbortFileUploadResponse], error)
}

FileParameterUploadServiceHandler is an implementation of the api.v1.FileParameterUploadService service.

type ImportInspectionServiceClient 

type ImportInspectionServiceClient interface {
	// Starts an import session for an inspection file and returns an import token.
	StartImportInspection(context.Context, *connect.Request[v1.StartImportInspectionRequest]) (*connect.Response[v1.StartImportInspectionResponse], error)
	// Uploads a single chunk of the inspection file within an active import session.
	UploadInspectionChunk(context.Context, *connect.Request[v1.UploadInspectionChunkRequest]) (*connect.Response[v1.UploadInspectionChunkResponse], error)
	// Completes the import session, validates the uploaded .khi file, and registers it to the inspection server.
	CompleteImportInspection(context.Context, *connect.Request[v1.CompleteImportInspectionRequest]) (*connect.Response[v1.CompleteImportInspectionResponse], error)
	// Aborts an in-progress import session and cleans up temporary files.
	AbortImportInspection(context.Context, *connect.Request[v1.AbortImportInspectionRequest]) (*connect.Response[v1.AbortImportInspectionResponse], error)
}

ImportInspectionServiceClient is a client for the api.v1.ImportInspectionService service.

func NewImportInspectionServiceClient 

func NewImportInspectionServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ImportInspectionServiceClient

NewImportInspectionServiceClient constructs a client for the api.v1.ImportInspectionService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type ImportInspectionServiceHandler 

type ImportInspectionServiceHandler interface {
	// Starts an import session for an inspection file and returns an import token.
	StartImportInspection(context.Context, *connect.Request[v1.StartImportInspectionRequest]) (*connect.Response[v1.StartImportInspectionResponse], error)
	// Uploads a single chunk of the inspection file within an active import session.
	UploadInspectionChunk(context.Context, *connect.Request[v1.UploadInspectionChunkRequest]) (*connect.Response[v1.UploadInspectionChunkResponse], error)
	// Completes the import session, validates the uploaded .khi file, and registers it to the inspection server.
	CompleteImportInspection(context.Context, *connect.Request[v1.CompleteImportInspectionRequest]) (*connect.Response[v1.CompleteImportInspectionResponse], error)
	// Aborts an in-progress import session and cleans up temporary files.
	AbortImportInspection(context.Context, *connect.Request[v1.AbortImportInspectionRequest]) (*connect.Response[v1.AbortImportInspectionResponse], error)
}

ImportInspectionServiceHandler is an implementation of the api.v1.ImportInspectionService service.

type InspectionServiceClient 

type InspectionServiceClient interface {
	// Returns all supported inspection types.
	GetInspectionTypes(context.Context, *connect.Request[v1.GetInspectionTypesRequest]) (*connect.Response[v1.GetInspectionTypesResponse], error)
	// Returns all currently active inspections (one-off snapshot).
	GetInspections(context.Context, *connect.Request[v1.GetInspectionsRequest]) (*connect.Response[v1.GetInspectionsResponse], error)
	// Streams real-time updates of active inspections and progress.
	// The server sends the latest state snapshot immediately upon connection.
	// The stream terminates after approximately 30 seconds to support runtimes without long-lived connection support;
	// clients are expected to automatically reconnect.
	WatchInspections(context.Context, *connect.Request[v1.WatchInspectionsRequest]) (*connect.ServerStreamForClient[v1.WatchInspectionsResponse], error)
	// Pulls active inspections and progress snapshot without opening a persistent stream.
	PullInspections(context.Context, *connect.Request[v1.PullInspectionsRequest]) (*connect.Response[v1.PullInspectionsResponse], error)
	// Creates a new inspection runner session for a given inspection type.
	CreateInspection(context.Context, *connect.Request[v1.CreateInspectionRequest]) (*connect.Response[v1.CreateInspectionResponse], error)
	// Updates inspection settings such as display title.
	UpdateInspection(context.Context, *connect.Request[v1.UpdateInspectionRequest]) (*connect.Response[v1.UpdateInspectionResponse], error)
	// Lists features available for an inspection and their enabled state.
	GetInspectionFeatures(context.Context, *connect.Request[v1.GetInspectionFeaturesRequest]) (*connect.Response[v1.GetInspectionFeaturesResponse], error)
	// Updates the enabled state of features for an inspection.
	UpdateInspectionFeatures(context.Context, *connect.Request[v1.UpdateInspectionFeaturesRequest]) (*connect.Response[v1.UpdateInspectionFeaturesResponse], error)
	// Dry-runs an inspection task graph with user parameters, returning form fields, queries, and plan.
	DryRunInspection(context.Context, *connect.Request[v1.DryRunInspectionRequest]) (*connect.Response[v1.DryRunInspectionResponse], error)
	// Executes an inspection task graph asynchronously.
	RunInspection(context.Context, *connect.Request[v1.RunInspectionRequest]) (*connect.Response[v1.RunInspectionResponse], error)
	// Cancels an in-progress inspection run.
	CancelInspection(context.Context, *connect.Request[v1.CancelInspectionRequest]) (*connect.Response[v1.CancelInspectionResponse], error)
	// Retrieves inspection metadata of a finished inspection.
	GetInspectionMetadata(context.Context, *connect.Request[v1.GetInspectionMetadataRequest]) (*connect.Response[v1.GetInspectionMetadataResponse], error)
	// Downloads a chunk of the generated .khi inspection binary data.
	GetInspectionDataChunk(context.Context, *connect.Request[v1.GetInspectionDataChunkRequest]) (*connect.Response[v1.GetInspectionDataChunkResponse], error)
}

InspectionServiceClient is a client for the api.v1.InspectionService service.

func NewInspectionServiceClient 

func NewInspectionServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) InspectionServiceClient

NewInspectionServiceClient constructs a client for the api.v1.InspectionService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type InspectionServiceHandler 

type InspectionServiceHandler interface {
	// Returns all supported inspection types.
	GetInspectionTypes(context.Context, *connect.Request[v1.GetInspectionTypesRequest]) (*connect.Response[v1.GetInspectionTypesResponse], error)
	// Returns all currently active inspections (one-off snapshot).
	GetInspections(context.Context, *connect.Request[v1.GetInspectionsRequest]) (*connect.Response[v1.GetInspectionsResponse], error)
	// Streams real-time updates of active inspections and progress.
	// The server sends the latest state snapshot immediately upon connection.
	// The stream terminates after approximately 30 seconds to support runtimes without long-lived connection support;
	// clients are expected to automatically reconnect.
	WatchInspections(context.Context, *connect.Request[v1.WatchInspectionsRequest], *connect.ServerStream[v1.WatchInspectionsResponse]) error
	// Pulls active inspections and progress snapshot without opening a persistent stream.
	PullInspections(context.Context, *connect.Request[v1.PullInspectionsRequest]) (*connect.Response[v1.PullInspectionsResponse], error)
	// Creates a new inspection runner session for a given inspection type.
	CreateInspection(context.Context, *connect.Request[v1.CreateInspectionRequest]) (*connect.Response[v1.CreateInspectionResponse], error)
	// Updates inspection settings such as display title.
	UpdateInspection(context.Context, *connect.Request[v1.UpdateInspectionRequest]) (*connect.Response[v1.UpdateInspectionResponse], error)
	// Lists features available for an inspection and their enabled state.
	GetInspectionFeatures(context.Context, *connect.Request[v1.GetInspectionFeaturesRequest]) (*connect.Response[v1.GetInspectionFeaturesResponse], error)
	// Updates the enabled state of features for an inspection.
	UpdateInspectionFeatures(context.Context, *connect.Request[v1.UpdateInspectionFeaturesRequest]) (*connect.Response[v1.UpdateInspectionFeaturesResponse], error)
	// Dry-runs an inspection task graph with user parameters, returning form fields, queries, and plan.
	DryRunInspection(context.Context, *connect.Request[v1.DryRunInspectionRequest]) (*connect.Response[v1.DryRunInspectionResponse], error)
	// Executes an inspection task graph asynchronously.
	RunInspection(context.Context, *connect.Request[v1.RunInspectionRequest]) (*connect.Response[v1.RunInspectionResponse], error)
	// Cancels an in-progress inspection run.
	CancelInspection(context.Context, *connect.Request[v1.CancelInspectionRequest]) (*connect.Response[v1.CancelInspectionResponse], error)
	// Retrieves inspection metadata of a finished inspection.
	GetInspectionMetadata(context.Context, *connect.Request[v1.GetInspectionMetadataRequest]) (*connect.Response[v1.GetInspectionMetadataResponse], error)
	// Downloads a chunk of the generated .khi inspection binary data.
	GetInspectionDataChunk(context.Context, *connect.Request[v1.GetInspectionDataChunkRequest]) (*connect.Response[v1.GetInspectionDataChunkResponse], error)
}

InspectionServiceHandler is an implementation of the api.v1.InspectionService service.

type PopupServiceClient 

type PopupServiceClient interface {
	// Watches real-time popup events from the server. The server terminates the stream every 30s to accommodate proxy timeouts, and clients are expected to reconnect.
	WatchPopup(context.Context, *connect.Request[v1.WatchPopupRequest]) (*connect.ServerStreamForClient[v1.WatchPopupResponse], error)
	// Validates the current input in the active popup dialog without submitting the final answer.
	ValidatePopupAnswer(context.Context, *connect.Request[v1.ValidatePopupAnswerRequest]) (*connect.Response[v1.ValidatePopupAnswerResponse], error)
	// Submits the finalized answer for the active popup dialog.
	SubmitPopupAnswer(context.Context, *connect.Request[v1.SubmitPopupAnswerRequest]) (*connect.Response[v1.SubmitPopupAnswerResponse], error)
	// Retrieves the currently active popup dialog snapshot without opening a persistent stream.
	PullPopup(context.Context, *connect.Request[v1.PullPopupRequest]) (*connect.Response[v1.PullPopupResponse], error)
}

PopupServiceClient is a client for the api.v1.PopupService service.

func NewPopupServiceClient 

func NewPopupServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) PopupServiceClient

NewPopupServiceClient constructs a client for the api.v1.PopupService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type PopupServiceHandler 

type PopupServiceHandler interface {
	// Watches real-time popup events from the server. The server terminates the stream every 30s to accommodate proxy timeouts, and clients are expected to reconnect.
	WatchPopup(context.Context, *connect.Request[v1.WatchPopupRequest], *connect.ServerStream[v1.WatchPopupResponse]) error
	// Validates the current input in the active popup dialog without submitting the final answer.
	ValidatePopupAnswer(context.Context, *connect.Request[v1.ValidatePopupAnswerRequest]) (*connect.Response[v1.ValidatePopupAnswerResponse], error)
	// Submits the finalized answer for the active popup dialog.
	SubmitPopupAnswer(context.Context, *connect.Request[v1.SubmitPopupAnswerRequest]) (*connect.Response[v1.SubmitPopupAnswerResponse], error)
	// Retrieves the currently active popup dialog snapshot without opening a persistent stream.
	PullPopup(context.Context, *connect.Request[v1.PullPopupRequest]) (*connect.Response[v1.PullPopupResponse], error)
}

PopupServiceHandler is an implementation of the api.v1.PopupService service.

type ServerStatusServiceClient 

type ServerStatusServiceClient interface {
	// Streams real-time server resource usage statistics.
	// The server sends the current state immediately upon connection and pushes updates periodically.
	// The stream terminates after approximately 30 seconds to support runtimes without long-lived connection support;
	// clients are expected to automatically reconnect.
	WatchServerStat(context.Context, *connect.Request[v1.WatchServerStatRequest]) (*connect.ServerStreamForClient[v1.WatchServerStatResponse], error)
	// Pulls current server resource usage statistics without opening a persistent stream.
	PullServerStat(context.Context, *connect.Request[v1.PullServerStatRequest]) (*connect.Response[v1.PullServerStatResponse], error)
}

ServerStatusServiceClient is a client for the api.v1.ServerStatusService service.

func NewServerStatusServiceClient 

func NewServerStatusServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ServerStatusServiceClient

NewServerStatusServiceClient constructs a client for the api.v1.ServerStatusService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type ServerStatusServiceHandler 

type ServerStatusServiceHandler interface {
	// Streams real-time server resource usage statistics.
	// The server sends the current state immediately upon connection and pushes updates periodically.
	// The stream terminates after approximately 30 seconds to support runtimes without long-lived connection support;
	// clients are expected to automatically reconnect.
	WatchServerStat(context.Context, *connect.Request[v1.WatchServerStatRequest], *connect.ServerStream[v1.WatchServerStatResponse]) error
	// Pulls current server resource usage statistics without opening a persistent stream.
	PullServerStat(context.Context, *connect.Request[v1.PullServerStatRequest]) (*connect.Response[v1.PullServerStatResponse], error)
}

ServerStatusServiceHandler is an implementation of the api.v1.ServerStatusService service.

type UnimplementedCELValidationServiceHandler 

type UnimplementedCELValidationServiceHandler struct{}

UnimplementedCELValidationServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedCELValidationServiceHandler) ValidateLogQuery 

func (UnimplementedCELValidationServiceHandler) ValidateLogQuery(context.Context, *connect.Request[v1.ValidateLogQueryRequest]) (*connect.Response[v1.ValidateLogQueryResponse], error)

func (UnimplementedCELValidationServiceHandler) ValidateTimelineQuery 

func (UnimplementedCELValidationServiceHandler) ValidateTimelineQuery(context.Context, *connect.Request[v1.ValidateTimelineQueryRequest]) (*connect.Response[v1.ValidateTimelineQueryResponse], error)

type UnimplementedFileParameterUploadServiceHandler 

type UnimplementedFileParameterUploadServiceHandler struct{}

UnimplementedFileParameterUploadServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedFileParameterUploadServiceHandler) AbortFileUpload 

func (UnimplementedFileParameterUploadServiceHandler) AbortFileUpload(context.Context, *connect.Request[v1.AbortFileUploadRequest]) (*connect.Response[v1.AbortFileUploadResponse], error)

func (UnimplementedFileParameterUploadServiceHandler) CompleteFileUpload 

func (UnimplementedFileParameterUploadServiceHandler) CompleteFileUpload(context.Context, *connect.Request[v1.CompleteFileUploadRequest]) (*connect.Response[v1.CompleteFileUploadResponse], error)

func (UnimplementedFileParameterUploadServiceHandler) StartFileUpload 

func (UnimplementedFileParameterUploadServiceHandler) StartFileUpload(context.Context, *connect.Request[v1.StartFileUploadRequest]) (*connect.Response[v1.StartFileUploadResponse], error)

func (UnimplementedFileParameterUploadServiceHandler) UploadFileChunk 

func (UnimplementedFileParameterUploadServiceHandler) UploadFileChunk(context.Context, *connect.Request[v1.UploadFileChunkRequest]) (*connect.Response[v1.UploadFileChunkResponse], error)

type UnimplementedImportInspectionServiceHandler 

type UnimplementedImportInspectionServiceHandler struct{}

UnimplementedImportInspectionServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedImportInspectionServiceHandler) AbortImportInspection 

func (UnimplementedImportInspectionServiceHandler) AbortImportInspection(context.Context, *connect.Request[v1.AbortImportInspectionRequest]) (*connect.Response[v1.AbortImportInspectionResponse], error)

func (UnimplementedImportInspectionServiceHandler) CompleteImportInspection 

func (UnimplementedImportInspectionServiceHandler) CompleteImportInspection(context.Context, *connect.Request[v1.CompleteImportInspectionRequest]) (*connect.Response[v1.CompleteImportInspectionResponse], error)

func (UnimplementedImportInspectionServiceHandler) StartImportInspection 

func (UnimplementedImportInspectionServiceHandler) StartImportInspection(context.Context, *connect.Request[v1.StartImportInspectionRequest]) (*connect.Response[v1.StartImportInspectionResponse], error)

func (UnimplementedImportInspectionServiceHandler) UploadInspectionChunk 

func (UnimplementedImportInspectionServiceHandler) UploadInspectionChunk(context.Context, *connect.Request[v1.UploadInspectionChunkRequest]) (*connect.Response[v1.UploadInspectionChunkResponse], error)

type UnimplementedInspectionServiceHandler 

type UnimplementedInspectionServiceHandler struct{}

UnimplementedInspectionServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedInspectionServiceHandler) CancelInspection 

func (UnimplementedInspectionServiceHandler) CancelInspection(context.Context, *connect.Request[v1.CancelInspectionRequest]) (*connect.Response[v1.CancelInspectionResponse], error)

func (UnimplementedInspectionServiceHandler) CreateInspection 

func (UnimplementedInspectionServiceHandler) CreateInspection(context.Context, *connect.Request[v1.CreateInspectionRequest]) (*connect.Response[v1.CreateInspectionResponse], error)

func (UnimplementedInspectionServiceHandler) DryRunInspection 

func (UnimplementedInspectionServiceHandler) DryRunInspection(context.Context, *connect.Request[v1.DryRunInspectionRequest]) (*connect.Response[v1.DryRunInspectionResponse], error)

func (UnimplementedInspectionServiceHandler) GetInspectionDataChunk 

func (UnimplementedInspectionServiceHandler) GetInspectionDataChunk(context.Context, *connect.Request[v1.GetInspectionDataChunkRequest]) (*connect.Response[v1.GetInspectionDataChunkResponse], error)

func (UnimplementedInspectionServiceHandler) GetInspectionFeatures 

func (UnimplementedInspectionServiceHandler) GetInspectionFeatures(context.Context, *connect.Request[v1.GetInspectionFeaturesRequest]) (*connect.Response[v1.GetInspectionFeaturesResponse], error)

func (UnimplementedInspectionServiceHandler) GetInspectionMetadata 

func (UnimplementedInspectionServiceHandler) GetInspectionMetadata(context.Context, *connect.Request[v1.GetInspectionMetadataRequest]) (*connect.Response[v1.GetInspectionMetadataResponse], error)

func (UnimplementedInspectionServiceHandler) GetInspectionTypes 

func (UnimplementedInspectionServiceHandler) GetInspectionTypes(context.Context, *connect.Request[v1.GetInspectionTypesRequest]) (*connect.Response[v1.GetInspectionTypesResponse], error)

func (UnimplementedInspectionServiceHandler) GetInspections 

func (UnimplementedInspectionServiceHandler) GetInspections(context.Context, *connect.Request[v1.GetInspectionsRequest]) (*connect.Response[v1.GetInspectionsResponse], error)

func (UnimplementedInspectionServiceHandler) PullInspections 

func (UnimplementedInspectionServiceHandler) PullInspections(context.Context, *connect.Request[v1.PullInspectionsRequest]) (*connect.Response[v1.PullInspectionsResponse], error)

func (UnimplementedInspectionServiceHandler) RunInspection 

func (UnimplementedInspectionServiceHandler) RunInspection(context.Context, *connect.Request[v1.RunInspectionRequest]) (*connect.Response[v1.RunInspectionResponse], error)

func (UnimplementedInspectionServiceHandler) UpdateInspection 

func (UnimplementedInspectionServiceHandler) UpdateInspection(context.Context, *connect.Request[v1.UpdateInspectionRequest]) (*connect.Response[v1.UpdateInspectionResponse], error)

func (UnimplementedInspectionServiceHandler) UpdateInspectionFeatures 

func (UnimplementedInspectionServiceHandler) UpdateInspectionFeatures(context.Context, *connect.Request[v1.UpdateInspectionFeaturesRequest]) (*connect.Response[v1.UpdateInspectionFeaturesResponse], error)

func (UnimplementedInspectionServiceHandler) WatchInspections 

func (UnimplementedInspectionServiceHandler) WatchInspections(context.Context, *connect.Request[v1.WatchInspectionsRequest], *connect.ServerStream[v1.WatchInspectionsResponse]) error

type UnimplementedPopupServiceHandler 

type UnimplementedPopupServiceHandler struct{}

UnimplementedPopupServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedPopupServiceHandler) PullPopup 

func (UnimplementedPopupServiceHandler) PullPopup(context.Context, *connect.Request[v1.PullPopupRequest]) (*connect.Response[v1.PullPopupResponse], error)

func (UnimplementedPopupServiceHandler) SubmitPopupAnswer 

func (UnimplementedPopupServiceHandler) SubmitPopupAnswer(context.Context, *connect.Request[v1.SubmitPopupAnswerRequest]) (*connect.Response[v1.SubmitPopupAnswerResponse], error)

func (UnimplementedPopupServiceHandler) ValidatePopupAnswer 

func (UnimplementedPopupServiceHandler) ValidatePopupAnswer(context.Context, *connect.Request[v1.ValidatePopupAnswerRequest]) (*connect.Response[v1.ValidatePopupAnswerResponse], error)

func (UnimplementedPopupServiceHandler) WatchPopup 

func (UnimplementedPopupServiceHandler) WatchPopup(context.Context, *connect.Request[v1.WatchPopupRequest], *connect.ServerStream[v1.WatchPopupResponse]) error

type UnimplementedServerStatusServiceHandler 

type UnimplementedServerStatusServiceHandler struct{}

UnimplementedServerStatusServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedServerStatusServiceHandler) PullServerStat 

func (UnimplementedServerStatusServiceHandler) PullServerStat(context.Context, *connect.Request[v1.PullServerStatRequest]) (*connect.Response[v1.PullServerStatResponse], error)

func (UnimplementedServerStatusServiceHandler) WatchServerStat 

func (UnimplementedServerStatusServiceHandler) WatchServerStat(context.Context, *connect.Request[v1.WatchServerStatRequest], *connect.ServerStream[v1.WatchServerStatResponse]) error

type UnimplementedWorkbenchServiceHandler 

type UnimplementedWorkbenchServiceHandler struct{}

UnimplementedWorkbenchServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedWorkbenchServiceHandler) CancelFilterTimelineSync 

func (UnimplementedWorkbenchServiceHandler) CancelFilterTimelineSync(context.Context, *connect.Request[v1.CancelFilterTimelineSyncRequest]) (*connect.Response[v1.CancelFilterTimelineSyncResponse], error)

func (UnimplementedWorkbenchServiceHandler) CancelOpenWorkbenchSync 

func (UnimplementedWorkbenchServiceHandler) CancelOpenWorkbenchSync(context.Context, *connect.Request[v1.CancelOpenWorkbenchSyncRequest]) (*connect.Response[v1.CancelOpenWorkbenchSyncResponse], error)

func (UnimplementedWorkbenchServiceHandler) CloseWorkbench 

func (UnimplementedWorkbenchServiceHandler) CloseWorkbench(context.Context, *connect.Request[v1.CloseWorkbenchRequest]) (*connect.Response[v1.CloseWorkbenchResponse], error)

func (UnimplementedWorkbenchServiceHandler) FilterTimeline 

func (UnimplementedWorkbenchServiceHandler) FilterTimeline(context.Context, *connect.Request[v1.FilterTimelineRequest], *connect.ServerStream[v1.FilterTimelineResponse]) error

func (UnimplementedWorkbenchServiceHandler) FilterTimelineSync 

func (UnimplementedWorkbenchServiceHandler) FilterTimelineSync(context.Context, *connect.Request[v1.FilterTimelineSyncRequest]) (*connect.Response[v1.FilterTimelineSyncResponse], error)

func (UnimplementedWorkbenchServiceHandler) GetArchitectureGraph 

func (UnimplementedWorkbenchServiceHandler) GetArchitectureGraph(context.Context, *connect.Request[v1.GetArchitectureGraphRequest]) (*connect.Response[v1.GetArchitectureGraphResponse], error)

func (UnimplementedWorkbenchServiceHandler) HeartbeatWorkbench 

func (UnimplementedWorkbenchServiceHandler) HeartbeatWorkbench(context.Context, *connect.Request[v1.HeartbeatWorkbenchRequest]) (*connect.Response[v1.HeartbeatWorkbenchResponse], error)

func (UnimplementedWorkbenchServiceHandler) OpenWorkbench 

func (UnimplementedWorkbenchServiceHandler) OpenWorkbench(context.Context, *connect.Request[v1.OpenWorkbenchRequest], *connect.ServerStream[v1.OpenWorkbenchResponse]) error

func (UnimplementedWorkbenchServiceHandler) OpenWorkbenchSync 

func (UnimplementedWorkbenchServiceHandler) OpenWorkbenchSync(context.Context, *connect.Request[v1.OpenWorkbenchSyncRequest]) (*connect.Response[v1.OpenWorkbenchSyncResponse], error)

func (UnimplementedWorkbenchServiceHandler) PullIndexProgress 

func (UnimplementedWorkbenchServiceHandler) PullIndexProgress(context.Context, *connect.Request[v1.PullIndexProgressRequest]) (*connect.Response[v1.PullIndexProgressResponse], error)

func (UnimplementedWorkbenchServiceHandler) ReadStructYAMLs 

func (UnimplementedWorkbenchServiceHandler) ReadStructYAMLs(context.Context, *connect.Request[v1.ReadStructYAMLsRequest]) (*connect.Response[v1.ReadStructYAMLsResponse], error)

func (UnimplementedWorkbenchServiceHandler) WatchIndexProgress 

func (UnimplementedWorkbenchServiceHandler) WatchIndexProgress(context.Context, *connect.Request[v1.WatchIndexProgressRequest], *connect.ServerStream[v1.WatchIndexProgressResponse]) error

type WorkbenchServiceClient 

type WorkbenchServiceClient interface {
	// Opens or attaches to an in-memory Workbench session with real-time loading progress streaming.
	OpenWorkbench(context.Context, *connect.Request[v1.OpenWorkbenchRequest]) (*connect.ServerStreamForClient[v1.OpenWorkbenchResponse], error)
	// Opens or polls loading progress of a Workbench session without streaming.
	OpenWorkbenchSync(context.Context, *connect.Request[v1.OpenWorkbenchSyncRequest]) (*connect.Response[v1.OpenWorkbenchSyncResponse], error)
	// Cancels an in-progress synchronous workbench open task.
	CancelOpenWorkbenchSync(context.Context, *connect.Request[v1.CancelOpenWorkbenchSyncRequest]) (*connect.Response[v1.CancelOpenWorkbenchSyncResponse], error)
	// Watches the search index construction progress and status for an inspection dataset. The server terminates the stream every 30s to accommodate proxy timeouts, and clients are expected to reconnect.
	WatchIndexProgress(context.Context, *connect.Request[v1.WatchIndexProgressRequest]) (*connect.ServerStreamForClient[v1.WatchIndexProgressResponse], error)
	// Pulls the search index construction progress and status snapshot without opening a persistent stream.
	PullIndexProgress(context.Context, *connect.Request[v1.PullIndexProgressRequest]) (*connect.Response[v1.PullIndexProgressResponse], error)
	// Sends periodic heartbeat to keep the Workbench session alive in memory.
	HeartbeatWorkbench(context.Context, *connect.Request[v1.HeartbeatWorkbenchRequest]) (*connect.Response[v1.HeartbeatWorkbenchResponse], error)
	// Decodes interned structs by IDs and returns their formatted YAML strings.
	ReadStructYAMLs(context.Context, *connect.Request[v1.ReadStructYAMLsRequest]) (*connect.Response[v1.ReadStructYAMLsResponse], error)
	// Evaluates a timeline and log filtering pipeline on the server and streams progress updates followed by the final matched ID sets.
	FilterTimeline(context.Context, *connect.Request[v1.FilterTimelineRequest]) (*connect.ServerStreamForClient[v1.FilterTimelineResponse], error)
	// Evaluates a timeline and log filtering pipeline synchronously or polls its in-progress status.
	FilterTimelineSync(context.Context, *connect.Request[v1.FilterTimelineSyncRequest]) (*connect.Response[v1.FilterTimelineSyncResponse], error)
	// Cancels an in-progress synchronous timeline filtering task.
	CancelFilterTimelineSync(context.Context, *connect.Request[v1.CancelFilterTimelineSyncRequest]) (*connect.Response[v1.CancelFilterTimelineSyncResponse], error)
	// Computes the Kubernetes architecture graph for a specific timestamp based on the active timeline filter.
	GetArchitectureGraph(context.Context, *connect.Request[v1.GetArchitectureGraphRequest]) (*connect.Response[v1.GetArchitectureGraphResponse], error)
	// Explicitly closes and releases an active Workbench session.
	CloseWorkbench(context.Context, *connect.Request[v1.CloseWorkbenchRequest]) (*connect.Response[v1.CloseWorkbenchResponse], error)
}

WorkbenchServiceClient is a client for the api.v1.WorkbenchService service.

func NewWorkbenchServiceClient 

func NewWorkbenchServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) WorkbenchServiceClient

NewWorkbenchServiceClient constructs a client for the api.v1.WorkbenchService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type WorkbenchServiceHandler 

type WorkbenchServiceHandler interface {
	// Opens or attaches to an in-memory Workbench session with real-time loading progress streaming.
	OpenWorkbench(context.Context, *connect.Request[v1.OpenWorkbenchRequest], *connect.ServerStream[v1.OpenWorkbenchResponse]) error
	// Opens or polls loading progress of a Workbench session without streaming.
	OpenWorkbenchSync(context.Context, *connect.Request[v1.OpenWorkbenchSyncRequest]) (*connect.Response[v1.OpenWorkbenchSyncResponse], error)
	// Cancels an in-progress synchronous workbench open task.
	CancelOpenWorkbenchSync(context.Context, *connect.Request[v1.CancelOpenWorkbenchSyncRequest]) (*connect.Response[v1.CancelOpenWorkbenchSyncResponse], error)
	// Watches the search index construction progress and status for an inspection dataset. The server terminates the stream every 30s to accommodate proxy timeouts, and clients are expected to reconnect.
	WatchIndexProgress(context.Context, *connect.Request[v1.WatchIndexProgressRequest], *connect.ServerStream[v1.WatchIndexProgressResponse]) error
	// Pulls the search index construction progress and status snapshot without opening a persistent stream.
	PullIndexProgress(context.Context, *connect.Request[v1.PullIndexProgressRequest]) (*connect.Response[v1.PullIndexProgressResponse], error)
	// Sends periodic heartbeat to keep the Workbench session alive in memory.
	HeartbeatWorkbench(context.Context, *connect.Request[v1.HeartbeatWorkbenchRequest]) (*connect.Response[v1.HeartbeatWorkbenchResponse], error)
	// Decodes interned structs by IDs and returns their formatted YAML strings.
	ReadStructYAMLs(context.Context, *connect.Request[v1.ReadStructYAMLsRequest]) (*connect.Response[v1.ReadStructYAMLsResponse], error)
	// Evaluates a timeline and log filtering pipeline on the server and streams progress updates followed by the final matched ID sets.
	FilterTimeline(context.Context, *connect.Request[v1.FilterTimelineRequest], *connect.ServerStream[v1.FilterTimelineResponse]) error
	// Evaluates a timeline and log filtering pipeline synchronously or polls its in-progress status.
	FilterTimelineSync(context.Context, *connect.Request[v1.FilterTimelineSyncRequest]) (*connect.Response[v1.FilterTimelineSyncResponse], error)
	// Cancels an in-progress synchronous timeline filtering task.
	CancelFilterTimelineSync(context.Context, *connect.Request[v1.CancelFilterTimelineSyncRequest]) (*connect.Response[v1.CancelFilterTimelineSyncResponse], error)
	// Computes the Kubernetes architecture graph for a specific timestamp based on the active timeline filter.
	GetArchitectureGraph(context.Context, *connect.Request[v1.GetArchitectureGraphRequest]) (*connect.Response[v1.GetArchitectureGraphResponse], error)
	// Explicitly closes and releases an active Workbench session.
	CloseWorkbench(context.Context, *connect.Request[v1.CloseWorkbenchRequest]) (*connect.Response[v1.CloseWorkbenchResponse], error)
}

WorkbenchServiceHandler is an implementation of the api.v1.WorkbenchService service.

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.