ranke

package module

Go to main page

Versions in this module

v0

v0.25.1

Aug 27, 2026

Changes in this version

type ClaimBuilder

+ func (b ClaimBuilder) WithDatedEDTF(d string) ClaimBuilder

v0.25.0

Aug 27, 2026

Changes in this version

+ var ErrDatedForm = errors.New(...)

+ func TemporalMidpointMs(s string) (int64, bool)

type ClaimBuilder

+ Dated string

+ func (b ClaimBuilder) WithDated(d string) ClaimBuilder

type ClaimParts

+ Dated string

type Collation

+ const CompareTemporal

type Node

+ Dated func() string

v0.25.0-rc.1

Aug 27, 2026

v0.24.0

Aug 25, 2026

Changes in this version

+ var ErrEdgeOrder = errors.New("ranke.verify: a claim's edges are inlined ascending by id(e) (`V-EORDER`)")

+ var ErrEnvelopeHeaders = errors.New(...)

v0.23.0

Aug 25, 2026

v0.22.0

Aug 25, 2026

Changes in this version

+ var ErrIDMismatch = errors.New("ranke.verify: the claim's id is not the hash of the envelope it is stored as")

+ var ErrQueryEnvelopeAxis = errors.New(...)

type Claim

+ Envelope func() ([]byte, error)

type ClaimBuilder

+ func (b ClaimBuilder) AllowInvalid() ClaimBuilder

type Detail

+ const DetailEnvelope

type ResultKind

+ const KindClaimEnvelope

+ const KindPathEnvelope

v0.21.0

Aug 19, 2026

Changes in this version

+ var ErrQueryLayerName = errors.New("ranke.Query: execution.layer names a layer, so a stated one may not be empty")

+ var ErrQueryOrderField = errors.New("ranke.Query: a sort key names the field it orders on")

v0.20.0

Aug 13, 2026

Changes in this version

+ var ErrDeleteMarkNoTarget = errors.New(...)

+ type SweepResult struct

+ Claims []Id

+ Contents []Id

+ func DeletePlanned(ctx context.Context, u Universe, heads []Id, now time.Time) (SweepResult, error)

type Universe

+ DeleteClaims func(ctx context.Context, ids []Id) error

+ DeleteContents func(ctx context.Context, hashes []Id) error

v0.19.1

Aug 13, 2026

Changes in this version

+ var ErrContentBothSlots = errors.New(...)

+ var ErrCreatedAtNotMonotone = errors.New("ranke.verify: claim is dated before a claim it references")

+ var ErrProvenanceMissing = errors.New(...)

+ var ErrRelationDirection = errors.New(...)

+ var ErrTimestampForm = errors.New(...)

+ var ErrUnknownTypeClass = errors.New("ranke.verify: type class is not one of the fixed set")

type QueryReport

+ func ReportOf(results []QueryResult) *QueryReport

type QueryResult

+ Report *QueryReport

+ func AppendReport(results []QueryResult, rep *QueryReport) []QueryResult

type ResultKind

+ const KindReport

v0.19.0

Aug 11, 2026

v0.18.0

Aug 11, 2026

v0.17.0

Aug 10, 2026

Changes in this version

type Edge

+ ContentComplete func() bool

type Node

+ ContentComplete func() bool

v0.16.2

Aug 6, 2026

Changes in this version

+ var ErrBranchNotFound = errors.New("ranke.Archive.GetBranch: branch not found")

v0.16.1

Aug 6, 2026

v0.16.0

Aug 6, 2026

v0.15.7

Aug 5, 2026

v0.15.6

Aug 5, 2026

v0.15.5

Aug 5, 2026

Changes in this version

+ func MarshalCBOR(v any) ([]byte, error)

v0.15.4

Aug 5, 2026

v0.15.3

Aug 5, 2026

Changes in this version

+ var ErrQueryBounds = errors.New("ranke.Query: value below the minimum the schema fixes for its field")

v0.15.2

Aug 5, 2026

v0.15.1

Aug 4, 2026

v0.15.0

Aug 4, 2026

v0.14.0

Aug 4, 2026

Changes in this version

+ const EdgeTypeDelete

+ const EdgeTypeExpiry

+ var ErrQueryComparisonForm = errors.New(...)

+ var ErrQueryEnum = errors.New("ranke.Query: value outside the set the schema fixes for its field")

+ var ErrQueryHops = errors.New(...)

+ var ErrQueryOverflow = errors.New("ranke.Query: Output.Content.Overflow is required (cutoff | omit | reference)")

+ var ErrQueryWhereForm = errors.New("ranke.Query: a where node is exactly one of and | or | not | {field, test}")

+ func EncodeQuery(q Query) ([]byte, error)

+ func ValidateQuery(q Query) error

type EdgeSubtype

+ const EdgeSubtypeDelete

+ const EdgeSubtypeDeleteAlias

+ const EdgeSubtypeExpiry

+ const EdgeSubtypeExpiryAlias

