sqlite

package

v0.4.2 Latest Latest Go to latest Published: Jul 5, 2026 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/agent-guide/agent-gateway

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func CleanupUsageEvents(db *gorm.DB, retention time.Duration) error
func InsertACPUsageEvent(db *gorm.DB, ev usage.ACPUsageEvent) error
func InsertLLMUsageEvent(db *gorm.DB, ev usage.LLMUsageEvent) error
func InsertMCPUsageEvent(db *gorm.DB, ev usage.MCPUsageEvent) error
func MigrateUsageTables(db *gorm.DB) error
type Config
type JSONConfigStore
type SQLiteConfigStoreCreator
- func Open(ctx context.Context, cfg Config, logger *zap.Logger) (*SQLiteConfigStoreCreator, error)
type UsageQueries
- func NewUsageQueries(db *gorm.DB) *UsageQueries

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

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

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