Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var AdminClient *gapic.AdminClient
View Source
var AdminServiceCmd = &cobra.Command{ Use: "admin", Short: "The Admin service supports setup and operation of...", Long: "The Admin service supports setup and operation of an API registry. It is typically not included in hosted versions of the API.", ValidArgs: AdminSubCommands, PersistentPreRunE: func(cmd *cobra.Command, args []string) (err error) { AdminClient, err = connection.NewAdminClient(ctx) return }, }
View Source
var AdminSubCommands []string = []string{
"get-status",
"get-storage",
"migrate-database",
"poll-migrate-database", "list-projects",
"get-project",
"create-project",
"update-project",
"delete-project",
}
View Source
var CreateApiCmd = &cobra.Command{ Use: "create-api", Short: "CreateApi creates a specified API.", Long: "CreateApi creates a specified API.", PreRun: func(cmd *cobra.Command, args []string) { if CreateApiFromFile == "" { cmd.MarkFlagRequired("parent") cmd.MarkFlagRequired("api_id") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if CreateApiFromFile != "" { in, err = os.Open(CreateApiFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &CreateApiInput) if err != nil { return err } } if len(CreateApiInputApiLabels) > 0 { CreateApiInput.Api.Labels = make(map[string]string) } for _, item := range CreateApiInputApiLabels { split := strings.Split(item, "=") if len(split) < 2 { err = fmt.Errorf("Invalid map item: %q", item) return } CreateApiInput.Api.Labels[split[0]] = split[1] } if len(CreateApiInputApiAnnotations) > 0 { CreateApiInput.Api.Annotations = make(map[string]string) } for _, item := range CreateApiInputApiAnnotations { split := strings.Split(item, "=") if len(split) < 2 { err = fmt.Errorf("Invalid map item: %q", item) return } CreateApiInput.Api.Annotations[split[0]] = split[1] } if Verbose { printVerboseInput("Registry", "CreateApi", &CreateApiInput) } resp, err := RegistryClient.CreateApi(ctx, &CreateApiInput) if err != nil { return err } if Verbose { fmt.Print("Output: ") } printMessage(resp) return err }, }
View Source
var CreateApiDeploymentCmd = &cobra.Command{ Use: "create-api-deployment", Short: "CreateApiDeployment creates a specified...", Long: "CreateApiDeployment creates a specified deployment.", PreRun: func(cmd *cobra.Command, args []string) { if CreateApiDeploymentFromFile == "" { cmd.MarkFlagRequired("parent") cmd.MarkFlagRequired("api_deployment_id") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if CreateApiDeploymentFromFile != "" { in, err = os.Open(CreateApiDeploymentFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &CreateApiDeploymentInput) if err != nil { return err } } if len(CreateApiDeploymentInputApiDeploymentLabels) > 0 { CreateApiDeploymentInput.ApiDeployment.Labels = make(map[string]string) } for _, item := range CreateApiDeploymentInputApiDeploymentLabels { split := strings.Split(item, "=") if len(split) < 2 { err = fmt.Errorf("Invalid map item: %q", item) return } CreateApiDeploymentInput.ApiDeployment.Labels[split[0]] = split[1] } if len(CreateApiDeploymentInputApiDeploymentAnnotations) > 0 { CreateApiDeploymentInput.ApiDeployment.Annotations = make(map[string]string) } for _, item := range CreateApiDeploymentInputApiDeploymentAnnotations { split := strings.Split(item, "=") if len(split) < 2 { err = fmt.Errorf("Invalid map item: %q", item) return } CreateApiDeploymentInput.ApiDeployment.Annotations[split[0]] = split[1] } if Verbose { printVerboseInput("Registry", "CreateApiDeployment", &CreateApiDeploymentInput) } resp, err := RegistryClient.CreateApiDeployment(ctx, &CreateApiDeploymentInput) if err != nil { return err } if Verbose { fmt.Print("Output: ") } printMessage(resp) return err }, }
View Source
var CreateApiDeploymentFromFile string
View Source
var CreateApiDeploymentInput rpcpb.CreateApiDeploymentRequest
View Source
var CreateApiDeploymentInputApiDeploymentAnnotations []string
View Source
var CreateApiDeploymentInputApiDeploymentLabels []string
View Source
var CreateApiFromFile string
View Source
var CreateApiInput rpcpb.CreateApiRequest
View Source
var CreateApiInputApiAnnotations []string
View Source
var CreateApiInputApiLabels []string
View Source
var CreateApiSpecCmd = &cobra.Command{ Use: "create-api-spec", Short: "CreateApiSpec creates a specified spec.", Long: "CreateApiSpec creates a specified spec.", PreRun: func(cmd *cobra.Command, args []string) { if CreateApiSpecFromFile == "" { cmd.MarkFlagRequired("parent") cmd.MarkFlagRequired("api_spec_id") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if CreateApiSpecFromFile != "" { in, err = os.Open(CreateApiSpecFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &CreateApiSpecInput) if err != nil { return err } } if len(CreateApiSpecInputApiSpecLabels) > 0 { CreateApiSpecInput.ApiSpec.Labels = make(map[string]string) } for _, item := range CreateApiSpecInputApiSpecLabels { split := strings.Split(item, "=") if len(split) < 2 { err = fmt.Errorf("Invalid map item: %q", item) return } CreateApiSpecInput.ApiSpec.Labels[split[0]] = split[1] } if len(CreateApiSpecInputApiSpecAnnotations) > 0 { CreateApiSpecInput.ApiSpec.Annotations = make(map[string]string) } for _, item := range CreateApiSpecInputApiSpecAnnotations { split := strings.Split(item, "=") if len(split) < 2 { err = fmt.Errorf("Invalid map item: %q", item) return } CreateApiSpecInput.ApiSpec.Annotations[split[0]] = split[1] } if Verbose { printVerboseInput("Registry", "CreateApiSpec", &CreateApiSpecInput) } resp, err := RegistryClient.CreateApiSpec(ctx, &CreateApiSpecInput) if err != nil { return err } if Verbose { fmt.Print("Output: ") } printMessage(resp) return err }, }
View Source
var CreateApiSpecFromFile string
View Source
var CreateApiSpecInput rpcpb.CreateApiSpecRequest
View Source
var CreateApiSpecInputApiSpecAnnotations []string
View Source
var CreateApiSpecInputApiSpecLabels []string
View Source
var CreateApiVersionCmd = &cobra.Command{ Use: "create-api-version", Short: "CreateApiVersion creates a specified version.", Long: "CreateApiVersion creates a specified version.", PreRun: func(cmd *cobra.Command, args []string) { if CreateApiVersionFromFile == "" { cmd.MarkFlagRequired("parent") cmd.MarkFlagRequired("api_version_id") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if CreateApiVersionFromFile != "" { in, err = os.Open(CreateApiVersionFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &CreateApiVersionInput) if err != nil { return err } } if len(CreateApiVersionInputApiVersionLabels) > 0 { CreateApiVersionInput.ApiVersion.Labels = make(map[string]string) } for _, item := range CreateApiVersionInputApiVersionLabels { split := strings.Split(item, "=") if len(split) < 2 { err = fmt.Errorf("Invalid map item: %q", item) return } CreateApiVersionInput.ApiVersion.Labels[split[0]] = split[1] } if len(CreateApiVersionInputApiVersionAnnotations) > 0 { CreateApiVersionInput.ApiVersion.Annotations = make(map[string]string) } for _, item := range CreateApiVersionInputApiVersionAnnotations { split := strings.Split(item, "=") if len(split) < 2 { err = fmt.Errorf("Invalid map item: %q", item) return } CreateApiVersionInput.ApiVersion.Annotations[split[0]] = split[1] } if Verbose { printVerboseInput("Registry", "CreateApiVersion", &CreateApiVersionInput) } resp, err := RegistryClient.CreateApiVersion(ctx, &CreateApiVersionInput) if err != nil { return err } if Verbose { fmt.Print("Output: ") } printMessage(resp) return err }, }
View Source
var CreateApiVersionFromFile string
View Source
var CreateApiVersionInput rpcpb.CreateApiVersionRequest
View Source
var CreateApiVersionInputApiVersionAnnotations []string
View Source
var CreateApiVersionInputApiVersionLabels []string
View Source
var CreateArtifactCmd = &cobra.Command{ Use: "create-artifact", Short: "CreateArtifact creates a specified artifact.", Long: "CreateArtifact creates a specified artifact.", PreRun: func(cmd *cobra.Command, args []string) { if CreateArtifactFromFile == "" { cmd.MarkFlagRequired("parent") cmd.MarkFlagRequired("artifact_id") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if CreateArtifactFromFile != "" { in, err = os.Open(CreateArtifactFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &CreateArtifactInput) if err != nil { return err } } if len(CreateArtifactInputArtifactLabels) > 0 { CreateArtifactInput.Artifact.Labels = make(map[string]string) } for _, item := range CreateArtifactInputArtifactLabels { split := strings.Split(item, "=") if len(split) < 2 { err = fmt.Errorf("Invalid map item: %q", item) return } CreateArtifactInput.Artifact.Labels[split[0]] = split[1] } if len(CreateArtifactInputArtifactAnnotations) > 0 { CreateArtifactInput.Artifact.Annotations = make(map[string]string) } for _, item := range CreateArtifactInputArtifactAnnotations { split := strings.Split(item, "=") if len(split) < 2 { err = fmt.Errorf("Invalid map item: %q", item) return } CreateArtifactInput.Artifact.Annotations[split[0]] = split[1] } if Verbose { printVerboseInput("Registry", "CreateArtifact", &CreateArtifactInput) } resp, err := RegistryClient.CreateArtifact(ctx, &CreateArtifactInput) if err != nil { return err } if Verbose { fmt.Print("Output: ") } printMessage(resp) return err }, }
View Source
var CreateArtifactFromFile string
View Source
var CreateArtifactInput rpcpb.CreateArtifactRequest
View Source
var CreateArtifactInputArtifactAnnotations []string
View Source
var CreateArtifactInputArtifactLabels []string
View Source
var CreateInstanceCmd = &cobra.Command{ Use: "create-instance", Short: "Provisions instance resources for the Registry.", Long: "Provisions instance resources for the Registry.", PreRun: func(cmd *cobra.Command, args []string) { if CreateInstanceFromFile == "" { cmd.MarkFlagRequired("parent") cmd.MarkFlagRequired("instance_id") cmd.MarkFlagRequired("instance.config.cmek_key_name") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if CreateInstanceFromFile != "" { in, err = os.Open(CreateInstanceFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &CreateInstanceInput) if err != nil { return err } } if Verbose { printVerboseInput("Provisioning", "CreateInstance", &CreateInstanceInput) } resp, err := ProvisioningClient.CreateInstance(ctx, &CreateInstanceInput) if err != nil { return err } if !CreateInstanceFollow { var s interface{} s = resp.Name() if OutputJSON { d := make(map[string]string) d["operation"] = resp.Name() s = d } printMessage(s) return err } result, err := resp.Wait(ctx) if err != nil { return err } if Verbose { fmt.Print("Output: ") } printMessage(result) return err }, }
View Source
var CreateInstanceFollow bool
View Source
var CreateInstanceFromFile string
View Source
var CreateInstanceInput rpcpb.CreateInstanceRequest
View Source
var CreateInstancePollCmd = &cobra.Command{ Use: "poll-create-instance", Short: "Poll the status of a CreateInstanceOperation by name", RunE: func(cmd *cobra.Command, args []string) (err error) { op := ProvisioningClient.CreateInstanceOperation(CreateInstancePollOperation) if CreateInstanceFollow { resp, err := op.Wait(ctx) if err != nil { return err } if Verbose { fmt.Print("Output: ") } printMessage(resp) return err } resp, err := op.Poll(ctx) if err != nil { return err } else if resp != nil { if Verbose { fmt.Print("Output: ") } printMessage(resp) return } if op.Done() { fmt.Println(fmt.Sprintf("Operation %s is done", op.Name())) } else { fmt.Println(fmt.Sprintf("Operation %s not done", op.Name())) } return err }, }
View Source
var CreateInstancePollOperation string
View Source
var CreateProjectCmd = &cobra.Command{ Use: "create-project", Short: "CreateProject creates a specified project. (--...", Long: "CreateProject creates a specified project. (-- api-linter: standard-methods=disabled --) (-- api-linter: core::0133::http-uri-parent=disabled ...", PreRun: func(cmd *cobra.Command, args []string) { if CreateProjectFromFile == "" { cmd.MarkFlagRequired("project_id") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if CreateProjectFromFile != "" { in, err = os.Open(CreateProjectFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &CreateProjectInput) if err != nil { return err } } if Verbose { printVerboseInput("Admin", "CreateProject", &CreateProjectInput) } resp, err := AdminClient.CreateProject(ctx, &CreateProjectInput) if err != nil { return err } if Verbose { fmt.Print("Output: ") } printMessage(resp) return err }, }
View Source
var CreateProjectFromFile string
View Source
var CreateProjectInput rpcpb.CreateProjectRequest
View Source
var DeleteApiCmd = &cobra.Command{ Use: "delete-api", Short: "DeleteApi removes a specified API and all of the...", Long: "DeleteApi removes a specified API and all of the resources that it owns.", PreRun: func(cmd *cobra.Command, args []string) { if DeleteApiFromFile == "" { cmd.MarkFlagRequired("name") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if DeleteApiFromFile != "" { in, err = os.Open(DeleteApiFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &DeleteApiInput) if err != nil { return err } } if Verbose { printVerboseInput("Registry", "DeleteApi", &DeleteApiInput) } err = RegistryClient.DeleteApi(ctx, &DeleteApiInput) if err != nil { return err } return err }, }
View Source
var DeleteApiDeploymentCmd = &cobra.Command{ Use: "delete-api-deployment", Short: "DeleteApiDeployment removes a specified...", Long: "DeleteApiDeployment removes a specified deployment, all revisions, and all child resources (e.g. artifacts).", PreRun: func(cmd *cobra.Command, args []string) { if DeleteApiDeploymentFromFile == "" { cmd.MarkFlagRequired("name") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if DeleteApiDeploymentFromFile != "" { in, err = os.Open(DeleteApiDeploymentFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &DeleteApiDeploymentInput) if err != nil { return err } } if Verbose { printVerboseInput("Registry", "DeleteApiDeployment", &DeleteApiDeploymentInput) } err = RegistryClient.DeleteApiDeployment(ctx, &DeleteApiDeploymentInput) if err != nil { return err } return err }, }
View Source
var DeleteApiDeploymentFromFile string
View Source
var DeleteApiDeploymentInput rpcpb.DeleteApiDeploymentRequest
View Source
var DeleteApiDeploymentRevisionCmd = &cobra.Command{ Use: "delete-api-deployment-revision", Short: "DeleteApiDeploymentRevision deletes a revision of...", Long: "DeleteApiDeploymentRevision deletes a revision of a deployment.", PreRun: func(cmd *cobra.Command, args []string) { if DeleteApiDeploymentRevisionFromFile == "" { cmd.MarkFlagRequired("name") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if DeleteApiDeploymentRevisionFromFile != "" { in, err = os.Open(DeleteApiDeploymentRevisionFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &DeleteApiDeploymentRevisionInput) if err != nil { return err } } if Verbose { printVerboseInput("Registry", "DeleteApiDeploymentRevision", &DeleteApiDeploymentRevisionInput) } resp, err := RegistryClient.DeleteApiDeploymentRevision(ctx, &DeleteApiDeploymentRevisionInput) if err != nil { return err } if Verbose { fmt.Print("Output: ") } printMessage(resp) return err }, }
View Source
var DeleteApiDeploymentRevisionFromFile string
View Source
var DeleteApiDeploymentRevisionInput rpcpb.DeleteApiDeploymentRevisionRequest
View Source
var DeleteApiFromFile string
View Source
var DeleteApiInput rpcpb.DeleteApiRequest
View Source
var DeleteApiSpecCmd = &cobra.Command{ Use: "delete-api-spec", Short: "DeleteApiSpec removes a specified spec, all...", Long: "DeleteApiSpec removes a specified spec, all revisions, and all child resources (e.g. artifacts).", PreRun: func(cmd *cobra.Command, args []string) { if DeleteApiSpecFromFile == "" { cmd.MarkFlagRequired("name") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if DeleteApiSpecFromFile != "" { in, err = os.Open(DeleteApiSpecFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &DeleteApiSpecInput) if err != nil { return err } } if Verbose { printVerboseInput("Registry", "DeleteApiSpec", &DeleteApiSpecInput) } err = RegistryClient.DeleteApiSpec(ctx, &DeleteApiSpecInput) if err != nil { return err } return err }, }
View Source
var DeleteApiSpecFromFile string
View Source
var DeleteApiSpecInput rpcpb.DeleteApiSpecRequest
View Source
var DeleteApiSpecRevisionCmd = &cobra.Command{ Use: "delete-api-spec-revision", Short: "DeleteApiSpecRevision deletes a revision of a...", Long: "DeleteApiSpecRevision deletes a revision of a spec.", PreRun: func(cmd *cobra.Command, args []string) { if DeleteApiSpecRevisionFromFile == "" { cmd.MarkFlagRequired("name") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if DeleteApiSpecRevisionFromFile != "" { in, err = os.Open(DeleteApiSpecRevisionFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &DeleteApiSpecRevisionInput) if err != nil { return err } } if Verbose { printVerboseInput("Registry", "DeleteApiSpecRevision", &DeleteApiSpecRevisionInput) } resp, err := RegistryClient.DeleteApiSpecRevision(ctx, &DeleteApiSpecRevisionInput) if err != nil { return err } if Verbose { fmt.Print("Output: ") } printMessage(resp) return err }, }
View Source
var DeleteApiSpecRevisionFromFile string
View Source
var DeleteApiSpecRevisionInput rpcpb.DeleteApiSpecRevisionRequest
View Source
var DeleteApiVersionCmd = &cobra.Command{ Use: "delete-api-version", Short: "DeleteApiVersion removes a specified version and...", Long: "DeleteApiVersion removes a specified version and all of the resources that it owns.", PreRun: func(cmd *cobra.Command, args []string) { if DeleteApiVersionFromFile == "" { cmd.MarkFlagRequired("name") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if DeleteApiVersionFromFile != "" { in, err = os.Open(DeleteApiVersionFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &DeleteApiVersionInput) if err != nil { return err } } if Verbose { printVerboseInput("Registry", "DeleteApiVersion", &DeleteApiVersionInput) } err = RegistryClient.DeleteApiVersion(ctx, &DeleteApiVersionInput) if err != nil { return err } return err }, }
View Source
var DeleteApiVersionFromFile string
View Source
var DeleteApiVersionInput rpcpb.DeleteApiVersionRequest
View Source
var DeleteArtifactCmd = &cobra.Command{ Use: "delete-artifact", Short: "DeleteArtifact removes a specified artifact.", Long: "DeleteArtifact removes a specified artifact.", PreRun: func(cmd *cobra.Command, args []string) { if DeleteArtifactFromFile == "" { cmd.MarkFlagRequired("name") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if DeleteArtifactFromFile != "" { in, err = os.Open(DeleteArtifactFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &DeleteArtifactInput) if err != nil { return err } } if Verbose { printVerboseInput("Registry", "DeleteArtifact", &DeleteArtifactInput) } err = RegistryClient.DeleteArtifact(ctx, &DeleteArtifactInput) if err != nil { return err } return err }, }
View Source
var DeleteArtifactFromFile string
View Source
var DeleteArtifactInput rpcpb.DeleteArtifactRequest
View Source
var DeleteInstanceCmd = &cobra.Command{ Use: "delete-instance", Short: "Deletes the Registry instance.", Long: "Deletes the Registry instance.", PreRun: func(cmd *cobra.Command, args []string) { if DeleteInstanceFromFile == "" { cmd.MarkFlagRequired("name") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if DeleteInstanceFromFile != "" { in, err = os.Open(DeleteInstanceFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &DeleteInstanceInput) if err != nil { return err } } if Verbose { printVerboseInput("Provisioning", "DeleteInstance", &DeleteInstanceInput) } resp, err := ProvisioningClient.DeleteInstance(ctx, &DeleteInstanceInput) if err != nil { return err } if !DeleteInstanceFollow { var s interface{} s = resp.Name() if OutputJSON { d := make(map[string]string) d["operation"] = resp.Name() s = d } printMessage(s) return err } err = resp.Wait(ctx) return err }, }
View Source
var DeleteInstanceFollow bool
View Source
var DeleteInstanceFromFile string
View Source
var DeleteInstanceInput rpcpb.DeleteInstanceRequest
View Source
var DeleteInstancePollCmd = &cobra.Command{ Use: "poll-delete-instance", Short: "Poll the status of a DeleteInstanceOperation by name", RunE: func(cmd *cobra.Command, args []string) (err error) { op := ProvisioningClient.DeleteInstanceOperation(DeleteInstancePollOperation) if DeleteInstanceFollow { return op.Wait(ctx) } err = op.Poll(ctx) if err != nil { return err } if op.Done() { fmt.Println(fmt.Sprintf("Operation %s is done", op.Name())) } else { fmt.Println(fmt.Sprintf("Operation %s not done", op.Name())) } return err }, }
View Source
var DeleteInstancePollOperation string
View Source
var DeleteProjectCmd = &cobra.Command{ Use: "delete-project", Short: "DeleteProject removes a specified project and all...", Long: "DeleteProject removes a specified project and all of the resources that it owns.", PreRun: func(cmd *cobra.Command, args []string) { if DeleteProjectFromFile == "" { cmd.MarkFlagRequired("name") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if DeleteProjectFromFile != "" { in, err = os.Open(DeleteProjectFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &DeleteProjectInput) if err != nil { return err } } if Verbose { printVerboseInput("Admin", "DeleteProject", &DeleteProjectInput) } err = AdminClient.DeleteProject(ctx, &DeleteProjectInput) if err != nil { return err } return err }, }
View Source
var DeleteProjectFromFile string
View Source
var DeleteProjectInput rpcpb.DeleteProjectRequest
View Source
var GetApiCmd = &cobra.Command{ Use: "get-api", Short: "GetApi returns a specified API.", Long: "GetApi returns a specified API.", PreRun: func(cmd *cobra.Command, args []string) { if GetApiFromFile == "" { cmd.MarkFlagRequired("name") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if GetApiFromFile != "" { in, err = os.Open(GetApiFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &GetApiInput) if err != nil { return err } } if Verbose { printVerboseInput("Registry", "GetApi", &GetApiInput) } resp, err := RegistryClient.GetApi(ctx, &GetApiInput) if err != nil { return err } if Verbose { fmt.Print("Output: ") } printMessage(resp) return err }, }
View Source
var GetApiDeploymentCmd = &cobra.Command{ Use: "get-api-deployment", Short: "GetApiDeployment returns a specified deployment.", Long: "GetApiDeployment returns a specified deployment.", PreRun: func(cmd *cobra.Command, args []string) { if GetApiDeploymentFromFile == "" { cmd.MarkFlagRequired("name") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if GetApiDeploymentFromFile != "" { in, err = os.Open(GetApiDeploymentFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &GetApiDeploymentInput) if err != nil { return err } } if Verbose { printVerboseInput("Registry", "GetApiDeployment", &GetApiDeploymentInput) } resp, err := RegistryClient.GetApiDeployment(ctx, &GetApiDeploymentInput) if err != nil { return err } if Verbose { fmt.Print("Output: ") } printMessage(resp) return err }, }
View Source
var GetApiDeploymentFromFile string
View Source
var GetApiDeploymentInput rpcpb.GetApiDeploymentRequest
View Source
var GetApiFromFile string
View Source
var GetApiInput rpcpb.GetApiRequest
View Source
var GetApiSpecCmd = &cobra.Command{ Use: "get-api-spec", Short: "GetApiSpec returns a specified spec.", Long: "GetApiSpec returns a specified spec.", PreRun: func(cmd *cobra.Command, args []string) { if GetApiSpecFromFile == "" { cmd.MarkFlagRequired("name") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if GetApiSpecFromFile != "" { in, err = os.Open(GetApiSpecFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &GetApiSpecInput) if err != nil { return err } } if Verbose { printVerboseInput("Registry", "GetApiSpec", &GetApiSpecInput) } resp, err := RegistryClient.GetApiSpec(ctx, &GetApiSpecInput) if err != nil { return err } if Verbose { fmt.Print("Output: ") } printMessage(resp) return err }, }
View Source
var GetApiSpecContentsCmd = &cobra.Command{ Use: "get-api-spec-contents", Short: "GetApiSpecContents returns the contents of a...", Long: "GetApiSpecContents returns the contents of a specified spec. If specs are stored with GZip compression, the default behavior is to return the spec...", PreRun: func(cmd *cobra.Command, args []string) { if GetApiSpecContentsFromFile == "" { cmd.MarkFlagRequired("name") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if GetApiSpecContentsFromFile != "" { in, err = os.Open(GetApiSpecContentsFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &GetApiSpecContentsInput) if err != nil { return err } } if Verbose { printVerboseInput("Registry", "GetApiSpecContents", &GetApiSpecContentsInput) } resp, err := RegistryClient.GetApiSpecContents(ctx, &GetApiSpecContentsInput) if err != nil { return err } if Verbose { fmt.Print("Output: ") } printMessage(resp) return err }, }
View Source
var GetApiSpecContentsFromFile string
View Source
var GetApiSpecContentsInput rpcpb.GetApiSpecContentsRequest
View Source
var GetApiSpecFromFile string
View Source
var GetApiSpecInput rpcpb.GetApiSpecRequest
View Source
var GetApiVersionCmd = &cobra.Command{ Use: "get-api-version", Short: "GetApiVersion returns a specified version.", Long: "GetApiVersion returns a specified version.", PreRun: func(cmd *cobra.Command, args []string) { if GetApiVersionFromFile == "" { cmd.MarkFlagRequired("name") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if GetApiVersionFromFile != "" { in, err = os.Open(GetApiVersionFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &GetApiVersionInput) if err != nil { return err } } if Verbose { printVerboseInput("Registry", "GetApiVersion", &GetApiVersionInput) } resp, err := RegistryClient.GetApiVersion(ctx, &GetApiVersionInput) if err != nil { return err } if Verbose { fmt.Print("Output: ") } printMessage(resp) return err }, }
View Source
var GetApiVersionFromFile string
View Source
var GetApiVersionInput rpcpb.GetApiVersionRequest
View Source
var GetArtifactCmd = &cobra.Command{ Use: "get-artifact", Short: "GetArtifact returns a specified artifact.", Long: "GetArtifact returns a specified artifact.", PreRun: func(cmd *cobra.Command, args []string) { if GetArtifactFromFile == "" { cmd.MarkFlagRequired("name") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if GetArtifactFromFile != "" { in, err = os.Open(GetArtifactFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &GetArtifactInput) if err != nil { return err } } if Verbose { printVerboseInput("Registry", "GetArtifact", &GetArtifactInput) } resp, err := RegistryClient.GetArtifact(ctx, &GetArtifactInput) if err != nil { return err } if Verbose { fmt.Print("Output: ") } printMessage(resp) return err }, }
View Source
var GetArtifactContentsCmd = &cobra.Command{ Use: "get-artifact-contents", Short: "GetArtifactContents returns the contents of a...", Long: "GetArtifactContents returns the contents of a specified artifact. If artifacts are stored with GZip compression, the default behavior is to return...", PreRun: func(cmd *cobra.Command, args []string) { if GetArtifactContentsFromFile == "" { cmd.MarkFlagRequired("name") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if GetArtifactContentsFromFile != "" { in, err = os.Open(GetArtifactContentsFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &GetArtifactContentsInput) if err != nil { return err } } if Verbose { printVerboseInput("Registry", "GetArtifactContents", &GetArtifactContentsInput) } resp, err := RegistryClient.GetArtifactContents(ctx, &GetArtifactContentsInput) if err != nil { return err } if Verbose { fmt.Print("Output: ") } printMessage(resp) return err }, }
View Source
var GetArtifactContentsFromFile string
View Source
var GetArtifactContentsInput rpcpb.GetArtifactContentsRequest
View Source
var GetArtifactFromFile string
View Source
var GetArtifactInput rpcpb.GetArtifactRequest
View Source
var GetInstanceCmd = &cobra.Command{ Use: "get-instance", Short: "Gets details of a single Instance.", Long: "Gets details of a single Instance.", PreRun: func(cmd *cobra.Command, args []string) { if GetInstanceFromFile == "" { cmd.MarkFlagRequired("name") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if GetInstanceFromFile != "" { in, err = os.Open(GetInstanceFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &GetInstanceInput) if err != nil { return err } } if Verbose { printVerboseInput("Provisioning", "GetInstance", &GetInstanceInput) } resp, err := ProvisioningClient.GetInstance(ctx, &GetInstanceInput) if err != nil { return err } if Verbose { fmt.Print("Output: ") } printMessage(resp) return err }, }
View Source
var GetInstanceFromFile string
View Source
var GetInstanceInput rpcpb.GetInstanceRequest
View Source
var GetProjectCmd = &cobra.Command{ Use: "get-project", Short: "GetProject returns a specified project.", Long: "GetProject returns a specified project.", PreRun: func(cmd *cobra.Command, args []string) { if GetProjectFromFile == "" { cmd.MarkFlagRequired("name") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if GetProjectFromFile != "" { in, err = os.Open(GetProjectFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &GetProjectInput) if err != nil { return err } } if Verbose { printVerboseInput("Admin", "GetProject", &GetProjectInput) } resp, err := AdminClient.GetProject(ctx, &GetProjectInput) if err != nil { return err } if Verbose { fmt.Print("Output: ") } printMessage(resp) return err }, }
View Source
var GetProjectFromFile string
View Source
var GetProjectInput rpcpb.GetProjectRequest
View Source
var GetStatusCmd = &cobra.Command{ Use: "get-status", Short: "GetStatus returns the status of the service. (--...", Long: "GetStatus returns the status of the service. (-- api-linter: core::0131::request-message-name=disabled aip.dev/not-precedent: Not in the...", PreRun: func(cmd *cobra.Command, args []string) { }, RunE: func(cmd *cobra.Command, args []string) (err error) { if Verbose { printVerboseInput("Admin", "GetStatus", &GetStatusInput) } resp, err := AdminClient.GetStatus(ctx, &GetStatusInput) if err != nil { return err } if Verbose { fmt.Print("Output: ") } printMessage(resp) return err }, }
View Source
var GetStatusInput emptypb.Empty
View Source
var GetStorageCmd = &cobra.Command{ Use: "get-storage", Short: "GetStorage returns information about the storage...", Long: "GetStorage returns information about the storage used by the service. (-- api-linter: core::0131::request-message-name=disabled ...", PreRun: func(cmd *cobra.Command, args []string) { }, RunE: func(cmd *cobra.Command, args []string) (err error) { if Verbose { printVerboseInput("Admin", "GetStorage", &GetStorageInput) } resp, err := AdminClient.GetStorage(ctx, &GetStorageInput) if err != nil { return err } if Verbose { fmt.Print("Output: ") } printMessage(resp) return err }, }
View Source
var GetStorageInput emptypb.Empty
View Source
var ListApiDeploymentRevisionsCmd = &cobra.Command{ Use: "list-api-deployment-revisions", Short: "ListApiDeploymentRevisions lists all revisions of...", Long: "ListApiDeploymentRevisions lists all revisions of a deployment. Revisions are returned in descending order of revision creation time.", PreRun: func(cmd *cobra.Command, args []string) { if ListApiDeploymentRevisionsFromFile == "" { cmd.MarkFlagRequired("name") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if ListApiDeploymentRevisionsFromFile != "" { in, err = os.Open(ListApiDeploymentRevisionsFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &ListApiDeploymentRevisionsInput) if err != nil { return err } } if Verbose { printVerboseInput("Registry", "ListApiDeploymentRevisions", &ListApiDeploymentRevisionsInput) } iter := RegistryClient.ListApiDeploymentRevisions(ctx, &ListApiDeploymentRevisionsInput) _, err = iter.Next() if err != nil && err != iterator.Done { return err } if Verbose { fmt.Print("Output: ") } printMessage(iter.Response) return err }, }
View Source
var ListApiDeploymentRevisionsFromFile string
View Source
var ListApiDeploymentRevisionsInput rpcpb.ListApiDeploymentRevisionsRequest
View Source
var ListApiDeploymentsCmd = &cobra.Command{ Use: "list-api-deployments", Short: "ListApiDeployments returns matching deployments.", Long: "ListApiDeployments returns matching deployments.", PreRun: func(cmd *cobra.Command, args []string) { if ListApiDeploymentsFromFile == "" { cmd.MarkFlagRequired("parent") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if ListApiDeploymentsFromFile != "" { in, err = os.Open(ListApiDeploymentsFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &ListApiDeploymentsInput) if err != nil { return err } } if Verbose { printVerboseInput("Registry", "ListApiDeployments", &ListApiDeploymentsInput) } iter := RegistryClient.ListApiDeployments(ctx, &ListApiDeploymentsInput) _, err = iter.Next() if err != nil && err != iterator.Done { return err } if Verbose { fmt.Print("Output: ") } printMessage(iter.Response) return err }, }
View Source
var ListApiDeploymentsFromFile string
View Source
var ListApiDeploymentsInput rpcpb.ListApiDeploymentsRequest
View Source
var ListApiSpecRevisionsCmd = &cobra.Command{ Use: "list-api-spec-revisions", Short: "ListApiSpecRevisions lists all revisions of a...", Long: "ListApiSpecRevisions lists all revisions of a spec. Revisions are returned in descending order of revision creation time.", PreRun: func(cmd *cobra.Command, args []string) { if ListApiSpecRevisionsFromFile == "" { cmd.MarkFlagRequired("name") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if ListApiSpecRevisionsFromFile != "" { in, err = os.Open(ListApiSpecRevisionsFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &ListApiSpecRevisionsInput) if err != nil { return err } } if Verbose { printVerboseInput("Registry", "ListApiSpecRevisions", &ListApiSpecRevisionsInput) } iter := RegistryClient.ListApiSpecRevisions(ctx, &ListApiSpecRevisionsInput) _, err = iter.Next() if err != nil && err != iterator.Done { return err } if Verbose { fmt.Print("Output: ") } printMessage(iter.Response) return err }, }
View Source
var ListApiSpecRevisionsFromFile string
View Source
var ListApiSpecRevisionsInput rpcpb.ListApiSpecRevisionsRequest
View Source
var ListApiSpecsCmd = &cobra.Command{ Use: "list-api-specs", Short: "ListApiSpecs returns matching specs.", Long: "ListApiSpecs returns matching specs.", PreRun: func(cmd *cobra.Command, args []string) { if ListApiSpecsFromFile == "" { cmd.MarkFlagRequired("parent") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if ListApiSpecsFromFile != "" { in, err = os.Open(ListApiSpecsFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &ListApiSpecsInput) if err != nil { return err } } if Verbose { printVerboseInput("Registry", "ListApiSpecs", &ListApiSpecsInput) } iter := RegistryClient.ListApiSpecs(ctx, &ListApiSpecsInput) _, err = iter.Next() if err != nil && err != iterator.Done { return err } if Verbose { fmt.Print("Output: ") } printMessage(iter.Response) return err }, }
View Source
var ListApiSpecsFromFile string
View Source
var ListApiSpecsInput rpcpb.ListApiSpecsRequest
View Source
var ListApiVersionsCmd = &cobra.Command{ Use: "list-api-versions", Short: "ListApiVersions returns matching versions.", Long: "ListApiVersions returns matching versions.", PreRun: func(cmd *cobra.Command, args []string) { if ListApiVersionsFromFile == "" { cmd.MarkFlagRequired("parent") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if ListApiVersionsFromFile != "" { in, err = os.Open(ListApiVersionsFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &ListApiVersionsInput) if err != nil { return err } } if Verbose { printVerboseInput("Registry", "ListApiVersions", &ListApiVersionsInput) } iter := RegistryClient.ListApiVersions(ctx, &ListApiVersionsInput) _, err = iter.Next() if err != nil && err != iterator.Done { return err } if Verbose { fmt.Print("Output: ") } printMessage(iter.Response) return err }, }
View Source
var ListApiVersionsFromFile string
View Source
var ListApiVersionsInput rpcpb.ListApiVersionsRequest
View Source
var ListApisCmd = &cobra.Command{ Use: "list-apis", Short: "ListApis returns matching APIs.", Long: "ListApis returns matching APIs.", PreRun: func(cmd *cobra.Command, args []string) { if ListApisFromFile == "" { cmd.MarkFlagRequired("parent") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if ListApisFromFile != "" { in, err = os.Open(ListApisFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &ListApisInput) if err != nil { return err } } if Verbose { printVerboseInput("Registry", "ListApis", &ListApisInput) } iter := RegistryClient.ListApis(ctx, &ListApisInput) _, err = iter.Next() if err != nil && err != iterator.Done { return err } if Verbose { fmt.Print("Output: ") } printMessage(iter.Response) return err }, }
View Source
var ListApisFromFile string
View Source
var ListApisInput rpcpb.ListApisRequest
View Source
var ListArtifactsCmd = &cobra.Command{ Use: "list-artifacts", Short: "ListArtifacts returns matching artifacts.", Long: "ListArtifacts returns matching artifacts.", PreRun: func(cmd *cobra.Command, args []string) { if ListArtifactsFromFile == "" { cmd.MarkFlagRequired("parent") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if ListArtifactsFromFile != "" { in, err = os.Open(ListArtifactsFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &ListArtifactsInput) if err != nil { return err } } if Verbose { printVerboseInput("Registry", "ListArtifacts", &ListArtifactsInput) } iter := RegistryClient.ListArtifacts(ctx, &ListArtifactsInput) _, err = iter.Next() if err != nil && err != iterator.Done { return err } if Verbose { fmt.Print("Output: ") } printMessage(iter.Response) return err }, }
View Source
var ListArtifactsFromFile string
View Source
var ListArtifactsInput rpcpb.ListArtifactsRequest
View Source
var ListProjectsCmd = &cobra.Command{ Use: "list-projects", Short: "ListProjects returns matching projects. (--...", Long: "ListProjects returns matching projects. (-- api-linter: standard-methods=disabled --) (-- api-linter: core::0132::method-signature=disabled ...", PreRun: func(cmd *cobra.Command, args []string) { if ListProjectsFromFile == "" { } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if ListProjectsFromFile != "" { in, err = os.Open(ListProjectsFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &ListProjectsInput) if err != nil { return err } } if Verbose { printVerboseInput("Admin", "ListProjects", &ListProjectsInput) } iter := AdminClient.ListProjects(ctx, &ListProjectsInput) _, err = iter.Next() if err != nil && err != iterator.Done { return err } if Verbose { fmt.Print("Output: ") } printMessage(iter.Response) return err }, }
View Source
var ListProjectsFromFile string
View Source
var ListProjectsInput rpcpb.ListProjectsRequest
View Source
var MigrateDatabaseCmd = &cobra.Command{ Use: "migrate-database", Short: "MigrateDatabase attempts to migrate the database...", Long: "MigrateDatabase attempts to migrate the database to the current schema.", PreRun: func(cmd *cobra.Command, args []string) { if MigrateDatabaseFromFile == "" { } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if MigrateDatabaseFromFile != "" { in, err = os.Open(MigrateDatabaseFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &MigrateDatabaseInput) if err != nil { return err } } if Verbose { printVerboseInput("Admin", "MigrateDatabase", &MigrateDatabaseInput) } resp, err := AdminClient.MigrateDatabase(ctx, &MigrateDatabaseInput) if err != nil { return err } if !MigrateDatabaseFollow { var s interface{} s = resp.Name() if OutputJSON { d := make(map[string]string) d["operation"] = resp.Name() s = d } printMessage(s) return err } result, err := resp.Wait(ctx) if err != nil { return err } if Verbose { fmt.Print("Output: ") } printMessage(result) return err }, }
View Source
var MigrateDatabaseFollow bool
View Source
var MigrateDatabaseFromFile string
View Source
var MigrateDatabaseInput rpcpb.MigrateDatabaseRequest
View Source
var MigrateDatabasePollCmd = &cobra.Command{ Use: "poll-migrate-database", Short: "Poll the status of a MigrateDatabaseOperation by name", RunE: func(cmd *cobra.Command, args []string) (err error) { op := AdminClient.MigrateDatabaseOperation(MigrateDatabasePollOperation) if MigrateDatabaseFollow { resp, err := op.Wait(ctx) if err != nil { return err } if Verbose { fmt.Print("Output: ") } printMessage(resp) return err } resp, err := op.Poll(ctx) if err != nil { return err } else if resp != nil { if Verbose { fmt.Print("Output: ") } printMessage(resp) return } if op.Done() { fmt.Println(fmt.Sprintf("Operation %s is done", op.Name())) } else { fmt.Println(fmt.Sprintf("Operation %s not done", op.Name())) } return err }, }
View Source
var MigrateDatabasePollOperation string
View Source
var ProvisioningClient *gapic.ProvisioningClient
View Source
var ProvisioningServiceCmd = &cobra.Command{ Use: "provisioning", Short: "The service that is used for managing the data...", Long: "The service that is used for managing the data plane provisioning of the Registry.", ValidArgs: ProvisioningSubCommands, PersistentPreRunE: func(cmd *cobra.Command, args []string) (err error) { ProvisioningClient, err = connection.NewProvisioningClient(ctx) return }, }
View Source
var ProvisioningSubCommands []string = []string{
"create-instance",
"poll-create-instance", "delete-instance",
"poll-delete-instance", "get-instance",
}
View Source
var RegistryClient *gapic.RegistryClient
View Source
var RegistryServiceCmd = &cobra.Command{ Use: "registry", Short: "The Registry service allows teams to manage...", Long: "The Registry service allows teams to manage descriptions of APIs.", ValidArgs: RegistrySubCommands, PersistentPreRunE: func(cmd *cobra.Command, args []string) (err error) { RegistryClient, err = connection.NewRegistryClient(ctx) return }, }
View Source
var RegistrySubCommands []string = []string{
"list-apis",
"get-api",
"create-api",
"update-api",
"delete-api",
"list-api-versions",
"get-api-version",
"create-api-version",
"update-api-version",
"delete-api-version",
"list-api-specs",
"get-api-spec",
"get-api-spec-contents",
"create-api-spec",
"update-api-spec",
"delete-api-spec",
"tag-api-spec-revision",
"list-api-spec-revisions",
"rollback-api-spec",
"delete-api-spec-revision",
"list-api-deployments",
"get-api-deployment",
"create-api-deployment",
"update-api-deployment",
"delete-api-deployment",
"tag-api-deployment-revision",
"list-api-deployment-revisions",
"rollback-api-deployment",
"delete-api-deployment-revision",
"list-artifacts",
"get-artifact",
"get-artifact-contents",
"create-artifact",
"replace-artifact",
"delete-artifact",
}
View Source
var ReplaceArtifactCmd = &cobra.Command{ Use: "replace-artifact", Short: "ReplaceArtifact can be used to replace a...", Long: "ReplaceArtifact can be used to replace a specified artifact.", PreRun: func(cmd *cobra.Command, args []string) { if ReplaceArtifactFromFile == "" { } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if ReplaceArtifactFromFile != "" { in, err = os.Open(ReplaceArtifactFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &ReplaceArtifactInput) if err != nil { return err } } if len(ReplaceArtifactInputArtifactLabels) > 0 { ReplaceArtifactInput.Artifact.Labels = make(map[string]string) } for _, item := range ReplaceArtifactInputArtifactLabels { split := strings.Split(item, "=") if len(split) < 2 { err = fmt.Errorf("Invalid map item: %q", item) return } ReplaceArtifactInput.Artifact.Labels[split[0]] = split[1] } if len(ReplaceArtifactInputArtifactAnnotations) > 0 { ReplaceArtifactInput.Artifact.Annotations = make(map[string]string) } for _, item := range ReplaceArtifactInputArtifactAnnotations { split := strings.Split(item, "=") if len(split) < 2 { err = fmt.Errorf("Invalid map item: %q", item) return } ReplaceArtifactInput.Artifact.Annotations[split[0]] = split[1] } if Verbose { printVerboseInput("Registry", "ReplaceArtifact", &ReplaceArtifactInput) } resp, err := RegistryClient.ReplaceArtifact(ctx, &ReplaceArtifactInput) if err != nil { return err } if Verbose { fmt.Print("Output: ") } printMessage(resp) return err }, }
View Source
var ReplaceArtifactFromFile string
View Source
var ReplaceArtifactInput rpcpb.ReplaceArtifactRequest
View Source
var ReplaceArtifactInputArtifactAnnotations []string
View Source
var ReplaceArtifactInputArtifactLabels []string
View Source
var RollbackApiDeploymentCmd = &cobra.Command{ Use: "rollback-api-deployment", Short: "RollbackApiDeployment sets the current revision...", Long: "RollbackApiDeployment sets the current revision to a specified prior revision. Note that this creates a new revision with a new revision ID.", PreRun: func(cmd *cobra.Command, args []string) { if RollbackApiDeploymentFromFile == "" { cmd.MarkFlagRequired("name") cmd.MarkFlagRequired("revision_id") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if RollbackApiDeploymentFromFile != "" { in, err = os.Open(RollbackApiDeploymentFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &RollbackApiDeploymentInput) if err != nil { return err } } if Verbose { printVerboseInput("Registry", "RollbackApiDeployment", &RollbackApiDeploymentInput) } resp, err := RegistryClient.RollbackApiDeployment(ctx, &RollbackApiDeploymentInput) if err != nil { return err } if Verbose { fmt.Print("Output: ") } printMessage(resp) return err }, }
View Source
var RollbackApiDeploymentFromFile string
View Source
var RollbackApiDeploymentInput rpcpb.RollbackApiDeploymentRequest
View Source
var RollbackApiSpecCmd = &cobra.Command{ Use: "rollback-api-spec", Short: "RollbackApiSpec sets the current revision to a...", Long: "RollbackApiSpec sets the current revision to a specified prior revision. Note that this creates a new revision with a new revision ID.", PreRun: func(cmd *cobra.Command, args []string) { if RollbackApiSpecFromFile == "" { cmd.MarkFlagRequired("name") cmd.MarkFlagRequired("revision_id") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if RollbackApiSpecFromFile != "" { in, err = os.Open(RollbackApiSpecFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &RollbackApiSpecInput) if err != nil { return err } } if Verbose { printVerboseInput("Registry", "RollbackApiSpec", &RollbackApiSpecInput) } resp, err := RegistryClient.RollbackApiSpec(ctx, &RollbackApiSpecInput) if err != nil { return err } if Verbose { fmt.Print("Output: ") } printMessage(resp) return err }, }
View Source
var RollbackApiSpecFromFile string
View Source
var RollbackApiSpecInput rpcpb.RollbackApiSpecRequest
View Source
var TagApiDeploymentRevisionCmd = &cobra.Command{ Use: "tag-api-deployment-revision", Short: "TagApiDeploymentRevision adds a tag to a...", Long: "TagApiDeploymentRevision adds a tag to a specified revision of a deployment.", PreRun: func(cmd *cobra.Command, args []string) { if TagApiDeploymentRevisionFromFile == "" { cmd.MarkFlagRequired("name") cmd.MarkFlagRequired("tag") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if TagApiDeploymentRevisionFromFile != "" { in, err = os.Open(TagApiDeploymentRevisionFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &TagApiDeploymentRevisionInput) if err != nil { return err } } if Verbose { printVerboseInput("Registry", "TagApiDeploymentRevision", &TagApiDeploymentRevisionInput) } resp, err := RegistryClient.TagApiDeploymentRevision(ctx, &TagApiDeploymentRevisionInput) if err != nil { return err } if Verbose { fmt.Print("Output: ") } printMessage(resp) return err }, }
View Source
var TagApiDeploymentRevisionFromFile string
View Source
var TagApiDeploymentRevisionInput rpcpb.TagApiDeploymentRevisionRequest
View Source
var TagApiSpecRevisionCmd = &cobra.Command{ Use: "tag-api-spec-revision", Short: "TagApiSpecRevision adds a tag to a specified...", Long: "TagApiSpecRevision adds a tag to a specified revision of a spec.", PreRun: func(cmd *cobra.Command, args []string) { if TagApiSpecRevisionFromFile == "" { cmd.MarkFlagRequired("name") cmd.MarkFlagRequired("tag") } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if TagApiSpecRevisionFromFile != "" { in, err = os.Open(TagApiSpecRevisionFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &TagApiSpecRevisionInput) if err != nil { return err } } if Verbose { printVerboseInput("Registry", "TagApiSpecRevision", &TagApiSpecRevisionInput) } resp, err := RegistryClient.TagApiSpecRevision(ctx, &TagApiSpecRevisionInput) if err != nil { return err } if Verbose { fmt.Print("Output: ") } printMessage(resp) return err }, }
View Source
var TagApiSpecRevisionFromFile string
View Source
var TagApiSpecRevisionInput rpcpb.TagApiSpecRevisionRequest
View Source
var UpdateApiCmd = &cobra.Command{ Use: "update-api", Short: "UpdateApi can be used to modify a specified API.", Long: "UpdateApi can be used to modify a specified API.", PreRun: func(cmd *cobra.Command, args []string) { if UpdateApiFromFile == "" { } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if UpdateApiFromFile != "" { in, err = os.Open(UpdateApiFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &UpdateApiInput) if err != nil { return err } } if len(UpdateApiInputApiLabels) > 0 { UpdateApiInput.Api.Labels = make(map[string]string) } for _, item := range UpdateApiInputApiLabels { split := strings.Split(item, "=") if len(split) < 2 { err = fmt.Errorf("Invalid map item: %q", item) return } UpdateApiInput.Api.Labels[split[0]] = split[1] } if len(UpdateApiInputApiAnnotations) > 0 { UpdateApiInput.Api.Annotations = make(map[string]string) } for _, item := range UpdateApiInputApiAnnotations { split := strings.Split(item, "=") if len(split) < 2 { err = fmt.Errorf("Invalid map item: %q", item) return } UpdateApiInput.Api.Annotations[split[0]] = split[1] } if Verbose { printVerboseInput("Registry", "UpdateApi", &UpdateApiInput) } resp, err := RegistryClient.UpdateApi(ctx, &UpdateApiInput) if err != nil { return err } if Verbose { fmt.Print("Output: ") } printMessage(resp) return err }, }
View Source
var UpdateApiDeploymentCmd = &cobra.Command{ Use: "update-api-deployment", Short: "UpdateApiDeployment can be used to modify a...", Long: "UpdateApiDeployment can be used to modify a specified deployment.", PreRun: func(cmd *cobra.Command, args []string) { if UpdateApiDeploymentFromFile == "" { } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if UpdateApiDeploymentFromFile != "" { in, err = os.Open(UpdateApiDeploymentFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &UpdateApiDeploymentInput) if err != nil { return err } } if len(UpdateApiDeploymentInputApiDeploymentLabels) > 0 { UpdateApiDeploymentInput.ApiDeployment.Labels = make(map[string]string) } for _, item := range UpdateApiDeploymentInputApiDeploymentLabels { split := strings.Split(item, "=") if len(split) < 2 { err = fmt.Errorf("Invalid map item: %q", item) return } UpdateApiDeploymentInput.ApiDeployment.Labels[split[0]] = split[1] } if len(UpdateApiDeploymentInputApiDeploymentAnnotations) > 0 { UpdateApiDeploymentInput.ApiDeployment.Annotations = make(map[string]string) } for _, item := range UpdateApiDeploymentInputApiDeploymentAnnotations { split := strings.Split(item, "=") if len(split) < 2 { err = fmt.Errorf("Invalid map item: %q", item) return } UpdateApiDeploymentInput.ApiDeployment.Annotations[split[0]] = split[1] } if Verbose { printVerboseInput("Registry", "UpdateApiDeployment", &UpdateApiDeploymentInput) } resp, err := RegistryClient.UpdateApiDeployment(ctx, &UpdateApiDeploymentInput) if err != nil { return err } if Verbose { fmt.Print("Output: ") } printMessage(resp) return err }, }
View Source
var UpdateApiDeploymentFromFile string
View Source
var UpdateApiDeploymentInput rpcpb.UpdateApiDeploymentRequest
View Source
var UpdateApiDeploymentInputApiDeploymentAnnotations []string
View Source
var UpdateApiDeploymentInputApiDeploymentLabels []string
View Source
var UpdateApiFromFile string
View Source
var UpdateApiInput rpcpb.UpdateApiRequest
View Source
var UpdateApiInputApiAnnotations []string
View Source
var UpdateApiInputApiLabels []string
View Source
var UpdateApiSpecCmd = &cobra.Command{ Use: "update-api-spec", Short: "UpdateApiSpec can be used to modify a specified...", Long: "UpdateApiSpec can be used to modify a specified spec.", PreRun: func(cmd *cobra.Command, args []string) { if UpdateApiSpecFromFile == "" { } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if UpdateApiSpecFromFile != "" { in, err = os.Open(UpdateApiSpecFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &UpdateApiSpecInput) if err != nil { return err } } if len(UpdateApiSpecInputApiSpecLabels) > 0 { UpdateApiSpecInput.ApiSpec.Labels = make(map[string]string) } for _, item := range UpdateApiSpecInputApiSpecLabels { split := strings.Split(item, "=") if len(split) < 2 { err = fmt.Errorf("Invalid map item: %q", item) return } UpdateApiSpecInput.ApiSpec.Labels[split[0]] = split[1] } if len(UpdateApiSpecInputApiSpecAnnotations) > 0 { UpdateApiSpecInput.ApiSpec.Annotations = make(map[string]string) } for _, item := range UpdateApiSpecInputApiSpecAnnotations { split := strings.Split(item, "=") if len(split) < 2 { err = fmt.Errorf("Invalid map item: %q", item) return } UpdateApiSpecInput.ApiSpec.Annotations[split[0]] = split[1] } if Verbose { printVerboseInput("Registry", "UpdateApiSpec", &UpdateApiSpecInput) } resp, err := RegistryClient.UpdateApiSpec(ctx, &UpdateApiSpecInput) if err != nil { return err } if Verbose { fmt.Print("Output: ") } printMessage(resp) return err }, }
View Source
var UpdateApiSpecFromFile string
View Source
var UpdateApiSpecInput rpcpb.UpdateApiSpecRequest
View Source
var UpdateApiSpecInputApiSpecAnnotations []string
View Source
var UpdateApiSpecInputApiSpecLabels []string
View Source
var UpdateApiVersionCmd = &cobra.Command{ Use: "update-api-version", Short: "UpdateApiVersion can be used to modify a...", Long: "UpdateApiVersion can be used to modify a specified version.", PreRun: func(cmd *cobra.Command, args []string) { if UpdateApiVersionFromFile == "" { } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if UpdateApiVersionFromFile != "" { in, err = os.Open(UpdateApiVersionFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &UpdateApiVersionInput) if err != nil { return err } } if len(UpdateApiVersionInputApiVersionLabels) > 0 { UpdateApiVersionInput.ApiVersion.Labels = make(map[string]string) } for _, item := range UpdateApiVersionInputApiVersionLabels { split := strings.Split(item, "=") if len(split) < 2 { err = fmt.Errorf("Invalid map item: %q", item) return } UpdateApiVersionInput.ApiVersion.Labels[split[0]] = split[1] } if len(UpdateApiVersionInputApiVersionAnnotations) > 0 { UpdateApiVersionInput.ApiVersion.Annotations = make(map[string]string) } for _, item := range UpdateApiVersionInputApiVersionAnnotations { split := strings.Split(item, "=") if len(split) < 2 { err = fmt.Errorf("Invalid map item: %q", item) return } UpdateApiVersionInput.ApiVersion.Annotations[split[0]] = split[1] } if Verbose { printVerboseInput("Registry", "UpdateApiVersion", &UpdateApiVersionInput) } resp, err := RegistryClient.UpdateApiVersion(ctx, &UpdateApiVersionInput) if err != nil { return err } if Verbose { fmt.Print("Output: ") } printMessage(resp) return err }, }
View Source
var UpdateApiVersionFromFile string
View Source
var UpdateApiVersionInput rpcpb.UpdateApiVersionRequest
View Source
var UpdateApiVersionInputApiVersionAnnotations []string
View Source
var UpdateApiVersionInputApiVersionLabels []string
View Source
var UpdateProjectCmd = &cobra.Command{ Use: "update-project", Short: "UpdateProject can be used to modify a specified...", Long: "UpdateProject can be used to modify a specified project.", PreRun: func(cmd *cobra.Command, args []string) { if UpdateProjectFromFile == "" { } }, RunE: func(cmd *cobra.Command, args []string) (err error) { in := os.Stdin if UpdateProjectFromFile != "" { in, err = os.Open(UpdateProjectFromFile) if err != nil { return err } defer in.Close() err = jsonpb.Unmarshal(in, &UpdateProjectInput) if err != nil { return err } } if Verbose { printVerboseInput("Admin", "UpdateProject", &UpdateProjectInput) } resp, err := AdminClient.UpdateProject(ctx, &UpdateProjectInput) if err != nil { return err } if Verbose { fmt.Print("Output: ") } printMessage(resp) return err }, }
View Source
var UpdateProjectFromFile string
View Source
var UpdateProjectInput rpcpb.UpdateProjectRequest
View Source
var Verbose, OutputJSON bool
Functions ¶
Types ¶
This section is empty.
Source Files ¶
- admin_service.go
- apg.go
- completion.go
- create-api-deployment.go
- create-api-spec.go
- create-api-version.go
- create-api.go
- create-artifact.go
- create-instance.go
- create-project.go
- delete-api-deployment-revision.go
- delete-api-deployment.go
- delete-api-spec-revision.go
- delete-api-spec.go
- delete-api-version.go
- delete-api.go
- delete-artifact.go
- delete-instance.go
- delete-project.go
- get-api-deployment.go
- get-api-spec-contents.go
- get-api-spec.go
- get-api-version.go
- get-api.go
- get-artifact-contents.go
- get-artifact.go
- get-instance.go
- get-project.go
- get-status.go
- get-storage.go
- list-api-deployment-revisions.go
- list-api-deployments.go
- list-api-spec-revisions.go
- list-api-specs.go
- list-api-versions.go
- list-apis.go
- list-artifacts.go
- list-projects.go
- migrate-database.go
- provisioning_service.go
- registry_service.go
- replace-artifact.go
- rollback-api-deployment.go
- rollback-api-spec.go
- tag-api-deployment-revision.go
- tag-api-spec-revision.go
- update-api-deployment.go
- update-api-spec.go
- update-api-version.go
- update-api.go
- update-project.go
Click to show internal directories.
Click to hide internal directories.