type NodeSubtype

+ const NodeSubtypeDelete

+ const NodeSubtypeDeleteAlias

+ const NodeSubtypeExpiry

+ const NodeSubtypeExpiryAlias

+ type OutputContent struct

+ Max int

+ Overflow Overflow

type Query

+ func DecodeQuery(data []byte) (Query, error)

v0.13.0

Aug 4, 2026

Changes in this version

+ const FieldDeleteBy

+ const FieldDeleteByAlias

+ const FieldEdgesDiffOmitAlias

+ const FieldFieldsDiffOmitAlias

+ const FieldPubkeyExpiresAfter

+ const FieldPubkeyExpiresAfterAlias

+ const FieldPubkeyValidFrom

+ const FieldPubkeyValidFromAlias

+ var ErrDeleteByNotCopied = errors.New(...)

+ var ErrKeyExpired = errors.New(...)

+ var ErrKeyNotYetValid = errors.New("ranke.verify: claim is dated before its contributor key's pubkey_valid_from")

+ var ErrStructureNotDeletable = errors.New(...)

+ func CheckDeletable(class NodeClass, fields map[string]string) error

type EdgeConfig

+ Referenced Claim

type Graph

+ Cite func(ids ...Id)

type Id

+ func StrandedByDeletion(ctx context.Context, u Universe, heads []Id, own []Claim) ([]Id, error)

v0.12.0

Aug 4, 2026

Changes in this version

+ const TargetBranches

+ var ErrBranchNotCreatable = errors.New(...)

+ var ErrFutureDated = errors.New(...)

+ func AdmitCreatedAt(c Claim, base time.Time) error

type Archive

+ MissingBranches func(ctx context.Context, names []string) ([]string, error)

type Constraints

+ func (c Constraints) AdmitBranch(ctx context.Context, base Archive, branch string) error

type ContributionOption

+ func WithCreatableBranches(branches ...string) ContributionOption

type WireConstraints

+ Creatable []string

type WireKind

+ const WireCreatable

v0.11.0

Aug 4, 2026

Changes in this version

+ const ArchiveTagKey

+ var ErrUnreadableReference = errors.New(...)

+ var ErrWireLateConstraint = errors.New("ranke.Wire: every constraint record precedes the payload")

+ func DefaultClaimsInBranches(ctx context.Context, u Universe, branches map[string]Id, ids []Id) ([]bool, error)

type Constraints

+ func (c Constraints) AdmitReferences(ctx context.Context, u Universe, base Archive, branch string, own []Claim) error

type ContributionOption

+ func WithReferencableBranches(branches ...string) ContributionOption

type Universe

+ ClaimsInBranches func(ctx context.Context, branches map[string]Id, ids []Id) ([]bool, error)

+ type WireConstraints struct

+ Branches []string

+ Lifted []string

+ Referencable []string

+ func (w WireConstraints) Narrow(o WireConstraints) WireConstraints

+ func (w WireConstraints) Options() []ContributionOption

type WireKind

+ const WireBranches

+ const WireLifted

+ const WireReferencable

type WireReader

+ func (wr *WireReader) Constraints() (WireConstraints, error)

v0.10.0

Aug 3, 2026

Changes in this version

+ const NodeDelete

+ const NodeExpiry

+ var ErrReservedType = errors.New("ranke.Contribution: node type is the Sequencer's alone (lift it to add one)")

+ type Constraints struct

+ func NewConstraints(opts ...ContributionOption) Constraints

+ func (c Constraints) AdmitType(nodeType string) error

+ type ContributionOption func(*Constraints)

+ func WithLiftedTypes(types ...string) ContributionOption

v0.9.0

Aug 3, 2026

v0.8.0

Aug 3, 2026

v0.7.0

Jul 30, 2026

v0.6.0

Jul 30, 2026

Changes in this version

+ var ErrWire = errors.New("ranke.Wire")

+ var ErrWireKind = errors.New("ranke.Wire: unknown record kind (0 claim | 1 content | 2 header)")

+ var ErrWireNoBranch = errors.New("ranke.Wire: a claim record must name the branch it joins")

+ var ErrWireNoHeader = errors.New("ranke.Wire: a stream opens with a header record declaring its branches")

+ var ErrWireUndeclared = errors.New("ranke.Wire: claim names a branch the header does not declare")

type WireKind

+ const WireHeader

type WireReader

+ func (wr *WireReader) Branches() ([]string, error)

v0.5.0

Jul 30, 2026

Changes in this version

+ const WireMediaType

+ func DrainWire(ctx context.Context, c Contribution, u Universe, r io.Reader) error

type Contribution

+ AddWire func(ctx context.Context, r io.Reader) error

+ type WireKind uint64

+ const WireClaim

+ const WireContent

+ type WireReader struct

+ func NewWireReader(r io.Reader) *WireReader

+ func (wr *WireReader) Err() error

+ func (wr *WireReader) Next() bool

+ func (wr *WireReader) Record() WireRecord

