Go SDK reference

func (c *AnalyticsRuntimeClient) SQL(ctx context.Context, query string) ([]map[string]any, error)

func (c *AnalyticsRuntimeClient) RegisterCSV(ctx context.Context, name, path string) error

func (c *AnalyticsRuntimeClient) RegisterParquet(ctx context.Context, name, path string) error

func (c *AnalyticsRuntimeClient) RegisterCore(ctx context.Context, name, keyspace string) error

func (c *AnalyticsRuntimeClient) SetOptions(ctx context.Context, options map[string]any) error

func (c *AnalyticsRuntimeClient) CacheClear(ctx context.Context) error

func (c *AnalyticsRuntimeClient) CacheStats(ctx context.Context) (map[string]any, error)

type AnalyticsRuntimeClient struct {
	runtime *RuntimeClient
}

func NewClient(baseURL, apiKey string) *Client

func NewClientWithConfig(cfg Config) *Client

func (c *Client) ControlPlane() *ControlPlaneClient

func (c *Client) Runtime(instanceURL string) *RuntimeClient

type Config struct {
	BaseURL     string
	APIKey      string
	Timeout     time.Duration
	TenantID    string
	ReservoirID string
	AgentID     string
	DataspaceID string
}

type Client struct {
	config     Config
	httpClient *http.Client
}

func (c *ContinualRuntimeClient) CreateTask(ctx context.Context, name string, config map[string]any) (*TaskInfo, error)

func (c *ContinualRuntimeClient) GetTask(ctx context.Context, taskID string) (*TaskInfo, error)

func (c *ContinualRuntimeClient) ListTasks(ctx context.Context) ([]TaskInfo, error)

func (c *ContinualRuntimeClient) DeleteTask(ctx context.Context, taskID string) error

func (c *ContinualRuntimeClient) AddSamples(ctx context.Context, taskID string, samples []map[string]any) (int, error)

func (c *ContinualRuntimeClient) Train(ctx context.Context, taskID string, epochs int, config map[string]any) (*LearningProgress, error)

func (c *ContinualRuntimeClient) GetProgress(ctx context.Context, taskID string) (*LearningProgress, error)

func (c *ContinualRuntimeClient) Consolidate(ctx context.Context, taskID string) (map[string]any, error)

func (c *ContinualRuntimeClient) Replay(ctx context.Context, taskID string, numSamples int) (map[string]any, error)

func (c *ContinualRuntimeClient) Evaluate(ctx context.Context, taskID string, testData []map[string]any) (map[string]any, error)

func (c *ContinualRuntimeClient) GetStats(ctx context.Context) (map[string]any, error)

func (c *ContinualRuntimeClient) ExportModel(ctx context.Context, taskID string, format string) ([]byte, error)

type ContinualRuntimeClient struct {
	runtime *RuntimeClient
}

type TaskInfo struct {
	ID          string         `json:"id"`
	Name        string         `json:"name"`
	Status      string         `json:"status"`
	DatasetSize int            `json:"dataset_size"`
	Progress    float64        `json:"progress"`
	Metrics     map[string]any `json:"metrics,omitempty"`
	CreatedAt   string         `json:"created_at,omitempty"`
}

type LearningProgress struct {
	TaskID     string         `json:"task_id"`
	Epoch      int            `json:"epoch"`
	TotalEpoch int            `json:"total_epochs"`
	Loss       float64        `json:"loss"`
	Metrics    map[string]any `json:"metrics,omitempty"`
}

func (c *ControlPlaneClient) Tenants() *TenantClient

func (c *ControlPlaneClient) Backups() *BackupClient

func (c *ControlPlaneClient) Monitoring() *MonitoringClient

func (c *TenantClient) List(ctx context.Context, query *ListTenantsQuery) (*ListTenantsResponse, error)

func (c *TenantClient) Get(ctx context.Context, tenantID string) (*Tenant, error)

func (c *TenantClient) Create(ctx context.Context, req *CreateTenantRequest) (*Tenant, error)

func (c *TenantClient) Update(ctx context.Context, tenantID string, req *UpdateTenantRequest) (*Tenant, error)

