v1

package
v0.0.0-...-83adff0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 6, 2020 License: GPL-3.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const DiscoveryAppID = "video.live.streamng"

DiscoveryAppID .

Variables

View Source 
var (
	ErrInvalidLengthApi = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowApi   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterStreamServer 

func RegisterStreamServer(s *grpc.Server, srv StreamServer)

Types

type AdapterStream 

type AdapterStream struct {
	// src
	Src int64 `protobuf:"varint,1,opt,name=src,proto3" json:"src,omitempty"`
	// 房间号
	RoomId int64 `protobuf:"varint,2,opt,name=room_id,json=roomId,proto3" json:"room_id"`
	// 上行
	UpRank int64 `protobuf:"varint,3,opt,name=up_rank,json=upRank,proto3" json:"up_rank"`
	// 上行名称
	SrcName              string   `protobuf:"bytes,4,opt,name=src_name,json=srcName,proto3" json:"src_name"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

AdapterStream 上行流信息

func (*AdapterStream) Descriptor 

func (*AdapterStream) Descriptor() ([]byte, []int)

func (*AdapterStream) GetRoomId 

func (m *AdapterStream) GetRoomId() int64

func (*AdapterStream) GetSrc 

func (m *AdapterStream) GetSrc() int64

func (*AdapterStream) GetSrcName 

func (m *AdapterStream) GetSrcName() string

func (*AdapterStream) GetUpRank 

func (m *AdapterStream) GetUpRank() int64

func (*AdapterStream) Marshal 

func (m *AdapterStream) Marshal() (dAtA []byte, err error)

func (*AdapterStream) MarshalTo 

func (m *AdapterStream) MarshalTo(dAtA []byte) (int, error)

func (*AdapterStream) ProtoMessage 

func (*AdapterStream) ProtoMessage()

func (*AdapterStream) Reset 

func (m *AdapterStream) Reset()

func (*AdapterStream) Size 

func (m *AdapterStream) Size() (n int)

func (*AdapterStream) String 

func (m *AdapterStream) String() string

func (*AdapterStream) Unmarshal 

func (m *AdapterStream) Unmarshal(dAtA []byte) error

func (*AdapterStream) XXX_DiscardUnknown 

func (m *AdapterStream) XXX_DiscardUnknown()

func (*AdapterStream) XXX_Marshal 

func (m *AdapterStream) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AdapterStream) XXX_Merge 

func (dst *AdapterStream) XXX_Merge(src proto.Message)

func (*AdapterStream) XXX_Size 

func (m *AdapterStream) XXX_Size() int

func (*AdapterStream) XXX_Unmarshal 

func (m *AdapterStream) XXX_Unmarshal(b []byte) error

type ChangeSrcReq 

type ChangeSrcReq struct {
	// 房间号
	RoomId int64 `protobuf:"varint,1,opt,name=room_id,json=roomId,proto3" json:"room_id,omitempty"`
	// src
	Src int64 `protobuf:"varint,2,opt,name=src,proto3" json:"src,omitempty"`
	// 来源平台
	Source string `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"`
	// 操作人
	OperateName string `protobuf:"bytes,4,opt,name=operate_name,json=operateName,proto3" json:"operate_name,omitempty"`
	// 原因
	Reason               string   `protobuf:"bytes,5,opt,name=reason,proto3" json:"reason,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ChangeSrcReq 切换上行

func (*ChangeSrcReq) Descriptor 

func (*ChangeSrcReq) Descriptor() ([]byte, []int)

func (*ChangeSrcReq) GetOperateName 

func (m *ChangeSrcReq) GetOperateName() string

func (*ChangeSrcReq) GetReason 

func (m *ChangeSrcReq) GetReason() string

func (*ChangeSrcReq) GetRoomId 

func (m *ChangeSrcReq) GetRoomId() int64

func (*ChangeSrcReq) GetSource 

func (m *ChangeSrcReq) GetSource() string

func (*ChangeSrcReq) GetSrc 

func (m *ChangeSrcReq) GetSrc() int64

func (*ChangeSrcReq) Marshal 

func (m *ChangeSrcReq) Marshal() (dAtA []byte, err error)

func (*ChangeSrcReq) MarshalTo 

func (m *ChangeSrcReq) MarshalTo(dAtA []byte) (int, error)

func (*ChangeSrcReq) ProtoMessage 

func (*ChangeSrcReq) ProtoMessage()

func (*ChangeSrcReq) Reset 

func (m *ChangeSrcReq) Reset()

func (*ChangeSrcReq) Size 

func (m *ChangeSrcReq) Size() (n int)

func (*ChangeSrcReq) String 

func (m *ChangeSrcReq) String() string

func (*ChangeSrcReq) Unmarshal 

func (m *ChangeSrcReq) Unmarshal(dAtA []byte) error

func (*ChangeSrcReq) XXX_DiscardUnknown 

func (m *ChangeSrcReq) XXX_DiscardUnknown()

func (*ChangeSrcReq) XXX_Marshal 

func (m *ChangeSrcReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChangeSrcReq) XXX_Merge 

func (dst *ChangeSrcReq) XXX_Merge(src proto.Message)

func (*ChangeSrcReq) XXX_Size 

func (m *ChangeSrcReq) XXX_Size() int

func (*ChangeSrcReq) XXX_Unmarshal 

func (m *ChangeSrcReq) XXX_Unmarshal(b []byte) error

type CheckLiveStreamReply 

type CheckLiveStreamReply struct {
	List                 map[int64]bool `` /* 144-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*CheckLiveStreamReply) Descriptor 

func (*CheckLiveStreamReply) Descriptor() ([]byte, []int)

func (*CheckLiveStreamReply) GetList 

func (m *CheckLiveStreamReply) GetList() map[int64]bool

func (*CheckLiveStreamReply) Marshal 

func (m *CheckLiveStreamReply) Marshal() (dAtA []byte, err error)

func (*CheckLiveStreamReply) MarshalTo 

func (m *CheckLiveStreamReply) MarshalTo(dAtA []byte) (int, error)

func (*CheckLiveStreamReply) ProtoMessage 

func (*CheckLiveStreamReply) ProtoMessage()

func (*CheckLiveStreamReply) Reset 

func (m *CheckLiveStreamReply) Reset()

func (*CheckLiveStreamReply) Size 

func (m *CheckLiveStreamReply) Size() (n int)

func (*CheckLiveStreamReply) String 

func (m *CheckLiveStreamReply) String() string

func (*CheckLiveStreamReply) Unmarshal 

func (m *CheckLiveStreamReply) Unmarshal(dAtA []byte) error

func (*CheckLiveStreamReply) XXX_DiscardUnknown 

func (m *CheckLiveStreamReply) XXX_DiscardUnknown()

func (*CheckLiveStreamReply) XXX_Marshal 

func (m *CheckLiveStreamReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckLiveStreamReply) XXX_Merge 

func (dst *CheckLiveStreamReply) XXX_Merge(src proto.Message)

func (*CheckLiveStreamReply) XXX_Size 

func (m *CheckLiveStreamReply) XXX_Size() int

func (*CheckLiveStreamReply) XXX_Unmarshal 

func (m *CheckLiveStreamReply) XXX_Unmarshal(b []byte) error

type CheckLiveStreamReq 

type CheckLiveStreamReq struct {
	RoomId               []int64  `protobuf:"varint,1,rep,packed,name=room_id,json=roomId" json:"room_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CheckLiveStreamReq) Descriptor 

func (*CheckLiveStreamReq) Descriptor() ([]byte, []int)

func (*CheckLiveStreamReq) GetRoomId 

func (m *CheckLiveStreamReq) GetRoomId() []int64

func (*CheckLiveStreamReq) Marshal 

func (m *CheckLiveStreamReq) Marshal() (dAtA []byte, err error)

func (*CheckLiveStreamReq) MarshalTo 

func (m *CheckLiveStreamReq) MarshalTo(dAtA []byte) (int, error)

func (*CheckLiveStreamReq) ProtoMessage 

func (*CheckLiveStreamReq) ProtoMessage()

func (*CheckLiveStreamReq) Reset 

func (m *CheckLiveStreamReq) Reset()

func (*CheckLiveStreamReq) Size 

func (m *CheckLiveStreamReq) Size() (n int)

func (*CheckLiveStreamReq) String 

func (m *CheckLiveStreamReq) String() string

func (*CheckLiveStreamReq) Unmarshal 

func (m *CheckLiveStreamReq) Unmarshal(dAtA []byte) error

func (*CheckLiveStreamReq) XXX_DiscardUnknown 

func (m *CheckLiveStreamReq) XXX_DiscardUnknown()

func (*CheckLiveStreamReq) XXX_Marshal 

func (m *CheckLiveStreamReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckLiveStreamReq) XXX_Merge 

func (dst *CheckLiveStreamReq) XXX_Merge(src proto.Message)

func (*CheckLiveStreamReq) XXX_Size 

func (m *CheckLiveStreamReq) XXX_Size() int

func (*CheckLiveStreamReq) XXX_Unmarshal 

func (m *CheckLiveStreamReq) XXX_Unmarshal(b []byte) error

type ClearStreamStatusReq 

type ClearStreamStatusReq struct {
	// 房间号
	RoomId               int64    `protobuf:"varint,1,opt,name=room_id,json=roomId,proto3" json:"room_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ClearStreamStatusReq 清理互推

func (*ClearStreamStatusReq) Descriptor 

func (*ClearStreamStatusReq) Descriptor() ([]byte, []int)

func (*ClearStreamStatusReq) GetRoomId 

func (m *ClearStreamStatusReq) GetRoomId() int64

func (*ClearStreamStatusReq) Marshal 

func (m *ClearStreamStatusReq) Marshal() (dAtA []byte, err error)

func (*ClearStreamStatusReq) MarshalTo 

func (m *ClearStreamStatusReq) MarshalTo(dAtA []byte) (int, error)

func (*ClearStreamStatusReq) ProtoMessage 

func (*ClearStreamStatusReq) ProtoMessage()

func (*ClearStreamStatusReq) Reset 

func (m *ClearStreamStatusReq) Reset()

func (*ClearStreamStatusReq) Size 

func (m *ClearStreamStatusReq) Size() (n int)

func (*ClearStreamStatusReq) String 

func (m *ClearStreamStatusReq) String() string

func (*ClearStreamStatusReq) Unmarshal 

func (m *ClearStreamStatusReq) Unmarshal(dAtA []byte) error

func (*ClearStreamStatusReq) XXX_DiscardUnknown 

func (m *ClearStreamStatusReq) XXX_DiscardUnknown()

func (*ClearStreamStatusReq) XXX_Marshal 

func (m *ClearStreamStatusReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClearStreamStatusReq) XXX_Merge 

func (dst *ClearStreamStatusReq) XXX_Merge(src proto.Message)

func (*ClearStreamStatusReq) XXX_Size 

func (m *ClearStreamStatusReq) XXX_Size() int

func (*ClearStreamStatusReq) XXX_Unmarshal 

func (m *ClearStreamStatusReq) XXX_Unmarshal(b []byte) error

type CloseReply 

type CloseReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CloseReply CloseReply

func (*CloseReply) Descriptor 

func (*CloseReply) Descriptor() ([]byte, []int)

func (*CloseReply) Marshal 

func (m *CloseReply) Marshal() (dAtA []byte, err error)

func (*CloseReply) MarshalTo 

func (m *CloseReply) MarshalTo(dAtA []byte) (int, error)

func (*CloseReply) ProtoMessage 

func (*CloseReply) ProtoMessage()

func (*CloseReply) Reset 

func (m *CloseReply) Reset()

func (*CloseReply) Size 

func (m *CloseReply) Size() (n int)

func (*CloseReply) String 

func (m *CloseReply) String() string

func (*CloseReply) Unmarshal 

func (m *CloseReply) Unmarshal(dAtA []byte) error

func (*CloseReply) XXX_DiscardUnknown 

func (m *CloseReply) XXX_DiscardUnknown()

func (*CloseReply) XXX_Marshal 

func (m *CloseReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CloseReply) XXX_Merge 

func (dst *CloseReply) XXX_Merge(src proto.Message)

func (*CloseReply) XXX_Size 

func (m *CloseReply) XXX_Size() int

func (*CloseReply) XXX_Unmarshal 

func (m *CloseReply) XXX_Unmarshal(b []byte) error

type CloseReq 

type CloseReq struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CloseReq CloseReq

func (*CloseReq) Descriptor 

func (*CloseReq) Descriptor() ([]byte, []int)

func (*CloseReq) Marshal 

func (m *CloseReq) Marshal() (dAtA []byte, err error)

func (*CloseReq) MarshalTo 

func (m *CloseReq) MarshalTo(dAtA []byte) (int, error)

func (*CloseReq) ProtoMessage 

func (*CloseReq) ProtoMessage()

func (*CloseReq) Reset 

func (m *CloseReq) Reset()

func (*CloseReq) Size 

func (m *CloseReq) Size() (n int)

func (*CloseReq) String 

func (m *CloseReq) String() string

func (*CloseReq) Unmarshal 

func (m *CloseReq) Unmarshal(dAtA []byte) error

func (*CloseReq) XXX_DiscardUnknown 

func (m *CloseReq) XXX_DiscardUnknown()

func (*CloseReq) XXX_Marshal 

func (m *CloseReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CloseReq) XXX_Merge 

func (dst *CloseReq) XXX_Merge(src proto.Message)

func (*CloseReq) XXX_Size 

func (m *CloseReq) XXX_Size() int

func (*CloseReq) XXX_Unmarshal 

func (m *CloseReq) XXX_Unmarshal(b []byte) error

type CreateOfficalStreamReply 

type CreateOfficalStreamReply struct {
	// 是否成功
	Success              bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CreateOfficalStreamReply 创建流

func (*CreateOfficalStreamReply) Descriptor 

func (*CreateOfficalStreamReply) Descriptor() ([]byte, []int)

func (*CreateOfficalStreamReply) GetSuccess 

func (m *CreateOfficalStreamReply) GetSuccess() bool

func (*CreateOfficalStreamReply) Marshal 

func (m *CreateOfficalStreamReply) Marshal() (dAtA []byte, err error)

func (*CreateOfficalStreamReply) MarshalTo 

func (m *CreateOfficalStreamReply) MarshalTo(dAtA []byte) (int, error)

func (*CreateOfficalStreamReply) ProtoMessage 

func (*CreateOfficalStreamReply) ProtoMessage()

func (*CreateOfficalStreamReply) Reset 

func (m *CreateOfficalStreamReply) Reset()

func (*CreateOfficalStreamReply) Size 

func (m *CreateOfficalStreamReply) Size() (n int)

func (*CreateOfficalStreamReply) String 

func (m *CreateOfficalStreamReply) String() string

func (*CreateOfficalStreamReply) Unmarshal 

func (m *CreateOfficalStreamReply) Unmarshal(dAtA []byte) error

func (*CreateOfficalStreamReply) XXX_DiscardUnknown 

func (m *CreateOfficalStreamReply) XXX_DiscardUnknown()

func (*CreateOfficalStreamReply) XXX_Marshal 

func (m *CreateOfficalStreamReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateOfficalStreamReply) XXX_Merge 

func (dst *CreateOfficalStreamReply) XXX_Merge(src proto.Message)

func (*CreateOfficalStreamReply) XXX_Size 

func (m *CreateOfficalStreamReply) XXX_Size() int

func (*CreateOfficalStreamReply) XXX_Unmarshal 

func (m *CreateOfficalStreamReply) XXX_Unmarshal(b []byte) error

type CreateOfficalStreamReq 

type CreateOfficalStreamReq struct {
	// 流名
	StreamName string `protobuf:"bytes,1,opt,name=stream_name,json=streamName,proto3" json:"stream_name,omitempty"`
	// key
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// 房间号
	RoomId int64 `protobuf:"varint,3,opt,name=room_id,json=roomId,proto3" json:"room_id,omitempty"`
	// 是否线下测试
	Debug string `protobuf:"bytes,4,opt,name=debug,proto3" json:"debug,omitempty"`
	// 线下测试必传
	Uid                  int64    `protobuf:"varint,5,opt,name=uid,proto3" json:"uid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CreateOfficalStreamReq 创建流

func (*CreateOfficalStreamReq) Descriptor 

func (*CreateOfficalStreamReq) Descriptor() ([]byte, []int)

func (*CreateOfficalStreamReq) GetDebug 

func (m *CreateOfficalStreamReq) GetDebug() string

func (*CreateOfficalStreamReq) GetKey 

func (m *CreateOfficalStreamReq) GetKey() string

func (*CreateOfficalStreamReq) GetRoomId 

func (m *CreateOfficalStreamReq) GetRoomId() int64

func (*CreateOfficalStreamReq) GetStreamName 

func (m *CreateOfficalStreamReq) GetStreamName() string

func (*CreateOfficalStreamReq) GetUid 

func (m *CreateOfficalStreamReq) GetUid() int64

func (*CreateOfficalStreamReq) Marshal 

func (m *CreateOfficalStreamReq) Marshal() (dAtA []byte, err error)

func (*CreateOfficalStreamReq) MarshalTo 

func (m *CreateOfficalStreamReq) MarshalTo(dAtA []byte) (int, error)

func (*CreateOfficalStreamReq) ProtoMessage 

func (*CreateOfficalStreamReq) ProtoMessage()

func (*CreateOfficalStreamReq) Reset 

func (m *CreateOfficalStreamReq) Reset()

func (*CreateOfficalStreamReq) Size 

func (m *CreateOfficalStreamReq) Size() (n int)

func (*CreateOfficalStreamReq) String 

func (m *CreateOfficalStreamReq) String() string

func (*CreateOfficalStreamReq) Unmarshal 

func (m *CreateOfficalStreamReq) Unmarshal(dAtA []byte) error

func (*CreateOfficalStreamReq) XXX_DiscardUnknown 

func (m *CreateOfficalStreamReq) XXX_DiscardUnknown()

func (*CreateOfficalStreamReq) XXX_Marshal 

func (m *CreateOfficalStreamReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateOfficalStreamReq) XXX_Merge 

func (dst *CreateOfficalStreamReq) XXX_Merge(src proto.Message)

func (*CreateOfficalStreamReq) XXX_Size 

func (m *CreateOfficalStreamReq) XXX_Size() int

func (*CreateOfficalStreamReq) XXX_Unmarshal 

func (m *CreateOfficalStreamReq) XXX_Unmarshal(b []byte) error

type EmptyStruct 

type EmptyStruct struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

EmptyStruct 空的message，对应真实service只返回error，没有具体返回值

func (*EmptyStruct) Descriptor 

func (*EmptyStruct) Descriptor() ([]byte, []int)

func (*EmptyStruct) Marshal 

func (m *EmptyStruct) Marshal() (dAtA []byte, err error)

func (*EmptyStruct) MarshalTo 

func (m *EmptyStruct) MarshalTo(dAtA []byte) (int, error)

func (*EmptyStruct) ProtoMessage 

func (*EmptyStruct) ProtoMessage()

func (*EmptyStruct) Reset 

func (m *EmptyStruct) Reset()

func (*EmptyStruct) Size 

func (m *EmptyStruct) Size() (n int)

func (*EmptyStruct) String 

func (m *EmptyStruct) String() string

func (*EmptyStruct) Unmarshal 

func (m *EmptyStruct) Unmarshal(dAtA []byte) error

func (*EmptyStruct) XXX_DiscardUnknown 

func (m *EmptyStruct) XXX_DiscardUnknown()

func (*EmptyStruct) XXX_Marshal 

func (m *EmptyStruct) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EmptyStruct) XXX_Merge 

func (dst *EmptyStruct) XXX_Merge(src proto.Message)

func (*EmptyStruct) XXX_Size 

func (m *EmptyStruct) XXX_Size() int

func (*EmptyStruct) XXX_Unmarshal 

func (m *EmptyStruct) XXX_Unmarshal(b []byte) error

type GetAdapterStreamByStreamNameReply 

type GetAdapterStreamByStreamNameReply struct {
	// 流名map流具体信息
	List                 map[string]*AdapterStream `` /* 135-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

GetAdapterStreamByStreamNameReply 适配PHP代码

func (*GetAdapterStreamByStreamNameReply) Descriptor 

func (*GetAdapterStreamByStreamNameReply) Descriptor() ([]byte, []int)

func (*GetAdapterStreamByStreamNameReply) GetList 

func (m *GetAdapterStreamByStreamNameReply) GetList() map[string]*AdapterStream

func (*GetAdapterStreamByStreamNameReply) Marshal 

func (m *GetAdapterStreamByStreamNameReply) Marshal() (dAtA []byte, err error)

func (*GetAdapterStreamByStreamNameReply) MarshalTo 

func (m *GetAdapterStreamByStreamNameReply) MarshalTo(dAtA []byte) (int, error)

func (*GetAdapterStreamByStreamNameReply) ProtoMessage 

func (*GetAdapterStreamByStreamNameReply) ProtoMessage()

func (*GetAdapterStreamByStreamNameReply) Reset 

func (m *GetAdapterStreamByStreamNameReply) Reset()

func (*GetAdapterStreamByStreamNameReply) Size 

func (m *GetAdapterStreamByStreamNameReply) Size() (n int)

func (*GetAdapterStreamByStreamNameReply) String 

func (m *GetAdapterStreamByStreamNameReply) String() string

func (*GetAdapterStreamByStreamNameReply) Unmarshal 

func (m *GetAdapterStreamByStreamNameReply) Unmarshal(dAtA []byte) error

func (*GetAdapterStreamByStreamNameReply) XXX_DiscardUnknown 

func (m *GetAdapterStreamByStreamNameReply) XXX_DiscardUnknown()

func (*GetAdapterStreamByStreamNameReply) XXX_Marshal 

func (m *GetAdapterStreamByStreamNameReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetAdapterStreamByStreamNameReply) XXX_Merge 

func (dst *GetAdapterStreamByStreamNameReply) XXX_Merge(src proto.Message)

func (*GetAdapterStreamByStreamNameReply) XXX_Size 

func (m *GetAdapterStreamByStreamNameReply) XXX_Size() int

func (*GetAdapterStreamByStreamNameReply) XXX_Unmarshal 

func (m *GetAdapterStreamByStreamNameReply) XXX_Unmarshal(b []byte) error

type GetAdapterStreamByStreamNameReq 

type GetAdapterStreamByStreamNameReq struct {
	// 流名
	StreamNames          string   `protobuf:"bytes,1,opt,name=stream_names,json=streamNames,proto3" json:"stream_names"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetAdapterStreamByStreamNameReq 适配PHP代码

func (*GetAdapterStreamByStreamNameReq) Descriptor 

func (*GetAdapterStreamByStreamNameReq) Descriptor() ([]byte, []int)

func (*GetAdapterStreamByStreamNameReq) GetStreamNames 

func (m *GetAdapterStreamByStreamNameReq) GetStreamNames() string

func (*GetAdapterStreamByStreamNameReq) Marshal 

func (m *GetAdapterStreamByStreamNameReq) Marshal() (dAtA []byte, err error)

func (*GetAdapterStreamByStreamNameReq) MarshalTo 

func (m *GetAdapterStreamByStreamNameReq) MarshalTo(dAtA []byte) (int, error)

func (*GetAdapterStreamByStreamNameReq) ProtoMessage 

func (*GetAdapterStreamByStreamNameReq) ProtoMessage()

func (*GetAdapterStreamByStreamNameReq) Reset 

func (m *GetAdapterStreamByStreamNameReq) Reset()

func (*GetAdapterStreamByStreamNameReq) Size 

func (m *GetAdapterStreamByStreamNameReq) Size() (n int)

func (*GetAdapterStreamByStreamNameReq) String 

func (m *GetAdapterStreamByStreamNameReq) String() string

func (*GetAdapterStreamByStreamNameReq) Unmarshal 

func (m *GetAdapterStreamByStreamNameReq) Unmarshal(dAtA []byte) error

func (*GetAdapterStreamByStreamNameReq) XXX_DiscardUnknown 

func (m *GetAdapterStreamByStreamNameReq) XXX_DiscardUnknown()

func (*GetAdapterStreamByStreamNameReq) XXX_Marshal 

func (m *GetAdapterStreamByStreamNameReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetAdapterStreamByStreamNameReq) XXX_Merge 

func (dst *GetAdapterStreamByStreamNameReq) XXX_Merge(src proto.Message)

func (*GetAdapterStreamByStreamNameReq) XXX_Size 

func (m *GetAdapterStreamByStreamNameReq) XXX_Size() int

func (*GetAdapterStreamByStreamNameReq) XXX_Unmarshal 

func (m *GetAdapterStreamByStreamNameReq) XXX_Unmarshal(b []byte) error

type GetLineListByRoomIDReply 

type GetLineListByRoomIDReply struct {
	// 线路信息， 多条
	List                 []*LineList `protobuf:"bytes,1,rep,name=list" json:"list,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

GetLineListByRoomIDReply 获取线路信息

func (*GetLineListByRoomIDReply) Descriptor 

func (*GetLineListByRoomIDReply) Descriptor() ([]byte, []int)

func (*GetLineListByRoomIDReply) GetList 

func (m *GetLineListByRoomIDReply) GetList() []*LineList

func (*GetLineListByRoomIDReply) Marshal 

func (m *GetLineListByRoomIDReply) Marshal() (dAtA []byte, err error)

func (*GetLineListByRoomIDReply) MarshalTo 

func (m *GetLineListByRoomIDReply) MarshalTo(dAtA []byte) (int, error)

func (*GetLineListByRoomIDReply) ProtoMessage 

func (*GetLineListByRoomIDReply) ProtoMessage()

func (*GetLineListByRoomIDReply) Reset 

func (m *GetLineListByRoomIDReply) Reset()

func (*GetLineListByRoomIDReply) Size 

func (m *GetLineListByRoomIDReply) Size() (n int)

func (*GetLineListByRoomIDReply) String 

func (m *GetLineListByRoomIDReply) String() string

func (*GetLineListByRoomIDReply) Unmarshal 

func (m *GetLineListByRoomIDReply) Unmarshal(dAtA []byte) error

func (*GetLineListByRoomIDReply) XXX_DiscardUnknown 

func (m *GetLineListByRoomIDReply) XXX_DiscardUnknown()

func (*GetLineListByRoomIDReply) XXX_Marshal 

func (m *GetLineListByRoomIDReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetLineListByRoomIDReply) XXX_Merge 

func (dst *GetLineListByRoomIDReply) XXX_Merge(src proto.Message)

func (*GetLineListByRoomIDReply) XXX_Size 

func (m *GetLineListByRoomIDReply) XXX_Size() int

func (*GetLineListByRoomIDReply) XXX_Unmarshal 

func (m *GetLineListByRoomIDReply) XXX_Unmarshal(b []byte) error

type GetLineListByRoomIDReq 

type GetLineListByRoomIDReq struct {
	// 房间号
	RoomId               int64    `protobuf:"varint,1,opt,name=room_id,json=roomId,proto3" json:"room_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetLineListByRoomIDReq 获取线路信息

func (*GetLineListByRoomIDReq) Descriptor 

func (*GetLineListByRoomIDReq) Descriptor() ([]byte, []int)

func (*GetLineListByRoomIDReq) GetRoomId 

func (m *GetLineListByRoomIDReq) GetRoomId() int64

func (*GetLineListByRoomIDReq) Marshal 

func (m *GetLineListByRoomIDReq) Marshal() (dAtA []byte, err error)

func (*GetLineListByRoomIDReq) MarshalTo 

func (m *GetLineListByRoomIDReq) MarshalTo(dAtA []byte) (int, error)

func (*GetLineListByRoomIDReq) ProtoMessage 

func (*GetLineListByRoomIDReq) ProtoMessage()

func (*GetLineListByRoomIDReq) Reset 

func (m *GetLineListByRoomIDReq) Reset()

func (*GetLineListByRoomIDReq) Size 

func (m *GetLineListByRoomIDReq) Size() (n int)

func (*GetLineListByRoomIDReq) String 

func (m *GetLineListByRoomIDReq) String() string

func (*GetLineListByRoomIDReq) Unmarshal 

func (m *GetLineListByRoomIDReq) Unmarshal(dAtA []byte) error

func (*GetLineListByRoomIDReq) XXX_DiscardUnknown 

func (m *GetLineListByRoomIDReq) XXX_DiscardUnknown()

func (*GetLineListByRoomIDReq) XXX_Marshal 

func (m *GetLineListByRoomIDReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetLineListByRoomIDReq) XXX_Merge 

func (dst *GetLineListByRoomIDReq) XXX_Merge(src proto.Message)

func (*GetLineListByRoomIDReq) XXX_Size 

func (m *GetLineListByRoomIDReq) XXX_Size() int

func (*GetLineListByRoomIDReq) XXX_Unmarshal 

func (m *GetLineListByRoomIDReq) XXX_Unmarshal(b []byte) error

type GetMultiScreenShotReply 

type GetMultiScreenShotReply struct {
	// 房间号map截图地址
	List                 map[int64]string `` /* 143-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

GetMultiScreenShotReply 获取批量截图

func (*GetMultiScreenShotReply) Descriptor 

func (*GetMultiScreenShotReply) Descriptor() ([]byte, []int)

func (*GetMultiScreenShotReply) GetList 

func (m *GetMultiScreenShotReply) GetList() map[int64]string

func (*GetMultiScreenShotReply) Marshal 

func (m *GetMultiScreenShotReply) Marshal() (dAtA []byte, err error)

func (*GetMultiScreenShotReply) MarshalTo 

func (m *GetMultiScreenShotReply) MarshalTo(dAtA []byte) (int, error)

func (*GetMultiScreenShotReply) ProtoMessage 

func (*GetMultiScreenShotReply) ProtoMessage()

func (*GetMultiScreenShotReply) Reset 

func (m *GetMultiScreenShotReply) Reset()

func (*GetMultiScreenShotReply) Size 

func (m *GetMultiScreenShotReply) Size() (n int)

func (*GetMultiScreenShotReply) String 

func (m *GetMultiScreenShotReply) String() string

func (*GetMultiScreenShotReply) Unmarshal 

func (m *GetMultiScreenShotReply) Unmarshal(dAtA []byte) error

func (*GetMultiScreenShotReply) XXX_DiscardUnknown 

func (m *GetMultiScreenShotReply) XXX_DiscardUnknown()

func (*GetMultiScreenShotReply) XXX_Marshal 

func (m *GetMultiScreenShotReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetMultiScreenShotReply) XXX_Merge 

func (dst *GetMultiScreenShotReply) XXX_Merge(src proto.Message)

func (*GetMultiScreenShotReply) XXX_Size 

func (m *GetMultiScreenShotReply) XXX_Size() int

func (*GetMultiScreenShotReply) XXX_Unmarshal 

func (m *GetMultiScreenShotReply) XXX_Unmarshal(b []byte) error

type GetMultiScreenShotReq 

type GetMultiScreenShotReq struct {
	// 房间号
	RoomIds string `protobuf:"bytes,1,opt,name=room_ids,json=roomIds,proto3" json:"room_ids,omitempty"`
	// 时间戳
	Ts int64 `protobuf:"varint,2,opt,name=ts,proto3" json:"ts,omitempty"`
	// channel 是否为鉴黄
	Channel              string   `protobuf:"bytes,3,opt,name=channel,proto3" json:"channel,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetMultiScreenShotReq 获取批量截图

func (*GetMultiScreenShotReq) Descriptor 

func (*GetMultiScreenShotReq) Descriptor() ([]byte, []int)

func (*GetMultiScreenShotReq) GetChannel 

func (m *GetMultiScreenShotReq) GetChannel() string

func (*GetMultiScreenShotReq) GetRoomIds 

func (m *GetMultiScreenShotReq) GetRoomIds() string

func (*GetMultiScreenShotReq) GetTs 

func (m *GetMultiScreenShotReq) GetTs() int64

func (*GetMultiScreenShotReq) Marshal 

func (m *GetMultiScreenShotReq) Marshal() (dAtA []byte, err error)

func (*GetMultiScreenShotReq) MarshalTo 

func (m *GetMultiScreenShotReq) MarshalTo(dAtA []byte) (int, error)

func (*GetMultiScreenShotReq) ProtoMessage 

func (*GetMultiScreenShotReq) ProtoMessage()

func (*GetMultiScreenShotReq) Reset 

func (m *GetMultiScreenShotReq) Reset()

func (*GetMultiScreenShotReq) Size 

func (m *GetMultiScreenShotReq) Size() (n int)

func (*GetMultiScreenShotReq) String 

func (m *GetMultiScreenShotReq) String() string

func (*GetMultiScreenShotReq) Unmarshal 

func (m *GetMultiScreenShotReq) Unmarshal(dAtA []byte) error

func (*GetMultiScreenShotReq) XXX_DiscardUnknown 

func (m *GetMultiScreenShotReq) XXX_DiscardUnknown()

func (*GetMultiScreenShotReq) XXX_Marshal 

func (m *GetMultiScreenShotReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetMultiScreenShotReq) XXX_Merge 

func (dst *GetMultiScreenShotReq) XXX_Merge(src proto.Message)

func (*GetMultiScreenShotReq) XXX_Size 

func (m *GetMultiScreenShotReq) XXX_Size() int

func (*GetMultiScreenShotReq) XXX_Unmarshal 

func (m *GetMultiScreenShotReq) XXX_Unmarshal(b []byte) error

type GetMultiStreamInfoReply 

type GetMultiStreamInfoReply struct {
	// code
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	// message
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// 房间号map流详细信息
	Data                 map[uint32]*StreamFullInfo `` /* 136-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

GetMultiStreamInfoReply 批量获取房间信息

func (*GetMultiStreamInfoReply) Descriptor 

func (*GetMultiStreamInfoReply) Descriptor() ([]byte, []int)

func (*GetMultiStreamInfoReply) GetCode 

func (m *GetMultiStreamInfoReply) GetCode() int32

func (*GetMultiStreamInfoReply) GetData 

func (m *GetMultiStreamInfoReply) GetData() map[uint32]*StreamFullInfo

func (*GetMultiStreamInfoReply) GetMessage 

func (m *GetMultiStreamInfoReply) GetMessage() string

func (*GetMultiStreamInfoReply) Marshal 

func (m *GetMultiStreamInfoReply) Marshal() (dAtA []byte, err error)

func (*GetMultiStreamInfoReply) MarshalTo 

func (m *GetMultiStreamInfoReply) MarshalTo(dAtA []byte) (int, error)

func (*GetMultiStreamInfoReply) ProtoMessage 

func (*GetMultiStreamInfoReply) ProtoMessage()

func (*GetMultiStreamInfoReply) Reset 

func (m *GetMultiStreamInfoReply) Reset()

func (*GetMultiStreamInfoReply) Size 

func (m *GetMultiStreamInfoReply) Size() (n int)

func (*GetMultiStreamInfoReply) String 

func (m *GetMultiStreamInfoReply) String() string

func (*GetMultiStreamInfoReply) Unmarshal 

func (m *GetMultiStreamInfoReply) Unmarshal(dAtA []byte) error

func (*GetMultiStreamInfoReply) XXX_DiscardUnknown 

func (m *GetMultiStreamInfoReply) XXX_DiscardUnknown()

func (*GetMultiStreamInfoReply) XXX_Marshal 

func (m *GetMultiStreamInfoReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetMultiStreamInfoReply) XXX_Merge 

func (dst *GetMultiStreamInfoReply) XXX_Merge(src proto.Message)

func (*GetMultiStreamInfoReply) XXX_Size 

func (m *GetMultiStreamInfoReply) XXX_Size() int

func (*GetMultiStreamInfoReply) XXX_Unmarshal 

func (m *GetMultiStreamInfoReply) XXX_Unmarshal(b []byte) error

type GetMultiStreamInfoReq 

type GetMultiStreamInfoReq struct {
	// 房间号
	RoomIds              []uint32 `protobuf:"varint,1,rep,packed,name=room_ids,json=roomIds" json:"room_ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetMultiStreamInfoReq 批量获取房间信息

func (*GetMultiStreamInfoReq) Descriptor 

func (*GetMultiStreamInfoReq) Descriptor() ([]byte, []int)

func (*GetMultiStreamInfoReq) GetRoomIds 

func (m *GetMultiStreamInfoReq) GetRoomIds() []uint32

func (*GetMultiStreamInfoReq) Marshal 

func (m *GetMultiStreamInfoReq) Marshal() (dAtA []byte, err error)

func (*GetMultiStreamInfoReq) MarshalTo 

func (m *GetMultiStreamInfoReq) MarshalTo(dAtA []byte) (int, error)

func (*GetMultiStreamInfoReq) ProtoMessage 

func (*GetMultiStreamInfoReq) ProtoMessage()

func (*GetMultiStreamInfoReq) Reset 

func (m *GetMultiStreamInfoReq) Reset()

func (*GetMultiStreamInfoReq) Size 

func (m *GetMultiStreamInfoReq) Size() (n int)

func (*GetMultiStreamInfoReq) String 

func (m *GetMultiStreamInfoReq) String() string

func (*GetMultiStreamInfoReq) Unmarshal 

func (m *GetMultiStreamInfoReq) Unmarshal(dAtA []byte) error

func (*GetMultiStreamInfoReq) XXX_DiscardUnknown 

func (m *GetMultiStreamInfoReq) XXX_DiscardUnknown()

func (*GetMultiStreamInfoReq) XXX_Marshal 

func (m *GetMultiStreamInfoReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetMultiStreamInfoReq) XXX_Merge 

func (dst *GetMultiStreamInfoReq) XXX_Merge(src proto.Message)

func (*GetMultiStreamInfoReq) XXX_Size 

func (m *GetMultiStreamInfoReq) XXX_Size() int

func (*GetMultiStreamInfoReq) XXX_Unmarshal 

func (m *GetMultiStreamInfoReq) XXX_Unmarshal(b []byte) error

type GetOriginScreenShotPicReply 

type GetOriginScreenShotPicReply struct {
	// 房间号map截图地址
	List                 map[int64]string `` /* 143-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

GetOriginScreenShotPicReply 获取原图

func (*GetOriginScreenShotPicReply) Descriptor 

func (*GetOriginScreenShotPicReply) Descriptor() ([]byte, []int)

func (*GetOriginScreenShotPicReply) GetList 

func (m *GetOriginScreenShotPicReply) GetList() map[int64]string

func (*GetOriginScreenShotPicReply) Marshal 

func (m *GetOriginScreenShotPicReply) Marshal() (dAtA []byte, err error)

func (*GetOriginScreenShotPicReply) MarshalTo 

func (m *GetOriginScreenShotPicReply) MarshalTo(dAtA []byte) (int, error)

func (*GetOriginScreenShotPicReply) ProtoMessage 

func (*GetOriginScreenShotPicReply) ProtoMessage()

func (*GetOriginScreenShotPicReply) Reset 

func (m *GetOriginScreenShotPicReply) Reset()

func (*GetOriginScreenShotPicReply) Size 

func (m *GetOriginScreenShotPicReply) Size() (n int)

func (*GetOriginScreenShotPicReply) String 

func (m *GetOriginScreenShotPicReply) String() string

func (*GetOriginScreenShotPicReply) Unmarshal 

func (m *GetOriginScreenShotPicReply) Unmarshal(dAtA []byte) error

func (*GetOriginScreenShotPicReply) XXX_DiscardUnknown 

func (m *GetOriginScreenShotPicReply) XXX_DiscardUnknown()

func (*GetOriginScreenShotPicReply) XXX_Marshal 

func (m *GetOriginScreenShotPicReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetOriginScreenShotPicReply) XXX_Merge 

func (dst *GetOriginScreenShotPicReply) XXX_Merge(src proto.Message)

func (*GetOriginScreenShotPicReply) XXX_Size 

func (m *GetOriginScreenShotPicReply) XXX_Size() int

func (*GetOriginScreenShotPicReply) XXX_Unmarshal 

func (m *GetOriginScreenShotPicReply) XXX_Unmarshal(b []byte) error

type GetOriginScreenShotPicReq 

type GetOriginScreenShotPicReq struct {
	// 房间号
	RoomIds string `protobuf:"bytes,1,opt,name=room_ids,json=roomIds,proto3" json:"room_ids,omitempty"`
	// 时间戳
	Ts                   int64    `protobuf:"varint,2,opt,name=ts,proto3" json:"ts,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetOriginScreenShotPicReq 获取原图

func (*GetOriginScreenShotPicReq) Descriptor 

func (*GetOriginScreenShotPicReq) Descriptor() ([]byte, []int)

func (*GetOriginScreenShotPicReq) GetRoomIds 

func (m *GetOriginScreenShotPicReq) GetRoomIds() string

func (*GetOriginScreenShotPicReq) GetTs 

func (m *GetOriginScreenShotPicReq) GetTs() int64

func (*GetOriginScreenShotPicReq) Marshal 

func (m *GetOriginScreenShotPicReq) Marshal() (dAtA []byte, err error)

func (*GetOriginScreenShotPicReq) MarshalTo 

func (m *GetOriginScreenShotPicReq) MarshalTo(dAtA []byte) (int, error)

func (*GetOriginScreenShotPicReq) ProtoMessage 

func (*GetOriginScreenShotPicReq) ProtoMessage()

func (*GetOriginScreenShotPicReq) Reset 

func (m *GetOriginScreenShotPicReq) Reset()

func (*GetOriginScreenShotPicReq) Size 

func (m *GetOriginScreenShotPicReq) Size() (n int)

func (*GetOriginScreenShotPicReq) String 

func (m *GetOriginScreenShotPicReq) String() string

func (*GetOriginScreenShotPicReq) Unmarshal 

func (m *GetOriginScreenShotPicReq) Unmarshal(dAtA []byte) error

func (*GetOriginScreenShotPicReq) XXX_DiscardUnknown 

func (m *GetOriginScreenShotPicReq) XXX_DiscardUnknown()

func (*GetOriginScreenShotPicReq) XXX_Marshal 

func (m *GetOriginScreenShotPicReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetOriginScreenShotPicReq) XXX_Merge 

func (dst *GetOriginScreenShotPicReq) XXX_Merge(src proto.Message)

func (*GetOriginScreenShotPicReq) XXX_Size 

func (m *GetOriginScreenShotPicReq) XXX_Size() int

func (*GetOriginScreenShotPicReq) XXX_Unmarshal 

func (m *GetOriginScreenShotPicReq) XXX_Unmarshal(b []byte) error

type GetRoomIDByStreamNameReply 

type GetRoomIDByStreamNameReply struct {
	// 房间号
	RoomId               int64    `protobuf:"varint,1,opt,name=room_id,json=roomId,proto3" json:"room_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetRoomIDByStreamNameReply 获取房间号

func (*GetRoomIDByStreamNameReply) Descriptor 

func (*GetRoomIDByStreamNameReply) Descriptor() ([]byte, []int)

func (*GetRoomIDByStreamNameReply) GetRoomId 

func (m *GetRoomIDByStreamNameReply) GetRoomId() int64

func (*GetRoomIDByStreamNameReply) Marshal 

func (m *GetRoomIDByStreamNameReply) Marshal() (dAtA []byte, err error)

func (*GetRoomIDByStreamNameReply) MarshalTo 

func (m *GetRoomIDByStreamNameReply) MarshalTo(dAtA []byte) (int, error)

func (*GetRoomIDByStreamNameReply) ProtoMessage 

func (*GetRoomIDByStreamNameReply) ProtoMessage()

func (*GetRoomIDByStreamNameReply) Reset 

func (m *GetRoomIDByStreamNameReply) Reset()

func (*GetRoomIDByStreamNameReply) Size 

func (m *GetRoomIDByStreamNameReply) Size() (n int)

func (*GetRoomIDByStreamNameReply) String 

func (m *GetRoomIDByStreamNameReply) String() string

func (*GetRoomIDByStreamNameReply) Unmarshal 

func (m *GetRoomIDByStreamNameReply) Unmarshal(dAtA []byte) error

func (*GetRoomIDByStreamNameReply) XXX_DiscardUnknown 

func (m *GetRoomIDByStreamNameReply) XXX_DiscardUnknown()

func (*GetRoomIDByStreamNameReply) XXX_Marshal 

func (m *GetRoomIDByStreamNameReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetRoomIDByStreamNameReply) XXX_Merge 

func (dst *GetRoomIDByStreamNameReply) XXX_Merge(src proto.Message)

func (*GetRoomIDByStreamNameReply) XXX_Size 

func (m *GetRoomIDByStreamNameReply) XXX_Size() int

func (*GetRoomIDByStreamNameReply) XXX_Unmarshal 

func (m *GetRoomIDByStreamNameReply) XXX_Unmarshal(b []byte) error

type GetRoomIDByStreamNameReq 

type GetRoomIDByStreamNameReq struct {
	// 流名
	StreamName           string   `protobuf:"bytes,1,opt,name=stream_name,json=streamName,proto3" json:"stream_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetRoomIDByStreamNameReq 获取房间号

func (*GetRoomIDByStreamNameReq) Descriptor 

func (*GetRoomIDByStreamNameReq) Descriptor() ([]byte, []int)

func (*GetRoomIDByStreamNameReq) GetStreamName 

func (m *GetRoomIDByStreamNameReq) GetStreamName() string

func (*GetRoomIDByStreamNameReq) Marshal 

func (m *GetRoomIDByStreamNameReq) Marshal() (dAtA []byte, err error)

func (*GetRoomIDByStreamNameReq) MarshalTo 

func (m *GetRoomIDByStreamNameReq) MarshalTo(dAtA []byte) (int, error)

func (*GetRoomIDByStreamNameReq) ProtoMessage 

func (*GetRoomIDByStreamNameReq) ProtoMessage()

func (*GetRoomIDByStreamNameReq) Reset 

func (m *GetRoomIDByStreamNameReq) Reset()

func (*GetRoomIDByStreamNameReq) Size 

func (m *GetRoomIDByStreamNameReq) Size() (n int)

func (*GetRoomIDByStreamNameReq) String 

func (m *GetRoomIDByStreamNameReq) String() string

func (*GetRoomIDByStreamNameReq) Unmarshal 

func (m *GetRoomIDByStreamNameReq) Unmarshal(dAtA []byte) error

func (*GetRoomIDByStreamNameReq) XXX_DiscardUnknown 

func (m *GetRoomIDByStreamNameReq) XXX_DiscardUnknown()

func (*GetRoomIDByStreamNameReq) XXX_Marshal 

func (m *GetRoomIDByStreamNameReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetRoomIDByStreamNameReq) XXX_Merge 

func (dst *GetRoomIDByStreamNameReq) XXX_Merge(src proto.Message)

func (*GetRoomIDByStreamNameReq) XXX_Size 

func (m *GetRoomIDByStreamNameReq) XXX_Size() int

func (*GetRoomIDByStreamNameReq) XXX_Unmarshal 

func (m *GetRoomIDByStreamNameReq) XXX_Unmarshal(b []byte) error

type GetSingleScreeShotReply 

type GetSingleScreeShotReply struct {
	// 截图列表
	List                 []string `protobuf:"bytes,1,rep,name=list" json:"list,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetSingleScreeShotReply 获取单个截图

func (*GetSingleScreeShotReply) Descriptor 

func (*GetSingleScreeShotReply) Descriptor() ([]byte, []int)

func (*GetSingleScreeShotReply) GetList 

func (m *GetSingleScreeShotReply) GetList() []string

func (*GetSingleScreeShotReply) Marshal 

func (m *GetSingleScreeShotReply) Marshal() (dAtA []byte, err error)

func (*GetSingleScreeShotReply) MarshalTo 

func (m *GetSingleScreeShotReply) MarshalTo(dAtA []byte) (int, error)

func (*GetSingleScreeShotReply) ProtoMessage 

func (*GetSingleScreeShotReply) ProtoMessage()

func (*GetSingleScreeShotReply) Reset 

func (m *GetSingleScreeShotReply) Reset()

func (*GetSingleScreeShotReply) Size 

func (m *GetSingleScreeShotReply) Size() (n int)

func (*GetSingleScreeShotReply) String 

func (m *GetSingleScreeShotReply) String() string

func (*GetSingleScreeShotReply) Unmarshal 

func (m *GetSingleScreeShotReply) Unmarshal(dAtA []byte) error

func (*GetSingleScreeShotReply) XXX_DiscardUnknown 

func (m *GetSingleScreeShotReply) XXX_DiscardUnknown()

func (*GetSingleScreeShotReply) XXX_Marshal 

func (m *GetSingleScreeShotReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetSingleScreeShotReply) XXX_Merge 

func (dst *GetSingleScreeShotReply) XXX_Merge(src proto.Message)

func (*GetSingleScreeShotReply) XXX_Size 

func (m *GetSingleScreeShotReply) XXX_Size() int

func (*GetSingleScreeShotReply) XXX_Unmarshal 

func (m *GetSingleScreeShotReply) XXX_Unmarshal(b []byte) error

type GetSingleScreeShotReq 

type GetSingleScreeShotReq struct {
	// 房间号
	RoomId int64 `protobuf:"varint,1,opt,name=room_id,json=roomId,proto3" json:"room_id,omitempty"`
	// 开始时间
	StartTime string `protobuf:"bytes,2,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// 结束时间
	EndTime string `protobuf:"bytes,3,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// channel
	Channel              string   `protobuf:"bytes,4,opt,name=channel,proto3" json:"channel,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetSingleScreeShotReq 获取单个截图

func (*GetSingleScreeShotReq) Descriptor 

func (*GetSingleScreeShotReq) Descriptor() ([]byte, []int)

func (*GetSingleScreeShotReq) GetChannel 

func (m *GetSingleScreeShotReq) GetChannel() string

func (*GetSingleScreeShotReq) GetEndTime 

func (m *GetSingleScreeShotReq) GetEndTime() string

func (*GetSingleScreeShotReq) GetRoomId 

func (m *GetSingleScreeShotReq) GetRoomId() int64

func (*GetSingleScreeShotReq) GetStartTime 

func (m *GetSingleScreeShotReq) GetStartTime() string

func (*GetSingleScreeShotReq) Marshal 

func (m *GetSingleScreeShotReq) Marshal() (dAtA []byte, err error)

func (*GetSingleScreeShotReq) MarshalTo 

func (m *GetSingleScreeShotReq) MarshalTo(dAtA []byte) (int, error)

func (*GetSingleScreeShotReq) ProtoMessage 

func (*GetSingleScreeShotReq) ProtoMessage()

func (*GetSingleScreeShotReq) Reset 

func (m *GetSingleScreeShotReq) Reset()

func (*GetSingleScreeShotReq) Size 

func (m *GetSingleScreeShotReq) Size() (n int)

func (*GetSingleScreeShotReq) String 

func (m *GetSingleScreeShotReq) String() string

func (*GetSingleScreeShotReq) Unmarshal 

func (m *GetSingleScreeShotReq) Unmarshal(dAtA []byte) error

func (*GetSingleScreeShotReq) XXX_DiscardUnknown 

func (m *GetSingleScreeShotReq) XXX_DiscardUnknown()

func (*GetSingleScreeShotReq) XXX_Marshal 

func (m *GetSingleScreeShotReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetSingleScreeShotReq) XXX_Merge 

func (dst *GetSingleScreeShotReq) XXX_Merge(src proto.Message)

func (*GetSingleScreeShotReq) XXX_Size 

func (m *GetSingleScreeShotReq) XXX_Size() int

func (*GetSingleScreeShotReq) XXX_Unmarshal 

func (m *GetSingleScreeShotReq) XXX_Unmarshal(b []byte) error

type GetSrcByRoomIDReply 

type GetSrcByRoomIDReply struct {
	// 上行列表
	List                 []*RoomSrcCheck `protobuf:"bytes,1,rep,name=list" json:"list,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

GetSrcByRoomIDReply 获取上行信息

func (*GetSrcByRoomIDReply) Descriptor 

func (*GetSrcByRoomIDReply) Descriptor() ([]byte, []int)

func (*GetSrcByRoomIDReply) GetList 

func (m *GetSrcByRoomIDReply) GetList() []*RoomSrcCheck

func (*GetSrcByRoomIDReply) Marshal 

func (m *GetSrcByRoomIDReply) Marshal() (dAtA []byte, err error)

func (*GetSrcByRoomIDReply) MarshalTo 

func (m *GetSrcByRoomIDReply) MarshalTo(dAtA []byte) (int, error)

func (*GetSrcByRoomIDReply) ProtoMessage 

func (*GetSrcByRoomIDReply) ProtoMessage()

func (*GetSrcByRoomIDReply) Reset 

func (m *GetSrcByRoomIDReply) Reset()

func (*GetSrcByRoomIDReply) Size 

func (m *GetSrcByRoomIDReply) Size() (n int)

func (*GetSrcByRoomIDReply) String 

func (m *GetSrcByRoomIDReply) String() string

func (*GetSrcByRoomIDReply) Unmarshal 

func (m *GetSrcByRoomIDReply) Unmarshal(dAtA []byte) error

func (*GetSrcByRoomIDReply) XXX_DiscardUnknown 

func (m *GetSrcByRoomIDReply) XXX_DiscardUnknown()

func (*GetSrcByRoomIDReply) XXX_Marshal 

func (m *GetSrcByRoomIDReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetSrcByRoomIDReply) XXX_Merge 

func (dst *GetSrcByRoomIDReply) XXX_Merge(src proto.Message)

func (*GetSrcByRoomIDReply) XXX_Size 

func (m *GetSrcByRoomIDReply) XXX_Size() int

func (*GetSrcByRoomIDReply) XXX_Unmarshal 

func (m *GetSrcByRoomIDReply) XXX_Unmarshal(b []byte) error

type GetSrcByRoomIDReq 

type GetSrcByRoomIDReq struct {
	// 房间号
	RoomId               int64    `protobuf:"varint,1,opt,name=room_id,json=roomId,proto3" json:"room_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetSrcByRoomIDReq 获取上行信息

func (*GetSrcByRoomIDReq) Descriptor 

func (*GetSrcByRoomIDReq) Descriptor() ([]byte, []int)

func (*GetSrcByRoomIDReq) GetRoomId 

func (m *GetSrcByRoomIDReq) GetRoomId() int64

func (*GetSrcByRoomIDReq) Marshal 

func (m *GetSrcByRoomIDReq) Marshal() (dAtA []byte, err error)

func (*GetSrcByRoomIDReq) MarshalTo 

func (m *GetSrcByRoomIDReq) MarshalTo(dAtA []byte) (int, error)

func (*GetSrcByRoomIDReq) ProtoMessage 

func (*GetSrcByRoomIDReq) ProtoMessage()

func (*GetSrcByRoomIDReq) Reset 

func (m *GetSrcByRoomIDReq) Reset()

func (*GetSrcByRoomIDReq) Size 

func (m *GetSrcByRoomIDReq) Size() (n int)

func (*GetSrcByRoomIDReq) String 

func (m *GetSrcByRoomIDReq) String() string

func (*GetSrcByRoomIDReq) Unmarshal 

func (m *GetSrcByRoomIDReq) Unmarshal(dAtA []byte) error

func (*GetSrcByRoomIDReq) XXX_DiscardUnknown 

func (m *GetSrcByRoomIDReq) XXX_DiscardUnknown()

func (*GetSrcByRoomIDReq) XXX_Marshal 

func (m *GetSrcByRoomIDReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetSrcByRoomIDReq) XXX_Merge 

func (dst *GetSrcByRoomIDReq) XXX_Merge(src proto.Message)

func (*GetSrcByRoomIDReq) XXX_Size 

func (m *GetSrcByRoomIDReq) XXX_Size() int

func (*GetSrcByRoomIDReq) XXX_Unmarshal 

func (m *GetSrcByRoomIDReq) XXX_Unmarshal(b []byte) error

type GetStreamInfoReply 

type GetStreamInfoReply struct {
	// code
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	// message
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// 流详细信息
	Data                 *StreamFullInfo `protobuf:"bytes,3,opt,name=data" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

GetStreamInfoReply 获取单个流信息

func (*GetStreamInfoReply) Descriptor 

func (*GetStreamInfoReply) Descriptor() ([]byte, []int)

func (*GetStreamInfoReply) GetCode 

func (m *GetStreamInfoReply) GetCode() int32

func (*GetStreamInfoReply) GetData 

func (m *GetStreamInfoReply) GetData() *StreamFullInfo

func (*GetStreamInfoReply) GetMessage 

func (m *GetStreamInfoReply) GetMessage() string

func (*GetStreamInfoReply) Marshal 

func (m *GetStreamInfoReply) Marshal() (dAtA []byte, err error)

func (*GetStreamInfoReply) MarshalTo 

func (m *GetStreamInfoReply) MarshalTo(dAtA []byte) (int, error)

func (*GetStreamInfoReply) ProtoMessage 

func (*GetStreamInfoReply) ProtoMessage()

func (*GetStreamInfoReply) Reset 

func (m *GetStreamInfoReply) Reset()

func (*GetStreamInfoReply) Size 

func (m *GetStreamInfoReply) Size() (n int)

func (*GetStreamInfoReply) String 

func (m *GetStreamInfoReply) String() string

func (*GetStreamInfoReply) Unmarshal 

func (m *GetStreamInfoReply) Unmarshal(dAtA []byte) error

func (*GetStreamInfoReply) XXX_DiscardUnknown 

func (m *GetStreamInfoReply) XXX_DiscardUnknown()

func (*GetStreamInfoReply) XXX_Marshal 

func (m *GetStreamInfoReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetStreamInfoReply) XXX_Merge 

func (dst *GetStreamInfoReply) XXX_Merge(src proto.Message)

func (*GetStreamInfoReply) XXX_Size 

func (m *GetStreamInfoReply) XXX_Size() int

func (*GetStreamInfoReply) XXX_Unmarshal 

func (m *GetStreamInfoReply) XXX_Unmarshal(b []byte) error

type GetStreamInfoReq 

type GetStreamInfoReq struct {
	// 房间号
	RoomId uint32 `protobuf:"varint,1,opt,name=room_id,json=roomId,proto3" json:"room_id,omitempty"`
	// 流名
	StreamName           string   `protobuf:"bytes,2,opt,name=stream_name,json=streamName,proto3" json:"stream_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetStreamInfoReq 获取单个流信息

func (*GetStreamInfoReq) Descriptor 

func (*GetStreamInfoReq) Descriptor() ([]byte, []int)

func (*GetStreamInfoReq) GetRoomId 

func (m *GetStreamInfoReq) GetRoomId() uint32

func (*GetStreamInfoReq) GetStreamName 

func (m *GetStreamInfoReq) GetStreamName() string

func (*GetStreamInfoReq) Marshal 

func (m *GetStreamInfoReq) Marshal() (dAtA []byte, err error)

func (*GetStreamInfoReq) MarshalTo 

func (m *GetStreamInfoReq) MarshalTo(dAtA []byte) (int, error)

func (*GetStreamInfoReq) ProtoMessage 

func (*GetStreamInfoReq) ProtoMessage()

func (*GetStreamInfoReq) Reset 

func (m *GetStreamInfoReq) Reset()

func (*GetStreamInfoReq) Size 

func (m *GetStreamInfoReq) Size() (n int)

func (*GetStreamInfoReq) String 

func (m *GetStreamInfoReq) String() string

func (*GetStreamInfoReq) Unmarshal 

func (m *GetStreamInfoReq) Unmarshal(dAtA []byte) error

func (*GetStreamInfoReq) XXX_DiscardUnknown 

func (m *GetStreamInfoReq) XXX_DiscardUnknown()

func (*GetStreamInfoReq) XXX_Marshal 

func (m *GetStreamInfoReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetStreamInfoReq) XXX_Merge 

func (dst *GetStreamInfoReq) XXX_Merge(src proto.Message)

func (*GetStreamInfoReq) XXX_Size 

func (m *GetStreamInfoReq) XXX_Size() int

func (*GetStreamInfoReq) XXX_Unmarshal 

func (m *GetStreamInfoReq) XXX_Unmarshal(b []byte) error

type GetStreamLastTimeReply 

type GetStreamLastTimeReply struct {
	// 最后推流时间， -1 正在推流
	LastTime             int64    `protobuf:"varint,1,opt,name=last_time,json=lastTime,proto3" json:"last_time,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetStreamLastTimeReply 获取最后推流时间

func (*GetStreamLastTimeReply) Descriptor 

func (*GetStreamLastTimeReply) Descriptor() ([]byte, []int)

func (*GetStreamLastTimeReply) GetLastTime 

func (m *GetStreamLastTimeReply) GetLastTime() int64

func (*GetStreamLastTimeReply) Marshal 

func (m *GetStreamLastTimeReply) Marshal() (dAtA []byte, err error)

func (*GetStreamLastTimeReply) MarshalTo 

func (m *GetStreamLastTimeReply) MarshalTo(dAtA []byte) (int, error)

func (*GetStreamLastTimeReply) ProtoMessage 

func (*GetStreamLastTimeReply) ProtoMessage()

func (*GetStreamLastTimeReply) Reset 

func (m *GetStreamLastTimeReply) Reset()

func (*GetStreamLastTimeReply) Size 

func (m *GetStreamLastTimeReply) Size() (n int)

func (*GetStreamLastTimeReply) String 

func (m *GetStreamLastTimeReply) String() string

func (*GetStreamLastTimeReply) Unmarshal 

func (m *GetStreamLastTimeReply) Unmarshal(dAtA []byte) error

func (*GetStreamLastTimeReply) XXX_DiscardUnknown 

func (m *GetStreamLastTimeReply) XXX_DiscardUnknown()

func (*GetStreamLastTimeReply) XXX_Marshal 

func (m *GetStreamLastTimeReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetStreamLastTimeReply) XXX_Merge 

func (dst *GetStreamLastTimeReply) XXX_Merge(src proto.Message)

func (*GetStreamLastTimeReply) XXX_Size 

func (m *GetStreamLastTimeReply) XXX_Size() int

func (*GetStreamLastTimeReply) XXX_Unmarshal 

func (m *GetStreamLastTimeReply) XXX_Unmarshal(b []byte) error

type GetStreamLastTimeReq 

type GetStreamLastTimeReq struct {
	// 房间号
	RoomId               int64    `protobuf:"varint,1,opt,name=room_id,json=roomId,proto3" json:"room_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetStreamLastTimeReq 获取最后推流时间

func (*GetStreamLastTimeReq) Descriptor 

func (*GetStreamLastTimeReq) Descriptor() ([]byte, []int)

func (*GetStreamLastTimeReq) GetRoomId 

func (m *GetStreamLastTimeReq) GetRoomId() int64

func (*GetStreamLastTimeReq) Marshal 

func (m *GetStreamLastTimeReq) Marshal() (dAtA []byte, err error)

func (*GetStreamLastTimeReq) MarshalTo 

func (m *GetStreamLastTimeReq) MarshalTo(dAtA []byte) (int, error)

func (*GetStreamLastTimeReq) ProtoMessage 

func (*GetStreamLastTimeReq) ProtoMessage()

func (*GetStreamLastTimeReq) Reset 

func (m *GetStreamLastTimeReq) Reset()

func (*GetStreamLastTimeReq) Size 

func (m *GetStreamLastTimeReq) Size() (n int)

func (*GetStreamLastTimeReq) String 

func (m *GetStreamLastTimeReq) String() string

func (*GetStreamLastTimeReq) Unmarshal 

func (m *GetStreamLastTimeReq) Unmarshal(dAtA []byte) error

func (*GetStreamLastTimeReq) XXX_DiscardUnknown 

func (m *GetStreamLastTimeReq) XXX_DiscardUnknown()

func (*GetStreamLastTimeReq) XXX_Marshal 

func (m *GetStreamLastTimeReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetStreamLastTimeReq) XXX_Merge 

func (dst *GetStreamLastTimeReq) XXX_Merge(src proto.Message)

func (*GetStreamLastTimeReq) XXX_Size 

func (m *GetStreamLastTimeReq) XXX_Size() int

func (*GetStreamLastTimeReq) XXX_Unmarshal 

func (m *GetStreamLastTimeReq) XXX_Unmarshal(b []byte) error

type GetStreamNameByRoomIDReply 

type GetStreamNameByRoomIDReply struct {
	// 流名
	StreamName           string   `protobuf:"bytes,1,opt,name=stream_name,json=streamName,proto3" json:"stream_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetStreamNameByRoomIDReply 获取流名

func (*GetStreamNameByRoomIDReply) Descriptor 

func (*GetStreamNameByRoomIDReply) Descriptor() ([]byte, []int)

func (*GetStreamNameByRoomIDReply) GetStreamName 

func (m *GetStreamNameByRoomIDReply) GetStreamName() string

func (*GetStreamNameByRoomIDReply) Marshal 

func (m *GetStreamNameByRoomIDReply) Marshal() (dAtA []byte, err error)

func (*GetStreamNameByRoomIDReply) MarshalTo 

func (m *GetStreamNameByRoomIDReply) MarshalTo(dAtA []byte) (int, error)

func (*GetStreamNameByRoomIDReply) ProtoMessage 

func (*GetStreamNameByRoomIDReply) ProtoMessage()

func (*GetStreamNameByRoomIDReply) Reset 

func (m *GetStreamNameByRoomIDReply) Reset()

func (*GetStreamNameByRoomIDReply) Size 

func (m *GetStreamNameByRoomIDReply) Size() (n int)

func (*GetStreamNameByRoomIDReply) String 

func (m *GetStreamNameByRoomIDReply) String() string

func (*GetStreamNameByRoomIDReply) Unmarshal 

func (m *GetStreamNameByRoomIDReply) Unmarshal(dAtA []byte) error

func (*GetStreamNameByRoomIDReply) XXX_DiscardUnknown 

func (m *GetStreamNameByRoomIDReply) XXX_DiscardUnknown()

func (*GetStreamNameByRoomIDReply) XXX_Marshal 

func (m *GetStreamNameByRoomIDReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetStreamNameByRoomIDReply) XXX_Merge 

func (dst *GetStreamNameByRoomIDReply) XXX_Merge(src proto.Message)

func (*GetStreamNameByRoomIDReply) XXX_Size 

func (m *GetStreamNameByRoomIDReply) XXX_Size() int

func (*GetStreamNameByRoomIDReply) XXX_Unmarshal 

func (m *GetStreamNameByRoomIDReply) XXX_Unmarshal(b []byte) error

type GetStreamNameByRoomIDReq 

type GetStreamNameByRoomIDReq struct {
	// 房间号
	RoomId               int64    `protobuf:"varint,1,opt,name=room_id,json=roomId,proto3" json:"room_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetStreamNameByRoomIDReq 获取流名

func (*GetStreamNameByRoomIDReq) Descriptor 

func (*GetStreamNameByRoomIDReq) Descriptor() ([]byte, []int)

func (*GetStreamNameByRoomIDReq) GetRoomId 

func (m *GetStreamNameByRoomIDReq) GetRoomId() int64

func (*GetStreamNameByRoomIDReq) Marshal 

func (m *GetStreamNameByRoomIDReq) Marshal() (dAtA []byte, err error)

func (*GetStreamNameByRoomIDReq) MarshalTo 

func (m *GetStreamNameByRoomIDReq) MarshalTo(dAtA []byte) (int, error)

func (*GetStreamNameByRoomIDReq) ProtoMessage 

func (*GetStreamNameByRoomIDReq) ProtoMessage()

func (*GetStreamNameByRoomIDReq) Reset 

func (m *GetStreamNameByRoomIDReq) Reset()

func (*GetStreamNameByRoomIDReq) Size 

func (m *GetStreamNameByRoomIDReq) Size() (n int)

func (*GetStreamNameByRoomIDReq) String 

func (m *GetStreamNameByRoomIDReq) String() string

func (*GetStreamNameByRoomIDReq) Unmarshal 

func (m *GetStreamNameByRoomIDReq) Unmarshal(dAtA []byte) error

func (*GetStreamNameByRoomIDReq) XXX_DiscardUnknown 

func (m *GetStreamNameByRoomIDReq) XXX_DiscardUnknown()

func (*GetStreamNameByRoomIDReq) XXX_Marshal 

func (m *GetStreamNameByRoomIDReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetStreamNameByRoomIDReq) XXX_Merge 

func (dst *GetStreamNameByRoomIDReq) XXX_Merge(src proto.Message)

func (*GetStreamNameByRoomIDReq) XXX_Size 

func (m *GetStreamNameByRoomIDReq) XXX_Size() int

func (*GetStreamNameByRoomIDReq) XXX_Unmarshal 

func (m *GetStreamNameByRoomIDReq) XXX_Unmarshal(b []byte) error

type GetUpStreamRtmpReply 

type GetUpStreamRtmpReply struct {
	// 上行推流地址
	Up                   *UpStreamRtmp `protobuf:"bytes,1,opt,name=up" json:"up,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

GetUpStreamRtmpReply 获取上行推流地址

func (*GetUpStreamRtmpReply) Descriptor 

func (*GetUpStreamRtmpReply) Descriptor() ([]byte, []int)

func (*GetUpStreamRtmpReply) GetUp 

func (m *GetUpStreamRtmpReply) GetUp() *UpStreamRtmp

func (*GetUpStreamRtmpReply) Marshal 

func (m *GetUpStreamRtmpReply) Marshal() (dAtA []byte, err error)

func (*GetUpStreamRtmpReply) MarshalTo 

func (m *GetUpStreamRtmpReply) MarshalTo(dAtA []byte) (int, error)

func (*GetUpStreamRtmpReply) ProtoMessage 

func (*GetUpStreamRtmpReply) ProtoMessage()

func (*GetUpStreamRtmpReply) Reset 

func (m *GetUpStreamRtmpReply) Reset()

func (*GetUpStreamRtmpReply) Size 

func (m *GetUpStreamRtmpReply) Size() (n int)

func (*GetUpStreamRtmpReply) String 

func (m *GetUpStreamRtmpReply) String() string

func (*GetUpStreamRtmpReply) Unmarshal 

func (m *GetUpStreamRtmpReply) Unmarshal(dAtA []byte) error

func (*GetUpStreamRtmpReply) XXX_DiscardUnknown 

func (m *GetUpStreamRtmpReply) XXX_DiscardUnknown()

func (*GetUpStreamRtmpReply) XXX_Marshal 

func (m *GetUpStreamRtmpReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetUpStreamRtmpReply) XXX_Merge 

func (dst *GetUpStreamRtmpReply) XXX_Merge(src proto.Message)

func (*GetUpStreamRtmpReply) XXX_Size 

func (m *GetUpStreamRtmpReply) XXX_Size() int

func (*GetUpStreamRtmpReply) XXX_Unmarshal 

func (m *GetUpStreamRtmpReply) XXX_Unmarshal(b []byte) error

type GetUpStreamRtmpReq 

type GetUpStreamRtmpReq struct {
	// 房间号
	RoomId int64 `protobuf:"varint,1,opt,name=room_id,json=roomId,proto3" json:"room_id,omitempty"`
	// 免流
	FreeFlow string `protobuf:"bytes,2,opt,name=free_flow,json=freeFlow,proto3" json:"free_flow,omitempty"`
	// ip
	Ip string `protobuf:"bytes,3,opt,name=ip,proto3" json:"ip,omitempty"`
	// 所在区域
	AreaId int64 `protobuf:"varint,4,opt,name=area_id,json=areaId,proto3" json:"area_id,omitempty"`
	// 关注数
	Attentions int32 `protobuf:"varint,5,opt,name=attentions,proto3" json:"attentions,omitempty"`
	// uid
	Uid int64 `protobuf:"varint,6,opt,name=uid,proto3" json:"uid,omitempty"`
	// 平台
	Platform             string   `protobuf:"bytes,7,opt,name=platform,proto3" json:"platform,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetUpStreamRtmpReq 获取上行推流地址

func (*GetUpStreamRtmpReq) Descriptor 

func (*GetUpStreamRtmpReq) Descriptor() ([]byte, []int)

func (*GetUpStreamRtmpReq) GetAreaId 

func (m *GetUpStreamRtmpReq) GetAreaId() int64

func (*GetUpStreamRtmpReq) GetAttentions 

func (m *GetUpStreamRtmpReq) GetAttentions() int32

func (*GetUpStreamRtmpReq) GetFreeFlow 

func (m *GetUpStreamRtmpReq) GetFreeFlow() string

func (*GetUpStreamRtmpReq) GetIp 

func (m *GetUpStreamRtmpReq) GetIp() string

func (*GetUpStreamRtmpReq) GetPlatform 

func (m *GetUpStreamRtmpReq) GetPlatform() string

func (*GetUpStreamRtmpReq) GetRoomId 

func (m *GetUpStreamRtmpReq) GetRoomId() int64

func (*GetUpStreamRtmpReq) GetUid 

func (m *GetUpStreamRtmpReq) GetUid() int64

func (*GetUpStreamRtmpReq) Marshal 

func (m *GetUpStreamRtmpReq) Marshal() (dAtA []byte, err error)

func (*GetUpStreamRtmpReq) MarshalTo 

func (m *GetUpStreamRtmpReq) MarshalTo(dAtA []byte) (int, error)

func (*GetUpStreamRtmpReq) ProtoMessage 

func (*GetUpStreamRtmpReq) ProtoMessage()

func (*GetUpStreamRtmpReq) Reset 

func (m *GetUpStreamRtmpReq) Reset()

func (*GetUpStreamRtmpReq) Size 

func (m *GetUpStreamRtmpReq) Size() (n int)

func (*GetUpStreamRtmpReq) String 

func (m *GetUpStreamRtmpReq) String() string

func (*GetUpStreamRtmpReq) Unmarshal 

func (m *GetUpStreamRtmpReq) Unmarshal(dAtA []byte) error

func (*GetUpStreamRtmpReq) XXX_DiscardUnknown 

func (m *GetUpStreamRtmpReq) XXX_DiscardUnknown()

func (*GetUpStreamRtmpReq) XXX_Marshal 

func (m *GetUpStreamRtmpReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetUpStreamRtmpReq) XXX_Merge 

func (dst *GetUpStreamRtmpReq) XXX_Merge(src proto.Message)

func (*GetUpStreamRtmpReq) XXX_Size 

func (m *GetUpStreamRtmpReq) XXX_Size() int

func (*GetUpStreamRtmpReq) XXX_Unmarshal 

func (m *GetUpStreamRtmpReq) XXX_Unmarshal(b []byte) error

type LineList 

type LineList struct {
	// 上行
	Src int64 `protobuf:"varint,1,opt,name=src,proto3" json:"src,omitempty"`
	// 是否被使用
	Use bool `protobuf:"varint,2,opt,name=use,proto3" json:"use,omitempty"`
	// 描述
	Desc                 string   `protobuf:"bytes,3,opt,name=desc,proto3" json:"desc,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

LineList 线路信息

func (*LineList) Descriptor 

func (*LineList) Descriptor() ([]byte, []int)

func (*LineList) GetDesc 

func (m *LineList) GetDesc() string

func (*LineList) GetSrc 

func (m *LineList) GetSrc() int64

func (*LineList) GetUse 

func (m *LineList) GetUse() bool

func (*LineList) Marshal 

func (m *LineList) Marshal() (dAtA []byte, err error)

func (*LineList) MarshalTo 

func (m *LineList) MarshalTo(dAtA []byte) (int, error)

func (*LineList) ProtoMessage 

func (*LineList) ProtoMessage()

func (*LineList) Reset 

func (m *LineList) Reset()

func (*LineList) Size 

func (m *LineList) Size() (n int)

func (*LineList) String 

func (m *LineList) String() string

func (*LineList) Unmarshal 

func (m *LineList) Unmarshal(dAtA []byte) error

func (*LineList) XXX_DiscardUnknown 

func (m *LineList) XXX_DiscardUnknown()

func (*LineList) XXX_Marshal 

func (m *LineList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LineList) XXX_Merge 

func (dst *LineList) XXX_Merge(src proto.Message)

func (*LineList) XXX_Size 

func (m *LineList) XXX_Size() int

func (*LineList) XXX_Unmarshal 

func (m *LineList) XXX_Unmarshal(b []byte) error

type PingReply 

type PingReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

PingReply PingReply

func (*PingReply) Descriptor 

func (*PingReply) Descriptor() ([]byte, []int)

func (*PingReply) Marshal 

func (m *PingReply) Marshal() (dAtA []byte, err error)

func (*PingReply) MarshalTo 

func (m *PingReply) MarshalTo(dAtA []byte) (int, error)

func (*PingReply) ProtoMessage 

func (*PingReply) ProtoMessage()

func (*PingReply) Reset 

func (m *PingReply) Reset()

func (*PingReply) Size 

func (m *PingReply) Size() (n int)

func (*PingReply) String 

func (m *PingReply) String() string

func (*PingReply) Unmarshal 

func (m *PingReply) Unmarshal(dAtA []byte) error

func (*PingReply) XXX_DiscardUnknown 

func (m *PingReply) XXX_DiscardUnknown()

func (*PingReply) XXX_Marshal 

func (m *PingReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PingReply) XXX_Merge 

func (dst *PingReply) XXX_Merge(src proto.Message)

func (*PingReply) XXX_Size 

func (m *PingReply) XXX_Size() int

func (*PingReply) XXX_Unmarshal 

func (m *PingReply) XXX_Unmarshal(b []byte) error

type PingReq 

type PingReq struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

PingReq PingReq

func (*PingReq) Descriptor 

func (*PingReq) Descriptor() ([]byte, []int)

func (*PingReq) Marshal 

func (m *PingReq) Marshal() (dAtA []byte, err error)

func (*PingReq) MarshalTo 

func (m *PingReq) MarshalTo(dAtA []byte) (int, error)

func (*PingReq) ProtoMessage 

func (*PingReq) ProtoMessage()

func (*PingReq) Reset 

func (m *PingReq) Reset()

func (*PingReq) Size 

func (m *PingReq) Size() (n int)

func (*PingReq) String 

func (m *PingReq) String() string

func (*PingReq) Unmarshal 

func (m *PingReq) Unmarshal(dAtA []byte) error

func (*PingReq) XXX_DiscardUnknown 

func (m *PingReq) XXX_DiscardUnknown()

func (*PingReq) XXX_Marshal 

func (m *PingReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PingReq) XXX_Merge 

func (dst *PingReq) XXX_Merge(src proto.Message)

func (*PingReq) XXX_Size 

func (m *PingReq) XXX_Size() int

func (*PingReq) XXX_Unmarshal 

func (m *PingReq) XXX_Unmarshal(b []byte) error

type RoomSrcCheck 

type RoomSrcCheck struct {
	// 上行
	Src int64 `protobuf:"varint,1,opt,name=src,proto3" json:"src,omitempty"`
	// 是否被选择， 1或者0
	Checked int32 `protobuf:"varint,2,opt,name=checked,proto3" json:"checked,omitempty"`
	// 上行名称
	Desc                 string   `protobuf:"bytes,3,opt,name=desc,proto3" json:"desc,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

RoomSrcCheck 上行

func (*RoomSrcCheck) Descriptor 

func (*RoomSrcCheck) Descriptor() ([]byte, []int)

func (*RoomSrcCheck) GetChecked 

func (m *RoomSrcCheck) GetChecked() int32

func (*RoomSrcCheck) GetDesc 

func (m *RoomSrcCheck) GetDesc() string

func (*RoomSrcCheck) GetSrc 

func (m *RoomSrcCheck) GetSrc() int64

func (*RoomSrcCheck) Marshal 

func (m *RoomSrcCheck) Marshal() (dAtA []byte, err error)

func (*RoomSrcCheck) MarshalTo 

func (m *RoomSrcCheck) MarshalTo(dAtA []byte) (int, error)

func (*RoomSrcCheck) ProtoMessage 

func (*RoomSrcCheck) ProtoMessage()

func (*RoomSrcCheck) Reset 

func (m *RoomSrcCheck) Reset()

func (*RoomSrcCheck) Size 

func (m *RoomSrcCheck) Size() (n int)

func (*RoomSrcCheck) String 

func (m *RoomSrcCheck) String() string

func (*RoomSrcCheck) Unmarshal 

func (m *RoomSrcCheck) Unmarshal(dAtA []byte) error

func (*RoomSrcCheck) XXX_DiscardUnknown 

func (m *RoomSrcCheck) XXX_DiscardUnknown()

func (*RoomSrcCheck) XXX_Marshal 

func (m *RoomSrcCheck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RoomSrcCheck) XXX_Merge 

func (dst *RoomSrcCheck) XXX_Merge(src proto.Message)

func (*RoomSrcCheck) XXX_Size 

func (m *RoomSrcCheck) XXX_Size() int

func (*RoomSrcCheck) XXX_Unmarshal 

func (m *RoomSrcCheck) XXX_Unmarshal(b []byte) error

type StreamBase 

type StreamBase struct {
	// 流名
	StreamName string `protobuf:"bytes,1,opt,name=stream_name,json=streamName,proto3" json:"stream_name,omitempty"`
	// 默认上行
	DefaultUpstream uint32 `protobuf:"varint,2,opt,name=default_upstream,json=defaultUpstream,proto3" json:"default_upstream"`
	// 正在推流上行
	Origin uint32 `protobuf:"varint,3,opt,name=origin,proto3" json:"origin,omitempty"`
	// 转推cdn
	Forward []uint32 `protobuf:"varint,4,rep,packed,name=forward" json:"forward,omitempty"`
	// 主流1或者备用流2
	Type uint32 `protobuf:"varint,5,opt,name=type,proto3" json:"type,omitempty"`
	// 推流码
	Key string `protobuf:"bytes,6,opt,name=key,proto3" json:"key,omitempty"`
	// options
	Options              uint32   `protobuf:"varint,7,opt,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

StreamBase 流基本信息

func (*StreamBase) Descriptor 

func (*StreamBase) Descriptor() ([]byte, []int)

func (*StreamBase) GetDefaultUpstream 

func (m *StreamBase) GetDefaultUpstream() uint32

func (*StreamBase) GetForward 

func (m *StreamBase) GetForward() []uint32

func (*StreamBase) GetKey 

func (m *StreamBase) GetKey() string

func (*StreamBase) GetOptions 

func (m *StreamBase) GetOptions() uint32

func (*StreamBase) GetOrigin 

func (m *StreamBase) GetOrigin() uint32

func (*StreamBase) GetStreamName 

func (m *StreamBase) GetStreamName() string

func (*StreamBase) GetType 

func (m *StreamBase) GetType() uint32

func (*StreamBase) Marshal 

func (m *StreamBase) Marshal() (dAtA []byte, err error)

func (*StreamBase) MarshalTo 

func (m *StreamBase) MarshalTo(dAtA []byte) (int, error)

func (*StreamBase) ProtoMessage 

func (*StreamBase) ProtoMessage()

func (*StreamBase) Reset 

func (m *StreamBase) Reset()

func (*StreamBase) Size 

func (m *StreamBase) Size() (n int)

func (*StreamBase) String 

func (m *StreamBase) String() string

func (*StreamBase) Unmarshal 

func (m *StreamBase) Unmarshal(dAtA []byte) error

func (*StreamBase) XXX_DiscardUnknown 

func (m *StreamBase) XXX_DiscardUnknown()

func (*StreamBase) XXX_Marshal 

func (m *StreamBase) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamBase) XXX_Merge 

func (dst *StreamBase) XXX_Merge(src proto.Message)

func (*StreamBase) XXX_Size 

func (m *StreamBase) XXX_Size() int

func (*StreamBase) XXX_Unmarshal 

func (m *StreamBase) XXX_Unmarshal(b []byte) error

type StreamClient 

type StreamClient interface {
	// GetSingleScreeShot
	GetSingleScreeShot(ctx context.Context, in *GetSingleScreeShotReq, opts ...grpc.CallOption) (*GetSingleScreeShotReply, error)
	// GetMultiScreenShot
	GetMultiScreenShot(ctx context.Context, in *GetMultiScreenShotReq, opts ...grpc.CallOption) (*GetMultiScreenShotReply, error)
	// GetOriginScreenShotPic
	GetOriginScreenShotPic(ctx context.Context, in *GetOriginScreenShotPicReq, opts ...grpc.CallOption) (*GetOriginScreenShotPicReply, error)
	// CreateOfficeStream 创建正式流
	CreateOfficalStream(ctx context.Context, in *CreateOfficalStreamReq, opts ...grpc.CallOption) (*CreateOfficalStreamReply, error)
	// GetStreamInfo 获取单个流信息
	GetStreamInfo(ctx context.Context, in *GetStreamInfoReq, opts ...grpc.CallOption) (*GetStreamInfoReply, error)
	// GetMultiStreamInfo 批量获取流信息
	GetMultiStreamInfo(ctx context.Context, in *GetMultiStreamInfoReq, opts ...grpc.CallOption) (*GetMultiStreamInfoReply, error)
	// ChangeSrc 切换cdn
	ChangeSrc(ctx context.Context, in *ChangeSrcReq, opts ...grpc.CallOption) (*EmptyStruct, error)
	// GetStreamLastTime 得到流到最后推流时间;主流的推流时间up_rank = 1
	GetStreamLastTime(ctx context.Context, in *GetStreamLastTimeReq, opts ...grpc.CallOption) (*GetStreamLastTimeReply, error)
	// GetStreamNameByRoomID 需要考虑备用流 + 考虑短号
	GetStreamNameByRoomID(ctx context.Context, in *GetStreamNameByRoomIDReq, opts ...grpc.CallOption) (*GetStreamNameByRoomIDReply, error)
	// GetRoomIDByStreamName 查询房间号
	GetRoomIDByStreamName(ctx context.Context, in *GetRoomIDByStreamNameReq, opts ...grpc.CallOption) (*GetRoomIDByStreamNameReply, error)
	// GetAdapterStreamByStreamName 适配结果输出, 此处也可以输入备用流， 该结果只输出直推上行
	GetAdapterStreamByStreamName(ctx context.Context, in *GetAdapterStreamByStreamNameReq, opts ...grpc.CallOption) (*GetAdapterStreamByStreamNameReply, error)
	// GetSrcByRoomID
	GetSrcByRoomID(ctx context.Context, in *GetSrcByRoomIDReq, opts ...grpc.CallOption) (*GetSrcByRoomIDReply, error)
	// GetLineListByRoomID
	GetLineListByRoomID(ctx context.Context, in *GetLineListByRoomIDReq, opts ...grpc.CallOption) (*GetLineListByRoomIDReply, error)
	// GetUpStreamRtmp UpStream
	GetUpStreamRtmp(ctx context.Context, in *GetUpStreamRtmpReq, opts ...grpc.CallOption) (*GetUpStreamRtmpReply, error)
	// StreamCut 切流的房间和时间, 内部调用
	StreamCut(ctx context.Context, in *StreamCutReq, opts ...grpc.CallOption) (*EmptyStruct, error)
	// Ping Service
	Ping(ctx context.Context, in *PingReq, opts ...grpc.CallOption) (*PingReply, error)
	// Close Service
	Close(ctx context.Context, in *CloseReq, opts ...grpc.CallOption) (*CloseReply, error)
	// ClearRetweetRecord
	ClearStreamStatus(ctx context.Context, in *ClearStreamStatusReq, opts ...grpc.CallOption) (*EmptyStruct, error)
	// CheckLiveStreamList
	CheckLiveStreamList(ctx context.Context, in *CheckLiveStreamReq, opts ...grpc.CallOption) (*CheckLiveStreamReply, error)
}

StreamClient is the client API for Stream service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewClient 

func NewClient(cfg *warden.ClientConfig, opts ...grpc.DialOption) (StreamClient, error)

NewClient 建立grpc连接

func NewStreamClient 

func NewStreamClient(cc *grpc.ClientConn) StreamClient

type StreamCutReq 

type StreamCutReq struct {
	// 房间号
	RoomId int64 `protobuf:"varint,1,opt,name=room_id,json=roomId,proto3" json:"room_id,omitempty"`
	// 切流时间
	CutTime              int64    `protobuf:"varint,2,opt,name=cut_time,json=cutTime,proto3" json:"cut_time,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

StreamCutReq 切流

func (*StreamCutReq) Descriptor 

func (*StreamCutReq) Descriptor() ([]byte, []int)

func (*StreamCutReq) GetCutTime 

func (m *StreamCutReq) GetCutTime() int64

func (*StreamCutReq) GetRoomId 

func (m *StreamCutReq) GetRoomId() int64

func (*StreamCutReq) Marshal 

func (m *StreamCutReq) Marshal() (dAtA []byte, err error)

func (*StreamCutReq) MarshalTo 

func (m *StreamCutReq) MarshalTo(dAtA []byte) (int, error)

func (*StreamCutReq) ProtoMessage 

func (*StreamCutReq) ProtoMessage()

func (*StreamCutReq) Reset 

func (m *StreamCutReq) Reset()

func (*StreamCutReq) Size 

func (m *StreamCutReq) Size() (n int)

func (*StreamCutReq) String 

func (m *StreamCutReq) String() string

func (*StreamCutReq) Unmarshal 

func (m *StreamCutReq) Unmarshal(dAtA []byte) error

func (*StreamCutReq) XXX_DiscardUnknown 

func (m *StreamCutReq) XXX_DiscardUnknown()

func (*StreamCutReq) XXX_Marshal 

func (m *StreamCutReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamCutReq) XXX_Merge 

func (dst *StreamCutReq) XXX_Merge(src proto.Message)

func (*StreamCutReq) XXX_Size 

func (m *StreamCutReq) XXX_Size() int

func (*StreamCutReq) XXX_Unmarshal 

func (m *StreamCutReq) XXX_Unmarshal(b []byte) error

type StreamFullInfo 

type StreamFullInfo struct {
	// 房间号
	RoomId uint32 `protobuf:"varint,1,opt,name=room_id,json=roomId,proto3" json:"room_id,omitempty"`
	// 是否为冷热流
	Hot uint32 `protobuf:"varint,2,opt,name=hot,proto3" json:"hot,omitempty"`
	// 流列表
	List                 []*StreamBase `protobuf:"bytes,3,rep,name=list" json:"list,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

StreamFullInfo 流信息完整结构

func (*StreamFullInfo) Descriptor 

func (*StreamFullInfo) Descriptor() ([]byte, []int)

func (*StreamFullInfo) GetHot 

func (m *StreamFullInfo) GetHot() uint32

func (*StreamFullInfo) GetList 

func (m *StreamFullInfo) GetList() []*StreamBase

func (*StreamFullInfo) GetRoomId 

func (m *StreamFullInfo) GetRoomId() uint32

func (*StreamFullInfo) Marshal 

func (m *StreamFullInfo) Marshal() (dAtA []byte, err error)

func (*StreamFullInfo) MarshalTo 

func (m *StreamFullInfo) MarshalTo(dAtA []byte) (int, error)

func (*StreamFullInfo) ProtoMessage 

func (*StreamFullInfo) ProtoMessage()

func (*StreamFullInfo) Reset 

func (m *StreamFullInfo) Reset()

func (*StreamFullInfo) Size 

func (m *StreamFullInfo) Size() (n int)

func (*StreamFullInfo) String 

func (m *StreamFullInfo) String() string

func (*StreamFullInfo) Unmarshal 

func (m *StreamFullInfo) Unmarshal(dAtA []byte) error

func (*StreamFullInfo) XXX_DiscardUnknown 

func (m *StreamFullInfo) XXX_DiscardUnknown()

func (*StreamFullInfo) XXX_Marshal 

func (m *StreamFullInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamFullInfo) XXX_Merge 

func (dst *StreamFullInfo) XXX_Merge(src proto.Message)

func (*StreamFullInfo) XXX_Size 

func (m *StreamFullInfo) XXX_Size() int

func (*StreamFullInfo) XXX_Unmarshal 

func (m *StreamFullInfo) XXX_Unmarshal(b []byte) error

type StreamServer 

type StreamServer interface {
	// GetSingleScreeShot
	GetSingleScreeShot(context.Context, *GetSingleScreeShotReq) (*GetSingleScreeShotReply, error)
	// GetMultiScreenShot
	GetMultiScreenShot(context.Context, *GetMultiScreenShotReq) (*GetMultiScreenShotReply, error)
	// GetOriginScreenShotPic
	GetOriginScreenShotPic(context.Context, *GetOriginScreenShotPicReq) (*GetOriginScreenShotPicReply, error)
	// CreateOfficeStream 创建正式流
	CreateOfficalStream(context.Context, *CreateOfficalStreamReq) (*CreateOfficalStreamReply, error)
	// GetStreamInfo 获取单个流信息
	GetStreamInfo(context.Context, *GetStreamInfoReq) (*GetStreamInfoReply, error)
	// GetMultiStreamInfo 批量获取流信息
	GetMultiStreamInfo(context.Context, *GetMultiStreamInfoReq) (*GetMultiStreamInfoReply, error)
	// ChangeSrc 切换cdn
	ChangeSrc(context.Context, *ChangeSrcReq) (*EmptyStruct, error)
	// GetStreamLastTime 得到流到最后推流时间;主流的推流时间up_rank = 1
	GetStreamLastTime(context.Context, *GetStreamLastTimeReq) (*GetStreamLastTimeReply, error)
	// GetStreamNameByRoomID 需要考虑备用流 + 考虑短号
	GetStreamNameByRoomID(context.Context, *GetStreamNameByRoomIDReq) (*GetStreamNameByRoomIDReply, error)
	// GetRoomIDByStreamName 查询房间号
	GetRoomIDByStreamName(context.Context, *GetRoomIDByStreamNameReq) (*GetRoomIDByStreamNameReply, error)
	// GetAdapterStreamByStreamName 适配结果输出, 此处也可以输入备用流， 该结果只输出直推上行
	GetAdapterStreamByStreamName(context.Context, *GetAdapterStreamByStreamNameReq) (*GetAdapterStreamByStreamNameReply, error)
	// GetSrcByRoomID
	GetSrcByRoomID(context.Context, *GetSrcByRoomIDReq) (*GetSrcByRoomIDReply, error)
	// GetLineListByRoomID
	GetLineListByRoomID(context.Context, *GetLineListByRoomIDReq) (*GetLineListByRoomIDReply, error)
	// GetUpStreamRtmp UpStream
	GetUpStreamRtmp(context.Context, *GetUpStreamRtmpReq) (*GetUpStreamRtmpReply, error)
	// StreamCut 切流的房间和时间, 内部调用
	StreamCut(context.Context, *StreamCutReq) (*EmptyStruct, error)
	// Ping Service
	Ping(context.Context, *PingReq) (*PingReply, error)
	// Close Service
	Close(context.Context, *CloseReq) (*CloseReply, error)
	// ClearRetweetRecord
	ClearStreamStatus(context.Context, *ClearStreamStatusReq) (*EmptyStruct, error)
	// CheckLiveStreamList
	CheckLiveStreamList(context.Context, *CheckLiveStreamReq) (*CheckLiveStreamReply, error)
}

StreamServer is the server API for Stream service.

type TimeTime 

type TimeTime struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TimeTime 时间

func (*TimeTime) Descriptor 

func (*TimeTime) Descriptor() ([]byte, []int)

func (*TimeTime) Marshal 

func (m *TimeTime) Marshal() (dAtA []byte, err error)

func (*TimeTime) MarshalTo 

func (m *TimeTime) MarshalTo(dAtA []byte) (int, error)

func (*TimeTime) ProtoMessage 

func (*TimeTime) ProtoMessage()

func (*TimeTime) Reset 

func (m *TimeTime) Reset()

func (*TimeTime) Size 

func (m *TimeTime) Size() (n int)

func (*TimeTime) String 

func (m *TimeTime) String() string

func (*TimeTime) Unmarshal 

func (m *TimeTime) Unmarshal(dAtA []byte) error

func (*TimeTime) XXX_DiscardUnknown 

func (m *TimeTime) XXX_DiscardUnknown()

func (*TimeTime) XXX_Marshal 

func (m *TimeTime) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TimeTime) XXX_Merge 

func (dst *TimeTime) XXX_Merge(src proto.Message)

func (*TimeTime) XXX_Size 

func (m *TimeTime) XXX_Size() int

func (*TimeTime) XXX_Unmarshal 

func (m *TimeTime) XXX_Unmarshal(b []byte) error

type UpStreamRtmp 

type UpStreamRtmp struct {
	// 推流地址
	Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	// 推流码
	Code string `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"`
	// new link
	NewLink              string   `protobuf:"bytes,3,opt,name=new_link,json=newLink,proto3" json:"new_link,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

UpStreamRtmp 上行推流地址详细信息

func (*UpStreamRtmp) Descriptor 

func (*UpStreamRtmp) Descriptor() ([]byte, []int)

func (*UpStreamRtmp) GetAddr 

func (m *UpStreamRtmp) GetAddr() string

func (*UpStreamRtmp) GetCode 

func (m *UpStreamRtmp) GetCode() string
func (m *UpStreamRtmp) GetNewLink() string

func (*UpStreamRtmp) Marshal 

func (m *UpStreamRtmp) Marshal() (dAtA []byte, err error)

func (*UpStreamRtmp) MarshalTo 

func (m *UpStreamRtmp) MarshalTo(dAtA []byte) (int, error)

func (*UpStreamRtmp) ProtoMessage 

func (*UpStreamRtmp) ProtoMessage()

func (*UpStreamRtmp) Reset 

func (m *UpStreamRtmp) Reset()

func (*UpStreamRtmp) Size 

func (m *UpStreamRtmp) Size() (n int)

func (*UpStreamRtmp) String 

func (m *UpStreamRtmp) String() string

func (*UpStreamRtmp) Unmarshal 

func (m *UpStreamRtmp) Unmarshal(dAtA []byte) error

func (*UpStreamRtmp) XXX_DiscardUnknown 

func (m *UpStreamRtmp) XXX_DiscardUnknown()

func (*UpStreamRtmp) XXX_Marshal 

func (m *UpStreamRtmp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpStreamRtmp) XXX_Merge 

func (dst *UpStreamRtmp) XXX_Merge(src proto.Message)

func (*UpStreamRtmp) XXX_Size 

func (m *UpStreamRtmp) XXX_Size() int

func (*UpStreamRtmp) XXX_Unmarshal 

func (m *UpStreamRtmp) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.