+ type WireRecord struct

+ Blob ContentBlob

+ Branch string

+ Claim Claim

+ Kind WireKind

+ type WireWriter struct

+ func NewWireWriter(w io.Writer) *WireWriter

+ func (ww *WireWriter) WriteClaim(branch string, c Claim) error

+ func (ww *WireWriter) WriteContent(b ContentBlob) error

v0.4.0

Jul 30, 2026

Changes in this version

+ var ErrQueryEncoding = errors.New("ranke.Query: unknown Output.Encoding (native | json | cbor)")

+ func EncodeResults(results []QueryResult, out Output) error

type Claim

+ EncodeCBOR func(form Form) ([]byte, error)

+ EncodeJSON func(form Form) ([]byte, error)

type QueryResult

+ ClaimEncoded []byte

+ ClaimId Id

+ ClaimNative Claim

+ Kind ResultKind

+ PathEncoded [][]byte

+ PathId []Id

+ PathNative []Claim

type ResultEncoding

+ const ResultNative

+ type ResultKind string

+ const KindClaimEncoded

+ const KindClaimId

+ const KindClaimNative

+ const KindPathEncoded

+ const KindPathId

+ const KindPathNative

v0.3.3

Jul 29, 2026

v0.3.2

Jul 29, 2026

Changes in this version

type Archive

+ Head func() Id

v0.3.1

Jul 29, 2026

Changes in this version

+ func ShapeContent(ctx context.Context, u Universe, c Claim, out Output) []byte

v0.3.0

Jul 28, 2026

Changes in this version

+ const BranchArchive

+ const BranchUniverse

+ const EdgeTypeBranch

+ const EdgeTypeBranches

+ const EdgeTypeContributor

+ const EdgeTypeDiff

+ const EdgeTypeHead

+ const EdgeTypePrune

+ const Encoding3GP

+ const Encoding7Z

+ const EncodingAAC

+ const EncodingAPNG

+ const EncodingAVI

+ const EncodingAVIF

+ const EncodingBMP

+ const EncodingBzip2

+ const EncodingCSS

+ const EncodingCSV

+ const EncodingCalendar

+ const EncodingDOCX

+ const EncodingEPUB

+ const EncodingGIF

+ const EncodingGZIP

+ const EncodingHTML

+ const EncodingICO

+ const EncodingJAR

+ const EncodingJPEG

+ const EncodingJSON

+ const EncodingJSONLD

+ const EncodingJavaScript

+ const EncodingMIDI

+ const EncodingMP2T

+ const EncodingMP3

+ const EncodingMP4

+ const EncodingMPEG

+ const EncodingMSExcel

+ const EncodingMSPowerPoint

+ const EncodingMSWord

+ const EncodingMarkdown

+ const EncodingODP

+ const EncodingODS

+ const EncodingODT

+ const EncodingOTF

+ const EncodingOctetStream

+ const EncodingOggAudio

+ const EncodingOggVideo

+ const EncodingPDF

+ const EncodingPNG

+ const EncodingPPTX

+ const EncodingPlain

+ const EncodingRAR

+ const EncodingRTF

+ const EncodingSVG

+ const EncodingTAR

+ const EncodingTIFF

+ const EncodingTTF

+ const EncodingWAV

+ const EncodingWOFF

+ const EncodingWOFF2

+ const EncodingWebManifest

+ const EncodingWebP

+ const EncodingWebmAudio

+ const EncodingWebmVideo

+ const EncodingXHTML

+ const EncodingXLSX

+ const EncodingXML

+ const EncodingZIP

+ const FieldContent

+ const FieldContentAlias

+ const FieldContentHash

+ const FieldContentHashAlias

+ const FieldContentSize

+ const FieldContentSizeAlias

+ const FieldEdges

+ const FieldEdgesAlias

+ const FieldEdgesDiffOmit

+ const FieldFieldsDiffOmit

+ const FieldHeight

+ const FieldHeightAlias

+ const FieldName

+ const FieldNameAlias

+ const NodeTypBranches

+ const NodeTypeContributor

+ const NodeTypeHead

+ const ReservedPrefix

+ const SpineRevKey

+ var EdgeClasses = []EdgeClass

+ var ErrContentCapped = errors.New("ranke: content capped (stored shorter than content_size)")

+ var ErrQueryNoHead = errors.New(...)

+ var ErrQueryNoScope = errors.New(...)

+ var ErrQueryScanClaim = errors.New(...)

+ var ErrQueryScanShape = errors.New(...)

+ var ErrQueryUnanchored = errors.New("ranke.Query: unanchored traversal — Select.Path with no Select.Claim")

+ var ErrUnsupported = errors.New("ranke: operation not supported by this backend")

+ func BranchTagKey(branch string) string

+ func DefaultCopyClaims(ctx context.Context, dst, src Universe, ids []Id, opts ...CopyOption) error

+ func DefaultCopyContents(ctx context.Context, dst, src Universe, refs []ContentRef, opts ...CopyOption) error

