processdeployment

package
v0.0.24 Latest Latest
Warning

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

Go to latest
Published: Mar 2, 2026 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var DefaultTimeout = 30 * time.Second

Functions

This section is empty.

Types

type Config

type Config struct {
	ProcessDeploymentUrl         string `json:"process_deployment_url"`
	FogProcessDeploymentUrl      string `json:"fog_process_deployment_url"`
	FogProcessSyncUrl            string `json:"fog_process_sync_url"`
	DeviceRepositoryUrl          string `json:"device_repository_url"`
	AllowMsgEventsInFogProcesses bool   `json:"allow_msg_events_in_fog_processes"`
	AllowImportsInFogProcesses   bool   `json:"allow_imports_in_fog_processes"`
	ProcessDeploymentSource      string `json:"process_deployment_source"`
	WorkerParamPrefix            string `json:"worker_param_prefix"`
	InitTopics                   bool   `json:"init_topics"`

	HealthCheckInterval string `json:"health_check_interval"`
}

type DeploymentMetadata added in v0.0.23

type DeploymentMetadata struct {
	Metadata
	SyncInfo
}

type DeviceGroup

type DeviceGroup struct {
	Id        string   `json:"id"`
	Name      string   `json:"name"`
	DeviceIds []string `json:"device_ids"`
}

type Hub

type Hub struct {
	Id             string   `json:"id"`
	Name           string   `json:"name"`
	DeviceLocalIds []string `json:"device_local_ids"`
	DeviceIds      []string `json:"device_ids"`
}

type Metadata added in v0.0.23

type Metadata struct {
	CamundaDeploymentId string `json:"camunda_deployment_id"`
}

type ProcessDeployment

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

func New

func New(ctx context.Context, wg *sync.WaitGroup, config Config, libConfig configuration.Config, auth *auth.Auth, smartServiceRepo SmartServiceRepo) (*ProcessDeployment, error)

func (*ProcessDeployment) CheckDeployment added in v0.0.23

func (this *ProcessDeployment) CheckDeployment(token auth.Token, deploymentId string) (int, error)

func (*ProcessDeployment) CheckFogDeployment added in v0.0.23

func (this *ProcessDeployment) CheckFogDeployment(token auth.Token, hubId string, deploymentId string) (error, error)

func (*ProcessDeployment) Deploy

func (this *ProcessDeployment) Deploy(token auth.Token, deployment deploymentmodel.Deployment, allowMissingServiceSelection bool, hubId string) (result deploymentmodel.Deployment, err error)

func (*ProcessDeployment) Do

func (this *ProcessDeployment) Do(task model.CamundaExternalTask) (modules []model.Module, outputs map[string]interface{}, err error)

func (*ProcessDeployment) GetFogNetworks

func (this *ProcessDeployment) GetFogNetworks(token auth.Token) (result []Hub, err error)

func (*ProcessDeployment) GetFogSyncMetadata added in v0.0.23

func (this *ProcessDeployment) GetFogSyncMetadata(token auth.Token, hubId string, deploymentId string) (result []DeploymentMetadata, err error, code int)

func (*ProcessDeployment) GetGroup

func (this *ProcessDeployment) GetGroup(token auth.Token, id string) (result DeviceGroup, err error)

func (*ProcessDeployment) IsFogDeployment

func (this *ProcessDeployment) IsFogDeployment(token auth.Token, task model.CamundaExternalTask, deployment deploymentmodel.Deployment) (isFogDeployment bool, hubId string, err error)

func (*ProcessDeployment) PrepareRequest

func (this *ProcessDeployment) PrepareRequest(token auth.Token, processId string) (deployment deploymentmodel.Deployment, err error)

func (*ProcessDeployment) Undo

func (this *ProcessDeployment) Undo(modules []model.Module, reason error)

func (*ProcessDeployment) UseVariables

func (this *ProcessDeployment) UseVariables(task model.CamundaExternalTask, deployment *deploymentmodel.Deployment) error

type SmartServiceRepo

type SmartServiceRepo interface {
	GetInstanceUser(instanceId string) (userId string, err error)
	UseModuleDeleteInfo(info model.ModuleDeleteInfo) error
}

type SyncInfo added in v0.0.23

type SyncInfo struct {
	NetworkId       string    `json:"network_id"`
	IsPlaceholder   bool      `json:"is_placeholder"`
	MarkedForDelete bool      `json:"marked_for_delete"`
	SyncDate        time.Time `json:"sync_date"`
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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