pkg_updates

package
v0.1.57 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 23, 2024 License: GPL-2.0 Imports: 23 Imported by: 0

README

SLES Service Pack Migration and Package Update Engine - jobchecker

This is a simple workflow engine for bulk service pack migration and package update engine for SUSE Linux Enterprise Server (SLES) with SUSE Manager written in Go.

Systems from the given groups could be updated and migrated to the next service pack.

Reason choosing Go over Python is the concurrency capabilities and stabilities I experienced. Additionally Go is a compiled language and the binary is statically linked. This makes it easy to deploy the binary to any Linux systems.

Pre-requisites:

  • SUSE Manager / Uyuni v.4.3.6 or higher
  • Salt-master running on SLES 15 or higher
  • SMTP (e.g. postfix) where jobchecker is running must be configured to allow sending emails to the recipients
  • Port 12345 for local or remote access should be open on the firewall
  • Jobchecker must run as local root user
  • The jobchecker binary can be placed in $PATH directory

Concept:

The one binary jobchecker program is listening for HTTP requests. The program calls xmlrpc api of SUSE Manager. On the other hand side jobchecker uses salt tornado rest api to execute salt states, runners and execution modules.

Jobchecker uses golang gorm to store system workflow stage information in SQLite database file. The SQLite database file will be created if it does not exist. The SQLite database file will not be deleted if the workflow is finished. The jobchecker can be restarted and the process will re-read the db file and continue the workflow.

The name jobchecker was originally used at the time when I started it for only checking update and reboot jobs periodically. Over time I added more features to it. Now it is a bulk migration engine but can also be used for mass update and patching workflows.

The workflow at a glance:

  • patching/updates and service pack migration for given groups in SUSE Manager.
  • email notification with system workflow information will be sent every 10 minutes.
  • salt-run presence check to identify really online salt minions using salt-run manage.status
  • salt grains check if btrfs root disk has enough free space. (special customer requirement)
  • exclude systems by predefined no_patch grains key. (special customer requirement)
  • run service pack pre-migration salt states to prepare systems for updates.
  • assign predefined software channels to systems to apply latest updates prior to service pack migration.
  • update systems with latest updates of newly assigned software channels.
  • reboot systems after update.
  • run package refresh job.
  • run service pack migration dry-run.
  • run service pack migration, using ident and base channel with optional channels.
  • schedule system reboot.
  • run salt state to set certain values e.g. patch level, service pack level, etc. (customer requirement, for cmdb etc.)
  • run service pack post-migration salt states.

Disqualified systems will get a "note" message recorded under the system -> Notes in SUSE Manager so that the reason is also visible in SUMA UI.

During the workflow cycles admins can dump data from the DB file or via web browser e.g.

curl http://localhost:12345/pkg_update?filename=/srv/sumapatch/08112023_testgrp_t7udp.db | jq

Or access single system information e.g.

curl http://127.0.0.1:12345/pkg_update?filename=/srv/sumapatch/11112023_testgrp_t7udp.db&minion_name=pxesap02.bo2go.home' | jq

systemd service for jobchecker

Jobchecker runs as a systemd service. jobchecker.service

The suma-jobchecker runs non-stop. Upone received HTTP requests it will processes the requests in sub-routines concurrently. If no any job is in the queue then only health check is running every 10 seconds.

Inside the service file, you need to

  • change the path to the binary and the path to the config file.
  • change the Enrivonment variable SUMAKEY to your own key. This key is used to decrypt and encrypt the password value in the SUSE Manager configuration file.
  • change the path of templates to your own path. Examples: templates
  • change the interval to your own interval.

SUMA Configuration and Password encryption

The password is encrypted with the key (SUMAKEY) provided in the systemd service file. The key is used to decrypt the password value.

To encrypt the password, you can use the following command: https://github.com/bjin01/salt-sap-patching/blob/master/encrypt.py

python3.6 encrypt.py <YOUR-PASSWD>

Output:

Randomly generated key! Keep it safely!: 
taZk-X-MRuUSB-xYAzPys41Hi0X1iFDf0wBWynLTodw=

Save this encrypted password in your configuration file.
gAAAAABlGn1RxFaE9rRVJ.....InR0UE0TPl79yf5Dsv-MNM0Bw==

With the encrypted password and the key, you can create the configuration file. Example:

SUSE Manager configuration file:

cat /etc/salt/master.d/suma.conf 
suma_api:
  suma1.bo2go.home:
    username: 'admin'
    password: gAAAAABj_xzeu23IpzKM-mYOYO
    email_to:
      - bo.jin@example.com
    healthcheck_interval: 10
    healthcheck_email:
      - bo.jin@example.com

Run Jobchecker

In order to start the workflow which in turn is a HTTP POST Request sent to jobchecker a salt runner module was created. It takes a given configuration file as input parameter.

The runner module needs to be placed runners directory on salt master node. e.g. /srv/salt/_runners/get_spmigration_targets.py

salt-run start_spmigration.run config=/srv/salt/spmigration/spmigration_config.yaml

If jobchecker is not running on the same host as SUSE Manager then you need to specify the api_server parameter.

salt-run start_spmigration.run config=/srv/salt/spmigration/spmigration_config.yaml api_server='192.168.122.23'

Configuration file

The configuration file is a yaml file. Example: spmigration_config.yaml

# The configuration file for spmigration
groups:
- testgrp
minions_to_add:
- system1.example.com
- system2.example.com
sqlite_db: "/srv/sumapatch/07112023_testgrp_t7udp.db"
qualifying_only: false
log_level: info
timeout: 3
gather_job_timeout: 15
email_interval: 8
logfile: "/var/log/patching/sumapatching.log"
salt_master_address: 192.168.122.23
salt_api_port: 8000
salt_user: mysalt
salt_password: mytest
salt_diskspace_grains_key: btrfs:for_patching
salt_diskspace_grains_value: ok
salt_no_upgrade_exception_key: no_patch
salt_no_upgrade_exception_value: 'true'
salt_prep_state: orch.prepatch_states
salt_post_state: orch.postpatch_states
jobchecker_timeout: 0
jobchecker_emails:
- bo.jin@example.com
- bo.jin@example.com
t7user: t7udp
authentication_token: R2bfp223Qsk-pX970Jw8tyJUChT4-e2J8anZ4G4n4IM=
tracking_file_directory: "/var/log/sumapatch/"
patch_level: 2023-Q4
reboot_triage_timer: 20
workflow:
- assign_channels: 1
- package_updates: 2
- package_update_reboot: 3
- package_refresh: 4
- waiting: 5
- spmigration_dryrun: 6
- spmigration_run: 7
- spmigration_reboot: 8
- spmigration_package_refresh: 9
- post_migration: 10
assign_channels:
- assign_channel:
    current_base_channel: mytest-prd-sle-product-sles_sap15-sp4-pool-x86_64
    new_base_prefix: mytest-test-
