zishuo/onepanel
1
0
Fork 0
mirror of https://github.com/onepanelio/onepanel.git synced 2025-09-27 01:56:03 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

support stream => websocket for web clients

Browse Source
This commit is contained in:
rushtehrani
2020-01-02 10:45:51 -08:00
parent 724c73b421
commit bc1e19fbc7
7 changed files with 159 additions and 44 deletions
Download Patch File Download Diff File Expand all files Collapse all files

85
api/workflow.pb.go
View File

@@ -391,48 +391,49 @@ func init() {
func init() { proto.RegisterFile("workflow.proto", fileDescriptor_892c7f566756b0be) }
var fileDescriptor_892c7f566756b0be = []byte{
// 649 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xa4, 0x55, 0x4d, 0x4f, 0x13, 0x4f,
0x18, 0xff, 0x0f, 0xa5, 0x84, 0x3e, 0x04, 0xfe, 0xe4, 0xa1, 0xc0, 0xba, 0xc1, 0x88, 0x63, 0x4c,
0x40, 0xc8, 0x2e, 0x54, 0xb9, 0x60, 0x48, 0x34, 0x44, 0xf0, 0xc0, 0xc1, 0xac, 0x2f, 0x24, 0x5c,
0x64, 0x28, 0x03, 0x6e, 0x2c, 0xbb, 0xeb, 0xce, 0x6c, 0x39, 0x90, 0x5e, 0xf4, 0x23, 0xe8, 0xcd,
0x0f, 0xe1, 0xd5, 0xc4, 0x9b, 0x5f, 0x81, 0xaf, 0xe0, 0x07, 0x31, 0x9d, 0xdd, 0x19, 0xba, 0xdb,
0x55, 0xdb, 0xf4, 0x36, 0xf3, 0x3c, 0x4f, 0x7f, 0x2f, 0x33, 0xbf, 0xd9, 0xc2, 0xcc, 0x65, 0x18,
0xbf, 0x3f, 0x6b, 0x85, 0x97, 0x4e, 0x14, 0x87, 0x32, 0xc4, 0x0a, 0x8b, 0x7c, 0x7b, 0xe9, 0x3c,
0x0c, 0xcf, 0x5b, 0xdc, 0x65, 0x91, 0xef, 0xb2, 0x20, 0x08, 0x25, 0x93, 0x7e, 0x18, 0x88, 0x74,
0xc4, 0x5e, 0xd4, 0x3f, 0x79, 0x2b, 0xf9, 0x45, 0xd4, 0x62, 0x92, 0xa7, 0x0d, 0x7a, 0x0c, 0xf3,
0xbb, 0x31, 0x67, 0x92, 0x1f, 0x66, 0x03, 0x1e, 0xff, 0x90, 0x70, 0x21, 0x71, 0x09, 0x6a, 0x01,
0xbb, 0xe0, 0x22, 0x62, 0x4d, 0x6e, 0x91, 0x65, 0xb2, 0x52, 0xf3, 0x6e, 0x0a, 0xb8, 0x0a, 0x93,
0x1a, 0xd1, 0x1a, 0x5b, 0x26, 0x2b, 0x53, 0x8d, 0x69, 0x87, 0x45, 0xbe, 0x63, 0x50, 0x4c, 0x9b,
0xee, 0x01, 0xee, 0x73, 0x39, 0x1c, 0x3c, 0xc2, 0x78, 0x77, 0xa3, 0xa0, 0x6b, 0x9e, 0x5a, 0xd3,
0xe7, 0x50, 0x3f, 0x64, 0xb2, 0xf9, 0x6e, 0x74, 0xa4, 0x33, 0xa8, 0x1f, 0xf8, 0xc2, 0x48, 0x12,
0x83, 0x21, 0x6d, 0xc0, 0x9c, 0xf6, 0xf4, 0x2a, 0x3b, 0xc3, 0xd7, 0xfe, 0x69, 0x06, 0x5c, 0xd6,
0xa2, 0x47, 0x30, 0x5f, 0xe0, 0x11, 0x51, 0x18, 0x08, 0x8e, 0x75, 0xa8, 0x36, 0xc3, 0x24, 0x90,
0x8a, 0xa4, 0xea, 0xa5, 0x1b, 0x5c, 0x83, 0x9a, 0x46, 0x11, 0xd6, 0xd8, 0x72, 0xa5, 0xff, 0x50,
0x6f, 0xfa, 0xf4, 0x07, 0x81, 0x49, 0x5d, 0xc7, 0x59, 0xa8, 0x24, 0xfe, 0x69, 0x26, 0xb9, 0xbb,
0x2c, 0xb3, 0x8d, 0x0b, 0x30, 0x21, 0x24, 0x93, 0x89, 0xb0, 0x2a, 0xaa, 0x9a, 0xed, 0xd0, 0x01,
0x88, 0x58, 0xcc, 0x2e, 0xb8, 0xe4, 0xb1, 0xb0, 0xc6, 0x15, 0xf1, 0x8c, 0x22, 0x7e, 0xa1, 0xcb,
0x5e, 0xcf, 0x04, 0x3e, 0x85, 0xd9, 0xa2, 0x5b, 0xab, 0xaa, 0x32, 0x30, 0x9f, 0x93, 0xab, 0x9b,
0x5e, 0xdf, 0x38, 0xdd, 0x82, 0x9a, 0xc1, 0x36, 0x5a, 0x49, 0x8f, 0xd6, 0x3a, 0x54, 0xdb, 0xac,
0x95, 0x68, 0x03, 0xe9, 0xa6, 0xf1, 0x0d, 0xe0, 0x7f, 0x8d, 0xfe, 0x92, 0xc7, 0x6d, 0xbf, 0xc9,
0x31, 0x86, 0x99, 0x7c, 0x80, 0xd1, 0x56, 0x2a, 0x4a, 0x53, 0x6d, 0xe7, 0x0f, 0x94, 0x6e, 0x7d,
0xbc, 0xfe, 0xf5, 0x79, 0xcc, 0xa5, 0xf7, 0xba, 0xcf, 0x46, 0xb8, 0xed, 0xcd, 0x13, 0x2e, 0xd9,
0xa6, 0x7b, 0x65, 0x6e, 0xbd, 0xe3, 0x9a, 0x23, 0xdf, 0x36, 0x91, 0x46, 0x1f, 0xa6, 0x7a, 0x22,
0x8d, 0x8b, 0x0a, 0xb4, 0x3f, 0xe4, 0x45, 0xb6, 0x86, 0x62, 0x5b, 0xc7, 0x07, 0x03, 0xb0, 0xa5,
0xd5, 0x0e, 0x0a, 0x98, 0xce, 0x65, 0x08, 0x6f, 0x29, 0xcc, 0xb2, 0xfc, 0xda, 0x76, 0x59, 0x2b,
0x8d, 0x1c, 0x5d, 0x53, 0xdc, 0xf7, 0x71, 0x10, 0xa7, 0xb8, 0x03, 0xd3, 0xb9, 0xa7, 0x96, 0x91,
0x96, 0x3d, 0xbf, 0xa2, 0xc7, 0xff, 0x36, 0x08, 0x7e, 0x25, 0xb0, 0x90, 0x3f, 0x7e, 0x7d, 0xf1,
0x48, 0x4b, 0xee, 0xc6, 0xe4, 0x24, 0x43, 0x2c, 0x4f, 0x11, 0xdd, 0x53, 0x0e, 0x9e, 0xd0, 0xf5,
0x7f, 0x3b, 0x30, 0x1f, 0x39, 0xb1, 0xdd, 0x97, 0x3d, 0xfc, 0x49, 0xe0, 0x76, 0xb9, 0x80, 0x37,
0x3c, 0x16, 0x7e, 0x18, 0x8c, 0x22, 0xf2, 0x4c, 0x89, 0x3c, 0xa6, 0x07, 0xc3, 0x88, 0x74, 0xaf,
0x8a, 0x22, 0x9d, 0xc4, 0x3f, 0xed, 0xb8, 0xed, 0x54, 0x4f, 0x99, 0x89, 0x6b, 0x02, 0x73, 0x3d,
0x81, 0x33, 0xf5, 0x3b, 0xc5, 0x28, 0x0e, 0xa8, 0xfb, 0x13, 0x51, 0xc2, 0x3b, 0xd8, 0x18, 0x4e,
0x78, 0x57, 0xe7, 0xd1, 0x3e, 0x3e, 0x1b, 0xfe, 0x57, 0xc6, 0x9d, 0x7b, 0x95, 0xad, 0x3a, 0xf8,
0x9d, 0xc0, 0x52, 0x6f, 0x7c, 0x0b, 0x17, 0x23, 0x70, 0xa5, 0x2f, 0xe1, 0xc5, 0x11, 0xed, 0x73,
0x75, 0x80, 0xc9, 0xec, 0x69, 0xec, 0x2a, 0xeb, 0x3b, 0xf8, 0x78, 0x04, 0x13, 0xf8, 0x85, 0xe4,
0x3f, 0xf6, 0x9a, 0x4d, 0xe0, 0xdd, 0x3f, 0x2a, 0x31, 0x62, 0xe9, 0xdf, 0x46, 0x32, 0x95, 0x8f,
0x94, 0x4a, 0x07, 0x87, 0x8a, 0xff, 0xc9, 0x84, 0xfa, 0x97, 0x7f, 0xf8, 0x3b, 0x00, 0x00, 0xff,
0xff, 0xbd, 0xf5, 0xec, 0x7d, 0x33, 0x08, 0x00, 0x00,
// 660 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xa4, 0x96, 0xdf, 0x4e, 0xd4, 0x40,
0x14, 0xc6, 0x33, 0x2c, 0x4b, 0xd8, 0x43, 0x40, 0x72, 0x58, 0x60, 0x6d, 0x30, 0xe2, 0x18, 0x13,
0x10, 0xd2, 0xc2, 0x2a, 0x89, 0xc1, 0x98, 0x68, 0x88, 0xe0, 0x05, 0x17, 0xa6, 0xfe, 0x21, 0xe1,
0x46, 0x86, 0x65, 0xc0, 0xc6, 0xa5, 0xad, 0x9d, 0xe9, 0x72, 0x41, 0xf6, 0x46, 0x1f, 0x41, 0xef,
0x7c, 0x11, 0x13, 0xef, 0x7c, 0x05, 0x5e, 0xc1, 0xc4, 0xd7, 0x30, 0x3b, 0xed, 0x0c, 0xdb, 0x6e,
0xd5, 0x6e, 0xf6, 0x6e, 0xfe, 0x9c, 0x7e, 0xe7, 0xf7, 0xcd, 0x7c, 0x03, 0x0b, 0x33, 0x17, 0x41,
0xf4, 0xe1, 0xb4, 0x1d, 0x5c, 0xd8, 0x61, 0x14, 0xc8, 0x00, 0x2b, 0x2c, 0xf4, 0xac, 0xa5, 0xb3,
0x20, 0x38, 0x6b, 0x73, 0x87, 0x85, 0x9e, 0xc3, 0x7c, 0x3f, 0x90, 0x4c, 0x7a, 0x81, 0x2f, 0x92,
0x12, 0x6b, 0x51, 0x7f, 0xf2, 0x4e, 0xf2, 0xf3, 0xb0, 0xcd, 0x24, 0x4f, 0x36, 0xe8, 0x11, 0xcc,
0xef, 0x44, 0x9c, 0x49, 0x7e, 0x90, 0x16, 0xb8, 0xfc, 0x63, 0xcc, 0x85, 0xc4, 0x25, 0xa8, 0xf9,
0xec, 0x9c, 0x8b, 0x90, 0xb5, 0x78, 0x83, 0x2c, 0x93, 0x95, 0x9a, 0x7b, 0xbd, 0x80, 0xab, 0x30,
0xa9, 0x15, 0x1b, 0x63, 0xcb, 0x64, 0x65, 0xaa, 0x39, 0x6d, 0xb3, 0xd0, 0xb3, 0x8d, 0x8a, 0xd9,
0xa6, 0xbb, 0x80, 0x7b, 0x5c, 0x0e, 0x27, 0x8f, 0x30, 0xde, 0x9b, 0x28, 0xe9, 0x9a, 0xab, 0xc6,
0xf4, 0x05, 0xd4, 0x0f, 0x98, 0x6c, 0xbd, 0x1f, 0x5d, 0xe9, 0x14, 0xea, 0xfb, 0x9e, 0x30, 0x48,
0xa2, 0x9c, 0xd2, 0x06, 0xcc, 0x69, 0x4f, 0xaf, 0xd3, 0x33, 0x7c, 0xe3, 0x9d, 0xa4, 0xc2, 0x45,
0x5b, 0xf4, 0x10, 0xe6, 0x73, 0x7d, 0x44, 0x18, 0xf8, 0x82, 0x63, 0x1d, 0xaa, 0xad, 0x20, 0xf6,
0xa5, 0x6a, 0x52, 0x75, 0x93, 0x09, 0xae, 0x41, 0x4d, 0xab, 0x88, 0xc6, 0xd8, 0x72, 0x65, 0xf0,
0x50, 0xaf, 0xf7, 0xe9, 0x0f, 0x02, 0x93, 0x7a, 0x1d, 0x67, 0xa1, 0x12, 0x7b, 0x27, 0x29, 0x72,
0x6f, 0x58, 0x64, 0x1b, 0x17, 0x60, 0x42, 0x48, 0x26, 0x63, 0xd1, 0xa8, 0xa8, 0xd5, 0x74, 0x86,
0x36, 0x40, 0xc8, 0x22, 0x76, 0xce, 0x25, 0x8f, 0x44, 0x63, 0x5c, 0x35, 0x9e, 0x51, 0x8d, 0x5f,
0xea, 0x65, 0xb7, 0xaf, 0x02, 0x9f, 0xc1, 0x6c, 0xde, 0x6d, 0xa3, 0xaa, 0x32, 0x30, 0x9f, 0xc1,
0xd5, 0x9b, 0xee, 0x40, 0x39, 0xdd, 0x82, 0x9a, 0xd1, 0x36, 0xac, 0xa4, 0x8f, 0xb5, 0x0e, 0xd5,
0x0e, 0x6b, 0xc7, 0xda, 0x40, 0x32, 0x69, 0xfe, 0x06, 0xb8, 0xa1, 0xd5, 0x5f, 0xf1, 0xa8, 0xe3,
0xb5, 0x38, 0x46, 0x30, 0x93, 0x0d, 0x30, 0x5a, 0x8a, 0xa2, 0x30, 0xd5, 0x56, 0xf6, 0x40, 0xe9,
0xd6, 0xa7, 0xab, 0x5f, 0x5f, 0xc6, 0x1c, 0x7a, 0xb7, 0xf7, 0x6c, 0x84, 0xd3, 0xd9, 0x3c, 0xe6,
0x92, 0x6d, 0x3a, 0x97, 0xe6, 0xd6, 0xbb, 0x8e, 0x39, 0xf2, 0x6d, 0x13, 0x69, 0xf4, 0x60, 0xaa,
0x2f, 0xd2, 0xb8, 0xa8, 0x44, 0x07, 0x43, 0x9e, 0xef, 0xd6, 0x54, 0xdd, 0xd6, 0xf1, 0x7e, 0x89,
0x6e, 0xc9, 0x6a, 0x17, 0x05, 0x4c, 0x67, 0x32, 0x84, 0x37, 0x95, 0x66, 0x51, 0x7e, 0x2d, 0xab,
0x68, 0x2b, 0x89, 0x1c, 0x5d, 0x53, 0xbd, 0xef, 0x61, 0x19, 0xa7, 0x18, 0xc3, 0x74, 0xe6, 0xa9,
0xa5, 0x4d, 0x8b, 0x9e, 0x5f, 0xde, 0xe3, 0x23, 0xd5, 0xa7, 0x89, 0x1b, 0xe5, 0x3d, 0x3a, 0x17,
0x3d, 0xdd, 0x0d, 0x82, 0xdf, 0x08, 0x2c, 0x64, 0xaf, 0x4d, 0x07, 0x06, 0x69, 0xc1, 0x9d, 0x9a,
0x7c, 0xa5, 0x24, 0xc5, 0xe9, 0xa3, 0xbb, 0x8a, 0xe8, 0x29, 0x5d, 0xff, 0x3f, 0x91, 0xf9, 0xe3,
0x28, 0xb6, 0x07, 0x32, 0x8b, 0x3f, 0x09, 0xdc, 0x2a, 0x06, 0x78, 0xcb, 0x23, 0xe1, 0x05, 0xfe,
0x28, 0x90, 0xa7, 0x0a, 0xf2, 0x88, 0xee, 0x0f, 0x03, 0xe9, 0x5c, 0xe6, 0x21, 0xed, 0xd8, 0x3b,
0xe9, 0x3a, 0x9d, 0x84, 0xa7, 0xc8, 0xc4, 0x15, 0x81, 0xb9, 0xbe, 0xa0, 0x9a, 0xf5, 0xdb, 0xf9,
0x08, 0x97, 0xe4, 0xfe, 0x4c, 0x14, 0x78, 0x17, 0x9b, 0xc3, 0x81, 0xf7, 0x38, 0x0f, 0xf7, 0xf0,
0xf9, 0xf0, 0x5f, 0x19, 0x77, 0xce, 0x65, 0x3a, 0xea, 0xe2, 0x77, 0x02, 0x4b, 0xfd, 0xb1, 0xcf,
0x5d, 0x8c, 0xc0, 0x95, 0x81, 0x97, 0x91, 0x2f, 0xd1, 0x3e, 0x57, 0x4b, 0x54, 0xa6, 0x4f, 0x6a,
0x47, 0x59, 0x7f, 0x82, 0x8f, 0x47, 0x30, 0x81, 0x5f, 0x49, 0xf6, 0x9f, 0x84, 0xee, 0x26, 0xf0,
0xce, 0x5f, 0x49, 0x0c, 0x2c, 0xfd, 0x57, 0x49, 0x4a, 0xf9, 0x50, 0x51, 0xda, 0x38, 0x54, 0xfc,
0x8f, 0x27, 0xd4, 0xaf, 0x83, 0x07, 0x7f, 0x02, 0x00, 0x00, 0xff, 0xff, 0x32, 0xe7, 0x89, 0x2c,
0x6b, 0x08, 0x00, 0x00,
}
// Reference imports to suppress errors if they are not otherwise used.

77
api/workflow.pb.gw.go
View File

@@ -246,6 +246,52 @@ func local_request_WorkflowService_ListWorkflows_0(ctx context.Context, marshale
}
func request_WorkflowService_WatchWorkflow_0(ctx context.Context, marshaler runtime.Marshaler, client WorkflowServiceClient, req *http.Request, pathParams map[string]string) (WorkflowService_WatchWorkflowClient, runtime.ServerMetadata, error) {
var protoReq WatchWorkflowRequest
var metadata runtime.ServerMetadata
var (
val string
ok bool
err error
_ = err
)
val, ok = pathParams["namespace"]
if !ok {
return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "namespace")
}
protoReq.Namespace, err = runtime.String(val)
if err != nil {
return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "namespace", err)
}
val, ok = pathParams["name"]
if !ok {
return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
}
protoReq.Name, err = runtime.String(val)
if err != nil {
return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
}
stream, err := client.WatchWorkflow(ctx, &protoReq)
if err != nil {
return nil, metadata, err
}
header, err := stream.Header()
if err != nil {
return nil, metadata, err
}
metadata.HeaderMD = header
return stream, metadata, nil
}
func request_WorkflowService_CreateWorkflowTemplate_0(ctx context.Context, marshaler runtime.Marshaler, client WorkflowServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
var protoReq CreateWorkflowTemplateRequest
var metadata runtime.ServerMetadata
@@ -792,6 +838,13 @@ func RegisterWorkflowServiceHandlerServer(ctx context.Context, mux *runtime.Serv
})
mux.Handle("GET", pattern_WorkflowService_WatchWorkflow_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
err := status.Error(codes.Unimplemented, "streaming calls are not yet supported in the in-process transport")
_, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
return
})
mux.Handle("POST", pattern_WorkflowService_CreateWorkflowTemplate_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
ctx, cancel := context.WithCancel(req.Context())
defer cancel()
@@ -1013,6 +1066,26 @@ func RegisterWorkflowServiceHandlerClient(ctx context.Context, mux *runtime.Serv
})
mux.Handle("GET", pattern_WorkflowService_WatchWorkflow_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
ctx, cancel := context.WithCancel(req.Context())
defer cancel()
inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
rctx, err := runtime.AnnotateContext(ctx, mux, req)
if err != nil {
runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
return
}
resp, md, err := request_WorkflowService_WatchWorkflow_0(rctx, inboundMarshaler, client, req, pathParams)
ctx = runtime.NewServerMetadataContext(ctx, md)
if err != nil {
runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
return
}
forward_WorkflowService_WatchWorkflow_0(ctx, mux, outboundMarshaler, w, req, func() (proto.Message, error) { return resp.Recv() }, mux.GetForwardResponseOptions()...)
})
mux.Handle("POST", pattern_WorkflowService_CreateWorkflowTemplate_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
ctx, cancel := context.WithCancel(req.Context())
defer cancel()
@@ -1143,6 +1216,8 @@ var (
pattern_WorkflowService_ListWorkflows_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 1, 0, 4, 1, 5, 2, 2, 3}, []string{"apis", "v1beta1", "namespace", "workflows"}, "", runtime.AssumeColonVerbOpt(true)))
pattern_WorkflowService_WatchWorkflow_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 1, 0, 4, 1, 5, 2, 2, 3, 1, 0, 4, 1, 5, 4, 2, 5}, []string{"apis", "v1beta1", "namespace", "workflows", "name", "watch"}, "", runtime.AssumeColonVerbOpt(true)))
pattern_WorkflowService_CreateWorkflowTemplate_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 1, 0, 4, 1, 5, 2, 2, 3}, []string{"apis", "v1beta1", "namespace", "workflow_templates"}, "", runtime.AssumeColonVerbOpt(true)))
pattern_WorkflowService_CreateWorkflowTemplateVersion_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 1, 0, 4, 1, 5, 2, 2, 3, 1, 0, 4, 1, 5, 4, 2, 5}, []string{"apis", "v1beta1", "namespace", "workflow_templates", "workflowTemplate.uid", "versions"}, "", runtime.AssumeColonVerbOpt(true)))
@@ -1163,6 +1238,8 @@ var (
forward_WorkflowService_ListWorkflows_0 = runtime.ForwardResponseMessage
forward_WorkflowService_WatchWorkflow_0 = runtime.ForwardResponseStream
forward_WorkflowService_CreateWorkflowTemplate_0 = runtime.ForwardResponseMessage
forward_WorkflowService_CreateWorkflowTemplateVersion_0 = runtime.ForwardResponseMessage

6
api/workflow.proto
View File

@@ -26,7 +26,11 @@ service WorkflowService {
};
}
rpc WatchWorkflow (WatchWorkflowRequest) returns (stream Workflow) {}
rpc WatchWorkflow (WatchWorkflowRequest) returns (stream Workflow) {
option (google.api.http) = {
get: "/apis/v1beta1/{namespace}/workflows/{name}/watch"
};
}
rpc CreateWorkflowTemplate (CreateWorkflowTemplateRequest) returns (WorkflowTemplate) {
option (google.api.http) = {

30
api/workflow.swagger.json
View File

@@ -297,6 +297,36 @@
"WorkflowService"
]
}
},
"/apis/v1beta1/{namespace}/workflows/{name}/watch": {
"get": {
"operationId": "WatchWorkflow",
"responses": {
"200": {
"description": "A successful response.(streaming responses)",
"schema": {
"$ref": "#/x-stream-definitions/apiWorkflow"
}
}
},
"parameters": [
{
"name": "namespace",
"in": "path",
"required": true,
"type": "string"
},
{
"name": "name",
"in": "path",
"required": true,
"type": "string"
}
],
"tags": [
"WorkflowService"
]
}
}
},
"definitions": {

1
go.mod
View File

@@ -30,6 +30,7 @@ require (
github.com/pressly/goose v2.6.0+incompatible
github.com/sirupsen/logrus v1.4.2 // indirect
github.com/spf13/viper v1.6.1
github.com/tmc/grpc-websocket-proxy v0.0.0-20190109142713-0ad062ec5ee5
github.com/valyala/fasttemplate v1.1.0 // indirect
golang.org/x/crypto v0.0.0-20191128160524-b544559bb6d1 // indirect
golang.org/x/net v0.0.0-20191126235420-ef20fe5d7933 // indirect

1
go.sum
View File

@@ -240,6 +240,7 @@ github.com/stretchr/testify v1.3.0 h1:TivCn/peBQ7UY8ooIcPgZFpTNSz0Q2U6UrFlUfqbe0
github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
github.com/subosito/gotenv v1.2.0 h1:Slr1R9HxAlEKefgq5jn9U+DnETlIUa6HfgEzj0g5d7s=
github.com/subosito/gotenv v1.2.0/go.mod h1:N0PQaV/YGNqwC0u51sEeR/aUtSLEXKX9iv69rRypqCw=
github.com/tmc/grpc-websocket-proxy v0.0.0-20190109142713-0ad062ec5ee5 h1:LnC5Kc/wtumK+WB441p7ynQJzVuNRJiqddSIE3IlSEQ=
github.com/tmc/grpc-websocket-proxy v0.0.0-20190109142713-0ad062ec5ee5/go.mod h1:ncp9v5uamzpCO7NfCPTXjqaC+bZgJeR0sMTm6dMHP7U=
github.com/ugorji/go v1.1.4/go.mod h1:uQMGLiO92mf5W77hV/PUCpI3pbzQx3CRekS0kk+RGrc=
github.com/valyala/bytebufferpool v1.0.0 h1:GqA5TC/0021Y/b9FG4Oi9Mr3q7XYx6KllzawFIhcdPw=

3
main.go
View File

@@ -18,6 +18,7 @@ import (
"github.com/spf13/viper"
"google.golang.org/grpc"
"github.com/gorilla/handlers"
"github.com/tmc/grpc-websocket-proxy/wsproxy"
)
var (
@@ -94,7 +95,7 @@ func startHTTPProxy() {
}
log.Printf("Starting HTTP proxy on port %v", *httpPort)
if err = http.ListenAndServe(*httpPort, handlers.CORS()(mux)); err != nil {
if err = http.ListenAndServe(*httpPort, wsproxy.WebsocketProxy(handlers.CORS()(mux))); err != nil {
log.Fatalf("Failed to serve HTTP listener: %v", err)
}
}