Function newDefaultDriver

leader/dependency.go:101–140

(args DriverArgs)

}

func newDefaultDriver(args DriverArgs) (Driver, error) {
	var diDriver struct {
		di.In
		Driver `optional:"true"`
	}
	if err := args.Populator.Populate(&diDriver); err != nil {
		return nil, fmt.Errorf("failed to contruct default driver from DI: %w", err)
	}
	if diDriver.Driver != nil {
		return diDriver.Driver, nil
	}

	var injected struct {
		di.In

		Conf    contract.ConfigUnmarshaler
		AppName contract.AppName
		Env     contract.Env
		Maker   otetcd.Maker
		Driver  Driver `optional:"true"`
	}
	if err := args.Populator.Populate(&injected); err != nil {
		return nil, fmt.Errorf("missing dependency for the default election driver: %w", err)
	}
	if injected.Driver != nil {
		return injected.Driver, nil
	}
	var option Option
	if err := injected.Conf.Unmarshal("leader", &option); err != nil {
		return nil, fmt.Errorf("leader election configuration error: %w", err)
	}
	if option.EtcdName == "" {
		option.EtcdName = "default"
	}
	etcdClient, err := injected.Maker.Make(option.EtcdName)
	if err != nil {
		return nil, fmt.Errorf("failed to initiate leader election with etcd driver (%s): %w", option.EtcdName, err)
	}
	return leaderetcd.NewEtcdDriver(etcdClient, key.New(injected.AppName.String(), injected.Env.String())), nil
}

type configOut struct {
	di.Out