Directories
¶
| Path | Synopsis |
|---|---|
|
auth
|
|
|
keyset/gen
command
Command gen regenerates the embedded auth-disabled API token (keyset/token.jwt), signed with the committed private keyset.
|
Command gen regenerates the embedded auth-disabled API token (keyset/token.jwt), signed with the committed private keyset. |
|
Deprecated: This package is part of the legacy v0 workflow definition system.
|
Deprecated: This package is part of the legacy v0 workflow definition system. |
|
cloud/rest
Package rest provides primitives to interact with the openapi HTTP API.
|
Package rest provides primitives to interact with the openapi HTTP API. |
|
create
Deprecated: This package is part of the legacy v0 workflow definition system.
|
Deprecated: This package is part of the legacy v0 workflow definition system. |
|
rest
Package rest provides primitives to interact with the openapi HTTP API.
|
Package rest provides primitives to interact with the openapi HTTP API. |
|
Adapted from: https://github.com/hatchet-dev/hatchet-v1-archived/blob/3c2c13168afa1af68d4baaf5ed02c9d49c5f0323/cmd/cmdutils/interrupt.go
|
Adapted from: https://github.com/hatchet-dev/hatchet-v1-archived/blob/3c2c13168afa1af68d4baaf5ed02c9d49c5f0323/cmd/cmdutils/interrupt.go |
|
config
|
|
|
grpc
|
|
|
metrics/prometheus
Package prometheus registers the engine Prometheus collectors (global and tenant-labeled task metrics, pub/sub) and gates tenant series on entitlement.
|
Package prometheus registers the engine Prometheus collectors (global and tenant-labeled task metrics, pub/sub) and gates tenant series on entitlement. |
|
loadtest
|
|
|
Package migratediag provides redacted DSN summaries and uniform migration phase errors for hatchet-migrate and related migration binaries.
|
Package migratediag provides redacted DSN summaries and uniform migration phase errors for hatchet-migrate and related migration binaries. |
|
safeclient
Package safeclient provides an SSRF-hardened HTTP client for delivering outbound requests to user-supplied endpoints.
|
Package safeclient provides an SSRF-hardened HTTP client for delivering outbound requests to user-supplied endpoints. |
|
Package serverlessoperator is the serverless operator core: it owns (tenant, shard) lease units, polls their endpoints' healthchecks, registers their workflows with the engine through a link, and delivers assigned tasks to the endpoints over signed HTTP.
|
Package serverlessoperator is the serverless operator core: it owns (tenant, shard) lease units, polls their endpoints' healthchecks, registers their workflows with the engine through a link, and delivers assigned tasks to the endpoints over signed HTTP. |
|
contract
Package contract holds the parts of the serverless endpoint contract that are not protobuf messages: header names, the upgrade signature payload, wire constants and the protojson encoding every message travels in.
|
Package contract holds the parts of the serverless endpoint contract that are not protobuf messages: header names, the upgrade signature payload, wire constants and the protojson encoding every message travels in. |
|
durable
Package durable relays one durable task invocation between the engine, reached through a link.DurableChannel, and a serverless endpoint, reached over an operator-dialed websocket.
|
Package durable relays one durable task invocation between the engine, reached through a link.DurableChannel, and a serverless endpoint, reached over an operator-dialed websocket. |
|
internal/memrepo
Package memrepo is an in-memory repository.ServerlessRepository for unit tests of the serverless operator core and leaser.
|
Package memrepo is an in-memory repository.ServerlessRepository for unit tests of the serverless operator core and leaser. |
|
lease
Package lease is the serverless operator's process membership and unit ownership: one heartbeat row per process, fair-share claiming of (tenant, shard) units with FOR UPDATE SKIP LOCKED, shedding above fair share, and a periodic sweep of expired process rows.
|
Package lease is the serverless operator's process membership and unit ownership: one heartbeat row per process, fair-share claiming of (tenant, shard) units with FOR UPDATE SKIP LOCKED, shedding above fair share, and a periodic sweep of expired process rows. |
|
link
Package link defines the seam between the serverless operator core and the engine.
|
Package link defines the seam between the serverless operator core and the engine. |
|
link/enginelink
Package enginelink is the in-engine Link: a registration is an engine Worker row created and activated in process, an operator-backed dispatcher session that forwards assigned actions, and direct calls into the dispatcher for step events and durable invocations.
|
Package enginelink is the in-engine Link: a registration is an engine Worker row created and activated in process, an operator-backed dispatcher session that forwards assigned actions, and direct calls into the dispatcher for step events and durable invocations. |
|
link/grpclink
Package grpclink is the out-of-process Link: registrations are OperatorSessions opened over the engine's OperatorService with a per-tenant API token from a TenantTokenExchange.
|
Package grpclink is the out-of-process Link: registrations are OperatorSessions opened over the engine's OperatorService with a per-tenant API token from a TenantTokenExchange. |
|
testing
|
|
|
Deprecated: This package is part of the old generics-based v1 Go SDK.
|
Deprecated: This package is part of the old generics-based v1 Go SDK. |
|
factory
Deprecated: This package is part of the legacy v0 workflow definition system.
|
Deprecated: This package is part of the legacy v0 workflow definition system. |
|
features
Deprecated: This package is part of the legacy v0 workflow definition system.
|
Deprecated: This package is part of the legacy v0 workflow definition system. |
|
task
Deprecated: This package is part of the old generics-based v1 Go SDK.
|
Deprecated: This package is part of the old generics-based v1 Go SDK. |
|
worker
Deprecated: This package is part of the old generics-based v1 Go SDK.
|
Deprecated: This package is part of the old generics-based v1 Go SDK. |
|
workflow
Deprecated: This package is part of the old generics-based v1 Go SDK.
|
Deprecated: This package is part of the old generics-based v1 Go SDK. |
|
condition
Deprecated: This package is part of the legacy v0 workflow definition system.
|
Deprecated: This package is part of the legacy v0 workflow definition system. |
Click to show internal directories.
Click to hide internal directories.