services

package

Go to main page

Versions in this module

v0

v0.4.3

May 2, 2026

v0.4.2

May 2, 2026

v0.4.1

May 2, 2026

v0.4.0

May 2, 2026

Changes in this version

+ const SuggestRuleSystemPrompt

+ var ErrModelManagementNotSupported = errors.New("model management not supported for this provider")

+ func AppendWebhookTrace(c *ServiceContainer, e WebhookTraceEntry)

+ func ContextWithLogBuffer(ctx context.Context, deliveryID string, buf *DeliveryLogBuffer) context.Context

+ func LoadAnthropicAPIKey(ctx context.Context, config *configs.Config) error

+ func RegisterOperatorRoutes(mux *http.ServeMux, cfg *configs.Config, container *ServiceContainer, ...)

type AuditEvent

+ Actor string

type AuditEventType

+ const AuditEventConfigChange

+ type AuditListQuery struct

+ EventType string

+ Limit int

+ PRNumber *int

+ PathSearch string

+ RuleName string

+ Since *time.Time

+ Success *bool

type AuditLogger

+ LogConfigChangeEvent func(ctx context.Context, event *AuditEvent) error

+ QueryAuditEvents func(ctx context.Context, q AuditListQuery) ([]AuditEvent, error)

+ type DeliveryLogBuffer struct

+ func NewDeliveryLogBuffer() *DeliveryLogBuffer

+ func (b *DeliveryLogBuffer) Append(deliveryID string, entry LogEntry)

+ func (b *DeliveryLogBuffer) Get(deliveryID string) []LogEntry

+ type DeliverySnapshot struct

+ DeliveryID string

+ Duplicate bool

+ SeenAt time.Time

type DeliveryTracker

+ func (dt *DeliveryTracker) HistoryLen() int

+ func (dt *DeliveryTracker) RecentDeliveries(max int) []DeliverySnapshot

+ type LLMClient interface

+ DeleteModel func(ctx context.Context, name string) error

+ GenerateJSON func(ctx context.Context, systemPrompt, userPrompt string) (string, error)

+ GetActiveModel func() string

+ GetBaseURL func() string

+ ListModels func(ctx context.Context) ([]LLMModel, error)

+ Ping func(ctx context.Context) error

+ ProviderName func() string

+ PullModel func(ctx context.Context, name string, progress func(LLMPullProgress)) error

+ SetActiveModel func(model string)

+ SetBaseURL func(url string)

+ func NewLLMClient(opts LLMClientOptions) (LLMClient, error)

+ type LLMClientOptions struct

+ APIKey string

+ BaseURL string

+ Model string

+ Provider string

+ type LLMModel struct

+ ModifiedAt string

+ Name string

+ Size int64

+ type LLMPullProgress struct

+ Completed int64

+ Digest string

+ Error string

+ Status string

+ Total int64

+ type LogEntry struct

+ Fields map[string]any

+ Level string

+ Message string

+ Time time.Time

type MongoAuditLogger

+ func (mal *MongoAuditLogger) LogConfigChangeEvent(ctx context.Context, event *AuditEvent) error

+ func (mal *MongoAuditLogger) QueryAuditEvents(ctx context.Context, q AuditListQuery) ([]AuditEvent, error)

type NoOpAuditLogger

+ func (nal *NoOpAuditLogger) LogConfigChangeEvent(ctx context.Context, event *AuditEvent) error

+ func (nal *NoOpAuditLogger) QueryAuditEvents(ctx context.Context, q AuditListQuery) ([]AuditEvent, error)

+ type OperatorDeploymentInfo struct

+ AuditCollection string

+ AuditDatabase string

+ AuditEnabled bool

+ CloudRunConfig string

+ CloudRunRevision string

+ CloudRunService string

+ ConfigRepo string

+ DryRun bool

+ EffectiveConfig string

+ Env map[string]string

+ GoogleCloudProject string

+ GoogleCloudRegion string

+ MongoHealthy *bool

+ OperatorRepoSlug string

+ Port string

+ ReleaseAPIMode ReleaseAPIMode

+ UptimeSeconds int64

+ Version string

+ WebhookPath string

+ type OperatorRole string

+ const RoleDenied

+ const RoleOperator

+ const RoleWriter

+ type OperatorUser struct

+ AvatarURL string

+ Login string

+ Role OperatorRole

+ type ReleaseAPIMode string

+ const ReleaseAPIDisabled

