detector

Documentation

Index

• type Interface
• type Marker
  • func NewMarker(detectors []Interface, resolver resolver.Resolver) *Marker
  • func (m *Marker) DetectFunctionalServiceType(us *v1.Upstream) (*v1.ServiceInfo, map[string]string, error)

Types

type Interface

type Interface interface {
	// if it detects the upstream is a known functional type, give us the
	// service info and annotations to mark it with
	DetectFunctionalService(us *v1.Upstream, addr string) (*v1.ServiceInfo, map[string]string, error)
}

detectors detect a specific type of functional service if they detect the service, they return service info and annotations (optional) for the service

type Marker

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

marker marks the upstream as functional. this modifies the upstream it was received, so should not be called concurrently from multiple goroutines

func NewMarker

func NewMarker(detectors []Interface, resolver resolver.Resolver) *Marker

func (*Marker) DetectFunctionalServiceType

func (m *Marker) DetectFunctionalServiceType(us *v1.Upstream) (*v1.ServiceInfo, map[string]string, error)

should only be called for k8s, consul, and static type upstreams