runner_manager

Dec 5, 2025

Changes in this version

+ type CamService interface

+ For func(address string, cameraType model.CameraType) (camera.Cam, error)

type Option

+ func WithCamService(camService CamService) Option

Nov 22, 2025

Changes in this version

type Manager

+ func (m *Manager) RequestSelfStream(ctx context.Context, stream model.Stream) error

type Option

+ func WithMassStorage(path string) Option

+ func WithSubtitleClient(client pb.SubtitleGeneratorClient, auth string) Option

Oct 2, 2025

Changes in this version

+ type Manager struct

+ func New(dao dao.DaoWrapper, opts ...Option) *Manager

+ func (m *Manager) Notify(ctx context.Context, notification *protobuf.Notification) (*protobuf.NotificationResponse, error)

+ func (m *Manager) Register(ctx context.Context, req *protobuf.RegisterRequest) (*protobuf.RegisterResponse, error)

+ func (m *Manager) Run() error

+ func (m *Manager) TriggerDueStreams() error

+ type Option func(m *Manager)

+ func WithListenAddr(addr string) Option