proto

package
v1.2.3 Latest Latest
Warning

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

 Go to latest Published: Aug 25, 2022 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	TaskStatus_name = map[int32]string{
		0: "PENDING",
		1: "RUNNING",
		2: "SUCCESS",
		3: "FAILED",
		4: "CANCELING",
		5: "CANCELED",
		9: "UNKNOWN",
	}
	TaskStatus_value = map[string]int32{
		"PENDING":   0,
		"RUNNING":   1,
		"SUCCESS":   2,
		"FAILED":    3,
		"CANCELING": 4,
		"CANCELED":  5,
		"UNKNOWN":   9,
	}
)

Enum value maps for TaskStatus.

View Source 
var (
	BlkioKey_name = map[int32]string{
		0: "IOPS_READ",
		1: "IOPS_WRITE",
		2: "BPS_READ",
		3: "BPS_WRITE",
	}
	BlkioKey_value = map[string]int32{
		"IOPS_READ":  0,
		"IOPS_WRITE": 1,
		"BPS_READ":   2,
		"BPS_WRITE":  3,
	}
)

Enum value maps for BlkioKey.

View Source 
var (
	Status_StatusCode_name = map[int32]string{
		0: "OK",
		1: "INVALID",
		2: "PERMISSION_DENIED",
		3: "EXISTS",
		4: "NOT_EXIST",
		5: "NETWORK",
		6: "UNKNOWN",
	}
	Status_StatusCode_value = map[string]int32{
		"OK":                0,
		"INVALID":           1,
		"PERMISSION_DENIED": 2,
		"EXISTS":            3,
		"NOT_EXIST":         4,
		"NETWORK":           5,
		"UNKNOWN":           6,
	}
)

Enum value maps for Status_StatusCode.

View Source 
var File_hpfs_proto protoreflect.FileDescriptor

Functions

func RegisterHpfsServiceServer 

func RegisterHpfsServiceServer(s *grpc.Server, srv HpfsServiceServer)

Types

type AsyncTask 

type AsyncTask struct {

	// Trace id for task.
	TraceId string `protobuf:"bytes,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	// contains filtered or unexported fields
}

func (*AsyncTask) Descriptor deprecated 

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

Deprecated: Use AsyncTask.ProtoReflect.Descriptor instead.

func (*AsyncTask) GetTraceId 

func (x *AsyncTask) GetTraceId() string

func (*AsyncTask) ProtoMessage 

func (*AsyncTask) ProtoMessage()

func (*AsyncTask) ProtoReflect 

func (x *AsyncTask) ProtoReflect() protoreflect.Message

func (*AsyncTask) Reset 

func (x *AsyncTask) Reset()

func (*AsyncTask) String 

func (x *AsyncTask) String() string

type AsyncTaskRequest 

type AsyncTaskRequest struct {

	// Trace id for task.
	TraceId string `protobuf:"bytes,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	// contains filtered or unexported fields
}

func (*AsyncTaskRequest) Descriptor deprecated 

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

Deprecated: Use AsyncTaskRequest.ProtoReflect.Descriptor instead.

func (*AsyncTaskRequest) GetTraceId 

func (x *AsyncTaskRequest) GetTraceId() string

func (*AsyncTaskRequest) ProtoMessage 

func (*AsyncTaskRequest) ProtoMessage()

func (*AsyncTaskRequest) ProtoReflect 

func (x *AsyncTaskRequest) ProtoReflect() protoreflect.Message

func (*AsyncTaskRequest) Reset 

func (x *AsyncTaskRequest) Reset()

func (*AsyncTaskRequest) String 

func (x *AsyncTaskRequest) String() string

type BlkioCtrl 

type BlkioCtrl struct {

	// Control key.
	Key BlkioKey `protobuf:"varint,1,opt,name=key,proto3,enum=proto.BlkioKey" json:"key,omitempty"`
	// Control value.
	Value int64 `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	// Target device.
	//
	// Types that are assignable to Device:
	//	*BlkioCtrl_Path
	//	*BlkioCtrl_DeviceName
	//	*BlkioCtrl_MajorMinor
	Device isBlkioCtrl_Device `protobuf_oneof:"device"`
	// contains filtered or unexported fields
}

func (*BlkioCtrl) Descriptor deprecated 

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

Deprecated: Use BlkioCtrl.ProtoReflect.Descriptor instead.

func (*BlkioCtrl) GetDevice 

func (m *BlkioCtrl) GetDevice() isBlkioCtrl_Device

func (*BlkioCtrl) GetDeviceName 

func (x *BlkioCtrl) GetDeviceName() string

func (*BlkioCtrl) GetKey 

func (x *BlkioCtrl) GetKey() BlkioKey

func (*BlkioCtrl) GetMajorMinor 

func (x *BlkioCtrl) GetMajorMinor() string

func (*BlkioCtrl) GetPath 

func (x *BlkioCtrl) GetPath() string

func (*BlkioCtrl) GetValue 

func (x *BlkioCtrl) GetValue() int64

func (*BlkioCtrl) ProtoMessage 

func (*BlkioCtrl) ProtoMessage()

func (*BlkioCtrl) ProtoReflect 

func (x *BlkioCtrl) ProtoReflect() protoreflect.Message

func (*BlkioCtrl) Reset 

func (x *BlkioCtrl) Reset()

func (*BlkioCtrl) String 

func (x *BlkioCtrl) String() string

type BlkioCtrl_DeviceName 

type BlkioCtrl_DeviceName struct {
	// Device name.
	DeviceName string `protobuf:"bytes,4,opt,name=device_name,json=deviceName,proto3,oneof"`
}

type BlkioCtrl_MajorMinor 

type BlkioCtrl_MajorMinor struct {
	// Device's "major-minor" number of Linux.
	MajorMinor string `protobuf:"bytes,5,opt,name=major_minor,json=majorMinor,proto3,oneof"`
}

type BlkioCtrl_Path 

type BlkioCtrl_Path struct {
	// Mounted path of the device (sub-path supported)
	Path string `protobuf:"bytes,3,opt,name=path,proto3,oneof"`
}

type BlkioKey 

type BlkioKey int32
const (
	// IOPS (IO per second) read.
	BlkioKey_IOPS_READ BlkioKey = 0
	// IOPS (IO per second) write.
	BlkioKey_IOPS_WRITE BlkioKey = 1
	// BPS (bytes per second) read.
	BlkioKey_BPS_READ BlkioKey = 2
	// BPS (bytes per second) write.
	BlkioKey_BPS_WRITE BlkioKey = 3
)

func (BlkioKey) Descriptor 

func (BlkioKey) Descriptor() protoreflect.EnumDescriptor

func (BlkioKey) Enum 

func (x BlkioKey) Enum() *BlkioKey

func (BlkioKey) EnumDescriptor deprecated 

func (BlkioKey) EnumDescriptor() ([]byte, []int)

Deprecated: Use BlkioKey.Descriptor instead.

func (BlkioKey) Number 

func (x BlkioKey) Number() protoreflect.EnumNumber

func (BlkioKey) String 

func (x BlkioKey) String() string

func (BlkioKey) Type 

func (BlkioKey) Type() protoreflect.EnumType

type CancelAsyncTaskRequest 

type CancelAsyncTaskRequest struct {

	// Destination host.
	Host *Host `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// Async task.
	Task *AsyncTask `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelAsyncTaskRequest) Descriptor deprecated 

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

Deprecated: Use CancelAsyncTaskRequest.ProtoReflect.Descriptor instead.

func (*CancelAsyncTaskRequest) GetHost 

func (x *CancelAsyncTaskRequest) GetHost() *Host

func (*CancelAsyncTaskRequest) GetTask 

func (x *CancelAsyncTaskRequest) GetTask() *AsyncTask

func (*CancelAsyncTaskRequest) ProtoMessage 

func (*CancelAsyncTaskRequest) ProtoMessage()

func (*CancelAsyncTaskRequest) ProtoReflect 

func (x *CancelAsyncTaskRequest) ProtoReflect() protoreflect.Message

func (*CancelAsyncTaskRequest) Reset 

func (x *CancelAsyncTaskRequest) Reset()

func (*CancelAsyncTaskRequest) String 

func (x *CancelAsyncTaskRequest) String() string

type CancelAsyncTaskResponse 

type CancelAsyncTaskResponse struct {

	// Operation status
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelAsyncTaskResponse) Descriptor deprecated 

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

Deprecated: Use CancelAsyncTaskResponse.ProtoReflect.Descriptor instead.

func (*CancelAsyncTaskResponse) GetStatus 

func (x *CancelAsyncTaskResponse) GetStatus() *Status

func (*CancelAsyncTaskResponse) ProtoMessage 

func (*CancelAsyncTaskResponse) ProtoMessage()

func (*CancelAsyncTaskResponse) ProtoReflect 

func (x *CancelAsyncTaskResponse) ProtoReflect() protoreflect.Message

func (*CancelAsyncTaskResponse) Reset 

func (x *CancelAsyncTaskResponse) Reset()

func (*CancelAsyncTaskResponse) String 

func (x *CancelAsyncTaskResponse) String() string

type ControlCgroupsBlkioRequest 

type ControlCgroupsBlkioRequest struct {

	// Target host.
	Host *Host `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// Pod UID, use
	PodUid string `protobuf:"bytes,2,opt,name=pod_uid,json=podUid,proto3" json:"pod_uid,omitempty"`
	// Blkio controls.
	Controls []*BlkioCtrl `protobuf:"bytes,3,rep,name=controls,proto3" json:"controls,omitempty"`
	// contains filtered or unexported fields
}

