digit_video_recorder_driver

Documentation

Index

• Constants
• Variables
• type DigitVideoRecorderDriver
  • func NewDigitVideoRecorderDriver(name string, opt *DigitVideoRecorderDriverOption, args ...interface{}) (DigitVideoRecorderDriver, error)
  • func NewFFmpegDigitVideoRecorderDriver(opt *DigitVideoRecorderDriverOption, args ...interface{}) (DigitVideoRecorderDriver, error)
• type DigitVideoRecorderDriverFactory
• type DigitVideoRecorderDriverOption
  • func (o *DigitVideoRecorderDriverOption) Sub(key string) *DigitVideoRecorderDriverOption
• type DigitVideoRecorderState
  • func (s *DigitVideoRecorderState) String() string
• type FFmpegDigitVideoRecorderDriver
  • func (drv *FFmpegDigitVideoRecorderDriver) GetRecord(id string) (*Record, error)
  • func (drv *FFmpegDigitVideoRecorderDriver) ListRecords(flt ListRecordsFitler) ([]*Record, error)
  • func (drv *FFmpegDigitVideoRecorderDriver) Reset() error
  • func (drv *FFmpegDigitVideoRecorderDriver) Start() error
  • func (drv *FFmpegDigitVideoRecorderDriver) State() *DigitVideoRecorderState
  • func (drv *FFmpegDigitVideoRecorderDriver) Stop() error
• type ListRecordsFitler
• type Record
  • func (r *Record) Data() map[string]interface{}
  • func (r *Record) Reader() (io.Reader, error)
• type RecordStorage
  • func NewRecordStorage(name string, opt *RecordStorageOption, args ...interface{}) (RecordStorage, error)
• type RecordStorageOption

Constants

const (
	FFMPEG_DEFAULT_BINARY = `ffmpeg`
)

Variables

var (
	DIGITI_VIDEO_RECORDER_STATE_ON  = &DigitVideoRecorderState{state: "on"}
	DIGITI_VIDEO_RECORDER_STATE_OFF = &DigitVideoRecorderState{state: "off"}
)

var (
	ErrInvalidDigitVideoRecorderDriver = errors.New("invalid digit video recorder driver")
	ErrInvalidRecordStorage            = errors.New("invalid record storage")
	ErrNotStartable                    = errors.New("not startable")
	ErrNotFound                        = errors.New("record not found")
)

Types

type DigitVideoRecorderDriver

type DigitVideoRecorderDriver interface {
	Start() error
	Stop() error
	State() *DigitVideoRecorderState
	GetRecord(id string) (*Record, error)
	ListRecords(ListRecordsFitler) ([]*Record, error)
}

func NewDigitVideoRecorderDriver

func NewDigitVideoRecorderDriver(name string, opt *DigitVideoRecorderDriverOption, args ...interface{}) (DigitVideoRecorderDriver, error)

func NewFFmpegDigitVideoRecorderDriver

func NewFFmpegDigitVideoRecorderDriver(opt *DigitVideoRecorderDriverOption, args ...interface{}) (DigitVideoRecorderDriver, error)

type DigitVideoRecorderDriverFactory

type DigitVideoRecorderDriverFactory func(opt *DigitVideoRecorderDriverOption, args ...interface{}) (DigitVideoRecorderDriver, error)

type DigitVideoRecorderDriverOption

type DigitVideoRecorderDriverOption struct {
	*viper.Viper
}

func (*DigitVideoRecorderDriverOption) Sub

func (o *DigitVideoRecorderDriverOption) Sub(key string) *DigitVideoRecorderDriverOption

type DigitVideoRecorderState

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

func (*DigitVideoRecorderState) String

func (s *DigitVideoRecorderState) String() string

type FFmpegDigitVideoRecorderDriver

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

func (*FFmpegDigitVideoRecorderDriver) GetRecord

func (drv *FFmpegDigitVideoRecorderDriver) GetRecord(id string) (*Record, error)

func (*FFmpegDigitVideoRecorderDriver) ListRecords

func (drv *FFmpegDigitVideoRecorderDriver) ListRecords(flt ListRecordsFitler) ([]*Record, error)

func (*FFmpegDigitVideoRecorderDriver) Reset

func (drv *FFmpegDigitVideoRecorderDriver) Reset() error

func (*FFmpegDigitVideoRecorderDriver) Start

func (drv *FFmpegDigitVideoRecorderDriver) Start() error

func (*FFmpegDigitVideoRecorderDriver) State

func (drv *FFmpegDigitVideoRecorderDriver) State() *DigitVideoRecorderState

func (*FFmpegDigitVideoRecorderDriver) Stop

func (drv *FFmpegDigitVideoRecorderDriver) Stop() error

type ListRecordsFitler

type ListRecordsFitler struct {
	Range struct {
		StartAt time.Time
		EndAt   time.Time
	}
}

type Record

type Record struct {
	Id      string    `yaml:"id"`
	StartAt time.Time `yaml:"start_at"`
	EndAt   time.Time `yaml:"end_at"`
	Path    string    `yaml:"path"`
}

func (*Record) Data

func (r *Record) Data() map[string]interface{}

func (*Record) Reader

func (r *Record) Reader() (io.Reader, error)

type RecordStorage

type RecordStorage interface {
	ListRecords(ListRecordsFitler) ([]*Record, error)
	GetRecord(id string) (*Record, error)
	SetRecord(*Record) error
	UnsetRecord(id string) error
}

func NewRecordStorage

func NewRecordStorage(name string, opt *RecordStorageOption, args ...interface{}) (RecordStorage, error)

type RecordStorageOption

type RecordStorageOption struct {
	*viper.Viper
}