Track/Group/Frame

type TrackWriter struct {
	BroadcastPath BroadcastPath
	TrackName     TrackName
	// contains filtered or unexported fields
}

func (*TrackWriter) Close() error
func (*TrackWriter) CloseWithError(SubscribeErrorCode)
func (*TrackWriter) OpenGroup(context.Context) (*GroupWriter, error)
func (*TrackWriter) OpenGroupAt(context.Context, GroupSequence) (*GroupWriter, error)
func (*TrackWriter) SkipGroups(n uint64)
func (*TrackWriter) DropGroups(SubscribeDrop) error
func (*TrackWriter) DropNextGroups(n uint64, code SubscribeErrorCode) error
func (*TrackWriter) TrackConfig() *SubscribeConfig
func (*TrackWriter) ReadUpdate() (*SubscribeConfig, error)
func (*TrackWriter) Context() context.Context

type TrackReader struct {
	BroadcastPath BroadcastPath
	TrackName     TrackName
	// contains filtered or unexported fields
}

func (*TrackReader) AcceptGroup(context.Context) (*GroupReader, error)
func (*TrackReader) Close() error
func (*TrackReader) CloseWithError(SubscribeErrorCode)
func (*TrackReader) Update(*SubscribeConfig) error
func (*TrackReader) TrackConfig() *SubscribeConfig
func (*TrackReader) SubscribeID() SubscribeID
func (*TrackReader) Drops(context.Context) iter.Seq[SubscribeDrop]
func (*TrackReader) Context() context.Context

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

func (*GroupWriter) GroupSequence() GroupSequence
func (*GroupWriter) WriteFrame(*Frame) error
func (*GroupWriter) SetWriteDeadline(time.Time) error
func (*GroupWriter) CancelWrite(GroupErrorCode)
func (*GroupWriter) Close() error
func (*GroupWriter) Context() context.Context

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

func (*GroupReader) GroupSequence() GroupSequence
func (*GroupReader) ReadFrame(*Frame) error
func (*GroupReader) CancelRead(GroupErrorCode)
func (*GroupReader) SetReadDeadline(time.Time) error
func (*GroupReader) Frames(*Frame) iter.Seq[*Frame]

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

func NewFrame(int) *Frame
func (*Frame) Body() []byte
func (*Frame) Cap() int
func (*Frame) Len() int
func (*Frame) Reset()
func (*Frame) Clone() *Frame
func (*Frame) Write([]byte) (int, error)
func (*Frame) WriteTo(w io.Writer) (int64, error)