func (*ControlCgroupsBlkioRequest) Descriptor deprecated 

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

Deprecated: Use ControlCgroupsBlkioRequest.ProtoReflect.Descriptor instead.

func (*ControlCgroupsBlkioRequest) GetControls 

func (x *ControlCgroupsBlkioRequest) GetControls() []*BlkioCtrl

func (*ControlCgroupsBlkioRequest) GetHost 

func (x *ControlCgroupsBlkioRequest) GetHost() *Host

func (*ControlCgroupsBlkioRequest) GetPodUid 

func (x *ControlCgroupsBlkioRequest) GetPodUid() string

func (*ControlCgroupsBlkioRequest) ProtoMessage 

func (*ControlCgroupsBlkioRequest) ProtoMessage()

func (*ControlCgroupsBlkioRequest) ProtoReflect 

func (x *ControlCgroupsBlkioRequest) ProtoReflect() protoreflect.Message

func (*ControlCgroupsBlkioRequest) Reset 

func (x *ControlCgroupsBlkioRequest) Reset()

func (*ControlCgroupsBlkioRequest) String 

func (x *ControlCgroupsBlkioRequest) String() string

type ControlCgroupsBlkioResponse 

type ControlCgroupsBlkioResponse struct {

	// Operation status.
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ControlCgroupsBlkioResponse) Descriptor deprecated 

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

Deprecated: Use ControlCgroupsBlkioResponse.ProtoReflect.Descriptor instead.

func (*ControlCgroupsBlkioResponse) GetStatus 

func (x *ControlCgroupsBlkioResponse) GetStatus() *Status

func (*ControlCgroupsBlkioResponse) ProtoMessage 

func (*ControlCgroupsBlkioResponse) ProtoMessage()

func (*ControlCgroupsBlkioResponse) ProtoReflect 

func (x *ControlCgroupsBlkioResponse) ProtoReflect() protoreflect.Message

func (*ControlCgroupsBlkioResponse) Reset 

func (x *ControlCgroupsBlkioResponse) Reset()

func (*ControlCgroupsBlkioResponse) String 

func (x *ControlCgroupsBlkioResponse) String() string

type CreateDirectoryOptions 

type CreateDirectoryOptions struct {

	// Ignore the create if exists. If not true, an error will be returned.
	IgnoreIfExists bool `protobuf:"varint,1,opt,name=ignore_if_exists,json=ignoreIfExists,proto3" json:"ignore_if_exists,omitempty"`
	// Create all parent directories if necessary.
	CreateParentDirectories bool `` /* 133-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateDirectoryOptions) Descriptor deprecated 

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

Deprecated: Use CreateDirectoryOptions.ProtoReflect.Descriptor instead.

func (*CreateDirectoryOptions) GetCreateParentDirectories 

func (x *CreateDirectoryOptions) GetCreateParentDirectories() bool

func (*CreateDirectoryOptions) GetIgnoreIfExists 

func (x *CreateDirectoryOptions) GetIgnoreIfExists() bool

func (*CreateDirectoryOptions) ProtoMessage 

func (*CreateDirectoryOptions) ProtoMessage()

func (*CreateDirectoryOptions) ProtoReflect 

func (x *CreateDirectoryOptions) ProtoReflect() protoreflect.Message

func (*CreateDirectoryOptions) Reset 

func (x *CreateDirectoryOptions) Reset()

func (*CreateDirectoryOptions) String 

func (x *CreateDirectoryOptions) String() string

type CreateDirectoryRequest 

type CreateDirectoryRequest struct {

	// Target host.
	Host *Host `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// Create options.
	Options *CreateDirectoryOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// Directory to create.
	Directory *FileRequest `protobuf:"bytes,3,opt,name=directory,proto3" json:"directory,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateDirectoryRequest) Descriptor deprecated 

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

Deprecated: Use CreateDirectoryRequest.ProtoReflect.Descriptor instead.

func (*CreateDirectoryRequest) GetDirectory 

func (x *CreateDirectoryRequest) GetDirectory() *FileRequest

func (*CreateDirectoryRequest) GetHost 

func (x *CreateDirectoryRequest) GetHost() *Host

func (*CreateDirectoryRequest) GetOptions 

func (x *CreateDirectoryRequest) GetOptions() *CreateDirectoryOptions

func (*CreateDirectoryRequest) ProtoMessage 

func (*CreateDirectoryRequest) ProtoMessage()

func (*CreateDirectoryRequest) ProtoReflect 

func (x *CreateDirectoryRequest) ProtoReflect() protoreflect.Message

func (*CreateDirectoryRequest) Reset 

func (x *CreateDirectoryRequest) Reset()

func (*CreateDirectoryRequest) String 

func (x *CreateDirectoryRequest) String() string

type CreateDirectoryResponse 

type CreateDirectoryResponse struct {

	// Operation status.
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateDirectoryResponse) Descriptor deprecated 

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

Deprecated: Use CreateDirectoryResponse.ProtoReflect.Descriptor instead.

func (*CreateDirectoryResponse) GetStatus 

func (x *CreateDirectoryResponse) GetStatus() *Status

func (*CreateDirectoryResponse) ProtoMessage 

func (*CreateDirectoryResponse) ProtoMessage()

func (*CreateDirectoryResponse) ProtoReflect 

func (x *CreateDirectoryResponse) ProtoReflect() protoreflect.Message

func (*CreateDirectoryResponse) Reset 

func (x *CreateDirectoryResponse) Reset()

func (*CreateDirectoryResponse) String 

func (x *CreateDirectoryResponse) String() string

type CreateFileOptions 

type CreateFileOptions struct {

	// Ignore the create if exists. If not true, an error will be returned.
	IgnoreIfExists bool `protobuf:"varint,1,opt,name=ignore_if_exists,json=ignoreIfExists,proto3" json:"ignore_if_exists,omitempty"`
	// Overwrite the file if exists. If not true, leave the file not touched.
	OverwriteIfExists bool `protobuf:"varint,2,opt,name=overwrite_if_exists,json=overwriteIfExists,proto3" json:"overwrite_if_exists,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateFileOptions) Descriptor deprecated 

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

Deprecated: Use CreateFileOptions.ProtoReflect.Descriptor instead.

func (*CreateFileOptions) GetIgnoreIfExists 

func (x *CreateFileOptions) GetIgnoreIfExists() bool

func (*CreateFileOptions) GetOverwriteIfExists 

func (x *CreateFileOptions) GetOverwriteIfExists() bool

func (*CreateFileOptions) ProtoMessage 

func (*CreateFileOptions) ProtoMessage()

func (*CreateFileOptions) ProtoReflect 

func (x *CreateFileOptions) ProtoReflect() protoreflect.Message

func (*CreateFileOptions) Reset 

func (x *CreateFileOptions) Reset()

func (*CreateFileOptions) String 

func (x *CreateFileOptions) String() string

type CreateFileRequest 

type CreateFileRequest struct {

	// Target host.
	Host *Host `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// Create options.
	Options *CreateFileOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// File to create.
	File *FileRequest `protobuf:"bytes,3,opt,name=file,proto3" json:"file,omitempty"`
	// Initial file content if not empty. If options.ignore_if_exists and
	// options.overwrite_if_exists are true, the file content will be overwritten.
	Content []byte `protobuf:"bytes,4,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateFileRequest) Descriptor deprecated 

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

Deprecated: Use CreateFileRequest.ProtoReflect.Descriptor instead.

func (*CreateFileRequest) GetContent 

func (x *CreateFileRequest) GetContent() []byte

func (*CreateFileRequest) GetFile 

func (x *CreateFileRequest) GetFile() *FileRequest

func (*CreateFileRequest) GetHost 

func (x *CreateFileRequest) GetHost() *Host

func (*CreateFileRequest) GetOptions 

func (x *CreateFileRequest) GetOptions() *CreateFileOptions

func (*CreateFileRequest) ProtoMessage 

func (*CreateFileRequest) ProtoMessage()

func (*CreateFileRequest) ProtoReflect 

func (x *CreateFileRequest) ProtoReflect() protoreflect.Message

func (*CreateFileRequest) Reset 

func (x *CreateFileRequest) Reset()

func (*CreateFileRequest) String 

func (x *CreateFileRequest) String() string

type CreateFileResponse 

type CreateFileResponse struct {

	// Operation status.
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateFileResponse) Descriptor deprecated 

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

Deprecated: Use CreateFileResponse.ProtoReflect.Descriptor instead.

func (*CreateFileResponse) GetStatus 

func (x *CreateFileResponse) GetStatus() *Status

func (*CreateFileResponse) ProtoMessage 

func (*CreateFileResponse) ProtoMessage()

func (*CreateFileResponse) ProtoReflect 

func (x *CreateFileResponse) ProtoReflect() protoreflect.Message

func (*CreateFileResponse) Reset 

func (x *CreateFileResponse) Reset()

func (*CreateFileResponse) String 

func (x *CreateFileResponse) String() string

type CreateSymbolicLinkOptions 

type CreateSymbolicLinkOptions struct {

	// Ignore if dest symbolic file/directory exists.
	IgnoreIfExists bool `protobuf:"varint,1,opt,name=ignore_if_exists,json=ignoreIfExists,proto3" json:"ignore_if_exists,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateSymbolicLinkOptions) Descriptor deprecated 

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

Deprecated: Use CreateSymbolicLinkOptions.ProtoReflect.Descriptor instead.

func (*CreateSymbolicLinkOptions) GetIgnoreIfExists 

func (x *CreateSymbolicLinkOptions) GetIgnoreIfExists() bool

func (*CreateSymbolicLinkOptions) ProtoMessage 

func (*CreateSymbolicLinkOptions) ProtoMessage()

func (*CreateSymbolicLinkOptions) ProtoReflect 

func (x *CreateSymbolicLinkOptions) ProtoReflect() protoreflect.Message

func (*CreateSymbolicLinkOptions) Reset 

func (x *CreateSymbolicLinkOptions) Reset()

func (*CreateSymbolicLinkOptions) String 

func (x *CreateSymbolicLinkOptions) String() string

type CreateSymbolicLinkRequest 

type CreateSymbolicLinkRequest struct {

	// Target host.
	Host *Host `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// Create options.
	Options *CreateSymbolicLinkOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// Source file/directory path.
	DestPath string `protobuf:"bytes,3,opt,name=dest_path,json=destPath,proto3" json:"dest_path,omitempty"`
	// Destination file/directory path.
	LinkPath *FileRequest `protobuf:"bytes,4,opt,name=link_path,json=linkPath,proto3" json:"link_path,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateSymbolicLinkRequest) Descriptor deprecated 

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

Deprecated: Use CreateSymbolicLinkRequest.ProtoReflect.Descriptor instead.

func (*CreateSymbolicLinkRequest) GetDestPath 

func (x *CreateSymbolicLinkRequest) GetDestPath() string

func (*CreateSymbolicLinkRequest) GetHost 

func (x *CreateSymbolicLinkRequest) GetHost() *Host

func (*CreateSymbolicLinkRequest) GetLinkPath 

func (x *CreateSymbolicLinkRequest) GetLinkPath() *FileRequest

func (*CreateSymbolicLinkRequest) GetOptions 

func (x *CreateSymbolicLinkRequest) GetOptions() *CreateSymbolicLinkOptions

func (*CreateSymbolicLinkRequest) ProtoMessage 

func (*CreateSymbolicLinkRequest) ProtoMessage()

func (*CreateSymbolicLinkRequest) ProtoReflect 

func (x *CreateSymbolicLinkRequest) ProtoReflect() protoreflect.Message

func (*CreateSymbolicLinkRequest) Reset 

func (x *CreateSymbolicLinkRequest) Reset()

func (*CreateSymbolicLinkRequest) String 

func (x *CreateSymbolicLinkRequest) String() string

type CreateSymbolicLinkResponse 

type CreateSymbolicLinkResponse struct {

	// Operation status.
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateSymbolicLinkResponse) Descriptor deprecated 

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

Deprecated: Use CreateSymbolicLinkResponse.ProtoReflect.Descriptor instead.

func (*CreateSymbolicLinkResponse) GetStatus 

func (x *CreateSymbolicLinkResponse) GetStatus() *Status

func (*CreateSymbolicLinkResponse) ProtoMessage 

func (*CreateSymbolicLinkResponse) ProtoMessage()

func (*CreateSymbolicLinkResponse) ProtoReflect 

func (x *CreateSymbolicLinkResponse) ProtoReflect() protoreflect.Message

func (*CreateSymbolicLinkResponse) Reset 

func (x *CreateSymbolicLinkResponse) Reset()

func (*CreateSymbolicLinkResponse) String 

func (x *CreateSymbolicLinkResponse) String() string

type DeleteRemoteFileRequest 

type DeleteRemoteFileRequest struct {

	// Target.
	Target *RemoteFsEndpoint `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRemoteFileRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRemoteFileRequest.ProtoReflect.Descriptor instead.

func (*DeleteRemoteFileRequest) GetTarget 

func (x *DeleteRemoteFileRequest) GetTarget() *RemoteFsEndpoint

func (*DeleteRemoteFileRequest) ProtoMessage 

func (*DeleteRemoteFileRequest) ProtoMessage()

func (*DeleteRemoteFileRequest) ProtoReflect 

func (x *DeleteRemoteFileRequest) ProtoReflect() protoreflect.Message

func (*DeleteRemoteFileRequest) Reset 

func (x *DeleteRemoteFileRequest) Reset()

func (*DeleteRemoteFileRequest) String 

func (x *DeleteRemoteFileRequest) String() string

type DeleteRemoteFileResponse 

type DeleteRemoteFileResponse struct {

	// Operation status.
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRemoteFileResponse) Descriptor deprecated 

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

Deprecated: Use DeleteRemoteFileResponse.ProtoReflect.Descriptor instead.

func (*DeleteRemoteFileResponse) GetStatus 

func (x *DeleteRemoteFileResponse) GetStatus() *Status

func (*DeleteRemoteFileResponse) ProtoMessage 

func (*DeleteRemoteFileResponse) ProtoMessage()

func (*DeleteRemoteFileResponse) ProtoReflect 

func (x *DeleteRemoteFileResponse) ProtoReflect() protoreflect.Message

func (*DeleteRemoteFileResponse) Reset 

func (x *DeleteRemoteFileResponse) Reset()

func (*DeleteRemoteFileResponse) String 

func (x *DeleteRemoteFileResponse) String() string

type DiskInfo 

type DiskInfo struct {

	// Total size of the volume / disk.
	Total uint64 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	// Free size of the volume / disk.
	Free uint64 `protobuf:"varint,2,opt,name=free,proto3" json:"free,omitempty"`
	// Used size of the volume / disk.
	Used uint64 `protobuf:"varint,3,opt,name=Used,proto3" json:"Used,omitempty"`
	// Total inodes available.
	Files uint64 `protobuf:"varint,4,opt,name=files,proto3" json:"files,omitempty"`
	// Free inodes available.
	FFree uint64 `protobuf:"varint,5,opt,name=f_free,json=fFree,proto3" json:"f_free,omitempty"`
	// File system type.
	FsType string `protobuf:"bytes,6,opt,name=fs_type,json=fsType,proto3" json:"fs_type,omitempty"`
	// contains filtered or unexported fields
}

func (*DiskInfo) Descriptor deprecated 

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

Deprecated: Use DiskInfo.ProtoReflect.Descriptor instead.

func (*DiskInfo) GetFFree 

func (x *DiskInfo) GetFFree() uint64

func (*DiskInfo) GetFiles 

func (x *DiskInfo) GetFiles() uint64

func (*DiskInfo) GetFree 

func (x *DiskInfo) GetFree() uint64

func (*DiskInfo) GetFsType 

func (x *DiskInfo) GetFsType() string

func (*DiskInfo) GetTotal 

func (x *DiskInfo) GetTotal() uint64

func (*DiskInfo) GetUsed 

func (x *DiskInfo) GetUsed() uint64

func (*DiskInfo) ProtoMessage 

func (*DiskInfo) ProtoMessage()

func (*DiskInfo) ProtoReflect 

func (x *DiskInfo) ProtoReflect() protoreflect.Message

func (*DiskInfo) Reset 

func (x *DiskInfo) Reset()

func (*DiskInfo) String 

func (x *DiskInfo) String() string

type DownloadRequest 

type DownloadRequest struct {

	// Target host.
	Host *Host `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// Async task request.
	AsyncTask *AsyncTaskRequest `protobuf:"bytes,2,opt,name=async_task,json=asyncTask,proto3" json:"async_task,omitempty"`
	// Download tasks.
	Tasks []*DownloadTask `protobuf:"bytes,3,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*DownloadRequest) Descriptor deprecated 

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

Deprecated: Use DownloadRequest.ProtoReflect.Descriptor instead.

func (*DownloadRequest) GetAsyncTask 

func (x *DownloadRequest) GetAsyncTask() *AsyncTaskRequest

func (*DownloadRequest) GetHost 

func (x *DownloadRequest) GetHost() *Host

func (*DownloadRequest) GetTasks 

func (x *DownloadRequest) GetTasks() []*DownloadTask

func (*DownloadRequest) ProtoMessage 

func (*DownloadRequest) ProtoMessage()

func (*DownloadRequest) ProtoReflect 

func (x *DownloadRequest) ProtoReflect() protoreflect.Message

func (*DownloadRequest) Reset 

func (x *DownloadRequest) Reset()

func (*DownloadRequest) String 

func (x *DownloadRequest) String() string

type DownloadResponse 

type DownloadResponse struct {

	// Operation status.
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// Async task.
	Task *AsyncTask `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*DownloadResponse) Descriptor deprecated 

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

Deprecated: Use DownloadResponse.ProtoReflect.Descriptor instead.

func (*DownloadResponse) GetStatus 

func (x *DownloadResponse) GetStatus() *Status

func (*DownloadResponse) GetTask 

func (x *DownloadResponse) GetTask() *AsyncTask

func (*DownloadResponse) ProtoMessage 

func (*DownloadResponse) ProtoMessage()

func (*DownloadResponse) ProtoReflect 

func (x *DownloadResponse) ProtoReflect() protoreflect.Message

func (*DownloadResponse) Reset 

func (x *DownloadResponse) Reset()

func (*DownloadResponse) String 

func (x *DownloadResponse) String() string

type DownloadSource 

type DownloadSource struct {
	Endpoint *RemoteFsEndpoint `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// contains filtered or unexported fields
}

func (*DownloadSource) Descriptor deprecated 

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

Deprecated: Use DownloadSource.ProtoReflect.Descriptor instead.

func (*DownloadSource) GetEndpoint 

func (x *DownloadSource) GetEndpoint() *RemoteFsEndpoint

func (*DownloadSource) ProtoMessage 

func (*DownloadSource) ProtoMessage()

func (*DownloadSource) ProtoReflect 

func (x *DownloadSource) ProtoReflect() protoreflect.Message

func (*DownloadSource) Reset 

func (x *DownloadSource) Reset()

func (*DownloadSource) String 

func (x *DownloadSource) String() string

type DownloadTask 

type DownloadTask struct {

	// Download sources.
	Source *DownloadSource `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	// Target path.
	Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*DownloadTask) Descriptor deprecated 

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

Deprecated: Use DownloadTask.ProtoReflect.Descriptor instead.

func (*DownloadTask) GetPath 

func (x *DownloadTask) GetPath() string

func (*DownloadTask) GetSource 

func (x *DownloadTask) GetSource() *DownloadSource

func (*DownloadTask) ProtoMessage 

func (*DownloadTask) ProtoMessage()

func (*DownloadTask) ProtoReflect 

func (x *DownloadTask) ProtoReflect() protoreflect.Message

func (*DownloadTask) Reset 

func (x *DownloadTask) Reset()

func (*DownloadTask) String 

func (x *DownloadTask) String() string

type File 

type File struct {

	// File path.
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// Flag for directory.
	IsDirectory bool `protobuf:"varint,2,opt,name=is_directory,json=isDirectory,proto3" json:"is_directory,omitempty"`
	// File stats.
	Stats *FileStats `protobuf:"bytes,3,opt,name=stats,proto3" json:"stats,omitempty"`
	// contains filtered or unexported fields
}

File represents a file.

func (*File) Descriptor deprecated 

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

Deprecated: Use File.ProtoReflect.Descriptor instead.

func (*File) GetIsDirectory 

func (x *File) GetIsDirectory() bool

func (*File) GetPath 

func (x *File) GetPath() string

func (*File) GetStats 

func (x *File) GetStats() *FileStats

func (*File) ProtoMessage 

func (*File) ProtoMessage()

func (*File) ProtoReflect 

func (x *File) ProtoReflect() protoreflect.Message

func (*File) Reset 

func (x *File) Reset()

func (*File) String 

func (x *File) String() string

type FileInfo 

type FileInfo struct {

	// Base name of the file.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Size of file, in bytes.
	Size uint64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	// File mode.
	Mode uint32 `protobuf:"varint,3,opt,name=mode,proto3" json:"mode,omitempty"`
	// Modification time.
	ModTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=mod_time,json=modTime,proto3" json:"mod_time,omitempty"`
	// Is dir.
	IsDir bool `protobuf:"varint,5,opt,name=is_dir,json=isDir,proto3" json:"is_dir,omitempty"`
	// contains filtered or unexported fields
}

func (*FileInfo) Descriptor deprecated 

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

Deprecated: Use FileInfo.ProtoReflect.Descriptor instead.

func (*FileInfo) GetIsDir 

func (x *FileInfo) GetIsDir() bool

func (*FileInfo) GetModTime 

func (x *FileInfo) GetModTime() *timestamppb.Timestamp

func (*FileInfo) GetMode 

func (x *FileInfo) GetMode() uint32

func (*FileInfo) GetName 

func (x *FileInfo) GetName() string

func (*FileInfo) GetSize 

func (x *FileInfo) GetSize() uint64

func (*FileInfo) ProtoMessage 

func (*FileInfo) ProtoMessage()

func (*FileInfo) ProtoReflect 

func (x *FileInfo) ProtoReflect() protoreflect.Message

func (*FileInfo) Reset 

func (x *FileInfo) Reset()

func (*FileInfo) String 

func (x *FileInfo) String() string

type FileRequest 

type FileRequest struct {

	// Absolute path of file to be created.
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// File mode.
	Mode uint32 `protobuf:"varint,2,opt,name=mode,proto3" json:"mode,omitempty"`
	// File owner, either uid or user.
	//
	// Types that are assignable to Owner:
	//	*FileRequest_Uid
	//	*FileRequest_User
	Owner isFileRequest_Owner `protobuf_oneof:"owner"`
	// File group, either gid or name.
	//
	// Types that are assignable to Group:
	//	*FileRequest_Gid
	//	*FileRequest_GroupName
	Group isFileRequest_Group `protobuf_oneof:"group"`
	// contains filtered or unexported fields
}

func (*FileRequest) Descriptor deprecated 

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

Deprecated: Use FileRequest.ProtoReflect.Descriptor instead.

func (*FileRequest) GetGid 

func (x *FileRequest) GetGid() uint32

func (*FileRequest) GetGroup 

func (m *FileRequest) GetGroup() isFileRequest_Group

func (*FileRequest) GetGroupName 

func (x *FileRequest) GetGroupName() string

func (*FileRequest) GetMode 

func (x *FileRequest) GetMode() uint32

func (*FileRequest) GetOwner 

func (m *FileRequest) GetOwner() isFileRequest_Owner

func (*FileRequest) GetPath 

func (x *FileRequest) GetPath() string

func (*FileRequest) GetUid 

func (x *FileRequest) GetUid() uint32

func (*FileRequest) GetUser 

func (x *FileRequest) GetUser() string

func (*FileRequest) ProtoMessage 

func (*FileRequest) ProtoMessage()

func (*FileRequest) ProtoReflect 

func (x *FileRequest) ProtoReflect() protoreflect.Message

func (*FileRequest) Reset 

func (x *FileRequest) Reset()

func (*FileRequest) String 

func (x *FileRequest) String() string

type FileRequest_Gid 

type FileRequest_Gid struct {
	Gid uint32 `protobuf:"varint,5,opt,name=gid,proto3,oneof"`
}

type FileRequest_GroupName 

type FileRequest_GroupName struct {
	GroupName string `protobuf:"bytes,6,opt,name=group_name,json=groupName,proto3,oneof"`
}

type FileRequest_Uid 

type FileRequest_Uid struct {
	Uid uint32 `protobuf:"varint,3,opt,name=uid,proto3,oneof"`
}

type FileRequest_User 

type FileRequest_User struct {
	User string `protobuf:"bytes,4,opt,name=user,proto3,oneof"`
}

type FileStats 

type FileStats struct {

	// File mode, e.g. 0664
	Mode uint32 `protobuf:"varint,1,opt,name=mode,proto3" json:"mode,omitempty"`
	// File owner, either uid or user.
	//
	// Types that are assignable to Owner:
	//	*FileStats_Uid
	//	*FileStats_User
	Owner isFileStats_Owner `protobuf_oneof:"owner"`
	// File group, either gid or name.
	//
	// Types that are assignable to Group:
	//	*FileStats_Gid
	//	*FileStats_GroupName
	Group isFileStats_Group `protobuf_oneof:"group"`
	Size  uint64            `protobuf:"varint,6,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*FileStats) Descriptor deprecated 

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

Deprecated: Use FileStats.ProtoReflect.Descriptor instead.

func (*FileStats) GetGid 

func (x *FileStats) GetGid() uint32

func (*FileStats) GetGroup 

func (m *FileStats) GetGroup() isFileStats_Group

func (*FileStats) GetGroupName 

func (x *FileStats) GetGroupName() string

func (*FileStats) GetMode 

func (x *FileStats) GetMode() uint32

func (*FileStats) GetOwner 

func (m *FileStats) GetOwner() isFileStats_Owner

func (*FileStats) GetSize 

func (x *FileStats) GetSize() uint64

func (*FileStats) GetUid 

func (x *FileStats) GetUid() uint32

func (*FileStats) GetUser 

func (x *FileStats) GetUser() string

func (*FileStats) ProtoMessage 

func (*FileStats) ProtoMessage()

func (*FileStats) ProtoReflect 

func (x *FileStats) ProtoReflect() protoreflect.Message

func (*FileStats) Reset 

func (x *FileStats) Reset()

func (*FileStats) String 

func (x *FileStats) String() string

type FileStats_Gid 

type FileStats_Gid struct {
	Gid uint32 `protobuf:"varint,4,opt,name=gid,proto3,oneof"`
}

type FileStats_GroupName 

type FileStats_GroupName struct {
	GroupName string `protobuf:"bytes,5,opt,name=group_name,json=groupName,proto3,oneof"`
}

type FileStats_Uid 

type FileStats_Uid struct {
	Uid uint32 `protobuf:"varint,2,opt,name=uid,proto3,oneof"`
}

type FileStats_User 

type FileStats_User struct {
	User string `protobuf:"bytes,3,opt,name=user,proto3,oneof"`
}

type Host 

type Host struct {
	NodeName string `protobuf:"bytes,1,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	// contains filtered or unexported fields
}

func (*Host) Descriptor deprecated 

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

Deprecated: Use Host.ProtoReflect.Descriptor instead.

func (*Host) GetNodeName 

func (x *Host) GetNodeName() string

func (*Host) ProtoMessage 

func (*Host) ProtoMessage()

func (*Host) ProtoReflect 

func (x *Host) ProtoReflect() protoreflect.Message

func (*Host) Reset 

func (x *Host) Reset()

func (*Host) String 

func (x *Host) String() string

type HpfsServiceClient 

type HpfsServiceClient interface {
	CreateDirectory(ctx context.Context, in *CreateDirectoryRequest, opts ...grpc.CallOption) (*CreateDirectoryResponse, error)
	CreateFile(ctx context.Context, in *CreateFileRequest, opts ...grpc.CallOption) (*CreateFileResponse, error)
	CreateSymbolicLink(ctx context.Context, in *CreateSymbolicLinkRequest, opts ...grpc.CallOption) (*CreateSymbolicLinkResponse, error)
	ListDirectory(ctx context.Context, in *ListDirectoryRequest, opts ...grpc.CallOption) (*ListDirectoryResponse, error)
	RemoveDirectory(ctx context.Context, in *RemoveDirectoryRequest, opts ...grpc.CallOption) (*RemoveDirectoryResponse, error)
	RemoveFile(ctx context.Context, in *RemoveFileRequest, opts ...grpc.CallOption) (*RemoveFileResponse, error)
	TruncateFile(ctx context.Context, in *TruncateFileRequest, opts ...grpc.CallOption) (*TruncateFileResponse, error)
	DownloadFiles(ctx context.Context, in *DownloadRequest, opts ...grpc.CallOption) (*DownloadResponse, error)
	UploadFiles(ctx context.Context, in *UploadRequest, opts ...grpc.CallOption) (*UploadResponse, error)
	DeleteRemoteFile(ctx context.Context, in *DeleteRemoteFileRequest, opts ...grpc.CallOption) (*DeleteRemoteFileResponse, error)
	ShowAsyncTaskStatus(ctx context.Context, in *ShowAsyncTaskStatusRequest, opts ...grpc.CallOption) (*ShowAsyncTaskStatusResponse, error)
	CancelAsyncTask(ctx context.Context, in *CancelAsyncTaskRequest, opts ...grpc.CallOption) (*CancelAsyncTaskResponse, error)
	TransferFiles(ctx context.Context, in *TransferRequest, opts ...grpc.CallOption) (*TransferResponse, error)
	ShowDiskUsage(ctx context.Context, in *ShowDiskUsageRequest, opts ...grpc.CallOption) (*ShowDiskUsageResponse, error)
	ShowDiskInfo(ctx context.Context, in *ShowDiskInfoRequest, opts ...grpc.CallOption) (*ShowDiskInfoResponse, error)
	// Control blkio cgroups for kubernetes pods.
	ControlCgroupsBlkio(ctx context.Context, in *ControlCgroupsBlkioRequest, opts ...grpc.CallOption) (*ControlCgroupsBlkioResponse, error)
}

HpfsServiceClient is the client API for HpfsService service.

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

func NewHpfsServiceClient 

func NewHpfsServiceClient(cc grpc.ClientConnInterface) HpfsServiceClient

type HpfsServiceServer 

type HpfsServiceServer interface {
	CreateDirectory(context.Context, *CreateDirectoryRequest) (*CreateDirectoryResponse, error)
	CreateFile(context.Context, *CreateFileRequest) (*CreateFileResponse, error)
	CreateSymbolicLink(context.Context, *CreateSymbolicLinkRequest) (*CreateSymbolicLinkResponse, error)
	ListDirectory(context.Context, *ListDirectoryRequest) (*ListDirectoryResponse, error)
	RemoveDirectory(context.Context, *RemoveDirectoryRequest) (*RemoveDirectoryResponse, error)
	RemoveFile(context.Context, *RemoveFileRequest) (*RemoveFileResponse, error)
	TruncateFile(context.Context, *TruncateFileRequest) (*TruncateFileResponse, error)
	DownloadFiles(context.Context, *DownloadRequest) (*DownloadResponse, error)
	UploadFiles(context.Context, *UploadRequest) (*UploadResponse, error)
	DeleteRemoteFile(context.Context, *DeleteRemoteFileRequest) (*DeleteRemoteFileResponse, error)
	ShowAsyncTaskStatus(context.Context, *ShowAsyncTaskStatusRequest) (*ShowAsyncTaskStatusResponse, error)
	CancelAsyncTask(context.Context, *CancelAsyncTaskRequest) (*CancelAsyncTaskResponse, error)
	TransferFiles(context.Context, *TransferRequest) (*TransferResponse, error)
	ShowDiskUsage(context.Context, *ShowDiskUsageRequest) (*ShowDiskUsageResponse, error)
	ShowDiskInfo(context.Context, *ShowDiskInfoRequest) (*ShowDiskInfoResponse, error)
	// Control blkio cgroups for kubernetes pods.
	ControlCgroupsBlkio(context.Context, *ControlCgroupsBlkioRequest) (*ControlCgroupsBlkioResponse, error)
}

HpfsServiceServer is the server API for HpfsService service.

type ListDirectoryRequest 

type ListDirectoryRequest struct {

	// Target host.
	Host *Host `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// Directory path to list.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*ListDirectoryRequest) Descriptor deprecated 

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

Deprecated: Use ListDirectoryRequest.ProtoReflect.Descriptor instead.

func (*ListDirectoryRequest) GetHost 

func (x *ListDirectoryRequest) GetHost() *Host

func (*ListDirectoryRequest) GetPath 

func (x *ListDirectoryRequest) GetPath() string

func (*ListDirectoryRequest) ProtoMessage 

func (*ListDirectoryRequest) ProtoMessage()

func (*ListDirectoryRequest) ProtoReflect 

func (x *ListDirectoryRequest) ProtoReflect() protoreflect.Message

func (*ListDirectoryRequest) Reset 

func (x *ListDirectoryRequest) Reset()

func (*ListDirectoryRequest) String 

func (x *ListDirectoryRequest) String() string

type ListDirectoryResponse 

type ListDirectoryResponse struct {

	// Operation status.
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// Files under requested directory.
	Files []*FileInfo `protobuf:"bytes,2,rep,name=files,proto3" json:"files,omitempty"`
	// contains filtered or unexported fields
}

func (*ListDirectoryResponse) Descriptor deprecated 

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

Deprecated: Use ListDirectoryResponse.ProtoReflect.Descriptor instead.

func (*ListDirectoryResponse) GetFiles 

func (x *ListDirectoryResponse) GetFiles() []*FileInfo

func (*ListDirectoryResponse) GetStatus 

func (x *ListDirectoryResponse) GetStatus() *Status

func (*ListDirectoryResponse) ProtoMessage 

func (*ListDirectoryResponse) ProtoMessage()

func (*ListDirectoryResponse) ProtoReflect 

func (x *ListDirectoryResponse) ProtoReflect() protoreflect.Message

func (*ListDirectoryResponse) Reset 

func (x *ListDirectoryResponse) Reset()

func (*ListDirectoryResponse) String 

func (x *ListDirectoryResponse) String() string

type RemoteFsEndpoint 

type RemoteFsEndpoint struct {

	// File service protocol. Extension point for each different sources.
	// Currently supported protocols are:
	//     1. ftp, File Transfer Protocol.
	//     2. sftp, SSH File Transfer Protocol.
	//     3. http(s), Hypertext Transfer Protocol.
	//     4. oss (aliyun), Object Storage Service of Aliyun.
	//     5. hdfs, Hadoop Distributed File System.
	Protocol string `protobuf:"bytes,1,opt,name=protocol,proto3" json:"protocol,omitempty"`
	// Path in protocol specified format.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// Parameters for authenticate.
	Auth map[string]string `` /* 149-byte string literal not displayed */
	// Other parameters.
	Other map[string]string `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RemoteFsEndpoint) Descriptor deprecated 

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

Deprecated: Use RemoteFsEndpoint.ProtoReflect.Descriptor instead.

func (*RemoteFsEndpoint) GetAuth 

func (x *RemoteFsEndpoint) GetAuth() map[string]string

func (*RemoteFsEndpoint) GetOther 

func (x *RemoteFsEndpoint) GetOther() map[string]string

func (*RemoteFsEndpoint) GetPath 

func (x *RemoteFsEndpoint) GetPath() string

func (*RemoteFsEndpoint) GetProtocol 

func (x *RemoteFsEndpoint) GetProtocol() string

func (*RemoteFsEndpoint) ProtoMessage 

func (*RemoteFsEndpoint) ProtoMessage()

func (*RemoteFsEndpoint) ProtoReflect 

func (x *RemoteFsEndpoint) ProtoReflect() protoreflect.Message

func (*RemoteFsEndpoint) Reset 

func (x *RemoteFsEndpoint) Reset()

func (*RemoteFsEndpoint) String 

func (x *RemoteFsEndpoint) String() string

type RemoveDirectoryRequest 

type RemoveDirectoryRequest struct {

	// Target host.
	Host *Host `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// Remove options.
	Options *RemoveOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// Directory path to remove.
	Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveDirectoryRequest) Descriptor deprecated 

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

