1 // Copyright (C) The Arvados Authors. All rights reserved.
3 // SPDX-License-Identifier: AGPL-3.0
12 "git.arvados.org/arvados.git/sdk/go/arvados"
15 // Run a service using the arvados-server binary.
17 // In future this will bring up the service in the current process,
18 // but for now (at least until the subcommand handlers get a shutdown
19 // mechanism) it starts a child process using the arvados-server
20 // binary, which the supervisor is assumed to have installed in
21 // {super.tempdir}/bin/.
22 type runServiceCommand struct {
23 name string // arvados-server subcommand, e.g., "controller"
24 svc arvados.Service // cluster.Services.* entry with the desired InternalURLs
25 depends []supervisedTask // wait for these tasks before starting
28 func (runner runServiceCommand) String() string {
32 func (runner runServiceCommand) Run(ctx context.Context, fail func(error), super *Supervisor) error {
33 binfile := filepath.Join(super.bindir, "arvados-server")
34 err := super.RunProgram(ctx, super.bindir, nil, nil, binfile, "-version")
38 super.wait(ctx, runner.depends...)
39 for u := range runner.svc.InternalURLs {
41 if islocal, err := addrIsLocal(u.Host); err != nil {
46 super.waitShutdown.Add(1)
48 defer super.waitShutdown.Done()
49 fail(super.RunProgram(ctx, super.tempdir, nil, []string{"ARVADOS_SERVICE_INTERNAL_URL=" + u.String()}, binfile, runner.name, "-config", super.configfile))
55 // Run a Go service that isn't bundled in arvados-server.
56 type runGoProgram struct {
57 src string // source dir, e.g., "services/keepproxy"
58 svc arvados.Service // cluster.Services.* entry with the desired InternalURLs
59 depends []supervisedTask // wait for these tasks before starting
62 func (runner runGoProgram) String() string {
63 _, basename := filepath.Split(runner.src)
67 func (runner runGoProgram) Run(ctx context.Context, fail func(error), super *Supervisor) error {
68 if len(runner.svc.InternalURLs) == 0 {
69 return errors.New("bug: runGoProgram needs non-empty svc.InternalURLs")
72 binfile, err := super.installGoProgram(ctx, runner.src)
80 err = super.RunProgram(ctx, super.tempdir, nil, nil, binfile, "-version")
85 super.wait(ctx, runner.depends...)
86 for u := range runner.svc.InternalURLs {
88 if islocal, err := addrIsLocal(u.Host); err != nil {
93 super.waitShutdown.Add(1)
95 defer super.waitShutdown.Done()
96 fail(super.RunProgram(ctx, super.tempdir, nil, []string{"ARVADOS_SERVICE_INTERNAL_URL=" + u.String()}, binfile))