dakera

package module

Go to main page

Versions in this module

v0

v0.11.103

Aug 5, 2026

Changes in this version

+ const Version

type Client

+ func (c *Client) DebugConfig(ctx context.Context) (map[string]string, error)

type StoreMemoryRequest

+ ValidFrom *int64

type UnifiedQueryRequest

+ Cursor string

type UnifiedQueryResponse

+ NextCursor *string

v0.11.102

Jul 22, 2026

v0.11.101

Jul 16, 2026

v0.11.100

Jul 5, 2026

v0.11.99

Jul 3, 2026

Changes in this version

type RecalledMemory

+ SmartScore *float32

+ WeightedScore *float32

v0.11.98

Jul 2, 2026

v0.11.97

Jun 26, 2026

v0.11.96

Jun 24, 2026

Changes in this version

type EmbeddingModel

+ const EmbeddingModelGteModernBertBase

+ const EmbeddingModelModernBertEmbedBase

v0.11.95

Jun 23, 2026

Changes in this version

type Client

+ func (c *Client) AdminTtlCleanup(ctx context.Context, namespace string) (*TtlCleanupResponse, error)

+ type TtlCleanupRequest struct

+ Namespace string

+ type TtlCleanupResponse struct

+ Message string

+ NamespacesCleaned []string

+ Success bool

+ VectorsRemoved uint64

v0.11.94

Jun 18, 2026

v0.11.93

Jun 16, 2026

Changes in this version

+ type ChatMemorySession struct

+ func NewChatMemorySession(ctx context.Context, client *Client, agentID string, ...) (*ChatMemorySession, error)

+ func (s *ChatMemorySession) AgentID() string

+ func (s *ChatMemorySession) Close(ctx context.Context) (*SessionEndResponse, error)

+ func (s *ChatMemorySession) Recall(ctx context.Context, query string, topK int) ([]RecalledMemory, error)

+ func (s *ChatMemorySession) SessionID() string

+ func (s *ChatMemorySession) Store(ctx context.Context, role, content string) (*StoreMemoryResponse, error)

+ func (s *ChatMemorySession) StoreWithOptions(ctx context.Context, role, content string, opts ChatMemorySessionOptions) (*StoreMemoryResponse, error)

+ type ChatMemorySessionOptions struct

+ ExtraTags []string

+ Importance float32

v0.11.92

Jun 16, 2026

Changes in this version

type Client

+ func (c *Client) AdminReembedStaticCount(ctx context.Context) (*StaticCountResponse, error)

type RecalledMemory

+ Tags []string

+ func (r *RecalledMemory) UnmarshalJSON(data []byte) error

+ type StaticCountResponse struct

+ StaticCount int

type StoreMemoryRequest

+ Tags []string

v0.11.91

Jun 14, 2026

v0.11.90

Jun 13, 2026

Changes in this version

type Client

+ func (c *Client) EvaluateTif(ctx context.Context, memoryID string) (TifScore, error)

+ type TifClassification string

+ const TifAskClarification

+ const TifConfidentReuse

+ const TifSurfaceContradiction

+ const TifVerifyBeforeUse

+ type TifScore struct

+ Classification TifClassification

+ Falsity float64

+ FeedbackCount uint64

+ Indeterminacy float64

+ Truth float64

+ func ComputeTifScore(history *FeedbackHistoryResponse) TifScore

+ func TifScoreFromMetadata(data map[string]interface{}) (TifScore, bool)

v0.11.89

Jun 11, 2026

Changes in this version

type HealthResponse

+ BuildSha string

v0.11.83

Jun 4, 2026

Changes in this version

type Client

+ func (c *Client) AdminDrainReembed(ctx context.Context, req DrainReembedRequest) (*DrainReembedResponse, error)

+ type DrainReembedRequest struct

+ BatchSize *int

+ MinImportance *float32

+ TimeoutSecs *int

+ type DrainReembedResponse struct

+ Cycles int

+ ElapsedMs int64

+ Processed int

+ Remaining int

+ TimedOut bool

v0.11.75

May 31, 2026

v0.11.57

May 28, 2026

Changes in this version

+ type BatchStoreMemoryItem struct

+ Content string

+ ExpiresAt *int64

+ ID string

+ Importance *float32

+ MemoryType string

+ Metadata map[string]any

+ SessionID string

+ TTLSeconds *int64

+ Tags []string

+ type BatchStoreMemoryRequest struct

+ AgentID string

+ Memories []BatchStoreMemoryItem

+ type BatchStoreMemoryResponse struct

+ Stored []BatchStoredMemory

+ StoredCount int

+ TotalEmbeddingTimeMs int64

+ type BatchStoredMemory struct

+ AgentID string

+ Content string

+ CreatedAt int64

+ ID string

+ Importance float32

+ Tags []string

type Client

+ func (c *Client) StoreMemoriesBatch(ctx context.Context, req BatchStoreMemoryRequest) (*BatchStoreMemoryResponse, error)

v0.11.56

May 17, 2026

Changes in this version

+ type AdminBackupInfo struct

+ BackupID string

+ BackupType string

+ CompletedAt *uint64

+ Compression string

+ CreatedAt uint64

+ DurationSeconds *uint64

+ Encrypted bool

+ Error string

+ Name string

+ Namespaces []string

+ SizeBytes uint64

+ Status string

+ StoragePath string

+ VectorCount uint64

+ type AgentConsolidateResponse struct

+ AgentID string

+ AnchorIDs []string

+ ClustersFound int

+ DeprecatedIDs []string

+ MemoriesDeprecated int

+ MemoriesScanned int

+ Reason string

+ Skipped *bool

+ type AgentConsolidationConfig struct

+ Enabled bool

+ Epsilon float64

+ MinSamples int

+ SoftDeprecationDays int

+ type AgentConsolidationLogEntry struct

+ AnchorIDs []string

+ ClustersFound int

+ DeprecatedIDs []string

+ MemoriesDeprecated int

+ Timestamp int64

+ type BackupListResponse struct

+ Backups []AdminBackupInfo

+ Total uint64

+ type BackupSchedule struct

+ BackupType string

+ Compression string

+ Cron string

+ Enabled bool

+ Encrypt bool

+ LastBackupAt *uint64

+ MaxBackups uint32

+ Namespaces []string

+ NextBackupAt *uint64

+ RetentionDays uint32

+ type BulkDeleteResponse struct

+ Deleted int

+ Errors []string

+ Failed int

+ type BulkUpdateResponse struct

+ Errors []string

+ Failed int

+ Updated int

type Client

+ func (c *Client) AdminBackgroundActivity(ctx context.Context) (map[string]interface{}, error)

+ func (c *Client) AdminCheckQuota(ctx context.Context, namespace string, req QuotaCheckRequest) (*QuotaCheckResult, error)

+ func (c *Client) AdminClearSlowQueries(ctx context.Context, namespace string) (map[string]interface{}, error)

+ func (c *Client) AdminClusterReplication(ctx context.Context) (*ReplicationStatus, error)

+ func (c *Client) AdminCreateBackup(ctx context.Context, req CreateBackupRequest) (*CreateBackupResponse, error)

+ func (c *Client) AdminDeleteBackup(ctx context.Context, backupID string) (map[string]interface{}, error)

+ func (c *Client) AdminDeleteQuota(ctx context.Context, namespace string) (map[string]interface{}, error)

+ func (c *Client) AdminDisableMaintenance(ctx context.Context, req DisableMaintenanceRequest) (*MaintenanceStatus, error)

+ func (c *Client) AdminDownloadBackup(ctx context.Context, backupID string) ([]byte, error)

+ func (c *Client) AdminEnableMaintenance(ctx context.Context, req EnableMaintenanceRequest) (*MaintenanceStatus, error)

+ func (c *Client) AdminGetBackup(ctx context.Context, backupID string) (*AdminBackupInfo, error)

+ func (c *Client) AdminGetBackupSchedule(ctx context.Context) (*BackupSchedule, error)

+ func (c *Client) AdminGetDefaultQuota(ctx context.Context) (*DefaultQuotaResponse, error)

+ func (c *Client) AdminGetQuota(ctx context.Context, namespace string) (*QuotaStatus, error)

+ func (c *Client) AdminGetRestoreStatus(ctx context.Context, restoreID string) (*RestoreBackupResponse, error)

+ func (c *Client) AdminListBackups(ctx context.Context) (*BackupListResponse, error)

+ func (c *Client) AdminListQuotas(ctx context.Context) (*QuotaListResponse, error)

+ func (c *Client) AdminListShards(ctx context.Context) (*ShardListResponse, error)

+ func (c *Client) AdminListSlowQueries(ctx context.Context, namespace, queryType string, limit int) ([]map[string]interface{}, error)

+ func (c *Client) AdminMaintenanceStatus(ctx context.Context) (*MaintenanceStatus, error)

