Method Create

core/metadata/containers.go:123–172

(ctx context.Context, container containers.Container)

}

func (s *containerStore) Create(ctx context.Context, container containers.Container) (containers.Container, error) {
	ctx, span := tracing.StartSpan(ctx,
		tracing.Name(spanContainerPrefix, "Create"),
		tracing.WithAttribute("container.id", container.ID),
		tracing.WithNamespace(ctx),
	)
	defer span.End()
	if container.SandboxID != "" {
		span.SetAttributes(tracing.Attribute("sandbox.id", container.SandboxID))
	}
	namespace, err := namespaces.NamespaceRequired(ctx)
	if err != nil {
		return containers.Container{}, err
	}

	if err := validateContainer(&container); err != nil {
		return containers.Container{}, fmt.Errorf("create container failed validation: %w", err)
	}

	if err := update(ctx, s.db, func(tx *bolt.Tx) error {
		bkt, err := createContainersBucket(tx, namespace)
		if err != nil {
			return err
		}

		cbkt, err := bkt.CreateBucket([]byte(container.ID))
		if err != nil {
			if err == errbolt.ErrBucketExists {
				err = fmt.Errorf("container %q: %w", container.ID, errdefs.ErrAlreadyExists)
			}
			return err
		}

		container.CreatedAt = time.Now().UTC()
		container.UpdatedAt = container.CreatedAt
		if err := writeContainer(cbkt, &container); err != nil {
			return fmt.Errorf("failed to write container %q: %w", container.ID, err)
		}

		span.SetAttributes(
			tracing.Attribute("container.createdAt", container.CreatedAt.Format(time.RFC3339)),
			tracing.Attribute("container.updatedAt", container.UpdatedAt.Format(time.RFC3339)),
		)
		return nil
	}); err != nil {
		return containers.Container{}, err
	}

	return container, nil
}

func (s *containerStore) Update(ctx context.Context, container containers.Container, fieldpaths ...string) (containers.Container, error) {
	if container.ID == "" {