NewTaskEvent (reference) in projects: dports

Project(s)

Full Search
Definition
Symbol
File Path
History
Type

Searched refs:NewTaskEvent (Results 1 – 25 of 46) sorted by relevance

/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/nomad/client/allocrunner/taskrunner/
H A D	vault_hook.go	`212 structs.NewTaskEvent(structs.TaskKilling). 239 structs.NewTaskEvent(structs.TaskKilling). 245 …event := structs.NewTaskEvent(structs.TaskSignaling).SetTaskSignal(s).SetDisplayMessage("Vault: ne… 249 structs.NewTaskEvent(structs.TaskKilling). 257 structs.NewTaskEvent(structs.TaskRestartSignal). 305 structs.NewTaskEvent(structs.TaskKilling). 315 structs.NewTaskEvent(structs.TaskKilling).`
H A D	errors_test.go	`26 ev := structs.NewTaskEvent("test event") 45 ev := structs.NewTaskEvent("test event")`
H A D	task_runner_test.go	125 tr.Kill(context.Background(), structs.NewTaskEvent("cleanup")) 151 defer origTR.Kill(context.Background(), structs.NewTaskEvent("cleanup")) 167 defer newTR.Kill(context.Background(), structs.NewTaskEvent("cleanup")) 205 origTR.Kill(context.Background(), structs.NewTaskEvent("cleanup")) 246 newTR.Kill(context.Background(), structs.NewTaskEvent("cleanup")) 484 defer tr.Kill(context.Background(), structs.NewTaskEvent("cleanup")) 639 defer tr.Kill(context.Background(), structs.NewTaskEvent("cleanup")) 746 defer tr.Kill(context.Background(), structs.NewTaskEvent("cleanup")) 1066 defer tr.Kill(context.Background(), structs.NewTaskEvent("cleanup")) 1115 defer tr.Kill(context.Background(), structs.NewTaskEvent("cleanup")) [all …]
H A D	artifact_hook.go	`43 h.eventEmitter.EmitEvent(structs.NewTaskEvent(structs.TaskDownloadingArtifacts)) 60 …herr := NewHookError(wrapped, structs.NewTaskEvent(structs.TaskArtifactDownloadFailed).SetDownload…`
H A D	task_runner.go	344 tr.appendEvent(structs.NewTaskEvent(structs.TaskReceived)) 410 event := structs.NewTaskEvent(structs.TaskSetupFailure). 628 event := structs.NewTaskEvent(structs.TaskTerminated). 666 tr.EmitEvent(structs.NewTaskEvent(state)) 714 tr.EmitEvent(structs.NewTaskEvent(structs.TaskFailedValidation).SetValidationError(parseErr)) 745 tr.EmitEvent(structs.NewTaskEvent(structs.TaskDriverFailure).SetDriverError(taskErr)) 752 tr.EmitEvent(structs.NewTaskEvent(structs.TaskDriverFailure).SetDriverError(taskErr)) 758 tr.EmitEvent(structs.NewTaskEvent(structs.TaskDriverFailure).SetDriverError(err)) 778 tr.UpdateState(structs.TaskStateRunning, structs.NewTaskEvent(structs.TaskStarted)) 969 ev := structs.NewTaskEvent(structs.TaskRestoreFailed). [all …]
H A D	task_dir_hook.go	`61 h.runner.EmitEvent(structs.NewTaskEvent(structs.TaskSetup).SetMessage(structs.TaskBuildingTaskDir))`
H A D	template_hook.go	`152 structs.NewTaskEvent(structs.TaskKilling).`
/dports/sysutils/nomad/nomad-1.1.0/client/allocrunner/taskrunner/
H A D	vault_hook.go	`212 structs.NewTaskEvent(structs.TaskKilling). 239 structs.NewTaskEvent(structs.TaskKilling). 245 …event := structs.NewTaskEvent(structs.TaskSignaling).SetTaskSignal(s).SetDisplayMessage("Vault: ne… 249 structs.NewTaskEvent(structs.TaskKilling). 257 structs.NewTaskEvent(structs.TaskRestartSignal). 305 structs.NewTaskEvent(structs.TaskKilling). 315 structs.NewTaskEvent(structs.TaskKilling).`
H A D	task_runner_test.go	134 tr.Kill(context.Background(), structs.NewTaskEvent("cleanup")) 228 defer tr.Kill(context.Background(), structs.NewTaskEvent("cleanup")) 236 err = tr.Kill(ctx, structs.NewTaskEvent("shutdown")) 329 origTR.Kill(context.Background(), structs.NewTaskEvent("cleanup")) 370 newTR.Kill(context.Background(), structs.NewTaskEvent("cleanup")) 608 defer tr.Kill(context.Background(), structs.NewTaskEvent("cleanup")) 763 defer tr.Kill(context.Background(), structs.NewTaskEvent("cleanup")) 870 defer tr.Kill(context.Background(), structs.NewTaskEvent("cleanup")) 1191 defer tr.Kill(context.Background(), structs.NewTaskEvent("cleanup")) 1269 defer tr.Kill(context.Background(), structs.NewTaskEvent("cleanup")) [all …]
H A D	errors_test.go	`26 ev := structs.NewTaskEvent("test event") 45 ev := structs.NewTaskEvent("test event")`
H A D	task_runner.go	388 tr.appendEvent(structs.NewTaskEvent(structs.TaskReceived)) 454 event := structs.NewTaskEvent(structs.TaskSetupFailure). 695 event := structs.NewTaskEvent(structs.TaskTerminated). 733 tr.EmitEvent(structs.NewTaskEvent(state)) 788 tr.EmitEvent(structs.NewTaskEvent(structs.TaskFailedValidation).SetValidationError(parseErr)) 819 tr.EmitEvent(structs.NewTaskEvent(structs.TaskDriverFailure).SetDriverError(taskErr)) 826 tr.EmitEvent(structs.NewTaskEvent(structs.TaskDriverFailure).SetDriverError(taskErr)) 832 tr.EmitEvent(structs.NewTaskEvent(structs.TaskDriverFailure).SetDriverError(err)) 852 tr.UpdateState(structs.TaskStateRunning, structs.NewTaskEvent(structs.TaskStarted)) 1103 ev := structs.NewTaskEvent(structs.TaskRestoreFailed). [all …]
H A D	artifact_hook.go	`43 h.eventEmitter.EmitEvent(structs.NewTaskEvent(structs.TaskDownloadingArtifacts)) 61 …herr := NewHookError(wrapped, structs.NewTaskEvent(structs.TaskArtifactDownloadFailed).SetDownload…`
H A D	plugin_supervisor_hook.go	`200 event := structs.NewTaskEvent(structs.TaskPluginHealthy) 212 event := structs.NewTaskEvent(structs.TaskPluginUnhealthy) 233 event := structs.NewTaskEvent(structs.TaskPluginHealthy) 240 event := structs.NewTaskEvent(structs.TaskPluginUnhealthy)`
H A D	remotetask_hook.go	`87 h.tr.UpdateState(structs.TaskStateRunning, structs.NewTaskEvent(structs.TaskStarted))`
H A D	task_dir_hook.go	`62 h.runner.EmitEvent(structs.NewTaskEvent(structs.TaskSetup).SetMessage(structs.TaskBuildingTaskDir))`
H A D	template_hook.go	`173 structs.NewTaskEvent(structs.TaskKilling).`
H A D	sids_hook.go	`210 structs.NewTaskEvent(structs.TaskKilling).`
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/nomad/client/allocrunner/taskrunner/template/
H A D	template.go	211 structs.NewTaskEvent(structs.TaskKilling). 258 structs.NewTaskEvent(structs.TaskKilling). 338 …tm.config.Events.EmitEvent(structs.NewTaskEvent(consulTemplateSourceName).SetDisplayMessage(fmt.Sp… 361 structs.NewTaskEvent(structs.TaskKilling). 389 structs.NewTaskEvent(structs.TaskKilling). 399 structs.NewTaskEvent(structs.TaskKilling). 444 structs.NewTaskEvent(structs.TaskRestartSignal). 450 …event := structs.NewTaskEvent(structs.TaskSignaling).SetTaskSignal(s).SetDisplayMessage("Template … 463 structs.NewTaskEvent(structs.TaskKilling).
/dports/sysutils/nomad/nomad-1.1.0/client/allocrunner/taskrunner/template/
H A D	template.go	218 structs.NewTaskEvent(structs.TaskKilling). 265 structs.NewTaskEvent(structs.TaskKilling). 356 …tm.config.Events.EmitEvent(structs.NewTaskEvent(consulTemplateSourceName).SetDisplayMessage(fmt.Sp… 379 structs.NewTaskEvent(structs.TaskKilling). 413 structs.NewTaskEvent(structs.TaskKilling). 423 structs.NewTaskEvent(structs.TaskKilling). 468 structs.NewTaskEvent(structs.TaskRestartSignal). 474 …event := structs.NewTaskEvent(structs.TaskSignaling).SetTaskSignal(s).SetDisplayMessage("Template … 487 structs.NewTaskEvent(structs.TaskKilling).
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/nomad/nomad/structs/
H A D	structs_test.go	4335 prepopulatedEvent := NewTaskEvent(TaskSetup) 4343 {NewTaskEvent(TaskSetup).SetMessage("Setup"), "Setup"}, 4344 {NewTaskEvent(TaskStarted), "Task started by client"}, 4345 {NewTaskEvent(TaskReceived), "Task received by client"}, 4348 {NewTaskEvent(TaskSetupFailure), "Task setup failed"}, 4350 {NewTaskEvent(TaskDriverFailure), "Failed to start task"}, 4356 {NewTaskEvent(TaskKilling), "Sent interrupt"}, 4361 {NewTaskEvent(TaskKilled), "Task successfully killed"}, 4366 {NewTaskEvent(TaskSiblingFailed), "Task's sibling failed"}, 4368 {NewTaskEvent(TaskSignaling), "Task being sent a signal"}, [all …]
/dports/sysutils/nomad/nomad-1.1.0/nomad/structs/
H A D	structs_test.go	5302 prepopulatedEvent := NewTaskEvent(TaskSetup) 5310 {NewTaskEvent(TaskSetup).SetMessage("Setup"), "Setup"}, 5311 {NewTaskEvent(TaskStarted), "Task started by client"}, 5312 {NewTaskEvent(TaskReceived), "Task received by client"}, 5315 {NewTaskEvent(TaskSetupFailure), "Task setup failed"}, 5317 {NewTaskEvent(TaskDriverFailure), "Failed to start task"}, 5323 {NewTaskEvent(TaskKilling), "Sent interrupt"}, 5328 {NewTaskEvent(TaskKilled), "Task successfully killed"}, 5333 {NewTaskEvent(TaskSiblingFailed), "Task's sibling failed"}, 5335 {NewTaskEvent(TaskSignaling), "Task being sent a signal"}, [all …]
/dports/sysutils/nomad/nomad-1.1.0/client/allocrunner/
H A D	alloc_runner.go	`528 killEvent = structs.NewTaskEvent(structs.TaskSiblingFailed). 532 killEvent = structs.NewTaskEvent(structs.TaskLeaderDead) 538 killEvent = structs.NewTaskEvent(structs.TaskMainDead) 603 taskEvent := structs.NewTaskEvent(structs.TaskKilling) 626 taskEvent := structs.NewTaskEvent(structs.TaskKilling) 1202 event := structs.NewTaskEvent(structs.TaskSignaling).SetSignalText(signal)`
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/nomad/client/allocrunner/
H A D	alloc_runner.go	`446 killEvent = structs.NewTaskEvent(structs.TaskSiblingFailed). 450 killEvent = structs.NewTaskEvent(structs.TaskLeaderDead) 512 taskEvent := structs.NewTaskEvent(structs.TaskKilling) 534 taskEvent := structs.NewTaskEvent(structs.TaskKilling) 1060 event := structs.NewTaskEvent(structs.TaskSignaling).SetSignalText(signal)`
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/nomad/command/agent/
H A D	deployment_endpoint_test.go	`91 testEvent := structs.NewTaskEvent(structs.TaskSiblingFailed) 103 testEvent2 := structs.NewTaskEvent(structs.TaskSiblingFailed)`
/dports/sysutils/nomad/nomad-1.1.0/command/agent/
H A D	deployment_endpoint_test.go	`91 testEvent := structs.NewTaskEvent(structs.TaskSiblingFailed) 103 testEvent2 := structs.NewTaskEvent(structs.TaskSiblingFailed)`