sdk

package

Go to main page

Versions in this module

v0

v0.8.0

Aug 17, 2026

Changes in this version

type Client

+ func (c *Client) AddEternalFact(factString string) error

+ func (c *Client) AddTemporalFact(factString string, start, end time.Time) error

+ func (c *Client) AddTemporalFactAt(factString string, at time.Time) error

+ func (c *Client) AddTemporalFactInFuture(factString string, duration time.Duration) error

+ func (c *Client) AddTemporalFactInPast(factString string, duration time.Duration) error

+ func (c *Client) ContainsTemporalFact(factString string) (bool, error)

+ func (c *Client) EnableTemporal() error

+ func (c *Client) IsTemporalEnabled() (bool, error)

+ func (c *Client) QueryTemporalFactsAt(factPattern string, at time.Time) ([]string, error)

+ func (c *Client) QueryTemporalFactsDuring(factPattern string, start, end time.Time) ([]string, error)

+ func (c *Client) SetEvaluationTime(t time.Time) error

v0.7.0

Aug 17, 2026

Changes in this version

type Client

+ func (c *Client) Explain(ctx context.Context, queryStr string, facts []string) (*core.Explanation, error)

+ func (c *Client) RegisterSupervised(name string, act core.Action) core.Action

+ func (c *Client) ReloadPolicy(ctx context.Context, path string) error

+ func (c *Client) ReloadPolicySource(ctx context.Context, source string) error

type ClientOption

+ func WithPolicyPath(path string) ClientOption

v0.6.0

Aug 4, 2026

Changes in this version

type ClientOption

+ func WithConfigFile(path string) ClientOption

v0.5.0

Jul 28, 2026

v0.4.0

Jul 16, 2026

Changes in this version

type Client

+ func (c *Client) LoadFromSource(ctx context.Context, source string) error

+ func (c *Client) LoadPolicy(ctx context.Context, policy string) error

+ func (c *Client) ParadoxThreshold() float64

+ func (c *Client) RegisterExternalPredicate(name string, fn func(ctx context.Context, inputs []any) ([][]any, error)) error

type ClientOption

+ func WithSteeringEnabled() ClientOption

type HybridMemory

+ func (m *HybridMemory) RecallWithFacts(ctx context.Context, query string) (string, map[string]any, error)

v0.3.0

Jun 11, 2026

Changes in this version

+ const BackoffBase

+ const DefaultExamples

+ const DefaultMaxRetries

+ const DefaultMaxSteps

+ const DefaultPromptTemplate

+ const FailModeClosed

+ const FailModeOpen

+ const TracerName

+ func Execute[TIn any, TOut any](ctx context.Context, c *Client, handle TypedAction[TIn, TOut], input TIn) (TOut, error)

+ func HydrateActions(ctx context.Context, actions map[string]config.ActionConfig) ([]core.Action, error)

+ func NewActionFromConfig(ctx context.Context, name string, cfg config.ActionConfig) (core.Action, error)

+ func RegisterMemoryProvider(name string, factory MemoryFactory)

+ func RegisterProvider(name string, factory ProviderFactory)

+ func WithExtractor(action core.Action, ext ports.Extractor) core.Action

+ func WithJSONMode(enabled bool) core.GenerateOption

+ func WithMaxTokens(n int) core.GenerateOption

+ func WithModel(m string) core.GenerateOption

+ func WithStopSequences(seqs []string) core.GenerateOption

+ func WithStructuredOutput(schema any) core.GenerateOption

+ func WithTemperature(t float64) core.GenerateOption

+ func WithTopP(p float64) core.GenerateOption

+ type ActionMetadata = core.ActionMetadata

+ type Client struct

+ func Must(c *Client, err error) *Client

+ func NewClient(ctx context.Context, opts ...ClientOption) (*Client, error)

+ func NewClientFromConfig(ctx context.Context, cfg *config.Config, opts ...ClientOption) (*Client, error)

+ func NewClientFromFile(ctx context.Context, configPath string, opts ...ClientOption) (*Client, error)

+ func NewDefault() (*Client, error)

+ func TryClient(c *Client, err error) (*Client, error)

+ func (c *Client) Action(name string) core.Action

+ func (c *Client) Engine() core.Evaluator

+ func (c *Client) Execute(ctx context.Context, input core.Envelope, opts ...ExecuteOption) (core.Envelope, error)

+ func (c *Client) ExecuteByName(ctx context.Context, actionName string, input any, opts ...ExecuteOption) (core.Envelope, error)

