Documentation
¶
Index ¶
- func GetSource() api.Source
- type Source
- func (s *Source) Close(_ api.StreamContext) error
- func (s *Source) Connect(_ api.StreamContext, sch api.StatusChangeHandler) error
- func (s *Source) Info() model.NodeInfo
- func (s *Source) Provision(ctx api.StreamContext, props map[string]any) error
- func (s *Source) Subscribe(ctx api.StreamContext, ingest api.BytesIngest, ingestError api.ErrorIngest) error
- func (s *Source) TransformType() api.Source
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Source ¶
type Source struct {
Url string `json:"url"`
// Check https://www.ffmpeg.org/general.html#Video-Codecs, default to 'mjpeg'
Codec string `json:"codec"`
DebugResp bool `json:"debugResp"`
InputArgs map[string]any `json:"inputArgs"`
Interval cast.DurationConf `json:"interval"`
// contains filtered or unexported fields
}
func (*Source) Connect ¶
func (s *Source) Connect(_ api.StreamContext, sch api.StatusChangeHandler) error
func (*Source) Subscribe ¶
func (s *Source) Subscribe(ctx api.StreamContext, ingest api.BytesIngest, ingestError api.ErrorIngest) error
func (*Source) TransformType ¶
Source Files
Click to show internal directories.
Click to hide internal directories.