dds

Jun 17, 2026

Changes in this version

+ var ErrAccessDenied = errors.New("dds: access denied by topic ACL")

Jun 17, 2026

Changes in this version

+ var ErrDomainOutOfRange = fmt.Errorf("dds: domain out of range [0,232]: %w", ErrNotConnected)

+ func ValidateDomain(d Domain) error

Jun 17, 2026

Changes in this version

+ const SpecVersion

+ var ErrNotConnected = fmt.Errorf("dds: not connected: %w", relay.ErrNotConnected)

+ var ErrTimeout = fmt.Errorf("dds: timeout: %w", relay.ErrTimeout)

+ func Adapt(p Participant) relay.Node

type Metrics

+ ErrorCount uint64

type Sample

+ func FromMessage(m relay.Message) (Sample, error)

+ func (s Sample) ToMessage() relay.Message

Jun 11, 2026

Changes in this version

+ var ErrLoanBuffer = errors.New("dds: loan buffer unavailable or invalid")

+ type LoaningPublisher interface

+ Commit func(buf []byte) error

+ Loan func(size int) ([]byte, error)

Jun 8, 2026

Changes in this version

+ type ProtoCodec struct

+ func (ProtoCodec[T]) Marshal(v T) ([]byte, error)

+ func (ProtoCodec[T]) Unmarshal(data []byte) (T, error)

type WaitSet

+ func (ws *WaitSet) Attach(subs ...Subscriber) *WaitSet

+ func (ws *WaitSet) Detach(subs ...Subscriber) *WaitSet

Jun 8, 2026

Changes in this version

+ var ErrDeadlineMissed = errors.New("dds: deadline missed — no sample within QoS.Deadline period")

+ var ErrQoSMismatch = errors.New("dds: QoS incompatibility between publisher and subscriber")

+ var ErrResourceLimits = errors.New("dds: resource limit exceeded")

+ var ErrSampleRejected = errors.New("dds: sample rejected — resource limits exceeded")

+ type GobCodec struct

+ func (GobCodec[T]) Marshal(v T) ([]byte, error)

+ func (GobCodec[T]) Unmarshal(data []byte) (T, error)

type Participant

+ Domain func() Domain

type Publisher

+ WriteCtx func(ctx context.Context, payload []byte) error

type Sample

+ SequenceNumber uint64

+ WriterGUID GUID

type Subscriber

+ TryRead func() (Sample, bool)

+ Unsubscribe func() error

type SubscriberConfig

+ DeadlineMissedCallback func()

type SubscriberOption

+ func WithDeadlineMissed(fn func()) SubscriberOption

type TypedPublisher

+ func (tp *TypedPublisher[T]) WriteCtx(ctx context.Context, v T) error

type TypedSample

+ SequenceNumber uint64

+ WriterGUID GUID

Jun 7, 2026

Changes in this version

+ type DiscoveryMetrics struct

+ AnnouncesReceived uint64

+ AnnouncesSent uint64

+ EndpointMatches uint64

+ PeerEvictions uint64

+ PeersKnown uint64

+ type DiscoveryMetricsProvider interface

+ DiscoveryMetrics func() DiscoveryMetrics

+ type Health struct

+ Details map[string]string

+ Status HealthStatus

+ type HealthProvider interface

+ Health func() Health

+ type HealthStatus int

+ const HealthDegraded

+ const HealthDown

+ const HealthOK

+ func (h HealthStatus) String() string

+ type TopicMetrics struct

+ BytesDelivered uint64

+ BytesWritten uint64

+ DeliverCount uint64

+ DropCount uint64

+ Topic string

+ WriteCount uint64

+ type TopicMetricsProvider interface

+ TopicMetrics func() []TopicMetrics

Jun 7, 2026

Changes in this version

+ var ErrPayloadTooLarge = errors.New("dds: payload exceeds QoS MaxSampleSize")

type QoS

+ LatencyBudget time.Duration

+ Lifespan time.Duration

+ MaxSampleSize int

+ PublishPeriod time.Duration

+ TransportPriority int

Jun 7, 2026

Changes in this version

+ func CloseWithDrain(ctx context.Context, p Participant) error

+ type BackPressurePolicy int

+ const Block

+ const DropNewest

+ const DropOldest

+ type Codec interface

+ Marshal func(v T) ([]byte, error)

+ Unmarshal func(data []byte) (T, error)

+ type Drainer interface

+ CloseWithDrain func(ctx context.Context) error

+ type GUID [16]byte

+ type JSONCodec struct

+ func (JSONCodec[T]) Marshal(v T) ([]byte, error)

+ func (JSONCodec[T]) Unmarshal(data []byte) (T, error)

+ type LivelinessEvent int

+ const LivelinessGained

+ const LivelinessLost

type Sample

+ Timestamp time.Time

+ type Span interface

+ End func()

+ SetAttribute func(key, value string)

+ type SpanAttribute struct

+ Key string

+ Value string

type SubscriberConfig

+ BackPressure BackPressurePolicy

+ ChannelDepth int

+ func (c SubscriberConfig) ChanDepth(defaultDepth int) int

type SubscriberOption

+ func WithBackPressure(policy BackPressurePolicy) SubscriberOption

+ func WithChannelDepth(n int) SubscriberOption

+ type Tracer interface

+ Start func(ctx context.Context, spanName string, attrs ...SpanAttribute) (context.Context, Span)

+ var NoopTracer Tracer = noopTracerImpl{}

+ type TypedPublisher struct

+ func NewTypedPublisher[T any](pub Publisher, codec Codec[T]) *TypedPublisher[T]

+ func (tp *TypedPublisher[T]) Close() error

+ func (tp *TypedPublisher[T]) Write(v T) error

+ type TypedSample struct

+ Timestamp time.Time

+ Topic string

+ Value T

+ type TypedSubscriber struct

+ func NewTypedSubscriber[T any](sub Subscriber, codec Codec[T]) *TypedSubscriber[T]

+ func (ts *TypedSubscriber[T]) C() <-chan TypedSample[T]

+ func (ts *TypedSubscriber[T]) Close() error

Jun 7, 2026

Changes in this version

+ var ErrClosed = errors.New("dds: entity is closed")

+ var ErrTopicEmpty = errors.New("dds: topic name must not be empty")

+ type Metrics struct

+ BytesDelivered uint64

+ BytesWritten uint64

+ DeliverCount uint64

+ DropCount uint64

+ WriteCount uint64

+ type MetricsProvider interface

+ Metrics func() Metrics

type QoS

+ Deadline time.Duration

+ type SubscriberConfig struct

+ Filter func(Sample) bool

+ func ApplySubscriberOpts(opts []SubscriberOption) SubscriberConfig

+ type SubscriberOption func(*SubscriberConfig)

+ func WithFilter(fn func(Sample) bool) SubscriberOption

Jun 7, 2026

Changes in this version

+ var DefaultQoS = QoS

+ var ReliableQoS = QoS

+ type Domain int

+ type DurabilityKind int

+ const TransientLocal

+ const Volatile

+ type Participant interface

+ Close func() error

+ NewPublisher func(topic string, qos QoS) (Publisher, error)

+ NewSubscriber func(topic string, qos QoS) (Subscriber, error)

+ type Publisher interface

+ Close func() error

+ Write func(payload []byte) error

+ type QoS struct

+ Durability DurabilityKind

+ HistoryDepth int

+ Reliability ReliabilityKind

+ type ReliabilityKind int

+ const BestEffort

+ const Reliable

+ type Sample struct

+ Payload []byte

+ Topic string

+ type Subscriber interface

+ C func() <-chan Sample

+ Close func() error

+ type WaitSet struct

+ func NewWaitSet(subs ...Subscriber) *WaitSet

+ func (ws *WaitSet) Wait(ctx context.Context) (Sample, Subscriber, error)