svc

Documentation

Overview

package core

Index

• Variables
• type Server
  • func NewSVC() *Server
  • func (s *Server) BeginSync(sessions *models.SyncReport)
  • func (s *Server) Download(ctx context.Context, in *pb.DownloadRequest) (*pb.DownloadReply, error)
  • func (s *Server) HTTPServer()
  • func (s *Server) InitDriver() error
  • func (s *Server) ReportStatus()
  • func (s *Server) RpcServer()
  • func (s *Server) Sync(ctx context.Context, in *pb.SyncRequest) (*pb.SyncReply, error)
  • func (s *Server) Upload(ctx context.Context, in *pb.UploadRequest) (*pb.UploadReply, error)

Variables

var ReportSchedule = "*/5 * * * * *"

ReportSchedule

var ReportSyncQueue []models.SyncReport

Types

type Server

type Server struct {
	pb.UnimplementedStorageServer
	Config   *config.StorageConfig
	Schedule schedule.ScheduleManage
	Status   string
	G        *gin.Engine
	Driver   vo.Driver
}

Server

func NewSVC

func NewSVC() *Server

NewSVC

@return *Server

func (*Server) BeginSync

func (s *Server) BeginSync(sessions *models.SyncReport)

func (*Server) Download

func (s *Server) Download(ctx context.Context, in *pb.DownloadRequest) (*pb.DownloadReply, error)

func (*Server) HTTPServer

func (s *Server) HTTPServer()

HTTPServer

@receiver s

func (*Server) InitDriver

func (s *Server) InitDriver() error

func (*Server) ReportStatus

func (s *Server) ReportStatus()

func (*Server) RpcServer

func (s *Server) RpcServer()

RpcServer

@receiver s

func (*Server) Sync

func (s *Server) Sync(ctx context.Context, in *pb.SyncRequest) (*pb.SyncReply, error)

func (*Server) Upload

func (s *Server) Upload(ctx context.Context, in *pb.UploadRequest) (*pb.UploadReply, error)

Upload

@receiver s
@param ctx
@param in
@return *pb.UploadReply
@return error