proxy

Documentation

Index

• func AddNamespaceConstraint(req *http.Request, names ...string) *http.Request
• func NewProxyStore(clientGetter ClientGetter, lookup accesscontrol.AccessSetLookup) types2.Store
• type ClientGetter
• type Partition
  • func (p Partition) Name() string
• type Store
  • func (s *Store) ByID(apiOp *types2.APIRequest, schema *types2.APISchema, id string) (types2.APIObject, error)
  • func (s *Store) ByNames(apiOp *types2.APIRequest, schema *types2.APISchema, names sets.String) (types2.APIObjectList, error)
  • func (s *Store) Create(apiOp *types2.APIRequest, schema *types2.APISchema, params types2.APIObject) (types2.APIObject, error)
  • func (s *Store) Delete(apiOp *types2.APIRequest, schema *types2.APISchema, id string) (types2.APIObject, error)
  • func (s *Store) List(apiOp *types2.APIRequest, schema *types2.APISchema) (types2.APIObjectList, error)
  • func (s *Store) Update(apiOp *types2.APIRequest, schema *types2.APISchema, params types2.APIObject, ...) (types2.APIObject, error)
  • func (s *Store) Watch(apiOp *types2.APIRequest, schema *types2.APISchema, w types2.WatchRequest) (chan types2.APIEvent, error)
  • func (s *Store) WatchNames(apiOp *types2.APIRequest, schema *types2.APISchema, w types2.WatchRequest, ...) (chan types2.APIEvent, error)
• type WatchRefresh
  • func (w *WatchRefresh) Watch(apiOp *types2.APIRequest, schema *types2.APISchema, wr types2.WatchRequest) (chan types2.APIEvent, error)

Functions

func AddNamespaceConstraint

func AddNamespaceConstraint(req *http.Request, names ...string) *http.Request

func NewProxyStore

func NewProxyStore(clientGetter ClientGetter, lookup accesscontrol.AccessSetLookup) types2.Store

Types

type ClientGetter

type ClientGetter interface {
	IsImpersonating() bool
	K8sInterface(ctx *types2.APIRequest) (kubernetes.Interface, error)
	AdminK8sInterface() (kubernetes.Interface, error)
	Client(ctx *types2.APIRequest, schema *types2.APISchema, namespace string) (dynamic.ResourceInterface, error)
	DynamicClient(ctx *types2.APIRequest) (dynamic.Interface, error)
	AdminClient(ctx *types2.APIRequest, schema *types2.APISchema, namespace string) (dynamic.ResourceInterface, error)
	TableClient(ctx *types2.APIRequest, schema *types2.APISchema, namespace string) (dynamic.ResourceInterface, error)
	TableAdminClient(ctx *types2.APIRequest, schema *types2.APISchema, namespace string) (dynamic.ResourceInterface, error)
	TableClientForWatch(ctx *types2.APIRequest, schema *types2.APISchema, namespace string) (dynamic.ResourceInterface, error)
	TableAdminClientForWatch(ctx *types2.APIRequest, schema *types2.APISchema, namespace string) (dynamic.ResourceInterface, error)
}

type Partition

type Partition struct {
	Namespace   string
	All         bool
	Passthrough bool
	Names       sets.String
}

func (Partition) Name

func (p Partition) Name() string

type Store

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

func (*Store) ByID

func (s *Store) ByID(apiOp *types2.APIRequest, schema *types2.APISchema, id string) (types2.APIObject, error)

func (*Store) ByNames

func (s *Store) ByNames(apiOp *types2.APIRequest, schema *types2.APISchema, names sets.String) (types2.APIObjectList, error)

func (*Store) Create

func (s *Store) Create(apiOp *types2.APIRequest, schema *types2.APISchema, params types2.APIObject) (types2.APIObject, error)

func (*Store) Delete

func (s *Store) Delete(apiOp *types2.APIRequest, schema *types2.APISchema, id string) (types2.APIObject, error)

func (*Store) List

func (s *Store) List(apiOp *types2.APIRequest, schema *types2.APISchema) (types2.APIObjectList, error)

func (*Store) Update

func (s *Store) Update(apiOp *types2.APIRequest, schema *types2.APISchema, params types2.APIObject, id string) (types2.APIObject, error)

func (*Store) Watch

func (s *Store) Watch(apiOp *types2.APIRequest, schema *types2.APISchema, w types2.WatchRequest) (chan types2.APIEvent, error)

func (*Store) WatchNames

func (s *Store) WatchNames(apiOp *types2.APIRequest, schema *types2.APISchema, w types2.WatchRequest, names sets.String) (chan types2.APIEvent, error)

type WatchRefresh

type WatchRefresh struct {
	types2.Store
	// contains filtered or unexported fields
}

func (*WatchRefresh) Watch

func (w *WatchRefresh) Watch(apiOp *types2.APIRequest, schema *types2.APISchema, wr types2.WatchRequest) (chan types2.APIEvent, error)