bark

package
v0.26.0 Latest Latest
Warning

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

Go to latest
Published: Mar 14, 2026 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Bark

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

func NewBark

func NewBark(cfg BarkConfig) *Bark

func (*Bark) Start

func (b *Bark) Start(ctx context.Context) error

func (*Bark) Stop

func (b *Bark) Stop(ctx context.Context) error

type BarkConfig

type BarkConfig struct {
	Logger          *slog.Logger
	DB              *database.Database
	TlsCertFilePath string
	TlsKeyFilePath  string
	Host            string
	Port            uint
}

type BlobStoreBark

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

func NewBarkBlobStore

func NewBarkBlobStore(
	config BlobStoreBarkConfig,
	upstream blob.BlobStore,
) *BlobStoreBark

func (*BlobStoreBark) Close

func (b *BlobStoreBark) Close() error

func (*BlobStoreBark) Delete

func (b *BlobStoreBark) Delete(txn types.Txn, key []byte) error

func (*BlobStoreBark) DeleteBlock

func (b *BlobStoreBark) DeleteBlock(
	txn types.Txn,
	slot uint64,
	hash []byte,
	id uint64,
) error

func (*BlobStoreBark) DeleteTx

func (b *BlobStoreBark) DeleteTx(txn types.Txn, txHash []byte) error

func (*BlobStoreBark) DeleteUtxo

func (b *BlobStoreBark) DeleteUtxo(
	txn types.Txn,
	txId []byte,
	outputIdx uint32,
) error

func (*BlobStoreBark) Get

func (b *BlobStoreBark) Get(txn types.Txn, key []byte) ([]byte, error)

func (*BlobStoreBark) GetBlock

func (b *BlobStoreBark) GetBlock(
	txn types.Txn,
	slot uint64,
	hash []byte,
) ([]byte, types.BlockMetadata, error)

func (*BlobStoreBark) GetBlockURL

func (b *BlobStoreBark) GetBlockURL(
	ctx context.Context,
	txn types.Txn,
	point ocommon.Point,
) (types.SignedURL, types.BlockMetadata, error)

func (*BlobStoreBark) GetCommitTimestamp

func (b *BlobStoreBark) GetCommitTimestamp() (int64, error)

func (*BlobStoreBark) GetTx

func (b *BlobStoreBark) GetTx(txn types.Txn, txHash []byte) ([]byte, error)

func (*BlobStoreBark) GetUtxo

func (b *BlobStoreBark) GetUtxo(
	txn types.Txn,
	txId []byte,
	outputIdx uint32,
) ([]byte, error)

func (*BlobStoreBark) NewIterator

func (b *BlobStoreBark) NewIterator(
	txn types.Txn,
	opts types.BlobIteratorOptions,
) types.BlobIterator

func (*BlobStoreBark) NewTransaction

func (b *BlobStoreBark) NewTransaction(b2 bool) types.Txn

func (*BlobStoreBark) Set

func (b *BlobStoreBark) Set(txn types.Txn, key, val []byte) error

func (*BlobStoreBark) SetBlock

func (b *BlobStoreBark) SetBlock(
	txn types.Txn,
	slot uint64,
	hash []byte,
	cbor []byte,
	id uint64,
	blockType uint,
	height uint64,
	prevHash []byte,
) error

func (*BlobStoreBark) SetCommitTimestamp

func (b *BlobStoreBark) SetCommitTimestamp(i int64, txn types.Txn) error

func (*BlobStoreBark) SetTx

func (b *BlobStoreBark) SetTx(
	txn types.Txn,
	txHash []byte,
	offsetData []byte,
) error

func (*BlobStoreBark) SetUtxo

func (b *BlobStoreBark) SetUtxo(
	txn types.Txn,
	txId []byte,
	outputIdx uint32,
	cbor []byte,
) error

type BlobStoreBarkConfig

type BlobStoreBarkConfig struct {
	BaseUrl        string
	SecurityWindow uint64
	HTTPClient     *http.Client
	LedgerState    *ledger.LedgerState
	Logger         *slog.Logger
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL