storage

type FlushFunc ¶

type FlushFunc func(ctx context.Context, entries []*tessera.Entry) error

FlushFunc is the signature of a function which will receive the slice of queued entries. Normally, this function would be provided by storage implementations. It's important to note that the implementation MUST call each entry's MarshalBundleData function before attempting to integrate it into the tree. See the comment on Entry.MarshalBundleData for further info.

type Queue ¶

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

Queue knows how to queue up a number of entries in order.

When the buffered queue grows past a defined size, or the age of the oldest entry in the queue reaches a defined threshold, the queue will call a provided FlushFunc with a slice containing all queued entries in the same order as they were added.

func NewQueue(ctx context.Context, maxAge time.Duration, maxSize uint, f FlushFunc) *Queue

func (q *Queue) Add(ctx context.Context, e *tessera.Entry) tessera.IndexFuture

type SequencedEntry ¶

type SequencedEntry struct {
	// BundleData is the entry's data serialised into the correct format for appending to an entry bundle.
	BundleData []byte
	// LeafHash is the entry's Merkle leaf hash.
	LeafHash []byte
}

SequencedEntry represents a log entry which has already been sequenced.

type TileID ¶

type TileID struct {
	Level uint64
	Index uint64
}

TileID represents a tile address in tile-space.