native_storage_fs_grpc

package
v0.0.0-...-3b69245 Latest Latest
Warning

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

 Go to latest Published: Apr 27, 2024 License: AGPL-3.0 Imports: 9 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var FSService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "native_storage_fs.FSService",
	HandlerType: (*FSServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateFile",
			Handler:    _FSService_CreateFile_Handler,
		},
		{
			MethodName: "StatFile",
			Handler:    _FSService_StatFile_Handler,
		},
		{
			MethodName: "UpdateFile",
			Handler:    _FSService_UpdateFile_Handler,
		},
		{
			MethodName: "DeleteFile",
			Handler:    _FSService_DeleteFile_Handler,
		},
		{
			MethodName: "CountFiles",
			Handler:    _FSService_CountFiles_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "UploadFile",
			Handler:       _FSService_UploadFile_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "ListFiles",
			Handler:       _FSService_ListFiles_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Download",
			Handler:       _FSService_Download_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DownloadByPath",
			Handler:       _FSService_DownloadByPath_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DownloadDirect",
			Handler:       _FSService_DownloadDirect_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DownloadDirectByPath",
			Handler:       _FSService_DownloadDirectByPath_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "fs.proto",
}

FSService_ServiceDesc is the grpc.ServiceDesc for FSService 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 File_fs_proto protoreflect.FileDescriptor

Functions

func RegisterFSServiceServer 

func RegisterFSServiceServer(s grpc.ServiceRegistrar, srv FSServiceServer)

Types

type CountFilesRequest 

type CountFilesRequest struct {

	// Namespace where the files are stored
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Bucket UUID where the files are stored
	Bucket string `protobuf:"bytes,2,opt,name=bucket,proto3" json:"bucket,omitempty"`
	// contains filtered or unexported fields
}

func (*CountFilesRequest) Descriptor deprecated 

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

Deprecated: Use CountFilesRequest.ProtoReflect.Descriptor instead.

func (*CountFilesRequest) GetBucket 

func (x *CountFilesRequest) GetBucket() string

func (*CountFilesRequest) GetNamespace 

func (x *CountFilesRequest) GetNamespace() string

func (*CountFilesRequest) ProtoMessage 

func (*CountFilesRequest) ProtoMessage()

func (*CountFilesRequest) ProtoReflect 

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

func (*CountFilesRequest) Reset 

func (x *CountFilesRequest) Reset()

func (*CountFilesRequest) String 

func (x *CountFilesRequest) String() string

type CountFilesResponse 

type CountFilesResponse struct {
	Count uint32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*CountFilesResponse) Descriptor deprecated 

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

Deprecated: Use CountFilesResponse.ProtoReflect.Descriptor instead.

func (*CountFilesResponse) GetCount 

func (x *CountFilesResponse) GetCount() uint32

func (*CountFilesResponse) ProtoMessage 

func (*CountFilesResponse) ProtoMessage()

func (*CountFilesResponse) ProtoReflect 

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

func (*CountFilesResponse) Reset 

func (x *CountFilesResponse) Reset()

func (*CountFilesResponse) String 

func (x *CountFilesResponse) String() string

type CreateFileRequest 

type CreateFileRequest struct {

	// Namespace where the file should be stored
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Unique full path of the file inside bucket.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// Bucket UUID where the file should be stored
	Bucket string `protobuf:"bytes,3,opt,name=bucket,proto3" json:"bucket,omitempty"`
	// Mime type of the file
	MimeType string `protobuf:"bytes,4,opt,name=mimeType,proto3" json:"mimeType,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateFileRequest) Descriptor deprecated 

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

Deprecated: Use CreateFileRequest.ProtoReflect.Descriptor instead.

func (*CreateFileRequest) GetBucket 

func (x *CreateFileRequest) GetBucket() string

func (*CreateFileRequest) GetMimeType 

func (x *CreateFileRequest) GetMimeType() string

func (*CreateFileRequest) GetNamespace 

func (x *CreateFileRequest) GetNamespace() string

func (*CreateFileRequest) GetPath 

func (x *CreateFileRequest) GetPath() string

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

func (*CreateFileResponse) Descriptor deprecated 

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

Deprecated: Use CreateFileResponse.ProtoReflect.Descriptor instead.

func (*CreateFileResponse) GetFile 

func (x *CreateFileResponse) GetFile() *File

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 DeleteFileRequest 

type DeleteFileRequest struct {

	// Namespace where the file is stored
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Unique identifier of the file
	Uuid string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteFileRequest) Descriptor deprecated 

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

Deprecated: Use DeleteFileRequest.ProtoReflect.Descriptor instead.

func (*DeleteFileRequest) GetNamespace 

func (x *DeleteFileRequest) GetNamespace() string

func (*DeleteFileRequest) GetUuid 

func (x *DeleteFileRequest) GetUuid() string

func (*DeleteFileRequest) ProtoMessage 

func (*DeleteFileRequest) ProtoMessage()

func (*DeleteFileRequest) ProtoReflect 

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

func (*DeleteFileRequest) Reset 

func (x *DeleteFileRequest) Reset()

func (*DeleteFileRequest) String 

func (x *DeleteFileRequest) String() string

type DeleteFileResponse 

type DeleteFileResponse struct {
	File *File `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteFileResponse) Descriptor deprecated 

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

