semaphoreclient

package
v1.322.0 Latest Latest
Warning

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

Go to latest
Published: Nov 4, 2026 License: AGPL-3.0 Imports: 9 Imported by: 0

Documentation

Overview

Package semaphoreclient is the Temporal client side of the mobile-device semaphore workflow, shared by the HTTP handlers and the enqueue activity.

Index

Constants

This section is empty.

Variables

View Source
var ErrRunTicketNotFound = errors.New("run ticket not found")

ErrRunTicketNotFound signals that a run ticket could not be located in a device queue.

Functions

func CancelRun

CancelRun removes a run ticket from the device semaphore.

func EnqueueRun

EnqueueRun enqueues a run ticket on the device semaphore, starting the semaphore workflow in the same call when it is not running.

func EnsureWorkflow

func EnsureWorkflow(ctx context.Context, c client.Client, deviceID string) error

EnsureWorkflow starts the device semaphore workflow unless it is already running.

func UpdateID

func UpdateID(prefix, deviceID, ticketID string) string

UpdateID builds the stable update ID of a semaphore update for a ticket.

Types

This section is empty.

Jump to

Keyboard shortcuts

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