jetstream

Documentation

Index

• func NewJetStreamBufferReader(ctx context.Context, client clients.JetStreamClient, ...) (isb.BufferReader, error)
• func NewJetStreamBufferWriter(ctx context.Context, client clients.JetStreamClient, ...) (isb.BufferWriter, error)
• type ReadOption
  • func WithReadTimeOut(timeout time.Duration) ReadOption
• type WriteOption
  • func WithBufferUsageLimit(usageLimit float64) WriteOption
  • func WithMaxLength(length int64) WriteOption
  • func WithRefreshInterval(refreshInterval time.Duration) WriteOption

Functions

func NewJetStreamBufferReader

func NewJetStreamBufferReader(ctx context.Context, client clients.JetStreamClient, name, stream, subject string, opts ...ReadOption) (isb.BufferReader, error)

NewJetStreamBufferReader is used to provide a new JetStream buffer reader connection

func NewJetStreamBufferWriter

func NewJetStreamBufferWriter(ctx context.Context, client clients.JetStreamClient, name, stream, subject string, opts ...WriteOption) (isb.BufferWriter, error)

NewJetStreamBufferWriter is used to provide a new instance of JetStreamBufferWriter

Types

type ReadOption

type ReadOption func(*readOptions) error

func WithReadTimeOut

func WithReadTimeOut(timeout time.Duration) ReadOption

WithReadTimeOut is used to set read timeout option

type WriteOption

type WriteOption func(*writeOptions) error

func WithBufferUsageLimit

func WithBufferUsageLimit(usageLimit float64) WriteOption

WithBufferUsageLimit sets buffer usage limit option

func WithMaxLength

func WithMaxLength(length int64) WriteOption

WithMaxLength sets buffer max length option

func WithRefreshInterval

func WithRefreshInterval(refreshInterval time.Duration) WriteOption

WithRefreshInterval sets refresh interval option