+ func DefaultGetClaimHeights(ctx context.Context, u Universe, ids []Id) ([]uint64, error)

+ func DefaultSync(ctx context.Context, dst, src Universe, id Id) <-chan SyncResult

+ func DefaultTag(ctx context.Context, u Universe, head Id) error

+ func GetClaimHeight(ctx context.Context, u Universe, id Id) (uint64, error)

+ func GetTag(ctx context.Context, u Universe, id Id, tag string) (found bool, value string, err error)

+ func HeightOf(refs ...Claim) uint64

+ func Hops(n int) *int

+ func InClosure(ctx context.Context, u Universe, branch string, heads []Id, id Id) (bool, error)

+ func IsTextEncoding(encoding string) bool

+ func ReportEnabled(ctx context.Context, level ReportLevel) bool

+ func ReportEvent(ctx context.Context, engine, op string, level ReportLevel, detail string, ...)

+ func SyncedNow(id Id) <-chan SyncResult

+ func WantsDelta(opts ...GetOption) bool

+ func WithDetail(sentinel error, detail string) error

+ func WithReport(ctx context.Context, level ReportLevel) (context.Context, func() []QueryEvent)

+ func Wrap(sentinel, cause error) error

+ func WrapDetail(sentinel error, detail string, cause error) error

type Archive

+ GetBranches func(ctx context.Context) ([]Branch, error)

+ GetClaimContent func(ctx context.Context, id Id) (io.Reader, error)

+ Query func(ctx context.Context, q Query) (ResultStream, error)

+ Verify func(ctx context.Context, opts ...VerifyOption) (VerificationRun, error)

type Branch

+ GetClaim func(ctx context.Context, id Id) (Claim, error)

+ GetClaimContent func(ctx context.Context, id Id) (io.Reader, error)

+ HasClaim func(ctx context.Context, id Id) (bool, error)

+ Head func() Id

+ Prev func(ctx context.Context) (Branch, error)

+ Verify func(ctx context.Context, opts ...VerifyOption) (VerificationRun, error)

type Capabilities

+ ContentCap uint64

+ ExternalContent bool

+ RawClaims bool

+ ReverseWalk bool

+ Tags bool

+ Tier StorageTier

+ func (c Capabilities) AllowsTier(t StorageTier) bool

type Claim

+ func AssembleClaim(parts ClaimParts) (Claim, error)

+ func DefaultMaterialize(ctx context.Context, u Universe, claims []Claim, opts ...GetOption) ([]Claim, error)

+ func GetFromClosure(ctx context.Context, u Universe, branch string, heads []Id, id Id) (Claim, error)

+ GetContent func(ctx context.Context, u Universe) (io.Reader, error)

+ HasTag func(key string) bool

+ SetTag func(ctx context.Context, u Universe) error

+ Tag func(key string) string

+ Tags func() map[string]string

type ClaimBuilder

+ ContentSize uint64

+ DiffOf Id

+ Height uint64

+ InlineContent []byte

+ func (b ClaimBuilder) WithAutoHeight(ctx context.Context, u Universe) ClaimBuilder

+ func (b ClaimBuilder) WithDiff(id Id) ClaimBuilder

+ func (b ClaimBuilder) WithExternalContent(hash Id, size uint64) ClaimBuilder

+ func (b ClaimBuilder) WithHeight(h uint64) ClaimBuilder

+ func (b ClaimBuilder) WithInlineContent(c []byte) ClaimBuilder

+ type ClaimParts struct

+ ContentHash Id

+ ContentSize uint64

+ CreatedAt time.Time

+ Edges []EdgeParts

+ Encoding string

+ Fields map[string]string

+ Height uint64

+ ID Id

+ InlineContent []byte

+ Tags map[string]string

+ Type string

+ type Collation string

+ const CompareLexical

+ const CompareNumeric

+ type Comparison struct

+ Eq any

+ Ge any

+ Glob string

+ Gt any

+ In []any

+ Le any

+ Lt any

+ Ne any

+ type Content struct

+ Max int64

+ Overflow Overflow

+ type ContentKind int

+ const ContentExternal

+ const ContentInline

+ const ContentNone

type ContentRef

+ ContentSize uint64

+ type Contribution interface

+ AddClaims func(claims []Claim) error

+ AddGraph func(g Graph) error

+ Base func() (head Id, t time.Time)

+ CompleteAndVerify func(ctx context.Context) (VerifiedContribution, error)

type Contributor

+ Pubkey func() []byte

+ type Detail string

+ const DetailClaims

+ const DetailGraph

+ const DetailID

+ type Direction string

+ const DirConnections

+ const DirProvenance

+ const DirUses

type Edge

+ ContentKind func() ContentKind

+ Encoding func() string

+ EncodingClass func() EncodingClass

+ EncodingSub func() string

+ GetContent func(ctx context.Context, u Universe) (io.Reader, error)

+ GetContentHash func() Id

+ GetContentSize func() uint64

