daimon

func (*Adapter) Name ¶

func (*Adapter) Name() string

func (*Adapter) Run ¶

func (*Adapter) Run(ctx context.Context, config bridgeconfig.Config) error

func (*Codec) ControlAccepted ¶

func (c *Codec) ControlAccepted(config bridgeconfig.Config, event protocol.Event, acceptance loop.ControlAcceptance) error

func (*Codec) DecodeResponse ¶

func (*Codec) DecodeResponse(
	config bridgeconfig.Config,
	delivery loop.ControlDelivery,
	response *http.Response,
) (loop.ControlResult, error)

func (*Codec) EncodeRequest ¶

func (c *Codec) EncodeRequest(
	ctx context.Context,
	config bridgeconfig.Config,
	delivery loop.ControlDelivery,
) (*http.Request, error)

func (*Codec) RequiresDurableAcceptance ¶

func (*Codec) RequiresDurableAcceptance() bool

func (*Codec) StartControlAsync ¶

func (c *Codec) StartControlAsync(ctx context.Context, client *loop.MoltnetClient, config bridgeconfig.Config) error

func (*Codec) WaitControlAsync ¶ added in v0.1.19

func (c *Codec) WaitControlAsync()

WaitControlAsync blocks until the follower has returned. Every blocking call it makes is bound to the context StartControlAsync was given (`http.NewRequestWithContext` in fetch, and the same context through publish), so once the loop cancels it this returns promptly rather than waiting out a poll interval or an in-flight request.