data

Jan 31, 2024

Changes in this version

+ type Nullable **T

+ func ToNullable[T any](val T, valid, asked bool) Nullable[T]

type TaskOutput

+ Clip *UploadTaskOutput

Jun 23, 2023

Changes in this version

+ type ExportDataTaskOutput struct

+ IPFS *IPFSExportDataInfo

+ type IPFSExportDataInfo struct

+ CID string

type TaskOutput

+ ExportData *ExportDataTaskOutput

Jun 9, 2023

Changes in this version

type EventType

+ const EventTypeTaskResultPartial

+ type TaskPartialOutput struct

+ Upload *UploadTaskOutput

+ type TaskResultPartialEvent struct

+ Output *TaskPartialOutput

+ Task TaskInfo

+ func NewTaskResultPartialEvent(info TaskInfo, output *TaskPartialOutput) *TaskResultPartialEvent

Apr 12, 2023

Changes in this version

+ type InputVideo struct

+ Duration float64

+ SizeBytes int64

type TranscodeFileTaskOutput

+ InputVideo *InputVideo

+ RequestID string

Feb 10, 2023

Changes in this version

type TranscodeFileTaskOutput

+ BaseUrl string

+ Hls *TranscodeFileTaskOutputPath

+ Mp4 []TranscodeFileTaskOutputPath

+ type TranscodeFileTaskOutputPath struct

+ Path string

Feb 3, 2023

Changes in this version

type TaskOutput

+ TranscodeFile *TranscodeFileTaskOutput

+ type TranscodeFileTaskOutput struct

+ VideoFilePath string

Sep 17, 2022

Changes in this version

type TaskInfo

+ Step string

+ StepInput json.RawMessage

type TaskOutput

+ Upload *UploadTaskOutput

+ type UploadTaskOutput struct

+ AssetSpec interface{}

+ MetadataFilePath string

+ VideoFilePath string

Mar 29, 2022

Changes in this version

type TranscodeTaskOutput

+ Asset ImportTaskOutput

Mar 29, 2022

Changes in this version

+ type ErrorInfo struct

+ Message string

+ Unretriable bool

type EventType

+ const EventTypeTaskResult

+ const EventTypeTaskTrigger

+ type ExportTaskOutput struct

+ IPFS *IPFSExportInfo

+ Internal interface{}

+ type IPFSExportInfo struct

+ NFTMetadataCID string

+ VideoFileCID string

+ type ImportTaskOutput struct

+ AssetSpec interface{}

+ MetadataFilePath string

+ VideoFilePath string

+ type TaskInfo struct

+ ID string

+ Snapshot json.RawMessage

+ Type string

+ type TaskOutput struct

+ Export *ExportTaskOutput

+ Import *ImportTaskOutput

+ Transcode *TranscodeTaskOutput

+ type TaskResultEvent struct

+ Error *ErrorInfo

+ Output *TaskOutput

+ Task TaskInfo

+ func NewTaskResultEvent(info TaskInfo, err *ErrorInfo, output *TaskOutput) *TaskResultEvent

+ type TaskTriggerEvent struct

+ Task TaskInfo

+ func NewTaskTriggerEvent(info TaskInfo) *TaskTriggerEvent

+ type TranscodeTaskOutput struct

+ Assets []ImportTaskOutput

Jan 4, 2022

Changes in this version

type Base

+ Type_ EventType

type Event

+ Type func() EventType

Dec 6, 2021

Changes in this version

+ type Condition struct

+ ExtraData interface{}

+ Frequency stats.ByWindow

+ LastProbeTime *UnixMillisTime

+ LastTransitionTime *UnixMillisTime

+ Status *bool

+ Type ConditionType

+ func NewCondition(condType ConditionType, ts time.Time, status *bool, last *Condition) *Condition

+ type ConditionType string

+ type HealthStatus struct

+ Conditions []*Condition

+ Healthy *Condition

+ ID string

+ Metrics MetricsMap

+ Multistream []*MultistreamStatus

+ func NewHealthStatus(id string, conditions []*Condition) *HealthStatus

+ func NewMergedHealthStatus(base *HealthStatus, values HealthStatus) *HealthStatus

+ func (s *HealthStatus) Condition(typ ConditionType) *Condition

+ func (s *HealthStatus) ConditionsCopy() []*Condition

+ func (s *HealthStatus) MetricsCopy() MetricsMap

