negentropy

README

this is a fork of https://github.com/illuzen/go-negentropy

Documentation

Index

• Constants
• Variables
• func EncodeVarInt(n int) []byte
• func ItemCompare(a, b Item) int
• type Bound
  • func (b Bound) String() string
• type Item
  • func (i Item) String() string
• type Mode
  • func (v Mode) String() string
• type Negentropy
  • func New(storage Storage, frameSizeLimit int) *Negentropy
  • func (n *Negentropy) Name() string
  • func (n *Negentropy) Reconcile(msg string) (output string, err error)
  • func (n *Negentropy) SplitRange(lower, upper int, upperBound Bound, output *StringHexWriter)
  • func (n *Negentropy) Start() string
  • func (n *Negentropy) String() string
• type Storage
• type StringHexReader
  • func NewStringHexReader(source string) *StringHexReader
  • func (r *StringHexReader) Len() int
  • func (r *StringHexReader) ReadHexByte() (byte, error)
  • func (r *StringHexReader) ReadHexBytes(buf []byte) error
  • func (r *StringHexReader) ReadString(size int) (string, error)
• type StringHexWriter
  • func NewStringHexWriter(buf []byte) *StringHexWriter
  • func (r *StringHexWriter) Hex() string
  • func (r *StringHexWriter) Len() int
  • func (r *StringHexWriter) Reset()
  • func (r *StringHexWriter) WriteByte(b byte) error
  • func (r *StringHexWriter) WriteBytes(in []byte)
  • func (r *StringHexWriter) WriteHex(hexString string)

Constants

const FingerprintSize = 16

Variables

var InfiniteBound = Bound{Item: Item{Timestamp: maxTimestamp}}

Functions

func EncodeVarInt

func EncodeVarInt(n int) []byte

func ItemCompare

func ItemCompare(a, b Item) int

Types

type Bound

type Bound struct{ Item }

func (Bound) String

func (b Bound) String() string

type Item

type Item struct {
	Timestamp nostr.Timestamp
	ID        string
}

func (Item) String

func (i Item) String() string

type Mode

type Mode uint8

const (
	SkipMode        Mode = 0
	FingerprintMode Mode = 1
	IdListMode      Mode = 2
)

func (Mode) String

func (v Mode) String() string

type Negentropy

type Negentropy struct {
	Haves    chan string
	HaveNots chan string
	// contains filtered or unexported fields
}

func New

func New(storage Storage, frameSizeLimit int) *Negentropy

func (*Negentropy) Name

func (n *Negentropy) Name() string

func (*Negentropy) Reconcile

func (n *Negentropy) Reconcile(msg string) (output string, err error)

func (*Negentropy) SplitRange

func (n *Negentropy) SplitRange(lower, upper int, upperBound Bound, output *StringHexWriter)

func (*Negentropy) Start

func (n *Negentropy) Start() string

func (*Negentropy) String

func (n *Negentropy) String() string

type Storage

type Storage interface {
	Size() int
	Range(begin, end int) iter.Seq2[int, Item]
	FindLowerBound(begin, end int, value Bound) int
	GetBound(idx int) Bound
	Fingerprint(begin, end int) string
}

type StringHexReader

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

func NewStringHexReader

func NewStringHexReader(source string) *StringHexReader

func (*StringHexReader) Len

func (r *StringHexReader) Len() int

func (*StringHexReader) ReadHexByte

func (r *StringHexReader) ReadHexByte() (byte, error)

func (*StringHexReader) ReadHexBytes

func (r *StringHexReader) ReadHexBytes(buf []byte) error

func (*StringHexReader) ReadString

func (r *StringHexReader) ReadString(size int) (string, error)

type StringHexWriter

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

func NewStringHexWriter

func NewStringHexWriter(buf []byte) *StringHexWriter

func (*StringHexWriter) Hex

func (r *StringHexWriter) Hex() string

func (*StringHexWriter) Len

func (r *StringHexWriter) Len() int

func (*StringHexWriter) Reset

func (r *StringHexWriter) Reset()

func (*StringHexWriter) WriteByte

func (r *StringHexWriter) WriteByte(b byte) error

func (*StringHexWriter) WriteBytes

func (r *StringHexWriter) WriteBytes(in []byte)

func (*StringHexWriter) WriteHex

func (r *StringHexWriter) WriteHex(hexString string)