listeners

package
v22.11.9 Latest Latest
Warning

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

 Go to latest Published: May 30, 2023 License: Apache-2.0 Imports: 36 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var LabelHandler = handlers.NewTagHandler

LabelHandler ...

View Source 
var VolumeHandler = handlers.NewVolumeHandler

VolumeHandler ...

Functions

func PrepareInspectionJob added in v22.11.6 

func PrepareInspectionJob(ctx context.Context, tenantID string, jobDescription string) (_ backend.Job, ferr fail.Error)

func PrepareJob 

func PrepareJob(ctx context.Context, tenantID string, jobDescription string) (_ backend.Job, ferr fail.Error)

PrepareJob creates a new job

Types

type BucketListener 

type BucketListener struct {
	protocol.UnimplementedBucketServiceServer
}

BucketListener is the bucket service gRPC server

func (*BucketListener) Clear 

func (s *BucketListener) Clear(inctx context.Context, in *protocol.BucketRequest) (
	empty *googleprotobuf.Empty, err error,
)

Clear a bucket

func (*BucketListener) Create 

func (s *BucketListener) Create(inctx context.Context, in *protocol.BucketRequest) (
	empty *googleprotobuf.Empty, err error,
)

Create a new bucket

func (*BucketListener) Delete 

func (s *BucketListener) Delete(inctx context.Context, in *protocol.BucketDeleteRequest) (
	empty *googleprotobuf.Empty, err error,
)

Delete a bucket

func (*BucketListener) Download 

func (s *BucketListener) Download(
	inctx context.Context, in *protocol.BucketRequest,
) (_ *protocol.BucketDownloadResponse, err error)

Download a bucket

func (*BucketListener) Inspect 

func (s *BucketListener) Inspect(inctx context.Context, in *protocol.BucketRequest) (
	_ *protocol.BucketResponse, err error,
)

Inspect a bucket

func (*BucketListener) List 

func (s *BucketListener) List(inctx context.Context, in *protocol.BucketListRequest) (
	bl *protocol.BucketListResponse, err error,
)

List available buckets

func (*BucketListener) Mount 

func (s *BucketListener) Mount(inctx context.Context, in *protocol.BucketMountRequest) (
	empty *googleprotobuf.Empty, err error,
)

Mount a bucket on the filesystem of the host

func (*BucketListener) Unmount 

func (s *BucketListener) Unmount(inctx context.Context, in *protocol.BucketMountRequest) (
	empty *googleprotobuf.Empty, err error,
)

Unmount a bucket from the filesystem of the host

type ClusterListener 

type ClusterListener struct {
	protocol.UnimplementedClusterServiceServer
}

ClusterListener host service server grpc

func (*ClusterListener) Create 

func (s *ClusterListener) Create(inctx context.Context, in *protocol.ClusterCreateRequest) (_ *protocol.ClusterResponse, err error)

Create creates a new cluster

func (*ClusterListener) Delete 

func (s *ClusterListener) Delete(inctx context.Context, in *protocol.ClusterDeleteRequest) (empty *googleprotobuf.Empty, err error)

Delete a cluster

func (*ClusterListener) DeleteNode 

func (s *ClusterListener) DeleteNode(inctx context.Context, in *protocol.ClusterDeleteNodeRequest) (empty *googleprotobuf.Empty, err error)

DeleteNode removes node(s) from a cluster

func (*ClusterListener) Expand 

func (s *ClusterListener) Expand(inctx context.Context, in *protocol.ClusterResizeRequest) (_ *protocol.ClusterNodeListResponse, ferr error)

Expand adds node(s) to a cluster

func (*ClusterListener) FindAvailableMaster 

func (s *ClusterListener) FindAvailableMaster(inctx context.Context, in *protocol.Reference) (_ *protocol.Host, err error)

FindAvailableMaster determines the first master available master (ie the one that responds on ssh request)

func (*ClusterListener) Inspect 

func (s *ClusterListener) Inspect(inctx context.Context, in *protocol.Reference) (_ *protocol.ClusterResponse, err error)

Inspect a cluster

func (*ClusterListener) InspectMaster 

func (s *ClusterListener) InspectMaster(inctx context.Context, in *protocol.ClusterNodeRequest) (_ *protocol.Host, err error)

InspectMaster returns the information about a master of the cluster

func (*ClusterListener) InspectNode 

