dahuatasks

Documentation

Index

• Variables
• func HandlePushStreamTask(ctx context.Context, task *squeuel.Task) error
• func HandleSyncStreamTask(ctx context.Context, task *squeuel.Task) error
• func Init(_app App)
• func RegisterStreams()
• type App
• type StreamPayload
  • func (p StreamPayload) TaskID() squeuel.Option

Variables

var (
	SyncStreamTask = squeuel.NewTaskBuilder[StreamPayload]("dahua-stream:sync")
	PushStreamTask = squeuel.NewTaskBuilder[StreamPayload]("dahua-stream:push")
)

Functions

func HandlePushStreamTask

func HandlePushStreamTask(ctx context.Context, task *squeuel.Task) error

func HandleSyncStreamTask

func HandleSyncStreamTask(ctx context.Context, task *squeuel.Task) error

func Init

func Init(_app App)

func RegisterStreams

func RegisterStreams()

Types

type App

type App struct {
	DB  sqlite.DB
	Hub *bus.Hub
}

type StreamPayload

type StreamPayload struct {
	DeviceID int64
}

func (StreamPayload) TaskID

func (p StreamPayload) TaskID() squeuel.Option