mem

Documentation

Index

• type DB
  • func New() *DB
  • func (r *DB) Close() error
  • func (r *DB) CurrentEstablishmentEvent(pre string) (*event.Message, error)
  • func (r *DB) CurrentEvent(pre string) (*event.Message, error)
  • func (r *DB) EscrowLikelyDuplicitiousEvent(e *event.Message) error
  • func (r *DB) EscrowOutOfOrderEvent(e *event.Message) error
  • func (r *DB) EscrowPendingEvent(e *event.Message) error
  • func (r *DB) EventAt(pre string, sequence int) (*event.Message, error)
  • func (r *DB) Get(k string) ([]byte, error)
  • func (r *DB) Inception(pre string) (*event.Message, error)
  • func (r *DB) LastAcceptedDigest(pre string, seq int) ([]byte, error)
  • func (r *DB) LogEvent(e *event.Message, first bool) error
  • func (r *DB) LogNonTransferableReceipt(vrc *event.Receipt) error
  • func (r *DB) LogSize(pre string) int
  • func (r *DB) LogTransferableReceipt(vrc *event.Receipt) error
  • func (r *DB) Put(k string, v []byte) error
  • func (r *DB) RemovePendingEscrow(prefix string, sn int, dig string) error
  • func (r *DB) Seen(pre string) bool
  • func (r *DB) StreamAsFirstSeen(pre string, handler func(*event.Message) error) error
  • func (r *DB) StreamBySequenceNo(pre string, handler func(*event.Message) error) error
  • func (r *DB) StreamEstablisment(pre string, handler func(*event.Message) error) error
  • func (r *DB) StreamPending(pre string, handler func(*event.Message) error) error
  • func (r *DB) StreamTransferableReceipts(pre string, sn int, handler func(quadlet []byte) error) error

Types

type DB

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

func New

func New() *DB

func (*DB) Close

func (r *DB) Close() error

func (*DB) CurrentEstablishmentEvent

func (r *DB) CurrentEstablishmentEvent(pre string) (*event.Message, error)

func (*DB) CurrentEvent

func (r *DB) CurrentEvent(pre string) (*event.Message, error)

func (*DB) EscrowLikelyDuplicitiousEvent

func (r *DB) EscrowLikelyDuplicitiousEvent(e *event.Message) error

func (*DB) EscrowOutOfOrderEvent

func (r *DB) EscrowOutOfOrderEvent(e *event.Message) error

func (*DB) EscrowPendingEvent

func (r *DB) EscrowPendingEvent(e *event.Message) error

func (*DB) EventAt

func (r *DB) EventAt(pre string, sequence int) (*event.Message, error)

func (*DB) Get

func (r *DB) Get(k string) ([]byte, error)

func (*DB) Inception

func (r *DB) Inception(pre string) (*event.Message, error)

func (*DB) LastAcceptedDigest

func (r *DB) LastAcceptedDigest(pre string, seq int) ([]byte, error)

func (*DB) LogEvent

func (r *DB) LogEvent(e *event.Message, first bool) error

func (*DB) LogNonTransferableReceipt

func (r *DB) LogNonTransferableReceipt(vrc *event.Receipt) error

func (*DB) LogSize

func (r *DB) LogSize(pre string) int

func (*DB) LogTransferableReceipt

func (r *DB) LogTransferableReceipt(vrc *event.Receipt) error

func (*DB) Put

func (r *DB) Put(k string, v []byte) error

func (*DB) RemovePendingEscrow

func (r *DB) RemovePendingEscrow(prefix string, sn int, dig string) error

func (*DB) Seen

func (r *DB) Seen(pre string) bool

func (*DB) StreamAsFirstSeen

func (r *DB) StreamAsFirstSeen(pre string, handler func(*event.Message) error) error

TODO: implement

func (*DB) StreamBySequenceNo

func (r *DB) StreamBySequenceNo(pre string, handler func(*event.Message) error) error

TODO: implement

func (*DB) StreamEstablisment

func (r *DB) StreamEstablisment(pre string, handler func(*event.Message) error) error

func (*DB) StreamPending

func (r *DB) StreamPending(pre string, handler func(*event.Message) error) error

func (*DB) StreamTransferableReceipts

func (r *DB) StreamTransferableReceipts(pre string, sn int, handler func(quadlet []byte) error) error