Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func StartLinearPoller ¶
func StartLinearPoller( ctx context.Context, sidecars *sync.WaitGroup, cfg Config, runtimeCfg interfaces.RuntimeConfigLookup, workstation interfaces.FactoryWorkstationConfig, workerDef *interfaces.WorkerConfig, submitter Submitter, )
StartLinearPoller supervises a hosted Linear poller for one poller workstation. Unsupported providers must be filtered by the caller before invoking this function.
Types ¶
type Config ¶
type Config struct {
Logger *zap.Logger
Clock clockwork.Clock
HTTPClient *http.Client
SecretResolver SecretResolver
LinearEndpoint string
}
Config carries hosted-poller runtime dependencies injected by the service root.
type SecretResolver ¶
type SecretResolver func(ctx context.Context, runtimeCfg interfaces.RuntimeConfigLookup, secretRef string) (string, error)
SecretResolver resolves hosted-worker auth.secretRef values at runtime.
type Submitter ¶
type Submitter func(context.Context, interfaces.WorkRequest) error
Submitter submits normalized hosted-poller work requests into factory ingress.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.