Versions in this module Expand all Collapse all v0 v0.1.0 Jul 7, 2025 Changes in this version + type Client struct + Redis *redis.Client + SurrealDB *surrealdb.DB + func NewClient(cfg *config.Config) (*Client, error) + func (c *Client) Close() error + func (c *Client) ExecuteRedisCommand(ctx context.Context, cmd string, args ...interface{}) *redis.Cmd + func (c *Client) ExecuteSurrealQL(query string, vars map[string]interface{}) (interface{}, error) + func (c *Client) GetConfig() *config.Config + func (c *Client) GetRedis() *redis.Client + func (c *Client) GetSurrealDB() *surrealdb.DB + func (c *Client) Health(ctx context.Context) error + func (c *Client) IsRedisConnected() bool + func (c *Client) IsSurrealDBConnected() bool + func (c *Client) Reconnect() error + type CountFilters struct + Processed *bool + SessionID types.SessionID + TimeRange *models.TimeRange + type EpisodeStats struct + EpisodesWithEmbeddings int + LastUpdated time.Time + ProcessedEpisodes int + TotalEpisodes int + UniqueSessions int + UnprocessedEpisodes int + type EpisodeStore struct + func NewEpisodeStore(client *Client) *EpisodeStore + func (s *EpisodeStore) BatchCreate(ctx context.Context, episodes []*models.Episode) error + func (s *EpisodeStore) Count(ctx context.Context, tenantID types.TenantID, filters *CountFilters) (int, error) + func (s *EpisodeStore) Create(ctx context.Context, episode *models.Episode) error + func (s *EpisodeStore) Delete(ctx context.Context, tenantID types.TenantID, episodeID string) error + func (s *EpisodeStore) GetByID(ctx context.Context, tenantID types.TenantID, episodeID string) (*models.Episode, error) + func (s *EpisodeStore) GetBySessionID(ctx context.Context, tenantID types.TenantID, sessionID types.SessionID, ...) ([]*models.Episode, error) + func (s *EpisodeStore) GetStats(ctx context.Context, tenantID types.TenantID) (*EpisodeStats, error) + func (s *EpisodeStore) GetUnprocessed(ctx context.Context, tenantID types.TenantID, limit int) ([]*models.Episode, error) + func (s *EpisodeStore) List(ctx context.Context, tenantID types.TenantID, options *ListOptions) ([]*models.Episode, int, error) + func (s *EpisodeStore) MarkAsProcessed(ctx context.Context, tenantID types.TenantID, episodeID string) error + func (s *EpisodeStore) Update(ctx context.Context, tenantID types.TenantID, episodeID string, ...) (*models.Episode, error) + func (s *EpisodeStore) UpdateEmbedding(ctx context.Context, tenantID types.TenantID, episodeID string, ...) error + type GraphStats struct + EntityTypes map[string]int + LastUpdated time.Time + RelationshipTypes map[string]int + TotalEntities int + TotalRelationships int + type GraphStore struct + func NewGraphStore(client *Client) *GraphStore + func (s *GraphStore) BatchCreateEntities(ctx context.Context, entities []*models.Entity) error + func (s *GraphStore) BatchCreateRelationships(ctx context.Context, relationships []*models.Relationship) error + func (s *GraphStore) CreateEntity(ctx context.Context, entity *models.Entity) error + func (s *GraphStore) CreateRelationship(ctx context.Context, relationship *models.Relationship) error + func (s *GraphStore) DeleteEntity(ctx context.Context, tenantID types.TenantID, entityID string) error + func (s *GraphStore) DeleteRelationship(ctx context.Context, tenantID types.TenantID, relationshipID string) error + func (s *GraphStore) FindEntityByName(ctx context.Context, tenantID types.TenantID, name, entityType string) (*models.Entity, error) + func (s *GraphStore) GetEntityRelationships(ctx context.Context, tenantID types.TenantID, entityID string, ...) ([]*models.Relationship, error) + func (s *GraphStore) GetGraphStats(ctx context.Context, tenantID types.TenantID) (*GraphStats, error) + func (s *GraphStore) GetOrCreateEntity(ctx context.Context, tenantID types.TenantID, name, entityType string) (*models.Entity, error) + func (s *GraphStore) GetRelatedEntities(ctx context.Context, tenantID types.TenantID, entityID string, ...) ([]*models.RelatedEntity, error) + func (s *GraphStore) RelateEntities(ctx context.Context, tenantID types.TenantID, ...) error + func (s *GraphStore) RelationshipExists(ctx context.Context, tenantID types.TenantID, ...) (bool, error) + type ListOptions struct + Limit int + Offset int + OrderBy string + OrderDesc bool + Processed *bool + SessionID types.SessionID + TimeRange *models.TimeRange + type RelationshipDirection string + const RelationshipDirectionBoth + const RelationshipDirectionIncoming + const RelationshipDirectionOutgoing
Go to main page