listeners

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Nov 28, 2018 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var GetCurrentTenant = getCurrentTenant

GetCurrentTenant contains the current tenant

View Source 
var NewVolumeService = services.NewVolumeService

NewVolumeService ...

Functions

This section is empty.

Types

type BucketServiceListener 

type BucketServiceListener struct{}

BucketServiceListener is the bucket service grpc server

func (*BucketServiceListener) Create 

func (s *BucketServiceListener) Create(ctx context.Context, in *pb.Bucket) (*google_protobuf.Empty, error)

Create a new bucket

func (*BucketServiceListener) Delete 

func (s *BucketServiceListener) Delete(ctx context.Context, in *pb.Bucket) (*google_protobuf.Empty, error)

Delete a bucket

func (*BucketServiceListener) Inspect 

func (s *BucketServiceListener) Inspect(ctx context.Context, in *pb.Bucket) (*pb.BucketMountingPoint, error)

Inspect a bucket

func (*BucketServiceListener) List 

func (s *BucketServiceListener) List(ctx context.Context, in *google_protobuf.Empty) (*pb.BucketList, error)

List available buckets

func (*BucketServiceListener) Mount 

func (s *BucketServiceListener) Mount(ctx context.Context, in *pb.BucketMountingPoint) (*google_protobuf.Empty, error)

Mount a bucket on the filesystem of the host

func (*BucketServiceListener) Unmount 

func (s *BucketServiceListener) Unmount(ctx context.Context, in *pb.BucketMountingPoint) (*google_protobuf.Empty, error)

Unmount a bucket from the filesystem of the host

type HostServiceListener 

type HostServiceListener struct{}

HostServiceListener host service server grpc

func (*HostServiceListener) Create 

func (s *HostServiceListener) Create(ctx context.Context, in *pb.HostDefinition) (*pb.Host, error)

Create a new host

func (*HostServiceListener) Delete 

func (s *HostServiceListener) Delete(ctx context.Context, in *pb.Reference) (*google_protobuf.Empty, error)

Delete an host

func (*HostServiceListener) Inspect 

func (s *HostServiceListener) Inspect(ctx context.Context, in *pb.Reference) (*pb.Host, error)

Inspect an host

func (*HostServiceListener) List 

func (s *HostServiceListener) List(ctx context.Context, in *pb.HostListRequest) (*pb.HostList, error)

List available hosts

func (*HostServiceListener) Reboot 

func (s *HostServiceListener) Reboot(ctx context.Context, in *pb.Reference) (*google_protobuf.Empty, error)

Reboot ...

func (*HostServiceListener) SSH 

func (s *HostServiceListener) SSH(ctx context.Context, in *pb.Reference) (*pb.SshConfig, error)

SSH returns ssh parameters to access an host

func (*HostServiceListener) Start 

func (s *HostServiceListener) Start(ctx context.Context, in *pb.Reference) (*google_protobuf.Empty, error)

Start ...

func (*HostServiceListener) Status 

func (s *HostServiceListener) Status(ctx context.Context, in *pb.Reference) (*pb.HostStatus, error)

Status of a host

func (*HostServiceListener) Stop 

func (s *HostServiceListener) Stop(ctx context.Context, in *pb.Reference) (*google_protobuf.Empty, error)

Stop ...

type ImageServiceListener 

type ImageServiceListener struct{}

ImageServiceListener image service server grpc

func (*ImageServiceListener) List 

func (s *ImageServiceListener) List(ctx context.Context, in *pb.ImageListRequest) (*pb.ImageList, error)

List available images

type NetworkServiceListener 

type NetworkServiceListener struct{}

NetworkServiceListener network service server grpc

func (*NetworkServiceListener) Create 

func (s *NetworkServiceListener) Create(ctx context.Context, in *pb.NetworkDefinition) (*pb.Network, error)

Create a new network

func (*NetworkServiceListener) Delete 

func (s *NetworkServiceListener) Delete(ctx context.Context, in *pb.Reference) (*google_protobuf.Empty, error)

Delete a network

func (*NetworkServiceListener) Inspect 

func (s *NetworkServiceListener) Inspect(ctx context.Context, in *pb.Reference) (*pb.Network, error)

Inspect returns infos on a network

func (*NetworkServiceListener) List 

func (s *NetworkServiceListener) List(ctx context.Context, in *pb.NWListRequest) (*pb.NetworkList, error)

List existing networks

type SSHServiceListener 

type SSHServiceListener struct{}

SSHServiceListener SSH service server grpc

func (*SSHServiceListener) Copy 

func (s *SSHServiceListener) Copy(ctx context.Context, in *pb.SshCopyCommand) (*pb.SshResponse, error)

Copy copy file from/to an host

func (*SSHServiceListener) Run 

func (s *SSHServiceListener) Run(ctx context.Context, in *pb.SshCommand) (*pb.SshResponse, error)

Run executes an ssh command an an host

type ShareServiceListener 

type ShareServiceListener struct{}

ShareServiceListener Share service server grpc

