proto

type Algorithm interface {

	// UpdateStatus tell the algorithm that the SFU graph and the computation and communication quality has changed
	// `current` is the changed SFU's current status
	// `reports` is a series of Quality Report
	// `expected` is that which SFU's status should change
	UpdateStatus(current []Status, reports []Report) (expected []Status)
}

type AlgorithmWrapper struct {
	ProtobufAlgorithm
}

type ClientNeededSession struct {
	Session string `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	User    string `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	// contains filtered or unexported fields
}

type ClientNeededSessions []*ClientNeededSession

type ClientSessionItemList util.DisorderSetItemList[*ClientNeededSession]

type ComputationReport struct {
	Node   *Node    `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	Report *any.Any `protobuf:"bytes,2,opt,name=report,proto3" json:"report,omitempty"` //TODO: Add a more specific Report type
	// contains filtered or unexported fields
}

type ForwardTrack struct {

	//  src + remoteSessionId is unique, use it as key
	Src             *Node           `protobuf:"bytes,1,opt,name=src,proto3" json:"src,omitempty"`
	RemoteSessionId string          `protobuf:"bytes,2,opt,name=remoteSessionId,proto3" json:"remoteSessionId,omitempty"` // The video/audio has session id in different nodes
	LocalSessionId  string          `protobuf:"bytes,3,opt,name=localSessionId,proto3" json:"localSessionId,omitempty"`   // The video/audio has session id in different nodes
	Tracks          []*Subscription `protobuf:"bytes,4,rep,name=tracks,proto3" json:"tracks,omitempty"`
	// contains filtered or unexported fields
}

type ForwardTrackItemList util.DisorderSetItemList[*ForwardTrack]

type ForwardTracks []*ForwardTrack

type ISGLBClient interface {
	// When forward path changed, upload the SFUStatus from client to ISGLB
	// When forward path should change, send expected SFUStatus from ISGLB to client
	// Report the communication quality or computation quality of the edge
	SyncSFU(ctx context.Context, opts ...grpc.CallOption) (ISGLB_SyncSFUClient, error)
}

type ISGLBServer interface {
	// When forward path changed, upload the SFUStatus from client to ISGLB
	// When forward path should change, send expected SFUStatus from ISGLB to client
	// Report the communication quality or computation quality of the edge
	SyncSFU(ISGLB_SyncSFUServer) error
	// contains filtered or unexported methods
}

type ISGLB_SyncSFUClient interface {
	Send(*SyncRequest) error
	Recv() (*SFUStatus, error)
	grpc.ClientStream
}

type ISGLB_SyncSFUServer interface {
	Send(*SFUStatus) error
	Recv() (*SyncRequest, error)
	grpc.ServerStream
}

type Node struct {
	Id   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Info *any.Any `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

type ProceedTrack struct {
	DstSessionId     string   `protobuf:"bytes,1,opt,name=dstSessionId,proto3" json:"dstSessionId,omitempty"`
	Procedure        *any.Any `protobuf:"bytes,2,opt,name=procedure,proto3" json:"procedure,omitempty"`               //src track should be proceeded by what kind of procedure
	SrcSessionIdList []string `protobuf:"bytes,3,rep,name=srcSessionIdList,proto3" json:"srcSessionIdList,omitempty"` //TODO: procedure should be more specific
	// contains filtered or unexported fields
}

type ProceedTrackItemList util.DisorderSetItemList[*ProceedTrack]

type ProceedTracks []*ProceedTrack

type ProtobufAlgorithm interface {
	UpdateSFUStatus(current []*SFUStatus, reports []*QualityReport) (expected []*SFUStatus)
}

type QualityReport struct {
	Timestamp *timestamp.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Types that are assignable to Report:
	//	*QualityReport_Transmission
	//	*QualityReport_Computation
	Report isQualityReport_Report `protobuf_oneof:"report"`
	// contains filtered or unexported fields
}

type QualityReport_Computation struct {
	Computation *ComputationReport `protobuf:"bytes,3,opt,name=computation,proto3,oneof"`
}

type QualityReport_Transmission struct {
	Transmission *TransmissionReport `protobuf:"bytes,2,opt,name=transmission,proto3,oneof"`
}

type Report interface {
	// String stringify it
	String() string
	// Clone clone return a copy of this struct
	Clone() Report
}

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

type RequestReport struct {
	Report Report
}

type RequestStatus struct {
	Status Status
}

type SFUStatus struct {
	SFU           *Node                  `protobuf:"bytes,1,opt,name=SFU,proto3" json:"SFU,omitempty"`
	ForwardTracks []*ForwardTrack        `protobuf:"bytes,2,rep,name=forwardTracks,proto3" json:"forwardTracks,omitempty"`
	ProceedTracks []*ProceedTrack        `protobuf:"bytes,3,rep,name=proceedTracks,proto3" json:"proceedTracks,omitempty"`
	Clients       []*ClientNeededSession `protobuf:"bytes,4,rep,name=clients,proto3" json:"clients,omitempty"`
	// contains filtered or unexported fields
}

type Status interface {
	// Key return the key of this item
	Key() string
	// Compare compare if two IndexData is the same
	Compare(Status) bool
	// String stringify it
	String() string
	// Clone clone return a copy of this struct
	Clone() Status
}

type Subscription struct {
	TrackId string             `protobuf:"bytes,1,opt,name=TrackId,proto3" json:"TrackId,omitempty"`
	Mute    bool               `protobuf:"varint,2,opt,name=Mute,proto3" json:"Mute,omitempty"`
	Layer   Subscription_Layer `protobuf:"varint,3,opt,name=layer,proto3,enum=isglb.Subscription_Layer" json:"layer,omitempty"`
	// contains filtered or unexported fields
}

type Subscription_Layer int32

type SyncRequest struct {

	// Types that are assignable to Request:
	//	*SyncRequest_Status
	//	*SyncRequest_Report
	Request isSyncRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

type SyncRequest_Report struct {
	Report *QualityReport `protobuf:"bytes,2,opt,name=report,proto3,oneof"`
}

type SyncRequest_Status struct {
	Status *SFUStatus `protobuf:"bytes,1,opt,name=status,proto3,oneof"`
}

type TransmissionReport struct {
	Src    *Node    `protobuf:"bytes,1,opt,name=src,proto3" json:"src,omitempty"`
	Dst    *Node    `protobuf:"bytes,2,opt,name=dst,proto3" json:"dst,omitempty"`
	Report *any.Any `protobuf:"bytes,3,opt,name=report,proto3" json:"report,omitempty"` //TODO: Add a more specific Report type
	// contains filtered or unexported fields
}

type UnimplementedISGLBServer struct {
}

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