kinesisvideomanager

type BlockChWithBaseTimecode struct {
	Timecode chan uint64
	Block    chan ebml.Block
	Tag      chan *Tag
}

type BlockReader interface {
	// Read returns media block.
	Read() (*BlockWithBaseTimecode, error)
	// ReadTag returns stored tag.
	ReadTag() (*Tag, error)
	// Close the connenction to Kinesis Video Stream.
	Close() (*Container, error)
}

type BlockWithBaseTimecode struct {
	Timecode uint64
	Block    ebml.Block
}

type BlockWithMetadata struct {
	*BlockWithBaseTimecode
	*FragmentMetadata
}

type BlockWriter interface {
	// Write a block to Kinesis Video Stream.
	Write(*BlockWithBaseTimecode) error
	// ReadResponse reads a response from Kinesis Video Stream.
	ReadResponse() (*FragmentEvent, error)
	// Close immediately shuts down the client.
	Close() error
	// Shutdown gracefully shuts down the client without interrupting on-going PutMedia request.
	// If Shotdown returned an error, some of the internal resources might not released yet and
	// caller should call Shutdown or Close again.
	Shutdown(ctx context.Context) error
}

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

type Cluster struct {
	Timecode    chan uint64
	Position    uint64 `ebml:",omitempty"`
	SimpleBlock chan ebml.Block
}

type ClusterWrite struct {
	Timecode    chan uint64
	Position    uint64 `ebml:",omitempty"`
	SimpleBlock chan ebml.Block
}

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

type Container struct {
	Header  EBMLHeader `ebml:"EBML"`
	Segment Segment    `ebml:",size=unknown"`
}

type EBMLHeader struct {
	EBMLVersion            uint64
	EBMLReadVersion        uint64
	EBMLMaxIDLength        uint64
	EBMLMaxSizeLength      uint64
	EBMLDocType            string
	EBMLDocTypeVersion     uint64
	EBMLDocTypeReadVersion uint64
}

type ErrorID int

type Fragment []*BlockWithMetadata

type FragmentEvent struct {
	EventType        FragmentEventType
	FragmentTimecode uint64
	FragmentNumber   string // 158-bit number, handle as string
	ErrorId          ErrorID
	ErrorCode        string
	// contains filtered or unexported fields
}

type FragmentEventError struct {
	FragmentEvent
}

type FragmentEventType string

type FragmentMetadata struct {
	FragmentNumber    string
	ProducerTimestamp time.Time
	ServerTimestamp   time.Time
	Tags              map[string]SimpleTag
}

type FragmentTimecodeType string

type GetMediaBody struct {
	StartSelector StartSelector
	StreamARN     *string `json:",omitempty"`
	StreamName    *string `json:",omitempty"`
}

type GetMediaOption func(*GetMediaOptions)

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

type Info struct {
	TimecodeScale   uint64
	SegmentUID      []byte
	SegmentFilename string
	Title           string
	MuxingApp       string
	WritingApp      string
}

type LoggerIF interface {
	Debug(args ...interface{})
	Debugf(format string, args ...interface{})
	Info(args ...interface{})
	Infof(format string, args ...interface{})
	Warn(args ...interface{})
	Warnf(format string, args ...interface{})
	Error(args ...interface{})
	Errorf(format string, args ...interface{})
}

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

type PutMediaOption func(*PutMediaOptions)

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

type Segment struct {
	Info    Info
	Tracks  Tracks
	Cluster Cluster `ebml:",size=unknown"`
	Tags    Tags
}

type SegmentWrite struct {
	Info    Info
	Tracks  Tracks
	Cluster ClusterWrite `ebml:",size=unknown"`
	Tags    Tags
}

type SimpleTag struct {
	TagName   string
	TagString string `ebml:",omitempty"`
	TagBinary string `ebml:",omitempty"`
}

type StartSelector struct {
	AfterFragmentNumber string `json:",omitempty"`
	ContinuationToken   string `json:",omitempty"`
	StartSelectorType   StartSelectorType
	StartTimestamp      int `json:",omitempty"`
}

type StartSelectorType string

type StreamID interface {
	StreamARN() *string
	StreamName() *string
}

type Tag struct {
	SimpleTag []SimpleTag
}

type Tags struct {
	Tag chan *Tag `ebml:",omitempty"`
}

type TrackEntry struct {
	Name        string
	TrackNumber uint64
	TrackUID    uint64
	CodecID     string
	CodecName   string
	TrackType   uint64
}

type Tracks struct {
	TrackEntry []TrackEntry
}