Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterFuseFTPServer(s grpc.ServiceRegistrar, srv FuseFTPServer)
- type AddressAndPort
- func (*AddressAndPort) Descriptor() ([]byte, []int)deprecated
- func (x *AddressAndPort) GetIp() []byte
- func (x *AddressAndPort) GetPort() int32
- func (*AddressAndPort) ProtoMessage()
- func (x *AddressAndPort) ProtoReflect() protoreflect.Message
- func (x *AddressAndPort) Reset()
- func (x *AddressAndPort) String() string
- type FuseFTPClient
- type FuseFTPServer
- type MountIdentifier
- type MountRequest
- func (*MountRequest) Descriptor() ([]byte, []int)deprecated
- func (x *MountRequest) GetDirectory() string
- func (x *MountRequest) GetFtpServer() *AddressAndPort
- func (x *MountRequest) GetLogLevel() string
- func (x *MountRequest) GetMountPoint() string
- func (x *MountRequest) GetReadTimeout() *durationpb.Duration
- func (*MountRequest) ProtoMessage()
- func (x *MountRequest) ProtoReflect() protoreflect.Message
- func (x *MountRequest) Reset()
- func (x *MountRequest) String() string
- type SetFtpServerRequest
- func (*SetFtpServerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetFtpServerRequest) GetFtpServer() *AddressAndPort
- func (x *SetFtpServerRequest) GetId() *MountIdentifier
- func (*SetFtpServerRequest) ProtoMessage()
- func (x *SetFtpServerRequest) ProtoReflect() protoreflect.Message
- func (x *SetFtpServerRequest) Reset()
- func (x *SetFtpServerRequest) String() string
- type UnimplementedFuseFTPServer
- func (UnimplementedFuseFTPServer) Mount(context.Context, *MountRequest) (*MountIdentifier, error)
- func (UnimplementedFuseFTPServer) SetFtpServer(context.Context, *SetFtpServerRequest) (*emptypb.Empty, error)
- func (UnimplementedFuseFTPServer) Unmount(context.Context, *MountIdentifier) (*emptypb.Empty, error)
- func (UnimplementedFuseFTPServer) Version(context.Context, *emptypb.Empty) (*VersionInfo, error)
- type UnsafeFuseFTPServer
- type VersionInfo
Constants ¶
const ( FuseFTP_Version_FullMethodName = "/datawire.fuseftp.FuseFTP/Version" FuseFTP_Mount_FullMethodName = "/datawire.fuseftp.FuseFTP/Mount" FuseFTP_Unmount_FullMethodName = "/datawire.fuseftp.FuseFTP/Unmount" FuseFTP_SetFtpServer_FullMethodName = "/datawire.fuseftp.FuseFTP/SetFtpServer" )
Variables ¶
var File_rpc_fuseftp_proto protoreflect.FileDescriptor
var FuseFTP_ServiceDesc = grpc.ServiceDesc{ ServiceName: "datawire.fuseftp.FuseFTP", HandlerType: (*FuseFTPServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Version", Handler: _FuseFTP_Version_Handler, }, { MethodName: "Mount", Handler: _FuseFTP_Mount_Handler, }, { MethodName: "Unmount", Handler: _FuseFTP_Unmount_Handler, }, { MethodName: "SetFtpServer", Handler: _FuseFTP_SetFtpServer_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "rpc/fuseftp.proto", }
FuseFTP_ServiceDesc is the grpc.ServiceDesc for FuseFTP service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterFuseFTPServer ¶
func RegisterFuseFTPServer(s grpc.ServiceRegistrar, srv FuseFTPServer)
Types ¶
type AddressAndPort ¶
type AddressAndPort struct { Ip []byte `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"` Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` // contains filtered or unexported fields }
func (*AddressAndPort) Descriptor
deprecated
func (*AddressAndPort) Descriptor() ([]byte, []int)
Deprecated: Use AddressAndPort.ProtoReflect.Descriptor instead.
func (*AddressAndPort) GetIp ¶
func (x *AddressAndPort) GetIp() []byte
func (*AddressAndPort) GetPort ¶
func (x *AddressAndPort) GetPort() int32
func (*AddressAndPort) ProtoMessage ¶
func (*AddressAndPort) ProtoMessage()
func (*AddressAndPort) ProtoReflect ¶
func (x *AddressAndPort) ProtoReflect() protoreflect.Message
func (*AddressAndPort) Reset ¶
func (x *AddressAndPort) Reset()
func (*AddressAndPort) String ¶
func (x *AddressAndPort) String() string
type FuseFTPClient ¶
type FuseFTPClient interface { // Returns version information from the Connector Version(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*VersionInfo, error) // Mounts a remote directory and returns an identifier for the mount Mount(ctx context.Context, in *MountRequest, opts ...grpc.CallOption) (*MountIdentifier, error) // Unmounts the given identifier Unmount(ctx context.Context, in *MountIdentifier, opts ...grpc.CallOption) (*emptypb.Empty, error) // SetFtpServer changes the FTP server for a given mount identifier SetFtpServer(ctx context.Context, in *SetFtpServerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) }
FuseFTPClient is the client API for FuseFTP 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 NewFuseFTPClient ¶
func NewFuseFTPClient(cc grpc.ClientConnInterface) FuseFTPClient
type FuseFTPServer ¶
type FuseFTPServer interface { // Returns version information from the Connector Version(context.Context, *emptypb.Empty) (*VersionInfo, error) // Mounts a remote directory and returns an identifier for the mount Mount(context.Context, *MountRequest) (*MountIdentifier, error) // Unmounts the given identifier Unmount(context.Context, *MountIdentifier) (*emptypb.Empty, error) // SetFtpServer changes the FTP server for a given mount identifier SetFtpServer(context.Context, *SetFtpServerRequest) (*emptypb.Empty, error) // contains filtered or unexported methods }
FuseFTPServer is the server API for FuseFTP service. All implementations must embed UnimplementedFuseFTPServer for forward compatibility
type MountIdentifier ¶
type MountIdentifier struct { Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*MountIdentifier) Descriptor
deprecated
func (*MountIdentifier) Descriptor() ([]byte, []int)
Deprecated: Use MountIdentifier.ProtoReflect.Descriptor instead.
func (*MountIdentifier) GetId ¶
func (x *MountIdentifier) GetId() int32
func (*MountIdentifier) ProtoMessage ¶
func (*MountIdentifier) ProtoMessage()
func (*MountIdentifier) ProtoReflect ¶
func (x *MountIdentifier) ProtoReflect() protoreflect.Message
func (*MountIdentifier) Reset ¶
func (x *MountIdentifier) Reset()
func (*MountIdentifier) String ¶
func (x *MountIdentifier) String() string
type MountRequest ¶
type MountRequest struct { // The mount point on the local computer. Must be a drive letter on windows MountPoint string `protobuf:"bytes,1,opt,name=mount_point,json=mountPoint,proto3" json:"mount_point,omitempty"` // The ftp_server to connect to FtpServer *AddressAndPort `protobuf:"bytes,2,opt,name=ftp_server,json=ftpServer,proto3" json:"ftp_server,omitempty"` // Read timout ReadTimeout *durationpb.Duration `protobuf:"bytes,3,opt,name=read_timeout,json=readTimeout,proto3" json:"read_timeout,omitempty"` // The directory on the FTP server that gets mounted Directory string `protobuf:"bytes,4,opt,name=directory,proto3" json:"directory,omitempty"` // The logrus log level LogLevel string `protobuf:"bytes,5,opt,name=log_level,json=logLevel,proto3" json:"log_level,omitempty"` // contains filtered or unexported fields }
func (*MountRequest) Descriptor
deprecated
func (*MountRequest) Descriptor() ([]byte, []int)
Deprecated: Use MountRequest.ProtoReflect.Descriptor instead.
func (*MountRequest) GetDirectory ¶
func (x *MountRequest) GetDirectory() string
func (*MountRequest) GetFtpServer ¶
func (x *MountRequest) GetFtpServer() *AddressAndPort
func (*MountRequest) GetLogLevel ¶ added in v0.3.3
func (x *MountRequest) GetLogLevel() string
func (*MountRequest) GetMountPoint ¶
func (x *MountRequest) GetMountPoint() string
func (*MountRequest) GetReadTimeout ¶
func (x *MountRequest) GetReadTimeout() *durationpb.Duration
func (*MountRequest) ProtoMessage ¶
func (*MountRequest) ProtoMessage()
func (*MountRequest) ProtoReflect ¶
func (x *MountRequest) ProtoReflect() protoreflect.Message
func (*MountRequest) Reset ¶
func (x *MountRequest) Reset()
func (*MountRequest) String ¶
func (x *MountRequest) String() string
type SetFtpServerRequest ¶
type SetFtpServerRequest struct { Id *MountIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` FtpServer *AddressAndPort `protobuf:"bytes,2,opt,name=ftp_server,json=ftpServer,proto3" json:"ftp_server,omitempty"` // contains filtered or unexported fields }
func (*SetFtpServerRequest) Descriptor
deprecated
func (*SetFtpServerRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetFtpServerRequest.ProtoReflect.Descriptor instead.
func (*SetFtpServerRequest) GetFtpServer ¶
func (x *SetFtpServerRequest) GetFtpServer() *AddressAndPort
func (*SetFtpServerRequest) GetId ¶
func (x *SetFtpServerRequest) GetId() *MountIdentifier
func (*SetFtpServerRequest) ProtoMessage ¶
func (*SetFtpServerRequest) ProtoMessage()
func (*SetFtpServerRequest) ProtoReflect ¶
func (x *SetFtpServerRequest) ProtoReflect() protoreflect.Message
func (*SetFtpServerRequest) Reset ¶
func (x *SetFtpServerRequest) Reset()
func (*SetFtpServerRequest) String ¶
func (x *SetFtpServerRequest) String() string
type UnimplementedFuseFTPServer ¶
type UnimplementedFuseFTPServer struct { }
UnimplementedFuseFTPServer must be embedded to have forward compatible implementations.
func (UnimplementedFuseFTPServer) Mount ¶
func (UnimplementedFuseFTPServer) Mount(context.Context, *MountRequest) (*MountIdentifier, error)
func (UnimplementedFuseFTPServer) SetFtpServer ¶
func (UnimplementedFuseFTPServer) SetFtpServer(context.Context, *SetFtpServerRequest) (*emptypb.Empty, error)
func (UnimplementedFuseFTPServer) Unmount ¶
func (UnimplementedFuseFTPServer) Unmount(context.Context, *MountIdentifier) (*emptypb.Empty, error)
func (UnimplementedFuseFTPServer) Version ¶
func (UnimplementedFuseFTPServer) Version(context.Context, *emptypb.Empty) (*VersionInfo, error)
type UnsafeFuseFTPServer ¶
type UnsafeFuseFTPServer interface {
// contains filtered or unexported methods
}
UnsafeFuseFTPServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FuseFTPServer will result in compilation errors.
type VersionInfo ¶
type VersionInfo struct { Semver string `protobuf:"bytes,1,opt,name=semver,proto3" json:"semver,omitempty"` // contains filtered or unexported fields }
func (*VersionInfo) Descriptor
deprecated
func (*VersionInfo) Descriptor() ([]byte, []int)
Deprecated: Use VersionInfo.ProtoReflect.Descriptor instead.
func (*VersionInfo) GetSemver ¶
func (x *VersionInfo) GetSemver() string
func (*VersionInfo) ProtoMessage ¶
func (*VersionInfo) ProtoMessage()
func (*VersionInfo) ProtoReflect ¶
func (x *VersionInfo) ProtoReflect() protoreflect.Message
func (*VersionInfo) Reset ¶
func (x *VersionInfo) Reset()
func (*VersionInfo) String ¶
func (x *VersionInfo) String() string