+ func (c *Client) AdminMemoryTypeStats(ctx context.Context) (*MemoryTypeStatsResponse, error)

+ func (c *Client) AdminMigrateNamespaceDimensions(ctx context.Context, req MigrateNamespaceDimensionsRequest) (*MigrateDimensionsResponse, error)

+ func (c *Client) AdminRebalanceShards(ctx context.Context, req ShardRebalanceRequest) (*ShardRebalanceResponse, error)

+ func (c *Client) AdminRestoreBackup(ctx context.Context, req RestoreBackupRequest) (*RestoreBackupResponse, error)

+ func (c *Client) AdminSetDefaultQuota(ctx context.Context, req SetDefaultQuotaRequest) (*SetQuotaResponse, error)

+ func (c *Client) AdminSetQuota(ctx context.Context, namespace string, req SetQuotaRequest) (*SetQuotaResponse, error)

+ func (c *Client) AdminSlowQuerySummary(ctx context.Context) (map[string]interface{}, error)

+ func (c *Client) AdminStorageTierOverview(ctx context.Context) (*StorageTierOverview, error)

+ func (c *Client) AdminTtlStats(ctx context.Context) (*TtlStatsResponse, error)

+ func (c *Client) AdminUpdateBackupSchedule(ctx context.Context, req UpdateBackupScheduleRequest) (*BackupSchedule, error)

+ func (c *Client) AdminUpdateSlowQueryConfig(ctx context.Context, config map[string]interface{}) (map[string]interface{}, error)

+ func (c *Client) AdminUploadBackup(ctx context.Context, data []byte) (map[string]interface{}, error)

+ func (c *Client) BulkDeleteVectors(ctx context.Context, namespace string, filter map[string]interface{}) (*BulkDeleteResponse, error)

+ func (c *Client) BulkUpdateVectors(ctx context.Context, namespace string, filter map[string]interface{}, ...) (*BulkUpdateResponse, error)

+ func (c *Client) ConsolidateAgent(ctx context.Context, agentID string) (*AgentConsolidateResponse, error)

+ func (c *Client) CountVectors(ctx context.Context, namespace string, filter map[string]interface{}) (*CountVectorsResponse, error)

+ func (c *Client) FulltextDelete(ctx context.Context, namespace string, ids []string) (*FulltextDeleteResponse, error)

+ func (c *Client) FulltextStats(ctx context.Context, namespace string) (*FullTextIndexStats, error)

+ func (c *Client) GetConsolidationLog(ctx context.Context, agentID string) ([]AgentConsolidationLogEntry, error)

+ func (c *Client) GetNamespaceEntityConfig(ctx context.Context, namespace string) (*NamespaceEntityConfig, error)

+ func (c *Client) GetNamespaceExtractor(ctx context.Context, namespace string) (*ExtractorConfigResponse, error)

+ func (c *Client) HealthLive(ctx context.Context) (*LivenessResponse, error)

+ func (c *Client) HealthReady(ctx context.Context) (*ReadinessResponse, error)

+ func (c *Client) ImportJobStatus(ctx context.Context, jobID string) (*ImportJobStatus, error)

+ func (c *Client) OpsCompact(ctx context.Context, req CompactionRequest) (*CompactionResponse, error)

+ func (c *Client) OpsDiagnostics(ctx context.Context) (map[string]interface{}, error)

+ func (c *Client) OpsGetJob(ctx context.Context, jobID string) (*JobInfo, error)

+ func (c *Client) OpsListJobs(ctx context.Context) ([]JobInfo, error)

+ func (c *Client) OpsShutdown(ctx context.Context) (map[string]interface{}, error)

+ func (c *Client) PatchConsolidationConfig(ctx context.Context, agentID string, patch ConsolidationConfigPatch) (*AgentConsolidationConfig, error)

+ func (c *Client) RouteQuery(ctx context.Context, req RouteRequest) (*RouteResponse, error)

+ type CompactionRequest struct

+ Force bool

+ Namespace string

+ type CompactionResponse struct

+ JobID string

+ Message string

+ type ConsolidationConfigPatch struct

+ Enabled *bool

+ Epsilon *float64

+ MinSamples *int

+ SoftDeprecationDays *int

+ type CountVectorsResponse struct

+ Count int

+ Namespace string

+ type CreateBackupRequest struct

+ BackupType string

+ Compression string

+ Encrypt *bool

+ Name string

+ Namespaces []string

+ type CreateBackupResponse struct

+ Backup AdminBackupInfo

+ EstimatedCompletion *uint64

+ type DefaultQuotaResponse struct

+ Config *QuotaConfig

+ type DisableMaintenanceRequest struct

+ Force *bool

type Document

+ Text string

type DocumentInput

+ Text string

+ type EnableMaintenanceRequest struct

+ DurationMinutes *uint32

+ NodeIDs []string

+ Reason string

+ RejectRequests bool

+ type ExtractorConfigResponse struct

+ BaseURL string

+ Model string

+ Provider string

+ type FullTextIndexStats struct

+ AvgDocLength float64

+ DocumentCount uint32

+ UniqueTerms int

type FullTextSearchResult

+ Text string

+ type FulltextDeleteRequest struct

+ IDs []string

+ type FulltextDeleteResponse struct

+ DeletedCount int

+ type ImportJobStatus struct

+ Errors []string

+ FinishedAt *uint64

+ Format string

+ Imported int

+ JobID string

+ Skipped int

+ StartedAt uint64

+ Status string

+ Total int

+ type JobInfo struct

+ CompletedAt *uint64

+ CreatedAt uint64

+ ID string

+ JobType string

+ Message string

+ Metadata map[string]string

+ Progress uint8

+ StartedAt *uint64

+ Status string

+ type LivenessResponse struct

+ Alive bool

+ UptimeSeconds int64

+ Version string

+ type MaintenanceStatus struct

+ Enabled bool

+ EnabledAt *uint64

+ NodesInMaintenance []string

+ Reason string

+ RejectingRequests bool

+ ScheduledEnd *uint64

+ type MemoryTypeStatsResponse struct

+ AgentNamespaces uint64

+ Episodic uint64

+ Procedural uint64

+ Semantic uint64

+ Total uint64

+ Working uint64

+ type MigrateDimensionsResponse struct

+ AlreadyCurrent int

+ Failed int

+ Migrated int

+ Results []NamespaceMigrationResult

+ type MigrateNamespaceDimensionsRequest struct

+ Namespaces []string

+ TargetDimension int

+ type NamespaceEntityConfig struct

+ EntityTypes []string

+ ExtractEntities bool

+ Namespace string

+ type NamespaceMigrationResult struct

+ Error *string

+ Namespace string

+ OriginalDimension int

+ Status string

+ VectorsMigrated int

+ VectorsSkipped int

+ type NodeReplicationLag struct

+ LagMs uint64

+ NodeID string

+ Status string

+ type QuotaCheckRequest struct

+ Dimensions *int

+ MetadataBytes *int

+ VectorIDs []string

+ type QuotaCheckResult struct

+ Allowed bool

+ ExceededQuota string

+ Reason string

+ Usage QuotaUsage

+ type QuotaConfig struct

+ Enforcement string

+ MaxDimensions *int

+ MaxMetadataBytes *int

+ MaxStorageBytes *uint64

+ MaxVectors *uint64

+ type QuotaListResponse struct

+ DefaultConfig *QuotaConfig

+ Quotas []QuotaStatus

+ Total uint64

+ type QuotaStatus struct

+ Config QuotaConfig

+ ExceededQuotas []string

+ IsExceeded bool

+ Namespace string

+ StorageUsagePercent *float32

+ Usage QuotaUsage

+ VectorUsagePercent *float32

+ type QuotaUsage struct

+ AvgDimensions *int

+ AvgMetadataBytes *int

+ LastUpdated uint64

+ StorageBytes uint64

+ VectorCount uint64

+ type ReadinessCheckComponent struct

+ Message string

+ Status string

+ type ReadinessResponse struct

+ Checks map[string]ReadinessCheckComponent

+ Ready bool

+ Version string

+ type ReplicationStatus struct

+ HealthyReplicas uint32

+ ReplicationFactor uint32

+ ReplicationLag []NodeReplicationLag

+ TotalNodes uint32

+ type RestoreBackupRequest struct

+ BackupID string

+ Overwrite *bool

+ PointInTime *uint64

+ TargetNamespaces []string

+ type RestoreBackupResponse struct

+ BackupID string

+ CompletedAt *uint64

+ DurationSeconds *uint64

+ Error string

+ EstimatedCompletion *uint64

+ Namespaces []string

+ ProgressPercent *uint8

+ RestoreID string

+ StartedAt uint64

+ Status string

+ VectorsRestored *uint64

+ type RouteMatch struct

+ Description string

+ Namespace string

+ Similarity float64

+ type RouteRequest struct

+ MinSimilarity float32

+ Model string

+ Query string

