ingress

package

v0.2.0 Latest Latest Go to latest Published: Oct 8, 2026 License: Apache-2.0 Imports: 7 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/darcys22/steadmesh

Links

Open Source Insights

Documentation ¶

Overview ¶

Package ingress accepts verified inbound human events (§9.1, §9.2). Authorisation comes only from the adapter-verified account and user ids, matched against the declared channel bindings; message text is never consulted (A05). An event is acknowledged only after it is committed, and replays are deduplicated by the store (A09).

Index ¶

type Sink
- func (s *Sink) Accept(ctx context.Context, connection string, ev connectors.InboundEvent) error
type Store

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Sink ¶

type Sink struct {
	OrganizationID string
	Store          Store
	Metrics        *metrics.Metrics
	Log            *slog.Logger
}

Sink is the connectors.IngressSink of one organisation.

func (*Sink) Accept ¶

func (s *Sink) Accept(ctx context.Context, connection string, ev connectors.InboundEvent) error

Accept implements connectors.IngressSink. Events that no binding authorises are dropped (nil is returned so the adapter does not redeliver them).

type Store ¶

type Store interface {
	Organization(ctx context.Context, orgID string) (*store.Organization, error)
	SeatByKey(ctx context.Context, orgID, key string) (*store.Seat, error)
	IngestHuman(ctx context.Context, in store.HumanMessage) (*store.Ingested, error)
}

Store is the persistence the sink needs.

Source Files ¶

View all Source files

ingress.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL