livekit-protocol 0.7.5

// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// 	protoc-gen-go v1.36.11
// 	protoc        v4.23.4
// source: agent/livekit_agent_dev.proto

package agent

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)
)

// AgentDevMessage is used for IPC between the CLI and agent processes
// during dev-mode hot reload.
type AgentDevMessage struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Types that are valid to be assigned to Message:
	//
	//	*AgentDevMessage_GetRunningJobsRequest
	//	*AgentDevMessage_GetRunningJobsResponse
	Message       isAgentDevMessage_Message `protobuf_oneof:"message"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*AgentDevMessage) ProtoMessage() {}

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

func (x *AgentDevMessage) GetMessage() isAgentDevMessage_Message {
	if x != nil {
		return x.Message
	}
	return nil
}

func (x *AgentDevMessage) GetGetRunningJobsRequest() *GetRunningAgentJobsRequest {
	if x != nil {
		if x, ok := x.Message.(*AgentDevMessage_GetRunningJobsRequest); ok {
			return x.GetRunningJobsRequest
		}
	}
	return nil
}

func (x *AgentDevMessage) GetGetRunningJobsResponse() *GetRunningAgentJobsResponse {
	if x != nil {
		if x, ok := x.Message.(*AgentDevMessage_GetRunningJobsResponse); ok {
			return x.GetRunningJobsResponse
		}
	}
	return nil
}

type isAgentDevMessage_Message interface {
	isAgentDevMessage_Message()
}

type AgentDevMessage_GetRunningJobsRequest struct {
	GetRunningJobsRequest *GetRunningAgentJobsRequest `protobuf:"bytes,1,opt,name=get_running_jobs_request,json=getRunningJobsRequest,proto3,oneof"`
}

type AgentDevMessage_GetRunningJobsResponse struct {
	GetRunningJobsResponse *GetRunningAgentJobsResponse `protobuf:"bytes,2,opt,name=get_running_jobs_response,json=getRunningJobsResponse,proto3,oneof"`
}

func (*AgentDevMessage_GetRunningJobsRequest) isAgentDevMessage_Message() {}

func (*AgentDevMessage_GetRunningJobsResponse) isAgentDevMessage_Message() {}

type GetRunningAgentJobsRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*GetRunningAgentJobsRequest) ProtoMessage() {}

func (x *GetRunningAgentJobsRequest) ProtoReflect() protoreflect.Message {
	mi := &file_agent_livekit_agent_dev_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 GetRunningAgentJobsRequest.ProtoReflect.Descriptor instead.
func (*GetRunningAgentJobsRequest) Descriptor() ([]byte, []int) {
	return file_agent_livekit_agent_dev_proto_rawDescGZIP(), []int{1}
}

type GetRunningAgentJobsResponse struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Jobs          []*RunningAgentJobInfo `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*GetRunningAgentJobsResponse) ProtoMessage() {}