- assign_channel:
    current_base_channel: mysle15sp3-prd-sle-product-sles15-sp3-pool-x86_64
    new_base_prefix: ''
products:
- product:
    ident: '1565,1576,1609,1592,1572,1616,1580,935,1633,1614'
    name: SUSE Linux Enterprise Server for SAP Applications 15 SP5 x86_64
    base_channel_label: sle-product-sles_sap15-sp5-pool-x86_64
    clm_project_label: mysap15sp5
    optionalChildChannels:
      - old_channel: rke2-sles15sp4
        new_channel: rke2-sles15sp5
- product:
    ident: '1396,1423,1431,1411,1415,935,1403,1438'
    name: SUSE Linux Enterprise Server 15 SP4 x86_64
    base_channel_label: sle-product-sles15-sp4-pool-x86_64
    clm_project_label:
    optionalChildChannels:
      - old_channel: rke2-sles15sp4
        new_channel: rke2-sles15sp5
      - old_channel: rke2-common-15sp4
        new_channel: rke2-common-15sp5

Now let's go through the configuration file.

groups

The groups parameter is a list of groups in SUSE Manager. The systems in these groups will be migrated to the next service pack.

minions_to_add

The minions_to_add parameter is a list of minions. The systems in this list will be added to the pkg_update workflow if admins want to start over for some systems which might failed in the previous workflow.

For example: Dring the first pkg_update workflow run some system's package update or spmigration jobs failed due to package installation dependency issues. Admins fixed the dependency issues manually and want to start the workflow for this systems from the beginning again while the main workflow (or first workflow) is still running.

The command for this is:

salt-run start_spmigration.add_minions config=/srv/salt/spmigration/spmigration_config.yaml

This salt runner module function add_minion will read-in the spmigration config yaml file and make another HTTP POST request to jobchecker to add the systems to the workflow.

Those new systems will be reset to the beginning. All online presence check, btrfs disk space check, no_patch exception check and pre-states will be executed as well. Systems which passed the checks will start with first workflow step.

sqlite_db

The sqlite_db parameter is a string value. This parameter is used to specify the sqlite database file path. The sqlite database file will be used to store the status of all systems of the given groups during the workflow. The sqlite database file will be created if it does not exist. The sqlite database file will not be deleted if the workflow is finished. The jobchecker can be restarted and the process will re-read the db file and continue the workflow based on the system Migration_Stage and Migration_Stage_Status values.

If you want to start a new workflow then you need to delete the sqlite database file or use a new db file name prior to start the workflow.

The sqlite db file should be placed in a directory and on a disk which provides good IO performance. If the underneath disk is slow then the DB transactions could failed due to slowness > 200ms for write. The errors will be shown in the logs.

qualifying_only

The qualifying_only parameter is a boolean value. If it is set to true then the workflow only checks if the systems have valid migration targets or not. Admins need to read the log file to see the result. If it is set to false then the workflow will continue to run the whole workflow.

log_level

The log_level parameter is a string value. This parameter is used to specify the log level. The log level can be debug, info, warning, error, critical.

timeout

The timeout parameter is an integer value. This parameter is used in the salt-run manage.status timeout= and gather_job_timeout= parameters. The timeout is in seconds. If number of systems is high and salt minion take more time to respond then one might consider to increase this value.

gather_job_timeout

The gather_job_timeout parameter is an integer value. This parameter is used in the salt-run manage.status gather_job_timeout= parameter. The timeout is in seconds. If number of systems is high and salt minion take more time to respond then one might consider to increase this value.

email_interval

The email_interval parameter is an integer value. This parameter is used to specify the email interval in minutes. The email interval is used to send email notification to the recipients. Default is 10 minutes. The email contains the system workflow information as well as any remarks.

logfile

The logfile parameter is a string value. This parameter is used to specify the log file path.

salt_master_address

The salt_master_address parameter is a string value. This parameter is used to specify the salt master address.

salt_api_port

The salt_api_port parameter is an integer value. This parameter is used to specify the salt api port.

salt_user

The salt_user parameter is a string value. This parameter is used to specify the salt user. The salt user is defined in the salt master configuration file. e.g.

external_auth:
  file:
    ^filename: /etc/salt/master.d/susemanager-users.txt
    ^hashtype: sha512
    admin:
      - .*
      - '@wheel'
      - '@runner'
      - '@jobs'
  sharedsecret:
    mysalt:
       - .*
       - '@wheel'
       - '@runner'
       - '@jobs'
salt_password

The password for the mysalt user is stored in a file called /etc/salt/master.d/sharedsecret.conf

sharedsecret: mytest
salt_diskspace_grains_key

The salt_diskspace_grains_key parameter is a string value. This parameter is used to specify the salt grains key name for the disk space check. The name will be used in the salt grains.get function.

salt_diskspace_grains_value

The salt_diskspace_grains_value parameter is a string value. This parameter is used to specify the salt grains value for the disk space check. The value will be used in the salt grains.get function. If the grains.get result key value match the pre-defined value then the system is qualified for the migration. A note will be recorded under the system -> Notes in SUSE Manager.

salt_no_upgrade_exception_key

The salt_no_upgrade_exception_key parameter is a string value. This parameter is used to specify the salt grains key name for the no_upgrade exception. The name will be used in the salt grains.get function. If the grains.get result key value match the pre-defined value then the system is not qualified for the migration. A note will be recorded under the system -> Notes in SUSE Manager.

salt_no_upgrade_exception_value

The salt_no_upgrade_exception_value parameter is a string value. This parameter is used to specify the salt grains value for the no_upgrade exception. The value will be used in the salt grains.get function. If the grains.get result key value match the pre-defined value then the system is not qualified for the migration. A note will be recorded under the system -> Notes in SUSE Manager.

salt_prep_state

The salt_prep_state parameter is a string value. This parameter is used to specify the salt state for the pre-migration tasks. The state will be executed via salt state.apply. Within the state one can define To-Do's that are needed to prepare the system. e.g. stop some heavy running processes, etc.

salt_post_state

The salt_post_state parameter is a string value. This parameter is used to specify the salt state for the post-migration tasks. The state will be executed via salt state.apply. Within the state one can define To-Do's that are needed to clean up the system. e.g. start some heavy running processes, etc.

jobchecker_timeout

The jobchecker_timeout parameter is an integer value. This parameter is used to specify the timeout for the jobchecker api call. The timeout is in minutes. This timeout will be used in the jobcheck loops for update and spmigration jobs. After timeout the workflow will continue with next steps. For systems which jobs are still pending the status will be recorded.

jobchecker_emails

The jobchecker_emails parameter is a list of email addresses. This parameter is used to specify the email addresses for the jobchecker api call. The email addresses will be used in the jobchecker api call. At beginning and after the workflow is finished the jobchecker will send an email to the email recipients.

t7user

This is a customer specific parameter to indicate which admin user is running the workflow. The value will be used in the tracking file.

authentication_token

The authentication_token parameter is a string value. This parameter is used to specify the authentication token for the jobchecker api call. The authentication token will be used in the jobchecker api call. The authentication token is used to authenticate the caller.

tracking_file_directory

The tracking_file_directory parameter is a string value. This parameter is used to specify the tracking file directory. The tracking file directory will be used to store the tracking file. The purpose of this tracking file is to allow admins to follow the status of the systems while workflow is running. This file will be rewritten by jobchecker.

patch_level

This is a customer specific parameter. The value of this parameter will be used in a built-in salt execution module to set the patch level of the system.

reboot_triage_timer

If scheduled reboot jobs remain in pending state this parameter defines how long after reboot_job_start the reboot triage will start. The reboot triage feature will check if the system is online or not. If the system is online then a salt event will be sent to salt-master which in turn will trigger the minion-start reactor.

Additionally, the reboot triage will also consider salt-master server cpu 5 minutes load average. If the load average is higher than 10 then the reboot triage will be skipped until next triage check cycle. This is to avoid high load on salt-master server.

workflow

The workflow parameter is a list of workflow steps. The workflow steps will be executed in the given order. The number indicates the order of each step. Spmigration_run and spmigration_dryrun will not be executed on systems which ident value is empty but the steps will be gone through but very quickly. The ident value is the product ident that SUSE Manager detects. The ident value can be obtained by a script I wrote.

The name of each workflow step is fix but the order can be changed. The steps can be reduced if not needed. e.g. if you don't want to run package refresh then you can remove the package_refresh step from the workflow.

The current workflow steps and order is a best practice to first update the systems and then if identified to run service pack migration.

https://github.com/bjin01/salt-sap-patching/blob/master/srv/salt/_runners/get_spmigration_targets.py

assign_channels
assign_channels:
- assign_channel:
    current_base_channel: mytest-prd-sle-product-sles_sap15-sp4-pool-x86_64
    new_base_prefix: mytest-test-

In this section admins can define the channels for the systems to assign to. The systems will be assigned to the channels if the current_base_channel matches the system base channel.

current_base_channel: must have the parent channel label of the original SUSE vendor channel. e.g. sle-product-sles15-sp4-pool-x86_64

The new_base_prefix can have the value e.g. "myclm-test-" myclm is the content lifecycle management project label. test is the environment label. This value will be prepended to the current_base_channel and all child channels. Be careful to not forget the dash at the end of the prefix.

If new_base_prefix is left empty then the original SUSE vendor parent and child channels will be assigned if the system not already has the channels.

Make sure all child channels the systems need are available under the new parent channel.

You can define multiple assign_channel sections to match systems with different base channels in the given groups.

The channels will be used to apply latest updates/patches before running service pack migration. It is recommended to update the system as much as possible before running service pack migration. If a system has not been patched for more than 3 months then the service pack migration might fail because certain bugs have been fixed in the latest patches.

products
products:
- product:
    ident: '1565,1576,1609,1592,1572,1616,1580,935,1633,1614'
    name: SUSE Linux Enterprise Server for SAP Applications 15 SP5 x86_64
    base_channel_label: sle-product-sles_sap15-sp5-pool-x86_64
    clm_project_label: mysap15sp5
    optionalChildChannels:
      - old_channel: rke2-sles15sp4
        new_channel: rke2-sles15sp5

In this section admins can define the products (service packs) for the systems to migrate to. The systems will be migrated to the product if the given ident matches the system product ident that SUSE Manager detects.

The ident value holds IDs that match to the varios products that each system has. The ident value of every system within SUSE Manager can be obtained by a script I wrote.

https://github.com/bjin01/salt-sap-patching/blob/master/srv/salt/_runners/get_spmigration_targets.py

    salt-run get_spmigration_targets.list_targets groups="a_group1 testgrp"

The output will be ident values and products names that will be needed in order to define the products section in the configuration file.

- ident: [1563,1609,1602,1592,1572,1584,1580,935], friendly: [base: SUSE Linux Enterprise Server 15 SP5 x86_64, addon: SUSE Linux Enterprise Live Patching 15 SP5 x86_64, Public Cloud Module 15 SP5 x86_64, Web and Scripting Module 15 SP5 x86_64, Basesystem Module 15 SP5 x86_64, Containers Module 15 SP5 x86_64, Server Applications Module 15 SP5 x86_64, SUSE Manager Client Tools for SLE 15 x86_64]
- ident: [1563,1609,1602,1592,1572,1584,1580,935,1633], friendly: [base: SUSE Linux Enterprise Server 15 SP5 x86_64, addon: SUSE Linux Enterprise Live Patching 15 SP5 x86_64, Public Cloud Module 15 SP5 x86_64, Web and Scripting Module 15 SP5 x86_64, Basesystem Module 15 SP5 x86_64, Containers Module 15 SP5 x86_64, Server Applications Module 15 SP5 x86_64, SUSE Manager Client Tools for SLE 15 x86_64, Python 3 Module 15 SP5 x86_64]

The ident value in the configuration file does not need the [] brackets. The ident value is a string value.

The name value is a string value. The name value is the base product name.

The base_channel_label value is a string value. The base channel label is the parent channel label of the original SUSE vendor channel. e.g. sle-product-sles15-sp4-pool-x86_64

The clm_project_label value is a string value. This value is the content lifecycle management project label. This value will be prepended to the environment label and base_channel_label including all child channels.

If the clm_project_label is left empty then the original SUSE vendor parent and child channels will be assigned if the system not already has the channels.

The optionalChildChannels value is a list of key value pairs. The key "old_channel" holds the value of system's current optional child channel and the key "new_channel" holds the optional channel label of the new optional channale when assign channels for service pack migration. The child channels will be assigned to the systems. Make sure all child channels the systems need are available under the new parent channel. We don't check if the channel labels exist under the new parent channel. If the channels do not exist then spmigration_run and spmigration_dryrun job scheduling will fail.

Email notification

The email notification is a feature that sends emails to the recipients every 10 minutes within workflow deadline. The email contains the system's workflow steps information as well as any remarks, if system is online or not etc.

The email content is generated by a template. The template is located in the templates directory. The directory is specified in the jobchecker systemd service file.

List of useful commands

To get the migration target ident:

salt-run get_spmigration_targets.list_targets target_system=minion_name

To get unique migration target ident for all systems in a suma group:

salt-run get_spmigration_targets.list_targets groups="spmigration_test"
-------------------------------------------------------------------------

It is good to delete squid cache before starting spmigration:
salt -N sumaproxy state.apply squid.delete_cache

-------------------------------------------------------------------------

To start spmigration and updates run:

salt-run start_spmigration.run config=spmigration_config.yaml
-------------------------------------------------------------------------

To add minions to pkg_updates run:

salt-run start_spmigration.add_minions config=spmigration_config.yaml

-------------------------------------------------------------------------

To create single btrfs snapshot for a group of systems (suma)
salt-run btrfs_snapshot.create_single groups="testgrp"

-------------------------------------------------------------------------

Configuration file:
/srv/salt/base/spmigration/spmigration_config.yaml

if this parameter is set true then only target ident validation is run. 
qualifying_only: true

-------------------------------------------------------------------------

Run salt-run module post_patching.report to get the patching report in csv format.

salt-run post_patching.report file=/var/log/sumapatch/all_a_group1_minions.yaml presence_check=True

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Add_Note 

func Add_Note(sessionkey *auth.SumaSessionKey, sid int, subject string, note string) error

func Assign_Channels 

func Assign_Channels(sessionkey *auth.SumaSessionKey, groupsdata *Update_Groups, db *gorm.DB, wf []Workflow_Step, minion_list []Minion_Data, stage string)

func CPU_Load added in v0.1.54 

func CPU_Load() int

func Check_Jobs 

func Check_Jobs(ctx context.Context, groupsdata *Update_Groups, sessionkey *auth.SumaSessionKey, health *bool, db *gorm.DB, deadline *time.Time)

func Check_System_In_Jobs 

func Check_System_In_Jobs(sessionkey *auth.SumaSessionKey, jobid_pkg_update int, minion Minion_Data, groupsdata *Update_Groups) (string, error)

func Contains 

func Contains(elems []string, v string) bool

func Convert_String_IntSlices 

func Convert_String_IntSlices(mystring string) []int

func Convert_String_to_maps 

func Convert_String_to_maps(mystring string) map[string]string

func Convert_to_ISO8601_DateTime 

func Convert_to_ISO8601_DateTime(date time.Time) string

func Delete_Notes 

func Delete_Notes(sessionkey *auth.SumaSessionKey, sid int) error

func Find_MigrationTarget_New 

func Find_MigrationTarget_New(sessionkey *auth.SumaSessionKey, minionid int, UserData *Update_Groups) (ident string, migrate_base_channel string)

This func is for finding the migration target for each minion at the beginning of the migration process. If no proper migration target is found the minion will be excluded from further processing.

func Find_Next_Stage 

func Find_Next_Stage(wf []Workflow_Step, minion Minion_Data) string

func Get_Clm_Data 

func Get_Clm_Data(sessionkey *auth.SumaSessionKey, UserData *Update_Groups, db *gorm.DB)

func Get_Minions 

func Get_Minions(sessionkey *auth.SumaSessionKey, groupsdata *Update_Groups, db *gorm.DB) error

func Get_SID 

func Get_SID(sessionkey *auth.SumaSessionKey, system_name string) int

func Get_salt_online_Minions_in_Group_New 

func Get_salt_online_Minions_in_Group_New(sessionkey *auth.SumaSessionKey, minion_list []string, groupsdata *Update_Groups) []string

func ListMigrationTarget 

func ListMigrationTarget(sessionkey *auth.SumaSessionKey, UserData *Update_Groups, db *gorm.DB, wf []Workflow_Step, minion_list []Minion_Data, stage string)

func List_Project_Environments 

func List_Project_Environments(sessionkey *auth.SumaSessionKey, db *gorm.DB, proj_label string)

func Match_Job 

func Match_Job(sessionkey *auth.SumaSessionKey, minion Minion_Data, groupsdata *Update_Groups) (string, error)

func Match_Project_Environment_Label 

func Match_Project_Environment_Label(all_projects []ContentLifecycleManagement, channel_label string) (project_label, longest_env_label, original_channel_label string)

func Parse_Product_info 

func Parse_Product_info(inputString string)

func Post_Migration 

func Post_Migration(db *gorm.DB, groupsdata *Update_Groups, wf []Workflow_Step, minion_list []Minion_Data, stage string)

func Post_Migration_Debug 

func Post_Migration_Debug(db *gorm.DB, groupsdata *Update_Groups, minion_list []Minion_Data, stage string)

func Reboot 

func Reboot(sessionkey *auth.SumaSessionKey, db *gorm.DB, wf []Workflow_Step, minion_list []Minion_Data, stage string)

func Reboot_Triage added in v0.1.54 

func Reboot_Triage(sessionkey *auth.SumaSessionKey, jobid int, minion_id int, minion_name string, groupsdata *Update_Groups)

func Refresh_Packages 

func Refresh_Packages(sessionkey *auth.SumaSessionKey, db *gorm.DB, wf []Workflow_Step, minion_list []Minion_Data, stage string)

func SPMigration 

func SPMigration(sessionkey *auth.SumaSessionKey, db *gorm.DB, wf []Workflow_Step, minion_list []Minion_Data, stage string, dryrun bool)

func Salt_CSV_Report 

func Salt_CSV_Report(sessionkey *auth.SumaSessionKey, groupsdata *Update_Groups)

func Salt_Disk_Space_Check_New 

func Salt_Disk_Space_Check_New(sessionkey *auth.SumaSessionKey, groupsdata *Update_Groups, db *gorm.DB)

func Salt_Disk_Space_Check_New_by_List 

func Salt_Disk_Space_Check_New_by_List(sessionkey *auth.SumaSessionKey, groupsdata *Update_Groups, minion_list []Minion_Data, db *gorm.DB)

func Salt_No_Upgrade_Exception_Check_New 

func Salt_No_Upgrade_Exception_Check_New(sessionkey *auth.SumaSessionKey, groupsdata *Update_Groups, db *gorm.DB)

func Salt_No_Upgrade_Exception_Check_New_by_List 

func Salt_No_Upgrade_Exception_Check_New_by_List(sessionkey *auth.SumaSessionKey, groupsdata *Update_Groups, minion_list []Minion_Data, db *gorm.DB)

