本文整理汇总了Golang中github.com/coreos/rkt/Godeps/_workspace/src/github.com/appc/spec/schema.PodManifest类的典型用法代码示例。如果您正苦于以下问题:Golang PodManifest类的具体用法?Golang PodManifest怎么用?Golang PodManifest使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
在下文中一共展示了PodManifest类的8个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: getAppImageID
// getAppImageID returns the image id to enter
// If one was supplied in the flags then it's simply returned
// If the PM contains a single image, that image's id is returned
// If the PM has multiple images, the ids and names are printed and an error is returned
func getAppImageID(p *pod) (*types.Hash, error) {
if !flagAppImageID.Empty() {
return &flagAppImageID, nil
}
// figure out the image id, or show a list if multiple are present
b, err := ioutil.ReadFile(common.PodManifestPath(p.path()))
if err != nil {
return nil, fmt.Errorf("error reading pod manifest: %v", err)
}
m := schema.PodManifest{}
if err = m.UnmarshalJSON(b); err != nil {
return nil, fmt.Errorf("unable to load manifest: %v", err)
}
switch len(m.Apps) {
case 0:
return nil, fmt.Errorf("pod contains zero apps")
case 1:
return &m.Apps[0].Image.ID, nil
default:
}
stderr("Pod contains multiple apps:")
for _, ra := range m.Apps {
stderr("\t%s: %s", types.ShortHash(ra.Image.ID.String()), ra.Name.String())
}
return nil, fmt.Errorf("specify app using \"rkt enter --imageid ...\"")
}
开发者ID:balagopalraj,项目名称:clearlinux,代码行数:35,代码来源:enter.go
示例2: getAppName
// getAppName returns the app name to enter
// If one was supplied in the flags then it's simply returned
// If the PM contains a single app, that app's name is returned
// If the PM has multiple apps, the names are printed and an error is returned
func getAppName(p *pod) (*types.ACName, error) {
if flagAppName != "" {
return types.NewACName(flagAppName)
}
// figure out the app name, or show a list if multiple are present
b, err := ioutil.ReadFile(common.PodManifestPath(p.path()))
if err != nil {
return nil, fmt.Errorf("error reading pod manifest: %v", err)
}
m := schema.PodManifest{}
if err = m.UnmarshalJSON(b); err != nil {
return nil, fmt.Errorf("unable to load manifest: %v", err)
}
switch len(m.Apps) {
case 0:
return nil, fmt.Errorf("pod contains zero apps")
case 1:
return &m.Apps[0].Name, nil
default:
}
stderr("Pod contains multiple apps:")
for _, ra := range m.Apps {
stderr("\t%v", ra.Name)
}
return nil, fmt.Errorf("specify app using \"rkt enter --app= ...\"")
}
开发者ID:harpe1999,项目名称:rkt,代码行数:35,代码来源:enter.go
示例3: getApps
// getApps returns a list of apps in the pod
func (p *pod) getApps() (schema.AppList, error) {
pmb, err := p.readFile("pod")
if err != nil {
return nil, fmt.Errorf("error reading pod manifest: %v", err)
}
pm := new(schema.PodManifest)
if err = pm.UnmarshalJSON(pmb); err != nil {
return nil, fmt.Errorf("invalid pod manifest: %v", err)
}
return pm.Apps, nil
}
开发者ID:kinpro,项目名称:rkt,代码行数:12,代码来源:pods.go
示例4: runList
func runList(cmd *cobra.Command, args []string) (exit int) {
if !flagNoLegend {
fmt.Fprintf(tabOut, "UUID\tACI\tSTATE\tNETWORKS\n")
}
if err := walkPods(includeMostDirs, func(p *pod) {
m := schema.PodManifest{}
app_zero := ""
if !p.isPreparing && !p.isAbortedPrepare && !p.isExitedDeleting {
// TODO(vc): we should really hold a shared lock here to prevent gc of the pod
manifFile, err := p.readFile(common.PodManifestPath(""))
if err != nil {
stderr("Unable to read manifest: %v", err)
return
}
err = m.UnmarshalJSON(manifFile)
if err != nil {
stderr("Unable to load manifest: %v", err)
return
}
if len(m.Apps) == 0 {
stderr("Pod contains zero apps")
return
}
app_zero = m.Apps[0].Name.String()
}
uuid := ""
if flagFullOutput {
uuid = p.uuid.String()
} else {
uuid = p.uuid.String()[:8]
}
fmt.Fprintf(tabOut, "%s\t%s\t%s\t%s\n", uuid, app_zero, p.getState(), fmtNets(p.nets))
for i := 1; i < len(m.Apps); i++ {
fmt.Fprintf(tabOut, "\t%s\n", m.Apps[i].Name.String())
}
}); err != nil {
stderr("Failed to get pod handles: %v", err)
return 1
}
tabOut.Flush()
return 0
}
开发者ID:danieltaborda,项目名称:rkt,代码行数:49,代码来源:list.go
示例5: getAppCount
// getAppCount returns the app count of a pod. It can only be called on prepared pods.
func (p *pod) getAppCount() (int, error) {
if !p.isPrepared {
return -1, fmt.Errorf("error: only prepared pods can get their app count")
}
b, err := ioutil.ReadFile(common.PodManifestPath(p.path()))
if err != nil {
return -1, fmt.Errorf("error reading pod manifest: %v", err)
}
m := schema.PodManifest{}
if err = m.UnmarshalJSON(b); err != nil {
return -1, fmt.Errorf("unable to load manifest: %v", err)
}
return len(m.Apps), nil
}
开发者ID:jimberlage,项目名称:rkt,代码行数:18,代码来源:pods.go
示例6: generatePodManifest
// generatePodManifest creates the pod manifest from the command line input.
// It returns the pod manifest as []byte on success.
// This is invoked if no pod manifest is specified at the command line.
func generatePodManifest(cfg PrepareConfig, dir string) ([]byte, error) {
pm := schema.PodManifest{
ACKind: "PodManifest",
Apps: make(schema.AppList, 0),
}
v, err := types.NewSemVer(version.Version)
if err != nil {
return nil, fmt.Errorf("error creating version: %v", err)
}
pm.ACVersion = *v
if err := cfg.Apps.Walk(func(app *apps.App) error {
img := app.ImageID
am, err := cfg.Store.GetImageManifest(img.String())
if err != nil {
return fmt.Errorf("error getting the manifest: %v", err)
}
appName, err := imageNameToAppName(am.Name)
if err != nil {
return fmt.Errorf("error converting image name to app name: %v", err)
}
if err := prepareAppImage(cfg, *appName, img, dir, cfg.UseOverlay); err != nil {
return fmt.Errorf("error setting up image %s: %v", img, err)
}
if pm.Apps.Get(*appName) != nil {
return fmt.Errorf("error: multiple apps with name %s", am.Name)
}
if am.App == nil {
return fmt.Errorf("error: image %s has no app section", img)
}
ra := schema.RuntimeApp{
// TODO(vc): leverage RuntimeApp.Name for disambiguating the apps
Name: *appName,
App: am.App,
Image: schema.RuntimeImage{
Name: &am.Name,
ID: img,
},
Annotations: am.Annotations,
}
if execOverride := app.Exec; execOverride != "" {
ra.App.Exec = []string{execOverride}
}
if execAppends := app.Args; execAppends != nil {
ra.App.Exec = append(ra.App.Exec, execAppends...)
}
if cfg.InheritEnv || len(cfg.ExplicitEnv) > 0 {
MergeEnvs(&ra.App.Environment, cfg.InheritEnv, cfg.ExplicitEnv)
}
pm.Apps = append(pm.Apps, ra)
return nil
}); err != nil {
return nil, err
}
// TODO(jonboulle): check that app mountpoint expectations are
// satisfied here, rather than waiting for stage1
pm.Volumes = cfg.Volumes
pm.Ports = cfg.Ports
pmb, err := json.Marshal(pm)
if err != nil {
return nil, fmt.Errorf("error marshalling pod manifest: %v", err)
}
return pmb, nil
}
开发者ID:krieg,项目名称:rkt,代码行数:74,代码来源:run.go
示例7: runList
func runList(cmd *cobra.Command, args []string) int {
s, err := store.NewStore(globalFlags.Dir)
if err != nil {
stderr("list: cannot open store: %v", err)
return 1
}
var errors []error
tabBuffer := new(bytes.Buffer)
tabOut := getTabOutWithWriter(tabBuffer)
if !flagNoLegend {
if flagFullOutput {
fmt.Fprintf(tabOut, "UUID\tAPP\tIMAGE NAME\tIMAGE ID\tSTATE\tNETWORKS\n")
} else {
fmt.Fprintf(tabOut, "UUID\tAPP\tIMAGE NAME\tSTATE\tNETWORKS\n")
}
}
if err := walkPods(includeMostDirs, func(p *pod) {
pm := schema.PodManifest{}
if !p.isPreparing && !p.isAbortedPrepare && !p.isExitedDeleting {
// TODO(vc): we should really hold a shared lock here to prevent gc of the pod
pmf, err := p.readFile(common.PodManifestPath(""))
if err != nil {
errors = append(errors, newPodListReadError(p, err))
return
}
if err := pm.UnmarshalJSON(pmf); err != nil {
errors = append(errors, newPodListLoadError(p, err, pmf))
return
}
if len(pm.Apps) == 0 {
errors = append(errors, newPodListZeroAppsError(p))
return
}
}
type printedApp struct {
uuid string
appName string
imgName string
imgID string
state string
nets string
}
var appsToPrint []printedApp
uuid := p.uuid.String()
state := p.getState()
nets := fmtNets(p.nets)
if !flagFullOutput {
uuid = uuid[:8]
}
for _, app := range pm.Apps {
// Retrieve the image from the store.
imj, err := s.GetImageManifestJSON(app.Image.ID.String())
if err != nil {
errors = append(errors, newPodListImageStoreFailure(p, err, &pm, app))
return
}
var im *schema.ImageManifest
if err = json.Unmarshal(imj, &im); err != nil {
errors = append(errors, newPodListImageLoadFailure(p, err, &pm, imj, app))
return
}
imageName := im.Name.String()
if version, ok := im.Labels.Get("version"); ok {
imageName = fmt.Sprintf("%s:%s", imageName, version)
}
var imageID string
if flagFullOutput {
imageID = app.Image.ID.String()[:19]
}
appsToPrint = append(appsToPrint, printedApp{
uuid: uuid,
appName: app.Name.String(),
imgName: imageName,
imgID: imageID,
state: state,
nets: nets,
})
// clear those variables so they won't be
// printed for another apps in the pod as they
// are actually describing a pod, not an app
uuid = ""
state = ""
nets = ""
}
// if we reached that point, then it means that the
// pod and all its apps are valid, so they can be
// printed
for _, app := range appsToPrint {
if flagFullOutput {
//.........这里部分代码省略.........
开发者ID:derekparker,项目名称:rkt,代码行数:101,代码来源:list.go
示例8: runList
func runList(cmd *cobra.Command, args []string) (exit int) {
s, err := store.NewStore(globalFlags.Dir)
if err != nil {
stderr("list: cannot open store: %v", err)
return 1
}
if !flagNoLegend {
fmt.Fprintf(tabOut, "UUID\tAPP\tACI\tSTATE\tNETWORKS\n")
}
if err := walkPods(includeMostDirs, func(p *pod) {
pm := schema.PodManifest{}
if !p.isPreparing && !p.isAbortedPrepare && !p.isExitedDeleting {
// TODO(vc): we should really hold a shared lock here to prevent gc of the pod
pmf, err := p.readFile(common.PodManifestPath(""))
if err != nil {
stderr("Unable to read pod manifest: %v", err)
return
}
if err := pm.UnmarshalJSON(pmf); err != nil {
stderr("Unable to load manifest: %v", err)
return
}
if len(pm.Apps) == 0 {
stderr("Pod contains zero apps")
return
}
}
uuid := ""
if flagFullOutput {
uuid = p.uuid.String()
} else {
uuid = p.uuid.String()[:8]
}
for i, app := range pm.Apps {
// Retrieve the image from the store.
im, err := s.GetImageManifest(app.Image.ID.String())
if err != nil {
stderr("Unable to load image manifest: %v", err)
}
if i == 0 {
fmt.Fprintf(tabOut, "%s\t%s\t%s\t%s\t%s\n", uuid, app.Name.String(), im.Name.String(), p.getState(), fmtNets(p.nets))
} else {
fmt.Fprintf(tabOut, "\t%s\t%s\t\t\n", app.Name.String(), im.Name.String())
}
}
}); err != nil {
stderr("Failed to get pod handles: %v", err)
return 1
}
tabOut.Flush()
return 0
}
开发者ID:rhvgoyal,项目名称:rkt,代码行数:62,代码来源:list.go
注:本文中的github.com/coreos/rkt/Godeps/_workspace/src/github.com/appc/spec/schema.PodManifest类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论