storage

Documentation

Index

• type StoreBase
  • func NewStoreBase(ctx context.Context, PID entity.PartitionID, NodeID entity.NodeID, ...) (*StoreBase, error)
  • func (s *StoreBase) GetEngine() engine.Engine
  • func (s *StoreBase) GetSpace() entity.Space
  • func (s *StoreBase) GetVersion() entity.Version
  • func (s *StoreBase) SetSpace(space *entity.Space)

Types

type StoreBase

type StoreBase struct {
	sync.RWMutex
	Ctx       context.Context
	CtxCancel context.CancelFunc

	NodeID    entity.NodeID
	DataPath  string
	MetaPath  string
	Space     *entity.Space
	Partition *entity.Partition
	CloseOnce sync.Once

	Engine engine.Engine
}

StoreBase is the base class of partition store.

func NewStoreBase

func NewStoreBase(ctx context.Context, PID entity.PartitionID, NodeID entity.NodeID, path, DataPath, MetaPath string, space *entity.Space) (*StoreBase, error)

func (*StoreBase) GetEngine

func (s *StoreBase) GetEngine() engine.Engine

func (*StoreBase) GetSpace

func (s *StoreBase) GetSpace() entity.Space

func (*StoreBase) GetVersion

func (s *StoreBase) GetVersion() entity.Version

func (*StoreBase) SetSpace

func (s *StoreBase) SetSpace(space *entity.Space)