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

Moving the label messages out of workflow and into it's own proto file.

Browse Source 
- CronWorkflows re-use the same message types.
Added endpoints for CronWorkflow label operations.
This commit is contained in:
Aleksandr Melnikov
2020-04-02 14:56:00 -07:00
parent 6e27a5c6b8
commit 58eb005851
12 changed files with 946 additions and 564 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
api/api.pb.go
View File

@@ -21,7 +21,9 @@ var _ = math.Inf
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
func init() { proto.RegisterFile("api.proto", fileDescriptor_00212fb1f9d3bf1c) }
func init() {
proto.RegisterFile("api.proto", fileDescriptor_00212fb1f9d3bf1c)
}
var fileDescriptor_00212fb1f9d3bf1c = []byte{
// 265 bytes of a gzipped FileDescriptorProto

12
api/auth.pb.go
View File

@@ -109,7 +109,9 @@ func init() {
proto.RegisterType((*IsValidTokenRequest)(nil), "api.IsValidTokenRequest")
}
func init() { proto.RegisterFile("auth.proto", fileDescriptor_8bbd6f3875b0e874) }
func init() {
proto.RegisterFile("auth.proto", fileDescriptor_8bbd6f3875b0e874)
}
var fileDescriptor_8bbd6f3875b0e874 = []byte{
// 228 bytes of a gzipped FileDescriptorProto
@@ -132,11 +134,11 @@ var fileDescriptor_8bbd6f3875b0e874 = []byte{
// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var _ grpc.ClientConn
var _ grpc.ClientConnInterface
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
const _ = grpc.SupportPackageIsVersion4
const _ = grpc.SupportPackageIsVersion6
// AuthServiceClient is the client API for AuthService service.
//
@@ -146,10 +148,10 @@ type AuthServiceClient interface {
}
type authServiceClient struct {
cc *grpc.ClientConn
cc grpc.ClientConnInterface
}
func NewAuthServiceClient(cc *grpc.ClientConn) AuthServiceClient {
func NewAuthServiceClient(cc grpc.ClientConnInterface) AuthServiceClient {
return &authServiceClient{cc}
}

259
api/cron_workflow.pb.go
View File

@@ -469,66 +469,75 @@ func init() {
proto.RegisterType((*CronWorkflow)(nil), "api.CronWorkflow")
}
func init() { proto.RegisterFile("cron_workflow.proto", fileDescriptor_989cccaad551a50c) }
func init() {
proto.RegisterFile("cron_workflow.proto", fileDescriptor_989cccaad551a50c)
}
var fileDescriptor_989cccaad551a50c = []byte{
// 740 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x95, 0xdd, 0x4e, 0xdb, 0x48,
0x14, 0xc7, 0x65, 0x42, 0x20, 0x39, 0xcb, 0xee, 0x2a, 0xc3, 0x12, 0x8c, 0x89, 0x10, 0xeb, 0x9b,
0x45, 0xab, 0x55, 0xbc, 0xb0, 0x5a, 0xe8, 0x87, 0x8a, 0xda, 0x02, 0x6a, 0x85, 0xb8, 0x40, 0x06,
0x84, 0xd4, 0x1b, 0xe4, 0x8c, 0x4f, 0xd2, 0x51, 0x9d, 0x19, 0xd7, 0x33, 0x86, 0x06, 0xc4, 0x4d,
0x55, 0xf5, 0xa6, 0xea, 0x55, 0xd5, 0x9b, 0xf6, 0x35, 0xfa, 0x0e, 0x7d, 0x80, 0xbe, 0x42, 0x1f,
0xa4, 0xf2, 0xc4, 0x09, 0x49, 0x9c, 0xa0, 0x14, 0x71, 0x65, 0x9f, 0xf9, 0x9f, 0x99, 0xf3, 0x9b,
0xaf, 0xff, 0xc0, 0x2c, 0x8d, 0x04, 0x3f, 0x39, 0x13, 0xd1, 0x8b, 0x7a, 0x20, 0xce, 0xaa, 0x61,
0x24, 0x94, 0x20, 0x39, 0x2f, 0x64, 0x56, 0xa5, 0x21, 0x44, 0x23, 0x40, 0xc7, 0x0b, 0x99, 0xe3,
0x71, 0x2e, 0x94, 0xa7, 0x98, 0xe0, 0xb2, 0x9d, 0x62, 0x2d, 0xa6, 0xaa, 0x8e, 0x6a, 0x71, 0xdd,
0xc1, 0x66, 0xa8, 0x5a, 0xa9, 0x38, 0xdf, 0x19, 0xef, 0x44, 0x61, 0x33, 0x0c, 0x3c, 0x85, 0xa9,
0xf0, 0x5b, 0x7f, 0x21, 0x6b, 0xa6, 0x89, 0x2a, 0x62, 0xb4, 0x1d, 0xd9, 0xfb, 0x50, 0x39, 0xc4,
0xa8, 0xc9, 0xb8, 0xa7, 0x70, 0x2b, 0x12, 0xfc, 0x38, 0x4d, 0x76, 0xf1, 0x65, 0x8c, 0x52, 0x91,
0x0a, 0x14, 0xb9, 0xd7, 0x44, 0x19, 0x7a, 0x14, 0x4d, 0x63, 0xd9, 0x58, 0x29, 0xba, 0x57, 0x0d,
0x84, 0xc0, 0x64, 0x12, 0x98, 0x13, 0x5a, 0xd0, 0xff, 0xf6, 0x2e, 0x94, 0x9f, 0xa0, 0xba, 0x9d,
0xb1, 0x42, 0x58, 0xd8, 0x8a, 0xf0, 0x46, 0x68, 0xff, 0xc3, 0x0c, 0xed, 0xe9, 0xa4, 0x87, 0xfd,
0x65, 0xad, 0x54, 0xf5, 0x42, 0x56, 0xed, 0x1b, 0xad, 0x2f, 0xcd, 0x7e, 0x63, 0xc0, 0xc2, 0x51,
0xe8, 0xdf, 0xd6, 0x6a, 0x64, 0x30, 0x72, 0xe3, 0x61, 0x7c, 0x36, 0x60, 0x7e, 0x8f, 0xc9, 0x1b,
0x2c, 0xe3, 0x1a, 0xcc, 0x65, 0x4e, 0xc2, 0x49, 0xcc, 0xfc, 0x94, 0x6a, 0xb6, 0x23, 0x1e, 0xa6,
0xda, 0x11, 0xf3, 0x89, 0x05, 0x85, 0xd0, 0x6b, 0xe0, 0x01, 0x3b, 0x47, 0x0d, 0x98, 0x77, 0xbb,
0x71, 0x32, 0xa9, 0xe4, 0xdf, 0x9c, 0xd4, 0xed, 0xfa, 0xdf, 0xfe, 0x62, 0xc0, 0xc2, 0x20, 0x9d,
0x74, 0x51, 0x86, 0x82, 0x4b, 0x24, 0x7f, 0x40, 0x9e, 0x8a, 0x98, 0x2b, 0xcd, 0x96, 0x77, 0xdb,
0x01, 0xd9, 0x80, 0x5f, 0x7b, 0x67, 0x28, 0xcd, 0x89, 0xe5, 0xdc, 0xf0, 0x95, 0xe8, 0xcf, 0xeb,
0x02, 0xe4, 0xae, 0x00, 0x92, 0x12, 0xc9, 0x57, 0xa6, 0x54, 0xed, 0x80, 0x2c, 0x01, 0x28, 0xa1,
0xbc, 0x60, 0x4b, 0x57, 0xcf, 0x6b, 0xa9, 0xa7, 0xc5, 0xfe, 0x94, 0x83, 0x99, 0xde, 0x4a, 0xdd,
0x0d, 0x33, 0x7a, 0x36, 0xcc, 0x82, 0x82, 0xa4, 0xcf, 0xd1, 0x8f, 0x83, 0xce, 0x46, 0x76, 0xe3,
0x44, 0x53, 0xac, 0x89, 0xe7, 0x82, 0xb7, 0x71, 0x8a, 0x6e, 0x37, 0x26, 0x26, 0x4c, 0xcb, 0x58,
0x86, 0xc8, 0x7d, 0x0d, 0x55, 0x70, 0x3b, 0x21, 0xf9, 0x07, 0x4a, 0x54, 0x70, 0x1a, 0x47, 0x11,
0x72, 0xda, 0xda, 0x17, 0x01, 0xa3, 0x2d, 0x4d, 0x57, 0x74, 0xb3, 0x02, 0xb9, 0x03, 0xf3, 0x52,
0x79, 0x91, 0x62, 0xbc, 0xb1, 0x8d, 0x9e, 0x1f, 0x30, 0x8e, 0x07, 0x48, 0x05, 0xf7, 0xa5, 0x39,
0xb5, 0x6c, 0xac, 0xe4, 0xdc, 0x51, 0x32, 0xd9, 0x04, 0x4b, 0xc6, 0x94, 0xa2, 0x94, 0xf5, 0x38,
0xd8, 0x15, 0x35, 0xf9, 0x94, 0x49, 0x25, 0xa2, 0xd6, 0x1e, 0x6b, 0x32, 0x65, 0x4e, 0xeb, 0xe5,
0xb8, 0x26, 0x83, 0xac, 0x43, 0xb9, 0xee, 0xb1, 0x00, 0xfd, 0x4c, 0xdf, 0x82, 0xee, 0x3b, 0x42,
0x25, 0xdb, 0x50, 0xea, 0x1c, 0xaa, 0x9d, 0x57, 0x48, 0xe3, 0xc4, 0xb2, 0xcc, 0xa2, 0x3e, 0xe7,
0x65, 0xbd, 0xbb, 0xc7, 0x83, 0xaa, 0x9b, 0xed, 0xb0, 0xf6, 0x6e, 0x0a, 0x66, 0x7b, 0x37, 0xe7,
0x00, 0xa3, 0x53, 0x46, 0x91, 0xbc, 0x35, 0x80, 0x64, 0x3d, 0x80, 0x2c, 0xa5, 0xe7, 0x66, 0x84,
0x39, 0x58, 0xd9, 0x73, 0x65, 0x3f, 0x78, 0xfd, 0xed, 0xfb, 0x87, 0x89, 0x0d, 0xfb, 0xaf, 0xc4,
0x5e, 0xa5, 0x73, 0xba, 0x5a, 0x43, 0xe5, 0xad, 0x3a, 0x17, 0xdd, 0xbb, 0x73, 0xe9, 0xf4, 0x19,
0xf3, 0xbd, 0xbe, 0x2b, 0x49, 0xde, 0x1b, 0x40, 0xb2, 0xce, 0x90, 0x82, 0x8c, 0xb4, 0x8c, 0x61,
0x20, 0xdb, 0x1a, 0x64, 0xd3, 0xae, 0x8e, 0x09, 0xd2, 0x56, 0x2e, 0x07, 0x78, 0x5a, 0xf0, 0xfb,
0x80, 0xcf, 0x92, 0x45, 0x5d, 0x6b, 0xb8, 0xfb, 0x0e, 0x03, 0x59, 0xd7, 0x20, 0xff, 0x92, 0x9f,
0x04, 0x21, 0x5f, 0x0d, 0x28, 0x65, 0xee, 0x3f, 0xa9, 0xe8, 0x02, 0x23, 0x5c, 0xcb, 0x5a, 0x1a,
0xaa, 0x76, 0x5d, 0xc3, 0x56, 0x9a, 0x85, 0x93, 0x95, 0x31, 0x59, 0xe4, 0xb3, 0xc7, 0xe4, 0xe1,
0xb8, 0xb9, 0xce, 0xc5, 0x50, 0x4f, 0xbc, 0x24, 0x1f, 0x0d, 0x98, 0x1b, 0xfa, 0xfe, 0x91, 0x3f,
0x35, 0xef, 0x75, 0x6f, 0xa3, 0x55, 0xae, 0xb6, 0x1f, 0xe4, 0x6a, 0xe7, 0x41, 0xae, 0xee, 0x24,
0x0f, 0xb2, 0xfd, 0x48, 0x4f, 0xe5, 0xfe, 0xdf, 0x77, 0xc7, 0xc7, 0xd3, 0xeb, 0xea, 0xa8, 0x4e,
0xb5, 0xda, 0x94, 0x1e, 0xf2, 0xbf, 0x1f, 0x01, 0x00, 0x00, 0xff, 0xff, 0x74, 0x56, 0x62, 0x2e,
0x2b, 0x08, 0x00, 0x00,
// 855 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x95, 0x41, 0x6f, 0xdc, 0x44,
0x14, 0xc7, 0xe5, 0x6c, 0x93, 0x66, 0x5f, 0x03, 0x28, 0x13, 0x36, 0xeb, 0x75, 0xa3, 0x28, 0xf8,
0x42, 0x54, 0xa1, 0x35, 0x0d, 0x22, 0x2d, 0x05, 0xa2, 0x86, 0xa4, 0x80, 0xaa, 0x1c, 0x2a, 0xa7,
0x55, 0x25, 0x2e, 0xd1, 0xec, 0xf8, 0xed, 0x32, 0xaa, 0x77, 0xc6, 0x78, 0xc6, 0x2d, 0xdb, 0x68,
0x2f, 0x08, 0x71, 0x03, 0x21, 0x21, 0x38, 0xc0, 0xd7, 0xe0, 0x3b, 0x70, 0x46, 0x7c, 0x05, 0x3e,
0x08, 0xf2, 0xd8, 0xde, 0xec, 0xae, 0xbd, 0x65, 0xb3, 0xcd, 0xc9, 0x7e, 0xf3, 0x9f, 0x99, 0xf7,
0xf3, 0xbc, 0xe7, 0xff, 0xc0, 0x06, 0x8b, 0xa5, 0x38, 0x7b, 0x21, 0xe3, 0x67, 0xdd, 0x50, 0xbe,
0x68, 0x47, 0xb1, 0xd4, 0x92, 0xd4, 0x68, 0xc4, 0x9d, 0xad, 0x9e, 0x94, 0xbd, 0x10, 0x3d, 0x1a,
0x71, 0x8f, 0x0a, 0x21, 0x35, 0xd5, 0x5c, 0x0a, 0x95, 0x4d, 0x71, 0x6e, 0xe6, 0xaa, 0x89, 0x3a,
0x49, 0xd7, 0xc3, 0x7e, 0xa4, 0x07, 0xb9, 0xd8, 0x2c, 0xf6, 0x3b, 0xd3, 0xd8, 0x8f, 0x42, 0xaa,
0x31, 0x17, 0xde, 0x9c, 0x4c, 0xe4, 0xac, 0xf5, 0x51, 0xc7, 0x9c, 0xe5, 0xd1, 0x8d, 0x90, 0x76,
0x30, 0xcc, 0x02, 0xf7, 0x11, 0x6c, 0x3d, 0xc6, 0xb8, 0xcf, 0x05, 0xd5, 0x78, 0x14, 0x4b, 0xf1,
0x34, 0x5f, 0xe9, 0xe3, 0x37, 0x09, 0x2a, 0x4d, 0xb6, 0xa0, 0x2e, 0x68, 0x1f, 0x55, 0x44, 0x19,
0xda, 0xd6, 0x8e, 0xb5, 0x5b, 0xf7, 0x2f, 0x06, 0x08, 0x81, 0x6b, 0x69, 0x60, 0x2f, 0x19, 0xc1,
0xbc, 0xbb, 0x0f, 0x61, 0xf3, 0x0b, 0xd4, 0x57, 0xb3, 0x57, 0x04, 0xad, 0xa3, 0x18, 0x17, 0x42,
0xfb, 0x10, 0xd6, 0xd8, 0xd8, 0x22, 0xb3, 0xed, 0x8d, 0xbd, 0xf5, 0x36, 0x8d, 0x78, 0x7b, 0x62,
0xb7, 0x89, 0x69, 0xee, 0xf7, 0x16, 0xb4, 0x9e, 0x44, 0xc1, 0x55, 0x9d, 0x46, 0x09, 0xa3, 0x36,
0x1f, 0xc6, 0x1f, 0x16, 0x34, 0x4f, 0xb8, 0x5a, 0xe0, 0x18, 0xf7, 0xa0, 0x51, 0x6a, 0x8b, 0xb3,
0x84, 0x07, 0x39, 0xd5, 0x46, 0x21, 0x3e, 0xce, 0xb5, 0x27, 0x3c, 0x20, 0x0e, 0xac, 0x46, 0xb4,
0x87, 0xa7, 0xfc, 0x25, 0x1a, 0xc0, 0x65, 0x7f, 0x14, 0xa7, 0x1f, 0x95, 0xbe, 0xdb, 0xd7, 0xcc,
0xb8, 0x79, 0x77, 0xff, 0xb4, 0xa0, 0x35, 0x4d, 0xa7, 0x7c, 0x54, 0x91, 0x14, 0x0a, 0xc9, 0xdb,
0xb0, 0xcc, 0x64, 0x22, 0xb4, 0x61, 0x5b, 0xf6, 0xb3, 0x80, 0xdc, 0x81, 0x37, 0xc6, 0xbf, 0x50,
0xd9, 0x4b, 0x3b, 0xb5, 0xea, 0x93, 0x98, 0x9c, 0x37, 0x02, 0xa8, 0x5d, 0x00, 0xa4, 0x29, 0xd2,
0xa7, 0xca, 0xa9, 0xb2, 0x80, 0x6c, 0x03, 0x68, 0xa9, 0x69, 0x78, 0x64, 0xb2, 0x2f, 0x1b, 0x69,
0x6c, 0xc4, 0xfd, 0xbd, 0x06, 0x6b, 0xe3, 0x99, 0x46, 0x05, 0xb3, 0xc6, 0x0a, 0xe6, 0xc0, 0xaa,
0x62, 0x5f, 0x63, 0x90, 0x84, 0x45, 0x21, 0x47, 0x71, 0xaa, 0x69, 0xde, 0xc7, 0x97, 0x52, 0x64,
0x38, 0x75, 0x7f, 0x14, 0x13, 0x1b, 0xae, 0xab, 0x44, 0x45, 0x28, 0x02, 0x03, 0xb5, 0xea, 0x17,
0x21, 0x79, 0x0f, 0xd6, 0x99, 0x14, 0x2c, 0x89, 0x63, 0x14, 0x6c, 0xf0, 0x48, 0x86, 0x9c, 0x0d,
0x0c, 0x5d, 0xdd, 0x2f, 0x0b, 0xe4, 0x2e, 0x34, 0x95, 0xa6, 0xb1, 0xe6, 0xa2, 0x77, 0x8c, 0x34,
0x08, 0xb9, 0xc0, 0x53, 0x64, 0x52, 0x04, 0xca, 0x5e, 0xd9, 0xb1, 0x76, 0x6b, 0xfe, 0x2c, 0x99,
0x1c, 0x80, 0xa3, 0x12, 0xc6, 0x50, 0xa9, 0x6e, 0x12, 0x3e, 0x94, 0x1d, 0xf5, 0x25, 0x57, 0x5a,
0xc6, 0x83, 0x13, 0xde, 0xe7, 0xda, 0xbe, 0x6e, 0x8e, 0xe3, 0x15, 0x33, 0xc8, 0x3e, 0x6c, 0x76,
0x29, 0x0f, 0x31, 0x28, 0xad, 0x5d, 0x35, 0x6b, 0x67, 0xa8, 0xe4, 0x18, 0xd6, 0x8b, 0xa6, 0x7a,
0xf0, 0x2d, 0xb2, 0x24, 0xf5, 0x2f, 0xbb, 0x6e, 0xfa, 0x7c, 0xd3, 0x54, 0xf7, 0xe9, 0xb4, 0xea,
0x97, 0x17, 0xec, 0xfd, 0x0d, 0xb0, 0x31, 0x5e, 0x9c, 0x53, 0x8c, 0x9f, 0x73, 0x86, 0xe4, 0x07,
0x0b, 0x48, 0xd9, 0x03, 0xc8, 0x76, 0xde, 0x37, 0x33, 0xcc, 0xc1, 0x29, 0xf7, 0x95, 0xfb, 0xe9,
0x77, 0xff, 0xfc, 0xfb, 0xcb, 0xd2, 0x1d, 0xf7, 0xdd, 0xd4, 0x6b, 0x95, 0xf7, 0xfc, 0x76, 0x07,
0x35, 0xbd, 0xed, 0x9d, 0x8f, 0xfe, 0x9d, 0xa1, 0x37, 0xe1, 0xd2, 0xf7, 0x26, 0x7e, 0x49, 0xf2,
0xa3, 0x05, 0xa4, 0xec, 0x0c, 0x39, 0xc8, 0x4c, 0xcb, 0xa8, 0x02, 0x39, 0x36, 0x20, 0x07, 0x6e,
0x7b, 0x4e, 0x90, 0x4c, 0x19, 0x4e, 0xf1, 0x0c, 0xe0, 0xad, 0x29, 0x9f, 0x25, 0x37, 0x4d, 0xae,
0x6a, 0xf7, 0xad, 0x02, 0xd9, 0x37, 0x20, 0xef, 0x93, 0x4b, 0x82, 0x90, 0xbf, 0x2c, 0x58, 0x2f,
0xfd, 0xff, 0x64, 0xcb, 0x24, 0x98, 0xe1, 0x5a, 0xce, 0x76, 0xa5, 0x3a, 0x72, 0x0d, 0x57, 0x1b,
0x16, 0x41, 0x76, 0xe7, 0x64, 0x51, 0x5f, 0x7d, 0x46, 0xee, 0xcf, 0x3b, 0xd7, 0x3b, 0xaf, 0xf4,
0xc4, 0x21, 0xf9, 0xd5, 0x82, 0x46, 0xe5, 0xfd, 0x47, 0xde, 0x31, 0xbc, 0xaf, 0xba, 0x1b, 0x9d,
0xcd, 0x76, 0x76, 0x3b, 0xb7, 0x8b, 0xdb, 0xb9, 0xfd, 0x20, 0xbd, 0x9d, 0xdd, 0x43, 0xf3, 0x29,
0x1f, 0xdf, 0xfa, 0x68, 0x7e, 0x3c, 0x73, 0xae, 0x9e, 0x2e, 0xb2, 0xa5, 0x5d, 0xdf, 0x98, 0xaa,
0xe3, 0x49, 0x7a, 0x6b, 0x2b, 0xd2, 0x28, 0x6a, 0x9c, 0xc5, 0x17, 0x2c, 0x53, 0xc3, 0xf9, 0xb1,
0x1e, 0x18, 0x96, 0xbb, 0x64, 0xff, 0xb2, 0x2c, 0x61, 0x96, 0xee, 0x27, 0x0b, 0x1a, 0x87, 0x41,
0x30, 0x13, 0xe4, 0x30, 0x08, 0xe6, 0x03, 0xf9, 0xdc, 0x80, 0xdc, 0x77, 0x17, 0x04, 0xb9, 0xb7,
0x92, 0x03, 0xfd, 0x66, 0x41, 0xcb, 0xc7, 0x28, 0xa4, 0x0c, 0x2b, 0xa0, 0x5a, 0x26, 0x7b, 0xae,
0x5f, 0x0a, 0xcc, 0x79, 0x5d, 0xb0, 0x9f, 0x2d, 0x68, 0x1e, 0x63, 0x88, 0xba, 0xcc, 0x45, 0x9a,
0x26, 0x77, 0xa6, 0x9a, 0x91, 0xff, 0x83, 0xca, 0x2d, 0xe2, 0xd6, 0x27, 0x8b, 0x41, 0x79, 0xe7,
0xcf, 0x70, 0x30, 0xec, 0xac, 0x98, 0xc6, 0xfc, 0xe0, 0xbf, 0x00, 0x00, 0x00, 0xff, 0xff, 0xe9,
0x77, 0xb5, 0xc0, 0x7e, 0x0a, 0x00, 0x00,
}
// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var _ grpc.ClientConn
var _ grpc.ClientConnInterface
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
const _ = grpc.SupportPackageIsVersion4
const _ = grpc.SupportPackageIsVersion6
// CronWorkflowServiceClient is the client API for CronWorkflowService service.
//
@@ -539,13 +548,17 @@ type CronWorkflowServiceClient interface {
GetCronWorkflow(ctx context.Context, in *GetCronWorkflowRequest, opts ...grpc.CallOption) (*CronWorkflow, error)
ListCronWorkflows(ctx context.Context, in *ListCronWorkflowRequest, opts ...grpc.CallOption) (*ListCronWorkflowsResponse, error)
TerminateCronWorkflow(ctx context.Context, in *TerminateCronWorkflowRequest, opts ...grpc.CallOption) (*empty.Empty, error)
GetCronWorkflowLabels(ctx context.Context, in *GetLabelsRequest, opts ...grpc.CallOption) (*GetLabelsResponse, error)
AddCronWorkflowLabels(ctx context.Context, in *AddLabelsRequest, opts ...grpc.CallOption) (*GetLabelsResponse, error)
ReplaceCronWorkflowLabels(ctx context.Context, in *ReplaceLabelsRequest, opts ...grpc.CallOption) (*GetLabelsResponse, error)
DeleteCronWorkflowLabel(ctx context.Context, in *DeleteLabelRequest, opts ...grpc.CallOption) (*GetLabelsResponse, error)
}
type cronWorkflowServiceClient struct {
cc *grpc.ClientConn
cc grpc.ClientConnInterface
}
func NewCronWorkflowServiceClient(cc *grpc.ClientConn) CronWorkflowServiceClient {
func NewCronWorkflowServiceClient(cc grpc.ClientConnInterface) CronWorkflowServiceClient {
return &cronWorkflowServiceClient{cc}
}
@@ -594,6 +607,42 @@ func (c *cronWorkflowServiceClient) TerminateCronWorkflow(ctx context.Context, i
return out, nil
}
func (c *cronWorkflowServiceClient) GetCronWorkflowLabels(ctx context.Context, in *GetLabelsRequest, opts ...grpc.CallOption) (*GetLabelsResponse, error) {
out := new(GetLabelsResponse)
err := c.cc.Invoke(ctx, "/api.CronWorkflowService/GetCronWorkflowLabels", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *cronWorkflowServiceClient) AddCronWorkflowLabels(ctx context.Context, in *AddLabelsRequest, opts ...grpc.CallOption) (*GetLabelsResponse, error) {
out := new(GetLabelsResponse)
err := c.cc.Invoke(ctx, "/api.CronWorkflowService/AddCronWorkflowLabels", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *cronWorkflowServiceClient) ReplaceCronWorkflowLabels(ctx context.Context, in *ReplaceLabelsRequest, opts ...grpc.CallOption) (*GetLabelsResponse, error) {
out := new(GetLabelsResponse)
err := c.cc.Invoke(ctx, "/api.CronWorkflowService/ReplaceCronWorkflowLabels", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *cronWorkflowServiceClient) DeleteCronWorkflowLabel(ctx context.Context, in *DeleteLabelRequest, opts ...grpc.CallOption) (*GetLabelsResponse, error) {
out := new(GetLabelsResponse)
err := c.cc.Invoke(ctx, "/api.CronWorkflowService/DeleteCronWorkflowLabel", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// CronWorkflowServiceServer is the server API for CronWorkflowService service.
type CronWorkflowServiceServer interface {
CreateCronWorkflow(context.Context, *CreateCronWorkflowRequest) (*CronWorkflow, error)
@@ -601,6 +650,10 @@ type CronWorkflowServiceServer interface {
GetCronWorkflow(context.Context, *GetCronWorkflowRequest) (*CronWorkflow, error)
ListCronWorkflows(context.Context, *ListCronWorkflowRequest) (*ListCronWorkflowsResponse, error)
TerminateCronWorkflow(context.Context, *TerminateCronWorkflowRequest) (*empty.Empty, error)
GetCronWorkflowLabels(context.Context, *GetLabelsRequest) (*GetLabelsResponse, error)
AddCronWorkflowLabels(context.Context, *AddLabelsRequest) (*GetLabelsResponse, error)
ReplaceCronWorkflowLabels(context.Context, *ReplaceLabelsRequest) (*GetLabelsResponse, error)
DeleteCronWorkflowLabel(context.Context, *DeleteLabelRequest) (*GetLabelsResponse, error)
}
// UnimplementedCronWorkflowServiceServer can be embedded to have forward compatible implementations.
@@ -622,6 +675,18 @@ func (*UnimplementedCronWorkflowServiceServer) ListCronWorkflows(ctx context.Con
func (*UnimplementedCronWorkflowServiceServer) TerminateCronWorkflow(ctx context.Context, req *TerminateCronWorkflowRequest) (*empty.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method TerminateCronWorkflow not implemented")
}
func (*UnimplementedCronWorkflowServiceServer) GetCronWorkflowLabels(ctx context.Context, req *GetLabelsRequest) (*GetLabelsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetCronWorkflowLabels not implemented")
}
func (*UnimplementedCronWorkflowServiceServer) AddCronWorkflowLabels(ctx context.Context, req *AddLabelsRequest) (*GetLabelsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method AddCronWorkflowLabels not implemented")
}
func (*UnimplementedCronWorkflowServiceServer) ReplaceCronWorkflowLabels(ctx context.Context, req *ReplaceLabelsRequest) (*GetLabelsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ReplaceCronWorkflowLabels not implemented")
}
func (*UnimplementedCronWorkflowServiceServer) DeleteCronWorkflowLabel(ctx context.Context, req *DeleteLabelRequest) (*GetLabelsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method DeleteCronWorkflowLabel not implemented")
}
func RegisterCronWorkflowServiceServer(s *grpc.Server, srv CronWorkflowServiceServer) {
s.RegisterService(&_CronWorkflowService_serviceDesc, srv)
@@ -717,6 +782,78 @@ func _CronWorkflowService_TerminateCronWorkflow_Handler(srv interface{}, ctx con
return interceptor(ctx, in, info, handler)
}
func _CronWorkflowService_GetCronWorkflowLabels_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetLabelsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CronWorkflowServiceServer).GetCronWorkflowLabels(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/api.CronWorkflowService/GetCronWorkflowLabels",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CronWorkflowServiceServer).GetCronWorkflowLabels(ctx, req.(*GetLabelsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _CronWorkflowService_AddCronWorkflowLabels_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(AddLabelsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CronWorkflowServiceServer).AddCronWorkflowLabels(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/api.CronWorkflowService/AddCronWorkflowLabels",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CronWorkflowServiceServer).AddCronWorkflowLabels(ctx, req.(*AddLabelsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _CronWorkflowService_ReplaceCronWorkflowLabels_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ReplaceLabelsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CronWorkflowServiceServer).ReplaceCronWorkflowLabels(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/api.CronWorkflowService/ReplaceCronWorkflowLabels",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CronWorkflowServiceServer).ReplaceCronWorkflowLabels(ctx, req.(*ReplaceLabelsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _CronWorkflowService_DeleteCronWorkflowLabel_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(DeleteLabelRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CronWorkflowServiceServer).DeleteCronWorkflowLabel(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/api.CronWorkflowService/DeleteCronWorkflowLabel",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CronWorkflowServiceServer).DeleteCronWorkflowLabel(ctx, req.(*DeleteLabelRequest))
}
return interceptor(ctx, in, info, handler)
}
var _CronWorkflowService_serviceDesc = grpc.ServiceDesc{
ServiceName: "api.CronWorkflowService",
HandlerType: (*CronWorkflowServiceServer)(nil),
@@ -741,6 +878,22 @@ var _CronWorkflowService_serviceDesc = grpc.ServiceDesc{
MethodName: "TerminateCronWorkflow",
Handler: _CronWorkflowService_TerminateCronWorkflow_Handler,
},
{
MethodName: "GetCronWorkflowLabels",
Handler: _CronWorkflowService_GetCronWorkflowLabels_Handler,
},
{
MethodName: "AddCronWorkflowLabels",
Handler: _CronWorkflowService_AddCronWorkflowLabels_Handler,
},
{
MethodName: "ReplaceCronWorkflowLabels",
Handler: _CronWorkflowService_ReplaceCronWorkflowLabels_Handler,
},
{
MethodName: "DeleteCronWorkflowLabel",
Handler: _CronWorkflowService_DeleteCronWorkflowLabel_Handler,
},
},
Streams: []grpc.StreamDesc{},
Metadata: "cron_workflow.proto",

534
api/cron_workflow.pb.gw.go
View File

@@ -505,6 +505,364 @@ func local_request_CronWorkflowService_TerminateCronWorkflow_0(ctx context.Conte
}
func request_CronWorkflowService_GetCronWorkflowLabels_0(ctx context.Context, marshaler runtime.Marshaler, client CronWorkflowServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
var protoReq GetLabelsRequest
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)
}
msg, err := client.GetCronWorkflowLabels(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
return msg, metadata, err
}
func local_request_CronWorkflowService_GetCronWorkflowLabels_0(ctx context.Context, marshaler runtime.Marshaler, server CronWorkflowServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
var protoReq GetLabelsRequest
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)
}
msg, err := server.GetCronWorkflowLabels(ctx, &protoReq)
return msg, metadata, err
}
func request_CronWorkflowService_AddCronWorkflowLabels_0(ctx context.Context, marshaler runtime.Marshaler, client CronWorkflowServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
var protoReq AddLabelsRequest
var metadata runtime.ServerMetadata
newReader, berr := utilities.IOReaderFactory(req.Body)
if berr != nil {
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
}
if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.Labels); err != nil && err != io.EOF {
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
}
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)
}
msg, err := client.AddCronWorkflowLabels(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
return msg, metadata, err
}
func local_request_CronWorkflowService_AddCronWorkflowLabels_0(ctx context.Context, marshaler runtime.Marshaler, server CronWorkflowServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
var protoReq AddLabelsRequest
var metadata runtime.ServerMetadata
newReader, berr := utilities.IOReaderFactory(req.Body)
if berr != nil {
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
}
if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.Labels); err != nil && err != io.EOF {
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
}
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)
}
msg, err := server.AddCronWorkflowLabels(ctx, &protoReq)
return msg, metadata, err
}
func request_CronWorkflowService_ReplaceCronWorkflowLabels_0(ctx context.Context, marshaler runtime.Marshaler, client CronWorkflowServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
var protoReq ReplaceLabelsRequest
var metadata runtime.ServerMetadata
newReader, berr := utilities.IOReaderFactory(req.Body)
if berr != nil {
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
}
if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.Labels); err != nil && err != io.EOF {
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
}
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)
}
msg, err := client.ReplaceCronWorkflowLabels(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
return msg, metadata, err
}
func local_request_CronWorkflowService_ReplaceCronWorkflowLabels_0(ctx context.Context, marshaler runtime.Marshaler, server CronWorkflowServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
var protoReq ReplaceLabelsRequest
var metadata runtime.ServerMetadata
newReader, berr := utilities.IOReaderFactory(req.Body)
if berr != nil {
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
}
if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.Labels); err != nil && err != io.EOF {
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
}
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)
}
msg, err := server.ReplaceCronWorkflowLabels(ctx, &protoReq)
return msg, metadata, err
}
func request_CronWorkflowService_DeleteCronWorkflowLabel_0(ctx context.Context, marshaler runtime.Marshaler, client CronWorkflowServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
var protoReq DeleteLabelRequest
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)
}
val, ok = pathParams["key"]
if !ok {
return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "key")
}
protoReq.Key, err = runtime.String(val)
if err != nil {
return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "key", err)
}
msg, err := client.DeleteCronWorkflowLabel(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
return msg, metadata, err
}
func local_request_CronWorkflowService_DeleteCronWorkflowLabel_0(ctx context.Context, marshaler runtime.Marshaler, server CronWorkflowServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
var protoReq DeleteLabelRequest
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)
}
val, ok = pathParams["key"]
if !ok {
return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "key")
}
protoReq.Key, err = runtime.String(val)
if err != nil {
return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "key", err)
}
msg, err := server.DeleteCronWorkflowLabel(ctx, &protoReq)
return msg, metadata, err
}
// RegisterCronWorkflowServiceHandlerServer registers the http handlers for service CronWorkflowService to "mux".
// UnaryRPC :call CronWorkflowServiceServer directly.
// StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.
@@ -630,6 +988,86 @@ func RegisterCronWorkflowServiceHandlerServer(ctx context.Context, mux *runtime.
})
mux.Handle("GET", pattern_CronWorkflowService_GetCronWorkflowLabels_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.AnnotateIncomingContext(ctx, mux, req)
if err != nil {
runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
return
}
resp, md, err := local_request_CronWorkflowService_GetCronWorkflowLabels_0(rctx, inboundMarshaler, server, req, pathParams)
ctx = runtime.NewServerMetadataContext(ctx, md)
if err != nil {
runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
return
}
forward_CronWorkflowService_GetCronWorkflowLabels_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
})
mux.Handle("POST", pattern_CronWorkflowService_AddCronWorkflowLabels_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.AnnotateIncomingContext(ctx, mux, req)
if err != nil {
runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
return
}
resp, md, err := local_request_CronWorkflowService_AddCronWorkflowLabels_0(rctx, inboundMarshaler, server, req, pathParams)
ctx = runtime.NewServerMetadataContext(ctx, md)
if err != nil {
runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
return
}
forward_CronWorkflowService_AddCronWorkflowLabels_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
})
mux.Handle("PUT", pattern_CronWorkflowService_ReplaceCronWorkflowLabels_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.AnnotateIncomingContext(ctx, mux, req)
if err != nil {
runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
return
}
resp, md, err := local_request_CronWorkflowService_ReplaceCronWorkflowLabels_0(rctx, inboundMarshaler, server, req, pathParams)
ctx = runtime.NewServerMetadataContext(ctx, md)
if err != nil {
runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
return
}
forward_CronWorkflowService_ReplaceCronWorkflowLabels_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
})
mux.Handle("DELETE", pattern_CronWorkflowService_DeleteCronWorkflowLabel_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.AnnotateIncomingContext(ctx, mux, req)
if err != nil {
runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
return
}
resp, md, err := local_request_CronWorkflowService_DeleteCronWorkflowLabel_0(rctx, inboundMarshaler, server, req, pathParams)
ctx = runtime.NewServerMetadataContext(ctx, md)
if err != nil {
runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
return
}
forward_CronWorkflowService_DeleteCronWorkflowLabel_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
})
return nil
}
@@ -791,6 +1229,86 @@ func RegisterCronWorkflowServiceHandlerClient(ctx context.Context, mux *runtime.
})
mux.Handle("GET", pattern_CronWorkflowService_GetCronWorkflowLabels_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_CronWorkflowService_GetCronWorkflowLabels_0(rctx, inboundMarshaler, client, req, pathParams)
ctx = runtime.NewServerMetadataContext(ctx, md)
if err != nil {
runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
return
}
forward_CronWorkflowService_GetCronWorkflowLabels_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
})
mux.Handle("POST", pattern_CronWorkflowService_AddCronWorkflowLabels_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_CronWorkflowService_AddCronWorkflowLabels_0(rctx, inboundMarshaler, client, req, pathParams)
ctx = runtime.NewServerMetadataContext(ctx, md)
if err != nil {
runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
return
}
forward_CronWorkflowService_AddCronWorkflowLabels_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
})
mux.Handle("PUT", pattern_CronWorkflowService_ReplaceCronWorkflowLabels_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_CronWorkflowService_ReplaceCronWorkflowLabels_0(rctx, inboundMarshaler, client, req, pathParams)
ctx = runtime.NewServerMetadataContext(ctx, md)
if err != nil {
runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
return
}
forward_CronWorkflowService_ReplaceCronWorkflowLabels_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
})
mux.Handle("DELETE", pattern_CronWorkflowService_DeleteCronWorkflowLabel_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_CronWorkflowService_DeleteCronWorkflowLabel_0(rctx, inboundMarshaler, client, req, pathParams)
ctx = runtime.NewServerMetadataContext(ctx, md)
if err != nil {
runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
return
}
forward_CronWorkflowService_DeleteCronWorkflowLabel_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
})
return nil
}
@@ -806,6 +1324,14 @@ var (
pattern_CronWorkflowService_ListCronWorkflows_1 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 1, 0, 4, 1, 5, 2, 2, 3, 1, 0, 4, 1, 5, 4}, []string{"apis", "v1beta1", "namespace", "cron_workflows", "workflow_template_uid"}, "", runtime.AssumeColonVerbOpt(true)))
pattern_CronWorkflowService_TerminateCronWorkflow_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", "cron_workflows", "name", "terminate"}, "", runtime.AssumeColonVerbOpt(true)))
pattern_CronWorkflowService_GetCronWorkflowLabels_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", "cron_workflows", "name", "labels"}, "", runtime.AssumeColonVerbOpt(true)))
pattern_CronWorkflowService_AddCronWorkflowLabels_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", "cron_workflows", "name", "labels"}, "", runtime.AssumeColonVerbOpt(true)))
pattern_CronWorkflowService_ReplaceCronWorkflowLabels_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", "cron_workflows", "name", "labels"}, "", runtime.AssumeColonVerbOpt(true)))
pattern_CronWorkflowService_DeleteCronWorkflowLabel_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, 1, 0, 4, 1, 5, 6}, []string{"apis", "v1beta1", "namespace", "cron_workflows", "name", "labels", "key"}, "", runtime.AssumeColonVerbOpt(true)))
)
var (
@@ -820,4 +1346,12 @@ var (
forward_CronWorkflowService_ListCronWorkflows_1 = runtime.ForwardResponseMessage
forward_CronWorkflowService_TerminateCronWorkflow_0 = runtime.ForwardResponseMessage
forward_CronWorkflowService_GetCronWorkflowLabels_0 = runtime.ForwardResponseMessage
forward_CronWorkflowService_AddCronWorkflowLabels_0 = runtime.ForwardResponseMessage
forward_CronWorkflowService_ReplaceCronWorkflowLabels_0 = runtime.ForwardResponseMessage
forward_CronWorkflowService_DeleteCronWorkflowLabel_0 = runtime.ForwardResponseMessage
)

27
api/cron_workflow.proto
View File

@@ -7,6 +7,7 @@ import "google/protobuf/empty.proto";
import "workflow_template.proto";
import "workflow.proto";
import "metric.proto";
import "label.proto";
service CronWorkflowService {
rpc CreateCronWorkflow (CreateCronWorkflowRequest) returns (CronWorkflow) {
@@ -43,6 +44,32 @@ service CronWorkflowService {
delete: "/apis/v1beta1/{namespace}/cron_workflows/{name}/terminate"
};
}
rpc GetCronWorkflowLabels (GetLabelsRequest) returns (GetLabelsResponse) {
option (google.api.http) = {
get: "/apis/v1beta1/{namespace}/cron_workflows/{name}/labels"
};
}
rpc AddCronWorkflowLabels (AddLabelsRequest) returns (GetLabelsResponse) {
option (google.api.http) = {
post: "/apis/v1beta1/{namespace}/cron_workflows/{name}/labels"
body: "labels"
};
}
rpc ReplaceCronWorkflowLabels (ReplaceLabelsRequest) returns (GetLabelsResponse) {
option (google.api.http) = {
put: "/apis/v1beta1/{namespace}/cron_workflows/{name}/labels"
body: "labels"
};
}
rpc DeleteCronWorkflowLabel (DeleteLabelRequest) returns (GetLabelsResponse) {
option (google.api.http) = {
delete: "/apis/v1beta1/{namespace}/cron_workflows/{name}/labels/{key}"
};
}
}
message TerminateCronWorkflowRequest {

39
api/label.proto Normal file
View File

@@ -0,0 +1,39 @@
syntax = "proto3";
package api;
message KeyValue {
string key = 1;
string value = 2;
}
message Labels {
repeated KeyValue items = 1;
}
message AddLabelsRequest {
string namespace = 1;
string name = 2;
Labels labels = 3;
}
message ReplaceLabelsRequest {
string namespace = 1;
string name = 2;
Labels labels = 3;
}
message GetLabelsRequest {
string namespace = 1;
string name = 2;
}
message GetLabelsResponse {
repeated KeyValue labels = 1;
}
message DeleteLabelRequest {
string namespace = 1;
string name = 2;
string key = 3;
}

4
api/metric.pb.go
View File

@@ -79,7 +79,9 @@ func init() {
proto.RegisterType((*Metric)(nil), "api.Metric")
}
func init() { proto.RegisterFile("metric.proto", fileDescriptor_da41641f55bff5df) }
func init() {
proto.RegisterFile("metric.proto", fileDescriptor_da41641f55bff5df)
}
var fileDescriptor_da41641f55bff5df = []byte{
// 105 bytes of a gzipped FileDescriptorProto

12
api/namespace.pb.go
View File

@@ -117,7 +117,9 @@ func init() {
proto.RegisterType((*Namespace)(nil), "api.Namespace")
}
func init() { proto.RegisterFile("namespace.proto", fileDescriptor_ecb1e126f615f5dd) }
func init() {
proto.RegisterFile("namespace.proto", fileDescriptor_ecb1e126f615f5dd)
}
var fileDescriptor_ecb1e126f615f5dd = []byte{
// 238 bytes of a gzipped FileDescriptorProto
@@ -140,11 +142,11 @@ var fileDescriptor_ecb1e126f615f5dd = []byte{
// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var _ grpc.ClientConn
var _ grpc.ClientConnInterface
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
const _ = grpc.SupportPackageIsVersion4
const _ = grpc.SupportPackageIsVersion6
// NamespaceServiceClient is the client API for NamespaceService service.
//
@@ -154,10 +156,10 @@ type NamespaceServiceClient interface {
}
type namespaceServiceClient struct {
cc *grpc.ClientConn
cc grpc.ClientConnInterface
}
func NewNamespaceServiceClient(cc *grpc.ClientConn) NamespaceServiceClient {
func NewNamespaceServiceClient(cc grpc.ClientConnInterface) NamespaceServiceClient {
return &namespaceServiceClient{cc}
}

12
api/secret.pb.go
View File

@@ -710,7 +710,9 @@ func init() {
proto.RegisterMapType((map[string]string)(nil), "api.Secret.DataEntry")
}
func init() { proto.RegisterFile("secret.proto", fileDescriptor_6acf428160d7a216) }
func init() {
proto.RegisterFile("secret.proto", fileDescriptor_6acf428160d7a216)
}
var fileDescriptor_6acf428160d7a216 = []byte{
// 713 bytes of a gzipped FileDescriptorProto
@@ -763,11 +765,11 @@ var fileDescriptor_6acf428160d7a216 = []byte{
// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var _ grpc.ClientConn
var _ grpc.ClientConnInterface
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
const _ = grpc.SupportPackageIsVersion4
const _ = grpc.SupportPackageIsVersion6
// SecretServiceClient is the client API for SecretService service.
//
@@ -784,10 +786,10 @@ type SecretServiceClient interface {
}
type secretServiceClient struct {
cc *grpc.ClientConn
cc grpc.ClientConnInterface
}
func NewSecretServiceClient(cc *grpc.ClientConn) SecretServiceClient {
func NewSecretServiceClient(cc grpc.ClientConnInterface) SecretServiceClient {
return &secretServiceClient{cc}
}

566
api/workflow.pb.go
View File

@@ -1040,343 +1040,6 @@ func (m *ListFilesResponse) GetParentPath() string {
return ""
}
type KeyValue struct {
Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *KeyValue) Reset() { *m = KeyValue{} }
func (m *KeyValue) String() string { return proto.CompactTextString(m) }
func (*KeyValue) ProtoMessage() {}
func (*KeyValue) Descriptor() ([]byte, []int) {
return fileDescriptor_892c7f566756b0be, []int{18}
}
func (m *KeyValue) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_KeyValue.Unmarshal(m, b)
}
func (m *KeyValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_KeyValue.Marshal(b, m, deterministic)
}
func (m *KeyValue) XXX_Merge(src proto.Message) {
xxx_messageInfo_KeyValue.Merge(m, src)
}
func (m *KeyValue) XXX_Size() int {
return xxx_messageInfo_KeyValue.Size(m)
}
func (m *KeyValue) XXX_DiscardUnknown() {
xxx_messageInfo_KeyValue.DiscardUnknown(m)
}
var xxx_messageInfo_KeyValue proto.InternalMessageInfo
func (m *KeyValue) GetKey() string {
if m != nil {
return m.Key
}
return ""
}
func (m *KeyValue) GetValue() string {
if m != nil {
return m.Value
}
return ""
}
type Labels struct {
Items []*KeyValue `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *Labels) Reset() { *m = Labels{} }
func (m *Labels) String() string { return proto.CompactTextString(m) }
func (*Labels) ProtoMessage() {}
func (*Labels) Descriptor() ([]byte, []int) {
return fileDescriptor_892c7f566756b0be, []int{19}
}
func (m *Labels) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_Labels.Unmarshal(m, b)
}
func (m *Labels) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_Labels.Marshal(b, m, deterministic)
}
func (m *Labels) XXX_Merge(src proto.Message) {
xxx_messageInfo_Labels.Merge(m, src)
}
func (m *Labels) XXX_Size() int {
return xxx_messageInfo_Labels.Size(m)
}
func (m *Labels) XXX_DiscardUnknown() {
xxx_messageInfo_Labels.DiscardUnknown(m)
}
var xxx_messageInfo_Labels proto.InternalMessageInfo
func (m *Labels) GetItems() []*KeyValue {
if m != nil {
return m.Items
}
return nil
}
type AddLabelsRequest struct {
Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Labels *Labels `protobuf:"bytes,3,opt,name=labels,proto3" json:"labels,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *AddLabelsRequest) Reset() { *m = AddLabelsRequest{} }
func (m *AddLabelsRequest) String() string { return proto.CompactTextString(m) }
func (*AddLabelsRequest) ProtoMessage() {}
func (*AddLabelsRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_892c7f566756b0be, []int{20}
}
func (m *AddLabelsRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_AddLabelsRequest.Unmarshal(m, b)
}
func (m *AddLabelsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_AddLabelsRequest.Marshal(b, m, deterministic)
}
func (m *AddLabelsRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_AddLabelsRequest.Merge(m, src)
}
func (m *AddLabelsRequest) XXX_Size() int {
return xxx_messageInfo_AddLabelsRequest.Size(m)
}
func (m *AddLabelsRequest) XXX_DiscardUnknown() {
xxx_messageInfo_AddLabelsRequest.DiscardUnknown(m)
}
var xxx_messageInfo_AddLabelsRequest proto.InternalMessageInfo
func (m *AddLabelsRequest) GetNamespace() string {
if m != nil {
return m.Namespace
}
return ""
}
func (m *AddLabelsRequest) GetName() string {
if m != nil {
return m.Name
}
return ""
}
func (m *AddLabelsRequest) GetLabels() *Labels {
if m != nil {
return m.Labels
}
return nil
}
type ReplaceLabelsRequest struct {
Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Labels *Labels `protobuf:"bytes,3,opt,name=labels,proto3" json:"labels,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ReplaceLabelsRequest) Reset() { *m = ReplaceLabelsRequest{} }
func (m *ReplaceLabelsRequest) String() string { return proto.CompactTextString(m) }
func (*ReplaceLabelsRequest) ProtoMessage() {}
func (*ReplaceLabelsRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_892c7f566756b0be, []int{21}
}
func (m *ReplaceLabelsRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ReplaceLabelsRequest.Unmarshal(m, b)
}
func (m *ReplaceLabelsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ReplaceLabelsRequest.Marshal(b, m, deterministic)
}
func (m *ReplaceLabelsRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_ReplaceLabelsRequest.Merge(m, src)
}
func (m *ReplaceLabelsRequest) XXX_Size() int {
return xxx_messageInfo_ReplaceLabelsRequest.Size(m)
}
func (m *ReplaceLabelsRequest) XXX_DiscardUnknown() {
xxx_messageInfo_ReplaceLabelsRequest.DiscardUnknown(m)
}
var xxx_messageInfo_ReplaceLabelsRequest proto.InternalMessageInfo
func (m *ReplaceLabelsRequest) GetNamespace() string {
if m != nil {
return m.Namespace
}
return ""
}
func (m *ReplaceLabelsRequest) GetName() string {
if m != nil {
return m.Name
}
return ""
}
func (m *ReplaceLabelsRequest) GetLabels() *Labels {
if m != nil {
return m.Labels
}
return nil
}
type GetLabelsRequest struct {
Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *GetLabelsRequest) Reset() { *m = GetLabelsRequest{} }
func (m *GetLabelsRequest) String() string { return proto.CompactTextString(m) }
func (*GetLabelsRequest) ProtoMessage() {}
func (*GetLabelsRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_892c7f566756b0be, []int{22}
}
func (m *GetLabelsRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetLabelsRequest.Unmarshal(m, b)
}
func (m *GetLabelsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetLabelsRequest.Marshal(b, m, deterministic)
}
func (m *GetLabelsRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetLabelsRequest.Merge(m, src)
}
func (m *GetLabelsRequest) XXX_Size() int {
return xxx_messageInfo_GetLabelsRequest.Size(m)
}
func (m *GetLabelsRequest) XXX_DiscardUnknown() {
xxx_messageInfo_GetLabelsRequest.DiscardUnknown(m)
}
var xxx_messageInfo_GetLabelsRequest proto.InternalMessageInfo
func (m *GetLabelsRequest) GetNamespace() string {
if m != nil {
return m.Namespace
}
return ""
}
func (m *GetLabelsRequest) GetName() string {
if m != nil {
return m.Name
}
return ""
}
type GetLabelsResponse struct {
Labels []*KeyValue `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *GetLabelsResponse) Reset() { *m = GetLabelsResponse{} }
func (m *GetLabelsResponse) String() string { return proto.CompactTextString(m) }
func (*GetLabelsResponse) ProtoMessage() {}
func (*GetLabelsResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_892c7f566756b0be, []int{23}
}
func (m *GetLabelsResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetLabelsResponse.Unmarshal(m, b)
}
func (m *GetLabelsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetLabelsResponse.Marshal(b, m, deterministic)
}
func (m *GetLabelsResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetLabelsResponse.Merge(m, src)
}
func (m *GetLabelsResponse) XXX_Size() int {
return xxx_messageInfo_GetLabelsResponse.Size(m)
}
func (m *GetLabelsResponse) XXX_DiscardUnknown() {
xxx_messageInfo_GetLabelsResponse.DiscardUnknown(m)
}
var xxx_messageInfo_GetLabelsResponse proto.InternalMessageInfo
func (m *GetLabelsResponse) GetLabels() []*KeyValue {
if m != nil {
return m.Labels
}
return nil
}
type DeleteLabelRequest struct {
Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *DeleteLabelRequest) Reset() { *m = DeleteLabelRequest{} }
func (m *DeleteLabelRequest) String() string { return proto.CompactTextString(m) }
func (*DeleteLabelRequest) ProtoMessage() {}
func (*DeleteLabelRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_892c7f566756b0be, []int{24}
}
func (m *DeleteLabelRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_DeleteLabelRequest.Unmarshal(m, b)
}
func (m *DeleteLabelRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_DeleteLabelRequest.Marshal(b, m, deterministic)
}
func (m *DeleteLabelRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_DeleteLabelRequest.Merge(m, src)
}
func (m *DeleteLabelRequest) XXX_Size() int {
return xxx_messageInfo_DeleteLabelRequest.Size(m)
}
func (m *DeleteLabelRequest) XXX_DiscardUnknown() {
xxx_messageInfo_DeleteLabelRequest.DiscardUnknown(m)
}
var xxx_messageInfo_DeleteLabelRequest proto.InternalMessageInfo
func (m *DeleteLabelRequest) GetNamespace() string {
if m != nil {
return m.Namespace
}
return ""
}
func (m *DeleteLabelRequest) GetName() string {
if m != nil {
return m.Name
}
return ""
}
func (m *DeleteLabelRequest) GetKey() string {
if m != nil {
return m.Key
}
return ""
}
func init() {
proto.RegisterType((*CreateWorkflowExecutionRequest)(nil), "api.CreateWorkflowExecutionRequest")
proto.RegisterType((*GetWorkflowExecutionRequest)(nil), "api.GetWorkflowExecutionRequest")
@@ -1396,135 +1059,124 @@ func init() {
proto.RegisterType((*File)(nil), "api.File")
proto.RegisterType((*ListFilesRequest)(nil), "api.ListFilesRequest")
proto.RegisterType((*ListFilesResponse)(nil), "api.ListFilesResponse")
proto.RegisterType((*KeyValue)(nil), "api.KeyValue")
proto.RegisterType((*Labels)(nil), "api.Labels")
proto.RegisterType((*AddLabelsRequest)(nil), "api.AddLabelsRequest")
proto.RegisterType((*ReplaceLabelsRequest)(nil), "api.ReplaceLabelsRequest")
proto.RegisterType((*GetLabelsRequest)(nil), "api.GetLabelsRequest")
proto.RegisterType((*GetLabelsResponse)(nil), "api.GetLabelsResponse")
proto.RegisterType((*DeleteLabelRequest)(nil), "api.DeleteLabelRequest")
}
func init() { proto.RegisterFile("workflow.proto", fileDescriptor_892c7f566756b0be) }
func init() {
proto.RegisterFile("workflow.proto", fileDescriptor_892c7f566756b0be)
}
var fileDescriptor_892c7f566756b0be = []byte{
// 1711 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xbc, 0x58, 0x4b, 0x6f, 0x1b, 0x47,
0x12, 0x46, 0x8b, 0x92, 0x2c, 0x95, 0xec, 0x5d, 0xa9, 0x6d, 0x49, 0xd4, 0x58, 0x2f, 0xb7, 0x6c,
0xaf, 0x2c, 0xac, 0x39, 0xb6, 0xd6, 0xbb, 0x58, 0x68, 0xed, 0xb5, 0x65, 0xbd, 0xd6, 0x6b, 0x39,
0x76, 0x68, 0xf9, 0x81, 0x5c, 0x92, 0x16, 0xd9, 0x94, 0x06, 0x22, 0x39, 0x93, 0x99, 0xa6, 0x64,
0x45, 0xe0, 0x21, 0x8f, 0x43, 0x4e, 0x41, 0x00, 0x07, 0x81, 0xe1, 0x00, 0x41, 0x02, 0xe4, 0x90,
0x9f, 0x90, 0x53, 0x0e, 0x41, 0x02, 0x04, 0xc8, 0xd1, 0xa7, 0x9c, 0x72, 0x49, 0xfe, 0x47, 0xd0,
0xaf, 0xd1, 0x90, 0x9c, 0xa1, 0x44, 0x4a, 0xc9, 0x89, 0xd3, 0x55, 0xdd, 0x55, 0x5f, 0x3d, 0xba,
0xba, 0x8a, 0xf0, 0x97, 0x1d, 0xd7, 0xdf, 0x2a, 0x14, 0xdd, 0x9d, 0x8c, 0xe7, 0xbb, 0xdc, 0xc5,
0x29, 0xea, 0x39, 0xd6, 0xe8, 0x86, 0xeb, 0x6e, 0x14, 0x99, 0x4d, 0x3d, 0xc7, 0xa6, 0xe5, 0xb2,
0xcb, 0x29, 0x77, 0xdc, 0x72, 0xa0, 0xb6, 0x58, 0x67, 0x35, 0x57, 0xae, 0xd6, 0x2b, 0x05, 0x9b,
0x95, 0x3c, 0xbe, 0xab, 0x99, 0xc3, 0x46, 0xde, 0x9b, 0x9c, 0x95, 0xbc, 0x22, 0xe5, 0x4c, 0x33,
0x4e, 0x96, 0x18, 0xf7, 0x9d, 0x9c, 0x5a, 0x91, 0x0f, 0x10, 0x8c, 0x2f, 0xf8, 0x8c, 0x72, 0xf6,
0x44, 0xef, 0x5f, 0x7a, 0xc6, 0x72, 0x15, 0xa1, 0x26, 0xcb, 0xde, 0xae, 0xb0, 0x80, 0xe3, 0x51,
0xe8, 0x2d, 0xd3, 0x12, 0x0b, 0x3c, 0x9a, 0x63, 0x69, 0x34, 0x89, 0xa6, 0x7b, 0xb3, 0xfb, 0x04,
0xbc, 0x08, 0x03, 0x3b, 0xf5, 0x27, 0xd3, 0x1d, 0x93, 0x68, 0xba, 0x6f, 0x76, 0x28, 0x43, 0x3d,
0x27, 0xd3, 0x28, 0xb7, 0xf1, 0x00, 0xb9, 0x0f, 0x67, 0x57, 0x18, 0x6f, 0x13, 0x02, 0x86, 0x4e,
0xb1, 0x90, 0x5a, 0x7b, 0xb3, 0xf2, 0x9b, 0x3c, 0x05, 0xbc, 0xc2, 0xf8, 0xbc, 0xcf, 0x9d, 0x02,
0xcd, 0xf1, 0xb6, 0xe5, 0xe0, 0x7e, 0x48, 0x6d, 0xb1, 0xdd, 0x74, 0x4a, 0x92, 0xc4, 0x27, 0x79,
0x1d, 0xc6, 0x9e, 0x50, 0x9e, 0xdb, 0x3c, 0x46, 0xb0, 0x6b, 0x30, 0x99, 0x65, 0x41, 0x65, 0xbd,
0xe4, 0x1c, 0xa7, 0x0b, 0x1e, 0xc1, 0xb9, 0x35, 0xe6, 0x97, 0x9c, 0x72, 0xfb, 0xc1, 0x8d, 0x13,
0xfb, 0x1c, 0xc1, 0x44, 0x5c, 0xac, 0x56, 0xdd, 0x8d, 0xa0, 0x7d, 0x3f, 0xa7, 0xe1, 0x84, 0xe7,
0xe6, 0x5f, 0x13, 0x64, 0xe5, 0x6b, 0xb3, 0xc4, 0xe7, 0xe1, 0x54, 0xce, 0x2d, 0x73, 0xea, 0x94,
0x99, 0x2f, 0xf9, 0x9d, 0x92, 0x5f, 0x4b, 0x24, 0x1e, 0x90, 0x38, 0x50, 0xf7, 0x64, 0xae, 0xff,
0x11, 0xb8, 0xc8, 0x2a, 0x4c, 0x35, 0xd5, 0x18, 0x78, 0x6e, 0x39, 0x60, 0xf8, 0x02, 0x9c, 0x50,
0x17, 0x2e, 0x48, 0xa3, 0xc9, 0xd4, 0x74, 0xdf, 0x6c, 0x9f, 0xbc, 0x15, 0x6a, 0x5b, 0xd6, 0xf0,
0xc8, 0xcf, 0x08, 0xc6, 0x56, 0x9d, 0xa0, 0x51, 0xde, 0x21, 0xb1, 0x5f, 0x81, 0xd3, 0xe6, 0x56,
0xad, 0xe9, 0xfb, 0xfe, 0xc8, 0xc9, 0x6b, 0x53, 0xe2, 0x58, 0xf8, 0xdf, 0x30, 0x5c, 0x4f, 0x7e,
0xcc, 0xfc, 0x40, 0x5c, 0x5f, 0x65, 0x69, 0x12, 0x1b, 0x5b, 0xd0, 0xe3, 0xd1, 0x0d, 0xf6, 0xd0,
0x79, 0x47, 0x05, 0xa3, 0x2b, 0x1b, 0xae, 0x85, 0x0f, 0xc5, 0x77, 0xba, 0x4b, 0xd2, 0xe5, 0x37,
0xf9, 0x11, 0xc1, 0x78, 0x92, 0x6d, 0xda, 0x4b, 0x67, 0xa0, 0x2b, 0xe7, 0x56, 0xca, 0x5c, 0x1a,
0xd6, 0x95, 0x55, 0x0b, 0xbc, 0x0c, 0xb8, 0xa1, 0x54, 0x04, 0xe9, 0x0e, 0xe9, 0xc6, 0xa4, 0xe2,
0x12, 0x73, 0x22, 0x04, 0x95, 0xda, 0x07, 0x25, 0x34, 0x8a, 0xdf, 0x40, 0x5b, 0xa0, 0x16, 0x78,
0x1c, 0x80, 0xbb, 0x9c, 0x16, 0x17, 0x24, 0x18, 0x65, 0x44, 0x84, 0x42, 0x6e, 0x43, 0xcf, 0xaa,
0xbb, 0xb1, 0x54, 0xe6, 0xfe, 0xae, 0x08, 0x08, 0x77, 0x4a, 0x2c, 0xe0, 0xb4, 0xe4, 0x99, 0x80,
0x84, 0x04, 0x91, 0x38, 0x22, 0x43, 0x59, 0x99, 0xeb, 0x20, 0x98, 0x25, 0xf9, 0xa9, 0x03, 0x06,
0x1a, 0x70, 0x0b, 0x69, 0x39, 0x59, 0x87, 0xf3, 0xf3, 0xdc, 0x48, 0x0b, 0x09, 0xa2, 0x0c, 0x55,
0xc2, 0x70, 0x8a, 0xcf, 0x30, 0x59, 0x53, 0x91, 0x64, 0x15, 0x36, 0x6d, 0xd2, 0xc0, 0x5c, 0x11,
0xb5, 0x10, 0x92, 0x03, 0x4e, 0x7d, 0x25, 0xb9, 0x4b, 0x49, 0x0e, 0x09, 0xc2, 0xe2, 0x82, 0x53,
0x76, 0x82, 0x4d, 0xc9, 0xee, 0x96, 0xec, 0x08, 0x45, 0x04, 0xbb, 0x44, 0xcb, 0x4e, 0x81, 0x05,
0x3c, 0x7d, 0x42, 0x72, 0xc3, 0x35, 0xbe, 0x09, 0xe0, 0x51, 0x9f, 0x96, 0x18, 0x67, 0x7e, 0x90,
0xee, 0x91, 0x71, 0x99, 0x88, 0x8f, 0xcb, 0x03, 0xb3, 0x2f, 0x1b, 0x39, 0x82, 0xe7, 0xa1, 0xbf,
0x3e, 0xc9, 0xd2, 0xbd, 0xf2, 0xed, 0x18, 0xac, 0x11, 0x63, 0x98, 0xd9, 0x86, 0xed, 0x64, 0x19,
0xac, 0x64, 0x65, 0xa1, 0x97, 0x50, 0xad, 0x97, 0xb6, 0x69, 0xb1, 0x62, 0xee, 0xb9, 0x5a, 0x90,
0x8b, 0xd0, 0xbf, 0xff, 0x5a, 0xe8, 0xac, 0xc4, 0xd0, 0x99, 0xa7, 0x9c, 0xca, 0xd3, 0x27, 0xb3,
0xf2, 0x9b, 0x7c, 0x8f, 0xa0, 0x73, 0xd9, 0x29, 0xea, 0x4c, 0xe7, 0x9b, 0x46, 0xb4, 0xf8, 0x8e,
0xad, 0x20, 0xa3, 0xd0, 0xcb, 0x9e, 0x71, 0x56, 0x8e, 0xdc, 0xac, 0x7d, 0x82, 0x38, 0x11, 0x98,
0x7b, 0x94, 0xca, 0xca, 0x6f, 0x3c, 0x09, 0x7d, 0x3a, 0x57, 0xd6, 0x76, 0x3d, 0xa6, 0x43, 0x16,
0x25, 0x61, 0x02, 0x27, 0x8b, 0x34, 0xe0, 0xf7, 0xdc, 0xbc, 0x53, 0x70, 0x58, 0x5e, 0x87, 0xad,
0x86, 0x26, 0xf4, 0xe6, 0x1d, 0x9f, 0xe5, 0xb8, 0xeb, 0xef, 0xca, 0xc8, 0xf5, 0x64, 0xf7, 0x09,
0xe4, 0x29, 0xf4, 0x8b, 0x2b, 0x29, 0x2c, 0x39, 0x42, 0x75, 0x34, 0x3e, 0x48, 0xed, 0xfb, 0x80,
0xac, 0xc1, 0x40, 0x44, 0xb2, 0xf6, 0xe4, 0x04, 0x74, 0x15, 0x04, 0x41, 0xd7, 0xc0, 0x5e, 0x19,
0x5d, 0xb1, 0x25, 0xab, 0xe8, 0x22, 0x0d, 0x3d, 0xea, 0xb3, 0x32, 0x7f, 0x20, 0xe4, 0x29, 0x1d,
0x11, 0x0a, 0x99, 0x85, 0x9e, 0xbb, 0x6c, 0xf7, 0xb1, 0x08, 0x95, 0x79, 0x93, 0x51, 0xf8, 0x26,
0x27, 0x84, 0xf4, 0x32, 0x74, 0xaf, 0xd2, 0x75, 0x56, 0x0c, 0xf0, 0x14, 0x74, 0x39, 0x9c, 0x95,
0x8c, 0xfa, 0x53, 0x52, 0xbd, 0x91, 0x97, 0x55, 0x3c, 0xe2, 0x40, 0xff, 0x7c, 0x3e, 0xaf, 0x4e,
0xb4, 0xef, 0x92, 0x29, 0xe8, 0x2e, 0x4a, 0x11, 0xd2, 0x29, 0xa6, 0xdc, 0x6b, 0xa9, 0x9a, 0x45,
0x4a, 0x70, 0x26, 0xcb, 0xbc, 0x22, 0xcd, 0xb1, 0x3f, 0x45, 0xdd, 0x22, 0xf4, 0xaf, 0x30, 0x7e,
0x44, 0x55, 0x64, 0x0e, 0x06, 0x22, 0x52, 0xc2, 0xe7, 0xcd, 0xe8, 0x8f, 0x75, 0xad, 0x41, 0xf0,
0x14, 0xf0, 0x22, 0x2b, 0x32, 0xae, 0xec, 0x3d, 0xc6, 0x76, 0x6c, 0xf6, 0x97, 0x49, 0xf8, 0xab,
0x29, 0x00, 0x0f, 0x99, 0xbf, 0xed, 0xe4, 0x18, 0xfe, 0x02, 0xc1, 0x70, 0x42, 0x53, 0x8b, 0xa7,
0x24, 0xc0, 0xe6, 0x2d, 0xaf, 0x95, 0xf0, 0xb8, 0x90, 0xff, 0xbd, 0xf7, 0xea, 0xd7, 0xe7, 0x1d,
0xb7, 0xc9, 0x65, 0xd1, 0x91, 0x07, 0xf6, 0xf6, 0xd5, 0x75, 0xc6, 0xe9, 0x55, 0x7b, 0x2f, 0x04,
0x5d, 0xb5, 0xc3, 0xb6, 0x9b, 0x85, 0xef, 0xcf, 0x5c, 0x63, 0xc3, 0x8b, 0x3f, 0x42, 0x70, 0x26,
0xae, 0x7d, 0xc0, 0x93, 0x52, 0x75, 0x93, 0x66, 0x38, 0x11, 0xdc, 0x75, 0x09, 0xee, 0x5f, 0xf8,
0x5a, 0x4b, 0xe0, 0x14, 0xbf, 0x8a, 0x5f, 0x20, 0x18, 0x8a, 0x7f, 0xa4, 0x31, 0x51, 0x39, 0xd5,
0xac, 0x3b, 0xb1, 0xa6, 0x9a, 0xee, 0x51, 0xc9, 0x42, 0xfe, 0x29, 0x11, 0xda, 0xb8, 0x35, 0xf7,
0xe1, 0x97, 0x08, 0x86, 0xe2, 0x5b, 0x6e, 0x0d, 0xad, 0x69, 0x3f, 0x9e, 0xe8, 0xaf, 0xdb, 0x12,
0xcd, 0x75, 0x3c, 0xd7, 0x8e, 0xbf, 0xec, 0x1d, 0xa1, 0xf3, 0x0a, 0xc2, 0xdf, 0x22, 0x48, 0x27,
0xb5, 0xc3, 0xf8, 0x7c, 0x62, 0x30, 0x23, 0xdd, 0xb2, 0xa5, 0xee, 0x8c, 0xe9, 0x2b, 0xc8, 0x96,
0xc4, 0xc5, 0x70, 0xae, 0x2d, 0x5c, 0x9e, 0x9b, 0x0f, 0xec, 0x3d, 0xdd, 0xa4, 0x56, 0xed, 0xb0,
0x4b, 0x0e, 0xec, 0xbd, 0x9a, 0x8e, 0xb9, 0x6a, 0x17, 0xdd, 0x8d, 0xe0, 0x0a, 0xc2, 0x3f, 0xa0,
0xf8, 0xd9, 0x4b, 0x37, 0xb2, 0xf8, 0x6f, 0x89, 0x36, 0xd4, 0x36, 0xd7, 0xd6, 0xf4, 0xc1, 0x1b,
0x75, 0x1e, 0x3c, 0x94, 0x16, 0xde, 0xc3, 0x77, 0x8f, 0xc3, 0x42, 0xdd, 0x41, 0xe3, 0x2f, 0x11,
0x8c, 0x24, 0x4e, 0x51, 0xf8, 0x82, 0x04, 0x77, 0xd0, 0x94, 0x95, 0x98, 0x2b, 0x4b, 0x12, 0xf1,
0x4d, 0xeb, 0x46, 0x5b, 0x88, 0x7d, 0xad, 0x16, 0x7f, 0x85, 0xc0, 0x4a, 0x9e, 0xc9, 0xf0, 0x45,
0xa9, 0xfd, 0xc0, 0xa1, 0xcd, 0x1a, 0xca, 0xa8, 0xc9, 0x3f, 0x63, 0x26, 0xff, 0xcc, 0x92, 0x98,
0xfc, 0xc9, 0xb2, 0x44, 0x79, 0xcb, 0xfa, 0x6f, 0x5b, 0x28, 0xb9, 0xd1, 0x8b, 0x3f, 0x43, 0x30,
0x54, 0x5b, 0x21, 0x4d, 0xbb, 0xa5, 0x2f, 0x5c, 0x3c, 0xd3, 0xc0, 0x8b, 0xef, 0xdd, 0x0c, 0x3a,
0xf2, 0xf7, 0x43, 0xa0, 0x33, 0xff, 0x59, 0x04, 0x73, 0x0d, 0x1d, 0x1f, 0xfe, 0x0d, 0xc1, 0xd8,
0x23, 0x2f, 0x1f, 0x03, 0xc0, 0x0c, 0x28, 0x97, 0x24, 0x80, 0xa6, 0x7b, 0x0e, 0xc0, 0xfa, 0x2e,
0x92, 0x60, 0xf7, 0xac, 0x8d, 0x56, 0xc0, 0xda, 0x7b, 0xf5, 0x60, 0x33, 0x15, 0x27, 0x5f, 0xb5,
0xb7, 0x95, 0xce, 0x38, 0xbe, 0x66, 0x55, 0x63, 0xec, 0xfc, 0x0e, 0xc1, 0x58, 0xbc, 0xa3, 0x8d,
0x9d, 0x47, 0x08, 0x46, 0x41, 0xda, 0xf7, 0x16, 0x59, 0x3d, 0x4e, 0xfb, 0x62, 0x8c, 0x78, 0x85,
0xe0, 0x74, 0xa4, 0x24, 0x84, 0xf4, 0x89, 0xfa, 0x62, 0x71, 0x48, 0xdc, 0xef, 0xab, 0xc0, 0x54,
0xf1, 0x6c, 0x6b, 0xc0, 0x05, 0xce, 0x37, 0x56, 0xf0, 0x52, 0xeb, 0xa7, 0x22, 0xd1, 0x33, 0xc1,
0xc2, 0xdf, 0x20, 0x18, 0x8d, 0xbe, 0x75, 0x75, 0x81, 0x09, 0xf0, 0x74, 0xc3, 0x73, 0x58, 0xbf,
0xc5, 0xd8, 0x79, 0xe9, 0x10, 0x3b, 0x75, 0xd9, 0x5c, 0x90, 0xa6, 0xdf, 0xc0, 0xff, 0x39, 0x82,
0x11, 0xf8, 0x13, 0x04, 0x83, 0x71, 0xda, 0x02, 0x7c, 0x2e, 0x11, 0x49, 0x08, 0x96, 0x34, 0xdb,
0xa2, 0x51, 0x5e, 0x93, 0x28, 0x33, 0xb8, 0xa5, 0x6b, 0x8e, 0xbf, 0x46, 0x30, 0x3c, 0xef, 0xe7,
0x36, 0x9d, 0xed, 0xc6, 0x9a, 0xa3, 0x7a, 0x8b, 0x04, 0xae, 0x81, 0x76, 0xbe, 0xf9, 0x26, 0x0d,
0x4e, 0xbf, 0xf9, 0xd6, 0x5c, 0x1b, 0x2e, 0xa4, 0x4a, 0xb6, 0x68, 0xdd, 0xfa, 0x22, 0xff, 0x2d,
0xe2, 0x61, 0x93, 0xca, 0x75, 0xff, 0x36, 0xea, 0x14, 0xae, 0x9f, 0x2a, 0xc9, 0x7d, 0x89, 0xe1,
0x0e, 0x5e, 0x69, 0xab, 0x4a, 0x53, 0x2d, 0x2e, 0xb0, 0xf7, 0xb6, 0xd8, 0xee, 0x8d, 0x99, 0x99,
0x2a, 0xfe, 0x10, 0x41, 0x6f, 0x38, 0x72, 0xe1, 0xc1, 0x30, 0x46, 0xd1, 0xe1, 0x4e, 0xbf, 0x6c,
0x0d, 0x93, 0x19, 0x59, 0x95, 0x68, 0x96, 0xf1, 0x62, 0x5b, 0x68, 0xe4, 0xf0, 0x66, 0xef, 0x89,
0xc1, 0x4f, 0x42, 0xf9, 0x18, 0x81, 0x15, 0xdb, 0xee, 0xa8, 0x39, 0x6c, 0xd0, 0xb8, 0xaa, 0x66,
0x16, 0xd1, 0xd8, 0x1a, 0x86, 0x8b, 0x96, 0x12, 0xbe, 0x11, 0x9b, 0x1a, 0x3d, 0x44, 0x63, 0x6b,
0xcd, 0xe7, 0xf3, 0xcd, 0x21, 0xd5, 0x0f, 0x7e, 0x89, 0x90, 0xee, 0x4a, 0x48, 0x4b, 0xe4, 0x28,
0x90, 0xe6, 0xf4, 0x54, 0x24, 0xe6, 0x94, 0x71, 0x3d, 0x07, 0x26, 0xc1, 0x1b, 0xd1, 0x7d, 0x4b,
0xe3, 0xb0, 0x78, 0x10, 0x44, 0xeb, 0x58, 0x20, 0xbe, 0x44, 0x30, 0xaa, 0x26, 0xb7, 0x78, 0x84,
0x3a, 0xfb, 0x1b, 0x87, 0xbb, 0x44, 0x78, 0x77, 0x24, 0xbc, 0x85, 0x99, 0xf9, 0x23, 0xc0, 0x93,
0xb9, 0x5f, 0x15, 0x37, 0x71, 0x24, 0xe6, 0x09, 0x69, 0x2f, 0xd9, 0x5a, 0x19, 0x07, 0x22, 0xa5,
0xa1, 0x26, 0xd7, 0x3e, 0x45, 0x30, 0x12, 0xc9, 0xb5, 0x58, 0x40, 0x87, 0x4e, 0xb5, 0xff, 0x4b,
0x40, 0x8b, 0xe4, 0x08, 0x80, 0xc2, 0x30, 0x7e, 0x8e, 0x60, 0xac, 0x2e, 0xd3, 0xea, 0xc0, 0xb5,
0x91, 0x68, 0x1a, 0xa0, 0x75, 0x1c, 0x00, 0x5f, 0x20, 0x38, 0x5b, 0x9b, 0x67, 0x35, 0xf8, 0x5a,
0x4f, 0x33, 0x3d, 0xaa, 0xcf, 0xdc, 0x6a, 0x1f, 0x9c, 0xca, 0xb2, 0xf5, 0x6e, 0xd9, 0x65, 0xff,
0xe3, 0xf7, 0x00, 0x00, 0x00, 0xff, 0xff, 0x63, 0x83, 0x4e, 0x73, 0xa2, 0x1b, 0x00, 0x00,
// 1610 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xb4, 0x98, 0xcd, 0x6f, 0x1b, 0x45,
0x14, 0xc0, 0x35, 0x71, 0xd2, 0x26, 0x2f, 0x2d, 0xa4, 0xd3, 0x36, 0x71, 0xb6, 0xf9, 0xea, 0xf4,
0x83, 0x34, 0x02, 0x6f, 0x1b, 0x0a, 0x42, 0xa1, 0xa5, 0x4d, 0xf3, 0x45, 0x69, 0x4a, 0x8b, 0x9b,
0xd2, 0x8a, 0x0b, 0x4c, 0xec, 0x71, 0xb2, 0x8a, 0xbd, 0xbb, 0xec, 0x8e, 0x93, 0x06, 0xcb, 0x07,
0x3e, 0x0e, 0x9c, 0x10, 0x52, 0x11, 0xaa, 0x8a, 0x84, 0x8a, 0xc4, 0x81, 0x3f, 0x81, 0x13, 0x07,
0x04, 0x12, 0x12, 0xc7, 0x9e, 0x38, 0x71, 0x81, 0xff, 0x03, 0xcd, 0xec, 0xcc, 0x66, 0x6d, 0xef,
0x3a, 0xf1, 0x26, 0x9c, 0xbc, 0xf3, 0x66, 0x76, 0xde, 0xef, 0x7d, 0xcc, 0x9b, 0xb7, 0x86, 0x17,
0xb6, 0x1c, 0x6f, 0xa3, 0x54, 0x76, 0xb6, 0x72, 0xae, 0xe7, 0x70, 0x07, 0x67, 0xa8, 0x6b, 0x19,
0x23, 0x6b, 0x8e, 0xb3, 0x56, 0x66, 0x26, 0x75, 0x2d, 0x93, 0xda, 0xb6, 0xc3, 0x29, 0xb7, 0x1c,
0xdb, 0x0f, 0x96, 0x18, 0xa7, 0xd4, 0xac, 0x1c, 0xad, 0x56, 0x4b, 0x26, 0xab, 0xb8, 0x7c, 0x5b,
0x4d, 0x0e, 0xe9, 0xfd, 0x3e, 0xe4, 0xac, 0xe2, 0x96, 0x29, 0x67, 0x6a, 0xe2, 0x48, 0x85, 0x71,
0xcf, 0x2a, 0xa8, 0x51, 0x7f, 0x99, 0xae, 0xb2, 0x72, 0x30, 0x20, 0x5f, 0x20, 0x18, 0x9b, 0xf3,
0x18, 0xe5, 0xec, 0x81, 0x7a, 0x79, 0xe1, 0x11, 0x2b, 0x54, 0x85, 0xce, 0x3c, 0xfb, 0xb8, 0xca,
0x7c, 0x8e, 0x47, 0xa0, 0xcf, 0xa6, 0x15, 0xe6, 0xbb, 0xb4, 0xc0, 0xb2, 0x68, 0x02, 0x4d, 0xf6,
0xe5, 0x77, 0x04, 0x78, 0x1e, 0x8e, 0x6d, 0x35, 0xbf, 0x99, 0xed, 0x9a, 0x40, 0x93, 0xfd, 0xd3,
0x83, 0x39, 0xea, 0x5a, 0xb9, 0xd6, 0x7d, 0x5b, 0x5f, 0x20, 0x77, 0xe0, 0xd4, 0x12, 0xe3, 0x29,
0x11, 0x30, 0x74, 0x8b, 0x81, 0xd4, 0xda, 0x97, 0x97, 0xcf, 0xe4, 0x21, 0xe0, 0x25, 0xc6, 0x67,
0x3d, 0x6e, 0x95, 0x68, 0x81, 0xa7, 0xde, 0x07, 0x0f, 0x40, 0x66, 0x83, 0x6d, 0x67, 0x33, 0x52,
0x24, 0x1e, 0xc9, 0x7b, 0x30, 0xfa, 0x80, 0xf2, 0xc2, 0xfa, 0x01, 0xc2, 0xae, 0xc0, 0x44, 0x9e,
0xf9, 0xd5, 0xd5, 0x8a, 0x75, 0x90, 0x2e, 0xb8, 0x0f, 0xa7, 0x57, 0x98, 0x57, 0xb1, 0xec, 0xf4,
0xc1, 0x8d, 0xdb, 0xf6, 0x31, 0x82, 0xf1, 0xb8, 0x58, 0x2d, 0x3b, 0x6b, 0x7e, 0x7a, 0x3f, 0x67,
0xe1, 0xb0, 0xeb, 0x14, 0xdf, 0x15, 0xe2, 0xc0, 0xd7, 0x7a, 0x88, 0xcf, 0xc2, 0xd1, 0x82, 0x63,
0x73, 0x6a, 0xd9, 0xcc, 0x93, 0xf3, 0xdd, 0x72, 0xbe, 0x51, 0x48, 0x5c, 0x20, 0x71, 0x50, 0xb7,
0x65, 0xe2, 0xff, 0x1f, 0x5c, 0x64, 0x19, 0xce, 0xb4, 0xd5, 0xe8, 0xbb, 0x8e, 0xed, 0x33, 0x7c,
0x0e, 0x0e, 0x07, 0xa7, 0xcf, 0xcf, 0xa2, 0x89, 0xcc, 0x64, 0xff, 0x74, 0xbf, 0x3c, 0x15, 0xc1,
0xb2, 0xbc, 0x9e, 0x23, 0x7f, 0x21, 0x18, 0x5d, 0xb6, 0xfc, 0xd6, 0xfd, 0xf6, 0xc8, 0x7e, 0x11,
0x8e, 0xeb, 0x53, 0xb5, 0xa2, 0x0e, 0xff, 0x7d, 0xab, 0xa8, 0x4c, 0x89, 0x9b, 0xc2, 0x6f, 0xc0,
0x50, 0xb3, 0xf8, 0x7d, 0xe6, 0xf9, 0xe2, 0xf8, 0x06, 0x96, 0x26, 0x4d, 0x63, 0x03, 0x7a, 0x5d,
0xba, 0xc6, 0xee, 0x59, 0x9f, 0x04, 0xc1, 0xe8, 0xc9, 0x87, 0x63, 0xe1, 0x43, 0xf1, 0x9c, 0xed,
0x91, 0x72, 0xf9, 0x4c, 0xfe, 0x40, 0x30, 0x96, 0x64, 0x9b, 0xf2, 0xd2, 0x09, 0xe8, 0x29, 0x38,
0x55, 0x9b, 0x4b, 0xc3, 0x7a, 0xf2, 0xc1, 0x00, 0x2f, 0x02, 0x6e, 0x29, 0x15, 0x7e, 0xb6, 0x4b,
0xba, 0x31, 0xa9, 0xb8, 0xc4, 0xbc, 0x11, 0x42, 0x65, 0x76, 0xa0, 0x84, 0x46, 0xf1, 0xeb, 0x2b,
0x0b, 0x82, 0x01, 0x1e, 0x03, 0xe0, 0x0e, 0xa7, 0xe5, 0x39, 0x09, 0x13, 0x18, 0x11, 0x91, 0x90,
0x1b, 0xd0, 0xbb, 0xec, 0xac, 0x2d, 0xd8, 0xdc, 0xdb, 0x16, 0x01, 0xe1, 0x56, 0x85, 0xf9, 0x9c,
0x56, 0x5c, 0x1d, 0x90, 0x50, 0x20, 0x12, 0x47, 0x64, 0x28, 0xb3, 0xb9, 0x0a, 0x82, 0x1e, 0x92,
0x3f, 0xbb, 0xe0, 0x58, 0x0b, 0xb7, 0xd8, 0xad, 0x20, 0xeb, 0x70, 0x71, 0x96, 0xeb, 0xdd, 0x42,
0x81, 0x28, 0x43, 0xd5, 0x30, 0x9c, 0xe2, 0x31, 0x4c, 0xd6, 0x4c, 0x24, 0x59, 0x85, 0x4d, 0xeb,
0xd4, 0xd7, 0x47, 0x24, 0x18, 0x88, 0x9d, 0x7d, 0x4e, 0xbd, 0x60, 0xe7, 0x9e, 0x60, 0xe7, 0x50,
0x20, 0x2c, 0x2e, 0x59, 0xb6, 0xe5, 0xaf, 0xcb, 0xe9, 0x43, 0x72, 0x3a, 0x22, 0x11, 0xc1, 0xae,
0x50, 0xdb, 0x2a, 0x31, 0x9f, 0x67, 0x0f, 0xcb, 0xd9, 0x70, 0x8c, 0xaf, 0x01, 0xb8, 0xd4, 0xa3,
0x15, 0xc6, 0x99, 0xe7, 0x67, 0x7b, 0x65, 0x5c, 0xc6, 0xe3, 0xe3, 0x72, 0x57, 0xaf, 0xcb, 0x47,
0x5e, 0xc1, 0xb3, 0x30, 0xd0, 0x9c, 0x64, 0xd9, 0x3e, 0x79, 0x77, 0x9c, 0x6c, 0xd8, 0x46, 0x4f,
0xe6, 0x5b, 0x96, 0x93, 0x45, 0x30, 0x92, 0x95, 0x85, 0x5e, 0x42, 0x8d, 0x5e, 0xda, 0xa4, 0xe5,
0xaa, 0x3e, 0xe7, 0xc1, 0x80, 0x9c, 0x87, 0x81, 0x9d, 0xdb, 0x42, 0x65, 0x25, 0x86, 0xee, 0x22,
0xe5, 0x54, 0xbe, 0x7d, 0x24, 0x2f, 0x9f, 0xc9, 0x6f, 0x08, 0xba, 0x17, 0xad, 0xb2, 0xca, 0x74,
0xbe, 0xae, 0xb7, 0x16, 0xcf, 0xb1, 0x15, 0x64, 0x04, 0xfa, 0xd8, 0x23, 0xce, 0xec, 0xc8, 0xc9,
0xda, 0x11, 0x88, 0x37, 0x7c, 0x7d, 0x8e, 0x32, 0x79, 0xf9, 0x8c, 0x27, 0xa0, 0x5f, 0xe5, 0xca,
0xca, 0xb6, 0xcb, 0x54, 0xc8, 0xa2, 0x22, 0x4c, 0xe0, 0x48, 0x99, 0xfa, 0xfc, 0xb6, 0x53, 0xb4,
0x4a, 0x16, 0x2b, 0xaa, 0xb0, 0x35, 0xc8, 0x84, 0xde, 0xa2, 0xe5, 0xb1, 0x02, 0x77, 0xbc, 0x6d,
0x19, 0xb9, 0xde, 0xfc, 0x8e, 0x80, 0x3c, 0x84, 0x01, 0x71, 0x24, 0x85, 0x25, 0xfb, 0xa8, 0x8e,
0xda, 0x07, 0x99, 0x1d, 0x1f, 0x90, 0x15, 0x38, 0x16, 0xd9, 0x59, 0x79, 0x72, 0x1c, 0x7a, 0x4a,
0x42, 0xa0, 0x6a, 0x60, 0x9f, 0x8c, 0xae, 0x58, 0x92, 0x0f, 0xe4, 0x22, 0x0d, 0x5d, 0xea, 0x31,
0x9b, 0xdf, 0x15, 0xfb, 0x05, 0x3a, 0x22, 0x92, 0xe9, 0xbf, 0x27, 0xe0, 0x45, 0x1d, 0xe7, 0x7b,
0xcc, 0xdb, 0xb4, 0x0a, 0x0c, 0x3f, 0x43, 0x30, 0x94, 0xd0, 0xbb, 0xe0, 0x33, 0x52, 0x43, 0xfb,
0xce, 0xc6, 0x48, 0xa8, 0x21, 0xe4, 0xed, 0xcf, 0x9e, 0xff, 0xf3, 0xb8, 0xeb, 0x06, 0x79, 0x45,
0x74, 0x61, 0xbe, 0xb9, 0x79, 0x69, 0x95, 0x71, 0x7a, 0xc9, 0xac, 0x85, 0xce, 0xa8, 0x9b, 0x61,
0xab, 0xc5, 0xc2, 0x32, 0x33, 0xd3, 0xda, 0xd7, 0xe0, 0xaf, 0x10, 0x9c, 0x88, 0xbb, 0x25, 0xf0,
0x84, 0x54, 0xdd, 0xa6, 0xe7, 0x49, 0x84, 0xbb, 0x22, 0xe1, 0x5e, 0xc7, 0x97, 0x3b, 0x82, 0x0b,
0xe6, 0xeb, 0xf8, 0x09, 0x82, 0xc1, 0xf8, 0x5a, 0x8c, 0x89, 0x54, 0xd8, 0xf6, 0x12, 0x32, 0xce,
0xb4, 0x5d, 0x13, 0x04, 0x9b, 0xbc, 0x26, 0x09, 0x4d, 0xdc, 0x99, 0xfb, 0xf0, 0x53, 0x04, 0x83,
0xf1, 0x9d, 0x95, 0x42, 0x6b, 0xdb, 0x76, 0x25, 0xfa, 0xeb, 0x86, 0xa4, 0xb9, 0x82, 0x67, 0xd2,
0xf8, 0xcb, 0xdc, 0x12, 0x3a, 0x2f, 0x22, 0xfc, 0x0b, 0x82, 0x6c, 0x52, 0xd7, 0x83, 0xcf, 0x26,
0x06, 0x33, 0xd2, 0x14, 0x19, 0x47, 0x03, 0xdf, 0xa9, 0xeb, 0x83, 0x6c, 0x48, 0x2e, 0x86, 0x0b,
0xa9, 0xb8, 0x5c, 0xa7, 0xe8, 0x9b, 0x35, 0xd5, 0x8b, 0xd4, 0xcd, 0xb0, 0x19, 0xf2, 0xcd, 0x5a,
0x43, 0x63, 0x54, 0x37, 0xcb, 0xce, 0x9a, 0x7f, 0x11, 0xe1, 0xdf, 0x51, 0x7c, 0x8b, 0xad, 0xfa,
0x15, 0xfc, 0x52, 0xa2, 0x0d, 0x8d, 0x3d, 0x94, 0x31, 0xb9, 0xfb, 0x42, 0x95, 0x07, 0xf7, 0xa4,
0x85, 0xb7, 0xf1, 0xad, 0x83, 0xb0, 0x50, 0x35, 0x4a, 0xf8, 0x07, 0x04, 0xc3, 0x89, 0xcd, 0x32,
0x3e, 0x27, 0xe1, 0x76, 0x6b, 0xa6, 0x13, 0x73, 0x65, 0x41, 0x12, 0x5f, 0x33, 0xae, 0xa6, 0x22,
0xf6, 0x94, 0x5a, 0xfc, 0x23, 0x02, 0x23, 0xb9, 0xf5, 0xc6, 0xe7, 0xa5, 0xf6, 0x5d, 0x7b, 0x73,
0x63, 0x30, 0x17, 0x7c, 0xed, 0xe5, 0xf4, 0xd7, 0x5e, 0x6e, 0x41, 0x7c, 0xed, 0x91, 0x45, 0x49,
0x79, 0xdd, 0x78, 0x2b, 0x15, 0x25, 0xd7, 0x7a, 0xf1, 0x77, 0x08, 0x06, 0x1b, 0x2b, 0xa4, 0xbe,
0x55, 0xd5, 0x81, 0x8b, 0x9f, 0xd4, 0x78, 0xf1, 0x57, 0xb4, 0xa6, 0x23, 0x2f, 0xef, 0x81, 0x4e,
0x7f, 0xa7, 0xfa, 0x33, 0x2d, 0x17, 0x3b, 0xfe, 0x17, 0xc1, 0xe8, 0x7d, 0xb7, 0x18, 0x03, 0xa0,
0xfb, 0xd0, 0x0b, 0x12, 0xa0, 0xed, 0x9a, 0x5d, 0x58, 0x3f, 0x45, 0x12, 0xb6, 0x66, 0xac, 0x75,
0x02, 0x6b, 0xd6, 0x9a, 0x61, 0x73, 0x55, 0xab, 0x58, 0x37, 0x37, 0x03, 0x9d, 0x71, 0xf3, 0x6a,
0xaa, 0x1e, 0x63, 0xe7, 0xaf, 0x08, 0x46, 0xe3, 0x1d, 0xad, 0xed, 0xdc, 0x47, 0x30, 0x4a, 0xd2,
0xbe, 0x8f, 0xc8, 0xf2, 0x41, 0xda, 0x17, 0x63, 0xc4, 0x73, 0x04, 0xc7, 0x23, 0x25, 0x21, 0x94,
0x8f, 0x37, 0x17, 0x8b, 0x3d, 0x72, 0x7f, 0x1e, 0x04, 0xa6, 0x8e, 0xa7, 0x3b, 0x03, 0x17, 0x9c,
0x1f, 0x2c, 0xe1, 0x85, 0xce, 0xdf, 0x8a, 0x44, 0x4f, 0x07, 0x0b, 0xff, 0x8c, 0x60, 0x24, 0x7a,
0xd7, 0x35, 0x05, 0xc6, 0xc7, 0x93, 0x2d, 0xd7, 0x61, 0xf3, 0x12, 0x6d, 0xe7, 0x85, 0x3d, 0xac,
0x54, 0x65, 0x73, 0x4e, 0x9a, 0x7e, 0x15, 0xbf, 0xb9, 0x0f, 0x23, 0xf0, 0x37, 0x08, 0x4e, 0xc6,
0x69, 0xf3, 0xf1, 0xe9, 0x44, 0x92, 0x10, 0x96, 0xb4, 0x5b, 0xa2, 0x28, 0x2f, 0x4b, 0xca, 0x1c,
0xee, 0xe8, 0x98, 0xe3, 0x9f, 0x10, 0x0c, 0xcd, 0x7a, 0x85, 0x75, 0x6b, 0xb3, 0xb5, 0xe6, 0x04,
0xbd, 0x45, 0xc2, 0xac, 0x46, 0x3b, 0xdb, 0x7e, 0x91, 0x82, 0x53, 0x77, 0xbe, 0x31, 0x93, 0xc2,
0x85, 0x34, 0xd8, 0x5b, 0xb4, 0x6e, 0xfd, 0x91, 0xbf, 0x90, 0xf0, 0x90, 0x4e, 0xe5, 0xa6, 0x3f,
0x95, 0x54, 0x0a, 0x37, 0x7f, 0x3c, 0x90, 0x3b, 0x92, 0xe1, 0x26, 0x5e, 0x4a, 0x55, 0xa5, 0xa9,
0xda, 0xce, 0x37, 0x6b, 0x1b, 0x6c, 0xfb, 0xea, 0xd4, 0x54, 0x1d, 0x7f, 0x89, 0xa0, 0x2f, 0xec,
0xac, 0xf1, 0xc9, 0x30, 0x46, 0xd1, 0x1e, 0x5e, 0xdd, 0x6c, 0x2d, 0x0d, 0x38, 0x59, 0x96, 0x34,
0x8b, 0x78, 0x3e, 0x15, 0x8d, 0xec, 0xd1, 0xcd, 0x9a, 0xe8, 0xef, 0x25, 0xca, 0xd7, 0x08, 0x8c,
0xd8, 0x76, 0x87, 0xae, 0xb2, 0xb2, 0x66, 0x5b, 0x62, 0x3c, 0x18, 0x37, 0xb2, 0x45, 0xc4, 0x29,
0x12, 0xbe, 0x95, 0xad, 0x1c, 0xe8, 0x7c, 0x82, 0xc0, 0x98, 0x2d, 0x16, 0xdb, 0x23, 0xcd, 0x16,
0x8b, 0x7b, 0x43, 0xba, 0x25, 0x91, 0x16, 0xc8, 0x7e, 0x90, 0x66, 0x0e, 0x29, 0xb4, 0x67, 0x08,
0xc6, 0xf2, 0xcc, 0x2d, 0xd3, 0x02, 0x4b, 0xc2, 0x1b, 0x56, 0x7d, 0x8b, 0x5c, 0xd4, 0x11, 0xa2,
0x71, 0x20, 0x88, 0x4f, 0x11, 0x8c, 0xcc, 0xb3, 0x32, 0xe3, 0x09, 0x84, 0x2a, 0xfb, 0x83, 0x25,
0x52, 0xb2, 0x1b, 0xde, 0x4d, 0x89, 0x37, 0x37, 0x35, 0xbb, 0x0f, 0x3c, 0x99, 0xfb, 0x75, 0x71,
0x12, 0x87, 0x63, 0xae, 0x90, 0x74, 0xc9, 0xd6, 0xc9, 0xe7, 0x40, 0xa4, 0x34, 0x34, 0xe4, 0xda,
0xb7, 0x08, 0x86, 0x23, 0xb9, 0x16, 0x0b, 0xb4, 0xe7, 0x54, 0x7b, 0x47, 0x02, 0xcd, 0x93, 0x7d,
0x00, 0x85, 0x61, 0xfc, 0x1e, 0xc1, 0x68, 0x53, 0xa6, 0x35, 0xc1, 0xa5, 0x48, 0x34, 0x05, 0x68,
0x1c, 0x04, 0xe0, 0x13, 0x04, 0xa7, 0x1a, 0xf3, 0xac, 0x81, 0xaf, 0xf3, 0x34, 0x53, 0x9f, 0xea,
0x53, 0xd7, 0xd3, 0xc3, 0x05, 0x59, 0xb6, 0x7a, 0x48, 0x76, 0xd9, 0xaf, 0xfe, 0x17, 0x00, 0x00,
0xff, 0xff, 0x24, 0x3b, 0x30, 0x18, 0x96, 0x19, 0x00, 0x00,
}
// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var _ grpc.ClientConn
var _ grpc.ClientConnInterface
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
const _ = grpc.SupportPackageIsVersion4
const _ = grpc.SupportPackageIsVersion6
// WorkflowServiceClient is the client API for WorkflowService service.
//
@@ -1559,10 +1211,10 @@ type WorkflowServiceClient interface {
}
type workflowServiceClient struct {
cc *grpc.ClientConn
cc grpc.ClientConnInterface
}
func NewWorkflowServiceClient(cc *grpc.ClientConn) WorkflowServiceClient {
func NewWorkflowServiceClient(cc grpc.ClientConnInterface) WorkflowServiceClient {
return &workflowServiceClient{cc}
}

37
api/workflow.proto
View File

@@ -6,6 +6,7 @@ import "google/api/annotations.proto";
import "google/protobuf/empty.proto";
import "workflow_template.proto";
import "metric.proto";
import "label.proto";
service WorkflowService {
// Creates a Workflow
@@ -283,39 +284,3 @@ message ListFilesResponse {
repeated File files = 1;
string parentPath = 2;
}
message KeyValue {
string key = 1;
string value = 2;
}
message Labels {
repeated KeyValue items = 1;
}
message AddLabelsRequest {
string namespace = 1;
string name = 2;
Labels labels = 3;
}
message ReplaceLabelsRequest {
string namespace = 1;
string name = 2;
Labels labels = 3;
}
message GetLabelsRequest {
string namespace = 1;
string name = 2;
}
message GetLabelsResponse {
repeated KeyValue labels = 1;
}
message DeleteLabelRequest {
string namespace = 1;
string name = 2;
string key = 3;
}

4
api/workflow_template.pb.go
View File

@@ -535,7 +535,9 @@ func init() {
proto.RegisterType((*WorkflowTemplate)(nil), "api.WorkflowTemplate")
}
func init() { proto.RegisterFile("workflow_template.proto", fileDescriptor_b9a07547748a96e8) }
func init() {
proto.RegisterFile("workflow_template.proto", fileDescriptor_b9a07547748a96e8)
}
var fileDescriptor_b9a07547748a96e8 = []byte{
// 368 bytes of a gzipped FileDescriptorProto