runner_manager

package

v1.7.2 Latest Latest Go to latest Published: Dec 5, 2025 License: MIT Imports: 27 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type CamService interface {
	For(address string, cameraType model.CameraType) (camera.Cam, error)
}

type Manager struct {
	protobuf.UnimplementedRunnerManagerServiceServer
	// contains filtered or unexported fields
}

Manager manages communication with runners and handles job distribution

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

New returns a new instance of Manager with the given Options

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) RequestSelfStream(ctx context.Context, stream model.Stream) error

func (m *Manager) Run() error

func (m *Manager) TriggerDueStreams() error

type Option func(m *Manager)

Option is a func that applies configuration to the Manager

func WithCamService(camService CamService) Option

func WithListenAddr(addr string) Option

WithListenAddr sets the address the Manager listens on for gRPC connections from the Runner. If not applied, the default is used (:50056)

func WithMassStorage(path string) Option

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