kloakd

package module

Go to main page

Versions in this module

v0

v0.6.0

Nov 2, 2026

Changes in this version

+ const CrawlPagesDefaultLimit

+ const CrawlPagesMaxLimit

+ var ErrInvalidPagesLimit = errors.New("invalid crawl pages limit")

type ConcurrencyLimitError

+ ActiveRequests int

type CrawlOptions

+ IncludeGrouping bool

type CrawlOrchestratorOptions

+ ExtractItemSelector string

type CrawlPage

+ Records []map[string]interface{}

+ type CrawlPagesOptions struct

+ Cursor string

+ IncludeGrouping bool

+ Limit int

+ type CrawlPagesResult struct

+ CrawlID string

+ NextCursor string

+ Nodes []PageNode

+ Raw map[string]interface{}

+ Total int

type ExtractHTMLOptions

+ ItemSelector string

type ExtractOptions

+ ItemSelector string

type PageNode

+ CrawlParentURL *string

+ IsGrouping bool

type WebgrphNamespace

+ func (w *WebgrphNamespace) ListCrawlPages(ctx context.Context, crawlID string, opts *CrawlPagesOptions) (*CrawlPagesResult, error)

v0.5.0

Oct 28, 2026

Changes in this version

+ type APIDataOptions struct

+ EndpointHash string

type ChatEvent

+ Actions []map[string]interface{}

+ Content *string

+ Err error

+ Raw map[string]interface{}

+ Timestamp string

+ Type string

type ChatTurn

+ Actions []map[string]interface{}

+ Errors []ChatEvent

+ Events []ChatEvent

+ Interpretation map[string]interface{}

+ OK bool

+ Results []map[string]interface{}

+ Warnings []string

type Client

+ func (c *Client) GetHandoff(ctx context.Context, jobID string) (*HandoffJob, error)

+ func (c *Client) WaitForHandoff(ctx context.Context, jobID string, poll *PollOptions) (map[string]interface{}, error)

+ type ConcurrencyLimitError struct

+ ActiveCrawls int

+ ConcurrentLimit int

+ TestKeyID string

+ Tier string

+ func (e *ConcurrencyLimitError) Error() string

type CrawlOptions

+ Budget map[string]interface{}

+ Scope map[string]interface{}

type CrawlOrchestratorOptions

+ Budget map[string]interface{}

+ CaptureMode string

+ ExtractFields []SchemaField

+ Scope map[string]interface{}

type CrawlPage

+ ExtractionError *string

type CrawlProgressEvent

+ Err error

type CrawlStreamOptions

+ Budget map[string]interface{}

+ CaptureMode string

+ IncludeExternalLinks bool

+ Scope map[string]interface{}

+ type ExportOptions struct

+ MaxBytes int

+ ResourceIDs []string

+ type ExtractAllAPIDataOptions struct

+ EndpointHash string

+ MaxRecords int

type ExtractHTMLOptions

+ Fields []SchemaField

type ExtractOptions

+ Fields []SchemaField

type ExtractionResult

+ AuthRequired bool

+ DiscoveryID *string

type FetchEvent

+ ArtifactID *string

+ Err error

+ Error *string

+ JobID string

+ Pipeline *PipelineEvent

+ Raw map[string]interface{}

+ Status string

+ TierUsed *int

type FetchResult

+ AuthRequired bool

+ DiscoveryID *string

type FetchyrNamespace

+ func (f *FetchyrNamespace) ResumeAuthChainCredentials(ctx context.Context, discoveryID, username, password string, remember bool) (map[string]interface{}, error)

+ func (f *FetchyrNamespace) ResumeAuthChainMFA(ctx context.Context, discoveryID, mfaCode string) (map[string]interface{}, error)

+ type FindingsOptions struct

+ FindingKind string

+ Limit int

+ Offset int

+ type ForbiddenError struct

+ func (e *ForbiddenError) Error() string

+ type GraphOptions struct

+ EdgeKind string

+ Limit int

+ MaxDepth int

+ ResourceType string

+ type HandoffJob struct

+ Error *string

+ JobID string

+ Kind string

+ Raw map[string]interface{}

+ Result map[string]interface{}

+ Status string

+ type ListContentOptions struct

+ Page int

+ PageSize int

+ Search string

+ type ListJobsOptions struct

+ Limit int

+ Page int

+ StatusFilter string

+ type ListPage struct

+ Limit int

+ Offset int

+ type ListScrapersOptions struct

+ IsTemplate *bool

+ Page int

+ PageSize int

+ type ListWorkflowsOptions struct

+ Page int

+ PageSize int

+ type MultiSiteWorkflowOptions struct

+ Dependencies []SiteDependency

+ Description string

+ GlobalConfig map[string]interface{}

+ type NexusReasonResult struct

+ Confidence float64

+ ReasoningID *string

+ Results []string

+ Success bool

type NotEntitledError

+ CurrentTier string

+ Feature string

+ RequiredTier string

+ func (e *NotEntitledError) As(target interface{}) bool

+ type PipelineEvent struct

+ DurationMs *float64

+ Err error

+ Error map[string]interface{}

+ EventType string

+ Message string

+ Metadata map[string]interface{}

+ Phase string

+ PipelineID string

+ ProgressPct *float64

