store

Documentation

Index

• Constants
• Variables
• type ApplyHandle
• 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) Close() 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.NewInternalErrorNoCtx("group not found")
	ErrLsnNotFount   = moerr.NewInternalErrorNoCtx("lsn not found")
	ErrTimeOut       = moerr.NewInternalErrorNoCtx("retry timeout")
	ErrLsnTooSmall   = moerr.NewInternalErrorNoCtx("lsn is too small")
)

var DefaultMaxBatchSize = 10000

Types

type ApplyHandle

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

type Store

type Store interface {
	Append(gid uint32, entry entry.Entry) (lsn uint64, 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
	sm.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) Close

func (w *StoreImpl) Close() 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)