oto/services/core/oto/runner.pb.go

// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// 	protoc-gen-go v1.36.11
// 	protoc        v5.29.3
// source: oto/runner.proto

package otopb

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 HeartbeatStatus int32

const (
	HeartbeatStatus_HEARTBEAT_STATUS_UNSPECIFIED HeartbeatStatus = 0
	HeartbeatStatus_HEARTBEAT_STATUS_HEALTHY     HeartbeatStatus = 1
	HeartbeatStatus_HEARTBEAT_STATUS_UNHEALTHY   HeartbeatStatus = 2
)

// Enum value maps for HeartbeatStatus.
var (
	HeartbeatStatus_name = map[int32]string{
		0: "HEARTBEAT_STATUS_UNSPECIFIED",
		1: "HEARTBEAT_STATUS_HEALTHY",
		2: "HEARTBEAT_STATUS_UNHEALTHY",
	}
	HeartbeatStatus_value = map[string]int32{
		"HEARTBEAT_STATUS_UNSPECIFIED": 0,
		"HEARTBEAT_STATUS_HEALTHY":     1,
		"HEARTBEAT_STATUS_UNHEALTHY":   2,
	}
)

func (x HeartbeatStatus) Enum() *HeartbeatStatus {
	p := new(HeartbeatStatus)
	*p = x
	return p
}

func (x HeartbeatStatus) String() string {
	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}

func (HeartbeatStatus) Descriptor() protoreflect.EnumDescriptor {
	return file_oto_runner_proto_enumTypes[0].Descriptor()
}

func (HeartbeatStatus) Type() protoreflect.EnumType {
	return &file_oto_runner_proto_enumTypes[0]
}

func (x HeartbeatStatus) Number() protoreflect.EnumNumber {
	return protoreflect.EnumNumber(x)
}

// Deprecated: Use HeartbeatStatus.Descriptor instead.
func (HeartbeatStatus) EnumDescriptor() ([]byte, []int) {
	return file_oto_runner_proto_rawDescGZIP(), []int{0}
}

type RunnerCapability struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Name          string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version       string                 `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *RunnerCapability) Reset() {
	*x = RunnerCapability{}
	mi := &file_oto_runner_proto_msgTypes[0]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *RunnerCapability) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*RunnerCapability) ProtoMessage() {}

func (x *RunnerCapability) ProtoReflect() protoreflect.Message {
	mi := &file_oto_runner_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 RunnerCapability.ProtoReflect.Descriptor instead.
func (*RunnerCapability) Descriptor() ([]byte, []int) {
	return file_oto_runner_proto_rawDescGZIP(), []int{0}
}

func (x *RunnerCapability) GetName() string {
	if x != nil {
		return x.Name
	}
	return ""
}

func (x *RunnerCapability) GetVersion() string {
	if x != nil {
		return x.Version
	}
	return ""
}

type CommandCatalogSummary struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	CommandTypes  []string               `protobuf:"bytes,1,rep,name=command_types,json=commandTypes,proto3" json:"command_types,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *CommandCatalogSummary) Reset() {
	*x = CommandCatalogSummary{}
	mi := &file_oto_runner_proto_msgTypes[1]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *CommandCatalogSummary) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*CommandCatalogSummary) ProtoMessage() {}

func (x *CommandCatalogSummary) ProtoReflect() protoreflect.Message {
	mi := &file_oto_runner_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)
}

// Deprecated: Use CommandCatalogSummary.ProtoReflect.Descriptor instead.
func (*CommandCatalogSummary) Descriptor() ([]byte, []int) {
	return file_oto_runner_proto_rawDescGZIP(), []int{1}
}

func (x *CommandCatalogSummary) GetCommandTypes() []string {
	if x != nil {
		return x.CommandTypes
	}
	return nil
}

type RegisterRunnerRequest struct {
	state           protoimpl.MessageState `protogen:"open.v1"`
	EnrollmentToken string                 `protobuf:"bytes,1,opt,name=enrollment_token,json=enrollmentToken,proto3" json:"enrollment_token,omitempty"`
	RunnerId        string                 `protobuf:"bytes,2,opt,name=runner_id,json=runnerId,proto3" json:"runner_id,omitempty"`
	Alias           string                 `protobuf:"bytes,3,opt,name=alias,proto3" json:"alias,omitempty"`
	ProtocolVersion string                 `protobuf:"bytes,4,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
	Capability      *RunnerCapability      `protobuf:"bytes,5,opt,name=capability,proto3" json:"capability,omitempty"`
	CommandCatalog  *CommandCatalogSummary `protobuf:"bytes,6,opt,name=command_catalog,json=commandCatalog,proto3" json:"command_catalog,omitempty"`
	unknownFields   protoimpl.UnknownFields
	sizeCache       protoimpl.SizeCache
}

func (x *RegisterRunnerRequest) Reset() {
	*x = RegisterRunnerRequest{}
	mi := &file_oto_runner_proto_msgTypes[2]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *RegisterRunnerRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*RegisterRunnerRequest) ProtoMessage() {}

func (x *RegisterRunnerRequest) ProtoReflect() protoreflect.Message {
	mi := &file_oto_runner_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)
}

// Deprecated: Use RegisterRunnerRequest.ProtoReflect.Descriptor instead.
func (*RegisterRunnerRequest) Descriptor() ([]byte, []int) {
	return file_oto_runner_proto_rawDescGZIP(), []int{2}
}

func (x *RegisterRunnerRequest) GetEnrollmentToken() string {
	if x != nil {
		return x.EnrollmentToken
	}
	return ""
}

func (x *RegisterRunnerRequest) GetRunnerId() string {
	if x != nil {
		return x.RunnerId
	}
	return ""
}

func (x *RegisterRunnerRequest) GetAlias() string {
	if x != nil {
		return x.Alias
	}
	return ""
}

func (x *RegisterRunnerRequest) GetProtocolVersion() string {
	if x != nil {
		return x.ProtocolVersion
	}
	return ""
}

func (x *RegisterRunnerRequest) GetCapability() *RunnerCapability {
	if x != nil {
		return x.Capability
	}
	return nil
}

func (x *RegisterRunnerRequest) GetCommandCatalog() *CommandCatalogSummary {
	if x != nil {
		return x.CommandCatalog
	}
	return nil
}

type RegisterRunnerResponse struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Accepted      bool                   `protobuf:"varint,1,opt,name=accepted,proto3" json:"accepted,omitempty"`
	RejectReason  string                 `protobuf:"bytes,2,opt,name=reject_reason,json=rejectReason,proto3" json:"reject_reason,omitempty"`
	RunnerId      string                 `protobuf:"bytes,3,opt,name=runner_id,json=runnerId,proto3" json:"runner_id,omitempty"`
	Alias         string                 `protobuf:"bytes,4,opt,name=alias,proto3" json:"alias,omitempty"`
	Error         *ProtocolError         `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *RegisterRunnerResponse) Reset() {
	*x = RegisterRunnerResponse{}
	mi := &file_oto_runner_proto_msgTypes[3]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *RegisterRunnerResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*RegisterRunnerResponse) ProtoMessage() {}

func (x *RegisterRunnerResponse) ProtoReflect() protoreflect.Message {
	mi := &file_oto_runner_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)
}

// Deprecated: Use RegisterRunnerResponse.ProtoReflect.Descriptor instead.
func (*RegisterRunnerResponse) Descriptor() ([]byte, []int) {
	return file_oto_runner_proto_rawDescGZIP(), []int{3}
}

