rancher/types
1
0
Fork 0
mirror of https://github.com/rancher/types.git synced 2025-05-07 22:56:19 +00:00
Code Issues Releases Wiki Activity

Merge pull request from shanewxy/api-redeploy

Browse Source 
Added redeploy to workload api actions
This commit is contained in:
Dan Ramich 2020-02-11 15:40:34 -07:00 committed by GitHub
commit 46dbf16cb7
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
8 changed files with 70 additions and 4 deletions

25
apis/project.cattle.io/v3/schema/schema.go
View File

@ -123,8 +123,9 @@ func workloadTypes(schemas *types.Schemas) *types.Schemas {
"rollback": {
Input: "rollbackRevision",
},
"pause": {},
"resume": {},
"pause": {},
"resume": {},
"redeploy": {},
}
schema.MustCustomizeField("name", func(field types.Field) types.Field {
field.Type = "dnsLabelRestricted"
@ -182,6 +183,9 @@ func statefulSetTypes(schemas *types.Schemas) *types.Schemas {
MustImport(&Version, k8sappv1.StatefulSetSpec{}, statefulSetConfigOverride{}).
MustImportAndCustomize(&Version, k8sappv1.StatefulSet{}, func(schema *types.Schema) {
schema.BaseType = "workload"
schema.ResourceActions = map[string]types.Action{
"redeploy": {},
}
schema.MustCustomizeField("name", func(field types.Field) types.Field {
field.Type = "dnsLabelRestricted"
field.Nullable = false
@ -218,6 +222,9 @@ func replicaSetTypes(schemas *types.Schemas) *types.Schemas {
MustImport(&Version, appsv1.ReplicaSetSpec{}, replicaSetConfigOverride{}).
MustImportAndCustomize(&Version, appsv1.ReplicaSet{}, func(schema *types.Schema) {
schema.BaseType = "workload"
schema.ResourceActions = map[string]types.Action{
"redeploy": {},
}
schema.MustCustomizeField("name", func(field types.Field) types.Field {
field.Type = "dnsLabelRestricted"
field.Nullable = false
@ -256,6 +263,9 @@ func replicationControllerTypes(schemas *types.Schemas) *types.Schemas {
schema.BaseType = "workload"
schema.CollectionMethods = []string{http.MethodGet}
schema.ResourceMethods = []string{http.MethodGet}
schema.ResourceActions = map[string]types.Action{
"redeploy": {},
}
schema.MustCustomizeField("name", func(field types.Field) types.Field {
field.Type = "dnsLabelRestricted"
field.Nullable = false
@ -302,6 +312,9 @@ func daemonSetTypes(schemas *types.Schemas) *types.Schemas {
MustImport(&Version, k8sappv1.DaemonSetSpec{}, daemonSetOverride{}).
MustImportAndCustomize(&Version, k8sappv1.DaemonSet{}, func(schema *types.Schema) {
schema.BaseType = "workload"
schema.ResourceActions = map[string]types.Action{
"redeploy": {},
}
schema.MustCustomizeField("name", func(field types.Field) types.Field {
field.Type = "dnsLabelRestricted"
field.Nullable = false
@ -408,6 +421,9 @@ func cronJobTypes(schemas *types.Schemas) *types.Schemas {
MustImport(&Version, batchv1beta1.JobTemplateSpec{}).
MustImportAndCustomize(&Version, batchv1beta1.CronJob{}, func(schema *types.Schema) {
schema.BaseType = "workload"
schema.ResourceActions = map[string]types.Action{
"redeploy": {},
}
schema.MustCustomizeField("name", func(field types.Field) types.Field {
field.Type = "dnsLabelRestricted"
field.Nullable = false
@ -469,8 +485,9 @@ func deploymentTypes(schemas *types.Schemas) *types.Schemas {
"rollback": {
Input: "deploymentRollbackInput",
},
"pause": {},
"resume": {},
"pause": {},
"resume": {},
"redeploy": {},
}
schema.MustCustomizeField("name", func(field types.Field) types.Field {
field.Type = "dnsLabelRestricted"

7
client/project/v3/zz_generated_cron_job.go
View File

@ -138,6 +138,8 @@ type CronJobOperations interface {
Replace(existing *CronJob) (*CronJob, error)
ByID(id string) (*CronJob, error)
Delete(container *CronJob) error
ActionRedeploy(resource *CronJob) error
}
func newCronJobClient(apiClient *Client) *CronJobClient {
@ -208,3 +210,8 @@ func (c *CronJobClient) ByID(id string) (*CronJob, error) {
func (c *CronJobClient) Delete(container *CronJob) error {
return c.apiClient.Ops.DoResourceDelete(CronJobType, &container.Resource)
}
func (c *CronJobClient) ActionRedeploy(resource *CronJob) error {
err := c.apiClient.Ops.DoAction(CronJobType, "redeploy", &resource.Resource, nil, nil)
return err
}

7
client/project/v3/zz_generated_daemon_set.go
View File

@ -136,6 +136,8 @@ type DaemonSetOperations interface {
Replace(existing *DaemonSet) (*DaemonSet, error)
ByID(id string) (*DaemonSet, error)
Delete(container *DaemonSet) error
ActionRedeploy(resource *DaemonSet) error
}
func newDaemonSetClient(apiClient *Client) *DaemonSetClient {
@ -206,3 +208,8 @@ func (c *DaemonSetClient) ByID(id string) (*DaemonSet, error) {
func (c *DaemonSetClient) Delete(container *DaemonSet) error {
return c.apiClient.Ops.DoResourceDelete(DaemonSetType, &container.Resource)
}
func (c *DaemonSetClient) ActionRedeploy(resource *DaemonSet) error {
err := c.apiClient.Ops.DoAction(DaemonSetType, "redeploy", &resource.Resource, nil, nil)
return err
}

7
client/project/v3/zz_generated_deployment.go
View File

@ -143,6 +143,8 @@ type DeploymentOperations interface {
ActionPause(resource *Deployment) error
ActionRedeploy(resource *Deployment) error
ActionResume(resource *Deployment) error
ActionRollback(resource *Deployment, input *DeploymentRollbackInput) error
@ -222,6 +224,11 @@ func (c *DeploymentClient) ActionPause(resource *Deployment) error {
return err
}
func (c *DeploymentClient) ActionRedeploy(resource *Deployment) error {
err := c.apiClient.Ops.DoAction(DeploymentType, "redeploy", &resource.Resource, nil, nil)
return err
}
func (c *DeploymentClient) ActionResume(resource *Deployment) error {
err := c.apiClient.Ops.DoAction(DeploymentType, "resume", &resource.Resource, nil, nil)
return err

7
client/project/v3/zz_generated_replica_set.go
View File

@ -138,6 +138,8 @@ type ReplicaSetOperations interface {
Replace(existing *ReplicaSet) (*ReplicaSet, error)
ByID(id string) (*ReplicaSet, error)
Delete(container *ReplicaSet) error
ActionRedeploy(resource *ReplicaSet) error
}
func newReplicaSetClient(apiClient *Client) *ReplicaSetClient {
@ -208,3 +210,8 @@ func (c *ReplicaSetClient) ByID(id string) (*ReplicaSet, error) {
func (c *ReplicaSetClient) Delete(container *ReplicaSet) error {
return c.apiClient.Ops.DoResourceDelete(ReplicaSetType, &container.Resource)
}
func (c *ReplicaSetClient) ActionRedeploy(resource *ReplicaSet) error {
err := c.apiClient.Ops.DoAction(ReplicaSetType, "redeploy", &resource.Resource, nil, nil)
return err
}

7
client/project/v3/zz_generated_replication_controller.go
View File

@ -138,6 +138,8 @@ type ReplicationControllerOperations interface {
Replace(existing *ReplicationController) (*ReplicationController, error)
ByID(id string) (*ReplicationController, error)
Delete(container *ReplicationController) error
ActionRedeploy(resource *ReplicationController) error
}
func newReplicationControllerClient(apiClient *Client) *ReplicationControllerClient {
@ -208,3 +210,8 @@ func (c *ReplicationControllerClient) ByID(id string) (*ReplicationController, e
func (c *ReplicationControllerClient) Delete(container *ReplicationController) error {
return c.apiClient.Ops.DoResourceDelete(ReplicationControllerType, &container.Resource)
}
func (c *ReplicationControllerClient) ActionRedeploy(resource *ReplicationController) error {
err := c.apiClient.Ops.DoAction(ReplicationControllerType, "redeploy", &resource.Resource, nil, nil)
return err
}

7
client/project/v3/zz_generated_stateful_set.go
View File

@ -138,6 +138,8 @@ type StatefulSetOperations interface {
Replace(existing *StatefulSet) (*StatefulSet, error)
ByID(id string) (*StatefulSet, error)
Delete(container *StatefulSet) error
ActionRedeploy(resource *StatefulSet) error
}
func newStatefulSetClient(apiClient *Client) *StatefulSetClient {
@ -208,3 +210,8 @@ func (c *StatefulSetClient) ByID(id string) (*StatefulSet, error) {
func (c *StatefulSetClient) Delete(container *StatefulSet) error {
return c.apiClient.Ops.DoResourceDelete(StatefulSetType, &container.Resource)
}
func (c *StatefulSetClient) ActionRedeploy(resource *StatefulSet) error {
err := c.apiClient.Ops.DoAction(StatefulSetType, "redeploy", &resource.Resource, nil, nil)
return err
}

7
client/project/v3/zz_generated_workload.go
View File

@ -169,6 +169,8 @@ type WorkloadOperations interface {
ActionPause(resource *Workload) error
ActionRedeploy(resource *Workload) error
ActionResume(resource *Workload) error
ActionRollback(resource *Workload, input *RollbackRevision) error
@ -248,6 +250,11 @@ func (c *WorkloadClient) ActionPause(resource *Workload) error {
return err
}
func (c *WorkloadClient) ActionRedeploy(resource *Workload) error {
err := c.apiClient.Ops.DoAction(WorkloadType, "redeploy", &resource.Resource, nil, nil)
return err
}
func (c *WorkloadClient) ActionResume(resource *Workload) error {
err := c.apiClient.Ops.DoAction(WorkloadType, "resume", &resource.Resource, nil, nil)
return err