zishuo/onepanel
1
0
Fork 0
mirror of https://github.com/onepanelio/onepanel.git synced 2025-11-02 20:04:01 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

add ListWorkflowTemplates

Browse Source
This commit is contained in:
rushtehrani
2019-12-19 11:15:53 -08:00
parent bdcd517135
commit 3d5aeccaa1
9 changed files with 397 additions and 83 deletions
Download Patch File Download Diff File Expand all files Collapse all files

133
api/workflow.pb.go
View File

@@ -214,8 +214,8 @@ func (m *ListWorkflowsRequest) GetWorkflowTemplateUid() string {
}
type ListWorkflowsResponse struct {
Workflows []*Workflow `protobuf:"bytes,1,rep,name=workflows,proto3" json:"workflows,omitempty"`
Count int32 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
Count int32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
Workflows []*Workflow `protobuf:"bytes,2,rep,name=workflows,proto3" json:"workflows,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
@@ -246,13 +246,6 @@ func (m *ListWorkflowsResponse) XXX_DiscardUnknown() {
var xxx_messageInfo_ListWorkflowsResponse proto.InternalMessageInfo
func (m *ListWorkflowsResponse) GetWorkflows() []*Workflow {
if m != nil {
return m.Workflows
}
return nil
}
func (m *ListWorkflowsResponse) GetCount() int32 {
if m != nil {
return m.Count
@@ -260,6 +253,13 @@ func (m *ListWorkflowsResponse) GetCount() int32 {
return 0
}
func (m *ListWorkflowsResponse) GetWorkflows() []*Workflow {
if m != nil {
return m.Workflows
}
return nil
}
type Workflow struct {
Uid string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
@@ -391,45 +391,46 @@ func init() {
func init() { proto.RegisterFile("workflow.proto", fileDescriptor_892c7f566756b0be) }
var fileDescriptor_892c7f566756b0be = []byte{
// 596 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xa4, 0x55, 0xcd, 0x6e, 0xd3, 0x40,
0x10, 0x66, 0x9b, 0xa6, 0x34, 0x53, 0xb5, 0x54, 0xd3, 0xb4, 0x35, 0x56, 0x24, 0xa2, 0x45, 0x48,
0x29, 0xad, 0xe2, 0x36, 0xa8, 0x97, 0xa2, 0x4a, 0xa0, 0x8a, 0x96, 0x03, 0x07, 0x64, 0x7e, 0x2a,
0xf5, 0x02, 0xdb, 0x64, 0x5b, 0x2c, 0x12, 0xdb, 0x78, 0xd7, 0xe9, 0x21, 0xca, 0x05, 0x1e, 0x81,
0x23, 0x2f, 0x82, 0xc4, 0x63, 0xe4, 0x15, 0x78, 0x10, 0x94, 0xb5, 0x77, 0x1b, 0x3b, 0x96, 0x48,
0xd4, 0xdb, 0xee, 0xcc, 0xf8, 0x9b, 0xef, 0xdb, 0xf9, 0x76, 0x0d, 0x6b, 0x37, 0x41, 0xf4, 0xf5,
0xaa, 0x1b, 0xdc, 0x34, 0xc3, 0x28, 0x90, 0x01, 0x96, 0x58, 0xe8, 0xd9, 0xb5, 0xeb, 0x20, 0xb8,
0xee, 0x72, 0x87, 0x85, 0x9e, 0xc3, 0x7c, 0x3f, 0x90, 0x4c, 0x7a, 0x81, 0x2f, 0x92, 0x12, 0x7b,
0x5b, 0x7f, 0xf2, 0x49, 0xf2, 0x5e, 0xd8, 0x65, 0x92, 0x27, 0x09, 0xfa, 0x19, 0x36, 0x4f, 0x22,
0xce, 0x24, 0x3f, 0x4f, 0x0b, 0x5c, 0xfe, 0x2d, 0xe6, 0x42, 0x62, 0x0d, 0x2a, 0x3e, 0xeb, 0x71,
0x11, 0xb2, 0x36, 0xb7, 0x48, 0x9d, 0x34, 0x2a, 0xee, 0x6d, 0x00, 0x77, 0x60, 0x59, 0x23, 0x5a,
0x0b, 0x75, 0xd2, 0x58, 0x69, 0xad, 0x36, 0x59, 0xe8, 0x35, 0x0d, 0x8a, 0x49, 0xd3, 0x53, 0xc0,
0x33, 0x2e, 0xe7, 0x83, 0x47, 0x58, 0x1c, 0x6f, 0x14, 0x74, 0xc5, 0x55, 0x6b, 0xfa, 0x1a, 0xaa,
0xe7, 0x4c, 0xb6, 0xbf, 0xdc, 0x1d, 0xe9, 0x0a, 0xaa, 0x6f, 0x3c, 0x61, 0x28, 0x89, 0xd9, 0x90,
0xf6, 0x61, 0x43, 0x6b, 0x7a, 0x9f, 0x9e, 0xe1, 0x07, 0xaf, 0x93, 0x02, 0x17, 0xa5, 0xe8, 0x05,
0x6c, 0xe6, 0xfa, 0x88, 0x30, 0xf0, 0x05, 0xc7, 0x5d, 0xa8, 0xe8, 0x7a, 0x61, 0x91, 0x7a, 0x69,
0xfa, 0xf8, 0x6e, 0xf3, 0x58, 0x85, 0x72, 0x3b, 0x88, 0x7d, 0xa9, 0x3a, 0x95, 0xdd, 0x64, 0x43,
0xff, 0x10, 0x58, 0xd6, 0xd5, 0xb8, 0x0e, 0xa5, 0xd8, 0xeb, 0xa4, 0x94, 0xc7, 0xcb, 0x22, 0xd9,
0xb8, 0x05, 0x4b, 0x42, 0x32, 0x19, 0x0b, 0xab, 0xa4, 0xa2, 0xe9, 0x0e, 0x9b, 0x00, 0x21, 0x8b,
0x58, 0x8f, 0x4b, 0x1e, 0x09, 0x6b, 0x51, 0xd1, 0x59, 0x53, 0x74, 0xde, 0xea, 0xb0, 0x3b, 0x51,
0x81, 0x2f, 0x61, 0x3d, 0xaf, 0xd6, 0x2a, 0x2b, 0x0f, 0x6c, 0x66, 0x44, 0xe8, 0xa4, 0x3b, 0x55,
0x4e, 0x0f, 0xa1, 0x62, 0xb0, 0x0d, 0x57, 0x32, 0xc1, 0xb5, 0x0a, 0xe5, 0x3e, 0xeb, 0xc6, 0x5a,
0x40, 0xb2, 0x69, 0x8d, 0xee, 0xc3, 0x03, 0x8d, 0xfe, 0x8e, 0x47, 0x7d, 0xaf, 0xcd, 0x31, 0x82,
0xb5, 0xac, 0x81, 0xd1, 0x56, 0x2c, 0x0a, 0x5d, 0x6d, 0x67, 0x8f, 0x99, 0x1e, 0x7e, 0x1f, 0xfd,
0xfd, 0xb9, 0xe0, 0xd0, 0xc7, 0xe3, 0x6b, 0x23, 0x9c, 0xfe, 0xc1, 0x25, 0x97, 0xec, 0xc0, 0x19,
0x98, 0xa9, 0x0f, 0x1d, 0x33, 0x88, 0x23, 0x63, 0x69, 0xf4, 0x60, 0x65, 0xc2, 0xd2, 0xb8, 0xad,
0x40, 0xa7, 0x4d, 0x9e, 0xef, 0xd6, 0x52, 0xdd, 0xf6, 0xf0, 0xe9, 0x0c, 0xdd, 0x92, 0xe8, 0x10,
0x05, 0xac, 0x66, 0x3c, 0x84, 0x0f, 0x15, 0x66, 0x91, 0x7f, 0x6d, 0xbb, 0x28, 0x95, 0x58, 0x8e,
0xee, 0xaa, 0xde, 0x4f, 0x70, 0x16, 0xa5, 0x78, 0x0c, 0xab, 0x99, 0xab, 0x96, 0x36, 0x2d, 0xba,
0x7e, 0x79, 0x8d, 0xf7, 0xf6, 0x09, 0xfe, 0x22, 0xb0, 0x95, 0x3d, 0x7e, 0x3d, 0x78, 0xa4, 0x05,
0xb3, 0x31, 0x3e, 0x49, 0x11, 0x8b, 0x5d, 0x44, 0x4f, 0x95, 0x82, 0x17, 0x74, 0xef, 0xff, 0x0a,
0xcc, 0x23, 0x27, 0x8e, 0xa6, 0xbc, 0x87, 0x23, 0x02, 0x1b, 0x13, 0xb3, 0x32, 0xf1, 0x47, 0xf9,
0x29, 0xce, 0xc8, 0xeb, 0x07, 0x51, 0xc4, 0x86, 0xd8, 0x9a, 0x87, 0x98, 0x33, 0x88, 0xbd, 0xce,
0xf0, 0xe2, 0x0c, 0x5f, 0xcd, 0xff, 0x95, 0xd3, 0xe7, 0x91, 0x18, 0x3f, 0xee, 0xce, 0x20, 0x5d,
0x0d, 0xf1, 0x37, 0x81, 0xda, 0xe4, 0xe4, 0x35, 0xbd, 0x8f, 0x69, 0x29, 0x36, 0xa6, 0xcc, 0x91,
0x2f, 0xd1, 0x3a, 0x77, 0x66, 0xa8, 0x4c, 0x5d, 0x75, 0xa2, 0xa4, 0x1f, 0xe3, 0xf3, 0x3b, 0x88,
0xb8, 0x5c, 0x52, 0x7f, 0xa2, 0x67, 0xff, 0x02, 0x00, 0x00, 0xff, 0xff, 0x90, 0x49, 0xff, 0xc5,
0xd7, 0x06, 0x00, 0x00,
// 624 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xa4, 0x55, 0xcf, 0x6e, 0xd3, 0x4e,
0x10, 0xfe, 0xb9, 0x69, 0xaa, 0x66, 0xaa, 0xe4, 0x57, 0x4d, 0x93, 0xd6, 0x58, 0x91, 0x08, 0x8b,
0x90, 0x52, 0x5a, 0xc5, 0x6d, 0xa0, 0x97, 0xa2, 0x4a, 0xa0, 0x8a, 0x96, 0x03, 0x07, 0x64, 0xfe,
0x54, 0xea, 0x05, 0xb6, 0xc9, 0xb6, 0x58, 0x24, 0xb6, 0xf1, 0xae, 0xd3, 0x43, 0x94, 0x0b, 0x3c,
0x02, 0xdc, 0x78, 0x11, 0x24, 0x1e, 0xa3, 0xaf, 0xc0, 0x89, 0xa7, 0x40, 0x59, 0x7b, 0xb7, 0xb1,
0x63, 0x20, 0x51, 0x6f, 0xbb, 0x33, 0xe3, 0x6f, 0xbe, 0x6f, 0xe7, 0xdb, 0x35, 0x54, 0x2e, 0xfd,
0xf0, 0xc3, 0x79, 0xcf, 0xbf, 0x6c, 0x05, 0xa1, 0x2f, 0x7c, 0x2c, 0xd0, 0xc0, 0xb5, 0xea, 0x17,
0xbe, 0x7f, 0xd1, 0x63, 0x36, 0x0d, 0x5c, 0x9b, 0x7a, 0x9e, 0x2f, 0xa8, 0x70, 0x7d, 0x8f, 0xc7,
0x25, 0xd6, 0x86, 0xfa, 0xe4, 0xad, 0x60, 0xfd, 0xa0, 0x47, 0x05, 0x8b, 0x13, 0xe4, 0x1d, 0xd4,
0x0e, 0x43, 0x46, 0x05, 0x3b, 0x49, 0x0a, 0x1c, 0xf6, 0x31, 0x62, 0x5c, 0x60, 0x1d, 0x4a, 0x1e,
0xed, 0x33, 0x1e, 0xd0, 0x0e, 0x33, 0x8d, 0x86, 0xd1, 0x2c, 0x39, 0xd7, 0x01, 0xdc, 0x84, 0x65,
0x85, 0x68, 0x2e, 0x34, 0x8c, 0xe6, 0x4a, 0xbb, 0xdc, 0xa2, 0x81, 0xdb, 0xd2, 0x28, 0x3a, 0x4d,
0x8e, 0x00, 0x8f, 0x99, 0x98, 0x0f, 0x1e, 0x61, 0x71, 0xbc, 0x91, 0xd0, 0x25, 0x47, 0xae, 0xc9,
0x33, 0xa8, 0x9e, 0x50, 0xd1, 0x79, 0x7f, 0x73, 0xa4, 0x73, 0xa8, 0x3e, 0x77, 0xb9, 0xa6, 0xc4,
0x67, 0x43, 0xda, 0x81, 0x35, 0xa5, 0xe9, 0x55, 0x72, 0x86, 0xaf, 0xdd, 0x6e, 0x02, 0x9c, 0x97,
0x22, 0xa7, 0x50, 0xcb, 0xf4, 0xe1, 0x81, 0xef, 0x71, 0x86, 0x55, 0x28, 0x76, 0xfc, 0xc8, 0x13,
0xb2, 0x49, 0xd1, 0x89, 0x37, 0xb8, 0x05, 0x25, 0x85, 0xc2, 0xcd, 0x85, 0x46, 0x61, 0xfa, 0x50,
0xaf, 0xf3, 0xe4, 0x87, 0x01, 0xcb, 0x2a, 0x8e, 0xab, 0x50, 0x88, 0xdc, 0x6e, 0x42, 0x79, 0xbc,
0xcc, 0x93, 0x8d, 0xeb, 0xb0, 0xc4, 0x05, 0x15, 0x11, 0x37, 0x0b, 0x32, 0x9a, 0xec, 0xb0, 0x05,
0x10, 0xd0, 0x90, 0xf6, 0x99, 0x60, 0x21, 0x37, 0x17, 0x65, 0xe3, 0x8a, 0x6c, 0xfc, 0x42, 0x85,
0x9d, 0x89, 0x0a, 0x7c, 0x02, 0xab, 0x59, 0xb5, 0x66, 0x51, 0x7a, 0xa0, 0x96, 0xa2, 0xab, 0x92,
0xce, 0x54, 0x39, 0xd9, 0x83, 0x92, 0xc6, 0xd6, 0x5c, 0x8d, 0x09, 0xae, 0x55, 0x28, 0x0e, 0x68,
0x2f, 0x52, 0x02, 0xe2, 0x4d, 0xfb, 0xd7, 0x32, 0xfc, 0xaf, 0xd0, 0x5f, 0xb2, 0x70, 0xe0, 0x76,
0x18, 0x86, 0x50, 0x49, 0x1b, 0x18, 0x2d, 0xc9, 0x22, 0xd7, 0xd5, 0x56, 0xfa, 0x40, 0xc9, 0xde,
0xa7, 0xab, 0x9f, 0x5f, 0x16, 0x6c, 0x72, 0x77, 0x7c, 0x6d, 0xb8, 0x3d, 0xd8, 0x3d, 0x63, 0x82,
0xee, 0xda, 0x43, 0x3d, 0xf5, 0x91, 0xad, 0x8f, 0x7c, 0x5f, 0x5b, 0x1a, 0x5d, 0x58, 0x99, 0xb0,
0x34, 0x6e, 0x48, 0xd0, 0x69, 0x93, 0x67, 0xbb, 0xb5, 0x65, 0xb7, 0x6d, 0xbc, 0x3f, 0x43, 0xb7,
0x38, 0x3a, 0x42, 0x0e, 0xe5, 0x94, 0x87, 0xf0, 0x96, 0xc4, 0xcc, 0xf3, 0xaf, 0x65, 0xe5, 0xa5,
0x62, 0xcb, 0x91, 0x2d, 0xd9, 0xfb, 0x1e, 0xce, 0xa2, 0x14, 0x0f, 0xa0, 0x9c, 0xba, 0x6a, 0x49,
0xd3, 0xbc, 0xeb, 0x97, 0xd5, 0xf8, 0xdf, 0x8e, 0x81, 0xdf, 0x0c, 0x58, 0x4f, 0x1f, 0xbf, 0x1a,
0x3c, 0x92, 0x9c, 0xd9, 0x68, 0x9f, 0x24, 0x88, 0xf9, 0x2e, 0x22, 0x47, 0x52, 0xc1, 0x63, 0xb2,
0xfd, 0x6f, 0x05, 0xfa, 0x91, 0xe3, 0xfb, 0x53, 0xde, 0xc3, 0x2b, 0x03, 0xd6, 0x26, 0x66, 0xa5,
0xe3, 0xb7, 0xb3, 0x53, 0x9c, 0x91, 0xd7, 0x67, 0x43, 0x12, 0x1b, 0x61, 0x7b, 0x1e, 0x62, 0xf6,
0x30, 0x72, 0xbb, 0xa3, 0xd3, 0x63, 0x7c, 0x3a, 0xff, 0x57, 0xf6, 0x80, 0x85, 0x7c, 0xfc, 0xb8,
0xdb, 0xc3, 0x64, 0x35, 0xc2, 0xef, 0x06, 0xd4, 0x27, 0x27, 0xaf, 0xe8, 0xbd, 0x49, 0x4a, 0xb1,
0x39, 0x65, 0x8e, 0x6c, 0x89, 0xd2, 0xb9, 0x39, 0x43, 0x65, 0xe2, 0xaa, 0x43, 0x29, 0xfd, 0x00,
0x1f, 0xdd, 0x40, 0x04, 0x7e, 0x35, 0xd2, 0xef, 0xa4, 0xea, 0xc6, 0xf1, 0xce, 0x1f, 0x99, 0x68,
0xb2, 0xe4, 0x6f, 0x25, 0x09, 0xcb, 0x87, 0x92, 0x65, 0x0b, 0xe7, 0x72, 0xce, 0xd9, 0x92, 0xfc,
0x41, 0x3e, 0xf8, 0x1d, 0x00, 0x00, 0xff, 0xff, 0x12, 0x2a, 0x17, 0xe3, 0x6e, 0x07, 0x00, 0x00,
}
// Reference imports to suppress errors if they are not otherwise used.
@@ -452,6 +453,7 @@ type WorkflowServiceClient interface {
CreateWorkflowTemplate(ctx context.Context, in *CreateWorkflowTemplateRequest, opts ...grpc.CallOption) (*WorkflowTemplate, error)
GetWorkflowTemplate(ctx context.Context, in *GetWorkflowTemplateRequest, opts ...grpc.CallOption) (*WorkflowTemplate, error)
ListWorkflowTemplateVersions(ctx context.Context, in *ListWorkflowTemplateVersionsRequest, opts ...grpc.CallOption) (*ListWorkflowTemplateVersionsResponse, error)
ListWorkflowTemplates(ctx context.Context, in *ListWorkflowTemplatesRequest, opts ...grpc.CallOption) (*ListWorkflowTemplatesResponse, error)
}
type workflowServiceClient struct {
@@ -548,6 +550,15 @@ func (c *workflowServiceClient) ListWorkflowTemplateVersions(ctx context.Context
return out, nil
}
func (c *workflowServiceClient) ListWorkflowTemplates(ctx context.Context, in *ListWorkflowTemplatesRequest, opts ...grpc.CallOption) (*ListWorkflowTemplatesResponse, error) {
out := new(ListWorkflowTemplatesResponse)
err := c.cc.Invoke(ctx, "/api.WorkflowService/ListWorkflowTemplates", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// WorkflowServiceServer is the server API for WorkflowService service.
type WorkflowServiceServer interface {
// Creates a Workflow
@@ -558,6 +569,7 @@ type WorkflowServiceServer interface {
CreateWorkflowTemplate(context.Context, *CreateWorkflowTemplateRequest) (*WorkflowTemplate, error)
GetWorkflowTemplate(context.Context, *GetWorkflowTemplateRequest) (*WorkflowTemplate, error)
ListWorkflowTemplateVersions(context.Context, *ListWorkflowTemplateVersionsRequest) (*ListWorkflowTemplateVersionsResponse, error)
ListWorkflowTemplates(context.Context, *ListWorkflowTemplatesRequest) (*ListWorkflowTemplatesResponse, error)
}
// UnimplementedWorkflowServiceServer can be embedded to have forward compatible implementations.
@@ -585,6 +597,9 @@ func (*UnimplementedWorkflowServiceServer) GetWorkflowTemplate(ctx context.Conte
func (*UnimplementedWorkflowServiceServer) ListWorkflowTemplateVersions(ctx context.Context, req *ListWorkflowTemplateVersionsRequest) (*ListWorkflowTemplateVersionsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ListWorkflowTemplateVersions not implemented")
}
func (*UnimplementedWorkflowServiceServer) ListWorkflowTemplates(ctx context.Context, req *ListWorkflowTemplatesRequest) (*ListWorkflowTemplatesResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ListWorkflowTemplates not implemented")
}
func RegisterWorkflowServiceServer(s *grpc.Server, srv WorkflowServiceServer) {
s.RegisterService(&_WorkflowService_serviceDesc, srv)
@@ -719,6 +734,24 @@ func _WorkflowService_ListWorkflowTemplateVersions_Handler(srv interface{}, ctx
return interceptor(ctx, in, info, handler)
}
func _WorkflowService_ListWorkflowTemplates_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ListWorkflowTemplatesRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(WorkflowServiceServer).ListWorkflowTemplates(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/api.WorkflowService/ListWorkflowTemplates",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(WorkflowServiceServer).ListWorkflowTemplates(ctx, req.(*ListWorkflowTemplatesRequest))
}
return interceptor(ctx, in, info, handler)
}
var _WorkflowService_serviceDesc = grpc.ServiceDesc{
ServiceName: "api.WorkflowService",
HandlerType: (*WorkflowServiceServer)(nil),
@@ -747,6 +780,10 @@ var _WorkflowService_serviceDesc = grpc.ServiceDesc{
MethodName: "ListWorkflowTemplateVersions",
Handler: _WorkflowService_ListWorkflowTemplateVersions_Handler,
},
{
MethodName: "ListWorkflowTemplates",
Handler: _WorkflowService_ListWorkflowTemplates_Handler,
},
},
Streams: []grpc.StreamDesc{
{