Versions in this module Expand all Collapse all v1 v1.1.0 May 12, 2026 v1.0.13 May 12, 2026 Changes in this version + type AddEvent func(*AddEventOptions) + func WithOnlyIfStreamExists() AddEvent + func WithTopic(topic string) AddEvent + type AddEventOptions struct + OnlyIfStreamExists bool + Topic string + func ParseAddEventOptions(opts ...AddEvent) AddEventOptions + type AddStream func(*AddStreamOptions) + func WithAddStreamStartAfter(id string) AddStream + func WithAddStreamStartAt(startAt time.Time) AddStream + func WithAddStreamStartAtNewest() AddStream + func WithAddStreamStartAtOldest() AddStream + type AddStreamOptions struct + LastEventID string + func ParseAddStreamOptions(opts ...AddStream) AddStreamOptions + type Reader func(*ReaderOptions) + func WithReaderBlockDuration(d time.Duration) Reader + func WithReaderBufferSize(size int) Reader + func WithReaderMaxPolled(n int64) Reader + func WithReaderStartAfter(id string) Reader + func WithReaderStartAt(startAt time.Time) Reader + func WithReaderStartAtNewest() Reader + func WithReaderStartAtOldest() Reader + func WithReaderTopic(topic string) Reader + func WithReaderTopicPattern(pattern string) Reader + type ReaderOptions struct + BlockDuration time.Duration + BufferSize int + LastEventID string + MaxPolled int64 + Topic string + TopicPattern string + func ParseReaderOptions(opts ...Reader) ReaderOptions + type Sink func(*SinkOptions) + func WithSinkAckGracePeriod(d time.Duration) Sink + func WithSinkBlockDuration(d time.Duration) Sink + func WithSinkBufferSize(size int) Sink + func WithSinkMaxPolled(n int64) Sink + func WithSinkNoAck() Sink + func WithSinkStartAfter(id string) Sink + func WithSinkStartAt(startAt time.Time) Sink + func WithSinkStartAtNewest() Sink + func WithSinkStartAtOldest() Sink + func WithSinkTopic(topic string) Sink + func WithSinkTopicPattern(pattern string) Sink + type SinkOptions struct + AckGracePeriod time.Duration + BlockDuration time.Duration + BufferSize int + LastEventID string + MaxPolled int64 + NoAck bool + Topic string + TopicPattern string + func ParseSinkOptions(opts ...Sink) SinkOptions + type Stream func(*StreamOptions) + func WithStreamLogger(logger pulse.Logger) Stream + func WithStreamMaxLen(len int) Stream + func WithStreamSlidingTTL(ttl time.Duration) Stream + func WithStreamTTL(ttl time.Duration) Stream + type StreamOptions struct + Logger pulse.Logger + MaxLen int + TTL time.Duration + TTLSliding bool + func ParseStreamOptions(opts ...Stream) StreamOptions
Go to main page