rpc

package
v0.0.3 Latest Latest
Warning

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

 Go to latest Published: Jul 12, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Version_name = map[int32]string{
		0: "DUMMY",
		1: "DEFAULT",
	}
	Version_value = map[string]int32{
		"DUMMY":   0,
		"DEFAULT": 1,
	}
)

Enum value maps for Version.

View Source 
var (
	CodecType_name = map[int32]string{
		0: "RAW",
		1: "TELEPHONE_EVENT_8K",
		2: "TELEPHONE_EVENT_16K",
		3: "PCM_ALAW",
		4: "AMRNB",
		5: "AMRWB",
		6: "H264",
	}
	CodecType_value = map[string]int32{
		"RAW":                 0,
		"TELEPHONE_EVENT_8K":  1,
		"TELEPHONE_EVENT_16K": 2,
		"PCM_ALAW":            3,
		"AMRNB":               4,
		"AMRWB":               5,
		"H264":                6,
	}
)

Enum value maps for CodecType.

View Source 
var (
	SystemCommand_name = map[int32]string{
		0: "USER_EVENT",
		1: "REGISTER",
		2: "KEEPALIVE",
		3: "SESSION_INFO",
	}
	SystemCommand_value = map[string]int32{
		"USER_EVENT":   0,
		"REGISTER":     1,
		"KEEPALIVE":    2,
		"SESSION_INFO": 3,
	}
)

Enum value maps for SystemCommand.

View Source 
var File_msapi_proto protoreflect.FileDescriptor
View Source 
var MediaApi_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "rpc.MediaApi",
	HandlerType: (*MediaApiServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetVersion",
			Handler:    _MediaApi_GetVersion_Handler,
		},
		{
			MethodName: "PrepareSession",
			Handler:    _MediaApi_PrepareSession_Handler,
		},
		{
			MethodName: "UpdateSession",
			Handler:    _MediaApi_UpdateSession_Handler,
		},
		{
			MethodName: "StartSession",
			Handler:    _MediaApi_StartSession_Handler,
		},
		{
			MethodName: "StopSession",
			Handler:    _MediaApi_StopSession_Handler,
		},
		{
			MethodName: "ExecuteAction",
			Handler:    _MediaApi_ExecuteAction_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ExecuteActionWithNotify",
			Handler:       _MediaApi_ExecuteActionWithNotify_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ExecuteActionWithPush",
			Handler:       _MediaApi_ExecuteActionWithPush_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "SystemChannel",
			Handler:       _MediaApi_SystemChannel_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "msapi.proto",
}

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

Functions

func RegisterMediaApiServer 

func RegisterMediaApiServer(s grpc.ServiceRegistrar, srv MediaApiServer)

Types

type Action added in v0.0.2 

type Action struct {
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Cmd       string `protobuf:"bytes,2,opt,name=cmd,proto3" json:"cmd,omitempty"`
	CmdArg    string `protobuf:"bytes,3,opt,name=cmd_arg,json=cmdArg,proto3" json:"cmd_arg,omitempty"`
	// contains filtered or unexported fields
}

func (*Action) Descriptor deprecated added in v0.0.2 

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

Deprecated: Use Action.ProtoReflect.Descriptor instead.

func (*Action) GetCmd added in v0.0.2 

func (x *Action) GetCmd() string

func (*Action) GetCmdArg added in v0.0.2 

func (x *Action) GetCmdArg() string

func (*Action) GetSessionId added in v0.0.2 

func (x *Action) GetSessionId() string

func (*Action) ProtoMessage added in v0.0.2 

func (*Action) ProtoMessage()

func (*Action) ProtoReflect added in v0.0.2 

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

func (*Action) Reset added in v0.0.2 

func (x *Action) Reset()

func (*Action) String added in v0.0.2 

func (x *Action) String() string

type ActionEvent added in v0.0.2 

type ActionEvent struct {
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Event     string `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*ActionEvent) Descriptor deprecated added in v0.0.2 

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

Deprecated: Use ActionEvent.ProtoReflect.Descriptor instead.

func (*ActionEvent) GetEvent added in v0.0.2 

func (x *ActionEvent) GetEvent() string

func (*ActionEvent) GetSessionId added in v0.0.2 

func (x *ActionEvent) GetSessionId() string

func (*ActionEvent) ProtoMessage added in v0.0.2 

func (*ActionEvent) ProtoMessage()

func (*ActionEvent) ProtoReflect added in v0.0.2 

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

func (*ActionEvent) Reset added in v0.0.2 

func (x *ActionEvent) Reset()

func (*ActionEvent) String added in v0.0.2 

func (x *ActionEvent) String() string

type ActionResult added in v0.0.2 

type ActionResult struct {
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	State     string `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*ActionResult) Descriptor deprecated added in v0.0.2 

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

