request

package

v0.0.3 Latest Latest Go to latest Published: May 26, 2026 License: MIT Imports: 2 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Outbox interface {
	Enqueue(context.Context, []byte) error
}

type Registry interface {
	Register(id string)
	Remove(id string)
	Consume(ctx context.Context, id string) error
	Has(id string) bool
}

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

func NewSendRequestService(
	egress Outbox,
	pending Registry,
) *SendRequestService

func (service *SendRequestService) Send(ctx context.Context, input app.Frame) error