+ TopK int

+ type RouteResponse struct

+ EmbeddingTimeMs uint64

+ Model string

+ Routes []RouteMatch

+ type SetDefaultQuotaRequest struct

+ Config *QuotaConfig

+ type SetQuotaRequest struct

+ Config QuotaConfig

+ type SetQuotaResponse struct

+ Config QuotaConfig

+ Message string

+ Namespace string

+ Success bool

+ type ShardInfo struct

+ Namespace string

+ PrimaryNode string

+ ReplicaNodes []string

+ ShardID string

+ SizeBytes uint64

+ State string

+ VectorCount uint64

+ type ShardListResponse struct

+ Shards []ShardInfo

+ Total uint32

+ type ShardMove struct

+ FromNode string

+ ShardID string

+ ToNode string

+ type ShardRebalanceRequest struct

+ DryRun bool

+ ShardIDs []string

+ type ShardRebalanceResponse struct

+ EstimatedSeconds *uint64

+ Initiated bool

+ OperationID string

+ PlannedMoves []ShardMove

+ ShardsAffected uint32

+ type StorageTierOverview struct

+ Activity TierActivity

+ Architecture []TierInfo

+ Config TierConfig

+ TiersEnabled bool

+ type TierActivity struct

+ CacheHitRate float64

+ Demotions uint64

+ DemotionsToCold uint64

+ DemotionsToWarm uint64

+ Promotions uint64

+ PromotionsToHot uint64

+ StorageBackend string

+ type TierConfig struct

+ AutoTierEnabled bool

+ HotTierCapacity int

+ HotToWarmThresholdSecs uint64

+ TierCheckIntervalSecs uint64

+ WarmToColdThresholdSecs uint64

+ type TierInfo struct

+ Capacity string

+ CurrentCount uint64

+ Description string

+ HitCount uint64

+ HitRate float64

+ Name string

+ Status string

+ TargetLatency string

+ Technology string

+ TierType string

+ type TtlNamespaceStats struct

+ ExpiredPendingCleanup uint64

+ ExpiringWithinDay uint64

+ ExpiringWithinHour uint64

+ Namespace string

+ VectorsWithTtl uint64

+ type TtlStatsResponse struct

+ Namespaces []TtlNamespaceStats

+ TotalExpired uint64

+ TotalWithTtl uint64

+ type UpdateBackupScheduleRequest struct

+ BackupType string

+ Compression string

+ Cron string

+ Enabled *bool

+ Encrypt *bool

+ MaxBackups *uint32

+ Namespaces []string

+ RetentionDays *uint32

v0.11.55

May 17, 2026

Changes in this version

type ConsolidateRequest

+ AgentID string

type HybridSearchOptions

+ VectorWeight float32

type Memory

+ AgentID string

+ LastAccessedAt int64

+ Tags []string

type NamespaceInfo

+ Dimension int

+ Distance string

type RecallRequest

+ AgentID string

type SearchMemoriesRequest

+ AgentID string

type StoreMemoryRequest

+ AgentID string

type UpdateImportanceRequest

+ AgentID string

v0.11.54

May 13, 2026

v0.11.53

May 8, 2026

v0.11.51

May 6, 2026

Changes in this version

+ const OpArrayContains

+ const OpArrayContainsAll

+ const OpArrayContainsAny

+ const OpContains

+ const OpEndsWith

+ const OpExists

+ const OpGlob

+ const OpIContains

+ const OpRegex

+ const OpStartsWith

+ func ArrayContains(value interface{}) map[string]interface

+ func ArrayContainsAll(values ...interface{}) map[string]interface

+ func ArrayContainsAny(values ...interface{}) map[string]interface

+ func Contains(substr string) map[string]interface

+ func EndsWith(suffix string) map[string]interface

+ func Exists(present bool) map[string]interface

+ func Glob(pattern string) map[string]interface

+ func IContains(substr string) map[string]interface

+ func Regex(pattern string) map[string]interface

+ func StartsWith(prefix string) map[string]interface

type Client

+ func (c *Client) AdminFulltextReindex(ctx context.Context, namespace string) (*FulltextReindexResponse, error)

+ type FulltextReindexNamespaceResult struct

+ AlreadyIndexed int

+ Namespace string

+ NewlyIndexed int

+ ParseFailures int

+ VectorsScanned int

+ type FulltextReindexResponse struct

+ Details []FulltextReindexNamespaceResult

+ NamespacesProcessed int

+ TotalIndexed int

+ TotalSkipped int

v0.11.36

Apr 26, 2026

v0.11.31

Apr 25, 2026

v0.11.30

Apr 25, 2026

v0.11.4

Apr 18, 2026

Changes in this version

type RecallRequest

+ Iterations *uint8

v0.11.3

Apr 18, 2026

Changes in this version

type RecallRequest

+ VectorWeight *float32

v0.11.2

Apr 16, 2026

v0.11.1

Apr 16, 2026

v0.11.0

Apr 15, 2026

Changes in this version

+ type FusionStrategy string

+ const FusionStrategyMinMax

+ const FusionStrategyRRF

type RecallRequest

+ Fusion *FusionStrategy

+ Neighborhood *bool

v0.10.2

Apr 13, 2026

Changes in this version

type EmbeddingModel

+ const EmbeddingModelBGELarge

type RecallRequest

+ Rerank *bool

type SearchMemoriesRequest

+ Rerank *bool

v0.10.1

Apr 13, 2026

Changes in this version

type ConsolidateResponse

+ ConsolidatedMemory *Memory

+ MemoriesRemoved int

+ SourceMemoryIDs []string

type StoreMemoryResponse

+ EmbeddingTimeMs *int64

+ Memory *Memory

v0.10.0

Apr 12, 2026

Changes in this version

type Client

+ func (c *Client) CompressAgent(ctx context.Context, agentID string) (*CompressResponse, error)

+ type CompressResponse struct

+ AgentID string

+ DurationMs float64

+ MemoriesAfter int64

+ MemoriesBefore int64

+ RemovedCount int64

type MemoryPolicy

+ DedupOnStore *bool

+ DedupThreshold *float32

type RecallRequest

+ Routing *RoutingMode

+ type RoutingMode string

+ const RoutingModeAuto

+ const RoutingModeBM25

+ const RoutingModeHybrid

+ const RoutingModeVector

type SearchMemoriesRequest

+ Routing *RoutingMode

v0.9.15

Apr 8, 2026

v0.9.14

Apr 7, 2026

Changes in this version

type Client

+ func (c *Client) GetWakeUpContext(ctx context.Context, agentID string, opts *WakeUpOptions) (*WakeUpResponse, error)

+ type WakeUpOptions struct

+ MinImportance *float32

+ TopN *int

+ type WakeUpResponse struct

+ AgentID string

+ Memories []Memory

+ TotalAvailable int64

v0.9.13

Apr 6, 2026

Changes in this version

type Session

+ ID string

+ MemoryCount int

+ Summary string

+ type SessionEndResponse struct

+ MemoryCount int

+ Session Session

+ type SessionStartResponse struct

+ Session Session

v0.9.12

Apr 6, 2026

Changes in this version

type Client

+ func (c *Client) GetKpis(ctx context.Context) (*KpiSnapshot, error)

+ type KpiSnapshot struct

+ ActiveAgentsCount uint64

+ ApiErrorRate5xxPct float64

+ CrossAgentNetworkNodeCount uint64

+ MemoryRetention7dPct float64

+ RecallLatencyP50Ms float64

+ RecallLatencyP99Ms float64

+ SessionCountWeek uint64

+ StoreLatencyP50Ms float64

v0.9.11

Apr 1, 2026

Changes in this version

type MemoryPolicy

+ RateLimitEnabled *bool

+ RateLimitRecallsPerMinute *uint32

+ RateLimitStoresPerMinute *uint32

v0.9.10

Mar 31, 2026

Changes in this version

type RecallRequest

+ AssociatedMemoriesDepth *int

+ AssociatedMemoriesMinWeight *float32

type RecalledMemory

+ Depth *int

v0.9.9

Mar 31, 2026

Changes in this version

type MemoryPolicy

+ ConsolidatedCount *uint64

+ ConsolidationEnabled *bool

+ ConsolidationIntervalHours *uint32

+ ConsolidationThreshold *float64

type RecallRequest

+ Since *string

+ Until *string

v0.9.8

Mar 31, 2026

Changes in this version

type Client

+ func (c *Client) GetMemoryPolicy(ctx context.Context, namespace string) (*MemoryPolicy, error)

+ func (c *Client) SetMemoryPolicy(ctx context.Context, namespace string, policy MemoryPolicy) (*MemoryPolicy, error)

+ type MemoryPolicy struct

+ EpisodicDecay *string

+ EpisodicTTLSeconds *int64

+ ProceduralDecay *string

+ ProceduralTTLSeconds *int64

+ SemanticDecay *string

