service

package
v0.0.6 Latest Latest
Warning

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

 Go to latest Published: Sep 28, 2023 License: MIT Imports: 17 Imported by: 0

README

Service

Documentation

Index

Constants

View Source 
const SUCCESS = "success"

Variables

View Source 
var ProviderSet = wire.NewSet(
	NewAgentService,
	NewStorageService,
	NewUserService,
	NewComputeInstanceService,
	NewComputePowerService,
	NewCronJob,
	NewIpfShell,
)

ProviderSet is service providers.

Functions

func NewIpfShell added in v0.0.6 

func NewIpfShell(c *conf.Data) *shell.Shell

Types

type AgentService 

type AgentService struct {
	pb.UnimplementedAgentServer
	// contains filtered or unexported fields
}

func NewAgentService 

func NewAgentService(uc *biz.AgentUsecase, logger log.Logger) *AgentService

func (*AgentService) CreateAgent 

func (s *AgentService) CreateAgent(ctx context.Context, req *pb.CreateAgentRequest) (*pb.CreateAgentReply, error)

func (*AgentService) DeleteAgent 

func (s *AgentService) DeleteAgent(ctx context.Context, req *pb.DeleteAgentRequest) (*pb.DeleteAgentReply, error)

func (*AgentService) GetAgent 

func (s *AgentService) GetAgent(ctx context.Context, req *pb.GetAgentRequest) (*pb.GetAgentReply, error)

func (*AgentService) ListAgent 

func (s *AgentService) ListAgent(ctx context.Context, req *pb.ListAgentRequest) (*pb.ListAgentReply, error)

func (*AgentService) ListAgentInstance added in v0.0.6 

func (s *AgentService) ListAgentInstance(ctx context.Context, req *pb.ListAgentInstanceReq) (*computepb.ListInstanceReply, error)

func (*AgentService) ReportInstanceStatus added in v0.0.6 

func (s *AgentService) ReportInstanceStatus(ctx context.Context, req *computepb.Instance) (rsp *pb.ReportInstanceStatusReply, err error)

func (*AgentService) UpdateAgent 

func (s *AgentService) UpdateAgent(ctx context.Context, req *pb.UpdateAgentRequest) (*pb.UpdateAgentReply, error)

type ComputeInstanceService 

type ComputeInstanceService struct {
	pb.UnimplementedComputeInstanceServer
	// contains filtered or unexported fields
}

func NewComputeInstanceService 

func NewComputeInstanceService(uc *biz.ComputeInstanceUsercase, logger log.Logger) *ComputeInstanceService

func (*ComputeInstanceService) Create 

func (s *ComputeInstanceService) Create(ctx context.Context, req *pb.CreateInstanceRequest) (*pb.CreateInstanceReply, error)

func (*ComputeInstanceService) Delete 

func (s *ComputeInstanceService) Delete(ctx context.Context, req *pb.DeleteInstanceRequest) (*pb.DeleteInstanceReply, error)

func (*ComputeInstanceService) Get 

func (s *ComputeInstanceService) Get(ctx context.Context, req *pb.GetInstanceRequest) (*pb.GetInstanceReply, error)

func (*ComputeInstanceService) List 

func (s *ComputeInstanceService) List(ctx context.Context, req *pb.ListInstanceRequest) (*pb.ListInstanceReply, error)

func (*ComputeInstanceService) ListComputeImage 

func (s *ComputeInstanceService) ListComputeImage(ctx context.Context, req *pb.ListComputeImageRequest) (*pb.ListComputeImageReply, error)

func (*ComputeInstanceService) ListComputeInstanceDuration 

func (s *ComputeInstanceService) ListComputeInstanceDuration(ctx context.Context, req *pb.ListComputeDurationRequest) (*pb.ListComputeDurationReply, error)

func (*ComputeInstanceService) ListComputeSpec 

func (s *ComputeInstanceService) ListComputeSpec(ctx context.Context, req *pb.ListComputeSpecRequest) (*pb.ListComputeSpecReply, error)

func (*ComputeInstanceService) StartInstance 

func (s *ComputeInstanceService) StartInstance(ctx context.Context, req *pb.GetInstanceRequest) (*pb.StartInstanceReply, error)

func (*ComputeInstanceService) StopInstance 

func (s *ComputeInstanceService) StopInstance(ctx context.Context, req *pb.GetInstanceRequest) (*pb.StopInstanceReply, error)

func (*ComputeInstanceService) Terminal added in v0.0.3 

func (s *ComputeInstanceService) Terminal(w http.ResponseWriter, r *http.Request)

type ComputePowerService added in v0.0.3 

type ComputePowerService struct {
	pb.UnimplementedComputePowerServer
	// contains filtered or unexported fields
}

func NewComputePowerService added in v0.0.3 

func NewComputePowerService(uc *biz.ScriptUseCase, ipfsShell *shell.Shell, logger log.Logger) (*ComputePowerService, error)

func (*ComputePowerService) CancelExecPythonPackage added in v0.0.3 

