Method format

cli/command/service/logs.go:207–244

(ctx context.Context, logCtx logContext)

}

func (f *taskFormatter) format(ctx context.Context, logCtx logContext) (string, error) {
	if cached, ok := f.cache[logCtx]; ok {
		return cached, nil
	}

	nodeName, err := f.r.Resolve(ctx, swarm.Node{}, logCtx.nodeID)
	if err != nil {
		return "", err
	}

	serviceName, err := f.r.Resolve(ctx, swarm.Service{}, logCtx.serviceID)
	if err != nil {
		return "", err
	}

	res, err := f.client.TaskInspect(ctx, logCtx.taskID, client.TaskInspectOptions{})
	if err != nil {
		return "", err
	}

	taskName := fmt.Sprintf("%s.%d", serviceName, res.Task.Slot)
	if !f.opts.noTaskIDs {
		if f.opts.noTrunc {
			taskName += "." + res.Task.ID
		} else {
			taskName += "." + formatter.TruncateID(res.Task.ID)
		}
	}

	paddingCount := f.padding - getMaxLength(res.Task.Slot)
	padding := ""
	if paddingCount > 0 {
		padding = strings.Repeat(" ", paddingCount)
	}
	formatted := taskName + "@" + nodeName + padding
	f.cache[logCtx] = formatted
	return formatted, nil
}

type logWriter struct {
	ctx  context.Context