+ Raw map[string]interface{}

+ Sequence int

+ StageID string

+ Status string

+ SubStatus string

+ Timestamp string

type QuotaExceededError

+ Tier string

type RateLimitError

+ QuotaExhausted bool

+ QuotaLimit int

+ QuotaUsed int

+ UpgradeURL string

+ type ReaderViewOptions struct

+ CrawlID string

+ SessionArtifactID string

+ type ReasonOptions struct

+ PerceptionID string

+ TimeoutSecs float64

+ type ResourceListOptions struct

+ Limit int

+ Offset int

+ ResourceType string

+ type ResourcesOptions struct

+ Limit int

+ Offset int

+ ResourceType string

+ SiteID string

+ type SchemaField struct

+ Attribute string

+ Name string

+ Selector string

+ Type string

+ type SiteDependency struct

+ Condition string

+ DataRequirements []string

+ DependencySite string

+ DependencyType string

+ DependentSite string

+ TimeoutSecs int

+ type SiteSearchOptions struct

+ Limit int

+ MimeType string

+ Offset int

type SkanyrNamespace

+ func (s *SkanyrNamespace) Diff(ctx context.Context, siteID, snapshotA, snapshotB string) (map[string]interface{}, error)

+ func (s *SkanyrNamespace) ExportSite(ctx context.Context, siteID string, opts *ExportOptions) ([]byte, error)

+ func (s *SkanyrNamespace) GetExtractionStructure(ctx context.Context, contentHash string) (map[string]interface{}, error)

+ func (s *SkanyrNamespace) GetExtractionText(ctx context.Context, contentHash string) (string, error)

+ func (s *SkanyrNamespace) GetFindings(ctx context.Context, siteID string, opts *FindingsOptions) ([]map[string]interface{}, error)

+ func (s *SkanyrNamespace) GetGraph(ctx context.Context, siteID string, opts *GraphOptions) (map[string]interface{}, error)

+ func (s *SkanyrNamespace) GetGraphStats(ctx context.Context, siteID string) (map[string]interface{}, error)

+ func (s *SkanyrNamespace) GetResource(ctx context.Context, resourceID string) (map[string]interface{}, error)

+ func (s *SkanyrNamespace) GetSubgraph(ctx context.Context, siteID, resourceID string, hops int) (map[string]interface{}, error)

+ func (s *SkanyrNamespace) GetTechnologies(ctx context.Context, siteID string) ([]map[string]interface{}, error)

+ func (s *SkanyrNamespace) GetTechnologyEvidence(ctx context.Context, siteID, subject string, opts *TechnologyEvidenceOptions) (map[string]interface{}, error)

+ func (s *SkanyrNamespace) GetTimeline(ctx context.Context, siteID string, limit int) (map[string]interface{}, error)

+ func (s *SkanyrNamespace) GetTimelineSnapshot(ctx context.Context, siteID, snapshotID string) (map[string]interface{}, error)

+ func (s *SkanyrNamespace) ListResources(ctx context.Context, opts *ResourcesOptions) ([]map[string]interface{}, error)

+ func (s *SkanyrNamespace) ListSnapshots(ctx context.Context, siteID string, limit int) (map[string]interface{}, error)

+ func (s *SkanyrNamespace) SearchSite(ctx context.Context, siteID, query string, opts *SiteSearchOptions) (map[string]interface{}, error)

+ func (s *SkanyrNamespace) UpdateSite(ctx context.Context, siteID, policy string) (map[string]interface{}, error)

+ type TechnologyEvidenceOptions struct

+ Detector string

+ Limit int

+ Offset int

v0.4.0

Oct 28, 2026

Changes in this version

+ const DefaultPollInterval

+ const DefaultPollTimeout

type ApiError

+ JobID string

type Config

+ PollInterval time.Duration

+ PollTimeout time.Duration

+ type PollOptions struct

+ Interval time.Duration

+ Timeout time.Duration

v0.3.0

Oct 27, 2026

Changes in this version

+ const DefaultCrawlPollInterval

+ const DefaultCrawlPollTimeout

+ const DefaultFetchPollInterval

+ const DefaultFetchPollTimeout

+ type BillingUnavailableError struct

+ RetryAfter int

+ func (e *BillingUnavailableError) Error() string

+ type CheckDuplicateOptions struct

+ ContentHash string

+ SessionID string

type Client

+ func (c *Client) Crawl(ctx context.Context, targetURL string, opts *CrawlOrchestratorOptions) (*SiteCrawlResult, error)

+ func (c *Client) CrawlStream(ctx context.Context, targetURL string, opts *CrawlOrchestratorOptions) (<-chan CrawlProgressEvent, error)

type CrawlOptions

+ CaptureMode string

+ FastMode bool

+ PollInterval time.Duration

+ PollTimeout time.Duration

+ type CrawlOrchestratorOptions struct

+ ExtractSchema map[string]string

+ IncludeExternalLinks bool

+ MaxDepth int

+ MaxPages int

+ OutputFormat string

+ SessionArtifactID string

+ type CrawlPage struct

+ ArtifactID *string

+ Error *string

+ HTML *string

+ StatusCode int

+ StructuredData map[string]interface{}

+ Success bool

+ TierUsed int

+ URL string

