kinesisvideomanager

Jun 19, 2023

Changes in this version

type PutMediaOption

+ func OnPutMediaNewConn(onNewConn func()) PutMediaOption

+ func OnPutMediaSwitchConn(onSwitchConn func(timecode uint64)) PutMediaOption

Jan 21, 2023

Changes in this version

+ var ErrWriteTimeout = errors.New("write timeout")

+ type BlockReader interface

+ Close func() (*Container, error)

+ Read func() (*BlockWithBaseTimecode, error)

+ ReadTag func() (*Tag, error)

type BlockWriter

+ Close func() error

+ ReadResponse func() (*FragmentEvent, error)

+ Shutdown func(ctx context.Context) error

type FragmentEvent

+ func (e *FragmentEvent) AsError() error

+ type FragmentEventError struct

+ func (e FragmentEventError) Error() string

+ type FragmentEventType string

+ const FRAGMENT_EVENT_BUFFERING

+ const FRAGMENT_EVENT_ERROR

+ const FRAGMENT_EVENT_IDLE

+ const FRAGMENT_EVENT_PERSISTED

+ const FRAGMENT_EVENT_RECEIVED

type GetMediaOption

+ func WithGetMediaBufferLen(n int) GetMediaOption

+ func WithGetMediaTagBufferLen(n int) GetMediaOption

type PutMediaOption

+ func WithPutMediaBufferLen(n int) PutMediaOption

+ func WithPutMediaResponseBufferLen(n int) PutMediaOption

Sep 29, 2022

Changes in this version

+ var ErrInvalidTimecode = errors.New("invalid timecode")

+ type BlockWriter interface

+ Write func(*BlockWithBaseTimecode) error

type PutMediaOption

+ func WithBlockWriterReceiver(fn func(BlockWriter)) PutMediaOption

Jul 7, 2022

Changes in this version

type PutMediaOption

+ func WithPutMediaLogger(logger LoggerIF) PutMediaOption

Apr 2, 2021

Changes in this version

type FragmentEvent

+ func (e *FragmentEvent) Dump() []byte

type PutMediaOption

+ func WithFragmentHeadDumpLen(n int) PutMediaOption

Mar 30, 2021

Changes in this version

+ type ErrorID int

+ const ARCHIVAL_ERROR

+ const FRAGMENT_METADATA_LIMIT_REACHED

+ const FRAGMENT_TIMECODE_LESSER_THAN_PREVIOUS

+ const FRAMES_MISSING_FOR_TRACK

+ const INTERNAL_ERROR

+ const INVALID_MKV_DATA

+ const INVALID_PRODUCER_TIMESTAMP

+ const KMS_KEY_ACCESS_DENIED

+ const KMS_KEY_DISABLED

+ const KMS_KEY_INVALID_STATE

+ const KMS_KEY_INVALID_USAGE

+ const KMS_KEY_NOT_FOUND

+ const KMS_KEY_UNAVAILABLE

+ const KMS_KEY_VALIDATION_ERROR

+ const MAX_CONNECTION_DURATION_REACHED

+ const MAX_FRAGMENT_DURATION_REACHED

+ const MAX_FRAGMENT_SIZE_REACHED

+ const MORE_THAN_ALLOWED_TRACKS_FOUND

+ const STREAM_NOT_ACTIVE

+ const STREAM_READ_ERROR

+ const TRACK_NUMBER_MISMATCH

Mar 29, 2021

Changes in this version

type FragmentEvent

+ func (e *FragmentEvent) Error() string

+ func (e *FragmentEvent) IsError() bool

Mar 22, 2021

Changes in this version

type PutMediaOption

+ func WithPutMediaRetry(count int, intervalBase time.Duration) PutMediaOption

Nov 24, 2020

Changes in this version

+ const TagNameExceptionErrorCode

+ const TagNameExceptionMessage

+ const TagNameFragmentNumber

+ const TagNameProducerTimestamp

+ const TagNameServerTimestamp

+ const TimecodeScale

+ func ParseTimestamp(timestamp string) (time.Time, error)

+ func SetLogger(l LoggerIF)

+ func ToTimestamp(t time.Time) string

+ type BlockChWithBaseTimecode struct

+ Block chan ebml.Block

+ Tag chan *Tag

+ Timecode chan uint64

+ type BlockWithBaseTimecode struct

+ Block ebml.Block

+ Timecode uint64

+ func (bt *BlockWithBaseTimecode) AbsTimecode() int64

+ type BlockWithMetadata struct

+ type Client struct

+ func New(sess client.ConfigProvider, cfgs ...*aws.Config) (*Client, error)

+ func (c *Client) Consumer(streamID StreamID) (*Consumer, error)

