v1.9.6 Latest Latest

This package is not in the latest version of its module.

Go to latest
Published: Feb 28, 2022 License: GPL-3.0 Imports: 35 Imported by: 1



Package cloud contains utilities for distributed InMAP simulations.



This section is empty.


This section is empty.


func JobSpec

func JobSpec(root *cobra.Command, config *viper.Viper, version, name string, cmdArgs, inputFiles []string, memoryGB int32) (*cloudrpc.JobSpec, error)

JobSpec initializes a cloudrpc.JobSpec object from the given configuration information. memoryGB and storageGB are the required amounts of RAM and hard-disk storage, respectively, in gigabytes. name is the user-specified job name, cmdArgs is a list of InMAP sub-commands (e.g., "run steady"), and inputFiles is a list of the configuration arguments that represent input files. Version is the version of the InMAP Docker image to use, such as "latest" or "v1.7.2".

func OpenBucket

func OpenBucket(ctx context.Context, bucketName string) (*blob.Bucket, error)

OpenBucket returns the blob storage bucket specified by bucketName, where bucketName must be in the format 'provider://name' where provider is the name of the storage provider and name is the name of the bucket. Even if name contains subdirectories, only the base directory name will be used when opening the bucket. The currently accepted storage providers are "file" for the local filesystem (e.g., for testing), "gs" for Google Cloud Storage, and "s3" for AWS S3.


type Client

type Client struct {


	// Image holds the container image to be used.
	// The default is "inmap/inmap:latest".
	Image string

	// Volumes specifies any Kubernetes volumes that are to be
	// mounted in the containers that are created.
	// Each volume will be mounted at /data/volumeName
	// with read-only access.
	Volumes []core.Volume
	// contains filtered or unexported fields

Client is a Kubernetes client for InMAP.

func NewClient

func NewClient(k kubernetes.Interface, root *cobra.Command, config *viper.Viper, bucketName string, inputFileArgs, outputFileArgs []string) (*Client, error)

NewClient creates a new distributed InMAP Kubernetes client. root is the root command to be run, config holds simulation configuration information, and bucketName is the name of a blob storage bucket for storing output files in the format gs://bucketname. inputFileArgs and outputFileArgs list the names of the configuration arguments that represent input and output files.

func NewFakeClient

func NewFakeClient(checkConfig func([]string), checkRun func([]byte, error), bucket string, root *cobra.Command, config *viper.Viper, inputFileArgs, outputFileArgs []string) (*Client, error)

NewFakeClient creates a client for testing. Jobs that are created using this client are run locally. The InMAP command must be compiled for it to work, e.g., `go install`. The checkConfig and checkRun functions, if not nil, will be run before and after executing the inmap command, respectively.

func (*Client) Delete

func (c *Client) Delete(ctx context.Context, job *cloudrpc.JobName) (*cloudrpc.JobName, error)

Delete deletes the given job.

func (*Client) Output

func (c *Client) Output(ctx context.Context, job *cloudrpc.JobName) (*cloudrpc.JobOutput, error)

Output returns the output of the specified job.

func (*Client) RunJob

func (c *Client) RunJob(ctx context.Context, job *cloudrpc.JobSpec) (*cloudrpc.JobStatus, error)

RunJob creates (and queues) a Kubernetes job with the given name that executes the given command with the given command-line arguments on the given container image. resources specifies the minimum required resources for execution.

func (*Client) Status

func (c *Client) Status(ctx context.Context, job *cloudrpc.JobName) (*cloudrpc.JobStatus, error)

Status returns the status of the given job.

type FakeRPCClient

type FakeRPCClient struct {
	Client *Client

FakeRPCClient is a local RPC client for testing.

func (FakeRPCClient) Delete

func (FakeRPCClient) Output

func (FakeRPCClient) RunJob

func (FakeRPCClient) Status


Path Synopsis
Package cloudrpc is a generated protocol buffer package.
Package cloudrpc is a generated protocol buffer package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL