Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Collector ¶
type Collector struct {
// contains filtered or unexported fields
}
func NewCollector ¶
func NewCollector(repo *cluster.Repository, options Options) *Collector
func (*Collector) TriggerCollection ¶ added in v1.0.61
func (c *Collector) TriggerCollection(ctx context.Context, credentialIDs map[string]struct{}, providers map[string]struct{}) (int, error)
TriggerCollection queues an asynchronous forced collection round for the matching credentials and returns how many new local jobs were accepted. Empty filters accept every eligible credential. The round runs on a detached context so it outlives the caller (for example an HTTP request).
type Options ¶
type Options struct {
Owner string
HomeID string
GlobalProxyURL string
GlobalProxyURLProvider func() string
PollInterval time.Duration
ProbeTimeout time.Duration
LeaseDuration time.Duration
SnapshotFreshness time.Duration
ProviderConcurrency int
CodexUsageURL string
ClaudeUsageURL string
ClaudeProfileURL string
KimiUsageURL string
XAIBillingURL string
AntigravityURLs []string
Now func() time.Time
HTTPClient func(*coreauth.Auth, time.Duration) (*http.Client, error)
ResolveAuth func(context.Context, *coreauth.Auth) (*coreauth.Auth, error)
}
Source Files
Click to show internal directories.
Click to hide internal directories.