+ const ReleaseAPITagCreateEnabled

type ServiceContainer

+ DeliveryLogs *DeliveryLogBuffer

+ WebhookTraces *WebhookTraceBuffer

+ type WebhookTraceBuffer struct

+ func NewWebhookTraceBuffer() *WebhookTraceBuffer

+ func (b *WebhookTraceBuffer) Append(e WebhookTraceEntry)

+ func (b *WebhookTraceBuffer) Len() int

+ func (b *WebhookTraceBuffer) Recent(max int) []WebhookTraceEntry

+ func (b *WebhookTraceBuffer) RepoForDelivery(deliveryID string) string

+ type WebhookTraceEntry struct

+ Action string

+ At time.Time

+ BaseBranch string

+ CommitSHA string

+ DeliveryID string

+ Detail string

+ EventType string

+ Outcome string

+ PRNumber int

+ Repo string

v0.3.1

Apr 30, 2026

v0.3.0

Apr 14, 2026

v0.2.0

Feb 20, 2026

Changes in this version

+ const LevelCritical

+ var ErrAuthentication = errors.New("github app authentication failed")

+ var ErrConfigLoad = errors.New("config load failed")

+ var ErrConfigValidation = errors.New("config validation failed")

+ var ErrContentNil = errors.New("file content is nil")

+ var ErrInstallationNotFound = errors.New("no installation found for organization")

+ var ErrMergeConflict = errors.New("merge conflict")

+ var ErrSecretAccess = errors.New("secret access failed")

+ var GlobalRateLimitState = &RateLimitState

+ func AddFilesToTargetRepos(ctx context.Context, config *configs.Config, ...)

+ func CloseGoogleLogger()

+ func ConfigDiagnosticHandler(container *ServiceContainer, version string) http.HandlerFunc

+ func ConfigurePermissions(ctx context.Context, config *configs.Config) error

+ func DeleteBranchIfExistsExported(ctx context.Context, client *github.Client, defaultOwner, repo string, ...) error

+ func GetFilesChangedInPr(ctx context.Context, config *configs.Config, owner string, repo string, ...) ([]types.ChangedFile, error)

+ func GetGraphQLClient(ctx context.Context, config *configs.Config) (*graphql.Client, error)

+ func GetGraphQLClientForOrg(ctx context.Context, config *configs.Config, org string) (*graphql.Client, error)

+ func GetRestClient() *github.Client

+ func GetRestClientForOrg(ctx context.Context, config *configs.Config, org string) (*github.Client, error)

+ func HandleWebhookWithContainer(w http.ResponseWriter, r *http.Request, config *configs.Config, ...)

+ func HealthHandler(startTime time.Time, version string) http.HandlerFunc

+ func InitializeLogger(config *configs.Config)

+ func IsPermanentError(err error) bool

+ func LoadMongoURI(ctx context.Context, config *configs.Config) error

+ func LoadWebhookSecret(ctx context.Context, config *configs.Config) error

+ func LogAndReturnError(ctx context.Context, operation string, message string, err error)

+ func LogCritical(message string, args ...any)

+ func LogDebug(message string, args ...any)

+ func LogError(message string, args ...any)

+ func LogErrorCtx(ctx context.Context, message string, err error, fields map[string]interface{})

+ func LogFileOperation(ctx context.Context, operation string, sourcePath string, targetRepo string, ...)

+ func LogInfo(message string, args ...any)

+ func LogInfoCtx(ctx context.Context, message string, fields map[string]interface{})

+ func LogWarning(message string, args ...any)

+ func LogWarningCtx(ctx context.Context, message string, fields map[string]interface{})

+ func LogWebhookOperation(ctx context.Context, operation string, message string, err error, ...)

+ func MergePRBodyWithTemplate(configuredBody, template string) string

+ func MetricsHandler(metricsCollector *MetricsCollector, fileStateService FileStateService) http.HandlerFunc

+ func ReadinessHandler(container *ServiceContainer) http.HandlerFunc

+ func RetrieveFileContents(ctx context.Context, config *configs.Config, filePath string) (github.RepositoryContent, error)

+ func RetrieveFileContentsWithConfigAndBranch(ctx context.Context, config *configs.Config, filePath string, branch string, ...) (*github.RepositoryContent, error)

+ func SetInstallationTokenForOrg(org, token string)

+ func UpdateDeprecationFile(ctx context.Context, config *configs.Config, ...)