+ GetInlineContent func() ([]byte, error)

type EdgeClass

+ const EdgeClassContribution

+ const EdgeClassContributionAlias

+ const EdgeClassDerivation

+ const EdgeClassDerivationAlias

+ const EdgeClassRelation

+ const EdgeClassRelationAlias

type EdgeConfig

+ ContentHash Id

+ ContentSize uint64

+ Encoding string

+ InlineContent []byte

+ type EdgeFilterFieldValue struct

+ Field string

+ Value string

+ func (f EdgeFilterFieldValue) IsEdgeFilter() bool

+ func (f EdgeFilterFieldValue) MatchEdge(e Edge) bool

+ func (f EdgeFilterFieldValue) MatchNode(Node) bool

+ type EdgeFilterType struct

+ Type string

+ func (f EdgeFilterType) IsEdgeFilter() bool

+ func (f EdgeFilterType) MatchEdge(e Edge) bool

+ func (f EdgeFilterType) MatchNode(Node) bool

+ type EdgeFilterTypes struct

+ Types []string

+ func (f EdgeFilterTypes) IsEdgeFilter() bool

+ func (f EdgeFilterTypes) MatchEdge(e Edge) bool

+ func (f EdgeFilterTypes) MatchNode(Node) bool

+ type EdgeParts struct

+ ContentHash Id

+ ContentSize uint64

+ Encoding string

+ Fields map[string]string

+ ID Id

+ InlineContent []byte

+ Reference Id

+ RelationDirection RelationDirection

+ Type string

+ type EdgeSubtype string

+ const EdgeSubtypeBranch

+ const EdgeSubtypeBranchAlias

+ const EdgeSubtypeBranches

+ const EdgeSubtypeBranchesAlias

+ const EdgeSubtypeContributor

+ const EdgeSubtypeContributorAlias

+ const EdgeSubtypeDiff

+ const EdgeSubtypeDiffAlias

+ const EdgeSubtypeHead

+ const EdgeSubtypeHeadAlias

+ const EdgeSubtypePrune

+ const EdgeSubtypePruneAlias

+ type EncodingSubtype string

+ type Execution struct

+ Layer string

+ Report ReportLevel

+ type Failure struct

+ Depth int

+ Err error

+ ID Id

+ type Field string

type Filter

+ IsEdgeFilter func() bool

+ MatchEdge func(e Edge) bool

+ MatchNode func(n Node) bool

+ type Form string

+ const FormMaterialized

+ const FormOriginal

+ type GetOption func(*getConfig)

+ func WithNotDiffMaterialized() GetOption

type Graph

+ func NewGraphFromClosure(ctx context.Context, head Id, universe Universe) (Graph, error)

+ AddClaims func(ctx context.Context, claims ...Claim) error

+ ContainsClaim func(ctx context.Context, id Id) (bool, error)

+ GetClaim func(ctx context.Context, id Id) (Claim, error)

+ Verify func(opts ...VerifyOption) VerificationRun

+ type HeightCache struct

+ func NewHeightCache() *HeightCache

+ func (c *HeightCache) Get(id Id) (uint64, bool)

+ func (c *HeightCache) GetClaimHeights(ctx context.Context, u Universe, ids []Id) ([]uint64, error)

+ func (c *HeightCache) Note(id Id, height uint64)

+ func (c *HeightCache) NoteClaims(cs ...Claim)

+ type History interface

+ Append func(ctx context.Context, id Id, height int, revision int) (HistoryItem, error)

+ Close func() error

+ GetAtRevision func(ctx context.Context, revision int) (HistoryItem, error)

+ GetBulk func(ctx context.Context, fromRevision, toExcludingRevision int) ([]HistoryItem, error)

+ Latest func(ctx context.Context) (HistoryItem, error)

+ Len func(ctx context.Context) (int, error)

+ type HistoryItem struct

+ func NewHistoryItem(id Id, revision int, height int, timestamp time.Time) HistoryItem

+ func SpliceHistory(existing, tagged []HistoryItem) []HistoryItem

+ func TagArchive(ctx context.Context, a Archive, opts ...TagArchiveOptions) ([]HistoryItem, error)

+ func (h HistoryItem) GetHeight() int

+ func (h HistoryItem) GetId() Id

+ func (h HistoryItem) GetRevision() int

+ func (h HistoryItem) GetTimestamp() time.Time

+ type Limit struct

+ Results int

+ Time time.Duration

+ type MergableContribution interface

+ Heads func() []Id

type Node

+ ContentKind func() ContentKind

+ GetContent func(ctx context.Context, u Universe) (io.Reader, error)

+ GetContentHash func() Id

+ GetContentSize func() uint64

+ GetInlineContent func() ([]byte, error)

+ Height func() uint64

type NodeClass

+ const NodeClassContribution

+ const NodeClassContributionAlias

+ const NodeClassDerivation

+ const NodeClassDerivationAlias

+ const NodeClassEntity

