litefs

Oct 4, 2023

Changes in this version

type Leaser

+ Hostname func() string

type NodeInfo

+ IsPrimary bool

type StaticLeaser

+ func (l *StaticLeaser) Hostname() string

type Store

+ DatabaseFilter []string

+ func (s *Store) PrimaryInfoWithContext(ctx context.Context) (isPrimary bool, info *PrimaryInfo)

Sep 21, 2023

Changes in this version

+ const MaxBackupLTXFileN

+ type OS interface

+ Create func(op, name string) (*os.File, error)

+ Mkdir func(op, path string, perm os.FileMode) error

+ MkdirAll func(op, path string, perm os.FileMode) error

+ Open func(op, name string) (*os.File, error)

+ OpenFile func(op, opname string, flag int, perm os.FileMode) (*os.File, error)

+ ReadDir func(op, opname string) ([]os.DirEntry, error)

+ ReadFile func(op, name string) ([]byte, error)

+ Remove func(op, name string) error

+ RemoveAll func(op, name string) error

+ Rename func(op, oldpath, newpath string) error

+ Stat func(op, name string) (os.FileInfo, error)

+ Truncate func(op, name string, size int64) error

+ WriteFile func(op, name string, data []byte, perm os.FileMode) error

type Store

+ Exit func(int)

+ OS OS

Sep 6, 2023

Changes in this version

+ const EventChannelBufferSize

+ const EventTypeInit

+ const EventTypePrimaryChange

+ const EventTypeTx

+ type ChangeSetSubscriber struct

+ func (s *ChangeSetSubscriber) Close() error

+ func (s *ChangeSetSubscriber) DirtySet() map[string]struct{}

+ func (s *ChangeSetSubscriber) HandoffCh() chan string

+ func (s *ChangeSetSubscriber) MarkDirty(name string)

+ func (s *ChangeSetSubscriber) NodeID() uint64

+ func (s *ChangeSetSubscriber) NotifyCh() <-chan struct{}

type DB

+ func (db *DB) Drop(ctx context.Context) (err error)

+ func (db *DB) PageN() uint32

+ type Event struct

+ DB string

+ Data any

+ Type string

+ func (e *Event) UnmarshalJSON(data []byte) error

+ type EventSubscriber struct

+ func (s *EventSubscriber) C() <-chan Event

+ func (s *EventSubscriber) Stop()

+ type InitEventData struct

+ Hostname string

+ IsPrimary bool

+ type PrimaryChangeEventData struct

+ Hostname string

+ IsPrimary bool

type Store

+ func (s *Store) NotifyEvent(event Event)

+ func (s *Store) SubscribeChangeSet(nodeID uint64) *ChangeSetSubscriber

+ func (s *Store) SubscribeEvents() *EventSubscriber

+ func (s *Store) UnsubscribeChangeSet(sub *ChangeSetSubscriber)

+ func (s *Store) UnsubscribeEvents(sub *EventSubscriber)

+ type TxEventData struct

+ Commit uint32

+ PageSize uint32

+ PostApplyChecksum ltx.Checksum

+ TXID ltx.TXID

+ Timestamp time.Time

Aug 11, 2023

Changes in this version

+ const MetricsMonitorInterval

+ var GlobalStore atomic.Value

type Store

+ func (s *Store) Lag() time.Duration

Jul 5, 2023

Changes in this version

+ const DefaultBackupFullSyncInterval

type Store

+ BackupFullSyncInterval time.Duration

Jun 23, 2023

Changes in this version

+ const ChecksumBlockSize

+ const ClusterIDLen

+ const ClusterIDPrefix

+ const DefaultBackupDelay

+ const StreamFrameTypeHWM

+ const StreamFrameTypeHeartbeat

+ var ErrInvalidClusterID = errors.New("invalid cluster id")

+ var LogLevel struct

+ func GenerateClusterID() string

+ func ValidateClusterID(id string) error

+ type BackupClient interface

+ FetchSnapshot func(ctx context.Context, name string) (io.ReadCloser, error)

+ PosMap func(ctx context.Context) (map[string]ltx.Pos, error)

+ URL func() string

+ WriteTx func(ctx context.Context, name string, r io.Reader) (hwm ltx.TXID, err error)

type DB

+ func (db *DB) HWM() ltx.TXID

