mrshandler

package
v0.0.0-...-83dc736 Latest Latest
Warning

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

 Go to latest Published: Jan 18, 2019 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	JOB_STAT_TERM      = "Terminated"
	JOB_STAT_STARTING  = "Starting"
	JOB_STAT_RUNNING   = "Running"
	JOB_STAT_COMPLETED = "Completed"
	JOB_STAT_ABNORMAL  = "Abnormal"
	JOB_STAT_ERROR     = "Error"
)
View Source 
var (
	KEY_CLUSTER_ID   = "ClusterID"
	KEY_ENDPOINT     = "Endpoint"
	KEY_ACCESS_KEY   = "AccessKey"
	KEY_SECURITY_KEY = "SecurityKey"
	//KEY_REGION      = "Region"
	KEY_UNAME     = "Uname"
	KEY_PASSWD    = "Passwd"
	KEY_DNAME     = "Dname"
	KEY_PROJ_ID   = "ProjID"
	KEY_BUCKET    = "Bucket"
	KEY_PROG_NAME = "ProgName"
	KEY_ARGUMENTS = "Arguments"
)

Functions

This section is empty.

Types

type MrsDataAnalst 

type MrsDataAnalst struct {
	ClusterID   string
	AccessKey   string
	SecurityKey string
	Endpoint    string
	Uname       string
	Passwd      string
	Dname       string
	JobName     string
	ProjID      string
	ProgName    string
	Arguments   string
	Path        string //bucket + virt_bucket
	Token       string
	JobID       string
}

func (*MrsDataAnalst) Handle 

func (da *MrsDataAnalst) Handle(ctx context.Context, in *pb.RunJobRequest, j *flowtype.Job, remoteBucket string) error

func (*MrsDataAnalst) Init 

func (da *MrsDataAnalst) Init(in *string) error

type PyResp 

type PyResp struct {
	Err         string `json:"err,omitempty"`
	Token       string `json:"token,omitempty"`
	JobID       string `json:"jobid,omitempty"`
	JobStat     string `json:"jobstat,omitempty"`
	JobProgress string `json:"jobprogress,omitempty"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.