Function NewResolverWithDefaultPort

proxycore/endpoint.go:84–89

(contactPoints []string, defaultPort int)

}

func NewResolverWithDefaultPort(contactPoints []string, defaultPort int) EndpointResolver {
	return &defaultEndpointResolver{
		contactPoints: contactPoints,
		defaultPort:   strconv.Itoa(defaultPort),
	}
}

func (r *defaultEndpointResolver) Resolve(ctx context.Context) ([]Endpoint, error) {
	var endpoints []Endpoint