+ func (db *DB) SetHWM(txID ltx.TXID)

+ func (db *DB) Timestamp() time.Time

+ type Environment interface

+ SetPrimaryStatus func(ctx context.Context, isPrimary bool) error

+ Type func() string

+ type FileBackupClient struct

+ func NewFileBackupClient(path string) *FileBackupClient

+ func (c *FileBackupClient) FetchSnapshot(ctx context.Context, name string) (_ io.ReadCloser, retErr error)

+ func (c *FileBackupClient) Open() (err error)

+ func (c *FileBackupClient) PosMap(ctx context.Context) (map[string]ltx.Pos, error)

+ func (c *FileBackupClient) URL() string

+ func (c *FileBackupClient) WriteTx(ctx context.Context, name string, r io.Reader) (hwm ltx.TXID, err error)

+ type HWMStreamFrame struct

+ Name string

+ TXID ltx.TXID

+ func (*HWMStreamFrame) Type() StreamFrameType

+ func (f *HWMStreamFrame) ReadFrom(r io.Reader) (int64, error)

+ func (f *HWMStreamFrame) WriteTo(w io.Writer) (int64, error)

+ type HeartbeatStreamFrame struct

+ Timestamp int64

+ func (f *HeartbeatStreamFrame) ReadFrom(r io.Reader) (int64, error)

+ func (f *HeartbeatStreamFrame) Type() StreamFrameType

+ func (f *HeartbeatStreamFrame) WriteTo(w io.Writer) (int64, error)

type Invalidator

+ InvalidateLag func() error

type Leaser

+ ClusterID func(ctx context.Context) (string, error)

+ SetClusterID func(ctx context.Context, clusterID string) error

+ Type func() string

type NodeInfo

+ ClusterID string

type StaticLeaser

+ func (l *StaticLeaser) ClusterID(ctx context.Context) (string, error)

+ func (l *StaticLeaser) SetClusterID(ctx context.Context, clusterID string) error

+ func (l *StaticLeaser) Type() string

type Store

+ BackupClient BackupClient

+ BackupDelay time.Duration

+ Environment Environment

+ func (s *Store) ClusterID() string

+ func (s *Store) ClusterIDPath() string

+ func (s *Store) PrimaryTimestamp() int64

+ func (s *Store) SyncBackup(ctx context.Context) error

+ type Stream interface

+ ClusterID func() string

Apr 11, 2023

Changes in this version

+ const DefaultHaltAcquireTimeout

+ const DefaultHaltLockMonitorInterval

+ const DefaultHaltLockTTL

+ const FileTypeLock

+ const LockTypeHalt

+ const StreamFrameTypeDropDB

+ const StreamFrameTypeHandoff

+ const WaitInterval

+ var ErrDuplicateLTXFile = fmt.Errorf("duplicate ltx file")

+ var ErrInvalidNodeID = errors.New("invalid node id")

+ var ErrNoHaltPrimary = errors.New("no remote halt needed on primary node")

+ var ErrNotEligible = errors.New("not eligible to become primary")

+ var ErrStoreClosed = fmt.Errorf("store closed")

+ func FormatNodeID(id uint64) string

+ func ParseNodeID(s string) (uint64, error)

type Client

+ AcquireHaltLock func(ctx context.Context, primaryURL string, nodeID uint64, name string, ...) (*HaltLock, error)

+ Commit func(ctx context.Context, primaryURL string, nodeID uint64, name string, ...) error

+ ReleaseHaltLock func(ctx context.Context, primaryURL string, nodeID uint64, name string, ...) error

type DB

+ func (db *DB) AcquireHaltLock(ctx context.Context, lockID int64) (_ *HaltLock, retErr error)

+ func (db *DB) AcquireRemoteHaltLock(ctx context.Context, lockID int64) (_ *HaltLock, retErr error)

+ func (db *DB) ApplyLTXNoLock(ctx context.Context, path string) error

+ func (db *DB) Checkpoint(ctx context.Context) (err error)

+ func (db *DB) CheckpointNoLock(ctx context.Context) (err error)

+ func (db *DB) EnforceHaltLockExpiration(ctx context.Context)

+ func (db *DB) Export(ctx context.Context, dst io.Writer) (Pos, error)

+ func (db *DB) HasRemoteHaltLock() bool

