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
CodexResetCreditsURL 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.