+ func (p CrawlPage) Ok() bool

+ type CrawlProgressEvent struct

+ Error *string

+ Metadata map[string]interface{}

+ Page *int

+ Success *bool

+ Total *int

+ Type string

+ URL *string

type CrawlResult

+ Status string

+ type CreateWorkflowOptions struct

+ Description string

+ WorkflowType string

type DeduplicationResult

+ IsDuplicate bool

+ MatchType *string

+ OriginalURL *string

+ SimilarityScore float64

type EvadrNamespace

+ func (e *EvadrNamespace) JobEvents(ctx context.Context, jobID string) (<-chan map[string]interface{}, error)

+ func (e *EvadrNamespace) Profile(ctx context.Context, targetURL string) (map[string]interface{}, error)

+ type ExecuteWorkflowOptions struct

+ InputData map[string]interface{}

+ SessionArtifactID string

type ExecutionResult

+ Result map[string]interface{}

type ExtractHTMLOptions

+ SchemaSpec map[string]interface{}

+ type ExtractOptions struct

+ ApiMapArtifactID string

+ FetchArtifactID string

+ Level string

+ Options map[string]interface{}

+ SchemaSpec map[string]interface{}

+ SessionArtifactID string

type FetchAsyncOptions

+ SessionArtifactID string

type FetchOptions

+ PollInterval time.Duration

+ PollTimeout time.Duration

type FetchStreamOptions

+ SessionArtifactID string

+ UseProxy bool

type FetchyrNamespace

+ func (f *FetchyrNamespace) Authenticate(ctx context.Context, credentialName, targetURL string) (*SessionResult, error)

+ func (f *FetchyrNamespace) CheckDuplicate(ctx context.Context, targetURL string, opts *CheckDuplicateOptions) (*DeduplicationResult, error)

+ func (f *FetchyrNamespace) DiscoverAuthChain(ctx context.Context, targetURL string) (map[string]interface{}, error)

+ func (f *FetchyrNamespace) GetAuthChainStatus(ctx context.Context, discoveryID string) (map[string]interface{}, error)

+ func (f *FetchyrNamespace) ResolveMFA(ctx context.Context, challengeID, resolution string) (map[string]interface{}, error)

+ func (f *FetchyrNamespace) ResumeExecution(ctx context.Context, workflowID, executionID string, ...) (*ExecutionResult, error)

type FormDetectionResult

+ Fields []map[string]interface{}

+ FormsFound int

+ LoginFormDetected bool

+ URL string

+ type HandedOff struct

+ JobID string

+ PollURL string

+ Reason string

+ WaitedSeconds float64

type KloakdError

+ Code string

type KolektrNamespace

+ func (k *KolektrNamespace) Extract(ctx context.Context, targetURL string, opts *ExtractOptions) (*ExtractionResult, error)

type MfaDetectionResult

+ Message *string

type NexusAnalyzeResult

+ Confidence float64

+ ReasoningID string

+ URL string

type NexusExecuteResult

+ StrategyID string

type NexusKnowledgeResult

+ Patterns []map[string]interface{}

+ TotalPatterns int

type NexusSynthesisResult

+ Confidence float64

+ Program string

+ Steps []map[string]interface{}

+ StrategyType string

type NexusVerifyResult

+ StrategyID string

+ Verified bool

type PageNode

+ Category string

+ ID string

+ Metadata map[string]interface{}

+ ParentURL *string

+ type PaymentRequiredError struct

+ UpgradeURL string

+ func (e *PaymentRequiredError) Error() string

+ type QuotaExceededError struct

+ GBLimit float64

+ GBUsed float64

+ PurchasedGBBalance float64

+ UpgradeURL string

+ func (e *QuotaExceededError) Error() string

+ type SearchOptions struct

+ Limit int

+ MimeType string

+ Offset int

+ SiteID string

type SessionResult

+ AuthMethod *string

+ TargetDomain *string

+ type SiteCrawlResult struct

+ CrawlArtifactID *string

+ Error *string

+ Pages []CrawlPage

+ PagesFailed int

+ PagesFetched int

+ Success bool

+ TotalPagesDiscovered int

+ URL string

type SkanyrNamespace

+ func (s *SkanyrNamespace) CreateSiteFromCrawl(ctx context.Context, crawlID string) (map[string]interface{}, error)

+ func (s *SkanyrNamespace) DeleteSite(ctx context.Context, siteID string) error

+ func (s *SkanyrNamespace) Extract(ctx context.Context, contentHash, mimeType string, ...) (map[string]interface{}, error)

+ func (s *SkanyrNamespace) GetSite(ctx context.Context, siteID string) (map[string]interface{}, error)

+ func (s *SkanyrNamespace) ListSites(ctx context.Context) (map[string]interface{}, error)

+ func (s *SkanyrNamespace) Search(ctx context.Context, query string, opts *SearchOptions) (map[string]interface{}, error)

+ func (s *SkanyrNamespace) SetSitePolicy(ctx context.Context, siteID, policy string) (map[string]interface{}, error)

+ func (s *SkanyrNamespace) SiteAPIs(ctx context.Context, siteID string) (map[string]interface{}, error)

+ func (s *SkanyrNamespace) SiteResources(ctx context.Context, siteID string) (map[string]interface{}, error)

