server

type Billing interface {
	Balance(uid string) int64
	// Debit returns ErrInsufficient when the balance cannot cover atoms.
	Debit(uid string, atoms int64) error
	Credit(uid string, atoms int64) error
}

type Harness struct {
	// contains filtered or unexported fields
}

type HarnessConfig struct {
	// DataDir holds the built-in ledger. Required unless Billing is set.
	DataDir string
	// AllowedPeers is the default-deny caller allowlist (64-hex uids).
	AllowedPeers []string
	// AllowFunc, when non-nil, replaces the allowlist entirely (e.g. an
	// open service that admits every KX'd caller and lets billing and
	// rate limits do the gating).
	AllowFunc func(uid string) bool
	// Billing, when non-nil, replaces the built-in ledger for balance
	// reads, debits, and credits.
	Billing Billing
	// CallsPerMinute rate-limits each caller. Zero selects 30.
	CallsPerMinute int
	// TTL/ChunkSize/Assembler tune the transport (zero = defaults).
	TTL       time.Duration
	ChunkSize int
	Logf      func(format string, args ...any)
}

type Ledger struct {
	// contains filtered or unexported fields
}

type PriceFunc[In any] func(ctx context.Context, peer string, in In) (atoms int64, err error)

type TipJournal struct {
	// contains filtered or unexported fields
}