apiserver

Documentation

Index

• Constants
• Variables
• func NewRequestInfoResolver(o *Options) *apirequest.RequestInfoFactory
• func TrimUrl(inUrl *url.URL, prePath string) (*url.URL, error)
• func WithRequestInfo(handler http.Handler, resolver request.RequestInfoResolver) http.Handler
• type Injector
  • func New(m *protomanager.SpecManager) Injector
• type Options
  • func NewOptions() *Options
  • func (o *Options) ApplyTo(apiserver **server.SecureServingInfo) error
  • func (o *Options) Validate() []error
• type Proxy
  • func NewProxy(opts *Options) (*Proxy, error)
  • func (p *Proxy) Start(ctx context.Context) (<-chan struct{}, error)

Constants

const (
	// DefaultLegacyAPIPrefix is where the legacy APIs will be located.
	DefaultLegacyAPIPrefix = "/api"

	// APIGroupPrefix is where non-legacy API group will be located.
	APIGroupPrefix = "/apis"
)

Variables

var ErrObjectTooLarge = fmt.Errorf("object to decode was longer than maximum allowed size")

var (
	ListCount = 0
)

Functions

func NewRequestInfoResolver

func NewRequestInfoResolver(o *Options) *apirequest.RequestInfoFactory

func TrimUrl

func TrimUrl(inUrl *url.URL, prePath string) (*url.URL, error)

func WithRequestInfo

func WithRequestInfo(handler http.Handler, resolver request.RequestInfoResolver) http.Handler

WithRequestInfo attaches a RequestInfo to the context.

Types

type Injector

type Injector interface {
	Inject(*http.Request, *request.RequestInfo) error
}

func New

func New(m *protomanager.SpecManager) Injector

type Options

type Options struct {
	Config               *rest.Config
	SecureServingOptions *options.SecureServingOptions

	RequestInfoResolver    apirequest.RequestInfoResolver
	LegacyAPIGroupPrefixes sets.Set[string]
	LongRunningFunc        apirequest.LongRunningRequestCheck
	HandlerChainWaitGroup  *utilwaitgroup.SafeWaitGroup

	LeaderElectionName string
	SpecManager        *protomanager.SpecManager

	BreakerWrapperFunc        func(http.Handler) http.Handler
	FaultInjectionWrapperFunc func(http.Handler) http.Handler
}

Options contains everything necessary to create and run proxy.

func NewOptions

func NewOptions() *Options

func (*Options) ApplyTo

func (o *Options) ApplyTo(apiserver **server.SecureServingInfo) error

func (*Options) Validate

func (o *Options) Validate() []error

type Proxy

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

func NewProxy

func NewProxy(opts *Options) (*Proxy, error)

func (*Proxy) Start

func (p *Proxy) Start(ctx context.Context) (<-chan struct{}, error)