worker

package
v0.0.0-...-b2289a0 Latest Latest
Warning

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

 Go to latest Published: Feb 4, 2025 License: Apache-2.0 Imports: 33 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Queues 

func Queues() []string

Types

type BuildApplicationRequest 

type BuildApplicationRequest struct {
	AppId        string `json:"app_id"`
	DeploymentId string `json:"deployment_id"`
}

BuildApplicationRequest : request payload for deploy application

type DeleteApplicationRequest 

type DeleteApplicationRequest struct {
	Id string `json:"id"`
}

DeleteApplicationRequest : request payload for application delete

type DeployApplicationRequest 

type DeployApplicationRequest struct {
	AppId             string `json:"app_id"`
	DeploymentId      string `json:"deployment_id"`
	IgnoreProxyUpdate bool   `json:"ignore_proxy_update"`
}

DeployApplicationRequest : request payload for deploy application

type DockerPushLogger 

type DockerPushLogger struct {
	// contains filtered or unexported fields
}

type IngressRuleApplyRequest 

type IngressRuleApplyRequest struct {
	Id uint `json:"id"`
}

IngressRuleApplyRequest : request payload for ingress rule apply

type IngressRuleDeleteRequest 

type IngressRuleDeleteRequest struct {
	Id uint `json:"id"`
}

IngressRuleDeleteRequest : request payload for ingress rule delete

type IngressRuleHttpsRedirectRequest 

type IngressRuleHttpsRedirectRequest struct {
	Id      uint `json:"id"`
	Enabled bool `json:"enabled"`
}

IngressRuleHttpsRedirectRequest : request payload for ingress rule https redirect

type InstallDependenciesOnServerRequest 

type InstallDependenciesOnServerRequest struct {
	ServerId uint `json:"server_id"`
	LogId    uint `json:"log_id"`
}

InstallDependenciesOnServerRequest : request payload for install dependencies on server

type Manager 

type Manager struct {
	Config         *config.Config
	ServiceManager *service_manager.ServiceManager
}

Manager : hold references to other functions of service

func NewManager 

func NewManager(config *config.Config, manager *service_manager.ServiceManager) *Manager

func (Manager) BuildApplication 

func (m Manager) BuildApplication(request BuildApplicationRequest, ctx context.Context, cancelContext context.CancelFunc) error

func (Manager) DeleteApplication 

func (m Manager) DeleteApplication(request DeleteApplicationRequest, ctx context.Context, _ context.CancelFunc) error

func (Manager) DeployApplication 

func (m Manager) DeployApplication(request DeployApplicationRequest, _ context.Context, _ context.CancelFunc) error

func (Manager) EnqueueBuildApplicationRequest 

func (m Manager) EnqueueBuildApplicationRequest(applicationId string, deploymentId string) error

func (Manager) EnqueueDeleteApplicationRequest 

func (m Manager) EnqueueDeleteApplicationRequest(applicationId string) error

func (Manager) EnqueueDeletePersistentVolumeRequest 

func (m Manager) EnqueueDeletePersistentVolumeRequest(persistentVolumeId uint) error

func (Manager) EnqueueDeployApplicationRequest 

func (m Manager) EnqueueDeployApplicationRequest(applicationId string, deploymentId string) error

func (Manager) EnqueueDeployApplicationRequestWithNoProxyUpdate 

func (m Manager) EnqueueDeployApplicationRequestWithNoProxyUpdate(applicationId string, deploymentId string) error

func (Manager) EnqueueIngressRuleApplyRequest 

func (m Manager) EnqueueIngressRuleApplyRequest(ingressRuleId uint) error

func (Manager) EnqueueIngressRuleDeleteRequest 

func (m Manager) EnqueueIngressRuleDeleteRequest(ingressRuleId uint) error

func (Manager) EnqueueIngressRuleHttpsRedirectRequest 

func (m Manager) EnqueueIngressRuleHttpsRedirectRequest(ingressRuleId uint, enabled bool) error

func (Manager) EnqueueInstallDependenciesOnServerRequest 

func (m Manager) EnqueueInstallDependenciesOnServerRequest(serverId uint, logId uint) error

func (Manager) EnqueuePersistentVolumeBackupRequest 

func (m Manager) EnqueuePersistentVolumeBackupRequest(persistentVolumeBackupId uint) error

func (Manager) EnqueuePersistentVolumeRestoreRequest 

func (m Manager) EnqueuePersistentVolumeRestoreRequest(persistentVolumeRestoreId uint) error

func (Manager) EnqueueRedirectRuleApplyRequest 

func (m Manager) EnqueueRedirectRuleApplyRequest(redirectRuleId uint) error

func (Manager) EnqueueRedirectRuleDeleteRequest 

func (m Manager) EnqueueRedirectRuleDeleteRequest(redirectRuleId uint) error

func (Manager) EnqueueSSLGenerateRequest 

func (m Manager) EnqueueSSLGenerateRequest(domainId uint) error

func (Manager) EnqueueSSLProxyUpdateRequest 

func (m Manager) EnqueueSSLProxyUpdateRequest(domainId uint) error

func (Manager) EnqueueSetupAndEnableProxyRequest 

func (m Manager) EnqueueSetupAndEnableProxyRequest(serverId uint, logId uint) error

func (Manager) EnqueueSetupServerRequest 

func (m Manager) EnqueueSetupServerRequest(serverId uint, logId uint, advertiseIP string) error

func (Manager) EnqueueUpdateApplicationOnServerScheduleDeploymentUpdateRequest 

func (m Manager) EnqueueUpdateApplicationOnServerScheduleDeploymentUpdateRequest(serverId uint) error

func (Manager) IngressRuleApply 

func (m Manager) IngressRuleApply(request IngressRuleApplyRequest, ctx context.Context, _ context.CancelFunc) error

func (Manager) IngressRuleDelete 

func (m Manager) IngressRuleDelete(request IngressRuleDeleteRequest, ctx context.Context, _ context.CancelFunc) error

func (Manager) IngressRuleHttpsRedirect 

func (m Manager) IngressRuleHttpsRedirect(request IngressRuleHttpsRedirectRequest, ctx context.Context, _ context.CancelFunc) error

func (Manager) InstallDependenciesOnServer 

func (m Manager) InstallDependenciesOnServer(request InstallDependenciesOnServerRequest, ctx context.Context, _ context.CancelFunc) error

func (Manager) PersistentVolumeBackup 

func (m Manager) PersistentVolumeBackup(request PersistentVolumeBackupRequest, ctx context.Context, _ context.CancelFunc) error

func (Manager) PersistentVolumeDeletion 

func (m Manager) PersistentVolumeDeletion(request PersistentVolumeDeletionRequest, ctx context.Context, _ context.CancelFunc) error

func (Manager) PersistentVolumeRestore 

func (m Manager) PersistentVolumeRestore(request PersistentVolumeRestoreRequest, ctx context.Context, _ context.CancelFunc) error

func (Manager) RedirectRuleApply 

func (m Manager) RedirectRuleApply(request RedirectRuleApplyRequest, ctx context.Context, _ context.CancelFunc) error

func (Manager) RedirectRuleDelete 

func (m Manager) RedirectRuleDelete(request RedirectRuleDeleteRequest, ctx context.Context, _ context.CancelFunc) error

func (Manager) SSLGenerate 

func (m Manager) SSLGenerate(request SSLGenerateRequest, ctx context.Context, _ context.CancelFunc) error

func (Manager) SSLProxyUpdate 

func (m Manager) SSLProxyUpdate(request SSLProxyUpdateRequest, ctx context.Context, _ context.CancelFunc) error

func (Manager) SetupAndEnableProxy 

func (m Manager) SetupAndEnableProxy(request SetupAndEnableProxyRequest, ctx context.Context, cancelCtx context.CancelFunc) error

func (Manager) SetupServer 

func (m Manager) SetupServer(request SetupServerRequest, ctx context.Context, _ context.CancelFunc) error

func (Manager) StartConsumers 

func (m Manager) StartConsumers(nowait bool) error

func (Manager) UpdateApplicationOnServerScheduleDeploymentUpdate 

func (m Manager) UpdateApplicationOnServerScheduleDeploymentUpdate(_ UpdateApplicationOnServerScheduleDeploymentStatusUpdateRequest, ctx context.Context, _ context.CancelFunc) error

func (Manager) WaitForConsumers 

func (m Manager) WaitForConsumers()

type PersistentVolumeBackupRequest 

type PersistentVolumeBackupRequest struct {
	Id uint `json:"id"`
}

PersistentVolumeBackupRequest : request payload for persistent volume backup

type PersistentVolumeDeletionRequest 

type PersistentVolumeDeletionRequest struct {
	Id uint `json:"id"`
}

PersistentVolumeDeletionRequest : request payload for delete persistent volume

type PersistentVolumeRestoreRequest 

type PersistentVolumeRestoreRequest struct {
	Id uint `json:"id"`
}

PersistentVolumeRestoreRequest : request payload for persistent volume restore

type RedirectRuleApplyRequest 

type RedirectRuleApplyRequest struct {
	Id uint `json:"id"`
}

RedirectRuleApplyRequest : request payload for redirect rule apply

type RedirectRuleDeleteRequest 

type RedirectRuleDeleteRequest struct {
	Id uint `json:"id"`
}

RedirectRuleDeleteRequest : request payload for redirect rule delete

type SSLGenerateRequest 

type SSLGenerateRequest struct {
	DomainId uint `json:"domain_id"`
}

SSLGenerateRequest : request payload for ssl generate

type SSLProxyUpdateRequest 

type SSLProxyUpdateRequest struct {
	DomainId uint `json:"domain_id"`
}

SSLProxyUpdateRequest : request payload for updatin SSL ceritifcate on proxies

type SetupAndEnableProxyRequest 

type SetupAndEnableProxyRequest struct {
	ServerId uint `json:"server_id"`
	LogId    uint `json:"log_id"`
}

SetupAndEnableProxyRequest : request payload for setup server

type SetupServerRequest 

type SetupServerRequest struct {
	ServerId    uint   `json:"server_id"`
	AdvertiseIP string `json:"advertise_ip"`
	LogId       uint   `json:"log_id"`
}

SetupServerRequest : request payload for setup server

type UpdateApplicationOnServerScheduleDeploymentStatusUpdateRequest 

type UpdateApplicationOnServerScheduleDeploymentStatusUpdateRequest struct {
	ServerId uint `json:"server_id"`
}

UpdateApplicationOnServerScheduleDeploymentStatusUpdateRequest : request payload for update application on server deployment status update

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.