service

package

v0.0.5 Latest Latest Go to latest Published: Sep 27, 2023 License: MIT Imports: 26 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/mohaijiang/computeshare-client

Links

Open Source Insights

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
type VmService
- func NewVmService(client *client.Client, logger log.Logger) *VmService
type VmWebsocketHandler
- func NewVmWebsocketHandler(cli *client.Client) *VmWebsocketHandler
- func (handler *VmWebsocketHandler) Terminal(w http.ResponseWriter, r *http.Request)

Constants ¶

View Source

const P2PProtoPrefix = "/x/"

Variables ¶

View Source

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 ¶ added in v0.0.3

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

func NewComputePowerService ¶ added in v0.0.3

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

func (*ComputePowerService) CancelExecPythonPackage ¶ added in v0.0.3

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

func (*ComputePowerService) RunPythonPackage ¶ added in v0.0.3

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 ¶ added in v0.0.2

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

func (*VmService) StopVm ¶ added in v0.0.2

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

type VmWebsocketHandler ¶ added in v0.0.2

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

func NewVmWebsocketHandler ¶ added in v0.0.2

func NewVmWebsocketHandler(cli *client.Client) *VmWebsocketHandler

func (*VmWebsocketHandler) Terminal ¶ added in v0.0.2

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL