dispense

Documentation

Index

• type Service
  • func New() *Service
  • func (s *Service) BigFileDownload(in *pb.DownloadInfo, stream pb.FileServerService_BigFileDownloadServer) error
  • func (s *Service) ChunkUpload(stream pb.FileServerService_ChunkUploadServer) error
  • func (s *Service) Download(ctx context.Context, in *pb.DownloadInfo) (*pb.DownloadResponse, error)
  • func (s *Service) OtherBigFileDownload(in *pb.DownloadInfo, nodeName string, ...) error
  • func (s *Service) OtherNodeDownload(ctx context.Context, resp *pb.DownloadResponse, in *pb.DownloadInfo) (*pb.DownloadResponse, error)
  • func (s *Service) SingleUpload(ctx context.Context, in *pb.UploadInfo) (ret *pb.UpLoadResponse, err error)

Types

type Service

type Service struct {
	*registry.Metadata
	pb.UnimplementedFileServerServiceServer
}

func New

func New() *Service

func (*Service) BigFileDownload

func (s *Service) BigFileDownload(in *pb.DownloadInfo, stream pb.FileServerService_BigFileDownloadServer) error

func (*Service) ChunkUpload

func (s *Service) ChunkUpload(stream pb.FileServerService_ChunkUploadServer) error

func (*Service) Download

func (s *Service) Download(ctx context.Context, in *pb.DownloadInfo) (*pb.DownloadResponse, error)

func (*Service) OtherBigFileDownload

func (s *Service) OtherBigFileDownload(in *pb.DownloadInfo, nodeName string, stream pb.FileServerService_BigFileDownloadServer) error

func (*Service) OtherNodeDownload

func (s *Service) OtherNodeDownload(ctx context.Context, resp *pb.DownloadResponse, in *pb.DownloadInfo) (*pb.DownloadResponse, error)

func (*Service) SingleUpload

func (s *Service) SingleUpload(ctx context.Context, in *pb.UploadInfo) (ret *pb.UpLoadResponse, err error)