ftp

package
v0.0.0-...-4a7e8af Latest Latest
Warning

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

 Go to latest Published: Jan 13, 2023 License: BSD-3-Clause Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	FtpResult_Result_name = map[int32]string{
		0:  "RESULT_UNKNOWN",
		1:  "RESULT_SUCCESS",
		2:  "RESULT_NEXT",
		3:  "RESULT_TIMEOUT",
		4:  "RESULT_BUSY",
		5:  "RESULT_FILE_IO_ERROR",
		6:  "RESULT_FILE_EXISTS",
		7:  "RESULT_FILE_DOES_NOT_EXIST",
		8:  "RESULT_FILE_PROTECTED",
		9:  "RESULT_INVALID_PARAMETER",
		10: "RESULT_UNSUPPORTED",
		11: "RESULT_PROTOCOL_ERROR",
		12: "RESULT_NO_SYSTEM",
	}
	FtpResult_Result_value = map[string]int32{
		"RESULT_UNKNOWN":             0,
		"RESULT_SUCCESS":             1,
		"RESULT_NEXT":                2,
		"RESULT_TIMEOUT":             3,
		"RESULT_BUSY":                4,
		"RESULT_FILE_IO_ERROR":       5,
		"RESULT_FILE_EXISTS":         6,
		"RESULT_FILE_DOES_NOT_EXIST": 7,
		"RESULT_FILE_PROTECTED":      8,
		"RESULT_INVALID_PARAMETER":   9,
		"RESULT_UNSUPPORTED":         10,
		"RESULT_PROTOCOL_ERROR":      11,
		"RESULT_NO_SYSTEM":           12,
	}
)

Enum value maps for FtpResult_Result.

View Source 
var File_ftp_proto protoreflect.FileDescriptor
View Source 
var FtpService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mavsdk.rpc.ftp.FtpService",
	HandlerType: (*FtpServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Reset",
			Handler:    _FtpService_Reset_Handler,
		},
		{
			MethodName: "ListDirectory",
			Handler:    _FtpService_ListDirectory_Handler,
		},
		{
			MethodName: "CreateDirectory",
			Handler:    _FtpService_CreateDirectory_Handler,
		},
		{
			MethodName: "RemoveDirectory",
			Handler:    _FtpService_RemoveDirectory_Handler,
		},
		{
			MethodName: "RemoveFile",
			Handler:    _FtpService_RemoveFile_Handler,
		},
		{
			MethodName: "Rename",
			Handler:    _FtpService_Rename_Handler,
		},
		{
			MethodName: "AreFilesIdentical",
			Handler:    _FtpService_AreFilesIdentical_Handler,
		},
		{
			MethodName: "SetRootDirectory",
			Handler:    _FtpService_SetRootDirectory_Handler,
		},
		{
			MethodName: "SetTargetCompid",
			Handler:    _FtpService_SetTargetCompid_Handler,
		},
		{
			MethodName: "GetOurCompid",
			Handler:    _FtpService_GetOurCompid_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SubscribeDownload",
			Handler:       _FtpService_SubscribeDownload_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeUpload",
			Handler:       _FtpService_SubscribeUpload_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "ftp.proto",
}

FtpService_ServiceDesc is the grpc.ServiceDesc for FtpService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterFtpServiceServer 

func RegisterFtpServiceServer(s grpc.ServiceRegistrar, srv FtpServiceServer)

Types

type AreFilesIdenticalRequest 

type AreFilesIdenticalRequest struct {
	LocalFilePath  string `protobuf:"bytes,1,opt,name=local_file_path,json=localFilePath,proto3" json:"local_file_path,omitempty"`    // The path of the local file.
	RemoteFilePath string `protobuf:"bytes,2,opt,name=remote_file_path,json=remoteFilePath,proto3" json:"remote_file_path,omitempty"` // The path of the remote file.
	// contains filtered or unexported fields
}

func (*AreFilesIdenticalRequest) Descriptor deprecated 

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

Deprecated: Use AreFilesIdenticalRequest.ProtoReflect.Descriptor instead.

func (*AreFilesIdenticalRequest) GetLocalFilePath 

func (x *AreFilesIdenticalRequest) GetLocalFilePath() string

func (*AreFilesIdenticalRequest) GetRemoteFilePath 

func (x *AreFilesIdenticalRequest) GetRemoteFilePath() string

func (*AreFilesIdenticalRequest) ProtoMessage 

func (*AreFilesIdenticalRequest) ProtoMessage()

func (*AreFilesIdenticalRequest) ProtoReflect 

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

func (*AreFilesIdenticalRequest) Reset 

func (x *AreFilesIdenticalRequest) Reset()

