Unlock 30% off on Manual Testing Annual Plans this Holiday Season.

Copied to Clipboard!

How to use init method of defaults Package

Best Rod code snippet using defaults.init

initconfiguration.go

Source:initconfiguration.go

...189	// Default all the embedded ComponentConfig structs190	componentconfigs.Default(&internalcfg.ClusterConfiguration, &internalcfg.LocalAPIEndpoint, &internalcfg.NodeRegistration)191	return internalcfg, nil192}193// DefaultedInitConfiguration takes a versioned init config (often populated by flags), defaults it and converts it into internal InitConfiguration194func DefaultedInitConfiguration(versionedInitCfg *kubeadmapiv1.InitConfiguration, versionedClusterCfg *kubeadmapiv1.ClusterConfiguration) (*kubeadmapi.InitConfiguration, error) {195	internalcfg := &kubeadmapi.InitConfiguration{}196	// Takes passed flags into account; the defaulting is executed once again enforcing assignment of197	// static default values to cfg only for values not provided with flags198	kubeadmscheme.Scheme.Default(versionedInitCfg)199	if err := kubeadmscheme.Scheme.Convert(versionedInitCfg, internalcfg, nil); err != nil {200		return nil, err201	}202	kubeadmscheme.Scheme.Default(versionedClusterCfg)203	if err := kubeadmscheme.Scheme.Convert(versionedClusterCfg, &internalcfg.ClusterConfiguration, nil); err != nil {204		return nil, err205	}206	// Applies dynamic defaults to settings not provided with flags207	if err := SetInitDynamicDefaults(internalcfg); err != nil {208		return nil, err209	}210	// Validates cfg (flags/configs + defaults + dynamic defaults)211	if err := validation.ValidateInitConfiguration(internalcfg).ToAggregate(); err != nil {212		return nil, err213	}214	return internalcfg, nil215}216// LoadInitConfigurationFromFile loads a supported versioned InitConfiguration from a file, converts it into internal config, defaults it and verifies it.217func LoadInitConfigurationFromFile(cfgPath string) (*kubeadmapi.InitConfiguration, error) {218	klog.V(1).Infof("loading configuration from %q", cfgPath)219	b, err := os.ReadFile(cfgPath)220	if err != nil {221		return nil, errors.Wrapf(err, "unable to read config from %q ", cfgPath)222	}223	return BytesToInitConfiguration(b)224}225// LoadOrDefaultInitConfiguration takes a path to a config file and a versioned configuration that can serve as the default config226// If cfgPath is specified, the versioned configs will always get overridden with the one in the file (specified by cfgPath).227// The external, versioned configuration is defaulted and converted to the internal type.228// Right thereafter, the configuration is defaulted again with dynamic values (like IP addresses of a machine, etc)229// Lastly, the internal config is validated and returned.230func LoadOrDefaultInitConfiguration(cfgPath string, versionedInitCfg *kubeadmapiv1.InitConfiguration, versionedClusterCfg *kubeadmapiv1.ClusterConfiguration) (*kubeadmapi.InitConfiguration, error) {231	if cfgPath != "" {232		// Loads configuration from config file, if provided233		// Nb. --config overrides command line flags234		return LoadInitConfigurationFromFile(cfgPath)235	}236	return DefaultedInitConfiguration(versionedInitCfg, versionedClusterCfg)237}238// BytesToInitConfiguration converts a byte slice to an internal, defaulted and validated InitConfiguration object.239// The map may contain many different YAML documents. These YAML documents are parsed one-by-one240// and well-known ComponentConfig GroupVersionKinds are stored inside of the internal InitConfiguration struct.241// The resulting InitConfiguration is then dynamically defaulted and validated prior to return.242func BytesToInitConfiguration(b []byte) (*kubeadmapi.InitConfiguration, error) {243	gvkmap, err := kubeadmutil.SplitYAMLDocuments(b)244	if err != nil {245		return nil, err246	}247	return documentMapToInitConfiguration(gvkmap, false)248}249// documentMapToInitConfiguration converts a map of GVKs and YAML documents to defaulted and validated configuration object.250func documentMapToInitConfiguration(gvkmap kubeadmapi.DocumentMap, allowDeprecated bool) (*kubeadmapi.InitConfiguration, error) {251	var initcfg *kubeadmapi.InitConfiguration252	var clustercfg *kubeadmapi.ClusterConfiguration253	for gvk, fileContent := range gvkmap {254		// first, check if this GVK is supported and possibly not deprecated255		if err := validateSupportedVersion(gvk.GroupVersion(), allowDeprecated); err != nil {256			return nil, err257		}258		// verify the validity of the YAML259		if err := strict.VerifyUnmarshalStrict([]*runtime.Scheme{kubeadmscheme.Scheme, componentconfigs.Scheme}, gvk, fileContent); err != nil {260			klog.Warning(err.Error())261		}262		if kubeadmutil.GroupVersionKindsHasInitConfiguration(gvk) {263			// Set initcfg to an empty struct value the deserializer will populate264			initcfg = &kubeadmapi.InitConfiguration{}265			// Decode the bytes into the internal struct. Under the hood, the bytes will be unmarshalled into the266			// right external version, defaulted, and converted into the internal version.267			if err := runtime.DecodeInto(kubeadmscheme.Codecs.UniversalDecoder(), fileContent, initcfg); err != nil {268				return nil, err269			}270			continue271		}272		if kubeadmutil.GroupVersionKindsHasClusterConfiguration(gvk) {273			// Set clustercfg to an empty struct value the deserializer will populate274			clustercfg = &kubeadmapi.ClusterConfiguration{}275			// Decode the bytes into the internal struct. Under the hood, the bytes will be unmarshalled into the276			// right external version, defaulted, and converted into the internal version.277			if err := runtime.DecodeInto(kubeadmscheme.Codecs.UniversalDecoder(), fileContent, clustercfg); err != nil {278				return nil, err279			}280			continue281		}282		// If the group is neither a kubeadm core type or of a supported component config group, we dump a warning about it being ignored283		if !componentconfigs.Scheme.IsGroupRegistered(gvk.Group) {284			klog.Warningf("[config] WARNING: Ignored YAML document with GroupVersionKind %v\n", gvk)285		}286	}287	// Enforce that InitConfiguration and/or ClusterConfiguration has to exist among the YAML documents288	if initcfg == nil && clustercfg == nil {289		return nil, errors.New("no InitConfiguration or ClusterConfiguration kind was found in the YAML file")290	}291	// If InitConfiguration wasn't given, default it by creating an external struct instance, default it and convert into the internal type292	if initcfg == nil {293		extinitcfg := &kubeadmapiv1.InitConfiguration{}294		kubeadmscheme.Scheme.Default(extinitcfg)295		// Set initcfg to an empty struct value the deserializer will populate296		initcfg = &kubeadmapi.InitConfiguration{}297		if err := kubeadmscheme.Scheme.Convert(extinitcfg, initcfg, nil); err != nil {298			return nil, err299		}300	}301	// If ClusterConfiguration was given, populate it in the InitConfiguration struct302	if clustercfg != nil {303		initcfg.ClusterConfiguration = *clustercfg304	} else {305		// Populate the internal InitConfiguration.ClusterConfiguration with defaults306		extclustercfg := &kubeadmapiv1.ClusterConfiguration{}307		kubeadmscheme.Scheme.Default(extclustercfg)308		if err := kubeadmscheme.Scheme.Convert(extclustercfg, &initcfg.ClusterConfiguration, nil); err != nil {309			return nil, err310		}311	}312	// Load any component configs313	if err := componentconfigs.FetchFromDocumentMap(&initcfg.ClusterConfiguration, gvkmap); err != nil {314		return nil, err315	}316	// Applies dynamic defaults to settings not provided with flags317	if err := SetInitDynamicDefaults(initcfg); err != nil {318		return nil, err319	}320	// Validates cfg (flags/configs + defaults + dynamic defaults)321	if err := validation.ValidateInitConfiguration(initcfg).ToAggregate(); err != nil {322		return nil, err323	}324	return initcfg, nil325}326// MarshalInitConfigurationToBytes marshals the internal InitConfiguration object to bytes. It writes the embedded327// ClusterConfiguration object with ComponentConfigs out as separate YAML documents328func MarshalInitConfigurationToBytes(cfg *kubeadmapi.InitConfiguration, gv schema.GroupVersion) ([]byte, error) {329	initbytes, err := kubeadmutil.MarshalToYamlForCodecs(cfg, gv, kubeadmscheme.Codecs)330	if err != nil {331		return []byte{}, err332	}333	allFiles := [][]byte{initbytes}334	// Exception: If the specified groupversion is targeting the internal type, don't print embedded ClusterConfiguration contents335	// This is mostly used for unit testing. In a real scenario the internal version of the API is never marshalled as-is.336	if gv.Version != runtime.APIVersionInternal {337		clusterbytes, err := kubeadmutil.MarshalToYamlForCodecs(&cfg.ClusterConfiguration, gv, kubeadmscheme.Codecs)338		if err != nil {339			return []byte{}, err340		}341		allFiles = append(allFiles, clusterbytes)342	}343	return bytes.Join(allFiles, []byte(kubeadmconstants.YAMLDocumentSeparator)), nil344}...

init.go

Source:init.go

...15	"koding/klientctl/helper"16	"github.com/spf13/cobra"17	yaml "gopkg.in/yaml.v2"18)19type initOptions struct {20	output   string21	provider string22	defaults bool23}24// NewInitCommand creates a command that generates a new stack template.25func NewInitCommand(c *cli.CLI) *cobra.Command {26	opts := &initOptions{}27	cmd := &cobra.Command{28		Use:   "init",29		Short: "Generate a new stack template file",30		RunE:  initCommand(c, opts),31	}32	// Flags.33	flags := cmd.Flags()34	flags.StringVarP(&opts.output, "output", "o", config.Konfig.Template.File, "output filename")35	flags.StringVarP(&opts.provider, "provider", "p", "", "cloud provider to use")36	flags.BoolVar(&opts.defaults, "defaults", false, "use default values for stack vars")37	// Middlewares.38	cli.MultiCobraCmdMiddleware(39		cli.DaemonRequired, // Deamon service is required.40		cli.NoArgs,         // No custom arguments are accepted.41	)(c, cmd)42	return cmd43}44func initCommand(c *cli.CLI, opts *initOptions) cli.CobraFuncE {45	return func(cmd *cobra.Command, args []string) error {46		return Init(c, opts.output, opts.defaults, opts.provider)47	}48}49// Init initializes a template.50func Init(c *cli.CLI, output string, useDefaults bool, providerName string) error {51	if _, err := os.Stat(output); err == nil && !useDefaults {52		yn, err := helper.Fask(c.In(), c.Out(), "Do you want to overwrite %q file? [y/N]: ", output)53		if err != nil {54			return err55		}56		switch strings.ToLower(yn) {57		case "yes", "y":58			fmt.Fprintln(c.Out())59		default:60			return errors.New("aborted by user")61		}62	}63	descs, err := credential.Describe()...

