future

package

v0.1.0-latest-stable Latest Latest Go to latest Published: Sep 30, 2026 License: Apache-2.0 Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func New(fn func() (any, error), cleanupFunc func() bool) *Future

func (f *Future) GetResult() (any, error)

func (f *Future) GetState() FutureTaskState

type FutureTaskState int

const (
	Poll FutureTaskState = iota
	Ready
)

type TaskManager struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewTaskManager(maxRun int) *TaskManager

func (m *TaskManager) Len() int

func (m *TaskManager) RunTask(taskID string, f func() (any, error), cleanupFunc func() bool) (task *Future, maxReached bool)

func (m *TaskManager) StartHousekeeping()