func (*AreFilesIdenticalRequest) String 

func (x *AreFilesIdenticalRequest) String() string

type AreFilesIdenticalResponse 

type AreFilesIdenticalResponse struct {
	FtpResult    *FtpResult `protobuf:"bytes,1,opt,name=ftp_result,json=ftpResult,proto3" json:"ftp_result,omitempty"`
	AreIdentical bool       `protobuf:"varint,2,opt,name=are_identical,json=areIdentical,proto3" json:"are_identical,omitempty"` // Whether the files are identical.
	// contains filtered or unexported fields
}

func (*AreFilesIdenticalResponse) Descriptor deprecated 

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

Deprecated: Use AreFilesIdenticalResponse.ProtoReflect.Descriptor instead.

func (*AreFilesIdenticalResponse) GetAreIdentical 

func (x *AreFilesIdenticalResponse) GetAreIdentical() bool

func (*AreFilesIdenticalResponse) GetFtpResult 

func (x *AreFilesIdenticalResponse) GetFtpResult() *FtpResult

func (*AreFilesIdenticalResponse) ProtoMessage 

func (*AreFilesIdenticalResponse) ProtoMessage()

func (*AreFilesIdenticalResponse) ProtoReflect 

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

func (*AreFilesIdenticalResponse) Reset 

func (x *AreFilesIdenticalResponse) Reset()

func (*AreFilesIdenticalResponse) String 

func (x *AreFilesIdenticalResponse) String() string

type CreateDirectoryRequest 

type CreateDirectoryRequest struct {
	RemoteDir string `protobuf:"bytes,1,opt,name=remote_dir,json=remoteDir,proto3" json:"remote_dir,omitempty"` // The remote directory to create.
	// contains filtered or unexported fields
}

func (*CreateDirectoryRequest) Descriptor deprecated 

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

Deprecated: Use CreateDirectoryRequest.ProtoReflect.Descriptor instead.

func (*CreateDirectoryRequest) GetRemoteDir 

