Something went wrong. Try again.
Monorepo for Tangled
Something went wrong. Try again.
12345678910111213141516171819202122232425262728293031323334353637package knotacl
import ( "context" "log/slog" "time"
"tangled.org/core/appview/db" "tangled.org/core/appview/knotcompat")
const latchOpTimeout = 5 * time.Second
type latch struct { execer db.Execer log *slog.Logger}
func NewLatch(execer db.Execer, logger *slog.Logger) knotcompat.NativeLatch { return latch{execer: execer, log: logger}}
func (l latch) IsNative(host string) bool { ctx, cancel := context.WithTimeout(context.Background(), latchOpTimeout) defer cancel() native, err := db.IsKnotAclNative(ctx, l.execer, host) return err == nil && native}
func (l latch) MarkNative(host string) { ctx, cancel := context.WithTimeout(context.Background(), latchOpTimeout) defer cancel() if err := db.MarkKnotAclNative(ctx, l.execer, host); err != nil { l.log.Error("failed to persist native knot latch, it will be re-probed after restart", "host", host, "err", err) }}