+ const NodeClassEntityAlias

+ const NodeClassRelation

+ const NodeClassRelationAlias

+ const NodeClassSource

+ const NodeClassSourceAlias

+ type NodeSubtype string

+ const NodeSubtypeBranch

+ const NodeSubtypeBranchAlias

+ const NodeSubtypeBranches

+ const NodeSubtypeBranchesAlias

+ const NodeSubtypeContributor

+ const NodeSubtypeContributorAlias

+ const NodeSubtypeDiff

+ const NodeSubtypeDiffAlias

+ const NodeSubtypeHead

+ const NodeSubtypeHeadAlias

+ type OrderKey struct

+ Compare Collation

+ Dir SortDir

+ Field string

+ type Output struct

+ Content *Content

+ Detail Detail

+ Encoding ResultEncoding

+ Form Form

+ Shape Shape

+ type Overflow string

+ const OverflowCutoff

+ const OverflowOmit

+ const OverflowReference

+ type PathStep struct

+ Dir Direction

+ Edges []string

+ Max int

+ Min *int

+ Nodes []string

+ func (s PathStep) MinHops() int

+ type Query struct

+ Execution Execution

+ Limit Limit

+ Order []OrderKey

+ Output Output

+ Select Select

+ Where *Where

+ type QueryEvent struct

+ At time.Duration

+ Attrs map[string]any

+ Detail string

+ Duration time.Duration

+ Engine string

+ Level ReportLevel

+ Op string

+ type QueryReport struct

+ Elapsed time.Duration

+ Events []QueryEvent

+ Results int

+ StartedAt time.Time

+ Truncated bool

+ type QueryResult struct

+ Claim Claim

+ Content []byte

+ Id Id

+ Path []Claim

+ type Receipt interface

+ Head func() Id

+ type ReportLevel string

+ const ReportDebug

+ const ReportError

+ const ReportInfo

+ const ReportTrace

+ const ReportWarn

+ type ResultEncoding string

+ const ResultCBOR

+ const ResultJSON

+ type ResultStream interface

+ Close func() error

+ Err func() error

+ Next func() bool

+ Report func() *QueryReport

+ Result func() QueryResult

+ func DefaultQuery(ctx context.Context, u Universe, q Query, scope Scope) (ResultStream, error)

+ type Scope struct

+ Branch string

+ Head Id

+ Height uint64

+ Revision int

+ type Select struct

+ Branch string

+ Claim Id

+ Head Id

+ Path []PathStep

+ type Sequencer interface

+ GetArchive func(ctx context.Context) (Archive, error)

+ GetContributor func() Contributor

+ Merge func(ctx context.Context, c MergableContribution) (Receipt, error)

+ NewContribution func(ctx context.Context) (Contribution, error)

+ type Shape string

+ const ShapePath

+ const ShapeSingle

+ type SortDir string

+ const SortAsc

+ const SortDesc

+ type StorageTier string

+ const StorageTierAuthoritative

+ const StorageTierBackground

+ const StorageTierEager

+ const StorageTierLazy

+ type SyncResult struct

+ Err error

+ SyncedTo Id

+ type TagArchiveOptions struct

+ RetagAll bool

type Universe

+ func NewMemoryUniverse() Universe

+ GetClaimHeights func(ctx context.Context, ids []Id) ([]uint64, error)

+ GetClaimTags func(ctx context.Context, claims []Id) ([]map[string]string, error)

+ GetClaimsRaw func(ctx context.Context, ids []Id) ([][]byte, error)

+ Query func(ctx context.Context, q Query, scope Scope) (ResultStream, error)

+ SetClaimsTags func(ctx context.Context, clearTags []string, tags map[string]map[string]string) error

+ Sync func(ctx context.Context, src Universe, id Id) <-chan SyncResult

+ Tag func(ctx context.Context, head Id) error

+ type VerificationRun interface

+ Done func() bool

+ Err func() error

+ Failures func() []Failure

+ Verified func() int

+ Wait func()

+ type VerifiedContribution interface

+ Ids func() []Id

+ Persist func(ctx context.Context) (MergableContribution, error)

+ type VerifyOption func(*verifyConfig)

+ func WithCreatedAfter(t time.Time) VerifyOption

+ func WithExternalContent() VerifyOption

+ func WithMaxClaims(n int) VerifyOption

+ func WithMaxDepth(n int) VerifyOption

+ func WithOnError(fn func(Failure)) VerifyOption

+ func WithSkipRules(names ...string) VerifyOption

+ func WithStopAfter(n int) VerifyOption

+ func WithTrusted(fn func(Id) bool) VerifyOption

+ type VerifyRule struct

+ Name string

+ Rule string

+ func VerifyRuleSet() []VerifyRule

+ type Where struct

+ And []Where

+ Field string

+ Not *Where

+ Or []Where

+ Test *Comparison

v0.2.0

Jun 30, 2026

Changes in this version

+ type Capabilities struct

+ Delete bool

+ Enumerate bool

