resolver

Documentation

Index

• type Endpoint
• type ServiceResolver
• type ServiceResolverImpl
  • func NewServiceResolverImpl(c client.Client) *ServiceResolverImpl
  • func (e *ServiceResolverImpl) Resolve(ctx context.Context, logger logr.Logger, svcNsName types.NamespacedName, ...) ([]Endpoint, error)

Types

type Endpoint

type Endpoint struct {
	// Address is the IP address of the endpoint.
	Address string
	// Port is the port of the endpoint.
	Port int32
	// IPv6 is true if the endpoint is an IPv6 address.
	IPv6 bool
}

Endpoint is the internal representation of a Kubernetes endpoint.

type ServiceResolver

type ServiceResolver interface {
	Resolve(
		ctx context.Context,
		logger logr.Logger,
		svcNsName types.NamespacedName,
		svcPort v1.ServicePort,
		allowedAddressType []discoveryV1.AddressType,
	) ([]Endpoint, error)
}

ServiceResolver resolves a Service's NamespacedName and ServicePort to a list of Endpoints. Returns an error if the Service or Service Port cannot be resolved.

type ServiceResolverImpl

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

ServiceResolverImpl implements ServiceResolver.

func NewServiceResolverImpl

func NewServiceResolverImpl(c client.Client) *ServiceResolverImpl

NewServiceResolverImpl creates a new instance of a ServiceResolverImpl.

func (*ServiceResolverImpl) Resolve

func (e *ServiceResolverImpl) Resolve(
	ctx context.Context,
	logger logr.Logger,
	svcNsName types.NamespacedName,
	svcPort v1.ServicePort,
	allowedAddressType []discoveryV1.AddressType,
) ([]Endpoint, error)

Resolve resolves a Service's NamespacedName and ServicePort to a list of Endpoints. Returns an error if the Service or ServicePort cannot be resolved.