func (s *ClusterListener) InspectNode(inctx context.Context, in *protocol.ClusterNodeRequest) (_ *protocol.Host, err error)

InspectNode inspects a node of the cluster

func (*ClusterListener) List 

func (s *ClusterListener) List(inctx context.Context, in *protocol.Reference) (hl *protocol.ClusterListResponse, err error)

List lists clusters

func (*ClusterListener) ListMasters 

func (s *ClusterListener) ListMasters(inctx context.Context, in *protocol.Reference) (_ *protocol.ClusterNodeListResponse, err error)

ListMasters returns the list of masters of the cluster

func (*ClusterListener) ListNodes 

func (s *ClusterListener) ListNodes(inctx context.Context, in *protocol.Reference) (_ *protocol.ClusterNodeListResponse, err error)

ListNodes lists node(s) of a cluster

func (*ClusterListener) Shrink 

func (s *ClusterListener) Shrink(inctx context.Context, in *protocol.ClusterResizeRequest) (_ *protocol.ClusterNodeListResponse, err error)

Shrink removes node(s) from a cluster

func (*ClusterListener) Start 

func (s *ClusterListener) Start(inctx context.Context, in *protocol.Reference) (empty *googleprotobuf.Empty, err error)

Start ...

func (*ClusterListener) StartMaster 

func (s *ClusterListener) StartMaster(inctx context.Context, in *protocol.ClusterNodeRequest) (empty *googleprotobuf.Empty, err error)

StartMaster starts a stopped master of the ClassicCluster

func (*ClusterListener) StartNode 

func (s *ClusterListener) StartNode(inctx context.Context, in *protocol.ClusterNodeRequest) (empty *googleprotobuf.Empty, err error)

StartNode starts a stopped node of the cluster

func (*ClusterListener) State 

func (s *ClusterListener) State(inctx context.Context, in *protocol.Reference) (ht *protocol.ClusterStateResponse, err error)

State returns the status of a cluster

func (*ClusterListener) StateMaster 

func (s *ClusterListener) StateMaster(inctx context.Context, in *protocol.ClusterNodeRequest) (_ *protocol.HostStatus, err error)

StateMaster returns the state of a master of the ClassicCluster

func (*ClusterListener) StateNode 

func (s *ClusterListener) StateNode(inctx context.Context, in *protocol.ClusterNodeRequest) (_ *protocol.HostStatus, err error)

StateNode returns the state of a node of the cluster

func (*ClusterListener) Stop 

func (s *ClusterListener) Stop(inctx context.Context, in *protocol.Reference) (empty *googleprotobuf.Empty, err error)

Stop shutdowns an entire cluster (including the gateways)

func (*ClusterListener) StopMaster 

func (s *ClusterListener) StopMaster(inctx context.Context, in *protocol.ClusterNodeRequest) (empty *googleprotobuf.Empty, err error)

StopMaster stops a master of the ClassicCluster

func (*ClusterListener) StopNode 

func (s *ClusterListener) StopNode(inctx context.Context, in *protocol.ClusterNodeRequest) (empty *googleprotobuf.Empty, err error)

StopNode stops a node of the cluster

type FeatureListener 

type FeatureListener struct {
	protocol.UnimplementedFeatureServiceServer
}

FeatureListener feature service server grpc

func (*FeatureListener) Add 

func (s *FeatureListener) Add(inctx context.Context, in *protocol.FeatureActionRequest) (empty *googleprotobuf.Empty, ferr error)

Add ...

func (*FeatureListener) Check 

func (s *FeatureListener) Check(inctx context.Context, in *protocol.FeatureActionRequest) (empty *googleprotobuf.Empty, ferr error)

Check checks if a feature installed on target

func (*FeatureListener) List 

func (s *FeatureListener) List(inctx context.Context, in *protocol.FeatureListRequest) (_ *protocol.FeatureListResponse, ferr error)

List ...

func (*FeatureListener) Remove 

func (s *FeatureListener) Remove(inctx context.Context, in *protocol.FeatureActionRequest) (empty *googleprotobuf.Empty, ferr error)

Remove uninstalls a Feature

type HostListener 

type HostListener struct {
	protocol.UnimplementedHostServiceServer
}

HostListener host service server grpc

func (*HostListener) BindLabel 

func (s *HostListener) BindLabel(inctx context.Context, in *protocol.LabelBindRequest) (empty *googleprotobuf.Empty, err error)

