server

Documentation

Index

• Constants
• func CreateAndValidateCerts(ctx context.Context, coreV1Interface corev1.CoreV1Interface, ...)
• func GetTLSData(ctx context.Context, logger *zap.SugaredLogger) (*tls.Certificate, error)
• func UpdateCACertToClusterInterceptorCRD(ctx context.Context, service *Server, ...)
• type Error
• type HTTPError
  • func (se HTTPError) Error() string
  • func (se HTTPError) Status() int
• type Server
  • func NewWithCoreInterceptors(sg interceptors.SecretGetter, logger *zap.SugaredLogger) (*Server, error)
  • func (is *Server) ExecuteInterceptor(r *http.Request) ([]byte, error)
  • func (is *Server) RegisterInterceptor(path string, interceptor triggersv1.InterceptorInterface)
  • func (is *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)

Constants

const (
	Decade = 100 * 365 * 24 * time.Hour
)

Functions

func CreateAndValidateCerts

func CreateAndValidateCerts(ctx context.Context, coreV1Interface corev1.CoreV1Interface, logger *zap.SugaredLogger, service *Server, tc triggersv1alpha1.TriggersV1alpha1Interface)

func GetTLSData

func GetTLSData(ctx context.Context, logger *zap.SugaredLogger) (*tls.Certificate, error)

func UpdateCACertToClusterInterceptorCRD

func UpdateCACertToClusterInterceptorCRD(ctx context.Context, service *Server, tc triggersv1alpha1.TriggersV1alpha1Interface, logger *zap.SugaredLogger, timer time.Duration)

Types

type Error

type Error interface {
	error
	Status() int
}

Error represents a handler error. It provides methods for a HTTP status code and embeds the built-in error interface.

type HTTPError

type HTTPError struct {
	Code int
	Err  error
}

HTTPError represents an error with an associated HTTP status code.

func (HTTPError) Error

func (se HTTPError) Error() string

Allows HTTPError to satisfy the error interface.

func (HTTPError) Status

func (se HTTPError) Status() int

Returns our HTTP status code.

type Server

type Server struct {
	Logger *zap.SugaredLogger
	// contains filtered or unexported fields
}

func NewWithCoreInterceptors

func NewWithCoreInterceptors(sg interceptors.SecretGetter, logger *zap.SugaredLogger) (*Server, error)

func (*Server) ExecuteInterceptor

func (is *Server) ExecuteInterceptor(r *http.Request) ([]byte, error)

func (*Server) RegisterInterceptor

func (is *Server) RegisterInterceptor(path string, interceptor triggersv1.InterceptorInterface)

RegisterInterceptor sets up the interceptor to be served at the specfied path

func (*Server) ServeHTTP

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