grpc_trainer_v2

package
v0.0.0-...-4e3790f Latest Latest
Warning

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

 Go to latest Published: Aug 30, 2019 License: Apache-2.0, CC-BY-4.0, MIT Imports: 5 Imported by: 8

Documentation

Overview

Package grpc_trainer_v2 is a generated protocol buffer package.

It is generated from these files: 

trainer.proto

It has these top-level messages: 

CreateRequest
EMExtractionSpec
EMGroup
EMMeta
EMAny
MetaInfo
LogLine
Any
EMetrics
Query
CreateResponse
UpdateRequest
UpdateResponse
GetRequest
GetResponse
GetStatusResponse
GetStatusIDResponse
GetMetricsStringResponse
GetTestResponse
GetAllRequest
GetAllResponse
HaltRequest
HaltResponse
ResumeRequest
ResumeResponse
DeleteRequest
DeleteResponse
Metrics
Job
ModelDefinition
Framework
ImageLocation
Training
TrainingStatus
Datastore
ResourceRequirements
ModelDefinitionRequest
TrainedModelRequest
TrainedModelLogRequest
TrainedModelMetricsRequest
GetLatestMetricsRequest
GetLatestMetricsResponse
UpdateTrainedModelMetricsRequest
UpdateTrainedModelMetricsResponse
ByteStreamResponse
ZippedDataChunk
GetVersionsRequest
Frameworks
FrameworkDetailList
FrameworkDetails

Index

Constants

This section is empty.

Variables

View Source 
var Any_DataType_name = map[int32]string{
	0: "STRING",
	1: "JSONSTRING",
	2: "INT",
	3: "FLOAT",
}
View Source 
var Any_DataType_value = map[string]int32{
	"STRING":     0,
	"JSONSTRING": 1,
	"INT":        2,
	"FLOAT":      3,
}
View Source 
var Query_SearchType_name = map[int32]string{
	0: "TERM",
	1: "NESTED",
	2: "MATCH",
	3: "ALL",
}
View Source 
var Query_SearchType_value = map[string]int32{
	"TERM":   0,
	"NESTED": 1,
	"MATCH":  2,
	"ALL":    3,
}
View Source 
var SizeUnit_name = map[int32]string{
	0: "MB",
	1: "MiB",
	2: "GB",
	3: "GiB",
}
View Source 
var SizeUnit_value = map[string]int32{
	"MB":  0,
	"MiB": 1,
	"GB":  2,
	"GiB": 3,
}
View Source 
var Status_name = map[int32]string{
	0:  "NOT_STARTED",
	1:  "PENDING",
	5:  "HALTED",
	10: "FAILED",
	20: "DEPLOY",
	30: "DOWNLOADING",
	40: "PROCESSING",
	50: "STORING",
	60: "COMPLETED",
	70: "QUEUED",
}
View Source 
var Status_value = map[string]int32{
	"NOT_STARTED": 0,
	"PENDING":     1,
	"HALTED":      5,
	"FAILED":      10,
	"DEPLOY":      20,
	"DOWNLOADING": 30,
	"PROCESSING":  40,
	"STORING":     50,
	"COMPLETED":   60,
	"QUEUED":      70,
}

Functions

func RegisterTrainerServer 

func RegisterTrainerServer(s *grpc.Server, srv TrainerServer)

Types

type Any 

type Any struct {
	// Datatype of the value.
	Type Any_DataType `protobuf:"varint,1,opt,name=type,enum=grpc.trainer.v2.Any_DataType" json:"type,omitempty" bson:"type,omitempty"`
	// String representation of a value
	Value string `protobuf:"bytes,2,opt,name=value" json:"value,omitempty" bson:"value,omitempty"`
}

Any represents a typed value used with the evaluation metrics record.

func (*Any) Descriptor 

func (*Any) Descriptor() ([]byte, []int)

func (*Any) GetType 

func (m *Any) GetType() Any_DataType

func (*Any) GetValue 

func (m *Any) GetValue() string

func (*Any) ProtoMessage 

func (*Any) ProtoMessage()

func (*Any) Reset 

func (m *Any) Reset()

func (*Any) String 

func (m *Any) String() string

type Any_DataType 

type Any_DataType int32
const (
	Any_STRING     Any_DataType = 0
	Any_JSONSTRING Any_DataType = 1
	Any_INT        Any_DataType = 2
	Any_FLOAT      Any_DataType = 3
)

func (Any_DataType) EnumDescriptor 

func (Any_DataType) EnumDescriptor() ([]byte, []int)

func (Any_DataType) String 

func (x Any_DataType) String() string

type ByteStreamResponse 

type ByteStreamResponse struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty" bson:"data,omitempty"`
}

func (*ByteStreamResponse) Descriptor 

func (*ByteStreamResponse) Descriptor() ([]byte, []int)

func (*ByteStreamResponse) GetData 

func (m *ByteStreamResponse) GetData() []byte

func (*ByteStreamResponse) ProtoMessage 

func (*ByteStreamResponse) ProtoMessage()

func (*ByteStreamResponse) Reset 

func (m *ByteStreamResponse) Reset()

func (*ByteStreamResponse) String 

func (m *ByteStreamResponse) String() string

type CreateRequest 

type CreateRequest struct {
	UserId          string           `protobuf:"bytes,1,opt,name=user_id,json=userId" json:"user_id,omitempty" bson:"user_id,omitempty"`
	ModelDefinition *ModelDefinition `` /* 133-byte string literal not displayed */
	Training        *Training        `protobuf:"bytes,3,opt,name=training" json:"training,omitempty" bson:"training,omitempty"`
	Datastores      []*Datastore     `protobuf:"bytes,4,rep,name=datastores" json:"datastores,omitempty" bson:"datastores,omitempty"`
	// EMExtractionSpec allows the caller to specify evaluation metrics extraction.
	EvaluationMetrics *EMExtractionSpec `` /* 141-byte string literal not displayed */
}

func (*CreateRequest) Descriptor 

func (*CreateRequest) Descriptor() ([]byte, []int)

func (*CreateRequest) GetDatastores 

func (m *CreateRequest) GetDatastores() []*Datastore

func (*CreateRequest) GetEvaluationMetrics 

func (m *CreateRequest) GetEvaluationMetrics() *EMExtractionSpec

func (*CreateRequest) GetModelDefinition 

func (m *CreateRequest) GetModelDefinition() *ModelDefinition

func (*CreateRequest) GetTraining 

func (m *CreateRequest) GetTraining() *Training

func (*CreateRequest) GetUserId 

func (m *CreateRequest) GetUserId() string

func (*CreateRequest) ProtoMessage 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) Reset 

func (m *CreateRequest) Reset()

func (*CreateRequest) String 

func (m *CreateRequest) String() string

type CreateResponse 

type CreateResponse struct {
	TrainingId string `protobuf:"bytes,1,opt,name=training_id,json=trainingId" json:"training_id,omitempty" bson:"training_id,omitempty"`
}

func (*CreateResponse) Descriptor 

func (*CreateResponse) Descriptor() ([]byte, []int)

func (*CreateResponse) GetTrainingId 

func (m *CreateResponse) GetTrainingId() string

func (*CreateResponse) ProtoMessage 

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) Reset 

func (m *CreateResponse) Reset()

func (*CreateResponse) String 

func (m *CreateResponse) String() string

type Datastore 

type Datastore struct {
	Id   string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty" bson:"id,omitempty"`
	Type string `protobuf:"bytes,2,opt,name=type" json:"type,omitempty" bson:"type,omitempty"`
	// additional fields for the given Datastore type
	Fields map[string]string `` /* 156-byte string literal not displayed */
	// connection information for the given Datastore type
	Connection map[string]string `` /* 168-byte string literal not displayed */
}

func (*Datastore) Descriptor 

func (*Datastore) Descriptor() ([]byte, []int)

func (*Datastore) GetConnection 

func (m *Datastore) GetConnection() map[string]string

func (*Datastore) GetFields 

func (m *Datastore) GetFields() map[string]string

func (*Datastore) GetId 

func (m *Datastore) GetId() string

func (*Datastore) GetType 

func (m *Datastore) GetType() string

func (*Datastore) ProtoMessage 

func (*Datastore) ProtoMessage()

func (*Datastore) Reset 

func (m *Datastore) Reset()

func (*Datastore) String 

func (m *Datastore) String() string

type DeleteRequest 

type DeleteRequest struct {
	TrainingId string `protobuf:"bytes,1,opt,name=training_id,json=trainingId" json:"training_id,omitempty" bson:"training_id,omitempty"`
	UserId     string `protobuf:"bytes,2,opt,name=user_id,json=userId" json:"user_id,omitempty" bson:"user_id,omitempty"`
}

func (*DeleteRequest) Descriptor 

func (*DeleteRequest) Descriptor() ([]byte, []int)

func (*DeleteRequest) GetTrainingId 