Deprecated: Use DeleteFileResponse.ProtoReflect.Descriptor instead.

func (*DeleteFileResponse) GetFile 

func (x *DeleteFileResponse) GetFile() *File

func (*DeleteFileResponse) ProtoMessage 

func (*DeleteFileResponse) ProtoMessage()

func (*DeleteFileResponse) ProtoReflect 

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

func (*DeleteFileResponse) Reset 

func (x *DeleteFileResponse) Reset()

func (*DeleteFileResponse) String 

func (x *DeleteFileResponse) String() string

type DownloadDirectFileByPathRequest 

type DownloadDirectFileByPathRequest struct {

	// Namespace where the file is stored
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Unique full path of the file inside bucket.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// Direct download secret of the file
	DirectDownloadSecret string `protobuf:"bytes,3,opt,name=directDownloadSecret,proto3" json:"directDownloadSecret,omitempty"`
	Bucket               string `protobuf:"bytes,4,opt,name=bucket,proto3" json:"bucket,omitempty"`
	// How much bytes to skip from beginning of the file. 0 means start from beginning
	Seek uint64 `protobuf:"varint,5,opt,name=seek,proto3" json:"seek,omitempty"`
	// How much bytes (at most) to read from the file. 0 means read all bytes from seek position
	Limit uint64 `protobuf:"varint,6,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*DownloadDirectFileByPathRequest) Descriptor deprecated 

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

Deprecated: Use DownloadDirectFileByPathRequest.ProtoReflect.Descriptor instead.

func (*DownloadDirectFileByPathRequest) GetBucket 

func (x *DownloadDirectFileByPathRequest) GetBucket() string

func (*DownloadDirectFileByPathRequest) GetDirectDownloadSecret 

func (x *DownloadDirectFileByPathRequest) GetDirectDownloadSecret() string

func (*DownloadDirectFileByPathRequest) GetLimit 

func (x *DownloadDirectFileByPathRequest) GetLimit() uint64

func (*DownloadDirectFileByPathRequest) GetNamespace 

func (x *DownloadDirectFileByPathRequest) GetNamespace() string

func (*DownloadDirectFileByPathRequest) GetPath 

func (x *DownloadDirectFileByPathRequest) GetPath() string

func (*DownloadDirectFileByPathRequest) GetSeek 

func (x *DownloadDirectFileByPathRequest) GetSeek() uint64

func (*DownloadDirectFileByPathRequest) ProtoMessage 

func (*DownloadDirectFileByPathRequest) ProtoMessage()

func (*DownloadDirectFileByPathRequest) ProtoReflect 

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

func (*DownloadDirectFileByPathRequest) Reset 

func (x *DownloadDirectFileByPathRequest) Reset()

func (*DownloadDirectFileByPathRequest) String 

func (x *DownloadDirectFileByPathRequest) String() string

type DownloadDirectFileByPathResponse 

type DownloadDirectFileByPathResponse struct {

	// File binary data
	DataChunk []byte `protobuf:"bytes,1,opt,name=dataChunk,proto3" json:"dataChunk,omitempty"`
	// contains filtered or unexported fields
}

func (*DownloadDirectFileByPathResponse) Descriptor deprecated 

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

Deprecated: Use DownloadDirectFileByPathResponse.ProtoReflect.Descriptor instead.

func (*DownloadDirectFileByPathResponse) GetDataChunk 

func (x *DownloadDirectFileByPathResponse) GetDataChunk() []byte

func (*DownloadDirectFileByPathResponse) ProtoMessage 

func (*DownloadDirectFileByPathResponse) ProtoMessage()

func (*DownloadDirectFileByPathResponse) ProtoReflect 

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

func (*DownloadDirectFileByPathResponse) Reset 

func (x *DownloadDirectFileByPathResponse) Reset()

func (*DownloadDirectFileByPathResponse) String 

func (x *DownloadDirectFileByPathResponse) String() string

type DownloadDirectFileRequest 

type DownloadDirectFileRequest struct {

	// Namespace where the file is stored
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Unique identifier of the file
	Uuid string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// Direct download secret of the file
	DirectDownloadSecret string `protobuf:"bytes,3,opt,name=directDownloadSecret,proto3" json:"directDownloadSecret,omitempty"`
	// How much bytes to skip from beginning of the file. 0 means start from beginning
	Seek uint64 `protobuf:"varint,4,opt,name=seek,proto3" json:"seek,omitempty"`
	// How much bytes (at most) to read from the file. 0 means read all bytes from seek position
	Limit uint64 `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*DownloadDirectFileRequest) Descriptor deprecated 

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

