Documentation
¶
Index ¶
- type Storage
- func (s *Storage) Close() error
- func (s *Storage) Create(ctx context.Context, req connection.CreateConnectionRequest) (*connection.Connection, error)
- func (s *Storage) Delete(ctx context.Context, id int64) error
- func (s *Storage) FindConnectionPaths(ctx context.Context, fromNoteID, toNoteID int64, maxDepth int) ([]connection.ConnectionPath, error)
- func (s *Storage) Get(ctx context.Context, id int64) (*connection.Connection, error)
- func (s *Storage) GetBidirectionalConnections(ctx context.Context, noteID int64) (*connection.NoteConnectionsResponse, error)
- func (s *Storage) GetConnectionStats(ctx context.Context) (*connection.ConnectionStats, error)
- func (s *Storage) GetConnectionsByType(ctx context.Context, connectionType string, ...) (*connection.ListConnectionsResponse, error)
- func (s *Storage) GetNoteConnections(ctx context.Context, req connection.NoteConnectionsRequest) (*connection.NoteConnectionsResponse, error)
- func (s *Storage) List(ctx context.Context, req connection.ListConnectionsRequest) (*connection.ListConnectionsResponse, error)
- func (s *Storage) Update(ctx context.Context, id int64, req connection.UpdateConnectionRequest) (*connection.Connection, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Storage ¶
type Storage struct {
// contains filtered or unexported fields
}
Storage implements the connection.Storage interface using SQLite
func NewStorage ¶
NewStorage creates a new SQLite storage instance
func (*Storage) Create ¶
func (s *Storage) Create(ctx context.Context, req connection.CreateConnectionRequest) (*connection.Connection, error)
Create creates a new connection
func (*Storage) FindConnectionPaths ¶
func (s *Storage) FindConnectionPaths(ctx context.Context, fromNoteID, toNoteID int64, maxDepth int) ([]connection.ConnectionPath, error)
FindConnectionPaths finds paths between two notes (basic implementation)
func (*Storage) Get ¶
func (s *Storage) Get(ctx context.Context, id int64) (*connection.Connection, error)
Get retrieves a connection by ID
func (*Storage) GetBidirectionalConnections ¶
func (s *Storage) GetBidirectionalConnections(ctx context.Context, noteID int64) (*connection.NoteConnectionsResponse, error)
GetBidirectionalConnections retrieves both incoming and outgoing connections for a note
func (*Storage) GetConnectionStats ¶
func (s *Storage) GetConnectionStats(ctx context.Context) (*connection.ConnectionStats, error)
GetConnectionStats retrieves statistics about connections
func (*Storage) GetConnectionsByType ¶
func (s *Storage) GetConnectionsByType(ctx context.Context, connectionType string, req connection.ListConnectionsRequest) (*connection.ListConnectionsResponse, error)
GetConnectionsByType retrieves connections filtered by type
func (*Storage) GetNoteConnections ¶
func (s *Storage) GetNoteConnections(ctx context.Context, req connection.NoteConnectionsRequest) (*connection.NoteConnectionsResponse, error)
GetNoteConnections retrieves all connections for a specific note
func (*Storage) List ¶
func (s *Storage) List(ctx context.Context, req connection.ListConnectionsRequest) (*connection.ListConnectionsResponse, error)
List lists connections with pagination and filtering
func (*Storage) Update ¶
func (s *Storage) Update(ctx context.Context, id int64, req connection.UpdateConnectionRequest) (*connection.Connection, error)
Update updates an existing connection
Source Files
Click to show internal directories.
Click to hide internal directories.