Function createDataClients

skipper.go:1230–1303

(o Options, cr *certregistry.CertRegistry)

}

func createDataClients(o Options, cr *certregistry.CertRegistry) ([]routing.DataClient, error) {
	var clients []routing.DataClient

	if o.RoutesFile != "" {
		for rf := range strings.SplitSeq(o.RoutesFile, ",") {
			f, err := eskipfile.Open(rf)
			if err != nil {
				return nil, fmt.Errorf("error while opening eskip file: %w", err)
			}

			clients = append(clients, f)
		}
	}

	if o.WatchRoutesFile != "" {
		for rf := range strings.SplitSeq(o.WatchRoutesFile, ",") {
			clients = append(clients, eskipfile.Watch(rf))
		}
	}

	if len(o.RoutesURLs) > 0 {
		for _, url := range o.RoutesURLs {
			client, err := eskipfile.RemoteWatch(&eskipfile.RemoteWatchOptions{
				RemoteFile:    url,
				FailOnStartup: true,
				HTTPTimeout:   o.SourcePollTimeout,
			})
			if err != nil {
				return nil, fmt.Errorf("error while loading routes from url %s: %w", url, err)
			}
			clients = append(clients, client)
		}
	}

	if o.InlineRoutes != "" {
		ir, err := routestring.New(o.InlineRoutes)
		if err != nil {
			return nil, fmt.Errorf("error while parsing inline routes: %w", err)
		}

		clients = append(clients, ir)
	}

	if len(o.EtcdUrls) > 0 {
		etcdClient, err := etcd.New(etcd.Options{
			Endpoints:  o.EtcdUrls,
			Prefix:     o.EtcdPrefix,
			Timeout:    o.EtcdWaitTimeout,
			Insecure:   o.EtcdInsecure,
			OAuthToken: o.EtcdOAuthToken,
			Username:   o.EtcdUsername,
			Password:   o.EtcdPassword,
		})

		if err != nil {
			return nil, fmt.Errorf("error while creating etcd client: %w", err)
		}