Deprecated: Use DownloadDirectFileRequest.ProtoReflect.Descriptor instead.

func (*DownloadDirectFileRequest) GetDirectDownloadSecret 

func (x *DownloadDirectFileRequest) GetDirectDownloadSecret() string

func (*DownloadDirectFileRequest) GetLimit 

func (x *DownloadDirectFileRequest) GetLimit() uint64

func (*DownloadDirectFileRequest) GetNamespace 

func (x *DownloadDirectFileRequest) GetNamespace() string

func (*DownloadDirectFileRequest) GetSeek 

func (x *DownloadDirectFileRequest) GetSeek() uint64

func (*DownloadDirectFileRequest) GetUuid 

func (x *DownloadDirectFileRequest) GetUuid() string

func (*DownloadDirectFileRequest) ProtoMessage 

func (*DownloadDirectFileRequest) ProtoMessage()

func (*DownloadDirectFileRequest) ProtoReflect 

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

func (*DownloadDirectFileRequest) Reset 

func (x *DownloadDirectFileRequest) Reset()

func (*DownloadDirectFileRequest) String 

func (x *DownloadDirectFileRequest) String() string

type DownloadDirectFileResponse 

type DownloadDirectFileResponse struct {

	// File binary data
	DataChunk []byte `protobuf:"bytes,1,opt,name=dataChunk,proto3" json:"dataChunk,omitempty"`
	// contains filtered or unexported fields
}

func (*DownloadDirectFileResponse) Descriptor deprecated 

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

Deprecated: Use DownloadDirectFileResponse.ProtoReflect.Descriptor instead.

func (*DownloadDirectFileResponse) GetDataChunk 

func (x *DownloadDirectFileResponse) GetDataChunk() []byte

func (*DownloadDirectFileResponse) ProtoMessage 

func (*DownloadDirectFileResponse) ProtoMessage()

func (*DownloadDirectFileResponse) ProtoReflect 

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

func (*DownloadDirectFileResponse) Reset 

func (x *DownloadDirectFileResponse) Reset()

func (*DownloadDirectFileResponse) String 

func (x *DownloadDirectFileResponse) String() string

type DownloadFileByPathRequest 

type DownloadFileByPathRequest struct {

	// Namespace where the file is stored
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Unique full path of the file inside bucket.
	Path   string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	Bucket string `protobuf:"bytes,3,opt,name=bucket,proto3" json:"bucket,omitempty"`
	// How much bytes to skip from beginning of the file. 0 means start from beginning
	Seek uint64 `protobuf:"varint,4,opt,name=seek,proto3" json:"seek,omitempty"`
	// How much bytes (at most) to read from the file. 0 means read all bytes from seek position
	Limit uint64 `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*DownloadFileByPathRequest) Descriptor deprecated 

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

Deprecated: Use DownloadFileByPathRequest.ProtoReflect.Descriptor instead.

func (*DownloadFileByPathRequest) GetBucket 

func (x *DownloadFileByPathRequest) GetBucket() string

func (*DownloadFileByPathRequest) GetLimit 

func (x *DownloadFileByPathRequest) GetLimit() uint64

func (*DownloadFileByPathRequest) GetNamespace 

func (x *DownloadFileByPathRequest) GetNamespace() string

func (*DownloadFileByPathRequest) GetPath 

func (x *DownloadFileByPathRequest) GetPath() string

func (*DownloadFileByPathRequest) GetSeek 

func (x *DownloadFileByPathRequest) GetSeek() uint64

func (*DownloadFileByPathRequest) ProtoMessage 

func (*DownloadFileByPathRequest) ProtoMessage()

func (*DownloadFileByPathRequest) ProtoReflect 

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

func (*DownloadFileByPathRequest) Reset 

func (x *DownloadFileByPathRequest) Reset()

func (*DownloadFileByPathRequest) String 

func (x *DownloadFileByPathRequest) String() string

type DownloadFileByPathResponse 

type DownloadFileByPathResponse struct {

	// File binary data
	DataChunk []byte `protobuf:"bytes,1,opt,name=dataChunk,proto3" json:"dataChunk,omitempty"`
	// contains filtered or unexported fields
}

func (*DownloadFileByPathResponse) Descriptor deprecated 

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

Deprecated: Use DownloadFileByPathResponse.ProtoReflect.Descriptor instead.

func (*DownloadFileByPathResponse) GetDataChunk 

func (x *DownloadFileByPathResponse) GetDataChunk() []byte

func (*DownloadFileByPathResponse) ProtoMessage 

func (*DownloadFileByPathResponse) ProtoMessage()

func (*DownloadFileByPathResponse) ProtoReflect 

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

func (*DownloadFileByPathResponse) Reset 

func (x *DownloadFileByPathResponse) Reset()

func (*DownloadFileByPathResponse) String 

func (x *DownloadFileByPathResponse) String() string

type DownloadFileRequest 

type DownloadFileRequest struct {

	// Namespace where the file is stored
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Unique identifier of the file
	Uuid string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// How much bytes to skip from beginning of the file. 0 means start from beginning
	Seek uint64 `protobuf:"varint,3,opt,name=seek,proto3" json:"seek,omitempty"`
	// How much bytes (at most) to read from the file. 0 means read all bytes from seek position
	Limit uint64 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*DownloadFileRequest) Descriptor deprecated 

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

Deprecated: Use DownloadFileRequest.ProtoReflect.Descriptor instead.

func (*DownloadFileRequest) GetLimit 

func (x *DownloadFileRequest) GetLimit() uint64

func (*DownloadFileRequest) GetNamespace 

func (x *DownloadFileRequest) GetNamespace() string

func (*DownloadFileRequest) GetSeek 

func (x *DownloadFileRequest) GetSeek() uint64

func (*DownloadFileRequest) GetUuid 

func (x *DownloadFileRequest) GetUuid() string

func (*DownloadFileRequest) ProtoMessage 

func (*DownloadFileRequest) ProtoMessage()

func (*DownloadFileRequest) ProtoReflect 

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

func (*DownloadFileRequest) Reset 

func (x *DownloadFileRequest) Reset()

func (*DownloadFileRequest) String 

func (x *DownloadFileRequest) String() string

type DownloadFileResponse 

type DownloadFileResponse struct {

	// File binary data
	DataChunk []byte `protobuf:"bytes,1,opt,name=dataChunk,proto3" json:"dataChunk,omitempty"`
	// contains filtered or unexported fields
}

func (*DownloadFileResponse) Descriptor deprecated 

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

Deprecated: Use DownloadFileResponse.ProtoReflect.Descriptor instead.

func (*DownloadFileResponse) GetDataChunk 

func (x *DownloadFileResponse) GetDataChunk() []byte

func (*DownloadFileResponse) ProtoMessage 

func (*DownloadFileResponse) ProtoMessage()

func (*DownloadFileResponse) ProtoReflect 

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

func (*DownloadFileResponse) Reset 

func (x *DownloadFileResponse) Reset()

func (*DownloadFileResponse) String 

func (x *DownloadFileResponse) String() string

type FSServiceClient 

type FSServiceClient interface {
	CreateFile(ctx context.Context, in *CreateFileRequest, opts ...grpc.CallOption) (*CreateFileResponse, error)
	UploadFile(ctx context.Context, opts ...grpc.CallOption) (FSService_UploadFileClient, error)
	StatFile(ctx context.Context, in *StatFileRequest, opts ...grpc.CallOption) (*StatFileResponse, error)
	UpdateFile(ctx context.Context, in *UpdateFileRequest, opts ...grpc.CallOption) (*UpdateFileResponse, error)
	DeleteFile(ctx context.Context, in *DeleteFileRequest, opts ...grpc.CallOption) (*DeleteFileResponse, error)
	ListFiles(ctx context.Context, in *ListFilesRequest, opts ...grpc.CallOption) (FSService_ListFilesClient, error)
	CountFiles(ctx context.Context, in *CountFilesRequest, opts ...grpc.CallOption) (*CountFilesResponse, error)
	Download(ctx context.Context, in *DownloadFileRequest, opts ...grpc.CallOption) (FSService_DownloadClient, error)
	DownloadByPath(ctx context.Context, in *DownloadFileByPathRequest, opts ...grpc.CallOption) (FSService_DownloadByPathClient, error)
	DownloadDirect(ctx context.Context, in *DownloadDirectFileRequest, opts ...grpc.CallOption) (FSService_DownloadDirectClient, error)
	DownloadDirectByPath(ctx context.Context, in *DownloadDirectFileByPathRequest, opts ...grpc.CallOption) (FSService_DownloadDirectByPathClient, error)
}

FSServiceClient is the client API for FSService 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 NewFSServiceClient 

func NewFSServiceClient(cc grpc.ClientConnInterface) FSServiceClient

type FSServiceServer 

type FSServiceServer interface {
	CreateFile(context.Context, *CreateFileRequest) (*CreateFileResponse, error)
	UploadFile(FSService_UploadFileServer) error
	StatFile(context.Context, *StatFileRequest) (*StatFileResponse, error)
	UpdateFile(context.Context, *UpdateFileRequest) (*UpdateFileResponse, error)
	DeleteFile(context.Context, *DeleteFileRequest) (*DeleteFileResponse, error)
	ListFiles(*ListFilesRequest, FSService_ListFilesServer) error
	CountFiles(context.Context, *CountFilesRequest) (*CountFilesResponse, error)
	Download(*DownloadFileRequest, FSService_DownloadServer) error
	DownloadByPath(*DownloadFileByPathRequest, FSService_DownloadByPathServer) error
	DownloadDirect(*DownloadDirectFileRequest, FSService_DownloadDirectServer) error
	DownloadDirectByPath(*DownloadDirectFileByPathRequest, FSService_DownloadDirectByPathServer) error
	// contains filtered or unexported methods
}

FSServiceServer is the server API for FSService service. All implementations must embed UnimplementedFSServiceServer for forward compatibility

type FSService_DownloadByPathClient 

type FSService_DownloadByPathClient interface {
	Recv() (*DownloadFileByPathResponse, error)
	grpc.ClientStream
}

type FSService_DownloadByPathServer 

type FSService_DownloadByPathServer interface {
	Send(*DownloadFileByPathResponse) error
	grpc.ServerStream
}

type FSService_DownloadClient 

type FSService_DownloadClient interface {
	Recv() (*DownloadFileResponse, error)
	grpc.ClientStream
}

type FSService_DownloadDirectByPathClient 

type FSService_DownloadDirectByPathClient interface {
	Recv() (*DownloadDirectFileByPathResponse, error)
	grpc.ClientStream
}

type FSService_DownloadDirectByPathServer 

type FSService_DownloadDirectByPathServer interface {
	Send(*DownloadDirectFileByPathResponse) error
	grpc.ServerStream
}

type FSService_DownloadDirectClient 

type FSService_DownloadDirectClient interface {
	Recv() (*DownloadDirectFileResponse, error)
	grpc.ClientStream
}

type FSService_DownloadDirectServer 

type FSService_DownloadDirectServer interface {
	Send(*DownloadDirectFileResponse) error
	grpc.ServerStream
}

type FSService_DownloadServer 

type FSService_DownloadServer interface {
	Send(*DownloadFileResponse) error
	grpc.ServerStream
}

type FSService_ListFilesClient 

type FSService_ListFilesClient interface {
	Recv() (*ListFilesResponse, error)
	grpc.ClientStream
}

type FSService_ListFilesServer 

type FSService_ListFilesServer interface {
	Send(*ListFilesResponse) error
	grpc.ServerStream
}

type FSService_UploadFileClient 

type FSService_UploadFileClient interface {
	Send(*UploadFileRequest) error
	CloseAndRecv() (*UploadFileResponse, error)
	grpc.ClientStream
}

type FSService_UploadFileServer 

type FSService_UploadFileServer interface {
	SendAndClose(*UploadFileResponse) error
	Recv() (*UploadFileRequest, error)
	grpc.ServerStream
}

type File 

type File struct {

	// Namespace where the file is stored
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Unique identifier of the file
	Uuid string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// Unique full path of the file inside bucket.
	Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	// Bucket UUID where the file is stored
	Bucket string `protobuf:"bytes,4,opt,name=bucket,proto3" json:"bucket,omitempty"`
	// Long random string that can be used by other services to allow user to directly download file (for example making CDN link)
	DirectDownloadSecret string `protobuf:"bytes,5,opt,name=directDownloadSecret,proto3" json:"directDownloadSecret,omitempty"`
	// Mime type of the file
	MimeType string `protobuf:"bytes,6,opt,name=mimeType,proto3" json:"mimeType,omitempty"`
	// File size in bytes
	Size int64 `protobuf:"varint,7,opt,name=size,proto3" json:"size,omitempty"`
	// When file was creted
	XCreated *timestamp.Timestamp `protobuf:"bytes,100,opt,name=_created,json=Created,proto3" json:"_created,omitempty"`
	// When file was updated last time
	XUpdated *timestamp.Timestamp `protobuf:"bytes,101,opt,name=_updated,json=Updated,proto3" json:"_updated,omitempty"`
	// Version of the file. Automatically increases on every update to the file binary data or file information
	XVersion int64 `protobuf:"varint,102,opt,name=_version,json=Version,proto3" json:"_version,omitempty"`
	// contains filtered or unexported fields
}

func (*File) Descriptor deprecated 

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

Deprecated: Use File.ProtoReflect.Descriptor instead.

func (*File) GetBucket 

func (x *File) GetBucket() string

func (*File) GetDirectDownloadSecret 

func (x *File) GetDirectDownloadSecret() string

func (*File) GetMimeType 

func (x *File) GetMimeType() string

func (*File) GetNamespace 

func (x *File) GetNamespace() string

func (*File) GetPath 

func (x *File) GetPath() string

func (*File) GetSize 

func (x *File) GetSize() int64

func (*File) GetUuid 

func (x *File) GetUuid() string

func (*File) GetXCreated 

func (x *File) GetXCreated() *timestamp.Timestamp

func (*File) GetXUpdated 

func (x *File) GetXUpdated() *timestamp.Timestamp

func (*File) GetXVersion 

func (x *File) GetXVersion() int64

func (*File) ProtoMessage 

func (*File) ProtoMessage()

func (*File) ProtoReflect 

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

func (*File) Reset 

func (x *File) Reset()

func (*File) String 

func (x *File) String() string

type ListFilesRequest 

type ListFilesRequest struct {

	// Namespace where the files are stored
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Bucket UUID where the files are stored
	Bucket string `protobuf:"bytes,2,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Skip   uint32 `protobuf:"varint,3,opt,name=skip,proto3" json:"skip,omitempty"`
	Limit  uint32 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*ListFilesRequest) Descriptor deprecated 

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

