kloakd

package module
v0.2.0 Latest Latest
Warning

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

 Go to latest Published: May 13, 2026 License: MIT Imports: 12 Imported by: 0

README

kloakd-go

Official Go SDK for the KLOAKD API — the anti-bot intelligence platform.

Requirements

  • Go 1.21+
  • KLOAKD API key and organization ID

Installation

go get github.com/kloakd/kloakd-go

Quickstart

package main

import (
    "context"
    "fmt"
    "log"

    kloakd "github.com/kloakd/kloakd-go"
)

func main() {
    client, err := kloakd.New(kloakd.Config{
        APIKey:         "sk-live-...",
        OrganizationID: "your-org-uuid",
    })
    if err != nil {
        log.Fatal(err)
    }

    ctx := context.Background()

    // Anti-bot fetch
    fetch, err := client.Evadr.Fetch(ctx, "https://books.toscrape.com", nil)
    if err != nil {
        log.Fatal(err)
    }
    fmt.Printf("Fetched via tier %d\n", fetch.TierUsed)

    // Site crawl (reuse fetch artifact)
    crawl, err := client.Webgrph.Crawl(ctx, "https://books.toscrape.com", &kloakd.CrawlOptions{
        MaxDepth: 2,
        MaxPages: 50,
    })
    fmt.Printf("Found %d pages\n", crawl.TotalPages)

    // Extract structured data
    data, err := client.Kolektr.Page(ctx, "https://books.toscrape.com", &kloakd.PageOptions{
        Schema: map[string]interface{}{
            "title": "css:h3 a",
            "price": "css:p.price_color",
        },
    })
    fmt.Printf("Extracted %d records\n", data.TotalRecords)
}

Configuration

client, err := kloakd.New(kloakd.Config{
    APIKey:         "sk-live-...",   // required
    OrganizationID: "org-uuid",      // required
    BaseURL:        "https://api.kloakd.dev", // optional, default shown
    Timeout:        30 * time.Second,         // optional, default 30s
    MaxRetries:     3,                        // optional, default 3
    HTTPClient:     customHTTPClient,         // optional, for testing/proxies
})

Modules

client.Evadr — Anti-Bot Intelligence
// Fetch a URL through anti-bot bypass
result, err := client.Evadr.Fetch(ctx, url, nil)

// Async job
jobID, err := client.Evadr.FetchAsync(ctx, url, nil)

// SSE streaming
ch, err := client.Evadr.FetchStream(ctx, url, nil)
for event := range ch {
    fmt.Println(event.Type, event.Tier)
}

// Analyze anti-bot defenses
analysis, err := client.Evadr.Analyze(ctx, url, nil)
client.Webgrph — Site Mapping
// Crawl site hierarchy
crawl, err := client.Webgrph.Crawl(ctx, url, &kloakd.CrawlOptions{MaxDepth: 3, MaxPages: 100})

// Auto-paginate all pages
pages, err := client.Webgrph.CrawlAll(ctx, url, nil)

// SSE streaming
ch, err := client.Webgrph.CrawlStream(ctx, url, nil)
for event := range ch {
    fmt.Println(event.Type, event.URL)
}
client.Skanyr — API Discovery
result, err := client.Skanyr.Discover(ctx, url, nil)
endpoints, err := client.Skanyr.DiscoverAll(ctx, url, nil)

ch, err := client.Skanyr.DiscoverStream(ctx, url, nil)
for event := range ch {
    fmt.Println(event.Type, event.EndpointURL)
}
client.Nexus — Strategy Engine
perception, _ := client.Nexus.Analyze(ctx, url, nil)
strategy, _   := client.Nexus.Synthesize(ctx, perception.PerceptionID, nil)
verified, _   := client.Nexus.Verify(ctx, strategy.StrategyID)
result, _     := client.Nexus.Execute(ctx, strategy.StrategyID, url)
knowledge, _  := client.Nexus.Knowledge(ctx, result.ExecutionResultID)
client.Parlyr — Conversational NLP
parse, err := client.Parlyr.Parse(ctx, "scrape example.com", nil)

// Blocking chat (collects SSE internally)
turn, err := client.Parlyr.Chat(ctx, sessionID, "scrape example.com")

// SSE streaming
ch, err := client.Parlyr.ChatStream(ctx, sessionID, message)
for event := range ch {
    fmt.Println(event.Event, event.Data)
}
client.Fetchyr — RPA & Authentication
session, err := client.Fetchyr.Login(ctx, loginURL, "#user", "#pass", "u", "p", nil)
page, err    := client.Fetchyr.Fetch(ctx, protectedURL, *session.ArtifactID, nil)
client.Kolektr — Data Extraction
data, err := client.Kolektr.Page(ctx, url, &kloakd.PageOptions{
    Schema: map[string]interface{}{"title": "css:h1", "price": "css:.price"},
})