func (m *DeleteRequest) GetTrainingId() string

func (*DeleteRequest) GetUserId 

func (m *DeleteRequest) GetUserId() string

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (m *DeleteRequest) String() string

type DeleteResponse 

type DeleteResponse struct {
	TrainingId string `protobuf:"bytes,1,opt,name=training_id,json=trainingId" json:"training_id,omitempty" bson:"training_id,omitempty"`
}

func (*DeleteResponse) Descriptor 

func (*DeleteResponse) Descriptor() ([]byte, []int)

func (*DeleteResponse) GetTrainingId 

func (m *DeleteResponse) GetTrainingId() string

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) Reset 

func (m *DeleteResponse) Reset()

func (*DeleteResponse) String 

func (m *DeleteResponse) String() string

type EMAny 

type EMAny struct {
	// one of: STRING, JSONSTRING, INT, FLOAT
	Type string `protobuf:"bytes,1,opt,name=type" json:"type,omitempty" bson:"type,omitempty"`
	// String represenation of the value.
	Value string `protobuf:"bytes,2,opt,name=value" json:"value,omitempty" bson:"value,omitempty"`
}

Typed value for EMExtractionSpec. The data type here can't be an enum, due to internal issues with YAML conversion.

func (*EMAny) Descriptor 

func (*EMAny) Descriptor() ([]byte, []int)

func (*EMAny) GetType 

func (m *EMAny) GetType() string

func (*EMAny) GetValue 

func (m *EMAny) GetValue() string

func (*EMAny) ProtoMessage 

func (*EMAny) ProtoMessage()

func (*EMAny) Reset 

func (m *EMAny) Reset()

func (*EMAny) String 

func (m *EMAny) String() string

type EMExtractionSpec 

type EMExtractionSpec struct {
	// Loosly typed string representing what kind of log-collector to use.
	// For Logs-only, specify `type: logger`
	// For the Regex_extractor log-collector, specify `type: regex_extractor`
	// For Tensorboard, specify `type: tensorboard`
	// To invoke the emetrics_file_extractor, you can specify the following synonyms
	// `type: optivist` || `type: emetrics_file` || `type: file`.
	Type     string `protobuf:"bytes,1,opt,name=type" json:"type,omitempty" bson:"type,omitempty"`
	ImageTag string `protobuf:"bytes,6,opt,name=image_tag,json=imageTag" json:"image_tag,omitempty" bson:"image_tag,omitempty"`
	// The filename of the logfile.  (Normally this should be left to default).
	In string `protobuf:"bytes,2,opt,name=in" json:"in,omitempty" bson:"in,omitempty"`
	// For the regex_extractor, number of lines to keep in the buffer for regex matching.
	LineLookahead int32 `` /* 126-byte string literal not displayed */
	// (Eventual) Available event types: 'images', 'distributions', 'histograms', 'images'
	// 'audio', 'scalars', 'tensors', 'graph', 'meta_graph', 'run_metadata'.
	// For now only scalars are supported.
	EventTypes []string `protobuf:"bytes,4,rep,name=eventTypes" json:"eventTypes,omitempty" bson:"eventTypes,omitempty"`
	// For the regex_extractor, the `EMExtractionSpec` should contain a `groups` section, which should contain
	// templates for groups such as `test` and `train`, which group names should be be the keys of this map.
	Groups map[string]*EMGroup `` /* 156-byte string literal not displayed */
}

EMExtractionSpec represents the specification for extracting structured evaluation metrics from training jobs. It is used across all log collectors, so some fields may not be relevent for all log collectors. Note: Don't use enums with this, as need to do untyped YAML convert to string and back Refer to https://github.com/AISphere/ffdl-metrics for complete documentation.

func (*EMExtractionSpec) Descriptor 

func (*EMExtractionSpec) Descriptor() ([]byte, []int)

func (*EMExtractionSpec) GetEventTypes 

func (m *EMExtractionSpec) GetEventTypes() []string

func (*EMExtractionSpec) GetGroups 

func (m *EMExtractionSpec) GetGroups() map[string]*EMGroup

func (*EMExtractionSpec) GetImageTag 

func (m *EMExtractionSpec) GetImageTag() string

func (*EMExtractionSpec) GetIn 

func (m *EMExtractionSpec) GetIn() string

func (*EMExtractionSpec) GetLineLookahead 

func (m *EMExtractionSpec) GetLineLookahead() int32

func (*EMExtractionSpec) GetType 

func (m *EMExtractionSpec) GetType() string

func (*EMExtractionSpec) ProtoMessage 

func (*EMExtractionSpec) ProtoMessage()

func (*EMExtractionSpec) Reset 

func (m *EMExtractionSpec) Reset()

func (*EMExtractionSpec) String 

func (m *EMExtractionSpec) String() string

type EMGroup 

type EMGroup struct {
	// Python regular expressions, which use the named group feature `(?P<name>...)`, to specify
	// a name of a matching expression, which can then be used to specify the value that is used in the template
	// for the `EMetrics` record. To help with verbosity, the regex_extractor allows the following macros: GLOG_STAMP,
	// TIMESTAMP, FLOAT, INT, INT_ANY, and HEX.  (See dlaas-training-metrics-service README for more details.
	Regex string `protobuf:"bytes,1,opt,name=regex" json:"regex,omitempty" bson:"regex,omitempty"`
	// Allows the caller to specify a binding for the time field of the meta structure.
	Meta *EMMeta `protobuf:"bytes,2,opt,name=meta" json:"meta,omitempty" bson:"meta,omitempty"`
	// Map of keys and regex references for value-related (y-axis) values.
	Values map[string]*EMAny `` /* 156-byte string literal not displayed */
	// Map of keys and regex references for time-related (x-axis) values.
	Etimes map[string]*EMAny `` /* 156-byte string literal not displayed */
}

EMGroup represents a group, such as `test` or `train`, that acts as a template for structured evaluation metrics, and which allows the specification of a regular expression (regex) that contains named bindings with sub-expressions, which can then be used as references to specify structured time-related (x-axis) and value-related (y-axis) values.

func (*EMGroup) Descriptor 

func (*EMGroup) Descriptor() ([]byte, []int)

func (*EMGroup) GetEtimes 

func (m *EMGroup) GetEtimes() map[string]*EMAny

func (*EMGroup) GetMeta 

func (m *EMGroup) GetMeta() *EMMeta

func (*EMGroup) GetRegex 

func (m *EMGroup) GetRegex() string

func (*EMGroup) GetValues 

func (m *EMGroup) GetValues() map[string]*EMAny

func (*EMGroup) ProtoMessage 

func (*EMGroup) ProtoMessage()

func (*EMGroup) Reset 

func (m *EMGroup) Reset()

func (*EMGroup) String 

func (m *EMGroup) String() string

type EMMeta 

type EMMeta struct {
	// Time that the metric occured: representing the number of millisecond since midnight January 1, 1970.
	// (ref, for instance $timestamp).  Value will be extracted from timestamps
	Time string `protobuf:"bytes,3,opt,name=time" json:"time,omitempty" bson:"time,omitempty"`
	// Optional subid
	Subid string `protobuf:"bytes,5,opt,name=subid" json:"subid,omitempty" bson:"subid,omitempty"`
}

Allows the user to bind an extracted value to the time field of the evaluation metrics.

func (*EMMeta) Descriptor 

func (*EMMeta) Descriptor() ([]byte, []int)

func (*EMMeta) GetSubid 

func (m *EMMeta) GetSubid() string

func (*EMMeta) GetTime 

func (m *EMMeta) GetTime() string

func (*EMMeta) ProtoMessage 

func (*EMMeta) ProtoMessage()

func (*EMMeta) Reset 

func (m *EMMeta) Reset()

func (*EMMeta) String 

func (m *EMMeta) String() string

type EMetrics 

type EMetrics struct {
	// For MetaInfo, at the minimum training_id and user_id must be specified.
	Meta *MetaInfo `protobuf:"bytes,1,opt,name=meta" json:"meta,omitempty" bson:"meta,omitempty"`
	// Map of temporal keys, normally values for the x-axis on a graph.
	// Example: {"iteration": 209}
	Etimes map[string]*Any `` /* 156-byte string literal not displayed */
	// Group label, such as test, train, or validate
	Grouplabel string `protobuf:"bytes,3,opt,name=grouplabel" json:"grouplabel,omitempty" bson:"grouplabel,omitempty"`
	// Map of value keys, normally values for the y-axis on a graph.
	// / Example: {"cross_entropy": 0.4430539906024933,	"accuracy": 0.8999999761581421}
	Values map[string]*Any `` /* 156-byte string literal not displayed */
}

EMetrics specifies an evaluation metrics record from the training data.

func (*EMetrics) Descriptor 

func (*EMetrics) Descriptor() ([]byte, []int)

func (*EMetrics) GetEtimes 

func (m *EMetrics) GetEtimes() map[string]*Any

