bitask

Documentation

Index

• Constants
• func GetBitpageEventName(e int) string
• type BitpageTask
  • func NewBitpageTask(opts *BitpageTaskOptions) *BitpageTask
  • func (t *BitpageTask) Close()
  • func (t *BitpageTask) PushTask(task *BitpageTaskData)
  • func (t *BitpageTask) Run()
• type BitpageTaskData
• type BitpageTaskOptions
• type MemFlushTask
  • func NewMemFlushTask(opts *MemFlushTaskOptions) *MemFlushTask
  • func (t *MemFlushTask) Close()
  • func (t *MemFlushTask) PushTask(task *MemFlushTaskData)
  • func (t *MemFlushTask) Run()
• type MemFlushTaskData
• type MemFlushTaskOptions

Constants

const (
	BitpageEventFlush int = 1 + iota
	BitpageEventSplit
	BitpageEventFreePage
)

Functions

func GetBitpageEventName

func GetBitpageEventName(e int) string

Types

type BitpageTask

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

func NewBitpageTask

func NewBitpageTask(opts *BitpageTaskOptions) *BitpageTask

func (*BitpageTask) Close

func (t *BitpageTask) Close()

func (*BitpageTask) PushTask

func (t *BitpageTask) PushTask(task *BitpageTaskData)

func (*BitpageTask) Run

func (t *BitpageTask) Run()

type BitpageTaskData

type BitpageTaskData struct {
	Index        int
	Event        int
	Pn           uint32
	Sentinel     []byte
	Pns          []uint32
	SendTime     time.Time
	WaitDuration time.Duration
}

type BitpageTaskOptions

type BitpageTaskOptions struct {
	Size    int
	DbState *statemachine.DbStateMachine
	DoFunc  func(*BitpageTaskData)
	Logger  base.Logger
	TaskWg  *sync.WaitGroup
}

type MemFlushTask

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

func NewMemFlushTask

func NewMemFlushTask(opts *MemFlushTaskOptions) *MemFlushTask

func (*MemFlushTask) Close

func (t *MemFlushTask) Close()

func (*MemFlushTask) PushTask

func (t *MemFlushTask) PushTask(task *MemFlushTaskData)

func (*MemFlushTask) Run

func (t *MemFlushTask) Run()

type MemFlushTaskData

type MemFlushTaskData struct {
	Index      int
	NeedReport bool
}

type MemFlushTaskOptions

type MemFlushTaskOptions struct {
	Size   int
	DoFunc func(*MemFlushTaskData)
	Logger base.Logger
	TaskWg *sync.WaitGroup
}