+ func (s *SkanyrNamespace) Sync(ctx context.Context, siteID string, opts *SyncOptions) (map[string]interface{}, error)

+ type SyncOptions struct

+ Policy string

+ URLs []string

type WebgrphNamespace

+ func (w *WebgrphNamespace) CancelCrawl(ctx context.Context, crawlID string) (map[string]interface{}, error)

+ func (w *WebgrphNamespace) CrawlEvents(ctx context.Context, crawlID string) (<-chan map[string]interface{}, error)

+ func (w *WebgrphNamespace) DeleteSession(ctx context.Context, sessionID string) error

+ func (w *WebgrphNamespace) DetectedAPIs(ctx context.Context, pageURL string) (map[string]interface{}, error)

+ func (w *WebgrphNamespace) EndSession(ctx context.Context, sessionID string) (map[string]interface{}, error)

+ func (w *WebgrphNamespace) GetSession(ctx context.Context, sessionID string) (map[string]interface{}, error)

+ func (w *WebgrphNamespace) ListSessions(ctx context.Context, activeOnly bool) (map[string]interface{}, error)

+ func (w *WebgrphNamespace) ReaderView(ctx context.Context, targetURL, crawlID string) (map[string]interface{}, error)

+ func (w *WebgrphNamespace) SaveSession(ctx context.Context, session map[string]interface{}) (map[string]interface{}, error)

+ func (w *WebgrphNamespace) StartCrawl(ctx context.Context, targetURL string, opts *CrawlOptions) (*CrawlResult, error)

+ func (w *WebgrphNamespace) UpdateSessionJob(ctx context.Context, sessionID, jobID string) (map[string]interface{}, error)

type WorkflowResult

+ Description *string

+ IsActive bool

+ WorkflowType string

v0.2.0

May 13, 2026

Changes in this version

type EvadrNamespace

+ func (e *EvadrNamespace) DeleteProxy(ctx context.Context, name string) error

+ func (e *EvadrNamespace) GetJob(ctx context.Context, jobID string) (map[string]interface{}, error)

+ func (e *EvadrNamespace) GetJobEvents(ctx context.Context, jobID string) (map[string]interface{}, error)

+ func (e *EvadrNamespace) ListProfiles(ctx context.Context) (map[string]interface{}, error)

+ func (e *EvadrNamespace) ListProxies(ctx context.Context) (map[string]interface{}, error)

+ func (e *EvadrNamespace) ListVendors(ctx context.Context) (map[string]interface{}, error)

+ func (e *EvadrNamespace) Scan(ctx context.Context, targetURL string, opts *AnalyzeOptions) (map[string]interface{}, error)

type FetchyrNamespace

+ func (f *FetchyrNamespace) CreateDedupSession(ctx context.Context, config map[string]interface{}) (map[string]interface{}, error)

+ func (f *FetchyrNamespace) CreateMultiSiteWorkflow(ctx context.Context, sites []map[string]interface{}, name string) (map[string]interface{}, error)

+ func (f *FetchyrNamespace) DeleteCredentials(ctx context.Context, name string) error

+ func (f *FetchyrNamespace) DeleteWorkflow(ctx context.Context, workflowID string) error

+ func (f *FetchyrNamespace) FillForm(ctx context.Context, targetURL string, formData map[string]string, ...) (map[string]interface{}, error)

+ func (f *FetchyrNamespace) GetDedupDomainStatistics(ctx context.Context, domain string) (map[string]interface{}, error)

+ func (f *FetchyrNamespace) GetDedupSession(ctx context.Context, sessionID string) (map[string]interface{}, error)

+ func (f *FetchyrNamespace) GetDedupSessionStatistics(ctx context.Context, sessionID string) (map[string]interface{}, error)

+ func (f *FetchyrNamespace) GetMFAChallenge(ctx context.Context, challengeID string) (map[string]interface{}, error)

+ func (f *FetchyrNamespace) GetMFAStatistics(ctx context.Context, domain string) (map[string]interface{}, error)

+ func (f *FetchyrNamespace) GetWorkflow(ctx context.Context, workflowID string) (map[string]interface{}, error)

+ func (f *FetchyrNamespace) GetWorkflowStatistics(ctx context.Context, workflowID string) (map[string]interface{}, error)

+ func (f *FetchyrNamespace) ListCredentials(ctx context.Context) (map[string]interface{}, error)

+ func (f *FetchyrNamespace) ListDedupSessions(ctx context.Context) (map[string]interface{}, error)

+ func (f *FetchyrNamespace) ListMFAChallenges(ctx context.Context) (map[string]interface{}, error)

+ func (f *FetchyrNamespace) ListSessions(ctx context.Context) (map[string]interface{}, error)

+ func (f *FetchyrNamespace) ListWorkflows(ctx context.Context) (map[string]interface{}, error)

+ func (f *FetchyrNamespace) StoreCredentials(ctx context.Context, name string, credentials map[string]interface{}) (map[string]interface{}, error)

+ func (f *FetchyrNamespace) TerminateSession(ctx context.Context, artifactID string) error

+ func (f *FetchyrNamespace) UpdateWorkflow(ctx context.Context, workflowID string, updates map[string]interface{}) (map[string]interface{}, error)

