server

func (*LogManagerServer) DownloadJobMgrLogFile ¶

func (s *LogManagerServer) DownloadJobMgrLogFile(req *logpb.DownloadJobMgrRequest, stream logpb.LogManager_DownloadJobMgrLogFileServer) error

func (*LogManagerServer) DownloadTaskMgrLogFile ¶

func (s *LogManagerServer) DownloadTaskMgrLogFile(req *logpb.DownloadTaskMgrRequest, stream logpb.LogManager_DownloadTaskMgrLogFileServer) error

func (*LogManagerServer) GetUploadingTaskStat ¶

func (s *LogManagerServer) GetUploadingTaskStat(_ context.Context, req *logpb.TaskStatRequest) (*logpb.TaskStatReply, error)

func (*LogManagerServer) ListJMHistoryLogFiles ¶

func (s *LogManagerServer) ListJMHistoryLogFiles(_ context.Context, req *logpb.ListHistLogsRequest) (*logpb.ListJMHistLogsReply, error)

func (*LogManagerServer) ListTMHistoryLogFiles ¶

func (s *LogManagerServer) ListTMHistoryLogFiles(_ context.Context, req *logpb.ListHistLogsRequest) (*logpb.ListTMHistLogsReply, error)

full path for taskManager log files: /:space_id/:flow_id/:inst_id/logs/taskmanager/:taskManager_id/:log_file so we need to get existed taskManagerIDs first

func (*LogManagerServer) UploadLogFile ¶

func (s *LogManagerServer) UploadLogFile(_ context.Context, req *logpb.UploadFileRequest) (*logpb.UploadFileReply, error)