mirror of
https://github.com/langhuihui/monibuca.git
synced 2025-10-05 13:36:51 +08:00
1322 lines
42 KiB
Go
1322 lines
42 KiB
Go
// Code generated by protoc-gen-go. DO NOT EDIT.
|
||
// versions:
|
||
// protoc-gen-go v1.36.6
|
||
// protoc v5.29.3
|
||
// source: crontab.proto
|
||
|
||
package pb
|
||
|
||
import (
|
||
_ "google.golang.org/genproto/googleapis/api/annotations"
|
||
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
|
||
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
|
||
timestamppb "google.golang.org/protobuf/types/known/timestamppb"
|
||
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 PlanResponseList struct {
|
||
state protoimpl.MessageState `protogen:"open.v1"`
|
||
Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
|
||
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
|
||
TotalCount uint32 `protobuf:"varint,3,opt,name=totalCount,proto3" json:"totalCount,omitempty"`
|
||
PageNum uint32 `protobuf:"varint,4,opt,name=pageNum,proto3" json:"pageNum,omitempty"`
|
||
PageSize uint32 `protobuf:"varint,5,opt,name=pageSize,proto3" json:"pageSize,omitempty"`
|
||
Data []*Plan `protobuf:"bytes,6,rep,name=data,proto3" json:"data,omitempty"`
|
||
unknownFields protoimpl.UnknownFields
|
||
sizeCache protoimpl.SizeCache
|
||
}
|
||
|
||
func (x *PlanResponseList) Reset() {
|
||
*x = PlanResponseList{}
|
||
mi := &file_crontab_proto_msgTypes[0]
|
||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||
ms.StoreMessageInfo(mi)
|
||
}
|
||
|
||
func (x *PlanResponseList) String() string {
|
||
return protoimpl.X.MessageStringOf(x)
|
||
}
|
||
|
||
func (*PlanResponseList) ProtoMessage() {}
|
||
|
||
func (x *PlanResponseList) ProtoReflect() protoreflect.Message {
|
||
mi := &file_crontab_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 PlanResponseList.ProtoReflect.Descriptor instead.
|
||
func (*PlanResponseList) Descriptor() ([]byte, []int) {
|
||
return file_crontab_proto_rawDescGZIP(), []int{0}
|
||
}
|
||
|
||
func (x *PlanResponseList) GetCode() int32 {
|
||
if x != nil {
|
||
return x.Code
|
||
}
|
||
return 0
|
||
}
|
||
|
||
func (x *PlanResponseList) GetMessage() string {
|
||
if x != nil {
|
||
return x.Message
|
||
}
|
||
return ""
|
||
}
|
||
|
||
func (x *PlanResponseList) GetTotalCount() uint32 {
|
||
if x != nil {
|
||
return x.TotalCount
|
||
}
|
||
return 0
|
||
}
|
||
|
||
func (x *PlanResponseList) GetPageNum() uint32 {
|
||
if x != nil {
|
||
return x.PageNum
|
||
}
|
||
return 0
|
||
}
|
||
|
||
func (x *PlanResponseList) GetPageSize() uint32 {
|
||
if x != nil {
|
||
return x.PageSize
|
||
}
|
||
return 0
|
||
}
|
||
|
||
func (x *PlanResponseList) GetData() []*Plan {
|
||
if x != nil {
|
||
return x.Data
|
||
}
|
||
return nil
|
||
}
|
||
|
||
type Plan struct {
|
||
state protoimpl.MessageState `protogen:"open.v1"`
|
||
Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
|
||
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
|
||
Enable bool `protobuf:"varint,3,opt,name=enable,proto3" json:"enable,omitempty"`
|
||
CreateTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=createTime,proto3" json:"createTime,omitempty"`
|
||
UpdateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=updateTime,proto3" json:"updateTime,omitempty"`
|
||
Plan string `protobuf:"bytes,6,opt,name=plan,proto3" json:"plan,omitempty"`
|
||
unknownFields protoimpl.UnknownFields
|
||
sizeCache protoimpl.SizeCache
|
||
}
|
||
|
||
func (x *Plan) Reset() {
|
||
*x = Plan{}
|
||
mi := &file_crontab_proto_msgTypes[1]
|
||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||
ms.StoreMessageInfo(mi)
|
||
}
|
||
|
||
func (x *Plan) String() string {
|
||
return protoimpl.X.MessageStringOf(x)
|
||
}
|
||
|
||
func (*Plan) ProtoMessage() {}
|
||
|
||
func (x *Plan) ProtoReflect() protoreflect.Message {
|
||
mi := &file_crontab_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 Plan.ProtoReflect.Descriptor instead.
|
||
func (*Plan) Descriptor() ([]byte, []int) {
|
||
return file_crontab_proto_rawDescGZIP(), []int{1}
|
||
}
|
||
|
||
func (x *Plan) GetId() uint32 {
|
||
if x != nil {
|
||
return x.Id
|
||
}
|
||
return 0
|
||
}
|
||
|
||
func (x *Plan) GetName() string {
|
||
if x != nil {
|
||
return x.Name
|
||
}
|
||
return ""
|
||
}
|
||
|
||
func (x *Plan) GetEnable() bool {
|
||
if x != nil {
|
||
return x.Enable
|
||
}
|
||
return false
|
||
}
|
||
|
||
func (x *Plan) GetCreateTime() *timestamppb.Timestamp {
|
||
if x != nil {
|
||
return x.CreateTime
|
||
}
|
||
return nil
|
||
}
|
||
|
||
func (x *Plan) GetUpdateTime() *timestamppb.Timestamp {
|
||
if x != nil {
|
||
return x.UpdateTime
|
||
}
|
||
return nil
|
||
}
|
||
|
||
func (x *Plan) GetPlan() string {
|
||
if x != nil {
|
||
return x.Plan
|
||
}
|
||
return ""
|
||
}
|
||
|
||
type ReqPlanList struct {
|
||
state protoimpl.MessageState `protogen:"open.v1"`
|
||
PageNum uint32 `protobuf:"varint,1,opt,name=pageNum,proto3" json:"pageNum,omitempty"`
|
||
PageSize uint32 `protobuf:"varint,2,opt,name=pageSize,proto3" json:"pageSize,omitempty"`
|
||
unknownFields protoimpl.UnknownFields
|
||
sizeCache protoimpl.SizeCache
|
||
}
|
||
|
||
func (x *ReqPlanList) Reset() {
|
||
*x = ReqPlanList{}
|
||
mi := &file_crontab_proto_msgTypes[2]
|
||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||
ms.StoreMessageInfo(mi)
|
||
}
|
||
|
||
func (x *ReqPlanList) String() string {
|
||
return protoimpl.X.MessageStringOf(x)
|
||
}
|
||
|
||
func (*ReqPlanList) ProtoMessage() {}
|
||
|
||
func (x *ReqPlanList) ProtoReflect() protoreflect.Message {
|
||
mi := &file_crontab_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 ReqPlanList.ProtoReflect.Descriptor instead.
|
||
func (*ReqPlanList) Descriptor() ([]byte, []int) {
|
||
return file_crontab_proto_rawDescGZIP(), []int{2}
|
||
}
|
||
|
||
func (x *ReqPlanList) GetPageNum() uint32 {
|
||
if x != nil {
|
||
return x.PageNum
|
||
}
|
||
return 0
|
||
}
|
||
|
||
func (x *ReqPlanList) GetPageSize() uint32 {
|
||
if x != nil {
|
||
return x.PageSize
|
||
}
|
||
return 0
|
||
}
|
||
|
||
type DeleteRequest struct {
|
||
state protoimpl.MessageState `protogen:"open.v1"`
|
||
Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
|
||
unknownFields protoimpl.UnknownFields
|
||
sizeCache protoimpl.SizeCache
|
||
}
|
||
|
||
func (x *DeleteRequest) Reset() {
|
||
*x = DeleteRequest{}
|
||
mi := &file_crontab_proto_msgTypes[3]
|
||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||
ms.StoreMessageInfo(mi)
|
||
}
|
||
|
||
func (x *DeleteRequest) String() string {
|
||
return protoimpl.X.MessageStringOf(x)
|
||
}
|
||
|
||
func (*DeleteRequest) ProtoMessage() {}
|
||
|
||
func (x *DeleteRequest) ProtoReflect() protoreflect.Message {
|
||
mi := &file_crontab_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 DeleteRequest.ProtoReflect.Descriptor instead.
|
||
func (*DeleteRequest) Descriptor() ([]byte, []int) {
|
||
return file_crontab_proto_rawDescGZIP(), []int{3}
|
||
}
|
||
|
||
func (x *DeleteRequest) GetId() uint32 {
|
||
if x != nil {
|
||
return x.Id
|
||
}
|
||
return 0
|
||
}
|
||
|
||
type Response struct {
|
||
state protoimpl.MessageState `protogen:"open.v1"`
|
||
Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
|
||
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
|
||
unknownFields protoimpl.UnknownFields
|
||
sizeCache protoimpl.SizeCache
|
||
}
|
||
|
||
func (x *Response) Reset() {
|
||
*x = Response{}
|
||
mi := &file_crontab_proto_msgTypes[4]
|
||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||
ms.StoreMessageInfo(mi)
|
||
}
|
||
|
||
func (x *Response) String() string {
|
||
return protoimpl.X.MessageStringOf(x)
|
||
}
|
||
|
||
func (*Response) ProtoMessage() {}
|
||
|
||
func (x *Response) ProtoReflect() protoreflect.Message {
|
||
mi := &file_crontab_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 Response.ProtoReflect.Descriptor instead.
|
||
func (*Response) Descriptor() ([]byte, []int) {
|
||
return file_crontab_proto_rawDescGZIP(), []int{4}
|
||
}
|
||
|
||
func (x *Response) GetCode() int32 {
|
||
if x != nil {
|
||
return x.Code
|
||
}
|
||
return 0
|
||
}
|
||
|
||
func (x *Response) GetMessage() string {
|
||
if x != nil {
|
||
return x.Message
|
||
}
|
||
return ""
|
||
}
|
||
|
||
// RecordPlanStream 相关消息定义
|
||
type PlanStream struct {
|
||
state protoimpl.MessageState `protogen:"open.v1"`
|
||
PlanId uint32 `protobuf:"varint,1,opt,name=planId,proto3" json:"planId,omitempty"`
|
||
StreamPath string `protobuf:"bytes,2,opt,name=stream_path,json=streamPath,proto3" json:"stream_path,omitempty"`
|
||
Fragment string `protobuf:"bytes,3,opt,name=fragment,proto3" json:"fragment,omitempty"`
|
||
FilePath string `protobuf:"bytes,4,opt,name=filePath,proto3" json:"filePath,omitempty"`
|
||
RecordType string `protobuf:"bytes,5,opt,name=record_type,json=recordType,proto3" json:"record_type,omitempty"` // 录制类型，例如 "mp4", "flv"
|
||
CreatedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
|
||
UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
|
||
Enable bool `protobuf:"varint,8,opt,name=enable,proto3" json:"enable,omitempty"` // 是否启用该录制流
|
||
unknownFields protoimpl.UnknownFields
|
||
sizeCache protoimpl.SizeCache
|
||
}
|
||
|
||
func (x *PlanStream) Reset() {
|
||
*x = PlanStream{}
|
||
mi := &file_crontab_proto_msgTypes[5]
|
||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||
ms.StoreMessageInfo(mi)
|
||
}
|
||
|
||
func (x *PlanStream) String() string {
|
||
return protoimpl.X.MessageStringOf(x)
|
||
}
|
||
|
||
func (*PlanStream) ProtoMessage() {}
|
||
|
||
func (x *PlanStream) ProtoReflect() protoreflect.Message {
|
||
mi := &file_crontab_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 PlanStream.ProtoReflect.Descriptor instead.
|
||
func (*PlanStream) Descriptor() ([]byte, []int) {
|
||
return file_crontab_proto_rawDescGZIP(), []int{5}
|
||
}
|
||
|
||
func (x *PlanStream) GetPlanId() uint32 {
|
||
if x != nil {
|
||
return x.PlanId
|
||
}
|
||
return 0
|
||
}
|
||
|
||
func (x *PlanStream) GetStreamPath() string {
|
||
if x != nil {
|
||
return x.StreamPath
|
||
}
|
||
return ""
|
||
}
|
||
|
||
func (x *PlanStream) GetFragment() string {
|
||
if x != nil {
|
||
return x.Fragment
|
||
}
|
||
return ""
|
||
}
|
||
|
||
func (x *PlanStream) GetFilePath() string {
|
||
if x != nil {
|
||
return x.FilePath
|
||
}
|
||
return ""
|
||
}
|
||
|
||
func (x *PlanStream) GetRecordType() string {
|
||
if x != nil {
|
||
return x.RecordType
|
||
}
|
||
return ""
|
||
}
|
||
|
||
func (x *PlanStream) GetCreatedAt() *timestamppb.Timestamp {
|
||
if x != nil {
|
||
return x.CreatedAt
|
||
}
|
||
return nil
|
||
}
|
||
|
||
func (x *PlanStream) GetUpdatedAt() *timestamppb.Timestamp {
|
||
if x != nil {
|
||
return x.UpdatedAt
|
||
}
|
||
return nil
|
||
}
|
||
|
||
func (x *PlanStream) GetEnable() bool {
|
||
if x != nil {
|
||
return x.Enable
|
||
}
|
||
return false
|
||
}
|
||
|
||
type ReqPlanStreamList struct {
|
||
state protoimpl.MessageState `protogen:"open.v1"`
|
||
PageNum uint32 `protobuf:"varint,1,opt,name=pageNum,proto3" json:"pageNum,omitempty"`
|
||
PageSize uint32 `protobuf:"varint,2,opt,name=pageSize,proto3" json:"pageSize,omitempty"`
|
||
PlanId uint32 `protobuf:"varint,3,opt,name=planId,proto3" json:"planId,omitempty"` // 可选的按录制计划ID筛选
|
||
StreamPath string `protobuf:"bytes,4,opt,name=stream_path,json=streamPath,proto3" json:"stream_path,omitempty"` // 可选的按流路径筛选
|
||
unknownFields protoimpl.UnknownFields
|
||
sizeCache protoimpl.SizeCache
|
||
}
|
||
|
||
func (x *ReqPlanStreamList) Reset() {
|
||
*x = ReqPlanStreamList{}
|
||
mi := &file_crontab_proto_msgTypes[6]
|
||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||
ms.StoreMessageInfo(mi)
|
||
}
|
||
|
||
func (x *ReqPlanStreamList) String() string {
|
||
return protoimpl.X.MessageStringOf(x)
|
||
}
|
||
|
||
func (*ReqPlanStreamList) ProtoMessage() {}
|
||
|
||
func (x *ReqPlanStreamList) ProtoReflect() protoreflect.Message {
|
||
mi := &file_crontab_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 ReqPlanStreamList.ProtoReflect.Descriptor instead.
|
||
func (*ReqPlanStreamList) Descriptor() ([]byte, []int) {
|
||
return file_crontab_proto_rawDescGZIP(), []int{6}
|
||
}
|
||
|
||
func (x *ReqPlanStreamList) GetPageNum() uint32 {
|
||
if x != nil {
|
||
return x.PageNum
|
||
}
|
||
return 0
|
||
}
|
||
|
||
func (x *ReqPlanStreamList) GetPageSize() uint32 {
|
||
if x != nil {
|
||
return x.PageSize
|
||
}
|
||
return 0
|
||
}
|
||
|
||
func (x *ReqPlanStreamList) GetPlanId() uint32 {
|
||
if x != nil {
|
||
return x.PlanId
|
||
}
|
||
return 0
|
||
}
|
||
|
||
func (x *ReqPlanStreamList) GetStreamPath() string {
|
||
if x != nil {
|
||
return x.StreamPath
|
||
}
|
||
return ""
|
||
}
|
||
|
||
type RecordPlanStreamResponseList struct {
|
||
state protoimpl.MessageState `protogen:"open.v1"`
|
||
Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
|
||
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
|
||
TotalCount uint32 `protobuf:"varint,3,opt,name=totalCount,proto3" json:"totalCount,omitempty"`
|
||
PageNum uint32 `protobuf:"varint,4,opt,name=pageNum,proto3" json:"pageNum,omitempty"`
|
||
PageSize uint32 `protobuf:"varint,5,opt,name=pageSize,proto3" json:"pageSize,omitempty"`
|
||
Data []*PlanStream `protobuf:"bytes,6,rep,name=data,proto3" json:"data,omitempty"`
|
||
unknownFields protoimpl.UnknownFields
|
||
sizeCache protoimpl.SizeCache
|
||
}
|
||
|
||
func (x *RecordPlanStreamResponseList) Reset() {
|
||
*x = RecordPlanStreamResponseList{}
|
||
mi := &file_crontab_proto_msgTypes[7]
|
||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||
ms.StoreMessageInfo(mi)
|
||
}
|
||
|
||
func (x *RecordPlanStreamResponseList) String() string {
|
||
return protoimpl.X.MessageStringOf(x)
|
||
}
|
||
|
||
func (*RecordPlanStreamResponseList) ProtoMessage() {}
|
||
|
||
func (x *RecordPlanStreamResponseList) ProtoReflect() protoreflect.Message {
|
||
mi := &file_crontab_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 RecordPlanStreamResponseList.ProtoReflect.Descriptor instead.
|
||
func (*RecordPlanStreamResponseList) Descriptor() ([]byte, []int) {
|
||
return file_crontab_proto_rawDescGZIP(), []int{7}
|
||
}
|
||
|
||
func (x *RecordPlanStreamResponseList) GetCode() int32 {
|
||
if x != nil {
|
||
return x.Code
|
||
}
|
||
return 0
|
||
}
|
||
|
||
func (x *RecordPlanStreamResponseList) GetMessage() string {
|
||
if x != nil {
|
||
return x.Message
|
||
}
|
||
return ""
|
||
}
|
||
|
||
func (x *RecordPlanStreamResponseList) GetTotalCount() uint32 {
|
||
if x != nil {
|
||
return x.TotalCount
|
||
}
|
||
return 0
|
||
}
|
||
|
||
func (x *RecordPlanStreamResponseList) GetPageNum() uint32 {
|
||
if x != nil {
|
||
return x.PageNum
|
||
}
|
||
return 0
|
||
}
|
||
|
||
func (x *RecordPlanStreamResponseList) GetPageSize() uint32 {
|
||
if x != nil {
|
||
return x.PageSize
|
||
}
|
||
return 0
|
||
}
|
||
|
||
func (x *RecordPlanStreamResponseList) GetData() []*PlanStream {
|
||
if x != nil {
|
||
return x.Data
|
||
}
|
||
return nil
|
||
}
|
||
|
||
type DeletePlanStreamRequest struct {
|
||
state protoimpl.MessageState `protogen:"open.v1"`
|
||
PlanId uint32 `protobuf:"varint,1,opt,name=planId,proto3" json:"planId,omitempty"`
|
||
StreamPath string `protobuf:"bytes,2,opt,name=streamPath,proto3" json:"streamPath,omitempty"`
|
||
unknownFields protoimpl.UnknownFields
|
||
sizeCache protoimpl.SizeCache
|
||
}
|
||
|
||
func (x *DeletePlanStreamRequest) Reset() {
|
||
*x = DeletePlanStreamRequest{}
|
||
mi := &file_crontab_proto_msgTypes[8]
|
||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||
ms.StoreMessageInfo(mi)
|
||
}
|
||
|
||
func (x *DeletePlanStreamRequest) String() string {
|
||
return protoimpl.X.MessageStringOf(x)
|
||
}
|
||
|
||
func (*DeletePlanStreamRequest) ProtoMessage() {}
|
||
|
||
func (x *DeletePlanStreamRequest) ProtoReflect() protoreflect.Message {
|
||
mi := &file_crontab_proto_msgTypes[8]
|
||
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 DeletePlanStreamRequest.ProtoReflect.Descriptor instead.
|
||
func (*DeletePlanStreamRequest) Descriptor() ([]byte, []int) {
|
||
return file_crontab_proto_rawDescGZIP(), []int{8}
|
||
}
|
||
|
||
func (x *DeletePlanStreamRequest) GetPlanId() uint32 {
|
||
if x != nil {
|
||
return x.PlanId
|
||
}
|
||
return 0
|
||
}
|
||
|
||
func (x *DeletePlanStreamRequest) GetStreamPath() string {
|
||
if x != nil {
|
||
return x.StreamPath
|
||
}
|
||
return ""
|
||
}
|
||
|
||
// 解析计划请求
|
||
type ParsePlanRequest struct {
|
||
state protoimpl.MessageState `protogen:"open.v1"`
|
||
Plan string `protobuf:"bytes,1,opt,name=plan,proto3" json:"plan,omitempty"` // 168位的0/1字符串，表示一周的每个小时是否录制
|
||
unknownFields protoimpl.UnknownFields
|
||
sizeCache protoimpl.SizeCache
|
||
}
|
||
|
||
func (x *ParsePlanRequest) Reset() {
|
||
*x = ParsePlanRequest{}
|
||
mi := &file_crontab_proto_msgTypes[9]
|
||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||
ms.StoreMessageInfo(mi)
|
||
}
|
||
|
||
func (x *ParsePlanRequest) String() string {
|
||
return protoimpl.X.MessageStringOf(x)
|
||
}
|
||
|
||
func (*ParsePlanRequest) ProtoMessage() {}
|
||
|
||
func (x *ParsePlanRequest) ProtoReflect() protoreflect.Message {
|
||
mi := &file_crontab_proto_msgTypes[9]
|
||
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 ParsePlanRequest.ProtoReflect.Descriptor instead.
|
||
func (*ParsePlanRequest) Descriptor() ([]byte, []int) {
|
||
return file_crontab_proto_rawDescGZIP(), []int{9}
|
||
}
|
||
|
||
func (x *ParsePlanRequest) GetPlan() string {
|
||
if x != nil {
|
||
return x.Plan
|
||
}
|
||
return ""
|
||
}
|
||
|
||
// 时间段信息
|
||
type TimeSlotInfo struct {
|
||
state protoimpl.MessageState `protogen:"open.v1"`
|
||
Start *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"` // 开始时间
|
||
End *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty"` // 结束时间
|
||
Weekday string `protobuf:"bytes,3,opt,name=weekday,proto3" json:"weekday,omitempty"` // 周几（例如：周一）
|
||
TimeRange string `protobuf:"bytes,4,opt,name=time_range,json=timeRange,proto3" json:"time_range,omitempty"` // 时间范围（例如：09:00-10:00）
|
||
unknownFields protoimpl.UnknownFields
|
||
sizeCache protoimpl.SizeCache
|
||
}
|
||
|
||
func (x *TimeSlotInfo) Reset() {
|
||
*x = TimeSlotInfo{}
|
||
mi := &file_crontab_proto_msgTypes[10]
|
||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||
ms.StoreMessageInfo(mi)
|
||
}
|
||
|
||
func (x *TimeSlotInfo) String() string {
|
||
return protoimpl.X.MessageStringOf(x)
|
||
}
|
||
|
||
func (*TimeSlotInfo) ProtoMessage() {}
|
||
|
||
func (x *TimeSlotInfo) ProtoReflect() protoreflect.Message {
|
||
mi := &file_crontab_proto_msgTypes[10]
|
||
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 TimeSlotInfo.ProtoReflect.Descriptor instead.
|
||
func (*TimeSlotInfo) Descriptor() ([]byte, []int) {
|
||
return file_crontab_proto_rawDescGZIP(), []int{10}
|
||
}
|
||
|
||
func (x *TimeSlotInfo) GetStart() *timestamppb.Timestamp {
|
||
if x != nil {
|
||
return x.Start
|
||
}
|
||
return nil
|
||
}
|
||
|
||
func (x *TimeSlotInfo) GetEnd() *timestamppb.Timestamp {
|
||
if x != nil {
|
||
return x.End
|
||
}
|
||
return nil
|
||
}
|
||
|
||
func (x *TimeSlotInfo) GetWeekday() string {
|
||
if x != nil {
|
||
return x.Weekday
|
||
}
|
||
return ""
|
||
}
|
||
|
||
func (x *TimeSlotInfo) GetTimeRange() string {
|
||
if x != nil {
|
||
return x.TimeRange
|
||
}
|
||
return ""
|
||
}
|
||
|
||
// 解析计划响应
|
||
type ParsePlanResponse struct {
|
||
state protoimpl.MessageState `protogen:"open.v1"`
|
||
Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` // 响应码
|
||
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // 响应消息
|
||
Slots []*TimeSlotInfo `protobuf:"bytes,3,rep,name=slots,proto3" json:"slots,omitempty"` // 所有计划的时间段
|
||
NextSlot *TimeSlotInfo `protobuf:"bytes,4,opt,name=next_slot,json=nextSlot,proto3" json:"next_slot,omitempty"` // 从当前时间开始的下一个时间段
|
||
unknownFields protoimpl.UnknownFields
|
||
sizeCache protoimpl.SizeCache
|
||
}
|
||
|
||
func (x *ParsePlanResponse) Reset() {
|
||
*x = ParsePlanResponse{}
|
||
mi := &file_crontab_proto_msgTypes[11]
|
||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||
ms.StoreMessageInfo(mi)
|
||
}
|
||
|
||
func (x *ParsePlanResponse) String() string {
|
||
return protoimpl.X.MessageStringOf(x)
|
||
}
|
||
|
||
func (*ParsePlanResponse) ProtoMessage() {}
|
||
|
||
func (x *ParsePlanResponse) ProtoReflect() protoreflect.Message {
|
||
mi := &file_crontab_proto_msgTypes[11]
|
||
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 ParsePlanResponse.ProtoReflect.Descriptor instead.
|
||
func (*ParsePlanResponse) Descriptor() ([]byte, []int) {
|
||
return file_crontab_proto_rawDescGZIP(), []int{11}
|
||
}
|
||
|
||
func (x *ParsePlanResponse) GetCode() int32 {
|
||
if x != nil {
|
||
return x.Code
|
||
}
|
||
return 0
|
||
}
|
||
|
||
func (x *ParsePlanResponse) GetMessage() string {
|
||
if x != nil {
|
||
return x.Message
|
||
}
|
||
return ""
|
||
}
|
||
|
||
func (x *ParsePlanResponse) GetSlots() []*TimeSlotInfo {
|
||
if x != nil {
|
||
return x.Slots
|
||
}
|
||
return nil
|
||
}
|
||
|
||
func (x *ParsePlanResponse) GetNextSlot() *TimeSlotInfo {
|
||
if x != nil {
|
||
return x.NextSlot
|
||
}
|
||
return nil
|
||
}
|
||
|
||
// 新增的消息定义
|
||
// 获取Crontab状态请求
|
||
type CrontabStatusRequest struct {
|
||
state protoimpl.MessageState `protogen:"open.v1"`
|
||
// 可以为空，表示获取所有任务
|
||
StreamPath string `protobuf:"bytes,1,opt,name=stream_path,json=streamPath,proto3" json:"stream_path,omitempty"` // 可选，按流路径过滤
|
||
unknownFields protoimpl.UnknownFields
|
||
sizeCache protoimpl.SizeCache
|
||
}
|
||
|
||
func (x *CrontabStatusRequest) Reset() {
|
||
*x = CrontabStatusRequest{}
|
||
mi := &file_crontab_proto_msgTypes[12]
|
||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||
ms.StoreMessageInfo(mi)
|
||
}
|
||
|
||
func (x *CrontabStatusRequest) String() string {
|
||
return protoimpl.X.MessageStringOf(x)
|
||
}
|
||
|
||
func (*CrontabStatusRequest) ProtoMessage() {}
|
||
|
||
func (x *CrontabStatusRequest) ProtoReflect() protoreflect.Message {
|
||
mi := &file_crontab_proto_msgTypes[12]
|
||
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 CrontabStatusRequest.ProtoReflect.Descriptor instead.
|
||
func (*CrontabStatusRequest) Descriptor() ([]byte, []int) {
|
||
return file_crontab_proto_rawDescGZIP(), []int{12}
|
||
}
|
||
|
||
func (x *CrontabStatusRequest) GetStreamPath() string {
|
||
if x != nil {
|
||
return x.StreamPath
|
||
}
|
||
return ""
|
||
}
|
||
|
||
// 任务信息
|
||
type CrontabTaskInfo struct {
|
||
state protoimpl.MessageState `protogen:"open.v1"`
|
||
PlanId uint32 `protobuf:"varint,1,opt,name=plan_id,json=planId,proto3" json:"plan_id,omitempty"` // 计划ID
|
||
PlanName string `protobuf:"bytes,2,opt,name=plan_name,json=planName,proto3" json:"plan_name,omitempty"` // 计划名称
|
||
StreamPath string `protobuf:"bytes,3,opt,name=stream_path,json=streamPath,proto3" json:"stream_path,omitempty"` // 流路径
|
||
IsRecording bool `protobuf:"varint,4,opt,name=is_recording,json=isRecording,proto3" json:"is_recording,omitempty"` // 是否正在录制
|
||
StartTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"` // 当前/下一个任务开始时间
|
||
EndTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"` // 当前/下一个任务结束时间
|
||
TimeRange string `protobuf:"bytes,7,opt,name=time_range,json=timeRange,proto3" json:"time_range,omitempty"` // 时间范围（例如：09:00-10:00）
|
||
Weekday string `protobuf:"bytes,8,opt,name=weekday,proto3" json:"weekday,omitempty"` // 周几（例如：周一）
|
||
FilePath string `protobuf:"bytes,9,opt,name=file_path,json=filePath,proto3" json:"file_path,omitempty"` // 文件保存路径
|
||
Fragment string `protobuf:"bytes,10,opt,name=fragment,proto3" json:"fragment,omitempty"` // 分片设置
|
||
ElapsedSeconds uint32 `protobuf:"varint,11,opt,name=elapsed_seconds,json=elapsedSeconds,proto3" json:"elapsed_seconds,omitempty"` // 已运行时间（秒，仅对正在运行的任务有效）
|
||
RemainingSeconds uint32 `protobuf:"varint,12,opt,name=remaining_seconds,json=remainingSeconds,proto3" json:"remaining_seconds,omitempty"` // 剩余时间（秒）
|
||
PlanSlots []*TimeSlotInfo `protobuf:"bytes,13,rep,name=plan_slots,json=planSlots,proto3" json:"plan_slots,omitempty"` // 完整的计划时间段列表
|
||
unknownFields protoimpl.UnknownFields
|
||
sizeCache protoimpl.SizeCache
|
||
}
|
||
|
||
func (x *CrontabTaskInfo) Reset() {
|
||
*x = CrontabTaskInfo{}
|
||
mi := &file_crontab_proto_msgTypes[13]
|
||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||
ms.StoreMessageInfo(mi)
|
||
}
|
||
|
||
func (x *CrontabTaskInfo) String() string {
|
||
return protoimpl.X.MessageStringOf(x)
|
||
}
|
||
|
||
func (*CrontabTaskInfo) ProtoMessage() {}
|
||
|
||
func (x *CrontabTaskInfo) ProtoReflect() protoreflect.Message {
|
||
mi := &file_crontab_proto_msgTypes[13]
|
||
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 CrontabTaskInfo.ProtoReflect.Descriptor instead.
|
||
func (*CrontabTaskInfo) Descriptor() ([]byte, []int) {
|
||
return file_crontab_proto_rawDescGZIP(), []int{13}
|
||
}
|
||
|
||
func (x *CrontabTaskInfo) GetPlanId() uint32 {
|
||
if x != nil {
|
||
return x.PlanId
|
||
}
|
||
return 0
|
||
}
|
||
|
||
func (x *CrontabTaskInfo) GetPlanName() string {
|
||
if x != nil {
|
||
return x.PlanName
|
||
}
|
||
return ""
|
||
}
|
||
|
||
func (x *CrontabTaskInfo) GetStreamPath() string {
|
||
if x != nil {
|
||
return x.StreamPath
|
||
}
|
||
return ""
|
||
}
|
||
|
||
func (x *CrontabTaskInfo) GetIsRecording() bool {
|
||
if x != nil {
|
||
return x.IsRecording
|
||
}
|
||
return false
|
||
}
|
||
|
||
func (x *CrontabTaskInfo) GetStartTime() *timestamppb.Timestamp {
|
||
if x != nil {
|
||
return x.StartTime
|
||
}
|
||
return nil
|
||
}
|
||
|
||
func (x *CrontabTaskInfo) GetEndTime() *timestamppb.Timestamp {
|
||
if x != nil {
|
||
return x.EndTime
|
||
}
|
||
return nil
|
||
}
|
||
|
||
func (x *CrontabTaskInfo) GetTimeRange() string {
|
||
if x != nil {
|
||
return x.TimeRange
|
||
}
|
||
return ""
|
||
}
|
||
|
||
func (x *CrontabTaskInfo) GetWeekday() string {
|
||
if x != nil {
|
||
return x.Weekday
|
||
}
|
||
return ""
|
||
}
|
||
|
||
func (x *CrontabTaskInfo) GetFilePath() string {
|
||
if x != nil {
|
||
return x.FilePath
|
||
}
|
||
return ""
|
||
}
|
||
|
||
func (x *CrontabTaskInfo) GetFragment() string {
|
||
if x != nil {
|
||
return x.Fragment
|
||
}
|
||
return ""
|
||
}
|
||
|
||
func (x *CrontabTaskInfo) GetElapsedSeconds() uint32 {
|
||
if x != nil {
|
||
return x.ElapsedSeconds
|
||
}
|
||
return 0
|
||
}
|
||
|
||
func (x *CrontabTaskInfo) GetRemainingSeconds() uint32 {
|
||
if x != nil {
|
||
return x.RemainingSeconds
|
||
}
|
||
return 0
|
||
}
|
||
|
||
func (x *CrontabTaskInfo) GetPlanSlots() []*TimeSlotInfo {
|
||
if x != nil {
|
||
return x.PlanSlots
|
||
}
|
||
return nil
|
||
}
|
||
|
||
// 获取Crontab状态响应
|
||
type CrontabStatusResponse struct {
|
||
state protoimpl.MessageState `protogen:"open.v1"`
|
||
Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` // 响应码
|
||
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // 响应消息
|
||
RunningTasks []*CrontabTaskInfo `protobuf:"bytes,3,rep,name=running_tasks,json=runningTasks,proto3" json:"running_tasks,omitempty"` // 当前正在执行的任务列表
|
||
NextTasks []*CrontabTaskInfo `protobuf:"bytes,4,rep,name=next_tasks,json=nextTasks,proto3" json:"next_tasks,omitempty"` // 下一个计划执行的任务列表
|
||
TotalRunning uint32 `protobuf:"varint,5,opt,name=total_running,json=totalRunning,proto3" json:"total_running,omitempty"` // 正在运行的任务总数
|
||
TotalPlanned uint32 `protobuf:"varint,6,opt,name=total_planned,json=totalPlanned,proto3" json:"total_planned,omitempty"` // 计划中的任务总数
|
||
unknownFields protoimpl.UnknownFields
|
||
sizeCache protoimpl.SizeCache
|
||
}
|
||
|
||
func (x *CrontabStatusResponse) Reset() {
|
||
*x = CrontabStatusResponse{}
|
||
mi := &file_crontab_proto_msgTypes[14]
|
||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||
ms.StoreMessageInfo(mi)
|
||
}
|
||
|
||
func (x *CrontabStatusResponse) String() string {
|
||
return protoimpl.X.MessageStringOf(x)
|
||
}
|
||
|
||
func (*CrontabStatusResponse) ProtoMessage() {}
|
||
|
||
func (x *CrontabStatusResponse) ProtoReflect() protoreflect.Message {
|
||
mi := &file_crontab_proto_msgTypes[14]
|
||
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 CrontabStatusResponse.ProtoReflect.Descriptor instead.
|
||
func (*CrontabStatusResponse) Descriptor() ([]byte, []int) {
|
||
return file_crontab_proto_rawDescGZIP(), []int{14}
|
||
}
|
||
|
||
func (x *CrontabStatusResponse) GetCode() int32 {
|
||
if x != nil {
|
||
return x.Code
|
||
}
|
||
return 0
|
||
}
|
||
|
||
func (x *CrontabStatusResponse) GetMessage() string {
|
||
if x != nil {
|
||
return x.Message
|
||
}
|
||
return ""
|
||
}
|
||
|
||
func (x *CrontabStatusResponse) GetRunningTasks() []*CrontabTaskInfo {
|
||
if x != nil {
|
||
return x.RunningTasks
|
||
}
|
||
return nil
|
||
}
|
||
|
||
func (x *CrontabStatusResponse) GetNextTasks() []*CrontabTaskInfo {
|
||
if x != nil {
|
||
return x.NextTasks
|
||
}
|
||
return nil
|
||
}
|
||
|
||
func (x *CrontabStatusResponse) GetTotalRunning() uint32 {
|
||
if x != nil {
|
||
return x.TotalRunning
|
||
}
|
||
return 0
|
||
}
|
||
|
||
func (x *CrontabStatusResponse) GetTotalPlanned() uint32 {
|
||
if x != nil {
|
||
return x.TotalPlanned
|
||
}
|
||
return 0
|
||
}
|
||
|
||
var File_crontab_proto protoreflect.FileDescriptor
|
||
|
||
const file_crontab_proto_rawDesc = "" +
|
||
"\n" +
|
||
"\rcrontab.proto\x12\acrontab\x1a\x1cgoogle/api/annotations.proto\x1a\x1fgoogle/protobuf/timestamp.proto\"\xb9\x01\n" +
|
||
"\x10PlanResponseList\x12\x12\n" +
|
||
"\x04code\x18\x01 \x01(\x05R\x04code\x12\x18\n" +
|
||
"\amessage\x18\x02 \x01(\tR\amessage\x12\x1e\n" +
|
||
"\n" +
|
||
"totalCount\x18\x03 \x01(\rR\n" +
|
||
"totalCount\x12\x18\n" +
|
||
"\apageNum\x18\x04 \x01(\rR\apageNum\x12\x1a\n" +
|
||
"\bpageSize\x18\x05 \x01(\rR\bpageSize\x12!\n" +
|
||
"\x04data\x18\x06 \x03(\v2\r.crontab.PlanR\x04data\"\xce\x01\n" +
|
||
"\x04Plan\x12\x0e\n" +
|
||
"\x02id\x18\x01 \x01(\rR\x02id\x12\x12\n" +
|
||
"\x04name\x18\x02 \x01(\tR\x04name\x12\x16\n" +
|
||
"\x06enable\x18\x03 \x01(\bR\x06enable\x12:\n" +
|
||
"\n" +
|
||
"createTime\x18\x04 \x01(\v2\x1a.google.protobuf.TimestampR\n" +
|
||
"createTime\x12:\n" +
|
||
"\n" +
|
||
"updateTime\x18\x05 \x01(\v2\x1a.google.protobuf.TimestampR\n" +
|
||
"updateTime\x12\x12\n" +
|
||
"\x04plan\x18\x06 \x01(\tR\x04plan\"C\n" +
|
||
"\vReqPlanList\x12\x18\n" +
|
||
"\apageNum\x18\x01 \x01(\rR\apageNum\x12\x1a\n" +
|
||
"\bpageSize\x18\x02 \x01(\rR\bpageSize\"\x1f\n" +
|
||
"\rDeleteRequest\x12\x0e\n" +
|
||
"\x02id\x18\x01 \x01(\rR\x02id\"8\n" +
|
||
"\bResponse\x12\x12\n" +
|
||
"\x04code\x18\x01 \x01(\x05R\x04code\x12\x18\n" +
|
||
"\amessage\x18\x02 \x01(\tR\amessage\"\xac\x02\n" +
|
||
"\n" +
|
||
"PlanStream\x12\x16\n" +
|
||
"\x06planId\x18\x01 \x01(\rR\x06planId\x12\x1f\n" +
|
||
"\vstream_path\x18\x02 \x01(\tR\n" +
|
||
"streamPath\x12\x1a\n" +
|
||
"\bfragment\x18\x03 \x01(\tR\bfragment\x12\x1a\n" +
|
||
"\bfilePath\x18\x04 \x01(\tR\bfilePath\x12\x1f\n" +
|
||
"\vrecord_type\x18\x05 \x01(\tR\n" +
|
||
"recordType\x129\n" +
|
||
"\n" +
|
||
"created_at\x18\x06 \x01(\v2\x1a.google.protobuf.TimestampR\tcreatedAt\x129\n" +
|
||
"\n" +
|
||
"updated_at\x18\a \x01(\v2\x1a.google.protobuf.TimestampR\tupdatedAt\x12\x16\n" +
|
||
"\x06enable\x18\b \x01(\bR\x06enable\"\x82\x01\n" +
|
||
"\x11ReqPlanStreamList\x12\x18\n" +
|
||
"\apageNum\x18\x01 \x01(\rR\apageNum\x12\x1a\n" +
|
||
"\bpageSize\x18\x02 \x01(\rR\bpageSize\x12\x16\n" +
|
||
"\x06planId\x18\x03 \x01(\rR\x06planId\x12\x1f\n" +
|
||
"\vstream_path\x18\x04 \x01(\tR\n" +
|
||
"streamPath\"\xcb\x01\n" +
|
||
"\x1cRecordPlanStreamResponseList\x12\x12\n" +
|
||
"\x04code\x18\x01 \x01(\x05R\x04code\x12\x18\n" +
|
||
"\amessage\x18\x02 \x01(\tR\amessage\x12\x1e\n" +
|
||
"\n" +
|
||
"totalCount\x18\x03 \x01(\rR\n" +
|
||
"totalCount\x12\x18\n" +
|
||
"\apageNum\x18\x04 \x01(\rR\apageNum\x12\x1a\n" +
|
||
"\bpageSize\x18\x05 \x01(\rR\bpageSize\x12'\n" +
|
||
"\x04data\x18\x06 \x03(\v2\x13.crontab.PlanStreamR\x04data\"Q\n" +
|
||
"\x17DeletePlanStreamRequest\x12\x16\n" +
|
||
"\x06planId\x18\x01 \x01(\rR\x06planId\x12\x1e\n" +
|
||
"\n" +
|
||
"streamPath\x18\x02 \x01(\tR\n" +
|
||
"streamPath\"&\n" +
|
||
"\x10ParsePlanRequest\x12\x12\n" +
|
||
"\x04plan\x18\x01 \x01(\tR\x04plan\"\xa7\x01\n" +
|
||
"\fTimeSlotInfo\x120\n" +
|
||
"\x05start\x18\x01 \x01(\v2\x1a.google.protobuf.TimestampR\x05start\x12,\n" +
|
||
"\x03end\x18\x02 \x01(\v2\x1a.google.protobuf.TimestampR\x03end\x12\x18\n" +
|
||
"\aweekday\x18\x03 \x01(\tR\aweekday\x12\x1d\n" +
|
||
"\n" +
|
||
"time_range\x18\x04 \x01(\tR\ttimeRange\"\xa2\x01\n" +
|
||
"\x11ParsePlanResponse\x12\x12\n" +
|
||
"\x04code\x18\x01 \x01(\x05R\x04code\x12\x18\n" +
|
||
"\amessage\x18\x02 \x01(\tR\amessage\x12+\n" +
|
||
"\x05slots\x18\x03 \x03(\v2\x15.crontab.TimeSlotInfoR\x05slots\x122\n" +
|
||
"\tnext_slot\x18\x04 \x01(\v2\x15.crontab.TimeSlotInfoR\bnextSlot\"7\n" +
|
||
"\x14CrontabStatusRequest\x12\x1f\n" +
|
||
"\vstream_path\x18\x01 \x01(\tR\n" +
|
||
"streamPath\"\xfb\x03\n" +
|
||
"\x0fCrontabTaskInfo\x12\x17\n" +
|
||
"\aplan_id\x18\x01 \x01(\rR\x06planId\x12\x1b\n" +
|
||
"\tplan_name\x18\x02 \x01(\tR\bplanName\x12\x1f\n" +
|
||
"\vstream_path\x18\x03 \x01(\tR\n" +
|
||
"streamPath\x12!\n" +
|
||
"\fis_recording\x18\x04 \x01(\bR\visRecording\x129\n" +
|
||
"\n" +
|
||
"start_time\x18\x05 \x01(\v2\x1a.google.protobuf.TimestampR\tstartTime\x125\n" +
|
||
"\bend_time\x18\x06 \x01(\v2\x1a.google.protobuf.TimestampR\aendTime\x12\x1d\n" +
|
||
"\n" +
|
||
"time_range\x18\a \x01(\tR\ttimeRange\x12\x18\n" +
|
||
"\aweekday\x18\b \x01(\tR\aweekday\x12\x1b\n" +
|
||
"\tfile_path\x18\t \x01(\tR\bfilePath\x12\x1a\n" +
|
||
"\bfragment\x18\n" +
|
||
" \x01(\tR\bfragment\x12'\n" +
|
||
"\x0felapsed_seconds\x18\v \x01(\rR\x0eelapsedSeconds\x12+\n" +
|
||
"\x11remaining_seconds\x18\f \x01(\rR\x10remainingSeconds\x124\n" +
|
||
"\n" +
|
||
"plan_slots\x18\r \x03(\v2\x15.crontab.TimeSlotInfoR\tplanSlots\"\x87\x02\n" +
|
||
"\x15CrontabStatusResponse\x12\x12\n" +
|
||
"\x04code\x18\x01 \x01(\x05R\x04code\x12\x18\n" +
|
||
"\amessage\x18\x02 \x01(\tR\amessage\x12=\n" +
|
||
"\rrunning_tasks\x18\x03 \x03(\v2\x18.crontab.CrontabTaskInfoR\frunningTasks\x127\n" +
|
||
"\n" +
|
||
"next_tasks\x18\x04 \x03(\v2\x18.crontab.CrontabTaskInfoR\tnextTasks\x12#\n" +
|
||
"\rtotal_running\x18\x05 \x01(\rR\ftotalRunning\x12#\n" +
|
||
"\rtotal_planned\x18\x06 \x01(\rR\ftotalPlanned2\xe0\a\n" +
|
||
"\x03api\x12O\n" +
|
||
"\x04List\x12\x14.crontab.ReqPlanList\x1a\x19.crontab.PlanResponseList\"\x16\x82\xd3\xe4\x93\x02\x10\x12\x0e/plan/api/list\x12A\n" +
|
||
"\x03Add\x12\r.crontab.Plan\x1a\x11.crontab.Response\"\x18\x82\xd3\xe4\x93\x02\x12:\x01*\"\r/plan/api/add\x12L\n" +
|
||
"\x06Update\x12\r.crontab.Plan\x1a\x11.crontab.Response\" \x82\xd3\xe4\x93\x02\x1a:\x01*\"\x15/plan/api/update/{id}\x12U\n" +
|
||
"\x06Remove\x12\x16.crontab.DeleteRequest\x1a\x11.crontab.Response\" \x82\xd3\xe4\x93\x02\x1a:\x01*\"\x15/plan/api/remove/{id}\x12x\n" +
|
||
"\x15ListRecordPlanStreams\x12\x1a.crontab.ReqPlanStreamList\x1a%.crontab.RecordPlanStreamResponseList\"\x1c\x82\xd3\xe4\x93\x02\x16\x12\x14/planstream/api/list\x12]\n" +
|
||
"\x13AddRecordPlanStream\x12\x13.crontab.PlanStream\x1a\x11.crontab.Response\"\x1e\x82\xd3\xe4\x93\x02\x18:\x01*\"\x13/planstream/api/add\x12c\n" +
|
||
"\x16UpdateRecordPlanStream\x12\x13.crontab.PlanStream\x1a\x11.crontab.Response\"!\x82\xd3\xe4\x93\x02\x1b:\x01*\"\x16/planstream/api/update\x12\x89\x01\n" +
|
||
"\x16RemoveRecordPlanStream\x12 .crontab.DeletePlanStreamRequest\x1a\x11.crontab.Response\":\x82\xd3\xe4\x93\x024:\x01*\"//planstream/api/remove/{planId}/{streamPath=**}\x12f\n" +
|
||
"\rParsePlanTime\x12\x19.crontab.ParsePlanRequest\x1a\x1a.crontab.ParsePlanResponse\"\x1e\x82\xd3\xe4\x93\x02\x18\x12\x16/plan/api/parse/{plan}\x12n\n" +
|
||
"\x10GetCrontabStatus\x12\x1d.crontab.CrontabStatusRequest\x1a\x1e.crontab.CrontabStatusResponse\"\x1b\x82\xd3\xe4\x93\x02\x15\x12\x13/crontab/api/statusB\x1fZ\x1dm7s.live/v5/plugin/crontab/pbb\x06proto3"
|
||
|
||
var (
|
||
file_crontab_proto_rawDescOnce sync.Once
|
||
file_crontab_proto_rawDescData []byte
|
||
)
|
||
|
||
func file_crontab_proto_rawDescGZIP() []byte {
|
||
file_crontab_proto_rawDescOnce.Do(func() {
|
||
file_crontab_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_crontab_proto_rawDesc), len(file_crontab_proto_rawDesc)))
|
||
})
|
||
return file_crontab_proto_rawDescData
|
||
}
|
||
|
||
var file_crontab_proto_msgTypes = make([]protoimpl.MessageInfo, 15)
|
||
var file_crontab_proto_goTypes = []any{
|
||
(*PlanResponseList)(nil), // 0: crontab.PlanResponseList
|
||
(*Plan)(nil), // 1: crontab.Plan
|
||
(*ReqPlanList)(nil), // 2: crontab.ReqPlanList
|
||
(*DeleteRequest)(nil), // 3: crontab.DeleteRequest
|
||
(*Response)(nil), // 4: crontab.Response
|
||
(*PlanStream)(nil), // 5: crontab.PlanStream
|
||
(*ReqPlanStreamList)(nil), // 6: crontab.ReqPlanStreamList
|
||
(*RecordPlanStreamResponseList)(nil), // 7: crontab.RecordPlanStreamResponseList
|
||
(*DeletePlanStreamRequest)(nil), // 8: crontab.DeletePlanStreamRequest
|
||
(*ParsePlanRequest)(nil), // 9: crontab.ParsePlanRequest
|
||
(*TimeSlotInfo)(nil), // 10: crontab.TimeSlotInfo
|
||
(*ParsePlanResponse)(nil), // 11: crontab.ParsePlanResponse
|
||
(*CrontabStatusRequest)(nil), // 12: crontab.CrontabStatusRequest
|
||
(*CrontabTaskInfo)(nil), // 13: crontab.CrontabTaskInfo
|
||
(*CrontabStatusResponse)(nil), // 14: crontab.CrontabStatusResponse
|
||
(*timestamppb.Timestamp)(nil), // 15: google.protobuf.Timestamp
|
||
}
|
||
var file_crontab_proto_depIdxs = []int32{
|
||
1, // 0: crontab.PlanResponseList.data:type_name -> crontab.Plan
|
||
15, // 1: crontab.Plan.createTime:type_name -> google.protobuf.Timestamp
|
||
15, // 2: crontab.Plan.updateTime:type_name -> google.protobuf.Timestamp
|
||
15, // 3: crontab.PlanStream.created_at:type_name -> google.protobuf.Timestamp
|
||
15, // 4: crontab.PlanStream.updated_at:type_name -> google.protobuf.Timestamp
|
||
5, // 5: crontab.RecordPlanStreamResponseList.data:type_name -> crontab.PlanStream
|
||
15, // 6: crontab.TimeSlotInfo.start:type_name -> google.protobuf.Timestamp
|
||
15, // 7: crontab.TimeSlotInfo.end:type_name -> google.protobuf.Timestamp
|
||
10, // 8: crontab.ParsePlanResponse.slots:type_name -> crontab.TimeSlotInfo
|
||
10, // 9: crontab.ParsePlanResponse.next_slot:type_name -> crontab.TimeSlotInfo
|
||
15, // 10: crontab.CrontabTaskInfo.start_time:type_name -> google.protobuf.Timestamp
|
||
15, // 11: crontab.CrontabTaskInfo.end_time:type_name -> google.protobuf.Timestamp
|
||
10, // 12: crontab.CrontabTaskInfo.plan_slots:type_name -> crontab.TimeSlotInfo
|
||
13, // 13: crontab.CrontabStatusResponse.running_tasks:type_name -> crontab.CrontabTaskInfo
|
||
13, // 14: crontab.CrontabStatusResponse.next_tasks:type_name -> crontab.CrontabTaskInfo
|
||
2, // 15: crontab.api.List:input_type -> crontab.ReqPlanList
|
||
1, // 16: crontab.api.Add:input_type -> crontab.Plan
|
||
1, // 17: crontab.api.Update:input_type -> crontab.Plan
|
||
3, // 18: crontab.api.Remove:input_type -> crontab.DeleteRequest
|
||
6, // 19: crontab.api.ListRecordPlanStreams:input_type -> crontab.ReqPlanStreamList
|
||
5, // 20: crontab.api.AddRecordPlanStream:input_type -> crontab.PlanStream
|
||
5, // 21: crontab.api.UpdateRecordPlanStream:input_type -> crontab.PlanStream
|
||
8, // 22: crontab.api.RemoveRecordPlanStream:input_type -> crontab.DeletePlanStreamRequest
|
||
9, // 23: crontab.api.ParsePlanTime:input_type -> crontab.ParsePlanRequest
|
||
12, // 24: crontab.api.GetCrontabStatus:input_type -> crontab.CrontabStatusRequest
|
||
0, // 25: crontab.api.List:output_type -> crontab.PlanResponseList
|
||
4, // 26: crontab.api.Add:output_type -> crontab.Response
|
||
4, // 27: crontab.api.Update:output_type -> crontab.Response
|
||
4, // 28: crontab.api.Remove:output_type -> crontab.Response
|
||
7, // 29: crontab.api.ListRecordPlanStreams:output_type -> crontab.RecordPlanStreamResponseList
|
||
4, // 30: crontab.api.AddRecordPlanStream:output_type -> crontab.Response
|
||
4, // 31: crontab.api.UpdateRecordPlanStream:output_type -> crontab.Response
|
||
4, // 32: crontab.api.RemoveRecordPlanStream:output_type -> crontab.Response
|
||
11, // 33: crontab.api.ParsePlanTime:output_type -> crontab.ParsePlanResponse
|
||
14, // 34: crontab.api.GetCrontabStatus:output_type -> crontab.CrontabStatusResponse
|
||
25, // [25:35] is the sub-list for method output_type
|
||
15, // [15:25] is the sub-list for method input_type
|
||
15, // [15:15] is the sub-list for extension type_name
|
||
15, // [15:15] is the sub-list for extension extendee
|
||
0, // [0:15] is the sub-list for field type_name
|
||
}
|
||
|
||
func init() { file_crontab_proto_init() }
|
||
func file_crontab_proto_init() {
|
||
if File_crontab_proto != nil {
|
||
return
|
||
}
|
||
type x struct{}
|
||
out := protoimpl.TypeBuilder{
|
||
File: protoimpl.DescBuilder{
|
||
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
|
||
RawDescriptor: unsafe.Slice(unsafe.StringData(file_crontab_proto_rawDesc), len(file_crontab_proto_rawDesc)),
|
||
NumEnums: 0,
|
||
NumMessages: 15,
|
||
NumExtensions: 0,
|
||
NumServices: 1,
|
||
},
|
||
GoTypes: file_crontab_proto_goTypes,
|
||
DependencyIndexes: file_crontab_proto_depIdxs,
|
||
MessageInfos: file_crontab_proto_msgTypes,
|
||
}.Build()
|
||
File_crontab_proto = out.File
|
||
file_crontab_proto_goTypes = nil
|
||
file_crontab_proto_depIdxs = nil
|
||
}
|