discovery

Documentation

Index

• Variables
• type Filter
  • func (p *Filter) IncrementalAggregatedResources(ads.AggregatedDiscoveryService_IncrementalAggregatedResourcesServer) error
  • func (p *Filter) Register(rpcs *grpc.Server)
  • func (p *Filter) StreamAggregatedResources(stream ads.AggregatedDiscoveryService_StreamAggregatedResourcesServer) error
• type FilterFunc

Variables

var (
	// Identity is a FilterFunc that always returns the original discovery response, unaltered.
	Identity = func(resp *xdsapi.DiscoveryResponse) (*xdsapi.DiscoveryResponse, error) {
		return resp, nil
	}
)

Types

type Filter

type Filter struct {
	// DiscoveryAddr is the address of the "real" discovery service whose responses will be filtered.
	DiscoveryAddr string

	// The filtering function to be used for processing discovery responses. If nil, Identity will be used.
	FilterFunc FilterFunc
}

Filter proxies requests to an Envoy discovery service (e.g. Pilot) and filters the responses.

func (*Filter) IncrementalAggregatedResources

func (p *Filter) IncrementalAggregatedResources(ads.AggregatedDiscoveryService_IncrementalAggregatedResourcesServer) error

IncrementalAggregatedResources implements the ADS interface.

func (*Filter) Register

func (p *Filter) Register(rpcs *grpc.Server)

Register adds the handlers to the grpc server

func (*Filter) StreamAggregatedResources

func (p *Filter) StreamAggregatedResources(stream ads.AggregatedDiscoveryService_StreamAggregatedResourcesServer) error

StreamAggregatedResources implements the ADS interface.

type FilterFunc

type FilterFunc func(resp *xdsapi.DiscoveryResponse) (*xdsapi.DiscoveryResponse, error)

FilterFunc is a function that allows an application to filter Envoy discovery responses