Versions in this module Expand all Collapse all v0 v0.3.1 May 11, 2023 v0.3.0 Sep 27, 2022 Changes in this version + type Writer struct + func NewWriter(ctx context.Context, params WriterParams) (*Writer, error) + func (w *Writer) Close(ctx context.Context) error + func (w *Writer) Write(ctx context.Context, record sdk.Record) error + type WriterParams struct + Conn *nats.Conn + RetryAttempts int + RetryWait time.Duration + Subject string
Go to main page