// Auto-paginate
records, err := client.Kolektr.PageAll(ctx, url, nil)

// From raw HTML
data, err = client.Kolektr.ExtractHTML(ctx, html, url, nil)

Error Handling

import "errors"

result, err := client.Evadr.Fetch(ctx, url, nil)
if err != nil {
    var rlErr *kloakd.RateLimitError
    var authErr *kloakd.AuthenticationError
    switch {
    case errors.As(err, &rlErr):
        time.Sleep(time.Duration(rlErr.RetryAfter) * time.Second)
    case errors.As(err, &authErr):
        log.Fatal("invalid API key")
    default:
        log.Printf("error: %v", err)
    }
}

Error types: KloakdError, AuthenticationError (401), NotEntitledError (403), RateLimitError (429), UpstreamError (502), ApiError (other 4xx/5xx).

Retry Policy

  • Retryable status codes: 429, 500, 502, 503, 504
  • Strategy: exponential backoff — 1s × 2^attempt, capped at 60s
  • 429: respects Retry-After header / retry_after body field
  • Non-retryable: 400, 401, 403, 404
  • Default max retries: 3 (override via Config.MaxRetries)

Running the Quickstart

export KLOAKD_API_KEY=sk-live-...
export KLOAKD_ORG_ID=your-org-uuid
go run ./examples/quickstart/main.go

Running Tests

go test . -v
go test . -cover

License

MIT

Documentation

Overview

Package kloakd provides the Go SDK for the KLOAKD API. Error hierarchy mirrors the design document §6.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AnalyzeOptions 

type AnalyzeOptions struct {
	StatusCode  int
	Headers     map[string]string
	BodySnippet string
}

AnalyzeOptions configures optional parameters for Evadr.Analyze.

type AnalyzeResult 

type AnalyzeResult struct {
	Blocked            bool
	Vendor             *string
	Confidence         float64
	RecommendedActions []string
}

AnalyzeResult is returned by Evadr.Analyze.

type ApiEndpoint 

type ApiEndpoint struct {
	URL        string
	Method     string
	ApiType    string
	Confidence float64
	Parameters map[string]interface{}
}

ApiEndpoint represents a discovered API endpoint.

type ApiError 

type ApiError struct {
	KloakdError
}

ApiError is returned for any other 4xx/5xx response.

func (*ApiError) Error 

func (e *ApiError) Error() string

type AuthenticationError 

type AuthenticationError struct {
	KloakdError
}

AuthenticationError is returned for HTTP 401 — invalid or expired API key.

func (*AuthenticationError) Error 

func (e *AuthenticationError) Error() string

type ChatEvent 

type ChatEvent struct {
	Event string
	Data  map[string]interface{}
}

ChatEvent is yielded by Parlyr.ChatStream.

type ChatTurn 

type ChatTurn struct {
	SessionID           string
	Intent              string
	Confidence          float64
	Tier                int
	Response            string
	Entities            map[string]interface{}
	RequiresAction      bool
	ClarificationNeeded *string
}

ChatTurn is returned by Parlyr.Chat.

type Client 

type Client struct {
	Evadr   *EvadrNamespace
	Webgrph *WebgrphNamespace
	Skanyr  *SkanyrNamespace
	Nexus   *NexusNamespace
	Parlyr  *ParlyrNamespace
	Fetchyr *FetchyrNamespace
	Kolektr *KolektrNamespace
	// contains filtered or unexported fields
}

Client is the KLOAKD SDK client. Create one with New(). 

client := kloakd.New(kloakd.Config{
    APIKey:         "sk-live-...",
    OrganizationID: "your-org-uuid",
})

func MustNew 

func MustNew(cfg Config) *Client

MustNew is like New but panics on configuration error.

func New 

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

New creates a new KLOAKD client with the given configuration. Returns an error if APIKey or OrganizationID are missing.

type Config 

type Config struct {
	// APIKey is the KLOAKD API key (required). Starts with "sk-".
	APIKey string

	// OrganizationID is the UUID of the organization (required).
	OrganizationID string

	// BaseURL overrides the API base URL. Defaults to https://api.kloakd.dev.
	BaseURL string

	// Timeout is the per-request timeout. Defaults to 30s.
	Timeout time.Duration

	// MaxRetries sets the number of retry attempts for retryable errors.
	// 0 means one attempt (no retries). Defaults to 3.
	MaxRetries int

	// HTTPClient allows injecting a custom *http.Client (e.g. for testing).
	HTTPClient *http.Client
}

