byoc

type AIAuthRequest struct {
	// Stream name or stream key
	Stream    string `json:"stream"`
	StreamKey string `json:"stream_key"`

	// Stream type, eg RTMP or WHIP
	Type string `json:"type"`

	// Query parameters that came with the stream, if any
	QueryParams string `json:"query_params,omitempty"`

	// Gateway host
	GatewayHost string `json:"gateway_host"`
	WhepURL     string `json:"whep_url"`
	StatusURL   string `json:"status_url"`
	UpdateURL   string `json:"update_url"`
}

type AIAuthResponse struct {
	// Where to send the output video
	RTMPOutputURL string `json:"rtmp_output_url"`

	// Name of the pipeline to run
	Pipeline string `json:"pipeline"`

	// ID of the pipeline to run
	PipelineID string `json:"pipeline_id"`

	// ID of the stream
	StreamID string `json:"stream_id"`

	// Parameters for the pipeline
	PipelineParams json.RawMessage `json:"pipeline_parameters"`
	// contains filtered or unexported fields
}

type BYOCGatewayServer struct {
	StreamPipelines map[string]*BYOCStreamPipeline
	// contains filtered or unexported fields
}

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

type BYOCStreamPipeline struct {
	RequestID    string
	StreamID     string
	Params       []byte
	Pipeline     string
	ControlPub   *trickle.TricklePublisher
	StopControl  func()
	ReportUpdate func([]byte)
	OutCond      *sync.Cond
	OutWriter    *media.RingBuffer
	Closed       bool

	DataWriter *media.SegmentWriter
	// contains filtered or unexported fields
}

type JobOrchestratorsFilter struct {
	Exclude []string `json:"exclude,omitempty"`
	Include []string `json:"include,omitempty"`
}

type JobParameters struct {
	// Gateway
	Orchestrators JobOrchestratorsFilter `json:"orchestrators,omitempty"` // list of orchestrators to use for the job

	// Orchestrator
	EnableVideoIngress bool `json:"enable_video_ingress,omitempty"`
	EnableVideoEgress  bool `json:"enable_video_egress,omitempty"`
	EnableDataOutput   bool `json:"enable_data_output,omitempty"`
}

type JobRequest struct {
	ID            string `json:"id"`
	Request       string `json:"request"`
	Parameters    string `json:"parameters"` // additional information for the Gateway to use to select orchestrators or to send to the worker
	Capability    string `json:"capability"`
	CapabilityUrl string `json:"capability_url"` // this is set when verified orch as capability
	Sender        string `json:"sender"`
	Sig           string `json:"sig"`
	Timeout       int    `json:"timeout_seconds"`

	OrchSearchTimeout     time.Duration
	OrchSearchRespTimeout time.Duration
}

type JobRequestDetails struct {
	StreamId string `json:"stream_id"`
}

type JobSender struct {
	Addr string `json:"addr"`
	Sig  string `json:"sig"`
}

type JobToken struct {
	SenderAddress     *JobSender        `json:"sender_address,omitempty"`
	TicketParams      *net.TicketParams `json:"ticket_params,omitempty"`
	Balance           int64             `json:"balance,omitempty"`
	Price             *net.PriceInfo    `json:"price,omitempty"`
	ServiceAddr       string            `json:"service_addr,omitempty"`
	AvailableCapacity int64             `json:"available_capacity,omitempty"`

	LastNonce uint32
}

type Orchestrator interface {
	TranscoderSecret() string
	VerifySig(addr ethcommon.Address, msg string, sig []byte) bool
	ReserveExternalCapabilityCapacity(capability string) error
	GetUrlForCapability(capability string) string
	JobPriceInfo(sender ethcommon.Address, capability string) (*net.PriceInfo, error)
	TicketParams(sender ethcommon.Address, priceInfo *net.PriceInfo) (*net.TicketParams, error)
	Balance(sender ethcommon.Address, manifestID core.ManifestID) *big.Rat
	CheckExternalCapabilityCapacity(capability string) int64
	RemoveExternalCapability(extCapName string) error
	RegisterExternalCapability(extCapSettings string) (*core.ExternalCapability, error)
	FreeExternalCapabilityCapacity(capability string) error
	ServiceURI() *url.URL
	ProcessPayment(ctx context.Context, payment net.Payment, manifestID core.ManifestID) error
	DebitFees(sender ethcommon.Address, manifestID core.ManifestID, priceInfo *net.PriceInfo, units int64)
}

type OrchestratorSwapper interface {
	// contains filtered or unexported methods
}

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

type StartRequest struct {
	Stream     string `json:"stream_name"`
	RtmpOutput string `json:"rtmp_output"`
	StreamId   string `json:"stream_id"`
	Params     string `json:"params"`
}

type StatusStore interface {
	Store(streamID string, status map[string]interface{})
	StoreKey(streamID, key string, status interface{})
	Clear(streamID string)
	Get(streamID string) (map[string]interface{}, bool)
	StoreIfNotExists(streamID string, key string, status interface{})
}

type StreamUrls struct {
	StreamId      string `json:"stream_id"`
	WhipUrl       string `json:"whip_url"`
	WhepUrl       string `json:"whep_url"`
	RtmpUrl       string `json:"rtmp_url"`
	RtmpOutputUrl string `json:"rtmp_output_url"`
	UpdateUrl     string `json:"update_url"`
	StatusUrl     string `json:"status_url"`
	DataUrl       string `json:"data_url"`
	StopUrl       string `json:"stop_url"`
}