Versions in this module Expand all Collapse all v0 v0.1.1 Apr 2, 2026 v0.1.0 Mar 30, 2026 Changes in this version + var ErrHeadMismatch = errors.New("head mismatch") + var ErrNotFound = errors.New("not found") + type LogRecord struct + CreatedAt time.Time + LogDID string + UpdatedAt time.Time + type LogStore struct + func OpenLogStore(basePath, logDID string) (*LogStore, error) + func (s *LogStore) AddRevocation(ctx context.Context, delegationCID string) error + func (s *LogStore) Close() error + func (s *LogStore) CreateLogRecord(ctx context.Context, logDID string) error + func (s *LogStore) DBPath() string + func (s *LogStore) DequeuePendingCARs(ctx context.Context, limit int) ([]storage.PendingCAR, error) + func (s *LogStore) EnqueueAndUpdateHead(ctx context.Context, logDID string, treeSize uint64, headCID string, ...) (int64, error) + func (s *LogStore) GetHead(ctx context.Context, logDID string) (string, uint64, error) + func (s *LogStore) GetLatestHeadCAR(ctx context.Context, logDID string) (headCID string, treeSize uint64, carData []byte, err error) + func (s *LogStore) GetLogRecord(ctx context.Context, logDID string) (*LogRecord, error) + func (s *LogStore) GetPendingBlobsForCAR(ctx context.Context, queueID int64) ([]storage.PendingBlob, error) + func (s *LogStore) GetRevocations(ctx context.Context) ([]string, error) + func (s *LogStore) GetTreeState(ctx context.Context, logDID string) (size uint64, root []byte, err error) + func (s *LogStore) IsRevoked(ctx context.Context, delegationCID string) (bool, error) + func (s *LogStore) ListLogDIDs(ctx context.Context) ([]string, error) + func (s *LogStore) LogDID() string + func (s *LogStore) MarkBlobFailed(ctx context.Context, id int64, errMsg string) error + func (s *LogStore) MarkBlobUploaded(ctx context.Context, id int64) error + func (s *LogStore) MarkCARFailed(ctx context.Context, id int64, errMsg string) error + func (s *LogStore) MarkCARUploaded(ctx context.Context, id int64) error + func (s *LogStore) SetLatestHeadCAR(ctx context.Context, logDID string, treeSize uint64, headCID string, ...) error + func (s *LogStore) SetTreeState(ctx context.Context, logDID string, size uint64, root []byte) error + type StoreManager struct + func NewStoreManager(basePath string) *StoreManager + func (m *StoreManager) BasePath() string + func (m *StoreManager) CloseAll() error + func (m *StoreManager) GetStateStore(logDID string) (storage.StateStore, error) + func (m *StoreManager) GetStore(logDID string) (*LogStore, error) + func (m *StoreManager) ListLogDIDs() ([]string, error)
Go to main page