go_live_stream_svr

package module
v0.0.0-...-c0018c6 Latest Latest
Warning

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

 Go to latest Published: Aug 25, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	GoLiveStreamSvr_StartLiveTask_FullMethodName  = "/go_live_stream_svr.go_live_stream_svr/StartLiveTask"
	GoLiveStreamSvr_UpdateLiveTask_FullMethodName = "/go_live_stream_svr.go_live_stream_svr/UpdateLiveTask"
)

Variables

View Source 
var File_go_live_stream_svr_proto protoreflect.FileDescriptor
View Source 
var GoLiveStreamSvr_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "go_live_stream_svr.go_live_stream_svr",
	HandlerType: (*GoLiveStreamSvrServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "StartLiveTask",
			Handler:    _GoLiveStreamSvr_StartLiveTask_Handler,
		},
		{
			MethodName: "UpdateLiveTask",
			Handler:    _GoLiveStreamSvr_UpdateLiveTask_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "go_live_stream_svr.proto",
}

GoLiveStreamSvr_ServiceDesc is the grpc.ServiceDesc for GoLiveStreamSvr service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterGoLiveStreamSvrServer 

func RegisterGoLiveStreamSvrServer(s grpc.ServiceRegistrar, srv GoLiveStreamSvrServer)

Types

type GoLiveStreamSvrClient 

type GoLiveStreamSvrClient interface {
	StartLiveTask(ctx context.Context, in *StartLiveTaskReq, opts ...grpc.CallOption) (*StartLiveTaskRsp, error)
	UpdateLiveTask(ctx context.Context, in *UpdateLiveTaskReq, opts ...grpc.CallOption) (*UpdateLiveTaskRsp, error)
}

GoLiveStreamSvrClient is the client API for GoLiveStreamSvr service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewGoLiveStreamSvrClient 

func NewGoLiveStreamSvrClient(cc grpc.ClientConnInterface) GoLiveStreamSvrClient

type GoLiveStreamSvrServer 

type GoLiveStreamSvrServer interface {
	StartLiveTask(context.Context, *StartLiveTaskReq) (*StartLiveTaskRsp, error)
	UpdateLiveTask(context.Context, *UpdateLiveTaskReq) (*UpdateLiveTaskRsp, error)
}

GoLiveStreamSvrServer is the server API for GoLiveStreamSvr service. All implementations should embed UnimplementedGoLiveStreamSvrServer for forward compatibility

type StartLiveTaskReq 

type StartLiveTaskReq struct {
	TaskId   string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	FilePath string `protobuf:"bytes,2,opt,name=file_path,json=filePath,proto3" json:"file_path,omitempty"`
	RtmpUrl  string `protobuf:"bytes,3,opt,name=rtmp_url,json=rtmpUrl,proto3" json:"rtmp_url,omitempty"`
	// contains filtered or unexported fields
}

func (*StartLiveTaskReq) Descriptor deprecated 

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

Deprecated: Use StartLiveTaskReq.ProtoReflect.Descriptor instead.

func (*StartLiveTaskReq) GetFilePath 

func (x *StartLiveTaskReq) GetFilePath() string

func (*StartLiveTaskReq) GetRtmpUrl 

func (x *StartLiveTaskReq) GetRtmpUrl() string

func (*StartLiveTaskReq) GetTaskId 

func (x *StartLiveTaskReq) GetTaskId() string

func (*StartLiveTaskReq) ProtoMessage 

func (*StartLiveTaskReq) ProtoMessage()

func (*StartLiveTaskReq) ProtoReflect 

func (x *StartLiveTaskReq) ProtoReflect() protoreflect.Message

func (*StartLiveTaskReq) Reset 

func (x *StartLiveTaskReq) Reset()

func (*StartLiveTaskReq) String 

func (x *StartLiveTaskReq) String() string

type StartLiveTaskRsp 

type StartLiveTaskRsp struct {
	Code int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Msg  string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*StartLiveTaskRsp) Descriptor deprecated 

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

Deprecated: Use StartLiveTaskRsp.ProtoReflect.Descriptor instead.