func (x *CreateDirectoryRequest) GetRemoteDir() string

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 {
	FtpResult *FtpResult `protobuf:"bytes,1,opt,name=ftp_result,json=ftpResult,proto3" json:"ftp_result,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateDirectoryResponse) Descriptor deprecated 

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

Deprecated: Use CreateDirectoryResponse.ProtoReflect.Descriptor instead.

func (*CreateDirectoryResponse) GetFtpResult 

func (x *CreateDirectoryResponse) GetFtpResult() *FtpResult

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 DownloadResponse 

type DownloadResponse struct {
	FtpResult    *FtpResult    `protobuf:"bytes,1,opt,name=ftp_result,json=ftpResult,proto3" json:"ftp_result,omitempty"`
	ProgressData *ProgressData `protobuf:"bytes,2,opt,name=progress_data,json=progressData,proto3" json:"progress_data,omitempty"` // The progress data if result is next
	// contains filtered or unexported fields
}

func (*DownloadResponse) Descriptor deprecated 

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

Deprecated: Use DownloadResponse.ProtoReflect.Descriptor instead.

func (*DownloadResponse) GetFtpResult 

func (x *DownloadResponse) GetFtpResult() *FtpResult

func (*DownloadResponse) GetProgressData 

func (x *DownloadResponse) GetProgressData() *ProgressData

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 FtpResult 

type FtpResult struct {
	Result    FtpResult_Result `protobuf:"varint,1,opt,name=result,proto3,enum=mavsdk.rpc.ftp.FtpResult_Result" json:"result,omitempty"` // Result enum value
	ResultStr string           `protobuf:"bytes,2,opt,name=result_str,json=resultStr,proto3" json:"result_str,omitempty"`                // Human-readable English string describing the result
	// contains filtered or unexported fields
}

Result type.

func (*FtpResult) Descriptor deprecated 

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

Deprecated: Use FtpResult.ProtoReflect.Descriptor instead.

func (*FtpResult) GetResult 

func (x *FtpResult) GetResult() FtpResult_Result

func (*FtpResult) GetResultStr 

func (x *FtpResult) GetResultStr() string

func (*FtpResult) ProtoMessage 

func (*FtpResult) ProtoMessage()

func (*FtpResult) ProtoReflect 

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

func (*FtpResult) Reset 

func (x *FtpResult) Reset()

func (*FtpResult) String 

func (x *FtpResult) String() string

type FtpResult_Result 

type FtpResult_Result int32

Possible results returned for FTP commands 

const (
	FtpResult_RESULT_UNKNOWN             FtpResult_Result = 0  // Unknown result
	FtpResult_RESULT_SUCCESS             FtpResult_Result = 1  // Success
	FtpResult_RESULT_NEXT                FtpResult_Result = 2  // Intermediate message showing progress
	FtpResult_RESULT_TIMEOUT             FtpResult_Result = 3  // Timeout
	FtpResult_RESULT_BUSY                FtpResult_Result = 4  // Operation is already in progress
	FtpResult_RESULT_FILE_IO_ERROR       FtpResult_Result = 5  // File IO operation error
	FtpResult_RESULT_FILE_EXISTS         FtpResult_Result = 6  // File exists already
	FtpResult_RESULT_FILE_DOES_NOT_EXIST FtpResult_Result = 7  // File does not exist
	FtpResult_RESULT_FILE_PROTECTED      FtpResult_Result = 8  // File is write protected
	FtpResult_RESULT_INVALID_PARAMETER   FtpResult_Result = 9  // Invalid parameter
	FtpResult_RESULT_UNSUPPORTED         FtpResult_Result = 10 // Unsupported command
	FtpResult_RESULT_PROTOCOL_ERROR      FtpResult_Result = 11 // General protocol error
	FtpResult_RESULT_NO_SYSTEM           FtpResult_Result = 12 // No system connected
)

func (FtpResult_Result) Descriptor 

func (FtpResult_Result) Descriptor() protoreflect.EnumDescriptor

func (FtpResult_Result) Enum 

func (x FtpResult_Result) Enum() *FtpResult_Result

func (FtpResult_Result) EnumDescriptor deprecated 

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

Deprecated: Use FtpResult_Result.Descriptor instead.

func (FtpResult_Result) Number 

func (x FtpResult_Result) Number() protoreflect.EnumNumber

func (FtpResult_Result) String 

func (x FtpResult_Result) String() string

func (FtpResult_Result) Type 

func (FtpResult_Result) Type() protoreflect.EnumType

type FtpServiceClient 

type FtpServiceClient interface {
	// Resets FTP server in case there are stale open sessions.
	Reset(ctx context.Context, in *ResetRequest, opts ...grpc.CallOption) (*ResetResponse, error)
	// Downloads a file to local directory.
	SubscribeDownload(ctx context.Context, in *SubscribeDownloadRequest, opts ...grpc.CallOption) (FtpService_SubscribeDownloadClient, error)
	// Uploads local file to remote directory.
	SubscribeUpload(ctx context.Context, in *SubscribeUploadRequest, opts ...grpc.CallOption) (FtpService_SubscribeUploadClient, error)
	// Lists items from a remote directory.
	ListDirectory(ctx context.Context, in *ListDirectoryRequest, opts ...grpc.CallOption) (*ListDirectoryResponse, error)
	// Creates a remote directory.
	CreateDirectory(ctx context.Context, in *CreateDirectoryRequest, opts ...grpc.CallOption) (*CreateDirectoryResponse, error)
	// Removes a remote directory.
	RemoveDirectory(ctx context.Context, in *RemoveDirectoryRequest, opts ...grpc.CallOption) (*RemoveDirectoryResponse, error)
	// Removes a remote file.
	RemoveFile(ctx context.Context, in *RemoveFileRequest, opts ...grpc.CallOption) (*RemoveFileResponse, error)
	// Renames a remote file or remote directory.
	Rename(ctx context.Context, in *RenameRequest, opts ...grpc.CallOption) (*RenameResponse, error)
	// Compares a local file to a remote file using a CRC32 checksum.
	AreFilesIdentical(ctx context.Context, in *AreFilesIdenticalRequest, opts ...grpc.CallOption) (*AreFilesIdenticalResponse, error)
	// Set root directory for MAVLink FTP server.
	SetRootDirectory(ctx context.Context, in *SetRootDirectoryRequest, opts ...grpc.CallOption) (*SetRootDirectoryResponse, error)
	// Set target component ID. By default it is the autopilot.
	SetTargetCompid(ctx context.Context, in *SetTargetCompidRequest, opts ...grpc.CallOption) (*SetTargetCompidResponse, error)
	// Get our own component ID.
	GetOurCompid(ctx context.Context, in *GetOurCompidRequest, opts ...grpc.CallOption) (*GetOurCompidResponse, error)
}

FtpServiceClient is the client API for FtpService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewFtpServiceClient 

func NewFtpServiceClient(cc grpc.ClientConnInterface) FtpServiceClient

type FtpServiceServer 

type FtpServiceServer interface {
	// Resets FTP server in case there are stale open sessions.
	Reset(context.Context, *ResetRequest) (*ResetResponse, error)
	// Downloads a file to local directory.
	SubscribeDownload(*SubscribeDownloadRequest, FtpService_SubscribeDownloadServer) error
	// Uploads local file to remote directory.
	SubscribeUpload(*SubscribeUploadRequest, FtpService_SubscribeUploadServer) error
	// Lists items from a remote directory.
	ListDirectory(context.Context, *ListDirectoryRequest) (*ListDirectoryResponse, error)
	// Creates a remote directory.
	CreateDirectory(context.Context, *CreateDirectoryRequest) (*CreateDirectoryResponse, error)
	// Removes a remote directory.
	RemoveDirectory(context.Context, *RemoveDirectoryRequest) (*RemoveDirectoryResponse, error)
	// Removes a remote file.
	RemoveFile(context.Context, *RemoveFileRequest) (*RemoveFileResponse, error)
	// Renames a remote file or remote directory.
	Rename(context.Context, *RenameRequest) (*RenameResponse, error)
	// Compares a local file to a remote file using a CRC32 checksum.
	AreFilesIdentical(context.Context, *AreFilesIdenticalRequest) (*AreFilesIdenticalResponse, error)
	// Set root directory for MAVLink FTP server.
	SetRootDirectory(context.Context, *SetRootDirectoryRequest) (*SetRootDirectoryResponse, error)
	// Set target component ID. By default it is the autopilot.
	SetTargetCompid(context.Context, *SetTargetCompidRequest) (*SetTargetCompidResponse, error)
	// Get our own component ID.
	GetOurCompid(context.Context, *GetOurCompidRequest) (*GetOurCompidResponse, error)
	// contains filtered or unexported methods
}

FtpServiceServer is the server API for FtpService service. All implementations must embed UnimplementedFtpServiceServer for forward compatibility

type FtpService_SubscribeDownloadClient 

type FtpService_SubscribeDownloadClient interface {
	Recv() (*DownloadResponse, error)
	grpc.ClientStream
}

type FtpService_SubscribeDownloadServer 

type FtpService_SubscribeDownloadServer interface {
	Send(*DownloadResponse) error
	grpc.ServerStream
}

type FtpService_SubscribeUploadClient 

type FtpService_SubscribeUploadClient interface {
	Recv() (*UploadResponse, error)
	grpc.ClientStream
}

type FtpService_SubscribeUploadServer 

type FtpService_SubscribeUploadServer interface {
	Send(*UploadResponse) error
	grpc.ServerStream
}

type GetOurCompidRequest 

type GetOurCompidRequest struct {
	// contains filtered or unexported fields
}

func (*GetOurCompidRequest) Descriptor deprecated 

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

Deprecated: Use GetOurCompidRequest.ProtoReflect.Descriptor instead.

func (*GetOurCompidRequest) ProtoMessage 

func (*GetOurCompidRequest) ProtoMessage()

func (*GetOurCompidRequest) ProtoReflect 

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

func (*GetOurCompidRequest) Reset 

func (x *GetOurCompidRequest) Reset()

func (*GetOurCompidRequest) String 

func (x *GetOurCompidRequest) String() string

type GetOurCompidResponse 

type GetOurCompidResponse struct {
	Compid uint32 `protobuf:"varint,1,opt,name=compid,proto3" json:"compid,omitempty"` // Our component ID.
	// contains filtered or unexported fields
}

func (*GetOurCompidResponse) Descriptor deprecated 

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

Deprecated: Use GetOurCompidResponse.ProtoReflect.Descriptor instead.

func (*GetOurCompidResponse) GetCompid 

func (x *GetOurCompidResponse) GetCompid() uint32

func (*GetOurCompidResponse) ProtoMessage 

func (*GetOurCompidResponse) ProtoMessage()

func (*GetOurCompidResponse) ProtoReflect 

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

func (*GetOurCompidResponse) Reset 

func (x *GetOurCompidResponse) Reset()

func (*GetOurCompidResponse) String 

func (x *GetOurCompidResponse) String() string

type ListDirectoryRequest 

type ListDirectoryRequest struct {
	RemoteDir string `protobuf:"bytes,1,opt,name=remote_dir,json=remoteDir,proto3" json:"remote_dir,omitempty"` // The remote directory to list the contents for.
	// contains filtered or unexported fields
}

func (*ListDirectoryRequest) Descriptor deprecated 

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

Deprecated: Use ListDirectoryRequest.ProtoReflect.Descriptor instead.

func (*ListDirectoryRequest) GetRemoteDir 

func (x *ListDirectoryRequest) GetRemoteDir() 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 {
	FtpResult *FtpResult `protobuf:"bytes,1,opt,name=ftp_result,json=ftpResult,proto3" json:"ftp_result,omitempty"`
	Paths     []string   `protobuf:"bytes,2,rep,name=paths,proto3" json:"paths,omitempty"` // The found directory contents.
	// contains filtered or unexported fields
}

func (*ListDirectoryResponse) Descriptor deprecated 

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

Deprecated: Use ListDirectoryResponse.ProtoReflect.Descriptor instead.

func (*ListDirectoryResponse) GetFtpResult 

func (x *ListDirectoryResponse) GetFtpResult() *FtpResult

func (*ListDirectoryResponse) GetPaths 

func (x *ListDirectoryResponse) GetPaths() []string

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 ProgressData 

type ProgressData struct {
	BytesTransferred uint32 `protobuf:"varint,1,opt,name=bytes_transferred,json=bytesTransferred,proto3" json:"bytes_transferred,omitempty"` // The number of bytes already transferred.
	TotalBytes       uint32 `protobuf:"varint,2,opt,name=total_bytes,json=totalBytes,proto3" json:"total_bytes,omitempty"`                   // The total bytes to transfer.
	// contains filtered or unexported fields
}

Progress data type for file transfer.

func (*ProgressData) Descriptor deprecated 

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

Deprecated: Use ProgressData.ProtoReflect.Descriptor instead.

func (*ProgressData) GetBytesTransferred 

func (x *ProgressData) GetBytesTransferred() uint32

func (*ProgressData) GetTotalBytes 

func (x *ProgressData) GetTotalBytes() uint32

func (*ProgressData) ProtoMessage 

func (*ProgressData) ProtoMessage()

func (*ProgressData) ProtoReflect 

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

func (*ProgressData) Reset 

func (x *ProgressData) Reset()

func (*ProgressData) String 

func (x *ProgressData) String() string

type RemoveDirectoryRequest 

type RemoveDirectoryRequest struct {
	RemoteDir string `protobuf:"bytes,1,opt,name=remote_dir,json=remoteDir,proto3" json:"remote_dir,omitempty"` // The remote directory to remove.
	// contains filtered or unexported fields
}

func (*RemoveDirectoryRequest) Descriptor deprecated 

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

Deprecated: Use RemoveDirectoryRequest.ProtoReflect.Descriptor instead.

func (*RemoveDirectoryRequest) GetRemoteDir 

func (x *RemoveDirectoryRequest) GetRemoteDir() 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 {
	FtpResult *FtpResult `protobuf:"bytes,1,opt,name=ftp_result,json=ftpResult,proto3" json:"ftp_result,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveDirectoryResponse) Descriptor deprecated 

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

Deprecated: Use RemoveDirectoryResponse.ProtoReflect.Descriptor instead.

func (*RemoveDirectoryResponse) GetFtpResult 

func (x *RemoveDirectoryResponse) GetFtpResult() *FtpResult

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 {
	RemoteFilePath string `protobuf:"bytes,1,opt,name=remote_file_path,json=remoteFilePath,proto3" json:"remote_file_path,omitempty"` // The path of the remote file to remove.
	// contains filtered or unexported fields
}

func (*RemoveFileRequest) Descriptor deprecated 

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

Deprecated: Use RemoveFileRequest.ProtoReflect.Descriptor instead.

func (*RemoveFileRequest) GetRemoteFilePath 

func (x *RemoveFileRequest) GetRemoteFilePath() 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 {
	FtpResult *FtpResult `protobuf:"bytes,1,opt,name=ftp_result,json=ftpResult,proto3" json:"ftp_result,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveFileResponse) Descriptor deprecated 

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

Deprecated: Use RemoveFileResponse.ProtoReflect.Descriptor instead.

func (*RemoveFileResponse) GetFtpResult 

func (x *RemoveFileResponse) GetFtpResult() *FtpResult

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 RenameRequest 

type RenameRequest struct {
	RemoteFromPath string `protobuf:"bytes,1,opt,name=remote_from_path,json=remoteFromPath,proto3" json:"remote_from_path,omitempty"` // The remote source path.
	RemoteToPath   string `protobuf:"bytes,2,opt,name=remote_to_path,json=remoteToPath,proto3" json:"remote_to_path,omitempty"`       // The remote destination path.
	// contains filtered or unexported fields
}

func (*RenameRequest) Descriptor deprecated 

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

Deprecated: Use RenameRequest.ProtoReflect.Descriptor instead.

func (*RenameRequest) GetRemoteFromPath 

func (x *RenameRequest) GetRemoteFromPath() string

func (*RenameRequest) GetRemoteToPath 

func (x *RenameRequest) GetRemoteToPath() string

func (*RenameRequest) ProtoMessage 

func (*RenameRequest) ProtoMessage()

func (*RenameRequest) ProtoReflect 

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

func (*RenameRequest) Reset 

func (x *RenameRequest) Reset()

func (*RenameRequest) String 

func (x *RenameRequest) String() string

type RenameResponse 

type RenameResponse struct {
	FtpResult *FtpResult `protobuf:"bytes,1,opt,name=ftp_result,json=ftpResult,proto3" json:"ftp_result,omitempty"`
	// contains filtered or unexported fields
}

func (*RenameResponse) Descriptor deprecated 

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

Deprecated: Use RenameResponse.ProtoReflect.Descriptor instead.

func (*RenameResponse) GetFtpResult 

func (x *RenameResponse) GetFtpResult() *FtpResult

func (*RenameResponse) ProtoMessage 

func (*RenameResponse) ProtoMessage()

func (*RenameResponse) ProtoReflect 

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

func (*RenameResponse) Reset 

func (x *RenameResponse) Reset()

func (*RenameResponse) String 

func (x *RenameResponse) String() string

type ResetRequest 

type ResetRequest struct {
	// contains filtered or unexported fields
}

func (*ResetRequest) Descriptor deprecated 

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

Deprecated: Use ResetRequest.ProtoReflect.Descriptor instead.

func (*ResetRequest) ProtoMessage 

func (*ResetRequest) ProtoMessage()

func (*ResetRequest) ProtoReflect 

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

func (*ResetRequest) Reset 

func (x *ResetRequest) Reset()

func (*ResetRequest) String 

func (x *ResetRequest) String() string

type ResetResponse 

type ResetResponse struct {
	FtpResult *FtpResult `protobuf:"bytes,1,opt,name=ftp_result,json=ftpResult,proto3" json:"ftp_result,omitempty"`
	// contains filtered or unexported fields
}

func (*ResetResponse) Descriptor deprecated 

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

Deprecated: Use ResetResponse.ProtoReflect.Descriptor instead.

func (*ResetResponse) GetFtpResult 

func (x *ResetResponse) GetFtpResult() *FtpResult

func (*ResetResponse) ProtoMessage 

func (*ResetResponse) ProtoMessage()

func (*ResetResponse) ProtoReflect 

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

func (*ResetResponse) Reset 

func (x *ResetResponse) Reset()

func (*ResetResponse) String 

func (x *ResetResponse) String() string

type ServiceImpl 

type ServiceImpl struct {
	Client FtpServiceClient
}

func (*ServiceImpl) AreFilesIdentical 

func (s *ServiceImpl) AreFilesIdentical(ctx context.Context, localFilePath string, remoteFilePath string) (*AreFilesIdenticalResponse, error)

func (*ServiceImpl) CreateDirectory 

func (s *ServiceImpl) CreateDirectory(ctx context.Context, remoteDir string) (*CreateDirectoryResponse, error)

func (*ServiceImpl) Download 

func (a *ServiceImpl) Download(ctx context.Context, remoteFilePath string, localDir string) (<-chan *ProgressData, error)

func (*ServiceImpl) GetOurCompid 

func (s *ServiceImpl) GetOurCompid(ctx context.Context) (*GetOurCompidResponse, error)

func (*ServiceImpl) ListDirectory 

func (s *ServiceImpl) ListDirectory(ctx context.Context, remoteDir string) (*ListDirectoryResponse, error)

func (*ServiceImpl) RemoveDirectory 

func (s *ServiceImpl) RemoveDirectory(ctx context.Context, remoteDir string) (*RemoveDirectoryResponse, error)

func (*ServiceImpl) RemoveFile 

func (s *ServiceImpl) RemoveFile(ctx context.Context, remoteFilePath string) (*RemoveFileResponse, error)

func (*ServiceImpl) Rename 

func (s *ServiceImpl) Rename(ctx context.Context, remoteFromPath string, remoteToPath string) (*RenameResponse, error)

func (*ServiceImpl) Reset 

func (s *ServiceImpl) Reset(ctx context.Context) (*ResetResponse, error)

func (*ServiceImpl) SetRootDirectory 

func (s *ServiceImpl) SetRootDirectory(ctx context.Context, rootDir string) (*SetRootDirectoryResponse, error)

func (*ServiceImpl) SetTargetCompid 

func (s *ServiceImpl) SetTargetCompid(ctx context.Context, compid uint32) (*SetTargetCompidResponse, error)

func (*ServiceImpl) Upload 

func (a *ServiceImpl) Upload(ctx context.Context, localFilePath string, remoteDir string) (<-chan *ProgressData, error)

type SetRootDirectoryRequest 

type SetRootDirectoryRequest struct {
	RootDir string `protobuf:"bytes,1,opt,name=root_dir,json=rootDir,proto3" json:"root_dir,omitempty"` // The root directory to set.
	// contains filtered or unexported fields
}

func (*SetRootDirectoryRequest) Descriptor deprecated 

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

Deprecated: Use SetRootDirectoryRequest.ProtoReflect.Descriptor instead.

func (*SetRootDirectoryRequest) GetRootDir 

func (x *SetRootDirectoryRequest) GetRootDir() string

func (*SetRootDirectoryRequest) ProtoMessage 

func (*SetRootDirectoryRequest) ProtoMessage()

func (*SetRootDirectoryRequest) ProtoReflect 

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

func (*SetRootDirectoryRequest) Reset 

func (x *SetRootDirectoryRequest) Reset()

func (*SetRootDirectoryRequest) String 

func (x *SetRootDirectoryRequest) String() string

type SetRootDirectoryResponse 

type SetRootDirectoryResponse struct {
	FtpResult *FtpResult `protobuf:"bytes,1,opt,name=ftp_result,json=ftpResult,proto3" json:"ftp_result,omitempty"`
	// contains filtered or unexported fields
}

func (*SetRootDirectoryResponse) Descriptor deprecated 

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

Deprecated: Use SetRootDirectoryResponse.ProtoReflect.Descriptor instead.

func (*SetRootDirectoryResponse) GetFtpResult 

func (x *SetRootDirectoryResponse) GetFtpResult() *FtpResult

func (*SetRootDirectoryResponse) ProtoMessage 

func (*SetRootDirectoryResponse) ProtoMessage()

func (*SetRootDirectoryResponse) ProtoReflect 

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

func (*SetRootDirectoryResponse) Reset 

func (x *SetRootDirectoryResponse) Reset()

func (*SetRootDirectoryResponse) String 

func (x *SetRootDirectoryResponse) String() string

type SetTargetCompidRequest 

type SetTargetCompidRequest struct {
	Compid uint32 `protobuf:"varint,1,opt,name=compid,proto3" json:"compid,omitempty"` // The component ID to set.
	// contains filtered or unexported fields
}

func (*SetTargetCompidRequest) Descriptor deprecated 

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

Deprecated: Use SetTargetCompidRequest.ProtoReflect.Descriptor instead.

func (*SetTargetCompidRequest) GetCompid 

func (x *SetTargetCompidRequest) GetCompid() uint32

func (*SetTargetCompidRequest) ProtoMessage 

func (*SetTargetCompidRequest) ProtoMessage()

func (*SetTargetCompidRequest) ProtoReflect 

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

func (*SetTargetCompidRequest) Reset 

func (x *SetTargetCompidRequest) Reset()

func (*SetTargetCompidRequest) String 

func (x *SetTargetCompidRequest) String() string

type SetTargetCompidResponse 

type SetTargetCompidResponse struct {
	FtpResult *FtpResult `protobuf:"bytes,1,opt,name=ftp_result,json=ftpResult,proto3" json:"ftp_result,omitempty"`
	// contains filtered or unexported fields
}

func (*SetTargetCompidResponse) Descriptor deprecated 

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

Deprecated: Use SetTargetCompidResponse.ProtoReflect.Descriptor instead.

func (*SetTargetCompidResponse) GetFtpResult 

func (x *SetTargetCompidResponse) GetFtpResult() *FtpResult

func (*SetTargetCompidResponse) ProtoMessage 

func (*SetTargetCompidResponse) ProtoMessage()

func (*SetTargetCompidResponse) ProtoReflect 

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

func (*SetTargetCompidResponse) Reset 

func (x *SetTargetCompidResponse) Reset()

func (*SetTargetCompidResponse) String 

func (x *SetTargetCompidResponse) String() string

type SubscribeDownloadRequest 

type SubscribeDownloadRequest struct {
	RemoteFilePath string `protobuf:"bytes,1,opt,name=remote_file_path,json=remoteFilePath,proto3" json:"remote_file_path,omitempty"` // The path of the remote file to download.
	LocalDir       string `protobuf:"bytes,2,opt,name=local_dir,json=localDir,proto3" json:"local_dir,omitempty"`                     // The local directory to download to.
	// contains filtered or unexported fields
}

func (*SubscribeDownloadRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeDownloadRequest.ProtoReflect.Descriptor instead.

func (*SubscribeDownloadRequest) GetLocalDir 

func (x *SubscribeDownloadRequest) GetLocalDir() string

func (*SubscribeDownloadRequest) GetRemoteFilePath 

func (x *SubscribeDownloadRequest) GetRemoteFilePath() string

func (*SubscribeDownloadRequest) ProtoMessage 

func (*SubscribeDownloadRequest) ProtoMessage()

func (*SubscribeDownloadRequest) ProtoReflect 

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

func (*SubscribeDownloadRequest) Reset 

func (x *SubscribeDownloadRequest) Reset()

func (*SubscribeDownloadRequest) String 

func (x *SubscribeDownloadRequest) String() string

type SubscribeUploadRequest 

type SubscribeUploadRequest struct {
	LocalFilePath string `protobuf:"bytes,1,opt,name=local_file_path,json=localFilePath,proto3" json:"local_file_path,omitempty"` // The local file path to upload.
	RemoteDir     string `protobuf:"bytes,2,opt,name=remote_dir,json=remoteDir,proto3" json:"remote_dir,omitempty"`               // The remote directory to upload to.
	// contains filtered or unexported fields
}

func (*SubscribeUploadRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeUploadRequest.ProtoReflect.Descriptor instead.

func (*SubscribeUploadRequest) GetLocalFilePath 

func (x *SubscribeUploadRequest) GetLocalFilePath() string

func (*SubscribeUploadRequest) GetRemoteDir 

func (x *SubscribeUploadRequest) GetRemoteDir() string

func (*SubscribeUploadRequest) ProtoMessage 

func (*SubscribeUploadRequest) ProtoMessage()

func (*SubscribeUploadRequest) ProtoReflect 

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

func (*SubscribeUploadRequest) Reset 

func (x *SubscribeUploadRequest) Reset()

func (*SubscribeUploadRequest) String 

func (x *SubscribeUploadRequest) String() string

type UnimplementedFtpServiceServer 

type UnimplementedFtpServiceServer struct {
}

UnimplementedFtpServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedFtpServiceServer) AreFilesIdentical 

func (UnimplementedFtpServiceServer) AreFilesIdentical(context.Context, *AreFilesIdenticalRequest) (*AreFilesIdenticalResponse, error)

func (UnimplementedFtpServiceServer) CreateDirectory 

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

func (UnimplementedFtpServiceServer) GetOurCompid 

func (UnimplementedFtpServiceServer) GetOurCompid(context.Context, *GetOurCompidRequest) (*GetOurCompidResponse, error)

func (UnimplementedFtpServiceServer) ListDirectory 

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

func (UnimplementedFtpServiceServer) RemoveDirectory 

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

func (UnimplementedFtpServiceServer) RemoveFile 

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

func (UnimplementedFtpServiceServer) Rename 

func (UnimplementedFtpServiceServer) Rename(context.Context, *RenameRequest) (*RenameResponse, error)

func (UnimplementedFtpServiceServer) Reset 

func (UnimplementedFtpServiceServer) Reset(context.Context, *ResetRequest) (*ResetResponse, error)

func (UnimplementedFtpServiceServer) SetRootDirectory 

func (UnimplementedFtpServiceServer) SetRootDirectory(context.Context, *SetRootDirectoryRequest) (*SetRootDirectoryResponse, error)

func (UnimplementedFtpServiceServer) SetTargetCompid 

func (UnimplementedFtpServiceServer) SetTargetCompid(context.Context, *SetTargetCompidRequest) (*SetTargetCompidResponse, error)

func (UnimplementedFtpServiceServer) SubscribeDownload 

func (UnimplementedFtpServiceServer) SubscribeDownload(*SubscribeDownloadRequest, FtpService_SubscribeDownloadServer) error

func (UnimplementedFtpServiceServer) SubscribeUpload 

func (UnimplementedFtpServiceServer) SubscribeUpload(*SubscribeUploadRequest, FtpService_SubscribeUploadServer) error

type UnsafeFtpServiceServer 

type UnsafeFtpServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeFtpServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FtpServiceServer will result in compilation errors.

type UploadResponse 

type UploadResponse struct {
	FtpResult    *FtpResult    `protobuf:"bytes,1,opt,name=ftp_result,json=ftpResult,proto3" json:"ftp_result,omitempty"`
	ProgressData *ProgressData `protobuf:"bytes,2,opt,name=progress_data,json=progressData,proto3" json:"progress_data,omitempty"` // The progress data if result is next
	// contains filtered or unexported fields
}

func (*UploadResponse) Descriptor deprecated 

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

Deprecated: Use UploadResponse.ProtoReflect.Descriptor instead.

func (*UploadResponse) GetFtpResult 

func (x *UploadResponse) GetFtpResult() *FtpResult

func (*UploadResponse) GetProgressData 

func (x *UploadResponse) GetProgressData() *ProgressData

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

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.