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 Iterator struct + func NewIterator(ctx context.Context, params IteratorParams) (*Iterator, error) + func (i *Iterator) Ack(ctx context.Context, sdkPosition sdk.Position) error + func (i *Iterator) HasNext(ctx context.Context) bool + func (i *Iterator) Next(ctx context.Context) (sdk.Record, error) + func (i *Iterator) Stop() (err error) + type IteratorParams struct + AckPolicy nats.AckPolicy + BufferSize int + Conn *nats.Conn + DeliverPolicy nats.DeliverPolicy + DeliverSubject string + Durable string + SDKPosition sdk.Position + Subject string
Go to main page