+ GQL bool

+ Overwrite bool

+ Persistent bool

type Universe

+ Capabilities func() Capabilities

v0.1.0

Jun 25, 2026

Changes in this version

+ const EdgeBranch

+ const EdgeBranches

+ const EdgeContributor

+ const EdgeHead

+ const EdgePrune

+ const NodeBranches

+ const NodeContributor

+ const NodeHead

+ var ErrClosed = errors.New("ranke: closed")

+ var ErrIntegrity = errors.New("ranke: integrity check failed")

+ var ErrNotFound = errors.New("ranke: not found")

+ func DecodePublicKey(b []byte) (multicodec.Code, crypto.PublicKey, error)

+ func EncodePublicKey(pub crypto.PublicKey) ([]byte, error)

+ func EncodingApplication(sub string) string

+ func EncodingAudio(sub string) string

+ func EncodingExample(sub string) string

+ func EncodingFont(sub string) string

+ func EncodingImage(sub string) string

+ func EncodingMessage(sub string) string

+ func EncodingModel(sub string) string

+ func EncodingMultipart(sub string) string

+ func EncodingText(sub string) string

+ func EncodingVideo(sub string) string

+ func GetContent(ctx context.Context, u Universe, hash Id, size uint64) ([]byte, error)

+ func HasClaim(ctx context.Context, u Universe, id Id) (bool, error)

+ func HasContent(ctx context.Context, u Universe, hash Id) (bool, error)

+ func LoadEd25519PrivateKeyPEM(path string) (ed25519.PrivateKey, error)

+ func LoadEd25519PublicKeyPEM(path string) (ed25519.PublicKey, error)

+ func NewVerifyingReader(src io.ReadCloser, hash Id, size uint64) (io.ReadCloser, error)

+ func PutClaim(ctx context.Context, u Universe, c Claim) error

+ func PutContent(ctx context.Context, u Universe, hash Id, content []byte) error

+ func TypeDerivation(sub string) string

+ func TypeEntity(sub string) string

+ func TypeRelation(sub string) string

+ func TypeSource(sub string) string

+ func VerifyContent(hash Id, size uint64, data []byte) error

+ type Archive interface

+ AddClaim func(ctx context.Context, branchName string, c Claim, createdAt ...time.Time) error

+ AddGraph func(ctx context.Context, branchName string, g Graph, contributor Contributor, ...) error

+ Branches func(ctx context.Context) []Branch

+ GetBranch func(ctx context.Context, name string) (Branch, error)

+ GetClaim func(ctx context.Context, id Id) (Claim, error)

+ HasBranch func(ctx context.Context, name string) bool

+ HasClaim func(ctx context.Context, id Id) bool

+ VerifyBranch func(ctx context.Context, name string) error

+ func NewArchive(ctx context.Context, u Universe, bth BranchTableHead) (Archive, error)

+ type Branch interface

+ Latest func() BranchEntry

+ Name func() string

+ Provenance func() []BranchEntry

+ type BranchEntry interface

+ Claim func() Claim

+ Contributor func() Contributor

+ Head func() Id

+ Time func() time.Time

+ type BranchTable interface

+ Bh func() Id

+ Get func(ctx context.Context, name string) (Branch, error)

+ Has func(name string) bool

+ History func(ctx context.Context) ([]BranchTable, error)

+ List func(ctx context.Context) ([]Branch, error)

+ Set func(ctx context.Context, name string, head Id, contributor Contributor, ...) (BranchTable, error)

+ func LoadBranchTable(ctx context.Context, u Universe, bh Id) (BranchTable, error)

+ type BranchTableHead interface

+ Close func() error

+ Load func(ctx context.Context) (Id, error)

+ Save func(ctx context.Context, id Id) error

+ type Claim interface

+ AsContributor func(signingKey ...crypto.Signer) (Contributor, error)

+ Contributor func() Contributor

+ Edges func(filters ...Filter) []Edge

+ Encode func() ([]byte, error)

+ Graph func(ctx context.Context) (Graph, error)

+ ID func() Id

+ IsContributor func() bool

+ Node func() Node

+ Validate func(ctx context.Context) error

+ func DecodeClaim(id Id, b []byte) (Claim, error)

+ func GetClaim(ctx context.Context, u Universe, id Id) (Claim, error)

+ type ClaimBuilder struct

+ Content []byte

+ ContentHash Id

+ Contributor Contributor

+ CreatedAt time.Time

+ Edges []Edge

+ Encoding string

+ EncodingClass EncodingClass

+ EncodingSub string

+ Fields map[string]string

+ Pubkey []byte

+ SigningKey crypto.Signer

+ Title string

+ Type string

+ TypeClass NodeClass

+ TypeSub string

+ func NewClaim(typ string, contributor Contributor, content []byte) ClaimBuilder

+ func (b ClaimBuilder) Sign(signingKey ...crypto.Signer) (Claim, error)

+ func (b ClaimBuilder) WithContent(c []byte) ClaimBuilder

+ func (b ClaimBuilder) WithContentHash(h Id) ClaimBuilder

+ func (b ClaimBuilder) WithContributor(c Contributor) ClaimBuilder

+ func (b ClaimBuilder) WithCreatedAt(t time.Time) ClaimBuilder

+ func (b ClaimBuilder) WithEdges(edges ...Edge) ClaimBuilder

+ func (b ClaimBuilder) WithEncoding(e string) ClaimBuilder

+ func (b ClaimBuilder) WithField(key, value string) ClaimBuilder

+ func (b ClaimBuilder) WithPubkey(p []byte) ClaimBuilder

+ func (b ClaimBuilder) WithSigningKey(k crypto.Signer) ClaimBuilder

+ func (b ClaimBuilder) WithTitle(t string) ClaimBuilder

+ func (b ClaimBuilder) WithType(t string) ClaimBuilder

+ type ContentBlob struct

+ Content []byte

+ Hash Id

+ type ContentRef struct

+ Hash Id

+ Size uint64

+ type Contributor interface

+ SigningKey func() crypto.Signer

+ func WithSigningKey(c Contributor, key crypto.Signer) Contributor

+ type CopyConfig struct

+ Closure bool

+ Content bool

+ Progress func(CopyProgress)

+ func NewCopyConfig(opts ...CopyOption) CopyConfig

+ type CopyOption func(*CopyConfig)

+ func WithClosure() CopyOption

+ func WithContent() CopyOption

+ func WithProgress(fn func(CopyProgress)) CopyOption

+ type CopyProgress struct

+ BytesCopied uint64

+ BytesRemaining uint64

+ ClaimsCopied uint64

+ ClaimsRemaining uint64

+ DiscoveryComplete bool

+ type Edge interface

+ Content func() []byte

+ Fields func() []string

+ GetField func(name string) (string, error)

+ HasField func(name string) bool

+ ID func() Id

+ Reference func() Id

+ RelationDirection func() RelationDirection

+ Type func() string

+ TypeClass func() EdgeClass

+ TypeSub func() string

+ func NewEdge(cfg EdgeConfig) (Edge, error)

+ type EdgeClass string

+ const EdgeContribution

+ const EdgeDerivation

+ const EdgeRelation

+ type EdgeConfig struct

+ Content []byte

+ Fields map[string]string

+ Reference Id

+ RelationDirection RelationDirection

+ Type string

+ TypeClass EdgeClass

+ TypeSub string

+ type EncodingClass string

+ type Filter interface

+ Match func(e Edge) bool

+ type Graph interface

+ Add func(claims ...Claim) error

+ Consolidate func(contributor Contributor, createdAt ...time.Time) (Claim, error)

+ Contains func(id Id) bool

+ Get func(id Id) (Claim, bool)

+ Heads func() []Id

+ IsConsolidated func() bool

+ Validate func(report ...func(c Claim, depth int, err error)) error

+ ValidateWithExceptions func(skip ...Id) error

+ func NewGraph(root Contributor) Graph

+ type Id interface

+ Algorithm func() string

+ Equal func(other Id) bool

+ String func() string

+ func HashContent(content []byte) (Id, error)

+ func ParseId(s string) (Id, error)

+ type Keypair struct

+ Private crypto.Signer

+ Pubkey []byte

+ func LoadPrivateKey(path string) (Keypair, error)

+ type Node interface

+ Content func() ([]byte, error)

+ ContentHash func() Id

+ CreatedAt func() time.Time

+ Edges func() []Id

+ Encoding func() string

+ EncodingClass func() EncodingClass

+ EncodingSub func() string

+ Fields func() []string

+ GetField func(name string) (string, error)

+ HasField func(name string) bool

+ ID func() Id

+ Pubkey func() []byte

+ Size func() uint64

+ Title func() string

+ Type func() string

+ TypeClass func() NodeClass

+ TypeSub func() string

+ type NodeClass string

+ const NodeContribution

+ const NodeDerivation

+ const NodeEntity

+ const NodeRelation

+ const NodeSource

+ type RelationDirection int8

+ const RelationFrom

+ const RelationTo

+ type Universe interface

+ Close func() error

+ CopyClaims func(ctx context.Context, src Universe, ids []Id, opts ...CopyOption) error

+ CopyContents func(ctx context.Context, src Universe, refs []ContentRef, opts ...CopyOption) error

+ GetClaims func(ctx context.Context, ids []Id) ([]Claim, error)

+ GetContents func(ctx context.Context, refs []ContentRef) ([][]byte, error)

+ HasClaims func(ctx context.Context, ids []Id) ([]bool, error)

+ HasContents func(ctx context.Context, hashes []Id) ([]bool, error)

+ PutClaims func(ctx context.Context, cs []Claim) error

+ PutContents func(ctx context.Context, blobs []ContentBlob) error

+ StreamContent func(ctx context.Context, hash Id, size uint64) (io.ReadCloser, error)

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