utils

package
v1.3.0-develop.17 Latest Latest
Warning

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

 Go to latest Published: Oct 4, 2023 License: Apache-2.0 Imports: 38 Imported by: 0

Documentation

Index

Constants

View Source 
const APP_NAME = "k8s"
View Source 
const CONFIGVERSION = 1
View Source 
const CONTEXTOWN = "own-context"
View Source 
const CONTEXTSSECRET = "punq-contexts"
View Source 
const JWTSECRET = "punq-jwt"
View Source 
const USERADMIN = "admin"
View Source 
const USERSSECRET = "punq-users"

Variables

View Source 
var ChangeLog string
View Source 
var ConfigPath string
View Source 
var DefaultConfigFileOperator string
View Source 
var DefaultConfigFileProd string
View Source 
var DefaultConfigLocalFile string
View Source 
var YamlTemplatesFolder embed.FS

Functions

func BytesToHumanReadable 

func BytesToHumanReadable(b int64) string

func ConfirmTask 

func ConfirmTask(s string, tries int) bool

func Contains 

func Contains(s []string, str string) bool

func ContainsInt 

func ContainsInt(v int, a []int) bool

func CreateDirIfNotExist 

func CreateDirIfNotExist(dir string)

func DeleteCurrentConfig added in v1.1.41 

func DeleteCurrentConfig()

func DeleteDirIfExist 

func DeleteDirIfExist(dir string)

func Diff 

func Diff(a []string, b []string) []string

func Equals added in v1.2.22 

func Equals(s []string, str string) bool

func FatalError added in v1.3.0 

func FatalError(message string)

func FillWith 

func FillWith(s string, targetLength int, chars string) string

func FunctionName 

func FunctionName() string

func GetDefaultKubeConfig added in v1.2.40 

func GetDefaultKubeConfig() string

func GetDirectories 

func GetDirectories(customConfigPath string) (configDir string, configPath string)

func GetRequiredHeader added in v1.2.0 

func GetRequiredHeader(c *gin.Context, headerField string) string

func HashString added in v1.2.38 

func HashString(data string) string

func HttpHeader 

func HttpHeader(additionalName string) http.Header

func HttpRespondForWorkloadResult added in v1.2.0 

func HttpRespondForWorkloadResult(c *gin.Context, workloadResult K8sWorkloadResult)

func HumanDuration 

func HumanDuration(d time.Duration) string

TAKEN FROM Kubernetes apimachineryv0.25.1

func InitCertificate 

func InitCertificate() cmapi.Certificate

func InitCertificateSigningRequestYaml 

func InitCertificateSigningRequestYaml() string

func InitCertificateYaml 

func InitCertificateYaml() string

func InitClusterIssuerYaml 

func InitClusterIssuerYaml() string

func InitClusterRoleBindingYaml 

func InitClusterRoleBindingYaml() string

func InitClusterRoleYaml 

func InitClusterRoleYaml() string

func InitConfigMap 

func InitConfigMap() core.ConfigMap

func InitConfigMapYaml 

func InitConfigMapYaml() string

func InitConfigYaml 

func InitConfigYaml(showDebug bool, customConfigName string, stage string)

func InitContainerSecret 

func InitContainerSecret() core.Secret

func InitContainerSecretYaml 

func InitContainerSecretYaml() string

func InitCronJob 

func InitCronJob() v1job.CronJob

func InitCronJobYaml 

func InitCronJobYaml() string

func InitCustomResourceDefinitionYaml 

func InitCustomResourceDefinitionYaml() string

func InitDaemonsetYaml 

func InitDaemonsetYaml() string

func InitDeployment 

func InitDeployment() v1.Deployment

func InitDeploymentYaml 

func InitDeploymentYaml() string

func InitEndPointYaml 

func InitEndPointYaml() string

func InitHpaYaml 

func InitHpaYaml() string

func InitIngresYaml 

func InitIngresYaml() string

func InitIngress 

func InitIngress() netv1.Ingress

func InitIngressYaml 

func InitIngressYaml() string

func InitIssuerYaml 

func InitIssuerYaml() string

func InitJobYaml 

func InitJobYaml() string

func InitLeaseYaml 

func InitLeaseYaml() string

func InitNamespaceYaml 

func InitNamespaceYaml() string

func InitNetPolNamespace 

func InitNetPolNamespace() netv1.NetworkPolicy

func InitNetPolNamespaceYaml 

func InitNetPolNamespaceYaml() string

func InitNetPolService 

func InitNetPolService() netv1.NetworkPolicy

func InitNetPolServiceYaml 

func InitNetPolServiceYaml() string

func InitNetPolYaml 

func InitNetPolYaml() string

func InitOrderYaml 

func InitOrderYaml() string

func InitPersistentVolume 

func InitPersistentVolume() core.PersistentVolume

func InitPersistentVolumeClaim 

func InitPersistentVolumeClaim() core.PersistentVolumeClaim

func InitPersistentVolumeClaimYaml 

func InitPersistentVolumeClaimYaml() string

func InitPersistentVolumeYaml 

func InitPersistentVolumeYaml() string

func InitPodYaml 

func InitPodYaml() string

func InitPriorityClassYaml 

func InitPriorityClassYaml() string

func InitPunqIngress 

func InitPunqIngress() netv1.Ingress

func InitPunqService 

func InitPunqService() core.Service

func InitReplicaSetYaml 

func InitReplicaSetYaml() string

func InitResourceQuotaYaml 

func InitResourceQuotaYaml() string

func InitRoleBindingYaml 

func InitRoleBindingYaml() string

func InitRoleYaml 

func InitRoleYaml() string

func InitSecret 

func InitSecret() core.Secret

func InitSecretYaml 

func InitSecretYaml() string

func InitService 

func InitService() core.Service

func InitServiceAccountExampleYaml 

func InitServiceAccountExampleYaml() string

func InitServiceExampleYaml 

func InitServiceExampleYaml() string

func InitServiceYaml 

func InitServiceYaml() string

func InitStatefulsetYaml 

func InitStatefulsetYaml() string

func InitStorageClassYaml 

func InitStorageClassYaml() string

func InitUpgradeConfigMap 

func InitUpgradeConfigMap() core.ConfigMap

func InitUpgradeJob 

func InitUpgradeJob() v1job.Job

func InitVolumeAttachmentYaml 

func InitVolumeAttachmentYaml() string

func InitVolumeSnapshotYaml 

func InitVolumeSnapshotYaml() string

func IsNewReleaseAvailable added in v1.1.42 

func IsNewReleaseAvailable() bool

func IsProduction added in v1.2.22 

func IsProduction() bool

func JsonStringToHumanDuration 

func JsonStringToHumanDuration(jsonTime string) string

func MalformedMessage added in v1.2.0 

func MalformedMessage(c *gin.Context, msg string)

func MissingHeader added in v1.2.1 

func MissingHeader(c *gin.Context, header string)

func NanoId 

func NanoId() string

func NanoIdExtraLong 

func NanoIdExtraLong() string

func NotFound added in v1.2.0 

func NotFound(c *gin.Context, msg string)

func NumberToHumanReadable 

func NumberToHumanReadable(b uint64) string

func OpenBrowser 

func OpenBrowser(url string)

func ParseJsonStringArray 

func ParseJsonStringArray(input string) []string

func Pointer 

func Pointer[K any](val K) *K

func PrintChangeLog added in v1.1.27 

func PrintChangeLog()

func PrintError added in v1.3.0 

func PrintError(message string)

func PrintInfo added in v1.3.0 

func PrintInfo(message string)
func PrintLogo()

func PrintPrettyPost added in v1.2.0 

func PrintPrettyPost(c *gin.Context)

func PrintSettings 

func PrintSettings()

func PrintVersionInfo 

func PrintVersionInfo()

func QuickHash 

func QuickHash(s string) string

func Remove 

func Remove[T any](slice []T, s int) []T

func Round 

func Round(num float64) int

func SelectIndexInteractive added in v1.2.38 

func SelectIndexInteractive(question string, noOfElements int) int

func ToFixed 

func ToFixed(num float64, precision int) float64

func TruncateText 

func TruncateText(s string, max int) string

func Unauthorized added in v1.2.0 

func Unauthorized(c *gin.Context, msg string)

func WriteDefaultConfig 

func WriteDefaultConfig(stage string)

Types

type ClusterSecret 

type ClusterSecret struct {
	ApiKey       string
	ClusterMfaId string
	ClusterName  string
}

This object will initially created in secrets when the software is installed into the cluster for the first time (resource: secret -> mogenius/mogenius)

type Config 

type Config struct {
	Config struct {
		Version int `yaml:"version" env-description:"Version of the configuration yaml."`
	} `yaml:"config"`
	Frontend struct {
		Host string `yaml:"host" env:"frontend_host" env-description:"Host of the frontend server."`
		Port int    `yaml:"port" env:"frontend_port" env-description:"Port of the frontend server."`
	} `yaml:"frontend"`
	Backend struct {
		Host string `yaml:"host" env:"backend_host" env-description:"Host of the backend server."`
		Port int    `yaml:"port" env:"backend_port" env-description:"Port of the backend server."`
	} `yaml:"backend"`
	Kubernetes struct {
		ClusterName  string `yaml:"cluster_name" env:"cluster_name" env-description:"The Name of the Kubernetes Cluster"`
		OwnNamespace string `yaml:"own_namespace" env:"OWN_NAMESPACE" env-description:"The Namespace of mogenius platform"`
		RunInCluster bool   `` /* 229-byte string literal not displayed */
	} `yaml:"kubernetes"`
	Misc struct {
		Stage            string   `yaml:"stage" env:"stage" env-description:"mogenius k8s-manager stage" env-default:"prod"`
		Debug            bool     `yaml:"debug" env:"debug" env-description:"If set to true, debug features will be enabled." env-default:"false"`
		CheckForUpdates  int      `yaml:"check_for_updates" env:"check_for_updates" env-description:"Time interval between update checks." env-default:"86400"`
		IgnoreNamespaces []string `yaml:"ignore_namespaces" env:"ignore_namespaces" env-description:"List of all ignored namespaces." env-default:""`
	} `yaml:"misc"`
}
var CONFIG Config

type K8sWorkloadResult added in v1.2.0 

type K8sWorkloadResult struct {
	Result interface{} `json:"result,omitempty"`
	Error  interface{} `json:"error,omitempty"`
}

type Release 

type Release struct {
	TagName   string `json:"tag_name"`
	Published string `json:"published_at"`
}

type ResponseError 

type ResponseError struct {
	Error string `json:"error,omitempty"`
}

func CreateError 

func CreateError(err error) ResponseError

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.