// GetSourceEndpointOrFail gets source's endpoint or fail.
GetSourceEndpointOrFail gets source's endpoint or fail.
// GetSourceEndpointOrFail gets source ' s endpoint or fail .
func GetSourceEndpointOrFail(client *eventingtestlib.Client, source *sourcesv1alpha1.DockerHubSource) string {
	dhCli := GetSourceClient(client).SourcesV1alpha1().DockerHubSources(client.Namespace)
	url := ""
	err := wait.PollImmediate(1*time.Second, 1*time.Minute, func() (bool, error) {
		dhs, err := dhCli.Get(context.Background(), source.Name, metav1.GetOptions{})
		if err != nil {
			return true, fmt.Errorf("failed to get DockerHubSource: %v", source.Name)
		}
		url = dhs.Status.URL.String()
		if url == "" {
			return false, nil
		}
		return true, nil
	})
	if err != nil {
		client.T.Fatalf("failed to source endpoint: %v", err)
	}
	return url
}
func GetSourceEndpointOrFail ( client * eventingtestlib . Client , source * sourcesv1alpha1 . DockerHubSource ) string { dhCli := GetSourceClient ( client ) . SourcesV1alpha1 ( ) . DockerHubSources ( client . Namespace ) url := " " err := wait . PollImmediate ( 1 * time . Second , 1 * time . Minute , func ( ) ( bool , error ) { dhs , err := dhCli . Get ( context . Background ( ) , source . Name , metav1 . GetOptions { } ) if err != nil { return true , fmt . Errorf ( " " , source . Name ) } url = dhs . Status . URL . String ( ) if url == " " { return false , nil } return true , nil } ) if err != nil { client . T . Fatalf ( " " , err ) } return url }
GetSourceEndpointOrFail gets source's endpoint or fail.
GetSourceEndpointOrFail gets source ' s endpoint or fail .