service

package
v0.1.1-rc.0...-32aea41 Latest Latest
Warning

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

Go to latest
Published: Dec 12, 2022 License: Apache-2.0, CC-BY-4.0, MIT Imports: 11 Imported by: 0

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

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 Config

type Config struct {
	// contains filtered or unexported fields
}

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

type Lifecycle struct {
	Listener        net.Listener
	Server          *grpc.Server
	RegisterService func()
}

Lifecycle implements the lifecycle operations for microservice including dynamic service registration.

func (*Lifecycle) GetListenerAddress

func (s *Lifecycle) GetListenerAddress() string

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.

func (*Lifecycle) Start

func (s *Lifecycle) Start(port int, background bool)

Start will start a gRPC microservice on a given port and run it either in foreground or background.

func (*Lifecycle) Stop

func (s *Lifecycle) Stop()

Stop will stop the gRPC microservice and the socket.

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 (*ResourceRequirements) GetSchedpolicy

func (m *ResourceRequirements) GetSchedpolicy() string

func (*ResourceRequirements) GetStorage

func (m *ResourceRequirements) GetStorage() float64

func (*ResourceRequirements) GetStorageUnit

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

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) Descriptor() ([]byte, []int)

func (*User) GetEmail

func (m *User) GetEmail() string

func (*User) GetFirstname

func (m *User) GetFirstname() string

func (*User) GetId

func (m *User) GetId() string

func (*User) GetLastname

func (m *User) GetLastname() string

func (*User) GetRoles

func (m *User) GetRoles() []string

func (*User) ProtoMessage

func (*User) ProtoMessage()

func (*User) Reset

func (m *User) Reset()

func (*User) String

func (m *User) String() string

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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