fake

Documentation

Index

• Constants
• Variables
• func EncodeUpstreamSpec(spec UpstreamSpec) *types.Struct
• type FakeED
  • func (fed *FakeED) Endpoints() <-chan endpointdiscovery.EndpointGroups
  • func (fed *FakeED) Error() <-chan error
  • func (fed *FakeED) Run(stop <-chan struct{})
  • func (fed *FakeED) TrackUpstreams(upstreams []*v1.Upstream)
• type Plugin
  • func (p *Plugin) GetDependencies(_ *v1.Config) *plugins.Dependencies
  • func (p *Plugin) Init(options bootstrap.Options) error
  • func (p *Plugin) ProcessUpstream(_ *plugins.UpstreamPluginParams, in *v1.Upstream, out *envoyapi.Cluster) error
  • func (p *Plugin) SetupEndpointDiscovery() (endpointdiscovery.Interface, error)
• type UpstreamSpec
  • func DecodeUpstreamSpec(generic v1.UpstreamSpec) (*UpstreamSpec, error)

Constants

const (
	// define Upstream type name
	UpstreamTypeFake = "fake"
)

Variables

var FakeEndpointDiscovery = FakeED{
	EndpointGroups: make(chan endpointdiscovery.EndpointGroups, 100),
	Errors:         make(chan error, 100),
}

Functions

func EncodeUpstreamSpec

func EncodeUpstreamSpec(spec UpstreamSpec) *types.Struct

Types

type FakeED

type FakeED struct {
	EndpointGroups chan endpointdiscovery.EndpointGroups
	Errors         chan error
}

func (*FakeED) Endpoints

func (fed *FakeED) Endpoints() <-chan endpointdiscovery.EndpointGroups

func (*FakeED) Error

func (fed *FakeED) Error() <-chan error

func (*FakeED) Run

func (fed *FakeED) Run(stop <-chan struct{})

func (*FakeED) TrackUpstreams

func (fed *FakeED) TrackUpstreams(upstreams []*v1.Upstream)

type Plugin

type Plugin struct{}

func (*Plugin) GetDependencies

func (p *Plugin) GetDependencies(_ *v1.Config) *plugins.Dependencies

func (*Plugin) Init

func (p *Plugin) Init(options bootstrap.Options) error

func (*Plugin) ProcessUpstream

func (p *Plugin) ProcessUpstream(_ *plugins.UpstreamPluginParams, in *v1.Upstream, out *envoyapi.Cluster) error

func (*Plugin) SetupEndpointDiscovery

func (p *Plugin) SetupEndpointDiscovery() (endpointdiscovery.Interface, error)

type UpstreamSpec

type UpstreamSpec = static.UpstreamSpec

func DecodeUpstreamSpec

func DecodeUpstreamSpec(generic v1.UpstreamSpec) (*UpstreamSpec, error)