lib/controller/localdb/container_request.go

   1 // Copyright (C) The Arvados Authors. All rights reserved.
   2 //
   3 // SPDX-License-Identifier: AGPL-3.0
   4
   5 package localdb
   6
   7 import (
   8         "context"
   9
  10         "git.arvados.org/arvados.git/sdk/go/arvados"
  11 )
  12
  13 // ContainerRequestCreate defers to railsProxy for everything except
  14 // vocabulary checking.
  15 func (conn *Conn) ContainerRequestCreate(ctx context.Context, opts arvados.CreateOptions) (arvados.ContainerRequest, error) {
  16         conn.logActivity(ctx)
  17         err := conn.checkProperties(ctx, opts.Attrs["properties"])
  18         if err != nil {
  19                 return arvados.ContainerRequest{}, err
  20         }
  21         resp, err := conn.railsProxy.ContainerRequestCreate(ctx, opts)
  22         if err != nil {
  23                 return resp, err
  24         }
  25         return resp, nil
  26 }
  27
  28 // ContainerRequestUpdate defers to railsProxy for everything except
  29 // vocabulary checking.
  30 func (conn *Conn) ContainerRequestUpdate(ctx context.Context, opts arvados.UpdateOptions) (arvados.ContainerRequest, error) {
  31         conn.logActivity(ctx)
  32         err := conn.checkProperties(ctx, opts.Attrs["properties"])
  33         if err != nil {
  34                 return arvados.ContainerRequest{}, err
  35         }
  36         resp, err := conn.railsProxy.ContainerRequestUpdate(ctx, opts)
  37         if err != nil {
  38                 return resp, err
  39         }
  40         return resp, nil
  41 }
  42
  43 func (conn *Conn) ContainerRequestGet(ctx context.Context, opts arvados.GetOptions) (arvados.ContainerRequest, error) {
  44         conn.logActivity(ctx)
  45         return conn.railsProxy.ContainerRequestGet(ctx, opts)
  46 }
  47
  48 func (conn *Conn) ContainerRequestList(ctx context.Context, opts arvados.ListOptions) (arvados.ContainerRequestList, error) {
  49         conn.logActivity(ctx)
  50         return conn.railsProxy.ContainerRequestList(ctx, opts)
  51 }
  52
  53 func (conn *Conn) ContainerRequestDelete(ctx context.Context, opts arvados.DeleteOptions) (arvados.ContainerRequest, error) {
  54         conn.logActivity(ctx)
  55         return conn.railsProxy.ContainerRequestDelete(ctx, opts)
  56 }