Deprecated: Use ListFilesRequest.ProtoReflect.Descriptor instead.

func (*ListFilesRequest) GetBucket 

func (x *ListFilesRequest) GetBucket() string

func (*ListFilesRequest) GetLimit 

func (x *ListFilesRequest) GetLimit() uint32

func (*ListFilesRequest) GetNamespace 

func (x *ListFilesRequest) GetNamespace() string

func (*ListFilesRequest) GetSkip 

func (x *ListFilesRequest) GetSkip() uint32

func (*ListFilesRequest) ProtoMessage 

func (*ListFilesRequest) ProtoMessage()

func (*ListFilesRequest) ProtoReflect 

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

func (*ListFilesRequest) Reset 

func (x *ListFilesRequest) Reset()

func (*ListFilesRequest) String 

func (x *ListFilesRequest) String() string

type ListFilesResponse 

type ListFilesResponse struct {
	File *File `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"`
	// contains filtered or unexported fields
}

func (*ListFilesResponse) Descriptor deprecated 

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

Deprecated: Use ListFilesResponse.ProtoReflect.Descriptor instead.

func (*ListFilesResponse) GetFile 

func (x *ListFilesResponse) GetFile() *File

func (*ListFilesResponse) ProtoMessage 

func (*ListFilesResponse) ProtoMessage()

