common

package

v0.11.0 Latest Latest Go to latest Published: Dec 21, 2025 License: Apache-2.0 Imports: 36 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/open-uem/openuem-worker

Links

Open Source Insights

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func GetWd ¶

func GetWd() (string, error)

Types ¶

type Worker ¶

type Worker struct {
	NATSConnection         *nats.Conn
	NATSConnectJob         gocron.Job
	NATSServers            string
	DBUrl                  string
	DBConnectJob           gocron.Job
	ConfigJob              gocron.Job
	TaskScheduler          gocron.Scheduler
	Model                  *models.Model
	CACert                 *x509.Certificate
	CAPrivateKey           *rsa.PrivateKey
	ClientCertPath         string
	ClientKeyPath          string
	CACertPath             string
	CAKeyPath              string
	PKCS12                 []byte
	Cert                   *x509.Certificate
	CertBytes              []byte
	PrivateKey             *rsa.PrivateKey
	CertRequest            *openuem_nats.CertificateRequest
	Settings               *ent.Settings
	Logger                 *utils.OpenUEMLogger
	ConsoleURL             string
	OCSPResponders         []string
	JetstreamContextCancel context.CancelFunc
	Version                string
	Channel                server.Channel
	Replicas               int
	Jetstream              jetstream.JetStream
}

func NewWorker ¶

func NewWorker(logName string) *Worker

func (*Worker) AgentConfigHandler ¶

func (w *Worker) AgentConfigHandler(msg *nats.Msg)

func (*Worker) ApplyUnixEndpointProfiles ¶ added in v0.9.0

func (w *Worker) ApplyUnixEndpointProfiles(msg *nats.Msg)

func (*Worker) ApplyWindowsEndpointProfiles ¶ added in v0.9.0

func (w *Worker) ApplyWindowsEndpointProfiles(msg *nats.Msg)

func (*Worker) CheckCLICommonRequisites ¶

func (w *Worker) CheckCLICommonRequisites(cCtx *cli.Context) error

func (*Worker) DeployResultReceivedHandler ¶

func (w *Worker) DeployResultReceivedHandler(msg *nats.Msg)

func (*Worker) GenerateAgentCertificate ¶

func (w *Worker) GenerateAgentCertificate() error

func (*Worker) GenerateAnsibleConfig ¶ added in v0.9.0

func (w *Worker) GenerateAnsibleConfig(profile *ent.Profile) (*ansiblecfg.AnsiblePlaybook, error)

func (*Worker) GenerateCertManagerWorkerConfig ¶

func (w *Worker) GenerateCertManagerWorkerConfig() error

func (*Worker) GenerateCommonWorkerConfig ¶

func (w *Worker) GenerateCommonWorkerConfig(c string) error

func (*Worker) GenerateNetbirdConfig ¶ added in v0.11.0

func (w *Worker) GenerateNetbirdConfig(profile *ent.Profile, agentID string) ([]*openuem_nats.NetbirdTask, error)

func (*Worker) GenerateUserCertificate ¶

func (w *Worker) GenerateUserCertificate() error

func (*Worker) GenerateWinGetConfig ¶

func (w *Worker) GenerateWinGetConfig(profile *ent.Profile) (*wingetcfg.WinGetCfg, error)

func (*Worker) GetAppliedProfiles ¶

func (w *Worker) GetAppliedProfiles(agentID string) ([]*ent.Profile, error)

func (*Worker) NewAgentCertificateHandler ¶

func (w *Worker) NewAgentCertificateHandler(msg *nats.Msg)

func (*Worker) NewUserCertificateHandler ¶

func (w *Worker) NewUserCertificateHandler(msg *nats.Msg)

func (*Worker) NewX509AgentCertificateTemplate ¶

func (w *Worker) NewX509AgentCertificateTemplate() (*x509.Certificate, error)

func (*Worker) NewX509UserCertificateTemplate ¶

func (w *Worker) NewX509UserCertificateTemplate() (*x509.Certificate, error)

func (*Worker) PingHandler ¶

func (w *Worker) PingHandler(msg *nats.Msg)

func (*Worker) ReloadSettingsHandler ¶

func (w *Worker) ReloadSettingsHandler(msg *nats.Msg)

func (*Worker) ReportReceivedHandler ¶

func (w *Worker) ReportReceivedHandler(msg *nats.Msg)

func (*Worker) RevokeCertificateHandler ¶

func (w *Worker) RevokeCertificateHandler(msg *nats.Msg)

func (*Worker) SendCertificate ¶

func (w *Worker) SendCertificate() error

func (*Worker) SendConfirmEmailHandler ¶

func (w *Worker) SendConfirmEmailHandler(msg *nats.Msg)

func (*Worker) SendUserCertificateHandler ¶

func (w *Worker) SendUserCertificateHandler(msg *nats.Msg)

func (*Worker) StartDBConnectJob ¶

func (w *Worker) StartDBConnectJob(subscription func() error) error

func (*Worker) StartGenerateWorkerConfigJob ¶

func (w *Worker) StartGenerateWorkerConfigJob(workerName string, common bool) error

func (*Worker) StartNATSConnectJob ¶

func (w *Worker) StartNATSConnectJob(queueSubscribe func() error) error

func (*Worker) StartWorker ¶

func (w *Worker) StartWorker(subscription func() error)

func (*Worker) StopWorker ¶

func (w *Worker) StopWorker()

func (*Worker) SubscribeToAgentWorkerQueues ¶

func (w *Worker) SubscribeToAgentWorkerQueues() error

func (*Worker) SubscribeToCertManagerWorkerQueues ¶

func (w *Worker) SubscribeToCertManagerWorkerQueues() error

func (*Worker) SubscribeToNotificationWorkerQueues ¶

func (w *Worker) SubscribeToNotificationWorkerQueues() error

func (*Worker) WinGetCfgApplicationReport ¶

func (w *Worker) WinGetCfgApplicationReport(msg *nats.Msg)

func (*Worker) WinGetCfgDeploymentReport ¶

func (w *Worker) WinGetCfgDeploymentReport(msg *nats.Msg)

func (*Worker) WinGetCfgMarkPackageAsExcluded ¶

func (w *Worker) WinGetCfgMarkPackageAsExcluded(msg *nats.Msg)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
notifications templ: version: v0.2.771	templ: version: v0.2.771

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL