// 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
}
