pb

package
v0.1.2 Latest Latest
Warning

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

 Go to latest Published: May 19, 2023 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	AgentRpcServer_Ping_FullMethodName     = "/pb.AgentRpcServer/Ping"
	AgentRpcServer_StartApp_FullMethodName = "/pb.AgentRpcServer/StartApp"
	AgentRpcServer_StopApp_FullMethodName  = "/pb.AgentRpcServer/StopApp"
)

Variables

View Source 
var (
	UESSInstanceStatus_name = map[int32]string{
		0: "All",
		1: "Active",
		2: "Dead",
	}
	UESSInstanceStatus_value = map[string]int32{
		"All":    0,
		"Active": 1,
		"Dead":   2,
	}
)

Enum value maps for UESSInstanceStatus.

View Source 
var AgentRpcServer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.AgentRpcServer",
	HandlerType: (*AgentRpcServerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ping",
			Handler:    _AgentRpcServer_Ping_Handler,
		},
		{
			MethodName: "StartApp",
			Handler:    _AgentRpcServer_StartApp_Handler,
		},
		{
			MethodName: "StopApp",
			Handler:    _AgentRpcServer_StopApp_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "uess-agent.proto",
}

AgentRpcServer_ServiceDesc is the grpc.ServiceDesc for AgentRpcServer 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_uess_agent_proto protoreflect.FileDescriptor
View Source 
var File_uess_enum_proto protoreflect.FileDescriptor
View Source 
var File_uess_host_proto protoreflect.FileDescriptor
View Source 
var File_uess_instance_proto protoreflect.FileDescriptor

Functions

func RegisterAgentRpcServerServer 

func RegisterAgentRpcServerServer(s grpc.ServiceRegistrar, srv AgentRpcServerServer)

Types

type AgentRpcServerClient 

type AgentRpcServerClient interface {
	// 心跳
	Ping(ctx context.Context, in *UESSRpcPingRequest, opts ...grpc.CallOption) (*UESSRpcPingResponse, error)
	// 启动应用
	StartApp(ctx context.Context, in *UESSStartAppRequest, opts ...grpc.CallOption) (*UESSStartAppResponse, error)
	// 停止应用
	StopApp(ctx context.Context, in *UESSStopAppRequest, opts ...grpc.CallOption) (*UESSStopAppResponse, error)
}

AgentRpcServerClient is the client API for AgentRpcServer 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 NewAgentRpcServerClient 

func NewAgentRpcServerClient(cc grpc.ClientConnInterface) AgentRpcServerClient

type AgentRpcServerServer 

type AgentRpcServerServer interface {
	// 心跳
	Ping(context.Context, *UESSRpcPingRequest) (*UESSRpcPingResponse, error)
	// 启动应用
	StartApp(context.Context, *UESSStartAppRequest) (*UESSStartAppResponse, error)
	// 停止应用
	StopApp(context.Context, *UESSStopAppRequest) (*UESSStopAppResponse, error)
	// contains filtered or unexported methods
}

AgentRpcServerServer is the server API for AgentRpcServer service. All implementations must embed UnimplementedAgentRpcServerServer for forward compatibility

type UESSCreateInstanceRequest 

type UESSCreateInstanceRequest struct {
	AppName string `protobuf:"bytes,1,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"` // 应用名称
	// contains filtered or unexported fields
}

创建实例 POST token_option /api/v1/instance/create

func (*UESSCreateInstanceRequest) Descriptor deprecated 

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

Deprecated: Use UESSCreateInstanceRequest.ProtoReflect.Descriptor instead.

func (*UESSCreateInstanceRequest) GetAppName 

func (x *UESSCreateInstanceRequest) GetAppName() string

func (*UESSCreateInstanceRequest) ProtoMessage 

func (*UESSCreateInstanceRequest) ProtoMessage()

func (*UESSCreateInstanceRequest) ProtoReflect 

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

func (*UESSCreateInstanceRequest) Reset 

func (x *UESSCreateInstanceRequest) Reset()

