kernelnodeops

package

Go to main page

Versions in this module

v4

v4.2.1

Oct 12, 2026

v4.2.0

Oct 11, 2026

Changes in this version

+ const ForwardConfigFormat

+ func AgentAckJSON(ack any) []byte

+ func AgentControlConnectionJSON(connection any) []byte

+ func AgentListEntryJSON(session agentstreams.Session, now time.Time) []byte

+ func AgentMonitorJSON(nodeID uint, system map[string]any, updatedAt time.Time) []byte

+ func AgentObservedStateJSON(observed *agentv1pb.ObservedState) []byte

+ func AgentTaskJSON(row *model.AgentDiagnosticTask) []byte

+ func ConfigApplied(ctx context.Context, db *gorm.DB, node agentcontrol.AgentNode, ...) (bool, error)

+ func ConfigStatusErrorCode(status *agentv1pb.ConfigStatus) string

+ func SetDiagnosticResultGraceForTest(grace time.Duration) (restore func())

+ func SortAgentSessions(sessions []agentstreams.Session)

type Acceptance

+ Result *kernelnodeopsv1.OperationResult

type AgentDiagnostic

+ func RunAgentDiagnosticOnStream(ctx context.Context, db *gorm.DB, sources AgentSources, ...) (*AgentDiagnostic, bool, error)

+ type ForwardChecks struct

+ Sources SourcesFunc

+ func (c ForwardChecks) Check(ctx context.Context, node agentcontrol.AgentNode, action string, ...) (*kernelforward.CheckResult, error)

+ func (c ForwardChecks) Vantage(node agentcontrol.AgentNode) kernelforward.NodeVantage

v4.2.0-rc.4

Oct 9, 2026

v4.2.0-rc.3

Oct 9, 2026

v4.2.0-rc.2

Oct 5, 2026

v4.2.0-rc.1

Oct 5, 2026

v4.1.0

Oct 4, 2026

Changes in this version

+ const AgentDiagnosticOperation

+ const AgentDiagnosticTaskType

+ const AgentEnrollmentActor

+ const DefaultAgentAckTimeout

+ const DefaultJobPoll

+ const DefaultMaxRunning

+ const DefaultNodeQuota

+ const DefaultPackageQuota

+ const DefaultPollInterval

+ const DefaultTimeout

+ const DesiredConfigFormat

+ const DiagnosisAgentCapability

+ const DiagnosisAgentCapabilityVersion

+ const EventRetention

+ const KindAgentDiagnostic

+ const KindAgentOperation

+ const KindCleanAgentIssue

+ const KindCredentialIssue

+ const KindCredentialRevoke

+ const KindDiagnoseEndpoints

+ const KindDiagnoseForward

+ const KindDiagnoseForwardBackend

+ const KindDiagnoseNodeStats

+ const KindDiagnoseTunnel

+ const KindForwardApply

+ const KindForwardLegacyRule

+ const KindForwardSyncBackend

+ const KindForwardTunnel

+ const KindNodeRetire

+ const KindNodeSync

+ const KindProtocolRetire

+ const KindRegKeyIssue

+ const KindRegKeyRevoke

+ const KindSecretsPut

+ const MaxAgentAckTimeout

+ const MaxWait

+ const NodeReloadOperation

+ const OperationRetention

+ const RevealAPIKey

+ const RevealAPIToken

+ const RevealCredential

+ const RevealKey

+ const RevealSecret

+ const RevealToken

+ const SealedPrefix

+ var DefaultExecutors = NewRegistry()

+ var ErrNoRequestBinding = errors.New("the operation has no live request binding")

+ var ErrNodeGone = errors.New("node does not exist")

+ var ErrOperationEnded = errors.New("node operation has ended")

+ func ConfigLaggingNodes(ctx context.Context, db *gorm.DB) (int64, error)

+ func ConfigSnapshotOf(row model.KernelNodeDesiredConfig) *agentv1pb.ConfigSnapshot

+ func ConfigVerdict(desired model.KernelNodeDesiredConfig, found bool, ...) string

+ func DialTarget() sealedsecrets.Target

+ func FamilyOfKind(name string) kernelnodeopsv1.OperationFamily

+ func KnownKinds() []string

+ func LoadConfigStatus(ctx context.Context, db *gorm.DB, node agentcontrol.AgentNode) (model.KernelNodeConfigStatus, bool, error)

+ func LoadDesiredConfig(ctx context.Context, db *gorm.DB, node agentcontrol.AgentNode) (model.KernelNodeDesiredConfig, bool, error)

+ func NewTaskID() string

+ func NodeTarget(ref *kernelnodeopsv1.NodeRef) sealedsecrets.Target

+ func RecordConfigStatus(ctx context.Context, db *gorm.DB, node agentcontrol.AgentNode, ...) (string, error)

+ func RefreshDesiredConfig(ctx context.Context, db *gorm.DB, node agentcontrol.AgentNode, now time.Time) (model.KernelNodeDesiredConfig, bool, error)