func (c *TenantClient) Delete(ctx context.Context, tenantID string) error

func (c *TenantClient) Start(ctx context.Context, tenantID string) (*Tenant, error)

func (c *TenantClient) Stop(ctx context.Context, tenantID string) (*Tenant, error)

func (c *BackupClient) List(ctx context.Context, tenantID string) ([]Backup, error)

func (c *BackupClient) Create(ctx context.Context, tenantID string, req *CreateBackupRequest) (*Backup, error)

func (c *BackupClient) Get(ctx context.Context, tenantID, backupID string) (*Backup, error)

func (c *BackupClient) Delete(ctx context.Context, tenantID, backupID string) error

func (c *BackupClient) Restore(ctx context.Context, tenantID, backupID string) error

func (c *MonitoringClient) Health(ctx context.Context, tenantID string) (*HealthStatus, error)

func (c *MonitoringClient) Usage(ctx context.Context, tenantID string) (*UsageMetrics, error)

func (c *MonitoringClient) Metrics(ctx context.Context, tenantID string) (*MetricsSnapshot, error)

type ControlPlaneClient struct {
	client *Client
}

type Tenant struct {
	ID        string       `json:"id"`
	OrgID     string       `json:"org_id"`
	Name      string       `json:"name"`
	Plan      TenantPlan   `json:"plan"`
	Status    TenantStatus `json:"status"`
	Endpoint  string       `json:"endpoint"`
	Region    string       `json:"region,omitempty"`
	CreatedAt time.Time    `json:"created_at"`
	UpdatedAt time.Time    `json:"updated_at"`
}

type CreateTenantRequest struct {
	OrgID  string     `json:"org_id"`
	Name   string     `json:"name"`
	Plan   TenantPlan `json:"plan"`
	Region string     `json:"region,omitempty"`
}

type UpdateTenantRequest struct {
	Name *string     `json:"name,omitempty"`
	Plan *TenantPlan `json:"plan,omitempty"`
}

type ListTenantsQuery struct {
	OrgID  string `json:"org_id,omitempty"`
	Status string `json:"status,omitempty"`
	Limit  int    `json:"limit,omitempty"`
	Offset int    `json:"offset,omitempty"`
}

type ListTenantsResponse struct {
	Tenants []Tenant `json:"tenants"`
	Total   int      `json:"total"`
}

type TenantClient struct {
	client *Client
}

type Backup struct {
	BackupID    string    `json:"backup_id"`
	TenantID    string    `json:"tenant_id"`
	Name        string    `json:"name,omitempty"`
	Description string    `json:"description,omitempty"`
	SizeBytes   int64     `json:"size_bytes"`
	Status      string    `json:"status"`
	CreatedAt   time.Time `json:"created_at"`
}

type CreateBackupRequest struct {
	Name        string `json:"name,omitempty"`
	Description string `json:"description,omitempty"`
}

type BackupClient struct {
	client *Client
}

type HealthStatus struct {
	Status    string            `json:"status"`
	Timestamp time.Time         `json:"timestamp"`
	Services  map[string]string `json:"services"`
}

type UsageMetrics struct {
	TenantID string `json:"tenant_id"`
	Period   string `json:"period"`
	Usage    struct {
		StorageGB struct {
			Current float64 `json:"current"`
			Limit   float64 `json:"limit"`
		} `json:"storage_gb"`
		RequestsCount struct {
			Current int `json:"current"`
			Limit   int `json:"limit"`
		} `json:"requests_count"`
		BandwidthGB struct {
			Current float64 `json:"current"`
			Limit   float64 `json:"limit"`
		} `json:"bandwidth_gb"`
	} `json:"usage"`
}

type MetricsSnapshot struct {
	Timestamp time.Time         `json:"timestamp"`
	Metrics   map[string]any    `json:"metrics"`
}

type MonitoringClient struct {
	client *Client
}

type TenantPlan string

type TenantStatus string

TenantPlanFree       TenantPlan = "free"

TenantPlanPro        TenantPlan = "pro"

TenantPlanEnterprise TenantPlan = "enterprise"

TenantStatusProvisioning TenantStatus = "provisioning"

TenantStatusActive       TenantStatus = "active"

TenantStatusSuspended    TenantStatus = "suspended"

TenantStatusDeleting     TenantStatus = "deleting"

func (e *Error) Error() string

func (e *Error) IsNotFound() bool

func (e *Error) IsUnauthorized() bool

func (e *Error) IsForbidden() bool

func (e *Error) IsConflict() bool

func (e *Error) IsRateLimit() bool

func (e *Error) IsServerError() bool

type Error struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
	Details any    `json:"details,omitempty"`
}

func (c *GraphRuntimeClient) Cypher(ctx context.Context, query string) ([]map[string]any, error)

func (c *GraphRuntimeClient) TextSearch(ctx context.Context, query string, limit int) ([]SearchResult, error)

func (c *GraphRuntimeClient) EnsurePropertyIndex(ctx context.Context, property string) error

func (c *GraphRuntimeClient) IndexStats(ctx context.Context) (map[string]any, error)

func (c *GraphRuntimeClient) PageRank(ctx context.Context, dampingFactor float64) (map[string]any, error)

func (c *GraphRuntimeClient) ShortestPath(ctx context.Context, source, target string) (map[string]any, error)

func (c *GraphRuntimeClient) ConnectedComponents(ctx context.Context, strong bool) (map[string]any, error)

func (c *GraphRuntimeClient) MicrotheorySwitch(ctx context.Context, name string) error

func (c *GraphRuntimeClient) MicrotheoryKeyspace(ctx context.Context, name string) (string, error)

func (c *GraphRuntimeClient) SchemaMetadata(ctx context.Context) (map[string]any, error)

type GraphRuntimeClient struct {
	runtime *RuntimeClient
}

type CypherResult struct {
	Rows []map[string]any `json:"rows"`
}

type SearchResult struct {
	EntityID string  `json:"entity_id"`
	Score    float64 `json:"score"`
}

func (c *KVClient) Get(ctx context.Context, key string) (*KVItem, error)

func (c *KVClient) Set(ctx context.Context, key string, value any, metadata map[string]any) (int64, error)

func (c *KVClient) Delete(ctx context.Context, key string) error

func (c *KVClient) Exists(ctx context.Context, key string) (bool, error)

func (c *KVClient) Scan(ctx context.Context, prefix string, cursor string, limit int) (*KVScanResult, error)

func (c *KVClient) MGet(ctx context.Context, keys []string) ([]KVItem, error)

func (c *KVClient) MSet(ctx context.Context, items []KVItem) error

func (c *KVClient) Incr(ctx context.Context, key string, delta int64) (int64, error)

func (c *KVClient) SetEx(ctx context.Context, key string, value any, ttlSecs int) error

type KVClient struct {
	runtime *RuntimeClient
}

type KVItem struct {
	Key      string         `json:"key"`
	Value    any            `json:"value"`
	Version  int64          `json:"version,omitempty"`
	Metadata map[string]any `json:"metadata,omitempty"`
}

type KVScanResult struct {
	Items   []KVItem `json:"items"`
	Cursor  string   `json:"cursor,omitempty"`
	HasMore bool     `json:"has_more"`
}

func (c *MemoryRuntimeClient) Episodic() *EpisodicMemoryClient

func (c *MemoryRuntimeClient) Procedural() *ProceduralMemoryClient

func (c *MemoryRuntimeClient) Resource() *ResourceMemoryClient

func (c *MemoryRuntimeClient) Vault() *VaultMemoryClient

func (c *MemoryRuntimeClient) Cognitive() *CognitiveMemoryClient

func (c *MemoryRuntimeClient) HybridRetrieval(ctx context.Context, query string, memoryTypes []string, limit int) ([]map[string]any, error)

func (c *MemoryRuntimeClient) Stats(ctx context.Context) (map[string]any, error)

func (c *EpisodicMemoryClient) Insert(ctx context.Context, content string, timestamp string, metadata map[string]any) (string, error)

func (c *EpisodicMemoryClient) Get(ctx context.Context, id string) (*EpisodeItem, error)

