repo

package

v0.0.0-...-c20d9b3 Latest Latest Go to latest Published: Sep 23, 2025 License: AGPL-3.0 Imports: 18 Imported by: 0

Details

This section is empty.

This section is empty.

func NewProxyRepo(db *db.Client, redis *redis.Client) domain.ProxyRepo

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

func (r *ProxyRepo) AcceptCompletion(ctx context.Context, req *domain.AcceptCompletionReq) error

func (r *ProxyRepo) Record(ctx context.Context, record *domain.RecordParam) error

func (r *ProxyRepo) Report(ctx context.Context, model *db.Model, req *domain.ReportReq) error

func (r *ProxyRepo) SelectModelWithLoadBalancing(modelName string, modelType consts.ModelType) (*db.Model, error)

func (r *ProxyRepo) UpdateByTaskID(ctx context.Context, taskID string, fn func(*db.TaskUpdateOne)) error

func (r *ProxyRepo) ValidateApiKey(ctx context.Context, key string) (*db.ApiKey, error)