+ func (db *DB) Mode() DBMode

+ func (db *DB) ReleaseHaltLock(ctx context.Context, id int64)

+ func (db *DB) ReleaseRemoteHaltLock(ctx context.Context, lockID int64) (retErr error)

+ func (db *DB) RemoteHaltLock() *HaltLock

+ func (db *DB) TryAcquireWriteLock() (ret *GuardSet)

+ func (db *DB) UnsetRemoteHaltLock(ctx context.Context, lockID int64) (retErr error)

+ func (db *DB) WaitPosExact(ctx context.Context, target Pos) error

+ func (db *DB) WriteLTXFileAt(ctx context.Context, r io.Reader) (string, error)

+ func (db *DB) Writeable() bool

+ type DropDBStreamFrame struct

+ Name string

+ func (*DropDBStreamFrame) Type() StreamFrameType

+ func (f *DropDBStreamFrame) ReadFrom(r io.Reader) (int64, error)

+ func (f *DropDBStreamFrame) WriteTo(w io.Writer) (int64, error)

+ type HaltLock struct

+ Expires *time.Time

+ ID int64

+ Pos Pos

+ type HandoffStreamFrame struct

+ LeaseID string

+ func (*HandoffStreamFrame) Type() StreamFrameType

+ func (f *HandoffStreamFrame) ReadFrom(r io.Reader) (int64, error)

+ func (f *HandoffStreamFrame) WriteTo(w io.Writer) (int64, error)

type Lease

+ Handoff func(nodeID uint64) error

+ HandoffCh func() <-chan uint64

+ ID func() string

type Leaser

+ AcquireExisting func(ctx context.Context, leaseID string) (Lease, error)

+ type NodeInfo struct

+ Candidate bool

+ ID uint64

+ Path string

+ Primary bool

+ func (i *NodeInfo) UnmarshalJSON(data []byte) (err error)

+ func (i NodeInfo) MarshalJSON() ([]byte, error)

type Pos

+ func (p *Pos) UnmarshalJSON(data []byte) (err error)

+ func (p Pos) MarshalJSON() ([]byte, error)

type StaticLease

+ func (l *StaticLease) Handoff(nodeID uint64) error

+ func (l *StaticLease) HandoffCh() <-chan uint64

+ func (l *StaticLease) ID() string

type StaticLeaser

+ func (l *StaticLeaser) AcquireExisting(ctx context.Context, leaseID string) (Lease, error)

type Store

+ Compress bool

+ HaltAcquireTimeout time.Duration

+ HaltLockMonitorInterval time.Duration

+ HaltLockTTL time.Duration

+ func (s *Store) DropDB(ctx context.Context, name string) (err error)

+ func (s *Store) EnforceHaltLockExpiration(ctx context.Context)

+ func (s *Store) Expvar() expvar.Var

+ func (s *Store) Handoff(nodeID uint64) error

+ func (s *Store) LogPrefix() string

+ func (s *Store) SubscriberByNodeID(nodeID uint64) *Subscriber

type Subscriber

+ func (s *Subscriber) Handoff(leaseID string)

+ func (s *Subscriber) HandoffCh() <-chan string

+ func (s *Subscriber) NodeID() uint64

Dec 26, 2022

Changes in this version

+ const DBModeRollback

+ const DBModeWAL

+ const DefaultDemoteDelay

+ const DefaultReconnectDelay

+ const DefaultRetention

+ const LockTypeCkpt

+ const LockTypeDMS

+ const LockTypeRead0

+ const LockTypeRead1

+ const LockTypeRead2

+ const LockTypeRead3

+ const LockTypeRead4

+ const LockTypeRecover

+ const LockTypeWrite

+ const SQLITE_JOURNAL_HEADER_SIZE

+ const StreamFrameTypeEnd

+ const TraceLogFlags

+ const WALIndexBlockSize

+ var NativeEndian = binary.LittleEndian

+ var TraceLog = log.New(io.Discard, "", TraceLogFlags)

+ func ContainsLockType(a []LockType, typ LockType) bool

+ func JournalChecksum(data []byte, initial uint32) uint32

+ func WALChecksum(bo binary.ByteOrder, s0, s1 uint32, b []byte) (uint32, uint32)

type DB

