Documentation ¶
Overview ¶
Package service is a generated protocol buffer package.
It is generated from these files:
lcm.proto
It has these top-level messages:
ResourceRequirements User JobDeploymentRequest ImageLocation JobDeploymentResponse JobKillRequest JobKillResponse JobHaltRequest JobHaltResponse
Index ¶
- Variables
- func RegisterLifecycleManagerServer(s *grpc.Server, srv LifecycleManagerServer)
- type ImageLocation
- func (*ImageLocation) Descriptor() ([]byte, []int)
- func (m *ImageLocation) GetAccessToken() string
- func (m *ImageLocation) GetEmail() string
- func (m *ImageLocation) GetNamespace() string
- func (m *ImageLocation) GetRegistry() string
- func (*ImageLocation) ProtoMessage()
- func (m *ImageLocation) Reset()
- func (m *ImageLocation) String() string
- type JobDeploymentRequest
- func (*JobDeploymentRequest) Descriptor() ([]byte, []int)
- func (m *JobDeploymentRequest) GetEnvVars() map[string]string
- func (m *JobDeploymentRequest) GetEvaluationMetricsSpec() string
- func (m *JobDeploymentRequest) GetFramework() string
- func (m *JobDeploymentRequest) GetImageLocation() *ImageLocation
- func (m *JobDeploymentRequest) GetImageTag() string
- func (m *JobDeploymentRequest) GetLabels() map[string]string
- func (m *JobDeploymentRequest) GetName() string
- func (m *JobDeploymentRequest) GetResources() *ResourceRequirements
- func (m *JobDeploymentRequest) GetTrainingId() string
- func (m *JobDeploymentRequest) GetUserId() string
- func (m *JobDeploymentRequest) GetVersion() string
- func (*JobDeploymentRequest) ProtoMessage()
- func (m *JobDeploymentRequest) Reset()
- func (m *JobDeploymentRequest) String() string
- type JobDeploymentResponse
- type JobHaltRequest
- type JobHaltResponse
- type JobKillRequest
- type JobKillResponse
- type Lifecycle
- type LifecycleHandler
- type LifecycleManagerClient
- type LifecycleManagerServer
- type ResourceRequirements
- func (*ResourceRequirements) Descriptor() ([]byte, []int)
- func (m *ResourceRequirements) GetArchitecture() string
- func (m *ResourceRequirements) GetCpus() float64
- func (m *ResourceRequirements) GetGpuType() string
- func (m *ResourceRequirements) GetGpus() float64
- func (m *ResourceRequirements) GetLearners() int32
- func (m *ResourceRequirements) GetMemory() float64
- func (m *ResourceRequirements) GetMemoryUnit() ResourceRequirements_MemoryUnit
- func (m *ResourceRequirements) GetSchedpolicy() string
- func (m *ResourceRequirements) GetStorage() float64
- func (m *ResourceRequirements) GetStorageUnit() ResourceRequirements_MemoryUnit
- func (m *ResourceRequirements) GetTopology() string
- func (*ResourceRequirements) ProtoMessage()
- func (m *ResourceRequirements) Reset()
- func (m *ResourceRequirements) String() string
- type ResourceRequirements_MemoryUnit
- type StatusMessages
- type User
Constants ¶
This section is empty.
Variables ¶
View Source
var ResourceRequirements_MemoryUnit_name = map[int32]string{
0: "MB",
1: "MiB",
2: "GB",
3: "GiB",
4: "TB",
5: "TiB",
}
View Source
var ResourceRequirements_MemoryUnit_value = map[string]int32{
"MB": 0,
"MiB": 1,
"GB": 2,
"GiB": 3,
"TB": 4,
"TiB": 5,
}
View Source
var StatusMessages_name = map[int32]string{
0: "NORMAL_OPERATION",
10: "INTERNAL_ERROR",
20: "INSUFFICIENT_RESOURCES",
}
View Source
var StatusMessages_value = map[string]int32{
"NORMAL_OPERATION": 0,
"INTERNAL_ERROR": 10,
"INSUFFICIENT_RESOURCES": 20,
}
Functions ¶
func RegisterLifecycleManagerServer ¶
func RegisterLifecycleManagerServer(s *grpc.Server, srv LifecycleManagerServer)
Types ¶
type ImageLocation ¶
type ImageLocation struct { Registry string `protobuf:"bytes,1,opt,name=registry" json:"registry,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace" json:"namespace,omitempty"` AccessToken string `protobuf:"bytes,3,opt,name=access_token,json=accessToken" json:"access_token,omitempty"` Email string `protobuf:"bytes,4,opt,name=email" json:"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 JobDeploymentRequest ¶
type JobDeploymentRequest struct { Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"` Resources *ResourceRequirements `protobuf:"bytes,4,opt,name=resources" json:"resources,omitempty"` EnvVars map[string]string `` /* 149-byte string literal not displayed */ Labels map[string]string `` /* 132-byte string literal not displayed */ UserId string `protobuf:"bytes,7,opt,name=user_id,json=userId" json:"user_id,omitempty"` TrainingId string `protobuf:"bytes,8,opt,name=training_id,json=trainingId" json:"training_id,omitempty"` Framework string `protobuf:"bytes,9,opt,name=framework" json:"framework,omitempty"` Version string `protobuf:"bytes,10,opt,name=version" json:"version,omitempty"` EvaluationMetricsSpec string `protobuf:"bytes,11,opt,name=evaluation_metrics_spec,json=evaluationMetricsSpec" json:"evaluation_metrics_spec,omitempty"` ImageTag string `protobuf:"bytes,12,opt,name=image_tag,json=imageTag" json:"image_tag,omitempty"` ImageLocation *ImageLocation `protobuf:"bytes,13,opt,name=image_location,json=imageLocation" json:"image_location,omitempty"` }
func (*JobDeploymentRequest) Descriptor ¶
func (*JobDeploymentRequest) Descriptor() ([]byte, []int)
func (*JobDeploymentRequest) GetEnvVars ¶
func (m *JobDeploymentRequest) GetEnvVars() map[string]string
func (*JobDeploymentRequest) GetEvaluationMetricsSpec ¶
func (m *JobDeploymentRequest) GetEvaluationMetricsSpec() string
func (*JobDeploymentRequest) GetFramework ¶
func (m *JobDeploymentRequest) GetFramework() string
func (*JobDeploymentRequest) GetImageLocation ¶
func (m *JobDeploymentRequest) GetImageLocation() *ImageLocation
func (*JobDeploymentRequest) GetImageTag ¶
func (m *JobDeploymentRequest) GetImageTag() string
func (*JobDeploymentRequest) GetLabels ¶
func (m *JobDeploymentRequest) GetLabels() map[string]string
func (*JobDeploymentRequest) GetName ¶
func (m *JobDeploymentRequest) GetName() string
func (*JobDeploymentRequest) GetResources ¶
func (m *JobDeploymentRequest) GetResources() *ResourceRequirements
func (*JobDeploymentRequest) GetTrainingId ¶
func (m *JobDeploymentRequest) GetTrainingId() string
func (*JobDeploymentRequest) GetUserId ¶
func (m *JobDeploymentRequest) GetUserId() string
func (*JobDeploymentRequest) GetVersion ¶
func (m *JobDeploymentRequest) GetVersion() string
func (*JobDeploymentRequest) ProtoMessage ¶
func (*JobDeploymentRequest) ProtoMessage()
func (*JobDeploymentRequest) Reset ¶
func (m *JobDeploymentRequest) Reset()
func (*JobDeploymentRequest) String ¶
func (m *JobDeploymentRequest) String() string
type JobDeploymentResponse ¶
type JobDeploymentResponse struct { Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"` Status string `protobuf:"bytes,2,opt,name=status" json:"status,omitempty"` }
func (*JobDeploymentResponse) Descriptor ¶
func (*JobDeploymentResponse) Descriptor() ([]byte, []int)
func (*JobDeploymentResponse) GetName ¶
func (m *JobDeploymentResponse) GetName() string
func (*JobDeploymentResponse) GetStatus ¶
func (m *JobDeploymentResponse) GetStatus() string
func (*JobDeploymentResponse) ProtoMessage ¶
func (*JobDeploymentResponse) ProtoMessage()
func (*JobDeploymentResponse) Reset ¶
func (m *JobDeploymentResponse) Reset()
func (*JobDeploymentResponse) String ¶
func (m *JobDeploymentResponse) String() string
type JobHaltRequest ¶
type JobHaltRequest struct { Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"` TrainingId string `protobuf:"bytes,2,opt,name=training_id,json=trainingId" json:"training_id,omitempty"` UserId string `protobuf:"bytes,3,opt,name=user_id,json=userId" json:"user_id,omitempty"` }
func (*JobHaltRequest) Descriptor ¶
func (*JobHaltRequest) Descriptor() ([]byte, []int)
func (*JobHaltRequest) GetName ¶
func (m *JobHaltRequest) GetName() string
func (*JobHaltRequest) GetTrainingId ¶
func (m *JobHaltRequest) GetTrainingId() string
func (*JobHaltRequest) GetUserId ¶
func (m *JobHaltRequest) GetUserId() string
func (*JobHaltRequest) ProtoMessage ¶
func (*JobHaltRequest) ProtoMessage()
func (*JobHaltRequest) Reset ¶
func (m *JobHaltRequest) Reset()
func (*JobHaltRequest) String ¶
func (m *JobHaltRequest) String() string
type JobHaltResponse ¶
type JobHaltResponse struct { }
func (*JobHaltResponse) Descriptor ¶
func (*JobHaltResponse) Descriptor() ([]byte, []int)
func (*JobHaltResponse) ProtoMessage ¶
func (*JobHaltResponse) ProtoMessage()
func (*JobHaltResponse) Reset ¶
func (m *JobHaltResponse) Reset()
func (*JobHaltResponse) String ¶
func (m *JobHaltResponse) String() string
type JobKillRequest ¶
type JobKillRequest struct { Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"` TrainingId string `protobuf:"bytes,2,opt,name=training_id,json=trainingId" json:"training_id,omitempty"` UserId string `protobuf:"bytes,3,opt,name=user_id,json=userId" json:"user_id,omitempty"` }
func (*JobKillRequest) Descriptor ¶
func (*JobKillRequest) Descriptor() ([]byte, []int)
func (*JobKillRequest) GetName ¶
func (m *JobKillRequest) GetName() string
func (*JobKillRequest) GetTrainingId ¶
func (m *JobKillRequest) GetTrainingId() string
func (*JobKillRequest) GetUserId ¶
func (m *JobKillRequest) GetUserId() string
func (*JobKillRequest) ProtoMessage ¶
func (*JobKillRequest) ProtoMessage()
func (*JobKillRequest) Reset ¶
func (m *JobKillRequest) Reset()
func (*JobKillRequest) String ¶
func (m *JobKillRequest) String() string
type JobKillResponse ¶
type JobKillResponse struct { }
func (*JobKillResponse) Descriptor ¶
func (*JobKillResponse) Descriptor() ([]byte, []int)
func (*JobKillResponse) ProtoMessage ¶
func (*JobKillResponse) ProtoMessage()
func (*JobKillResponse) Reset ¶
func (m *JobKillResponse) Reset()
func (*JobKillResponse) String ¶
func (m *JobKillResponse) String() string
type Lifecycle ¶
Lifecycle implements the lifecycle operations for microservice including dynamic service registration.
func (*Lifecycle) GetListenerAddress ¶
GetListenerAddress will get the address and port the service is listening. Returns the empty string if the service is not running but the method is invoked.
type LifecycleHandler ¶
type LifecycleHandler interface { Start(port int, background bool) Stop() GetListenerAddress() string }
LifecycleHandler provides basic lifecycle methods that each microservice has to implement.
type LifecycleManagerClient ¶
type LifecycleManagerClient interface { DeployTrainingJob(ctx context.Context, in *JobDeploymentRequest, opts ...grpc.CallOption) (*JobDeploymentResponse, error) KillTrainingJob(ctx context.Context, in *JobKillRequest, opts ...grpc.CallOption) (*JobKillResponse, error) HaltTrainingJob(ctx context.Context, in *JobHaltRequest, opts ...grpc.CallOption) (*JobHaltResponse, error) }
func NewLifecycleManagerClient ¶
func NewLifecycleManagerClient(cc *grpc.ClientConn) LifecycleManagerClient
type LifecycleManagerServer ¶
type LifecycleManagerServer interface { DeployTrainingJob(context.Context, *JobDeploymentRequest) (*JobDeploymentResponse, error) KillTrainingJob(context.Context, *JobKillRequest) (*JobKillResponse, error) HaltTrainingJob(context.Context, *JobHaltRequest) (*JobHaltResponse, error) }
type ResourceRequirements ¶
type ResourceRequirements struct { Cpus float64 `protobuf:"fixed64,1,opt,name=cpus" json:"cpus,omitempty"` Gpus float64 `protobuf:"fixed64,2,opt,name=gpus" json:"gpus,omitempty"` Memory float64 `protobuf:"fixed64,3,opt,name=memory" json:"memory,omitempty"` MemoryUnit ResourceRequirements_MemoryUnit `` /* 130-byte string literal not displayed */ Learners int32 `protobuf:"varint,5,opt,name=learners" json:"learners,omitempty"` Schedpolicy string `protobuf:"bytes,6,opt,name=schedpolicy" json:"schedpolicy,omitempty"` Topology string `protobuf:"bytes,7,opt,name=topology" json:"topology,omitempty"` Architecture string `protobuf:"bytes,8,opt,name=architecture" json:"architecture,omitempty"` Storage float64 `protobuf:"fixed64,9,opt,name=storage" json:"storage,omitempty"` StorageUnit ResourceRequirements_MemoryUnit `` /* 134-byte string literal not displayed */ GpuType string `protobuf:"bytes,11,opt,name=gpu_type,json=gpuType" json:"gpu_type,omitempty"` }
func (*ResourceRequirements) Descriptor ¶
func (*ResourceRequirements) Descriptor() ([]byte, []int)
func (*ResourceRequirements) GetArchitecture ¶
func (m *ResourceRequirements) GetArchitecture() string
func (*ResourceRequirements) GetCpus ¶
func (m *ResourceRequirements) GetCpus() float64
func (*ResourceRequirements) GetGpuType ¶
func (m *ResourceRequirements) GetGpuType() string
func (*ResourceRequirements) GetGpus ¶
func (m *ResourceRequirements) GetGpus() float64
func (*ResourceRequirements) GetLearners ¶
func (m *ResourceRequirements) GetLearners() int32
func (*ResourceRequirements) GetMemory ¶
func (m *ResourceRequirements) GetMemory() float64
func (*ResourceRequirements) GetMemoryUnit ¶
func (m *ResourceRequirements) GetMemoryUnit() ResourceRequirements_MemoryUnit
func (*ResourceRequirements) GetSchedpolicy ¶
func (m *ResourceRequirements) GetSchedpolicy() string
func (*ResourceRequirements) GetStorage ¶
func (m *ResourceRequirements) GetStorage() float64
func (*ResourceRequirements) GetStorageUnit ¶
func (m *ResourceRequirements) GetStorageUnit() ResourceRequirements_MemoryUnit
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 ResourceRequirements_MemoryUnit ¶
type ResourceRequirements_MemoryUnit int32
const ( ResourceRequirements_MB ResourceRequirements_MemoryUnit = 0 ResourceRequirements_MiB ResourceRequirements_MemoryUnit = 1 ResourceRequirements_GB ResourceRequirements_MemoryUnit = 2 ResourceRequirements_GiB ResourceRequirements_MemoryUnit = 3 ResourceRequirements_TB ResourceRequirements_MemoryUnit = 4 ResourceRequirements_TiB ResourceRequirements_MemoryUnit = 5 )
func (ResourceRequirements_MemoryUnit) EnumDescriptor ¶
func (ResourceRequirements_MemoryUnit) EnumDescriptor() ([]byte, []int)
func (ResourceRequirements_MemoryUnit) String ¶
func (x ResourceRequirements_MemoryUnit) String() string
type StatusMessages ¶
type StatusMessages int32
const ( StatusMessages_NORMAL_OPERATION StatusMessages = 0 StatusMessages_INTERNAL_ERROR StatusMessages = 10 StatusMessages_INSUFFICIENT_RESOURCES StatusMessages = 20 )
func (StatusMessages) EnumDescriptor ¶
func (StatusMessages) EnumDescriptor() ([]byte, []int)
func (StatusMessages) String ¶
func (x StatusMessages) String() string
type User ¶
type User struct { Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"` Roles []string `protobuf:"bytes,2,rep,name=roles" json:"roles,omitempty"` Firstname string `protobuf:"bytes,3,opt,name=firstname" json:"firstname,omitempty"` Lastname string `protobuf:"bytes,4,opt,name=lastname" json:"lastname,omitempty"` Email string `protobuf:"bytes,5,opt,name=email" json:"email,omitempty"` }
func (*User) Descriptor ¶
func (*User) GetFirstname ¶
func (*User) GetLastname ¶
func (*User) ProtoMessage ¶
func (*User) ProtoMessage()
Click to show internal directories.
Click to hide internal directories.