store

Documentation

Index

• Constants
• Variables
• type ApplyHandle
• type Index
  • func NewIndex(lsn uint64, csn, size uint32) *Index
  • func (index *Index) Clone() *Index
  • func (index *Index) Compare(o *Index) int
  • func (index *Index) ReadFrom(r io.Reader) (n int64, err error)
  • func (index *Index) String() string
  • func (index *Index) WriteTo(w io.Writer) (n int64, err error)
• type Store
  • func NewStoreWithBatchStoreDriver(dir, name string, cfg *batchstoredriver.StoreCfg) Store
  • func NewStoreWithLogserviceDriver(factory logservicedriver.LogServiceClientFactory) Store
• type StoreImpl
  • func NewStore(driver driver.Driver) *StoreImpl
  • func (w *StoreImpl) Append(gid uint32, e entry.Entry) (lsn uint64, err error)
  • func (w *StoreImpl) CkpCkp()
  • func (w *StoreImpl) Close() error
  • func (w *StoreImpl) FuzzyCheckpoint(gid uint32, indexes []*Index) (ckpEntry entry.Entry, err error)
  • func (w *StoreImpl) Load(gid uint32, lsn uint64) (entry.Entry, error)
  • func (w *StoreImpl) RangeCheckpoint(gid uint32, start, end uint64) (ckpEntry entry.Entry, err error)
  • func (w *StoreImpl) Replay(h ApplyHandle) error
  • func (w *StoreImpl) Start()
• type StoreInfo
  • func (w *StoreInfo) GetCheckpointed(gid uint32) (lsn uint64)
  • func (w *StoreInfo) GetCurrSeqNum(gid uint32) (lsn uint64)
  • func (w *StoreInfo) GetPendding(gid uint32) (cnt uint64)
  • func (w *StoreInfo) GetSynced(gid uint32) (lsn uint64)
  • func (w *StoreInfo) SetCheckpointed(gid uint32, lsn uint64)

Constants

const (
	GroupCKP      = entry.GTCKp
	GroupInternal = entry.GTInternal
)

Variables

var (
	ErrGroupNotFount = moerr.NewInternalError("group not found")
	ErrLsnNotFount   = moerr.NewInternalError("lsn not found")
	ErrTimeOut       = moerr.NewInternalError("retry timeout")
	ErrLsnTooSmall   = moerr.NewInternalError("lsn is too small")
)

var DefaultMaxBatchSize = 10000

Types

type ApplyHandle

type ApplyHandle = func(group uint32, commitId uint64, payload []byte, typ uint16, info any)

type Index

type Index struct {
	LSN  uint64
	CSN  uint32
	Size uint32
}

func NewIndex

func NewIndex(lsn uint64, csn, size uint32) *Index

func (*Index) Clone

func (index *Index) Clone() *Index

func (*Index) Compare

func (index *Index) Compare(o *Index) int

func (*Index) ReadFrom

func (index *Index) ReadFrom(r io.Reader) (n int64, err error)

func (*Index) String

func (index *Index) String() string

func (*Index) WriteTo

func (index *Index) WriteTo(w io.Writer) (n int64, err error)

type Store

type Store interface {
	Append(gid uint32, entry entry.Entry) (lsn uint64, err error)
	FuzzyCheckpoint(gid uint32, idxes []*Index) (ckpEntry entry.Entry, err error)
	RangeCheckpoint(gid uint32, start, end uint64) (ckpEntry entry.Entry, err error)
	Load(gid uint32, lsn uint64) (entry.Entry, error)

	GetCurrSeqNum(gid uint32) (lsn uint64)
	GetSynced(gid uint32) (lsn uint64)
	GetPendding(gid uint32) (cnt uint64)
	GetCheckpointed(gid uint32) (lsn uint64)

	Replay(h ApplyHandle) error
	Close() error
}

func NewStoreWithBatchStoreDriver

func NewStoreWithBatchStoreDriver(dir, name string, cfg *batchstoredriver.StoreCfg) Store

func NewStoreWithLogserviceDriver

func NewStoreWithLogserviceDriver(factory logservicedriver.LogServiceClientFactory) Store

type StoreImpl

type StoreImpl struct {
	*StoreInfo
	common.ClosedState
	// contains filtered or unexported fields
}

func NewStore

func NewStore(driver driver.Driver) *StoreImpl

func (*StoreImpl) Append

func (w *StoreImpl) Append(gid uint32, e entry.Entry) (lsn uint64, err error)

func (*StoreImpl) CkpCkp

func (w *StoreImpl) CkpCkp()

func (*StoreImpl) Close

func (w *StoreImpl) Close() error

func (*StoreImpl) FuzzyCheckpoint

func (w *StoreImpl) FuzzyCheckpoint(gid uint32, indexes []*Index) (ckpEntry entry.Entry, err error)

func (*StoreImpl) Load

func (w *StoreImpl) Load(gid uint32, lsn uint64) (entry.Entry, error)

func (*StoreImpl) RangeCheckpoint

func (w *StoreImpl) RangeCheckpoint(gid uint32, start, end uint64) (ckpEntry entry.Entry, err error)

func (*StoreImpl) Replay

func (w *StoreImpl) Replay(h ApplyHandle) error

func (*StoreImpl) Start

func (w *StoreImpl) Start()

type StoreInfo

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

func (*StoreInfo) GetCheckpointed

func (w *StoreInfo) GetCheckpointed(gid uint32) (lsn uint64)

func (*StoreInfo) GetCurrSeqNum

func (w *StoreInfo) GetCurrSeqNum(gid uint32) (lsn uint64)

func (*StoreInfo) GetPendding

func (w *StoreInfo) GetPendding(gid uint32) (cnt uint64)

func (*StoreInfo) GetSynced

func (w *StoreInfo) GetSynced(gid uint32) (lsn uint64)

func (*StoreInfo) SetCheckpointed

func (w *StoreInfo) SetCheckpointed(gid uint32, lsn uint64)