func (x *RegisterRunnerResponse) GetAccepted() bool {
	if x != nil {
		return x.Accepted
	}
	return false
}

func (x *RegisterRunnerResponse) GetRejectReason() string {
	if x != nil {
		return x.RejectReason
	}
	return ""
}

func (x *RegisterRunnerResponse) GetRunnerId() string {
	if x != nil {
		return x.RunnerId
	}
	return ""
}

func (x *RegisterRunnerResponse) GetAlias() string {
	if x != nil {
		return x.Alias
	}
	return ""
}

func (x *RegisterRunnerResponse) GetError() *ProtocolError {
	if x != nil {
		return x.Error
	}
	return nil
}

type HeartbeatRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	RunnerId      string                 `protobuf:"bytes,1,opt,name=runner_id,json=runnerId,proto3" json:"runner_id,omitempty"`
	Status        HeartbeatStatus        `protobuf:"varint,2,opt,name=status,proto3,enum=oto.runner.v1.HeartbeatStatus" json:"status,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *HeartbeatRequest) Reset() {
	*x = HeartbeatRequest{}
	mi := &file_oto_runner_proto_msgTypes[4]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *HeartbeatRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*HeartbeatRequest) ProtoMessage() {}

func (x *HeartbeatRequest) ProtoReflect() protoreflect.Message {
	mi := &file_oto_runner_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)
}

// Deprecated: Use HeartbeatRequest.ProtoReflect.Descriptor instead.
func (*HeartbeatRequest) Descriptor() ([]byte, []int) {
	return file_oto_runner_proto_rawDescGZIP(), []int{4}
}

func (x *HeartbeatRequest) GetRunnerId() string {
	if x != nil {
		return x.RunnerId
	}
	return ""
}

func (x *HeartbeatRequest) GetStatus() HeartbeatStatus {
	if x != nil {
		return x.Status
	}
	return HeartbeatStatus_HEARTBEAT_STATUS_UNSPECIFIED
}

type HeartbeatResponse struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Success       bool                   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	ErrorMessage  string                 `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	Error         *ProtocolError         `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *HeartbeatResponse) Reset() {
	*x = HeartbeatResponse{}
	mi := &file_oto_runner_proto_msgTypes[5]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *HeartbeatResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*HeartbeatResponse) ProtoMessage() {}

func (x *HeartbeatResponse) ProtoReflect() protoreflect.Message {
	mi := &file_oto_runner_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)
}

// Deprecated: Use HeartbeatResponse.ProtoReflect.Descriptor instead.
func (*HeartbeatResponse) Descriptor() ([]byte, []int) {
	return file_oto_runner_proto_rawDescGZIP(), []int{5}
}

func (x *HeartbeatResponse) GetSuccess() bool {
	if x != nil {
		return x.Success
	}
	return false
}

func (x *HeartbeatResponse) GetErrorMessage() string {
	if x != nil {
		return x.ErrorMessage
	}
	return ""
}

func (x *HeartbeatResponse) GetError() *ProtocolError {
	if x != nil {
		return x.Error
	}
	return nil
}

type BootstrapCommandRequest struct {
	state           protoimpl.MessageState `protogen:"open.v1"`
	RunnerId        string                 `protobuf:"bytes,1,opt,name=runner_id,json=runnerId,proto3" json:"runner_id,omitempty"`
	EnrollmentToken string                 `protobuf:"bytes,2,opt,name=enrollment_token,json=enrollmentToken,proto3" json:"enrollment_token,omitempty"`
	unknownFields   protoimpl.UnknownFields
	sizeCache       protoimpl.SizeCache
}

func (x *BootstrapCommandRequest) Reset() {
	*x = BootstrapCommandRequest{}
	mi := &file_oto_runner_proto_msgTypes[6]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *BootstrapCommandRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*BootstrapCommandRequest) ProtoMessage() {}

func (x *BootstrapCommandRequest) ProtoReflect() protoreflect.Message {
	mi := &file_oto_runner_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)
}

// Deprecated: Use BootstrapCommandRequest.ProtoReflect.Descriptor instead.
func (*BootstrapCommandRequest) Descriptor() ([]byte, []int) {
	return file_oto_runner_proto_rawDescGZIP(), []int{6}
}

func (x *BootstrapCommandRequest) GetRunnerId() string {
	if x != nil {
		return x.RunnerId
	}
	return ""
}

func (x *BootstrapCommandRequest) GetEnrollmentToken() string {
	if x != nil {
		return x.EnrollmentToken
	}
	return ""
}

type BootstrapCommandResponse struct {
	state            protoimpl.MessageState `protogen:"open.v1"`
	BootstrapCommand string                 `protobuf:"bytes,1,opt,name=bootstrap_command,json=bootstrapCommand,proto3" json:"bootstrap_command,omitempty"`
	unknownFields    protoimpl.UnknownFields
	sizeCache        protoimpl.SizeCache
}

func (x *BootstrapCommandResponse) Reset() {
	*x = BootstrapCommandResponse{}
	mi := &file_oto_runner_proto_msgTypes[7]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *BootstrapCommandResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*BootstrapCommandResponse) ProtoMessage() {}

func (x *BootstrapCommandResponse) ProtoReflect() protoreflect.Message {
	mi := &file_oto_runner_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)
}

// Deprecated: Use BootstrapCommandResponse.ProtoReflect.Descriptor instead.
func (*BootstrapCommandResponse) Descriptor() ([]byte, []int) {
	return file_oto_runner_proto_rawDescGZIP(), []int{7}
}

func (x *BootstrapCommandResponse) GetBootstrapCommand() string {
	if x != nil {
		return x.BootstrapCommand
	}
	return ""
}

type JobClaimRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	RunnerId      string                 `protobuf:"bytes,1,opt,name=runner_id,json=runnerId,proto3" json:"runner_id,omitempty"`
	JobId         string                 `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	ExecutionId   string                 `protobuf:"bytes,3,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *JobClaimRequest) Reset() {
	*x = JobClaimRequest{}
	mi := &file_oto_runner_proto_msgTypes[8]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *JobClaimRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*JobClaimRequest) ProtoMessage() {}

func (x *JobClaimRequest) ProtoReflect() protoreflect.Message {
	mi := &file_oto_runner_proto_msgTypes[8]
	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 JobClaimRequest.ProtoReflect.Descriptor instead.
func (*JobClaimRequest) Descriptor() ([]byte, []int) {
	return file_oto_runner_proto_rawDescGZIP(), []int{8}
}

func (x *JobClaimRequest) GetRunnerId() string {
	if x != nil {
		return x.RunnerId
	}
	return ""
}

func (x *JobClaimRequest) GetJobId() string {
	if x != nil {
		return x.JobId
	}
	return ""
}

func (x *JobClaimRequest) GetExecutionId() string {
	if x != nil {
		return x.ExecutionId
	}
	return ""
}

type JobClaimResponse struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Accepted      bool                   `protobuf:"varint,1,opt,name=accepted,proto3" json:"accepted,omitempty"`
	ErrorMessage  string                 `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	JobId         string                 `protobuf:"bytes,3,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	ExecutionId   string                 `protobuf:"bytes,4,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	State         string                 `protobuf:"bytes,5,opt,name=state,proto3" json:"state,omitempty"`
	RunnerId      string                 `protobuf:"bytes,6,opt,name=runner_id,json=runnerId,proto3" json:"runner_id,omitempty"`
	RunRequest    *RunRequest            `protobuf:"bytes,7,opt,name=run_request,json=runRequest,proto3" json:"run_request,omitempty"`
	Error         *ProtocolError         `protobuf:"bytes,8,opt,name=error,proto3" json:"error,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *JobClaimResponse) Reset() {
	*x = JobClaimResponse{}
	mi := &file_oto_runner_proto_msgTypes[9]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *JobClaimResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*JobClaimResponse) ProtoMessage() {}

func (x *JobClaimResponse) ProtoReflect() protoreflect.Message {
	mi := &file_oto_runner_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)
}

// Deprecated: Use JobClaimResponse.ProtoReflect.Descriptor instead.
func (*JobClaimResponse) Descriptor() ([]byte, []int) {
	return file_oto_runner_proto_rawDescGZIP(), []int{9}
}

func (x *JobClaimResponse) GetAccepted() bool {
	if x != nil {
		return x.Accepted
	}
	return false
}

func (x *JobClaimResponse) GetErrorMessage() string {
	if x != nil {
		return x.ErrorMessage
	}
	return ""
}

func (x *JobClaimResponse) GetJobId() string {
	if x != nil {
		return x.JobId
	}
	return ""
}

func (x *JobClaimResponse) GetExecutionId() string {
	if x != nil {
		return x.ExecutionId
	}
	return ""
}

func (x *JobClaimResponse) GetState() string {
	if x != nil {
		return x.State
	}
	return ""
}

func (x *JobClaimResponse) GetRunnerId() string {
	if x != nil {
		return x.RunnerId
	}
	return ""
}

func (x *JobClaimResponse) GetRunRequest() *RunRequest {
	if x != nil {
		return x.RunRequest
	}
	return nil
}

func (x *JobClaimResponse) GetError() *ProtocolError {
	if x != nil {
		return x.Error
	}
	return nil
}

type StepEventReport struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	StepId        int32                  `protobuf:"varint,1,opt,name=step_id,json=stepId,proto3" json:"step_id,omitempty"`
	WorkflowIndex int32                  `protobuf:"varint,2,opt,name=workflow_index,json=workflowIndex,proto3" json:"workflow_index,omitempty"`
	StepType      string                 `protobuf:"bytes,3,opt,name=step_type,json=stepType,proto3" json:"step_type,omitempty"`
	Event         string                 `protobuf:"bytes,4,opt,name=event,proto3" json:"event,omitempty"`
	Timestamp     string                 `protobuf:"bytes,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	CommandId     string                 `protobuf:"bytes,6,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
	CommandType   string                 `protobuf:"bytes,7,opt,name=command_type,json=commandType,proto3" json:"command_type,omitempty"`
	Error         map[string]string      `protobuf:"bytes,8,rep,name=error,proto3" json:"error,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *StepEventReport) Reset() {
	*x = StepEventReport{}
	mi := &file_oto_runner_proto_msgTypes[10]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *StepEventReport) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*StepEventReport) ProtoMessage() {}

func (x *StepEventReport) ProtoReflect() protoreflect.Message {
	mi := &file_oto_runner_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)
}

// Deprecated: Use StepEventReport.ProtoReflect.Descriptor instead.
func (*StepEventReport) Descriptor() ([]byte, []int) {
	return file_oto_runner_proto_rawDescGZIP(), []int{10}
}

func (x *StepEventReport) GetStepId() int32 {
	if x != nil {
		return x.StepId
	}
	return 0
}

func (x *StepEventReport) GetWorkflowIndex() int32 {
	if x != nil {
		return x.WorkflowIndex
	}
	return 0
}

func (x *StepEventReport) GetStepType() string {
	if x != nil {
		return x.StepType
	}
	return ""
}

func (x *StepEventReport) GetEvent() string {
	if x != nil {
		return x.Event
	}
	return ""
}

func (x *StepEventReport) GetTimestamp() string {
	if x != nil {
		return x.Timestamp
	}
	return ""
}

func (x *StepEventReport) GetCommandId() string {
	if x != nil {
		return x.CommandId
	}
	return ""
}

func (x *StepEventReport) GetCommandType() string {
	if x != nil {
		return x.CommandType
	}
	return ""
}

func (x *StepEventReport) GetError() map[string]string {
	if x != nil {
		return x.Error
	}
	return nil
}

type ExecutionReportRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	RunnerId      string                 `protobuf:"bytes,1,opt,name=runner_id,json=runnerId,proto3" json:"runner_id,omitempty"`
	JobId         string                 `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	ExecutionId   string                 `protobuf:"bytes,3,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	Success       bool                   `protobuf:"varint,4,opt,name=success,proto3" json:"success,omitempty"`
	ExitCode      int32                  `protobuf:"varint,5,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	Message       string                 `protobuf:"bytes,6,opt,name=message,proto3" json:"message,omitempty"`
	StepEvents    []*StepEventReport     `protobuf:"bytes,7,rep,name=step_events,json=stepEvents,proto3" json:"step_events,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *ExecutionReportRequest) Reset() {
	*x = ExecutionReportRequest{}
	mi := &file_oto_runner_proto_msgTypes[11]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *ExecutionReportRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*ExecutionReportRequest) ProtoMessage() {}

func (x *ExecutionReportRequest) ProtoReflect() protoreflect.Message {
	mi := &file_oto_runner_proto_msgTypes[11]
	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 ExecutionReportRequest.ProtoReflect.Descriptor instead.
func (*ExecutionReportRequest) Descriptor() ([]byte, []int) {
	return file_oto_runner_proto_rawDescGZIP(), []int{11}
}

func (x *ExecutionReportRequest) GetRunnerId() string {
	if x != nil {
		return x.RunnerId
	}
	return ""
}

func (x *ExecutionReportRequest) GetJobId() string {
	if x != nil {
		return x.JobId
	}
	return ""
}

func (x *ExecutionReportRequest) GetExecutionId() string {
	if x != nil {
		return x.ExecutionId
	}
	return ""
}

func (x *ExecutionReportRequest) GetSuccess() bool {
	if x != nil {
		return x.Success
	}
	return false
}

func (x *ExecutionReportRequest) GetExitCode() int32 {
	if x != nil {
		return x.ExitCode
	}
	return 0
}

func (x *ExecutionReportRequest) GetMessage() string {
	if x != nil {
		return x.Message
	}
	return ""
}

func (x *ExecutionReportRequest) GetStepEvents() []*StepEventReport {
	if x != nil {
		return x.StepEvents
	}
	return nil
}

type ExecutionReportResponse struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Accepted      bool                   `protobuf:"varint,1,opt,name=accepted,proto3" json:"accepted,omitempty"`
	ErrorMessage  string                 `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	JobId         string                 `protobuf:"bytes,3,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	ExecutionId   string                 `protobuf:"bytes,4,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	State         string                 `protobuf:"bytes,5,opt,name=state,proto3" json:"state,omitempty"`
	RunnerId      string                 `protobuf:"bytes,6,opt,name=runner_id,json=runnerId,proto3" json:"runner_id,omitempty"`
	Error         *ProtocolError         `protobuf:"bytes,7,opt,name=error,proto3" json:"error,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *ExecutionReportResponse) Reset() {
	*x = ExecutionReportResponse{}
	mi := &file_oto_runner_proto_msgTypes[12]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *ExecutionReportResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*ExecutionReportResponse) ProtoMessage() {}

func (x *ExecutionReportResponse) ProtoReflect() protoreflect.Message {
	mi := &file_oto_runner_proto_msgTypes[12]
	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 ExecutionReportResponse.ProtoReflect.Descriptor instead.
func (*ExecutionReportResponse) Descriptor() ([]byte, []int) {
	return file_oto_runner_proto_rawDescGZIP(), []int{12}
}

func (x *ExecutionReportResponse) GetAccepted() bool {
	if x != nil {
		return x.Accepted
	}
	return false
}

func (x *ExecutionReportResponse) GetErrorMessage() string {
	if x != nil {
		return x.ErrorMessage
	}
	return ""
}

func (x *ExecutionReportResponse) GetJobId() string {
	if x != nil {
		return x.JobId
	}
	return ""
}

func (x *ExecutionReportResponse) GetExecutionId() string {
	if x != nil {
		return x.ExecutionId
	}
	return ""
}

func (x *ExecutionReportResponse) GetState() string {
	if x != nil {
		return x.State
	}
	return ""
}

func (x *ExecutionReportResponse) GetRunnerId() string {
	if x != nil {
		return x.RunnerId
	}
	return ""
}

func (x *ExecutionReportResponse) GetError() *ProtocolError {
	if x != nil {
		return x.Error
	}
	return nil
}

type LogAppendRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	RunnerId      string                 `protobuf:"bytes,1,opt,name=runner_id,json=runnerId,proto3" json:"runner_id,omitempty"`
	ExecutionId   string                 `protobuf:"bytes,2,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	Line          string                 `protobuf:"bytes,3,opt,name=line,proto3" json:"line,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *LogAppendRequest) Reset() {
	*x = LogAppendRequest{}
	mi := &file_oto_runner_proto_msgTypes[13]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *LogAppendRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*LogAppendRequest) ProtoMessage() {}

func (x *LogAppendRequest) ProtoReflect() protoreflect.Message {
	mi := &file_oto_runner_proto_msgTypes[13]
	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 LogAppendRequest.ProtoReflect.Descriptor instead.
func (*LogAppendRequest) Descriptor() ([]byte, []int) {
	return file_oto_runner_proto_rawDescGZIP(), []int{13}
}

func (x *LogAppendRequest) GetRunnerId() string {
	if x != nil {
		return x.RunnerId
	}
	return ""
}

func (x *LogAppendRequest) GetExecutionId() string {
	if x != nil {
		return x.ExecutionId
	}
	return ""
}

func (x *LogAppendRequest) GetLine() string {
	if x != nil {
		return x.Line
	}
	return ""
}

type LogAppendResponse struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Accepted      bool                   `protobuf:"varint,1,opt,name=accepted,proto3" json:"accepted,omitempty"`
	ErrorMessage  string                 `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	Error         *ProtocolError         `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *LogAppendResponse) Reset() {
	*x = LogAppendResponse{}
	mi := &file_oto_runner_proto_msgTypes[14]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *LogAppendResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*LogAppendResponse) ProtoMessage() {}

func (x *LogAppendResponse) ProtoReflect() protoreflect.Message {
	mi := &file_oto_runner_proto_msgTypes[14]
	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 LogAppendResponse.ProtoReflect.Descriptor instead.
func (*LogAppendResponse) Descriptor() ([]byte, []int) {
	return file_oto_runner_proto_rawDescGZIP(), []int{14}
}

func (x *LogAppendResponse) GetAccepted() bool {
	if x != nil {
		return x.Accepted
	}
	return false
}

func (x *LogAppendResponse) GetErrorMessage() string {
	if x != nil {
		return x.ErrorMessage
	}
	return ""
}

func (x *LogAppendResponse) GetError() *ProtocolError {
	if x != nil {
		return x.Error
	}
	return nil
}

type ArtifactReportRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	RunnerId      string                 `protobuf:"bytes,1,opt,name=runner_id,json=runnerId,proto3" json:"runner_id,omitempty"`
	ExecutionId   string                 `protobuf:"bytes,2,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	Name          string                 `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Path          string                 `protobuf:"bytes,4,opt,name=path,proto3" json:"path,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *ArtifactReportRequest) Reset() {
	*x = ArtifactReportRequest{}
	mi := &file_oto_runner_proto_msgTypes[15]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *ArtifactReportRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*ArtifactReportRequest) ProtoMessage() {}

func (x *ArtifactReportRequest) ProtoReflect() protoreflect.Message {
	mi := &file_oto_runner_proto_msgTypes[15]
	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 ArtifactReportRequest.ProtoReflect.Descriptor instead.
func (*ArtifactReportRequest) Descriptor() ([]byte, []int) {
	return file_oto_runner_proto_rawDescGZIP(), []int{15}
}

func (x *ArtifactReportRequest) GetRunnerId() string {
	if x != nil {
		return x.RunnerId
	}
	return ""
}

func (x *ArtifactReportRequest) GetExecutionId() string {
	if x != nil {
		return x.ExecutionId
	}
	return ""
}

func (x *ArtifactReportRequest) GetName() string {
	if x != nil {
		return x.Name
	}
	return ""
}

func (x *ArtifactReportRequest) GetPath() string {
	if x != nil {
		return x.Path
	}
	return ""
}

type ArtifactReportResponse struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Accepted      bool                   `protobuf:"varint,1,opt,name=accepted,proto3" json:"accepted,omitempty"`
	ErrorMessage  string                 `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	Error         *ProtocolError         `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *ArtifactReportResponse) Reset() {
	*x = ArtifactReportResponse{}
	mi := &file_oto_runner_proto_msgTypes[16]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *ArtifactReportResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*ArtifactReportResponse) ProtoMessage() {}

func (x *ArtifactReportResponse) ProtoReflect() protoreflect.Message {
	mi := &file_oto_runner_proto_msgTypes[16]
	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 ArtifactReportResponse.ProtoReflect.Descriptor instead.
func (*ArtifactReportResponse) Descriptor() ([]byte, []int) {
	return file_oto_runner_proto_rawDescGZIP(), []int{16}
}

func (x *ArtifactReportResponse) GetAccepted() bool {
	if x != nil {
		return x.Accepted
	}
	return false
}

func (x *ArtifactReportResponse) GetErrorMessage() string {
	if x != nil {
		return x.ErrorMessage
	}
	return ""
}

func (x *ArtifactReportResponse) GetError() *ProtocolError {
	if x != nil {
		return x.Error
	}
	return nil
}

type ProtocolError struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Code          string                 `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	Message       string                 `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Details       map[string]string      `protobuf:"bytes,3,rep,name=details,proto3" json:"details,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *ProtocolError) Reset() {
	*x = ProtocolError{}
	mi := &file_oto_runner_proto_msgTypes[17]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *ProtocolError) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*ProtocolError) ProtoMessage() {}