Deprecated: Use ActionResult.ProtoReflect.Descriptor instead.

func (*ActionResult) GetSessionId added in v0.0.2 

func (x *ActionResult) GetSessionId() string

func (*ActionResult) GetState added in v0.0.2 

func (x *ActionResult) GetState() string

func (*ActionResult) ProtoMessage added in v0.0.2 

func (*ActionResult) ProtoMessage()

func (*ActionResult) ProtoReflect added in v0.0.2 

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

func (*ActionResult) Reset added in v0.0.2 

func (x *ActionResult) Reset()

func (*ActionResult) String added in v0.0.2 

func (x *ActionResult) String() string

type CodecInfo added in v0.0.2 

type CodecInfo struct {
	PayloadNumber uint32    `protobuf:"varint,1,opt,name=payload_number,json=payloadNumber,proto3" json:"payload_number,omitempty"`              // negotiated payload type, dynamic(96 ~ 127) or fixed type
	PayloadType   CodecType `protobuf:"varint,2,opt,name=payload_type,json=payloadType,proto3,enum=rpc.CodecType" json:"payload_type,omitempty"` // used to identify mime type, like "AMR","PCM_ALAW"
	CodecParam    string    `protobuf:"bytes,3,opt,name=codec_param,json=codecParam,proto3" json:"codec_param,omitempty"`                        // parameter of codec, like fmtp: ...
	// contains filtered or unexported fields
}

func (*CodecInfo) Descriptor deprecated added in v0.0.2 

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

Deprecated: Use CodecInfo.ProtoReflect.Descriptor instead.

func (*CodecInfo) GetCodecParam added in v0.0.2 

func (x *CodecInfo) GetCodecParam() string

func (*CodecInfo) GetPayloadNumber added in v0.0.2 

func (x *CodecInfo) GetPayloadNumber() uint32

func (*CodecInfo) GetPayloadType added in v0.0.2 

func (x *CodecInfo) GetPayloadType() CodecType

func (*CodecInfo) ProtoMessage added in v0.0.2 

func (*CodecInfo) ProtoMessage()

func (*CodecInfo) ProtoReflect added in v0.0.2 

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

func (*CodecInfo) Reset added in v0.0.2 

func (x *CodecInfo) Reset()

func (*CodecInfo) String added in v0.0.2 

func (x *CodecInfo) String() string

type CodecType 

type CodecType int32
const (
	CodecType_RAW                 CodecType = 0 // raw packet data
	CodecType_TELEPHONE_EVENT_8K  CodecType = 1
	CodecType_TELEPHONE_EVENT_16K CodecType = 2
	CodecType_PCM_ALAW            CodecType = 3
	CodecType_AMRNB               CodecType = 4
	CodecType_AMRWB               CodecType = 5
	CodecType_H264                CodecType = 6
)

func (CodecType) Descriptor 

func (CodecType) Descriptor() protoreflect.EnumDescriptor

func (CodecType) Enum 

func (x CodecType) Enum() *CodecType

func (CodecType) EnumDescriptor deprecated 

func (CodecType) EnumDescriptor() ([]byte, []int)

Deprecated: Use CodecType.Descriptor instead.

func (CodecType) Number 

func (x CodecType) Number() protoreflect.EnumNumber

func (CodecType) String 

func (x CodecType) String() string

func (CodecType) Type 

func (CodecType) Type() protoreflect.EnumType

type CreateParam added in v0.0.2 

type CreateParam struct {
	PeerIp     string       `protobuf:"bytes,1,opt,name=peer_ip,json=peerIp,proto3" json:"peer_ip,omitempty"`        // remote rtp ip
	PeerPort   uint32       `protobuf:"varint,2,opt,name=peer_port,json=peerPort,proto3" json:"peer_port,omitempty"` // remote rtp port
	Codecs     []*CodecInfo `protobuf:"bytes,3,rep,name=codecs,proto3" json:"codecs,omitempty"`
	GraphDesc  string       `protobuf:"bytes,4,opt,name=graph_desc,json=graphDesc,proto3" json:"graph_desc,omitempty"`    // used to describe event graph
	InstanceId string       `protobuf:"bytes,5,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"` // which instance creates this session
	// contains filtered or unexported fields
}

