node

package

Go to main page

Versions in this module

v0

v0.10.0

Sep 11, 2026

v0.9.3

Sep 6, 2026

Changes in this version

type ExecUpgrader

+ AckDir string

+ DSNEnv string

+ func (e ExecUpgrader) Check() error

v0.9.2

Sep 5, 2026

v0.9.1

Sep 5, 2026

v0.9.0

Sep 5, 2026

v0.8.0

Sep 5, 2026

Changes in this version

+ type CacheObserver interface

+ ObserveCache func(ctx context.Context, instance, leaseID string, epoch int64, ...) error

type CacheService

+ func (s *CacheService) SetCacheObserver(observer CacheObserver)

+ func (s *CacheService) SettleObservation(ctx context.Context, instance string)

type CacheSessionScope

+ Epoch int64

+ LeaseID string

type LeaseStore

+ RecordCacheObservation func(ctx context.Context, leaseID string, epoch int64, obs alloc.CacheObservation) error

type Runner

+ func (r *Runner) ObserveCache(ctx context.Context, instance, leaseID string, epoch int64, ...) error

v0.7.0

Sep 5, 2026

v0.6.1

Sep 4, 2026

v0.6.0

Sep 4, 2026

v0.5.0

Sep 3, 2026

Changes in this version

+ const AckAccepted

+ const AckFD

+ const AckRefused

+ const DefaultMaxCustody

+ const MaxAckBytes

+ var ErrNoUpgrader = errors.New("node: this node has no transactional updater")

+ var ErrUpgradeRefused = errors.New("node: the updater refused this upgrade")

+ type ActionsPolicy interface

+ ActionsCacheAllowed func(ctx context.Context, owner, repository string) (bool, error)

+ type CacheCredentials struct

+ ActionsCAPEM string

+ ActionsProxy string

+ Token string

+ type CacheService struct

+ func NewCacheService(endpoint string, namespace string, stateDir string, ...) (*CacheService, error)

+ func (s *CacheService) Cleanup(ctx context.Context, instance string) error

+ func (s *CacheService) Endpoint() string

+ func (s *CacheService) Prepare(instance string, trust provider.TrustClass) (CacheCredentials, error)

+ func (s *CacheService) PrepareScoped(instance string, scope CacheSessionScope) (CacheCredentials, error)

+ func (s *CacheService) ReconcileInventory(ctx context.Context, instances []*provider.Instance) error

+ func (s *CacheService) RenewActive(ctx context.Context, until time.Time) error

+ func (s *CacheService) RetryClosed(ctx context.Context) error

+ func (s *CacheService) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (s *CacheService) SetActionsPolicy(policy ActionsPolicy)

+ func (s *CacheService) SettleDocker(ctx context.Context, instance string, succeeded bool) error

+ type CacheSessionScope struct

+ Intercept bool

+ Owner string

+ Repository string

+ Trust provider.TrustClass

+ WorkflowRef string

+ type ExecUpgrader struct

+ Binary string

+ ConfigPath string

+ func (e ExecUpgrader) StartUpgrade(ctx context.Context, spec nodeapi.UpgradeSpec) error

+ type JITSource interface

+ Describe func(ctx context.Context, name, group string) (*Set, []string, error)

+ EnsureRunnerRemoved func(ctx context.Context, leaseID string) error

+ JITConfig func(ctx context.Context, scaleSetID int, runnerName, workFolder string) (Registration, error)

+ RecoverRunner func(ctx context.Context, leaseID, tier string, requestID int64, runnerName string) (RunnerRecovery, error)

+ RemoveRunner func(ctx context.Context, leaseID string, runnerID int64, runnerName string) error

+ type Job = server.Job

+ type LeaseStore interface

+ Advance func(ctx context.Context, leaseID string, epoch int64, to alloc.Phase) error

+ Bind func(ctx context.Context, leaseID string, epoch int64, node string) error

+ Heartbeat func(ctx context.Context, leaseID string, epoch int64) error

+ LaunchedLeaseIDs func(ctx context.Context, node string) (map[string]bool, error)

+ Lease func(ctx context.Context, leaseID string) (*alloc.Lease, error)

+ LeaseTTL func() time.Duration

+ MarkFailure func(ctx context.Context, leaseID string, epoch int64, reason string) error

+ QuarantinedLeaseIDs func(ctx context.Context, node string) (map[string]bool, error)

+ Reconcile func(ctx context.Context, node string, running []string) (int, error)

+ Release func(ctx context.Context, leaseID string, epoch int64, outcome alloc.Phase) error

+ Resize func(ctx context.Context, leaseID string, epoch int64, instanceType string, ...) error

+ type Option func(*Runner)

+ func WithCacheService(cache *CacheService) Option

+ func WithMaxCustody(d time.Duration) Option

+ func WithRegistryMirrors(mirrors config.RegistryMirrors) Option

+ func WithUpgrader(u Upgrader) Option

+ type Registration interface

+ Config func() string

+ ID func() int64

+ RunnerName func() string

+ type Runner struct

+ func New(a LeaseStore, node string, jit JITSource, p provider.Provider, ...) *Runner

+ func (r *Runner) AssumeCustody(ctx context.Context, lease *alloc.Lease, requestID int64) error

+ func (r *Runner) Destroy(ctx context.Context, requestID int64) error

+ func (r *Runner) DestroyCompleted(ctx context.Context, requestID int64, result string) error

+ func (r *Runner) Holding() bool

+ func (r *Runner) Instances(ctx context.Context) ([]string, error)

+ func (r *Runner) KeepAlive(ctx context.Context)

+ func (r *Runner) Launch(ctx context.Context, lease *alloc.Lease, tier *nodeapi.TierSpec, job Job) error

+ func (r *Runner) Recover(ctx context.Context) error

+ func (r *Runner) StartUpgrade(ctx context.Context, spec nodeapi.UpgradeSpec) error

+ func (r *Runner) Superseded()

+ func (r *Runner) Sweep(ctx context.Context) error

+ func (r *Runner) Tend(ctx context.Context) error

+ func (r *Runner) WatchInterruptions(ctx context.Context)

+ type RunnerRecovery string

+ const RunnerRecoveryBusy

+ const RunnerRecoveryRetired

+ const RunnerRecoveryTracked

+ type Set struct

+ ID int

+ Name string

+ type Upgrader interface

+ StartUpgrade func(ctx context.Context, spec nodeapi.UpgradeSpec) error

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