func (*EMetrics) GetGrouplabel 

func (m *EMetrics) GetGrouplabel() string

func (*EMetrics) GetMeta 

func (m *EMetrics) GetMeta() *MetaInfo

func (*EMetrics) GetValues 

func (m *EMetrics) GetValues() map[string]*Any

func (*EMetrics) ProtoMessage 

func (*EMetrics) ProtoMessage()

func (*EMetrics) Reset 

func (m *EMetrics) Reset()

func (*EMetrics) String 

func (m *EMetrics) String() string

type Framework 

type Framework struct {
	Name          string         `protobuf:"bytes,1,opt,name=name" json:"name,omitempty" bson:"name,omitempty"`
	Version       string         `protobuf:"bytes,2,opt,name=version" json:"version,omitempty" bson:"version,omitempty"`
	ImageTag      string         `protobuf:"bytes,3,opt,name=image_tag,json=imageTag" json:"image_tag,omitempty" bson:"image_tag,omitempty"`
	ImageLocation *ImageLocation `protobuf:"bytes,4,opt,name=image_location,json=imageLocation" json:"image_location,omitempty" bson:"image_location,omitempty"`
}

func (*Framework) Descriptor 

func (*Framework) Descriptor() ([]byte, []int)

func (*Framework) GetImageLocation 

func (m *Framework) GetImageLocation() *ImageLocation

func (*Framework) GetImageTag 

func (m *Framework) GetImageTag() string

func (*Framework) GetName 

func (m *Framework) GetName() string

func (*Framework) GetVersion 

func (m *Framework) GetVersion() string

func (*Framework) ProtoMessage 

func (*Framework) ProtoMessage()

func (*Framework) Reset 

func (m *Framework) Reset()

func (*Framework) String 

func (m *Framework) String() string

type FrameworkDetailList 

type FrameworkDetailList struct {
	Versions []*FrameworkDetails `protobuf:"bytes,1,rep,name=versions" json:"versions,omitempty" bson:"versions,omitempty"`
}

func (*FrameworkDetailList) Descriptor 

func (*FrameworkDetailList) Descriptor() ([]byte, []int)

func (*FrameworkDetailList) GetVersions 

func (m *FrameworkDetailList) GetVersions() []*FrameworkDetails

func (*FrameworkDetailList) ProtoMessage 

func (*FrameworkDetailList) ProtoMessage()

func (*FrameworkDetailList) Reset 

func (m *FrameworkDetailList) Reset()

func (*FrameworkDetailList) String 

func (m *FrameworkDetailList) String() string

type FrameworkDetails 

type FrameworkDetails struct {
	Version string `protobuf:"bytes,1,opt,name=version" json:"version,omitempty" bson:"version,omitempty"`
	// If true, the image can be used by any user. If false, the image is only available for internal usage.
	External bool `protobuf:"varint,2,opt,name=external" json:"external,omitempty" bson:"external,omitempty"`
}

func (*FrameworkDetails) Descriptor 

func (*FrameworkDetails) Descriptor() ([]byte, []int)

func (*FrameworkDetails) GetExternal 

func (m *FrameworkDetails) GetExternal() bool

func (*FrameworkDetails) GetVersion 

func (m *FrameworkDetails) GetVersion() string

func (*FrameworkDetails) ProtoMessage 

func (*FrameworkDetails) ProtoMessage()

func (*FrameworkDetails) Reset 

func (m *FrameworkDetails) Reset()

func (*FrameworkDetails) String 

func (m *FrameworkDetails) String() string

type Frameworks 

type Frameworks struct {
	Frameworks map[string]*FrameworkDetailList `` /* 168-byte string literal not displayed */
}

Contains a list of all frameworks currently supported along with the versions of that framework and whether a specific framework version can be used by anyone or only for internal usage.

func (*Frameworks) Descriptor 

func (*Frameworks) Descriptor() ([]byte, []int)

func (*Frameworks) GetFrameworks 

func (m *Frameworks) GetFrameworks() map[string]*FrameworkDetailList

func (*Frameworks) ProtoMessage 

func (*Frameworks) ProtoMessage()

func (*Frameworks) Reset 

func (m *Frameworks) Reset()

func (*Frameworks) String 

func (m *Frameworks) String() string

type GetAllRequest 

type GetAllRequest struct {
	UserId string `protobuf:"bytes,1,opt,name=user_id,json=userId" json:"user_id,omitempty" bson:"user_id,omitempty"`
}

func (*GetAllRequest) Descriptor 

func (*GetAllRequest) Descriptor() ([]byte, []int)

func (*GetAllRequest) GetUserId 

func (m *GetAllRequest) GetUserId() string

func (*GetAllRequest) ProtoMessage 

func (*GetAllRequest) ProtoMessage()

func (*GetAllRequest) Reset 

func (m *GetAllRequest) Reset()

func (*GetAllRequest) String 

func (m *GetAllRequest) String() string

type GetAllResponse 

type GetAllResponse struct {
	Jobs []*Job `protobuf:"bytes,1,rep,name=jobs" json:"jobs,omitempty" bson:"jobs,omitempty"`
}

func (*GetAllResponse) Descriptor 

func (*GetAllResponse) Descriptor() ([]byte, []int)

func (*GetAllResponse) GetJobs 

func (m *GetAllResponse) GetJobs() []*Job

func (*GetAllResponse) ProtoMessage 

func (*GetAllResponse) ProtoMessage()

func (*GetAllResponse) Reset 

func (m *GetAllResponse) Reset()

func (*GetAllResponse) String 

func (m *GetAllResponse) String() string

type GetLatestMetricsRequest 

type GetLatestMetricsRequest struct {
	TrainingId string `protobuf:"bytes,1,opt,name=training_id,json=trainingId" json:"training_id,omitempty" bson:"training_id,omitempty"`
	UserId     string `protobuf:"bytes,2,opt,name=user_id,json=userId" json:"user_id,omitempty" bson:"user_id,omitempty"`
}

func (*GetLatestMetricsRequest) Descriptor 

func (*GetLatestMetricsRequest) Descriptor() ([]byte, []int)

func (*GetLatestMetricsRequest) GetTrainingId 

func (m *GetLatestMetricsRequest) GetTrainingId() string

func (*GetLatestMetricsRequest) GetUserId 

func (m *GetLatestMetricsRequest) GetUserId() string

func (*GetLatestMetricsRequest) ProtoMessage 

func (*GetLatestMetricsRequest) ProtoMessage()

func (*GetLatestMetricsRequest) Reset 

func (m *GetLatestMetricsRequest) Reset()

func (*GetLatestMetricsRequest) String 

func (m *GetLatestMetricsRequest) String() string

type GetLatestMetricsResponse 

type GetLatestMetricsResponse struct {
	TrainingId string   `protobuf:"bytes,1,opt,name=training_id,json=trainingId" json:"training_id,omitempty" bson:"training_id,omitempty"`
	UserId     string   `protobuf:"bytes,2,opt,name=user_id,json=userId" json:"user_id,omitempty" bson:"user_id,omitempty"`
	Metrics    *Metrics `protobuf:"bytes,3,opt,name=metrics" json:"metrics,omitempty" bson:"metrics,omitempty"`
}

func (*GetLatestMetricsResponse) Descriptor 

func (*GetLatestMetricsResponse) Descriptor() ([]byte, []int)

func (*GetLatestMetricsResponse) GetMetrics 

func (m *GetLatestMetricsResponse) GetMetrics() *Metrics

func (*GetLatestMetricsResponse) GetTrainingId 

func (m *GetLatestMetricsResponse) GetTrainingId() string

func (*GetLatestMetricsResponse) GetUserId 

func (m *GetLatestMetricsResponse) GetUserId() string

func (*GetLatestMetricsResponse) ProtoMessage 

func (*GetLatestMetricsResponse) ProtoMessage()

func (*GetLatestMetricsResponse) Reset 

func (m *GetLatestMetricsResponse) Reset()

func (*GetLatestMetricsResponse) String 

func (m *GetLatestMetricsResponse) String() string

type GetMetricsStringResponse 

type GetMetricsStringResponse struct {
	Metrics string `protobuf:"bytes,1,opt,name=metrics" json:"metrics,omitempty" bson:"metrics,omitempty"`
}

func (*GetMetricsStringResponse) Descriptor 

func (*GetMetricsStringResponse) Descriptor() ([]byte, []int)

func (*GetMetricsStringResponse) GetMetrics 

func (m *GetMetricsStringResponse) GetMetrics() string

func (*GetMetricsStringResponse) ProtoMessage 

func (*GetMetricsStringResponse) ProtoMessage()

func (*GetMetricsStringResponse) Reset 

func (m *GetMetricsStringResponse) Reset()

func (*GetMetricsStringResponse) String 

func (m *GetMetricsStringResponse) String() string

type GetRequest 

type GetRequest struct {
	TrainingId string `protobuf:"bytes,1,opt,name=training_id,json=trainingId" json:"training_id,omitempty" bson:"training_id,omitempty"`
	UserId     string `protobuf:"bytes,2,opt,name=user_id,json=userId" json:"user_id,omitempty" bson:"user_id,omitempty"`
}

func (*GetRequest) Descriptor 

func (*GetRequest) Descriptor() ([]byte, []int)

func (*GetRequest) GetTrainingId 

func (m *GetRequest) GetTrainingId() string

func (*GetRequest) GetUserId 

func (m *GetRequest) GetUserId() string

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (m *GetRequest) Reset()

func (*GetRequest) String 

func (m *GetRequest) String() string

type GetResponse 

type GetResponse struct {
	Job *Job `protobuf:"bytes,1,opt,name=job" json:"job,omitempty" bson:"job,omitempty"`
}

func (*GetResponse) Descriptor 

func (*GetResponse) Descriptor() ([]byte, []int)

func (*GetResponse) GetJob 

func (m *GetResponse) GetJob() *Job

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) Reset 

func (m *GetResponse) Reset()

func (*GetResponse) String 

func (m *GetResponse) String() string

type GetStatusIDResponse 

type GetStatusIDResponse struct {
	Status Status `protobuf:"varint,1,opt,name=status,enum=grpc.trainer.v2.Status" json:"status,omitempty" bson:"status,omitempty"`
}

func (*GetStatusIDResponse) Descriptor 

func (*GetStatusIDResponse) Descriptor() ([]byte, []int)

func (*GetStatusIDResponse) GetStatus 

func (m *GetStatusIDResponse) GetStatus() Status

func (*GetStatusIDResponse) ProtoMessage 

func (*GetStatusIDResponse) ProtoMessage()

func (*GetStatusIDResponse) Reset 

func (m *GetStatusIDResponse) Reset()

func (*GetStatusIDResponse) String 

func (m *GetStatusIDResponse) String() string

type GetStatusResponse 

type GetStatusResponse struct {
	Status *TrainingStatus `protobuf:"bytes,1,opt,name=status" json:"status,omitempty" bson:"status,omitempty"`
}

func (*GetStatusResponse) Descriptor 

func (*GetStatusResponse) Descriptor() ([]byte, []int)

func (*GetStatusResponse) GetStatus 

func (m *GetStatusResponse) GetStatus() *TrainingStatus

func (*GetStatusResponse) ProtoMessage 

func (*GetStatusResponse) ProtoMessage()

func (*GetStatusResponse) Reset 

func (m *GetStatusResponse) Reset()

func (*GetStatusResponse) String 

func (m *GetStatusResponse) String() string

type GetTestResponse 

type GetTestResponse struct {
	Test string `protobuf:"bytes,1,opt,name=test" json:"test,omitempty" bson:"test,omitempty"`
}

func (*GetTestResponse) Descriptor 

func (*GetTestResponse) Descriptor() ([]byte, []int)

func (*GetTestResponse) GetTest 

func (m *GetTestResponse) GetTest() string

func (*GetTestResponse) ProtoMessage 

func (*GetTestResponse) ProtoMessage()

func (*GetTestResponse) Reset 

func (m *GetTestResponse) Reset()

func (*GetTestResponse) String 

func (m *GetTestResponse) String() string

type GetVersionsRequest 

type GetVersionsRequest struct {
}

func (*GetVersionsRequest) Descriptor 

func (*GetVersionsRequest) Descriptor() ([]byte, []int)

func (*GetVersionsRequest) ProtoMessage 

func (*GetVersionsRequest) ProtoMessage()

func (*GetVersionsRequest) Reset 

func (m *GetVersionsRequest) Reset()

func (*GetVersionsRequest) String 

func (m *GetVersionsRequest) String() string

type HaltRequest 

type HaltRequest struct {
	TrainingId string `protobuf:"bytes,1,opt,name=training_id,json=trainingId" json:"training_id,omitempty" bson:"training_id,omitempty"`
	UserId     string `protobuf:"bytes,2,opt,name=user_id,json=userId" json:"user_id,omitempty" bson:"user_id,omitempty"`
}

func (*HaltRequest) Descriptor 

func (*HaltRequest) Descriptor() ([]byte, []int)

func (*HaltRequest) GetTrainingId 

func (m *HaltRequest) GetTrainingId() string

func (*HaltRequest) GetUserId 

func (m *HaltRequest) GetUserId() string

func (*HaltRequest) ProtoMessage 

func (*HaltRequest) ProtoMessage()

func (*HaltRequest) Reset 

func (m *HaltRequest) Reset()

func (*HaltRequest) String 

func (m *HaltRequest) String() string

type HaltResponse 

type HaltResponse struct {
	TrainingId string `protobuf:"bytes,1,opt,name=training_id,json=trainingId" json:"training_id,omitempty" bson:"training_id,omitempty"`
	UserId     string `protobuf:"bytes,2,opt,name=user_id,json=userId" json:"user_id,omitempty" bson:"user_id,omitempty"`
	Status     Status `protobuf:"varint,3,opt,name=status,enum=grpc.trainer.v2.Status" json:"status,omitempty" bson:"status,omitempty"`
}

func (*HaltResponse) Descriptor 

func (*HaltResponse) Descriptor() ([]byte, []int)

func (*HaltResponse) GetStatus 

func (m *HaltResponse) GetStatus() Status

func (*HaltResponse) GetTrainingId 

func (m *HaltResponse) GetTrainingId() string

func (*HaltResponse) GetUserId 

func (m *HaltResponse) GetUserId() string

func (*HaltResponse) ProtoMessage 

func (*HaltResponse) ProtoMessage()

func (*HaltResponse) Reset 

func (m *HaltResponse) Reset()

func (*HaltResponse) String 

func (m *HaltResponse) String() string

type ImageLocation 

type ImageLocation struct {
	Registry    string `protobuf:"bytes,1,opt,name=registry" json:"registry,omitempty" bson:"registry,omitempty"`
	Namespace   string `protobuf:"bytes,2,opt,name=namespace" json:"namespace,omitempty" bson:"namespace,omitempty"`
	AccessToken string `protobuf:"bytes,3,opt,name=access_token,json=accessToken" json:"access_token,omitempty" bson:"access_token,omitempty"`
	Email       string `protobuf:"bytes,4,opt,name=email" json:"email,omitempty" bson:"email,omitempty"`
}

func (*ImageLocation) Descriptor 

func (*ImageLocation) Descriptor() ([]byte, []int)

func (*ImageLocation) GetAccessToken 

func (m *ImageLocation) GetAccessToken() string

func (*ImageLocation) GetEmail 

func (m *ImageLocation) GetEmail() string

func (*ImageLocation) GetNamespace 

func (m *ImageLocation) GetNamespace() string

func (*ImageLocation) GetRegistry 

func (m *ImageLocation) GetRegistry() string

func (*ImageLocation) ProtoMessage 

func (*ImageLocation) ProtoMessage()

func (*ImageLocation) Reset 

func (m *ImageLocation) Reset()

func (*ImageLocation) String 

func (m *ImageLocation) String() string

type Job 

type Job struct {
	TrainingId      string           `protobuf:"bytes,1,opt,name=training_id,json=trainingId" json:"training_id,omitempty" bson:"training_id,omitempty"`
	UserId          string           `protobuf:"bytes,2,opt,name=user_id,json=userId" json:"user_id,omitempty" bson:"user_id,omitempty"`
	ModelDefinition *ModelDefinition `` /* 133-byte string literal not displayed */
	Training        *Training        `protobuf:"bytes,4,opt,name=training" json:"training,omitempty" bson:"training,omitempty"`
	Status          *TrainingStatus  `protobuf:"bytes,5,opt,name=status" json:"status,omitempty" bson:"status,omitempty"`
	Datastores      []*Datastore     `protobuf:"bytes,6,rep,name=datastores" json:"datastores,omitempty" bson:"datastores,omitempty"`
	JobId           string           `protobuf:"bytes,7,opt,name=job_id,json=jobId" json:"job_id,omitempty" bson:"job_id,omitempty"`
	Metrics         *Metrics         `protobuf:"bytes,8,opt,name=metrics" json:"metrics,omitempty" bson:"metrics,omitempty"`
}

func (*Job) Descriptor 

func (*Job) Descriptor() ([]byte, []int)

func (*Job) GetDatastores 

func (m *Job) GetDatastores() []*Datastore

func (*Job) GetJobId 

func (m *Job) GetJobId() string

func (*Job) GetMetrics 

func (m *Job) GetMetrics() *Metrics

func (*Job) GetModelDefinition 

func (m *Job) GetModelDefinition() *ModelDefinition

func (*Job) GetStatus 

func (m *Job) GetStatus() *TrainingStatus

func (*Job) GetTraining 

func (m *Job) GetTraining() *Training

func (*Job) GetTrainingId 

func (m *Job) GetTrainingId() string

func (*Job) GetUserId 

func (m *Job) GetUserId() string

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) Reset 

func (m *Job) Reset()

func (*Job) String 

func (m *Job) String() string

type LogLine 

type LogLine struct {
	// For MetaInfo, at the minimum training_id and user_id must be specified.
	Meta *MetaInfo `protobuf:"bytes,1,opt,name=meta" json:"meta,omitempty" bson:"meta,omitempty"`
	// Raw line from the logs.
	Line string `protobuf:"bytes,2,opt,name=line" json:"line,omitempty" bson:"line,omitempty"`
}

LogLine represents one line of log information, returned by training data endpoints.

func (*LogLine) Descriptor 

func (*LogLine) Descriptor() ([]byte, []int)

func (*LogLine) GetLine 

func (m *LogLine) GetLine() string

func (*LogLine) GetMeta 

func (m *LogLine) GetMeta() *MetaInfo

func (*LogLine) ProtoMessage 

func (*LogLine) ProtoMessage()

func (*LogLine) Reset 

func (m *LogLine) Reset()

func (*LogLine) String 

func (m *LogLine) String() string

type MetaInfo 

type MetaInfo struct {
	// Unique id identifying the training job
	TrainingId string `protobuf:"bytes,1,opt,name=training_id,json=trainingId" json:"training_id,omitempty" bson:"training_id,omitempty"`
	// Unique id identifying the user
	UserId string `protobuf:"bytes,2,opt,name=user_id,json=userId" json:"user_id,omitempty" bson:"user_id,omitempty"`
	// Time that the metric occured: representing the number of millisecond since midnight January 1, 1970.
	Time int64 `protobuf:"varint,3,opt,name=time" json:"time,omitempty" bson:"time,omitempty"`
	// Sequential index, 1-based
	Rindex int64 `protobuf:"varint,4,opt,name=rindex" json:"rindex,omitempty" bson:"rindex,omitempty"`
	// Optional subid
	Subid string `protobuf:"bytes,5,opt,name=subid" json:"subid,omitempty" bson:"subid,omitempty"`
}

MetaInfo represents data shared with both log lines and evaluation metrics.

func (*MetaInfo) Descriptor 

func (*MetaInfo) Descriptor() ([]byte, []int)

func (*MetaInfo) GetRindex 

func (m *MetaInfo) GetRindex() int64

func (*MetaInfo) GetSubid 

func (m *MetaInfo) GetSubid() string

func (*MetaInfo) GetTime 

func (m *MetaInfo) GetTime() int64

func (*MetaInfo) GetTrainingId 

func (m *MetaInfo) GetTrainingId() string

func (*MetaInfo) GetUserId 

func (m *MetaInfo) GetUserId() string

func (*MetaInfo) ProtoMessage 

func (*MetaInfo) ProtoMessage()

func (*MetaInfo) Reset 

func (m *MetaInfo) Reset()

func (*MetaInfo) String 

func (m *MetaInfo) String() string

type Metrics 

type Metrics struct {
	Timestamp string            `protobuf:"bytes,1,opt,name=timestamp" json:"timestamp,omitempty" bson:"timestamp,omitempty"`
	Type      string            `protobuf:"bytes,2,opt,name=type" json:"type,omitempty" bson:"type,omitempty"`
	Iteration int32             `protobuf:"varint,3,opt,name=iteration" json:"iteration,omitempty" bson:"iteration,omitempty"`
	Values    map[string]string `` /* 156-byte string literal not displayed */
}

func (*Metrics) Descriptor 

func (*Metrics) Descriptor() ([]byte, []int)

func (*Metrics) GetIteration 

func (m *Metrics) GetIteration() int32

func (*Metrics) GetTimestamp 

func (m *Metrics) GetTimestamp() string

func (*Metrics) GetType 

func (m *Metrics) GetType() string

func (*Metrics) GetValues 

func (m *Metrics) GetValues() map[string]string

func (*Metrics) ProtoMessage 

func (*Metrics) ProtoMessage()

func (*Metrics) Reset 

func (m *Metrics) Reset()

func (*Metrics) String 

func (m *Metrics) String() string

type ModelDefinition 

type ModelDefinition struct {
	Name        string     `protobuf:"bytes,1,opt,name=name" json:"name,omitempty" bson:"name,omitempty"`
	Description string     `protobuf:"bytes,2,opt,name=description" json:"description,omitempty" bson:"description,omitempty"`
	Content     []byte     `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty" bson:"content,omitempty"`
	Location    string     `protobuf:"bytes,4,opt,name=location" json:"location,omitempty" bson:"location,omitempty"`
	Framework   *Framework `protobuf:"bytes,5,opt,name=framework" json:"framework,omitempty" bson:"framework,omitempty"`
}

func (*ModelDefinition) Descriptor 

func (*ModelDefinition) Descriptor() ([]byte, []int)

func (*ModelDefinition) GetContent 

func (m *ModelDefinition) GetContent() []byte

func (*ModelDefinition) GetDescription 

func (m *ModelDefinition) GetDescription() string

func (*ModelDefinition) GetFramework 

func (m *ModelDefinition) GetFramework() *Framework

func (*ModelDefinition) GetLocation 

func (m *ModelDefinition) GetLocation() string

func (*ModelDefinition) GetName 

func (m *ModelDefinition) GetName() string

func (*ModelDefinition) ProtoMessage 

func (*ModelDefinition) ProtoMessage()

func (*ModelDefinition) Reset 

func (m *ModelDefinition) Reset()

func (*ModelDefinition) String 

func (m *ModelDefinition) String() string

type ModelDefinitionRequest 

type ModelDefinitionRequest struct {
	TrainingId string `protobuf:"bytes,1,opt,name=training_id,json=trainingId" json:"training_id,omitempty" bson:"training_id,omitempty"`
	UserId     string `protobuf:"bytes,2,opt,name=user_id,json=userId" json:"user_id,omitempty" bson:"user_id,omitempty"`
}

func (*ModelDefinitionRequest) Descriptor 

func (*ModelDefinitionRequest) Descriptor() ([]byte, []int)

func (*ModelDefinitionRequest) GetTrainingId 

func (m *ModelDefinitionRequest) GetTrainingId() string

func (*ModelDefinitionRequest) GetUserId 

func (m *ModelDefinitionRequest) GetUserId() string

func (*ModelDefinitionRequest) ProtoMessage 

func (*ModelDefinitionRequest) ProtoMessage()

func (*ModelDefinitionRequest) Reset 

func (m *ModelDefinitionRequest) Reset()

func (*ModelDefinitionRequest) String 

func (m *ModelDefinitionRequest) String() string

type Query 

type Query struct {
	// At this time, the SearchType value should normally always be TERM.
	SearchType Query_SearchType `` /* 133-byte string literal not displayed */
	// At the minimum, the training_data and user_data must be specified in the meta substructure.
	Meta  *MetaInfo `protobuf:"bytes,3,opt,name=meta" json:"meta,omitempty" bson:"meta,omitempty"`
	Since string    `protobuf:"bytes,4,opt,name=since" json:"since,omitempty" bson:"since,omitempty"`
	// Only get this many records
	Pagesize int32 `protobuf:"varint,5,opt,name=pagesize" json:"pagesize,omitempty" bson:"pagesize,omitempty"`
	// The starting position.  If positive or zero, count from beginning, if negative, count from end, exclusive with since.
	Pos int64 `protobuf:"varint,6,opt,name=pos" json:"pos,omitempty" bson:"pos,omitempty"`
}

Query specifies the input query for logs and evaluation metrics.

func (*Query) Descriptor 

func (*Query) Descriptor() ([]byte, []int)

func (*Query) GetMeta 

func (m *Query) GetMeta() *MetaInfo

func (*Query) GetPagesize 

func (m *Query) GetPagesize() int32

func (*Query) GetPos 

func (m *Query) GetPos() int64

func (*Query) GetSearchType 

func (m *Query) GetSearchType() Query_SearchType

func (*Query) GetSince 

func (m *Query) GetSince() string

func (*Query) ProtoMessage 

func (*Query) ProtoMessage()

func (*Query) Reset 

func (m *Query) Reset()

func (*Query) String 

func (m *Query) String() string

type Query_SearchType 

type Query_SearchType int32
const (
	Query_TERM   Query_SearchType = 0
	Query_NESTED Query_SearchType = 1
	Query_MATCH  Query_SearchType = 2
	Query_ALL    Query_SearchType = 3
)

func (Query_SearchType) EnumDescriptor 

func (Query_SearchType) EnumDescriptor() ([]byte, []int)

func (Query_SearchType) String 

func (x Query_SearchType) String() string

type ResourceRequirements 

