ecosystem

type Binding ¶

type Binding struct {
	Producer       string
	InstallationID string
	Namespace      string
	AppID          string
	OrgID          string
	TenantID       string
}

Binding comes from the host installation registry, never delivery content. Each adapter serves one immutable namespace ownership record.

func (b Binding) Validate() error

type Chronicle ¶

type Chronicle struct {
	Binding Binding
	Client  ChronicleClient
}

func (s Chronicle) Accept(ctx context.Context, d durable.Delivery) (durable.SinkReceipt, error)

type ChronicleClient ¶

type ChronicleClient interface {
	RecordOnce(context.Context, ca.Request) (*ca.Receipt, error)
}

type ConflictResponse ¶

type ConflictResponse struct {
	Destination       string `json:"destination"`
	SourceKey         string `json:"source_key"`
	SourceFingerprint string `json:"source_fingerprint"`
	Fingerprint       string `json:"fingerprint"`
}

ConflictResponse is emitted only after the reliable API confirms a conflict. Its binding prevents an unrelated proxy error from permanently blocking work.

type Relay ¶

type Relay struct {
	Binding Binding
	Client  RelayClient
}

func (s Relay) Accept(ctx context.Context, d durable.Delivery) (durable.SinkReceipt, error)

type RelayClient ¶

type RelayClient interface {
	SendReliable(context.Context, ra.Request) (*ra.Receipt, error)
}

type Remote ¶

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

Remote owns a fixed destination and never accepts URLs from delivery content. Credentials are private and error messages contain no request or response data.

func NewRemote(endpoint, bearer string, timeout time.Duration, localLoopbackHTTP bool) (*Remote, error)

func (r *Remote) Close()

func (r *Remote) RecordOnce(ctx context.Context, request ca.Request) (*ca.Receipt, error)

func (r *Remote) SendReliable(ctx context.Context, request ra.Request) (*ra.Receipt, error)