proto

package
v0.3.0 Latest Latest
Warning

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

 Go to latest Published: Jan 26, 2021 License: AGPL-3.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Trickle_Target_name = map[int32]string{
		0: "PUBLISHER",
		1: "SUBSCRIBER",
	}
	Trickle_Target_value = map[string]int32{
		"PUBLISHER":  0,
		"SUBSCRIBER": 1,
	}
)

Enum value maps for Trickle_Target.

View Source 
var (
	JobData_JobStatus_name = map[int32]string{
		0: "CREATED",
		1: "RUNNING",
		2: "STOPPED",
		3: "ERROR",
	}
	JobData_JobStatus_value = map[string]int32{
		"CREATED": 0,
		"RUNNING": 1,
		"STOPPED": 2,
		"ERROR":   3,
	}
)

Enum value maps for JobData_JobStatus.

View Source 
var File_pkg_proto_noir_proto protoreflect.FileDescriptor
View Source 
var Noir_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "noir.Noir",
	HandlerType: (*NoirServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Send",
			Handler:    _Noir_Send_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Subscribe",
			Handler:       _Noir_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Admin",
			Handler:       _Noir_Admin_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "Signal",
			Handler:       _Noir_Signal_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "pkg/proto/noir.proto",
}

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

View Source 
var SFU_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "noir.SFU",
	HandlerType: (*SFUServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Signal",
			Handler:       _SFU_Signal_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "pkg/proto/noir.proto",
}

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

Functions

func KeyNodeMap added in v0.2.1 

func KeyNodeMap() string

func KeyNodeRooms added in v0.2.1 

func KeyNodeRooms(nodeID string) string

func KeyPeerNewsChannel added in v0.2.3 

func KeyPeerNewsChannel(peerID string) string

func KeyRoomData added in v0.2.1 

func KeyRoomData(roomID string) string

func KeyRoomScores added in v0.2.7 

func KeyRoomScores() string

Scores -

func KeyRoomUsers added in v0.2.1 

func KeyRoomUsers(roomID string) string

func KeyRouterTopic added in v0.2.5 

func KeyRouterTopic() string

func KeyTopicFromAdmin added in v0.2.7 

func KeyTopicFromAdmin(clientID string) string

func KeyTopicFromJob added in v0.2.7 

func KeyTopicFromJob(jobID string) string

func KeyTopicFromPeer 

func KeyTopicFromPeer(peerID string) string

func KeyTopicToAdmin added in v0.2.7 

func KeyTopicToAdmin(clientID string) string

func KeyTopicToJob added in v0.2.7 

func KeyTopicToJob(jobID string) string

func KeyTopicToPeer 

func KeyTopicToPeer(peerID string) string

func KeyUserData added in v0.2.1 

func KeyUserData(userID string) string

func KeyWorkerTopic 

func KeyWorkerTopic(nodeID string) string

func RegisterNoirServer added in v0.2.7 

func RegisterNoirServer(s grpc.ServiceRegistrar, srv NoirServer)

func RegisterSFUServer added in v0.2.7 

func RegisterSFUServer(s grpc.ServiceRegistrar, srv SFUServer)

Types

type AdminClient added in v0.2.7 

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

GRPC ADMIN API

func (*AdminClient) Descriptor deprecated added in v0.2.7 

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

Deprecated: Use AdminClient.ProtoReflect.Descriptor instead.

func (*AdminClient) GetClientID added in v0.2.7 

func (x *AdminClient) GetClientID() string

func (*AdminClient) ProtoMessage added in v0.2.7 

func (*AdminClient) ProtoMessage()

func (*AdminClient) ProtoReflect added in v0.2.7 

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

func (*AdminClient) Reset added in v0.2.7 

func (x *AdminClient) Reset()

func (*AdminClient) String added in v0.2.7 

func (x *AdminClient) String() string

type AdminReply added in v0.2.7 

type AdminReply struct {

	// Types that are assignable to Payload:
	//	*AdminReply_Error
	//	*AdminReply_RoomAdmin
	//	*AdminReply_RoomCount
	//	*AdminReply_RoomList
	Payload isAdminReply_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*AdminReply) Descriptor deprecated added in v0.2.7 

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

Deprecated: Use AdminReply.ProtoReflect.Descriptor instead.

func (*AdminReply) GetError added in v0.2.7 

func (x *AdminReply) GetError() string

func (*AdminReply) GetPayload added in v0.2.7 

func (m *AdminReply) GetPayload() isAdminReply_Payload

func (*AdminReply) GetRoomAdmin added in v0.2.7 

func (x *AdminReply) GetRoomAdmin() *RoomAdminReply

func (*AdminReply) GetRoomCount added in v0.2.7 

func (x *AdminReply) GetRoomCount() *RoomCountReply

func (*AdminReply) GetRoomList added in v0.2.7 

func (x *AdminReply) GetRoomList() *RoomListReply

func (*AdminReply) ProtoMessage added in v0.2.7 

func (*AdminReply) ProtoMessage()

func (*AdminReply) ProtoReflect added in v0.2.7 

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

func (*AdminReply) Reset added in v0.2.7 

func (x *AdminReply) Reset()

func (*AdminReply) String added in v0.2.7 

func (x *AdminReply) String() string

type AdminReply_Error added in v0.2.7 

type AdminReply_Error struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3,oneof"`
}

type AdminReply_RoomAdmin added in v0.2.7 

type AdminReply_RoomAdmin struct {
	RoomAdmin *RoomAdminReply `protobuf:"bytes,2,opt,name=roomAdmin,proto3,oneof"`
}

type AdminReply_RoomCount added in v0.2.7 

type AdminReply_RoomCount struct {
	RoomCount *RoomCountReply `protobuf:"bytes,3,opt,name=roomCount,proto3,oneof"`
}

type AdminReply_RoomList added in v0.2.7 

type AdminReply_RoomList struct {
	RoomList *RoomListReply `protobuf:"bytes,4,opt,name=roomList,proto3,oneof"`
}

type AdminRequest added in v0.2.7 

