core

type ChunkHaveMsg struct {
	ChunkName string
	StreamID  string
	PeerID    string
	Addr      string
}

type ChunkReqAckMsg struct {
	ChunkName string
	StreamID  string
	Data      string //hex encoded
}

type ChunkReqMsg struct {
	ChunkName string
	StreamID  string
	Peer      string
}

type ChunkSubscriber struct {
	Buffer *stream.HLSBuffer
	Node   *LivepeerNode
}

type JoinMsg struct {
	ID   string
	Addr string
}

type LivepeerNode struct {
	// Self
	Identity  peer.ID             // the local node's identity
	Peerstore ps.Peerstore        // storage for other Peer instances
	Routing   routing.IpfsRouting // the routing system. recommend ipfs-dht
	Priv      crypto.PrivKey
	Pub       crypto.PubKey

	PeerHost    p2phost.Host             // the network host (server+client)
	StreamPeers map[string][]ps.PeerInfo // the network host (server+client)
	HLSBuf      *lpmsStream.HLSBuffer
}

type Message struct {
	Msg  int
	Data interface{}
}

type StreamID string

type SubReqMsg struct {
	ID   string
	Addr string
	SID  string
}

type Transcode struct {
	StrmID string
}

type WrappedStream struct {
	Stream net.Stream
	Enc    multicodec.Encoder
	Dec    multicodec.Decoder
	Writer *bufio.Writer
	Reader *bufio.Reader
}