package replay
import (
livekit "github.com/livekit/protocol/livekit"
_ "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 *livekit.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() *livekit.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 *livekit.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() *livekit.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"`
Duration int64 `protobuf:"varint,4,opt,name=duration,proto3" json:"duration,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) GetDuration() int64 {
if x != nil {
return x.Duration
}
return 0
}
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[3]
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[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 (*DeleteReplayRequest) Descriptor() ([]byte, []int) {
return file_cloud_replay_proto_rawDescGZIP(), []int{3}
}
func (x *DeleteReplayRequest) GetReplayId() string {
if x != nil {
return x.ReplayId
}
return ""
}
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"` SeekOffset int64 `protobuf:"varint,3,opt,name=seek_offset,json=seekOffset,proto3" json:"seek_offset,omitempty"` unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *PlaybackRequest) Reset() {
*x = PlaybackRequest{}
mi := &file_cloud_replay_proto_msgTypes[4]
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[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 (*PlaybackRequest) Descriptor() ([]byte, []int) {
return file_cloud_replay_proto_rawDescGZIP(), []int{4}
}
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) GetSeekOffset() int64 {
if x != nil {
return x.SeekOffset
}
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[5]
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[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 (*PlaybackResponse) Descriptor() ([]byte, []int) {
return file_cloud_replay_proto_rawDescGZIP(), []int{5}
}
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"`
SeekOffset int64 `protobuf:"varint,2,opt,name=seek_offset,json=seekOffset,proto3" json:"seek_offset,omitempty"` unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *SeekRequest) Reset() {
*x = SeekRequest{}
mi := &file_cloud_replay_proto_msgTypes[6]
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[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 (*SeekRequest) Descriptor() ([]byte, []int) {
return file_cloud_replay_proto_rawDescGZIP(), []int{6}
}
func (x *SeekRequest) GetPlaybackId() string {
if x != nil {
return x.PlaybackId
}
return ""
}
func (x *SeekRequest) GetSeekOffset() int64 {
if x != nil {
return x.SeekOffset
}
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[7]
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[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 (*ClosePlaybackRequest) Descriptor() ([]byte, []int) {
return file_cloud_replay_proto_rawDescGZIP(), []int{7}
}
func (x *ClosePlaybackRequest) GetPlaybackId() string {
if x != nil {
return x.PlaybackId
}
return ""
}
var File_cloud_replay_proto protoreflect.FileDescriptor
const file_cloud_replay_proto_rawDesc = "" +
"\n" +
"\x12cloud_replay.proto\x12\x06replay\x1a\x1bgoogle/protobuf/empty.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\"\x85\x01\n" +
"\x13ListReplaysResponse\x12,\n" +
"\areplays\x18\x01 \x03(\v2\x12.replay.ReplayInfoR\areplays\x12@\n" +
"\x0fnext_page_token\x18\x02 \x01(\v2\x18.livekit.TokenPaginationR\rnextPageToken\"\x8f\x01\n" +
"\n" +
"ReplayInfo\x12)\n" +
"\treplay_id\x18\x01 \x01(\tB\f\x9a\xec,\breplayIDR\breplayId\x12\x1b\n" +
"\troom_name\x18\x02 \x01(\tR\broomName\x12\x1d\n" +
"\n" +
"start_time\x18\x03 \x01(\x03R\tstartTime\x12\x1a\n" +
"\bduration\x18\x04 \x01(\x03R\bduration\"@\n" +
"\x13DeleteReplayRequest\x12)\n" +
"\treplay_id\x18\x01 \x01(\tB\f\x9a\xec,\breplayIDR\breplayId\"\x82\x01\n" +
"\x0fPlaybackRequest\x12)\n" +
"\treplay_id\x18\x01 \x01(\tB\f\x9a\xec,\breplayIDR\breplayId\x12#\n" +
"\rplayback_room\x18\x02 \x01(\tR\fplaybackRoom\x12\x1f\n" +
"\vseek_offset\x18\x03 \x01(\x03R\n" +
"seekOffset\"C\n" +
"\x10PlaybackResponse\x12/\n" +
"\vplayback_id\x18\x01 \x01(\tB\x0e\x9a\xec,\n" +
"playbackIDR\n" +
"playbackId\"_\n" +
"\vSeekRequest\x12/\n" +
"\vplayback_id\x18\x01 \x01(\tB\x0e\x9a\xec,\n" +
"playbackIDR\n" +
"playbackId\x12\x1f\n" +
"\vseek_offset\x18\x02 \x01(\x03R\n" +
"seekOffset\"G\n" +
"\x14ClosePlaybackRequest\x12/\n" +
"\vplayback_id\x18\x01 \x01(\tB\x0e\x9a\xec,\n" +
"playbackIDR\n" +
"playbackId2\xc8\x02\n" +
"\x06Replay\x12F\n" +
"\vListReplays\x12\x1a.replay.ListReplaysRequest\x1a\x1b.replay.ListReplaysResponse\x12C\n" +
"\fDeleteReplay\x12\x1b.replay.DeleteReplayRequest\x1a\x16.google.protobuf.Empty\x12=\n" +
"\bPlayback\x12\x17.replay.PlaybackRequest\x1a\x18.replay.PlaybackResponse\x123\n" +
"\x04Seek\x12\x13.replay.SeekRequest\x1a\x16.google.protobuf.Empty\x12=\n" +
"\x05Close\x12\x1c.replay.ClosePlaybackRequest\x1a\x16.google.protobuf.EmptyBEZ\"github.com/livekit/protocol/replay\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), (*DeleteReplayRequest)(nil), (*PlaybackRequest)(nil), (*PlaybackResponse)(nil), (*SeekRequest)(nil), (*ClosePlaybackRequest)(nil), (*livekit.TokenPagination)(nil), (*emptypb.Empty)(nil), }
var file_cloud_replay_proto_depIdxs = []int32{
8, 2, 8, 0, 3, 4, 6, 7, 1, 9, 5, 9, 9, 8, 3, 3, 3, 0, }
func init() { file_cloud_replay_proto_init() }
func file_cloud_replay_proto_init() {
if File_cloud_replay_proto != nil {
return
}
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
}