config.go

Source:config.go

...7	"koding/klientctl/ctlcli"8	"koding/klientctl/endpoint/kloud"9)10var DefaultClient = &Client{}11func init() {12	ctlcli.CloseOnExit(DefaultClient)13}14type Client struct {15	Kloud *kloud.Client16	Store *configstore.Client17	once     sync.Once // for c.init()18	defaults config.Konfigs19}20func (c *Client) Used() (*config.Konfig, error) {21	c.init()22	return c.store().Used()23}24func (c *Client) Use(k *config.Konfig) error {25	c.init()26	return c.store().Use(k)27}28func (c *Client) List() config.Konfigs {29	c.init()30	return c.store().List()31}32func (c *Client) Set(key, value string) error {33	c.init()34	return c.store().Set(key, value)35}36func (c *Client) Close() (err error) {37	c.init()38	if len(c.defaults) != 0 {39		err = c.store().Commit(func(cache *config.Cache) error {40			return cache.SetValue("konfigs.default", c.defaults)41		})42	}43	return err44}45func (c *Client) Defaults() (*config.Konfig, error) {46	c.init()47	return c.fetchDefaults(false)48}49func (c *Client) fetchDefaults(force bool) (*config.Konfig, error) {50	used, err := c.store().Used()51	if err != nil {52		return nil, err53	}54	id := used.ID()55	if !force {56		if defaults, ok := c.defaults[id]; ok {57			return defaults, nil58		}59	}60	var req = &stack.ConfigMetadataRequest{}61	var resp stack.ConfigMetadataResponse62	if err := c.kloud().Call("config.metadata", req, &resp); err != nil {63		return nil, err64	}65	defaults := &config.Konfig{66		Endpoints: resp.Metadata.Endpoints,67	}68	c.defaults[defaults.ID()] = defaults69	return defaults, nil70}71type ResetOpts struct {72	Force bool73}74func (c *Client) Reset(opts *ResetOpts) error {75	c.init()76	used, err := c.store().Used()77	if err != nil {78		return err79	}80	defaults, err := c.fetchDefaults(opts.Force)81	if err != nil {82		return err83	}84	used.Endpoints = defaults.Endpoints85	return c.store().Use(used)86}87func (c *Client) init() {88	c.once.Do(c.initClient)89}90func (c *Client) initClient() {91	c.defaults = make(config.Konfigs)92	// Ignoring read error, if it's non-nil then empty cache is going to93	// be used instead.94	_ = c.store().Commit(func(cache *config.Cache) error {95		return cache.GetValue("konfigs.default", &c.defaults)96	})97}98func (c *Client) kloud() *kloud.Client {99	if c.Kloud != nil {100		return c.Kloud101	}102	return kloud.DefaultClient103}104func (c *Client) store() *configstore.Client {...

init

Using AI Code Generation

1import (2func main() {3    conf, err := config.NewConfig("ini", "conf/app.conf")4    if err != nil {5        fmt.Println(err)6    }7    fmt.Println(conf.String("appname"))8    fmt.Println(conf.String("httpport"))9    fmt.Println(conf.String("runmode"))10    fmt.Println(conf.String("autorender"))11    fmt.Println(conf.String("copyrequestbody"))12}13import (14func main() {15    conf, err := config.NewConfig("ini", "conf/app.conf")16    if err != nil {17        fmt.Println(err)18    }19    fmt.Println(conf.String("appname"))20    fmt.Println(conf.String("httpport"))21    fmt.Println(conf.String("runmode"))22    fmt.Println(conf.String("autorender"))23    fmt.Println(conf.String("copyrequestbody"))24}

init

Using AI Code Generation

1import (2func main() {3	fmt.Println("Hello World")4	defaults, err := config.NewConfig("ini", "conf/defaults.conf")5	if err != nil {6		logs.Error("Error in reading defaults file", err)7	}8	fmt.Println(defaults.String("default::default"))9}

init

Using AI Code Generation

1func main() {2    defaults := &defaults{}3    defaults.init()4    fmt.Println(defaults)5}6func main() {7    defaults := &defaults{}8    defaults.init()9    fmt.Println(defaults)10}11func main() {12    defaults := &defaults{}13    defaults.init()14    fmt.Println(defaults)15}16func main() {17    defaults := &defaults{}18    defaults.init()19    fmt.Println(defaults)20}21func main() {22    defaults := &defaults{}23    defaults.init()24    fmt.Println(defaults)25}26func main() {27    defaults := &defaults{}28    defaults.init()29    fmt.Println(defaults)30}31func main() {32    defaults := &defaults{}33    defaults.init()34    fmt.Println(defaults)35}36func main() {37    defaults := &defaults{}38    defaults.init()39    fmt.Println(defaults)40}41func main() {42    defaults := &defaults{}43    defaults.init()44    fmt.Println(defaults)45}46func main() {47    defaults := &defaults{}48    defaults.init()49    fmt.Println(defaults)50}51func main() {52    defaults := &defaults{}53    defaults.init()54    fmt.Println(defaults)55}56func main() {57    defaults := &defaults{}58    defaults.init()59    fmt.Println(defaults)60}61func main() {62    defaults := &defaults{}63    defaults.init()64    fmt.Println(defaults)65}66func main() {

init

Using AI Code Generation

1import (2func main() {3	fmt.Println("Hello, playground")4	fmt.Println(defaults.Name)5}6import "fmt"7func init() {8	fmt.Println("defaults package initialized")9}

init

Using AI Code Generation

1func main() {2  x.init()3  fmt.Println(x.a)4  fmt.Println(x.b)5}6func main() {7  x.init()8  fmt.Println(x.a)9  fmt.Println(x.b)10}11import "fmt"12func main() {13  x.init()14  fmt.Println(x.a)15  fmt.Println(x.b)16}17func main() {18  x.init()19  fmt.Println(x.a)20  fmt.Println(x.b)21}22func main() {23  x.init()24  fmt.Println(x.a)25  fmt.Println(x.b)26}27import "fmt"28func main() {29  x.init()30  fmt.Println(x.a)31  fmt.Println(x.b)32}33func main() {34  x.init()35  fmt.Println(x.a)36  fmt.Println(x.b)37}38func main() {39  x.init()40  fmt.Println(x.a)41  fmt.Println(x.b)42}43import "fmt"44func main() {45  x.init()46  fmt.Println(x.a)47  fmt.Println(x.b)48}49func main() {50  x.init()51  fmt.Println(x.a)52  fmt.Println(x.b)53}54func main() {55  x.init()56  fmt.Println(x.a)57  fmt.Println(x.b)58}59import "fmt"

init

Using AI Code Generation

1import (2func main() {3	fmt.Println(defaults.GetName())4	fmt.Println(defaults.GetAge())5	fmt.Println(defaults.GetHeight())6	fmt.Println(defaults.GetWeight())7}

init

Using AI Code Generation

1func main() {2    defaults := defaults.Defaults{}3    defaults.InitDefaults()4    fmt.Println("default value of int is", defaults.Int)5    fmt.Println("default value of string is", defaults.String)6    fmt.Println("default value of float is", defaults.Float)7    fmt.Println("default value of bool is", defaults.Bool)8}9In the above code, the init method is used to initialize the variables of the defaults class. The init method is called when the package is imported. The init method is called before the main function. The init method is used to initialize the variables and

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.