opentelemetry

Documentation

Index

• type CheckerWithTracing
  • func NewCheckerWithTracing(base endpointresolver.Checker, instance string, ...) CheckerWithTracing
  • func (_d CheckerWithTracing) ExternalDNS(ctx context.Context, hostname string, externalDNS []string) (err error)
  • func (_d CheckerWithTracing) HTTP(ctx context.Context, userAgent string, hostname string, ...) (sa1 []string, err error)
  • func (_d CheckerWithTracing) NativeDNS(ctx context.Context, hostname string) (ips []string, err error)
  • func (_d CheckerWithTracing) Ports(ctx context.Context, ips []string, ports []int) (openPorts []int, err error)
• type ResolverWithTracing
  • func NewResolverWithTracing(base endpointresolver.Resolver, instance string, ...) ResolverWithTracing
  • func (_d ResolverWithTracing) Resolve(ctx context.Context, conf endpointresolver.ResolveConf) (urls []string, err error)

Types

type CheckerWithTracing

type CheckerWithTracing struct {
	endpointresolver.Checker
	// contains filtered or unexported fields
}

CheckerWithTracing implements endpointresolver.Checker interface instrumented with opentracing spans

func NewCheckerWithTracing

func NewCheckerWithTracing(base endpointresolver.Checker, instance string, spanDecorator ...func(span trace.Span, params, results map[string]interface{})) CheckerWithTracing

NewCheckerWithTracing returns CheckerWithTracing

func (CheckerWithTracing) ExternalDNS

func (_d CheckerWithTracing) ExternalDNS(ctx context.Context, hostname string, externalDNS []string) (err error)

DNSCheckWithExternalProvider implements endpointresolver.Checker

func (CheckerWithTracing) HTTP

func (_d CheckerWithTracing) HTTP(ctx context.Context, userAgent string, hostname string, customHeaders map[string]string, openPorts []int) (sa1 []string, err error)

HTTPCheck implements endpointresolver.Checker

func (CheckerWithTracing) NativeDNS

func (_d CheckerWithTracing) NativeDNS(ctx context.Context, hostname string) (ips []string, err error)

NativeDNSCheck implements endpointresolver.Checker

func (CheckerWithTracing) Ports

func (_d CheckerWithTracing) Ports(ctx context.Context, ips []string, ports []int) (openPorts []int, err error)

CheckAllPorts implements endpointresolver.Checker

type ResolverWithTracing

type ResolverWithTracing struct {
	endpointresolver.Resolver
	// contains filtered or unexported fields
}

ResolverWithTracing implements endpointresolver.Resolver interface instrumented with opentracing spans

func NewResolverWithTracing

func NewResolverWithTracing(base endpointresolver.Resolver, instance string, spanDecorator ...func(span trace.Span, params, results map[string]interface{})) ResolverWithTracing

NewResolverWithTracing returns ResolverWithTracing

func (ResolverWithTracing) Resolve

func (_d ResolverWithTracing) Resolve(ctx context.Context, conf endpointresolver.ResolveConf) (urls []string, err error)

Resolve implements endpointresolver.Resolver