k3s/pkg/daemons/executor/etcd.go

// +build !no_embedded_executor

package executor

import (
	"github.com/sirupsen/logrus"
	"go.etcd.io/etcd/embed"
)

func (e Embedded) CurrentETCDOptions() (InitialOptions, error) {
	return InitialOptions{}, nil
}

func (e Embedded) ETCD(args ETCDConfig) error {
	configFile, err := args.ToConfigFile()
	if err != nil {
		return err
	}
	cfg, err := embed.ConfigFromFile(configFile)
	if err != nil {
		return err
	}
	etcd, err := embed.StartEtcd(cfg)
	if err != nil {
		return nil
	}

	go func() {
		err := <-etcd.Err()
		logrus.Fatalf("etcd exited: %v", err)
	}()
	return nil
}