linkedlog

Documentation

Index

• Constants
• type Bitmap
  • func NewBitmap() Bitmap
  • func NewBitmapFromValues(values ...bool) Bitmap
  • func (b Bitmap) Get(index int) bool
  • func (b Bitmap) IsEmpty() bool
  • func (b *Bitmap) Set(index int, value bool)
• type KeyToOffsetAndSizeAndBlocktime
• type KeyToOffsetAndSizeAndBlocktimeSlice
  • func (s KeyToOffsetAndSizeAndBlocktimeSlice) Has(key solana.PublicKey) bool
• type LinkedLog
  • func NewLinkedLog(filename string) (*LinkedLog, error)
  • func (s *LinkedLog) Close() error
  • func (s *LinkedLog) Flush() error
  • func (s *LinkedLog) Put(callbackBefore func(pk solana.PublicKey) (indexes.OffsetAndSize, error), ...) (uint64, error)
  • func (s *LinkedLog) Read(offset uint64) ([]OffsetAndSizeAndSlot, indexes.OffsetAndSize, error)
  • func (s *LinkedLog) ReadWithSize(offset uint64, size uint64) ([]OffsetAndSizeAndSlot, indexes.OffsetAndSize, error)
• type OffsetAndSizeAndSlot
  • func NewOffsetAndSizeAndSlot(offset uint64, size uint64, slot uint64) *OffsetAndSizeAndSlot
  • func OffsetAndSizeAndSlotSliceFromBytes(buf []byte) ([]OffsetAndSizeAndSlot, error)
  • func (oas OffsetAndSizeAndSlot) Bytes() []byte
  • func (oas *OffsetAndSizeAndSlot) FromBytes(buf []byte) error
  • func (oas *OffsetAndSizeAndSlot) FromReader(r UvarintReader) error
  • func (oas *OffsetAndSizeAndSlot) HasMeta() bool
  • func (oas *OffsetAndSizeAndSlot) IsSuccess() bool
  • func (oas *OffsetAndSizeAndSlot) IsVote() bool
  • func (oas *OffsetAndSizeAndSlot) SetHasMeta(hasMeta bool)
  • func (oas *OffsetAndSizeAndSlot) SetIsSuccess(isSuccess bool)
  • func (oas *OffsetAndSizeAndSlot) SetIsVote(isVote bool)
• type UvarintReader

Constants

const (
	KiB = 1024
	MiB = 1024 * KiB
	GiB = 1024 * MiB
)

Types

type Bitmap

type Bitmap byte

func NewBitmap

func NewBitmap() Bitmap

func NewBitmapFromValues

func NewBitmapFromValues(values ...bool) Bitmap

func (Bitmap) Get

func (b Bitmap) Get(index int) bool

Get returns the value of the bit at the given index.

func (Bitmap) IsEmpty

func (b Bitmap) IsEmpty() bool

IsEmpty returns true if all the bits are unset.

func (*Bitmap) Set

func (b *Bitmap) Set(index int, value bool)

Set sets the value of the bit at the given index.

type KeyToOffsetAndSizeAndBlocktime

type KeyToOffsetAndSizeAndBlocktime struct {
	Key    solana.PublicKey
	Values []*OffsetAndSizeAndSlot
}

type KeyToOffsetAndSizeAndBlocktimeSlice

type KeyToOffsetAndSizeAndBlocktimeSlice []KeyToOffsetAndSizeAndBlocktime

func (KeyToOffsetAndSizeAndBlocktimeSlice) Has

func (s KeyToOffsetAndSizeAndBlocktimeSlice) Has(key solana.PublicKey) bool

Has returns true if the given public key is in the slice.

type LinkedLog

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

func NewLinkedLog

func NewLinkedLog(filename string) (*LinkedLog, error)

func (*LinkedLog) Close

func (s *LinkedLog) Close() error

func (*LinkedLog) Flush

func (s *LinkedLog) Flush() error

Flush flushes the buffer to disk

func (*LinkedLog) Put

func (s *LinkedLog) Put(
	callbackBefore func(pk solana.PublicKey) (indexes.OffsetAndSize, error),
	callbackAfter func(pk solana.PublicKey, offset uint64, ln uint32) error,
	values ...KeyToOffsetAndSizeAndBlocktime,
) (uint64, error)

func (*LinkedLog) Read

func (s *LinkedLog) Read(offset uint64) ([]OffsetAndSizeAndSlot, indexes.OffsetAndSize, error)

Read reads the block stored at the given offset.

func (*LinkedLog) ReadWithSize

func (s *LinkedLog) ReadWithSize(offset uint64, size uint64) ([]OffsetAndSizeAndSlot, indexes.OffsetAndSize, error)

type OffsetAndSizeAndSlot

type OffsetAndSizeAndSlot struct {
	Offset uint64 // encoded as uvarint
	Size   uint64 // encoded as uvarint
	Slot   uint64 // encoded as uvarint
	Flags  Bitmap // encoded as byte
}

func NewOffsetAndSizeAndSlot

func NewOffsetAndSizeAndSlot(offset uint64, size uint64, slot uint64) *OffsetAndSizeAndSlot

func OffsetAndSizeAndSlotSliceFromBytes

func OffsetAndSizeAndSlotSliceFromBytes(buf []byte) ([]OffsetAndSizeAndSlot, error)

func (OffsetAndSizeAndSlot) Bytes

func (oas OffsetAndSizeAndSlot) Bytes() []byte

Bytes returns the offset and size as a byte slice.

func (*OffsetAndSizeAndSlot) FromBytes

func (oas *OffsetAndSizeAndSlot) FromBytes(buf []byte) error

FromBytes parses the offset and size from a byte slice.

func (*OffsetAndSizeAndSlot) FromReader

func (oas *OffsetAndSizeAndSlot) FromReader(r UvarintReader) error

func (*OffsetAndSizeAndSlot) HasMeta

func (oas *OffsetAndSizeAndSlot) HasMeta() bool

HasMeta returns true if the transaction had metadata.

func (*OffsetAndSizeAndSlot) IsSuccess

func (oas *OffsetAndSizeAndSlot) IsSuccess() bool

IsSuccess returns the isSuccess flag.

func (*OffsetAndSizeAndSlot) IsVote

func (oas *OffsetAndSizeAndSlot) IsVote() bool

IsVote returns the isVote flag.

func (*OffsetAndSizeAndSlot) SetHasMeta

func (oas *OffsetAndSizeAndSlot) SetHasMeta(hasMeta bool)

SetHasMeta sets the hasMeta flag.

func (*OffsetAndSizeAndSlot) SetIsSuccess

func (oas *OffsetAndSizeAndSlot) SetIsSuccess(isSuccess bool)

SetIsSuccess sets the isSuccess flag.

func (*OffsetAndSizeAndSlot) SetIsVote

func (oas *OffsetAndSizeAndSlot) SetIsVote(isVote bool)

SetIsVote sets the isVote flag.

type UvarintReader

type UvarintReader interface {
	ReadUvarint() (uint64, error)
	ReadByte() (byte, error)
}