Documentation
¶
Index ¶
- type ControlPlane
- func (c *ControlPlane) Describe() contract.SystemDescriptor
- func (c *ControlPlane) GetThread(ctx context.Context, threadID string, providerSessionID string) (*contract.TrackedThread, error)
- func (c *ControlPlane) GetTrackedSession(ctx context.Context, sessionID string, providerSessionID string) (*contract.TrackedSession, error)
- 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) ListTrackedSessions(ctx context.Context, runtime string) ([]contract.TrackedSession, 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) SetThreadMetadata(ctx context.Context, threadID string, metadata contract.ThreadMetadata) 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) GetThread ¶ added in v0.5.0
func (c *ControlPlane) GetThread(ctx context.Context, threadID string, providerSessionID string) (*contract.TrackedThread, error)
func (*ControlPlane) GetTrackedSession ¶ added in v0.5.0
func (c *ControlPlane) GetTrackedSession(ctx context.Context, sessionID string, providerSessionID string) (*contract.TrackedSession, error)
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) ListTrackedSessions ¶ added in v0.5.0
func (c *ControlPlane) ListTrackedSessions(ctx context.Context, runtime string) ([]contract.TrackedSession, 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) SetThreadMetadata ¶ added in v0.5.0
func (c *ControlPlane) SetThreadMetadata(ctx context.Context, threadID string, metadata contract.ThreadMetadata) 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.