func (x *GetRunningAgentJobsResponse) ProtoReflect() protoreflect.Message {
	mi := &file_agent_livekit_agent_dev_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 GetRunningAgentJobsResponse.ProtoReflect.Descriptor instead.
func (*GetRunningAgentJobsResponse) Descriptor() ([]byte, []int) {
	return file_agent_livekit_agent_dev_proto_rawDescGZIP(), []int{2}
}

func (x *GetRunningAgentJobsResponse) GetJobs() []*RunningAgentJobInfo {
	if x != nil {
		return x.Jobs
	}
	return nil
}

type RunningAgentJobInfo struct {
	state          protoimpl.MessageState `protogen:"open.v1"`
	Job            []byte                 `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	AcceptName     string                 `protobuf:"bytes,2,opt,name=accept_name,json=acceptName,proto3" json:"accept_name,omitempty"`
	AcceptIdentity string                 `protobuf:"bytes,3,opt,name=accept_identity,json=acceptIdentity,proto3" json:"accept_identity,omitempty"`
	AcceptMetadata string                 `protobuf:"bytes,4,opt,name=accept_metadata,json=acceptMetadata,proto3" json:"accept_metadata,omitempty"`
	Url            string                 `protobuf:"bytes,5,opt,name=url,proto3" json:"url,omitempty"`
	Token          string                 `protobuf:"bytes,6,opt,name=token,proto3" json:"token,omitempty"`
	WorkerId       string                 `protobuf:"bytes,7,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	MockJob        bool                   `protobuf:"varint,8,opt,name=mock_job,json=mockJob,proto3" json:"mock_job,omitempty"`
	unknownFields  protoimpl.UnknownFields
	sizeCache      protoimpl.SizeCache
}

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

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

func (*RunningAgentJobInfo) ProtoMessage() {}

func (x *RunningAgentJobInfo) ProtoReflect() protoreflect.Message {
	mi := &file_agent_livekit_agent_dev_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 RunningAgentJobInfo.ProtoReflect.Descriptor instead.
func (*RunningAgentJobInfo) Descriptor() ([]byte, []int) {
	return file_agent_livekit_agent_dev_proto_rawDescGZIP(), []int{3}
}

func (x *RunningAgentJobInfo) GetJob() []byte {
	if x != nil {
		return x.Job
	}
	return nil
}

func (x *RunningAgentJobInfo) GetAcceptName() string {
	if x != nil {
		return x.AcceptName
	}
	return ""
}

func (x *RunningAgentJobInfo) GetAcceptIdentity() string {
	if x != nil {
		return x.AcceptIdentity
	}
	return ""
}

func (x *RunningAgentJobInfo) GetAcceptMetadata() string {
	if x != nil {
		return x.AcceptMetadata
	}
	return ""
}

func (x *RunningAgentJobInfo) GetUrl() string {
	if x != nil {
		return x.Url
	}
	return ""
}

func (x *RunningAgentJobInfo) GetToken() string {
	if x != nil {
		return x.Token
	}
	return ""
}

func (x *RunningAgentJobInfo) GetWorkerId() string {
	if x != nil {
		return x.WorkerId
	}
	return ""
}

func (x *RunningAgentJobInfo) GetMockJob() bool {
	if x != nil {
		return x.MockJob
	}
	return false
}

var File_agent_livekit_agent_dev_proto protoreflect.FileDescriptor

const file_agent_livekit_agent_dev_proto_rawDesc = "" +
	"\n" +
	"\x1dagent/livekit_agent_dev.proto\x12\rlivekit.agent\"\xeb\x01\n" +
	"\x0fAgentDevMessage\x12d\n" +
	"\x18get_running_jobs_request\x18\x01 \x01(\v2).livekit.agent.GetRunningAgentJobsRequestH\x00R\x15getRunningJobsRequest\x12g\n" +
	"\x19get_running_jobs_response\x18\x02 \x01(\v2*.livekit.agent.GetRunningAgentJobsResponseH\x00R\x16getRunningJobsResponseB\t\n" +
	"\amessage\"\x1c\n" +
	"\x1aGetRunningAgentJobsRequest\"U\n" +
	"\x1bGetRunningAgentJobsResponse\x126\n" +
	"\x04jobs\x18\x01 \x03(\v2\".livekit.agent.RunningAgentJobInfoR\x04jobs\"\xfa\x01\n" +
	"\x13RunningAgentJobInfo\x12\x10\n" +
	"\x03job\x18\x01 \x01(\fR\x03job\x12\x1f\n" +
	"\vaccept_name\x18\x02 \x01(\tR\n" +
	"acceptName\x12'\n" +
	"\x0faccept_identity\x18\x03 \x01(\tR\x0eacceptIdentity\x12'\n" +
	"\x0faccept_metadata\x18\x04 \x01(\tR\x0eacceptMetadata\x12\x10\n" +
	"\x03url\x18\x05 \x01(\tR\x03url\x12\x14\n" +
	"\x05token\x18\x06 \x01(\tR\x05token\x12\x1b\n" +
	"\tworker_id\x18\a \x01(\tR\bworkerId\x12\x19\n" +
	"\bmock_job\x18\b \x01(\bR\amockJobB+Z)github.com/livekit/protocol/livekit/agentb\x06proto3"

var (
	file_agent_livekit_agent_dev_proto_rawDescOnce sync.Once
	file_agent_livekit_agent_dev_proto_rawDescData []byte
)

func file_agent_livekit_agent_dev_proto_rawDescGZIP() []byte {
	file_agent_livekit_agent_dev_proto_rawDescOnce.Do(func() {
		file_agent_livekit_agent_dev_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_agent_livekit_agent_dev_proto_rawDesc), len(file_agent_livekit_agent_dev_proto_rawDesc)))
	})
	return file_agent_livekit_agent_dev_proto_rawDescData
}

var file_agent_livekit_agent_dev_proto_msgTypes = make([]protoimpl.MessageInfo, 4)
var file_agent_livekit_agent_dev_proto_goTypes = []any{
	(*AgentDevMessage)(nil),             // 0: livekit.agent.AgentDevMessage
	(*GetRunningAgentJobsRequest)(nil),  // 1: livekit.agent.GetRunningAgentJobsRequest
	(*GetRunningAgentJobsResponse)(nil), // 2: livekit.agent.GetRunningAgentJobsResponse
	(*RunningAgentJobInfo)(nil),         // 3: livekit.agent.RunningAgentJobInfo
}
var file_agent_livekit_agent_dev_proto_depIdxs = []int32{
	1, // 0: livekit.agent.AgentDevMessage.get_running_jobs_request:type_name -> livekit.agent.GetRunningAgentJobsRequest
	2, // 1: livekit.agent.AgentDevMessage.get_running_jobs_response:type_name -> livekit.agent.GetRunningAgentJobsResponse
	3, // 2: livekit.agent.GetRunningAgentJobsResponse.jobs:type_name -> livekit.agent.RunningAgentJobInfo
	3, // [3:3] is the sub-list for method output_type
	3, // [3:3] is the sub-list for method input_type
	3, // [3:3] is the sub-list for extension type_name
	3, // [3:3] is the sub-list for extension extendee
	0, // [0:3] is the sub-list for field type_name
}

func init() { file_agent_livekit_agent_dev_proto_init() }
func file_agent_livekit_agent_dev_proto_init() {
	if File_agent_livekit_agent_dev_proto != nil {
		return
	}
	file_agent_livekit_agent_dev_proto_msgTypes[0].OneofWrappers = []any{
		(*AgentDevMessage_GetRunningJobsRequest)(nil),
		(*AgentDevMessage_GetRunningJobsResponse)(nil),
	}
	type x struct{}
	out := protoimpl.TypeBuilder{
		File: protoimpl.DescBuilder{
			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
			RawDescriptor: unsafe.Slice(unsafe.StringData(file_agent_livekit_agent_dev_proto_rawDesc), len(file_agent_livekit_agent_dev_proto_rawDesc)),
			NumEnums:      0,
			NumMessages:   4,
			NumExtensions: 0,
			NumServices:   0,
		},
		GoTypes:           file_agent_livekit_agent_dev_proto_goTypes,
		DependencyIndexes: file_agent_livekit_agent_dev_proto_depIdxs,
		MessageInfos:      file_agent_livekit_agent_dev_proto_msgTypes,
	}.Build()
	File_agent_livekit_agent_dev_proto = out.File
	file_agent_livekit_agent_dev_proto_goTypes = nil
	file_agent_livekit_agent_dev_proto_depIdxs = nil
}