Documentation
¶
Index ¶
- type ControlPlane
- func (c *ControlPlane) Describe() contract.SystemDescriptor
- func (c *ControlPlane) Interrupt(ctx context.Context, sessionID string) (*contract.RuntimeEvent, error)
- func (c *ControlPlane) ListSessions(ctx context.Context, runtime string) ([]contract.RuntimeSession, error)
- func (c *ControlPlane) Respond(ctx context.Context, request api.RespondRequest) (*contract.RuntimeEvent, error)
- func (c *ControlPlane) ResumeSession(ctx context.Context, runtime string, request api.ResumeSessionRequest) (*contract.RuntimeSession, error)
- func (c *ControlPlane) SendInput(ctx context.Context, request api.SendInputRequest) (*contract.RuntimeEvent, error)
- func (c *ControlPlane) StartSession(ctx context.Context, runtime string, request api.StartSessionRequest) (*contract.RuntimeSession, error)
- func (c *ControlPlane) StopSession(ctx context.Context, sessionID string) (*contract.RuntimeEvent, error)
- func (c *ControlPlane) SubscribeEvents(buffer int) (<-chan contract.RuntimeEvent, func())
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ControlPlane ¶
type ControlPlane struct {
// contains filtered or unexported fields
}
ControlPlane exposes the app-managed runtime control plane as an importable Go API. It intentionally reuses the public contract and controlplane types so callers do not need to shell out or duplicate the RPC protocol.
func New ¶
func New() *ControlPlane
func (*ControlPlane) Describe ¶
func (c *ControlPlane) Describe() contract.SystemDescriptor
func (*ControlPlane) Interrupt ¶
func (c *ControlPlane) Interrupt(ctx context.Context, sessionID string) (*contract.RuntimeEvent, error)
func (*ControlPlane) ListSessions ¶
func (c *ControlPlane) ListSessions(ctx context.Context, runtime string) ([]contract.RuntimeSession, error)
func (*ControlPlane) Respond ¶
func (c *ControlPlane) Respond(ctx context.Context, request api.RespondRequest) (*contract.RuntimeEvent, error)
func (*ControlPlane) ResumeSession ¶
func (c *ControlPlane) ResumeSession(ctx context.Context, runtime string, request api.ResumeSessionRequest) (*contract.RuntimeSession, error)
func (*ControlPlane) SendInput ¶
func (c *ControlPlane) SendInput(ctx context.Context, request api.SendInputRequest) (*contract.RuntimeEvent, error)
func (*ControlPlane) StartSession ¶
func (c *ControlPlane) StartSession(ctx context.Context, runtime string, request api.StartSessionRequest) (*contract.RuntimeSession, error)
func (*ControlPlane) StopSession ¶
func (c *ControlPlane) StopSession(ctx context.Context, sessionID string) (*contract.RuntimeEvent, error)
func (*ControlPlane) SubscribeEvents ¶
func (c *ControlPlane) SubscribeEvents(buffer int) (<-chan contract.RuntimeEvent, func())
Source Files
Click to show internal directories.
Click to hide internal directories.