func (x *ProtocolError) ProtoReflect() protoreflect.Message {
	mi := &file_oto_runner_proto_msgTypes[17]
	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 ProtocolError.ProtoReflect.Descriptor instead.
func (*ProtocolError) Descriptor() ([]byte, []int) {
	return file_oto_runner_proto_rawDescGZIP(), []int{17}
}

func (x *ProtocolError) GetCode() string {
	if x != nil {
		return x.Code
	}
	return ""
}

func (x *ProtocolError) GetMessage() string {
	if x != nil {
		return x.Message
	}
	return ""
}

func (x *ProtocolError) GetDetails() map[string]string {
	if x != nil {
		return x.Details
	}
	return nil
}

type RunRequest struct {
	state            protoimpl.MessageState `protogen:"open.v1"`
	RunnerId         string                 `protobuf:"bytes,1,opt,name=runner_id,json=runnerId,proto3" json:"runner_id,omitempty"`
	JobId            string                 `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	ExecutionId      string                 `protobuf:"bytes,3,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	PipelineYamlPath string                 `protobuf:"bytes,4,opt,name=pipeline_yaml_path,json=pipelineYamlPath,proto3" json:"pipeline_yaml_path,omitempty"`                                   // Path to the pipeline YAML file to be executed
	PipelineYaml     string                 `protobuf:"bytes,5,opt,name=pipeline_yaml,json=pipelineYaml,proto3" json:"pipeline_yaml,omitempty"`                                                 // Inline content of the pipeline YAML if passed directly
	Variables        map[string]string      `protobuf:"bytes,6,rep,name=variables,proto3" json:"variables,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"` // Execution variables/parameters
	CommandTypes     []string               `protobuf:"bytes,7,rep,name=command_types,json=commandTypes,proto3" json:"command_types,omitempty"`                                                 // List of command types that are allowed or required, representing the capability/catalog limits
	unknownFields    protoimpl.UnknownFields
	sizeCache        protoimpl.SizeCache
}

func (x *RunRequest) Reset() {
	*x = RunRequest{}
	mi := &file_oto_runner_proto_msgTypes[18]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *RunRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*RunRequest) ProtoMessage() {}

func (x *RunRequest) ProtoReflect() protoreflect.Message {
	mi := &file_oto_runner_proto_msgTypes[18]
	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 RunRequest.ProtoReflect.Descriptor instead.
func (*RunRequest) Descriptor() ([]byte, []int) {
	return file_oto_runner_proto_rawDescGZIP(), []int{18}
}

func (x *RunRequest) GetRunnerId() string {
	if x != nil {
		return x.RunnerId
	}
	return ""
}

func (x *RunRequest) GetJobId() string {
	if x != nil {
		return x.JobId
	}
	return ""
}

func (x *RunRequest) GetExecutionId() string {
	if x != nil {
		return x.ExecutionId
	}
	return ""
}

func (x *RunRequest) GetPipelineYamlPath() string {
	if x != nil {
		return x.PipelineYamlPath
	}
	return ""
}

func (x *RunRequest) GetPipelineYaml() string {
	if x != nil {
		return x.PipelineYaml
	}
	return ""
}

func (x *RunRequest) GetVariables() map[string]string {
	if x != nil {
		return x.Variables
	}
	return nil
}

func (x *RunRequest) GetCommandTypes() []string {
	if x != nil {
		return x.CommandTypes
	}
	return nil
}

type CancelRunRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	RunnerId      string                 `protobuf:"bytes,1,opt,name=runner_id,json=runnerId,proto3" json:"runner_id,omitempty"`
	ExecutionId   string                 `protobuf:"bytes,2,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	Reason        string                 `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *CancelRunRequest) Reset() {
	*x = CancelRunRequest{}
	mi := &file_oto_runner_proto_msgTypes[19]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *CancelRunRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*CancelRunRequest) ProtoMessage() {}

func (x *CancelRunRequest) ProtoReflect() protoreflect.Message {
	mi := &file_oto_runner_proto_msgTypes[19]
	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 CancelRunRequest.ProtoReflect.Descriptor instead.
func (*CancelRunRequest) Descriptor() ([]byte, []int) {
	return file_oto_runner_proto_rawDescGZIP(), []int{19}
}

func (x *CancelRunRequest) GetRunnerId() string {
	if x != nil {
		return x.RunnerId
	}
	return ""
}

func (x *CancelRunRequest) GetExecutionId() string {
	if x != nil {
		return x.ExecutionId
	}
	return ""
}

func (x *CancelRunRequest) GetReason() string {
	if x != nil {
		return x.Reason
	}
	return ""
}

type CancelRunResponse struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Success       bool                   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	ErrorMessage  string                 `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	Error         *ProtocolError         `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *CancelRunResponse) Reset() {
	*x = CancelRunResponse{}
	mi := &file_oto_runner_proto_msgTypes[20]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *CancelRunResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*CancelRunResponse) ProtoMessage() {}

func (x *CancelRunResponse) ProtoReflect() protoreflect.Message {
	mi := &file_oto_runner_proto_msgTypes[20]
	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 CancelRunResponse.ProtoReflect.Descriptor instead.
func (*CancelRunResponse) Descriptor() ([]byte, []int) {
	return file_oto_runner_proto_rawDescGZIP(), []int{20}
}

func (x *CancelRunResponse) GetSuccess() bool {
	if x != nil {
		return x.Success
	}
	return false
}

func (x *CancelRunResponse) GetErrorMessage() string {
	if x != nil {
		return x.ErrorMessage
	}
	return ""
}

func (x *CancelRunResponse) GetError() *ProtocolError {
	if x != nil {
		return x.Error
	}
	return nil
}

type RunnerStatusRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	RunnerId      string                 `protobuf:"bytes,1,opt,name=runner_id,json=runnerId,proto3" json:"runner_id,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *RunnerStatusRequest) Reset() {
	*x = RunnerStatusRequest{}
	mi := &file_oto_runner_proto_msgTypes[21]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *RunnerStatusRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*RunnerStatusRequest) ProtoMessage() {}

func (x *RunnerStatusRequest) ProtoReflect() protoreflect.Message {
	mi := &file_oto_runner_proto_msgTypes[21]
	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 RunnerStatusRequest.ProtoReflect.Descriptor instead.
func (*RunnerStatusRequest) Descriptor() ([]byte, []int) {
	return file_oto_runner_proto_rawDescGZIP(), []int{21}
}

func (x *RunnerStatusRequest) GetRunnerId() string {
	if x != nil {
		return x.RunnerId
	}
	return ""
}

type RunnerStatusResponse struct {
	state              protoimpl.MessageState `protogen:"open.v1"`
	RunnerId           string                 `protobuf:"bytes,1,opt,name=runner_id,json=runnerId,proto3" json:"runner_id,omitempty"`
	Status             string                 `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	CurrentExecutionId string                 `protobuf:"bytes,3,opt,name=current_execution_id,json=currentExecutionId,proto3" json:"current_execution_id,omitempty"`
	Error              *ProtocolError         `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	unknownFields      protoimpl.UnknownFields
	sizeCache          protoimpl.SizeCache
}

func (x *RunnerStatusResponse) Reset() {
	*x = RunnerStatusResponse{}
	mi := &file_oto_runner_proto_msgTypes[22]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *RunnerStatusResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*RunnerStatusResponse) ProtoMessage() {}

func (x *RunnerStatusResponse) ProtoReflect() protoreflect.Message {
	mi := &file_oto_runner_proto_msgTypes[22]
	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 RunnerStatusResponse.ProtoReflect.Descriptor instead.
func (*RunnerStatusResponse) Descriptor() ([]byte, []int) {
	return file_oto_runner_proto_rawDescGZIP(), []int{22}
}

func (x *RunnerStatusResponse) GetRunnerId() string {
	if x != nil {
		return x.RunnerId
	}
	return ""
}

func (x *RunnerStatusResponse) GetStatus() string {
	if x != nil {
		return x.Status
	}
	return ""
}

func (x *RunnerStatusResponse) GetCurrentExecutionId() string {
	if x != nil {
		return x.CurrentExecutionId
	}
	return ""
}

func (x *RunnerStatusResponse) GetError() *ProtocolError {
	if x != nil {
		return x.Error
	}
	return nil
}

type SelfUpdateRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	RunnerId      string                 `protobuf:"bytes,1,opt,name=runner_id,json=runnerId,proto3" json:"runner_id,omitempty"`
	Version       string                 `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	DownloadUrl   string                 `protobuf:"bytes,3,opt,name=download_url,json=downloadUrl,proto3" json:"download_url,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *SelfUpdateRequest) Reset() {
	*x = SelfUpdateRequest{}
	mi := &file_oto_runner_proto_msgTypes[23]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *SelfUpdateRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*SelfUpdateRequest) ProtoMessage() {}

func (x *SelfUpdateRequest) ProtoReflect() protoreflect.Message {
	mi := &file_oto_runner_proto_msgTypes[23]
	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 SelfUpdateRequest.ProtoReflect.Descriptor instead.
func (*SelfUpdateRequest) Descriptor() ([]byte, []int) {
	return file_oto_runner_proto_rawDescGZIP(), []int{23}
}

func (x *SelfUpdateRequest) GetRunnerId() string {
	if x != nil {
		return x.RunnerId
	}
	return ""
}

func (x *SelfUpdateRequest) GetVersion() string {
	if x != nil {
		return x.Version
	}
	return ""
}

func (x *SelfUpdateRequest) GetDownloadUrl() string {
	if x != nil {
		return x.DownloadUrl
	}
	return ""
}

type SelfUpdateResponse struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Success       bool                   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	ErrorMessage  string                 `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	Error         *ProtocolError         `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *SelfUpdateResponse) Reset() {
	*x = SelfUpdateResponse{}
	mi := &file_oto_runner_proto_msgTypes[24]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *SelfUpdateResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*SelfUpdateResponse) ProtoMessage() {}

func (x *SelfUpdateResponse) ProtoReflect() protoreflect.Message {
	mi := &file_oto_runner_proto_msgTypes[24]
	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 SelfUpdateResponse.ProtoReflect.Descriptor instead.
func (*SelfUpdateResponse) Descriptor() ([]byte, []int) {
	return file_oto_runner_proto_rawDescGZIP(), []int{24}
}

func (x *SelfUpdateResponse) GetSuccess() bool {
	if x != nil {
		return x.Success
	}
	return false
}

func (x *SelfUpdateResponse) GetErrorMessage() string {
	if x != nil {
		return x.ErrorMessage
	}
	return ""
}

func (x *SelfUpdateResponse) GetError() *ProtocolError {
	if x != nil {
		return x.Error
	}
	return nil
}

var File_oto_runner_proto protoreflect.FileDescriptor

const file_oto_runner_proto_rawDesc = "" +
	"\n" +
	"\x10oto/runner.proto\x12\roto.runner.v1\"@\n" +
	"\x10RunnerCapability\x12\x12\n" +
	"\x04name\x18\x01 \x01(\tR\x04name\x12\x18\n" +
	"\aversion\x18\x02 \x01(\tR\aversion\"<\n" +
	"\x15CommandCatalogSummary\x12#\n" +
	"\rcommand_types\x18\x01 \x03(\tR\fcommandTypes\"\xb0\x02\n" +
	"\x15RegisterRunnerRequest\x12)\n" +
	"\x10enrollment_token\x18\x01 \x01(\tR\x0fenrollmentToken\x12\x1b\n" +
	"\trunner_id\x18\x02 \x01(\tR\brunnerId\x12\x14\n" +
	"\x05alias\x18\x03 \x01(\tR\x05alias\x12)\n" +
	"\x10protocol_version\x18\x04 \x01(\tR\x0fprotocolVersion\x12?\n" +
	"\n" +
	"capability\x18\x05 \x01(\v2\x1f.oto.runner.v1.RunnerCapabilityR\n" +
	"capability\x12M\n" +
	"\x0fcommand_catalog\x18\x06 \x01(\v2$.oto.runner.v1.CommandCatalogSummaryR\x0ecommandCatalog\"\xc0\x01\n" +
	"\x16RegisterRunnerResponse\x12\x1a\n" +
	"\baccepted\x18\x01 \x01(\bR\baccepted\x12#\n" +
	"\rreject_reason\x18\x02 \x01(\tR\frejectReason\x12\x1b\n" +
	"\trunner_id\x18\x03 \x01(\tR\brunnerId\x12\x14\n" +
	"\x05alias\x18\x04 \x01(\tR\x05alias\x122\n" +
	"\x05error\x18\x05 \x01(\v2\x1c.oto.runner.v1.ProtocolErrorR\x05error\"g\n" +
	"\x10HeartbeatRequest\x12\x1b\n" +
	"\trunner_id\x18\x01 \x01(\tR\brunnerId\x126\n" +
	"\x06status\x18\x02 \x01(\x0e2\x1e.oto.runner.v1.HeartbeatStatusR\x06status\"\x86\x01\n" +
	"\x11HeartbeatResponse\x12\x18\n" +
	"\asuccess\x18\x01 \x01(\bR\asuccess\x12#\n" +
	"\rerror_message\x18\x02 \x01(\tR\ferrorMessage\x122\n" +
	"\x05error\x18\x03 \x01(\v2\x1c.oto.runner.v1.ProtocolErrorR\x05error\"a\n" +
	"\x17BootstrapCommandRequest\x12\x1b\n" +
	"\trunner_id\x18\x01 \x01(\tR\brunnerId\x12)\n" +
	"\x10enrollment_token\x18\x02 \x01(\tR\x0fenrollmentToken\"G\n" +
	"\x18BootstrapCommandResponse\x12+\n" +
	"\x11bootstrap_command\x18\x01 \x01(\tR\x10bootstrapCommand\"h\n" +
	"\x0fJobClaimRequest\x12\x1b\n" +
	"\trunner_id\x18\x01 \x01(\tR\brunnerId\x12\x15\n" +
	"\x06job_id\x18\x02 \x01(\tR\x05jobId\x12!\n" +
	"\fexecution_id\x18\x03 \x01(\tR\vexecutionId\"\xb0\x02\n" +
	"\x10JobClaimResponse\x12\x1a\n" +
	"\baccepted\x18\x01 \x01(\bR\baccepted\x12#\n" +
	"\rerror_message\x18\x02 \x01(\tR\ferrorMessage\x12\x15\n" +
	"\x06job_id\x18\x03 \x01(\tR\x05jobId\x12!\n" +
	"\fexecution_id\x18\x04 \x01(\tR\vexecutionId\x12\x14\n" +
	"\x05state\x18\x05 \x01(\tR\x05state\x12\x1b\n" +
	"\trunner_id\x18\x06 \x01(\tR\brunnerId\x12:\n" +
	"\vrun_request\x18\a \x01(\v2\x19.oto.runner.v1.RunRequestR\n" +
	"runRequest\x122\n" +
	"\x05error\x18\b \x01(\v2\x1c.oto.runner.v1.ProtocolErrorR\x05error\"\xdf\x02\n" +
	"\x0fStepEventReport\x12\x17\n" +
	"\astep_id\x18\x01 \x01(\x05R\x06stepId\x12%\n" +
	"\x0eworkflow_index\x18\x02 \x01(\x05R\rworkflowIndex\x12\x1b\n" +
	"\tstep_type\x18\x03 \x01(\tR\bstepType\x12\x14\n" +
	"\x05event\x18\x04 \x01(\tR\x05event\x12\x1c\n" +
	"\ttimestamp\x18\x05 \x01(\tR\ttimestamp\x12\x1d\n" +
	"\n" +
	"command_id\x18\x06 \x01(\tR\tcommandId\x12!\n" +
	"\fcommand_type\x18\a \x01(\tR\vcommandType\x12?\n" +
	"\x05error\x18\b \x03(\v2).oto.runner.v1.StepEventReport.ErrorEntryR\x05error\x1a8\n" +
	"\n" +
	"ErrorEntry\x12\x10\n" +
	"\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n" +
	"\x05value\x18\x02 \x01(\tR\x05value:\x028\x01\"\x81\x02\n" +
	"\x16ExecutionReportRequest\x12\x1b\n" +
	"\trunner_id\x18\x01 \x01(\tR\brunnerId\x12\x15\n" +
	"\x06job_id\x18\x02 \x01(\tR\x05jobId\x12!\n" +
	"\fexecution_id\x18\x03 \x01(\tR\vexecutionId\x12\x18\n" +
	"\asuccess\x18\x04 \x01(\bR\asuccess\x12\x1b\n" +
	"\texit_code\x18\x05 \x01(\x05R\bexitCode\x12\x18\n" +
	"\amessage\x18\x06 \x01(\tR\amessage\x12?\n" +
	"\vstep_events\x18\a \x03(\v2\x1e.oto.runner.v1.StepEventReportR\n" +
	"stepEvents\"\xfb\x01\n" +
	"\x17ExecutionReportResponse\x12\x1a\n" +
	"\baccepted\x18\x01 \x01(\bR\baccepted\x12#\n" +
	"\rerror_message\x18\x02 \x01(\tR\ferrorMessage\x12\x15\n" +
	"\x06job_id\x18\x03 \x01(\tR\x05jobId\x12!\n" +
	"\fexecution_id\x18\x04 \x01(\tR\vexecutionId\x12\x14\n" +
	"\x05state\x18\x05 \x01(\tR\x05state\x12\x1b\n" +
	"\trunner_id\x18\x06 \x01(\tR\brunnerId\x122\n" +
	"\x05error\x18\a \x01(\v2\x1c.oto.runner.v1.ProtocolErrorR\x05error\"f\n" +
	"\x10LogAppendRequest\x12\x1b\n" +
	"\trunner_id\x18\x01 \x01(\tR\brunnerId\x12!\n" +
	"\fexecution_id\x18\x02 \x01(\tR\vexecutionId\x12\x12\n" +
	"\x04line\x18\x03 \x01(\tR\x04line\"\x88\x01\n" +
	"\x11LogAppendResponse\x12\x1a\n" +
	"\baccepted\x18\x01 \x01(\bR\baccepted\x12#\n" +
	"\rerror_message\x18\x02 \x01(\tR\ferrorMessage\x122\n" +
	"\x05error\x18\x03 \x01(\v2\x1c.oto.runner.v1.ProtocolErrorR\x05error\"\x7f\n" +
	"\x15ArtifactReportRequest\x12\x1b\n" +
	"\trunner_id\x18\x01 \x01(\tR\brunnerId\x12!\n" +
	"\fexecution_id\x18\x02 \x01(\tR\vexecutionId\x12\x12\n" +
	"\x04name\x18\x03 \x01(\tR\x04name\x12\x12\n" +
	"\x04path\x18\x04 \x01(\tR\x04path\"\x8d\x01\n" +
	"\x16ArtifactReportResponse\x12\x1a\n" +
	"\baccepted\x18\x01 \x01(\bR\baccepted\x12#\n" +
	"\rerror_message\x18\x02 \x01(\tR\ferrorMessage\x122\n" +
	"\x05error\x18\x03 \x01(\v2\x1c.oto.runner.v1.ProtocolErrorR\x05error\"\xbe\x01\n" +
	"\rProtocolError\x12\x12\n" +
	"\x04code\x18\x01 \x01(\tR\x04code\x12\x18\n" +
	"\amessage\x18\x02 \x01(\tR\amessage\x12C\n" +
	"\adetails\x18\x03 \x03(\v2).oto.runner.v1.ProtocolError.DetailsEntryR\adetails\x1a:\n" +
	"\fDetailsEntry\x12\x10\n" +
	"\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n" +
	"\x05value\x18\x02 \x01(\tR\x05value:\x028\x01\"\xe1\x02\n" +
	"\n" +
	"RunRequest\x12\x1b\n" +
	"\trunner_id\x18\x01 \x01(\tR\brunnerId\x12\x15\n" +
	"\x06job_id\x18\x02 \x01(\tR\x05jobId\x12!\n" +
	"\fexecution_id\x18\x03 \x01(\tR\vexecutionId\x12,\n" +
	"\x12pipeline_yaml_path\x18\x04 \x01(\tR\x10pipelineYamlPath\x12#\n" +
	"\rpipeline_yaml\x18\x05 \x01(\tR\fpipelineYaml\x12F\n" +
	"\tvariables\x18\x06 \x03(\v2(.oto.runner.v1.RunRequest.VariablesEntryR\tvariables\x12#\n" +
	"\rcommand_types\x18\a \x03(\tR\fcommandTypes\x1a<\n" +
	"\x0eVariablesEntry\x12\x10\n" +
	"\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n" +
	"\x05value\x18\x02 \x01(\tR\x05value:\x028\x01\"j\n" +
	"\x10CancelRunRequest\x12\x1b\n" +
	"\trunner_id\x18\x01 \x01(\tR\brunnerId\x12!\n" +
	"\fexecution_id\x18\x02 \x01(\tR\vexecutionId\x12\x16\n" +
	"\x06reason\x18\x03 \x01(\tR\x06reason\"\x86\x01\n" +
	"\x11CancelRunResponse\x12\x18\n" +
	"\asuccess\x18\x01 \x01(\bR\asuccess\x12#\n" +
	"\rerror_message\x18\x02 \x01(\tR\ferrorMessage\x122\n" +
	"\x05error\x18\x03 \x01(\v2\x1c.oto.runner.v1.ProtocolErrorR\x05error\"2\n" +
	"\x13RunnerStatusRequest\x12\x1b\n" +
	"\trunner_id\x18\x01 \x01(\tR\brunnerId\"\xb1\x01\n" +
	"\x14RunnerStatusResponse\x12\x1b\n" +
	"\trunner_id\x18\x01 \x01(\tR\brunnerId\x12\x16\n" +
	"\x06status\x18\x02 \x01(\tR\x06status\x120\n" +
	"\x14current_execution_id\x18\x03 \x01(\tR\x12currentExecutionId\x122\n" +
	"\x05error\x18\x04 \x01(\v2\x1c.oto.runner.v1.ProtocolErrorR\x05error\"m\n" +
	"\x11SelfUpdateRequest\x12\x1b\n" +
	"\trunner_id\x18\x01 \x01(\tR\brunnerId\x12\x18\n" +
	"\aversion\x18\x02 \x01(\tR\aversion\x12!\n" +
	"\fdownload_url\x18\x03 \x01(\tR\vdownloadUrl\"\x87\x01\n" +
	"\x12SelfUpdateResponse\x12\x18\n" +
	"\asuccess\x18\x01 \x01(\bR\asuccess\x12#\n" +
	"\rerror_message\x18\x02 \x01(\tR\ferrorMessage\x122\n" +
	"\x05error\x18\x03 \x01(\v2\x1c.oto.runner.v1.ProtocolErrorR\x05error*q\n" +
	"\x0fHeartbeatStatus\x12 \n" +
	"\x1cHEARTBEAT_STATUS_UNSPECIFIED\x10\x00\x12\x1c\n" +
	"\x18HEARTBEAT_STATUS_HEALTHY\x10\x01\x12\x1e\n" +
	"\x1aHEARTBEAT_STATUS_UNHEALTHY\x10\x02B-Z+github.com/toki/oto/services/core/oto;otopbb\x06proto3"

var (
	file_oto_runner_proto_rawDescOnce sync.Once
	file_oto_runner_proto_rawDescData []byte
)

func file_oto_runner_proto_rawDescGZIP() []byte {
	file_oto_runner_proto_rawDescOnce.Do(func() {
		file_oto_runner_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_oto_runner_proto_rawDesc), len(file_oto_runner_proto_rawDesc)))
	})
	return file_oto_runner_proto_rawDescData
}

var file_oto_runner_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
var file_oto_runner_proto_msgTypes = make([]protoimpl.MessageInfo, 28)
var file_oto_runner_proto_goTypes = []any{
	(HeartbeatStatus)(0),             // 0: oto.runner.v1.HeartbeatStatus
	(*RunnerCapability)(nil),         // 1: oto.runner.v1.RunnerCapability
	(*CommandCatalogSummary)(nil),    // 2: oto.runner.v1.CommandCatalogSummary
	(*RegisterRunnerRequest)(nil),    // 3: oto.runner.v1.RegisterRunnerRequest
	(*RegisterRunnerResponse)(nil),   // 4: oto.runner.v1.RegisterRunnerResponse
	(*HeartbeatRequest)(nil),         // 5: oto.runner.v1.HeartbeatRequest
	(*HeartbeatResponse)(nil),        // 6: oto.runner.v1.HeartbeatResponse
	(*BootstrapCommandRequest)(nil),  // 7: oto.runner.v1.BootstrapCommandRequest
	(*BootstrapCommandResponse)(nil), // 8: oto.runner.v1.BootstrapCommandResponse
	(*JobClaimRequest)(nil),          // 9: oto.runner.v1.JobClaimRequest
	(*JobClaimResponse)(nil),         // 10: oto.runner.v1.JobClaimResponse
	(*StepEventReport)(nil),          // 11: oto.runner.v1.StepEventReport
	(*ExecutionReportRequest)(nil),   // 12: oto.runner.v1.ExecutionReportRequest
	(*ExecutionReportResponse)(nil),  // 13: oto.runner.v1.ExecutionReportResponse
	(*LogAppendRequest)(nil),         // 14: oto.runner.v1.LogAppendRequest
	(*LogAppendResponse)(nil),        // 15: oto.runner.v1.LogAppendResponse
	(*ArtifactReportRequest)(nil),    // 16: oto.runner.v1.ArtifactReportRequest
	(*ArtifactReportResponse)(nil),   // 17: oto.runner.v1.ArtifactReportResponse
	(*ProtocolError)(nil),            // 18: oto.runner.v1.ProtocolError
	(*RunRequest)(nil),               // 19: oto.runner.v1.RunRequest
	(*CancelRunRequest)(nil),         // 20: oto.runner.v1.CancelRunRequest
	(*CancelRunResponse)(nil),        // 21: oto.runner.v1.CancelRunResponse
	(*RunnerStatusRequest)(nil),      // 22: oto.runner.v1.RunnerStatusRequest
	(*RunnerStatusResponse)(nil),     // 23: oto.runner.v1.RunnerStatusResponse
	(*SelfUpdateRequest)(nil),        // 24: oto.runner.v1.SelfUpdateRequest
	(*SelfUpdateResponse)(nil),       // 25: oto.runner.v1.SelfUpdateResponse
	nil,                              // 26: oto.runner.v1.StepEventReport.ErrorEntry
	nil,                              // 27: oto.runner.v1.ProtocolError.DetailsEntry
	nil,                              // 28: oto.runner.v1.RunRequest.VariablesEntry
}
var file_oto_runner_proto_depIdxs = []int32{
	1,  // 0: oto.runner.v1.RegisterRunnerRequest.capability:type_name -> oto.runner.v1.RunnerCapability
	2,  // 1: oto.runner.v1.RegisterRunnerRequest.command_catalog:type_name -> oto.runner.v1.CommandCatalogSummary
	18, // 2: oto.runner.v1.RegisterRunnerResponse.error:type_name -> oto.runner.v1.ProtocolError
	0,  // 3: oto.runner.v1.HeartbeatRequest.status:type_name -> oto.runner.v1.HeartbeatStatus
	18, // 4: oto.runner.v1.HeartbeatResponse.error:type_name -> oto.runner.v1.ProtocolError
	19, // 5: oto.runner.v1.JobClaimResponse.run_request:type_name -> oto.runner.v1.RunRequest
	18, // 6: oto.runner.v1.JobClaimResponse.error:type_name -> oto.runner.v1.ProtocolError
	26, // 7: oto.runner.v1.StepEventReport.error:type_name -> oto.runner.v1.StepEventReport.ErrorEntry
	11, // 8: oto.runner.v1.ExecutionReportRequest.step_events:type_name -> oto.runner.v1.StepEventReport
	18, // 9: oto.runner.v1.ExecutionReportResponse.error:type_name -> oto.runner.v1.ProtocolError
	18, // 10: oto.runner.v1.LogAppendResponse.error:type_name -> oto.runner.v1.ProtocolError
	18, // 11: oto.runner.v1.ArtifactReportResponse.error:type_name -> oto.runner.v1.ProtocolError
	27, // 12: oto.runner.v1.ProtocolError.details:type_name -> oto.runner.v1.ProtocolError.DetailsEntry
	28, // 13: oto.runner.v1.RunRequest.variables:type_name -> oto.runner.v1.RunRequest.VariablesEntry
	18, // 14: oto.runner.v1.CancelRunResponse.error:type_name -> oto.runner.v1.ProtocolError
	18, // 15: oto.runner.v1.RunnerStatusResponse.error:type_name -> oto.runner.v1.ProtocolError
	18, // 16: oto.runner.v1.SelfUpdateResponse.error:type_name -> oto.runner.v1.ProtocolError
	17, // [17:17] is the sub-list for method output_type
	17, // [17:17] is the sub-list for method input_type
	17, // [17:17] is the sub-list for extension type_name
	17, // [17:17] is the sub-list for extension extendee
	0,  // [0:17] is the sub-list for field type_name
}

func init() { file_oto_runner_proto_init() }
func file_oto_runner_proto_init() {
	if File_oto_runner_proto != nil {
		return
	}
	type x struct{}
	out := protoimpl.TypeBuilder{
		File: protoimpl.DescBuilder{
			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
			RawDescriptor: unsafe.Slice(unsafe.StringData(file_oto_runner_proto_rawDesc), len(file_oto_runner_proto_rawDesc)),
			NumEnums:      1,
			NumMessages:   28,
			NumExtensions: 0,
			NumServices:   0,
		},
		GoTypes:           file_oto_runner_proto_goTypes,
		DependencyIndexes: file_oto_runner_proto_depIdxs,
		EnumInfos:         file_oto_runner_proto_enumTypes,
		MessageInfos:      file_oto_runner_proto_msgTypes,
	}.Build()
	File_oto_runner_proto = out.File
	file_oto_runner_proto_goTypes = nil
	file_oto_runner_proto_depIdxs = nil
}