+ SemanticTTLSeconds *int64

+ SpacedRepetitionBaseIntervalSeconds *int64

+ SpacedRepetitionFactor *float64

+ WorkingDecay *string

+ WorkingTTLSeconds *int64

type RecallRequest

+ AssociatedMemoriesCap *int

+ IncludeAssociated bool

+ type RecallResponse struct

+ AssociatedMemories []RecalledMemory

+ Memories []RecalledMemory

v0.9.7

Mar 31, 2026

Changes in this version

type Client

+ func (c *Client) KnowledgeExport(ctx context.Context, agentID, format string) (*KgExportResponse, error)

+ func (c *Client) KnowledgePath(ctx context.Context, agentID, fromID, toID string) (*KgPathResponse, error)

+ func (c *Client) KnowledgeQuery(ctx context.Context, agentID string, rootID string, edgeType string, ...) (*KgQueryResponse, error)

+ type KgExportResponse struct

+ AgentID string

+ EdgeCount int

+ Edges []GraphEdge

+ Format string

+ NodeCount int

+ type KgPathResponse struct

+ AgentID string

+ FromID string

+ HopCount int

+ Path []string

+ ToID string

+ type KgQueryResponse struct

+ AgentID string

+ EdgeCount int

+ Edges []GraphEdge

+ NodeCount int

v0.9.6

Mar 30, 2026

Changes in this version

type Client

+ func (c *Client) OdeExtractEntities(ctx context.Context, req ExtractEntitiesRequest) (*ExtractEntitiesResponse, error)

type ClientOptions

+ OdeURL string

+ type ExtractEntitiesRequest struct

+ AgentID string

+ Content string

+ EntityTypes []string

+ MemoryID string

+ type ExtractEntitiesResponse struct

+ Entities []OdeEntity

+ Model string

+ ProcessingTimeMs int

+ type OdeEntity struct

+ End int

+ Label string

+ Score float64

+ Start int

+ Text string

v0.9.5

Mar 30, 2026

Changes in this version

+ type AuditEvent struct

+ AgentID string

+ Details map[string]interface{}

+ EventType string

+ ID string

+ Namespace string

+ Timestamp int64

+ type AuditExportResponse struct

+ Count int

+ Data string

+ Format string

+ type AuditListResponse struct

+ Cursor string

+ Events []AuditEvent

+ Total int

+ type AuditQuery struct

+ AgentID string

+ Cursor string

+ EventType string

+ FromTs int64

+ Limit int

+ ToTs int64

type Client

+ func (c *Client) ConfigureNamespaceExtractor(ctx context.Context, namespace string, provider string, model string) error

+ func (c *Client) ExportAudit(ctx context.Context, format string, agentID string, eventType string, ...) (*AuditExportResponse, error)

+ func (c *Client) ExportMemories(ctx context.Context, format string, agentID string, namespace string, ...) (*MemoryExportResponse, error)

+ func (c *Client) ExtractText(ctx context.Context, text string, namespace string, provider string, ...) (*ExtractionResult, error)

+ func (c *Client) ImportMemories(ctx context.Context, data interface{}, format string, agentID string, ...) (*MemoryImportResponse, error)

+ func (c *Client) ListAuditEvents(ctx context.Context, query AuditQuery) (*AuditListResponse, error)

+ func (c *Client) ListExtractProviders(ctx context.Context) ([]ExtractionProviderInfo, error)

+ func (c *Client) RotateEncryptionKey(ctx context.Context, newKey string, namespace string) (*RotateEncryptionKeyResponse, error)

+ func (c *Client) StreamAuditEvents(ctx context.Context, agentID string, eventType string) (<-chan EventResult, error)

type ClusterStatus

+ RedisHealthy *bool

type ConsolidateRequest

+ Config *ConsolidationConfig

type ConsolidateResponse

+ Log []ConsolidationLogEntry

+ type ConsolidationConfig struct

+ Algorithm string

+ Eps *float32

+ MinSamples *int

+ type ConsolidationLogEntry struct

+ DurationMs float64

+ MemoriesAfter int

+ MemoriesBefore int

+ Step string

+ type ExtractionProviderInfo struct

+ Available bool

+ Models []string

+ Name string

+ type ExtractionResult struct

+ DurationMs float64

+ Entities []map[string]interface{}

+ Model string

+ Provider string

+ type MemoryExportResponse struct

+ Count int

+ Data []map[string]interface{}

+ Format string

+ type MemoryImportResponse struct

+ Errors []string

+ ImportedCount int

+ SkippedCount int

+ type RotateEncryptionKeyRequest struct

+ Namespace string

+ NewKey string

+ type RotateEncryptionKeyResponse struct

+ Namespaces []string

+ Rotated int

+ Skipped int

v0.9.3

Mar 29, 2026

Changes in this version

type Client

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

v0.9.2

Mar 27, 2026

Changes in this version

+ type AgentFeedbackSummary struct

+ AgentID string

+ Downvotes uint64

+ Flags uint64

+ HealthScore float32

+ TotalFeedback uint64

+ Upvotes uint64

type Client

+ func (c *Client) CreateNamespaceKey(ctx context.Context, namespace string, req CreateNamespaceKeyRequest) (*CreateNamespaceKeyResponse, error)

+ func (c *Client) DeleteNamespaceKey(ctx context.Context, namespace string, keyID string) (*KeySuccessResponse, error)

+ func (c *Client) FeedbackMemory(ctx context.Context, memoryID string, agentID string, signal FeedbackSignal) (*FeedbackResponse, error)

+ func (c *Client) GetAgentFeedbackSummary(ctx context.Context, agentID string) (*AgentFeedbackSummary, error)

+ func (c *Client) GetFeedbackHealth(ctx context.Context, agentID string) (*FeedbackHealthResponse, error)

+ func (c *Client) GetMemoryFeedbackHistory(ctx context.Context, memoryID string) (*FeedbackHistoryResponse, error)

+ func (c *Client) ListNamespaceKeys(ctx context.Context, namespace string) (*ListNamespaceKeysResponse, error)

+ func (c *Client) NamespaceKeyUsage(ctx context.Context, namespace string, keyID string) (*NamespaceKeyUsageResponse, error)

+ func (c *Client) PatchMemoryImportance(ctx context.Context, memoryID string, agentID string, importance float32) (*FeedbackResponse, error)

+ type CreateNamespaceKeyRequest struct

+ ExpiresInDays *int

+ Name string

+ type CreateNamespaceKeyResponse struct

+ CreatedAt int64

+ ExpiresAt *int64

+ Key string

+ KeyID string

+ Name string

+ Namespace string

+ Warning string

+ type FeedbackHealthResponse struct

+ AgentID string

+ AvgImportance float32

+ HealthScore float32

+ MemoryCount int

+ type FeedbackHistoryEntry struct

+ NewImportance float32

+ OldImportance float32

+ Signal FeedbackSignal

+ Timestamp uint64

+ type FeedbackHistoryResponse struct

+ Entries []FeedbackHistoryEntry

+ MemoryID string

+ type FeedbackResponse struct

+ MemoryID string

+ NewImportance float32

+ Signal FeedbackSignal

+ type FeedbackSignal string

+ const FeedbackSignalDownvote

+ const FeedbackSignalFlag

+ const FeedbackSignalNegative

+ const FeedbackSignalPositive

+ const FeedbackSignalUpvote

+ type KeySuccessResponse struct

+ Message string

+ Success bool

+ type ListNamespaceKeysResponse struct

+ Keys []NamespaceKeyInfo

+ Namespace string

+ Total int

+ type MemoryFeedbackBodyRequest struct

+ AgentID string

+ Signal FeedbackSignal

+ type MemoryImportancePatchRequest struct

+ AgentID string

+ Importance float32

+ type NamespaceKeyInfo struct

+ Active bool

+ CreatedAt int64

+ ExpiresAt *int64

+ KeyID string

+ Name string

+ Namespace string

+ type NamespaceKeyUsageResponse struct

+ AvgLatencyMs float64

+ BytesTransferred uint64

+ FailedRequests uint64

+ KeyID string

+ Namespace string

+ SuccessfulRequests uint64

+ TotalRequests uint64

v0.9.0

Mar 26, 2026

Changes in this version

type Client

+ func (c *Client) AgentGraphExport(ctx context.Context, agentID, format string) (*GraphExport, error)

+ func (c *Client) ConfigureNamespaceNer(ctx context.Context, namespace string, config NamespaceNerConfig) (map[string]interface{}, error)

+ func (c *Client) ExtractEntities(ctx context.Context, text string, entityTypes []string) (*EntityExtractionResponse, error)

+ func (c *Client) MemoryEntities(ctx context.Context, memoryID string) (*MemoryEntitiesResponse, error)

+ func (c *Client) MemoryGraph(ctx context.Context, memoryID string, opts *GraphOptions) (*MemoryGraph, error)

