ipc

type ExecutorType string

type Exiting struct {
	Reason string `json:"reason"`
}

type InitializeRequest struct {
	AsyncioDebug      bool    `json:"asyncio_debug"`
	PingInterval      float64 `json:"ping_interval"`
	PingTimeout       float64 `json:"ping_timeout"`
	HighPingThreshold float64 `json:"high_ping_threshold"`
}

type InitializeResponse struct {
	Error string `json:"error,omitempty"`
}

type JobExecutor interface {
	ID() string
	Status() JobStatus
	Started() bool
	LaunchJob(ctx context.Context, job *livekit.Job) error
	Close(ctx context.Context) error
}

type JobStatus string

type Message struct {
	Type    MessageType     `json:"type"`
	Payload json.RawMessage `json:"payload,omitempty"`
}

type MessageType string

type PingRequest struct {
	Timestamp int64 `json:"timestamp"`
}

type PongResponse struct {
	LastTimestamp int64 `json:"last_timestamp"`
	Timestamp     int64 `json:"timestamp"`
}

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

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

type ShutdownRequest struct {
	Reason string `json:"reason"`
}

type StartJobRequest struct {
	Job *livekit.Job `json:"job"`
}

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