+ func (c *Client) Provider(streamID StreamID, tracks []TrackEntry) (*Provider, error)

+ type Cluster struct

+ Position uint64

+ SimpleBlock chan ebml.Block

+ Timecode chan uint64

+ type ClusterWrite struct

+ Position uint64

+ SimpleBlock chan ebml.Block

+ Timecode chan uint64

+ type Consumer struct

+ func (c *Consumer) GetMedia(ch chan *BlockWithBaseTimecode, chTag chan *Tag, opts ...GetMediaOption) (*Container, error)

+ type Container struct

+ Header EBMLHeader

+ Segment Segment

+ type EBMLHeader struct

+ EBMLDocType string

+ EBMLDocTypeReadVersion uint64

+ EBMLDocTypeVersion uint64

+ EBMLMaxIDLength uint64

+ EBMLMaxSizeLength uint64

+ EBMLReadVersion uint64

+ EBMLVersion uint64

+ type Fragment []*BlockWithMetadata

+ type FragmentEvent struct

+ ErrorCode string

+ ErrorId int

+ EventType string

+ FragmentNumber string

+ FragmentTimecode uint64

+ type FragmentMetadata struct

+ FragmentNumber string

+ ProducerTimestamp time.Time

+ ServerTimestamp time.Time

+ Tags map[string]SimpleTag

+ type FragmentTimecodeType string

+ const FragmentTimecodeTypeAbsolute

+ const FragmentTimecodeTypeRelative

+ type GetMediaBody struct

+ StartSelector StartSelector

+ StreamARN *string

+ StreamName *string

+ type GetMediaOption func(*GetMediaOptions)

+ func WithStartSelectorContinuationToken(token string) GetMediaOption

+ func WithStartSelectorNow() GetMediaOption

+ func WithStartSelectorProducerTimestamp(timestamp time.Time) GetMediaOption

+ type GetMediaOptions struct

+ type Info struct

+ MuxingApp string

+ SegmentFilename string

+ SegmentUID []byte

+ TimecodeScale uint64

+ Title string

+ WritingApp string

+ type LoggerIF interface

+ Debug func(args ...interface{})

+ Debugf func(format string, args ...interface{})

+ Error func(args ...interface{})

+ Errorf func(format string, args ...interface{})

+ Info func(args ...interface{})

+ Infof func(format string, args ...interface{})

+ Warn func(args ...interface{})

+ Warnf func(format string, args ...interface{})

+ func Logger() LoggerIF

+ type Provider struct

+ func (p *Provider) PutMedia(ch chan *BlockWithBaseTimecode, chResp chan FragmentEvent, ...)

+ type PutMediaOption func(*PutMediaOptions)

+ func OnError(onError func(error)) PutMediaOption

+ func WithConnectionTimeout(timeout time.Duration) PutMediaOption

+ func WithFragmentTimecodeType(fragmentTimecodeType FragmentTimecodeType) PutMediaOption

+ func WithHttpClient(client http.Client) PutMediaOption

+ func WithProducerStartTimestamp(producerStartTimestamp time.Time) PutMediaOption

+ func WithSegmentUID(segmentUID []byte) PutMediaOption

+ func WithTags(tags func() []SimpleTag) PutMediaOption

+ func WithTitle(title string) PutMediaOption

+ type PutMediaOptions struct

+ type Segment struct

+ Cluster Cluster

+ Info Info

+ Tags Tags

+ Tracks Tracks

+ type SegmentWrite struct

+ Cluster ClusterWrite

+ Info Info

+ Tags Tags

+ Tracks Tracks

+ type SimpleTag struct

+ TagBinary string

+ TagName string

+ TagString string

+ type StartSelector struct

+ AfterFragmentNumber string

+ ContinuationToken string

+ StartSelectorType StartSelectorType

+ StartTimestamp int

+ type StartSelectorType string

+ const StartSelectorTypeContinuationToken

+ const StartSelectorTypeEarliest

+ const StartSelectorTypeFragmentNumber

+ const StartSelectorTypeNow

+ const StartSelectorTypeProducerTimestamp

+ const StartSelectorTypeServerTimestamp

+ type StreamID interface

+ StreamARN func() *string

+ StreamName func() *string

+ func StreamARN(arn string) StreamID

+ func StreamName(name string) StreamID

+ type Tag struct

+ SimpleTag []SimpleTag

+ type Tags struct

+ Tag chan *Tag

+ type TrackEntry struct

+ CodecID string

+ CodecName string

+ Name string

+ TrackNumber uint64

+ TrackType uint64

+ TrackUID uint64

+ type Tracks struct

+ TrackEntry []TrackEntry