type KolektrNamespace

+ func (k *KolektrNamespace) CreateJob(ctx context.Context, config map[string]interface{}) (map[string]interface{}, error)

+ func (k *KolektrNamespace) CreateScraper(ctx context.Context, config map[string]interface{}) (map[string]interface{}, error)

+ func (k *KolektrNamespace) DeleteContent(ctx context.Context, itemID string) error

+ func (k *KolektrNamespace) DeleteScraper(ctx context.Context, scraperID string) error

+ func (k *KolektrNamespace) ExtractAllAPIData(ctx context.Context, apiEndpoint string) (map[string]interface{}, error)

+ func (k *KolektrNamespace) GetAPIData(ctx context.Context, apiEndpoint string) (map[string]interface{}, error)

+ func (k *KolektrNamespace) GetAPIDataPaginated(ctx context.Context, apiEndpoint string, offset, limit int) (map[string]interface{}, error)

+ func (k *KolektrNamespace) GetContent(ctx context.Context, itemID string) (map[string]interface{}, error)

+ func (k *KolektrNamespace) GetJob(ctx context.Context, jobID string) (map[string]interface{}, error)

+ func (k *KolektrNamespace) GetJobProgress(ctx context.Context, jobID string) (map[string]interface{}, error)

+ func (k *KolektrNamespace) GetJobProgressEvents(ctx context.Context, jobID string) (map[string]interface{}, error)

+ func (k *KolektrNamespace) GetJobProgressLatest(ctx context.Context, jobID string) (map[string]interface{}, error)

+ func (k *KolektrNamespace) GetJobProgressSummary(ctx context.Context, jobID string) (map[string]interface{}, error)

+ func (k *KolektrNamespace) GetJobStatus(ctx context.Context, jobID string) (map[string]interface{}, error)

+ func (k *KolektrNamespace) GetPipelineEvents(ctx context.Context, pipelineID string) (map[string]interface{}, error)

+ func (k *KolektrNamespace) GetPipelineStream(ctx context.Context, pipelineID string) (map[string]interface{}, error)

+ func (k *KolektrNamespace) GetProgressPhase(ctx context.Context, phaseName string) (map[string]interface{}, error)

+ func (k *KolektrNamespace) GetProgressPhaseSteps(ctx context.Context, phaseName string) (map[string]interface{}, error)

+ func (k *KolektrNamespace) GetProgressSummary(ctx context.Context) (map[string]interface{}, error)

+ func (k *KolektrNamespace) GetScraper(ctx context.Context, scraperID string) (map[string]interface{}, error)

+ func (k *KolektrNamespace) ListContent(ctx context.Context) (map[string]interface{}, error)

+ func (k *KolektrNamespace) ListJobs(ctx context.Context) (map[string]interface{}, error)

+ func (k *KolektrNamespace) ListProgressPhases(ctx context.Context) (map[string]interface{}, error)

+ func (k *KolektrNamespace) ListScrapers(ctx context.Context) (map[string]interface{}, error)

+ func (k *KolektrNamespace) UpdateScraper(ctx context.Context, scraperID string, updates map[string]interface{}) (map[string]interface{}, error)

type NexusNamespace

+ func (n *NexusNamespace) CleanupCache(ctx context.Context) (map[string]interface{}, error)

+ func (n *NexusNamespace) CreatePreference(ctx context.Context, preference map[string]interface{}) (map[string]interface{}, error)

+ func (n *NexusNamespace) DeletePreference(ctx context.Context, preferenceID string) error

+ func (n *NexusNamespace) DisableHook(ctx context.Context, hookName string) (map[string]interface{}, error)

+ func (n *NexusNamespace) EnableHook(ctx context.Context, hookName string) (map[string]interface{}, error)

+ func (n *NexusNamespace) GetCacheStatistics(ctx context.Context) (map[string]interface{}, error)

+ func (n *NexusNamespace) GetHooksStatus(ctx context.Context) (map[string]interface{}, error)

+ func (n *NexusNamespace) GetPreferences(ctx context.Context, userID string) (map[string]interface{}, error)

+ func (n *NexusNamespace) GetRecommendationStatistics(ctx context.Context) (map[string]interface{}, error)

+ func (n *NexusNamespace) InvalidateCache(ctx context.Context) (map[string]interface{}, error)

+ func (n *NexusNamespace) ListRecommendationApplications(ctx context.Context) (map[string]interface{}, error)

+ func (n *NexusNamespace) Reason(ctx context.Context, context_ map[string]interface{}) (map[string]interface{}, error)

+ func (n *NexusNamespace) RecommendAnalyze(ctx context.Context, data map[string]interface{}) (map[string]interface{}, error)

+ func (n *NexusNamespace) UpdatePreference(ctx context.Context, preferenceID string, data map[string]interface{}) (map[string]interface{}, error)

type SkanyrNamespace

+ func (s *SkanyrNamespace) AnalyzeBundle(ctx context.Context, targetURL string) (map[string]interface{}, error)

+ func (s *SkanyrNamespace) DeleteSession(ctx context.Context, sessionID string) error

+ func (s *SkanyrNamespace) DetectedAPIs(ctx context.Context, pageURL string) (map[string]interface{}, error)

