walrusds

package module

Go to main page

Versions in this module

v0

v0.6.0

Jul 26, 2026

Changes in this version

type Config

+ PackIdleFlush time.Duration

type StageStats

+ Newest sql.NullTime

v0.5.0

Jul 21, 2026

Changes in this version

type Config

+ PackFlushInterval time.Duration

+ PackMaxAge time.Duration

type Index

+ PromoteStaged func(ctx context.Context, recs []KeyRecord) error

+ StageClaim func(ctx context.Context, maxCount int, maxBytes int64, lease time.Duration) ([]StageEntry, error)

+ StageGet func(ctx context.Context, key string) ([]byte, error)

+ StageGetSize func(ctx context.Context, key string) (int64, error)

+ StagePutMany func(ctx context.Context, entries []StageEntry) error

+ StageRelease func(ctx context.Context, keys []string) error

+ StageStats func(ctx context.Context) (StageStats, error)

+ type StageEntry struct

+ Key string

+ Value []byte

+ type StageStats struct

+ Bytes int64

+ Count int64

+ Oldest sql.NullTime

v0.4.0

Jun 25, 2026

Changes in this version

+ const DefaultNShards

+ func EncodedBlobLength(unencodedLength int64, nShards int) int64

+ func EncodedStorageUnits(encodedSize int64) int64

type Config

+ NShards int

type QuiltStoreResult

+ Cost uint64

+ EncodedSize int64

type Record

+ Cost uint64

+ EncodedSize int64

type StoreResult

+ Cost uint64

+ EncodedSize int64

v0.3.0

Jun 24, 2026

Changes in this version

type QuiltStoreResult

+ ObjectID string

type Record

+ ObjectID string

type StoreResult

+ ObjectID string

v0.2.0

Jun 22, 2026

Changes in this version

type Client

+ func (c *Client) ReadQuiltPatch(ctx context.Context, patchID string) ([]byte, error)

+ func (c *Client) StoreQuilt(ctx context.Context, parts []QuiltPart, epochs int, deletable bool) (QuiltStoreResult, error)

type Config

+ DisableQuilt bool

+ MaxOpenConns int

+ type QuiltPart struct

+ Data []byte

+ Identifier string

+ type QuiltPatch struct

+ Identifier string

+ QuiltPatchID string

+ type QuiltStoreResult struct

+ EndEpoch uint64

+ Patches []QuiltPatch

+ QuiltID string

type Record

+ PatchID string

v0.1.0

Jun 9, 2026

Changes in this version

+ var ErrBlobNotFound = errors.New("walrusds: blob not found")

+ type Client struct

+ func NewClient(conf ClientConfig) *Client

+ func (c *Client) Read(ctx context.Context, blobID string) ([]byte, error)

+ func (c *Client) ReadRange(ctx context.Context, blobID string, offset, length int64) ([]byte, error)

+ func (c *Client) Store(ctx context.Context, value []byte, epochs int, deletable bool) (StoreResult, error)

+ type ClientConfig struct

+ AggregatorURLs []string

+ BlobCacheBytes int64

+ MaxRetries int

+ PublisherURLs []string

+ RequestTimeout time.Duration

+ type Config struct

+ AggregatorURLs []string

+ BlobCacheBytes int64

+ Deletable bool

+ EpochDuration time.Duration

+ Epochs int

+ MaxRetries int

+ PackTargetSize int64

+ PostgresURL string

+ PublisherURLs []string

+ RenewInterval time.Duration

+ RenewLead time.Duration

+ RequestTimeout time.Duration

+ Table string

+ Workers int

+ type Index interface

+ Close func() error

+ Delete func(ctx context.Context, key string) error

+ DeleteMany func(ctx context.Context, keys []string) error

+ DueForRenewal func(ctx context.Context, before time.Time, limit int) ([]RenewItem, error)

+ Get func(ctx context.Context, key string) (Record, error)

+ List func(ctx context.Context, prefix string, limit, offset int) ([]ListItem, error)

+ Put func(ctx context.Context, key string, rec Record) error

+ PutMany func(ctx context.Context, recs []KeyRecord) error

+ UpdateBlobAfterRenewal func(ctx context.Context, oldBlobID, newBlobID string, endEpoch uint64, ...) error

+ type KeyRecord struct

+ Key string

+ Rec Record

+ type ListItem struct

+ Key string

+ Size int64

+ type Record struct

+ BlobID string

+ Deletable bool

+ EndEpoch uint64

+ ExpiresAt sql.NullTime

+ Offset int64

+ Size int64

+ type RenewItem struct

+ BlobID string

+ type StoreResult struct

+ BlobID string

+ EndEpoch uint64

+ type WalrusDatastore struct

+ func NewWalrusDatastore(conf Config) (*WalrusDatastore, error)

+ func (w *WalrusDatastore) Batch(_ context.Context) (ds.Batch, error)

+ func (w *WalrusDatastore) Close() error

+ func (w *WalrusDatastore) Delete(ctx context.Context, k ds.Key) error

+ func (w *WalrusDatastore) Get(ctx context.Context, k ds.Key) ([]byte, error)

+ func (w *WalrusDatastore) GetSize(ctx context.Context, k ds.Key) (int, error)

+ func (w *WalrusDatastore) Has(ctx context.Context, k ds.Key) (bool, error)

+ func (w *WalrusDatastore) Put(ctx context.Context, k ds.Key, value []byte) error

+ func (w *WalrusDatastore) Query(ctx context.Context, q dsq.Query) (dsq.Results, error)

+ func (w *WalrusDatastore) Sync(ctx context.Context, prefix ds.Key) error

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