func Salt_Refresh_Grains_New 

func Salt_Refresh_Grains_New(sessionkey *auth.SumaSessionKey, groupsdata *Update_Groups, db *gorm.DB)

func Salt_Refresh_Grains_New_by_List 

func Salt_Refresh_Grains_New_by_List(sessionkey *auth.SumaSessionKey, groupsdata *Update_Groups, minion_list []Minion_Data, db *gorm.DB)

func Salt_Run_Post_State 

func Salt_Run_Post_State(groupsdata *Update_Groups, post_minion_list []string)

func Salt_Run_state_apply 

func Salt_Run_state_apply(groupsdata *Update_Groups, stage string, db *gorm.DB)

func Salt_Run_state_apply_by_List 

func Salt_Run_state_apply_by_List(groupsdata *Update_Groups, minion_list []Minion_Data, stage string, db *gorm.DB)

func Salt_Set_Patch_Level 

func Salt_Set_Patch_Level(groupsdata *Update_Groups, minion_list []string, stage string, db *gorm.DB)

func SchedulePackageUpdates 

func SchedulePackageUpdates(sessionkey *auth.SumaSessionKey, minion_id_list []int) int

func Send_Email 

func Send_Email(ctx context.Context, groupsdata *Update_Groups, email_template_dir *email.Templates_Dir, db *gorm.DB, health *bool, deadline *time.Time)

func SetLogger added in v0.1.53 

func SetLogger(l *logrus.Logger)

func Start_Workflow 

func Start_Workflow(ctx context.Context, sessionkey *auth.SumaSessionKey, groupsdata *Update_Groups, db *gorm.DB, health *bool, deadline *time.Time)

func Update_packages 

func Update_packages(sessionkey *auth.SumaSessionKey, db *gorm.DB, wf []Workflow_Step, minion_list []Minion_Data, stage string)

func Waiting_Stage 

func Waiting_Stage(db *gorm.DB, wf []Workflow_Step, minion_list []Minion_Data, stage string)

Types

type Add_Note_Request 

type Add_Note_Request struct {
	Sessionkey string `xmlrpc:"sessionKey"`
	Sid        int    `xmlrpc:"sid"`
	Subject    string `xmlrpc:"subject"`
	Body       string `xmlrpc:"body"`
}

type All_Minions_In_Group 

type All_Minions_In_Group struct {
	Minion_List map[string][]string
}

type Array 

type Array struct {
	Data Data `xml:"data"`
}

type Array_ActiveSystems_in_Group 

type Array_ActiveSystems_in_Group struct {
	Data Data_ActiveSystems_in_Group `xml:"data"`
}

type Assigne_Channel 

type Assigne_Channel struct {
	Current_base_channel string `xmlrpc:"current_base_channel"`
	New_base_prefix      string `xmlrpc:"new_base_prefix"`
}

type Assigne_Channels_Job 

type Assigne_Channels_Job struct {
	JobID     int    `json:"JobID"`
	JobStatus string `json:"JobStatus"`
}

type Change_Channels_Request 

type Change_Channels_Request struct {
	Sessionkey         string    `xmlrpc:"sessionKey"`
	Sid                int       `xmlrpc:"sid"`
	BaseChannelLabel   string    `xmlrpc:"baseChannelLabel"`
	ChildLabels        []string  `xmlrpc:"childLabels"`
	EarliestOccurrence time.Time `xmlrpc:"earliestOccurrence"`
}

type ContentLifecycleManagement 

type ContentLifecycleManagement struct {
	gorm.Model
	Clm_Project_Label             string
	Clm_Project_Environment_Label string
}

type ContentSource 

type ContentSource struct {
	Id        int    `xmlrpc:"id,omitempty"`
	Label     string `xmlrpc:"label,omitempty"`
	SourceUrl string `xmlrpc:"sourceUrl,omitempty"`
	Type      string `xmlrpc:"type,omitempty"`
}

type CustomTime 

type CustomTime struct {
	time.Time
}

func (*CustomTime) UnmarshalXML 

func (c *CustomTime) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error

type Data 

type Data struct {
	Values []Struct `xml:"value>struct"`
}

type Data_ActiveSystems_in_Group 

type Data_ActiveSystems_in_Group struct {
	Values []int `xml:"value>i4"`
}

type Delete_Notes_Request 

type Delete_Notes_Request struct {
	Sessionkey string `xmlrpc:"sessionKey"`
	Sid        int    `xmlrpc:"sid"`
}

type Generic_Job_Response 

type Generic_Job_Response struct {
	JobID int `xmlrpc:"id"`
}

type GetId_Request 

type GetId_Request struct {
	Sessionkey string `xmlrpc:"sessionKey"`
	Name       string `xmlrpc:"name"`
}

type GetId_Response 

type GetId_Response struct {
	Result []struct {
		Id                 int       `xmlrpc:"id"`
		Name               string    `xmlrpc:"name"`
		Last_checkin       time.Time `xmlrpc:"last_checkin"`
		Created            time.Time `xmlrpc:"created"`
		Last_boot          time.Time `xmlrpc:"last_boot"`
		Extra_pkg_count    int       `xmlrpc:"extra_pkg_count"`
		Outdated_pkg_count int       `xmlrpc:"outdated_pkg_count"`
	} `xmlrpc:"result"`
}

type Get_Channels_Request 

type Get_Channels_Request struct {
	Sessionkey string `xmlrpc:"sessionKey"`
	Sid        int    `xmlrpc:"sid"`
}

type Get_Channels_Response 

type Get_Channels_Response struct {
	Result []struct {
		Id                   int             `xmlrpc:"id,omitempty"`
		Name                 string          `xmlrpc:"name,omitempty"`
		Label                string          `xmlrpc:"label,omitempty"`
		Arch_name            string          `xmlrpc:"arch_name,omitempty"`
		Arch_label           string          `xmlrpc:"arch_label,omitempty"`
		Summary              string          `xmlrpc:"summary,omitempty"`
		Description          string          `xmlrpc:"description,omitempty"`
		Checksum_label       string          `xmlrpc:"checksum_label,omitempty"`
		Last_modified        time.Time       `xmlrpc:"last_modified,omitempty"`
		Maintainer_name      string          `xmlrpc:"maintainer_name,omitempty"`
		Maintainer_email     string          `xmlrpc:"maintainer_email,omitempty"`
		Maintainer_phone     string          `xmlrpc:"maintainer_phone,omitempty"`
		Support_policy       string          `xmlrpc:"support_policy,omitempty"`
		Gpg_key_url          string          `xmlrpc:"gpg_key_url,omitempty"`
		Gpg_key_id           string          `xmlrpc:"gpg_key_id,omitempty"`
		Gpg_key_fp           string          `xmlrpc:"gpg_key_fp,omitempty"`
		Yumrepo_last_sync    time.Time       `xmlrpc:"yumrepo_last_sync,omitempty"`
		End_of_life          string          `xmlrpc:"end_of_life,omitempty"`
		Parent_channel_label string          `xmlrpc:"parent_channel_label,omitempty"`
		Clone_original       string          `xmlrpc:"clone_original,omitempty"`
		ContentSources       []ContentSource `xmlrpc:"contentSources,omitempty"`
	}
}

