poddiscovery

package

v1.9.0 Latest Latest Go to latest Published: Oct 29, 2026 License: Apache-2.0 Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type ResolveRequest struct {
	HeadlessService string
	Namespace       string
}

ResolveRequest identifies the headless service to discover replicas from.

func MonoVertexRequest(mv *v1alpha1.MonoVertex) ResolveRequest

MonoVertexRequest returns the DNS discovery request for a MonoVertex.

func PipelineVertexRequest(pl *v1alpha1.Pipeline, vertexName string) ResolveRequest

PipelineVertexRequest returns the DNS discovery request for a Pipeline vertex.

type Resolver interface {
	Resolve(ctx context.Context, req ResolveRequest) (int, error)
}

Resolver discovers the replica count from a headless Service's DNS records. Replicas are assumed to be contiguous from 0 to count-1.

func NewResolver() Resolver

NewResolver returns a Resolver backed by the pod's configured DNS resolver.