+ func WithRequestID(r *http.Request) (context.Context, string)

+ type AuditEvent struct

+ AdditionalData map[string]any

+ CommitSHA string

+ DurationMs int64

+ ErrorMessage string

+ EventType AuditEventType

+ FileSize int64

+ ID string

+ PRNumber int

+ RuleName string

+ SourcePath string

+ SourceRepo string

+ Success bool

+ TargetPath string

+ TargetRepo string

+ Timestamp time.Time

+ type AuditEventType string

+ const AuditEventCopy

+ const AuditEventDeprecation

+ const AuditEventError

+ type AuditLogger interface

+ Close func(ctx context.Context) error

+ GetDailyVolume func(ctx context.Context, days int) ([]DailyStats, error)

+ GetEventsByRule func(ctx context.Context, ruleName string, limit int) ([]AuditEvent, error)

+ GetFailedEvents func(ctx context.Context, limit int) ([]AuditEvent, error)

+ GetRecentEvents func(ctx context.Context, limit int) ([]AuditEvent, error)

+ GetStatsByRule func(ctx context.Context) (map[string]RuleStats, error)

+ LogCopyEvent func(ctx context.Context, event *AuditEvent) error

+ LogDeprecationEvent func(ctx context.Context, event *AuditEvent) error

+ LogErrorEvent func(ctx context.Context, event *AuditEvent) error

+ Ping func(ctx context.Context) error

+ func NewMongoAuditLogger(ctx context.Context, mongoURI, database, collection string, enabled bool) (AuditLogger, error)

+ type AuditLoggerHealthStatus struct

+ Connected bool

+ Status string

+ type CachedConfigLoader struct

+ func (c *CachedConfigLoader) InvalidateCache()

+ func (c *CachedConfigLoader) LoadConfig(ctx context.Context, config *configs.Config) (*types.YAMLConfig, error)

+ func (c *CachedConfigLoader) LoadConfigFromContent(content string, filename string) (*types.YAMLConfig, error)

+ type ConfigDiagnosticResponse struct

+ Environment ConfigEnvironment

+ LoadError string

+ Version string

+ Workflows []ConfigDiagnosticWorkflow

+ type ConfigDiagnosticWorkflow struct

+ CommitStrategy string

+ DestBranch string

+ DestRepo string

+ Exclude []string

+ Name string

+ SourceBranch string

+ SourceRepo string

+ Transforms int

+ type ConfigEnvironment struct

+ AuditEnabled bool

+ ConfigCacheTTLSeconds int

+ ConfigRepoBranch string

+ ConfigRepoName string

+ ConfigRepoOwner string

+ DryRun bool

+ EffectiveConfig string

+ GitHubAPIMaxRetries int

+ MetricsEnabled bool

+ MongoURI string

+ PEMKey string

+ Port string

+ SlackEnabled bool

+ SlackWebhook string

+ UseMainConfig bool

+ WebhookMaxRetries int

+ WebhookProcessingTimeoutSeconds int

+ WebhookSecret string

+ WebserverPath string

+ type ConfigLoader interface

+ LoadConfig func(ctx context.Context, config *configs.Config) (*types.YAMLConfig, error)

+ LoadConfigFromContent func(content string, filename string) (*types.YAMLConfig, error)

+ func NewCachedConfigLoader(inner ConfigLoader, ttl time.Duration) ConfigLoader

+ func NewConfigLoader() ConfigLoader

+ func NewMainConfigLoader() ConfigLoader

+ type DailyStats struct

+ Date string

+ FailureCount int

+ SuccessCount int

+ TotalCopies int

+ type DefaultConfigLoader struct

+ func (cl *DefaultConfigLoader) LoadConfig(ctx context.Context, config *configs.Config) (*types.YAMLConfig, error)

+ func (cl *DefaultConfigLoader) LoadConfigFromContent(content string, filename string) (*types.YAMLConfig, error)

+ type DefaultFileStateService struct

+ func (fss *DefaultFileStateService) AddFileToDeprecate(deprecationFile string, entry types.DeprecatedFileEntry)

+ func (fss *DefaultFileStateService) AddFileToUpload(key types.UploadKey, content types.UploadFileContent)

+ func (fss *DefaultFileStateService) ClearFilesToDeprecate()

+ func (fss *DefaultFileStateService) ClearFilesToUpload()

+ func (fss *DefaultFileStateService) GetFilesToDeprecate() map[string][]types.DeprecatedFileEntry