+ func (c *Client) MemoryLink(ctx context.Context, sourceID, targetID string, edgeType EdgeType) (*GraphLinkResponse, error)

+ func (c *Client) MemoryPath(ctx context.Context, sourceID, targetID string) (*GraphPath, error)

+ func (c *Client) SubscribeAgentMemories(ctx context.Context, agentID string, tags []string) (<-chan MemoryEventResult, error)

+ type EdgeType string

+ const EdgeTypeLinkedBy

+ const EdgeTypePrecedes

+ const EdgeTypeRelatedTo

+ const EdgeTypeSharesEntity

+ type EntityExtractionResponse struct

+ Entities []ExtractedEntity

+ type ExtractedEntity struct

+ EntityType string

+ Score float64

+ Value string

+ type GraphEdge struct

+ CreatedAt int64

+ EdgeType EdgeType

+ ID string

+ SourceID string

+ TargetID string

+ Weight float64

+ type GraphExport struct

+ AgentID string

+ Data string

+ EdgeCount int64

+ Format string

+ NodeCount int64

+ type GraphLinkRequest struct

+ EdgeType EdgeType

+ TargetID string

+ type GraphLinkResponse struct

+ Edge GraphEdge

+ type GraphNode struct

+ ContentPreview string

+ Depth int

+ Importance float64

+ MemoryID string

+ type GraphOptions struct

+ Depth int

+ Types []EdgeType

+ type GraphPath struct

+ Edges []GraphEdge

+ Hops int

+ Path []string

+ SourceID string

+ TargetID string

+ type MemoryEntitiesResponse struct

+ Entities []ExtractedEntity

+ MemoryID string

+ type MemoryGraph struct

+ Depth int

+ Edges []GraphEdge

+ Nodes []GraphNode

+ RootID string

+ type NamespaceNerConfig struct

+ EntityTypes []string

+ ExtractEntities bool

v0.8.6

Mar 25, 2026

Changes in this version

type OpsStats

+ State string

v0.8.5

Mar 25, 2026

Changes in this version

type Client

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

+ type OpsStats struct

+ NamespaceCount int64

+ Timestamp int64

+ TotalVectors int64

+ UptimeSeconds int64

+ Version string

v0.8.3

Mar 23, 2026

Changes in this version

type DakeraEvent

+ Timestamp int64

v0.8.2

Mar 23, 2026

v0.8.1

Mar 23, 2026

v0.8.0

Mar 23, 2026

v0.7.3

Mar 23, 2026

Changes in this version

type Client

+ func (c *Client) DecayConfig(ctx context.Context) (*DecayConfigResponse, error)

+ func (c *Client) DecayStats(ctx context.Context) (*DecayStatsResponse, error)

+ func (c *Client) DecayUpdateConfig(ctx context.Context, req DecayConfigUpdateRequest) (*DecayConfigUpdateResponse, error)

+ type DecayConfigResponse struct

+ HalfLifeHours float64

+ MinImportance float32

+ Strategy string

+ type DecayConfigUpdateRequest struct

+ HalfLifeHours *float64

+ MinImportance *float32

+ Strategy *string

+ type DecayConfigUpdateResponse struct

+ Config DecayConfigResponse

+ Message string

+ Success bool

+ type DecayStatsResponse struct

+ CyclesRun uint64

+ LastCycle *LastDecayCycleStats

+ LastRunAt *uint64

+ TotalDecayed uint64

+ TotalDeleted uint64

+ type LastDecayCycleStats struct

+ MemoriesDecayed int

+ MemoriesDeleted int

+ MemoriesProcessed int

+ NamespacesProcessed int

type StoreMemoryRequest

+ ExpiresAt *int64

v0.7.2

Mar 23, 2026

Changes in this version

+ type AutoPilotConfig struct

+ ConsolidationIntervalHours uint64

+ DedupIntervalHours uint64

+ DedupThreshold float32

+ Enabled bool

+ type AutoPilotConfigRequest struct

+ ConsolidationIntervalHours *uint64

+ DedupIntervalHours *uint64

+ DedupThreshold *float32

+ Enabled *bool

+ type AutoPilotConfigResponse struct

+ Config AutoPilotConfig

+ Message string

+ Success bool

+ type AutoPilotConsolidationResult struct

+ ClustersMerged int

+ MemoriesConsolidated int

+ MemoriesScanned int

+ NamespacesProcessed int

+ type AutoPilotDedupResult struct

+ DuplicatesRemoved int

+ MemoriesScanned int

+ NamespacesProcessed int

+ type AutoPilotStatusResponse struct

+ Config AutoPilotConfig

+ LastConsolidation *ConsolidationResultSnapshot

+ LastConsolidationAt *uint64

+ LastDedup *DedupResultSnapshot

+ LastDedupAt *uint64

+ TotalConsolidated uint64

+ TotalDedupRemoved uint64

+ type AutoPilotTriggerResponse struct

+ Action string

+ Consolidation *AutoPilotConsolidationResult

+ Dedup *AutoPilotDedupResult

+ Message string

+ Success bool

type Client

+ func (c *Client) AutopilotStatus(ctx context.Context) (*AutoPilotStatusResponse, error)

+ func (c *Client) AutopilotTrigger(ctx context.Context, action string) (*AutoPilotTriggerResponse, error)

+ func (c *Client) AutopilotUpdateConfig(ctx context.Context, req AutoPilotConfigRequest) (*AutoPilotConfigResponse, error)

+ type ConsolidationResultSnapshot struct

+ ClustersMerged int

+ MemoriesConsolidated int

+ MemoriesScanned int

+ NamespacesProcessed int

+ type DedupResultSnapshot struct

+ DuplicatesRemoved int

+ MemoriesScanned int

+ NamespacesProcessed int

v0.7.1

Mar 22, 2026

v0.7.0

Mar 22, 2026

Changes in this version

+ type BatchForgetRequest struct

+ AgentID string

+ Filter BatchMemoryFilter

+ type BatchForgetResponse struct

+ DeletedCount int

+ type BatchMemoryFilter struct

+ CreatedAfter *int64

+ CreatedBefore *int64

+ MaxImportance *float32

+ MemoryType string

+ MinImportance *float32

+ SessionID string

+ Tags []string

+ type BatchRecallRequest struct

+ AgentID string

+ Filter BatchMemoryFilter

+ Limit int

+ type BatchRecallResponse struct

+ Filtered int

+ Memories []RecalledMemory

+ Total int

type Client

+ func (c *Client) BatchForget(ctx context.Context, req BatchForgetRequest) (*BatchForgetResponse, error)

+ func (c *Client) BatchRecall(ctx context.Context, req BatchRecallRequest) (*BatchRecallResponse, error)

+ func (c *Client) LastRateLimitHeaders() *RateLimitHeaders

type ClientOptions

+ ConnectTimeout time.Duration

+ RetryBackoff *RetryConfig

+ type RateLimitHeaders struct

+ Limit int64

+ QuotaLimit int64

+ QuotaUsed int64

+ Remaining int64

+ Reset int64

+ type RetryConfig struct

+ BaseDelay time.Duration

+ Jitter bool

+ MaxDelay time.Duration

+ MaxRetries int

+ func DefaultRetryConfig() RetryConfig

v0.6.2

Mar 21, 2026

Changes in this version

type CrossAgentNetworkResponse

+ NodeCount int

v0.6.1

Mar 20, 2026

Changes in this version

+ func IsAuthorizationError(err error) bool

+ type AuthorizationError struct

+ func NewAuthorizationError(message string, statusCode int, code ErrorCode, body interface{}) *AuthorizationError

+ func (e *AuthorizationError) Error() string

type DakeraError

+ Code ErrorCode

+ type ErrorCode string

+ const ErrorCodeApiKeyExpired

+ const ErrorCodeAuthenticationRequired

+ const ErrorCodeDimensionMismatch

+ const ErrorCodeEmptyVector

+ const ErrorCodeInsufficientScope

+ const ErrorCodeInternalError

+ const ErrorCodeInvalidApiKey

+ const ErrorCodeInvalidRequest

+ const ErrorCodeNamespaceAccessDenied

+ const ErrorCodeNamespaceNotFound

+ const ErrorCodeQuotaExceeded

+ const ErrorCodeServiceUnavailable

+ const ErrorCodeStorageError

+ const ErrorCodeUnknown

+ const ErrorCodeVectorNotFound

v0.6.0

Mar 20, 2026

Changes in this version

type Client

+ func (c *Client) ConfigureNamespace(ctx context.Context, namespace string, req ConfigureNamespaceRequest) (*ConfigureNamespaceResponse, error)

+ type ConfigureNamespaceRequest struct

+ Dimension int

+ Distance DistanceMetric

+ type ConfigureNamespaceResponse struct

+ Created bool

+ Dimension int

+ Distance DistanceMetric

+ Namespace string

+ type DistanceMetric string