func (*ListFilesResponse) ProtoReflect 

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

func (*ListFilesResponse) Reset 

func (x *ListFilesResponse) Reset()

func (*ListFilesResponse) String 

func (x *ListFilesResponse) String() string

type StatFileRequest 

type StatFileRequest struct {

	// Namespace where the file is stored
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Unique identifier of the file
	Uuid string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// If true, file information will be loaded from cache if possible
	UseCache bool `protobuf:"varint,3,opt,name=useCache,proto3" json:"useCache,omitempty"`
	// contains filtered or unexported fields
}

func (*StatFileRequest) Descriptor deprecated 

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

Deprecated: Use StatFileRequest.ProtoReflect.Descriptor instead.

func (*StatFileRequest) GetNamespace 

func (x *StatFileRequest) GetNamespace() string

func (*StatFileRequest) GetUseCache 

func (x *StatFileRequest) GetUseCache() bool

func (*StatFileRequest) GetUuid 

func (x *StatFileRequest) GetUuid() string

func (*StatFileRequest) ProtoMessage 

func (*StatFileRequest) ProtoMessage()

func (*StatFileRequest) ProtoReflect 

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

func (*StatFileRequest) Reset 

func (x *StatFileRequest) Reset()

func (*StatFileRequest) String 

func (x *StatFileRequest) String() string

type StatFileResponse 

type StatFileResponse struct {
	File *File `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"`
	// contains filtered or unexported fields
}

func (*StatFileResponse) Descriptor deprecated 

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

Deprecated: Use StatFileResponse.ProtoReflect.Descriptor instead.

func (*StatFileResponse) GetFile 

func (x *StatFileResponse) GetFile() *File

func (*StatFileResponse) ProtoMessage 

func (*StatFileResponse) ProtoMessage()

func (*StatFileResponse) ProtoReflect 

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

func (*StatFileResponse) Reset 

func (x *StatFileResponse) Reset()

func (*StatFileResponse) String 

func (x *StatFileResponse) String() string

type UnimplementedFSServiceServer 

type UnimplementedFSServiceServer struct {
}

UnimplementedFSServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedFSServiceServer) CountFiles 

func (UnimplementedFSServiceServer) CountFiles(context.Context, *CountFilesRequest) (*CountFilesResponse, error)

func (UnimplementedFSServiceServer) CreateFile 

func (UnimplementedFSServiceServer) CreateFile(context.Context, *CreateFileRequest) (*CreateFileResponse, error)

func (UnimplementedFSServiceServer) DeleteFile 

func (UnimplementedFSServiceServer) DeleteFile(context.Context, *DeleteFileRequest) (*DeleteFileResponse, error)

func (UnimplementedFSServiceServer) Download 

func (UnimplementedFSServiceServer) Download(*DownloadFileRequest, FSService_DownloadServer) error

func (UnimplementedFSServiceServer) DownloadByPath 

func (UnimplementedFSServiceServer) DownloadByPath(*DownloadFileByPathRequest, FSService_DownloadByPathServer) error

func (UnimplementedFSServiceServer) DownloadDirect 

func (UnimplementedFSServiceServer) DownloadDirect(*DownloadDirectFileRequest, FSService_DownloadDirectServer) error

func (UnimplementedFSServiceServer) DownloadDirectByPath 

func (UnimplementedFSServiceServer) DownloadDirectByPath(*DownloadDirectFileByPathRequest, FSService_DownloadDirectByPathServer) error

func (UnimplementedFSServiceServer) ListFiles 

func (UnimplementedFSServiceServer) ListFiles(*ListFilesRequest, FSService_ListFilesServer) error

func (UnimplementedFSServiceServer) StatFile 

func (UnimplementedFSServiceServer) StatFile(context.Context, *StatFileRequest) (*StatFileResponse, error)

func (UnimplementedFSServiceServer) UpdateFile 

func (UnimplementedFSServiceServer) UpdateFile(context.Context, *UpdateFileRequest) (*UpdateFileResponse, error)

func (UnimplementedFSServiceServer) UploadFile 

func (UnimplementedFSServiceServer) UploadFile(FSService_UploadFileServer) error

type UnsafeFSServiceServer 

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

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

type UpdateFileRequest 

type UpdateFileRequest struct {

	// Namespace where the file is stored
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Unique identifier of the file
	Uuid string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// New file path
	Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	// New mime type of the file
	MimeType string `protobuf:"bytes,4,opt,name=mimeType,proto3" json:"mimeType,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateFileRequest) Descriptor deprecated 

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

Deprecated: Use UpdateFileRequest.ProtoReflect.Descriptor instead.

func (*UpdateFileRequest) GetMimeType 

func (x *UpdateFileRequest) GetMimeType() string

func (*UpdateFileRequest) GetNamespace 

func (x *UpdateFileRequest) GetNamespace() string

func (*UpdateFileRequest) GetPath 

func (x *UpdateFileRequest) GetPath() string

func (*UpdateFileRequest) GetUuid 

func (x *UpdateFileRequest) GetUuid() string

func (*UpdateFileRequest) ProtoMessage 

func (*UpdateFileRequest) ProtoMessage()

func (*UpdateFileRequest) ProtoReflect 

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

func (*UpdateFileRequest) Reset 

func (x *UpdateFileRequest) Reset()

func (*UpdateFileRequest) String 

func (x *UpdateFileRequest) String() string

type UpdateFileResponse 

type UpdateFileResponse struct {
	File *File `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateFileResponse) Descriptor deprecated 

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

Deprecated: Use UpdateFileResponse.ProtoReflect.Descriptor instead.

func (*UpdateFileResponse) GetFile 

func (x *UpdateFileResponse) GetFile() *File

func (*UpdateFileResponse) ProtoMessage 

func (*UpdateFileResponse) ProtoMessage()

func (*UpdateFileResponse) ProtoReflect 

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

func (*UpdateFileResponse) Reset 

func (x *UpdateFileResponse) Reset()

func (*UpdateFileResponse) String 

func (x *UpdateFileResponse) String() string

type UploadFileRequest 

type UploadFileRequest struct {

	// Namespace where the file should be stored
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Unique identifier of the file
	Uuid string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// File binary data
	DataChunk []byte `protobuf:"bytes,3,opt,name=dataChunk,proto3" json:"dataChunk,omitempty"`
	// contains filtered or unexported fields
}

func (*UploadFileRequest) Descriptor deprecated 

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

Deprecated: Use UploadFileRequest.ProtoReflect.Descriptor instead.

func (*UploadFileRequest) GetDataChunk 

func (x *UploadFileRequest) GetDataChunk() []byte

func (*UploadFileRequest) GetNamespace 

func (x *UploadFileRequest) GetNamespace() string

func (*UploadFileRequest) GetUuid 

func (x *UploadFileRequest) GetUuid() string

func (*UploadFileRequest) ProtoMessage 

func (*UploadFileRequest) ProtoMessage()

func (*UploadFileRequest) ProtoReflect 

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

func (*UploadFileRequest) Reset 

func (x *UploadFileRequest) Reset()

func (*UploadFileRequest) String 

func (x *UploadFileRequest) String() string

type UploadFileResponse 

type UploadFileResponse struct {
	File *File `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"`
	// contains filtered or unexported fields
}

func (*UploadFileResponse) Descriptor deprecated 

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

Deprecated: Use UploadFileResponse.ProtoReflect.Descriptor instead.

func (*UploadFileResponse) GetFile 

func (x *UploadFileResponse) GetFile() *File

func (*UploadFileResponse) ProtoMessage 

func (*UploadFileResponse) ProtoMessage()

func (*UploadFileResponse) ProtoReflect 

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

func (*UploadFileResponse) Reset 

func (x *UploadFileResponse) Reset()

func (*UploadFileResponse) String 

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