machinehttp

type ExecStreamExecutor interface {
	OpenExecStream(context.Context, machine.StreamRequest) (io.ReadCloser, error)
}

type ExecuteRequest struct {
	OperationID string                   `json:"operation_id"`
	Context     machine.OperationContext `json:"context"`
	Input       json.RawMessage          `json:"input,omitempty"`
}

type Executor interface {
	SupportedOperationIDs() []string
	Execute(context.Context, machine.Operation, machine.OperationContext, json.RawMessage, ProgressReporter) (json.RawMessage, error)
}

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

type LogStreamExecutor interface {
	OpenLogStream(context.Context, machine.StreamRequest) (io.ReadCloser, error)
}

type ProgressReporter func(machine.OperationProgress)

type TerminalExecutor interface {
	OpenTerminal(context.Context, machine.StreamRequest) (terminal.Session, error)
	RecordTerminalAudit(context.Context, machine.StreamDescriptor, string) error
}