func (*UESSCreateInstanceRequest) String 

func (x *UESSCreateInstanceRequest) String() string

type UESSCreateInstanceResponse 

type UESSCreateInstanceResponse struct {
	Msg        string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	Code       int32  `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"`
	InstanceId string `protobuf:"bytes,3,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"` // 实例ID
	WsUrl      string `protobuf:"bytes,4,opt,name=ws_url,json=wsUrl,proto3" json:"ws_url,omitempty"`
	// contains filtered or unexported fields
}

func (*UESSCreateInstanceResponse) Descriptor deprecated 

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

Deprecated: Use UESSCreateInstanceResponse.ProtoReflect.Descriptor instead.

func (*UESSCreateInstanceResponse) GetCode 

func (x *UESSCreateInstanceResponse) GetCode() int32

func (*UESSCreateInstanceResponse) GetInstanceId 

func (x *UESSCreateInstanceResponse) GetInstanceId() string

func (*UESSCreateInstanceResponse) GetMsg 

func (x *UESSCreateInstanceResponse) GetMsg() string

func (*UESSCreateInstanceResponse) GetWsUrl 

func (x *UESSCreateInstanceResponse) GetWsUrl() string

func (*UESSCreateInstanceResponse) ProtoMessage 

func (*UESSCreateInstanceResponse) ProtoMessage()

func (*UESSCreateInstanceResponse) ProtoReflect 

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

func (*UESSCreateInstanceResponse) Reset 

func (x *UESSCreateInstanceResponse) Reset()

func (*UESSCreateInstanceResponse) String 

func (x *UESSCreateInstanceResponse) String() string

type UESSHostRegisterRequest 