+ func RegisterNodeOperationExecutors(registry *Registry, sources SourcesFunc) error

+ func SplitPhasesFrom(db *gorm.DB) func(ctx context.Context) ([]*kernelnodeopsv1.TableSplitState, error)

+ func StoreDesiredConfig(ctx context.Context, db *gorm.DB, cfg *DesiredConfig, now time.Time) (model.KernelNodeDesiredConfig, bool, error)

+ func Terminal(state string) bool

+ func UseAgentStreams(streams agentstreams.Streams)

+ func UseWebSocketAgents(agents agentstreams.WebSockets)

+ type Acceptance struct

+ Channel kernelnodeopsv1.Channel

+ ForwardRuntimeJobID uint64

+ KernelOperationID string

+ NodeRevision uint64

+ type AdminError struct

+ Code string

+ Message string

+ Retryable bool

+ type AdminFanOut struct

+ Failed uint32

+ Pending uint32

+ Succeeded uint32

+ Total uint32

+ type AdminOperation struct

+ AcceptedAt *time.Time

+ Attempt uint32

+ CancelReason string

+ CancelRequestedAt *time.Time

+ Channel string

+ CreatedAt time.Time

+ Cursor uint64

+ DeadlineAt time.Time

+ Digest string

+ Error *AdminError

+ Evidence json.RawMessage

+ Family string

+ FanOut *AdminFanOut

+ FinishedAt *time.Time

+ ForwardRuntimeJobID uint64

+ KernelOperationID string

+ Kind string

+ NodeRevision uint64

+ Operation json.RawMessage

+ OperationID string

+ PackageGeneration uint64

+ PackageID string

+ ParentOperationID string

+ Reason string

+ RequestID string

+ Resource string

+ Result json.RawMessage

+ State string

+ SubmittedBy string

+ Targets []AdminTarget

+ Terminal bool

+ UpdatedAt time.Time

+ type AdminPage struct

+ NextBefore uint64

+ Operations []AdminOperation

+ func AdminList(ctx context.Context, db *gorm.DB, query AdminQuery) (AdminPage, error)

+ type AdminQuery struct

+ Before uint64

+ Family string

+ Kind string

+ Limit int

+ OperationID string

+ PackageID string

+ Parent string

+ RequestID string

+ State string

+ TargetID uint64

+ TargetKind string

+ func ParseAdminQuery(get func(string) string) (AdminQuery, error)

+ type AdminTarget struct

+ ID uint64

+ Kind string

+ type AgentDiagnostic struct

+ Dispatch agentstreams.DiagnosticDispatch

+ Row *model.AgentDiagnosticTask

+ Task agentstreams.DiagnosticTask

+ func RunAgentDiagnostic(ctx context.Context, db *gorm.DB, request AgentDiagnosticRequest, ...) (*AgentDiagnostic, error)

+ type AgentDiagnosticRequest struct

+ Action string

+ NodeID uint

+ Params map[string]any

+ Timeout int

+ type AgentDirectory interface

+ Advertises func(node *kernelnodeopsv1.NodeRef, name, version string) bool

+ type AgentOperation struct

+ Ack *agentv1pb.OperationAck

+ Desired *agentv1pb.DesiredOperation

+ func DispatchAgentOperation(ctx context.Context, streams agentstreams.Streams, node agentcontrol.AgentNode, ...) (*AgentOperation, error)

+ func (o *AgentOperation) Release()

+ type AgentOperationRequest struct

+ Kind string

+ OperationID string

+ PayloadJSON []byte

+ Timeout time.Duration

+ type AgentSources struct

+ Streams agentstreams.Streams

+ WebSockets agentstreams.WebSockets

+ func DefaultAgentSources() AgentSources

+ type Authorizer interface

+ AuthorizeCapability func(ctx context.Context, host packagebridge.HostIdentity, capability string) error

+ type BoundRequest struct

+ ActorID uint64

+ Admin bool

+ Deadline time.Time

+ RequestID string

+ RouteID string

+ type ConnectionTest struct

+ Now func() time.Time

+ Probes service.DiagnosisProbes

+ func (c *ConnectionTest) Execute(ctx context.Context, run *Run) Outcome

+ func (c *ConnectionTest) Held() int

+ func (c *ConnectionTest) Prepare(_ context.Context, submission *Submission) error

+ func (c *ConnectionTest) Register(registry *Registry) error

+ type Credentials struct

+ PKI func(ctx context.Context, tx *gorm.DB) (*agentpki.Service, error)

+ func (c *Credentials) Register(registry *Registry) error

+ type DesiredConfig struct

+ Document map[string]any

+ ExcludedProtocols uint32

+ Format string

+ Hash string

+ JSON []byte

+ Node agentcontrol.AgentNode

+ func BuildDesiredConfig(db *gorm.DB, node agentcontrol.AgentNode) (*DesiredConfig, error)

