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) GetCreatedAt() string
- func (x *CI) GetDescription() string
- func (x *CI) GetID() int64
- func (x *CI) GetLogs() string
- func (x *CI) GetServiceID() int64
- func (x *CI) GetStatus() string
- func (x *CI) GetTag() string
- func (x *CI) GetUserId() int64
- func (x *CI) GetUsername() 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 CIsRequest
- func (*CIsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CIsRequest) GetPage() int32
- func (x *CIsRequest) GetPageSize() int32
- func (x *CIsRequest) GetServiceID() int64
- func (x *CIsRequest) GetVersion() string
- func (*CIsRequest) ProtoMessage()
- func (x *CIsRequest) ProtoReflect() protoreflect.Message
- func (x *CIsRequest) Reset()
- func (x *CIsRequest) String() string
- type CIsResult
- 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) CommitWorklfow(ctx context.Context, in *ServiceRequest, opts ...http.CallOption) (*common.Msg, error)
- func (c *ServiceInterfaceHTTPClientImpl) Delete(ctx context.Context, in *ServiceRequest, opts ...http.CallOption) (*common.Msg, error)
- func (c *ServiceInterfaceHTTPClientImpl) Get(ctx context.Context, in *ServiceRequest, opts ...http.CallOption) (*Service, error)
- func (c *ServiceInterfaceHTTPClientImpl) GetServiceCis(ctx context.Context, in *CIsRequest, opts ...http.CallOption) (*CIsResult, error)
- func (c *ServiceInterfaceHTTPClientImpl) GetWorkflow(ctx context.Context, in *ServiceRequest, opts ...http.CallOption) (*Worklfow, 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) (*common.Msg, error)
- func (c *ServiceInterfaceHTTPClientImpl) Save(ctx context.Context, in *Service, opts ...http.CallOption) (*common.Msg, error)
- func (c *ServiceInterfaceHTTPClientImpl) SaveWorkflow(ctx context.Context, in *ServiceRequest, opts ...http.CallOption) (*common.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 (x *ServiceRequest) GetWfType() int32
- func (x *ServiceRequest) GetWorkflow() *Worklfow
- func (x *ServiceRequest) GetWorkflowId() 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) CommitWorklfow(context.Context, *ServiceRequest) (*common.Msg, error)
- func (UnimplementedServiceInterfaceServer) Delete(context.Context, *ServiceRequest) (*common.Msg, error)
- func (UnimplementedServiceInterfaceServer) Get(context.Context, *ServiceRequest) (*Service, error)
- func (UnimplementedServiceInterfaceServer) GetServiceCis(context.Context, *CIsRequest) (*CIsResult, error)
- func (UnimplementedServiceInterfaceServer) GetWorkflow(context.Context, *ServiceRequest) (*Worklfow, error)
- func (UnimplementedServiceInterfaceServer) List(context.Context, *ServiceRequest) (*Services, error)
- func (UnimplementedServiceInterfaceServer) Ping(context.Context, *emptypb.Empty) (*common.Msg, error)
- func (UnimplementedServiceInterfaceServer) Save(context.Context, *Service) (*common.Msg, error)
- func (UnimplementedServiceInterfaceServer) SaveWorkflow(context.Context, *ServiceRequest) (*common.Msg, error)
- type UnsafeServiceInterfaceServer
- type WfStep
- func (*WfStep) Descriptor() ([]byte, []int)deprecated
- func (x *WfStep) GetDefault() bool
- func (x *WfStep) GetName() string
- func (x *WfStep) GetTasks() []*WfTask
- func (*WfStep) ProtoMessage()
- func (x *WfStep) ProtoReflect() protoreflect.Message
- func (x *WfStep) Reset()
- func (x *WfStep) String() string
- type WfTask
- func (*WfTask) Descriptor() ([]byte, []int)deprecated
- func (x *WfTask) GetDefault() bool
- func (x *WfTask) GetName() string
- func (x *WfTask) GetTemplateName() string
- func (*WfTask) ProtoMessage()
- func (x *WfTask) ProtoReflect() protoreflect.Message
- func (x *WfTask) Reset()
- func (x *WfTask) String() string
- type WfTemplate
- func (*WfTemplate) Descriptor() ([]byte, []int)deprecated
- func (x *WfTemplate) GetArgs() []string
- func (x *WfTemplate) GetCommand() []string
- func (x *WfTemplate) GetImage() string
- func (x *WfTemplate) GetIsScript() bool
- func (x *WfTemplate) GetName() string
- func (x *WfTemplate) GetSource() string
- func (*WfTemplate) ProtoMessage()
- func (x *WfTemplate) ProtoReflect() protoreflect.Message
- func (x *WfTemplate) Reset()
- func (x *WfTemplate) String() string
- type Worklfow
- func (*Worklfow) Descriptor() ([]byte, []int)deprecated
- func (x *Worklfow) GetDescription() string
- func (x *Worklfow) GetID() int64
- func (x *Worklfow) GetName() string
- func (x *Worklfow) GetSteps() []*WfStep
- func (x *Worklfow) GetTemplates() []*WfTemplate
- 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" ServiceInterface_Delete_FullMethodName = "/service.v1alpha1.ServiceInterface/Delete" ServiceInterface_GetWorkflow_FullMethodName = "/service.v1alpha1.ServiceInterface/GetWorkflow" ServiceInterface_SaveWorkflow_FullMethodName = "/service.v1alpha1.ServiceInterface/SaveWorkflow" ServiceInterface_CommitWorklfow_FullMethodName = "/service.v1alpha1.ServiceInterface/CommitWorklfow" ServiceInterface_GetServiceCis_FullMethodName = "/service.v1alpha1.ServiceInterface/GetServiceCis" )
const OperationServiceInterfaceCommitWorklfow = "/service.v1alpha1.ServiceInterface/CommitWorklfow"
const OperationServiceInterfaceDelete = "/service.v1alpha1.ServiceInterface/Delete"
const OperationServiceInterfaceGet = "/service.v1alpha1.ServiceInterface/Get"
const OperationServiceInterfaceGetServiceCis = "/service.v1alpha1.ServiceInterface/GetServiceCis"
const OperationServiceInterfaceGetWorkflow = "/service.v1alpha1.ServiceInterface/GetWorkflow"
const OperationServiceInterfaceList = "/service.v1alpha1.ServiceInterface/List"
const OperationServiceInterfacePing = "/service.v1alpha1.ServiceInterface/Ping"
const OperationServiceInterfaceSave = "/service.v1alpha1.ServiceInterface/Save"
const OperationServiceInterfaceSaveWorkflow = "/service.v1alpha1.ServiceInterface/SaveWorkflow"
Variables ¶
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, }, { MethodName: "Delete", Handler: _ServiceInterface_Delete_Handler, }, { MethodName: "GetWorkflow", Handler: _ServiceInterface_GetWorkflow_Handler, }, { MethodName: "SaveWorkflow", Handler: _ServiceInterface_SaveWorkflow_Handler, }, { MethodName: "CommitWorklfow", Handler: _ServiceInterface_CommitWorklfow_Handler, }, { MethodName: "GetServiceCis", Handler: _ServiceInterface_GetServiceCis_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"` Status string `protobuf:"bytes,9,opt,name=Status,json=status,proto3" json:"Status,omitempty"` CreatedAt string `protobuf:"bytes,10,opt,name=CreatedAt,json=created_at,proto3" json:"CreatedAt,omitempty"` Username string `protobuf:"bytes,11,opt,name=Username,json=username,proto3" json:"Username,omitempty"` UserId int64 `protobuf:"varint,12,opt,name=UserId,json=user_id,proto3" json:"UserId,omitempty"` Logs string `protobuf:"bytes,13,opt,name=Logs,json=logs,proto3" json:"Logs,omitempty"` // contains filtered or unexported fields }
func (*CI) Descriptor
deprecated
func (*CI) GetCreatedAt ¶
func (*CI) GetDescription ¶
func (*CI) GetServiceID ¶
func (*CI) GetUsername ¶
func (*CI) GetVersion ¶
func (*CI) GetWorkflowName ¶
func (*CI) ProtoMessage ¶
func (*CI) ProtoMessage()
func (*CI) ProtoReflect ¶
func (x *CI) ProtoReflect() protoreflect.Message
type CIsRequest ¶
type CIsRequest struct { ServiceID int64 `protobuf:"varint,1,opt,name=ServiceID,json=service_id,proto3" json:"ServiceID,omitempty"` Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` Page int32 `protobuf:"varint,3,opt,name=page,proto3" json:"page,omitempty"` PageSize int32 `protobuf:"varint,4,opt,name=pageSize,json=page_size,proto3" json:"pageSize,omitempty"` // contains filtered or unexported fields }
func (*CIsRequest) Descriptor
deprecated
func (*CIsRequest) Descriptor() ([]byte, []int)
Deprecated: Use CIsRequest.ProtoReflect.Descriptor instead.
func (*CIsRequest) GetPage ¶
func (x *CIsRequest) GetPage() int32
func (*CIsRequest) GetPageSize ¶
func (x *CIsRequest) GetPageSize() int32
func (*CIsRequest) GetServiceID ¶
func (x *CIsRequest) GetServiceID() int64
func (*CIsRequest) GetVersion ¶
func (x *CIsRequest) GetVersion() string
func (*CIsRequest) ProtoMessage ¶
func (*CIsRequest) ProtoMessage()
func (*CIsRequest) ProtoReflect ¶
func (x *CIsRequest) ProtoReflect() protoreflect.Message
func (*CIsRequest) Reset ¶
func (x *CIsRequest) Reset()
func (*CIsRequest) String ¶
func (x *CIsRequest) String() string
type CIsResult ¶
type CIsResult struct { CIs []*CI `protobuf:"bytes,1,rep,name=CIs,json=cis,proto3" json:"CIs,omitempty"` Total int64 `protobuf:"varint,2,opt,name=Total,json=total,proto3" json:"Total,omitempty"` // contains filtered or unexported fields }
func (*CIsResult) Descriptor
deprecated
func (*CIsResult) ProtoMessage ¶
func (*CIsResult) ProtoMessage()
func (*CIsResult) ProtoReflect ¶
func (x *CIsResult) 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) (*common.Msg, error) List(ctx context.Context, in *ServiceRequest, opts ...grpc.CallOption) (*Services, error) Save(ctx context.Context, in *Service, opts ...grpc.CallOption) (*common.Msg, error) Get(ctx context.Context, in *ServiceRequest, opts ...grpc.CallOption) (*Service, error) Delete(ctx context.Context, in *ServiceRequest, opts ...grpc.CallOption) (*common.Msg, error) GetWorkflow(ctx context.Context, in *ServiceRequest, opts ...grpc.CallOption) (*Worklfow, error) SaveWorkflow(ctx context.Context, in *ServiceRequest, opts ...grpc.CallOption) (*common.Msg, error) CommitWorklfow(ctx context.Context, in *ServiceRequest, opts ...grpc.CallOption) (*common.Msg, error) GetServiceCis(ctx context.Context, in *CIsRequest, opts ...grpc.CallOption) (*CIsResult, 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 { CommitWorklfow(ctx context.Context, req *ServiceRequest, opts ...http.CallOption) (rsp *common.Msg, err error) Delete(ctx context.Context, req *ServiceRequest, opts ...http.CallOption) (rsp *common.Msg, err error) Get(ctx context.Context, req *ServiceRequest, opts ...http.CallOption) (rsp *Service, err error) GetServiceCis(ctx context.Context, req *CIsRequest, opts ...http.CallOption) (rsp *CIsResult, err error) GetWorkflow(ctx context.Context, req *ServiceRequest, opts ...http.CallOption) (rsp *Worklfow, 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 *common.Msg, err error) Save(ctx context.Context, req *Service, opts ...http.CallOption) (rsp *common.Msg, err error) SaveWorkflow(ctx context.Context, req *ServiceRequest, opts ...http.CallOption) (rsp *common.Msg, err error) }
func NewServiceInterfaceHTTPClient ¶
func NewServiceInterfaceHTTPClient(client *http.Client) ServiceInterfaceHTTPClient
type ServiceInterfaceHTTPClientImpl ¶
type ServiceInterfaceHTTPClientImpl struct {
// contains filtered or unexported fields
}
func (*ServiceInterfaceHTTPClientImpl) CommitWorklfow ¶
func (c *ServiceInterfaceHTTPClientImpl) CommitWorklfow(ctx context.Context, in *ServiceRequest, opts ...http.CallOption) (*common.Msg, error)
func (*ServiceInterfaceHTTPClientImpl) Delete ¶
func (c *ServiceInterfaceHTTPClientImpl) Delete(ctx context.Context, in *ServiceRequest, opts ...http.CallOption) (*common.Msg, error)
func (*ServiceInterfaceHTTPClientImpl) Get ¶
func (c *ServiceInterfaceHTTPClientImpl) Get(ctx context.Context, in *ServiceRequest, opts ...http.CallOption) (*Service, error)
func (*ServiceInterfaceHTTPClientImpl) GetServiceCis ¶
func (c *ServiceInterfaceHTTPClientImpl) GetServiceCis(ctx context.Context, in *CIsRequest, opts ...http.CallOption) (*CIsResult, error)
func (*ServiceInterfaceHTTPClientImpl) GetWorkflow ¶
func (c *ServiceInterfaceHTTPClientImpl) GetWorkflow(ctx context.Context, in *ServiceRequest, opts ...http.CallOption) (*Worklfow, 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) (*common.Msg, error)
func (*ServiceInterfaceHTTPClientImpl) Save ¶
func (c *ServiceInterfaceHTTPClientImpl) Save(ctx context.Context, in *Service, opts ...http.CallOption) (*common.Msg, error)
func (*ServiceInterfaceHTTPClientImpl) SaveWorkflow ¶
func (c *ServiceInterfaceHTTPClientImpl) SaveWorkflow(ctx context.Context, in *ServiceRequest, opts ...http.CallOption) (*common.Msg, error)
type ServiceInterfaceHTTPServer ¶
type ServiceInterfaceHTTPServer interface { CommitWorklfow(context.Context, *ServiceRequest) (*common.Msg, error) Delete(context.Context, *ServiceRequest) (*common.Msg, error) Get(context.Context, *ServiceRequest) (*Service, error) GetServiceCis(context.Context, *CIsRequest) (*CIsResult, error) GetWorkflow(context.Context, *ServiceRequest) (*Worklfow, error) List(context.Context, *ServiceRequest) (*Services, error) Ping(context.Context, *emptypb.Empty) (*common.Msg, error) Save(context.Context, *Service) (*common.Msg, error) SaveWorkflow(context.Context, *ServiceRequest) (*common.Msg, error) }
type ServiceInterfaceServer ¶
type ServiceInterfaceServer interface { Ping(context.Context, *emptypb.Empty) (*common.Msg, error) List(context.Context, *ServiceRequest) (*Services, error) Save(context.Context, *Service) (*common.Msg, error) Get(context.Context, *ServiceRequest) (*Service, error) Delete(context.Context, *ServiceRequest) (*common.Msg, error) GetWorkflow(context.Context, *ServiceRequest) (*Worklfow, error) SaveWorkflow(context.Context, *ServiceRequest) (*common.Msg, error) CommitWorklfow(context.Context, *ServiceRequest) (*common.Msg, error) GetServiceCis(context.Context, *CIsRequest) (*CIsResult, 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"` Workflow *Worklfow `protobuf:"bytes,9,opt,name=workflow,proto3" json:"workflow,omitempty"` WfType int32 `protobuf:"varint,10,opt,name=wfType,json=wf_type,proto3" json:"wfType,omitempty"` WorkflowId int64 `protobuf:"varint,11,opt,name=workflowId,json=workflow_id,proto3" json:"workflowId,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) GetWfType ¶
func (x *ServiceRequest) GetWfType() int32
func (*ServiceRequest) GetWorkflow ¶
func (x *ServiceRequest) GetWorkflow() *Worklfow
func (*ServiceRequest) GetWorkflowId ¶
func (x *ServiceRequest) GetWorkflowId() 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.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedServiceInterfaceServer) CommitWorklfow ¶
func (UnimplementedServiceInterfaceServer) CommitWorklfow(context.Context, *ServiceRequest) (*common.Msg, error)
func (UnimplementedServiceInterfaceServer) Delete ¶
func (UnimplementedServiceInterfaceServer) Delete(context.Context, *ServiceRequest) (*common.Msg, error)
func (UnimplementedServiceInterfaceServer) Get ¶
func (UnimplementedServiceInterfaceServer) Get(context.Context, *ServiceRequest) (*Service, error)
func (UnimplementedServiceInterfaceServer) GetServiceCis ¶
func (UnimplementedServiceInterfaceServer) GetServiceCis(context.Context, *CIsRequest) (*CIsResult, error)
func (UnimplementedServiceInterfaceServer) GetWorkflow ¶
func (UnimplementedServiceInterfaceServer) GetWorkflow(context.Context, *ServiceRequest) (*Worklfow, error)
func (UnimplementedServiceInterfaceServer) List ¶
func (UnimplementedServiceInterfaceServer) List(context.Context, *ServiceRequest) (*Services, error)
func (UnimplementedServiceInterfaceServer) SaveWorkflow ¶
func (UnimplementedServiceInterfaceServer) SaveWorkflow(context.Context, *ServiceRequest) (*common.Msg, 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 WfStep ¶
type WfStep struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Tasks []*WfTask `protobuf:"bytes,2,rep,name=Tasks,json=tasks,proto3" json:"Tasks,omitempty"` Default bool `protobuf:"varint,3,opt,name=default,proto3" json:"default,omitempty"` // contains filtered or unexported fields }
func (*WfStep) Descriptor
deprecated
func (*WfStep) GetDefault ¶
func (*WfStep) ProtoMessage ¶
func (*WfStep) ProtoMessage()
func (*WfStep) ProtoReflect ¶
func (x *WfStep) ProtoReflect() protoreflect.Message
type WfTask ¶
type WfTask struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` TemplateName string `protobuf:"bytes,2,opt,name=templateName,json=template_name,proto3" json:"templateName,omitempty"` Default bool `protobuf:"varint,3,opt,name=default,proto3" json:"default,omitempty"` // contains filtered or unexported fields }
func (*WfTask) Descriptor
deprecated
func (*WfTask) GetDefault ¶
func (*WfTask) GetTemplateName ¶
func (*WfTask) ProtoMessage ¶
func (*WfTask) ProtoMessage()
func (*WfTask) ProtoReflect ¶
func (x *WfTask) ProtoReflect() protoreflect.Message
type WfTemplate ¶
type WfTemplate struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Image string `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"` Command []string `protobuf:"bytes,3,rep,name=command,proto3" json:"command,omitempty"` Args []string `protobuf:"bytes,4,rep,name=args,proto3" json:"args,omitempty"` Source string `protobuf:"bytes,5,opt,name=source,proto3" json:"source,omitempty"` IsScript bool `protobuf:"varint,6,opt,name=IsScript,json=is_script,proto3" json:"IsScript,omitempty"` // contains filtered or unexported fields }
func (*WfTemplate) Descriptor
deprecated
func (*WfTemplate) Descriptor() ([]byte, []int)
Deprecated: Use WfTemplate.ProtoReflect.Descriptor instead.
func (*WfTemplate) GetArgs ¶
func (x *WfTemplate) GetArgs() []string
func (*WfTemplate) GetCommand ¶
func (x *WfTemplate) GetCommand() []string
func (*WfTemplate) GetImage ¶
func (x *WfTemplate) GetImage() string
func (*WfTemplate) GetIsScript ¶
func (x *WfTemplate) GetIsScript() bool
func (*WfTemplate) GetName ¶
func (x *WfTemplate) GetName() string
func (*WfTemplate) GetSource ¶
func (x *WfTemplate) GetSource() string
func (*WfTemplate) ProtoMessage ¶
func (*WfTemplate) ProtoMessage()
func (*WfTemplate) ProtoReflect ¶
func (x *WfTemplate) ProtoReflect() protoreflect.Message
func (*WfTemplate) Reset ¶
func (x *WfTemplate) Reset()
func (*WfTemplate) String ¶
func (x *WfTemplate) String() string
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"` Description string `protobuf:"bytes,3,opt,name=Description,json=description,proto3" json:"Description,omitempty"` Steps []*WfStep `protobuf:"bytes,4,rep,name=Steps,json=steps,proto3" json:"Steps,omitempty"` Templates []*WfTemplate `protobuf:"bytes,5,rep,name=Templates,json=templates,proto3" json:"Templates,omitempty"` // contains filtered or unexported fields }
func (*Worklfow) Descriptor
deprecated
func (*Worklfow) GetDescription ¶
func (*Worklfow) GetTemplates ¶
func (x *Worklfow) GetTemplates() []*WfTemplate
func (*Worklfow) ProtoMessage ¶
func (*Worklfow) ProtoMessage()
func (*Worklfow) ProtoReflect ¶
func (x *Worklfow) ProtoReflect() protoreflect.Message