broker

type Broker struct {
	*server.Server
	// contains filtered or unexported fields
}

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

type Config struct {
	CoordinatorURL                              string
	Log                                         *logging.Logger
	ICEServers                                  []pion.ICEServer
	Zipper                                      ZipCompression
	Auth                                        authentication.ServerAuthenticator
	ReliableWriterControllerFactory             WriterControllerFactory
	UnreliableWriterControllerFactory           WriterControllerFactory
	ReliableChannelBufferedAmountLowThreshold   uint64
	UnreliableChannelBufferedAmountLowThreshold uint64

	MaxPeers               uint16
	ExitOnCoordinatorClose bool
	WebRtcLogLevel         zerolog.Level
	Role                   protocol.Role
}

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

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

type GzipCompression struct{}

type PeerStats struct {
	Alias      uint64
	Identity   []byte
	State      pion.ICEConnectionState
	TopicCount uint32

	Nomination          bool
	LocalCandidateType  pion.ICECandidateType
	RemoteCandidateType pion.ICECandidateType

	DataChannelsOpened    uint32
	DataChannelsClosed    uint32
	DataChannelsRequested uint32
	DataChannelsAccepted  uint32

	ReliableProtocol         string
	ReliableState            pion.DataChannelState
	ReliableBytesSent        uint64
	ReliableBytesReceived    uint64
	ReliableMessagesSent     uint32
	ReliableMessagesReceived uint32
	ReliableBufferedAmount   uint64

	UnreliableProtocol         string
	UnreliableState            pion.DataChannelState
	UnreliableBytesSent        uint64
	UnreliableBytesReceived    uint64
	UnreliableMessagesSent     uint32
	UnreliableMessagesReceived uint32
	UnreliableBufferedAmount   uint64

	ICETransportBytesSent     uint64
	ICETransportBytesReceived uint64

	SCTPTransportBytesSent     uint64
	SCTPTransportBytesReceived uint64
}

type PeerWriter interface {
	BufferedAmount() uint64
	Write(p []byte) error
}

type Stats struct {
	Time                time.Time
	Alias               uint64
	ConnectChSize       int
	WebRtcControlChSize int
	UnregisterChSize    int
	TopicCount          int
	SubscriptionChSize  int
	MessagesChSize      int
	Peers               map[uint64]PeerStats
}

type StatsSummary struct {
	From time.Time
	To   time.Time

	StateCount               map[pion.ICEConnectionState]uint32
	LocalCandidateTypeCount  map[pion.ICECandidateType]uint32
	RemoteCandidateTypeCount map[pion.ICECandidateType]uint32

	MessagesSentByDC, BytesSentByDC, BytesSentByICE, BytesSentBySCTP                 uint64
	MessagesReceivedByDC, BytesReceivedByDC, BytesReceivedByICE, BytesReceivedBySCTP uint64
}

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

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

type WriterController interface {
	Write(byte []byte)
	OnBufferedAmountLow()
}

type WriterControllerFactory = func(uint64, PeerWriter) WriterController

type ZipCompression interface {
	Zip(plain []byte) ([]byte, error)
	Unzip(zipped []byte) ([]byte, error)
}