loop

func (*MoltnetClient) ReportWakeFailed ¶ added in v0.1.14

func (c *MoltnetClient) ReportWakeFailed(
	ctx context.Context,
	requestPayload protocol.ReportWakeFailedRequest,
) error

ReportWakeFailed posts a terminal (permanent or retry-budget-exhausted) control-delivery wake failure to POST /v1/agents/wake-failed, so the server records agent.wake.failed for an event the bridge already ACKed and skipped, without tearing down the attachment socket to do so. See internal/bridge/loop/control_delivery.go's reportWakeFailure, the sole caller.

func (*MoltnetClient) SendMessage ¶

func (c *MoltnetClient) SendMessage(
	ctx context.Context,
	requestPayload protocol.SendMessageRequest,
) (protocol.MessageAccepted, error)

func (*MoltnetClient) StreamEvents ¶

func (c *MoltnetClient) StreamEvents(
	ctx context.Context,
	config bridgeconfig.Config,
	handle func(event protocol.Event) error,
) error

func (*MoltnetClient) StreamEventsReady ¶

func (c *MoltnetClient) StreamEventsReady(
	ctx context.Context,
	config bridgeconfig.Config,
	onReady func(),
	handle func(event protocol.Event) error,
) error