+ func (c *Client) ExecutePlan(ctx context.Context, steps []PlanStep, initialInput core.Envelope) (core.Envelope, error)

+ func (c *Client) ExecuteSingleStep(ctx context.Context, actionName string, payload any, params *ExecutionParams) (core.Envelope, error)

+ func (c *Client) LoadFacts(facts []string) error

+ func (c *Client) LoadGherkinPolicy(ctx context.Context, featureContent string) error

+ func (c *Client) LoadNTriplesFile(path string) error

+ func (c *Client) Logger() core.Logger

+ func (c *Client) Memory() core.AgentMemory

+ func (c *Client) Plan(ctx context.Context, goalName string) ([]PlanStep, error)

+ func (c *Client) RegisterAction(name string, action core.Action)

+ func (c *Client) SetLLM(gen core.TextGenerator)

+ func (c *Client) Shutdown(ctx context.Context) error

+ func (c *Client) Supervise(action core.Action) core.Action

+ func (c *Client) Tracer() trace.Tracer

+ type ClientOption func(*Client) error

+ func WithAgentMemory(mem core.AgentMemory) ClientOption

+ func WithBlueprintPath(path string) ClientOption

+ func WithConfig(cfg *config.Config) ClientOption

+ func WithEngine(e core.Evaluator) ClientOption

+ func WithFailMode(mode string) ClientOption

+ func WithHistory(store core.HistoryStore) ClientOption

+ func WithLLM(gen core.TextGenerator) ClientOption

+ func WithLogger(l core.Logger) ClientOption

+ func WithMemory(mem core.AgentMemory) ClientOption

+ func WithProviderConfig(name string, cfg config.ActionConfig) ClientOption

+ func WithStateProvider(provider core.StateProvider) ClientOption

+ func WithStdoutTracer() ClientOption

+ func WithTracerProvider(tp trace.TracerProvider) ClientOption

+ type Envelope = core.Envelope

+ func NewEnvelope(payload any) Envelope

+ type ExecuteOption func(*ExecutionParams)

+ func WithMaxSteps(n int) ExecuteOption

+ func WithMetadata(key, value string) ExecuteOption

+ func WithMetadataMap(meta map[string]any) ExecuteOption

+ func WithSessionID(id string) ExecuteOption

+ func WithTransientMemory() ExecuteOption

+ type ExecutionParams struct

+ AuditRecords []core.AuditRecord

+ CurrentHistory []core.Message

+ FeedbackHistory []string

+ LastFeedback string

+ MaxSteps int

+ MemoryMode core.MemoryMode

+ Metadata map[string]string

+ RetryCount int

+ SessionID string

+ Store core.HistoryStore

+ type Generator struct

+ func NewPolicyGenerator(llmAction core.Action, opts GeneratorOptions) (*Generator, error)

+ func (g *Generator) GenerateRule(ctx context.Context, schemaSample any, policyText string) (string, error)

+ type GeneratorOptions struct

+ Examples string

+ PromptTemplate string

+ RuleHead string

+ type HybridMemory struct

+ CollectionName string

+ Embedder core.Embedder

+ History core.HistoryStore

+ TopK int

+ Vectors core.VectorStore

+ func NewHybridMemory(h core.HistoryStore, v core.VectorStore, e core.Embedder) *HybridMemory

+ func (m *HybridMemory) Append(ctx context.Context, sessionID string, msgs []core.Message) error

+ func (m *HybridMemory) Init(ctx context.Context) error

+ func (m *HybridMemory) Memorize(ctx context.Context, query string, answer string) error

+ func (m *HybridMemory) Read(ctx context.Context, sessionID string) ([]core.Message, error)

+ func (m *HybridMemory) Recall(ctx context.Context, query string) (string, error)

+ type MemoryFactory func(ctx context.Context, cfg config.MemoryConfig) (core.AgentMemory, error)

+ func MemoryProvider(name string) (MemoryFactory, error)

+ type PlanStep struct

+ ActionName string

+ Order int

+ type ProviderFactory func(opts map[string]any) (ClientOption, error)

+ func Provider(name string) (ProviderFactory, error)

+ type Runnable struct

+ func Define[In any, Out any](c *Client, name string, handler func(context.Context, In) (Out, error)) *Runnable[In, Out]

+ func (r *Runnable[In, Out]) Run(ctx context.Context, input In) (Out, error)

+ type TypedAction struct

+ Name string

+ func DefineAction[TIn any, TOut any](name string) TypedAction[TIn, TOut]

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