+ func (fss *DefaultFileStateService) GetFilesToUpload() map[types.UploadKey]types.UploadFileContent

+ type DefaultMainConfigLoader struct

+ func (mcl *DefaultMainConfigLoader) LoadConfig(ctx context.Context, config *configs.Config) (*types.YAMLConfig, error)

+ func (mcl *DefaultMainConfigLoader) LoadConfigFromContent(content string, filename string) (*types.YAMLConfig, error)

+ func (mcl *DefaultMainConfigLoader) LoadMainConfig(ctx context.Context, config *configs.Config) (*types.YAMLConfig, error)

+ func (mcl *DefaultMainConfigLoader) LoadMainConfigFromContent(ctx context.Context, content string, config *configs.Config) (*types.YAMLConfig, error)

+ type DefaultMessageTemplater struct

+ func (mt *DefaultMessageTemplater) RenderCommitMessage(template string, ctx *types.MessageContext) string

+ func (mt *DefaultMessageTemplater) RenderPRBody(template string, ctx *types.MessageContext) string

+ func (mt *DefaultMessageTemplater) RenderPRTitle(template string, ctx *types.MessageContext) string

+ type DefaultPRTemplateFetcher struct

+ func (f *DefaultPRTemplateFetcher) FetchPRTemplate(ctx context.Context, client *github.Client, repoFullName string, branch string) (string, error)

+ type DefaultPathTransformer struct

+ func (pt *DefaultPathTransformer) Transform(sourcePath string, template string, variables map[string]string) (string, error)

+ type DefaultPatternMatcher struct

+ func (pm *DefaultPatternMatcher) Match(filePath string, pattern types.SourcePattern) types.MatchResult

+ type DefaultSlackNotifier struct

+ func (sn *DefaultSlackNotifier) IsEnabled() bool

+ func (sn *DefaultSlackNotifier) NotifyDeprecation(ctx context.Context, event *DeprecationEvent) error

+ func (sn *DefaultSlackNotifier) NotifyError(ctx context.Context, event *ErrorEvent) error

+ func (sn *DefaultSlackNotifier) NotifyFilesCopied(ctx context.Context, event *FilesCopiedEvent) error

+ func (sn *DefaultSlackNotifier) NotifyPRProcessed(ctx context.Context, event *PRProcessedEvent) error

+ type DeliveryTracker struct

+ func NewDeliveryTracker(ttl time.Duration) *DeliveryTracker

+ func (dt *DeliveryTracker) Len() int

+ func (dt *DeliveryTracker) Stop()

+ func (dt *DeliveryTracker) TryRecord(deliveryID string) bool

+ type DeprecationEvent struct

+ FileCount int

+ Files []string

+ PRNumber int

+ SourceRepo string

+ type ErrorEvent struct

+ AdditionalInfo map[string]interface{}

+ Attempts int

+ DeliveryID string

+ Error error

+ Operation string

+ PRNumber int

+ SourceRepo string

+ type FileMetrics struct

+ Deprecated int64

+ Matched int64

+ UploadFailed int64

+ UploadSuccessRate float64

+ UploadTime ProcessingTimeStats

+ Uploaded int64

+ type FileStateService interface

+ AddFileToDeprecate func(deprecationFile string, entry types.DeprecatedFileEntry)

+ AddFileToUpload func(key types.UploadKey, content types.UploadFileContent)

+ ClearFilesToDeprecate func()

+ ClearFilesToUpload func()

+ GetFilesToDeprecate func() map[string][]types.DeprecatedFileEntry

+ GetFilesToUpload func() map[types.UploadKey]types.UploadFileContent

+ func NewFileStateService() FileStateService

+ type FilesCopiedEvent struct

+ FileCount int

+ Files []string

+ PRNumber int

+ RuleName string

+ SourceRepo string

+ TargetRepo string

+ type GitHubAPIMetrics struct

+ Calls int64

+ ErrorRate float64

+ Errors int64

+ RateLimit RateLimitInfo

+ type GitHubHealthStatus struct

+ Authenticated bool

+ Status string

+ type HealthStatus struct

+ AuditLogger AuditLoggerHealthStatus

+ GitHub GitHubHealthStatus

+ Queues QueueHealthStatus

+ Started bool

+ Status string

+ Uptime string

+ type MessageTemplater interface

+ RenderCommitMessage func(template string, ctx *types.MessageContext) string

