controlplane

func (b *EventBus) Publish(event contract.RuntimeEvent)

func (b *EventBus) Subscribe(buffer int) (<-chan contract.RuntimeEvent, func())

func (l *EventLogger) Write(event contract.RuntimeEvent) error

func (s *RPCServer) ServeUnix(ctx context.Context, socketPath string) error

func (s *Service) Describe() contract.SystemDescriptor

func (s *Service) Interrupt(
	ctx context.Context,
	sessionID string,
) (*contract.RuntimeEvent, error)

func (s *Service) ListSessions(
	ctx context.Context,
	runtime string,
) ([]contract.RuntimeSession, error)

func (s *Service) PublishEvent(event contract.RuntimeEvent)

func (s *Service) Respond(
	ctx context.Context,
	request api.RespondRequest,
) (*contract.RuntimeEvent, error)

func (s *Service) ResumeSession(
	ctx context.Context,
	runtime string,
	request api.ResumeSessionRequest,
) (*contract.RuntimeSession, error)

func (s *Service) SendInput(
	ctx context.Context,
	request api.SendInputRequest,
) (*contract.RuntimeEvent, error)

func (s *Service) StartSession(
	ctx context.Context,
	runtime string,
	request api.StartSessionRequest,
) (*contract.RuntimeSession, error)

func (s *Service) StopSession(
	ctx context.Context,
	sessionID string,
) (*contract.RuntimeEvent, error)

func (s *Service) SubscribeEvents(buffer int) (<-chan contract.RuntimeEvent, func())

func (d *SessionDirectory) Delete(sessionID string)

func (d *SessionDirectory) Get(sessionID string) (contract.RuntimeSession, bool)

func (d *SessionDirectory) List() []contract.RuntimeSession

func (d *SessionDirectory) UpdateFromEvent(event contract.RuntimeEvent)

func (d *SessionDirectory) Upsert(session contract.RuntimeSession)