Config holds all configuration for the KLOAKD client.

type CrawlEvent 

type CrawlEvent struct {
	Type       string
	URL        *string
	Depth      *int
	PagesFound *int
	Metadata   map[string]interface{}
}

CrawlEvent is yielded by Webgrph.CrawlStream.

type CrawlOptions 

type CrawlOptions struct {
	MaxDepth             int
	MaxPages             int
	IncludeExternalLinks bool
	SessionArtifactID    string
	Limit                int
	Offset               int
}

CrawlOptions configures optional parameters for Webgrph.Crawl.

type CrawlResult 

type CrawlResult struct {
	Success         bool
	CrawlID         string
	URL             string
	TotalPages      int
	MaxDepthReached int
	Pages           []PageNode
	HasMore         bool
	Total           int
	ArtifactID      *string
	Error           *string
}

CrawlResult is returned by Webgrph.Crawl.

type CrawlStreamOptions 

type CrawlStreamOptions struct {
	MaxDepth          int
	MaxPages          int
	SessionArtifactID string
}

CrawlStreamOptions configures optional parameters for Webgrph.CrawlStream.

type DeduplicationResult 

type DeduplicationResult struct {
	UniqueRecords  []map[string]interface{}
	DuplicateCount int
	TotalInput     int
	Error          *string
}

DeduplicationResult is returned by Fetchyr.CheckDuplicates.

type DiscoverEvent 

type DiscoverEvent struct {
	Type        string
	EndpointURL *string
	ApiType     *string
	Metadata    map[string]interface{}
}

DiscoverEvent is yielded by Skanyr.DiscoverStream.

type DiscoverOptions 

type DiscoverOptions struct {
	SiteHierarchyArtifactID string
	MaxRequests             int
	SessionArtifactID       string
	Limit                   int
	Offset                  int
}

DiscoverOptions configures optional parameters for Skanyr.Discover.

type DiscoverResult 

type DiscoverResult struct {
	Success        bool
	DiscoveryID    string
	URL            string
	TotalEndpoints int
	Endpoints      []ApiEndpoint
	HasMore        bool
	Total          int
	ArtifactID     *string
	Error          *string
}

DiscoverResult is returned by Skanyr.Discover.

type DiscoverStreamOptions 

type DiscoverStreamOptions struct {
	SiteHierarchyArtifactID string
	MaxRequests             int
}

DiscoverStreamOptions configures optional parameters for Skanyr.DiscoverStream.

type EvadrNamespace 

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

EvadrNamespace exposes the Anti-Bot Intelligence module. Access via client.Evadr.

func (*EvadrNamespace) Analyze 

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

Analyze inspects the anti-bot defenses of the given URL.

func (*EvadrNamespace) DeleteProxy added in v0.2.0 

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

DeleteProxy deletes a stored proxy configuration by name.

func (*EvadrNamespace) Fetch 

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

Fetch performs an anti-bot fetch of the given URL.

func (*EvadrNamespace) FetchAsync 

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

FetchAsync enqueues an anti-bot fetch job and returns the job ID.

func (*EvadrNamespace) FetchStream 

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

FetchStream opens a server-sent events stream for an anti-bot fetch operation. Returns a read-only channel of FetchEvent values. The channel is closed when the stream ends or ctx is cancelled.

func (*EvadrNamespace) GetJob added in v0.2.0 

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

GetJob polls an async fetch job by ID.

func (*EvadrNamespace) GetJobEvents added in v0.2.0 

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

GetJobEvents retrieves SSE events for an async fetch job.

func (*EvadrNamespace) ListProfiles added in v0.2.0 

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

ListProfiles lists available evasion profiles.

func (*EvadrNamespace) ListProxies added in v0.2.0 

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

ListProxies lists stored proxy configurations (names only, no secrets).

func (*EvadrNamespace) ListVendors added in v0.2.0 

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

ListVendors lists all known anti-bot detection vendors.

func (*EvadrNamespace) Scan added in v0.2.0 

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

Scan scans a URL response for anti-bot vendor signatures.

func (*EvadrNamespace) StoreProxy 

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

StoreProxy registers a named proxy in the organization's proxy pool.

type ExecutionResult 

type ExecutionResult struct {
	ExecutionID string
	WorkflowID  string
	Status      string
	StartedAt   *string
	CompletedAt *string
	Records     []map[string]interface{}
	Error       *string
}

ExecutionResult is returned by Fetchyr.ExecuteWorkflow / GetExecution.

type ExtractHTMLOptions 

