store

package

Go to main page

Versions in this module

v0

v0.8.1

Mar 4, 2026

v0.8.0

Mar 4, 2026

Changes in this version

+ type Session struct

+ CreatedAt time.Time

+ ExternalID string

+ ID string

+ LastAccessedAt time.Time

+ TenantID string

type Store

+ func (s *Store) DeleteSession(ctx context.Context, tenantID, externalID string) error

+ func (s *Store) GetOrCreateSession(ctx context.Context, tenantID, externalID string) (*Session, error)

+ func (s *Store) GetSession(ctx context.Context, tenantID, sessionID string) (*Session, error)

+ func (s *Store) GetSessionByExternalID(ctx context.Context, tenantID, externalID string) (*Session, error)

+ func (s *Store) ListSessionFiles(ctx context.Context, tenantID, sessionID string) ([]*File, error)

+ func (s *Store) TouchSession(ctx context.Context, sessionID string) error

v0.7.0

Mar 3, 2026

v0.6.0

Mar 3, 2026

v0.5.0

Mar 3, 2026

v0.4.0

Mar 3, 2026

v0.3.0

Mar 3, 2026

Changes in this version

+ type DBTX interface

+ ExecContext func(ctx context.Context, query string, args ...any) (sql.Result, error)

+ QueryContext func(ctx context.Context, query string, args ...any) (*sql.Rows, error)

+ QueryRowContext func(ctx context.Context, query string, args ...any) *sql.Row

type Store

+ func (s *Store) RunInTx(ctx context.Context, fn func(tx *Store) error) error

v0.2.0

Mar 3, 2026

Changes in this version

+ type File struct

+ ContentType string

+ CreatedAt time.Time

+ ExecutionID string

+ ID string

+ Name string

+ ParentID *string

+ S3Key string

+ SessionID string

+ SizeBytes int64

+ TenantID string

+ UpdatedAt time.Time

+ Version int

+ type FileFilter struct

+ ExecutionID string

+ Limit int

+ Offset int

+ SessionID string

+ TenantID string

type Store

+ func (s *Store) CreateFile(ctx context.Context, f *File) (*File, error)

+ func (s *Store) DeleteFile(ctx context.Context, id string) error

+ func (s *Store) GetFile(ctx context.Context, id string) (*File, error)

+ func (s *Store) ListFileVersions(ctx context.Context, fileID string) ([]*File, error)

+ func (s *Store) ListFiles(ctx context.Context, filter FileFilter) ([]*File, error)

+ func (s *Store) ResolveLatestVersion(ctx context.Context, tenantID, name string) (string, error)

+ func (s *Store) UpdateFile(ctx context.Context, f *File) error

v0.1.0

Feb 26, 2026

Changes in this version

+ var ErrNotFound = errors.New("not found")

+ type APIKey struct

+ CreatedAt time.Time

+ ID string

+ KeyHash string

+ Name string

+ RevokedAt *time.Time

+ TenantID string

+ type Execution struct

+ CreatedAt time.Time

+ DurationMs int64

+ Error *string

+ FilesList []string

+ FilesURL string

+ FinishedAt *time.Time

+ ID string

+ Input json.RawMessage

+ Logs string

+ Output json.RawMessage

+ SkillName string

+ SkillVersion string

+ Status string

+ TenantID string

+ type SkillRecord struct

+ Description string

+ Lang string

+ Name string

+ TenantID string

+ UploadedAt time.Time

+ Version string

+ type Store struct

+ func New(dsn string) (*Store, error)

+ func NewWithDB(db *sql.DB) *Store

+ func (s *Store) Close() error

+ func (s *Store) CreateExecution(ctx context.Context, e *Execution) (*Execution, error)

+ func (s *Store) CreateKey(ctx context.Context, tenantID, name, keyHash string) (*APIKey, error)

+ func (s *Store) DB() *sql.DB

+ func (s *Store) DeleteSkill(ctx context.Context, tenantID, name, version string) error

+ func (s *Store) GetAPIKeyByHash(ctx context.Context, hash string) (*APIKey, error)

+ func (s *Store) GetExecution(ctx context.Context, id string) (*Execution, error)

+ func (s *Store) GetSkill(ctx context.Context, tenantID, name, version string) (*SkillRecord, error)

+ func (s *Store) InsertExecution(ctx context.Context, e *Execution) error

+ func (s *Store) ListExecutions(ctx context.Context, tenantID string, limit, offset int) ([]Execution, error)

+ func (s *Store) ListKeys(ctx context.Context, tenantID string) ([]APIKey, error)

+ func (s *Store) ListSkills(ctx context.Context, tenantID string) ([]SkillRecord, error)

+ func (s *Store) Ping(ctx context.Context) error

+ func (s *Store) RevokeKey(ctx context.Context, keyID string) error

+ func (s *Store) UpdateExecution(ctx context.Context, e *Execution) error

+ func (s *Store) UpsertSkill(ctx context.Context, rec *SkillRecord) error

+ func (s *Store) ValidateKey(ctx context.Context, keyHash string) (*APIKey, error)

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