buildr/api
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

feat: include default spec in plugin inventory

Browse source
This commit is contained in:
Peter 2023-08-23 18:58:33 +02:00
parent dbc0adad8f
commit 52d0bd9e97
Signed by: prskr
GPG key ID: C1DB5D2E8DB512F9
7 changed files with 489 additions and 175 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

27
.editorconfig Normal file
View file

@ -0,0 +1,27 @@
root = true
[*]
charset = utf-8
end_of_line = lf
indent_size = 4
tab_width = 4
indent_style = space
insert_final_newline = false
max_line_length = 120
trim_trailing_whitespace = true
[*.go]
indent_style = tab
ij_smart_tabs = true
ij_go_GROUP_CURRENT_PROJECT_IMPORTS = true
ij_go_group_stdlib_imports = true
ij_go_import_sorting = goimports
ij_go_local_group_mode = project
ij_go_move_all_imports_in_one_declaration = true
ij_go_move_all_stdlib_imports_in_one_group = true
ij_go_remove_redundant_import_aliases = true
[*.{yml,yaml}]
indent_size = 2
tab_width = 2
insert_final_newline = true

292
generated/rpc/v1/executor.pb.go
View file

@ -656,7 +656,7 @@ type PluginInventory struct {
sizeCache protoimpl.SizeCache sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields unknownFields protoimpl.UnknownFields
Modules []*ModuleReference `protobuf:"bytes,1,rep,name=modules,proto3" json:"modules,omitempty"` Specs []*PluginInventory_InventorySpec `protobuf:"bytes,1,rep,name=specs,proto3" json:"specs,omitempty"`
} }
func (x *PluginInventory) Reset() { func (x *PluginInventory) Reset() {
@ -691,9 +691,9 @@ func (*PluginInventory) Descriptor() ([]byte, []int) {
return file_rpc_v1_executor_proto_rawDescGZIP(), []int{10} return file_rpc_v1_executor_proto_rawDescGZIP(), []int{10}
} }
func (x *PluginInventory) GetModules() []*ModuleReference { func (x *PluginInventory) GetSpecs() []*PluginInventory_InventorySpec {
if x != nil { if x != nil {
return x.Modules return x.Specs
} }
return nil return nil
} }
@ -1102,6 +1102,61 @@ func (x *TaskLog_LogAttribute) GetValue() string {
return "" return ""
} }
type PluginInventory_InventorySpec struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
ModuleRef *ModuleReference `protobuf:"bytes,1,opt,name=module_ref,json=moduleRef,proto3" json:"module_ref,omitempty"`
EmptySpec []byte `protobuf:"bytes,2,opt,name=empty_spec,json=emptySpec,proto3" json:"empty_spec,omitempty"`
}
func (x *PluginInventory_InventorySpec) Reset() {
*x = PluginInventory_InventorySpec{}
if protoimpl.UnsafeEnabled {
mi := &file_rpc_v1_executor_proto_msgTypes[15]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *PluginInventory_InventorySpec) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*PluginInventory_InventorySpec) ProtoMessage() {}
func (x *PluginInventory_InventorySpec) ProtoReflect() protoreflect.Message {
mi := &file_rpc_v1_executor_proto_msgTypes[15]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use PluginInventory_InventorySpec.ProtoReflect.Descriptor instead.
func (*PluginInventory_InventorySpec) Descriptor() ([]byte, []int) {
return file_rpc_v1_executor_proto_rawDescGZIP(), []int{10, 0}
}
func (x *PluginInventory_InventorySpec) GetModuleRef() *ModuleReference {
if x != nil {
return x.ModuleRef
}
return nil
}
func (x *PluginInventory_InventorySpec) GetEmptySpec() []byte {
if x != nil {
return x.EmptySpec
}
return nil
}
var File_rpc_v1_executor_proto protoreflect.FileDescriptor var File_rpc_v1_executor_proto protoreflect.FileDescriptor
var file_rpc_v1_executor_proto_rawDesc = []byte{ var file_rpc_v1_executor_proto_rawDesc = []byte{
@ -1172,82 +1227,89 @@ var file_rpc_v1_executor_proto_rawDesc = []byte{
0x22, 0x38, 0x0a, 0x06, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x12, 0x18, 0x0a, 0x07, 0x73, 0x75, 0x22, 0x38, 0x0a, 0x06, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x12, 0x18, 0x0a, 0x07, 0x73, 0x75,
0x63, 0x63, 0x65, 0x73, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x73, 0x75, 0x63, 0x63, 0x63, 0x65, 0x73, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x73, 0x75, 0x63,
0x63, 0x65, 0x73, 0x73, 0x12, 0x14, 0x0a, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x18, 0x02, 0x20, 0x63, 0x65, 0x73, 0x73, 0x12, 0x14, 0x0a, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x18, 0x02, 0x20,
0x01, 0x28, 0x09, 0x52, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x22, 0x4b, 0x0a, 0x0f, 0x50, 0x6c, 0x01, 0x28, 0x09, 0x52, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x22, 0xc4, 0x01, 0x0a, 0x0f, 0x50,
0x75, 0x67, 0x69, 0x6e, 0x49, 0x6e, 0x76, 0x65, 0x6e, 0x74, 0x6f, 0x72, 0x79, 0x12, 0x38, 0x0a, 0x6c, 0x75, 0x67, 0x69, 0x6e, 0x49, 0x6e, 0x76, 0x65, 0x6e, 0x74, 0x6f, 0x72, 0x79, 0x12, 0x42,
0x07, 0x6d, 0x6f, 0x64, 0x75, 0x6c, 0x65, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1e, 0x0a, 0x05, 0x73, 0x70, 0x65, 0x63, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x2c, 0x2e,
0x2e, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x72, 0x2e, 0x72, 0x70, 0x63, 0x2e, 0x76, 0x31, 0x2e, 0x4d, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x72, 0x2e, 0x72, 0x70, 0x63, 0x2e, 0x76, 0x31, 0x2e, 0x50, 0x6c,
0x6f, 0x64, 0x75, 0x6c, 0x65, 0x52, 0x65, 0x66, 0x65, 0x72, 0x65, 0x6e, 0x63, 0x65, 0x52, 0x07, 0x75, 0x67, 0x69, 0x6e, 0x49, 0x6e, 0x76, 0x65, 0x6e, 0x74, 0x6f, 0x72, 0x79, 0x2e, 0x49, 0x6e,
0x6d, 0x6f, 0x64, 0x75, 0x6c, 0x65, 0x73, 0x22, 0x9f, 0x02, 0x0a, 0x16, 0x45, 0x78, 0x65, 0x63, 0x76, 0x65, 0x6e, 0x74, 0x6f, 0x72, 0x79, 0x53, 0x70, 0x65, 0x63, 0x52, 0x05, 0x73, 0x70, 0x65,
0x75, 0x74, 0x69, 0x6f, 0x6e, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x63, 0x73, 0x1a, 0x6d, 0x0a, 0x0d, 0x49, 0x6e, 0x76, 0x65, 0x6e, 0x74, 0x6f, 0x72, 0x79, 0x53,
0x67, 0x65, 0x12, 0x1f, 0x0a, 0x0a, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x5f, 0x69, 0x64, 0x70, 0x65, 0x63, 0x12, 0x3d, 0x0a, 0x0a, 0x6d, 0x6f, 0x64, 0x75, 0x6c, 0x65, 0x5f, 0x72, 0x65,
0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x48, 0x00, 0x52, 0x09, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x66, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1e, 0x2e, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x72,
0x65, 0x49, 0x64, 0x12, 0x1f, 0x0a, 0x0a, 0x72, 0x65, 0x70, 0x6c, 0x69, 0x65, 0x73, 0x5f, 0x74, 0x2e, 0x72, 0x70, 0x63, 0x2e, 0x76, 0x31, 0x2e, 0x4d, 0x6f, 0x64, 0x75, 0x6c, 0x65, 0x52, 0x65,
0x6f, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x48, 0x00, 0x52, 0x09, 0x72, 0x65, 0x70, 0x6c, 0x69, 0x66, 0x65, 0x72, 0x65, 0x6e, 0x63, 0x65, 0x52, 0x09, 0x6d, 0x6f, 0x64, 0x75, 0x6c, 0x65, 0x52,
0x65, 0x73, 0x54, 0x6f, 0x12, 0x40, 0x0a, 0x0a, 0x73, 0x74, 0x61, 0x72, 0x74, 0x5f, 0x74, 0x61, 0x65, 0x66, 0x12, 0x1d, 0x0a, 0x0a, 0x65, 0x6d, 0x70, 0x74, 0x79, 0x5f, 0x73, 0x70, 0x65, 0x63,
0x73, 0x6b, 0x18, 0x0b, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x09, 0x65, 0x6d, 0x70, 0x74, 0x79, 0x53, 0x70, 0x65,
0x72, 0x2e, 0x72, 0x70, 0x63, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x74, 0x61, 0x72, 0x74, 0x54, 0x61, 0x63, 0x22, 0x9f, 0x02, 0x0a, 0x16, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x43,
0x73, 0x6b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x48, 0x01, 0x52, 0x09, 0x73, 0x74, 0x61, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x1f, 0x0a, 0x0a,
0x72, 0x74, 0x54, 0x61, 0x73, 0x6b, 0x12, 0x3e, 0x0a, 0x09, 0x67, 0x65, 0x74, 0x5f, 0x73, 0x74, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c,
0x61, 0x74, 0x65, 0x18, 0x0c, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x62, 0x75, 0x69, 0x6c, 0x48, 0x00, 0x52, 0x09, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x49, 0x64, 0x12, 0x1f, 0x0a,
0x64, 0x72, 0x2e, 0x72, 0x70, 0x63, 0x2e, 0x76, 0x31, 0x2e, 0x47, 0x65, 0x74, 0x53, 0x74, 0x61, 0x0a, 0x72, 0x65, 0x70, 0x6c, 0x69, 0x65, 0x73, 0x5f, 0x74, 0x6f, 0x18, 0x02, 0x20, 0x01, 0x28,
0x74, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x48, 0x01, 0x52, 0x08, 0x67, 0x65, 0x0c, 0x48, 0x00, 0x52, 0x09, 0x72, 0x65, 0x70, 0x6c, 0x69, 0x65, 0x73, 0x54, 0x6f, 0x12, 0x40,
0x74, 0x53, 0x74, 0x61, 0x74, 0x65, 0x12, 0x2d, 0x0a, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x18, 0x0a, 0x0a, 0x73, 0x74, 0x61, 0x72, 0x74, 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x18, 0x0b, 0x20, 0x01,
0x0d, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x15, 0x2e, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x72, 0x2e, 0x72, 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x72, 0x2e, 0x72, 0x70, 0x63, 0x2e,
0x70, 0x63, 0x2e, 0x76, 0x31, 0x2e, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x48, 0x01, 0x52, 0x05, 0x76, 0x31, 0x2e, 0x53, 0x74, 0x61, 0x72, 0x74, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x65, 0x71, 0x75,
0x65, 0x72, 0x72, 0x6f, 0x72, 0x42, 0x06, 0x0a, 0x04, 0x6d, 0x65, 0x74, 0x61, 0x42, 0x0a, 0x0a, 0x65, 0x73, 0x74, 0x48, 0x01, 0x52, 0x09, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x61, 0x73, 0x6b,
0x08, 0x65, 0x6e, 0x76, 0x65, 0x6c, 0x6f, 0x70, 0x65, 0x22, 0x96, 0x03, 0x0a, 0x16, 0x45, 0x78, 0x12, 0x3e, 0x0a, 0x09, 0x67, 0x65, 0x74, 0x5f, 0x73, 0x74, 0x61, 0x74, 0x65, 0x18, 0x0c, 0x20,
0x01, 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x72, 0x2e, 0x72, 0x70, 0x63,
0x2e, 0x76, 0x31, 0x2e, 0x47, 0x65, 0x74, 0x53, 0x74, 0x61, 0x74, 0x65, 0x52, 0x65, 0x73, 0x70,
0x6f, 0x6e, 0x73, 0x65, 0x48, 0x01, 0x52, 0x08, 0x67, 0x65, 0x74, 0x53, 0x74, 0x61, 0x74, 0x65,
0x12, 0x2d, 0x0a, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x18, 0x0d, 0x20, 0x01, 0x28, 0x0b, 0x32,
0x15, 0x2e, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x72, 0x2e, 0x72, 0x70, 0x63, 0x2e, 0x76, 0x31, 0x2e,
0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x48, 0x01, 0x52, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x42,
0x06, 0x0a, 0x04, 0x6d, 0x65, 0x74, 0x61, 0x42, 0x0a, 0x0a, 0x08, 0x65, 0x6e, 0x76, 0x65, 0x6c,
0x6f, 0x70, 0x65, 0x22, 0x96, 0x03, 0x0a, 0x16, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f,
0x6e, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x1f,
0x0a, 0x0a, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01,
0x28, 0x0c, 0x48, 0x00, 0x52, 0x09, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x49, 0x64, 0x12,
0x1f, 0x0a, 0x0a, 0x72, 0x65, 0x70, 0x6c, 0x69, 0x65, 0x73, 0x5f, 0x74, 0x6f, 0x18, 0x02, 0x20,
0x01, 0x28, 0x0c, 0x48, 0x00, 0x52, 0x09, 0x72, 0x65, 0x70, 0x6c, 0x69, 0x65, 0x73, 0x54, 0x6f,
0x12, 0x3c, 0x0a, 0x0b, 0x74, 0x61, 0x73, 0x6b, 0x5f, 0x72, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x18,
0x0b, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x72, 0x2e, 0x72,
0x70, 0x63, 0x2e, 0x76, 0x31, 0x2e, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74,
0x48, 0x01, 0x52, 0x0a, 0x74, 0x61, 0x73, 0x6b, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x12, 0x33,
0x0a, 0x08, 0x74, 0x61, 0x73, 0x6b, 0x5f, 0x6c, 0x6f, 0x67, 0x18, 0x0c, 0x20, 0x01, 0x28, 0x0b,
0x32, 0x16, 0x2e, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x72, 0x2e, 0x72, 0x70, 0x63, 0x2e, 0x76, 0x31,
0x2e, 0x54, 0x61, 0x73, 0x6b, 0x4c, 0x6f, 0x67, 0x48, 0x01, 0x52, 0x07, 0x74, 0x61, 0x73, 0x6b,
0x4c, 0x6f, 0x67, 0x12, 0x3c, 0x0a, 0x0b, 0x74, 0x61, 0x73, 0x6b, 0x5f, 0x6f, 0x75, 0x74, 0x70,
0x75, 0x74, 0x18, 0x0d, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x62, 0x75, 0x69, 0x6c, 0x64,
0x72, 0x2e, 0x72, 0x70, 0x63, 0x2e, 0x76, 0x31, 0x2e, 0x54, 0x61, 0x73, 0x6b, 0x4f, 0x75, 0x74,
0x70, 0x75, 0x74, 0x48, 0x01, 0x52, 0x0a, 0x74, 0x61, 0x73, 0x6b, 0x4f, 0x75, 0x74, 0x70, 0x75,
0x74, 0x12, 0x3d, 0x0a, 0x09, 0x67, 0x65, 0x74, 0x5f, 0x73, 0x74, 0x61, 0x74, 0x65, 0x18, 0x0e,
0x20, 0x01, 0x28, 0x0b, 0x32, 0x1e, 0x2e, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x72, 0x2e, 0x72, 0x70,
0x63, 0x2e, 0x76, 0x31, 0x2e, 0x47, 0x65, 0x74, 0x53, 0x74, 0x61, 0x74, 0x65, 0x52, 0x65, 0x71,
0x75, 0x65, 0x73, 0x74, 0x48, 0x01, 0x52, 0x08, 0x67, 0x65, 0x74, 0x53, 0x74, 0x61, 0x74, 0x65,
0x12, 0x36, 0x0a, 0x09, 0x73, 0x65, 0x74, 0x5f, 0x73, 0x74, 0x61, 0x74, 0x65, 0x18, 0x0f, 0x20,
0x01, 0x28, 0x0b, 0x32, 0x17, 0x2e, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x72, 0x2e, 0x72, 0x70, 0x63,
0x2e, 0x76, 0x31, 0x2e, 0x53, 0x65, 0x74, 0x53, 0x74, 0x61, 0x74, 0x65, 0x48, 0x01, 0x52, 0x08,
0x73, 0x65, 0x74, 0x53, 0x74, 0x61, 0x74, 0x65, 0x42, 0x06, 0x0a, 0x04, 0x6d, 0x65, 0x74, 0x61,
0x42, 0x0a, 0x0a, 0x08, 0x65, 0x6e, 0x76, 0x65, 0x6c, 0x6f, 0x70, 0x65, 0x2a, 0x74, 0x0a, 0x10,
0x54, 0x61, 0x73, 0x6b, 0x4f, 0x75, 0x74, 0x70, 0x75, 0x74, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65,
0x12, 0x22, 0x0a, 0x1e, 0x54, 0x41, 0x53, 0x4b, 0x5f, 0x4f, 0x55, 0x54, 0x50, 0x55, 0x54, 0x5f,
0x53, 0x4f, 0x55, 0x52, 0x43, 0x45, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49,
0x45, 0x44, 0x10, 0x00, 0x12, 0x1d, 0x0a, 0x19, 0x54, 0x41, 0x53, 0x4b, 0x5f, 0x4f, 0x55, 0x54,
0x50, 0x55, 0x54, 0x5f, 0x53, 0x4f, 0x55, 0x52, 0x43, 0x45, 0x5f, 0x53, 0x54, 0x44, 0x4f, 0x55,
0x54, 0x10, 0x01, 0x12, 0x1d, 0x0a, 0x19, 0x54, 0x41, 0x53, 0x4b, 0x5f, 0x4f, 0x55, 0x54, 0x50,
0x55, 0x54, 0x5f, 0x53, 0x4f, 0x55, 0x52, 0x43, 0x45, 0x5f, 0x53, 0x54, 0x44, 0x45, 0x52, 0x52,
0x10, 0x02, 0x32, 0x74, 0x0a, 0x0f, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x6f, 0x72, 0x53, 0x65,
0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x61, 0x0a, 0x0d, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x65,
0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x25, 0x2e, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x72, 0x2e,
0x72, 0x70, 0x63, 0x2e, 0x76, 0x31, 0x2e, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e,
0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x1a, 0x25, 0x2e,
0x62, 0x75, 0x69, 0x6c, 0x64, 0x72, 0x2e, 0x72, 0x70, 0x63, 0x2e, 0x76, 0x31, 0x2e, 0x45, 0x78,
0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x4d, 0x65, 0x73, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x4d, 0x65, 0x73,
0x73, 0x61, 0x67, 0x65, 0x12, 0x1f, 0x0a, 0x0a, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x5f, 0x73, 0x61, 0x67, 0x65, 0x28, 0x01, 0x30, 0x01, 0x42, 0xaa, 0x01, 0x0a, 0x11, 0x63, 0x6f, 0x6d,
0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x48, 0x00, 0x52, 0x09, 0x6d, 0x65, 0x73, 0x73, 0x2e, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x72, 0x2e, 0x72, 0x70, 0x63, 0x2e, 0x76, 0x31, 0x42, 0x0d,
0x61, 0x67, 0x65, 0x49, 0x64, 0x12, 0x1f, 0x0a, 0x0a, 0x72, 0x65, 0x70, 0x6c, 0x69, 0x65, 0x73, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x6f, 0x72, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x48, 0x02, 0x50,
0x5f, 0x74, 0x6f, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x48, 0x00, 0x52, 0x09, 0x72, 0x65, 0x70, 0x01, 0x5a, 0x2e, 0x63, 0x6f, 0x64, 0x65, 0x2e, 0x69, 0x63, 0x62, 0x34, 0x64, 0x63, 0x30, 0x2e,
0x6c, 0x69, 0x65, 0x73, 0x54, 0x6f, 0x12, 0x3c, 0x0a, 0x0b, 0x74, 0x61, 0x73, 0x6b, 0x5f, 0x72, 0x64, 0x65, 0x2f, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x72, 0x2f, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x72,
0x65, 0x73, 0x75, 0x6c, 0x74, 0x18, 0x0b, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x62, 0x75, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x72, 0x70, 0x63, 0x2f, 0x76, 0x31, 0x3b, 0x72, 0x70, 0x63, 0x76,
0x69, 0x6c, 0x64, 0x72, 0x2e, 0x72, 0x70, 0x63, 0x2e, 0x76, 0x31, 0x2e, 0x54, 0x61, 0x73, 0x6b, 0x31, 0xa2, 0x02, 0x03, 0x42, 0x52, 0x58, 0xaa, 0x02, 0x0d, 0x42, 0x75, 0x69, 0x6c, 0x64, 0x72,
0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x48, 0x01, 0x52, 0x0a, 0x74, 0x61, 0x73, 0x6b, 0x52, 0x65, 0x2e, 0x52, 0x70, 0x63, 0x2e, 0x56, 0x31, 0xca, 0x02, 0x0d, 0x42, 0x75, 0x69, 0x6c, 0x64, 0x72,
0x73, 0x75, 0x6c, 0x74, 0x12, 0x33, 0x0a, 0x08, 0x74, 0x61, 0x73, 0x6b, 0x5f, 0x6c, 0x6f, 0x67, 0x5c, 0x52, 0x70, 0x63, 0x5c, 0x56, 0x31, 0xe2, 0x02, 0x19, 0x42, 0x75, 0x69, 0x6c, 0x64, 0x72,
0x18, 0x0c, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x16, 0x2e, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x72, 0x2e, 0x5c, 0x52, 0x70, 0x63, 0x5c, 0x56, 0x31, 0x5c, 0x47, 0x50, 0x42, 0x4d, 0x65, 0x74, 0x61, 0x64,
0x72, 0x70, 0x63, 0x2e, 0x76, 0x31, 0x2e, 0x54, 0x61, 0x73, 0x6b, 0x4c, 0x6f, 0x67, 0x48, 0x01, 0x61, 0x74, 0x61, 0xea, 0x02, 0x0f, 0x42, 0x75, 0x69, 0x6c, 0x64, 0x72, 0x3a, 0x3a, 0x52, 0x70,
0x52, 0x07, 0x74, 0x61, 0x73, 0x6b, 0x4c, 0x6f, 0x67, 0x12, 0x3c, 0x0a, 0x0b, 0x74, 0x61, 0x73, 0x63, 0x3a, 0x3a, 0x56, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
0x6b, 0x5f, 0x6f, 0x75, 0x74, 0x70, 0x75, 0x74, 0x18, 0x0d, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19,
0x2e, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x72, 0x2e, 0x72, 0x70, 0x63, 0x2e, 0x76, 0x31, 0x2e, 0x54,
0x61, 0x73, 0x6b, 0x4f, 0x75, 0x74, 0x70, 0x75, 0x74, 0x48, 0x01, 0x52, 0x0a, 0x74, 0x61, 0x73,
0x6b, 0x4f, 0x75, 0x74, 0x70, 0x75, 0x74, 0x12, 0x3d, 0x0a, 0x09, 0x67, 0x65, 0x74, 0x5f, 0x73,
0x74, 0x61, 0x74, 0x65, 0x18, 0x0e, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1e, 0x2e, 0x62, 0x75, 0x69,
0x6c, 0x64, 0x72, 0x2e, 0x72, 0x70, 0x63, 0x2e, 0x76, 0x31, 0x2e, 0x47, 0x65, 0x74, 0x53, 0x74,
0x61, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x48, 0x01, 0x52, 0x08, 0x67, 0x65,
0x74, 0x53, 0x74, 0x61, 0x74, 0x65, 0x12, 0x36, 0x0a, 0x09, 0x73, 0x65, 0x74, 0x5f, 0x73, 0x74,
0x61, 0x74, 0x65, 0x18, 0x0f, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x17, 0x2e, 0x62, 0x75, 0x69, 0x6c,
0x64, 0x72, 0x2e, 0x72, 0x70, 0x63, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x65, 0x74, 0x53, 0x74, 0x61,
0x74, 0x65, 0x48, 0x01, 0x52, 0x08, 0x73, 0x65, 0x74, 0x53, 0x74, 0x61, 0x74, 0x65, 0x42, 0x06,
0x0a, 0x04, 0x6d, 0x65, 0x74, 0x61, 0x42, 0x0a, 0x0a, 0x08, 0x65, 0x6e, 0x76, 0x65, 0x6c, 0x6f,
0x70, 0x65, 0x2a, 0x74, 0x0a, 0x10, 0x54, 0x61, 0x73, 0x6b, 0x4f, 0x75, 0x74, 0x70, 0x75, 0x74,
0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x12, 0x22, 0x0a, 0x1e, 0x54, 0x41, 0x53, 0x4b, 0x5f, 0x4f,
0x55, 0x54, 0x50, 0x55, 0x54, 0x5f, 0x53, 0x4f, 0x55, 0x52, 0x43, 0x45, 0x5f, 0x55, 0x4e, 0x53,
0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x1d, 0x0a, 0x19, 0x54, 0x41,
0x53, 0x4b, 0x5f, 0x4f, 0x55, 0x54, 0x50, 0x55, 0x54, 0x5f, 0x53, 0x4f, 0x55, 0x52, 0x43, 0x45,
0x5f, 0x53, 0x54, 0x44, 0x4f, 0x55, 0x54, 0x10, 0x01, 0x12, 0x1d, 0x0a, 0x19, 0x54, 0x41, 0x53,
0x4b, 0x5f, 0x4f, 0x55, 0x54, 0x50, 0x55, 0x54, 0x5f, 0x53, 0x4f, 0x55, 0x52, 0x43, 0x45, 0x5f,
0x53, 0x54, 0x44, 0x45, 0x52, 0x52, 0x10, 0x02, 0x32, 0x74, 0x0a, 0x0f, 0x45, 0x78, 0x65, 0x63,
0x75, 0x74, 0x6f, 0x72, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x61, 0x0a, 0x0d, 0x45,
0x78, 0x65, 0x63, 0x75, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x25, 0x2e, 0x62,
0x75, 0x69, 0x6c, 0x64, 0x72, 0x2e, 0x72, 0x70, 0x63, 0x2e, 0x76, 0x31, 0x2e, 0x45, 0x78, 0x65,
0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x4d, 0x65, 0x73, 0x73,
0x61, 0x67, 0x65, 0x1a, 0x25, 0x2e, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x72, 0x2e, 0x72, 0x70, 0x63,
0x2e, 0x76, 0x31, 0x2e, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x65, 0x72,
0x76, 0x65, 0x72, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x28, 0x01, 0x30, 0x01, 0x42, 0xaa,
0x01, 0x0a, 0x11, 0x63, 0x6f, 0x6d, 0x2e, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x72, 0x2e, 0x72, 0x70,
0x63, 0x2e, 0x76, 0x31, 0x42, 0x0d, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x6f, 0x72, 0x50, 0x72,
0x6f, 0x74, 0x6f, 0x48, 0x02, 0x50, 0x01, 0x5a, 0x2e, 0x63, 0x6f, 0x64, 0x65, 0x2e, 0x69, 0x63,
0x62, 0x34, 0x64, 0x63, 0x30, 0x2e, 0x64, 0x65, 0x2f, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x72, 0x2f,
0x62, 0x75, 0x69, 0x6c, 0x64, 0x72, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x72, 0x70, 0x63, 0x2f, 0x76,
0x31, 0x3b, 0x72, 0x70, 0x63, 0x76, 0x31, 0xa2, 0x02, 0x03, 0x42, 0x52, 0x58, 0xaa, 0x02, 0x0d,
0x42, 0x75, 0x69, 0x6c, 0x64, 0x72, 0x2e, 0x52, 0x70, 0x63, 0x2e, 0x56, 0x31, 0xca, 0x02, 0x0d,
0x42, 0x75, 0x69, 0x6c, 0x64, 0x72, 0x5c, 0x52, 0x70, 0x63, 0x5c, 0x56, 0x31, 0xe2, 0x02, 0x19,
0x42, 0x75, 0x69, 0x6c, 0x64, 0x72, 0x5c, 0x52, 0x70, 0x63, 0x5c, 0x56, 0x31, 0x5c, 0x47, 0x50,
0x42, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0xea, 0x02, 0x0f, 0x42, 0x75, 0x69, 0x6c,
0x64, 0x72, 0x3a, 0x3a, 0x52, 0x70, 0x63, 0x3a, 0x3a, 0x56, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f,
0x74, 0x6f, 0x33,
} }
var ( var (
@ -1263,36 +1325,37 @@ func file_rpc_v1_executor_proto_rawDescGZIP() []byte {
} }
var file_rpc_v1_executor_proto_enumTypes = make([]protoimpl.EnumInfo, 1) var file_rpc_v1_executor_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
var file_rpc_v1_executor_proto_msgTypes = make([]protoimpl.MessageInfo, 15) var file_rpc_v1_executor_proto_msgTypes = make([]protoimpl.MessageInfo, 16)
var file_rpc_v1_executor_proto_goTypes = []interface{}{ var file_rpc_v1_executor_proto_goTypes = []interface{}{
(TaskOutputSource)(0), // 0: buildr.rpc.v1.TaskOutputSource (TaskOutputSource)(0), // 0: buildr.rpc.v1.TaskOutputSource
(*Buildr)(nil), // 1: buildr.rpc.v1.Buildr (*Buildr)(nil), // 1: buildr.rpc.v1.Buildr
(*TaskReference)(nil), // 2: buildr.rpc.v1.TaskReference (*TaskReference)(nil), // 2: buildr.rpc.v1.TaskReference
(*StartTaskRequest)(nil), // 3: buildr.rpc.v1.StartTaskRequest (*StartTaskRequest)(nil), // 3: buildr.rpc.v1.StartTaskRequest
(*TaskResult)(nil), // 4: buildr.rpc.v1.TaskResult (*TaskResult)(nil), // 4: buildr.rpc.v1.TaskResult
(*TaskOutput)(nil), // 5: buildr.rpc.v1.TaskOutput (*TaskOutput)(nil), // 5: buildr.rpc.v1.TaskOutput
(*TaskLog)(nil), // 6: buildr.rpc.v1.TaskLog (*TaskLog)(nil), // 6: buildr.rpc.v1.TaskLog
(*SetState)(nil), // 7: buildr.rpc.v1.SetState (*SetState)(nil), // 7: buildr.rpc.v1.SetState
(*GetStateRequest)(nil), // 8: buildr.rpc.v1.GetStateRequest (*GetStateRequest)(nil), // 8: buildr.rpc.v1.GetStateRequest
(*GetStateResponse)(nil), // 9: buildr.rpc.v1.GetStateResponse (*GetStateResponse)(nil), // 9: buildr.rpc.v1.GetStateResponse
(*Result)(nil), // 10: buildr.rpc.v1.Result (*Result)(nil), // 10: buildr.rpc.v1.Result
(*PluginInventory)(nil), // 11: buildr.rpc.v1.PluginInventory (*PluginInventory)(nil), // 11: buildr.rpc.v1.PluginInventory
(*ExecutionClientMessage)(nil), // 12: buildr.rpc.v1.ExecutionClientMessage (*ExecutionClientMessage)(nil), // 12: buildr.rpc.v1.ExecutionClientMessage
(*ExecutionServerMessage)(nil), // 13: buildr.rpc.v1.ExecutionServerMessage (*ExecutionServerMessage)(nil), // 13: buildr.rpc.v1.ExecutionServerMessage
(*Buildr_Repo)(nil), // 14: buildr.rpc.v1.Buildr.Repo (*Buildr_Repo)(nil), // 14: buildr.rpc.v1.Buildr.Repo
(*TaskLog_LogAttribute)(nil), // 15: buildr.rpc.v1.TaskLog.LogAttribute (*TaskLog_LogAttribute)(nil), // 15: buildr.rpc.v1.TaskLog.LogAttribute
(*ModuleReference)(nil), // 16: buildr.rpc.v1.ModuleReference (*PluginInventory_InventorySpec)(nil), // 16: buildr.rpc.v1.PluginInventory.InventorySpec
(*ModuleSpec)(nil), // 17: buildr.rpc.v1.ModuleSpec (*ModuleReference)(nil), // 17: buildr.rpc.v1.ModuleReference
(*ModuleSpec)(nil), // 18: buildr.rpc.v1.ModuleSpec
} }
var file_rpc_v1_executor_proto_depIdxs = []int32{ var file_rpc_v1_executor_proto_depIdxs = []int32{
14, // 0: buildr.rpc.v1.Buildr.repo:type_name -> buildr.rpc.v1.Buildr.Repo 14, // 0: buildr.rpc.v1.Buildr.repo:type_name -> buildr.rpc.v1.Buildr.Repo
16, // 1: buildr.rpc.v1.TaskReference.module:type_name -> buildr.rpc.v1.ModuleReference 17, // 1: buildr.rpc.v1.TaskReference.module:type_name -> buildr.rpc.v1.ModuleReference
2, // 2: buildr.rpc.v1.StartTaskRequest.reference:type_name -> buildr.rpc.v1.TaskReference 2, // 2: buildr.rpc.v1.StartTaskRequest.reference:type_name -> buildr.rpc.v1.TaskReference
1, // 3: buildr.rpc.v1.StartTaskRequest.buildr:type_name -> buildr.rpc.v1.Buildr 1, // 3: buildr.rpc.v1.StartTaskRequest.buildr:type_name -> buildr.rpc.v1.Buildr
17, // 4: buildr.rpc.v1.StartTaskRequest.spec:type_name -> buildr.rpc.v1.ModuleSpec 18, // 4: buildr.rpc.v1.StartTaskRequest.spec:type_name -> buildr.rpc.v1.ModuleSpec
0, // 5: buildr.rpc.v1.TaskOutput.source:type_name -> buildr.rpc.v1.TaskOutputSource 0, // 5: buildr.rpc.v1.TaskOutput.source:type_name -> buildr.rpc.v1.TaskOutputSource
15, // 6: buildr.rpc.v1.TaskLog.attributes:type_name -> buildr.rpc.v1.TaskLog.LogAttribute 15, // 6: buildr.rpc.v1.TaskLog.attributes:type_name -> buildr.rpc.v1.TaskLog.LogAttribute
16, // 7: buildr.rpc.v1.PluginInventory.modules:type_name -> buildr.rpc.v1.ModuleReference 16, // 7: buildr.rpc.v1.PluginInventory.specs:type_name -> buildr.rpc.v1.PluginInventory.InventorySpec
3, // 8: buildr.rpc.v1.ExecutionClientMessage.start_task:type_name -> buildr.rpc.v1.StartTaskRequest 3, // 8: buildr.rpc.v1.ExecutionClientMessage.start_task:type_name -> buildr.rpc.v1.StartTaskRequest
9, // 9: buildr.rpc.v1.ExecutionClientMessage.get_state:type_name -> buildr.rpc.v1.GetStateResponse 9, // 9: buildr.rpc.v1.ExecutionClientMessage.get_state:type_name -> buildr.rpc.v1.GetStateResponse
10, // 10: buildr.rpc.v1.ExecutionClientMessage.error:type_name -> buildr.rpc.v1.Result 10, // 10: buildr.rpc.v1.ExecutionClientMessage.error:type_name -> buildr.rpc.v1.Result
@ -1301,13 +1364,14 @@ var file_rpc_v1_executor_proto_depIdxs = []int32{
5, // 13: buildr.rpc.v1.ExecutionServerMessage.task_output:type_name -> buildr.rpc.v1.TaskOutput 5, // 13: buildr.rpc.v1.ExecutionServerMessage.task_output:type_name -> buildr.rpc.v1.TaskOutput
8, // 14: buildr.rpc.v1.ExecutionServerMessage.get_state:type_name -> buildr.rpc.v1.GetStateRequest 8, // 14: buildr.rpc.v1.ExecutionServerMessage.get_state:type_name -> buildr.rpc.v1.GetStateRequest
7, // 15: buildr.rpc.v1.ExecutionServerMessage.set_state:type_name -> buildr.rpc.v1.SetState 7, // 15: buildr.rpc.v1.ExecutionServerMessage.set_state:type_name -> buildr.rpc.v1.SetState
12, // 16: buildr.rpc.v1.ExecutorService.ExecuteStream:input_type -> buildr.rpc.v1.ExecutionClientMessage 17, // 16: buildr.rpc.v1.PluginInventory.InventorySpec.module_ref:type_name -> buildr.rpc.v1.ModuleReference
13, // 17: buildr.rpc.v1.ExecutorService.ExecuteStream:output_type -> buildr.rpc.v1.ExecutionServerMessage 12, // 17: buildr.rpc.v1.ExecutorService.ExecuteStream:input_type -> buildr.rpc.v1.ExecutionClientMessage
17, // [17:18] is the sub-list for method output_type 13, // 18: buildr.rpc.v1.ExecutorService.ExecuteStream:output_type -> buildr.rpc.v1.ExecutionServerMessage
16, // [16:17] is the sub-list for method input_type 18, // [18:19] is the sub-list for method output_type
16, // [16:16] is the sub-list for extension type_name 17, // [17:18] is the sub-list for method input_type
16, // [16:16] is the sub-list for extension extendee 17, // [17:17] is the sub-list for extension type_name
0, // [0:16] is the sub-list for field type_name 17, // [17:17] is the sub-list for extension extendee
0, // [0:17] is the sub-list for field type_name
} }
func init() { file_rpc_v1_executor_proto_init() } func init() { file_rpc_v1_executor_proto_init() }
@ -1497,6 +1561,18 @@ func file_rpc_v1_executor_proto_init() {
return nil return nil
} }
} }
file_rpc_v1_executor_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*PluginInventory_InventorySpec); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
} }
file_rpc_v1_executor_proto_msgTypes[11].OneofWrappers = []interface{}{ file_rpc_v1_executor_proto_msgTypes[11].OneofWrappers = []interface{}{
(*ExecutionClientMessage_MessageId)(nil), (*ExecutionClientMessage_MessageId)(nil),
@ -1520,7 +1596,7 @@ func file_rpc_v1_executor_proto_init() {
GoPackagePath: reflect.TypeOf(x{}).PkgPath(), GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: file_rpc_v1_executor_proto_rawDesc, RawDescriptor: file_rpc_v1_executor_proto_rawDesc,
NumEnums: 1, NumEnums: 1,
NumMessages: 15, NumMessages: 16,
NumExtensions: 0, NumExtensions: 0,
NumServices: 1, NumServices: 1,
}, },

205
generated/rpc/v1/executor_vtproto.pb.go
View file

@ -619,6 +619,56 @@ func (m *Result) MarshalToSizedBufferVT(dAtA []byte) (int, error) {
return len(dAtA) - i, nil return len(dAtA) - i, nil
} }
func (m *PluginInventory_InventorySpec) MarshalVT() (dAtA []byte, err error) {
if m == nil {
return nil, nil
}
size := m.SizeVT()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBufferVT(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *PluginInventory_InventorySpec) MarshalToVT(dAtA []byte) (int, error) {
size := m.SizeVT()
return m.MarshalToSizedBufferVT(dAtA[:size])
}
func (m *PluginInventory_InventorySpec) MarshalToSizedBufferVT(dAtA []byte) (int, error) {
if m == nil {
return 0, nil
}
i := len(dAtA)
_ = i
var l int
_ = l
if m.unknownFields != nil {
i -= len(m.unknownFields)
copy(dAtA[i:], m.unknownFields)
}
if len(m.EmptySpec) > 0 {
i -= len(m.EmptySpec)
copy(dAtA[i:], m.EmptySpec)
i = encodeVarint(dAtA, i, uint64(len(m.EmptySpec)))
i--
dAtA[i] = 0x12
}
if m.ModuleRef != nil {
size, err := m.ModuleRef.MarshalToSizedBufferVT(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarint(dAtA, i, uint64(size))
i--
dAtA[i] = 0xa
}
return len(dAtA) - i, nil
}
func (m *PluginInventory) MarshalVT() (dAtA []byte, err error) { func (m *PluginInventory) MarshalVT() (dAtA []byte, err error) {
if m == nil { if m == nil {
return nil, nil return nil, nil
@ -649,9 +699,9 @@ func (m *PluginInventory) MarshalToSizedBufferVT(dAtA []byte) (int, error) {
i -= len(m.unknownFields) i -= len(m.unknownFields)
copy(dAtA[i:], m.unknownFields) copy(dAtA[i:], m.unknownFields)
} }
if len(m.Modules) > 0 { if len(m.Specs) > 0 {
for iNdEx := len(m.Modules) - 1; iNdEx >= 0; iNdEx-- { for iNdEx := len(m.Specs) - 1; iNdEx >= 0; iNdEx-- {
size, err := m.Modules[iNdEx].MarshalToSizedBufferVT(dAtA[:i]) size, err := m.Specs[iNdEx].MarshalToSizedBufferVT(dAtA[:i])
if err != nil { if err != nil {
return 0, err return 0, err
} }
@ -1200,14 +1250,32 @@ func (m *Result) SizeVT() (n int) {
return n return n
} }
func (m *PluginInventory_InventorySpec) SizeVT() (n int) {
if m == nil {
return 0
}
var l int
_ = l
if m.ModuleRef != nil {
l = m.ModuleRef.SizeVT()
n += 1 + l + sov(uint64(l))
}
l = len(m.EmptySpec)
if l > 0 {
n += 1 + l + sov(uint64(l))
}
n += len(m.unknownFields)
return n
}
func (m *PluginInventory) SizeVT() (n int) { func (m *PluginInventory) SizeVT() (n int) {
if m == nil { if m == nil {
return 0 return 0
} }
var l int var l int
_ = l _ = l
if len(m.Modules) > 0 { if len(m.Specs) > 0 {
for _, e := range m.Modules { for _, e := range m.Specs {
l = e.SizeVT() l = e.SizeVT()
n += 1 + l + sov(uint64(l)) n += 1 + l + sov(uint64(l))
} }
@ -2843,6 +2911,127 @@ func (m *Result) UnmarshalVT(dAtA []byte) error {
} }
return nil return nil
} }
func (m *PluginInventory_InventorySpec) UnmarshalVT(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflow
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: PluginInventory_InventorySpec: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: PluginInventory_InventorySpec: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ModuleRef", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflow
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLength
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLength
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.ModuleRef == nil {
m.ModuleRef = &ModuleReference{}
}
if err := m.ModuleRef.UnmarshalVT(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field EmptySpec", wireType)
}
var byteLen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflow
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
byteLen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if byteLen < 0 {
return ErrInvalidLength
}
postIndex := iNdEx + byteLen
if postIndex < 0 {
return ErrInvalidLength
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.EmptySpec = append(m.EmptySpec[:0], dAtA[iNdEx:postIndex]...)
if m.EmptySpec == nil {
m.EmptySpec = []byte{}
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skip(dAtA[iNdEx:])
if err != nil {
return err
}
if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLength
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.unknownFields = append(m.unknownFields, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *PluginInventory) UnmarshalVT(dAtA []byte) error { func (m *PluginInventory) UnmarshalVT(dAtA []byte) error {
l := len(dAtA) l := len(dAtA)
iNdEx := 0 iNdEx := 0
@ -2874,7 +3063,7 @@ func (m *PluginInventory) UnmarshalVT(dAtA []byte) error {
switch fieldNum { switch fieldNum {
case 1: case 1:
if wireType != 2 { if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Modules", wireType) return fmt.Errorf("proto: wrong wireType = %d for field Specs", wireType)
} }
var msglen int var msglen int
for shift := uint(0); ; shift += 7 { for shift := uint(0); ; shift += 7 {
@ -2901,8 +3090,8 @@ func (m *PluginInventory) UnmarshalVT(dAtA []byte) error {
if postIndex > l { if postIndex > l {
return io.ErrUnexpectedEOF return io.ErrUnexpectedEOF
} }
m.Modules = append(m.Modules, &ModuleReference{}) m.Specs = append(m.Specs, &PluginInventory_InventorySpec{})
if err := m.Modules[len(m.Modules)-1].UnmarshalVT(dAtA[iNdEx:postIndex]); err != nil { if err := m.Specs[len(m.Specs)-1].UnmarshalVT(dAtA[iNdEx:postIndex]); err != nil {
return err return err
} }
iNdEx = postIndex iNdEx = postIndex

2
go.mod
View file

@ -14,5 +14,5 @@ require (
golang.org/x/net v0.14.0 // indirect golang.org/x/net v0.14.0 // indirect
golang.org/x/sys v0.11.0 // indirect golang.org/x/sys v0.11.0 // indirect
golang.org/x/text v0.12.0 // indirect golang.org/x/text v0.12.0 // indirect
google.golang.org/genproto/googleapis/rpc v0.0.0-20230815205213-6bfd019c3878 // indirect google.golang.org/genproto/googleapis/rpc v0.0.0-20230822172742-b8732ec3820d // indirect
) )

4
go.sum
View file

@ -11,8 +11,8 @@ golang.org/x/sys v0.11.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
golang.org/x/text v0.12.0 h1:k+n5B8goJNdU7hSvEtMUz3d1Q6D/XW4COJSJR6fN0mc= golang.org/x/text v0.12.0 h1:k+n5B8goJNdU7hSvEtMUz3d1Q6D/XW4COJSJR6fN0mc=
golang.org/x/text v0.12.0/go.mod h1:TvPlkZtksWOMsz7fbANvkp4WM8x/WCo/om8BMLbz+aE= golang.org/x/text v0.12.0/go.mod h1:TvPlkZtksWOMsz7fbANvkp4WM8x/WCo/om8BMLbz+aE=
golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
google.golang.org/genproto/googleapis/rpc v0.0.0-20230815205213-6bfd019c3878 h1:lv6/DhyiFFGsmzxbsUUTOkN29II+zeWHxvT8Lpdxsv0= google.golang.org/genproto/googleapis/rpc v0.0.0-20230822172742-b8732ec3820d h1:uvYuEyMHKNt+lT4K3bN6fGswmK8qSvcreM3BwjDh+y4=
google.golang.org/genproto/googleapis/rpc v0.0.0-20230815205213-6bfd019c3878/go.mod h1:+Bk1OCOj40wS2hwAMA+aCW9ypzm63QTBBHp6lQ3p+9M= google.golang.org/genproto/googleapis/rpc v0.0.0-20230822172742-b8732ec3820d/go.mod h1:+Bk1OCOj40wS2hwAMA+aCW9ypzm63QTBBHp6lQ3p+9M=
google.golang.org/grpc v1.57.0 h1:kfzNeI/klCGD2YPMUlaGNT3pxvYfga7smW3Vth8Zsiw= google.golang.org/grpc v1.57.0 h1:kfzNeI/klCGD2YPMUlaGNT3pxvYfga7smW3Vth8Zsiw=
google.golang.org/grpc v1.57.0/go.mod h1:Sd+9RMTACXwmub0zcNY2c4arhtrbBYD1AUHI/dt16Mo= google.golang.org/grpc v1.57.0/go.mod h1:Sd+9RMTACXwmub0zcNY2c4arhtrbBYD1AUHI/dt16Mo=
google.golang.org/protobuf v1.26.0-rc.1/go.mod h1:jlhhOSvTdKEhbULTjvd4ARK9grFBp09yW+WbY/TyQbw= google.golang.org/protobuf v1.26.0-rc.1/go.mod h1:jlhhOSvTdKEhbULTjvd4ARK9grFBp09yW+WbY/TyQbw=

18
renovate.json Normal file
View file

@ -0,0 +1,18 @@
{
"$schema": "https://docs.renovatebot.com/renovate-schema.json",
"extends": [
":dependencyDashboard",
":ignoreModulesAndTests",
":semanticPrefixFixDepsChoreOthers",
":autodetectPinVersions",
":prHourlyLimit2",
":prConcurrentLimit10",
"group:monorepos",
"group:recommended",
"workarounds:all"
],
"postUpdateOptions": [
"gomodTidy1.17",
"gomodUpdateImportPaths"
]
}

116
rpc/v1/executor.proto
View file

@ -5,106 +5,110 @@ package buildr.rpc.v1;
import "rpc/v1/spec.proto"; import "rpc/v1/spec.proto";
message Buildr { message Buildr {
message Repo { message Repo {
string root = 1; string root = 1;
} }
Repo repo = 1; Repo repo = 1;
string bin_dir = 2; string bin_dir = 2;
string out_dir = 3; string out_dir = 3;
} }
message TaskReference { message TaskReference {
string id = 1; string id = 1;
string name = 2; string name = 2;
ModuleReference module = 3; ModuleReference module = 3;
} }
message StartTaskRequest { message StartTaskRequest {
TaskReference reference = 1; TaskReference reference = 1;
Buildr buildr = 2; Buildr buildr = 2;
ModuleSpec spec = 3; ModuleSpec spec = 3;
} }
message TaskResult { message TaskResult {
string error = 1; string error = 1;
string modified_files_archive_path = 2; string modified_files_archive_path = 2;
} }
enum TaskOutputSource { enum TaskOutputSource {
TASK_OUTPUT_SOURCE_UNSPECIFIED = 0; TASK_OUTPUT_SOURCE_UNSPECIFIED = 0;
TASK_OUTPUT_SOURCE_STDOUT = 1; TASK_OUTPUT_SOURCE_STDOUT = 1;
TASK_OUTPUT_SOURCE_STDERR = 2; TASK_OUTPUT_SOURCE_STDERR = 2;
} }
message TaskOutput { message TaskOutput {
TaskOutputSource source = 1; TaskOutputSource source = 1;
bytes payload = 2; bytes payload = 2;
} }
message TaskLog { message TaskLog {
message LogAttribute { message LogAttribute {
string key = 1; string key = 1;
string value = 2; string value = 2;
} }
int64 time = 1; int64 time = 1;
string message = 2; string message = 2;
int32 level = 3; int32 level = 3;
repeated LogAttribute attributes = 4; repeated LogAttribute attributes = 4;
} }
message SetState { message SetState {
bytes key = 1; bytes key = 1;
bytes data = 2; bytes data = 2;
} }
message GetStateRequest { message GetStateRequest {
bytes key = 1; bytes key = 1;
} }
message GetStateResponse { message GetStateResponse {
bytes key = 1; bytes key = 1;
bytes data = 2; bytes data = 2;
} }
message Result { message Result {
bool success = 1; bool success = 1;
string error = 2; string error = 2;
} }
message PluginInventory { message PluginInventory {
repeated ModuleReference modules = 1; message InventorySpec {
ModuleReference module_ref = 1;
bytes empty_spec = 2;
}
repeated InventorySpec specs = 1;
} }
message ExecutionClientMessage { message ExecutionClientMessage {
oneof meta { oneof meta {
bytes message_id = 1; bytes message_id = 1;
bytes replies_to = 2; bytes replies_to = 2;
} }
oneof envelope { oneof envelope {
StartTaskRequest start_task = 11; StartTaskRequest start_task = 11;
GetStateResponse get_state = 12; GetStateResponse get_state = 12;
Result error = 13; Result error = 13;
} }
} }
message ExecutionServerMessage { message ExecutionServerMessage {
oneof meta { oneof meta {
bytes message_id = 1; bytes message_id = 1;
bytes replies_to = 2; bytes replies_to = 2;
} }
oneof envelope { oneof envelope {
TaskResult task_result = 11; TaskResult task_result = 11;
TaskLog task_log = 12; TaskLog task_log = 12;
TaskOutput task_output = 13; TaskOutput task_output = 13;
GetStateRequest get_state = 14; GetStateRequest get_state = 14;
SetState set_state = 15; SetState set_state = 15;
} }
} }
service ExecutorService { service ExecutorService {
rpc ExecuteStream(stream ExecutionClientMessage) returns (stream ExecutionServerMessage); rpc ExecuteStream(stream ExecutionClientMessage) returns (stream ExecutionServerMessage);
} }