v1beta1

package
v1.1.1 Latest Latest
Warning

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

 Go to latest Published: Mar 31, 2022 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterVolumeServer 

func RegisterVolumeServer(s *grpc.Server, srv VolumeServer)

Types

type DismountVolumeRequest 

type DismountVolumeRequest struct {
	// Volume device ID of the volume to dismount
	VolumeId string `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	// Path where the volume has been mounted.
	Path                 string   `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DismountVolumeRequest) Descriptor 

func (*DismountVolumeRequest) Descriptor() ([]byte, []int)

func (*DismountVolumeRequest) GetPath 

func (m *DismountVolumeRequest) GetPath() string

func (*DismountVolumeRequest) GetVolumeId 

func (m *DismountVolumeRequest) GetVolumeId() string

func (*DismountVolumeRequest) ProtoMessage 

func (*DismountVolumeRequest) ProtoMessage()

func (*DismountVolumeRequest) Reset 

func (m *DismountVolumeRequest) Reset()

func (*DismountVolumeRequest) String 

func (m *DismountVolumeRequest) String() string

func (*DismountVolumeRequest) XXX_DiscardUnknown 

func (m *DismountVolumeRequest) XXX_DiscardUnknown()

func (*DismountVolumeRequest) XXX_Marshal 

func (m *DismountVolumeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DismountVolumeRequest) XXX_Merge 

func (m *DismountVolumeRequest) XXX_Merge(src proto.Message)

func (*DismountVolumeRequest) XXX_Size 

func (m *DismountVolumeRequest) XXX_Size() int

func (*DismountVolumeRequest) XXX_Unmarshal 

func (m *DismountVolumeRequest) XXX_Unmarshal(b []byte) error

type DismountVolumeResponse 

type DismountVolumeResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DismountVolumeResponse) Descriptor 

func (*DismountVolumeResponse) Descriptor() ([]byte, []int)

func (*DismountVolumeResponse) ProtoMessage 

func (*DismountVolumeResponse) ProtoMessage()

func (*DismountVolumeResponse) Reset 

func (m *DismountVolumeResponse) Reset()

func (*DismountVolumeResponse) String 

func (m *DismountVolumeResponse) String() string

func (*DismountVolumeResponse) XXX_DiscardUnknown 

func (m *DismountVolumeResponse) XXX_DiscardUnknown()

func (*DismountVolumeResponse) XXX_Marshal 

func (m *DismountVolumeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DismountVolumeResponse) XXX_Merge 

func (m *DismountVolumeResponse) XXX_Merge(src proto.Message)

func (*DismountVolumeResponse) XXX_Size 

func (m *DismountVolumeResponse) XXX_Size() int

func (*DismountVolumeResponse) XXX_Unmarshal 

func (m *DismountVolumeResponse) XXX_Unmarshal(b []byte) error

type FormatVolumeRequest 

type FormatVolumeRequest struct {
	// Volume device ID of the volume to format
	VolumeId             string   `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FormatVolumeRequest) Descriptor 

func (*FormatVolumeRequest) Descriptor() ([]byte, []int)

func (*FormatVolumeRequest) GetVolumeId 

func (m *FormatVolumeRequest) GetVolumeId() string

func (*FormatVolumeRequest) ProtoMessage 

func (*FormatVolumeRequest) ProtoMessage()

func (*FormatVolumeRequest) Reset 

func (m *FormatVolumeRequest) Reset()

func (*FormatVolumeRequest) String 

func (m *FormatVolumeRequest) String() string

func (*FormatVolumeRequest) XXX_DiscardUnknown 

func (m *FormatVolumeRequest) XXX_DiscardUnknown()

func (*FormatVolumeRequest) XXX_Marshal 

func (m *FormatVolumeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FormatVolumeRequest) XXX_Merge 

func (m *FormatVolumeRequest) XXX_Merge(src proto.Message)

func (*FormatVolumeRequest) XXX_Size 

func (m *FormatVolumeRequest) XXX_Size() int

func (*FormatVolumeRequest) XXX_Unmarshal 

func (m *FormatVolumeRequest) XXX_Unmarshal(b []byte) error

type FormatVolumeResponse 

type FormatVolumeResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FormatVolumeResponse) Descriptor 

func (*FormatVolumeResponse) Descriptor() ([]byte, []int)

func (*FormatVolumeResponse) ProtoMessage 

func (*FormatVolumeResponse) ProtoMessage()

func (*FormatVolumeResponse) Reset 

func (m *FormatVolumeResponse) Reset()

func (*FormatVolumeResponse) String 

func (m *FormatVolumeResponse) String() string

func (*FormatVolumeResponse) XXX_DiscardUnknown 

func (m *FormatVolumeResponse) XXX_DiscardUnknown()

func (*FormatVolumeResponse) XXX_Marshal 

func (m *FormatVolumeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FormatVolumeResponse) XXX_Merge 

func (m *FormatVolumeResponse) XXX_Merge(src proto.Message)

func (*FormatVolumeResponse) XXX_Size 

func (m *FormatVolumeResponse) XXX_Size() int

func (*FormatVolumeResponse) XXX_Unmarshal 

func (m *FormatVolumeResponse) XXX_Unmarshal(b []byte) error

type IsVolumeFormattedRequest 

type IsVolumeFormattedRequest struct {
	// Volume device ID of the volume to check
	VolumeId             string   `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IsVolumeFormattedRequest) Descriptor 

func (*IsVolumeFormattedRequest) Descriptor() ([]byte, []int)

func (*IsVolumeFormattedRequest) GetVolumeId 

func (m *IsVolumeFormattedRequest) GetVolumeId() string

func (*IsVolumeFormattedRequest) ProtoMessage 

func (*IsVolumeFormattedRequest) ProtoMessage()

func (*IsVolumeFormattedRequest) Reset 

func (m *IsVolumeFormattedRequest) Reset()

func (*IsVolumeFormattedRequest) String 

func (m *IsVolumeFormattedRequest) String() string

func (*IsVolumeFormattedRequest) XXX_DiscardUnknown 

func (m *IsVolumeFormattedRequest) XXX_DiscardUnknown()

func (*IsVolumeFormattedRequest) XXX_Marshal 

func (m *IsVolumeFormattedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IsVolumeFormattedRequest) XXX_Merge 

func (m *IsVolumeFormattedRequest) XXX_Merge(src proto.Message)

func (*IsVolumeFormattedRequest) XXX_Size 

func (m *IsVolumeFormattedRequest) XXX_Size() int

func (*IsVolumeFormattedRequest) XXX_Unmarshal 

func (m *IsVolumeFormattedRequest) XXX_Unmarshal(b []byte) error

type IsVolumeFormattedResponse 

type IsVolumeFormattedResponse struct {
	// Is the volume formatted with NTFS
	Formatted            bool     `protobuf:"varint,1,opt,name=formatted,proto3" json:"formatted,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IsVolumeFormattedResponse) Descriptor 

func (*IsVolumeFormattedResponse) Descriptor() ([]byte, []int)

func (*IsVolumeFormattedResponse) GetFormatted 

func (m *IsVolumeFormattedResponse) GetFormatted() bool

func (*IsVolumeFormattedResponse) ProtoMessage 

func (*IsVolumeFormattedResponse) ProtoMessage()

func (*IsVolumeFormattedResponse) Reset 

func (m *IsVolumeFormattedResponse) Reset()

func (*IsVolumeFormattedResponse) String 

func (m *IsVolumeFormattedResponse) String() string

func (*IsVolumeFormattedResponse) XXX_DiscardUnknown 

func (m *IsVolumeFormattedResponse) XXX_DiscardUnknown()

func (*IsVolumeFormattedResponse) XXX_Marshal 

func (m *IsVolumeFormattedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IsVolumeFormattedResponse) XXX_Merge 

func (m *IsVolumeFormattedResponse) XXX_Merge(src proto.Message)

func (*IsVolumeFormattedResponse) XXX_Size 

func (m *IsVolumeFormattedResponse) XXX_Size() int

func (*IsVolumeFormattedResponse) XXX_Unmarshal 

func (m *IsVolumeFormattedResponse) XXX_Unmarshal(b []byte) error

type ListVolumesOnDiskRequest 

type ListVolumesOnDiskRequest struct {
	// Disk device ID of the disk to query for volumes
	DiskId               string   `protobuf:"bytes,1,opt,name=disk_id,json=diskId,proto3" json:"disk_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListVolumesOnDiskRequest) Descriptor 

func (*ListVolumesOnDiskRequest) Descriptor() ([]byte, []int)

func (*ListVolumesOnDiskRequest) GetDiskId 

func (m *ListVolumesOnDiskRequest) GetDiskId() string

func (*ListVolumesOnDiskRequest) ProtoMessage 

func (*ListVolumesOnDiskRequest) ProtoMessage()

func (*ListVolumesOnDiskRequest) Reset 

func (m *ListVolumesOnDiskRequest) Reset()

func (*ListVolumesOnDiskRequest) String 

func (m *ListVolumesOnDiskRequest) String() string

func (*ListVolumesOnDiskRequest) XXX_DiscardUnknown 

func (m *ListVolumesOnDiskRequest) XXX_DiscardUnknown()

func (*ListVolumesOnDiskRequest) XXX_Marshal 

func (m *ListVolumesOnDiskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListVolumesOnDiskRequest) XXX_Merge 

func (m *ListVolumesOnDiskRequest) XXX_Merge(src proto.Message)

func (*ListVolumesOnDiskRequest) XXX_Size 

func (m *ListVolumesOnDiskRequest) XXX_Size() int

func (*ListVolumesOnDiskRequest) XXX_Unmarshal 

func (m *ListVolumesOnDiskRequest) XXX_Unmarshal(b []byte) error

type ListVolumesOnDiskResponse 

type ListVolumesOnDiskResponse struct {
	// Volume device IDs of volumes on the specified disk
	VolumeIds            []string `protobuf:"bytes,1,rep,name=volume_ids,json=volumeIds,proto3" json:"volume_ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListVolumesOnDiskResponse) Descriptor 

func (*ListVolumesOnDiskResponse) Descriptor() ([]byte, []int)

func (*ListVolumesOnDiskResponse) GetVolumeIds 

func (m *ListVolumesOnDiskResponse) GetVolumeIds() []string

func (*ListVolumesOnDiskResponse) ProtoMessage 

func (*ListVolumesOnDiskResponse) ProtoMessage()

func (*ListVolumesOnDiskResponse) Reset 

func (m *ListVolumesOnDiskResponse) Reset()

func (*ListVolumesOnDiskResponse) String 

func (m *ListVolumesOnDiskResponse) String() string

func (*ListVolumesOnDiskResponse) XXX_DiscardUnknown 

func (m *ListVolumesOnDiskResponse) XXX_DiscardUnknown()

func (*ListVolumesOnDiskResponse) XXX_Marshal 

func (m *ListVolumesOnDiskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListVolumesOnDiskResponse) XXX_Merge 

func (m *ListVolumesOnDiskResponse) XXX_Merge(src proto.Message)

func (*ListVolumesOnDiskResponse) XXX_Size 

func (m *ListVolumesOnDiskResponse) XXX_Size() int

func (*ListVolumesOnDiskResponse) XXX_Unmarshal 

func (m *ListVolumesOnDiskResponse) XXX_Unmarshal(b []byte) error

type MountVolumeRequest 

type MountVolumeRequest struct {
	// Volume device ID of the volume to mount
	VolumeId string `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	// Path in the host's file system where the volume needs to be mounted
	Path                 string   `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MountVolumeRequest) Descriptor 

func (*MountVolumeRequest) Descriptor() ([]byte, []int)

func (*MountVolumeRequest) GetPath 

func (m *MountVolumeRequest) GetPath() string

func (*MountVolumeRequest) GetVolumeId 

func (m *MountVolumeRequest) GetVolumeId() string

func (*MountVolumeRequest) ProtoMessage 

func (*MountVolumeRequest) ProtoMessage()

func (*MountVolumeRequest) Reset 

func (m *MountVolumeRequest) Reset()

func (*MountVolumeRequest) String 

func (m *MountVolumeRequest) String() string

func (*MountVolumeRequest) XXX_DiscardUnknown 

func (m *MountVolumeRequest) XXX_DiscardUnknown()

func (*MountVolumeRequest) XXX_Marshal 

func (m *MountVolumeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MountVolumeRequest) XXX_Merge 

func (m *MountVolumeRequest) XXX_Merge(src proto.Message)

func (*MountVolumeRequest) XXX_Size 

func (m *MountVolumeRequest) XXX_Size() int

func (*MountVolumeRequest) XXX_Unmarshal 

func (m *MountVolumeRequest) XXX_Unmarshal(b []byte) error

type MountVolumeResponse 

type MountVolumeResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MountVolumeResponse) Descriptor 

func (*MountVolumeResponse) Descriptor() ([]byte, []int)

func (*MountVolumeResponse) ProtoMessage 

func (*MountVolumeResponse) ProtoMessage()

func (*MountVolumeResponse) Reset 

func (m *MountVolumeResponse) Reset()

func (*MountVolumeResponse) String 

func (m *MountVolumeResponse) String() string

func (*MountVolumeResponse) XXX_DiscardUnknown 

func (m *MountVolumeResponse) XXX_DiscardUnknown()

func (*MountVolumeResponse) XXX_Marshal 

func (m *MountVolumeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MountVolumeResponse) XXX_Merge 

func (m *MountVolumeResponse) XXX_Merge(src proto.Message)

func (*MountVolumeResponse) XXX_Size 

func (m *MountVolumeResponse) XXX_Size() int

func (*MountVolumeResponse) XXX_Unmarshal 

func (m *MountVolumeResponse) XXX_Unmarshal(b []byte) error

type ResizeVolumeRequest 

type ResizeVolumeRequest struct {
	// Volume device ID of the volume to dismount
	VolumeId string `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	// New size of the volume
	Size                 int64    `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResizeVolumeRequest) Descriptor 

func (*ResizeVolumeRequest) Descriptor() ([]byte, []int)

func (*ResizeVolumeRequest) GetSize 

func (m *ResizeVolumeRequest) GetSize() int64

func (*ResizeVolumeRequest) GetVolumeId 

func (m *ResizeVolumeRequest) GetVolumeId() string

func (*ResizeVolumeRequest) ProtoMessage 

func (*ResizeVolumeRequest) ProtoMessage()

func (*ResizeVolumeRequest) Reset 

func (m *ResizeVolumeRequest) Reset()

func (*ResizeVolumeRequest) String 

func (m *ResizeVolumeRequest) String() string

func (*ResizeVolumeRequest) XXX_DiscardUnknown 

func (m *ResizeVolumeRequest) XXX_DiscardUnknown()

func (*ResizeVolumeRequest) XXX_Marshal 

func (m *ResizeVolumeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResizeVolumeRequest) XXX_Merge 

func (m *ResizeVolumeRequest) XXX_Merge(src proto.Message)

func (*ResizeVolumeRequest) XXX_Size 

func (m *ResizeVolumeRequest) XXX_Size() int

func (*ResizeVolumeRequest) XXX_Unmarshal 

func (m *ResizeVolumeRequest) XXX_Unmarshal(b []byte) error

type ResizeVolumeResponse 

type ResizeVolumeResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResizeVolumeResponse) Descriptor 

func (*ResizeVolumeResponse) Descriptor() ([]byte, []int)

func (*ResizeVolumeResponse) ProtoMessage 

func (*ResizeVolumeResponse) ProtoMessage()

func (*ResizeVolumeResponse) Reset 

func (m *ResizeVolumeResponse) Reset()

func (*ResizeVolumeResponse) String 

func (m *ResizeVolumeResponse) String() string

func (*ResizeVolumeResponse) XXX_DiscardUnknown 

func (m *ResizeVolumeResponse) XXX_DiscardUnknown()

func (*ResizeVolumeResponse) XXX_Marshal 

func (m *ResizeVolumeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResizeVolumeResponse) XXX_Merge 

func (m *ResizeVolumeResponse) XXX_Merge(src proto.Message)

func (*ResizeVolumeResponse) XXX_Size 

func (m *ResizeVolumeResponse) XXX_Size() int

func (*ResizeVolumeResponse) XXX_Unmarshal 

func (m *ResizeVolumeResponse) XXX_Unmarshal(b []byte) error

type UnimplementedVolumeServer 

type UnimplementedVolumeServer struct {
}

UnimplementedVolumeServer can be embedded to have forward compatible implementations.

func (*UnimplementedVolumeServer) DismountVolume 

func (*UnimplementedVolumeServer) DismountVolume(ctx context.Context, req *DismountVolumeRequest) (*DismountVolumeResponse, error)

func (*UnimplementedVolumeServer) FormatVolume 

func (*UnimplementedVolumeServer) FormatVolume(ctx context.Context, req *FormatVolumeRequest) (*FormatVolumeResponse, error)

func (*UnimplementedVolumeServer) GetVolumeDiskNumber 

func (*UnimplementedVolumeServer) GetVolumeDiskNumber(ctx context.Context, req *VolumeDiskNumberRequest) (*VolumeDiskNumberResponse, error)

func (*UnimplementedVolumeServer) GetVolumeIDFromMount 

func (*UnimplementedVolumeServer) GetVolumeIDFromMount(ctx context.Context, req *VolumeIDFromMountRequest) (*VolumeIDFromMountResponse, error)

func (*UnimplementedVolumeServer) IsVolumeFormatted 

func (*UnimplementedVolumeServer) IsVolumeFormatted(ctx context.Context, req *IsVolumeFormattedRequest) (*IsVolumeFormattedResponse, error)

func (*UnimplementedVolumeServer) ListVolumesOnDisk 

func (*UnimplementedVolumeServer) ListVolumesOnDisk(ctx context.Context, req *ListVolumesOnDiskRequest) (*ListVolumesOnDiskResponse, error)

func (*UnimplementedVolumeServer) MountVolume 

func (*UnimplementedVolumeServer) MountVolume(ctx context.Context, req *MountVolumeRequest) (*MountVolumeResponse, error)

func (*UnimplementedVolumeServer) ResizeVolume 

func (*UnimplementedVolumeServer) ResizeVolume(ctx context.Context, req *ResizeVolumeRequest) (*ResizeVolumeResponse, error)

func (*UnimplementedVolumeServer) VolumeStats 

func (*UnimplementedVolumeServer) VolumeStats(ctx context.Context, req *VolumeStatsRequest) (*VolumeStatsResponse, error)

type VolumeClient 

type VolumeClient interface {
	// ListVolumesOnDisk returns the volume IDs (in \\.\Volume{GUID} format) for
	// all volumes on a Disk device
	ListVolumesOnDisk(ctx context.Context, in *ListVolumesOnDiskRequest, opts ...grpc.CallOption) (*ListVolumesOnDiskResponse, error)
	// MountVolume mounts the volume at the requested global staging path
	MountVolume(ctx context.Context, in *MountVolumeRequest, opts ...grpc.CallOption) (*MountVolumeResponse, error)
	// DismountVolume gracefully dismounts a volume
	DismountVolume(ctx context.Context, in *DismountVolumeRequest, opts ...grpc.CallOption) (*DismountVolumeResponse, error)
	// IsVolumeFormatted checks if a volume is formatted with NTFS
	IsVolumeFormatted(ctx context.Context, in *IsVolumeFormattedRequest, opts ...grpc.CallOption) (*IsVolumeFormattedResponse, error)
	// FormatVolume formats a volume with the provided file system
	FormatVolume(ctx context.Context, in *FormatVolumeRequest, opts ...grpc.CallOption) (*FormatVolumeResponse, error)
	// ResizeVolume performs resizing of the partition and file system for a block based volume
	ResizeVolume(ctx context.Context, in *ResizeVolumeRequest, opts ...grpc.CallOption) (*ResizeVolumeResponse, error)
	// VolumeStats gathers DiskSize, VolumeSize and VolumeUsedSize for a volume
	VolumeStats(ctx context.Context, in *VolumeStatsRequest, opts ...grpc.CallOption) (*VolumeStatsResponse, error)
	// GetVolumeDiskNumber gets the disk number of the disk where the volume is located
	GetVolumeDiskNumber(ctx context.Context, in *VolumeDiskNumberRequest, opts ...grpc.CallOption) (*VolumeDiskNumberResponse, error)
	// GetVolumeIDFromMount gets the volume id for a given mount
	GetVolumeIDFromMount(ctx context.Context, in *VolumeIDFromMountRequest, opts ...grpc.CallOption) (*VolumeIDFromMountResponse, error)
}

VolumeClient is the client API for Volume service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewVolumeClient 

func NewVolumeClient(cc *grpc.ClientConn) VolumeClient

type VolumeDiskNumberRequest 

type VolumeDiskNumberRequest struct {
	// Volume device Id of the volume to get the disk number for
	VolumeId             string   `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VolumeDiskNumberRequest) Descriptor 

func (*VolumeDiskNumberRequest) Descriptor() ([]byte, []int)

func (*VolumeDiskNumberRequest) GetVolumeId 

func (m *VolumeDiskNumberRequest) GetVolumeId() string

func (*VolumeDiskNumberRequest) ProtoMessage 

func (*VolumeDiskNumberRequest) ProtoMessage()

func (*VolumeDiskNumberRequest) Reset 

func (m *VolumeDiskNumberRequest) Reset()

func (*VolumeDiskNumberRequest) String 

func (m *VolumeDiskNumberRequest) String() string

func (*VolumeDiskNumberRequest) XXX_DiscardUnknown 

func (m *VolumeDiskNumberRequest) XXX_DiscardUnknown()

func (*VolumeDiskNumberRequest) XXX_Marshal 

func (m *VolumeDiskNumberRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VolumeDiskNumberRequest) XXX_Merge 

func (m *VolumeDiskNumberRequest) XXX_Merge(src proto.Message)

func (*VolumeDiskNumberRequest) XXX_Size 

func (m *VolumeDiskNumberRequest) XXX_Size() int

func (*VolumeDiskNumberRequest) XXX_Unmarshal 

func (m *VolumeDiskNumberRequest) XXX_Unmarshal(b []byte) error

type VolumeDiskNumberResponse 

type VolumeDiskNumberResponse struct {
	// Corresponding disk number
	DiskNumber           int64    `protobuf:"varint,1,opt,name=diskNumber,proto3" json:"diskNumber,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VolumeDiskNumberResponse) Descriptor 

func (*VolumeDiskNumberResponse) Descriptor() ([]byte, []int)

func (*VolumeDiskNumberResponse) GetDiskNumber 

func (m *VolumeDiskNumberResponse) GetDiskNumber() int64

func (*VolumeDiskNumberResponse) ProtoMessage 

func (*VolumeDiskNumberResponse) ProtoMessage()

func (*VolumeDiskNumberResponse) Reset 

func (m *VolumeDiskNumberResponse) Reset()

func (*VolumeDiskNumberResponse) String 

func (m *VolumeDiskNumberResponse) String() string

func (*VolumeDiskNumberResponse) XXX_DiscardUnknown 

func (m *VolumeDiskNumberResponse) XXX_DiscardUnknown()

func (*VolumeDiskNumberResponse) XXX_Marshal 

func (m *VolumeDiskNumberResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VolumeDiskNumberResponse) XXX_Merge 

func (m *VolumeDiskNumberResponse) XXX_Merge(src proto.Message)

func (*VolumeDiskNumberResponse) XXX_Size 

func (m *VolumeDiskNumberResponse) XXX_Size() int

func (*VolumeDiskNumberResponse) XXX_Unmarshal 

func (m *VolumeDiskNumberResponse) XXX_Unmarshal(b []byte) error

type VolumeIDFromMountRequest 

type VolumeIDFromMountRequest struct {
	// Mount
	Mount                string   `protobuf:"bytes,1,opt,name=mount,proto3" json:"mount,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VolumeIDFromMountRequest) Descriptor 

func (*VolumeIDFromMountRequest) Descriptor() ([]byte, []int)

func (*VolumeIDFromMountRequest) GetMount 

func (m *VolumeIDFromMountRequest) GetMount() string

func (*VolumeIDFromMountRequest) ProtoMessage 

func (*VolumeIDFromMountRequest) ProtoMessage()

func (*VolumeIDFromMountRequest) Reset 

func (m *VolumeIDFromMountRequest) Reset()

func (*VolumeIDFromMountRequest) String 

func (m *VolumeIDFromMountRequest) String() string

func (*VolumeIDFromMountRequest) XXX_DiscardUnknown 

func (m *VolumeIDFromMountRequest) XXX_DiscardUnknown()

func (*VolumeIDFromMountRequest) XXX_Marshal 

func (m *VolumeIDFromMountRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VolumeIDFromMountRequest) XXX_Merge 

func (m *VolumeIDFromMountRequest) XXX_Merge(src proto.Message)

func (*VolumeIDFromMountRequest) XXX_Size 

func (m *VolumeIDFromMountRequest) XXX_Size() int

func (*VolumeIDFromMountRequest) XXX_Unmarshal 

func (m *VolumeIDFromMountRequest) XXX_Unmarshal(b []byte) error

type VolumeIDFromMountResponse 

type VolumeIDFromMountResponse struct {
	// Mount
	VolumeId             string   `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VolumeIDFromMountResponse) Descriptor 

func (*VolumeIDFromMountResponse) Descriptor() ([]byte, []int)

func (*VolumeIDFromMountResponse) GetVolumeId 

func (m *VolumeIDFromMountResponse) GetVolumeId() string

func (*VolumeIDFromMountResponse) ProtoMessage 

func (*VolumeIDFromMountResponse) ProtoMessage()

func (*VolumeIDFromMountResponse) Reset 

func (m *VolumeIDFromMountResponse) Reset()

func (*VolumeIDFromMountResponse) String 

func (m *VolumeIDFromMountResponse) String() string

func (*VolumeIDFromMountResponse) XXX_DiscardUnknown 

func (m *VolumeIDFromMountResponse) XXX_DiscardUnknown()

func (*VolumeIDFromMountResponse) XXX_Marshal 

func (m *VolumeIDFromMountResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VolumeIDFromMountResponse) XXX_Merge 

func (m *VolumeIDFromMountResponse) XXX_Merge(src proto.Message)

func (*VolumeIDFromMountResponse) XXX_Size 

func (m *VolumeIDFromMountResponse) XXX_Size() int

func (*VolumeIDFromMountResponse) XXX_Unmarshal 

func (m *VolumeIDFromMountResponse) XXX_Unmarshal(b []byte) error

type VolumeServer 

type VolumeServer interface {
	// ListVolumesOnDisk returns the volume IDs (in \\.\Volume{GUID} format) for
	// all volumes on a Disk device
	ListVolumesOnDisk(context.Context, *ListVolumesOnDiskRequest) (*ListVolumesOnDiskResponse, error)
	// MountVolume mounts the volume at the requested global staging path
	MountVolume(context.Context, *MountVolumeRequest) (*MountVolumeResponse, error)
	// DismountVolume gracefully dismounts a volume
	DismountVolume(context.Context, *DismountVolumeRequest) (*DismountVolumeResponse, error)
	// IsVolumeFormatted checks if a volume is formatted with NTFS
	IsVolumeFormatted(context.Context, *IsVolumeFormattedRequest) (*IsVolumeFormattedResponse, error)
	// FormatVolume formats a volume with the provided file system
	FormatVolume(context.Context, *FormatVolumeRequest) (*FormatVolumeResponse, error)
	// ResizeVolume performs resizing of the partition and file system for a block based volume
	ResizeVolume(context.Context, *ResizeVolumeRequest) (*ResizeVolumeResponse, error)
	// VolumeStats gathers DiskSize, VolumeSize and VolumeUsedSize for a volume
	VolumeStats(context.Context, *VolumeStatsRequest) (*VolumeStatsResponse, error)
	// GetVolumeDiskNumber gets the disk number of the disk where the volume is located
	GetVolumeDiskNumber(context.Context, *VolumeDiskNumberRequest) (*VolumeDiskNumberResponse, error)
	// GetVolumeIDFromMount gets the volume id for a given mount
	GetVolumeIDFromMount(context.Context, *VolumeIDFromMountRequest) (*VolumeIDFromMountResponse, error)
}

VolumeServer is the server API for Volume service.

type VolumeStatsRequest 

type VolumeStatsRequest struct {
	// Volume device Id of the volume to get the stats for
	VolumeId             string   `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VolumeStatsRequest) Descriptor 

func (*VolumeStatsRequest) Descriptor() ([]byte, []int)

func (*VolumeStatsRequest) GetVolumeId 

func (m *VolumeStatsRequest) GetVolumeId() string

func (*VolumeStatsRequest) ProtoMessage 

func (*VolumeStatsRequest) ProtoMessage()

func (*VolumeStatsRequest) Reset 

func (m *VolumeStatsRequest) Reset()

func (*VolumeStatsRequest) String 

func (m *VolumeStatsRequest) String() string

func (*VolumeStatsRequest) XXX_DiscardUnknown 

func (m *VolumeStatsRequest) XXX_DiscardUnknown()

func (*VolumeStatsRequest) XXX_Marshal 

func (m *VolumeStatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VolumeStatsRequest) XXX_Merge 

func (m *VolumeStatsRequest) XXX_Merge(src proto.Message)

func (*VolumeStatsRequest) XXX_Size 

func (m *VolumeStatsRequest) XXX_Size() int

func (*VolumeStatsRequest) XXX_Unmarshal 

func (m *VolumeStatsRequest) XXX_Unmarshal(b []byte) error

type VolumeStatsResponse 

type VolumeStatsResponse struct {
	// Capacity of the volume
	VolumeSize int64 `protobuf:"varint,1,opt,name=volumeSize,proto3" json:"volumeSize,omitempty"`
	// Used bytes
	VolumeUsedSize       int64    `protobuf:"varint,2,opt,name=volumeUsedSize,proto3" json:"volumeUsedSize,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VolumeStatsResponse) Descriptor 

func (*VolumeStatsResponse) Descriptor() ([]byte, []int)

func (*VolumeStatsResponse) GetVolumeSize 

func (m *VolumeStatsResponse) GetVolumeSize() int64

func (*VolumeStatsResponse) GetVolumeUsedSize 

func (m *VolumeStatsResponse) GetVolumeUsedSize() int64

func (*VolumeStatsResponse) ProtoMessage 

func (*VolumeStatsResponse) ProtoMessage()

func (*VolumeStatsResponse) Reset 

func (m *VolumeStatsResponse) Reset()

func (*VolumeStatsResponse) String 

func (m *VolumeStatsResponse) String() string

func (*VolumeStatsResponse) XXX_DiscardUnknown 

func (m *VolumeStatsResponse) XXX_DiscardUnknown()

func (*VolumeStatsResponse) XXX_Marshal 

func (m *VolumeStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VolumeStatsResponse) XXX_Merge 

func (m *VolumeStatsResponse) XXX_Merge(src proto.Message)

func (*VolumeStatsResponse) XXX_Size 

func (m *VolumeStatsResponse) XXX_Size() int

func (*VolumeStatsResponse) XXX_Unmarshal 

func (m *VolumeStatsResponse) XXX_Unmarshal(b []byte) error

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.