+ RenderPRBody func(template string, ctx *types.MessageContext) string

+ RenderPRTitle func(template string, ctx *types.MessageContext) string

+ func NewMessageTemplater() MessageTemplater

+ type MetricsCollector struct

+ func NewMetricsCollector() *MetricsCollector

+ func (mc *MetricsCollector) GetFilesMatched() int

+ func (mc *MetricsCollector) GetFilesUploadFailed() int

+ func (mc *MetricsCollector) GetFilesUploaded() int

+ func (mc *MetricsCollector) GetMetrics(fileStateService FileStateService) MetricsData

+ func (mc *MetricsCollector) RecordFileDeprecated()

+ func (mc *MetricsCollector) RecordFileMatched()

+ func (mc *MetricsCollector) RecordFileUploadFailed()

+ func (mc *MetricsCollector) RecordFileUploaded(duration time.Duration)

+ func (mc *MetricsCollector) RecordGitHubAPICall()

+ func (mc *MetricsCollector) RecordGitHubAPIError()

+ func (mc *MetricsCollector) RecordWebhookFailed()

+ func (mc *MetricsCollector) RecordWebhookIgnored(eventType string)

+ func (mc *MetricsCollector) RecordWebhookProcessed(duration time.Duration)

+ func (mc *MetricsCollector) RecordWebhookReceived()

+ type MetricsData struct

+ Files FileMetrics

+ GitHubAPI GitHubAPIMetrics

+ Queues QueueMetrics

+ System SystemMetrics

+ Webhooks WebhookMetrics

+ type MongoAuditLogger struct

+ func (mal *MongoAuditLogger) Close(ctx context.Context) error

+ func (mal *MongoAuditLogger) GetDailyVolume(ctx context.Context, days int) ([]DailyStats, error)

+ func (mal *MongoAuditLogger) GetEventsByRule(ctx context.Context, ruleName string, limit int) ([]AuditEvent, error)

+ func (mal *MongoAuditLogger) GetFailedEvents(ctx context.Context, limit int) ([]AuditEvent, error)

+ func (mal *MongoAuditLogger) GetRecentEvents(ctx context.Context, limit int) ([]AuditEvent, error)

+ func (mal *MongoAuditLogger) GetStatsByRule(ctx context.Context) (map[string]RuleStats, error)

+ func (mal *MongoAuditLogger) LogCopyEvent(ctx context.Context, event *AuditEvent) error

+ func (mal *MongoAuditLogger) LogDeprecationEvent(ctx context.Context, event *AuditEvent) error

+ func (mal *MongoAuditLogger) LogErrorEvent(ctx context.Context, event *AuditEvent) error

+ func (mal *MongoAuditLogger) Ping(ctx context.Context) error

+ type NoOpAuditLogger struct

+ func (nal *NoOpAuditLogger) Close(ctx context.Context) error

+ func (nal *NoOpAuditLogger) GetDailyVolume(ctx context.Context, days int) ([]DailyStats, error)

+ func (nal *NoOpAuditLogger) GetEventsByRule(ctx context.Context, ruleName string, limit int) ([]AuditEvent, error)

+ func (nal *NoOpAuditLogger) GetFailedEvents(ctx context.Context, limit int) ([]AuditEvent, error)

+ func (nal *NoOpAuditLogger) GetRecentEvents(ctx context.Context, limit int) ([]AuditEvent, error)

+ func (nal *NoOpAuditLogger) GetStatsByRule(ctx context.Context) (map[string]RuleStats, error)

+ func (nal *NoOpAuditLogger) LogCopyEvent(ctx context.Context, event *AuditEvent) error

+ func (nal *NoOpAuditLogger) LogDeprecationEvent(ctx context.Context, event *AuditEvent) error

+ func (nal *NoOpAuditLogger) LogErrorEvent(ctx context.Context, event *AuditEvent) error

+ func (nal *NoOpAuditLogger) Ping(ctx context.Context) error

+ type PRProcessedEvent struct

+ FilesCopied int

+ FilesFailed int

+ FilesMatched int

+ PRNumber int

+ PRTitle string

+ PRURL string

+ ProcessingTime time.Duration

+ SourceRepo string

+ TargetRepos []string

+ type PRTemplateFetcher interface

+ FetchPRTemplate func(ctx context.Context, client *github.Client, repoFullName string, branch string) (string, error)

+ func NewPRTemplateFetcher() PRTemplateFetcher