+ func (db *DB) AcquireWriteLock(ctx context.Context) (_ *GuardSet, err error)

+ func (db *DB) CanLock(ctx context.Context, owner uint64, lockTypes []LockType) (bool, RWMutexState)

+ func (db *DB) CanRLock(ctx context.Context, owner uint64, lockTypes []LockType) bool

+ func (db *DB) CloseDatabase(ctx context.Context, f *os.File, owner uint64) error

+ func (db *DB) CloseJournal(ctx context.Context, f *os.File, owner uint64) error

+ func (db *DB) CloseSHM(ctx context.Context, f *os.File, owner uint64) error

+ func (db *DB) CloseWAL(ctx context.Context, f *os.File, owner uint64) error

+ func (db *DB) CommitWAL(ctx context.Context) (err error)

+ func (db *DB) CreateGuardSetIfNotExists(owner uint64) *GuardSet

+ func (db *DB) CreateSHM() (*os.File, error)

+ func (db *DB) CreateWAL() (*os.File, error)

+ func (db *DB) Import(ctx context.Context, r io.Reader) error

+ func (db *DB) OpenDatabase(ctx context.Context) (*os.File, error)

+ func (db *DB) OpenJournal(ctx context.Context) (*os.File, error)

+ func (db *DB) OpenSHM(ctx context.Context) (*os.File, error)

+ func (db *DB) OpenWAL(ctx context.Context) (*os.File, error)

+ func (db *DB) ReadDatabaseAt(ctx context.Context, f *os.File, data []byte, offset int64, owner uint64) (int, error)

+ func (db *DB) ReadJournalAt(ctx context.Context, f *os.File, data []byte, offset int64, owner uint64) (int, error)

+ func (db *DB) ReadSHMAt(ctx context.Context, f *os.File, data []byte, offset int64, owner uint64) (int, error)

+ func (db *DB) ReadWALAt(ctx context.Context, f *os.File, data []byte, offset int64, owner uint64) (int, error)

+ func (db *DB) Recover(ctx context.Context) error

+ func (db *DB) RemoveJournal(ctx context.Context) error

+ func (db *DB) RemoveSHM(ctx context.Context) error

+ func (db *DB) RemoveWAL(ctx context.Context) (err error)

+ func (db *DB) SHMPath() string

+ func (db *DB) SyncDatabase(ctx context.Context) (err error)

+ func (db *DB) SyncJournal(ctx context.Context) (err error)

+ func (db *DB) SyncSHM(ctx context.Context) (err error)

+ func (db *DB) SyncWAL(ctx context.Context) (err error)

+ func (db *DB) TruncateDatabase(ctx context.Context, size int64) (err error)

+ func (db *DB) TruncateJournal(ctx context.Context) error

+ func (db *DB) TruncateSHM(ctx context.Context, size int64) error

+ func (db *DB) TruncateWAL(ctx context.Context, size int64) (err error)

+ func (db *DB) TryLocks(ctx context.Context, owner uint64, lockTypes []LockType) (bool, error)

+ func (db *DB) TryRLocks(ctx context.Context, owner uint64, lockTypes []LockType) bool

+ func (db *DB) Unlock(ctx context.Context, owner uint64, lockTypes []LockType)

+ func (db *DB) UnlockDatabase(ctx context.Context, owner uint64)

+ func (db *DB) UnlockSHM(ctx context.Context, owner uint64)

+ func (db *DB) WALPath() string

+ func (db *DB) WriteDatabaseAt(ctx context.Context, f *os.File, data []byte, offset int64, owner uint64) error

+ func (db *DB) WriteJournalAt(ctx context.Context, f *os.File, data []byte, offset int64, owner uint64) (err error)

+ func (db *DB) WriteSHMAt(ctx context.Context, f *os.File, data []byte, offset int64, owner uint64) (int, error)

+ func (db *DB) WriteWALAt(ctx context.Context, f *os.File, data []byte, offset int64, owner uint64) (err error)

+ type DBMode int

+ func (m DBMode) String() string

+ type EndStreamFrame struct

+ func (f *EndStreamFrame) ReadFrom(r io.Reader) (int64, error)

+ func (f *EndStreamFrame) Type() StreamFrameType

+ func (f *EndStreamFrame) WriteTo(w io.Writer) (int64, error)

type GuardSet

