utils

Jul 26, 2023

Changes in this version

+ func GetJobById(c *api.Client, jid string) (*models.Job, *models.Error)

Mar 19, 2024

Changes in this version

+ const CleanupInterval

+ type Cache struct

+ func CreateCache(secretTtl time.Duration, ...) *Cache

+ func (c *Cache) ClearMachineCache(machineId string)

+ func (c *Cache) Empty()

+ func (c *Cache) Get(machineId string, lookupUri string) (interface{}, error)

Jan 12, 2023

Changes in this version

+ func Package(target, src string) error

+ func Unpack(src []byte, target string) error

Oct 14, 2021

Changes in this version

+ func AddDrpParam(c *api.Client, objtype, objkey, param string, new interface{}) *models.Error

+ func AddOrSetDrpParam(c *api.Client, objtype, objkey, param string, new interface{}) *models.Error

+ func AddToJobLog(c *api.Client, jid, data string) *models.Error

+ func ConvertError(code int, err error) *models.Error

+ func DeleteDrpMachine(c *api.Client, uuid string) *models.Error

+ func GetDrpBooleanParam(c *api.Client, objtype, objkey, param string) (bool, *models.Error)

+ func GetDrpIntParam(c *api.Client, objtype, objkey, param string) (int, *models.Error)

+ func GetDrpMachineByParam(c *api.Client, param, value string) (*models.Machine, *models.Error)

+ func GetDrpObjByParam(c *api.Client, objtype, param, value string) (models.Model, *models.Error)

+ func GetDrpParam(c *api.Client, objtype, objkey, param string) (interface{}, *models.Error)

+ func GetDrpStringParam(c *api.Client, objtype, objkey, param string) (string, *models.Error)

+ func GetParamOrBoolean(m map[string]interface{}, p string, b bool) bool

+ func GetParamOrInt(m map[string]interface{}, p string, i int) int

+ func GetParamOrInt64(m map[string]interface{}, p string, i int64) int64

+ func GetParamOrString(m map[string]interface{}, p, s string) string

+ func MakeError(code int, msg string) *models.Error

+ func RemoveDrpParam(c *api.Client, objtype, objkey, param string, old interface{}) *models.Error

+ func SetDrpParam(c *api.Client, objtype, objkey, param string, old, new interface{}) *models.Error

+ func SetErrorName(name string)

+ func ValidateBooleanValue(param string, val interface{}) (bool, *models.Error)

+ func ValidateIntValue(param string, val interface{}) (int, *models.Error)

+ func ValidateStringValue(param string, val interface{}) (string, *models.Error)

+ type PerIdQueue struct

+ Capacity int

+ func NewQueues(ctx context.Context, limit int) *PerIdQueue

+ func (pmq *PerIdQueue) Add(id string, l logger.Logger, req func()) error