mediafragment

Documentation

Index

• type Client
  • func New(streamID kvm.StreamID, sess client.ConfigProvider, cfgs ...*aws.Config) (*Client, error)
  • func (c *Client) GetMediaForFragmentList(fragments FragmentIDs, handler func(kvm.Fragment), errHandler func(error)) error
  • func (c *Client) ListFragments(opts ...ListFragmentsOption) (*ListFragmentsOutput, error)
• type FragmentError
  • func (e *FragmentError) Error() string
• type FragmentIDs
  • func NewFragmentIDs(ids ...string) FragmentIDs
• type ListFragmentsOption
  • func WithMaxResults(maxResults int64) ListFragmentsOption
  • func WithNextToken(nextToken *string) ListFragmentsOption
  • func WithProducerTimestampRange(startTime, endTime time.Time) ListFragmentsOption
  • func WithServerTimestampRange(startTime, endTime time.Time) ListFragmentsOption
• type ListFragmentsOutput
  • func (l *ListFragmentsOutput) FragmentIDs() FragmentIDs
  • func (l ListFragmentsOutput) Len() int
  • func (l *ListFragmentsOutput) Sort()
  • func (l *ListFragmentsOutput) SortByFragmentNumber()
  • func (l *ListFragmentsOutput) SortByProducerTimestamp()
  • func (l *ListFragmentsOutput) Swap(i, j int)
  • func (l *ListFragmentsOutput) Uniq()
• type SortByFragmentNumber
  • func (l SortByFragmentNumber) Less(i, j int) bool
• type SortByProducerTimestamp
  • func (l SortByProducerTimestamp) Less(i, j int) bool

Types

type Client

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

func New

func New(streamID kvm.StreamID, sess client.ConfigProvider, cfgs ...*aws.Config) (*Client, error)

func (*Client) GetMediaForFragmentList

func (c *Client) GetMediaForFragmentList(fragments FragmentIDs, handler func(kvm.Fragment), errHandler func(error)) error

func (*Client) ListFragments

func (c *Client) ListFragments(opts ...ListFragmentsOption) (*ListFragmentsOutput, error)

type FragmentError

type FragmentError struct {
	FragmentNumber string
	Code           string
	Message        string
}

func (*FragmentError) Error

func (e *FragmentError) Error() string

type FragmentIDs

type FragmentIDs []*string

func NewFragmentIDs

func NewFragmentIDs(ids ...string) FragmentIDs

type ListFragmentsOption

type ListFragmentsOption func(input *kvam.ListFragmentsInput)

func WithMaxResults

func WithMaxResults(maxResults int64) ListFragmentsOption

func WithNextToken

func WithNextToken(nextToken *string) ListFragmentsOption

func WithProducerTimestampRange

func WithProducerTimestampRange(startTime, endTime time.Time) ListFragmentsOption

func WithServerTimestampRange

func WithServerTimestampRange(startTime, endTime time.Time) ListFragmentsOption

type ListFragmentsOutput

type ListFragmentsOutput struct {
	*kvam.ListFragmentsOutput
}

func (*ListFragmentsOutput) FragmentIDs

func (l *ListFragmentsOutput) FragmentIDs() FragmentIDs

func (ListFragmentsOutput) Len

func (l ListFragmentsOutput) Len() int

func (*ListFragmentsOutput) Sort

func (l *ListFragmentsOutput) Sort()

Sort is alias of SortByFragmentNumber.

Deprecated: use SortByFragmentNumber or SortByProducerTimestamp

func (*ListFragmentsOutput) SortByFragmentNumber

func (l *ListFragmentsOutput) SortByFragmentNumber()

func (*ListFragmentsOutput) SortByProducerTimestamp

func (l *ListFragmentsOutput) SortByProducerTimestamp()

func (*ListFragmentsOutput) Swap

func (l *ListFragmentsOutput) Swap(i, j int)

func (*ListFragmentsOutput) Uniq

func (l *ListFragmentsOutput) Uniq()

Uniq removes duplicated fragments. Fragments with same ProducerTimestamp excepting the longest one will be removed. List of the fragments must be sorted by ProducerTimestamp before calling Uniq.

type SortByFragmentNumber

type SortByFragmentNumber struct {
	*ListFragmentsOutput
}

func (SortByFragmentNumber) Less

func (l SortByFragmentNumber) Less(i, j int) bool

type SortByProducerTimestamp

type SortByProducerTimestamp struct {
	*ListFragmentsOutput
}

func (SortByProducerTimestamp) Less

func (l SortByProducerTimestamp) Less(i, j int) bool