+ const DistanceMetricCosine

+ const DistanceMetricDotProduct

+ const DistanceMetricEuclidean

v0.5.0

Mar 20, 2026

Changes in this version

+ type AgentNetworkEdge struct

+ Similarity float32

+ Source string

+ SourceAgent string

+ Target string

+ TargetAgent string

+ type AgentNetworkInfo struct

+ AgentID string

+ AvgImportance float32

+ MemoryCount int

+ type AgentNetworkNode struct

+ AgentID string

+ Content string

+ CreatedAt int64

+ ID string

+ Importance float32

+ MemoryType string

+ Tags []string

+ type AgentNetworkStats struct

+ Density float32

+ TotalAgents int

+ TotalCrossEdges int

+ TotalNodes int

type Client

+ func (c *Client) CrossAgentNetwork(ctx context.Context, req CrossAgentNetworkRequest) (*CrossAgentNetworkResponse, error)

+ func (c *Client) StreamMemoryEvents(ctx context.Context) (<-chan MemoryEventResult, error)

+ type CrossAgentNetworkRequest struct

+ AgentIDs []string

+ MaxCrossEdges int

+ MaxNodesPerAgent int

+ MinImportance float32

+ MinSimilarity float32

+ type CrossAgentNetworkResponse struct

+ Agents []AgentNetworkInfo

+ Edges []AgentNetworkEdge

+ Nodes []AgentNetworkNode

+ Stats AgentNetworkStats

+ type MemoryEvent struct

+ AgentID string

+ Content *string

+ EventType string

+ Importance *float32

+ MemoryID *string

+ SessionID *string

+ Tags []string

+ Timestamp int64

+ type MemoryEventResult struct

+ Err error

+ Event *MemoryEvent

v0.4.0

Mar 19, 2026

Changes in this version

type Client

+ func (c *Client) StreamGlobalEvents(ctx context.Context) (<-chan EventResult, error)

+ func (c *Client) StreamNamespaceEvents(ctx context.Context, namespace string) (<-chan EventResult, error)

+ type DakeraEvent struct

+ Count int

+ Dimension int

+ Dropped int64

+ Hint string

+ JobID string

+ JobType string

+ Message string

+ Namespace string

+ Op VectorMutationOp

+ OpType string

+ OperationID string

+ Progress int

+ Status string

+ Type string

+ UpdatedAt int64

+ type EventResult struct

+ Err error

+ Event *DakeraEvent

+ type OpStatus string

+ const OpStatusCompleted

+ const OpStatusFailed

+ const OpStatusPending

+ const OpStatusRunning

+ type VectorMutationOp string

+ const VectorMutationDeleted

+ const VectorMutationUpserted

v0.3.0

Mar 19, 2026

v0.2.0

Mar 15, 2026

Changes in this version

+ const OpAnd

+ const OpEq

+ const OpGt

+ const OpGte

+ const OpIn

+ const OpLt

+ const OpLte

+ const OpNe

+ const OpNin

+ const OpOr

+ func And(conditions ...map[string]interface{}) map[string]interface

+ func Eq(value interface{}) map[string]interface

+ func Gt(value interface{}) map[string]interface

+ func Gte(value interface{}) map[string]interface

+ func In(values ...interface{}) map[string]interface

+ func IsAuthenticationError(err error) bool

+ func IsConnectionError(err error) bool

+ func IsNotFoundError(err error) bool

+ func IsRateLimitError(err error) bool

+ func IsServerError(err error) bool

+ func IsTimeoutError(err error) bool

+ func IsValidationError(err error) bool

+ func Lt(value interface{}) map[string]interface

+ func Lte(value interface{}) map[string]interface

+ func Ne(value interface{}) map[string]interface

+ func Nin(values ...interface{}) map[string]interface

+ func Or(conditions ...map[string]interface{}) map[string]interface

+ type AgentMemoriesOptions struct

+ Limit *int

+ MemoryType string

+ type AgentSessionsOptions struct

+ ActiveOnly *bool

+ Limit *int

+ type AgentStats struct

+ ActiveSessions int64

+ AgentID string

+ AvgImportance *float32

+ MemoriesByType map[string]int64

+ NewestMemoryAt string

+ OldestMemoryAt string

+ TotalMemories int64

+ TotalSessions int64

+ type AgentSummary struct

+ ActiveSessions int64

+ AgentID string

+ MemoryCount int64

+ SessionCount int64

+ type AggregationGroup struct

+ Count int

+ Key string

+ Metrics map[string]interface{}

+ TopHits []QueryResult

+ type AggregationRequest struct

+ Filter map[string]interface{}

+ GroupBy string

+ Metrics []string

+ TopGroups *int

+ TopK *int

+ Vector []float32

+ type AggregationResponse struct

+ Groups []AggregationGroup

+ SearchTimeMs *int64

+ TotalGroups int

+ type AnalyticsOptions struct

+ Namespace string

+ Period string

+ type AnalyticsOverview struct

+ AvgLatencyMs float64

+ CacheHitRate float64

+ ErrorRate float64

+ P95LatencyMs float64

+ P99LatencyMs float64

+ QueriesPerSecond float64

+ StorageUsedBytes uint64

+ TotalNamespaces uint64

+ TotalQueries uint64

+ TotalVectors uint64

+ UptimeSeconds uint64

+ type ApiKey struct

+ Active bool

+ CreatedAt string

+ ExpiresAt string

+ ID string

+ Key string

+ Name string

+ Permissions []string

+ type AuthenticationError struct

+ func NewAuthenticationError(message string, statusCode int, body interface{}) *AuthenticationError

+ func (e *AuthenticationError) Error() string

+ type BackupInfo struct

+ CreatedAt string

+ ID string

+ IncludeData bool

+ SizeBytes int64

+ Status string

+ type BatchQuerySpec struct

+ Filter map[string]interface{}

+ IncludeMetadata bool

+ IncludeValues bool

+ TopK int

+ Vector []float32

+ type BatchTextQueryOptions struct

+ Filter map[string]interface{}

+ IncludeVectors bool

+ Model EmbeddingModel

+ TopK int

+ type BatchTextQueryResponse struct

+ EmbeddingTimeMs int64

+ Model string

+ Results [][]TextSearchResult

+ SearchTimeMs int64

+ type CacheStats struct

+ HitRate float64

+ MemoryBytes int64

+ TotalEntries int

+ type Client struct

+ func NewClient(baseURL string) *Client

+ func NewClientWithOptions(opts ClientOptions) *Client

+ func (c *Client) AdminIndexStats(ctx context.Context, namespace string) (map[string]interface{}, error)

+ func (c *Client) AgentMemories(ctx context.Context, agentID string, opts *AgentMemoriesOptions) ([]RecalledMemory, error)

+ func (c *Client) AgentSessions(ctx context.Context, agentID string, opts *AgentSessionsOptions) ([]Session, error)

+ func (c *Client) AgentStats(ctx context.Context, agentID string) (*AgentStats, error)

+ func (c *Client) Aggregate(ctx context.Context, namespace string, req AggregationRequest) (*AggregationResponse, error)

+ func (c *Client) AnalyticsLatency(ctx context.Context, opts *AnalyticsOptions) (*LatencyAnalytics, error)

+ func (c *Client) AnalyticsOverview(ctx context.Context, opts *AnalyticsOptions) (*AnalyticsOverview, error)

+ func (c *Client) AnalyticsStorage(ctx context.Context, namespace string) (*StorageAnalytics, error)

+ func (c *Client) AnalyticsThroughput(ctx context.Context, opts *AnalyticsOptions) (*ThroughputAnalytics, error)

+ func (c *Client) BatchQuery(ctx context.Context, namespace string, queries []BatchQuerySpec) ([]SearchResult, error)

+ func (c *Client) BatchQueryText(ctx context.Context, namespace string, queries []string, ...) (*BatchTextQueryResponse, error)

+ func (c *Client) CacheClear(ctx context.Context, namespace string) (*StatusResponse, error)

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

+ func (c *Client) ClusterNodes(ctx context.Context) ([]ClusterNode, error)

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

+ func (c *Client) Compact(ctx context.Context, namespace string) (*StatusResponse, error)

+ func (c *Client) ConfigureTTL(ctx context.Context, namespace string, ttlSeconds int, strategy string) (*TtlConfig, error)

+ func (c *Client) Consolidate(ctx context.Context, agentID string, req ConsolidateRequest) (*ConsolidateResponse, error)

+ func (c *Client) CreateBackup(ctx context.Context, includeData bool) (*BackupInfo, error)

+ func (c *Client) CreateKey(ctx context.Context, req CreateKeyRequest) (*ApiKey, error)

+ func (c *Client) CreateNamespace(ctx context.Context, namespace string, opts *CreateNamespaceOptions) (*NamespaceInfo, error)

+ func (c *Client) DeactivateKey(ctx context.Context, keyID string) (*ApiKey, error)