func (*CreateParam) Descriptor deprecated added in v0.0.2 

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

Deprecated: Use CreateParam.ProtoReflect.Descriptor instead.

func (*CreateParam) GetCodecs added in v0.0.2 

func (x *CreateParam) GetCodecs() []*CodecInfo

func (*CreateParam) GetGraphDesc added in v0.0.2 

func (x *CreateParam) GetGraphDesc() string

func (*CreateParam) GetInstanceId added in v0.0.3 

func (x *CreateParam) GetInstanceId() string

func (*CreateParam) GetPeerIp added in v0.0.2 

func (x *CreateParam) GetPeerIp() string

func (*CreateParam) GetPeerPort added in v0.0.2 

func (x *CreateParam) GetPeerPort() uint32

func (*CreateParam) ProtoMessage added in v0.0.2 

func (*CreateParam) ProtoMessage()

func (*CreateParam) ProtoReflect added in v0.0.2 

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

func (*CreateParam) Reset added in v0.0.2 

func (x *CreateParam) Reset()

func (*CreateParam) String added in v0.0.2 

func (x *CreateParam) String() string

type Empty added in v0.0.3 

type Empty struct {
	// contains filtered or unexported fields
}

func (*Empty) Descriptor deprecated added in v0.0.3 

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage added in v0.0.3 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect added in v0.0.3 

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

func (*Empty) Reset added in v0.0.3 

func (x *Empty) Reset()

func (*Empty) String added in v0.0.3 

func (x *Empty) String() string

type MediaApiClient 

type MediaApiClient interface {
	GetVersion(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*VersionNumber, error)
	PrepareSession(ctx context.Context, in *CreateParam, opts ...grpc.CallOption) (*Session, error)
	UpdateSession(ctx context.Context, in *UpdateParam, opts ...grpc.CallOption) (*Status, error)
	StartSession(ctx context.Context, in *StartParam, opts ...grpc.CallOption) (*Status, error)
	StopSession(ctx context.Context, in *StopParam, opts ...grpc.CallOption) (*Status, error)
	ExecuteAction(ctx context.Context, in *Action, opts ...grpc.CallOption) (*ActionResult, error)
	ExecuteActionWithNotify(ctx context.Context, in *Action, opts ...grpc.CallOption) (MediaApi_ExecuteActionWithNotifyClient, error)
	ExecuteActionWithPush(ctx context.Context, opts ...grpc.CallOption) (MediaApi_ExecuteActionWithPushClient, error)
	SystemChannel(ctx context.Context, opts ...grpc.CallOption) (MediaApi_SystemChannelClient, error)
}

MediaApiClient is the client API for MediaApi 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 NewMediaApiClient 

func NewMediaApiClient(cc grpc.ClientConnInterface) MediaApiClient

type MediaApiServer 

type MediaApiServer interface {
	GetVersion(context.Context, *Empty) (*VersionNumber, error)
	PrepareSession(context.Context, *CreateParam) (*Session, error)
	UpdateSession(context.Context, *UpdateParam) (*Status, error)
	StartSession(context.Context, *StartParam) (*Status, error)
	StopSession(context.Context, *StopParam) (*Status, error)
	ExecuteAction(context.Context, *Action) (*ActionResult, error)
	ExecuteActionWithNotify(*Action, MediaApi_ExecuteActionWithNotifyServer) error
	ExecuteActionWithPush(MediaApi_ExecuteActionWithPushServer) error
	SystemChannel(MediaApi_SystemChannelServer) error
	// contains filtered or unexported methods
}

MediaApiServer is the server API for MediaApi service. All implementations must embed UnimplementedMediaApiServer for forward compatibility

type MediaApi_ExecuteActionWithNotifyClient 

type MediaApi_ExecuteActionWithNotifyClient interface {
	Recv() (*ActionEvent, error)
	grpc.ClientStream
}

type MediaApi_ExecuteActionWithNotifyServer 

type MediaApi_ExecuteActionWithNotifyServer interface {
	Send(*ActionEvent) error
	grpc.ServerStream
}

type MediaApi_ExecuteActionWithPushClient added in v0.0.3 

type MediaApi_ExecuteActionWithPushClient interface {
	Send(*PushData) error
	CloseAndRecv() (*ActionResult, error)
	grpc.ClientStream
}

type MediaApi_ExecuteActionWithPushServer added in v0.0.3 

type MediaApi_ExecuteActionWithPushServer interface {
	SendAndClose(*ActionResult) error
	Recv() (*PushData, error)
	grpc.ServerStream
}

type MediaApi_SystemChannelClient added in v0.0.3 

type MediaApi_SystemChannelClient interface {
	Send(*SystemEvent) error
	Recv() (*SystemEvent, error)
	grpc.ClientStream
}

type MediaApi_SystemChannelServer added in v0.0.3 

type MediaApi_SystemChannelServer interface {
	Send(*SystemEvent) error
	Recv() (*SystemEvent, error)
	grpc.ServerStream
}

type PushData added in v0.0.3 

type PushData struct {
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // only used in first packet, following packets use the same session id
	NodeName  string `protobuf:"bytes,2,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	MsgType   string `protobuf:"bytes,3,opt,name=msg_type,json=msgType,proto3" json:"msg_type,omitempty"`
	Data      []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*PushData) Descriptor deprecated added in v0.0.3 

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

Deprecated: Use PushData.ProtoReflect.Descriptor instead.

func (*PushData) GetData added in v0.0.3 

func (x *PushData) GetData() []byte

func (*PushData) GetMsgType added in v0.0.3 

func (x *PushData) GetMsgType() string

func (*PushData) GetNodeName added in v0.0.3 

func (x *PushData) GetNodeName() string

func (*PushData) GetSessionId added in v0.0.3 

func (x *PushData) GetSessionId() string

func (*PushData) ProtoMessage added in v0.0.3 

func (*PushData) ProtoMessage()

func (*PushData) ProtoReflect added in v0.0.3 

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

func (*PushData) Reset added in v0.0.3 

func (x *PushData) Reset()

func (*PushData) String added in v0.0.3 

func (x *PushData) String() string

type Session added in v0.0.2 

type Session struct {
	SessionId    string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	LocalIp      string `protobuf:"bytes,2,opt,name=local_ip,json=localIp,proto3" json:"local_ip,omitempty"`
	LocalRtpPort uint32 `protobuf:"varint,3,opt,name=local_rtp_port,json=localRtpPort,proto3" json:"local_rtp_port,omitempty"`
	PeerIp       string `protobuf:"bytes,4,opt,name=peer_ip,json=peerIp,proto3" json:"peer_ip,omitempty"`
	PeerRtpPort  uint32 `protobuf:"varint,5,opt,name=peer_rtp_port,json=peerRtpPort,proto3" json:"peer_rtp_port,omitempty"`
	// contains filtered or unexported fields
}

func (*Session) Descriptor deprecated added in v0.0.2 

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

Deprecated: Use Session.ProtoReflect.Descriptor instead.

func (*Session) GetLocalIp added in v0.0.2 

func (x *Session) GetLocalIp() string

func (*Session) GetLocalRtpPort added in v0.0.2 

func (x *Session) GetLocalRtpPort() uint32

func (*Session) GetPeerIp added in v0.0.2 

func (x *Session) GetPeerIp() string

func (*Session) GetPeerRtpPort added in v0.0.2 

func (x *Session) GetPeerRtpPort() uint32

func (*Session) GetSessionId added in v0.0.2 

func (x *Session) GetSessionId() string

func (*Session) ProtoMessage added in v0.0.2 

func (*Session) ProtoMessage()

func (*Session) ProtoReflect added in v0.0.2 

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

func (*Session) Reset added in v0.0.2 

func (x *Session) Reset()

func (*Session) String added in v0.0.2 

func (x *Session) String() string

type StartParam added in v0.0.2 

type StartParam struct {
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StartParam) Descriptor deprecated added in v0.0.2 

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

Deprecated: Use StartParam.ProtoReflect.Descriptor instead.

func (*StartParam) GetSessionId added in v0.0.2 

func (x *StartParam) GetSessionId() string

func (*StartParam) ProtoMessage added in v0.0.2 

func (*StartParam) ProtoMessage()

func (*StartParam) ProtoReflect added in v0.0.2 

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

func (*StartParam) Reset added in v0.0.2 

func (x *StartParam) Reset()

func (*StartParam) String added in v0.0.2 

func (x *StartParam) String() string

type Status added in v0.0.2 

type Status struct {
	Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*Status) Descriptor deprecated added in v0.0.2 

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

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetStatus added in v0.0.2 

func (x *Status) GetStatus() string

func (*Status) ProtoMessage added in v0.0.2 

func (*Status) ProtoMessage()

func (*Status) ProtoReflect added in v0.0.2 

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

func (*Status) Reset added in v0.0.2 

func (x *Status) Reset()

func (*Status) String added in v0.0.2 

func (x *Status) String() string

type StopParam added in v0.0.2 

type StopParam struct {
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StopParam) Descriptor deprecated added in v0.0.2 

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

Deprecated: Use StopParam.ProtoReflect.Descriptor instead.

func (*StopParam) GetSessionId added in v0.0.2 

func (x *StopParam) GetSessionId() string

func (*StopParam) ProtoMessage added in v0.0.2 

func (*StopParam) ProtoMessage()

func (*StopParam) ProtoReflect added in v0.0.2 

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

func (*StopParam) Reset added in v0.0.2 

func (x *StopParam) Reset()

func (*StopParam) String added in v0.0.2 

func (x *StopParam) String() string

type SystemCommand added in v0.0.3 

type SystemCommand int32
const (
	SystemCommand_USER_EVENT   SystemCommand = 0 // used by other subsystem
	SystemCommand_REGISTER     SystemCommand = 1
	SystemCommand_KEEPALIVE    SystemCommand = 2
	SystemCommand_SESSION_INFO SystemCommand = 3
)

func (SystemCommand) Descriptor added in v0.0.3 

func (SystemCommand) Descriptor() protoreflect.EnumDescriptor

func (SystemCommand) Enum added in v0.0.3 

func (x SystemCommand) Enum() *SystemCommand

func (SystemCommand) EnumDescriptor deprecated added in v0.0.3 

func (SystemCommand) EnumDescriptor() ([]byte, []int)

Deprecated: Use SystemCommand.Descriptor instead.

func (SystemCommand) Number added in v0.0.3 

func (x SystemCommand) Number() protoreflect.EnumNumber

func (SystemCommand) String added in v0.0.3 

func (x SystemCommand) String() string

func (SystemCommand) Type added in v0.0.3 

func (SystemCommand) Type() protoreflect.EnumType

type SystemEvent added in v0.0.3 

type SystemEvent struct {
	Cmd        SystemCommand `protobuf:"varint,1,opt,name=cmd,proto3,enum=rpc.SystemCommand" json:"cmd,omitempty"`
	InstanceId string        `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	SessionId  string        `protobuf:"bytes,3,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Event      string        `protobuf:"bytes,4,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*SystemEvent) Descriptor deprecated added in v0.0.3 

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

Deprecated: Use SystemEvent.ProtoReflect.Descriptor instead.

func (*SystemEvent) GetCmd added in v0.0.3 

func (x *SystemEvent) GetCmd() SystemCommand

func (*SystemEvent) GetEvent added in v0.0.3 

func (x *SystemEvent) GetEvent() string

func (*SystemEvent) GetInstanceId added in v0.0.3 

func (x *SystemEvent) GetInstanceId() string

func (*SystemEvent) GetSessionId added in v0.0.3 

func (x *SystemEvent) GetSessionId() string

func (*SystemEvent) ProtoMessage added in v0.0.3 

func (*SystemEvent) ProtoMessage()

func (*SystemEvent) ProtoReflect added in v0.0.3 

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

func (*SystemEvent) Reset added in v0.0.3 

func (x *SystemEvent) Reset()

func (*SystemEvent) String added in v0.0.3 

func (x *SystemEvent) String() string

type UnimplementedMediaApiServer 

type UnimplementedMediaApiServer struct {
}

UnimplementedMediaApiServer must be embedded to have forward compatible implementations.

func (UnimplementedMediaApiServer) ExecuteAction 

func (UnimplementedMediaApiServer) ExecuteAction(context.Context, *Action) (*ActionResult, error)

func (UnimplementedMediaApiServer) ExecuteActionWithNotify 

func (UnimplementedMediaApiServer) ExecuteActionWithNotify(*Action, MediaApi_ExecuteActionWithNotifyServer) error

func (UnimplementedMediaApiServer) ExecuteActionWithPush added in v0.0.3 

func (UnimplementedMediaApiServer) ExecuteActionWithPush(MediaApi_ExecuteActionWithPushServer) error

func (UnimplementedMediaApiServer) GetVersion added in v0.0.3 

func (UnimplementedMediaApiServer) GetVersion(context.Context, *Empty) (*VersionNumber, error)

func (UnimplementedMediaApiServer) PrepareSession added in v0.0.2 

func (UnimplementedMediaApiServer) PrepareSession(context.Context, *CreateParam) (*Session, error)

func (UnimplementedMediaApiServer) StartSession 

func (UnimplementedMediaApiServer) StartSession(context.Context, *StartParam) (*Status, error)

func (UnimplementedMediaApiServer) StopSession 

func (UnimplementedMediaApiServer) StopSession(context.Context, *StopParam) (*Status, error)

func (UnimplementedMediaApiServer) SystemChannel added in v0.0.3 

func (UnimplementedMediaApiServer) SystemChannel(MediaApi_SystemChannelServer) error

func (UnimplementedMediaApiServer) UpdateSession added in v0.0.3 

func (UnimplementedMediaApiServer) UpdateSession(context.Context, *UpdateParam) (*Status, error)

type UnsafeMediaApiServer 

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

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

type UpdateParam added in v0.0.3 

type UpdateParam struct {
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	PeerIp    string `protobuf:"bytes,2,opt,name=peer_ip,json=peerIp,proto3" json:"peer_ip,omitempty"`
	PeerPort  uint32 `protobuf:"varint,3,opt,name=peer_port,json=peerPort,proto3" json:"peer_port,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateParam) Descriptor deprecated added in v0.0.3 

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

Deprecated: Use UpdateParam.ProtoReflect.Descriptor instead.

func (*UpdateParam) GetPeerIp added in v0.0.3 

func (x *UpdateParam) GetPeerIp() string

func (*UpdateParam) GetPeerPort added in v0.0.3 

func (x *UpdateParam) GetPeerPort() uint32

func (*UpdateParam) GetSessionId added in v0.0.3 

func (x *UpdateParam) GetSessionId() string

func (*UpdateParam) ProtoMessage added in v0.0.3 

func (*UpdateParam) ProtoMessage()

func (*UpdateParam) ProtoReflect added in v0.0.3 

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

func (*UpdateParam) Reset added in v0.0.3 

func (x *UpdateParam) Reset()

func (*UpdateParam) String added in v0.0.3 

func (x *UpdateParam) String() string

type Version added in v0.0.3 

type Version int32
const (
	Version_DUMMY   Version = 0 // first must be zero in proto3
	Version_DEFAULT Version = 1 // increase it every time this file being changed
)

func (Version) Descriptor added in v0.0.3 

func (Version) Descriptor() protoreflect.EnumDescriptor

func (Version) Enum added in v0.0.3 

func (x Version) Enum() *Version

func (Version) EnumDescriptor deprecated added in v0.0.3 

func (Version) EnumDescriptor() ([]byte, []int)

Deprecated: Use Version.Descriptor instead.

func (Version) Number added in v0.0.3 

func (x Version) Number() protoreflect.EnumNumber

func (Version) String added in v0.0.3 

func (x Version) String() string

func (Version) Type added in v0.0.3 

func (Version) Type() protoreflect.EnumType

type VersionNumber added in v0.0.3 

type VersionNumber struct {
	Ver Version `protobuf:"varint,2,opt,name=ver,proto3,enum=rpc.Version" json:"ver,omitempty"`
	// contains filtered or unexported fields
}

func (*VersionNumber) Descriptor deprecated added in v0.0.3 

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

Deprecated: Use VersionNumber.ProtoReflect.Descriptor instead.

func (*VersionNumber) GetVer added in v0.0.3 

func (x *VersionNumber) GetVer() Version

func (*VersionNumber) ProtoMessage added in v0.0.3 

func (*VersionNumber) ProtoMessage()

func (*VersionNumber) ProtoReflect added in v0.0.3 

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

func (*VersionNumber) Reset added in v0.0.3 

func (x *VersionNumber) Reset()

func (*VersionNumber) String added in v0.0.3 

func (x *VersionNumber) 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.