package livekit
import (
_ "github.com/livekit/protocol/livekit/logger"
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
reflect "reflect"
sync "sync"
unsafe "unsafe"
)
const (
_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)
type JobRestartPolicy int32
const (
JobRestartPolicy_JRP_ON_FAILURE JobRestartPolicy = 0 JobRestartPolicy_JRP_NEVER JobRestartPolicy = 1 )
var (
JobRestartPolicy_name = map[int32]string{
0: "JRP_ON_FAILURE",
1: "JRP_NEVER",
}
JobRestartPolicy_value = map[string]int32{
"JRP_ON_FAILURE": 0,
"JRP_NEVER": 1,
}
)
func (x JobRestartPolicy) Enum() *JobRestartPolicy {
p := new(JobRestartPolicy)
*p = x
return p
}
func (x JobRestartPolicy) String() string {
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}
func (JobRestartPolicy) Descriptor() protoreflect.EnumDescriptor {
return file_livekit_agent_dispatch_proto_enumTypes[0].Descriptor()
}
func (JobRestartPolicy) Type() protoreflect.EnumType {
return &file_livekit_agent_dispatch_proto_enumTypes[0]
}
func (x JobRestartPolicy) Number() protoreflect.EnumNumber {
return protoreflect.EnumNumber(x)
}
func (JobRestartPolicy) EnumDescriptor() ([]byte, []int) {
return file_livekit_agent_dispatch_proto_rawDescGZIP(), []int{0}
}
type CreateAgentDispatchRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
AgentName string `protobuf:"bytes,1,opt,name=agent_name,json=agentName,proto3" json:"agent_name,omitempty"`
Room string `protobuf:"bytes,2,opt,name=room,proto3" json:"room,omitempty"`
Metadata string `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
RestartPolicy JobRestartPolicy `protobuf:"varint,4,opt,name=restart_policy,json=restartPolicy,proto3,enum=livekit.JobRestartPolicy" json:"restart_policy,omitempty"` Deployment string `protobuf:"bytes,5,opt,name=deployment,proto3" json:"deployment,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *CreateAgentDispatchRequest) Reset() {
*x = CreateAgentDispatchRequest{}
mi := &file_livekit_agent_dispatch_proto_msgTypes[0]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *CreateAgentDispatchRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CreateAgentDispatchRequest) ProtoMessage() {}
func (x *CreateAgentDispatchRequest) ProtoReflect() protoreflect.Message {
mi := &file_livekit_agent_dispatch_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 (*CreateAgentDispatchRequest) Descriptor() ([]byte, []int) {
return file_livekit_agent_dispatch_proto_rawDescGZIP(), []int{0}
}
func (x *CreateAgentDispatchRequest) GetAgentName() string {
if x != nil {
return x.AgentName
}
return ""
}
func (x *CreateAgentDispatchRequest) GetRoom() string {
if x != nil {
return x.Room
}
return ""
}
func (x *CreateAgentDispatchRequest) GetMetadata() string {
if x != nil {
return x.Metadata
}
return ""
}
func (x *CreateAgentDispatchRequest) GetRestartPolicy() JobRestartPolicy {
if x != nil {
return x.RestartPolicy
}
return JobRestartPolicy_JRP_ON_FAILURE
}
func (x *CreateAgentDispatchRequest) GetDeployment() string {
if x != nil {
return x.Deployment
}
return ""
}
type RoomAgentDispatch struct {
state protoimpl.MessageState `protogen:"open.v1"`
AgentName string `protobuf:"bytes,1,opt,name=agent_name,json=agentName,proto3" json:"agent_name,omitempty"`
Metadata string `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
RestartPolicy JobRestartPolicy `protobuf:"varint,3,opt,name=restart_policy,json=restartPolicy,proto3,enum=livekit.JobRestartPolicy" json:"restart_policy,omitempty"` Deployment string `protobuf:"bytes,4,opt,name=deployment,proto3" json:"deployment,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *RoomAgentDispatch) Reset() {
*x = RoomAgentDispatch{}
mi := &file_livekit_agent_dispatch_proto_msgTypes[1]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *RoomAgentDispatch) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*RoomAgentDispatch) ProtoMessage() {}
func (x *RoomAgentDispatch) ProtoReflect() protoreflect.Message {
mi := &file_livekit_agent_dispatch_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 (*RoomAgentDispatch) Descriptor() ([]byte, []int) {
return file_livekit_agent_dispatch_proto_rawDescGZIP(), []int{1}
}
func (x *RoomAgentDispatch) GetAgentName() string {
if x != nil {
return x.AgentName
}
return ""
}
func (x *RoomAgentDispatch) GetMetadata() string {
if x != nil {
return x.Metadata
}
return ""
}
func (x *RoomAgentDispatch) GetRestartPolicy() JobRestartPolicy {
if x != nil {
return x.RestartPolicy
}
return JobRestartPolicy_JRP_ON_FAILURE
}
func (x *RoomAgentDispatch) GetDeployment() string {
if x != nil {
return x.Deployment
}
return ""
}
type DeleteAgentDispatchRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
DispatchId string `protobuf:"bytes,1,opt,name=dispatch_id,json=dispatchId,proto3" json:"dispatch_id,omitempty"`
Room string `protobuf:"bytes,2,opt,name=room,proto3" json:"room,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *DeleteAgentDispatchRequest) Reset() {
*x = DeleteAgentDispatchRequest{}
mi := &file_livekit_agent_dispatch_proto_msgTypes[2]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *DeleteAgentDispatchRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*DeleteAgentDispatchRequest) ProtoMessage() {}
func (x *DeleteAgentDispatchRequest) ProtoReflect() protoreflect.Message {
mi := &file_livekit_agent_dispatch_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)
}
func (*DeleteAgentDispatchRequest) Descriptor() ([]byte, []int) {
return file_livekit_agent_dispatch_proto_rawDescGZIP(), []int{2}
}
func (x *DeleteAgentDispatchRequest) GetDispatchId() string {
if x != nil {
return x.DispatchId
}
return ""
}
func (x *DeleteAgentDispatchRequest) GetRoom() string {
if x != nil {
return x.Room
}
return ""
}
type ListAgentDispatchRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
DispatchId string `protobuf:"bytes,1,opt,name=dispatch_id,json=dispatchId,proto3" json:"dispatch_id,omitempty"` Room string `protobuf:"bytes,2,opt,name=room,proto3" json:"room,omitempty"` unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *ListAgentDispatchRequest) Reset() {
*x = ListAgentDispatchRequest{}
mi := &file_livekit_agent_dispatch_proto_msgTypes[3]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *ListAgentDispatchRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*ListAgentDispatchRequest) ProtoMessage() {}
func (x *ListAgentDispatchRequest) ProtoReflect() protoreflect.Message {
mi := &file_livekit_agent_dispatch_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 (*ListAgentDispatchRequest) Descriptor() ([]byte, []int) {
return file_livekit_agent_dispatch_proto_rawDescGZIP(), []int{3}
}
func (x *ListAgentDispatchRequest) GetDispatchId() string {
if x != nil {
return x.DispatchId
}
return ""
}
func (x *ListAgentDispatchRequest) GetRoom() string {
if x != nil {
return x.Room
}
return ""
}
type ListAgentDispatchResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
AgentDispatches []*AgentDispatch `protobuf:"bytes,1,rep,name=agent_dispatches,json=agentDispatches,proto3" json:"agent_dispatches,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *ListAgentDispatchResponse) Reset() {
*x = ListAgentDispatchResponse{}
mi := &file_livekit_agent_dispatch_proto_msgTypes[4]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *ListAgentDispatchResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*ListAgentDispatchResponse) ProtoMessage() {}
func (x *ListAgentDispatchResponse) ProtoReflect() protoreflect.Message {
mi := &file_livekit_agent_dispatch_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 (*ListAgentDispatchResponse) Descriptor() ([]byte, []int) {
return file_livekit_agent_dispatch_proto_rawDescGZIP(), []int{4}
}
func (x *ListAgentDispatchResponse) GetAgentDispatches() []*AgentDispatch {
if x != nil {
return x.AgentDispatches
}
return nil
}
type AgentDispatch struct {
state protoimpl.MessageState `protogen:"open.v1"`
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
AgentName string `protobuf:"bytes,2,opt,name=agent_name,json=agentName,proto3" json:"agent_name,omitempty"`
Room string `protobuf:"bytes,3,opt,name=room,proto3" json:"room,omitempty"`
Metadata string `protobuf:"bytes,4,opt,name=metadata,proto3" json:"metadata,omitempty"`
State *AgentDispatchState `protobuf:"bytes,5,opt,name=state,proto3" json:"state,omitempty"`
RestartPolicy JobRestartPolicy `protobuf:"varint,6,opt,name=restart_policy,json=restartPolicy,proto3,enum=livekit.JobRestartPolicy" json:"restart_policy,omitempty"` Deployment string `protobuf:"bytes,7,opt,name=deployment,proto3" json:"deployment,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *AgentDispatch) Reset() {
*x = AgentDispatch{}
mi := &file_livekit_agent_dispatch_proto_msgTypes[5]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *AgentDispatch) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*AgentDispatch) ProtoMessage() {}
func (x *AgentDispatch) ProtoReflect() protoreflect.Message {
mi := &file_livekit_agent_dispatch_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)
}
func (*AgentDispatch) Descriptor() ([]byte, []int) {
return file_livekit_agent_dispatch_proto_rawDescGZIP(), []int{5}
}
func (x *AgentDispatch) GetId() string {
if x != nil {
return x.Id
}
return ""
}
func (x *AgentDispatch) GetAgentName() string {
if x != nil {
return x.AgentName
}
return ""
}
func (x *AgentDispatch) GetRoom() string {
if x != nil {
return x.Room
}
return ""
}
func (x *AgentDispatch) GetMetadata() string {
if x != nil {
return x.Metadata
}
return ""
}
func (x *AgentDispatch) GetState() *AgentDispatchState {
if x != nil {
return x.State
}
return nil
}
func (x *AgentDispatch) GetRestartPolicy() JobRestartPolicy {
if x != nil {
return x.RestartPolicy
}
return JobRestartPolicy_JRP_ON_FAILURE
}
func (x *AgentDispatch) GetDeployment() string {
if x != nil {
return x.Deployment
}
return ""
}
type AgentDispatchState struct {
state protoimpl.MessageState `protogen:"open.v1"`
Jobs []*Job `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
CreatedAt int64 `protobuf:"varint,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
DeletedAt int64 `protobuf:"varint,3,opt,name=deleted_at,json=deletedAt,proto3" json:"deleted_at,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *AgentDispatchState) Reset() {
*x = AgentDispatchState{}
mi := &file_livekit_agent_dispatch_proto_msgTypes[6]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *AgentDispatchState) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*AgentDispatchState) ProtoMessage() {}
func (x *AgentDispatchState) ProtoReflect() protoreflect.Message {
mi := &file_livekit_agent_dispatch_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)
}
func (*AgentDispatchState) Descriptor() ([]byte, []int) {
return file_livekit_agent_dispatch_proto_rawDescGZIP(), []int{6}
}
func (x *AgentDispatchState) GetJobs() []*Job {
if x != nil {
return x.Jobs
}
return nil
}
func (x *AgentDispatchState) GetCreatedAt() int64 {
if x != nil {
return x.CreatedAt
}
return 0
}
func (x *AgentDispatchState) GetDeletedAt() int64 {
if x != nil {
return x.DeletedAt
}
return 0
}
var File_livekit_agent_dispatch_proto protoreflect.FileDescriptor
const file_livekit_agent_dispatch_proto_rawDesc = "" +
"\n" +
"\x1clivekit_agent_dispatch.proto\x12\alivekit\x1a\x13livekit_agent.proto\x1a\x14logger/options.proto\"\xd2\x01\n" +
"\x1aCreateAgentDispatchRequest\x12\x1d\n" +
"\n" +
"agent_name\x18\x01 \x01(\tR\tagentName\x12\x12\n" +
"\x04room\x18\x02 \x01(\tR\x04room\x12\x1f\n" +
"\bmetadata\x18\x03 \x01(\tB\x03\xa8P\x01R\bmetadata\x12@\n" +
"\x0erestart_policy\x18\x04 \x01(\x0e2\x19.livekit.JobRestartPolicyR\rrestartPolicy\x12\x1e\n" +
"\n" +
"deployment\x18\x05 \x01(\tR\n" +
"deployment\"\xb5\x01\n" +
"\x11RoomAgentDispatch\x12\x1d\n" +
"\n" +
"agent_name\x18\x01 \x01(\tR\tagentName\x12\x1f\n" +
"\bmetadata\x18\x02 \x01(\tB\x03\xa8P\x01R\bmetadata\x12@\n" +
"\x0erestart_policy\x18\x03 \x01(\x0e2\x19.livekit.JobRestartPolicyR\rrestartPolicy\x12\x1e\n" +
"\n" +
"deployment\x18\x04 \x01(\tR\n" +
"deployment\"`\n" +
"\x1aDeleteAgentDispatchRequest\x12.\n" +
"\vdispatch_id\x18\x01 \x01(\tB\r\xbaP\n" +
"dispatchIDR\n" +
"dispatchId\x12\x12\n" +
"\x04room\x18\x02 \x01(\tR\x04room\"^\n" +
"\x18ListAgentDispatchRequest\x12.\n" +
"\vdispatch_id\x18\x01 \x01(\tB\r\xbaP\n" +
"dispatchIDR\n" +
"dispatchId\x12\x12\n" +
"\x04room\x18\x02 \x01(\tR\x04room\"^\n" +
"\x19ListAgentDispatchResponse\x12A\n" +
"\x10agent_dispatches\x18\x01 \x03(\v2\x16.livekit.AgentDispatchR\x0fagentDispatches\"\x88\x02\n" +
"\rAgentDispatch\x12\x0e\n" +
"\x02id\x18\x01 \x01(\tR\x02id\x12\x1d\n" +
"\n" +
"agent_name\x18\x02 \x01(\tR\tagentName\x12\x12\n" +
"\x04room\x18\x03 \x01(\tR\x04room\x12\x1f\n" +
"\bmetadata\x18\x04 \x01(\tB\x03\xa8P\x01R\bmetadata\x121\n" +
"\x05state\x18\x05 \x01(\v2\x1b.livekit.AgentDispatchStateR\x05state\x12@\n" +
"\x0erestart_policy\x18\x06 \x01(\x0e2\x19.livekit.JobRestartPolicyR\rrestartPolicy\x12\x1e\n" +
"\n" +
"deployment\x18\a \x01(\tR\n" +
"deployment\"t\n" +
"\x12AgentDispatchState\x12 \n" +
"\x04jobs\x18\x01 \x03(\v2\f.livekit.JobR\x04jobs\x12\x1d\n" +
"\n" +
"created_at\x18\x02 \x01(\x03R\tcreatedAt\x12\x1d\n" +
"\n" +
"deleted_at\x18\x03 \x01(\x03R\tdeletedAt*5\n" +
"\x10JobRestartPolicy\x12\x12\n" +
"\x0eJRP_ON_FAILURE\x10\x00\x12\r\n" +
"\tJRP_NEVER\x10\x012\x8b\x02\n" +
"\x14AgentDispatchService\x12M\n" +
"\x0eCreateDispatch\x12#.livekit.CreateAgentDispatchRequest\x1a\x16.livekit.AgentDispatch\x12M\n" +
"\x0eDeleteDispatch\x12#.livekit.DeleteAgentDispatchRequest\x1a\x16.livekit.AgentDispatch\x12U\n" +
"\fListDispatch\x12!.livekit.ListAgentDispatchRequest\x1a\".livekit.ListAgentDispatchResponseBFZ#github.com/livekit/protocol/livekit\xaa\x02\rLiveKit.Proto\xea\x02\x0eLiveKit::Protob\x06proto3"
var (
file_livekit_agent_dispatch_proto_rawDescOnce sync.Once
file_livekit_agent_dispatch_proto_rawDescData []byte
)
func file_livekit_agent_dispatch_proto_rawDescGZIP() []byte {
file_livekit_agent_dispatch_proto_rawDescOnce.Do(func() {
file_livekit_agent_dispatch_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_livekit_agent_dispatch_proto_rawDesc), len(file_livekit_agent_dispatch_proto_rawDesc)))
})
return file_livekit_agent_dispatch_proto_rawDescData
}
var file_livekit_agent_dispatch_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
var file_livekit_agent_dispatch_proto_msgTypes = make([]protoimpl.MessageInfo, 7)
var file_livekit_agent_dispatch_proto_goTypes = []any{
(JobRestartPolicy)(0), (*CreateAgentDispatchRequest)(nil), (*RoomAgentDispatch)(nil), (*DeleteAgentDispatchRequest)(nil), (*ListAgentDispatchRequest)(nil), (*ListAgentDispatchResponse)(nil), (*AgentDispatch)(nil), (*AgentDispatchState)(nil), (*Job)(nil), }
var file_livekit_agent_dispatch_proto_depIdxs = []int32{
0, 0, 6, 7, 0, 8, 1, 3, 4, 6, 6, 5, 9, 6, 6, 6, 0, }
func init() { file_livekit_agent_dispatch_proto_init() }
func file_livekit_agent_dispatch_proto_init() {
if File_livekit_agent_dispatch_proto != nil {
return
}
file_livekit_agent_proto_init()
type x struct{}
out := protoimpl.TypeBuilder{
File: protoimpl.DescBuilder{
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: unsafe.Slice(unsafe.StringData(file_livekit_agent_dispatch_proto_rawDesc), len(file_livekit_agent_dispatch_proto_rawDesc)),
NumEnums: 1,
NumMessages: 7,
NumExtensions: 0,
NumServices: 1,
},
GoTypes: file_livekit_agent_dispatch_proto_goTypes,
DependencyIndexes: file_livekit_agent_dispatch_proto_depIdxs,
EnumInfos: file_livekit_agent_dispatch_proto_enumTypes,
MessageInfos: file_livekit_agent_dispatch_proto_msgTypes,
}.Build()
File_livekit_agent_dispatch_proto = out.File
file_livekit_agent_dispatch_proto_goTypes = nil
file_livekit_agent_dispatch_proto_depIdxs = nil
}