service

README

Service

Documentation

Index

• Constants
• Variables
• func NewDockerCli() (*client.Client, error)
• type ComputePowerService
  • func NewComputePowerService(ipfsShell *shell.Shell, client *client.Client, logger log.Logger) (*ComputePowerService, error)
  • func (s *ComputePowerService) CancelExecPythonPackage(ctx context.Context, req *pb.CancelExecPythonPackageClientRequest) (*pb.CancelExecPythonPackageClientReply, error)
  • func (s *ComputePowerService) RunPythonPackage(ctx context.Context, req *pb.RunPythonPackageClientRequest) (*pb.RunPythonPackageClientReply, error)
• type GreeterService
  • func NewGreeterService(uc *biz.GreeterUsecase) *GreeterService
  • func (s *GreeterService) SayHello(ctx context.Context, in *v1.HelloRequest) (*v1.HelloReply, error)
• type P2pService
  • func NewP2pService(ipfsShell *shell.Shell) *P2pService
  • func (s *P2pService) CloseListen(ctx context.Context, req *pb.CloseListenRequest) (*pb.CloseListenReply, error)
  • func (s *P2pService) CreateForward(ctx context.Context, req *pb.CreateForwardRequest) (*pb.CreateForwardReply, error)
  • func (s *P2pService) CreateListen(ctx context.Context, req *pb.CreateListenRequest) (*pb.CreateListenReply, error)
  • func (s *P2pService) ListListen(ctx context.Context, req *pb.ListListenRequest) (*pb.ListListenReply, error)
• type VmService
  • func NewVmService(client *client.Client, logger log.Logger) *VmService
  • func (s *VmService) CreateVm(ctx context.Context, req *pb.CreateVmRequest) (*pb.GetVmReply, error)
  • func (s *VmService) DeleteVm(ctx context.Context, req *pb.DeleteVmRequest) (*pb.DeleteVmReply, error)
  • func (s *VmService) GetVm(ctx context.Context, req *pb.GetVmRequest) (*pb.GetVmReply, error)
  • func (s *VmService) ListVm(ctx context.Context, req *pb.ListVmRequest) (*pb.ListVmReply, error)
  • func (s *VmService) StartVm(ctx context.Context, req *pb.GetVmRequest) (*pb.GetVmReply, error)
  • func (s *VmService) StopVm(ctx context.Context, req *pb.GetVmRequest) (*pb.GetVmReply, error)
• type VmWebsocketHandler
  • func NewVmWebsocketHandler(cli *client.Client) *VmWebsocketHandler
  • func (handler *VmWebsocketHandler) Terminal(w http.ResponseWriter, r *http.Request)

Constants

const P2PProtoPrefix = "/x/"

Variables

var ProviderSet = wire.NewSet(
	NewGreeterService,
	NewP2pService,
	NewDockerCli,
	NewVmService,
	NewComputePowerService,
	NewVmWebsocketHandler,
)

ProviderSet is service providers.

Functions

func NewDockerCli

func NewDockerCli() (*client.Client, error)

Types

type ComputePowerService

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

func NewComputePowerService

func NewComputePowerService(ipfsShell *shell.Shell, client *client.Client, logger log.Logger) (*ComputePowerService, error)

func (*ComputePowerService) CancelExecPythonPackage

func (s *ComputePowerService) CancelExecPythonPackage(ctx context.Context, req *pb.CancelExecPythonPackageClientRequest) (*pb.CancelExecPythonPackageClientReply, error)

func (*ComputePowerService) RunPythonPackage

func (s *ComputePowerService) RunPythonPackage(ctx context.Context, req *pb.RunPythonPackageClientRequest) (*pb.RunPythonPackageClientReply, error)

type GreeterService

type GreeterService struct {
	v1.UnimplementedGreeterServer
	// contains filtered or unexported fields
}

GreeterService is a greeter service.

func NewGreeterService

func NewGreeterService(uc *biz.GreeterUsecase) *GreeterService

NewGreeterService new a greeter service.

func (*GreeterService) SayHello

func (s *GreeterService) SayHello(ctx context.Context, in *v1.HelloRequest) (*v1.HelloReply, error)

SayHello implements helloworld.GreeterServer.

type P2pService

type P2pService struct {
	pb.UnimplementedP2PServer
	// contains filtered or unexported fields
}

func NewP2pService

func NewP2pService(ipfsShell *shell.Shell) *P2pService

func (*P2pService) CloseListen

func (s *P2pService) CloseListen(ctx context.Context, req *pb.CloseListenRequest) (*pb.CloseListenReply, error)

func (*P2pService) CreateForward

func (s *P2pService) CreateForward(ctx context.Context, req *pb.CreateForwardRequest) (*pb.CreateForwardReply, error)

func (*P2pService) CreateListen

func (s *P2pService) CreateListen(ctx context.Context, req *pb.CreateListenRequest) (*pb.CreateListenReply, error)

func (*P2pService) ListListen

func (s *P2pService) ListListen(ctx context.Context, req *pb.ListListenRequest) (*pb.ListListenReply, error)

type VmService

type VmService struct {
	pb.UnimplementedVmServer
	// contains filtered or unexported fields
}

func NewVmService

func NewVmService(client *client.Client, logger log.Logger) *VmService

func (*VmService) CreateVm

func (s *VmService) CreateVm(ctx context.Context, req *pb.CreateVmRequest) (*pb.GetVmReply, error)

func (*VmService) DeleteVm

func (s *VmService) DeleteVm(ctx context.Context, req *pb.DeleteVmRequest) (*pb.DeleteVmReply, error)

func (*VmService) GetVm

func (s *VmService) GetVm(ctx context.Context, req *pb.GetVmRequest) (*pb.GetVmReply, error)

func (*VmService) ListVm

func (s *VmService) ListVm(ctx context.Context, req *pb.ListVmRequest) (*pb.ListVmReply, error)

func (*VmService) StartVm

func (s *VmService) StartVm(ctx context.Context, req *pb.GetVmRequest) (*pb.GetVmReply, error)

func (*VmService) StopVm

func (s *VmService) StopVm(ctx context.Context, req *pb.GetVmRequest) (*pb.GetVmReply, error)

type VmWebsocketHandler

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

func NewVmWebsocketHandler

func NewVmWebsocketHandler(cli *client.Client) *VmWebsocketHandler

func (*VmWebsocketHandler) Terminal

func (handler *VmWebsocketHandler) Terminal(w http.ResponseWriter, r *http.Request)