+ func (s *SkanyrNamespace) DiscoverPageLive(ctx context.Context, targetURL string) (map[string]interface{}, error)

+ func (s *SkanyrNamespace) EndSession(ctx context.Context, sessionID string) (map[string]interface{}, error)

+ func (s *SkanyrNamespace) ExpandNode(ctx context.Context, nodeID string) (map[string]interface{}, error)

+ func (s *SkanyrNamespace) GetDiscovery(ctx context.Context, discoveryID string) (map[string]interface{}, error)

+ func (s *SkanyrNamespace) GetDiscoveryEvents(ctx context.Context, discoveryID string) (map[string]interface{}, error)

+ func (s *SkanyrNamespace) GetSession(ctx context.Context, sessionID string) (map[string]interface{}, error)

+ func (s *SkanyrNamespace) Health(ctx context.Context) (map[string]interface{}, error)

+ func (s *SkanyrNamespace) Hierarchy(ctx context.Context, targetURL string) (map[string]interface{}, error)

+ func (s *SkanyrNamespace) ListSessions(ctx context.Context) (map[string]interface{}, error)

+ func (s *SkanyrNamespace) ReaderView(ctx context.Context, targetURL string) (map[string]interface{}, error)

+ func (s *SkanyrNamespace) Retry(ctx context.Context, discoveryID string, overrides map[string]interface{}) (map[string]interface{}, error)

+ func (s *SkanyrNamespace) SaveSession(ctx context.Context, config map[string]interface{}) (map[string]interface{}, error)

+ func (s *SkanyrNamespace) UpdateSessionJob(ctx context.Context, sessionID, jobID string) (map[string]interface{}, error)

type WebgrphNamespace

+ func (w *WebgrphNamespace) GetCrawlEvents(ctx context.Context, crawlID string) (map[string]interface{}, error)

+ func (w *WebgrphNamespace) GetCrawlPages(ctx context.Context, crawlID string) (map[string]interface{}, error)

+ func (w *WebgrphNamespace) GetCrawlStatus(ctx context.Context, crawlID string) (map[string]interface{}, error)

+ func (w *WebgrphNamespace) GetDashboardSummary(ctx context.Context) (map[string]interface{}, error)

+ func (w *WebgrphNamespace) GetDiscoveryPatterns(ctx context.Context) (map[string]interface{}, error)

+ func (w *WebgrphNamespace) GetEfficiencyMetrics(ctx context.Context) (map[string]interface{}, error)

+ func (w *WebgrphNamespace) GetErrorSummary(ctx context.Context) (map[string]interface{}, error)

+ func (w *WebgrphNamespace) GetJobTrends(ctx context.Context) (map[string]interface{}, error)

+ func (w *WebgrphNamespace) GetSiteMappingTrends(ctx context.Context) (map[string]interface{}, error)

+ func (w *WebgrphNamespace) GetUserBehaviorInsights(ctx context.Context) (map[string]interface{}, error)

v0.1.2

Apr 10, 2026

Changes in this version

+ type AnalyzeOptions struct

+ BodySnippet string

+ Headers map[string]string

+ StatusCode int

+ type AnalyzeResult struct

+ Blocked bool

+ Confidence float64

+ RecommendedActions []string

+ Vendor *string

+ type ApiEndpoint struct

+ ApiType string

+ Confidence float64

+ Method string

+ Parameters map[string]interface{}

+ URL string

+ type ApiError struct

+ func (e *ApiError) Error() string

+ type AuthenticationError struct

+ func (e *AuthenticationError) Error() string

+ type ChatEvent struct

+ Data map[string]interface{}

+ Event string

+ type ChatTurn struct

+ ClarificationNeeded *string

+ Confidence float64

+ Entities map[string]interface{}

+ Intent string

+ RequiresAction bool

+ Response string

+ SessionID string

+ Tier int

+ type Client struct

+ Evadr *EvadrNamespace

+ Fetchyr *FetchyrNamespace

+ Kolektr *KolektrNamespace

+ Nexus *NexusNamespace

+ Parlyr *ParlyrNamespace

+ Skanyr *SkanyrNamespace

+ Webgrph *WebgrphNamespace

+ func MustNew(cfg Config) *Client

+ func New(cfg Config) (*Client, error)

+ type Config struct

+ APIKey string

+ BaseURL string

+ HTTPClient *http.Client

+ MaxRetries int

+ OrganizationID string

+ Timeout time.Duration

+ type CrawlEvent struct

+ Depth *int

+ Metadata map[string]interface{}

+ PagesFound *int

+ Type string

+ URL *string

+ type CrawlOptions struct

+ IncludeExternalLinks bool

+ Limit int

+ MaxDepth int

+ MaxPages int

+ Offset int

+ SessionArtifactID string

+ type CrawlResult struct

+ ArtifactID *string

+ CrawlID string

+ Error *string

+ HasMore bool

+ MaxDepthReached int

+ Pages []PageNode

+ Success bool

+ Total int

+ TotalPages int

+ URL string

+ type CrawlStreamOptions struct

+ MaxDepth int

+ MaxPages int

+ SessionArtifactID string

+ type DeduplicationResult struct

+ DuplicateCount int

+ Error *string

+ TotalInput int

+ UniqueRecords []map[string]interface{}

