storage_service

package
v0.0.0-...-76f7c0c Latest Latest
Warning

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

Go to latest
Published: Oct 10, 2021 License: MIT Imports: 8 Imported by: 8

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_storage_service_proto protoreflect.FileDescriptor

Functions

func RegisterStorageServer

func RegisterStorageServer(s *grpc.Server, srv StorageServer)

Types

type DeleteFileRequest

type DeleteFileRequest struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteFileRequest) Descriptor deprecated

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

Deprecated: Use DeleteFileRequest.ProtoReflect.Descriptor instead.

func (*DeleteFileRequest) GetKey

func (x *DeleteFileRequest) GetKey() 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 {
	// contains filtered or unexported fields
}

func (*DeleteFileResponse) Descriptor deprecated

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

Deprecated: Use DeleteFileResponse.ProtoReflect.Descriptor instead.

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 DeleteFilesRequest

type DeleteFilesRequest struct {
	Prefix string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteFilesRequest) Descriptor deprecated

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

Deprecated: Use DeleteFilesRequest.ProtoReflect.Descriptor instead.

func (*DeleteFilesRequest) GetPrefix

func (x *DeleteFilesRequest) GetPrefix() string

func (*DeleteFilesRequest) ProtoMessage

func (*DeleteFilesRequest) ProtoMessage()

func (*DeleteFilesRequest) ProtoReflect

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

func (*DeleteFilesRequest) Reset

func (x *DeleteFilesRequest) Reset()

func (*DeleteFilesRequest) String

func (x *DeleteFilesRequest) String() string

type DeleteFilesResponse

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

func (*DeleteFilesResponse) Descriptor deprecated

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

Deprecated: Use DeleteFilesResponse.ProtoReflect.Descriptor instead.

func (*DeleteFilesResponse) ProtoMessage

func (*DeleteFilesResponse) ProtoMessage()

func (*DeleteFilesResponse) ProtoReflect

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

func (*DeleteFilesResponse) Reset

func (x *DeleteFilesResponse) Reset()

func (*DeleteFilesResponse) String

func (x *DeleteFilesResponse) String() string

type FileInfo

type FileInfo struct {
	FileName string `protobuf:"bytes,1,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	Size     uint32 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*FileInfo) Descriptor deprecated

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

Deprecated: Use FileInfo.ProtoReflect.Descriptor instead.

func (*FileInfo) GetFileName

func (x *FileInfo) GetFileName() string

func (*FileInfo) GetSize

func (x *FileInfo) GetSize() uint32

func (*FileInfo) ProtoMessage

func (*FileInfo) ProtoMessage()

func (*FileInfo) ProtoReflect

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

func (*FileInfo) Reset

func (x *FileInfo) Reset()

func (*FileInfo) String

func (x *FileInfo) String() string

type GetFileRequest

type GetFileRequest struct {
	FileName string `protobuf:"bytes,1,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFileRequest) Descriptor deprecated

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

Deprecated: Use GetFileRequest.ProtoReflect.Descriptor instead.

func (*GetFileRequest) GetFileName

func (x *GetFileRequest) GetFileName() string

func (*GetFileRequest) ProtoMessage

func (*GetFileRequest) ProtoMessage()

func (*GetFileRequest) ProtoReflect

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

func (*GetFileRequest) Reset

func (x *GetFileRequest) Reset()

func (*GetFileRequest) String

func (x *GetFileRequest) String() string

type GetFileResponse

type GetFileResponse struct {
	ChunkData []byte `protobuf:"bytes,2,opt,name=chunk_data,json=chunkData,proto3" json:"chunk_data,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFileResponse) Descriptor deprecated

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

Deprecated: Use GetFileResponse.ProtoReflect.Descriptor instead.

func (*GetFileResponse) GetChunkData

func (x *GetFileResponse) GetChunkData() []byte

func (*GetFileResponse) ProtoMessage

func (*GetFileResponse) ProtoMessage()

func (*GetFileResponse) ProtoReflect

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

func (*GetFileResponse) Reset

func (x *GetFileResponse) Reset()

func (*GetFileResponse) String

func (x *GetFileResponse) String() string

type GetFilesRequest

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

func (*GetFilesRequest) Descriptor deprecated

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

Deprecated: Use GetFilesRequest.ProtoReflect.Descriptor instead.

func (*GetFilesRequest) ProtoMessage

func (*GetFilesRequest) ProtoMessage()

func (*GetFilesRequest) ProtoReflect

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

func (*GetFilesRequest) Reset

func (x *GetFilesRequest) Reset()

func (*GetFilesRequest) String

func (x *GetFilesRequest) String() string

type GetFilesResponse

type GetFilesResponse struct {
	Object *StorageObject `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFilesResponse) Descriptor deprecated

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

Deprecated: Use GetFilesResponse.ProtoReflect.Descriptor instead.

func (*GetFilesResponse) GetObject

func (x *GetFilesResponse) GetObject() *StorageObject

func (*GetFilesResponse) ProtoMessage

func (*GetFilesResponse) ProtoMessage()

func (*GetFilesResponse) ProtoReflect

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

func (*GetFilesResponse) Reset

func (x *GetFilesResponse) Reset()

func (*GetFilesResponse) String

func (x *GetFilesResponse) String() string

type StorageClient

type StorageClient interface {
	// Uploads a file in chunks
	UploadFile(ctx context.Context, opts ...grpc.CallOption) (Storage_UploadFileClient, error)
	// Downloads a file in chunks
	GetFile(ctx context.Context, in *GetFileRequest, opts ...grpc.CallOption) (Storage_GetFileClient, error)
	// Returns a list of all files
	GetFiles(ctx context.Context, in *GetFilesRequest, opts ...grpc.CallOption) (Storage_GetFilesClient, error)
	// Deletes a file
	DeleteFile(ctx context.Context, in *DeleteFileRequest, opts ...grpc.CallOption) (*DeleteFileResponse, error)
	// Deletes all files
	DeleteFiles(ctx context.Context, in *DeleteFilesRequest, opts ...grpc.CallOption) (*DeleteFilesResponse, error)
}

StorageClient is the client API for Storage service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewStorageClient

func NewStorageClient(cc grpc.ClientConnInterface) StorageClient

type StorageObject

type StorageObject struct {
	Key          string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	LastModified string `protobuf:"bytes,2,opt,name=last_modified,json=lastModified,proto3" json:"last_modified,omitempty"`
	Size         uint64 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	StorageClass string `protobuf:"bytes,4,opt,name=storage_class,json=storageClass,proto3" json:"storage_class,omitempty"`
	// contains filtered or unexported fields
}

func (*StorageObject) Descriptor deprecated

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

Deprecated: Use StorageObject.ProtoReflect.Descriptor instead.

func (*StorageObject) GetKey

func (x *StorageObject) GetKey() string

func (*StorageObject) GetLastModified

func (x *StorageObject) GetLastModified() string

func (*StorageObject) GetSize

func (x *StorageObject) GetSize() uint64

func (*StorageObject) GetStorageClass

func (x *StorageObject) GetStorageClass() string

func (*StorageObject) ProtoMessage

func (*StorageObject) ProtoMessage()

func (*StorageObject) ProtoReflect

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

func (*StorageObject) Reset

func (x *StorageObject) Reset()

func (*StorageObject) String

func (x *StorageObject) String() string

type StorageServer

type StorageServer interface {
	// Uploads a file in chunks
	UploadFile(Storage_UploadFileServer) error
	// Downloads a file in chunks
	GetFile(*GetFileRequest, Storage_GetFileServer) error
	// Returns a list of all files
	GetFiles(*GetFilesRequest, Storage_GetFilesServer) error
	// Deletes a file
	DeleteFile(context.Context, *DeleteFileRequest) (*DeleteFileResponse, error)
	// Deletes all files
	DeleteFiles(context.Context, *DeleteFilesRequest) (*DeleteFilesResponse, error)
}

StorageServer is the server API for Storage service.

type Storage_GetFileClient

type Storage_GetFileClient interface {
	Recv() (*GetFileResponse, error)
	grpc.ClientStream
}

type Storage_GetFileServer

type Storage_GetFileServer interface {
	Send(*GetFileResponse) error
	grpc.ServerStream
}

type Storage_GetFilesClient

type Storage_GetFilesClient interface {
	Recv() (*GetFilesResponse, error)
	grpc.ClientStream
}

type Storage_GetFilesServer

type Storage_GetFilesServer interface {
	Send(*GetFilesResponse) error
	grpc.ServerStream
}

type Storage_UploadFileClient

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

type Storage_UploadFileServer

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

type UnimplementedStorageServer

type UnimplementedStorageServer struct {
}

UnimplementedStorageServer can be embedded to have forward compatible implementations.

func (*UnimplementedStorageServer) DeleteFile

func (*UnimplementedStorageServer) DeleteFiles

func (*UnimplementedStorageServer) GetFile

func (*UnimplementedStorageServer) GetFiles

func (*UnimplementedStorageServer) UploadFile

type UploadFileRequest

type UploadFileRequest struct {

	// Types that are assignable to Data:
	//	*UploadFileRequest_Info
	//	*UploadFileRequest_ChunkData
	Data isUploadFileRequest_Data `protobuf_oneof:"data"`
	// contains filtered or unexported fields
}

The file is divided into multiple chunks which are sent on by one to the server in each request message. oneof: specify that only one of a range of fields can be set in any message: the first request will only contain the metadata (file info)

func (*UploadFileRequest) Descriptor deprecated

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

Deprecated: Use UploadFileRequest.ProtoReflect.Descriptor instead.

func (*UploadFileRequest) GetChunkData

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

func (*UploadFileRequest) GetData

func (m *UploadFileRequest) GetData() isUploadFileRequest_Data

func (*UploadFileRequest) GetInfo

func (x *UploadFileRequest) GetInfo() *FileInfo

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 UploadFileRequest_ChunkData

type UploadFileRequest_ChunkData struct {
	ChunkData []byte `protobuf:"bytes,2,opt,name=chunk_data,json=chunkData,proto3,oneof"`
}

type UploadFileRequest_Info

type UploadFileRequest_Info struct {
	Info *FileInfo `protobuf:"bytes,1,opt,name=info,proto3,oneof"`
}

type UploadFileResponse

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

func (*UploadFileResponse) Descriptor deprecated

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

Deprecated: Use UploadFileResponse.ProtoReflect.Descriptor instead.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL