server

Documentation

Index

• func NewPushWebhook(id string, subs []chan events.PushData, ph events.PayloadHandler) http.Handler
• func NewSubscriber(id string, bot repoBot, renderer krm.Renderer, messenger commitMessenger, ...) chan events.PushData
• func RequireHeaders(headers []config.Header, handler http.Handler) http.Handler
• func WatchConfigOrDie(path string, onChange func(c *config.NormalizedConfig))
• func WithK8sChain(o *Options)
• type Option
  • func WithConfig(c *config.NormalizedConfig) Option
  • func WithConfigPath(path string) Option
  • func WithDataPath(path string) Option
  • func WithDebounce(d time.Duration) Option
  • func WithDefaultRegistry(registry string) Option
  • func WithImagerefTemplate(t string) Option
  • func WithMuxGenerator(g muxGenerator) Option
  • func WithWatch(enabled bool) Option
• type Options
• type Server
  • func NewOrDie(options ...Option) *Server
  • func (s *Server) Reload(handler http.Handler)
  • func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)

Functions

func NewPushWebhook

func NewPushWebhook(id string, subs []chan events.PushData, ph events.PayloadHandler) http.Handler

func NewSubscriber

func NewSubscriber(id string, bot repoBot, renderer krm.Renderer, messenger commitMessenger, delay time.Duration) chan events.PushData

func RequireHeaders

func RequireHeaders(headers []config.Header, handler http.Handler) http.Handler

func WatchConfigOrDie

func WatchConfigOrDie(path string, onChange func(c *config.NormalizedConfig))

func WithK8sChain

func WithK8sChain(o *Options)

Types

type Option

type Option func(*Options)

func WithConfig

func WithConfig(c *config.NormalizedConfig) Option

func WithConfigPath

func WithConfigPath(path string) Option

func WithDataPath

func WithDataPath(path string) Option

func WithDebounce

func WithDebounce(d time.Duration) Option

func WithDefaultRegistry

func WithDefaultRegistry(registry string) Option

func WithImagerefTemplate

func WithImagerefTemplate(t string) Option

func WithMuxGenerator

func WithMuxGenerator(g muxGenerator) Option

func WithWatch

func WithWatch(enabled bool) Option

type Options

type Options struct {
	Watch       bool
	ConfigPath  string
	Config      *config.NormalizedConfig
	Datapath    string
	UseK8sChain bool
	// contains filtered or unexported fields
}

type Server

type Server struct {
	// contains filtered or unexported fields
}

func NewOrDie

func NewOrDie(options ...Option) *Server

func (*Server) Reload

func (s *Server) Reload(handler http.Handler)

func (*Server) ServeHTTP

func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)