type ExtractHTMLOptions struct {
	Schema map[string]interface{}
}

ExtractHTMLOptions configures optional parameters for Kolektr.ExtractHTML.

type ExtractionResult 

type ExtractionResult struct {
	Success      bool
	URL          string
	Method       string
	Records      []map[string]interface{}
	TotalRecords int
	PagesScraped int
	HasMore      bool
	Total        int
	ArtifactID   *string
	JobID        *string
	Error        *string
}

ExtractionResult is returned by Kolektr.Page and Kolektr.ExtractHTML.

type FetchAsyncOptions 

type FetchAsyncOptions struct {
	ForceBrowser bool
	UseProxy     bool
	WebhookURL   string
}

FetchAsyncOptions configures optional parameters for Evadr.FetchAsync.

type FetchEvent 

type FetchEvent struct {
	Type     string
	Tier     *int
	Vendor   *string
	Metadata map[string]interface{}
}

FetchEvent is yielded by Evadr.FetchStream.

type FetchOptions 

type FetchOptions struct {
	ForceBrowser      bool
	UseProxy          bool
	SessionArtifactID string
}

FetchOptions configures optional parameters for Evadr.Fetch.

type FetchResult 

type FetchResult struct {
	Success         bool
	URL             string
	StatusCode      int
	TierUsed        int
	HTML            *string
	VendorDetected  *string
	AntiBotBypassed bool
	ArtifactID      *string
	Error           *string
}

FetchResult is returned by Evadr.Fetch.

type FetchStreamOptions 

type FetchStreamOptions struct {
	ForceBrowser bool
}

FetchStreamOptions configures optional parameters for Evadr.FetchStream.

type FetchyrFetchOptions 

type FetchyrFetchOptions struct {
	WaitForSelector string
	ExtractHTML     bool
}

FetchyrFetchOptions configures optional parameters for Fetchyr.Fetch.

type FetchyrNamespace 

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

FetchyrNamespace exposes the RPA & Authentication module. Access via client.Fetchyr.

func (*FetchyrNamespace) CheckDuplicates 

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

CheckDuplicates deduplicates a list of records, optionally scoped to a domain.

func (*FetchyrNamespace) CreateDedupSession added in v0.2.0 

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

CreateDedupSession creates a deduplication session.

func (*FetchyrNamespace) CreateMultiSiteWorkflow added in v0.2.0 

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

CreateMultiSiteWorkflow creates a multi-site orchestration workflow.

func (*FetchyrNamespace) CreateWorkflow 

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

CreateWorkflow creates a new RPA workflow.

func (*FetchyrNamespace) DeleteCredentials added in v0.2.0 

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

DeleteCredentials deletes stored credentials by name.

func (*FetchyrNamespace) DeleteWorkflow added in v0.2.0 

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

DeleteWorkflow deletes a workflow definition.

func (*FetchyrNamespace) DetectForms 

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

DetectForms detects forms on a page.

func (*FetchyrNamespace) DetectMFA 

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

DetectMFA detects MFA challenges on a page.

func (*FetchyrNamespace) ExecuteWorkflow 

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

ExecuteWorkflow triggers execution of a workflow by ID.

func (*FetchyrNamespace) Fetch 

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

Fetch performs an authenticated fetch within an existing session.

func (*FetchyrNamespace) FillForm added in v0.2.0 

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

FillForm fills and optionally submits a form on a page.

func (*FetchyrNamespace) GetDedupDomainStatistics added in v0.2.0 

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

GetDedupDomainStatistics gets deduplication statistics for a domain.

func (*FetchyrNamespace) GetDedupSession added in v0.2.0 

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

GetDedupSession gets a deduplication session by ID.

func (*FetchyrNamespace) GetDedupSessionStatistics added in v0.2.0 

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

GetDedupSessionStatistics gets statistics for a deduplication session.

func (*FetchyrNamespace) GetExecution 

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

GetExecution retrieves the result of a workflow execution.

func (*FetchyrNamespace) GetMFAChallenge added in v0.2.0 

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

GetMFAChallenge gets a specific MFA challenge by ID.

func (*FetchyrNamespace) GetMFAStatistics added in v0.2.0 

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

GetMFAStatistics gets MFA statistics for a domain.

func (*FetchyrNamespace) GetWorkflow added in v0.2.0 

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

GetWorkflow gets a workflow definition by ID.

func (*FetchyrNamespace) GetWorkflowStatistics added in v0.2.0 

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

GetWorkflowStatistics gets execution statistics for a workflow.

func (*FetchyrNamespace) ListCredentials added in v0.2.0 

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