+ type DiscoverEvent struct

+ ApiType *string

+ EndpointURL *string

+ Metadata map[string]interface{}

+ Type string

+ type DiscoverOptions struct

+ Limit int

+ MaxRequests int

+ Offset int

+ SessionArtifactID string

+ SiteHierarchyArtifactID string

+ type DiscoverResult struct

+ ArtifactID *string

+ DiscoveryID string

+ Endpoints []ApiEndpoint

+ Error *string

+ HasMore bool

+ Success bool

+ Total int

+ TotalEndpoints int

+ URL string

+ type DiscoverStreamOptions struct

+ MaxRequests int

+ SiteHierarchyArtifactID string

+ type EvadrNamespace struct

+ func (e *EvadrNamespace) Analyze(ctx context.Context, targetURL string, opts *AnalyzeOptions) (*AnalyzeResult, error)

+ func (e *EvadrNamespace) Fetch(ctx context.Context, targetURL string, opts *FetchOptions) (*FetchResult, error)

+ func (e *EvadrNamespace) FetchAsync(ctx context.Context, targetURL string, opts *FetchAsyncOptions) (string, error)

+ func (e *EvadrNamespace) FetchStream(ctx context.Context, targetURL string, opts *FetchStreamOptions) (<-chan FetchEvent, error)

+ func (e *EvadrNamespace) StoreProxy(ctx context.Context, name, proxyURL string) error

+ type ExecutionResult struct

+ CompletedAt *string

+ Error *string

+ ExecutionID string

+ Records []map[string]interface{}

+ StartedAt *string

+ Status string

+ WorkflowID string

+ type ExtractHTMLOptions struct

+ Schema map[string]interface{}

+ type ExtractionResult struct

+ ArtifactID *string

+ Error *string

+ HasMore bool

+ JobID *string

+ Method string

+ PagesScraped int

+ Records []map[string]interface{}

+ Success bool

+ Total int

+ TotalRecords int

+ URL string

+ type FetchAsyncOptions struct

+ ForceBrowser bool

+ UseProxy bool

+ WebhookURL string

+ type FetchEvent struct

+ Metadata map[string]interface{}

+ Tier *int

+ Type string

+ Vendor *string

+ type FetchOptions struct

+ ForceBrowser bool

+ SessionArtifactID string

+ UseProxy bool

+ type FetchResult struct

+ AntiBotBypassed bool

+ ArtifactID *string

+ Error *string

+ HTML *string

+ StatusCode int

+ Success bool

+ TierUsed int

+ URL string

+ VendorDetected *string

+ type FetchStreamOptions struct

+ ForceBrowser bool

+ type FetchyrFetchOptions struct

+ ExtractHTML bool

+ WaitForSelector string

+ type FetchyrNamespace struct

+ func (f *FetchyrNamespace) CheckDuplicates(ctx context.Context, records []map[string]interface{}, domain string) (*DeduplicationResult, error)

+ func (f *FetchyrNamespace) CreateWorkflow(ctx context.Context, name string, steps []map[string]interface{}, ...) (*WorkflowResult, error)

+ func (f *FetchyrNamespace) DetectForms(ctx context.Context, targetURL string, sessionArtifactID string) (*FormDetectionResult, error)

+ func (f *FetchyrNamespace) DetectMFA(ctx context.Context, targetURL string, sessionArtifactID string) (*MfaDetectionResult, error)

+ func (f *FetchyrNamespace) ExecuteWorkflow(ctx context.Context, workflowID string) (*ExecutionResult, error)

+ func (f *FetchyrNamespace) Fetch(ctx context.Context, targetURL, sessionArtifactID string, ...) (*FetchyrResult, error)

+ func (f *FetchyrNamespace) GetExecution(ctx context.Context, workflowID, executionID string) (*ExecutionResult, error)

+ func (f *FetchyrNamespace) Login(ctx context.Context, ...) (*SessionResult, error)

+ func (f *FetchyrNamespace) SubmitMFA(ctx context.Context, challengeID, code string) (*MfaResult, error)

+ type FetchyrResult struct

+ ArtifactID *string

+ Error *string

+ HTML *string

+ SessionArtifactID string

+ StatusCode int

+ Success bool

+ URL string

+ type FormDetectionResult struct

+ Error *string

+ Forms []map[string]interface{}

+ TotalForms int

+ type KloakdError struct

+ Message string

+ StatusCode int

+ func (e *KloakdError) Error() string

+ type KolektrNamespace struct

+ func (k *KolektrNamespace) ExtractHTML(ctx context.Context, html, targetURL string, opts *ExtractHTMLOptions) (*ExtractionResult, error)

+ func (k *KolektrNamespace) Page(ctx context.Context, targetURL string, opts *PageOptions) (*ExtractionResult, error)

+ func (k *KolektrNamespace) PageAll(ctx context.Context, targetURL string, opts *PageOptions) ([]map[string]interface{}, error)

+ type LoginOptions struct

+ SubmitSelector string

+ SuccessURLContains string

+ type MfaDetectionResult struct

+ ChallengeID *string

+ Error *string

+ MfaDetected bool

+ MfaType *string

+ type MfaResult struct

+ Error *string

+ SessionArtifactID *string

+ Success bool

+ type NexusAnalyzeOptions struct

