bahman/protocol
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
Files
renovate/major-github-workflows
protocol/livekit/cloud_replay.pb.go
Paul Wells 7fd3701836 move proto options to use lk reserved range (#1495) 
* move proto options to use lk reserved range

* generated protobuf

* Create swift-swans-sit.md

---------

Co-authored-by: github-actions <41898282+github-actions[bot]@users.noreply.github.com>
2026-04-11 08:23:11 -07:00

578 lines
18 KiB
Go
Raw Permalink Blame History

// Copyright 2026 LiveKit, Inc.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// protoc-gen-go v1.36.11
// protoc v4.23.4
// source: cloud_replay.proto
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 (
// 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)
)
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"` // optional
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)
}
// Deprecated: Use ListReplaysRequest.ProtoReflect.Descriptor instead.
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)
}
// Deprecated: Use ListReplaysResponse.ProtoReflect.Descriptor instead.
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)
}
// Deprecated: Use ReplayInfo.ProtoReflect.Descriptor instead.
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"` // name of room to play into
SeekOffsetMs int64 `protobuf:"varint,3,opt,name=seek_offset_ms,json=seekOffsetMs,proto3" json:"seek_offset_ms,omitempty"` // initial timestamp (ms)
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)
}
// Deprecated: Use PlaybackRequest.ProtoReflect.Descriptor instead.
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)
}
// Deprecated: Use PlaybackResponse.ProtoReflect.Descriptor instead.
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"` // timestamp (ms)
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)
}
// Deprecated: Use SeekRequest.ProtoReflect.Descriptor instead.
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)
}
// Deprecated: Use ClosePlaybackRequest.ProtoReflect.Descriptor instead.
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)
}
// Deprecated: Use DeleteReplayRequest.ProtoReflect.Descriptor instead.
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), // 0: livekit.ListReplaysRequest
(*ListReplaysResponse)(nil), // 1: livekit.ListReplaysResponse
(*ReplayInfo)(nil), // 2: livekit.ReplayInfo
(*PlaybackRequest)(nil), // 3: livekit.PlaybackRequest
(*PlaybackResponse)(nil), // 4: livekit.PlaybackResponse
(*SeekRequest)(nil), // 5: livekit.SeekRequest
(*ClosePlaybackRequest)(nil), // 6: livekit.ClosePlaybackRequest
(*DeleteReplayRequest)(nil), // 7: livekit.DeleteReplayRequest
(*TokenPagination)(nil), // 8: livekit.TokenPagination
(*ExportReplayRequest)(nil), // 9: livekit.ExportReplayRequest
(*emptypb.Empty)(nil), // 10: google.protobuf.Empty
(*EgressInfo)(nil), // 11: livekit.EgressInfo
}
var file_cloud_replay_proto_depIdxs = []int32{
8, // 0: livekit.ListReplaysRequest.page_token:type_name -> livekit.TokenPagination
2, // 1: livekit.ListReplaysResponse.replays:type_name -> livekit.ReplayInfo
8, // 2: livekit.ListReplaysResponse.next_page_token:type_name -> livekit.TokenPagination
0, // 3: livekit.Replay.ListReplays:input_type -> livekit.ListReplaysRequest
3, // 4: livekit.Replay.Playback:input_type -> livekit.PlaybackRequest
5, // 5: livekit.Replay.Seek:input_type -> livekit.SeekRequest
6, // 6: livekit.Replay.Close:input_type -> livekit.ClosePlaybackRequest
9, // 7: livekit.Replay.Export:input_type -> livekit.ExportReplayRequest
7, // 8: livekit.Replay.DeleteReplay:input_type -> livekit.DeleteReplayRequest
1, // 9: livekit.Replay.ListReplays:output_type -> livekit.ListReplaysResponse
4, // 10: livekit.Replay.Playback:output_type -> livekit.PlaybackResponse
10, // 11: livekit.Replay.Seek:output_type -> google.protobuf.Empty
10, // 12: livekit.Replay.Close:output_type -> google.protobuf.Empty
11, // 13: livekit.Replay.Export:output_type -> livekit.EgressInfo
10, // 14: livekit.Replay.DeleteReplay:output_type -> google.protobuf.Empty
9, // [9:15] is the sub-list for method output_type
3, // [3:9] 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_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
}
Reference in New Issue View Git Blame Copy Permalink