Documentation
¶
Overview ¶
Package playbackts observes bounded fixed-program transport streams. Transport receipts and counter normalization are not decoder or seamless splice proof.
Index ¶
Constants ¶
This section is empty.
Variables ¶
var ErrUnsupported = errors.New("unsupported or unproven transport stream")
Functions ¶
This section is empty.
Types ¶
type Candidate ¶
type Candidate struct {
// contains filtered or unexported fields
}
Candidate owns uncommitted bytes. Target is an instruction, not evidence that a Store admitted this identity, a generation was frozen, or an encoder fenced.
func NewCandidate ¶
func NewCandidate(target playbackbuffer.Key, size int64, reader io.Reader, limits Limits) (*Candidate, error)
NewCandidate reads exactly size bytes and immediate EOF. Reader must bound its own blocking Read; no background goroutine or service is started.
func (*Candidate) Key ¶
func (c *Candidate) Key() playbackbuffer.Key
type Limits ¶
Limits bound each allocation and the number of observations. Zero is invalid. Hard ceilings also prevent an accidentally unlimited caller configuration.
type Receipt ¶
type Receipt struct {
// contains filtered or unexported fields
}
Receipt is immutable evidence from actual published Store bytes. Fields are private so callers cannot assert parsed facts or attach arbitrary identities.
func (*Receipt) Identity ¶
func (r *Receipt) Identity() playbackbuffer.RetainedIdentity
Source Files