package livekit
import (
_ "github.com/livekit/protocol/livekit/logger"
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
emptypb "google.golang.org/protobuf/types/known/emptypb"
reflect "reflect"
sync "sync"
unsafe "unsafe"
)
const (
_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)
type ListReplaysRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
RoomName string `protobuf:"bytes,1,opt,name=room_name,json=roomName,proto3" json:"room_name,omitempty"` PageToken *TokenPagination `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *ListReplaysRequest) Reset() {
*x = ListReplaysRequest{}
mi := &file_cloud_replay_proto_msgTypes[0]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *ListReplaysRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*ListReplaysRequest) ProtoMessage() {}
func (x *ListReplaysRequest) ProtoReflect() protoreflect.Message {
mi := &file_cloud_replay_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 (*ListReplaysRequest) Descriptor() ([]byte, []int) {
return file_cloud_replay_proto_rawDescGZIP(), []int{0}
}
func (x *ListReplaysRequest) GetRoomName() string {
if x != nil {
return x.RoomName
}
return ""
}
func (x *ListReplaysRequest) GetPageToken() *TokenPagination {
if x != nil {
return x.PageToken
}
return nil
}
type ListReplaysResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Replays []*ReplayInfo `protobuf:"bytes,1,rep,name=replays,proto3" json:"replays,omitempty"`
NextPageToken *TokenPagination `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *ListReplaysResponse) Reset() {
*x = ListReplaysResponse{}
mi := &file_cloud_replay_proto_msgTypes[1]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *ListReplaysResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*ListReplaysResponse) ProtoMessage() {}
func (x *ListReplaysResponse) ProtoReflect() protoreflect.Message {
mi := &file_cloud_replay_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 (*ListReplaysResponse) Descriptor() ([]byte, []int) {
return file_cloud_replay_proto_rawDescGZIP(), []int{1}
}
func (x *ListReplaysResponse) GetReplays() []*ReplayInfo {
if x != nil {
return x.Replays
}
return nil
}
func (x *ListReplaysResponse) GetNextPageToken() *TokenPagination {
if x != nil {
return x.NextPageToken
}
return nil
}
type ReplayInfo struct {
state protoimpl.MessageState `protogen:"open.v1"`
ReplayId string `protobuf:"bytes,1,opt,name=replay_id,json=replayId,proto3" json:"replay_id,omitempty"`
RoomName string `protobuf:"bytes,2,opt,name=room_name,json=roomName,proto3" json:"room_name,omitempty"`
StartTime int64 `protobuf:"varint,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
DurationMs int64 `protobuf:"varint,4,opt,name=duration_ms,json=durationMs,proto3" json:"duration_ms,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *ReplayInfo) Reset() {
*x = ReplayInfo{}
mi := &file_cloud_replay_proto_msgTypes[2]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *ReplayInfo) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*ReplayInfo) ProtoMessage() {}
func (x *ReplayInfo) ProtoReflect() protoreflect.Message {
mi := &file_cloud_replay_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 (*ReplayInfo) Descriptor() ([]byte, []int) {
return file_cloud_replay_proto_rawDescGZIP(), []int{2}
}
func (x *ReplayInfo) GetReplayId() string {
if x != nil {
return x.ReplayId
}
return ""
}
func (x *ReplayInfo) GetRoomName() string {
if x != nil {
return x.RoomName
}
return ""
}
func (x *ReplayInfo) GetStartTime() int64 {
if x != nil {
return x.StartTime
}
return 0
}
func (x *ReplayInfo) GetDurationMs() int64 {
if x != nil {
return x.DurationMs
}
return 0
}
type PlaybackRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
ReplayId string `protobuf:"bytes,1,opt,name=replay_id,json=replayId,proto3" json:"replay_id,omitempty"`
PlaybackRoom string `protobuf:"bytes,2,opt,name=playback_room,json=playbackRoom,proto3" json:"playback_room,omitempty"` SeekOffsetMs int64 `protobuf:"varint,3,opt,name=seek_offset_ms,json=seekOffsetMs,proto3" json:"seek_offset_ms,omitempty"` unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *PlaybackRequest) Reset() {
*x = PlaybackRequest{}
mi := &file_cloud_replay_proto_msgTypes[3]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *PlaybackRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*PlaybackRequest) ProtoMessage() {}
func (x *PlaybackRequest) ProtoReflect() protoreflect.Message {
mi := &file_cloud_replay_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 (*PlaybackRequest) Descriptor() ([]byte, []int) {
return file_cloud_replay_proto_rawDescGZIP(), []int{3}
}
func (x *PlaybackRequest) GetReplayId() string {
if x != nil {
return x.ReplayId
}
return ""
}
func (x *PlaybackRequest) GetPlaybackRoom() string {
if x != nil {
return x.PlaybackRoom
}
return ""
}
func (x *PlaybackRequest) GetSeekOffsetMs() int64 {
if x != nil {
return x.SeekOffsetMs
}
return 0
}
type PlaybackResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
PlaybackId string `protobuf:"bytes,1,opt,name=playback_id,json=playbackId,proto3" json:"playback_id,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *PlaybackResponse) Reset() {
*x = PlaybackResponse{}
mi := &file_cloud_replay_proto_msgTypes[4]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *PlaybackResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*PlaybackResponse) ProtoMessage() {}
func (x *PlaybackResponse) ProtoReflect() protoreflect.Message {
mi := &file_cloud_replay_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 (*PlaybackResponse) Descriptor() ([]byte, []int) {
return file_cloud_replay_proto_rawDescGZIP(), []int{4}
}
func (x *PlaybackResponse) GetPlaybackId() string {
if x != nil {
return x.PlaybackId
}
return ""
}
type SeekRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
PlaybackId string `protobuf:"bytes,1,opt,name=playback_id,json=playbackId,proto3" json:"playback_id,omitempty"`
SeekOffsetMs int64 `protobuf:"varint,2,opt,name=seek_offset_ms,json=seekOffsetMs,proto3" json:"seek_offset_ms,omitempty"` unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *SeekRequest) Reset() {
*x = SeekRequest{}
mi := &file_cloud_replay_proto_msgTypes[5]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *SeekRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SeekRequest) ProtoMessage() {}
func (x *SeekRequest) ProtoReflect() protoreflect.Message {
mi := &file_cloud_replay_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 (*SeekRequest) Descriptor() ([]byte, []int) {
return file_cloud_replay_proto_rawDescGZIP(), []int{5}
}
func (x *SeekRequest) GetPlaybackId() string {
if x != nil {
return x.PlaybackId
}
return ""
}
func (x *SeekRequest) GetSeekOffsetMs() int64 {
if x != nil {
return x.SeekOffsetMs
}
return 0
}
type ClosePlaybackRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
PlaybackId string `protobuf:"bytes,1,opt,name=playback_id,json=playbackId,proto3" json:"playback_id,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *ClosePlaybackRequest) Reset() {
*x = ClosePlaybackRequest{}
mi := &file_cloud_replay_proto_msgTypes[6]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *ClosePlaybackRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*ClosePlaybackRequest) ProtoMessage() {}
func (x *ClosePlaybackRequest) ProtoReflect() protoreflect.Message {
mi := &file_cloud_replay_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 (*ClosePlaybackRequest) Descriptor() ([]byte, []int) {
return file_cloud_replay_proto_rawDescGZIP(), []int{6}
}
func (x *ClosePlaybackRequest) GetPlaybackId() string {
if x != nil {
return x.PlaybackId
}
return ""
}
type DeleteReplayRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
ReplayId string `protobuf:"bytes,1,opt,name=replay_id,json=replayId,proto3" json:"replay_id,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *DeleteReplayRequest) Reset() {
*x = DeleteReplayRequest{}
mi := &file_cloud_replay_proto_msgTypes[7]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *DeleteReplayRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*DeleteReplayRequest) ProtoMessage() {}
func (x *DeleteReplayRequest) ProtoReflect() protoreflect.Message {
mi := &file_cloud_replay_proto_msgTypes[7]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*DeleteReplayRequest) Descriptor() ([]byte, []int) {
return file_cloud_replay_proto_rawDescGZIP(), []int{7}
}
func (x *DeleteReplayRequest) GetReplayId() string {
if x != nil {
return x.ReplayId
}
return ""
}
var File_cloud_replay_proto protoreflect.FileDescriptor
const file_cloud_replay_proto_rawDesc = "" +
"\n" +
"\x12cloud_replay.proto\x12\alivekit\x1a\x1bgoogle/protobuf/empty.proto\x1a\x14livekit_egress.proto\x1a\x14livekit_models.proto\x1a\x14logger/options.proto\"j\n" +
"\x12ListReplaysRequest\x12\x1b\n" +
"\troom_name\x18\x01 \x01(\tR\broomName\x127\n" +
"\n" +
"page_token\x18\x02 \x01(\v2\x18.livekit.TokenPaginationR\tpageToken\"\x86\x01\n" +
"\x13ListReplaysResponse\x12-\n" +
"\areplays\x18\x01 \x03(\v2\x13.livekit.ReplayInfoR\areplays\x12@\n" +
"\x0fnext_page_token\x18\x02 \x01(\v2\x18.livekit.TokenPaginationR\rnextPageToken\"\x93\x01\n" +
"\n" +
"ReplayInfo\x12(\n" +
"\treplay_id\x18\x01 \x01(\tB\v\xbaP\breplayIDR\breplayId\x12\x1b\n" +
"\troom_name\x18\x02 \x01(\tR\broomName\x12\x1d\n" +
"\n" +
"start_time\x18\x03 \x01(\x03R\tstartTime\x12\x1f\n" +
"\vduration_ms\x18\x04 \x01(\x03R\n" +
"durationMs\"\x86\x01\n" +
"\x0fPlaybackRequest\x12(\n" +
"\treplay_id\x18\x01 \x01(\tB\v\xbaP\breplayIDR\breplayId\x12#\n" +
"\rplayback_room\x18\x02 \x01(\tR\fplaybackRoom\x12$\n" +
"\x0eseek_offset_ms\x18\x03 \x01(\x03R\fseekOffsetMs\"B\n" +
"\x10PlaybackResponse\x12.\n" +
"\vplayback_id\x18\x01 \x01(\tB\r\xbaP\n" +
"playbackIDR\n" +
"playbackId\"c\n" +
"\vSeekRequest\x12.\n" +
"\vplayback_id\x18\x01 \x01(\tB\r\xbaP\n" +
"playbackIDR\n" +
"playbackId\x12$\n" +
"\x0eseek_offset_ms\x18\x02 \x01(\x03R\fseekOffsetMs\"F\n" +
"\x14ClosePlaybackRequest\x12.\n" +
"\vplayback_id\x18\x01 \x01(\tB\r\xbaP\n" +
"playbackIDR\n" +
"playbackId\"?\n" +
"\x13DeleteReplayRequest\x12(\n" +
"\treplay_id\x18\x01 \x01(\tB\v\xbaP\breplayIDR\breplayId2\x8c\x03\n" +
"\x06Replay\x12H\n" +
"\vListReplays\x12\x1b.livekit.ListReplaysRequest\x1a\x1c.livekit.ListReplaysResponse\x12?\n" +
"\bPlayback\x12\x18.livekit.PlaybackRequest\x1a\x19.livekit.PlaybackResponse\x124\n" +
"\x04Seek\x12\x14.livekit.SeekRequest\x1a\x16.google.protobuf.Empty\x12>\n" +
"\x05Close\x12\x1d.livekit.ClosePlaybackRequest\x1a\x16.google.protobuf.Empty\x12;\n" +
"\x06Export\x12\x1c.livekit.ExportReplayRequest\x1a\x13.livekit.EgressInfo\x12D\n" +
"\fDeleteReplay\x12\x1c.livekit.DeleteReplayRequest\x1a\x16.google.protobuf.EmptyBFZ#github.com/livekit/protocol/livekit\xaa\x02\rLiveKit.Proto\xea\x02\x0eLiveKit::Protob\x06proto3"
var (
file_cloud_replay_proto_rawDescOnce sync.Once
file_cloud_replay_proto_rawDescData []byte
)
func file_cloud_replay_proto_rawDescGZIP() []byte {
file_cloud_replay_proto_rawDescOnce.Do(func() {
file_cloud_replay_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_cloud_replay_proto_rawDesc), len(file_cloud_replay_proto_rawDesc)))
})
return file_cloud_replay_proto_rawDescData
}
var file_cloud_replay_proto_msgTypes = make([]protoimpl.MessageInfo, 8)
var file_cloud_replay_proto_goTypes = []any{
(*ListReplaysRequest)(nil), (*ListReplaysResponse)(nil), (*ReplayInfo)(nil), (*PlaybackRequest)(nil), (*PlaybackResponse)(nil), (*SeekRequest)(nil), (*ClosePlaybackRequest)(nil), (*DeleteReplayRequest)(nil), (*TokenPagination)(nil), (*ExportReplayRequest)(nil), (*emptypb.Empty)(nil), (*EgressInfo)(nil), }
var file_cloud_replay_proto_depIdxs = []int32{
8, 2, 8, 0, 3, 5, 6, 9, 7, 1, 4, 10, 10, 11, 10, 9, 3, 3, 3, 0, }
func init() { file_cloud_replay_proto_init() }
func file_cloud_replay_proto_init() {
if File_cloud_replay_proto != nil {
return
}
file_livekit_egress_proto_init()
file_livekit_models_proto_init()
type x struct{}
out := protoimpl.TypeBuilder{
File: protoimpl.DescBuilder{
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: unsafe.Slice(unsafe.StringData(file_cloud_replay_proto_rawDesc), len(file_cloud_replay_proto_rawDesc)),
NumEnums: 0,
NumMessages: 8,
NumExtensions: 0,
NumServices: 1,
},
GoTypes: file_cloud_replay_proto_goTypes,
DependencyIndexes: file_cloud_replay_proto_depIdxs,
MessageInfos: file_cloud_replay_proto_msgTypes,
}.Build()
File_cloud_replay_proto = out.File
file_cloud_replay_proto_goTypes = nil
file_cloud_replay_proto_depIdxs = nil
}