Deprecated: Use RemoveDirectoryRequest.ProtoReflect.Descriptor instead.

func (*RemoveDirectoryRequest) GetHost 

func (x *RemoveDirectoryRequest) GetHost() *Host

func (*RemoveDirectoryRequest) GetOptions 

func (x *RemoveDirectoryRequest) GetOptions() *RemoveOptions

func (*RemoveDirectoryRequest) GetPath 

func (x *RemoveDirectoryRequest) GetPath() string

func (*RemoveDirectoryRequest) ProtoMessage 

func (*RemoveDirectoryRequest) ProtoMessage()

func (*RemoveDirectoryRequest) ProtoReflect 

func (x *RemoveDirectoryRequest) ProtoReflect() protoreflect.Message

func (*RemoveDirectoryRequest) Reset 

func (x *RemoveDirectoryRequest) Reset()

func (*RemoveDirectoryRequest) String 

func (x *RemoveDirectoryRequest) String() string

type RemoveDirectoryResponse 

type RemoveDirectoryResponse struct {

	// Operation status.
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveDirectoryResponse) Descriptor deprecated 

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

Deprecated: Use RemoveDirectoryResponse.ProtoReflect.Descriptor instead.

func (*RemoveDirectoryResponse) GetStatus 

func (x *RemoveDirectoryResponse) GetStatus() *Status

