ipc

type ActiveJobsRequest struct{}

type ActiveJobsResponse struct {
	Jobs        []RunningJobInfo `json:"jobs,omitempty"`
	ReloadCount int              `json:"reload_count"`
}

type DumpStackTraceRequest struct{}

type ExecutorType string

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

type InferenceRequest struct {
	Method    string `json:"method"`
	RequestID string `json:"request_id"`
	Data      []byte `json:"data"`
}

type InferenceResponse struct {
	RequestID string `json:"request_id"`
	Data      []byte `json:"data"`
	Error     string `json:"error,omitempty"`
}

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

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

type JSONJob struct {
	ID string
	// contains filtered or unexported fields
}

type Job interface {
	GetId() string
}

type JobAcceptArguments struct {
	Name       string            `json:"name"`
	Identity   string            `json:"identity"`
	Metadata   string            `json:"metadata"`
	Attributes map[string]string `json:"attributes,omitempty"`
}

type JobExecutor interface {
	ID() string
	Status() JobStatus
	Started() bool
	Job() Job
	RunningJob() *RunningJobInfo
	LaunchJob(ctx context.Context, job Job) error
	LaunchRunningJob(ctx context.Context, info RunningJobInfo) 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 ProcPoolEvent string

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

type ReloadJobsRequest struct{}

type ReloadJobsResponse struct {
	Jobs        []RunningJobInfo `json:"jobs,omitempty"`
	ReloadCount int              `json:"reload_count"`
}

type Reloaded struct{}

type RunningJobInfo struct {
	AcceptArguments JobAcceptArguments `json:"accept_arguments"`
	Job             Job                `json:"job"`
	URL             string             `json:"url"`
	Token           string             `json:"token"`
	WorkerID        string             `json:"worker_id"`
	FakeJob         bool               `json:"fake_job"`
}

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

type ShutdownRequestAck struct{}

type ShuttingDown struct{}

type StartJobRequest struct {
	RunningJob RunningJobInfo `json:"running_job"`
}

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