foundational_store

func DecodeEndpoint ¶

func DecodeEndpoint(raw string) (*dregistry.Endpoint, error)

DecodeEndpoint is the inverse of EncodeEndpoint.

func DeploymentID ¶

func DeploymentID(identifier string) string

DeploymentID strips the trailing "@v<version>" suffix from a hosted-store identifier.

func EncodeEndpoint ¶

func EncodeEndpoint(endpoint *dregistry.Endpoint) string

EncodeEndpoint turns a resolved endpoint into the string we send to tier2. The scheme carries TLS so the json resolver on the other side can recover it.

func Lookup ¶

func Lookup(endpoints map[string]string, identifier string) (*dregistry.Endpoint, error)

Lookup returns the pre-resolved endpoint for identifier from a map that ResolveIdentifiers (or the ProcessRange proto field) already filled.

func NewPassthroughResolver ¶

func NewPassthroughResolver() (dregistry.Resolver, error)

NewPassthroughResolver treats the identifier itself as the endpoint.

func NewResolver ¶

func NewResolver(endpoints map[string]string, registryAddress string, logger *zap.Logger) (dregistry.Resolver, error)

NewResolver builds the 3-tier foundational-store resolver used by tier1: JSON map (if any) → control-plane (if address set, with @v strip) → identifier passthrough.

func NewStaticResolver ¶

func NewStaticResolver(endpoints map[string]string) (dregistry.Resolver, error)

NewStaticResolver looks up identifiers in a pre-resolved map. Tier2 uses this because tier1 already resolved every identifier onto the subrequest.

func NewStoreClient ¶

func NewStoreClient(rawEndpoint string, useTLS bool, logger *zap.Logger) (
	client pbservice.StoreClient,
	closer func() error,
	err error,
)

func ResolveIdentifiers ¶

func ResolveIdentifiers(ctx context.Context, resolver dregistry.Resolver, identifiers []string) (map[string]string, error)

ResolveIdentifiers looks up each identifier once. The caller (tier1) ships the resulting map to tier2 so workers do not dial the control plane themselves.