func (*RemoveDirectoryResponse) ProtoMessage 

func (*RemoveDirectoryResponse) ProtoMessage()

func (*RemoveDirectoryResponse) ProtoReflect 

func (x *RemoveDirectoryResponse) ProtoReflect() protoreflect.Message

func (*RemoveDirectoryResponse) Reset 

func (x *RemoveDirectoryResponse) Reset()

func (*RemoveDirectoryResponse) String 

func (x *RemoveDirectoryResponse) String() string

type RemoveFileRequest 

type RemoveFileRequest struct {

	// Target host.
	Host *Host `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// Remove options.
	Options *RemoveOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// File path to remove.
	Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveFileRequest) Descriptor deprecated 

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

Deprecated: Use RemoveFileRequest.ProtoReflect.Descriptor instead.

func (*RemoveFileRequest) GetHost 

func (x *RemoveFileRequest) GetHost() *Host

func (*RemoveFileRequest) GetOptions 

func (x *RemoveFileRequest) GetOptions() *RemoveOptions

func (*RemoveFileRequest) GetPath 

func (x *RemoveFileRequest) GetPath() string

func (*RemoveFileRequest) ProtoMessage 

func (*RemoveFileRequest) ProtoMessage()

func (*RemoveFileRequest) ProtoReflect 

func (x *RemoveFileRequest) ProtoReflect() protoreflect.Message

func (*RemoveFileRequest) Reset 

func (x *RemoveFileRequest) Reset()

func (*RemoveFileRequest) String 

func (x *RemoveFileRequest) String() string

type RemoveFileResponse 

type RemoveFileResponse struct {

	// Operation status.
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveFileResponse) Descriptor deprecated 

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

Deprecated: Use RemoveFileResponse.ProtoReflect.Descriptor instead.

func (*RemoveFileResponse) GetStatus 

func (x *RemoveFileResponse) GetStatus() *Status

func (*RemoveFileResponse) ProtoMessage 

func (*RemoveFileResponse) ProtoMessage()

func (*RemoveFileResponse) ProtoReflect 

func (x *RemoveFileResponse) ProtoReflect() protoreflect.Message

func (*RemoveFileResponse) Reset 

func (x *RemoveFileResponse) Reset()

func (*RemoveFileResponse) String 

func (x *RemoveFileResponse) String() string

type RemoveOptions 

type RemoveOptions struct {

	// Ignore if file/directory not exists.
	IgnoreIfNotExists bool `protobuf:"varint,1,opt,name=ignore_if_not_exists,json=ignoreIfNotExists,proto3" json:"ignore_if_not_exists,omitempty"`
	// Recursively
	Recursive bool `protobuf:"varint,2,opt,name=recursive,proto3" json:"recursive,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveOptions) Descriptor deprecated 

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

Deprecated: Use RemoveOptions.ProtoReflect.Descriptor instead.

func (*RemoveOptions) GetIgnoreIfNotExists 

func (x *RemoveOptions) GetIgnoreIfNotExists() bool

func (*RemoveOptions) GetRecursive 

func (x *RemoveOptions) GetRecursive() bool

func (*RemoveOptions) ProtoMessage 

func (*RemoveOptions) ProtoMessage()

func (*RemoveOptions) ProtoReflect 

func (x *RemoveOptions) ProtoReflect() protoreflect.Message

func (*RemoveOptions) Reset 

func (x *RemoveOptions) Reset()

func (*RemoveOptions) String 

func (x *RemoveOptions) String() string

type ShowAsyncTaskStatusRequest 

type ShowAsyncTaskStatusRequest struct {

	// Destination host.
	Host *Host `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// Async task.
	Task *AsyncTask `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowAsyncTaskStatusRequest) Descriptor deprecated 

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

Deprecated: Use ShowAsyncTaskStatusRequest.ProtoReflect.Descriptor instead.

func (*ShowAsyncTaskStatusRequest) GetHost 

func (x *ShowAsyncTaskStatusRequest) GetHost() *Host

func (*ShowAsyncTaskStatusRequest) GetTask 

func (x *ShowAsyncTaskStatusRequest) GetTask() *AsyncTask

func (*ShowAsyncTaskStatusRequest) ProtoMessage 

func (*ShowAsyncTaskStatusRequest) ProtoMessage()

func (*ShowAsyncTaskStatusRequest) ProtoReflect 

func (x *ShowAsyncTaskStatusRequest) ProtoReflect() protoreflect.Message

func (*ShowAsyncTaskStatusRequest) Reset 

func (x *ShowAsyncTaskStatusRequest) Reset()

func (*ShowAsyncTaskStatusRequest) String 

func (x *ShowAsyncTaskStatusRequest) String() string

type ShowAsyncTaskStatusResponse 

type ShowAsyncTaskStatusResponse struct {

	// Operation status
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// Task status.
	TaskStatus TaskStatus `protobuf:"varint,2,opt,name=task_status,json=taskStatus,proto3,enum=proto.TaskStatus" json:"task_status,omitempty"`
	// Progress of transfer.
	Progress float64 `protobuf:"fixed64,3,opt,name=progress,proto3" json:"progress,omitempty"`
	// Error message.
	Message string `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowAsyncTaskStatusResponse) Descriptor deprecated 

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

Deprecated: Use ShowAsyncTaskStatusResponse.ProtoReflect.Descriptor instead.

func (*ShowAsyncTaskStatusResponse) GetMessage 

func (x *ShowAsyncTaskStatusResponse) GetMessage() string

func (*ShowAsyncTaskStatusResponse) GetProgress 

func (x *ShowAsyncTaskStatusResponse) GetProgress() float64

func (*ShowAsyncTaskStatusResponse) GetStatus 

func (x *ShowAsyncTaskStatusResponse) GetStatus() *Status

func (*ShowAsyncTaskStatusResponse) GetTaskStatus 

func (x *ShowAsyncTaskStatusResponse) GetTaskStatus() TaskStatus

func (*ShowAsyncTaskStatusResponse) ProtoMessage 

func (*ShowAsyncTaskStatusResponse) ProtoMessage()

func (*ShowAsyncTaskStatusResponse) ProtoReflect 

func (x *ShowAsyncTaskStatusResponse) ProtoReflect() protoreflect.Message

func (*ShowAsyncTaskStatusResponse) Reset 

func (x *ShowAsyncTaskStatusResponse) Reset()

func (*ShowAsyncTaskStatusResponse) String 

func (x *ShowAsyncTaskStatusResponse) String() string

type ShowDiskInfoRequest 

type ShowDiskInfoRequest struct {

	// Target host.
	Host *Host `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// Target path.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowDiskInfoRequest) Descriptor deprecated 

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

Deprecated: Use ShowDiskInfoRequest.ProtoReflect.Descriptor instead.

func (*ShowDiskInfoRequest) GetHost 

func (x *ShowDiskInfoRequest) GetHost() *Host

func (*ShowDiskInfoRequest) GetPath 

func (x *ShowDiskInfoRequest) GetPath() string

func (*ShowDiskInfoRequest) ProtoMessage 

func (*ShowDiskInfoRequest) ProtoMessage()

func (*ShowDiskInfoRequest) ProtoReflect 

func (x *ShowDiskInfoRequest) ProtoReflect() protoreflect.Message

func (*ShowDiskInfoRequest) Reset 

func (x *ShowDiskInfoRequest) Reset()

func (*ShowDiskInfoRequest) String 

func (x *ShowDiskInfoRequest) String() string

type ShowDiskInfoResponse 

type ShowDiskInfoResponse struct {

	// Operation status.
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// Disk info.
	Info *DiskInfo `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowDiskInfoResponse) Descriptor deprecated 

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

Deprecated: Use ShowDiskInfoResponse.ProtoReflect.Descriptor instead.

func (*ShowDiskInfoResponse) GetInfo 

func (x *ShowDiskInfoResponse) GetInfo() *DiskInfo

func (*ShowDiskInfoResponse) GetStatus 

func (x *ShowDiskInfoResponse) GetStatus() *Status

func (*ShowDiskInfoResponse) ProtoMessage 

func (*ShowDiskInfoResponse) ProtoMessage()

func (*ShowDiskInfoResponse) ProtoReflect 

func (x *ShowDiskInfoResponse) ProtoReflect() protoreflect.Message

func (*ShowDiskInfoResponse) Reset 

func (x *ShowDiskInfoResponse) Reset()

func (*ShowDiskInfoResponse) String 

func (x *ShowDiskInfoResponse) String() string

type ShowDiskUsageRequest 

type ShowDiskUsageRequest struct {

	// Target host.
	Host *Host `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// Path of file/directory.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowDiskUsageRequest) Descriptor deprecated 

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

Deprecated: Use ShowDiskUsageRequest.ProtoReflect.Descriptor instead.

func (*ShowDiskUsageRequest) GetHost 

func (x *ShowDiskUsageRequest) GetHost() *Host

func (*ShowDiskUsageRequest) GetPath 

func (x *ShowDiskUsageRequest) GetPath() string

func (*ShowDiskUsageRequest) ProtoMessage 

func (*ShowDiskUsageRequest) ProtoMessage()

func (*ShowDiskUsageRequest) ProtoReflect 

func (x *ShowDiskUsageRequest) ProtoReflect() protoreflect.Message

func (*ShowDiskUsageRequest) Reset 

func (x *ShowDiskUsageRequest) Reset()

func (*ShowDiskUsageRequest) String 

func (x *ShowDiskUsageRequest) String() string

type ShowDiskUsageResponse 

type ShowDiskUsageResponse struct {

	// Operation status
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// Size in bytes.
	Size uint64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowDiskUsageResponse) Descriptor deprecated 

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

Deprecated: Use ShowDiskUsageResponse.ProtoReflect.Descriptor instead.

func (*ShowDiskUsageResponse) GetSize 

func (x *ShowDiskUsageResponse) GetSize() uint64

func (*ShowDiskUsageResponse) GetStatus 

func (x *ShowDiskUsageResponse) GetStatus() *Status

func (*ShowDiskUsageResponse) ProtoMessage 

func (*ShowDiskUsageResponse) ProtoMessage()

func (*ShowDiskUsageResponse) ProtoReflect 

func (x *ShowDiskUsageResponse) ProtoReflect() protoreflect.Message

func (*ShowDiskUsageResponse) Reset 

func (x *ShowDiskUsageResponse) Reset()

func (*ShowDiskUsageResponse) String 

func (x *ShowDiskUsageResponse) String() string

type Status 

type Status struct {

	// Status code.
	Code Status_StatusCode `protobuf:"varint,1,opt,name=code,proto3,enum=proto.Status_StatusCode" json:"code,omitempty"`
	// Error message.
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Status) Descriptor deprecated 

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

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetCode 

func (x *Status) GetCode() Status_StatusCode

func (*Status) GetMessage 

func (x *Status) GetMessage() string

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) ProtoReflect 

func (x *Status) ProtoReflect() protoreflect.Message

func (*Status) Reset 

func (x *Status) Reset()

func (*Status) String 

func (x *Status) String() string

type Status_StatusCode 

type Status_StatusCode int32

Enum for error codes. 

const (
	// Operation is successful.
	Status_OK Status_StatusCode = 0
	// Indicates an invalid argument.
	Status_INVALID Status_StatusCode = 1
	// Permission denied.
	Status_PERMISSION_DENIED Status_StatusCode = 2
	// File already exists.
	Status_EXISTS Status_StatusCode = 3
	// File does not exist.
	Status_NOT_EXIST Status_StatusCode = 4
	// Network error, like rpc or network failure.
	Status_NETWORK Status_StatusCode = 5
	// Unknown error.
	Status_UNKNOWN Status_StatusCode = 6
)

func (Status_StatusCode) Descriptor 

func (Status_StatusCode) Descriptor() protoreflect.EnumDescriptor

func (Status_StatusCode) Enum 

func (x Status_StatusCode) Enum() *Status_StatusCode

func (Status_StatusCode) EnumDescriptor deprecated 

func (Status_StatusCode) EnumDescriptor() ([]byte, []int)

Deprecated: Use Status_StatusCode.Descriptor instead.

func (Status_StatusCode) Number 

func (x Status_StatusCode) Number() protoreflect.EnumNumber

func (Status_StatusCode) String 

func (x Status_StatusCode) String() string

func (Status_StatusCode) Type 

func (Status_StatusCode) Type() protoreflect.EnumType

type TaskStatus 

type TaskStatus int32
const (
	// Task is pending.
	TaskStatus_PENDING TaskStatus = 0
	// Task is running.
	TaskStatus_RUNNING TaskStatus = 1
	// Task has been completed successfully.
	TaskStatus_SUCCESS TaskStatus = 2
	// Task was failed.
	TaskStatus_FAILED TaskStatus = 3
	// Task is canceling.
	TaskStatus_CANCELING TaskStatus = 4
	// Tasks was canceled.
	TaskStatus_CANCELED TaskStatus = 5
	// Status unknown.
	TaskStatus_UNKNOWN TaskStatus = 9
)

func (TaskStatus) Descriptor 

func (TaskStatus) Descriptor() protoreflect.EnumDescriptor

func (TaskStatus) Enum 

func (x TaskStatus) Enum() *TaskStatus

func (TaskStatus) EnumDescriptor deprecated 

func (TaskStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use TaskStatus.Descriptor instead.

func (TaskStatus) Number 

func (x TaskStatus) Number() protoreflect.EnumNumber

func (TaskStatus) String 

func (x TaskStatus) String() string

func (TaskStatus) Type 

func (TaskStatus) Type() protoreflect.EnumType

type TransferRequest 

type TransferRequest struct {

	// Source host.
	SrcHost *Host `protobuf:"bytes,1,opt,name=src_host,json=srcHost,proto3" json:"src_host,omitempty"`
	// Destination host.
	DestHost *Host `protobuf:"bytes,2,opt,name=dest_host,json=destHost,proto3" json:"dest_host,omitempty"`
	// Async task request.
	AsyncTask *AsyncTaskRequest `protobuf:"bytes,3,opt,name=async_task,json=asyncTask,proto3" json:"async_task,omitempty"`
	// Source path.
	SrcPath string `protobuf:"bytes,4,opt,name=src_path,json=srcPath,proto3" json:"src_path,omitempty"`
	// Destination path.
	DestPath string `protobuf:"bytes,5,opt,name=dest_path,json=destPath,proto3" json:"dest_path,omitempty"`
	// contains filtered or unexported fields
}

func (*TransferRequest) Descriptor deprecated 

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

Deprecated: Use TransferRequest.ProtoReflect.Descriptor instead.

func (*TransferRequest) GetAsyncTask 

func (x *TransferRequest) GetAsyncTask() *AsyncTaskRequest

func (*TransferRequest) GetDestHost 

func (x *TransferRequest) GetDestHost() *Host

func (*TransferRequest) GetDestPath 

func (x *TransferRequest) GetDestPath() string

func (*TransferRequest) GetSrcHost 

func (x *TransferRequest) GetSrcHost() *Host

func (*TransferRequest) GetSrcPath 

func (x *TransferRequest) GetSrcPath() string

func (*TransferRequest) ProtoMessage 

func (*TransferRequest) ProtoMessage()

func (*TransferRequest) ProtoReflect 

func (x *TransferRequest) ProtoReflect() protoreflect.Message

func (*TransferRequest) Reset 

func (x *TransferRequest) Reset()

func (*TransferRequest) String 

func (x *TransferRequest) String() string

type TransferResponse 

type TransferResponse struct {

	// Operation status
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// Async task.
	Task *AsyncTask `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*TransferResponse) Descriptor deprecated 

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

Deprecated: Use TransferResponse.ProtoReflect.Descriptor instead.

func (*TransferResponse) GetStatus 

func (x *TransferResponse) GetStatus() *Status

func (*TransferResponse) GetTask 

func (x *TransferResponse) GetTask() *AsyncTask

func (*TransferResponse) ProtoMessage 

func (*TransferResponse) ProtoMessage()

func (*TransferResponse) ProtoReflect 

func (x *TransferResponse) ProtoReflect() protoreflect.Message

func (*TransferResponse) Reset 

func (x *TransferResponse) Reset()

func (*TransferResponse) String 

func (x *TransferResponse) String() string

type TruncateFileOptions 

type TruncateFileOptions struct {

	// Ignore truncate if file not exists.
	IgnoreIfNotExists bool `protobuf:"varint,1,opt,name=ignore_if_not_exists,json=ignoreIfNotExists,proto3" json:"ignore_if_not_exists,omitempty"`
	// contains filtered or unexported fields
}

func (*TruncateFileOptions) Descriptor deprecated 

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

Deprecated: Use TruncateFileOptions.ProtoReflect.Descriptor instead.

func (*TruncateFileOptions) GetIgnoreIfNotExists 

func (x *TruncateFileOptions) GetIgnoreIfNotExists() bool

func (*TruncateFileOptions) ProtoMessage 

func (*TruncateFileOptions) ProtoMessage()

func (*TruncateFileOptions) ProtoReflect 

func (x *TruncateFileOptions) ProtoReflect() protoreflect.Message

func (*TruncateFileOptions) Reset 

func (x *TruncateFileOptions) Reset()

func (*TruncateFileOptions) String 

func (x *TruncateFileOptions) String() string

type TruncateFileRequest 

type TruncateFileRequest struct {

	// Target host.
	Host *Host `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// Truncate file options.
	Options *TruncateFileOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// File path to truncate.
	Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*TruncateFileRequest) Descriptor deprecated 

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

Deprecated: Use TruncateFileRequest.ProtoReflect.Descriptor instead.

func (*TruncateFileRequest) GetHost 

func (x *TruncateFileRequest) GetHost() *Host

func (*TruncateFileRequest) GetOptions 

func (x *TruncateFileRequest) GetOptions() *TruncateFileOptions

func (*TruncateFileRequest) GetPath 

func (x *TruncateFileRequest) GetPath() string

func (*TruncateFileRequest) ProtoMessage 

func (*TruncateFileRequest) ProtoMessage()

func (*TruncateFileRequest) ProtoReflect 

func (x *TruncateFileRequest) ProtoReflect() protoreflect.Message

func (*TruncateFileRequest) Reset 

func (x *TruncateFileRequest) Reset()

func (*TruncateFileRequest) String 

func (x *TruncateFileRequest) String() string

type TruncateFileResponse 

type TruncateFileResponse struct {

	// Operation status.
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*TruncateFileResponse) Descriptor deprecated 

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

Deprecated: Use TruncateFileResponse.ProtoReflect.Descriptor instead.

func (*TruncateFileResponse) GetStatus 

func (x *TruncateFileResponse) GetStatus() *Status

func (*TruncateFileResponse) ProtoMessage 

func (*TruncateFileResponse) ProtoMessage()

func (*TruncateFileResponse) ProtoReflect 

func (x *TruncateFileResponse) ProtoReflect() protoreflect.Message

func (*TruncateFileResponse) Reset 

func (x *TruncateFileResponse) Reset()

func (*TruncateFileResponse) String 

func (x *TruncateFileResponse) String() string

type UnimplementedHpfsServiceServer 

type UnimplementedHpfsServiceServer struct {
}

UnimplementedHpfsServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedHpfsServiceServer) CancelAsyncTask 

func (*UnimplementedHpfsServiceServer) CancelAsyncTask(context.Context, *CancelAsyncTaskRequest) (*CancelAsyncTaskResponse, error)

func (*UnimplementedHpfsServiceServer) ControlCgroupsBlkio 

func (*UnimplementedHpfsServiceServer) ControlCgroupsBlkio(context.Context, *ControlCgroupsBlkioRequest) (*ControlCgroupsBlkioResponse, error)

func (*UnimplementedHpfsServiceServer) CreateDirectory 

func (*UnimplementedHpfsServiceServer) CreateDirectory(context.Context, *CreateDirectoryRequest) (*CreateDirectoryResponse, error)

func (*UnimplementedHpfsServiceServer) CreateFile 

func (*UnimplementedHpfsServiceServer) CreateFile(context.Context, *CreateFileRequest) (*CreateFileResponse, error)
func (*UnimplementedHpfsServiceServer) CreateSymbolicLink(context.Context, *CreateSymbolicLinkRequest) (*CreateSymbolicLinkResponse, error)

func (*UnimplementedHpfsServiceServer) DeleteRemoteFile 

func (*UnimplementedHpfsServiceServer) DeleteRemoteFile(context.Context, *DeleteRemoteFileRequest) (*DeleteRemoteFileResponse, error)

func (*UnimplementedHpfsServiceServer) DownloadFiles 

func (*UnimplementedHpfsServiceServer) DownloadFiles(context.Context, *DownloadRequest) (*DownloadResponse, error)

func (*UnimplementedHpfsServiceServer) ListDirectory 

func (*UnimplementedHpfsServiceServer) ListDirectory(context.Context, *ListDirectoryRequest) (*ListDirectoryResponse, error)

func (*UnimplementedHpfsServiceServer) RemoveDirectory 

func (*UnimplementedHpfsServiceServer) RemoveDirectory(context.Context, *RemoveDirectoryRequest) (*RemoveDirectoryResponse, error)

func (*UnimplementedHpfsServiceServer) RemoveFile 

func (*UnimplementedHpfsServiceServer) RemoveFile(context.Context, *RemoveFileRequest) (*RemoveFileResponse, error)

func (*UnimplementedHpfsServiceServer) ShowAsyncTaskStatus 

func (*UnimplementedHpfsServiceServer) ShowAsyncTaskStatus(context.Context, *ShowAsyncTaskStatusRequest) (*ShowAsyncTaskStatusResponse, error)

func (*UnimplementedHpfsServiceServer) ShowDiskInfo 

func (*UnimplementedHpfsServiceServer) ShowDiskInfo(context.Context, *ShowDiskInfoRequest) (*ShowDiskInfoResponse, error)

func (*UnimplementedHpfsServiceServer) ShowDiskUsage 

func (*UnimplementedHpfsServiceServer) ShowDiskUsage(context.Context, *ShowDiskUsageRequest) (*ShowDiskUsageResponse, error)

func (*UnimplementedHpfsServiceServer) TransferFiles 

func (*UnimplementedHpfsServiceServer) TransferFiles(context.Context, *TransferRequest) (*TransferResponse, error)

func (*UnimplementedHpfsServiceServer) TruncateFile 

func (*UnimplementedHpfsServiceServer) TruncateFile(context.Context, *TruncateFileRequest) (*TruncateFileResponse, error)

func (*UnimplementedHpfsServiceServer) UploadFiles 

func (*UnimplementedHpfsServiceServer) UploadFiles(context.Context, *UploadRequest) (*UploadResponse, error)

type UploadRequest 

type UploadRequest struct {

	// Target host.
	Host *Host `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// Async task request.
	AsyncTask *AsyncTaskRequest `protobuf:"bytes,2,opt,name=async_task,json=asyncTask,proto3" json:"async_task,omitempty"`
	// Target file path.
	Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	// Upload target.
	Target *UploadTarget `protobuf:"bytes,4,opt,name=target,proto3" json:"target,omitempty"`
	// contains filtered or unexported fields
}

func (*UploadRequest) Descriptor deprecated 

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

Deprecated: Use UploadRequest.ProtoReflect.Descriptor instead.

func (*UploadRequest) GetAsyncTask 

func (x *UploadRequest) GetAsyncTask() *AsyncTaskRequest

func (*UploadRequest) GetHost 

func (x *UploadRequest) GetHost() *Host

func (*UploadRequest) GetPath 

func (x *UploadRequest) GetPath() string

func (*UploadRequest) GetTarget 

func (x *UploadRequest) GetTarget() *UploadTarget

func (*UploadRequest) ProtoMessage 

func (*UploadRequest) ProtoMessage()

func (*UploadRequest) ProtoReflect 

func (x *UploadRequest) ProtoReflect() protoreflect.Message

func (*UploadRequest) Reset 

func (x *UploadRequest) Reset()

func (*UploadRequest) String 

func (x *UploadRequest) String() string

type UploadResponse 

type UploadResponse struct {

	// Operation status
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// Async task.
	Task *AsyncTask `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*UploadResponse) Descriptor deprecated 

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

Deprecated: Use UploadResponse.ProtoReflect.Descriptor instead.

func (*UploadResponse) GetStatus 

func (x *UploadResponse) GetStatus() *Status

func (*UploadResponse) GetTask 

func (x *UploadResponse) GetTask() *AsyncTask

func (*UploadResponse) ProtoMessage 

func (*UploadResponse) ProtoMessage()

func (*UploadResponse) ProtoReflect 

func (x *UploadResponse) ProtoReflect() protoreflect.Message

func (*UploadResponse) Reset 

func (x *UploadResponse) Reset()

func (*UploadResponse) String 

func (x *UploadResponse) String() string

type UploadTarget 

type UploadTarget struct {
	Endpoint *RemoteFsEndpoint `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// contains filtered or unexported fields
}

func (*UploadTarget) Descriptor deprecated 

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

Deprecated: Use UploadTarget.ProtoReflect.Descriptor instead.

func (*UploadTarget) GetEndpoint 

func (x *UploadTarget) GetEndpoint() *RemoteFsEndpoint

func (*UploadTarget) ProtoMessage 

func (*UploadTarget) ProtoMessage()

func (*UploadTarget) ProtoReflect 

func (x *UploadTarget) ProtoReflect() protoreflect.Message

func (*UploadTarget) Reset 

func (x *UploadTarget) Reset()

func (*UploadTarget) String 

func (x *UploadTarget) String() string

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.