BindLabel binds a Label to a Host

func (*HostListener) BindSecurityGroup 

func (s *HostListener) BindSecurityGroup(inctx context.Context, in *protocol.SecurityGroupHostBindRequest) (empty *googleprotobuf.Empty, err error)

BindSecurityGroup attaches a Security Group to a host

func (*HostListener) Create 

func (s *HostListener) Create(inctx context.Context, in *protocol.HostDefinition) (_ *protocol.Host, err error)

Create creates a new host

func (*HostListener) Delete 

func (s *HostListener) Delete(inctx context.Context, in *protocol.HostDeleteRequest) (empty *googleprotobuf.Empty, err error)

Delete a host

func (*HostListener) DisableSecurityGroup 

func (s *HostListener) DisableSecurityGroup(inctx context.Context, in *protocol.SecurityGroupHostBindRequest) (empty *googleprotobuf.Empty, err error)

DisableSecurityGroup applies a Security Group already attached (if not already applied)

func (*HostListener) EnableSecurityGroup 

func (s *HostListener) EnableSecurityGroup(inctx context.Context, in *protocol.SecurityGroupHostBindRequest) (empty *googleprotobuf.Empty, err error)

EnableSecurityGroup applies a Security Group already attached (if not already applied)

func (*HostListener) Inspect 

func (s *HostListener) Inspect(inctx context.Context, in *protocol.Reference) (h *protocol.Host, ferr error)

Inspect a host

func (*HostListener) InspectLabel 

func (s *HostListener) InspectLabel(inctx context.Context, in *protocol.HostLabelRequest) (_ *protocol.HostLabelResponse, err error)

InspectLabel inspects a Label of a Host

func (*HostListener) List 

func (s *HostListener) List(inctx context.Context, in *protocol.HostListRequest) (hl *protocol.HostList, err error)

List lists hosts managed by SafeScale only, or all hosts.

func (*HostListener) ListLabels 

func (s *HostListener) ListLabels(inctx context.Context, in *protocol.LabelBoundsRequest) (_ *protocol.LabelListResponse, err error)

ListLabels lists Label/Tag bound to a Host

func (*HostListener) ListSecurityGroups 

func (s *HostListener) ListSecurityGroups(inctx context.Context, in *protocol.SecurityGroupHostBindRequest) (_ *protocol.SecurityGroupBondsResponse, err error)

ListSecurityGroups applies a Security Group already attached (if not already applied)

func (*HostListener) Reboot 

func (s *HostListener) Reboot(inctx context.Context, in *protocol.Reference) (empty *googleprotobuf.Empty, err error)

Reboot reboots a host.

func (*HostListener) ResetLabel 

func (s *HostListener) ResetLabel(inctx context.Context, in *protocol.LabelBindRequest) (empty *googleprotobuf.Empty, err error)

ResetLabel restores default value of Label to the Host

func (*HostListener) SSH 

func (s *HostListener) SSH(inctx context.Context, in *protocol.Reference) (_ *protocol.SshConfig, err error)

SSH returns ssh parameters to access a host

func (*HostListener) Start 

func (s *HostListener) Start(inctx context.Context, in *protocol.Reference) (empty *googleprotobuf.Empty, err error)

Start ...

func (*HostListener) Status 

func (s *HostListener) Status(inctx context.Context, in *protocol.Reference) (ht *protocol.HostStatus, err error)

Status returns the status of a host (running or stopped mainly)

func (*HostListener) Stop 

func (s *HostListener) Stop(inctx context.Context, in *protocol.Reference) (empty *googleprotobuf.Empty, err error)

Stop shutdowns a host.

func (*HostListener) UnbindLabel 

func (s *HostListener) UnbindLabel(inctx context.Context, in *protocol.LabelBindRequest) (empty *googleprotobuf.Empty, err error)

UnbindLabel unbinds a Label from a Host

func (*HostListener) UnbindSecurityGroup 

func (s *HostListener) UnbindSecurityGroup(inctx context.Context, in *protocol.SecurityGroupHostBindRequest) (empty *googleprotobuf.Empty, err error)

UnbindSecurityGroup detaches a Security Group from a host

func (*HostListener) UpdateLabel 

func (s *HostListener) UpdateLabel(inctx context.Context, in *protocol.LabelBindRequest) (empty *googleprotobuf.Empty, err error)

UpdateLabel updates Label value for the Host

type ImageListener 

type ImageListener struct {
	protocol.UnimplementedImageServiceServer
}

ImageListener image service server grpc

func (*ImageListener) List 

func (s *ImageListener) List(inctx context.Context, in *protocol.ImageListRequest) (_ *protocol.ImageList, err error)

List available images

type JobManagerListener 

type JobManagerListener struct {
	protocol.UnimplementedJobServiceServer
}

JobManagerListener service server gRPC

func (*JobManagerListener) List 

func (s *JobManagerListener) List(inctx context.Context, _ *googleprotobuf.Empty) (jl *protocol.JobList, err error)

List running process

func (*JobManagerListener) Stop 

func (s *JobManagerListener) Stop(ctx context.Context, in *protocol.JobDefinition) (empty *googleprotobuf.Empty, ferr error)

Stop specified process

type LabelListener 

type LabelListener struct {
	protocol.UnimplementedLabelServiceServer
}

LabelListener is the tag service gRPC server

func (*LabelListener) Create 

func (s *LabelListener) Create(inctx context.Context, in *protocol.LabelCreateRequest) (_ *protocol.LabelInspectResponse, err error)

Create a new label/tag

func (*LabelListener) Delete 

func (s *LabelListener) Delete(inctx context.Context, in *protocol.LabelDeleteRequest) (empty *googleprotobuf.Empty, err error)

Delete a Label

func (*LabelListener) Inspect 

func (s *LabelListener) Inspect(inctx context.Context, in *protocol.LabelInspectRequest) (_ *protocol.LabelInspectResponse, err error)

Inspect a Label/Tag

func (*LabelListener) List 

func (s *LabelListener) List(inctx context.Context, in *protocol.LabelListRequest) (_ *protocol.LabelListResponse, err error)

List the available tags

type NetworkListener 

type NetworkListener struct {
	protocol.UnimplementedNetworkServiceServer
}

NetworkListener network service server grpc

func (*NetworkListener) Create 

func (s *NetworkListener) Create(inctx context.Context, in *protocol.NetworkCreateRequest) (_ *protocol.Network, ferr error)

Create a new network

func (*NetworkListener) Delete 

func (s *NetworkListener) Delete(inctx context.Context, in *protocol.NetworkDeleteRequest) (empty *googleprotobuf.Empty, err error)

Delete a network

func (*NetworkListener) Inspect 

func (s *NetworkListener) Inspect(inctx context.Context, in *protocol.Reference) (_ *protocol.Network, err error)

Inspect returns infos on a network

func (*NetworkListener) List 

func (s *NetworkListener) List(inctx context.Context, in *protocol.NetworkListRequest) (_ *protocol.NetworkList, err error)

List existing networks

type SSHListener 

type SSHListener struct {
	protocol.UnimplementedSshServiceServer
}

SSHListener SSH service server grpc

func (*SSHListener) Copy 

func (s *SSHListener) Copy(inctx context.Context, in *protocol.SshCopyCommand) (sr *protocol.SshResponse, err error)

Copy copies file from/to a host

func (*SSHListener) Run 

func (s *SSHListener) Run(inctx context.Context, in *protocol.SshCommand) (sr *protocol.SshResponse, ferr error)

Run executes an ssh command on a host

type SecurityGroupListener 

type SecurityGroupListener struct {
	protocol.UnimplementedSecurityGroupServiceServer
}

SecurityGroupListener security-group service server grpc

func (*SecurityGroupListener) AddRule 

func (s *SecurityGroupListener) AddRule(inctx context.Context, in *protocol.SecurityGroupRuleRequest) (sgr *protocol.SecurityGroupResponse, err error)

AddRule creates a new rule and add it to an existing security group

func (*SecurityGroupListener) Bonds 

func (s *SecurityGroupListener) Bonds(inctx context.Context, in *protocol.SecurityGroupBondsRequest) (_ *protocol.SecurityGroupBondsResponse, err error)

Bonds lists the resources bound to the Security Group

func (*SecurityGroupListener) Clear 

func (s *SecurityGroupListener) Clear(inctx context.Context, in *protocol.Reference) (empty *googleprotobuf.Empty, err error)

Clear calls the clear method to remove all rules from a security group

func (*SecurityGroupListener) Create 

func (s *SecurityGroupListener) Create(inctx context.Context, in *protocol.SecurityGroupCreateRequest) (_ *protocol.SecurityGroupResponse, err error)

Create creates a new Security Group

func (*SecurityGroupListener) Delete 

func (s *SecurityGroupListener) Delete(inctx context.Context, in *protocol.SecurityGroupDeleteRequest) (empty *googleprotobuf.Empty, err error)

Delete a host

func (*SecurityGroupListener) DeleteRule 

func (s *SecurityGroupListener) DeleteRule(inctx context.Context, in *protocol.SecurityGroupRuleDeleteRequest) (_ *protocol.SecurityGroupResponse, err error)

DeleteRule deletes a rule identified by id from a security group

func (*SecurityGroupListener) Inspect 

func (s *SecurityGroupListener) Inspect(inctx context.Context, in *protocol.Reference) (_ *protocol.SecurityGroupResponse, err error)

Inspect a host

func (*SecurityGroupListener) List 

func (s *SecurityGroupListener) List(inctx context.Context, in *protocol.SecurityGroupListRequest) (_ *protocol.SecurityGroupListResponse, err error)

List lists hosts managed by SafeScale only, or all hosts.

func (*SecurityGroupListener) Reset 

func (s *SecurityGroupListener) Reset(inctx context.Context, in *protocol.Reference) (empty *googleprotobuf.Empty, err error)

Reset clears the rules of a security group and readds the ones stored in metadata

type ShareListener 

type ShareListener struct {
	protocol.UnimplementedShareServiceServer
}

ShareListener Share service server grpc

func (*ShareListener) Create 

func (s *ShareListener) Create(inctx context.Context, in *protocol.ShareDefinition) (_ *protocol.ShareDefinition, err error)

Create calls share service creation

func (*ShareListener) Delete 

func (s *ShareListener) Delete(inctx context.Context, in *protocol.ShareDeleteRequest) (empty *googleprotobuf.Empty, err error)

Delete call share service deletion

func (*ShareListener) Inspect 

func (s *ShareListener) Inspect(inctx context.Context, in *protocol.Reference) (sml *protocol.ShareMountList, err error)

Inspect shows the detail of a share and all connected clients

func (*ShareListener) List 

func (s *ShareListener) List(inctx context.Context, in *protocol.Reference) (_ *protocol.ShareList, err error)

List return the list of all available shares

func (*ShareListener) Mount 

func (s *ShareListener) Mount(inctx context.Context, in *protocol.ShareMountDefinition) (smd *protocol.ShareMountDefinition, err error)

Mount mounts share on a local directory of the given host

func (*ShareListener) Unmount 

func (s *ShareListener) Unmount(inctx context.Context, in *protocol.ShareMountDefinition) (empty *googleprotobuf.Empty, err 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 SubnetListener 

type SubnetListener struct {
	protocol.UnimplementedSubnetServiceServer
}

SubnetListener subnet service server gRPC

func (*SubnetListener) BindSecurityGroup 

func (s *SubnetListener) BindSecurityGroup(inctx context.Context, in *protocol.SecurityGroupSubnetBindRequest) (empty *googleprotobuf.Empty, err error)

BindSecurityGroup attaches a Security Group to a hostnetwork

func (*SubnetListener) Create 

func (s *SubnetListener) Create(inctx context.Context, in *protocol.SubnetCreateRequest) (_ *protocol.Subnet, err error)

Create a new subnet

func (*SubnetListener) Delete 

func (s *SubnetListener) Delete(inctx context.Context, in *protocol.SubnetDeleteRequest) (empty *googleprotobuf.Empty, err error)

Delete a/many subnet/s

func (*SubnetListener) DisableSecurityGroup 

func (s *SubnetListener) DisableSecurityGroup(inctx context.Context, in *protocol.SecurityGroupSubnetBindRequest) (empty *googleprotobuf.Empty, err error)

DisableSecurityGroup detaches a Security Group from a subnet

func (*SubnetListener) EnableSecurityGroup 

func (s *SubnetListener) EnableSecurityGroup(inctx context.Context, in *protocol.SecurityGroupSubnetBindRequest) (empty *googleprotobuf.Empty, err error)

EnableSecurityGroup applies the rules of a bound security group on a network

func (*SubnetListener) Inspect 

func (s *SubnetListener) Inspect(inctx context.Context, in *protocol.SubnetInspectRequest) (_ *protocol.Subnet, err error)

Inspect returns infos on a subnet

func (*SubnetListener) List 

func (s *SubnetListener) List(inctx context.Context, in *protocol.SubnetListRequest) (_ *protocol.SubnetList, ferr error)

List existing networks

func (*SubnetListener) ListSecurityGroups 

func (s *SubnetListener) ListSecurityGroups(inctx context.Context, in *protocol.SecurityGroupSubnetBindRequest) (_ *protocol.SecurityGroupBondsResponse, err error)

ListSecurityGroups lists the Security Group bound to subnet

func (*SubnetListener) UnbindSecurityGroup 

func (s *SubnetListener) UnbindSecurityGroup(inctx context.Context, in *protocol.SecurityGroupSubnetBindRequest) (empty *googleprotobuf.Empty, err error)

UnbindSecurityGroup detaches a Security Group from a subnet

type TemplateListener 

type TemplateListener struct {
	protocol.UnimplementedTemplateServiceServer
}

TemplateListener host service server grpc

func (*TemplateListener) Inspect 

func (s *TemplateListener) Inspect(inctx context.Context, in *protocol.TemplateInspectRequest) (_ *protocol.HostTemplate, ferr error)

Inspect returns information about a tenant

func (*TemplateListener) List 

func (s *TemplateListener) List(inctx context.Context, in *protocol.TemplateListRequest) (_ *protocol.TemplateList, err error)

List available templates

func (*TemplateListener) Match 

func (s *TemplateListener) Match(inctx context.Context, in *protocol.TemplateMatchRequest) (tl *protocol.TemplateList, err error)

Match lists templates that match the sizing

type TenantListener 

type TenantListener struct {
	protocol.UnimplementedTenantServiceServer
}

TenantListener server is used to implement SafeScale.safescale.

func (*TenantListener) Get 

func (s *TenantListener) Get(inctx context.Context, in *googleprotobuf.Empty) (_ *protocol.TenantName, err error)

Get returns the name of the current tenant used

func (*TenantListener) Inspect 

func (s *TenantListener) Inspect(inctx context.Context, in *protocol.TenantName) (_ *protocol.TenantInspectResponse, ferr error)

Inspect returns information about a tenant

func (*TenantListener) List 

func (s *TenantListener) List(inctx context.Context, in *googleprotobuf.Empty) (_ *protocol.TenantList, err error)

List lists registered tenants

func (*TenantListener) Scan 

func (s *TenantListener) Scan(inctx context.Context, in *protocol.TenantScanRequest) (_ *protocol.ScanResultList, err error)

Scan proceeds a scan of host corresponding to each template to gather real data(metadata in particular)

func (*TenantListener) Set 

func (s *TenantListener) Set(inctx context.Context, in *protocol.TenantName) (empty *googleprotobuf.Empty, err error)

Set sets the tenant to use for each command

type VolumeListener 

type VolumeListener struct {
	protocol.UnimplementedVolumeServiceServer
}

VolumeListener is the volume service gRPC server

func (*VolumeListener) Attach 

func (s *VolumeListener) Attach(inctx context.Context, in *protocol.VolumeAttachmentRequest) (_ *googleprotobuf.Empty, err error)

Attach a volume to a host and create a mount point

func (*VolumeListener) Create 

func (s *VolumeListener) Create(inctx context.Context, in *protocol.VolumeCreateRequest) (_ *protocol.VolumeInspectResponse, err error)

Create a new volume

func (*VolumeListener) Delete 

func (s *VolumeListener) Delete(inctx context.Context, in *protocol.VolumeDeleteRequest) (empty *googleprotobuf.Empty, err error)

Delete a volume

func (*VolumeListener) Detach 

func (s *VolumeListener) Detach(inctx context.Context, in *protocol.VolumeDetachmentRequest) (empty *googleprotobuf.Empty, err error)

Detach a volume from a host. It umount associated mountpoint

func (*VolumeListener) Inspect 

func (s *VolumeListener) Inspect(inctx context.Context, in *protocol.Reference) (_ *protocol.VolumeInspectResponse, err error)

Inspect a volume

func (*VolumeListener) List 

func (s *VolumeListener) List(inctx context.Context, in *protocol.VolumeListRequest) (_ *protocol.VolumeListResponse, err 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.