type UESSHostRegisterRequest struct {
	HostIp string `protobuf:"bytes,1,opt,name=host_ip,json=hostIp,proto3" json:"host_ip,omitempty"`
	Port   uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

主机注册 POST token_option /api/v1/host/register

func (*UESSHostRegisterRequest) Descriptor deprecated 

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

Deprecated: Use UESSHostRegisterRequest.ProtoReflect.Descriptor instead.

func (*UESSHostRegisterRequest) GetHostIp 

func (x *UESSHostRegisterRequest) GetHostIp() string

func (*UESSHostRegisterRequest) GetPort 

func (x *UESSHostRegisterRequest) GetPort() uint32

func (*UESSHostRegisterRequest) ProtoMessage 

func (*UESSHostRegisterRequest) ProtoMessage()

func (*UESSHostRegisterRequest) ProtoReflect 

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

func (*UESSHostRegisterRequest) Reset 

func (x *UESSHostRegisterRequest) Reset()

func (*UESSHostRegisterRequest) String 

func (x *UESSHostRegisterRequest) String() string

type UESSHostRegisterResponse 

type UESSHostRegisterResponse struct {
	Msg  string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	Code int32  `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"`
	// contains filtered or unexported fields
}

func (*UESSHostRegisterResponse) Descriptor deprecated 

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

Deprecated: Use UESSHostRegisterResponse.ProtoReflect.Descriptor instead.

func (*UESSHostRegisterResponse) GetCode 

func (x *UESSHostRegisterResponse) GetCode() int32

func (*UESSHostRegisterResponse) GetMsg 

func (x *UESSHostRegisterResponse) GetMsg() string

func (*UESSHostRegisterResponse) ProtoMessage 

func (*UESSHostRegisterResponse) ProtoMessage()

func (*UESSHostRegisterResponse) ProtoReflect 

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

func (*UESSHostRegisterResponse) Reset 

func (x *UESSHostRegisterResponse) Reset()

func (*UESSHostRegisterResponse) String 

func (x *UESSHostRegisterResponse) String() string

type UESSInstanceListRequest 

type UESSInstanceListRequest struct {
	Status UESSInstanceStatus `protobuf:"varint,1,opt,name=status,proto3,enum=pb.UESSInstanceStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

创建实例 POST token_option /api/v1/instance/list

func (*UESSInstanceListRequest) Descriptor deprecated 

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

Deprecated: Use UESSInstanceListRequest.ProtoReflect.Descriptor instead.

func (*UESSInstanceListRequest) GetStatus 

func (x *UESSInstanceListRequest) GetStatus() UESSInstanceStatus

func (*UESSInstanceListRequest) ProtoMessage 

func (*UESSInstanceListRequest) ProtoMessage()

func (*UESSInstanceListRequest) ProtoReflect 

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

func (*UESSInstanceListRequest) Reset 

func (x *UESSInstanceListRequest) Reset()

func (*UESSInstanceListRequest) String 

func (x *UESSInstanceListRequest) String() string

type UESSInstanceListResponse 

type UESSInstanceListResponse struct {
	Msg        string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	Code       int32  `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"`
	InstanceId string `protobuf:"bytes,3,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"` // 实例ID
	WsUrl      string `protobuf:"bytes,4,opt,name=ws_url,json=wsUrl,proto3" json:"ws_url,omitempty"`
	// contains filtered or unexported fields
}

func (*UESSInstanceListResponse) Descriptor deprecated 

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

Deprecated: Use UESSInstanceListResponse.ProtoReflect.Descriptor instead.

func (*UESSInstanceListResponse) GetCode 

func (x *UESSInstanceListResponse) GetCode() int32

func (*UESSInstanceListResponse) GetInstanceId 

func (x *UESSInstanceListResponse) GetInstanceId() string

func (*UESSInstanceListResponse) GetMsg 

func (x *UESSInstanceListResponse) GetMsg() string

func (*UESSInstanceListResponse) GetWsUrl 

func (x *UESSInstanceListResponse) GetWsUrl() string

func (*UESSInstanceListResponse) ProtoMessage 

func (*UESSInstanceListResponse) ProtoMessage()

func (*UESSInstanceListResponse) ProtoReflect 

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

func (*UESSInstanceListResponse) Reset 

func (x *UESSInstanceListResponse) Reset()

func (*UESSInstanceListResponse) String 

func (x *UESSInstanceListResponse) String() string

type UESSInstanceStatus 

type UESSInstanceStatus int32

实例状态 

const (
	UESSInstanceStatus_All    UESSInstanceStatus = 0
	UESSInstanceStatus_Active UESSInstanceStatus = 1
	UESSInstanceStatus_Dead   UESSInstanceStatus = 2
)

func (UESSInstanceStatus) Descriptor 

func (UESSInstanceStatus) Descriptor() protoreflect.EnumDescriptor

func (UESSInstanceStatus) Enum 

func (x UESSInstanceStatus) Enum() *UESSInstanceStatus

func (UESSInstanceStatus) EnumDescriptor deprecated 

func (UESSInstanceStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use UESSInstanceStatus.Descriptor instead.

func (UESSInstanceStatus) Number 

func (x UESSInstanceStatus) Number() protoreflect.EnumNumber

func (UESSInstanceStatus) String 

func (x UESSInstanceStatus) String() string

func (UESSInstanceStatus) Type 

func (UESSInstanceStatus) Type() protoreflect.EnumType

type UESSRemoveInstanceRequest 

type UESSRemoveInstanceRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"` // 实例ID
	// contains filtered or unexported fields
}

移除实例 POST token_option /api/v1/instance/remove

func (*UESSRemoveInstanceRequest) Descriptor deprecated 

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

Deprecated: Use UESSRemoveInstanceRequest.ProtoReflect.Descriptor instead.

func (*UESSRemoveInstanceRequest) GetInstanceId 

func (x *UESSRemoveInstanceRequest) GetInstanceId() string

func (*UESSRemoveInstanceRequest) ProtoMessage 

func (*UESSRemoveInstanceRequest) ProtoMessage()

func (*UESSRemoveInstanceRequest) ProtoReflect 

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

func (*UESSRemoveInstanceRequest) Reset 

func (x *UESSRemoveInstanceRequest) Reset()

func (*UESSRemoveInstanceRequest) String 

func (x *UESSRemoveInstanceRequest) String() string

type UESSRemoveInstanceResponse 

type UESSRemoveInstanceResponse struct {
	Msg  string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	Code int32  `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"`
	// contains filtered or unexported fields
}

func (*UESSRemoveInstanceResponse) Descriptor deprecated 

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

Deprecated: Use UESSRemoveInstanceResponse.ProtoReflect.Descriptor instead.

func (*UESSRemoveInstanceResponse) GetCode 

func (x *UESSRemoveInstanceResponse) GetCode() int32

func (*UESSRemoveInstanceResponse) GetMsg 

func (x *UESSRemoveInstanceResponse) GetMsg() string

func (*UESSRemoveInstanceResponse) ProtoMessage 

func (*UESSRemoveInstanceResponse) ProtoMessage()

func (*UESSRemoveInstanceResponse) ProtoReflect 

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

func (*UESSRemoveInstanceResponse) Reset 

func (x *UESSRemoveInstanceResponse) Reset()

func (*UESSRemoveInstanceResponse) String 

func (x *UESSRemoveInstanceResponse) String() string

type UESSRpcPingRequest 

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

func (*UESSRpcPingRequest) Descriptor deprecated 

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

Deprecated: Use UESSRpcPingRequest.ProtoReflect.Descriptor instead.

func (*UESSRpcPingRequest) ProtoMessage 

func (*UESSRpcPingRequest) ProtoMessage()

func (*UESSRpcPingRequest) ProtoReflect 

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

func (*UESSRpcPingRequest) Reset 

func (x *UESSRpcPingRequest) Reset()

func (*UESSRpcPingRequest) String 

func (x *UESSRpcPingRequest) String() string

type UESSRpcPingResponse 

type UESSRpcPingResponse struct {
	Code       int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Msg        string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	FreeCpu    int32  `protobuf:"varint,3,opt,name=free_cpu,json=freeCpu,proto3" json:"free_cpu,omitempty"`
	FreeGpu    int32  `protobuf:"varint,4,opt,name=free_gpu,json=freeGpu,proto3" json:"free_gpu,omitempty"`
	FreeMemory int32  `protobuf:"varint,5,opt,name=free_memory,json=freeMemory,proto3" json:"free_memory,omitempty"`
	// contains filtered or unexported fields
}

func (*UESSRpcPingResponse) Descriptor deprecated 

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

Deprecated: Use UESSRpcPingResponse.ProtoReflect.Descriptor instead.

func (*UESSRpcPingResponse) GetCode added in v0.1.1 

func (x *UESSRpcPingResponse) GetCode() int32

func (*UESSRpcPingResponse) GetFreeCpu 

func (x *UESSRpcPingResponse) GetFreeCpu() int32

func (*UESSRpcPingResponse) GetFreeGpu 

func (x *UESSRpcPingResponse) GetFreeGpu() int32

func (*UESSRpcPingResponse) GetFreeMemory 

func (x *UESSRpcPingResponse) GetFreeMemory() int32

func (*UESSRpcPingResponse) GetMsg added in v0.1.1 

func (x *UESSRpcPingResponse) GetMsg() string

func (*UESSRpcPingResponse) ProtoMessage 

func (*UESSRpcPingResponse) ProtoMessage()

func (*UESSRpcPingResponse) ProtoReflect 

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

func (*UESSRpcPingResponse) Reset 

func (x *UESSRpcPingResponse) Reset()

func (*UESSRpcPingResponse) String 

func (x *UESSRpcPingResponse) String() string

type UESSStartAppRequest 

type UESSStartAppRequest struct {
	AppName string `protobuf:"bytes,1,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"`
	SlsHost string `protobuf:"bytes,2,opt,name=sls_host,json=slsHost,proto3" json:"sls_host,omitempty"`
	Port    uint32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*UESSStartAppRequest) Descriptor deprecated 

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

Deprecated: Use UESSStartAppRequest.ProtoReflect.Descriptor instead.

func (*UESSStartAppRequest) GetAppName 

func (x *UESSStartAppRequest) GetAppName() string

func (*UESSStartAppRequest) GetPort added in v0.1.2 

func (x *UESSStartAppRequest) GetPort() uint32

func (*UESSStartAppRequest) GetSlsHost added in v0.1.2 

func (x *UESSStartAppRequest) GetSlsHost() string

func (*UESSStartAppRequest) ProtoMessage 

func (*UESSStartAppRequest) ProtoMessage()

func (*UESSStartAppRequest) ProtoReflect 

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

func (*UESSStartAppRequest) Reset 

func (x *UESSStartAppRequest) Reset()

func (*UESSStartAppRequest) String 

func (x *UESSStartAppRequest) String() string

type UESSStartAppResponse 

type UESSStartAppResponse struct {
	Code int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Msg  string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*UESSStartAppResponse) Descriptor deprecated 

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

Deprecated: Use UESSStartAppResponse.ProtoReflect.Descriptor instead.

func (*UESSStartAppResponse) GetCode 

func (x *UESSStartAppResponse) GetCode() int32

func (*UESSStartAppResponse) GetMsg 

func (x *UESSStartAppResponse) GetMsg() string

func (*UESSStartAppResponse) ProtoMessage 

func (*UESSStartAppResponse) ProtoMessage()

func (*UESSStartAppResponse) ProtoReflect 

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

func (*UESSStartAppResponse) Reset 

func (x *UESSStartAppResponse) Reset()

func (*UESSStartAppResponse) String 

func (x *UESSStartAppResponse) String() string

type UESSStopAppRequest 

type UESSStopAppRequest struct {
	Pid int32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
	// contains filtered or unexported fields
}

func (*UESSStopAppRequest) Descriptor deprecated 

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

Deprecated: Use UESSStopAppRequest.ProtoReflect.Descriptor instead.

func (*UESSStopAppRequest) GetPid 

func (x *UESSStopAppRequest) GetPid() int32

func (*UESSStopAppRequest) ProtoMessage 

func (*UESSStopAppRequest) ProtoMessage()

func (*UESSStopAppRequest) ProtoReflect 

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

func (*UESSStopAppRequest) Reset 

func (x *UESSStopAppRequest) Reset()

func (*UESSStopAppRequest) String 

func (x *UESSStopAppRequest) String() string

type UESSStopAppResponse 

type UESSStopAppResponse struct {
	Code int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Msg  string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*UESSStopAppResponse) Descriptor deprecated 

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

Deprecated: Use UESSStopAppResponse.ProtoReflect.Descriptor instead.

func (*UESSStopAppResponse) GetCode 

func (x *UESSStopAppResponse) GetCode() int32

func (*UESSStopAppResponse) GetMsg 

func (x *UESSStopAppResponse) GetMsg() string

func (*UESSStopAppResponse) ProtoMessage 

func (*UESSStopAppResponse) ProtoMessage()

func (*UESSStopAppResponse) ProtoReflect 

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

func (*UESSStopAppResponse) Reset 

func (x *UESSStopAppResponse) Reset()

func (*UESSStopAppResponse) String 

func (x *UESSStopAppResponse) String() string

type UnimplementedAgentRpcServerServer 

type UnimplementedAgentRpcServerServer struct {
}

UnimplementedAgentRpcServerServer must be embedded to have forward compatible implementations.

func (UnimplementedAgentRpcServerServer) Ping 

func (UnimplementedAgentRpcServerServer) Ping(context.Context, *UESSRpcPingRequest) (*UESSRpcPingResponse, error)

func (UnimplementedAgentRpcServerServer) StartApp 

func (UnimplementedAgentRpcServerServer) StartApp(context.Context, *UESSStartAppRequest) (*UESSStartAppResponse, error)

func (UnimplementedAgentRpcServerServer) StopApp 

func (UnimplementedAgentRpcServerServer) StopApp(context.Context, *UESSStopAppRequest) (*UESSStopAppResponse, error)

type UnsafeAgentRpcServerServer 

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

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

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.