upstreams

Documentation

Index

• Variables
• func DestinationToUpstreamRef(dest *v1.Destination) (*core.ResourceRef, error)
• func NewHybridUpstreamClient(upstreamClient v1.UpstreamClient, serviceClient skkube.ServiceClient, ...) (v1.UpstreamClient, error)

Variables

var (
	// used in tests
	TimerOverride <-chan time.Time
)

Functions

func DestinationToUpstreamRef

func DestinationToUpstreamRef(dest *v1.Destination) (*core.ResourceRef, error)

DestinationToUpstreamRef converts a route destination to an upstream ref. The upstream ref may refer to either a real or in-memory upstream, depending on the destination type.

func NewHybridUpstreamClient

func NewHybridUpstreamClient(
	upstreamClient v1.UpstreamClient,
	serviceClient skkube.ServiceClient,
	consulClient consul.ConsulWatcher,
	settings *v1.Settings) (v1.UpstreamClient, error)