stream

Documentation

Index

• type FixedSizeObserver
  • func NewFixedSizeObserver[T interface{}](ctx context.Context, maxSize int, waitElementsInterval time.Duration, ...) *FixedSizeObserver[T]
  • func (q *FixedSizeObserver[T]) Ack(msgId uint64)
  • func (q *FixedSizeObserver[T]) GetLength() int
  • func (q *FixedSizeObserver[T]) Publish(element T) uint64
  • func (q *FixedSizeObserver[T]) Release()
  • func (q *FixedSizeObserver[T]) Subscribe(ctx context.Context) <-chan T
  • func (q *FixedSizeObserver[T]) WaitAck(msgId uint64)

Types

type FixedSizeObserver

type FixedSizeObserver[T interface{}] struct {
	// contains filtered or unexported fields
}

func NewFixedSizeObserver

func NewFixedSizeObserver[T interface{}](
	ctx context.Context,
	maxSize int,
	waitElementsInterval time.Duration,
	waitSubscribersInterval time.Duration,
	skipElements bool,
	skipWithoutSubscribers bool,
	acquiringRequired bool,
	retriesMaxCount int,
) *FixedSizeObserver[T]

func (*FixedSizeObserver[T]) Ack

func (q *FixedSizeObserver[T]) Ack(msgId uint64)

func (*FixedSizeObserver[T]) GetLength

func (q *FixedSizeObserver[T]) GetLength() int

func (*FixedSizeObserver[T]) Publish

func (q *FixedSizeObserver[T]) Publish(element T) uint64

func (*FixedSizeObserver[T]) Release

func (q *FixedSizeObserver[T]) Release()

func (*FixedSizeObserver[T]) Subscribe

func (q *FixedSizeObserver[T]) Subscribe(ctx context.Context) <-chan T

func (*FixedSizeObserver[T]) WaitAck

func (q *FixedSizeObserver[T]) WaitAck(msgId uint64)