pb

package
v1.2.1 Latest Latest
Warning

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

 Go to latest Published: May 6, 2025 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	FsGrpc_TryStealInodeOwnership_FullMethodName = "/FsGrpc/TryStealInodeOwnership"
	FsGrpc_CreateFile_FullMethodName             = "/FsGrpc/CreateFile"
	FsGrpc_Unlink_FullMethodName                 = "/FsGrpc/Unlink"
	FsGrpc_OpenFile_FullMethodName               = "/FsGrpc/OpenFile"
	FsGrpc_ReleaseFileHandle_FullMethodName      = "/FsGrpc/ReleaseFileHandle"
	FsGrpc_ReadFile_FullMethodName               = "/FsGrpc/ReadFile"
	FsGrpc_WriteFile_FullMethodName              = "/FsGrpc/WriteFile"
	FsGrpc_CreateSymlink_FullMethodName          = "/FsGrpc/CreateSymlink"
	FsGrpc_ReadSymlink_FullMethodName            = "/FsGrpc/ReadSymlink"
	FsGrpc_MkDir_FullMethodName                  = "/FsGrpc/MkDir"
	FsGrpc_RmDir_FullMethodName                  = "/FsGrpc/RmDir"
	FsGrpc_OpenDir_FullMethodName                = "/FsGrpc/OpenDir"
	FsGrpc_ReleaseDirHandle_FullMethodName       = "/FsGrpc/ReleaseDirHandle"
	FsGrpc_ReadDir_FullMethodName                = "/FsGrpc/ReadDir"
	FsGrpc_LookUpInode_FullMethodName            = "/FsGrpc/LookUpInode"
	FsGrpc_LookUpInode2_FullMethodName           = "/FsGrpc/LookUpInode2"
	FsGrpc_GetInodeAttributes_FullMethodName     = "/FsGrpc/GetInodeAttributes"
	FsGrpc_SetInodeAttributes_FullMethodName     = "/FsGrpc/SetInodeAttributes"
	FsGrpc_ForgetInode_FullMethodName            = "/FsGrpc/ForgetInode"
	FsGrpc_ForgetInode2_FullMethodName           = "/FsGrpc/ForgetInode2"
)
View Source 
const (
	Recovery_Unmount_FullMethodName = "/Recovery/Unmount"
)

Variables

View Source 
var File_internal_pb_fs_grpc_proto protoreflect.FileDescriptor
View Source 
var File_internal_pb_recovery_proto protoreflect.FileDescriptor
View Source 
var FsGrpc_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "FsGrpc",
	HandlerType: (*FsGrpcServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "TryStealInodeOwnership",
			Handler:    _FsGrpc_TryStealInodeOwnership_Handler,
		},
		{
			MethodName: "CreateFile",
			Handler:    _FsGrpc_CreateFile_Handler,
		},
		{
			MethodName: "Unlink",
			Handler:    _FsGrpc_Unlink_Handler,
		},
		{
			MethodName: "OpenFile",
			Handler:    _FsGrpc_OpenFile_Handler,
		},
		{
			MethodName: "ReleaseFileHandle",
			Handler:    _FsGrpc_ReleaseFileHandle_Handler,
		},
		{
			MethodName: "ReadFile",
			Handler:    _FsGrpc_ReadFile_Handler,
		},
		{
			MethodName: "WriteFile",
			Handler:    _FsGrpc_WriteFile_Handler,
		},
		{
			MethodName: "CreateSymlink",
			Handler:    _FsGrpc_CreateSymlink_Handler,
		},
		{
			MethodName: "ReadSymlink",
			Handler:    _FsGrpc_ReadSymlink_Handler,
		},
		{
			MethodName: "MkDir",
			Handler:    _FsGrpc_MkDir_Handler,
		},
		{
			MethodName: "RmDir",
			Handler:    _FsGrpc_RmDir_Handler,
		},
		{
			MethodName: "OpenDir",
			Handler:    _FsGrpc_OpenDir_Handler,
		},
		{
			MethodName: "ReleaseDirHandle",
			Handler:    _FsGrpc_ReleaseDirHandle_Handler,
		},
		{
			MethodName: "ReadDir",
			Handler:    _FsGrpc_ReadDir_Handler,
		},
		{
			MethodName: "LookUpInode",
			Handler:    _FsGrpc_LookUpInode_Handler,
		},
		{
			MethodName: "LookUpInode2",
			Handler:    _FsGrpc_LookUpInode2_Handler,
		},
		{
			MethodName: "GetInodeAttributes",
			Handler:    _FsGrpc_GetInodeAttributes_Handler,
		},
		{
			MethodName: "SetInodeAttributes",
			Handler:    _FsGrpc_SetInodeAttributes_Handler,
		},
		{
			MethodName: "ForgetInode",
			Handler:    _FsGrpc_ForgetInode_Handler,
		},
		{
			MethodName: "ForgetInode2",
			Handler:    _FsGrpc_ForgetInode2_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "core/pb/fs_grpc.proto",
}

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

View Source 
var Recovery_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "Recovery",
	HandlerType: (*RecoveryServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Unmount",
			Handler:    _Recovery_Unmount_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "core/pb/recovery.proto",
}

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

Functions

func RegisterFsGrpcServer 

func RegisterFsGrpcServer(s grpc.ServiceRegistrar, srv FsGrpcServer)

func RegisterRecoveryServer 

func RegisterRecoveryServer(s grpc.ServiceRegistrar, srv RecoveryServer)

Types

type AreYouInodeOwnerRequest 

type AreYouInodeOwnerRequest struct {
	InodeId uint64 `protobuf:"varint,1,opt,name=inodeId,proto3" json:"inodeId,omitempty"`
	// contains filtered or unexported fields
}

func (*AreYouInodeOwnerRequest) Descriptor deprecated 

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

Deprecated: Use AreYouInodeOwnerRequest.ProtoReflect.Descriptor instead.

func (*AreYouInodeOwnerRequest) GetInodeId 

func (x *AreYouInodeOwnerRequest) GetInodeId() uint64

func (*AreYouInodeOwnerRequest) ProtoMessage 

func (*AreYouInodeOwnerRequest) ProtoMessage()

func (*AreYouInodeOwnerRequest) ProtoReflect 

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

func (*AreYouInodeOwnerRequest) Reset 

func (x *AreYouInodeOwnerRequest) Reset()

func (*AreYouInodeOwnerRequest) String 

func (x *AreYouInodeOwnerRequest) String() string

type AreYouInodeOwnerResponse 

type AreYouInodeOwnerResponse struct {
	Yes bool `protobuf:"varint,1,opt,name=yes,proto3" json:"yes,omitempty"`
	// contains filtered or unexported fields
}

func (*AreYouInodeOwnerResponse) Descriptor deprecated 

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

Deprecated: Use AreYouInodeOwnerResponse.ProtoReflect.Descriptor instead.

func (*AreYouInodeOwnerResponse) GetYes 

func (x *AreYouInodeOwnerResponse) GetYes() bool

func (*AreYouInodeOwnerResponse) ProtoMessage 

func (*AreYouInodeOwnerResponse) ProtoMessage()

func (*AreYouInodeOwnerResponse) ProtoReflect 

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

func (*AreYouInodeOwnerResponse) Reset 

func (x *AreYouInodeOwnerResponse) Reset()

func (*AreYouInodeOwnerResponse) String 

func (x *AreYouInodeOwnerResponse) String() string

type Attributes 

