server

Documentation

Index

• Constants
• func CreateCerts(ctx context.Context, coreV1Interface corev1.CoreV1Interface, noAfter time.Time, ...) ([]byte, []byte, error)
• 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) CheckCertValidity(ctx context.Context, serverCert, caCert []byte, ...)
  • func (is *Server) ExecuteInterceptor(r *http.Request) ([]byte, error)
  • func (is *Server) ListAndUpdateClusterInterceptorCRD(ctx context.Context, tc triggersv1alpha1.TriggersV1alpha1Interface, ...) 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
	InterceptorTLSSecretKey = "INTERCEPTOR_TLS_SECRET_NAME"
	InterceptorTLSSvcKey    = "INTERCEPTOR_TLS_SVC_NAME"
)

Functions

func CreateCerts

func CreateCerts(ctx context.Context, coreV1Interface corev1.CoreV1Interface, noAfter time.Time, logger *zap.SugaredLogger) ([]byte, []byte, error)

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) CheckCertValidity

func (is *Server) CheckCertValidity(ctx context.Context, serverCert, caCert []byte, coreV1Interface corev1.CoreV1Interface,
	logger *zap.SugaredLogger, tc triggersv1alpha1.TriggersV1alpha1Interface, tickerTime time.Duration)

func (*Server) ExecuteInterceptor

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

func (*Server) ListAndUpdateClusterInterceptorCRD

func (is *Server) ListAndUpdateClusterInterceptorCRD(ctx context.Context, tc triggersv1alpha1.TriggersV1alpha1Interface, caCert []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)