fs3

package
v0.0.0-...-700b64f Latest Latest
Warning

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

 Go to latest Published: Dec 31, 2022 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Fs3_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "fs3.Fs3",
	HandlerType: (*Fs3Server)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Copy",
			Handler:    _Fs3_Copy_Handler,
		},
		{
			MethodName: "Remove",
			Handler:    _Fs3_Remove_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _Fs3_Get_Handler,
		},
		{
			MethodName: "Describe",
			Handler:    _Fs3_Describe_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "fs3/fs3.proto",
}

Fs3_ServiceDesc is the grpc.ServiceDesc for Fs3 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 Status_name = map[int32]string{
	0: "UNSPECIFIED",
	1: "GREAT_SUCCESS",
	2: "NOT_FOUND",
	3: "INTERNAL_ERROR",
	4: "ILLEGAL_PATH",
	5: "BAD_REQUEST",
}
View Source 
var Status_value = map[string]int32{
	"UNSPECIFIED":    0,
	"GREAT_SUCCESS":  1,
	"NOT_FOUND":      2,
	"INTERNAL_ERROR": 3,
	"ILLEGAL_PATH":   4,
	"BAD_REQUEST":    5,
}

Functions

func RegisterFs3Server 

func RegisterFs3Server(s grpc.ServiceRegistrar, srv Fs3Server)

Types

type CopyReply 

type CopyReply struct {
	Status               Status   `protobuf:"varint,1,opt,name=status,proto3,enum=fs3.Status" json:"status,omitempty"`
	FilePath             string   `protobuf:"bytes,2,opt,name=file_path,json=filePath,proto3" json:"file_path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CopyReply) Descriptor 

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

func (*CopyReply) GetFilePath 

func (m *CopyReply) GetFilePath() string

func (*CopyReply) GetStatus 

func (m *CopyReply) GetStatus() Status

func (*CopyReply) ProtoMessage 

func (*CopyReply) ProtoMessage()

func (*CopyReply) Reset 

func (m *CopyReply) Reset()

func (*CopyReply) String 

func (m *CopyReply) String() string

func (*CopyReply) XXX_DiscardUnknown 

func (m *CopyReply) XXX_DiscardUnknown()

func (*CopyReply) XXX_Marshal 

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

func (*CopyReply) XXX_Merge 

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

func (*CopyReply) XXX_Size 

func (m *CopyReply) XXX_Size() int

func (*CopyReply) XXX_Unmarshal 

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

type CopyRequest 

type CopyRequest struct {
	FilePath             string   `protobuf:"bytes,1,opt,name=file_path,json=filePath,proto3" json:"file_path,omitempty"`
	FileContent          []byte   `protobuf:"bytes,2,opt,name=file_content,json=fileContent,proto3" json:"file_content,omitempty"`
	Token                string   `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CopyRequest) Descriptor 

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

func (*CopyRequest) GetFileContent 

func (m *CopyRequest) GetFileContent() []byte

func (*CopyRequest) GetFilePath 

func (m *CopyRequest) GetFilePath() string

func (*CopyRequest) GetToken 

func (m *CopyRequest) GetToken() string

func (*CopyRequest) ProtoMessage 

func (*CopyRequest) ProtoMessage()

func (*CopyRequest) Reset 

func (m *CopyRequest) Reset()

func (*CopyRequest) String 

func (m *CopyRequest) String() string

func (*CopyRequest) XXX_DiscardUnknown 

func (m *CopyRequest) XXX_DiscardUnknown()

func (*CopyRequest) XXX_Marshal 

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

func (*CopyRequest) XXX_Merge 

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

func (*CopyRequest) XXX_Size 

func (m *CopyRequest) XXX_Size() int

func (*CopyRequest) XXX_Unmarshal 

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

type DescribeReply 

