INNER CODE UNIT · Go

main

m3db/m3 · scripts/development/m3_consumer_service/bootstrap/main.go:104

func main() {
	var cfgPath string
	flag.StringVar(&cfgPath, "config", "./scripts/development/m3_consumer_service/m3msg-bootstrap.yaml", "bootstrap yaml path")
	flag.Parse()

	f, err := os.Open(cfgPath)
	if err != nil {
		fatalf("open config: %v", err)
	}
	defer f.Close()

	var cfg Config
	if err := yaml.NewDecoder(f).Decode(&cfg); err != nil {
		fatalf("decode yaml: %v", err)
	}

	client := cfg.newCoordinatorClientFromConfig()
	ctx := context.Background()

View source record →