+ func (c *Client) Deduplicate(ctx context.Context, req DeduplicateRequest) (*DeduplicateResponse, error)

+ func (c *Client) Delete(ctx context.Context, namespace string, opts DeleteOptions) (*DeleteResponse, error)

+ func (c *Client) DeleteBackup(ctx context.Context, backupID string) error

+ func (c *Client) DeleteKey(ctx context.Context, keyID string) error

+ func (c *Client) DeleteNamespace(ctx context.Context, namespace string) error

+ func (c *Client) EndSession(ctx context.Context, sessionID string) error

+ func (c *Client) ExplainQuery(ctx context.Context, namespace string, req QueryExplainRequest) (*QueryExplainResponse, error)

+ func (c *Client) ExportVectors(ctx context.Context, namespace string, req ExportRequest) (*ExportResponse, error)

+ func (c *Client) Fetch(ctx context.Context, namespace string, ids []string, opts *FetchOptions) ([]Vector, error)

+ func (c *Client) Flush(ctx context.Context, namespace string) (*StatusResponse, error)

+ func (c *Client) Forget(ctx context.Context, agentID, memoryID string) error

+ func (c *Client) FullKnowledgeGraph(ctx context.Context, req FullKnowledgeGraphRequest) (*KnowledgeGraphResponse, error)

+ func (c *Client) FulltextSearch(ctx context.Context, namespace string, query string, ...) ([]FullTextSearchResult, error)

+ func (c *Client) GetConfig(ctx context.Context) (map[string]interface{}, error)

+ func (c *Client) GetIndexStats(ctx context.Context, namespace string) (*IndexStats, error)

+ func (c *Client) GetKey(ctx context.Context, keyID string) (*ApiKey, error)

+ func (c *Client) GetMemory(ctx context.Context, agentID, memoryID string) (*Memory, error)

+ func (c *Client) GetNamespace(ctx context.Context, namespace string) (*NamespaceInfo, error)

+ func (c *Client) GetQuotas(ctx context.Context) (map[string]interface{}, error)

+ func (c *Client) GetSession(ctx context.Context, sessionID string) (*Session, error)

+ func (c *Client) Health(ctx context.Context) (*HealthResponse, error)

+ func (c *Client) HybridSearch(ctx context.Context, namespace string, vector []float32, query string, ...) ([]HybridSearchResult, error)

+ func (c *Client) IndexDocuments(ctx context.Context, namespace string, documents []DocumentInput) (*IndexDocumentsResponse, error)

+ func (c *Client) KeyUsage(ctx context.Context, keyID string) (*KeyUsage, error)

+ func (c *Client) KnowledgeGraph(ctx context.Context, req KnowledgeGraphRequest) (*KnowledgeGraphResponse, error)

+ func (c *Client) ListAgents(ctx context.Context) ([]AgentSummary, error)

+ func (c *Client) ListBackups(ctx context.Context) ([]BackupInfo, error)

+ func (c *Client) ListKeys(ctx context.Context) ([]ApiKey, error)

+ func (c *Client) ListNamespaces(ctx context.Context) ([]NamespaceInfo, error)

+ func (c *Client) ListSessions(ctx context.Context, opts *ListSessionsOptions) ([]Session, error)

+ func (c *Client) MemoryFeedback(ctx context.Context, agentID string, req MemoryFeedbackRequest) (*MemoryFeedbackResponse, error)

+ func (c *Client) MultiVectorSearch(ctx context.Context, namespace string, req MultiVectorSearchRequest) (*MultiVectorSearchResponse, error)

+ func (c *Client) OptimizeNamespace(ctx context.Context, namespace string) (*StatusResponse, error)

+ func (c *Client) Query(ctx context.Context, namespace string, vector []float32, opts *QueryOptions) (*SearchResult, error)

+ func (c *Client) QueryText(ctx context.Context, namespace string, text string, opts *TextQueryOptions) (*TextQueryResponse, error)

+ func (c *Client) RebuildIndexes(ctx context.Context, namespace string) (*StatusResponse, error)

+ func (c *Client) Recall(ctx context.Context, agentID string, req RecallRequest) ([]RecalledMemory, error)

+ func (c *Client) RestoreBackup(ctx context.Context, backupID string) (*StatusResponse, error)

+ func (c *Client) RotateKey(ctx context.Context, keyID string) (*ApiKey, error)

+ func (c *Client) SearchMemories(ctx context.Context, agentID string, req SearchMemoriesRequest) ([]RecalledMemory, error)

+ func (c *Client) SessionMemories(ctx context.Context, sessionID string) ([]RecalledMemory, error)

+ func (c *Client) SlowQueries(ctx context.Context, opts *SlowQueryOptions) ([]SlowQuery, error)

+ func (c *Client) StartSession(ctx context.Context, req StartSessionRequest) (*Session, error)

+ func (c *Client) StoreMemory(ctx context.Context, agentID string, req StoreMemoryRequest) (*StoreMemoryResponse, error)

+ func (c *Client) Summarize(ctx context.Context, req SummarizeRequest) (*SummarizeResponse, error)

+ func (c *Client) UnifiedQuery(ctx context.Context, namespace string, req UnifiedQueryRequest) (*UnifiedQueryResponse, error)

+ func (c *Client) UpdateConfig(ctx context.Context, config map[string]interface{}) (map[string]interface{}, error)

+ func (c *Client) UpdateImportance(ctx context.Context, agentID string, req UpdateImportanceRequest) error

+ func (c *Client) UpdateMemory(ctx context.Context, agentID, memoryID string, req UpdateMemoryRequest) (*StoreMemoryResponse, error)

+ func (c *Client) UpdateQuotas(ctx context.Context, quotas map[string]interface{}) (map[string]interface{}, error)

+ func (c *Client) Upsert(ctx context.Context, namespace string, vectors []VectorInput) (*UpsertResponse, error)

+ func (c *Client) UpsertColumns(ctx context.Context, namespace string, req ColumnUpsertRequest) (*UpsertResponse, error)

+ func (c *Client) UpsertText(ctx context.Context, namespace string, documents []TextDocument, ...) (*TextUpsertResponse, error)

+ func (c *Client) WarmCache(ctx context.Context, namespace string, req WarmCacheRequest) (*WarmCacheResponse, error)

+ type ClientOptions struct

+ APIKey string

+ BaseURL string

+ Headers map[string]string

+ MaxRetries int

+ Timeout time.Duration

+ type ClusterNode struct

+ Address string

+ ID string

+ Role string

+ Status string

+ type ClusterStatus struct

+ Healthy bool

+ Nodes int

+ Status string

+ Version string

+ type ColumnUpsertRequest struct

+ Attributes map[string][]interface{}

+ Dimension *int

+ IDs []string

+ TTLSeconds *int

+ Vectors [][]float32

+ type ConnectionError struct

+ func NewConnectionError(message string) *ConnectionError

+ func (e *ConnectionError) Error() string

+ type ConsolidateRequest struct

+ DryRun bool

+ MemoryType string

+ Threshold *float32

+ type ConsolidateResponse struct

+ ConsolidatedCount int

+ NewMemories []string

+ RemovedCount int

+ type CreateKeyRequest struct

+ ExpiresAt string

+ Name string

+ Permissions []string

+ type CreateNamespaceOptions struct

+ Dimensions int

+ IndexType string

+ Metadata map[string]interface{}

+ type DakeraError struct

+ Message string

+ ResponseBody interface{}

+ StatusCode int

+ func (e *DakeraError) Error() string

+ type DeduplicateRequest struct

+ AgentID string

+ DryRun bool

+ MemoryType string

+ Threshold *float32

+ type DeduplicateResponse struct

+ DuplicatesFound int

+ Groups [][]string

+ RemovedCount int

+ type DeleteOptions struct

+ DeleteAll bool

+ Filter map[string]interface{}

+ IDs []string

+ type DeleteResponse struct

+ DeletedCount int

+ type Document struct

+ Content string

+ ID string

+ Metadata map[string]interface{}

+ type DocumentInput struct

+ Content string

+ ID string

+ Metadata map[string]interface{}

+ type EmbeddingModel string

+ const EmbeddingModelBGESmall

+ const EmbeddingModelE5Small

+ const EmbeddingModelMiniLM

+ type ExportRequest struct

+ Cursor string

+ Filter map[string]interface{}

+ IncludeVectors bool

+ Limit *int

+ type ExportResponse struct

+ HasMore bool

+ NextCursor string

+ Vectors []ExportedVector

+ type ExportedVector struct

+ ID string

+ Metadata map[string]interface{}

+ Values []float32

+ type FetchOptions struct

+ IncludeMetadata bool

+ IncludeValues bool

+ type FullKnowledgeGraphRequest struct

+ AgentID string

+ ClusterThreshold *float32

+ MaxEdgesPerNode *int

+ MaxNodes *int