type Get_System_by_Group_Request 

type Get_System_by_Group_Request struct {
	Sessionkey string `xmlrpc:"sessionKey"`
	GroupName  string `xmlrpc:"systemGroupName"`
}

type Get_Upgradable_Packages_Request 

type Get_Upgradable_Packages_Request struct {
	Sessionkey string `xmlrpc:"sessionKey"`
	Sid        int    `xmlrpc:"systemId"`
}

type Get_Upgradable_Packages_Response 

type Get_Upgradable_Packages_Response struct {
	Result []struct {
		Name          string `xmlrpc:"name,omitempty"`
		From_release  string `xmlrpc:"from_release,omitempty"`
		To_epoch      string `xmlrpc:"to_epoch,omitempty"`
		Arch          string `xmlrpc:"arch,omitempty"`
		To_package_id int    `xmlrpc:"to_package_id,omitempty"`
		From_version  string `xmlrpc:"from_version,omitempty"`
		To_version    string `xmlrpc:"to_version,omitempty"`
		From_arch     string `xmlrpc:"from_arch,omitempty"`
		To_arch       string `xmlrpc:"to_arch,omitempty"`
		From_epoch    string `xmlrpc:"from_epoch,omitempty"`
		To_release    string `xmlrpc:"to_release,omitempty"`
	}
}

type Group 

type Group struct {
	gorm.Model
	Group_Name string             `json:"group_name" gorm:"primaryKey"`
	T7User     string             `json:"t7user"`
	Ctx_ID     string             `json:"context_id"`
	Email      []Jobchecker_Email `gorm:"constraint:OnUpdate:CASCADE,OnDelete:SET NULL"`
}

DB columns: ID, Group_Name, T7User, Email

type Host_Job_Info 

type Host_Job_Info struct {
	Assigne_Channels_Job     Assigne_Channels_Job     `json:"Assigne_Channels_Job"`
	Pkg_Refresh_Job          Pkg_Refresh_Job          `json:"Pkg_Refresh_Job"`
	Update_Pkg_Job           Update_Pkg_Job           `json:"Update_Pkg_Job"`
	Reboot_Pre_MigrationJob  Reboot_Pre_MigrationJob  `json:"Reboot_Pre_MigrationJob"`
	SP_Migration_DryRun_Job  SP_Migration_DryRun_Job  `json:"SP_Migration_DryRun_Job"`
	SP_Migration_Job         SP_Migration_Job         `json:"SP_Migration_Job"`
	Reboot_Post_MigrationJob Reboot_Post_MigrationJob `json:"Reboot_Post_MigrationJob"`
	Channel_Environment      string                   `json:"Channel_Environment"`
}

type InnerValue 

type InnerValue struct {
	StringValue   *string     `xml:"string,omitempty"`
	IntegerValue  *int        `xml:"i4,omitempty"`
	Int           *int        `xml:"int,omitempty"`
	DateTimeValue *CustomTime `xml:"dateTime.iso8601,omitempty"`
	BooleanValue  *bool       `xml:"bool,omitempty"`
}

func (InnerValue) GetFieldValue 

func (v InnerValue) GetFieldValue() interface{}

type Job_Chain 

type Job_Chain struct {
	SP_Migration_Hosts []Host_Job_Info
}

type Job_Data 

type Job_Data struct {
	Scheduler         string
	Name              string
	CompletedSystems  int
	FailedSystems     int
	InProgressSystems int
	Id                int
	Type              string
	Earliest          time.Time
}

type Jobchecker_Email 

type Jobchecker_Email struct {
	gorm.Model
	Email   string `json:"email"`
	GroupID uint   `json:"group_id"`
}

DB columns: ID, Email, GroupID

type ListAllChannels_Request 

type ListAllChannels_Request struct {
	Sessionkey string `xmlrpc:"sessionKey"`
}

type ListAllChannels_Response 

type ListAllChannels_Response struct {
	Result []struct {
		Id            int    `xmlrpc:"id,omitempty"`
		Name          string `xmlrpc:"name,omitempty"`
		Label         string `xmlrpc:"label,omitempty"`
		Arch_name     string `xmlrpc:"arch_name,omitempty"`
		Provider_name string `xmlrpc:"provider_name,omitempty"`
		Packages      int    `xmlrpc:"packages,omitempty"`
		Systems       int    `xmlrpc:"systems,omitempty"`
	}
}

func List_All_Channels 

func List_All_Channels(sessionkey *auth.SumaSessionKey) *ListAllChannels_Response

type ListMigrationTarget_Request 

type ListMigrationTarget_Request struct {
	Sessionkey                          string `xmlrpc:"sessionKey"`
	Sid                                 int    `xmlrpc:"sid"`
	ExcludeTargetWhereMissingSuccessors bool   `xmlrpc:"excludeTargetWhereMissingSuccessors"`
}

type ListMigrationTarget_Response 

type ListMigrationTarget_Response struct {
	Result []struct {
		Ident    string `xmlrpc:"ident,omitempty"`
		Friendly string `xmlrpc:"friendly,omitempty"`
	}
}

type ListSystemEvents_Request added in v0.1.54 

type ListSystemEvents_Request struct {
	Sessionkey   string    `xmlrpc:"sessionKey"`
	Sid          int       `xmlrpc:"sid"`
	EarliestDate time.Time `xmlrpc:"earliest_date"`
}

type ListSystemEvents_Response added in v0.1.54 

type ListSystemEvents_Response struct {
	Result []struct {
		Failed_count     int       `xmlrpc:"failed_count,omitempty"`
		Modified_date    time.Time `xmlrpc:"modified_date,omitempty"`
		Action_type      string    `xmlrpc:"action_type,omitempty"`
		Created_date     time.Time `xmlrpc:"created_date,omitempty"`
		Successful_count int       `xmlrpc:"successful_count,omitempty"`
		Earliest_action  string    `xmlrpc:"earliest_action,omitempty"`
		Archived         int       `xmlrpc:"archived,omitempty"`
		Scheduler_user   string    `xmlrpc:"scheduler_user,omitempty"`
		Name             string    `xmlrpc:"name,omitempty"`
		Id               int       `xmlrpc:"id,omitempty"`
		Version          string    `xmlrpc:"version,omitempty"`
		Completed_date   time.Time `xmlrpc:"completed_date,omitempty"`
		Pickup_date      time.Time `xmlrpc:"pickup_date,omitempty"`
		Result_msg       string    `xmlrpc:"result_msg,omitempty"`
	}
}

type ListSystemInJobs 

type ListSystemInJobs struct {
	ListInProgressSystems ListSystemInJobs_Response
	ListFailedSystems     ListSystemInJobs_Response
	ListCompletedSystems  ListSystemInJobs_Response
}

func (*ListSystemInJobs) List_Completed_Systems 

func (c *ListSystemInJobs) List_Completed_Systems(sessionkey *auth.SumaSessionKey, jobid_pkg_update int)

func (*ListSystemInJobs) List_Failed_Systems 

func (c *ListSystemInJobs) List_Failed_Systems(sessionkey *auth.SumaSessionKey, jobid_pkg_update int)

func (*ListSystemInJobs) List_InProgress_Systems 

func (c *ListSystemInJobs) List_InProgress_Systems(sessionkey *auth.SumaSessionKey, jobid_pkg_update int)

type ListSystemInJobs_Request 

type ListSystemInJobs_Request struct {
	Sessionkey string `xmlrpc:"sessionKey"`
	ActionId   int    `xmlrpc:"actionId"`
}

type ListSystemInJobs_Response 

type ListSystemInJobs_Response struct {
	Result []struct {
		Server_name  string
		Base_channel string
		Server_id    int
		Timestamp    time.Time
		Message      string
	}
}

func (*ListSystemInJobs_Response) Get_Systems_In_Jobs added in v0.1.55 

func (s *ListSystemInJobs_Response) Get_Systems_In_Jobs() (Systems []string)

type List_Project_Environments_Request 

type List_Project_Environments_Request struct {
	Sessionkey   string `xmlrpc:"sessionKey"`
	ProjectLabel string `xmlrpc:"projectLabel"`
}

type List_Project_Environments_Response 

type List_Project_Environments_Response struct {
	Result []struct {
		Id                       int       `xmlrpc:"id"`
		Label                    string    `xmlrpc:"label"`
		Name                     string    `xmlrpc:"name"`
		Description              string    `xmlrpc:"description"`
		Status                   string    `xmlrpc:"status"`
		LastBuildDate            time.Time `xmlrpc:"lastBuildDate"`
		ContentProjectLabel      string    `xmlrpc:"contentProjectLabel"`
		PreviousEnvironmentLabel string    `xmlrpc:"previousEnvironmentLabel"`
		NextEnvironmentLabel     string    `xmlrpc:"nextEnvironmentLabel"`
	}
}

type List_Projects_Request 

type List_Projects_Request struct {
	Sessionkey string `xmlrpc:"sessionKey"`
}

type List_Projects_Response 

type List_Projects_Response struct {
	Result []struct {
		Id               int       `xmlrpc:"id"`
		Label            string    `xmlrpc:"label"`
		Name             string    `xmlrpc:"name"`
		Description      string    `xmlrpc:"description"`
		LastBuildDate    time.Time `xmlrpc:"lastBuildDate"`
		OrgId            int       `xmlrpc:"orgId"`
		FirstEnvironment string    `xmlrpc:"firstEnvironment"`
	}
}

type Member 

type Member struct {
	Name  string     `xml:"name"`
	Value InnerValue `xml:"value"`
}

type MethodResponse 

type MethodResponse struct {
	Params Params `xml:"params"`
}

type MethodResponse_ActiveSystems_in_Group 

type MethodResponse_ActiveSystems_in_Group struct {
	Params Params_ActiveSystems_in_Group `xml:"params"`
}

type Minion_Data 

type Minion_Data struct {
	gorm.Model
	Minion_ID                int                `json:"Minion_ID"`
	Minion_Name              string             `json:"Minion_Name"`
	Minion_Status            string             `json:"Minion_Status"`
	Minion_Remarks           string             `json:"Minion_Remarks"`
	Clm_Stage                string             `json:"Clm_Stage"`
	Workflow_Step            string             `json:"Workflow_Step"`
	JobID                    int                `json:"JobID"`
	JobStatus                string             `json:"JobStatus"`
	Migration_Stage          string             `json:"Migration_Stage"`
	Migration_Stage_Status   string             `json:"Migration_Stage_Status"`
	Target_base_channel      string             `json:"Target_base_channel"`
	Target_Ident             string             `json:"Target_Ident"`
	Target_Optional_Channels []OptionalChannels `json:"Target_Optional_Channels" gorm:"many2many:Minion_Data_OptionalChannels;"`
	Minion_Groups            []Group            `json:"Minion_Groups" gorm:"many2many:Minion_Data_Groups;"`
}

DB columns: ID, Minion_ID, Minion_Name, Minion_Status, Workflow_Step, JobID, JobStatus, Migration_Stage, Migration_Stage_Status, Target_base_channel, Target_Ident, Target_Optional_Channels, Minion_Groups

func Detect_Online_Minions 

func Detect_Online_Minions(sessionkey *auth.SumaSessionKey, list []Minion_Data, groupsdata *Update_Groups) []Minion_Data

func GetAll_Minions_From_DB 

func GetAll_Minions_From_DB(db *gorm.DB) ([]Minion_Data, error)

type OptionalChannel 

type OptionalChannel struct {
	Old_Channel string `xmlrpc:"old_channel"`
	New_Channel string `xmlrpc:"new_channel"`
}

type OptionalChannels 

type OptionalChannels struct {
	gorm.Model
	Channel_Label    string `json:"channel_label" gorm:"primaryKey"`
	Minion_DataRefer uint   `json:"minion_data_refer"`
}

DB columns: ID, Channel_Label

type Param 

type Param struct {
	Value Value `xml:"value"`
}

type Param_ActiveSystems_in_Group 

type Param_ActiveSystems_in_Group struct {
	Value Value_ActiveSystems_in_Group `xml:"value"`
}

type Params 

type Params struct {
	Param Param `xml:"param"`
}

type Params_ActiveSystems_in_Group 

type Params_ActiveSystems_in_Group struct {
	Param Param_ActiveSystems_in_Group `xml:"param"`
}

type Pkg_Refresh_Job 