+ type Diagnosis struct

+ Agents AgentDirectory

+ Now func() time.Time

+ Probes service.DiagnosisProbes

+ func (d *Diagnosis) Register(registry *Registry) error

+ type DiagnosticValidationError struct

+ Err error

+ func (e *DiagnosticValidationError) Error() string

+ func (e *DiagnosticValidationError) Unwrap() error

+ type Engine struct

+ DB *gorm.DB

+ Executors *Registry

+ MaxRunning int

+ NodeQuota int

+ Now func() time.Time

+ PackageQuota int

+ PollInterval time.Duration

+ Secrets *sealedsecrets.Store

+ Timeout time.Duration

+ func EngineFor(db *gorm.DB) *Engine

+ func (e *Engine) Prune(ctx context.Context, now time.Time) (int64, error)

+ func (e *Engine) Run(ctx context.Context)

+ func (e *Engine) Wake()

+ type Executor interface

+ Execute func(ctx context.Context, run *Run) Outcome

+ type ExecutorFunc func(ctx context.Context, run *Run) Outcome

+ func (f ExecutorFunc) Execute(ctx context.Context, run *Run) Outcome

+ type Forward struct

+ JobPoll time.Duration

+ Now func() time.Time

+ func (f *Forward) Register(registry *Registry) error

+ type NodeSync struct

+ Ack *agentv1pb.OperationAck

+ Changed bool

+ Channel kernelnodeopsv1.Channel

+ Config *DesiredConfig

+ Desired *agentv1pb.DesiredOperation

+ DispatchErr error

+ Node agentcontrol.AgentNode

+ Pushed bool

+ SessionID string

+ Snapshot *agentv1pb.ConfigSnapshot

+ Stored model.KernelNodeDesiredConfig

+ func SyncNode(ctx context.Context, db *gorm.DB, streams agentstreams.Streams, ...) (*NodeSync, error)

+ func (s *NodeSync) Release()

+ type Outcome struct

+ func Cancelled(message string) Outcome

+ func Failed(code kernelnodeopsv1.ErrorCode, message string, retryable bool) Outcome

+ func FanOut(children ...*kernelnodeopsv1.OperationSpec) Outcome

+ func Succeeded(result *kernelnodeopsv1.OperationResult) Outcome

+ func (o Outcome) WithChannel(channel kernelnodeopsv1.Channel) Outcome

+ func (o Outcome) WithResult(result *kernelnodeopsv1.OperationResult) Outcome

+ type Preparer interface

+ Prepare func(ctx context.Context, submission *Submission) error

+ type QueryError struct

+ Message string

+ func (e *QueryError) Error() string

+ type Registry struct

+ func NewRegistry() *Registry

+ func (r *Registry) Kinds() []string

+ func (r *Registry) Lookup(kindName string) (Executor, bool)

+ func (r *Registry) Register(kindName string, executor Executor) error

+ type Retirements struct

+ func (r *Retirements) Register(registry *Registry) error

+ type Run struct

+ Attempt uint32

+ Deadline time.Time

+ Kind string

+ Operation *kernelnodeopsv1.OperationSpec

+ OperationID string

+ PackageID string

+ ParentOperationID string

+ Request *BoundRequest

+ RequestID string

+ Targets []*kernelnodeopsv1.NodeRef

+ func (r *Run) Accept(ctx context.Context, acceptance Acceptance) error

+ func (r *Run) DB() *gorm.DB

+ func (r *Run) Prepared() any

+ func (r *Run) Reveal(name, value string) (*kernelnodeopsv1.SecretHandle, error)

+ func (r *Run) UseSecret(values ...string)

+ type SecretDocuments struct

+ func (s *SecretDocuments) Register(registry *Registry) error

+ type Server struct

+ Agents *AgentSources

+ Authorizer Authorizer

+ Engine *Engine

+ SplitPhases func(ctx context.Context) ([]*kernelnodeopsv1.TableSplitState, error)

+ func (s *Server) For(host packagebridge.HostIdentity) kernelnodeopsv1.KernelNodeOpsServer

+ type SourcesFunc func() AgentSources

+ type Submission struct

+ Binding []byte

+ Host packagebridge.HostIdentity

+ Kind string

+ Operation *kernelnodeopsv1.OperationSpec

+ Request *BoundRequest

+ Targets []*kernelnodeopsv1.NodeRef

+ func (s *Submission) Retain(value any)

+ func (s *Submission) Unseal(uses ...sealedsecrets.Use) ([]sealedsecrets.Secret, error)

+ type SyncNodeOptions struct

+ AckTimeout time.Duration

+ Force bool

+ Now func() time.Time

v4.1.0-rc.6

Oct 3, 2026

v4.1.0-rc.5

Oct 2, 2026

v4.1.0-rc.4

Oct 2, 2026

v4.1.0-rc.3

Oct 2, 2026

v4.1.0-rc.2

Oct 1, 2026

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