Function WithExecutorID

execution/context.go:16–25

(ctx context.Context, executorID string)

)

func WithExecutorID(ctx context.Context, executorID string) context.Context {
	currentPath := ExecutorPath(ctx)
	newPath := fmt.Sprintf("%s/%s", currentPath, executorID)
	currentDepth := ExecutorDepth(ctx)
	newDepth := currentDepth + 1
	ctx = context.WithValue(ctx, executorIDCtxKey, executorID)
	ctx = context.WithValue(ctx, executorPathCtxKey, newPath)
	ctx = context.WithValue(ctx, executorDepthCtxKey, newDepth)
	return ctx
}

func ExecutorID(ctx context.Context) string {
	v, ok := ctx.Value(executorIDCtxKey).(string)