Documentation
¶
Index ¶
- type Memory
- func (r *Memory) AcquireAlertThrottleSlot(ctx context.Context, window time.Duration, limit int) (*alert.ThrottleResult, error)
- func (r *Memory) BatchGetAlerts(ctx context.Context, alertIDs []types.AlertID) (alert.Alerts, error)
- func (r *Memory) BatchGetDiagnosisIssueCounts(ctx context.Context, diagnosisIDs []types.DiagnosisID) (map[types.DiagnosisID]diagnosis.IssueCounts, error)
- func (r *Memory) BatchGetTickets(ctx context.Context, ticketIDs []types.TicketID) ([]*ticket.Ticket, error)
- func (r *Memory) BatchPutAlerts(ctx context.Context, alerts alert.Alerts) error
- func (r *Memory) BatchSaveAgentMemories(ctx context.Context, memories []*memory.AgentMemory) error
- func (r *Memory) BatchUpdateTicketsStatus(ctx context.Context, ticketIDs []types.TicketID, status types.TicketStatus) error
- func (r *Memory) BindAlertsToTicket(ctx context.Context, alertIDs []types.AlertID, ticketID types.TicketID) error
- func (r *Memory) CheckAlertThrottle(ctx context.Context, window time.Duration, limit int) (*alert.ThrottleResult, error)
- func (r *Memory) CountActivities(ctx context.Context) (int, error)
- func (r *Memory) CountAlertsWithoutTicket(ctx context.Context) (int, error)
- func (r *Memory) CountDeclinedAlerts(ctx context.Context) (int, error)
- func (r *Memory) CountDiagnosisIssues(_ context.Context, diagnosisID types.DiagnosisID, ...) (int, error)
- func (r *Memory) CountQueuedAlerts(ctx context.Context) (int, error)
- func (r *Memory) CountTicketComments(ctx context.Context, ticketID types.TicketID) (int, error)
- func (r *Memory) CountTicketsByStatus(ctx context.Context, statuses []types.TicketStatus, keyword, assigneeID string) (int, error)
- func (r *Memory) CreateNotice(ctx context.Context, notice *notice.Notice) error
- func (r *Memory) CreateTagWithID(ctx context.Context, tag *tag.Tag) error
- func (r *Memory) DeleteAgentMemoriesBatch(ctx context.Context, agentID string, memoryIDs []types.AgentMemoryID) (int, error)
- func (r *Memory) DeleteKnowledge(_ context.Context, id types.KnowledgeID) error
- func (r *Memory) DeleteKnowledgeTag(_ context.Context, id types.KnowledgeTagID) error
- func (r *Memory) DeleteQueuedAlerts(ctx context.Context, ids []types.QueuedAlertID) error
- func (r *Memory) DeleteSession(ctx context.Context, sessionID types.SessionID) error
- func (r *Memory) DeleteTagByID(ctx context.Context, tagID string) error
- func (r *Memory) DeleteToken(ctx context.Context, tokenID auth.TokenID) error
- func (r *Memory) FindNearestAlerts(ctx context.Context, embedding []float32, limit int) (alert.Alerts, error)
- func (r *Memory) FindNearestTickets(ctx context.Context, embedding []float32, limit int) ([]*ticket.Ticket, error)
- func (r *Memory) FindNearestTicketsWithSpan(ctx context.Context, embedding []float32, begin, end time.Time, limit int) ([]*ticket.Ticket, error)
- func (r *Memory) FindSimilarAlerts(ctx context.Context, target alert.Alert, limit int) (alert.Alerts, error)
- func (r *Memory) GetActivities(ctx context.Context, offset, limit int) ([]*activity.Activity, error)
- func (r *Memory) GetAgentMemory(ctx context.Context, agentID string, id types.AgentMemoryID) (*memory.AgentMemory, error)
- func (r *Memory) GetAlert(ctx context.Context, alertID types.AlertID) (*alert.Alert, error)
- func (r *Memory) GetAlertList(ctx context.Context, listID types.AlertListID) (*alert.List, error)
- func (r *Memory) GetAlertListByThread(ctx context.Context, thread slack.Thread) (*alert.List, error)
- func (r *Memory) GetAlertListsInThread(ctx context.Context, thread slack.Thread) ([]*alert.List, error)
- func (r *Memory) GetAlertWithoutEmbedding(ctx context.Context) (alert.Alerts, error)
- func (r *Memory) GetAlertWithoutTicket(ctx context.Context, offset, limit int) (alert.Alerts, error)
- func (r *Memory) GetAlertsBySpan(ctx context.Context, begin, end time.Time) (alert.Alerts, error)
- func (r *Memory) GetAlertsByThread(ctx context.Context, thread slack.Thread) (alert.Alerts, error)
- func (r *Memory) GetAlertsWithInvalidEmbedding(ctx context.Context) (alert.Alerts, error)
- func (r *Memory) GetAllAlerts(_ context.Context) (alert.Alerts, error)
- func (r *Memory) GetAllCallCounts() map[string]int
- func (r *Memory) GetAllTickets(_ context.Context) ([]*ticket.Ticket, error)
- func (r *Memory) GetCallCount(methodName string) int
- func (r *Memory) GetDeclinedAlerts(ctx context.Context, offset, limit int) (alert.Alerts, error)
- func (r *Memory) GetDiagnosis(_ context.Context, id types.DiagnosisID) (*diagnosis.Diagnosis, error)
- func (r *Memory) GetDiagnosisIssue(_ context.Context, diagnosisID types.DiagnosisID, issueID string) (*diagnosis.Issue, error)
- func (r *Memory) GetDiagnosisIssueCounts(_ context.Context, diagnosisID types.DiagnosisID) (diagnosis.IssueCounts, error)
- func (r *Memory) GetHITLRequest(ctx context.Context, id types.HITLRequestID) (*hitl.Request, error)
- func (r *Memory) GetKnowledge(_ context.Context, id types.KnowledgeID) (*knowledge.Knowledge, error)
- func (r *Memory) GetKnowledgeLog(_ context.Context, knowledgeID types.KnowledgeID, logID types.KnowledgeLogID) (*knowledge.KnowledgeLog, error)
- func (r *Memory) GetKnowledgeTag(_ context.Context, id types.KnowledgeTagID) (*knowledge.KnowledgeTag, error)
- func (r *Memory) GetLatestAlertByThread(ctx context.Context, thread slack.Thread) (*alert.Alert, error)
- func (r *Memory) GetLatestAlertListInThread(ctx context.Context, thread slack.Thread) (*alert.List, error)
- func (r *Memory) GetLatestHistory(ctx context.Context, ticketID types.TicketID) (*ticket.History, error)
- func (r *Memory) GetNotice(ctx context.Context, id types.NoticeID) (*notice.Notice, error)
- func (r *Memory) GetOrCreateTagByName(ctx context.Context, name, description, color, createdBy string) (*tag.Tag, error)
- func (r *Memory) GetQueuedAlert(ctx context.Context, id types.QueuedAlertID) (*alert.QueuedAlert, error)
- func (r *Memory) GetRefineGroup(ctx context.Context, groupID types.RefineGroupID) (*refine.Group, error)
- func (r *Memory) GetReprocessBatchJob(ctx context.Context, id types.ReprocessBatchJobID) (*alert.ReprocessBatchJob, error)
- func (r *Memory) GetReprocessJob(ctx context.Context, id types.ReprocessJobID) (*alert.ReprocessJob, error)
- func (r *Memory) GetSession(ctx context.Context, sessionID types.SessionID) (*session.Session, error)
- func (r *Memory) GetSessionMessages(ctx context.Context, sessionID types.SessionID) ([]*session.Message, error)
- func (r *Memory) GetSessionsByTicket(ctx context.Context, ticketID types.TicketID) ([]*session.Session, error)
- func (r *Memory) GetTagByID(ctx context.Context, tagID string) (*tag.Tag, error)
- func (r *Memory) GetTagByName(ctx context.Context, name string) (*tag.Tag, error)
- func (r *Memory) GetTagsByIDs(ctx context.Context, tagIDs []string) ([]*tag.Tag, error)
- func (r *Memory) GetTicket(ctx context.Context, ticketID types.TicketID) (*ticket.Ticket, error)
- func (r *Memory) GetTicketByThread(ctx context.Context, thread slack.Thread) (*ticket.Ticket, error)
- func (r *Memory) GetTicketComments(ctx context.Context, ticketID types.TicketID) ([]ticket.Comment, error)
- func (r *Memory) GetTicketCommentsPaginated(ctx context.Context, ticketID types.TicketID, offset, limit int) ([]ticket.Comment, error)
- func (r *Memory) GetTicketUnpromptedComments(ctx context.Context, ticketID types.TicketID) ([]ticket.Comment, error)
- func (r *Memory) GetTicketsBySpan(ctx context.Context, start, end time.Time) ([]*ticket.Ticket, error)
- func (r *Memory) GetTicketsByStatus(ctx context.Context, statuses []types.TicketStatus, keyword, assigneeID string, ...) ([]*ticket.Ticket, error)
- func (r *Memory) GetTicketsByStatusAndSpan(ctx context.Context, status types.TicketStatus, begin, end time.Time) ([]*ticket.Ticket, error)
- func (r *Memory) GetTicketsWithInvalidEmbedding(ctx context.Context) ([]*ticket.Ticket, error)
- func (r *Memory) GetToken(ctx context.Context, tokenID auth.TokenID) (*auth.Token, error)
- func (r *Memory) IsTagNameExists(ctx context.Context, name string) (bool, error)
- func (r *Memory) ListAgentMemories(ctx context.Context, agentID string) ([]*memory.AgentMemory, error)
- func (r *Memory) ListAgentMemoriesWithOptions(ctx context.Context, agentID string, opts interfaces.AgentMemoryListOptions) ([]*memory.AgentMemory, int, error)
- func (r *Memory) ListAllAgentIDs(ctx context.Context) ([]*interfaces.AgentSummary, error)
- func (r *Memory) ListAllKnowledges(_ context.Context) ([]*knowledge.Knowledge, error)
- func (r *Memory) ListAllTags(ctx context.Context) ([]*tag.Tag, error)
- func (r *Memory) ListDiagnoses(_ context.Context, offset, limit int) ([]*diagnosis.Diagnosis, int, error)
- func (r *Memory) ListDiagnosisIssues(_ context.Context, diagnosisID types.DiagnosisID, offset, limit int, ...) ([]*diagnosis.Issue, int, error)
- func (r *Memory) ListKnowledgeLogs(_ context.Context, knowledgeID types.KnowledgeID) ([]*knowledge.KnowledgeLog, error)
- func (r *Memory) ListKnowledgeTags(_ context.Context) ([]*knowledge.KnowledgeTag, error)
- func (r *Memory) ListKnowledgesByCategoryAndTags(_ context.Context, category types.KnowledgeCategory, ...) ([]*knowledge.Knowledge, error)
- func (r *Memory) ListLegacyKnowledges(_ context.Context) ([]*interfaces.LegacyKnowledge, error)
- func (r *Memory) ListPendingDiagnosisIssues(_ context.Context, diagnosisID types.DiagnosisID) ([]*diagnosis.Issue, error)
- func (r *Memory) ListQueuedAlerts(ctx context.Context, offset, limit int) ([]*alert.QueuedAlert, error)
- func (r *Memory) PutActivity(ctx context.Context, activity *activity.Activity) error
- func (r *Memory) PutAlert(ctx context.Context, alert alert.Alert) error
- func (r *Memory) PutAlertList(ctx context.Context, list *alert.List) error
- func (r *Memory) PutDiagnosis(_ context.Context, d *diagnosis.Diagnosis) error
- func (r *Memory) PutDiagnosisIssue(_ context.Context, issue *diagnosis.Issue) error
- func (r *Memory) PutHITLRequest(ctx context.Context, req *hitl.Request) error
- func (r *Memory) PutHistory(ctx context.Context, ticketID types.TicketID, history *ticket.History) error
- func (r *Memory) PutKnowledge(_ context.Context, k *knowledge.Knowledge) error
- func (r *Memory) PutKnowledgeLog(_ context.Context, log *knowledge.KnowledgeLog) error
- func (r *Memory) PutKnowledgeTag(_ context.Context, tag *knowledge.KnowledgeTag) error
- func (r *Memory) PutQueuedAlert(ctx context.Context, qa *alert.QueuedAlert) error
- func (r *Memory) PutRefineGroup(ctx context.Context, group *refine.Group) error
- func (r *Memory) PutReprocessBatchJob(ctx context.Context, job *alert.ReprocessBatchJob) error
- func (r *Memory) PutReprocessJob(ctx context.Context, job *alert.ReprocessJob) error
- func (r *Memory) PutSession(ctx context.Context, sess *session.Session) error
- func (r *Memory) PutSessionMessage(ctx context.Context, message *session.Message) error
- func (r *Memory) PutTicket(ctx context.Context, t ticket.Ticket) error
- func (r *Memory) PutTicketComment(ctx context.Context, comment ticket.Comment) error
- func (r *Memory) PutTicketCommentsPrompted(ctx context.Context, ticketID types.TicketID, commentIDs []types.CommentID) error
- func (r *Memory) PutToken(ctx context.Context, token *auth.Token) error
- func (r *Memory) RemoveTagFromAllAlerts(ctx context.Context, name string) error
- func (r *Memory) RemoveTagFromAllTickets(ctx context.Context, name string) error
- func (r *Memory) RemoveTagIDFromAllAlerts(ctx context.Context, tagID string) error
- func (r *Memory) RemoveTagIDFromAllTickets(ctx context.Context, tagID string) error
- func (r *Memory) ResetCallCounts()
- func (r *Memory) SaveAgentMemory(ctx context.Context, mem *memory.AgentMemory) error
- func (r *Memory) SearchAlerts(ctx context.Context, path, op string, value any, limit int) (alert.Alerts, error)
- func (r *Memory) SearchMemoriesByEmbedding(ctx context.Context, agentID string, embedding []float32, limit int) ([]*memory.AgentMemory, error)
- func (r *Memory) SearchQueuedAlerts(ctx context.Context, keyword string, offset, limit int) ([]*alert.QueuedAlert, int, error)
- func (r *Memory) UnbindAlertFromTicket(ctx context.Context, alertID types.AlertID) error
- func (r *Memory) UpdateAlertStatus(ctx context.Context, alertID types.AlertID, status alert.AlertStatus) error
- func (r *Memory) UpdateHITLRequestStatus(ctx context.Context, id types.HITLRequestID, status hitl.Status, ...) error
- func (r *Memory) UpdateMemoryScore(ctx context.Context, agentID string, memoryID types.AgentMemoryID, ...) error
- func (r *Memory) UpdateMemoryScoreBatch(ctx context.Context, agentID string, ...) error
- func (r *Memory) UpdateNotice(ctx context.Context, notice *notice.Notice) error
- func (r *Memory) UpdateTag(ctx context.Context, tag *tag.Tag) error
- func (r *Memory) WatchHITLRequest(ctx context.Context, id types.HITLRequestID) (<-chan *hitl.Request, <-chan error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Memory ¶
type Memory struct {
// contains filtered or unexported fields
}
func (*Memory) AcquireAlertThrottleSlot ¶ added in v0.14.0
func (r *Memory) AcquireAlertThrottleSlot(ctx context.Context, window time.Duration, limit int) (*alert.ThrottleResult, error)
AcquireAlertThrottleSlot atomically checks and consumes a throttle slot.
func (*Memory) BatchGetAlerts ¶
func (*Memory) BatchGetDiagnosisIssueCounts ¶ added in v0.13.0
func (r *Memory) BatchGetDiagnosisIssueCounts(ctx context.Context, diagnosisIDs []types.DiagnosisID) (map[types.DiagnosisID]diagnosis.IssueCounts, error)
BatchGetDiagnosisIssueCounts returns issue counts for multiple diagnoses in one call.
func (*Memory) BatchGetTickets ¶
func (*Memory) BatchPutAlerts ¶
func (*Memory) BatchSaveAgentMemories ¶ added in v0.8.0
BatchSaveAgentMemories saves multiple agent memories in a batch
func (*Memory) BatchUpdateTicketsStatus ¶
func (*Memory) BindAlertsToTicket ¶
func (*Memory) CheckAlertThrottle ¶ added in v0.14.0
func (r *Memory) CheckAlertThrottle(ctx context.Context, window time.Duration, limit int) (*alert.ThrottleResult, error)
CheckAlertThrottle checks whether throttle slots are available (read-only). Does NOT consume a slot.
func (*Memory) CountAlertsWithoutTicket ¶
func (*Memory) CountDeclinedAlerts ¶ added in v0.10.0
func (*Memory) CountDiagnosisIssues ¶ added in v0.13.0
func (r *Memory) CountDiagnosisIssues(_ context.Context, diagnosisID types.DiagnosisID, status *diagnosis.IssueStatus) (int, error)
CountDiagnosisIssues counts issues for a diagnosis, optionally filtered by status.
func (*Memory) CountQueuedAlerts ¶ added in v0.14.0
CountQueuedAlerts returns the total number of queued alerts
func (*Memory) CountTicketComments ¶
func (*Memory) CountTicketsByStatus ¶
func (*Memory) CreateNotice ¶
func (*Memory) CreateTagWithID ¶
func (*Memory) DeleteAgentMemoriesBatch ¶ added in v0.6.2
func (r *Memory) DeleteAgentMemoriesBatch(ctx context.Context, agentID string, memoryIDs []types.AgentMemoryID) (int, error)
DeleteAgentMemoriesBatch deletes multiple agent memories in a batch Returns the number of successfully deleted memories
func (*Memory) DeleteKnowledge ¶ added in v0.14.0
func (*Memory) DeleteKnowledgeTag ¶ added in v0.14.0
func (*Memory) DeleteQueuedAlerts ¶ added in v0.14.0
DeleteQueuedAlerts deletes queued alerts by IDs
func (*Memory) DeleteSession ¶ added in v0.8.0
func (*Memory) DeleteTagByID ¶
func (*Memory) DeleteToken ¶
func (*Memory) FindNearestAlerts ¶
func (*Memory) FindNearestTickets ¶
func (*Memory) FindNearestTicketsWithSpan ¶
func (*Memory) FindSimilarAlerts ¶
func (*Memory) GetActivities ¶
func (*Memory) GetAgentMemory ¶
func (r *Memory) GetAgentMemory(ctx context.Context, agentID string, id types.AgentMemoryID) (*memory.AgentMemory, error)
GetAgentMemory retrieves an agent memory record by agentID and memoryID
func (*Memory) GetAlertList ¶
func (*Memory) GetAlertListByThread ¶
func (*Memory) GetAlertListsInThread ¶
func (*Memory) GetAlertWithoutEmbedding ¶
func (*Memory) GetAlertWithoutTicket ¶
func (*Memory) GetAlertsBySpan ¶
func (*Memory) GetAlertsByThread ¶
func (*Memory) GetAlertsWithInvalidEmbedding ¶
func (*Memory) GetAllAlerts ¶ added in v0.13.0
GetAllAlerts returns all alerts for full-scan diagnosis checks.
func (*Memory) GetAllCallCounts ¶
GetAllCallCounts returns a copy of all call counts
func (*Memory) GetAllTickets ¶ added in v0.13.0
GetAllTickets returns all tickets for full-scan diagnosis checks.
func (*Memory) GetCallCount ¶
GetCallCount returns the number of times a method has been called
func (*Memory) GetDeclinedAlerts ¶ added in v0.10.0
func (*Memory) GetDiagnosis ¶ added in v0.13.0
func (r *Memory) GetDiagnosis(_ context.Context, id types.DiagnosisID) (*diagnosis.Diagnosis, error)
GetDiagnosis retrieves a diagnosis by ID.
func (*Memory) GetDiagnosisIssue ¶ added in v0.13.0
func (r *Memory) GetDiagnosisIssue(_ context.Context, diagnosisID types.DiagnosisID, issueID string) (*diagnosis.Issue, error)
GetDiagnosisIssue retrieves a specific issue by diagnosisID and issueID.
func (*Memory) GetDiagnosisIssueCounts ¶ added in v0.13.0
func (r *Memory) GetDiagnosisIssueCounts(_ context.Context, diagnosisID types.DiagnosisID) (diagnosis.IssueCounts, error)
GetDiagnosisIssueCounts returns all status counts for a diagnosis in a single pass.
func (*Memory) GetHITLRequest ¶ added in v0.13.0
func (*Memory) GetKnowledge ¶ added in v0.8.0
func (*Memory) GetKnowledgeLog ¶ added in v0.14.0
func (r *Memory) GetKnowledgeLog(_ context.Context, knowledgeID types.KnowledgeID, logID types.KnowledgeLogID) (*knowledge.KnowledgeLog, error)
func (*Memory) GetKnowledgeTag ¶ added in v0.14.0
func (r *Memory) GetKnowledgeTag(_ context.Context, id types.KnowledgeTagID) (*knowledge.KnowledgeTag, error)
func (*Memory) GetLatestAlertByThread ¶
func (*Memory) GetLatestAlertListInThread ¶
func (*Memory) GetLatestHistory ¶
func (*Memory) GetOrCreateTagByName ¶
func (r *Memory) GetOrCreateTagByName(ctx context.Context, name, description, color, createdBy string) (*tag.Tag, error)
GetOrCreateTagByName atomically gets an existing tag or creates a new one
func (*Memory) GetQueuedAlert ¶ added in v0.14.0
func (r *Memory) GetQueuedAlert(ctx context.Context, id types.QueuedAlertID) (*alert.QueuedAlert, error)
GetQueuedAlert retrieves a queued alert by ID
func (*Memory) GetRefineGroup ¶ added in v0.10.0
func (*Memory) GetReprocessBatchJob ¶ added in v0.14.0
func (r *Memory) GetReprocessBatchJob(ctx context.Context, id types.ReprocessBatchJobID) (*alert.ReprocessBatchJob, error)
GetReprocessBatchJob retrieves a reprocess batch job by ID
func (*Memory) GetReprocessJob ¶ added in v0.14.0
func (r *Memory) GetReprocessJob(ctx context.Context, id types.ReprocessJobID) (*alert.ReprocessJob, error)
GetReprocessJob retrieves a reprocess job by ID
func (*Memory) GetSession ¶ added in v0.8.0
func (*Memory) GetSessionMessages ¶ added in v0.8.0
func (*Memory) GetSessionsByTicket ¶ added in v0.8.0
func (*Memory) GetTagByID ¶
func (*Memory) GetTagByName ¶
func (*Memory) GetTagsByIDs ¶
func (*Memory) GetTicketByThread ¶
func (*Memory) GetTicketComments ¶
func (*Memory) GetTicketCommentsPaginated ¶
func (*Memory) GetTicketUnpromptedComments ¶
func (*Memory) GetTicketsBySpan ¶
func (*Memory) GetTicketsByStatus ¶
func (*Memory) GetTicketsByStatusAndSpan ¶
func (*Memory) GetTicketsWithInvalidEmbedding ¶
func (*Memory) IsTagNameExists ¶
func (*Memory) ListAgentMemories ¶ added in v0.6.2
func (r *Memory) ListAgentMemories(ctx context.Context, agentID string) ([]*memory.AgentMemory, error)
ListAgentMemories lists all memories for an agent Results are ordered by CreatedAt DESC
func (*Memory) ListAgentMemoriesWithOptions ¶ added in v0.8.0
func (r *Memory) ListAgentMemoriesWithOptions(ctx context.Context, agentID string, opts interfaces.AgentMemoryListOptions) ([]*memory.AgentMemory, int, error)
ListAgentMemoriesWithOptions lists memories with filtering, sorting, and pagination
func (*Memory) ListAllAgentIDs ¶ added in v0.8.0
func (r *Memory) ListAllAgentIDs(ctx context.Context) ([]*interfaces.AgentSummary, error)
ListAllAgentIDs returns all agent IDs that have memories with their counts
func (*Memory) ListAllKnowledges ¶ added in v0.14.0
func (*Memory) ListDiagnoses ¶ added in v0.13.0
func (r *Memory) ListDiagnoses(_ context.Context, offset, limit int) ([]*diagnosis.Diagnosis, int, error)
ListDiagnoses returns paginated diagnoses ordered by CreatedAt DESC.
func (*Memory) ListDiagnosisIssues ¶ added in v0.13.0
func (r *Memory) ListDiagnosisIssues(_ context.Context, diagnosisID types.DiagnosisID, offset, limit int, status *diagnosis.IssueStatus, ruleID *diagnosis.RuleID) ([]*diagnosis.Issue, int, error)
ListDiagnosisIssues returns paginated issues for a diagnosis ordered by CreatedAt ASC. status and ruleID are optional server-side filters.
func (*Memory) ListKnowledgeLogs ¶ added in v0.14.0
func (r *Memory) ListKnowledgeLogs(_ context.Context, knowledgeID types.KnowledgeID) ([]*knowledge.KnowledgeLog, error)
func (*Memory) ListKnowledgeTags ¶ added in v0.14.0
func (*Memory) ListKnowledgesByCategoryAndTags ¶ added in v0.14.0
func (r *Memory) ListKnowledgesByCategoryAndTags(_ context.Context, category types.KnowledgeCategory, tagIDs []types.KnowledgeTagID) ([]*knowledge.Knowledge, error)
func (*Memory) ListLegacyKnowledges ¶ added in v0.14.0
func (r *Memory) ListLegacyKnowledges(_ context.Context) ([]*interfaces.LegacyKnowledge, error)
ListLegacyKnowledges returns nil for the memory repository since it has no legacy data.
func (*Memory) ListPendingDiagnosisIssues ¶ added in v0.13.0
func (r *Memory) ListPendingDiagnosisIssues(_ context.Context, diagnosisID types.DiagnosisID) ([]*diagnosis.Issue, error)
ListPendingDiagnosisIssues returns all pending issues for a diagnosis.
func (*Memory) ListQueuedAlerts ¶ added in v0.14.0
func (r *Memory) ListQueuedAlerts(ctx context.Context, offset, limit int) ([]*alert.QueuedAlert, error)
ListQueuedAlerts returns queued alerts ordered by CreatedAt ASC (FIFO) with pagination
func (*Memory) PutActivity ¶
Activity related methods
func (*Memory) PutAlertList ¶
func (*Memory) PutDiagnosis ¶ added in v0.13.0
PutDiagnosis saves or updates a diagnosis header.
func (*Memory) PutDiagnosisIssue ¶ added in v0.13.0
PutDiagnosisIssue saves or updates a diagnosis issue.
func (*Memory) PutHITLRequest ¶ added in v0.13.0
func (*Memory) PutHistory ¶
func (*Memory) PutKnowledge ¶ added in v0.8.0
func (*Memory) PutKnowledgeLog ¶ added in v0.14.0
func (*Memory) PutKnowledgeTag ¶ added in v0.14.0
func (*Memory) PutQueuedAlert ¶ added in v0.14.0
PutQueuedAlert saves a queued alert
func (*Memory) PutRefineGroup ¶ added in v0.10.0
func (*Memory) PutReprocessBatchJob ¶ added in v0.14.0
PutReprocessBatchJob saves a reprocess batch job
func (*Memory) PutReprocessJob ¶ added in v0.14.0
PutReprocessJob saves a reprocess job
func (*Memory) PutSession ¶ added in v0.8.0
func (*Memory) PutSessionMessage ¶ added in v0.8.0
func (*Memory) PutTicketComment ¶
func (*Memory) PutTicketCommentsPrompted ¶
func (*Memory) RemoveTagFromAllAlerts ¶
func (*Memory) RemoveTagFromAllTickets ¶
func (*Memory) RemoveTagIDFromAllAlerts ¶
func (*Memory) RemoveTagIDFromAllTickets ¶
func (*Memory) ResetCallCounts ¶
func (r *Memory) ResetCallCounts()
ResetCallCounts clears all call counters
func (*Memory) SaveAgentMemory ¶
SaveAgentMemory saves an agent memory record
func (*Memory) SearchAlerts ¶
func (*Memory) SearchMemoriesByEmbedding ¶
func (r *Memory) SearchMemoriesByEmbedding(ctx context.Context, agentID string, embedding []float32, limit int) ([]*memory.AgentMemory, error)
SearchMemoriesByEmbedding searches for agent memories by embedding similarity
func (*Memory) SearchQueuedAlerts ¶ added in v0.14.0
func (r *Memory) SearchQueuedAlerts(ctx context.Context, keyword string, offset, limit int) ([]*alert.QueuedAlert, int, error)
SearchQueuedAlerts searches queued alerts by keyword in title and data
func (*Memory) UnbindAlertFromTicket ¶
func (*Memory) UpdateAlertStatus ¶ added in v0.10.0
func (*Memory) UpdateHITLRequestStatus ¶ added in v0.13.0
func (*Memory) UpdateMemoryScore ¶ added in v0.6.2
func (r *Memory) UpdateMemoryScore(ctx context.Context, agentID string, memoryID types.AgentMemoryID, score float64, lastUsedAt time.Time) error
UpdateMemoryScore updates the quality score and last used timestamp of an agent memory
func (*Memory) UpdateMemoryScoreBatch ¶ added in v0.6.2
func (r *Memory) UpdateMemoryScoreBatch(ctx context.Context, agentID string, updates map[types.AgentMemoryID]struct { Score float64 LastUsedAt time.Time }) error
UpdateMemoryScoreBatch updates quality scores and last used timestamps for multiple agent memories