webhook

Documentation

Index

• func IsSHA(ref string) bool
• type Metrics
  • func NewMetrics() *Metrics
• type Server
  • func (s *Server) CreateAgent(l *logrus.Entry, owner, repo, ref string) (plugins.Agent, error)
• type WebhooksController
  • func NewWebhooksController(path, namespace, botName, pluginFilename, configFilename string) (*WebhooksController, error)
  • func (o *WebhooksController) CleanupGitClientDir()
  • func (o *WebhooksController) DefaultHandler(w http.ResponseWriter, r *http.Request)
  • func (o *WebhooksController) HandlePollingRequests(w http.ResponseWriter, r *http.Request)
  • func (o *WebhooksController) HandleWebhookRequests(w http.ResponseWriter, r *http.Request)
  • func (o *WebhooksController) Health(w http.ResponseWriter, r *http.Request)
  • func (o *WebhooksController) Metrics(w http.ResponseWriter, r *http.Request)
  • func (o *WebhooksController) ProcessWebHook(l *logrus.Entry, webhook scm.Webhook) (*logrus.Entry, string, error)
  • func (o *WebhooksController) Ready(w http.ResponseWriter, r *http.Request)

Functions

func IsSHA

func IsSHA(ref string) bool

IsSHA returns true if the given ref is a SHA

Types

type Metrics

type Metrics struct {
	WebhookCounter  *prometheus.CounterVec
	ResponseCounter *prometheus.CounterVec
}

Metrics is a set of metrics gathered by hook.

func NewMetrics

func NewMetrics() *Metrics

NewMetrics creates a new set of metrics for the hook server.

type Server

type Server struct {
	ClientAgent    *plugins.ClientAgent
	Plugins        *plugins.ConfigAgent
	ConfigAgent    *config.Agent
	ServerURL      *url.URL
	TokenGenerator func() []byte
	Metrics        *Metrics
	FileBrowsers   *filebrowser.FileBrowsers
	InRepoCache    *lru.Cache
	// contains filtered or unexported fields
}

Server keeps the information required to start a server

func (*Server) CreateAgent

func (s *Server) CreateAgent(l *logrus.Entry, owner, repo, ref string) (plugins.Agent, error)

CreateAgent creates an agent for the given repository if the repository is configured to use in repository configuration then we create the use the repository specific configuration

type WebhooksController

type WebhooksController struct {
	ConfigMapWatcher *watcher.ConfigMapWatcher
	// contains filtered or unexported fields
}

WebhooksController holds the command line arguments

func NewWebhooksController

func NewWebhooksController(path, namespace, botName, pluginFilename, configFilename string) (*WebhooksController, error)

NewWebhooksController creates and configures the controller

func (*WebhooksController) CleanupGitClientDir

func (o *WebhooksController) CleanupGitClientDir()

CleanupGitClientDir cleans up the git client's working directory

func (*WebhooksController) DefaultHandler

func (o *WebhooksController) DefaultHandler(w http.ResponseWriter, r *http.Request)

DefaultHandler responds to requests without a specific handler

func (*WebhooksController) HandlePollingRequests

func (o *WebhooksController) HandlePollingRequests(w http.ResponseWriter, r *http.Request)

HandlePollingRequests handles incoming polling events

func (*WebhooksController) HandleWebhookRequests

func (o *WebhooksController) HandleWebhookRequests(w http.ResponseWriter, r *http.Request)

HandleWebhookRequests handles incoming webhook events

func (*WebhooksController) Health

func (o *WebhooksController) Health(w http.ResponseWriter, r *http.Request)

Health returns either HTTP 204 if the service is healthy, otherwise nothing ('cos it's dead).

func (*WebhooksController) Metrics

func (o *WebhooksController) Metrics(w http.ResponseWriter, r *http.Request)

Metrics returns the prometheus metrics

func (*WebhooksController) ProcessWebHook

func (o *WebhooksController) ProcessWebHook(l *logrus.Entry, webhook scm.Webhook) (*logrus.Entry, string, error)

ProcessWebHook process a webhook

func (*WebhooksController) Ready

func (o *WebhooksController) Ready(w http.ResponseWriter, r *http.Request)

Ready returns either HTTP 204 if the service is Ready to serve requests, otherwise HTTP 503.