type DescribeReply struct {
	Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=fs3.Status" json:"status,omitempty"`
	Path   string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// Types that are valid to be assigned to Resource:
	//	*DescribeReply_File_
	//	*DescribeReply_Directory_
	Resource             isDescribeReply_Resource `protobuf_oneof:"resource"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

reply containing description of file or directory

func (*DescribeReply) Descriptor 

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

func (*DescribeReply) GetDirectory 

func (m *DescribeReply) GetDirectory() *DescribeReply_Directory

func (*DescribeReply) GetFile 

func (m *DescribeReply) GetFile() *DescribeReply_File

func (*DescribeReply) GetPath 

func (m *DescribeReply) GetPath() string

func (*DescribeReply) GetResource 

func (m *DescribeReply) GetResource() isDescribeReply_Resource

func (*DescribeReply) GetStatus 

func (m *DescribeReply) GetStatus() Status

func (*DescribeReply) ProtoMessage 

func (*DescribeReply) ProtoMessage()

func (*DescribeReply) Reset 

func (m *DescribeReply) Reset()

func (*DescribeReply) String 

func (m *DescribeReply) String() string

func (*DescribeReply) XXX_DiscardUnknown 

func (m *DescribeReply) XXX_DiscardUnknown()

func (*DescribeReply) XXX_Marshal 

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

func (*DescribeReply) XXX_Merge 

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

func (*DescribeReply) XXX_OneofWrappers 

func (*DescribeReply) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*DescribeReply) XXX_Size 

func (m *DescribeReply) XXX_Size() int

func (*DescribeReply) XXX_Unmarshal 

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

type DescribeReply_Directory 

type DescribeReply_Directory struct {
	Directoryname        string   `protobuf:"bytes,1,opt,name=directoryname,proto3" json:"directoryname,omitempty"`
	Files                []string `protobuf:"bytes,2,rep,name=files,proto3" json:"files,omitempty"`
	Subdirectories       []string `protobuf:"bytes,3,rep,name=subdirectories,proto3" json:"subdirectories,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DescribeReply_Directory) Descriptor 

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

func (*DescribeReply_Directory) GetDirectoryname 

func (m *DescribeReply_Directory) GetDirectoryname() string

func (*DescribeReply_Directory) GetFiles 

func (m *DescribeReply_Directory) GetFiles() []string

func (*DescribeReply_Directory) GetSubdirectories 

func (m *DescribeReply_Directory) GetSubdirectories() []string

func (*DescribeReply_Directory) ProtoMessage 

func (*DescribeReply_Directory) ProtoMessage()

func (*DescribeReply_Directory) Reset 

func (m *DescribeReply_Directory) Reset()

func (*DescribeReply_Directory) String 

func (m *DescribeReply_Directory) String() string

func (*DescribeReply_Directory) XXX_DiscardUnknown 

func (m *DescribeReply_Directory) XXX_DiscardUnknown()

func (*DescribeReply_Directory) XXX_Marshal 

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

func (*DescribeReply_Directory) XXX_Merge 

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

func (*DescribeReply_Directory) XXX_Size 

func (m *DescribeReply_Directory) XXX_Size() int

func (*DescribeReply_Directory) XXX_Unmarshal 

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

type DescribeReply_Directory_ 

type DescribeReply_Directory_ struct {
	Directory *DescribeReply_Directory `protobuf:"bytes,4,opt,name=directory,proto3,oneof"`
}

type DescribeReply_File 

type DescribeReply_File struct {
	Filename             string   `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DescribeReply_File) Descriptor 

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

func (*DescribeReply_File) GetFilename 

func (m *DescribeReply_File) GetFilename() string

func (*DescribeReply_File) ProtoMessage 

func (*DescribeReply_File) ProtoMessage()

func (*DescribeReply_File) Reset 

func (m *DescribeReply_File) Reset()

func (*DescribeReply_File) String 

func (m *DescribeReply_File) String() string

func (*DescribeReply_File) XXX_DiscardUnknown 

func (m *DescribeReply_File) XXX_DiscardUnknown()

func (*DescribeReply_File) XXX_Marshal 

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

func (*DescribeReply_File) XXX_Merge 

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

func (*DescribeReply_File) XXX_Size 

func (m *DescribeReply_File) XXX_Size() int

func (*DescribeReply_File) XXX_Unmarshal 

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

type DescribeReply_File_ 

type DescribeReply_File_ struct {
	File *DescribeReply_File `protobuf:"bytes,3,opt,name=file,proto3,oneof"`
}

type DescribeRequest 

type DescribeRequest struct {
	Path                 string   `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Token                string   `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

request used to get a description of document/directory from server

func (*DescribeRequest) Descriptor 

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

func (*DescribeRequest) GetPath 

func (m *DescribeRequest) GetPath() string

func (*DescribeRequest) GetToken 

func (m *DescribeRequest) GetToken() string

func (*DescribeRequest) ProtoMessage 

func (*DescribeRequest) ProtoMessage()

func (*DescribeRequest) Reset 

func (m *DescribeRequest) Reset()

func (*DescribeRequest) String 

func (m *DescribeRequest) String() string

func (*DescribeRequest) XXX_DiscardUnknown 

func (m *DescribeRequest) XXX_DiscardUnknown()

func (*DescribeRequest) XXX_Marshal 

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

func (*DescribeRequest) XXX_Merge 

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

func (*DescribeRequest) XXX_Size 

func (m *DescribeRequest) XXX_Size() int

func (*DescribeRequest) XXX_Unmarshal 

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

type Fs3Client 

type Fs3Client interface {
	Copy(ctx context.Context, in *CopyRequest, opts ...grpc.CallOption) (*CopyReply, error)
	Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*RemoveReply, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetReply, error)
	Describe(ctx context.Context, in *DescribeRequest, opts ...grpc.CallOption) (*DescribeReply, error)
}

Fs3Client is the client API for Fs3 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 NewFs3Client 

func NewFs3Client(cc grpc.ClientConnInterface) Fs3Client

type Fs3Server 

type Fs3Server interface {
	Copy(context.Context, *CopyRequest) (*CopyReply, error)
	Remove(context.Context, *RemoveRequest) (*RemoveReply, error)
	Get(context.Context, *GetRequest) (*GetReply, error)
	Describe(context.Context, *DescribeRequest) (*DescribeReply, error)
	// contains filtered or unexported methods
}

Fs3Server is the server API for Fs3 service. All implementations must embed UnimplementedFs3Server for forward compatibility

type GetReply 

type GetReply struct {
	Status               Status   `protobuf:"varint,1,opt,name=status,proto3,enum=fs3.Status" json:"status,omitempty"`
	FilePath             string   `protobuf:"bytes,2,opt,name=file_path,json=filePath,proto3" json:"file_path,omitempty"`
	FileContent          []byte   `protobuf:"bytes,3,opt,name=file_content,json=fileContent,proto3" json:"file_content,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetReply) Descriptor 

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

func (*GetReply) GetFileContent 

func (m *GetReply) GetFileContent() []byte

func (*GetReply) GetFilePath 

func (m *GetReply) GetFilePath() string

func (*GetReply) GetStatus 

func (m *GetReply) GetStatus() Status

func (*GetReply) ProtoMessage 

func (*GetReply) ProtoMessage()

func (*GetReply) Reset 

func (m *GetReply) Reset()

func (*GetReply) String 

func (m *GetReply) String() string

func (*GetReply) XXX_DiscardUnknown 

func (m *GetReply) XXX_DiscardUnknown()

func (*GetReply) XXX_Marshal 

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

func (*GetReply) XXX_Merge 

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

func (*GetReply) XXX_Size 

func (m *GetReply) XXX_Size() int

func (*GetReply) XXX_Unmarshal 

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

type GetRequest 

type GetRequest struct {
	FilePath             string   `protobuf:"bytes,1,opt,name=file_path,json=filePath,proto3" json:"file_path,omitempty"`
	Token                string   `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetRequest) Descriptor 

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

func (*GetRequest) GetFilePath 

func (m *GetRequest) GetFilePath() string

func (*GetRequest) GetToken 

func (m *GetRequest) GetToken() string

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (m *GetRequest) Reset()

func (*GetRequest) String 

func (m *GetRequest) String() string

func (*GetRequest) XXX_DiscardUnknown 

func (m *GetRequest) XXX_DiscardUnknown()

func (*GetRequest) XXX_Marshal 

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

func (*GetRequest) XXX_Merge 

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

func (*GetRequest) XXX_Size 

func (m *GetRequest) XXX_Size() int

func (*GetRequest) XXX_Unmarshal 

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

type RemoveReply 

type RemoveReply struct {
	Status               Status   `protobuf:"varint,1,opt,name=status,proto3,enum=fs3.Status" json:"status,omitempty"`
	FilePath             string   `protobuf:"bytes,2,opt,name=file_path,json=filePath,proto3" json:"file_path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveReply) Descriptor 

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

func (*RemoveReply) GetFilePath 

func (m *RemoveReply) GetFilePath() string

func (*RemoveReply) GetStatus 

func (m *RemoveReply) GetStatus() Status

func (*RemoveReply) ProtoMessage 

func (*RemoveReply) ProtoMessage()

func (*RemoveReply) Reset 

func (m *RemoveReply) Reset()

func (*RemoveReply) String 

func (m *RemoveReply) String() string

func (*RemoveReply) XXX_DiscardUnknown 

func (m *RemoveReply) XXX_DiscardUnknown()

func (*RemoveReply) XXX_Marshal 

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

func (*RemoveReply) XXX_Merge 

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

func (*RemoveReply) XXX_Size 

func (m *RemoveReply) XXX_Size() int

func (*RemoveReply) XXX_Unmarshal 

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

type RemoveRequest 

type RemoveRequest struct {
	FilePath             string   `protobuf:"bytes,1,opt,name=file_path,json=filePath,proto3" json:"file_path,omitempty"`
	Token                string   `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveRequest) Descriptor 

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

func (*RemoveRequest) GetFilePath 

func (m *RemoveRequest) GetFilePath() string

func (*RemoveRequest) GetToken 

func (m *RemoveRequest) GetToken() string

func (*RemoveRequest) ProtoMessage 

func (*RemoveRequest) ProtoMessage()

func (*RemoveRequest) Reset 

func (m *RemoveRequest) Reset()

func (*RemoveRequest) String 

func (m *RemoveRequest) String() string

func (*RemoveRequest) XXX_DiscardUnknown 

func (m *RemoveRequest) XXX_DiscardUnknown()

func (*RemoveRequest) XXX_Marshal 

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

func (*RemoveRequest) XXX_Merge 

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

func (*RemoveRequest) XXX_Size 

func (m *RemoveRequest) XXX_Size() int

func (*RemoveRequest) XXX_Unmarshal 

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

type Status 

type Status int32
const (
	Status_UNSPECIFIED    Status = 0
	Status_GREAT_SUCCESS  Status = 1
	Status_NOT_FOUND      Status = 2
	Status_INTERNAL_ERROR Status = 3
	Status_ILLEGAL_PATH   Status = 4
	Status_BAD_REQUEST    Status = 5
)

func (Status) EnumDescriptor 

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

func (Status) String 

func (x Status) String() string

type UnimplementedFs3Server 

type UnimplementedFs3Server struct {
}

UnimplementedFs3Server must be embedded to have forward compatible implementations.

func (UnimplementedFs3Server) Copy 

func (UnimplementedFs3Server) Copy(context.Context, *CopyRequest) (*CopyReply, error)

func (UnimplementedFs3Server) Describe 

func (UnimplementedFs3Server) Describe(context.Context, *DescribeRequest) (*DescribeReply, error)

func (UnimplementedFs3Server) Get 

func (UnimplementedFs3Server) Get(context.Context, *GetRequest) (*GetReply, error)

func (UnimplementedFs3Server) Remove 

func (UnimplementedFs3Server) Remove(context.Context, *RemoveRequest) (*RemoveReply, error)

type UnsafeFs3Server 

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

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

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.