func (c *EpisodicMemoryClient) Search(ctx context.Context, query string, limit int) ([]EpisodeItem, error)

func (c *EpisodicMemoryClient) Range(ctx context.Context, startTime, endTime string, limit int) ([]EpisodeItem, error)

func (c *EpisodicMemoryClient) Recent(ctx context.Context, limit int) ([]EpisodeItem, error)

func (c *EpisodicMemoryClient) Delete(ctx context.Context, id string) error

func (c *ProceduralMemoryClient) Store(ctx context.Context, name, description string, steps []ProcStep, metadata map[string]any) (string, error)

func (c *ProceduralMemoryClient) Get(ctx context.Context, id string) (*Procedure, error)

func (c *ProceduralMemoryClient) GetByName(ctx context.Context, name string) (*Procedure, error)

func (c *ProceduralMemoryClient) List(ctx context.Context, limit, offset int) ([]Procedure, error)

func (c *ProceduralMemoryClient) Delete(ctx context.Context, id string) error

func (c *ResourceMemoryClient) Upload(ctx context.Context, name, contentType string, content []byte, metadata map[string]any) (string, error)

func (c *ResourceMemoryClient) Get(ctx context.Context, id string) (*ResourceItem, error)

func (c *ResourceMemoryClient) GetContent(ctx context.Context, id string) ([]byte, error)

func (c *ResourceMemoryClient) List(ctx context.Context, limit, offset int) ([]ResourceItem, error)

func (c *ResourceMemoryClient) Search(ctx context.Context, query string, limit int) ([]ResourceItem, error)

func (c *ResourceMemoryClient) Delete(ctx context.Context, id string) error

func (c *VaultMemoryClient) Store(ctx context.Context, key string, value any, metadata map[string]any) error

func (c *VaultMemoryClient) Get(ctx context.Context, key string) (*VaultEntry, error)

func (c *VaultMemoryClient) ListKeys(ctx context.Context, prefix string, limit int) ([]string, error)

func (c *VaultMemoryClient) Delete(ctx context.Context, key string) error

func (c *CognitiveMemoryClient) Thought(ctx context.Context, sessionID, thoughtType string, content map[string]any) (string, error)

func (c *CognitiveMemoryClient) Decision(ctx context.Context, sessionID, decision string, reasoning string, confidence float64) (string, error)

func (c *CognitiveMemoryClient) Interaction(ctx context.Context, sessionID, interactionType string, input, output map[string]any) (string, error)

func (c *CognitiveMemoryClient) GetSession(ctx context.Context, sessionID string) ([]ThoughtRecord, error)

func (c *CognitiveMemoryClient) Query(ctx context.Context, query string, types []string, limit int) ([]ThoughtRecord, error)

func (c *CognitiveMemoryClient) GetReasoningChain(ctx context.Context, chainID string) ([]ThoughtRecord, error)

type MemoryRuntimeClient struct {
	runtime *RuntimeClient
}

type EpisodicMemoryClient struct {
	runtime *RuntimeClient
}

type EpisodeItem struct {
	ID        string         `json:"id"`
	Content   string         `json:"content"`
	Timestamp string         `json:"timestamp"`
	Embedding []float32      `json:"embedding,omitempty"`
	Metadata  map[string]any `json:"metadata,omitempty"`
}

type ProceduralMemoryClient struct {
	runtime *RuntimeClient
}

type Procedure struct {
	ID          string         `json:"id"`
	Name        string         `json:"name"`
	Description string         `json:"description,omitempty"`
	Steps       []ProcStep     `json:"steps"`
	Metadata    map[string]any `json:"metadata,omitempty"`
}

type ProcStep struct {
	Order       int            `json:"order"`
	Action      string         `json:"action"`
	Parameters  map[string]any `json:"parameters,omitempty"`
	Description string         `json:"description,omitempty"`
}

type ResourceMemoryClient struct {
	runtime *RuntimeClient
}

type ResourceItem struct {
	ID          string         `json:"id"`
	Name        string         `json:"name"`
	ContentType string         `json:"content_type"`
	Size        int64          `json:"size"`
	CreatedAt   string         `json:"created_at"`
	Metadata    map[string]any `json:"metadata,omitempty"`
}