+ func (s *GuardSet) Ckpt() *RWMutexGuard

+ func (s *GuardSet) DMS() *RWMutexGuard

+ func (s *GuardSet) Pending() *RWMutexGuard

+ func (s *GuardSet) Read0() *RWMutexGuard

+ func (s *GuardSet) Read1() *RWMutexGuard

+ func (s *GuardSet) Read2() *RWMutexGuard

+ func (s *GuardSet) Read3() *RWMutexGuard

+ func (s *GuardSet) Read4() *RWMutexGuard

+ func (s *GuardSet) Recover() *RWMutexGuard

+ func (s *GuardSet) Reserved() *RWMutexGuard

+ func (s *GuardSet) Shared() *RWMutexGuard

+ func (s *GuardSet) UnlockDatabase()

+ func (s *GuardSet) UnlockSHM()

+ func (s *GuardSet) Write() *RWMutexGuard

type Invalidator

+ InvalidateDBRange func(db *DB, offset, size int64) error

+ InvalidateEntry func(name string) error

+ InvalidateSHM func(db *DB) error

+ type JournalReader struct

+ func NewJournalReader(f *os.File, pageSize uint32) *JournalReader

+ func (r *JournalReader) DatabaseSize() int64

+ func (r *JournalReader) IsValid() bool

+ func (r *JournalReader) Next() (err error)

+ func (r *JournalReader) ReadFrame() (pgno uint32, data []byte, err error)

type LockType

+ func ParseDatabaseLockRange(start, end uint64) []LockType

+ func ParseSHMLockRange(start, end uint64) []LockType

+ func (t LockType) String() string

type RWMutex

+ OnLockStateChange func(prevState, newState RWMutexState)

type RWMutexGuard

+ func (g *RWMutexGuard) State() RWMutexState

type Store

+ DemoteDelay time.Duration

+ ReconnectDelay time.Duration

+ Retention time.Duration

+ func (s *Store) Demote()

+ func (s *Store) Recover(ctx context.Context) (err error)

+ type WALReader struct

+ func NewWALReader(r io.Reader) *WALReader

+ func (r *WALReader) Offset() int64

+ func (r *WALReader) PageSize() uint32

+ func (r *WALReader) ReadFrame(data []byte) (pgno, commit uint32, err error)

+ func (r *WALReader) ReadHeader() error

Sep 21, 2022

Changes in this version

+ const DefaultRetentionDuration

+ const DefaultRetentionMonitorInterval

+ const FileTypePos

+ const IDLength

+ const RWMutexInterval

+ const SQLITE_DATABASE_HEADER_STRING

+ const StreamFrameTypeReady

type DB

+ Now func() time.Time

+ func (db *DB) ApplyLTX(ctx context.Context, path string) error

+ func (db *DB) EnforceRetention(ctx context.Context, minTime time.Time) error

+ func (db *DB) GuardSet() *GuardSet

+ func (db *DB) PageSize() uint32

+ func (db *DB) ReadLTXDir() ([]fs.DirEntry, error)

+ func (db *DB) Store() *Store

+ func (db *DB) WriteSnapshotTo(ctx context.Context, dst io.Writer) (header ltx.Header, trailer ltx.Trailer, err error)

+ type GuardSet struct

+ func (s *GuardSet) Guard(lockType LockType) *RWMutexGuard

+ func (s *GuardSet) Unlock()

type Invalidator

+ InvalidatePos func(db *DB) error

type LTXStreamFrame

+ Name string

type Leaser

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

type Pos

+ PostApplyChecksum uint64

+ func (p Pos) String() string

+ type PrimaryInfo struct

+ AdvertiseURL string

+ Hostname string

+ func (info *PrimaryInfo) Clone() *PrimaryInfo

type RWMutex

+ func (rw *RWMutex) Guard() RWMutexGuard

type RWMutexGuard

+ func (g *RWMutexGuard) CanRLock() bool

+ func (g *RWMutexGuard) Lock(ctx context.Context) error

+ func (g *RWMutexGuard) TryRLock() bool

type RWMutexState

+ func (s RWMutexState) String() string

+ type ReadyStreamFrame struct

+ func (*ReadyStreamFrame) Type() StreamFrameType

+ func (f *ReadyStreamFrame) ReadFrom(r io.Reader) (int64, error)

