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 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"`
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 ""
}
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"`
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 ""
}
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"`
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
}
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\"q\n" +
"\x1aCreateAgentDispatchRequest\x12\x1d\n" +
"\n" +
"agent_name\x18\x01 \x01(\tR\tagentName\x12\x12\n" +
"\x04room\x18\x02 \x01(\tR\x04room\x12 \n" +
"\bmetadata\x18\x03 \x01(\tB\x04\x88\xec,\x01R\bmetadata\"T\n" +
"\x11RoomAgentDispatch\x12\x1d\n" +
"\n" +
"agent_name\x18\x01 \x01(\tR\tagentName\x12 \n" +
"\bmetadata\x18\x02 \x01(\tB\x04\x88\xec,\x01R\bmetadata\"a\n" +
"\x1aDeleteAgentDispatchRequest\x12/\n" +
"\vdispatch_id\x18\x01 \x01(\tB\x0e\x9a\xec,\n" +
"dispatchIDR\n" +
"dispatchId\x12\x12\n" +
"\x04room\x18\x02 \x01(\tR\x04room\"_\n" +
"\x18ListAgentDispatchRequest\x12/\n" +
"\vdispatch_id\x18\x01 \x01(\tB\x0e\x9a\xec,\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\"\xa7\x01\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 \n" +
"\bmetadata\x18\x04 \x01(\tB\x04\x88\xec,\x01R\bmetadata\x121\n" +
"\x05state\x18\x05 \x01(\v2\x1b.livekit.AgentDispatchStateR\x05state\"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\tdeletedAt2\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_msgTypes = make([]protoimpl.MessageInfo, 7)
var file_livekit_agent_dispatch_proto_goTypes = []any{
(*CreateAgentDispatchRequest)(nil), (*RoomAgentDispatch)(nil), (*DeleteAgentDispatchRequest)(nil), (*ListAgentDispatchRequest)(nil), (*ListAgentDispatchResponse)(nil), (*AgentDispatch)(nil), (*AgentDispatchState)(nil), (*Job)(nil), }
var file_livekit_agent_dispatch_proto_depIdxs = []int32{
5, 6, 7, 0, 2, 3, 5, 5, 4, 6, 3, 3, 3, 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: 0,
NumMessages: 7,
NumExtensions: 0,
NumServices: 1,
},
GoTypes: file_livekit_agent_dispatch_proto_goTypes,
DependencyIndexes: file_livekit_agent_dispatch_proto_depIdxs,
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
}