daemon

package

v0.1.0 Latest Latest Go to latest Published: Jun 26, 2026 License: Apache-2.0 Imports: 32 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/byteyellow/agentprovenance

Links

Open Source Insights

Documentation ¶

Index ¶

type Client
- func NewClient(baseURL string) Client
type Server
- func NewServer(dataDir string) (Server, func(), error)
type SnapshotCreateResponse

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Client ¶

type Client struct {
	BaseURL string
	HTTP    *http.Client
	Token   string
}

func NewClient ¶

func NewClient(baseURL string) Client

func (Client) CreateLease ¶

func (c Client) CreateLease(task string) (string, error)

func (Client) CreateSession ¶

func (c Client) CreateSession(leaseID string) (string, error)

func (Client) CreateSnapshot ¶

func (c Client) CreateSnapshot(sessionID, typ, path, name string) (SnapshotCreateResponse, error)

func (Client) EvidenceManifest ¶

func (c Client) EvidenceManifest(runID string, materialize bool) (evidence.MaterializedManifest, error)

func (Client) Exec ¶

func (c Client) Exec(sessionID string, command []string, stream bool, out io.Writer) (string, error)

func (Client) ExplainGraph ¶

func (c Client) ExplainGraph(opts provenance.ExplainOptions) (provenance.ExplainManifest, error)

func (Client) ExportBatchForensics ¶

func (c Client) ExportBatchForensics(opts forensics.BatchExportOptions) (forensics.BatchBundleInfo, error)

func (Client) ExportForensics ¶

func (c Client) ExportForensics(runID string) (forensics.BundleInfo, error)

func (Client) ImportSignals ¶

func (c Client) ImportSignals(runID, engine string, signals []signal.EvalSignal) (signal.EvalReport, error)

func (Client) InspectSession ¶

func (c Client) InspectSession(sessionID string) (control.SessionInfo, error)

func (Client) ListSessions ¶

func (c Client) ListSessions() ([]control.SessionInfo, error)

func (Client) ObserveSummary ¶

func (c Client) ObserveSummary(runID string, topN int) (observability.Summary, error)

func (Client) RemoveSession ¶

func (c Client) RemoveSession(sessionID string) error

func (Client) ResumeSnapshot ¶

func (c Client) ResumeSnapshot(snapshotNameOrID, leaseID string) (string, error)

func (Client) RunBuiltinSignals ¶

func (c Client) RunBuiltinSignals(runID string) (signal.EvalReport, error)

func (Client) SchedulerStatus ¶

func (c Client) SchedulerStatus(snapshot string) (scheduler.NodeState, error)

func (Client) SecurityDeviations ¶

func (c Client) SecurityDeviations(runID string) (baseline.DeviationsReport, error)

func (Client) SecurityResponses ¶

func (c Client) SecurityResponses(runID string) (securitymodel.ResponseActionsReport, error)

func (Client) SecurityRisks ¶

func (c Client) SecurityRisks(runID string) (securitymodel.RiskSignalsReport, error)

func (Client) SetSessionCPUProfile ¶

func (c Client) SetSessionCPUProfile(sessionID, profile string) error

func (Client) SignalContext ¶

func (c Client) SignalContext(runID string) (signal.EvalContext, error)

func (Client) StopSession ¶

func (c Client) StopSession(sessionID string) error

func (Client) TelemetryCorrelations ¶

func (c Client) TelemetryCorrelations(runID, eventID string) (telemetry.CorrelationReport, error)

func (Client) Timeline ¶

func (c Client) Timeline(opts provenance.TimelineOptions) (provenance.TimelineManifest, error)

func (Client) VerifyGraph ¶

func (c Client) VerifyGraph(runID string) (provenance.VerifyResult, error)

type Server ¶

type Server struct {
	DB               *sql.DB
	Paths            store.Paths
	Driver           runtimeplane.Driver
	SampleInterval   time.Duration
	SampleLimit      int
	SampleTimeout    time.Duration
	RawRetention     time.Duration
	MaxRawSamples    int
	EvidenceInterval time.Duration
	EvidenceLimit    int
	SpoolInterval    time.Duration
	SpoolLimit       int
	SpoolMaxQueued   int
	SpoolDropPolicy  string
	GCInterval       time.Duration
	GCLimit          int
	// AuthToken, when set, requires every request except GET /v1/health to carry
	// `Authorization: Bearer <AuthToken>`. Empty = open (backward compatible).
	AuthToken string
	// contains filtered or unexported fields
}

func NewServer ¶

func NewServer(dataDir string) (Server, func(), error)

func (Server) Handler ¶

func (s Server) Handler() http.Handler

func (Server) StartEvidenceWorker ¶

func (s Server) StartEvidenceWorker(ctx context.Context)

func (Server) StartGCWorker ¶

func (s Server) StartGCWorker(ctx context.Context)

func (Server) StartSampler ¶

func (s Server) StartSampler(ctx context.Context)

func (Server) StartSpoolWorker ¶

func (s Server) StartSpoolWorker(ctx context.Context)

type SnapshotCreateResponse ¶

type SnapshotCreateResponse struct {
	SnapshotID       string `json:"snapshot_id"`
	Files            int64  `json:"files"`
	Bytes            int64  `json:"bytes"`
	SnapshotCreateMS int64  `json:"snapshot_create_ms"`
	Hash             string `json:"hash"`
}

Source Files ¶

View all Source files

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