type ResourceRequirements struct {
	// Number of CPU cores
	Cpus float32 `protobuf:"fixed32,1,opt,name=cpus" json:"cpus,omitempty" bson:"cpus,omitempty"`
	// Number of GPUs
	Gpus float32 `protobuf:"fixed32,2,opt,name=gpus" json:"gpus,omitempty" bson:"gpus,omitempty"`
	// RAM
	Memory      float32  `protobuf:"fixed32,3,opt,name=memory" json:"memory,omitempty" bson:"memory,omitempty"`
	MemoryUnit  SizeUnit `` /* 144-byte string literal not displayed */
	Storage     float32  `protobuf:"fixed32,5,opt,name=storage" json:"storage,omitempty" bson:"storage,omitempty"`
	StorageUnit SizeUnit `` /* 148-byte string literal not displayed */
	// Number of learners
	Learners     int32  `protobuf:"varint,7,opt,name=learners" json:"learners,omitempty" bson:"learners,omitempty"`
	Schedpolicy  string `protobuf:"bytes,8,opt,name=schedpolicy" json:"schedpolicy,omitempty" bson:"schedpolicy,omitempty"`
	Topology     string `protobuf:"bytes,9,opt,name=topology" json:"topology,omitempty" bson:"topology,omitempty"`
	Architecture string `protobuf:"bytes,10,opt,name=architecture" json:"architecture,omitempty" bson:"architecture,omitempty"`
	// Optional. If not specified, job will be scheduled ONLY on nvidia-TeslaK80
	// Constraint strictly enforced. If e.g., a nvidia-TeslaP100 is requested,
	// job will NOT start until a nvidia-TeslaP100 is available
	// Can only be nvidia-TeslaK80, nvidia-TeslaP100 or nvidia-TeslaV100
	GpuType string `protobuf:"bytes,11,opt,name=gpu_type,json=gpuType" json:"gpu_type,omitempty" bson:"gpu_type,omitempty"`
}

Used to specify resource requirements of a training job

func (*ResourceRequirements) Descriptor 

func (*ResourceRequirements) Descriptor() ([]byte, []int)

func (*ResourceRequirements) GetArchitecture 

func (m *ResourceRequirements) GetArchitecture() string

func (*ResourceRequirements) GetCpus 

func (m *ResourceRequirements) GetCpus() float32

func (*ResourceRequirements) GetGpuType 

func (m *ResourceRequirements) GetGpuType() string

func (*ResourceRequirements) GetGpus 

func (m *ResourceRequirements) GetGpus() float32

func (*ResourceRequirements) GetLearners 

func (m *ResourceRequirements) GetLearners() int32

func (*ResourceRequirements) GetMemory 

func (m *ResourceRequirements) GetMemory() float32

func (*ResourceRequirements) GetMemoryUnit 

func (m *ResourceRequirements) GetMemoryUnit() SizeUnit

func (*ResourceRequirements) GetSchedpolicy 

func (m *ResourceRequirements) GetSchedpolicy() string

func (*ResourceRequirements) GetStorage 

func (m *ResourceRequirements) GetStorage() float32

func (*ResourceRequirements) GetStorageUnit 

func (m *ResourceRequirements) GetStorageUnit() SizeUnit

func (*ResourceRequirements) GetTopology 

func (m *ResourceRequirements) GetTopology() string

func (*ResourceRequirements) ProtoMessage 

func (*ResourceRequirements) ProtoMessage()

func (*ResourceRequirements) Reset 

func (m *ResourceRequirements) Reset()

func (*ResourceRequirements) String 

func (m *ResourceRequirements) String() string

type ResumeRequest 

type ResumeRequest struct {
	TrainingId string `protobuf:"bytes,1,opt,name=training_id,json=trainingId" json:"training_id,omitempty" bson:"training_id,omitempty"`
	UserId     string `protobuf:"bytes,2,opt,name=user_id,json=userId" json:"user_id,omitempty" bson:"user_id,omitempty"`
}

func (*ResumeRequest) Descriptor 

func (*ResumeRequest) Descriptor() ([]byte, []int)

func (*ResumeRequest) GetTrainingId 

func (m *ResumeRequest) GetTrainingId() string

func (*ResumeRequest) GetUserId 

func (m *ResumeRequest) GetUserId() string

func (*ResumeRequest) ProtoMessage 

func (*ResumeRequest) ProtoMessage()

func (*ResumeRequest) Reset 

func (m *ResumeRequest) Reset()

func (*ResumeRequest) String 

func (m *ResumeRequest) String() string

type ResumeResponse 

type ResumeResponse struct {
	TrainingId string `protobuf:"bytes,1,opt,name=training_id,json=trainingId" json:"training_id,omitempty" bson:"training_id,omitempty"`
	UserId     string `protobuf:"bytes,2,opt,name=user_id,json=userId" json:"user_id,omitempty" bson:"user_id,omitempty"`
	Status     Status `protobuf:"varint,3,opt,name=status,enum=grpc.trainer.v2.Status" json:"status,omitempty" bson:"status,omitempty"`
}

func (*ResumeResponse) Descriptor 

func (*ResumeResponse) Descriptor() ([]byte, []int)

func (*ResumeResponse) GetStatus 

func (m *ResumeResponse) GetStatus() Status

func (*ResumeResponse) GetTrainingId 

func (m *ResumeResponse) GetTrainingId() string

func (*ResumeResponse) GetUserId 

func (m *ResumeResponse) GetUserId() string

func (*ResumeResponse) ProtoMessage 

func (*ResumeResponse) ProtoMessage()

func (*ResumeResponse) Reset 

func (m *ResumeResponse) Reset()

func (*ResumeResponse) String 

func (m *ResumeResponse) String() string

type SizeUnit 

type SizeUnit int32
const (
	SizeUnit_MB  SizeUnit = 0
	SizeUnit_MiB SizeUnit = 1
	SizeUnit_GB  SizeUnit = 2
	SizeUnit_GiB SizeUnit = 3
)

func (SizeUnit) EnumDescriptor 

func (SizeUnit) EnumDescriptor() ([]byte, []int)

func (SizeUnit) String 

func (x SizeUnit) String() string

type Status 

type Status int32
const (
	Status_NOT_STARTED Status = 0
	Status_PENDING     Status = 1
	Status_HALTED      Status = 5
	Status_FAILED      Status = 10
	Status_DEPLOY      Status = 20
	Status_DOWNLOADING Status = 30
	Status_PROCESSING  Status = 40
	Status_STORING     Status = 50
	Status_COMPLETED   Status = 60
	Status_QUEUED      Status = 70
)

func (Status) EnumDescriptor 

func (Status) EnumDescriptor() ([]byte, []int)

func (Status) String 

func (x Status) String() string

type TrainedModelLogRequest 

type TrainedModelLogRequest struct {
	TrainingId string `protobuf:"bytes,1,opt,name=training_id,json=trainingId" json:"training_id,omitempty" bson:"training_id,omitempty"`
	UserId     string `protobuf:"bytes,2,opt,name=user_id,json=userId" json:"user_id,omitempty" bson:"user_id,omitempty"`
	Follow     bool   `protobuf:"varint,5,opt,name=follow" json:"follow,omitempty" bson:"follow,omitempty"`
	// These are for internal use only, and will be eventually removed!
	IsMetrics bool `protobuf:"varint,3,opt,name=is_metrics,json=isMetrics" json:"is_metrics,omitempty" bson:"is_metrics,omitempty"`
	IsSummary bool `protobuf:"varint,4,opt,name=is_summary,json=isSummary" json:"is_summary,omitempty" bson:"is_summary,omitempty"`
}

func (*TrainedModelLogRequest) Descriptor 

func (*TrainedModelLogRequest) Descriptor() ([]byte, []int)

func (*TrainedModelLogRequest) GetFollow 

func (m *TrainedModelLogRequest) GetFollow() bool

func (*TrainedModelLogRequest) GetIsMetrics 

func (m *TrainedModelLogRequest) GetIsMetrics() bool

func (*TrainedModelLogRequest) GetIsSummary 

func (m *TrainedModelLogRequest) GetIsSummary() bool

func (*TrainedModelLogRequest) GetTrainingId 

func (m *TrainedModelLogRequest) GetTrainingId() string

func (*TrainedModelLogRequest) GetUserId 

func (m *TrainedModelLogRequest) GetUserId() string

func (*TrainedModelLogRequest) ProtoMessage 

func (*TrainedModelLogRequest) ProtoMessage()

func (*TrainedModelLogRequest) Reset 

func (m *TrainedModelLogRequest) Reset()

func (*TrainedModelLogRequest) String 

func (m *TrainedModelLogRequest) String() string

type TrainedModelMetricsRequest 

type TrainedModelMetricsRequest struct {
	TrainingId string `protobuf:"bytes,1,opt,name=training_id,json=trainingId" json:"training_id,omitempty" bson:"training_id,omitempty"`
	UserId     string `protobuf:"bytes,2,opt,name=user_id,json=userId" json:"user_id,omitempty" bson:"user_id,omitempty"`
	Follow     bool   `protobuf:"varint,3,opt,name=follow" json:"follow,omitempty" bson:"follow,omitempty"`
}

func (*TrainedModelMetricsRequest) Descriptor 

func (*TrainedModelMetricsRequest) Descriptor() ([]byte, []int)

func (*TrainedModelMetricsRequest) GetFollow 

func (m *TrainedModelMetricsRequest) GetFollow() bool

func (*TrainedModelMetricsRequest) GetTrainingId 

func (m *TrainedModelMetricsRequest) GetTrainingId() string

func (*TrainedModelMetricsRequest) GetUserId 

func (m *TrainedModelMetricsRequest) GetUserId() string

func (*TrainedModelMetricsRequest) ProtoMessage 

func (*TrainedModelMetricsRequest) ProtoMessage()

func (*TrainedModelMetricsRequest) Reset 

func (m *TrainedModelMetricsRequest) Reset()

func (*TrainedModelMetricsRequest) String 

func (m *TrainedModelMetricsRequest) String() string

type TrainedModelRequest 

type TrainedModelRequest struct {
	TrainingId string `protobuf:"bytes,1,opt,name=training_id,json=trainingId" json:"training_id,omitempty" bson:"training_id,omitempty"`
	UserId     string `protobuf:"bytes,2,opt,name=user_id,json=userId" json:"user_id,omitempty" bson:"user_id,omitempty"`
}

func (*TrainedModelRequest) Descriptor 

func (*TrainedModelRequest) Descriptor() ([]byte, []int)

func (*TrainedModelRequest) GetTrainingId 

func (m *TrainedModelRequest) GetTrainingId() string

func (*TrainedModelRequest) GetUserId 

func (m *TrainedModelRequest) GetUserId() string

func (*TrainedModelRequest) ProtoMessage 

func (*TrainedModelRequest) ProtoMessage()

func (*TrainedModelRequest) Reset 

func (m *TrainedModelRequest) Reset()

func (*TrainedModelRequest) String 

func (m *TrainedModelRequest) String() string

type TrainerClient 

type TrainerClient interface {
	// Creates a new deep learning training job for a given model definition.
	CreateTrainingJob(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
	// Reads a training job with a given ID.
	GetTrainingJob(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	// Returns all training jobs for a given user.
	GetAllTrainingsJobs(ctx context.Context, in *GetAllRequest, opts ...grpc.CallOption) (*GetAllResponse, error)
	// Deletes a training job with a given ID.
	DeleteTrainingJob(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	// Halts the training with a given ID without discarding the result.
	HaltTrainingJob(ctx context.Context, in *HaltRequest, opts ...grpc.CallOption) (*HaltResponse, error)
	// Returns the model definition that was used for training as application/zip.
	GetModelDefinition(ctx context.Context, in *ModelDefinitionRequest, opts ...grpc.CallOption) (Trainer_GetModelDefinitionClient, error)
	// Returns the trained model as application/zip.
	GetTrainedModel(ctx context.Context, in *TrainedModelRequest, opts ...grpc.CallOption) (Trainer_GetTrainedModelClient, error)
	// Returns the logs from the ZIP file stored in the object store.
	// Deprecated
	GetTrainedModelLogs(ctx context.Context, in *TrainedModelLogRequest, opts ...grpc.CallOption) (Trainer_GetTrainedModelLogsClient, error)
	GetTrainingLogs(ctx context.Context, in *Query, opts ...grpc.CallOption) (Trainer_GetTrainingLogsClient, error)
	// Get evaluation metrics records, based on query
	GetTrainingEMetrics(ctx context.Context, in *Query, opts ...grpc.CallOption) (Trainer_GetTrainingEMetricsClient, error)
	GetVersions(ctx context.Context, in *GetVersionsRequest, opts ...grpc.CallOption) (*Frameworks, error)
	// For internal use only!
	GetTrainingStatusID(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetStatusIDResponse, error)
	// For internal use only!
	// Updates an existing training status
	// TODO we should not have this but until we fix the status update handling properly, we have no other choice.
	UpdateTrainingJob(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error)
	// Not implemented, to be removed (for GA)
	ResumeTrainingJob(ctx context.Context, in *ResumeRequest, opts ...grpc.CallOption) (*ResumeResponse, error)
}

func NewTrainerClient 

func NewTrainerClient(cc *grpc.ClientConn) TrainerClient

type TrainerServer 

type TrainerServer interface {
	// Creates a new deep learning training job for a given model definition.
	CreateTrainingJob(context.Context, *CreateRequest) (*CreateResponse, error)
	// Reads a training job with a given ID.
	GetTrainingJob(context.Context, *GetRequest) (*GetResponse, error)
	// Returns all training jobs for a given user.
	GetAllTrainingsJobs(context.Context, *GetAllRequest) (*GetAllResponse, error)
	// Deletes a training job with a given ID.
	DeleteTrainingJob(context.Context, *DeleteRequest) (*DeleteResponse, error)
	// Halts the training with a given ID without discarding the result.
	HaltTrainingJob(context.Context, *HaltRequest) (*HaltResponse, error)
	// Returns the model definition that was used for training as application/zip.
	GetModelDefinition(*ModelDefinitionRequest, Trainer_GetModelDefinitionServer) error
	// Returns the trained model as application/zip.
	GetTrainedModel(*TrainedModelRequest, Trainer_GetTrainedModelServer) error
	// Returns the logs from the ZIP file stored in the object store.
	// Deprecated
	GetTrainedModelLogs(*TrainedModelLogRequest, Trainer_GetTrainedModelLogsServer) error
	GetTrainingLogs(*Query, Trainer_GetTrainingLogsServer) error
	// Get evaluation metrics records, based on query
	GetTrainingEMetrics(*Query, Trainer_GetTrainingEMetricsServer) error
	GetVersions(context.Context, *GetVersionsRequest) (*Frameworks, error)
	// For internal use only!
	GetTrainingStatusID(context.Context, *GetRequest) (*GetStatusIDResponse, error)
	// For internal use only!
	// Updates an existing training status
	// TODO we should not have this but until we fix the status update handling properly, we have no other choice.
	UpdateTrainingJob(context.Context, *UpdateRequest) (*UpdateResponse, error)
	// Not implemented, to be removed (for GA)
	ResumeTrainingJob(context.Context, *ResumeRequest) (*ResumeResponse, error)
}

type Trainer_GetModelDefinitionClient 

type Trainer_GetModelDefinitionClient interface {
	Recv() (*ZippedDataChunk, error)
	grpc.ClientStream
}

type Trainer_GetModelDefinitionServer 

type Trainer_GetModelDefinitionServer interface {
	Send(*ZippedDataChunk) error
	grpc.ServerStream
}

type Trainer_GetTrainedModelClient 

type Trainer_GetTrainedModelClient interface {
	Recv() (*ZippedDataChunk, error)
	grpc.ClientStream
}

type Trainer_GetTrainedModelLogsClient 

type Trainer_GetTrainedModelLogsClient interface {
	Recv() (*ByteStreamResponse, error)
	grpc.ClientStream
}

type Trainer_GetTrainedModelLogsServer 

type Trainer_GetTrainedModelLogsServer interface {
	Send(*ByteStreamResponse) error
	grpc.ServerStream
}

type Trainer_GetTrainedModelServer 

type Trainer_GetTrainedModelServer interface {
	Send(*ZippedDataChunk) error
	grpc.ServerStream
}

type Trainer_GetTrainingEMetricsClient 

type Trainer_GetTrainingEMetricsClient interface {
	Recv() (*EMetrics, error)
	grpc.ClientStream
}

type Trainer_GetTrainingEMetricsServer 

type Trainer_GetTrainingEMetricsServer interface {
	Send(*EMetrics) error
	grpc.ServerStream
}

type Trainer_GetTrainingLogsClient 

type Trainer_GetTrainingLogsClient interface {
	Recv() (*LogLine, error)
	grpc.ClientStream
}

type Trainer_GetTrainingLogsServer 

type Trainer_GetTrainingLogsServer interface {
	Send(*LogLine) error
	grpc.ServerStream
}

type Training 

type Training struct {
	// Command to execute during training
	Command string `protobuf:"bytes,1,opt,name=command" json:"command,omitempty" bson:"command,omitempty"`
	// Resource requirements for the training
	Resources *ResourceRequirements `protobuf:"bytes,2,opt,name=resources" json:"resources,omitempty" bson:"resources,omitempty"`
	// Input and output data as data store references
	InputData  []string `protobuf:"bytes,3,rep,name=input_data,json=inputData" json:"input_data,omitempty" bson:"input_data,omitempty"`
	OutputData []string `protobuf:"bytes,4,rep,name=output_data,json=outputData" json:"output_data,omitempty" bson:"output_data,omitempty"`
	// whether we want to enable detailed profiling during the training
	Profiling bool `protobuf:"varint,5,opt,name=profiling" json:"profiling,omitempty" bson:"profiling,omitempty"`
}

func (*Training) Descriptor 

func (*Training) Descriptor() ([]byte, []int)

func (*Training) GetCommand 

func (m *Training) GetCommand() string

func (*Training) GetInputData 

func (m *Training) GetInputData() []string

func (*Training) GetOutputData 

func (m *Training) GetOutputData() []string

func (*Training) GetProfiling 

func (m *Training) GetProfiling() bool

func (*Training) GetResources 

func (m *Training) GetResources() *ResourceRequirements

func (*Training) ProtoMessage 

func (*Training) ProtoMessage()

func (*Training) Reset 

func (m *Training) Reset()

func (*Training) String 

func (m *Training) String() string

type TrainingStatus 

type TrainingStatus struct {
	Status                 Status `protobuf:"varint,1,opt,name=status,enum=grpc.trainer.v2.Status" json:"status,omitempty" bson:"status,omitempty"`
	SubmissionTimestamp    string `` /* 149-byte string literal not displayed */
	CompletionTimestamp    string `` /* 149-byte string literal not displayed */
	DownloadStartTimestamp string `` /* 164-byte string literal not displayed */
	ProcessStartTimestamp  string `` /* 160-byte string literal not displayed */
	StoreStartTimestamp    string `` /* 152-byte string literal not displayed */
	StatusMessage          string `protobuf:"bytes,8,opt,name=status_message,json=statusMessage" json:"status_message,omitempty" bson:"status_message,omitempty"`
	ErrorCode              string `protobuf:"bytes,9,opt,name=error_code,json=errorCode" json:"error_code,omitempty" bson:"error_code,omitempty"`
}

func (*TrainingStatus) Descriptor 

func (*TrainingStatus) Descriptor() ([]byte, []int)

func (*TrainingStatus) GetCompletionTimestamp 

func (m *TrainingStatus) GetCompletionTimestamp() string

func (*TrainingStatus) GetDownloadStartTimestamp 

func (m *TrainingStatus) GetDownloadStartTimestamp() string

func (*TrainingStatus) GetErrorCode 

func (m *TrainingStatus) GetErrorCode() string

func (*TrainingStatus) GetProcessStartTimestamp 

func (m *TrainingStatus) GetProcessStartTimestamp() string

func (*TrainingStatus) GetStatus 

func (m *TrainingStatus) GetStatus() Status

func (*TrainingStatus) GetStatusMessage 

func (m *TrainingStatus) GetStatusMessage() string

func (*TrainingStatus) GetStoreStartTimestamp 

func (m *TrainingStatus) GetStoreStartTimestamp() string

func (*TrainingStatus) GetSubmissionTimestamp 

func (m *TrainingStatus) GetSubmissionTimestamp() string

func (*TrainingStatus) ProtoMessage 

func (*TrainingStatus) ProtoMessage()

func (*TrainingStatus) Reset 

func (m *TrainingStatus) Reset()

func (*TrainingStatus) String 

func (m *TrainingStatus) String() string

type UpdateRequest 

type UpdateRequest struct {
	TrainingId    string `protobuf:"bytes,1,opt,name=training_id,json=trainingId" json:"training_id,omitempty" bson:"training_id,omitempty"`
	UserId        string `protobuf:"bytes,2,opt,name=user_id,json=userId" json:"user_id,omitempty" bson:"user_id,omitempty"`
	Status        Status `protobuf:"varint,3,opt,name=status,enum=grpc.trainer.v2.Status" json:"status,omitempty" bson:"status,omitempty"`
	StatusMessage string `protobuf:"bytes,4,opt,name=status_message,json=statusMessage" json:"status_message,omitempty" bson:"status_message,omitempty"`
	ErrorCode     string `protobuf:"bytes,5,opt,name=error_code,json=errorCode" json:"error_code,omitempty" bson:"error_code,omitempty"`
	Timestamp     string `protobuf:"bytes,6,opt,name=timestamp" json:"timestamp,omitempty" bson:"timestamp,omitempty"`
}

func (*UpdateRequest) Descriptor 

func (*UpdateRequest) Descriptor() ([]byte, []int)

func (*UpdateRequest) GetErrorCode 

func (m *UpdateRequest) GetErrorCode() string

func (*UpdateRequest) GetStatus 

func (m *UpdateRequest) GetStatus() Status

func (*UpdateRequest) GetStatusMessage 

func (m *UpdateRequest) GetStatusMessage() string

func (*UpdateRequest) GetTimestamp 

func (m *UpdateRequest) GetTimestamp() string

func (*UpdateRequest) GetTrainingId 

func (m *UpdateRequest) GetTrainingId() string

func (*UpdateRequest) GetUserId 

func (m *UpdateRequest) GetUserId() string

func (*UpdateRequest) ProtoMessage 

func (*UpdateRequest) ProtoMessage()

func (*UpdateRequest) Reset 

func (m *UpdateRequest) Reset()

func (*UpdateRequest) String 

func (m *UpdateRequest) String() string

type UpdateResponse 

type UpdateResponse struct {
	TrainingId string `protobuf:"bytes,1,opt,name=training_id,json=trainingId" json:"training_id,omitempty" bson:"training_id,omitempty"`
}

func (*UpdateResponse) Descriptor 

func (*UpdateResponse) Descriptor() ([]byte, []int)

func (*UpdateResponse) GetTrainingId 

func (m *UpdateResponse) GetTrainingId() string

func (*UpdateResponse) ProtoMessage 

func (*UpdateResponse) ProtoMessage()

func (*UpdateResponse) Reset 

func (m *UpdateResponse) Reset()

func (*UpdateResponse) String 

func (m *UpdateResponse) String() string

type UpdateTrainedModelMetricsRequest 

type UpdateTrainedModelMetricsRequest struct {
	TrainingId string   `protobuf:"bytes,1,opt,name=training_id,json=trainingId" json:"training_id,omitempty" bson:"training_id,omitempty"`
	UserId     string   `protobuf:"bytes,2,opt,name=user_id,json=userId" json:"user_id,omitempty" bson:"user_id,omitempty"`
	NewMetrics *Metrics `protobuf:"bytes,3,opt,name=new_metrics,json=newMetrics" json:"new_metrics,omitempty" bson:"new_metrics,omitempty"`
}

func (*UpdateTrainedModelMetricsRequest) Descriptor 

func (*UpdateTrainedModelMetricsRequest) Descriptor() ([]byte, []int)

func (*UpdateTrainedModelMetricsRequest) GetNewMetrics 

func (m *UpdateTrainedModelMetricsRequest) GetNewMetrics() *Metrics

func (*UpdateTrainedModelMetricsRequest) GetTrainingId 

func (m *UpdateTrainedModelMetricsRequest) GetTrainingId() string

func (*UpdateTrainedModelMetricsRequest) GetUserId 

func (m *UpdateTrainedModelMetricsRequest) GetUserId() string

func (*UpdateTrainedModelMetricsRequest) ProtoMessage 

func (*UpdateTrainedModelMetricsRequest) ProtoMessage()

func (*UpdateTrainedModelMetricsRequest) Reset 

func (m *UpdateTrainedModelMetricsRequest) Reset()

func (*UpdateTrainedModelMetricsRequest) String 

func (m *UpdateTrainedModelMetricsRequest) String() string

type UpdateTrainedModelMetricsResponse 

type UpdateTrainedModelMetricsResponse struct {
	TrainingId string `protobuf:"bytes,1,opt,name=training_id,json=trainingId" json:"training_id,omitempty" bson:"training_id,omitempty"`
}

func (*UpdateTrainedModelMetricsResponse) Descriptor 

func (*UpdateTrainedModelMetricsResponse) Descriptor() ([]byte, []int)

func (*UpdateTrainedModelMetricsResponse) GetTrainingId 

func (m *UpdateTrainedModelMetricsResponse) GetTrainingId() string

func (*UpdateTrainedModelMetricsResponse) ProtoMessage 

func (*UpdateTrainedModelMetricsResponse) ProtoMessage()

func (*UpdateTrainedModelMetricsResponse) Reset 

func (m *UpdateTrainedModelMetricsResponse) Reset()

func (*UpdateTrainedModelMetricsResponse) String 

func (m *UpdateTrainedModelMetricsResponse) String() string

type ZippedDataChunk 

type ZippedDataChunk struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty" bson:"data,omitempty"`
}

func (*ZippedDataChunk) Descriptor 

func (*ZippedDataChunk) Descriptor() ([]byte, []int)

func (*ZippedDataChunk) GetData 

func (m *ZippedDataChunk) GetData() []byte

func (*ZippedDataChunk) ProtoMessage 

func (*ZippedDataChunk) ProtoMessage()

func (*ZippedDataChunk) Reset 

func (m *ZippedDataChunk) Reset()

func (*ZippedDataChunk) String 

func (m *ZippedDataChunk) String() string

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.