v1

package
v0.0.1 Latest Latest
Warning

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

 Go to latest Published: Sep 14, 2023 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Computepower_RunPythonPackage_FullMethodName = "/api.compute.v1.Computepower/RunPythonPackage"
	Computepower_RunBenchmarks_FullMethodName    = "/api.compute.v1.Computepower/RunBenchmarks"
)
View Source 
const (
	Vm_CreateVm_FullMethodName = "/api.compute.v1.Vm/CreateVm"
	Vm_DeleteVm_FullMethodName = "/api.compute.v1.Vm/DeleteVm"
	Vm_GetVm_FullMethodName    = "/api.compute.v1.Vm/GetVm"
	Vm_ListVm_FullMethodName   = "/api.compute.v1.Vm/ListVm"
)
View Source 
const OperationComputepowerRunBenchmarks = "/api.compute.v1.Computepower/RunBenchmarks"
View Source 
const OperationComputepowerRunPythonPackage = "/api.compute.v1.Computepower/RunPythonPackage"
View Source 
const OperationVmCreateVm = "/api.compute.v1.Vm/CreateVm"
View Source 
const OperationVmDeleteVm = "/api.compute.v1.Vm/DeleteVm"
View Source 
const OperationVmGetVm = "/api.compute.v1.Vm/GetVm"
View Source 
const OperationVmListVm = "/api.compute.v1.Vm/ListVm"

Variables

View Source 
var Computepower_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.compute.v1.Computepower",
	HandlerType: (*ComputepowerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RunPythonPackage",
			Handler:    _Computepower_RunPythonPackage_Handler,
		},
		{
			MethodName: "RunBenchmarks",
			Handler:    _Computepower_RunBenchmarks_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/compute/v1/computepower.proto",
}

Computepower_ServiceDesc is the grpc.ServiceDesc for Computepower service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_api_compute_v1_computepower_proto protoreflect.FileDescriptor
View Source 
var File_api_compute_v1_vm_proto protoreflect.FileDescriptor
View Source 
var Vm_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.compute.v1.Vm",
	HandlerType: (*VmServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateVm",
			Handler:    _Vm_CreateVm_Handler,
		},
		{
			MethodName: "DeleteVm",
			Handler:    _Vm_DeleteVm_Handler,
		},
		{
			MethodName: "GetVm",
			Handler:    _Vm_GetVm_Handler,
		},
		{
			MethodName: "ListVm",
			Handler:    _Vm_ListVm_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/compute/v1/vm.proto",
}

Vm_ServiceDesc is the grpc.ServiceDesc for Vm service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterComputepowerHTTPServer 

func RegisterComputepowerHTTPServer(s *http.Server, srv ComputepowerHTTPServer)

func RegisterComputepowerServer 

func RegisterComputepowerServer(s grpc.ServiceRegistrar, srv ComputepowerServer)

func RegisterVmHTTPServer 

func RegisterVmHTTPServer(s *http.Server, srv VmHTTPServer)

func RegisterVmServer 

func RegisterVmServer(s grpc.ServiceRegistrar, srv VmServer)

Types

type ComputepowerClient 

type ComputepowerClient interface {
	RunPythonPackage(ctx context.Context, in *RunPythonPackageRequest, opts ...grpc.CallOption) (*RunPythonPackageReply, error)
	RunBenchmarks(ctx context.Context, in *RunBenchmarksRequest, opts ...grpc.CallOption) (*RunBenchmarksReply, error)
}

ComputepowerClient is the client API for Computepower service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewComputepowerClient 

func NewComputepowerClient(cc grpc.ClientConnInterface) ComputepowerClient

type ComputepowerHTTPClient 

type ComputepowerHTTPClient interface {
	RunBenchmarks(ctx context.Context, req *RunBenchmarksRequest, opts ...http.CallOption) (rsp *RunBenchmarksReply, err error)
	RunPythonPackage(ctx context.Context, req *RunPythonPackageRequest, opts ...http.CallOption) (rsp *RunPythonPackageReply, err error)
}

func NewComputepowerHTTPClient 

func NewComputepowerHTTPClient(client *http.Client) ComputepowerHTTPClient

