Documentation
¶
Overview ¶
Package session provides a SQLite-based implementation of the ADK session.Service interface.
Index ¶
- type SQLiteService
- func (s *SQLiteService) AppendEvent(ctx context.Context, sess session.Session, ev *session.Event) error
- func (s *SQLiteService) Close() error
- func (s *SQLiteService) Create(ctx context.Context, req *session.CreateRequest) (*session.CreateResponse, error)
- func (s *SQLiteService) Delete(ctx context.Context, req *session.DeleteRequest) error
- func (s *SQLiteService) Get(ctx context.Context, req *session.GetRequest) (*session.GetResponse, error)
- func (s *SQLiteService) List(ctx context.Context, req *session.ListRequest) (*session.ListResponse, error)
- func (s *SQLiteService) ListWithSummaries(ctx context.Context, appName, userID string) ([]SessionInfo, error)
- func (s *SQLiteService) UpdateSummary(ctx context.Context, sessionID, summary string) error
- func (s *SQLiteService) UpdateTokenUsage(ctx context.Context, sessionID string, inputTokens, outputTokens int) error
- type SessionInfo
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SQLiteService ¶
type SQLiteService struct {
// contains filtered or unexported fields
}
SQLiteService implements session.Service using SQLite for persistence.
func NewSQLiteService ¶
func NewSQLiteService(dbPath string) (*SQLiteService, error)
NewSQLiteService creates a new SQLite-based session service. If dbPath is empty, it defaults to ~/.pumbaa/sessions.db
func (*SQLiteService) AppendEvent ¶
func (s *SQLiteService) AppendEvent(ctx context.Context, sess session.Session, ev *session.Event) error
AppendEvent appends an event to a session.
func (*SQLiteService) Close ¶
func (s *SQLiteService) Close() error
Close closes the database connection.
func (*SQLiteService) Create ¶
func (s *SQLiteService) Create(ctx context.Context, req *session.CreateRequest) (*session.CreateResponse, error)
Create creates a new session.
func (*SQLiteService) Delete ¶
func (s *SQLiteService) Delete(ctx context.Context, req *session.DeleteRequest) error
Delete deletes a session.
func (*SQLiteService) Get ¶
func (s *SQLiteService) Get(ctx context.Context, req *session.GetRequest) (*session.GetResponse, error)
Get retrieves a session by ID.
func (*SQLiteService) List ¶
func (s *SQLiteService) List(ctx context.Context, req *session.ListRequest) (*session.ListResponse, error)
List lists all sessions for a user.
func (*SQLiteService) ListWithSummaries ¶ added in v1.0.3
func (s *SQLiteService) ListWithSummaries(ctx context.Context, appName, userID string) ([]SessionInfo, error)
ListWithSummaries returns all sessions for a user with their summaries and metadata.
func (*SQLiteService) UpdateSummary ¶ added in v1.0.3
func (s *SQLiteService) UpdateSummary(ctx context.Context, sessionID, summary string) error
UpdateSummary updates the summary for a session.
func (*SQLiteService) UpdateTokenUsage ¶ added in v1.0.3
func (s *SQLiteService) UpdateTokenUsage(ctx context.Context, sessionID string, inputTokens, outputTokens int) error
UpdateTokenUsage updates the accumulated token counts for a session.