+ MinSimilarity *float32

+ type FullTextSearchOptions struct

+ Filter map[string]interface{}

+ TopK int

+ type FullTextSearchResult struct

+ Content string

+ ID string

+ Metadata map[string]interface{}

+ Score float32

+ type HealthResponse struct

+ Status string

+ Version string

+ type HybridSearchOptions struct

+ Alpha float32

+ Filter map[string]interface{}

+ TopK int

+ type HybridSearchResult struct

+ Content string

+ ID string

+ Metadata map[string]interface{}

+ Score float32

+ TextScore float32

+ Values []float32

+ VectorScore float32

+ type IndexDocumentsResponse struct

+ IndexedCount int

+ type IndexStats struct

+ Dimensions int

+ IndexType string

+ IndexedCount int64

+ Namespace string

+ SizeBytes int64

+ Utilization float64

+ VectorCount int64

+ type KeyUsage struct

+ KeyID string

+ LastUsed string

+ RequestsByEndpoint map[string]int64

+ TotalRequests int64

+ type KnowledgeEdge struct

+ Relationship string

+ Similarity float32

+ Source string

+ Target string

+ type KnowledgeGraphRequest struct

+ AgentID string

+ Depth *int

+ MemoryID string

+ MinSimilarity *float32

+ type KnowledgeGraphResponse struct

+ Clusters [][]string

+ Edges []KnowledgeEdge

+ Nodes []KnowledgeNode

+ type KnowledgeNode struct

+ Content string

+ ID string

+ Importance *float32

+ MemoryType string

+ Metadata map[string]interface{}

+ type LatencyAnalytics struct

+ AvgMs float64

+ ByOperation map[string]OperationLatency

+ MaxMs float64

+ P50Ms float64

+ P95Ms float64

+ P99Ms float64

+ Period string

+ type ListSessionsOptions struct

+ ActiveOnly *bool

+ AgentID string

+ Limit *int

+ Offset *int

+ type Memory struct

+ AccessCount *int

+ Content string

+ CreatedAt string

+ ID string

+ Importance float32

+ MemoryType string

+ Metadata map[string]interface{}

+ UpdatedAt string

+ type MemoryFeedbackRequest struct

+ Feedback string

+ MemoryID string

+ RelevanceScore *float32

+ type MemoryFeedbackResponse struct

+ Status string

+ UpdatedImportance *float32

+ type MultiVectorSearchRequest struct

+ Filter map[string]interface{}

+ IncludeMetadata bool

+ IncludeVectors bool

+ MmrLambda *float32

+ MmrPrefetchK *int

+ Negative [][]float32

+ Positive [][]float32

+ TopK int

+ type MultiVectorSearchResponse struct

+ Results []MultiVectorSearchResult

+ SearchTimeMs *int64

+ Strategy string

+ type MultiVectorSearchResult struct

+ ID string

+ Metadata map[string]interface{}

+ Score float32

+ Values []float32

+ type NamespaceInfo struct

+ CreatedAt *time.Time

+ Dimensions int

+ IndexType string

+ Metadata map[string]interface{}

+ Name string

+ UpdatedAt *time.Time

+ VectorCount int64

+ type NamespaceStorage struct

+ Bytes uint64

+ VectorCount uint64

+ type NotFoundError struct

+ func NewNotFoundError(message string, statusCode int, body interface{}) *NotFoundError

+ func (e *NotFoundError) Error() string

+ type OperationLatency struct

+ AvgMs float64

+ Count uint64

+ P95Ms float64

+ type QueryExplainRequest struct

+ Filter map[string]interface{}

+ IncludeMetadata bool

+ TopK int

+ Vector []float32

+ type QueryExplainResponse struct

+ IndexType string

+ Plan map[string]interface{}

+ Results []QueryResult

+ Steps []map[string]interface{}

+ TotalTimeMs *float64

+ VectorsScanned *int64

+ type QueryOptions struct

+ Filter map[string]interface{}

+ IncludeMetadata bool

+ IncludeValues bool

+ TopK int

+ type QueryResult struct

+ ID string

+ Metadata map[string]interface{}

+ Score float32

+ Values []float32

+ type RateLimitError struct

+ RetryAfter int

+ func NewRateLimitError(message string, statusCode int, body interface{}, retryAfter int) *RateLimitError

+ func (e *RateLimitError) Error() string

+ type RecallRequest struct

+ MemoryType string

+ MinImportance *float32

+ Query string

+ TopK int

+ type RecalledMemory struct

+ Content string

+ CreatedAt string

+ ID string

+ Importance float32

+ MemoryType string

+ Metadata map[string]interface{}

+ Score float32

+ type SearchMemoriesRequest struct

+ MemoryType string

+ MinImportance *float32

+ Query string

+ TopK int

+ type SearchResult struct

+ Results []QueryResult

+ TotalSearched int

+ type ServerError struct

+ func NewServerError(message string, statusCode int, body interface{}) *ServerError

+ func (e *ServerError) Error() string

+ type Session struct

+ AgentID string

+ EndedAt string

+ Metadata map[string]interface{}

+ SessionID string

+ StartedAt string

+ type SlowQuery struct

+ DurationMs float64

+ Namespace string

+ Query string

+ Timestamp string

+ type SlowQueryOptions struct

+ Limit int

+ MinDurationMs int

+ type StartSessionRequest struct

+ AgentID string

+ Metadata map[string]interface{}

+ type StatusResponse struct

+ Status string

+ type StorageAnalytics struct

+ ByNamespace map[string]NamespaceStorage

+ DataBytes uint64

+ IndexBytes uint64

+ TotalBytes uint64

+ type StoreMemoryRequest struct

+ Content string

+ Embedding []float32

+ Importance *float32

+ MemoryType string

+ Metadata map[string]interface{}

+ SessionID string

+ TTLSeconds *int

+ type StoreMemoryResponse struct

+ MemoryID string

+ Status string

+ type SummarizeRequest struct

+ AgentID string

+ DryRun bool

+ MemoryIDs []string

+ TargetType string

+ type SummarizeResponse struct

+ NewMemoryID string

+ SourceCount int

+ Summary string

+ type TextDocument struct

+ ID string

+ Metadata map[string]interface{}

+ TTLSeconds *int

+ Text string

+ type TextQueryOptions struct

+ Filter map[string]interface{}

+ IncludeText bool

+ IncludeVectors bool

+ Model EmbeddingModel

+ TopK int

+ type TextQueryResponse struct

+ EmbeddingTimeMs int64

+ Model string

+ Results []TextSearchResult

+ SearchTimeMs int64

+ type TextSearchResult struct

+ ID string

+ Metadata map[string]interface{}

+ Score float32

+ Text string

+ Vector []float32

+ type TextUpsertOptions struct

+ Model EmbeddingModel

+ type TextUpsertResponse struct

+ EmbeddingTimeMs int64

+ Model string

+ TokensProcessed int

+ UpsertedCount int

+ type ThroughputAnalytics struct

+ ByOperation map[string]uint64

+ OperationsPerSecond float64

+ Period string

+ TotalOperations uint64

+ type TimeoutError struct

+ func NewTimeoutError(message string) *TimeoutError

+ func (e *TimeoutError) Error() string

+ type TtlConfig struct

+ Namespace string

+ Strategy string

+ TtlSeconds int

+ type UnifiedQueryRequest struct

+ Filter map[string]interface{}

+ FusionMethod string

+ IncludeMetadata bool

+ IncludeVectors bool

+ Rerank bool

+ Text string

+ TextWeight *float32

+ TopK int

+ Vector []float32

+ VectorWeight *float32

+ type UnifiedQueryResponse struct

+ FusionMethod string

+ Results []UnifiedSearchResult

+ SearchTimeMs *int64

+ type UnifiedSearchResult struct

+ Content string

+ ID string

+ Metadata map[string]interface{}

+ Score float32

+ TextScore *float32

+ Values []float32

+ VectorScore *float32

+ type UpdateImportanceRequest struct

+ Importance float32

+ MemoryIDs []string

+ type UpdateMemoryRequest struct

+ Content *string

+ MemoryType *string

+ Metadata map[string]interface{}

+ type UpsertResponse struct

+ UpsertedCount int

+ type ValidationError struct

+ func NewValidationError(message string, statusCode int, body interface{}) *ValidationError

+ func (e *ValidationError) Error() string

+ type Vector struct

+ ID string

+ Metadata map[string]interface{}

+ Values []float32

+ type VectorInput struct

+ ID string

+ Metadata map[string]interface{}

+ Values []float32

+ type WarmCacheRequest struct

+ AccessPattern string

+ Background bool

+ MaxVectors *int

+ Priority string

+ TTLHintSeconds *int

+ TargetTier string

+ VectorIDs []string

+ type WarmCacheResponse struct

+ EntriesWarmed int

+ Status string

+ TimeTakenMs *int64

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