loop

type AsyncControlCodec ¶ added in v0.1.18

type AsyncControlCodec interface {
	StartControlAsync(context.Context, *MoltnetClient, bridgeconfig.Config) error
	ControlAccepted(bridgeconfig.Config, protocol.Event, ControlAcceptance) error
}

AsyncControlCodec persists accepted work before the inbound attachment ACK and follows its terminal result independently. Moltnet remains transport; the runtime remains responsible for execution policy and scheduling.

type ControlAcceptance ¶ added in v0.1.18

type ControlAcceptance struct {
	ID            string
	AgentID       string
	DeliveryID    string
	RequestDigest string
	AcceptedAt    time.Time
}

ControlAcceptance is runtime-neutral durable acceptance metadata. A codec may use it to start asynchronous terminal-receipt delivery after the attachment has already accepted the inbound event.

type ControlCodec ¶ added in v0.1.18

type ControlCodec interface {
	EncodeRequest(context.Context, bridgeconfig.Config, ControlDelivery) (*http.Request, error)
	DecodeResponse(bridgeconfig.Config, ControlDelivery, *http.Response) (ControlResult, error)
}

ControlCodec owns a runtime's request and response wire contracts. A nil request with no error intentionally skips a delivery, which lets runtimes without a bootstrap wire event opt out without branching in the loop.

type ControlDelivery ¶ added in v0.1.18

type ControlDelivery struct {
	Target        protocol.Target
	EventID       string
	From          string
	Message       string
	TransportText string
	OccurredAt    time.Time
}

ControlDelivery is the runtime-neutral wake material produced by the Moltnet stream. Runtime adapters own its wire encoding.

type ControlPublicationObserver ¶ added in v0.1.18

type ControlPublicationObserver interface {
	ControlResultPublished(ControlDelivery)
}

ControlPublicationObserver is an optional codec hook called only after a requested Moltnet publication succeeds.

type ControlResult ¶ added in v0.1.18

type ControlResult struct {
	Text        string
	Publish     bool
	PublishOnce bool
	Acceptance  *ControlAcceptance
}

ControlResult tells the shared loop whether a decoded runtime result should be published back to the inbound Moltnet conversation.

type DurableAcceptanceCodec ¶ added in v0.1.18

type DurableAcceptanceCodec interface {
	RequiresDurableAcceptance() bool
}

DurableAcceptanceCodec marks codecs whose successful response is the sole attachment ACK boundary. Failed acceptance must remain unacknowledged and replayable; it cannot be converted into a skipped delivery.

type MoltnetClient ¶

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

func NewMoltnetClient(config bridgeconfig.Config) *MoltnetClient

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

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

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

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