type VaultMemoryClient struct {
	runtime *RuntimeClient
}

type VaultEntry struct {
	Key       string         `json:"key"`
	Value     any            `json:"value"`
	CreatedAt string         `json:"created_at"`
	UpdatedAt string         `json:"updated_at"`
	Metadata  map[string]any `json:"metadata,omitempty"`
}

type CognitiveMemoryClient struct {
	runtime *RuntimeClient
}

type ThoughtRecord struct {
	ID        string         `json:"id"`
	SessionID string         `json:"session_id"`
	Type      string         `json:"type"`
	Content   map[string]any `json:"content"`
	Timestamp string         `json:"timestamp"`
	Metadata  map[string]any `json:"metadata,omitempty"`
}

func (c *MHNRuntimeClient) CreateNetwork(ctx context.Context, name string, patternDim int, beta float64, config map[string]any) (*MHNNetworkInfo, error)

func (c *MHNRuntimeClient) GetNetwork(ctx context.Context, networkID string) (*MHNNetworkInfo, error)

func (c *MHNRuntimeClient) ListNetworks(ctx context.Context) ([]MHNNetworkInfo, error)

func (c *MHNRuntimeClient) DeleteNetwork(ctx context.Context, networkID string) error

func (c *MHNRuntimeClient) StorePatterns(ctx context.Context, networkID string, patterns [][]float32, ids []string, metadata []map[string]any) (int, error)

func (c *MHNRuntimeClient) Retrieve(ctx context.Context, networkID string, query []float32) (*RetrievalResult, error)

func (c *MHNRuntimeClient) RetrieveK(ctx context.Context, networkID string, query []float32, k int) ([]RetrievalResult, error)

func (c *MHNRuntimeClient) Associate(ctx context.Context, networkID string, partial []float32, iterations int) (*RetrievalResult, error)

func (c *MHNRuntimeClient) Update(ctx context.Context, networkID string, patterns [][]float32, learningRate float64) error

func (c *MHNRuntimeClient) Clear(ctx context.Context, networkID string) error

func (c *MHNRuntimeClient) GetEnergy(ctx context.Context, networkID string, pattern []float32) (float64, error)

func (c *MHNRuntimeClient) GetStats(ctx context.Context) (map[string]any, error)

type MHNRuntimeClient struct {
	runtime *RuntimeClient
}

type MHNNetworkInfo struct {
	ID          string         `json:"id"`
	Name        string         `json:"name"`
	PatternDim  int            `json:"pattern_dim"`
	PatternCount int           `json:"pattern_count"`
	Beta        float64        `json:"beta"`
	Config      map[string]any `json:"config,omitempty"`
	CreatedAt   string         `json:"created_at,omitempty"`
}

type RetrievalResult struct {
	Pattern    []float32      `json:"pattern"`
	Similarity float64        `json:"similarity"`
	PatternID  string         `json:"pattern_id,omitempty"`
	Metadata   map[string]any `json:"metadata,omitempty"`
}

func (c *MLRuntimeClient) RegisterModel(ctx context.Context, name, version, framework string, modelData []byte, metadata map[string]any) (*ModelInfo, error)

func (c *MLRuntimeClient) GetModel(ctx context.Context, modelID string) (*ModelInfo, error)

func (c *MLRuntimeClient) ListModels(ctx context.Context) ([]ModelInfo, error)

func (c *MLRuntimeClient) DeleteModel(ctx context.Context, modelID string) error

func (c *MLRuntimeClient) Infer(ctx context.Context, modelID string, input any) (*InferenceResult, error)

func (c *MLRuntimeClient) BatchInfer(ctx context.Context, modelID string, inputs []any) ([]InferenceResult, error)

func (c *MLRuntimeClient) Embed(ctx context.Context, modelID string, texts []string) ([][]float32, error)

func (c *MLRuntimeClient) Classify(ctx context.Context, modelID string, input any) (map[string]float64, error)

func (c *MLRuntimeClient) GetStats(ctx context.Context) (map[string]any, error)

func (c *MLRuntimeClient) WarmUp(ctx context.Context, modelID string) error

type MLRuntimeClient struct {
	runtime *RuntimeClient
}

type ModelInfo struct {
	ID          string         `json:"id"`
	Name        string         `json:"name"`
	Version     string         `json:"version"`
	Framework   string         `json:"framework"`
	InputShape  []int          `json:"input_shape,omitempty"`
	OutputShape []int          `json:"output_shape,omitempty"`
	Metadata    map[string]any `json:"metadata,omitempty"`
	CreatedAt   string         `json:"created_at,omitempty"`
}

type InferenceResult struct {
	Output     any            `json:"output"`
	Latency    float64        `json:"latency_ms"`
	ModelID    string         `json:"model_id"`
	Metadata   map[string]any `json:"metadata,omitempty"`
}

func (c *NeurosymbolicRuntimeClient) Reason(ctx context.Context, query string, context map[string]any) (*ReasoningResult, error)

func (c *NeurosymbolicRuntimeClient) Query(ctx context.Context, query string, useNeural bool) ([]map[string]any, error)

func (c *NeurosymbolicRuntimeClient) Infer(ctx context.Context, premises []string, constraints []string) (*ReasoningResult, error)

func (c *NeurosymbolicRuntimeClient) AddKnowledge(ctx context.Context, subject, predicate, object string, metadata map[string]any) (string, error)

func (c *NeurosymbolicRuntimeClient) QueryKnowledge(ctx context.Context, subject, predicate, object string) ([]map[string]any, error)

func (c *NeurosymbolicRuntimeClient) Explain(ctx context.Context, conclusion string, maxDepth int) ([]ReasonStep, error)

func (c *NeurosymbolicRuntimeClient) Validate(ctx context.Context, conclusion string, evidence []string) (map[string]any, error)

func (c *NeurosymbolicRuntimeClient) GetStats(ctx context.Context) (map[string]any, error)

type NeurosymbolicRuntimeClient struct {
	runtime *RuntimeClient
}

type ReasoningResult struct {
	Answer     string         `json:"answer"`
	Confidence float64        `json:"confidence"`
	Evidence   []Evidence     `json:"evidence,omitempty"`
	Trace      []ReasonStep   `json:"trace,omitempty"`
	Metadata   map[string]any `json:"metadata,omitempty"`
}

type Evidence struct {
	Source     string         `json:"source"`
	Content    string         `json:"content"`
	Relevance  float64        `json:"relevance"`
	Metadata   map[string]any `json:"metadata,omitempty"`
}

type ReasonStep struct {
	Step       int            `json:"step"`
	Type       string         `json:"type"`
	Input      map[string]any `json:"input"`
	Output     map[string]any `json:"output"`
	Confidence float64        `json:"confidence"`
}

func (c *RuntimeClient) Core() *CoreRuntimeClient

func (c *RuntimeClient) KV() *KVClient

func (c *RuntimeClient) Graph() *GraphRuntimeClient

func (c *RuntimeClient) Vector() *VectorRuntimeClient

func (c *RuntimeClient) Analytics() *AnalyticsRuntimeClient

func (c *RuntimeClient) Memory() *MemoryRuntimeClient

func (c *RuntimeClient) ML() *MLRuntimeClient

func (c *RuntimeClient) SNN() *SNNRuntimeClient

func (c *RuntimeClient) Neurosymbolic() *NeurosymbolicRuntimeClient

func (c *RuntimeClient) Continual() *ContinualRuntimeClient

func (c *RuntimeClient) MHN() *MHNRuntimeClient

func (c *CoreRuntimeClient) Stats(ctx context.Context) (map[string]any, error)

func (c *CoreRuntimeClient) ListKeyspaces(ctx context.Context) ([]KeyspaceInfo, error)

func (c *CoreRuntimeClient) CreateKeyspace(ctx context.Context, name, model string, config map[string]any) (*KeyspaceInfo, error)

func (c *CoreRuntimeClient) GetKeyspace(ctx context.Context, name string) (*KeyspaceInfo, error)