diff --git a/workflows/go/generate.go b/workflows/go/generate.go index b44e2ac4..773ea9e5 100644 --- a/workflows/go/generate.go +++ b/workflows/go/generate.go @@ -11,5 +11,20 @@ package workflows //go:generate protoc --proto_path=../ --go_out=./ --go_opt=module=github.com/smartcontractkit/chainlink-protos/workflows/go ../workflows/v1/workflow_started.proto //go:generate protoc --proto_path=../ --go_out=./ --go_opt=module=github.com/smartcontractkit/chainlink-protos/workflows/go ../workflows/v1/workflow_status_changed.proto //go:generate protoc --proto_path=../ --go_out=./ --go_opt=module=github.com/smartcontractkit/chainlink-protos/workflows/go ../common/v1/base_message.proto -//go:generate protoc --proto_path=../ --go_out=./ --go_opt=module=github.com/smartcontractkit/chainlink-protos/workflows/go ../workflows/v2/operational_events.proto + +// v2 operational events +//go:generate protoc --proto_path=../ --go_out=./ --go_opt=module=github.com/smartcontractkit/chainlink-protos/workflows/go ../workflows/v2/execution_status.proto +//go:generate protoc --proto_path=../ --go_out=./ --go_opt=module=github.com/smartcontractkit/chainlink-protos/workflows/go ../workflows/v2/cre_info.proto +//go:generate protoc --proto_path=../ --go_out=./ --go_opt=module=github.com/smartcontractkit/chainlink-protos/workflows/go ../workflows/v2/workflow_key.proto +//go:generate protoc --proto_path=../ --go_out=./ --go_opt=module=github.com/smartcontractkit/chainlink-protos/workflows/go ../workflows/v2/transaction_info.proto +//go:generate protoc --proto_path=../ --go_out=./ --go_opt=module=github.com/smartcontractkit/chainlink-protos/workflows/go ../workflows/v2/workflow.proto +//go:generate protoc --proto_path=../ --go_out=./ --go_opt=module=github.com/smartcontractkit/chainlink-protos/workflows/go ../workflows/v2/workflow_deployed.proto +//go:generate protoc --proto_path=../ --go_out=./ --go_opt=module=github.com/smartcontractkit/chainlink-protos/workflows/go ../workflows/v2/workflow_updated.proto +//go:generate protoc --proto_path=../ --go_out=./ --go_opt=module=github.com/smartcontractkit/chainlink-protos/workflows/go ../workflows/v2/workflow_deleted.proto +//go:generate protoc --proto_path=../ --go_out=./ --go_opt=module=github.com/smartcontractkit/chainlink-protos/workflows/go ../workflows/v2/trigger_execution_started.proto +//go:generate protoc --proto_path=../ --go_out=./ --go_opt=module=github.com/smartcontractkit/chainlink-protos/workflows/go ../workflows/v2/workflow_execution_started.proto +//go:generate protoc --proto_path=../ --go_out=./ --go_opt=module=github.com/smartcontractkit/chainlink-protos/workflows/go ../workflows/v2/workflow_execution_finished.proto +//go:generate protoc --proto_path=../ --go_out=./ --go_opt=module=github.com/smartcontractkit/chainlink-protos/workflows/go ../workflows/v2/capability_execution_started.proto +//go:generate protoc --proto_path=../ --go_out=./ --go_opt=module=github.com/smartcontractkit/chainlink-protos/workflows/go ../workflows/v2/capability_execution_finished.proto + // do not include deprecated workflows/pb/base_message_legacy.proto diff --git a/workflows/go/v2/capability_execution_finished.pb.go b/workflows/go/v2/capability_execution_finished.pb.go new file mode 100644 index 00000000..668df448 --- /dev/null +++ b/workflows/go/v2/capability_execution_finished.pb.go @@ -0,0 +1,185 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// versions: +// protoc-gen-go v1.36.6 +// protoc v5.29.3 +// source: workflows/v2/capability_execution_finished.proto + +package v2 + +import ( + protoreflect "google.golang.org/protobuf/reflect/protoreflect" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" + reflect "reflect" + sync "sync" + unsafe "unsafe" +) + +const ( + // Verify that this generated code is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) + // Verify that runtime/protoimpl is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) +) + +type CapabilityExecutionFinished struct { + state protoimpl.MessageState `protogen:"open.v1"` + CreInfo *CreInfo `protobuf:"bytes,1,opt,name=creInfo,proto3" json:"creInfo,omitempty"` + Workflow *WorkflowKey `protobuf:"bytes,2,opt,name=workflow,proto3" json:"workflow,omitempty"` + WorkflowExecutionID string `protobuf:"bytes,3,opt,name=workflowExecutionID,proto3" json:"workflowExecutionID,omitempty"` + Timestamp string `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"` + CapabilityID string `protobuf:"bytes,5,opt,name=capabilityID,proto3" json:"capabilityID,omitempty"` + StepRef int32 `protobuf:"varint,6,opt,name=stepRef,proto3" json:"stepRef,omitempty"` + Status ExecutionStatus `protobuf:"varint,7,opt,name=status,proto3,enum=workflows.v2.ExecutionStatus" json:"status,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *CapabilityExecutionFinished) Reset() { + *x = CapabilityExecutionFinished{} + mi := &file_workflows_v2_capability_execution_finished_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *CapabilityExecutionFinished) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*CapabilityExecutionFinished) ProtoMessage() {} + +func (x *CapabilityExecutionFinished) ProtoReflect() protoreflect.Message { + mi := &file_workflows_v2_capability_execution_finished_proto_msgTypes[0] + if x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use CapabilityExecutionFinished.ProtoReflect.Descriptor instead. +func (*CapabilityExecutionFinished) Descriptor() ([]byte, []int) { + return file_workflows_v2_capability_execution_finished_proto_rawDescGZIP(), []int{0} +} + +func (x *CapabilityExecutionFinished) GetCreInfo() *CreInfo { + if x != nil { + return x.CreInfo + } + return nil +} + +func (x *CapabilityExecutionFinished) GetWorkflow() *WorkflowKey { + if x != nil { + return x.Workflow + } + return nil +} + +func (x *CapabilityExecutionFinished) GetWorkflowExecutionID() string { + if x != nil { + return x.WorkflowExecutionID + } + return "" +} + +func (x *CapabilityExecutionFinished) GetTimestamp() string { + if x != nil { + return x.Timestamp + } + return "" +} + +func (x *CapabilityExecutionFinished) GetCapabilityID() string { + if x != nil { + return x.CapabilityID + } + return "" +} + +func (x *CapabilityExecutionFinished) GetStepRef() int32 { + if x != nil { + return x.StepRef + } + return 0 +} + +func (x *CapabilityExecutionFinished) GetStatus() ExecutionStatus { + if x != nil { + return x.Status + } + return ExecutionStatus_EXECUTION_STATUS_UNSPECIFIED +} + +var File_workflows_v2_capability_execution_finished_proto protoreflect.FileDescriptor + +const file_workflows_v2_capability_execution_finished_proto_rawDesc = "" + + "\n" + + "0workflows/v2/capability_execution_finished.proto\x12\fworkflows.v2\x1a\x1bworkflows/v2/cre_info.proto\x1a\x1fworkflows/v2/workflow_key.proto\x1a#workflows/v2/execution_status.proto\"\xca\x02\n" + + "\x1bCapabilityExecutionFinished\x12/\n" + + "\acreInfo\x18\x01 \x01(\v2\x15.workflows.v2.CreInfoR\acreInfo\x125\n" + + "\bworkflow\x18\x02 \x01(\v2\x19.workflows.v2.WorkflowKeyR\bworkflow\x120\n" + + "\x13workflowExecutionID\x18\x03 \x01(\tR\x13workflowExecutionID\x12\x1c\n" + + "\ttimestamp\x18\x04 \x01(\tR\ttimestamp\x12\"\n" + + "\fcapabilityID\x18\x05 \x01(\tR\fcapabilityID\x12\x18\n" + + "\astepRef\x18\x06 \x01(\x05R\astepRef\x125\n" + + "\x06status\x18\a \x01(\x0e2\x1d.workflows.v2.ExecutionStatusR\x06statusB>Z workflows.v2.CreInfo + 2, // 1: workflows.v2.CapabilityExecutionFinished.workflow:type_name -> workflows.v2.WorkflowKey + 3, // 2: workflows.v2.CapabilityExecutionFinished.status:type_name -> workflows.v2.ExecutionStatus + 3, // [3:3] is the sub-list for method output_type + 3, // [3:3] is the sub-list for method input_type + 3, // [3:3] is the sub-list for extension type_name + 3, // [3:3] is the sub-list for extension extendee + 0, // [0:3] is the sub-list for field type_name +} + +func init() { file_workflows_v2_capability_execution_finished_proto_init() } +func file_workflows_v2_capability_execution_finished_proto_init() { + if File_workflows_v2_capability_execution_finished_proto != nil { + return + } + file_workflows_v2_cre_info_proto_init() + file_workflows_v2_workflow_key_proto_init() + file_workflows_v2_execution_status_proto_init() + type x struct{} + out := protoimpl.TypeBuilder{ + File: protoimpl.DescBuilder{ + GoPackagePath: reflect.TypeOf(x{}).PkgPath(), + RawDescriptor: unsafe.Slice(unsafe.StringData(file_workflows_v2_capability_execution_finished_proto_rawDesc), len(file_workflows_v2_capability_execution_finished_proto_rawDesc)), + NumEnums: 0, + NumMessages: 1, + NumExtensions: 0, + NumServices: 0, + }, + GoTypes: file_workflows_v2_capability_execution_finished_proto_goTypes, + DependencyIndexes: file_workflows_v2_capability_execution_finished_proto_depIdxs, + MessageInfos: file_workflows_v2_capability_execution_finished_proto_msgTypes, + }.Build() + File_workflows_v2_capability_execution_finished_proto = out.File + file_workflows_v2_capability_execution_finished_proto_goTypes = nil + file_workflows_v2_capability_execution_finished_proto_depIdxs = nil +} diff --git a/workflows/go/v2/capability_execution_started.pb.go b/workflows/go/v2/capability_execution_started.pb.go new file mode 100644 index 00000000..f69a9431 --- /dev/null +++ b/workflows/go/v2/capability_execution_started.pb.go @@ -0,0 +1,173 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// versions: +// protoc-gen-go v1.36.6 +// protoc v5.29.3 +// source: workflows/v2/capability_execution_started.proto + +package v2 + +import ( + protoreflect "google.golang.org/protobuf/reflect/protoreflect" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" + reflect "reflect" + sync "sync" + unsafe "unsafe" +) + +const ( + // Verify that this generated code is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) + // Verify that runtime/protoimpl is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) +) + +type CapabilityExecutionStarted struct { + state protoimpl.MessageState `protogen:"open.v1"` + CreInfo *CreInfo `protobuf:"bytes,1,opt,name=creInfo,proto3" json:"creInfo,omitempty"` + Workflow *WorkflowKey `protobuf:"bytes,2,opt,name=workflow,proto3" json:"workflow,omitempty"` + WorkflowExecutionID string `protobuf:"bytes,3,opt,name=workflowExecutionID,proto3" json:"workflowExecutionID,omitempty"` + Timestamp string `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"` + CapabilityID string `protobuf:"bytes,5,opt,name=capabilityID,proto3" json:"capabilityID,omitempty"` + StepRef int32 `protobuf:"varint,6,opt,name=stepRef,proto3" json:"stepRef,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *CapabilityExecutionStarted) Reset() { + *x = CapabilityExecutionStarted{} + mi := &file_workflows_v2_capability_execution_started_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *CapabilityExecutionStarted) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*CapabilityExecutionStarted) ProtoMessage() {} + +func (x *CapabilityExecutionStarted) ProtoReflect() protoreflect.Message { + mi := &file_workflows_v2_capability_execution_started_proto_msgTypes[0] + if x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use CapabilityExecutionStarted.ProtoReflect.Descriptor instead. +func (*CapabilityExecutionStarted) Descriptor() ([]byte, []int) { + return file_workflows_v2_capability_execution_started_proto_rawDescGZIP(), []int{0} +} + +func (x *CapabilityExecutionStarted) GetCreInfo() *CreInfo { + if x != nil { + return x.CreInfo + } + return nil +} + +func (x *CapabilityExecutionStarted) GetWorkflow() *WorkflowKey { + if x != nil { + return x.Workflow + } + return nil +} + +func (x *CapabilityExecutionStarted) GetWorkflowExecutionID() string { + if x != nil { + return x.WorkflowExecutionID + } + return "" +} + +func (x *CapabilityExecutionStarted) GetTimestamp() string { + if x != nil { + return x.Timestamp + } + return "" +} + +func (x *CapabilityExecutionStarted) GetCapabilityID() string { + if x != nil { + return x.CapabilityID + } + return "" +} + +func (x *CapabilityExecutionStarted) GetStepRef() int32 { + if x != nil { + return x.StepRef + } + return 0 +} + +var File_workflows_v2_capability_execution_started_proto protoreflect.FileDescriptor + +const file_workflows_v2_capability_execution_started_proto_rawDesc = "" + + "\n" + + "/workflows/v2/capability_execution_started.proto\x12\fworkflows.v2\x1a\x1bworkflows/v2/cre_info.proto\x1a\x1fworkflows/v2/workflow_key.proto\"\x92\x02\n" + + "\x1aCapabilityExecutionStarted\x12/\n" + + "\acreInfo\x18\x01 \x01(\v2\x15.workflows.v2.CreInfoR\acreInfo\x125\n" + + "\bworkflow\x18\x02 \x01(\v2\x19.workflows.v2.WorkflowKeyR\bworkflow\x120\n" + + "\x13workflowExecutionID\x18\x03 \x01(\tR\x13workflowExecutionID\x12\x1c\n" + + "\ttimestamp\x18\x04 \x01(\tR\ttimestamp\x12\"\n" + + "\fcapabilityID\x18\x05 \x01(\tR\fcapabilityID\x12\x18\n" + + "\astepRef\x18\x06 \x01(\x05R\astepRefB>Z workflows.v2.CreInfo + 2, // 1: workflows.v2.CapabilityExecutionStarted.workflow:type_name -> workflows.v2.WorkflowKey + 2, // [2:2] is the sub-list for method output_type + 2, // [2:2] is the sub-list for method input_type + 2, // [2:2] is the sub-list for extension type_name + 2, // [2:2] is the sub-list for extension extendee + 0, // [0:2] is the sub-list for field type_name +} + +func init() { file_workflows_v2_capability_execution_started_proto_init() } +func file_workflows_v2_capability_execution_started_proto_init() { + if File_workflows_v2_capability_execution_started_proto != nil { + return + } + file_workflows_v2_cre_info_proto_init() + file_workflows_v2_workflow_key_proto_init() + type x struct{} + out := protoimpl.TypeBuilder{ + File: protoimpl.DescBuilder{ + GoPackagePath: reflect.TypeOf(x{}).PkgPath(), + RawDescriptor: unsafe.Slice(unsafe.StringData(file_workflows_v2_capability_execution_started_proto_rawDesc), len(file_workflows_v2_capability_execution_started_proto_rawDesc)), + NumEnums: 0, + NumMessages: 1, + NumExtensions: 0, + NumServices: 0, + }, + GoTypes: file_workflows_v2_capability_execution_started_proto_goTypes, + DependencyIndexes: file_workflows_v2_capability_execution_started_proto_depIdxs, + MessageInfos: file_workflows_v2_capability_execution_started_proto_msgTypes, + }.Build() + File_workflows_v2_capability_execution_started_proto = out.File + file_workflows_v2_capability_execution_started_proto_goTypes = nil + file_workflows_v2_capability_execution_started_proto_depIdxs = nil +} diff --git a/workflows/go/v2/cre_info.pb.go b/workflows/go/v2/cre_info.pb.go new file mode 100644 index 00000000..1a364aba --- /dev/null +++ b/workflows/go/v2/cre_info.pb.go @@ -0,0 +1,206 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// versions: +// protoc-gen-go v1.36.6 +// protoc v5.29.3 +// source: workflows/v2/cre_info.proto + +package v2 + +import ( + protoreflect "google.golang.org/protobuf/reflect/protoreflect" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" + reflect "reflect" + sync "sync" + unsafe "unsafe" +) + +const ( + // Verify that this generated code is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) + // Verify that runtime/protoimpl is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) +) + +type CreInfo struct { + state protoimpl.MessageState `protogen:"open.v1"` + DonID int32 `protobuf:"varint,1,opt,name=donID,proto3" json:"donID,omitempty"` + DonF int32 `protobuf:"varint,2,opt,name=donF,proto3" json:"donF,omitempty"` + DonN int32 `protobuf:"varint,3,opt,name=donN,proto3" json:"donN,omitempty"` + P2PID string `protobuf:"bytes,4,opt,name=p2pID,proto3" json:"p2pID,omitempty"` + WorkflowRegistryAddress string `protobuf:"bytes,5,opt,name=workflowRegistryAddress,proto3" json:"workflowRegistryAddress,omitempty"` + WorkflowRegistryVersion string `protobuf:"bytes,6,opt,name=workflowRegistryVersion,proto3" json:"workflowRegistryVersion,omitempty"` + WorkflowRegistryChain string `protobuf:"bytes,7,opt,name=workflowRegistryChain,proto3" json:"workflowRegistryChain,omitempty"` + EngineVersion string `protobuf:"bytes,8,opt,name=engineVersion,proto3" json:"engineVersion,omitempty"` + CapabilitiesRegistryVersion string `protobuf:"bytes,9,opt,name=capabilitiesRegistryVersion,proto3" json:"capabilitiesRegistryVersion,omitempty"` + DonVersion string `protobuf:"bytes,10,opt,name=donVersion,proto3" json:"donVersion,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *CreInfo) Reset() { + *x = CreInfo{} + mi := &file_workflows_v2_cre_info_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *CreInfo) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*CreInfo) ProtoMessage() {} + +func (x *CreInfo) ProtoReflect() protoreflect.Message { + mi := &file_workflows_v2_cre_info_proto_msgTypes[0] + if x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use CreInfo.ProtoReflect.Descriptor instead. +func (*CreInfo) Descriptor() ([]byte, []int) { + return file_workflows_v2_cre_info_proto_rawDescGZIP(), []int{0} +} + +func (x *CreInfo) GetDonID() int32 { + if x != nil { + return x.DonID + } + return 0 +} + +func (x *CreInfo) GetDonF() int32 { + if x != nil { + return x.DonF + } + return 0 +} + +func (x *CreInfo) GetDonN() int32 { + if x != nil { + return x.DonN + } + return 0 +} + +func (x *CreInfo) GetP2PID() string { + if x != nil { + return x.P2PID + } + return "" +} + +func (x *CreInfo) GetWorkflowRegistryAddress() string { + if x != nil { + return x.WorkflowRegistryAddress + } + return "" +} + +func (x *CreInfo) GetWorkflowRegistryVersion() string { + if x != nil { + return x.WorkflowRegistryVersion + } + return "" +} + +func (x *CreInfo) GetWorkflowRegistryChain() string { + if x != nil { + return x.WorkflowRegistryChain + } + return "" +} + +func (x *CreInfo) GetEngineVersion() string { + if x != nil { + return x.EngineVersion + } + return "" +} + +func (x *CreInfo) GetCapabilitiesRegistryVersion() string { + if x != nil { + return x.CapabilitiesRegistryVersion + } + return "" +} + +func (x *CreInfo) GetDonVersion() string { + if x != nil { + return x.DonVersion + } + return "" +} + +var File_workflows_v2_cre_info_proto protoreflect.FileDescriptor + +const file_workflows_v2_cre_info_proto_rawDesc = "" + + "\n" + + "\x1bworkflows/v2/cre_info.proto\x12\fworkflows.v2\"\x8f\x03\n" + + "\aCreInfo\x12\x14\n" + + "\x05donID\x18\x01 \x01(\x05R\x05donID\x12\x12\n" + + "\x04donF\x18\x02 \x01(\x05R\x04donF\x12\x12\n" + + "\x04donN\x18\x03 \x01(\x05R\x04donN\x12\x14\n" + + "\x05p2pID\x18\x04 \x01(\tR\x05p2pID\x128\n" + + "\x17workflowRegistryAddress\x18\x05 \x01(\tR\x17workflowRegistryAddress\x128\n" + + "\x17workflowRegistryVersion\x18\x06 \x01(\tR\x17workflowRegistryVersion\x124\n" + + "\x15workflowRegistryChain\x18\a \x01(\tR\x15workflowRegistryChain\x12$\n" + + "\rengineVersion\x18\b \x01(\tR\rengineVersion\x12@\n" + + "\x1bcapabilitiesRegistryVersion\x18\t \x01(\tR\x1bcapabilitiesRegistryVersion\x12\x1e\n" + + "\n" + + "donVersion\x18\n" + + " \x01(\tR\n" + + "donVersionB>ZZZ workflows.v2.WorkflowKey - 1, // 1: workflows.v2.WorkflowDeployed.creInfo:type_name -> workflows.v2.CREInfo - 3, // 2: workflows.v2.WorkflowDeployed.txInfo:type_name -> workflows.v2.TransactionInfo - 4, // 3: workflows.v2.WorkflowDeployed.workflow:type_name -> workflows.v2.Workflow - 13, // 4: workflows.v2.WorkflowDeployed.errorMessage:type_name -> google.protobuf.StringValue - 1, // 5: workflows.v2.WorkflowUpdated.creInfo:type_name -> workflows.v2.CREInfo - 3, // 6: workflows.v2.WorkflowUpdated.txInfo:type_name -> workflows.v2.TransactionInfo - 4, // 7: workflows.v2.WorkflowUpdated.workflow:type_name -> workflows.v2.Workflow - 13, // 8: workflows.v2.WorkflowUpdated.errorMessage:type_name -> google.protobuf.StringValue - 1, // 9: workflows.v2.WorkflowDeleted.creInfo:type_name -> workflows.v2.CREInfo - 3, // 10: workflows.v2.WorkflowDeleted.txInfo:type_name -> workflows.v2.TransactionInfo - 4, // 11: workflows.v2.WorkflowDeleted.workflow:type_name -> workflows.v2.Workflow - 13, // 12: workflows.v2.WorkflowDeleted.errorMessage:type_name -> google.protobuf.StringValue - 1, // 13: workflows.v2.TriggerExecutionStarted.creInfo:type_name -> workflows.v2.CREInfo - 2, // 14: workflows.v2.TriggerExecutionStarted.workflow:type_name -> workflows.v2.WorkflowKey - 1, // 15: workflows.v2.WorkflowExecutionStarted.creInfo:type_name -> workflows.v2.CREInfo - 2, // 16: workflows.v2.WorkflowExecutionStarted.workflow:type_name -> workflows.v2.WorkflowKey - 1, // 17: workflows.v2.WorkflowExecutionFinished.creInfo:type_name -> workflows.v2.CREInfo - 2, // 18: workflows.v2.WorkflowExecutionFinished.workflow:type_name -> workflows.v2.WorkflowKey - 0, // 19: workflows.v2.WorkflowExecutionFinished.status:type_name -> workflows.v2.ExecutionStatus - 1, // 20: workflows.v2.CapabilityExecutionStarted.creInfo:type_name -> workflows.v2.CREInfo - 2, // 21: workflows.v2.CapabilityExecutionStarted.workflow:type_name -> workflows.v2.WorkflowKey - 1, // 22: workflows.v2.CapabilityExecutionFinished.creInfo:type_name -> workflows.v2.CREInfo - 2, // 23: workflows.v2.CapabilityExecutionFinished.workflow:type_name -> workflows.v2.WorkflowKey - 0, // 24: workflows.v2.CapabilityExecutionFinished.status:type_name -> workflows.v2.ExecutionStatus - 25, // [25:25] is the sub-list for method output_type - 25, // [25:25] is the sub-list for method input_type - 25, // [25:25] is the sub-list for extension type_name - 25, // [25:25] is the sub-list for extension extendee - 0, // [0:25] is the sub-list for field type_name -} - -func init() { file_workflows_v2_operational_events_proto_init() } -func file_workflows_v2_operational_events_proto_init() { - if File_workflows_v2_operational_events_proto != nil { - return - } - type x struct{} - out := protoimpl.TypeBuilder{ - File: protoimpl.DescBuilder{ - GoPackagePath: reflect.TypeOf(x{}).PkgPath(), - RawDescriptor: unsafe.Slice(unsafe.StringData(file_workflows_v2_operational_events_proto_rawDesc), len(file_workflows_v2_operational_events_proto_rawDesc)), - NumEnums: 1, - NumMessages: 12, - NumExtensions: 0, - NumServices: 0, - }, - GoTypes: file_workflows_v2_operational_events_proto_goTypes, - DependencyIndexes: file_workflows_v2_operational_events_proto_depIdxs, - EnumInfos: file_workflows_v2_operational_events_proto_enumTypes, - MessageInfos: file_workflows_v2_operational_events_proto_msgTypes, - }.Build() - File_workflows_v2_operational_events_proto = out.File - file_workflows_v2_operational_events_proto_goTypes = nil - file_workflows_v2_operational_events_proto_depIdxs = nil -} diff --git a/workflows/go/v2/transaction_info.pb.go b/workflows/go/v2/transaction_info.pb.go new file mode 100644 index 00000000..35c297aa --- /dev/null +++ b/workflows/go/v2/transaction_info.pb.go @@ -0,0 +1,140 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// versions: +// protoc-gen-go v1.36.6 +// protoc v5.29.3 +// source: workflows/v2/transaction_info.proto + +package v2 + +import ( + protoreflect "google.golang.org/protobuf/reflect/protoreflect" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" + reflect "reflect" + sync "sync" + unsafe "unsafe" +) + +const ( + // Verify that this generated code is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) + // Verify that runtime/protoimpl is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) +) + +type TransactionInfo struct { + state protoimpl.MessageState `protogen:"open.v1"` + ChainSelector string `protobuf:"bytes,1,opt,name=chainSelector,proto3" json:"chainSelector,omitempty"` + TxHash string `protobuf:"bytes,2,opt,name=txHash,proto3" json:"txHash,omitempty"` + GasCost string `protobuf:"bytes,3,opt,name=gasCost,proto3" json:"gasCost,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *TransactionInfo) Reset() { + *x = TransactionInfo{} + mi := &file_workflows_v2_transaction_info_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *TransactionInfo) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*TransactionInfo) ProtoMessage() {} + +func (x *TransactionInfo) ProtoReflect() protoreflect.Message { + mi := &file_workflows_v2_transaction_info_proto_msgTypes[0] + if x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use TransactionInfo.ProtoReflect.Descriptor instead. +func (*TransactionInfo) Descriptor() ([]byte, []int) { + return file_workflows_v2_transaction_info_proto_rawDescGZIP(), []int{0} +} + +func (x *TransactionInfo) GetChainSelector() string { + if x != nil { + return x.ChainSelector + } + return "" +} + +func (x *TransactionInfo) GetTxHash() string { + if x != nil { + return x.TxHash + } + return "" +} + +func (x *TransactionInfo) GetGasCost() string { + if x != nil { + return x.GasCost + } + return "" +} + +var File_workflows_v2_transaction_info_proto protoreflect.FileDescriptor + +const file_workflows_v2_transaction_info_proto_rawDesc = "" + + "\n" + + "#workflows/v2/transaction_info.proto\x12\fworkflows.v2\"i\n" + + "\x0fTransactionInfo\x12$\n" + + "\rchainSelector\x18\x01 \x01(\tR\rchainSelector\x12\x16\n" + + "\x06txHash\x18\x02 \x01(\tR\x06txHash\x12\x18\n" + + "\agasCost\x18\x03 \x01(\tR\agasCostB>ZZ workflows.v2.CreInfo + 2, // 1: workflows.v2.TriggerExecutionStarted.workflow:type_name -> workflows.v2.WorkflowKey + 2, // [2:2] is the sub-list for method output_type + 2, // [2:2] is the sub-list for method input_type + 2, // [2:2] is the sub-list for extension type_name + 2, // [2:2] is the sub-list for extension extendee + 0, // [0:2] is the sub-list for field type_name +} + +func init() { file_workflows_v2_trigger_execution_started_proto_init() } +func file_workflows_v2_trigger_execution_started_proto_init() { + if File_workflows_v2_trigger_execution_started_proto != nil { + return + } + file_workflows_v2_cre_info_proto_init() + file_workflows_v2_workflow_key_proto_init() + type x struct{} + out := protoimpl.TypeBuilder{ + File: protoimpl.DescBuilder{ + GoPackagePath: reflect.TypeOf(x{}).PkgPath(), + RawDescriptor: unsafe.Slice(unsafe.StringData(file_workflows_v2_trigger_execution_started_proto_rawDesc), len(file_workflows_v2_trigger_execution_started_proto_rawDesc)), + NumEnums: 0, + NumMessages: 1, + NumExtensions: 0, + NumServices: 0, + }, + GoTypes: file_workflows_v2_trigger_execution_started_proto_goTypes, + DependencyIndexes: file_workflows_v2_trigger_execution_started_proto_depIdxs, + MessageInfos: file_workflows_v2_trigger_execution_started_proto_msgTypes, + }.Build() + File_workflows_v2_trigger_execution_started_proto = out.File + file_workflows_v2_trigger_execution_started_proto_goTypes = nil + file_workflows_v2_trigger_execution_started_proto_depIdxs = nil +} diff --git a/workflows/go/v2/workflow.pb.go b/workflows/go/v2/workflow.pb.go new file mode 100644 index 00000000..0fea75dd --- /dev/null +++ b/workflows/go/v2/workflow.pb.go @@ -0,0 +1,152 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// versions: +// protoc-gen-go v1.36.6 +// protoc v5.29.3 +// source: workflows/v2/workflow.proto + +package v2 + +import ( + protoreflect "google.golang.org/protobuf/reflect/protoreflect" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" + reflect "reflect" + sync "sync" + unsafe "unsafe" +) + +const ( + // Verify that this generated code is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) + // Verify that runtime/protoimpl is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) +) + +type Workflow struct { + state protoimpl.MessageState `protogen:"open.v1"` + WorkflowKey *WorkflowKey `protobuf:"bytes,1,opt,name=workflowKey,proto3" json:"workflowKey,omitempty"` + Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` + BinaryURL string `protobuf:"bytes,3,opt,name=binaryURL,proto3" json:"binaryURL,omitempty"` + ConfigURL string `protobuf:"bytes,4,opt,name=configURL,proto3" json:"configURL,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *Workflow) Reset() { + *x = Workflow{} + mi := &file_workflows_v2_workflow_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *Workflow) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*Workflow) ProtoMessage() {} + +func (x *Workflow) ProtoReflect() protoreflect.Message { + mi := &file_workflows_v2_workflow_proto_msgTypes[0] + if x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use Workflow.ProtoReflect.Descriptor instead. +func (*Workflow) Descriptor() ([]byte, []int) { + return file_workflows_v2_workflow_proto_rawDescGZIP(), []int{0} +} + +func (x *Workflow) GetWorkflowKey() *WorkflowKey { + if x != nil { + return x.WorkflowKey + } + return nil +} + +func (x *Workflow) GetVersion() string { + if x != nil { + return x.Version + } + return "" +} + +func (x *Workflow) GetBinaryURL() string { + if x != nil { + return x.BinaryURL + } + return "" +} + +func (x *Workflow) GetConfigURL() string { + if x != nil { + return x.ConfigURL + } + return "" +} + +var File_workflows_v2_workflow_proto protoreflect.FileDescriptor + +const file_workflows_v2_workflow_proto_rawDesc = "" + + "\n" + + "\x1bworkflows/v2/workflow.proto\x12\fworkflows.v2\x1a\x1fworkflows/v2/workflow_key.proto\"\x9d\x01\n" + + "\bWorkflow\x12;\n" + + "\vworkflowKey\x18\x01 \x01(\v2\x19.workflows.v2.WorkflowKeyR\vworkflowKey\x12\x18\n" + + "\aversion\x18\x02 \x01(\tR\aversion\x12\x1c\n" + + "\tbinaryURL\x18\x03 \x01(\tR\tbinaryURL\x12\x1c\n" + + "\tconfigURL\x18\x04 \x01(\tR\tconfigURLB>Z workflows.v2.WorkflowKey + 1, // [1:1] is the sub-list for method output_type + 1, // [1:1] is the sub-list for method input_type + 1, // [1:1] is the sub-list for extension type_name + 1, // [1:1] is the sub-list for extension extendee + 0, // [0:1] is the sub-list for field type_name +} + +func init() { file_workflows_v2_workflow_proto_init() } +func file_workflows_v2_workflow_proto_init() { + if File_workflows_v2_workflow_proto != nil { + return + } + file_workflows_v2_workflow_key_proto_init() + type x struct{} + out := protoimpl.TypeBuilder{ + File: protoimpl.DescBuilder{ + GoPackagePath: reflect.TypeOf(x{}).PkgPath(), + RawDescriptor: unsafe.Slice(unsafe.StringData(file_workflows_v2_workflow_proto_rawDesc), len(file_workflows_v2_workflow_proto_rawDesc)), + NumEnums: 0, + NumMessages: 1, + NumExtensions: 0, + NumServices: 0, + }, + GoTypes: file_workflows_v2_workflow_proto_goTypes, + DependencyIndexes: file_workflows_v2_workflow_proto_depIdxs, + MessageInfos: file_workflows_v2_workflow_proto_msgTypes, + }.Build() + File_workflows_v2_workflow_proto = out.File + file_workflows_v2_workflow_proto_goTypes = nil + file_workflows_v2_workflow_proto_depIdxs = nil +} diff --git a/workflows/go/v2/workflow_deleted.pb.go b/workflows/go/v2/workflow_deleted.pb.go new file mode 100644 index 00000000..f8440198 --- /dev/null +++ b/workflows/go/v2/workflow_deleted.pb.go @@ -0,0 +1,170 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// versions: +// protoc-gen-go v1.36.6 +// protoc v5.29.3 +// source: workflows/v2/workflow_deleted.proto + +package v2 + +import ( + protoreflect "google.golang.org/protobuf/reflect/protoreflect" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" + wrapperspb "google.golang.org/protobuf/types/known/wrapperspb" + reflect "reflect" + sync "sync" + unsafe "unsafe" +) + +const ( + // Verify that this generated code is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) + // Verify that runtime/protoimpl is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) +) + +type WorkflowDeleted struct { + state protoimpl.MessageState `protogen:"open.v1"` + CreInfo *CreInfo `protobuf:"bytes,1,opt,name=creInfo,proto3" json:"creInfo,omitempty"` + Timestamp string `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` + TxInfo *TransactionInfo `protobuf:"bytes,3,opt,name=txInfo,proto3" json:"txInfo,omitempty"` + Workflow *Workflow `protobuf:"bytes,4,opt,name=workflow,proto3" json:"workflow,omitempty"` + ErrorMessage *wrapperspb.StringValue `protobuf:"bytes,5,opt,name=errorMessage,proto3" json:"errorMessage,omitempty"` // present ⇔ failure + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *WorkflowDeleted) Reset() { + *x = WorkflowDeleted{} + mi := &file_workflows_v2_workflow_deleted_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *WorkflowDeleted) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*WorkflowDeleted) ProtoMessage() {} + +func (x *WorkflowDeleted) ProtoReflect() protoreflect.Message { + mi := &file_workflows_v2_workflow_deleted_proto_msgTypes[0] + if x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use WorkflowDeleted.ProtoReflect.Descriptor instead. +func (*WorkflowDeleted) Descriptor() ([]byte, []int) { + return file_workflows_v2_workflow_deleted_proto_rawDescGZIP(), []int{0} +} + +func (x *WorkflowDeleted) GetCreInfo() *CreInfo { + if x != nil { + return x.CreInfo + } + return nil +} + +func (x *WorkflowDeleted) GetTimestamp() string { + if x != nil { + return x.Timestamp + } + return "" +} + +func (x *WorkflowDeleted) GetTxInfo() *TransactionInfo { + if x != nil { + return x.TxInfo + } + return nil +} + +func (x *WorkflowDeleted) GetWorkflow() *Workflow { + if x != nil { + return x.Workflow + } + return nil +} + +func (x *WorkflowDeleted) GetErrorMessage() *wrapperspb.StringValue { + if x != nil { + return x.ErrorMessage + } + return nil +} + +var File_workflows_v2_workflow_deleted_proto protoreflect.FileDescriptor + +const file_workflows_v2_workflow_deleted_proto_rawDesc = "" + + "\n" + + "#workflows/v2/workflow_deleted.proto\x12\fworkflows.v2\x1a\x1egoogle/protobuf/wrappers.proto\x1a\x1bworkflows/v2/cre_info.proto\x1a#workflows/v2/transaction_info.proto\x1a\x1bworkflows/v2/workflow.proto\"\x8d\x02\n" + + "\x0fWorkflowDeleted\x12/\n" + + "\acreInfo\x18\x01 \x01(\v2\x15.workflows.v2.CreInfoR\acreInfo\x12\x1c\n" + + "\ttimestamp\x18\x02 \x01(\tR\ttimestamp\x125\n" + + "\x06txInfo\x18\x03 \x01(\v2\x1d.workflows.v2.TransactionInfoR\x06txInfo\x122\n" + + "\bworkflow\x18\x04 \x01(\v2\x16.workflows.v2.WorkflowR\bworkflow\x12@\n" + + "\ferrorMessage\x18\x05 \x01(\v2\x1c.google.protobuf.StringValueR\ferrorMessageB>Z workflows.v2.CreInfo + 2, // 1: workflows.v2.WorkflowDeleted.txInfo:type_name -> workflows.v2.TransactionInfo + 3, // 2: workflows.v2.WorkflowDeleted.workflow:type_name -> workflows.v2.Workflow + 4, // 3: workflows.v2.WorkflowDeleted.errorMessage:type_name -> google.protobuf.StringValue + 4, // [4:4] is the sub-list for method output_type + 4, // [4:4] is the sub-list for method input_type + 4, // [4:4] is the sub-list for extension type_name + 4, // [4:4] is the sub-list for extension extendee + 0, // [0:4] is the sub-list for field type_name +} + +func init() { file_workflows_v2_workflow_deleted_proto_init() } +func file_workflows_v2_workflow_deleted_proto_init() { + if File_workflows_v2_workflow_deleted_proto != nil { + return + } + file_workflows_v2_cre_info_proto_init() + file_workflows_v2_transaction_info_proto_init() + file_workflows_v2_workflow_proto_init() + type x struct{} + out := protoimpl.TypeBuilder{ + File: protoimpl.DescBuilder{ + GoPackagePath: reflect.TypeOf(x{}).PkgPath(), + RawDescriptor: unsafe.Slice(unsafe.StringData(file_workflows_v2_workflow_deleted_proto_rawDesc), len(file_workflows_v2_workflow_deleted_proto_rawDesc)), + NumEnums: 0, + NumMessages: 1, + NumExtensions: 0, + NumServices: 0, + }, + GoTypes: file_workflows_v2_workflow_deleted_proto_goTypes, + DependencyIndexes: file_workflows_v2_workflow_deleted_proto_depIdxs, + MessageInfos: file_workflows_v2_workflow_deleted_proto_msgTypes, + }.Build() + File_workflows_v2_workflow_deleted_proto = out.File + file_workflows_v2_workflow_deleted_proto_goTypes = nil + file_workflows_v2_workflow_deleted_proto_depIdxs = nil +} diff --git a/workflows/go/v2/workflow_deployed.pb.go b/workflows/go/v2/workflow_deployed.pb.go new file mode 100644 index 00000000..3cf6ff69 --- /dev/null +++ b/workflows/go/v2/workflow_deployed.pb.go @@ -0,0 +1,170 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// versions: +// protoc-gen-go v1.36.6 +// protoc v5.29.3 +// source: workflows/v2/workflow_deployed.proto + +package v2 + +import ( + protoreflect "google.golang.org/protobuf/reflect/protoreflect" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" + wrapperspb "google.golang.org/protobuf/types/known/wrapperspb" + reflect "reflect" + sync "sync" + unsafe "unsafe" +) + +const ( + // Verify that this generated code is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) + // Verify that runtime/protoimpl is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) +) + +type WorkflowDeployed struct { + state protoimpl.MessageState `protogen:"open.v1"` + CreInfo *CreInfo `protobuf:"bytes,1,opt,name=creInfo,proto3" json:"creInfo,omitempty"` + Timestamp string `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` + TxInfo *TransactionInfo `protobuf:"bytes,3,opt,name=txInfo,proto3" json:"txInfo,omitempty"` + Workflow *Workflow `protobuf:"bytes,4,opt,name=workflow,proto3" json:"workflow,omitempty"` + ErrorMessage *wrapperspb.StringValue `protobuf:"bytes,5,opt,name=errorMessage,proto3" json:"errorMessage,omitempty"` // present ⇔ failure + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *WorkflowDeployed) Reset() { + *x = WorkflowDeployed{} + mi := &file_workflows_v2_workflow_deployed_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *WorkflowDeployed) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*WorkflowDeployed) ProtoMessage() {} + +func (x *WorkflowDeployed) ProtoReflect() protoreflect.Message { + mi := &file_workflows_v2_workflow_deployed_proto_msgTypes[0] + if x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use WorkflowDeployed.ProtoReflect.Descriptor instead. +func (*WorkflowDeployed) Descriptor() ([]byte, []int) { + return file_workflows_v2_workflow_deployed_proto_rawDescGZIP(), []int{0} +} + +func (x *WorkflowDeployed) GetCreInfo() *CreInfo { + if x != nil { + return x.CreInfo + } + return nil +} + +func (x *WorkflowDeployed) GetTimestamp() string { + if x != nil { + return x.Timestamp + } + return "" +} + +func (x *WorkflowDeployed) GetTxInfo() *TransactionInfo { + if x != nil { + return x.TxInfo + } + return nil +} + +func (x *WorkflowDeployed) GetWorkflow() *Workflow { + if x != nil { + return x.Workflow + } + return nil +} + +func (x *WorkflowDeployed) GetErrorMessage() *wrapperspb.StringValue { + if x != nil { + return x.ErrorMessage + } + return nil +} + +var File_workflows_v2_workflow_deployed_proto protoreflect.FileDescriptor + +const file_workflows_v2_workflow_deployed_proto_rawDesc = "" + + "\n" + + "$workflows/v2/workflow_deployed.proto\x12\fworkflows.v2\x1a\x1egoogle/protobuf/wrappers.proto\x1a\x1bworkflows/v2/cre_info.proto\x1a#workflows/v2/transaction_info.proto\x1a\x1bworkflows/v2/workflow.proto\"\x8e\x02\n" + + "\x10WorkflowDeployed\x12/\n" + + "\acreInfo\x18\x01 \x01(\v2\x15.workflows.v2.CreInfoR\acreInfo\x12\x1c\n" + + "\ttimestamp\x18\x02 \x01(\tR\ttimestamp\x125\n" + + "\x06txInfo\x18\x03 \x01(\v2\x1d.workflows.v2.TransactionInfoR\x06txInfo\x122\n" + + "\bworkflow\x18\x04 \x01(\v2\x16.workflows.v2.WorkflowR\bworkflow\x12@\n" + + "\ferrorMessage\x18\x05 \x01(\v2\x1c.google.protobuf.StringValueR\ferrorMessageB>Z workflows.v2.CreInfo + 2, // 1: workflows.v2.WorkflowDeployed.txInfo:type_name -> workflows.v2.TransactionInfo + 3, // 2: workflows.v2.WorkflowDeployed.workflow:type_name -> workflows.v2.Workflow + 4, // 3: workflows.v2.WorkflowDeployed.errorMessage:type_name -> google.protobuf.StringValue + 4, // [4:4] is the sub-list for method output_type + 4, // [4:4] is the sub-list for method input_type + 4, // [4:4] is the sub-list for extension type_name + 4, // [4:4] is the sub-list for extension extendee + 0, // [0:4] is the sub-list for field type_name +} + +func init() { file_workflows_v2_workflow_deployed_proto_init() } +func file_workflows_v2_workflow_deployed_proto_init() { + if File_workflows_v2_workflow_deployed_proto != nil { + return + } + file_workflows_v2_cre_info_proto_init() + file_workflows_v2_transaction_info_proto_init() + file_workflows_v2_workflow_proto_init() + type x struct{} + out := protoimpl.TypeBuilder{ + File: protoimpl.DescBuilder{ + GoPackagePath: reflect.TypeOf(x{}).PkgPath(), + RawDescriptor: unsafe.Slice(unsafe.StringData(file_workflows_v2_workflow_deployed_proto_rawDesc), len(file_workflows_v2_workflow_deployed_proto_rawDesc)), + NumEnums: 0, + NumMessages: 1, + NumExtensions: 0, + NumServices: 0, + }, + GoTypes: file_workflows_v2_workflow_deployed_proto_goTypes, + DependencyIndexes: file_workflows_v2_workflow_deployed_proto_depIdxs, + MessageInfos: file_workflows_v2_workflow_deployed_proto_msgTypes, + }.Build() + File_workflows_v2_workflow_deployed_proto = out.File + file_workflows_v2_workflow_deployed_proto_goTypes = nil + file_workflows_v2_workflow_deployed_proto_depIdxs = nil +} diff --git a/workflows/go/v2/workflow_execution_finished.pb.go b/workflows/go/v2/workflow_execution_finished.pb.go new file mode 100644 index 00000000..74e03fad --- /dev/null +++ b/workflows/go/v2/workflow_execution_finished.pb.go @@ -0,0 +1,167 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// versions: +// protoc-gen-go v1.36.6 +// protoc v5.29.3 +// source: workflows/v2/workflow_execution_finished.proto + +package v2 + +import ( + protoreflect "google.golang.org/protobuf/reflect/protoreflect" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" + reflect "reflect" + sync "sync" + unsafe "unsafe" +) + +const ( + // Verify that this generated code is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) + // Verify that runtime/protoimpl is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) +) + +type WorkflowExecutionFinished struct { + state protoimpl.MessageState `protogen:"open.v1"` + CreInfo *CreInfo `protobuf:"bytes,1,opt,name=creInfo,proto3" json:"creInfo,omitempty"` + Workflow *WorkflowKey `protobuf:"bytes,2,opt,name=workflow,proto3" json:"workflow,omitempty"` + WorkflowExecutionID string `protobuf:"bytes,3,opt,name=workflowExecutionID,proto3" json:"workflowExecutionID,omitempty"` + Timestamp string `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"` + Status ExecutionStatus `protobuf:"varint,5,opt,name=status,proto3,enum=workflows.v2.ExecutionStatus" json:"status,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *WorkflowExecutionFinished) Reset() { + *x = WorkflowExecutionFinished{} + mi := &file_workflows_v2_workflow_execution_finished_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *WorkflowExecutionFinished) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*WorkflowExecutionFinished) ProtoMessage() {} + +func (x *WorkflowExecutionFinished) ProtoReflect() protoreflect.Message { + mi := &file_workflows_v2_workflow_execution_finished_proto_msgTypes[0] + if x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use WorkflowExecutionFinished.ProtoReflect.Descriptor instead. +func (*WorkflowExecutionFinished) Descriptor() ([]byte, []int) { + return file_workflows_v2_workflow_execution_finished_proto_rawDescGZIP(), []int{0} +} + +func (x *WorkflowExecutionFinished) GetCreInfo() *CreInfo { + if x != nil { + return x.CreInfo + } + return nil +} + +func (x *WorkflowExecutionFinished) GetWorkflow() *WorkflowKey { + if x != nil { + return x.Workflow + } + return nil +} + +func (x *WorkflowExecutionFinished) GetWorkflowExecutionID() string { + if x != nil { + return x.WorkflowExecutionID + } + return "" +} + +func (x *WorkflowExecutionFinished) GetTimestamp() string { + if x != nil { + return x.Timestamp + } + return "" +} + +func (x *WorkflowExecutionFinished) GetStatus() ExecutionStatus { + if x != nil { + return x.Status + } + return ExecutionStatus_EXECUTION_STATUS_UNSPECIFIED +} + +var File_workflows_v2_workflow_execution_finished_proto protoreflect.FileDescriptor + +const file_workflows_v2_workflow_execution_finished_proto_rawDesc = "" + + "\n" + + ".workflows/v2/workflow_execution_finished.proto\x12\fworkflows.v2\x1a\x1bworkflows/v2/cre_info.proto\x1a\x1fworkflows/v2/workflow_key.proto\x1a#workflows/v2/execution_status.proto\"\x8a\x02\n" + + "\x19WorkflowExecutionFinished\x12/\n" + + "\acreInfo\x18\x01 \x01(\v2\x15.workflows.v2.CreInfoR\acreInfo\x125\n" + + "\bworkflow\x18\x02 \x01(\v2\x19.workflows.v2.WorkflowKeyR\bworkflow\x120\n" + + "\x13workflowExecutionID\x18\x03 \x01(\tR\x13workflowExecutionID\x12\x1c\n" + + "\ttimestamp\x18\x04 \x01(\tR\ttimestamp\x125\n" + + "\x06status\x18\x05 \x01(\x0e2\x1d.workflows.v2.ExecutionStatusR\x06statusB>Z workflows.v2.CreInfo + 2, // 1: workflows.v2.WorkflowExecutionFinished.workflow:type_name -> workflows.v2.WorkflowKey + 3, // 2: workflows.v2.WorkflowExecutionFinished.status:type_name -> workflows.v2.ExecutionStatus + 3, // [3:3] is the sub-list for method output_type + 3, // [3:3] is the sub-list for method input_type + 3, // [3:3] is the sub-list for extension type_name + 3, // [3:3] is the sub-list for extension extendee + 0, // [0:3] is the sub-list for field type_name +} + +func init() { file_workflows_v2_workflow_execution_finished_proto_init() } +func file_workflows_v2_workflow_execution_finished_proto_init() { + if File_workflows_v2_workflow_execution_finished_proto != nil { + return + } + file_workflows_v2_cre_info_proto_init() + file_workflows_v2_workflow_key_proto_init() + file_workflows_v2_execution_status_proto_init() + type x struct{} + out := protoimpl.TypeBuilder{ + File: protoimpl.DescBuilder{ + GoPackagePath: reflect.TypeOf(x{}).PkgPath(), + RawDescriptor: unsafe.Slice(unsafe.StringData(file_workflows_v2_workflow_execution_finished_proto_rawDesc), len(file_workflows_v2_workflow_execution_finished_proto_rawDesc)), + NumEnums: 0, + NumMessages: 1, + NumExtensions: 0, + NumServices: 0, + }, + GoTypes: file_workflows_v2_workflow_execution_finished_proto_goTypes, + DependencyIndexes: file_workflows_v2_workflow_execution_finished_proto_depIdxs, + MessageInfos: file_workflows_v2_workflow_execution_finished_proto_msgTypes, + }.Build() + File_workflows_v2_workflow_execution_finished_proto = out.File + file_workflows_v2_workflow_execution_finished_proto_goTypes = nil + file_workflows_v2_workflow_execution_finished_proto_depIdxs = nil +} diff --git a/workflows/go/v2/workflow_execution_started.pb.go b/workflows/go/v2/workflow_execution_started.pb.go new file mode 100644 index 00000000..29fe8e39 --- /dev/null +++ b/workflows/go/v2/workflow_execution_started.pb.go @@ -0,0 +1,164 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// versions: +// protoc-gen-go v1.36.6 +// protoc v5.29.3 +// source: workflows/v2/workflow_execution_started.proto + +package v2 + +import ( + protoreflect "google.golang.org/protobuf/reflect/protoreflect" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" + reflect "reflect" + sync "sync" + unsafe "unsafe" +) + +const ( + // Verify that this generated code is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) + // Verify that runtime/protoimpl is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) +) + +type WorkflowExecutionStarted struct { + state protoimpl.MessageState `protogen:"open.v1"` + CreInfo *CreInfo `protobuf:"bytes,1,opt,name=creInfo,proto3" json:"creInfo,omitempty"` + Workflow *WorkflowKey `protobuf:"bytes,2,opt,name=workflow,proto3" json:"workflow,omitempty"` + WorkflowExecutionID string `protobuf:"bytes,3,opt,name=workflowExecutionID,proto3" json:"workflowExecutionID,omitempty"` + Timestamp string `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"` + TriggerID string `protobuf:"bytes,5,opt,name=triggerID,proto3" json:"triggerID,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *WorkflowExecutionStarted) Reset() { + *x = WorkflowExecutionStarted{} + mi := &file_workflows_v2_workflow_execution_started_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *WorkflowExecutionStarted) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*WorkflowExecutionStarted) ProtoMessage() {} + +func (x *WorkflowExecutionStarted) ProtoReflect() protoreflect.Message { + mi := &file_workflows_v2_workflow_execution_started_proto_msgTypes[0] + if x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use WorkflowExecutionStarted.ProtoReflect.Descriptor instead. +func (*WorkflowExecutionStarted) Descriptor() ([]byte, []int) { + return file_workflows_v2_workflow_execution_started_proto_rawDescGZIP(), []int{0} +} + +func (x *WorkflowExecutionStarted) GetCreInfo() *CreInfo { + if x != nil { + return x.CreInfo + } + return nil +} + +func (x *WorkflowExecutionStarted) GetWorkflow() *WorkflowKey { + if x != nil { + return x.Workflow + } + return nil +} + +func (x *WorkflowExecutionStarted) GetWorkflowExecutionID() string { + if x != nil { + return x.WorkflowExecutionID + } + return "" +} + +func (x *WorkflowExecutionStarted) GetTimestamp() string { + if x != nil { + return x.Timestamp + } + return "" +} + +func (x *WorkflowExecutionStarted) GetTriggerID() string { + if x != nil { + return x.TriggerID + } + return "" +} + +var File_workflows_v2_workflow_execution_started_proto protoreflect.FileDescriptor + +const file_workflows_v2_workflow_execution_started_proto_rawDesc = "" + + "\n" + + "-workflows/v2/workflow_execution_started.proto\x12\fworkflows.v2\x1a\x1bworkflows/v2/cre_info.proto\x1a\x1fworkflows/v2/workflow_key.proto\"\xf0\x01\n" + + "\x18WorkflowExecutionStarted\x12/\n" + + "\acreInfo\x18\x01 \x01(\v2\x15.workflows.v2.CreInfoR\acreInfo\x125\n" + + "\bworkflow\x18\x02 \x01(\v2\x19.workflows.v2.WorkflowKeyR\bworkflow\x120\n" + + "\x13workflowExecutionID\x18\x03 \x01(\tR\x13workflowExecutionID\x12\x1c\n" + + "\ttimestamp\x18\x04 \x01(\tR\ttimestamp\x12\x1c\n" + + "\ttriggerID\x18\x05 \x01(\tR\ttriggerIDB>Z workflows.v2.CreInfo + 2, // 1: workflows.v2.WorkflowExecutionStarted.workflow:type_name -> workflows.v2.WorkflowKey + 2, // [2:2] is the sub-list for method output_type + 2, // [2:2] is the sub-list for method input_type + 2, // [2:2] is the sub-list for extension type_name + 2, // [2:2] is the sub-list for extension extendee + 0, // [0:2] is the sub-list for field type_name +} + +func init() { file_workflows_v2_workflow_execution_started_proto_init() } +func file_workflows_v2_workflow_execution_started_proto_init() { + if File_workflows_v2_workflow_execution_started_proto != nil { + return + } + file_workflows_v2_cre_info_proto_init() + file_workflows_v2_workflow_key_proto_init() + type x struct{} + out := protoimpl.TypeBuilder{ + File: protoimpl.DescBuilder{ + GoPackagePath: reflect.TypeOf(x{}).PkgPath(), + RawDescriptor: unsafe.Slice(unsafe.StringData(file_workflows_v2_workflow_execution_started_proto_rawDesc), len(file_workflows_v2_workflow_execution_started_proto_rawDesc)), + NumEnums: 0, + NumMessages: 1, + NumExtensions: 0, + NumServices: 0, + }, + GoTypes: file_workflows_v2_workflow_execution_started_proto_goTypes, + DependencyIndexes: file_workflows_v2_workflow_execution_started_proto_depIdxs, + MessageInfos: file_workflows_v2_workflow_execution_started_proto_msgTypes, + }.Build() + File_workflows_v2_workflow_execution_started_proto = out.File + file_workflows_v2_workflow_execution_started_proto_goTypes = nil + file_workflows_v2_workflow_execution_started_proto_depIdxs = nil +} diff --git a/workflows/go/v2/workflow_key.pb.go b/workflows/go/v2/workflow_key.pb.go new file mode 100644 index 00000000..8c1ec8db --- /dev/null +++ b/workflows/go/v2/workflow_key.pb.go @@ -0,0 +1,151 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// versions: +// protoc-gen-go v1.36.6 +// protoc v5.29.3 +// source: workflows/v2/workflow_key.proto + +package v2 + +import ( + protoreflect "google.golang.org/protobuf/reflect/protoreflect" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" + reflect "reflect" + sync "sync" + unsafe "unsafe" +) + +const ( + // Verify that this generated code is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) + // Verify that runtime/protoimpl is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) +) + +type WorkflowKey struct { + state protoimpl.MessageState `protogen:"open.v1"` + WorkflowOwner string `protobuf:"bytes,1,opt,name=workflowOwner,proto3" json:"workflowOwner,omitempty"` + WorkflowName string `protobuf:"bytes,2,opt,name=workflowName,proto3" json:"workflowName,omitempty"` + WorkflowID string `protobuf:"bytes,3,opt,name=workflowID,proto3" json:"workflowID,omitempty"` + OrganizationID string `protobuf:"bytes,4,opt,name=organizationID,proto3" json:"organizationID,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *WorkflowKey) Reset() { + *x = WorkflowKey{} + mi := &file_workflows_v2_workflow_key_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *WorkflowKey) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*WorkflowKey) ProtoMessage() {} + +func (x *WorkflowKey) ProtoReflect() protoreflect.Message { + mi := &file_workflows_v2_workflow_key_proto_msgTypes[0] + if x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use WorkflowKey.ProtoReflect.Descriptor instead. +func (*WorkflowKey) Descriptor() ([]byte, []int) { + return file_workflows_v2_workflow_key_proto_rawDescGZIP(), []int{0} +} + +func (x *WorkflowKey) GetWorkflowOwner() string { + if x != nil { + return x.WorkflowOwner + } + return "" +} + +func (x *WorkflowKey) GetWorkflowName() string { + if x != nil { + return x.WorkflowName + } + return "" +} + +func (x *WorkflowKey) GetWorkflowID() string { + if x != nil { + return x.WorkflowID + } + return "" +} + +func (x *WorkflowKey) GetOrganizationID() string { + if x != nil { + return x.OrganizationID + } + return "" +} + +var File_workflows_v2_workflow_key_proto protoreflect.FileDescriptor + +const file_workflows_v2_workflow_key_proto_rawDesc = "" + + "\n" + + "\x1fworkflows/v2/workflow_key.proto\x12\fworkflows.v2\"\x9f\x01\n" + + "\vWorkflowKey\x12$\n" + + "\rworkflowOwner\x18\x01 \x01(\tR\rworkflowOwner\x12\"\n" + + "\fworkflowName\x18\x02 \x01(\tR\fworkflowName\x12\x1e\n" + + "\n" + + "workflowID\x18\x03 \x01(\tR\n" + + "workflowID\x12&\n" + + "\x0eorganizationID\x18\x04 \x01(\tR\x0eorganizationIDB>ZZ workflows.v2.CreInfo + 2, // 1: workflows.v2.WorkflowUpdated.txInfo:type_name -> workflows.v2.TransactionInfo + 3, // 2: workflows.v2.WorkflowUpdated.workflow:type_name -> workflows.v2.Workflow + 4, // 3: workflows.v2.WorkflowUpdated.errorMessage:type_name -> google.protobuf.StringValue + 4, // [4:4] is the sub-list for method output_type + 4, // [4:4] is the sub-list for method input_type + 4, // [4:4] is the sub-list for extension type_name + 4, // [4:4] is the sub-list for extension extendee + 0, // [0:4] is the sub-list for field type_name +} + +func init() { file_workflows_v2_workflow_updated_proto_init() } +func file_workflows_v2_workflow_updated_proto_init() { + if File_workflows_v2_workflow_updated_proto != nil { + return + } + file_workflows_v2_cre_info_proto_init() + file_workflows_v2_transaction_info_proto_init() + file_workflows_v2_workflow_proto_init() + type x struct{} + out := protoimpl.TypeBuilder{ + File: protoimpl.DescBuilder{ + GoPackagePath: reflect.TypeOf(x{}).PkgPath(), + RawDescriptor: unsafe.Slice(unsafe.StringData(file_workflows_v2_workflow_updated_proto_rawDesc), len(file_workflows_v2_workflow_updated_proto_rawDesc)), + NumEnums: 0, + NumMessages: 1, + NumExtensions: 0, + NumServices: 0, + }, + GoTypes: file_workflows_v2_workflow_updated_proto_goTypes, + DependencyIndexes: file_workflows_v2_workflow_updated_proto_depIdxs, + MessageInfos: file_workflows_v2_workflow_updated_proto_msgTypes, + }.Build() + File_workflows_v2_workflow_updated_proto = out.File + file_workflows_v2_workflow_updated_proto_goTypes = nil + file_workflows_v2_workflow_updated_proto_depIdxs = nil +} diff --git a/workflows/workflows/v2/capability_execution_finished.proto b/workflows/workflows/v2/capability_execution_finished.proto new file mode 100644 index 00000000..3c1d1fee --- /dev/null +++ b/workflows/workflows/v2/capability_execution_finished.proto @@ -0,0 +1,20 @@ +syntax = "proto3"; + +package workflows.v2; + +option go_package = "github.com/smartcontractkit/chainlink-protos/workflows/go/v2"; + +import "workflows/v2/cre_info.proto"; +import "workflows/v2/workflow_key.proto"; +import "workflows/v2/execution_status.proto"; + +message CapabilityExecutionFinished { + CreInfo creInfo = 1; + WorkflowKey workflow = 2; + string workflowExecutionID = 3; + string timestamp = 4; + + string capabilityID = 5; + int32 stepRef = 6; + ExecutionStatus status = 7; +} \ No newline at end of file diff --git a/workflows/workflows/v2/capability_execution_started.proto b/workflows/workflows/v2/capability_execution_started.proto new file mode 100644 index 00000000..87d00ace --- /dev/null +++ b/workflows/workflows/v2/capability_execution_started.proto @@ -0,0 +1,18 @@ +syntax = "proto3"; + +package workflows.v2; + +option go_package = "github.com/smartcontractkit/chainlink-protos/workflows/go/v2"; + +import "workflows/v2/cre_info.proto"; +import "workflows/v2/workflow_key.proto"; + +message CapabilityExecutionStarted { + CreInfo creInfo = 1; + WorkflowKey workflow = 2; + string workflowExecutionID = 3; + string timestamp = 4; + + string capabilityID = 5; + int32 stepRef = 6; +} \ No newline at end of file diff --git a/workflows/workflows/v2/cre_info.proto b/workflows/workflows/v2/cre_info.proto new file mode 100644 index 00000000..b402675b --- /dev/null +++ b/workflows/workflows/v2/cre_info.proto @@ -0,0 +1,20 @@ +syntax = "proto3"; + +package workflows.v2; + +option go_package = "github.com/smartcontractkit/chainlink-protos/workflows/go/v2"; + +// METADATA + +message CreInfo { + int32 donID = 1; + int32 donF = 2; + int32 donN = 3; + string p2pID = 4; + string workflowRegistryAddress = 5; + string workflowRegistryVersion = 6; + string workflowRegistryChain = 7; + string engineVersion = 8; + string capabilitiesRegistryVersion = 9; + string donVersion = 10; +} \ No newline at end of file diff --git a/workflows/workflows/v2/execution_status.proto b/workflows/workflows/v2/execution_status.proto new file mode 100644 index 00000000..09cc67b6 --- /dev/null +++ b/workflows/workflows/v2/execution_status.proto @@ -0,0 +1,13 @@ +syntax = "proto3"; + +package workflows.v2; + +option go_package = "github.com/smartcontractkit/chainlink-protos/workflows/go/v2"; + +// EXECUTION + +enum ExecutionStatus { + EXECUTION_STATUS_UNSPECIFIED = 0; + EXECUTION_STATUS_SUCCEEDED = 1; + EXECUTION_STATUS_FAILED = 2; +} \ No newline at end of file diff --git a/workflows/workflows/v2/operational_events.proto b/workflows/workflows/v2/operational_events.proto deleted file mode 100644 index 7dbb8833..00000000 --- a/workflows/workflows/v2/operational_events.proto +++ /dev/null @@ -1,127 +0,0 @@ -syntax = "proto3"; - -package workflows.v2; - -import "google/protobuf/wrappers.proto"; - -option go_package = "github.com/smartcontractkit/chainlink-protos/workflows/go/v2"; - -// METADATA - -message CREInfo { - int32 donID = 1; - int32 donF = 2; - int32 donN = 3; - string p2pID = 4; - string workflowRegistryAddress = 5; - string workflowRegistryVersion = 6; - string workflowRegistryChain = 7; - string engineVersion = 8; - string capabilitiesRegistryVersion = 9; - string donVersion = 10; -} - -message WorkflowKey { - string workflowOwner = 1; - string workflowName = 2; - string workflowID = 3; - string organizationID = 4; -} - -// DEPLOYMENT - -message TransactionInfo { - string chainSelector = 1; - string txHash = 2; - string gasCost = 3; -} - -message Workflow { - WorkflowKey workflowKey = 1; - string version = 2; - string binaryURL = 3; - string configURL = 4; -} - -message WorkflowDeployed { - CREInfo creInfo = 1; - string timestamp = 2; - TransactionInfo txInfo = 3; - - Workflow workflow = 4; - google.protobuf.StringValue errorMessage = 5; // present ⇔ failure -} - -message WorkflowUpdated { - CREInfo creInfo = 1; - string timestamp = 2; - TransactionInfo txInfo = 3; - - Workflow workflow = 4; - google.protobuf.StringValue errorMessage = 5; // present ⇔ failure -} - -message WorkflowDeleted { - CREInfo creInfo = 1; - string timestamp = 2; - TransactionInfo txInfo = 3; - - Workflow workflow = 4; - google.protobuf.StringValue errorMessage = 5; // present ⇔ failure -} - -// EXECUTION - -enum ExecutionStatus { - EXECUTION_STATUS_UNSPECIFIED = 0; - EXECUTION_STATUS_SUCCEEDED = 1; - EXECUTION_STATUS_FAILED = 2; -} - -message TriggerExecutionStarted { - CREInfo creInfo = 1; - WorkflowKey workflow = 2; - string workflowExecutionID = 3; - string timestamp = 4; - - string triggerID = 5; -} - -message WorkflowExecutionStarted { - CREInfo creInfo = 1; - WorkflowKey workflow = 2; - string workflowExecutionID = 3; - string timestamp = 4; - - string triggerID = 5; -} - -message WorkflowExecutionFinished { - CREInfo creInfo = 1; - WorkflowKey workflow = 2; - string workflowExecutionID = 3; - string timestamp = 4; - - ExecutionStatus status = 5; -} - -message CapabilityExecutionStarted { - CREInfo creInfo = 1; - WorkflowKey workflow = 2; - string workflowExecutionID = 3; - string timestamp = 4; - - string capabilityID = 5; - int32 stepRef = 6; -} - -message CapabilityExecutionFinished { - CREInfo creInfo = 1; - WorkflowKey workflow = 2; - string workflowExecutionID = 3; - string timestamp = 4; - - string capabilityID = 5; - int32 stepRef = 6; - ExecutionStatus status = 7; -} diff --git a/workflows/workflows/v2/transaction_info.proto b/workflows/workflows/v2/transaction_info.proto new file mode 100644 index 00000000..982514c4 --- /dev/null +++ b/workflows/workflows/v2/transaction_info.proto @@ -0,0 +1,13 @@ +syntax = "proto3"; + +package workflows.v2; + +option go_package = "github.com/smartcontractkit/chainlink-protos/workflows/go/v2"; + +// DEPLOYMENT + +message TransactionInfo { + string chainSelector = 1; + string txHash = 2; + string gasCost = 3; +} \ No newline at end of file diff --git a/workflows/workflows/v2/trigger_execution_started.proto b/workflows/workflows/v2/trigger_execution_started.proto new file mode 100644 index 00000000..39136593 --- /dev/null +++ b/workflows/workflows/v2/trigger_execution_started.proto @@ -0,0 +1,17 @@ +syntax = "proto3"; + +package workflows.v2; + +option go_package = "github.com/smartcontractkit/chainlink-protos/workflows/go/v2"; + +import "workflows/v2/cre_info.proto"; +import "workflows/v2/workflow_key.proto"; + +message TriggerExecutionStarted { + CreInfo creInfo = 1; + WorkflowKey workflow = 2; + string workflowExecutionID = 3; + string timestamp = 4; + + string triggerID = 5; +} \ No newline at end of file diff --git a/workflows/workflows/v2/workflow.proto b/workflows/workflows/v2/workflow.proto new file mode 100644 index 00000000..74156c2c --- /dev/null +++ b/workflows/workflows/v2/workflow.proto @@ -0,0 +1,14 @@ +syntax = "proto3"; + +package workflows.v2; + +option go_package = "github.com/smartcontractkit/chainlink-protos/workflows/go/v2"; + +import "workflows/v2/workflow_key.proto"; + +message Workflow { + WorkflowKey workflowKey = 1; + string version = 2; + string binaryURL = 3; + string configURL = 4; +} \ No newline at end of file diff --git a/workflows/workflows/v2/workflow_deleted.proto b/workflows/workflows/v2/workflow_deleted.proto new file mode 100644 index 00000000..1bcba091 --- /dev/null +++ b/workflows/workflows/v2/workflow_deleted.proto @@ -0,0 +1,19 @@ +syntax = "proto3"; + +package workflows.v2; + +option go_package = "github.com/smartcontractkit/chainlink-protos/workflows/go/v2"; + +import "google/protobuf/wrappers.proto"; +import "workflows/v2/cre_info.proto"; +import "workflows/v2/transaction_info.proto"; +import "workflows/v2/workflow.proto"; + +message WorkflowDeleted { + CreInfo creInfo = 1; + string timestamp = 2; + TransactionInfo txInfo = 3; + + Workflow workflow = 4; + google.protobuf.StringValue errorMessage = 5; // present ⇔ failure +} \ No newline at end of file diff --git a/workflows/workflows/v2/workflow_deployed.proto b/workflows/workflows/v2/workflow_deployed.proto new file mode 100644 index 00000000..1349d29e --- /dev/null +++ b/workflows/workflows/v2/workflow_deployed.proto @@ -0,0 +1,19 @@ +syntax = "proto3"; + +package workflows.v2; + +option go_package = "github.com/smartcontractkit/chainlink-protos/workflows/go/v2"; + +import "google/protobuf/wrappers.proto"; +import "workflows/v2/cre_info.proto"; +import "workflows/v2/transaction_info.proto"; +import "workflows/v2/workflow.proto"; + +message WorkflowDeployed { + CreInfo creInfo = 1; + string timestamp = 2; + TransactionInfo txInfo = 3; + + Workflow workflow = 4; + google.protobuf.StringValue errorMessage = 5; // present ⇔ failure +} \ No newline at end of file diff --git a/workflows/workflows/v2/workflow_execution_finished.proto b/workflows/workflows/v2/workflow_execution_finished.proto new file mode 100644 index 00000000..d0d94efd --- /dev/null +++ b/workflows/workflows/v2/workflow_execution_finished.proto @@ -0,0 +1,18 @@ +syntax = "proto3"; + +package workflows.v2; + +option go_package = "github.com/smartcontractkit/chainlink-protos/workflows/go/v2"; + +import "workflows/v2/cre_info.proto"; +import "workflows/v2/workflow_key.proto"; +import "workflows/v2/execution_status.proto"; + +message WorkflowExecutionFinished { + CreInfo creInfo = 1; + WorkflowKey workflow = 2; + string workflowExecutionID = 3; + string timestamp = 4; + + ExecutionStatus status = 5; +} \ No newline at end of file diff --git a/workflows/workflows/v2/workflow_execution_started.proto b/workflows/workflows/v2/workflow_execution_started.proto new file mode 100644 index 00000000..749e2cbb --- /dev/null +++ b/workflows/workflows/v2/workflow_execution_started.proto @@ -0,0 +1,17 @@ +syntax = "proto3"; + +package workflows.v2; + +option go_package = "github.com/smartcontractkit/chainlink-protos/workflows/go/v2"; + +import "workflows/v2/cre_info.proto"; +import "workflows/v2/workflow_key.proto"; + +message WorkflowExecutionStarted { + CreInfo creInfo = 1; + WorkflowKey workflow = 2; + string workflowExecutionID = 3; + string timestamp = 4; + + string triggerID = 5; +} \ No newline at end of file diff --git a/workflows/workflows/v2/workflow_key.proto b/workflows/workflows/v2/workflow_key.proto new file mode 100644 index 00000000..69757883 --- /dev/null +++ b/workflows/workflows/v2/workflow_key.proto @@ -0,0 +1,12 @@ +syntax = "proto3"; + +package workflows.v2; + +option go_package = "github.com/smartcontractkit/chainlink-protos/workflows/go/v2"; + +message WorkflowKey { + string workflowOwner = 1; + string workflowName = 2; + string workflowID = 3; + string organizationID = 4; +} \ No newline at end of file diff --git a/workflows/workflows/v2/workflow_updated.proto b/workflows/workflows/v2/workflow_updated.proto new file mode 100644 index 00000000..2564a9d9 --- /dev/null +++ b/workflows/workflows/v2/workflow_updated.proto @@ -0,0 +1,19 @@ +syntax = "proto3"; + +package workflows.v2; + +option go_package = "github.com/smartcontractkit/chainlink-protos/workflows/go/v2"; + +import "google/protobuf/wrappers.proto"; +import "workflows/v2/cre_info.proto"; +import "workflows/v2/transaction_info.proto"; +import "workflows/v2/workflow.proto"; + +message WorkflowUpdated { + CreInfo creInfo = 1; + string timestamp = 2; + TransactionInfo txInfo = 3; + + Workflow workflow = 4; + google.protobuf.StringValue errorMessage = 5; // present ⇔ failure +} \ No newline at end of file