pool

Documentation

Index

• Variables
• type BufferPoolManager
  • func NewBufferPool(o Options) BufferPoolManager
• type Ctx
• type FetchPageOption
• type FindOneAvailablePageOption
• type Frame
• type NewPageOption
  • func MergeNewPageOptions(opts ...*NewPageOption) *NewPageOption
• type Options
• type PageID

Variables

var (
	ErrNoAvailablePage = errors.New("failed to find an available page")
	ErrPinCountZero    = errors.New("page pin count is not zero")
)

Types

type BufferPoolManager

type BufferPoolManager interface {
	FetchPage(ctx Ctx, pageId uint64, opts ...*FetchPageOption) (page.Page, error)
	UnpinPage(ctx Ctx, pageId uint64, dirty bool) (bool, error)
	NewPage(ctx Ctx, pageId *uint64, opts ...*NewPageOption) (page.Page, error)
	DeletePage(ctx Ctx, pageId uint64) (bool, error)
	FlushAll(ctx Ctx) error
}

func NewBufferPool

func NewBufferPool(o Options) BufferPoolManager

NewBufferPool TODO: pre-allocation

type Ctx

type Ctx interface {
}

Ctx TODO

type FetchPageOption

type FetchPageOption struct {
}

type FindOneAvailablePageOption

type FindOneAvailablePageOption struct {
}

type Frame

type Frame uint64

type NewPageOption

type NewPageOption struct {
}

func MergeNewPageOptions

func MergeNewPageOptions(opts ...*NewPageOption) *NewPageOption

type Options

type Options struct {
	DiskManager disk.BasicManager
	Replacer    replacer.Replacer
	Cap         uint64
	Len         uint64
}

type PageID

type PageID uint64