interceptor

Documentation

Index

• type DynamicWebhookHandler
  • func (dwc *DynamicWebhookHandler) Handle(w http.ResponseWriter, r *http.Request)
• type GitPushResponse
• type GitPusher
  • func (gp *GitPusher) Push() (GitPushResponse, error)
• type RepoRetriever
  • func (rp RepoRetriever) GetTargetRepository() (*git.Repository, error)
  • func (rp RepoRetriever) GetUpstreamRepository() (*git.Repository, error)
• type WebhookInterceptsAll
  • func (s *WebhookInterceptsAll) Register(interceptor syngit.RemoteSyncer, path string) *DynamicWebhookHandler
  • func (s *WebhookInterceptsAll) Start()
  • func (s *WebhookInterceptsAll) Unregister(n types.NamespacedName)
• type WebhookRequestChecker
  • func (wrc *WebhookRequestChecker) ProcessSteps() admissionv1.AdmissionReview
• type WorktreeRetriever
  • func (wr WorktreeRetriever) GetWorkTree(gp GitPusher) (*git.Worktree, bool, error)

Types

type DynamicWebhookHandler

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

PathHandler represents an instance of a path handler with a specific namespace and name

func (*DynamicWebhookHandler) Handle

func (dwc *DynamicWebhookHandler) Handle(w http.ResponseWriter, r *http.Request)

Handle processes the incoming dynamic webhook request

type GitPushResponse

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

type GitPusher

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

func (*GitPusher) Push

func (gp *GitPusher) Push() (GitPushResponse, error)

type RepoRetriever

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

func (RepoRetriever) GetTargetRepository

func (rp RepoRetriever) GetTargetRepository() (*git.Repository, error)

func (RepoRetriever) GetUpstreamRepository

func (rp RepoRetriever) GetUpstreamRepository() (*git.Repository, error)

type WebhookInterceptsAll

type WebhookInterceptsAll struct {
	K8sClient client.Client

	sync.RWMutex

	Manager ctrl.Manager
	// contains filtered or unexported fields
}

func (*WebhookInterceptsAll) Register

func (s *WebhookInterceptsAll) Register(interceptor syngit.RemoteSyncer, path string) *DynamicWebhookHandler

Register registers the path in the pathHandlers map

func (*WebhookInterceptsAll) Start

func (s *WebhookInterceptsAll) Start()

func (*WebhookInterceptsAll) Unregister

func (s *WebhookInterceptsAll) Unregister(n types.NamespacedName)

Unregister removes the specific webhook from the pathHandlers map

type WebhookRequestChecker

type WebhookRequestChecker struct {

	// Status and condition mutex
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*WebhookRequestChecker) ProcessSteps

func (wrc *WebhookRequestChecker) ProcessSteps() admissionv1.AdmissionReview

type WorktreeRetriever

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

func (WorktreeRetriever) GetWorkTree

func (wr WorktreeRetriever) GetWorkTree(gp GitPusher) (*git.Worktree, bool, error)