type ComputepowerHTTPClientImpl 

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

func (*ComputepowerHTTPClientImpl) RunBenchmarks 

func (c *ComputepowerHTTPClientImpl) RunBenchmarks(ctx context.Context, in *RunBenchmarksRequest, opts ...http.CallOption) (*RunBenchmarksReply, error)

func (*ComputepowerHTTPClientImpl) RunPythonPackage 

func (c *ComputepowerHTTPClientImpl) RunPythonPackage(ctx context.Context, in *RunPythonPackageRequest, opts ...http.CallOption) (*RunPythonPackageReply, error)

type ComputepowerHTTPServer 

type ComputepowerHTTPServer interface {
	RunBenchmarks(context.Context, *RunBenchmarksRequest) (*RunBenchmarksReply, error)
	RunPythonPackage(context.Context, *RunPythonPackageRequest) (*RunPythonPackageReply, error)
}

type ComputepowerServer 

type ComputepowerServer interface {
	RunPythonPackage(context.Context, *RunPythonPackageRequest) (*RunPythonPackageReply, error)
	RunBenchmarks(context.Context, *RunBenchmarksRequest) (*RunBenchmarksReply, error)
	// contains filtered or unexported methods
}

ComputepowerServer is the server API for Computepower service. All implementations must embed UnimplementedComputepowerServer for forward compatibility

type CreateVmRequest 