type Attributes struct {
	Size  uint64               `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
	Mtime *timestamp.Timestamp `protobuf:"bytes,2,opt,name=mtime,proto3" json:"mtime,omitempty"`
	Ctime *timestamp.Timestamp `protobuf:"bytes,3,opt,name=ctime,proto3" json:"ctime,omitempty"`
	Mode  uint32               `protobuf:"varint,4,opt,name=mode,proto3" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

func (*Attributes) Descriptor deprecated 

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

Deprecated: Use Attributes.ProtoReflect.Descriptor instead.

func (*Attributes) GetCtime 

func (x *Attributes) GetCtime() *timestamp.Timestamp

func (*Attributes) GetMode 

func (x *Attributes) GetMode() uint32

func (*Attributes) GetMtime 

func (x *Attributes) GetMtime() *timestamp.Timestamp

func (*Attributes) GetSize 

func (x *Attributes) GetSize() uint64

func (*Attributes) ProtoMessage 

func (*Attributes) ProtoMessage()

func (*Attributes) ProtoReflect 

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

func (*Attributes) Reset 

func (x *Attributes) Reset()

func (*Attributes) String 

func (x *Attributes) String() string

type CreateFileRequest 

type CreateFileRequest struct {
	Parent uint64 `protobuf:"varint,2,opt,name=parent,proto3" json:"parent,omitempty"`
	Name   string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Mode   uint32 `protobuf:"varint,4,opt,name=mode,proto3" json:"mode,omitempty"`
	NodeId uint64 `protobuf:"varint,5,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateFileRequest) Descriptor deprecated 

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

Deprecated: Use CreateFileRequest.ProtoReflect.Descriptor instead.

func (*CreateFileRequest) GetMode 

func (x *CreateFileRequest) GetMode() uint32

func (*CreateFileRequest) GetName 

func (x *CreateFileRequest) GetName() string

func (*CreateFileRequest) GetNodeId 

func (x *CreateFileRequest) GetNodeId() uint64

func (*CreateFileRequest) GetParent 

func (x *CreateFileRequest) GetParent() uint64

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 {
	AnotherOwner *Owner `protobuf:"bytes,1,opt,name=AnotherOwner,proto3,oneof" json:"AnotherOwner,omitempty"`
	// inode to ensure
	Inode *Inode `protobuf:"bytes,2,opt,name=inode,proto3" json:"inode,omitempty"`
	// return values
	Child    uint64      `protobuf:"varint,3,opt,name=child,proto3" json:"child,omitempty"`
	Attr     *Attributes `protobuf:"bytes,4,opt,name=attr,proto3" json:"attr,omitempty"`
	HandleId uint64      `protobuf:"varint,5,opt,name=handleId,proto3" json:"handleId,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateFileResponse) Descriptor deprecated 

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

Deprecated: Use CreateFileResponse.ProtoReflect.Descriptor instead.

func (*CreateFileResponse) GetAnotherOwner 

func (x *CreateFileResponse) GetAnotherOwner() *Owner

func (*CreateFileResponse) GetAttr 

func (x *CreateFileResponse) GetAttr() *Attributes

func (*CreateFileResponse) GetChild 

func (x *CreateFileResponse) GetChild() uint64

func (*CreateFileResponse) GetHandleId 

func (x *CreateFileResponse) GetHandleId() uint64

func (*CreateFileResponse) GetInode 

func (x *CreateFileResponse) GetInode() *Inode

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 CreateSymlinkRequest 

type CreateSymlinkRequest struct {
	Parent uint64 `protobuf:"varint,1,opt,name=parent,proto3" json:"parent,omitempty"`
	Name   string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	NodeId uint64 `protobuf:"varint,4,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateSymlinkRequest) Descriptor deprecated 

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

Deprecated: Use CreateSymlinkRequest.ProtoReflect.Descriptor instead.

func (*CreateSymlinkRequest) GetName 

func (x *CreateSymlinkRequest) GetName() string

func (*CreateSymlinkRequest) GetNodeId 

func (x *CreateSymlinkRequest) GetNodeId() uint64

func (*CreateSymlinkRequest) GetParent 

func (x *CreateSymlinkRequest) GetParent() uint64

func (*CreateSymlinkRequest) GetTarget 

func (x *CreateSymlinkRequest) GetTarget() string

func (*CreateSymlinkRequest) ProtoMessage 

func (*CreateSymlinkRequest) ProtoMessage()

func (*CreateSymlinkRequest) ProtoReflect 

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

func (*CreateSymlinkRequest) Reset 

func (x *CreateSymlinkRequest) Reset()

func (*CreateSymlinkRequest) String 

func (x *CreateSymlinkRequest) String() string

type CreateSymlinkResponse 

type CreateSymlinkResponse struct {
	AnotherOwner *Owner `protobuf:"bytes,1,opt,name=AnotherOwner,proto3,oneof" json:"AnotherOwner,omitempty"`
	// inode to ensure
	Inode *Inode `protobuf:"bytes,2,opt,name=inode,proto3" json:"inode,omitempty"`
	// return values
	Child uint64      `protobuf:"varint,3,opt,name=child,proto3" json:"child,omitempty"`
	Attr  *Attributes `protobuf:"bytes,4,opt,name=attr,proto3" json:"attr,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateSymlinkResponse) Descriptor deprecated 

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

Deprecated: Use CreateSymlinkResponse.ProtoReflect.Descriptor instead.

func (*CreateSymlinkResponse) GetAnotherOwner 

func (x *CreateSymlinkResponse) GetAnotherOwner() *Owner

func (*CreateSymlinkResponse) GetAttr 

func (x *CreateSymlinkResponse) GetAttr() *Attributes

func (*CreateSymlinkResponse) GetChild 

func (x *CreateSymlinkResponse) GetChild() uint64

func (*CreateSymlinkResponse) GetInode 

func (x *CreateSymlinkResponse) GetInode() *Inode

func (*CreateSymlinkResponse) ProtoMessage 

func (*CreateSymlinkResponse) ProtoMessage()

func (*CreateSymlinkResponse) ProtoReflect 

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

func (*CreateSymlinkResponse) Reset 

func (x *CreateSymlinkResponse) Reset()

func (*CreateSymlinkResponse) String 

func (x *CreateSymlinkResponse) String() string

type ForgetInode2Request 

type ForgetInode2Request struct {
	InodeId uint64 `protobuf:"varint,1,opt,name=inodeId,proto3" json:"inodeId,omitempty"`
	// contains filtered or unexported fields
}

func (*ForgetInode2Request) Descriptor deprecated 

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

Deprecated: Use ForgetInode2Request.ProtoReflect.Descriptor instead.

func (*ForgetInode2Request) GetInodeId 

func (x *ForgetInode2Request) GetInodeId() uint64

func (*ForgetInode2Request) ProtoMessage 

func (*ForgetInode2Request) ProtoMessage()

func (*ForgetInode2Request) ProtoReflect 

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

func (*ForgetInode2Request) Reset 

func (x *ForgetInode2Request) Reset()

func (*ForgetInode2Request) String 

func (x *ForgetInode2Request) String() string

type ForgetInode2Response 

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

func (*ForgetInode2Response) Descriptor deprecated 

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

Deprecated: Use ForgetInode2Response.ProtoReflect.Descriptor instead.

func (*ForgetInode2Response) ProtoMessage 

func (*ForgetInode2Response) ProtoMessage()

func (*ForgetInode2Response) ProtoReflect 

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

func (*ForgetInode2Response) Reset 

func (x *ForgetInode2Response) Reset()

func (*ForgetInode2Response) String 

func (x *ForgetInode2Response) String() string

type ForgetInodeRequest 

type ForgetInodeRequest struct {
	InodeId uint64 `protobuf:"varint,1,opt,name=inodeId,proto3" json:"inodeId,omitempty"`
	NodeId  uint64 `protobuf:"varint,2,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	N       uint64 `protobuf:"varint,3,opt,name=n,proto3" json:"n,omitempty"`
	// contains filtered or unexported fields
}

func (*ForgetInodeRequest) Descriptor deprecated 

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

Deprecated: Use ForgetInodeRequest.ProtoReflect.Descriptor instead.

func (*ForgetInodeRequest) GetInodeId 

func (x *ForgetInodeRequest) GetInodeId() uint64

func (*ForgetInodeRequest) GetN 

func (x *ForgetInodeRequest) GetN() uint64

func (*ForgetInodeRequest) GetNodeId 

func (x *ForgetInodeRequest) GetNodeId() uint64

func (*ForgetInodeRequest) ProtoMessage 

func (*ForgetInodeRequest) ProtoMessage()

func (*ForgetInodeRequest) ProtoReflect 

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

func (*ForgetInodeRequest) Reset 

func (x *ForgetInodeRequest) Reset()

func (*ForgetInodeRequest) String 

func (x *ForgetInodeRequest) String() string

type ForgetInodeResponse 

type ForgetInodeResponse struct {
	AnotherOwner *Owner `protobuf:"bytes,1,opt,name=AnotherOwner,proto3,oneof" json:"AnotherOwner,omitempty"`
	Forget       bool   `protobuf:"varint,2,opt,name=forget,proto3" json:"forget,omitempty"`
	// contains filtered or unexported fields
}

func (*ForgetInodeResponse) Descriptor deprecated 

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

Deprecated: Use ForgetInodeResponse.ProtoReflect.Descriptor instead.

func (*ForgetInodeResponse) GetAnotherOwner 

func (x *ForgetInodeResponse) GetAnotherOwner() *Owner

func (*ForgetInodeResponse) GetForget 

func (x *ForgetInodeResponse) GetForget() bool

func (*ForgetInodeResponse) ProtoMessage 

func (*ForgetInodeResponse) ProtoMessage()

func (*ForgetInodeResponse) ProtoReflect 

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

func (*ForgetInodeResponse) Reset 

func (x *ForgetInodeResponse) Reset()

func (*ForgetInodeResponse) String 

func (x *ForgetInodeResponse) String() string

type FsGrpcClient 

type FsGrpcClient interface {
	// stealing
	TryStealInodeOwnership(ctx context.Context, in *TryStealInodeOwnershipRequest, opts ...grpc.CallOption) (*TryStealInodeOwnershipResponse, error)
	// file
	CreateFile(ctx context.Context, in *CreateFileRequest, opts ...grpc.CallOption) (*CreateFileResponse, error)
	Unlink(ctx context.Context, in *UnlinkRequest, opts ...grpc.CallOption) (*UnlinkResponse, error)
	OpenFile(ctx context.Context, in *OpenFileRequest, opts ...grpc.CallOption) (*OpenFileResponse, error)
	ReleaseFileHandle(ctx context.Context, in *ReleaseFileHandleRequest, opts ...grpc.CallOption) (*ReleaseFileHandleResponse, error)
	ReadFile(ctx context.Context, in *ReadFileRequest, opts ...grpc.CallOption) (*ReadFileResponse, error)
	WriteFile(ctx context.Context, in *WriteFileRequest, opts ...grpc.CallOption) (*WriteFileResponse, error)
	// symlinks
	CreateSymlink(ctx context.Context, in *CreateSymlinkRequest, opts ...grpc.CallOption) (*CreateSymlinkResponse, error)
	ReadSymlink(ctx context.Context, in *ReadSymlinkRequest, opts ...grpc.CallOption) (*ReadSymlinkResponse, error)
	// dir
	MkDir(ctx context.Context, in *MkDirRequest, opts ...grpc.CallOption) (*MkDirResponse, error)
	RmDir(ctx context.Context, in *RmDirRequest, opts ...grpc.CallOption) (*RmDirResponse, error)
	OpenDir(ctx context.Context, in *OpenDirRequest, opts ...grpc.CallOption) (*OpenDirResponse, error)
	ReleaseDirHandle(ctx context.Context, in *ReleaseDirHandleRequest, opts ...grpc.CallOption) (*ReleaseDirHandleResponse, error)
	ReadDir(ctx context.Context, in *ReadDirRequest, opts ...grpc.CallOption) (*ReadDirResponse, error)
	LookUpInode(ctx context.Context, in *LookUpInodeRequest, opts ...grpc.CallOption) (*LookUpInodeResponse, error)
	LookUpInode2(ctx context.Context, in *LookUpInode2Request, opts ...grpc.CallOption) (*LookUpInode2Response, error)
	// both
	GetInodeAttributes(ctx context.Context, in *GetInodeAttributesRequest, opts ...grpc.CallOption) (*GetInodeAttributesResponse, error)
	SetInodeAttributes(ctx context.Context, in *SetInodeAttributesRequest, opts ...grpc.CallOption) (*SetInodeAttributesResponse, error)
	ForgetInode(ctx context.Context, in *ForgetInodeRequest, opts ...grpc.CallOption) (*ForgetInodeResponse, error)
	ForgetInode2(ctx context.Context, in *ForgetInode2Request, opts ...grpc.CallOption) (*ForgetInode2Response, error)
}

FsGrpcClient is the client API for FsGrpc 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 NewFsGrpcClient 

func NewFsGrpcClient(cc grpc.ClientConnInterface) FsGrpcClient

type FsGrpcServer 

type FsGrpcServer interface {
	// stealing
	TryStealInodeOwnership(context.Context, *TryStealInodeOwnershipRequest) (*TryStealInodeOwnershipResponse, error)
	// file
	CreateFile(context.Context, *CreateFileRequest) (*CreateFileResponse, error)
	Unlink(context.Context, *UnlinkRequest) (*UnlinkResponse, error)
	OpenFile(context.Context, *OpenFileRequest) (*OpenFileResponse, error)
	ReleaseFileHandle(context.Context, *ReleaseFileHandleRequest) (*ReleaseFileHandleResponse, error)
	ReadFile(context.Context, *ReadFileRequest) (*ReadFileResponse, error)
	WriteFile(context.Context, *WriteFileRequest) (*WriteFileResponse, error)
	// symlinks
	CreateSymlink(context.Context, *CreateSymlinkRequest) (*CreateSymlinkResponse, error)
	ReadSymlink(context.Context, *ReadSymlinkRequest) (*ReadSymlinkResponse, error)
	// dir
	MkDir(context.Context, *MkDirRequest) (*MkDirResponse, error)
	RmDir(context.Context, *RmDirRequest) (*RmDirResponse, error)
	OpenDir(context.Context, *OpenDirRequest) (*OpenDirResponse, error)
	ReleaseDirHandle(context.Context, *ReleaseDirHandleRequest) (*ReleaseDirHandleResponse, error)
	ReadDir(context.Context, *ReadDirRequest) (*ReadDirResponse, error)
	LookUpInode(context.Context, *LookUpInodeRequest) (*LookUpInodeResponse, error)
	LookUpInode2(context.Context, *LookUpInode2Request) (*LookUpInode2Response, error)
	// both
	GetInodeAttributes(context.Context, *GetInodeAttributesRequest) (*GetInodeAttributesResponse, error)
	SetInodeAttributes(context.Context, *SetInodeAttributesRequest) (*SetInodeAttributesResponse, error)
	ForgetInode(context.Context, *ForgetInodeRequest) (*ForgetInodeResponse, error)
	ForgetInode2(context.Context, *ForgetInode2Request) (*ForgetInode2Response, error)
	// contains filtered or unexported methods
}

FsGrpcServer is the server API for FsGrpc service. All implementations must embed UnimplementedFsGrpcServer for forward compatibility

type GetInodeAttributesRequest 

type GetInodeAttributesRequest struct {
	InodeId uint64 `protobuf:"varint,1,opt,name=inodeId,proto3" json:"inodeId,omitempty"`
	// contains filtered or unexported fields
}

func (*GetInodeAttributesRequest) Descriptor deprecated 

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

Deprecated: Use GetInodeAttributesRequest.ProtoReflect.Descriptor instead.

func (*GetInodeAttributesRequest) GetInodeId 

func (x *GetInodeAttributesRequest) GetInodeId() uint64

func (*GetInodeAttributesRequest) ProtoMessage 

func (*GetInodeAttributesRequest) ProtoMessage()

func (*GetInodeAttributesRequest) ProtoReflect 

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

func (*GetInodeAttributesRequest) Reset 

func (x *GetInodeAttributesRequest) Reset()

func (*GetInodeAttributesRequest) String 

func (x *GetInodeAttributesRequest) String() string

type GetInodeAttributesResponse 

type GetInodeAttributesResponse struct {
	AnotherOwner *Owner `protobuf:"bytes,1,opt,name=AnotherOwner,proto3,oneof" json:"AnotherOwner,omitempty"`
	// return values
	Attributes *Attributes `protobuf:"bytes,2,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// contains filtered or unexported fields
}

func (*GetInodeAttributesResponse) Descriptor deprecated 

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

Deprecated: Use GetInodeAttributesResponse.ProtoReflect.Descriptor instead.

func (*GetInodeAttributesResponse) GetAnotherOwner 

func (x *GetInodeAttributesResponse) GetAnotherOwner() *Owner

func (*GetInodeAttributesResponse) GetAttributes 

func (x *GetInodeAttributesResponse) GetAttributes() *Attributes

func (*GetInodeAttributesResponse) ProtoMessage 

func (*GetInodeAttributesResponse) ProtoMessage()

func (*GetInodeAttributesResponse) ProtoReflect 

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

func (*GetInodeAttributesResponse) Reset 

func (x *GetInodeAttributesResponse) Reset()

func (*GetInodeAttributesResponse) String 

func (x *GetInodeAttributesResponse) String() string

type Inode 

type Inode struct {
	Id      uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name    string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Dir     bool   `protobuf:"varint,3,opt,name=dir,proto3" json:"dir,omitempty"`
	Symlink bool   `protobuf:"varint,4,opt,name=symlink,proto3" json:"symlink,omitempty"`
	Owner   *Owner `protobuf:"bytes,5,opt,name=owner,proto3" json:"owner,omitempty"`
	// contains filtered or unexported fields
}

func (*Inode) Descriptor deprecated 

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

Deprecated: Use Inode.ProtoReflect.Descriptor instead.

func (*Inode) GetDir 

func (x *Inode) GetDir() bool

func (*Inode) GetId 

func (x *Inode) GetId() uint64

func (*Inode) GetName 

func (x *Inode) GetName() string

func (*Inode) GetOwner 

func (x *Inode) GetOwner() *Owner
func (x *Inode) GetSymlink() bool

func (*Inode) ProtoMessage 

func (*Inode) ProtoMessage()

func (*Inode) ProtoReflect 

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

func (*Inode) Reset 

func (x *Inode) Reset()

func (*Inode) String 

func (x *Inode) String() string

type JoinClusterRequest 

type JoinClusterRequest struct {
	Url    string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	NodeId uint64 `protobuf:"varint,2,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	// contains filtered or unexported fields
}

func (*JoinClusterRequest) Descriptor deprecated 

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

Deprecated: Use JoinClusterRequest.ProtoReflect.Descriptor instead.

func (*JoinClusterRequest) GetNodeId 

func (x *JoinClusterRequest) GetNodeId() uint64

func (*JoinClusterRequest) GetUrl 

func (x *JoinClusterRequest) GetUrl() string

func (*JoinClusterRequest) ProtoMessage 

func (*JoinClusterRequest) ProtoMessage()

func (*JoinClusterRequest) ProtoReflect 

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

func (*JoinClusterRequest) Reset 

func (x *JoinClusterRequest) Reset()

func (*JoinClusterRequest) String 

func (x *JoinClusterRequest) String() string

type JoinClusterResponse 

type JoinClusterResponse struct {
	NodeId uint64                      `protobuf:"varint,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	Peers  []*JoinClusterResponse_Peer `protobuf:"bytes,2,rep,name=peers,proto3" json:"peers,omitempty"`
	// contains filtered or unexported fields
}

func (*JoinClusterResponse) Descriptor deprecated 

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

Deprecated: Use JoinClusterResponse.ProtoReflect.Descriptor instead.

func (*JoinClusterResponse) GetNodeId 

func (x *JoinClusterResponse) GetNodeId() uint64

func (*JoinClusterResponse) GetPeers 

func (x *JoinClusterResponse) GetPeers() []*JoinClusterResponse_Peer

func (*JoinClusterResponse) ProtoMessage 

func (*JoinClusterResponse) ProtoMessage()

func (*JoinClusterResponse) ProtoReflect 

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

func (*JoinClusterResponse) Reset 

func (x *JoinClusterResponse) Reset()

func (*JoinClusterResponse) String 

func (x *JoinClusterResponse) String() string

type JoinClusterResponse_Peer 

type JoinClusterResponse_Peer struct {
	NodeId uint64 `protobuf:"varint,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	Url    string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

func (*JoinClusterResponse_Peer) Descriptor deprecated 

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

Deprecated: Use JoinClusterResponse_Peer.ProtoReflect.Descriptor instead.

func (*JoinClusterResponse_Peer) GetNodeId 

func (x *JoinClusterResponse_Peer) GetNodeId() uint64

func (*JoinClusterResponse_Peer) GetUrl 

func (x *JoinClusterResponse_Peer) GetUrl() string

func (*JoinClusterResponse_Peer) ProtoMessage 

func (*JoinClusterResponse_Peer) ProtoMessage()

func (*JoinClusterResponse_Peer) ProtoReflect 

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

func (*JoinClusterResponse_Peer) Reset 

func (x *JoinClusterResponse_Peer) Reset()

func (*JoinClusterResponse_Peer) String 

func (x *JoinClusterResponse_Peer) String() string

type LookUpInode2Request 

type LookUpInode2Request struct {
	InodeId uint64 `protobuf:"varint,1,opt,name=inodeId,proto3" json:"inodeId,omitempty"`
	NodeId  uint64 `protobuf:"varint,2,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	// contains filtered or unexported fields
}

func (*LookUpInode2Request) Descriptor deprecated 

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

Deprecated: Use LookUpInode2Request.ProtoReflect.Descriptor instead.

func (*LookUpInode2Request) GetInodeId 

func (x *LookUpInode2Request) GetInodeId() uint64

func (*LookUpInode2Request) GetNodeId 

func (x *LookUpInode2Request) GetNodeId() uint64

func (*LookUpInode2Request) ProtoMessage 

func (*LookUpInode2Request) ProtoMessage()

func (*LookUpInode2Request) ProtoReflect 

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

func (*LookUpInode2Request) Reset 

func (x *LookUpInode2Request) Reset()

func (*LookUpInode2Request) String 

func (x *LookUpInode2Request) String() string

type LookUpInode2Response 

type LookUpInode2Response struct {
	AnotherOwner *Owner      `protobuf:"bytes,1,opt,name=AnotherOwner,proto3,oneof" json:"AnotherOwner,omitempty"`
	Attr         *Attributes `protobuf:"bytes,2,opt,name=attr,proto3" json:"attr,omitempty"`
	// contains filtered or unexported fields
}

func (*LookUpInode2Response) Descriptor deprecated 

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

Deprecated: Use LookUpInode2Response.ProtoReflect.Descriptor instead.

func (*LookUpInode2Response) GetAnotherOwner 

func (x *LookUpInode2Response) GetAnotherOwner() *Owner

func (*LookUpInode2Response) GetAttr 

func (x *LookUpInode2Response) GetAttr() *Attributes

func (*LookUpInode2Response) ProtoMessage 

func (*LookUpInode2Response) ProtoMessage()

func (*LookUpInode2Response) ProtoReflect 

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

func (*LookUpInode2Response) Reset 

func (x *LookUpInode2Response) Reset()

func (*LookUpInode2Response) String 

func (x *LookUpInode2Response) String() string

type LookUpInodeRequest 

type LookUpInodeRequest struct {
	Parent uint64 `protobuf:"varint,1,opt,name=parent,proto3" json:"parent,omitempty"`
	Name   string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	NodeId uint64 `protobuf:"varint,3,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	// contains filtered or unexported fields
}

func (*LookUpInodeRequest) Descriptor deprecated 

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

Deprecated: Use LookUpInodeRequest.ProtoReflect.Descriptor instead.

func (*LookUpInodeRequest) GetName 

func (x *LookUpInodeRequest) GetName() string

func (*LookUpInodeRequest) GetNodeId 

func (x *LookUpInodeRequest) GetNodeId() uint64

func (*LookUpInodeRequest) GetParent 

func (x *LookUpInodeRequest) GetParent() uint64

func (*LookUpInodeRequest) ProtoMessage 

func (*LookUpInodeRequest) ProtoMessage()

func (*LookUpInodeRequest) ProtoReflect 

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

func (*LookUpInodeRequest) Reset 

func (x *LookUpInodeRequest) Reset()

func (*LookUpInodeRequest) String 

func (x *LookUpInodeRequest) String() string

type LookUpInodeResponse 

type LookUpInodeResponse struct {
	AnotherOwner *Owner `protobuf:"bytes,1,opt,name=AnotherOwner,proto3,oneof" json:"AnotherOwner,omitempty"`
	// inode to ensure
	Inode *Inode `protobuf:"bytes,2,opt,name=inode,proto3,oneof" json:"inode,omitempty"`
	// return values
	Child uint64      `protobuf:"varint,3,opt,name=child,proto3" json:"child,omitempty"`
	Attr  *Attributes `protobuf:"bytes,4,opt,name=attr,proto3" json:"attr,omitempty"`
	Errno uint64      `protobuf:"varint,5,opt,name=errno,proto3" json:"errno,omitempty"`
	// contains filtered or unexported fields
}

func (*LookUpInodeResponse) Descriptor deprecated 

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

Deprecated: Use LookUpInodeResponse.ProtoReflect.Descriptor instead.

func (*LookUpInodeResponse) GetAnotherOwner 

func (x *LookUpInodeResponse) GetAnotherOwner() *Owner

func (*LookUpInodeResponse) GetAttr 

func (x *LookUpInodeResponse) GetAttr() *Attributes

func (*LookUpInodeResponse) GetChild 

func (x *LookUpInodeResponse) GetChild() uint64

func (*LookUpInodeResponse) GetErrno 

func (x *LookUpInodeResponse) GetErrno() uint64

func (*LookUpInodeResponse) GetInode 

func (x *LookUpInodeResponse) GetInode() *Inode

func (*LookUpInodeResponse) ProtoMessage 

func (*LookUpInodeResponse) ProtoMessage()

func (*LookUpInodeResponse) ProtoReflect 

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

func (*LookUpInodeResponse) Reset 

func (x *LookUpInodeResponse) Reset()

func (*LookUpInodeResponse) String 

func (x *LookUpInodeResponse) String() string

type MkDirRequest 

type MkDirRequest struct {
	Parent uint64 `protobuf:"varint,2,opt,name=parent,proto3" json:"parent,omitempty"`
	Name   string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Mode   uint32 `protobuf:"varint,4,opt,name=mode,proto3" json:"mode,omitempty"`
	NodeId uint64 `protobuf:"varint,5,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	// contains filtered or unexported fields
}

func (*MkDirRequest) Descriptor deprecated 

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

Deprecated: Use MkDirRequest.ProtoReflect.Descriptor instead.

func (*MkDirRequest) GetMode 

func (x *MkDirRequest) GetMode() uint32

func (*MkDirRequest) GetName 

func (x *MkDirRequest) GetName() string

func (*MkDirRequest) GetNodeId 

func (x *MkDirRequest) GetNodeId() uint64

func (*MkDirRequest) GetParent 

func (x *MkDirRequest) GetParent() uint64

func (*MkDirRequest) ProtoMessage 

func (*MkDirRequest) ProtoMessage()

func (*MkDirRequest) ProtoReflect 

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

func (*MkDirRequest) Reset 

func (x *MkDirRequest) Reset()

func (*MkDirRequest) String 

func (x *MkDirRequest) String() string

type MkDirResponse 

type MkDirResponse struct {
	AnotherOwner *Owner `protobuf:"bytes,1,opt,name=AnotherOwner,proto3,oneof" json:"AnotherOwner,omitempty"`
	// inode to ensure
	Inode *Inode `protobuf:"bytes,2,opt,name=inode,proto3" json:"inode,omitempty"`
	// return values
	Child uint64      `protobuf:"varint,3,opt,name=child,proto3" json:"child,omitempty"`
	Attr  *Attributes `protobuf:"bytes,4,opt,name=attr,proto3" json:"attr,omitempty"`
	// contains filtered or unexported fields
}

func (*MkDirResponse) Descriptor deprecated 

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

Deprecated: Use MkDirResponse.ProtoReflect.Descriptor instead.

func (*MkDirResponse) GetAnotherOwner 

func (x *MkDirResponse) GetAnotherOwner() *Owner

func (*MkDirResponse) GetAttr 

func (x *MkDirResponse) GetAttr() *Attributes

func (*MkDirResponse) GetChild 

func (x *MkDirResponse) GetChild() uint64

func (*MkDirResponse) GetInode 

func (x *MkDirResponse) GetInode() *Inode

func (*MkDirResponse) ProtoMessage 

func (*MkDirResponse) ProtoMessage()

func (*MkDirResponse) ProtoReflect 

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

func (*MkDirResponse) Reset 

func (x *MkDirResponse) Reset()

func (*MkDirResponse) String 

func (x *MkDirResponse) String() string

type OpenDirRequest 

type OpenDirRequest struct {
	InodeId uint64 `protobuf:"varint,1,opt,name=inodeId,proto3" json:"inodeId,omitempty"`
	// contains filtered or unexported fields
}

func (*OpenDirRequest) Descriptor deprecated 

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

Deprecated: Use OpenDirRequest.ProtoReflect.Descriptor instead.

func (*OpenDirRequest) GetInodeId 

func (x *OpenDirRequest) GetInodeId() uint64

func (*OpenDirRequest) ProtoMessage 

func (*OpenDirRequest) ProtoMessage()

func (*OpenDirRequest) ProtoReflect 

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

func (*OpenDirRequest) Reset 

func (x *OpenDirRequest) Reset()

func (*OpenDirRequest) String 

func (x *OpenDirRequest) String() string

type OpenDirResponse 

type OpenDirResponse struct {
	AnotherOwner *Owner `protobuf:"bytes,1,opt,name=AnotherOwner,proto3,oneof" json:"AnotherOwner,omitempty"`
	// return values
	HandleId uint64 `protobuf:"varint,2,opt,name=handleId,proto3" json:"handleId,omitempty"`
	Errno    uint64 `protobuf:"varint,3,opt,name=errno,proto3" json:"errno,omitempty"`
	// contains filtered or unexported fields
}

func (*OpenDirResponse) Descriptor deprecated 

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

Deprecated: Use OpenDirResponse.ProtoReflect.Descriptor instead.

func (*OpenDirResponse) GetAnotherOwner 

func (x *OpenDirResponse) GetAnotherOwner() *Owner

func (*OpenDirResponse) GetErrno 

func (x *OpenDirResponse) GetErrno() uint64

func (*OpenDirResponse) GetHandleId 

func (x *OpenDirResponse) GetHandleId() uint64

func (*OpenDirResponse) ProtoMessage 

func (*OpenDirResponse) ProtoMessage()

func (*OpenDirResponse) ProtoReflect 

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

func (*OpenDirResponse) Reset 

func (x *OpenDirResponse) Reset()

func (*OpenDirResponse) String 

func (x *OpenDirResponse) String() string

type OpenFileRequest 

type OpenFileRequest struct {
	InodeId uint64 `protobuf:"varint,1,opt,name=inodeId,proto3" json:"inodeId,omitempty"`
	// contains filtered or unexported fields
}

func (*OpenFileRequest) Descriptor deprecated 

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

Deprecated: Use OpenFileRequest.ProtoReflect.Descriptor instead.

func (*OpenFileRequest) GetInodeId 

func (x *OpenFileRequest) GetInodeId() uint64

func (*OpenFileRequest) ProtoMessage 

func (*OpenFileRequest) ProtoMessage()

func (*OpenFileRequest) ProtoReflect 

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

func (*OpenFileRequest) Reset 

func (x *OpenFileRequest) Reset()

func (*OpenFileRequest) String 

func (x *OpenFileRequest) String() string

type OpenFileResponse 

type OpenFileResponse struct {
	AnotherOwner *Owner `protobuf:"bytes,1,opt,name=AnotherOwner,proto3,oneof" json:"AnotherOwner,omitempty"`
	// return values
	HandleId uint64 `protobuf:"varint,2,opt,name=handleId,proto3" json:"handleId,omitempty"`
	Errno    uint64 `protobuf:"varint,3,opt,name=errno,proto3" json:"errno,omitempty"`
	// contains filtered or unexported fields
}

func (*OpenFileResponse) Descriptor deprecated 

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

Deprecated: Use OpenFileResponse.ProtoReflect.Descriptor instead.

func (*OpenFileResponse) GetAnotherOwner 

func (x *OpenFileResponse) GetAnotherOwner() *Owner

func (*OpenFileResponse) GetErrno 

func (x *OpenFileResponse) GetErrno() uint64

func (*OpenFileResponse) GetHandleId 

func (x *OpenFileResponse) GetHandleId() uint64

func (*OpenFileResponse) ProtoMessage 

func (*OpenFileResponse) ProtoMessage()

func (*OpenFileResponse) ProtoReflect 

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

func (*OpenFileResponse) Reset 

func (x *OpenFileResponse) Reset()

func (*OpenFileResponse) String 

func (x *OpenFileResponse) String() string

type Owner 

type Owner struct {
	Term   uint64 `protobuf:"varint,1,opt,name=term,proto3" json:"term,omitempty"`
	NodeId uint64 `protobuf:"varint,2,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	// contains filtered or unexported fields
}

func (*Owner) Descriptor deprecated 

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

Deprecated: Use Owner.ProtoReflect.Descriptor instead.

func (*Owner) GetNodeId 

func (x *Owner) GetNodeId() uint64

func (*Owner) GetTerm 

func (x *Owner) GetTerm() uint64

func (*Owner) ProtoMessage 

func (*Owner) ProtoMessage()

func (*Owner) ProtoReflect 

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

func (*Owner) Reset 

func (x *Owner) Reset()

func (*Owner) String 

func (x *Owner) String() string

type ReadDirRequest 

type ReadDirRequest struct {
	CallerId  uint64 `protobuf:"varint,1,opt,name=callerId,proto3" json:"callerId,omitempty"`
	HandleId  uint64 `protobuf:"varint,2,opt,name=handleId,proto3" json:"handleId,omitempty"`
	Offset    uint64 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	Dst       []byte `protobuf:"bytes,4,opt,name=dst,proto3" json:"dst,omitempty"`
	BytesRead int32  `protobuf:"varint,5,opt,name=bytesRead,proto3" json:"bytesRead,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadDirRequest) Descriptor deprecated 

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

Deprecated: Use ReadDirRequest.ProtoReflect.Descriptor instead.

func (*ReadDirRequest) GetBytesRead 

func (x *ReadDirRequest) GetBytesRead() int32

func (*ReadDirRequest) GetCallerId 

func (x *ReadDirRequest) GetCallerId() uint64

func (*ReadDirRequest) GetDst 

func (x *ReadDirRequest) GetDst() []byte

func (*ReadDirRequest) GetHandleId 

func (x *ReadDirRequest) GetHandleId() uint64

func (*ReadDirRequest) GetOffset 

func (x *ReadDirRequest) GetOffset() uint64

func (*ReadDirRequest) ProtoMessage 

func (*ReadDirRequest) ProtoMessage()

func (*ReadDirRequest) ProtoReflect 

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

func (*ReadDirRequest) Reset 

func (x *ReadDirRequest) Reset()

func (*ReadDirRequest) String 

func (x *ReadDirRequest) String() string

type ReadDirResponse 

type ReadDirResponse struct {
	AnotherOwner *Owner `protobuf:"bytes,1,opt,name=AnotherOwner,proto3,oneof" json:"AnotherOwner,omitempty"`
	// return values
	Dst       []byte `protobuf:"bytes,2,opt,name=dst,proto3" json:"dst,omitempty"`
	BytesRead int32  `protobuf:"varint,3,opt,name=bytesRead,proto3" json:"bytesRead,omitempty"`
	Errno     uint64 `protobuf:"varint,4,opt,name=errno,proto3" json:"errno,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadDirResponse) Descriptor deprecated 

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

Deprecated: Use ReadDirResponse.ProtoReflect.Descriptor instead.

func (*ReadDirResponse) GetAnotherOwner 

func (x *ReadDirResponse) GetAnotherOwner() *Owner

func (*ReadDirResponse) GetBytesRead 

func (x *ReadDirResponse) GetBytesRead() int32

func (*ReadDirResponse) GetDst 

func (x *ReadDirResponse) GetDst() []byte

func (*ReadDirResponse) GetErrno 

func (x *ReadDirResponse) GetErrno() uint64

func (*ReadDirResponse) ProtoMessage 

func (*ReadDirResponse) ProtoMessage()

func (*ReadDirResponse) ProtoReflect 

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

func (*ReadDirResponse) Reset 

func (x *ReadDirResponse) Reset()

func (*ReadDirResponse) String 

func (x *ReadDirResponse) String() string

type ReadFileRequest 

type ReadFileRequest struct {
	HandleId uint64 `protobuf:"varint,1,opt,name=handleId,proto3" json:"handleId,omitempty"`
	Offset   int64  `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Size     int64  `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadFileRequest) Descriptor deprecated 

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

Deprecated: Use ReadFileRequest.ProtoReflect.Descriptor instead.

func (*ReadFileRequest) GetHandleId 

func (x *ReadFileRequest) GetHandleId() uint64

func (*ReadFileRequest) GetOffset 

func (x *ReadFileRequest) GetOffset() int64

func (*ReadFileRequest) GetSize 

func (x *ReadFileRequest) GetSize() int64

func (*ReadFileRequest) ProtoMessage 

func (*ReadFileRequest) ProtoMessage()

func (*ReadFileRequest) ProtoReflect 

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

func (*ReadFileRequest) Reset 

func (x *ReadFileRequest) Reset()

func (*ReadFileRequest) String 

func (x *ReadFileRequest) String() string

type ReadFileResponse 

type ReadFileResponse struct {
	AnotherOwner *Owner `protobuf:"bytes,1,opt,name=AnotherOwner,proto3,oneof" json:"AnotherOwner,omitempty"`
	// return values
	BytesRead int32  `protobuf:"varint,2,opt,name=bytesRead,proto3" json:"bytesRead,omitempty"`
	Data      []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	Errno     uint64 `protobuf:"varint,4,opt,name=errno,proto3" json:"errno,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadFileResponse) Descriptor deprecated 

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

Deprecated: Use ReadFileResponse.ProtoReflect.Descriptor instead.

func (*ReadFileResponse) GetAnotherOwner 

func (x *ReadFileResponse) GetAnotherOwner() *Owner

func (*ReadFileResponse) GetBytesRead 

func (x *ReadFileResponse) GetBytesRead() int32

func (*ReadFileResponse) GetData 

func (x *ReadFileResponse) GetData() []byte

func (*ReadFileResponse) GetErrno 

func (x *ReadFileResponse) GetErrno() uint64

func (*ReadFileResponse) ProtoMessage 

func (*ReadFileResponse) ProtoMessage()

func (*ReadFileResponse) ProtoReflect 

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

func (*ReadFileResponse) Reset 

func (x *ReadFileResponse) Reset()

func (*ReadFileResponse) String 

func (x *ReadFileResponse) String() string

type ReadSymlinkRequest 

type ReadSymlinkRequest struct {
	Inode uint64 `protobuf:"varint,1,opt,name=inode,proto3" json:"inode,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadSymlinkRequest) Descriptor deprecated 

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

Deprecated: Use ReadSymlinkRequest.ProtoReflect.Descriptor instead.

func (*ReadSymlinkRequest) GetInode 

func (x *ReadSymlinkRequest) GetInode() uint64

func (*ReadSymlinkRequest) ProtoMessage 

func (*ReadSymlinkRequest) ProtoMessage()

func (*ReadSymlinkRequest) ProtoReflect 

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

func (*ReadSymlinkRequest) Reset 

func (x *ReadSymlinkRequest) Reset()

func (*ReadSymlinkRequest) String 

func (x *ReadSymlinkRequest) String() string

type ReadSymlinkResponse 

type ReadSymlinkResponse struct {
	AnotherOwner *Owner `protobuf:"bytes,1,opt,name=AnotherOwner,proto3,oneof" json:"AnotherOwner,omitempty"`
	Target       string `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	Errno        uint64 `protobuf:"varint,3,opt,name=errno,proto3" json:"errno,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadSymlinkResponse) Descriptor deprecated 

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

Deprecated: Use ReadSymlinkResponse.ProtoReflect.Descriptor instead.

func (*ReadSymlinkResponse) GetAnotherOwner 

func (x *ReadSymlinkResponse) GetAnotherOwner() *Owner

func (*ReadSymlinkResponse) GetErrno 

func (x *ReadSymlinkResponse) GetErrno() uint64

func (*ReadSymlinkResponse) GetTarget 

func (x *ReadSymlinkResponse) GetTarget() string

func (*ReadSymlinkResponse) ProtoMessage 

func (*ReadSymlinkResponse) ProtoMessage()

func (*ReadSymlinkResponse) ProtoReflect 

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

func (*ReadSymlinkResponse) Reset 

func (x *ReadSymlinkResponse) Reset()

func (*ReadSymlinkResponse) String 

func (x *ReadSymlinkResponse) String() string

type RecoveryClient 

type RecoveryClient interface {
	Unmount(ctx context.Context, in *UnmountRequest, opts ...grpc.CallOption) (*UnmountResponse, error)
}

RecoveryClient is the client API for Recovery 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 NewRecoveryClient 

func NewRecoveryClient(cc grpc.ClientConnInterface) RecoveryClient

type RecoveryServer 

type RecoveryServer interface {
	Unmount(context.Context, *UnmountRequest) (*UnmountResponse, error)
	// contains filtered or unexported methods
}

RecoveryServer is the server API for Recovery service. All implementations must embed UnimplementedRecoveryServer for forward compatibility

type ReleaseDirHandleRequest 

type ReleaseDirHandleRequest struct {
	HandleId uint64 `protobuf:"varint,1,opt,name=handleId,proto3" json:"handleId,omitempty"`
	// contains filtered or unexported fields
}

func (*ReleaseDirHandleRequest) Descriptor deprecated 

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

Deprecated: Use ReleaseDirHandleRequest.ProtoReflect.Descriptor instead.

func (*ReleaseDirHandleRequest) GetHandleId 

func (x *ReleaseDirHandleRequest) GetHandleId() uint64

func (*ReleaseDirHandleRequest) ProtoMessage 

func (*ReleaseDirHandleRequest) ProtoMessage()

func (*ReleaseDirHandleRequest) ProtoReflect 

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

func (*ReleaseDirHandleRequest) Reset 

func (x *ReleaseDirHandleRequest) Reset()

func (*ReleaseDirHandleRequest) String 

func (x *ReleaseDirHandleRequest) String() string

type ReleaseDirHandleResponse 

type ReleaseDirHandleResponse struct {
	AnotherOwner *Owner `protobuf:"bytes,1,opt,name=AnotherOwner,proto3,oneof" json:"AnotherOwner,omitempty"`
	// contains filtered or unexported fields
}

func (*ReleaseDirHandleResponse) Descriptor deprecated 

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

Deprecated: Use ReleaseDirHandleResponse.ProtoReflect.Descriptor instead.

func (*ReleaseDirHandleResponse) GetAnotherOwner 

func (x *ReleaseDirHandleResponse) GetAnotherOwner() *Owner

func (*ReleaseDirHandleResponse) ProtoMessage 

func (*ReleaseDirHandleResponse) ProtoMessage()

func (*ReleaseDirHandleResponse) ProtoReflect 

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

func (*ReleaseDirHandleResponse) Reset 

func (x *ReleaseDirHandleResponse) Reset()

func (*ReleaseDirHandleResponse) String 

func (x *ReleaseDirHandleResponse) String() string

type ReleaseFileHandleRequest 

type ReleaseFileHandleRequest struct {
	HandleId uint64 `protobuf:"varint,1,opt,name=handleId,proto3" json:"handleId,omitempty"`
	// contains filtered or unexported fields
}

func (*ReleaseFileHandleRequest) Descriptor deprecated 

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

Deprecated: Use ReleaseFileHandleRequest.ProtoReflect.Descriptor instead.

func (*ReleaseFileHandleRequest) GetHandleId 

func (x *ReleaseFileHandleRequest) GetHandleId() uint64

func (*ReleaseFileHandleRequest) ProtoMessage 

func (*ReleaseFileHandleRequest) ProtoMessage()

func (*ReleaseFileHandleRequest) ProtoReflect 

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

func (*ReleaseFileHandleRequest) Reset 

func (x *ReleaseFileHandleRequest) Reset()

func (*ReleaseFileHandleRequest) String 

func (x *ReleaseFileHandleRequest) String() string

type ReleaseFileHandleResponse 

type ReleaseFileHandleResponse struct {
	AnotherOwner *Owner `protobuf:"bytes,1,opt,name=AnotherOwner,proto3,oneof" json:"AnotherOwner,omitempty"`
	// contains filtered or unexported fields
}

func (*ReleaseFileHandleResponse) Descriptor deprecated 

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

Deprecated: Use ReleaseFileHandleResponse.ProtoReflect.Descriptor instead.

func (*ReleaseFileHandleResponse) GetAnotherOwner 

func (x *ReleaseFileHandleResponse) GetAnotherOwner() *Owner

func (*ReleaseFileHandleResponse) ProtoMessage 

func (*ReleaseFileHandleResponse) ProtoMessage()

func (*ReleaseFileHandleResponse) ProtoReflect 

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

func (*ReleaseFileHandleResponse) Reset 

func (x *ReleaseFileHandleResponse) Reset()

func (*ReleaseFileHandleResponse) String 

func (x *ReleaseFileHandleResponse) String() string

type RmDirRequest 

type RmDirRequest struct {
	Parent uint64 `protobuf:"varint,1,opt,name=parent,proto3" json:"parent,omitempty"`
	Name   string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*RmDirRequest) Descriptor deprecated 

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

Deprecated: Use RmDirRequest.ProtoReflect.Descriptor instead.

func (*RmDirRequest) GetName 

func (x *RmDirRequest) GetName() string

func (*RmDirRequest) GetParent 

func (x *RmDirRequest) GetParent() uint64

func (*RmDirRequest) ProtoMessage 

func (*RmDirRequest) ProtoMessage()

func (*RmDirRequest) ProtoReflect 

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

func (*RmDirRequest) Reset 

func (x *RmDirRequest) Reset()

func (*RmDirRequest) String 

func (x *RmDirRequest) String() string

type RmDirResponse 

type RmDirResponse struct {
	AnotherOwner *Owner `protobuf:"bytes,1,opt,name=AnotherOwner,proto3,oneof" json:"AnotherOwner,omitempty"`
	Errno        uint64 `protobuf:"varint,2,opt,name=errno,proto3" json:"errno,omitempty"`
	// contains filtered or unexported fields
}

func (*RmDirResponse) Descriptor deprecated 

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

Deprecated: Use RmDirResponse.ProtoReflect.Descriptor instead.

func (*RmDirResponse) GetAnotherOwner 

func (x *RmDirResponse) GetAnotherOwner() *Owner

func (*RmDirResponse) GetErrno 

func (x *RmDirResponse) GetErrno() uint64

func (*RmDirResponse) ProtoMessage 

func (*RmDirResponse) ProtoMessage()

func (*RmDirResponse) ProtoReflect 

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

func (*RmDirResponse) Reset 

func (x *RmDirResponse) Reset()

func (*RmDirResponse) String 

func (x *RmDirResponse) String() string

type SetInodeAttributesRequest 

type SetInodeAttributesRequest struct {
	InodeId uint64               `protobuf:"varint,1,opt,name=inodeId,proto3" json:"inodeId,omitempty"`
	Size    *uint64              `protobuf:"varint,2,opt,name=size,proto3,oneof" json:"size,omitempty"`
	Mode    *uint32              `protobuf:"varint,3,opt,name=mode,proto3,oneof" json:"mode,omitempty"`
	Ctime   *timestamp.Timestamp `protobuf:"bytes,4,opt,name=ctime,proto3,oneof" json:"ctime,omitempty"`
	Mtime   *timestamp.Timestamp `protobuf:"bytes,5,opt,name=mtime,proto3,oneof" json:"mtime,omitempty"`
	// contains filtered or unexported fields
}

func (*SetInodeAttributesRequest) Descriptor deprecated 

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

Deprecated: Use SetInodeAttributesRequest.ProtoReflect.Descriptor instead.

func (*SetInodeAttributesRequest) GetCtime 

func (x *SetInodeAttributesRequest) GetCtime() *timestamp.Timestamp

func (*SetInodeAttributesRequest) GetInodeId 

func (x *SetInodeAttributesRequest) GetInodeId() uint64

func (*SetInodeAttributesRequest) GetMode 

func (x *SetInodeAttributesRequest) GetMode() uint32

func (*SetInodeAttributesRequest) GetMtime 

func (x *SetInodeAttributesRequest) GetMtime() *timestamp.Timestamp

func (*SetInodeAttributesRequest) GetSize 

func (x *SetInodeAttributesRequest) GetSize() uint64

func (*SetInodeAttributesRequest) ProtoMessage 

func (*SetInodeAttributesRequest) ProtoMessage()

func (*SetInodeAttributesRequest) ProtoReflect 

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

func (*SetInodeAttributesRequest) Reset 

func (x *SetInodeAttributesRequest) Reset()

func (*SetInodeAttributesRequest) String 

func (x *SetInodeAttributesRequest) String() string

type SetInodeAttributesResponse 

type SetInodeAttributesResponse struct {
	AnotherOwner *Owner `protobuf:"bytes,1,opt,name=AnotherOwner,proto3,oneof" json:"AnotherOwner,omitempty"`
	// return values
	Attributes *Attributes `protobuf:"bytes,2,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// contains filtered or unexported fields
}

func (*SetInodeAttributesResponse) Descriptor deprecated 

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

Deprecated: Use SetInodeAttributesResponse.ProtoReflect.Descriptor instead.

func (*SetInodeAttributesResponse) GetAnotherOwner 

func (x *SetInodeAttributesResponse) GetAnotherOwner() *Owner

func (*SetInodeAttributesResponse) GetAttributes 

func (x *SetInodeAttributesResponse) GetAttributes() *Attributes

func (*SetInodeAttributesResponse) ProtoMessage 

func (*SetInodeAttributesResponse) ProtoMessage()

func (*SetInodeAttributesResponse) ProtoReflect 

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

func (*SetInodeAttributesResponse) Reset 

func (x *SetInodeAttributesResponse) Reset()

func (*SetInodeAttributesResponse) String 

func (x *SetInodeAttributesResponse) String() string

type StolenInode 

type StolenInode struct {
	OwnerTerm    uint64            `protobuf:"varint,1,opt,name=ownerTerm,proto3" json:"ownerTerm,omitempty"`
	Attr         *Attributes       `protobuf:"bytes,3,opt,name=attr,proto3" json:"attr,omitempty"`
	UserMetadata map[string][]byte `` /* 165-byte string literal not displayed */
	Refcnt       int64             `protobuf:"varint,5,opt,name=refcnt,proto3" json:"refcnt,omitempty"`
	Refcnts      map[uint64]uint64 `` /* 157-byte string literal not displayed */
	Children     []*Inode          `protobuf:"bytes,7,rep,name=children,proto3" json:"children,omitempty"`
	// contains filtered or unexported fields
}

func (*StolenInode) Descriptor deprecated 

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

Deprecated: Use StolenInode.ProtoReflect.Descriptor instead.

func (*StolenInode) GetAttr 

func (x *StolenInode) GetAttr() *Attributes

func (*StolenInode) GetChildren 

func (x *StolenInode) GetChildren() []*Inode

func (*StolenInode) GetOwnerTerm 

func (x *StolenInode) GetOwnerTerm() uint64

func (*StolenInode) GetRefcnt 

func (x *StolenInode) GetRefcnt() int64

func (*StolenInode) GetRefcnts 

func (x *StolenInode) GetRefcnts() map[uint64]uint64

func (*StolenInode) GetUserMetadata 

func (x *StolenInode) GetUserMetadata() map[string][]byte

func (*StolenInode) ProtoMessage 

func (*StolenInode) ProtoMessage()

func (*StolenInode) ProtoReflect 

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

func (*StolenInode) Reset 

func (x *StolenInode) Reset()

func (*StolenInode) String 

func (x *StolenInode) String() string

type TryStealInodeOwnershipRequest 

type TryStealInodeOwnershipRequest struct {
	InodeId uint64 `protobuf:"varint,1,opt,name=inodeId,proto3" json:"inodeId,omitempty"`
	NodeId  uint64 `protobuf:"varint,2,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	// contains filtered or unexported fields
}

func (*TryStealInodeOwnershipRequest) Descriptor deprecated 

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

Deprecated: Use TryStealInodeOwnershipRequest.ProtoReflect.Descriptor instead.

func (*TryStealInodeOwnershipRequest) GetInodeId 

func (x *TryStealInodeOwnershipRequest) GetInodeId() uint64

func (*TryStealInodeOwnershipRequest) GetNodeId 

func (x *TryStealInodeOwnershipRequest) GetNodeId() uint64

func (*TryStealInodeOwnershipRequest) ProtoMessage 

func (*TryStealInodeOwnershipRequest) ProtoMessage()

func (*TryStealInodeOwnershipRequest) ProtoReflect 

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

func (*TryStealInodeOwnershipRequest) Reset 

func (x *TryStealInodeOwnershipRequest) Reset()

func (*TryStealInodeOwnershipRequest) String 

func (x *TryStealInodeOwnershipRequest) String() string

type TryStealInodeOwnershipResponse 

type TryStealInodeOwnershipResponse struct {
	AnotherOwner *Owner       `protobuf:"bytes,1,opt,name=AnotherOwner,proto3,oneof" json:"AnotherOwner,omitempty"`
	StolenInode  *StolenInode `protobuf:"bytes,2,opt,name=stolenInode,proto3,oneof" json:"stolenInode,omitempty"`
	// contains filtered or unexported fields
}

func (*TryStealInodeOwnershipResponse) Descriptor deprecated 

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

Deprecated: Use TryStealInodeOwnershipResponse.ProtoReflect.Descriptor instead.

func (*TryStealInodeOwnershipResponse) GetAnotherOwner 

func (x *TryStealInodeOwnershipResponse) GetAnotherOwner() *Owner

func (*TryStealInodeOwnershipResponse) GetStolenInode 

func (x *TryStealInodeOwnershipResponse) GetStolenInode() *StolenInode

func (*TryStealInodeOwnershipResponse) ProtoMessage 

func (*TryStealInodeOwnershipResponse) ProtoMessage()

func (*TryStealInodeOwnershipResponse) ProtoReflect 

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

func (*TryStealInodeOwnershipResponse) Reset 

func (x *TryStealInodeOwnershipResponse) Reset()

func (*TryStealInodeOwnershipResponse) String 

func (x *TryStealInodeOwnershipResponse) String() string

type UnimplementedFsGrpcServer 

type UnimplementedFsGrpcServer struct {
}

UnimplementedFsGrpcServer must be embedded to have forward compatible implementations.

func (UnimplementedFsGrpcServer) CreateFile 

func (UnimplementedFsGrpcServer) CreateFile(context.Context, *CreateFileRequest) (*CreateFileResponse, error)
func (UnimplementedFsGrpcServer) CreateSymlink(context.Context, *CreateSymlinkRequest) (*CreateSymlinkResponse, error)

func (UnimplementedFsGrpcServer) ForgetInode 

func (UnimplementedFsGrpcServer) ForgetInode(context.Context, *ForgetInodeRequest) (*ForgetInodeResponse, error)

func (UnimplementedFsGrpcServer) ForgetInode2 

func (UnimplementedFsGrpcServer) ForgetInode2(context.Context, *ForgetInode2Request) (*ForgetInode2Response, error)

func (UnimplementedFsGrpcServer) GetInodeAttributes 

func (UnimplementedFsGrpcServer) GetInodeAttributes(context.Context, *GetInodeAttributesRequest) (*GetInodeAttributesResponse, error)

func (UnimplementedFsGrpcServer) LookUpInode 

func (UnimplementedFsGrpcServer) LookUpInode(context.Context, *LookUpInodeRequest) (*LookUpInodeResponse, error)

func (UnimplementedFsGrpcServer) LookUpInode2 

func (UnimplementedFsGrpcServer) LookUpInode2(context.Context, *LookUpInode2Request) (*LookUpInode2Response, error)

func (UnimplementedFsGrpcServer) MkDir 

func (UnimplementedFsGrpcServer) MkDir(context.Context, *MkDirRequest) (*MkDirResponse, error)

func (UnimplementedFsGrpcServer) OpenDir 

func (UnimplementedFsGrpcServer) OpenDir(context.Context, *OpenDirRequest) (*OpenDirResponse, error)

func (UnimplementedFsGrpcServer) OpenFile 

func (UnimplementedFsGrpcServer) OpenFile(context.Context, *OpenFileRequest) (*OpenFileResponse, error)

func (UnimplementedFsGrpcServer) ReadDir 

func (UnimplementedFsGrpcServer) ReadDir(context.Context, *ReadDirRequest) (*ReadDirResponse, error)

func (UnimplementedFsGrpcServer) ReadFile 

func (UnimplementedFsGrpcServer) ReadFile(context.Context, *ReadFileRequest) (*ReadFileResponse, error)
func (UnimplementedFsGrpcServer) ReadSymlink(context.Context, *ReadSymlinkRequest) (*ReadSymlinkResponse, error)

func (UnimplementedFsGrpcServer) ReleaseDirHandle 

func (UnimplementedFsGrpcServer) ReleaseDirHandle(context.Context, *ReleaseDirHandleRequest) (*ReleaseDirHandleResponse, error)

func (UnimplementedFsGrpcServer) ReleaseFileHandle 

func (UnimplementedFsGrpcServer) ReleaseFileHandle(context.Context, *ReleaseFileHandleRequest) (*ReleaseFileHandleResponse, error)

func (UnimplementedFsGrpcServer) RmDir 

func (UnimplementedFsGrpcServer) RmDir(context.Context, *RmDirRequest) (*RmDirResponse, error)

func (UnimplementedFsGrpcServer) SetInodeAttributes 

func (UnimplementedFsGrpcServer) SetInodeAttributes(context.Context, *SetInodeAttributesRequest) (*SetInodeAttributesResponse, error)

func (UnimplementedFsGrpcServer) TryStealInodeOwnership 

func (UnimplementedFsGrpcServer) TryStealInodeOwnership(context.Context, *TryStealInodeOwnershipRequest) (*TryStealInodeOwnershipResponse, error)
func (UnimplementedFsGrpcServer) Unlink(context.Context, *UnlinkRequest) (*UnlinkResponse, error)

func (UnimplementedFsGrpcServer) WriteFile 

func (UnimplementedFsGrpcServer) WriteFile(context.Context, *WriteFileRequest) (*WriteFileResponse, error)

type UnimplementedRecoveryServer 

type UnimplementedRecoveryServer struct {
}

UnimplementedRecoveryServer must be embedded to have forward compatible implementations.

func (UnimplementedRecoveryServer) Unmount 

func (UnimplementedRecoveryServer) Unmount(context.Context, *UnmountRequest) (*UnmountResponse, error)

type UnlinkRequest 

type UnlinkRequest struct {
	Parent uint64 `protobuf:"varint,1,opt,name=parent,proto3" json:"parent,omitempty"`
	Name   string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*UnlinkRequest) Descriptor deprecated 

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

Deprecated: Use UnlinkRequest.ProtoReflect.Descriptor instead.

func (*UnlinkRequest) GetName 

func (x *UnlinkRequest) GetName() string

func (*UnlinkRequest) GetParent 

func (x *UnlinkRequest) GetParent() uint64

func (*UnlinkRequest) ProtoMessage 

func (*UnlinkRequest) ProtoMessage()

func (*UnlinkRequest) ProtoReflect 

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

func (*UnlinkRequest) Reset 

func (x *UnlinkRequest) Reset()

func (*UnlinkRequest) String 

func (x *UnlinkRequest) String() string

type UnlinkResponse 

type UnlinkResponse struct {
	AnotherOwner *Owner `protobuf:"bytes,1,opt,name=AnotherOwner,proto3,oneof" json:"AnotherOwner,omitempty"`
	// inode to ensure
	Inode *Inode `protobuf:"bytes,2,opt,name=inode,proto3" json:"inode,omitempty"`
	// return values
	Errno uint64 `protobuf:"varint,3,opt,name=errno,proto3" json:"errno,omitempty"`
	// contains filtered or unexported fields
}

func (*UnlinkResponse) Descriptor deprecated 

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

Deprecated: Use UnlinkResponse.ProtoReflect.Descriptor instead.

func (*UnlinkResponse) GetAnotherOwner 

func (x *UnlinkResponse) GetAnotherOwner() *Owner

func (*UnlinkResponse) GetErrno 

func (x *UnlinkResponse) GetErrno() uint64

func (*UnlinkResponse) GetInode 

func (x *UnlinkResponse) GetInode() *Inode

func (*UnlinkResponse) ProtoMessage 

func (*UnlinkResponse) ProtoMessage()

func (*UnlinkResponse) ProtoReflect 

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

func (*UnlinkResponse) Reset 

func (x *UnlinkResponse) Reset()

func (*UnlinkResponse) String 

func (x *UnlinkResponse) String() string

type UnmountRequest 

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

func (*UnmountRequest) Descriptor deprecated 

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

Deprecated: Use UnmountRequest.ProtoReflect.Descriptor instead.

func (*UnmountRequest) ProtoMessage 

func (*UnmountRequest) ProtoMessage()

func (*UnmountRequest) ProtoReflect 

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

func (*UnmountRequest) Reset 

func (x *UnmountRequest) Reset()

func (*UnmountRequest) String 

func (x *UnmountRequest) String() string

type UnmountResponse 

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

func (*UnmountResponse) Descriptor deprecated 

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

Deprecated: Use UnmountResponse.ProtoReflect.Descriptor instead.

func (*UnmountResponse) ProtoMessage 

func (*UnmountResponse) ProtoMessage()

func (*UnmountResponse) ProtoReflect 

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

func (*UnmountResponse) Reset 

func (x *UnmountResponse) Reset()

func (*UnmountResponse) String 

func (x *UnmountResponse) String() string

type UnsafeFsGrpcServer 

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

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

type UnsafeRecoveryServer 

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

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

type WriteFileRequest 

type WriteFileRequest struct {
	HandleId uint64 `protobuf:"varint,1,opt,name=handleId,proto3" json:"handleId,omitempty"`
	Offset   int64  `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Data     []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteFileRequest) Descriptor deprecated 

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

Deprecated: Use WriteFileRequest.ProtoReflect.Descriptor instead.

func (*WriteFileRequest) GetData 

func (x *WriteFileRequest) GetData() []byte

func (*WriteFileRequest) GetHandleId 

func (x *WriteFileRequest) GetHandleId() uint64

func (*WriteFileRequest) GetOffset 

func (x *WriteFileRequest) GetOffset() int64

func (*WriteFileRequest) ProtoMessage 

func (*WriteFileRequest) ProtoMessage()

func (*WriteFileRequest) ProtoReflect 

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

func (*WriteFileRequest) Reset 

func (x *WriteFileRequest) Reset()

func (*WriteFileRequest) String 

func (x *WriteFileRequest) String() string

type WriteFileResponse 

type WriteFileResponse struct {
	AnotherOwner *Owner `protobuf:"bytes,1,opt,name=AnotherOwner,proto3,oneof" json:"AnotherOwner,omitempty"`
	// return values
	Errno uint64 `protobuf:"varint,2,opt,name=errno,proto3" json:"errno,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteFileResponse) Descriptor deprecated 

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

Deprecated: Use WriteFileResponse.ProtoReflect.Descriptor instead.

func (*WriteFileResponse) GetAnotherOwner 

func (x *WriteFileResponse) GetAnotherOwner() *Owner

func (*WriteFileResponse) GetErrno 

func (x *WriteFileResponse) GetErrno() uint64

func (*WriteFileResponse) ProtoMessage 

func (*WriteFileResponse) ProtoMessage()

func (*WriteFileResponse) ProtoReflect 

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

func (*WriteFileResponse) Reset 

func (x *WriteFileResponse) Reset()

func (*WriteFileResponse) String 

func (x *WriteFileResponse) 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.