queue

type Interface interface {
	// IdempotentGetProjectLevelQueue returns project level queue
	// if not exists, automatically create one by given workspace and project resource config
	IdempotentGetProjectLevelQueue(workspace string, project *apistructs.ProjectDTO) (*pb.Queue, error)

	InjectQueueManager(queueManager pb.QueueServiceServer)
}

type ProjectQueueResource struct {
	Concurrency int64
	MaxCPU      float64
	MaxMemoryMB float64
}