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. |
|
operatorclient
Package operatorclient connects an out-of-process operator to the engine's OperatorService: one Connect call registers one worker and returns the Session that streams its assigned actions, keeps its action set up to date and reports task progress.
|
Package operatorclient connects an out-of-process operator to the engine's OperatorService: one Connect call registers one worker and returns the Session that streams its assigned actions, keeps its action set up to date and reports task progress. |
|
rest
Package rest provides primitives to interact with the openapi HTTP API.
|
Package rest provides primitives to interact with the openapi HTTP API. |
|
streaming
Package streaming holds the machinery every long-lived gRPC stream client in this module shares: a stream whose underlying client is replaced on reconnect, the receive loop that drives it with backoff, and the error classification that decides between reconnecting and stopping.
|
Package streaming holds the machinery every long-lived gRPC stream client in this module shares: a stream whose underlying client is replaced on reconnect, the receive loop that drives it with backoff, and the error classification that decides between reconnecting and stopping. |
|
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
|
|
|
cli/profilestore
Package profilestore is the shared implementation of the Hatchet CLI's profile store (~/.hatchet/profiles.yaml by default).
|
Package profilestore is the shared implementation of the Hatchet CLI's profile store (~/.hatchet/profiles.yaml by default). |
|
serverlessoperator
Package serverlessoperator is the configuration of the hatchet-serverless-operator binary: the file struct its environment is bound onto and the validation of the values that must agree with each other.
|
Package serverlessoperator is the configuration of the hatchet-serverless-operator binary: the file struct its environment is bound onto and the validation of the values that must agree with each other. |
|
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. |
|
dagoperator/e2e
Package e2e holds tests that run the DAG operator against an in-process engine.
|
Package e2e holds tests that run the DAG operator against an in-process engine. |
|
hostgrpc
Package hostgrpc is the out-of-process operator host: it implements pkg/operator.Host over pkg/client/operatorclient, speaking OperatorService to the engine with a per-tenant API token from a TokenSource.
|
Package hostgrpc is the out-of-process operator host: it implements pkg/operator.Host over pkg/client/operatorclient, speaking OperatorService to the engine with a per-tenant API token from a TokenSource. |
|
operatortest
Package operatortest holds a sample contract operator for tests.
|
Package operatortest holds a sample contract operator for tests. |
|
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, partition) lease units, polls their endpoints' healthchecks, registers their workflows with the engine and delivers assigned tasks to the endpoints over signed HTTP or, for durable tasks, over a websocket relay.
|
Package serverlessoperator is the serverless operator core: it owns (tenant, partition) lease units, polls their endpoints' healthchecks, registers their workflows with the engine and delivers assigned tasks to the endpoints over signed HTTP or, for durable tasks, over a websocket relay. |
|
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 task invocation between the engine and a serverless endpoint over an operator-dialed websocket.
|
Package durable relays one task invocation between the engine and a serverless endpoint 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, partition) 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, partition) units with FOR UPDATE SKIP LOCKED, shedding above fair share, and a periodic sweep of expired process rows. |
|
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.