...

Source file src/edge-infra.dev/cmd/edge/datasync/cushion/main.go

Documentation: edge-infra.dev/cmd/edge/datasync/cushion

     1  package main
     2  
     3  import (
     4  	"context"
     5  	"os"
     6  
     7  	"edge-infra.dev/pkg/edge/datasync/cushion"
     8  	"edge-infra.dev/pkg/lib/fog"
     9  )
    10  
    11  func main() {
    12  	cfg, err := cushion.NewConfig()
    13  	logger := fog.New().WithName("cushion")
    14  	if err != nil {
    15  		logger.Error(err, "error starting cushion")
    16  		os.Exit(1)
    17  	}
    18  
    19  	server, err := cushion.NewServer(cushion.ServerOptionPort(cfg.Port))
    20  	if err != nil {
    21  		logger.Error(err, "error starting cushion server")
    22  		os.Exit(1)
    23  	}
    24  	go server.Run() //nolint:errcheck
    25  
    26  	opts, err := cushion.DaemonOptions(cfg, logger)
    27  	if err != nil {
    28  		logger.Error(err, "error initializing cushion daemon options")
    29  		os.Exit(1)
    30  	}
    31  
    32  	daemon, err := cushion.NewDaemon(cfg, opts...)
    33  	if err != nil {
    34  		logger.Error(err, "error starting New Daemon")
    35  		os.Exit(1)
    36  	}
    37  
    38  	err = daemon.Run(context.Background())
    39  	if err != nil {
    40  		logger.Error(err, "error running cushion daemon")
    41  		os.Exit(1)
    42  	}
    43  }
    44  

View as plain text