type AdminRequest struct {

	// Types that are assignable to Payload:
	//	*AdminRequest_RoomAdmin
	//	*AdminRequest_RoomCount
	//	*AdminRequest_RoomList
	Payload isAdminRequest_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

**************************************************** Admin Commands ***************************************************

func (*AdminRequest) Descriptor deprecated added in v0.2.7 

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

Deprecated: Use AdminRequest.ProtoReflect.Descriptor instead.

func (*AdminRequest) GetPayload added in v0.2.7 

func (m *AdminRequest) GetPayload() isAdminRequest_Payload

func (*AdminRequest) GetRoomAdmin added in v0.2.7 

func (x *AdminRequest) GetRoomAdmin() *RoomAdminRequest

func (*AdminRequest) GetRoomCount added in v0.2.7 

func (x *AdminRequest) GetRoomCount() *RoomCountRequest

func (*AdminRequest) GetRoomList added in v0.2.7 

func (x *AdminRequest) GetRoomList() *RoomListRequest

func (*AdminRequest) ProtoMessage added in v0.2.7 

func (*AdminRequest) ProtoMessage()

func (*AdminRequest) ProtoReflect added in v0.2.7 

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

func (*AdminRequest) Reset added in v0.2.7 

func (x *AdminRequest) Reset()

func (*AdminRequest) String added in v0.2.7 

func (x *AdminRequest) String() string

type AdminRequest_RoomAdmin added in v0.2.7 

type AdminRequest_RoomAdmin struct {
	RoomAdmin *RoomAdminRequest `protobuf:"bytes,1,opt,name=roomAdmin,proto3,oneof"`
}

type AdminRequest_RoomCount added in v0.2.7 

type AdminRequest_RoomCount struct {
	RoomCount *RoomCountRequest `protobuf:"bytes,2,opt,name=roomCount,proto3,oneof"`
}

type AdminRequest_RoomList added in v0.2.7 

type AdminRequest_RoomList struct {
	RoomList *RoomListRequest `protobuf:"bytes,3,opt,name=roomList,proto3,oneof"`
}

type CreateRoomReply added in v0.2.7 

type CreateRoomReply struct {
	Options *RoomOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateRoomReply) Descriptor deprecated added in v0.2.7 

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

Deprecated: Use CreateRoomReply.ProtoReflect.Descriptor instead.

func (*CreateRoomReply) GetOptions added in v0.2.7 

func (x *CreateRoomReply) GetOptions() *RoomOptions

func (*CreateRoomReply) ProtoMessage added in v0.2.7 

func (*CreateRoomReply) ProtoMessage()

func (*CreateRoomReply) ProtoReflect added in v0.2.7 

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

func (*CreateRoomReply) Reset added in v0.2.7 

func (x *CreateRoomReply) Reset()

func (*CreateRoomReply) String added in v0.2.7 

func (x *CreateRoomReply) String() string

type CreateRoomRequest added in v0.2.7 

type CreateRoomRequest struct {
	Options *RoomOptions `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateRoomRequest) Descriptor deprecated added in v0.2.7 

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

Deprecated: Use CreateRoomRequest.ProtoReflect.Descriptor instead.

func (*CreateRoomRequest) GetOptions added in v0.2.7 

func (x *CreateRoomRequest) GetOptions() *RoomOptions

func (*CreateRoomRequest) ProtoMessage added in v0.2.7 

func (*CreateRoomRequest) ProtoMessage()

func (*CreateRoomRequest) ProtoReflect added in v0.2.7 

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

func (*CreateRoomRequest) Reset added in v0.2.7 

func (x *CreateRoomRequest) Reset()

func (*CreateRoomRequest) String added in v0.2.7 

func (x *CreateRoomRequest) String() string

type Empty added in v0.2.7 

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

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

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage added in v0.2.7 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect added in v0.2.7 

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

func (*Empty) Reset added in v0.2.7 

func (x *Empty) Reset()

func (*Empty) String added in v0.2.7 

func (x *Empty) String() string

type JobData added in v0.2.7 

type JobData struct {
	Id         string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Handler    string               `protobuf:"bytes,2,opt,name=handler,proto3" json:"handler,omitempty"`
	Status     JobData_JobStatus    `protobuf:"varint,3,opt,name=status,proto3,enum=noir.JobData_JobStatus" json:"status,omitempty"`
	Created    *timestamp.Timestamp `protobuf:"bytes,4,opt,name=created,proto3" json:"created,omitempty"`
	LastUpdate *timestamp.Timestamp `protobuf:"bytes,5,opt,name=lastUpdate,proto3" json:"lastUpdate,omitempty"`
	NodeID     string               `protobuf:"bytes,6,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	// contains filtered or unexported fields
}

func (*JobData) Descriptor deprecated added in v0.2.7 

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

Deprecated: Use JobData.ProtoReflect.Descriptor instead.

func (*JobData) GetCreated added in v0.2.7 

func (x *JobData) GetCreated() *timestamp.Timestamp

func (*JobData) GetHandler added in v0.2.7 

func (x *JobData) GetHandler() string

func (*JobData) GetId added in v0.2.7 

func (x *JobData) GetId() string

func (*JobData) GetLastUpdate added in v0.2.7 

func (x *JobData) GetLastUpdate() *timestamp.Timestamp

func (*JobData) GetNodeID added in v0.2.7 

func (x *JobData) GetNodeID() string

func (*JobData) GetStatus added in v0.2.7 

func (x *JobData) GetStatus() JobData_JobStatus

func (*JobData) ProtoMessage added in v0.2.7 

func (*JobData) ProtoMessage()

func (*JobData) ProtoReflect added in v0.2.7 

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

func (*JobData) Reset added in v0.2.7 

func (x *JobData) Reset()

func (*JobData) String added in v0.2.7 

func (x *JobData) String() string

type JobData_JobStatus added in v0.2.7 

type JobData_JobStatus int32
const (
	JobData_CREATED JobData_JobStatus = 0
	JobData_RUNNING JobData_JobStatus = 1
	JobData_STOPPED JobData_JobStatus = 2
	JobData_ERROR   JobData_JobStatus = 3
)

func (JobData_JobStatus) Descriptor added in v0.2.7 

func (JobData_JobStatus) Descriptor() protoreflect.EnumDescriptor

func (JobData_JobStatus) Enum added in v0.2.7 

func (x JobData_JobStatus) Enum() *JobData_JobStatus

func (JobData_JobStatus) EnumDescriptor deprecated added in v0.2.7 

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

Deprecated: Use JobData_JobStatus.Descriptor instead.

func (JobData_JobStatus) Number added in v0.2.7 

func (x JobData_JobStatus) Number() protoreflect.EnumNumber

func (JobData_JobStatus) String added in v0.2.7 

func (x JobData_JobStatus) String() string

func (JobData_JobStatus) Type added in v0.2.7 

func (JobData_JobStatus) Type() protoreflect.EnumType

type JoinReply 

type JoinReply struct {
	Description []byte `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*JoinReply) Descriptor deprecated 

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

Deprecated: Use JoinReply.ProtoReflect.Descriptor instead.

func (*JoinReply) GetDescription 

func (x *JoinReply) GetDescription() []byte

func (*JoinReply) ProtoMessage 

func (*JoinReply) ProtoMessage()

func (*JoinReply) ProtoReflect 

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

func (*JoinReply) Reset 

func (x *JoinReply) Reset()

func (*JoinReply) String 

func (x *JoinReply) String() string

type JoinRequest 

type JoinRequest struct {
	Sid         string `protobuf:"bytes,1,opt,name=sid,proto3" json:"sid,omitempty"`
	Description []byte `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*JoinRequest) Descriptor deprecated 

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

Deprecated: Use JoinRequest.ProtoReflect.Descriptor instead.

func (*JoinRequest) GetDescription 

func (x *JoinRequest) GetDescription() []byte

func (*JoinRequest) GetSid 

func (x *JoinRequest) GetSid() string

func (*JoinRequest) ProtoMessage 

func (*JoinRequest) ProtoMessage()

func (*JoinRequest) ProtoReflect 

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

func (*JoinRequest) Reset 

func (x *JoinRequest) Reset()

func (*JoinRequest) String 

func (x *JoinRequest) String() string

type NodeData added in v0.2.1 

type NodeData struct {
	Id         string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	LastUpdate *timestamp.Timestamp `protobuf:"bytes,2,opt,name=lastUpdate,proto3" json:"lastUpdate,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeData) Descriptor deprecated added in v0.2.1 

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

Deprecated: Use NodeData.ProtoReflect.Descriptor instead.

func (*NodeData) GetId added in v0.2.1 

func (x *NodeData) GetId() string

func (*NodeData) GetLastUpdate added in v0.2.1 

func (x *NodeData) GetLastUpdate() *timestamp.Timestamp

func (*NodeData) ProtoMessage added in v0.2.1 

func (*NodeData) ProtoMessage()

func (*NodeData) ProtoReflect added in v0.2.1 

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

func (*NodeData) Reset added in v0.2.1 

func (x *NodeData) Reset()

func (*NodeData) String added in v0.2.1 

func (x *NodeData) String() string

type NoirClient added in v0.2.7 

type NoirClient interface {
	Subscribe(ctx context.Context, in *AdminClient, opts ...grpc.CallOption) (Noir_SubscribeClient, error)
	Send(ctx context.Context, in *NoirRequest, opts ...grpc.CallOption) (*Empty, error)
	Admin(ctx context.Context, opts ...grpc.CallOption) (Noir_AdminClient, error)
	Signal(ctx context.Context, opts ...grpc.CallOption) (Noir_SignalClient, error)
}

NoirClient is the client API for Noir 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 NewNoirClient added in v0.2.7 

func NewNoirClient(cc grpc.ClientConnInterface) NoirClient

type NoirObject added in v0.2.1 

type NoirObject struct {

	// Types that are assignable to Data:
	//	*NoirObject_Node
	//	*NoirObject_Room
	//	*NoirObject_User
	Data isNoirObject_Data `protobuf_oneof:"data"`
	// contains filtered or unexported fields
}

func (*NoirObject) Descriptor deprecated added in v0.2.1 

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

Deprecated: Use NoirObject.ProtoReflect.Descriptor instead.

func (*NoirObject) GetData added in v0.2.1 

func (m *NoirObject) GetData() isNoirObject_Data

func (*NoirObject) GetNode added in v0.2.1 

func (x *NoirObject) GetNode() *NodeData

func (*NoirObject) GetRoom added in v0.2.1 

func (x *NoirObject) GetRoom() *RoomData

func (*NoirObject) GetUser added in v0.2.1 

func (x *NoirObject) GetUser() *UserData

func (*NoirObject) ProtoMessage added in v0.2.1 

func (*NoirObject) ProtoMessage()

func (*NoirObject) ProtoReflect added in v0.2.1 

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

func (*NoirObject) Reset added in v0.2.1 

func (x *NoirObject) Reset()

func (*NoirObject) String added in v0.2.1 

func (x *NoirObject) String() string

type NoirObject_Node added in v0.2.1 

type NoirObject_Node struct {
	Node *NodeData `protobuf:"bytes,1,opt,name=node,proto3,oneof"`
}

type NoirObject_Room added in v0.2.1 

type NoirObject_Room struct {
	Room *RoomData `protobuf:"bytes,2,opt,name=room,proto3,oneof"`
}

type NoirObject_User added in v0.2.1 

type NoirObject_User struct {
	User *UserData `protobuf:"bytes,3,opt,name=user,proto3,oneof"`
}

type NoirReply 

type NoirReply struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	At string `protobuf:"bytes,2,opt,name=at,proto3" json:"at,omitempty"`
	// Types that are assignable to Command:
	//	*NoirReply_Signal
	//	*NoirReply_Admin
	//	*NoirReply_Error
	Command isNoirReply_Command `protobuf_oneof:"command"`
	// contains filtered or unexported fields
}

func (*NoirReply) Descriptor deprecated 

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

Deprecated: Use NoirReply.ProtoReflect.Descriptor instead.

func (*NoirReply) GetAdmin added in v0.2.7 

func (x *NoirReply) GetAdmin() *AdminReply

func (*NoirReply) GetAt 

func (x *NoirReply) GetAt() string

func (*NoirReply) GetCommand 

func (m *NoirReply) GetCommand() isNoirReply_Command

func (*NoirReply) GetError 

func (x *NoirReply) GetError() string

func (*NoirReply) GetId 

func (x *NoirReply) GetId() string

func (*NoirReply) GetSignal 

func (x *NoirReply) GetSignal() *SignalReply

func (*NoirReply) ProtoMessage 

func (*NoirReply) ProtoMessage()

func (*NoirReply) ProtoReflect 

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

func (*NoirReply) Reset 

func (x *NoirReply) Reset()

func (*NoirReply) String 

func (x *NoirReply) String() string

type NoirReply_Admin added in v0.2.7 

type NoirReply_Admin struct {
	Admin *AdminReply `protobuf:"bytes,4,opt,name=admin,proto3,oneof"`
}

type NoirReply_Error 

type NoirReply_Error struct {
	Error string `protobuf:"bytes,5,opt,name=error,proto3,oneof"`
}

type NoirReply_Signal 

type NoirReply_Signal struct {
	Signal *SignalReply `protobuf:"bytes,3,opt,name=signal,proto3,oneof"`
}

type NoirRequest 

type NoirRequest struct {
	Id     string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	At     string `protobuf:"bytes,2,opt,name=at,proto3" json:"at,omitempty"`
	Action string `protobuf:"bytes,3,opt,name=action,proto3" json:"action,omitempty"`
	// Types that are assignable to Command:
	//	*NoirRequest_Signal
	//	*NoirRequest_Admin
	Command isNoirRequest_Command `protobuf_oneof:"command"`
	AdminID string                `protobuf:"bytes,6,opt,name=adminID,proto3" json:"adminID,omitempty"`
	// contains filtered or unexported fields
}

func (*NoirRequest) Descriptor deprecated 

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

Deprecated: Use NoirRequest.ProtoReflect.Descriptor instead.

func (*NoirRequest) GetAction 

func (x *NoirRequest) GetAction() string

func (*NoirRequest) GetAdmin added in v0.2.7 

func (x *NoirRequest) GetAdmin() *AdminRequest

func (*NoirRequest) GetAdminID added in v0.2.7 

func (x *NoirRequest) GetAdminID() string

func (*NoirRequest) GetAt 

func (x *NoirRequest) GetAt() string

func (*NoirRequest) GetCommand 

func (m *NoirRequest) GetCommand() isNoirRequest_Command

func (*NoirRequest) GetId 

func (x *NoirRequest) GetId() string

func (*NoirRequest) GetSignal 

func (x *NoirRequest) GetSignal() *SignalRequest

func (*NoirRequest) ProtoMessage 

func (*NoirRequest) ProtoMessage()

func (*NoirRequest) ProtoReflect 

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

func (*NoirRequest) Reset 

func (x *NoirRequest) Reset()

func (*NoirRequest) String 

func (x *NoirRequest) String() string

type NoirRequest_Admin added in v0.2.7 

type NoirRequest_Admin struct {
	Admin *AdminRequest `protobuf:"bytes,5,opt,name=admin,proto3,oneof"`
}

type NoirRequest_Signal 

type NoirRequest_Signal struct {
	Signal *SignalRequest `protobuf:"bytes,4,opt,name=signal,proto3,oneof"`
}

type NoirServer added in v0.2.7 

type NoirServer interface {
	Subscribe(*AdminClient, Noir_SubscribeServer) error
	Send(context.Context, *NoirRequest) (*Empty, error)
	Admin(Noir_AdminServer) error
	Signal(Noir_SignalServer) error
	// contains filtered or unexported methods
}

NoirServer is the server API for Noir service. All implementations must embed UnimplementedNoirServer for forward compatibility

type Noir_AdminClient added in v0.2.7 

type Noir_AdminClient interface {
	Send(*NoirRequest) error
	Recv() (*NoirReply, error)
	grpc.ClientStream
}

type Noir_AdminServer added in v0.2.7 

type Noir_AdminServer interface {
	Send(*NoirReply) error
	Recv() (*NoirRequest, error)
	grpc.ServerStream
}

type Noir_SignalClient added in v0.2.7 

type Noir_SignalClient interface {
	Send(*SignalRequest) error
	Recv() (*SignalReply, error)
	grpc.ClientStream
}

type Noir_SignalServer added in v0.2.7 

type Noir_SignalServer interface {
	Send(*SignalReply) error
	Recv() (*SignalRequest, error)
	grpc.ServerStream
}

type Noir_SubscribeClient added in v0.2.7 

type Noir_SubscribeClient interface {
	Recv() (*NoirReply, error)
	grpc.ClientStream
}

type Noir_SubscribeServer added in v0.2.7 

type Noir_SubscribeServer interface {
	Send(*NoirReply) error
	grpc.ServerStream
}

type PeerJobData added in v0.2.7 

type PeerJobData struct {
	RoomID          string   `protobuf:"bytes,1,opt,name=roomID,proto3" json:"roomID,omitempty"`
	UserID          string   `protobuf:"bytes,2,opt,name=userID,proto3" json:"userID,omitempty"`
	PublishTracks   []string `protobuf:"bytes,3,rep,name=publishTracks,proto3" json:"publishTracks,omitempty"`
	SubscribeTracks []string `protobuf:"bytes,4,rep,name=subscribeTracks,proto3" json:"subscribeTracks,omitempty"`
	// contains filtered or unexported fields
}

func (*PeerJobData) Descriptor deprecated added in v0.2.7 

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

Deprecated: Use PeerJobData.ProtoReflect.Descriptor instead.

func (*PeerJobData) GetPublishTracks added in v0.2.7 

func (x *PeerJobData) GetPublishTracks() []string

func (*PeerJobData) GetRoomID added in v0.2.7 

func (x *PeerJobData) GetRoomID() string

func (*PeerJobData) GetSubscribeTracks added in v0.2.7 

func (x *PeerJobData) GetSubscribeTracks() []string

func (*PeerJobData) GetUserID added in v0.3.0 

func (x *PeerJobData) GetUserID() string

func (*PeerJobData) ProtoMessage added in v0.2.7 

func (*PeerJobData) ProtoMessage()

func (*PeerJobData) ProtoReflect added in v0.2.7 

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

func (*PeerJobData) Reset added in v0.2.7 

func (x *PeerJobData) Reset()

func (*PeerJobData) String added in v0.2.7 

func (x *PeerJobData) String() string

type RoomAdminReply added in v0.2.1 

type RoomAdminReply struct {
	RoomID string `protobuf:"bytes,1,opt,name=roomID,proto3" json:"roomID,omitempty"`
	// Types that are assignable to Payload:
	//	*RoomAdminReply_Error
	//	*RoomAdminReply_CreateRoom
	//	*RoomAdminReply_RoomJob
	Payload isRoomAdminReply_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*RoomAdminReply) Descriptor deprecated added in v0.2.1 

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

Deprecated: Use RoomAdminReply.ProtoReflect.Descriptor instead.

func (*RoomAdminReply) GetCreateRoom added in v0.2.7 

func (x *RoomAdminReply) GetCreateRoom() *CreateRoomReply

func (*RoomAdminReply) GetError added in v0.2.1 

func (x *RoomAdminReply) GetError() string

func (*RoomAdminReply) GetPayload added in v0.2.1 

func (m *RoomAdminReply) GetPayload() isRoomAdminReply_Payload

func (*RoomAdminReply) GetRoomID added in v0.2.1 

func (x *RoomAdminReply) GetRoomID() string

func (*RoomAdminReply) GetRoomJob added in v0.2.7 

func (x *RoomAdminReply) GetRoomJob() *RoomJobReply

func (*RoomAdminReply) ProtoMessage added in v0.2.1 

func (*RoomAdminReply) ProtoMessage()

func (*RoomAdminReply) ProtoReflect added in v0.2.1 

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

func (*RoomAdminReply) Reset added in v0.2.1 

func (x *RoomAdminReply) Reset()

func (*RoomAdminReply) String added in v0.2.1 

func (x *RoomAdminReply) String() string

type RoomAdminReply_CreateRoom added in v0.2.7 

type RoomAdminReply_CreateRoom struct {
	CreateRoom *CreateRoomReply `protobuf:"bytes,3,opt,name=createRoom,proto3,oneof"`
}

type RoomAdminReply_Error added in v0.2.1 

type RoomAdminReply_Error struct {
	Error string `protobuf:"bytes,2,opt,name=error,proto3,oneof"`
}

type RoomAdminReply_RoomJob added in v0.2.7 

type RoomAdminReply_RoomJob struct {
	RoomJob *RoomJobReply `protobuf:"bytes,4,opt,name=roomJob,proto3,oneof"`
}

type RoomAdminRequest added in v0.2.1 

type RoomAdminRequest struct {
	RoomID string `protobuf:"bytes,1,opt,name=roomID,proto3" json:"roomID,omitempty"`
	// Types that are assignable to Method:
	//	*RoomAdminRequest_CreateRoom
	//	*RoomAdminRequest_RoomJob
	Method isRoomAdminRequest_Method `protobuf_oneof:"method"`
	// contains filtered or unexported fields
}

func (*RoomAdminRequest) Descriptor deprecated added in v0.2.1 

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

Deprecated: Use RoomAdminRequest.ProtoReflect.Descriptor instead.

func (*RoomAdminRequest) GetCreateRoom added in v0.2.7 

func (x *RoomAdminRequest) GetCreateRoom() *CreateRoomRequest

func (*RoomAdminRequest) GetMethod added in v0.2.7 

func (m *RoomAdminRequest) GetMethod() isRoomAdminRequest_Method

func (*RoomAdminRequest) GetRoomID added in v0.2.1 

func (x *RoomAdminRequest) GetRoomID() string

func (*RoomAdminRequest) GetRoomJob added in v0.2.7 

func (x *RoomAdminRequest) GetRoomJob() *RoomJobRequest

func (*RoomAdminRequest) ProtoMessage added in v0.2.1 

func (*RoomAdminRequest) ProtoMessage()

func (*RoomAdminRequest) ProtoReflect added in v0.2.1 

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

func (*RoomAdminRequest) Reset added in v0.2.1 

func (x *RoomAdminRequest) Reset()

func (*RoomAdminRequest) String added in v0.2.1 

func (x *RoomAdminRequest) String() string

type RoomAdminRequest_CreateRoom added in v0.2.7 

type RoomAdminRequest_CreateRoom struct {
	CreateRoom *CreateRoomRequest `protobuf:"bytes,2,opt,name=createRoom,proto3,oneof"`
}

type RoomAdminRequest_RoomJob added in v0.2.7 

type RoomAdminRequest_RoomJob struct {
	RoomJob *RoomJobRequest `protobuf:"bytes,3,opt,name=roomJob,proto3,oneof"`
}

type RoomCountReply added in v0.2.7 

type RoomCountReply struct {
	Result int64 `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*RoomCountReply) Descriptor deprecated added in v0.2.7 

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

Deprecated: Use RoomCountReply.ProtoReflect.Descriptor instead.

func (*RoomCountReply) GetResult added in v0.2.7 

func (x *RoomCountReply) GetResult() int64

func (*RoomCountReply) ProtoMessage added in v0.2.7 

func (*RoomCountReply) ProtoMessage()

func (*RoomCountReply) ProtoReflect added in v0.2.7 

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

func (*RoomCountReply) Reset added in v0.2.7 

func (x *RoomCountReply) Reset()

func (*RoomCountReply) String added in v0.2.7 

func (x *RoomCountReply) String() string

type RoomCountRequest added in v0.2.7 

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

func (*RoomCountRequest) Descriptor deprecated added in v0.2.7 

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

Deprecated: Use RoomCountRequest.ProtoReflect.Descriptor instead.

func (*RoomCountRequest) ProtoMessage added in v0.2.7 

func (*RoomCountRequest) ProtoMessage()

func (*RoomCountRequest) ProtoReflect added in v0.2.7 

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

func (*RoomCountRequest) Reset added in v0.2.7 

func (x *RoomCountRequest) Reset()

func (*RoomCountRequest) String added in v0.2.7 

func (x *RoomCountRequest) String() string

type RoomData added in v0.2.1 

type RoomData struct {
	Id         string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Created    *timestamp.Timestamp `protobuf:"bytes,2,opt,name=created,proto3" json:"created,omitempty"`
	LastUpdate *timestamp.Timestamp `protobuf:"bytes,3,opt,name=lastUpdate,proto3" json:"lastUpdate,omitempty"`
	NodeID     string               `protobuf:"bytes,4,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	Options    *RoomOptions         `protobuf:"bytes,5,opt,name=options,proto3" json:"options,omitempty"`
	Publisher  string               `protobuf:"bytes,6,opt,name=publisher,proto3" json:"publisher,omitempty"`
	// contains filtered or unexported fields
}

func (*RoomData) Descriptor deprecated added in v0.2.1 

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

Deprecated: Use RoomData.ProtoReflect.Descriptor instead.

func (*RoomData) GetCreated added in v0.2.1 

func (x *RoomData) GetCreated() *timestamp.Timestamp

func (*RoomData) GetId added in v0.2.1 

func (x *RoomData) GetId() string

func (*RoomData) GetLastUpdate added in v0.2.1 

func (x *RoomData) GetLastUpdate() *timestamp.Timestamp

func (*RoomData) GetNodeID added in v0.2.1 

func (x *RoomData) GetNodeID() string

func (*RoomData) GetOptions added in v0.2.1 

func (x *RoomData) GetOptions() *RoomOptions

func (*RoomData) GetPublisher added in v0.2.1 

func (x *RoomData) GetPublisher() string

func (*RoomData) ProtoMessage added in v0.2.1 

func (*RoomData) ProtoMessage()

func (*RoomData) ProtoReflect added in v0.2.1 

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

func (*RoomData) Reset added in v0.2.1 

func (x *RoomData) Reset()

func (*RoomData) String added in v0.2.1 

func (x *RoomData) String() string

type RoomJobReply added in v0.2.7 

type RoomJobReply struct {
	Handler string `protobuf:"bytes,1,opt,name=handler,proto3" json:"handler,omitempty"`
	Pid     string `protobuf:"bytes,2,opt,name=pid,proto3" json:"pid,omitempty"` // peer id will be random if not specified
	Status  bool   `protobuf:"varint,3,opt,name=status,proto3" json:"status,omitempty"`
	Options []byte `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*RoomJobReply) Descriptor deprecated added in v0.2.7 

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

Deprecated: Use RoomJobReply.ProtoReflect.Descriptor instead.

func (*RoomJobReply) GetHandler added in v0.2.7 

func (x *RoomJobReply) GetHandler() string

func (*RoomJobReply) GetOptions added in v0.2.7 

func (x *RoomJobReply) GetOptions() []byte

func (*RoomJobReply) GetPid added in v0.2.7 

func (x *RoomJobReply) GetPid() string

func (*RoomJobReply) GetStatus added in v0.2.7 

func (x *RoomJobReply) GetStatus() bool

func (*RoomJobReply) ProtoMessage added in v0.2.7 

func (*RoomJobReply) ProtoMessage()

func (*RoomJobReply) ProtoReflect added in v0.2.7 

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

func (*RoomJobReply) Reset added in v0.2.7 

func (x *RoomJobReply) Reset()

func (*RoomJobReply) String added in v0.2.7 

func (x *RoomJobReply) String() string

type RoomJobRequest added in v0.2.7 

type RoomJobRequest struct {
	Handler string `protobuf:"bytes,1,opt,name=handler,proto3" json:"handler,omitempty"`
	Pid     string `protobuf:"bytes,2,opt,name=pid,proto3" json:"pid,omitempty"` // peer id will be random if not specified
	Options []byte `protobuf:"bytes,3,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*RoomJobRequest) Descriptor deprecated added in v0.2.7 

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

Deprecated: Use RoomJobRequest.ProtoReflect.Descriptor instead.

func (*RoomJobRequest) GetHandler added in v0.2.7 

func (x *RoomJobRequest) GetHandler() string

func (*RoomJobRequest) GetOptions added in v0.2.7 

func (x *RoomJobRequest) GetOptions() []byte

func (*RoomJobRequest) GetPid added in v0.2.7 

func (x *RoomJobRequest) GetPid() string

func (*RoomJobRequest) ProtoMessage added in v0.2.7 

func (*RoomJobRequest) ProtoMessage()

func (*RoomJobRequest) ProtoReflect added in v0.2.7 

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

func (*RoomJobRequest) Reset added in v0.2.7 

func (x *RoomJobRequest) Reset()

func (*RoomJobRequest) String added in v0.2.7 

func (x *RoomJobRequest) String() string

type RoomListEntry added in v0.2.7 

type RoomListEntry struct {
	Id    string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Score int64  `protobuf:"varint,2,opt,name=score,proto3" json:"score,omitempty"`
	// contains filtered or unexported fields
}

func (*RoomListEntry) Descriptor deprecated added in v0.2.7 

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

Deprecated: Use RoomListEntry.ProtoReflect.Descriptor instead.

func (*RoomListEntry) GetId added in v0.2.7 

func (x *RoomListEntry) GetId() string

func (*RoomListEntry) GetScore added in v0.2.7 

func (x *RoomListEntry) GetScore() int64

func (*RoomListEntry) ProtoMessage added in v0.2.7 

func (*RoomListEntry) ProtoMessage()

func (*RoomListEntry) ProtoReflect added in v0.2.7 

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

func (*RoomListEntry) Reset added in v0.2.7 

func (x *RoomListEntry) Reset()

func (*RoomListEntry) String added in v0.2.7 

func (x *RoomListEntry) String() string

type RoomListReply added in v0.2.7 

type RoomListReply struct {
	Count  int64            `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	Result []*RoomListEntry `protobuf:"bytes,2,rep,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*RoomListReply) Descriptor deprecated added in v0.2.7 

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

Deprecated: Use RoomListReply.ProtoReflect.Descriptor instead.

func (*RoomListReply) GetCount added in v0.2.7 

func (x *RoomListReply) GetCount() int64

func (*RoomListReply) GetResult added in v0.2.7 

func (x *RoomListReply) GetResult() []*RoomListEntry

func (*RoomListReply) ProtoMessage added in v0.2.7 

func (*RoomListReply) ProtoMessage()

func (*RoomListReply) ProtoReflect added in v0.2.7 

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

func (*RoomListReply) Reset added in v0.2.7 

func (x *RoomListReply) Reset()

func (*RoomListReply) String added in v0.2.7 

func (x *RoomListReply) String() string

type RoomListRequest added in v0.2.7 

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

func (*RoomListRequest) Descriptor deprecated added in v0.2.7 

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

Deprecated: Use RoomListRequest.ProtoReflect.Descriptor instead.

func (*RoomListRequest) ProtoMessage added in v0.2.7 

func (*RoomListRequest) ProtoMessage()

func (*RoomListRequest) ProtoReflect added in v0.2.7 

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

func (*RoomListRequest) Reset added in v0.2.7 

func (x *RoomListRequest) Reset()

func (*RoomListRequest) String added in v0.2.7 

func (x *RoomListRequest) String() string

type RoomOptions added in v0.2.1 

type RoomOptions struct {
	Debug           int32  `protobuf:"varint,1,opt,name=debug,proto3" json:"debug,omitempty"`
	Title           string `protobuf:"bytes,2,opt,name=title,proto3" json:"title,omitempty"`
	MaxAgeSeconds   int32  `protobuf:"varint,3,opt,name=maxAgeSeconds,proto3" json:"maxAgeSeconds,omitempty"`
	KeyExpiryFactor int32  `protobuf:"varint,4,opt,name=keyExpiryFactor,proto3" json:"keyExpiryFactor,omitempty"`
	JoinPassword    string `protobuf:"bytes,5,opt,name=joinPassword,proto3" json:"joinPassword,omitempty"`
	PublishPassword string `protobuf:"bytes,6,opt,name=publishPassword,proto3" json:"publishPassword,omitempty"`
	MaxPeers        int32  `protobuf:"varint,7,opt,name=maxPeers,proto3" json:"maxPeers,omitempty"`
	IsChannel       bool   `protobuf:"varint,8,opt,name=isChannel,proto3" json:"isChannel,omitempty"`
	// contains filtered or unexported fields
}

func (*RoomOptions) Descriptor deprecated added in v0.2.1 

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

Deprecated: Use RoomOptions.ProtoReflect.Descriptor instead.

func (*RoomOptions) GetDebug added in v0.2.1 

func (x *RoomOptions) GetDebug() int32

func (*RoomOptions) GetIsChannel added in v0.2.1 

func (x *RoomOptions) GetIsChannel() bool

func (*RoomOptions) GetJoinPassword added in v0.2.1 

func (x *RoomOptions) GetJoinPassword() string

func (*RoomOptions) GetKeyExpiryFactor added in v0.2.1 

func (x *RoomOptions) GetKeyExpiryFactor() int32

func (*RoomOptions) GetMaxAgeSeconds added in v0.2.1 

func (x *RoomOptions) GetMaxAgeSeconds() int32

func (*RoomOptions) GetMaxPeers added in v0.2.1 

func (x *RoomOptions) GetMaxPeers() int32

func (*RoomOptions) GetPublishPassword added in v0.2.1 

func (x *RoomOptions) GetPublishPassword() string

func (*RoomOptions) GetTitle added in v0.2.1 

func (x *RoomOptions) GetTitle() string

func (*RoomOptions) ProtoMessage added in v0.2.1 

func (*RoomOptions) ProtoMessage()

func (*RoomOptions) ProtoReflect added in v0.2.1 

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

func (*RoomOptions) Reset added in v0.2.1 

func (x *RoomOptions) Reset()

func (*RoomOptions) String added in v0.2.1 

func (x *RoomOptions) String() string

type SFUClient added in v0.2.7 

type SFUClient interface {
	Signal(ctx context.Context, opts ...grpc.CallOption) (SFU_SignalClient, error)
}

SFUClient is the client API for SFU 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 NewSFUClient added in v0.2.7 

func NewSFUClient(cc grpc.ClientConnInterface) SFUClient

type SFUServer added in v0.2.7 

type SFUServer interface {
	Signal(SFU_SignalServer) error
	// contains filtered or unexported methods
}

SFUServer is the server API for SFU service. All implementations must embed UnimplementedSFUServer for forward compatibility

type SFU_SignalClient added in v0.2.7 

type SFU_SignalClient interface {
	Send(*SignalRequest) error
	Recv() (*SignalReply, error)
	grpc.ClientStream
}

type SFU_SignalServer added in v0.2.7 

type SFU_SignalServer interface {
	Send(*SignalReply) error
	Recv() (*SignalRequest, error)
	grpc.ServerStream
}

type SignalReply 

type SignalReply struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to Payload:
	//	*SignalReply_Join
	//	*SignalReply_Description
	//	*SignalReply_Trickle
	//	*SignalReply_IceConnectionState
	//	*SignalReply_Error
	//	*SignalReply_Kill
	Payload   isSignalReply_Payload `protobuf_oneof:"payload"`
	RequestId string                `protobuf:"bytes,8,opt,name=requestId,proto3" json:"requestId,omitempty"` // optional, for requests with replies
	// contains filtered or unexported fields
}

func (*SignalReply) Descriptor deprecated 

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

Deprecated: Use SignalReply.ProtoReflect.Descriptor instead.

func (*SignalReply) GetDescription 

func (x *SignalReply) GetDescription() []byte

func (*SignalReply) GetError 

func (x *SignalReply) GetError() string

func (*SignalReply) GetIceConnectionState 

func (x *SignalReply) GetIceConnectionState() string

func (*SignalReply) GetId 

func (x *SignalReply) GetId() string

func (*SignalReply) GetJoin 

func (x *SignalReply) GetJoin() *JoinReply

func (*SignalReply) GetKill added in v0.2.1 

func (x *SignalReply) GetKill() bool

func (*SignalReply) GetPayload 

func (m *SignalReply) GetPayload() isSignalReply_Payload

func (*SignalReply) GetRequestId 

func (x *SignalReply) GetRequestId() string

func (*SignalReply) GetTrickle 

func (x *SignalReply) GetTrickle() *Trickle

func (*SignalReply) ProtoMessage 

func (*SignalReply) ProtoMessage()

func (*SignalReply) ProtoReflect 

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

func (*SignalReply) Reset 

func (x *SignalReply) Reset()

func (*SignalReply) String 

func (x *SignalReply) String() string

type SignalReply_Description 

type SignalReply_Description struct {
	Description []byte `protobuf:"bytes,3,opt,name=description,proto3,oneof"`
}

type SignalReply_Error 

type SignalReply_Error struct {
	Error string `protobuf:"bytes,6,opt,name=error,proto3,oneof"`
}

type SignalReply_IceConnectionState 

type SignalReply_IceConnectionState struct {
	IceConnectionState string `protobuf:"bytes,5,opt,name=iceConnectionState,proto3,oneof"`
}

type SignalReply_Join 

type SignalReply_Join struct {
	Join *JoinReply `protobuf:"bytes,2,opt,name=join,proto3,oneof"`
}

type SignalReply_Kill added in v0.2.1 

type SignalReply_Kill struct {
	Kill bool `protobuf:"varint,7,opt,name=kill,proto3,oneof"`
}

type SignalReply_Trickle 

type SignalReply_Trickle struct {
	Trickle *Trickle `protobuf:"bytes,4,opt,name=trickle,proto3,oneof"`
}

type SignalRequest 

type SignalRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // SignalRequest.id should be called pid but we are ion-sfu compatible
	// Types that are assignable to Payload:
	//	*SignalRequest_Join
	//	*SignalRequest_Description
	//	*SignalRequest_Trickle
	//	*SignalRequest_Kill
	Payload   isSignalRequest_Payload `protobuf_oneof:"payload"`
	RequestId string                  `protobuf:"bytes,6,opt,name=requestId,proto3" json:"requestId,omitempty"` // optional, for requests with replies
	// contains filtered or unexported fields
}

**************************************************** SIGNAL COMMANDS - ION-SFU COMPATIBLE 1 SIGNAL = 1 CLIENT CONNECTION ***************************************************

func (*SignalRequest) Descriptor deprecated 

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

Deprecated: Use SignalRequest.ProtoReflect.Descriptor instead.

func (*SignalRequest) GetDescription 

func (x *SignalRequest) GetDescription() []byte

func (*SignalRequest) GetId 

func (x *SignalRequest) GetId() string

func (*SignalRequest) GetJoin 

func (x *SignalRequest) GetJoin() *JoinRequest

func (*SignalRequest) GetKill added in v0.2.1 

func (x *SignalRequest) GetKill() bool

func (*SignalRequest) GetPayload 

func (m *SignalRequest) GetPayload() isSignalRequest_Payload

func (*SignalRequest) GetRequestId 

func (x *SignalRequest) GetRequestId() string

func (*SignalRequest) GetTrickle 

func (x *SignalRequest) GetTrickle() *Trickle

func (*SignalRequest) ProtoMessage 

func (*SignalRequest) ProtoMessage()

func (*SignalRequest) ProtoReflect 

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

func (*SignalRequest) Reset 

func (x *SignalRequest) Reset()

func (*SignalRequest) String 

func (x *SignalRequest) String() string

type SignalRequest_Description 

type SignalRequest_Description struct {
	Description []byte `protobuf:"bytes,3,opt,name=description,proto3,oneof"`
}

type SignalRequest_Join 

type SignalRequest_Join struct {
	Join *JoinRequest `protobuf:"bytes,2,opt,name=join,proto3,oneof"`
}

type SignalRequest_Kill added in v0.2.1 

type SignalRequest_Kill struct {
	Kill bool `protobuf:"varint,5,opt,name=kill,proto3,oneof"`
}

type SignalRequest_Trickle 

type SignalRequest_Trickle struct {
	Trickle *Trickle `protobuf:"bytes,4,opt,name=trickle,proto3,oneof"`
}

type Trickle 

type Trickle struct {
	Target Trickle_Target `protobuf:"varint,1,opt,name=target,proto3,enum=noir.Trickle_Target" json:"target,omitempty"`
	Init   string         `protobuf:"bytes,2,opt,name=init,proto3" json:"init,omitempty"`
	// contains filtered or unexported fields
}

func (*Trickle) Descriptor deprecated 

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

Deprecated: Use Trickle.ProtoReflect.Descriptor instead.

func (*Trickle) GetInit 

func (x *Trickle) GetInit() string

func (*Trickle) GetTarget 

func (x *Trickle) GetTarget() Trickle_Target

func (*Trickle) ProtoMessage 

func (*Trickle) ProtoMessage()

func (*Trickle) ProtoReflect 

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

func (*Trickle) Reset 

func (x *Trickle) Reset()

func (*Trickle) String 

func (x *Trickle) String() string

type Trickle_Target 

type Trickle_Target int32
const (
	Trickle_PUBLISHER  Trickle_Target = 0
	Trickle_SUBSCRIBER Trickle_Target = 1
)

func (Trickle_Target) Descriptor 

func (Trickle_Target) Descriptor() protoreflect.EnumDescriptor

func (Trickle_Target) Enum 

func (x Trickle_Target) Enum() *Trickle_Target

func (Trickle_Target) EnumDescriptor deprecated 

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

Deprecated: Use Trickle_Target.Descriptor instead.

func (Trickle_Target) Number 

func (x Trickle_Target) Number() protoreflect.EnumNumber

func (Trickle_Target) String 

func (x Trickle_Target) String() string

func (Trickle_Target) Type 

func (Trickle_Target) Type() protoreflect.EnumType

type UnimplementedNoirServer added in v0.2.7 

type UnimplementedNoirServer struct {
}

UnimplementedNoirServer must be embedded to have forward compatible implementations.

func (UnimplementedNoirServer) Admin added in v0.2.7 

func (UnimplementedNoirServer) Admin(Noir_AdminServer) error

func (UnimplementedNoirServer) Send added in v0.2.7 

func (UnimplementedNoirServer) Send(context.Context, *NoirRequest) (*Empty, error)

func (UnimplementedNoirServer) Signal added in v0.2.7 

func (UnimplementedNoirServer) Signal(Noir_SignalServer) error

func (UnimplementedNoirServer) Subscribe added in v0.2.7 

func (UnimplementedNoirServer) Subscribe(*AdminClient, Noir_SubscribeServer) error

type UnimplementedSFUServer added in v0.2.7 

type UnimplementedSFUServer struct {
}

UnimplementedSFUServer must be embedded to have forward compatible implementations.

func (UnimplementedSFUServer) Signal added in v0.2.7 

func (UnimplementedSFUServer) Signal(SFU_SignalServer) error

type UnsafeNoirServer added in v0.2.7 

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

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

type UnsafeSFUServer added in v0.2.7 

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

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

type UserData added in v0.2.1 

type UserData struct {
	Id         string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Created    *timestamp.Timestamp `protobuf:"bytes,2,opt,name=created,proto3" json:"created,omitempty"`
	LastUpdate *timestamp.Timestamp `protobuf:"bytes,4,opt,name=lastUpdate,proto3" json:"lastUpdate,omitempty"`
	RoomID     string               `protobuf:"bytes,5,opt,name=roomID,proto3" json:"roomID,omitempty"`
	Options    *UserOptions         `protobuf:"bytes,6,opt,name=options,proto3" json:"options,omitempty"`
	Publishing bool                 `protobuf:"varint,7,opt,name=publishing,proto3" json:"publishing,omitempty"`
	// contains filtered or unexported fields
}

func (*UserData) Descriptor deprecated added in v0.2.1 

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

Deprecated: Use UserData.ProtoReflect.Descriptor instead.

func (*UserData) GetCreated added in v0.2.1 

func (x *UserData) GetCreated() *timestamp.Timestamp

func (*UserData) GetId added in v0.2.1 

func (x *UserData) GetId() string

func (*UserData) GetLastUpdate added in v0.2.1 

func (x *UserData) GetLastUpdate() *timestamp.Timestamp

func (*UserData) GetOptions added in v0.2.1 

func (x *UserData) GetOptions() *UserOptions

func (*UserData) GetPublishing added in v0.2.1 

func (x *UserData) GetPublishing() bool

func (*UserData) GetRoomID added in v0.2.1 

func (x *UserData) GetRoomID() string

func (*UserData) ProtoMessage added in v0.2.1 

func (*UserData) ProtoMessage()

func (*UserData) ProtoReflect added in v0.2.1 

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

func (*UserData) Reset added in v0.2.1 

func (x *UserData) Reset()

func (*UserData) String added in v0.2.1 

func (x *UserData) String() string

type UserOptions added in v0.2.1 

type UserOptions struct {
	Debug           int32  `protobuf:"varint,1,opt,name=debug,proto3" json:"debug,omitempty"`
	Title           string `protobuf:"bytes,2,opt,name=title,proto3" json:"title,omitempty"`
	MaxAgeSeconds   int32  `protobuf:"varint,3,opt,name=maxAgeSeconds,proto3" json:"maxAgeSeconds,omitempty"`
	KeyExpiryFactor int32  `protobuf:"varint,4,opt,name=keyExpiryFactor,proto3" json:"keyExpiryFactor,omitempty"`
	// contains filtered or unexported fields
}

func (*UserOptions) Descriptor deprecated added in v0.2.1 

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

Deprecated: Use UserOptions.ProtoReflect.Descriptor instead.

func (*UserOptions) GetDebug added in v0.2.1 

func (x *UserOptions) GetDebug() int32

func (*UserOptions) GetKeyExpiryFactor added in v0.2.1 

func (x *UserOptions) GetKeyExpiryFactor() int32

func (*UserOptions) GetMaxAgeSeconds added in v0.2.1 

func (x *UserOptions) GetMaxAgeSeconds() int32

func (*UserOptions) GetTitle added in v0.2.1 

func (x *UserOptions) GetTitle() string

func (*UserOptions) ProtoMessage added in v0.2.1 

func (*UserOptions) ProtoMessage()

func (*UserOptions) ProtoReflect added in v0.2.1 

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

func (*UserOptions) Reset added in v0.2.1 

func (x *UserOptions) Reset()

func (*UserOptions) String added in v0.2.1 

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