runneractivity

package
v0.9.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 14, 2026 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Package runneractivity carries only current-connection activity between the proxy and daemon. It is not audit storage; reconnect invalidates all markers.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Capture 

func Capture(dir string) uuid.UUID

Capture must run at request admission, not when an old request later finishes.

func Publish 

func Publish(dir string, epoch uuid.UUID) error

Publish switches the local channel to a fresh started connection. Nil removes admission authority. Reads never accept a partly written epoch.

func Record 

func Record(dir string, epoch uuid.UUID) error

Record coalesces live activity. Caller serializes writes; no durable replay path calls it. Offline admission (nil epoch) cannot produce an activity signal.

Types

type Marker 

type Marker struct {
	Epoch uuid.UUID `json:"epoch"`
	ID    uuid.UUID `json:"id"`
}

Marker binds one newly admitted request to the connection present at admission.

func Read 

func Read(dir string) (Marker, error)

Read observes a whole replacement without deleting it: deleting after a read could erase a newer concurrent writer. The daemon deduplicates ID in memory.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.