package main import ( "time" "github.com/pkg/errors" ioprojectatomicpodman "github.com/projectatomic/libpod/cmd/podman/varlink" "github.com/projectatomic/libpod/pkg/varlinkapi" "github.com/projectatomic/libpod/version" "github.com/sirupsen/logrus" "github.com/urfave/cli" "github.com/varlink/go/varlink" ) var ( varlinkDescription = ` podman varlink run varlink interface ` varlinkFlags = []cli.Flag{ cli.IntFlag{ Name: "timeout, t", Usage: "time until the varlink session expires in milliseconds. default is 1 second; 0 means no timeout.", Value: 1000, }, } varlinkCommand = cli.Command{ Name: "varlink", Usage: "Run varlink interface", Description: varlinkDescription, Flags: varlinkFlags, Action: varlinkCmd, ArgsUsage: "VARLINK_URI", } ) func varlinkCmd(c *cli.Context) error { args := c.Args() if len(args) < 1 { return errors.Errorf("you must provide a varlink URI") } timeout := time.Duration(c.Int64("timeout")) * time.Millisecond var varlinkInterfaces = []*ioprojectatomicpodman.VarlinkInterface{varlinkapi.New(c)} // Register varlink service. The metadata can be retrieved with: // $ varlink info [varlink address URI] service, err := varlink.NewService( "Atomic", "podman", version.Version, "https://github.com/projectatomic/libpod", ) if err != nil { return errors.Wrapf(err, "unable to create new varlink service") } for _, i := range varlinkInterfaces { if err := service.RegisterInterface(i); err != nil { return errors.Errorf("unable to register varlink interface %v", i) } } // Run the varlink server at the given address if err = service.Listen(args[0], timeout); err != nil { switch err.(type) { case varlink.ServiceTimeoutError: logrus.Infof("varlink service expired (use --timeout to increase session time beyond %d ms)", c.Int64("timeout")) return nil default: return errors.Errorf("unable to start varlink service") } } return nil }