+ func (f *ReadyStreamFrame) WriteTo(w io.Writer) (int64, error)

+ type StaticLease struct

+ func (l *StaticLease) Close() error

+ func (l *StaticLease) Renew(ctx context.Context) error

+ func (l *StaticLease) RenewedAt() time.Time

+ func (l *StaticLease) TTL() time.Duration

+ type StaticLeaser struct

+ func NewStaticLeaser(isPrimary bool, hostname, advertiseURL string) *StaticLeaser

+ func (l *StaticLeaser) Acquire(ctx context.Context) (Lease, error)

+ func (l *StaticLeaser) AdvertiseURL() string

+ func (l *StaticLeaser) Close() (err error)

+ func (l *StaticLeaser) IsPrimary() bool

+ func (l *StaticLeaser) PrimaryInfo(ctx context.Context) (PrimaryInfo, error)

type Store

+ RetentionDuration time.Duration

+ RetentionMonitorInterval time.Duration

+ StrictVerify bool

+ func (s *Store) Candidate() bool

+ func (s *Store) CreateDBIfNotExists(name string) (*DB, error)

+ func (s *Store) DBPath(name string) string

+ func (s *Store) EnforceRetention(ctx context.Context) (err error)

+ func (s *Store) ID() string

+ func (s *Store) PrimaryCtx(ctx context.Context) context.Context

+ func (s *Store) PrimaryInfo() *PrimaryInfo

+ func (s *Store) ReadyCh() chan struct{}

+ type StoreVar Store

+ func (v *StoreVar) String() string

Aug 5, 2022

Changes in this version

type DB

+ func (db *DB) DatabasePath() string

+ func (db *DB) JournalPath() string

+ type Invalidator interface

+ InvalidateDB func(db *DB, offset, size int64) error

type Store

+ Invalidator Invalidator

Jul 26, 2022

Changes in this version

+ const F_OFD_GETLK

+ const F_OFD_SETLK

+ const F_OFD_SETLKW

+ const FileTypeDatabase

+ const FileTypeJournal

+ const FileTypeNone

+ const FileTypeSHM

+ const FileTypeWAL

+ const JournalModeDelete

+ const JournalModePersist

+ const JournalModeTruncate

+ const JournalModeWAL

+ const LockTypePending

+ const LockTypeReserved

+ const LockTypeShared

+ const PENDING_BYTE

+ const PageSize

+ const RESERVED_BYTE

+ const RWMutexStateExclusive

+ const RWMutexStateShared

+ const RWMutexStateUnlocked

+ const SHARED_FIRST

+ const SHARED_SIZE

+ const SQLITE_DATABASE_SIZE_OFFSET

+ const SQLITE_JOURNAL_HEADER_STRING

+ const StreamFrameTypeDB

+ const StreamFrameTypeLTX

+ const WALFrameHeaderSize

+ const WALHeaderSize

+ const WALIndexHeaderSize

+ const WAL_CKPT_LOCK

+ const WAL_READ_LOCK0

+ const WAL_READ_LOCK1

+ const WAL_READ_LOCK2

+ const WAL_READ_LOCK3

+ const WAL_READ_LOCK4

+ const WAL_RECOVER_LOCK

+ const WAL_WRITE_LOCK

+ var ErrDatabaseExists = fmt.Errorf("database already exists")

+ var ErrDatabaseNotFound = fmt.Errorf("database not found")

+ var ErrLeaseExpired = errors.New("lease expired")

+ var ErrNoPrimary = errors.New("no primary")

+ var ErrPrimaryExists = errors.New("primary exists")

+ var ErrReadOnlyReplica = fmt.Errorf("read only replica")

+ func FormatDBID(id uint32) string

+ func ParseDBID(s string) (uint32, error)

+ func TrimName(name string) string

+ func WriteStreamFrame(w io.Writer, f StreamFrame) error

+ type Client interface

+ Stream func(ctx context.Context, rawurl string, posMap map[uint32]Pos) (StreamReader, error)

+ type DB struct

+ func NewDB(store *Store, id uint32, path string) *DB

+ func (db *DB) CommitJournal(mode JournalMode) error

+ func (db *DB) CreateJournal() (*os.File, error)

+ func (db *DB) ID() uint32

+ func (db *DB) InWriteTx() bool

+ func (db *DB) LTXDir() string

+ func (db *DB) LTXPath(minTXID, maxTXID uint64) string

+ func (db *DB) Name() string

+ func (db *DB) Open() error

+ func (db *DB) OpenLTXFile(txID uint64) (*os.File, error)

+ func (db *DB) Path() string

+ func (db *DB) PendingLock() *RWMutex

+ func (db *DB) Pos() Pos

+ func (db *DB) ReservedLock() *RWMutex

+ func (db *DB) SharedLock() *RWMutex

+ func (db *DB) TXID() uint64

+ func (db *DB) TryApplyLTX(path string) error

+ func (db *DB) WriteDatabase(f *os.File, data []byte, offset int64) error

+ func (db *DB) WriteJournal(f *os.File, data []byte, offset int64) error

+ type DBStreamFrame struct

+ DBID uint32

+ Name string

+ func (*DBStreamFrame) Type() StreamFrameType

+ func (f *DBStreamFrame) ReadFrom(r io.Reader) (int64, error)

+ func (f *DBStreamFrame) WriteTo(w io.Writer) (int64, error)

+ type FileType int

+ func (t FileType) IsValid() bool

+ type InodeNotifier interface

+ InodeNotify func(dbID uint32, off int64, length int64) error

+ type JournalMode string

+ type LTXStreamFrame struct

+ Size int64

+ func (*LTXStreamFrame) Type() StreamFrameType

+ func (f *LTXStreamFrame) ReadFrom(r io.Reader) (int64, error)

+ func (f *LTXStreamFrame) WriteTo(w io.Writer) (int64, error)

+ type Lease interface

+ Close func() error

+ Renew func(ctx context.Context) error

+ RenewedAt func() time.Time

+ TTL func() time.Duration

+ type Leaser interface

+ Acquire func(ctx context.Context) (Lease, error)

+ AdvertiseURL func() string

+ PrimaryURL func(ctx context.Context) (string, error)

+ type LockType int

+ func ParseLockRange(start, end uint64) []LockType

+ type Pos struct

+ Chksum uint64

+ TXID uint64

+ func (p Pos) IsZero() bool

+ type RWMutex struct

+ func (rw *RWMutex) CanLock() bool

+ func (rw *RWMutex) CanRLock() bool

+ func (rw *RWMutex) State() RWMutexState

+ func (rw *RWMutex) TryLock() *RWMutexGuard

+ func (rw *RWMutex) TryRLock() *RWMutexGuard

+ type RWMutexGuard struct

+ func (g *RWMutexGuard) CanLock() bool

+ func (g *RWMutexGuard) RLock()

+ func (g *RWMutexGuard) TryLock() bool

+ func (g *RWMutexGuard) Unlock()

+ type RWMutexState int

+ type Store struct

+ Client Client

+ InodeNotifier InodeNotifier

+ Leaser Leaser

+ func NewStore(path string) *Store

+ func (s *Store) Close() error

+ func (s *Store) CreateDB(name string) (*DB, *os.File, error)

+ func (s *Store) DB(id uint32) *DB

+ func (s *Store) DBByName(name string) *DB

+ func (s *Store) DBDir(id uint32) string

+ func (s *Store) DBs() []*DB

+ func (s *Store) ForceCreateDB(id uint32, name string) (*DB, error)

+ func (s *Store) IsPrimary() bool

+ func (s *Store) MarkDirty(dbID uint32)

+ func (s *Store) Open() error

+ func (s *Store) Path() string

+ func (s *Store) PosMap() map[uint32]Pos

+ func (s *Store) PrimaryURL() string

+ func (s *Store) Subscribe() *Subscriber

+ func (s *Store) Unsubscribe(sub *Subscriber)

+ type StreamFrame interface

+ Type func() StreamFrameType

+ func ReadStreamFrame(r io.Reader) (StreamFrame, error)

+ type StreamFrameType uint32

+ type StreamReader interface

+ NextFrame func() (StreamFrame, error)

+ type Subscriber struct

+ func (s *Subscriber) Close() error

+ func (s *Subscriber) DirtySet() map[uint32]struct{}

+ func (s *Subscriber) MarkDirty(dbID uint32)

+ func (s *Subscriber) NotifyCh() <-chan struct{}