ListCredentials lists stored credential names (no secret values).

func (*FetchyrNamespace) ListDedupSessions added in v0.2.0 

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

ListDedupSessions lists active deduplication sessions.

func (*FetchyrNamespace) ListMFAChallenges added in v0.2.0 

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

ListMFAChallenges lists pending MFA challenges.

func (*FetchyrNamespace) ListSessions added in v0.2.0 

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

ListSessions lists active browser sessions.

func (*FetchyrNamespace) ListWorkflows added in v0.2.0 

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

ListWorkflows lists all RPA workflow definitions.

func (*FetchyrNamespace) Login 

func (f *FetchyrNamespace) Login(
	ctx context.Context,
	targetURL, usernameSelector, passwordSelector, username, password string,
	opts *LoginOptions,
) (*SessionResult, error)

Login performs an automated login and returns an authenticated session artifact.

func (*FetchyrNamespace) StoreCredentials added in v0.2.0 

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

StoreCredentials stores login credentials securely.

func (*FetchyrNamespace) SubmitMFA 

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

SubmitMFA submits an MFA code for the given challenge ID.

func (*FetchyrNamespace) TerminateSession added in v0.2.0 

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

TerminateSession terminates a session and releases Chrome slot.

func (*FetchyrNamespace) UpdateWorkflow added in v0.2.0 

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

UpdateWorkflow updates an existing workflow.

type FetchyrResult 

type FetchyrResult struct {
	Success           bool
	URL               string
	StatusCode        int
	HTML              *string
	ArtifactID        *string
	SessionArtifactID string
	Error             *string
}

FetchyrResult is returned by Fetchyr.Fetch.

type FormDetectionResult 

type FormDetectionResult struct {
	Forms      []map[string]interface{}
	TotalForms int
	Error      *string
}

FormDetectionResult is returned by Fetchyr.DetectForms.

type KloakdError 

type KloakdError struct {
	StatusCode int
	Message    string
}

KloakdError is the base error type for all SDK errors. Every error carries StatusCode and Message.

func (*KloakdError) Error 

func (e *KloakdError) Error() string

type KolektrNamespace 

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

KolektrNamespace exposes the Data Extraction module. Access via client.Kolektr.

func (*KolektrNamespace) CreateJob added in v0.2.0 

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

CreateJob creates an extraction job.

func (*KolektrNamespace) CreateScraper added in v0.2.0 

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

CreateScraper creates a scraper configuration.

func (*KolektrNamespace) DeleteContent added in v0.2.0 

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

DeleteContent deletes a content item.

func (*KolektrNamespace) DeleteScraper added in v0.2.0 

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

DeleteScraper deletes a scraper configuration.

func (*KolektrNamespace) ExtractAllAPIData added in v0.2.0 

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

ExtractAllAPIData extracts all data from a discovered API endpoint.

func (*KolektrNamespace) ExtractHTML 

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

ExtractHTML extracts structured data from raw HTML without making a network request.

func (*KolektrNamespace) GetAPIData added in v0.2.0 

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

GetAPIData gets all extracted data for a discovered API endpoint.

func (*KolektrNamespace) GetAPIDataPaginated added in v0.2.0 

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

GetAPIDataPaginated gets API data with pagination.

func (*KolektrNamespace) GetContent added in v0.2.0 

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

GetContent gets a content item by ID.

func (*KolektrNamespace) GetJob added in v0.2.0 

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

GetJob gets an extraction job by ID.

func (*KolektrNamespace) GetJobProgress added in v0.2.0 

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

GetJobProgress gets job progress.

func (*KolektrNamespace) GetJobProgressEvents added in v0.2.0 

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

GetJobProgressEvents gets job progress events.

func (*KolektrNamespace) GetJobProgressLatest added in v0.2.0 

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

GetJobProgressLatest gets latest progress event for a job.

func (*KolektrNamespace) GetJobProgressSummary added in v0.2.0 

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

GetJobProgressSummary gets job progress summary.

func (*KolektrNamespace) GetJobStatus added in v0.2.0 

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

GetJobStatus gets extraction job status.

func (*KolektrNamespace) GetPipelineEvents added in v0.2.0 

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

GetPipelineEvents gets events for a pipeline run.

func (*KolektrNamespace) GetPipelineStream added in v0.2.0 

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

GetPipelineStream streams pipeline data.

func (*KolektrNamespace) GetProgressPhase added in v0.2.0 

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

GetProgressPhase gets info for a specific progress phase.

func (*KolektrNamespace) GetProgressPhaseSteps added in v0.2.0 

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

GetProgressPhaseSteps gets steps for a progress phase.

