memeorycontainer

Documentation

Index

• func MakeOrderedMapContainer() *orderedMapContainer
• func MakeQueueContainer(size uint32, timeout time.Duration) *queueContainer
• func MakeredisContainer() *redisContainer
• type MemeoryContainer

Functions

func MakeOrderedMapContainer

func MakeOrderedMapContainer() *orderedMapContainer

MakeOrderedMapContainer 构造队列型任务容器

func MakeQueueContainer

func MakeQueueContainer(size uint32, timeout time.Duration) *queueContainer

MakeQueueContainer 构造队列型任务容器, size 表示队列的大小, timeout 表示队列读取的超时时间

func MakeredisContainer

func MakeredisContainer() *redisContainer

MakeredisContainer 构造队列型任务容器

Types

type MemeoryContainer

type MemeoryContainer interface {
	lighttaskscheduler.TaskContainer

	// AddRunningTask 向容器添加正在运行中的任务
	// 对于某些可持久化任务，调度器如果因为某些原因退出，需要从 db 中恢复状态，这个接口用来向容器中添加恢复前还在执行中的任务
	AddRunningTask(ctx context.Context, task lighttaskscheduler.Task) (err error)
}

MemeoryContainer 内存型任务容器，优先：快读快写，缺点：不可持久化，