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 (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) 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

Source Files

View all Source files

Directories

Path Synopsis

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.