| // Code generated by protoc-gen-go. DO NOT EDIT. |
| // versions: |
| // protoc-gen-go v1.36.6 |
| // protoc v6.31.1 |
| // source: internal/protov1/plugin.proto |
| |
| package protov1 |
| |
| import ( |
| protoreflect "google.golang.org/protobuf/reflect/protoreflect" |
| protoimpl "google.golang.org/protobuf/runtime/protoimpl" |
| _ "google.golang.org/protobuf/types/gofeaturespb" |
| reflect "reflect" |
| 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 BundleInfo struct { |
| state protoimpl.MessageState `protogen:"opaque.v1"` |
| xxx_hidden_Name *string `protobuf:"bytes,1,opt,name=name"` |
| xxx_hidden_Version *string `protobuf:"bytes,2,opt,name=version"` |
| XXX_raceDetectHookData protoimpl.RaceDetectHookData |
| XXX_presence [1]uint32 |
| unknownFields protoimpl.UnknownFields |
| sizeCache protoimpl.SizeCache |
| } |
| |
| func (x *BundleInfo) Reset() { |
| *x = BundleInfo{} |
| mi := &file_internal_protov1_plugin_proto_msgTypes[0] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| |
| func (x *BundleInfo) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*BundleInfo) ProtoMessage() {} |
| |
| func (x *BundleInfo) ProtoReflect() protoreflect.Message { |
| mi := &file_internal_protov1_plugin_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) |
| } |
| |
| func (x *BundleInfo) GetName() string { |
| if x != nil { |
| if x.xxx_hidden_Name != nil { |
| return *x.xxx_hidden_Name |
| } |
| return "" |
| } |
| return "" |
| } |
| |
| func (x *BundleInfo) GetVersion() string { |
| if x != nil { |
| if x.xxx_hidden_Version != nil { |
| return *x.xxx_hidden_Version |
| } |
| return "" |
| } |
| return "" |
| } |
| |
| func (x *BundleInfo) SetName(v string) { |
| x.xxx_hidden_Name = &v |
| protoimpl.X.SetPresent(&(x.XXX_presence[0]), 0, 2) |
| } |
| |
| func (x *BundleInfo) SetVersion(v string) { |
| x.xxx_hidden_Version = &v |
| protoimpl.X.SetPresent(&(x.XXX_presence[0]), 1, 2) |
| } |
| |
| func (x *BundleInfo) HasName() bool { |
| if x == nil { |
| return false |
| } |
| return protoimpl.X.Present(&(x.XXX_presence[0]), 0) |
| } |
| |
| func (x *BundleInfo) HasVersion() bool { |
| if x == nil { |
| return false |
| } |
| return protoimpl.X.Present(&(x.XXX_presence[0]), 1) |
| } |
| |
| func (x *BundleInfo) ClearName() { |
| protoimpl.X.ClearPresent(&(x.XXX_presence[0]), 0) |
| x.xxx_hidden_Name = nil |
| } |
| |
| func (x *BundleInfo) ClearVersion() { |
| protoimpl.X.ClearPresent(&(x.XXX_presence[0]), 1) |
| x.xxx_hidden_Version = nil |
| } |
| |
| type BundleInfo_builder struct { |
| _ [0]func() // Prevents comparability and use of unkeyed literals for the builder. |
| |
| Name *string |
| Version *string |
| } |
| |
| func (b0 BundleInfo_builder) Build() *BundleInfo { |
| m0 := &BundleInfo{} |
| b, x := &b0, m0 |
| _, _ = b, x |
| if b.Name != nil { |
| protoimpl.X.SetPresentNonAtomic(&(x.XXX_presence[0]), 0, 2) |
| x.xxx_hidden_Name = b.Name |
| } |
| if b.Version != nil { |
| protoimpl.X.SetPresentNonAtomic(&(x.XXX_presence[0]), 1, 2) |
| x.xxx_hidden_Version = b.Version |
| } |
| return m0 |
| } |
| |
| type UUID struct { |
| state protoimpl.MessageState `protogen:"opaque.v1"` |
| xxx_hidden_Value *string `protobuf:"bytes,1,opt,name=value"` |
| XXX_raceDetectHookData protoimpl.RaceDetectHookData |
| XXX_presence [1]uint32 |
| unknownFields protoimpl.UnknownFields |
| sizeCache protoimpl.SizeCache |
| } |
| |
| func (x *UUID) Reset() { |
| *x = UUID{} |
| mi := &file_internal_protov1_plugin_proto_msgTypes[1] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| |
| func (x *UUID) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*UUID) ProtoMessage() {} |
| |
| func (x *UUID) ProtoReflect() protoreflect.Message { |
| mi := &file_internal_protov1_plugin_proto_msgTypes[1] |
| if x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| func (x *UUID) GetValue() string { |
| if x != nil { |
| if x.xxx_hidden_Value != nil { |
| return *x.xxx_hidden_Value |
| } |
| return "" |
| } |
| return "" |
| } |
| |
| func (x *UUID) SetValue(v string) { |
| x.xxx_hidden_Value = &v |
| protoimpl.X.SetPresent(&(x.XXX_presence[0]), 0, 1) |
| } |
| |
| func (x *UUID) HasValue() bool { |
| if x == nil { |
| return false |
| } |
| return protoimpl.X.Present(&(x.XXX_presence[0]), 0) |
| } |
| |
| func (x *UUID) ClearValue() { |
| protoimpl.X.ClearPresent(&(x.XXX_presence[0]), 0) |
| x.xxx_hidden_Value = nil |
| } |
| |
| type UUID_builder struct { |
| _ [0]func() // Prevents comparability and use of unkeyed literals for the builder. |
| |
| Value *string |
| } |
| |
| func (b0 UUID_builder) Build() *UUID { |
| m0 := &UUID{} |
| b, x := &b0, m0 |
| _, _ = b, x |
| if b.Value != nil { |
| protoimpl.X.SetPresentNonAtomic(&(x.XXX_presence[0]), 0, 1) |
| x.xxx_hidden_Value = b.Value |
| } |
| return m0 |
| } |
| |
| type GetMetadata struct { |
| state protoimpl.MessageState `protogen:"opaque.v1"` |
| unknownFields protoimpl.UnknownFields |
| sizeCache protoimpl.SizeCache |
| } |
| |
| func (x *GetMetadata) Reset() { |
| *x = GetMetadata{} |
| mi := &file_internal_protov1_plugin_proto_msgTypes[2] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| |
| func (x *GetMetadata) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*GetMetadata) ProtoMessage() {} |
| |
| func (x *GetMetadata) ProtoReflect() protoreflect.Message { |
| mi := &file_internal_protov1_plugin_proto_msgTypes[2] |
| if x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| type GetMetadata_builder struct { |
| _ [0]func() // Prevents comparability and use of unkeyed literals for the builder. |
| |
| } |
| |
| func (b0 GetMetadata_builder) Build() *GetMetadata { |
| m0 := &GetMetadata{} |
| b, x := &b0, m0 |
| _, _ = b, x |
| return m0 |
| } |
| |
| type ExecuteTaskWorkload struct { |
| state protoimpl.MessageState `protogen:"opaque.v1"` |
| xxx_hidden_Token *string `protobuf:"bytes,1,opt,name=token"` |
| xxx_hidden_Ti *TaskInstance `protobuf:"bytes,2,opt,name=ti"` |
| xxx_hidden_BundleInfo *BundleInfo `protobuf:"bytes,3,opt,name=bundle_info,json=bundleInfo"` |
| xxx_hidden_LogPath *string `protobuf:"bytes,4,opt,name=log_path,json=logPath"` |
| XXX_raceDetectHookData protoimpl.RaceDetectHookData |
| XXX_presence [1]uint32 |
| unknownFields protoimpl.UnknownFields |
| sizeCache protoimpl.SizeCache |
| } |
| |
| func (x *ExecuteTaskWorkload) Reset() { |
| *x = ExecuteTaskWorkload{} |
| mi := &file_internal_protov1_plugin_proto_msgTypes[3] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| |
| func (x *ExecuteTaskWorkload) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*ExecuteTaskWorkload) ProtoMessage() {} |
| |
| func (x *ExecuteTaskWorkload) ProtoReflect() protoreflect.Message { |
| mi := &file_internal_protov1_plugin_proto_msgTypes[3] |
| if x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| func (x *ExecuteTaskWorkload) GetToken() string { |
| if x != nil { |
| if x.xxx_hidden_Token != nil { |
| return *x.xxx_hidden_Token |
| } |
| return "" |
| } |
| return "" |
| } |
| |
| func (x *ExecuteTaskWorkload) GetTi() *TaskInstance { |
| if x != nil { |
| return x.xxx_hidden_Ti |
| } |
| return nil |
| } |
| |
| func (x *ExecuteTaskWorkload) GetBundleInfo() *BundleInfo { |
| if x != nil { |
| return x.xxx_hidden_BundleInfo |
| } |
| return nil |
| } |
| |
| func (x *ExecuteTaskWorkload) GetLogPath() string { |
| if x != nil { |
| if x.xxx_hidden_LogPath != nil { |
| return *x.xxx_hidden_LogPath |
| } |
| return "" |
| } |
| return "" |
| } |
| |
| func (x *ExecuteTaskWorkload) SetToken(v string) { |
| x.xxx_hidden_Token = &v |
| protoimpl.X.SetPresent(&(x.XXX_presence[0]), 0, 4) |
| } |
| |
| func (x *ExecuteTaskWorkload) SetTi(v *TaskInstance) { |
| x.xxx_hidden_Ti = v |
| } |
| |
| func (x *ExecuteTaskWorkload) SetBundleInfo(v *BundleInfo) { |
| x.xxx_hidden_BundleInfo = v |
| } |
| |
| func (x *ExecuteTaskWorkload) SetLogPath(v string) { |
| x.xxx_hidden_LogPath = &v |
| protoimpl.X.SetPresent(&(x.XXX_presence[0]), 3, 4) |
| } |
| |
| func (x *ExecuteTaskWorkload) HasToken() bool { |
| if x == nil { |
| return false |
| } |
| return protoimpl.X.Present(&(x.XXX_presence[0]), 0) |
| } |
| |
| func (x *ExecuteTaskWorkload) HasTi() bool { |
| if x == nil { |
| return false |
| } |
| return x.xxx_hidden_Ti != nil |
| } |
| |
| func (x *ExecuteTaskWorkload) HasBundleInfo() bool { |
| if x == nil { |
| return false |
| } |
| return x.xxx_hidden_BundleInfo != nil |
| } |
| |
| func (x *ExecuteTaskWorkload) HasLogPath() bool { |
| if x == nil { |
| return false |
| } |
| return protoimpl.X.Present(&(x.XXX_presence[0]), 3) |
| } |
| |
| func (x *ExecuteTaskWorkload) ClearToken() { |
| protoimpl.X.ClearPresent(&(x.XXX_presence[0]), 0) |
| x.xxx_hidden_Token = nil |
| } |
| |
| func (x *ExecuteTaskWorkload) ClearTi() { |
| x.xxx_hidden_Ti = nil |
| } |
| |
| func (x *ExecuteTaskWorkload) ClearBundleInfo() { |
| x.xxx_hidden_BundleInfo = nil |
| } |
| |
| func (x *ExecuteTaskWorkload) ClearLogPath() { |
| protoimpl.X.ClearPresent(&(x.XXX_presence[0]), 3) |
| x.xxx_hidden_LogPath = nil |
| } |
| |
| type ExecuteTaskWorkload_builder struct { |
| _ [0]func() // Prevents comparability and use of unkeyed literals for the builder. |
| |
| Token *string |
| Ti *TaskInstance |
| BundleInfo *BundleInfo |
| LogPath *string |
| } |
| |
| func (b0 ExecuteTaskWorkload_builder) Build() *ExecuteTaskWorkload { |
| m0 := &ExecuteTaskWorkload{} |
| b, x := &b0, m0 |
| _, _ = b, x |
| if b.Token != nil { |
| protoimpl.X.SetPresentNonAtomic(&(x.XXX_presence[0]), 0, 4) |
| x.xxx_hidden_Token = b.Token |
| } |
| x.xxx_hidden_Ti = b.Ti |
| x.xxx_hidden_BundleInfo = b.BundleInfo |
| if b.LogPath != nil { |
| protoimpl.X.SetPresentNonAtomic(&(x.XXX_presence[0]), 3, 4) |
| x.xxx_hidden_LogPath = b.LogPath |
| } |
| return m0 |
| } |
| |
| type TaskInstance struct { |
| state protoimpl.MessageState `protogen:"opaque.v1"` |
| xxx_hidden_Id *UUID `protobuf:"bytes,1,opt,name=id"` |
| xxx_hidden_DagId *string `protobuf:"bytes,2,opt,name=dag_id,json=dagId"` |
| xxx_hidden_RunId *string `protobuf:"bytes,3,opt,name=run_id,json=runId"` |
| xxx_hidden_TaskId *string `protobuf:"bytes,4,opt,name=task_id,json=taskId"` |
| xxx_hidden_MapIndex int32 `protobuf:"varint,5,opt,name=map_index,json=mapIndex"` |
| xxx_hidden_TryNumber int32 `protobuf:"varint,6,opt,name=try_number,json=tryNumber"` |
| xxx_hidden_Hostname *string `protobuf:"bytes,7,opt,name=hostname"` |
| xxx_hidden_OtelContext map[string]string `protobuf:"bytes,8,rep,name=otel_context,json=otelContext" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"` |
| XXX_raceDetectHookData protoimpl.RaceDetectHookData |
| XXX_presence [1]uint32 |
| unknownFields protoimpl.UnknownFields |
| sizeCache protoimpl.SizeCache |
| } |
| |
| func (x *TaskInstance) Reset() { |
| *x = TaskInstance{} |
| mi := &file_internal_protov1_plugin_proto_msgTypes[4] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| |
| func (x *TaskInstance) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*TaskInstance) ProtoMessage() {} |
| |
| func (x *TaskInstance) ProtoReflect() protoreflect.Message { |
| mi := &file_internal_protov1_plugin_proto_msgTypes[4] |
| if x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| func (x *TaskInstance) GetId() *UUID { |
| if x != nil { |
| return x.xxx_hidden_Id |
| } |
| return nil |
| } |
| |
| func (x *TaskInstance) GetDagId() string { |
| if x != nil { |
| if x.xxx_hidden_DagId != nil { |
| return *x.xxx_hidden_DagId |
| } |
| return "" |
| } |
| return "" |
| } |
| |
| func (x *TaskInstance) GetRunId() string { |
| if x != nil { |
| if x.xxx_hidden_RunId != nil { |
| return *x.xxx_hidden_RunId |
| } |
| return "" |
| } |
| return "" |
| } |
| |
| func (x *TaskInstance) GetTaskId() string { |
| if x != nil { |
| if x.xxx_hidden_TaskId != nil { |
| return *x.xxx_hidden_TaskId |
| } |
| return "" |
| } |
| return "" |
| } |
| |
| func (x *TaskInstance) GetMapIndex() int32 { |
| if x != nil { |
| return x.xxx_hidden_MapIndex |
| } |
| return 0 |
| } |
| |
| func (x *TaskInstance) GetTryNumber() int32 { |
| if x != nil { |
| return x.xxx_hidden_TryNumber |
| } |
| return 0 |
| } |
| |
| func (x *TaskInstance) GetHostname() string { |
| if x != nil { |
| if x.xxx_hidden_Hostname != nil { |
| return *x.xxx_hidden_Hostname |
| } |
| return "" |
| } |
| return "" |
| } |
| |
| func (x *TaskInstance) GetOtelContext() map[string]string { |
| if x != nil { |
| return x.xxx_hidden_OtelContext |
| } |
| return nil |
| } |
| |
| func (x *TaskInstance) SetId(v *UUID) { |
| x.xxx_hidden_Id = v |
| } |
| |
| func (x *TaskInstance) SetDagId(v string) { |
| x.xxx_hidden_DagId = &v |
| protoimpl.X.SetPresent(&(x.XXX_presence[0]), 1, 8) |
| } |
| |
| func (x *TaskInstance) SetRunId(v string) { |
| x.xxx_hidden_RunId = &v |
| protoimpl.X.SetPresent(&(x.XXX_presence[0]), 2, 8) |
| } |
| |
| func (x *TaskInstance) SetTaskId(v string) { |
| x.xxx_hidden_TaskId = &v |
| protoimpl.X.SetPresent(&(x.XXX_presence[0]), 3, 8) |
| } |
| |
| func (x *TaskInstance) SetMapIndex(v int32) { |
| x.xxx_hidden_MapIndex = v |
| protoimpl.X.SetPresent(&(x.XXX_presence[0]), 4, 8) |
| } |
| |
| func (x *TaskInstance) SetTryNumber(v int32) { |
| x.xxx_hidden_TryNumber = v |
| protoimpl.X.SetPresent(&(x.XXX_presence[0]), 5, 8) |
| } |
| |
| func (x *TaskInstance) SetHostname(v string) { |
| x.xxx_hidden_Hostname = &v |
| protoimpl.X.SetPresent(&(x.XXX_presence[0]), 6, 8) |
| } |
| |
| func (x *TaskInstance) SetOtelContext(v map[string]string) { |
| x.xxx_hidden_OtelContext = v |
| } |
| |
| func (x *TaskInstance) HasId() bool { |
| if x == nil { |
| return false |
| } |
| return x.xxx_hidden_Id != nil |
| } |
| |
| func (x *TaskInstance) HasDagId() bool { |
| if x == nil { |
| return false |
| } |
| return protoimpl.X.Present(&(x.XXX_presence[0]), 1) |
| } |
| |
| func (x *TaskInstance) HasRunId() bool { |
| if x == nil { |
| return false |
| } |
| return protoimpl.X.Present(&(x.XXX_presence[0]), 2) |
| } |
| |
| func (x *TaskInstance) HasTaskId() bool { |
| if x == nil { |
| return false |
| } |
| return protoimpl.X.Present(&(x.XXX_presence[0]), 3) |
| } |
| |
| func (x *TaskInstance) HasMapIndex() bool { |
| if x == nil { |
| return false |
| } |
| return protoimpl.X.Present(&(x.XXX_presence[0]), 4) |
| } |
| |
| func (x *TaskInstance) HasTryNumber() bool { |
| if x == nil { |
| return false |
| } |
| return protoimpl.X.Present(&(x.XXX_presence[0]), 5) |
| } |
| |
| func (x *TaskInstance) HasHostname() bool { |
| if x == nil { |
| return false |
| } |
| return protoimpl.X.Present(&(x.XXX_presence[0]), 6) |
| } |
| |
| func (x *TaskInstance) ClearId() { |
| x.xxx_hidden_Id = nil |
| } |
| |
| func (x *TaskInstance) ClearDagId() { |
| protoimpl.X.ClearPresent(&(x.XXX_presence[0]), 1) |
| x.xxx_hidden_DagId = nil |
| } |
| |
| func (x *TaskInstance) ClearRunId() { |
| protoimpl.X.ClearPresent(&(x.XXX_presence[0]), 2) |
| x.xxx_hidden_RunId = nil |
| } |
| |
| func (x *TaskInstance) ClearTaskId() { |
| protoimpl.X.ClearPresent(&(x.XXX_presence[0]), 3) |
| x.xxx_hidden_TaskId = nil |
| } |
| |
| func (x *TaskInstance) ClearMapIndex() { |
| protoimpl.X.ClearPresent(&(x.XXX_presence[0]), 4) |
| x.xxx_hidden_MapIndex = 0 |
| } |
| |
| func (x *TaskInstance) ClearTryNumber() { |
| protoimpl.X.ClearPresent(&(x.XXX_presence[0]), 5) |
| x.xxx_hidden_TryNumber = 0 |
| } |
| |
| func (x *TaskInstance) ClearHostname() { |
| protoimpl.X.ClearPresent(&(x.XXX_presence[0]), 6) |
| x.xxx_hidden_Hostname = nil |
| } |
| |
| type TaskInstance_builder struct { |
| _ [0]func() // Prevents comparability and use of unkeyed literals for the builder. |
| |
| Id *UUID |
| DagId *string |
| RunId *string |
| TaskId *string |
| MapIndex *int32 |
| TryNumber *int32 |
| Hostname *string |
| OtelContext map[string]string |
| } |
| |
| func (b0 TaskInstance_builder) Build() *TaskInstance { |
| m0 := &TaskInstance{} |
| b, x := &b0, m0 |
| _, _ = b, x |
| x.xxx_hidden_Id = b.Id |
| if b.DagId != nil { |
| protoimpl.X.SetPresentNonAtomic(&(x.XXX_presence[0]), 1, 8) |
| x.xxx_hidden_DagId = b.DagId |
| } |
| if b.RunId != nil { |
| protoimpl.X.SetPresentNonAtomic(&(x.XXX_presence[0]), 2, 8) |
| x.xxx_hidden_RunId = b.RunId |
| } |
| if b.TaskId != nil { |
| protoimpl.X.SetPresentNonAtomic(&(x.XXX_presence[0]), 3, 8) |
| x.xxx_hidden_TaskId = b.TaskId |
| } |
| if b.MapIndex != nil { |
| protoimpl.X.SetPresentNonAtomic(&(x.XXX_presence[0]), 4, 8) |
| x.xxx_hidden_MapIndex = *b.MapIndex |
| } |
| if b.TryNumber != nil { |
| protoimpl.X.SetPresentNonAtomic(&(x.XXX_presence[0]), 5, 8) |
| x.xxx_hidden_TryNumber = *b.TryNumber |
| } |
| if b.Hostname != nil { |
| protoimpl.X.SetPresentNonAtomic(&(x.XXX_presence[0]), 6, 8) |
| x.xxx_hidden_Hostname = b.Hostname |
| } |
| x.xxx_hidden_OtelContext = b.OtelContext |
| return m0 |
| } |
| |
| type Execute struct { |
| state protoimpl.MessageState `protogen:"opaque.v1"` |
| unknownFields protoimpl.UnknownFields |
| sizeCache protoimpl.SizeCache |
| } |
| |
| func (x *Execute) Reset() { |
| *x = Execute{} |
| mi := &file_internal_protov1_plugin_proto_msgTypes[5] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| |
| func (x *Execute) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*Execute) ProtoMessage() {} |
| |
| func (x *Execute) ProtoReflect() protoreflect.Message { |
| mi := &file_internal_protov1_plugin_proto_msgTypes[5] |
| if x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| type Execute_builder struct { |
| _ [0]func() // Prevents comparability and use of unkeyed literals for the builder. |
| |
| } |
| |
| func (b0 Execute_builder) Build() *Execute { |
| m0 := &Execute{} |
| b, x := &b0, m0 |
| _, _ = b, x |
| return m0 |
| } |
| |
| type GetMetadata_Request struct { |
| state protoimpl.MessageState `protogen:"opaque.v1"` |
| unknownFields protoimpl.UnknownFields |
| sizeCache protoimpl.SizeCache |
| } |
| |
| func (x *GetMetadata_Request) Reset() { |
| *x = GetMetadata_Request{} |
| mi := &file_internal_protov1_plugin_proto_msgTypes[6] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| |
| func (x *GetMetadata_Request) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*GetMetadata_Request) ProtoMessage() {} |
| |
| func (x *GetMetadata_Request) ProtoReflect() protoreflect.Message { |
| mi := &file_internal_protov1_plugin_proto_msgTypes[6] |
| if x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| type GetMetadata_Request_builder struct { |
| _ [0]func() // Prevents comparability and use of unkeyed literals for the builder. |
| |
| } |
| |
| func (b0 GetMetadata_Request_builder) Build() *GetMetadata_Request { |
| m0 := &GetMetadata_Request{} |
| b, x := &b0, m0 |
| _, _ = b, x |
| return m0 |
| } |
| |
| type GetMetadata_Response struct { |
| state protoimpl.MessageState `protogen:"opaque.v1"` |
| xxx_hidden_Bundle *BundleInfo `protobuf:"bytes,1,opt,name=bundle"` |
| unknownFields protoimpl.UnknownFields |
| sizeCache protoimpl.SizeCache |
| } |
| |
| func (x *GetMetadata_Response) Reset() { |
| *x = GetMetadata_Response{} |
| mi := &file_internal_protov1_plugin_proto_msgTypes[7] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| |
| func (x *GetMetadata_Response) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*GetMetadata_Response) ProtoMessage() {} |
| |
| func (x *GetMetadata_Response) ProtoReflect() protoreflect.Message { |
| mi := &file_internal_protov1_plugin_proto_msgTypes[7] |
| if x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| func (x *GetMetadata_Response) GetBundle() *BundleInfo { |
| if x != nil { |
| return x.xxx_hidden_Bundle |
| } |
| return nil |
| } |
| |
| func (x *GetMetadata_Response) SetBundle(v *BundleInfo) { |
| x.xxx_hidden_Bundle = v |
| } |
| |
| func (x *GetMetadata_Response) HasBundle() bool { |
| if x == nil { |
| return false |
| } |
| return x.xxx_hidden_Bundle != nil |
| } |
| |
| func (x *GetMetadata_Response) ClearBundle() { |
| x.xxx_hidden_Bundle = nil |
| } |
| |
| type GetMetadata_Response_builder struct { |
| _ [0]func() // Prevents comparability and use of unkeyed literals for the builder. |
| |
| Bundle *BundleInfo |
| } |
| |
| func (b0 GetMetadata_Response_builder) Build() *GetMetadata_Response { |
| m0 := &GetMetadata_Response{} |
| b, x := &b0, m0 |
| _, _ = b, x |
| x.xxx_hidden_Bundle = b.Bundle |
| return m0 |
| } |
| |
| type Execute_Request struct { |
| state protoimpl.MessageState `protogen:"opaque.v1"` |
| xxx_hidden_Workload isExecute_Request_Workload `protobuf_oneof:"workload"` |
| unknownFields protoimpl.UnknownFields |
| sizeCache protoimpl.SizeCache |
| } |
| |
| func (x *Execute_Request) Reset() { |
| *x = Execute_Request{} |
| mi := &file_internal_protov1_plugin_proto_msgTypes[9] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| |
| func (x *Execute_Request) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*Execute_Request) ProtoMessage() {} |
| |
| func (x *Execute_Request) ProtoReflect() protoreflect.Message { |
| mi := &file_internal_protov1_plugin_proto_msgTypes[9] |
| if x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| func (x *Execute_Request) GetTask() *ExecuteTaskWorkload { |
| if x != nil { |
| if x, ok := x.xxx_hidden_Workload.(*execute_Request_Task); ok { |
| return x.Task |
| } |
| } |
| return nil |
| } |
| |
| func (x *Execute_Request) SetTask(v *ExecuteTaskWorkload) { |
| if v == nil { |
| x.xxx_hidden_Workload = nil |
| return |
| } |
| x.xxx_hidden_Workload = &execute_Request_Task{v} |
| } |
| |
| func (x *Execute_Request) HasWorkload() bool { |
| if x == nil { |
| return false |
| } |
| return x.xxx_hidden_Workload != nil |
| } |
| |
| func (x *Execute_Request) HasTask() bool { |
| if x == nil { |
| return false |
| } |
| _, ok := x.xxx_hidden_Workload.(*execute_Request_Task) |
| return ok |
| } |
| |
| func (x *Execute_Request) ClearWorkload() { |
| x.xxx_hidden_Workload = nil |
| } |
| |
| func (x *Execute_Request) ClearTask() { |
| if _, ok := x.xxx_hidden_Workload.(*execute_Request_Task); ok { |
| x.xxx_hidden_Workload = nil |
| } |
| } |
| |
| const Execute_Request_Workload_not_set_case case_Execute_Request_Workload = 0 |
| const Execute_Request_Task_case case_Execute_Request_Workload = 1 |
| |
| func (x *Execute_Request) WhichWorkload() case_Execute_Request_Workload { |
| if x == nil { |
| return Execute_Request_Workload_not_set_case |
| } |
| switch x.xxx_hidden_Workload.(type) { |
| case *execute_Request_Task: |
| return Execute_Request_Task_case |
| default: |
| return Execute_Request_Workload_not_set_case |
| } |
| } |
| |
| type Execute_Request_builder struct { |
| _ [0]func() // Prevents comparability and use of unkeyed literals for the builder. |
| |
| // There is only one workload for now, but set it up to have multiple |
| |
| // Fields of oneof xxx_hidden_Workload: |
| Task *ExecuteTaskWorkload |
| // -- end of xxx_hidden_Workload |
| } |
| |
| func (b0 Execute_Request_builder) Build() *Execute_Request { |
| m0 := &Execute_Request{} |
| b, x := &b0, m0 |
| _, _ = b, x |
| if b.Task != nil { |
| x.xxx_hidden_Workload = &execute_Request_Task{b.Task} |
| } |
| return m0 |
| } |
| |
| type case_Execute_Request_Workload protoreflect.FieldNumber |
| |
| func (x case_Execute_Request_Workload) String() string { |
| md := file_internal_protov1_plugin_proto_msgTypes[9].Descriptor() |
| if x == 0 { |
| return "not set" |
| } |
| return protoimpl.X.MessageFieldStringOf(md, protoreflect.FieldNumber(x)) |
| } |
| |
| type isExecute_Request_Workload interface { |
| isExecute_Request_Workload() |
| } |
| |
| type execute_Request_Task struct { |
| Task *ExecuteTaskWorkload `protobuf:"bytes,1,opt,name=task,oneof"` |
| } |
| |
| func (*execute_Request_Task) isExecute_Request_Workload() {} |
| |
| type Execute_Response struct { |
| state protoimpl.MessageState `protogen:"opaque.v1"` |
| unknownFields protoimpl.UnknownFields |
| sizeCache protoimpl.SizeCache |
| } |
| |
| func (x *Execute_Response) Reset() { |
| *x = Execute_Response{} |
| mi := &file_internal_protov1_plugin_proto_msgTypes[10] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| |
| func (x *Execute_Response) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*Execute_Response) ProtoMessage() {} |
| |
| func (x *Execute_Response) ProtoReflect() protoreflect.Message { |
| mi := &file_internal_protov1_plugin_proto_msgTypes[10] |
| if x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| type Execute_Response_builder struct { |
| _ [0]func() // Prevents comparability and use of unkeyed literals for the builder. |
| |
| } |
| |
| func (b0 Execute_Response_builder) Build() *Execute_Response { |
| m0 := &Execute_Response{} |
| b, x := &b0, m0 |
| _, _ = b, x |
| return m0 |
| } |
| |
| var File_internal_protov1_plugin_proto protoreflect.FileDescriptor |
| |
| const file_internal_protov1_plugin_proto_rawDesc = "" + |
| "\n" + |
| "\x1dinternal/protov1/plugin.proto\x12\tbundle.v1\x1a!google/protobuf/go_features.proto\":\n" + |
| "\n" + |
| "BundleInfo\x12\x12\n" + |
| "\x04name\x18\x01 \x01(\tR\x04name\x12\x18\n" + |
| "\aversion\x18\x02 \x01(\tR\aversion\"\x1c\n" + |
| "\x04UUID\x12\x14\n" + |
| "\x05value\x18\x01 \x01(\tR\x05value\"S\n" + |
| "\vGetMetadata\x1a\t\n" + |
| "\aRequest\x1a9\n" + |
| "\bResponse\x12-\n" + |
| "\x06bundle\x18\x01 \x01(\v2\x15.bundle.v1.BundleInfoR\x06bundle\"\xa7\x01\n" + |
| "\x13ExecuteTaskWorkload\x12\x14\n" + |
| "\x05token\x18\x01 \x01(\tR\x05token\x12'\n" + |
| "\x02ti\x18\x02 \x01(\v2\x17.bundle.v1.TaskInstanceR\x02ti\x126\n" + |
| "\vbundle_info\x18\x03 \x01(\v2\x15.bundle.v1.BundleInfoR\n" + |
| "bundleInfo\x12\x19\n" + |
| "\blog_path\x18\x04 \x01(\tR\alogPath\"\xdb\x02\n" + |
| "\fTaskInstance\x12\x1f\n" + |
| "\x02id\x18\x01 \x01(\v2\x0f.bundle.v1.UUIDR\x02id\x12\x15\n" + |
| "\x06dag_id\x18\x02 \x01(\tR\x05dagId\x12\x15\n" + |
| "\x06run_id\x18\x03 \x01(\tR\x05runId\x12\x17\n" + |
| "\atask_id\x18\x04 \x01(\tR\x06taskId\x12\x1b\n" + |
| "\tmap_index\x18\x05 \x01(\x05R\bmapIndex\x12\x1d\n" + |
| "\n" + |
| "try_number\x18\x06 \x01(\x05R\ttryNumber\x12\x1a\n" + |
| "\bhostname\x18\a \x01(\tR\bhostname\x12K\n" + |
| "\fotel_context\x18\b \x03(\v2(.bundle.v1.TaskInstance.OtelContextEntryR\votelContext\x1a>\n" + |
| "\x10OtelContextEntry\x12\x10\n" + |
| "\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n" + |
| "\x05value\x18\x02 \x01(\tR\x05value:\x028\x01\"b\n" + |
| "\aExecute\x1aK\n" + |
| "\aRequest\x124\n" + |
| "\x04task\x18\x01 \x01(\v2\x1e.bundle.v1.ExecuteTaskWorkloadH\x00R\x04taskB\n" + |
| "\n" + |
| "\bworkload\x1a\n" + |
| "\n" + |
| "\bResponse2\x9f\x01\n" + |
| "\tDagBundle\x12N\n" + |
| "\vGetMetadata\x12\x1e.bundle.v1.GetMetadata.Request\x1a\x1f.bundle.v1.GetMetadata.Response\x12B\n" + |
| "\aExecute\x12\x1a.bundle.v1.Execute.Request\x1a\x1b.bundle.v1.Execute.ResponseB;Z1github.com/apache/airflow/go-sdk/internal/protov1\x92\x03\x05\xd2>\x02\x10\x03b\beditionsp\xe8\a" |
| |
| var file_internal_protov1_plugin_proto_msgTypes = make([]protoimpl.MessageInfo, 11) |
| var file_internal_protov1_plugin_proto_goTypes = []any{ |
| (*BundleInfo)(nil), // 0: bundle.v1.BundleInfo |
| (*UUID)(nil), // 1: bundle.v1.UUID |
| (*GetMetadata)(nil), // 2: bundle.v1.GetMetadata |
| (*ExecuteTaskWorkload)(nil), // 3: bundle.v1.ExecuteTaskWorkload |
| (*TaskInstance)(nil), // 4: bundle.v1.TaskInstance |
| (*Execute)(nil), // 5: bundle.v1.Execute |
| (*GetMetadata_Request)(nil), // 6: bundle.v1.GetMetadata.Request |
| (*GetMetadata_Response)(nil), // 7: bundle.v1.GetMetadata.Response |
| nil, // 8: bundle.v1.TaskInstance.OtelContextEntry |
| (*Execute_Request)(nil), // 9: bundle.v1.Execute.Request |
| (*Execute_Response)(nil), // 10: bundle.v1.Execute.Response |
| } |
| var file_internal_protov1_plugin_proto_depIdxs = []int32{ |
| 4, // 0: bundle.v1.ExecuteTaskWorkload.ti:type_name -> bundle.v1.TaskInstance |
| 0, // 1: bundle.v1.ExecuteTaskWorkload.bundle_info:type_name -> bundle.v1.BundleInfo |
| 1, // 2: bundle.v1.TaskInstance.id:type_name -> bundle.v1.UUID |
| 8, // 3: bundle.v1.TaskInstance.otel_context:type_name -> bundle.v1.TaskInstance.OtelContextEntry |
| 0, // 4: bundle.v1.GetMetadata.Response.bundle:type_name -> bundle.v1.BundleInfo |
| 3, // 5: bundle.v1.Execute.Request.task:type_name -> bundle.v1.ExecuteTaskWorkload |
| 6, // 6: bundle.v1.DagBundle.GetMetadata:input_type -> bundle.v1.GetMetadata.Request |
| 9, // 7: bundle.v1.DagBundle.Execute:input_type -> bundle.v1.Execute.Request |
| 7, // 8: bundle.v1.DagBundle.GetMetadata:output_type -> bundle.v1.GetMetadata.Response |
| 10, // 9: bundle.v1.DagBundle.Execute:output_type -> bundle.v1.Execute.Response |
| 8, // [8:10] is the sub-list for method output_type |
| 6, // [6:8] is the sub-list for method input_type |
| 6, // [6:6] is the sub-list for extension type_name |
| 6, // [6:6] is the sub-list for extension extendee |
| 0, // [0:6] is the sub-list for field type_name |
| } |
| |
| func init() { file_internal_protov1_plugin_proto_init() } |
| func file_internal_protov1_plugin_proto_init() { |
| if File_internal_protov1_plugin_proto != nil { |
| return |
| } |
| file_internal_protov1_plugin_proto_msgTypes[9].OneofWrappers = []any{ |
| (*execute_Request_Task)(nil), |
| } |
| type x struct{} |
| out := protoimpl.TypeBuilder{ |
| File: protoimpl.DescBuilder{ |
| GoPackagePath: reflect.TypeOf(x{}).PkgPath(), |
| RawDescriptor: unsafe.Slice(unsafe.StringData(file_internal_protov1_plugin_proto_rawDesc), len(file_internal_protov1_plugin_proto_rawDesc)), |
| NumEnums: 0, |
| NumMessages: 11, |
| NumExtensions: 0, |
| NumServices: 1, |
| }, |
| GoTypes: file_internal_protov1_plugin_proto_goTypes, |
| DependencyIndexes: file_internal_protov1_plugin_proto_depIdxs, |
| MessageInfos: file_internal_protov1_plugin_proto_msgTypes, |
| }.Build() |
| File_internal_protov1_plugin_proto = out.File |
| file_internal_protov1_plugin_proto_goTypes = nil |
| file_internal_protov1_plugin_proto_depIdxs = nil |
| } |
