Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

webhook

package

Go to main page

Versions in this module

v0

v0.10.0

Jul 11, 2026

v0.9.0

May 5, 2026

Changes in this version

+ var ErrRepoLockTimeout = errors.New("repo lock timeout")

+ var ErrSyncQueueFull = errors.New("sync queue full")

+ var ErrSyncQueueShuttingDown = errors.New("sync queue shutting down")

+ func AllowRuleOwners(rules []RepoRule) []string

+ func AllowRulesSpanMultipleOwners(rules []RepoRule) (bool, []string)

+ func CloneOrPull(ctx context.Context, repoURL, repoRoot, namespace string, ...) error

+ func CloneOrPullBranch(ctx context.Context, repoURL, repoRoot, namespace, branch string, ...) error

+ func CloneOrPullBranchLocked(ctx context.Context, locker *RepoLocker, ...) error

+ func ExtractNamespace(repoFullName string) string

+ func GenerateAppJWT(appID int64, privateKeyPEM []byte) (string, error)

+ func IsNonRetryable(err error) bool

+ func NonRetryable(err error) error

+ func NormalizeBranchRef(ref string) (string, bool)

+ func RepoDir(repoRoot, namespace string) string

+ func ResolveCloneURL(repoFullName, payloadCloneURL string, baseURLs []string, allowPayload bool) (string, error)

+ type GitAuth struct

+ AppID int64

+ AppKey []byte

+ InstallToken string

+ SSHKeyData []byte

+ SSHKeyPath string

+ SSHPassword string

+ func (a *GitAuth) Resolve() (transport.AuthMethod, error)

+ type QueueConfig struct

+ MaxTrackedRepos int

+ ShutdownTimeout time.Duration

+ type RepoFilter struct

+ func NewRepoFilter(patterns []string) *RepoFilter

+ func NewRepoFilterFromRules(rules []RepoRule) *RepoFilter

+ func (f *RepoFilter) IsAllowed(repoFullName string) bool

+ func (f *RepoFilter) IsAllowedBranch(repoFullName, branch string) bool

+ func (f *RepoFilter) IsAllowedRef(repoFullName, ref string) bool

+ type RepoLocker struct

+ func NewRepoLocker(timeout time.Duration) *RepoLocker

+ func (l *RepoLocker) WithLock(ctx context.Context, lockRoot, repoFullName string, ...) error

+ type RepoRule struct

+ Branches []string

+ Pattern string

+ func ParseRepoRule(s string) RepoRule

+ type RepoStats struct

+ Branch string

+ EnqueuedAt time.Time

+ LastError string

+ LastErrorTime time.Time

+ LastSuccessTime time.Time

+ Processing bool

+ ProcessingAt time.Time

+ Queued bool

+ Repo string

+ type RetryConfig struct

+ BaseDelay time.Duration

+ MaxAttempts int

+ MaxDelay time.Duration

+ type SyncFunc func(ctx context.Context, repoFullName, cloneURL, branch string) error

+ type SyncHandlerFunc func(ctx context.Context, repoFullName, cloneURL, branch string) error

+ type SyncQueue struct

+ func NewSyncQueue(workers int, handler SyncHandlerFunc) *SyncQueue

+ func NewSyncQueueWithConfig(ctx context.Context, workers int, handler SyncHandlerFunc, cfg QueueConfig) *SyncQueue

+ func NewSyncQueueWithContext(ctx context.Context, workers int, handler SyncHandlerFunc) *SyncQueue

+ func NewSyncQueueWithOptions(ctx context.Context, workers int, handler SyncHandlerFunc, retry RetryConfig) *SyncQueue

+ func (q *SyncQueue) Add(ctx context.Context, repoFullName, cloneURL, branch string) error

+ func (q *SyncQueue) Shutdown()

+ func (q *SyncQueue) Stats() SyncQueueStats

+ type SyncQueueStats struct

+ Dirty int

+ FailureTotal int64

+ LastError string

+ LastErrorTime time.Time

+ LastSuccessTime time.Time

+ MaxTrackedRepos int

+ OldestProcessingAge time.Duration

+ OldestQueuedAge time.Duration

+ Processing int

+ QueueFullTotal int64

+ Queued int

+ RecentRepos []RepoStats

+ Shutdown bool

+ TrackedRepos int

+ type WebhookHandler struct

+ func NewWebhookHandler(secret []byte, filter *RepoFilter, onSync SyncFunc) *WebhookHandler

+ func NewWebhookHandlerWithConfig(cfg WebhookHandlerConfig) *WebhookHandler

+ func NewWebhookHandlerWithOptions(secret []byte, filter *RepoFilter, onSync SyncFunc, insecure bool) *WebhookHandler

+ func (h *WebhookHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type WebhookHandlerConfig struct

+ CloneBaseURL string

+ CloneBaseURLs []string

+ Filter *RepoFilter

+ Insecure bool

+ OnSync SyncFunc

+ Secret []byte

v0.8.5

Apr 19, 2026

v0.8.4

Apr 19, 2026