wrappa

Documentation

Index

• type APIAuthWrappa
  • func NewAPIAuthWrappa(checkPipelineAccessHandlerFactory auth.CheckPipelineAccessHandlerFactory, ...) *APIAuthWrappa
  • func (wrappa *APIAuthWrappa) Wrap(handlers rata.Handlers) rata.Handlers
• type APIMetricsWrappa
  • func (wrappa APIMetricsWrappa) Wrap(handlers rata.Handlers) rata.Handlers
• type AccessorWrappa
  • func NewAccessorWrappa(logger lager.Logger, accessFactory accessor.AccessFactory, ...) *AccessorWrappa
  • func (w *AccessorWrappa) Wrap(handlers rata.Handlers) rata.Handlers
• type CompressionWrappa
  • func (wrappa CompressionWrappa) Wrap(handlers rata.Handlers) rata.Handlers
• type ConcourseVersionWrappa
  • func (wrappa ConcourseVersionWrappa) Wrap(handlers rata.Handlers) rata.Handlers
• type ConcurrentRequestLimitsWrappa
  • func (wrappa ConcurrentRequestLimitsWrappa) Wrap(handlers rata.Handlers) rata.Handlers
• type ConcurrentRequestPolicy
  • func NewConcurrentRequestPolicy(limits map[LimitedRoute]int) ConcurrentRequestPolicy
• type LimitedRoute
  • func (lr *LimitedRoute) UnmarshalFlag(value string) error
• type LoggerHandler
  • func (handler LoggerHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type MultiWrappa
  • func (wrappas MultiWrappa) Wrap(handlers rata.Handlers) rata.Handlers
• type PolicyCheckWrappa
  • func NewPolicyCheckWrappa(logger lager.Logger, checker policychecker.PolicyChecker) *PolicyCheckWrappa
  • func (w *PolicyCheckWrappa) Wrap(handlers rata.Handlers) rata.Handlers
• type Pool
  • func NewPool(size int) Pool
• type RejectArchivedWrappa
  • func NewRejectArchivedWrappa(factory pipelineserver.RejectArchivedHandlerFactory) *RejectArchivedWrappa
  • func (rw *RejectArchivedWrappa) Wrap(handlers rata.Handlers) rata.Handlers
• type SecurityHandler
  • func (handler SecurityHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type VersionedHandler
  • func (handler VersionedHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type Wrappa
  • func NewAPIMetricsWrappa(logger lager.Logger) Wrappa
  • func NewCompressionWrappa(logger lager.Logger) Wrappa
  • func NewConcourseVersionWrappa(version string) Wrappa
  • func NewConcurrentRequestLimitsWrappa(logger lager.Logger, concurrentRequestPolicy ConcurrentRequestPolicy) Wrappa

Types

type APIAuthWrappa

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

func NewAPIAuthWrappa

func NewAPIAuthWrappa(
	checkPipelineAccessHandlerFactory auth.CheckPipelineAccessHandlerFactory,
	checkBuildReadAccessHandlerFactory auth.CheckBuildReadAccessHandlerFactory,
	checkBuildWriteAccessHandlerFactory auth.CheckBuildWriteAccessHandlerFactory,
	checkWorkerTeamAccessHandlerFactory auth.CheckWorkerTeamAccessHandlerFactory,
) *APIAuthWrappa

func (*APIAuthWrappa) Wrap

func (wrappa *APIAuthWrappa) Wrap(handlers rata.Handlers) rata.Handlers

type APIMetricsWrappa

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

func (APIMetricsWrappa) Wrap

func (wrappa APIMetricsWrappa) Wrap(handlers rata.Handlers) rata.Handlers

type AccessorWrappa

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

func NewAccessorWrappa

func NewAccessorWrappa(
	logger lager.Logger,
	accessFactory accessor.AccessFactory,
	auditor auditor.Auditor,
	customRoles map[string]string,
) *AccessorWrappa

func (*AccessorWrappa) Wrap

func (w *AccessorWrappa) Wrap(handlers rata.Handlers) rata.Handlers

type CompressionWrappa

type CompressionWrappa struct {
	lager.Logger
}

func (CompressionWrappa) Wrap

func (wrappa CompressionWrappa) Wrap(handlers rata.Handlers) rata.Handlers

type ConcourseVersionWrappa

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

func (ConcourseVersionWrappa) Wrap

func (wrappa ConcourseVersionWrappa) Wrap(handlers rata.Handlers) rata.Handlers

type ConcurrentRequestLimitsWrappa

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

func (ConcurrentRequestLimitsWrappa) Wrap

func (wrappa ConcurrentRequestLimitsWrappa) Wrap(
	handlers rata.Handlers,
) rata.Handlers

type ConcurrentRequestPolicy

type ConcurrentRequestPolicy interface {
	HandlerPool(action string) (Pool, bool)
}

func NewConcurrentRequestPolicy

func NewConcurrentRequestPolicy(
	limits map[LimitedRoute]int,
) ConcurrentRequestPolicy

type LimitedRoute

type LimitedRoute string

func (*LimitedRoute) UnmarshalFlag

func (lr *LimitedRoute) UnmarshalFlag(value string) error

type LoggerHandler

type LoggerHandler struct {
	Logger  lager.Logger
	Handler http.Handler
}

func (LoggerHandler) ServeHTTP

func (handler LoggerHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type MultiWrappa

type MultiWrappa []Wrappa

func (MultiWrappa) Wrap

func (wrappas MultiWrappa) Wrap(handlers rata.Handlers) rata.Handlers

type PolicyCheckWrappa

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

func NewPolicyCheckWrappa

func NewPolicyCheckWrappa(
	logger lager.Logger,
	checker policychecker.PolicyChecker,
) *PolicyCheckWrappa

func (*PolicyCheckWrappa) Wrap

func (w *PolicyCheckWrappa) Wrap(handlers rata.Handlers) rata.Handlers

type Pool

type Pool interface {
	Size() int
	TryAcquire() bool
	Release()
}

func NewPool

func NewPool(size int) Pool

type RejectArchivedWrappa

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

func NewRejectArchivedWrappa

func NewRejectArchivedWrappa(factory pipelineserver.RejectArchivedHandlerFactory) *RejectArchivedWrappa

func (*RejectArchivedWrappa) Wrap

func (rw *RejectArchivedWrappa) Wrap(handlers rata.Handlers) rata.Handlers

type SecurityHandler

type SecurityHandler struct {
	XFrameOptions string
	Handler       http.Handler
}

func (SecurityHandler) ServeHTTP

func (handler SecurityHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type VersionedHandler

type VersionedHandler struct {
	Version string
	Handler http.Handler
}

func (VersionedHandler) ServeHTTP

func (handler VersionedHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type Wrappa

type Wrappa interface {
	Wrap(rata.Handlers) rata.Handlers
}

func NewAPIMetricsWrappa

func NewAPIMetricsWrappa(logger lager.Logger) Wrappa

func NewCompressionWrappa

func NewCompressionWrappa(logger lager.Logger) Wrappa

func NewConcourseVersionWrappa

func NewConcourseVersionWrappa(version string) Wrappa

func NewConcurrentRequestLimitsWrappa

func NewConcurrentRequestLimitsWrappa(
	logger lager.Logger,
	concurrentRequestPolicy ConcurrentRequestPolicy,
) Wrappa