Documentation
¶
Overview ¶
Package factory wires concrete dependencies for the github-dark-factory-watcher binary.
Index ¶
- func CreateGitHubAppClient(ctx context.Context, appID int64, installationID int64, pemKey []byte) (*http.Client, error)
- func CreateKafkaSender(syncProducer libkafka.SyncProducer, topicPrefix base.TopicPrefix) task.CreateCommandSender
- func CreateWatcher(ghClient pkg.GitHubClient, createSender task.CreateCommandSender, ...) pkg.Watcher
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateGitHubAppClient ¶
func CreateGitHubAppClient( ctx context.Context, appID int64, installationID int64, pemKey []byte, ) (*http.Client, error)
CreateGitHubAppClient creates an HTTP client authenticated as a GitHub App installation.
func CreateKafkaSender ¶
func CreateKafkaSender( syncProducer libkafka.SyncProducer, topicPrefix base.TopicPrefix, ) task.CreateCommandSender
CreateKafkaSender constructs a typed create-task command sender backed by a Kafka sync producer.
func CreateWatcher ¶
func CreateWatcher( ghClient pkg.GitHubClient, createSender task.CreateCommandSender, metrics pkg.Metrics, cursorPath string, startTime libtime.DateTime, scope string, scopeFilter filter.TaskCreationFilter, cfg pkg.TaskConfig, ) pkg.Watcher
CreateWatcher wires all dependencies and returns a ready-to-use Watcher.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.