+ func (s *HealthStatus) MultistreamCopy() []*MultistreamStatus

+ type Measure struct

+ Timestamp time.Time

+ Value float64

+ func (m *Measure) UnmarshalJSON(raw []byte) error

+ func (m Measure) MarshalJSON() ([]byte, error)

+ type Metric struct

+ Dimensions map[string]string

+ Last Measure

+ Name MetricName

+ func NewMetric(name MetricName, dimensions map[string]string, ts time.Time, value float64) *Metric

+ func (m *Metric) Matches(name MetricName, odim map[string]string) bool

+ type MetricName string

+ type MetricsMap map[MetricName][]*Metric

+ func (m MetricsMap) Add(metric *Metric) MetricsMap

+ func (m MetricsMap) GetMetric(name MetricName, dimensions map[string]string) *Metric

+ type MultistreamStatus struct

+ Connected *Condition

+ Target MultistreamTargetInfo

Oct 27, 2021

Changes in this version

type EventType

+ const EventTypeStreamState

type MediaServerMetricsEvent

+ Region string

+ type StreamState struct

+ Active bool

+ type StreamStateEvent struct

+ NodeID string

+ Region string

+ State StreamState

+ UserID string

+ func NewStreamStateEvent(nodeID, region, userID, streamID string, state StreamState) *StreamStateEvent

Oct 27, 2021

Changes in this version

type EventType

+ const EventTypeMediaServerMetrics

+ type MediaServerMetricsEvent struct

+ Multistream []*MultistreamTargetMetrics

+ NodeID string

+ Stats *StreamMetrics

+ func NewMediaServerMetricsEvent(nodeID, streamID string, stats *StreamMetrics, ...) *MediaServerMetricsEvent

+ type MultistreamMetrics struct

+ ActiveSec int64

+ Bytes int64

+ MediaTimeMs int64

+ type MultistreamTargetMetrics struct

+ Metrics *MultistreamMetrics

+ Target MultistreamTargetInfo

+ type StreamMetrics struct

+ MediaTimeMs *int64

Aug 26, 2021

Changes in this version

type Base

+ StreamID_ string

+ func (b *Base) StreamID() string

type Event

+ StreamID func() string

type EventType

+ const EventTypeWebhook

+ type MultistreamTargetInfo struct

+ ID string

+ Name string

+ Profile string

+ type MultistreamWebhookPayload struct

+ Target MultistreamTargetInfo

+ type UnixMillisTime struct

+ func NewUnixMillisTime(unixMillis int64) UnixMillisTime

+ func (u *UnixMillisTime) UnmarshalJSON(data []byte) error

+ func (u UnixMillisTime) MarshalJSON() ([]byte, error)

+ func (u UnixMillisTime) UnixMillis() int64

+ type WebhookEvent struct

+ Event string

+ Payload json.RawMessage

+ SessionID string

+ UserID string

+ func NewWebhookEvent(streamID, event, userID, sessionID string, payload interface{}) (*WebhookEvent, error)

Aug 12, 2021

Changes in this version

+ type Base struct

+ ID_ uuid.UUID

+ ManifestID_ string

+ Timestamp_ UnixNanoTime

+ Type EventType

+ func (b *Base) ID() uuid.UUID

+ func (b *Base) ManifestID() string

+ func (b *Base) Timestamp() time.Time

+ type Event interface

+ ID func() uuid.UUID

+ ManifestID func() string

+ Timestamp func() time.Time

+ func ParseEvent(data []byte) (Event, error)

+ type EventType string

+ const EventTypeTranscode

+ type OrchestratorMetadata struct

+ Address string

+ TranscoderUri string

+ type SegmentMetadata struct

+ ByteSize int

+ Duration float64

+ Name string

+ SeqNo uint64

+ type TranscodeAttemptInfo struct

+ Error *string

+ LatencyMs int64

+ Orchestrator OrchestratorMetadata

+ type TranscodeEvent struct

+ Attempts []TranscodeAttemptInfo

+ LatencyMs int64

+ NodeID string

+ Segment SegmentMetadata

+ StartTime UnixNanoTime

+ Success bool

+ func NewTranscodeEvent(nodeID, mid string, seg SegmentMetadata, startTime time.Time, success bool, ...) *TranscodeEvent

+ type UnixNanoTime struct

+ func (u *UnixNanoTime) UnmarshalJSON(data []byte) error

+ func (u UnixNanoTime) MarshalJSON() ([]byte, error)