func (*KolektrNamespace) GetProgressSummary added in v0.2.0 

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

GetProgressSummary gets overall progress summary.

func (*KolektrNamespace) GetScraper added in v0.2.0 

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

GetScraper gets a scraper configuration by ID.

func (*KolektrNamespace) ListContent added in v0.2.0 

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

ListContent lists content items.

func (*KolektrNamespace) ListJobs added in v0.2.0 

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

ListJobs lists extraction jobs.

func (*KolektrNamespace) ListProgressPhases added in v0.2.0 

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

ListProgressPhases lists all progress phases.

func (*KolektrNamespace) ListScrapers added in v0.2.0 

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

ListScrapers lists scraper configurations.

func (*KolektrNamespace) Page 

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

Page extracts structured data from a URL using the full Kolektr pipeline.

func (*KolektrNamespace) PageAll 

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

PageAll auto-paginates until all records are retrieved.

func (*KolektrNamespace) UpdateScraper added in v0.2.0 

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

UpdateScraper updates a scraper configuration.

type LoginOptions 

type LoginOptions struct {
	SubmitSelector     string
	SuccessURLContains string
}

LoginOptions configures optional parameters for Fetchyr.Login.

type MfaDetectionResult 

type MfaDetectionResult struct {
	MfaDetected bool
	ChallengeID *string
	MfaType     *string
	Error       *string
}

MfaDetectionResult is returned by Fetchyr.DetectMFA.

type MfaResult 

type MfaResult struct {
	Success           bool
	SessionArtifactID *string
	Error             *string
}

MfaResult is returned by Fetchyr.SubmitMFA.

type NexusAnalyzeOptions 

type NexusAnalyzeOptions struct {
	HTML        string
	Constraints map[string]interface{}
}

NexusAnalyzeOptions configures optional parameters for Nexus.Analyze.

type NexusAnalyzeResult 

type NexusAnalyzeResult struct {
	PerceptionID    string
	Strategy        map[string]interface{}
	PageType        string
	ComplexityLevel string
	ArtifactID      *string
	DurationMs      int
	Error           *string
}

NexusAnalyzeResult is returned by Nexus.Analyze.

type NexusExecuteResult 

type NexusExecuteResult struct {
	ExecutionResultID string
	Success           bool
	Records           []map[string]interface{}
	ArtifactID        *string
	DurationMs        int
	Error             *string
}

NexusExecuteResult is returned by Nexus.Execute.

type NexusKnowledgeResult 

type NexusKnowledgeResult struct {
	LearnedConcepts []map[string]interface{}
	LearnedPatterns []map[string]interface{}
	DurationMs      int
	Error           *string
}

NexusKnowledgeResult is returned by Nexus.Knowledge.

type NexusNamespace 

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

NexusNamespace exposes the Strategy Engine module (5-layer cognitive pipeline). Access via client.Nexus.

func (*NexusNamespace) Analyze 

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

Analyze analyzes a URL using the Nexus perception layer.

func (*NexusNamespace) CleanupCache added in v0.2.0 

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

CleanupCache cleans up recommendation cache.

func (*NexusNamespace) CreatePreference added in v0.2.0 

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

CreatePreference creates a recommendation preference.

func (*NexusNamespace) DeletePreference added in v0.2.0 

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

DeletePreference deletes a recommendation preference.

func (*NexusNamespace) DisableHook added in v0.2.0 

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

DisableHook disables a recommendation hook.

func (*NexusNamespace) EnableHook added in v0.2.0 

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

EnableHook enables a recommendation hook.

func (*NexusNamespace) Execute 

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

Execute runs a verified strategy against a URL.

func (*NexusNamespace) GetCacheStatistics added in v0.2.0 

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

GetCacheStatistics gets recommendation cache statistics.

func (*NexusNamespace) GetHooksStatus added in v0.2.0 

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

GetHooksStatus gets hooks status.

func (*NexusNamespace) GetPreferences added in v0.2.0 

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

GetPreferences gets user preferences.

func (*NexusNamespace) GetRecommendationStatistics added in v0.2.0 

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

GetRecommendationStatistics gets recommendation statistics.

func (*NexusNamespace) InvalidateCache added in v0.2.0 

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

InvalidateCache invalidates recommendation cache.

func (*NexusNamespace) Knowledge 

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

Knowledge stores learned concepts and patterns from an execution result.

func (*NexusNamespace) ListRecommendationApplications added in v0.2.0 

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

ListRecommendationApplications lists recommendation applications.

func (*NexusNamespace) Reason added in v0.2.0 

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

Reason performs logical reasoning via the Strategy Engine.

func (*NexusNamespace) RecommendAnalyze added in v0.2.0 

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

RecommendAnalyze analyzes and gets recommendations.

func (*NexusNamespace) Synthesize 

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

Synthesize generates a scraping strategy from a perception ID.

func (*NexusNamespace) UpdatePreference added in v0.2.0 

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

UpdatePreference updates a recommendation preference.

func (*NexusNamespace) Verify 

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

Verify verifies the safety of a strategy before execution.

type NexusSynthesisResult 

type NexusSynthesisResult struct {
	StrategyID      string
	StrategyName    string
	GeneratedCode   string
	ArtifactID      *string
	SynthesisTimeMs int
	Error           *string
}

NexusSynthesisResult is returned by Nexus.Synthesize.

type NexusSynthesizeOptions 

type NexusSynthesizeOptions struct {
	Strategy string
	Timeout  int
}

NexusSynthesizeOptions configures optional parameters for Nexus.Synthesize.

type NexusVerifyResult 

type NexusVerifyResult struct {
	VerificationResultID string
	IsSafe               bool
	RiskScore            float64
	SafetyScore          float64
	Violations           []string
	DurationMs           int
	Error                *string
}

NexusVerifyResult is returned by Nexus.Verify.

type NotEntitledError 

type NotEntitledError struct {
	KloakdError
	Module     string
	UpgradeURL string
}

NotEntitledError is returned for HTTP 403 — tenant not on required plan.

func (*NotEntitledError) Error 

func (e *NotEntitledError) Error() string

type PageNode 

type PageNode struct {
	URL        string
	Depth      int
	Title      *string
	StatusCode *int
	Children   []string
}

PageNode represents a single page in the site hierarchy.

type PageOptions 

type PageOptions struct {
	Schema            map[string]interface{}
	FetchArtifactID   string
	SessionArtifactID string
	ApiMapArtifactID  string
	Limit             int
	Offset            int
}

PageOptions configures optional parameters for Kolektr.Page.

type ParlyrNamespace 

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

ParlyrNamespace exposes the Conversational NLP module. Access via client.Parlyr.

func (*ParlyrNamespace) Chat 

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

Chat sends a message to a conversation session and blocks until the full response is collected from the SSE stream.

func (*ParlyrNamespace) ChatStream 

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

ChatStream opens an SSE stream for a conversation turn. Returns a read-only channel of ChatEvent values.

func (*ParlyrNamespace) DeleteSession 

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

DeleteSession removes a conversation session.

func (*ParlyrNamespace) Parse 

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

Parse interprets a natural language message.

type ParseOptions 

type ParseOptions struct {
	SessionID string
}

ParseOptions configures optional parameters for Parlyr.Parse.

type ParseResult 

type ParseResult struct {
	Intent              string
	Confidence          float64
	Tier                int
	Source              string
	Entities            map[string]interface{}
	RequiresAction      bool
	ClarificationNeeded *string
	Reasoning           *string
	DetectedURL         *string
}

ParseResult is returned by Parlyr.Parse.

type RateLimitError 

type RateLimitError struct {
	KloakdError
	RetryAfter int    // seconds
	ResetAt    string // ISO timestamp
}

RateLimitError is returned for HTTP 429 — quota exceeded.

func (*RateLimitError) Error 

func (e *RateLimitError) Error() string

type SessionResult 

type SessionResult struct {
	Success       bool
	SessionID     string
	URL           string
	ArtifactID    *string
	ScreenshotURL *string
	Error         *string
}

SessionResult is returned by Fetchyr.Login.

type SkanyrNamespace 

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

SkanyrNamespace exposes the API Discovery module. Access via client.Skanyr.

func (*SkanyrNamespace) AnalyzeBundle added in v0.2.0 

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

AnalyzeBundle analyses a JS bundle URL for embedded API patterns.

func (*SkanyrNamespace) DeleteSession added in v0.2.0 

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

DeleteSession deletes a discovery session.

func (*SkanyrNamespace) DetectedAPIs added in v0.2.0 

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

DetectedAPIs lists all detected APIs from a prior discovery run.

func (*SkanyrNamespace) Discover 

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

Discover discovers API endpoints on the given URL.

func (*SkanyrNamespace) DiscoverAll 

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

DiscoverAll auto-paginates until all endpoints are retrieved.

func (*SkanyrNamespace) DiscoverPageLive added in v0.2.0 

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

DiscoverPageLive runs all detectors against a single page.

func (*SkanyrNamespace) DiscoverStream 

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

DiscoverStream opens a server-sent events stream for the API discovery operation. Returns a read-only channel of DiscoverEvent values.

