Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterServiceInterfaceHTTPServer(s *http.Server, srv ServiceInterfaceHTTPServer)
- func RegisterServiceInterfaceServer(s grpc.ServiceRegistrar, srv ServiceInterfaceServer)
- type CD
- type CI
- func (*CI) Descriptor() ([]byte, []int)deprecated
- func (x *CI) GetArgs() string
- func (x *CI) GetBranch() string
- func (x *CI) GetDescription() string
- func (x *CI) GetID() int64
- func (x *CI) GetServiceID() int64
- func (x *CI) GetTag() string
- func (x *CI) GetVersion() string
- func (x *CI) GetWorkflowName() string
- func (*CI) ProtoMessage()
- func (x *CI) ProtoReflect() protoreflect.Message
- func (x *CI) Reset()
- func (x *CI) String() string
- type ErrorReason
- func (ErrorReason) Descriptor() protoreflect.EnumDescriptor
- func (x ErrorReason) Enum() *ErrorReason
- func (ErrorReason) EnumDescriptor() ([]byte, []int)deprecated
- func (x ErrorReason) Number() protoreflect.EnumNumber
- func (x ErrorReason) String() string
- func (ErrorReason) Type() protoreflect.EnumType
- type Msg
- type Port
- func (*Port) Descriptor() ([]byte, []int)deprecated
- func (x *Port) GetContainerPort() int32
- func (x *Port) GetID() int64
- func (x *Port) GetIngressPath() string
- func (x *Port) GetProtocol() string
- func (*Port) ProtoMessage()
- func (x *Port) ProtoReflect() protoreflect.Message
- func (x *Port) Reset()
- func (x *Port) String() string
- type Service
- func (*Service) Descriptor() ([]byte, []int)deprecated
- func (x *Service) GetBusiness() string
- func (x *Service) GetCPU() float32
- func (x *Service) GetCodeRepo() string
- func (x *Service) GetDisk() float32
- func (x *Service) GetGPU() float32
- func (x *Service) GetID() int64
- func (x *Service) GetLimitCpu() float32
- func (x *Service) GetLimitDisk() float32
- func (x *Service) GetLimitGPU() float32
- func (x *Service) GetLimitMemory() float32
- func (x *Service) GetMemory() float32
- func (x *Service) GetName() string
- func (x *Service) GetPorts() []*Port
- func (x *Service) GetProjectID() int64
- func (x *Service) GetProjectName() string
- func (x *Service) GetReplicas() int32
- func (x *Service) GetTechnology() string
- func (x *Service) GetWorkflowID() int64
- func (*Service) ProtoMessage()
- func (x *Service) ProtoReflect() protoreflect.Message
- func (x *Service) Reset()
- func (x *Service) String() string
- type ServiceInterfaceClient
- type ServiceInterfaceHTTPClient
- type ServiceInterfaceHTTPClientImpl
- func (c *ServiceInterfaceHTTPClientImpl) Get(ctx context.Context, in *ServiceRequest, opts ...http.CallOption) (*Service, error)
- func (c *ServiceInterfaceHTTPClientImpl) List(ctx context.Context, in *ServiceRequest, opts ...http.CallOption) (*Services, error)
- func (c *ServiceInterfaceHTTPClientImpl) Ping(ctx context.Context, in *emptypb.Empty, opts ...http.CallOption) (*Msg, error)
- func (c *ServiceInterfaceHTTPClientImpl) Save(ctx context.Context, in *Service, opts ...http.CallOption) (*Msg, error)
- type ServiceInterfaceHTTPServer
- type ServiceInterfaceServer
- type ServiceRequest
- func (*ServiceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ServiceRequest) GetId() int64
- func (x *ServiceRequest) GetName() string
- func (x *ServiceRequest) GetPage() int64
- func (x *ServiceRequest) GetPageSize() int64
- func (x *ServiceRequest) GetProjectId() int64
- func (*ServiceRequest) ProtoMessage()
- func (x *ServiceRequest) ProtoReflect() protoreflect.Message
- func (x *ServiceRequest) Reset()
- func (x *ServiceRequest) String() string
- type Services
- type UnimplementedServiceInterfaceServer
- func (UnimplementedServiceInterfaceServer) Get(context.Context, *ServiceRequest) (*Service, error)
- func (UnimplementedServiceInterfaceServer) List(context.Context, *ServiceRequest) (*Services, error)
- func (UnimplementedServiceInterfaceServer) Ping(context.Context, *emptypb.Empty) (*Msg, error)
- func (UnimplementedServiceInterfaceServer) Save(context.Context, *Service) (*Msg, error)
- type UnsafeServiceInterfaceServer
- type Worklfow
- func (*Worklfow) Descriptor() ([]byte, []int)deprecated
- func (x *Worklfow) GetID() int64
- func (x *Worklfow) GetName() string
- func (x *Worklfow) GetWorklfow() []byte
- func (*Worklfow) ProtoMessage()
- func (x *Worklfow) ProtoReflect() protoreflect.Message
- func (x *Worklfow) Reset()
- func (x *Worklfow) String() string
Constants ¶
const ( ServiceInterface_Ping_FullMethodName = "/service.v1alpha1.ServiceInterface/Ping" ServiceInterface_List_FullMethodName = "/service.v1alpha1.ServiceInterface/List" ServiceInterface_Save_FullMethodName = "/service.v1alpha1.ServiceInterface/Save" ServiceInterface_Get_FullMethodName = "/service.v1alpha1.ServiceInterface/Get" )
const OperationServiceInterfaceGet = "/service.v1alpha1.ServiceInterface/Get"
const OperationServiceInterfaceList = "/service.v1alpha1.ServiceInterface/List"
const OperationServiceInterfacePing = "/service.v1alpha1.ServiceInterface/Ping"
const OperationServiceInterfaceSave = "/service.v1alpha1.ServiceInterface/Save"
Variables ¶
var ( ErrorReason_name = map[int32]string{ 0: "SUCCEED", 1: "FAILED", } ErrorReason_value = map[string]int32{ "SUCCEED": 0, "FAILED": 1, } )
Enum value maps for ErrorReason.
var File_api_service_v1alpha1_error_reason_proto protoreflect.FileDescriptor
var File_api_service_v1alpha1_message_proto protoreflect.FileDescriptor
var File_api_service_v1alpha1_service_proto protoreflect.FileDescriptor
var ServiceInterface_ServiceDesc = grpc.ServiceDesc{ ServiceName: "service.v1alpha1.ServiceInterface", HandlerType: (*ServiceInterfaceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Ping", Handler: _ServiceInterface_Ping_Handler, }, { MethodName: "List", Handler: _ServiceInterface_List_Handler, }, { MethodName: "Save", Handler: _ServiceInterface_Save_Handler, }, { MethodName: "Get", Handler: _ServiceInterface_Get_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "api/service/v1alpha1/service.proto", }
ServiceInterface_ServiceDesc is the grpc.ServiceDesc for ServiceInterface service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterServiceInterfaceHTTPServer ¶
func RegisterServiceInterfaceHTTPServer(s *http.Server, srv ServiceInterfaceHTTPServer)
func RegisterServiceInterfaceServer ¶
func RegisterServiceInterfaceServer(s grpc.ServiceRegistrar, srv ServiceInterfaceServer)
Types ¶
type CD ¶
type CD struct { ID int64 `protobuf:"varint,1,opt,name=ID,json=id,proto3" json:"ID,omitempty"` ServiceID int64 `protobuf:"varint,2,opt,name=ServiceID,json=service_id,proto3" json:"ServiceID,omitempty"` // contains filtered or unexported fields }
func (*CD) Descriptor
deprecated
func (*CD) GetServiceID ¶
func (*CD) ProtoMessage ¶
func (*CD) ProtoMessage()
func (*CD) ProtoReflect ¶
func (x *CD) ProtoReflect() protoreflect.Message
type CI ¶
type CI struct { ID int64 `protobuf:"varint,1,opt,name=ID,json=id,proto3" json:"ID,omitempty"` Version string `protobuf:"bytes,2,opt,name=Version,json=version,proto3" json:"Version,omitempty"` Branch string `protobuf:"bytes,3,opt,name=Branch,json=branch,proto3" json:"Branch,omitempty"` Tag string `protobuf:"bytes,4,opt,name=Tag,json=tag,proto3" json:"Tag,omitempty"` Args string `protobuf:"bytes,5,opt,name=Args,json=args,proto3" json:"Args,omitempty"` Description string `protobuf:"bytes,6,opt,name=Description,json=description,proto3" json:"Description,omitempty"` WorkflowName string `protobuf:"bytes,7,opt,name=WorkflowName,json=workflow_name,proto3" json:"WorkflowName,omitempty"` ServiceID int64 `protobuf:"varint,8,opt,name=ServiceID,json=service_id,proto3" json:"ServiceID,omitempty"` // contains filtered or unexported fields }
func (*CI) Descriptor
deprecated
func (*CI) GetDescription ¶
func (*CI) GetServiceID ¶
func (*CI) GetVersion ¶
func (*CI) GetWorkflowName ¶
func (*CI) ProtoMessage ¶
func (*CI) ProtoMessage()
func (*CI) ProtoReflect ¶
func (x *CI) ProtoReflect() protoreflect.Message
type ErrorReason ¶
type ErrorReason int32
const ( ErrorReason_SUCCEED ErrorReason = 0 ErrorReason_FAILED ErrorReason = 1 )
func (ErrorReason) Descriptor ¶
func (ErrorReason) Descriptor() protoreflect.EnumDescriptor
func (ErrorReason) Enum ¶
func (x ErrorReason) Enum() *ErrorReason
func (ErrorReason) EnumDescriptor
deprecated
func (ErrorReason) EnumDescriptor() ([]byte, []int)
Deprecated: Use ErrorReason.Descriptor instead.
func (ErrorReason) Number ¶
func (x ErrorReason) Number() protoreflect.EnumNumber
func (ErrorReason) String ¶
func (x ErrorReason) String() string
func (ErrorReason) Type ¶
func (ErrorReason) Type() protoreflect.EnumType
type Msg ¶
type Msg struct { Reason ErrorReason `protobuf:"varint,1,opt,name=Reason,proto3,enum=service.v1alpha1.ErrorReason" json:"Reason,omitempty"` Message string `protobuf:"bytes,2,opt,name=Message,proto3" json:"Message,omitempty"` // contains filtered or unexported fields }
func (*Msg) Descriptor
deprecated
func (*Msg) GetMessage ¶
func (*Msg) GetReason ¶
func (x *Msg) GetReason() ErrorReason
func (*Msg) ProtoMessage ¶
func (*Msg) ProtoMessage()
func (*Msg) ProtoReflect ¶
func (x *Msg) ProtoReflect() protoreflect.Message
type Port ¶
type Port struct { ID int64 `protobuf:"varint,1,opt,name=ID,json=id,proto3" json:"ID,omitempty"` IngressPath string `protobuf:"bytes,2,opt,name=IngressPath,json=ingress_path,proto3" json:"IngressPath,omitempty"` ContainerPort int32 `protobuf:"varint,3,opt,name=ContainerPort,json=container_port,proto3" json:"ContainerPort,omitempty"` Protocol string `protobuf:"bytes,4,opt,name=Protocol,json=protocol,proto3" json:"Protocol,omitempty"` // contains filtered or unexported fields }
func (*Port) Descriptor
deprecated
func (*Port) GetContainerPort ¶
func (*Port) GetIngressPath ¶
func (*Port) GetProtocol ¶
func (*Port) ProtoMessage ¶
func (*Port) ProtoMessage()
func (*Port) ProtoReflect ¶
func (x *Port) ProtoReflect() protoreflect.Message
type Service ¶
type Service struct { ID int64 `protobuf:"varint,1,opt,name=ID,json=id,proto3" json:"ID,omitempty"` Name string `protobuf:"bytes,2,opt,name=Name,json=name,proto3" json:"Name,omitempty"` CodeRepo string `protobuf:"bytes,3,opt,name=CodeRepo,json=code_repo,proto3" json:"CodeRepo,omitempty"` Replicas int32 `protobuf:"varint,7,opt,name=Replicas,json=replicas,proto3" json:"Replicas,omitempty"` CPU float32 `protobuf:"fixed32,8,opt,name=CPU,json=cpu,proto3" json:"CPU,omitempty"` LimitCpu float32 `protobuf:"fixed32,9,opt,name=LimitCpu,json=limit_cpu,proto3" json:"LimitCpu,omitempty"` GPU float32 `protobuf:"fixed32,10,opt,name=GPU,json=gpu,proto3" json:"GPU,omitempty"` LimitGPU float32 `protobuf:"fixed32,11,opt,name=LimitGPU,json=limit_gpu,proto3" json:"LimitGPU,omitempty"` Memory float32 `protobuf:"fixed32,12,opt,name=Memory,json=memory,proto3" json:"Memory,omitempty"` LimitMemory float32 `protobuf:"fixed32,13,opt,name=LimitMemory,json=limit_memory,proto3" json:"LimitMemory,omitempty"` Disk float32 `protobuf:"fixed32,14,opt,name=Disk,json=disk,proto3" json:"Disk,omitempty"` LimitDisk float32 `protobuf:"fixed32,15,opt,name=LimitDisk,json=limit_disk,proto3" json:"LimitDisk,omitempty"` WorkflowID int64 `protobuf:"varint,16,opt,name=WorkflowID,json=workflow_id,proto3" json:"WorkflowID,omitempty"` Ports []*Port `protobuf:"bytes,17,rep,name=Ports,json=ports,proto3" json:"Ports,omitempty"` ProjectID int64 `protobuf:"varint,20,opt,name=ProjectID,json=project_id,proto3" json:"ProjectID,omitempty"` Business string `protobuf:"bytes,21,opt,name=Business,json=business,proto3" json:"Business,omitempty"` Technology string `protobuf:"bytes,22,opt,name=Technology,json=technology,proto3" json:"Technology,omitempty"` ProjectName string `protobuf:"bytes,23,opt,name=project_name,proto3" json:"project_name,omitempty"` // contains filtered or unexported fields }
func (*Service) Descriptor
deprecated
func (*Service) GetBusiness ¶
func (*Service) GetCodeRepo ¶
func (*Service) GetLimitCpu ¶
func (*Service) GetLimitDisk ¶
func (*Service) GetLimitGPU ¶
func (*Service) GetLimitMemory ¶
func (*Service) GetProjectID ¶
func (*Service) GetProjectName ¶
func (*Service) GetReplicas ¶
func (*Service) GetTechnology ¶
func (*Service) GetWorkflowID ¶
func (*Service) ProtoMessage ¶
func (*Service) ProtoMessage()
func (*Service) ProtoReflect ¶
func (x *Service) ProtoReflect() protoreflect.Message
type ServiceInterfaceClient ¶
type ServiceInterfaceClient interface { Ping(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Msg, error) List(ctx context.Context, in *ServiceRequest, opts ...grpc.CallOption) (*Services, error) Save(ctx context.Context, in *Service, opts ...grpc.CallOption) (*Msg, error) Get(ctx context.Context, in *ServiceRequest, opts ...grpc.CallOption) (*Service, error) }
ServiceInterfaceClient is the client API for ServiceInterface 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 NewServiceInterfaceClient ¶
func NewServiceInterfaceClient(cc grpc.ClientConnInterface) ServiceInterfaceClient
type ServiceInterfaceHTTPClient ¶
type ServiceInterfaceHTTPClient interface { Get(ctx context.Context, req *ServiceRequest, opts ...http.CallOption) (rsp *Service, err error) List(ctx context.Context, req *ServiceRequest, opts ...http.CallOption) (rsp *Services, err error) Ping(ctx context.Context, req *emptypb.Empty, opts ...http.CallOption) (rsp *Msg, err error) Save(ctx context.Context, req *Service, opts ...http.CallOption) (rsp *Msg, err error) }
func NewServiceInterfaceHTTPClient ¶
func NewServiceInterfaceHTTPClient(client *http.Client) ServiceInterfaceHTTPClient
type ServiceInterfaceHTTPClientImpl ¶
type ServiceInterfaceHTTPClientImpl struct {
// contains filtered or unexported fields
}
func (*ServiceInterfaceHTTPClientImpl) Get ¶
func (c *ServiceInterfaceHTTPClientImpl) Get(ctx context.Context, in *ServiceRequest, opts ...http.CallOption) (*Service, error)
func (*ServiceInterfaceHTTPClientImpl) List ¶
func (c *ServiceInterfaceHTTPClientImpl) List(ctx context.Context, in *ServiceRequest, opts ...http.CallOption) (*Services, error)
func (*ServiceInterfaceHTTPClientImpl) Ping ¶
func (c *ServiceInterfaceHTTPClientImpl) Ping(ctx context.Context, in *emptypb.Empty, opts ...http.CallOption) (*Msg, error)
func (*ServiceInterfaceHTTPClientImpl) Save ¶
func (c *ServiceInterfaceHTTPClientImpl) Save(ctx context.Context, in *Service, opts ...http.CallOption) (*Msg, error)
type ServiceInterfaceServer ¶
type ServiceInterfaceServer interface { Ping(context.Context, *emptypb.Empty) (*Msg, error) List(context.Context, *ServiceRequest) (*Services, error) Save(context.Context, *Service) (*Msg, error) Get(context.Context, *ServiceRequest) (*Service, error) // contains filtered or unexported methods }
ServiceInterfaceServer is the server API for ServiceInterface service. All implementations must embed UnimplementedServiceInterfaceServer for forward compatibility
type ServiceRequest ¶
type ServiceRequest struct { Name string `protobuf:"bytes,1,opt,name=Name,json=name,proto3" json:"Name,omitempty"` Page int64 `protobuf:"varint,2,opt,name=page,proto3" json:"page,omitempty"` PageSize int64 `protobuf:"varint,3,opt,name=pageSize,json=page_size,proto3" json:"pageSize,omitempty"` ProjectId int64 `protobuf:"varint,4,opt,name=projectId,json=project_id,proto3" json:"projectId,omitempty"` Id int64 `protobuf:"varint,5,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*ServiceRequest) Descriptor
deprecated
func (*ServiceRequest) Descriptor() ([]byte, []int)
Deprecated: Use ServiceRequest.ProtoReflect.Descriptor instead.
func (*ServiceRequest) GetId ¶
func (x *ServiceRequest) GetId() int64
func (*ServiceRequest) GetName ¶
func (x *ServiceRequest) GetName() string
func (*ServiceRequest) GetPage ¶
func (x *ServiceRequest) GetPage() int64
func (*ServiceRequest) GetPageSize ¶
func (x *ServiceRequest) GetPageSize() int64
func (*ServiceRequest) GetProjectId ¶
func (x *ServiceRequest) GetProjectId() int64
func (*ServiceRequest) ProtoMessage ¶
func (*ServiceRequest) ProtoMessage()
func (*ServiceRequest) ProtoReflect ¶
func (x *ServiceRequest) ProtoReflect() protoreflect.Message
func (*ServiceRequest) Reset ¶
func (x *ServiceRequest) Reset()
func (*ServiceRequest) String ¶
func (x *ServiceRequest) String() string
type Services ¶
type Services struct { Services []*Service `protobuf:"bytes,1,rep,name=Services,json=services,proto3" json:"Services,omitempty"` Total int64 `protobuf:"varint,2,opt,name=Total,json=total,proto3" json:"Total,omitempty"` // contains filtered or unexported fields }
func (*Services) Descriptor
deprecated
func (*Services) GetServices ¶
func (*Services) ProtoMessage ¶
func (*Services) ProtoMessage()
func (*Services) ProtoReflect ¶
func (x *Services) ProtoReflect() protoreflect.Message
type UnimplementedServiceInterfaceServer ¶
type UnimplementedServiceInterfaceServer struct { }
UnimplementedServiceInterfaceServer must be embedded to have forward compatible implementations.
func (UnimplementedServiceInterfaceServer) Get ¶
func (UnimplementedServiceInterfaceServer) Get(context.Context, *ServiceRequest) (*Service, error)
func (UnimplementedServiceInterfaceServer) List ¶
func (UnimplementedServiceInterfaceServer) List(context.Context, *ServiceRequest) (*Services, error)
type UnsafeServiceInterfaceServer ¶
type UnsafeServiceInterfaceServer interface {
// contains filtered or unexported methods
}
UnsafeServiceInterfaceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ServiceInterfaceServer will result in compilation errors.
type Worklfow ¶
type Worklfow struct { ID int64 `protobuf:"varint,1,opt,name=ID,json=id,proto3" json:"ID,omitempty"` Name string `protobuf:"bytes,2,opt,name=Name,json=name,proto3" json:"Name,omitempty"` Worklfow []byte `protobuf:"bytes,3,opt,name=Worklfow,json=workflow,proto3" json:"Worklfow,omitempty"` // contains filtered or unexported fields }
func (*Worklfow) Descriptor
deprecated
func (*Worklfow) GetWorklfow ¶
func (*Worklfow) ProtoMessage ¶
func (*Worklfow) ProtoMessage()
func (*Worklfow) ProtoReflect ¶
func (x *Worklfow) ProtoReflect() protoreflect.Message