func (s *ComputePowerService) CancelExecPythonPackage(ctx context.Context, req *pb.CancelExecPythonPackageRequest) (*pb.CancelExecPythonPackageReply, error)

func (*ComputePowerService) DownloadScriptExecuteResult added in v0.0.3 

func (s *ComputePowerService) DownloadScriptExecuteResult(ctx context.Context, req *pb.DownloadScriptExecuteResultRequest) (*pb.DownloadScriptExecuteResultReply, error)

func (*ComputePowerService) GetScriptExecutionRecordInfo added in v0.0.5 

func (s *ComputePowerService) GetScriptExecutionRecordInfo(ctx context.Context, req *pb.GetScriptExecutionRecordInfoRequest) (*pb.GetScriptInfoReply, error)

func (*ComputePowerService) GetScriptExecutionRecordList added in v0.0.5 

func (s *ComputePowerService) GetScriptExecutionRecordList(ctx context.Context, req *pb.GetScriptExecutionRecordListRequest) (*pb.GetScriptListReply, error)

func (*ComputePowerService) RunPythonPackage added in v0.0.3 

func (s *ComputePowerService) RunPythonPackage(ctx context.Context, req *pb.RunPythonPackageServerRequest) (*pb.RunPythonPackageServerReply, error)

func (*ComputePowerService) UploadScriptFile added in v0.0.3 

func (s *ComputePowerService) UploadScriptFile(ctx context.Context, req *pb.UploadScriptFileRequest) (*pb.UploadScriptFileReply, error)

type CronJob added in v0.0.3 

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

func NewCronJob added in v0.0.3 

func NewCronJob(computeInstanceUsercase *biz.ComputeInstanceUsercase, agentUsecase *biz.AgentUsecase, logger log.Logger) *CronJob

func (*CronJob) StartJob added in v0.0.3 

func (c *CronJob) StartJob()

type StorageService 

type StorageService struct {
	pb.UnimplementedStorageServer
	// contains filtered or unexported fields
}

func NewStorageService 

func NewStorageService(uc *biz.Storagecase, ipfsShell *shell.Shell, logger log.Logger) (*StorageService, error)

func (*StorageService) CreateDir 

func (s *StorageService) CreateDir(ctx context.Context, req *pb.CreateDirRequest) (*pb.CreateDirReply, error)

func (*StorageService) Delete 

func (s *StorageService) Delete(ctx context.Context, req *pb.DeleteRequest) (*pb.DeleteReply, error)

func (*StorageService) Download 

func (s *StorageService) Download(ctx context.Context, req *pb.DownloadRequest) (*pb.DownloadReply, error)

func (*StorageService) List 

func (s *StorageService) List(ctx context.Context, req *pb.ListRequest) (*pb.ListReply, error)

func (*StorageService) UploadFile 

func (s *StorageService) UploadFile(ctx context.Context, req *pb.UploadFileRequest) (*pb.UploadFileReply, error)

type UserService 

type UserService struct {
	pb.UnimplementedUserServer
	// contains filtered or unexported fields
}

func NewUserService 

func NewUserService(uc *biz.UserUsercase, logger log.Logger) *UserService

func (*UserService) CreateUser 

func (s *UserService) CreateUser(ctx context.Context, req *pb.CreateUserRequest) (*pb.CreateUserReply, error)

func (*UserService) DeleteUser 

func (s *UserService) DeleteUser(ctx context.Context, req *pb.DeleteUserRequest) (*pb.DeleteUserReply, error)

func (*UserService) GetUser 

func (s *UserService) GetUser(ctx context.Context, req *pb.GetUserRequest) (*pb.GetUserReply, error)

func (*UserService) ListUser 

func (s *UserService) ListUser(ctx context.Context, req *pb.ListUserRequest) (*pb.ListUserReply, error)

func (*UserService) Login 

func (s *UserService) Login(ctx context.Context, req *pb.LoginRequest) (*pb.LoginReply, error)

func (*UserService) LoginWithValidateCode 

func (s *UserService) LoginWithValidateCode(ctx context.Context, req *pb.LoginWithValidateCodeRequest) (*pb.LoginReply, error)

func (*UserService) SendValidateCode 

func (s *UserService) SendValidateCode(ctx context.Context, req *pb.SendValidateCodeRequest) (*pb.SendValidateCodeReply, error)

func (*UserService) UpdateUser 

func (s *UserService) UpdateUser(ctx context.Context, req *pb.UpdateUserRequest) (*pb.UpdateUserReply, error)

func (*UserService) UpdateUserPassword 

func (s *UserService) UpdateUserPassword(ctx context.Context, req *pb.UpdateUserPasswordRequest) (*pb.UpdateUserPasswordReply, error)

func (*UserService) UpdateUserTelephone 

func (s *UserService) UpdateUserTelephone(ctx context.Context, req *pb.UpdateUserTelephoneRequest) (*pb.UpdateUserTelephoneReply, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.