+ Constraints map[string]interface{}

+ HTML string

+ type NexusAnalyzeResult struct

+ ArtifactID *string

+ ComplexityLevel string

+ DurationMs int

+ Error *string

+ PageType string

+ PerceptionID string

+ Strategy map[string]interface{}

+ type NexusExecuteResult struct

+ ArtifactID *string

+ DurationMs int

+ Error *string

+ ExecutionResultID string

+ Records []map[string]interface{}

+ Success bool

+ type NexusKnowledgeResult struct

+ DurationMs int

+ Error *string

+ LearnedConcepts []map[string]interface{}

+ LearnedPatterns []map[string]interface{}

+ type NexusNamespace struct

+ func (n *NexusNamespace) Analyze(ctx context.Context, targetURL string, opts *NexusAnalyzeOptions) (*NexusAnalyzeResult, error)

+ func (n *NexusNamespace) Execute(ctx context.Context, strategyID, targetURL string) (*NexusExecuteResult, error)

+ func (n *NexusNamespace) Knowledge(ctx context.Context, executionResultID string) (*NexusKnowledgeResult, error)

+ func (n *NexusNamespace) Synthesize(ctx context.Context, perceptionID string, opts *NexusSynthesizeOptions) (*NexusSynthesisResult, error)

+ func (n *NexusNamespace) Verify(ctx context.Context, strategyID string) (*NexusVerifyResult, error)

+ type NexusSynthesisResult struct

+ ArtifactID *string

+ Error *string

+ GeneratedCode string

+ StrategyID string

+ StrategyName string

+ SynthesisTimeMs int

+ type NexusSynthesizeOptions struct

+ Strategy string

+ Timeout int

+ type NexusVerifyResult struct

+ DurationMs int

+ Error *string

+ IsSafe bool

+ RiskScore float64

+ SafetyScore float64

+ VerificationResultID string

+ Violations []string

+ type NotEntitledError struct

+ Module string

+ UpgradeURL string

+ func (e *NotEntitledError) Error() string

+ type PageNode struct

+ Children []string

+ Depth int

+ StatusCode *int

+ Title *string

+ URL string

+ type PageOptions struct

+ ApiMapArtifactID string

+ FetchArtifactID string

+ Limit int

+ Offset int

+ Schema map[string]interface{}

+ SessionArtifactID string

+ type ParlyrNamespace struct

+ func (p *ParlyrNamespace) Chat(ctx context.Context, sessionID, message string) (*ChatTurn, error)

+ func (p *ParlyrNamespace) ChatStream(ctx context.Context, sessionID, message string) (<-chan ChatEvent, error)

+ func (p *ParlyrNamespace) DeleteSession(ctx context.Context, sessionID string) error

+ func (p *ParlyrNamespace) Parse(ctx context.Context, message string, opts *ParseOptions) (*ParseResult, error)

+ type ParseOptions struct

+ SessionID string

+ type ParseResult struct

+ ClarificationNeeded *string

+ Confidence float64

+ DetectedURL *string

+ Entities map[string]interface{}

+ Intent string

+ Reasoning *string

+ RequiresAction bool

+ Source string

+ Tier int

+ type RateLimitError struct

+ ResetAt string

+ RetryAfter int

+ func (e *RateLimitError) Error() string

+ type SessionResult struct

+ ArtifactID *string

+ Error *string

+ ScreenshotURL *string

+ SessionID string

+ Success bool

+ URL string

+ type SkanyrNamespace struct

+ func (s *SkanyrNamespace) Discover(ctx context.Context, targetURL string, opts *DiscoverOptions) (*DiscoverResult, error)

+ func (s *SkanyrNamespace) DiscoverAll(ctx context.Context, targetURL string, opts *DiscoverOptions) ([]ApiEndpoint, error)

+ func (s *SkanyrNamespace) DiscoverStream(ctx context.Context, targetURL string, opts *DiscoverStreamOptions) (<-chan DiscoverEvent, error)

+ func (s *SkanyrNamespace) GetApiMap(ctx context.Context, artifactID string) (map[string]interface{}, error)

+ func (s *SkanyrNamespace) GetJob(ctx context.Context, jobID string) (map[string]interface{}, error)

+ type UpstreamError struct

+ func (e *UpstreamError) Error() string

+ type WebgrphNamespace struct

+ func (w *WebgrphNamespace) Crawl(ctx context.Context, targetURL string, opts *CrawlOptions) (*CrawlResult, error)

+ func (w *WebgrphNamespace) CrawlAll(ctx context.Context, targetURL string, opts *CrawlOptions) ([]PageNode, error)

+ func (w *WebgrphNamespace) CrawlStream(ctx context.Context, targetURL string, opts *CrawlStreamOptions) (<-chan CrawlEvent, error)

+ func (w *WebgrphNamespace) GetHierarchy(ctx context.Context, artifactID string) (map[string]interface{}, error)

+ func (w *WebgrphNamespace) GetJob(ctx context.Context, jobID string) (map[string]interface{}, error)

+ type WorkflowResult struct

+ CreatedAt string

+ Error *string

+ Name string

+ Steps []map[string]interface{}

+ URL *string

+ WorkflowID string

v0.1.1

Apr 10, 2026

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL