rpc

README

upload服务

telegram客户端实现里，upload和download是两个独立的连接，相应的会有upload和download独立的服务。

当前先简单实现upload和download逻辑

后续也将upload和download服务独立出来，并引入独立的图片存储服务和文件存储系统

Documentation

Index

• type UploadServiceImpl
  • func (s *UploadServiceImpl) UploadGetCdnFile(ctx context.Context, request *mtproto.TLUploadGetCdnFile) (*mtproto.Upload_CdnFile, error)
  • func (s *UploadServiceImpl) UploadGetCdnFileHashes(ctx context.Context, request *mtproto.TLUploadGetCdnFileHashes) (*mtproto.Vector_CdnFileHash, error)
  • func (s *UploadServiceImpl) UploadGetFile(ctx context.Context, request *mtproto.TLUploadGetFile) (*mtproto.Upload_File, error)
  • func (s *UploadServiceImpl) UploadGetWebFile(ctx context.Context, request *mtproto.TLUploadGetWebFile) (*mtproto.Upload_WebFile, error)
  • func (s *UploadServiceImpl) UploadReuploadCdnFile(ctx context.Context, request *mtproto.TLUploadReuploadCdnFile) (*mtproto.Vector_CdnFileHash, error)
  • func (s *UploadServiceImpl) UploadSaveBigFilePart(ctx context.Context, request *mtproto.TLUploadSaveBigFilePart) (*mtproto.Bool, error)
  • func (s *UploadServiceImpl) UploadSaveFilePart(ctx context.Context, request *mtproto.TLUploadSaveFilePart) (*mtproto.Bool, error)

Types

type UploadServiceImpl

type UploadServiceImpl struct {
	DataPath string
}

func (*UploadServiceImpl) UploadGetCdnFile

func (s *UploadServiceImpl) UploadGetCdnFile(ctx context.Context, request *mtproto.TLUploadGetCdnFile) (*mtproto.Upload_CdnFile, error)

upload.getCdnFile#2000bcc3 file_token:bytes offset:int limit:int = upload.CdnFile;

func (*UploadServiceImpl) UploadGetCdnFileHashes

func (s *UploadServiceImpl) UploadGetCdnFileHashes(ctx context.Context, request *mtproto.TLUploadGetCdnFileHashes) (*mtproto.Vector_CdnFileHash, error)

upload.getCdnFileHashes#f715c87b file_token:bytes offset:int = Vector<CdnFileHash>;

func (*UploadServiceImpl) UploadGetFile

func (s *UploadServiceImpl) UploadGetFile(ctx context.Context, request *mtproto.TLUploadGetFile) (*mtproto.Upload_File, error)

upload.getFile#e3a6cfb5 location:InputFileLocation offset:int limit:int = upload.File;

func (*UploadServiceImpl) UploadGetWebFile

func (s *UploadServiceImpl) UploadGetWebFile(ctx context.Context, request *mtproto.TLUploadGetWebFile) (*mtproto.Upload_WebFile, error)

upload.getWebFile#24e6818d location:InputWebFileLocation offset:int limit:int = upload.WebFile;

func (*UploadServiceImpl) UploadReuploadCdnFile

func (s *UploadServiceImpl) UploadReuploadCdnFile(ctx context.Context, request *mtproto.TLUploadReuploadCdnFile) (*mtproto.Vector_CdnFileHash, error)

upload.reuploadCdnFile#1af91c09 file_token:bytes request_token:bytes = Vector<CdnFileHash>;

func (*UploadServiceImpl) UploadSaveBigFilePart

func (s *UploadServiceImpl) UploadSaveBigFilePart(ctx context.Context, request *mtproto.TLUploadSaveBigFilePart) (*mtproto.Bool, error)

upload.saveBigFilePart#de7b673d file_id:long file_part:int file_total_parts:int bytes:bytes = Bool;

func (*UploadServiceImpl) UploadSaveFilePart

func (s *UploadServiceImpl) UploadSaveFilePart(ctx context.Context, request *mtproto.TLUploadSaveFilePart) (*mtproto.Bool, error)

upload.saveFilePart#b304a621 file_id:long file_part:int bytes:bytes = Bool;