Versions in this module Expand all Collapse all v0 v0.11.2 Aug 12, 2026 Changes in this version + const HeaderTimestamp + func ValidatePipelineID(id string) error + type Option func(*config) error + func WithErrorHandler(fn func(error)) Option + func WithPrefix(prefix string) Option + type Transport struct + func New(conn *nats.Conn, opts ...Option) (Transport, error) + func (t Transport) PublishDiagnosis(ctx context.Context, msg toc.DiagnosisMessage) error + func (t Transport) PublishObservations(ctx context.Context, batch toc.ObservationBatch) error + func (t Transport) SubscribeAllDiagnosis(ctx context.Context, fn toc.DiagnosisHandler) (toc.Subscription, error) + func (t Transport) SubscribeAllObservations(ctx context.Context, fn toc.ObservationHandler) (toc.Subscription, error) + func (t Transport) SubscribeDiagnosis(ctx context.Context, pipelineID string, fn toc.DiagnosisHandler) (toc.Subscription, error) + func (t Transport) SubscribeObservations(ctx context.Context, pipelineID string, fn toc.ObservationHandler) (toc.Subscription, error)
Go to main page