codex

package

v0.1.1 Latest Latest Go to latest Published: Mar 3, 2026 License: MIT Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Adapter communicates with Codex via its WebSocket JSON-RPC API server.

func New(cfg runtime.AdapterConfig) *Adapter

New creates a Codex adapter.

func (a *Adapter) CreateSession(_ context.Context) (string, error)

func (a *Adapter) Events() <-chan runtime.Event

func (a *Adapter) IsHealthy(_ context.Context) bool

func (a *Adapter) RespondToUserInput(callID string, answers []runtime.QuestionAnswer) error

RespondToUserInput sends answers back to Codex via JSON-RPC.

func (a *Adapter) ResumeSession(_ context.Context, sessionID string) error

func (a *Adapter) Runtime() runtime.Runtime

func (a *Adapter) SendMessage(_ context.Context, text string) error

func (a *Adapter) Start(ctx context.Context) error

func (a *Adapter) Stop(_ context.Context) error

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

Client is a JSON-RPC 2.0 client over WebSocket.

func NewClient(url string) (*Client, error)

NewClient dials a WebSocket and starts reading.

func (c *Client) Call(method string, params interface{}) (json.RawMessage, error)

Call sends a JSON-RPC request and waits for the response.

func (c *Client) Close() error

Close shuts down the WebSocket connection.

func (c *Client) Notifications() <-chan rpcResponse

Notifications returns the channel for server-push notifications.