func (*SkanyrNamespace) EndSession added in v0.2.0 

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

EndSession ends an active discovery session.

func (*SkanyrNamespace) ExpandNode added in v0.2.0 

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

ExpandNode expands a hierarchy node to discover child pages.

func (*SkanyrNamespace) GetApiMap 

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

GetApiMap retrieves a stored API map artifact by ID.

func (*SkanyrNamespace) GetDiscovery added in v0.2.0 

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

GetDiscovery polls discovery status by ID.

func (*SkanyrNamespace) GetDiscoveryEvents added in v0.2.0 

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

GetDiscoveryEvents gets SSE stream events for a discovery run.

func (*SkanyrNamespace) GetJob 

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

GetJob retrieves the status of a discovery job by ID.

func (*SkanyrNamespace) GetSession added in v0.2.0 

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

GetSession gets a discovery session by ID.

func (*SkanyrNamespace) Health added in v0.2.0 

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

Health performs a health check for Skanyr discovery service.

func (*SkanyrNamespace) Hierarchy added in v0.2.0 

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

Hierarchy discovers site hierarchy from a URL.

func (*SkanyrNamespace) ListSessions added in v0.2.0 

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

ListSessions lists discovery sessions.

func (*SkanyrNamespace) ReaderView added in v0.2.0 

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

ReaderView extracts a clean reader view of a page.

func (*SkanyrNamespace) Retry added in v0.2.0 

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

Retry retries a discovery run with optional overrides.

func (*SkanyrNamespace) SaveSession added in v0.2.0 

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

SaveSession saves a discovery session.

func (*SkanyrNamespace) UpdateSessionJob added in v0.2.0 

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

UpdateSessionJob updates the job ID associated with a session.

type UpstreamError 

type UpstreamError struct {
	KloakdError
}

UpstreamError is returned for HTTP 502 — upstream site fetch failed.

func (*UpstreamError) Error 

func (e *UpstreamError) Error() string

type WebgrphNamespace 

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

WebgrphNamespace exposes the Site Mapping & Discovery module. Access via client.Webgrph.

func (*WebgrphNamespace) Crawl 

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

Crawl performs a site crawl and returns the hierarchy result.

func (*WebgrphNamespace) CrawlAll 

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

CrawlAll auto-paginates until all pages are retrieved.

func (*WebgrphNamespace) CrawlStream 

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

CrawlStream opens a server-sent events stream for the crawl operation. Returns a read-only channel of CrawlEvent values.

func (*WebgrphNamespace) GetCrawlEvents added in v0.2.0 

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

GetCrawlEvents gets SSE events for a crawl.

func (*WebgrphNamespace) GetCrawlPages added in v0.2.0 

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

GetCrawlPages gets paginated list of discovered pages.

func (*WebgrphNamespace) GetCrawlStatus added in v0.2.0 

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

GetCrawlStatus polls crawl status and stats.

func (*WebgrphNamespace) GetDashboardSummary added in v0.2.0 

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

GetDashboardSummary gets analytics dashboard summary.

func (*WebgrphNamespace) GetDiscoveryPatterns added in v0.2.0 

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

GetDiscoveryPatterns gets content discovery pattern analytics.

func (*WebgrphNamespace) GetEfficiencyMetrics added in v0.2.0 

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

GetEfficiencyMetrics gets scraping efficiency metrics.

func (*WebgrphNamespace) GetErrorSummary added in v0.2.0 

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

GetErrorSummary gets error summary analytics.

func (*WebgrphNamespace) GetHierarchy 

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

GetHierarchy retrieves a stored site hierarchy artifact by ID.

func (*WebgrphNamespace) GetJob 

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

GetJob retrieves the status of a crawl job by ID.

func (*WebgrphNamespace) GetJobTrends added in v0.2.0 

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

GetJobTrends gets job trends analytics.

func (*WebgrphNamespace) GetSiteMappingTrends added in v0.2.0 

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

GetSiteMappingTrends gets site mapping trends.

func (*WebgrphNamespace) GetUserBehaviorInsights added in v0.2.0 

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

GetUserBehaviorInsights gets user behavior insights.

type WorkflowResult 

type WorkflowResult struct {
	WorkflowID string
	Name       string
	Steps      []map[string]interface{}
	URL        *string
	CreatedAt  string
	Error      *string
}

WorkflowResult is returned by Fetchyr.CreateWorkflow.

Source Files

View all Source files

Directories

Path Synopsis
examples
quickstart command
Quickstart: Discover and extract from a site in ~10 lines.
 Quickstart: Discover and extract from a site in ~10 lines.

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.