jetstream

Documentation

Index

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

Functions

func NewJetStreamBufferReader

func NewJetStreamBufferReader(ctx context.Context, client jsclient.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 jsclient.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 WithAckInfoCheckInterval

func WithAckInfoCheckInterval(t time.Duration) ReadOption

WithAckInfoCheckInterval is used to set the periodical ack information check interval

func WithReadTimeOut

func WithReadTimeOut(timeout time.Duration) ReadOption

WithReadTimeOut is used to set read timeout option

func WithUsingAckInfoAsRate

func WithUsingAckInfoAsRate(yes bool) ReadOption

WithUsingAckInfoAsRate is used to set whether to run ack information check in the reader, which is for ack rate calculation

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

func WithUsingWriteInfoAsRate

func WithUsingWriteInfoAsRate(yes bool) WriteOption

WithUsingWriteInfoAsRate sets whether to check sequence for rate calculation