interceptors

Documentation

Index

• Constants
• func Canonical(h map[string][]string) http.Header
• func Execute(ctx context.Context, client *http.Client, ...) (*triggersv1beta1.InterceptorResponse, error)
• func Fail(c codes.Code, msg string) *triggersv1beta1.InterceptorResponse
• func Failf(c codes.Code, format string, a ...interface{}) *triggersv1beta1.InterceptorResponse
• func GetInterceptorParams(i *triggersv1beta1.EventInterceptor) map[string]interface{}
• func GetSecretToken(req *http.Request, sl corev1lister.SecretLister, sr *triggersv1beta1.SecretRef, ...) ([]byte, error)
• func ResolveToURL(getter InterceptorGetter, name string) (*apis.URL, error)
• func UnmarshalParams(ip map[string]interface{}, p interface{}) error
• type Interceptor
• type InterceptorGetter

Constants

const (
	CoreInterceptorsHost = "tekton-triggers-core-interceptors"
)

const RequestCacheKey key = "interceptors.RequestCache"

Functions

func Canonical

func Canonical(h map[string][]string) http.Header

Canonical updates the map keys to use the Canonical name

func Execute

func Execute(ctx context.Context, client *http.Client, req *triggersv1beta1.InterceptorRequest, url string) (*triggersv1beta1.InterceptorResponse, error)

func Fail

func Fail(c codes.Code, msg string) *triggersv1beta1.InterceptorResponse

Fail constructs a InterceptorResponse that should not continue further processing.

func Failf

func Failf(c codes.Code, format string, a ...interface{}) *triggersv1beta1.InterceptorResponse

Failf constructs a InterceptorResponse that should not continue further processing.

func GetInterceptorParams

func GetInterceptorParams(i *triggersv1beta1.EventInterceptor) map[string]interface{}

GetInterceptorParams returns InterceptorParams for the current interceptors

func GetSecretToken

func GetSecretToken(req *http.Request, sl corev1lister.SecretLister, sr *triggersv1beta1.SecretRef, triggerNS string) ([]byte, error)

GetSecretToken queries Kubernetes for the given secret reference. We use this function to resolve secret material like GitHub webhook secrets, and call it once for every trigger that references it.

As we may have many triggers that all use the same secret, we cache the secret values in the request cache.

func ResolveToURL

func ResolveToURL(getter InterceptorGetter, name string) (*apis.URL, error)

ResolveToURL finds an Interceptor's URL.

func UnmarshalParams

func UnmarshalParams(ip map[string]interface{}, p interface{}) error

UnmarshalParams unmarshalls the passed in InterceptorParams into the provided param struct

Types

type Interceptor

type Interceptor interface {
	ExecuteTrigger(req *http.Request) (*http.Response, error)
}

Interceptor is the interface that all interceptors implement.

type InterceptorGetter

type InterceptorGetter func(name string) (*triggersv1alpha1.ClusterInterceptor, error)