func (*StartLiveTaskRsp) GetCode 

func (x *StartLiveTaskRsp) GetCode() int32

func (*StartLiveTaskRsp) GetMsg 

func (x *StartLiveTaskRsp) GetMsg() string

func (*StartLiveTaskRsp) ProtoMessage 

func (*StartLiveTaskRsp) ProtoMessage()

func (*StartLiveTaskRsp) ProtoReflect 

func (x *StartLiveTaskRsp) ProtoReflect() protoreflect.Message

func (*StartLiveTaskRsp) Reset 

func (x *StartLiveTaskRsp) Reset()

func (*StartLiveTaskRsp) String 

func (x *StartLiveTaskRsp) String() string

type UnimplementedGoLiveStreamSvrServer 

type UnimplementedGoLiveStreamSvrServer struct {
}

UnimplementedGoLiveStreamSvrServer should be embedded to have forward compatible implementations.

func (UnimplementedGoLiveStreamSvrServer) StartLiveTask 

func (UnimplementedGoLiveStreamSvrServer) StartLiveTask(context.Context, *StartLiveTaskReq) (*StartLiveTaskRsp, error)

func (UnimplementedGoLiveStreamSvrServer) UpdateLiveTask 

func (UnimplementedGoLiveStreamSvrServer) UpdateLiveTask(context.Context, *UpdateLiveTaskReq) (*UpdateLiveTaskRsp, error)

type UnsafeGoLiveStreamSvrServer 

type UnsafeGoLiveStreamSvrServer interface {
	// contains filtered or unexported methods
}

UnsafeGoLiveStreamSvrServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GoLiveStreamSvrServer will result in compilation errors.

type UpdateLiveTaskReq 

type UpdateLiveTaskReq struct {
	TaskId   string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	FilePath string `protobuf:"bytes,2,opt,name=file_path,json=filePath,proto3" json:"file_path,omitempty"`
	RtmpUrl  string `protobuf:"bytes,3,opt,name=rtmp_url,json=rtmpUrl,proto3" json:"rtmp_url,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateLiveTaskReq) Descriptor deprecated 

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

Deprecated: Use UpdateLiveTaskReq.ProtoReflect.Descriptor instead.

func (*UpdateLiveTaskReq) GetFilePath 

func (x *UpdateLiveTaskReq) GetFilePath() string

func (*UpdateLiveTaskReq) GetRtmpUrl 

func (x *UpdateLiveTaskReq) GetRtmpUrl() string

func (*UpdateLiveTaskReq) GetTaskId 

func (x *UpdateLiveTaskReq) GetTaskId() string

func (*UpdateLiveTaskReq) ProtoMessage 

func (*UpdateLiveTaskReq) ProtoMessage()

func (*UpdateLiveTaskReq) ProtoReflect 

func (x *UpdateLiveTaskReq) ProtoReflect() protoreflect.Message

func (*UpdateLiveTaskReq) Reset 

func (x *UpdateLiveTaskReq) Reset()

func (*UpdateLiveTaskReq) String 

func (x *UpdateLiveTaskReq) String() string

type UpdateLiveTaskRsp 

type UpdateLiveTaskRsp struct {
	Code int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Msg  string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateLiveTaskRsp) Descriptor deprecated 

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

Deprecated: Use UpdateLiveTaskRsp.ProtoReflect.Descriptor instead.

func (*UpdateLiveTaskRsp) GetCode 

func (x *UpdateLiveTaskRsp) GetCode() int32

func (*UpdateLiveTaskRsp) GetMsg 

func (x *UpdateLiveTaskRsp) GetMsg() string

func (*UpdateLiveTaskRsp) ProtoMessage 

func (*UpdateLiveTaskRsp) ProtoMessage()

func (*UpdateLiveTaskRsp) ProtoReflect 

func (x *UpdateLiveTaskRsp) ProtoReflect() protoreflect.Message

func (*UpdateLiveTaskRsp) Reset 

func (x *UpdateLiveTaskRsp) Reset()

func (*UpdateLiveTaskRsp) String 

func (x *UpdateLiveTaskRsp) String() string

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.