Skip to content

Commit bd8773f

Browse files
committed
Update sample to use new sysinfo lib, resourcetuner moved into worker
lib
1 parent 400ac77 commit bd8773f

1 file changed

Lines changed: 13 additions & 8 deletions

File tree

docs/develop/worker-performance.mdx

Lines changed: 13 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -448,12 +448,16 @@ These examples focus on Activities and Local Activities, since Workflow Tasks no
448448
### Go SDK
449449

450450
```go
451-
import "go.temporal.io/sdk/contrib/resourcetuner"
451+
import (
452+
"go.temporal.io/sdk/contrib/sysinfo"
453+
"go.temporal.io/sdk/worker"
454+
)
452455

453456
// Using the ResourceBasedTuner in worker options
454-
tuner, err := resourcetuner.NewResourceBasedTuner(resourcetuner.ResourceBasedTunerOptions{
455-
TargetMem: 0.8,
456-
TargetCpu: 0.9,
457+
tuner, err := worker.NewResourceBasedTuner(worker.ResourceBasedTunerOptions{
458+
TargetMem: 0.8,
459+
TargetCpu: 0.9,
460+
InfoSupplier: sysinfo.SysInfoProvider(),
457461
})
458462
if err != nil {
459463
return err
@@ -463,17 +467,18 @@ workerOptions := worker.Options{
463467
}
464468

465469
// Customize the tuner
466-
options := resourcetuner.DefaultResourceControllerOptions()
470+
options := worker.DefaultResourceControllerOptions()
467471
options.MemTargetPercent = 0.8
468472
options.CpuTargetPercent = 0.9
469-
controller := resourcetuner.NewResourceController(options)
473+
options.InfoSupplier = sysinfo.SysInfoProvider()
474+
controller := worker.NewResourceController(options)
470475
wfSS, err := worker.NewFixedSizeSlotSupplier(10)
471476
if err != nil {
472477
return err
473478
}
474479

475-
actSS, err := resourcetuner.NewResourceBasedSlotSupplier(controller, resourcetuner.DefaultActivityResourceBasedSlotSupplierOptions())
476-
laSS, err := resourcetuner.NewResourceBasedSlotSupplier(controller, resourcetuner.DefaultActivityResourceBasedSlotSupplierOptions())
480+
actSS, err := worker.NewResourceBasedSlotSupplier(controller, worker.DefaultActivityResourceBasedSlotSupplierOptions())
481+
laSS, err := worker.NewResourceBasedSlotSupplier(controller, worker.DefaultActivityResourceBasedSlotSupplierOptions())
477482
nexusSS, err := worker.NewFixedSizeSlotSupplier(10)
478483
if err != nil {
479484
return err

0 commit comments

Comments
 (0)