runner

Documentation

Index

• type HLSServer
  • func NewHLSServer(liveDir string, log *slog.Logger, version string) *HLSServer
  • func (h *HLSServer) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (h *HLSServer) Start() error
• type Runner
  • func NewRunner(v string) *Runner
  • func (r *Runner) Cleanup()
  • func (r *Runner) Drain()
  • func (r *Runner) InitApiGrpc()
  • func (r *Runner) RegisterWithGocast(retries int)
  • func (r *Runner) RequestStream(_ context.Context, req *protobuf.StreamRequest) (*protobuf.StreamResponse, error)
  • func (r *Runner) RequestStreamEnd(_ context.Context, req *protobuf.StreamEndRequest) (*protobuf.StreamEndResponse, error)
  • func (r *Runner) Run(ctx context.Context)
  • func (r *Runner) RunAction(a []actions.Action, data map[string]any, logger *slog.Logger) string

Types

type HLSServer

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

func NewHLSServer

func NewHLSServer(liveDir string, log *slog.Logger, version string) *HLSServer

func (*HLSServer) ServeHTTP

func (h *HLSServer) ServeHTTP(w http.ResponseWriter, r *http.Request)

func (*HLSServer) Start

func (h *HLSServer) Start() error

type Runner

type Runner struct {
	JobCount chan int

	StartTime time.Time
	protobuf.UnimplementedRunnerServiceServer

	Metrics *metrics.Broker
	Version string
	// contains filtered or unexported fields
}

func NewRunner

func NewRunner(v string) *Runner

func (*Runner) Cleanup

func (r *Runner) Cleanup()

Cleanup is called on force shutdown while actions are still running. it cancels all running actions

func (*Runner) Drain

func (r *Runner) Drain()

func (*Runner) InitApiGrpc

func (r *Runner) InitApiGrpc()

func (*Runner) RegisterWithGocast

func (r *Runner) RegisterWithGocast(retries int)

func (*Runner) RequestStream

func (r *Runner) RequestStream(_ context.Context, req *protobuf.StreamRequest) (*protobuf.StreamResponse, error)

func (*Runner) RequestStreamEnd

func (r *Runner) RequestStreamEnd(_ context.Context, req *protobuf.StreamEndRequest) (*protobuf.StreamEndResponse, error)

func (*Runner) Run

func (r *Runner) Run(ctx context.Context)

func (*Runner) RunAction

func (r *Runner) RunAction(a []actions.Action, data map[string]any, logger *slog.Logger) string