ealthread

type AllocReq struct {
	Role   string         // role name, must not be empty
	Socket eal.NumaSocket // preferred NUMA socket
}

type Config map[string]RoleConfig

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

type LoadStat struct {
	// EmptyPolls is number of polls that processed zero item.
	EmptyPolls uint64 `json:"emptyPolls" gqldesc:"Polls that processed zero item."`

	// ValidPolls is number of polls that processed non-zero items.
	ValidPolls uint64 `json:"validPolls" gqldesc:"Polls that processed non-zero items."`

	// Items is count of processed items.
	Items uint64 `json:"items" gqldesc:"Count of processed items."`

	// ItemsPerPoll is average count of processed items per valid poll.
	// This is only available from Sub() return value.
	ItemsPerPoll float64 `json:"itemsPerPoll,omitempty" gqldesc:"Average count of processed items per valid poll."`
}

type RoleConfig struct {
	LCores  []int
	PerNuma map[int]int
}

type StopChan chan bool

type Stopper interface {
	// BeforeWait is invoked before lcore.Wait().
	BeforeWait()

	// AfterWait is invoked after lcore.Wait().
	AfterWait()
}

type Thread interface {
	// LCore returns allocated lcore.
	LCore() eal.LCore

	// SetLCore assigns an lcore.
	// This can only be used when the thread is stopped.
	SetLCore(lc eal.LCore)

	// IsRunning indicates whether the thread is running.
	IsRunning() bool

	// Stop stops the thread.
	Stop() error
	// contains filtered or unexported methods
}

type ThreadWithCtrl interface {
	ThreadWithLoadStat
	ThreadCtrl() *Ctrl
}

type ThreadWithLoadStat interface {
	Thread
	ThreadLoadStat() LoadStat
}

type ThreadWithRole interface {
	Thread
	ThreadRole() string
}