+ type PathTransformer interface

+ Transform func(sourcePath string, template string, variables map[string]string) (string, error)

+ func NewPathTransformer() PathTransformer

+ type PatternMatcher interface

+ Match func(filePath string, pattern types.SourcePattern) types.MatchResult

+ func NewPatternMatcher() PatternMatcher

+ type ProcessingTimeStats struct

+ AvgMs float64

+ MaxMs float64

+ MinMs float64

+ P50Ms float64

+ P95Ms float64

+ P99Ms float64

+ type QueueHealthStatus struct

+ DeprecationCount int

+ UploadCount int

+ type QueueMetrics struct

+ DeprecationQueueSize int

+ RetryQueueSize int

+ UploadQueueSize int

+ type RateLimitInfo struct

+ Remaining int

+ ResetAt time.Time

+ type RateLimitState struct

+ func (s *RateLimitState) Get() (remaining int, resetAt time.Time)

+ type RuleStats struct

+ AvgDuration float64

+ FailureCount int

+ RuleName string

+ SuccessCount int

+ TotalCopies int

+ type ServiceContainer struct

+ AuditLogger AuditLogger

+ Config *configs.Config

+ ConfigLoader ConfigLoader

+ DeliveryTracker *DeliveryTracker

+ FileStateService FileStateService

+ MessageTemplater MessageTemplater

+ MetricsCollector *MetricsCollector

+ PRTemplateFetcher PRTemplateFetcher

+ PathTransformer PathTransformer

+ PatternMatcher PatternMatcher

+ SlackNotifier SlackNotifier

+ StartTime time.Time

+ TokenManager *TokenManager

+ func NewServiceContainer(config *configs.Config) (*ServiceContainer, error)

+ func (sc *ServiceContainer) Close(ctx context.Context) error

+ func (sc *ServiceContainer) IsClosed() bool

+ func (sc *ServiceContainer) Wait()

+ type SlackAttachment struct

+ Color string

+ Fields []SlackField

+ Footer string

+ FooterIcon string

+ Text string

+ Timestamp int64

+ Title string

+ TitleLink string

+ type SlackField struct

+ Short bool

+ Title string

+ Value string

+ type SlackMessage struct

+ Attachments []SlackAttachment

+ Channel string

+ IconEmoji string

+ Text string

+ Username string

+ type SlackNotifier interface

+ IsEnabled func() bool

+ NotifyDeprecation func(ctx context.Context, event *DeprecationEvent) error

+ NotifyError func(ctx context.Context, event *ErrorEvent) error

+ NotifyFilesCopied func(ctx context.Context, event *FilesCopiedEvent) error

+ NotifyPRProcessed func(ctx context.Context, event *PRProcessedEvent) error

+ func NewSlackNotifier(webhookURL, channel, username, iconEmoji string) SlackNotifier

+ func NewSlackNotifierWithOptions(webhookURL, channel, username, iconEmoji string, plainTextOnly bool, ...) SlackNotifier

+ type SystemMetrics struct

+ UptimeSeconds int64

+ type TokenManager struct

+ func DefaultTokenManager() *TokenManager

+ func NewTokenManager() *TokenManager

+ func (tm *TokenManager) GetCachedJWT() (string, bool)

+ func (tm *TokenManager) GetHTTPClient() *http.Client

+ func (tm *TokenManager) GetInstallationAccessToken() string

+ func (tm *TokenManager) GetTokenForOrg(org string) (string, bool)

+ func (tm *TokenManager) SetCachedJWT(token string, expiry time.Time)

+ func (tm *TokenManager) SetHTTPClient(client *http.Client)

+ func (tm *TokenManager) SetInstallationAccessToken(token string)

+ func (tm *TokenManager) SetTokenForOrg(org, token string, expiresAt time.Time)

+ func (tm *TokenManager) SetTokenForOrgNoExpiry(org, token string)

+ type WebhookMetrics struct

+ EventTypes map[string]int64

+ Failed int64

+ Ignored int64

+ Processed int64

+ ProcessingTime ProcessingTimeStats

+ Received int64

+ SuccessRate float64

+ type WorkflowProcessor interface

+ ProcessWorkflow func(ctx context.Context, workflow types.Workflow, changedFiles []types.ChangedFile, ...) error

+ func NewWorkflowProcessor(patternMatcher PatternMatcher, pathTransformer PathTransformer, ...) WorkflowProcessor

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL