v0

package
v0.10.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 4, 2025 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
const LEDGERKEYSIZE = 32

Variables

This section is empty.

Functions

This section is empty.

Types

type FinalityLedger 

type FinalityLedger[T ILedgerItem] struct {
	SimpleLedger[T]
	// contains filtered or unexported fields
}

func NewFinalityLedger 

func NewFinalityLedger[T ILedgerItem](name, dbDir string, cacheSize int, cb func() T) (*FinalityLedger[T], xerrors.XError)

func (*FinalityLedger[T]) CancelDelFinality 

func (ledger *FinalityLedger[T]) CancelDelFinality(key LedgerKey) xerrors.XError

func (*FinalityLedger[T]) CancelSetFinality 

func (ledger *FinalityLedger[T]) CancelSetFinality(key LedgerKey) xerrors.XError

func (*FinalityLedger[T]) Commit 

func (ledger *FinalityLedger[T]) Commit() ([]byte, int64, xerrors.XError)

func (*FinalityLedger[T]) DelFinality 

func (ledger *FinalityLedger[T]) DelFinality(key LedgerKey) (T, xerrors.XError)

func (*FinalityLedger[T]) GetFinality 

func (ledger *FinalityLedger[T]) GetFinality(key LedgerKey) (T, xerrors.XError)

func (*FinalityLedger[T]) ImmutableLedgerAt 

func (ledger *FinalityLedger[T]) ImmutableLedgerAt(n int64, cacheSize int) (ILedger[T], xerrors.XError)

func (*FinalityLedger[T]) IterateFinalityGotItems 

func (ledger *FinalityLedger[T]) IterateFinalityGotItems(cb func(T) xerrors.XError) xerrors.XError

func (*FinalityLedger[T]) IterateFinalityUpdatedItems 

func (ledger *FinalityLedger[T]) IterateFinalityUpdatedItems(cb func(T) xerrors.XError) xerrors.XError

func (*FinalityLedger[T]) IterateReadAllFinalityItems 

func (ledger *FinalityLedger[T]) IterateReadAllFinalityItems(cb func(T) xerrors.XError) xerrors.XError

func (*FinalityLedger[T]) SetFinality 

func (ledger *FinalityLedger[T]) SetFinality(item T) xerrors.XError

type IFinalityLedger 

type IFinalityLedger[T ILedgerItem] interface {
	ILedger[T]
	SetFinality(T) xerrors.XError
	CancelSetFinality(LedgerKey) xerrors.XError
	GetFinality(LedgerKey) (T, xerrors.XError)
	DelFinality(LedgerKey) (T, xerrors.XError)
	CancelDelFinality(LedgerKey) xerrors.XError
	IterateReadAllFinalityItems(func(T) xerrors.XError) xerrors.XError
	IterateFinalityGotItems(func(T) xerrors.XError) xerrors.XError
	IterateFinalityUpdatedItems(func(T) xerrors.XError) xerrors.XError
	ImmutableLedgerAt(int64, int) (ILedger[T], xerrors.XError)
}

type ILedger 

type ILedger[T ILedgerItem] interface {
	Version() int64
	Set(T) xerrors.XError
	CancelSet(LedgerKey) xerrors.XError
	Get(LedgerKey) (T, xerrors.XError)
	Del(LedgerKey) (T, xerrors.XError)
	CancelDel(LedgerKey) xerrors.XError
	Read(LedgerKey) (T, xerrors.XError)
	IterateReadAllItems(func(T) xerrors.XError) xerrors.XError
	IterateGotItems(func(T) xerrors.XError) xerrors.XError
	IterateUpdatedItems(func(T) xerrors.XError) xerrors.XError
	Commit() ([]byte, int64, xerrors.XError)
	Clone() ILedger[T]
	Close() xerrors.XError
}

type ILedgerItem 

type ILedgerItem interface {
	Key() LedgerKey
	Encode() ([]byte, xerrors.XError)
	Decode([]byte) xerrors.XError
}

type LedgerKey 

type LedgerKey = [32]byte

func ToLedgerKey 

func ToLedgerKey(s []byte) LedgerKey

type LedgerKeyList 

type LedgerKeyList []LedgerKey

func (LedgerKeyList) Len 

func (a LedgerKeyList) Len() int

func (LedgerKeyList) Less 

func (a LedgerKeyList) Less(i, j int) bool

func (LedgerKeyList) Swap 

func (a LedgerKeyList) Swap(i, j int)

type LedgerStrKey 