type Pkg_Refresh_Job struct {
	JobID     int    `json:"JobID"`
	JobStatus string `json:"JobStatus"`
}

type Reboot_Post_MigrationJob 

type Reboot_Post_MigrationJob struct {
	JobID     int    `json:"JobID"`
	JobStatus string `json:"JobStatus"`
}

type Reboot_Pre_MigrationJob 

type Reboot_Pre_MigrationJob struct {
	JobID     int    `json:"JobID"`
	JobStatus string `json:"JobStatus"`
}

type SP_Migration_DryRun_Job 

type SP_Migration_DryRun_Job struct {
	JobID     int    `json:"JobID"`
	JobStatus string `json:"JobStatus"`
}

type SP_Migration_Job 

type SP_Migration_Job struct {
	JobID     int    `json:"JobID"`
	JobStatus string `json:"JobStatus"`
}

type SchedulePackageUpdates_Request 

type SchedulePackageUpdates_Request struct {
	Sessionkey         string    `xmlrpc:"sessionKey"`
	Sids               []int     `xmlrpc:"sids"`
	EarliestOccurrence time.Time `xmlrpc:"earliestOccurrence"`
}

type SchedulePackageUpdates_Response 

type SchedulePackageUpdates_Response struct {
	ActionId int
}

type ScheduleSPMigrationDryRun_Request 

type ScheduleSPMigrationDryRun_Request struct {
	Sessionkey                                  string    `xmlrpc:"sessionKey"`
	Sid                                         int       `xmlrpc:"sid"`
	TargetIdent                                 string    `xmlrpc:"targetIdent"`
	BaseChannelLabel                            string    `xmlrpc:"baseChannelLabel"`
	OptionalChildChannels                       []string  `xmlrpc:"optionalChildChannels"`
	DryRun                                      bool      `xmlrpc:"dryRun"`
	AllowVendorChange                           bool      `xmlrpc:"allowVendorChange"`
	RemoveProductsWithNoSuccessorAfterMigration bool      `xmlrpc:"removeProductsWithNoSuccessorAfterMigration"`
	EarliestOccurrence                          time.Time `xmlrpc:"earliestOccurrence"`
}

type ScheduleSPMigrationDryRun_Response 

type ScheduleSPMigrationDryRun_Response struct {
	JobID int `xmlrpc:"id"`
}

type Schedule_Pkg_Refresh_Request 

type Schedule_Pkg_Refresh_Request struct {
	Sessionkey         string    `xmlrpc:"sessionKey"`
	Sid                int       `xmlrpc:"sid"`
	EarliestOccurrence time.Time `xmlrpc:"earliestOccurrence"`
}

type Schedule_Pkg_Refresh_Response 

type Schedule_Pkg_Refresh_Response struct {
	JobID int `xmlrpc:"id"`
}

type Schedule_Reboot_Request 

type Schedule_Reboot_Request struct {
	Sessionkey         string    `xmlrpc:"sessionKey"`
	Sid                int       `xmlrpc:"sid"`
	EarliestOccurrence time.Time `xmlrpc:"earliestOccurrence"`
}

type Schedule_Reboot_Response 

type Schedule_Reboot_Response struct {
	JobID int `xmlrpc:"id"`
}

type Struct 

type Struct struct {
	Members []Member `xml:"member"`
}

func (Struct) GetMemberValue 

func (s Struct) GetMemberValue(name string) interface{}

type Target_Product 

type Target_Product struct {
	Name                  string            `json:"name"`
	Ident                 string            `json:"ident"`
	Base_Channel          string            `json:"base_channel_label"`
	Clm_Project_Label     string            `json:"clm_project_label"`
	OptionalChildChannels []OptionalChannel `json:"optionalChildChannels"`
}

type Update_Groups 

type Update_Groups struct {
	gorm.Model
	Groups          []string `json:"groups"`
	Minions_to_add  []string `json:"minions_to_add"`
	Sqlite_db       string   `json:"sqlite_db"`
	Qualifying_only bool     `json:"qualifying_only"`
	//Delay                           int              `json:"delay"`
	Timeout                         int    `json:"timeout"`
	GatherJobTimeout                int    `json:"gather_job_timeout"`
	Email_Interval                  int    `json:"email_interval"`
	Logfile                         string `json:"logfile"`
	Log_Level                       string `json:"log_level"`
	SaltMaster_Address              string `json:"salt_master_address"`
	SaltApi_Port                    int    `json:"salt_api_port"`
	SaltUser                        string `json:"salt_user"`
	SaltPassword                    string `json:"salt_password"`
	Salt_diskspace_grains_key       string `json:"salt_diskspace_grains_key"`
	Salt_diskspace_grains_value     string `json:"salt_diskspace_grains_value"`
	Salt_no_upgrade_exception_key   string `json:"salt_no_upgrade_exception_key"`
	Salt_no_upgrade_exception_value string `json:"salt_no_upgrade_exception_value"`
	Salt_Prep_State                 string `json:"salt_prep_state"`
	Salt_Post_State                 string `json:"salt_post_state"`
	JobcheckerTimeout               int    `json:"jobchecker_timeout"`
	Reboot_Triage_Timer             int    `json:"reboot_triage_timer"`
	//Reboot_timeout                  int              `json:"reboot_timeout"`
	JobcheckerEmails []string `json:"jobchecker_emails"`
	Patch_Level      string   `json:"patch_level"`
	//Include_Spmigration             bool             `json:"include_spmigration"`
	T7User                  string           `json:"t7user"`
	Token                   string           `json:"authentication_token"`
	Tracking_file_directory string           `json:"tracking_file_directory"`
	Ctx_ID                  string           `json:"context_id"`
	Workflow                []map[string]int `json:"workflow"`
	Assigne_channels        []struct {
		Assigne_Channel Assigne_Channel `json:"assign_channel"`
	} `json:"assign_channels"`

	Target_Products []struct {
		Product Target_Product `json:"product"`
	} `json:"products"`
}

type Update_Pkg_Job 

type Update_Pkg_Job struct {
	JobID     int    `json:"JobID"`
	JobStatus string `json:"JobStatus"`
}

type Value 

type Value struct {
	Array Array `xml:"array"`
}

type Value_ActiveSystems_in_Group 

type Value_ActiveSystems_in_Group struct {
	Array Array_ActiveSystems_in_Group `xml:"array"`
}

type Workflow_Step 

type Workflow_Step struct {
	gorm.Model
	Order int    `json:"order"`
	Name  string `json:"name"`
}

func Get_Workflow_From_DB 

func Get_Workflow_From_DB(db *gorm.DB) ([]Workflow_Step, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.