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). |
|
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. |
|
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.