type LedgerStrKey = string

type MemLedger 

type MemLedger[T ILedgerItem] struct {
	// contains filtered or unexported fields
}

func NewMemLedger 

func NewMemLedger[T ILedgerItem](name, cb func() T) (*MemLedger[T], xerrors.XError)

func (*MemLedger[T]) CancelDel 

func (ledger *MemLedger[T]) CancelDel(key LedgerKey) xerrors.XError

func (*MemLedger[T]) CancelSet 

func (ledger *MemLedger[T]) CancelSet(key LedgerKey) xerrors.XError

func (*MemLedger[T]) Clone 

func (ledger *MemLedger[T]) Clone() ILedger[T]

func (*MemLedger[T]) Close 

func (ledger *MemLedger[T]) Close() xerrors.XError

func (*MemLedger[T]) Commit 

func (ledger *MemLedger[T]) Commit() ([]byte, int64, xerrors.XError)

func (*MemLedger[T]) Del 

func (ledger *MemLedger[T]) Del(key LedgerKey) (T, xerrors.XError)

func (*MemLedger[T]) Get 

func (ledger *MemLedger[T]) Get(key LedgerKey) (T, xerrors.XError)

func (*MemLedger[T]) IterateGotItems 

func (ledger *MemLedger[T]) IterateGotItems(cb func(T) xerrors.XError) xerrors.XError

func (*MemLedger[T]) IterateReadAllItems 

func (ledger *MemLedger[T]) IterateReadAllItems(cb func(T) xerrors.XError) xerrors.XError

func (*MemLedger[T]) IterateUpdatedItems 

func (ledger *MemLedger[T]) IterateUpdatedItems(cb func(T) xerrors.XError) xerrors.XError

func (*MemLedger[T]) Read 

func (ledger *MemLedger[T]) Read(key LedgerKey) (T, xerrors.XError)

func (*MemLedger[T]) Set 

func (ledger *MemLedger[T]) Set(item T) xerrors.XError

func (*MemLedger[T]) Version 

func (ledger *MemLedger[T]) Version() int64

type SimpleLedger 

type SimpleLedger[T ILedgerItem] struct {
	// contains filtered or unexported fields
}

func NewSimpleLedger 

func NewSimpleLedger[T ILedgerItem](name, dbDir string, cacheSize int, cb func() T) (*SimpleLedger[T], xerrors.XError)

func (*SimpleLedger[T]) CancelDel 

func (ledger *SimpleLedger[T]) CancelDel(key LedgerKey) xerrors.XError

func (*SimpleLedger[T]) CancelSet 

func (ledger *SimpleLedger[T]) CancelSet(key LedgerKey) xerrors.XError

func (*SimpleLedger[T]) Clone 

func (ledger *SimpleLedger[T]) Clone() ILedger[T]

func (*SimpleLedger[T]) Close 

func (ledger *SimpleLedger[T]) Close() xerrors.XError

func (*SimpleLedger[T]) Commit 

func (ledger *SimpleLedger[T]) Commit() ([]byte, int64, xerrors.XError)

func (*SimpleLedger[T]) Del 

func (ledger *SimpleLedger[T]) Del(key LedgerKey) (T, xerrors.XError)

func (*SimpleLedger[T]) Get 

func (ledger *SimpleLedger[T]) Get(key LedgerKey) (T, xerrors.XError)

func (*SimpleLedger[T]) ImmutableLedgerAt 

func (ledger *SimpleLedger[T]) ImmutableLedgerAt(n int64, cacheSize int) (*SimpleLedger[T], xerrors.XError)

func (*SimpleLedger[T]) IterateGotItems 

func (ledger *SimpleLedger[T]) IterateGotItems(cb func(T) xerrors.XError) xerrors.XError

func (*SimpleLedger[T]) IterateReadAllItems 

func (ledger *SimpleLedger[T]) IterateReadAllItems(cb func(T) xerrors.XError) xerrors.XError

func (*SimpleLedger[T]) IterateUpdatedItems 

func (ledger *SimpleLedger[T]) IterateUpdatedItems(cb func(T) xerrors.XError) xerrors.XError

func (*SimpleLedger[T]) Read 

func (ledger *SimpleLedger[T]) Read(key LedgerKey) (T, xerrors.XError)

func (*SimpleLedger[T]) Set 

func (ledger *SimpleLedger[T]) Set(item T) xerrors.XError

func (*SimpleLedger[T]) Version 

func (ledger *SimpleLedger[T]) Version() int64

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.