workQueue

package

v0.0.2 Latest Latest Go to latest Published: Jan 15, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Details

This section is empty.

View Source

var Queue chan interface{}

func Close()

func InitWorkQueue()

func SyncLoop(ctx context.Context, wg *sync.WaitGroup)

SyncLoop 将容器的创建信息同步到etcd，当程序收到停止信号时，已经开始的 put 任务会继续执行但是没有开始的任务，不会被执行，SyncLoop 会直接返回

func VolumeMountPoint(name string) (string, error)

VolumeMountPoint 获取 Volume 的 MountPoint

type CopyTask struct {
	Resource    etcd.EtcdResource
	OldResource string
	NewResource string
}