func (*ShareServiceListener) Create 

func (s *ShareServiceListener) Create(ctx context.Context, in *pb.ShareDefinition) (*pb.ShareDefinition, error)

Create calls share service creation

func (*ShareServiceListener) Delete 

func (s *ShareServiceListener) Delete(ctx context.Context, in *pb.Reference) (*google_protobuf.Empty, error)

Delete call share service deletion

func (*ShareServiceListener) Inspect 

func (s *ShareServiceListener) Inspect(ctx context.Context, in *pb.Reference) (*pb.ShareMountList, error)

Inspect shows the detail of a share and all connected clients

func (*ShareServiceListener) List 

func (s *ShareServiceListener) List(ctx context.Context, in *google_protobuf.Empty) (*pb.ShareList, error)

List return the list of all available shares

func (*ShareServiceListener) Mount 

func (s *ShareServiceListener) Mount(ctx context.Context, in *pb.ShareMountDefinition) (*pb.ShareMountDefinition, error)

Mount mounts share on a local directory of the given host

func (*ShareServiceListener) Unmount 

func (s *ShareServiceListener) Unmount(ctx context.Context, in *pb.ShareMountDefinition) (*google_protobuf.Empty, error)

Unmount unmounts share from the given host

type StoredCPUInfo 

type StoredCPUInfo struct {
	ID           string `bow:"key"`
	TenantName   string `json:"tenant_name,omitempty"`
	TemplateID   string `json:"template_id,omitempty"`
	TemplateName string `json:"template_name,omitempty"`
	ImageID      string `json:"image_id,omitempty"`
	ImageName    string `json:"image_name,omitempty"`
	LastUpdated  string `json:"last_updated,omitempty"`

	NumberOfCPU    int     `json:"number_of_cpu,omitempty"`
	NumberOfCore   int     `json:"number_of_core,omitempty"`
	NumberOfSocket int     `json:"number_of_socket,omitempty"`
	CPUFrequency   float64 `json:"cpu_frequency,omitempty"`
	CPUArch        string  `json:"cpu_arch,omitempty"`
	Hypervisor     string  `json:"hypervisor,omitempty"`
	CPUModel       string  `json:"cpu_model,omitempty"`
	RAMSize        float64 `json:"ram_size,omitempty"`
	RAMFreq        float64 `json:"ram_freq,omitempty"`
	GPU            int     `json:"gpu,omitempty"`
	GPUModel       string  `json:"gpu_model,omitempty"`
}

StoredCPUInfo ...

type TemplateServiceListener 

type TemplateServiceListener struct{}

TemplateServiceListener host service server grpc

func (*TemplateServiceListener) List 

func (s *TemplateServiceListener) List(ctx context.Context, in *pb.TemplateListRequest) (*pb.TemplateList, error)

List available templates

type Tenant 

type Tenant struct {
	Service *providers.Service
	// contains filtered or unexported fields
}

Tenant structure to handle name and clientAPI for a tenant

type TenantServiceListener 

type TenantServiceListener struct{}

TenantServiceListener server is used to implement SafeScale.broker.

func (*TenantServiceListener) Get 

func (s *TenantServiceListener) Get(ctx context.Context, in *google_protobuf.Empty) (*pb.TenantName, error)

Get returns the name of the current tenant used

func (*TenantServiceListener) List 

func (s *TenantServiceListener) List(ctx context.Context, in *google_protobuf.Empty) (*pb.TenantList, error)

List registerd tenants

func (*TenantServiceListener) Set 

func (s *TenantServiceListener) Set(ctx context.Context, in *pb.TenantName) (*google_protobuf.Empty, error)

Set the the tenant tu use for each command

type VolumeServiceListener 

type VolumeServiceListener struct{}

VolumeServiceListener is the volume service grps server

func (*VolumeServiceListener) Attach 

func (s *VolumeServiceListener) Attach(ctx context.Context, in *pb.VolumeAttachment) (*google_protobuf.Empty, error)

Attach a volume to an host and create a mount point

func (*VolumeServiceListener) Create 

func (s *VolumeServiceListener) Create(ctx context.Context, in *pb.VolumeDefinition) (*pb.Volume, error)

Create a new volume

func (*VolumeServiceListener) Delete 

func (s *VolumeServiceListener) Delete(ctx context.Context, in *pb.Reference) (*google_protobuf.Empty, error)

Delete a volume

func (*VolumeServiceListener) Detach 

func (s *VolumeServiceListener) Detach(ctx context.Context, in *pb.VolumeDetachment) (*google_protobuf.Empty, error)

Detach a volume from an host. It umount associated mountpoint

func (*VolumeServiceListener) Inspect 

func (s *VolumeServiceListener) Inspect(ctx context.Context, in *pb.Reference) (*pb.VolumeInfo, error)

Inspect a volume

func (*VolumeServiceListener) List 

func (s *VolumeServiceListener) List(ctx context.Context, in *pb.VolumeListRequest) (*pb.VolumeList, error)

List the available volumes

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.