type CreateVmRequest struct {
	Image string `protobuf:"bytes,1,opt,name=image,proto3" json:"image,omitempty"`
	Port  string `protobuf:"bytes,2,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateVmRequest) Descriptor deprecated 

func (*CreateVmRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateVmRequest.ProtoReflect.Descriptor instead.

func (*CreateVmRequest) GetImage 

func (x *CreateVmRequest) GetImage() string

func (*CreateVmRequest) GetPort 

func (x *CreateVmRequest) GetPort() string

func (*CreateVmRequest) ProtoMessage 

func (*CreateVmRequest) ProtoMessage()

func (*CreateVmRequest) ProtoReflect 

func (x *CreateVmRequest) ProtoReflect() protoreflect.Message

func (*CreateVmRequest) Reset 

func (x *CreateVmRequest) Reset()

func (*CreateVmRequest) String 

func (x *CreateVmRequest) String() string

type DeleteVmReply 

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

func (*DeleteVmReply) Descriptor deprecated 

func (*DeleteVmReply) Descriptor() ([]byte, []int)

Deprecated: Use DeleteVmReply.ProtoReflect.Descriptor instead.

func (*DeleteVmReply) ProtoMessage 

func (*DeleteVmReply) ProtoMessage()

func (*DeleteVmReply) ProtoReflect 

func (x *DeleteVmReply) ProtoReflect() protoreflect.Message

func (*DeleteVmReply) Reset 

func (x *DeleteVmReply) Reset()

func (*DeleteVmReply) String 

func (x *DeleteVmReply) String() string

type DeleteVmRequest 

type DeleteVmRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteVmRequest) Descriptor deprecated 

func (*DeleteVmRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteVmRequest.ProtoReflect.Descriptor instead.

func (*DeleteVmRequest) GetId 

func (x *DeleteVmRequest) GetId() string

func (*DeleteVmRequest) ProtoMessage 

func (*DeleteVmRequest) ProtoMessage()

func (*DeleteVmRequest) ProtoReflect 

func (x *DeleteVmRequest) ProtoReflect() protoreflect.Message

func (*DeleteVmRequest) Reset 

func (x *DeleteVmRequest) Reset()

func (*DeleteVmRequest) String 

func (x *DeleteVmRequest) String() string

type GetVmReply 

type GetVmReply struct {
	Id    string         `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Image string         `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	Ports []*PortBinding `protobuf:"bytes,3,rep,name=ports,proto3" json:"ports,omitempty"`
	// contains filtered or unexported fields
}

func (*GetVmReply) Descriptor deprecated 

func (*GetVmReply) Descriptor() ([]byte, []int)

Deprecated: Use GetVmReply.ProtoReflect.Descriptor instead.

func (*GetVmReply) GetId 

func (x *GetVmReply) GetId() string

func (*GetVmReply) GetImage 

func (x *GetVmReply) GetImage() string

func (*GetVmReply) GetPorts 

func (x *GetVmReply) GetPorts() []*PortBinding

func (*GetVmReply) ProtoMessage 

func (*GetVmReply) ProtoMessage()

func (*GetVmReply) ProtoReflect 

func (x *GetVmReply) ProtoReflect() protoreflect.Message

func (*GetVmReply) Reset 

func (x *GetVmReply) Reset()

func (*GetVmReply) String 

func (x *GetVmReply) String() string

type GetVmRequest 

type GetVmRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetVmRequest) Descriptor deprecated 

func (*GetVmRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetVmRequest.ProtoReflect.Descriptor instead.

func (*GetVmRequest) GetId 

func (x *GetVmRequest) GetId() string

func (*GetVmRequest) ProtoMessage 

func (*GetVmRequest) ProtoMessage()

func (*GetVmRequest) ProtoReflect 

func (x *GetVmRequest) ProtoReflect() protoreflect.Message

func (*GetVmRequest) Reset 

func (x *GetVmRequest) Reset()

func (*GetVmRequest) String 

func (x *GetVmRequest) String() string

type ListVmReply 

type ListVmReply struct {
	Result []*GetVmReply `protobuf:"bytes,1,rep,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*ListVmReply) Descriptor deprecated 

func (*ListVmReply) Descriptor() ([]byte, []int)

Deprecated: Use ListVmReply.ProtoReflect.Descriptor instead.

func (*ListVmReply) GetResult 

func (x *ListVmReply) GetResult() []*GetVmReply

func (*ListVmReply) ProtoMessage 

func (*ListVmReply) ProtoMessage()

func (*ListVmReply) ProtoReflect 

func (x *ListVmReply) ProtoReflect() protoreflect.Message

func (*ListVmReply) Reset 

func (x *ListVmReply) Reset()

func (*ListVmReply) String 

func (x *ListVmReply) String() string

type ListVmRequest 

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

func (*ListVmRequest) Descriptor deprecated 

func (*ListVmRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListVmRequest.ProtoReflect.Descriptor instead.

func (*ListVmRequest) ProtoMessage 

func (*ListVmRequest) ProtoMessage()

func (*ListVmRequest) ProtoReflect 

func (x *ListVmRequest) ProtoReflect() protoreflect.Message

func (*ListVmRequest) Reset 

func (x *ListVmRequest) Reset()

func (*ListVmRequest) String 

func (x *ListVmRequest) String() string

type PortBinding 

type PortBinding struct {
	Ip          string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	PrivatePort uint32 `protobuf:"varint,2,opt,name=private_port,json=privatePort,proto3" json:"private_port,omitempty"`
	PublicPort  uint32 `protobuf:"varint,3,opt,name=public_port,json=publicPort,proto3" json:"public_port,omitempty"`
	Type        string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*PortBinding) Descriptor deprecated 

func (*PortBinding) Descriptor() ([]byte, []int)

Deprecated: Use PortBinding.ProtoReflect.Descriptor instead.

func (*PortBinding) GetIp 

func (x *PortBinding) GetIp() string

func (*PortBinding) GetPrivatePort 

func (x *PortBinding) GetPrivatePort() uint32

func (*PortBinding) GetPublicPort 

func (x *PortBinding) GetPublicPort() uint32

func (*PortBinding) GetType 

func (x *PortBinding) GetType() string

func (*PortBinding) ProtoMessage 

func (*PortBinding) ProtoMessage()

func (*PortBinding) ProtoReflect 

func (x *PortBinding) ProtoReflect() protoreflect.Message

func (*PortBinding) Reset 

func (x *PortBinding) Reset()

func (*PortBinding) String 

func (x *PortBinding) String() string

type RunBenchmarksReply 

type RunBenchmarksReply struct {
	Output string `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"`
	// contains filtered or unexported fields
}

func (*RunBenchmarksReply) Descriptor deprecated 

func (*RunBenchmarksReply) Descriptor() ([]byte, []int)

Deprecated: Use RunBenchmarksReply.ProtoReflect.Descriptor instead.

func (*RunBenchmarksReply) GetOutput 

func (x *RunBenchmarksReply) GetOutput() string

func (*RunBenchmarksReply) ProtoMessage 

func (*RunBenchmarksReply) ProtoMessage()

func (*RunBenchmarksReply) ProtoReflect 

func (x *RunBenchmarksReply) ProtoReflect() protoreflect.Message

func (*RunBenchmarksReply) Reset 

func (x *RunBenchmarksReply) Reset()

func (*RunBenchmarksReply) String 

func (x *RunBenchmarksReply) String() string

type RunBenchmarksRequest 

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

func (*RunBenchmarksRequest) Descriptor deprecated 

func (*RunBenchmarksRequest) Descriptor() ([]byte, []int)

Deprecated: Use RunBenchmarksRequest.ProtoReflect.Descriptor instead.

func (*RunBenchmarksRequest) ProtoMessage 

func (*RunBenchmarksRequest) ProtoMessage()

func (*RunBenchmarksRequest) ProtoReflect 

func (x *RunBenchmarksRequest) ProtoReflect() protoreflect.Message

func (*RunBenchmarksRequest) Reset 

func (x *RunBenchmarksRequest) Reset()

func (*RunBenchmarksRequest) String 

func (x *RunBenchmarksRequest) String() string

type RunPythonPackageReply 

type RunPythonPackageReply struct {
	Output string `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"`
	// contains filtered or unexported fields
}

func (*RunPythonPackageReply) Descriptor deprecated 

func (*RunPythonPackageReply) Descriptor() ([]byte, []int)

Deprecated: Use RunPythonPackageReply.ProtoReflect.Descriptor instead.

func (*RunPythonPackageReply) GetOutput 

func (x *RunPythonPackageReply) GetOutput() string

func (*RunPythonPackageReply) ProtoMessage 

func (*RunPythonPackageReply) ProtoMessage()

func (*RunPythonPackageReply) ProtoReflect 

func (x *RunPythonPackageReply) ProtoReflect() protoreflect.Message

func (*RunPythonPackageReply) Reset 

func (x *RunPythonPackageReply) Reset()

func (*RunPythonPackageReply) String 

func (x *RunPythonPackageReply) String() string

type RunPythonPackageRequest 

type RunPythonPackageRequest struct {
	Cid     string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
	Command string `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"`
	// contains filtered or unexported fields
}

func (*RunPythonPackageRequest) Descriptor deprecated 

func (*RunPythonPackageRequest) Descriptor() ([]byte, []int)

Deprecated: Use RunPythonPackageRequest.ProtoReflect.Descriptor instead.

func (*RunPythonPackageRequest) GetCid 

func (x *RunPythonPackageRequest) GetCid() string

func (*RunPythonPackageRequest) GetCommand 

func (x *RunPythonPackageRequest) GetCommand() string

func (*RunPythonPackageRequest) ProtoMessage 

func (*RunPythonPackageRequest) ProtoMessage()

func (*RunPythonPackageRequest) ProtoReflect 

func (x *RunPythonPackageRequest) ProtoReflect() protoreflect.Message

func (*RunPythonPackageRequest) Reset 

func (x *RunPythonPackageRequest) Reset()

func (*RunPythonPackageRequest) String 

func (x *RunPythonPackageRequest) String() string

type UnimplementedComputepowerServer 

type UnimplementedComputepowerServer struct {
}

UnimplementedComputepowerServer must be embedded to have forward compatible implementations.

func (UnimplementedComputepowerServer) RunBenchmarks 

func (UnimplementedComputepowerServer) RunBenchmarks(context.Context, *RunBenchmarksRequest) (*RunBenchmarksReply, error)

func (UnimplementedComputepowerServer) RunPythonPackage 

func (UnimplementedComputepowerServer) RunPythonPackage(context.Context, *RunPythonPackageRequest) (*RunPythonPackageReply, error)

type UnimplementedVmServer 

type UnimplementedVmServer struct {
}

UnimplementedVmServer must be embedded to have forward compatible implementations.

func (UnimplementedVmServer) CreateVm 

func (UnimplementedVmServer) CreateVm(context.Context, *CreateVmRequest) (*GetVmReply, error)

func (UnimplementedVmServer) DeleteVm 

func (UnimplementedVmServer) DeleteVm(context.Context, *DeleteVmRequest) (*DeleteVmReply, error)

func (UnimplementedVmServer) GetVm 

func (UnimplementedVmServer) GetVm(context.Context, *GetVmRequest) (*GetVmReply, error)

func (UnimplementedVmServer) ListVm 

func (UnimplementedVmServer) ListVm(context.Context, *ListVmRequest) (*ListVmReply, error)

type UnsafeComputepowerServer 

type UnsafeComputepowerServer interface {
	// contains filtered or unexported methods
}

UnsafeComputepowerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ComputepowerServer will result in compilation errors.

type UnsafeVmServer 

type UnsafeVmServer interface {
	// contains filtered or unexported methods
}

UnsafeVmServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to VmServer will result in compilation errors.

type VmClient 

type VmClient interface {
	CreateVm(ctx context.Context, in *CreateVmRequest, opts ...grpc.CallOption) (*GetVmReply, error)
	DeleteVm(ctx context.Context, in *DeleteVmRequest, opts ...grpc.CallOption) (*DeleteVmReply, error)
	GetVm(ctx context.Context, in *GetVmRequest, opts ...grpc.CallOption) (*GetVmReply, error)
	ListVm(ctx context.Context, in *ListVmRequest, opts ...grpc.CallOption) (*ListVmReply, error)
}

VmClient is the client API for Vm service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewVmClient 

func NewVmClient(cc grpc.ClientConnInterface) VmClient

type VmHTTPClient 

type VmHTTPClient interface {
	CreateVm(ctx context.Context, req *CreateVmRequest, opts ...http.CallOption) (rsp *GetVmReply, err error)
	DeleteVm(ctx context.Context, req *DeleteVmRequest, opts ...http.CallOption) (rsp *DeleteVmReply, err error)
	GetVm(ctx context.Context, req *GetVmRequest, opts ...http.CallOption) (rsp *GetVmReply, err error)
	ListVm(ctx context.Context, req *ListVmRequest, opts ...http.CallOption) (rsp *ListVmReply, err error)
}

func NewVmHTTPClient 

func NewVmHTTPClient(client *http.Client) VmHTTPClient

type VmHTTPClientImpl 

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

func (*VmHTTPClientImpl) CreateVm 

func (c *VmHTTPClientImpl) CreateVm(ctx context.Context, in *CreateVmRequest, opts ...http.CallOption) (*GetVmReply, error)

func (*VmHTTPClientImpl) DeleteVm 

func (c *VmHTTPClientImpl) DeleteVm(ctx context.Context, in *DeleteVmRequest, opts ...http.CallOption) (*DeleteVmReply, error)

func (*VmHTTPClientImpl) GetVm 

func (c *VmHTTPClientImpl) GetVm(ctx context.Context, in *GetVmRequest, opts ...http.CallOption) (*GetVmReply, error)

func (*VmHTTPClientImpl) ListVm 

func (c *VmHTTPClientImpl) ListVm(ctx context.Context, in *ListVmRequest, opts ...http.CallOption) (*ListVmReply, error)

type VmHTTPServer 

type VmHTTPServer interface {
	CreateVm(context.Context, *CreateVmRequest) (*GetVmReply, error)
	DeleteVm(context.Context, *DeleteVmRequest) (*DeleteVmReply, error)
	GetVm(context.Context, *GetVmRequest) (*GetVmReply, error)
	ListVm(context.Context, *ListVmRequest) (*ListVmReply, error)
}

type VmServer 

type VmServer interface {
	CreateVm(context.Context, *CreateVmRequest) (*GetVmReply, error)
	DeleteVm(context.Context, *DeleteVmRequest) (*DeleteVmReply, error)
	GetVm(context.Context, *GetVmRequest) (*GetVmReply, error)
	ListVm(context.Context, *ListVmRequest) (*ListVmReply, error)
	// contains filtered or unexported methods
}

VmServer is the server API for Vm service. All implementations must embed UnimplementedVmServer for forward compatibility

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.