Documentation
¶
Overview ¶
Package memory provides explicit local ephemeral fan-out for pub/sub contracts.
Index ¶
- type Backend
- func (b *Backend) Close() error
- func (*Backend) FoundryAdapter(frameworkadapter.Seal)
- func (b *Backend) Publish(ctx context.Context, channel pubsub.Channel, data []byte) (uint64, error)
- func (b *Backend) Subscribe(ctx context.Context, channels []pubsub.Channel, limits pubsub.Limits) (pubsub.Stream, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Backend ¶
type Backend struct {
// contains filtered or unexported fields
}
Backend owns a bounded number of local subscriptions. It starts no goroutines, does not share process-global state, and never becomes a Redis failure fallback.
func (*Backend) FoundryAdapter ¶
func (*Backend) FoundryAdapter(frameworkadapter.Seal)
FoundryAdapter marks the backend as framework-owned adapter I/O.
Source Files
Click to show internal directories.
Click to hide internal directories.