sqlite

package
v0.4.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 11, 2026 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrTagUnsupported   = errors.New("config store schema does not support tag queries")
	ErrInvalidKeyParts  = errors.New("invalid config store key parts")
	ErrUnknownIndexName = errors.New("unknown config store index")
)

Functions

func CleanupUsageEvents added in v0.4.0 

func CleanupUsageEvents(db *gorm.DB, retention time.Duration) error

func InsertACPUsageEvent added in v0.4.0 

func InsertACPUsageEvent(db *gorm.DB, ev usage.ACPUsageEvent) error

func InsertLLMUsageEvent added in v0.4.0 

func InsertLLMUsageEvent(db *gorm.DB, ev usage.LLMUsageEvent) error

func InsertMCPUsageEvent added in v0.4.0 

func InsertMCPUsageEvent(db *gorm.DB, ev usage.MCPUsageEvent) error

func MigrateUsageTables added in v0.4.0 

func MigrateUsageTables(db *gorm.DB) error

MigrateUsageTables creates the typed usage event tables and brings an older database up to the current shape.

The mcp_usage_events columns presented_tool_name, executed_tool_name, execution_mode, and policy_action are reserved for a future MCP tool-policy layer. Nothing populates them in v0.4.x, so they are always NULL; do not read them as dimensions.

Types

type Config 

type Config struct {
	SQLitePath string `json:"sqlite_path,omitempty"`
}

type JSONConfigStore 

type JSONConfigStore struct {
	// contains filtered or unexported fields
}

func (*JSONConfigStore) Create 

func (s *JSONConfigStore) Create(ctx context.Context, obj any) error

func (*JSONConfigStore) Delete 

func (s *JSONConfigStore) Delete(ctx context.Context, keyParts ...any) error

func (*JSONConfigStore) Get 

func (s *JSONConfigStore) Get(ctx context.Context, keyParts ...any) (any, error)

func (*JSONConfigStore) GetByIndex 

func (s *JSONConfigStore) GetByIndex(ctx context.Context, indexName string, value any) (any, error)

func (*JSONConfigStore) List 

func (s *JSONConfigStore) List(ctx context.Context) ([]any, error)

func (*JSONConfigStore) ListByTag 

func (s *JSONConfigStore) ListByTag(ctx context.Context, tag string) ([]any, error)

func (*JSONConfigStore) ListByTagPrefix 

func (s *JSONConfigStore) ListByTagPrefix(ctx context.Context, tagPrefix string) ([]any, error)

func (*JSONConfigStore) Update 

func (s *JSONConfigStore) Update(ctx context.Context, obj any) error

type SQLiteConfigStoreCreator 

type SQLiteConfigStoreCreator struct {
	SQLitePath string `json:"sqlite_path,omitempty"`
	// contains filtered or unexported fields
}

func Open 

func Open(ctx context.Context, cfg Config, logger *zap.Logger) (*SQLiteConfigStoreCreator, error)

func (*SQLiteConfigStoreCreator) NewStore 

func (s *SQLiteConfigStoreCreator) NewStore(storeSchema configstore.StoreSchema) (configstore.ConfigStore, error)

func (*SQLiteConfigStoreCreator) Open 

func (s *SQLiteConfigStoreCreator) Open(_ context.Context) error

func (*SQLiteConfigStoreCreator) UsageDB added in v0.4.0 

func (s *SQLiteConfigStoreCreator) UsageDB() *gorm.DB

type UsageQueries added in v0.4.0 

type UsageQueries struct {
	// contains filtered or unexported fields
}

func NewUsageQueries added in v0.4.0 

func NewUsageQueries(db *gorm.DB) *UsageQueries

func (*UsageQueries) ACPBreakdown added in v0.4.0 

func (q *UsageQueries) ACPBreakdown(opts usage.BreakdownOptions) (usage.BreakdownResponse, error)

func (*UsageQueries) ACPSummary added in v0.4.0 

func (q *UsageQueries) ACPSummary(opts usage.BreakdownOptions) (usage.BreakdownResponse, error)

func (*UsageQueries) ACPTimeseries added in v0.4.0 

func (q *UsageQueries) ACPTimeseries(opts usage.TimeseriesOptions) (usage.SeriesResponse, error)

func (*UsageQueries) InteractionsSummary added in v0.4.0 

func (q *UsageQueries) InteractionsSummary(opts usage.BreakdownOptions) (usage.BreakdownResponse, error)

func (*UsageQueries) LLMBreakdown added in v0.4.0 

func (q *UsageQueries) LLMBreakdown(opts usage.BreakdownOptions) (usage.BreakdownResponse, error)

func (*UsageQueries) LLMTimeseries added in v0.4.0 

func (q *UsageQueries) LLMTimeseries(opts usage.TimeseriesOptions) (usage.SeriesResponse, error)

func (*UsageQueries) ListEvents added in v0.4.0 

func (q *UsageQueries) ListEvents(kind string, opts usage.EventListOptions) (usage.EventListResponse, error)

func (*UsageQueries) ListInteractions added in v0.4.0 

func (q *UsageQueries) ListInteractions(opts usage.EventListOptions) (usage.EventListResponse, error)

func (*UsageQueries) MCPBreakdown added in v0.4.0 

func (q *UsageQueries) MCPBreakdown(opts usage.BreakdownOptions) (usage.BreakdownResponse, error)

func (*UsageQueries) MCPTimeseries added in v0.4.0 

func (q *UsageQueries) MCPTimeseries(opts usage.TimeseriesOptions) (usage.SeriesResponse, error)

func (*UsageQueries) MCPToolsSummary added in v0.4.0 

func (q *UsageQueries) MCPToolsSummary(opts usage.SummaryOptions) (usage.BreakdownResponse, error)

func (*UsageQueries) Summary added in v0.4.0 

func (q *UsageQueries) Summary() (usage.Summary, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.