filter

Documentation

Index

• func NewFilterReadCloser(req *http.Request, rc io.ReadCloser, handler Handler, ...) (int, io.ReadCloser, error)
• type Approver
  • func NewApprover(comp, resource string, verbs ...string) *Approver
  • func (a *Approver) Approve(comp, resource, verb string) bool
• type Factory
• type FilterInitializer
• type FilterInitializers
  • func (fis FilterInitializers) Initialize(ins Interface) error
• type Filters
  • func NewFilters(disabledFilters []string) *Filters
  • func (fs *Filters) Enabled(name string) bool
  • func (fs *Filters) NewFromFilters(initializer FilterInitializer) (Interface, error)
  • func (fs *Filters) Register(name string, fn Factory)
• type Handler
• type Interface
• type NodeGetter

Functions

func NewFilterReadCloser

func NewFilterReadCloser(
	req *http.Request,
	rc io.ReadCloser,
	handler Handler,
	serializer *serializer.Serializer,
	stopCh <-chan struct{}) (int, io.ReadCloser, error)

NewFilterReadCloser create an filterReadCloser object

Types

type Approver

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

func NewApprover

func NewApprover(comp, resource string, verbs ...string) *Approver

func (*Approver) Approve

func (a *Approver) Approve(comp, resource, verb string) bool

type Factory

type Factory func() (Interface, error)

type FilterInitializer

type FilterInitializer interface {
	Initialize(filter Interface) error
}

type FilterInitializers

type FilterInitializers []FilterInitializer

func (FilterInitializers) Initialize

func (fis FilterInitializers) Initialize(ins Interface) error

type Filters

type Filters struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewFilters

func NewFilters(disabledFilters []string) *Filters

func (*Filters) Enabled

func (fs *Filters) Enabled(name string) bool

func (*Filters) NewFromFilters

func (fs *Filters) NewFromFilters(initializer FilterInitializer) (Interface, error)

func (*Filters) Register

func (fs *Filters) Register(name string, fn Factory)

type Handler

type Handler interface {
	StreamResponseFilter(rc io.ReadCloser, ch chan watch.Event) error
	ObjectResponseFilter(b []byte) ([]byte, error)
}

type Interface

type Interface interface {
	Approve(comp, resource, verb string) bool
	Filter(req *http.Request, rc io.ReadCloser, stopCh <-chan struct{}) (int, io.ReadCloser, error)
}

type NodeGetter

type NodeGetter func() (*v1.Node, error)