proto

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 ComputationReport struct {
	Node   *ion.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             *ion.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 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 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 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 SFUStatus struct {
	SFU           *ion.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 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=islb.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    *ion.Node `protobuf:"bytes,1,opt,name=src,proto3" json:"src,omitempty"`
	Dst    *ion.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
}