File: //snap/google-cloud-cli/current/lib/googlecloudsdk/command_lib/emulators/bigtable_util.py
# -*- coding: utf-8 -*- #
# Copyright 2015 Google LLC. All Rights Reserved.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
"""Utility functions for gcloud bigtable emulator."""
from __future__ import absolute_import
from __future__ import division
from __future__ import unicode_literals
import os
from googlecloudsdk.command_lib.emulators import util
from googlecloudsdk.core import execution_utils
from googlecloudsdk.core import log
from googlecloudsdk.core.util import platforms
BIGTABLE = 'bigtable'
BIGTABLE_TITLE = 'Google Cloud Bigtable emulator'
BIGTABLE_EXECUTABLE = 'cbtemulator'
def GetDataDir():
return util.GetDataDir(BIGTABLE)
def BuildStartArgs(args):
"""Builds the command for starting the bigtable emulator.
Args:
args: (list of str) The arguments for the bigtable emulator, excluding the
program binary.
Returns:
A list of command arguments.
"""
bigtable_dir = util.GetEmulatorRoot(BIGTABLE)
bigtable_executable = os.path.join(bigtable_dir, BIGTABLE_EXECUTABLE)
if platforms.OperatingSystem.Current() is platforms.OperatingSystem.WINDOWS:
bigtable_executable += '.exe'
return execution_utils.ArgsForExecutableTool(bigtable_executable, *args)
def GetEnv(args):
"""Returns an environment variable mapping from an argparse.Namespace."""
return {
'BIGTABLE_EMULATOR_HOST':
'%s:%s' % (args.host_port.host, args.host_port.port)
}
def Start(args):
bigtable_args = BuildStartArgs(util.BuildArgsList(args))
log.status.Print('Executing: {0}'.format(' '.join(bigtable_args)))
with util.Exec(bigtable_args) as bigtable_process:
util.WriteEnvYaml(GetEnv(args), GetDataDir())
util.PrefixOutput(bigtable_process, BIGTABLE)