Function newVertex

dag/vertex.go:30–43

(id int, work func(ctx context.Context) error, options ...VertexOption)

}

func newVertex(id int, work func(ctx context.Context) error, options ...VertexOption) *vertex {
	vertex := &vertex{
		id:   id,
		work: work,
		done: make(chan struct{}),
	}
	for _, f := range options {
		f(vertex)
	}
	if vertex.name == "" {
		vertex.name = "vertex-" + strconv.Itoa(id)
	}
	return vertex
}

func (v *vertex) execute(ctx context.Context) error {
	if v.logger != nil {