http

package
v0.2.2 Latest Latest
Warning

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

Go to latest
Published: May 23, 2026 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CheckpointLister added in v0.2.0

type CheckpointLister interface {
	ListRunCheckpoints(ctx context.Context, runID string, limit int) (any, error)
}

type CheckpointLoader added in v0.2.0

type CheckpointLoader interface {
	GetRunCheckpoint(ctx context.Context, runID string, version int64) (any, error)
}

type CheckpointResumer added in v0.2.0

type CheckpointResumer interface {
	ResumeFromCheckpoint(ctx context.Context, runID string, version int64) (any, error)
}

type Config

type Config struct {
	Store           obspkg.EventStore
	Hub             *obspkg.EventHub
	AuthMiddleware  func(nethttp.Handler) nethttp.Handler
	TraceExploreURL string
	Steps           StepsLister
	HITLResume      RunHITLResumer
	Graph           GraphExporter
	Resume          StepResumer
	History         CheckpointLister
	Checkpoints     CheckpointLoader
	Restore         CheckpointResumer
	Studio          StudioValidator
	Codegen         StudioCodeGenerator
	YAML            StudioYAMLExporter
	ImportYAML      StudioYAMLImporter
	RunStudio       StudioRunner
	StudioSave      StudioSaver
	Compare         RunComparer
	Thread          ThreadLister
	Fork            RunForker
}

type GraphExporter added in v0.2.0

type GraphExporter interface {
	ExportScenarioGraph() any
}

type Handler

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

func NewHandler

func NewHandler(config Config) (*Handler, error)

func (*Handler) ServeHTTP

func (handler *Handler) ServeHTTP(w nethttp.ResponseWriter, r *nethttp.Request)

type RunComparer added in v0.2.0

type RunComparer interface {
	CompareRuns(ctx context.Context, runA, runB string) (any, error)
}

type RunForker added in v0.2.0

type RunForker interface {
	ForkRun(ctx context.Context, runID string, version int64) (any, error)
}

type RunHITLResumer added in v0.2.0

type RunHITLResumer interface {
	ResumeRunHITL(ctx context.Context, runID string, decision core.Decision, amendment json.RawMessage, continueExecution bool) (any, error)
}

type StepResumer added in v0.2.0

type StepResumer interface {
	ResumeFromStep(ctx context.Context, runID, nodeID string) (any, error)
}

type StepsLister added in v0.2.0

type StepsLister interface {
	ListRunSteps(ctx context.Context, runID string) (any, error)
}

type StudioCodeGenerator added in v0.2.0

type StudioCodeGenerator interface {
	GenerateStudioBuilderCode(ctx context.Context, graph any) (any, error)
}

type StudioRunner added in v0.2.0

type StudioRunner interface {
	RunStudioGraph(ctx context.Context, graph any, req any) (any, error)
}

type StudioSaver added in v0.2.0

type StudioSaver interface {
	SaveStudioGraph(ctx context.Context, graph any) (any, error)
}

type StudioValidator added in v0.2.0

type StudioValidator interface {
	ValidateStudioGraph(ctx context.Context, graph any) (any, error)
}

type StudioYAMLExporter added in v0.2.0

type StudioYAMLExporter interface {
	GenerateStudioScenarioYAML(ctx context.Context, graph any) (any, error)
}

type StudioYAMLImporter added in v0.2.0

type StudioYAMLImporter interface {
	ImportStudioScenarioYAML(ctx context.Context, yaml []byte, layout any) (any, error)
}

type ThreadLister added in v0.2.0

type ThreadLister interface {
	ListRunThread(ctx context.Context, runID string) (any, error)
}

Jump to

Keyboard shortcuts

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